src/Service/CustomNotificationService.php line 33

Open in your IDE?
  1. <?php
  3. namespace App\Service;
  5. use Pimcore\Db;
  6. use Pimcore\Model\DataObject;
  7. use Pimcore\Model\DataObject\Customer;
  8. use Pimcore\Model\DataObject\Location;
  9. use Pimcore\Model\DataObject\AlertType;
  10. use Pimcore\Model\DataObject\AlertMaster;
  11. use App\Model\CustomNotificationLog\Listing;
  12. use Pimcore\Model\DataObject\AbstractObject;
  13. use Pimcore\Model\DataObject\CustomNotification;
  14. use Pimcore\Model\DataObject\AdvanceCustomNotification;
  15. use Pimcore\Model\DataObject\Data\ObjectMetadata;
  16. use Symfony\Component\Templating\EngineInterface;
  17. use Pimcore\Model\DataObject\MannedAlertSubscription;
  18. use Symfony\Component\Process\Process;
  19. use Symfony\Component\Process\Exception\ProcessFailedException;
  20. use Pimcore\Model\DataObject\UserGroup;
  22. class CustomNotificationService
  23. {
  25.     private $templating;
  27.     public function __construct(EngineInterface $templating)
  28.     {
  30.         $this->templating = $templating;
  31.     }
  33.     public function subscribeAlerts($customer, $locationIds, $alertType, $title, $color, $units, $minValue, $maxValue, $weatherModel, $alertOnEmail, $alertOnSMS, $calculate, $duration,$frequency=1, $logger, $translator)
  34.     {
  35.         // try {
  36.         // retrieve customer by userId
  37.         if (!$customer instanceof Customer) {
  38.             throw new \Exception('Customer not found for userId:');
  39.         }
  41.         // retrieve location by locationId
  42.         // $location = DataObject::getById($locationId);
  43.         // if (!$location) {
  44.         //     throw new \Exception('Location not found for locationId: ' . $locationId);
  45.         // }
  47.         // retrieve alertType by alertType
  48.         $alertTypes = new  AlertMaster\Listing();
  49.         $alertTypes->addConditionParam("alertKey = ? AND units = ?", [$alertType, $units]);
  50.         $alertType = $alertTypes->current();
  51.         // $alertType = AlertMaster::getByAlertKey($alertType, true);
  52.         if (!$alertType) {
  53.             throw new \Exception('Alert type not found: ' . $alertType);
  54.         }
  56.         if (count($locationIds)) {
  57.             $notificationIds = [];
  58.             foreach ($locationIds as $locationId) {
  60.                 $location = DataObject::getById($locationId);
  61.                 if (!$location) {
  62.                     throw new \Exception('Location not found for locationId: ' . $locationId);
  63.                 }
  65.                 $key = \Pimcore\Model\Element\Service::getValidKey($alertType->getAlertKey(), 'object');
  66.                 // $customNotification = \Pimcore\Model\DataObject::getByPath('/CustomNotification/'.$customer->getEmail().'/'.$key.time());
  67.                 // if(!$customNotification){
  69.                 // }   
  70.                 $customNotification = new CustomNotification();
  71.                 $customNotification->setKey($key . time() . rand(0, 100));
  72.                 $customNotification->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/Notification/CustomNotification/'));
  74.                 $customNotification->setTitle($title);
  75.                 $customNotification->setColor($color);
  76.                 $customNotification->setUnits($units);
  77.                 $customNotification->setMinValue($minValue);
  78.                 $customNotification->setMaxValue($maxValue);
  79.                 $customNotification->setWeatherModel($weatherModel);
  80.                 $customNotification->setAlertOnEmail($alertOnEmail);
  81.                 $customNotification->setAlertOnSMS($alertOnSMS);
  83.                 $customNotification->setLocation($location);
  85.                 // set metadata for user
  86.                 $objectArray = [];
  87.                 $objectMetadata = new DataObject\Data\ObjectMetadata('user', ['alert_on_email', 'alert_on_sms'],  $customer);
  88.                 $objectMetadata->setAlert_on_email($alertOnEmail);
  89.                 $objectMetadata->setAlert_on_sms($alertOnSMS);
  90.                 array_push($objectArray, $objectMetadata);
  92.                 $customNotification->setUser($objectArray);
  93.                 $customNotification->setAlert($alertType);
  94.                 $customNotification->setStatus(true);
  95.                 $customNotification->setPublished(true);
  96.                 $customNotification->setCalculate($calculate);
  97.                 $customNotification->setDuration($duration);
  98.                 $customNotification->setFrequency($frequency);
  99.                 $customNotification->save();
  101.                 $notificationIds[] = $customNotification->getId();
  103.                 // Execute notification command if alertOnEmail is true
  104.                 // $hitCommand = $alertOnEmail == true || $alertOnEmail == '1' ? true : false;
  105.                 // if ($hitCommand) {
  108.                 //     $commandArguments = ['php', 'bin/console', 'app:get-custom-notification'];
  109.                 //     if ($customNotification->getId()) {
  110.                 //         $commandArguments[] = (string) $customNotification->getId(); // Cast ID to string if needed
  111.                 //     }
  113.                 //     $process = new Process($commandArguments);
  114.                 //     $process->setWorkingDirectory(PIMCORE_PROJECT_ROOT);
  115.                 //     $process->setTimeout(300); // Set timeout to 300 seconds (5 minutes)
  118.                 //     try {
  119.                 //         $process->mustRun();
  120.                 //         $logger->info("Custom Notification command executed successfully: " . $process->getOutput());
  121.                 //         $result['success'] = true;
  122.                 //         $result['message'] = $process->getOutput();
  123.                 //     } catch (ProcessFailedException $exception) {
  124.                 //         $logger->error("Custom Notification command failed: " . $exception->getMessage());
  125.                 //         $result['success'] = false;
  126.                 //         $result['message'] = "Failed to execute Custom notification command.";
  127.                 //     }
  128.                 // }
  129.             }
  131.             \App\Lib\Utility::storeActivityLog($customNotification, $customer, $action = 'create-user-custom-notification', $translator);
  133.             return ["success" => true, "data" => $notificationIds, "message" => $translator->trans("alert_created_successfully")];
  134.         }
  136.         return ["success" => false, "data" => "Location is mandatory"];
  138.         // return ["success" => true, "data" => $customNotification->getId()];
  139.         // } catch (\Exception $ex) {
  140.         //     throw new \Exception($ex->getMessage());
  141.         // }
  142.     }
  144.     public function subscribeAlertsByTag($customer, $tagIds, $alertType, $title, $color, $units, $minValue, $maxValue, $weatherModel, $alertOnEmail, $alertOnSMS, $calculate, $duration, $frequency=1, $logger, $translator)
  145.     {
  146.         if (!$customer instanceof Customer) {
  147.             throw new \Exception('Customer not found for userId:');
  148.         }
  150.         // retrieve alertType by alertType
  151.         $alertTypes = new  AlertMaster\Listing();
  152.         $alertTypes->addConditionParam("alertKey = ? AND units = ?", [$alertType, $units]);
  153.         $alertType = $alertTypes->current();
  154.         if (!$alertType) {
  155.             throw new \Exception('Alert type not found: ' . $alertType);
  156.         }
  158.         $notificationIds = [];
  159.         if (count($tagIds)) {
  161.             foreach ($tagIds as $tagId) {
  162.                 $tag = DataObject::getById($tagId);
  163.                 if (!$tag) {
  164.                     throw new \Exception('Tag not found for tagId: ' . $tagId);
  165.                 }
  167.                 // Assuming Location::getByTag($tag) retrieves multiple locations associated with the tag
  168.                 $locations = Location::getByTag($tag);
  170.                 foreach ($locations as $location) {
  172.                     $key = \Pimcore\Model\Element\Service::getValidKey($alertType->getAlertKey(), 'object');
  174.                     $customNotification = new CustomNotification();
  175.                     $customNotification->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/Notification/CustomNotification/'));
  176.                     $customNotification->setKey($key . time() . rand(0, 100));
  178.                     $customNotification->setTitle($title);
  179.                     $customNotification->setColor($color);
  180.                     $customNotification->setUnits($units);
  181.                     $customNotification->setMinValue($minValue);
  182.                     $customNotification->setMaxValue($maxValue);
  183.                     $customNotification->setWeatherModel($weatherModel);
  184.                     $customNotification->setAlertOnEmail($alertOnEmail);
  185.                     $customNotification->setAlertOnSMS($alertOnSMS);
  186.                     $customNotification->setTag($tag);
  187.                     $customNotification->setLocation($location);
  189.                     // set metadata for user
  190.                     $objectArray = [];
  191.                     $objectMetadata = new DataObject\Data\ObjectMetadata('user', ['alert_on_email', 'alert_on_sms'],  $customer);
  192.                     $objectMetadata->setAlert_on_email($alertOnEmail);
  193.                     $objectMetadata->setAlert_on_sms($alertOnSMS);
  194.                     array_push($objectArray, $objectMetadata);
  196.                     $customNotification->setUser($objectArray);
  197.                     $customNotification->setAlert($alertType);
  198.                     $customNotification->setStatus(true);
  199.                     $customNotification->setPublished(true);
  200.                     $customNotification->setCalculate($calculate);
  201.                     $customNotification->setDuration($duration);
  202.                     $customNotification->setFrequency($frequency);
  203.                     $customNotification->save();
  205.                     $notificationIds[] = $customNotification->getId();
  207.                     // Execute notification command if alertOnEmail is true
  208.                     // $hitCommand = $alertOnEmail == true || $alertOnEmail == '1' ? true : false;
  209.                     // if ($hitCommand) {
  211.                     //     $commandArguments = ['php', 'bin/console', 'app:get-custom-notification'];
  212.                     //     if ($customNotification->getId()) {
  213.                     //         $commandArguments[] = (string) $customNotification->getId(); // Cast ID to string if needed
  214.                     //     }
  216.                     //     $process = new Process($commandArguments);
  217.                     //     $process->setWorkingDirectory(PIMCORE_PROJECT_ROOT);
  218.                     //     $process->setTimeout(300); // Set timeout to 300 seconds (5 minutes)
  221.                     //     try {
  222.                     //         $process->mustRun();
  223.                     //         $logger->info("Custom Notification command executed successfully: " . $process->getOutput());
  224.                     //         $result['success'] = true;
  225.                     //         $result['message'] = $process->getOutput();
  226.                     //     } catch (ProcessFailedException $exception) {
  227.                     //         $logger->error("Custom Notification command failed: " . $exception->getMessage());
  228.                     //         $result['success'] = false;
  229.                     //         $result['message'] = "Failed to execute Custom notification command.";
  230.                     //     }
  231.                     // }
  232.                 }
  234.                 return ["success" => true, "data" => $notificationIds, "message" => $translator->trans("alert_created_successfully")];
  235.             }
  237.             return ["success" => false, "data" => "Tag id is mandatory"];
  238.         }
  239.     }
  241.     public function unSubscribeAlerts($customer, $locationId, $alertType, $translator)
  242.     {
  243.         try {
  244.             // retrieve customer by userId            
  245.             if (!$customer instanceof \Pimcore\Model\DataObject) {
  246.                 throw new \Exception('Customer not found');
  247.             }
  249.             // retrieve location by locationId
  250.             $location = DataObject::getById($locationId);
  251.             if (!$location) {
  252.                 throw new \Exception('Location not found for locationId: ' . $locationId);
  253.             }
  255.             // retrieve alertType by alertType
  256.             $alertType = AlertMaster::getByAlertKey($alertType, true);
  257.             if (!$alertType) {
  258.                 throw new \Exception('Alert type not found: ' . $alertType);
  259.             }
  261.             $customNotification = new CustomNotification\Listing();
  262.             // $customNotification->filterByUser($customer);
  263.             $customNotification->addConditionParam("user like '%," . $customer->getId() . ",%'");
  264.             $customNotification->filterByLocation($location);
  265.             $customNotification->filterByAlert($alertType);
  266.             $customNotifications = $customNotification->load();
  268.             if ($customNotifications) {
  270.                 foreach ($customNotifications as $customNotification) {
  271.                     $objectArray = ($customNotification) ? $customNotification->getUser() : [];
  272.                     if ($objectArray) {
  273.                         foreach ($objectArray as $key => $objUser) {
  274.                             // added below new line to remove the user from the array
  275.                             $currentUser = $objUser->getObject();
  276.                             if ($currentUser->getId() == $customer->getId()) {
  277.                                 unset($objectArray[$key]);
  278.                             }
  279.                         }
  280.                     }
  282.                      // If no other users left, delete the customNotification
  283.                     if (empty($objectArray)) {
  284.                         $customNotification->delete();
  285.                         return ["success" => true, "message" => $translator->trans("customer_notification_removed")];
  286.                     }
  288.                     $customNotification->setUser($objectArray);
  289.                     $customNotification->save();
  291.                     return ["success" => true, "message" => $translator->trans("customer_notification_removed")];
  292.                 }
  293.             } else {
  294.                 return ["success" => false, "message" => $translator->trans("notification_not_found")];
  295.             }
  298.             // if ($customNotifications) {
  299.             //     $customNotifications[0]->setStatus(false);
  300.             //     $customNotification = $customNotifications[0]->save();
  301.             //     $customNotification->delete();
  302.             //     return ["success" => true, "message" => $translator->trans("customer_notification_removed")];
  303.             // } else {
  304.             //     return ["success" => false, "message" => $translator->trans("notification_not_found")];
  305.             // }
  306.         } catch (\Exception $ex) {
  307.             throw new \Exception($ex->getMessage());
  308.         }
  309.     }
  311.     public function unSubscribeAlertsBulk($customer, $notificationIds, $translator)
  312.     {
  313.             $userId = $customer->getId();
  314.             // retrieve customer by userId            
  315.             if (!$customer instanceof Customer) {
  316.                 return ["success" => false, "message" => $translator->trans("customer_not_found")];
  317.             }
  319.             foreach ($notificationIds as $notificationId) {
  320.                 $notification = CustomNotification::getById($notificationId);
  321.                 if (!$notification) {
  322.                     return ["success" => false, "message" => $translator->trans('notification_not_found') . " {$notificationId}"];
  323.                 }
  324.                 $existingUsers = $notification->getUser();
  326.                 $remainingUsers = [];
  327.                 $userFound = false;
  329.                 foreach ($existingUsers as $user) {
  330.                     // print_r($user->getObjectId());
  331.                     if ($user->getObjectId() && $user->getObjectId() == $userId) {
  332.                         $userFound = true;
  333.                         continue; // skip this user (removing)
  334.                     }
  335.                     $remainingUsers[] = $user;
  336.                 }
  338.                 // Only act if the user was part of this notification
  339.                 if ($userFound) {
  340.                     if (count($remainingUsers) === 0) {
  341.                         // No other users — delete the notification
  342.                         $notification->delete();
  343.                         \App\Lib\Utility::storeActivityLog($notification, $user, $action = 'delete-notification', $translator);
  344.                     } else {
  345.                         // Save updated user list
  346.                         $notification->setUser($remainingUsers);
  347.                         $notification->save();
  348.                     }
  349.                 }            
  350.             }
  351.             return ["success" => true, "message" => $translator->trans("customer_notifications_removed")];
  352.     }
  354.     public function getUserAlerts($userId, $locationId, $params, $paginator)
  355.     {
  356.         $response = [];
  358.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  359.         $page = isset($params['page']) ? $params['page'] : 1;
  361.         // retrieve customer by userId
  362.         $customer = DataObject::getById($userId);
  364.         if (!$customer) {
  365.             throw new \Exception('Customer not found for userId: ' . $userId);
  366.         }
  368.         $customerId = $customer->getId();
  370.         if ($locationId > 0) {
  371.             $locationId = DataObject::getById($locationId);
  372.             if (!$locationId) {
  373.                 throw new \Exception('Location not found for userId: ' . $locationId);
  374.             }
  375.         }
  377.         // Get All the Classes
  378.         $class = new \Pimcore\Model\DataObject\ClassDefinition();
  379.         $custom_notification = $class->getDao()->getIdByName('CustomNotification');
  380.         $customer = $class->getDao()->getIdByName('Customer');
  381.         $location = $class->getDao()->getIdByName('Location');
  382.         $tag = $class->getDao()->getIdByName('Tags');
  384.         $db = Db::get();
  385.         $select = $db->createQueryBuilder();
  386.         $select->select('notification.oo_id');
  387.         $select->from('object_' . $custom_notification, 'notification');
  388.         //$select->leftJoin('notification', 'object_query_' . $customer, 'customer', 'customer.oo_id = notification.user__id');
  389.         $select->leftJoin('notification', 'object_query_' . $location, 'location', 'location.oo_id = notification.location__id');
  390.         $select->leftJoin('location', 'object_query_' . $tag, 'tag', 'tag.oo_id = location.Tag');
  392.         if (isset($params['title']) && !empty($params['title'])) {
  393.             $select->andWhere("notification.title LIKE " . $db->quote("%" . $params['title'] . "%"));
  394.         }
  396.         if (isset($params['color']) && !empty($params['color'])) {
  397.             $select->andWhere("notification.color LIKE " . $db->quote("%" . $params['color'] . "%"));
  398.         }
  400.         if (isset($params['calculation']) && !empty($params['calculation'])) {
  401.             $select->andWhere("notification.calculate LIKE " . $db->quote("%" . $params['calculation'] . "%"));
  402.         }
  404.         if (isset($params['weatherModel']) && !empty($params['weatherModel'])) {
  405.             $select->andWhere("notification.weatherModel LIKE " . $db->quote("%" . $params['weatherModel'] . "%"));
  406.         }
  408.         if (isset($params['tagId']) && !empty($params['tagId'])) {
  409.             $tagConditions = [];
  410.             foreach ($params['tagId'] as $tag) {
  411.                 $tagConditions[] = "location.Tag LIKE " . $db->quote("%" . $tag . "%");
  412.             }
  413.             $select->andWhere(implode(' OR ', $tagConditions));
  414.         }
  416.         $select->andWhere("notification.user like " . $db->quote("%" . $customerId . "%"));
  417.         $select->andWhere("o_published = 1");
  418.         // $select->andWhere("notification.user__id = ".$db->quote($userId));
  419.         $select->orderBy('oo_id', 'DESC');
  420.         $select->groupBy(array('oo_id'));
  422.         // Bind parameters
  424.         $paginator = $paginator->paginate(
  425.             $select,
  426.             $page,
  427.             $pageSize
  428.         );
  429.         if ($select) {
  430.             foreach ($paginator as $customNotification) {
  431.                 $customNotification = DataObject\CustomNotification::getById($customNotification['oo_id'], true);
  433.                 if ($customNotification instanceof \Pimcore\Model\DataObject\CustomNotification) {
  434.                     if ($customNotification->getLocation() && $customNotification->getAlert()) {
  436.                         $tags = [];
  437.                         if ($customNotification->getLocation()) {
  438.                             foreach ($customNotification->getLocation()->getTag() as $tag) {
  439.                                 $tags[] = [
  440.                                     "id" => $tag->getId(),
  441.                                     "nameEn" => ($tag->getTagName('en') == "" || $tag->getTagName('en') == null) ? null : $tag->getTagName('en'),
  442.                                     "nameAr" => ($tag->getTagName('ar') == "" || $tag->getTagName('ar') == null) ? null :  $tag->getTagName('ar'),
  443.                                     "metaDataEn" => ($tag->getMetaData('en') == "" || $tag->getMetaData('en') == null) ? null : $tag->getMetaData('en'),
  444.                                     "metaDataAr" => ($tag->getMetaData('ar') == "" || $tag->getMetaData('ar') == null) ? null :  $tag->getMetaData('ar'),
  445.                                 ];
  446.                             }
  447.                         }
  449.                         $objectArray = ($customNotification) ? $customNotification->getUser() : [];
  450.                         $userMetaData = [];
  451.                         if ($objectArray) {
  452.                             foreach ($objectArray as $key => $objUser) {
  453.                                 $currentUser = $objUser->getObject();
  454.                                 if ($currentUser->getId() == $userId) {
  457.                                     $userData = $objUser->getData();
  458.                                     $userMetaData['alert_on_email'] = isset($userData['alert_on_email']) && $userData['alert_on_email'] == '1' ? true : false;
  459.                                     $userMetaData['alert_on_sms'] = isset($userData['alert_on_sms']) && $userData['alert_on_sms'] == '1' ? true : false;
  460.                                     break; // Stop the loop once a match is found
  461.                                 }
  462.                             }
  463.                         }
  464.                         $userGroups = [];
  465.                         if ($customNotification->getUserGroup()) {
  466.                             foreach ($customNotification->getUserGroup() as $userGroup) {
  467.                                 $userGroups[] = [
  468.                                     "id" => $userGroup->getId(),
  469.                                     "groupName_en" => $userGroup->getGroupName("en"),
  470.                                     "groupName_ar" => $userGroup->getGroupName("ar"),
  471.                                 ];
  472.                             }
  473.                         }
  475.                         $response[] = [
  476.                             "id" => $customNotification->getId(),
  477.                             'location_id' => ($customNotification->getLocation()) ? $customNotification->getLocation()->getId() : 0,
  478.                             "alert_type" => $customNotification->getAlert()->getName(),
  479.                             "alert_key" => $customNotification->getAlert()->getAlertKey(),
  480.                             "parameter_name_en" => $customNotification->getAlert()->getName("en"),
  481.                             "parameter_name_ar" => $customNotification->getAlert()->getName("ar"),
  482.                             "location_name" => $customNotification->getLocation()->getTitle(),
  483.                             "title" => $customNotification->gettitle(),
  484.                             "color" => $customNotification->getColor(),
  485.                             "color_ar" => (\App\Lib\Utility::getArabicTranslation($customNotification->getColor(), CUSTOM_NOTIFICATION_COLORS) ? \App\Lib\Utility::getArabicTranslation($customNotification->getColor(), CUSTOM_NOTIFICATION_COLORS) : ''),
  486.                             "units" => $customNotification->getunits(),
  487.                             "units_ar" => (\App\Lib\Utility::getArabicTranslationUnits($customNotification->getunits()) ? \App\Lib\Utility::getArabicTranslationUnits($customNotification->getunits()) : ''),
  488.                             "min_value" => $customNotification->getMinValue(),
  489.                             "max_value" => $customNotification->getMaxValue(),
  490.                             "weather_model" => $customNotification->getWeatherModel(),
  491.                             "alert_on_email" => $userMetaData['alert_on_email'],
  492.                             "alert_on_sms" => $userMetaData['alert_on_sms'],
  493.                             "calculation" => $customNotification->getCalculate(),
  494.                             "calculation_ar" => (\App\Lib\Utility::getArabicTranslation($customNotification->getCalculate(), CUSTOM_NOTIFICATION_CONDITION) ? \App\Lib\Utility::getArabicTranslation($customNotification->getCalculate(), CUSTOM_NOTIFICATION_CONDITION) : ''),
  495.                             "duration" => $customNotification->getDuration(),
  496.                             "frequency" => $customNotification->getFrequency(),
  497.                             "tags" => $tags,
  498.                             "userGroups" => $userGroups
  499.                         ];
  500.                     }
  501.                 }
  502.             }
  503.         }
  505.         return ["success" => true, "data" => $response, 'paginationVariables' => $paginator->getPaginationData()];
  506.     }
  508.     public function getAlertMaster()
  509.     {
  510.         $response = [];
  511.         $alertMaster = new DataObject\AlertMaster\Listing();
  512.         $alertMaster->addConditionParam("isHidden is null OR isHidden = 0");
  513.         $alertMaster->setOrderKey("order");
  514.         $alertMaster->setOrder("asc");
  515.         $alertMasters = $alertMaster->load();
  516.         if ($alertMasters) {
  517.             foreach ($alertMasters as $alertMaster) {
  518.                 $response[] = ["id" => $alertMaster->getId(), "name_en" => $alertMaster->getName('en'), "name_ar" => $alertMaster->getName('ar'), "alert_key" => $alertMaster->getAlertKey(), "meteo_matics_key" => $alertMaster->getMeteoMaticsKey(), "units" => $alertMaster->getUnits(), "unit_title" => $alertMaster->getUnitTitle('en'), "unit_title_ar" => $alertMaster->getUnitTitle('ar')];
  519.             }
  520.         }
  522.         return ["success" => true, "data" => $response];
  523.     }
  527.     public function mannedAlertFilters()
  528.     {
  529.         $response = [];
  530.         $alertMaster = new DataObject\AlertStatus\Listing();
  531.         $alertMasters = $alertMaster->load();
  532.         $imageTemplate = [];
  533.         if ($alertMasters) {
  534.             foreach ($alertMasters as $alertMaster) {
  535.                 //if(!in_array($alertMaster->getImageTemplate(),$imageTemplate)){
  536.                 $response['alert_status'][] = ["id" => $alertMaster->getAlertStatusId(), "name_en" => $alertMaster->getName('en'), "name_ar" => $alertMaster->getName('ar')];
  537.                 // $imageTemplate[] = $alertMaster->getName('en');
  538.                 // }
  539.             }
  540.         }
  542.         $regionMaster = new DataObject\Region\Listing();
  543.         $regionMasters = $regionMaster->load();
  544.         if ($regionMasters) {
  545.             foreach ($regionMasters as $regionMaster) {
  546.                 $response['regions'][] = ["id" => $regionMaster->getRegionId(), "name_en" => $regionMaster->getName('en'), "name_ar" => $regionMaster->getName('ar')];
  547.             }
  548.         }
  550.         $alertHazardMaster = new DataObject\AlertHazard\Listing();
  551.         $alertHazardMasters = $alertHazardMaster->load();
  552.         if ($alertHazardMasters) {
  553.             foreach ($alertHazardMasters as $alertHazardMaster) {
  554.                 $response['alert_hazards'][] = ["id" => $alertHazardMaster->getAlertHazardId(), "name_en" => $alertHazardMaster->getName('en'), "name_ar" => $alertHazardMaster->getName('ar')];
  555.             }
  556.         }
  558.         $alertTypeMaster = new DataObject\AlertType\Listing();
  559.         $alertTypeMasters = $alertTypeMaster->load();
  560.         if ($alertTypeMasters) {
  561.             foreach ($alertTypeMasters as $alertTypeMaster) {
  562.                 $response['alert_type'][] = ["id" => $alertTypeMaster->getAlertTypeId(), "name_en" => $alertTypeMaster->getName('en'), "name_ar" => $alertTypeMaster->getName('ar')];
  563.             }
  564.         }
  566.         $alertActionMaster = new DataObject\AlertAction\Listing();
  567.         $alertActionMasters = $alertActionMaster->load();
  568.         if ($alertActionMasters) {
  569.             $alertActionArr = [];
  570.             foreach ($alertActionMasters as $alertActionMaster) {
  571.                 //if(!in_array($alertActionMaster->getSeverity(),$alertActionArr)){
  572.                 $response['alert_actions'][] = ["id" => $alertActionMaster->getAlertActionId(), "severity" => ucwords($alertActionMaster->getName('en'))];
  573.                 // $alertActionArr[] = $alertActionMaster->getSeverity();
  574.                 //}
  575.             }
  576.         }
  577.         return ["success" => true, "data" => $response];
  578.     }
  581.     // public function getMannedAlerts($params, $paginator)
  582.     // {
  583.     //     $response = [];
  584.     //     $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  585.     //     $page = isset($params['page']) ? $params['page'] : 1;
  587.     //     $mannedAlert = new DataObject\MannedAlertNotification\Listing();
  588.     //     //$mannedAlert->setCondition("o_creationDate > " . strtotime('-2 days'));
  589.     //     if (!empty($params['alert_status'])) {
  590.     //         $alertStatusSql = null;
  591.     //         foreach ($params['alert_status'] as $alertStatus) {
  592.     //             $alertStatus = \Pimcore\Model\DataObject\AlertStatus::getByAlertStatusId($alertStatus, true);
  593.     //             if ($alertStatus) {
  594.     //                 $alertStatusSql .= "alertStatus__id = " . $alertStatus->getId() . " OR ";
  595.     //             }
  596.     //         }
  597.     //         $mannedAlert->addConditionParam("(" . substr($alertStatusSql, 0, -3) . ")");
  598.     //     }
  600.     //     if (isset($params['id']) && !empty($params['id'])) {
  601.     //         $idSql = '';
  602.     //         $idSql .= "alertId = " . $params['id'] . " OR ";
  603.     //         $mannedAlert->addConditionParam("(" . substr($idSql, 0, -3) . ")");
  604.     //     }
  606.     //     if (!empty($params['alert_region'])) {
  607.     //         $alertRegionSql = null;
  608.     //         foreach ($params['alert_region'] as $alertRegionId) {
  609.     //             $alertRegion = \Pimcore\Model\DataObject\Region::getByRegionId($alertRegionId, true);
  610.     //             if ($alertRegion) {
  611.     //                 $alertRegionSql .= "region__id = " . $alertRegion->getId() . " OR ";
  612.     //             }
  613.     //         }
  615.     //         if (!empty($alertRegion)) {
  616.     //             $mannedAlert->addConditionParam("(" . substr($alertRegionSql, 0, -3) . ")");
  617.     //         }
  618.     //     }
  621.     //     // added filter for public portal 
  622.     //     if (isset($params['governorate_id']) && !empty($params['governorate_id'])) {
  623.     //         $alertGovernorateSql = null;
  624.     //         foreach ($params['governorate_id'] as $alertGovernorateId) {
  625.     //             $alertGovernorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($alertGovernorateId, true);
  626.     //             if ($alertGovernorate) {
  627.     //                 $alertGovernorateSql .= "governorates LIKE '%," . $alertGovernorate->getId() . ",%' OR ";
  628.     //             }
  629.     //         }
  631.     //         if (!empty($alertGovernorateSql)) {
  632.     //             $mannedAlert->addConditionParam("(" . substr($alertGovernorateSql, 0, -3) . ")");
  633.     //         }
  634.     //     }
  637.     //     if (!empty($params['alert_type'])) {
  638.     //         $alertTypeSql = null;
  639.     //         foreach ($params['alert_type'] as $alertTypeId) {
  640.     //             $alertType = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alertTypeId, true);
  641.     //             if ($alertType) {
  642.     //                 $alertTypeSql .= "alertType__id = " . $alertType->getId() . " OR ";
  643.     //             }
  644.     //         }
  646.     //         if (!empty($alertTypeSql)) {
  647.     //             $mannedAlert->addConditionParam("(" . substr($alertTypeSql, 0, -3) . ")");
  648.     //         }
  649.     //     }
  651.     //     if (!empty($params['alert_actions'])) {
  653.     //         $alertActionIdSql = "";
  654.     //         foreach ($params['alert_actions'] as $alertAction) {
  655.     //             $alertAction = \Pimcore\Model\DataObject\AlertAction::getByAlertActionId($alertAction, true);
  656.     //             if ($alertAction) {
  657.     //                 $alertActionIdSql .= "alertAction LIKE '%," . $alertAction->getId() . ",%' OR ";
  658.     //             }
  659.     //         }
  661.     //         if (!empty($alertActionIdSql)) {
  662.     //             $mannedAlert->addConditionParam("(" . substr($alertActionIdSql, 0, -3) . ")");
  663.     //         }
  664.     //     }
  667.     //     if (!empty($params['from_date'])  && !empty($params['to_date'])) {
  668.     //         // $mannedAlert->filterByFromDate($params['from_date'], ">=");
  669.     //         // $mannedAlert->filterByToDate($params['to_date'], "<=");
  670.     //         // $mannedAlert->filterByFromDate(strtotime($params['from_date']), ">=");
  671.     //         $mannedAlert->filterByToDate(time(), ">=");
  672.     //     }
  674.     //     $mannedAlert->setOrderKey("lastModifiedDate");
  675.     //     $mannedAlert->setOrder("desc");
  676.     //     $mannedAlerts = $mannedAlert->load();
  679.     //     // code for devide api which does not need pagination
  680.     //     if ($paginator == null) {
  682.     //         $count = 0;
  683.     //         foreach ($mannedAlerts as $mannedAlert) {
  684.     //             $response[$count] = [
  685.     //                 "id" => $mannedAlert->getAlertId(),
  686.     //                 "title" => $mannedAlert->getTitle(),
  687.     //                 "other_locations" => [
  688.     //                     "en" => ($mannedAlert->getotherLocation()) ? $mannedAlert->getotherLocation()->getName('en') : null,
  689.     //                     "ar" => ($mannedAlert->getotherLocation()) ? $mannedAlert->getotherLocation()->getName('ar') : null
  690.     //                 ],
  691.     //                 "alert_type" => [
  692.     //                     "id" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getAlertTypeId() : null,
  693.     //                     "en" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getName('en') : null,
  694.     //                     "ar" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getName('ar') : null,
  695.     //                     "color" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getColor() : null
  696.     //                 ],
  697.     //                 "fromDate" => $mannedAlert->getFromDate()->toDateTimeString(),
  698.     //                 "toDate" => $mannedAlert->getToDate()->toDateTimeString(),
  699.     //                 "lastModifiedDate" => $mannedAlert->getLastModifiedDate()->toDateTimeString(),
  700.     //                 "rawData" => $mannedAlert->getRawText(),
  701.     //                 "region" => [
  702.     //                     "id" => ($mannedAlert->getRegion()) ? $mannedAlert->getRegion()->getRegionId() : null,
  703.     //                     "en" => ($mannedAlert->getRegion()) ? $mannedAlert->getRegion()->getName('en') : null,
  704.     //                     "ar" => ($mannedAlert->getRegion()) ? $mannedAlert->getRegion()->getName('ar') : null
  705.     //                 ],
  706.     //                 "alert_status" => [
  707.     //                     "id" => ($mannedAlert->getalertStatus()) ? $mannedAlert->getalertStatus()->getalertStatusId() : null,
  708.     //                     "en" => ($mannedAlert->getalertStatus()) ? $mannedAlert->getalertStatus()->getName('en') : null,
  709.     //                     "ar" => ($mannedAlert->getalertStatus()) ? $mannedAlert->getalertStatus()->getName('ar') : null
  710.     //                 ]
  711.     //             ];
  713.     //             $alertHazards = $mannedAlert->getalertHazards();
  714.     //             if ($alertHazards) {
  715.     //                 foreach ($alertHazards as $alertHazard) {
  716.     //                     $response[$count]['alert_hazard'][] = ["id" => $alertHazard->getAlertHazardId(), "name_en" => $alertHazard->getName('en'), "name_ar" => $alertHazard->getName('ar')];
  717.     //                 }
  718.     //             }
  720.     //             $governorates = $mannedAlert->getGovernorates();
  723.     //             if ($governorates) {
  724.     //                 $alertJsonDecodeData =   json_decode($mannedAlert->getRawText());
  725.     //                 $governoratesData = $alertJsonDecodeData->governorates;
  726.     //                 foreach ($governorates as $governorate) {
  727.     //                     $isEnrireGovernorate = false;
  728.     //                     foreach ($governoratesData as $governorateData) {
  729.     //                         if ($governorateData->id == $governorate->getGovernoteId()) {
  730.     //                             if (count($governorateData->municipalities) == 0) {
  732.     //                                 $isEnrireGovernorate = true;
  733.     //                                 break;
  734.     //                             }
  735.     //                         }
  736.     //                     }
  738.     //                     $response[$count]['governorates'][] = ["id" => $governorate->getGovernoteId(), "name_en" => $governorate->getName('en'), "name_ar" => $governorate->getName('ar'), 'isEnrireGovernorate' => $isEnrireGovernorate];
  739.     //                 }
  740.     //             }
  742.     //             $alertActionMasters = $mannedAlert->getAlertAction();
  743.     //             if ($alertActionMasters) {
  744.     //                 foreach ($alertActionMasters as $alertActionMaster) {
  745.     //                     $response[$count]['alert_actions'][] = ["id" => $alertActionMaster->getAlertActionId(), "name_en" => $alertActionMaster->getName('en'), "name_ar" => $alertActionMaster->getName('ar')];
  746.     //                 }
  747.     //             }
  749.     //             $alert = json_decode($mannedAlert->getRawText(), true);
  751.     //             // extra param js
  752.     //             $alertObj = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert['alertType'], true);
  753.     //             $alertName = $alertObj->getName() ? $alertObj->getName() : '';
  755.     //             $alert['host'] = API_BASE_URL;
  756.     //             $alert['alertColor'] = $alertName;
  758.     //             $backgroundColor = '#fcb82526';
  759.     //             $borderColor = '#000000';
  760.     //             $textColor = '#000000';
  762.     //             if (isset($alert['alertColor']) && !empty(trim($alert['alertColor']))) {
  763.     //                 $alertColorLower = strtolower(trim($alert['alertColor']));
  765.     //                 if ($alertColorLower === 'red') {
  766.     //                     $backgroundColor = '#f6000017';
  767.     //                     $borderColor = '#F60000';
  768.     //                     $textColor = '#F60000';
  769.     //                 } elseif ($alertColorLower === 'orange') {
  770.     //                     $backgroundColor = '#ff66001f';
  771.     //                     $borderColor = '#FF6600';
  772.     //                     $textColor = '#FF6600';
  773.     //                 } elseif ($alertColorLower === 'yellow') {
  774.     //                     $backgroundColor = '#fcb82526';
  775.     //                     $borderColor = '#FCB825';
  776.     //                     $textColor = '#FCB825';
  777.     //                 }
  778.     //             }
  780.     //             $alert['backgroundColor'] = $backgroundColor;
  781.     //             $alert['borderColor'] = $borderColor;
  782.     //             $alert['textColor'] = $textColor;
  784.     //             $alert['name'] = ""; // ned to fiex this 
  787.     //             if ($mannedAlert->getRawText()) {
  788.     //                 $html = $this->templating->render('web2print/_manned_alert_notification_en.html.twig', $alert);
  789.     //                 $response[$count]['message_en'] = $html;
  792.     //                 $html = $this->templating->render('web2print/_manned_alert_notification.html.twig', $alert);
  793.     //                 $response[$count]['message_ar'] = $html;
  794.     //             } else {
  795.     //                 $response[$count]['message'] = [];
  796.     //             }
  798.     //             $count++;
  799.     //         }
  801.     //         return ["success" => true, "data" => $response];
  802.     //     }
  804.     //     $paginator = $paginator->paginate(
  805.     //         $mannedAlerts,
  806.     //         $page,
  807.     //         $pageSize
  808.     //     );
  810.     //     if ($paginator) {
  811.     //         $count = 0;
  812.     //         foreach ($paginator as $mannedAlert) {
  813.     //             $response[$count] = [
  814.     //                 "id" => $mannedAlert->getAlertId(),
  815.     //                 "title" => $mannedAlert->getTitle(),
  816.     //                 "other_locations" => [
  817.     //                     "en" => ($mannedAlert->getotherLocation()) ? $mannedAlert->getotherLocation()->getName('en') : null,
  818.     //                     "ar" => ($mannedAlert->getotherLocation()) ? $mannedAlert->getotherLocation()->getName('ar') : null
  819.     //                 ],
  820.     //                 "alert_type" => [
  821.     //                     "id" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getAlertTypeId() : null,
  822.     //                     "en" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getName('en') : null,
  823.     //                     "ar" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getName('ar') : null,
  824.     //                     "color" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getColor() : null
  825.     //                 ],
  826.     //                 "fromDate" => $mannedAlert->getFromDate()->toDateTimeString(),
  827.     //                 "toDate" => $mannedAlert->getToDate()->toDateTimeString(),
  828.     //                 "lastModifiedDate" => $mannedAlert->getLastModifiedDate()->toDateTimeString(),
  829.     //                 "region" => [
  830.     //                     "id" => ($mannedAlert->getRegion()) ? $mannedAlert->getRegion()->getRegionId() : null,
  831.     //                     "en" => ($mannedAlert->getRegion()) ? $mannedAlert->getRegion()->getName('en') : null,
  832.     //                     "ar" => ($mannedAlert->getRegion()) ? $mannedAlert->getRegion()->getName('ar') : null
  833.     //                 ],
  834.     //                 "alert_status" => [
  835.     //                     "id" => ($mannedAlert->getalertStatus()) ? $mannedAlert->getalertStatus()->getalertStatusId() : null,
  836.     //                     "en" => ($mannedAlert->getalertStatus()) ? $mannedAlert->getalertStatus()->getName('en') : null,
  837.     //                     "ar" => ($mannedAlert->getalertStatus()) ? $mannedAlert->getalertStatus()->getName('ar') : null
  838.     //                 ]
  839.     //             ];
  841.     //             $alertHazards = $mannedAlert->getalertHazards();
  842.     //             if ($alertHazards) {
  843.     //                 foreach ($alertHazards as $alertHazard) {
  844.     //                     $response[$count]['alert_hazard'][] = ["id" => $alertHazard->getAlertHazardId(), "name_en" => $alertHazard->getName('en'), "name_ar" => $alertHazard->getName('ar')];
  845.     //                 }
  846.     //             }
  848.     //             $governorates = $mannedAlert->getGovernorates();
  849.     //             if ($governorates) {
  850.     //                 foreach ($governorates as $governorate) {
  851.     //                     $response[$count]['governorates'][] = ["id" => $governorate->getGovernoteId(), "name_en" => $governorate->getName('en'), "name_ar" => $governorate->getName('ar')];
  852.     //                 }
  853.     //             }
  855.     //             $alertActionMasters = $mannedAlert->getAlertAction();
  856.     //             if ($alertActionMasters) {
  857.     //                 foreach ($alertActionMasters as $alertActionMaster) {
  858.     //                     $response[$count]['alert_actions'][] = ["id" => $alertActionMaster->getAlertActionId(), "name_en" => $alertActionMaster->getName('en'), "name_ar" => $alertActionMaster->getName('ar')];
  859.     //                 }
  860.     //             }
  862.     //             $alert = json_decode($mannedAlert->getRawText(), true);
  864.     //             // extra param js
  865.     //             $alertObj = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert['alertType'], true);
  866.     //             $alertName = $alertObj->getName() ? $alertObj->getName() : '';
  868.     //             $alert['host'] = API_BASE_URL;
  869.     //             $alert['alertColor'] = $alertName;
  871.     //             $backgroundColor = '#fcb82526';
  872.     //             $borderColor = '#000000';
  873.     //             $textColor = '#000000';
  875.     //             if (isset($alert['alertColor']) && !empty(trim($alert['alertColor']))) {
  876.     //                 $alertColorLower = strtolower(trim($alert['alertColor']));
  878.     //                 if ($alertColorLower === 'red') {
  879.     //                     $backgroundColor = '#f6000017';
  880.     //                     $borderColor = '#F60000';
  881.     //                     $textColor = '#F60000';
  882.     //                 } elseif ($alertColorLower === 'orange') {
  883.     //                     $backgroundColor = '#ff66001f';
  884.     //                     $borderColor = '#FF6600';
  885.     //                     $textColor = '#FF6600';
  886.     //                 } elseif ($alertColorLower === 'yellow') {
  887.     //                     $backgroundColor = '#fcb82526';
  888.     //                     $borderColor = '#FCB825';
  889.     //                     $textColor = '#FCB825';
  890.     //                 }
  891.     //             }
  893.     //             $alert['backgroundColor'] = $backgroundColor;
  894.     //             $alert['borderColor'] = $borderColor;
  895.     //             $alert['textColor'] = $textColor;
  897.     //             $alert['name'] = ""; // ned to fiex this 
  900.     //             if ($mannedAlert->getRawText()) {
  901.     //                 $html = $this->templating->render('web2print/_manned_alert_notification_en.html.twig', $alert);
  902.     //                 $response[$count]['message_en'] = $html;
  905.     //                 $html = $this->templating->render('web2print/_manned_alert_notification.html.twig', $alert);
  906.     //                 $response[$count]['message_ar'] = $html;
  907.     //             } else {
  908.     //                 $response[$count]['message'] = [];
  909.     //             }
  911.     //             $count++;
  912.     //         }
  913.     //     }
  916.     //     return ["success" => true, "total" => count($mannedAlerts), "data" => $response, "paginationVariables" => $paginator->getPaginationData()];
  917.     // }
  919.     public function getMannedAlerts($params, $paginator)
  920.     {
  921.         $response = [];
  922.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  923.         $page = isset($params['page']) ? $params['page'] : 1;
  925.         $mannedAlert = new DataObject\EwsNotification\Listing();
  926.         $mannedAlert->filterByIsManned(1);
  927.         //$mannedAlert->setCondition("o_creationDate > " . strtotime('-2 days'));
  928.         if (!empty($params['alert_status'])) {
  929.             $alertStatusSql = null;
  930.             foreach ($params['alert_status'] as $alertStatus) {
  931.                 $alertStatus = \Pimcore\Model\DataObject\AlertStatus::getByAlertStatusId($alertStatus, true);
  932.                 if ($alertStatus) {
  933.                     $alertStatusSql .= "alertStatus__id = " . $alertStatus->getId() . " OR ";
  934.                 }
  935.             }
  936.             $mannedAlert->addConditionParam("(" . substr($alertStatusSql, 0, -3) . ")");
  937.         }
  939.         if (isset($params['id']) && !empty($params['id'])) {
  940.             $idSql = '';
  941.             $idSql .= "alertId = " . $params['id'] . " OR ";
  942.             $mannedAlert->addConditionParam("(" . substr($idSql, 0, -3) . ")");
  943.         }
  945.         if (!empty($params['alert_region'])) {
  946.             $alertRegionSql = null;
  947.             foreach ($params['alert_region'] as $alertRegionId) {
  948.                 $alertRegion = \Pimcore\Model\DataObject\Region::getByRegionId($alertRegionId, true);
  949.                 if ($alertRegion) {
  950.                     $alertRegionSql .= "region__id = " . $alertRegion->getId() . " OR ";
  951.                 }
  952.             }
  954.             if (!empty($alertRegion)) {
  955.                 $mannedAlert->addConditionParam("(" . substr($alertRegionSql, 0, -3) . ")");
  956.             }
  957.         }
  960.         // added filter for public portal 
  961.         if (isset($params['governorate_id']) && !empty($params['governorate_id'])) {
  962.             $alertGovernorateSql = null;
  963.             foreach ($params['governorate_id'] as $alertGovernorateId) {
  964.                 $alertGovernorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($alertGovernorateId, true);
  965.                 if ($alertGovernorate) {
  966.                     $alertGovernorateSql .= "governorate LIKE '%," . $alertGovernorate->getId() . ",%' OR ";
  967.                 }
  968.             }
  970.             if (!empty($alertGovernorateSql)) {
  971.                 $mannedAlert->addConditionParam("(" . substr($alertGovernorateSql, 0, -3) . ")");
  972.             }
  973.         }
  976.         if (!empty($params['alert_type'])) {
  977.             $alertTypeSql = null;
  978.             foreach ($params['alert_type'] as $alertTypeId) {
  979.                 $alertType = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alertTypeId, true);
  980.                 if ($alertType) {
  981.                     $alertTypeSql .= "alertType__id = " . $alertType->getId() . " OR ";
  982.                 }
  983.             }
  985.             if (!empty($alertTypeSql)) {
  986.                 $mannedAlert->addConditionParam("(" . substr($alertTypeSql, 0, -3) . ")");
  987.             }
  988.         }
  990.         if (!empty($params['alert_actions'])) {
  992.             $alertActionIdSql = "";
  993.             foreach ($params['alert_actions'] as $alertAction) {
  994.                 $alertAction = \Pimcore\Model\DataObject\AlertAction::getByAlertActionId($alertAction, true);
  995.                 if ($alertAction) {
  996.                     $alertActionIdSql .= "alertAction LIKE '%," . $alertAction->getId() . ",%' OR ";
  997.                 }
  998.             }
  1000.             if (!empty($alertActionIdSql)) {
  1001.                 $mannedAlert->addConditionParam("(" . substr($alertActionIdSql, 0, -3) . ")");
  1002.             }
  1003.         }
  1006.         if (!empty($params['from_date'])  && !empty($params['to_date'])) {
  1007.             // $mannedAlert->filterByFromDate($params['from_date'], ">=");
  1008.             // $mannedAlert->filterByToDate($params['to_date'], "<=");
  1009.             // $mannedAlert->filterByFromDate(strtotime($params['from_date']), ">=");
  1010.             $mannedAlert->filterByEndDate(time(), ">=");
  1011.         }
  1013.         $mannedAlert->setOrderKey("lastModifiedDate");
  1014.         $mannedAlert->setOrder("desc");
  1015.         $mannedAlerts = $mannedAlert->load();
  1017.         $timezone = new \DateTimeZone(TIMEZONE);
  1018.         // code for devide api which does not need pagination
  1019.         if ($paginator == null) {
  1021.             $count = 0;
  1022.             foreach ($mannedAlerts as $mannedAlert) {
  1023.                 $response[$count] = [
  1024.                     "id" => $mannedAlert->getAlertId(),
  1025.                     "title" => $mannedAlert->getTitle(),
  1026.                     "other_locations" => [
  1027.                         "en" => $mannedAlert->getOtherLocation(),
  1028.                         "ar" => $mannedAlert->getOtherLocation()
  1029.                     ],
  1030.                     "alert_type" => [
  1031.                         "id" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getAlertTypeId() : null,
  1032.                         "en" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getName('en') : null,
  1033.                         "ar" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getName('ar') : null,
  1034.                         "color" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getColor() : null
  1035.                     ],
  1036.                     "fromDate" => $mannedAlert->getStartDate()->setTimezone($timezone)->toDateTimeString(),
  1037.                     "toDate" => $mannedAlert->getEndDate()->setTimezone($timezone)->toDateTimeString(),
  1038.                     "lastModifiedDate" => $mannedAlert->getLastModifiedDate()->toDateTimeString(),
  1039.                     "rawData" => $mannedAlert->getRawText(),
  1040.                     "region" => [
  1041.                         "id" => ($mannedAlert->getRegion()) ? $mannedAlert->getRegion()->getRegionId() : null,
  1042.                         "en" => ($mannedAlert->getRegion()) ? $mannedAlert->getRegion()->getName('en') : null,
  1043.                         "ar" => ($mannedAlert->getRegion()) ? $mannedAlert->getRegion()->getName('ar') : null
  1044.                     ],
  1045.                     "alert_status" => [
  1046.                         "id" => ($mannedAlert->getalertStatus()) ? $mannedAlert->getalertStatus()->getalertStatusId() : null,
  1047.                         "en" => ($mannedAlert->getalertStatus()) ? $mannedAlert->getalertStatus()->getName('en') : null,
  1048.                         "ar" => ($mannedAlert->getalertStatus()) ? $mannedAlert->getalertStatus()->getName('ar') : null
  1049.                     ]
  1050.                 ];
  1052.                 $alertHazards = $mannedAlert->getalertHazard();
  1053.                 if ($alertHazards) {
  1054.                     foreach ($alertHazards as $alertHazard) {
  1055.                         $response[$count]['alert_hazard'][] = ["id" => $alertHazard->getAlertHazardId(), "name_en" => $alertHazard->getName('en'), "name_ar" => $alertHazard->getName('ar')];
  1056.                     }
  1057.                 }
  1059.                 $governorates = $mannedAlert->getGovernorate();
  1062.                 if ($governorates) {
  1063.                     $alertJsonDecodeData =   json_decode($mannedAlert->getRawText());
  1064.                     $governoratesData = $alertJsonDecodeData->governorates;
  1065.                     foreach ($governorates as $governorate) {
  1066.                         $isEnrireGovernorate = false;
  1067.                         $municipalities = [];
  1068.                         foreach ($governoratesData as $governorateData) {
  1069.                             if ($governorateData->id == $governorate->getGovernoteId()) {
  1070.                                 if (count($governorateData->municipalities) == 0) {
  1072.                                     $isEnrireGovernorate = true;
  1073.                                 } else {
  1074.                                     foreach ($governorateData->municipalities as $municipality) {
  1075.                                         $municipalities[] = [
  1076.                                             "id" => $municipality->id,
  1077.                                             "name_en" => $municipality->nameEn,
  1078.                                             "name_ar" => $municipality->nameAr,
  1079.                                             "longitude" => $municipality->longitude,
  1080.                                             "latitude" => $municipality->latitude
  1081.                                         ];
  1082.                                     }
  1083.                                 }
  1084.                                 break;
  1085.                             }
  1086.                         }
  1088.                         $response[$count]['governorates'][] = [
  1089.                             "id" => $governorate->getGovernoteId(),
  1090.                             "name_en" => $governorate->getName('en'),
  1091.                             "name_ar" => $governorate->getName('ar'),
  1092.                             'isEnrireGovernorate' => $isEnrireGovernorate,
  1093.                             'municipalities' => $municipalities
  1094.                         ];
  1095.                     }
  1096.                 }
  1098.                 $alertActionMasters = $mannedAlert->getAlertAction();
  1099.                 if ($alertActionMasters) {
  1100.                     foreach ($alertActionMasters as $alertActionMaster) {
  1101.                         $response[$count]['alert_actions'][] = ["id" => $alertActionMaster->getAlertActionId(), "name_en" => $alertActionMaster->getName('en'), "name_ar" => $alertActionMaster->getName('ar')];
  1102.                     }
  1103.                 }
  1105.                 $alert = json_decode($mannedAlert->getRawText(), true);
  1107.                 // extra param js
  1108.                 $alertObj = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert['alertType'], true);
  1109.                 $alertName = $alertObj->getName() ? $alertObj->getName() : '';
  1111.                 $alert['host'] = API_BASE_URL;
  1112.                 $alert['alertColor'] = $alertName;
  1114.                 $backgroundColor = '#fcb82526';
  1115.                 $borderColor = '#000000';
  1116.                 $textColor = '#000000';
  1118.                 if (isset($alert['alertColor']) && !empty(trim($alert['alertColor']))) {
  1119.                     $alertColorLower = strtolower(trim($alert['alertColor']));
  1121.                     if ($alertColorLower === 'red') {
  1122.                         $backgroundColor = '#f6000017';
  1123.                         $borderColor = '#F60000';
  1124.                         $textColor = '#F60000';
  1125.                     } elseif ($alertColorLower === 'orange') {
  1126.                         $backgroundColor = '#ff66001f';
  1127.                         $borderColor = '#FF6600';
  1128.                         $textColor = '#FF6600';
  1129.                     } elseif ($alertColorLower === 'yellow') {
  1130.                         $backgroundColor = '#fcb82526';
  1131.                         $borderColor = '#FCB825';
  1132.                         $textColor = '#FCB825';
  1133.                     }
  1134.                 }
  1136.                 $alert['backgroundColor'] = $backgroundColor;
  1137.                 $alert['borderColor'] = $borderColor;
  1138.                 $alert['textColor'] = $textColor;
  1140.                 $alert['name'] = ""; // ned to fiex this 
  1143.                 if ($mannedAlert->getRawText()) {
  1144.                     $html = $this->templating->render('web2print/_manned_alert_notification_en.html.twig', $alert);
  1145.                     $response[$count]['message_en'] = $html;
  1148.                     $html = $this->templating->render('web2print/_manned_alert_notification.html.twig', $alert);
  1149.                     $response[$count]['message_ar'] = $html;
  1150.                 } else {
  1151.                     $response[$count]['message'] = [];
  1152.                 }
  1154.                 $count++;
  1155.             }
  1157.             return ["success" => true, "data" => $response];
  1158.         }
  1160.         $paginator = $paginator->paginate(
  1161.             $mannedAlerts,
  1162.             $page,
  1163.             $pageSize
  1164.         );
  1166.         if ($paginator) {
  1167.             $count = 0;
  1168.             foreach ($paginator as $mannedAlert) {
  1169.                 $response[$count] = [
  1170.                     "id" => $mannedAlert->getAlertId(),
  1171.                     "title" => $mannedAlert->getTitle(),
  1172.                     "other_locations" => [
  1173.                         "en" => $mannedAlert->getOtherLocation(),
  1174.                         "ar" => $mannedAlert->getOtherLocation()
  1175.                     ],
  1176.                     "alert_type" => [
  1177.                         "id" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getAlertTypeId() : null,
  1178.                         "en" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getName('en') : null,
  1179.                         "ar" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getName('ar') : null,
  1180.                         "color" => ($mannedAlert->getAlertType()) ? $mannedAlert->getAlertType()->getColor() : null
  1181.                     ],
  1182.                     "fromDate" => $mannedAlert->getStartDate()->toDateTimeString(),
  1183.                     "toDate" => $mannedAlert->getEndDate()->toDateTimeString(),
  1184.                     "lastModifiedDate" => $mannedAlert->getLastModifiedDate()->toDateTimeString(),
  1185.                     "region" => [
  1186.                         "id" => ($mannedAlert->getRegion()) ? $mannedAlert->getRegion()->getRegionId() : null,
  1187.                         "en" => ($mannedAlert->getRegion()) ? $mannedAlert->getRegion()->getName('en') : null,
  1188.                         "ar" => ($mannedAlert->getRegion()) ? $mannedAlert->getRegion()->getName('ar') : null
  1189.                     ],
  1190.                     "alert_status" => [
  1191.                         "id" => ($mannedAlert->getalertStatus()) ? $mannedAlert->getalertStatus()->getalertStatusId() : null,
  1192.                         "en" => ($mannedAlert->getalertStatus()) ? $mannedAlert->getalertStatus()->getName('en') : null,
  1193.                         "ar" => ($mannedAlert->getalertStatus()) ? $mannedAlert->getalertStatus()->getName('ar') : null
  1194.                     ]
  1195.                 ];
  1197.                 $alertHazards = $mannedAlert->getalertHazard();
  1198.                 if ($alertHazards) {
  1199.                     foreach ($alertHazards as $alertHazard) {
  1200.                         $response[$count]['alert_hazard'][] = ["id" => $alertHazard->getAlertHazardId(), "name_en" => $alertHazard->getName('en'), "name_ar" => $alertHazard->getName('ar')];
  1201.                     }
  1202.                 }
  1204.                 $governorates = $mannedAlert->getGovernorate();
  1205.                 if ($governorates) {
  1206.                     foreach ($governorates as $governorate) {
  1207.                         $response[$count]['governorates'][] = ["id" => $governorate->getGovernoteId(), "name_en" => $governorate->getName('en'), "name_ar" => $governorate->getName('ar')];
  1208.                     }
  1209.                 }
  1211.                 $alertActionMasters = $mannedAlert->getAlertAction();
  1212.                 if ($alertActionMasters) {
  1213.                     foreach ($alertActionMasters as $alertActionMaster) {
  1214.                         $response[$count]['alert_actions'][] = ["id" => $alertActionMaster->getAlertActionId(), "name_en" => $alertActionMaster->getName('en'), "name_ar" => $alertActionMaster->getName('ar')];
  1215.                     }
  1216.                 }
  1218.                 $alert = json_decode($mannedAlert->getRawText(), true);
  1220.                 // extra param js
  1221.                 $alertObj = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert['alertType'], true);
  1222.                 $alertName = $alertObj->getName() ? $alertObj->getName() : '';
  1224.                 $alert['host'] = API_BASE_URL;
  1225.                 $alert['alertColor'] = $alertName;
  1227.                 $backgroundColor = '#fcb82526';
  1228.                 $borderColor = '#000000';
  1229.                 $textColor = '#000000';
  1231.                 if (isset($alert['alertColor']) && !empty(trim($alert['alertColor']))) {
  1232.                     $alertColorLower = strtolower(trim($alert['alertColor']));
  1234.                     if ($alertColorLower === 'red') {
  1235.                         $backgroundColor = '#f6000017';
  1236.                         $borderColor = '#F60000';
  1237.                         $textColor = '#F60000';
  1238.                     } elseif ($alertColorLower === 'orange') {
  1239.                         $backgroundColor = '#ff66001f';
  1240.                         $borderColor = '#FF6600';
  1241.                         $textColor = '#FF6600';
  1242.                     } elseif ($alertColorLower === 'yellow') {
  1243.                         $backgroundColor = '#fcb82526';
  1244.                         $borderColor = '#FCB825';
  1245.                         $textColor = '#FCB825';
  1246.                     }
  1247.                 }
  1249.                 $alert['backgroundColor'] = $backgroundColor;
  1250.                 $alert['borderColor'] = $borderColor;
  1251.                 $alert['textColor'] = $textColor;
  1253.                 $alert['name'] = ""; // ned to fiex this 
  1256.                 if ($mannedAlert->getRawText()) {
  1257.                     $html = $this->templating->render('web2print/_manned_alert_notification_en.html.twig', $alert);
  1258.                     $response[$count]['message_en'] = $html;
  1261.                     $html = $this->templating->render('web2print/_manned_alert_notification.html.twig', $alert);
  1262.                     $response[$count]['message_ar'] = $html;
  1263.                 } else {
  1264.                     $response[$count]['message'] = [];
  1265.                 }
  1267.                 $count++;
  1268.             }
  1269.         }
  1272.         return ["success" => true, "total" => count($mannedAlerts), "data" => $response, "paginationVariables" => $paginator->getPaginationData()];
  1273.     }
  1276.     public function getAlertHistory($user, $params)
  1277.     {
  1279.         $response = [];
  1280.         $alertHistory = new DataObject\AlertHistory\Listing();
  1282.         $alertHistory->filterByUser($user);
  1283.         if (!empty($params['location_id'])) {
  1284.             $location_id = $params['location_id'];
  1285.             $alertHistory->addConditionParam("Location__id = ?", $location_id, "AND");
  1286.         }
  1287.         if (!empty($params['title'])) {
  1288.             $title = $params['title'];
  1289.             $alertHistory->addConditionParam("AdministrativeTitle LIKE ?", "%$title%", "AND");
  1290.         }
  1292.         $alertHistory->setOffset(!empty($params['offset']) ? $params['offset'] : 0);
  1293.         $alertHistory->setLimit(!empty($params['limit']) ? $params['limit'] : LIMIT_PER_PAGE);
  1295.         $alertHistory->setOrderKey("o_creationDate");
  1296.         $alertHistory->setOrder("desc");
  1297.         $alertHistorys = $alertHistory->load();
  1299.         if ($alertHistorys) {
  1300.             foreach ($alertHistorys as $alertHistory) {
  1301.                 $response[] = [
  1302.                     "id" => $alertHistory->getId(),
  1303.                     "modification_date" => $alertHistory->getModificaitonDate()->toDateTimeString(),
  1304.                     "title" => $alertHistory->getAdministrativeTitle(),
  1305.                     "color" => $alertHistory->getColorCode(),
  1306.                     "units" => $alertHistory->getUnits(),
  1307.                     "min_value" => $alertHistory->getMinValue(),
  1308.                     "max_value" => $alertHistory->getMaxValue(),
  1309.                     "weather_model" => $alertHistory->getWeatherModel(),
  1310.                     "alert_enable" => $alertHistory->getAlertEnable(),
  1311.                     "alert_type" => $alertHistory->getAlertType(),
  1312.                     "location" => ($alertHistory->getLocation()) ? $alertHistory->getLocation()->getName() : '',
  1313.                     "user" => $alertHistory->getUser()->getEmail(),
  1314.                     "is_sent" => $alertHistory->getisSent(),
  1315.                 ];
  1316.             }
  1317.         }
  1319.         return ["success" => true, "total" => count($alertHistorys), "data" => $response];
  1320.     }
  1322.     public function getCustomNotificationLog($id)
  1323.     {
  1324.         $notificationArr = [];
  1325.         $notificationLog = new Listing();
  1326.         if ($id) {
  1327.             $notificationLog->setCondition("customNotificationId = {$id}");
  1328.         }
  1329.         $notifications = $notificationLog->load();
  1330.         if ($notifications) {
  1331.             $count = 0;
  1332.             foreach ($notifications as $notification) {
  1333.                 $customNotification = \Pimcore\Model\DataObject::getById($notification->getcustomNotificationId());
  1334.                 if ($customNotification) {
  1335.                     $notificationArr[$count]['id'] = $notification->getId();
  1336.                     $notificationArr[$count]['customNotificationId'] = $notification->getcustomNotificationId();
  1337.                     $notificationArr[$count]['datetime'] = $notification->getDatetime();
  1338.                     $notificationArr[$count]['thresholdValue'] = $notification->getthresholdValue();
  1339.                     $notificationArr[$count]['color'] = $notification->getColor();
  1340.                     $notificationArr[$count]['customNotificaiton'] = [
  1341.                         "id" => $customNotification->getId(),
  1342.                         'location_id' => ($customNotification->getLocation()) ? $customNotification->getLocation()->getId() : 0,
  1343.                         "alert_type" => $customNotification->getAlert()->getName(),
  1344.                         "alert_key" => $customNotification->getAlert()->getAlertKey(),
  1345.                         "location_name" => $customNotification->getLocation()->getName(),
  1346.                         "title" => $customNotification->gettitle(),
  1347.                         "color" => $customNotification->getColor(),
  1348.                         "units" => $customNotification->getunits(),
  1349.                         "min_value" => $customNotification->getMinValue(),
  1350.                         "max_value" => $customNotification->getMaxValue(),
  1351.                         "weather_model" => $customNotification->getWeatherModel(),
  1352.                         "alert_on_email" => $customNotification->getalertOnEmail(),
  1353.                         "alert_on_sms" => $customNotification->getalertOnSMS(),
  1354.                         "calculation" => $customNotification->getCalculate()
  1355.                     ];
  1356.                 }
  1357.             }
  1358.         }
  1360.         return $notificationArr;
  1361.     }
  1363.     public function getUserCustomNotificationByOrganization($params, $organizationId, $loggedInUser, $paginator)
  1364.     {
  1365.         // try {
  1366.         $response = [];
  1368.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  1369.         $page = isset($params['page']) ? $params['page'] : 1;
  1371.         $organization = \Pimcore\Model\DataObject::getById($organizationId);
  1372.         if (!$organization instanceof \Pimcore\Model\DataObject\Organization) {
  1373.             throw new \Exception("Organization does not exists");
  1374.         }
  1375.         // retrieve customer by userId  
  1376.         $customers = new Customer\Listing();
  1377.         $customers->filterByOrganization($organization);
  1378.         if ($customers->getCount() == 0) {
  1379.             throw new \Exception("Customer does not exists in this organization");
  1380.         }
  1381.         foreach ($customers as $customer) {
  1382.             $customNotifications = new CustomNotification\Listing();
  1383.             $customNotifications->addConditionParam("user like '%," . $customer->getId() . ",%'");
  1385.             //filter by Name
  1386.             if (isset($params['search']) && !empty($params['search'])) {
  1387.                 $customNotifications->addConditionParam("title like '%" . $params['search'] . "%'");
  1388.             }
  1390.             //filter by color
  1391.             if (isset($params['color']) && !empty($params['color'])) {
  1392.                 $customNotifications->addConditionParam("color like '%" . $params['color'] . "%'");
  1393.             }
  1395.             //filter by calculation 
  1396.             if (isset($params['calculation']) && !empty($params['calculation'])) {
  1397.                 $customNotifications->addConditionParam("calculate like '%" . $params['calculation'] . "%'");
  1398.             }
  1399.             //$customNotifications->filterByUser($customer);
  1400.             if ($customNotifications->getCount() > 0) {
  1401.                 foreach ($customNotifications as $customNotification) {
  1402.                     //  p_r($customNotification->getAlert());exit; 
  1403.                     if (count($customNotification->getUser()) > 0) {
  1404.                         foreach ($customNotification->getUser() as $user) {
  1405.                             $user = $user->getObject();
  1406.                             if ($user instanceof Customer && $user->getId() != $loggedInUser->getId()) {
  1409.                                 if ($customNotification->getLocation() && $customNotification->getAlert()) {
  1411.                                     // Check if the entry already exists for this customer and notification
  1412.                                     $existingEntry = array_filter(
  1413.                                         $response,
  1414.                                         function ($entry) use ($customNotification, $user) {
  1415.                                             return (
  1416.                                                 $entry['id'] == $customNotification->getId() &&
  1417.                                                 $entry['customerId'] == $user->getId()
  1418.                                             );
  1419.                                         }
  1420.                                     );
  1421.                                     // Add the entry only if it doesn't exist
  1422.                                     if (empty($existingEntry)) {
  1423.                                         $response[] = [
  1424.                                             "id" => $customNotification->getId(),
  1425.                                             'location_id' => ($customNotification->getLocation()) ? $customNotification->getLocation()->getId() : 0,
  1426.                                             "alert_type" => $customNotification->getAlert()->getName(),
  1427.                                             "alert_key" => $customNotification->getAlert()->getAlertKey(),
  1428.                                             "location_name" => $customNotification->getLocation()->getName(),
  1429.                                             "title" => $customNotification->gettitle(),
  1430.                                             "color" => $customNotification->getColor(),
  1431.                                             "units" => $customNotification->getunits(),
  1432.                                             "min_value" => $customNotification->getMinValue(),
  1433.                                             "max_value" => $customNotification->getMaxValue(),
  1434.                                             "weather_model" => $customNotification->getWeatherModel(),
  1435.                                             "alert_on_email" => $customNotification->getalertOnEmail(),
  1436.                                             "alert_on_sms" => $customNotification->getalertOnSMS(),
  1437.                                             "calculation" => $customNotification->getCalculate(),
  1438.                                             "duration" => $customNotification->getDuration(),
  1439.                                             "customerId" => $user->getId(),
  1440.                                             "customerName" => $user->getName(),
  1441.                                             "customerEmail" => $user->getEmail()
  1442.                                         ];
  1443.                                     }
  1444.                                 }
  1445.                             }
  1446.                         }
  1447.                     }
  1448.                 }
  1449.             }
  1450.         }
  1452.         $paginator = $paginator->paginate(
  1453.             $response,
  1454.             $page,
  1455.             $pageSize
  1456.         );
  1457.         // } catch (\Exception $e) {
  1458.         //     throw new \Exception($e->getMessage());
  1459.         // }
  1462.         return ["success" => true, "data" => $paginator, 'paginationVariables' => $paginator->getPaginationData()];
  1463.     }
  1465.     public function updateSubscribeAlerts($customer, $notificationId, $locationId, $alertType, $title, $color, $units, $minValue, $maxValue, $weatherModel, $alertOnEmail, $alertOnSMS, $calculate, $duration, $frequency=1, $translator)
  1466.     {
  1467.         // retrieve customer by userId
  1468.         if (!$customer instanceof Customer) {
  1469.             throw new \Exception('Customer not found for userId:');
  1470.         }
  1472.         // retrieve location by locationId
  1473.         $location = DataObject::getById($locationId);
  1474.         if (!$location) {
  1475.             throw new \Exception('Location not found for locationId: ' . $locationId);
  1476.         }
  1478.         // retrieve alertType by alertType
  1479.         $alertType = AlertMaster::getByAlertKey($alertType, true);
  1480.         if (!$alertType) {
  1481.             throw new \Exception('Alert type not found: ' . $alertType);
  1482.         }
  1484.         $customNotification = \Pimcore\Model\DataObject::getById($notificationId, true);
  1485.         if (!$customNotification instanceof CustomNotification) {
  1486.             throw new \Exception('Custom notification not found with id.');
  1487.         }
  1488.         $customNotification->setTitle($title);
  1489.         $customNotification->setColor($color);
  1490.         $customNotification->setUnits($units);
  1491.         $customNotification->setMinValue($minValue);
  1492.         $customNotification->setMaxValue($maxValue);
  1493.         $customNotification->setWeatherModel($weatherModel);
  1496.         $customNotification->setLocation($location);
  1498.         $objectArray = ($customNotification) ? $customNotification->getUser() : [];
  1499.         if ($objectArray) {
  1500.             foreach ($objectArray as $key => $objUser) {
  1501.                 $currentUser = $objUser->getObject();
  1502.                 if ($currentUser->getId() == $customer->getId()) {
  1504.                     unset($objectArray[$key]);
  1506.                     break; // Stop the loop once a match is found
  1507.                 }
  1508.             }
  1510.             $objectMetadata = new DataObject\Data\ObjectMetadata('user', ['token', 'alert_on_email', 'alert_on_sms'],  $customer);
  1511.             $objectMetadata->setToken("");
  1512.             $objectMetadata->setAlert_on_email($alertOnEmail);
  1513.             $objectMetadata->setAlert_on_sms($alertOnSMS);
  1514.             array_push($objectArray, $objectMetadata);
  1515.             $customNotification->setUser($objectArray);
  1516.         }
  1517.         $customNotification->setAlert($alertType);
  1518.         $customNotification->setStatus(true);
  1519.         $customNotification->setPublished(true);
  1520.         $customNotification->setCalculate($calculate);
  1521.         $customNotification->setDuration($duration);
  1522.         $customNotification->setFrequency($frequency);
  1523.         $customNotification->save();
  1525.         return [
  1526.             "success" => true,
  1527.             "data" => [
  1528.                 "id" => $customNotification->getId()
  1529.             ],
  1530.             "message" => $translator->trans("update_successfully")
  1531.         ];
  1532.     }
  1534.     public function getCustomNotificationAlerts($params, $paginator)
  1535.     {
  1536.         $response = [];
  1537.         $customNotifications = [];
  1539.         $customNotificationQuery = new CustomNotification\Listing();
  1540.         $color = '';
  1541.         $condition = '';
  1542.         $model = '';
  1544.         if (!empty($params['color'])) {
  1545.             $color = $params['color'];
  1546.             $customNotificationQuery->addConditionParam("color = ?", $color, "AND");
  1547.         }
  1548.         if (!empty($params['condition'])) {
  1549.             $condition = $params['condition'];
  1550.             $customNotificationQuery->addConditionParam("calculate = ?", $condition, "AND");
  1551.         }
  1552.         if (!empty($params['model'])) {
  1553.             $model = $params['model'];
  1554.             $customNotificationQuery->addConditionParam("weatherModel = ?", $model, "AND");
  1555.         }
  1557.         $customNotificationQuery->setOffset(!empty($params['offset']) ? $params['offset'] : 0);
  1558.         $customNotificationQuery->setLimit(!empty($params['limit']) ? $params['limit'] : LIMIT_PER_PAGE);
  1560.         $customNotificationQuery->setOrder("desc");
  1561.         $customNotifications = $customNotificationQuery->load();
  1563.         if (!empty($customNotifications)) {
  1564.             foreach ($customNotifications as $customNotification) {
  1565.                 $response[] = [
  1566.                     "id" => $customNotification->getId(),
  1567.                     'location_id' => ($customNotification->getLocation()) ? $customNotification->getLocation()->getId() : 0,
  1568.                     "alert_type" => $customNotification->getAlert()->getName(),
  1569.                     "alert_key" => $customNotification->getAlert()->getAlertKey(),
  1570.                     "location_name" => ($customNotification->getLocation()) ? $customNotification->getLocation()->getTitle() : '',
  1571.                     "title" => $customNotification->getTitle(),
  1572.                     "color" => $customNotification->getColor(),
  1573.                     "units" => $customNotification->getunits(),
  1574.                     "min_value" => $customNotification->getMinValue(),
  1575.                     "max_value" => $customNotification->getMaxValue(),
  1576.                     "weather_model" => $customNotification->getWeatherModel(),
  1577.                     "alert_on_email" => $customNotification->getalertOnEmail(),
  1578.                     "alert_on_sms" => $customNotification->getalertOnSMS(),
  1579.                     "calculation" => $customNotification->getCalculate(),
  1580.                 ];
  1581.             }
  1582.         }
  1583.         return ["success" => true, "total" => count($customNotifications), "data" => $response];
  1584.     }
  1586.     public function customNotificationFilters($translator)
  1587.     {
  1588.         $response = [];
  1590.         $response[] = [
  1591.             "model" => \App\Lib\Utility::customNotificationWeatherModelList(),
  1592.             "parameters" => \App\Lib\Utility::customNotificationParametersList(),
  1593.             "colors" => \App\Lib\Utility::customNotificationConfigColorsList(),
  1594.             "condition" => \App\Lib\Utility::customNotificationConditionList(),
  1595.             "durations" => \App\Lib\Utility::customNotificationDurationsList($translator)
  1596.         ];
  1598.         return ["success" => true, "data" => $response];
  1599.     }
  1601.     public function updateSubscribeNotification($token, $translator)
  1602.     {
  1605.         $db = Db::get();
  1606.         $select = $db->createQueryBuilder();
  1607.         $select->select('cn.o_id AS cn_id', 'cn.dest_id  AS user_id', 'cn.auto_id  AS id')
  1608.             ->from('object_metadata_custom_notification', 'cn')
  1609.             ->andwhere('cn.column = :type')
  1610.             ->andwhere('cn.data = :token')
  1611.             ->setParameter('token', $token)
  1612.             ->setParameter('type', 'token');
  1613.         $result = $select->execute()->fetchAllAssociative();
  1615.         if (empty($result)) {
  1616.             return ["success" => false, "message" => $translator->trans("invalid_token")];
  1617.         }
  1618.         $result = $result[0];
  1621.         $user = \Pimcore\Model\DataObject\Customer::getById($result['user_id']);
  1622.         $customNotification = \Pimcore\Model\DataObject\CustomNotification::getById($result['cn_id']);
  1624.         if ($customNotification instanceof \Pimcore\Model\DataObject\CustomNotification && $user instanceof \Pimcore\Model\DataObject\Customer) {
  1626.             $objectArray = ($customNotification) ? $customNotification->getUser() : [];
  1627.             if ($objectArray) {
  1628.                 foreach ($objectArray as $key => $objUser) {
  1629.                     $currentUser = $objUser->getObject();
  1630.                     if ($currentUser->getId() == $user->getId()) {
  1632.                         unset($objectArray[$key]);
  1634.                         break; // Stop the loop once a match is found
  1635.                     }
  1636.                 }
  1638.                 $objectMetadata = new DataObject\Data\ObjectMetadata('user', ['token', 'alert_on_email', 'alert_on_sms'],  $user);
  1639.                 $objectMetadata->setToken("");
  1640.                 $objectMetadata->setAlert_on_email(false);
  1641.                 $objectMetadata->setAlert_on_sms(false);
  1642.                 array_push($objectArray, $objectMetadata);
  1644.                 $customNotification->setUser($objectArray);
  1645.                 $customNotification->save();
  1646.             }
  1648.             return ["success" => true, "message" => $translator->trans("you_have_successfully_unsubscribed_that_notification")];
  1649.         } else {
  1650.             return ["success" => false, "message" => $translator->trans("notification_not_found")];
  1651.         }
  1652.     }
  1655.     public function unSubscribeEwsNotification($token, $translator)
  1656.     {
  1659.         $user = \Pimcore\Model\DataObject\Customer::getByEwsNotificationToken($token, true);
  1661.         if ($user) {
  1662.             $user->setEwsNotificationToken("");
  1663.             $user->setSendEwsEmail(false);
  1664.             $user->save();
  1665.             return ["success" => true, "message" => $translator->trans("you_have_successfully_unsubscribed_that_notification")];
  1666.         } else {
  1667.             return ["success" => false, "message" => $translator->trans("user_not_found")];
  1668.         }
  1669.     }
  1671.     public function mannedAlertSubscription($customer, $params, $translator)
  1672.     {
  1673.         $region_id = isset($params['region_id']) ? $params['region_id'] : null;
  1674.         $governorate_ids = isset($params['governorate_id']) ? (array)$params['governorate_id'] : [];
  1675.         $alert_status_id = isset($params['alert_status_id']) ? $params['alert_status_id'] : 0;
  1676.         $alert_type_ids = isset($params['alert_type_id']) ? $params['alert_type_id'] : [];
  1677.         $phenomena_ids = isset($params['phenomena_id']) ? $params['phenomena_id'] : [];
  1678.         $is_public = isset($params['is_public']) ? $params['is_public'] : false;
  1679.         $email = isset($params['email']) ? strtolower($params['email']) : '';
  1680.         $notifyEmail = isset($params['notifyEmail']) ? $params['notifyEmail'] : true;
  1681.         $notifySMS = isset($params['notifySMS']) ? $params['notifySMS'] : true;
  1684.         if (!$customer instanceof Customer) {
  1685.             return ["success" => false, "message" => $translator->trans("customer_not_found_for_" . $customer->getId())];
  1686.         }
  1687.         $alertRegion = null;
  1688.         if ($region_id) {
  1689.             $alertRegion = \Pimcore\Model\DataObject\Region::getByRegionId($region_id, true);
  1690.             if (!$alertRegion) {
  1691.                 return ["success" => false, "message" => $translator->trans("region_not_found_for_" . $region_id)];
  1692.             }
  1693.         }
  1696.         // $alertStatus = \Pimcore\Model\DataObject\AlertStatus::getById($alert_status_id, true);
  1697.         // if (!$alertStatus) {
  1698.         //     return ["success" => false, "message" => $translator->trans("alert_status_not_found_for_".$alert_status_id)];
  1699.         // }
  1701.         $alertTypeIDS = [];
  1702.         foreach ($alert_type_ids as $alert_type_id) {
  1703.             $alertType = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert_type_id, true);
  1704.             if (!$alertType) {
  1705.                 return ["success" => false, "message" => $translator->trans("alert_type_not_found_for_" . $alert_type_id)];
  1706.             }
  1707.             $alertTypeIDS[] = $alertType->getId();
  1708.         }
  1710.         $governateIDS = [];
  1711.         $governorate = null;
  1712.         foreach ($governorate_ids as $govId) {
  1713.             $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($govId, true);
  1716.             if (!$governorate) {
  1717.                 return ["success" => false, "message" => $translator->trans("governorate_not_found_for_" . $govId)];
  1718.             }
  1719.             $governateIDS[] = $governorate->getId();
  1720.         }
  1722.         $phenomenaIDS = [];
  1723.         foreach ($phenomena_ids as $phenomena_id) {
  1724.             $phenomena = \Pimcore\Model\DataObject\AlertStatus::getByAlertStatusId($phenomena_id, true);
  1725.             if (!$phenomena) {
  1726.                 return ["success" => false, "message" => $translator->trans("alert_status_not_found_for_" . $phenomena_id)];
  1727.             }
  1728.             $phenomenaIDS[] = $phenomena->getId();
  1729.         }
  1731.         $govID = implode(',', $governateIDS);
  1732.         $alertID = implode(',', $alertTypeIDS);
  1733.         $phenomenaID = implode(',', $phenomenaIDS);
  1735.         $existingSubscription = new DataObject\MannedAlertSubscription\Listing();
  1736.         if ($alertRegion) {
  1737.             $existingSubscription->addConditionParam("region__id = ?", [$alertRegion->getId()]);
  1738.         }
  1739.         $existingSubscription->addConditionParam("governorate = ? ", [',' . $govID . ',']);
  1740.         $existingSubscription->addConditionParam("alertType = ? ", [',' . $alertID . ',']);
  1741.         $existingSubscription->addConditionParam("alertStatus = ? ", [',' . $phenomenaID . ',']);
  1742.         if ($is_public) {
  1743.             $existingSubscription->addConditionParam("LOWER(email) = ?", [$email]);
  1744.         } else {
  1745.             $existingSubscription->addConditionParam("creator__id = ?", [$customer->getId()]);
  1746.         }
  1747.         $existingSubscription->setOrderKey("oo_id");
  1748.         $existingSubscription->setOrder("desc");
  1749.         $existingSubscription->load();
  1751.         if (count($existingSubscription) > 0) {
  1752.             return ["success" => false, "message" => $translator->trans("manned_alert_subscription_already_exists")];
  1753.         }
  1755.         // Create the subscription if it doesn't exist
  1756.         if ($governorate !== null) {
  1757.             $key = \Pimcore\Model\Element\Service::getValidKey($governorate->getId(), 'object');
  1758.         } else {
  1759.             $key = \Pimcore\Model\Element\Service::getValidKey($email, 'object');
  1760.         }
  1761.         $mannedSubscription = new \Pimcore\Model\DataObject\MannedAlertSubscription();
  1762.         $mannedSubscription->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Subscription/' . $customer->getEmail()));
  1763.         $mannedSubscription->setKey($key . time() . rand(0, 100));
  1765.         $mannedSubscription->setRegion($alertRegion);
  1766.         $governorateOBJ = [];
  1767.         foreach ($governorate_ids as $govId) {
  1768.             $governorateOBJ[] = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($govId, true);
  1769.         }
  1770.         $alert_typeOBJ = [];
  1771.         foreach ($alert_type_ids as $alert_type_id) {
  1772.             $alert_typeOBJ[] = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert_type_id, true);
  1773.         }
  1774.         $phenomenaOBJ = [];
  1775.         foreach ($phenomena_ids as $phenomena_id) {
  1776.             $phenomenaOBJ[] = \Pimcore\Model\DataObject\AlertStatus::getByAlertStatusId($phenomena_id, true);
  1777.         }
  1779.         $mannedSubscription->setGovernorate($governorateOBJ);
  1780.         $mannedSubscription->setAlertType($alert_typeOBJ);
  1781.         $mannedSubscription->setAlertStatus($phenomenaOBJ);
  1782.         $mannedSubscription->setCreator($customer);
  1783.         $mannedSubscription->setIsSubscribed($notifyEmail);
  1784.         $mannedSubscription->setNotifyEmail($notifyEmail);
  1785.         $mannedSubscription->setNotifySMS($notifySMS);
  1786.         $mannedSubscription->setIsPublic($is_public);
  1787.         $mannedSubscription->setEmail($email);
  1788.         $mannedSubscription->setPublished(true);
  1789.         $mannedSubscription->save();
  1791.         return ["success" => true, "message" => $translator->trans("manned_alert_subscription_created")];
  1792.     }
  1794.     public function mannedAlertSubscriber($params, $user, $translator)
  1795.     {
  1796.         $subscription_id = isset($params['subscription_id']) ? (int)$params['subscription_id'] : 0;
  1797.         $isOwner = isset($params['isOwner']) ? (bool)$params['isOwner'] : false;
  1799.         // Permission check: only client admin can assign
  1800.         if (!empty($user->getRole()) && $user->getRole()->getName() !== USER_ROLES['CLIENT_ADMIN']) {
  1801.             return ["success" => false, "message" => $translator->trans("you_are_not_allowed_to_assign_subscription")];
  1802.         }
  1804.         // Load and validate subscription once
  1805.         $subscription = \Pimcore\Model\DataObject\MannedAlertSubscription::getById($subscription_id, true);
  1806.         if (!$subscription instanceof \Pimcore\Model\DataObject\MannedAlertSubscription) {
  1807.             return ["success" => false, "message" => $translator->trans("subscription_not_found_for_subscription_id_" . $subscription_id)];
  1808.         }
  1810.         // Normalize user ids: user_id can be scalar or array
  1811.         $userIds = [];
  1812.         if (isset($params['user_id'])) {
  1813.             if (is_array($params['user_id'])) {
  1814.                 $userIds = array_values(array_unique(array_map('intval', array_filter($params['user_id']))));
  1815.             } else {
  1816.                 $userIds = [ (int)$params['user_id'] ];
  1817.             }
  1818.         }
  1820.         $added = 0;
  1821.         $keyBase = \Pimcore\Model\Element\Service::getValidKey($subscription->getId(), 'object');
  1823.         foreach ($userIds as $user_id) {
  1824.             if (!$user_id) {
  1825.                 continue;
  1826.             }
  1828.             $customer = \Pimcore\Model\DataObject\Customer::getById($user_id, true);
  1829.             if (!$customer instanceof Customer) {
  1830.                 continue; // skip invalid user ids
  1831.             }
  1833.             // Check for existing assignment
  1834.             $existingSubscriber = new DataObject\MannedAlertSubscriber\Listing();
  1835.             $existingSubscriber->addConditionParam("userId__id = ?", [$customer->getId()]);
  1836.             $existingSubscriber->addConditionParam("subscriptionId__id = ?", [$subscription->getId()]);
  1837.             $existingSubscriber->setOrderKey("o_id");
  1838.             $existingSubscriber->setOrder("desc");
  1839.             $existingSubscriber->load();
  1841.             if (count($existingSubscriber) > 0) {
  1842.                 continue; // skip duplicates
  1843.             }
  1845.             // Create subscription assignment
  1846.             $mannedSubscriber = new \Pimcore\Model\DataObject\MannedAlertSubscriber();
  1847.             $mannedSubscriber->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Subscriber/' . $customer->getEmail()));
  1848.             $mannedSubscriber->setKey($keyBase . time() . rand(0, 100));
  1849.             $mannedSubscriber->setUserId($customer);
  1850.             $mannedSubscriber->setSubscriptionId($subscription);
  1851.             $mannedSubscriber->setIsOwner($isOwner);
  1852.             $mannedSubscriber->setPublished(true);
  1853.             $mannedSubscriber->save();
  1855.             // Also add to subscription subscribers relation (avoid duplicates)
  1856.             $currentSubscribers = $subscription->getSubscribers();
  1857.             $updatedSubscribers = [];
  1858.             if ($currentSubscribers instanceof \Traversable || is_array($currentSubscribers)) {
  1859.                 foreach ($currentSubscribers as $existing) {
  1860.                     $updatedSubscribers[] = $existing;
  1861.                 }
  1862.             }
  1863.             $alreadyRelated = false;
  1864.             foreach ($updatedSubscribers as $existing) {
  1865.                 if (method_exists($existing, 'getId') && $existing->getId() === $customer->getId()) {
  1866.                     $alreadyRelated = true;
  1867.                     break;
  1868.                 }
  1869.             }
  1870.             if (!$alreadyRelated) {
  1871.                 $updatedSubscribers[] = $customer;
  1872.                 $subscription->setSubscribers($updatedSubscribers);
  1873.                 $subscription->save();
  1874.             }
  1876.             $added++;
  1877.         }
  1879.         if (count($userIds) > 1) {
  1880.             // Collective response for multiple users
  1881.             return ["success" => $added > 0, "message" => $translator->trans("subscription_assigned_successfully") . ": " . $added];
  1882.         }
  1884.         // Single user response
  1885.         if ($added === 1) {
  1886.             return ["success" => true, "message" => $translator->trans("subscription_assigned_successfully")];
  1887.         }
  1889.         return ["success" => false, "message" => $translator->trans("this_subscription_already_assigned_to_this_user")];
  1890.     }
  1892.     public function listMannedAlertSubscription($params, $user, $paginator)
  1893.     {
  1894.         $pageSize = $params['page_size'] ?? LIMIT_PER_PAGE;
  1895.         $page = $params['page'] ?? 1;
  1897.         $mannedAlertSubscription = new DataObject\MannedAlertSubscription\Listing();
  1898.         if (isset($params['isAssigned'])) {
  1899.             $isAssignedParam = $params['isAssigned'];
  1900.             $truthyValues = [true, 1, '1', 'true', 'TRUE', 'True'];
  1901.             $falsyValues = [false, 0, '0', 'false', 'FALSE', 'False'];
  1903.             if (in_array($isAssignedParam, $truthyValues, true)) {
  1904.                 // Only subscriptions assigned to the user (not created by them)
  1905.                 $mannedAlertSubscription->addConditionParam("FIND_IN_SET(?, subscribers) > 0 AND creator__id != ?", [$user->getId(), $user->getId()]);
  1906.             } elseif (in_array($isAssignedParam, $falsyValues, true)) {
  1907.                 // Only subscriptions created by the user
  1908.                 $mannedAlertSubscription->addConditionParam("creator__id = ?", [$user->getId()]);
  1909.             } else {
  1910.                 // Fallback to default behavior if param is malformed
  1911.                 $mannedAlertSubscription->addConditionParam("creator__id = ? OR FIND_IN_SET(?, subscribers) > 0", [$user->getId(), $user->getId()]);
  1912.             }
  1913.         } else {
  1914.             // Default: include subscriptions created by the user OR assigned to the user
  1915.             $mannedAlertSubscription->addConditionParam("creator__id = ? OR FIND_IN_SET(?, subscribers) > 0", [$user->getId(), $user->getId()]);
  1916.         }
  1917.         if (isset($params['region_id']) && !empty($params['region_id'])) {
  1918.             $region_ids = $params['region_id'];
  1919.             $regionIDS = [];
  1921.             foreach ($region_ids as $regionId) {
  1922.                 $region = \Pimcore\Model\DataObject\Region::getByRegionId($regionId, true);
  1923.                 $regionIDS[] = $region->getId();
  1924.             }
  1926.             // Use placeholders for each region ID
  1927.             $placeholders = implode(',', array_fill(0, count($regionIDS), '?'));
  1929.             $mannedAlertSubscription->addConditionParam('region__id IN (' . $placeholders . ')', $regionIDS);
  1930.         }
  1933.         if (isset($params['alert_id']) && !empty($params['alert_id'])) {
  1934.             $alertIds = $params['alert_id'];
  1935.             $alertTypeIDS = [];
  1936.             foreach ($alertIds as $alert_type_id) {
  1937.                 $alertType = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert_type_id, true);
  1938.                 $alertTypeIDS[] = $alertType->getId();
  1939.             }
  1941.             $alertTypeID = implode(',', $alertTypeIDS);
  1942.             // $mannedAlertSubscription->addConditionParam("alertType = ? ", [','.$alertTypeID.',']);
  1943.             $mannedAlertSubscription->addConditionParam("alertType REGEXP CONCAT('(^|,)(', REPLACE('$alertTypeID',',', '|'), ')(,|$)')");
  1944.         }
  1946.         if (isset($params['phenomena_id']) && !empty($params['phenomena_id'])) {
  1947.             $alertStatusIds = $params['phenomena_id'];
  1948.             $alertStatusIDS = [];
  1949.             foreach ($alertStatusIDS as $alertStatusId) {
  1950.                 $alertStatus = \Pimcore\Model\DataObject\AlertStatus::getByAlertStatusId($alertStatusId, true);
  1951.                 $alertStatusIDS[] = $$alertStatus->getId();
  1952.             }
  1954.             $alertStatusID = implode(',', $alertStatusIDS);
  1955.             // $mannedAlertSubscription->addConditionParam("phenomena = ? ", [','.$phenomenaID.',']);
  1956.             $mannedAlertSubscription->addConditionParam("alertStatus REGEXP CONCAT('(^|,)(', REPLACE('$alertStatusID',',', '|'), ')(,|$)')");
  1957.         }
  1959.         $mannedAlertSubscription->setOrderKey("oo_id");
  1960.         $mannedAlertSubscription->setOrder("desc");
  1962.         $paginator = $paginator->paginate(
  1963.             $mannedAlertSubscription,
  1964.             $page,
  1965.             $pageSize
  1966.         );
  1968.         $response = [];
  1970.         foreach ($paginator as $subscription) {
  1971.             if ($subscription) {
  1972.                 $governorates = [];
  1973.                 foreach ($subscription->getGovernorate() as $governorate) {
  1974.                     $governorates[] = [
  1975.                         "id" => $governorate->getGovernoteId(),
  1976.                         "en" => $governorate->getName('en'),
  1977.                         "ar" => $governorate->getName('ar')
  1978.                     ];
  1979.                 }
  1980.                 $alert_types = [];
  1981.                 foreach ($subscription->getAlertType() as $alert_type) {
  1982.                     $alert_types[] = [
  1983.                         "id" => $alert_type->getAlertTypeId(),
  1984.                         "color" => $alert_type->getColor(),
  1985.                         "en" => $alert_type->getName('en'),
  1986.                         "ar" => $alert_type->getName('ar')
  1987.                     ];
  1988.                 }
  1989.                 $phenomenas = [];
  1990.                 if ($subscription->getAlertStatus()) {
  1991.                     foreach ($subscription->getAlertStatus() as $subscriptionAlertStatus) {
  1992.                         $phenomenas[] = [
  1993.                             "id" => $subscriptionAlertStatus->getAlertStatusId(),
  1994.                             "en" => $subscriptionAlertStatus->getName('en'),
  1995.                             "ar" => $subscriptionAlertStatus->getName('ar')
  1996.                         ];
  1997.                     }
  1998.                 }
  2000.                 $response[] = [
  2001.                     "id" => $subscription->getId(),
  2002.                     "region" => [
  2003.                         [
  2004.                             "id" => $subscription->getRegion()->getRegionId(),
  2005.                             "en" => $subscription->getRegion()->getName('en'),
  2006.                             "ar" => $subscription->getRegion()->getName('ar')
  2007.                         ]
  2008.                     ],
  2009.                     "alertType" => $alert_types,
  2010.                     "governorate" => $governorates,
  2011.                     "phenomena" => $phenomenas,
  2012.                     "notifyEmail" => $subscription->getNotifyEmail() == null ? false : $subscription->getNotifyEmail(),
  2013.                     "notifySMS" => $subscription->getNotifySMS() == null ? false : $subscription->getNotifySMS(),
  2014.                     "creator" => $subscription->getCreator()?->getEmail(),
  2015.                     "isAssigned" => $subscription->getCreator()?->getEmail() !== $user->getEmail() ? true : false
  2016.                 ];
  2017.             }
  2018.         }
  2020.         return [
  2021.             "success" => true,
  2022.             "data" => $response,
  2023.             'paginationVariables' => $paginator->getPaginationData()
  2024.         ];
  2025.     }
  2027.     public function deleteMannedAlertSubscription($request, $params, $user, $translator)
  2028.     {
  2029.         $subscription_id = isset($params['subscription_id']) ? $params['subscription_id'] : null;
  2031.         $alertSubscription = \Pimcore\Model\DataObject\MannedAlertSubscription::getById($subscription_id, true);
  2032.         if (!$alertSubscription) {
  2033.             return ["success" => false, "message" => $translator->trans("alert_subscription_not_found")];
  2034.         }
  2035.         if ($alertSubscription->getCreator() == $user) {
  2036.             if ($alertSubscription instanceof \Pimcore\Model\DataObject\MannedAlertSubscription) {
  2037.                 $alertSubscription->delete();
  2038.                 return ["success" => true, "message" => $translator->trans("subscription_deleted")];
  2039.             }
  2040.         } else {
  2041.             $subscribedUser = [];
  2042.             $message = "user_not_found_in_this_subscription";
  2043.             foreach ($alertSubscription->getSubscribers() as $assignUser) {
  2044.                 if ($assignUser == $user) {
  2045.                     $message = "subscription_deleted";
  2046.                 } else {
  2047.                     $subscribedUser[] = $assignUser;
  2048.                 }
  2049.                 $alertSubscription->setSubscribers($subscribedUser);
  2050.                 $alertSubscription->save();
  2051.             }
  2052.             return ["success" => true, "message" => $translator->trans($message)];
  2053.         }
  2054.     }
  2055.     public function mannedAlertSubscribe($request, $params, $user, $translator)
  2056.     {
  2057.         $subscription_id = isset($params['subscription_id']) ? $params['subscription_id'] : null;
  2058.         $notifyEmail = isset($params['notifyEmail']) ? $params['notifyEmail'] : false;
  2059.         $notifySMS = isset($params['notifySMS']) ? $params['notifySMS'] : false;
  2061.         $subscription = new DataObject\MannedAlertSubscription\Listing();
  2062.         $subscription->setCondition("oo_id = ?", [$subscription_id]);
  2063.         $subscription->filterByCreator($user);
  2064.         $subscriptionData = $subscription->current();
  2066.         if ($subscriptionData instanceof \Pimcore\Model\DataObject\MannedAlertSubscription) {
  2067.             try {
  2068.                 $subscriptionData->setIsSubscribed($notifyEmail);
  2069.                 $subscriptionData->setNotifyEmail($notifyEmail);
  2070.                 $subscriptionData->setNotifySMS($notifySMS);
  2071.                 $subscriptionData->save();
  2072.                 return ["success" => true, "message" => $translator->trans('Subscription_unsubscribed_successfully')];
  2073.             } catch (\Exception $e) {
  2074.                 throw new \Exception($e->getMessage());
  2075.             }
  2076.         }
  2078.         return ["success" => false, "message" => $translator->trans("subscription_not_found_for_id_" . $subscription_id)];
  2079.     }
  2081.     public function assignUsersWithCustomNotification($request, $userIdsArray, $notificationId, $translator)
  2082.     {
  2085.         $users = [];
  2086.         $customNotification = CustomNotification::getById($notificationId);
  2087.         if (!$customNotification) {
  2088.             return ["success" => false, "message" => $translator->trans("custom_notification_not_found_for_id_" . $notificationId)];
  2089.         }
  2091.         $objectArray = ($customNotification) ? $customNotification->getUser() : [];
  2093.         if ($objectArray) {
  2094.             foreach ($objectArray as $key => $objUser) {
  2095.                 $users[] = $objUser->getObject();
  2096.             }
  2097.         }
  2098.         if (count($userIdsArray) > 0) {
  2099.             // validate if users are available to given ids
  2100.             foreach ($userIdsArray as $userId) {
  2101.                 $user = Customer::getById($userId);
  2102.                 if (!$user) {
  2103.                     return ["success" => false, "message" => $translator->trans("user_not_found_for_id_" . $userId)];
  2104.                 } else {
  2106.                     if (!in_array($user, $users)) {
  2108.                         $objectMetadata = new DataObject\Data\ObjectMetadata('user', ['alert_on_email', 'alert_on_sms'],  $user);
  2109.                         $objectMetadata->setAlert_on_email(true);
  2110.                         $objectMetadata->setAlert_on_sms(true);
  2111.                         array_push($objectArray, $objectMetadata);
  2112.                     }
  2113.                 }
  2114.             }
  2115.             $customNotification->setUser($objectArray);
  2116.             $customNotification->save();
  2118.             return ["success" => true, "message" => $translator->trans("custom_notification_assigned_successfully")];
  2119.         } else {
  2120.             return ["success" => false, "message" => $translator->trans("user_id_array_is_empty")];
  2121.         }
  2122.     }
  2124.     public function unSubscribeNotification($customer, $translator)
  2125.     {
  2126.         $ownerNotifications = new AdvanceCustomNotification\Listing();
  2127.         // $$ownerNotification=->filterByUser($customer);
  2128.         $ownerNotifications->setCondition("owner__id =?", [$customer->getId()]);
  2129.         $ownerNotifications->load();
  2130.         if ($ownerNotifications) {
  2132.             foreach ($ownerNotifications as $ownerNotification) {
  2133.                 // Assuming 'getAlerts' is the name of your multi-selection field
  2134.                 $sendNotificationAlertTypes = $ownerNotification->getAlerts();
  2136.                 // Check if 'email' is currently selected
  2137.                 if (is_array($sendNotificationAlertTypes)) {
  2138.                     if (in_array('email', $sendNotificationAlertTypes)) {
  2139.                         // Remove 'email' from the selection
  2140.                         $updatedMethods = array_filter($sendNotificationAlertTypes, function ($method) {
  2141.                             return $method !== 'email';
  2142.                         });
  2144.                         // Set the updated selection without 'email'
  2145.                         $ownerNotification->setAlerts(array_values($updatedMethods)); // Ensure array is reindexed if necessary
  2146.                     }
  2147.                 }
  2148.                 $ownerNotification->save();
  2149.             }
  2150.         }
  2151.         $customer->setUnSubscribeCustomNotificationToken("");
  2152.         $customer->save();
  2154.         /* DO NOT REMOVE BELOW CODE */
  2156.         // $customNotifications = new AdvanceCustomNotification\Listing();
  2157.         // $userGroup = $customer->getUserGroup(); // getUserGroup method based on your relation name
  2158.         // $userGroupId = null;
  2159.         // $likePatternUserGroup=null;
  2160.         // if ($userGroup) {
  2161.         //     $userGroupId = $userGroup->getId();
  2162.         //     $likePatternUserGroup = '%,' . $userGroupId . ',%';
  2163.         // }
  2164.         // $likePatternUser = '%,' . $customer->getId() . ',%';
  2165.         // $condition = "(user LIKE ? OR usergroup LIKE ?)";
  2166.         // $customNotifications->setCondition($condition, [$likePatternUser, $likePatternUserGroup]);
  2167.         // if ($customNotifications) {
  2168.         //     foreach ($customNotifications as $customNotification) {
  2170.         //         $objectArray = $customNotification->getUnSubscriber();
  2172.         //         // Flag to check if the customer is already in the unsubscriber list
  2173.         //         $isAlreadyUnsubscribed = false;
  2175.         //         // Step 2: Check if the customer is already in that list
  2176.         //         foreach ($objectArray as $objectMetadata) {
  2177.         //             if ($objectMetadata->getObject() instanceof \Pimcore\Model\DataObject\Customer && $objectMetadata->getObject()->getId() == $customer->getId()) {
  2178.         //                 // The customer is already an unsubscriber
  2179.         //                 $isAlreadyUnsubscribed = true;
  2180.         //                 break; // No need to check further
  2181.         //             }
  2182.         //         }
  2184.         //         // Step 3: If not already unsubscribed, add the customer to the list
  2185.         //         if (!$isAlreadyUnsubscribed) {
  2186.         //             // Create a new ObjectMetadata instance for the new unsubscriber
  2187.         //             // Assuming you don't need to add specific metadata here, otherwise include those fields in the array
  2188.         //             $newUnsubscriber = new ObjectMetadata('unSubscriber', ['date'], $customer);
  2190.         //             // Set the current date for the 'date' metadata field
  2191.         //             $currentDate = new \DateTime();
  2192.         //             $newUnsubscriber->setDate($currentDate->format('Y-m-d H:i:s'));
  2193.         //             // $newUnsubscriber->setMetadata('date', 'text', $currentDate->format('Y-m-d H:i:s'));
  2195.         //             // Add the new unsubscriber to the objectArray
  2196.         //             $objectArray[] = $newUnsubscriber;
  2198.         //             // Set the updated array back to the CustomNotification object
  2199.         //             $customNotification->setUnSubscriber($objectArray);
  2201.         //             // Save the CustomNotification object
  2202.         //             $customNotification->save();
  2203.         //         }
  2205.         //     }
  2206.         //     $customer->setUnSubscribeCustomNotificationToken("");
  2207.         //     $customer->save();
  2208.         //     return ["success" => true, "message" => $translator->trans("You have successfully unsubscribed to all notifications")];
  2209.         // }
  2210.         return ["success" => true, "message" => $translator->trans("You have successfully unsubscribed to all notifications")];
  2212.         // else {
  2213.         //     return ["success" => false, "message" => $translator->trans("Notifications Not Found")];
  2214.         // }
  2215.     }
  2216.     public function assignAlertSubscription($customer, $params, $translator)
  2217.     {
  2218.         $alert_subscription_id = isset($params['AlertSubscriptionId']) ? $params['AlertSubscriptionId'] : null;
  2219.         $user_ids = isset($params['UserId']) ? $params['UserId'] : 0;
  2222.         $alertSubscription = \Pimcore\Model\DataObject\MannedAlertSubscription::getById($alert_subscription_id, true);
  2223.         if (!$alertSubscription) {
  2224.             return ["success" => false, "message" => $translator->trans("alert_subscription_not_found")];
  2225.         }
  2226.         if ($alertSubscription->getCreator() !== $customer) {
  2227.             return ["success" => false, "message" => $translator->trans("alert_does_not_create_by_login_user")];
  2228.         }
  2229.         $message = [];
  2230.         foreach ($user_ids as $user_id) {
  2233.             $assignedUser = DataObject\Customer::getById($user_id);
  2234.             if ($assignedUser) {
  2235.                 if (!($customer->getOrganization() == $assignedUser->getOrganization())) {
  2236.                     // return ["success" => false, "message" => $translator->trans("user_does_not_belongs_to_same_organization")];
  2237.                     $message[] = $translator->trans("user_does_not_belongs_to_same_organization");
  2238.                 }
  2239.                 $subscribedUser = [];
  2240.                 foreach ($alertSubscription->getSubscribers() as $user) {
  2241.                     if ($user == $assignedUser) {
  2242.                         $message[] = $translator->trans("user_already_assigned");
  2243.                     } else {
  2244.                         $subscribedUser[] = $user;
  2245.                     }
  2246.                 }
  2247.                 $subscribedUser[] = $assignedUser;
  2248.                 $alertSubscription->setSubscribers($subscribedUser);
  2249.                 $alertSubscription->save();
  2250.             }
  2251.         }
  2252.         return ["success" => true, "message" => $translator->trans("manned_alert_subscription_assigned")];
  2253.     }
  2255.     public function assignUserGroupWithCustomNotification($request, $userGroupIdsArray, $notificationId, $translator)
  2256.     {
  2257.         $customNotification = CustomNotification::getById($notificationId);
  2258.         if (!$customNotification) {
  2259.             return ["success" => false, "message" => $translator->trans("custom_notification_not_found_for_id_" . $notificationId)];
  2260.         }
  2262.         if (count($userGroupIdsArray) > 0) {
  2263.             $selectedUserGroups = [];
  2264.             $newObjectArray = [];
  2265.             $processedUserIds = [];
  2267.             // Get existing users (retain all and avoid duplicates)
  2268.             $existingUsers = [];
  2269.             if ($customNotification) {
  2270.                 try {
  2271.                     $existingUsers = $customNotification->getUser();
  2272.                 } catch (\Throwable $e) {
  2273.                     // In case of broken relation IDs, proceed with empty existing users
  2274.                     $existingUsers = [];
  2275.                 }
  2276.             }
  2277.             if ($existingUsers) {
  2278.                 foreach ($existingUsers as $existingUserMetadata) {
  2279.                     if (!$existingUserMetadata) {
  2280.                         continue;
  2281.                     }
  2282.                     // If metadata exists, keep users that are not from user groups
  2283.                     if ($existingUserMetadata instanceof \Pimcore\Model\DataObject\Data\ObjectMetadata) {
  2284.                         // Only keep if the underlying object still exists
  2285.                         $related = $existingUserMetadata->getObject();
  2286.                         if ($related) {
  2287.                             $newObjectArray[] = $existingUserMetadata;
  2288.                             $processedUserIds[] = $related->getId();
  2289.                         }
  2290.                         continue;
  2291.                     }
  2292.                     // If item is a plain Customer (no metadata), wrap into metadata for the 'user' field
  2293.                     if ($existingUserMetadata instanceof Customer) {
  2294.                         $wrapped = new DataObject\Data\ObjectMetadata('user', ['alert_on_email', 'alert_on_sms', 'is_group_user','group_id'], $existingUserMetadata);
  2295.                         $wrapped->setAlert_on_email(true);
  2296.                         $wrapped->setAlert_on_sms(true);
  2297.                         $wrapped->setIs_group_user(false);
  2298.                         $wrapped->setGroup_id(null);
  2299.                         $newObjectArray[] = $wrapped;
  2300.                         $processedUserIds[] = $existingUserMetadata->getId();
  2301.                     }
  2302.                 }
  2303.             }
  2305.             // Process new user groups
  2306.             if (!empty($userGroupIdsArray)) {
  2307.                 foreach ($userGroupIdsArray as $userGroup) {
  2308.                     $UserGroupObject = UserGroup::getById($userGroup, true);
  2309.                     if ($UserGroupObject) {
  2310.                         $selectedUserGroups[] = $UserGroupObject;
  2311.                         
  2312.                         $userGroupUsers = Customer::getByUserGroup($UserGroupObject);
  2313.                         foreach ($userGroupUsers as $userGroupUser) {
  2314.                             // Check if user is not already processed to avoid duplicates
  2315.                             if (!in_array($userGroupUser->getId(), $processedUserIds)) {
  2316.                                 $objectMetadata = new DataObject\Data\ObjectMetadata('user', ['alert_on_email', 'alert_on_sms', 'is_group_user','group_id'], $userGroupUser);
  2317.                                 $objectMetadata->setAlert_on_email(true);
  2318.                                 $objectMetadata->setAlert_on_sms(true);
  2319.                                 $objectMetadata->setIs_group_user(true);
  2320.                                 $objectMetadata->setGroup_id($UserGroupObject->getId());
  2321.                                 $newObjectArray[] = $objectMetadata;
  2322.                                 $processedUserIds[] = $userGroupUser->getId();
  2323.                             }
  2324.                         }
  2325.                     }
  2326.                 }
  2327.             }
  2329.             // Update the notification with new user groups and users
  2330.             $customNotification->setUserGroup($selectedUserGroups);
  2331.             $customNotification->setUser($newObjectArray);
  2332.             $customNotification->save();
  2334.             return ["success" => true, "message" => $translator->trans("custom_notification_assigned_successfully")];
  2335.         } else {
  2336.             return ["success" => false, "message" => $translator->trans("user_group_array_is_empty")];
  2337.         }
  2338.     }
  2340.     public function assignUserGroupWithAlertSubscription($request, $userGroupIdsArray, $notificationId, $translator)
  2341.     {
  2342.         $alertSubscription = MannedAlertSubscription::getById($notificationId, true);
  2343.         if (!$alertSubscription) {
  2344.             return ["success" => false, "message" => $translator->trans("custom_notification_not_found_for_id_" . $notificationId)];
  2345.         }
  2347.         if (count($userGroupIdsArray) > 0) {
  2348.             $selectedUserGroups = [];
  2349.             $newObjectArray = [];
  2350.             $processedUserIds = [];
  2352.         // Get existing subscribers (retain all and avoid duplicates). This relation does NOT support metadata.
  2353.         $existingUsers = [];
  2354.             if ($alertSubscription) {
  2355.                 try {
  2356.                     $existingUsers = $alertSubscription->getSubscribers();
  2357.                 } catch (\Throwable $e) {
  2358.                     // In case of broken relation IDs, proceed with empty existing users
  2359.                     $existingUsers = [];
  2360.                 }
  2361.             }
  2362.             if ($existingUsers) {
  2363.                 foreach ($existingUsers as $existingUserMetadata) {
  2364.                     if (!$existingUserMetadata) {
  2365.                         continue;
  2366.                     }
  2367.                 // Subscribers is many-to-many without metadata: keep customers directly
  2368.                 if ($existingUserMetadata instanceof Customer) {
  2369.                     $newObjectArray[] = $existingUserMetadata;
  2370.                     $processedUserIds[] = $existingUserMetadata->getId();
  2371.                 }
  2372.                 }
  2373.             }
  2375.             // Process new user groups
  2376.             if (!empty($userGroupIdsArray)) {
  2377.                 foreach ($userGroupIdsArray as $userGroup) {
  2378.                     $UserGroupObject = UserGroup::getById($userGroup, true);
  2379.                     if ($UserGroupObject) {
  2380.                         $selectedUserGroups[] = $UserGroupObject;
  2381.                         
  2382.                         $userGroupUsers = Customer::getByUserGroup($UserGroupObject);
  2383.                         foreach ($userGroupUsers as $userGroupUser) {
  2384.                             // Check if user is not already processed to avoid duplicates
  2385.                             if (!in_array($userGroupUser->getId(), $processedUserIds)) {
  2386.                                 $newObjectArray[] = $userGroupUser;
  2387.                                 $processedUserIds[] = $userGroupUser->getId();
  2388.                             }
  2389.                         }
  2390.                     }
  2391.                 }
  2392.             }
  2394.             // Update the notification with new user groups and users
  2395.             $alertSubscription->setUserGroup($selectedUserGroups);
  2396.             $alertSubscription->setSubscribers($newObjectArray);
  2397.             $alertSubscription->save();
  2399.             return ["success" => true, "message" => $translator->trans("custom_notification_assigned_successfully")];
  2400.         } else {
  2401.             return ["success" => false, "message" => $translator->trans("user_group_array_is_empty")];
  2402.         }
  2403.     }
  2404.     
  2405. }