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;
52. private $mailer;
54. public function __construct(EntityManagerInterface $em, PaginationManager $pagination, RequestStack $requestStack, Encryptor $encryptor, MailerInterface $mailer)
55. {
56. $this->em = $em;
57. $this->pageManager = $pagination;
58. $this->requestStack = $requestStack;
59. $this->encryptor = $encryptor;
60. $this->mailer = $mailer;
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->setEmail($this->encryptor->encrypt($data->get('email')));
237. $distributors->setHashedEmail(md5($data->get('email')));
238. $distributors->setDomainName(md5($domainName[1]));
239. $distributors->setTelephone($this->encryptor->encrypt($data->get('telephone')));
240. $distributors->setIntlCode($this->encryptor->encrypt($data->get('intl-code')));
241. $distributors->setIsoCode($this->encryptor->encrypt($data->get('iso-code')));
242. $distributors->setAddressCountry($countries);
243. $distributors->setTracking($tracking);
244. $distributors->setIsApproved(0);
246. $this->em->persist($distributors);
247. $this->em->flush();
249. // Create user
250. $distributor = $this->em->getRepository(Distributors::class)->findOneBy([
251. 'hashedEmail' => md5($data->get('email')),
252. ]);
253. $distributorUsers = new DistributorUsers();
255. $hashed_pwd = $passwordHasher->hashPassword($distributorUsers, $plainTextPwd);
257. $distributorUsers->setDistributor($distributor);
258. $distributorUsers->setFirstName($this->encryptor->encrypt($data->get('first-name')));
259. $distributorUsers->setLastName($this->encryptor->encrypt($data->get('last-name')));
260. $distributorUsers->setPosition($this->encryptor->encrypt($data->get('position')));
261. $distributorUsers->setEmail($this->encryptor->encrypt($data->get('email')));
262. $distributorUsers->setHashedEmail(md5($data->get('email')));
263. $distributorUsers->setTelephone($this->encryptor->encrypt($data->get('telephone')));
264. $distributorUsers->setRoles(['ROLE_DISTRIBUTOR']);
265. $distributorUsers->setPassword($hashed_pwd);
266. $distributorUsers->setIsPrimary(1);
268. $this->em->persist($distributorUsers);
269. $this->em->flush();
271. // Assign User Permissions
272. $userPermissions = $this->em->getRepository(UserPermissions::class)->findBy([
273. 'isDistributor' => 1,
274. ]);
276. foreach($userPermissions as $userPermission){
278. $distributorUserPermissions = new DistributorUserPermissions();
280. $distributorUserPermissions->setUser($distributorUsers);
281. $distributorUserPermissions->setDistributor($distributors);
282. $distributorUserPermissions->setPermission($userPermission);
284. $this->em->persist($distributorUserPermissions);
285. }
287. $this->em->flush();
289. // Send Email
290. $body = '<table style="padding: 8px; border-collapse: collapse; border: none; font-family: arial">';
291. $body .= '<tr><td colspan="2">Hi '. $data->get('first_name') .',</td></tr>';
292. $body .= '<tr><td colspan="2">&nbsp;</td></tr>';
293. $body .= '<tr><td colspan="2">Please use the credentials below login to the Fluid Backend.</td></tr>';
294. $body .= '<tr><td colspan="2">&nbsp;</td></tr>';
295. $body .= '<tr>';
296. $body .= ' <td><b>URL: </b></td>';
297. $body .= ' <td><a href="https://'. $_SERVER['HTTP_HOST'] .'/distributors/login">https://'. $_SERVER['HTTP_HOST'] .'/distributor/login</a></td>';
298. $body .= '</tr>';
299. $body .= '<tr>';
300. $body .= ' <td><b>Username: </b></td>';
301. $body .= ' <td>'. $data->get('email') .'</td>';
302. $body .= '</tr>';
303. $body .= '<tr>';
304. $body .= ' <td><b>Password: </b></td>';
305. $body .= ' <td>'. $plainTextPwd .'</td>';
306. $body .= '</tr>';
307. $body .= '</table>';
309. $subject = 'Fluid Login Credentials';
310. $to = $data->get('email');
312. exec(__DIR__ . '/../../bin/console app:send-email "'. $subject .'" "'. addslashes($body) .'" "'. $to .'" "" "" "'. true .'" > /dev/null 2>&1 &');
313. }
315. $response = '
316. <div class="row pt-3">
317. <div class="col-12 text-center mt-1 pt-3 pb-3" id="order_header">
318. <h4 class="text-primary">Let\'s Create Your Account.</h4>
319. <span class="text-primary">
320. Your Fluid account was successfully created, an email with your login credentials has been sent to your inbox.
321. </span>
322. </div>';
324. } else {
326. $response = false;
327. }
329. return new JsonResponse($response);
330. }
332. #[Route('/distributors/get/company-information', name: 'get_company_information')]
333. public function getCompanyInformation(Request $request): Response
334. {
335. $distributorId = $this->getUser()->getDistributor()->getId();
336. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
337. $countries = $this->em->getRepository(Countries::class)->findAll();
339. $html = $this->render('frontend/distributors/company_information.html.twig', [
340. 'distributor' => $distributor,
341. 'countries' => $countries,
342. ])->getContent();
344. return new JsonResponse($html);
345. }
347. private function generatePassword(): string
348. {
349. $curl = curl_init();
351. curl_setopt_array($curl, array(
352. CURLOPT_URL => 'https://www.dinopass.com/password/simple',
353. CURLOPT_RETURNTRANSFER => true,
354. CURLOPT_ENCODING => '',
355. CURLOPT_MAXREDIRS => 10,
356. CURLOPT_TIMEOUT => 0,
357. CURLOPT_FOLLOWLOCATION => true,
358. CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
359. CURLOPT_CUSTOMREQUEST => 'GET',
360. ));
362. $response = curl_exec($curl);
364. curl_close($curl);
366. $this->plainPassword = $response;
368. return $this->plainPassword;
369. }
371. public function createDistributorUserForm()
372. {
373. $distributorUsers = new DistributorUsers();
375. return $this->createForm(DistributorUsersFormType::class, $distributorUsers);
376. }
378. #[Route('/distributors/update/company-information', name: 'distributor_update_company_information')]
379. public function distributorUpdateCompanyInformationAction(Request $request): Response
380. {
381. $data = $request->request->all('distributor_form');
383. $distributor = $this->getUser()->getDistributor();
384. $countryId = (int) $data['addressCountry'];
385. $logo = '';
386. $country = $this->em->getRepository(Countries::class)->find($countryId);
387. $isApproved = (bool) $distributor->getIsApproved() ?? false;
388. $tradeLicense = $_FILES['distributor_form']['name']['trade-license-file'];
389. $tradeLicenseNo = $data['trade-license-no'];
390. $tradeLicenseExpDate = $data['trade-license-exp-date'];
392. // Account approval required if reg docs change
393. if(
394. !empty($tradeLicense) || $tradeLicenseNo != $this->encryptor->decrypt($distributor->getTradeLicenseNo()) ||
395. $tradeLicenseExpDate != $distributor->getTradeLicenseExpDate()->format('Y-m-d')
396. )
397. {
398. $distributor->setIsApproved(0);
399. $isApproved = false;
400. }
402. if($distributor != null)
403. {
404. $domainName = explode('@', $data['email']);
406. $distributor->setDistributorName($this->encryptor->encrypt($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. $response = $this->render('Admin/distributors/distributors.html.twig', [
1134. 'distributor' => $distributor,
1135. 'distributorUsers' => $distributorUsers,
1136. 'userPermissions' => $userPermissions,
1137. 'api' => $api,
1138. 'countries' => $countries,
1139. 'distributorProducts' => $distributorProducts,
1140. ])->getContent();
1142. return new JsonResponse($response);
1143. }
1145. #[Route('/admin/approve/distributor', name: 'admin_approve_distributor')]
1146. public function adminApproveDistributor(Request $request): Response
1147. {
1148. $distributorId = $request->request->get('distributor-id');
1149. $isApproved = $request->request->get('is-approved');
1150. $distributor = $this->em->getRepository(Distributors::class)->find($distributorId);
1152. if($distributor != null)
1153. {
1154. if($isApproved == 1 || $isApproved == 0)
1155. {
1156. $isApproved = 2;
1157. }
1158. else if($isApproved == 2)
1159. {
1160. $isApproved = 1;
1161. }
1163. $distributor->setIsApproved($isApproved);
1165. $this->em->persist($distributor);
1166. $this->em->flush();
1167. }
1169. return new JsonResponse('');
1170. }
1172. #[Route('/admin/get-distributor-products', name: 'admin_get_distributor_products')]
1173. public function distributorInventory(Request $request): Response
1174. {
1175. $pageId = $request->request->get('page-id');
1176. $distributorId = $request->request->get('distributor-id');
1177. $manufacturerId = $request->request->get('manufacturer-id');
1178. $speciesId = $request->request->get('species-id');
1180. $response = $this->getDistributorInventory($pageId, $distributorId, $manufacturerId, $speciesId, $request);
1182. return new JsonResponse($response);
1183. }
1185. #[Route('/admin/save-scraper-frequency', name: 'admin_save_scraper_frequency')]
1186. public function saveScraperFrequency(Request $request): Response
1187. {
1188. $name = $request->request->get('name');
1189. $cron = $request->request->get('cron');
1190. $status = (int) $request->request->get('status');
1191. $scraperUrlId = $request->request->get('scraper-url-id');
1192. $frequency = $request->request->get('frequency');
1194. $scraperUrl = $this->em->getRepository(ScraperUrls::class)->find($scraperUrlId);
1196. if($scraperUrl == null)
1197. {
1198. $response = [
1199. 'flash' => 'Please first save the scraper url.',
1200. 'type' => 'danger'
1201. ];
1203. return new JsonResponse($response);
1204. }
1206. $cronJob = $this->em->getRepository(CronJob::class)->findOneBy([
1207. 'scraperUrl' => $scraperUrl->getId(),
1208. ]);
1210. if($cronJob == null)
1211. {
1212. $cronJob = new CronJob();
1213. }
1215. $cronJob->setName($name);
1216. $cronJob->setExpression($cron);
1217. $cronJob->setCommand($scraperUrl->getDistributor()->getScraperAunthentication()->getCommand());
1218. $cronJob->setActive($status);
1219. $cronJob->setScraperUrl($scraperUrl);
1220. $cronJob->setFrequency($frequency);
1221. $cronJob->setDescription($this->getCronDescription($cron, $frequency));
1223. $this->em->persist($cronJob);
1224. $this->em->flush();
1226. $response = [
1227. 'flash' => 'Schedule saved successfully.',
1228. 'type' => 'success'
1229. ];
1231. return new JsonResponse($response);
1232. }
1234. public function getCronDescription($cron, $frequency): string
1235. {
1236. $description = '';
1238. // Daily
1239. if(strtolower($frequency) == 'daily')
1240. {
1241. $pieces = explode(' ', $cron);
1242. $hour = $pieces[1];
1243. $timeOfDay = 'pm';
1245. if($hour >= 0 and $hour < 12)
1246. {
1247. $timeOfDay = 'am';
1248. }
1250. $description = 'Every day at '. $hour . $timeOfDay;
1251. }
1253. // Weekly
1254. if(strtolower($frequency) == 'weekly')
1255. {
1256. $pieces = explode(' ', $cron);
1257. $hour = $pieces[1];
1258. $day = (int) $pieces[4];
1259. $timeOfDay = 'pm';
1261. if($hour >= 0 and $hour < 12)
1262. {
1263. $timeOfDay = 'am';
1264. }
1266. $date = new \DateTime();
1267. $date->setISODate(date('Y'), 1, $day);
1268. $day = $date->format('l');
1270. $description = 'Every '. $day .' at '. $hour . $timeOfDay;
1271. }
1273. // Monthly
1274. if(strtolower($frequency) == 'monthly')
1275. {
1276. $pieces = explode(' ', $cron);
1277. $hour = $pieces[1];
1278. $day = $pieces[2];
1279. $timeOfDay = 'pm';
1281. if($hour >= 0 and $hour < 12)
1282. {
1283. $timeOfDay = 'am';
1284. }
1286. $description = 'At '. $hour . $timeOfDay .' on day '. $day .' of the month';
1287. }
1289. return $description;
1290. }
1292. public function getDistributorInventory($pageId, $distributorId, $manufacturerId, $speciesId, $request)
1293. {
1294. $dataAction = 'data-action="click->admin--distributors#onClickPagination"';
1295. $distributorProductsRepo = $this->em->getRepository(AiProducts::class)->findByManufacturer($distributorId,$manufacturerId,$speciesId);
1296. $distributorProducts = $this->pageManager->paginate($distributorProductsRepo[0], $request, self::ITEMS_PER_PAGE);
1297. $distributorProductsPagination = $this->getAjaxPagination($pageId, $distributorProducts, $distributorId, $dataAction);
1298. $species = $this->em->getRepository(AiProductsSpecies::class)->adminFindByDistributorProducts($distributorId);
1300. return $this->render('Admin/distributors/distributor_products.html.twig', [
1301. 'species' => $species,
1302. 'speciesId' => $speciesId,
1303. 'distributorProducts' => $distributorProducts,
1304. 'pagination' => $distributorProductsPagination,
1305. ])->getContent();
1306. }
1308. public function getPagination($currentPage, $results, $dataAction = '', $itemsPerPage = 10): string
1309. {
1310. return $this->render('pagination.html.twig', [
1311. 'currentPage' => $currentPage,
1312. 'results' => $results,
1313. 'dataAction' => $dataAction,
1314. 'itemsPerPage' => $itemsPerPage,
1315. 'lastPage' => $this->pageManager->lastPage($results),
1316. 'totalPages' => ceil(count($results) / $itemsPerPage),
1317. 'i' => max(1, $currentPage - 5),
1318. 'forLimit' => min($currentPage + 5, ceil(count($results) / $itemsPerPage)),
1319. ])->getContent();
1320. }
1322. public function getAjaxPagination($pageId, $results, $url, $dataAction = '', $itemsPerPage = 10): string
1323. {
1324. $currentPage = $pageId;
1325. $totalPages = ceil(count($results) / $itemsPerPage);
1326. $limit = 5;
1327. $lastPage = $this->pageManager->lastPage($results);
1328. $pagination = '';
1330. if(count($results) > 0)
1331. {
1332. $pagination .= '
1333. <!-- Pagination -->
1334. <div class="row mt-3">
1335. <div class="col-12">';
1337. if ($lastPage > 1)
1338. {
1339. $previousPageNo = $currentPage - 1;
1340. $previousPage = $url . $previousPageNo;
1342. $pagination .= '
1343. <nav class="custom-pagination">
1344. <ul class="pagination justify-content-center">
1345. ';
1347. $disabled = 'disabled';
1348. $dataDisabled = 'true';
1350. // Previous Link
1351. if ($currentPage > 1)
1352. {
1353. $disabled = '';
1354. $dataDisabled = 'false';
1355. }
1357. if ($totalPages >= 1 && $pageId <= $totalPages && $currentPage != 1)
1358. {
1359. $pagination .= '
1360. <li class="page-item ' . $disabled . '">
1361. <a
1362. class="address-pagination"
1363. aria-disabled="' . $dataDisabled . '"
1364. data-page-id="' . $currentPage - 1 . '"
1365. href="#"
1366. ' . $dataAction . '
1367. >
1368. <span aria-hidden="true">&laquo;</span> <span class="d-none d-sm-inline">Previous</span>
1369. </a>
1370. </li>
1371. <li class="page-item ">
1372. <a
1373. class="address-pagination"
1374. data-page-id="1"
1375. href="#"
1376. '. $dataAction .'
1377. >
1378. First
1379. </a>
1380. </li>';
1381. }
1383. $i = max(1, $currentPage - $limit);
1384. $forLimit = min($currentPage + $limit, $totalPages);
1385. $isActive = false;
1387. for (; $i <= $forLimit; $i++)
1388. {
1389. $active = '';
1391. if ($i == (int)$currentPage) {
1393. $active = 'active';
1394. $isActive = true;
1395. }
1397. // Go to previous page if all records for a page have been deleted
1398. if (!$isActive && $i == count($results)) {
1400. $active = 'active';
1401. }
1403. $pagination .= '
1404. <li class="page-item ' . $active . '">
1405. <a
1406. class="address-pagination"
1407. data-page-id="' . $i . '"
1408. href="#"
1409. ' . $dataAction . '
1410. >' . $i . '</a>
1411. </li>';
1412. }
1414. $disabled = 'disabled';
1415. $dataDisabled = 'true';
1417. if ($currentPage < $lastPage) {
1419. $disabled = '';
1420. $dataDisabled = 'false';
1421. }
1423. if ($currentPage < $lastPage)
1424. {
1425. $pagination .= '
1426. <li class="page-item ">
1427. <a
1428. class="address-pagination"
1429. data-page-id="'. $lastPage .'"
1430. href="#"
1431. '. $dataAction .'
1432. >
1433. Last
1434. </a>
1435. </li>
1436. <li class="page-item ' . $disabled . '">
1437. <a
1438. class="address-pagination"
1439. aria-disabled="' . $dataDisabled . '"
1440. data-page-id="' . $currentPage + 1 . '"
1441. href="#"
1442. '. $dataAction .'
1443. >
1444. <span class="d-none d-sm-inline">Next</span> <span aria-hidden="true">&raquo;</span>
1445. </a>
1446. </li>';
1447. }
1449. $pagination .= '
1450. </ul>
1451. </nav>
1452. <input type="hidden" id="page_no" value="' . $currentPage . '">
1453. </div>';
1454. }
1455. }
1457. return $pagination;
1458. }
1459. }