src/Model/OrganizationModel.php line 1211

Open in your IDE?
  1. <?php
  3. namespace App\Model;
  5. use Pimcore\Model\DataObject\Customer;
  6. use Symfony\Component\HttpFoundation\Request;
  7. use Pimcore\Model\DataObject;
  8. use App\Model\InvitationModel;
  9. use App\Model\UserModel;
  10. use App\Model\PackageModel;
  11. use App\Model\LocationModel;
  12. use App\Service\UserPermission;
  13. use Pimcore\Model\DataObject\UserRole;
  14. use Pimcore\Model\DataObject\UserTag;
  15. use Carbon\Carbon;
  16. use Psr\Log\LoggerInterface;
  17. use Doctrine\DBAL\Connection;
  18. use App\Service\NCMCRMIntegrationService;
  19. use App\Model\ReportingPortalModel;
  20. use App\Model\WeatherParameterModel;
  21. use App\Model\EwsPortalModel;
  22. use Pimcore\Model\DataObject\Organization;
  23. use Pimcore\Model\DataObject\PermissionGroup;
  25. class OrganizationModel
  26. {
  28.     public $userModel;
  29.     public $invitationModel;
  30.     public $organizationModel;
  31.     public $locationModel;
  32.     private $userPermission;
  33.     private $crmService;
  34.     private $reportingPortalModel;
  35.     private $ewsPortalModel;
  36.     private $parameterModel;
  37.     private $connection;
  39.     function __construct()
  40.     {
  41.         $this->userModel = new UserModel();
  42.         $this->invitationModel = new InvitationModel();
  43.         $this->locationModel  = new LocationModel();
  44.         $this->userPermission  = new UserPermission();
  45.         $this->crmService = new NCMCRMIntegrationService();
  46.         $this->reportingPortalModel = new ReportingPortalModel();
  47.         $this->ewsPortalModel = new EwsPortalModel();
  48.         $this->parameterModel = new WeatherParameterModel();
  49.     }
  51.     /**
  52.      * Create organization
  53.      * 
  54.      */
  55.     public function createOrganization($request, $params, $loggedInUser, $translator): array
  56.     {
  57.         try {
  59.             $listing = new Organization\Listing();
  60.             $listing->setUnpublished(true); // Include unpublished
  61.             $listing->setOrderKey('o_id');
  62.             $listing->setOrder('DESC');
  63.             $listing->setLimit(1);
  65.             $last = $listing->current();
  66.             $nextNumber = 1;
  67.             if ($last instanceof Organization) {
  68.                 $lastId = $last->getUniqueId(); // e.g. NCM-ENT-00023
  69.                 if (preg_match('/NCM-ENT-(\d+)/', $lastId, $matches)) {
  70.                     $nextNumber = (int)$matches[1] + 1;
  71.                 }
  72.             }
  74.             // Format: NCM-ENT-00001
  75.             $newUniqueId = 'NCM-ENT-' . str_pad($nextNumber, 5, '0', STR_PAD_LEFT);
  78.             $result = [];
  79.             $orgName = trim(strip_tags($params['name']));
  80.             $orgNameAr = trim(strip_tags($params['nameAr']));
  81.             $email = trim($params['email']);
  82.             $orgCode = trim(strip_tags($params['code']));
  83.             //$logo = trim(strip_tags($params['logo']));
  84.             $clientType = trim(strip_tags($params['client_type']));
  86.             $organization = new DataObject\Organization();
  87.             $organization->setParent(DataObject\Service::createFolderByPath('/UserManagement/Organization'));
  88.             $organization->setKey($orgName);
  89.             $organization->setName($orgName, 'en');
  90.             $organization->setName($orgNameAr, 'ar');
  91.             $organization->setCode($orgCode);
  92.             $organization->setEmail($email);
  93.             //$organization->setImage($this->createAssetByURL($logo));
  94.             $organization->setCilent_type($clientType);
  95.             $organization->setClientType($clientType);
  96.             $organization->setStatus($params['entityStatus']);
  97.             $organization->setTrialLimit($params['trialLimit']);
  98.             $organization->setPackageActivationDate(Carbon::now());
  99.             $organization->setPackage($params['package'] ?? null);
  100.             $organization->setIsActive(true);
  101.             $organization->setCreatedBy($loggedInUser);
  102.             $organization->setPublished(true);
  103.             $organization->setUniqueId($newUniqueId);
  104.             $organization->save();
  106.             return ["success" => true, "message" => $translator->trans("organization_created_successifully"), 'data' => $organization];
  107.         } catch (\Exception $ex) {
  108.             return ["success" => false, "message" => $ex->getMessage()];
  109.         }
  110.         return $result;
  111.     }
  114.     /**
  115.      * Create Entity
  116.      * 
  117.      */
  118.     public function createEntity($request, $params, $user, $translator): array
  119.     {
  122.         $package  = DataObject\Package::getById($params['packageId'], true);
  124.         if (!$package instanceof DataObject\Package) {
  125.             return ["success" => false, "message" => $translator->trans("package_not_found")];
  126.         }
  128.         $entity = DataObject\Organization::getByName($params['name'], 'en', ['limit' => 1, 'unpublished' => true]);
  129.         if ($entity instanceof DataObject\Organization) {
  130.             return ["success" => false, "message" => $translator->trans("entity_already_exists") . " : " . $params['name']];
  131.         }
  133.         $createNameEn = trim(strip_tags($params['name']));
  134.         $createNameAr = isset($params['nameAr']) ? trim(strip_tags($params['nameAr'])) : $createNameEn;
  135.         $orgCode = isset($params['code']) ? trim(strip_tags($params['code'])) : $params['name'];
  136.         $clientType = trim(strip_tags($params['clientType']));
  137.         $listing = new Organization\Listing();
  138.         $listing->setUnpublished(true); // Include unpublished
  139.         $listing->setOrderKey('o_id');
  140.         $listing->setOrder('DESC');
  141.         $listing->setLimit(1);
  143.         $last = $listing->current();
  145.         $nextNumber = 1;
  146.         if ($last instanceof Organization) {
  147.             $lastId = $last->getUniqueId(); // e.g. NCM-ENT-00023
  148.             if (preg_match('/NCM-ENT-(\d+)/', $lastId, $matches)) {
  149.                 $nextNumber = (int)$matches[1] + 1;
  150.             }
  151.         }
  153.         // Format: NCM-ENT-00001
  154.         $newUniqueId = 'NCM-ENT-' . str_pad($nextNumber, 5, '0', STR_PAD_LEFT);
  156.         // $result = $this->reportingPortalModel->createOrganization([
  157.         //     'name' => $params['name'],
  158.         //     'nameAr' => $params['nameAr'],
  159.         //     'code' => isset($params['code']) ? $params['code'] : null,
  160.         //     'packageName' => $package->getPackageName('en'),
  161.         //     'clientType' => $params['clientType'],
  162.         //     'trialLimit' => isset($params['trialLimit']) ? $params['trialLimit'] : null,
  163.         //     'status' => isset($params['status']) ? $params['status'] : null,
  164.         //     'userEmail' => $user->getEmail(),
  165.         //     'uniqueId' => $newUniqueId,
  166.         // ]);
  168.         $entity = new DataObject\Organization();
  169.         $entity->setParent(DataObject\Service::createFolderByPath('/UserManagement/Organization'));
  170.         $entity->setKey($createNameEn);
  171.         $entity->setName($createNameEn, 'en');
  172.         $entity->setName($createNameAr, 'ar');
  173.         $entity->setCode($orgCode);
  174.         $entity->setClientType($clientType);
  175.         $entity->setPackage($package);
  176.         if (isset($params['entityStatus']) && !empty($params['entityStatus'])) {
  177.             $entity->setStatus($params['entityStatus']);
  178.             if (!isset($params['trialLimit']) || empty($params['trialLimit'])) {
  179.                 if ($params['entityStatus'] === 'trial') {
  180.                     return ["success" => false, "message" => $translator->trans("trial_limit_is_required")];
  181.                 } else {
  182.                     return ["success" => false, "message" => $translator->trans("tenure_is_required")];
  183.                 }
  184.             }
  185.             $entity->setTrialLimit($params['trialLimit']);
  186.         } else {
  187.             // When entityStatus is not sent, set trial limit
  188.             if (!isset($params['trialLimit']) || empty($params['trialLimit'])) {
  189.                 return ["success" => false, "message" => $translator->trans("tenure_is_required")];
  190.             }
  191.             $entity->setTrialLimit($params['trialLimit']);
  192.         }
  193.         $entityTag  = DataObject\UserTag::getById($params['tagId'], true);
  194.         if (isset($params['tagId']) && !empty($params['tagId'])) {
  195.             $entity->setTag($entityTag);
  196.         }
  197.         $entity->setPackageActivationDate(Carbon::parse($params['startDate']));
  198.         $entity->setPublished(true);
  199.         $entity->setIsActive(false);
  200.         $entity->setCreatedBy($user);
  201.         $entity->setUniqueId($newUniqueId);
  202.         $entity->save();
  204.         return ["success" => true, "message" => $translator->trans("entity_created")];
  205.     }
  207.     /**
  208.      * Edit organization
  209.      * 
  210.      */
  211.     public function editOrganization($request, $params, $packageModel, $translator): array
  212.     {
  215.         $updateOrganization = DataObject\Organization::getById($params['id'], true);
  217.         // $result = $this->reportingPortalModel->editOrganization([
  218.         //     'name' => $params['name'],
  219.         //     'nameAr' => $params['nameAr'],
  220.         //     'code' => isset($params['code']) ? $params['code'] : null,
  221.         //     'clientType' => isset($params['clientType']) ? $params['clientType'] : null,
  222.         //     'trialLimit' => isset($params['trialLimit']) ? $params['trialLimit'] : null,
  223.         //     'status' => isset($params['status']) ? $params['status'] : null,
  224.         //     'country' => isset($params['country']) ? $params['country'] : null,
  225.         //     'state' => isset($params['state']) ? $params['state'] : null,
  226.         //     'phone' => isset($params['phone']) ? $params['phone'] : null,
  227.         //     'packageId' => isset($params['packageId']) ? $params['packageId'] : null,
  228.         //     'uniqueId' => $updateOrganization->getUniqueId(),
  229.         // ]);
  231.         if ($updateOrganization) {
  232.             if (isset($params['name']) && !empty($params['name'])) {
  234.                 // Check if the name already exists for another organization
  235.                 $existingOrganization = DataObject\Organization::getByName($params['name'], 'en', ['limit' => 1, 'unpublished' => true]);
  236.                 if ($existingOrganization && $existingOrganization->getId() !== $updateOrganization->getId()) {
  237.                     return ["success" => false, "message" => $translator->trans("entity_already_exists") . " : " . $params['name']];
  238.                 }
  240.                 $updateOrganization->setName(trim(strip_tags($params['name'])), 'en');
  241.                 $updateOrganization->setKey(trim(strip_tags($params['name']))); // Update key to match new name
  242.             }
  244.             if (isset($params['nameAr']) && !empty($params['nameAr'])) {
  245.                 $updateOrganization->setName(trim(strip_tags($params['nameAr'])), 'ar');
  246.             }
  248.             // if (isset($params['email']) && !empty($params['email'])) {
  249.             //     $updateOrganization->setEmail(trim(strip_tags($params['email'])));
  250.             // }
  252.             if (isset($params['clientType']) && !empty($params['clientType'])) {
  253.                 $updateOrganization->setClientType(trim(strip_tags($params['clientType'])));
  254.             }
  256.             if (isset($params['isActive']) && !empty($params['isActive'])) {
  257.                 $updateOrganization->setIsActive($params['isActive']);
  258.             }
  259.             if (isset($params['startDate']) && !empty($params['startDate'])) {
  260.                 $updateOrganization->setPackageActivationDate(Carbon::parse($params['startDate']));
  261.             }
  262.             if (isset($params['entityStatus']) && !empty($params['entityStatus'])) {
  263.                 $updateOrganization->setStatus($params['entityStatus']);
  264.                 if (!isset($params['trialLimit']) || empty($params['trialLimit'])) {
  265.                     if ($params['entityStatus'] === 'trial') {
  266.                         return ["success" => false, "message" => $translator->trans("trial_limit_is_required")];
  267.                     } else {
  268.                         return ["success" => false, "message" => $translator->trans("tenure_is_required")];
  269.                     }
  270.                 }
  271.                 $updateOrganization->setTrialLimit($params['trialLimit']);
  272.             } else {
  273.                 if (!isset($params['trialLimit']) || empty($params['trialLimit'])) {
  274.                     return ["success" => false, "message" => $translator->trans("tenure_is_required")];
  275.                 }
  276.                 $updateOrganization->setTrialLimit($params['trialLimit']);
  277.             }
  279.             if (isset($params['isSMSEnabled']) && !empty($params['isSMSEnabled'])) {
  280.                 $updateOrganization->setIsSMSEnabled($params['isSMSEnabled']);
  281.             }
  283.             if (isset($params['code']) && !empty($params['code'])) {
  284.                 $updateOrganization->setCode(trim(strip_tags($params['code'])));
  285.             }
  287.             if (isset($params['country']) && !empty($params['country'])) {
  288.                 $updateOrganization->setCountry(trim(strip_tags($params['country'])));
  289.             }
  291.             if (isset($params['state']) && !empty($params['state'])) {
  292.                 $updateOrganization->setState(trim(strip_tags($params['state'])));
  293.             }
  295.             if (isset($params['phone']) && !empty($params['phone'])) {
  296.                 $updateOrganization->setPhone(trim(strip_tags($params['phone'])));
  297.             }
  299.             if (isset($params['packageId']) && !empty($params['packageId'])) {
  300.                 $package = DataObject\Package::getById($params['packageId'], true);
  301.                 if ($package instanceof DataObject\Package) {
  302.                     $packageModel->updateEntityPackage($package, $updateOrganization, $translator);
  303.                 }
  304.             }
  305.             if (isset($params['tagId']) && !empty($params['tagId'])) {
  306.                 $entityTag  = DataObject\UserTag::getById($params['tagId'], true);
  307.                 $updateOrganization->setTag($entityTag);
  308.             } else {
  309.                 $updateOrganization->setTag(null);
  310.             }
  311.             // if (isset($params['logo']) && !empty($params['logo'])) {
  312.             //     $updateOrganization->setImage($this->createAssetByURL($params['logo']));
  313.             // }
  315.             $updateOrganization->save();
  317.             return ["success" => true, "message" => $translator->trans("organization_updated_successifully")];
  318.         }
  320.         return ["success" => false, "message" => $translator->trans("organization_does_not_exists")];
  321.     }
  323.     /**
  324.      * List organization
  325.      * 
  326.      */
  327.     public function listOrganizations($request, $params, $translator, $paginator): array
  328.     {
  331.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  332.         $page = isset($params['page']) ? $params['page'] : 1;
  334.         $organizations = new DataObject\Organization\Listing();
  335.         $organizations->addConditionParam("isInternal IS NULL OR isInternal = 0"); // Exclude internal organizations
  337.         if (isset($params['isArchived']) && !empty($params['isArchived'] && $params['isArchived'] == true)) {
  338.             $organizations->setUnpublished(true); // Include unpublished
  339.             $organizations->addConditionParam("o_published = 0"); // Filter only unpublished
  340.             $organizations->addConditionParam("isDeleted = 1"); // Filter only deleted
  341.         }
  343.         if (isset($params['search']) && !empty($params['search'])) {
  344.             $organizations->addConditionParam("name LIKE " . $organizations->quote("%" . $params['search'] . "%"));
  345.         }
  347.         if (isset($params['packageId']) && !empty($params['packageId'])) {
  348.             $organizations->addConditionParam("package__id =?", [$params['packageId']]);
  349.         }
  352.         if (isset($params['clientType']) && !empty($params['clientType'])) {
  353.             $organizations->filterByClientType($params['clientType']);
  354.         }
  356.         if (isset($params['isActive'])) {
  357.             $organizations->filterByIsActive($params['isActive']);
  358.         }
  360.         if (isset($params['status']) && !empty($params['status'])) {
  361.             $organizations->filterByStatus($params['status']);
  362.         }
  364.         if (isset($params['isSMSEnabled'])) {
  365.             $organizations->filterByIsSMSEnabled($params['isSMSEnabled'] ?? false);
  366.         }
  368.         if (isset($params['tagId'])) {
  369.             $tag = DataObject\UserTag::getById($params['tagId']);
  370.             if ($tag) {
  371.                 $organizations->filterByTag($tag);
  372.             }
  373.         }
  375.         //get by customer name
  376.         if (isset($params['username'])) {
  377.             $organizations->addConditionParam("createdBy__id IN (SELECT u.oo_id FROM object_query_customer u WHERE u.name LIKE ?)", ['%' . $params['username'] . '%']);
  378.         }
  381.         $orderKeyArray = ["clientType", "o_creationDate", "isSMSEnabled", "isActive", "name", "packageExpiry", "totalAdmins", "totalUsers", "createdBy"];
  382.         $orderArray = ["asc", "desc"];
  384.         if (isset($params["orderKey"], $params["order"]) && in_array($params["orderKey"], $orderKeyArray) && in_array(strtolower($params["order"]), $orderArray)) {
  385.             if ($params["orderKey"] === "packageExpiry") {
  386.                 $sqlExpression = "CASE 
  387.                     WHEN packageActivationDate IS NULL OR trialLimit IS NULL OR trialLimit <= 0 THEN NULL
  388.                     WHEN packageActivationDate REGEXP '^[0-9]+$' THEN 
  389.                         DATE_ADD(FROM_UNIXTIME(packageActivationDate), INTERVAL trialLimit DAY)
  390.                     ELSE 
  391.                         DATE_ADD(packageActivationDate, INTERVAL trialLimit DAY)
  392.                 END";
  393.                 $organizations->setOrderKey($sqlExpression, false);
  394.                 $organizations->setOrder($params["order"]);
  395.             } elseif ($params["orderKey"] === "totalAdmins") {
  396.                 // Order by total client admins per organization using a correlated subquery
  397.                 $clientAdminRole = DataObject\UserRole::getByName(USER_ROLES['CLIENT_ADMIN'], true);
  398.                 $clientAdminRoleId = $clientAdminRole instanceof DataObject\UserRole ? (int)$clientAdminRole->getId() : 0;
  399.                 // Use the correct table reference for the outer query when localized tables are used
  400.                 $organizations->setOrderKey("
  401.                 (SELECT COUNT(*) 
  402.                  FROM object_customer c 
  403.                  WHERE c.organization__id = object_localized_organization_en.o_id AND c.role__id = {$clientAdminRoleId})
  404.             ", false);
  405.                 $organizations->setOrder($params["order"]);
  406.             } elseif (($params["orderKey"] === "totalUsers")) {
  407.                 // Order by total client users per organization using a correlated subquery
  408.                 $clientUserRole = DataObject\UserRole::getByName(USER_ROLES['CLIENT_USER'], true);
  409.                 $clientUserRoleId = $clientUserRole instanceof DataObject\UserRole ? (int)$clientUserRole->getId() : 0;
  410.                 // Use the correct table reference for the outer query when localized tables are used
  411.                 $organizations->setOrderKey("
  412.                 (SELECT COUNT(*) 
  413.                  FROM object_customer c 
  414.                  WHERE c.organization__id = object_localized_organization_en.o_id AND c.role__id = {$clientUserRoleId})
  415.             ", false);
  416.                 $organizations->setOrder($params["order"]);
  417.             } elseif (($params["orderKey"] === "createdBy")) {
  418.                 $organizations->setOrderKey("
  419.             COALESCE(
  420.             (SELECT c.name
  421.              FROM object_customer c
  422.              WHERE c.oo_id = (
  423.                  SELECT o.createdBy__id
  424.                  FROM object_organization o
  425.                  WHERE o.o_id = object_localized_organization_en.o_id
  426.                  LIMIT 1
  427.              )
  428.              LIMIT 1),
  429.             ''
  430.             )
  431.             ", false);
  432.                 $organizations->setOrder($params["order"]);
  433.             } else {
  434.                 $organizations->setOrderKey($params["orderKey"]);
  435.                 $organizations->setOrder($params["order"]);
  436.             }
  437.         }else{
  438.              $organizations->setOrderKey("o_creationDate");
  439.             $organizations->setOrder("desc");
  440.         }
  443.         $paginator = $paginator->paginate(
  444.             $organizations,
  445.             $page,
  446.             $pageSize
  447.         );
  451.         $organizationsListData = [];
  452.         foreach ($paginator as $organization) {
  454.             $packageData = [];
  455.             $trialLeftDays = null;
  456.             if ($organization instanceof DataObject\Organization) {
  457.                 if ($organization->getPackage() instanceof DataObject\Package) {
  458.                     $packageData = [
  459.                         "id" => $organization->getPackage()->getId(),
  460.                         "nameEn" => $organization->getPackage()->getPackageName("en"),
  461.                         "nameAr" => $organization->getPackage()->getPackageName("ar"),
  462.                         "packageExpiry" => $this->calculatePackageExpiry($organization)
  463.                     ];
  464.                 }
  465.                 // if ($organization->getIsActive()) {
  466.                 $trialLeftDays =   \App\Lib\Utility::getTrialLeftDays($organization->getPackageActivationDate(), $organization->getTrialLimit());
  467.                 // }
  469.                 $clientType = $organization ? $organization->getClientType() : '';
  470.                 $entityTypeArray = [
  471.                     "key" => $clientType,
  472.                     'nameEn' => $clientType === 'organization' ? 'Entity' : ($clientType ? $translator->trans($clientType, [], null, 'en') : ''),
  473.                     'nameAr' => $clientType === 'organization' ? 'الجهة' : ($clientType ? $translator->trans($clientType, [], null, 'ar') : ''),
  474.                 ];
  477.                 $organizationsListData[] = [
  478.                     "id" => $organization->getId(),
  479.                     "nameEn" => $organization->getName("en"),
  480.                     "nameAr" => $organization->getName("ar"),
  481.                     "code" => $organization->getCode(),
  482.                     "city" => $organization->getCity(),
  483.                     "state" => $organization->getState(), // Province or Region
  484.                     "zip" => $organization->getZip(),
  485.                     "email" => $organization->getEmail(),
  486.                     "country" => $organization->getCountry(),
  487.                     "isActive" => !$organization->getIsSuspend() && $organization->getIsActive(),
  488.                     "isSuspended" => $organization->getIsSuspend() ? true : false,
  489.                     "assignedPackage" => $packageData,
  490.                     "createdAt" => (new \DateTime())->setTimestamp($organization->getCreationDate())->format('Y-m-d H:i:s'),
  491.                     "updatedAt" => (new \DateTime())->setTimestamp($organization->getModificationDate())->format('Y-m-d H:i:s'),
  492.                     "adminUserCount" => $this->getUserCountByEntity($organization, USER_ROLES['CLIENT_ADMIN']),
  493.                     "userCount" => $this->getUserCountByEntity($organization, USER_ROLES['CLIENT_USER']),
  494.                     "status" => $organization->getStatus(),
  495.                     "isSMSEnabled" => $organization->getIsSMSEnabled() ? true : false,
  496.                     "entityType" => $entityTypeArray,
  497.                     'trialLeftDays' =>  $organization->getTrialLimit() ? $organization->getTrialLimit() : null,
  498.                     "smsConsumption" => $organization->getSmsConsumption(),
  499.                     "SMSLimit" => $organization->getSmsLimit(),
  500.                     "createdBy" => $organization->getCreatedBy() ? $organization->getCreatedBy()->getName() : null,
  501.                     "startDate" => $organization->getPackageActivationDate() ? (new \DateTime($organization->getPackageActivationDate()))->setTimezone(new \DateTimeZone('Asia/Riyadh'))->format('Y-m-d') : null,
  502.                     "tag" => $organization->getTag() ? [
  503.                         "id" => $organization->getTag()->getId(),
  504.                         "name" => $organization->getTag()->getName()
  505.                     ] : null,
  506.                     "endDate" => $organization->getPackageActivationDate() && isset($trialLeftDays)
  507.                         ? (clone (new \DateTime($organization->getPackageActivationDate())))
  508.                         ->add(new \DateInterval('P' . (int)$organization->getTrialLimit() . 'D'))
  509.                         ->setTimezone(new \DateTimeZone('Asia/Riyadh'))
  510.                         ->format('Y-m-d')
  511.                         : null,
  512.                 ];
  513.             }
  514.         }
  516.         return ["success" => true, "data" => $organizationsListData, 'paginationVariables' => $paginator->getPaginationData()];
  517.     }
  521.     private function getUserCountByEntity($organization, $roleName = null)
  522.     {
  524.         // force to return all objects including unpublished ones, even if setUnpublished is set to false
  525.         \Pimcore\Model\DataObject::setHideUnpublished(false);
  526.         $customers = new Customer\Listing();
  527.         $customers->filterByOrganization($organization);
  529.         if ($roleName) {
  530.             $role = DataObject\UserRole::getByName($roleName, true);
  532.             $customers->filterByRole($role);
  533.         }
  535.         return $customers->getCount();
  536.     }
  538.     /**
  539.      * Delete organization
  540.      * 
  541.      */
  542.     public function deleteOrganization($user, $params, $translator): array
  543.     {
  544.         $ids = is_array($params['id']) ? $params['id'] : [$params['id']];
  546.         $results = [];
  547.         foreach ($ids as $orgId) {
  548.             $entity = DataObject\Organization::getById($orgId, true);
  550.             if ($entity) {
  552.                 // $result = $this->reportingPortalModel->deleteOrganization([
  553.                 //     'uniqueId' => $entity->getUniqueId(),
  554.                 //     'userEmail' => $user->getEmail(),
  555.                 // ]);
  557.                 if ($this->getUserCountByEntity($entity) === 0) {
  558.                     $entity->setIsDeleted(true); // Custom field
  559.                     $entity->setDeletedBy($user);
  560.                     $entity->setDeletedAt(Carbon::now());
  561.                     $entity->setPublished(false);
  562.                     $entity->save();
  564.                     $results[] = ["id" => $orgId, "success" => true, "message" => $translator->trans("organization_deleted_successifully")];
  565.                 } else {
  566.                     $results[] = ["id" => $orgId, "success" => false, "message" => $translator->trans("organization_has_users")];
  567.                 }
  568.             } else {
  569.                 $results[] = ["id" => $orgId, "success" => false, "message" => $translator->trans("organization_does_not_exists")];
  570.             }
  571.         }
  573.         if (!is_array($params['id'])) {
  574.             $single = $results[0] ?? ["success" => false, "message" => $translator->trans("unknown_error")];
  575.             return ["success" => $single["success"], "message" => $single["message"]];
  576.         }
  578.         $successCount = 0;
  579.         $failedCount = 0;
  580.         $failedItems = [];
  582.         foreach ($results as $r) {
  583.             if (!empty($r['success'])) {
  584.                 $successCount++;
  585.             } else {
  586.                 $failedCount++;
  587.                 $failedItems[] = [
  588.                     'id' => $r['id'],
  589.                     'reason' => $r['message']
  590.                 ];
  591.             }
  592.         }
  594.         $message = sprintf("%s: %d", $translator->trans("organization_deleted_successifully"), $successCount);
  595.         if ($failedCount > 0) {
  596.             $message .= sprintf(", %s: %d", $translator->trans("failed"), $failedCount);
  597.         }
  599.         return [
  600.             "success" => true,
  601.             "message" => $message,
  602.             "processed" => $successCount,
  603.             "failed" => $failedCount,
  604.             "failedItems" => $failedItems
  605.         ];
  606.     }
  609.     /**
  610.      * Retrieve organization
  611.      * 
  612.      */
  613.     public function retrieveOrganization($user, $params, $translator): array
  614.     {
  618.         $entity = DataObject\Organization::getById($params['id'], true);
  619.         if ($entity) {
  620.             $entity->setIsDeleted(false); // Custom field
  621.             $entity->setDeletedBy(null);
  622.             $entity->setDeletedAt(null);
  623.             $entity->setPublished(true);
  624.             $entity->save();
  625.             return ["success" => true, "message" => $translator->trans("organization_retrieved_successifully")];
  626.         }
  627.         return ["success" => false, "message" => $translator->trans("organization_does_not_exists")];
  628.     }
  630.     /**
  631.      * Send invite to NCM users
  632.      * 
  633.      */
  634.     public function adminInviteNCMUser($request, $translator, $email,  $fullName, $role, $userTagId, $hostName, $loggedInUser, $allowedApiGroups, $permissionUserGroupIds, $templating, $isNoExpiry = false, $phone = null): array
  636.     {
  637.         $result = [];
  639.         // try {
  641.         $user  = DataObject\Customer::getByEmail($email, ['limit' => 1, 'unpublished' => true]);
  642.         if ($user instanceof DataObject\Customer) {
  643.             if ($user->getRole()->getName() ==  USER_ROLES['CLIENT_ADMIN'] || $user->getRole()->getName() == USER_ROLES['CLIENT_USER']) {
  644.                 return ["success" => false, "message" => $translator->trans("user_already_exists_in_external_user")];
  645.             } else {
  646.                 return ["success" => false, "message" => $translator->trans("user_already_exists")];
  647.             }
  648.         }
  652.         $organization = $loggedInUser->getOrganization();
  654.         if ($organization instanceof DataObject\Organization) {
  655.             // Register user if not exists
  657.             if ($loggedInUser->getRole()->getName() == USER_ROLES['NCM_OPERATOR'] && $role == USER_ROLES['NCM_IT']) {
  658.                 return ["success" => false, "message" => $translator->trans("NCM_OPERATOR_can_not_invite_NCM_IT.")];
  659.             }
  661.             if ($loggedInUser->getRole()->getName() == USER_ROLES['CLIENT_ADMIN'] || $loggedInUser->getRole()->getName() == USER_ROLES['CLIENT_USER']) {
  662.                 return ["success" => false, "message" => $translator->trans(USER_ROLES[$loggedInUser->getRole()->getName()] . "_can_not_invite_" . USER_ROLES[$role])];
  663.             }
  664.             $userRole = DataObject\UserRole::getByName(USER_ROLES[$role], true);
  666.             if ($userRole instanceof DataObject\UserRole) {
  668.                 $package  = $userRole->getCustomPackage();
  670.                 if (!$package instanceof DataObject\Package) {
  671.                     return ["success" => false, "message" => $translator->trans("package_not_found")];
  672.                 }
  674.                 // // check package user limit
  675.                 // $subscriptionList = new DataObject\Subscription\Listing();
  676.                 // $subscriptionList->filterBySubscribedUser($loggedInUser);
  677.                 // // $subscriptionList->filterBySubscriptionType("custom");
  678.                 // $subscriptionList->filterByIsActive(true);
  679.                 // $subscriptionList->load();
  681.                 // $customerList = new DataObject\Customer\Listing();
  682.                 // $customerList->filterByOrganization($organization);
  683.                 // $customerList->setUnpublished(1);
  684.                 // $totalcustomer = $customerList->count();
  686.                 // $maxUser = 0;
  687.                 // foreach ($subscriptionList as $subscription) {
  688.                 //     $loggedInUserPackage = $subscription->getSubscribedPackage();
  689.                 //     if ($loggedInUserPackage instanceof DataObject\Package) {
  691.                 //         if ($loggedInUserPackage->getMaxUsers()) {
  692.                 //             $maxUser += (int) $loggedInUserPackage->getMaxUsers();
  693.                 //         }
  694.                 //     }
  695.                 // }
  697.                 // if ($totalcustomer >= $maxUser) {
  698.                 //     return ["success" => false, "message" => $translator->trans("invite_user_limit_exceeded_for_this_organization")];
  699.                 // }
  700.                 // // check package user limit
  702.                 $params = [
  703.                     'email' => $email,
  704.                     'organization' => $organization,
  705.                     'name' => $fullName,
  706.                     'groupId' => null,
  707.                     'createdBy' => $loggedInUser,
  708.                     'isNoExpiry' => $isNoExpiry,
  709.                     'phone' => $phone,
  710.                     'permissionUserGroupIds' => $permissionUserGroupIds
  711.                 ];
  712.                 $userResponse = $this->createUser($userRole, $params, $translator);
  714.                 if ($userResponse['success'] == true) {
  716.                     $user = $userResponse['data'];
  719.                     // assign user tag to user
  721.                     if (isset($userTagId) && !empty($userTagId)) {
  722.                         $tage  = UserTag::getById($userTagId);
  723.                         if ($tage instanceof UserTag) {
  724.                             $user->setTag($tage);
  725.                             $user->save();
  726.                         }
  727.                     }
  729.                     // Send invite
  730.                     $permission = [];
  731.                     $params = [
  732.                         'user' => $user,
  733.                         'email' => $user->getEmail(),
  734.                         'userName' => $user->getName(),
  735.                         'role' => ($user->getRole() ? $user->getRole()->getName() : null),
  736.                         'url' => $hostName . $userResponse['token'],
  737.                         'clientType' => "NCM_admin",
  738.                         'inviteSenderName' => $loggedInUser->getName(),
  739.                         'permissions' => $permission,
  740.                         'subject' => "Invitation to Join Admin Portal as NCM Admin",
  741.                         'hostPath' => $request->getSchemeAndHttpHost(),
  742.                         'resend' => false,
  743.                     ];
  745.                     $inviteResponse = $this->invitationModel->sendInvite($params, $translator, $templating);
  747.                     return $inviteResponse;
  750.                     // $ncmUserSubscription = $this->userModel->setNcmUserSubscription($userRole, $user, $allowedApiGroups, $isNoExpiry);
  751.                     // if ($ncmUserSubscription instanceof DataObject\Subscription) {
  752.                     //     // Send invite
  753.                     //     $permission = [];
  754.                     //     $params = [
  755.                     //         'user' => $user,
  756.                     //         'email' => $user->getEmail(),
  757.                     //         'userName' => $user->getName(),
  758.                     //         'role' => ($user->getRole() ? $user->getRole()->getName() : null),
  759.                     //         'url' => $hostName . $userResponse['token'],
  760.                     //         'clientType' => "NCM_admin",
  761.                     //         'inviteSenderName' => $loggedInUser->getName(),
  762.                     //         'permissions' => $permission,
  763.                     //         'subject' => "Invitation to Join Admin Portal as NCM Admin",
  764.                     //         'hostPath' => $request->getSchemeAndHttpHost(),
  765.                     //         'resend' => false,
  766.                     //     ];
  768.                     //     $inviteResponse = $this->invitationModel->sendInvite($params, $translator, $templating);
  770.                     //     return $inviteResponse;
  771.                     // } else {
  772.                     //     return ["success" => false, "message" => $translator->trans("user_subscription_not_created")];
  773.                     // }
  774.                 } else {
  775.                     return $userResponse;
  776.                 }
  777.             } else {
  778.                 return ["success" => false, "message" => $translator->trans("user_role_not_found")];
  779.             }
  780.         } else {
  781.             return ["success" => false, "message" =>   $translator->trans("no_organization_is_associated_with_logged_in_user")];
  782.         }
  783.         // } catch (\Exception $ex) {
  784.         //     $result = ["success" => false, "message" => $ex->getMessage()];
  785.         // }
  787.         return $result;
  788.     }
  790.     /**
  791.      * Send invite to Organization and Individual users
  792.      * 
  793.      */
  794.     public function adminInvite(
  795.         $request,
  796.         $translator,
  797.         $email,
  798.         $name,
  799.         $role,
  800.         $logo,
  801.         $clientType,
  802.         $companyNameEn,
  803.         $companyNameAR,
  804.         $locations,
  805.         $loggedInUser,
  806.         $hostName,
  807.         $department,
  808.         $title,
  809.         $groupId,
  810.         $packageId,
  811.         $organizationId,
  812.         $templating,
  813.         $phone,
  814.         $entityStatus,
  815.         $trialLimit
  816.     ): array {
  817.         $result = [];
  819.         // try {
  820.         $user  = DataObject\Customer::getByEmail($email, ['limit' => 1, 'unpublished' => true]);
  821.         if ($user instanceof DataObject\Customer) {
  823.             if ($user->getRole()->getName() == USER_ROLES['NCM_OPERATOR'] || $user->getRole()->getName() == USER_ROLES['NCM_IT']) {
  824.                 return ["success" => false, "message" => $translator->trans("user_already_exists_in_internal_user")];
  825.             } else {
  827.                 $data = ['email' => $email, 'name' => $name,  'role' => $role];
  828.                 return ["success" => false, "message" => $translator->trans("user_already_exists"), 'data' => $data];
  829.             }
  830.         }
  833.         switch ($clientType) {
  834.             case 'organization':
  835.             case 'government':
  836.                 // Register organization if not exists
  839.                 $package  = DataObject\Package::getById($packageId, true);
  841.                 if (!$package instanceof DataObject\Package) {
  842.                     return ["success" => false, "message" => $translator->trans("package_not_found")];
  843.                 }
  845.                 // Check if the name already exists for another organization
  846.                 $organization = DataObject\Organization::getByName($companyNameEn, 'en', ['limit' => 1, 'unpublished' => true]);
  847.                 if ($organization instanceof DataObject\Organization) {
  848.                     return ["success" => false, "message" => $translator->trans("organization_already_exists") . " : " . $companyNameEn];
  849.                 }
  853.                 // $organizationByEmail = DataObject\Organization::getByEmail($email, true);
  854.                 // if ($organizationByEmail instanceof DataObject\Organization) {
  855.                 //     return ["success" => false, "message" => sprintf($translator->trans("organization_already_created_with_this: %s"), $email)];
  856.                 // }
  858.                 $allowedStatuses = ['paid', 'trial', 'expired'];
  859.                 if (!in_array($entityStatus, $allowedStatuses)) {
  860.                     return ["success" => false, "message" => $translator->trans("undefined_entity_status")];
  861.                 }
  862.                 $params = [
  863.                     'name' => $companyNameEn,
  864.                     'nameAr' => $companyNameAR,
  865.                     'code' => $companyNameEn,
  866.                     'client_type' => $clientType,
  867.                     'email' => $email,
  868.                     'phone' => $phone,
  869.                     'entityStatus' => $entityStatus,
  870.                     'trialLimit' => $trialLimit,
  871.                     'package' => $package,
  872.                     // 'logo'=>$logo
  873.                 ];
  875.                 $organization = $this->createOrganization($request, $params, $loggedInUser, $translator);
  876.                 if (isset($organization['data']) && $organization['data'] instanceof DataObject\Organization) {
  877.                     // check role of user before inviting 
  878.                     if ($loggedInUser->getRole()->getName() == USER_ROLES['CLIENT_ADMIN'] && ($role == USER_ROLES['NCM_IT'] || $role == USER_ROLES['NCM_OPERATOR'])) {
  879.                         return ["success" => false, "message" => $translator->trans("CLIENT_ADMIN_can_not_invite_NCM_IT_or_NCM_OPERATOR")];
  880.                     }
  882.                     if ($loggedInUser->getRole()->getName() == USER_ROLES['CLIENT_ADMIN']) {
  883.                         return ["success" => false, "message" => $translator->trans("CLIENT_USER_can_not_invite")];
  884.                     }
  886.                     $userRole = DataObject\UserRole::getByName(USER_ROLES['CLIENT_ADMIN'], true);
  887.                     if (!$userRole instanceof UserRole) {
  888.                         return ["success" => false, "message" => $translator->trans("User_Role_Not_Found")];
  889.                     }
  891.                     $params = [
  892.                         'email' => $email,
  893.                         'organization' => $organization['data'],
  894.                         'name' => $name,
  895.                         'groupId' => $groupId,
  896.                         'createdBy' => $loggedInUser,
  897.                         'phone' => $phone
  898.                     ];
  900.                     $userResponse = $this->createUser($userRole, $params, $translator);
  902.                     if ($userResponse['success'] != true) {
  903.                         return $userResponse;
  904.                     }
  906.                     // new invited user
  907.                     $user = $userResponse['data'];
  908.                     $params = [
  909.                         'locations' => $locations,
  910.                         'loggedInUser' => $loggedInUser,
  911.                         'user' => $user,
  912.                         'package' => $package,
  913.                         'disallowedApiGroupsArray' => null,
  914.                         'subscriptionType' => 'custom'
  915.                     ];
  917.                     $assignPermission = $this->assignPermissionAndLocation($user, $userRole, $params, $translator);
  919.                     if ($assignPermission['success'] != true) {
  920.                         return $assignPermission;
  921.                     }
  922.                     // Send invite
  924.                     $permission = [
  925.                         'Allow Custom Notification' => "",
  926.                         'Allow Add Location' => "",
  927.                         'Allow AlertHistory For Custom Alerts' => "",
  928.                         'Allow Forecast' => "",
  929.                         'Allow Organization Admin To Invite Users' => "",
  930.                     ];
  931.                     $params = [
  932.                         'user' => $user,
  933.                         'email' => $user->getEmail(),
  934.                         'userName' => $user->getName(),
  935.                         'url' => $hostName . $userResponse['token'],
  936.                         'role' => ($user->getRole() ? $user->getRole()->getName() : null),
  937.                         'clientType' => $clientType,
  938.                         'inviteSenderName' => $loggedInUser->getName(),
  939.                         'organization_name' => ($user->getOrganization() ? $user->getOrganization()->getName() : null),
  940.                         'NCMItAdminsData' => $this->getNCMItData(),
  941.                         'entityAdminsData' => $this->getEntityAdminData($user->getOrganization()),
  942.                         'permissions' => $permission,
  943.                         'inviteSenderRole' => ($loggedInUser->getRole() ? $loggedInUser->getRole()->getName() : null),
  944.                         'subject' => "Invitation to Join NCM Business Portal",
  945.                         'NCMItAdminNotificationSubject' => "NCM Admin Invited Organization",
  946.                         'resend' => false,
  947.                         'hostPath' => $request->getSchemeAndHttpHost()
  948.                     ];
  950.                     $inviteResponse = $this->invitationModel->sendInvite($params, $translator, $templating);
  951.                     return $inviteResponse;
  952.                 } else {
  953.                     return ["success" => false, "message" =>  $translator->trans("Organization_does_not_created")];
  954.                 }
  956.                 break;
  958.             case 'individual':
  960.                 // Register user if not exists                                
  961.                 $organization['data'] = $loggedInUser->getOrganization();
  963.                 if (isset($organization['data']) && $organization['data'] instanceof \Pimcore\Model\DataObject\Organization) {
  964.                     // Register user if not exists
  965.                     $organization_users = new DataObject\Customer\Listing();
  966.                     $organization_users->filterByOrganization($organization['data']);
  967.                     $organization_users->load();
  968.                     if ($organization_users->getCount() >= $organization['data']->getLimit()) {
  969.                         throw new \Exception("Inivite Limit Exceeded");
  970.                     }
  972.                     $userRole = DataObject\UserRole::getByName(USER_ROLES['CLIENT_USER'], true);
  974.                     if (!$userRole instanceof UserRole) {
  975.                         throw new \Exception("User role not found");
  976.                     }
  978.                     $params = [
  979.                         'email' => $email,
  980.                         'organization' => $organization['data'],
  981.                         'name' => $name,
  982.                         'department' => $department,
  983.                         'title' => $title,
  984.                         'groupId' => $groupId,
  985.                         'createdBy' => $loggedInUser,
  986.                         'phone' => $phone
  987.                     ];
  989.                     // check package user limit
  990.                     $customSubscriptions = new DataObject\Subscription\Listing();
  991.                     $customSubscriptions->filterBySubscribedUser($loggedInUser);
  992.                     $customSubscriptions->filterByIsActive(true);
  993.                     $customSubscriptions->filterBySubscriptionType("custom");
  994.                     $customSubscription = $customSubscriptions->current();
  996.                     if (!$customSubscription instanceof DataObject\Subscription) {
  997.                         return ["success" => false, "message" => $translator->trans("no_custom_subscription_found_to_organization")];
  998.                     }
  1000.                     $package = $customSubscription->getSubscribedPackage();
  1002.                     if (!$package instanceof DataObject\Package) {
  1003.                         return ["success" => false, "message" => $translator->trans("custom_package_not_found_to_organization")];
  1004.                     }
  1006.                     $customerList = new DataObject\Customer\Listing();
  1007.                     $customerList->filterByOrganization($organization['data']);
  1008.                     $customerList->setUnpublished(1);
  1009.                     $totalcustomer = $customerList->count();
  1011.                     $maxUser = 0;
  1012.                     if ($package->getMaxUsers()) {
  1013.                         $maxUser = (int) $package->getMaxUsers();
  1014.                     }
  1016.                     if ($totalcustomer >= $maxUser) {
  1017.                         return ["success" => false, "message" => $translator->trans("invite_user_limit_exceeded_for_this_organization")];
  1018.                     }
  1019.                     // check package user limit
  1021.                     $userResponse = $this->createUser($userRole, $params, $translator);
  1023.                     if ($userResponse['success'] != true) {
  1024.                         return $userResponse;
  1025.                     }
  1027.                     // new invited user
  1028.                     $user = $userResponse['data'];
  1031.                     $params = [
  1032.                         'locations' => $locations,
  1033.                         'loggedInUser' => $loggedInUser,
  1034.                         'user' => $user,
  1035.                         'package' => $package,
  1036.                         'disallowedApiGroupsArray' => null,
  1037.                         'subscriptionType' => 'custom'
  1038.                     ];
  1040.                     $assignPermission = $this->assignPermissionAndLocation($user, $userRole, $params, $translator);
  1042.                     if ($assignPermission['success'] != true) {
  1043.                         return $assignPermission;
  1044.                     }
  1045.                     // Send invite
  1046.                     $params = [
  1047.                         'user' => $user,
  1048.                         'email' => $user->getEmail(),
  1049.                         'userName' => $user->getName(),
  1050.                         'url' => $hostName . $userResponse['token'],
  1051.                         'role' => ($user->getRole() ? $loggedInUser->getRole()->getName() : null),
  1052.                         'clientType' => "individual",
  1053.                         'inviteSenderName' => $loggedInUser->getName(),
  1054.                         'entityAdminsData' => $this->getEntityAdminData($user->getOrganization()),
  1055.                         'subject' => "Invitation to Join NCM Business Portal",
  1056.                         'hostPath' => $request->getSchemeAndHttpHost(),
  1057.                         'phone' => $phone,
  1058.                         'resend' => false,
  1059.                         // 'invite_sender_organization_name' => ($loggedInUser->getOrganization() ? $loggedInUser->getOrganization()->getName() : null),
  1060.                     ];
  1062.                     $inviteResponse = $this->invitationModel->sendInvite($params, $translator, $templating);
  1064.                     return $inviteResponse;
  1065.                 } else {
  1066.                     return ["success" => false, "message" =>  $translator->trans("no_organization_is_associated_with_logged_in_user")];
  1067.                 }
  1069.                 break;
  1071.             case 'user':
  1073.                 // Register user if not exists
  1075.                 if ($organizationId != null) {
  1076.                     $organization = DataObject\Organization::getById($organizationId, true);
  1077.                     if (!$organization instanceof DataObject\Organization) {
  1078.                         return ["success" => false, "message" =>  $translator->trans("organization_does_not_exists")];
  1079.                     }
  1080.                 }
  1082.                 $organizationEmail = $organization->getEmail();
  1084.                 // if(substr(strrchr($organizationEmail, "@"), 1) != substr(strrchr($email, "@"), 1)){
  1085.                 //     return ["success" => false, "message" =>  $translator->trans("email_does_not_belongs_to_organization")];
  1086.                 // }
  1088.                 // get organization package
  1089.                 $package = $organization->getPackage();
  1090.                 if (!$package instanceof DataObject\Package) {
  1092.                     $organizationUser = DataObject\Customer::getByOrganization($organization, ['limit' => 1, 'unpublished' => true]);
  1093.                     if (!$organizationUser instanceof DataObject\Customer) {
  1094.                         return ["success" => false, "message" =>  $translator->trans("organization_owner_not_exists")];
  1095.                     }
  1097.                     // Get Custom Subscription of the organization and package
  1098.                     $customSubscriptions = new DataObject\Subscription\Listing();
  1099.                     $customSubscriptions->filterBySubscribedUser($organizationUser);
  1100.                     $customSubscriptions->filterByIsActive(true);
  1101.                     $customSubscriptions->filterBySubscriptionType("custom");
  1102.                     $customSubscription = $customSubscriptions->current();
  1104.                     if (!$customSubscription instanceof DataObject\Subscription) {
  1105.                         return ["success" => false, "message" => $translator->trans("no_custom_subscription_found_to_organization")];
  1106.                     }
  1108.                     $package = $customSubscription->getSubscribedPackage();
  1110.                     if (!$package instanceof DataObject\Package) {
  1111.                         return ["success" => false, "message" => $translator->trans("custom_package_not_found_to_organization")];
  1112.                     }
  1113.                 }
  1114.                 // check package user limit
  1115.                 $customerList = new DataObject\Customer\Listing();
  1116.                 $customerList->filterByOrganization($organization);
  1117.                 $customerList->setUnpublished(1);
  1118.                 $totalcustomer = $customerList->count();
  1122.                 // get package user limit
  1123.                 $maxUser = (int) $package->getMaxUsers();;
  1126.                 if ($totalcustomer >= $maxUser) {
  1127.                     return ["success" => false, "message" => $translator->trans("invite_user_limit_exceeded_for_this_organization")];
  1128.                 }
  1129.                 // check package user limit
  1131.                 $userRole = DataObject\UserRole::getByName($role, true);
  1132.                 if (!$userRole instanceof UserRole) {
  1133.                     throw new \Exception("User role not found");
  1134.                 }
  1135.                 $params = [
  1136.                     'email' => $email,
  1137.                     'organization' => $organization,
  1138.                     'name' => $name,
  1139.                     'department' => $department,
  1140.                     'title' => $title,
  1141.                     'groupId' => $groupId,
  1142.                     'createdBy' => $loggedInUser,
  1143.                     'phone' => $phone
  1144.                 ];
  1145.                 $userResponse = $this->createUser($userRole, $params, $translator);
  1146.                 if ($userResponse['success'] != true) {
  1147.                     return $userResponse;
  1148.                 }
  1149.                 // new invited user
  1150.                 $user = $userResponse['data'];
  1151.                 $params = [
  1152.                     'locations' => $locations,
  1153.                     'loggedInUser' => $loggedInUser,
  1154.                     'user' => $user,
  1155.                     'package' => $package,
  1156.                     'disallowedApiGroupsArray' => null,
  1157.                     'subscriptionType' => 'custom'
  1158.                 ];
  1159.                 $assignPermission = $this->assignPermissionAndLocation($user, $userRole, $params, $translator);
  1160.                 if ($assignPermission['success'] != true) {
  1161.                     return $assignPermission;
  1162.                 }
  1163.                 // Send invite
  1164.                 $params = [
  1165.                     'user' => $user,
  1166.                     'email' => $user->getEmail(),
  1167.                     'userName' => $user->getName(),
  1168.                     'url' => $hostName . $userResponse['token'],
  1169.                     'role' => ($user->getRole() ? $user->getRole()->getName() : null),
  1170.                     'clientType' => "user",
  1171.                     'inviteSenderName' => $loggedInUser->getName(),
  1172.                     'entityAdminsData' => $this->getEntityAdminData($user->getOrganization()),
  1173.                     'subject' => "Invitation to Join NCM Business Portal",
  1174.                     'hostPath' => $request->getSchemeAndHttpHost(),
  1175.                     'resend' => false,
  1176.                     //'invite_sender_organization_name' => ($loggedInUser->getOrganization() ? $loggedInUser->getOrganization()->getName() : null),
  1177.                 ];
  1178.                 // Send invitation
  1179.                 $inviteResponse = $this->invitationModel->sendInvite($params, $translator, $templating);
  1181.                 //set organization active if it is not active and total customer is less than 1
  1182.                 if ($totalcustomer < 1 && !$organization->getIsActive()) {
  1183.                     $organization->setIsActive(true);
  1184.                     // assign package to organization if not assigned
  1185.                     if (!$organization->getPackage() instanceof DataObject\Package) {
  1186.                         $organization->setPackage($package);
  1187.                     }
  1188.                     $organization->setPackageActivationDate(Carbon::now());
  1189.                     $organization->save();
  1190.                 }
  1191.                 return $inviteResponse;
  1193.                 break;
  1195.             default:
  1197.                 return ["success" => false, "message" => $translator->trans("invalid_client_type")];
  1198.         }
  1199.         // } catch (\Exception $ex) {
  1200.         //     // $result = ["success" => false, "message" => $ex->getMessage()];
  1201.         // }
  1203.         return $result;
  1204.     }
  1207.     /**
  1208.      * Create new user directly form admin and organization or user by NCM 
  1209.      * 
  1210.      */
  1211.     public function adminCreateUser(
  1212.         $request,
  1213.         $translator,
  1214.         $email,
  1215.         $name,
  1216.         $role,
  1217.         $logo = null,
  1218.         $clientType,
  1219.         $companyNameEn,
  1220.         $companyNameAr,
  1221.         $locations,
  1222.         $loggedInUser,
  1223.         $department = null,
  1224.         $title = null,
  1225.         $groupId,
  1226.         $packageId,
  1227.         $organizationId,
  1228.         $password,
  1229.         $phone = null,
  1230.         $entityStatus,
  1231.         $trialLimit,
  1232.         $templating
  1233.     ) {
  1235.         $result = [];
  1236.         $user  = DataObject\Customer::getByEmail($email, ['limit' => 1, 'unpublished' => true]);
  1237.         if ($user instanceof DataObject\Customer) {
  1238.             if ($user->getRole()->getName() == USER_ROLES['NCM_OPERATOR'] || $user->getRole()->getName() == USER_ROLES['NCM_IT']) {
  1239.                 return ["success" => false, "message" => $translator->trans("user_already_exists_in_internal_user")];
  1240.             } else {
  1241.                 return ["success" => false, "message" => $translator->trans("user_already_exists")];
  1242.             }
  1243.         }
  1246.         switch ($clientType) {
  1247.             case 'organization':
  1248.             case 'government':
  1249.                 // Register organization if not exists
  1251.                 $package  = DataObject\Package::getById($packageId, true);
  1252.                 if (!$package instanceof DataObject\Package) {
  1253.                     return ["success" => false, "message" => $translator->trans("package_not_found")];
  1254.                 }
  1256.                 // Check if the name already exists for another organization
  1257.                 $organization = DataObject\Organization::getByName($companyNameEn, 'en', ['limit' => 1, 'unpublished' => true]);
  1258.                 if ($organization instanceof DataObject\Organization) {
  1259.                     return ["success" => false, "message" => $translator->trans("organization_already_exists") . " : " . $companyNameEn];
  1260.                 }
  1262.                 // $organizationByEmail = DataObject\Organization::getByEmail($email, true);
  1263.                 // if ($organizationByEmail instanceof DataObject\Organization) {
  1264.                 //     return ["success" => false, "message" => sprintf($translator->trans("organization_already_created_with_this: %s"), $email)];
  1265.                 // }
  1267.                 $allowedStatuses = ['paid', 'trial', 'expired'];
  1268.                 if (!in_array($entityStatus, $allowedStatuses)) {
  1269.                     return ["success" => false, "message" => $translator->trans("undefined_entity_status")];
  1270.                 }
  1272.                 // set params to create organization
  1273.                 $params = [
  1274.                     'name' => $companyNameEn,
  1275.                     'nameAr' => $companyNameAr,
  1276.                     'code' => $companyNameEn,
  1277.                     'client_type' => $clientType,
  1278.                     'email' => $email,
  1279.                     'entityStatus' => $entityStatus,
  1280.                     'trialLimit' => $trialLimit,
  1281.                     'package' => $package
  1282.                     // 'logo'=>$logo
  1283.                 ];
  1285.                 $organization = $this->createOrganization($request, $params, $loggedInUser, $translator);
  1286.                 if (isset($organization['data']) && $organization['data'] instanceof DataObject\Organization) {
  1287.                     // check role of user before inviting 
  1288.                     if ($loggedInUser->getRole()->getName() == USER_ROLES['CLIENT_ADMIN'] && ($role == USER_ROLES['NCM_IT'] || $role == USER_ROLES['NCM_OPERATOR'])) {
  1289.                         return ["success" => false, "message" => $translator->trans("CLIENT_ADMIN_can_not_invite_NCM_IT_or_NCM_OPERATOR")];
  1290.                     }
  1292.                     if ($loggedInUser->getRole()->getName() == USER_ROLES['CLIENT_ADMIN']) {
  1293.                         return ["success" => false, "message" => $translator->trans("CLIENT_USER_can_not_invite")];
  1294.                     }
  1296.                     $userRole = DataObject\UserRole::getByName(USER_ROLES['CLIENT_ADMIN'], true);
  1297.                     if (!$userRole instanceof UserRole) {
  1298.                         return ["success" => false, "message" => $translator->trans("User_Role_Not_Found")];
  1299.                     }
  1301.                     // set params to create user
  1302.                     $params = [
  1303.                         'email' => $email,
  1304.                         'organization' => $organization['data'],
  1305.                         'name' => $name,
  1306.                         'role' => $userRole,
  1307.                         'groupId' => $groupId,
  1308.                         'title' =>  $title,
  1309.                         'department' => $department,
  1310.                         'password' => $password,
  1311.                         'createdBy' => $loggedInUser,
  1312.                         'token' => null,
  1313.                         'published' => true,
  1314.                         'phone' =>  $phone
  1315.                     ];
  1316.                     $userResponse = $this->userModel->register($request, $params, $translator);
  1319.                     if ($userResponse['success'] == true) {
  1320.                         $user = $userResponse['data'];
  1322.                         if (empty($user->getNcmCRMId())) {
  1323.                             // Prepare contact data for CRM
  1324.                             $contactData = [
  1325.                                 "firstName" => $user->getName(),
  1326.                                 "lastName" => "",
  1327.                                 "fullName" => $user->getName(),
  1328.                                 "email" => $user->getEmail(),
  1329.                                 "businessPhone" => $user->getPhoneNo() ?? "",
  1330.                                 "address" => new \stdClass(),
  1331.                             ];
  1333.                             // Call CRM Service
  1334.                             $crmId = $this->crmService->addContact($contactData);
  1335.                             if ($crmId) {
  1336.                                 $user->setNcmCRMId($crmId);
  1337.                                 $user->save();
  1338.                             }
  1339.                         }
  1340.                     }
  1342.                     if ($userResponse['success'] != true) {
  1343.                         return $userResponse;
  1344.                     }
  1346.                     // new invited user
  1347.                     $user = $userResponse['data'];
  1348.                     $params = [
  1349.                         'locations' => $locations,
  1350.                         'loggedInUser' => $loggedInUser,
  1351.                         'user' => $user,
  1352.                         'package' => $package,
  1353.                         'disallowedApiGroupsArray' => null,
  1354.                         'subscriptionType' => 'custom'
  1355.                     ];
  1357.                     $assignPermission = $this->assignPermissionAndLocation($user, $userRole, $params, $translator);
  1359.                     if ($assignPermission['success'] != true) {
  1360.                         return $assignPermission;
  1361.                     }
  1363.                     return ["success" => true, "message" =>  $translator->trans("organization_created_successfully")];
  1364.                 } else {
  1365.                     return ["success" => false, "message" =>  $translator->trans("Organization_does_not_created")];
  1366.                 }
  1368.                 break;
  1372.             case 'user':
  1374.                 // Register user if not exists
  1375.                 if ($organizationId != null) {
  1376.                     $organization = DataObject\Organization::getById($organizationId, true);
  1377.                     if (!$organization instanceof DataObject\Organization) {
  1378.                         return ["success" => false, "message" =>  $translator->trans("organization_does_not_exists")];
  1379.                     }
  1380.                 }
  1382.                 $organizationEmail = $organization->getEmail();
  1384.                 // if(substr(strrchr($organizationEmail, "@"), 1) != substr(strrchr($email, "@"), 1)){
  1385.                 //     return ["success" => false, "message" =>  $translator->trans("email_does_not_belongs_to_organization")];
  1386.                 // }
  1389.                 // get organization package
  1390.                 $package = $organization->getPackage();
  1391.                 if (!$package instanceof DataObject\Package) {
  1393.                     $organizationUser = DataObject\Customer::getByOrganization($organization, ['limit' => 1, 'unpublished' => true]);
  1394.                     if (!$organizationUser instanceof DataObject\Customer) {
  1395.                         return ["success" => false, "message" =>  $translator->trans("organization_owner_not_exists")];
  1396.                     }
  1398.                     // Get Custom Subscription of the organization and package
  1399.                     $customSubscriptions = new DataObject\Subscription\Listing();
  1400.                     $customSubscriptions->filterBySubscribedUser($organizationUser);
  1401.                     $customSubscriptions->filterByIsActive(true);
  1402.                     $customSubscriptions->filterBySubscriptionType("custom");
  1403.                     $customSubscription = $customSubscriptions->current();
  1405.                     if (!$customSubscription instanceof DataObject\Subscription) {
  1406.                         return ["success" => false, "message" => $translator->trans("no_custom_subscription_found_to_organization")];
  1407.                     }
  1409.                     $package = $customSubscription->getSubscribedPackage();
  1411.                     if (!$package instanceof DataObject\Package) {
  1412.                         return ["success" => false, "message" => $translator->trans("custom_package_not_found_to_organization")];
  1413.                     }
  1414.                 }
  1416.                 // check package user limit
  1417.                 $customerList = new DataObject\Customer\Listing();
  1418.                 $customerList->filterByOrganization($organization);
  1419.                 $customerList->setUnpublished(1);
  1420.                 $totalcustomer = $customerList->count();
  1424.                 // get package user limit
  1425.                 $maxUser = (int) $package->getMaxUsers();
  1428.                 if ($totalcustomer >= $maxUser) {
  1429.                     return ["success" => false, "message" => $translator->trans("invite_user_limit_exceeded_for_this_organization")];
  1430.                 }
  1431.                 // check package user limit
  1433.                 $userRole = DataObject\UserRole::getByName($role, true);
  1434.                 if (!$userRole instanceof UserRole) {
  1435.                     return ["success" => false, "message" => $translator->trans("User_Role_Not_Found")];
  1436.                 }
  1438.                 // set params to create user
  1439.                 $params = [
  1440.                     'email' => $email,
  1441.                     'organization' => $organization,
  1442.                     'name' => $name,
  1443.                     'role' => $userRole,
  1444.                     'groupId' => $groupId,
  1445.                     'title' =>  $title,
  1446.                     'department' => $department,
  1447.                     'password' => $password,
  1448.                     'createdBy' => $loggedInUser,
  1449.                     'token' => null,
  1450.                     'published' => true,
  1451.                     'phone' => $phone
  1452.                 ];
  1453.                 $userResponse = $this->userModel->register($request, $params, $translator);
  1455.                 if ($userResponse['success'] != true) {
  1456.                     return $userResponse;
  1457.                 }
  1459.                 if ($userResponse['success'] == true) {
  1460.                     $user = $userResponse['data'];
  1462.                     if (empty($user->getNcmCRMId())) {
  1463.                         $contactData = [
  1464.                             "firstName" => $user->getName(),
  1465.                             "lastName" => "",
  1466.                             "fullName" => $user->getName(),
  1467.                             "email" => $user->getEmail(),
  1468.                             "businessPhone" => $user->getPhoneNo() ?? "",
  1469.                             "address" => new \stdClass(),
  1471.                         ];
  1473.                         // Call CRM Service
  1474.                         $crmId = $this->crmService->addContact($contactData);
  1475.                         if ($crmId) {
  1476.                             $user->setNcmCRMId($crmId);
  1477.                             $user->save();
  1478.                         }
  1479.                     }
  1480.                 }
  1482.                 // new invited user
  1483.                 $user = $userResponse['data'];
  1484.                 $params = [
  1485.                     'locations' => $locations,
  1486.                     'loggedInUser' => $loggedInUser,
  1487.                     'user' => $user,
  1488.                     'package' => $package,
  1489.                     'disallowedApiGroupsArray' => null,
  1490.                     'subscriptionType' => 'custom'
  1491.                 ];
  1492.                 $assignPermission = $this->assignPermissionAndLocation($user, $userRole, $params, $translator);
  1493.                 if ($assignPermission['success'] != true) {
  1494.                     return $assignPermission;
  1495.                 }
  1497.                 $userData = [
  1498.                     'userId' => $user->getId(),
  1499.                     'email' => $user->getEmail(),
  1500.                     'name' => $user->getName(),
  1501.                     'role' => $role,
  1502.                     'type' => 'created',
  1503.                 ];
  1505.                 $entityAdminsData = $this->getEntityAdminData($organization);
  1507.                 // Temporarily closed for testing purposes
  1508.                 // $this->invitationModel->notifyAdmins($userData, $entityAdminsData, $translator, $templating);
  1510.                 //set organization active if it is not active and total customer is less than 1
  1511.                 if ($totalcustomer < 1 && !$organization->getIsActive()) {
  1512.                     $organization->setIsActive(true);
  1513.                     // assign package to organization if not assigned
  1514.                     if (!$organization->getPackage() instanceof DataObject\Package) {
  1515.                         $organization->setPackage($package);
  1516.                     }
  1517.                     $organization->setPackageActivationDate(Carbon::now());
  1518.                     $organization->save();
  1519.                 }
  1520.                 return ["success" => true, "message" =>  $translator->trans("user_created_successfully")];
  1522.                 break;
  1524.             default:
  1526.                 return ["success" => false, "message" => $translator->trans("invalid_client_type")];
  1527.         }
  1530.         return $result;
  1531.     }
  1533.     /**
  1534.      * Send invite to Organization and Individual users
  1535.      * 
  1536.      */
  1537.     public function clientInvite(
  1538.         $request,
  1539.         $translator,
  1540.         $email,
  1541.         $name,
  1542.         $role,
  1543.         $clientType,
  1544.         $locations,
  1545.         $locationTagIds,
  1546.         $loggedInUser,
  1547.         $hostName,
  1548.         $department,
  1549.         $title,
  1550.         $groupId,
  1551.         $disallowedApiGroupsArray,
  1552.         $templating,
  1553.         $isNoExpiry = false
  1554.     ) {
  1555.         $user  = DataObject\Customer::getByEmail($email, ['limit' => 1, 'unpublished' => true]);
  1556.         if ($user instanceof DataObject\Customer) {
  1557.             if (($user->getRole()->getName() ==  USER_ROLES['CLIENT_ADMIN'] || $user->getRole()->getName() == USER_ROLES['CLIENT_USER']) && $user->getOrganization()->getId() == $loggedInUser->getOrganization()->getId()) {
  1558.                 return ["success" => false, "message" => $translator->trans("user_already_exists")];
  1559.             } elseif (($user->getRole()->getName() ==  USER_ROLES['CLIENT_ADMIN'] || $user->getRole()->getName() == USER_ROLES['CLIENT_USER']) && $user->getOrganization()->getId() != $loggedInUser->getOrganization()->getId()) {
  1560.                 return ["success" => false, "message" => $translator->trans("user_already_exists_in_different_organization")];
  1561.             } elseif ($user->getRole()->getName() == USER_ROLES['NCM_OPERATOR'] || $user->getRole()->getName() == USER_ROLES['NCM_IT']) {
  1562.                 return ["success" => false, "message" => $translator->trans("user_already_exists_in_admin")];
  1563.             }
  1564.         }
  1566.         $organization = $loggedInUser->getOrganization();
  1567.         if (!$organization instanceof DataObject\Organization) {
  1568.             return ["success" => false, "message" => $translator->trans("no_organization_is_associated_with_logged_in_user")];
  1569.         }
  1570.         $organizationEmail = $organization->getEmail();
  1573.         // Set organization email if not set 
  1574.         if (empty($organizationEmail)) {
  1575.             $organization->setEmail($email);
  1576.             $organization->save();
  1577.         } else {
  1578.             if (substr(strrchr($organizationEmail, "@"), 1) != substr(strrchr($email, "@"), 1)) {
  1579.                 return ["success" => false, "message" =>  $translator->trans("email_does_not_belongs_to_organization")];
  1580.             }
  1581.         }
  1583.         $userRole = DataObject\UserRole::getByName(USER_ROLES[$role], true);
  1584.         if (!$userRole instanceof UserRole) {
  1585.             return ["success" => false, "message" => $translator->trans("User_role_not_found")];
  1586.         }
  1588.         $package = $organization->getPackage();
  1590.         if (!$package instanceof DataObject\Package) {
  1591.             // Get Custom Subscription of the organization and package
  1592.             $customSubscriptions = new DataObject\Subscription\Listing();
  1593.             $customSubscriptions->filterBySubscribedUser($loggedInUser);
  1594.             $customSubscriptions->filterByIsActive(true);
  1595.             $customSubscriptions->filterBySubscriptionType("custom");
  1596.             $customSubscription = $customSubscriptions->current();
  1598.             if (!$customSubscription instanceof DataObject\Subscription) {
  1599.                 return ["success" => false, "message" => $translator->trans("no_custom_subscription_found_to_organization")];
  1600.             }
  1602.             $package = $customSubscription->getSubscribedPackage();
  1604.             if (!$package instanceof DataObject\Package) {
  1605.                 return ["success" => false, "message" => $translator->trans("custom_package_not_found_to_organization")];
  1606.             }
  1607.         }
  1609.         $customerList = new DataObject\Customer\Listing();
  1610.         $customerList->filterByOrganization($organization);
  1611.         $customerList->setUnpublished(1);
  1612.         $totalcustomer = $customerList->count();
  1614.         $maxUser = 0;
  1615.         if ($package->getMaxUsers()) {
  1616.             $maxUser = (int) $package->getMaxUsers();
  1617.         }
  1619.         if ($totalcustomer >= $maxUser) {
  1620.             return ["success" => false, "message" => $translator->trans("invite_user_limit_exceeded_for_this_organization")];
  1621.         }
  1623.         $params = [
  1624.             'email' => $email,
  1625.             'organization' => $organization,
  1626.             'name' => $name,
  1627.             'department' => $department,
  1628.             'title' => $title,
  1629.             'groupId' => $groupId,
  1630.             'createdBy' => $loggedInUser,
  1631.             'isNoExpiry' => $isNoExpiry
  1633.         ];
  1635.         $userResponse = $this->createUser($userRole, $params, $translator);
  1636.         if ($userResponse['success'] != true) {
  1637.             return $userResponse;
  1638.         }
  1642.         // new invited user
  1643.         $user = $userResponse['data'];
  1644.         $params = [
  1645.             'locations' => $locations,
  1646.             'loggedInUser' => $loggedInUser,
  1647.             'user' => $user,
  1648.             'package' => $package,
  1649.             'disallowedApiGroupsArray' => $role == USER_ROLES['CLIENT_USER'] ? $disallowedApiGroupsArray : null,
  1650.             'subscriptionType' => 'custom',
  1651.             'isNoExpiry' => $isNoExpiry,
  1653.         ];
  1654.         $assignPermission = $this->assignPermissionAndLocation($user, $userRole, $params, $translator);
  1656.         if ($assignPermission['success'] != true) {
  1657.             return $assignPermission;
  1658.         }
  1661.         // Assign location by location tag id to user
  1663.         if (isset($locationTagIds) && !empty($locationTagIds)) {
  1665.             $assignLocationByLocationTagId = $this->userModel->assignLocationToUser($loggedInUser, null, $locationTagIds, [$user->getId()], null, false, false, $translator);
  1666.             if (isset($assignLocationByLocationTagId['success']) && $assignLocationByLocationTagId['success'] == false) {
  1667.                 return $assignLocationByLocationTagId;
  1668.             }
  1669.         }
  1673.         // Send invite
  1674.         $params = [
  1675.             'user' => $user,
  1676.             'email' => $user->getEmail(),
  1677.             'userName' => $user->getName(),
  1678.             'url' => $hostName . $userResponse['token'],
  1679.             'role' => ($user->getRole() ? $user->getRole()->getName() : null),
  1680.             'clientType' => "user",
  1681.             'inviteSenderName' => $loggedInUser->getName(),
  1682.             // 'invite_sender_organization_name' => ($loggedInUser->getOrganization() ? $loggedInUser->getOrganization()->getName() : null),
  1683.             'subject' => "Invitation to Join NCM Business Portal",
  1684.             'hostPath' => $request->getSchemeAndHttpHost(),
  1685.             'entityAdminsData' => $this->getEntityAdminData($user->getOrganization()),
  1686.             'resend' => false,
  1687.         ];
  1689.         // Send invitation
  1690.         $inviteResponse = $this->invitationModel->sendInvite($params, $translator, $templating);
  1691.         return $inviteResponse;
  1692.     }
  1695.     /**
  1696.      * Resend invite to Organization , NCM_users or Individual users
  1697.      * 
  1698.      */
  1699.     public function resendInvite($request, $userIdOrIds, $loggedInUser, $translator, $templating): array
  1701.     {
  1703.         $ids = is_array($userIdOrIds) ? $userIdOrIds : [$userIdOrIds];
  1704.         $results = [];
  1706.         foreach ($ids as $userId) {
  1707.             $user = DataObject\Customer::getById($userId, true);
  1709.             if ($user instanceof \Pimcore\Model\DataObject\Customer) {
  1710.                 if (!empty($user->getToken())) {
  1711.                     $organization = $user->getOrganization();
  1712.                     if ($organization instanceof \Pimcore\Model\DataObject\Organization) {
  1714.                         $headers = array('alg' => 'HS256', 'typ' => 'JWT');
  1715.                         //create token for new user
  1716.                         $payload = array('email' => $user->getEmail(), 'org_id' => $organization->getId(), 'time' => time());
  1717.                         $newToken = $this->invitationModel->generateJwtToken($headers, $payload);
  1719.                         $user->setToken($newToken);
  1720.                         $user->save();
  1721.                         if ($user) {
  1723.                             $decodedJwtToken['username'] = $user->getEmail();
  1724.                             $userPermissions = $this->userPermission->checkPermission($decodedJwtToken, $translator);
  1726.                             $userPermission = $userPermissions['success'] ? $userPermissions['grants'] : null;
  1729.                             $role = ($user->getRole()) ? $user->getRole()->getName() : null;
  1730.                             $clientType = null;
  1731.                             if ($role == 'CLIENT_ADMIN' || $role == 'CLIENT_USER') {
  1732.                                 $hostName = NCM_HOST_NAME;
  1733.                                 $subject = "Invitation to Join NCM Business Portal";
  1735.                                 $clientOrganization = DataObject\Organization::getByEmail($user->getEmail(), true);
  1736.                                 if ($clientOrganization instanceof \Pimcore\Model\DataObject\Organization) {
  1737.                                     $clientType = $clientOrganization->getCilent_type();
  1738.                                 } else {
  1739.                                     $clientType = "user";
  1740.                                 }
  1741.                             } else {
  1742.                                 $hostName = NCM_ADMIN_HOST_NAME;
  1743.                                 $subject = "Invitation to Join NCM Admin Portal";
  1744.                                 $clientType = "NCM_admin";
  1745.                             }
  1748.                             if ($clientType == "NCM_admin") {
  1750.                                 $permission = [
  1752.                                     'Inviting Clients' => isset($userPermission['grants']['invite_user']) ? $userPermission['grants']['invite_user'] : false,
  1753.                                     'Managing Clients' => isset($userPermission['grants']['edit_user']) ? $userPermission['grants']['edit_user'] : false,
  1754.                                     'Deleting Clients' => isset($userPermission['grants']['delete_user']) ? $userPermission['grants']['delete_user'] : false,
  1755.                                     'Inviting NCM Admin' => isset($userPermission['grants']['invite_ncm_user']) ? $userPermission['grants']['invite_ncm_user'] : false,
  1756.                                     'Managing NCM Admin' => isset($userPermission['grants']['edit_ncm_user']) ? $userPermission['grants']['edit_ncm_user'] : false,
  1757.                                     'Deleting NCM Admin' => isset($userPermission['grants']['delete_ncm_user']) ? $userPermission['grants']['delete_ncm_user'] : false,
  1758.                                 ];
  1760.                                 $params = [
  1761.                                     'user' => $user,
  1762.                                     'email' => $user->getEmail(),
  1763.                                     'userName' => $user->getName(),
  1764.                                     'role' => ($user->getRole() ? $user->getRole()->getName() : null),
  1765.                                     'url' => $hostName . $newToken,
  1766.                                     'clientType' => "NCM_admin",
  1767.                                     'inviteSenderName' => $loggedInUser->getName(),
  1768.                                     'permissions' => $permission,
  1769.                                     'subject' => "Invitation to Join Admin Portal as NCM Admin",
  1770.                                     'resend' => true
  1771.                                 ];
  1772.                             } elseif ($clientType == "organization" || $clientType == "government") {
  1774.                                 $permission = [
  1775.                                     'Allow Custom Notification' => isset($userPermission['grants']['get_custom_notification']) ? $userPermission['grants']['get_custom_notification'] : false,
  1776.                                     'Allow Add Location' => isset($userPermission['grants']['compare_location']) ? $userPermission['grants']['compare_location'] : false,
  1777.                                     'Allow AlertHistory For Custom Alerts' => isset($userPermission['grants']['alert_history']) ? $userPermission['grants']['alert_history'] : false,
  1778.                                     'Allow Forecast' => isset($userPermission['grants']['get_weather']) ? $userPermission['grants']['get_weather'] : false,
  1779.                                     'Allow Organization Admin To Invite Users' => isset($userPermission['grants']['invite_user']) ? $userPermission['grants']['invite_user'] : false,
  1780.                                 ];
  1781.                                 $params = [
  1782.                                     'user' => $user,
  1783.                                     'email' => $user->getEmail(),
  1784.                                     'userName' => $user->getName(),
  1785.                                     'url' => $hostName . $newToken,
  1786.                                     'role' => ($user->getRole() ? $user->getRole()->getName() : null),
  1787.                                     'clientType' => $clientType,
  1788.                                     'inviteSenderName' => $loggedInUser->getName(),
  1789.                                     'organization_name' => ($user->getOrganization() ? $user->getOrganization()->getName() : null),
  1790.                                     'NCMItAdminsData' => $this->getNCMItData(),
  1791.                                     'permissions' => $permission,
  1792.                                     'inviteSenderRole' => ($loggedInUser->getRole() ? $loggedInUser->getRole()->getName() : null),
  1793.                                     'subject' => "Invitation to Join NCM Business Portal",
  1794.                                     'NCMItAdminNotificationSubject' => "NCM Admin Invited Organization",
  1795.                                     'resend' => true
  1796.                                 ];
  1797.                             } elseif ($clientType == "individual" || $clientType == "user") {
  1799.                                 $params = [
  1800.                                     'user' => $user,
  1801.                                     'email' => $user->getEmail(),
  1802.                                     'userName' => $user->getName(),
  1803.                                     'url' => $hostName . $newToken,
  1804.                                     'role' => ($user->getRole() ? $loggedInUser->getRole()->getName() : null),
  1805.                                     'clientType' => "user",
  1806.                                     'inviteSenderName' => $loggedInUser->getName(),
  1807.                                     // 'invite_sender_organization_name' => ($loggedInUser->getOrganization() ? $loggedInUser->getOrganization()->getName() : null),
  1808.                                     'subject' => "Invitation to Join NCM Business Portal",
  1809.                                     'resend' => true
  1810.                                 ];
  1811.                             }
  1813.                             // Send invitation
  1814.                             $inviteResponse = $this->invitationModel->sendInvite($params, $translator, $templating);
  1815.                             $results[] = ["id" => $userId, "success" => ($inviteResponse['success'] ?? false), "message" => ($inviteResponse['message'] ?? null)];
  1816.                         }
  1817.                     } else {
  1818.                         $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("no_organization_is_associated_with_logged_in_user")];
  1819.                     }
  1820.                 } else {
  1821.                     $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("user_token_is_invalid")];
  1822.                 }
  1823.             } else {
  1824.                 $results[] = ["id" => $userId, "success" => false, "message" => $translator->trans("user_is_not_available")];
  1825.             }
  1826.         }
  1828.         if (!is_array($userIdOrIds)) {
  1829.             $single = $results[0] ?? ["success" => false, "message" => $translator->trans("unknown_error")];
  1830.             return ["success" => $single["success"], "message" => $single["message"]];
  1831.         }
  1833.         $successCount = 0;
  1834.         foreach ($results as $r) {
  1835.             if (!empty($r['success'])) {
  1836.                 $successCount++;
  1837.             }
  1838.         }
  1839.         return ["success" => true, "message" => sprintf("%s: %d", $translator->trans("reinvite_email_sent"), $successCount)];
  1840.     }
  1843.     /**
  1844.      * Get NCM_IT Admins Data
  1845.      */
  1846.     public function getNCMItData()
  1847.     {
  1849.         $NCMItData = [];
  1850.         $NCMItRole = DataObject\UserRole::getByName(USER_ROLES['NCM_IT'], true);
  1852.         $NCMItAdmins = new DataObject\Customer\Listing();
  1853.         $NCMItAdmins->filterByRole($NCMItRole);
  1854.         foreach ($NCMItAdmins as $NCMItAdminsData) {
  1855.             $NCMItData[] = [
  1856.                 'email' => $NCMItAdminsData->getEmail(),
  1857.                 'name' => $NCMItAdminsData->getName()
  1858.             ];
  1859.         }
  1860.         return $NCMItData;
  1861.     }
  1863.     /**
  1864.      * Get Entity Admins Data
  1865.      */
  1867.     public function getEntityAdminData(Organization $organization)
  1868.     {
  1869.         $entityAdminData = [];
  1870.         $entityAdminRole = DataObject\UserRole::getByName(USER_ROLES['CLIENT_ADMIN'], true);
  1872.         $entityAdmins = new DataObject\Customer\Listing();
  1873.         $entityAdmins->filterByRole($entityAdminRole);
  1874.         $entityAdmins->filterByOrganization($organization);
  1876.         foreach ($entityAdmins as $entityAdmin) {
  1877.             $entityAdminData[] = [
  1878.                 'id' => $entityAdmin->getId(),
  1879.                 'email' => $entityAdmin->getEmail(),
  1880.                 'name' => $entityAdmin->getName(),
  1881.                 'entityName' => $organization->getName(),
  1882.             ];
  1883.         }
  1884.         return $entityAdminData;
  1885.     }
  1887.     /**
  1888.      * Create asset
  1889.      */
  1890.     private function createAssetByURL($url)
  1891.     {
  1892.         $asset = new \Pimcore\Model\Asset\Image();
  1893.         $asset->setFilename(time() . '-' . basename(parse_url($url, PHP_URL_PATH)));
  1894.         $asset->setData(file_get_contents($url));
  1895.         $asset->setParent(\Pimcore\Model\Asset\Service::createFolderByPath("organization_logo"));
  1896.         $asset->save();
  1897.         $advancedImage = new \Pimcore\Model\DataObject\Data\Hotspotimage();
  1898.         $advancedImage->setImage($asset);
  1899.         return $advancedImage;
  1900.     }
  1902.     /**
  1903.      * Create user if not exists
  1904.      */
  1905.     private function createUser($userRole, $params, $translator)
  1906.     {
  1908.         $userResponse = [];
  1909.         if ($userRole instanceof \Pimcore\Model\DataObject\UserRole) {
  1912.             $headers = array('alg' => 'HS256', 'typ' => 'JWT');
  1913.             //create token for new user
  1914.             $payload = array('email' => $params['email'], 'org_id' => $params['organization']->getId(), 'time' => time());
  1915.             $token = $this->invitationModel->generateJwtToken($headers, $payload);
  1917.             $requestParam = [
  1918.                 'email' => $params['email'],
  1919.                 'organization' => $params['organization'],
  1920.                 'name' => $params['name'],
  1921.                 'role' => $userRole,
  1922.                 'groupId' => $params['groupId'],
  1923.                 'title' => (isset($params['title']) ? $params['title'] : ''),
  1924.                 'department' => (isset($params['department']) ? $params['department'] : ''),
  1925.                 'password' => (isset($params['password']) ? $params['password'] : ''),
  1926.                 'token' => $token,
  1927.                 'isNoExpiry' => (isset($params['isNoExpiry']) ? $params['isNoExpiry'] : false),
  1928.                 'createdBy' => $params['createdBy'],
  1929.                 'published' => (isset($params['published']) ? $params['published'] : false),
  1930.                 'phone' => isset($params['phone']) ? $params['phone'] : null,
  1931.                 'permissionUserGroupIds' => isset($params['permissionUserGroupIds']) ? $params['permissionUserGroupIds'] : []
  1933.             ];
  1934.             $userResponse = $this->userModel->register(null, $requestParam, $translator);
  1935.             if ($userResponse['success'] == true) {
  1936.                 $user = $userResponse['data'];
  1938.                 if ($user->getRole()->getName() !== USER_ROLES['NCM_IT']) {
  1939.                     if (empty($user->getNcmCRMId())) {
  1940.                         $contactData = [
  1941.                             "firstName" => $user->getName(),
  1942.                             "lastName" => "",
  1943.                             "fullName" => $user->getName(),
  1944.                             "email" => $user->getEmail(),
  1945.                             "businessPhone" => $user->getPhoneNo() ?? "",
  1946.                             "address" => new \stdClass(),
  1947.                         ];
  1949.                         $crmId = $this->crmService->addContact($contactData);
  1950.                         if ($crmId) {
  1951.                             $user->setNcmCRMId($crmId);
  1952.                             $user->save();
  1953.                         }
  1954.                     }
  1955.                 }
  1956.             }
  1957.             $userResponse['token'] = $token;
  1958.         }
  1960.         return $userResponse;
  1961.     }
  1964.     /**
  1965.      * Assiging user permission
  1966.      */
  1967.     private function assignPermissionAndLocation($user, $userRole, $params, $translator)
  1968.     {
  1969.         try {
  1970.             if (!$user instanceof \Pimcore\Model\DataObject\Customer) {
  1971.                 throw new \Exception($translator->trans("user_not_exists"));
  1972.             }
  1973.             // assign user to assigned locations
  1974.             if (!empty($params['locations']) && count($params['locations'][0]) > 0) {
  1975.                 foreach ($params['locations'][0] as $key => $value) {
  1976.                     $location = DataObject\Location::getById($value, true);
  1977.                     if ($location) {
  1978.                         $this->locationModel->locationMetaData($location, $user);
  1979.                     } else {
  1980.                         return ["success" => false, "message" => $translator->trans("location_does_not_exists")];
  1981.                     }
  1982.                 }
  1983.             }
  1984.             $params = [
  1985.                 'user' => $user,
  1986.                 'userRole' => $userRole,
  1987.                 'loggedInUser' => $params['loggedInUser'],
  1988.                 'package' => $params['package'],
  1989.                 'disallowedApiGroupsArray' => $params['disallowedApiGroupsArray'],
  1990.                 'isNoExpiry' => (isset($params['isNoExpiry']) ? $params['isNoExpiry'] : false),
  1991.             ];
  1993.             //$userPermissionResponse = $this->userModel->setPcakageSubscription($params);
  1994.             $subscription = $this->userModel->setSubscription($params['package'], $user,  $params['disallowedApiGroupsArray'], "custom", $params['isNoExpiry']);
  1995.             $result = $this->parameterModel->riskCategoryBulkCreation($user, $translator);
  1996.             if ($subscription && $result) {
  1997.                 return ["success" => true, "message" => "set_subscription."];
  1998.             }
  2000.             //return $subscription;
  2001.         } catch (\Exception $ex) {
  2002.             return ["success" => false, "message" => $ex->getMessage()];
  2003.         }
  2004.     }
  2005.     /**
  2006.      * add NCM user by admin
  2007.      * 
  2008.      */
  2009.     public function adminAddNCMUser($request, $translator, $email,  $fullName, $role, $userTagId, $hostName, $loggedInUser, $allowedApiGroups, $permissionUserGroupIds, $templating, $isNoExpiry = false, $phone = null, $password = ""): array
  2010.     {
  2011.         $result = [];
  2013.         // try {
  2015.         $user  = DataObject\Customer::getByEmail($email, ['limit' => 1, 'unpublished' => true]);
  2016.         if ($user instanceof DataObject\Customer) {
  2017.             if ($user->getRole()->getName() ==  USER_ROLES['CLIENT_ADMIN'] || $user->getRole()->getName() == USER_ROLES['CLIENT_USER']) {
  2018.                 return ["success" => false, "message" => $translator->trans("user_already_exists_in_external_user")];
  2019.             } else {
  2020.                 return ["success" => false, "message" => $translator->trans("user_already_exists")];
  2021.             }
  2022.         }
  2026.         $organization = $loggedInUser->getOrganization();
  2028.         if ($organization instanceof DataObject\Organization) {
  2029.             // Register user if not exists
  2031.             if ($loggedInUser->getRole()->getName() == USER_ROLES['NCM_OPERATOR'] && $role == USER_ROLES['NCM_IT']) {
  2032.                 return ["success" => false, "message" => $translator->trans("NCM_OPERATOR_can_not_invite_NCM_IT.")];
  2033.             }
  2035.             if ($loggedInUser->getRole()->getName() == USER_ROLES['CLIENT_ADMIN'] || $loggedInUser->getRole()->getName() == USER_ROLES['CLIENT_USER']) {
  2036.                 return ["success" => false, "message" => $translator->trans(USER_ROLES[$loggedInUser->getRole()->getName()] . "_can_not_invite_" . USER_ROLES[$role])];
  2037.             }
  2038.             $userRole = DataObject\UserRole::getByName(USER_ROLES[$role], true);
  2040.             if ($userRole instanceof DataObject\UserRole) {
  2042.                 $package  = $userRole->getCustomPackage();
  2044.                 if (!$package instanceof DataObject\Package) {
  2045.                     return ["success" => false, "message" => $translator->trans("package_not_found")];
  2046.                 }
  2048.                 $params = [
  2049.                     'email' => $email,
  2050.                     'organization' => $organization,
  2051.                     'name' => $fullName,
  2052.                     'groupId' => null,
  2053.                     'createdBy' => $loggedInUser,
  2054.                     'isNoExpiry' => $isNoExpiry,
  2055.                     'phone' => $phone,
  2056.                     'published' => true,
  2057.                     "password" => $password,
  2058.                     'permissionUserGroupIds' => $permissionUserGroupIds
  2059.                 ];
  2060.                 $userResponse = $this->createUser($userRole, $params, $translator);
  2062.                 if ($userResponse['success'] == true) {
  2064.                     $user = $userResponse['data'];
  2067.                     // assign user tag to user
  2069.                     if (isset($userTagId) && !empty($userTagId)) {
  2070.                         $tage  = UserTag::getById($userTagId);
  2071.                         if ($tage instanceof UserTag) {
  2072.                             $user->setTag($tage);
  2073.                             $user->save();
  2074.                         }
  2075.                     }
  2076.                     
  2077.                     return ["success" => true, "message" => $translator->trans("user_created")];
  2079.                     // $ncmUserSubscription = $this->userModel->setNcmUserSubscription($userRole, $user, $allowedApiGroups, $isNoExpiry);
  2080.                     // if ($ncmUserSubscription instanceof DataObject\Subscription) {
  2082.                     //     $accessWRSIds = [];
  2083.                     //     $accessWRSApiGroups = new DataObject\APIGroup\Listing();
  2084.                     //     $accessWRSApiGroups->setCondition("groupName LIKE ?", ["weather_report%"]);
  2085.                     //     foreach ($accessWRSApiGroups as $Wrsgroup) {
  2086.                     //         $accessWRSIds[] = $Wrsgroup->getId();
  2087.                     //     }
  2089.                     //     $accessEWSIds = [];
  2090.                     //     $accessEWSApiGroups = new DataObject\APIGroup\Listing();
  2091.                     //     $accessEWSApiGroups->setCondition("groupName LIKE ?", ["ews_alert%"]);
  2092.                     //     foreach ($accessEWSApiGroups as $Ewsgroup) {
  2093.                     //         $accessEWSIds[] = $Ewsgroup->getId();
  2094.                     //     }
  2096.                     //     $matchedEWS = array_intersect($allowedApiGroups, $accessEWSIds);
  2097.                     //     $matchedWRS = array_intersect($allowedApiGroups, $accessWRSIds);
  2099.                     //     if ($matchedEWS) {
  2100.                     //         $ncmEwsUser = $this->ewsPortalModel->addNcmUser([
  2101.                     //             'name' => $fullName,
  2102.                     //             'email' => $email,
  2103.                     //             'role' => $role,
  2104.                     //             'allowedApiGroups' => $allowedApiGroups,
  2105.                     //             'hostName' => $hostName,
  2106.                     //             'isNoExpiry' => $isNoExpiry,
  2107.                     //             'phone' => $phone,
  2108.                     //             'password' => $password,
  2109.                     //         ]);
  2110.                     //     }
  2111.                     //     if ($matchedWRS) {
  2112.                     //         $ncmReportingUser = $this->reportingPortalModel->addNcmUser([
  2113.                     //             'name' => $fullName,
  2114.                     //             'email' => $email,
  2115.                     //             'role' => $role,
  2116.                     //             'allowedApiGroups' => $allowedApiGroups,
  2117.                     //             'hostName' => $hostName,
  2118.                     //             'isNoExpiry' => $isNoExpiry,
  2119.                     //             'phone' => $phone,
  2120.                     //             'password' => $password,
  2121.                     //         ]);
  2122.                     //     }
  2125.                     //     return ["success" => true, "message" => $translator->trans("user_created")];
  2126.                     // } else {
  2127.                     //     return ["success" => false, "message" => $translator->trans("user_subscription_not_created")];
  2128.                     // }
  2131.                 } else {
  2132.                     return $userResponse;
  2133.                 }
  2134.             } else {
  2135.                 return ["success" => false, "message" => $translator->trans("user_role_not_found")];
  2136.             }
  2137.         } else {
  2138.             return ["success" => false, "message" =>   $translator->trans("no_organization_is_associated_with_logged_in_user")];
  2139.         }
  2140.         // } catch (\Exception $ex) {
  2141.         //     $result = ["success" => false, "message" => $ex->getMessage()];
  2142.         // }
  2144.         return $result;
  2145.     }
  2146.     public function updateEntityStatus($params, $loggedInUser, $translator)
  2147.     {
  2148.         $ids = is_array($params['organization_id']) ? $params['organization_id'] : [$params['organization_id']];
  2149.         $entityStatus = $params['entity_status'] ?? null;
  2150.         $trialLimit   = $params['trialLimit'] ?? null;
  2152.         if (!$entityStatus) {
  2153.             return [
  2154.                 'success' => false,
  2155.                 'message' => $translator->trans("invalid_entity_status"),
  2156.             ];
  2157.         }
  2159.         $userRole = $loggedInUser->getRole()->getName();
  2160.         if (!in_array($userRole, [USER_ROLES['NCM_IT'], USER_ROLES['NCM_OPERATOR']])) {
  2161.             return [
  2162.                 'success' => false,
  2163.                 'message' => $translator->trans("%s_has_not_permission_change_entity_status", [
  2164.                     '%s' => $userRole,
  2165.                 ]),
  2166.             ];
  2167.         }
  2169.         $results = [];
  2170.         foreach ($ids as $orgId) {
  2171.             $organization = DataObject\Organization::getById($orgId);
  2172.             if (!$organization instanceof DataObject\Organization) {
  2173.                 $results[] = [
  2174.                     'id' => $orgId,
  2175.                     'success' => false,
  2176.                     'message' => $translator->trans("organization_does_not_exist"),
  2177.                 ];
  2178.                 continue;
  2179.             }
  2181.             if ($entityStatus === "trial" && !empty($trialLimit)) {
  2182.                 $organization->setPackageActivationDate(Carbon::now());
  2183.                 $organization->setTrialLimit($trialLimit);
  2184.             }
  2186.             $organization->setStatus($entityStatus);
  2187.             $organization->save();
  2189.             $results[] = [
  2190.                 'id' => $orgId,
  2191.                 'success' => true,
  2192.                 'message' => $translator->trans("entity_status_updated"),
  2193.             ];
  2194.         }
  2196.         if (!is_array($params['organization_id'])) {
  2197.             $single = $results[0] ?? [
  2198.                 'success' => false,
  2199.                 'message' => $translator->trans("unknown_error"),
  2200.             ];
  2201.             return [
  2202.                 'success' => $single['success'],
  2203.                 'message' => $single['message'],
  2204.             ];
  2205.         }
  2207.         $successCount = 0;
  2208.         $failedCount = 0;
  2209.         foreach ($results as $r) {
  2210.             if (!empty($r['success'])) {
  2211.                 $successCount++;
  2212.             } else {
  2213.                 $failedCount++;
  2214.             }
  2215.         }
  2217.         return [
  2218.             'success' => true,
  2219.             'processed' => $successCount,
  2220.             'failed' => $failedCount,
  2221.             'results' => $results,
  2222.             'message' => sprintf("%s: %d", $translator->trans("entity_status_updated"), $successCount),
  2223.         ];
  2224.     }
  2226.     public function updateEntitySmsConfig($request, $params, $translator)
  2227.     {
  2228.         $ids = is_array($params['organizationId']) ? $params['organizationId'] : [$params['organizationId']];
  2230.         $results = [];
  2231.         foreach ($ids as $orgId) {
  2232.             $organization = DataObject\Organization::getById($orgId,);
  2234.             if (!$organization instanceof DataObject\Organization) {
  2235.                 $results[] = ['id' => $orgId, 'success' => false, 'message' => $translator->trans("organization_does_not_exist")];
  2236.                 continue;
  2237.             }
  2238.             $organization->setIsSMSEnabled($params['isSmsEnabled']);
  2239.             $organization->save();
  2240.             $results[] = ['id' => $orgId, 'success' => true, 'message' => $translator->trans('sms_config_updated')];
  2241.         }
  2243.         if (!is_array($params['organizationId'])) {
  2244.             $single = $results[0] ?? ['success' => false, 'message' => $translator->trans('unknown_error')];
  2245.             return ['success' => $single['success'], 'message' => $single['message']];
  2246.         }
  2248.         $successCount = 0;
  2249.         foreach ($results as $r) {
  2250.             if (!empty($r['success'])) {
  2251.                 $successCount++;
  2252.             }
  2253.         }
  2254.         return ['success' => true, 'message' => sprintf("%s: %d", $translator->trans('sms_config_updated'), $successCount)];
  2255.     }
  2257.     public function renewEntitySMSConsumption($request, $params, $translator)
  2258.     {
  2259.         $ids = is_array($params['organizationId']) ? $params['organizationId'] : [$params['organizationId']];
  2261.         $results = [];
  2262.         foreach ($ids as $orgId) {
  2263.             $organization = DataObject\Organization::getById($orgId,);
  2265.             if (!$organization instanceof DataObject\Organization) {
  2266.                 $results[] = ['id' => $orgId, 'success' => false, 'message' => $translator->trans("organization_does_not_exist")];
  2267.                 continue;
  2268.             }
  2269.             $organization->setIsSMSEnabled(true);
  2270.             $organization->setSmsConsumption(0);
  2271.             $organization->save();
  2272.             $results[] = ['id' => $orgId, 'success' => true, 'message' => $translator->trans('sms_consumption_renewed')];
  2273.         }
  2275.         if (!is_array($params['organizationId'])) {
  2276.             $single = $results[0] ?? ['success' => false, 'message' => $translator->trans('unknown_error')];
  2277.             return ['success' => $single['success'], 'message' => $single['message']];
  2278.         }
  2280.         $successCount = 0;
  2281.         foreach ($results as $r) {
  2282.             if (!empty($r['success'])) {
  2283.                 $successCount++;
  2284.             }
  2285.         }
  2286.         return ['success' => true, 'message' => sprintf("%s: %d", $translator->trans('sms_consumption_renewed'), $successCount)];
  2287.     }
  2290.     public function bulkEntityAction($params, $packageModel, $user, $translator)
  2291.     {
  2293.         $actionType = $params['actionType'] ?? null;
  2294.         $entityIds = $params['entityIds'] ?? [];
  2295.         $payload = $params['payload'] ?? [];
  2296.         $processed = 0;
  2297.         foreach ($entityIds as $id) {
  2298.             $entity = DataObject\Organization::getById($id);
  2299.             if (!$entity instanceof DataObject\Organization) {
  2300.                 continue;
  2301.             }
  2303.             switch ($actionType) {
  2304.                 case 'update_status':
  2305.                     if (!empty($payload['status'])) {
  2306.                         $entity->setStatus($payload['status']); // Enum: Trial, Paid, Expired
  2307.                         $entity->save();
  2308.                         $processed++;
  2309.                     }
  2310.                     break;
  2312.                 case 'update_package':
  2313.                     if (!empty($payload['packageId'])) {
  2314.                         $package = DataObject\Package::getById($payload['packageId']);
  2315.                         if ($package instanceof DataObject\Package) {
  2316.                             $packageModel->updateEntityPackage($entity, $package, $translator);
  2317.                             $entity->setPackage($package);
  2318.                             $entity->save();
  2319.                             $processed++;
  2320.                         }
  2321.                     }
  2322.                     break;
  2324.                 case 'edit':
  2325.                     // Update fields dynamically (only safe editable fields!)
  2326.                     foreach ($payload as $field => $value) {
  2327.                         $setter = 'set' . ucfirst($field);
  2328.                         if (method_exists($entity, $setter)) {
  2329.                             $entity->$setter($value);
  2330.                         }
  2331.                     }
  2332.                     $entity->save();
  2333.                     $processed++;
  2334.                     break;
  2336.                 case 'soft_delete':
  2337.                     if ($this->getUserCountByEntity($entity) === 0) {
  2338.                         $entity->setIsDeleted(true); // Custom field
  2339.                         $entity->setDeletedBy($user);
  2340.                         $entity->setDeletedAt(Carbon::now());
  2341.                         $entity->setPublished(false);
  2342.                         $entity->save();
  2343.                         $processed++;
  2344.                     }
  2345.                     break;
  2346.             }
  2347.         }
  2349.         return [
  2350.             "success" => true,
  2351.             "processed" => $processed,
  2352.             "message" => $translator->trans("action_completed"),
  2353.         ];
  2354.     }
  2356.     private function calculatePackageExpiry($organization): ?string
  2357.     {
  2358.         try {
  2359.             $packageActivationDate = $organization->getPackageActivationDate();
  2360.             if (!$packageActivationDate) {
  2361.                 return null;
  2362.             }
  2364.             $trialLimit = $organization->getTrialLimit();
  2365.             if (!$trialLimit || $trialLimit <= 0) {
  2366.                 return null;
  2367.             }
  2368.             if (is_numeric($packageActivationDate)) {
  2369.                 $activationDate = new \DateTime();
  2370.                 $activationDate->setTimestamp($packageActivationDate);
  2371.             } else {
  2372.                 $activationDate = $packageActivationDate;
  2373.             }
  2374.             $expiryDate = clone $activationDate;
  2375.             $expiryDate->add(new \DateInterval('P' . $trialLimit . 'D'));
  2377.             return $expiryDate->format('Y-m-d H:i:s');
  2378.         } catch (\Exception $e) {
  2379.             return null;
  2380.         }
  2381.     }
  2383.     public function suspendEntity($loggedInUser, $params, $translator)
  2384.     {
  2385.         $ids = is_array($params['organization_id']) ? $params['organization_id'] : [$params['organization_id']];
  2387.         $userRole = $loggedInUser->getRole()->getName();
  2388.         if (!in_array($userRole, [USER_ROLES['NCM_IT'], USER_ROLES['NCM_OPERATOR']])) {
  2389.             return [
  2390.                 'success' => false,
  2391.                 'message' => $translator->trans("%s_has_not_permission_change_entity_status", [
  2392.                     '%s' => $userRole,
  2393.                 ]),
  2394.             ];
  2395.         }
  2397.         $results = [];
  2398.         foreach ($ids as $orgId) {
  2399.             $organization = DataObject\Organization::getById($orgId,);
  2400.             if (!$organization instanceof DataObject\Organization) {
  2401.                 $results[] = ['id' => $orgId, 'success' => false, 'message' => $translator->trans("organization_does_not_exist")];
  2402.                 continue;
  2403.             }
  2405.             $organization->setIsSuspend(true);
  2406.             $organization->save();
  2407.             $results[] = ['id' => $orgId, 'success' => true, 'message' => $translator->trans("entity_suspended")];
  2408.         }
  2410.         if (!is_array($params['organization_id'])) {
  2411.             $single = $results[0] ?? ['success' => false, 'message' => $translator->trans("unknown_error")];
  2412.             return ['success' => $single['success'], 'message' => $single['message']];
  2413.         }
  2415.         $successCount = 0;
  2416.         foreach ($results as $r) {
  2417.             if (!empty($r['success'])) {
  2418.                 $successCount++;
  2419.             }
  2420.         }
  2421.         return ['success' => true, 'message' => sprintf("%s: %d", $translator->trans("entity_suspended"), $successCount)];
  2422.     }
  2424.     public function resumeEntity($loggedInUser, $params, $translator)
  2425.     {
  2426.         $ids = is_array($params['organization_id']) ? $params['organization_id'] : [$params['organization_id']];
  2428.         $userRole = $loggedInUser->getRole()->getName();
  2429.         if (!in_array($userRole, [USER_ROLES['NCM_IT'], USER_ROLES['NCM_OPERATOR']])) {
  2430.             return [
  2431.                 'success' => false,
  2432.                 'message' => $translator->trans("%s_has_not_permission_change_entity_status", [
  2433.                     '%s' => $userRole,
  2434.                 ]),
  2435.             ];
  2436.         }
  2438.         $results = [];
  2439.         foreach ($ids as $orgId) {
  2440.             $organization = DataObject\Organization::getById($orgId,);
  2441.             if (!$organization instanceof DataObject\Organization) {
  2442.                 $results[] = ['id' => $orgId, 'success' => false, 'message' => $translator->trans("organization_does_not_exist")];
  2443.                 continue;
  2444.             }
  2446.             $organization->setIsSuspend(false);
  2447.             $organization->save();
  2448.             $results[] = ['id' => $orgId, 'success' => true, 'message' => $translator->trans("entity_resumed")];
  2449.         }
  2451.         if (!is_array($params['organization_id'])) {
  2452.             $single = $results[0] ?? ['success' => false, 'message' => $translator->trans("unknown_error")];
  2453.             return ['success' => $single['success'], 'message' => $single['message']];
  2454.         }
  2456.         $successCount = 0;
  2457.         foreach ($results as $r) {
  2458.             if (!empty($r['success'])) {
  2459.                 $successCount++;
  2460.             }
  2461.         }
  2462.         return ['success' => true, 'message' => sprintf("%s: %d", $translator->trans("entity_resumed"), $successCount)];
  2463.     }
  2464. }