src/Services/Common.php line 97

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.     }
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.         }
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.     }
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. }