src/Services/Common.php line 79

Open in your IDE?
  1. <?php
  3. namespace App\Services;
  5. use App\Config;
  6. use App\Entity\AdjustAppDetails;
  7. use App\Entity\AdvertiserAccountManager;
  8. use App\Entity\AdvertiserInfo;
  9. use App\Entity\AdvertiserTagRelationship;
  10. use App\Entity\AffiliateAccountManager;
  11. use App\Entity\AffiliateInfo;
  12. use App\Entity\AffiliateOfferApproval;
  13. use App\Entity\AffiliateOfferBlockLogs;
  14. use App\Entity\AffiliateTagRelationship;
  15. use App\Entity\MafoAffiliates;
  16. use App\Entity\AlertMeta;
  17. use App\Entity\AppInfo;
  18. use App\Entity\CommandLogger;
  19. use App\Entity\DeductionControl;
  20. use App\Entity\Employees;
  21. use App\Entity\MafoUserNotifications;
  22. use App\Entity\MmpAdvertisers;
  23. use App\Entity\MmpMobileApps;
  24. use App\Entity\ObjectMappingWithTuneWebAccount;
  25. use App\Entity\OfferCategories;
  26. use App\Entity\OfferCategoryRelationship;
  27. use App\Entity\OfferCreativeFile;
  28. use App\Entity\OfferGeoRelationship;
  29. use App\Entity\OfferGoalsInfo;
  30. use App\Entity\OfferInfo;
  31. use App\Entity\OfferTagRelationship;
  32. use App\Entity\OfferWhitelist;
  33. use App\Entity\SkadNetworkApiLogs;
  34. use App\Entity\SkadNetworkManualPostbackMapping;
  35. use App\Entity\SkadNetworkPostbackLogs;
  36. use App\Entity\Tag;
  37. use App\Entity\UserApiKey;
  38. use App\Entity\Users;
  39. use App\Entity\MafoAdvertisers;
  40. use App\Entity\MafoOffers;
  41. use App\Repository\AdvertiserAccountManagerRepository;
  42. use Aws\Credentials\Credentials;
  43. use Aws\S3\Exception\S3Exception;
  44. use Aws\Exception\MultipartUploadException;
  45. use Aws\S3\MultipartUploader;
  46. use Aws\S3\ObjectUploader;
  47. use Aws\S3\S3Client;
  48. use Doctrine\ORM\EntityManagerInterface;
  49. use PhpOffice\PhpSpreadsheet\IOFactory;
  50. use PhpOffice\PhpSpreadsheet\Spreadsheet;
  51. use Psr\Log\LoggerInterface;
  52. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  53. use Symfony\Component\Mercure\HubInterface;
  54. use Symfony\Component\Mercure\Update;
  55. use Twig\Environment;
  57. /**
  58.  *
  59.  * Common functions which are used throughout the project
  60.  *
  61.  * Class Common
  62.  * @package App\Services
  63.  */
  64. class Common
  65. {
  67.     private $em;
  68.     private $brandApi;
  69.     private $doctrine;
  70.     private $scraper;
  71.     private $elasticCache;
  72.     private $rootPath;
  73.     private $usersComponents;
  74.     private $mafoObjectsComponents;
  75.     private $hyperApis;
  76.     private LoggerInterface $logger;
  77.     private HubInterface $hub;
  79.     public function __construct(
  80.         MysqlQueries $em,
  81.         BrandHasofferAPI $brandApi,
  82.         EntityManagerInterface $doctrine,
  83.         Scraper $scraper,
  84.         Environment $templating,
  85.         Aws\ElasticCache $elasticCache,
  86.         ParameterBagInterface $params,
  87.         UsersComponents $usersComponents,
  88.         MafoObjectsComponents $mafoObjectsComponents,
  89.         HyperApis $hyperApis,
  90.         LoggerInterface $logger,
  91.         HubInterface $hub
  92.     ) {
  93.         $this->em = $em;
  94.         $this->brandApi = $brandApi;
  95.         $this->doctrine = $doctrine;
  96.         $this->scraper = $scraper;
  97.         $this->template = $templating;
  98.         $this->elasticCache = $elasticCache;
  99.         $this->rootPath = $params->get('kernel.project_dir');
  100.         $this->usersComponents = $usersComponents;
  101.         $this->mafoObjectsComponents = $mafoObjectsComponents;
  102.         $this->hyperApis = $hyperApis;
  103.         $this->logger = $logger;
  104.         $this->hub = $hub;
  105.     }
  107.     public function getAdvertisersListByStatusWithKeys($arr = [])
  108.     {
  109.         $statuses = isset($arr['statuses']) && sizeof($arr['statuses']) > 0 ? $arr['statuses'] : [Config::ACTIVE_STATUS];
  110.         $tuneAccount = isset($arr['tuneAccount']) ? $arr['tuneAccount'] : Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE;
  112.         $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HO_ADVERTISER_LIST_FOR_MULTISELECT . '_' . $tuneAccount);
  114.         if (!$cachedList || (count($statuses) == 1 && !in_array(Config::ACTIVE_STATUS, $statuses))) {
  115.             $advertiserList = $this->getWarmedUpHoAdvertiserList($statuses, $tuneAccount);
  116.         } else {
  117.             $advertiserList = json_decode($cachedList, true);
  118.         }
  120.         ksort($advertiserList);
  122.         return $advertiserList;
  123.     }
  125.     public function getWarmedUpHoAdvertiserList($statuses, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  126.     {
  127.         $advertiserList = [];
  128.         $advertiserData = $this->doctrine->getRepository(AdvertiserInfo::class)->getAdvertiserListByStatus($statuses, $tuneAccount  );
  130.         $employeesInfo = $this->getEmployeesByEmployeeId();
  132.         foreach ($advertiserData as $key => $value) {
  133.             $temp = [
  134.                 'status' => $value['status'],
  135.                 'name' => $value['company'],
  136.                 'accountManagerId' => $value['accountManagerId'],
  137.                 'accountManagerEmail' => null,
  138.                 'accountManagerName' => null,
  139.                 'id' => (int)$value['advertiserId']
  140.             ];
  141.             if (array_key_exists($value['accountManagerId'], $employeesInfo)) {
  142.                 $temp['accountManagerEmail'] = $employeesInfo[$value['accountManagerId']]['email'];
  143.                 $temp['accountManagerName'] = $employeesInfo[$value['accountManagerId']]['fullName'];
  144.             }
  146.             $advertiserList[$value['advertiserId']] = $temp;
  147.         }
  148.         return $advertiserList;
  149.     }
  151.     public function getAffiliateListByStatusWithKeys($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  152.     {
  153.         $statuses = [Config::ACTIVE_STATUS];
  155.         $tuneAccountCacheKey = Config::CACHE_REDIS_HO_AFFILIATE_LIST_FOR_MULTISELECT . '_' . $tuneAccount;  
  157.         $cachedList = $this->elasticCache->redisGet($tuneAccountCacheKey);
  159.         if (!$cachedList || (count($statuses) == 1 && !in_array(Config::ACTIVE_STATUS, $statuses))) {
  160.             $affiliateList = $this->getWarmedUpHoAffiliateList($statuses, $tuneAccount);
  161.         } else {
  162.             $affiliateList = json_decode($cachedList, true);
  163.         }
  165.         ksort($affiliateList);
  167.         return $affiliateList;
  168.     }
  170.     public function getPublisherAffiliateListByStatusWithKeys($statuses = [Config::ACTIVE_STATUS], $affiliateIds)
  171.     {
  172.         //        $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HO_AFFILIATE_LIST_FOR_MULTISELECT);
  173.         //
  174.         //        if (!$cachedList || (count($statuses) == 1 && !in_array(Config::ACTIVE_STATUS, $statuses))) {
  175.         //            $affiliateList = $this->getWarmedUpHoPublisherAffiliateList($statuses);
  176.         //        } else {
  177.         //            $affiliateList = json_decode($cachedList, true);
  178.         //        }
  180.         $affiliateList = $this->getWarmedUpHoPublisherAffiliateList($statuses, $affiliateIds);
  183.         ksort($affiliateList);
  185.         return $affiliateList;
  186.     }
  188.     public function getWarmedUpHoAffiliateList($statuses, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  189.     {
  190.         $affiliateList = [];
  191.         $affiliateData = $this->doctrine->getRepository(AffiliateInfo::class)->getAffiliateListByStatusArr($statuses, $tuneAccount);
  193.         $employeesInfo = $this->getEmployeesByEmployeeId();
  195.         foreach ($affiliateData as $key => $value) {
  196.             $temp = [
  197.                 'status' => $value['status'],
  198.                 'name' => $value['company'],
  199.                 'accountManagerId' => $value['accountManagerId'],
  200.                 'accountManagerEmail' => null,
  201.                 'accountManagerName' => null,
  202.                 'id' => (int)$value['affiliateId']
  203.             ];
  205.             if (array_key_exists($value['accountManagerId'], $employeesInfo)) {
  206.                 $temp['accountManagerEmail'] = $employeesInfo[$value['accountManagerId']]['email'];
  207.                 $temp['accountManagerName'] = $employeesInfo[$value['accountManagerId']]['fullName'];
  208.             }
  210.             $affiliateList[$value['affiliateId']] = $temp;
  211.         }
  212.         return $affiliateList;
  213.     }
  215.   
  217.     public function getWarmedUpHoPublisherAffiliateList(array $statuses, array $affiliateIds = [])
  218.     {
  219.         $affiliateList = [];
  221.         // Fetch affiliate data based on status
  222.         $affiliateData = $this->doctrine->getRepository(AffiliateInfo::class)->getAffiliateListByStatusArr($statuses);
  224.         // Get employee information
  225.         $employeesInfo = $this->getEmployeesByEmployeeId();
  227.         foreach ($affiliateData as $value) {
  228.             // Only process if the affiliateId is in the provided $affiliateIds array, or if $affiliateIds is empty
  229.             if (empty($affiliateIds) || in_array($value['affiliateId'], $affiliateIds)) {
  230.                 $temp = [
  231.                     'status' => $value['status'],
  232.                     'name' => $value['company'],
  233.                     'accountManagerId' => $value['accountManagerId'],
  234.                     'accountManagerEmail' => null,
  235.                     'accountManagerName' => null,
  236.                     'id' => (int)$value['affiliateId']
  237.                 ];
  239.                 // Check if account manager info is available
  240.                 if (array_key_exists($value['accountManagerId'], $employeesInfo)) {
  241.                     $temp['accountManagerEmail'] = $employeesInfo[$value['accountManagerId']]['email'];
  242.                     $temp['accountManagerName'] = $employeesInfo[$value['accountManagerId']]['fullName'];
  243.                 }
  245.                 // Add to affiliate list
  246.                 $affiliateList[$value['affiliateId']] = $temp;
  247.             }
  248.         }
  250.         return $affiliateList;
  251.     }
  254.     public function getWarmedUpHoPublisherMafoAffiliateList(array $statuses, array $affiliateIds = [])
  255.     {
  256.         $affiliateList = [];
  258.         // Fetch affiliate data based on status
  259.         $affiliateData = $this->doctrine->getRepository(MafoAffiliates::class)->getAffiliateListByStatusArr($statuses);
  261.         // Get employee information
  262.         $employeesInfo = $this->getEmployeesByEmployeeId();
  264.         foreach ($affiliateData as $value) {
  265.             // Only process if the affiliateId is in the provided $affiliateIds array, or if $affiliateIds is empty
  266.             if (empty($affiliateIds) || in_array($value['affiliateId'], $affiliateIds)) {
  267.                 $temp = [
  268.                     'status' => $value['status'],
  269.                     'name' => $value['name'],
  270.                     'accountManagerId' => $value['accountManagerId'],
  271.                     'accountManagerEmail' => null,
  272.                     'accountManagerName' => null,
  273.                     'id' => (int)$value['id']
  274.                 ];
  276.                 // Check if account manager info is available
  277.                 if (array_key_exists($value['accountManagerId'], $employeesInfo)) {
  278.                     $temp['accountManagerEmail'] = $employeesInfo[$value['accountManagerId']]['email'];
  279.                     $temp['accountManagerName'] = $employeesInfo[$value['accountManagerId']]['fullName'];
  280.                 }
  282.                 // Add to affiliate list
  283.                 $affiliateList[$value['id']] = $temp;
  284.             }
  285.         }
  287.         return $affiliateList;
  288.     }
  291.     public function getHyperClientCachedListByKeys()
  292.     {
  294.         $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HYPER_CLIENT_LIST);
  296.         if (!$cachedList) {
  297.             $clientList = $this->getHyperClientListByKeys();
  298.         } else {
  299.             $clientList = json_decode($cachedList, true);
  300.         }
  302.         return $clientList;
  303.     }
  305.     public function getHyperClientListByKeys()
  306.     {
  308.         $hyperData = $this->hyperApis->getHyperClientList();
  310.         $clientList = [];
  311.         if ($hyperData && isset($hyperData['Result']) && $hyperData['Result'] == 'Ok') {
  312.             foreach ($hyperData['ResultData']['Data'] as $key => $value) {
  315.                 $countryCode = null;
  316.                 foreach (Config::COUNTRIES as $k => $v) {
  317.                     if ($this->checkForString($value['Country'], $v['name'])) {
  318.                         $countryCode = $k;
  319.                         break;
  320.                     }
  321.                 }
  323.                 $value['countryCode'] = $countryCode;
  325.                 $clientList[$value['ClientNumber']] = $value;
  326.             }
  327.         }
  329.         $this->elasticCache->redisSet(Config::CACHE_REDIS_HYPER_CLIENT_LIST, json_encode($clientList));
  330.         return $clientList;
  331.     }
  334.     public function getHyperPublisherCachedListByKeys()
  335.     {
  337.         $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HYPER_PUBLISHER_LIST);
  339.         if (!$cachedList) {
  340.             $clientList = $this->getHyperPublisherListByKeys();
  341.         } else {
  342.             $clientList = json_decode($cachedList, true);
  343.         }
  345.         return $clientList;
  346.     }
  348.     public function getHyperPublisherListByKeys()
  349.     {
  351.         $hyperData = $this->hyperApis->getHyperPublisherInfo();
  353.         $clientList = [];
  354.         if ($hyperData && isset($hyperData['Result']) && $hyperData['Result'] == 'Ok') {
  355.             foreach ($hyperData['ResultData']['Data'] as $key => $value) {
  358.                 $countryCode = null;
  359.                 foreach (Config::COUNTRIES as $k => $v) {
  360.                     if ($this->checkForString($value['Country'], $v['name'])) {
  361.                         $countryCode = $k;
  362.                         break;
  363.                     }
  364.                 }
  366.                 $value['countryCode'] = $countryCode;
  368.                 $clientList[$value['SupplierNumber']] = $value;
  369.             }
  370.         }
  372.         
  373.         return $clientList;
  374.     }
  376.     public function getHyperAffiliateListByKeys()
  377.     {
  379.         $hyperData = $this->hyperApis->getHyperClientList();
  381.         $clientList = [];
  382.         if ($hyperData && isset($hyperData['Result']) && $hyperData['Result'] == 'Ok') {
  383.             foreach ($hyperData['ResultData']['Data'] as $key => $value) {
  386.                 $countryCode = null;
  387.                 foreach (Config::COUNTRIES as $k => $v) {
  388.                     if ($this->checkForString($value['Country'], $v['name'])) {
  389.                         $countryCode = $k;
  390.                         break;
  391.                     }
  392.                 }
  394.                 $value['countryCode'] = $countryCode;
  396.                 $clientList[$value['ClientNumber']] = $value;
  397.             }
  398.         }
  400.         $this->elasticCache->redisSet(Config::CACHE_REDIS_HYPER_CLIENT_LIST, json_encode($clientList));
  401.         return $clientList;
  402.     }
  405.     public function getMmpAdvertisersListWithKeys()
  406.     {
  407.         $advertisers = $this->doctrine->getRepository(MmpAdvertisers::class)->getMmpAdvertisers();
  409.         $data = [];
  410.         foreach ($advertisers as $key => $value) {
  411.             $data[$value['id']] = [
  412.                 'value' => $value['id'],
  413.                 'label' => $value['name']
  414.             ];
  415.         }
  416.         ksort($data);
  418.         return $data;
  419.     }
  422.     public function getAffiliateTagListByStatusWithKeys($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  423.     {
  424.         $tagsInDb = $this->doctrine->getRepository(Tag::class)->getTags(1, null, null, 1, $tuneAccount);
  425.         $tagList = [];
  426.         foreach ($tagsInDb as $key => $value) {
  427.             $tagList[$value['tagId']] = [
  428.                 'value' => $value['tagId'],
  429.                 'name' => $value['name']
  430.             ];
  431.         }
  432.         ksort($tagList);
  434.         return $tagList;
  435.     }
  437.     public function getOfferCategoriesListByStatusWithKeys($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  438.     {
  439.         $status = Config::ACTIVE_STATUS;
  440.         $offerCategoriesData = $this->doctrine->getRepository(OfferCategories::class)->getOfferCategoriesByStatus($status, $tuneAccount);
  441.         $offerCategoryList = [];
  442.         foreach ($offerCategoriesData as $key => $value) {
  443.             $offerCategoryList[$value['categoryId']] = [
  444.                 'name' => $value['name'],
  445.                 'id' => (int)$value['categoryId']
  446.             ];
  447.         }
  448.         ksort($offerCategoryList);
  450.         return $offerCategoryList;
  451.     }
  453.     public function getAdvertiserListByAdvertiserIdArr($advertiserIdArr, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  454.     {
  456.         $advertiserDataByAdvertiserId = [];
  458.         if ($advertiserIdArr) {
  459.             $advertiserInfo = $this->doctrine->getRepository(AdvertiserInfo::class)->getAdvertiserInfoByAdvertiserIdArr($advertiserIdArr, $tuneAccount);
  461.             foreach ($advertiserInfo as $key => $value) {
  462.                 $advertiserDataByAdvertiserId[$value['advertiserId']] = [
  463.                     'id' => (int)$value['advertiserId'],
  464.                     'name' => $value['company']
  465.                 ];
  466.             }
  467.         }
  469.         return $advertiserDataByAdvertiserId;
  470.     }
  472.     public function getGoalDisableLinkData($offerId)
  473.     {
  475.         $data = $this->em->getGoalDisableLinkData($offerId);
  477.         $distinctOfferIds = [];
  478.         foreach ($data as $key => $value) {
  479.             if (!in_array($value['offerId'], $distinctOfferIds)) {
  480.                 $distinctOfferIds[] = $value['offerId'];
  481.             }
  482.         }
  483.         $offerGoalsByOfferId = [];
  485.         if ($distinctOfferIds) {
  486.             $offerGoalData = $this->doctrine->getRepository(OfferGoalsInfo::class)->getGoalsDataByOfferIdArr($distinctOfferIds);
  488.             if ($offerGoalData) {
  489.                 foreach ($offerGoalData as $key => $value) {
  490.                     $offerGoalsByOfferId[$value['offerId']][] = $value['goalId'];
  491.                 }
  492.             }
  493.         }
  495.         $bifurcatedData = [];
  496.         foreach ($data as $key => $value) {
  497.             if (array_key_exists($value['offerId'], $offerGoalsByOfferId) && in_array($value['goalId'], $offerGoalsByOfferId[$value['offerId']])) {
  498.                 $bifurcatedData[$value['addedFrom']][] = $value;
  499.             }
  500.         }
  502.         return $bifurcatedData;
  503.     }
  505.     public function disableLink($offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $addedFrom, $advertiserId, $jsonMetaDataStr, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  506.     {
  507.         $disableLinkMd5 = $this->getDisableLinkMd5($offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $tuneAccount);
  508.         $md5Exist = $this->em->getDisableLinkByMd5($disableLinkMd5);
  509.         if (!$md5Exist) {
  510.             $data = $this->brandApi->saveOfferDisabledLink($offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $tuneAccount);
  511.             if ($data['response']['status'] === 1) {
  512.                 $this->em->insertToDisableLink($disableLinkMd5, $offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $addedFrom, $advertiserId, $jsonMetaDataStr);
  513.             }
  514.         }
  515.     }
  517.     public function getDisableLinkMd5($offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $trackingAccount = Config::TUNE_ACCOUNT_DEFAULT, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  518.     {
  520.         $trackingAccountStr = $trackingAccount == Config::TUNE_ACCOUNT_DEFAULT ? '' : Config::TUNE_ACCOUNT_WEB;
  521.         return md5($offerId . $affiliateId . $source . $affsub2 . $affSub3 . $affSub5 . $trackingAccountStr . $tuneAccount);
  522.     }
  524.     public function automaticDisableLinkData($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  525.     {
  527.         $automaticDisableLinkData = $this->em->getAutomaticDisableLinkData($tuneAccount);
  529.         $finalArr['byAdvertiser'] = [];
  530.         $finalArr['byAffiliate'] = [];
  531.         $finalArr['byOffer'] = [];
  532.         foreach ($automaticDisableLinkData as $key => $value) {
  534.             $value['tuneAccountPretty'] = Config::MAFO_SYSTEM_IDENTIFIER_PRETTY[$value['tuneAccount']];
  535.             $value['dateInserted'] = $value['dateInserted']->format('Y-m-d H:i:s');
  536.             if ($value['advertiserId']) {
  537.                 $finalArr['byAdvertiser'][] = $value;
  538.             }
  539.             if ($value['affiliateId']) {
  540.                 $finalArr['byAffiliate'][] = $value;
  541.             }
  542.             if ($value['offerId']) {
  543.                 $finalArr['byOffer'][] = $value;
  544.             }
  545.         }
  547.         return $finalArr;
  548.     }
  550.     public function deleteDisableLinkByMd5($md5, $id, $trackingAccount = Config::TUNE_ACCOUNT_DEFAULT)
  551.     {
  553.         $disableLink = $this->em->getDisableLinkByMd5($md5);
  555.         if ($disableLink) {
  556.             $offerId = $disableLink->getOfferId();
  557.             $affiliateId = $disableLink->getAffiliateId();
  558.             $source = $disableLink->getSource();
  559.             $affSub2 = $disableLink->getAffsub2();
  560.             $affSub3 = $disableLink->getAffsub3();
  561.             $affSub5 = $disableLink->getAffsub5();
  562.             $advertiserId = $disableLink->getAdvertiserId();
  563.             $addedFrom = $disableLink->getAddedFrom();
  564.             $meta = $disableLink->getMeta();
  565.             $wasInsertedOn = $disableLink->getDateInserted();
  566.             $trackingAccount = $disableLink->getTrackingAccount();
  567.             $strict = 0;
  569.             $disableLinkData = $this->brandApi->findDisableLink($offerId, $affiliateId, $source, $strict, $affSub2, $affSub3, $affSub5, $trackingAccount)['response']['data'];
  571.             foreach ($disableLinkData as $k => $v) {
  572.                 $this->brandApi->deleteDisableLink($k, $trackingAccount);
  573.             }
  575.             $this->em->deleteDisableLinkByMd5($md5);
  576.             //            Removing dump from mysql and added dump of DisableLinks to mongo
  577.             //            $this->em->insertToDisableLinkDump($md5, $offerId, $affiliateId, $source, $affSub2, $addedFrom, $advertiserId, $meta, $wasInsertedOn, $affSub3, $affSub5, $trackingAccount);
  578.         } else {
  579.             $this->brandApi->deleteDisableLink($id);
  580.         }
  581.     }
  583.     public function checkForNonIncentInString($string)
  584.     {
  585.         if ($this->checkForString($string, 'Non Incent') || $this->checkForString($string, 'NO Incent') || $this->checkForString($string, 'No-Incent') || $this->checkForString($string, 'Non-Incent') || $this->checkForString($string, 'NonIncent') || $this->checkForString($string, 'NoIncent') || $this->checkForString($string, 'No_Incent') || $this->checkForString($string, 'Non_Incent')) {
  586.             return true;
  587.         }
  589.         return false;
  590.     }
  593.     public function checkForString($superString, $checkString)
  594.     {
  595.         if (strpos(strtolower($superString), strtolower($checkString)) !== false) {
  596.             return true;
  597.         } else {
  598.             return false;
  599.         }
  600.     }
  602.     public function filterSource($source)
  603.     {
  604.         if ($this->checkForString($source, "_")) {
  605.             $source = explode("_", $source);
  606.             if (($source[0] == "" && $source[1] != "") || ($source[0] != "" && $source[1] == "") || ($source[0] == "" && $source[1] == "")) {
  607.                 $source = implode("_", $source);
  608.             } else {
  609.                 $source = $source[0];
  610.             }
  611.         }
  613.         return $source;
  614.     }
  616.     public function filterSourceByAffiliate($source, $affiliateId)
  617.     {
  618.         if ($affiliateId == 3467) {
  620.             $actualSource = $source;
  621.             if (substr($source, 0, 4) === "114_") {
  622.                 $actualSource = substr($source, 4);
  623.             }
  625.             return $actualSource;
  626.         }
  628.         return $source;
  629.     }
  631.     public function filterSourceByAffiliateAndLtr($source, $affiliateId, $clicks, $conversions)
  632.     {
  633.         if ($affiliateId == 3467) {
  635.             $actualSource = $source;
  636.             if (substr($source, 0, 4) === "114_") {
  637.                 $actualSource = substr($source, 4);
  638.             }
  640.             if ($conversions > 15 && (($conversions / $clicks) * 100 > 30)) {
  641.                 return $actualSource;
  642.             } else {
  643.                 return false;
  644.             }
  645.         }
  647.         return $source;
  648.     }
  650.     public function getBulkCapData()
  651.     {
  652.         $bulkData = $this->em->getBulkCapData();
  654.         foreach ($bulkData as $key => $value) {
  655.             $bulkData[$key]['affiliateOfferCapType'] = str_replace("_", " ", ucfirst($value['affiliateOfferCapType']));
  656.             $bulkData[$key]['dateInserted'] = $value['dateInserted']->format('Y-m-d H:s:i');
  657.         }
  659.         return $bulkData;
  660.     }
  662.     public function getBulkCapByAffiliateData()
  663.     {
  664.         $bulkData = $this->em->getBulkCapByAffiliateData();
  666.         foreach ($bulkData as $key => $value) {
  667.             $bulkData[$key]['affiliateOfferCapType'] = str_replace("_", " ", ucfirst($value['affiliateOfferCapType']));
  668.             $bulkData[$key]['dateInserted'] = $value['dateInserted']->format('Y-m-d H:s:i');
  669.         }
  671.         return $bulkData;
  672.     }
  674.     public function getAccountManagerInfoByTuneAdvertiserId($advertiserId, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  675.     {
  677.         $accountManagerInfo = $this->doctrine->getRepository(AdvertiserAccountManager::class)->getAdvertiserAccountManagerByAdvertiserId($advertiserId, $tuneAccount);
  679.         $email = Config::ALERT_RECIPIENT_DEFAULT_EMAIL;
  680.         $firstName = '';
  681.         $lastName = '';
  682.         if ($accountManagerInfo) {
  683.             $email = $accountManagerInfo->getEmail();
  684.             $firstName = $accountManagerInfo->getFirstName();
  685.             $lastName = $accountManagerInfo->getLastName();
  686.         }
  688.         return [
  689.             'emailId' => $email,
  690.             'firstName' => $firstName,
  691.             'lastName' => $lastName
  692.         ];
  693.     }
  695.     public function getAccountManagerInfoByMafoAdvertiserId($advertiserId)
  696.     {
  697.         $mafoAdvertiserInfo = $this->doctrine->getRepository(MafoAdvertisers::class)->findOneBy(['id' => $advertiserId]);
  699.         $email = Config::ALERT_RECIPIENT_DEFAULT_EMAIL;
  700.         $firstName = '';
  701.         $lastName = '';
  702.         if ($mafoAdvertiserInfo) {
  703.             $accountManagerInfo = $this->doctrine->getRepository(Users::class)->findOneBy(['email' => $mafoAdvertiserInfo->getAccountManagerEmail()]);
  704.             $email = $mafoAdvertiserInfo->getAccountManagerEmail();
  705.             $name = $accountManagerInfo->getName();
  706.             $nameArr = explode(" ", $name);
  707.             $firstName = $nameArr[0];
  708.             $lastName = $nameArr[1];
  709.         }
  711.         return [
  712.             'emailId' => $email,
  713.             'firstName' => $firstName,
  714.             'lastName' => $lastName
  715.         ];
  716.     }
  718.     public function getAccountManagerInfoByTuneAffiliateId($affiliateId, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  719.     {
  721.         $accountManagerInfo = $this->doctrine->getRepository(AffiliateAccountManager::class)->getAffiliateAccountManagerByAffiliateId($affiliateId, $tuneAccount);
  723.         $email = Config::ALERT_RECIPIENT_DEFAULT_EMAIL;
  724.         $firstName = '';
  725.         $lastName = '';
  726.         if ($accountManagerInfo) {
  727.             $email = $accountManagerInfo->getEmail();
  728.             $firstName = $accountManagerInfo->getFirstName();
  729.             $lastName = $accountManagerInfo->getLastName();
  730.         }
  732.         return [
  733.             'emailId' => $email,
  734.             'firstName' => $firstName,
  735.             'lastName' => $lastName
  736.         ];
  737.     }
  739.     public function getAccountManagerInfoByMafoAffiliateId($affiliateId)
  740.     {
  741.         $mafoAffiliateInfo = $this->doctrine->getRepository(MafoAffiliates::class)->findOneBy(['id' => $affiliateId]);
  743.         $email = Config::ALERT_RECIPIENT_DEFAULT_EMAIL;
  744.         $firstName = '';
  745.         $lastName = '';
  746.         if ($mafoAffiliateInfo) {
  747.             $accountManagerInfo = $this->doctrine->getRepository(Users::class)->findOneBy(['email' => $mafoAffiliateInfo->getAccountManagerEmail()]);
  748.             $email = $mafoAffiliateInfo->getAccountManagerEmail();
  749.             $name = $accountManagerInfo->getName();
  750.             $nameArr = explode(" ", $name);
  751.             $firstName = $nameArr[0];
  752.             $lastName = $nameArr[1];
  753.         }
  755.         return [
  756.             'emailId' => $email,
  757.             'firstName' => $firstName,
  758.             'lastName' => $lastName
  759.         ];
  760.     }
  762.     public function getAccountManagerInfoByAffiliateIdArrWithKeys($affiliateIdArr, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  763.     {
  765.         $accountManagerInfoDB = $this->doctrine->getRepository(AffiliateAccountManager::class)->getDataByAffiliateIds($affiliateIdArr, $tuneAccount );
  766.         $accountManagerInfo = [];
  768.         foreach ($accountManagerInfoDB as $key => $value) {
  769.             $accountManagerInfo[$value['affiliateId']] = $value;
  770.             $accountManagerInfo[$value['affiliateId']]['id'] = $value['employeeId'];
  771.             $accountManagerInfo[$value['affiliateId']]['name'] = $value['firstName'] . ' ' . $value['lastName'];
  772.         }
  774.         return $accountManagerInfo;
  775.     }
  777.     public function getAccountManagerInfoByOfferId($offerId)
  778.     {
  780.         $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->checkOfferIdExist($offerId);
  781.         return $this->getAccountManagerInfoByTuneAdvertiserId($offerInfo ? $offerInfo->getAdvertiserId() : null);
  782.     }
  784.     public function getDisableLinkLogs($affiliateIdArray, $offerIdArray, $sourceIdArray, $advertiserArray, $addedFromArr, $dateStart, $dateEnd, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  785.     {
  787.         $disableLinksMyMd5 = [];
  788.         $disableLinkData = [];
  789.         if (empty($addedFromArr) || in_array(Config::DISABLE_LINKS_FROM_HO_PANEL, $addedFromArr)) {
  791.             $disableLinkDataFromHO = $this->brandApi->findDisableLinksDyDateRange($offerIdArray, $affiliateIdArray, $sourceIdArray, [], $dateStart, $dateEnd, $tuneAccount)['response']['data']['data'];
  793.             $disableLinkData = [];
  794.             $md5Arr = [];
  795.             foreach ($disableLinkDataFromHO as $key => $value) {
  797.                 $md5 = $this->getDisableLinkMd5($value['OfferDisabledLink']['offer_id'], $value['OfferDisabledLink']['affiliate_id'], $value['OfferDisabledLink']['source'], Config::DEFAULT_AFF_SUB2, Config::DEFAULT_AFF_SUB3, Config::DEFAULT_AFF_SUB5, $tuneAccount);
  798.                 $disableLinkData[] = [
  799.                     'affiliateId' => $value['OfferDisabledLink']['affiliate_id'],
  800.                     'offerId' => $value['OfferDisabledLink']['offer_id'],
  801.                     'source' => $value['OfferDisabledLink']['source'],
  802.                     'advertiserId' => null,
  803.                     'dateInserted' => $value['OfferDisabledLink']['datetime'],
  804.                     'addedFrom' => null,
  805.                     'md5' => $md5,
  806.                     'tuneAccount' => $tuneAccount,
  807.                     'id' => $value['OfferDisabledLink']['id']
  808.                 ];
  810.                 $md5Arr[] = $md5;
  811.             }
  814.             if (!empty($md5Arr)) {
  815.                 $savedDisableLinkData = $this->em->getDisableLinksByMd5Arr($md5Arr);
  816.                 foreach ($savedDisableLinkData as $key => $value) {
  817.                     $disableLinksMyMd5[$value['md5']] = $value;
  818.                 }
  819.             }
  820.         } else {
  822.             $disableLinkData = $this->em->getDisableLinkLogs($affiliateIdArray, $offerIdArray, $advertiserArray, $sourceIdArray, $addedFromArr, $dateStart, $dateEnd);
  824.             foreach ($disableLinkData as $key => $value) {
  825.                 $disableLinksMyMd5[$value['md5']] = $value;
  826.                 $disableLinkData[$key]['dateInserted'] = $value['dateInserted']->format('Y-m-d H:i:s');
  827.             }
  828.         }
  831.         $distinctOfferIdArr = [];
  832.         $distinctAffiliateIdArr = [];
  834.         foreach ($disableLinkData as $key => $value) {
  836.             if (!in_array($value['offerId'], $distinctOfferIdArr)) {
  837.                 array_push($distinctOfferIdArr, $value['offerId']);
  838.             }
  840.             if (!in_array($value['affiliateId'], $distinctAffiliateIdArr)) {
  841.                 array_push($distinctAffiliateIdArr, $value['affiliateId']);
  842.             }
  844.             $disableLinkData[$key]['date_inserted'] = $value['dateInserted'];
  845.         }
  847.         $offerInfo = [];
  848.         if (!empty($distinctOfferIdArr)) {
  849.             $offerInfo = $this->getOfferInfoByKey($distinctOfferIdArr, $tuneAccount);
  850.         }
  852.         $advertiserList = $this->getAdvertisersListByStatusWithKeys([
  853.             'tuneAccount' => $tuneAccount
  854.         ]);
  855.         $affiliateList = $this->getAffiliateListByStatusWithKeys($tuneAccount);
  857.         foreach ($disableLinkData as $key => $value) {
  859.             if (!array_key_exists($value['offerId'], $offerInfo)) {
  860.                 unset($disableLinkData[$key]);
  861.                 continue;
  862.             }
  863.             $offerName = $offerInfo[$value['offerId']]['name'] ?? '';
  864.             $advertiserName = array_key_exists($offerInfo[$value['offerId']]['advertiserId'], $advertiserList) ? $advertiserList[$offerInfo[$value['offerId']]['advertiserId']]['name'] : '';
  865.             $advertiserId = $offerInfo[$value['offerId']]['advertiserId'] ?? '';
  866.             $affiliateName = array_key_exists($value['affiliateId'], $affiliateList) ? $affiliateList[$value['affiliateId']]['name'] : '';
  867.             $meta = [];
  868.             $addedFrom = Config::DISABLE_LINKS_FROM_HO_PANEL;
  870.             if (array_key_exists($value['md5'], $disableLinksMyMd5)) {
  871.                 $meta = json_decode($disableLinksMyMd5[$value['md5']]['meta'], true) != null ? json_decode($disableLinksMyMd5[$value['md5']]['meta'], true) : [];
  872.                 $addedFrom = $disableLinksMyMd5[$value['md5']]['addedFrom'];
  873.             }
  875.             if (
  876.                 (!empty($addedFromArr) && !in_array($addedFrom, $addedFromArr)) ||
  877.                 (sizeof($advertiserArray) && !in_array($advertiserId, $advertiserArray))
  878.             ) {
  879.                 unset($disableLinkData[$key]);
  880.                 continue;
  881.             }
  883.             $disableLinkData[$key]['affiliateName'] = $affiliateName;
  884.             $disableLinkData[$key]['advertiserName'] = $advertiserName;
  885.             $disableLinkData[$key]['advertiserId'] = $advertiserId;
  886.             $disableLinkData[$key]['offerName'] = $offerName;
  887.             $disableLinkData[$key]['addedFrom'] = $addedFrom;
  888.             $disableLinkData[$key]['meta'] = $meta;
  889.         }
  891.         return $disableLinkData;
  892.     }
  894.     public function createUpdateRetentionOptimisation($offerId, $goalId, $retentionRate, $minimumBudget, $sendAlert, $autoBlock, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  895.     {
  897.         $retentionOptimisationExist = $this->em->getRetentionOptimisationByParams($offerId, $goalId, $tuneAccount);
  899.         if ($retentionOptimisationExist) {
  900.             if ($sendAlert === null) {
  901.                 $sendAlert = $retentionOptimisationExist->getSendAlert();
  902.             }
  903.             if ($autoBlock === null) {
  904.                 $autoBlock = $retentionOptimisationExist->getAutoBlock();
  905.             }
  906.             $this->em->updateRetentionOptimisation($offerId, $goalId, $retentionRate, $minimumBudget, $sendAlert, $autoBlock, $tuneAccount);
  907.         } else {
  908.             $this->em->insertRetentionOptimisation($offerId, $goalId, $retentionRate, $minimumBudget, $sendAlert, $autoBlock, $tuneAccount);
  909.         }
  910.     }
  912.     public function getRetentionOptimisationData($offerId, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  913.     {
  915.         $retentionOptimisationData = $this->em->getRetentionOptimisation($offerId, $tuneAccount);
  917.         $distinctOfferIds = [];
  918.         foreach ($retentionOptimisationData as $key => $value) {
  919.             if (!in_array($value['offerId'], $distinctOfferIds)) {
  920.                 array_push($distinctOfferIds, $value['offerId']);
  921.             }
  922.         }
  926.         foreach ($retentionOptimisationData as $key => $value) {
  929.             // $retentionOptimisationData[$key]['offerName'] = $offerInfo[$value['offerId']]['name'] ?? "";
  930.             // $retentionOptimisationData[$key]['advertiserId'] = $offerInfo[$value['offerId']]['advertiserId'] ?? "";
  931.             // $retentionOptimisationData[$key]['advertiserName'] = $offerInfo[$value['offerId']]['Advertiser']['company'] ?? "";
  932.             // $retentionOptimisationData[$key]['advertiserName'] = array_key_exists($offerInfo[$value['offerId']]['advertiserId'], $advertiserList) ? $advertiserList[$offerInfo[$value['offerId']]['advertiserId']]['name'] : '';
  933.             // $retentionOptimisationData[$key]['goalName'] = $offerInfo[$value['offerId']]['Goal'][$value['goalId']]['name'] ?? "";
  934.             $retentionOptimisationData[$key]['dateInserted'] = $value['dateUpdated']->format("Y-m-d H:s:i");
  935.         }
  937.         return array_values($retentionOptimisationData);
  938.     }
  940.     public function changeCamelCaseToWords($camelCaseString)
  941.     {
  943.         return ucfirst(implode(" ", preg_split('/(?=[A-Z])/', $camelCaseString)));
  944.     }
  946.     public function setOfferAffiliateCap($affiliateId, $offerId, $affiliateOfferCapType, $capValue, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  947.     {
  948.         $capExist = $this->em->getCombinationFromAffiliateOfferCapping($affiliateId, $offerId, $affiliateOfferCapType, $tuneAccount);
  950.         if (!$capExist || ($capExist->getCapValue() != $capValue)) {
  951.             if ($capExist) {
  952.                 $this->em->deleteAffiliateOfferCapById($capExist->getId());
  953.             }
  955.             $hoResponse = $this->brandApi->setAffiliateOfferCap($affiliateId, $offerId, $affiliateOfferCapType, $capValue, $tuneAccount);
  957.             if ($hoResponse['response']['status'] == 1) {
  958.                 $this->em->insertToAffiliateOfferCap($affiliateId, $offerId, $affiliateOfferCapType, $capValue, $tuneAccount);
  959.             }
  960.         }
  961.     }
  963.     public function getImpressionOptimisationData()
  964.     {
  965.         $impressionOptimisations = $this->em->getActiveImpressionOptimisation();
  966.         foreach ($impressionOptimisations as $key => $value) {
  967.             $impressionOptimisations[$key]['dateUpdated'] = $value['dateUpdated']->format("Y-m-d H:s:i");
  968.             $impressionOptimisations[$key]['dateInserted'] = $value['dateInserted']->format("Y-m-d H:s:i");
  969.         }
  971.         return $impressionOptimisations;
  972.     }
  974.     public function createUpdateImpressionOptimisation($offerId, $affiliate_id, $ctr, $addedBy)
  975.     {
  977.         return $this->em->createUpdateImpression($offerId, $affiliate_id, $ctr, $addedBy);
  978.     }
  980.     public function getFraudFlagLogs($affiliateIdArray, $offerIdArray, $advertiserArray, $dateStart, $dateEnd)
  981.     {
  984.         $fraudFlagData = [];
  986.         $fraudFlagData = $this->em->getFraudFlagLogs($affiliateIdArray, $offerIdArray, $advertiserArray, $dateStart, $dateEnd);
  988.         //                foreach ($fraudFlagData as $key => $value) {
  989.         //                    $fraudFlagData[$key]['dateInserted'] = $value['dateInserted']->format('Y-m-d H:i:s');
  990.         //                }
  991.         $distinctOfferIdArr = [];
  992.         $distinctAffiliateIdArr = [];
  994.         foreach ($fraudFlagData as $key => $value) {
  996.             if (!in_array($value['offerId'], $distinctOfferIdArr)) {
  997.                 array_push($distinctOfferIdArr, $value['offerId']);
  998.             }
  1000.             if (!in_array($value['affiliateId'], $distinctAffiliateIdArr)) {
  1001.                 array_push($distinctAffiliateIdArr, $value['affiliateId']);
  1002.             }
  1004.             $fraudFlagData[$key]['date_inserted'] = $value['dateInserted']->format('Y-m-d H:i:s');
  1005.         }
  1007.         if (!empty($distinctOfferIdArr)) {
  1008.             $offerInfo = $this->brandApi->getOffersByOfferIdsArr($distinctOfferIdArr)['response']['data'];
  1009.         }
  1010.         if (!empty($distinctAffiliateIdArr)) {
  1011.             $affiliateInfo = $this->brandApi->getAffiliatesByAffiliateIdArr($distinctAffiliateIdArr)['response']['data'];
  1012.         }
  1014.         foreach ($fraudFlagData as $key => $value) {
  1015.             $offerName = $offerInfo[$value['offerId']]['Offer']['name'] ?? '';
  1016.             $advertiserName = $offerInfo[$value['offerId']]['Advertiser']['company'] ?? '';
  1017.             $advertiserId = $offerInfo[$value['offerId']]['Advertiser']['id'] ?? '';
  1018.             $affiliateName = $affiliateInfo[$value['affiliateId']]['Affiliate']['company'] ?? '';
  1021.             $fraudFlagData[$key]['affiliateName'] = $affiliateName;
  1022.             $fraudFlagData[$key]['advertiserName'] = $advertiserName;
  1023.             $fraudFlagData[$key]['advertiserId'] = $advertiserId;
  1024.             $fraudFlagData[$key]['offerName'] = $offerName;
  1025.         }
  1027.         return $fraudFlagData;
  1028.     }
  1030.     public function deleteFraudFlagLogs($id)
  1031.     {
  1032.         $this->em->deleteFraudFlagLogs($id);
  1033.     }
  1035.     public function blockOfferForAffiliate($offerId, $affiliateId, $blockType, $blockedFrom, $conversions, $clicks, $ltr, $trackingAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  1036.     {
  1038.         $combinationExist = $this->doctrine->getRepository('App\Entity\AffiliateOfferBlock')->findOneBy([
  1039.             'offerId' => $offerId,
  1040.             'affiliateId' => $affiliateId,
  1041.             'trackingAccount' => $trackingAccount
  1042.         ]);
  1044.         $affiliateOfferBlockedInHO = $this->brandApi->getAffiliateOfferBlock($offerId, $affiliateId, $trackingAccount)['response']['data']['data'];
  1046.         if (array_key_exists($offerId, $affiliateOfferBlockedInHO) && $affiliateOfferBlockedInHO[$offerId]['OfferAffiliateBlock']['affiliate_id'] == $affiliateId && !$combinationExist) {
  1047.             return false;
  1048.         }
  1051.         if (!$combinationExist) {
  1052.             if ($blockType === Config::AFFILIATE_OFFER_BLOCK_MACRO) {
  1053.                 $hoResponse = $this->brandApi->blockOfferAffiliate($offerId, $affiliateId, $trackingAccount);
  1054.             } elseif ($blockType === Config::AFFILIATE_OFFER_UNBLOCK_MACRO) {
  1055.                 $hoResponse = $this->brandApi->unblockOfferAffiliate($offerId, $affiliateId, $trackingAccount);
  1056.             }
  1057.             if (isset($hoResponse['response']['status']) && $hoResponse['response']['status'] == 1) {
  1058.                 $this->doctrine->getRepository('App\Entity\AffiliateOfferBlock')->insertToOfferAffiliateBlock($offerId, $affiliateId, $blockType, $blockedFrom, $conversions, $clicks, $ltr, $trackingAccount);
  1060.                 //            Removing dump from mysql and added dump of AffiliateOfferBlock to mongo
  1061.                 //                $this->doctrine->getRepository('App\Entity\AffiliateOfferBlockLogs')->insertToOfferAffiliateBlockLogs($offerId, $affiliateId, $blockType, $blockedFrom, $conversions, $clicks, $ltr, $trackingAccount);
  1062.                 return true;
  1063.             }
  1064.         }
  1065.         return false;
  1066.     }
  1068.     public function deleteOfferAffiliateBlock($offerId, $affiliateId, $trackingAccount)
  1069.     {
  1071.         $hoResponse = $this->brandApi->unblockOfferAffiliate($offerId, $affiliateId, $trackingAccount);
  1072.         if ($hoResponse['response']['status'] == 1) {
  1073.             $this->doctrine->getRepository('App\Entity\AffiliateOfferBlock')->deleteOfferAffiliateBlock($offerId, $affiliateId, $trackingAccount);
  1074.         }
  1075.     }
  1077.     public function populateDbByOfferId($offerId, $metaData = [])
  1078.     {
  1079.         $calledFromCronJob = $metaData['calledFromCronJob'] ?? true;
  1080.         $tuneAccount = $metaData['tuneAccount'] ?? Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE;
  1082.         $offerExistInDB = $this->doctrine->getRepository('App\Entity\OfferInfo')->findOneBy([
  1083.             'offerId' => $offerId,
  1084.             'tuneAccount' => $tuneAccount
  1085.         ]);
  1086.         $offerInfo[$offerId] = $this->brandApi->getOfferByOfferId($offerId, $tuneAccount)['response']['data'];
  1087.         $offerIpWhitelistHoData = $this->brandApi->getIpWhitelistByOfferId($offerId, $tuneAccount)['response']['data'];
  1088.         $offerFileCreativesHoData = $this->brandApi->getOfferFilesByOfferId($offerId, $tuneAccount);
  1090.         $offerIpWhitelistArray = [];
  1091.         foreach ($offerIpWhitelistHoData as $key => $value) {
  1092.             if ($value['OfferWhitelist']['type'] == Config::OFFER_IP_WHITELIST_TYPE_POSTBACK) {
  1093.                 array_push($offerIpWhitelistArray, $value['OfferWhitelist']['content']);
  1094.             }
  1095.         }
  1097.         $offerCountryIdArray = isset($offerInfo[$offerId]['Country']) ? array_keys($offerInfo[$offerId]['Country']) : [];
  1098.         $offerCategoryIdArray = isset($offerInfo[$offerId]['OfferCategory']) ? array_keys($offerInfo[$offerId]['OfferCategory']) : [];
  1099.         $offerTagIdArray = isset($offerInfo[$offerId]['OfferTag']) ? array_keys($offerInfo[$offerId]['OfferTag']) : [];
  1101.         $offerGoalArray = isset($offerInfo[$offerId]['Goal']) ? array_values($offerInfo[$offerId]['Goal']) : [];
  1102.         foreach ($offerGoalArray as $key => $value) {
  1103.             foreach ($value as $k => $v) {
  1104.                 $offerGoalArray[$key][lcfirst(implode('', array_map('ucfirst', explode('_', $k))))] = $v;
  1105.                 if ($this->checkForString($k, '_')) {
  1106.                     unset($offerGoalArray[$key][$k]);
  1107.                 }
  1108.             }
  1109.         }
  1111.         if ($offerExistInDB) {
  1113.             $offerDataToUpdate = [];
  1114.             foreach ($offerInfo[$offerId]['Offer'] as $key => $value) {
  1115.                 $appId = $this->scraper->getAppId($offerInfo[$offerId]['Offer']['preview_url']);
  1116.                 if (!$appId) {
  1117.                     $appId = 'Not Found';
  1118.                 }
  1119.                 $offerDataToUpdate['appId'] = $appId;
  1120.                 $offerDataToUpdate[lcfirst(implode('', array_map('ucfirst', explode('_', $key))))] = $value;
  1121.             }
  1123.             $offerDataToUpdate['geoIdsJson'] = json_encode($offerCountryIdArray);
  1124.             $offerDataToUpdate['categoryIdsJson'] = json_encode($offerCategoryIdArray);
  1125.             $offerDataToUpdate['tagIdsJson'] = json_encode($offerTagIdArray);
  1126.             // $offerDataToUpdate['whitelistIpsJson'] = json_encode($offerIpWhitelistArray);
  1128.             if ($offerInfo[$offerId]['Thumbnail'] && isset($offerInfo[$offerId]['Thumbnail']['preview_uri'])) {
  1129.                 $offerDataToUpdate['thumbnail'] = $offerInfo[$offerId]['Thumbnail']['preview_uri'];
  1130.             }
  1132.             $this->doctrine->getRepository(OfferInfo::class)->updateOfferByOfferId($offerId, $offerDataToUpdate, $tuneAccount);
  1133.         } else {
  1135.             $offerValue = $offerInfo[$offerId];
  1137.             $domain = $offerInfo[$offerId]['Hostname']['domain'] ?? '';
  1139.             $appId = $this->scraper->getAppId($offerValue['Offer']['preview_url']);
  1140.             if (!$appId) {
  1141.                 $appId = 'Not Found';
  1142.             }
  1143.             $offerValue['Offer']['app_id'] = $appId;
  1144.             if (!$offerValue['Offer']['advertiser_id']) {
  1145.                 $offerValue['Offer']['advertiser_id'] = 0;
  1146.             }
  1147.             $this->doctrine->getRepository(OfferInfo::class)->insertToOfferInfo($offerValue['Offer']['id'], $offerValue['Offer']['advertiser_id'], $offerValue['Offer']['name'], $offerValue['Offer']['description'], $offerValue['Offer']['require_approval'], $offerValue['Offer']['preview_url'], $offerValue['Thumbnail']['preview_uri'] ?? null, $offerValue['Offer']['offer_url'], $offerValue['Offer']['currency'], $offerValue['Offer']['default_payout'], $offerValue['Offer']['payout_type'], $offerValue['Offer']['max_payout'], $offerValue['Offer']['revenue_type'], $offerValue['Offer']['status'], $offerValue['Offer']['redirect_offer_id'], $offerValue['Offer']['ref_id'], $offerValue['Offer']['conversion_cap'], $offerValue['Offer']['monthly_conversion_cap'], $offerValue['Offer']['payout_cap'], $offerValue['Offer']['monthly_payout_cap'], $offerValue['Offer']['revenue_cap'], $offerValue['Offer']['monthly_revenue_cap'], json_encode($offerCountryIdArray), json_encode($offerCategoryIdArray), $offerValue['Offer']['is_private'], $offerValue['Offer']['default_goal_name'], $offerValue['Offer']['note'], $offerValue['Offer']['has_goals_enabled'], $offerValue['Offer']['enforce_secure_tracking_link'], $offerValue['Offer']['enable_offer_whitelist'], $offerValue['Offer']['lifetime_conversion_cap'], $offerValue['Offer']['lifetime_payout_cap'], $offerValue['Offer']['lifetime_revenue_cap'], json_encode($offerTagIdArray), json_encode([]), $offerValue['Offer']['protocol'], $offerValue['Offer']['app_id'], $offerValue['Offer']['approve_conversions'], $domain, $tuneAccount);
  1148.         }
  1150.         $this->mafoObjectsComponents->createOrUpdateOffer($tuneAccount, $offerId);
  1152.         foreach ($offerGoalArray as $key => $value) {
  1153.             $goalExistInDB = $this->doctrine->getRepository(OfferGoalsInfo::class)->findOneBy(['goalId' => $value['id'], 'tuneAccount' => $tuneAccount]);
  1155.             if ($goalExistInDB) {
  1156.                 $this->doctrine->getRepository(OfferGoalsInfo::class)->updateGoalByGoalId($value['id'], $value, $tuneAccount);
  1157.             } else {
  1158.                 $this->doctrine->getRepository(OfferGoalsInfo::class)->insertToOfferGoalsInfo($value['id'], $offerId, $value['name'], $value['description'], $value['status'], $value['isPrivate'], $value['payoutType'], $value['defaultPayout'], $value['revenueType'], $value['maxPayout'], $value['tieredPayout'], $value['tieredRevenue'], $value['usePayoutGroups'], $value['useRevenueGroups'], $value['advertiserId'], $value['protocol'], $value['allowMultipleConversions'], $value['approveConversions'], $value['enforceEncryptTrackingPixels'], $value['isEndPoint'], $value['refId'], $tuneAccount);
  1159.             }
  1160.         }
  1162.         if ($calledFromCronJob) {
  1163.             $this->scraper->getAppDetailsByPreviewUrl($offerInfo[$offerId]['Offer']['preview_url']);
  1166.             if (is_array($offerTagIdArray)) {
  1167.                 $this->doctrine->getRepository(OfferTagRelationship::class)->deleteOfferTagRelationByOfferId($offerId, $tuneAccount);
  1168.                 foreach ($offerTagIdArray as $tagId) {
  1169.                     $this->doctrine->getRepository(OfferTagRelationship::class)->insertToOfferTagRelationship($offerId, $tagId, $tuneAccount);
  1170.                 }
  1171.             }
  1173.             if (is_array($offerCategoryIdArray)) {
  1174.                 $this->doctrine->getRepository(OfferCategoryRelationship::class)->deleteOfferCategoryRelationByOfferId($offerId, $tuneAccount);
  1175.                 foreach ($offerCategoryIdArray as $categoryId) {
  1176.                     $this->doctrine->getRepository(OfferCategoryRelationship::class)->insertToOfferCategoryRelationship($offerId, $categoryId, $tuneAccount);
  1177.                 }
  1178.             }
  1180.             if (is_array($offerCountryIdArray)) {
  1181.                 $this->doctrine->getRepository(OfferGeoRelationship::class)->deleteOfferGeoRelationByOfferId($offerId, $tuneAccount);
  1182.                 foreach ($offerCountryIdArray as $geo) {
  1183.                     $this->doctrine->getRepository(OfferGeoRelationship::class)->insertToOfferGeoRelationship($offerId, $geo, $tuneAccount);
  1184.                 }
  1185.             }
  1186.         }
  1188.         if (!$calledFromCronJob) {
  1190.             $offerWhitelistIdArrFromHO = [];
  1191.             foreach ($offerIpWhitelistHoData as $key => $value) {
  1192.                 $value = $value['OfferWhitelist'];
  1193.                 $value['tuneAccount'] = $tuneAccount;
  1195.                 $offerWhitelistExist = $this->doctrine->getRepository(OfferWhitelist::class)->findOneBy(['whitelistId' => $value['id'], 'tuneAccount' => $tuneAccount]);
  1197.                 if (!$offerWhitelistExist) {
  1198.                     $this->doctrine->getRepository(OfferWhitelist::class)->insertToOfferWhitelist($value['id'], $value['offer_id'], $value['type'], $value['content_type'], $value['content'], $tuneAccount);
  1199.                 } else {
  1200.                     $this->doctrine->getRepository(OfferWhitelist::class)->updateOfferWhitelistByWhitelistId($value['id'], $value, $tuneAccount);
  1201.                 }
  1202.                 array_push($offerWhitelistIdArrFromHO, $value['id']);
  1203.             }
  1205.             if (sizeof($offerWhitelistIdArrFromHO)) {
  1206.                 $offerWhitelistToBeDeleted = $this->doctrine->getRepository(OfferWhitelist::class)->getDeletedOfferWhitelistIds($offerId, $offerWhitelistIdArrFromHO, $tuneAccount);
  1207.                 foreach ($offerWhitelistToBeDeleted as $key => $value) {
  1208.                     $this->doctrine->getRepository(OfferWhitelist::class)->deleteByWhitelistId($value['whitelistId'], $tuneAccount);
  1209.                 }
  1210.             }
  1213.             foreach ($offerFileCreativesHoData as $key => $value) {
  1214.                 $fileExist = $this->doctrine->getRepository(OfferCreativeFile::class)->findOneBy(['fileId' => $key, 'tuneAccount' => $tuneAccount]);
  1215.                 if (isset($value['OfferFile'])) {
  1216.                     if (!$fileExist) {
  1217.                         $response = $value['OfferFile'];
  1218.                         if ($response['status'] == Config::DELETED_STATUS || $response['status'] == Config::PENDING_STATUS) {
  1219.                             continue;
  1220.                         }
  1221.                         $this->doctrine->getRepository(OfferCreativeFile::class)->insertToOfferCreativeFile($response['id'], $response['offer_id'], $response['display'], $response['filename'], $response['size'], $response['status'], $response['type'], $response['width'], $response['height'], $response['code'], $response['flash_vars'], $response['interface'], $response['account_id'], $response['is_private'], $response['url'], $response['preview_uri'], $response['thumbnail'], $tuneAccount);
  1222.                     } elseif ($fileExist->getStatus() != $value['OfferFile']['status']) {
  1223.                         $this->doctrine->getRepository(OfferCreativeFile::class)->updateStatusByFileId($value['OfferFile']['id'], $value['OfferFile']['status'], $tuneAccount);
  1224.                     }
  1225.                 }
  1226.             }
  1227.         }
  1228.     }
  1230.     public function updateOffer($offerId, $offerDetails, $offerCountries, $offerCategories, $offerTags, $offerWhitelistIps, $tuneAccount)
  1231.     {
  1232.         $offerCreateHoResponse = $this->brandApi->createOrUpdateOffer($offerId, $offerDetails, $tuneAccount);
  1234.         if ($offerCreateHoResponse['response']['status'] === 1) {
  1235.             $offerInfo = $offerCreateHoResponse['response']['data']['Offer'];
  1236.             $offerId = $offerInfo['id'];
  1238.             $this->doctrine->getRepository(OfferInfo::class)->updateOfferByOfferId($offerId, $offerDetails, $tuneAccount);
  1240.             $this->updateOfferCountries($offerId, $offerCountries, $tuneAccount);
  1241.             $this->updateOfferCategories($offerId, $offerCategories, $tuneAccount);
  1242.             $this->updateOfferTags($offerId, $offerTags, $tuneAccount);
  1243.             $this->updateOfferWhitelist($offerId, $offerWhitelistIps, $tuneAccount);
  1244.             $this->mafoObjectsComponents->createOrUpdateOffer($tuneAccount, $offerId);
  1245.         }
  1247.         return $offerCreateHoResponse;
  1248.     }
  1250.     public function createNewOffer($offerDetails, $offerCountries, $offerCategories, $offerTags, $offerWhitelistIps, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  1251.     {
  1253.         $offerCreateHoResponse = $this->brandApi->createOrUpdateOffer(null, $offerDetails, $tuneAccount);
  1255.         if ($offerCreateHoResponse['response']['status'] === 1) {
  1257.             $offerInfo = $offerCreateHoResponse['response']['data']['Offer'];
  1258.             $offerId = $offerInfo['id'];
  1260.             $appId = $this->scraper->getAppId($offerInfo['preview_url']);
  1261.             if (!$appId) {
  1262.                 $appId = 'Not Found';
  1263.             }
  1264.             $offerInfo['app_id'] = $appId;
  1266.             $this->doctrine->getRepository('App\Entity\OfferInfo')->insertToOfferInfo($offerId, $offerInfo['advertiser_id'], $offerInfo['name'], $offerInfo['description'], $offerInfo['require_approval'], $offerInfo['preview_url'], null, $offerInfo['offer_url'], $offerInfo['currency'], $offerInfo['default_payout'], $offerInfo['payout_type'], $offerInfo['max_payout'], $offerInfo['revenue_type'], $offerInfo['status'], $offerInfo['redirect_offer_id'], $offerInfo['ref_id'], $offerInfo['conversion_cap'], $offerInfo['monthly_conversion_cap'], $offerInfo['payout_cap'], $offerInfo['monthly_payout_cap'], $offerInfo['revenue_cap'], $offerInfo['monthly_revenue_cap'], '[]', '[]', $offerInfo['is_private'], $offerInfo['default_goal_name'], $offerInfo['note'], $offerInfo['has_goals_enabled'], $offerInfo['enforce_secure_tracking_link'], $offerInfo['enable_offer_whitelist'], $offerInfo['lifetime_conversion_cap'], $offerInfo['lifetime_payout_cap'], $offerInfo['lifetime_revenue_cap'], '[]', '[]', $offerInfo['protocol'], $offerInfo['app_id'], null, $offerDetails['trackingDomain'] ?? null, $tuneAccount);
  1268.             $this->updateOfferCountries($offerId, $offerCountries, $tuneAccount);
  1269.             $this->updateOfferCategories($offerId, $offerCategories, $tuneAccount);
  1270.             $this->updateOfferTags($offerId, $offerTags, $tuneAccount);
  1271.             $this->updateOfferWhitelist($offerId, $offerWhitelistIps, $tuneAccount);
  1272.             $this->mafoObjectsComponents->createOrUpdateOffer($tuneAccount, $offerId);
  1275.             $appDetails = $this->scraper->getAppDetailsByPreviewUrl($offerInfo['preview_url']);
  1277.             if ($appDetails) {
  1278.                 $fileResponse = $this->uploadFile($offerId, $appDetails['icon'], Config::FILE_TYPE_THUMBNAIL, 0);
  1279.                 if ($fileResponse['response']['status'] == 1) {
  1280.                     $this->doctrine->getRepository('App\Entity\OfferInfo')->updateOfferByOfferId($offerId, ['thumbnail' => $fileResponse['response']['data']['OfferFile']['url']], $tuneAccount);
  1281.                 }
  1282.             }
  1283.         }
  1285.         return $offerCreateHoResponse;
  1286.     }
  1288.     public function updateOfferCountries($offerId, $offerCountries, $tuneAccount)
  1289.     {
  1291.         $savedOfferInfo = $this->doctrine->getRepository('App\Entity\OfferInfo')->findOneBy(['offerId' => $offerId, 'tuneAccount' => $tuneAccount]);
  1292.         $savedGeos = json_decode($savedOfferInfo->getGeoIdsJson(), true);
  1293.         foreach ($savedGeos as $geo) {
  1294.             if (!in_array($geo, $offerCountries)) {
  1295.                 $this->brandApi->removeGeoFromOffer($offerId, $geo, $tuneAccount);
  1296.             }
  1297.         }
  1298.         foreach ($offerCountries as $geo) {
  1299.             $this->brandApi->addGeoToOffer($offerId, $geo, $tuneAccount);
  1300.         }
  1302.         $this->doctrine->getRepository('App\Entity\OfferInfo')->updateOfferByOfferId($offerId, ['geoIdsJson' => json_encode($offerCountries)], $tuneAccount);
  1303.     }
  1305.     public function updateOfferCategories($offerId, $offerCategories, $tuneAccount)
  1306.     {
  1307.         if (is_array($offerCategories) && count($offerCategories) > 0) {
  1308.             $this->brandApi->setCategoryToOffer($offerId, $offerCategories, $tuneAccount);
  1309.             $this->doctrine->getRepository('App\Entity\OfferInfo')->updateOfferByOfferId($offerId, ['categoryIdsJson' => json_encode($offerCategories)], $tuneAccount);
  1310.         }
  1311.     }
  1313.     public function updateOfferTags($offerId, $offerTags, $tuneAccount)
  1314.     {
  1315.         if (is_array($offerTags) && count($offerTags) > 0) {
  1316.             foreach ($offerTags as $tagId) {
  1317.                 $this->brandApi->addTagToOffer($offerId, $tagId, $tuneAccount);
  1318.             }
  1319.             $this->doctrine->getRepository('App\Entity\OfferInfo')->updateOfferByOfferId($offerId, ['tagIdsJson' => json_encode($offerTags)], $tuneAccount);
  1320.         }
  1321.     }
  1323.     public function updateOfferWhitelist($offerId, $offerWhitelistIps, $tuneAccount)
  1324.     {
  1325.         if (is_array($offerWhitelistIps) && count($offerWhitelistIps) > 0) {
  1326.             foreach ($offerWhitelistIps as $whitelistIp) {
  1327.                 $this->brandApi->addIpWhitelistToOffer($offerId, $whitelistIp, Config::OFFER_IP_WHITELIST_CONTENT_TYPE_IP_ADDRESS, Config::OFFER_IP_WHITELIST_TYPE_POSTBACK, $tuneAccount);
  1328.             }
  1329.             // echo json_encode($offerWhitelistIps);
  1330.             // $this->doctrine->getRepository('App\Entity\OfferInfo')->updateOfferByOfferId($offerId, ['whitelistIpsJson' => json_encode($offerWhitelistIps)], $tuneAccount);
  1331.         }
  1332.     }
  1334.     public function updateOfferGoal($goalId, $offerGoalDetails, $tuneAccount)
  1335.     {
  1337.         if (isset($offerGoalDetails['goal_id'])) {
  1338.             unset($offerGoalDetails['goal_id']);
  1339.         }
  1340.         $offerGoalCreateHoResponse = $this->brandApi->createOrUpdateOfferGoal($goalId, $offerGoalDetails, $tuneAccount);
  1342.         if ($offerGoalCreateHoResponse['response']['status'] === 1) {
  1343.             $dataToUpdate = [];
  1344.             foreach ($offerGoalCreateHoResponse['response']['data']['Goal'] as $key => $value) {
  1345.                 if ($key === 'id') {
  1346.                     continue;
  1347.                 }
  1348.                 $dataToUpdate[$this->convertStringFromSnakeCaseToCamelCase($key)] = $value;
  1349.             }
  1351.             $this->doctrine->getRepository(OfferGoalsInfo::class)->updateGoalByGoalId($goalId, $dataToUpdate, $tuneAccount);
  1352.         }
  1354.         return $offerGoalCreateHoResponse;
  1355.     }
  1358.     public function createNewOfferGoal($offerGoalDetails, $tuneAccount)
  1359.     {
  1360.         $offerGoalCreateHoResponse = $this->brandApi->createOrUpdateOfferGoal(null, $offerGoalDetails, $tuneAccount);
  1361.         if ($offerGoalCreateHoResponse['response']['status'] === 1) {
  1362.             $offerGoalCreateHoResponseData = $offerGoalCreateHoResponse['response']['data']['Goal'];
  1363.             $this->doctrine->getRepository(OfferGoalsInfo::class)->insertToOfferGoalsInfo(
  1364.                 $offerGoalCreateHoResponseData['id'],
  1365.                 $offerGoalCreateHoResponseData['offer_id'],
  1366.                 $offerGoalCreateHoResponseData['name'],
  1367.                 $offerGoalCreateHoResponseData['description'],
  1368.                 $offerGoalCreateHoResponseData['status'],
  1369.                 $offerGoalCreateHoResponseData['is_private'],
  1370.                 $offerGoalCreateHoResponseData['payout_type'],
  1371.                 $offerGoalCreateHoResponseData['default_payout'],
  1372.                 $offerGoalCreateHoResponseData['revenue_type'],
  1373.                 $offerGoalCreateHoResponseData['max_payout'],
  1374.                 $offerGoalCreateHoResponseData['tiered_payout'],
  1375.                 $offerGoalCreateHoResponseData['tiered_revenue'],
  1376.                 $offerGoalCreateHoResponseData['use_payout_groups'],
  1377.                 $offerGoalCreateHoResponseData['use_revenue_groups'],
  1378.                 $offerGoalCreateHoResponseData['advertiser_id'],
  1379.                 $offerGoalCreateHoResponseData['protocol'],
  1380.                 $offerGoalCreateHoResponseData['allow_multiple_conversions'],
  1381.                 $offerGoalCreateHoResponseData['approve_conversions'],
  1382.                 $offerGoalCreateHoResponseData['enforce_encrypt_tracking_pixels'],
  1383.                 $offerGoalCreateHoResponseData['is_end_point'],
  1384.                 $offerGoalCreateHoResponseData['ref_id'],
  1385.                 $tuneAccount
  1386.             );
  1387.         }
  1389.         return $offerGoalCreateHoResponse;
  1390.     }
  1392.     public function uploadFile($offerId, $fileUrlToUpload, $creativeType, $isPrivate)
  1393.     {
  1394.         $fileData = @file_get_contents($fileUrlToUpload);
  1395.         $fileExtension = pathinfo($fileUrlToUpload, PATHINFO_EXTENSION);
  1396.         $fileName = $fileExtension === '' ? $offerId . "_" . basename($fileUrlToUpload) . '.png' : $offerId . "_" . basename($fileUrlToUpload);
  1397.         file_put_contents($fileName, $fileData);
  1398.         $fileResponse = $this->brandApi->offerFileAPI($offerId, $creativeType, $fileName, $fileName, $isPrivate);
  1399.         unlink($fileName);
  1400.         return $fileResponse;
  1401.     }
  1403.     public function convertStringFromCamelCaseToSnakeCase($input)
  1404.     {
  1405.         preg_match_all('!([A-Z][A-Z0-9]*(?=$|[A-Z][a-z0-9])|[A-Za-z][a-z0-9]+)!', $input, $matches);
  1406.         $ret = $matches[0];
  1407.         foreach ($ret as &$match) {
  1408.             $match = $match == strtoupper($match) ? strtolower($match) : lcfirst($match);
  1409.         }
  1410.         return implode('_', $ret);
  1411.     }
  1413.     public function convertStringFromSnakeCaseToCamelCase($input)
  1414.     {
  1415.         return lcfirst(implode('', array_map('ucfirst', explode('_', $input))));
  1416.     }
  1418.     public function getScraper()
  1419.     {
  1420.         return $this->scraper;
  1421.     }
  1423.     public function getOfferListByOfferIdArr($offerIdArr)
  1424.     {
  1426.         $response = [];
  1428.         if ($offerIdArr) {
  1429.             $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->getOffersByOfferIdsArr($offerIdArr);
  1431.             foreach ($offerInfo as $key => $value) {
  1432.                 $response[$value['offerId']] = [
  1433.                     'id' => (int)$value['offerId'],
  1434.                     'name' => $value['name']
  1435.                 ];
  1436.             }
  1437.         }
  1439.         return $response;
  1440.     }
  1442.     public function checkOfferAffiliateCapping($offerId, $affiliateId, $goalId)
  1443.     {
  1445.         $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->getOfferDataByOfferId($offerId);
  1447.         if (!$offerInfo) {
  1448.             return false;
  1449.         }
  1451.         $conversionCapByOfferIdHOData = $this->brandApi->getCappingByOfferId($offerId)['response']['data'];
  1453.         $conversionCap = $offerInfo->getConversionCap();
  1454.         $payoutCap = $offerInfo->getPayoutCap();
  1455.         $revenueCap = $offerInfo->getRevenueCap();
  1457.         $monthlyConversionCap = $offerInfo->getMonthlyConversionCap();
  1458.         $monthlyPayoutCap = $offerInfo->getMonthlyPayoutCap();
  1459.         $monthlyRevenueCap = $offerInfo->getMonthlyRevenueCap();
  1461.         foreach ($conversionCapByOfferIdHOData as $key => $value) {
  1462.             if ($value['OfferConversionCap']['offer_id'] == $offerId && $value['OfferConversionCap']['affiliate_id'] == $affiliateId) {
  1464.                 $conversionCap = $value['OfferConversionCap']['conversion_cap'];
  1465.                 $payoutCap = $value['OfferConversionCap']['payout_cap'];
  1466.                 $revenueCap = $value['OfferConversionCap']['revenue_cap'];
  1468.                 $monthlyConversionCap = $value['OfferConversionCap']['monthly_conversion_cap'];
  1469.                 $monthlyPayoutCap = $value['OfferConversionCap']['monthly_payout_cap'];
  1470.                 $monthlyRevenueCap = $value['OfferConversionCap']['monthly_revenue_cap'];
  1472.                 break;
  1473.             }
  1474.         }
  1476.         $dailyConversionGenerated = 0;
  1477.         $dailyPayoutGenerated = 0;
  1478.         $dailyRevenueGenerated = 0;
  1480.         $monthlyConversionGenerated = 0;
  1481.         $monthlyPayoutGenerated = 0;
  1482.         $monthlyRevenueGenerated = 0;
  1484.         $statByDay = $this->brandApi->getStatsForCappingCheck($offerId, $affiliateId, $goalId, true, false)['response']['data']['data'];
  1486.         if (!empty($statByDay)) {
  1487.             $dailyConversionGenerated = $statByDay[0]['Stat']['conversions'];
  1488.             $dailyPayoutGenerated = $statByDay[0]['Stat']['payout'];
  1489.             $dailyRevenueGenerated = $statByDay[0]['Stat']['revenue'];
  1490.         }
  1492.         $statByMonth = $this->brandApi->getStatsForCappingCheck($offerId, $affiliateId, $goalId, false, true)['response']['data']['data'];
  1494.         if (!empty($statByMonth) && isset($statByDay[0])) {
  1495.             $monthlyConversionGenerated = $statByDay[0]['Stat']['conversions'];
  1496.             $monthlyPayoutGenerated = $statByDay[0]['Stat']['payout'];
  1497.             $monthlyRevenueGenerated = $statByDay[0]['Stat']['revenue'];
  1498.         }
  1500.         $conversionCapReached = $dailyConversionGenerated >= $conversionCap && $conversionCap != 0;
  1501.         $payoutCapReached = $dailyPayoutGenerated >= $payoutCap && $payoutCap != 0;
  1502.         $revenueCapReached = $dailyRevenueGenerated >= $revenueCap && $revenueCap != 0;
  1504.         $monthlyConversionCapReached = $monthlyConversionGenerated >= $monthlyConversionCap && $monthlyConversionCap != 0;
  1505.         $monthlyPayoutCapReached = $monthlyPayoutGenerated >= $monthlyPayoutCap && $monthlyPayoutCap != 0;
  1506.         $monthlyRevenueCapReached = $monthlyRevenueGenerated >= $monthlyRevenueCap && $monthlyRevenueCap != 0;
  1508.         $cappingReached = false;
  1509.         if ($conversionCapReached || $payoutCapReached || $revenueCapReached || $monthlyConversionCapReached || $monthlyPayoutCapReached || $monthlyRevenueCapReached) {
  1510.             $cappingReached = true;
  1511.         }
  1513.         return [
  1514.             'conversionCap' => $conversionCap,
  1515.             'payoutCap' => $payoutCap,
  1516.             'revenueCap' => $revenueCap,
  1517.             'monthlyConversionCap' => $monthlyConversionCap,
  1518.             'monthlyPayoutCap' => $monthlyPayoutCap,
  1519.             'monthlyRevenueCap' => $monthlyRevenueCap,
  1520.             'dailyConversionGenerated' => $dailyConversionGenerated,
  1521.             'dailyPayoutGenerated' => $dailyPayoutGenerated,
  1522.             'dailyRevenueGenerated' => $dailyRevenueGenerated,
  1523.             'monthlyConversionGenerated' => $monthlyConversionGenerated,
  1524.             'monthlyPayoutGenerated' => $monthlyPayoutGenerated,
  1525.             'monthlyRevenueGenerated' => $monthlyRevenueGenerated,
  1526.             'conversionCapReached' => $conversionCapReached,
  1527.             'payoutCapReached' => $payoutCapReached,
  1528.             'revenueCapReached' => $revenueCapReached,
  1529.             'monthlyConversionCapReached' => $monthlyConversionCapReached,
  1530.             'monthlyPayoutCapReached' => $monthlyPayoutCapReached,
  1531.             'monthlyRevenueCapReached' => $monthlyRevenueCapReached,
  1532.             'cappingReached' => $cappingReached
  1533.         ];
  1534.     }
  1537.     public function appsBlackAndWhiteList($data)
  1538.     {
  1540.         $dateRange = 30;
  1541.         $minClicks = 100;
  1542.         $dataToProcess = [];
  1544.         foreach ($data as $key => $value) {
  1545.             $value['offerId'] ? $dataToProcess['offer'][$value['offerId']][$value['param']][$value['listType']][] = $value['appId'] : false;
  1546.             $value['advertiserId'] ? $dataToProcess['advertiser'][$value['advertiserId']][$value['param']][$value['listType']][] = $value['appId'] : false;
  1547.             $value['affiliateId'] ? $dataToProcess['affiliate'][$value['affiliateId']][$value['param']][$value['listType']][] = $value['appId'] : false;
  1548.         }
  1550.         $dataToBlock = [];
  1551.         foreach ($dataToProcess as $entityType => $entity) {
  1552.             foreach ($entity as $entityId => $entityData) {
  1553.                 foreach ($entityData as $param => $paramData) {
  1555.                     $advertiserId = $entityType == 'advertiser' ? $entityId : null;
  1556.                     $affiliateId = $entityType == 'affiliate' ? $entityId : null;
  1557.                     $offerId = $entityType == 'offer' ? $entityId : null;
  1559.                     if ($advertiserId) {
  1560.                         $addedFrom = Config::DISABLE_LINK_FROM_APPS_BLACK_AND_WHITE_LIST_BY_ADVERTISER;
  1561.                     } elseif ($affiliateId) {
  1562.                         $addedFrom = Config::DISABLE_LINK_FROM_APPS_BLACK_AND_WHITE_LIST_BY_AFFILIATE;
  1563.                     } else {
  1564.                         $addedFrom = Config::DISABLE_LINK_FROM_APPS_BLACK_AND_WHITE_LIST_BY_OFFER;
  1565.                     }
  1567.                     if ($advertiserId == null && $affiliateId == null && $offerId == null) {
  1568.                         continue;
  1569.                     }
  1571.                     $statData = $this->brandApi->getStatsForAppBlackAndWhiteList($offerId, $affiliateId, $advertiserId, $dateRange, $minClicks, $param)['response']['data']['data'];
  1573.                     foreach ($paramData as $listType => $appIds) {
  1574.                         foreach ($statData as $key => $value) {
  1575.                             $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->findOneBy(['offerId' => $value['Stat']['offer_id']]);
  1576.                             if (
  1577.                                 !$offerInfo ||
  1578.                                 !in_array($offerInfo->getAppId(), $appIds)
  1579.                             ) {
  1580.                                 continue;
  1581.                             }
  1582.                             $temp = [
  1583.                                 'offerId' => $value['Stat']['offer_id'],
  1584.                                 'affiliateId' => $value['Stat']['affiliate_id'],
  1585.                                 'advertiserId' => $value['Stat']['advertiser_id'],
  1586.                                 'param' => $param,
  1587.                                 'paramValue' => $value['Stat'][$param],
  1588.                                 'clicks' => $value['Stat']['clicks'],
  1589.                                 'conversions' => $value['Stat']['conversions'],
  1590.                                 'addedFrom' => $addedFrom,
  1591.                                 'listType' => $listType
  1592.                             ];
  1594.                             if (array_key_exists('blacklist', $paramData) && in_array($value['Stat'][$param], $paramData['blacklist'])) {
  1595.                                 $dataToBlock[] = $temp;
  1596.                             }
  1598.                             if (array_key_exists('whitelist', $paramData) && !in_array($value['Stat'][$param], $paramData['whitelist'])) {
  1599.                                 $dataToBlock[] = $temp;
  1600.                             }
  1601.                         }
  1602.                     }
  1603.                 }
  1604.             }
  1605.         }
  1607.         return $dataToBlock;
  1608.     }
  1610.     public function setAffiliateOfferApproval($offerId, $affiliateId, $status, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  1611.     {
  1613.         $combinationExist = $this->doctrine->getRepository(AffiliateOfferApproval::class)->checkIfOfferApproved($offerId, $affiliateId, $tuneAccount);
  1615.         if ($combinationExist && $combinationExist->getApprovalStatus() != $status) {
  1616.             $hoResponse = $this->brandApi->setOfferApprovalForAffiliate($offerId, $affiliateId, $status, $tuneAccount);
  1617.             if ($hoResponse['response']['status'] == 1) {
  1618.                 $this->doctrine->getRepository(AffiliateOfferApproval::class)->updateAffiliateOfferApprovalById($combinationExist->getId(), [
  1619.                     'approvalStatus' => $status
  1620.                 ]);
  1621.             }
  1622.         } elseif (!$combinationExist) {
  1623.             $hoResponse = $this->brandApi->setOfferApprovalForAffiliate($offerId, $affiliateId, $status, $tuneAccount);
  1624.             if ($hoResponse['response']['status'] == 1) {
  1625.                 $this->doctrine->getRepository(AffiliateOfferApproval::class)->insertToAffiliateOfferApproval(null, $affiliateId, null, $offerId, null, null, null, $status, null, null, $tuneAccount);
  1626.             }
  1627.         }
  1628.     }
  1630.     public function disableLinkByExternalUrl($offerId, $advertiserId, $affiliateId, $source, $affSub2, $affSub3, $affSub5)
  1631.     {
  1633.         $stat = [
  1634.             'offerId' => $offerId,
  1635.             'advertiserId' => $advertiserId,
  1636.             'affiliateId' => $affiliateId,
  1637.             'source' => $source,
  1638.             'affSub2' => $affSub2,
  1639.             'affSub3' => $affSub3,
  1640.             'affSub5' => $affSub5
  1641.         ];
  1643.         $link = Config::DISABLE_LINK_EXTERNAL_ENDPOINT . '?token=' . base64_encode(json_encode($stat));
  1645.         return $link;
  1646.     }
  1648.     public function getOfferInfoByKey($offerIdArr, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  1649.     {
  1651.         if (!is_array($offerIdArr) || !sizeof($offerIdArr)) {
  1652.             return [];
  1653.         }
  1654.         $offerData = $this->doctrine->getRepository(OfferInfo::class)->getOffersByOfferIdsArr($offerIdArr, $tuneAccount);
  1655.         $offerInfo = [];
  1656.         foreach ($offerData as $key => $value) {
  1657.             $offerInfo[$value['offerId']] = $value;
  1658.         }
  1660.         return $offerInfo;
  1661.     }
  1663.     public function getMafoOfferInfoByKey($offerIdArr)
  1664.     {
  1666.         if (!is_array($offerIdArr) || !sizeof($offerIdArr)) {
  1667.             return [];
  1668.         }
  1669.         $offerData = $this->doctrine->getRepository(MafoOffers::class)->getMafoOffersByOfferIdsArr($offerIdArr);
  1670.         $offerInfo = [];
  1671.         foreach ($offerData as $key => $value) {
  1672.             $offerInfo[$value['id']] = $value;
  1673.         }
  1675.         return $offerInfo;
  1676.     }
  1678.     public function getEmployeesByEmployeeId()
  1679.     {
  1681.         $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HO_EMPLOYEES_LIST);
  1683.         if (!$cachedList) {
  1684.             $employeeList = $this->getWarmedUpEmployeesByEmployeeId();
  1685.         } else {
  1686.             $employeeList = json_decode($cachedList, true);
  1687.         }
  1689.         ksort($employeeList);
  1691.         return $employeeList;
  1692.     }
  1694.     public function getWarmedUpEmployeesByEmployeeId()
  1695.     {
  1697.         $employeesData = $this->doctrine->getRepository(Employees::class)->getEmployees();
  1698.         $data = [];
  1699.         foreach ($employeesData as $key => $value) {
  1700.             $data[$value['employeeId']] = [
  1701.                 'firstName' => $value['firstName'],
  1702.                 'lastName' => $value['lastName'],
  1703.                 'email' => $value['email'],
  1704.                 'fullName' => $value['fullName']
  1705.             ];
  1706.         }
  1708.         return $data;
  1709.     }
  1711.     public function getMd5ForMmpReport($advertiser, $offerCountry, $offerRegion, $offerCity, $appId, $event, $revenueModel, $payoutModel)
  1712.     {
  1714.         return md5(strtolower($advertiser) . '#' . strtolower($offerCountry) . '#' . strtolower($offerRegion) . '#' . strtolower($offerCity) . '#' . strtolower($appId) . '#' . strtolower($event) . '#' . strtolower($revenueModel) . '#' . strtolower($payoutModel));
  1715.     }
  1717.     public function updateAffiliateDBByIds($affiliateIds, $metaData)
  1718.     {
  1720.         $createApiKeyIfNotExist = $metaData['createApiKeyIfNotExist'] ?? false;
  1721.         $tuneAccount = $metaData['tuneAccount'] ?? Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE;
  1723.         $affiliateInfoArr = $this->brandApi->getAffiliateInfoByAffiliateIdsArr($affiliateIds, $tuneAccount)['response']['data'];
  1724.         foreach ($affiliateInfoArr as $key => $value) {
  1725.             $affiliateDBInfo = $this->doctrine->getRepository(AffiliateInfo::class)->findOneBy(['affiliateId' => $value['Affiliate']['id'], 'tuneAccount' => $tuneAccount]);
  1726.             if ($affiliateDBInfo) {
  1727.                 $this->doctrine->getRepository(AffiliateInfo::class)->updateAffiliateInfoByAffiliateId($value['Affiliate']['id'], [
  1728.                     'status' => $value['Affiliate']['status'],
  1729.                     'accountManagerId' => $value['AccountManager'] !== null ? $value['AccountManager']['id'] : null,
  1730.                     'company' => $value['Affiliate']['company']
  1731.                 ], $tuneAccount);
  1732.             } else {
  1733.                 $this->doctrine->getRepository(AffiliateInfo::class)->insertToAffiliateInfo($value['Affiliate']['id'], $value['Affiliate']['company'], $value['AccountManager'] !== null ? $value['AccountManager']['id'] : null, $value['Affiliate']['status'], $tuneAccount);
  1734.             }
  1736.             //            $this->mafoObjectsComponents->createOrUpdateAffiliate(Config::MAFO_SYSTEM_IDENTIFIER_TUNE, $value['Affiliate']['id']);
  1737.             //            $execCommand = "php " . $this->rootPath . "/bin/console app:updateCache " . Config::CACHE_REDIS_HO_AFFILIATE_LIST_FOR_MULTISELECT . " --env=prod > /dev/null &";
  1738.             //            exec($execCommand);
  1740.             if ($value['AffiliateUser'] !== null) {
  1741.                 foreach ($value['AffiliateUser'] as $k => $v) {
  1742.                     if ($v['status'] == Config::ACTIVE_STATUS) {
  1744.                         if ($createApiKeyIfNotExist) {
  1745.                             $apiKeyData = $this->doctrine->getRepository(UserApiKey::class)->findOneBy(['affiliateId' => $value['Affiliate']['id'], 'tuneAccount' => $tuneAccount]);
  1746.                             if (!$apiKeyData) {
  1747.                                 $this->brandApi->generateApiKeyByUserId($k, $tuneAccount);
  1748.                             }
  1749.                         }
  1751.                         $userApiData = $this->brandApi->getUserApiKey($k)['response']['data'];
  1752.                         if ($userApiData) {
  1754.                             $userApiKey = $this->doctrine->getRepository(UserApiKey::class)->findOneBy(['userId' => $k, 'tuneAccount' => $tuneAccount]);
  1755.                             if ($userApiKey) {
  1756.                                 $this->doctrine->getRepository(UserApiKey::class)->updateUserApiKeyByUserId($k, [
  1757.                                     'affiliateId' => $value['Affiliate']['id'],
  1758.                                     'userType' => $userApiData['user_type'],
  1759.                                     'apiKey' => $userApiData['api_key'],
  1760.                                     'apiKeyStatus' => $userApiData['status'],
  1761.                                     'userStatus' => $v['status']
  1762.                                 ], $tuneAccount);
  1763.                             } else {
  1764.                                 $this->doctrine->getRepository(UserApiKey::class)->insertToUserApiKey($value['Affiliate']['id'], $k, $userApiData['user_type'], $userApiData['api_key'], $userApiData['status'], $v['status'], $tuneAccount);
  1765.                             }
  1766.                         }
  1767.                     }
  1768.                 }
  1769.             }
  1771.             if ($value['AccountManager'] !== null) {
  1772.                 $affiliateAccountManagerDBInfo = $this->doctrine->getRepository(AffiliateAccountManager::class)->findOneBy(['affiliateId' => $value['Affiliate']['id'], 'tuneAccount' => $tuneAccount]);
  1774.                 if ($affiliateAccountManagerDBInfo) {
  1775.                     $this->doctrine->getRepository(AffiliateAccountManager::class)->updateDataByAffiliateId($value['Affiliate']['id'], [
  1776.                         'employeeId' => $value['AccountManager']['id'],
  1777.                         'email' => $value['AccountManager']['email'],
  1778.                         'firstName' => $value['AccountManager']['first_name'],
  1779.                         'lastName' => $value['AccountManager']['last_name'],
  1780.                         'status' => $value['AccountManager']['status'],
  1781.                     ], $tuneAccount);
  1782.                 } else {
  1783.                     $this->doctrine->getRepository(AffiliateAccountManager::class)->insertToAffiliateAccountManager($value['Affiliate']['id'], $value['AccountManager']['id'], $value['AccountManager']['email'], $value['AccountManager']['first_name'], $value['AccountManager']['last_name'], $value['AccountManager']['status'], $tuneAccount);
  1784.                 }
  1785.             }
  1787.             $affiliateTagRelationship = $this->brandApi->getAffiliateTagRelationByAffiliateId($value['Affiliate']['id'], $tuneAccount);
  1789.             if ($affiliateTagRelationship['response']['status'] == 1) {
  1790.                 $affiliateTags = [];
  1791.                 foreach ($affiliateTagRelationship['response']['data']['data'] as $k => $v) {
  1792.                     !in_array($v['AffiliatesTags']['tag_id'], $affiliateTags) ? array_push($affiliateTags, $v['AffiliatesTags']['tag_id']) : false;
  1793.                 }
  1794.                 $affiliateDBTagsData = $this->doctrine->getRepository(AffiliateTagRelationship::class)->getAffiliateTagRelationshipByAffiliateId($value['Affiliate']['id'], $tuneAccount);
  1795.                 $affiliateDBTags = [];
  1796.                 foreach ($affiliateDBTagsData as $k => $v) {
  1797.                     !in_array($v['tagId'], $affiliateDBTags) ? array_push($affiliateDBTags, $v['tagId']) : false;
  1798.                 }
  1800.                 if ($affiliateDBTags != $affiliateTags) {
  1801.                     $this->doctrine->getRepository(AffiliateTagRelationship::class)->deleteAffiliateTagRelationshipByAffiliateId($value['Affiliate']['id'], $tuneAccount);
  1802.                     foreach ($affiliateTags as $affiliateTag) {
  1803.                         $this->doctrine->getRepository(AffiliateTagRelationship::class)->insertToAffiliateTagRelationship($affiliateTag, $value['Affiliate']['id'], $tuneAccount);
  1804.                     }
  1805.                 }
  1806.             }
  1807.         }
  1808.     }
  1810.     public function updateAdvertiserDBById($advertiserId, $metaData, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  1811.     {
  1812.         $this->updateAdvertiserDBByIds([$advertiserId], $tuneAccount);
  1815.         if ($this->doctrine->getRepository(AdvertiserInfo::class)->findOneBy(['advertiserId' => $advertiserId, 'tuneAccount' => $tuneAccount])) {
  1816.             $advertiserDiscountType = $metaData['advertiserDiscountType'] ?? Config::ADVERTISER_DISCOUNT_TYPE_NO_DISCOUNT;
  1817.             $advertiserDiscountValue = $metaData['advertiserDiscountValue'] ?? null;
  1818.             if ($advertiserDiscountValue < 1 || $advertiserDiscountValue > 100) {
  1819.                 $advertiserDiscountType = Config::ADVERTISER_DISCOUNT_TYPE_NO_DISCOUNT;
  1820.                 $advertiserDiscountValue = null;
  1821.             }
  1822.             $this->doctrine->getRepository(AdvertiserInfo::class)->updateAdvertiserInfoByAdvertiserId($advertiserId, [
  1823.                 'discountValue' => $advertiserDiscountType !== Config::ADVERTISER_DISCOUNT_TYPE_NO_DISCOUNT ? $advertiserDiscountValue : 0,
  1824.                 'discountType' => $advertiserDiscountType,
  1825.             ], $tuneAccount);
  1826.         }
  1827.     }
  1829.     public function updateAdvertiserDBByIds($advertiserIds, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  1830.     {
  1832.         $advertiserInfoArr = $this->brandApi->getAdvertiserInfoByAdvertiserIdsArr($advertiserIds, $tuneAccount)['response']['data'];
  1834.         foreach ($advertiserInfoArr as $key => $value) {
  1835.             $advertiserDBInfo = $this->doctrine->getRepository(AdvertiserInfo::class)->findOneBy([
  1836.                 'advertiserId' => $value['Advertiser']['id'],
  1837.                 'tuneAccount' => $tuneAccount
  1838.             ]);
  1839.             if ($advertiserDBInfo) {
  1840.                 $this->doctrine->getRepository(AdvertiserInfo::class)->updateAdvertiserInfoByAdvertiserId($value['Advertiser']['id'], [
  1841.                     'status' => $value['Advertiser']['status'],
  1842.                     'accountManagerId' => $value['AccountManager'] !== null ? $value['AccountManager']['id'] : null,
  1843.                     'company' => $value['Advertiser']['company']
  1844.                 ], $tuneAccount);
  1845.             } else {
  1846.                 $this->doctrine->getRepository(AdvertiserInfo::class)->insertToAdvertiserInfo($value['Advertiser']['id'], $value['Advertiser']['company'], $value['AccountManager'] !== null ? $value['AccountManager']['id'] : null, $value['Advertiser']['status'], $tuneAccount);
  1847.             }
  1849.             // $this->mafoObjectsComponents->createOrUpdateAdvertiser(Config::MAFO_SYSTEM_IDENTIFIER_TUNE, $value['Advertiser']['id']);
  1850. //            $execCommand = "php " . $this->rootPath . "/bin/console app:updateCache " . Config::CACHE_REDIS_HO_ADVERTISER_LIST_FOR_MULTISELECT . " --env=prod > /dev/null &";
  1851. //            exec($execCommand);
  1853.             if ($value['AccountManager'] !== null) {
  1854.                 $affiliateAccountManagerDBInfo = $this->doctrine->getRepository(AdvertiserAccountManager::class)->findOneBy(['advertiserId' => $value['Advertiser']['id']]);
  1856.                 if ($affiliateAccountManagerDBInfo) {
  1857.                     $this->doctrine->getRepository(AdvertiserAccountManager::class)->updateDataByAdvertiserId($value['Advertiser']['id'], [
  1858.                         'employeeId' => $value['AccountManager']['id'],
  1859.                         'email' => $value['AccountManager']['email'],
  1860.                         'firstName' => $value['AccountManager']['first_name'],
  1861.                         'lastName' => $value['AccountManager']['last_name'],
  1862.                         'status' => $value['AccountManager']['status'],
  1863.                     ], $tuneAccount);
  1864.                 } else {
  1865.                     $this->doctrine->getRepository(AdvertiserAccountManager::class)->insertToAdvertiserAccountManager($value['Advertiser']['id'], $value['AccountManager']['id'], $value['AccountManager']['email'], $value['AccountManager']['first_name'], $value['AccountManager']['last_name'], $value['AccountManager']['status'], $tuneAccount);
  1866.                 }
  1867.             }
  1869.             $advertiserTagRelationship = $this->brandApi->getAdvertiserTagRelationByAdvertiserId($value['Advertiser']['id'], $tuneAccount);
  1871.             if ($advertiserTagRelationship['response']['status'] == 1) {
  1872.                 $advertiserTags = [];
  1873.                 foreach ($advertiserTagRelationship['response']['data']['data'] as $k => $v) {
  1874.                     !in_array($v['AdvertisersTags']['tag_id'], $advertiserTags) ? array_push($advertiserTags, $v['AdvertisersTags']['tag_id']) : false;
  1875.                 }
  1876.                 $advertiserDBTagsData = $this->doctrine->getRepository(AdvertiserTagRelationship::class)->getAdvertiserTagRelationshipByAdvertiserId($value['Advertiser']['id'], $tuneAccount);
  1877.                 $advertiserDBTags = [];
  1878.                 foreach ($advertiserDBTagsData as $k => $v) {
  1879.                     !in_array($v['tagId'], $advertiserDBTags) ? array_push($advertiserDBTags, $v['tagId']) : false;
  1880.                 }
  1882.                 if ($advertiserDBTags != $advertiserTags) {
  1883.                     $this->doctrine->getRepository(AdvertiserTagRelationship::class)->deleteAdvertiserTagRelationshipByAdvertiserId($value['Advertiser']['id'], $tuneAccount);
  1884.                     foreach ($advertiserTags as $advertiserTag) {
  1885.                         $this->doctrine->getRepository(AdvertiserTagRelationship::class)->insertToAdvertiserTagRelationship($advertiserTag, $value['Advertiser']['id'], $tuneAccount);
  1886.                     }
  1887.                 }
  1888.             }
  1889.         }
  1890.     }
  1892.     public function getEmployeesWithEmailAsKey()
  1893.     {
  1895.         $employeesData = $this->doctrine->getRepository(Employees::class)->getEmployees();
  1896.         $employees = [];
  1898.         foreach ($employeesData as $key => $value) {
  1899.             $employees[strtolower($value['email'])] = $value;
  1900.         }
  1902.         return $employees;
  1903.     }
  1905.     public function getNewsletterBuilderTemplate($offerIds, $introduction, $unsubscribeEmailId = '')
  1906.     {
  1908.         $offerInfoFromApi = [];
  1909.         if ($offerIds) {
  1910.             $offerInfoFromApi = $this->doctrine->getRepository(OfferInfo::class)->getOffersByOfferIdsArr($offerIds);
  1911.         }
  1913.         $offerInfoByOfferId = [];
  1914.         foreach ($offerIds as $offerId) {
  1915.             foreach ($offerInfoFromApi as $key => $value) {
  1916.                 if ($offerId == $value['offerId']) {
  1917.                     $value['geos'] = json_decode($value['geoIdsJson'], true);
  1918.                     $offerInfoByOfferId[] = $value;
  1919.                 }
  1920.             }
  1921.         }
  1923.         return $this->template->render('components/newsletterBuilder.html.twig', [
  1924.             'offerDetails' => $offerInfoByOfferId,
  1925.             'introduction' => $introduction,
  1926.             'unsubscribeLink' => "http://firehose.mobupps.com/api/unsubscribe/" . $unsubscribeEmailId
  1927.         ]);
  1928.     }
  1930.     public function getOfferGoalInfoByOfferGoalIdArrWithKeys($offerGoalIdArr)
  1931.     {
  1933.         $offerGoalData = $this->doctrine->getRepository(OfferGoalsInfo::class)->getGoalInfoByGoalIdArr($offerGoalIdArr);
  1934.         $data = [];
  1935.         foreach ($offerGoalData as $key => $value) {
  1936.             $data[$value['goalId']] = $value;
  1937.         }
  1939.         return $data;
  1940.     }
  1942.     public function getSkadNetworkMessageSeparator()
  1943.     {
  1944.         return mb_chr(Config::SKADNETWORK_MESSAGE_SEPARATOR_CODE);
  1945.     }
  1947.     public function setCommandLoggerData($identifier, $commandName, $meta)
  1948.     {
  1950.         $identifierExists = $this->doctrine->getRepository(CommandLogger::class)->findOneBy([
  1951.             'identifier' => $identifier
  1952.         ]);
  1954.         if (is_array($meta)) {
  1955.             $meta = json_encode($meta);
  1956.         }
  1958.         $currentTimestamp = strtotime('now');
  1960.         if (!$identifierExists) {
  1961.             $this->doctrine->getRepository(CommandLogger::class)->insertToCommandLogger($identifier, $commandName, $currentTimestamp, null, null, null);
  1962.         } else {
  1963.             $this->doctrine->getRepository(CommandLogger::class)->updateCommandLoggerById($identifierExists->getId(), [
  1964.                 'endTimestamp' => $currentTimestamp,
  1965.                 'timestampDiff' => $currentTimestamp - $identifierExists->getStartTimestamp(),
  1966.                 'meta' => $meta
  1967.             ]);
  1968.         }
  1969.     }
  1971.     public function getMafoUsersWithEmailIdAsKey()
  1972.     {
  1973.         $users = $this->doctrine->getRepository('App\Entity\Users')->getUsers();
  1975.         $arr = [];
  1976.         foreach ($users as $key => $value) {
  1977.             $name = explode(' ', $value['name']);
  1978.             $value['firstName'] = $name[0];
  1979.             $arr[$value['email']] = $value;
  1980.         }
  1982.         return $arr;
  1983.     }
  1984.     
  1986.     public function checkAlertMetaExists($identifier, $type)
  1987.     {
  1988.         $identifierExists = $this->doctrine->getRepository(AlertMeta::class)->findOneBy(['identifier' => $identifier]);
  1990.         if (!$identifierExists) {
  1991.             $this->doctrine->getRepository(AlertMeta::class)->insertToAlertMeta($identifier, $type);
  1992.             return false;
  1993.         } else {
  1994.             return true;
  1995.         }
  1996.     }
  1998.     public function getHourOffsetFromTimezoneString($timezone)
  1999.     {
  2000.         $hourOffset = '+0:00';
  2001.         if (array_key_exists($timezone, Config::TIMEZONES)) {
  2002.             $timezone = Config::TIMEZONES[$timezone];
  2003.             $timezone = explode(" ", $timezone)[0];
  2004.             $timezone = str_replace("(GMT", "", $timezone);
  2005.             $hourOffset = str_replace(")", "", $timezone);
  2006.         }
  2007.         return $hourOffset;
  2008.     }
  2011.     public function processPendingPostback($postbackLogId)
  2012.     {
  2014.         $postbackLogData = $this->doctrine->getRepository(SkadNetworkPostbackLogs::class)->findOneBy(['id' => $postbackLogId]);
  2015.         $endpoint = $postbackLogData->getEndpoint();
  2016.         $appId = $postbackLogData->getAppId();
  2017.         $campaignId = $postbackLogData->getCampaignId();
  2018.         $payload = json_decode($postbackLogData->getRequest(), true);
  2019.         $isAttributionSignatureValid = $postbackLogData->getIsAttributionSignatureValid();
  2020.         $postbackTimestamp = $postbackLogData->getDateInserted()->getTimestamp();
  2022.         $offerId = null;
  2023.         $affiliateId = null;
  2024.         $skadNetworkPostbackMappingExists = null;
  2025.         if ($endpoint == Config::SKADNETWORK_POSTBACK_ENDPOINT_WMADV) {
  2026.             $skadNetworkPostbackMappingExists = $this->doctrine->getRepository(SkadNetworkManualPostbackMapping::class)->findOneBy([
  2027.                 'appId' => $appId,
  2028.                 'campaignId' => $campaignId,
  2029.                 'isDeleted' => 0
  2030.             ]);
  2032.             if ($skadNetworkPostbackMappingExists) {
  2033.                 $offerId = $skadNetworkPostbackMappingExists->getOfferId();
  2034.                 $affiliateId = $skadNetworkPostbackMappingExists->getAffiliateId();
  2035.             }
  2036.         } else {
  2037.             $apiLogsData = $this->doctrine->getRepository(SkadNetworkApiLogs::class)->findOneBy(['appId' => $appId, 'campaignId' => $campaignId]);
  2038.             if ($apiLogsData) {
  2039.                 $offerId = $apiLogsData->getOfferId();
  2040.                 $affiliateId = $apiLogsData->getAffiliateId();
  2041.             }
  2042.         }
  2044.         $postbacksToMake = [];
  2045.         if ($isAttributionSignatureValid && $postbackLogData->getDidWin()) {
  2046.             if ($offerId) {
  2047.                 $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->findOneBy(['offerId' => $offerId]);
  2048.                 if ($offerInfo && $offerInfo->getSkadNetworkMmp() && in_array($offerInfo->getSkadNetworkMmp(), Config::SKADNETOWRK_MMP)) {
  2049.                     if ($offerInfo->getSkadNetworkMmp() == Config::SKADNETWORK_MMP_ADJUST && $offerInfo->getSkadNetworkAdjustTracker()) {
  2051.                         $offerGeoRelationship = $this->doctrine->getRepository(OfferGeoRelationship::class)->findOneBy(['offerId' => $offerInfo->getOfferId()]);
  2053.                         $postbackParams = [
  2054.                             'tracker' => $offerInfo->getSkadNetworkAdjustTracker(),
  2055.                             'sk_payload' => urlencode($payload),
  2056.                             'sk_ts' => strtotime('now')
  2057.                         ];
  2059.                         if ($offerGeoRelationship && $offerGeoRelationship->getGeo()) {
  2060.                             $postbackParams['country'] = strtolower($offerGeoRelationship->getGeo());
  2061.                         }
  2063.                         $postbacksToMake[] = [
  2064.                             'requestType' => Config::HTTP_METHOD_POST,
  2065.                             'requestUrl' => Config::SKADNETOWRK_MMP_POSTBACK_URL[$offerInfo->getSkadNetworkMmp()] . '?' . http_build_query($postbackParams),
  2066.                             'postbackForMmp' => true,
  2067.                             'skadNetworkMmp' => Config::SKADNETWORK_MMP_ADJUST
  2068.                         ];
  2069.                     } else if ($offerInfo->getSkadNetworkMmp() == Config::SKADNETWORK_MMP_BRANCH) {
  2070.                         $postbacksToMake[] = [
  2071.                             'requestType' => Config::HTTP_METHOD_POST,
  2072.                             'requestUrl' => Config::SKADNETOWRK_MMP_POSTBACK_URL[Config::SKADNETWORK_MMP_BRANCH],
  2073.                             'postbackForMmp' => true,
  2074.                             'skadNetworkMmp' => Config::SKADNETWORK_MMP_BRANCH
  2075.                         ];
  2076.                         if ($skadNetworkPostbackMappingExists) {
  2077.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerCampaignId()) {
  2078.                                 $payload['partner-campaign-id'] = $skadNetworkPostbackMappingExists->getBranchPartnerCampaignId();
  2079.                             }
  2080.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerCampaignName()) {
  2081.                                 $payload['partner-campaign-name'] = $skadNetworkPostbackMappingExists->getBranchPartnerCampaignName();
  2082.                             }
  2083.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerAdSetId()) {
  2084.                                 $payload['partner-ad-set-id'] = $skadNetworkPostbackMappingExists->getBranchPartnerAdSetId();
  2085.                             }
  2086.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerAdSetName()) {
  2087.                                 $payload['partner-ad-set-name'] = $skadNetworkPostbackMappingExists->getBranchPartnerAdSetName();
  2088.                             }
  2089.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerAdId()) {
  2090.                                 $payload['partner-ad-id'] = $skadNetworkPostbackMappingExists->getBranchPartnerAdId();
  2091.                             }
  2092.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerAdName()) {
  2093.                                 $payload['partner-ad-name'] = $skadNetworkPostbackMappingExists->getBranchPartnerAdName();
  2094.                             }
  2095.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerCreativeId()) {
  2096.                                 $payload['partner-creative-id'] = $skadNetworkPostbackMappingExists->getBranchPartnerCreativeId();
  2097.                             }
  2098.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerCreativeName()) {
  2099.                                 $payload['partner-creative-name'] = $skadNetworkPostbackMappingExists->getBranchPartnerCreativeName();
  2100.                             }
  2101.                         }
  2102.                     } else if ($offerInfo->getSkadNetworkMmp() == Config::SKADNETWORK_MMP_APPSFLYER) {
  2103.                         //                        $payload['ad-network-campaign-id'] = $campaignId . "";
  2104.                         //                        $payload['ad-network-campaign-name'] = $offerId . "";
  2105.                         //                        $payload['ad-network-country-code'] = implode(",", json_decode($offerInfo->getGeoIdsJson(), true));
  2106.                         //                        $payload['timestamp'] = $postbackTimestamp;
  2108.                         //                        if($affiliateId) {
  2109.                         //                            $payload['source-app-id'] = $affiliateId."";
  2110.                         //                            $payload['ad-network-source-app-id'] = $affiliateId."";
  2111.                         //                        }
  2113.                         $postbacksToMake[] = [
  2114.                             'requestType' => Config::HTTP_METHOD_POST,
  2115.                             'requestUrl' => Config::SKADNETOWRK_MMP_POSTBACK_URL[$offerInfo->getSkadNetworkMmp()],
  2116.                             'postbackForMmp' => true,
  2117.                             'skadNetworkMmp' => $offerInfo->getSkadNetworkMmp()
  2118.                         ];
  2119.                     } else {
  2120.                         $postbacksToMake[] = [
  2121.                             'requestType' => Config::HTTP_METHOD_POST,
  2122.                             'requestUrl' => Config::SKADNETOWRK_MMP_POSTBACK_URL[$offerInfo->getSkadNetworkMmp()],
  2123.                             'postbackForMmp' => true,
  2124.                             'skadNetworkMmp' => $offerInfo->getSkadNetworkMmp()
  2125.                         ];
  2126.                     }
  2127.                 }
  2128.             }
  2130.             if ($affiliateId) {
  2131.                 $affiliateInfo = $this->doctrine->getRepository(AffiliateInfo::class)->findOneBy(['affiliateId' => $affiliateId]);
  2132.                 if ($affiliateInfo && $affiliateInfo->getSkadNetworkPostbackUrl()) {
  2133.                     $postbacksToMake[] = [
  2134.                         'requestType' => Config::HTTP_METHOD_POST,
  2135.                         'requestUrl' => $affiliateInfo->getSkadNetworkPostbackUrl(),
  2136.                         'postbackForMmp' => false
  2137.                     ];
  2138.                 }
  2139.             }
  2141.             foreach ($postbacksToMake as $key => $value) {
  2143.                 $result = false;
  2144.                 if ($value['requestType'] == Config::HTTP_METHOD_POST) {
  2145.                     $postdata = json_encode($payload);
  2146.                     $ch = curl_init($value['requestUrl']);
  2147.                     curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
  2148.                     curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
  2149.                     curl_setopt($ch, CURLOPT_POST, 1);
  2150.                     curl_setopt($ch, CURLOPT_POSTFIELDS, $postdata);
  2151.                     curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  2152.                     curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
  2153.                     curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/json'));
  2154.                     $result = curl_exec($ch);
  2155.                     curl_close($ch);
  2156.                 } elseif ($value['requestType'] == Config::HTTP_METHOD_GET) {
  2157.                     $ch = curl_init($value['requestUrl']);
  2158.                     curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  2159.                     curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
  2160.                     curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/json'));
  2161.                     $result = curl_exec($ch);
  2162.                     curl_close($ch);
  2163.                 }
  2165.                 if ($result) {
  2166.                     if (array_key_exists('postbackForMmp', $value) && $value['postbackForMmp']) {
  2167.                         if (
  2168.                             array_key_exists('skadNetworkMmp', $value) &&
  2169.                             $value['skadNetworkMmp'] == Config::SKADNETWORK_MMP_BRANCH
  2170.                         ) {
  2171.                             $result = json_decode($result, true);
  2172.                             if (array_key_exists('id', $result)) {
  2173.                                 $this->doctrine->getRepository(SkadNetworkPostbackLogs::class)->updateSkadNetworkPostbackLogs($postbackLogId, [
  2174.                                     'isPostbackScheduledForMmp' => false,
  2175.                                     'branchPostbackId' => $result['id']
  2176.                                 ]);
  2177.                             }
  2178.                         } else if ($value['skadNetworkMmp'] == Config::SKADNETWORK_MMP_APPSFLYER) {
  2179.                             $this->doctrine->getRepository(SkadNetworkPostbackLogs::class)->updateSkadNetworkPostbackLogs($postbackLogId, [
  2180.                                 'isPostbackScheduledForMmp' => false
  2181.                             ]);
  2182.                         }
  2183.                     } else {
  2184.                         $this->doctrine->getRepository(SkadNetworkPostbackLogs::class)->updateSkadNetworkPostbackLogs($postbackLogId, [
  2185.                             'isPostbackScheduledForAffiliate' => false
  2186.                         ]);
  2187.                     }
  2188.                 }
  2189.             }
  2190.         }
  2191.     }
  2193.     public function getAppInfoByAppIdArrWithKeys($appIdArr)
  2194.     {
  2195.         $appData = [];
  2196.         if ($appIdArr) {
  2197.             $appData = $this->doctrine->getRepository(AppInfo::class)->getDataByAppIds($appIdArr);
  2198.         }
  2200.         $arr = [];
  2201.         foreach ($appData as $key => $value) {
  2202.             $arr[$value['appId']] = $value;
  2203.         }
  2205.         return $arr;
  2206.     }
  2208.     public function getAppInfoWithKeys($fromCache = true)
  2209.     {
  2210.         $arr = [];
  2211.         if ($fromCache) {
  2212.             $arr = $this->elasticCache->redisGet(Config::CACHE_REDIS_APP_INFO_KEY);
  2213.         }
  2215.         if (!$arr) {
  2216.             $appData = $this->doctrine->getRepository(AppInfo::class)->getAppIds();
  2218.             $arr = [];
  2219.             foreach ($appData as $key => $value) {
  2220.                 $arr[$value['appId']] = $value;
  2221.             }
  2222.         } else {
  2223.             $arr = json_decode($arr, true);
  2224.         }
  2226.         return $arr;
  2227.     }
  2229.     public function getDataFromJsonFile($jsonFileName)
  2230.     {
  2232.         $json = file_get_contents($this->rootPath . "/src/Resources/json/" . $jsonFileName . ".json");
  2234.         if (in_array($jsonFileName, [Config::JSON_FILE_FINANCIAL_TOOLS_GAP_CONTROL, Config::JSON_FILE_FINANCIAL_TOOLS_MAFO_GAP_CONTROL])) {
  2236.             $teamsByTeamId = $this->usersComponents->getTeamsByTeamId();
  2237.             $usersByTeamId = $this->usersComponents->getMafoUsersByTeamIds();
  2239.             $columnsData = json_decode($json, true);
  2240.             foreach ($usersByTeamId as $teamId => $users) {
  2241.                 if (sizeof($users)) {
  2242.                     $columnsData[$teamsByTeamId[$teamId]['label'] . 'Cost'] = [
  2243.                         'header' => $teamsByTeamId[$teamId]['label'] . ' Media Cost',
  2244.                         'accessor' => $teamsByTeamId[$teamId]['label'] . 'Cost',
  2245.                         'percentageWidth' => 5,
  2246.                         'show' => true,
  2247.                         'disabled' => false,
  2248.                         'customClass' => 'text-right',
  2249.                         'category' => 'statistics',
  2250.                         'footerEnabled' => true,
  2251.                         'aggregate' => 'sum',
  2252.                         //                        'alwaysEnabled' => true
  2253.                     ];
  2254.                 }
  2255.             }
  2257.             $itemsToBePushedToEnd = ['totalAffiliateCost', 'gap'];
  2258.             $arrToBePushedToEnd = [];
  2259.             foreach ($itemsToBePushedToEnd as $key => $value) {
  2260.                 $arrToBePushedToEnd[$value] = $columnsData[$value];
  2261.                 unset($columnsData[$value]);
  2262.             }
  2263.             $columnsData = array_merge($columnsData, $arrToBePushedToEnd);
  2265.             $json = json_encode($columnsData);
  2266.         }
  2268.         return json_decode($json, true);
  2269.     }
  2271.     public function changeColumnVisibilityForTable($tableColumns, $selectedColumns, $groupedColumns)
  2272.     {
  2273.         foreach ($tableColumns as $key => $value) {
  2274.             $tableColumns[$key]['show'] = false;
  2275.             foreach ($selectedColumns as $k => $v) {
  2276.                 if ($value['accessor'] === $k && $v !== 'undefined') {
  2277.                     $tableColumns[$key]['show'] = $v == '0' ? false : true;
  2278.                     break;
  2279.                 }
  2280.             }
  2281.             foreach ($groupedColumns as $k => $v) {
  2282.                 if ($value['accessor'] === $k && $v !== 'undefined') {
  2283.                     $tableColumns[$key]['groupBy'] = !($v == '0');
  2284.                     !($v == '0') ? $tableColumns[$key]['show'] = true : null;
  2285.                     break;
  2286.                 }
  2287.             }
  2288.         }
  2289.         return $tableColumns;
  2290.     }
  2292.     public function downloadCSV($tableColumns, $data, $reportNamePretty)
  2293.     {
  2295.         $reportName = str_replace(" ", "-", strtolower($reportNamePretty));
  2296.         $header = [];
  2297.         foreach ($tableColumns as $key => $value) {
  2298.             if ($value['show'] == 1) {
  2299.                 $headerValue = isset($value['Header']) ? $value['Header'] : (isset($value['header']) ? $value['header'] : null);
  2300.                 array_push($header, $headerValue);
  2301.             }
  2302.         }
  2304.         $rows = [$header];
  2305.         foreach ($data as $key => $value) {
  2306.             $row = [];
  2307.             foreach ($tableColumns as $k => $v) {
  2308.                 if ($v['show'] == 1) {
  2310.                     if ($v['accessor'] == 'comments' && is_array($value[$v['accessor']])) {
  2311.                         $comments = '';
  2312.                         foreach ($value[$v['accessor']] as $commentKey => $commentValue) {
  2313.                             $commentValue['comment'] = $commentValue['isDeleted'] ? "**This comment was deleted.**" : $commentValue['comment'];
  2314.                             $comments .= "{$commentValue['addedByName']} [{$commentValue['dateInserted']}]: {$commentValue['comment']}\n";
  2315.                         }
  2316.                         $value[$v['accessor']] = $comments;
  2317.                     } elseif ($v['accessor'] == 'attachedFiles') {
  2318.                         $value[$v['accessor']] = $value['linkToFile'];
  2319.                     } elseif (is_array($value[$v['accessor']])) {
  2320.                         $items = '';
  2321.                         if (array_key_exists('label', $value[$v['accessor']])) {
  2322.                             $items .= $value[$v['accessor']]['label'];
  2323.                         } else {
  2324.                             foreach ($value[$v['accessor']] as $kk => $vv) {
  2325.                                 if (array_key_Exists('label', $vv)) {
  2326.                                     $items .= $vv['label'] . "\n";
  2327.                                 }
  2328.                             }
  2329.                         }
  2330.                         $value[$v['accessor']] = $items;
  2331.                     }
  2334.                     array_push($row, $value[$v['accessor']]);
  2335.                 }
  2336.             }
  2337.             $rows[] = $row;
  2338.         }
  2340.         $spreadsheet = new Spreadsheet();
  2341.         $spreadsheet->getProperties()->setCreator('MAFO')->setLastModifiedBy('MAFO')->setTitle($reportNamePretty . ' Report')->setSubject($reportNamePretty)->setDescription($reportNamePretty);
  2343.         //        echo json_encode($rows);die;
  2344.         $spreadsheet->getActiveSheet()->fromArray($rows, null, 'A1');
  2346.         header('Content-Type: application/vnd.ms-excel');
  2347.         header('Content-Disposition: attachment;filename="' . $reportName . '.xls"');
  2348.         header('Cache-Control: max-age=0');
  2349.         $writer = IOFactory::createWriter($spreadsheet, 'Xls');
  2350.         $writer->save('php://output');
  2351.         exit;
  2352.     }
  2354.     public function getReportResponse($finalArr, $tableColumns, $limit, $page, $sortBy, $sortType)
  2355.     {
  2357.         foreach ($finalArr as $key => $value) {
  2358.             foreach ($tableColumns as $k => $v) {
  2359.                 if (isset($v['footerEnabled'])) {
  2360.                     if (!array_key_exists('Footer', $v)) {
  2361.                         $tableColumns[$k]['Footer'] = 0;
  2362.                     }
  2364.                     if (array_key_exists($v['accessor'], $value)) {
  2365.                         $tableColumns[$k]['Footer'] += $value[$v['accessor']];
  2366.                     }
  2367.                 }
  2368.             }
  2369.         }
  2371.         foreach ($tableColumns as $key => $value) {
  2372.             if (isset($value['footerEnabled']) && isset($value['Footer'])) {
  2373.                 $tableColumns[$key]['Footer'] = round($value['Footer'], 2);
  2374.             }
  2375.         }
  2377.         if (sizeof($finalArr)) {
  2378.             $entity = $finalArr[0];
  2379.             if (array_key_exists($sortBy, $entity)) {
  2380.                 $sortFlag = 3;
  2381.                 if ($sortType == Config::SORT_TYPE_ASC) {
  2382.                     $sortFlag = 4;
  2383.                 }
  2384.                 array_multisort(array_column($finalArr, $sortBy), $sortFlag, $finalArr);
  2385.             }
  2386.         }
  2388.         $offset = $limit * ($page - 1);
  2390.         $totalRecordCount = sizeof($finalArr);
  2391.         $noOfPages = ceil($totalRecordCount / $limit);
  2392.         $finalArr = array_slice($finalArr, $offset, $limit);
  2394.         return [
  2395.             'response' => [
  2396.                 'success' => true,
  2397.                 'httpStatus' => Config::HTTP_STATUS_CODE_OK,
  2398.                 'data' => [
  2399.                     'tableColumns' => $tableColumns,
  2400.                     'data' => $finalArr,
  2401.                     'metaData' => [
  2402.                         "total" => $totalRecordCount,
  2403.                         "limit" => $limit,
  2404.                         "page" => $page,
  2405.                         "pages" => $noOfPages
  2406.                     ]
  2407.                 ],
  2408.                 'error' => null
  2409.             ]
  2410.         ];
  2411.     }
  2413.     public function getDeductionForAdvertiserAndAffiliateForPeriod($offerId, $advertiserId, $affiliateId, $startDate, $endDate)
  2414.     {
  2415.         $totalDeduction = 0;
  2416.         $approvedDeduction = 0;
  2417.         if (
  2418.             $this->doctrine->getRepository(AdvertiserInfo::class)->findOneBy(['advertiserId' => $advertiserId]) &&
  2419.             $this->doctrine->getRepository(AffiliateInfo::class)->findOneBy(['affiliateId' => $affiliateId])
  2420.         ) {
  2421.             $deductionControlData = $this->doctrine->getRepository(DeductionControl::class)->getDeductionControlData($offerId ? [$offerId] : [], $advertiserId ? [$advertiserId] : [], $affiliateId ? [$affiliateId] : [], [], [], $startDate, $endDate, 0, []);
  2422.             foreach ($deductionControlData as $key => $value) {
  2423.                 $totalDeduction += $value['deductionValue'];
  2424.                 if ($value['status'] === Config::REVENUE_CONTROL_STATUS_APPROVED) {
  2425.                     $approvedDeduction += $value['deductionValue'];
  2426.                 }
  2427.             }
  2428.         }
  2430.         return [
  2431.             'advertiserId' => $advertiserId,
  2432.             'affiliateId' => $affiliateId,
  2433.             'totalDeduction' => round($totalDeduction, 2),
  2434.             'approvedDeduction' => round($approvedDeduction, 2),
  2435.         ];
  2436.     }
  2438.     public function getIndexedDeductionFromDeductionControlByAdvertiserAndAffiliate($startDate, $endDate)
  2439.     {
  2441.         $indexedDeduction = [];
  2443.         $deductionControlData = $this->doctrine->getRepository(DeductionControl::class)->getDeductionControlData([], [], [], [], [], $startDate, $endDate, 0, []);
  2445.         foreach ($deductionControlData as $key => $value) {
  2447.             $deductionPeriod = $value['deductionPeriod']->format('Y-m');
  2448.             if (!isset($indexedDeduction[$deductionPeriod])) {
  2449.                 $indexedDeduction[$deductionPeriod] = [];
  2450.             }
  2451.             if (!isset($indexedDeduction[$deductionPeriod][$value['advertiserId']])) {
  2452.                 $indexedDeduction[$deductionPeriod][$value['advertiserId']] = [];
  2453.             }
  2454.             if (!isset($indexedDeduction[$deductionPeriod][$value['advertiserId']][$value['affiliateId']])) {
  2455.                 $indexedDeduction[$deductionPeriod][$value['advertiserId']][$value['affiliateId']] = [
  2456.                     'advertiserId' => $value['advertiserId'],
  2457.                     'affiliateId' => $value['affiliateId'],
  2458.                     'totalDeduction' => 0,
  2459.                     'approvedDeduction' => 0
  2460.                 ];
  2461.             }
  2463.             $indexedDeduction[$deductionPeriod][$value['advertiserId']][$value['affiliateId']]['totalDeduction'] += $value['deductionValue'];
  2464.             if ($value['status'] === Config::REVENUE_CONTROL_STATUS_APPROVED) {
  2465.                 $indexedDeduction[$deductionPeriod][$value['advertiserId']][$value['affiliateId']]['approvedDeduction'] += $value['deductionValue'];
  2466.             }
  2467.         }
  2469.         return $indexedDeduction;
  2470.     }
  2472.     public function detectCSVDelimiter($csvFile)
  2473.     {
  2474.         $delimiters = [";" => 0, "," => 0, "\t" => 0, "|" => 0];
  2476.         $handle = fopen($csvFile, "r");
  2477.         $firstLine = fgets($handle);
  2478.         fclose($handle);
  2479.         foreach ($delimiters as $delimiter => &$count) {
  2480.             $count = count(str_getcsv($firstLine, $delimiter));
  2481.         }
  2483.         return array_search(max($delimiters), $delimiters);
  2484.     }
  2486.     public function assignTagsToOffers()
  2487.     {
  2488.         $activeOffers = $this->doctrine->getRepository(OfferInfo::class)->getOfferInfoByStatus(Config::ACTIVE_STATUS);
  2490.         foreach ($activeOffers as $key => $value) {
  2491.             if ($value['offerUrl']) {
  2492.                 foreach (Config::HASOFFER_TRACKING_LINK_KEYWORDS_BY_TAG_ID as $k => $v) {
  2493.                     if ($k == Config::HASOFFER_ADJUST_OFFER_TAG_ID) {
  2494.                         $adjustAppDetails = $this->doctrine->getRepository(AdjustAppDetails::class)->getAdjustAppDetails();
  2495.                         foreach ($adjustAppDetails as $kk => $vv) {
  2496.                             if (
  2497.                                 $this->checkForString($value['offerUrl'], $vv['appToken']) &&
  2498.                                 array_key_exists($vv['account'], Config::MMP_ADJUST_ACCOUNT_TUNE_TAG_MAPPING)
  2499.                             ) {
  2500.                                 $this->brandApi->addTagToOffer($value['offerId'], Config::MMP_ADJUST_ACCOUNT_TUNE_TAG_MAPPING[$vv['account']]);
  2501.                                 $this->populateDbByOfferId($value['offerId']);
  2502.                                 break 2;
  2503.                             }
  2504.                         }
  2505.                     } else {
  2506.                         foreach ($v as $subLink) {
  2507.                             if (
  2508.                                 isset($value['offerUrl']) &&
  2509.                                 $this->checkForString($value['offerUrl'], $subLink) &&
  2510.                                 !$this->doctrine->getRepository(OfferTagRelationship::class)->findOneBy(['tagId' => $k, 'offerId' => $value['offerId']])
  2511.                             ) {
  2512.                                 $this->brandApi->addTagToOffer($value['offerId'], $k);
  2513.                                 $this->populateDbByOfferId($value['offerId']);
  2514.                                 break 2;
  2515.                             }
  2516.                         }
  2517.                     }
  2518.                 }
  2519.             }
  2520.         }
  2521.     }
  2523.     public function getReportsRowWiseDataByAggregation($tableColumns, $selectedColumns, $rowWiseData)
  2524.     {
  2526.         $finalArr = [];
  2527.         foreach ($rowWiseData as $rowWiseIndex => $rowWiseValue) {
  2529.             $indexArr = [];
  2530.             foreach ($selectedColumns as $key => $value) {
  2531.                 if (
  2532.                     array_key_exists($key, $tableColumns) &&
  2533.                     $value &&
  2534.                     in_array($tableColumns[$key]['category'], ['data_fields', 'item_interval'])
  2535.                 ) {
  2536.                     $indexArr[] = $rowWiseValue[$key];
  2537.                 }
  2538.             }
  2540.             $index = md5(implode("#", $indexArr));
  2542.             if (!array_key_exists($index, $finalArr)) {
  2543.                 foreach ($selectedColumns as $key => $value) {
  2544.                     if (array_key_exists($key, $tableColumns) && $value && array_key_exists($key, $rowWiseValue)) {
  2545.                         if (in_array($tableColumns[$key]['category'], ['data_fields', 'item_interval'])) {
  2546.                             $finalArr[$index][$key] = $rowWiseValue[$key];
  2547.                         }
  2548.                     }
  2549.                 }
  2550.                 foreach ($tableColumns as $key => $value) {
  2551.                     if ($value['category'] == 'statistics') {
  2552.                         $finalArr[$index][$key] = 0;
  2553.                     }
  2554.                 }
  2555.             }
  2557.             foreach ($tableColumns as $key => $value) {
  2558.                 if (
  2559.                     (
  2560.                         $value['category'] == 'statistics' && !isset($value['calculationType'])
  2561.                     ) ||
  2562.                     (
  2563.                         isset($value['calculationType']) && $value['category'] == 'statistics' && $value['calculationType'] != 'percentage'
  2564.                     )
  2565.                 ) {
  2566.                     $finalArr[$index][$key] += $rowWiseValue[$key];
  2567.                     $finalArr[$index][$key] = round($finalArr[$index][$key], 2);
  2568.                 }
  2569.             }
  2570.         }
  2572.         return $finalArr;
  2573.     }
  2575.     public function getPaginatedResponseForReports($reportData, $tableColumns, $selectedColumns, $sortBy, $sortType, $limit, $page)
  2576.     {
  2578.         $reportData = array_values($reportData);
  2580.         if (sizeof($reportData)) {
  2581.             $entity = $reportData[0];
  2582.             if (array_key_exists($sortBy, $entity)) {
  2583.                 $sortFlag = 3;
  2584.                 if ($sortType == Config::SORT_TYPE_ASC) {
  2585.                     $sortFlag = 4;
  2586.                 }
  2587.                 array_multisort(array_column($reportData, $sortBy), $sortFlag, $reportData);
  2588.             }
  2589.         }
  2591.         $offset = $limit * ($page - 1);
  2593.         $totalRecordCount = sizeof($reportData);
  2594.         $noOfPages = ceil($totalRecordCount / $limit);
  2596.         foreach ($tableColumns as $key => $value) {
  2597.             if (isset($value['aggregate'])) {
  2598.                 if ($value['aggregate'] == 'sum') {
  2599.                     $tableColumns[$key]['Footer'] = number_format(round(array_sum(array_column($reportData, $value['accessor'])), 2));
  2600.                 }
  2601.                 if ($value['aggregate'] == 'average' && count($reportData) > 0) {
  2602.                     $tableColumns[$key]['Footer'] = number_format(round(array_sum(array_column($reportData, $value['accessor'])) / count($reportData), 2));
  2603.                 }
  2604.             }
  2605.         }
  2607.         $tableColumns = $this->changeColumnVisibilityForTable(array_values($tableColumns), $selectedColumns, []);
  2609.         return [
  2610.             'response' => [
  2611.                 'success' => true,
  2612.                 'httpStatus' => Config::HTTP_STATUS_CODE_OK,
  2613.                 'data' => [
  2614.                     'tableColumns' => array_values($tableColumns),
  2615.                     'data' => array_slice($reportData, $offset, $limit),
  2616.                     'metaData' => [
  2617.                         'total' => $totalRecordCount,
  2618.                         'limit' => (int)$limit,
  2619.                         'page' => (int)$page,
  2620.                         'pages' => (int)$noOfPages,
  2621.                     ]
  2622.                 ],
  2623.                 'error' => null
  2624.             ]
  2625.         ];
  2626.     }
  2628.     public function getAffiliateCategoryByAffiliateId($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  2629.     {
  2630.         $affiliateTagRelationshipData = $this->doctrine->getRepository(AffiliateTagRelationship::class)->getAffiliateTagRelationshipByTagIdArr([Config::HASOFFER_AFFILIATE_CATEGORY_A_TAG_ID, Config::HASOFFER_AFFILIATE_CATEGORY_B_TAG_ID], $tuneAccount);
  2632.         $data = [];
  2633.         foreach ($affiliateTagRelationshipData as $key => $value) {
  2634.             $data[$key] = [
  2635.                 'category' => Config::HASOFFER_AFFILIATE_CATEGORY_ARRAY[$value['tagId']],
  2636.                 'affiliateId' => $value['affiliateId']
  2637.             ];
  2638.         }
  2640.         $affiliateData = $this->doctrine->getRepository(AffiliateInfo::class)->getAffiliateListByArrToSearch([], $tuneAccount);
  2642.         foreach ($affiliateData as $key => $value) {
  2643.             if (!array_key_exists($value['affiliateId'], $data)) {
  2644.                 $data[$value['affiliateId']] = [
  2645.                     'category' => Config::HASOFFER_AFFILIATE_CATEGORY_UNCATEGORISED_TAG_NAME,
  2646.                     'affiliateId' => $value['affiliateId']
  2647.                 ];
  2648.             }
  2649.         }
  2651.         return $data;
  2652.     }
  2654.     public function getPidByOfferId($offerId, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
  2655.     {
  2657.         $tunePid = null;
  2658.         $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->findOneBy(['offerId' => $offerId, 'tuneAccount' => $tuneAccount]);
  2660.         if ($offerInfo) {
  2661.             $parsedUrl = parse_url($offerInfo->getOfferUrl());
  2662.             if (isset($parsedUrl['query'])) {
  2663.                 parse_str($parsedUrl['query'], $query);
  2664.                 if (isset($query['pid']) && in_array($query['pid'], Config::TUNE_APPSFLYER_PIDS)) {
  2665.                     $tunePid = $query['pid'];
  2666.                 }
  2667.             }
  2668.         }
  2670.         return $tunePid;
  2671.     }
  2673.     public function getWhitelistIPsAppsflyerOrAdjust($offerUrl)
  2674.     {
  2676.         $whitelistIps = [];
  2678.         if (stripos($offerUrl, Config::APPSFLYER_DOMAIN) !== false) {
  2679.             $whitelistIps = Config::WIZARD_APPSFLYER_WHITE_LIST;
  2680.         }
  2682.         if (
  2683.             stripos($offerUrl, Config::ADJUST_IO_DOMAIN) !== false
  2684.             || stripos($offerUrl, Config::ADJUST_COM_DOMAIN) !== false
  2685.         ) {
  2686.             $whitelistIps = Config::WIZARD_ADJUST_WHITE_LIST;
  2687.         }
  2689.         return $whitelistIps;
  2690.     }
  2692.     public function updateNotificationUnreadCountByUser($userEmail, $unreadNotificationCount)
  2693.     {
  2695.         $cacheKey = Config::CACHE_REDIS_UNREAD_NOTIFICATION_COUNT_BY_USER . $userEmail;
  2696.         if (is_null($this->elasticCache->redisGet($cacheKey))) {
  2697.             $userData = $this->doctrine->getRepository(MafoUserNotifications::class)->findBy([
  2698.                 'sentToUserId' => $userEmail,
  2699.                 'isRead' => 0
  2700.             ]);
  2701.             $notificationCount = count($userData);
  2702.         } else {
  2703.             $notificationCount = $this->elasticCache->redisGet($cacheKey);
  2704.         }
  2706.         $unreadNotificationCount += $notificationCount;
  2708.         $this->elasticCache->redisSet($cacheKey, $unreadNotificationCount);
  2709.     }
  2711.     public function getUnreadNotificationCountByUser($userEmail)
  2712.     {
  2714.         $cacheKey = Config::CACHE_REDIS_UNREAD_NOTIFICATION_COUNT_BY_USER . $userEmail;
  2715.         if (is_null($this->elasticCache->redisGet($cacheKey))) {
  2716.             $userData = $this->doctrine->getRepository(MafoUserNotifications::class)->findBy([
  2717.                 'sentToUserId' => $userEmail,
  2718.                 'isRead' => 0
  2719.             ]);
  2720.             $notificationCount = count($userData);
  2721.         } else {
  2722.             $notificationCount = $this->elasticCache->redisGet($cacheKey);
  2723.         }
  2725.         return $notificationCount;
  2726.     }
  2728.     public function sendPushNotification($topic, $topicData)
  2729.     {
  2730.         try {
  2731.             $update = new Update(
  2732.                 $topic,
  2733.                 $topicData
  2734.                 //               ,true
  2735.             );
  2737.             $this->hub->publish($update);
  2738.         } catch (\Exception $e) {
  2739.             $this->logger->error('Error occurred: ' . $e);
  2740.         }
  2741.     }
  2743.     public function getEmployeesByUserId()
  2744.     {
  2746.         $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HO_EMPLOYEES_LIST);
  2748.         if (!$cachedList) {
  2749.             $employeeList = $this->getWarmedUpUsersByUserId();
  2750.         } else {
  2751.             $employeeList = json_decode($cachedList, true);
  2752.         }
  2754.         ksort($employeeList);
  2756.         return $employeeList;
  2757.     }
  2759.     public function getWarmedUpUsersByUserId()
  2760.     {
  2762.         $employeesData = $this->doctrine->getRepository(Users::class)->getEmployees();
  2763.         $data = [];
  2764.         foreach ($employeesData as $key => $value) {
  2765.             $data[$value['email']] = [
  2766.                 'firstName' => $value['name'],
  2767.                 'email' => $value['email']
  2768.             ];
  2769.         }
  2770.         return $data;
  2771.     }
  2772. }