src/Model/UserModel.php line 4935

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;
28. use Symfony\Component\Templating\EngineInterface;
30. class UserModel
31. {
32.     public $emailService;
33.     public $userPermission;
34.     private $locationModel;
35.     private $c2Service;
36.     private $reportingPortalModel;
37.     private $ewsPortalModel;
38.     function __construct()
39.     {
40.         $this->emailService  = new EmailService();
41.         $this->userPermission  = new UserPermission();
42.         $this->locationModel = new LocationModel();
43.         $this->c2Service = new C2Service();
44.         $this->reportingPortalModel = new ReportingPortalModel();
45.         $this->ewsPortalModel = new EwsPortalModel();
46.     }
49.     public function register($request, $params, $translator): array
50.     {
51.         $result = [];
52.         try {
54.             Utility::validateEmail($params['email']);
55.             Utility::validateName($params['name']);
57.             if (!$params['organization'] instanceof \Pimcore\Model\DataObject\Organization) {
58.                 return ["success" => false, "message" => $translator->trans("invalid_organization_passed")];
59.             }
60.             if (!$params['role'] instanceof \Pimcore\Model\DataObject\UserRole) {
61.                 return ["success" => false, "message" => $translator->trans("invalid_user_role")];
62.             }
64.             $user = DataObject\Customer::getByEmail($params['email'], true);
66.             if ($user instanceof \Pimcore\Model\DataObject\Customer) {
67.                 return ["success" => false, "message" => $translator->trans("user_already_exists")];
68.             }
70.             $userGroup = DataObject\UserGroup::getById($params['groupId'], true);
72.             $registerUser = new DataObject\Customer();
73.             $registerUser->setParent(DataObject\Service::createFolderByPath('/UserManagement/Users'));
74.             $registerUser->setKey(trim(strip_tags($params['email'])));
75.             $registerUser->setName(strip_tags($params['name']));
76.             $registerUser->setEmail(trim(strip_tags($params['email'])));
77.             if ((isset($params['published'])) && ($params['published'] == false)) {
78.                 # code...
79.                 $registerUser->setToken((isset($params['token'])) ? $params['token'] : '');
80.             }
81.             $registerUser->setRole($params['role']);
82.             if ($userGroup instanceof \Pimcore\Model\DataObject\UserGroup) {
83.                 $registerUser->setUserGroup($userGroup);
84.             }
86.             // assign user permissions to user
87.             if (isset($params['permissionUserGroupIds']) && !empty($params['permissionUserGroupIds']) && is_array($params['permissionUserGroupIds'])) {
88.                 $permissionGroups = [];
89.                 foreach ($params['permissionUserGroupIds'] as $groupId) {
90.                     $permissionGroup = PermissionGroup::getById($groupId);
91.                     if ($permissionGroup) {
92.                         $permissionGroups[] = $permissionGroup;
93.                     }
94.                 }
95.                 $registerUser->setPermissionGroups($permissionGroups);
96.             }
98.             $registerUser->setOrganization($params['organization']);
99.             $registerUser->setPassword($params['password']);
100.             $registerUser->setTitle((isset($params['title'])) ? $params['title'] : '');
101.             $registerUser->setDepartment((isset($params['department'])) ? $params['department'] : '');
102.             $registerUser->setCreatedBy($params['createdBy']);
103.             // Set created-by snapshot fields for future reference even if relation is removed
104.             if (isset($params['createdBy']) && $params['createdBy'] instanceof DataObject\Customer) {
105.                 $creator = $params['createdBy'];
106.                 $registerUser->setCreatedByUserName($creator->getName());
107.                 $registerUser->setCreatedByUserEmail($creator->getEmail());
108.                 $registerUser->setCreatedByUserStatus($creator->getIsDeleted() ? 'deleted' : 'active');
109.             } else {
110.                 $registerUser->setCreatedByUserStatus('deleted');
111.             }
112.             $registerUser->setPublished((isset($params['published'])) ? $params['published'] : true);
113.             $registerUser->setIsActive(true);
114.             $registerUser->setphoneNo(isset($params['phone']) ? $params['phone'] : '');
115.             if ($params['role']->getName() == USER_ROLES['CLIENT_ADMIN'] || $params['role']->getName() == USER_ROLES['CLIENT_USER']) {
116.                 $registerUser->setTwoFactorAuth(true);
117.             }
119.             $registerUser->save();
121.             // assign default subscription based on role
122.             if ($params['role']->getName() !== USER_ROLES['NCM_IT'] && $params['role']->getName() !== USER_ROLES['NCM_OPERATOR']) {
123.                 # code...
124.                 $this->createSubscription($translator, $registerUser, $params['role'], isset($params['isNoExpiry']) ? $params['isNoExpiry'] : false);
125.             }
126.             return ["success" => true, "message" => $translator->trans("user_registered_success"), 'data' => $registerUser];
127.         } catch (\Exception $ex) {
128.             throw new \Exception($ex->getMessage());
129.         }
130.         return $result;
131.     }
133.     /**
134.      * Create Subscritpion 
135.      */
136.     public function createSubscription($translator, $user, $role, $isNoExpiry = false): array
137.     {
138.         $result = [];
139.         try {
140.             $subscriptionsArray = [];
142.             if ($role instanceof DataObject\UserRole) {
144.                 $packages = $role->getDefaultPackages();
145.                 if ($packages) {
146.                     foreach ($packages as $key => $package) {
147.                         if ($package instanceof DataObject\Package) {
148.                             if ($user instanceof DataObject\Customer) {
149.                                 $subscription = $this->setSubscription($package, $user, null, "default", true);
150.                                 if ($subscription instanceof DataObject\Subscription) {
151.                                     $subscriptionsArray[] = [
152.                                         "id" => $subscription->getId(),
153.                                         "key" => $subscription->getKey(),
154.                                     ];
155.                                 }
156.                             }
157.                         }
158.                     }
159.                     return ["success" => true, "data" => $subscriptionsArray];
160.                 }
161.             }
162.         } catch (\Exception $ex) {
163.             throw new \Exception($ex->getMessage());
164.         }
166.         return $result;
167.     }
169.     public function editUser($params, $translator): array
170.     {
172.         $updateUser = DataObject\Customer::getById($params['id'], true);
174.         if ($updateUser instanceof DataObject\Customer && !$updateUser->getIsDeleted()) {
175.             $loggedInUserRole = $params['loggedInUser']->getRole() ? $params['loggedInUser']->getRole()->getName() : null;
176.             $updateOrganization = $updateUser->getOrganization();
178.             // Update client type for NCM_IT role
179.             if (!empty($params['client_type'])) {
180.                 if ($loggedInUserRole == USER_ROLES['NCM_IT']  || $loggedInUserRole == USER_ROLES['NCM_OPERATOR'] && $updateOrganization) {
181.                     $updateOrganization->setCilent_type($params['client_type']);
182.                     $updateOrganization->setClientType($params['client_type']);
183.                     $updateOrganization->save();
184.                 } else {
185.                     return [
186.                         "success" => false,
187.                         "message" => $translator->trans("access_denied_to_update_organization_client_type")
188.                     ];
189.                 }
190.             }
192.             // Update entity status with validation
193.             if (!empty($params['entity_status'])) {
194.                 $allowedStatuses = ['paid', 'trial', 'expired'];
196.                 if (in_array($params['entity_status'], $allowedStatuses)) {
197.                     if (in_array($loggedInUserRole, [USER_ROLES['NCM_IT'], USER_ROLES['NCM_OPERATOR']]) && $updateOrganization) {
198.                         if ($params['client_type'] == "government") {
199.                             $updateOrganization->setStatus("paid");
200.                         } else {
201.                             $updateOrganization->setStatus($params['entity_status']);
202.                         }
204.                         if ($params['entity_status'] == "trial") {
205.                             if (empty($params['trialLimit'])) {
206.                                 return [
207.                                     "success" => false,
208.                                     "message" => $translator->trans("trial_limit_is_required")
209.                                 ];
210.                             }
212.                             if ($updateOrganization->getStatus() == "expired") {
213.                                 $updateOrganization->setPackageActivationDate(Carbon::now());
214.                             }
216.                             $updateOrganization->setTrialLimit($params['trialLimit']);
217.                         }
219.                         $updateOrganization->save();
220.                     }
221.                 }
222.             }
224.             // Update company name in English
225.             if (!empty($params['company_name_en'])) {
226.                 if ($loggedInUserRole == USER_ROLES['NCM_IT'] || $loggedInUserRole == USER_ROLES['NCM_OPERATOR'] && $updateOrganization) {
227.                     // Check if the name already exists for another organization
228.                     $existingOrganization = DataObject\Organization::getByName($params['company_name_en'], 'en', ['limit' => 1, 'unpublished' => true]);
229.                     if ($existingOrganization && $existingOrganization->getId() !== $updateOrganization->getId()) {
230.                         return [
231.                             "success" => false,
232.                             "message" => $translator->trans("organization_already_exists") . " : " . $params['company_name_en']
233.                         ];
234.                     }
235.                     $updateOrganization->setName($params['company_name_en'], 'en');
236.                     $updateOrganization->setKey(trim(strip_tags($params['company_name_en']))); // Update key to match new name
237.                     $updateOrganization->save();
238.                 } else {
239.                     return [
240.                         "success" => false,
241.                         "message" => $translator->trans("access_denied_to_update_organization_company_name_en")
242.                     ];
243.                 }
244.             }
246.             // Update company name in Arabic
247.             if (!empty($params['company_name_ar'])) {
248.                 if ($loggedInUserRole == USER_ROLES['NCM_IT'] || $loggedInUserRole == USER_ROLES['NCM_OPERATOR'] && $updateOrganization) {
249.                     $updateOrganization->setName($params['company_name_ar'], 'ar');
250.                     $updateOrganization->save();
251.                 } else {
252.                     return [
253.                         "success" => false,
254.                         "message" => $translator->trans("access_denied_to_update_organization_company_name_ar")
255.                     ];
256.                 }
257.             }
259.             // Update user details (name, password, phone, etc.)
260.             if (!empty($params['name'])) {
261.                 $updateUser->setName(strip_tags($params['name']));
262.             }
264.             if (!empty($params['password'])) {
265.                 $updateUser->setPassword(strip_tags($params['password']));
266.             }
268.             // update phone number
269.             if (!empty($params['phone'])) {
270.                 $phone = trim($params['phone']);
271.                 if (strlen($phone) !== 9) {
272.                     return ["success" => false, "message" => $translator->trans("phone_no_must_be_9_digits")];
273.                 } elseif (!ctype_digit($phone)) {
274.                     return ["success" => false, "message" => $translator->trans("phone_no_must_be_numeric")];
275.                 } else {
276.                     $updateUser->setPhoneNo($phone);
277.                 }
278.             } else if (empty($params['phone']) && isset($params['phone'])) {
279.                 $updateUser->setPhoneNo("");
280.             }
282.             // Set user role if provided
283.             if (!empty($params['role'])) {
284.                 $userRole = DataObject\UserRole::getByName(USER_ROLES[$params['role']], true);
285.                 if ($userRole instanceof DataObject\UserRole) {
286.                     // Prevent role update if it would leave no admin in the organization
287.                     if ($params['role'] == USER_ROLES['CLIENT_USER'] && $updateUser->getRole()->getName() == USER_ROLES['CLIENT_ADMIN']) {
288.                         $adminRole = DataObject\UserRole::getByName(USER_ROLES['CLIENT_ADMIN'], true);
289.                         $adminCount = new DataObject\Customer\Listing();
290.                         $adminCount->filterByOrganization($updateUser->getOrganization());
291.                         $adminCount->filterByRole($adminRole);
292.                         $adminCount->filterByIsActive(true);
294.                         if ($adminCount->getCount() <= 1) {
295.                             return [
296.                                 "success" => false,
297.                                 "message" => $translator->trans('atleast_one_admin_required')
298.                             ];
299.                         }
300.                     }
302.                     $updateUser->setRole($userRole);
304.                     // Update default Package according to role
305.                     $rolePackage = $userRole->getDefaultPackages();
306.                     if ($rolePackage) {
307.                         foreach ($rolePackage as $package) {
308.                             if ($package instanceof DataObject\Package) {
309.                                 $this->updateSubscription($package, $updateUser, null, "default");
310.                             }
311.                         }
312.                     }
313.                 }
314.             }
316.             // Set department and title if provided
317.             if (!empty($params['department'])) {
318.                 $updateUser->setDepartment(strip_tags($params['department']));
319.             }
321.             if (!empty($params['title'])) {
322.                 $updateUser->setTitle(strip_tags($params['title']));
323.             }
325.             // Assign location by location tag id to user
326.             if (!empty($params['location_tag_ids'])) {
327.                 $this->assignLocationToUser($params['loggedInUser'], null, $params['location_tag_ids'], [$updateUser->getId()], null, false, false, $translator);
328.             }
330.             $updateUser->save();
332.             // Add updated user to updated permissions
333.             $params['user'] = $updateUser;
335.             // Package subscription update
336.             if (!empty($params['package_id'])) {
337.                 $package = DataObject\Package::getById($params['package_id'], true);
338.                 if ($package instanceof DataObject\Package) {
339.                     $this->updateSubscription($package, $params['user'], null, "custom");
340.                 }
341.             }
343.             if (isset($params['disallowedApiGroups'])) {
344.                 $this->disallowApiGroups($params['user'], $params['disallowedApiGroups'], "custom");
345.             }
347.             // Handle location assignment for CLIENT_ADMIN or CLIENT_USER roles
348.             if (in_array($params['role'], [USER_ROLES['CLIENT_ADMIN'], USER_ROLES['CLIENT_USER']])) {
349.                 if (isset($params['location'])) {
350.                     foreach ($params['location'] as $value) {
351.                         $location = DataObject\Location::getById($value, true);
352.                         if ($location) {
353.                             $this->locationModel->locationMetaData($location, $updateUser);
354.                         }
355.                     }
356.                 }
357.             }
359.             return [
360.                 "success" => true,
361.                 "message" => $translator->trans("user_updated_successfully")
362.             ];
363.         }
365.         return [
366.             "success" => false,
367.             "message" => $translator->trans("user_does_not_exist")
368.         ];
369.     }
374.     public function editNCMUser($params, $translator): array
375.     {
376.         $result = [];
378.         // try {
380.         $updateUser = DataObject\Customer::getById($params['id'], true);
382.         if ($updateUser instanceof DataObject\Customer && $updateUser->getIsDeleted() != true) {
385.             $loggedInUserRole = $params['loggedInUser']->getRole() ? $params['loggedInUser']->getRole()->getName() : null;
388.             if (isset($params['name']) && !empty($params['name'])) {
389.                 $updateUser->setName(strip_tags($params['name']));
390.             }
392.             // Set Role if $UserRole is provided
393.             if (isset($params['role']) && !empty($params['role'])) {
394.                 $UserRole = DataObject\UserRole::getByName(USER_ROLES[$params['role']], true);
395.                 if ($UserRole instanceof DataObject\UserRole) {
396.                     $updateUser->setRole($UserRole);
399.                     // Update default Package according to role
400.                     $rolePackage = $UserRole->getDefaultPackages();
401.                     if ($rolePackage) {
402.                         foreach ($rolePackage as $key => $package) {
403.                             if ($package instanceof DataObject\Package) {
404.                                 $this->updateSubscription($package, $updateUser, null, "default");
405.                             }
406.                         }
407.                     }
408.                 }
409.             }
411.             // update password
412.             if (isset($params['password']) && !empty($params['password'])) {
413.                 $updateUser->setPassword(strip_tags($params['password']));
414.             }
416.             // updated permissions 
417.             if (isset($params['allowedApiGrpups']) && !empty($params['allowedApiGrpups'])) {
418.                 $this->updateNCMUserSubscription($updateUser, $params['allowedApiGrpups']);
419.             }
422.             // update permission user groups
423.             if (isset($params['permissionUserGroupIds']) && !empty($params['permissionUserGroupIds'])) {
424.                 // Validate and prepare permission groups
425.                 $permissionGroups = [];
426.                 foreach ($params['permissionUserGroupIds'] as $groupId) {
427.                     $permissionGroup = PermissionGroup::getById($groupId);
428.                     if ($permissionGroup) {
429.                         $permissionGroups[] = $permissionGroup;
430.                     }
431.                 }
432.                 $updateUser->setPermissionGroups($permissionGroups);
433.             }
435.             // assign user tag to user
437.             if (isset($params['tagId']) && !empty($params['tagId'])) {
438.                 $tage  = UserTag::getById($params['tagId']);
439.                 if ($tage instanceof UserTag) {
440.                     $updateUser->setTag($tage);
441.                 }
442.             }
444.             if (isset($params['phone']) && !empty($params['phone'])) {
445.                 $updateUser->setPhoneNo(strip_tags($params['phone']));
446.             }
449.             $updateUser->save();
451.             // unset($params["Authorization"]);
452.             // $params["loggedInUserEmail"] = $loggedInUserRole = $params['loggedInUser']->getEmail();
453.             // $ncmReportingUser = $this->reportingPortalModel->updateNcmUser($params);
454.             // $ewsPortalUser = $this->ewsPortalModel->updateNcmUser($params);
457.             return ["success" => true, "message" => $translator->trans("user_updated_successifully")];
458.         }
460.         return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
461.         // } catch (\Exception $ex) {
462.         //     throw new \Exception($ex->getMessage());
463.         // }
465.         return $result;
466.     }
468.     public function disallowApiGroups($user, $disallowedApiGroups, $type)
469.     {
471.         $result = [];
472.         if (!$user instanceof DataObject\Customer) {
473.             return ["success" => false, "message" => "User is not available"];
474.         }
476.         $customSubscriptions = new DataObject\Subscription\Listing();
477.         $customSubscriptions->filterBySubscribedUser($user);
478.         $customSubscriptions->filterBySubscriptionType("custom");
479.         $customSubscriptions->filterByIsActive(true);
480.         $updateSubscription = $customSubscriptions->current();
481.         if ($updateSubscription instanceof  DataObject\Subscription) {
483.             //Set Disallowed ApiGroups
484.             if ($disallowedApiGroups != null) {
485.                 $disallowedApiGroupsArr = [];
486.                 foreach ($disallowedApiGroups as $disallowedApiGroupsId) {
487.                     $apiGroup =  DataObject\APIGroup::getById($disallowedApiGroupsId, true);
488.                     $disallowedApiGroupsArr[] = $apiGroup;
489.                 }
491.                 $updateSubscription->setDisallowedApiGroups($disallowedApiGroupsArr);
492.             } else {
493.                 $updateSubscription->setDisallowedApiGroups(null);
494.             }
495.             $updateSubscription->save();
496.         }
498.         return  $updateSubscription;
499.     }
501.     public function updateUserGroupData(
502.         $loggedInUser,
503.         $locations,
504.         $locationTagIds,
505.         $userGroupId,
506.         $userIds,
507.         $request,
508.         $lang,
509.         $translator
510.     ): array {
511.         $result = [];
513.         try {
515.             $userGroup = DataObject\UserGroup::getById($userGroupId, true);
517.             if (!$userGroup instanceof DataObject\UserGroup) {
518.                 return ["success" => false, "message" => $translator->trans("user_group_is_not_available")];
519.             }
521.             if (count($userIds) > 0) {
522.                 foreach ($userIds as $key => $userId) {
523.                     $user = DataObject\Customer::getById($userId, true);
524.                     $userGroupArr[] =  $userGroup;
525.                     foreach ($user->getUserGroup() as $group) {
526.                         $userGroupArr[] = $group;
527.                     }
528.                     $userGroupArr = array_unique($userGroupArr);
529.                     if ($user instanceof DataObject\Customer) {
530.                         $user->setUserGroup($userGroupArr);
531.                         $user->save();
532.                     }
533.                 }
535.                 // Assign location by location tag id to user
536.                 if (isset($locationTagIds) && !empty($locationTagIds)) {
537.                     $assignLocationByLocationTagId = $this->assignLocationToUser($loggedInUser, $locations, $locationTagIds, $userIds, null, false, false, $translator);
538.                     if (isset($assignLocationByLocationTagId['success']) && $assignLocationByLocationTagId['success'] == false) {
539.                         return $assignLocationByLocationTagId;
540.                     }
541.                 }
543.                 return ["success" => true, "message" => $translator->trans("user_group_are_updated_successfully ")];
544.             }
547.             return ["success" => false, "message" => $translator->trans("user_group_not_available")];
548.         } catch (\Exception $ex) {
549.             throw new \Exception($ex->getMessage());
550.         }
552.         return $result;
553.     }
555.     public function createUserGroupData($user, $groupNameEn, $groupNameAr, $detailEn, $detailAr, $groupId, $request, $lang, $translator): array
556.     {
557.         $result = [];
559.         try {
561.             $organization = $user->getOrganization();
563.             if (!$organization instanceof DataObject\Organization) {
564.                 return ["success" => false, "message" => $translator->trans("user_does_not_belongs_to_organization ")];
565.             }
566.             $userGroup = new DataObject\UserGroup\Listing();
567.             $userGroup->setLocale($lang);
568.             $userGroup->setCondition("groupName = ? ", [$groupNameEn]);
569.             $userGroup->filterByOrganization($organization);
570.             $userGroup = $userGroup->current();
572.             if ($userGroup instanceof DataObject\UserGroup) {
573.                 return ["success" => false, "message" => $translator->trans("user_group_name_already_available")];
574.             }
575.             if (!empty($groupId)) {
576.                 $userGroup = DataObject\UserGroup::getById($groupId, true);
577.                 if (!$userGroup instanceof DataObject\UserGroup) {
578.                     return ["success" => false, "message" => $translator->trans("user_group_is_not_available")];
579.                 }
580.                 $userGroup->setKey(trim(strip_tags($groupNameEn)));
581.                 $userGroup->setGroupName($groupNameEn, 'en');
582.                 $userGroup->setGroupName($groupNameAr, 'ar');
583.                 $userGroup->setDetail($detailEn, 'en');
584.                 $userGroup->setDetail($detailAr, 'ar');
585.                 $userGroup->save();
586.                 if ($userGroup) {
587.                     return ["success" => true, "message" => $translator->trans("user_group_updated_successfully")];
588.                 }
589.             }
590.             $userGroup = new DataObject\UserGroup();
591.             $userGroup->setParent(DataObject\Service::createFolderByPath('/UserManagement/UserGroups/' . $organization->getName()));
592.             $userGroup->setKey(trim(strip_tags($groupNameEn)));
593.             $userGroup->setGroupName($groupNameEn, 'en');
594.             $userGroup->setGroupName($groupNameAr, 'ar');
595.             $userGroup->setDetail($detailEn, 'en');
596.             $userGroup->setDetail($detailAr, 'ar');
597.             $userGroup->setOrganization($organization);
598.             $userGroup->setPublished(true);
599.             $userGroup->save();
600.             if ($userGroup) {
601.                 return ["success" => true, "message" => $translator->trans("user_group_created_successfully"), "user_group_id" => $userGroup->getId()];
602.             }
603.         } catch (\Exception $ex) {
604.             throw new \Exception($ex->getMessage());
605.         }
607.         return $result;
608.     }
610.     public function editUserGroupData($id, $groupNameEn, $groupNameAr, $detailEn, $detailAr, $request, $lang, $translator): array
611.     {
612.         $result = [];
614.         try {
616.             $userGroup = DataObject\UserGroup::getById($id, true);
618.             if (!$userGroup instanceof DataObject\UserGroup) {
619.                 return ["success" => false, "message" => $translator->trans("user_group_is_not_available")];
620.             }
622.             if (isset($groupNameEn) && !empty($groupNameEn)) {
623.                 $userGroup->setGroupName($groupNameEn, 'en');
624.             }
625.             if (isset($groupNameAr) && !empty($groupNameAr)) {
626.                 $userGroup->setGroupName($groupNameAr, 'ar');
627.             }
628.             if (isset($detailEn) && !empty($detailEn)) {
629.                 $userGroup->setDetail($detailEn, 'en');
630.             }
631.             if (isset($detailAr) && !empty($detailAr)) {
632.                 $userGroup->setDetail($detailAr, 'ar');
633.             }
634.             $userGroup->save();
635.             if ($userGroup) {
636.                 return ["success" => true, "message" => $translator->trans("user_group_updated_successfully")];
637.             }
638.         } catch (\Exception $ex) {
639.             throw new \Exception($ex->getMessage());
640.         }
642.         return $result;
643.     }
646.     public function deleteUserGroup($user, $id, $request, $translator): array
647.     {
648.         $result = [];
650.         try {
652.             $userGroup = DataObject\UserGroup::getById($id, true);
654.             if (!$userGroup instanceof DataObject\UserGroup) {
655.                 return ["success" => false, "message" => $translator->trans("user_group_is_not_available")];
656.             }
658.             if (!$userGroup->getOrganization()) {
659.                 return ["success" => false, "message" => $translator->trans("no_organization_is_assigned_to_this_user_group")];
660.             }
662.             $loggedInUserOrganizationName = $user->getOrganization() ? $user->getOrganization()->getName() : '';
663.             if ($userGroup->getOrganization()->getName("en") != $loggedInUserOrganizationName) {
664.                 return ["success" => false, "message" => $translator->trans("user_group_is_not_assigned_to_your_organization")];
665.             }
666.             $userGroup->delete();
667.             return ["success" => true, "message" => $translator->trans("user_group_deleted_successifully")];
668.         } catch (\Exception $ex) {
669.             throw new \Exception($ex->getMessage());
670.         }
672.         return $result;
673.     }
675.     public function userGroupListing($user, $translator, $paginator, $params): array
676.     {
677.         $result = [];
679.         try {
681.             $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
682.             $page = isset($params['page']) ? $params['page'] : 1;
684.             $lang = isset($params['lang']) ? $params['lang'] : 'en';
686.             $organization = $user->getOrganization();
688.             if (!$organization instanceof DataObject\Organization) {
689.                 return ["success" => false, "message" => $translator->trans("user_does_not_belongs_to_organization ")];
690.             }
692.             // Load LocationGroup listing
693.             $userGroupList = new DataObject\UserGroup\Listing();
694.             $userGroupList->filterByOrganization($organization);
695.             $userGroupList->setLocale($lang);
697.             if (isset($params['search']) && !empty($params['search'])) {
699.                 $userGroupList->addConditionParam('(groupName LIKE ? OR detail LIKE ?)', ['%' . $params['search'] . '%', '%' . $params['search'] . '%']);
700.             }
702.             $userGroupList->setOrderKey("oo_id");
703.             $userGroupList->setOrder("desc");
706.             $paginator = $paginator->paginate(
707.                 $userGroupList,
708.                 $page,
709.                 $pageSize
710.             );
712.             if ($paginator->getTotalItemCount() > 0) {
713.                 $userGroupListData = [];
715.                 foreach ($paginator as $key => $userGroup) {
716.                     $userListData = [];
717.                     $usersList = new DataObject\Customer\Listing();
718.                     $usersList->filterByUserGroup($userGroup);
719.                     $usersList->setOrderKey("oo_id");
720.                     $usersList->setOrder("desc");
721.                     if ($usersList) {
722.                         foreach ($usersList as $user) {
723.                             $userListData[] = [
724.                                 'id' => $user->getId(),
725.                                 'name' => $user->getName(),
726.                                 'email' => $user->getEmail(),
727.                                 'role' => $user->getRole() ? $user->getRole()->getName() : '',
728.                                 'organization' => $user->getOrganization() ?  $user->getOrganization()->getName() : '',
729.                             ];
730.                         }
731.                     }
732.                     $userGroupListData[] = [
733.                         'id' => $userGroup->getId(),
734.                         'groupName_en' => $userGroup->getGroupName("en"),
735.                         'detail_en' => $userGroup->getDetail("en"),
736.                         'groupName_ar' => $userGroup->getGroupName("ar"),
737.                         'detail_ar' => $userGroup->getDetail("ar"),
738.                         'usersData' => $userListData
739.                     ];
740.                 }
742.                 if (!empty($userGroupListData) && count($userGroupListData) > 0) {
743.                     return ["success" => true, "data" => $userGroupListData, "paginationVariables" => $paginator->getPaginationData()];
744.                 }
745.             }
746.             return ["success" => false, "message" => $translator->trans("user_groups_are_not_available")];
747.         } catch (\Exception $ex) {
748.             throw new \Exception($ex->getMessage());
749.         }
751.         return $result;
752.     }
754.     public function userGroupDetail($user, $userGroupId, $translator): array
755.     {
756.         $result = [];
758.         try {
760.             $organization = $user->getOrganization();
762.             if (!$organization instanceof DataObject\Organization) {
763.                 return ["success" => false, "message" => $translator->trans("user_does_not_belongs_to_organization")];
764.             }
766.             $userGroupData = [];
767.             $userListData = [];
768.             $data = [];
769.             $totalUsers  = 0;
771.             //load user group
772.             $userGroup = new DataObject\UserGroup\Listing();
773.             $userGroup->setCondition("oo_id = ? ", [$userGroupId]);
774.             $userGroup->filterByOrganization($organization);
775.             $userGroup = $userGroup->current();
777.             if ($userGroup instanceof DataObject\UserGroup) {
779.                 //get user group data   
780.                 $userGroupData[] = [
781.                     'id' => $userGroup->getId(),
782.                     'groupName_en' => $userGroup->getGroupName("en"),
783.                     'detail_en' => $userGroup->getDetail("en"),
784.                     'groupName_ar' => $userGroup->getGroupName("ar"),
785.                     'detail_ar' => $userGroup->getDetail("ar"),
786.                 ];
788.                 //get all users available in above user group
789.                 $customers = new DataObject\Customer\Listing();
790.                 $customers->filterByOrganization($organization);
791.                 $customers->filterByUserGroup($userGroup);
792.                 $customers->filterByIsActive(true);
794.                 if ($customers->getCount() > 0) {
795.                     $totalUsers = $customers->getCount();
797.                     foreach ($customers as $key => $customer) {
799.                         if ($customer instanceof DataObject\Customer) {
801.                             //get user  data   
802.                             $userListData[] = [
803.                                 'id' => $customer->getId(),
804.                                 'name' => $customer->getName(),
805.                                 'email' => $customer->getEmail(),
806.                                 'role' => $customer->getRole() ? $customer->getRole()->getName() : null,
807.                                 'department' => $customer->getDepartment(),
808.                                 'titile' => $customer->getTitle()
809.                             ];
810.                         }
811.                     }
813.                     // store all data in data array
814.                     $data[] = [
815.                         "userGroupData" => $userGroupData,
816.                         "totalUsers" => $totalUsers,
817.                         "users" => $userListData
818.                     ];
820.                     if (!empty($data) && count($data) > 0) {
821.                         return ["success" => true, "data" => $data];
822.                     }
823.                 }
824.             }
825.             return ["success" => false, "message" => $translator->trans("user_group_is_not_available")];
826.         } catch (\Exception $ex) {
827.             throw new \Exception($ex->getMessage());
828.         }
830.         return $result;
831.     }
834.     public function updateProfile($params, $translator): array
835.     {
836.         $result = [];
838.         try {
840.             $updateUser = DataObject\Customer::getById($params['id'], true);
842.             if ($updateUser) {
843.                 try {
844.                     $updateUser->setName(strip_tags($params['name']));
845.                     $updateUser->setDepartment(strip_tags($params['department']));
846.                     $updateUser->setTitle(strip_tags($params['title']));
847.                     if (isset($params['isTwoFactorAuth'])) {
848.                         if ($params['isTwoFactorAuth'] == true) {
849.                             $updateUser->setTwoFactorAuth(true);
850.                         } else {
851.                             $updateUser->setTwoFactorAuth(false);
852.                         }
853.                     }
855.                     if (isset($params['iqamaId']) && !empty($params['iqamaId'])) {
856.                         if (\App\Lib\Utility::validateIqamaId($params['iqamaId'])) {
857.                             $updateUser->setIqamaId($params['iqamaId']);
858.                         } else {
859.                             return ["success" => false, "message" => $translator->trans("iqama_id_is_invalid")];
860.                         }
861.                     }
863.                     if (!empty($params['phoneno'])) {
864.                         $phoneNo = trim($params['phoneno']);
865.                         if (strlen($phoneNo) !== 9) {
866.                             return ["success" => false, "message" => $translator->trans("phone_no_must_be_9_digits")];
867.                         } elseif (!ctype_digit($phoneNo)) {
868.                             return ["success" => false, "message" => $translator->trans("phone_no_must_be_numeric")];
869.                         } else {
870.                             $updateUser->setPhoneNo($phoneNo);
871.                         }
872.                     }
875.                     $updateUser->save();
876.                     if (!isset($params['from_ews']) && !isset($params['from_reporting'])) {
877.                         unset($params["Authorization"]);
878.                         $params["userEmail"] = $updateUser->getEmail();
879.                         $params["from_portal"] = true;
881.                         // Inform other systems
882.                         // $this->ewsPortalModel->updateProfile($params);
883.                         // $this->reportingPortalModel->updateProfile($params);
884.                     }
886.                     return ["success" => true, "message" => $translator->trans("user_updated_successfully")];
887.                 } catch (\Exception $ex) {
888.                     return ["success" => false, "message" => $translator->trans("user_not_updated_successfully")];
889.                 }
890.             }
892.             return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
893.         } catch (\Exception $ex) {
894.             throw new \Exception($ex->getMessage());
895.         }
897.         return $result;
898.     }
900.     /**
901.      * forget user password
902.      */
903.     public function forgotPassword($request, $email, $httpOrigin, $translator, $templating)
904.     {
905.         $result = [];
906.         try {
907.             $lang = $translator->getLocale();
909.             $user = DataObject\Customer::getByEmail($email, true);
910.             if ($user instanceof \Pimcore\Model\DataObject\Customer) {
912.                 //generate token
913.                 $token = md5($user->getId() . time() . uniqid());
914.                 $user->setResetPasswordToken($token);
915.                 //$user->setPasswordRecoveryTokenDate(Carbon::now());
916.                 $user->save();
918.                 $role = ($user->getRole()) ? $user->getRole()->getName() : null;
919.                 $hostName = $httpOrigin . "/auth/reset-password?token=";
920.                 if ($role == 'CLIENT_ADMIN' || $role == 'CLIENT_USER') {
921.                     $subject = $translator->trans("Reset Password to Join NCM Business Portal");
922.                     $title = $translator->trans("Meteo KSA");
923.                 } else {
924.                     $subject = $translator->trans("Reset Password to Join NCM Admin Portal");
925.                     $title = $translator->trans("Meteo KSA Admin");
926.                 }
928.                 $param = [
929.                     'userName' => $user->getName(),
930.                     'tokenLink' => $hostName . $token,
931.                     'title' => $title,
932.                 ];
934.                 $html = $templating->render('web2print/generic_mail.html.twig', $param);
935.                 $templateId = $_ENV['RESET_PASSWORD_TEMPLATE'];
936.                 $purpose = RESET_PASSWORD_MESSAGE;
937.                 $result = $this->c2Service->sendNotificationEmail($templateId, $user->getId(), $user->getId(), $html, $subject, $purpose);
939.                 //$result = $this->emailService->sendMail($param, $user->getEmail(), PASSWORD_RECOVERY_EMAIL_DOCUMENT_PATH, $subject);
940.                 $translator->setLocale($lang);
942.                 if ($result) {
943.                     return ["success" => true, "message" => $translator->trans("account_reset_mail_sent_when_possible")];
944.                 }
945.                 return ["success" => false, "message" => $translator->trans("an_error_occured_while_sending_mail")];
946.             } else {
947.                 return ["success" => false, "message" => $translator->trans("user_not_found")];
948.             }
949.         } catch (\Exception $ex) {
950.             throw new \Exception($ex->getMessage());
951.         }
953.         return $result;
954.     }
956.     /**
957.      * Reset user password
958.      */
959.     public function resetPassword($request, $token, $newPassword, $conformNewPassword, $translator): array
960.     {
961.         $result = [];
962.         try {
964.             //check if the token is valid
967.             $user = DataObject\Customer::getByResetPasswordToken($token, true);
968.             if ($user instanceof \Pimcore\Model\DataObject\Customer) {
970.                 if ($newPassword != $conformNewPassword) {
971.                     return ["success" => false, "message" => $translator->trans("new_password_and_conformNewPassword_not_matching")];
972.                 }
974.                 $user->setPassword($newPassword);
975.                 $user->setResetPasswordToken(null);
976.                 $user->save();
978.                 if ($user) {
979.                     return ["success" => true, "message" => $translator->trans("password_updated_successifully")];
980.                 }
981.             } else {
982.                 return ["success" => false, "message" => $translator->trans("user_not_found_token_is_not_valid")];
983.             }
984.         } catch (\Exception $ex) {
985.             throw new \Exception($ex->getMessage());
986.         }
988.         return $result;
989.     }
992.     /**
993.      * Reset user password
994.      */
995.     public function changePassword($user, $params, $translator): array
996.     {
997.         $result = [];
998.         try {
999.             if ($params['newPassword'] != $params['confirmNewPassword']) {
1000.                 return ["success" => false, "message" => $translator->trans("new_password_and_conformNewPassword_not_matching")];
1001.             }
1002.             if ($user) {
1003.                 if (password_verify(trim($params['oldPassword']), $user->getPassword())) {
1004.                     $user->setPassword($params['newPassword']);
1005.                     $user->save();
1007.                     if (!isset($params['from_ews']) && !isset($params['from_reporting'])) {
1008.                         unset($params["Authorization"]);
1009.                         $params["userEmail"] = $user->getEmail();
1010.                         $params["from_portal"] = true;
1012.                         // Inform other systems
1013.                         // $this->ewsPortalModel->changePassword($params);
1014.                         // $this->reportingPortalModel->changePassword($params);
1015.                     }
1018.                     return ["success" => true, "message" => $translator->trans("password_updated_successifully")];
1019.                 } else {
1020.                     return ["success" => false, "message" => $translator->trans("old_password_is_not_correct")];
1021.                 }
1022.             }
1023.             return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
1024.         } catch (\Exception $ex) {
1025.             throw new \Exception($ex->getMessage());
1026.         }
1028.         return $result;
1029.     }
1031.     /**
1032.      * Get Public User Premissions
1033.      */
1034.     public function publicUserPermissions($translator): array
1035.     {
1036.         $result = [];
1037.         try {
1039.             $db = Db::get();
1040.             $permissions = $db->fetchAll("SELECT * FROM `policy`");
1042.             return ["success" => true, "data" => $permissions];
1043.         } catch (\Exception $ex) {
1044.             throw new \Exception($ex->getMessage());
1045.         }
1047.         return $result;
1048.     }
1050.     /**
1051.      * Create Public User
1052.      */
1053.     public function addPublicUser($request, $params, $translator): array
1054.     {
1055.         $result = [];
1056.         try {
1057.             $user = DataObject\PublicUser::getByName($params['name'], true);
1058.             if ($user instanceof DataObject\PublicUser) {
1059.                 return ["success" => false, "message" => $translator->trans("This public user already exists.")];
1060.             }
1062.             $addPublicUser = new DataObject\PublicUser();
1063.             $addPublicUser->setParent(DataObject\Service::createFolderByPath('/UserManagement/PublicUsers/'));
1064.             $addPublicUser->setKey($params['name']);
1065.             $addPublicUser->setName($params['name']);
1066.             $addPublicUser->setStartDate(Carbon::parse($params['startDate']));
1067.             $addPublicUser->setEndDate(Carbon::parse($params['endDate']));
1068.             $addPublicUser->setPublished(true);
1069.             $addPublicUser->save();
1071.             if (!$addPublicUser->getId()) {
1072.                 throw new \Exception("Failed to create public user.");
1073.             }
1075.             $db = Db::get();
1076.             foreach ($params['permissions'] as $parameter) {
1077.                 $permission = $db->fetchOne("SELECT id FROM policy WHERE parameter = ?", $parameter);
1078.                 if ($permission) {
1079.                     $data = array(
1080.                         'user_id' => $addPublicUser->getId(),
1081.                         'policy_id' => $permission,
1082.                         'is_allowed' => 1
1083.                     );
1085.                     $insertResult = $db->insert("user_policy", $data);
1087.                     if (!$insertResult) {
1088.                         throw new \Exception($translator->trans("Failed to associate permissions with the public user."));
1089.                     }
1090.                 } else {
1091.                     throw new \Exception($translator->trans("Permission not found for parameter: " . $parameter));
1092.                 }
1093.             }
1095.             return ["success" => true, "message" => $translator->trans("Public user created successfully.")];
1096.         } catch (\Exception $ex) {
1097.             return ["success" => false, "message" => $ex->getMessage()];
1098.         }
1100.         return $result;
1101.     }
1103.     // public function deleteUser($request, $params, $translator): array
1104.     // {
1105.     //     $result = [];
1106.     //     // try {
1107.     //     $user = DataObject\Customer::getById($params['id'], true);
1108.     //     if ($user) {
1110.     //         // Deleting user location              
1111.     //         $locations = $this->locationModel->getLocationsByUserId($user->getId());
1112.     //         if ($locations) {
1113.     //             foreach ($locations as $location) {
1114.     //                 if ($location instanceof \Pimcore\Model\DataObject\Location) {
1115.     //                     $this->locationModel->deAssociateUserLocation($location, $user, $translator);
1116.     //                 }
1117.     //             }
1118.     //         }
1120.     //         // Deleting user custom notification
1121.     //         $customNotification = new \Pimcore\Model\DataObject\CustomNotification\Listing();
1122.     //         $customNotification->filterByUser($user);
1123.     //         foreach ($customNotification as $notification) {
1124.     //             $notification->delete();
1125.     //         }
1127.     //         $user->delete();
1129.     //         return ["success" => true, "message" => $translator->trans("user_deleted_successifully")];
1130.     //     }
1131.     //     return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
1132.     //     // } catch (\Exception $ex) {
1133.     //     //     throw new \Exception($ex->getMessage());
1134.     //     // }
1135.     //     return $result;
1136.     // }
1138.     public function deleteUser($request, $params, $loggedInUser, $translator, $templating=null): array
1139.     {
1140.         $result = [];
1142.         // Check if the user is already deleted
1143.         $deletedUsers = new DataObject\DeletedUsersData\Listing();
1144.         $deletedUsers->filterByPimId($params['id']);
1145.         $deletedUsers->filterByIsDeleted(true);
1146.         $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.         
1154.         if (!$user) {
1155.             return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
1156.         }
1158.         // Check if user is already deleted (in archive)
1159.         if ($user->getIsArchive()) {
1160.             return ["success" => false, "message" => $translator->trans("user_already_archived")];
1161.         }
1162.         
1163.         // Check if the delete request comes from a super admin
1164.         $isSuperAdmin = $loggedInUser->getIsSuperAdmin();
1165.         
1166.         if ($isSuperAdmin) {
1167.             // If super admin, directly archive the user
1168.             $user->setIsArchive(true);
1169.             $user->setIsDeleted(false);
1170.             $user->save();
1171.             
1172.             // Update created-by references: mark status as deleted and clear relation
1173.             $createdUsers = new DataObject\Customer\Listing();
1174.             $createdUsers->filterByCreatedBy($user);
1175.             foreach ($createdUsers as $createdUser) {
1176.                 if ($createdUser instanceof DataObject\Customer) {
1177.                     $createdUser->setCreatedBy(null);
1178.                     $createdUser->setCreatedByUserStatus('deleted');
1179.                     $createdUser->save();
1180.                 }
1181.             }
1182.             
1183.             // Create a deleted user record with reason "deleted by super admin"
1184.             $deleteUserRecord = new DataObject\DeletedUsersData();
1185.             $deleteUserRecord->setParent(DataObject\Service::createFolderByPath('/UserManagement/DeletedUsers/'));
1186.             $deleteUserRecord->setKey($user->getName() . strtotime("now") . rand(0, 100));
1187.             $deleteUserRecord->setName($user->getName());
1188.             $deleteUserRecord->setEmail($user->getEmail());
1189.             $deleteUserRecord->setPimId($user->getId());
1190.             $deleteUserRecord->setOrganizationName($user->getOrganization() ? $user->getOrganization()->getName() : '');
1191.             $deleteUserRecord->setRole($user->getRole() ? $user->getRole()->getName() : '');
1192.             $deleteUserRecord->setIsDeleted(true); // true = deleted by super admin
1193.             $deleteUserRecord->setDeletedBy($loggedInUser->getEmail());
1194.             $deleteUserRecord->setReason('deleted by super admin');
1195.             $deleteUserRecord->setPublished(true);
1196.             $deleteUserRecord->save();
1197.             
1198.             return ["success" => true, "message" => $translator->trans("user_deleted_by_super_admin")];
1199.         }
1200.         
1201.         // Mark user for deletion (soft delete - request for approval)
1202.         $user->setIsDeleted(true);
1203.         $user->save();
1205.         // Update created-by references: mark status as deleted and clear relation
1206.         $createdUsers = new DataObject\Customer\Listing();
1207.         $createdUsers->filterByCreatedBy($user);
1208.         foreach ($createdUsers as $createdUser) {
1209.             if ($createdUser instanceof DataObject\Customer) {
1210.                 $createdUser->setCreatedBy(null);
1211.                 $createdUser->setCreatedByUserStatus('deleted');
1212.                 $createdUser->save();
1213.             }
1214.         }
1216.         // Create a deleted user record
1217.         $deleteUserRecord = new DataObject\DeletedUsersData();
1218.         $deleteUserRecord->setParent(DataObject\Service::createFolderByPath('/UserManagement/DeletedUsers/'));
1219.         $deleteUserRecord->setKey($user->getName() . strtotime("now") . rand(0, 100));
1220.         $deleteUserRecord->setName($user->getName());
1221.         $deleteUserRecord->setEmail($user->getEmail());
1222.         $deleteUserRecord->setPimId($user->getId());
1223.         $deleteUserRecord->setOrganizationName($user->getOrganization() ? $user->getOrganization()->getName() : '');
1224.         $deleteUserRecord->setRole($user->getRole() ? $user->getRole()->getName() : '');
1225.         $deleteUserRecord->setIsDeleted(false); // false = pending approval
1226.         $deleteUserRecord->setDeletedBy($loggedInUser->getEmail());
1227.         $deleteUserRecord->setReason(isset($params['reason']) ? trim($params['reason']) : '');
1228.         $deleteUserRecord->setPublished(true);
1229.         $deleteUserRecord->save();
1230.         if($templating != null){
1231.             
1232.             // Send email notification to super admin users
1233.             $this->notifySuperAdminsForDeletion($user, $loggedInUser, $params['reason'],$translator,  $templating);
1234.         }
1235.         
1236.         return ["success" => true, "message" => $translator->trans("user_deletion_request_sent_for_approval")];
1237.     }
1238.     public function deleteNcmUser($request, $params, $loggedInUser, $translator, $templating = null): array
1239.     {
1240.         $result = [];
1241.         try {
1242.             $deletedUsers = new DataObject\DeletedUsersData\Listing();
1243.             $deletedUsers->filterByPimId($params['id']);
1244.             $deletedUsers->filterByIsDeleted(false);
1245.             $check = $deletedUsers->current();
1246.             if ($check instanceof DataObject\DeletedUsersData) {
1247.                 return ["success" => false, "message" => $translator->trans("user_already_deleted")];
1248.             }
1249.             // Fetch the user by ID
1250.             $user = DataObject\Customer::getById($params['id'], true);
1251.             if (!$user) {
1252.                 return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
1253.             }
1254.             $user->setToken(null);
1255.             $user->setIsDeleted(true);
1256.             $user->setPublished(false);
1257.             $user->save();
1258.             $createdUsers = new DataObject\Customer\Listing();
1259.             $createdUsers->filterByCreatedBy($user);
1260.             foreach ($createdUsers as $createdUser) {
1261.                 if ($createdUser instanceof DataObject\Customer) {
1262.                     $createdUser->setCreatedBy(null);
1263.                     $createdUser->setCreatedByUserStatus('deleted');
1264.                     $createdUser->save();
1265.                 }
1266.             }
1267.             $deleteUserRecord = new DataObject\DeletedUsersData();
1268.             $deleteUserRecord->setParent(DataObject\Service::createFolderByPath('/UserManagement/DeletedUsers/'));
1269.             $deleteUserRecord->setKey($user->getName() . strtotime("now") . rand(0, 100));
1270.             $deleteUserRecord->setName($user->getName());
1271.             $deleteUserRecord->setEmail($user->getEmail());
1272.             $deleteUserRecord->setPimId($user->getId());
1273.             $deleteUserRecord->setOrganizationName($user->getOrganization() ? $user->getOrganization()->getName() : '');
1274.             $deleteUserRecord->setRole($user->getRole() ? $user->getRole()->getName() : '');
1275.             $deleteUserRecord->setIsDeleted(false);
1276.             $deleteUserRecord->setDeletedBy($loggedInUser->getEmail());
1277.             $deleteUserRecord->setPublished(true);
1278.             $deleteUserRecord->save();
1279.             $locations = $this->locationModel->getLocationsByUserId($user->getId());
1280.             if ($locations) {
1281.                 foreach ($locations as $location) {
1282.                     if ($location instanceof \Pimcore\Model\DataObject\Location) {
1283.                         $this->locationModel->deAssociateUserLocation($location, $user, $translator);
1284.                     }
1285.                 }
1286.             }
1287.             // Delete user custom notifications
1288.             $customNotification = new \Pimcore\Model\DataObject\CustomNotification\Listing();
1289.             $customNotification->filterByUser($user);
1290.             foreach ($customNotification as $notification) {
1291.                 $notification->delete();
1292.             }
1293.             $dashboard = new DataObject\Dashboard\Listing();
1294.             $dashboard->setCondition('user__id = ?', [$user->getId()]);
1295.             if ($dashboard->current() instanceof DataObject\Dashboard) {
1296.                 $dashboard->current()->delete();
1297.             }
1298.             $subscriptions = new DataObject\Subscription\Listing();
1299.             $subscriptions->setCondition('subscribedUser__id = ?', [$user->getId()]);
1300.             foreach ($subscriptions as $subscription) {
1301.                 if ($subscription instanceof DataObject\Subscription) {
1302.                     $subscription->delete();
1303.                 }
1304.             }
1305.             $user->delete();
1306.             $deleteUserRecord->setIsDeleted(true);
1307.             $deleteUserRecord->save();
1308.             return ["success" => true, "message" => $translator->trans("user_deleted_successfully")];
1309.         }
1310.         catch (\Exception $ex) {
1311.             throw new \Exception($ex->getMessage());
1312.         }
1313.         return $result;
1314.     }
1316.     /**
1317.      * Un-archive user
1318.      */
1319.     public function unArchiveUser($request, $userId, $loggedInUser, $translator, $templating = null): array
1320.     {
1321.         $result = [];
1322.         
1323.         // Fetch the user by ID
1324.         $user = DataObject\Customer::getById($userId, true);  
1325.         if (!$user) {
1326.             return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
1327.         }
1328.         
1329.         // Check if user is already un-archived
1330.         if (!$user->getIsArchive()) {
1331.             return ["success" => false, "message" => $translator->trans("user_already_un_archived")];
1332.         }
1333.         $deletedUsers = new DataObject\DeletedUsersData\Listing();
1334.         $deletedUsers->filterByPimId($userId);
1335.         $deletedUsers->filterByIsDeleted(true);
1336.         $deleteUserRecord = $deletedUsers->current();
1338.         if (!$deleteUserRecord instanceof DataObject\DeletedUsersData) {
1339.             return ["success" => false, "message" => $translator->trans("no_pending_deletion_request")];
1340.         }
1341.         
1342.         // set archive to false (move to active)
1343.         $user->setIsArchive(false);
1344.         $user->setIsDeleted(false);
1345.         $user->save();
1347.         $deleteUserRecord = new DataObject\DeletedUsersData();
1348.         $deleteUserRecord->setParent(DataObject\Service::createFolderByPath('/UserManagement/DeletedUsers/'));
1349.         $deleteUserRecord->setKey($user->getName() . strtotime("now") . rand(0, 100));
1350.         $deleteUserRecord->setName($user->getName());
1351.         $deleteUserRecord->setEmail($user->getEmail());
1352.         $deleteUserRecord->setPimId($user->getId());
1353.         $deleteUserRecord->setOrganizationName($user->getOrganization() ? $user->getOrganization()->getName() : '');
1354.         $deleteUserRecord->setRole($user->getRole() ? $user->getRole()->getName() : '');
1355.         $deleteUserRecord->setIsDeleted(false); // false = un-deleted
1356.         $deleteUserRecord->setDeletedBy($loggedInUser->getEmail());
1357.         $deleteUserRecord->setPublished(true);
1358.         $deleteUserRecord->setReason('un-archive by super admin');
1359.         $deleteUserRecord->save();
1360.         
1361.         // Delete all existing DeletedUsersData records for this un-archived user (excluding the newly created un-archive record)
1362.         $existingDeletedUsers = new DataObject\DeletedUsersData\Listing();
1363.         $existingDeletedUsers->filterByPimId($user->getId());
1364.         foreach ($existingDeletedUsers as $existingRecord) {
1365.             if ($existingRecord instanceof DataObject\DeletedUsersData && $existingRecord->getId() !== $deleteUserRecord->getId()) {
1366.                 $existingRecord->delete();
1367.             }
1368.         }
1369.         
1370.         // Send email notification to the user
1371.         if ($templating != null) {
1372.             $this->notifyUserForUnArchive($user, $loggedInUser, $translator, $templating);
1373.         }
1374.         
1375.         return ["success" => true, "message" => $translator->trans("user_un_archive_successfully")];
1376.     }
1377.     /**
1378.      * Approve user deletion - finalize the deletion process
1379.      */
1380.     public function approveUserDeletion($request, $params, $loggedInUser, $translator, $templating = null): array
1381.     {
1382.         $result = [];
1384.         // Normalize ID - handle if it comes as an array
1385.         $userId = is_array($params['id']) ? (isset($params['id'][0]) ? $params['id'][0] : null) : $params['id'];
1386.         
1387.         if (empty($userId)) {
1388.             return ["success" => false, "message" => $translator->trans("missing_required_parameter_user_id")];
1389.         }
1391.         // Check if there's a pending deletion request
1392.         $deletedUsers = new DataObject\DeletedUsersData\Listing();
1393.         $deletedUsers->filterByPimId($userId);
1394.         $deletedUsers->filterByIsDeleted(false);
1395.         $deleteUserRecord = $deletedUsers->current();
1397.         if (!$deleteUserRecord instanceof DataObject\DeletedUsersData) {
1398.             return ["success" => false, "message" => $translator->trans("no_pending_deletion_request")];
1399.         }
1401.         // Fetch the user by ID
1402.         $user = DataObject\Customer::getById($userId, true);
1403.         if (!$user) {
1404.             return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
1405.         }
1407.         // set archive to true (move to archive)
1408.        
1409.         $user->setIsArchive(true);
1410.         $user->save();
1411.         $deleteUserRecord = new DataObject\DeletedUsersData();
1412.         $deleteUserRecord->setParent(DataObject\Service::createFolderByPath('/UserManagement/DeletedUsers/'));
1413.         $deleteUserRecord->setKey($user->getName() . strtotime("now") . rand(0, 100));
1414.         $deleteUserRecord->setName($user->getName());
1415.         $deleteUserRecord->setEmail($user->getEmail());
1416.         $deleteUserRecord->setPimId($user->getId());
1417.         $deleteUserRecord->setOrganizationName($user->getOrganization() ? $user->getOrganization()->getName() : '');
1418.         $deleteUserRecord->setRole($user->getRole() ? $user->getRole()->getName() : '');
1419.         $deleteUserRecord->setIsDeleted(true); // true = deleted approved by super admin
1420.         $deleteUserRecord->setDeletedBy($loggedInUser->getEmail());
1421.         $deleteUserRecord->setReason(isset($params['reason']) ? trim($params['reason']) : '');
1422.         $deleteUserRecord->setPublished(true);
1423.         $deleteUserRecord->save();
1424.         
1425.         // Send email notification to the user
1426.         if ($templating != null) {
1427.             $this->notifyUserForArchive($user, $loggedInUser, $translator, $templating);
1428.         }
1429.         
1430.         return ["success" => true, "message" => $translator->trans("user_deletion_approved_and_moved_to_archive")];
1431.     }
1433.     /**
1434.      * Reject user deletion - undo the deletion request
1435.      */
1436.     public function rejectUserDeletion($request, $params, $loggedInUser, $translator): array
1437.     {
1438.         $result = [];
1440.         // Normalize ID - handle if it comes as an array
1441.         $userId = is_array($params['id']) ? (isset($params['id'][0]) ? $params['id'][0] : null) : $params['id'];
1442.         
1443.         if (empty($userId)) {
1444.             return ["success" => false, "message" => $translator->trans("missing_required_parameter_user_id")];
1445.         }
1447.         // Check if there's a pending deletion request
1448.         $deletedUsers = new DataObject\DeletedUsersData\Listing();
1449.         $deletedUsers->filterByPimId($userId);
1450.         $deletedUsers->filterByIsDeleted(false);
1451.         $deleteUserRecord = $deletedUsers->current();
1453.         if (!$deleteUserRecord instanceof DataObject\DeletedUsersData) {
1454.             return ["success" => false, "message" => $translator->trans("no_pending_deletion_request")];
1455.         }
1457.         // Fetch the user by ID
1458.         $user = DataObject\Customer::getById($userId, true);
1459.         if (!$user) {
1460.             return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
1461.         }
1463.         // Reject deletion: set isDeleted to false to undo the deletion request
1464.         $user->setIsDeleted(false);
1465.         $user->save();
1467.         // Delete the pending deletion request record
1468.         $deleteUserRecord->delete();
1470.         return ["success" => true, "message" => $translator->trans("user_deletion_rejected")];
1471.     }
1473.     
1475.     
1476.    
1478.     /**
1479.      * Get all super admin users (NCM_IT role and users with IsSuperAdmin checkbox)
1480.      */
1481.     private function getSuperAdminUsers(): array
1482.     {
1483.         $superAdmins = [];
1484.         
1485.         // Get users with IsSuperAdmin checkbox checked
1486.         $isSuperAdminUsers = new DataObject\Customer\Listing();
1487.         $isSuperAdminUsers->filterByIsSuperAdmin(1);
1488.         $isSuperAdminUsers->setUnpublished(true);
1489.         foreach ($isSuperAdminUsers as $admin) {
1490.             if ($admin instanceof DataObject\Customer && !$admin->getIsDeleted()) {
1491.                 $superAdmins[] = [
1492.                     'email' => $admin->getEmail(),
1493.                     'name' => $admin->getName()
1494.                 ];
1495.             }
1496.         }
1498.         // Remove duplicates based on email
1499.         $uniqueAdmins = [];
1500.         $emails = [];
1501.         foreach ($superAdmins as $admin) {
1502.             if (!in_array($admin['email'], $emails)) {
1503.                 $emails[] = $admin['email'];
1504.                 $uniqueAdmins[] = $admin;
1505.             }
1506.         }
1508.         return $uniqueAdmins;
1509.     }
1511.     /**
1512.      * Send email notification to super admin users about user deletion request
1513.      */
1514.     private function notifySuperAdminsForDeletion($user, $loggedInUser, $reason, $translator, $templating): void
1515.     {
1516.        
1517.         try {
1518.             $superAdmins = $this->getSuperAdminUsers();
1519.             if (empty($superAdmins)) {
1520.                 return; // No super admins to notify
1521.             }
1523.             // Prepare email parameters
1524.             $emailParams = [
1525.                 'adminName' => $loggedInUser->getName(),
1526.                 'userName' => $user->getName(),
1527.                 'userEmail' => $user->getEmail(),
1528.                 'userRole' => $user->getRole() ? $user->getRole()->getName() : '',
1529.                 'organizationName' => $user->getOrganization() ? $user->getOrganization()->getName() : '',
1530.                 'deletedBy' => $loggedInUser->getName() . ' (' . $loggedInUser->getEmail() . ')',
1531.                 'userId' => $user->getId(),
1532.                 'reason'=>$reason,
1533.                 'host'=>API_BASE_URL,
1534.             ];
1536.             $subject = $translator->trans("user_deletion_request_notification_subject", [], null, $translator->getLocale());
1537.             if (empty($subject) || $subject === "user_deletion_request_notification_subject") {
1538.                 $subject = "طلب حذف مستخدم - User Deletion Request";
1539.             }
1541.             // Send email to each super admin
1542.             foreach ($superAdmins as $admin) {
1543.                 error_log("Sending deletion notification email to " . $admin['email']);
1544.                 try {
1545.                     
1546.                     // Generate HTML content from email parameters
1547.                     $html = $templating->render('email/user_deletion_request_template.html.twig', $emailParams);
1548.                     $templateId = 32;
1549.                     $objectId = $user->getId();
1550.                     $purpose = "user deletion request notification";
1551.                     $this->c2Service->sendDefaultEmail($templateId, $objectId, $admin['email'], $html, $subject, $purpose);
1552.                 } catch (\Exception $ex) {
1553.                     // Log error but continue with other admins
1554.                     error_log("Failed to send deletion notification email to " . $admin['email'] . ": " . $ex->getMessage());
1555.                 }
1556.             }
1557.         } catch (\Exception $ex) {
1558.             // Log error but don't fail the deletion request
1559.             error_log("Error in notifySuperAdminsForDeletion: " . $ex->getMessage());
1560.         }
1561.     }
1563.     /**
1564.      * Send email notification to user about un-archive
1565.      */
1566.     private function notifyUserForUnArchive($user, $loggedInUser, $translator, $templating): void
1567.     {
1568.         try {
1569.             // Check if user has email
1570.             if (empty($user->getEmail())) {
1571.                 error_log("User " . $user->getId() . " does not have an email address");
1572.                 return;
1573.             }
1575.             // Prepare email parameters
1576.             $emailParams = [
1577.                 'adminName' => $loggedInUser->getName(),
1578.                 'userName' => $user->getName(),
1579.                 'userEmail' => $user->getEmail(),
1580.                 'userRole' => $translator->trans( $user->getRole() ? $user->getRole()->getName() : ''),
1581.                 'organizationName' => $user->getOrganization() ? $user->getOrganization()->getName() : '',
1582.                 'unArchivedBy' => $loggedInUser->getName() . ' (' . $loggedInUser->getEmail() . ')',
1583.                 'userId' => $user->getId(),
1584.                 'host' => API_BASE_URL,
1585.             ];
1587.             $subject = $translator->trans("user_un_archive_notification_subject", [], null, $translator->getLocale());
1588.             if (empty($subject) || $subject === "user_un_archive_notification_subject") {
1589.                 $subject = "إعادة تفعيل المستخدم - User Un-Archive Notification";
1590.             }
1592.             error_log("Sending un-archive notification email to " . $user->getEmail());
1593.             try {
1594.                 // Generate HTML content from email parameters
1595.                 $html = $templating->render('email/user_un_archive_template.html.twig', $emailParams);
1596.                 $templateId = 32;
1597.                 $objectId = $user->getId();
1598.                 $purpose = "user un-archive notification";
1599.                 $this->c2Service->sendDefaultEmail($templateId, $objectId, $user->getEmail(), $html, $subject, $purpose);
1600.             } catch (\Exception $ex) {
1601.                 // Log error but don't fail the un-archive process
1602.                 error_log("Failed to send un-archive notification email to " . $user->getEmail() . ": " . $ex->getMessage());
1603.             }
1604.         } catch (\Exception $ex) {
1605.             // Log error but don't fail the un-archive process
1606.             error_log("Error in notifyUserForUnArchive: " . $ex->getMessage());
1607.         }
1608.     }
1610.     /**
1611.      * Send email notification to user about archive
1612.      */
1613.     private function notifyUserForArchive($user, $loggedInUser, $translator, $templating): void
1614.     {
1615.         try {
1616.             // Check if user has email
1617.             if (empty($user->getEmail())) {
1618.                 error_log("User " . $user->getId() . " does not have an email address");
1619.                 return;
1620.             }
1622.             // Prepare email parameters
1623.             $emailParams = [
1624.                 'adminName' => $loggedInUser->getName(),
1625.                 'userName' => $user->getName(),
1626.                 'userEmail' => $user->getEmail(),
1627.                 'userRole' => $translator->trans( $user->getRole() ? $user->getRole()->getName() : ''),
1628.                 'organizationName' => $user->getOrganization() ? $user->getOrganization()->getName() : '',
1629.                 'archivedBy' => $loggedInUser->getName() . ' (' . $loggedInUser->getEmail() . ')',
1630.                 'userId' => $user->getId(),
1631.                 'host' => API_BASE_URL,
1632.             ];
1634.             $subject = $translator->trans("user_archive_notification_subject", [], null, $translator->getLocale());
1635.             if (empty($subject) || $subject === "user_archive_notification_subject") {
1636.                 $subject = "أرشفة المستخدم - User Archive Notification";
1637.             }
1639.             error_log("Sending archive notification email to " . $user->getEmail());
1640.             try {
1641.                 // Generate HTML content from email parameters
1642.                 $html = $templating->render('email/user_archive_template.html.twig', $emailParams);
1643.                 $templateId = 32;
1644.                 $objectId = $user->getId();
1645.                 $purpose = "user archive notification";
1646.                 $this->c2Service->sendDefaultEmail($templateId, $objectId, $user->getEmail(), $html, $subject, $purpose);
1647.             } catch (\Exception $ex) {
1648.                 // Log error but don't fail the archive process
1649.                 error_log("Failed to send archive notification email to " . $user->getEmail() . ": " . $ex->getMessage());
1650.             }
1651.         } catch (\Exception $ex) {
1652.             // Log error but don't fail the archive process
1653.             error_log("Error in notifyUserForArchive: " . $ex->getMessage());
1654.         }
1655.     }
1658.     /**
1659.      * Get Client User Organization List
1660.      */
1661.     public function getClientUsers($request, $user, $params, $paginator, $translator)
1662.     {
1664.         $result = [];
1665.         $userData = [];
1666.         // try {
1669.         // Get All the Classes
1670.         $class = new \Pimcore\Model\DataObject\ClassDefinition();
1671.         $customer = $class->getDao()->getIdByName('Customer');
1672.         $subscription = $class->getDao()->getIdByName('Subscription');
1673.         $userRole = $class->getDao()->getIdByName('UserRole');
1674.         $organization = $class->getDao()->getIdByName('Organization');
1675.         $package = $class->getDao()->getIdByName('Package');
1677.         $db = Db::get();
1678.         $select = $db->createQueryBuilder();
1681.         $select->select('customer.oo_id');
1682.         $select->from('object_' . $customer, 'customer');
1683.         // $select->andWhere("customer.isArchive = 0");
1684.         // Use LEFT JOIN for subscriptions to handle suspended users (users without subscriptions)
1685.         $select->leftJoin('customer', 'object_' . $subscription, 'subscription', 'customer.oo_id = subscription.subscribedUser__id');
1686.         $select->leftJoin('subscription', 'object_' . $package, 'package', 'package.oo_id = subscription.subscribedPackage__id');
1687.         $select->innerJoin('customer', 'object_' . $organization, 'organization', 'organization.oo_id = customer.organization__id');
1688.         $select->innerJoin('customer', 'object_' . $userRole, 'userRole', 'userRole.oo_id = customer.role__id');
1690.         // Use placeholders to prevent SQL injection
1691.         if (isset($params['clientType']) && !empty($params['clientType'])) {
1692.             $select->Where("organization.clientType = " . $db->quote($params['clientType']));
1693.         }
1694.         if (isset($params['organization_id']) && !empty($params['organization_id'])) {
1695.             $select->andWhere("organization.oo_id = " . $db->quote($params['organization_id']));
1696.         }
1698.         if (isset($params['package_id']) && !empty($params['package_id'])) {
1699.             $select->andWhere("package.oo_id = " . $db->quote($params['package_id']));
1700.         }
1702.         if (isset($params['search']) && !empty($params['search'])) {
1703.             $select->andWhere("customer.name LIKE " . $db->quote("%" . $params['search'] . "%") . " OR customer.email LIKE " . $db->quote("%" . $params['search'] . "%"));
1704.         }
1706.         // Filter for archived users: archive =  , isDeleted and all
1707.         if (isset($params['type']) ) {
1708.             switch ($params['type']) {
1709.                 case 'archive':
1710.                     $select->andWhere("customer.isArchive = 1");
1711.                     break;
1712.                 case 'delete_pending':
1713.                     $select->andWhere("(customer.isDeleted = 1 AND (customer.isArchive = 0 OR customer.isArchive IS NULL))");
1715.                     break;
1716.                 case 'all':
1717.                     $select->andWhere("customer.isArchive = 0 OR customer.isArchive is NULL" );
1718.                     break;
1719.             }
1720.         }
1721.         if (isset($params['userStatus']) && !empty($params['userStatus'])) {
1722.             $filterStatus = strtolower(trim($params['userStatus']));
1724.             // Validate that the filter status is one of the allowed values
1725.             $allowedStatuses = ['pending', 'active', 'suspended', 'activepending'];
1726.             if (in_array($filterStatus, $allowedStatuses)) {
1727.                 switch ($filterStatus) {
1728.                     case 'pending':
1729.                         // Pending: user is unpublished, no custom subscription, has default subscription
1730.                         $select->andWhere("customer.o_published = 0");
1731.                         $select->andWhere("subscription.subscriptionType != 'custom'");
1732.                         $select->andWhere("subscription.subscribedUser__id IS NOT NULL");
1733.                         $select->andWhere("subscription.isWso IS NULL OR subscription.isWso = 0");
1734.                         $select->andWhere("userRole.name IN ('CLIENT_USER', 'CLIENT_ADMIN')");
1735.                         break;
1737.                     case 'active':
1738.                         // Active: user is published, has custom subscription, isActive = true
1739.                         $select->andWhere("customer.o_published = 1");
1740.                         $select->andWhere("subscription.subscriptionType = 'custom'");
1741.                         $select->andWhere("subscription.subscribedUser__id IS NOT NULL");
1742.                         $select->andWhere("subscription.isActive = 1");
1743.                         $select->andWhere("subscription.isWso IS NULL OR subscription.isWso = 0");
1744.                         $select->andWhere("userRole.name IN ('CLIENT_USER', 'CLIENT_ADMIN')");
1745.                         break;
1747.                     case 'suspended':
1748.                         // Suspended: user is published, has custom subscription, isActive = false
1749.                         $select->andWhere("customer.o_published = 1");
1750.                         $select->andWhere("subscription.subscriptionType = 'custom'");
1751.                         $select->andWhere("subscription.subscribedUser__id IS NOT NULL");
1752.                         $select->andWhere("subscription.isActive = 0");
1753.                         break;
1754.                     
1755.                     case 'activepending':
1756.                         // Active OR Pending
1757.                         $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))");
1758.                         $select->andWhere("subscription.isWso IS NULL OR subscription.isWso = 0");
1759.                         $select->andWhere("userRole.name IN ('CLIENT_USER', 'CLIENT_ADMIN')");
1760.                         break;
1761.                 }
1762.             }
1763.         }
1765.         $select->andWhere("userRole.name = " . $db->quote(USER_ROLES['CLIENT_ADMIN']) . " OR userRole.name = " . $db->quote(USER_ROLES['CLIENT_USER']));
1766.         $select->andWhere("customer.oo_id != " . $db->quote($user->getId()));
1767.         // $select->andWhere("customer.isDeleted != 1 OR customer.isDeleted IS NULL");
1768.         $select->andWhere("customer.organization__id IS NOT NULL");
1769.         $groupByFields = ['customer.oo_id'];
1770.         $hasSorting = false;
1772.         // Dynamic sorting logic with orderKey and order
1773.         $orderKey = $params['orderKey'] ?? null;
1774.         $order = $params['order'] ?? 'asc';
1776.         // Validate order parameter
1777.         if (!in_array(strtolower($order), ['asc', 'desc'])) {
1778.             $order = 'asc';
1779.         }
1781.         // Map orderKey to database fields
1782.         $sortingMap = [
1783.             'created' => 'customer.o_creationDate',
1784.             'username' => 'customer.name',
1785.             'email' => 'customer.email',
1786.             'role' => 'userRole.name',
1787.             'entityType' => 'organization.clientType',
1788.             'packageExpiry' => 'subscription.endDate',
1789.             'packageName' => 'localized_package.packageName',
1790.             'entityName' => 'localized_organization.name'
1791.         ];
1793.         if ($orderKey && isset($sortingMap[$orderKey])) {
1794.             $field = $sortingMap[$orderKey];
1796.             // Handle special cases that require joins
1797.             if ($orderKey === 'packageName') {
1798.                 $localizedPackageTable = 'object_localized_packages_' . ($params['lang'] ?? 'en');
1799.                 $select->leftJoin('package', $localizedPackageTable, 'localized_package', 'localized_package.ooo_id = package.oo_id');
1800.                 $groupByFields[] = 'localized_package.packageName';
1801.             } elseif ($orderKey === 'entityName') {
1802.                 $localizedOrgTable = 'object_localized_organization_' . ($params['lang'] ?? 'en');
1803.                 $select->leftJoin('organization', $localizedOrgTable, 'localized_organization', 'localized_organization.ooo_id = organization.oo_id');
1804.                 $groupByFields[] = 'localized_organization.name';
1805.             } else {
1806.                 $groupByFields[] = $field;
1807.             }
1809.             $select->orderBy($field, strtoupper($order));
1810.             $hasSorting = true;
1811.         }
1813.         // If no sort param given, apply default sort and group
1814.         if (!$hasSorting) {
1815.             $select->orderBy('customer.oo_id', 'DESC');
1816.             $groupByFields = ['customer.oo_id'];
1817.         }
1819.         // Final groupBy
1820.         $select->groupBy(array_unique($groupByFields));
1821.         // dd( $select->getSQL());
1822.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
1823.         $page = isset($params['page']) ? $params['page'] : 1;
1825.         $paginator = $paginator->paginate(
1826.             $select,
1827.             $page,
1828.             $pageSize
1829.         );
1831.         foreach ($paginator as $usersId) {
1833.             $usersData = DataObject\Customer::getById($usersId['oo_id'], true);
1834.             if ($usersData instanceof \Pimcore\Model\DataObject\Customer) {
1836.                 // Get Custom Subscription of the organization and package
1837.                 $customSubscriptions = new DataObject\Subscription\Listing();
1838.                 $customSubscriptions->filterBySubscribedUser($usersData);
1839.                 $customSubscriptions->filterByIsActive(true);
1841.                 $status = "Pending";
1842.                 if ($usersData->getToken() == "" && $usersData->isPublished() == true) {
1843.                     if ($customSubscriptions->count() > 0) {
1844.                         $status = "Active";
1845.                     } else {
1846.                         $status = "Suspended";
1847.                     }
1848.                 } elseif ($usersData->getToken() != "" && $usersData->isPublished() == false) {
1849.                     if ($customSubscriptions->count() > 0) {
1850.                         $status = "Pending";
1851.                     } else {
1852.                         $status = "Suspended";
1853.                     }
1854.                 }
1857.                 $customSubscriptions->filterBySubscriptionType("custom");
1858.                 $customSubscriptions->setOrderKey("o_modificationDate");
1859.                 $customSubscriptions->setOrder("desc");
1860.                 $packageData = [];
1861.                 $userPackage = null;
1862.                 if ($customSubscriptions->count() > 0) {
1863.                     foreach ($customSubscriptions as $key => $customSubscription) {
1864.                         if ($customSubscription instanceof \Pimcore\Model\DataObject\Subscription) {
1865.                             $package = $customSubscription->getSubscribedPackage();
1866.                             $userPackage = $package;
1867.                             if ($package) {
1868.                                 $packageData[] = [
1869.                                     "id" => $package->getId(),
1870.                                     "name" => $package->getPackageName('en'),
1871.                                     "name_ar" => $package->getPackageName('ar'),
1872.                                     "package_expiry" => $customSubscription->getEndDate(date("M d, Y"))
1873.                                 ];
1874.                             }
1875.                         }
1876.                     }
1877.                 }
1879.                 $permissionObj = $this->getUserPermissionInfo($usersData, $translator);
1880.                 $userPermissions = $permissionObj['success'] ? $permissionObj['grants'] : null;
1882.                 $organization = $usersData->getOrganization();
1883.                 $clientType = $organization ? $organization->getClientType() : '';
1885.                 $clientTypeArray = [
1886.                     "key" => $clientType,
1887.                     'name_en' => $clientType === 'organization' ? 'Entity' : ($clientType ? $translator->trans($clientType, [], null, 'en') : ''),
1888.                     'name_ar' => $clientType === 'organization' ? 'الجهة' : ($clientType ? $translator->trans($clientType, [], null, 'ar') : ''),
1889.                 ];
1891.                 $roleArray = [
1892.                     "key" => ($usersData->getRole()) ? $usersData->getRole()->getName() : null,
1893.                     'name_en' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'en') : null,
1894.                     'name_ar' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'ar') : null,
1895.                 ];
1896.                 // If user is pending, get invitation duration from MannedAlertLog
1897.                 if ($status === "Pending") {
1898.                     $invitationDuration = $this->getInvitationDate($usersData);
1899.                     $statusArray = [
1900.                         "key" => $status,
1901.                         'name_en' => $translator->trans($status, [], null, 'en'),
1902.                         'name_ar' => $translator->trans($status, [], null, 'ar'),
1903.                         'pendingDuration' => $invitationDuration // Add this field
1904.                     ];
1905.                 } else {
1906.                     $statusArray = [
1907.                         "key" => $status,
1908.                         'name_en' => $translator->trans($status, [], null, 'en'),
1909.                         'name_ar' => $translator->trans($status, [], null, 'ar'),
1910.                     ];
1911.                 }
1912.                 // $statusArray = [
1913.                 //     "key" => $status,
1914.                 //     'name_en' => $translator->trans($status, [], null, 'en'),
1915.                 //     'name_ar' => $translator->trans($status, [], null, 'ar'),
1916.                 // ];
1918.                 // Get delete reason from DeletedUsersData if type is delete_pending
1919.                 $deleteReason = null;
1920.                 if (isset($params['type']) && $params['type'] == 'delete_pending') {
1921.                     $deletedUsers = new DataObject\DeletedUsersData\Listing();
1922.                     $deletedUsers->filterByPimId($usersData->getId());
1923.                     $deletedUsers->setOrderKey('o_creationDate');
1924.                     $deletedUsers->setOrder('desc');
1925.                     $deletedUsers->setLimit(1);
1926.                     $deleteUserRecord = $deletedUsers->current();
1927.                     if ($deleteUserRecord instanceof DataObject\DeletedUsersData) {
1928.                         $deleteReason = $deleteUserRecord->getReason();
1929.                     }
1930.                 }
1932.                 $userData[] = [
1933.                     'id' => $usersData->getId(),
1934.                     'name' => $usersData->getName(),
1935.                     'title' => $usersData->getTitle(),
1936.                     'email' => $usersData->getEmail(),
1937.                     'phone' => $usersData->getPhoneNo(),
1938.                     'department' => $usersData->getDepartment(),
1939.                     'reason' => $deleteReason,
1940.                     'isDeleted' => $usersData->getIsDeleted() ? true : false,
1941.                     'role' => $roleArray,
1942.                     'company_name_en' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName("en") : null,
1943.                     'company_name_ar' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName("ar") : null,
1944.                     'packageData' => $packageData,
1945.                     'organizationId' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getId() : null,
1946.                     'location' => $this->getLocationList($usersData),
1947.                     'allowCustomNotification' => ($permissionObj['success'] && isset($userPermissions['get_custom_notification'])) ? $userPermissions['get_custom_notification'] : false,
1948.                     'allowAddLocation' => ($permissionObj['success'] && isset($userPermissions['create_location'])) ? $userPermissions['create_location'] : false,
1949.                     'allowForecast' => ($permissionObj['success'] && isset($userPermissions['get_weather'])) ? $userPermissions['get_weather'] : false,
1950.                     'allowAlertHistoryForCustomAlerts' => ($permissionObj['success'] && isset($userPermissions['alert_history'])) ? $userPermissions['alert_history'] : false,
1951.                     'automotive' => ($permissionObj['success'] && isset($userPermissions['automotive'])) ? $userPermissions['automotive'] : false,
1952.                     'aviation' => ($permissionObj['success'] && isset($userPermissions['aviation'])) ? $userPermissions['aviation'] : false,
1953.                     'shippingAndOffshore' => ($permissionObj['success'] && isset($userPermissions['shipping_and_offshore'])) ? $userPermissions['shipping_and_offshore'] : false,
1954.                     'insurance' => ($permissionObj['success'] && isset($userPermissions['insurance'])) ? $userPermissions['insurance'] : false,
1955.                     'energy' => ($permissionObj['success'] && isset($userPermissions['energy'])) ? $userPermissions['energy'] : false,
1956.                     'client_type' => $clientTypeArray,
1957.                     'status' => $statusArray,
1958.                     'createdBy' => $usersData->getCreatedBy() ? $usersData->getCreatedBy()->getName() : null,
1959.                     'createdAt' => date('Y-m-d H:i:s', $usersData->getCreationDate()),
1960.                     'iqamaId' => $usersData->getIqamaId() ? (string) $usersData->getIqamaId() : null,
1961.                     //'token' => $status == "Pending" ? $usersData->getToken() : '',
1962.                     'entity_status' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getStatus() : null,
1963.                     'entity_status_en' => ($usersData->getOrganization() && $usersData->getOrganization()->getStatus()) ? $translator->trans($usersData->getOrganization()->getStatus(), [], null, 'en') : null,
1964.                     'entity_status_ar' => ($usersData->getOrganization() && $usersData->getOrganization()->getStatus()) ? $translator->trans($usersData->getOrganization()->getStatus(), [], null, 'ar') : null,
1965.                     'trialLeftDays' => $usersData->getOrganization() ? 
1966.                         \App\Lib\Utility::getTrialLeftDays(
1967.                             $usersData->getOrganization()->getPackageActivationDate(),
1968.                             $usersData->getOrganization()->getTrialLimit()
1969.                         ) : null,
1970.                     'isSMSEnabled' => $organization ? $organization->getIsSMSEnabled() : false,
1971.                     'SMSLimit' => $userPackage?->getSMSLimit(),
1972.                     'SMSConsumption' => $organization ? $organization->getSmsConsumption() : 0,
1974.                 ];
1975.                 if (isset($params['sortByStatus']) && !empty($params['sortByStatus'])) {
1976.                     $statusFilter = strtoupper($params['sortByStatus']);
1978.                     usort($userData, function ($a, $b) use ($statusFilter) {
1979.                         $statusKeyA = $a['status']['key'];
1980.                         $statusKeyB = $b['status']['key'];
1982.                         if ($statusFilter === 'ASC') {
1983.                             if ($statusKeyA === 'Active' && $statusKeyB !== 'Active') {
1984.                                 return -1;
1985.                             }
1986.                             if ($statusKeyA !== 'Active' && $statusKeyB === 'Active') {
1987.                                 return 1;
1988.                             }
1989.                         } else if ($statusFilter === 'DESC') {
1990.                             if ($statusKeyA === 'Pending' && $statusKeyB !== 'Pending') {
1991.                                 return -1;
1992.                             }
1993.                             if ($statusKeyA !== 'Pending' && $statusKeyB === 'Pending') {
1994.                                 return 1;
1995.                             }
1996.                         }
1997.                         return 0; // They are equal in terms of status priority
1998.                     });
1999.                 }
2000.             }
2001.         }
2002.         if (!$paginator->count()) {
2003.             return ["success" => false, "message" => $translator->trans("no_user_available_to_this_organization")];
2004.         }
2005.         return ["success" => TRUE, "data" => $userData, "paginationVariables" => $paginator->getPaginationData()];
2006.         // } catch (\Exception $ex) {
2007.         //     throw new \Exception($ex->getMessage());
2008.         // }
2010.         return $result;
2011.     }
2017.     /**
2018.      * Get NCM User List
2019.      */
2020.     public function getNCMUsers($request, $user, $params, $paginator, $translator)
2021.     {
2023.         $result = [];
2024.         try {
2025.             $userData = [];
2027.             // if ($user->getOrganization() === null) {
2028.             //     return ["success" => false, "message" => $translator->trans("organization_does_not_exists")];
2029.             //  }
2031.             //  $organizationId = $user->getOrganization()->getId();
2034.             // Get All the Classes
2035.             $class = new \Pimcore\Model\DataObject\ClassDefinition();
2036.             $customer = $class->getDao()->getIdByName('Customer');
2037.             $subscription = $class->getDao()->getIdByName('Subscription');
2038.             $userRole = $class->getDao()->getIdByName('UserRole');
2039.             $userTag = $class->getDao()->getIdByName('UserTag');
2040.             $organization = $class->getDao()->getIdByName('Organization');
2041.             $package = $class->getDao()->getIdByName('Package');
2043.             $db = Db::get();
2044.             $select = $db->createQueryBuilder();
2045.             $select->select('customer.oo_id');
2046.             $select->from('object_' . $customer, 'customer');
2047.             $select->leftJoin('customer', 'object_' . $subscription, 'subscription', 'customer.oo_id = subscription.subscribedUser__id');
2048.             $select->leftJoin('subscription', 'object_' . $package, 'package', 'package.oo_id = subscription.subscribedPackage__id');
2049.             $select->leftJoin('customer', 'object_' . $organization, 'organization', 'organization.oo_id = customer.organization__id');
2050.             $select->leftJoin('customer', 'object_' . $userRole, 'userRole', 'userRole.oo_id = customer.role__id');
2051.             $select->leftJoin('customer', 'object_' . $userTag, 'userTage', 'userTage.oo_id = customer.tag__id');
2053.             if (isset($params['search']) && !empty($params['search'])) {
2054.                 $select->andWhere("customer.name LIKE " . $db->quote("%" . $params['search'] . "%") . " OR customer.email LIKE " . $db->quote("%" . $params['search'] . "%"));
2055.             }
2057.             if (isset($params['searchByTag']) && !empty($params['searchByTag'])) {
2058.                 $select->andWhere("customer.tag__id = " . $db->quote($params['searchByTag']));
2059.             }
2061.             // Filter by dual mode
2062.             if (isset($params['is_dual_mode']) && ($params['is_dual_mode'] == true )) {
2063.                 $select->andWhere("customer.dualMode = 1");
2064.             }
2066.             $select->andWhere("userRole.name = " . $db->quote(USER_ROLES['NCM_IT']) . " OR userRole.name = " . $db->quote(USER_ROLES['NCM_OPERATOR']));
2067.             $select->andWhere("customer.oo_id != " . $db->quote($user->getId()));
2068.             $select->andWhere("customer.isDeleted != 1 or customer.isDeleted IS NULL");
2069.             //$select->andWhere("organization.oo_id = ".$db->quote($organizationId));
2071.             // if (isset($params['status']) && !empty($params['status'])) {
2072.             //     $statusFilter = ucfirst($params['status']);
2074.             //     if ($statusFilter == 'Active') {
2075.             //         $select->andWhere("customer.token IS NULL AND customer.o_published = 1 AND subscription.subscribedUser__id IS NOT NULL");
2076.             //     } elseif ($statusFilter == 'Suspended') {
2077.             //         $select->andWhere("customer.token IS NULL AND customer.o_published = 1 AND subscription.subscribedUser__id IS NULL");
2078.             //     } elseif ($statusFilter == 'Pending') {
2079.             //         $select->andWhere("customer.token != '' AND customer.o_published = 0");
2080.             //     }
2081.             // }
2083.             // Dynamic sorting logic
2084.             $orderKey = isset($params['orderKey']) ? $params['orderKey'] : null;
2085.             $order = isset($params['order']) ? strtoupper($params['order']) : 'ASC';
2087.             // Validate order parameter
2088.             if (!in_array(strtoupper($order), ['ASC', 'DESC'])) {
2089.                 $order = 'ASC';
2090.             }
2092.             // Map orderKey to database fields
2093.             $fieldMapping = [
2094.                 'username' => 'customer.name',
2095.                 'email' => 'customer.email',
2096.                 'userTag' => 'userTage.name',
2097.                 'createdBy' => 'createdBy.name',
2098.                 'role' => 'userRole.name',
2099.                 'status' => 'status', // This will be handled separately as it's computed
2100.                 'createdOn' => 'customer.o_creationDate'
2101.             ];
2103.             if ($orderKey && isset($fieldMapping[$orderKey])) {
2104.                 $field = $fieldMapping[$orderKey];
2105.                 if ($orderKey === 'createdBy') {
2106.                     $select->leftJoin('customer', 'object_' . $customer, 'createdBy', 'createdBy.oo_id = customer.createdBy__id');
2107.                 }
2109.                 if ($orderKey === 'status') {
2110.                     $needStatusSort = true;
2111.                 } else {
2112.                     $select->orderBy($field, $order);
2113.                 }
2114.             } else {
2115.                 // Default sorting
2116.                 $select->orderBy('customer.o_creationDate', 'DESC');
2117.             }
2119.             $select->groupBy(array('oo_id'));
2122.             $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
2123.             $page = isset($params['page']) ? $params['page'] : 1;
2125.             $paginator = $paginator->paginate(
2126.                 $select,
2127.                 $page,
2128.                 $pageSize
2129.             );
2130.             foreach ($paginator as $usersId) {
2132.                 $usersData = DataObject\Customer::getById($usersId['oo_id'], true);
2133.                 if ($usersData instanceof \Pimcore\Model\DataObject\Customer) {
2135.                     // Get Custom Subscription of the organization and package
2136.                     $customSubscriptions = new DataObject\Subscription\Listing();
2137.                     $customSubscriptions->filterBySubscribedUser($usersData);
2138.                     $customSubscriptions->filterByIsActive(true);
2140.                     $status = "Pending";
2141.                     if ($usersData->getToken() == "" && $usersData->isPublished() == true) {
2143.                         if ($usersData->getPermissionGroups() && count($usersData->getPermissionGroups()) > 0) {
2144.                             $status = "Active";
2145.                         } else {
2146.                             $status = "Suspended";
2147.                         }
2148.                     } elseif ($usersData->getToken() != "" && $usersData->isPublished() == false) {
2150.                         $status = "Pending";
2151.                     }
2154.                     $permissionObj = $this->getUserPermissionInfo($usersData, $translator);
2155.                     $userPermissions = $permissionObj['success'] ? $permissionObj['grants'] : null;
2157.                     //$customSubscriptions->filterBySubscriptionType("custom");
2158.                     $customSubscriptions->setOrderKey("o_modificationDate");
2159.                     $customSubscriptions->setOrder("desc");
2161.                     $apiGroupData = [];
2162.                     $packageData = [];
2163.                     $assignedApiGroupIds = [];
2164.                     if ($customSubscriptions->count() > 0) {
2165.                         foreach ($customSubscriptions as $key => $customSubscription) {
2166.                             if ($customSubscription instanceof \Pimcore\Model\DataObject\Subscription) {
2167.                                 $package = $customSubscription->getSubscribedPackage();
2168.                                 $disallowedApiGroups = $customSubscription->getDisallowedApiGroups();
2170.                                 // get all allowed API Group IDs for the user
2171.                                 $allowedApiGroups = $customSubscription->getAllowedApiGroups();
2173.                                 if (count($allowedApiGroups) > 0) {
2174.                                     foreach ($allowedApiGroups as $allowedApiGroup) {
2175.                                         if ($allowedApiGroup instanceof \Pimcore\Model\DataObject\ApiGroup) {
2176.                                             # code...
2177.                                             $assignedApiGroupIds[] = [
2178.                                                 "id" => $allowedApiGroup->getId(),
2179.                                                 "name" => $allowedApiGroup->getGroupName(),
2180.                                             ];
2181.                                         }
2182.                                     }
2183.                                 }
2184.                                 if ($package) {
2185.                                     $packageData[] = [
2186.                                         "id" => $package->getId(),
2187.                                         "name" => $package->getName(),
2188.                                         "package_expiry" => $customSubscription->getEndDate(date("M d, Y")),
2189.                                         "is_no_expiry" => $customSubscription->getIsNoExpiry() == null ? false : $customSubscription->getIsNoExpiry()
2190.                                     ];
2192.                                     $apiGroups = $package->getApiGroups();
2193.                                     if ($apiGroups) {
2194.                                         foreach ($apiGroups as  $apiGroup) {
2196.                                             $apiGroupId = $apiGroup->getId();
2197.                                             $apiGroupNameEn = $apiGroup->getApiGroupName('en');
2198.                                             $apiGroupNameAr = $apiGroup->getApiGroupName('ar');
2199.                                             $isDisallowed = false;
2201.                                             // Check if the current API group is disallowed
2202.                                             foreach ($disallowedApiGroups as $disallowedApiGroup) {
2203.                                                 if ($apiGroupId == $disallowedApiGroup->getId()) {
2204.                                                     $isDisallowed = true;
2205.                                                     break;
2206.                                                 }
2207.                                             }
2209.                                             // Only add the API group if it's not disallowed
2210.                                             if (!$isDisallowed) {
2211.                                                 $apiGroupData[] = [
2212.                                                     "id" => $apiGroupId,
2213.                                                     "name" => $apiGroupNameEn,
2214.                                                     "name_ar" => $apiGroupNameAr
2215.                                                 ];
2216.                                             }
2217.                                         }
2218.                                     }
2219.                                 }
2220.                             }
2221.                         }
2222.                     }
2225.                     $typeArray = [
2226.                         "key" => 'user',
2227.                         'name_en' => $translator->trans('user', [], null, 'en'),
2228.                         'name_ar' => $translator->trans('user', [], null, 'ar'),
2229.                     ];
2231.                     $roleArray = [
2232.                         "key" => ($usersData->getRole()) ? $usersData->getRole()->getName() : null,
2233.                         'name_en' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'en') : null,
2234.                         'name_ar' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'ar') : null,
2235.                     ];
2237.                     $statusArray = [
2238.                         "key" => $status,
2239.                         'name_en' => $translator->trans($status, [], null, 'en'),
2240.                         'name_ar' => $translator->trans($status, [], null, 'ar'),
2241.                     ];
2243.                     // Fetch Permission Groups Data
2244.                     $permissionGroups = $usersData->getPermissionGroups();
2245.                    
2246.                     $permissionGroupsData = [];
2247.                     $permissionGroupDualModeData = [];
2248.                     if ($permissionGroups) {
2249.                         foreach ($permissionGroups as $permissionGroup) {
2250.                             if ($permissionGroup instanceof \Pimcore\Model\DataObject\PermissionGroup) {
2251.                                 if($permissionGroup->getIsDualMode() == true){
2252.                                     $permissionGroupDualModeData[] = [
2253.                                         'id' => $permissionGroup->getId(),
2254.                                         'nameEn' => $permissionGroup->getName('en'),
2255.                                         'nameAr' => $permissionGroup->getName('ar'),
2256.                                         'descriptionEn' => $permissionGroup->getDescription('en'),
2257.                                         'descriptionAr' => $permissionGroup->getDescription('ar'),
2258.                                         'apiGroups' => array_map(function ($group) {
2259.                                             return ['id' => $group->getId(), 'nameEn' => $group->getApiGroupName('en'), 'nameAr' => $group->getApiGroupName('ar')];
2260.                                         }, $permissionGroup->getApiGroups() ?? []),
2261.                                     ];
2262.                                 }
2263.                                 else{
2264.                                 $permissionGroupsData[] = [
2265.                                     'id' => $permissionGroup->getId(),
2266.                                     'nameEn' => $permissionGroup->getName('en'),
2267.                                     'nameAr' => $permissionGroup->getName('ar'),
2268.                                     'descriptionEn' => $permissionGroup->getDescription('en'),
2269.                                     'descriptionAr' => $permissionGroup->getDescription('ar'),
2270.                                     'apiGroups' => array_map(function ($group) {
2271.                                         return ['id' => $group->getId(), 'nameEn' => $group->getApiGroupName('en'), 'nameAr' => $group->getApiGroupName('ar')];
2272.                                     }, $permissionGroup->getApiGroups() ?? []),
2273.                                     ];
2274.                                 }
2275.                             }
2276.                         }
2277.                     }
2280.                     $userData[] = [
2281.                         'id' => $usersData->getId(),
2282.                         'name' => $usersData->getName(),
2283.                         'title' => $usersData->getTitle(),
2284.                         'email' => $usersData->getEmail(),
2285.                         'department' => $usersData->getDepartment(),
2286.                         'role' => $roleArray,
2287.                         'organization' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName() : null,
2288.                         'organizationId' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getId() : null,
2289.                         'location' => $this->getLocationList($usersData),
2290.                         'invite_user' => ($permissionObj['success'] && isset($userPermissions['invite_user'])) ? $userPermissions['invite_user'] : false,
2291.                         'edit_user' => ($permissionObj['success'] && isset($userPermissions['edit_user'])) ? $userPermissions['edit_user'] : false,
2292.                         'delete_user' => ($permissionObj['success'] && isset($userPermissions['delete_user'])) ? $userPermissions['delete_user'] : false,
2293.                         'invite_ncm_user' => ($permissionObj['success'] && isset($userPermissions['invite_ncm_user'])) ? $userPermissions['invite_ncm_user'] : false,
2294.                         'edit_ncm_user' => ($permissionObj['success'] && isset($userPermissions['edit_ncm_user'])) ? $userPermissions['edit_ncm_user'] : false,
2295.                         'delete_ncm_user' => ($permissionObj['success'] && isset($userPermissions['delete_ncm_user'])) ? $userPermissions['delete_ncm_user'] : false,
2296.                         'type' => $typeArray,
2297.                         'status' => $statusArray,
2298.                         'apiGroups' => $apiGroupData,
2299.                         'assignedApiGroupIds' => $assignedApiGroupIds,
2300.                         'packageData' => $packageData,
2301.                         'createdBy' => $usersData->getCreatedBy() ? $usersData->getCreatedBy()->getName() : null,
2302.                         'creationDate' => $usersData->getCreationDate() ? date('Y-m-d', $usersData->getCreationDate()) : null,
2303.                         'iqamaId' => $usersData->getIqamaId() ? (string) $usersData->getIqamaId() : null,
2304.                         'tag' => $usersData->getTag() ? ['id' => $usersData->getTag()->getId(), 'name' => $usersData->getTag()->getName()] : null,
2305.                         'permissionGroupsData' => $permissionGroupsData,
2306.                         'permissionGroupDualMode' => $permissionGroupDualModeData,
2307.                         'dualMode' => $usersData->getDualMode() ? true : false,
2308.                         //'token' => $usersData->getToken(),
2309.                     ];
2310.                 }
2311.             }
2315.             if (!$userData) {
2316.                 return ["success" => false, "message" => $translator->trans("no_user_available_in_NCM")];
2317.             }
2319.             // Handle status sorting if needed
2320.             if (isset($needStatusSort) && $needStatusSort && $orderKey === 'status') {
2321.                 usort($userData, function ($a, $b) use ($order) {
2322.                     $statusA = $a['status']['key'];
2323.                     $statusB = $b['status']['key'];
2325.                     if ($order === 'ASC') {
2326.                         return strcmp($statusA, $statusB);
2327.                     } else {
2328.                         return strcmp($statusB, $statusA);
2329.                     }
2330.                 });
2331.             }
2333.             return ["success" => TRUE, "data" => $userData, "paginationVariables" => $paginator->getPaginationData()];
2334.         } catch (\Exception $ex) {
2335.             throw new \Exception($ex->getMessage());
2336.         }
2338.         return $result;
2339.     }
2340.     public function getDualModeUsers($request, $user, $params, $paginator, $translator)
2341.     {
2342.        $result = [];
2343.         try {
2344.             $userData = [];
2346.             // if ($user->getOrganization() === null) {
2347.             //     return ["success" => false, "message" => $translator->trans("organization_does_not_exists")];
2348.             //  }
2350.             //  $organizationId = $user->getOrganization()->getId();
2353.             // Get All the Classes
2354.             $class = new \Pimcore\Model\DataObject\ClassDefinition();
2355.             $customer = $class->getDao()->getIdByName('Customer');
2356.             $subscription = $class->getDao()->getIdByName('Subscription');
2357.             $userRole = $class->getDao()->getIdByName('UserRole');
2358.             $userTag = $class->getDao()->getIdByName('UserTag');
2359.             $organization = $class->getDao()->getIdByName('Organization');
2360.             $package = $class->getDao()->getIdByName('Package');
2362.             $db = Db::get();
2363.             $select = $db->createQueryBuilder();
2364.             $select->select('customer.oo_id');
2365.             $select->from('object_' . $customer, 'customer');
2366.             $select->leftJoin('customer', 'object_' . $subscription, 'subscription', 'customer.oo_id = subscription.subscribedUser__id');
2367.             $select->leftJoin('subscription', 'object_' . $package, 'package', 'package.oo_id = subscription.subscribedPackage__id');
2368.             $select->leftJoin('customer', 'object_' . $organization, 'organization', 'organization.oo_id = customer.organization__id');
2369.             $select->leftJoin('customer', 'object_' . $userRole, 'userRole', 'userRole.oo_id = customer.role__id');
2370.             $select->leftJoin('customer', 'object_' . $userTag, 'userTage', 'userTage.oo_id = customer.tag__id');
2372.             if (isset($params['search']) && !empty($params['search'])) {
2373.                 $select->andWhere("customer.name LIKE " . $db->quote("%" . $params['search'] . "%") . " OR customer.email LIKE " . $db->quote("%" . $params['search'] . "%"));
2374.             }
2376.             if (isset($params['searchByTag']) && !empty($params['searchByTag'])) {
2377.                 $select->andWhere("customer.tag__id = " . $db->quote($params['searchByTag']));
2378.             }
2380.             
2381.             $select->andWhere("customer.dualMode = 1");
2382.            
2384.             $select->andWhere("userRole.name = " . $db->quote(USER_ROLES['NCM_IT']) . " OR userRole.name = " . $db->quote(USER_ROLES['NCM_OPERATOR']));
2385.             $select->andWhere("customer.oo_id != " . $db->quote($user->getId()));
2386.             $select->andWhere("customer.isDeleted != 1 or customer.isDeleted IS NULL");
2387.             //$select->andWhere("organization.oo_id = ".$db->quote($organizationId));
2389.             // if (isset($params['status']) && !empty($params['status'])) {
2390.             //     $statusFilter = ucfirst($params['status']);
2392.             //     if ($statusFilter == 'Active') {
2393.             //         $select->andWhere("customer.token IS NULL AND customer.o_published = 1 AND subscription.subscribedUser__id IS NOT NULL");
2394.             //     } elseif ($statusFilter == 'Suspended') {
2395.             //         $select->andWhere("customer.token IS NULL AND customer.o_published = 1 AND subscription.subscribedUser__id IS NULL");
2396.             //     } elseif ($statusFilter == 'Pending') {
2397.             //         $select->andWhere("customer.token != '' AND customer.o_published = 0");
2398.             //     }
2399.             // }
2401.             // Dynamic sorting logic
2402.             $orderKey = isset($params['orderKey']) ? $params['orderKey'] : null;
2403.             $order = isset($params['order']) ? strtoupper($params['order']) : 'ASC';
2405.             // Validate order parameter
2406.             if (!in_array(strtoupper($order), ['ASC', 'DESC'])) {
2407.                 $order = 'ASC';
2408.             }
2410.             // Map orderKey to database fields
2411.             $fieldMapping = [
2412.                 'username' => 'customer.name',
2413.                 'email' => 'customer.email',
2414.                 'userTag' => 'userTage.name',
2415.                 'createdBy' => 'createdBy.name',
2416.                 'role' => 'userRole.name',
2417.                 'status' => 'status', // This will be handled separately as it's computed
2418.                 'createdOn' => 'customer.o_creationDate'
2419.             ];
2421.             if ($orderKey && isset($fieldMapping[$orderKey])) {
2422.                 $field = $fieldMapping[$orderKey];
2423.                 if ($orderKey === 'createdBy') {
2424.                     $select->leftJoin('customer', 'object_' . $customer, 'createdBy', 'createdBy.oo_id = customer.createdBy__id');
2425.                 }
2427.                 if ($orderKey === 'status') {
2428.                     $needStatusSort = true;
2429.                 } else {
2430.                     $select->orderBy($field, $order);
2431.                 }
2432.             } else {
2433.                 // Default sorting
2434.                 $select->orderBy('customer.o_creationDate', 'DESC');
2435.             }
2437.             $select->groupBy(array('oo_id'));
2440.             $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
2441.             $page = isset($params['page']) ? $params['page'] : 1;
2443.             $paginator = $paginator->paginate(
2444.                 $select,
2445.                 $page,
2446.                 $pageSize
2447.             );
2448.             foreach ($paginator as $usersId) {
2450.                 $usersData = DataObject\Customer::getById($usersId['oo_id'], true);
2451.                 if ($usersData instanceof \Pimcore\Model\DataObject\Customer) {
2453.                     // Get Custom Subscription of the organization and package
2454.                     $customSubscriptions = new DataObject\Subscription\Listing();
2455.                     $customSubscriptions->filterBySubscribedUser($usersData);
2456.                     $customSubscriptions->filterByIsActive(true);
2458.                     $status = "Pending";
2459.                     if ($usersData->getToken() == "" && $usersData->isPublished() == true) {
2461.                         if ($usersData->getPermissionGroups() && count($usersData->getPermissionGroups()) > 0) {
2462.                             $status = "Active";
2463.                         } else {
2464.                             $status = "Suspended";
2465.                         }
2466.                     } elseif ($usersData->getToken() != "" && $usersData->isPublished() == false) {
2468.                         $status = "Pending";
2469.                     }
2472.                     $permissionObj = $this->getUserPermissionInfo($usersData, $translator);
2473.                     $userPermissions = $permissionObj['success'] ? $permissionObj['grants'] : null;
2475.                     //$customSubscriptions->filterBySubscriptionType("custom");
2476.                     $customSubscriptions->setOrderKey("o_modificationDate");
2477.                     $customSubscriptions->setOrder("desc");
2479.                     $apiGroupData = [];
2480.                     $packageData = [];
2481.                     $assignedApiGroupIds = [];
2482.                     if ($customSubscriptions->count() > 0) {
2483.                         foreach ($customSubscriptions as $key => $customSubscription) {
2484.                             if ($customSubscription instanceof \Pimcore\Model\DataObject\Subscription) {
2485.                                 $package = $customSubscription->getSubscribedPackage();
2486.                                 $disallowedApiGroups = $customSubscription->getDisallowedApiGroups();
2488.                                 // get all allowed API Group IDs for the user
2489.                                 $allowedApiGroups = $customSubscription->getAllowedApiGroups();
2491.                                 if (count($allowedApiGroups) > 0) {
2492.                                     foreach ($allowedApiGroups as $allowedApiGroup) {
2493.                                         if ($allowedApiGroup instanceof \Pimcore\Model\DataObject\ApiGroup) {
2494.                                             # code...
2495.                                             $assignedApiGroupIds[] = [
2496.                                                 "id" => $allowedApiGroup->getId(),
2497.                                                 "name" => $allowedApiGroup->getGroupName(),
2498.                                             ];
2499.                                         }
2500.                                     }
2501.                                 }
2502.                                 if ($package) {
2503.                                     $packageData[] = [
2504.                                         "id" => $package->getId(),
2505.                                         "name" => $package->getName(),
2506.                                         "package_expiry" => $customSubscription->getEndDate(date("M d, Y")),
2507.                                         "is_no_expiry" => $customSubscription->getIsNoExpiry() == null ? false : $customSubscription->getIsNoExpiry()
2508.                                     ];
2510.                                     $apiGroups = $package->getApiGroups();
2511.                                     if ($apiGroups) {
2512.                                         foreach ($apiGroups as  $apiGroup) {
2514.                                             $apiGroupId = $apiGroup->getId();
2515.                                             $apiGroupNameEn = $apiGroup->getApiGroupName('en');
2516.                                             $apiGroupNameAr = $apiGroup->getApiGroupName('ar');
2517.                                             $isDisallowed = false;
2519.                                             // Check if the current API group is disallowed
2520.                                             foreach ($disallowedApiGroups as $disallowedApiGroup) {
2521.                                                 if ($apiGroupId == $disallowedApiGroup->getId()) {
2522.                                                     $isDisallowed = true;
2523.                                                     break;
2524.                                                 }
2525.                                             }
2527.                                             // Only add the API group if it's not disallowed
2528.                                             if (!$isDisallowed) {
2529.                                                 $apiGroupData[] = [
2530.                                                     "id" => $apiGroupId,
2531.                                                     "name" => $apiGroupNameEn,
2532.                                                     "name_ar" => $apiGroupNameAr
2533.                                                 ];
2534.                                             }
2535.                                         }
2536.                                     }
2537.                                 }
2538.                             }
2539.                         }
2540.                     }
2543.                     $typeArray = [
2544.                         "key" => 'user',
2545.                         'name_en' => $translator->trans('user', [], null, 'en'),
2546.                         'name_ar' => $translator->trans('user', [], null, 'ar'),
2547.                     ];
2549.                     $roleArray = [
2550.                         "key" => ($usersData->getRole()) ? $usersData->getRole()->getName() : null,
2551.                         'name_en' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'en') : null,
2552.                         'name_ar' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'ar') : null,
2553.                     ];
2555.                     $statusArray = [
2556.                         "key" => $status,
2557.                         'name_en' => $translator->trans($status, [], null, 'en'),
2558.                         'name_ar' => $translator->trans($status, [], null, 'ar'),
2559.                     ];
2561.                     // Fetch Permission Groups Data
2562.                     $permissionGroups = $usersData->getPermissionGroups();
2563.                    
2564.                     $permissionGroupsData = [];
2565.                     $permissionGroupDualModeData = [];
2566.                     if ($permissionGroups) {
2567.                         foreach ($permissionGroups as $permissionGroup) {
2568.                             if ($permissionGroup instanceof \Pimcore\Model\DataObject\PermissionGroup) {
2569.                                 if($permissionGroup->getIsDualMode() == true){
2570.                                     $permissionGroupDualModeData[] = [
2571.                                         'id' => $permissionGroup->getId(),
2572.                                         'nameEn' => $permissionGroup->getName('en'),
2573.                                         'nameAr' => $permissionGroup->getName('ar'),
2574.                                         'descriptionEn' => $permissionGroup->getDescription('en'),
2575.                                         'descriptionAr' => $permissionGroup->getDescription('ar'),
2576.                                         'apiGroups' => array_map(function ($group) {
2577.                                             return ['id' => $group->getId(), 'nameEn' => $group->getApiGroupName('en'), 'nameAr' => $group->getApiGroupName('ar')];
2578.                                         }, $permissionGroup->getApiGroups() ?? []),
2579.                                     ];
2580.                                 }
2581.                                 else{
2582.                                 $permissionGroupsData[] = [
2583.                                     'id' => $permissionGroup->getId(),
2584.                                     'nameEn' => $permissionGroup->getName('en'),
2585.                                     'nameAr' => $permissionGroup->getName('ar'),
2586.                                     'descriptionEn' => $permissionGroup->getDescription('en'),
2587.                                     'descriptionAr' => $permissionGroup->getDescription('ar'),
2588.                                     'apiGroups' => array_map(function ($group) {
2589.                                         return ['id' => $group->getId(), 'nameEn' => $group->getApiGroupName('en'), 'nameAr' => $group->getApiGroupName('ar')];
2590.                                     }, $permissionGroup->getApiGroups() ?? []),
2591.                                     ];
2592.                                 }
2593.                             }
2594.                         }
2595.                     }
2598.                     $userData[] = [
2599.                         'id' => $usersData->getId(),
2600.                         'name' => $usersData->getName(),
2601.                         'title' => $usersData->getTitle(),
2602.                         'email' => $usersData->getEmail(),
2603.                         'department' => $usersData->getDepartment(),
2604.                         'role' => $roleArray,
2605.                         'organization' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName() : null,
2606.                         'organizationId' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getId() : null,
2607.                         'location' => $this->getLocationList($usersData),
2608.                         'invite_user' => ($permissionObj['success'] && isset($userPermissions['invite_user'])) ? $userPermissions['invite_user'] : false,
2609.                         'edit_user' => ($permissionObj['success'] && isset($userPermissions['edit_user'])) ? $userPermissions['edit_user'] : false,
2610.                         'delete_user' => ($permissionObj['success'] && isset($userPermissions['delete_user'])) ? $userPermissions['delete_user'] : false,
2611.                         'invite_ncm_user' => ($permissionObj['success'] && isset($userPermissions['invite_ncm_user'])) ? $userPermissions['invite_ncm_user'] : false,
2612.                         'edit_ncm_user' => ($permissionObj['success'] && isset($userPermissions['edit_ncm_user'])) ? $userPermissions['edit_ncm_user'] : false,
2613.                         'delete_ncm_user' => ($permissionObj['success'] && isset($userPermissions['delete_ncm_user'])) ? $userPermissions['delete_ncm_user'] : false,
2614.                         'type' => $typeArray,
2615.                         'status' => $statusArray,
2616.                         'apiGroups' => $apiGroupData,
2617.                         'assignedApiGroupIds' => $assignedApiGroupIds,
2618.                         'packageData' => $packageData,
2619.                         'createdBy' => $usersData->getCreatedBy() ? $usersData->getCreatedBy()->getName() : null,
2620.                         'creationDate' => $usersData->getCreationDate() ? date('Y-m-d', $usersData->getCreationDate()) : null,
2621.                         'iqamaId' => $usersData->getIqamaId() ? (string) $usersData->getIqamaId() : null,
2622.                         'tag' => $usersData->getTag() ? ['id' => $usersData->getTag()->getId(), 'name' => $usersData->getTag()->getName()] : null,
2623.                         'permissionGroupsData' => $permissionGroupsData,
2624.                         'permissionGroupDualMode' => $permissionGroupDualModeData,
2625.                         'dualMode' => $usersData->getDualMode() ? true : false,
2626.                         //'token' => $usersData->getToken(),
2627.                     ];
2628.                 }
2629.             }
2631.             $permissionGroups = new DataObject\PermissionGroup\Listing();
2632.             $permissionGroups->setCondition("isDualMode = 1");
2633.             // Total active users: same logic as per-user status (token empty, published, at least one permission group)
2634.             $totalActiveUsers = 0;
2635.             $activeListing = new DataObject\Customer\Listing();
2636.             $activeListing->addConditionParam('dualMode = ?', 1);
2637.             $activeListing->addConditionParam('(token IS NULL OR token = "")');
2638.             $activeListing->addConditionParam('o_published = ?', 1);
2639.             $activeListing->addConditionParam('(isDeleted != 1 OR isDeleted IS NULL)');
2640.             $activeListing->addConditionParam('oo_id != ?', $user->getId());
2641.             $ncmRoleRows = $db->executeQuery("SELECT oo_id FROM object_" . $userRole . " WHERE name IN (?, ?)", [
2642.                 USER_ROLES['NCM_IT'],
2643.                 USER_ROLES['NCM_OPERATOR']
2644.             ])->fetchAll(\PDO::FETCH_ASSOC);
2645.             $ncmRoleIds = $ncmRoleRows ? array_column($ncmRoleRows, 'oo_id') : [];
2646.             if (!empty($ncmRoleIds)) {
2647.                 $activeListing->addConditionParam('role__id IN (' . implode(',', array_map('intval', $ncmRoleIds)) . ')');
2648.             }
2649.             // if (isset($params['search']) && !empty($params['search'])) {
2650.             //     $activeListing->addConditionParam('(name LIKE ? OR email LIKE ?)', ['%' . $params['search'] . '%', '%' . $params['search'] . '%']);
2651.             // }
2652.             // if (isset($params['searchByTag']) && !empty($params['searchByTag'])) {
2653.             //     $activeListing->addConditionParam('tag__id = ?', $params['searchByTag']);
2654.             // }
2655.             foreach ($activeListing as $customerObj) {
2656.                 if ($customerObj instanceof \Pimcore\Model\DataObject\Customer) {
2657.                     $groups = $customerObj->getPermissionGroups();
2658.                     if ($groups && count($groups) > 0) {
2659.                         $totalActiveUsers++;
2660.                     }
2661.                 }
2662.             }
2664.             // Total users count: all dual-mode NCM users (no search/tag filter)
2665.             $countSelect = $db->createQueryBuilder();
2666.             $countSelect->select('COUNT(DISTINCT customer.oo_id) as total');
2667.             $countSelect->from('object_' . $customer, 'customer');
2668.             $countSelect->leftJoin('customer', 'object_' . $userRole, 'userRole', 'userRole.oo_id = customer.role__id');
2669.             $countSelect->andWhere("customer.dualMode = 1");
2670.             $countSelect->andWhere("(userRole.name = " . $db->quote(USER_ROLES['NCM_IT']) . " OR userRole.name = " . $db->quote(USER_ROLES['NCM_OPERATOR']) . ")");
2671.             $countSelect->andWhere("customer.oo_id != " . $db->quote($user->getId()));
2672.             $countSelect->andWhere("(customer.isDeleted != 1 OR customer.isDeleted IS NULL)");
2673.             $totalUsersCount = (int) $countSelect->execute()->fetchOne();
2675.             $summary = [
2676.                 "total_groups" => $permissionGroups->count(),
2677.                 "total_users" => $totalUsersCount,
2678.                 "total_active_users" => $totalActiveUsers,
2679.             ];
2680.        
2681.           
2683.             if (!$userData) {
2684.                 return ["success" => false, "message" => $translator->trans("no_user_available_in_NCM")];
2685.             }
2687.             // Handle status sorting if needed
2688.             if (isset($needStatusSort) && $needStatusSort && $orderKey === 'status') {
2689.                 usort($userData, function ($a, $b) use ($order) {
2690.                     $statusA = $a['status']['key'];
2691.                     $statusB = $b['status']['key'];
2693.                     if ($order === 'ASC') {
2694.                         return strcmp($statusA, $statusB);
2695.                     } else {
2696.                         return strcmp($statusB, $statusA);
2697.                     }
2698.                 });
2699.             }
2701.             return [
2702.                 "success" => true,
2703.                 "data" => $userData,
2704.                 "summary_counts" => $summary,
2705.                 "paginationVariables" => $paginator->getPaginationData()
2706.             ];
2707.         } catch (\Exception $ex) {
2708.             throw new \Exception($ex->getMessage());
2709.         }
2711.         return $result;
2712.     }
2713.     /**
2714.      * Summary of assignPermissionUserGroupToDualModeUser
2715.      * assign permission group to dual mode user
2716.      */
2717.     public function assignPermissionUserGroupToDualModeUser($request, $user, $params, $translator)
2718.     {
2719.         try {
2720.             $user = DataObject\Customer::getById($params['userid'], true);
2721.             if (!$user) {
2722.                 return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
2723.             }
2724.             $permissionGroups = [];
2725.             foreach ($params['permissions_id'] as $groupId) {
2726.                 $permissionGroup = PermissionGroup::getById($groupId);
2727.                 if ($permissionGroup) {
2728.                     $permissionGroups[] = $permissionGroup;
2729.                 } else {
2730.                     return ["success" => false, "message" => $translator->trans("permission_group_does_not_exists")];
2731.                 }
2732.             }
2733.             $user->setPermissionGroups($permissionGroups);
2734.             $user->save();
2735.             return ["success" => true, "message" => $translator->trans("user_assigned_to_dual_mode_successfully")];
2736.             
2737.         } catch (\Exception $ex) {
2738.             return ["success" => false, "message" => $ex->getMessage()];
2739.         }
2740.     }
2741.     /**
2742.      * Summary of assignBulkUserPermissionGroup
2743.      * assign permission groups to multiple users in bulk
2744.      */
2745.     public function assignBulkUserPermissionGroup($user, $params, $translator)
2746.     {
2747.         try {
2748.             // Validate and prepare users
2749.             $userData = [];
2750.             foreach ($params["userIds"] as $userId) {
2751.                 $userToUpdate = DataObject\Customer::getById($userId);
2752.                 if (!$userToUpdate) {
2753.                     return ["success" => false, "message" => $translator->trans("User_not_found") . ": " . $userId];
2754.                 }
2755.                 $userData[] = $userToUpdate;
2756.             }
2758.             // Validate and prepare permission groups
2759.             $permissionGroups = [];
2760.             foreach ($params["permissionIds"] as $groupId) {
2761.                 $permissionGroup = PermissionGroup::getById($groupId);
2762.                 if (!$permissionGroup) {
2763.                     return ["success" => false, "message" => $translator->trans("Invalid_GroupId") . ": " . $groupId];
2764.                 }
2765.                 $permissionGroups[] = $permissionGroup;
2766.             }
2768.             // Assign permission groups to all users
2769.             foreach ($userData as $userToUpdate) {
2770.                 $userToUpdate->setPermissionGroups($permissionGroups);
2771.                 $userToUpdate->save();
2772.             }
2774.             return ["success" => true, "message" => $translator->trans("Permission_groups_assigned")];
2775.         } catch (\Exception $ex) {
2776.             return ["success" => false, "message" => $ex->getMessage()];
2777.         }
2778.     }
2779.     /**
2780.      * Get User List
2781.      */
2782.     public function getUsers($request, $user, $translator, $params, $paginator)
2783.     {
2785.         $result = [];
2786.         $userData = [];
2789.         try {
2791.             if ($user->getOrganization() === null) {
2792.                 return ["success" => false, "message" => $translator->trans("organization_does_not_exists")];
2793.             }
2795.             $organizationId = $user->getOrganization()->getId();
2796.             
2797.             // Get All the Classes
2798.             $class = new \Pimcore\Model\DataObject\ClassDefinition();
2799.             $customer = $class->getDao()->getIdByName('Customer');
2800.             $subscription = $class->getDao()->getIdByName('Subscription');
2801.             $userRole = $class->getDao()->getIdByName('UserRole');
2802.             $organization = $class->getDao()->getIdByName('Organization');
2803.             $package = $class->getDao()->getIdByName('Package');
2805.             $db = Db::get();
2806.             $select = $db->createQueryBuilder();
2807.             $select->select('customer.oo_id');
2808.             $select->from('object_' . $customer, 'customer');
2809.             $select->innerJoin('customer', 'object_' . $subscription, 'subscription', 'customer.oo_id = subscription.subscribedUser__id');
2810.             $select->innerJoin('subscription', 'object_' . $package, 'package', 'package.oo_id = subscription.subscribedPackage__id');
2811.             $select->innerJoin('customer', 'object_' . $organization, 'organization', 'organization.oo_id = customer.organization__id');
2812.             $select->innerJoin('customer', 'object_' . $userRole, 'userRole', 'userRole.oo_id = customer.role__id');
2814.             if (isset($params['search']) && !empty($params['search'])) {
2815.                 $select->andWhere("customer.name LIKE " . $db->quote("%" . $params['search'] . "%") . " OR customer.email LIKE " . $db->quote("%" . $params['search'] . "%"));
2816.             }
2818.             $select->andWhere("userRole.name = " . $db->quote(USER_ROLES['CLIENT_ADMIN']) . " OR userRole.name = " . $db->quote(USER_ROLES['CLIENT_USER']));
2819.             $select->andWhere("customer.oo_id != " . $db->quote($user->getId()));
2820.             $select->andWhere("organization.oo_id = " . $db->quote($organizationId));
2821.             $select->andWhere("customer.isArchive != 1 or customer.isArchive IS NULL");
2823.             if (isset($params['status']) && $params['status'] == true) {
2824.                 $select->andWhere("customer.o_published = 1");
2825.             }
2827.             $select->orderBy('oo_id', 'DESC');
2828.             $select->groupBy(array('oo_id'));
2830.             $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
2831.             $page = isset($params['page']) ? $params['page'] : 1;
2833.             $paginator = $paginator->paginate(
2834.                 $select,
2835.                 $page,
2836.                 $pageSize
2837.             );
2838.             foreach ($paginator as $usersId) {
2840.                 $usersData = DataObject\Customer::getById($usersId['oo_id'], true);
2841.                 if ($usersData instanceof \Pimcore\Model\DataObject\Customer) {
2843.                     // Get Custom Subscription of the organization and package
2844.                     $customSubscriptions = new DataObject\Subscription\Listing();
2845.                     $customSubscriptions->filterBySubscribedUser($usersData);
2846.                     $customSubscriptions->filterByIsActive(true);
2849.                     $status = "Pending";
2850.                     if ($usersData->getToken() == "" && $usersData->isPublished() == true) {
2852.                         if ($customSubscriptions->count() > 0) {
2854.                             $status = "Active";
2855.                         } else {
2857.                             $status = "Suspended";
2858.                         }
2859.                     } elseif ($usersData->getToken() != "" && $usersData->isPublished() == false) {
2861.                         $status = "Pending";
2862.                     }
2865.                     $permissionObj = $this->getUserPermissionInfo($usersData, $translator);
2866.                     $userPermissions = $permissionObj['success'] ? $permissionObj['grants'] : null;
2868.                     $customSubscriptions->filterBySubscriptionType("custom");
2869.                     $customSubscriptions->setOrderKey("o_modificationDate");
2870.                     $customSubscriptions->setOrder("desc");
2871.                     $apiGroupData = [];
2872.                     $packageData = [];
2873.                     $dissAllowedApiGroupID = [];
2875.                     if ($customSubscriptions->count() > 0) {
2876.                         foreach ($customSubscriptions as $key => $customSubscription) {
2877.                             if ($customSubscription instanceof \Pimcore\Model\DataObject\Subscription) {
2878.                                 $package = $customSubscription->getSubscribedPackage();
2880.                                 if ($package) {
2882.                                     $packageData[] = [
2883.                                         "id" => $package->getId(),
2884.                                         "name" => $package->getName(),
2885.                                         "package_expiry" => $customSubscription->getEndDate(date("M d, Y"))
2886.                                     ];
2887.                                 }
2888.                                 $disallowedApiGroups = $customSubscription->getDisallowedApiGroups();
2890.                                 if (count($disallowedApiGroups) > 0) {
2891.                                     foreach ($disallowedApiGroups as $value) {
2892.                                         $dissAllowedApiGroupID[] = $value->getId();
2893.                                     }
2894.                                 }
2896.                                 if ($package) {
2897.                                     $apiGroups = $package->getApiGroups();
2898.                                     if ($apiGroups) {
2899.                                         foreach ($apiGroups as  $apiGroup) {
2900.                                             if (!in_array($apiGroup->getId(), $dissAllowedApiGroupID)) {
2901.                                                 $apiGroupData[] = [
2902.                                                     "id" => $apiGroup->getId(),
2903.                                                     "name" => $apiGroup->getApiGroupName('en'),
2904.                                                     "name_ar" => $apiGroup->getApiGroupName('ar')
2905.                                                 ];
2906.                                             }
2907.                                         }
2908.                                     }
2909.                                 }
2910.                             }
2911.                         }
2912.                     }
2915.                     $typeArray = [
2916.                         "key" => 'user',
2917.                         'name_en' => $translator->trans('user', [], null, 'en'),
2918.                         'name_ar' => $translator->trans('user', [], null, 'ar'),
2919.                     ];
2921.                     $roleArray = [
2922.                         "key" => ($usersData->getRole()) ? $usersData->getRole()->getName() : null,
2923.                         'name_en' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'en') : null,
2924.                         'name_ar' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'ar') : null,
2925.                     ];
2927.                     $statusArray = [
2928.                         "key" => $status,
2929.                         'name_en' => $translator->trans($status, [], null, 'en'),
2930.                         'name_ar' => $translator->trans($status, [], null, 'ar'),
2931.                     ];
2933.                     $userData[] = [
2934.                         'id' => $usersData->getId(),
2935.                         'name' => $usersData->getName(),
2936.                         'title' => $usersData->getTitle(),
2937.                         'email' => $usersData->getEmail(),
2938.                         'phone' => $usersData->getPhoneNo(),
2939.                         'department' => $usersData->getDepartment(),
2940.                         'role' => $roleArray,
2941.                         'organization' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName() : null,
2942.                         'organizationId' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getId() : null,
2943.                         'location' => $this->getLocationList($usersData),
2944.                         'allowCustomNotification' => ($permissionObj['success']) ? $userPermissions['get_custom_notification'] : false,
2945.                         'allowAddLocation' => ($permissionObj['success']) ? $userPermissions['create_location'] : false,
2946.                         'allowForecast' => ($permissionObj['success']) ? $userPermissions['get_weather'] : false,
2947.                         'allowAlertHistoryForCustomAlerts' => ($permissionObj['success']) ? $userPermissions['alert_history'] : false,
2948.                         'automotive' => ($permissionObj['success']) ? $userPermissions['automotive'] : false,
2949.                         'aviation' => ($permissionObj['success']) ? $userPermissions['aviation'] : false,
2950.                         'shippingAndOffshore' => ($permissionObj['success']) ? $userPermissions['shipping_and_offshore'] : false,
2951.                         'insurance' => ($permissionObj['success']) ? $userPermissions['insurance'] : false,
2952.                         'energy' => ($permissionObj['success']) ? $userPermissions['energy'] : false,
2953.                         'type' => $typeArray,
2954.                         'status' => $statusArray,
2955.                         'packageData' => $packageData,
2956.                         'apiGroups' => $apiGroupData,
2957.                         'createdBy' => $usersData->getCreatedBy() ? $usersData->getCreatedBy()->getName() : null,
2958.                         'iqamaId' => $usersData->getIqamaId() ? (string) $usersData->getIqamaId() : null,
2959.                         //'token' => $status == "Pending" ? $usersData->getToken() : '',
2960.                     ];
2961.                 }
2962.             }
2965.             if (!$paginator->count()) {
2966.                 return ["success" => false, "message" => $translator->trans("no_user_available_to_this_organization.")];
2967.             }
2968.             return ["success" => TRUE, "data" => $userData, 'paginationVariables' => $paginator->getPaginationData()];
2969.         } catch (\Exception $ex) {
2970.             throw new \Exception($ex->getMessage());
2971.         }
2973.         return $result;
2974.     }
2976.     // /**
2977.     //  * set package subscription
2978.     //  */
2979.     // public function setPcakageSubscription($params)
2980.     // {
2981.     //     $result = [];
2983.     //     try {
2985.     //         $apiGroup = $this->createApiGrpup($params);
2987.     //         $package = new DataObject\Package();
2988.     //         $package->setParent(DataObject\Service::createFolderByPath('/UserManagement/Packages/CustomPackages/'));
2989.     //         $package->setKey(\Pimcore\Model\Element\Service::getValidKey($apiGroup->getId() . time(), 'object'));
2990.     //         $package->setApiGroups([$apiGroup]);
2991.     //         $package->setTenure(1);
2992.     //         $package->setMaxLocation(100);
2993.     //         $package->setMaxUsers(100);
2994.     //         $package->setIsActive(true);
2995.     //         $package->setPublished(true);
2996.     //         $package->save();
2997.     //         $subscription = $this->setSubscription($package, $params['user']);
2998.     //         if ($subscription instanceof DataObject\Subscription) {
2999.     //             return ["success" => true, "message" => "set_subscription."];
3000.     //         }
3001.     //         //return $subscription;
3002.     //     } catch (\Exception $ex) {
3003.     //         throw new \Exception($ex->getMessage());
3004.     //     }
3006.     //     return $result;
3007.     // }
3009.     /**
3010.      * set create subscription
3011.      */
3012.     public function setSubscription($package, $user, $disallowedApiGroupsArray, $subscriptionType, $isNoExpiry = false)
3013.     {
3014.         $result = [];
3015.         try {
3017.             if (!$package instanceof DataObject\Package) {
3018.                 return ["success" => false, "message" => "Package is not available"];
3019.             }
3020.             if (!$user instanceof DataObject\Customer) {
3021.                 return ["success" => false, "message" => "User is not available"];
3022.             }
3024.             $organization = $user->getOrganization();
3026.             if (!$organization instanceof DataObject\Organization) {
3027.                 return ["success" => false, "message" => "Organization is not available"];
3028.             }
3030.             $packageActivationDate = $organization->getPackageActivationDate();
3032.             if (!$packageActivationDate || strtotime($packageActivationDate) === false) {
3033.                 $packageActivationDate = date('Y-m-d');
3034.             } else {
3035.                 $packageActivationDate = date('Y-m-d', strtotime($packageActivationDate));
3036.             }
3037.             // Set Subscription Expiry
3038.             $subscriptionExpiry = date('Y-m-d', strtotime('+' . $organization->getTrialLimit() . ' days', strtotime($packageActivationDate)));
3042.             $subscription = new DataObject\Subscription();
3043.             $subscription->setParent(DataObject\Service::createFolderByPath('/UserManagement/Subscriptions/' . $user->getEmail()));
3044.             $subscription->setKey(\Pimcore\Model\Element\Service::getValidKey($package->getId() . time() . rand(1000, 10000), 'object'));
3045.             $subscription->setSubscribedPackage($package);
3046.             $subscription->setSubscribedUser($user);
3048.             //Set Disallowed ApiGroups
3049.             if ($disallowedApiGroupsArray != null) {
3052.                 $disallowedApiGroups = [];
3053.                 foreach ($disallowedApiGroupsArray as $disallowedApiGroupsId) {
3054.                     $apiGroup =  DataObject\APIGroup::getById($disallowedApiGroupsId, true);
3055.                     $disallowedApiGroups[] = $apiGroup;
3056.                 }
3057.                 $subscription->setDisallowedApiGroups($disallowedApiGroups);
3058.             }
3059.             //$subscription->setDisallowedApis($disAllowPermissions);
3060.             $subscription->setSubscriptionType($subscriptionType);
3061.             $subscription->setStartDate(Carbon::parse(new \Datetime(date('Y-m-d'))));
3062.             $subscription->setEndDate(Carbon::parse(new \Datetime($subscriptionExpiry)));
3063.             $subscription->setIsNoExpiry($isNoExpiry);
3064.             $subscription->setIsActive(true);
3065.             $subscription->setPublished(true);
3066.             $subscription->save();
3068.             return  $subscription;
3069.         } catch (\Exception $ex) {
3070.             throw new \Exception($ex->getMessage());
3071.         }
3072.         return $result;
3073.     }
3076.     /**
3077.      * set NCM User subscription
3078.      */
3079.     public function setNcmUserSubscription($role, $user, $allowedApiGrpups, $isNoExpiry = false)
3080.     {
3081.         $result = [];
3082.         try {
3086.             if ($role instanceof DataObject\UserRole) {
3088.                 $packages = $role->getDefaultPackages();
3089.                 if ($packages) {
3090.                     $defaultPackage = $packages[0];
3091.                     if ($defaultPackage instanceof DataObject\Package) {
3092.                         $subscription = new DataObject\Subscription();
3093.                         $subscription->setParent(DataObject\Service::createFolderByPath('/UserManagement/Subscriptions/NCM Users/' . $user->getEmail()));
3094.                         $subscription->setKey(\Pimcore\Model\Element\Service::getValidKey($defaultPackage->getId() . time() . uniqid(), 'object'));
3095.                         $subscription->setSubscribedPackage($defaultPackage);
3096.                         $subscription->setSubscribedUser($user);
3098.                         //Set allowed ApiGroups
3099.                         if ($allowedApiGrpups != null) {
3102.                             $allowedApiGrpupsArray = [];
3103.                             foreach ($allowedApiGrpups as $allowedApiGrpupId) {
3104.                                 $apiGroup =  DataObject\APIGroup::getById($allowedApiGrpupId, true);
3105.                                 if ($apiGroup) {
3106.                                     $allowedApiGrpupsArray[] = $apiGroup;
3107.                                 }
3108.                             }
3110.                             $subscription->setAllowedApiGroups($allowedApiGrpupsArray);
3111.                         }
3114.                         $subscriptionExpiry = date('Y-m-d', strtotime('+' . $defaultPackage->getTenure() . ' days'));
3116.                         $subscription->setSubscriptionType("default");
3117.                         $subscription->setStartDate(Carbon::parse(new \Datetime(date('Y-m-d'))));
3118.                         $subscription->setEndDate(Carbon::parse(new \Datetime($subscriptionExpiry)));
3119.                         $subscription->setIsNoExpiry($isNoExpiry);
3120.                         $subscription->setIsActive(true);
3121.                         $subscription->setPublished(true);
3122.                         $subscription->save();
3124.                         return $subscription;
3125.                     }
3126.                 }
3127.             }
3128.         } catch (\Exception $ex) {
3129.             throw new \Exception($ex->getMessage());
3130.         }
3131.         return $result;
3132.     }
3135.     /**
3136.      * set create subscription
3137.      */
3138.     public function updateSubscription($package, $user, $disAllowPermissions, $subscriptionType = "custom")
3139.     {
3140.         $result = [];
3142.         try {
3144.             if (!$package instanceof DataObject\Package) {
3145.                 return ["success" => false, "message" => "Package is not available"];
3146.             }
3147.             if (!$user instanceof DataObject\Customer) {
3148.                 return ["success" => false, "message" => "User is not available"];
3149.             }
3150.             $subscriptionExpiry = date('Y-m-d', strtotime('+' . $package->getTenure() . ' days'));
3152.             $customSubscriptions = new DataObject\Subscription\Listing();
3153.             $customSubscriptions->filterBySubscribedUser($user);
3154.             $customSubscriptions->filterBySubscriptionType($subscriptionType);
3155.             //$customSubscriptions->filterByIsActive(true);
3156.             $updateSubscription = $customSubscriptions->current();
3157.             if (!$updateSubscription instanceof  DataObject\Subscription) {
3158.                 $updateSubscription = new DataObject\Subscription();
3159.                 $updateSubscription->setParent(DataObject\Service::createFolderByPath('/UserManagement/Subscriptions/' . $user->getEmail()));
3160.                 $updateSubscription->setKey(\Pimcore\Model\Element\Service::getValidKey($package->getId() . time() . rand(1000, 10000), 'object'));
3161.                 $updateSubscription->setStartDate(Carbon::parse(new \Datetime(date('Y-m-d'))));
3162.                 $updateSubscription->setEndDate(Carbon::parse(new \Datetime($subscriptionExpiry)));
3163.                 $updateSubscription->setIsActive(true);
3164.                 $updateSubscription->setSubscriptionType($subscriptionType);
3165.                 $updateSubscription->setPublished(true);
3166.                 $updateSubscription->setSubscribedUser($user);
3167.             }
3168.             $updateSubscription->setSubscribedPackage($package);
3169.             if ($subscriptionType == 'default') {
3170.                 $updateSubscription->setIsNoExpiry(true);
3171.             }
3172.             $updateSubscription->save();
3174.             return  $updateSubscription;
3175.         } catch (\Exception $ex) {
3176.             throw new \Exception($ex->getMessage());
3177.         }
3178.         return $result;
3179.     }
3182.     /**
3183.      * Update NCM User Subscription
3184.      */
3185.     public function updateNCMUserSubscription($user, $allowedApiGroups)
3186.     {
3187.         $result = [];
3188.         try {
3189.             if (!$user instanceof DataObject\Customer) {
3190.                 return ["success" => false, "message" => "User is not available"];
3191.             }
3193.             $subscriptionListing = new DataObject\Subscription\Listing();
3194.             $subscriptionListing->filterBySubscribedUser($user);
3195.             $subscriptionListing->filterByIsActive(true);
3197.             // Fetch all active subscriptions
3198.             $activeSubscriptions = iterator_to_array($subscriptionListing);
3200.             if (count($activeSubscriptions) === 0) {
3201.                 $defaultPackage = $user->getRole()?->getDefaultPackages()[0] ?? null;
3203.                 if ($defaultPackage instanceof DataObject\Package) {
3204.                     $subscription = new DataObject\Subscription();
3205.                     $subscription->setParent(DataObject\Service::createFolderByPath('/UserManagement/Subscriptions/NCM Users/' . $user->getEmail()));
3206.                     $subscription->setKey(\Pimcore\Model\Element\Service::getValidKey($defaultPackage->getId() . time() . uniqid(), 'object'));
3207.                     $subscription->setSubscribedPackage($defaultPackage);
3208.                     $subscription->setSubscribedUser($user);
3209.                     $subscription->setStartDate(Carbon::parse(new \DateTime(date('Y-m-d'))));
3210.                     // Set end date to one month from today
3211.                     $subscription->setEndDate(Carbon::now()->addMonth());
3212.                     $subscription->setIsNoExpiry(true);
3213.                     $subscription->setIsActive(true);
3214.                     $subscription->setPublished(false);
3215.                     $subscription->save();
3217.                     $activeSubscriptions = [$subscription];
3218.                 }
3219.             }
3221.             // Unpublish all active subscriptions except the first one
3222.             foreach ($activeSubscriptions as $index => $subscription) {
3223.                 if ($index > 0) {
3224.                     $subscription->setPublished(false);
3225.                     $subscription->save();
3226.                 }
3227.             }
3229.             // Update the first subscription if it exists
3230.             $updateSubscription = $activeSubscriptions[0] ?? null;
3232.             if ($updateSubscription instanceof DataObject\Subscription) {
3233.                 // Set allowed ApiGroups
3234.                 if (!empty($allowedApiGroups)) {
3235.                     $allowedApiGroupsArray = [];
3236.                     foreach ($allowedApiGroups as $allowedApiGroupId) {
3237.                         $apiGroup = DataObject\APIGroup::getById($allowedApiGroupId, true);
3238.                         if ($apiGroup) {
3239.                             $allowedApiGroupsArray[] = $apiGroup;
3240.                         }
3241.                     }
3242.                     $updateSubscription->setAllowedApiGroups($allowedApiGroupsArray);
3243.                 }
3245.                 $updateSubscription->setSubscriptionType("default");
3246.                 $updateSubscription->setParent(DataObject\Service::createFolderByPath('/UserManagement/Subscriptions/NCM Users/' . $user->getEmail()));
3247.                 $updateSubscription->save();
3249.                 return $updateSubscription;
3250.             }
3251.         } catch (\Exception $ex) {
3252.             throw new \Exception($ex->getMessage());
3253.         }
3255.         return $result;
3256.     }
3259.     /**
3260.      * set package subscription
3261.      */
3262.     public function createApiGrpup($params)
3263.     {
3264.         $result = [];
3266.         try {
3268.             $mergedArray = [];
3270.             if (isset($params['allowAddLocation']) && $params['allowAddLocation'] === true) {
3271.                 foreach (USER_PERMISSIONS['is_allow_location'] as $value) {
3272.                     $mergedArray[] = $value;
3273.                 }
3274.             }
3276.             if (isset($params['is_allow_user']) && $params['is_allow_user']   === true) {
3278.                 foreach (USER_PERMISSIONS['is_allow_user'] as $value) {
3279.                     $mergedArray[] = $value;
3280.                 }
3281.             }
3283.             if (isset($params['is_allow_ncm_user']) && $params['is_allow_ncm_user']  === true) {
3284.                 foreach (USER_PERMISSIONS['is_allow_ncm_user'] as $value) {
3285.                     $mergedArray[] = $value;
3286.                 }
3287.             }
3289.             if (isset($params['is_allow_organization']) && $params['is_allow_organization']  === true) {
3290.                 foreach (USER_PERMISSIONS['is_allow_organization'] as $value) {
3291.                     $mergedArray[] = $value;
3292.                 }
3293.             }
3295.             if (isset($params['is_allow_ncm_organization']) && $params['is_allow_ncm_organization']  === true) {
3296.                 foreach (USER_PERMISSIONS['is_allow_ncm_organization'] as $value) {
3297.                     $mergedArray[] = $value;
3298.                 }
3299.             }
3301.             if (isset($params['is_allow_custom_notification']) && $params['is_allow_custom_notification']  === true) {
3302.                 foreach (USER_PERMISSIONS['is_allow_custom_notification'] as $value) {
3303.                     $mergedArray[] = $value;
3304.                 }
3305.             }
3307.             if (isset($params['is_allow_weather_forecast']) && $params['is_allow_weather_forecast']  === true) {
3308.                 foreach (USER_PERMISSIONS['is_allow_weather_forecast'] as $key => $value) {
3309.                     $mergedArray[] = $value;
3310.                 }
3311.             }
3312.             if (isset($params['is_allow_alert']) && $params['is_allow_alert']  === true) {
3313.                 foreach (USER_PERMISSIONS['is_allow_alert'] as $value) {
3314.                     $mergedArray[] = $value;
3315.                 }
3316.             }
3318.             if (isset($params['is_allow_report']) && $params['is_allow_report']  === true) {
3319.                 foreach (USER_PERMISSIONS['is_allow_report'] as $value) {
3320.                     $mergedArray[] = $value;
3321.                 }
3322.             }
3323.             if (isset($params['is_allow_weather_warnings']) && $params['is_allow_weather_warnings']  === true) {
3324.                 foreach (USER_PERMISSIONS['is_allow_weather_warnings'] as $value) {
3325.                     $mergedArray[] = $value;
3326.                 }
3327.             }
3328.             if (isset($params['is_energy']) && $params['is_energy']  === true) {
3329.                 foreach (USER_PERMISSIONS['is_energy'] as $value) {
3330.                     $mergedArray[] = $value;
3331.                 }
3332.             }
3333.             if (isset($params['is_insurance']) && $params['is_insurance']  === true) {
3334.                 foreach (USER_PERMISSIONS['is_insurance'] as $value) {
3335.                     $mergedArray[] = $value;
3336.                 }
3337.             }
3338.             if (isset($params['is_shippingAndOffshore']) && $params['is_shippingAndOffshore']  === true) {
3339.                 foreach (USER_PERMISSIONS['is_shippingAndOffshore'] as $value) {
3340.                     $mergedArray[] = $value;
3341.                 }
3342.             }
3343.             if (isset($params['is_automotive']) && $params['is_automotive']  === true) {
3344.                 foreach (USER_PERMISSIONS['is_automotive'] as $value) {
3345.                     $mergedArray[] = $value;
3346.                 }
3347.             }
3348.             if (isset($params['is_aviation']) && $params['is_aviation']  === true) {
3349.                 foreach (USER_PERMISSIONS['is_aviation'] as $value) {
3350.                     $mergedArray[] = $value;
3351.                 }
3352.             }
3354.             if (isset($params['is_agriculture']) && $params['is_agriculture']  === true) {
3355.                 foreach (USER_PERMISSIONS['is_agriculture'] as $value) {
3356.                     $mergedArray[] = $value;
3357.                 }
3358.             }
3359.             if (isset($params['invitingClients']) && $params['invitingClients']  === true) {
3360.                 foreach (USER_PERMISSIONS['invitingClients'] as $value) {
3361.                     $mergedArray[] = $value;
3362.                 }
3363.             }
3364.             if (isset($params['managingClients']) && $params['managingClients']  === true) {
3365.                 foreach (USER_PERMISSIONS['managingClients'] as $value) {
3366.                     $mergedArray[] = $value;
3367.                 }
3368.             }
3369.             if (isset($params['deletingClients']) && $params['deletingClients']  === true) {
3370.                 foreach (USER_PERMISSIONS['deletingClients'] as $value) {
3371.                     $mergedArray[] = $value;
3372.                 }
3373.             }
3374.             if (isset($params['invitingNCMAdmin']) && $params['invitingNCMAdmin']  === true) {
3375.                 foreach (USER_PERMISSIONS['invitingNCMAdmin'] as $value) {
3376.                     $mergedArray[] = $value;
3377.                 }
3378.             }
3379.             if (isset($params['managingNCMAdmin']) && $params['managingNCMAdmin']  === true) {
3380.                 foreach (USER_PERMISSIONS['managingNCMAdmin'] as $value) {
3381.                     $mergedArray[] = $value;
3382.                 }
3383.             }
3384.             if (isset($params['deletingNCMAdmin']) && $params['deletingNCMAdmin']  === true) {
3385.                 foreach (USER_PERMISSIONS['deletingNCMAdmin'] as $value) {
3386.                     $mergedArray[] = $value;
3387.                 }
3388.             }
3391.             // Get unique values using array_unique()
3392.             $uniqueValues = array_unique(array_values($mergedArray));
3393.             $userPermission  = array_values($uniqueValues);
3395.             $apiGroup = new DataObject\APIGroup();
3396.             $apiGroup->setParent(DataObject\Service::createFolderByPath('/UserManagement/APIGroups/CustomAPIGroups/'));
3397.             $apiGroup->setKey(\Pimcore\Model\Element\Service::getValidKey($userPermission[0] . time(), 'object'));
3399.             $apiGroup->setIsActive(true);
3400.             $apiGroup->setAllowedApis($userPermission);
3401.             $apiGroup->setPublished(true);
3402.             $apiGroup->save();
3404.             return $apiGroup;
3405.         } catch (\Exception $ex) {
3406.             throw new \Exception($ex->getMessage());
3407.         }
3409.         return $result;
3410.     }
3413.     /**
3414.      * set User Permissions
3415.      */
3416.     public function setUserPermissions($params)
3417.     {
3418.         $result = [];
3420.         try {
3422.             // check if all permissions are given than now need to create seperate role 
3423.             $loggedInUserRole = ($params['loggedInUser']->getRole() ? $params['loggedInUser']->getRole()->getName() : null);
3424.             $invitedUserRoleName = ($params['user']->getRole() ? $params['user']->getRole()->getName() : null);
3426.             if ($loggedInUserRole == USER_ROLES['NCM_OPERATOR'] || $loggedInUserRole == USER_ROLES['NCM_IT']) {
3427.                 if ($params['allowCustomNotification'] == true && $params['allowAddLocation'] == true && $params['allowAlertHistoryForCustomAlerts'] == true && $params['allowForecast'] == true && $params['allowOrganizationAdminToInviteUsers'] == true) {
3428.                     // delete specific role if all permission are given
3429.                     $permission = DataObject\Permission::getByAllowedUserRole($params['user'], true);
3430.                     if ($permission instanceof \Pimcore\Model\DataObject\Permission) {
3431.                         $permission->delete();
3432.                     }
3433.                     return ["success" => true, "message" => "Set Permission."];
3434.                 }
3435.             } else {
3436.                 if (
3437.                     $params['allowCustomNotification'] == true &&
3438.                     $params['allowAddLocation'] == true &&
3439.                     $params['allowAlertHistoryForCustomAlerts'] == true &&
3440.                     $params['allowForecast'] == true  &&
3441.                     $params['automotive'] == true &&
3442.                     $params['aviation'] == true &&
3443.                     $params['insurance'] == true &&
3444.                     $params['energy'] == true
3445.                 ) {
3446.                     // delete specific role if all permission are given
3447.                     $permission = DataObject\Permission::getByAllowedUserRole($params['user'], true);
3448.                     if ($permission instanceof \Pimcore\Model\DataObject\Permission) {
3449.                         $permission->delete();
3450.                     }
3451.                     return ["success" => true, "message" => "set_permission"];
3452.                 }
3453.             }
3455.             $permission = DataObject\Permission::getByAllowedUserRole($params['user'], true);
3456.             if ($permission) {
3457.                 // $permission->setDepartment($allowAlertHistoryForCustomAlerts);
3458.                 $permission->setAlert_history($params['allowAlertHistoryForCustomAlerts']);
3459.                 $permission->setGet_custom_notification($params['allowCustomNotification']);
3461.                 $permission->setCreate_location($params['allowAddLocation']);
3462.                 $permission->setGet_weather($params['allowForecast']);
3465.                 // set Industry permissions
3466.                 $permission->setAutomotive($params['automotive'] == false ? false : true);
3467.                 $permission->setAviation($params['aviation'] == false ? false : true);
3468.                 $permission->setShipping_and_offshore($params['shippingAndOffshore'] == false ? false : true);
3469.                 $permission->setInsurance($params['insurance'] == false ? false : true);
3470.                 $permission->setEnergy($params['energy'] == false ? false : true);
3473.                 // default permission on the basis of add location
3474.                 if (false == $params['allowAddLocation']) {
3475.                     $permission->setEdit_location(false);
3476.                     $permission->setDelete_location(false);
3477.                     $permission->setSearch_location(false);
3478.                     $permission->setCompare_location(false);
3479.                 } else {
3480.                     $permission->setEdit_location(true);
3481.                     $permission->setDelete_location(true);
3482.                     $permission->setSearch_location(true);
3483.                     $permission->setCompare_location(true);
3484.                 }
3486.                 // default permission on the basis of add invite user
3487.                 if ($params['allowOrganizationAdminToInviteUsers'] == true || $invitedUserRoleName == USER_ROLES['CLIENT_ADMIN']) {
3488.                     $permission->setEdit_user(true);
3489.                     $permission->setDelete_user(true);
3490.                     $permission->setList_user(true);
3491.                     $permission->setSuspend_user(true);
3492.                     $permission->setInvite_user(true);
3493.                     $permission->setResend_invite(true);
3494.                     $permission->setCreate_user(true);
3495.                 } else {
3496.                     $permission->setEdit_user(false);
3497.                     $permission->setDelete_user(false);
3498.                     $permission->setList_user(false);
3499.                     $permission->setSuspend_user(false);
3500.                     $permission->setInvite_user(false);
3501.                     $permission->setResend_invite(false);
3502.                     $permission->setCreate_user(false);
3503.                 }
3505.                 // default permission to any user
3506.                 $permission->setGet_profile(true);
3507.                 $permission->setUpdate_profile(true);
3508.                 $permission->setChange_password(true);
3509.                 $permission->setView_user(true);
3510.                 $permission->setList_location(true);
3511.                 $permission->setView_location(true);
3513.                 $permission->setAllowedUserRole($params['user']);
3514.                 $permission->save();
3515.             } else {
3517.                 $permissions = new DataObject\Permission();
3518.                 $permissions->setParent(DataObject\Service::createFolderByPath('/UserManagement/Permission/User'));
3519.                 $permissions->setKey($params['user']->getEmail());
3520.                 // $permissions->setDepartment($allowAlertHistoryForCustomAlerts);
3522.                 $permissions->setAlert_history($params['allowAlertHistoryForCustomAlerts']);
3523.                 $permissions->setGet_custom_notification($params['allowCustomNotification']);
3524.                 $permissions->setInvite_user($params['allowOrganizationAdminToInviteUsers']);
3525.                 $permissions->setCreate_location($params['allowAddLocation']);
3526.                 $permissions->setGet_weather($params['allowForecast']);
3529.                 // set Industry permissions
3530.                 $permissions->setAutomotive($params['automotive'] == false ? false : true);
3531.                 $permissions->setAviation($params['aviation'] == false ? false : true);
3532.                 $permissions->setShipping_and_offshore($params['shippingAndOffshore'] == false ? false : true);
3533.                 $permissions->setInsurance($params['insurance'] == false ? false : true);
3534.                 $permissions->setEnergy($params['energy'] == false ? false : true);
3536.                 // default permission on the basis of add location
3537.                 if ($params['allowAddLocation'] == true) {
3539.                     $permissions->setEdit_location(true);
3540.                     $permissions->setDelete_location(true);
3541.                     $permissions->setSearch_location(true);
3542.                     $permissions->setCompare_location(true);
3543.                 } else {
3544.                     $permissions->setEdit_location(false);
3545.                     $permissions->setDelete_location(false);
3546.                     $permissions->setSearch_location(false);
3547.                     $permissions->setCompare_location(false);
3548.                 }
3550.                 // default permission on the basis of add invite user
3551.                 if ($params['allowOrganizationAdminToInviteUsers'] == true || $invitedUserRoleName == USER_ROLES['CLIENT_ADMIN']) {
3552.                     $permissions->setEdit_user(true);
3553.                     $permissions->setDelete_user(true);
3554.                     $permissions->setList_user(true);
3555.                     $permissions->setSuspend_user(true);
3556.                     $permissions->setInvite_user(true);
3557.                     $permissions->setResend_invite(true);
3558.                     $permissions->setCreate_user(true);
3559.                 } else {
3560.                     $permissions->setEdit_user(false);
3561.                     $permissions->setDelete_user(false);
3562.                     $permissions->setList_user(false);
3563.                     $permissions->setSuspend_user(false);
3564.                     $permissions->setInvite_user(false);
3565.                     $permissions->setResend_invite(false);
3566.                     $permissions->setCreate_user(false);
3567.                 }
3569.                 // default permission to any user
3570.                 $permissions->setGet_profile(true);
3571.                 $permissions->setUpdate_profile(true);
3572.                 $permissions->setChange_password(true);
3573.                 $permissions->setView_user(true);
3574.                 $permissions->setList_location(true);
3575.                 $permissions->setView_location(true);
3577.                 $permissions->setAllowedUserRole($params['user']);
3578.                 $permissions->setPublished(true);
3579.                 $permissions->save();
3580.             }
3582.             return ["success" => true, "message" => "set_permission."];
3583.         } catch (\Exception $ex) {
3584.             throw new \Exception($ex->getMessage());
3585.         }
3587.         return $result;
3588.     }
3590.     /**
3591.      * set NCM Admin User Permissions
3592.      */
3593.     public function setNCMAdminUserPermissions($params)
3594.     {
3595.         $result = [];
3597.         try {
3600.             if ($params['invitingClients'] == false || $params['managingClients'] == false || $params['deletingClients'] == false || $params['invitingNCMAdmin'] == false || $params['managingNCMAdmin'] == false || $params['deletingNCMAdmin'] == false) {
3602.                 $permission = DataObject\Permission::getByAllowedUserRole($params['user'], true);
3603.                 if ($permission) {
3605.                     // default permission to any user
3606.                     $permission->setGet_profile(true);
3607.                     $permission->setUpdate_profile(true);
3608.                     $permission->setChange_password(true);
3609.                     $permission->setView_user(true);
3610.                     $permission->setList_location(true);
3611.                     $permission->setView_location(true);
3612.                     $permission->setEdit_location(true);
3613.                     $permission->setDelete_location(true);
3614.                     $permission->setSearch_location(true);
3615.                     $permission->setCompare_location(true);
3616.                     $permission->setList_ncm_user(true);
3617.                     $permission->setList_user(true);
3619.                     // set Industry permissions
3620.                     $permission->setAutomotive(true);
3621.                     $permission->setAviation(true);
3622.                     $permission->setShipping_and_offshore(true);
3623.                     $permission->setInsurance(true);
3624.                     $permission->setEnergy(true);
3626.                     // set invitingClients permissions
3627.                     $permission->setInvite_user($params['invitingClients'] == false ? false : true);
3628.                     $permission->setInvite_organization($params['invitingClients'] == false ? false : true);
3629.                     $permission->setResend_invite($params['invitingClients'] == false ? false : true);
3631.                     // set managingClients permissions
3632.                     $permission->setEdit_user($params['managingClients'] == false ? false : true);
3634.                     // set deletingClients permissions
3635.                     $permission->setDelete_user($params['deletingClients'] == false ? false : true);
3637.                     // set invitingNCMAdmin permissions
3638.                     $permission->setInvite_ncm_user($params['invitingNCMAdmin'] == false ? false : true);
3640.                     // set managingNCMAdmin permissions
3641.                     $permission->setEdit_ncm_user($params['managingNCMAdmin'] == false ? false : true);
3643.                     // set deletingNCMAdmin permissions
3644.                     $permission->setDelete_ncm_user($params['deletingNCMAdmin'] == false ? false : true);
3646.                     $permission->setAllowedUserRole($params['user']);
3648.                     $permission->save();
3649.                 } else {
3651.                     $permissions = new DataObject\Permission();
3652.                     $permissions->setParent(DataObject\Service::createFolderByPath('/UserManagement/Permission/User'));
3653.                     $permissions->setKey($params['user']->getEmail());
3654.                     // $permissions->setDepartment($allowAlertHistoryForCustomAlerts);
3656.                     // default permission to any user
3657.                     $permissions->setGet_profile(true);
3658.                     $permissions->setUpdate_profile(true);
3659.                     $permissions->setChange_password(true);
3660.                     $permissions->setView_user(true);
3661.                     $permissions->setList_location(true);
3662.                     $permissions->setView_location(true);
3663.                     $permissions->setList_ncm_user(true);
3664.                     $permissions->setList_user(true);
3666.                     // set Industry permissions
3667.                     $permissions->setAutomotive(true);
3668.                     $permissions->setAviation(true);
3669.                     $permissions->setShipping_and_offshore(true);
3670.                     $permissions->setInsurance(true);
3671.                     $permissions->setEnergy(true);
3673.                     // set invitingClients permissions
3674.                     $permissions->setInvite_user($params['invitingClients'] == false ? false : true);
3675.                     $permissions->setInvite_organization($params['invitingClients'] == false ? false : true);
3676.                     $permissions->setResend_invite($params['invitingClients'] == false ? false : true);
3678.                     // set managingClients permissions
3679.                     $permissions->setEdit_user($params['managingClients'] == false ? false : true);
3681.                     // set deletingClients permissions
3682.                     $permissions->setDelete_user($params['deletingClients'] == false ? false : true);
3684.                     // set invitingNCMAdmin permissions
3685.                     $permissions->setInvite_ncm_user($params['invitingNCMAdmin'] == false ? false : true);
3687.                     // set managingNCMAdmin permissions
3688.                     $permissions->setEdit_ncm_user($params['managingNCMAdmin'] == false ? false : true);
3690.                     // set deletingNCMAdmin permissions
3691.                     $permissions->setDelete_ncm_user($params['deletingNCMAdmin'] == false ? false : true);
3693.                     $permissions->setAllowedUserRole($params['user']);
3695.                     $permissions->setPublished(true);
3696.                     $permissions->save();
3697.                 }
3699.                 return ["success" => true, "message" => "set_permission"];
3700.             } else {
3701.                 // delete specific role if all permission are given
3702.                 $permission = DataObject\Permission::getByAllowedUserRole($params['user'], true);
3703.                 if ($permission instanceof \Pimcore\Model\DataObject\Permission) {
3704.                     $permission->delete();
3705.                 }
3707.                 return ["success" => true, "message" => "set_permission"];
3708.             }
3709.         } catch (\Exception $ex) {
3710.             throw new \Exception($ex->getMessage());
3711.         }
3713.         return $result;
3714.     }
3716.     public function getUserPermissionInfo($user, $translator)
3717.     {
3719.         $userEmail = [];
3720.         $userEmail['username'] = $user->getEmail();
3721.         // return $permission = DataObject\Permission::getByAllowedUserRole($user, true);
3722.         return $permission = $this->userPermission->getUserPermissions($userEmail, $translator);
3723.     }
3725.     public function getLocationList($user)
3726.     {
3727.         try {
3728.             $entries = new DataObject\Location\Listing();
3729.             $entries->setCondition("user LIKE " . $entries->quote("%," . $user->getId() . ",%"));
3730.             $entries->load();
3731.             $tempArr = [];
3732.             if (!empty($entries)) {
3733.                 foreach ($entries as $object) {
3734.                     array_push($tempArr, $object->getId());
3735.                 }
3736.             }
3737.             return $tempArr;
3738.         } catch (\Exception $ex) {
3739.             throw new \Exception($ex->getMessage());
3740.         }
3741.     }
3743.     public function assignLocationToUser($loggedInUser, $locationIds, $locationTagIds, $targetUsers, $targetUserGroups, $weatherSevereAlert, $customNotificationAlert, $translator)
3744.     {
3745.         $assignedLocationArr = [];
3747.         // Validate all users and user groups upfront
3749.         $validatedUsers = [];
3750.         if ($targetUsers) {
3751.             foreach ($targetUsers as $userId) {
3752.                 $user = \Pimcore\Model\DataObject::getById($userId);
3753.                 if (!$user instanceof Customer) {
3755.                     return ["success" => false, "message" => $translator->trans("Invalid User ID"), "userId" => $userId];
3756.                 }
3757.                 $organizationMatch = \App\Lib\Utility::matchOrganization($user, $loggedInUser);
3758.                 if (!$organizationMatch["success"]) {
3760.                     return ["success" => false, "message" => $translator->trans("User ID does not belong to your organization."), "userId" => $userId];
3761.                 }
3762.                 $validatedUsers[] = $user;
3763.             }
3764.         }
3766.         $validatedUserGroups = [];
3767.         if ($targetUserGroups) {
3768.             foreach ($targetUserGroups as $userGroupId) {
3769.                 $userGroup = \Pimcore\Model\DataObject::getById($userGroupId);
3770.                 if (!$userGroup instanceof UserGroup) {
3771.                     return ["success" => false, "message" => $translator->trans("Invalid User Group ID"), "userGroupId" => $userGroupId];
3772.                 }
3773.                 $targetUsersInGroup = new DataObject\Customer\Listing();
3774.                 $targetUsersInGroup->filterByUserGroup($userGroup);
3775.                 foreach ($targetUsersInGroup as $user) {
3776.                     $organizationMatch = \App\Lib\Utility::matchOrganization($user, $loggedInUser);
3777.                     if (!$organizationMatch["success"]) {
3778.                         return ["success" => false, "message" => $translator->trans("A user in group ID does not belong to your organization."), "userGroupId" => $userGroupId];
3779.                     }
3780.                 }
3781.                 $validatedUserGroups[] = $userGroup;
3782.             }
3783.         }
3786.         // Process Locations by Location IDs
3787.         if ($locationIds) {
3788.             foreach ($locationIds as $locationID) {
3789.                 $location = \Pimcore\Model\DataObject::getById($locationID);
3790.                 if ($location instanceof Location) {
3791.                     // Assign to validated users
3792.                     foreach ($validatedUsers as $user) {
3793.                         $this->locationModel->locationMetaData($location, $user, $weatherSevereAlert, $customNotificationAlert);
3794.                         $assignedLocationArr[] = $location->getId();
3795.                     }
3797.                     // Assign to validated user groups
3798.                     foreach ($validatedUserGroups as $userGroup) {
3799.                         $targetUsersInGroup = new DataObject\Customer\Listing();
3800.                         $targetUsersInGroup->filterByUserGroup($userGroup);
3801.                         foreach ($targetUsersInGroup as $user) {
3802.                             $this->locationModel->locationMetaData($location, $user, $weatherSevereAlert, $customNotificationAlert);
3803.                             $assignedLocationArr[] = $location->getId();
3804.                         }
3805.                     }
3806.                 } else {
3807.                     return ["success" => false, "message" => $translator->trans("Invalid Location ID"), "locationId" => $locationID];
3808.                 }
3809.             }
3810.         }
3812.         // Process Locations by Location Tag IDs
3813.         if ($locationTagIds) {
3814.             foreach ($locationTagIds as $locationTagId) {
3815.                 $locationTag = \Pimcore\Model\DataObject::getById($locationTagId);
3816.                 if ($locationTag instanceof Tags) {
3817.                     $locations = new DataObject\Location\Listing();
3819.                     $locations->setCondition("Tag LIKE " . $locations->quote("%," . $locationTag->getId() . ",%"));
3821.                     $locations->load();
3823.                     foreach ($locations as $location) {
3824.                         if ($location instanceof Location) {
3825.                             // Assign to validated users
3826.                             foreach ($validatedUsers as $user) {
3827.                                 $this->locationModel->locationMetaData($location, $user, $weatherSevereAlert, $customNotificationAlert);
3828.                                 $assignedLocationArr[] = $location->getId();
3829.                             }
3831.                             // Assign to validated user groups
3832.                             foreach ($validatedUserGroups as $userGroup) {
3833.                                 $targetUsersInGroup = new DataObject\Customer\Listing();
3834.                                 $targetUsersInGroup->filterByUserGroup($userGroup);
3835.                                 foreach ($targetUsersInGroup as $user) {
3836.                                     $this->locationModel->locationMetaData($location, $user, $weatherSevereAlert, $customNotificationAlert);
3837.                                     $assignedLocationArr[] = $location->getId();
3838.                                 }
3839.                             }
3840.                         }
3841.                     }
3842.                 } else {
3843.                     return ["success" => false, "message" => $translator->trans("Invalid Location Tag ID"), 'locationId' => $locationTagId];
3844.                 }
3845.             }
3846.         }
3849.         return array_values(array_unique($assignedLocationArr));
3850.     }
3854.     public function getUserLocations($user)
3855.     {
3856.         try {
3857.             $locationData = [];
3858.             $locations = $this->getLocationList($user);
3859.             if ($locations) {
3860.                 foreach ($locations as $locationId) {
3861.                     $location = \Pimcore\Model\DataObject::getById($locationId);
3862.                     if ($location instanceof Location) {
3863.                         $alertConfig = $this->locationModel->getUserSevereAlertAndCustomNotification($location, $user);
3864.                         $locationData[] = [
3865.                             'id' => $location->getId(),
3866.                             'name' => $location->getName(),
3867.                             'title' => $location->getTitle(),
3868.                             'coordinates' => $location->getCoordinates(),
3869.                             'severeWeatherAlert' => isset($alertConfig['get_severe_alert']) && ($alertConfig['get_severe_alert'] == true) ?? false,
3870.                             'customNotificationAlert' => isset($alertConfig['get_custom_notification']) && ($alertConfig['get_custom_notification'] == true) ?? false,
3871.                         ];
3872.                     }
3873.                 }
3874.             }
3876.             return $locationData;
3877.         } catch (\Exception $ex) {
3878.             throw new \Exception($ex->getMessage());
3879.         }
3880.     }
3882.     public function getUsersLocationByOrganizationId($organizationId)
3883.     {
3884.         // try {
3885.         $organization = \Pimcore\Model\DataObject::getById($organizationId);
3886.         if (!$organization instanceof \Pimcore\Model\DataObject\Organization) {
3887.             throw new \Exception("Organization not found");
3888.         }
3889.         $customers = new \Pimcore\Model\DataObject\Customer\Listing();
3890.         $customers->filterByOrganization($organization);
3891.         if ($customers->getCount() == 0) {
3892.             throw new \Exception("Customers does not exists in this organization");
3893.         }
3895.         $locationData = [];
3896.         foreach ($customers as $customer) {
3897.             $locations = $this->getLocationList($customer);
3898.             if ($locations) {
3899.                 foreach ($locations as $locationId) {
3900.                     $location = \Pimcore\Model\DataObject::getById($locationId);
3901.                     if ($location instanceof Location) {
3902.                         $alertConfig = $this->locationModel->getUserSevereAlertAndCustomNotification($location, $customer);
3903.                         $locationData[] = [
3904.                             'id' => $location->getId(),
3905.                             'name' => $location->getName(),
3906.                             'title' => $location->getTitle(),
3907.                             'coordinates' => $location->getCoordinates(),
3908.                             'severeWeatherAlert' => isset($alertConfig['get_severe_alert']) && ($alertConfig['get_severe_alert'] == true) ?? false,
3909.                             'customNotificationAlert' => isset($alertConfig['get_custom_notification']) && ($alertConfig['get_custom_notification'] == true) ?? false,
3910.                             "customerId" => $customer->getId(),
3911.                             "customerName" => $customer->getName(),
3912.                             "customerEmail" => $customer->getEmail()
3913.                         ];
3914.                     }
3915.                 }
3916.             }
3917.         }
3919.         return $locationData;
3920.         // } catch (\Exception $ex) {
3921.         //     throw new \Exception($ex->getMessage());
3922.         // }
3923.     }
3926.     /**
3927.      * Get User Assigned API Groups
3928.      *
3929.      */
3930.     public function getUserApiGroups($user)
3931.     {
3933.         $apiGroups = [];
3935.         $subscriptions = new DataObject\Subscription\Listing();
3936.         $subscriptions->filterBySubscribedUser($user);
3938.         $currentDate = date('Y-m-d'); // Assuming the date and time format is 'YYYY-MM-DD'
3940.         $subscriptions->filterByEndDate(strtotime($currentDate), ">=");
3941.         $subscriptions->filterBySubscriptionType("custom");
3942.         $subscriptions->filterByIsActive(true);
3943.         $subscriptions->load();
3945.         foreach ($subscriptions as $subscription) {
3946.             $package = $subscription->getSubscribedPackage();
3947.             if ($package instanceof DataObject\Package) {
3949.                 if ($package->getApiGroups()) {
3951.                     foreach ($package->getApiGroups() as $key => $ApiGroup) {
3953.                         $apiGroups[] = [
3954.                             "apiGroupId" => $ApiGroup->getId(),
3955.                             "type" => $ApiGroup->getApiGroupType(),
3956.                             "name" => $ApiGroup->getApiGroupName('en'),
3957.                             "name_ar" => $ApiGroup->getApiGroupName('ar'),
3959.                         ];
3960.                     }
3961.                 }
3962.             }
3963.         }
3964.         return $apiGroups;
3965.     }
3969.     /**
3970.      * generate unsubscribe token user
3971.      */
3972.     public function unSubscribeGenerateToken($email)
3973.     {
3974.         $token = '';
3975.         try {
3976.             //generate token
3977.             $user = DataObject\Customer::getByEmail($email, true);
3979.             // $token = md5($user->getEmail() . time() . uniqid());
3980.             $token = base64_encode($user->getEmail() . time() . uniqid());
3981.             $user->setunSubscribeToken($token);
3982.             $user->save();
3984.             return $token;
3985.         } catch (\Exception $ex) {
3986.             throw new \Exception($ex->getMessage());
3987.         }
3989.         return $token;
3990.     }
3993.     /**
3994.      * generate unsubscribe ews notification token user
3995.      */
3996.     public function unSubscribeEwsGenerateToken($email)
3997.     {
3998.         $token = '';
3999.         try {
4000.             //generate token
4001.             $user = DataObject\Customer::getByEmail($email, true);
4003.             // $token = md5($user->getEmail() . time() . uniqid());
4004.             $token = base64_encode($user->getEmail() . time() . uniqid());
4005.             $user->setEwsNotificationToken($token);
4006.             $user->save();
4008.             return $token;
4009.         } catch (\Exception $ex) {
4010.             throw new \Exception($ex->getMessage());
4011.         }
4013.         return $token;
4014.     }
4016.     /**
4017.      * Get NCM User List
4018.      */
4019.     public function getAllActiveUsersInExcelData($params, $user, $translator)
4020.     {
4022.         $result = [];
4023.         try {
4024.             $userDataEn = [];
4026.             // Get All the Classes
4027.             $class = new \Pimcore\Model\DataObject\ClassDefinition();
4028.             $customer = $class->getDao()->getIdByName('Customer');
4029.             $subscription = $class->getDao()->getIdByName('Subscription');
4030.             $userRole = $class->getDao()->getIdByName('UserRole');
4031.             $organization = $class->getDao()->getIdByName('Organization');
4032.             $package = $class->getDao()->getIdByName('Package');
4034.             $db = Db::get();
4035.             $select = $db->createQueryBuilder();
4036.             $select->select('customer.oo_id');
4037.             $select->from('object_' . $customer, 'customer');
4038.             $select->innerJoin('customer', 'object_' . $subscription, 'subscription', 'customer.oo_id = subscription.subscribedUser__id');
4039.             $select->innerJoin('subscription', 'object_' . $package, 'package', 'package.oo_id = subscription.subscribedPackage__id');
4040.             $select->innerJoin('customer', 'object_' . $organization, 'organization', 'organization.oo_id = customer.organization__id');
4041.             $select->innerJoin('customer', 'object_' . $userRole, 'userRole', 'userRole.oo_id = customer.role__id');
4043.             // if (isset($params['search']) && !empty($params['search'])) {
4044.             //     $select->andWhere("customer.name LIKE " . $db->quote("%" . $params['search'] . "%") . " OR customer.email LIKE " . $db->quote("%" . $params['search'] . "%"));
4045.             // }
4046.             if (isset($params['type']) && !empty($params['type'])) {
4047.                 if ($params['type'] == 'client') {
4048.                     $select->andWhere("userRole.name = " . $db->quote(USER_ROLES['CLIENT_ADMIN']) . " OR userRole.name = " . $db->quote(USER_ROLES['CLIENT_USER']));
4049.                 } elseif ($params['type'] == 'ncm') {
4050.                     $select->andWhere("userRole.name = " . $db->quote(USER_ROLES['NCM_IT']) . " OR userRole.name = " . $db->quote(USER_ROLES['NCM_OPERATOR']));
4051.                 }
4052.             }
4053.             $select->andWhere("customer.oo_id != " . $db->quote($user->getId()));
4054.             $select->andWhere("customer.isDeleted != 1 or customer.isDeleted IS NULL");
4055.             if (!empty($params["entityId"])) {
4056.                 $select->andWhere("organization.oo_id = " . $db->quote($params["entityId"]));
4057.             }
4059.             $select->orderBy('oo_id', 'DESC');
4060.             $select->groupBy(array('oo_id'));
4061.             $select = $select->execute();
4062.             $usersIds = $select->fetchAllAssociative();
4064.             if (count($usersIds) == 0) {
4065.                 return ["success" => false, "message" => $translator->trans("no_user_available_in_NCM")];
4066.             }
4068.             $userDataEn[] = [
4069.                 'S. No' => 'S. No',
4070.                 'Username' => 'Username',
4071.                 'Entity' => 'Entity',
4072.                 'Entity AR' => 'Entity AR',
4073.                 'Email Address' => 'Email Address',
4074.                 'Type' => 'Type',
4075.                 'Role' => 'Role',
4076.                 'Created By' => 'Created By',
4077.                 'Created On' => 'Created On',
4078.                 'Package' => 'Package',
4079.                 'Package Expiry' => 'Package Expiry',
4080.                 'Status' => 'Status',
4081.             ];
4083.             foreach ($usersIds as $userKey => $usersId) {
4085.                 $usersData = DataObject\Customer::getById($usersId['oo_id'], true);
4086.                 if ($usersData instanceof \Pimcore\Model\DataObject\Customer) {
4088.                     // Get Custom Subscription of the organization and package
4089.                     $customSubscriptions = new DataObject\Subscription\Listing();
4090.                     $customSubscriptions->filterBySubscribedUser($usersData);
4091.                     $customSubscriptions->filterByIsActive(true);
4093.                     $status = "";
4094.                     if ($usersData->getToken() == "" && $usersData->isPublished() == true) {
4096.                         if ($customSubscriptions->count() > 0) {
4097.                             $status = "Active";
4098.                         } else {
4099.                             $status = "Suspended";
4100.                         }
4101.                     } elseif ($usersData->getToken() != "" && $usersData->isPublished() == false) {
4103.                         $status = "Pending";
4104.                     }
4106.                     $permissionObj = $this->getUserPermissionInfo($usersData, $translator);
4107.                     $userPermissions = $permissionObj['success'] ? $permissionObj['grants'] : null;
4109.                     $customSubscriptions->filterBySubscriptionType("custom");
4110.                     $customSubscriptions->setOrderKey("o_modificationDate");
4111.                     $customSubscriptions->setOrder("desc");
4113.                     $apiGroupData = [];
4114.                     $packageData = [];
4115.                     if ($customSubscriptions->count() > 0) {
4116.                         foreach ($customSubscriptions as $key => $customSubscription) {
4117.                             if ($customSubscription instanceof \Pimcore\Model\DataObject\Subscription) {
4118.                                 $package = $customSubscription->getSubscribedPackage();
4119.                                 $disallowedApiGroups = $customSubscription->getDisallowedApiGroups();
4120.                                 if ($package) {
4121.                                     $packageData[] = [
4122.                                         "id" => $package->getId(),
4123.                                         "name" => $package->getPackageName("en"),
4124.                                         "package_expiry" => $customSubscription->getEndDate(date("M d, Y"))
4125.                                     ];
4127.                                     $apiGroups = $package->getApiGroups();
4128.                                     if ($apiGroups) {
4129.                                         foreach ($apiGroups as  $apiGroup) {
4131.                                             $apiGroupId = $apiGroup->getId();
4132.                                             $apiGroupNameEn = $apiGroup->getApiGroupName('en');
4133.                                             $apiGroupNameAr = $apiGroup->getApiGroupName('ar');
4134.                                             $isDisallowed = false;
4136.                                             // Check if the current API group is disallowed
4137.                                             foreach ($disallowedApiGroups as $disallowedApiGroup) {
4138.                                                 if ($apiGroupId == $disallowedApiGroup->getId()) {
4139.                                                     $isDisallowed = true;
4140.                                                     break;
4141.                                                 }
4142.                                             }
4144.                                             // Only add the API group if it's not disallowed
4145.                                             if (!$isDisallowed) {
4146.                                                 $apiGroupData[] = [
4147.                                                     "id" => $apiGroupId,
4148.                                                     "name" => $apiGroupNameEn,
4149.                                                     "name_ar" => $apiGroupNameAr
4150.                                                 ];
4151.                                             }
4152.                                         }
4153.                                     }
4154.                                 }
4155.                             }
4156.                         }
4157.                     }
4159.                     $userDataEn[] = [
4160.                         'S. No' => $userKey + 1,
4161.                         'Username' => $usersData->getName(),
4162.                         'Entity' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName() : null,
4163.                         'Entity AR' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName('ar') : null,
4164.                         'Email Address' => $usersData->getEmail(),
4165.                         'Type' => $translator->trans('user', [], null, 'en'),
4166.                         'Role' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'en') : null,
4167.                         'Created By' => $usersData->getCreatedBy() ? $usersData->getCreatedBy()->getName() : null,
4168.                         'Created On' => $usersData->getCreationDate() ? date('Y-m-d', $usersData->getCreationDate()) : null,
4169.                         'Package' => isset($packageData[0]['name']) ? $packageData[0]['name'] : null,
4170.                         'Package Expiry' => isset($packageData[0]['package_expiry']) ? date("M d, Y", strtotime($packageData[0]['package_expiry'])) : null,
4171.                         'Status' => $translator->trans($status, [], null, 'en'),
4173.                     ];
4174.                 }
4175.             }
4177.             $excelData = ExcelGenerator::createAndSaveXlsx($userDataEn, $params['type'] . "_users_data", true, '/users/excel/');
4178.             return ["success" => true, "message" => $translator->trans("excel_generated"), "data" =>  $excelData];
4179.         } catch (\Exception $ex) {
4180.             throw new \Exception($ex->getMessage());
4181.         }
4182.     }
4184.     public function getDualModeUsersInExcelData($params, $user, $translator)
4185.     {
4186.         $result = [];
4187.         try {
4188.             $userDataEn = [];
4190.             // Get All the Classes
4191.             $class = new \Pimcore\Model\DataObject\ClassDefinition();
4192.             $customer = $class->getDao()->getIdByName('Customer');
4193.             $subscription = $class->getDao()->getIdByName('Subscription');
4194.             $userRole = $class->getDao()->getIdByName('UserRole');
4195.             $organization = $class->getDao()->getIdByName('Organization');
4196.             $package = $class->getDao()->getIdByName('Package');
4198.             $db = Db::get();
4199.             $select = $db->createQueryBuilder();
4200.             $select->select('customer.oo_id');
4201.             $select->from('object_' . $customer, 'customer');
4202.             $select->innerJoin('customer', 'object_' . $subscription, 'subscription', 'customer.oo_id = subscription.subscribedUser__id');
4203.             $select->innerJoin('subscription', 'object_' . $package, 'package', 'package.oo_id = subscription.subscribedPackage__id');
4204.             $select->innerJoin('customer', 'object_' . $organization, 'organization', 'organization.oo_id = customer.organization__id');
4205.             $select->innerJoin('customer', 'object_' . $userRole, 'userRole', 'userRole.oo_id = customer.role__id');
4207.             // Filter for dual mode users
4208.             $select->andWhere("customer.dualMode = 1");
4210.             // if (isset($params['type']) && !empty($params['type'])) {
4211.             //     if ($params['type'] == 'client') {
4212.             //         $select->andWhere("userRole.name = " . $db->quote(USER_ROLES['CLIENT_ADMIN']) . " OR userRole.name = " . $db->quote(USER_ROLES['CLIENT_USER']));
4213.             //     } elseif ($params['type'] == 'ncm') {
4214.             //         $select->andWhere("userRole.name = " . $db->quote(USER_ROLES['NCM_IT']) . " OR userRole.name = " . $db->quote(USER_ROLES['NCM_OPERATOR']));
4215.             //     }
4216.             // }
4217.             $select->andWhere("customer.oo_id != " . $db->quote($user->getId()));
4218.             $select->andWhere("customer.isDeleted != 1 or customer.isDeleted IS NULL");
4219.             if (!empty($params["entityId"])) {
4220.                 $select->andWhere("organization.oo_id = ".$db->quote($params["entityId"]));
4221.             }
4223.             $select->orderBy('oo_id', 'DESC');
4224.             $select->groupBy(array('oo_id'));
4225.             $select = $select->execute();
4226.             $usersIds = $select->fetchAllAssociative();
4228.             if (count($usersIds) == 0) {
4229.                 return ["success" => false, "message" => $translator->trans("no_dual_mode_user_available")];
4230.             }
4232.             $userDataEn[] = [
4233.                 'S. No' => 'S. No',
4234.                 'Username' => 'Username',
4235.                 'Entity' => 'Entity',
4236.                 'Entity AR' => 'Entity AR',
4237.                 'Email Address' => 'Email Address',
4238.                 'Type' => 'Type',
4239.                 'Role' => 'Role',
4240.                 'Created By' => 'Created By',
4241.                 'Created On' => 'Created On',
4242.                 'Package' => 'Package',
4243.                 'Package Expiry' => 'Package Expiry',
4244.                 'Status' => 'Status',
4245.             ];
4247.             foreach ($usersIds as $userKey => $usersId) {
4249.                 $usersData = DataObject\Customer::getById($usersId['oo_id'], true);
4250.                 if ($usersData instanceof \Pimcore\Model\DataObject\Customer) {
4252.                     // Get Custom Subscription of the organization and package
4253.                     $customSubscriptions = new DataObject\Subscription\Listing();
4254.                     $customSubscriptions->filterBySubscribedUser($usersData);
4255.                     $customSubscriptions->filterByIsActive(true);
4257.                     $status = "";
4258.                     if ($usersData->getToken() == "" && $usersData->isPublished() == true) {
4260.                         if ($customSubscriptions->count() > 0) {
4261.                             $status = "Active";
4262.                         } else {
4263.                             $status = "Suspended";
4264.                         }
4265.                     } elseif ($usersData->getToken() != "" && $usersData->isPublished() == false) {
4267.                         $status = "Pending";
4268.                     }
4270.                     $permissionObj = $this->getUserPermissionInfo($usersData, $translator);
4271.                     $userPermissions = $permissionObj['success'] ? $permissionObj['grants'] : null;
4273.                     $customSubscriptions->filterBySubscriptionType("custom");
4274.                     $customSubscriptions->setOrderKey("o_modificationDate");
4275.                     $customSubscriptions->setOrder("desc");
4277.                     $apiGroupData = [];
4278.                     $packageData = [];
4279.                     if ($customSubscriptions->count() > 0) {
4280.                         foreach ($customSubscriptions as $key => $customSubscription) {
4281.                             if ($customSubscription instanceof \Pimcore\Model\DataObject\Subscription) {
4282.                                 $package = $customSubscription->getSubscribedPackage();
4283.                                 $disallowedApiGroups = $customSubscription->getDisallowedApiGroups();
4284.                                 if ($package) {
4285.                                     $packageData[] = [
4286.                                         "id" => $package->getId(),
4287.                                         "name" => $package->getPackageName("en"),
4288.                                         "package_expiry" => $customSubscription->getEndDate(date("M d, Y"))
4289.                                     ];
4291.                                     $apiGroups = $package->getApiGroups();
4292.                                     if ($apiGroups) {
4293.                                         foreach ($apiGroups as  $apiGroup) {
4295.                                             $apiGroupId = $apiGroup->getId();
4296.                                             $apiGroupNameEn = $apiGroup->getApiGroupName('en');
4297.                                             $apiGroupNameAr = $apiGroup->getApiGroupName('ar');
4298.                                             $isDisallowed = false;
4300.                                             // Check if the current API group is disallowed
4301.                                             foreach ($disallowedApiGroups as $disallowedApiGroup) {
4302.                                                 if ($apiGroupId == $disallowedApiGroup->getId()) {
4303.                                                     $isDisallowed = true;
4304.                                                     break;
4305.                                                 }
4306.                                             }
4308.                                             // Only add the API group if it's not disallowed
4309.                                             if (!$isDisallowed) {
4310.                                                 $apiGroupData[] = [
4311.                                                     "id" => $apiGroupId,
4312.                                                     "name" => $apiGroupNameEn,
4313.                                                     "name_ar" => $apiGroupNameAr
4314.                                                 ];
4315.                                             }
4316.                                         }
4317.                                     }
4318.                                 }
4319.                             }
4320.                         }
4321.                     }
4323.                     $userDataEn[] = [
4324.                         'S. No' => $userKey + 1,
4325.                         'Username' => $usersData->getName(),
4326.                         'Entity' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName() : null,
4327.                         'Entity AR' => ($usersData->getOrganization()) ? $usersData->getOrganization()->getName('ar') : null,
4328.                         'Email Address' => $usersData->getEmail(),
4329.                         'Type' => $translator->trans('user', [], null, 'en'),
4330.                         'Role' => $usersData->getRole() ? $translator->trans($usersData->getRole()->getName(), [], null, 'en') : null,
4331.                         'Created By' => $usersData->getCreatedBy() ? $usersData->getCreatedBy()->getName() : null,
4332.                         'Created On' => $usersData->getCreationDate() ? date('Y-m-d', $usersData->getCreationDate()) : null,
4333.                         'Package' => isset($packageData[0]['name']) ? $packageData[0]['name'] : null,
4334.                         'Package Expiry' => isset($packageData[0]['package_expiry']) ? date("M d, Y", strtotime($packageData[0]['package_expiry'])) : null,
4335.                         'Status' => $translator->trans($status, [], null, 'en'),
4337.                     ];
4338.                 }
4339.             }
4340.             $excelData = ExcelGenerator::createAndSaveXlsx($userDataEn, $params['type'] . "_dual_mode_users_data", true, '/users/excel/');
4341.             return ["success" => true, "message" => $translator->trans("excel_generated"), "data" =>  $excelData];
4342.         } catch (\Exception $ex) {
4343.             throw new \Exception($ex->getMessage());
4344.         }
4345.     }
4347.     public function createWsoUser($name, $email, $translator): array
4348.     {
4349.         try {
4350.             Utility::validateEmail($email);
4351.             Utility::validateName($name);
4353.             $user = DataObject\Customer::getByEmail($email, true);
4355.             if ($user instanceof \Pimcore\Model\DataObject\Customer) {
4356.                 return ["success" => false, "message" => $translator->trans("user_already_exists")];
4357.             }
4359.             $registerUser = new DataObject\Customer();
4360.             $registerUser->setParent(DataObject\Service::createFolderByPath('/UserManagement/WsoUsers'));
4361.             $registerUser->setKey(trim(strip_tags($email)));
4362.             $registerUser->setUserType('public');
4363.             $registerUser->setName(strip_tags($name));
4364.             $registerUser->setEmail(trim(strip_tags($email)));
4365.             $registerUser->setPublished(true);
4366.             $registerUser->setIsActive(true);
4367.             $registerUser->setSendEwsEmail(false);
4368.             $registerUser->setOmitMandatoryCheck(true);
4369.             $registerUser->save();
4371.             return ["success" => true, "message" => $translator->trans("user_registered_success"), 'data' => $registerUser->getId()];
4372.         } catch (\Exception $ex) {
4373.             throw new \Exception($ex->getMessage());
4374.         }
4375.         return [];
4376.     }
4379.     /**
4380.      * Create User Tag
4381.      */
4382.     public function createUserTag($user, $name, $request, $lang, $translator, $organization = false)
4383.     {
4384.         $result = [];
4386.         try {
4387.             $userTag = new DataObject\UserTag();
4388.             if ($organization) {
4389.                 $userTag->setParent(DataObject\Service::createFolderByPath('/Organization/tags/'));
4390.             } else {
4391.                 $userTag->setParent(DataObject\Service::createFolderByPath('/UserManagement/user tags/'));
4392.             }
4393.             $userTag->setKey(\Pimcore\Model\Element\Service::getValidKey($name . '_' . uniqid(), 'object'));
4394.             $userTag->setName(strip_tags($name));
4395.             $userTag->setOrganization($organization);
4396.             $userTag->setPublished(true);
4397.             $userTag->save();
4398.             if ($userTag) {
4399.                 return ["success" => true, "message" => $translator->trans("user_tag_created_successfully"), "user_tag_id" => $userTag->getId()];
4400.             }
4401.         } catch (\Exception $ex) {
4402.             throw new \Exception($ex->getMessage());
4403.         }
4404.         return $result;
4405.     }
4407.     public function assignBulkUserTag($user, $params, $translator)
4408.     {
4409.         try {
4410.             // Validate tag first
4411.             $tag = DataObject\UserTag::getById($params['tagId'], true);
4412.             if (!$tag) {
4413.                 return ["success" => false, "message" => $translator->trans("tag_does_not_exists")];
4414.             }
4416.             // Validate and process all users
4417.             $userIds = $params['userIds'];
4418.             $processedUsers = [];
4419.             $failedUsers = [];
4421.             foreach ($userIds as $userId) {
4422.                 $userToUpdate = DataObject\Customer::getById($userId, true);
4423.                 if (!$userToUpdate) {
4424.                     $failedUsers[] = $userId;
4425.                     continue;
4426.                 }
4427.                 $userToUpdate->setTag($tag);
4428.                 $userToUpdate->save();
4429.                 $processedUsers[] = $userId;
4430.             }
4432.             if (!empty($failedUsers)) {
4433.                 return [
4434.                     "success" => false,
4435.                     "message" => $translator->trans("Some_users_not_found"),
4436.                     "failed_user_ids" => $failedUsers,
4437.                     "processed_user_ids" => $processedUsers
4438.                 ];
4439.             }
4441.             return [
4442.                 "success" => true,
4443.                 "message" => $translator->trans("user_tag_assigned_successfully"),
4444.                 "processed_user_ids" => $processedUsers
4445.             ];
4446.         } catch (\Exception $ex) {
4447.             return ["success" => false, "message" => $ex->getMessage()];
4448.         }
4449.     }
4451.     /**
4452.      * User Tag Listing
4453.      */
4454.     public function userTagListing($user, $translator, $paginator, $params)
4455.     {
4456.         $result = [];
4458.         try {
4459.             $tagData = [];
4461.             $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
4462.             $page = isset($params['page']) ? $params['page'] : 1;
4464.             $tagList = new DataObject\UserTag\Listing();
4465.             // Check if organization parameter is set and not empty
4466.             if (isset($params['organization']) && !empty($params['organization'])) {
4467.                 $organization = $params['organization'];
4468.                 $tagList->setCondition("organization = true");
4469.             } else {
4470.                 $tagList->setCondition("(organization = false OR organization is null)");
4471.             }
4472.             if (isset($params['search']) && !empty($params['search'])) {
4473.                 $tagList->setCondition("name LIKE " . $tagList->quote("%" . $params['search'] . "%"));
4474.             }
4476.             $allowed = [
4477.                 'name'
4478.             ];
4479.             if ($params['sortBy'] && in_array($params['sortBy'], $allowed, true)) {
4480.                 $tagList->setOrderKey($params['sortBy']);
4481.                 $tagList->setOrder($params['sortDir'] === 'DESC' ? 'DESC' : 'ASC');
4482.             }
4484.             $paginator = $paginator->paginate(
4485.                 $tagList,
4486.                 $page,
4487.                 $pageSize
4488.             );
4489.             if ($paginator->getTotalItemCount() > 0) {
4491.                 foreach ($paginator as $key => $tag) {
4492.                     $tagData[] = [
4493.                         'id' => $tag->getId(),
4494.                         'name' => $tag->getName()
4495.                     ];
4496.                 }
4498.                 if (!empty($tagData) && count($tagData) > 0) {
4499.                     return ["success" => true, "data" => $tagData, "paginationVariables" => $paginator->getPaginationData()];
4500.                 }
4501.             }
4502.             return ["success" => false, "message" => $translator->trans("user_groups_are_not_available")];
4503.         } catch (\Exception $ex) {
4504.             throw new \Exception($ex->getMessage());
4505.         }
4506.         return $result;
4507.     }
4510.     /**
4511.      * Validate the unsubscribe token
4512.      *
4513.      * @param string $token
4514.      * @param Translator $translator
4515.      * @return array
4516.      */
4517.     public function unsubscribeTokenValidate($token, $translator)
4518.     {
4519.         // Fetch user by unsubscribe token
4520.         $user = Customer::getByUnSubToken($token, true);
4522.         if (!$user) {
4523.             return [
4524.                 "success" => false,
4525.                 "message" => $translator->trans("invalid_token")
4526.             ];
4527.         }
4529.         // Prepare the data
4530.         $data = [
4531.             "success" => true,
4532.             "id" => $user->getId(),
4533.             "email" => $user->getEmail(),
4534.             "customNotification" => $user->getCustomNotification(),
4535.             "earlyWarningNotification" => $user->getEarlyWarningNotification(),
4536.             "advanceCustomNotification" => $user->getAdvanceCustomNotification(),
4537.             "severeWeatherAlert" => $user->getSevereWeatherAlert()
4538.         ];
4540.         return $data;
4541.     }
4544.     /**
4545.      * update user Subscription
4546.      *
4547.      * @param string $params
4548.      * @param Translator $translator
4549.      * @return array
4550.      */
4551.     public function updateUserSubscription($params, $translator)
4552.     {
4553.         // Fetch user by unsubscribe token
4554.         $user = Customer::getById($params['id'], true);
4556.         if (!$user) {
4557.             return [
4558.                 "success" => false,
4559.                 "message" => $translator->trans("invalid_user_id")
4560.             ];
4561.         }
4562.         if (isset($params['customNotification'])) {
4564.             $user->setCustomNotification($params['customNotification']);
4565.         }
4566.         if (isset($params['earlyWarningNotification'])) {
4568.             $user->setEarlyWarningNotification($params['earlyWarningNotification']);
4569.         }
4570.         if (isset($params['advanceCustomNotification'])) {
4572.             $user->setAdvanceCustomNotification($params['advanceCustomNotification']);
4573.         }
4574.         if (isset($params['severeWeatherAlert'])) {
4576.             $user->setSevereWeatherAlert($params['severeWeatherAlert']);
4577.         }
4579.         $user->save();
4582.         // Prepare the data
4583.         $data = [
4584.             "success" => true,
4585.             "message" => $translator->trans("subscription_updated")
4587.         ];
4589.         return $data;
4590.     }
4592.     public function saveBulkUserInviteLog($user, $data, $organizationId)
4593.     {
4594.         $bulkUserInviteLog = new DataObject\BulkInviteUserReport();
4595.         $bulkUserInviteLog->setParent(DataObject\Service::createFolderByPath('/UserManagement/BulkUserInviteLog'));
4596.         $bulkUserInviteLog->setKey(\Pimcore\Model\Element\Service::getValidKey(uniqid(), 'object'));
4597.         $bulkUserInviteLog->setPublished(true);
4598.         $bulkUserInviteLog->setJsonData(json_encode($data));
4599.         $organization = DataObject\Organization::getById($organizationId);
4600.         if ($organization) {
4601.             $bulkUserInviteLog->setOrganization($organization);
4602.         }
4603.         $bulkUserInviteLog->setCreatedBy($user);
4604.         $bulkUserInviteLog->save();
4605.         return $bulkUserInviteLog;
4606.     }
4608.     public function getEntitySubscription($user)
4609.     {
4610.         $package = null;
4611.         $subscriptions = new Subscription\Listing();
4612.         $subscriptions->filterBySubscribedUser($user);
4613.         $subscriptions->filterBySubscriptionType("custom");
4614.         $subscription = $subscriptions->current();
4616.         return $subscription;
4617.     }
4619.     public function getEntityPackage($user)
4620.     {
4621.         $package = null;
4622.         $subscriptions = new Subscription\Listing();
4623.         $subscriptions->filterBySubscribedUser($user);
4624.         $subscriptions->filterBySubscriptionType("custom");
4625.         $subscription = $subscriptions->current();
4626.         if ($subscription) {
4627.             $package = $subscription->getSubscribedPackage();
4628.         }
4630.         return $package;
4631.     }
4633.     private function getInvitationDate($user): string
4634.     {
4635.         try {
4636.             $token = $user->getToken();
4638.             if (empty($token)) {
4639.                 $creationDate = $user->getCreationDate();
4640.                 if ($creationDate) {
4641.                     return date('Y-m-d H:i:s', $creationDate);
4642.                 }
4643.                 return "Unknown";
4644.             }
4646.             $tokenParts = explode('.', $token);
4647.             if (count($tokenParts) !== 3) {
4648.                 $creationDate = $user->getCreationDate();
4649.                 if ($creationDate) {
4650.                     return date('Y-m-d H:i:s', $creationDate);
4651.                 }
4652.                 return "Invalid token";
4653.             }
4655.             $payload = json_decode(base64_decode(str_replace(['-', '_'], ['+', '/'], $tokenParts[1])), true);
4657.             if (!$payload || !isset($payload['time'])) {
4658.                 $creationDate = $user->getCreationDate();
4659.                 if ($creationDate) {
4660.                     return date('Y-m-d H:i:s', $creationDate);
4661.                 }
4662.                 return "No invitation time found";
4663.             }
4665.             $invitationTime = $payload['time'];
4667.             return date('Y-m-d H:i:s', $invitationTime);
4668.         } catch (\Exception $e) {
4669.             $creationDate = $user->getCreationDate();
4670.             if ($creationDate) {
4671.                 return date('Y-m-d H:i:s', $creationDate);
4672.             }
4673.             return "Error getting date";
4674.         }
4675.     }
4677.     public function listC2Users($params, $translator)
4678.     {
4679.         try {
4680.             $userData = [];
4682.             // Get class IDs for table names
4683.             $class = new \Pimcore\Model\DataObject\ClassDefinition();
4684.             $customerClassId = $class->getDao()->getIdByName('Customer');
4685.             $subscriptionClassId = $class->getDao()->getIdByName('Subscription');
4686.             $packageClassId = $class->getDao()->getIdByName('Package');
4688.             $db = Db::get();
4689.             $select = $db->createQueryBuilder();
4691.             // Select customer data and subscription/package info
4692.             $select->select([
4693.                 'customer.oo_id AS customer_id',
4694.                 'customer.name AS customer_name',
4695.                 'customer.email AS customer_email',
4696.                 'customer.phoneNo AS customer_phone',
4697.                 'subscription.oo_id AS subscription_id',
4698.                 'subscription.isActive AS subscription_is_active',
4699.                 'subscription.endDate AS subscription_end_date',
4700.                 'subscription.subscriptionType AS subscription_type'
4701.             ]);
4703.             $select->from('object_' . $customerClassId, 'customer');
4705.             // INNER JOIN with Subscription to get only customers with subscriptions
4706.             // Then filter by active subscriptions
4707.             $select->innerJoin(
4708.                 'customer',
4709.                 'object_' . $subscriptionClassId,
4710.                 'subscription',
4711.                 'customer.oo_id = subscription.subscribedUser__id'
4712.             );
4715.             // Apply filters
4716.             // Phone number must exist and be exactly 9 digits
4717.             $select->where("customer.phoneNo IS NOT NULL AND customer.phoneNo != '' AND CHAR_LENGTH(customer.phoneNo) = 9");
4718.             
4719.             // Customer must be published
4720.             $select->andWhere("customer.o_published = 1");
4721.             
4722.             // Only active subscriptions
4723.             $select->andWhere("subscription.isActive = 1");
4724.             
4725.             // Only 'custom' subscription type (matching the commented code pattern)
4726.             $select->andWhere("subscription.subscriptionType = " . $db->quote('custom'));
4727.             
4728.             // Only subscriptions with end date in future (or no expiry)
4729.             // Pimcore stores dates as Unix timestamps, so compare with current timestamp
4730.             $currentTimestamp = time();
4731.             $select->andWhere("(subscription.endDate IS NULL OR subscription.endDate >= " . $currentTimestamp . ")");
4733.             // Execute query
4734.             $results = $select->execute()->fetchAllAssociative();
4736.             // Process results
4737.             foreach ($results as $row) {
4738.                 // Parse endDate - Pimcore stores dates as Unix timestamps
4739.                 $packageExpiry = null;
4740.                 if (!empty($row['subscription_end_date'])) {
4741.                     try {
4742.                         // Check if it's a Unix timestamp (numeric) or date string
4743.                         if (is_numeric($row['subscription_end_date'])) {
4744.                             // Unix timestamp - use @ prefix to parse
4745.                             $date = new \DateTime('@' . $row['subscription_end_date']);
4746.                             $date->setTimezone(new \DateTimeZone('Asia/Riyadh'));
4747.                             $packageExpiry = $date->format('M d, Y');
4748.                         } else {
4749.                             // Date string - parse directly
4750.                             $date = new \DateTime($row['subscription_end_date']);
4751.                             $packageExpiry = $date->format('M d, Y');
4752.                         }
4753.                     } catch (\Exception $e) {
4754.                         // If parsing fails, log and continue
4755.                         error_log('Error parsing subscription end date: ' . $e->getMessage() . ' - Value: ' . $row['subscription_end_date']);
4756.                         $packageExpiry = null;
4757.                     }
4758.                 }
4759.                 
4760.                 $userData[] = [
4761.                     'id' => (int) $row['customer_id'],
4762.                     'name' => $row['customer_name'] ?? '',
4763.                     'email' => $row['customer_email'] ?? '',
4764.                     'phoneNumber' => '+966' . $row['customer_phone'],
4765.                     'package_expiry' => $packageExpiry,
4766.                     'status' => $row['subscription_is_active'] ? 'Active' : 'Suspended',
4767.                 ];
4768.             }
4770.             return ["success" => true, "data" => $userData];
4772.         } catch (\Exception $e) {
4773.             error_log('Error in listC2Users: ' . $e->getMessage());
4774.             return ["success" => false, "error" => $e->getMessage(), "data" => []];
4775.         }
4776.     }
4778.     /**
4779.      * List user groups with simplified response (groupid, name, user_ids)
4780.      * Only includes users with mobile numbers (like listC2Users logic)
4781.      */
4782.     public function listUserGroupsSimple($user, $translator): array
4783.     {
4784.         try {
4785.             $organization = $user->getOrganization();
4787.             if (!$organization instanceof DataObject\Organization) {
4788.                 return ["success" => false, "message" => $translator->trans("user_does_not_belongs_to_organization")];
4789.             }
4791.             // Get class IDs for table names
4792.             $class = new \Pimcore\Model\DataObject\ClassDefinition();
4793.             $customerClassId = $class->getDao()->getIdByName('Customer');
4794.             $subscriptionClassId = $class->getDao()->getIdByName('Subscription');
4796.             $db = Db::get();
4798.             // Load UserGroup listing
4799.             $userGroupList = new DataObject\UserGroup\Listing();
4800.             $userGroupList->filterByOrganization($organization);
4801.             $userGroupList->setOrderKey("oo_id");
4802.             $userGroupList->setOrder("desc");
4804.             $userGroupListData = [];
4806.             foreach ($userGroupList as $userGroup) {
4807.                 $groupId = $userGroup->getId();
4808.                 
4809.                 // Use direct SQL to find users in this group
4810.                 // Pimcore stores userGroup as comma-separated string: ",398039,398040,"
4811.                 $select = $db->createQueryBuilder();
4812.                 $select->select(['customer.oo_id AS customer_id', 'customer.phoneNo AS phone_no']);
4813.                 $select->from('object_' . $customerClassId, 'customer');
4814.                 
4815.                 // Filter by user group - format is ",groupId," to match exact group ID
4816.                 $select->where("customer.userGroup LIKE :groupIdPattern");
4817.                 $select->setParameter('groupIdPattern', '%,' . $groupId . ',%');
4818.                 
4819.                 // Join with subscription to filter active subscriptions
4820.                 $select->innerJoin(
4821.                     'customer',
4822.                     'object_' . $subscriptionClassId,
4823.                     'subscription',
4824.                     'customer.oo_id = subscription.subscribedUser__id'
4825.                 );
4827.                 // Apply mobile number filter (same as listC2Users)
4828.                 $select->andWhere("customer.phoneNo IS NOT NULL AND customer.phoneNo != '' AND CHAR_LENGTH(customer.phoneNo) = 9");
4829.                 
4830.                 // Customer must be published
4831.                 $select->andWhere("customer.o_published = 1");
4832.                 
4833.                 // Only active subscriptions
4834.                 $select->andWhere("subscription.isActive = 1");
4835.                 
4836.                 // Only 'custom' subscription type
4837.                 $select->andWhere("subscription.subscriptionType = " . $db->quote('custom'));
4838.                 
4839.                 // Only subscriptions with end date in future (or no expiry)
4840.                 $currentTimestamp = time();
4841.                 $select->andWhere("(subscription.endDate IS NULL OR subscription.endDate >= " . $currentTimestamp . ")");
4843.                 $results = $select->execute()->fetchAllAssociative();
4844.                 
4845.                 // Convert user_ids to phone numbers
4846.                 $userPhones = [];
4847.                 foreach ($results as $row) {
4848.                     $phoneNo = $row['phone_no'];
4849.                     if (!empty($phoneNo) && strlen($phoneNo) === 9) {
4850.                         $userPhones[] = '+966' . $phoneNo;
4851.                     }
4852.                 }
4854.                 $userGroupListData[] = [
4855.                     'groupid' => $userGroup->getId(),
4856.                     'name' => $userGroup->getGroupName("en") ?: $userGroup->getGroupName("ar") ?: '',
4857.                     'user_phones' => $userPhones
4858.                 ];
4859.             }
4860.             
4861.             // Also fetch UserSMSGroup objects
4862.             $userSMSGroupList = new DataObject\UserSMSGroup\Listing();
4863.             $userSMSGroupList->setOrderKey("oo_id");
4864.             $userSMSGroupList->setOrder("desc");
4865.             
4866.             foreach ($userSMSGroupList as $userSMSGroup) {
4867.                 // Extract phone numbers from groupData JSON
4868.                 $groupData = $userSMSGroup->getGroupData();
4869.                 $userPhones = [];
4870.                 
4871.                 if (!empty($groupData)) {
4872.                     try {
4873.                         $userInfoArray = json_decode($groupData, true);
4874.                         if (is_array($userInfoArray)) {
4875.                             foreach ($userInfoArray as $userInfo) {
4876.                                 if (isset($userInfo['phoneNumber']) && !empty($userInfo['phoneNumber'])) {
4877.                                     $phoneNumber = $userInfo['phoneNumber'];
4878.                                     // Ensure phone number is in +966XXXXXXXXX format
4879.                                     if (!preg_match('/^\+966/', $phoneNumber)) {
4880.                                         // Remove +966 or 966 prefix to get 9 digits
4881.                                         $phoneDigits = preg_replace('/^\+966/', '', $phoneNumber);
4882.                                         $phoneDigits = preg_replace('/^966/', '', $phoneDigits);
4883.                                         $phoneDigits = preg_replace('/[^0-9]/', '', $phoneDigits);
4884.                                         if (strlen($phoneDigits) === 9) {
4885.                                             $phoneNumber = '+966' . $phoneDigits;
4886.                                         }
4887.                                     }
4888.                                     $userPhones[] = $phoneNumber;
4889.                                 }
4890.                             }
4891.                         }
4892.                     } catch (\Exception $ex) {
4893.                         // Skip invalid JSON
4894.                         continue;
4895.                     }
4896.                 }
4897.                 
4898.                 // Merge with existing UserGroup if same name, otherwise add as new entry
4899.                 $groupName = $userSMSGroup->getGroupName("en") ?: $userSMSGroup->getGroupName("ar") ?: '';
4900.                 $merged = false;
4901.                 
4902.                 foreach ($userGroupListData as &$existingGroup) {
4903.                     if ($existingGroup['name'] === $groupName) {
4904.                         // Merge phone numbers (remove duplicates)
4905.                         $existingGroup['user_phones'] = array_values(array_unique(array_merge($existingGroup['user_phones'], $userPhones)));
4906.                         $merged = true;
4907.                         break;
4908.                     }
4909.                 }
4910.                 
4911.                 if (!$merged && !empty($userPhones)) {
4912.                     // Add as new entry if not merged
4913.                     $userGroupListData[] = [
4914.                         'groupid' => $userSMSGroup->getId(),
4915.                         'name' => $groupName,
4916.                         'user_phones' => $userPhones
4917.                     ];
4918.                 }
4919.             }
4921.             if (!empty($userGroupListData)) {
4922.                 return ["success" => true, "data" => $userGroupListData];
4923.             }
4925.             return ["success" => false, "message" => $translator->trans("user_groups_are_not_available")];
4926.         } catch (\Exception $ex) {
4927.             throw new \Exception($ex->getMessage());
4928.         }
4929.     }
4931.     /**
4932.      * Create or update user group with simplified parameters
4933.      * Only assigns users that have mobile numbers (like listC2Users logic)
4934.      */
4935.     public function createUpdateUserGroupSimple($user, $groupName, $userIds, $groupId = null, $translator): array
4936.     {
4937.         try {
4938.             $organization = $user->getOrganization();
4940.             if (!$organization instanceof DataObject\Organization) {
4941.                 return ["success" => false, "message" => $translator->trans("user_does_not_belongs_to_organization")];
4942.             }
4944.             // Get class IDs for table names
4945.             $class = new \Pimcore\Model\DataObject\ClassDefinition();
4946.             $customerClassId = $class->getDao()->getIdByName('Customer');
4947.             $subscriptionClassId = $class->getDao()->getIdByName('Subscription');
4949.             $db = Db::get();
4951.             // Validate and filter user_ids - only include users with mobile numbers
4952.             $validUserIds = [];
4953.             if (!empty($userIds)) {
4954.                 $select = $db->createQueryBuilder();
4955.                 $select->select(['customer.oo_id AS customer_id']);
4956.                 $select->from('object_' . $customerClassId, 'customer');
4957.                 
4958.                 // Join with subscription to filter active subscriptions
4959.                 $select->innerJoin(
4960.                     'customer',
4961.                     'object_' . $subscriptionClassId,
4962.                     'subscription',
4963.                     'customer.oo_id = subscription.subscribedUser__id'
4964.                 );
4966.                 // Filter by provided user IDs
4967.                 $select->where("customer.oo_id IN (:userIds)");
4968.                 $select->setParameter('userIds', $userIds, \Doctrine\DBAL\Connection::PARAM_INT_ARRAY);
4970.                 // Apply mobile number filter (same as listC2Users)
4971.                 $select->andWhere("customer.phoneNo IS NOT NULL AND customer.phoneNo != '' AND CHAR_LENGTH(customer.phoneNo) = 9");
4972.                 
4973.                 // Customer must be published
4974.                 $select->andWhere("customer.o_published = 1");
4975.                 
4976.                 // Only active subscriptions
4977.                 $select->andWhere("subscription.isActive = 1");
4978.                 
4979.                 // Only 'custom' subscription type
4980.                 $select->andWhere("subscription.subscriptionType = " . $db->quote('custom'));
4981.                 
4982.                 // Only subscriptions with end date in future (or no expiry)
4983.                 $currentTimestamp = time();
4984.                 $select->andWhere("(subscription.endDate IS NULL OR subscription.endDate >= " . $currentTimestamp . ")");
4986.                 $results = $select->execute()->fetchAllAssociative();
4987.                 
4988.                 foreach ($results as $row) {
4989.                     $validUserIds[] = (int) $row['customer_id'];
4990.                 }
4991.             }
4993.             if (empty($validUserIds)) {
4994.                 return ["success" => false, "message" => $translator->trans("no_valid_users_with_mobile_numbers_found")];
4995.             }
4997.             // Validate group name uniqueness when creating new group
4998.             if (!$groupId) {
4999.                 // Check if group name already exists in the same organization
5000.                 $existingGroupList = new DataObject\UserGroup\Listing();
5001.                 $existingGroupList->filterByOrganization($organization);
5002.                 $existingGroupList->setLocale('en');
5003.                 
5004.                 foreach ($existingGroupList as $existingGroup) {
5005.                     if ($existingGroup instanceof DataObject\UserGroup) {
5006.                         $existingGroupNameEn = $existingGroup->getGroupName('en');
5007.                         $existingGroupNameAr = $existingGroup->getGroupName('ar');
5008.                         
5009.                         // Check if group name matches (case-insensitive)
5010.                         if (strcasecmp(trim($existingGroupNameEn), trim($groupName)) === 0 || 
5011.                             strcasecmp(trim($existingGroupNameAr), trim($groupName)) === 0) {
5012.                             return ["success" => false, "message" => $translator->trans("group_name_already_exists")];
5013.                         }
5014.                     }
5015.                 }
5016.             }
5018.             // Create or update user group
5019.             if ($groupId) {
5020.                 // Update existing group
5021.                 $userGroup = DataObject\UserGroup::getById($groupId, true);
5023.                 
5024.                 
5025.                 if (!$userGroup instanceof DataObject\UserGroup) {
5026.                     return ["success" => false, "message" => $translator->trans("user_group_is_not_available")];
5027.                 }
5029.                 // Verify organization
5030.                 if (!$userGroup->getOrganization() || $userGroup->getOrganization()->getId() != $organization->getId()) {
5031.                     return ["success" => false, "message" => $translator->trans("user_group_is_not_assigned_to_your_organization")];
5032.                 }
5034.                 // Update group name
5035.                 $userGroup->setGroupName($groupName, "en");
5036.                 $userGroup->setGroupName($groupName, "ar");
5037.             } else {
5038.                 // Create new group
5039.                 $userGroup = new DataObject\UserGroup();
5040.                 $userGroup->setParent(DataObject\Service::createFolderByPath('/UserManagement/UserGroups/' . $organization->getName()));
5041.             $userGroup->setKey(trim(strip_tags($groupName.'-'.uniqid())));
5042.             $userGroup->setGroupName($groupName, 'en');
5043.             $userGroup->setGroupName($groupName, 'ar');
5044.             $userGroup->setDetail($groupName, 'en');
5045.             $userGroup->setDetail($groupName, 'ar');
5046.             $userGroup->setOrganization($organization);
5047.             $userGroup->setPublished(true);
5048.                 // dump($userGroup);
5049.                 // die;
5050.                 // $userGroup->setGroupName($groupName, "en");
5051.                 // $userGroup->setGroupName($groupName, "ar");
5052.                 // $userGroup->setOrganization($organization);
5053.                 $userGroup->setIsActive(true);
5054.             }
5056.             $userGroup->save();
5057.             
5058.             // Reload the group to ensure it has all necessary data
5059.             $userGroup = DataObject\UserGroup::getById($userGroup->getId(), true);
5061.             // Assign users to group
5062.             foreach ($validUserIds as $userId) {
5063.                 $customer = DataObject\Customer::getById($userId, true);
5064.                 
5065.                 if ($customer instanceof DataObject\Customer) {
5066.                     // Get existing user groups for this customer
5067.                     $existingGroups = [];
5068.                     
5069.                     // Collect existing groups and their IDs
5070.                     $currentGroups = $customer->getUserGroup();
5071.                     if ($currentGroups) {
5072.                         foreach ($currentGroups as $group) {
5073.                             if ($group instanceof DataObject\UserGroup) {
5074.                                 $groupId = $group->getId();
5075.                                 // Skip if this is the same group we're adding
5076.                                 if ($groupId != $userGroup->getId()) {
5077.                                     $existingGroups[] = $group;
5078.                                 }
5079.                             }
5080.                         }
5081.                     }
5082.                     
5083.                     // Add the new/updated group
5084.                     $existingGroups[] = $userGroup;
5085.                     
5086.                     // Update customer's user groups
5087.                     $customer->setUserGroup($existingGroups);
5088.                     $customer->save();
5089.                 }
5090.             }
5092.             // Remove users from group if they're not in the valid list
5093.             // Get all users currently in this group
5094.             $allUsersInGroup = new DataObject\Customer\Listing();
5095.             $allUsersInGroup->filterByUserGroup($userGroup);
5096.             
5097.             foreach ($allUsersInGroup as $customer) {
5098.                 if (!in_array($customer->getId(), $validUserIds)) {
5099.                     // Get existing groups and remove this one
5100.                     $existingGroups = [];
5101.                     $currentGroups = $customer->getUserGroup();
5102.                     
5103.                     if ($currentGroups) {
5104.                         foreach ($currentGroups as $group) {
5105.                             if ($group instanceof DataObject\UserGroup) {
5106.                                 // Only keep groups that are NOT the one we're removing
5107.                                 if ($group->getId() != $userGroup->getId()) {
5108.                                     $existingGroups[] = $group;
5109.                                 }
5110.                             }
5111.                         }
5112.                     }
5113.                     
5114.                     $customer->setUserGroup($existingGroups);
5115.                     $customer->save();
5116.                 }
5117.             }
5119.             $action = $groupId ? "updated" : "created";
5120.             return [
5121.                 "success" => true, 
5122.                 "message" => $translator->trans("user_group_{$action}_successfully"),
5123.                 "data" => [
5124.                     "groupid" => $userGroup->getId(),
5125.                     "name" => $groupName,
5126.                     "user_ids" => $validUserIds
5127.                 ]
5128.             ];
5129.         } catch (\Exception $ex) {
5130.             throw new \Exception($ex->getMessage());
5131.         }
5132.     }
5136.     /**
5137.      * Internal user dual mode
5138.      * @param array $params
5139.      * @param Translator $translator
5140.      * @return array
5141.      */
5143.     public function internalUserDualMode($params, $translator): array
5144.     {
5145.         try {
5146.             $user = DataObject\Customer::getById($params['id'], true);
5147.             // check if user is internal user
5148.             if (!$user) {
5149.                 return ["success" => false, "message" => $translator->trans("user_does_not_exists")];
5150.             }
5151.             // get internal organization
5152.             $organization = new DataObject\Organization\Listing();
5153.             $organization->filterByIsInternal(true);
5154.             $entity = $organization->current();
5155.             if(!$entity) {
5156.                 return ["success" => false, "message" => $translator->trans("internal_organization_does_not_exists")];
5157.             }
5159.             $package = $entity->getPackage();
5160.             if (!$package) {
5161.                 return ["success" => false, "message" => $translator->trans("package_does_not_exists")];
5162.             }
5164.             if ($params['mode'] == true) {
5165.                 $user->setDualMode(true);
5166.                 $user->save();
5167.                
5168.                 // get existing subscription
5169.                 $subscriptions = new DataObject\Subscription\Listing();
5170.                 $subscriptions->filterBySubscribedUser($user);
5171.                 $subscriptions->filterBySubscriptionType('custom');
5172.                 $subscriptions->filterBySubscribedPackage($package);
5173.                 $subscription = $subscriptions->current();
5174.                 if ($subscription) {
5175.                     $subscription->setIsNoExpiry(true);
5176.                     $subscription->setIsActive(true);
5177.                     $subscription->setSubscriptionType('custom');
5178.                     $subscription->setPublished(true);
5179.                     $subscription->setSubscribedPackage($package);
5180.                     $subscription->setSubscribedUser($user);
5181.                     $subscription->save();
5182.                 } else {
5183.                     // create new subscription
5184.                     $subscription = new DataObject\Subscription();
5185.                     $subscription->setParent(DataObject\Service::createFolderByPath('/UserManagement/Subscriptions/' . $user->getEmail()));
5186.                     $subscription->setKey(\Pimcore\Model\Element\Service::getValidKey($package->getId() . time() . rand(1000, 10000), 'object'));
5187.                     $subscription->setSubscribedPackage($package);
5188.                     $subscription->setSubscribedUser($user);
5189.                     $subscription->setSubscriptionType('custom');
5190.                     $subscription->setIsNoExpiry(true);
5191.                     $subscription->setIsActive(true);
5192.                     $subscription->setPublished(true);
5193.                     $subscription->save();
5194.                 }
5195.               
5196.             } else {
5197.                 // disable dual mode
5198.                 $user->setDualMode(false);
5199.                 $user->save();
5200.                 // get existing subscription
5201.                 $subscriptions = new DataObject\Subscription\Listing();
5202.                 $subscriptions->filterBySubscribedUser($user);
5203.                 $subscriptions->filterBySubscribedPackage($package);
5204.                 $subscriptions->filterBySubscriptionType('custom');
5206.                 $subscription = $subscriptions->current();
5207.                 // delete subscription
5208.                 if ($subscription) {
5209.                     $subscription->delete();
5210.                 }
5211.             }
5212.             return ["success" => true, "message" => $translator->trans("internal_user_dual_mode_updated_successfully")];
5213.         } catch (\Exception $ex) {
5214.             throw new \Exception($ex->getMessage());
5215.         }
5216.     }
5217. }