1. <?php
3. namespace App\Controller;
5. use App\Entity\Addresses;
6. use App\Entity\AiProducts;
7. use App\Entity\AiProductsSpecies;
8. use App\Entity\Api;
9. use App\Entity\ApiDetails;
10. use App\Entity\AvailabilityTracker;
11. use App\Entity\Clinics;
12. use App\Entity\ClinicUsers;
13. use App\Entity\Countries;
14. use App\Entity\CronJob;
15. use App\Entity\DistributorProducts;
16. use App\Entity\Distributors;
17. use App\Entity\DistributorUserPermissions;
18. use App\Entity\DistributorUsers;
19. use App\Entity\Notifications;
20. use App\Entity\Products;
21. use App\Entity\RefreshTokens;
22. use App\Entity\RestrictedDomains;
23. use App\Entity\ScraperUrls;
24. use App\Entity\Tracking;
25. use App\Entity\UserPermissions;
26. use App\Form\AddressesFormType;
27. use App\Form\DistributorFormType;
28. use App\Form\DistributorUsersFormType;
29. use App\Services\PaginationManager;
30. use Doctrine\ORM\EntityManagerInterface;
31. use Nzo\UrlEncryptorBundle\Encryptor\Encryptor;
32. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
33. use Symfony\Component\HttpFoundation\BinaryFileResponse;
34. use Symfony\Component\HttpFoundation\JsonResponse;
35. use Symfony\Component\HttpFoundation\Request;
36. use Symfony\Component\HttpFoundation\RequestStack;
37. use Symfony\Component\HttpFoundation\Response;
38. use Symfony\Component\HttpFoundation\ResponseHeaderBag;
39. use Symfony\Component\Mailer\MailerInterface;
40. use Symfony\Component\PasswordHasher\Hasher\UserPasswordHasherInterface;
41. use Symfony\Component\Routing\Annotation\Route;
42. use Symfony\Component\Security\Csrf\TokenStorage\TokenStorageInterface;
43. use Symfony\Component\Lock\LockFactory;
44. use Symfony\Component\Lock\Store\FlockStore;
46. class DistributorsController extends AbstractController
47. {
48. private $em;
49. const ITEMS_PER_PAGE = 10;
50. private $pageManager;
51. private $requestStack;
52. private $plainPassword;
53. private $encryptor;
55. public function __construct(EntityManagerInterface $em, PaginationManager $pagination, RequestStack $requestStack, Encryptor $encryptor)
56. {
57. $this->em = $em;
58. $this->pageManager = $pagination;
59. $this->requestStack = $requestStack;
60. $this->encryptor = $encryptor;
61. }
63. #[Route('/distributors/dashboard', name: 'distributor_dashboard')]
64. #[Route('/distributors/account', name: 'distributor_account')]
65. #[Route('/distributors/about', name: 'distributor_about')]
66. #[Route('/distributors/operating-hours', name: 'distributor_operating_hours')]
67. #[Route('/distributors/refund-policy', name: 'distributor_refund_policy')]
68. #[Route('/distributors/sales-tax-policy', name: 'distributor_sales_tax_policy')]
69. #[Route('/distributors/shipping-policy', name: 'distributor_shipping_policy')]
70. #[Route('/distributors/manage-inventory', name: 'distributor_manage_inventory')]
71. #[Route('/distributors/users', name: 'distributor_get_users')]
72. #[Route('/distributors/order/{order_id}', name: 'distributor_order')]
73. #[Route('/distributors/orders/{distributor_id}', name: 'distributor_order_list')]
74. #[Route('/distributors/customers/1', name: 'distributor_customer_list')]
75. #[Route('/distributors/inventory/list', name: 'distributor_inventory_list')]
76. public function distributorDashboardAction(Request $request): Response
77. {
78. if($this->getUser()->getUserIdentifier() == null){
80. $this->addFlash('danger', 'Your session expired due to inactivity, please login.');
82. return $this->redirectToRoute('distributor_login');
83. }
85. $distributor = $this->getUser()->getDistributor();
86. $user = $this->getUser();
87. $username = $distributor->getDistributorName();
89. $permissions = [];
91. foreach($user->getDistributorUserPermissions() as $permission){
93. $permissions[] = $permission->getPermission()->getId();
94. }
96. return $this->render('frontend/distributors/index.html.twig',[
97. 'distributor' => $distributor,
98. 'permissions' => json_encode($permissions),
99. 'username' => $username,
100. ]);
101. }
103. #[Route('/distributors/register', name: 'distributor_reg')]
104. public function distributorReg(Request $request): Response
105. {
106. $countries = $this->em->getRepository(Countries::class)->findBy([
107. 'isActive' => 1,
108. ]);
109. $form = $this->createRegisterForm();
111. return $this->render('frontend/distributors/register.html.twig', [
112. 'form' => $form->createView(),
113. 'countries' => $countries
114. ]);
115. }
117. #[Route('/sellers', name: 'sellers_page')]
118. public function sellersAction(Request $request): Response
119. {
120. $sellers = $this->em->getRepository(Distributors::class)->findBy([
121. 'isApproved' => true,
122. ]);
124. return $this->render('frontend/sellers.html.twig', [
125. 'sellers' => $sellers,
126. ]);
127. }
129. protected function createRegisterForm()
130. {
131. $distributors = new Distributors();
133. return $this->createForm(DistributorFormType::class, $distributors);
134. }
136. #[Route('/distributors/register/check-email', name: 'distributor_check_email')]
137. public function distributorsCheckEmailAction(Request $request): Response
138. {
139. $email = $request->request->get('email');
140. $domainName = explode('@', $email);
141. $response['response'] = true;
142. $firstName = '';
143. $restrictedDomains = $this->em->getRepository(RestrictedDomains::class)->arrayFindAll();
145. foreach($restrictedDomains as $restrictedDomain)
146. {
147. if(md5($domainName[1]) == md5($restrictedDomain->getName()))
148. {
149. $response['response'] = false;
150. $response['restricted'] = true;
152. return new JsonResponse($response);
153. }
154. }
156. $distributor = $this->em->getRepository(Distributors::class)->findOneBy([
157. 'hashedEmail' => md5($email),
158. ]);
160. $distributorDomain = $this->em->getRepository(Distributors::class)->findOneBy([
161. 'domainName' => md5($domainName[1]),
162. ]);
164. $distributorUsers = $this->em->getRepository(DistributorUsers::class)->findOneBy([
165. 'hashedEmail' => md5($email),
166. ]);
168. $clinic = $this->em->getRepository(Clinics::class)->findOneBy([
169. 'hashedEmail' => md5($email),
170. ]);
172. $clinicDomain = $this->em->getRepository(Clinics::class)->findOneBy([
173. 'domainName' => md5($domainName[1]),
174. ]);
176. $clinicUsers = $this->em->getRepository(ClinicUsers::class)->findOneBy([
177. 'hashedEmail' => md5($email),
178. ]);
180. if($clinicDomain != null)
181. {
182. $user = $this->em->getRepository(ClinicUsers::class)->findOneBy([
183. 'clinic' => $clinicDomain->getId(),
184. 'isPrimary' => 1
185. ]);
186. $firstName = $this->encryptor->decrypt($user->getFirstName());
187. }
189. if($distributorDomain != null)
190. {
191. $user = $this->em->getRepository(DistributorUsers::class)->findOneBy([
192. 'distributor' => $distributorDomain->getId(),
193. 'isPrimary' => 1
194. ]);
195. $firstName = $this->encryptor->decrypt($user->getFirstName());
196. }
198. $response['firstName'] = $firstName;
200. if($distributor != null || $distributorUsers != null || $clinic != null || $clinicUsers != null || $clinicDomain != null || $distributorDomain != null)
201. {
202. $response['response'] = false;
203. $response['restricted'] = false;
204. }
206. return new JsonResponse($response);
207. }
209. #[Route('/distributor/addresses', name: 'distributor_addresses')]
210. public function createDistributorAddressesForm()
211. {
212. $addresses = new Addresses();
214. return $this->createForm(AddressesFormType::class, $addresses);
215. }
217. #[Route('/distributor/register/create', name: 'distributor_create')]
218. public function distributorCreateAction(Request $request, UserPasswordHasherInterface $passwordHasher, MailerInterface $mailer): Response
219. {
220. $data = $request->request;
221. $distributor = $this->em->getRepository(Distributors::class)->findOneBy(['email' => $data->get('email')]);
222. $countries = $this->em->getRepository(Countries::class)->find($data->get('country'));
223. $tracking = $this->em->getRepository(Tracking::class)->find(3);
225. if($distributor == null) {
227. $distributors = new Distributors();
229. $plainTextPwd = $this->generatePassword();
231. if (!empty($plainTextPwd)) {
233. $domainName = explode('@', $data->get('email'));
235. $distributors->setDistributorName($this->encryptor->encrypt($data->get('distributor-name')));
236. $distributors->setName($data->get('distributor-name'));
237. $distributors->setEmail($this->encryptor->encrypt($data->get('email')));
238. $distributors->setHashedEmail(md5($data->get('email')));
239. $distributors->setDomainName(md5($domainName[1]));
240. $distributors->setTelephone($this->encryptor->encrypt($data->get('telephone')));
241. $distributors->setIntlCode($this->encryptor->encrypt($data->get('intl-code')));
242. $distributors->setIsoCode($this->encryptor->encrypt($data->get('iso-code')));
243. $distributors->setAddressCountry($countries);
244. $distributors->setTracking($tracking);
245. $distributors->setIsApproved(0);
247. $this->em->persist($distributors);
248. $this->em->flush();
250. // Create user
251. $distributor = $this->em->getRepository(Distributors::class)->findOneBy([
252. 'hashedEmail' => md5($data->get('email')),
253. ]);
254. $distributorUsers = new DistributorUsers();
256. $hashed_pwd = $passwordHasher->hashPassword($distributorUsers, $plainTextPwd);
258. $distributorUsers->setDistributor($distributor);
259. $distributorUsers->setFirstName($this->encryptor->encrypt($data->get('first-name')));
260. $distributorUsers->setLastName($this->encryptor->encrypt($data->get('last-name')));
261. $distributorUsers->setPosition($this->encryptor->encrypt($data->get('position')));
262. $distributorUsers->setEmail($this->encryptor->encrypt($data->get('email')));
263. $distributorUsers->setHashedEmail(md5($data->get('email')));
264. $distributorUsers->setTelephone($this->encryptor->encrypt($data->get('telephone')));
265. $distributorUsers->setRoles(['ROLE_DISTRIBUTOR']);
266. $distributorUsers->setPassword($hashed_pwd);
267. $distributorUsers->setIsPrimary(1);
269. $this->em->persist($distributorUsers);
270. $this->em->flush();
272. // Assign User Permissions
273. $userPermissions = $this->em->getRepository(UserPermissions::class)->findBy([
274. 'isDistributor' => 1,
275. ]);
277. foreach($userPermissions as $userPermission){
279. $distributorUserPermissions = new DistributorUserPermissions();
281. $distributorUserPermissions->setUser($distributorUsers);
282. $distributorUserPermissions->setDistributor($distributors);
283. $distributorUserPermissions->setPermission($userPermission);
285. $this->em->persist($distributorUserPermissions);
286. }
288. $this->em->flush();
290. // Send Email
291. $body = '<table style="padding: 8px; border-collapse: collapse; border: none; font-family: arial">';
292. $body .= '<tr><td colspan="2">Hi '. $data->get('first_name') .',</td></tr>';
293. $body .= '<tr><td colspan="2">&nbsp;</td></tr>';
294. $body .= '<tr><td colspan="2">Please use the credentials below login to the Fluid Backend.</td></tr>';
295. $body .= '<tr><td colspan="2">&nbsp;</td></tr>';
296. $body .= '<tr>';
297. $body .= ' <td><b>URL: </b></td>';
298. $body .= ' <td><a href="https://'. $_SERVER['HTTP_HOST'] .'/distributors/login">https://'. $_SERVER['HTTP_HOST'] .'/distributor/login</a></td>';
299. $body .= '</tr>';
300. $body .= '<tr>';
301. $body .= ' <td><b>Username: </b></td>';
302. $body .= ' <td>'. $data->get('email') .'</td>';
303. $body .= '</tr>';
304. $body .= '<tr>';
305. $body .= ' <td><b>Password: </b></td>';
306. $body .= ' <td>'. $plainTextPwd .'</td>';
307. $body .= '</tr>';
308. $body .= '</table>';
310. $subject = 'Fluid Login Credentials';
311. $to = $data->get('email');
313. exec(__DIR__ . '/../../bin/console app:send-email "'. $subject .'" "'. addslashes($body) .'" "'. $to .'" "" "" "'. true .'" > /dev/null 2>&1 &');
314. }
316. $response = '
317. <div class="row pt-3">
318. <div class="col-12 text-center mt-1 pt-3 pb-3" id="order_header">
319. <h4 class="text-primary">Let\'s Create Your Account.</h4>
320. <span class="text-primary">
321. Your Fluid account was successfully created, an email with your login credentials has been sent to your inbox.
322. </span>
323. </div>';
325. } else {
327. $response = false;
328. }
330. return new JsonResponse($response);
331. }
333. #[Route('/distributors/get/company-information', name: 'get_company_information')]
334. public function getCompanyInformation(Request $request): Response
335. {
336. $distributorId = $this->getUser()->getDistributor()->getId();
337. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
338. $countries = $this->em->getRepository(Countries::class)->findAll();
340. $html = $this->render('frontend/distributors/company_information.html.twig', [
341. 'distributor' => $distributor,
342. 'countries' => $countries,
343. ])->getContent();
345. return new JsonResponse($html);
346. }
348. private function generatePassword(): string
349. {
350. $curl = curl_init();
352. curl_setopt_array($curl, array(
353. CURLOPT_URL => 'https://www.dinopass.com/password/simple',
354. CURLOPT_RETURNTRANSFER => true,
355. CURLOPT_ENCODING => '',
356. CURLOPT_MAXREDIRS => 10,
357. CURLOPT_TIMEOUT => 0,
358. CURLOPT_FOLLOWLOCATION => true,
359. CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
360. CURLOPT_CUSTOMREQUEST => 'GET',
361. ));
363. $response = curl_exec($curl);
365. curl_close($curl);
367. $this->plainPassword = $response;
369. return $this->plainPassword;
370. }
372. public function createDistributorUserForm()
373. {
374. $distributorUsers = new DistributorUsers();
376. return $this->createForm(DistributorUsersFormType::class, $distributorUsers);
377. }
379. #[Route('/distributors/update/company-information', name: 'distributor_update_company_information')]
380. public function distributorUpdateCompanyInformationAction(Request $request): Response
381. {
382. $data = $request->request->all('distributor_form');
384. $distributor = $this->getUser()->getDistributor();
385. $countryId = (int) $data['addressCountry'];
386. $logo = '';
387. $country = $this->em->getRepository(Countries::class)->find($countryId);
388. $isApproved = (bool) $distributor->getIsApproved() ?? false;
389. $tradeLicense = $_FILES['distributor_form']['name']['trade-license-file'];
390. $tradeLicenseNo = $data['trade-license-no'];
391. $tradeLicenseExpDate = $data['trade-license-exp-date'];
393. // Account approval required if reg docs change
394. if(
395. !empty($tradeLicense) || $tradeLicenseNo != $this->encryptor->decrypt($distributor->getTradeLicenseNo()) ||
396. $tradeLicenseExpDate != $distributor->getTradeLicenseExpDate()->format('Y-m-d')
397. )
398. {
399. $distributor->setIsApproved(0);
400. $isApproved = false;
401. }
403. if($distributor != null)
404. {
405. $domainName = explode('@', $data['email']);
407. $distributor->setDistributorName($this->encryptor->encrypt($data['distributor-name']));
408. $distributor->setName($data['distributor-name']);
409. $distributor->setTelephone($this->encryptor->encrypt($data['telephone']));
410. $distributor->setEmail($this->encryptor->encrypt($data['email']));
411. $distributor->setWebsite($this->encryptor->encrypt($data['website']));
412. $distributor->setDomainName(md5($domainName[1]));
413. $distributor->setAddressCountry($country);
414. $distributor->setAddressStreet($this->encryptor->encrypt($data['address-street']));
415. $distributor->setAddressCity($this->encryptor->encrypt($data['address-city']));
416. $distributor->setAddressPostalCode($this->encryptor->encrypt($data['address-postal-code']));
417. $distributor->setAddressState($this->encryptor->encrypt($data['address-state']));
418. $distributor->setIsoCode($this->encryptor->encrypt($data['iso-code']));
419. $distributor->setIntlCode($this->encryptor->encrypt($data['intl-code']));
420. $distributor->setManagerFirstName($this->encryptor->encrypt($data['manager-first-name']));
421. $distributor->setManagerLastName($this->encryptor->encrypt($data['manager-last-name']));
422. $distributor->setManagerIdNo($this->encryptor->encrypt($data['manager-id-no']));
423. $distributor->setManagerIdExpDate(new \DateTime($data['manager-id-exp-date']));
424. $distributor->setTradeLicenseNo($this->encryptor->encrypt($data['trade-license-no']));
425. $distributor->setTradeLicenseExpDate(new \DateTime($data['trade-license-exp-date']));
427. if(!empty($_FILES['distributor_form']['name']['trade-license-file']))
428. {
429. $extension = pathinfo($_FILES['distributor_form']['name']['trade-license-file'], PATHINFO_EXTENSION);
430. $file = $distributor->getId() . '-' . uniqid() . '.' . $extension;
431. $targetFile = __DIR__ . '/../../public/documents/' . $file;
433. if(move_uploaded_file($_FILES['distributor_form']['tmp_name']['trade-license-file'], $targetFile))
434. {
435. $distributor->setTradeLicense($file);
436. }
437. }
439. if(!empty($_FILES['distributor_form']['name']['logo']))
440. {
441. $extension = pathinfo($_FILES['distributor_form']['name']['logo'], PATHINFO_EXTENSION);
442. $file = $distributor->getId() . '-' . uniqid() . '.' . $extension;
443. $targetFile = __DIR__ . '/../../public/images/logos/' . $file;
445. if (move_uploaded_file($_FILES['distributor_form']['tmp_name']['logo'], $targetFile))
446. {
447. $distributor->setLogo($file);
448. $logo = $file;
449. }
450. }
452. $this->em->persist($distributor);
453. $this->em->flush();
455. // Send Approval Email
456. if(!$isApproved)
457. {
458. $orderUrl = $this->getParameter('app.base_url') . '/admin/distributor/'. $distributor->getId();
459. $html = '<p>Please <a href="'. $orderUrl .'">click here</a> to view the distributors details.</p><br>';
461. $html = $this->forward('App\Controller\ResetPasswordController::emailFooter', [
462. 'html' => $html,
463. ]);
465. $subject = 'Fluid - Account Approval Request';
466. $to = $this->getParameter('app.email_admin');
468. exec(__DIR__ . '/../../bin/console app:send-email "'. $subject .'" "'. addslashes($html) .'" "'. $to .'" "" "" "'. true .'" > /dev/null 2>&1 &');
469. }
471. $message = '<b><i class="fa-solid fa-circle-check"></i></i></b> Company details successfully updated.<div class="flash-close"><i class="fa-solid fa-xmark"></i></div>';
472. }
473. else
474. {
475. $message = '<b><i class="fas fa-check-circle"></i> Personal details successfully updated.';
476. }
478. $response = [
479. 'message' => $message,
480. 'logo' => $logo,
481. ];
483. return new JsonResponse($response);
484. }
486. #[Route('/distributors/download/trade-license/{tradeLicense}', name: 'distributors_download_trade_license')]
487. public function distributorDownloadTradeLicenseAction(Request $request)
488. {
489. $path = __DIR__ . '/../../public/documents/';
490. $tradeLicense = $path . $request->get('tradeLicense');
491. $response = new BinaryFileResponse($tradeLicense);
493. $response->setContentDisposition(
494. ResponseHeaderBag::DISPOSITION_ATTACHMENT,
495. basename($tradeLicense)
496. );
498. return $response;
499. }
501. #[Route('/distributors/update/about_us', name: 'distributor_update_about_us')]
502. public function distributorUpdateAboutUsAction(Request $request): Response
503. {
504. $data = $request->request;
505. $distributor = $this->getUser()->getDistributor();
507. if($distributor != null)
508. {
509. $about = $data->get('about-us');
511. if(!empty($about))
512. {
513. $distributor->setAbout($about);
515. $this->em->persist($distributor);
516. $this->em->flush();
517. }
519. $response = '<b><i class="fa-solid fa-circle-check"></i></i></b> About us successfully updated.<div class="flash-close"><i class="fa-solid fa-xmark"></i></div>';
520. }
521. else
522. {
523. $response = '<b><i class="fas fa-check-circle"></i> An error occurred.';
524. }
526. return new JsonResponse($response);
527. }
529. #[Route('/distributors/update/operating_hours', name: 'distributor_update_operating_hours')]
530. public function distributorUpdateOperatingHoursAction(Request $request): Response
531. {
532. $data = $request->request;
533. $distributor = $this->getUser()->getDistributor();
535. if($distributor != null)
536. {
537. if(!empty($data->get('operating-hours')))
538. {
539. $distributor->setOperatingHours($data->get('operating-hours'));
540. }
542. $this->em->persist($distributor);
543. $this->em->flush();
545. $response = '<b><i class="fa-solid fa-circle-check"></i></i></b> Operating hours successfully updated.<div class="flash-close"><i class="fa-solid fa-xmark"></i></div>';
546. }
547. else
548. {
549. $response = '<b><i class="fas fa-check-circle"></i> Personal details successfully updated.';
550. }
552. return new JsonResponse($response);
553. }
555. #[Route('/distributors/update/refund_policy', name: 'distributor_update_refund_policy')]
556. public function distributorUpdateRefundPolicyAction(Request $request): Response
557. {
558. $data = $request->request;
559. $distributor = $this->getUser()->getDistributor();
561. if($distributor != null)
562. {
563. if(!empty($data->get('refund-policy')))
564. {
565. $distributor->setRefundPolicy($data->get('refund-policy'));
566. }
568. $this->em->persist($distributor);
569. $this->em->flush();
571. $response = '<b><i class="fa-solid fa-circle-check"></i></i></b> Refund policy successfully updated.<div class="flash-close"><i class="fa-solid fa-xmark"></i></div>';
572. }
573. else
574. {
575. $response = '<b><i class="fas fa-check-circle"></i> Personal details successfully updated.';
576. }
578. return new JsonResponse($response);
579. }
581. #[Route('/distributors/update/sales_tax_policy', name: 'distributor_update_sales_tax_policy')]
582. public function distributorUpdateSalesTaxPolicyAction(Request $request): Response
583. {
584. $data = $request->request;
585. $distributor = $this->getUser()->getDistributor();
587. if($distributor != null)
588. {
589. if(!empty($data->get('sales-tax-policy')))
590. {
591. $distributor->setSalesTaxPolicy($data->get('sales-tax-policy'));
592. }
594. $this->em->persist($distributor);
595. $this->em->flush();
597. $response = '<b><i class="fa-solid fa-circle-check"></i></i></b> Sales tax policy successfully updated.<div class="flash-close"><i class="fa-solid fa-xmark"></i></div>';
598. }
599. else
600. {
601. $response = '<b><i class="fas fa-check-circle"></i> Personal details successfully updated.';
602. }
604. return new JsonResponse($response);
605. }
607. #[Route('/distributors/update/shipping_policy', name: 'distributor_update_shipping_policy')]
608. public function distributorUpdateShippingPolicyAction(Request $request): Response
609. {
610. $data = $request->request;
611. $distributor = $this->getUser()->getDistributor();
613. if($distributor != null)
614. {
615. if(!empty($data->get('shipping-policy')))
616. {
617. $distributor->setShippingPolicy($data->get('shipping-policy'));
618. }
620. $this->em->persist($distributor);
621. $this->em->flush();
623. $response = '<b><i class="fa-solid fa-circle-check"></i></i></b> Shipping policy successfully updated.<div class="flash-close"><i class="fa-solid fa-xmark"></i></div>';
624. }
625. else
626. {
627. $response = '<b><i class="fas fa-check-circle"></i> Personal details successfully updated.';
628. }
630. return new JsonResponse($response);
631. }
633. #[Route('/distributors/get/about', name: 'get_about')]
634. public function getAbout(Request $request): Response
635. {
636. $distributorId = $this->getUser()->getDistributor()->getId();
637. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
638. $html = $this->render('frontend/distributors/about.html.twig', [
639. 'distributor' => $distributor,
640. ])->getContent();
642. return new JsonResponse($html);
643. }
645. #[Route('/distributors/get/operating-hours', name: 'get_distributor_operating_hours')]
646. public function getDistributorOperatingHours(Request $request): Response
647. {
648. $distributorId = $this->getUser()->getDistributor()->getId();
649. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
651. $html = $this->render('frontend/distributors/operating_hours.html.twig', [
652. 'distributor' => $distributor,
653. ])->getContent();
655. return new JsonResponse($html);
656. }
658. #[Route('/distributors/get/refund-policy', name: 'get_distributor_refund_policy')]
659. public function getDistributorRefundPolicy(Request $request): Response
660. {
661. $distributorId = $this->getUser()->getDistributor()->getId();
662. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
664. $html = $this->render('frontend/distributors/refund_policy.html.twig', [
665. 'distributor' => $distributor,
666. ])->getContent();
668. return new JsonResponse($html);
669. }
671. #[Route('/distributors/get/sales-tax-policy', name: 'get_distributor_sales_tax_policy')]
672. public function getDistributorSalesTaxPolicy(Request $request): Response
673. {
674. $distributorId = $this->getUser()->getDistributor()->getId();
675. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
677. $html = $this->render('frontend/distributors/sales_tax_policy.html.twig', [
678. 'distributor' => $distributor,
679. ])->getContent();
681. return new JsonResponse($html);
682. }
684. #[Route('/distributors/get/shipping-policy', name: 'get_distributor_shipping_policy')]
685. public function getDistributorShippingPolicy(Request $request): Response
686. {
687. $distributorId = $this->getUser()->getDistributor()->getId();
688. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
690. $html = $this->render('frontend/distributors/shipping_policy.htm.twig', [
691. 'distributor' => $distributor,
692. ])->getContent();
694. return new JsonResponse($html);
695. }
697. #[Route('/distributors/inventory-search', name: 'distributor_inventory_search')]
698. public function distributorInventorySearchAction(Request $request): Response
699. {
700. $products = $this->em->getRepository(Products::class)->findBySearch($request->get('keyword'));
701. $select = '<ul id="product_list">';
703. foreach($products as $product){
705. $id = $product->getId();
706. $name = $product->getName();
707. $dosage = '';
708. $size = '';
710. if(!empty($product->getDosage())) {
712. $unit = '';
714. if(!empty($product->getUnit())) {
716. $unit = $product->getUnit();
717. }
719. $dosage = ' | '. $product->getDosage() . $unit;
720. }
722. if(!empty($product->getSize())) {
724. $size = ' | '. $product->getSize();
725. }
727. $select .= "
728. <li
729. class=\"search-item\"
730. data-product-id=\"$id\"
731. data-product-name=\"$name\"
732. data-action='click->products--distributor-products#onclickEditIcon'
733. >$name$dosage$size</li>
734. ";
735. }
737. $select .= '</ul>';
739. return new Response($select);
740. }
742. #[Route('/distributors/inventory-get', name: 'distributor_inventory_get')]
743. public function distributorGetInventoryAction(Request $request,TokenStorageInterface $tokenStorage): Response
744. {
745. $productId = (int) $request->request->get('product-id');
746. $products = $this->em->getRepository(Products::class)->find($productId);
748. if($products != null)
749. {
750. $distributorId = $this->getUser()->getDistributor()->getId();
751. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
752. $response = [];
754. $response['html'] = json_decode($this->forward('App\Controller\DistributorProductsController::getDistributorProductAction')
755. ->getContent());
757. $distributorProduct = $this->em->getRepository(Distributors::class)
758. ->getDistributorProduct($distributor->getId(), $productId);
760. if($distributorProduct != null)
761. {
762. $response['distributor_id'] = $distributor->getId();
763. $response['itemId'] = $distributorProduct[0]['distributorProducts'][0]['itemId'];
764. $response['sku'] = $distributorProduct[0]['distributorProducts'][0]['sku'];
765. $response['unit_price'] = $distributorProduct[0]['distributorProducts'][0]['unitPrice'];
766. $response['stock_count'] = $distributorProduct[0]['distributorProducts'][0]['stockCount'];
767. $response['expiry_date'] = '';
768. $response['tax_exempt'] = $distributorProduct[0]['distributorProducts'][0]['taxExempt'];
769. $response['product'] = $distributorProduct[0]['distributorProducts'][0]['product'];
771. if($distributorProduct[0]['distributorProducts'][0]['expiryDate'] != null)
772. {
773. $response['expiry_date'] = $distributorProduct[0]['distributorProducts'][0]['expiryDate']->format('Y-m-d');
774. }
775. }
776. else
777. {
778. $product = $this->em->getRepository(Products::class)->find($productId);
780. $response['distributor_id'] = $distributor->getId();
781. $response['sku'] = '';
782. $response['distributor_no'] = '';
783. $response['unit_price'] = '';
784. $response['stock_count'] = '';
785. $response['expiry_date'] = '';
786. $response['tax_exempt'] = 0;
787. $response['product'] = [
788. 'dosage' => $product->getDosage(),
789. 'size' => $product->getSize(),
790. 'unit' => $product->getUnit(),
791. 'activeIngredient' => $product->getActiveIngredient(),
792. ];
793. }
794. }
795. else
796. {
797. $response['message'] = 'Inventory item not found';
798. }
800. return new JsonResponse($response);
801. }
803. #[Route('/distributors/inventory-update', name: 'distributor_inventory_update')]
804. public function distributorUpdateInventoryAction(Request $request, MailerInterface $mailer): Response
805. {
806. $data = $request->request->all('distributor_products_form');
807. $product = $this->em->getRepository(Products::class)->find($data['product']);
808. $distributor = $this->em->getRepository(Distributors::class)->find($data['distributor']);
809. $distributorProducts = $this->em->getRepository(DistributorProducts::class)->findOneBy(
810. [
811. 'product' => $data['product'],
812. 'distributor' => $data['distributor']
813. ]
814. );
815. $tracking = false;
816. $response['unitPrice'] = 0.00;
817. $response['stockLevel'] = 0;
819. if($distributorProducts == null){
821. $distributorProducts = new DistributorProducts();
823. } else {
825. if($distributorProducts->getStockCount() == 0){
827. $tracking = true;
828. }
829. }
831. if(!empty($data['product']) && !empty($data['distributor'])){
833. $trackingId = $distributor->getTracking()->getId();
835. $distributorProducts->setDistributor($distributor);
836. $distributorProducts->setProduct($product);
837. $distributorProducts->setSku($data['sku']);
838. $distributorProducts->setItemId($data['itemId']);
839. $distributorProducts->setTaxExempt($data['taxExempt']);
840. $distributorProducts->setIsActive(1);
842. $taxExempt = 0;
844. if(!empty($data['taxExempt'])){
846. $taxExempt = $data['taxExempt'];
847. }
849. $distributorProducts->setTaxExempt($taxExempt);
851. if($trackingId == 3)
852. {
853. $distributorProducts->setUnitPrice($data['unitPrice']);
854. $distributorProducts->setStockCount((int)$data['stockCount']);
855. }
857. // Get stock and price from API
858. if($trackingId == 1){
860. // Retrieve price & stock from api
861. $distributorId = $distributor->getId();
862. $priceStockLevels = json_decode($this->forward('App\Controller\ProductsController::zohoRetrieveItem',[
863. 'distributorId' => $distributorId,
864. 'itemId' => $data['itemId'],
865. ])->getContent(), true);
867. $response['unitPrice'] = $priceStockLevels['unitPrice'] ?? 0.00;
868. $response['stockLevel'] = $priceStockLevels['stockLevel'] ?? 0;
870. $distributorProducts->setUnitPrice($response['unitPrice']);
871. $distributorProducts->setStockCount($response['stockLevel']);
872. }
874. $this->em->persist($distributorProducts);
875. $this->em->flush();
877. // Update parent stock level
878. $stockCount = $this->em->getRepository(DistributorProducts::class)->getProductStockCount($product->getId());
880. $product->setStockCount($stockCount[0][1]);
882. // Get the lowest price
883. $lowestPrice = $this->em->getRepository(DistributorProducts::class)->getLowestPrice($product->getId());
885. $product->setUnitPrice($lowestPrice[0]['unitPrice'] ?? 0.00);
887. $this->em->persist($product);
888. $this->em->flush();
890. // Availability Tracker
891. $availabilityTracker = '';
893. if($tracking){
895. $availabilityTracker = $this->em->getRepository(AvailabilityTracker::class)->findBy([
896. 'product' => $product->getId(),
897. 'distributor' => $data['distributor'],
898. 'isSent' => 0,
899. ]);
901. foreach($availabilityTracker as $tracker){
903. $methodId = $tracker->getCommunication()->getCommunicationMethod()->getId();
904. $sendTo = $tracker->getCommunication()->getSendTo();
905. $product = $tracker->getProduct();
907. // In app notifications
908. if($methodId == 1){
910. $notifications = new Notifications();
912. $notifications->setClinic($tracker->getClinic());
913. $notifications->setIsRead(0);
914. $notifications->setIsReadDistributor(0);
915. $notifications->setIsActive(1);
916. $notifications->setAvailabilityTracker($tracker);
918. $this->em->persist($notifications);
919. $this->em->flush();
921. // Get the newly created notification
922. $notification = '
923. <table class="w-100">
924. <tr>
925. <td><span class="badge bg-success me-3">New Stock</span></td>
926. <td>'. $product->getName() .' '. $product->getDosage() . $product->getUnit() .'</td>
927. <td>
928. <a href="#" class="delete-notification" data-notification-id="'. $notifications->getId() .'">
929. <i class="fa-solid fa-xmark text-black-25 ms-3 float-end"></i>
930. </a>
931. </td>
932. </tr>
933. </table>';
935. $notifications = $this->em->getRepository(Notifications::class)->find($notifications->getId());
937. $notifications->setNotification($notification);
939. $this->em->persist($notifications);
940. $this->em->flush();
942. // Email notifications
943. } elseif($methodId == 2){
945. $body = '<table style="padding: 8px; border-collapse: collapse; border: none; font-family: arial">';
946. $body .= '<tr><td colspan="2">'. $product->getName() .' '. $product->getDosage() . $product->getUnit() .' is back in stock</td></tr>';
947. $body .= '<tr><td colspan="2">&nbsp;</td></tr>';
948. $body .= '<tr>';
949. $body .= ' <td><b>Distributor: </b></td>';
950. $body .= ' <td>'. $tracker->getDistributor()->getDistributorName() .'</td>';
951. $body .= '</tr>';
952. $body .= '<tr>';
953. $body .= ' <td><b>Stock Level: </b></td>';
954. $body .= ' <td>'. $tracker->getProduct()->getDistributorProducts()[0]->getStockCount() .'</td>';
955. $body .= '</tr>';
956. $body .= '</table>';
958. $subject = 'Fluid Stock Level Update';
959. $to = $sendTo;
961. exec(__DIR__ . '/../../bin/console app:send-email "'. $subject .'" "'. addslashes($body) .'" "'. $to .'" "" "" "'. true .'" > /dev/null 2>&1 &');
963. // Text notifications
964. } elseif($methodId == 3){
966. }
968. $availabilityTracker = $this->em->getRepository(AvailabilityTracker::class)->find($tracker->getId());
969. $availabilityTracker->setIsSent(1);
971. $this->em->persist($availabilityTracker);
972. $this->em->flush();
973. }
974. }
976. $response['flash'] = '<b><i class="fa-solid fa-circle-check"></i></i></b> '. $product->getName() .' successfully updated.<div class="flash-close"><i class="fa-solid fa-xmark"></i></div>';
978. } else {
980. $response['flash'] = 'An error occurred';
981. }
983. return new JsonResponse($response);
984. }
986. #[Route('/distributors/get/refresh-token', name: 'distributor_get_access_token')]
987. public function distributorGetRefreshTokenAction(Request $request): Response
988. {
989. $id = $this->getUser()->getDistributor()->getId();
990. $button = false;
991. $token = false;
992. $error = false;
994. if($id == null){
996. return $this->render('security/login.html.twig', [
997. 'last_username' => '',
998. 'error' => '',
999. 'csrf_token_intention' => 'authenticate',
1000. 'user_type' => 'distributors',
1002. ]);
1003. }
1005. $api = $this->em->getRepository(ApiDetails::class)->findOneBy([
1006. 'distributor' => $id,
1007. ]);
1009. // Check client id & secret exist
1010. if($api == null){
1012. $error = true;
1014. } else {
1016. $refreshTokens = $api->getRefreshTokens();
1018. if(count($refreshTokens) == 0){
1020. $button = true;
1022. } else {
1024. $token = true;
1025. }
1026. }
1028. return new JsonResponse([
1029. 'token' => $token,
1030. 'button' => $button,
1031. 'error' => $error
1032. ]);
1033. }
1035. #[Route('/distributors/zoho/set/refresh-token', name: 'zoho_set_refresh_token')]
1036. public function setZohoRefreshTokenAction(Request $request): Response
1037. {
1038. $distributorId = $this->getUser()->getDistributor()->getId();
1039. $apiDetails = $this->em->getRepository(ApiDetails::class)->findOneBy([
1040. 'distributor' => $distributorId,
1041. ]);
1042. $code = $request->query->get('code');
1043. $error = $request->query->get('error');
1045. if($code != null) {
1047. $curl = curl_init();
1048. $clientId = $this->encryptor->decrypt($apiDetails->getClientId());
1049. $clientSecret = $this->encryptor->decrypt($apiDetails->getClientSecret());
1050. $endpoint = 'https://accounts.zoho.com/oauth/v2/token?code=' . $code . '&client_id=' . $clientId . '&';
1051. $endpoint .= 'client_secret=' . $clientSecret . '&redirect_uri='. $this->getParameter('app.base_url') .'/distributors/zoho/set/refresh-token&';
1052. $endpoint .= 'grant_type=authorization_code';
1054. curl_setopt_array($curl, [
1055. CURLOPT_URL => $endpoint,
1056. CURLOPT_RETURNTRANSFER => true,
1057. CURLOPT_ENCODING => '',
1058. CURLOPT_MAXREDIRS => 10,
1059. CURLOPT_TIMEOUT => 0,
1060. CURLOPT_FOLLOWLOCATION => true,
1061. CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
1062. CURLOPT_CUSTOMREQUEST => 'POST'
1063. ]);
1065. $json = curl_exec($curl);
1067. curl_close($curl);
1069. $response = json_decode($json, true);
1071. if(array_key_exists('refresh_token', $response)){
1073. $session = $this->requestStack->getSession();
1074. $session->set('accessToken', $response['access_token']);
1075. $session->set('refreshToken', $response['refresh_token']);
1077. $refreshToken = new RefreshTokens();
1078. $api = $this->getUser()->getDistributor()->getApiDetails();
1080. $refreshToken->setToken($response['refresh_token']);
1081. $refreshToken->setApiDetails($api);
1083. $this->em->persist($refreshToken);
1084. $this->em->flush();
1086. return $this->redirectToRoute('distributor_manage_inventory');
1088. } elseif(array_key_exists('error', $response)){
1090. echo $response['error'];
1091. }
1093. } elseif($error != null){
1095. echo $error;
1097. file_put_contents(__DIR__ . '/../../public/zoho.log', date('Y-m-d H:i:s') .': '. $error . "\n", FILE_APPEND);
1098. }
1100. return new JsonResponse('');
1101. }
1103. #[Route('/admin/get/distributors/list', name: 'admin_get_distributors_list')]
1104. public function adminGetDistributorsList(Request $request): Response
1105. {
1106. $status = (int) $request->request->get('status');
1107. $distributors = $this->em->getRepository(Distributors::class)->adminFindAll($status);
1108. $results = $this->pageManager->paginate($distributors[0], $request, self::ITEMS_PER_PAGE);
1109. $dataAction = 'data-action="click->admin--distributors#onClickGetList"';
1110. $pagination = $this->getPagination($request->get('page_id'), $results, $dataAction, self::ITEMS_PER_PAGE);
1111. $response = $this->render('Admin/distributors/distributors_list.html.twig', [
1112. 'distributors' => $results,
1113. 'pagination' => $pagination,
1114. ])->getContent();
1116. return new JsonResponse($response);
1117. }
1119. #[Route('/admin/get/distributor/form', name: 'admin_get_distributor_form')]
1120. public function adminGetDistributorForm(Request $request): Response
1121. {
1122. $distributorId = $request->request->get('distributor-id') ?? 0;
1123. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
1124. $distributorUsers = $this->em->getRepository(DistributorUsers::class)->findBy([
1125. 'distributor' => $distributorId
1126. ]);
1127. $userPermissions = $this->em->getRepository(UserPermissions::class)->findBy([
1128. 'isDistributor' => 1
1129. ]);
1130. $api = $this->em->getRepository(Api::class)->findAll();
1131. $countries = $this->em->getRepository(Countries::class)->findBy([
1132. 'isActive' => true,
1133. ]);
1134. $distributorProducts = $this->getDistributorInventory(1, $distributorId, 0, 0, $request);
1135. $scraperUrls = $this->em->getRepository(ScraperUrls::class)->findBy([
1136. 'scraperAuthentication' => $distributor?->getScraperAunthentication()->getId(),
1137. ],
1138. [
1139. 'pageName' => 'ASC'
1140. ]);
1141. $response = $this->render('Admin/distributors/distributors.html.twig', [
1142. 'distributor' => $distributor,
1143. 'distributorUsers' => $distributorUsers,
1144. 'userPermissions' => $userPermissions,
1145. 'api' => $api,
1146. 'countries' => $countries,
1147. 'distributorProducts' => $distributorProducts,
1148. 'scraperUrls' => $scraperUrls,
1149. ])->getContent();
1151. return new JsonResponse($response);
1152. }
1154. #[Route('/admin/approve/distributor', name: 'admin_approve_distributor')]
1155. public function adminApproveDistributor(Request $request): Response
1156. {
1157. $distributorId = $request->request->get('distributor-id');
1158. $isApproved = $request->request->get('is-approved');
1159. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
1161. if($distributor != null)
1162. {
1163. if($isApproved == 1 || $isApproved == 0)
1164. {
1165. $isApproved = 2;
1166. }
1167. else if($isApproved == 2)
1168. {
1169. $isApproved = 1;
1170. }
1172. $distributor->setIsApproved($isApproved);
1174. $this->em->persist($distributor);
1175. $this->em->flush();
1176. }
1178. return new JsonResponse('');
1179. }
1181. #[Route('/admin/get-distributor-products', name: 'admin_get_distributor_products')]
1182. public function distributorInventory(Request $request): Response
1183. {
1184. $pageId = $request->request->get('page-id');
1185. $distributorId = $request->request->get('distributor-id');
1186. $manufacturerId = $request->request->get('manufacturer-id');
1187. $speciesId = $request->request->get('species-id');
1189. $response = $this->getDistributorInventory($pageId, $distributorId, $manufacturerId, $speciesId, $request);
1191. return new JsonResponse($response);
1192. }
1194. #[Route('/admin/save-scraper-frequency', name: 'admin_save_scraper_frequency')]
1195. public function saveScraperFrequency(Request $request): Response
1196. {
1197. $name = $request->request->get('name');
1198. $cron = $request->request->get('cron');
1199. $status = (int) $request->request->get('status');
1200. $scraperUrlId = $request->request->get('scraper-url-id');
1201. $frequency = $request->request->get('frequency');
1203. $scraperUrl = $this->em->getRepository(ScraperUrls::class)->find($scraperUrlId);
1205. if($scraperUrl == null)
1206. {
1207. $response = [
1208. 'flash' => 'Please first save the scraper url.',
1209. 'type' => 'danger'
1210. ];
1212. return new JsonResponse($response);
1213. }
1215. $cronJob = $this->em->getRepository(CronJob::class)->findOneBy([
1216. 'scraperUrl' => $scraperUrl->getId(),
1217. ]);
1219. if($cronJob == null)
1220. {
1221. $cronJob = new CronJob();
1222. }
1224. $cronJob->setName($name);
1225. $cronJob->setExpression($cron);
1226. $cronJob->setCommand($scraperUrl->getDistributor()->getScraperAunthentication()->getCommand());
1227. $cronJob->setActive($status);
1228. $cronJob->setScraperUrl($scraperUrl);
1229. $cronJob->setFrequency($frequency);
1230. $cronJob->setDescription($this->getCronDescription($cron, $frequency));
1232. $this->em->persist($cronJob);
1233. $this->em->flush();
1235. $response = [
1236. 'flash' => 'Schedule saved successfully.',
1237. 'type' => 'success'
1238. ];
1240. return new JsonResponse($response);
1241. }
1243. #[Route('/admin/run-scraper', name: 'admin_run_scraper')]
1244. public function runScraper(Request $request): Response
1245. {
1246. $lockFactory = new LockFactory(new FlockStore());
1247. $lock = $lockFactory->createLock('app:scrape-eurovets');
1248. $command = $request->request->get('command');
1249. $email = $this->encryptor->decrypt($this->getUser()->getEmail());
1251. if(!$lock->acquire())
1252. {
1253. $response = [
1254. 'flash' => 'Scraper is already running.',
1255. 'type' => 'danger'
1256. ];
1258. return new JsonResponse($response);
1259. }
1261. exec(__DIR__ . "/../../bin/console $command 0 $email > /dev/null 2>&1 &");
1263. $response = [
1264. 'flash' => 'Scraper successfully started.',
1265. 'type' => 'success'
1266. ];
1268. return new JsonResponse($response);
1269. }
1271. #[Route('/admin/scrape-brand', name: 'admin_scrape_brand')]
1272. public function scrapeBrand(Request $request): Response
1273. {
1274. $lockFactory = new LockFactory(new FlockStore());
1275. $command = $request->request->get('command');
1276. $lock = $lockFactory->createLock($command);
1277. $brandId = $request->request->get('brand-id');
1278. $email = $this->encryptor->decrypt($this->getUser()->getEmail());
1280. if(!$lock->acquire())
1281. {
1282. $response = [
1283. 'flash' => 'Scraper is already running.',
1284. 'type' => 'danger'
1285. ];
1287. return new JsonResponse($response);
1288. }
1290. // Not running
1291. $lock->release();
1293. exec(__DIR__ . "/../../bin/console $command $brandId $email > /dev/null 2>&1 &");
1295. $response = [
1296. 'flash' => 'Scraper successfully started.',
1297. 'type' => 'success'
1298. ];
1300. return new JsonResponse($response);
1301. }
1303. public function getCronDescription($cron, $frequency): string
1304. {
1305. $description = '';
1307. // Daily
1308. if(strtolower($frequency) == 'daily')
1309. {
1310. $pieces = explode(' ', $cron);
1311. $hour = $pieces[1];
1312. $timeOfDay = 'pm';
1314. if($hour >= 0 and $hour < 12)
1315. {
1316. $timeOfDay = 'am';
1317. }
1319. $description = 'Every day at '. $hour . $timeOfDay;
1320. }
1322. // Weekly
1323. if(strtolower($frequency) == 'weekly')
1324. {
1325. $pieces = explode(' ', $cron);
1326. $hour = $pieces[1];
1327. $day = (int) $pieces[4];
1328. $timeOfDay = 'pm';
1330. if($hour >= 0 and $hour < 12)
1331. {
1332. $timeOfDay = 'am';
1333. }
1335. $date = new \DateTime();
1336. $date->setISODate(date('Y'), 1, $day);
1337. $day = $date->format('l');
1339. $description = 'Every '. $day .' at '. $hour . $timeOfDay;
1340. }
1342. // Monthly
1343. if(strtolower($frequency) == 'monthly')
1344. {
1345. $pieces = explode(' ', $cron);
1346. $hour = $pieces[1];
1347. $day = $pieces[2];
1348. $timeOfDay = 'pm';
1350. if($hour >= 0 and $hour < 12)
1351. {
1352. $timeOfDay = 'am';
1353. }
1355. $description = 'At '. $hour . $timeOfDay .' on day '. $day .' of the month';
1356. }
1358. return $description;
1359. }
1361. public function getDistributorInventory($pageId, $distributorId, $manufacturerId, $speciesId, $request)
1362. {
1363. $dataAction = 'data-action="click->admin--distributors#onClickPagination"';
1364. $distributorProductsRepo = $this->em->getRepository(AiProducts::class)->findByManufacturer($distributorId,$manufacturerId,$speciesId);
1365. $distributorProducts = $this->pageManager->paginate($distributorProductsRepo[0], $request, self::ITEMS_PER_PAGE);
1366. $distributorProductsPagination = $this->getAjaxPagination($pageId, $distributorProducts, $distributorId, $dataAction);
1367. $species = $this->em->getRepository(AiProductsSpecies::class)->adminFindByDistributorProducts($distributorId);
1369. return $this->render('Admin/distributors/distributor_products.html.twig', [
1370. 'species' => $species,
1371. 'speciesId' => $speciesId,
1372. 'distributorProducts' => $distributorProducts,
1373. 'pagination' => $distributorProductsPagination,
1374. ])->getContent();
1375. }
1377. public function getPagination($currentPage, $results, $dataAction = '', $itemsPerPage = 10): string
1378. {
1379. return $this->render('pagination.html.twig', [
1380. 'currentPage' => $currentPage,
1381. 'results' => $results,
1382. 'dataAction' => $dataAction,
1383. 'itemsPerPage' => $itemsPerPage,
1384. 'lastPage' => $this->pageManager->lastPage($results),
1385. 'totalPages' => ceil(count($results) / $itemsPerPage),
1386. 'i' => max(1, $currentPage - 5),
1387. 'forLimit' => min($currentPage + 5, ceil(count($results) / $itemsPerPage)),
1388. ])->getContent();
1389. }
1391. public function getAjaxPagination($pageId, $results, $url, $dataAction = '', $itemsPerPage = 10): string
1392. {
1393. $currentPage = $pageId;
1394. $totalPages = ceil(count($results) / $itemsPerPage);
1395. $limit = 5;
1396. $lastPage = $this->pageManager->lastPage($results);
1397. $pagination = '';
1399. if(count($results) > 0)
1400. {
1401. $pagination .= '
1402. <!-- Pagination -->
1403. <div class="row mt-3">
1404. <div class="col-12">';
1406. if ($lastPage > 1)
1407. {
1408. $previousPageNo = $currentPage - 1;
1409. $previousPage = $url . $previousPageNo;
1411. $pagination .= '
1412. <nav class="custom-pagination">
1413. <ul class="pagination justify-content-center">
1414. ';
1416. $disabled = 'disabled';
1417. $dataDisabled = 'true';
1419. // Previous Link
1420. if ($currentPage > 1)
1421. {
1422. $disabled = '';
1423. $dataDisabled = 'false';
1424. }
1426. if ($totalPages >= 1 && $pageId <= $totalPages && $currentPage != 1)
1427. {
1428. $pagination .= '
1429. <li class="page-item ' . $disabled . '">
1430. <a
1431. class="address-pagination"
1432. aria-disabled="' . $dataDisabled . '"
1433. data-page-id="' . $currentPage - 1 . '"
1434. href="#"
1435. ' . $dataAction . '
1436. >
1437. <span aria-hidden="true">&laquo;</span> <span class="d-none d-sm-inline">Previous</span>
1438. </a>
1439. </li>
1440. <li class="page-item ">
1441. <a
1442. class="address-pagination"
1443. data-page-id="1"
1444. href="#"
1445. '. $dataAction .'
1446. >
1447. First
1448. </a>
1449. </li>';
1450. }
1452. $i = max(1, $currentPage - $limit);
1453. $forLimit = min($currentPage + $limit, $totalPages);
1454. $isActive = false;
1456. for (; $i <= $forLimit; $i++)
1457. {
1458. $active = '';
1460. if ($i == (int)$currentPage) {
1462. $active = 'active';
1463. $isActive = true;
1464. }
1466. // Go to previous page if all records for a page have been deleted
1467. if (!$isActive && $i == count($results)) {
1469. $active = 'active';
1470. }
1472. $pagination .= '
1473. <li class="page-item ' . $active . '">
1474. <a
1475. class="address-pagination"
1476. data-page-id="' . $i . '"
1477. href="#"
1478. ' . $dataAction . '
1479. >' . $i . '</a>
1480. </li>';
1481. }
1483. $disabled = 'disabled';
1484. $dataDisabled = 'true';
1486. if ($currentPage < $lastPage) {
1488. $disabled = '';
1489. $dataDisabled = 'false';
1490. }
1492. if ($currentPage < $lastPage)
1493. {
1494. $pagination .= '
1495. <li class="page-item ">
1496. <a
1497. class="address-pagination"
1498. data-page-id="'. $lastPage .'"
1499. href="#"
1500. '. $dataAction .'
1501. >
1502. Last
1503. </a>
1504. </li>
1505. <li class="page-item ' . $disabled . '">
1506. <a
1507. class="address-pagination"
1508. aria-disabled="' . $dataDisabled . '"
1509. data-page-id="' . $currentPage + 1 . '"
1510. href="#"
1511. '. $dataAction .'
1512. >
1513. <span class="d-none d-sm-inline">Next</span> <span aria-hidden="true">&raquo;</span>
1514. </a>
1515. </li>';
1516. }
1518. $pagination .= '
1519. </ul>
1520. </nav>
1521. <input type="hidden" id="page_no" value="' . $currentPage . '">
1522. </div>';
1523. }
1524. }
1526. return $pagination;
1527. }
1528. }