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;
44. class DistributorsController extends AbstractController
45. {
46. private $em;
47. const ITEMS_PER_PAGE = 10;
48. private $pageManager;
49. private $requestStack;
50. private $plainPassword;
51. private $encryptor;
53. public function __construct(EntityManagerInterface $em, PaginationManager $pagination, RequestStack $requestStack, Encryptor $encryptor)
54. {
55. $this->em = $em;
56. $this->pageManager = $pagination;
57. $this->requestStack = $requestStack;
58. $this->encryptor = $encryptor;
59. }
61. #[Route('/distributors/dashboard', name: 'distributor_dashboard')]
62. #[Route('/distributors/account', name: 'distributor_account')]
63. #[Route('/distributors/about', name: 'distributor_about')]
64. #[Route('/distributors/operating-hours', name: 'distributor_operating_hours')]
65. #[Route('/distributors/refund-policy', name: 'distributor_refund_policy')]
66. #[Route('/distributors/sales-tax-policy', name: 'distributor_sales_tax_policy')]
67. #[Route('/distributors/shipping-policy', name: 'distributor_shipping_policy')]
68. #[Route('/distributors/manage-inventory', name: 'distributor_manage_inventory')]
69. #[Route('/distributors/users', name: 'distributor_get_users')]
70. #[Route('/distributors/order/{order_id}', name: 'distributor_order')]
71. #[Route('/distributors/orders/{distributor_id}', name: 'distributor_order_list')]
72. #[Route('/distributors/customers/1', name: 'distributor_customer_list')]
73. #[Route('/distributors/inventory/list', name: 'distributor_inventory_list')]
74. public function distributorDashboardAction(Request $request): Response
75. {
76. if($this->getUser()->getUserIdentifier() == null){
78. $this->addFlash('danger', 'Your session expired due to inactivity, please login.');
80. return $this->redirectToRoute('distributor_login');
81. }
83. $distributor = $this->getUser()->getDistributor();
84. $user = $this->getUser();
85. $username = $distributor->getDistributorName();
87. $permissions = [];
89. foreach($user->getDistributorUserPermissions() as $permission){
91. $permissions[] = $permission->getPermission()->getId();
92. }
94. return $this->render('frontend/distributors/index.html.twig',[
95. 'distributor' => $distributor,
96. 'permissions' => json_encode($permissions),
97. 'username' => $username,
98. ]);
99. }
101. #[Route('/distributors/register', name: 'distributor_reg')]
102. public function distributorReg(Request $request): Response
103. {
104. $countries = $this->em->getRepository(Countries::class)->findBy([
105. 'isActive' => 1,
106. ]);
107. $form = $this->createRegisterForm();
109. return $this->render('frontend/distributors/register.html.twig', [
110. 'form' => $form->createView(),
111. 'countries' => $countries
112. ]);
113. }
115. #[Route('/sellers', name: 'sellers_page')]
116. public function sellersAction(Request $request): Response
117. {
118. $sellers = $this->em->getRepository(Distributors::class)->findBy([
119. 'isApproved' => true,
120. ]);
122. return $this->render('frontend/sellers.html.twig', [
123. 'sellers' => $sellers,
124. ]);
125. }
127. protected function createRegisterForm()
128. {
129. $distributors = new Distributors();
131. return $this->createForm(DistributorFormType::class, $distributors);
132. }
134. #[Route('/distributors/register/check-email', name: 'distributor_check_email')]
135. public function distributorsCheckEmailAction(Request $request): Response
136. {
137. $email = $request->request->get('email');
138. $domainName = explode('@', $email);
139. $response['response'] = true;
140. $firstName = '';
141. $restrictedDomains = $this->em->getRepository(RestrictedDomains::class)->arrayFindAll();
143. foreach($restrictedDomains as $restrictedDomain)
144. {
145. if(md5($domainName[1]) == md5($restrictedDomain->getName()))
146. {
147. $response['response'] = false;
148. $response['restricted'] = true;
150. return new JsonResponse($response);
151. }
152. }
154. $distributor = $this->em->getRepository(Distributors::class)->findOneBy([
155. 'hashedEmail' => md5($email),
156. ]);
158. $distributorDomain = $this->em->getRepository(Distributors::class)->findOneBy([
159. 'domainName' => md5($domainName[1]),
160. ]);
162. $distributorUsers = $this->em->getRepository(DistributorUsers::class)->findOneBy([
163. 'hashedEmail' => md5($email),
164. ]);
166. $clinic = $this->em->getRepository(Clinics::class)->findOneBy([
167. 'hashedEmail' => md5($email),
168. ]);
170. $clinicDomain = $this->em->getRepository(Clinics::class)->findOneBy([
171. 'domainName' => md5($domainName[1]),
172. ]);
174. $clinicUsers = $this->em->getRepository(ClinicUsers::class)->findOneBy([
175. 'hashedEmail' => md5($email),
176. ]);
178. if($clinicDomain != null)
179. {
180. $user = $this->em->getRepository(ClinicUsers::class)->findOneBy([
181. 'clinic' => $clinicDomain->getId(),
182. 'isPrimary' => 1
183. ]);
184. $firstName = $this->encryptor->decrypt($user->getFirstName());
185. }
187. if($distributorDomain != null)
188. {
189. $user = $this->em->getRepository(DistributorUsers::class)->findOneBy([
190. 'distributor' => $distributorDomain->getId(),
191. 'isPrimary' => 1
192. ]);
193. $firstName = $this->encryptor->decrypt($user->getFirstName());
194. }
196. $response['firstName'] = $firstName;
198. if($distributor != null || $distributorUsers != null || $clinic != null || $clinicUsers != null || $clinicDomain != null || $distributorDomain != null)
199. {
200. $response['response'] = false;
201. $response['restricted'] = false;
202. }
204. return new JsonResponse($response);
205. }
207. #[Route('/distributor/addresses', name: 'distributor_addresses')]
208. public function createDistributorAddressesForm()
209. {
210. $addresses = new Addresses();
212. return $this->createForm(AddressesFormType::class, $addresses);
213. }
215. #[Route('/distributor/register/create', name: 'distributor_create')]
216. public function distributorCreateAction(Request $request, UserPasswordHasherInterface $passwordHasher, MailerInterface $mailer): Response
217. {
218. $data = $request->request;
219. $distributor = $this->em->getRepository(Distributors::class)->findOneBy(['email' => $data->get('email')]);
220. $countries = $this->em->getRepository(Countries::class)->find($data->get('country'));
221. $tracking = $this->em->getRepository(Tracking::class)->find(3);
223. if($distributor == null) {
225. $distributors = new Distributors();
227. $plainTextPwd = $this->generatePassword();
229. if (!empty($plainTextPwd)) {
231. $domainName = explode('@', $data->get('email'));
233. $distributors->setDistributorName($this->encryptor->encrypt($data->get('distributor-name')));
234. $distributors->setName($data->get('distributor-name'));
235. $distributors->setEmail($this->encryptor->encrypt($data->get('email')));
236. $distributors->setHashedEmail(md5($data->get('email')));
237. $distributors->setDomainName(md5($domainName[1]));
238. $distributors->setTelephone($this->encryptor->encrypt($data->get('telephone')));
239. $distributors->setIntlCode($this->encryptor->encrypt($data->get('intl-code')));
240. $distributors->setIsoCode($this->encryptor->encrypt($data->get('iso-code')));
241. $distributors->setAddressCountry($countries);
242. $distributors->setTracking($tracking);
243. $distributors->setIsApproved(0);
245. $this->em->persist($distributors);
246. $this->em->flush();
248. // Create user
249. $distributor = $this->em->getRepository(Distributors::class)->findOneBy([
250. 'hashedEmail' => md5($data->get('email')),
251. ]);
252. $distributorUsers = new DistributorUsers();
254. $hashed_pwd = $passwordHasher->hashPassword($distributorUsers, $plainTextPwd);
256. $distributorUsers->setDistributor($distributor);
257. $distributorUsers->setFirstName($this->encryptor->encrypt($data->get('first-name')));
258. $distributorUsers->setLastName($this->encryptor->encrypt($data->get('last-name')));
259. $distributorUsers->setPosition($this->encryptor->encrypt($data->get('position')));
260. $distributorUsers->setEmail($this->encryptor->encrypt($data->get('email')));
261. $distributorUsers->setHashedEmail(md5($data->get('email')));
262. $distributorUsers->setTelephone($this->encryptor->encrypt($data->get('telephone')));
263. $distributorUsers->setRoles(['ROLE_DISTRIBUTOR']);
264. $distributorUsers->setPassword($hashed_pwd);
265. $distributorUsers->setIsPrimary(1);
267. $this->em->persist($distributorUsers);
268. $this->em->flush();
270. // Assign User Permissions
271. $userPermissions = $this->em->getRepository(UserPermissions::class)->findBy([
272. 'isDistributor' => 1,
273. ]);
275. foreach($userPermissions as $userPermission){
277. $distributorUserPermissions = new DistributorUserPermissions();
279. $distributorUserPermissions->setUser($distributorUsers);
280. $distributorUserPermissions->setDistributor($distributors);
281. $distributorUserPermissions->setPermission($userPermission);
283. $this->em->persist($distributorUserPermissions);
284. }
286. $this->em->flush();
288. // Send Email
289. $body = '<table style="padding: 8px; border-collapse: collapse; border: none; font-family: arial">';
290. $body .= '<tr><td colspan="2">Hi '. $data->get('first_name') .',</td></tr>';
291. $body .= '<tr><td colspan="2">&nbsp;</td></tr>';
292. $body .= '<tr><td colspan="2">Please use the credentials below login to the Fluid Backend.</td></tr>';
293. $body .= '<tr><td colspan="2">&nbsp;</td></tr>';
294. $body .= '<tr>';
295. $body .= ' <td><b>URL: </b></td>';
296. $body .= ' <td><a href="https://'. $_SERVER['HTTP_HOST'] .'/distributors/login">https://'. $_SERVER['HTTP_HOST'] .'/distributor/login</a></td>';
297. $body .= '</tr>';
298. $body .= '<tr>';
299. $body .= ' <td><b>Username: </b></td>';
300. $body .= ' <td>'. $data->get('email') .'</td>';
301. $body .= '</tr>';
302. $body .= '<tr>';
303. $body .= ' <td><b>Password: </b></td>';
304. $body .= ' <td>'. $plainTextPwd .'</td>';
305. $body .= '</tr>';
306. $body .= '</table>';
308. $subject = 'Fluid Login Credentials';
309. $to = $data->get('email');
311. exec(__DIR__ . '/../../bin/console app:send-email "'. $subject .'" "'. addslashes($body) .'" "'. $to .'" "" "" "'. true .'" > /dev/null 2>&1 &');
312. }
314. $response = '
315. <div class="row pt-3">
316. <div class="col-12 text-center mt-1 pt-3 pb-3" id="order_header">
317. <h4 class="text-primary">Let\'s Create Your Account.</h4>
318. <span class="text-primary">
319. Your Fluid account was successfully created, an email with your login credentials has been sent to your inbox.
320. </span>
321. </div>';
323. } else {
325. $response = false;
326. }
328. return new JsonResponse($response);
329. }
331. #[Route('/distributors/get/company-information', name: 'get_company_information')]
332. public function getCompanyInformation(Request $request): Response
333. {
334. $distributorId = $this->getUser()->getDistributor()->getId();
335. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
336. $countries = $this->em->getRepository(Countries::class)->findAll();
338. $html = $this->render('frontend/distributors/company_information.html.twig', [
339. 'distributor' => $distributor,
340. 'countries' => $countries,
341. ])->getContent();
343. return new JsonResponse($html);
344. }
346. private function generatePassword(): string
347. {
348. $curl = curl_init();
350. curl_setopt_array($curl, array(
351. CURLOPT_URL => 'https://www.dinopass.com/password/simple',
352. CURLOPT_RETURNTRANSFER => true,
353. CURLOPT_ENCODING => '',
354. CURLOPT_MAXREDIRS => 10,
355. CURLOPT_TIMEOUT => 0,
356. CURLOPT_FOLLOWLOCATION => true,
357. CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
358. CURLOPT_CUSTOMREQUEST => 'GET',
359. ));
361. $response = curl_exec($curl);
363. curl_close($curl);
365. $this->plainPassword = $response;
367. return $this->plainPassword;
368. }
370. public function createDistributorUserForm()
371. {
372. $distributorUsers = new DistributorUsers();
374. return $this->createForm(DistributorUsersFormType::class, $distributorUsers);
375. }
377. #[Route('/distributors/update/company-information', name: 'distributor_update_company_information')]
378. public function distributorUpdateCompanyInformationAction(Request $request): Response
379. {
380. $data = $request->request->all('distributor_form');
382. $distributor = $this->getUser()->getDistributor();
383. $countryId = (int) $data['addressCountry'];
384. $logo = '';
385. $country = $this->em->getRepository(Countries::class)->find($countryId);
386. $isApproved = (bool) $distributor->getIsApproved() ?? false;
387. $tradeLicense = $_FILES['distributor_form']['name']['trade-license-file'];
388. $tradeLicenseNo = $data['trade-license-no'];
389. $tradeLicenseExpDate = $data['trade-license-exp-date'];
391. // Account approval required if reg docs change
392. if(
393. !empty($tradeLicense) || $tradeLicenseNo != $this->encryptor->decrypt($distributor->getTradeLicenseNo()) ||
394. $tradeLicenseExpDate != $distributor->getTradeLicenseExpDate()->format('Y-m-d')
395. )
396. {
397. $distributor->setIsApproved(0);
398. $isApproved = false;
399. }
401. if($distributor != null)
402. {
403. $domainName = explode('@', $data['email']);
405. $distributor->setDistributorName($this->encryptor->encrypt($data['distributor-name']));
406. $distributor->setName($data['distributor-name']);
407. $distributor->setTelephone($this->encryptor->encrypt($data['telephone']));
408. $distributor->setEmail($this->encryptor->encrypt($data['email']));
409. $distributor->setWebsite($this->encryptor->encrypt($data['website']));
410. $distributor->setDomainName(md5($domainName[1]));
411. $distributor->setAddressCountry($country);
412. $distributor->setAddressStreet($this->encryptor->encrypt($data['address-street']));
413. $distributor->setAddressCity($this->encryptor->encrypt($data['address-city']));
414. $distributor->setAddressPostalCode($this->encryptor->encrypt($data['address-postal-code']));
415. $distributor->setAddressState($this->encryptor->encrypt($data['address-state']));
416. $distributor->setIsoCode($this->encryptor->encrypt($data['iso-code']));
417. $distributor->setIntlCode($this->encryptor->encrypt($data['intl-code']));
418. $distributor->setManagerFirstName($this->encryptor->encrypt($data['manager-first-name']));
419. $distributor->setManagerLastName($this->encryptor->encrypt($data['manager-last-name']));
420. $distributor->setManagerIdNo($this->encryptor->encrypt($data['manager-id-no']));
421. $distributor->setManagerIdExpDate(new \DateTime($data['manager-id-exp-date']));
422. $distributor->setTradeLicenseNo($this->encryptor->encrypt($data['trade-license-no']));
423. $distributor->setTradeLicenseExpDate(new \DateTime($data['trade-license-exp-date']));
425. if(!empty($_FILES['distributor_form']['name']['trade-license-file']))
426. {
427. $extension = pathinfo($_FILES['distributor_form']['name']['trade-license-file'], PATHINFO_EXTENSION);
428. $file = $distributor->getId() . '-' . uniqid() . '.' . $extension;
429. $targetFile = __DIR__ . '/../../public/documents/' . $file;
431. if(move_uploaded_file($_FILES['distributor_form']['tmp_name']['trade-license-file'], $targetFile))
432. {
433. $distributor->setTradeLicense($file);
434. }
435. }
437. if(!empty($_FILES['distributor_form']['name']['logo']))
438. {
439. $extension = pathinfo($_FILES['distributor_form']['name']['logo'], PATHINFO_EXTENSION);
440. $file = $distributor->getId() . '-' . uniqid() . '.' . $extension;
441. $targetFile = __DIR__ . '/../../public/images/logos/' . $file;
443. if (move_uploaded_file($_FILES['distributor_form']['tmp_name']['logo'], $targetFile))
444. {
445. $distributor->setLogo($file);
446. $logo = $file;
447. }
448. }
450. $this->em->persist($distributor);
451. $this->em->flush();
453. // Send Approval Email
454. if(!$isApproved)
455. {
456. $orderUrl = $this->getParameter('app.base_url') . '/admin/distributor/'. $distributor->getId();
457. $html = '<p>Please <a href="'. $orderUrl .'">click here</a> to view the distributors details.</p><br>';
459. $html = $this->forward('App\Controller\ResetPasswordController::emailFooter', [
460. 'html' => $html,
461. ]);
463. $subject = 'Fluid - Account Approval Request';
464. $to = $this->getParameter('app.email_admin');
466. exec(__DIR__ . '/../../bin/console app:send-email "'. $subject .'" "'. addslashes($html) .'" "'. $to .'" "" "" "'. true .'" > /dev/null 2>&1 &');
467. }
469. $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>';
470. }
471. else
472. {
473. $message = '<b><i class="fas fa-check-circle"></i> Personal details successfully updated.';
474. }
476. $response = [
477. 'message' => $message,
478. 'logo' => $logo,
479. ];
481. return new JsonResponse($response);
482. }
484. #[Route('/distributors/download/trade-license/{tradeLicense}', name: 'distributors_download_trade_license')]
485. public function distributorDownloadTradeLicenseAction(Request $request)
486. {
487. $path = __DIR__ . '/../../public/documents/';
488. $tradeLicense = $path . $request->get('tradeLicense');
489. $response = new BinaryFileResponse($tradeLicense);
491. $response->setContentDisposition(
492. ResponseHeaderBag::DISPOSITION_ATTACHMENT,
493. basename($tradeLicense)
494. );
496. return $response;
497. }
499. #[Route('/distributors/update/about_us', name: 'distributor_update_about_us')]
500. public function distributorUpdateAboutUsAction(Request $request): Response
501. {
502. $data = $request->request;
503. $distributor = $this->getUser()->getDistributor();
505. if($distributor != null)
506. {
507. $about = $data->get('about-us');
509. if(!empty($about))
510. {
511. $distributor->setAbout($about);
513. $this->em->persist($distributor);
514. $this->em->flush();
515. }
517. $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>';
518. }
519. else
520. {
521. $response = '<b><i class="fas fa-check-circle"></i> An error occurred.';
522. }
524. return new JsonResponse($response);
525. }
527. #[Route('/distributors/update/operating_hours', name: 'distributor_update_operating_hours')]
528. public function distributorUpdateOperatingHoursAction(Request $request): Response
529. {
530. $data = $request->request;
531. $distributor = $this->getUser()->getDistributor();
533. if($distributor != null)
534. {
535. if(!empty($data->get('operating-hours')))
536. {
537. $distributor->setOperatingHours($data->get('operating-hours'));
538. }
540. $this->em->persist($distributor);
541. $this->em->flush();
543. $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>';
544. }
545. else
546. {
547. $response = '<b><i class="fas fa-check-circle"></i> Personal details successfully updated.';
548. }
550. return new JsonResponse($response);
551. }
553. #[Route('/distributors/update/refund_policy', name: 'distributor_update_refund_policy')]
554. public function distributorUpdateRefundPolicyAction(Request $request): Response
555. {
556. $data = $request->request;
557. $distributor = $this->getUser()->getDistributor();
559. if($distributor != null)
560. {
561. if(!empty($data->get('refund-policy')))
562. {
563. $distributor->setRefundPolicy($data->get('refund-policy'));
564. }
566. $this->em->persist($distributor);
567. $this->em->flush();
569. $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>';
570. }
571. else
572. {
573. $response = '<b><i class="fas fa-check-circle"></i> Personal details successfully updated.';
574. }
576. return new JsonResponse($response);
577. }
579. #[Route('/distributors/update/sales_tax_policy', name: 'distributor_update_sales_tax_policy')]
580. public function distributorUpdateSalesTaxPolicyAction(Request $request): Response
581. {
582. $data = $request->request;
583. $distributor = $this->getUser()->getDistributor();
585. if($distributor != null)
586. {
587. if(!empty($data->get('sales-tax-policy')))
588. {
589. $distributor->setSalesTaxPolicy($data->get('sales-tax-policy'));
590. }
592. $this->em->persist($distributor);
593. $this->em->flush();
595. $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>';
596. }
597. else
598. {
599. $response = '<b><i class="fas fa-check-circle"></i> Personal details successfully updated.';
600. }
602. return new JsonResponse($response);
603. }
605. #[Route('/distributors/update/shipping_policy', name: 'distributor_update_shipping_policy')]
606. public function distributorUpdateShippingPolicyAction(Request $request): Response
607. {
608. $data = $request->request;
609. $distributor = $this->getUser()->getDistributor();
611. if($distributor != null)
612. {
613. if(!empty($data->get('shipping-policy')))
614. {
615. $distributor->setShippingPolicy($data->get('shipping-policy'));
616. }
618. $this->em->persist($distributor);
619. $this->em->flush();
621. $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>';
622. }
623. else
624. {
625. $response = '<b><i class="fas fa-check-circle"></i> Personal details successfully updated.';
626. }
628. return new JsonResponse($response);
629. }
631. #[Route('/distributors/get/about', name: 'get_about')]
632. public function getAbout(Request $request): Response
633. {
634. $distributorId = $this->getUser()->getDistributor()->getId();
635. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
636. $html = $this->render('frontend/distributors/about.html.twig', [
637. 'distributor' => $distributor,
638. ])->getContent();
640. return new JsonResponse($html);
641. }
643. #[Route('/distributors/get/operating-hours', name: 'get_distributor_operating_hours')]
644. public function getDistributorOperatingHours(Request $request): Response
645. {
646. $distributorId = $this->getUser()->getDistributor()->getId();
647. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
649. $html = $this->render('frontend/distributors/operating_hours.html.twig', [
650. 'distributor' => $distributor,
651. ])->getContent();
653. return new JsonResponse($html);
654. }
656. #[Route('/distributors/get/refund-policy', name: 'get_distributor_refund_policy')]
657. public function getDistributorRefundPolicy(Request $request): Response
658. {
659. $distributorId = $this->getUser()->getDistributor()->getId();
660. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
662. $html = $this->render('frontend/distributors/refund_policy.html.twig', [
663. 'distributor' => $distributor,
664. ])->getContent();
666. return new JsonResponse($html);
667. }
669. #[Route('/distributors/get/sales-tax-policy', name: 'get_distributor_sales_tax_policy')]
670. public function getDistributorSalesTaxPolicy(Request $request): Response
671. {
672. $distributorId = $this->getUser()->getDistributor()->getId();
673. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
675. $html = $this->render('frontend/distributors/sales_tax_policy.html.twig', [
676. 'distributor' => $distributor,
677. ])->getContent();
679. return new JsonResponse($html);
680. }
682. #[Route('/distributors/get/shipping-policy', name: 'get_distributor_shipping_policy')]
683. public function getDistributorShippingPolicy(Request $request): Response
684. {
685. $distributorId = $this->getUser()->getDistributor()->getId();
686. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
688. $html = $this->render('frontend/distributors/shipping_policy.htm.twig', [
689. 'distributor' => $distributor,
690. ])->getContent();
692. return new JsonResponse($html);
693. }
695. #[Route('/distributors/inventory-search', name: 'distributor_inventory_search')]
696. public function distributorInventorySearchAction(Request $request): Response
697. {
698. $products = $this->em->getRepository(Products::class)->findBySearch($request->get('keyword'));
699. $select = '<ul id="product_list">';
701. foreach($products as $product){
703. $id = $product->getId();
704. $name = $product->getName();
705. $dosage = '';
706. $size = '';
708. if(!empty($product->getDosage())) {
710. $unit = '';
712. if(!empty($product->getUnit())) {
714. $unit = $product->getUnit();
715. }
717. $dosage = ' | '. $product->getDosage() . $unit;
718. }
720. if(!empty($product->getSize())) {
722. $size = ' | '. $product->getSize();
723. }
725. $select .= "
726. <li
727. class=\"search-item\"
728. data-product-id=\"$id\"
729. data-product-name=\"$name\"
730. data-action='click->products--distributor-products#onclickEditIcon'
731. >$name$dosage$size</li>
732. ";
733. }
735. $select .= '</ul>';
737. return new Response($select);
738. }
740. #[Route('/distributors/inventory-get', name: 'distributor_inventory_get')]
741. public function distributorGetInventoryAction(Request $request,TokenStorageInterface $tokenStorage): Response
742. {
743. $productId = (int) $request->request->get('product-id');
744. $products = $this->em->getRepository(Products::class)->find($productId);
746. if($products != null)
747. {
748. $distributorId = $this->getUser()->getDistributor()->getId();
749. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
750. $response = [];
752. $response['html'] = json_decode($this->forward('App\Controller\DistributorProductsController::getDistributorProductAction')
753. ->getContent());
755. $distributorProduct = $this->em->getRepository(Distributors::class)
756. ->getDistributorProduct($distributor->getId(), $productId);
758. if($distributorProduct != null)
759. {
760. $response['distributor_id'] = $distributor->getId();
761. $response['itemId'] = $distributorProduct[0]['distributorProducts'][0]['itemId'];
762. $response['sku'] = $distributorProduct[0]['distributorProducts'][0]['sku'];
763. $response['unit_price'] = $distributorProduct[0]['distributorProducts'][0]['unitPrice'];
764. $response['stock_count'] = $distributorProduct[0]['distributorProducts'][0]['stockCount'];
765. $response['expiry_date'] = '';
766. $response['tax_exempt'] = $distributorProduct[0]['distributorProducts'][0]['taxExempt'];
767. $response['product'] = $distributorProduct[0]['distributorProducts'][0]['product'];
769. if($distributorProduct[0]['distributorProducts'][0]['expiryDate'] != null)
770. {
771. $response['expiry_date'] = $distributorProduct[0]['distributorProducts'][0]['expiryDate']->format('Y-m-d');
772. }
773. }
774. else
775. {
776. $product = $this->em->getRepository(Products::class)->find($productId);
778. $response['distributor_id'] = $distributor->getId();
779. $response['sku'] = '';
780. $response['distributor_no'] = '';
781. $response['unit_price'] = '';
782. $response['stock_count'] = '';
783. $response['expiry_date'] = '';
784. $response['tax_exempt'] = 0;
785. $response['product'] = [
786. 'dosage' => $product->getDosage(),
787. 'size' => $product->getSize(),
788. 'unit' => $product->getUnit(),
789. 'activeIngredient' => $product->getActiveIngredient(),
790. ];
791. }
792. }
793. else
794. {
795. $response['message'] = 'Inventory item not found';
796. }
798. return new JsonResponse($response);
799. }
801. #[Route('/distributors/inventory-update', name: 'distributor_inventory_update')]
802. public function distributorUpdateInventoryAction(Request $request, MailerInterface $mailer): Response
803. {
804. $data = $request->request->all('distributor_products_form');
805. $product = $this->em->getRepository(Products::class)->find($data['product']);
806. $distributor = $this->em->getRepository(Distributors::class)->find($data['distributor']);
807. $distributorProducts = $this->em->getRepository(DistributorProducts::class)->findOneBy(
808. [
809. 'product' => $data['product'],
810. 'distributor' => $data['distributor']
811. ]
812. );
813. $tracking = false;
814. $response['unitPrice'] = 0.00;
815. $response['stockLevel'] = 0;
817. if($distributorProducts == null){
819. $distributorProducts = new DistributorProducts();
821. } else {
823. if($distributorProducts->getStockCount() == 0){
825. $tracking = true;
826. }
827. }
829. if(!empty($data['product']) && !empty($data['distributor'])){
831. $trackingId = $distributor->getTracking()->getId();
833. $distributorProducts->setDistributor($distributor);
834. $distributorProducts->setProduct($product);
835. $distributorProducts->setSku($data['sku']);
836. $distributorProducts->setItemId($data['itemId']);
837. $distributorProducts->setTaxExempt($data['taxExempt']);
838. $distributorProducts->setIsActive(1);
840. $taxExempt = 0;
842. if(!empty($data['taxExempt'])){
844. $taxExempt = $data['taxExempt'];
845. }
847. $distributorProducts->setTaxExempt($taxExempt);
849. if($trackingId == 3)
850. {
851. $distributorProducts->setUnitPrice($data['unitPrice']);
852. $distributorProducts->setStockCount((int)$data['stockCount']);
853. }
855. // Get stock and price from API
856. if($trackingId == 1){
858. // Retrieve price & stock from api
859. $distributorId = $distributor->getId();
860. $priceStockLevels = json_decode($this->forward('App\Controller\ProductsController::zohoRetrieveItem',[
861. 'distributorId' => $distributorId,
862. 'itemId' => $data['itemId'],
863. ])->getContent(), true);
865. $response['unitPrice'] = $priceStockLevels['unitPrice'] ?? 0.00;
866. $response['stockLevel'] = $priceStockLevels['stockLevel'] ?? 0;
868. $distributorProducts->setUnitPrice($response['unitPrice']);
869. $distributorProducts->setStockCount($response['stockLevel']);
870. }
872. $this->em->persist($distributorProducts);
873. $this->em->flush();
875. // Update parent stock level
876. $stockCount = $this->em->getRepository(DistributorProducts::class)->getProductStockCount($product->getId());
878. $product->setStockCount($stockCount[0][1]);
880. // Get the lowest price
881. $lowestPrice = $this->em->getRepository(DistributorProducts::class)->getLowestPrice($product->getId());
883. $product->setUnitPrice($lowestPrice[0]['unitPrice'] ?? 0.00);
885. $this->em->persist($product);
886. $this->em->flush();
888. // Availability Tracker
889. $availabilityTracker = '';
891. if($tracking){
893. $availabilityTracker = $this->em->getRepository(AvailabilityTracker::class)->findBy([
894. 'product' => $product->getId(),
895. 'distributor' => $data['distributor'],
896. 'isSent' => 0,
897. ]);
899. foreach($availabilityTracker as $tracker){
901. $methodId = $tracker->getCommunication()->getCommunicationMethod()->getId();
902. $sendTo = $tracker->getCommunication()->getSendTo();
903. $product = $tracker->getProduct();
905. // In app notifications
906. if($methodId == 1){
908. $notifications = new Notifications();
910. $notifications->setClinic($tracker->getClinic());
911. $notifications->setIsRead(0);
912. $notifications->setIsReadDistributor(0);
913. $notifications->setIsActive(1);
914. $notifications->setAvailabilityTracker($tracker);
916. $this->em->persist($notifications);
917. $this->em->flush();
919. // Get the newly created notification
920. $notification = '
921. <table class="w-100">
922. <tr>
923. <td><span class="badge bg-success me-3">New Stock</span></td>
924. <td>'. $product->getName() .' '. $product->getDosage() . $product->getUnit() .'</td>
925. <td>
926. <a href="#" class="delete-notification" data-notification-id="'. $notifications->getId() .'">
927. <i class="fa-solid fa-xmark text-black-25 ms-3 float-end"></i>
928. </a>
929. </td>
930. </tr>
931. </table>';
933. $notifications = $this->em->getRepository(Notifications::class)->find($notifications->getId());
935. $notifications->setNotification($notification);
937. $this->em->persist($notifications);
938. $this->em->flush();
940. // Email notifications
941. } elseif($methodId == 2){
943. $body = '<table style="padding: 8px; border-collapse: collapse; border: none; font-family: arial">';
944. $body .= '<tr><td colspan="2">'. $product->getName() .' '. $product->getDosage() . $product->getUnit() .' is back in stock</td></tr>';
945. $body .= '<tr><td colspan="2">&nbsp;</td></tr>';
946. $body .= '<tr>';
947. $body .= ' <td><b>Distributor: </b></td>';
948. $body .= ' <td>'. $tracker->getDistributor()->getDistributorName() .'</td>';
949. $body .= '</tr>';
950. $body .= '<tr>';
951. $body .= ' <td><b>Stock Level: </b></td>';
952. $body .= ' <td>'. $tracker->getProduct()->getDistributorProducts()[0]->getStockCount() .'</td>';
953. $body .= '</tr>';
954. $body .= '</table>';
956. $subject = 'Fluid Stock Level Update';
957. $to = $sendTo;
959. exec(__DIR__ . '/../../bin/console app:send-email "'. $subject .'" "'. addslashes($body) .'" "'. $to .'" "" "" "'. true .'" > /dev/null 2>&1 &');
961. // Text notifications
962. } elseif($methodId == 3){
964. }
966. $availabilityTracker = $this->em->getRepository(AvailabilityTracker::class)->find($tracker->getId());
967. $availabilityTracker->setIsSent(1);
969. $this->em->persist($availabilityTracker);
970. $this->em->flush();
971. }
972. }
974. $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>';
976. } else {
978. $response['flash'] = 'An error occurred';
979. }
981. return new JsonResponse($response);
982. }
984. #[Route('/distributors/get/refresh-token', name: 'distributor_get_access_token')]
985. public function distributorGetRefreshTokenAction(Request $request): Response
986. {
987. $id = $this->getUser()->getDistributor()->getId();
988. $button = false;
989. $token = false;
990. $error = false;
992. if($id == null){
994. return $this->render('security/login.html.twig', [
995. 'last_username' => '',
996. 'error' => '',
997. 'csrf_token_intention' => 'authenticate',
998. 'user_type' => 'distributors',
1000. ]);
1001. }
1003. $api = $this->em->getRepository(ApiDetails::class)->findOneBy([
1004. 'distributor' => $id,
1005. ]);
1007. // Check client id & secret exist
1008. if($api == null){
1010. $error = true;
1012. } else {
1014. $refreshTokens = $api->getRefreshTokens();
1016. if(count($refreshTokens) == 0){
1018. $button = true;
1020. } else {
1022. $token = true;
1023. }
1024. }
1026. return new JsonResponse([
1027. 'token' => $token,
1028. 'button' => $button,
1029. 'error' => $error
1030. ]);
1031. }
1033. #[Route('/distributors/zoho/set/refresh-token', name: 'zoho_set_refresh_token')]
1034. public function setZohoRefreshTokenAction(Request $request): Response
1035. {
1036. $distributorId = $this->getUser()->getDistributor()->getId();
1037. $apiDetails = $this->em->getRepository(ApiDetails::class)->findOneBy([
1038. 'distributor' => $distributorId,
1039. ]);
1040. $code = $request->query->get('code');
1041. $error = $request->query->get('error');
1043. if($code != null) {
1045. $curl = curl_init();
1046. $clientId = $this->encryptor->decrypt($apiDetails->getClientId());
1047. $clientSecret = $this->encryptor->decrypt($apiDetails->getClientSecret());
1048. $endpoint = 'https://accounts.zoho.com/oauth/v2/token?code=' . $code . '&client_id=' . $clientId . '&';
1049. $endpoint .= 'client_secret=' . $clientSecret . '&redirect_uri='. $this->getParameter('app.base_url') .'/distributors/zoho/set/refresh-token&';
1050. $endpoint .= 'grant_type=authorization_code';
1052. curl_setopt_array($curl, [
1053. CURLOPT_URL => $endpoint,
1054. CURLOPT_RETURNTRANSFER => true,
1055. CURLOPT_ENCODING => '',
1056. CURLOPT_MAXREDIRS => 10,
1057. CURLOPT_TIMEOUT => 0,
1058. CURLOPT_FOLLOWLOCATION => true,
1059. CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
1060. CURLOPT_CUSTOMREQUEST => 'POST'
1061. ]);
1063. $json = curl_exec($curl);
1065. curl_close($curl);
1067. $response = json_decode($json, true);
1069. if(array_key_exists('refresh_token', $response)){
1071. $session = $this->requestStack->getSession();
1072. $session->set('accessToken', $response['access_token']);
1073. $session->set('refreshToken', $response['refresh_token']);
1075. $refreshToken = new RefreshTokens();
1076. $api = $this->getUser()->getDistributor()->getApiDetails();
1078. $refreshToken->setToken($response['refresh_token']);
1079. $refreshToken->setApiDetails($api);
1081. $this->em->persist($refreshToken);
1082. $this->em->flush();
1084. return $this->redirectToRoute('distributor_manage_inventory');
1086. } elseif(array_key_exists('error', $response)){
1088. echo $response['error'];
1089. }
1091. } elseif($error != null){
1093. echo $error;
1095. file_put_contents(__DIR__ . '/../../public/zoho.log', date('Y-m-d H:i:s') .': '. $error . "\n", FILE_APPEND);
1096. }
1098. return new JsonResponse('');
1099. }
1101. #[Route('/admin/get/distributors/list', name: 'admin_get_distributors_list')]
1102. public function adminGetDistributorsList(Request $request): Response
1103. {
1104. $status = (int) $request->request->get('status');
1105. $distributors = $this->em->getRepository(Distributors::class)->adminFindAll($status);
1106. $results = $this->pageManager->paginate($distributors[0], $request, self::ITEMS_PER_PAGE);
1107. $dataAction = 'data-action="click->admin--distributors#onClickGetList"';
1108. $pagination = $this->getPagination($request->get('page_id'), $results, $dataAction, self::ITEMS_PER_PAGE);
1109. $response = $this->render('Admin/distributors/distributors_list.html.twig', [
1110. 'distributors' => $results,
1111. 'pagination' => $pagination,
1112. ])->getContent();
1114. return new JsonResponse($response);
1115. }
1117. #[Route('/admin/get/distributor/form', name: 'admin_get_distributor_form')]
1118. public function adminGetDistributorForm(Request $request): Response
1119. {
1120. $distributorId = $request->request->get('distributor-id') ?? 0;
1121. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
1122. $distributorUsers = $this->em->getRepository(DistributorUsers::class)->findBy([
1123. 'distributor' => $distributorId
1124. ]);
1125. $userPermissions = $this->em->getRepository(UserPermissions::class)->findBy([
1126. 'isDistributor' => 1
1127. ]);
1128. $api = $this->em->getRepository(Api::class)->findAll();
1129. $countries = $this->em->getRepository(Countries::class)->findBy([
1130. 'isActive' => true,
1131. ]);
1132. $distributorProducts = $this->getDistributorInventory(1, $distributorId, 0, 0, $request);
1133. $scraperUrls = $this->em->getRepository(ScraperUrls::class)->findBy([
1134. 'scraperAuthentication' => $distributor->getScraperAunthentication()->getId(),
1135. ],
1136. [
1137. 'pageName' => 'ASC'
1138. ]);
1139. $response = $this->render('Admin/distributors/distributors.html.twig', [
1140. 'distributor' => $distributor,
1141. 'distributorUsers' => $distributorUsers,
1142. 'userPermissions' => $userPermissions,
1143. 'api' => $api,
1144. 'countries' => $countries,
1145. 'distributorProducts' => $distributorProducts,
1146. 'scraperUrls' => $scraperUrls,
1147. ])->getContent();
1149. return new JsonResponse($response);
1150. }
1152. #[Route('/admin/approve/distributor', name: 'admin_approve_distributor')]
1153. public function adminApproveDistributor(Request $request): Response
1154. {
1155. $distributorId = $request->request->get('distributor-id');
1156. $isApproved = $request->request->get('is-approved');
1157. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
1159. if($distributor != null)
1160. {
1161. if($isApproved == 1 || $isApproved == 0)
1162. {
1163. $isApproved = 2;
1164. }
1165. else if($isApproved == 2)
1166. {
1167. $isApproved = 1;
1168. }
1170. $distributor->setIsApproved($isApproved);
1172. $this->em->persist($distributor);
1173. $this->em->flush();
1174. }
1176. return new JsonResponse('');
1177. }
1179. #[Route('/admin/get-distributor-products', name: 'admin_get_distributor_products')]
1180. public function distributorInventory(Request $request): Response
1181. {
1182. $pageId = $request->request->get('page-id');
1183. $distributorId = $request->request->get('distributor-id');
1184. $manufacturerId = $request->request->get('manufacturer-id');
1185. $speciesId = $request->request->get('species-id');
1187. $response = $this->getDistributorInventory($pageId, $distributorId, $manufacturerId, $speciesId, $request);
1189. return new JsonResponse($response);
1190. }
1192. #[Route('/admin/save-scraper-frequency', name: 'admin_save_scraper_frequency')]
1193. public function saveScraperFrequency(Request $request): Response
1194. {
1195. $name = $request->request->get('name');
1196. $cron = $request->request->get('cron');
1197. $status = (int) $request->request->get('status');
1198. $scraperUrlId = $request->request->get('scraper-url-id');
1199. $frequency = $request->request->get('frequency');
1201. $scraperUrl = $this->em->getRepository(ScraperUrls::class)->find($scraperUrlId);
1203. if($scraperUrl == null)
1204. {
1205. $response = [
1206. 'flash' => 'Please first save the scraper url.',
1207. 'type' => 'danger'
1208. ];
1210. return new JsonResponse($response);
1211. }
1213. $cronJob = $this->em->getRepository(CronJob::class)->findOneBy([
1214. 'scraperUrl' => $scraperUrl->getId(),
1215. ]);
1217. if($cronJob == null)
1218. {
1219. $cronJob = new CronJob();
1220. }
1222. $cronJob->setName($name);
1223. $cronJob->setExpression($cron);
1224. $cronJob->setCommand($scraperUrl->getDistributor()->getScraperAunthentication()->getCommand());
1225. $cronJob->setActive($status);
1226. $cronJob->setScraperUrl($scraperUrl);
1227. $cronJob->setFrequency($frequency);
1228. $cronJob->setDescription($this->getCronDescription($cron, $frequency));
1230. $this->em->persist($cronJob);
1231. $this->em->flush();
1233. $response = [
1234. 'flash' => 'Schedule saved successfully.',
1235. 'type' => 'success'
1236. ];
1238. return new JsonResponse($response);
1239. }
1241. #[Route('/admin/run-scraper', name: 'admin_run_scraper')]
1242. public function runScraper(Request $request): Response
1243. {
1244. $command = $request->request->get('command');
1245. $argument = $request->request->get('argument');
1246. $email = $this->encryptor->decrypt($this->getUser()->getEmail());
1248. exec(__DIR__ . "/../../bin/console $command $argument $email > /dev/null 2>&1 &");
1250. $response = [
1251. 'flash' => 'Scraper successfully started.',
1252. 'type' => 'success'
1253. ];
1255. return new JsonResponse($response);
1256. }
1258. public function getCronDescription($cron, $frequency): string
1259. {
1260. $description = '';
1262. // Daily
1263. if(strtolower($frequency) == 'daily')
1264. {
1265. $pieces = explode(' ', $cron);
1266. $hour = $pieces[1];
1267. $timeOfDay = 'pm';
1269. if($hour >= 0 and $hour < 12)
1270. {
1271. $timeOfDay = 'am';
1272. }
1274. $description = 'Every day at '. $hour . $timeOfDay;
1275. }
1277. // Weekly
1278. if(strtolower($frequency) == 'weekly')
1279. {
1280. $pieces = explode(' ', $cron);
1281. $hour = $pieces[1];
1282. $day = (int) $pieces[4];
1283. $timeOfDay = 'pm';
1285. if($hour >= 0 and $hour < 12)
1286. {
1287. $timeOfDay = 'am';
1288. }
1290. $date = new \DateTime();
1291. $date->setISODate(date('Y'), 1, $day);
1292. $day = $date->format('l');
1294. $description = 'Every '. $day .' at '. $hour . $timeOfDay;
1295. }
1297. // Monthly
1298. if(strtolower($frequency) == 'monthly')
1299. {
1300. $pieces = explode(' ', $cron);
1301. $hour = $pieces[1];
1302. $day = $pieces[2];
1303. $timeOfDay = 'pm';
1305. if($hour >= 0 and $hour < 12)
1306. {
1307. $timeOfDay = 'am';
1308. }
1310. $description = 'At '. $hour . $timeOfDay .' on day '. $day .' of the month';
1311. }
1313. return $description;
1314. }
1316. public function getDistributorInventory($pageId, $distributorId, $manufacturerId, $speciesId, $request)
1317. {
1318. $dataAction = 'data-action="click->admin--distributors#onClickPagination"';
1319. $distributorProductsRepo = $this->em->getRepository(AiProducts::class)->findByManufacturer($distributorId,$manufacturerId,$speciesId);
1320. $distributorProducts = $this->pageManager->paginate($distributorProductsRepo[0], $request, self::ITEMS_PER_PAGE);
1321. $distributorProductsPagination = $this->getAjaxPagination($pageId, $distributorProducts, $distributorId, $dataAction);
1322. $species = $this->em->getRepository(AiProductsSpecies::class)->adminFindByDistributorProducts($distributorId);
1324. return $this->render('Admin/distributors/distributor_products.html.twig', [
1325. 'species' => $species,
1326. 'speciesId' => $speciesId,
1327. 'distributorProducts' => $distributorProducts,
1328. 'pagination' => $distributorProductsPagination,
1329. ])->getContent();
1330. }
1332. public function getPagination($currentPage, $results, $dataAction = '', $itemsPerPage = 10): string
1333. {
1334. return $this->render('pagination.html.twig', [
1335. 'currentPage' => $currentPage,
1336. 'results' => $results,
1337. 'dataAction' => $dataAction,
1338. 'itemsPerPage' => $itemsPerPage,
1339. 'lastPage' => $this->pageManager->lastPage($results),
1340. 'totalPages' => ceil(count($results) / $itemsPerPage),
1341. 'i' => max(1, $currentPage - 5),
1342. 'forLimit' => min($currentPage + 5, ceil(count($results) / $itemsPerPage)),
1343. ])->getContent();
1344. }
1346. public function getAjaxPagination($pageId, $results, $url, $dataAction = '', $itemsPerPage = 10): string
1347. {
1348. $currentPage = $pageId;
1349. $totalPages = ceil(count($results) / $itemsPerPage);
1350. $limit = 5;
1351. $lastPage = $this->pageManager->lastPage($results);
1352. $pagination = '';
1354. if(count($results) > 0)
1355. {
1356. $pagination .= '
1357. <!-- Pagination -->
1358. <div class="row mt-3">
1359. <div class="col-12">';
1361. if ($lastPage > 1)
1362. {
1363. $previousPageNo = $currentPage - 1;
1364. $previousPage = $url . $previousPageNo;
1366. $pagination .= '
1367. <nav class="custom-pagination">
1368. <ul class="pagination justify-content-center">
1369. ';
1371. $disabled = 'disabled';
1372. $dataDisabled = 'true';
1374. // Previous Link
1375. if ($currentPage > 1)
1376. {
1377. $disabled = '';
1378. $dataDisabled = 'false';
1379. }
1381. if ($totalPages >= 1 && $pageId <= $totalPages && $currentPage != 1)
1382. {
1383. $pagination .= '
1384. <li class="page-item ' . $disabled . '">
1385. <a
1386. class="address-pagination"
1387. aria-disabled="' . $dataDisabled . '"
1388. data-page-id="' . $currentPage - 1 . '"
1389. href="#"
1390. ' . $dataAction . '
1391. >
1392. <span aria-hidden="true">&laquo;</span> <span class="d-none d-sm-inline">Previous</span>
1393. </a>
1394. </li>
1395. <li class="page-item ">
1396. <a
1397. class="address-pagination"
1398. data-page-id="1"
1399. href="#"
1400. '. $dataAction .'
1401. >
1402. First
1403. </a>
1404. </li>';
1405. }
1407. $i = max(1, $currentPage - $limit);
1408. $forLimit = min($currentPage + $limit, $totalPages);
1409. $isActive = false;
1411. for (; $i <= $forLimit; $i++)
1412. {
1413. $active = '';
1415. if ($i == (int)$currentPage) {
1417. $active = 'active';
1418. $isActive = true;
1419. }
1421. // Go to previous page if all records for a page have been deleted
1422. if (!$isActive && $i == count($results)) {
1424. $active = 'active';
1425. }
1427. $pagination .= '
1428. <li class="page-item ' . $active . '">
1429. <a
1430. class="address-pagination"
1431. data-page-id="' . $i . '"
1432. href="#"
1433. ' . $dataAction . '
1434. >' . $i . '</a>
1435. </li>';
1436. }
1438. $disabled = 'disabled';
1439. $dataDisabled = 'true';
1441. if ($currentPage < $lastPage) {
1443. $disabled = '';
1444. $dataDisabled = 'false';
1445. }
1447. if ($currentPage < $lastPage)
1448. {
1449. $pagination .= '
1450. <li class="page-item ">
1451. <a
1452. class="address-pagination"
1453. data-page-id="'. $lastPage .'"
1454. href="#"
1455. '. $dataAction .'
1456. >
1457. Last
1458. </a>
1459. </li>
1460. <li class="page-item ' . $disabled . '">
1461. <a
1462. class="address-pagination"
1463. aria-disabled="' . $dataDisabled . '"
1464. data-page-id="' . $currentPage + 1 . '"
1465. href="#"
1466. '. $dataAction .'
1467. >
1468. <span class="d-none d-sm-inline">Next</span> <span aria-hidden="true">&raquo;</span>
1469. </a>
1470. </li>';
1471. }
1473. $pagination .= '
1474. </ul>
1475. </nav>
1476. <input type="hidden" id="page_no" value="' . $currentPage . '">
1477. </div>';
1478. }
1479. }
1481. return $pagination;
1482. }
1483. }