src/Model/PackageModel.php line 818

Open in your IDE?
  1. <?php
  3. namespace App\Model;
  5. use Symfony\Component\HttpFoundation\Request;
  6. use Pimcore\Model\DataObject;
  7. use App\Service\EmailService;
  8. use Pimcore\Bundle\AdminBundle\GDPR\DataProvider\SentMail;
  9. use App\Lib\Utility;
  10. use Pimcore\Db;
  11. use Pimcore\Model\DataObject\Package;
  12. use Pimcore\Model\DataObject\WeatherStations;
  13. use Pimcore\Model\DataObject\ThrottlingPolicy;
  14. use Pimcore\Model\DataObject\Subscription;
  15. use Carbon\Carbon;
  16. use App\C2IntegrationBundle\Service\C2Service;
  17. use Symfony\Component\Templating\EngineInterface;
  18. use Pimcore\Model\DataObject\Customer;
  19. use Pimcore\Model\DataObject\Organization;
  20. use Pimcore\Model\Asset;
  21. use Pimcore\Model\WebsiteSetting;
  23. class PackageModel
  24. {
  26.     private $templating;
  27.     private $c2Service;
  28.     private $db;
  30.     function __construct(EngineInterface $templating)
  31.     {
  32.         $this->c2Service = new C2Service();
  33.         $this->templating = $templating;
  34.         $this->db = \Pimcore\Db::get();
  35.     }
  37.     /**
  38.      * Create Package  function
  39.      */
  40.     public function createPackage($packageNameEn, $packageNameAr, $apiGroups, $price, $maxLocations, $maxUsers, $translator, $packageType = "public", $isAvailableOnWebsite = true, $isSMSEnabled, $isSMSEnableForCustomNotification, $isSMSEnableForMannedAlert, $isSMSEnableForOTP, $smsLimit, $weatherStationIds)
  41.     {
  43.         $apiGroupsArray = [];
  44.         // Utility::isValidTenure($tenure);
  45.         foreach ($apiGroups as $key => $apiGroupId) {
  46.             $apiGroup = DataObject\APIGroup::getById($apiGroupId, true);
  48.             if ($apiGroup instanceof DataObject\APIGroup) {
  49.                 $apiGroupsArray[] = $apiGroup;
  50.             }
  51.         }
  52.         if (count($apiGroupsArray) == 0) {
  53.             return ["success" => false, "message" => $translator->trans("no_api_group_available")];
  54.         }
  56.         $package = new DataObject\Package();
  57.         if ($packageType == "private") {
  58.             $package->setParent(DataObject\Service::createFolderByPath('/UserManagement/Packages/NCM Users/CustomPackages'));
  59.             $package->setPackagetype('private');
  60.         } else {
  61.             $package->setParent(DataObject\Service::createFolderByPath('/UserManagement/Packages/CustomPackages'));
  62.             $package->setPackagetype('public');
  63.         }
  64.         $weatherStations = [];
  65.         if (!empty($weatherStationIds)) {
  66.             foreach ($weatherStationIds as $stationId) {
  67.                 $weatherStation = DataObject\WeatherStations::getById($stationId, true);
  68.                 if ($weatherStation instanceof \Pimcore\Model\DataObject\WeatherStations) {
  69.                     $weatherStations[] = $weatherStation;
  70.                 }
  71.             }
  72.         }
  73.         $package->setWeatherStations($weatherStations);
  74.         $package->setKey(rand(1, 1000) . '-' . time());
  75.         $package->setPackageName(strip_tags($packageNameEn), 'en');
  76.         $package->setPackageName(strip_tags($packageNameAr), 'ar');
  77.         $quantityValue = new DataObject\Data\QuantityValue($price, 'SAR');
  78.         $package->setPrice($quantityValue);
  79.         $package->setApiGroups($apiGroupsArray);
  80.         // $package->setTenure(strip_tags($tenure));
  81.         $package->setMaxLocation(strip_tags($maxLocations));
  82.         $package->setMaxUsers(strip_tags($maxUsers));
  83.         $package->setIsActive(true);
  84.         $package->setIsApi(false);
  85.         $package->setIsAvailableOnWebsite($isAvailableOnWebsite ?? true);
  86.         $package->setIsSMSEnabled($isSMSEnabled);
  87.         $package->setIsSMSEnableForCustomNotification($isSMSEnableForCustomNotification);
  88.         $package->setIsSMSEnableForMannedAlert($isSMSEnableForMannedAlert);
  89.         $package->setIsSMSEnableForOTP($isSMSEnableForOTP);
  90.         $package->setSMSLimit($smsLimit);
  91.         $package->setPublished(true);
  92.         $package->Save();
  95.         if ($package) {
  96.             return ["success" => true, "data" => $package->getId(), "message" => $translator->trans("package_created")];
  97.         }
  98.     }
  100.     /**
  101.      * Update Package  function
  102.      */
  103.     public function updatePackage($params, $translator)
  104.     {
  106.         $updatePackage = DataObject\Package::getById($params["id"], true);
  108.         if (!$updatePackage instanceof DataObject\Package) {
  109.             return ["success" => false, "message" => $translator->trans("package_is_not_available")];
  110.         }
  112.         if (isset($params["api_groups"]) && !empty($params["api_groups"])) {
  114.             $apiGroupsArray = [];
  115.             foreach ($params["api_groups"] as $key => $apiGroupId) {
  116.                 $apiGroup = DataObject\APIGroup::getById($apiGroupId, true);
  118.                 if ($apiGroup instanceof DataObject\APIGroup) {
  119.                     $apiGroupsArray[] = $apiGroup;
  120.                 }
  121.             }
  122.             if (count($apiGroupsArray) > 0) {
  123.                 $updatePackage->setApiGroups($apiGroupsArray);
  124.             }
  125.         }
  127.         if (isset($params["name"]) && !empty($params["name"])) {
  128.             $updatePackage->setPackageName(strip_tags($params["name"]), 'en');
  129.         }
  130.         if (isset($params["name_ar"]) && !empty($params["name_ar"])) {
  131.             $updatePackage->setPackageName(strip_tags($params["name_ar"]), 'ar');
  132.         }
  133.         if (isset($params["price"]) && !empty($params["price"])) {
  134.             $quantityValue = new DataObject\Data\QuantityValue($params["price"], 'SAR');
  135.             $updatePackage->setPrice($quantityValue);
  136.         }
  137.         if (isset($params["tenure"]) && !empty($params["tenure"])) {
  138.             Utility::isValidTenure($params['tenure']);
  139.             $updatePackage->setTenure(strip_tags($params["tenure"]));
  140.         }
  141.         if (isset($params["max_locations"]) && !empty($params["max_locations"])) {
  142.             $updatePackage->setMaxLocation(strip_tags($params["max_locations"]));
  143.         }
  144.         if (isset($params["max_users"]) && !empty($params["max_users"])) {
  145.             $updatePackage->setMaxUsers(strip_tags($params["max_users"]));
  146.         }
  148.         if (isset($params['isSMSEnabled'])) {
  149.             $updatePackage->setIsSMSEnabled($params["isSMSEnabled"]);
  150.         }
  151.         if (isset($params['isSMSEnableForCustomNotification'])) {
  152.             $updatePackage->setIsSMSEnableForCustomNotification($params["isSMSEnableForCustomNotification"]);
  153.         }
  154.         if (isset($params['isSMSEnableForMannedAlert'])) {
  155.             $updatePackage->setIsSMSEnableForMannedAlert($params["isSMSEnableForMannedAlert"]);
  156.         }
  157.         if (isset($params['isSMSEnableForOTP'])) {
  158.             $updatePackage->setIsSMSEnableForOTP($params["isSMSEnableForOTP"]);
  159.         }
  160.         if (!empty($params['SMSLimit'])) {
  161.             $updatePackage->setSMSLimit($params["SMSLimit"]);
  162.         }
  163.         if (!empty($params['weatherStationIds']) && is_array($params['weatherStationIds'])) {
  164.             $weatherStations = [];
  165.             foreach ($params['weatherStationIds'] as $stationId) {
  166.                 $weatherStation = \Pimcore\Model\DataObject\WeatherStations::getById((int)$stationId);
  167.                 if ($weatherStation instanceof \Pimcore\Model\DataObject\WeatherStations) {
  168.                     $weatherStations[] = $weatherStation;
  169.                 }
  170.             }
  171.             $updatePackage->setWeatherStations($weatherStations);
  172.         }
  173.         $updatePackage->setIsApi(false);
  174.         $updatePackage->Save();
  176.         if ($updatePackage) {
  177.             return ["success" => true, "data" => $updatePackage->getId(), "message" => $translator->trans("package_updated")];
  178.         }
  179.     }
  181.     /**
  182.      * Delete Package function
  183.      */
  184.     public function deletePackage($Id, $loggedinUser, $translator)
  185.     {
  186.         // Get package by ID
  187.         $package = DataObject\Package::getById($Id, true);
  188.         if (!$package instanceof DataObject\Package) {
  189.             return ["success" => false, "message" => $translator->trans("package_is_not_available")];
  190.         }
  192.         // Check for active subscriptions
  193.         $subscriptions = new DataObject\Subscription\Listing();
  194.         $subscriptions->filterBySubscribedPackage($package);
  195.         $subscriptions->addConditionParam("subscribedUser__id IS NOT NULL");
  196.         $subscriptionsCount = $subscriptions->count();
  198.         // Check for organizations assigned to the package
  199.         $organizations = new DataObject\Organization\Listing();
  200.         $organizations->addConditionParam("package__id = ?", [$package->getId()]);
  201.         $organizationsCount = $organizations->count();
  203.         // Handle the different scenarios based on counts
  204.         if ($subscriptionsCount == 0 && $organizationsCount == 0) {
  205.             $package->delete();
  206.             return ["success" => true, "message" => $translator->trans("package_is_deleted")];
  207.         }
  209.         if ($subscriptionsCount > 0 && $organizationsCount == 0) {
  210.             return ["success" => false, "message" => $translator->trans("package_is_subscribed_by_customer")];
  211.         }
  213.         if ($organizationsCount > 0 && $subscriptionsCount == 0) {
  214.             return ["success" => false, "message" => $translator->trans("package_is_assigned_to_organization")];
  215.         }
  217.         return ["success" => false, "message" => $translator->trans("package_is_subscribed_by_user_and_assigned_to_organization")];
  218.     }
  220.     /**
  221.      * List Package  function
  222.      */
  223.     public function listPackage($params, $paginator, $translator)
  224.     {
  225.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  226.         $page = isset($params['page']) ? $params['page'] : 1;
  227.         $lang = isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE;
  229.         // Get class IDs
  230.         $class = new \Pimcore\Model\DataObject\ClassDefinition();
  231.         $customerClassId = $class->getDao()->getIdByName('Customer');
  232.         $subscriptionClassId = $class->getDao()->getIdByName('Subscription');
  233.         $packageClassId = $class->getDao()->getIdByName('Package');
  235.         $db = Db::get();
  237.         // Create QueryBuilder for the main query
  238.         $qb = $db->createQueryBuilder();
  239.         $qb->select([
  240.             'p.oo_id as id',
  241.             'p.packagetype as type',
  242.             'p.price__value as price',
  243.             'p.tenure',
  244.             'p.maxLocation as max_locations',
  245.             'p.maxUsers as max_users',
  246.             'p.isSMSEnabled',
  247.             'p.isSMSEnableForCustomNotification',
  248.             'p.isSMSEnableForMannedAlert',
  249.             'p.isSMSEnableForOTP',
  250.             'p.SMSLimit',
  251.             'p.isActive',
  252.             'p.o_published',
  253.             'p.isApi',
  254.             'p.isAvailableOnWebsite'
  255.         ])
  256.             ->from('object_' . $packageClassId, 'p')
  257.             ->where('p.packagetype = :packagetype')
  258.             ->andWhere('p.isAvailableOnWebsite = :isAvailableOnWebsite')
  259.             ->andWhere('p.isActive = :isActive')
  260.             ->andWhere('(p.isApi = 0 OR p.isApi IS NULL)')
  261.             ->setParameter('packagetype', 'public')
  262.             ->setParameter('isAvailableOnWebsite', 1)
  263.             ->setParameter('isActive', 1);
  265.         // Join localized tables for packageName
  266.         $qb->leftJoin('p', 'object_localized_query_packages_en', 'p_en', 'p_en.ooo_id = p.oo_id')
  267.             ->leftJoin('p', 'object_localized_query_packages_ar', 'p_ar', 'p_ar.ooo_id = p.oo_id')
  268.             ->addSelect([
  269.                 'p_en.packageName as name',
  270.                 'p_ar.packageName as name_ar'
  271.             ]);
  273.         // Add assign_users calculation as a subquery
  274.         $assignUsersSubquery = "(
  275.             SELECT COUNT(DISTINCT customer.oo_id) 
  276.             FROM object_{$customerClassId} customer
  277.             INNER JOIN object_{$subscriptionClassId} subscription ON customer.oo_id = subscription.subscribedUser__id
  278.             WHERE subscription.subscribedPackage__id = p.oo_id 
  279.             AND subscription.isActive = 1 
  280.             AND subscription.o_published = 1
  281.         )";
  283.         $qb->addSelect($assignUsersSubquery . ' as assign_users');
  285.         // Handle single ID filter
  286.         if (isset($params['id']) && !empty($params['id'])) {
  287.             $qb->andWhere('p.oo_id = :id')
  288.                 ->setParameter('id', $params['id']);
  289.         }
  291.         // Handle search filter
  292.         if (isset($params['search']) && !empty($params['search'])) {
  293.             $qb->andWhere('(p_en.packageName LIKE :search OR p_ar.packageName LIKE :search)')
  294.                 ->setParameter('search', '%' . $params['search'] . '%');
  295.         }
  297.         // Handle API group filter
  298.         if (isset($params['api_group']) && !empty($params['api_group'])) {
  299.             $qb->andWhere('p.ApiGroups LIKE :api_group')
  300.                 ->setParameter('api_group', '%,' . $params['api_group'] . ',%');
  301.         }
  303.         // Handle sorting
  304.         $allowedOrderKeys = ['name', 'tenure', 'price', 'maxLocation', 'maxUser', 'smsLimit', 'assign_users'];
  305.         $allowedOrderDirections = ['asc', 'desc'];
  307.         if (
  308.             isset($params['orderKey']) && in_array($params['orderKey'], $allowedOrderKeys) &&
  309.             isset($params['order']) && in_array(strtolower($params['order']), $allowedOrderDirections)
  310.         ) {
  312.             $orderKey = $params['orderKey'];
  313.             $orderDirection = strtolower($params['order']);
  315.             // Map the orderKey to the actual database field names
  316.             $fieldMapping = [
  317.                 'name' => $lang === 'ar' ? 'p_ar.packageName' : 'p_en.packageName',
  318.                 'tenure' => 'p.tenure',
  319.                 'price' => 'p.price__value',
  320.                 'maxLocation' => 'p.maxLocation',
  321.                 'maxUser' => 'p.maxUsers',
  322.                 'smsLimit' => 'p.SMSLimit',
  323.                 'assign_users' => 'assign_users'
  324.             ];
  326.             if (isset($fieldMapping[$orderKey])) {
  327.                 $dbField = $fieldMapping[$orderKey];
  328.                 $qb->orderBy($dbField, strtoupper($orderDirection));
  329.             }
  330.         } else {
  331.             // Default sorting
  332.             $qb->orderBy('p.oo_id', 'DESC');
  333.         }
  335.         // Use the paginator
  336.         $paginatorResult = $paginator->paginate(
  337.             $qb,
  338.             $page,
  339.             $pageSize
  340.         );
  342.         $totalPackages = $paginatorResult->count();
  343.         if ($totalPackages > 0) {
  344.             $packageDataArray = [];
  346.             foreach ($paginatorResult as $package) {
  347.                 // Get API Groups for this package
  348.                 $apiGroupDataArray = [];
  349.                 $packageObj = DataObject\Package::getById($package['id']);
  350.                 if ($packageObj) {
  351.                     $apiGroups = $packageObj->getApiGroups();
  352.                     if ($apiGroups) {
  353.                         foreach ($apiGroups as $apiGroup) {
  354.                             if ($apiGroup instanceof DataObject\APIGroup) {
  355.                                 $apiGroupDataArray[] = [
  356.                                     "id" => $apiGroup->getId(),
  357.                                     "type" => $apiGroup->getApiGroupType(),
  358.                                     "name" => $apiGroup->getApiGroupName('en'),
  359.                                     "name_ar" => $apiGroup->getApiGroupName('ar')
  360.                                 ];
  361.                             }
  362.                         }
  363.                     }
  365.                     // Get Weather Stations for this package
  366.                     $weatherStationArray = [];
  367.                     $weatherStations = $packageObj->getWeatherStations();
  368.                     if ($weatherStations) {
  369.                         foreach ($weatherStations as $weatherStation) {
  370.                             $weatherStationArray[] = [
  371.                                 "id" => $weatherStation->getId(),
  372.                                 "name" => $weatherStation->getName("en"),
  373.                                 "name_ar" => $weatherStation->getName("ar"),
  374.                             ];
  375.                         }
  376.                     }
  377.                 }
  379.                 // Build package data array
  380.                 $packageDataArray[] = [
  381.                     "id" => $package['id'],
  382.                     "assign_users" => (int)$package['assign_users'],
  383.                     "type" => $package['type'],
  384.                     "name" => $package['name'],
  385.                     "name_ar" => $package['name_ar'],
  386.                     "price" => $package['price'],
  387.                     "tenure" => $package['tenure'],
  388.                     "max_locations" => $package['max_locations'],
  389.                     "max_users" => $package['max_users'],
  390.                     "api_groups" => $apiGroupDataArray,
  391.                     "isSMSEnabled" => (bool)$package['isSMSEnabled'],
  392.                     "isSMSEnableForCustomNotification" => (bool)$package['isSMSEnableForCustomNotification'],
  393.                     "isSMSEnableForMannedAlert" => (bool)$package['isSMSEnableForMannedAlert'],
  394.                     "isSMSEnableForOTP" => (bool)$package['isSMSEnableForOTP'],
  395.                     "SMSLimit" => $package['SMSLimit'],
  396.                     "weatherStations" => $weatherStationArray,
  397.                 ];
  398.             }
  400.             return ["success" => true, "data" => $packageDataArray, "paginationVariables" => $paginatorResult->getPaginationData()];
  401.         }
  403.         return ["success" => false, "message" => $translator->trans("packages_are_not_available")];
  404.     }
  405.     /**
  406.      * List Package  function
  407.      */
  408.     public function listPackagesWithFilters($params, $paginator, $translator)
  409.     {
  413.         $class = new \Pimcore\Model\DataObject\ClassDefinition();
  414.         $customer = $class->getDao()->getIdByName('Customer');
  415.         $subscription = $class->getDao()->getIdByName('Subscription');
  416.         $organization = $class->getDao()->getIdByName('Organization');
  417.         $package = $class->getDao()->getIdByName('Package');
  419.         $db = Db::get();
  420.         $select = $db->createQueryBuilder();
  423.         $select->select('package.oo_id');
  424.         $select->from('object_' . $package, 'package');
  425.         $select->leftJoin('package', 'object_' . $subscription, 'subscription', 'package.oo_id = subscription.subscribedPackage__id');
  426.         $select->leftJoin('subscription', 'object_' . $customer, 'customer', 'customer.oo_id = subscription.subscribedUser__id');
  427.         $select->leftJoin('customer', 'object_' . $organization, 'organization', 'organization.oo_id = customer.organization__id');
  428.         $select->where("package.packagetype = " . $db->quote("public"));
  430.         if (isset($params['clientType']) && !empty($params['clientType'])) {
  431.             $select->andWhere("organization.cilent_type = " . $db->quote($params['clientType']));
  432.         }
  433.         if (isset($params['organization_id']) && !empty($params['organization_id'])) {
  435.             $select->andWhere("organization.oo_id = " . $db->quote($params['organization_id']));
  436.         }
  438.         if (isset($params['search']) && !empty($params['search'])) {
  439.             // Join the localized fields table for the language
  440.             $select->leftJoin('package', 'object_localized_query_' . $package . '_' . $params['lang'], 'localized', 'localized.ooo_id = package.oo_id');
  441.             $select->andWhere("localized.packageName LIKE " . $db->quote("%" . $params['search'] . "%"));
  442.         }
  444.         $select->andWhere("package.isAvailableOnWebsite = 1");
  445.         $select->andWhere("package.isActive = 1");
  446.         $select->andWhere("package.isApi = 0 OR package.isApi IS NULL");
  447.         $select->andWhere("package.o_published = 1");
  450.         $allowed = [
  451.             'name',
  452.             'name_ar'
  453.         ];
  454.         if (isset($params['sortBy']) && in_array($params['sortBy'], $allowed, true)) {
  455.             // decide language based on requested field
  456.             $sortAlias = 'localized_sort';
  457.             // ensure localized table is joined for sorting (avoids missing column error)
  458.             $select->leftJoin('package', 'object_localized_query_' . $package . '_' . $params['lang'], $sortAlias, $sortAlias . '.ooo_id = package.oo_id');
  459.             $direction = (isset($params['sortDir']) && strtoupper($params['sortDir']) === 'DESC') ? 'DESC' : 'ASC';
  460.             $select->orderBy($sortAlias . '.packageName', $direction);
  461.         } else {
  462.             $select->orderBy('package.oo_id', 'DESC');
  463.         }
  464.         // always group by package id to avoid duplicates from joins
  465.         $select->groupBy(['package.oo_id']);
  468.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  469.         $page = isset($params['page']) ? $params['page'] : 1;
  471.         $paginator = $paginator->paginate(
  472.             $select,
  473.             $page,
  474.             $pageSize
  475.         );
  477.         $totalPackages = $paginator->count();
  478.         if ($totalPackages > 0) {
  480.             foreach ($paginator as $key => $packageId) {
  481.                 $package = Package::getById($packageId['oo_id'], true);
  482.                 if ($package) {
  483.                     $apiGroupDataArray = [];
  484.                     // load all assigned APIGroups Data
  485.                     $apiGroups = $package->getApiGroups();
  486.                     if ($apiGroups) {
  487.                         foreach ($apiGroups as $key => $apiGroup) {
  488.                             if ($apiGroup instanceof DataObject\APIGroup) {
  489.                                 $apiGroupDataArray[] = [
  490.                                     "id" => $apiGroup->getId(),
  491.                                     "type" => $apiGroup->getApiGroupType(),
  492.                                     "name" => $apiGroup->getApiGroupName('en'),
  493.                                     "name_ar" => $apiGroup->getApiGroupName('ar')
  494.                                 ];
  495.                             }
  496.                         }
  497.                     }
  498.                     // Now, to get the price if it's set:
  499.                     $price = null;
  500.                     if ($package->getPrice()) {
  501.                         $price .= $package->getPrice()->getValue(); // Accessing the value of the QuantityValue object
  503.                     }
  504.                     // Get All Packes data
  505.                     $packageDataArray[] = [
  506.                         "id" => $package->getId(),
  507.                         "type" => $package->getPackagetype(),
  508.                         "name" => $package->getPackageName('en'),
  509.                         "name_ar" => $package->getPackageName('ar'),
  510.                         "price" => $price,
  511.                         "tenure" => $package->getTenure(),
  512.                         "max_locations" => $package->getMaxLocation(),
  513.                         "max_users" => $package->getMaxUsers(),
  514.                         "api_groups" => $apiGroupDataArray
  515.                     ];
  516.                     $apiGroupDataArray = [];
  517.                 }
  518.             }
  520.             return ["success" => true, "data" => $packageDataArray, "paginationVariables" => $paginator->getPaginationData()];
  521.         }
  522.         return ["success" => false, "message" => $translator->trans("packages_are_not_available")];
  523.     }
  525.     /**
  526.      * List APIGroup function
  527.      */
  528.     public function listApiGroup($params, $translator)
  529.     {
  531.         $apiGroupDataArray = [];
  532.         $apiGroups = new DataObject\APIGroup\Listing();
  533.         $apiGroups->filterByApiGroupType("public");
  534.         $apiGroups->filterByIsActive(true);
  535.         $apiGroups->setLocale($translator->getLocale());
  537.         if (isset($params['search']) && !empty(trim($params['search']))) {
  538.             $apiGroups->addConditionParam("apiGroupName LIKE " . $apiGroups->quote("%" . trim($params['search']) . "%"));
  539.         }
  541.         $allowed = [
  542.             'name',
  543.             'name_ar'
  544.         ];
  545.         if ($params['sortBy'] && in_array($params['sortBy'], $allowed, true)) {
  546.             $apiGroups->setOrderKey("apiGroupName", $params['sortBy'] == "name_ar" ? 'ar' : 'en');
  547.             $apiGroups->setOrder($params['sortDir'] === 'DESC' ? 'DESC' : 'ASC');
  548.         }
  550.         $totalApiGroups = $apiGroups->count();
  551.         if ($totalApiGroups > 0) {
  552.             $apiGroupDataArray[] = [
  553.                 "totalApiGroups" => $totalApiGroups
  554.             ];
  555.             foreach ($apiGroups as $key => $apiGroup) {
  557.                 // load all assigned APIGroups Data
  558.                 if ($apiGroup instanceof DataObject\APIGroup) {
  559.                     $apiGroupDataArray[] = [
  560.                         "id" => $apiGroup->getId(),
  561.                         "type" => $apiGroup->getApiGroupType(),
  562.                         "name" => $apiGroup->getApiGroupName('en'),
  563.                         "name_ar" => $apiGroup->getApiGroupName('ar')
  564.                     ];
  565.                 }
  566.             }
  568.             return ["success" => true, "data" => $apiGroupDataArray];
  569.         }
  570.         return ["success" => false, "message" => $translator->trans("api_groups_are_not_available")];
  571.     }
  573.     /**
  574.      * List Private APIGroup function
  575.      */
  576.     public function listPrivateApiGroup($params, $user, $translator)
  577.     {
  579.         $apiGroupDataArray = [];
  582.         $apiGroups = new DataObject\APIGroup\Listing();
  583.         $apiGroups->filterByApiGroupType("private");
  584.         $apiGroups->filterByIsActive(true);
  585.         $apiGroups->setOrderKey("order");
  586.         $apiGroups->setOrder('ASC');
  588.         $apiGroups->setLocale($translator->getLocale());
  590.         if ($apiGroups) {
  591.             foreach ($apiGroups as $apiGroup) {
  592.                 if ($apiGroup instanceof DataObject\APIGroup) {
  593.                     $apiGroupDataArray[] = [
  594.                         "id" => $apiGroup->getId(),
  595.                         "type" => $apiGroup->getApiGroupType(),
  596.                         "group_name" => $apiGroup->getGroupName(),
  597.                         "name" => $apiGroup->getApiGroupName('en'),
  598.                         "name_ar" => $apiGroup->getApiGroupName('ar')
  599.                     ];
  600.                 }
  601.             }
  602.         }
  604.         return ["success" => true, "data" => $apiGroupDataArray];
  605.     }
  607.     /**
  608.      * View APIGroup function
  609.      */
  610.     public function viewApiGroup($Id, $loggedinUser, $translator)
  611.     {
  613.         $apiGroupDataArray = [];
  614.         $apiGroups = new DataObject\APIGroup\Listing();
  615.         $apiGroups->filterById($Id);
  616.         $apiGroups->filterByApiGroupType("public");
  617.         $apiGroups->filterByIsActive(true);
  618.         $apiGroup =  $apiGroups->current();
  620.         // load all assigned APIGroups Data
  621.         if ($apiGroup instanceof DataObject\APIGroup) {
  622.             $apiGroupDataArray[] = [
  623.                 "id" => $apiGroup->getId(),
  624.                 "type" => $apiGroup->getApiGroupType(),
  625.                 "name" => $apiGroup->getApiGroupName('en'),
  626.                 "name_ar" => $apiGroup->getApiGroupName('ar'),
  627.                 "permission" => $apiGroup->getAllowedApis()
  628.             ];
  630.             return ["success" => true, "data" => $apiGroupDataArray];
  631.         }
  634.         return ["success" => false, "message" => $translator->trans("api_group_is_not_available")];
  635.     }
  638.     /**
  639.      * Suspend Package function
  640.      */
  641.     public function suspendPackage($userIdOrIds, $loggedinUser, $translator)
  642.     {
  643.         $ids = is_array($userIdOrIds) ? $userIdOrIds : [$userIdOrIds];
  645.         $results = [];
  646.         foreach ($ids as $userId) {
  647.             $customer = DataObject\Customer::getById($userId, true);
  648.             if (!$customer) {
  649.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("user_is_not_available")];
  650.                 continue;
  651.             }
  653.             //validate Role first
  654.             $loggedInUserRole = $loggedinUser->getRole() ? $loggedinUser->getRole()->getName() : USER_ROLES['CLIENT_USER'];
  655.             $customerRole =  $customer->getRole() ? $customer->getRole()->getName() : USER_ROLES['CLIENT_USER'];
  657.             if ($loggedInUserRole == USER_ROLES['CLIENT_USER'] && ($customerRole == USER_ROLES['NCM_OPERATOR'] || $customerRole == USER_ROLES['NCM_IT'] || $customerRole == USER_ROLES['CLIENT_ADMIN'])) {
  658.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("permission_denied_to_role")];
  659.                 continue;
  660.             } elseif ($loggedInUserRole == USER_ROLES['CLIENT_ADMIN'] && ($customerRole == USER_ROLES['NCM_IT'] || $customerRole == USER_ROLES['NCM_OPERATOR'])) {
  661.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("permission_denied_to_role")];
  662.                 continue;
  663.             } elseif ($loggedInUserRole == USER_ROLES['NCM_OPERATOR'] && ($customerRole == USER_ROLES['NCM_IT'])) {
  664.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("permission_denied_to_role")];
  665.                 continue;
  666.             }
  668.             $subscriptions = new DataObject\Subscription\Listing();
  669.             $subscriptions->filterBySubscribedUser($customer);
  670.             $subscriptions->filterByIsActive(true);
  672.             if ($subscriptions->count() > 0) {
  673.                 foreach ($subscriptions as $subscription) {
  674.                     if ($subscription) {
  675.                         $subscription->setIsActive(false);
  676.                         $subscription->save();
  677.                     }
  678.                 }
  679.                 $results[] = ["id" => $userId, "success" => true, "message" => $translator->trans("package_suspended_successfully")];
  680.             } else {
  681.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("active_subscription_is_not_available")];
  682.             }
  683.         }
  685.         // Preserve backward compatibility: if input was scalar, return single-object style
  686.         if (!is_array($userIdOrIds)) {
  687.             $single = $results[0] ?? ["success" => false, "message" => $translator->trans("unknown_error")];
  688.             return ["success" => $single["success"], "message" => $single["message"]];
  689.         }
  691.         $successCount = 0;
  692.         foreach ($results as $r) {
  693.             if (!empty($r['success'])) {
  694.                 $successCount++;
  695.             }
  696.         }
  697.         return ["success" => true, "message" => sprintf("%s: %d", $translator->trans("package_suspended_successfully"), $successCount)];
  698.     }
  700.     /**
  701.      * Resume Package function
  702.      */
  703.     public function resumePackage($userIdOrIds, $loggedinUser, $translator)
  704.     {
  705.         $ids = is_array($userIdOrIds) ? $userIdOrIds : [$userIdOrIds];
  707.         $results = [];
  708.         foreach ($ids as $userId) {
  709.             $customer = DataObject\Customer::getById($userId, true);
  710.             if (!$customer) {
  711.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("user_is_not_available")];
  712.                 continue;
  713.             }
  715.             //validate Role first
  716.             $loggedInUserRole = $loggedinUser->getRole() ? $loggedinUser->getRole()->getName() : USER_ROLES['CLIENT_USER'];
  717.             $customerRole =  $customer->getRole() ? $customer->getRole()->getName() : USER_ROLES['CLIENT_USER'];
  719.             if ($loggedInUserRole == USER_ROLES['CLIENT_USER'] && ($customerRole == USER_ROLES['NCM_OPERATOR'] || $customerRole == USER_ROLES['NCM_IT'] || $customerRole == USER_ROLES['CLIENT_ADMIN'])) {
  720.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("permission_denied_to_role")];
  721.                 continue;
  722.             } elseif ($loggedInUserRole == USER_ROLES['CLIENT_ADMIN'] && ($customerRole == USER_ROLES['NCM_IT'] || $customerRole == USER_ROLES['NCM_OPERATOR'])) {
  723.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("permission_denied_to_role")];
  724.                 continue;
  725.             } elseif ($loggedInUserRole == USER_ROLES['NCM_OPERATOR'] && ($customerRole == USER_ROLES['NCM_IT'])) {
  726.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("permission_denied_to_role")];
  727.                 continue;
  728.             }
  730.             $subscriptions = new DataObject\Subscription\Listing();
  731.             $subscriptions->filterBySubscribedUser($customer);
  732.             $subscriptions->filterByIsActive(false);
  734.             if ($subscriptions->count() > 0) {
  735.                 foreach ($subscriptions as $subscription) {
  736.                     if ($subscription) {
  737.                         $subscription->setIsActive(true);
  738.                         $subscription->save();
  739.                     }
  740.                 }
  741.                 $results[] = ["id" => $userId, "success" => true, "message" => $translator->trans("package_resumed_successfully")];
  742.             } else {
  743.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("suspended_subscription_is_not_available")];
  744.             }
  745.         }
  747.         if (!is_array($userIdOrIds)) {
  748.             $single = $results[0] ?? ["success" => false, "message" => $translator->trans("unknown_error")];
  749.             return ["success" => $single["success"], "message" => $single["message"]];
  750.         }
  752.         $successCount = 0;
  753.         foreach ($results as $r) {
  754.             if (!empty($r['success'])) {
  755.                 $successCount++;
  756.             }
  757.         }
  758.         return ["success" => true, "message" => sprintf("%s: %d", $translator->trans("package_resumed_successfully"), $successCount)];
  759.     }
  762.     /**
  763.      * Renew Package function for all users in organization
  764.      * $organization : organization object
  765.      */
  766.     public function renewPackage($organization, $days, $loggedinUser, $translator)
  767.     {
  768.         $successCount = 0;
  769.         $failCount = 0;
  770.         $results = [];
  771.         $customers = new DataObject\Customer\Listing();
  772.         $customers->filterByOrganization($organization);
  773.         foreach ($customers as $customer) {
  774.             $userId = $customer->getId();
  776.             //validate Role first
  777.             $loggedInUserRole = $loggedinUser->getRole() ? $loggedinUser->getRole()->getName() : USER_ROLES['CLIENT_USER'];
  778.             $customerRole =  $customer->getRole() ? $customer->getRole()->getName() : USER_ROLES['CLIENT_USER'];
  780.             if ($loggedInUserRole == USER_ROLES['CLIENT_USER'] && ($customerRole == USER_ROLES['NCM_OPERATOR'] || $customerRole == USER_ROLES['NCM_IT'] || $customerRole == USER_ROLES['CLIENT_ADMIN'])) {
  781.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("permission_denied_to_role")];
  782.                 continue;
  783.             } elseif ($loggedInUserRole == USER_ROLES['CLIENT_ADMIN'] && ($customerRole == USER_ROLES['NCM_IT'] || $customerRole == USER_ROLES['NCM_OPERATOR'])) {
  784.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("permission_denied_to_role")];
  785.                 continue;
  786.             } elseif ($loggedInUserRole == USER_ROLES['NCM_OPERATOR'] && ($customerRole == USER_ROLES['NCM_IT'])) {
  787.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("permission_denied_to_role")];
  788.                 continue;
  789.             }
  791.             $subscriptions = new DataObject\Subscription\Listing();
  792.             $subscriptions->filterBySubscribedUser($customer);
  793.             // $subscriptions->filterByIsActive(true);
  795.             if ($subscriptions->count() > 0) {
  796.                 $subscriptionExpiry = date('Y-m-d', strtotime('+' . $days . ' days'));
  797.                 foreach ($subscriptions as $subscription) {
  798.                     $subscription->setEndDate(\Carbon\Carbon::parse(new \Datetime($subscriptionExpiry)));
  799.                     $subscription->save();
  800.                 }
  801.                 $results[] = ["id" => $userId, "success" => true, "message" => $translator->trans("package_renewed_successfully")];
  802.                 $successCount++;
  803.             } else {
  804.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("subscription_is_not_available")];
  805.                 $failCount++;
  806.             }
  807.         }
  808.         $organization->setPackageActivationDate(\Carbon\Carbon::parse(new \Datetime(date('Y-m-d'))));
  809.         $organization->setTrialLimit($days);
  810.         $organization->save();
  811.         return ["success" => true, "message" => sprintf("%s: %d", $translator->trans("package_renewed_successfully"), $successCount)];
  812.     }
  815.     /**
  816.      * Create Wso Package function
  817.      */
  818.     public function createWsoPackage($packageNameEn, $price, $tenure, $throttling, $packageType = "public", $translator)
  819.     {
  820.         $package = DataObject\Package::getByName($packageNameEn, 'en');
  822.         if ($package->getCount() > 0) {
  823.             return ["success" => false, "message" => $translator->trans("package_with_this_name_exists")];
  824.         }
  826.         Utility::isValidTenure($tenure);
  827.         $throttling = DataObject\WSO2Policies::getById($throttling, true);
  829.         if (!$throttling) {
  830.             return ["success" => false, "message" => $translator->trans("throttling_is_not_available")];
  831.         }
  833.         $package = new DataObject\Package();
  834.         $package->setParent(DataObject\Service::createFolderByPath('/UserManagement/Packages/WSOPackages'));
  835.         $package->setPackagetype($packageType);
  836.         $package->setKey(rand(1, 1000) . '-' . time());
  838.         $package->setPackageCode(uniqid());
  839.         $package->setName(strip_tags($packageNameEn), 'en');
  840.         $package->setPackageName(strip_tags($packageNameEn), 'en');
  841.         // $package->setPackageName(strip_tags($packageNameAr), 'ar');
  843.         $quantityValue = new DataObject\Data\QuantityValue($price, 'SAR');
  844.         $package->setPrice($quantityValue);
  846.         $package->setTenure(strip_tags($tenure));
  847.         $package->setThrottlingPolicy($throttling->getId());
  848.         $package->setMaxLocation(0);
  849.         $package->setMaxUsers(0);
  850.         $package->setIsActive(true);
  851.         $package->setIsApi(true);
  852.         $package->setIsAvailableOnWebsite($isAvailableOnWebsite ?? false);
  853.         $package->setPublished(true);
  854.         $package->Save();
  856.         if ($package) {
  857.             return ["success" => true, "data" => $package->getId(), "message" => $translator->trans("package_created")];
  858.         }
  859.     }
  861.     /**
  862.      * Update Wso Package function
  863.      */
  864.     public function updateWsoPackage($params, $translator)
  865.     {
  866.         $updatePackage = DataObject\Package::getById($params["id"], true);
  868.         if (!$updatePackage instanceof DataObject\Package) {
  869.             return ["success" => false, "message" => $translator->trans("package_is_not_available")];
  870.         }
  872.         $updatePackage->setIsApi(true);
  874.         if (isset($params["name"]) && !empty($params["name"])) {
  875.             $updatePackage->setName(strip_tags($params["name"]), 'en');
  876.         }
  877.         if (isset($params["name"]) && !empty($params["name"])) {
  878.             $updatePackage->setPackageName(strip_tags($params["name"]), 'en');
  879.         }
  880.         if (isset($params["name_ar"]) && !empty($params["name_ar"])) {
  881.             $updatePackage->setPackageName(strip_tags($params["name_ar"]), 'ar');
  882.         }
  883.         if (isset($params["price"]) && ($params["price"] != null || $params["price"] != '')) {
  884.             $quantityValue = new DataObject\Data\QuantityValue($params["price"], 'SAR');
  885.             $updatePackage->setPrice($quantityValue);
  886.         }
  887.         if (isset($params["tenure"]) && !empty($params["tenure"])) {
  888.             Utility::isValidTenure($params['tenure']);
  889.             $updatePackage->setTenure(strip_tags($params["tenure"]));
  890.         }
  891.         if (isset($params["throttling"]) && !empty($params["throttling"])) {
  892.             $updatePackage->setThrottlingPolicy($params["throttling"]);
  893.         }
  895.         $updatePackage->Save();
  897.         if ($updatePackage) {
  898.             return ["success" => true, "data" => $updatePackage->getId(), "message" => $translator->trans("package_updated")];
  899.         }
  900.     }
  902.     /**
  903.      * Inactive Wso Package function
  904.      */
  905.     public function inactiveWsoPackage($Id, $status, $translator)
  906.     {
  907.         $package = DataObject\Package::getById($Id, true);
  908.         if (!$package instanceof DataObject\Package) {
  909.             return ["success" => false, "message" => $translator->trans("package_is_not_available")];
  910.         }
  912.         $package->setIsActive($status);
  913.         $package->save();
  914.         return ["success" => true, "message" => $translator->trans("package_status_updated")];
  915.     }
  917.     /**
  918.      * Delete Wso Package function
  919.      */
  920.     public function deleteWsoPackage($Id, $translator)
  921.     {
  922.         $package = DataObject\Package::getById($Id, true);
  923.         if (!$package instanceof DataObject\Package) {
  924.             return ["success" => false, "message" => $translator->trans("package_is_not_available")];
  925.         }
  927.         $subscriptions = new DataObject\Subscription\Listing();
  928.         $subscriptions->addConditionParam('subscribedUser__id IS NOT NULL');
  929.         $subscriptions->filterBySubscribedPackage($package);
  930.         $subscriptions->filterByIsActive(true);
  933.         if ($subscriptions->count() == 0) {
  934.             $package->delete();
  935.             return ["success" => true, "message" => $translator->trans("package_is_deleted")];
  936.         } else {
  937.             return ["success" => false, "message" => $translator->trans("package_is_subscribed_by_customer")];
  938.         }
  939.     }
  941.     /**
  942.      * List  Wso Package function
  943.      */
  944.     public function listWsoPackage($params, $paginator, $translator)
  945.     {
  947.         $throttlingArr = [];
  948.         $policies = new DataObject\WSO2Policies\Listing();
  949.         foreach ($policies as $policie) {
  950.             $throttlingArr[$policie->getId()] = $policie->getPolicyName();
  951.         }
  952.         $packageDataArray = [];
  953.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  954.         $page = isset($params['page']) ? $params['page'] : 1;
  955.         $lang = isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE;
  957.         $packages = new DataObject\Package\Listing();
  958.         $packages->filterByIsApi(true);
  960.         if (isset($params['search']) && !empty($params['search'])) {
  961.             $packages->addConditionParam("packageName LIKE " . $packages->quote("%" . $params['search'] . "%"));
  962.         }
  964.         $packages->filterByPackagetype("public");
  965.         $packages->addConditionParam("ThrottlingPolicy IS Not NULL");
  967.         // Dynamic sorting with orderKey and order
  968.         $orderKey = $params['orderKey'] ?? null;
  969.         $order = $params['order'] ?? 'desc';
  971.         // Validate order parameter
  972.         if (!in_array(strtolower($order), ['asc', 'desc'])) {
  973.             $order = 'desc';
  974.         }
  976.         // Map orderKey to database fields
  977.         $sortingMap = [
  978.             'name' => 'packageName',
  979.             'price' => 'price__value',
  980.             'tenure' => 'tenure',
  981.             'throttling' => 'ThrottlingPolicy',
  982.             'status' => 'isActive'
  983.         ];
  985.         if ($orderKey && isset($sortingMap[$orderKey])) {
  986.             $field = $sortingMap[$orderKey];
  987.             $packages->setOrderKey($field);
  988.             $packages->setOrder(strtoupper($order));
  989.         } else {
  990.             // Default sorting
  991.             $packages->setOrderKey("oo_id");
  992.             $packages->setOrder('desc');
  993.         }
  995.         $paginator = $paginator->paginate(
  996.             $packages,
  997.             $page,
  998.             $pageSize
  999.         );
  1001.         $totalPackages = $paginator->count();
  1003.         foreach ($paginator as $key => $package) {
  1004.             $price = null;
  1005.             if ($package->getPrice()) {
  1006.                 $price .= $package->getPrice()->getValue(); // Accessing the value of the QuantityValue object
  1008.             }
  1009.             $throttlingPolicy = intval($package->getThrottlingPolicy());
  1010.             // Get All Packes data
  1011.             $packageDataArray[] = [
  1012.                 "id" => $package->getId(),
  1013.                 "type" => $package->getPackagetype(),
  1014.                 "name" => $package->getPackageName('en'),
  1015.                 "name_ar" => $package->getPackageName('ar'),
  1016.                 "price" => $price,
  1017.                 "tenure" => $package->getTenure(),
  1018.                 "throttling" => $throttling =  $translator->trans($throttlingArr[$throttlingPolicy], [], null, "en"),
  1019.                 "throttling_ar" => $throttling = $translator->trans($throttlingArr[$throttlingPolicy], [], null, "ar")
  1020.             ];
  1021.         }
  1023.         if ($totalPackages > 0) {
  1024.             return ["success" => true, "data" => $packageDataArray, "paginationVariables" => $paginator->getPaginationData()];
  1025.         }
  1026.         return ["success" => false, "message" => $translator->trans("packages_are_not_available")];
  1027.     }
  1029.     /**
  1030.      * List Throttling  function
  1031.      */
  1032.     public function listThrottlingPolicies($params, $paginator, $translator)
  1033.     {
  1034.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  1035.         $page = isset($params['page']) ? $params['page'] : 1;
  1037.         $lang = isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE;
  1039.         $policesDataArray = [];
  1040.         // $apiGroupDataArray = [];
  1041.         $policies = new DataObject\WSO2Policies\Listing();
  1042.         $policies->setOrderKey('policyName');
  1043.         $policies->setOrder('asc');
  1044.         $paginator = $paginator->paginate(
  1045.             $policies,
  1046.             $page,
  1047.             $pageSize
  1048.         );
  1050.         if ($paginator->count() > 0) {
  1051.             $policesDataArray = [];
  1052.             foreach ($paginator as $policie) {
  1053.                 $policesDataArray[] = [
  1054.                     "id" => $policie->getId(),
  1055.                     "police_name" => $policie->getPolicyName(),
  1056.                     "police_display_name" => $translator->trans($policie->getDisplayName(), [], null, "en"),
  1057.                     "police_display_name_ar" => $translator->trans($policie->getDisplayName(), [], null, "ar"),
  1058.                     "description" => $policie->getDescription()
  1060.                 ];
  1061.             }
  1062.             if (!empty($policesDataArray)) {
  1063.                 return ["success" => true, "data" => $policesDataArray, 'paginationVariables' => $paginator->getPaginationData()];
  1064.             }
  1065.         }
  1068.         return ["success" => false, "message" => $translator->trans("throttling_policies_are_not_available")];
  1069.     }
  1071.     public function createWsoSubscription($params, $loggedInUser, $translator)
  1072.     {
  1073.         $result = [];
  1074.         $subscriptionType = "default";
  1075.         $disallowedApiGroupsArray = null;
  1076.         $package = DataObject\Package::getById($params['package_id']);
  1077.         if (!$package instanceof DataObject\Package) {
  1078.             return ["success" => false, "message" => "Package is not available"];
  1079.         }
  1080.         $user = Customer::getByEmail($params['email'], true);
  1081.         if (!$user) {
  1082.             // register wso user 
  1083.             Utility::validateEmail($params['email']);
  1084.             Utility::validateName($params['name']);
  1085.             $user = new DataObject\Customer();
  1086.             $user->setParent(DataObject\Service::createFolderByPath('/UserManagement/WsoUsers'));
  1087.             $user->setKey(trim(strip_tags($params['email'])));
  1088.             $user->setUserType('public');
  1089.             $user->setName(strip_tags($params['name']));
  1090.             $user->setEmail(trim(strip_tags($params['email'])));
  1091.             $user->setIsActive(true);
  1092.             $user->setSendEwsEmail(false);
  1093.             $user->setPublished(true);
  1094.             $user->setCreatedBy($loggedInUser);
  1095.             $user->setOmitMandatoryCheck(true);
  1096.             $user->save();
  1097.             $user->save();
  1098.         } else {
  1099.             $user->setName(strip_tags($params['name']));
  1100.             $user->setCreatedBy($loggedInUser);
  1101.             $user->setOmitMandatoryCheck(true);
  1102.             $user->save();
  1103.             $user->save();
  1104.         }
  1107.         $returnMessage = '';
  1108.         if (isset($params['subscription_id'])) {
  1109.             $subscription = DataObject\Subscription::getById($params['subscription_id']);
  1110.             if (!$subscription instanceof DataObject\Subscription) {
  1111.                 return ["success" => false, "message" => $translator->trans("invalid_subscription_id")];
  1112.             }
  1113.             $returnMessage = $translator->trans("wso_subscription_updated");
  1114.         } else {
  1115.             $subscription = new DataObject\Subscription();
  1116.             $subscription->setParent(DataObject\Service::createFolderByPath('/WSO2/Subscription/' . $user->getEmail()));
  1117.             $subscription->setKey(\Pimcore\Model\Element\Service::getValidKey($package->getId() . time() . rand(1000, 10000), 'object'));
  1118.             $subscription->setPublished(true);
  1120.             $returnMessage = $translator->trans("wso_subscription_created");
  1121.         }
  1122.         $subscriptionExpiry = date('Y-m-d', strtotime('+' . $package->getTenure() . ' days'));
  1123.         $subscription->setSubscribedPackage($package);
  1124.         $subscription->setSubscribedUser($user);
  1125.         $subscription->setIsWso(true);
  1127.         //Set Disallowed ApiGroups
  1128.         if ($disallowedApiGroupsArray != null) {
  1129.             $disallowedApiGroups = [];
  1130.             foreach ($disallowedApiGroupsArray as $disallowedApiGroupsId) {
  1131.                 $apiGroup =  DataObject\APIGroup::getById($disallowedApiGroupsId, true);
  1132.                 $disallowedApiGroups[] = $apiGroup;
  1133.             }
  1134.             $subscription->setDisallowedApiGroups($disallowedApiGroups);
  1135.         }
  1136.         //$subscription->setDisallowedApis($disAllowPermissions);
  1137.         $subscription->setSubscriptionType($subscriptionType);
  1138.         $subscription->setStartDate(Carbon::parse(new \Datetime(date('Y-m-d'))));
  1139.         $subscription->setEndDate(Carbon::parse(new \Datetime($subscriptionExpiry)));
  1140.         $subscription->setIsActive(true);
  1141.         $subscription->save();
  1142.         $subscription->save();
  1145.         // do not send email if subscription id is set
  1146.         if (!isset($params['subscription_id'])) {
  1147.             // send an email to the subscriber with the ClientID and Secret Key via C2.
  1148.             $user->save();
  1149.             $this->sendEmailSubscriber($subscription, $params['email']);
  1150.         }
  1152.         if ($subscription) {
  1153.             return ["success" => true, "data" => $subscription->getId(), "message" => $returnMessage];
  1154.         }
  1155.     }
  1159.     public function reinviteWsoSubscription($params, $translator)
  1160.     {
  1161.         $result = [];
  1163.         $customer = Customer::getById($params['user_id']);
  1165.         if (!$customer) {
  1166.             return ["success" => false, "message" => $translator->trans("invalid_user_id")];
  1167.         }
  1171.         $subscriptions = new DataObject\Subscription\Listing();
  1172.         $subscriptions->filterBySubscribedUser($customer);
  1173.         $subscriptions->filterByIsActive(true);
  1174.         $subscription = $subscriptions->current();
  1175.         $subscription->save();
  1177.         if ($subscription instanceof DataObject\Subscription) {
  1178.             $result = $this->sendEmailSubscriber($subscription, $customer->getEmail());
  1179.             if ($result) {
  1180.                 return ["success" => true, "message" => $translator->trans("reinvite_email_sent")];
  1181.             }
  1182.         } else {
  1183.             return ["success" => false, "message" => $translator->trans('subscription_is_not_available')];
  1184.         }
  1185.     }
  1188.     public function sendEmailSubscriber($subscription, $email)
  1189.     {
  1190.         // dd($subscription->getConsumerKey(),$subscription->getId());
  1191.         $purpose = WSO_SUBSCRIPTION_MESSAGE;
  1192.         $templateId = $_ENV['WSO_SUBSCRIPTION_TEMPLATE'];
  1193.         $subject = 'Wso Subscription Email';
  1195.         $param = [
  1196.             'name' => $subscription->getSubscribedUser()?->getName(),
  1197.             'consumerKey' => $subscription->getConsumerKey(),
  1198.             'consumerSecret' => $subscription->getConsumerSecret(),
  1199.             'apiEndpointUrl' => $_ENV['WSO_API_ENDPOINT'],
  1200.             'postmanCollectionUrl' => $_ENV['WSO_POSTMAN_COLLECTION'],
  1201.             'apiToken' => base64_encode($subscription->getSubscribedUser()?->getUserId() . ':' . $subscription->getSubscribedUser()?->getSecretKey()),
  1202.             'tenure' => $subscription->getSubscribedPackage()?->getTenure(),
  1203.             'packageName' => $subscription->getSubscribedPackage()?->getPackageName('en'),
  1204.             'subscriptionStartDate' => $subscription->getStartDate(),
  1205.             'subscriptionEndDate' => $subscription->getEndDate(),
  1208.         ];
  1210.         // Retrieve the PDF asset from website settings
  1211.         $pdfAssetId = WebsiteSetting::getByName('wso_pdf_document')->getData();
  1212.         $pdfAsset = Asset::getById($pdfAssetId->getId());
  1214.         // Check if the asset exists and is a PDF
  1215.         if ($pdfAsset && $pdfAsset instanceof Asset\Document) {
  1216.             $pdfFile = $pdfAsset;
  1217.         } else {
  1218.             // Handle the case where the asset is not found or not a PDF
  1219.             $pdfFile = null;
  1220.         }
  1222.         $html = $this->templating->render('web2print/wso_subscription_email.html.twig', $param);
  1223.         $this->c2Service->sendCustomReportEmail($templateId, $subscription->getId(), $email, $html, $subject, [$pdfFile], $purpose);
  1225.         return true;
  1226.     }
  1227.     public function listWsoSubscription($params, $paginator, $translator)
  1228.     {
  1229.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  1230.         $page = isset($params['page']) ? $params['page'] : 1;
  1232.         $lang = isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE;
  1234.         $subscriptionDataArray = [];
  1236.         // Use raw SQL query with JOINs
  1237.         $qb = $this->db->createQueryBuilder();
  1238.         $qb->select([
  1239.             's.oo_id as id',
  1240.             's.subscribedUser__id as user_id',
  1241.             'u.name as user_name',
  1242.             'u.email as user_email',
  1243.             's.subscribedPackage__id as package_id',
  1244.             'p.packageName as package_name',
  1245.             'p_ar.packageName as package_name_ar',
  1246.             'creator.name as createdBy',
  1247.             'u.o_creationDate as createdOn',
  1248.             's.startDate as subscription_start_date',
  1249.             's.endDate as subscription_end_date',
  1250.             's.isActive as subscription_status',
  1251.             's.subscriptionType as subscription_type'
  1252.         ])
  1253.             ->from('object_subscription', 's')
  1254.             ->leftJoin('s', 'object_customer', 'u', 's.subscribedUser__id = u.oo_id')
  1255.             ->leftJoin('u', 'object_customer', 'creator', 'u.createdBy__id = creator.oo_id')
  1256.             ->leftJoin('s', 'object_localized_query_packages_en', 'p', 's.subscribedPackage__id = p.ooo_id')
  1257.             ->leftJoin('s', 'object_localized_query_packages_ar', 'p_ar', 's.subscribedPackage__id = p_ar.ooo_id')
  1258.             ->where('s.subscribedPackage__id IS NOT NULL AND s.subscribedUser__id IS NOT NULL')
  1259.             ->andWhere('s.isWso = 1');
  1261.         // Add package filter
  1262.         if (isset($params['package_id']) && !empty($params['package_id'])) {
  1263.             $package = DataObject\Package::getById($params['package_id']);
  1264.             if ($package) {
  1265.                 $qb->andWhere('s.subscribedPackage__id = :package_id')
  1266.                     ->setParameter('package_id', $package->getId());
  1267.             }
  1268.         }
  1270.         // Add search filter
  1271.         if (isset($params['search']) && !empty($params['search'])) {
  1272.             $searchTerm = "%" . $params['search'] . "%";
  1273.             $qb->andWhere('u.name LIKE :search OR u.email LIKE :search')
  1274.                 ->setParameter('search', $searchTerm);
  1275.         }
  1277.         // Apply sorting
  1278.         $orderKey = $params['orderKey'] ?? null;
  1279.         $order = $params['order'] ?? 'desc';
  1281.         // Validate order parameter
  1282.         if (!in_array(strtolower($order), ['asc', 'desc'])) {
  1283.             $order = 'desc';
  1284.         }
  1286.         // Map orderKey to database fields
  1287.         $sortingMap = [
  1288.             'username' => 'u.name',
  1289.             'email' => 'u.email',
  1290.             'createdBy' => 'creator.name',
  1291.             'createdOn' => 'u.o_creationDate',
  1292.             'packageName' => 'p.packageName',
  1293.             'status' => 's.isActive',
  1294.             'startDate' => 's.startDate',
  1295.             'endDate' => 's.endDate'
  1296.         ];
  1298.         if ($orderKey && isset($sortingMap[$orderKey])) {
  1299.             $qb->orderBy($sortingMap[$orderKey], strtoupper($order));
  1300.         } else {
  1301.             // Default sorting
  1302.             $qb->orderBy('s.o_creationDate', 'DESC');
  1303.         }
  1305.         // Legacy sorting support (for backward compatibility)
  1306.         if (isset($params['start_date']) && in_array($params['start_date'], ['asc', 'desc'])) {
  1307.             $qb->orderBy('s.startDate', strtoupper($params['start_date']));
  1308.         }
  1309.         if (isset($params['end_date']) && in_array($params['end_date'], ['asc', 'desc'])) {
  1310.             $qb->orderBy('s.endDate', strtoupper($params['end_date']));
  1311.         }
  1313.         // Execute query and paginate
  1314.         $paginator = $paginator->paginate($qb, $page, $pageSize);
  1316.         if ($paginator->count() > 0) {
  1317.             foreach ($paginator as $row) {
  1318.                 $subscriptionDataArray[] = [
  1319.                     "id" => $row['id'],
  1320.                     'user_id' => $row['user_id'],
  1321.                     'user_name' => $row['user_name'],
  1322.                     'user_email' => $row['user_email'],
  1323.                     "package_id" => $row['package_id'],
  1324.                     "package_name" => $row['package_name'],
  1325.                     "package_name_ar" => $row['package_name_ar'] ?: (function () use ($row) {
  1326.                         // Fallback: get Arabic name using Pimcore ORM
  1327.                         if ($row['package_id']) {
  1328.                             $package = DataObject\Package::getById($row['package_id']);
  1329.                             return $package ? $package->getPackageName('ar') : null;
  1330.                         }
  1331.                         return null;
  1332.                     })(),
  1333.                     'createdBy' => $row['createdBy'],
  1334.                     'createdOn' => $row['createdOn'] ? date('Y-m-d h:i:s', $row['createdOn']) : null,
  1335.                     "subscription_start_date" => $row['subscription_start_date'] ? (new \DateTime('@' . $row['subscription_start_date']))->setTimezone(new \DateTimeZone('Asia/Riyadh')) : null,
  1336.                     "subscription_end_date" => $row['subscription_end_date'] ? (new \DateTime('@' . $row['subscription_end_date']))->setTimezone(new \DateTimeZone('Asia/Riyadh')) : null,
  1337.                     "subscription_status" => (bool)$row['subscription_status'],
  1338.                     "subscription_type" => $row['subscription_type'],
  1339.                     "status" => [
  1340.                         "key" => !$row['subscription_status'] ? $translator->trans("suspended") : (($row['subscription_end_date'] && time() <= $row['subscription_end_date']) ? $translator->trans("active") : $translator->trans("expired")),
  1341.                         "name_en" => !$row['subscription_status'] ? $translator->trans("suspended") : (($row['subscription_end_date'] && time() <= $row['subscription_end_date']) ? $translator->trans("active") : $translator->trans("expired")),
  1342.                         "name_ar" => !$row['subscription_status'] ? $translator->trans("suspended") : (($row['subscription_end_date'] && time() <= $row['subscription_end_date']) ? $translator->trans("active") : $translator->trans("expired"))
  1343.                     ]
  1344.                 ];
  1345.             }
  1347.             if (!empty($subscriptionDataArray)) {
  1348.                 return ["success" => true, "data" => $subscriptionDataArray, 'paginationVariables' => $paginator->getPaginationData()];
  1349.             }
  1350.         }
  1352.         return ["success" => true, "data" => [], 'paginationVariables' => $paginator->getPaginationData()];
  1353.     }
  1356.     /**
  1357.      * Delete Wso Subscription function
  1358.      */
  1359.     public function deleteWsoSubscription($params, $user, $translator)
  1360.     {
  1363.         $successDeletes = [];
  1364.         $failedDeletes = [];
  1366.         // Loop through each user ID to process deletion
  1367.         foreach ($params['user_id'] as $userId) {
  1368.             $customer = DataObject\Customer::getById($userId, true);
  1370.             if ($customer instanceof DataObject\Customer) {
  1371.                 // Handle subscriptions
  1372.                 $subscriptions = new DataObject\Subscription\Listing();
  1373.                 $subscriptions->filterBySubscribedUser($customer);
  1374.                 $subscriptions->filterByIsWso(true);
  1376.                 foreach ($subscriptions as $subscription) {
  1377.                     $subscription->delete();
  1378.                     \App\Lib\Utility::storeActivityLog($subscription, $user, 'temp user subscription delete', $translator);
  1379.                 }
  1381.                 // Handle customer deletion if they don't have a role or organization
  1382.                 if ($customer->getRole() === null && $customer->getOrganization() === null) {
  1383.                     $customer->delete();
  1384.                     \App\Lib\Utility::storeActivityLog($customer, $user, 'temp user delete', $translator);
  1385.                 }
  1387.                 $successDeletes[] = $userId;  // Add user ID to success array
  1388.             } else {
  1389.                 $failedDeletes[] = $userId;  // Add user ID to failed array if customer not found
  1390.             }
  1391.         }
  1393.         // Return the result
  1394.         if (!empty($failedDeletes)) {
  1395.             return [
  1396.                 "success" => false,
  1397.                 "message" => $translator->trans('some_users_failed_to_delete'),
  1398.                 'failed_users' => $failedDeletes,
  1399.                 'successful_deletions' => $successDeletes
  1400.             ];
  1401.         }
  1403.         // Success message if all deletions were successful
  1404.         return [
  1405.             "success" => true,
  1406.             "message" => $translator->trans('subscriptions_and_temp_users_deleted_successfully'),
  1407.             'deleted_users' => $successDeletes
  1408.         ];
  1409.     }
  1413.     public function updateEntityPackage($package, $organizations, $translator)
  1414.     {
  1416.         $totalUpdatedSubscriptions = 0;
  1417.         $organizationsResult = [];
  1419.         foreach ($organizations as $organization) {
  1420.             if (!$organization instanceof DataObject\Organization) {
  1421.                 continue;
  1422.             }
  1426.             $activationDate = $organization->getPackageActivationDate() ?: Carbon::now();
  1427.             $trialLimit = (int)$organization->getTrialLimit();
  1428.             if ($trialLimit <= 0) {
  1429.                 // fallback to package tenure (days) if trial limit not set
  1430.                 $trialLimit = (int)$package->getTenure();
  1431.             }
  1433.             $orgUpdated = 0;
  1434.             $customers = new DataObject\Customer\Listing();
  1435.             $customers->setUnpublished(true);
  1436.             $customers->filterByOrganization($organization);
  1438.             foreach ($customers as $customer) {
  1439.                 $roleName = $customer->getRole()?->getName();
  1440.                 if (!in_array($roleName, [USER_ROLES['CLIENT_ADMIN'], USER_ROLES['CLIENT_USER']], true)) {
  1441.                     continue;
  1442.                 }
  1444.                 $subscriptions = new DataObject\Subscription\Listing();
  1445.                 $subscriptions->filterBySubscribedUser($customer);
  1446.                 $subscriptions->filterBySubscriptionType("custom");
  1448.                 $subscriptionExpiry = Carbon::parse($activationDate)->copy()->addDays($trialLimit)->format('Y-m-d');
  1450.                 if ($subscriptions->count() > 0) {
  1451.                     foreach ($subscriptions as $subscription) {
  1452.                         $subscription->setEndDate(Carbon::parse(new \DateTime($subscriptionExpiry)));
  1453.                         $subscription->setSubscribedPackage($package);
  1454.                         $subscription->setDisallowedApiGroups(null);
  1455.                         $subscription->save();
  1456.                         $orgUpdated++;
  1457.                         $totalUpdatedSubscriptions++;
  1458.                     }
  1459.                 } else {
  1460.                     $subscription = new DataObject\Subscription();
  1461.                     $subscription->setParent(DataObject\Service::createFolderByPath('/UserManagement/Subscriptions/' . $customer->getEmail()));
  1462.                     $subscription->setKey(\Pimcore\Model\Element\Service::getValidKey($package->getId() . time() . rand(1000, 10000), 'object'));
  1463.                     $subscription->setSubscribedPackage($package);
  1464.                     $subscription->setSubscribedUser($customer);
  1465.                     $subscription->setSubscriptionType("custom");
  1466.                     $subscription->setStartDate(Carbon::parse($activationDate));
  1467.                     $subscription->setEndDate(Carbon::parse(new \DateTime($subscriptionExpiry)));
  1468.                     $subscription->setIsActive(true);
  1469.                     $subscription->setPublished(true);
  1470.                     $subscription->setDisallowedApiGroups(null);
  1471.                     $subscription->save();
  1472.                     $orgUpdated++;
  1473.                     $totalUpdatedSubscriptions++;
  1474.                 }
  1475.             }
  1477.             // Sync organization with package
  1478.             $organization->setIsSMSEnabled((bool)$package->getIsSMSEnabled());
  1479.             $organization->setPackage($package);
  1480.             $organization->setIsActive(true);
  1481.             $organization->save();
  1483.             $organizationsResult[] = [
  1484.                 'organization_id' => $organization->getId(),
  1485.                 'updated_subscriptions' => $orgUpdated
  1486.             ];
  1487.         }
  1489.         return [
  1490.             "success" => true,
  1491.             "message" => $translator->trans("total_customer_subscription_updated") . ": " . $totalUpdatedSubscriptions,
  1492.             "organizations" => $organizationsResult
  1493.         ];
  1494.     }
  1495.     /**
  1496.      * List SMS  function
  1497.      */
  1498.     public function listSmsCofiguration($params, $paginator, $translator)
  1499.     {
  1500.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  1501.         $page = isset($params['page']) ? $params['page'] : 1;
  1502.         $lang = isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE;
  1504.         $smsConfigArray = [];
  1505.         $smsConfig = new DataObject\SmsConfiguration\Listing();
  1506.         $smsConfig->setOrderKey('order');
  1507.         $smsConfig->setOrder('asc');
  1508.         $paginator = $paginator->paginate(
  1509.             $smsConfig,
  1510.             $page,
  1511.             $pageSize
  1512.         );
  1514.         if ($paginator->count() > 0) {
  1515.             $smsConfigArray = [];
  1516.             foreach ($paginator as $limit) {
  1517.                 $smsConfigArray[] = [
  1518.                     "id" => $limit->getId(),
  1519.                     "limit" => $limit->getLimit(),
  1522.                 ];
  1523.             }
  1524.             if (!empty($smsConfigArray)) {
  1525.                 return ["success" => true, "data" => $smsConfigArray, 'paginationVariables' => $paginator->getPaginationData()];
  1526.             }
  1527.         }
  1530.         return ["success" => false, "message" => $translator->trans("throttling_policies_are_not_available")];
  1531.     }
  1532. }