src/Model/UserModel.php line 3819

1. <?php
3. namespace App\Model;
5. use Pimcore\Db;
6. use Carbon\Carbon;
7. use App\Lib\Utility;
8. use App\Lib\ExcelGenerator;
9. use App\Service\EmailService;
10. use Pimcore\Model\DataObject;
11. use App\Service\UserPermission;
12. use Pimcore\Model\DataObject\Customer;
13. use Pimcore\Model\DataObject\Location;
14. use Pimcore\Model\DataObject\Tags;
15. use Pimcore\Model\DataObject\UserGroup;
16. use Pimcore\Model\DataObject\UserSMSGroup;
17. use Symfony\Component\HttpFoundation\Request;
18. use App\C2IntegrationBundle\Service\C2Service;
19. use PhpOffice\PhpSpreadsheet\Spreadsheet;
20. use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
21. use DateTime;
22. use Pimcore\Model\Asset\MetaData\ClassDefinition\Data\DataObject as DataDataObject;
23. use Pimcore\Model\DataObject\Subscription;
24. use Pimcore\Model\DataObject\UserTag;
25. use App\Model\ReportingPortalModel;
26. use App\Model\EwsPortalModel;
27. use Pimcore\Model\DataObject\PermissionGroup;
29. class UserModel
30. {
31.     public $emailService;
32.     public $userPermission;
33.     private $locationModel;
34.     private $c2Service;
35.     private $reportingPortalModel;
36.     private $ewsPortalModel;
37.     function __construct()
38.     {
39.         $this->emailService  = new EmailService();
40.         $this->userPermission  = new UserPermission();
41.         $this->locationModel = new LocationModel();
42.         $this->c2Service = new C2Service();
43.         $this->reportingPortalModel = new ReportingPortalModel();
44.         $this->ewsPortalModel = new EwsPortalModel();
45.     }
48.     public function register($request, $params, $translator): array
49.     {
50.         $result = [];
51.         try {
53.             Utility::validateEmail($params['email']);
54.             Utility::validateName($params['name']);
56.             if (!$params['organization'] instanceof \Pimcore\Model\DataObject\Organization) {
57.                 return ["success" => false, "message" => $translator->trans("invalid_organization_passed")];
58.             }
59.             if (!$params['role'] instanceof \Pimcore\Model\DataObject\UserRole) {
60.                 return ["success" => false, "message" => $translator->trans("invalid_user_role")];
61.             }
63.             $user = DataObject\Customer::getByEmail($params['email'], true);
65.             if ($user instanceof \Pimcore\Model\DataObject\Customer) {
66.                 return ["success" => false, "message" => $translator->trans("user_already_exists")];
67.             }
69.             $userGroup = DataObject\UserGroup::getById($params['groupId'], true);
71.             $registerUser = new DataObject\Customer();
72.             $registerUser->setParent(DataObject\Service::createFolderByPath('/UserManagement/Users'));
73.             $registerUser->setKey(trim(strip_tags($params['email'])));
74.             $registerUser->setName(strip_tags($params['name']));
75.             $registerUser->setEmail(trim(strip_tags($params['email'])));
76.             if ((isset($params['published'])) && ($params['published'] == false)) {
77.                 # code...
78.                 $registerUser->setToken((isset($params['token'])) ? $params['token'] : '');
79.             }
80.             $registerUser->setRole($params['role']);
81.             if ($userGroup instanceof \Pimcore\Model\DataObject\UserGroup) {
82.                 $registerUser->setUserGroup($userGroup);
83.             }
85.             // assign user permissions to user
86.             if (isset($params['permissionUserGroupIds']) && !empty($params['permissionUserGroupIds']) && is_array($params['permissionUserGroupIds'])) {
87.                 $permissionGroups = [];
88.                 foreach ($params['permissionUserGroupIds'] as $groupId) {
89.                     $permissionGroup = PermissionGroup::getById($groupId);
90.                     if ($permissionGroup) {
91.                         $permissionGroups[] = $permissionGroup;
92.                     }
93.                 }
94.                 $registerUser->setPermissionGroups($permissionGroups);
95.             }
97.             $registerUser->setOrganization($params['organization']);
98.             $registerUser->setPassword($params['password']);
99.             $registerUser->setTitle((isset($params['title'])) ? $params['title'] : '');
100.             $registerUser->setDepartment((isset($params['department'])) ? $params['department'] : '');
101.             $registerUser->setCreatedBy($params['createdBy']);
102.             // Set created-by snapshot fields for future reference even if relation is removed
103.             if (isset($params['createdBy']) && $params['createdBy'] instanceof DataObject\Customer) {
104.                 $creator = $params['createdBy'];
105.                 $registerUser->setCreatedByUserName($creator->getName());
106.                 $registerUser->setCreatedByUserEmail($creator->getEmail());
107.                 $registerUser->setCreatedByUserStatus($creator->getIsDeleted() ? 'deleted' : 'active');
108.             } else {
109.                 $registerUser->setCreatedByUserStatus('deleted');
110.             }
111.             $registerUser->setPublished((isset($params['published'])) ? $params['published'] : true);
112.             $registerUser->setIsActive(true);
113.             $registerUser->setphoneNo(isset($params['phone']) ? $params['phone'] : '');
114.             if ($params['role']->getName() == USER_ROLES['CLIENT_ADMIN'] || $params['role']->getName() == USER_ROLES['CLIENT_USER']) {
115.                 $registerUser->setTwoFactorAuth(true);
116.             }
118.             $registerUser->save();
120.             // assign default subscription based on role
121.             if ($params['role']->getName() !== USER_ROLES['NCM_IT'] && $params['role']->getName() !== USER_ROLES['NCM_OPERATOR']) {
122.                 # code...
123.                 $this->createSubscription($translator, $registerUser, $params['role'], isset($params['isNoExpiry']) ? $params['isNoExpiry'] : false);
124.             }
125.             return ["success" => true, "message" => $translator->trans("user_registered_success"), 'data' => $registerUser];
126.         } catch (\Exception $ex) {
127.             throw new \Exception($ex->getMessage());
128.         }
129.         return $result;
130.     }
132.     /**
133.      * Create Subscritpion 
134.      */
135.     public function createSubscription($translator, $user, $role, $isNoExpiry = false): array
136.     {
137.         $result = [];
138.         try {
139.             $subscriptionsArray = [];
141.             if ($role instanceof DataObject\UserRole) {
143.                 $packages = $role->getDefaultPackages();
144.                 if ($packages) {
145.                     foreach ($packages as $key => $package) {
146.                         if ($package instanceof DataObject\Package) {
147.                             if ($user instanceof DataObject\Customer) {
148.                                 $subscription = $this->setSubscription($package, $user, null, "default", true);
149.                                 if ($subscription instanceof DataObject\Subscription) {
150.                                     $subscriptionsArray[] = [
151.                                         "id" => $subscription->getId(),
152.                                         "key" => $subscription->getKey(),
153.                                     ];
154.                                 }
155.                             }
156.                         }
157.                     }
158.                     return ["success" => true, "data" => $subscriptionsArray];
159.                 }
160.             }
161.         } catch (\Exception $ex) {
162.             throw new \Exception($ex->getMessage());
163.         }
165.         return $result;
166.     }
168.     public function editUser($params, $translator): array
169.     {
171.         $updateUser = DataObject\Customer::getById($params['id'], true);
173.         if ($updateUser instanceof DataObject\Customer && !$updateUser->getIsDeleted()) {
174.             $loggedInUserRole = $params['loggedInUser']->getRole() ? $params['loggedInUser']->getRole()->getName() : null;
175.             $updateOrganization = $updateUser->getOrganization();
177.             // Update client type for NCM_IT role
178.             if (!empty($params['client_type'])) {
179.                 if ($loggedInUserRole == USER_ROLES['NCM_IT']  || $loggedInUserRole == USER_ROLES['NCM_OPERATOR'] && $updateOrganization) {
180.                     $updateOrganization->setCilent_type($params['client_type']);
181.                     $updateOrganization->setClientType($params['client_type']);
182.                     $updateOrganization->save();
183.                 } else {
184.                     return [
185.                         "success" => false,
186.                         "message" => $translator->trans("access_denied_to_update_organization_client_type")
187.                     ];
188.                 }
189.             }
191.             // Update entity status with validation
192.             if (!empty($params['entity_status'])) {
193.                 $allowedStatuses = ['paid', 'trial', 'expired'];
195.                 if (in_array($params['entity_status'], $allowedStatuses)) {
196.                     if (in_array($loggedInUserRole, [USER_ROLES['NCM_IT'], USER_ROLES['NCM_OPERATOR']]) && $updateOrganization) {
197.                         if ($params['client_type'] == "government") {
198.                             $updateOrganization->setStatus("paid");
199.                         } else {
200.                             $updateOrganization->setStatus($params['entity_status']);
201.                         }
203.                         if ($params['entity_status'] == "trial") {
204.                             if (empty($params['trialLimit'])) {
205.                                 return [
206.                                     "success" => false,
207.                                     "message" => $translator->trans("trial_limit_is_required")
208.                                 ];
209.                             }
211.                             if ($updateOrganization->getStatus() == "expired") {
212.                                 $updateOrganization->setPackageActivationDate(Carbon::now());
213.                             }
215.                             $updateOrganization->setTrialLimit($params['trialLimit']);
216.                         }
218.                         $updateOrganization->save();
219.                     }
220.                 }
221.             }
223.             // Update company name in English
224.             if (!empty($params['company_name_en'])) {
225.                 if ($loggedInUserRole == USER_ROLES['NCM_IT'] || $loggedInUserRole == USER_ROLES['NCM_OPERATOR'] && $updateOrganization) {
226.                     // Check if the name already exists for another organization
227.                     $existingOrganization = DataObject\Organization::getByName($params['company_name_en'], 'en', ['limit' => 1, 'unpublished' => true]);
228.                     if ($existingOrganization && $existingOrganization->getId() !== $updateOrganization->getId()) {
229.                         return [
230.                             "success" => false,
231.                             "message" => $translator->trans("organization_already_exists") . " : " . $params['company_name_en']
232.                         ];
233.                     }
234.                     $updateOrganization->setName($params['company_name_en'], 'en');
235.                     $updateOrganization->setKey(trim(strip_tags($params['company_name_en']))); // Update key to match new name
236.                     $updateOrganization->save();
237.                 } else {
238.                     return [
239.                         "success" => false,
240.                         "message" => $translator->trans("access_denied_to_update_organization_company_name_en")
241.                     ];
242.                 }
243.             }
245.             // Update company name in Arabic
246.             if (!empty($params['company_name_ar'])) {
247.                 if ($loggedInUserRole == USER_ROLES['NCM_IT'] || $loggedInUserRole == USER_ROLES['NCM_OPERATOR'] && $updateOrganization) {
248.                     $updateOrganization->setName($params['company_name_ar'], 'ar');
249.                     $updateOrganization->save();
250.                 } else {
251.                     return [
252.                         "success" => false,
253.                         "message" => $translator->trans("access_denied_to_update_organization_company_name_ar")
254.                     ];
255.                 }
256.             }
258.             // Update user details (name, password, phone, etc.)
259.             if (!empty($params['name'])) {
260.                 $updateUser->setName(strip_tags($params['name']));
261.             }
263.             if (!empty($params['password'])) {
264.                 $updateUser->setPassword(strip_tags($params['password']));
265.             }
267.             // update phone number
268.             if (!empty($params['phone'])) {
269.                 $phone = trim($params['phone']);
270.                 if (strlen($phone) !== 9) {
271.                     return ["success" => false, "message" => $translator->trans("phone_no_must_be_9_digits")];
272.                 } elseif (!ctype_digit($phone)) {
273.                     return ["success" => false, "message" => $translator->trans("phone_no_must_be_numeric")];
274.                 } else {
275.                     $updateUser->setPhoneNo($phone);
276.                 }
277.             } else if (empty($params['phone']) && isset($params['phone'])) {
278.                 $updateUser->setPhoneNo("");
279.             }
281.             // Set user role if provided
282.             if (!empty($params['role'])) {
283.                 $userRole = DataObject\UserRole::getByName(USER_ROLES[$params['role']], true);
284.                 if ($userRole instanceof DataObject\UserRole) {
285.                     // Prevent role update if it would leave no admin in the organization
286.                     if ($params['role'] == USER_ROLES['CLIENT_USER'] && $updateUser->getRole()->getName() == USER_ROLES['CLIENT_ADMIN']) {
287.                         $adminRole = DataObject\UserRole::getByName(USER_ROLES['CLIENT_ADMIN'], true);
288.                         $adminCount = new DataObject\Customer\Listing();
289.                         $adminCount->filterByOrganization($updateUser->getOrganization());
290.                         $adminCount->filterByRole($adminRole);
291.                         $adminCount->filterByIsActive(true);
293.                         if ($adminCount->getCount() <= 1) {
294.                             return [
295.                                 "success" => false,
296.                                 "message" => $translator->trans('atleast_one_admin_required')
297.                             ];
298.                         }
299.                     }
301.                     $updateUser->setRole($userRole);
303.                     // Update default Package according to role
304.                     $rolePackage = $userRole->getDefaultPackages();
305.                     if ($rolePackage) {
306.                         foreach ($rolePackage as $package) {
307.                             if ($package instanceof DataObject\Package) {
308.                                 $this->updateSubscription($package, $updateUser, null, "default");
309.                             }
310.                         }
311.                     }
312.                 }
313.             }
315.             // Set department and title if provided
316.             if (!empty($params['department'])) {
317.                 $updateUser->setDepartment(strip_tags($params['department']));
318.             }
320.             if (!empty($params['title'])) {
321.                 $updateUser->setTitle(strip_tags($params['title']));
322.             }
324.             // Assign location by location tag id to user
325.             if (!empty($params['location_tag_ids'])) {
326.                 $this->assignLocationToUser($params['loggedInUser'], null, $params['location_tag_ids'], [$updateUser->getId()], null, false, false, $translator);
327.             }
329.             $updateUser->save();
331.             // Add updated user to updated permissions
332.             $params['user'] = $updateUser;
334.             // Package subscription update
335.             if (!empty($params['package_id'])) {
336.                 $package = DataObject\Package::getById($params['package_id'], true);
337.                 if ($package instanceof DataObject\Package) {
338.                     $this->updateSubscription($package, $params['user'], null, "custom");
339.                 }
340.             }
342.             if (isset($params['disallowedApiGroups'])) {
343.                 $this->disallowApiGroups($params['user'], $params['disallowedApiGroups'], "custom");
344.             }
346.             // Handle location assignment for CLIENT_ADMIN or CLIENT_USER roles
347.             if (in_array($params['role'], [USER_ROLES['CLIENT_ADMIN'], USER_ROLES['CLIENT_USER']])) {
348.                 if (isset($params['location'])) {
349.                     foreach ($params['location'] as $value) {
350.                         $location = DataObject\Location::getById($value, true);
351.                         if ($location) {
352.                             $this->locationModel->locationMetaData($location, $updateUser);
353.                         }
354.                     }
355.                 }
356.             }
358.             return [
359.                 "success" => true,
360.                 "message" => $translator->trans("user_updated_successfully")
361.             ];
362.         }
364.         return [
365.             "success" => false,
366.             "message" => $translator->trans("user_does_not_exist")
367.         ];
368.     }
373.     public function editNCMUser($params, $translator): array
374.     {
375.         $result = [];
377.         // try {
379.         $updateUser = DataObject\Customer::getById($params['id'], true);
381.         if ($updateUser instanceof DataObject\Customer && $updateUser->getIsDeleted() != true) {
384.             $loggedInUserRole = $params['loggedInUser']->getRole() ? $params['loggedInUser']->getRole()->getName() : null;
387.             if (isset($params['name']) && !empty($params['name'])) {
388.                 $updateUser->setName(strip_tags($params['name']));
389.             }
391.             // Set Role if $UserRole is provided
392.             if (isset($params['role']) && !empty($params['role'])) {
393.                 $UserRole = DataObject\UserRole::getByName(USER_ROLES[$params['role']], true);
394.                 if ($UserRole instanceof DataObject\UserRole) {
395.                     $updateUser->setRole($UserRole);
398.                     // Update default Package according to role
399.                     $rolePackage = $UserRole->getDefaultPackages();
400.                     if ($rolePackage) {
401.                         foreach ($rolePackage as $key => $package) {
402.                             if ($package instanceof DataObject\Package) {
403.                                 $this->updateSubscription($package, $updateUser, null, "default");
404.                             }
405.                         }
406.                     }
407.                 }
408.             }
410.             // update password
411.             if (isset($params['password']) && !empty($params['password'])) {
412.                 $updateUser->setPassword(strip_tags($params['password']));
413.             }
415.             // updated permissions 
416.             if (isset($params['allowedApiGrpups']) && !empty($params['allowedApiGrpups'])) {
417.                 $this->updateNCMUserSubscription($updateUser, $params['allowedApiGrpups']);
418.             }
421.             // update permission user groups
422.             if (isset($params['permissionUserGroupIds']) && !empty($params['permissionUserGroupIds'])) {
423.                 // Validate and prepare permission groups
424.                 $permissionGroups = [];
425.                 foreach ($params['permissionUserGroupIds'] as $groupId) {
426.                     $permissionGroup = PermissionGroup::getById($groupId);
427.                     if ($permissionGroup) {
428.                         $permissionGroups[] = $permissionGroup;
429.                     }
430.                 }
431.                 $updateUser->setPermissionGroups($permissionGroups);
432.             }
434.             // assign user tag to user
436.             if (isset($params['tagId']) && !empty($params['tagId'])) {
437.                 $tage  = UserTag::getById($params['tagId']);
438.                 if ($tage instanceof UserTag) {
439.                     $updateUser->setTag($tage);
440.                 }
441.             }
443.             if (isset($params['phone']) && !empty($params['phone'])) {
444.                 $updateUser->setPhoneNo(strip_tags($params['phone']));
445.             }
448.             $updateUser->save();
450.             // unset($params["Authorization"]);
451.             // $params["loggedInUserEmail"] = $loggedInUserRole = $params['loggedInUser']->getEmail();
452.             // $ncmReportingUser = $this->reportingPortalModel->updateNcmUser($params);
453.             // $ewsPortalUser = $this->ewsPortalModel->updateNcmUser($params);
456.             return ["success" => true, "message" => $translator->trans("user_updated_successifully")];
457.         }
459.         return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
460.         // } catch (\Exception $ex) {
461.         //     throw new \Exception($ex->getMessage());
462.         // }
464.         return $result;
465.     }
467.     public function disallowApiGroups($user, $disallowedApiGroups, $type)
468.     {
470.         $result = [];
471.         if (!$user instanceof DataObject\Customer) {
472.             return ["success" => false, "message" => "User is not available"];
473.         }
475.         $customSubscriptions = new DataObject\Subscription\Listing();
476.         $customSubscriptions->filterBySubscribedUser($user);
477.         $customSubscriptions->filterBySubscriptionType("custom");
478.         $customSubscriptions->filterByIsActive(true);
479.         $updateSubscription = $customSubscriptions->current();
480.         if ($updateSubscription instanceof  DataObject\Subscription) {
482.             //Set Disallowed ApiGroups
483.             if ($disallowedApiGroups != null) {
484.                 $disallowedApiGroupsArr = [];
485.                 foreach ($disallowedApiGroups as $disallowedApiGroupsId) {
486.                     $apiGroup =  DataObject\APIGroup::getById($disallowedApiGroupsId, true);
487.                     $disallowedApiGroupsArr[] = $apiGroup;
488.                 }
490.                 $updateSubscription->setDisallowedApiGroups($disallowedApiGroupsArr);
491.             } else {
492.                 $updateSubscription->setDisallowedApiGroups(null);
493.             }
494.             $updateSubscription->save();
495.         }
497.         return  $updateSubscription;
498.     }
500.     public function updateUserGroupData(
501.         $loggedInUser,
502.         $locations,
503.         $locationTagIds,
504.         $userGroupId,
505.         $userIds,
506.         $request,
507.         $lang,
508.         $translator
509.     ): array {
510.         $result = [];
512.         try {
514.             $userGroup = DataObject\UserGroup::getById($userGroupId, true);
516.             if (!$userGroup instanceof DataObject\UserGroup) {
517.                 return ["success" => false, "message" => $translator->trans("user_group_is_not_available")];
518.             }
520.             if (count($userIds) > 0) {
521.                 foreach ($userIds as $key => $userId) {
522.                     $user = DataObject\Customer::getById($userId, true);
523.                     $userGroupArr[] =  $userGroup;
524.                     foreach ($user->getUserGroup() as $group) {
525.                         $userGroupArr[] = $group;
526.                     }
527.                     $userGroupArr = array_unique($userGroupArr);
528.                     if ($user instanceof DataObject\Customer) {
529.                         $user->setUserGroup($userGroupArr);
530.                         $user->save();
531.                     }
532.                 }
534.                 // Assign location by location tag id to user
535.                 if (isset($locationTagIds) && !empty($locationTagIds)) {
536.                     $assignLocationByLocationTagId = $this->assignLocationToUser($loggedInUser, $locations, $locationTagIds, $userIds, null, false, false, $translator);
537.                     if (isset($assignLocationByLocationTagId['success']) && $assignLocationByLocationTagId['success'] == false) {
538.                         return $assignLocationByLocationTagId;
539.                     }
540.                 }
542.                 return ["success" => true, "message" => $translator->trans("user_group_are_updated_successfully ")];
543.             }
546.             return ["success" => false, "message" => $translator->trans("user_group_not_available")];
547.         } catch (\Exception $ex) {
548.             throw new \Exception($ex->getMessage());
549.         }
551.         return $result;
552.     }
554.     public function createUserGroupData($user, $groupNameEn, $groupNameAr, $detailEn, $detailAr, $groupId, $request, $lang, $translator): array
555.     {
556.         $result = [];
558.         try {
560.             $organization = $user->getOrganization();
562.             if (!$organization instanceof DataObject\Organization) {
563.                 return ["success" => false, "message" => $translator->trans("user_does_not_belongs_to_organization ")];
564.             }
565.             $userGroup = new DataObject\UserGroup\Listing();
566.             $userGroup->setLocale($lang);
567.             $userGroup->setCondition("groupName = ? ", [$groupNameEn]);
568.             $userGroup->filterByOrganization($organization);
569.             $userGroup = $userGroup->current();
571.             if ($userGroup instanceof DataObject\UserGroup) {
572.                 return ["success" => false, "message" => $translator->trans("user_group_name_already_available")];
573.             }
574.             if (!empty($groupId)) {
575.                 $userGroup = DataObject\UserGroup::getById($groupId, true);
576.                 if (!$userGroup instanceof DataObject\UserGroup) {
577.                     return ["success" => false, "message" => $translator->trans("user_group_is_not_available")];
578.                 }
579.                 $userGroup->setKey(trim(strip_tags($groupNameEn)));
580.                 $userGroup->setGroupName($groupNameEn, 'en');
581.                 $userGroup->setGroupName($groupNameAr, 'ar');
582.                 $userGroup->setDetail($detailEn, 'en');
583.                 $userGroup->setDetail($detailAr, 'ar');
584.                 $userGroup->save();
585.                 if ($userGroup) {
586.                     return ["success" => true, "message" => $translator->trans("user_group_updated_successfully")];
587.                 }
588.             }
589.             $userGroup = new DataObject\UserGroup();
590.             $userGroup->setParent(DataObject\Service::createFolderByPath('/UserManagement/UserGroups/' . $organization->getName()));
591.             $userGroup->setKey(trim(strip_tags($groupNameEn)));
592.             $userGroup->setGroupName($groupNameEn, 'en');
593.             $userGroup->setGroupName($groupNameAr, 'ar');
594.             $userGroup->setDetail($detailEn, 'en');
595.             $userGroup->setDetail($detailAr, 'ar');
596.             $userGroup->setOrganization($organization);
597.             $userGroup->setPublished(true);
598.             $userGroup->save();
599.             if ($userGroup) {
600.                 return ["success" => true, "message" => $translator->trans("user_group_created_successfully"), "user_group_id" => $userGroup->getId()];
601.             }
602.         } catch (\Exception $ex) {
603.             throw new \Exception($ex->getMessage());
604.         }
606.         return $result;
607.     }
609.     public function editUserGroupData($id, $groupNameEn, $groupNameAr, $detailEn, $detailAr, $request, $lang, $translator): array
610.     {
611.         $result = [];
613.         try {
615.             $userGroup = DataObject\UserGroup::getById($id, true);
617.             if (!$userGroup instanceof DataObject\UserGroup) {
618.                 return ["success" => false, "message" => $translator->trans("user_group_is_not_available")];
619.             }
621.             if (isset($groupNameEn) && !empty($groupNameEn)) {
622.                 $userGroup->setGroupName($groupNameEn, 'en');
623.             }
624.             if (isset($groupNameAr) && !empty($groupNameAr)) {
625.                 $userGroup->setGroupName($groupNameAr, 'ar');
626.             }
627.             if (isset($detailEn) && !empty($detailEn)) {
628.                 $userGroup->setDetail($detailEn, 'en');
629.             }
630.             if (isset($detailAr) && !empty($detailAr)) {
631.                 $userGroup->setDetail($detailAr, 'ar');
632.             }
633.             $userGroup->save();
634.             if ($userGroup) {
635.                 return ["success" => true, "message" => $translator->trans("user_group_updated_successfully")];
636.             }
637.         } catch (\Exception $ex) {
638.             throw new \Exception($ex->getMessage());
639.         }
641.         return $result;
642.     }
645.     public function deleteUserGroup($user, $id, $request, $translator): array
646.     {
647.         $result = [];
649.         try {
651.             $userGroup = DataObject\UserGroup::getById($id, true);
653.             if (!$userGroup instanceof DataObject\UserGroup) {
654.                 return ["success" => false, "message" => $translator->trans("user_group_is_not_available")];
655.             }
657.             if (!$userGroup->getOrganization()) {
658.                 return ["success" => false, "message" => $translator->trans("no_organization_is_assigned_to_this_user_group")];
659.             }
661.             $loggedInUserOrganizationName = $user->getOrganization() ? $user->getOrganization()->getName() : '';
662.             if ($userGroup->getOrganization()->getName("en") != $loggedInUserOrganizationName) {
663.                 return ["success" => false, "message" => $translator->trans("user_group_is_not_assigned_to_your_organization")];
664.             }
665.             $userGroup->delete();
666.             return ["success" => true, "message" => $translator->trans("user_group_deleted_successifully")];
667.         } catch (\Exception $ex) {
668.             throw new \Exception($ex->getMessage());
669.         }
671.         return $result;
672.     }
674.     public function userGroupListing($user, $translator, $paginator, $params): array
675.     {
676.         $result = [];
678.         try {
680.             $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
681.             $page = isset($params['page']) ? $params['page'] : 1;
683.             $lang = isset($params['lang']) ? $params['lang'] : 'en';
685.             $organization = $user->getOrganization();
687.             if (!$organization instanceof DataObject\Organization) {
688.                 return ["success" => false, "message" => $translator->trans("user_does_not_belongs_to_organization ")];
689.             }
691.             // Load LocationGroup listing
692.             $userGroupList = new DataObject\UserGroup\Listing();
693.             $userGroupList->filterByOrganization($organization);
694.             $userGroupList->setLocale($lang);
696.             if (isset($params['search']) && !empty($params['search'])) {
698.                 $userGroupList->addConditionParam('(groupName LIKE ? OR detail LIKE ?)', ['%' . $params['search'] . '%', '%' . $params['search'] . '%']);
699.             }
701.             $userGroupList->setOrderKey("oo_id");
702.             $userGroupList->setOrder("desc");
705.             $paginator = $paginator->paginate(
706.                 $userGroupList,
707.                 $page,
708.                 $pageSize
709.             );
711.             if ($paginator->getTotalItemCount() > 0) {
712.                 $userGroupListData = [];
714.                 foreach ($paginator as $key => $userGroup) {
715.                     $userListData = [];
716.                     $usersList = new DataObject\Customer\Listing();
717.                     $usersList->filterByUserGroup($userGroup);
718.                     $usersList->setOrderKey("oo_id");
719.                     $usersList->setOrder("desc");
720.                     if ($usersList) {
721.                         foreach ($usersList as $user) {
722.                             $userListData[] = [
723.                                 'id' => $user->getId(),
724.                                 'name' => $user->getName(),
725.                                 'email' => $user->getEmail(),
726.                                 'role' => $user->getRole() ? $user->getRole()->getName() : '',
727.                                 'organization' => $user->getOrganization() ?  $user->getOrganization()->getName() : '',
728.                             ];
729.                         }
730.                     }
731.                     $userGroupListData[] = [
732.                         'id' => $userGroup->getId(),
733.                         'groupName_en' => $userGroup->getGroupName("en"),
734.                         'detail_en' => $userGroup->getDetail("en"),
735.                         'groupName_ar' => $userGroup->getGroupName("ar"),
736.                         'detail_ar' => $userGroup->getDetail("ar"),
737.                         'usersData' => $userListData
738.                     ];
739.                 }
741.                 if (!empty($userGroupListData) && count($userGroupListData) > 0) {
742.                     return ["success" => true, "data" => $userGroupListData, "paginationVariables" => $paginator->getPaginationData()];
743.                 }
744.             }
745.             return ["success" => false, "message" => $translator->trans("user_groups_are_not_available")];
746.         } catch (\Exception $ex) {
747.             throw new \Exception($ex->getMessage());
748.         }
750.         return $result;
751.     }
753.     public function userGroupDetail($user, $userGroupId, $translator): array
754.     {
755.         $result = [];
757.         try {
759.             $organization = $user->getOrganization();
761.             if (!$organization instanceof DataObject\Organization) {
762.                 return ["success" => false, "message" => $translator->trans("user_does_not_belongs_to_organization")];
763.             }
765.             $userGroupData = [];
766.             $userListData = [];
767.             $data = [];
768.             $totalUsers  = 0;
770.             //load user group
771.             $userGroup = new DataObject\UserGroup\Listing();
772.             $userGroup->setCondition("oo_id = ? ", [$userGroupId]);
773.             $userGroup->filterByOrganization($organization);
774.             $userGroup = $userGroup->current();
776.             if ($userGroup instanceof DataObject\UserGroup) {
778.                 //get user group data   
779.                 $userGroupData[] = [
780.                     'id' => $userGroup->getId(),
781.                     'groupName_en' => $userGroup->getGroupName("en"),
782.                     'detail_en' => $userGroup->getDetail("en"),
783.                     'groupName_ar' => $userGroup->getGroupName("ar"),
784.                     'detail_ar' => $userGroup->getDetail("ar"),
785.                 ];
787.                 //get all users available in above user group
788.                 $customers = new DataObject\Customer\Listing();
789.                 $customers->filterByOrganization($organization);
790.                 $customers->filterByUserGroup($userGroup);
791.                 $customers->filterByIsActive(true);
793.                 if ($customers->getCount() > 0) {
794.                     $totalUsers = $customers->getCount();
796.                     foreach ($customers as $key => $customer) {
798.                         if ($customer instanceof DataObject\Customer) {
800.                             //get user  data   
801.                             $userListData[] = [
802.                                 'id' => $customer->getId(),
803.                                 'name' => $customer->getName(),
804.                                 'email' => $customer->getEmail(),
805.                                 'role' => $customer->getRole() ? $customer->getRole()->getName() : null,
806.                                 'department' => $customer->getDepartment(),
807.                                 'titile' => $customer->getTitle()
808.                             ];
809.                         }
810.                     }
812.                     // store all data in data array
813.                     $data[] = [
814.                         "userGroupData" => $userGroupData,
815.                         "totalUsers" => $totalUsers,
816.                         "users" => $userListData
817.                     ];
819.                     if (!empty($data) && count($data) > 0) {
820.                         return ["success" => true, "data" => $data];
821.                     }
822.                 }
823.             }
824.             return ["success" => false, "message" => $translator->trans("user_group_is_not_available")];
825.         } catch (\Exception $ex) {
826.             throw new \Exception($ex->getMessage());
827.         }
829.         return $result;
830.     }
833.     public function updateProfile($params, $translator): array
834.     {
835.         $result = [];
837.         try {
839.             $updateUser = DataObject\Customer::getById($params['id'], true);
841.             if ($updateUser) {
842.                 try {
843.                     $updateUser->setName(strip_tags($params['name']));
844.                     $updateUser->setDepartment(strip_tags($params['department']));
845.                     $updateUser->setTitle(strip_tags($params['title']));
846.                     if (isset($params['isTwoFactorAuth'])) {
847.                         if ($params['isTwoFactorAuth'] == true) {
848.                             $updateUser->setTwoFactorAuth(true);
849.                         } else {
850.                             $updateUser->setTwoFactorAuth(false);
851.                         }
852.                     }
854.                     if (isset($params['iqamaId']) && !empty($params['iqamaId'])) {
855.                         if (\App\Lib\Utility::validateIqamaId($params['iqamaId'])) {
856.                             $updateUser->setIqamaId($params['iqamaId']);
857.                         } else {
858.                             return ["success" => false, "message" => $translator->trans("iqama_id_is_invalid")];
859.                         }
860.                     }
862.                     if (!empty($params['phoneno'])) {
863.                         $phoneNo = trim($params['phoneno']);
864.                         if (strlen($phoneNo) !== 9) {
865.                             return ["success" => false, "message" => $translator->trans("phone_no_must_be_9_digits")];
866.                         } elseif (!ctype_digit($phoneNo)) {
867.                             return ["success" => false, "message" => $translator->trans("phone_no_must_be_numeric")];
868.                         } else {
869.                             $updateUser->setPhoneNo($phoneNo);
870.                         }
871.                     }
874.                     $updateUser->save();
875.                     if (!isset($params['from_ews']) && !isset($params['from_reporting'])) {
876.                         unset($params["Authorization"]);
877.                         $params["userEmail"] = $updateUser->getEmail();
878.                         $params["from_portal"] = true;
880.                         // Inform other systems
881.                         // $this->ewsPortalModel->updateProfile($params);
882.                         // $this->reportingPortalModel->updateProfile($params);
883.                     }
885.                     return ["success" => true, "message" => $translator->trans("user_updated_successfully")];
886.                 } catch (\Exception $ex) {
887.                     return ["success" => false, "message" => $translator->trans("user_not_updated_successfully")];
888.                 }
889.             }
891.             return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
892.         } catch (\Exception $ex) {
893.             throw new \Exception($ex->getMessage());
894.         }
896.         return $result;
897.     }
899.     /**
900.      * forget user password
901.      */
902.     public function forgotPassword($request, $email, $httpOrigin, $translator, $templating)
903.     {
904.         $result = [];
905.         try {
906.             $lang = $translator->getLocale();
908.             $user = DataObject\Customer::getByEmail($email, true);
909.             if ($user instanceof \Pimcore\Model\DataObject\Customer) {
911.                 //generate token
912.                 $token = md5($user->getId() . time() . uniqid());
913.                 $user->setResetPasswordToken($token);
914.                 //$user->setPasswordRecoveryTokenDate(Carbon::now());
915.                 $user->save();
917.                 $role = ($user->getRole()) ? $user->getRole()->getName() : null;
918.                 $hostName = $httpOrigin . "/auth/reset-password?token=";
919.                 if ($role == 'CLIENT_ADMIN' || $role == 'CLIENT_USER') {
920.                     $subject = $translator->trans("Reset Password to Join NCM Business Portal");
921.                     $title = $translator->trans("Meteo KSA");
922.                 } else {
923.                     $subject = $translator->trans("Reset Password to Join NCM Admin Portal");
924.                     $title = $translator->trans("Meteo KSA Admin");
925.                 }
927.                 $param = [
928.                     'userName' => $user->getName(),
929.                     'tokenLink' => $hostName . $token,
930.                     'title' => $title,
931.                 ];
933.                 $html = $templating->render('web2print/generic_mail.html.twig', $param);
934.                 $templateId = $_ENV['RESET_PASSWORD_TEMPLATE'];
935.                 $purpose = RESET_PASSWORD_MESSAGE;
936.                 $result = $this->c2Service->sendNotificationEmail($templateId, $user->getId(), $user->getId(), $html, $subject, $purpose);
938.                 //$result = $this->emailService->sendMail($param, $user->getEmail(), PASSWORD_RECOVERY_EMAIL_DOCUMENT_PATH, $subject);
939.                 $translator->setLocale($lang);
941.                 if ($result) {
942.                     return ["success" => true, "message" => $translator->trans("account_reset_mail_sent_when_possible")];
943.                 }
944.                 return ["success" => false, "message" => $translator->trans("an_error_occured_while_sending_mail")];
945.             } else {
946.                 return ["success" => false, "message" => $translator->trans("user_not_found")];
947.             }
948.         } catch (\Exception $ex) {
949.             throw new \Exception($ex->getMessage());
950.         }
952.         return $result;
953.     }
955.     /**
956.      * Reset user password
957.      */
958.     public function resetPassword($request, $token, $newPassword, $conformNewPassword, $translator): array
959.     {
960.         $result = [];
961.         try {
963.             //check if the token is valid
966.             $user = DataObject\Customer::getByResetPasswordToken($token, true);
967.             if ($user instanceof \Pimcore\Model\DataObject\Customer) {
969.                 if ($newPassword != $conformNewPassword) {
970.                     return ["success" => false, "message" => $translator->trans("new_password_and_conformNewPassword_not_matching")];
971.                 }
973.                 $user->setPassword($newPassword);
974.                 $user->setResetPasswordToken(null);
975.                 $user->save();
977.                 if ($user) {
978.                     return ["success" => true, "message" => $translator->trans("password_updated_successifully")];
979.                 }
980.             } else {
981.                 return ["success" => false, "message" => $translator->trans("user_not_found_token_is_not_valid")];
982.             }
983.         } catch (\Exception $ex) {
984.             throw new \Exception($ex->getMessage());
985.         }
987.         return $result;
988.     }
991.     /**
992.      * Reset user password
993.      */
994.     public function changePassword($user, $params, $translator): array
995.     {
996.         $result = [];
997.         try {
998.             if ($params['newPassword'] != $params['confirmNewPassword']) {
999.                 return ["success" => false, "message" => $translator->trans("new_password_and_conformNewPassword_not_matching")];
1000.             }
1001.             if ($user) {
1002.                 if (password_verify(trim($params['oldPassword']), $user->getPassword())) {
1003.                     $user->setPassword($params['newPassword']);
1004.                     $user->save();
1006.                     if (!isset($params['from_ews']) && !isset($params['from_reporting'])) {
1007.                         unset($params["Authorization"]);
1008.                         $params["userEmail"] = $user->getEmail();
1009.                         $params["from_portal"] = true;
1011.                         // Inform other systems
1012.                         // $this->ewsPortalModel->changePassword($params);
1013.                         // $this->reportingPortalModel->changePassword($params);
1014.                     }
1017.                     return ["success" => true, "message" => $translator->trans("password_updated_successifully")];
1018.                 } else {
1019.                     return ["success" => false, "message" => $translator->trans("old_password_is_not_correct")];
1020.                 }
1021.             }
1022.             return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
1023.         } catch (\Exception $ex) {
1024.             throw new \Exception($ex->getMessage());
1025.         }
1027.         return $result;
1028.     }
1030.     /**
1031.      * Get Public User Premissions
1032.      */
1033.     public function publicUserPermissions($translator): array
1034.     {
1035.         $result = [];
1036.         try {
1038.             $db = Db::get();
1039.             $permissions = $db->fetchAll("SELECT * FROM `policy`");
1041.             return ["success" => true, "data" => $permissions];
1042.         } catch (\Exception $ex) {
1043.             throw new \Exception($ex->getMessage());
1044.         }
1046.         return $result;
1047.     }
1049.     /**
1050.      * Create Public User
1051.      */
1052.     public function addPublicUser($request, $params, $translator): array
1053.     {
1054.         $result = [];
1055.         try {
1056.             $user = DataObject\PublicUser::getByName($params['name'], true);
1057.             if ($user instanceof DataObject\PublicUser) {
1058.                 return ["success" => false, "message" => $translator->trans("This public user already exists.")];
1059.             }
1061.             $addPublicUser = new DataObject\PublicUser();
1062.             $addPublicUser->setParent(DataObject\Service::createFolderByPath('/UserManagement/PublicUsers/'));
1063.             $addPublicUser->setKey($params['name']);
1064.             $addPublicUser->setName($params['name']);
1065.             $addPublicUser->setStartDate(Carbon::parse($params['startDate']));
1066.             $addPublicUser->setEndDate(Carbon::parse($params['endDate']));
1067.             $addPublicUser->setPublished(true);
1068.             $addPublicUser->save();
1070.             if (!$addPublicUser->getId()) {
1071.                 throw new \Exception("Failed to create public user.");
1072.             }
1074.             $db = Db::get();
1075.             foreach ($params['permissions'] as $parameter) {
1076.                 $permission = $db->fetchOne("SELECT id FROM policy WHERE parameter = ?", $parameter);
1077.                 if ($permission) {
1078.                     $data = array(
1079.                         'user_id' => $addPublicUser->getId(),
1080.                         'policy_id' => $permission,
1081.                         'is_allowed' => 1
1082.                     );
1084.                     $insertResult = $db->insert("user_policy", $data);
1086.                     if (!$insertResult) {
1087.                         throw new \Exception($translator->trans("Failed to associate permissions with the public user."));
1088.                     }
1089.                 } else {
1090.                     throw new \Exception($translator->trans("Permission not found for parameter: " . $parameter));
1091.                 }
1092.             }
1094.             return ["success" => true, "message" => $translator->trans("Public user created successfully.")];
1095.         } catch (\Exception $ex) {
1096.             return ["success" => false, "message" => $ex->getMessage()];
1097.         }
1099.         return $result;
1100.     }
1102.     // public function deleteUser($request, $params, $translator): array
1103.     // {
1104.     //     $result = [];
1105.     //     // try {
1106.     //     $user = DataObject\Customer::getById($params['id'], true);
1107.     //     if ($user) {
1109.     //         // Deleting user location              
1110.     //         $locations = $this->locationModel->getLocationsByUserId($user->getId());
1111.     //         if ($locations) {
1112.     //             foreach ($locations as $location) {
1113.     //                 if ($location instanceof \Pimcore\Model\DataObject\Location) {
1114.     //                     $this->locationModel->deAssociateUserLocation($location, $user, $translator);
1115.     //                 }
1116.     //             }
1117.     //         }
1119.     //         // Deleting user custom notification
1120.     //         $customNotification = new \Pimcore\Model\DataObject\CustomNotification\Listing();
1121.     //         $customNotification->filterByUser($user);
1122.     //         foreach ($customNotification as $notification) {
1123.     //             $notification->delete();
1124.     //         }
1126.     //         $user->delete();
1128.     //         return ["success" => true, "message" => $translator->trans("user_deleted_successifully")];
1129.     //     }
1130.     //     return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
1131.     //     // } catch (\Exception $ex) {
1132.     //     //     throw new \Exception($ex->getMessage());
1133.     //     // }
1134.     //     return $result;
1135.     // }
1137.     public function deleteUser($request, $params, $loggedInUser, $translator): array
1138.     {
1139.         $result = [];
1141.         // Check if the user is already deleted
1142.         $deletedUsers = new DataObject\DeletedUsersData\Listing();
1143.         $deletedUsers->filterByPimId($params['id']);
1144.         $deletedUsers->filterByIsDeleted(false);
1145.         $check = $deletedUsers->current();
1147.         if ($check instanceof DataObject\DeletedUsersData) {
1148.             return ["success" => false, "message" => $translator->trans("user_already_deleted")];
1149.         }
1151.         // Fetch the user by ID
1152.         $user = DataObject\Customer::getById($params['id'], true);
1153.         if (!$user) {
1154.             return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
1155.         }
1157.         // Deactivate and save the user
1158.         $user->setToken(null);
1159.         $user->setIsDeleted(true);
1160.         $user->setPublished(false);
1161.         $user->save();
1163.         // Update created-by references: mark status as deleted and clear relation
1164.         $createdUsers = new DataObject\Customer\Listing();
1165.         $createdUsers->filterByCreatedBy($user);
1166.         foreach ($createdUsers as $createdUser) {
1167.             if ($createdUser instanceof DataObject\Customer) {
1168.                 $createdUser->setCreatedBy(null);
1169.                 $createdUser->setCreatedByUserStatus('deleted');
1170.                 $createdUser->save();
1171.             }
1172.         }
1174.         // Create a deleted user record
1175.         $deleteUserRecord = new DataObject\DeletedUsersData();
1176.         $deleteUserRecord->setParent(DataObject\Service::createFolderByPath('/UserManagement/DeletedUsers/'));
1177.         $deleteUserRecord->setKey($user->getName() . strtotime("now") . rand(0, 100));
1178.         $deleteUserRecord->setName($user->getName());
1179.         $deleteUserRecord->setEmail($user->getEmail());
1180.         $deleteUserRecord->setPimId($user->getId());
1181.         $deleteUserRecord->setOrganizationName($user->getOrganization() ? $user->getOrganization()->getName() : '');
1182.         $deleteUserRecord->setRole($user->getRole() ? $user->getRole()->getName() : '');
1183.         $deleteUserRecord->setIsDeleted(false);
1184.         $deleteUserRecord->setDeletedBy($loggedInUser->getEmail());
1185.         $deleteUserRecord->setPublished(true);
1186.         $deleteUserRecord->save();
1188.         // Delete user dependencies (locations)
1189.         $locations = $this->locationModel->getLocationsByUserId($user->getId());
1190.         if ($locations) {
1191.             foreach ($locations as $location) {
1192.                 if ($location instanceof \Pimcore\Model\DataObject\Location) {
1193.                     $this->locationModel->deAssociateUserLocation($location, $user, $translator);
1194.                 }
1195.             }
1196.         }
1198.         // Delete user custom notifications
1199.         $customNotification = new \Pimcore\Model\DataObject\CustomNotification\Listing();
1200.         $customNotification->filterByUser($user);
1201.         foreach ($customNotification as $notification) {
1202.             $notification->delete();
1203.         }
1205.         // Delete user dashboard
1206.         $dashboard = new DataObject\Dashboard\Listing();
1207.         $dashboard->setCondition('user__id = ?', [$user->getId()]);
1208.         if ($dashboard->current() instanceof DataObject\Dashboard) {
1209.             $dashboard->current()->delete();
1210.         }
1212.         // Delete user subscriptions
1213.         $subscriptions = new DataObject\Subscription\Listing();
1214.         $subscriptions->setCondition('subscribedUser__id = ?', [$user->getId()]);
1215.         foreach ($subscriptions as $subscription) {
1216.             if ($subscription instanceof DataObject\Subscription) {
1217.                 $subscription->delete();
1218.             }
1219.         }
1221.         // Finalize user deletion
1222.         $user->delete();
1224.         // Mark the deleted user record as deleted
1225.         $deleteUserRecord->setIsDeleted(true);
1226.         $deleteUserRecord->save();
1228.         return ["success" => true, "message" => $translator->trans("user_deleted_successfully")];
1229.     }
1232.     /**
1233.      * Get Client User Organization List
1234.      */
1235.     public function getClientUsers($request, $user, $params, $paginator, $translator)
1236.     {
1238.         $result = [];
1239.         $userData = [];
1240.         // try {
1243.         // Get All the Classes
1244.         $class = new \Pimcore\Model\DataObject\ClassDefinition();
1245.         $customer = $class->getDao()->getIdByName('Customer');
1246.         $subscription = $class->getDao()->getIdByName('Subscription');
1247.         $userRole = $class->getDao()->getIdByName('UserRole');
1248.         $organization = $class->getDao()->getIdByName('Organization');
1249.         $package = $class->getDao()->getIdByName('Package');
1251.         $db = Db::get();
1252.         $select = $db->createQueryBuilder();
1255.         $select->select('customer.oo_id');
1256.         $select->from('object_' . $customer, 'customer');
1258.         // Use LEFT JOIN for subscriptions to handle suspended users (users without subscriptions)
1259.         $select->leftJoin('customer', 'object_' . $subscription, 'subscription', 'customer.oo_id = subscription.subscribedUser__id');
1260.         $select->leftJoin('subscription', 'object_' . $package, 'package', 'package.oo_id = subscription.subscribedPackage__id');
1261.         $select->innerJoin('customer', 'object_' . $organization, 'organization', 'organization.oo_id = customer.organization__id');
1262.         $select->innerJoin('customer', 'object_' . $userRole, 'userRole', 'userRole.oo_id = customer.role__id');
1264.         // Use placeholders to prevent SQL injection
1265.         if (isset($params['clientType']) && !empty($params['clientType'])) {
1266.             $select->Where("organization.clientType = " . $db->quote($params['clientType']));
1267.         }
1268.         if (isset($params['organization_id']) && !empty($params['organization_id'])) {
1269.             $select->andWhere("organization.oo_id = " . $db->quote($params['organization_id']));
1270.         }
1272.         if (isset($params['package_id']) && !empty($params['package_id'])) {
1273.             $select->andWhere("package.oo_id = " . $db->quote($params['package_id']));
1274.         }
1276.         if (isset($params['search']) && !empty($params['search'])) {
1277.             $select->andWhere("customer.name LIKE " . $db->quote("%" . $params['search'] . "%") . " OR customer.email LIKE " . $db->quote("%" . $params['search'] . "%"));
1278.         }
1280.         if (isset($params['userStatus']) && !empty($params['userStatus'])) {
1281.             $filterStatus = strtolower(trim($params['userStatus']));
1283.             // Validate that the filter status is one of the allowed values
1284.             $allowedStatuses = ['pending', 'active', 'suspended', 'activepending'];
1285.             if (in_array($filterStatus, $allowedStatuses)) {
1286.                 switch ($filterStatus) {
1287.                     case 'pending':
1288.                         // Pending: user is unpublished, no custom subscription, has default subscription
1289.                         $select->andWhere("customer.o_published = 0");
1290.                         $select->andWhere("subscription.subscriptionType != 'custom'");
1291.                         $select->andWhere("subscription.subscribedUser__id IS NOT NULL");
1292.                         $select->andWhere("subscription.isWso IS NULL OR subscription.isWso = 0");
1293.                         $select->andWhere("userRole.name IN ('CLIENT_USER', 'CLIENT_ADMIN')");
1294.                         break;
1296.                     case 'active':
1297.                         // Active: user is published, has custom subscription, isActive = true
1298.                         $select->andWhere("customer.o_published = 1");
1299.                         $select->andWhere("subscription.subscriptionType = 'custom'");
1300.                         $select->andWhere("subscription.subscribedUser__id IS NOT NULL");
1301.                         $select->andWhere("subscription.isActive = 1");
1302.                         $select->andWhere("subscription.isWso IS NULL OR subscription.isWso = 0");
1303.                         $select->andWhere("userRole.name IN ('CLIENT_USER', 'CLIENT_ADMIN')");
1304.                         break;
1306.                     case 'suspended':
1307.                         // Suspended: user is published, has custom subscription, isActive = false
1308.                         $select->andWhere("customer.o_published = 1");
1309.                         $select->andWhere("subscription.subscriptionType = 'custom'");
1310.                         $select->andWhere("subscription.subscribedUser__id IS NOT NULL");
1311.                         $select->andWhere("subscription.isActive = 0");
1312.                         break;
1313.                     
1314.                     case 'activepending':
1315.                         // Active OR Pending
1316.                         $select->andWhere("((customer.o_published = 0 AND subscription.subscriptionType != 'custom' AND subscription.subscribedUser__id IS NOT NULL) OR (customer.o_published = 1 AND subscription.subscriptionType = 'custom' AND subscription.subscribedUser__id IS NOT NULL AND subscription.isActive = 1))");
1317.                         $select->andWhere("subscription.isWso IS NULL OR subscription.isWso = 0");
1318.                         $select->andWhere("userRole.name IN ('CLIENT_USER', 'CLIENT_ADMIN')");
1319.                         break;
1320.                 }
1321.             }
1322.         }
1324.         $select->andWhere("userRole.name = " . $db->quote(USER_ROLES['CLIENT_ADMIN']) . " OR userRole.name = " . $db->quote(USER_ROLES['CLIENT_USER']));
1325.         $select->andWhere("customer.oo_id != " . $db->quote($user->getId()));
1326.         $select->andWhere("customer.isDeleted != 1 OR customer.isDeleted IS NULL");
1327.         $select->andWhere("customer.organization__id IS NOT NULL");
1330.         $groupByFields = ['customer.oo_id'];
1331.         $hasSorting = false;
1333.         // Dynamic sorting logic with orderKey and order
1334.         $orderKey = $params['orderKey'] ?? null;
1335.         $order = $params['order'] ?? 'asc';
1337.         // Validate order parameter
1338.         if (!in_array(strtolower($order), ['asc', 'desc'])) {
1339.             $order = 'asc';
1340.         }
1342.         // Map orderKey to database fields
1343.         $sortingMap = [
1344.             'created' => 'customer.o_creationDate',
1345.             'username' => 'customer.name',
1346.             'email' => 'customer.email',
1347.             'role' => 'userRole.name',
1348.             'entityType' => 'organization.clientType',
1349.             'packageExpiry' => 'subscription.endDate',
1350.             'packageName' => 'localized_package.packageName',
1351.             'entityName' => 'localized_organization.name'
1352.         ];
1354.         if ($orderKey && isset($sortingMap[$orderKey])) {
1355.             $field = $sortingMap[$orderKey];
1357.             // Handle special cases that require joins
1358.             if ($orderKey === 'packageName') {
1359.                 $localizedPackageTable = 'object_localized_packages_' . ($params['lang'] ?? 'en');
1360.                 $select->leftJoin('package', $localizedPackageTable, 'localized_package', 'localized_package.ooo_id = package.oo_id');
1361.                 $groupByFields[] = 'localized_package.packageName';
1362.             } elseif ($orderKey === 'entityName') {
1363.                 $localizedOrgTable = 'object_localized_organization_' . ($params['lang'] ?? 'en');
1364.                 $select->leftJoin('organization', $localizedOrgTable, 'localized_organization', 'localized_organization.ooo_id = organization.oo_id');
1365.                 $groupByFields[] = 'localized_organization.name';
1366.             } else {
1367.                 $groupByFields[] = $field;
1368.             }
1370.             $select->orderBy($field, strtoupper($order));
1371.             $hasSorting = true;
1372.         }
1374.         // If no sort param given, apply default sort and group
1375.         if (!$hasSorting) {
1376.             $select->orderBy('customer.oo_id', 'DESC');
1377.             $groupByFields = ['customer.oo_id'];
1378.         }
1380.         // Final groupBy
1381.         $select->groupBy(array_unique($groupByFields));
1382.         // dd( $select->getSQL());
1383.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
1384.         $page = isset($params['page']) ? $params['page'] : 1;
1386.         $paginator = $paginator->paginate(
1387.             $select,
1388.             $page,
1389.             $pageSize
1390.         );
1392.         foreach ($paginator as $usersId) {
1394.             $usersData = DataObject\Customer::getById($usersId['oo_id'], true);
1395.             if ($usersData instanceof \Pimcore\Model\DataObject\Customer) {
1397.                 // Get Custom Subscription of the organization and package
1398.                 $customSubscriptions = new DataObject\Subscription\Listing();
1399.                 $customSubscriptions->filterBySubscribedUser($usersData);
1400.                 $customSubscriptions->filterByIsActive(true);
1402.                 $status = "Pending";
1403.                 if ($usersData->getToken() == "" && $usersData->isPublished() == true) {
1404.                     if ($customSubscriptions->count() > 0) {
1405.                         $status = "Active";
1406.                     } else {
1407.                         $status = "Suspended";
1408.                     }
1409.                 } elseif ($usersData->getToken() != "" && $usersData->isPublished() == false) {
1410.                     if ($customSubscriptions->count() > 0) {
1411.                         $status = "Pending";
1412.                     } else {
1413.                         $status = "Suspended";
1414.                     }
1415.                 }
1418.                 $customSubscriptions->filterBySubscriptionType("custom");
1419.                 $customSubscriptions->setOrderKey("o_modificationDate");
1420.                 $customSubscriptions->setOrder("desc");
1421.                 $packageData = [];
1422.                 $userPackage = null;
1423.                 if ($customSubscriptions->count() > 0) {
1424.                     foreach ($customSubscriptions as $key => $customSubscription) {
1425.                         if ($customSubscription instanceof \Pimcore\Model\DataObject\Subscription) {
1426.                             $package = $customSubscription->getSubscribedPackage();
1427.                             $userPackage = $package;
1428.                             if ($package) {
1429.                                 $packageData[] = [
1430.                                     "id" => $package->getId(),
1431.                                     "name" => $package->getPackageName('en'),
1432.                                     "name_ar" => $package->getPackageName('ar'),
1433.                                     "package_expiry" => $customSubscription->getEndDate(date("M d, Y"))
1434.                                 ];
1435.                             }
1436.                         }
1437.                     }
1438.                 }
1440.                 $permissionObj = $this->getUserPermissionInfo($usersData, $translator);
1441.                 $userPermissions = $permissionObj['success'] ? $permissionObj['grants'] : null;
1443.                 $organization = $usersData->getOrganization();
1444.                 $clientType = $organization ? $organization->getClientType() : '';
1446.                 $clientTypeArray = [
1447.                     "key" => $clientType,
1448.                     'name_en' => $clientType === 'organization' ? 'Entity' : ($clientType ? $translator->trans($clientType, [], null, 'en') : ''),
1449.                     'name_ar' => $clientType === 'organization' ? 'الجهة' : ($clientType ? $translator->trans($clientType, [], null, 'ar') : ''),
1450.                 ];
1452.                 $roleArray = [
1453.                     "key" => ($usersData->getRole()) ? $usersData->getRole()->getName() : null,
1454.                     'name_en' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'en') : null,
1455.                     'name_ar' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'ar') : null,
1456.                 ];
1457.                 // If user is pending, get invitation duration from MannedAlertLog
1458.                 if ($status === "Pending") {
1459.                     $invitationDuration = $this->getInvitationDate($usersData);
1460.                     $statusArray = [
1461.                         "key" => $status,
1462.                         'name_en' => $translator->trans($status, [], null, 'en'),
1463.                         'name_ar' => $translator->trans($status, [], null, 'ar'),
1464.                         'pendingDuration' => $invitationDuration // Add this field
1465.                     ];
1466.                 } else {
1467.                     $statusArray = [
1468.                         "key" => $status,
1469.                         'name_en' => $translator->trans($status, [], null, 'en'),
1470.                         'name_ar' => $translator->trans($status, [], null, 'ar'),
1471.                     ];
1472.                 }
1473.                 // $statusArray = [
1474.                 //     "key" => $status,
1475.                 //     'name_en' => $translator->trans($status, [], null, 'en'),
1476.                 //     'name_ar' => $translator->trans($status, [], null, 'ar'),
1477.                 // ];
1479.                 $userData[] = [
1480.                     'id' => $usersData->getId(),
1481.                     'name' => $usersData->getName(),
1482.                     'title' => $usersData->getTitle(),
1483.                     'email' => $usersData->getEmail(),
1484.                     'phone' => $usersData->getPhoneNo(),
1485.                     'department' => $usersData->getDepartment(),
1486.                     'role' => $roleArray,
1487.                     'company_name_en' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName("en") : null,
1488.                     'company_name_ar' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName("ar") : null,
1489.                     'packageData' => $packageData,
1490.                     'organizationId' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getId() : null,
1491.                     'location' => $this->getLocationList($usersData),
1492.                     'allowCustomNotification' => ($permissionObj['success'] && isset($userPermissions['get_custom_notification'])) ? $userPermissions['get_custom_notification'] : false,
1493.                     'allowAddLocation' => ($permissionObj['success'] && isset($userPermissions['create_location'])) ? $userPermissions['create_location'] : false,
1494.                     'allowForecast' => ($permissionObj['success'] && isset($userPermissions['get_weather'])) ? $userPermissions['get_weather'] : false,
1495.                     'allowAlertHistoryForCustomAlerts' => ($permissionObj['success'] && isset($userPermissions['alert_history'])) ? $userPermissions['alert_history'] : false,
1496.                     'automotive' => ($permissionObj['success'] && isset($userPermissions['automotive'])) ? $userPermissions['automotive'] : false,
1497.                     'aviation' => ($permissionObj['success'] && isset($userPermissions['aviation'])) ? $userPermissions['aviation'] : false,
1498.                     'shippingAndOffshore' => ($permissionObj['success'] && isset($userPermissions['shipping_and_offshore'])) ? $userPermissions['shipping_and_offshore'] : false,
1499.                     'insurance' => ($permissionObj['success'] && isset($userPermissions['insurance'])) ? $userPermissions['insurance'] : false,
1500.                     'energy' => ($permissionObj['success'] && isset($userPermissions['energy'])) ? $userPermissions['energy'] : false,
1501.                     'client_type' => $clientTypeArray,
1502.                     'status' => $statusArray,
1503.                     'createdBy' => $usersData->getCreatedBy() ? $usersData->getCreatedBy()->getName() : null,
1504.                     'createdAt' => date('Y-m-d H:i:s', $usersData->getCreationDate()),
1505.                     'iqamaId' => $usersData->getIqamaId() ? (string) $usersData->getIqamaId() : null,
1506.                     //'token' => $status == "Pending" ? $usersData->getToken() : '',
1507.                     'entity_status' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getStatus() : null,
1508.                     'entity_status_en' => ($usersData->getOrganization() && $usersData->getOrganization()->getStatus()) ? $translator->trans($usersData->getOrganization()->getStatus(), [], null, 'en') : null,
1509.                     'entity_status_ar' => ($usersData->getOrganization() && $usersData->getOrganization()->getStatus()) ? $translator->trans($usersData->getOrganization()->getStatus(), [], null, 'ar') : null,
1510.                     'trialLeftDays' => $usersData->getOrganization() ? 
1511.                         \App\Lib\Utility::getTrialLeftDays(
1512.                             $usersData->getOrganization()->getPackageActivationDate(),
1513.                             $usersData->getOrganization()->getTrialLimit()
1514.                         ) : null,
1515.                     'isSMSEnabled' => $organization ? $organization->getIsSMSEnabled() : false,
1516.                     'SMSLimit' => $userPackage?->getSMSLimit(),
1517.                     'SMSConsumption' => $organization ? $organization->getSmsConsumption() : 0,
1519.                 ];
1520.                 if (isset($params['sortByStatus']) && !empty($params['sortByStatus'])) {
1521.                     $statusFilter = strtoupper($params['sortByStatus']);
1523.                     usort($userData, function ($a, $b) use ($statusFilter) {
1524.                         $statusKeyA = $a['status']['key'];
1525.                         $statusKeyB = $b['status']['key'];
1527.                         if ($statusFilter === 'ASC') {
1528.                             if ($statusKeyA === 'Active' && $statusKeyB !== 'Active') {
1529.                                 return -1;
1530.                             }
1531.                             if ($statusKeyA !== 'Active' && $statusKeyB === 'Active') {
1532.                                 return 1;
1533.                             }
1534.                         } else if ($statusFilter === 'DESC') {
1535.                             if ($statusKeyA === 'Pending' && $statusKeyB !== 'Pending') {
1536.                                 return -1;
1537.                             }
1538.                             if ($statusKeyA !== 'Pending' && $statusKeyB === 'Pending') {
1539.                                 return 1;
1540.                             }
1541.                         }
1542.                         return 0; // They are equal in terms of status priority
1543.                     });
1544.                 }
1545.             }
1546.         }
1547.         if (!$paginator->count()) {
1548.             return ["success" => false, "message" => $translator->trans("no_user_available_to_this_organization")];
1549.         }
1550.         return ["success" => TRUE, "data" => $userData, "paginationVariables" => $paginator->getPaginationData()];
1551.         // } catch (\Exception $ex) {
1552.         //     throw new \Exception($ex->getMessage());
1553.         // }
1555.         return $result;
1556.     }
1562.     /**
1563.      * Get NCM User List
1564.      */
1565.     public function getNCMUsers($request, $user, $params, $paginator, $translator)
1566.     {
1568.         $result = [];
1569.         try {
1570.             $userData = [];
1572.             // if ($user->getOrganization() === null) {
1573.             //     return ["success" => false, "message" => $translator->trans("organization_does_not_exists")];
1574.             //  }
1576.             //  $organizationId = $user->getOrganization()->getId();
1579.             // Get All the Classes
1580.             $class = new \Pimcore\Model\DataObject\ClassDefinition();
1581.             $customer = $class->getDao()->getIdByName('Customer');
1582.             $subscription = $class->getDao()->getIdByName('Subscription');
1583.             $userRole = $class->getDao()->getIdByName('UserRole');
1584.             $userTag = $class->getDao()->getIdByName('UserTag');
1585.             $organization = $class->getDao()->getIdByName('Organization');
1586.             $package = $class->getDao()->getIdByName('Package');
1588.             $db = Db::get();
1589.             $select = $db->createQueryBuilder();
1590.             $select->select('customer.oo_id');
1591.             $select->from('object_' . $customer, 'customer');
1592.             $select->leftJoin('customer', 'object_' . $subscription, 'subscription', 'customer.oo_id = subscription.subscribedUser__id');
1593.             $select->leftJoin('subscription', 'object_' . $package, 'package', 'package.oo_id = subscription.subscribedPackage__id');
1594.             $select->leftJoin('customer', 'object_' . $organization, 'organization', 'organization.oo_id = customer.organization__id');
1595.             $select->leftJoin('customer', 'object_' . $userRole, 'userRole', 'userRole.oo_id = customer.role__id');
1596.             $select->leftJoin('customer', 'object_' . $userTag, 'userTage', 'userTage.oo_id = customer.tag__id');
1598.             if (isset($params['search']) && !empty($params['search'])) {
1599.                 $select->andWhere("customer.name LIKE " . $db->quote("%" . $params['search'] . "%") . " OR customer.email LIKE " . $db->quote("%" . $params['search'] . "%"));
1600.             }
1602.             if (isset($params['searchByTag']) && !empty($params['searchByTag'])) {
1603.                 $select->andWhere("customer.tag__id = " . $db->quote($params['searchByTag']));
1604.             }
1607.             $select->andWhere("userRole.name = " . $db->quote(USER_ROLES['NCM_IT']) . " OR userRole.name = " . $db->quote(USER_ROLES['NCM_OPERATOR']));
1608.             $select->andWhere("customer.oo_id != " . $db->quote($user->getId()));
1609.             $select->andWhere("customer.isDeleted != 1 or customer.isDeleted IS NULL");
1610.             //$select->andWhere("organization.oo_id = ".$db->quote($organizationId));
1612.             // if (isset($params['status']) && !empty($params['status'])) {
1613.             //     $statusFilter = ucfirst($params['status']);
1615.             //     if ($statusFilter == 'Active') {
1616.             //         $select->andWhere("customer.token IS NULL AND customer.o_published = 1 AND subscription.subscribedUser__id IS NOT NULL");
1617.             //     } elseif ($statusFilter == 'Suspended') {
1618.             //         $select->andWhere("customer.token IS NULL AND customer.o_published = 1 AND subscription.subscribedUser__id IS NULL");
1619.             //     } elseif ($statusFilter == 'Pending') {
1620.             //         $select->andWhere("customer.token != '' AND customer.o_published = 0");
1621.             //     }
1622.             // }
1624.             // Dynamic sorting logic
1625.             $orderKey = isset($params['orderKey']) ? $params['orderKey'] : null;
1626.             $order = isset($params['order']) ? strtoupper($params['order']) : 'ASC';
1628.             // Validate order parameter
1629.             if (!in_array(strtoupper($order), ['ASC', 'DESC'])) {
1630.                 $order = 'ASC';
1631.             }
1633.             // Map orderKey to database fields
1634.             $fieldMapping = [
1635.                 'username' => 'customer.name',
1636.                 'email' => 'customer.email',
1637.                 'userTag' => 'userTage.name',
1638.                 'createdBy' => 'createdBy.name',
1639.                 'role' => 'userRole.name',
1640.                 'status' => 'status', // This will be handled separately as it's computed
1641.                 'createdOn' => 'customer.o_creationDate'
1642.             ];
1644.             if ($orderKey && isset($fieldMapping[$orderKey])) {
1645.                 $field = $fieldMapping[$orderKey];
1646.                 if ($orderKey === 'createdBy') {
1647.                     $select->leftJoin('customer', 'object_' . $customer, 'createdBy', 'createdBy.oo_id = customer.createdBy__id');
1648.                 }
1650.                 if ($orderKey === 'status') {
1651.                     $needStatusSort = true;
1652.                 } else {
1653.                     $select->orderBy($field, $order);
1654.                 }
1655.             } else {
1656.                 // Default sorting
1657.                 $select->orderBy('customer.o_creationDate', 'DESC');
1658.             }
1660.             $select->groupBy(array('oo_id'));
1663.             $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
1664.             $page = isset($params['page']) ? $params['page'] : 1;
1666.             $paginator = $paginator->paginate(
1667.                 $select,
1668.                 $page,
1669.                 $pageSize
1670.             );
1671.             foreach ($paginator as $usersId) {
1673.                 $usersData = DataObject\Customer::getById($usersId['oo_id'], true);
1674.                 if ($usersData instanceof \Pimcore\Model\DataObject\Customer) {
1676.                     // Get Custom Subscription of the organization and package
1677.                     $customSubscriptions = new DataObject\Subscription\Listing();
1678.                     $customSubscriptions->filterBySubscribedUser($usersData);
1679.                     $customSubscriptions->filterByIsActive(true);
1681.                     $status = "Pending";
1682.                     if ($usersData->getToken() == "" && $usersData->isPublished() == true) {
1684.                         if ($usersData->getPermissionGroups() && count($usersData->getPermissionGroups()) > 0) {
1685.                             $status = "Active";
1686.                         } else {
1687.                             $status = "Suspended";
1688.                         }
1689.                     } elseif ($usersData->getToken() != "" && $usersData->isPublished() == false) {
1691.                         $status = "Pending";
1692.                     }
1695.                     $permissionObj = $this->getUserPermissionInfo($usersData, $translator);
1696.                     $userPermissions = $permissionObj['success'] ? $permissionObj['grants'] : null;
1698.                     //$customSubscriptions->filterBySubscriptionType("custom");
1699.                     $customSubscriptions->setOrderKey("o_modificationDate");
1700.                     $customSubscriptions->setOrder("desc");
1702.                     $apiGroupData = [];
1703.                     $packageData = [];
1704.                     $assignedApiGroupIds = [];
1705.                     if ($customSubscriptions->count() > 0) {
1706.                         foreach ($customSubscriptions as $key => $customSubscription) {
1707.                             if ($customSubscription instanceof \Pimcore\Model\DataObject\Subscription) {
1708.                                 $package = $customSubscription->getSubscribedPackage();
1709.                                 $disallowedApiGroups = $customSubscription->getDisallowedApiGroups();
1711.                                 // get all allowed API Group IDs for the user
1712.                                 $allowedApiGroups = $customSubscription->getAllowedApiGroups();
1714.                                 if (count($allowedApiGroups) > 0) {
1715.                                     foreach ($allowedApiGroups as $allowedApiGroup) {
1716.                                         if ($allowedApiGroup instanceof \Pimcore\Model\DataObject\ApiGroup) {
1717.                                             # code...
1718.                                             $assignedApiGroupIds[] = [
1719.                                                 "id" => $allowedApiGroup->getId(),
1720.                                                 "name" => $allowedApiGroup->getGroupName(),
1721.                                             ];
1722.                                         }
1723.                                     }
1724.                                 }
1725.                                 if ($package) {
1726.                                     $packageData[] = [
1727.                                         "id" => $package->getId(),
1728.                                         "name" => $package->getName(),
1729.                                         "package_expiry" => $customSubscription->getEndDate(date("M d, Y")),
1730.                                         "is_no_expiry" => $customSubscription->getIsNoExpiry() == null ? false : $customSubscription->getIsNoExpiry()
1731.                                     ];
1733.                                     $apiGroups = $package->getApiGroups();
1734.                                     if ($apiGroups) {
1735.                                         foreach ($apiGroups as  $apiGroup) {
1737.                                             $apiGroupId = $apiGroup->getId();
1738.                                             $apiGroupNameEn = $apiGroup->getApiGroupName('en');
1739.                                             $apiGroupNameAr = $apiGroup->getApiGroupName('ar');
1740.                                             $isDisallowed = false;
1742.                                             // Check if the current API group is disallowed
1743.                                             foreach ($disallowedApiGroups as $disallowedApiGroup) {
1744.                                                 if ($apiGroupId == $disallowedApiGroup->getId()) {
1745.                                                     $isDisallowed = true;
1746.                                                     break;
1747.                                                 }
1748.                                             }
1750.                                             // Only add the API group if it's not disallowed
1751.                                             if (!$isDisallowed) {
1752.                                                 $apiGroupData[] = [
1753.                                                     "id" => $apiGroupId,
1754.                                                     "name" => $apiGroupNameEn,
1755.                                                     "name_ar" => $apiGroupNameAr
1756.                                                 ];
1757.                                             }
1758.                                         }
1759.                                     }
1760.                                 }
1761.                             }
1762.                         }
1763.                     }
1766.                     $typeArray = [
1767.                         "key" => 'user',
1768.                         'name_en' => $translator->trans('user', [], null, 'en'),
1769.                         'name_ar' => $translator->trans('user', [], null, 'ar'),
1770.                     ];
1772.                     $roleArray = [
1773.                         "key" => ($usersData->getRole()) ? $usersData->getRole()->getName() : null,
1774.                         'name_en' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'en') : null,
1775.                         'name_ar' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'ar') : null,
1776.                     ];
1778.                     $statusArray = [
1779.                         "key" => $status,
1780.                         'name_en' => $translator->trans($status, [], null, 'en'),
1781.                         'name_ar' => $translator->trans($status, [], null, 'ar'),
1782.                     ];
1784.                     // Fetch Permission Groups Data
1785.                     $permissionGroups = $usersData->getPermissionGroups();
1786.                     $permissionGroupsData = [];
1787.                     if ($permissionGroups) {
1788.                         foreach ($permissionGroups as $permissionGroup) {
1789.                             if ($permissionGroup instanceof \Pimcore\Model\DataObject\PermissionGroup) {
1790.                                 $permissionGroupsData[] = [
1791.                                     'id' => $permissionGroup->getId(),
1792.                                     'nameEn' => $permissionGroup->getName('en'),
1793.                                     'nameAr' => $permissionGroup->getName('ar'),
1794.                                     'descriptionEn' => $permissionGroup->getDescription('en'),
1795.                                     'descriptionAr' => $permissionGroup->getDescription('ar'),
1796.                                     'apiGroups' => array_map(function ($group) {
1797.                                         return ['id' => $group->getId(), 'nameEn' => $group->getApiGroupName('en'), 'nameAr' => $group->getApiGroupName('ar')];
1798.                                     }, $permissionGroup->getApiGroups() ?? []),
1800.                                 ];
1801.                             }
1802.                         }
1803.                     }
1806.                     $userData[] = [
1807.                         'id' => $usersData->getId(),
1808.                         'name' => $usersData->getName(),
1809.                         'title' => $usersData->getTitle(),
1810.                         'email' => $usersData->getEmail(),
1811.                         'department' => $usersData->getDepartment(),
1812.                         'role' => $roleArray,
1813.                         'organization' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName() : null,
1814.                         'organizationId' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getId() : null,
1815.                         'location' => $this->getLocationList($usersData),
1816.                         'invite_user' => ($permissionObj['success'] && isset($userPermissions['invite_user'])) ? $userPermissions['invite_user'] : false,
1817.                         'edit_user' => ($permissionObj['success'] && isset($userPermissions['edit_user'])) ? $userPermissions['edit_user'] : false,
1818.                         'delete_user' => ($permissionObj['success'] && isset($userPermissions['delete_user'])) ? $userPermissions['delete_user'] : false,
1819.                         'invite_ncm_user' => ($permissionObj['success'] && isset($userPermissions['invite_ncm_user'])) ? $userPermissions['invite_ncm_user'] : false,
1820.                         'edit_ncm_user' => ($permissionObj['success'] && isset($userPermissions['edit_ncm_user'])) ? $userPermissions['edit_ncm_user'] : false,
1821.                         'delete_ncm_user' => ($permissionObj['success'] && isset($userPermissions['delete_ncm_user'])) ? $userPermissions['delete_ncm_user'] : false,
1822.                         'type' => $typeArray,
1823.                         'status' => $statusArray,
1824.                         'apiGroups' => $apiGroupData,
1825.                         'assignedApiGroupIds' => $assignedApiGroupIds,
1826.                         'packageData' => $packageData,
1827.                         'createdBy' => $usersData->getCreatedBy() ? $usersData->getCreatedBy()->getName() : null,
1828.                         'creationDate' => $usersData->getCreationDate() ? date('Y-m-d', $usersData->getCreationDate()) : null,
1829.                         'iqamaId' => $usersData->getIqamaId() ? (string) $usersData->getIqamaId() : null,
1830.                         'tag' => $usersData->getTag() ? ['id' => $usersData->getTag()->getId(), 'name' => $usersData->getTag()->getName()] : null,
1831.                         'permissionGroupsData' => $permissionGroupsData,
1832.                         'dualMode' => $usersData->getDualMode() ? true : false,
1833.                         //'token' => $usersData->getToken(),
1834.                     ];
1835.                 }
1836.             }
1840.             if (!$userData) {
1841.                 return ["success" => false, "message" => $translator->trans("no_user_available_in_NCM")];
1842.             }
1844.             // Handle status sorting if needed
1845.             if (isset($needStatusSort) && $needStatusSort && $orderKey === 'status') {
1846.                 usort($userData, function ($a, $b) use ($order) {
1847.                     $statusA = $a['status']['key'];
1848.                     $statusB = $b['status']['key'];
1850.                     if ($order === 'ASC') {
1851.                         return strcmp($statusA, $statusB);
1852.                     } else {
1853.                         return strcmp($statusB, $statusA);
1854.                     }
1855.                 });
1856.             }
1858.             return ["success" => TRUE, "data" => $userData, "paginationVariables" => $paginator->getPaginationData()];
1859.         } catch (\Exception $ex) {
1860.             throw new \Exception($ex->getMessage());
1861.         }
1863.         return $result;
1864.     }
1866.     /**
1867.      * Get User List
1868.      */
1869.     public function getUsers($request, $user, $translator, $params, $paginator)
1870.     {
1872.         $result = [];
1873.         $userData = [];
1876.         try {
1878.             if ($user->getOrganization() === null) {
1879.                 return ["success" => false, "message" => $translator->trans("organization_does_not_exists")];
1880.             }
1882.             $organizationId = $user->getOrganization()->getId();
1885.             // Get All the Classes
1886.             $class = new \Pimcore\Model\DataObject\ClassDefinition();
1887.             $customer = $class->getDao()->getIdByName('Customer');
1888.             $subscription = $class->getDao()->getIdByName('Subscription');
1889.             $userRole = $class->getDao()->getIdByName('UserRole');
1890.             $organization = $class->getDao()->getIdByName('Organization');
1891.             $package = $class->getDao()->getIdByName('Package');
1893.             $db = Db::get();
1894.             $select = $db->createQueryBuilder();
1895.             $select->select('customer.oo_id');
1896.             $select->from('object_' . $customer, 'customer');
1897.             $select->innerJoin('customer', 'object_' . $subscription, 'subscription', 'customer.oo_id = subscription.subscribedUser__id');
1898.             $select->innerJoin('subscription', 'object_' . $package, 'package', 'package.oo_id = subscription.subscribedPackage__id');
1899.             $select->innerJoin('customer', 'object_' . $organization, 'organization', 'organization.oo_id = customer.organization__id');
1900.             $select->innerJoin('customer', 'object_' . $userRole, 'userRole', 'userRole.oo_id = customer.role__id');
1902.             if (isset($params['search']) && !empty($params['search'])) {
1903.                 $select->andWhere("customer.name LIKE " . $db->quote("%" . $params['search'] . "%") . " OR customer.email LIKE " . $db->quote("%" . $params['search'] . "%"));
1904.             }
1906.             $select->andWhere("userRole.name = " . $db->quote(USER_ROLES['CLIENT_ADMIN']) . " OR userRole.name = " . $db->quote(USER_ROLES['CLIENT_USER']));
1907.             $select->andWhere("customer.oo_id != " . $db->quote($user->getId()));
1908.             $select->andWhere("organization.oo_id = " . $db->quote($organizationId));
1909.             $select->andWhere("customer.isDeleted != 1 or customer.isDeleted IS NULL");
1911.             if (isset($params['status']) && $params['status'] == true) {
1912.                 $select->andWhere("customer.o_published = 1");
1913.             }
1915.             $select->orderBy('oo_id', 'DESC');
1916.             $select->groupBy(array('oo_id'));
1918.             $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
1919.             $page = isset($params['page']) ? $params['page'] : 1;
1921.             $paginator = $paginator->paginate(
1922.                 $select,
1923.                 $page,
1924.                 $pageSize
1925.             );
1927.             foreach ($paginator as $usersId) {
1929.                 $usersData = DataObject\Customer::getById($usersId['oo_id'], true);
1930.                 if ($usersData instanceof \Pimcore\Model\DataObject\Customer) {
1932.                     // Get Custom Subscription of the organization and package
1933.                     $customSubscriptions = new DataObject\Subscription\Listing();
1934.                     $customSubscriptions->filterBySubscribedUser($usersData);
1935.                     $customSubscriptions->filterByIsActive(true);
1938.                     $status = "Pending";
1939.                     if ($usersData->getToken() == "" && $usersData->isPublished() == true) {
1941.                         if ($customSubscriptions->count() > 0) {
1943.                             $status = "Active";
1944.                         } else {
1946.                             $status = "Suspended";
1947.                         }
1948.                     } elseif ($usersData->getToken() != "" && $usersData->isPublished() == false) {
1950.                         $status = "Pending";
1951.                     }
1954.                     $permissionObj = $this->getUserPermissionInfo($usersData, $translator);
1955.                     $userPermissions = $permissionObj['success'] ? $permissionObj['grants'] : null;
1957.                     $customSubscriptions->filterBySubscriptionType("custom");
1958.                     $customSubscriptions->setOrderKey("o_modificationDate");
1959.                     $customSubscriptions->setOrder("desc");
1960.                     $apiGroupData = [];
1961.                     $packageData = [];
1962.                     $dissAllowedApiGroupID = [];
1964.                     if ($customSubscriptions->count() > 0) {
1965.                         foreach ($customSubscriptions as $key => $customSubscription) {
1966.                             if ($customSubscription instanceof \Pimcore\Model\DataObject\Subscription) {
1967.                                 $package = $customSubscription->getSubscribedPackage();
1969.                                 if ($package) {
1971.                                     $packageData[] = [
1972.                                         "id" => $package->getId(),
1973.                                         "name" => $package->getName(),
1974.                                         "package_expiry" => $customSubscription->getEndDate(date("M d, Y"))
1975.                                     ];
1976.                                 }
1977.                                 $disallowedApiGroups = $customSubscription->getDisallowedApiGroups();
1979.                                 if (count($disallowedApiGroups) > 0) {
1980.                                     foreach ($disallowedApiGroups as $value) {
1981.                                         $dissAllowedApiGroupID[] = $value->getId();
1982.                                     }
1983.                                 }
1985.                                 if ($package) {
1986.                                     $apiGroups = $package->getApiGroups();
1987.                                     if ($apiGroups) {
1988.                                         foreach ($apiGroups as  $apiGroup) {
1989.                                             if (!in_array($apiGroup->getId(), $dissAllowedApiGroupID)) {
1990.                                                 $apiGroupData[] = [
1991.                                                     "id" => $apiGroup->getId(),
1992.                                                     "name" => $apiGroup->getApiGroupName('en'),
1993.                                                     "name_ar" => $apiGroup->getApiGroupName('ar')
1994.                                                 ];
1995.                                             }
1996.                                         }
1997.                                     }
1998.                                 }
1999.                             }
2000.                         }
2001.                     }
2004.                     $typeArray = [
2005.                         "key" => 'user',
2006.                         'name_en' => $translator->trans('user', [], null, 'en'),
2007.                         'name_ar' => $translator->trans('user', [], null, 'ar'),
2008.                     ];
2010.                     $roleArray = [
2011.                         "key" => ($usersData->getRole()) ? $usersData->getRole()->getName() : null,
2012.                         'name_en' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'en') : null,
2013.                         'name_ar' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'ar') : null,
2014.                     ];
2016.                     $statusArray = [
2017.                         "key" => $status,
2018.                         'name_en' => $translator->trans($status, [], null, 'en'),
2019.                         'name_ar' => $translator->trans($status, [], null, 'ar'),
2020.                     ];
2022.                     $userData[] = [
2023.                         'id' => $usersData->getId(),
2024.                         'name' => $usersData->getName(),
2025.                         'title' => $usersData->getTitle(),
2026.                         'email' => $usersData->getEmail(),
2027.                         'phone' => $usersData->getPhoneNo(),
2028.                         'department' => $usersData->getDepartment(),
2029.                         'role' => $roleArray,
2030.                         'organization' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName() : null,
2031.                         'organizationId' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getId() : null,
2032.                         'location' => $this->getLocationList($usersData),
2033.                         'allowCustomNotification' => ($permissionObj['success']) ? $userPermissions['get_custom_notification'] : false,
2034.                         'allowAddLocation' => ($permissionObj['success']) ? $userPermissions['create_location'] : false,
2035.                         'allowForecast' => ($permissionObj['success']) ? $userPermissions['get_weather'] : false,
2036.                         'allowAlertHistoryForCustomAlerts' => ($permissionObj['success']) ? $userPermissions['alert_history'] : false,
2037.                         'automotive' => ($permissionObj['success']) ? $userPermissions['automotive'] : false,
2038.                         'aviation' => ($permissionObj['success']) ? $userPermissions['aviation'] : false,
2039.                         'shippingAndOffshore' => ($permissionObj['success']) ? $userPermissions['shipping_and_offshore'] : false,
2040.                         'insurance' => ($permissionObj['success']) ? $userPermissions['insurance'] : false,
2041.                         'energy' => ($permissionObj['success']) ? $userPermissions['energy'] : false,
2042.                         'type' => $typeArray,
2043.                         'status' => $statusArray,
2044.                         'packageData' => $packageData,
2045.                         'apiGroups' => $apiGroupData,
2046.                         'createdBy' => $usersData->getCreatedBy() ? $usersData->getCreatedBy()->getName() : null,
2047.                         'iqamaId' => $usersData->getIqamaId() ? (string) $usersData->getIqamaId() : null,
2048.                         //'token' => $status == "Pending" ? $usersData->getToken() : '',
2049.                     ];
2050.                 }
2051.             }
2054.             if (!$paginator->count()) {
2055.                 return ["success" => false, "message" => $translator->trans("no_user_available_to_this_organization.")];
2056.             }
2057.             return ["success" => TRUE, "data" => $userData, 'paginationVariables' => $paginator->getPaginationData()];
2058.         } catch (\Exception $ex) {
2059.             throw new \Exception($ex->getMessage());
2060.         }
2062.         return $result;
2063.     }
2065.     // /**
2066.     //  * set package subscription
2067.     //  */
2068.     // public function setPcakageSubscription($params)
2069.     // {
2070.     //     $result = [];
2072.     //     try {
2074.     //         $apiGroup = $this->createApiGrpup($params);
2076.     //         $package = new DataObject\Package();
2077.     //         $package->setParent(DataObject\Service::createFolderByPath('/UserManagement/Packages/CustomPackages/'));
2078.     //         $package->setKey(\Pimcore\Model\Element\Service::getValidKey($apiGroup->getId() . time(), 'object'));
2079.     //         $package->setApiGroups([$apiGroup]);
2080.     //         $package->setTenure(1);
2081.     //         $package->setMaxLocation(100);
2082.     //         $package->setMaxUsers(100);
2083.     //         $package->setIsActive(true);
2084.     //         $package->setPublished(true);
2085.     //         $package->save();
2086.     //         $subscription = $this->setSubscription($package, $params['user']);
2087.     //         if ($subscription instanceof DataObject\Subscription) {
2088.     //             return ["success" => true, "message" => "set_subscription."];
2089.     //         }
2090.     //         //return $subscription;
2091.     //     } catch (\Exception $ex) {
2092.     //         throw new \Exception($ex->getMessage());
2093.     //     }
2095.     //     return $result;
2096.     // }
2098.     /**
2099.      * set create subscription
2100.      */
2101.     public function setSubscription($package, $user, $disallowedApiGroupsArray, $subscriptionType, $isNoExpiry = false)
2102.     {
2103.         $result = [];
2104.         try {
2106.             if (!$package instanceof DataObject\Package) {
2107.                 return ["success" => false, "message" => "Package is not available"];
2108.             }
2109.             if (!$user instanceof DataObject\Customer) {
2110.                 return ["success" => false, "message" => "User is not available"];
2111.             }
2113.             $organization = $user->getOrganization();
2115.             if (!$organization instanceof DataObject\Organization) {
2116.                 return ["success" => false, "message" => "Organization is not available"];
2117.             }
2119.             $packageActivationDate = $organization->getPackageActivationDate();
2121.             if (!$packageActivationDate || strtotime($packageActivationDate) === false) {
2122.                 $packageActivationDate = date('Y-m-d');
2123.             } else {
2124.                 $packageActivationDate = date('Y-m-d', strtotime($packageActivationDate));
2125.             }
2126.             // Set Subscription Expiry
2127.             $subscriptionExpiry = date('Y-m-d', strtotime('+' . $organization->getTrialLimit() . ' days', strtotime($packageActivationDate)));
2131.             $subscription = new DataObject\Subscription();
2132.             $subscription->setParent(DataObject\Service::createFolderByPath('/UserManagement/Subscriptions/' . $user->getEmail()));
2133.             $subscription->setKey(\Pimcore\Model\Element\Service::getValidKey($package->getId() . time() . rand(1000, 10000), 'object'));
2134.             $subscription->setSubscribedPackage($package);
2135.             $subscription->setSubscribedUser($user);
2137.             //Set Disallowed ApiGroups
2138.             if ($disallowedApiGroupsArray != null) {
2141.                 $disallowedApiGroups = [];
2142.                 foreach ($disallowedApiGroupsArray as $disallowedApiGroupsId) {
2143.                     $apiGroup =  DataObject\APIGroup::getById($disallowedApiGroupsId, true);
2144.                     $disallowedApiGroups[] = $apiGroup;
2145.                 }
2146.                 $subscription->setDisallowedApiGroups($disallowedApiGroups);
2147.             }
2148.             //$subscription->setDisallowedApis($disAllowPermissions);
2149.             $subscription->setSubscriptionType($subscriptionType);
2150.             $subscription->setStartDate(Carbon::parse(new \Datetime(date('Y-m-d'))));
2151.             $subscription->setEndDate(Carbon::parse(new \Datetime($subscriptionExpiry)));
2152.             $subscription->setIsNoExpiry($isNoExpiry);
2153.             $subscription->setIsActive(true);
2154.             $subscription->setPublished(true);
2155.             $subscription->save();
2157.             return  $subscription;
2158.         } catch (\Exception $ex) {
2159.             throw new \Exception($ex->getMessage());
2160.         }
2161.         return $result;
2162.     }
2165.     /**
2166.      * set NCM User subscription
2167.      */
2168.     public function setNcmUserSubscription($role, $user, $allowedApiGrpups, $isNoExpiry = false)
2169.     {
2170.         $result = [];
2171.         try {
2175.             if ($role instanceof DataObject\UserRole) {
2177.                 $packages = $role->getDefaultPackages();
2178.                 if ($packages) {
2179.                     $defaultPackage = $packages[0];
2180.                     if ($defaultPackage instanceof DataObject\Package) {
2181.                         $subscription = new DataObject\Subscription();
2182.                         $subscription->setParent(DataObject\Service::createFolderByPath('/UserManagement/Subscriptions/NCM Users/' . $user->getEmail()));
2183.                         $subscription->setKey(\Pimcore\Model\Element\Service::getValidKey($defaultPackage->getId() . time() . uniqid(), 'object'));
2184.                         $subscription->setSubscribedPackage($defaultPackage);
2185.                         $subscription->setSubscribedUser($user);
2187.                         //Set allowed ApiGroups
2188.                         if ($allowedApiGrpups != null) {
2191.                             $allowedApiGrpupsArray = [];
2192.                             foreach ($allowedApiGrpups as $allowedApiGrpupId) {
2193.                                 $apiGroup =  DataObject\APIGroup::getById($allowedApiGrpupId, true);
2194.                                 if ($apiGroup) {
2195.                                     $allowedApiGrpupsArray[] = $apiGroup;
2196.                                 }
2197.                             }
2199.                             $subscription->setAllowedApiGroups($allowedApiGrpupsArray);
2200.                         }
2203.                         $subscriptionExpiry = date('Y-m-d', strtotime('+' . $defaultPackage->getTenure() . ' days'));
2205.                         $subscription->setSubscriptionType("default");
2206.                         $subscription->setStartDate(Carbon::parse(new \Datetime(date('Y-m-d'))));
2207.                         $subscription->setEndDate(Carbon::parse(new \Datetime($subscriptionExpiry)));
2208.                         $subscription->setIsNoExpiry($isNoExpiry);
2209.                         $subscription->setIsActive(true);
2210.                         $subscription->setPublished(true);
2211.                         $subscription->save();
2213.                         return $subscription;
2214.                     }
2215.                 }
2216.             }
2217.         } catch (\Exception $ex) {
2218.             throw new \Exception($ex->getMessage());
2219.         }
2220.         return $result;
2221.     }
2224.     /**
2225.      * set create subscription
2226.      */
2227.     public function updateSubscription($package, $user, $disAllowPermissions, $subscriptionType = "custom")
2228.     {
2229.         $result = [];
2231.         try {
2233.             if (!$package instanceof DataObject\Package) {
2234.                 return ["success" => false, "message" => "Package is not available"];
2235.             }
2236.             if (!$user instanceof DataObject\Customer) {
2237.                 return ["success" => false, "message" => "User is not available"];
2238.             }
2239.             $subscriptionExpiry = date('Y-m-d', strtotime('+' . $package->getTenure() . ' days'));
2241.             $customSubscriptions = new DataObject\Subscription\Listing();
2242.             $customSubscriptions->filterBySubscribedUser($user);
2243.             $customSubscriptions->filterBySubscriptionType($subscriptionType);
2244.             //$customSubscriptions->filterByIsActive(true);
2245.             $updateSubscription = $customSubscriptions->current();
2246.             if (!$updateSubscription instanceof  DataObject\Subscription) {
2247.                 $updateSubscription = new DataObject\Subscription();
2248.                 $updateSubscription->setParent(DataObject\Service::createFolderByPath('/UserManagement/Subscriptions/' . $user->getEmail()));
2249.                 $updateSubscription->setKey(\Pimcore\Model\Element\Service::getValidKey($package->getId() . time() . rand(1000, 10000), 'object'));
2250.                 $updateSubscription->setStartDate(Carbon::parse(new \Datetime(date('Y-m-d'))));
2251.                 $updateSubscription->setEndDate(Carbon::parse(new \Datetime($subscriptionExpiry)));
2252.                 $updateSubscription->setIsActive(true);
2253.                 $updateSubscription->setSubscriptionType($subscriptionType);
2254.                 $updateSubscription->setPublished(true);
2255.                 $updateSubscription->setSubscribedUser($user);
2256.             }
2257.             $updateSubscription->setSubscribedPackage($package);
2258.             if ($subscriptionType == 'default') {
2259.                 $updateSubscription->setIsNoExpiry(true);
2260.             }
2261.             $updateSubscription->save();
2263.             return  $updateSubscription;
2264.         } catch (\Exception $ex) {
2265.             throw new \Exception($ex->getMessage());
2266.         }
2267.         return $result;
2268.     }
2271.     /**
2272.      * Update NCM User Subscription
2273.      */
2274.     public function updateNCMUserSubscription($user, $allowedApiGroups)
2275.     {
2276.         $result = [];
2277.         try {
2278.             if (!$user instanceof DataObject\Customer) {
2279.                 return ["success" => false, "message" => "User is not available"];
2280.             }
2282.             $subscriptionListing = new DataObject\Subscription\Listing();
2283.             $subscriptionListing->filterBySubscribedUser($user);
2284.             $subscriptionListing->filterByIsActive(true);
2286.             // Fetch all active subscriptions
2287.             $activeSubscriptions = iterator_to_array($subscriptionListing);
2289.             if (count($activeSubscriptions) === 0) {
2290.                 $defaultPackage = $user->getRole()?->getDefaultPackages()[0] ?? null;
2292.                 if ($defaultPackage instanceof DataObject\Package) {
2293.                     $subscription = new DataObject\Subscription();
2294.                     $subscription->setParent(DataObject\Service::createFolderByPath('/UserManagement/Subscriptions/NCM Users/' . $user->getEmail()));
2295.                     $subscription->setKey(\Pimcore\Model\Element\Service::getValidKey($defaultPackage->getId() . time() . uniqid(), 'object'));
2296.                     $subscription->setSubscribedPackage($defaultPackage);
2297.                     $subscription->setSubscribedUser($user);
2298.                     $subscription->setStartDate(Carbon::parse(new \DateTime(date('Y-m-d'))));
2299.                     // Set end date to one month from today
2300.                     $subscription->setEndDate(Carbon::now()->addMonth());
2301.                     $subscription->setIsNoExpiry(true);
2302.                     $subscription->setIsActive(true);
2303.                     $subscription->setPublished(false);
2304.                     $subscription->save();
2306.                     $activeSubscriptions = [$subscription];
2307.                 }
2308.             }
2310.             // Unpublish all active subscriptions except the first one
2311.             foreach ($activeSubscriptions as $index => $subscription) {
2312.                 if ($index > 0) {
2313.                     $subscription->setPublished(false);
2314.                     $subscription->save();
2315.                 }
2316.             }
2318.             // Update the first subscription if it exists
2319.             $updateSubscription = $activeSubscriptions[0] ?? null;
2321.             if ($updateSubscription instanceof DataObject\Subscription) {
2322.                 // Set allowed ApiGroups
2323.                 if (!empty($allowedApiGroups)) {
2324.                     $allowedApiGroupsArray = [];
2325.                     foreach ($allowedApiGroups as $allowedApiGroupId) {
2326.                         $apiGroup = DataObject\APIGroup::getById($allowedApiGroupId, true);
2327.                         if ($apiGroup) {
2328.                             $allowedApiGroupsArray[] = $apiGroup;
2329.                         }
2330.                     }
2331.                     $updateSubscription->setAllowedApiGroups($allowedApiGroupsArray);
2332.                 }
2334.                 $updateSubscription->setSubscriptionType("default");
2335.                 $updateSubscription->setParent(DataObject\Service::createFolderByPath('/UserManagement/Subscriptions/NCM Users/' . $user->getEmail()));
2336.                 $updateSubscription->save();
2338.                 return $updateSubscription;
2339.             }
2340.         } catch (\Exception $ex) {
2341.             throw new \Exception($ex->getMessage());
2342.         }
2344.         return $result;
2345.     }
2348.     /**
2349.      * set package subscription
2350.      */
2351.     public function createApiGrpup($params)
2352.     {
2353.         $result = [];
2355.         try {
2357.             $mergedArray = [];
2359.             if (isset($params['allowAddLocation']) && $params['allowAddLocation'] === true) {
2360.                 foreach (USER_PERMISSIONS['is_allow_location'] as $value) {
2361.                     $mergedArray[] = $value;
2362.                 }
2363.             }
2365.             if (isset($params['is_allow_user']) && $params['is_allow_user']   === true) {
2367.                 foreach (USER_PERMISSIONS['is_allow_user'] as $value) {
2368.                     $mergedArray[] = $value;
2369.                 }
2370.             }
2372.             if (isset($params['is_allow_ncm_user']) && $params['is_allow_ncm_user']  === true) {
2373.                 foreach (USER_PERMISSIONS['is_allow_ncm_user'] as $value) {
2374.                     $mergedArray[] = $value;
2375.                 }
2376.             }
2378.             if (isset($params['is_allow_organization']) && $params['is_allow_organization']  === true) {
2379.                 foreach (USER_PERMISSIONS['is_allow_organization'] as $value) {
2380.                     $mergedArray[] = $value;
2381.                 }
2382.             }
2384.             if (isset($params['is_allow_ncm_organization']) && $params['is_allow_ncm_organization']  === true) {
2385.                 foreach (USER_PERMISSIONS['is_allow_ncm_organization'] as $value) {
2386.                     $mergedArray[] = $value;
2387.                 }
2388.             }
2390.             if (isset($params['is_allow_custom_notification']) && $params['is_allow_custom_notification']  === true) {
2391.                 foreach (USER_PERMISSIONS['is_allow_custom_notification'] as $value) {
2392.                     $mergedArray[] = $value;
2393.                 }
2394.             }
2396.             if (isset($params['is_allow_weather_forecast']) && $params['is_allow_weather_forecast']  === true) {
2397.                 foreach (USER_PERMISSIONS['is_allow_weather_forecast'] as $key => $value) {
2398.                     $mergedArray[] = $value;
2399.                 }
2400.             }
2401.             if (isset($params['is_allow_alert']) && $params['is_allow_alert']  === true) {
2402.                 foreach (USER_PERMISSIONS['is_allow_alert'] as $value) {
2403.                     $mergedArray[] = $value;
2404.                 }
2405.             }
2407.             if (isset($params['is_allow_report']) && $params['is_allow_report']  === true) {
2408.                 foreach (USER_PERMISSIONS['is_allow_report'] as $value) {
2409.                     $mergedArray[] = $value;
2410.                 }
2411.             }
2412.             if (isset($params['is_allow_weather_warnings']) && $params['is_allow_weather_warnings']  === true) {
2413.                 foreach (USER_PERMISSIONS['is_allow_weather_warnings'] as $value) {
2414.                     $mergedArray[] = $value;
2415.                 }
2416.             }
2417.             if (isset($params['is_energy']) && $params['is_energy']  === true) {
2418.                 foreach (USER_PERMISSIONS['is_energy'] as $value) {
2419.                     $mergedArray[] = $value;
2420.                 }
2421.             }
2422.             if (isset($params['is_insurance']) && $params['is_insurance']  === true) {
2423.                 foreach (USER_PERMISSIONS['is_insurance'] as $value) {
2424.                     $mergedArray[] = $value;
2425.                 }
2426.             }
2427.             if (isset($params['is_shippingAndOffshore']) && $params['is_shippingAndOffshore']  === true) {
2428.                 foreach (USER_PERMISSIONS['is_shippingAndOffshore'] as $value) {
2429.                     $mergedArray[] = $value;
2430.                 }
2431.             }
2432.             if (isset($params['is_automotive']) && $params['is_automotive']  === true) {
2433.                 foreach (USER_PERMISSIONS['is_automotive'] as $value) {
2434.                     $mergedArray[] = $value;
2435.                 }
2436.             }
2437.             if (isset($params['is_aviation']) && $params['is_aviation']  === true) {
2438.                 foreach (USER_PERMISSIONS['is_aviation'] as $value) {
2439.                     $mergedArray[] = $value;
2440.                 }
2441.             }
2443.             if (isset($params['is_agriculture']) && $params['is_agriculture']  === true) {
2444.                 foreach (USER_PERMISSIONS['is_agriculture'] as $value) {
2445.                     $mergedArray[] = $value;
2446.                 }
2447.             }
2448.             if (isset($params['invitingClients']) && $params['invitingClients']  === true) {
2449.                 foreach (USER_PERMISSIONS['invitingClients'] as $value) {
2450.                     $mergedArray[] = $value;
2451.                 }
2452.             }
2453.             if (isset($params['managingClients']) && $params['managingClients']  === true) {
2454.                 foreach (USER_PERMISSIONS['managingClients'] as $value) {
2455.                     $mergedArray[] = $value;
2456.                 }
2457.             }
2458.             if (isset($params['deletingClients']) && $params['deletingClients']  === true) {
2459.                 foreach (USER_PERMISSIONS['deletingClients'] as $value) {
2460.                     $mergedArray[] = $value;
2461.                 }
2462.             }
2463.             if (isset($params['invitingNCMAdmin']) && $params['invitingNCMAdmin']  === true) {
2464.                 foreach (USER_PERMISSIONS['invitingNCMAdmin'] as $value) {
2465.                     $mergedArray[] = $value;
2466.                 }
2467.             }
2468.             if (isset($params['managingNCMAdmin']) && $params['managingNCMAdmin']  === true) {
2469.                 foreach (USER_PERMISSIONS['managingNCMAdmin'] as $value) {
2470.                     $mergedArray[] = $value;
2471.                 }
2472.             }
2473.             if (isset($params['deletingNCMAdmin']) && $params['deletingNCMAdmin']  === true) {
2474.                 foreach (USER_PERMISSIONS['deletingNCMAdmin'] as $value) {
2475.                     $mergedArray[] = $value;
2476.                 }
2477.             }
2480.             // Get unique values using array_unique()
2481.             $uniqueValues = array_unique(array_values($mergedArray));
2482.             $userPermission  = array_values($uniqueValues);
2484.             $apiGroup = new DataObject\APIGroup();
2485.             $apiGroup->setParent(DataObject\Service::createFolderByPath('/UserManagement/APIGroups/CustomAPIGroups/'));
2486.             $apiGroup->setKey(\Pimcore\Model\Element\Service::getValidKey($userPermission[0] . time(), 'object'));
2488.             $apiGroup->setIsActive(true);
2489.             $apiGroup->setAllowedApis($userPermission);
2490.             $apiGroup->setPublished(true);
2491.             $apiGroup->save();
2493.             return $apiGroup;
2494.         } catch (\Exception $ex) {
2495.             throw new \Exception($ex->getMessage());
2496.         }
2498.         return $result;
2499.     }
2502.     /**
2503.      * set User Permissions
2504.      */
2505.     public function setUserPermissions($params)
2506.     {
2507.         $result = [];
2509.         try {
2511.             // check if all permissions are given than now need to create seperate role 
2512.             $loggedInUserRole = ($params['loggedInUser']->getRole() ? $params['loggedInUser']->getRole()->getName() : null);
2513.             $invitedUserRoleName = ($params['user']->getRole() ? $params['user']->getRole()->getName() : null);
2515.             if ($loggedInUserRole == USER_ROLES['NCM_OPERATOR'] || $loggedInUserRole == USER_ROLES['NCM_IT']) {
2516.                 if ($params['allowCustomNotification'] == true && $params['allowAddLocation'] == true && $params['allowAlertHistoryForCustomAlerts'] == true && $params['allowForecast'] == true && $params['allowOrganizationAdminToInviteUsers'] == true) {
2517.                     // delete specific role if all permission are given
2518.                     $permission = DataObject\Permission::getByAllowedUserRole($params['user'], true);
2519.                     if ($permission instanceof \Pimcore\Model\DataObject\Permission) {
2520.                         $permission->delete();
2521.                     }
2522.                     return ["success" => true, "message" => "Set Permission."];
2523.                 }
2524.             } else {
2525.                 if (
2526.                     $params['allowCustomNotification'] == true &&
2527.                     $params['allowAddLocation'] == true &&
2528.                     $params['allowAlertHistoryForCustomAlerts'] == true &&
2529.                     $params['allowForecast'] == true  &&
2530.                     $params['automotive'] == true &&
2531.                     $params['aviation'] == true &&
2532.                     $params['insurance'] == true &&
2533.                     $params['energy'] == true
2534.                 ) {
2535.                     // delete specific role if all permission are given
2536.                     $permission = DataObject\Permission::getByAllowedUserRole($params['user'], true);
2537.                     if ($permission instanceof \Pimcore\Model\DataObject\Permission) {
2538.                         $permission->delete();
2539.                     }
2540.                     return ["success" => true, "message" => "set_permission"];
2541.                 }
2542.             }
2544.             $permission = DataObject\Permission::getByAllowedUserRole($params['user'], true);
2545.             if ($permission) {
2546.                 // $permission->setDepartment($allowAlertHistoryForCustomAlerts);
2547.                 $permission->setAlert_history($params['allowAlertHistoryForCustomAlerts']);
2548.                 $permission->setGet_custom_notification($params['allowCustomNotification']);
2550.                 $permission->setCreate_location($params['allowAddLocation']);
2551.                 $permission->setGet_weather($params['allowForecast']);
2554.                 // set Industry permissions
2555.                 $permission->setAutomotive($params['automotive'] == false ? false : true);
2556.                 $permission->setAviation($params['aviation'] == false ? false : true);
2557.                 $permission->setShipping_and_offshore($params['shippingAndOffshore'] == false ? false : true);
2558.                 $permission->setInsurance($params['insurance'] == false ? false : true);
2559.                 $permission->setEnergy($params['energy'] == false ? false : true);
2562.                 // default permission on the basis of add location
2563.                 if (false == $params['allowAddLocation']) {
2564.                     $permission->setEdit_location(false);
2565.                     $permission->setDelete_location(false);
2566.                     $permission->setSearch_location(false);
2567.                     $permission->setCompare_location(false);
2568.                 } else {
2569.                     $permission->setEdit_location(true);
2570.                     $permission->setDelete_location(true);
2571.                     $permission->setSearch_location(true);
2572.                     $permission->setCompare_location(true);
2573.                 }
2575.                 // default permission on the basis of add invite user
2576.                 if ($params['allowOrganizationAdminToInviteUsers'] == true || $invitedUserRoleName == USER_ROLES['CLIENT_ADMIN']) {
2577.                     $permission->setEdit_user(true);
2578.                     $permission->setDelete_user(true);
2579.                     $permission->setList_user(true);
2580.                     $permission->setSuspend_user(true);
2581.                     $permission->setInvite_user(true);
2582.                     $permission->setResend_invite(true);
2583.                     $permission->setCreate_user(true);
2584.                 } else {
2585.                     $permission->setEdit_user(false);
2586.                     $permission->setDelete_user(false);
2587.                     $permission->setList_user(false);
2588.                     $permission->setSuspend_user(false);
2589.                     $permission->setInvite_user(false);
2590.                     $permission->setResend_invite(false);
2591.                     $permission->setCreate_user(false);
2592.                 }
2594.                 // default permission to any user
2595.                 $permission->setGet_profile(true);
2596.                 $permission->setUpdate_profile(true);
2597.                 $permission->setChange_password(true);
2598.                 $permission->setView_user(true);
2599.                 $permission->setList_location(true);
2600.                 $permission->setView_location(true);
2602.                 $permission->setAllowedUserRole($params['user']);
2603.                 $permission->save();
2604.             } else {
2606.                 $permissions = new DataObject\Permission();
2607.                 $permissions->setParent(DataObject\Service::createFolderByPath('/UserManagement/Permission/User'));
2608.                 $permissions->setKey($params['user']->getEmail());
2609.                 // $permissions->setDepartment($allowAlertHistoryForCustomAlerts);
2611.                 $permissions->setAlert_history($params['allowAlertHistoryForCustomAlerts']);
2612.                 $permissions->setGet_custom_notification($params['allowCustomNotification']);
2613.                 $permissions->setInvite_user($params['allowOrganizationAdminToInviteUsers']);
2614.                 $permissions->setCreate_location($params['allowAddLocation']);
2615.                 $permissions->setGet_weather($params['allowForecast']);
2618.                 // set Industry permissions
2619.                 $permissions->setAutomotive($params['automotive'] == false ? false : true);
2620.                 $permissions->setAviation($params['aviation'] == false ? false : true);
2621.                 $permissions->setShipping_and_offshore($params['shippingAndOffshore'] == false ? false : true);
2622.                 $permissions->setInsurance($params['insurance'] == false ? false : true);
2623.                 $permissions->setEnergy($params['energy'] == false ? false : true);
2625.                 // default permission on the basis of add location
2626.                 if ($params['allowAddLocation'] == true) {
2628.                     $permissions->setEdit_location(true);
2629.                     $permissions->setDelete_location(true);
2630.                     $permissions->setSearch_location(true);
2631.                     $permissions->setCompare_location(true);
2632.                 } else {
2633.                     $permissions->setEdit_location(false);
2634.                     $permissions->setDelete_location(false);
2635.                     $permissions->setSearch_location(false);
2636.                     $permissions->setCompare_location(false);
2637.                 }
2639.                 // default permission on the basis of add invite user
2640.                 if ($params['allowOrganizationAdminToInviteUsers'] == true || $invitedUserRoleName == USER_ROLES['CLIENT_ADMIN']) {
2641.                     $permissions->setEdit_user(true);
2642.                     $permissions->setDelete_user(true);
2643.                     $permissions->setList_user(true);
2644.                     $permissions->setSuspend_user(true);
2645.                     $permissions->setInvite_user(true);
2646.                     $permissions->setResend_invite(true);
2647.                     $permissions->setCreate_user(true);
2648.                 } else {
2649.                     $permissions->setEdit_user(false);
2650.                     $permissions->setDelete_user(false);
2651.                     $permissions->setList_user(false);
2652.                     $permissions->setSuspend_user(false);
2653.                     $permissions->setInvite_user(false);
2654.                     $permissions->setResend_invite(false);
2655.                     $permissions->setCreate_user(false);
2656.                 }
2658.                 // default permission to any user
2659.                 $permissions->setGet_profile(true);
2660.                 $permissions->setUpdate_profile(true);
2661.                 $permissions->setChange_password(true);
2662.                 $permissions->setView_user(true);
2663.                 $permissions->setList_location(true);
2664.                 $permissions->setView_location(true);
2666.                 $permissions->setAllowedUserRole($params['user']);
2667.                 $permissions->setPublished(true);
2668.                 $permissions->save();
2669.             }
2671.             return ["success" => true, "message" => "set_permission."];
2672.         } catch (\Exception $ex) {
2673.             throw new \Exception($ex->getMessage());
2674.         }
2676.         return $result;
2677.     }
2679.     /**
2680.      * set NCM Admin User Permissions
2681.      */
2682.     public function setNCMAdminUserPermissions($params)
2683.     {
2684.         $result = [];
2686.         try {
2689.             if ($params['invitingClients'] == false || $params['managingClients'] == false || $params['deletingClients'] == false || $params['invitingNCMAdmin'] == false || $params['managingNCMAdmin'] == false || $params['deletingNCMAdmin'] == false) {
2691.                 $permission = DataObject\Permission::getByAllowedUserRole($params['user'], true);
2692.                 if ($permission) {
2694.                     // default permission to any user
2695.                     $permission->setGet_profile(true);
2696.                     $permission->setUpdate_profile(true);
2697.                     $permission->setChange_password(true);
2698.                     $permission->setView_user(true);
2699.                     $permission->setList_location(true);
2700.                     $permission->setView_location(true);
2701.                     $permission->setEdit_location(true);
2702.                     $permission->setDelete_location(true);
2703.                     $permission->setSearch_location(true);
2704.                     $permission->setCompare_location(true);
2705.                     $permission->setList_ncm_user(true);
2706.                     $permission->setList_user(true);
2708.                     // set Industry permissions
2709.                     $permission->setAutomotive(true);
2710.                     $permission->setAviation(true);
2711.                     $permission->setShipping_and_offshore(true);
2712.                     $permission->setInsurance(true);
2713.                     $permission->setEnergy(true);
2715.                     // set invitingClients permissions
2716.                     $permission->setInvite_user($params['invitingClients'] == false ? false : true);
2717.                     $permission->setInvite_organization($params['invitingClients'] == false ? false : true);
2718.                     $permission->setResend_invite($params['invitingClients'] == false ? false : true);
2720.                     // set managingClients permissions
2721.                     $permission->setEdit_user($params['managingClients'] == false ? false : true);
2723.                     // set deletingClients permissions
2724.                     $permission->setDelete_user($params['deletingClients'] == false ? false : true);
2726.                     // set invitingNCMAdmin permissions
2727.                     $permission->setInvite_ncm_user($params['invitingNCMAdmin'] == false ? false : true);
2729.                     // set managingNCMAdmin permissions
2730.                     $permission->setEdit_ncm_user($params['managingNCMAdmin'] == false ? false : true);
2732.                     // set deletingNCMAdmin permissions
2733.                     $permission->setDelete_ncm_user($params['deletingNCMAdmin'] == false ? false : true);
2735.                     $permission->setAllowedUserRole($params['user']);
2737.                     $permission->save();
2738.                 } else {
2740.                     $permissions = new DataObject\Permission();
2741.                     $permissions->setParent(DataObject\Service::createFolderByPath('/UserManagement/Permission/User'));
2742.                     $permissions->setKey($params['user']->getEmail());
2743.                     // $permissions->setDepartment($allowAlertHistoryForCustomAlerts);
2745.                     // default permission to any user
2746.                     $permissions->setGet_profile(true);
2747.                     $permissions->setUpdate_profile(true);
2748.                     $permissions->setChange_password(true);
2749.                     $permissions->setView_user(true);
2750.                     $permissions->setList_location(true);
2751.                     $permissions->setView_location(true);
2752.                     $permissions->setList_ncm_user(true);
2753.                     $permissions->setList_user(true);
2755.                     // set Industry permissions
2756.                     $permissions->setAutomotive(true);
2757.                     $permissions->setAviation(true);
2758.                     $permissions->setShipping_and_offshore(true);
2759.                     $permissions->setInsurance(true);
2760.                     $permissions->setEnergy(true);
2762.                     // set invitingClients permissions
2763.                     $permissions->setInvite_user($params['invitingClients'] == false ? false : true);
2764.                     $permissions->setInvite_organization($params['invitingClients'] == false ? false : true);
2765.                     $permissions->setResend_invite($params['invitingClients'] == false ? false : true);
2767.                     // set managingClients permissions
2768.                     $permissions->setEdit_user($params['managingClients'] == false ? false : true);
2770.                     // set deletingClients permissions
2771.                     $permissions->setDelete_user($params['deletingClients'] == false ? false : true);
2773.                     // set invitingNCMAdmin permissions
2774.                     $permissions->setInvite_ncm_user($params['invitingNCMAdmin'] == false ? false : true);
2776.                     // set managingNCMAdmin permissions
2777.                     $permissions->setEdit_ncm_user($params['managingNCMAdmin'] == false ? false : true);
2779.                     // set deletingNCMAdmin permissions
2780.                     $permissions->setDelete_ncm_user($params['deletingNCMAdmin'] == false ? false : true);
2782.                     $permissions->setAllowedUserRole($params['user']);
2784.                     $permissions->setPublished(true);
2785.                     $permissions->save();
2786.                 }
2788.                 return ["success" => true, "message" => "set_permission"];
2789.             } else {
2790.                 // delete specific role if all permission are given
2791.                 $permission = DataObject\Permission::getByAllowedUserRole($params['user'], true);
2792.                 if ($permission instanceof \Pimcore\Model\DataObject\Permission) {
2793.                     $permission->delete();
2794.                 }
2796.                 return ["success" => true, "message" => "set_permission"];
2797.             }
2798.         } catch (\Exception $ex) {
2799.             throw new \Exception($ex->getMessage());
2800.         }
2802.         return $result;
2803.     }
2805.     public function getUserPermissionInfo($user, $translator)
2806.     {
2808.         $userEmail = [];
2809.         $userEmail['username'] = $user->getEmail();
2810.         // return $permission = DataObject\Permission::getByAllowedUserRole($user, true);
2811.         return $permission = $this->userPermission->getUserPermissions($userEmail, $translator);
2812.     }
2814.     public function getLocationList($user)
2815.     {
2816.         try {
2817.             $entries = new DataObject\Location\Listing();
2818.             $entries->setCondition("user LIKE " . $entries->quote("%," . $user->getId() . ",%"));
2819.             $entries->load();
2820.             $tempArr = [];
2821.             if (!empty($entries)) {
2822.                 foreach ($entries as $object) {
2823.                     array_push($tempArr, $object->getId());
2824.                 }
2825.             }
2826.             return $tempArr;
2827.         } catch (\Exception $ex) {
2828.             throw new \Exception($ex->getMessage());
2829.         }
2830.     }
2832.     public function assignLocationToUser($loggedInUser, $locationIds, $locationTagIds, $targetUsers, $targetUserGroups, $weatherSevereAlert, $customNotificationAlert, $translator)
2833.     {
2834.         $assignedLocationArr = [];
2836.         // Validate all users and user groups upfront
2838.         $validatedUsers = [];
2839.         if ($targetUsers) {
2840.             foreach ($targetUsers as $userId) {
2841.                 $user = \Pimcore\Model\DataObject::getById($userId);
2842.                 if (!$user instanceof Customer) {
2844.                     return ["success" => false, "message" => $translator->trans("Invalid User ID"), "userId" => $userId];
2845.                 }
2846.                 $organizationMatch = \App\Lib\Utility::matchOrganization($user, $loggedInUser);
2847.                 if (!$organizationMatch["success"]) {
2849.                     return ["success" => false, "message" => $translator->trans("User ID does not belong to your organization."), "userId" => $userId];
2850.                 }
2851.                 $validatedUsers[] = $user;
2852.             }
2853.         }
2855.         $validatedUserGroups = [];
2856.         if ($targetUserGroups) {
2857.             foreach ($targetUserGroups as $userGroupId) {
2858.                 $userGroup = \Pimcore\Model\DataObject::getById($userGroupId);
2859.                 if (!$userGroup instanceof UserGroup) {
2860.                     return ["success" => false, "message" => $translator->trans("Invalid User Group ID"), "userGroupId" => $userGroupId];
2861.                 }
2862.                 $targetUsersInGroup = new DataObject\Customer\Listing();
2863.                 $targetUsersInGroup->filterByUserGroup($userGroup);
2864.                 foreach ($targetUsersInGroup as $user) {
2865.                     $organizationMatch = \App\Lib\Utility::matchOrganization($user, $loggedInUser);
2866.                     if (!$organizationMatch["success"]) {
2867.                         return ["success" => false, "message" => $translator->trans("A user in group ID does not belong to your organization."), "userGroupId" => $userGroupId];
2868.                     }
2869.                 }
2870.                 $validatedUserGroups[] = $userGroup;
2871.             }
2872.         }
2875.         // Process Locations by Location IDs
2876.         if ($locationIds) {
2877.             foreach ($locationIds as $locationID) {
2878.                 $location = \Pimcore\Model\DataObject::getById($locationID);
2879.                 if ($location instanceof Location) {
2880.                     // Assign to validated users
2881.                     foreach ($validatedUsers as $user) {
2882.                         $this->locationModel->locationMetaData($location, $user, $weatherSevereAlert, $customNotificationAlert);
2883.                         $assignedLocationArr[] = $location->getId();
2884.                     }
2886.                     // Assign to validated user groups
2887.                     foreach ($validatedUserGroups as $userGroup) {
2888.                         $targetUsersInGroup = new DataObject\Customer\Listing();
2889.                         $targetUsersInGroup->filterByUserGroup($userGroup);
2890.                         foreach ($targetUsersInGroup as $user) {
2891.                             $this->locationModel->locationMetaData($location, $user, $weatherSevereAlert, $customNotificationAlert);
2892.                             $assignedLocationArr[] = $location->getId();
2893.                         }
2894.                     }
2895.                 } else {
2896.                     return ["success" => false, "message" => $translator->trans("Invalid Location ID"), "locationId" => $locationID];
2897.                 }
2898.             }
2899.         }
2901.         // Process Locations by Location Tag IDs
2902.         if ($locationTagIds) {
2903.             foreach ($locationTagIds as $locationTagId) {
2904.                 $locationTag = \Pimcore\Model\DataObject::getById($locationTagId);
2905.                 if ($locationTag instanceof Tags) {
2906.                     $locations = new DataObject\Location\Listing();
2908.                     $locations->setCondition("Tag LIKE " . $locations->quote("%," . $locationTag->getId() . ",%"));
2910.                     $locations->load();
2912.                     foreach ($locations as $location) {
2913.                         if ($location instanceof Location) {
2914.                             // Assign to validated users
2915.                             foreach ($validatedUsers as $user) {
2916.                                 $this->locationModel->locationMetaData($location, $user, $weatherSevereAlert, $customNotificationAlert);
2917.                                 $assignedLocationArr[] = $location->getId();
2918.                             }
2920.                             // Assign to validated user groups
2921.                             foreach ($validatedUserGroups as $userGroup) {
2922.                                 $targetUsersInGroup = new DataObject\Customer\Listing();
2923.                                 $targetUsersInGroup->filterByUserGroup($userGroup);
2924.                                 foreach ($targetUsersInGroup as $user) {
2925.                                     $this->locationModel->locationMetaData($location, $user, $weatherSevereAlert, $customNotificationAlert);
2926.                                     $assignedLocationArr[] = $location->getId();
2927.                                 }
2928.                             }
2929.                         }
2930.                     }
2931.                 } else {
2932.                     return ["success" => false, "message" => $translator->trans("Invalid Location Tag ID"), 'locationId' => $locationTagId];
2933.                 }
2934.             }
2935.         }
2938.         return array_values(array_unique($assignedLocationArr));
2939.     }
2943.     public function getUserLocations($user)
2944.     {
2945.         try {
2946.             $locationData = [];
2947.             $locations = $this->getLocationList($user);
2948.             if ($locations) {
2949.                 foreach ($locations as $locationId) {
2950.                     $location = \Pimcore\Model\DataObject::getById($locationId);
2951.                     if ($location instanceof Location) {
2952.                         $alertConfig = $this->locationModel->getUserSevereAlertAndCustomNotification($location, $user);
2953.                         $locationData[] = [
2954.                             'id' => $location->getId(),
2955.                             'name' => $location->getName(),
2956.                             'title' => $location->getTitle(),
2957.                             'coordinates' => $location->getCoordinates(),
2958.                             'severeWeatherAlert' => isset($alertConfig['get_severe_alert']) && ($alertConfig['get_severe_alert'] == true) ?? false,
2959.                             'customNotificationAlert' => isset($alertConfig['get_custom_notification']) && ($alertConfig['get_custom_notification'] == true) ?? false,
2960.                         ];
2961.                     }
2962.                 }
2963.             }
2965.             return $locationData;
2966.         } catch (\Exception $ex) {
2967.             throw new \Exception($ex->getMessage());
2968.         }
2969.     }
2971.     public function getUsersLocationByOrganizationId($organizationId)
2972.     {
2973.         // try {
2974.         $organization = \Pimcore\Model\DataObject::getById($organizationId);
2975.         if (!$organization instanceof \Pimcore\Model\DataObject\Organization) {
2976.             throw new \Exception("Organization not found");
2977.         }
2978.         $customers = new \Pimcore\Model\DataObject\Customer\Listing();
2979.         $customers->filterByOrganization($organization);
2980.         if ($customers->getCount() == 0) {
2981.             throw new \Exception("Customers does not exists in this organization");
2982.         }
2984.         $locationData = [];
2985.         foreach ($customers as $customer) {
2986.             $locations = $this->getLocationList($customer);
2987.             if ($locations) {
2988.                 foreach ($locations as $locationId) {
2989.                     $location = \Pimcore\Model\DataObject::getById($locationId);
2990.                     if ($location instanceof Location) {
2991.                         $alertConfig = $this->locationModel->getUserSevereAlertAndCustomNotification($location, $customer);
2992.                         $locationData[] = [
2993.                             'id' => $location->getId(),
2994.                             'name' => $location->getName(),
2995.                             'title' => $location->getTitle(),
2996.                             'coordinates' => $location->getCoordinates(),
2997.                             'severeWeatherAlert' => isset($alertConfig['get_severe_alert']) && ($alertConfig['get_severe_alert'] == true) ?? false,
2998.                             'customNotificationAlert' => isset($alertConfig['get_custom_notification']) && ($alertConfig['get_custom_notification'] == true) ?? false,
2999.                             "customerId" => $customer->getId(),
3000.                             "customerName" => $customer->getName(),
3001.                             "customerEmail" => $customer->getEmail()
3002.                         ];
3003.                     }
3004.                 }
3005.             }
3006.         }
3008.         return $locationData;
3009.         // } catch (\Exception $ex) {
3010.         //     throw new \Exception($ex->getMessage());
3011.         // }
3012.     }
3015.     /**
3016.      * Get User Assigned API Groups
3017.      *
3018.      */
3019.     public function getUserApiGroups($user)
3020.     {
3022.         $apiGroups = [];
3024.         $subscriptions = new DataObject\Subscription\Listing();
3025.         $subscriptions->filterBySubscribedUser($user);
3027.         $currentDate = date('Y-m-d'); // Assuming the date and time format is 'YYYY-MM-DD'
3029.         $subscriptions->filterByEndDate(strtotime($currentDate), ">=");
3030.         $subscriptions->filterBySubscriptionType("custom");
3031.         $subscriptions->filterByIsActive(true);
3032.         $subscriptions->load();
3034.         foreach ($subscriptions as $subscription) {
3035.             $package = $subscription->getSubscribedPackage();
3036.             if ($package instanceof DataObject\Package) {
3038.                 if ($package->getApiGroups()) {
3040.                     foreach ($package->getApiGroups() as $key => $ApiGroup) {
3042.                         $apiGroups[] = [
3043.                             "apiGroupId" => $ApiGroup->getId(),
3044.                             "type" => $ApiGroup->getApiGroupType(),
3045.                             "name" => $ApiGroup->getApiGroupName('en'),
3046.                             "name_ar" => $ApiGroup->getApiGroupName('ar'),
3048.                         ];
3049.                     }
3050.                 }
3051.             }
3052.         }
3053.         return $apiGroups;
3054.     }
3058.     /**
3059.      * generate unsubscribe token user
3060.      */
3061.     public function unSubscribeGenerateToken($email)
3062.     {
3063.         $token = '';
3064.         try {
3065.             //generate token
3066.             $user = DataObject\Customer::getByEmail($email, true);
3068.             // $token = md5($user->getEmail() . time() . uniqid());
3069.             $token = base64_encode($user->getEmail() . time() . uniqid());
3070.             $user->setunSubscribeToken($token);
3071.             $user->save();
3073.             return $token;
3074.         } catch (\Exception $ex) {
3075.             throw new \Exception($ex->getMessage());
3076.         }
3078.         return $token;
3079.     }
3082.     /**
3083.      * generate unsubscribe ews notification token user
3084.      */
3085.     public function unSubscribeEwsGenerateToken($email)
3086.     {
3087.         $token = '';
3088.         try {
3089.             //generate token
3090.             $user = DataObject\Customer::getByEmail($email, true);
3092.             // $token = md5($user->getEmail() . time() . uniqid());
3093.             $token = base64_encode($user->getEmail() . time() . uniqid());
3094.             $user->setEwsNotificationToken($token);
3095.             $user->save();
3097.             return $token;
3098.         } catch (\Exception $ex) {
3099.             throw new \Exception($ex->getMessage());
3100.         }
3102.         return $token;
3103.     }
3105.     /**
3106.      * Get NCM User List
3107.      */
3108.     public function getAllActiveUsersInExcelData($params, $user, $translator)
3109.     {
3111.         $result = [];
3112.         try {
3113.             $userDataEn = [];
3115.             // Get All the Classes
3116.             $class = new \Pimcore\Model\DataObject\ClassDefinition();
3117.             $customer = $class->getDao()->getIdByName('Customer');
3118.             $subscription = $class->getDao()->getIdByName('Subscription');
3119.             $userRole = $class->getDao()->getIdByName('UserRole');
3120.             $organization = $class->getDao()->getIdByName('Organization');
3121.             $package = $class->getDao()->getIdByName('Package');
3123.             $db = Db::get();
3124.             $select = $db->createQueryBuilder();
3125.             $select->select('customer.oo_id');
3126.             $select->from('object_' . $customer, 'customer');
3127.             $select->innerJoin('customer', 'object_' . $subscription, 'subscription', 'customer.oo_id = subscription.subscribedUser__id');
3128.             $select->innerJoin('subscription', 'object_' . $package, 'package', 'package.oo_id = subscription.subscribedPackage__id');
3129.             $select->innerJoin('customer', 'object_' . $organization, 'organization', 'organization.oo_id = customer.organization__id');
3130.             $select->innerJoin('customer', 'object_' . $userRole, 'userRole', 'userRole.oo_id = customer.role__id');
3132.             // if (isset($params['search']) && !empty($params['search'])) {
3133.             //     $select->andWhere("customer.name LIKE " . $db->quote("%" . $params['search'] . "%") . " OR customer.email LIKE " . $db->quote("%" . $params['search'] . "%"));
3134.             // }
3135.             if (isset($params['type']) && !empty($params['type'])) {
3136.                 if ($params['type'] == 'client') {
3137.                     $select->andWhere("userRole.name = " . $db->quote(USER_ROLES['CLIENT_ADMIN']) . " OR userRole.name = " . $db->quote(USER_ROLES['CLIENT_USER']));
3138.                 } elseif ($params['type'] == 'ncm') {
3139.                     $select->andWhere("userRole.name = " . $db->quote(USER_ROLES['NCM_IT']) . " OR userRole.name = " . $db->quote(USER_ROLES['NCM_OPERATOR']));
3140.                 }
3141.             }
3142.             $select->andWhere("customer.oo_id != " . $db->quote($user->getId()));
3143.             $select->andWhere("customer.isDeleted != 1 or customer.isDeleted IS NULL");
3144.             if (!empty($params["entityId"])) {
3145.                 $select->andWhere("organization.oo_id = " . $db->quote($params["entityId"]));
3146.             }
3148.             $select->orderBy('oo_id', 'DESC');
3149.             $select->groupBy(array('oo_id'));
3150.             $select = $select->execute();
3151.             $usersIds = $select->fetchAllAssociative();
3153.             if (count($usersIds) == 0) {
3154.                 return ["success" => false, "message" => $translator->trans("no_user_available_in_NCM")];
3155.             }
3157.             $userDataEn[] = [
3158.                 'S. No' => 'S. No',
3159.                 'Username' => 'Username',
3160.                 'Entity' => 'Entity',
3161.                 'Entity AR' => 'Entity AR',
3162.                 'Email Address' => 'Email Address',
3163.                 'Type' => 'Type',
3164.                 'Role' => 'Role',
3165.                 'Created By' => 'Created By',
3166.                 'Created On' => 'Created On',
3167.                 'Package' => 'Package',
3168.                 'Package Expiry' => 'Package Expiry',
3169.                 'Status' => 'Status',
3170.             ];
3172.             foreach ($usersIds as $userKey => $usersId) {
3174.                 $usersData = DataObject\Customer::getById($usersId['oo_id'], true);
3175.                 if ($usersData instanceof \Pimcore\Model\DataObject\Customer) {
3177.                     // Get Custom Subscription of the organization and package
3178.                     $customSubscriptions = new DataObject\Subscription\Listing();
3179.                     $customSubscriptions->filterBySubscribedUser($usersData);
3180.                     $customSubscriptions->filterByIsActive(true);
3182.                     $status = "";
3183.                     if ($usersData->getToken() == "" && $usersData->isPublished() == true) {
3185.                         if ($customSubscriptions->count() > 0) {
3186.                             $status = "Active";
3187.                         } else {
3188.                             $status = "Suspended";
3189.                         }
3190.                     } elseif ($usersData->getToken() != "" && $usersData->isPublished() == false) {
3192.                         $status = "Pending";
3193.                     }
3195.                     $permissionObj = $this->getUserPermissionInfo($usersData, $translator);
3196.                     $userPermissions = $permissionObj['success'] ? $permissionObj['grants'] : null;
3198.                     $customSubscriptions->filterBySubscriptionType("custom");
3199.                     $customSubscriptions->setOrderKey("o_modificationDate");
3200.                     $customSubscriptions->setOrder("desc");
3202.                     $apiGroupData = [];
3203.                     $packageData = [];
3204.                     if ($customSubscriptions->count() > 0) {
3205.                         foreach ($customSubscriptions as $key => $customSubscription) {
3206.                             if ($customSubscription instanceof \Pimcore\Model\DataObject\Subscription) {
3207.                                 $package = $customSubscription->getSubscribedPackage();
3208.                                 $disallowedApiGroups = $customSubscription->getDisallowedApiGroups();
3209.                                 if ($package) {
3210.                                     $packageData[] = [
3211.                                         "id" => $package->getId(),
3212.                                         "name" => $package->getPackageName("en"),
3213.                                         "package_expiry" => $customSubscription->getEndDate(date("M d, Y"))
3214.                                     ];
3216.                                     $apiGroups = $package->getApiGroups();
3217.                                     if ($apiGroups) {
3218.                                         foreach ($apiGroups as  $apiGroup) {
3220.                                             $apiGroupId = $apiGroup->getId();
3221.                                             $apiGroupNameEn = $apiGroup->getApiGroupName('en');
3222.                                             $apiGroupNameAr = $apiGroup->getApiGroupName('ar');
3223.                                             $isDisallowed = false;
3225.                                             // Check if the current API group is disallowed
3226.                                             foreach ($disallowedApiGroups as $disallowedApiGroup) {
3227.                                                 if ($apiGroupId == $disallowedApiGroup->getId()) {
3228.                                                     $isDisallowed = true;
3229.                                                     break;
3230.                                                 }
3231.                                             }
3233.                                             // Only add the API group if it's not disallowed
3234.                                             if (!$isDisallowed) {
3235.                                                 $apiGroupData[] = [
3236.                                                     "id" => $apiGroupId,
3237.                                                     "name" => $apiGroupNameEn,
3238.                                                     "name_ar" => $apiGroupNameAr
3239.                                                 ];
3240.                                             }
3241.                                         }
3242.                                     }
3243.                                 }
3244.                             }
3245.                         }
3246.                     }
3248.                     $userDataEn[] = [
3249.                         'S. No' => $userKey + 1,
3250.                         'Username' => $usersData->getName(),
3251.                         'Entity' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName() : null,
3252.                         'Entity AR' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName('ar') : null,
3253.                         'Email Address' => $usersData->getEmail(),
3254.                         'Type' => $translator->trans('user', [], null, 'en'),
3255.                         'Role' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'en') : null,
3256.                         'Created By' => $usersData->getCreatedBy() ? $usersData->getCreatedBy()->getName() : null,
3257.                         'Created On' => $usersData->getCreationDate() ? date('Y-m-d', $usersData->getCreationDate()) : null,
3258.                         'Package' => isset($packageData[0]['name']) ? $packageData[0]['name'] : null,
3259.                         'Package Expiry' => isset($packageData[0]['package_expiry']) ? date("M d, Y", strtotime($packageData[0]['package_expiry'])) : null,
3260.                         'Status' => $translator->trans($status, [], null, 'en'),
3262.                     ];
3263.                 }
3264.             }
3266.             $excelData = ExcelGenerator::createAndSaveXlsx($userDataEn, $params['type'] . "_users_data", true, '/users/excel/');
3267.             return ["success" => true, "message" => $translator->trans("excel_generated"), "data" =>  $excelData];
3268.         } catch (\Exception $ex) {
3269.             throw new \Exception($ex->getMessage());
3270.         }
3271.     }
3273.     public function createWsoUser($name, $email, $translator): array
3274.     {
3275.         try {
3276.             Utility::validateEmail($email);
3277.             Utility::validateName($name);
3279.             $user = DataObject\Customer::getByEmail($email, true);
3281.             if ($user instanceof \Pimcore\Model\DataObject\Customer) {
3282.                 return ["success" => false, "message" => $translator->trans("user_already_exists")];
3283.             }
3285.             $registerUser = new DataObject\Customer();
3286.             $registerUser->setParent(DataObject\Service::createFolderByPath('/UserManagement/WsoUsers'));
3287.             $registerUser->setKey(trim(strip_tags($email)));
3288.             $registerUser->setUserType('public');
3289.             $registerUser->setName(strip_tags($name));
3290.             $registerUser->setEmail(trim(strip_tags($email)));
3291.             $registerUser->setPublished(true);
3292.             $registerUser->setIsActive(true);
3293.             $registerUser->setSendEwsEmail(false);
3294.             $registerUser->setOmitMandatoryCheck(true);
3295.             $registerUser->save();
3297.             return ["success" => true, "message" => $translator->trans("user_registered_success"), 'data' => $registerUser->getId()];
3298.         } catch (\Exception $ex) {
3299.             throw new \Exception($ex->getMessage());
3300.         }
3301.         return [];
3302.     }
3305.     /**
3306.      * Create User Tag
3307.      */
3308.     public function createUserTag($user, $name, $request, $lang, $translator, $organization = false)
3309.     {
3310.         $result = [];
3312.         try {
3313.             $userTag = new DataObject\UserTag();
3314.             if ($organization) {
3315.                 $userTag->setParent(DataObject\Service::createFolderByPath('/Organization/tags/'));
3316.             } else {
3317.                 $userTag->setParent(DataObject\Service::createFolderByPath('/UserManagement/user tags/'));
3318.             }
3319.             $userTag->setKey(\Pimcore\Model\Element\Service::getValidKey($name . '_' . uniqid(), 'object'));
3320.             $userTag->setName(strip_tags($name));
3321.             $userTag->setOrganization($organization);
3322.             $userTag->setPublished(true);
3323.             $userTag->save();
3324.             if ($userTag) {
3325.                 return ["success" => true, "message" => $translator->trans("user_tag_created_successfully"), "user_tag_id" => $userTag->getId()];
3326.             }
3327.         } catch (\Exception $ex) {
3328.             throw new \Exception($ex->getMessage());
3329.         }
3330.         return $result;
3331.     }
3335.     /**
3336.      * User Tag Listing
3337.      */
3338.     public function userTagListing($user, $translator, $paginator, $params)
3339.     {
3340.         $result = [];
3342.         try {
3343.             $tagData = [];
3345.             $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
3346.             $page = isset($params['page']) ? $params['page'] : 1;
3348.             $tagList = new DataObject\UserTag\Listing();
3349.             // Check if organization parameter is set and not empty
3350.             if (isset($params['organization']) && !empty($params['organization'])) {
3351.                 $organization = $params['organization'];
3352.                 $tagList->setCondition("organization = true");
3353.             } else {
3354.                 $tagList->setCondition("(organization = false OR organization is null)");
3355.             }
3356.             if (isset($params['search']) && !empty($params['search'])) {
3357.                 $tagList->setCondition("name LIKE " . $tagList->quote("%" . $params['search'] . "%"));
3358.             }
3360.             $allowed = [
3361.                 'name'
3362.             ];
3363.             if ($params['sortBy'] && in_array($params['sortBy'], $allowed, true)) {
3364.                 $tagList->setOrderKey($params['sortBy']);
3365.                 $tagList->setOrder($params['sortDir'] === 'DESC' ? 'DESC' : 'ASC');
3366.             }
3368.             $paginator = $paginator->paginate(
3369.                 $tagList,
3370.                 $page,
3371.                 $pageSize
3372.             );
3373.             if ($paginator->getTotalItemCount() > 0) {
3375.                 foreach ($paginator as $key => $tag) {
3376.                     $tagData[] = [
3377.                         'id' => $tag->getId(),
3378.                         'name' => $tag->getName()
3379.                     ];
3380.                 }
3382.                 if (!empty($tagData) && count($tagData) > 0) {
3383.                     return ["success" => true, "data" => $tagData, "paginationVariables" => $paginator->getPaginationData()];
3384.                 }
3385.             }
3386.             return ["success" => false, "message" => $translator->trans("user_groups_are_not_available")];
3387.         } catch (\Exception $ex) {
3388.             throw new \Exception($ex->getMessage());
3389.         }
3390.         return $result;
3391.     }
3394.     /**
3395.      * Validate the unsubscribe token
3396.      *
3397.      * @param string $token
3398.      * @param Translator $translator
3399.      * @return array
3400.      */
3401.     public function unsubscribeTokenValidate($token, $translator)
3402.     {
3403.         // Fetch user by unsubscribe token
3404.         $user = Customer::getByUnSubToken($token, true);
3406.         if (!$user) {
3407.             return [
3408.                 "success" => false,
3409.                 "message" => $translator->trans("invalid_token")
3410.             ];
3411.         }
3413.         // Prepare the data
3414.         $data = [
3415.             "success" => true,
3416.             "id" => $user->getId(),
3417.             "email" => $user->getEmail(),
3418.             "customNotification" => $user->getCustomNotification(),
3419.             "earlyWarningNotification" => $user->getEarlyWarningNotification(),
3420.             "advanceCustomNotification" => $user->getAdvanceCustomNotification(),
3421.             "severeWeatherAlert" => $user->getSevereWeatherAlert()
3422.         ];
3424.         return $data;
3425.     }
3428.     /**
3429.      * update user Subscription
3430.      *
3431.      * @param string $params
3432.      * @param Translator $translator
3433.      * @return array
3434.      */
3435.     public function updateUserSubscription($params, $translator)
3436.     {
3437.         // Fetch user by unsubscribe token
3438.         $user = Customer::getById($params['id'], true);
3440.         if (!$user) {
3441.             return [
3442.                 "success" => false,
3443.                 "message" => $translator->trans("invalid_user_id")
3444.             ];
3445.         }
3446.         if (isset($params['customNotification'])) {
3448.             $user->setCustomNotification($params['customNotification']);
3449.         }
3450.         if (isset($params['earlyWarningNotification'])) {
3452.             $user->setEarlyWarningNotification($params['earlyWarningNotification']);
3453.         }
3454.         if (isset($params['advanceCustomNotification'])) {
3456.             $user->setAdvanceCustomNotification($params['advanceCustomNotification']);
3457.         }
3458.         if (isset($params['severeWeatherAlert'])) {
3460.             $user->setSevereWeatherAlert($params['severeWeatherAlert']);
3461.         }
3463.         $user->save();
3466.         // Prepare the data
3467.         $data = [
3468.             "success" => true,
3469.             "message" => $translator->trans("subscription_updated")
3471.         ];
3473.         return $data;
3474.     }
3476.     public function saveBulkUserInviteLog($user, $data, $organizationId)
3477.     {
3478.         $bulkUserInviteLog = new DataObject\BulkInviteUserReport();
3479.         $bulkUserInviteLog->setParent(DataObject\Service::createFolderByPath('/UserManagement/BulkUserInviteLog'));
3480.         $bulkUserInviteLog->setKey(\Pimcore\Model\Element\Service::getValidKey(uniqid(), 'object'));
3481.         $bulkUserInviteLog->setPublished(true);
3482.         $bulkUserInviteLog->setJsonData(json_encode($data));
3483.         $organization = DataObject\Organization::getById($organizationId);
3484.         if ($organization) {
3485.             $bulkUserInviteLog->setOrganization($organization);
3486.         }
3487.         $bulkUserInviteLog->setCreatedBy($user);
3488.         $bulkUserInviteLog->save();
3489.         return $bulkUserInviteLog;
3490.     }
3492.     public function getEntitySubscription($user)
3493.     {
3494.         $package = null;
3495.         $subscriptions = new Subscription\Listing();
3496.         $subscriptions->filterBySubscribedUser($user);
3497.         $subscriptions->filterBySubscriptionType("custom");
3498.         $subscription = $subscriptions->current();
3500.         return $subscription;
3501.     }
3503.     public function getEntityPackage($user)
3504.     {
3505.         $package = null;
3506.         $subscriptions = new Subscription\Listing();
3507.         $subscriptions->filterBySubscribedUser($user);
3508.         $subscriptions->filterBySubscriptionType("custom");
3509.         $subscription = $subscriptions->current();
3510.         if ($subscription) {
3511.             $package = $subscription->getSubscribedPackage();
3512.         }
3514.         return $package;
3515.     }
3517.     private function getInvitationDate($user): string
3518.     {
3519.         try {
3520.             $token = $user->getToken();
3522.             if (empty($token)) {
3523.                 $creationDate = $user->getCreationDate();
3524.                 if ($creationDate) {
3525.                     return date('Y-m-d H:i:s', $creationDate);
3526.                 }
3527.                 return "Unknown";
3528.             }
3530.             $tokenParts = explode('.', $token);
3531.             if (count($tokenParts) !== 3) {
3532.                 $creationDate = $user->getCreationDate();
3533.                 if ($creationDate) {
3534.                     return date('Y-m-d H:i:s', $creationDate);
3535.                 }
3536.                 return "Invalid token";
3537.             }
3539.             $payload = json_decode(base64_decode(str_replace(['-', '_'], ['+', '/'], $tokenParts[1])), true);
3541.             if (!$payload || !isset($payload['time'])) {
3542.                 $creationDate = $user->getCreationDate();
3543.                 if ($creationDate) {
3544.                     return date('Y-m-d H:i:s', $creationDate);
3545.                 }
3546.                 return "No invitation time found";
3547.             }
3549.             $invitationTime = $payload['time'];
3551.             return date('Y-m-d H:i:s', $invitationTime);
3552.         } catch (\Exception $e) {
3553.             $creationDate = $user->getCreationDate();
3554.             if ($creationDate) {
3555.                 return date('Y-m-d H:i:s', $creationDate);
3556.             }
3557.             return "Error getting date";
3558.         }
3559.     }
3561.     public function listC2Users($params, $translator)
3562.     {
3563.         try {
3564.             $userData = [];
3566.             // Get class IDs for table names
3567.             $class = new \Pimcore\Model\DataObject\ClassDefinition();
3568.             $customerClassId = $class->getDao()->getIdByName('Customer');
3569.             $subscriptionClassId = $class->getDao()->getIdByName('Subscription');
3570.             $packageClassId = $class->getDao()->getIdByName('Package');
3572.             $db = Db::get();
3573.             $select = $db->createQueryBuilder();
3575.             // Select customer data and subscription/package info
3576.             $select->select([
3577.                 'customer.oo_id AS customer_id',
3578.                 'customer.name AS customer_name',
3579.                 'customer.email AS customer_email',
3580.                 'customer.phoneNo AS customer_phone',
3581.                 'subscription.oo_id AS subscription_id',
3582.                 'subscription.isActive AS subscription_is_active',
3583.                 'subscription.endDate AS subscription_end_date',
3584.                 'subscription.subscriptionType AS subscription_type'
3585.             ]);
3587.             $select->from('object_' . $customerClassId, 'customer');
3589.             // INNER JOIN with Subscription to get only customers with subscriptions
3590.             // Then filter by active subscriptions
3591.             $select->innerJoin(
3592.                 'customer',
3593.                 'object_' . $subscriptionClassId,
3594.                 'subscription',
3595.                 'customer.oo_id = subscription.subscribedUser__id'
3596.             );
3599.             // Apply filters
3600.             // Phone number must exist and be exactly 9 digits
3601.             $select->where("customer.phoneNo IS NOT NULL AND customer.phoneNo != '' AND CHAR_LENGTH(customer.phoneNo) = 9");
3602.             
3603.             // Customer must be published
3604.             $select->andWhere("customer.o_published = 1");
3605.             
3606.             // Only active subscriptions
3607.             $select->andWhere("subscription.isActive = 1");
3608.             
3609.             // Only 'custom' subscription type (matching the commented code pattern)
3610.             $select->andWhere("subscription.subscriptionType = " . $db->quote('custom'));
3611.             
3612.             // Only subscriptions with end date in future (or no expiry)
3613.             // Pimcore stores dates as Unix timestamps, so compare with current timestamp
3614.             $currentTimestamp = time();
3615.             $select->andWhere("(subscription.endDate IS NULL OR subscription.endDate >= " . $currentTimestamp . ")");
3617.             // Execute query
3618.             $results = $select->execute()->fetchAllAssociative();
3620.             // Process results
3621.             foreach ($results as $row) {
3622.                 // Parse endDate - Pimcore stores dates as Unix timestamps
3623.                 $packageExpiry = null;
3624.                 if (!empty($row['subscription_end_date'])) {
3625.                     try {
3626.                         // Check if it's a Unix timestamp (numeric) or date string
3627.                         if (is_numeric($row['subscription_end_date'])) {
3628.                             // Unix timestamp - use @ prefix to parse
3629.                             $date = new \DateTime('@' . $row['subscription_end_date']);
3630.                             $date->setTimezone(new \DateTimeZone('Asia/Riyadh'));
3631.                             $packageExpiry = $date->format('M d, Y');
3632.                         } else {
3633.                             // Date string - parse directly
3634.                             $date = new \DateTime($row['subscription_end_date']);
3635.                             $packageExpiry = $date->format('M d, Y');
3636.                         }
3637.                     } catch (\Exception $e) {
3638.                         // If parsing fails, log and continue
3639.                         error_log('Error parsing subscription end date: ' . $e->getMessage() . ' - Value: ' . $row['subscription_end_date']);
3640.                         $packageExpiry = null;
3641.                     }
3642.                 }
3643.                 
3644.                 $userData[] = [
3645.                     'id' => (int) $row['customer_id'],
3646.                     'name' => $row['customer_name'] ?? '',
3647.                     'email' => $row['customer_email'] ?? '',
3648.                     'phoneNumber' => '+966' . $row['customer_phone'],
3649.                     'package_expiry' => $packageExpiry,
3650.                     'status' => $row['subscription_is_active'] ? 'Active' : 'Suspended',
3651.                 ];
3652.             }
3654.             return ["success" => true, "data" => $userData];
3656.         } catch (\Exception $e) {
3657.             error_log('Error in listC2Users: ' . $e->getMessage());
3658.             return ["success" => false, "error" => $e->getMessage(), "data" => []];
3659.         }
3660.     }
3662.     /**
3663.      * List user groups with simplified response (groupid, name, user_ids)
3664.      * Only includes users with mobile numbers (like listC2Users logic)
3665.      */
3666.     public function listUserGroupsSimple($user, $translator): array
3667.     {
3668.         try {
3669.             $organization = $user->getOrganization();
3671.             if (!$organization instanceof DataObject\Organization) {
3672.                 return ["success" => false, "message" => $translator->trans("user_does_not_belongs_to_organization")];
3673.             }
3675.             // Get class IDs for table names
3676.             $class = new \Pimcore\Model\DataObject\ClassDefinition();
3677.             $customerClassId = $class->getDao()->getIdByName('Customer');
3678.             $subscriptionClassId = $class->getDao()->getIdByName('Subscription');
3680.             $db = Db::get();
3682.             // Load UserGroup listing
3683.             $userGroupList = new DataObject\UserGroup\Listing();
3684.             $userGroupList->filterByOrganization($organization);
3685.             $userGroupList->setOrderKey("oo_id");
3686.             $userGroupList->setOrder("desc");
3688.             $userGroupListData = [];
3690.             foreach ($userGroupList as $userGroup) {
3691.                 $groupId = $userGroup->getId();
3692.                 
3693.                 // Use direct SQL to find users in this group
3694.                 // Pimcore stores userGroup as comma-separated string: ",398039,398040,"
3695.                 $select = $db->createQueryBuilder();
3696.                 $select->select(['customer.oo_id AS customer_id', 'customer.phoneNo AS phone_no']);
3697.                 $select->from('object_' . $customerClassId, 'customer');
3698.                 
3699.                 // Filter by user group - format is ",groupId," to match exact group ID
3700.                 $select->where("customer.userGroup LIKE :groupIdPattern");
3701.                 $select->setParameter('groupIdPattern', '%,' . $groupId . ',%');
3702.                 
3703.                 // Join with subscription to filter active subscriptions
3704.                 $select->innerJoin(
3705.                     'customer',
3706.                     'object_' . $subscriptionClassId,
3707.                     'subscription',
3708.                     'customer.oo_id = subscription.subscribedUser__id'
3709.                 );
3711.                 // Apply mobile number filter (same as listC2Users)
3712.                 $select->andWhere("customer.phoneNo IS NOT NULL AND customer.phoneNo != '' AND CHAR_LENGTH(customer.phoneNo) = 9");
3713.                 
3714.                 // Customer must be published
3715.                 $select->andWhere("customer.o_published = 1");
3716.                 
3717.                 // Only active subscriptions
3718.                 $select->andWhere("subscription.isActive = 1");
3719.                 
3720.                 // Only 'custom' subscription type
3721.                 $select->andWhere("subscription.subscriptionType = " . $db->quote('custom'));
3722.                 
3723.                 // Only subscriptions with end date in future (or no expiry)
3724.                 $currentTimestamp = time();
3725.                 $select->andWhere("(subscription.endDate IS NULL OR subscription.endDate >= " . $currentTimestamp . ")");
3727.                 $results = $select->execute()->fetchAllAssociative();
3728.                 
3729.                 // Convert user_ids to phone numbers
3730.                 $userPhones = [];
3731.                 foreach ($results as $row) {
3732.                     $phoneNo = $row['phone_no'];
3733.                     if (!empty($phoneNo) && strlen($phoneNo) === 9) {
3734.                         $userPhones[] = '+966' . $phoneNo;
3735.                     }
3736.                 }
3738.                 $userGroupListData[] = [
3739.                     'groupid' => $userGroup->getId(),
3740.                     'name' => $userGroup->getGroupName("en") ?: $userGroup->getGroupName("ar") ?: '',
3741.                     'user_phones' => $userPhones
3742.                 ];
3743.             }
3744.             
3745.             // Also fetch UserSMSGroup objects
3746.             $userSMSGroupList = new DataObject\UserSMSGroup\Listing();
3747.             $userSMSGroupList->setOrderKey("oo_id");
3748.             $userSMSGroupList->setOrder("desc");
3749.             
3750.             foreach ($userSMSGroupList as $userSMSGroup) {
3751.                 // Extract phone numbers from groupData JSON
3752.                 $groupData = $userSMSGroup->getGroupData();
3753.                 $userPhones = [];
3754.                 
3755.                 if (!empty($groupData)) {
3756.                     try {
3757.                         $userInfoArray = json_decode($groupData, true);
3758.                         if (is_array($userInfoArray)) {
3759.                             foreach ($userInfoArray as $userInfo) {
3760.                                 if (isset($userInfo['phoneNumber']) && !empty($userInfo['phoneNumber'])) {
3761.                                     $phoneNumber = $userInfo['phoneNumber'];
3762.                                     // Ensure phone number is in +966XXXXXXXXX format
3763.                                     if (!preg_match('/^\+966/', $phoneNumber)) {
3764.                                         // Remove +966 or 966 prefix to get 9 digits
3765.                                         $phoneDigits = preg_replace('/^\+966/', '', $phoneNumber);
3766.                                         $phoneDigits = preg_replace('/^966/', '', $phoneDigits);
3767.                                         $phoneDigits = preg_replace('/[^0-9]/', '', $phoneDigits);
3768.                                         if (strlen($phoneDigits) === 9) {
3769.                                             $phoneNumber = '+966' . $phoneDigits;
3770.                                         }
3771.                                     }
3772.                                     $userPhones[] = $phoneNumber;
3773.                                 }
3774.                             }
3775.                         }
3776.                     } catch (\Exception $ex) {
3777.                         // Skip invalid JSON
3778.                         continue;
3779.                     }
3780.                 }
3781.                 
3782.                 // Merge with existing UserGroup if same name, otherwise add as new entry
3783.                 $groupName = $userSMSGroup->getGroupName("en") ?: $userSMSGroup->getGroupName("ar") ?: '';
3784.                 $merged = false;
3785.                 
3786.                 foreach ($userGroupListData as &$existingGroup) {
3787.                     if ($existingGroup['name'] === $groupName) {
3788.                         // Merge phone numbers (remove duplicates)
3789.                         $existingGroup['user_phones'] = array_values(array_unique(array_merge($existingGroup['user_phones'], $userPhones)));
3790.                         $merged = true;
3791.                         break;
3792.                     }
3793.                 }
3794.                 
3795.                 if (!$merged && !empty($userPhones)) {
3796.                     // Add as new entry if not merged
3797.                     $userGroupListData[] = [
3798.                         'groupid' => $userSMSGroup->getId(),
3799.                         'name' => $groupName,
3800.                         'user_phones' => $userPhones
3801.                     ];
3802.                 }
3803.             }
3805.             if (!empty($userGroupListData)) {
3806.                 return ["success" => true, "data" => $userGroupListData];
3807.             }
3809.             return ["success" => false, "message" => $translator->trans("user_groups_are_not_available")];
3810.         } catch (\Exception $ex) {
3811.             throw new \Exception($ex->getMessage());
3812.         }
3813.     }
3815.     /**
3816.      * Create or update user group with simplified parameters
3817.      * Only assigns users that have mobile numbers (like listC2Users logic)
3818.      */
3819.     public function createUpdateUserGroupSimple($user, $groupName, $userIds, $groupId = null, $translator): array
3820.     {
3821.         try {
3822.             $organization = $user->getOrganization();
3824.             if (!$organization instanceof DataObject\Organization) {
3825.                 return ["success" => false, "message" => $translator->trans("user_does_not_belongs_to_organization")];
3826.             }
3828.             // Get class IDs for table names
3829.             $class = new \Pimcore\Model\DataObject\ClassDefinition();
3830.             $customerClassId = $class->getDao()->getIdByName('Customer');
3831.             $subscriptionClassId = $class->getDao()->getIdByName('Subscription');
3833.             $db = Db::get();
3835.             // Validate and filter user_ids - only include users with mobile numbers
3836.             $validUserIds = [];
3837.             if (!empty($userIds)) {
3838.                 $select = $db->createQueryBuilder();
3839.                 $select->select(['customer.oo_id AS customer_id']);
3840.                 $select->from('object_' . $customerClassId, 'customer');
3841.                 
3842.                 // Join with subscription to filter active subscriptions
3843.                 $select->innerJoin(
3844.                     'customer',
3845.                     'object_' . $subscriptionClassId,
3846.                     'subscription',
3847.                     'customer.oo_id = subscription.subscribedUser__id'
3848.                 );
3850.                 // Filter by provided user IDs
3851.                 $select->where("customer.oo_id IN (:userIds)");
3852.                 $select->setParameter('userIds', $userIds, \Doctrine\DBAL\Connection::PARAM_INT_ARRAY);
3854.                 // Apply mobile number filter (same as listC2Users)
3855.                 $select->andWhere("customer.phoneNo IS NOT NULL AND customer.phoneNo != '' AND CHAR_LENGTH(customer.phoneNo) = 9");
3856.                 
3857.                 // Customer must be published
3858.                 $select->andWhere("customer.o_published = 1");
3859.                 
3860.                 // Only active subscriptions
3861.                 $select->andWhere("subscription.isActive = 1");
3862.                 
3863.                 // Only 'custom' subscription type
3864.                 $select->andWhere("subscription.subscriptionType = " . $db->quote('custom'));
3865.                 
3866.                 // Only subscriptions with end date in future (or no expiry)
3867.                 $currentTimestamp = time();
3868.                 $select->andWhere("(subscription.endDate IS NULL OR subscription.endDate >= " . $currentTimestamp . ")");
3870.                 $results = $select->execute()->fetchAllAssociative();
3871.                 
3872.                 foreach ($results as $row) {
3873.                     $validUserIds[] = (int) $row['customer_id'];
3874.                 }
3875.             }
3877.             if (empty($validUserIds)) {
3878.                 return ["success" => false, "message" => $translator->trans("no_valid_users_with_mobile_numbers_found")];
3879.             }
3881.             // Validate group name uniqueness when creating new group
3882.             if (!$groupId) {
3883.                 // Check if group name already exists in the same organization
3884.                 $existingGroupList = new DataObject\UserGroup\Listing();
3885.                 $existingGroupList->filterByOrganization($organization);
3886.                 $existingGroupList->setLocale('en');
3887.                 
3888.                 foreach ($existingGroupList as $existingGroup) {
3889.                     if ($existingGroup instanceof DataObject\UserGroup) {
3890.                         $existingGroupNameEn = $existingGroup->getGroupName('en');
3891.                         $existingGroupNameAr = $existingGroup->getGroupName('ar');
3892.                         
3893.                         // Check if group name matches (case-insensitive)
3894.                         if (strcasecmp(trim($existingGroupNameEn), trim($groupName)) === 0 || 
3895.                             strcasecmp(trim($existingGroupNameAr), trim($groupName)) === 0) {
3896.                             return ["success" => false, "message" => $translator->trans("group_name_already_exists")];
3897.                         }
3898.                     }
3899.                 }
3900.             }
3902.             // Create or update user group
3903.             if ($groupId) {
3904.                 // Update existing group
3905.                 $userGroup = DataObject\UserGroup::getById($groupId, true);
3907.                 
3908.                 
3909.                 if (!$userGroup instanceof DataObject\UserGroup) {
3910.                     return ["success" => false, "message" => $translator->trans("user_group_is_not_available")];
3911.                 }
3913.                 // Verify organization
3914.                 if (!$userGroup->getOrganization() || $userGroup->getOrganization()->getId() != $organization->getId()) {
3915.                     return ["success" => false, "message" => $translator->trans("user_group_is_not_assigned_to_your_organization")];
3916.                 }
3918.                 // Update group name
3919.                 $userGroup->setGroupName($groupName, "en");
3920.                 $userGroup->setGroupName($groupName, "ar");
3921.             } else {
3922.                 // Create new group
3923.                 $userGroup = new DataObject\UserGroup();
3924.                 $userGroup->setParent(DataObject\Service::createFolderByPath('/UserManagement/UserGroups/' . $organization->getName()));
3925.             $userGroup->setKey(trim(strip_tags($groupName.'-'.uniqid())));
3926.             $userGroup->setGroupName($groupName, 'en');
3927.             $userGroup->setGroupName($groupName, 'ar');
3928.             $userGroup->setDetail($groupName, 'en');
3929.             $userGroup->setDetail($groupName, 'ar');
3930.             $userGroup->setOrganization($organization);
3931.             $userGroup->setPublished(true);
3932.                 // dump($userGroup);
3933.                 // die;
3934.                 // $userGroup->setGroupName($groupName, "en");
3935.                 // $userGroup->setGroupName($groupName, "ar");
3936.                 // $userGroup->setOrganization($organization);
3937.                 $userGroup->setIsActive(true);
3938.             }
3940.             $userGroup->save();
3941.             
3942.             // Reload the group to ensure it has all necessary data
3943.             $userGroup = DataObject\UserGroup::getById($userGroup->getId(), true);
3945.             // Assign users to group
3946.             foreach ($validUserIds as $userId) {
3947.                 $customer = DataObject\Customer::getById($userId, true);
3948.                 
3949.                 if ($customer instanceof DataObject\Customer) {
3950.                     // Get existing user groups for this customer
3951.                     $existingGroups = [];
3952.                     
3953.                     // Collect existing groups and their IDs
3954.                     $currentGroups = $customer->getUserGroup();
3955.                     if ($currentGroups) {
3956.                         foreach ($currentGroups as $group) {
3957.                             if ($group instanceof DataObject\UserGroup) {
3958.                                 $groupId = $group->getId();
3959.                                 // Skip if this is the same group we're adding
3960.                                 if ($groupId != $userGroup->getId()) {
3961.                                     $existingGroups[] = $group;
3962.                                 }
3963.                             }
3964.                         }
3965.                     }
3966.                     
3967.                     // Add the new/updated group
3968.                     $existingGroups[] = $userGroup;
3969.                     
3970.                     // Update customer's user groups
3971.                     $customer->setUserGroup($existingGroups);
3972.                     $customer->save();
3973.                 }
3974.             }
3976.             // Remove users from group if they're not in the valid list
3977.             // Get all users currently in this group
3978.             $allUsersInGroup = new DataObject\Customer\Listing();
3979.             $allUsersInGroup->filterByUserGroup($userGroup);
3980.             
3981.             foreach ($allUsersInGroup as $customer) {
3982.                 if (!in_array($customer->getId(), $validUserIds)) {
3983.                     // Get existing groups and remove this one
3984.                     $existingGroups = [];
3985.                     $currentGroups = $customer->getUserGroup();
3986.                     
3987.                     if ($currentGroups) {
3988.                         foreach ($currentGroups as $group) {
3989.                             if ($group instanceof DataObject\UserGroup) {
3990.                                 // Only keep groups that are NOT the one we're removing
3991.                                 if ($group->getId() != $userGroup->getId()) {
3992.                                     $existingGroups[] = $group;
3993.                                 }
3994.                             }
3995.                         }
3996.                     }
3997.                     
3998.                     $customer->setUserGroup($existingGroups);
3999.                     $customer->save();
4000.                 }
4001.             }
4003.             $action = $groupId ? "updated" : "created";
4004.             return [
4005.                 "success" => true, 
4006.                 "message" => $translator->trans("user_group_{$action}_successfully"),
4007.                 "data" => [
4008.                     "groupid" => $userGroup->getId(),
4009.                     "name" => $groupName,
4010.                     "user_ids" => $validUserIds
4011.                 ]
4012.             ];
4013.         } catch (\Exception $ex) {
4014.             throw new \Exception($ex->getMessage());
4015.         }
4016.     }
4020.     /**
4021.      * Internal user dual mode
4022.      * @param array $params
4023.      * @param Translator $translator
4024.      * @return array
4025.      */
4027.     public function internalUserDualMode($params, $translator): array
4028.     {
4029.         try {
4030.             $user = DataObject\Customer::getById($params['id'], true);
4031.             // check if user is internal user
4032.             if (!$user) {
4033.                 return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
4034.             }
4035.             // get internal organization
4036.             $organization = new DataObject\Organization\Listing();
4037.             $organization->filterByIsInternal(true);
4038.             $entity = $organization->current();
4039.             if(!$entity) {
4040.                 return ["success" => false, "message" => $translator->trans("internal_organization_does_not_exists")];
4041.             }
4043.             $package = $entity->getPackage();
4044.             if (!$package) {
4045.                 return ["success" => false, "message" => $translator->trans("package_does_not_exists")];
4046.             }
4048.             if ($params['mode'] == true) {
4049.                 $user->setDualMode(true);
4050.                 $user->save();
4051.                
4052.                 // get existing subscription
4053.                 $subscriptions = new DataObject\Subscription\Listing();
4054.                 $subscriptions->filterBySubscribedUser($user);
4055.                 $subscriptions->filterBySubscriptionType('custom');
4056.                 $subscriptions->filterBySubscribedPackage($package);
4057.                 $subscription = $subscriptions->current();
4058.                 if ($subscription) {
4059.                     $subscription->setIsNoExpiry(true);
4060.                     $subscription->setIsActive(true);
4061.                     $subscription->setSubscriptionType('custom');
4062.                     $subscription->setPublished(true);
4063.                     $subscription->setSubscribedPackage($package);
4064.                     $subscription->setSubscribedUser($user);
4065.                     $subscription->save();
4066.                 } else {
4067.                     // create new subscription
4068.                     $subscription = new DataObject\Subscription();
4069.                     $subscription->setParent(DataObject\Service::createFolderByPath('/UserManagement/Subscriptions/' . $user->getEmail()));
4070.                     $subscription->setKey(\Pimcore\Model\Element\Service::getValidKey($package->getId() . time() . rand(1000, 10000), 'object'));
4071.                     $subscription->setSubscribedPackage($package);
4072.                     $subscription->setSubscribedUser($user);
4073.                     $subscription->setSubscriptionType('custom');
4074.                     $subscription->setIsNoExpiry(true);
4075.                     $subscription->setIsActive(true);
4076.                     $subscription->setPublished(true);
4077.                     $subscription->save();
4078.                 }
4079.               
4080.             } else {
4081.                 // disable dual mode
4082.                 $user->setDualMode(false);
4083.                 $user->save();
4084.                 // get existing subscription
4085.                 $subscriptions = new DataObject\Subscription\Listing();
4086.                 $subscriptions->filterBySubscribedUser($user);
4087.                 $subscriptions->filterBySubscribedPackage($package);
4088.                 $subscriptions->filterBySubscriptionType('custom');
4090.                 $subscription = $subscriptions->current();
4091.                 // delete subscription
4092.                 if ($subscription) {
4093.                     $subscription->delete();
4094.                 }
4095.             }
4096.             return ["success" => true, "message" => $translator->trans("internal_user_dual_mode_updated_successfully")];
4097.         } catch (\Exception $ex) {
4098.             throw new \Exception($ex->getMessage());
4099.         }
4100.     }
4101. }