src/Services/Common.php line 171

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\MafoDeductionControl;
21. use App\Entity\Employees;
22. use App\Entity\MafoUserNotifications;
23. use App\Entity\MmpAdvertisers;
24. use App\Entity\MmpMobileApps;
25. use App\Entity\ObjectMappingWithTuneWebAccount;
26. use App\Entity\OfferCategories;
27. use App\Entity\OfferCategoryRelationship;
28. use App\Entity\OfferCreativeFile;
29. use App\Entity\OfferGeoRelationship;
30. use App\Entity\OfferGoalsInfo;
31. use App\Entity\OfferInfo;
32. use App\Entity\OfferTagRelationship;
33. use App\Entity\OfferWhitelist;
34. use App\Entity\SkadNetworkApiLogs;
35. use App\Entity\SkadNetworkManualPostbackMapping;
36. use App\Entity\SkadNetworkPostbackLogs;
37. use App\Entity\Tag;
38. use App\Entity\UserApiKey;
39. use App\Entity\Users;
40. use App\Entity\MafoAdvertisers;
41. use App\Entity\MafoOffers;
42. use App\Repository\AdvertiserAccountManagerRepository;
43. use Aws\Credentials\Credentials;
44. use Aws\S3\Exception\S3Exception;
45. use Aws\Exception\MultipartUploadException;
46. use Aws\S3\MultipartUploader;
47. use Aws\S3\ObjectUploader;
48. use Aws\S3\S3Client;
49. use Doctrine\ORM\EntityManagerInterface;
50. use PhpOffice\PhpSpreadsheet\IOFactory;
51. use PhpOffice\PhpSpreadsheet\Spreadsheet;
52. use Psr\Log\LoggerInterface;
53. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
54. use Symfony\Component\Mercure\HubInterface;
55. use Symfony\Component\Mercure\Update;
56. use Twig\Environment;
58. /**
59.  *
60.  * Common functions which are used throughout the project
61.  *
62.  * Class Common
63.  * @package App\Services
64.  */
65. class Common
66. {
68.     private $em;
69.     private $brandApi;
70.     private $doctrine;
71.     private $scraper;
72.     private $elasticCache;
73.     private $rootPath;
74.     private $usersComponents;
75.     private $mafoObjectsComponents;
76.     private $hyperApis;
77.     private LoggerInterface $logger;
78.     private HubInterface $hub;
80.     public function __construct(
81.         MysqlQueries $em,
82.         BrandHasofferAPI $brandApi,
83.         EntityManagerInterface $doctrine,
84.         Scraper $scraper,
85.         Environment $templating,
86.         Aws\ElasticCache $elasticCache,
87.         ParameterBagInterface $params,
88.         UsersComponents $usersComponents,
89.         MafoObjectsComponents $mafoObjectsComponents,
90.         HyperApis $hyperApis,
91.         LoggerInterface $logger,
92.         HubInterface $hub
93.     ) {
94.         $this->em = $em;
95.         $this->brandApi = $brandApi;
96.         $this->doctrine = $doctrine;
97.         $this->scraper = $scraper;
98.         $this->template = $templating;
99.         $this->elasticCache = $elasticCache;
100.         $this->rootPath = $params->get('kernel.project_dir');
101.         $this->usersComponents = $usersComponents;
102.         $this->mafoObjectsComponents = $mafoObjectsComponents;
103.         $this->hyperApis = $hyperApis;
104.         $this->logger = $logger;
105.         $this->hub = $hub;
106.     }
108.     public function getAdvertisersListByStatusWithKeys($arr = [])
109.     {
110.         $statuses = isset($arr['statuses']) && sizeof($arr['statuses']) > 0 ? $arr['statuses'] : [Config::ACTIVE_STATUS];
111.         $tuneAccount = isset($arr['tuneAccount']) ? $arr['tuneAccount'] : Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE;
113.         $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HO_ADVERTISER_LIST_FOR_MULTISELECT . '_' . $tuneAccount);
115.         if (!$cachedList || (count($statuses) == 1 && !in_array(Config::ACTIVE_STATUS, $statuses))) {
116.             $advertiserList = $this->getWarmedUpHoAdvertiserList($statuses, $tuneAccount);
117.         } else {
118.             $advertiserList = json_decode($cachedList, true);
119.         }
121.         ksort($advertiserList);
123.         return $advertiserList;
124.     }
126.     public function getWarmedUpHoAdvertiserList($statuses, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
127.     {
128.         $advertiserList = [];
129.         $advertiserData = $this->doctrine->getRepository(AdvertiserInfo::class)->getAdvertiserListByStatus($statuses, $tuneAccount);
131.         $employeesInfo = $this->getEmployeesByEmployeeId();
133.         foreach ($advertiserData as $key => $value) {
134.             $temp = [
135.                 'status' => $value['status'],
136.                 'name' => $value['company'],
137.                 'accountManagerId' => $value['accountManagerId'],
138.                 'accountManagerEmail' => null,
139.                 'accountManagerName' => null,
140.                 'id' => (int)$value['advertiserId']
141.             ];
142.             if (array_key_exists($value['accountManagerId'], $employeesInfo)) {
143.                 $temp['accountManagerEmail'] = $employeesInfo[$value['accountManagerId']]['email'];
144.                 $temp['accountManagerName'] = $employeesInfo[$value['accountManagerId']]['fullName'];
145.             }
147.             $advertiserList[$value['advertiserId']] = $temp;
148.         }
149.         return $advertiserList;
150.     }
152.     public function getAffiliateListByStatusWithKeys($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
153.     {
154.         $statuses = [Config::ACTIVE_STATUS];
156.         $tuneAccountCacheKey = Config::CACHE_REDIS_HO_AFFILIATE_LIST_FOR_MULTISELECT . '_' . $tuneAccount;
158.         $cachedList = $this->elasticCache->redisGet($tuneAccountCacheKey);
160.         if (!$cachedList || (count($statuses) == 1 && !in_array(Config::ACTIVE_STATUS, $statuses))) {
161.             $affiliateList = $this->getWarmedUpHoAffiliateList($statuses, $tuneAccount);
162.         } else {
163.             $affiliateList = json_decode($cachedList, true);
164.         }
166.         ksort($affiliateList);
168.         return $affiliateList;
169.     }
171.     public function getPublisherAffiliateListByStatusWithKeys($statuses = [Config::ACTIVE_STATUS], $affiliateIds)
172.     {
173.         //        $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HO_AFFILIATE_LIST_FOR_MULTISELECT);
174.         //
175.         //        if (!$cachedList || (count($statuses) == 1 && !in_array(Config::ACTIVE_STATUS, $statuses))) {
176.         //            $affiliateList = $this->getWarmedUpHoPublisherAffiliateList($statuses);
177.         //        } else {
178.         //            $affiliateList = json_decode($cachedList, true);
179.         //        }
181.         $affiliateList = $this->getWarmedUpHoPublisherAffiliateList($statuses, $affiliateIds);
184.         ksort($affiliateList);
186.         return $affiliateList;
187.     }
189.     public function getWarmedUpHoAffiliateList($statuses, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
190.     {
191.         $affiliateList = [];
192.         $affiliateData = $this->doctrine->getRepository(AffiliateInfo::class)->getAffiliateListByStatusArr($statuses, $tuneAccount);
194.         $employeesInfo = $this->getEmployeesByEmployeeId();
196.         foreach ($affiliateData as $key => $value) {
197.             $temp = [
198.                 'status' => $value['status'],
199.                 'name' => $value['company'],
200.                 'accountManagerId' => $value['accountManagerId'],
201.                 'accountManagerEmail' => null,
202.                 'accountManagerName' => null,
203.                 'id' => (int)$value['affiliateId']
204.             ];
206.             if (array_key_exists($value['accountManagerId'], $employeesInfo)) {
207.                 $temp['accountManagerEmail'] = $employeesInfo[$value['accountManagerId']]['email'];
208.                 $temp['accountManagerName'] = $employeesInfo[$value['accountManagerId']]['fullName'];
209.             }
211.             $affiliateList[$value['affiliateId']] = $temp;
212.         }
213.         return $affiliateList;
214.     }
218.     public function getWarmedUpHoPublisherAffiliateList(array $statuses, array $affiliateIds = [])
219.     {
220.         $affiliateList = [];
222.         // Fetch affiliate data based on status
223.         $affiliateData = $this->doctrine->getRepository(AffiliateInfo::class)->getAffiliateListByStatusArr($statuses);
225.         // Get employee information
226.         $employeesInfo = $this->getEmployeesByEmployeeId();
228.         foreach ($affiliateData as $value) {
229.             // Only process if the affiliateId is in the provided $affiliateIds array, or if $affiliateIds is empty
230.             if (empty($affiliateIds) || in_array($value['affiliateId'], $affiliateIds)) {
231.                 $temp = [
232.                     'status' => $value['status'],
233.                     'name' => $value['company'],
234.                     'accountManagerId' => $value['accountManagerId'],
235.                     'accountManagerEmail' => null,
236.                     'accountManagerName' => null,
237.                     'id' => (int)$value['affiliateId']
238.                 ];
240.                 // Check if account manager info is available
241.                 if (array_key_exists($value['accountManagerId'], $employeesInfo)) {
242.                     $temp['accountManagerEmail'] = $employeesInfo[$value['accountManagerId']]['email'];
243.                     $temp['accountManagerName'] = $employeesInfo[$value['accountManagerId']]['fullName'];
244.                 }
246.                 // Add to affiliate list
247.                 $affiliateList[$value['affiliateId']] = $temp;
248.             }
249.         }
251.         return $affiliateList;
252.     }
255.     public function getWarmedUpHoPublisherMafoAffiliateList(array $statuses, array $affiliateIds = [])
256.     {
257.         $affiliateList = [];
259.         // Fetch affiliate data based on status
260.         $affiliateData = $this->doctrine->getRepository(MafoAffiliates::class)->getAffiliateListByStatusArr($statuses);
262.         // Get employee information
263.         $employeesInfo = $this->getEmployeesByEmployeeId();
265.         foreach ($affiliateData as $value) {
266.             // Only process if the affiliateId is in the provided $affiliateIds array, or if $affiliateIds is empty
267.             if (empty($affiliateIds) || in_array($value['affiliateId'], $affiliateIds)) {
268.                 $temp = [
269.                     'status' => $value['status'],
270.                     'name' => $value['name'],
271.                     'accountManagerId' => $value['accountManagerId'],
272.                     'accountManagerEmail' => null,
273.                     'accountManagerName' => null,
274.                     'id' => (int)$value['id']
275.                 ];
277.                 // Check if account manager info is available
278.                 if (array_key_exists($value['accountManagerId'], $employeesInfo)) {
279.                     $temp['accountManagerEmail'] = $employeesInfo[$value['accountManagerId']]['email'];
280.                     $temp['accountManagerName'] = $employeesInfo[$value['accountManagerId']]['fullName'];
281.                 }
283.                 // Add to affiliate list
284.                 $affiliateList[$value['id']] = $temp;
285.             }
286.         }
288.         return $affiliateList;
289.     }
292.     public function getHyperClientCachedListByKeys()
293.     {
295.         $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HYPER_CLIENT_LIST);
297.         if (!$cachedList) {
298.             $clientList = $this->getHyperClientListByKeys();
299.         } else {
300.             $clientList = json_decode($cachedList, true);
301.         }
303.         return $clientList;
304.     }
306.     public function getHyperClientListByKeys()
307.     {
309.         $hyperData = $this->hyperApis->getHyperClientList();
311.         $clientList = [];
312.         if ($hyperData && isset($hyperData['Result']) && $hyperData['Result'] == 'Ok') {
313.             foreach ($hyperData['ResultData']['Data'] as $key => $value) {
316.                 $countryCode = null;
317.                 foreach (Config::COUNTRIES as $k => $v) {
318.                     if ($this->checkForString($value['Country'], $v['name'])) {
319.                         $countryCode = $k;
320.                         break;
321.                     }
322.                 }
324.                 $value['countryCode'] = $countryCode;
326.                 $clientList[$value['ClientNumber']] = $value;
327.             }
328.         }
330.         $this->elasticCache->redisSet(Config::CACHE_REDIS_HYPER_CLIENT_LIST, json_encode($clientList));
331.         return $clientList;
332.     }
335.     public function getHyperPublisherCachedListByKeys()
336.     {
338.         $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HYPER_PUBLISHER_LIST);
340.         if (!$cachedList) {
341.             $clientList = $this->getHyperPublisherListByKeys();
342.         } else {
343.             $clientList = json_decode($cachedList, true);
344.         }
346.         return $clientList;
347.     }
349.     public function getHyperPublisherListByKeys()
350.     {
352.         $hyperData = $this->hyperApis->getHyperPublisherInfo();
354.         $clientList = [];
355.         if ($hyperData && isset($hyperData['Result']) && $hyperData['Result'] == 'Ok') {
356.             foreach ($hyperData['ResultData']['Data'] as $key => $value) {
359.                 $countryCode = null;
360.                 foreach (Config::COUNTRIES as $k => $v) {
361.                     if ($this->checkForString($value['Country'], $v['name'])) {
362.                         $countryCode = $k;
363.                         break;
364.                     }
365.                 }
367.                 $value['countryCode'] = $countryCode;
369.                 $clientList[$value['SupplierNumber']] = $value;
370.             }
371.         }
374.         return $clientList;
375.     }
377.     public function getHyperAffiliateListByKeys()
378.     {
380.         $hyperData = $this->hyperApis->getHyperClientList();
382.         $clientList = [];
383.         if ($hyperData && isset($hyperData['Result']) && $hyperData['Result'] == 'Ok') {
384.             foreach ($hyperData['ResultData']['Data'] as $key => $value) {
387.                 $countryCode = null;
388.                 foreach (Config::COUNTRIES as $k => $v) {
389.                     if ($this->checkForString($value['Country'], $v['name'])) {
390.                         $countryCode = $k;
391.                         break;
392.                     }
393.                 }
395.                 $value['countryCode'] = $countryCode;
397.                 $clientList[$value['ClientNumber']] = $value;
398.             }
399.         }
401.         $this->elasticCache->redisSet(Config::CACHE_REDIS_HYPER_CLIENT_LIST, json_encode($clientList));
402.         return $clientList;
403.     }
406.     public function getMmpAdvertisersListWithKeys()
407.     {
408.         $advertisers = $this->doctrine->getRepository(MmpAdvertisers::class)->getMmpAdvertisers();
410.         $data = [];
411.         foreach ($advertisers as $key => $value) {
412.             $data[$value['id']] = [
413.                 'value' => $value['id'],
414.                 'label' => $value['name']
415.             ];
416.         }
417.         ksort($data);
419.         return $data;
420.     }
423.     public function getAffiliateTagListByStatusWithKeys($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
424.     {
425.         $tagsInDb = $this->doctrine->getRepository(Tag::class)->getTags(1, null, null, 1, $tuneAccount);
426.         $tagList = [];
427.         foreach ($tagsInDb as $key => $value) {
428.             $tagList[$value['tagId']] = [
429.                 'value' => $value['tagId'],
430.                 'name' => $value['name']
431.             ];
432.         }
433.         ksort($tagList);
435.         return $tagList;
436.     }
438.     public function getOfferCategoriesListByStatusWithKeys($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
439.     {
440.         $status = Config::ACTIVE_STATUS;
441.         $offerCategoriesData = $this->doctrine->getRepository(OfferCategories::class)->getOfferCategoriesByStatus($status, $tuneAccount);
442.         $offerCategoryList = [];
443.         foreach ($offerCategoriesData as $key => $value) {
444.             $offerCategoryList[$value['categoryId']] = [
445.                 'name' => $value['name'],
446.                 'id' => (int)$value['categoryId']
447.             ];
448.         }
449.         ksort($offerCategoryList);
451.         return $offerCategoryList;
452.     }
454.     public function getAdvertiserListByAdvertiserIdArr($advertiserIdArr, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
455.     {
457.         $advertiserDataByAdvertiserId = [];
459.         if ($advertiserIdArr) {
460.             $advertiserInfo = $this->doctrine->getRepository(AdvertiserInfo::class)->getAdvertiserInfoByAdvertiserIdArr($advertiserIdArr, $tuneAccount);
462.             foreach ($advertiserInfo as $key => $value) {
463.                 $advertiserDataByAdvertiserId[$value['advertiserId']] = [
464.                     'id' => (int)$value['advertiserId'],
465.                     'name' => $value['company']
466.                 ];
467.             }
468.         }
470.         return $advertiserDataByAdvertiserId;
471.     }
473.     public function getGoalDisableLinkData($offerId)
474.     {
476.         $data = $this->em->getGoalDisableLinkData($offerId);
478.         $distinctOfferIds = [];
479.         foreach ($data as $key => $value) {
480.             if (!in_array($value['offerId'], $distinctOfferIds)) {
481.                 $distinctOfferIds[] = $value['offerId'];
482.             }
483.         }
484.         $offerGoalsByOfferId = [];
486.         if ($distinctOfferIds) {
487.             $offerGoalData = $this->doctrine->getRepository(OfferGoalsInfo::class)->getGoalsDataByOfferIdArr($distinctOfferIds);
489.             if ($offerGoalData) {
490.                 foreach ($offerGoalData as $key => $value) {
491.                     $offerGoalsByOfferId[$value['offerId']][] = $value['goalId'];
492.                 }
493.             }
494.         }
496.         $bifurcatedData = [];
497.         foreach ($data as $key => $value) {
498.             if (array_key_exists($value['offerId'], $offerGoalsByOfferId) && in_array($value['goalId'], $offerGoalsByOfferId[$value['offerId']])) {
499.                 $bifurcatedData[$value['addedFrom']][] = $value;
500.             }
501.         }
503.         return $bifurcatedData;
504.     }
506.     public function disableLink($offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $addedFrom, $advertiserId, $jsonMetaDataStr, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
507.     {
508.         $disableLinkMd5 = $this->getDisableLinkMd5($offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $tuneAccount);
509.         $md5Exist = $this->em->getDisableLinkByMd5($disableLinkMd5);
510.         if (!$md5Exist) {
511.             $data = $this->brandApi->saveOfferDisabledLink($offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $tuneAccount);
512.             if ($data['response']['status'] === 1) {
513.                 $this->em->insertToDisableLink($disableLinkMd5, $offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $addedFrom, $advertiserId, $jsonMetaDataStr);
514.             }
515.         }
516.     }
518.     public function getDisableLinkMd5($offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $trackingAccount = Config::TUNE_ACCOUNT_DEFAULT, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
519.     {
521.         $trackingAccountStr = $trackingAccount == Config::TUNE_ACCOUNT_DEFAULT ? '' : Config::TUNE_ACCOUNT_WEB;
522.         return md5($offerId . $affiliateId . $source . $affsub2 . $affSub3 . $affSub5 . $trackingAccountStr . $tuneAccount);
523.     }
525.     public function automaticDisableLinkData($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
526.     {
528.         $automaticDisableLinkData = $this->em->getAutomaticDisableLinkData($tuneAccount);
530.         $finalArr['byAdvertiser'] = [];
531.         $finalArr['byAffiliate'] = [];
532.         $finalArr['byOffer'] = [];
533.         foreach ($automaticDisableLinkData as $key => $value) {
535.             $value['tuneAccountPretty'] = Config::MAFO_SYSTEM_IDENTIFIER_PRETTY[$value['tuneAccount']];
536.             $value['dateInserted'] = $value['dateInserted']->format('Y-m-d H:i:s');
537.             if ($value['advertiserId']) {
538.                 $finalArr['byAdvertiser'][] = $value;
539.             }
540.             if ($value['affiliateId']) {
541.                 $finalArr['byAffiliate'][] = $value;
542.             }
543.             if ($value['offerId']) {
544.                 $finalArr['byOffer'][] = $value;
545.             }
546.         }
548.         return $finalArr;
549.     }
551.     public function deleteDisableLinkByMd5($md5, $id, $trackingAccount = Config::TUNE_ACCOUNT_DEFAULT)
552.     {
554.         $disableLink = $this->em->getDisableLinkByMd5($md5);
556.         if ($disableLink) {
557.             $offerId = $disableLink->getOfferId();
558.             $affiliateId = $disableLink->getAffiliateId();
559.             $source = $disableLink->getSource();
560.             $affSub2 = $disableLink->getAffsub2();
561.             $affSub3 = $disableLink->getAffsub3();
562.             $affSub5 = $disableLink->getAffsub5();
563.             $advertiserId = $disableLink->getAdvertiserId();
564.             $addedFrom = $disableLink->getAddedFrom();
565.             $meta = $disableLink->getMeta();
566.             $wasInsertedOn = $disableLink->getDateInserted();
567.             $trackingAccount = $disableLink->getTrackingAccount();
568.             $strict = 0;
570.             $disableLinkData = $this->brandApi->findDisableLink($offerId, $affiliateId, $source, $strict, $affSub2, $affSub3, $affSub5, $trackingAccount)['response']['data'];
572.             foreach ($disableLinkData as $k => $v) {
573.                 $this->brandApi->deleteDisableLink($k, $trackingAccount);
574.             }
576.             $this->em->deleteDisableLinkByMd5($md5);
577.             //            Removing dump from mysql and added dump of DisableLinks to mongo
578.             //            $this->em->insertToDisableLinkDump($md5, $offerId, $affiliateId, $source, $affSub2, $addedFrom, $advertiserId, $meta, $wasInsertedOn, $affSub3, $affSub5, $trackingAccount);
579.         } else {
580.             $this->brandApi->deleteDisableLink($id);
581.         }
582.     }
584.     public function checkForNonIncentInString($string)
585.     {
586.         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')) {
587.             return true;
588.         }
590.         return false;
591.     }
594.     public function checkForString($superString, $checkString)
595.     {
596.         if (strpos(strtolower($superString), strtolower($checkString)) !== false) {
597.             return true;
598.         } else {
599.             return false;
600.         }
601.     }
603.     public function filterSource($source)
604.     {
605.         if ($this->checkForString($source, "_")) {
606.             $source = explode("_", $source);
607.             if (($source[0] == "" && $source[1] != "") || ($source[0] != "" && $source[1] == "") || ($source[0] == "" && $source[1] == "")) {
608.                 $source = implode("_", $source);
609.             } else {
610.                 $source = $source[0];
611.             }
612.         }
614.         return $source;
615.     }
617.     public function filterSourceByAffiliate($source, $affiliateId)
618.     {
619.         if ($affiliateId == 3467) {
621.             $actualSource = $source;
622.             if (substr($source, 0, 4) === "114_") {
623.                 $actualSource = substr($source, 4);
624.             }
626.             return $actualSource;
627.         }
629.         return $source;
630.     }
632.     public function filterSourceByAffiliateAndLtr($source, $affiliateId, $clicks, $conversions)
633.     {
634.         if ($affiliateId == 3467) {
636.             $actualSource = $source;
637.             if (substr($source, 0, 4) === "114_") {
638.                 $actualSource = substr($source, 4);
639.             }
641.             if ($conversions > 15 && (($conversions / $clicks) * 100 > 30)) {
642.                 return $actualSource;
643.             } else {
644.                 return false;
645.             }
646.         }
648.         return $source;
649.     }
651.     public function getBulkCapData()
652.     {
653.         $bulkData = $this->em->getBulkCapData();
655.         foreach ($bulkData as $key => $value) {
656.             $bulkData[$key]['affiliateOfferCapType'] = str_replace("_", " ", ucfirst($value['affiliateOfferCapType']));
657.             $bulkData[$key]['dateInserted'] = $value['dateInserted']->format('Y-m-d H:s:i');
658.         }
660.         return $bulkData;
661.     }
663.     public function getBulkCapByAffiliateData()
664.     {
665.         $bulkData = $this->em->getBulkCapByAffiliateData();
667.         foreach ($bulkData as $key => $value) {
668.             $bulkData[$key]['affiliateOfferCapType'] = str_replace("_", " ", ucfirst($value['affiliateOfferCapType']));
669.             $bulkData[$key]['dateInserted'] = $value['dateInserted']->format('Y-m-d H:s:i');
670.         }
672.         return $bulkData;
673.     }
675.     public function getAccountManagerInfoByTuneAdvertiserId($advertiserId, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
676.     {
678.         $accountManagerInfo = $this->doctrine->getRepository(AdvertiserAccountManager::class)->getAdvertiserAccountManagerByAdvertiserId($advertiserId, $tuneAccount);
680.         $email = Config::ALERT_RECIPIENT_DEFAULT_EMAIL;
681.         $firstName = '';
682.         $lastName = '';
683.         if ($accountManagerInfo) {
684.             $email = $accountManagerInfo->getEmail();
685.             $firstName = $accountManagerInfo->getFirstName();
686.             $lastName = $accountManagerInfo->getLastName();
687.         }
689.         return [
690.             'emailId' => $email,
691.             'firstName' => $firstName,
692.             'lastName' => $lastName
693.         ];
694.     }
696.     public function getAccountManagerInfoByMafoAdvertiserId($advertiserId)
697.     {
698.         $mafoAdvertiserInfo = $this->doctrine->getRepository(MafoAdvertisers::class)->findOneBy(['id' => $advertiserId]);
700.         $email = Config::ALERT_RECIPIENT_DEFAULT_EMAIL;
701.         $firstName = '';
702.         $lastName = '';
703.         if ($mafoAdvertiserInfo) {
704.             $accountManagerInfo = $this->doctrine->getRepository(Users::class)->findOneBy(['email' => $mafoAdvertiserInfo->getAccountManagerEmail()]);
705.             $email = $mafoAdvertiserInfo->getAccountManagerEmail();
706.             $name = $accountManagerInfo->getName();
707.             $nameArr = explode(" ", $name);
708.             $firstName = $nameArr[0];
709.             $lastName = $nameArr[1];
710.         }
712.         return [
713.             'emailId' => $email,
714.             'firstName' => $firstName,
715.             'lastName' => $lastName
716.         ];
717.     }
719.     public function getAccountManagerInfoByTuneAffiliateId($affiliateId, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
720.     {
722.         $accountManagerInfo = $this->doctrine->getRepository(AffiliateAccountManager::class)->getAffiliateAccountManagerByAffiliateId($affiliateId, $tuneAccount);
724.         $email = Config::ALERT_RECIPIENT_DEFAULT_EMAIL;
725.         $firstName = '';
726.         $lastName = '';
727.         if ($accountManagerInfo) {
728.             $email = $accountManagerInfo->getEmail();
729.             $firstName = $accountManagerInfo->getFirstName();
730.             $lastName = $accountManagerInfo->getLastName();
731.         }
733.         return [
734.             'emailId' => $email,
735.             'firstName' => $firstName,
736.             'lastName' => $lastName
737.         ];
738.     }
740.     public function getAccountManagerInfoByMafoAffiliateId($affiliateId)
741.     {
742.         $mafoAffiliateInfo = $this->doctrine->getRepository(MafoAffiliates::class)->findOneBy(['id' => $affiliateId]);
744.         $email = Config::ALERT_RECIPIENT_DEFAULT_EMAIL;
745.         $firstName = '';
746.         $lastName = '';
747.         if ($mafoAffiliateInfo) {
748.             $accountManagerInfo = $this->doctrine->getRepository(Users::class)->findOneBy(['email' => $mafoAffiliateInfo->getAccountManagerEmail()]);
749.             $email = $mafoAffiliateInfo->getAccountManagerEmail();
750.             $name = $accountManagerInfo->getName();
751.             $nameArr = explode(" ", $name);
752.             $firstName = $nameArr[0];
753.             $lastName = $nameArr[1];
754.         }
756.         return [
757.             'emailId' => $email,
758.             'firstName' => $firstName,
759.             'lastName' => $lastName
760.         ];
761.     }
763.     public function getAccountManagerInfoByAffiliateIdArrWithKeys($affiliateIdArr, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
764.     {
766.         $accountManagerInfoDB = $this->doctrine->getRepository(AffiliateAccountManager::class)->getDataByAffiliateIds($affiliateIdArr, $tuneAccount);
767.         $accountManagerInfo = [];
769.         foreach ($accountManagerInfoDB as $key => $value) {
770.             $accountManagerInfo[$value['affiliateId']] = $value;
771.             $accountManagerInfo[$value['affiliateId']]['id'] = $value['employeeId'];
772.             $accountManagerInfo[$value['affiliateId']]['name'] = $value['firstName'] . ' ' . $value['lastName'];
773.         }
775.         return $accountManagerInfo;
776.     }
778.     public function getAccountManagerInfoByOfferId($offerId)
779.     {
781.         $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->checkOfferIdExist($offerId);
782.         return $this->getAccountManagerInfoByTuneAdvertiserId($offerInfo ? $offerInfo->getAdvertiserId() : null);
783.     }
785.     public function getDisableLinkLogs($affiliateIdArray, $offerIdArray, $sourceIdArray, $advertiserArray, $addedFromArr, $dateStart, $dateEnd, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
786.     {
788.         $disableLinksMyMd5 = [];
789.         $disableLinkData = [];
790.         if (empty($addedFromArr) || in_array(Config::DISABLE_LINKS_FROM_HO_PANEL, $addedFromArr)) {
792.             $disableLinkDataFromHO = $this->brandApi->findDisableLinksDyDateRange($offerIdArray, $affiliateIdArray, $sourceIdArray, [], $dateStart, $dateEnd, $tuneAccount)['response']['data']['data'];
794.             $disableLinkData = [];
795.             $md5Arr = [];
796.             foreach ($disableLinkDataFromHO as $key => $value) {
798.                 $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);
799.                 $disableLinkData[] = [
800.                     'affiliateId' => $value['OfferDisabledLink']['affiliate_id'],
801.                     'offerId' => $value['OfferDisabledLink']['offer_id'],
802.                     'source' => $value['OfferDisabledLink']['source'],
803.                     'advertiserId' => null,
804.                     'dateInserted' => $value['OfferDisabledLink']['datetime'],
805.                     'addedFrom' => null,
806.                     'md5' => $md5,
807.                     'tuneAccount' => $tuneAccount,
808.                     'id' => $value['OfferDisabledLink']['id']
809.                 ];
811.                 $md5Arr[] = $md5;
812.             }
815.             if (!empty($md5Arr)) {
816.                 $savedDisableLinkData = $this->em->getDisableLinksByMd5Arr($md5Arr);
817.                 foreach ($savedDisableLinkData as $key => $value) {
818.                     $disableLinksMyMd5[$value['md5']] = $value;
819.                 }
820.             }
821.         } else {
823.             $disableLinkData = $this->em->getDisableLinkLogs($affiliateIdArray, $offerIdArray, $advertiserArray, $sourceIdArray, $addedFromArr, $dateStart, $dateEnd);
825.             foreach ($disableLinkData as $key => $value) {
826.                 $disableLinksMyMd5[$value['md5']] = $value;
827.                 $disableLinkData[$key]['dateInserted'] = $value['dateInserted']->format('Y-m-d H:i:s');
828.             }
829.         }
832.         $distinctOfferIdArr = [];
833.         $distinctAffiliateIdArr = [];
835.         foreach ($disableLinkData as $key => $value) {
837.             if (!in_array($value['offerId'], $distinctOfferIdArr)) {
838.                 array_push($distinctOfferIdArr, $value['offerId']);
839.             }
841.             if (!in_array($value['affiliateId'], $distinctAffiliateIdArr)) {
842.                 array_push($distinctAffiliateIdArr, $value['affiliateId']);
843.             }
845.             $disableLinkData[$key]['date_inserted'] = $value['dateInserted'];
846.         }
848.         $offerInfo = [];
849.         if (!empty($distinctOfferIdArr)) {
850.             $offerInfo = $this->getOfferInfoByKey($distinctOfferIdArr, $tuneAccount);
851.         }
853.         $advertiserList = $this->getAdvertisersListByStatusWithKeys([
854.             'tuneAccount' => $tuneAccount
855.         ]);
856.         $affiliateList = $this->getAffiliateListByStatusWithKeys($tuneAccount);
858.         foreach ($disableLinkData as $key => $value) {
860.             if (!array_key_exists($value['offerId'], $offerInfo)) {
861.                 unset($disableLinkData[$key]);
862.                 continue;
863.             }
864.             $offerName = $offerInfo[$value['offerId']]['name'] ?? '';
865.             $advertiserName = array_key_exists($offerInfo[$value['offerId']]['advertiserId'], $advertiserList) ? $advertiserList[$offerInfo[$value['offerId']]['advertiserId']]['name'] : '';
866.             $advertiserId = $offerInfo[$value['offerId']]['advertiserId'] ?? '';
867.             $affiliateName = array_key_exists($value['affiliateId'], $affiliateList) ? $affiliateList[$value['affiliateId']]['name'] : '';
868.             $meta = [];
869.             $addedFrom = Config::DISABLE_LINKS_FROM_HO_PANEL;
871.             if (array_key_exists($value['md5'], $disableLinksMyMd5)) {
872.                 $meta = json_decode($disableLinksMyMd5[$value['md5']]['meta'], true) != null ? json_decode($disableLinksMyMd5[$value['md5']]['meta'], true) : [];
873.                 $addedFrom = $disableLinksMyMd5[$value['md5']]['addedFrom'];
874.             }
876.             if (
877.                 (!empty($addedFromArr) && !in_array($addedFrom, $addedFromArr)) ||
878.                 (sizeof($advertiserArray) && !in_array($advertiserId, $advertiserArray))
879.             ) {
880.                 unset($disableLinkData[$key]);
881.                 continue;
882.             }
884.             $disableLinkData[$key]['affiliateName'] = $affiliateName;
885.             $disableLinkData[$key]['advertiserName'] = $advertiserName;
886.             $disableLinkData[$key]['advertiserId'] = $advertiserId;
887.             $disableLinkData[$key]['offerName'] = $offerName;
888.             $disableLinkData[$key]['addedFrom'] = $addedFrom;
889.             $disableLinkData[$key]['meta'] = $meta;
890.         }
892.         return $disableLinkData;
893.     }
895.     public function createUpdateRetentionOptimisation($offerId, $goalId, $retentionRate, $minimumBudget, $sendAlert, $autoBlock, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
896.     {
898.         $retentionOptimisationExist = $this->em->getRetentionOptimisationByParams($offerId, $goalId, $tuneAccount);
900.         if ($retentionOptimisationExist) {
901.             if ($sendAlert === null) {
902.                 $sendAlert = $retentionOptimisationExist->getSendAlert();
903.             }
904.             if ($autoBlock === null) {
905.                 $autoBlock = $retentionOptimisationExist->getAutoBlock();
906.             }
907.             $this->em->updateRetentionOptimisation($offerId, $goalId, $retentionRate, $minimumBudget, $sendAlert, $autoBlock, $tuneAccount);
908.         } else {
909.             $this->em->insertRetentionOptimisation($offerId, $goalId, $retentionRate, $minimumBudget, $sendAlert, $autoBlock, $tuneAccount);
910.         }
911.     }
913.     public function getRetentionOptimisationData($offerId, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
914.     {
916.         $retentionOptimisationData = $this->em->getRetentionOptimisation($offerId, $tuneAccount);
918.         $distinctOfferIds = [];
919.         foreach ($retentionOptimisationData as $key => $value) {
920.             if (!in_array($value['offerId'], $distinctOfferIds)) {
921.                 array_push($distinctOfferIds, $value['offerId']);
922.             }
923.         }
927.         foreach ($retentionOptimisationData as $key => $value) {
930.             // $retentionOptimisationData[$key]['offerName'] = $offerInfo[$value['offerId']]['name'] ?? "";
931.             // $retentionOptimisationData[$key]['advertiserId'] = $offerInfo[$value['offerId']]['advertiserId'] ?? "";
932.             // $retentionOptimisationData[$key]['advertiserName'] = $offerInfo[$value['offerId']]['Advertiser']['company'] ?? "";
933.             // $retentionOptimisationData[$key]['advertiserName'] = array_key_exists($offerInfo[$value['offerId']]['advertiserId'], $advertiserList) ? $advertiserList[$offerInfo[$value['offerId']]['advertiserId']]['name'] : '';
934.             // $retentionOptimisationData[$key]['goalName'] = $offerInfo[$value['offerId']]['Goal'][$value['goalId']]['name'] ?? "";
935.             $retentionOptimisationData[$key]['dateInserted'] = $value['dateUpdated']->format("Y-m-d H:s:i");
936.         }
938.         return array_values($retentionOptimisationData);
939.     }
941.     public function changeCamelCaseToWords($camelCaseString)
942.     {
944.         return ucfirst(implode(" ", preg_split('/(?=[A-Z])/', $camelCaseString)));
945.     }
947.     public function setOfferAffiliateCap($affiliateId, $offerId, $affiliateOfferCapType, $capValue, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
948.     {
949.         $capExist = $this->em->getCombinationFromAffiliateOfferCapping($affiliateId, $offerId, $affiliateOfferCapType, $tuneAccount);
951.         if (!$capExist || ($capExist->getCapValue() != $capValue)) {
952.             if ($capExist) {
953.                 $this->em->deleteAffiliateOfferCapById($capExist->getId());
954.             }
956.             $hoResponse = $this->brandApi->setAffiliateOfferCap($affiliateId, $offerId, $affiliateOfferCapType, $capValue, $tuneAccount);
958.             if ($hoResponse['response']['status'] == 1) {
959.                 $this->em->insertToAffiliateOfferCap($affiliateId, $offerId, $affiliateOfferCapType, $capValue, $tuneAccount);
960.             }
961.         }
962.     }
964.     public function getImpressionOptimisationData()
965.     {
966.         $impressionOptimisations = $this->em->getActiveImpressionOptimisation();
967.         foreach ($impressionOptimisations as $key => $value) {
968.             $impressionOptimisations[$key]['dateUpdated'] = $value['dateUpdated']->format("Y-m-d H:s:i");
969.             $impressionOptimisations[$key]['dateInserted'] = $value['dateInserted']->format("Y-m-d H:s:i");
970.         }
972.         return $impressionOptimisations;
973.     }
975.     public function createUpdateImpressionOptimisation($offerId, $affiliate_id, $ctr, $addedBy)
976.     {
978.         return $this->em->createUpdateImpression($offerId, $affiliate_id, $ctr, $addedBy);
979.     }
981.     public function getFraudFlagLogs($affiliateIdArray, $offerIdArray, $advertiserArray, $dateStart, $dateEnd)
982.     {
985.         $fraudFlagData = [];
987.         $fraudFlagData = $this->em->getFraudFlagLogs($affiliateIdArray, $offerIdArray, $advertiserArray, $dateStart, $dateEnd);
989.         //                foreach ($fraudFlagData as $key => $value) {
990.         //                    $fraudFlagData[$key]['dateInserted'] = $value['dateInserted']->format('Y-m-d H:i:s');
991.         //                }
992.         $distinctOfferIdArr = [];
993.         $distinctAffiliateIdArr = [];
995.         foreach ($fraudFlagData as $key => $value) {
997.             if (!in_array($value['offerId'], $distinctOfferIdArr)) {
998.                 array_push($distinctOfferIdArr, $value['offerId']);
999.             }
1001.             if (!in_array($value['affiliateId'], $distinctAffiliateIdArr)) {
1002.                 array_push($distinctAffiliateIdArr, $value['affiliateId']);
1003.             }
1005.             $fraudFlagData[$key]['date_inserted'] = $value['dateInserted']->format('Y-m-d H:i:s');
1006.         }
1008.         if (!empty($distinctOfferIdArr)) {
1009.             $offerInfo = $this->brandApi->getOffersByOfferIdsArr($distinctOfferIdArr)['response']['data'];
1010.         }
1011.         if (!empty($distinctAffiliateIdArr)) {
1012.             $affiliateInfo = $this->brandApi->getAffiliatesByAffiliateIdArr($distinctAffiliateIdArr)['response']['data'];
1013.         }
1015.         foreach ($fraudFlagData as $key => $value) {
1016.             $offerName = $offerInfo[$value['offerId']]['Offer']['name'] ?? '';
1017.             $advertiserName = $offerInfo[$value['offerId']]['Advertiser']['company'] ?? '';
1018.             $advertiserId = $offerInfo[$value['offerId']]['Advertiser']['id'] ?? '';
1019.             $affiliateName = $affiliateInfo[$value['affiliateId']]['Affiliate']['company'] ?? '';
1022.             $fraudFlagData[$key]['affiliateName'] = $affiliateName;
1023.             $fraudFlagData[$key]['advertiserName'] = $advertiserName;
1024.             $fraudFlagData[$key]['advertiserId'] = $advertiserId;
1025.             $fraudFlagData[$key]['offerName'] = $offerName;
1026.         }
1028.         return $fraudFlagData;
1029.     }
1031.     public function deleteFraudFlagLogs($id)
1032.     {
1033.         $this->em->deleteFraudFlagLogs($id);
1034.     }
1036.     public function blockOfferForAffiliate($offerId, $affiliateId, $blockType, $blockedFrom, $conversions, $clicks, $ltr, $trackingAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
1037.     {
1039.         $combinationExist = $this->doctrine->getRepository('App\Entity\AffiliateOfferBlock')->findOneBy([
1040.             'offerId' => $offerId,
1041.             'affiliateId' => $affiliateId,
1042.             'trackingAccount' => $trackingAccount
1043.         ]);
1045.         $affiliateOfferBlockedInHO = $this->brandApi->getAffiliateOfferBlock($offerId, $affiliateId, $trackingAccount)['response']['data']['data'];
1047.         if (array_key_exists($offerId, $affiliateOfferBlockedInHO) && $affiliateOfferBlockedInHO[$offerId]['OfferAffiliateBlock']['affiliate_id'] == $affiliateId && !$combinationExist) {
1048.             return false;
1049.         }
1052.         if (!$combinationExist) {
1053.             if ($blockType === Config::AFFILIATE_OFFER_BLOCK_MACRO) {
1054.                 $hoResponse = $this->brandApi->blockOfferAffiliate($offerId, $affiliateId, $trackingAccount);
1055.             } elseif ($blockType === Config::AFFILIATE_OFFER_UNBLOCK_MACRO) {
1056.                 $hoResponse = $this->brandApi->unblockOfferAffiliate($offerId, $affiliateId, $trackingAccount);
1057.             }
1058.             if (isset($hoResponse['response']['status']) && $hoResponse['response']['status'] == 1) {
1059.                 $this->doctrine->getRepository('App\Entity\AffiliateOfferBlock')->insertToOfferAffiliateBlock($offerId, $affiliateId, $blockType, $blockedFrom, $conversions, $clicks, $ltr, $trackingAccount);
1061.                 //            Removing dump from mysql and added dump of AffiliateOfferBlock to mongo
1062.                 //                $this->doctrine->getRepository('App\Entity\AffiliateOfferBlockLogs')->insertToOfferAffiliateBlockLogs($offerId, $affiliateId, $blockType, $blockedFrom, $conversions, $clicks, $ltr, $trackingAccount);
1063.                 return true;
1064.             }
1065.         }
1066.         return false;
1067.     }
1069.     public function deleteOfferAffiliateBlock($offerId, $affiliateId, $trackingAccount)
1070.     {
1072.         $hoResponse = $this->brandApi->unblockOfferAffiliate($offerId, $affiliateId, $trackingAccount);
1073.         if ($hoResponse['response']['status'] == 1) {
1074.             $this->doctrine->getRepository('App\Entity\AffiliateOfferBlock')->deleteOfferAffiliateBlock($offerId, $affiliateId, $trackingAccount);
1075.         }
1076.     }
1078.     public function populateDbByOfferId($offerId, $metaData = [])
1079.     {
1080.         $calledFromCronJob = $metaData['calledFromCronJob'] ?? true;
1081.         $tuneAccount = $metaData['tuneAccount'] ?? Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE;
1083.         $offerExistInDB = $this->doctrine->getRepository('App\Entity\OfferInfo')->findOneBy([
1084.             'offerId' => $offerId,
1085.             'tuneAccount' => $tuneAccount
1086.         ]);
1087.         $offerInfo[$offerId] = $this->brandApi->getOfferByOfferId($offerId, $tuneAccount)['response']['data'];
1088.         $offerIpWhitelistHoData = $this->brandApi->getIpWhitelistByOfferId($offerId, $tuneAccount)['response']['data'];
1089.         $offerFileCreativesHoData = $this->brandApi->getOfferFilesByOfferId($offerId, $tuneAccount);
1091.         $offerIpWhitelistArray = [];
1092.         foreach ($offerIpWhitelistHoData as $key => $value) {
1093.             if ($value['OfferWhitelist']['type'] == Config::OFFER_IP_WHITELIST_TYPE_POSTBACK) {
1094.                 array_push($offerIpWhitelistArray, $value['OfferWhitelist']['content']);
1095.             }
1096.         }
1098.         $offerCountryIdArray = isset($offerInfo[$offerId]['Country']) ? array_keys($offerInfo[$offerId]['Country']) : [];
1099.         $offerCategoryIdArray = isset($offerInfo[$offerId]['OfferCategory']) ? array_keys($offerInfo[$offerId]['OfferCategory']) : [];
1100.         $offerTagIdArray = isset($offerInfo[$offerId]['OfferTag']) ? array_keys($offerInfo[$offerId]['OfferTag']) : [];
1102.         $offerGoalArray = isset($offerInfo[$offerId]['Goal']) ? array_values($offerInfo[$offerId]['Goal']) : [];
1103.         foreach ($offerGoalArray as $key => $value) {
1104.             foreach ($value as $k => $v) {
1105.                 $offerGoalArray[$key][lcfirst(implode('', array_map('ucfirst', explode('_', $k))))] = $v;
1106.                 if ($this->checkForString($k, '_')) {
1107.                     unset($offerGoalArray[$key][$k]);
1108.                 }
1109.             }
1110.         }
1112.         if ($offerExistInDB) {
1114.             $offerDataToUpdate = [];
1115.             foreach ($offerInfo[$offerId]['Offer'] as $key => $value) {
1116.                 $appId = $this->scraper->getAppId($offerInfo[$offerId]['Offer']['preview_url']);
1117.                 if (!$appId) {
1118.                     $appId = 'Not Found';
1119.                 }
1120.                 $offerDataToUpdate['appId'] = $appId;
1121.                 $offerDataToUpdate[lcfirst(implode('', array_map('ucfirst', explode('_', $key))))] = $value;
1122.             }
1124.             $offerDataToUpdate['geoIdsJson'] = json_encode($offerCountryIdArray);
1125.             $offerDataToUpdate['categoryIdsJson'] = json_encode($offerCategoryIdArray);
1126.             $offerDataToUpdate['tagIdsJson'] = json_encode($offerTagIdArray);
1127.             // $offerDataToUpdate['whitelistIpsJson'] = json_encode($offerIpWhitelistArray);
1129.             if ($offerInfo[$offerId]['Thumbnail'] && isset($offerInfo[$offerId]['Thumbnail']['preview_uri'])) {
1130.                 $offerDataToUpdate['thumbnail'] = $offerInfo[$offerId]['Thumbnail']['preview_uri'];
1131.             }
1133.             $this->doctrine->getRepository(OfferInfo::class)->updateOfferByOfferId($offerId, $offerDataToUpdate, $tuneAccount);
1134.         } else {
1136.             $offerValue = $offerInfo[$offerId];
1138.             $domain = $offerInfo[$offerId]['Hostname']['domain'] ?? '';
1140.             $appId = $this->scraper->getAppId($offerValue['Offer']['preview_url']);
1141.             if (!$appId) {
1142.                 $appId = 'Not Found';
1143.             }
1144.             $offerValue['Offer']['app_id'] = $appId;
1145.             if (!$offerValue['Offer']['advertiser_id']) {
1146.                 $offerValue['Offer']['advertiser_id'] = 0;
1147.             }
1148.             $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, null);
1149.         }
1151.         $this->mafoObjectsComponents->createOrUpdateOffer($tuneAccount, $offerId);
1153.         foreach ($offerGoalArray as $key => $value) {
1154.             $goalExistInDB = $this->doctrine->getRepository(OfferGoalsInfo::class)->findOneBy(['goalId' => $value['id'], 'tuneAccount' => $tuneAccount]);
1156.             if ($goalExistInDB) {
1157.                 $this->doctrine->getRepository(OfferGoalsInfo::class)->updateGoalByGoalId($value['id'], $value, $tuneAccount);
1158.             } else {
1159.                 $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);
1160.             }
1161.         }
1163.         if ($calledFromCronJob) {
1164.             $this->scraper->getAppDetailsByPreviewUrl($offerInfo[$offerId]['Offer']['preview_url']);
1167.             if (is_array($offerTagIdArray)) {
1168.                 $this->doctrine->getRepository(OfferTagRelationship::class)->deleteOfferTagRelationByOfferId($offerId, $tuneAccount);
1169.                 foreach ($offerTagIdArray as $tagId) {
1170.                     $this->doctrine->getRepository(OfferTagRelationship::class)->insertToOfferTagRelationship($offerId, $tagId, $tuneAccount);
1171.                 }
1172.             }
1174.             if (is_array($offerCategoryIdArray)) {
1175.                 $this->doctrine->getRepository(OfferCategoryRelationship::class)->deleteOfferCategoryRelationByOfferId($offerId, $tuneAccount);
1176.                 foreach ($offerCategoryIdArray as $categoryId) {
1177.                     $this->doctrine->getRepository(OfferCategoryRelationship::class)->insertToOfferCategoryRelationship($offerId, $categoryId, $tuneAccount);
1178.                 }
1179.             }
1181.             if (is_array($offerCountryIdArray)) {
1182.                 $this->doctrine->getRepository(OfferGeoRelationship::class)->deleteOfferGeoRelationByOfferId($offerId, $tuneAccount);
1183.                 foreach ($offerCountryIdArray as $geo) {
1184.                     $this->doctrine->getRepository(OfferGeoRelationship::class)->insertToOfferGeoRelationship($offerId, $geo, $tuneAccount);
1185.                 }
1186.             }
1187.         }
1189.         if (!$calledFromCronJob) {
1191.             $offerWhitelistIdArrFromHO = [];
1192.             foreach ($offerIpWhitelistHoData as $key => $value) {
1193.                 $value = $value['OfferWhitelist'];
1194.                 $value['tuneAccount'] = $tuneAccount;
1196.                 $offerWhitelistExist = $this->doctrine->getRepository(OfferWhitelist::class)->findOneBy(['whitelistId' => $value['id'], 'tuneAccount' => $tuneAccount]);
1198.                 if (!$offerWhitelistExist) {
1199.                     $this->doctrine->getRepository(OfferWhitelist::class)->insertToOfferWhitelist($value['id'], $value['offer_id'], $value['type'], $value['content_type'], $value['content'], $tuneAccount);
1200.                 } else {
1201.                     $this->doctrine->getRepository(OfferWhitelist::class)->updateOfferWhitelistByWhitelistId($value['id'], $value, $tuneAccount);
1202.                 }
1203.                 array_push($offerWhitelistIdArrFromHO, $value['id']);
1204.             }
1206.             if (sizeof($offerWhitelistIdArrFromHO)) {
1207.                 $offerWhitelistToBeDeleted = $this->doctrine->getRepository(OfferWhitelist::class)->getDeletedOfferWhitelistIds($offerId, $offerWhitelistIdArrFromHO, $tuneAccount);
1208.                 foreach ($offerWhitelistToBeDeleted as $key => $value) {
1209.                     $this->doctrine->getRepository(OfferWhitelist::class)->deleteByWhitelistId($value['whitelistId'], $tuneAccount);
1210.                 }
1211.             }
1214.             foreach ($offerFileCreativesHoData as $key => $value) {
1215.                 $fileExist = $this->doctrine->getRepository(OfferCreativeFile::class)->findOneBy(['fileId' => $key, 'tuneAccount' => $tuneAccount]);
1216.                 if (isset($value['OfferFile'])) {
1217.                     if (!$fileExist) {
1218.                         $response = $value['OfferFile'];
1219.                         if ($response['status'] == Config::DELETED_STATUS || $response['status'] == Config::PENDING_STATUS) {
1220.                             continue;
1221.                         }
1222.                         $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);
1223.                     } elseif ($fileExist->getStatus() != $value['OfferFile']['status']) {
1224.                         $this->doctrine->getRepository(OfferCreativeFile::class)->updateStatusByFileId($value['OfferFile']['id'], $value['OfferFile']['status'], $tuneAccount);
1225.                     }
1226.                 }
1227.             }
1228.         }
1229.     }
1231.     public function updateOffer($offerId, $offerDetails, $offerCountries, $offerCategories, $offerTags, $offerWhitelistIps, $tuneAccount)
1232.     {
1233.         $offerCreateHoResponse = $this->brandApi->createOrUpdateOffer($offerId, $offerDetails, $tuneAccount);
1235.         if ($offerCreateHoResponse['response']['status'] === 1) {
1236.             $offerInfo = $offerCreateHoResponse['response']['data']['Offer'];
1237.             $offerId = $offerInfo['id'];
1239.             $this->doctrine->getRepository(OfferInfo::class)->updateOfferByOfferId($offerId, $offerDetails, $tuneAccount);
1241.             $this->updateOfferCountries($offerId, $offerCountries, $tuneAccount);
1242.             $this->updateOfferCategories($offerId, $offerCategories, $tuneAccount);
1243.             $this->updateOfferTags($offerId, $offerTags, $tuneAccount);
1244.             $this->updateOfferWhitelist($offerId, $offerWhitelistIps, $tuneAccount);
1245.             $this->mafoObjectsComponents->createOrUpdateOffer($tuneAccount, $offerId);
1246.         }
1248.         return $offerCreateHoResponse;
1249.     }
1251.     public function createNewOffer($offerDetails, $offerCountries, $offerCategories, $offerTags, $offerWhitelistIps, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
1252.     {
1254.         $offerCreateHoResponse = $this->brandApi->createOrUpdateOffer(null, $offerDetails, $tuneAccount);
1256.         if ($offerCreateHoResponse['response']['status'] === 1) {
1258.             $offerInfo = $offerCreateHoResponse['response']['data']['Offer'];
1259.             $offerId = $offerInfo['id'];
1261.             $appId = $this->scraper->getAppId($offerInfo['preview_url']);
1262.             if (!$appId) {
1263.                 $appId = 'Not Found';
1264.             }
1265.             $offerInfo['app_id'] = $appId;
1267.             $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, null);
1269.             $this->updateOfferCountries($offerId, $offerCountries, $tuneAccount);
1270.             $this->updateOfferCategories($offerId, $offerCategories, $tuneAccount);
1271.             $this->updateOfferTags($offerId, $offerTags, $tuneAccount);
1272.             $this->updateOfferWhitelist($offerId, $offerWhitelistIps, $tuneAccount);
1273.             $this->mafoObjectsComponents->createOrUpdateOffer($tuneAccount, $offerId);
1276.             $appDetails = $this->scraper->getAppDetailsByPreviewUrl($offerInfo['preview_url']);
1278.             if ($appDetails) {
1279.                 $fileResponse = $this->uploadFile($offerId, $appDetails['icon'], Config::FILE_TYPE_THUMBNAIL, 0);
1280.                 if ($fileResponse['response']['status'] == 1) {
1281.                     $this->doctrine->getRepository('App\Entity\OfferInfo')->updateOfferByOfferId($offerId, ['thumbnail' => $fileResponse['response']['data']['OfferFile']['url']], $tuneAccount);
1282.                 }
1283.             }
1284.         }
1286.         return $offerCreateHoResponse;
1287.     }
1289.     public function updateOfferCountries($offerId, $offerCountries, $tuneAccount)
1290.     {
1292.         $savedOfferInfo = $this->doctrine->getRepository('App\Entity\OfferInfo')->findOneBy(['offerId' => $offerId, 'tuneAccount' => $tuneAccount]);
1293.         $savedGeos = json_decode($savedOfferInfo->getGeoIdsJson(), true);
1294.         foreach ($savedGeos as $geo) {
1295.             if (!in_array($geo, $offerCountries)) {
1296.                 $this->brandApi->removeGeoFromOffer($offerId, $geo, $tuneAccount);
1297.             }
1298.         }
1299.         foreach ($offerCountries as $geo) {
1300.             $this->brandApi->addGeoToOffer($offerId, $geo, $tuneAccount);
1301.         }
1303.         $this->doctrine->getRepository('App\Entity\OfferInfo')->updateOfferByOfferId($offerId, ['geoIdsJson' => json_encode($offerCountries)], $tuneAccount);
1304.     }
1306.     public function updateOfferCategories($offerId, $offerCategories, $tuneAccount)
1307.     {
1308.         if (is_array($offerCategories) && count($offerCategories) > 0) {
1309.             $this->brandApi->setCategoryToOffer($offerId, $offerCategories, $tuneAccount);
1310.             $this->doctrine->getRepository('App\Entity\OfferInfo')->updateOfferByOfferId($offerId, ['categoryIdsJson' => json_encode($offerCategories)], $tuneAccount);
1311.         }
1312.     }
1314.     public function updateOfferTags($offerId, $offerTags, $tuneAccount)
1315.     {
1316.         if (is_array($offerTags) && count($offerTags) > 0) {
1317.             foreach ($offerTags as $tagId) {
1318.                 $this->brandApi->addTagToOffer($offerId, $tagId, $tuneAccount);
1319.             }
1320.             $this->doctrine->getRepository('App\Entity\OfferInfo')->updateOfferByOfferId($offerId, ['tagIdsJson' => json_encode($offerTags)], $tuneAccount);
1321.         }
1322.     }
1324.     public function updateOfferWhitelist($offerId, $offerWhitelistIps, $tuneAccount)
1325.     {
1326.         if (is_array($offerWhitelistIps) && count($offerWhitelistIps) > 0) {
1327.             foreach ($offerWhitelistIps as $whitelistIp) {
1328.                 $this->brandApi->addIpWhitelistToOffer($offerId, $whitelistIp, Config::OFFER_IP_WHITELIST_CONTENT_TYPE_IP_ADDRESS, Config::OFFER_IP_WHITELIST_TYPE_POSTBACK, $tuneAccount);
1329.             }
1330.             // echo json_encode($offerWhitelistIps);
1331.             // $this->doctrine->getRepository('App\Entity\OfferInfo')->updateOfferByOfferId($offerId, ['whitelistIpsJson' => json_encode($offerWhitelistIps)], $tuneAccount);
1332.         }
1333.     }
1335.     public function updateOfferGoal($goalId, $offerGoalDetails, $tuneAccount)
1336.     {
1338.         if (isset($offerGoalDetails['goal_id'])) {
1339.             unset($offerGoalDetails['goal_id']);
1340.         }
1341.         $offerGoalCreateHoResponse = $this->brandApi->createOrUpdateOfferGoal($goalId, $offerGoalDetails, $tuneAccount);
1343.         if ($offerGoalCreateHoResponse['response']['status'] === 1) {
1344.             $dataToUpdate = [];
1345.             foreach ($offerGoalCreateHoResponse['response']['data']['Goal'] as $key => $value) {
1346.                 if ($key === 'id') {
1347.                     continue;
1348.                 }
1349.                 $dataToUpdate[$this->convertStringFromSnakeCaseToCamelCase($key)] = $value;
1350.             }
1352.             $this->doctrine->getRepository(OfferGoalsInfo::class)->updateGoalByGoalId($goalId, $dataToUpdate, $tuneAccount);
1353.         }
1355.         return $offerGoalCreateHoResponse;
1356.     }
1359.     public function createNewOfferGoal($offerGoalDetails, $tuneAccount)
1360.     {
1361.         $offerGoalCreateHoResponse = $this->brandApi->createOrUpdateOfferGoal(null, $offerGoalDetails, $tuneAccount);
1362.         if ($offerGoalCreateHoResponse['response']['status'] === 1) {
1363.             $offerGoalCreateHoResponseData = $offerGoalCreateHoResponse['response']['data']['Goal'];
1364.             $this->doctrine->getRepository(OfferGoalsInfo::class)->insertToOfferGoalsInfo(
1365.                 $offerGoalCreateHoResponseData['id'],
1366.                 $offerGoalCreateHoResponseData['offer_id'],
1367.                 $offerGoalCreateHoResponseData['name'],
1368.                 $offerGoalCreateHoResponseData['description'],
1369.                 $offerGoalCreateHoResponseData['status'],
1370.                 $offerGoalCreateHoResponseData['is_private'],
1371.                 $offerGoalCreateHoResponseData['payout_type'],
1372.                 $offerGoalCreateHoResponseData['default_payout'],
1373.                 $offerGoalCreateHoResponseData['revenue_type'],
1374.                 $offerGoalCreateHoResponseData['max_payout'],
1375.                 $offerGoalCreateHoResponseData['tiered_payout'],
1376.                 $offerGoalCreateHoResponseData['tiered_revenue'],
1377.                 $offerGoalCreateHoResponseData['use_payout_groups'],
1378.                 $offerGoalCreateHoResponseData['use_revenue_groups'],
1379.                 $offerGoalCreateHoResponseData['advertiser_id'],
1380.                 $offerGoalCreateHoResponseData['protocol'],
1381.                 $offerGoalCreateHoResponseData['allow_multiple_conversions'],
1382.                 $offerGoalCreateHoResponseData['approve_conversions'],
1383.                 $offerGoalCreateHoResponseData['enforce_encrypt_tracking_pixels'],
1384.                 $offerGoalCreateHoResponseData['is_end_point'],
1385.                 $offerGoalCreateHoResponseData['ref_id'],
1386.                 $tuneAccount
1387.             );
1388.         }
1390.         return $offerGoalCreateHoResponse;
1391.     }
1393.     public function uploadFile($offerId, $fileUrlToUpload, $creativeType, $isPrivate)
1394.     {
1395.         $fileData = @file_get_contents($fileUrlToUpload);
1396.         $fileExtension = pathinfo($fileUrlToUpload, PATHINFO_EXTENSION);
1397.         $fileName = $fileExtension === '' ? $offerId . "_" . basename($fileUrlToUpload) . '.png' : $offerId . "_" . basename($fileUrlToUpload);
1398.         file_put_contents($fileName, $fileData);
1399.         $fileResponse = $this->brandApi->offerFileAPI($offerId, $creativeType, $fileName, $fileName, $isPrivate);
1400.         unlink($fileName);
1401.         return $fileResponse;
1402.     }
1404.     public function convertStringFromCamelCaseToSnakeCase($input)
1405.     {
1406.         preg_match_all('!([A-Z][A-Z0-9]*(?=$|[A-Z][a-z0-9])|[A-Za-z][a-z0-9]+)!', $input, $matches);
1407.         $ret = $matches[0];
1408.         foreach ($ret as &$match) {
1409.             $match = $match == strtoupper($match) ? strtolower($match) : lcfirst($match);
1410.         }
1411.         return implode('_', $ret);
1412.     }
1414.     public function convertStringFromSnakeCaseToCamelCase($input)
1415.     {
1416.         return lcfirst(implode('', array_map('ucfirst', explode('_', $input))));
1417.     }
1419.     public function getScraper()
1420.     {
1421.         return $this->scraper;
1422.     }
1424.     public function getOfferListByOfferIdArr($offerIdArr)
1425.     {
1427.         $response = [];
1429.         if ($offerIdArr) {
1430.             $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->getOffersByOfferIdsArr($offerIdArr);
1432.             foreach ($offerInfo as $key => $value) {
1433.                 $response[$value['offerId']] = [
1434.                     'id' => (int)$value['offerId'],
1435.                     'name' => $value['name']
1436.                 ];
1437.             }
1438.         }
1440.         return $response;
1441.     }
1443.     public function checkOfferAffiliateCapping($offerId, $affiliateId, $goalId)
1444.     {
1446.         $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->getOfferDataByOfferId($offerId);
1448.         if (!$offerInfo) {
1449.             return false;
1450.         }
1452.         $conversionCapByOfferIdHOData = $this->brandApi->getCappingByOfferId($offerId)['response']['data'];
1454.         $conversionCap = $offerInfo->getConversionCap();
1455.         $payoutCap = $offerInfo->getPayoutCap();
1456.         $revenueCap = $offerInfo->getRevenueCap();
1458.         $monthlyConversionCap = $offerInfo->getMonthlyConversionCap();
1459.         $monthlyPayoutCap = $offerInfo->getMonthlyPayoutCap();
1460.         $monthlyRevenueCap = $offerInfo->getMonthlyRevenueCap();
1462.         foreach ($conversionCapByOfferIdHOData as $key => $value) {
1463.             if ($value['OfferConversionCap']['offer_id'] == $offerId && $value['OfferConversionCap']['affiliate_id'] == $affiliateId) {
1465.                 $conversionCap = $value['OfferConversionCap']['conversion_cap'];
1466.                 $payoutCap = $value['OfferConversionCap']['payout_cap'];
1467.                 $revenueCap = $value['OfferConversionCap']['revenue_cap'];
1469.                 $monthlyConversionCap = $value['OfferConversionCap']['monthly_conversion_cap'];
1470.                 $monthlyPayoutCap = $value['OfferConversionCap']['monthly_payout_cap'];
1471.                 $monthlyRevenueCap = $value['OfferConversionCap']['monthly_revenue_cap'];
1473.                 break;
1474.             }
1475.         }
1477.         $dailyConversionGenerated = 0;
1478.         $dailyPayoutGenerated = 0;
1479.         $dailyRevenueGenerated = 0;
1481.         $monthlyConversionGenerated = 0;
1482.         $monthlyPayoutGenerated = 0;
1483.         $monthlyRevenueGenerated = 0;
1485.         $statByDay = $this->brandApi->getStatsForCappingCheck($offerId, $affiliateId, $goalId, true, false)['response']['data']['data'];
1487.         if (!empty($statByDay)) {
1488.             $dailyConversionGenerated = $statByDay[0]['Stat']['conversions'];
1489.             $dailyPayoutGenerated = $statByDay[0]['Stat']['payout'];
1490.             $dailyRevenueGenerated = $statByDay[0]['Stat']['revenue'];
1491.         }
1493.         $statByMonth = $this->brandApi->getStatsForCappingCheck($offerId, $affiliateId, $goalId, false, true)['response']['data']['data'];
1495.         if (!empty($statByMonth) && isset($statByDay[0])) {
1496.             $monthlyConversionGenerated = $statByDay[0]['Stat']['conversions'];
1497.             $monthlyPayoutGenerated = $statByDay[0]['Stat']['payout'];
1498.             $monthlyRevenueGenerated = $statByDay[0]['Stat']['revenue'];
1499.         }
1501.         $conversionCapReached = $dailyConversionGenerated >= $conversionCap && $conversionCap != 0;
1502.         $payoutCapReached = $dailyPayoutGenerated >= $payoutCap && $payoutCap != 0;
1503.         $revenueCapReached = $dailyRevenueGenerated >= $revenueCap && $revenueCap != 0;
1505.         $monthlyConversionCapReached = $monthlyConversionGenerated >= $monthlyConversionCap && $monthlyConversionCap != 0;
1506.         $monthlyPayoutCapReached = $monthlyPayoutGenerated >= $monthlyPayoutCap && $monthlyPayoutCap != 0;
1507.         $monthlyRevenueCapReached = $monthlyRevenueGenerated >= $monthlyRevenueCap && $monthlyRevenueCap != 0;
1509.         $cappingReached = false;
1510.         if ($conversionCapReached || $payoutCapReached || $revenueCapReached || $monthlyConversionCapReached || $monthlyPayoutCapReached || $monthlyRevenueCapReached) {
1511.             $cappingReached = true;
1512.         }
1514.         return [
1515.             'conversionCap' => $conversionCap,
1516.             'payoutCap' => $payoutCap,
1517.             'revenueCap' => $revenueCap,
1518.             'monthlyConversionCap' => $monthlyConversionCap,
1519.             'monthlyPayoutCap' => $monthlyPayoutCap,
1520.             'monthlyRevenueCap' => $monthlyRevenueCap,
1521.             'dailyConversionGenerated' => $dailyConversionGenerated,
1522.             'dailyPayoutGenerated' => $dailyPayoutGenerated,
1523.             'dailyRevenueGenerated' => $dailyRevenueGenerated,
1524.             'monthlyConversionGenerated' => $monthlyConversionGenerated,
1525.             'monthlyPayoutGenerated' => $monthlyPayoutGenerated,
1526.             'monthlyRevenueGenerated' => $monthlyRevenueGenerated,
1527.             'conversionCapReached' => $conversionCapReached,
1528.             'payoutCapReached' => $payoutCapReached,
1529.             'revenueCapReached' => $revenueCapReached,
1530.             'monthlyConversionCapReached' => $monthlyConversionCapReached,
1531.             'monthlyPayoutCapReached' => $monthlyPayoutCapReached,
1532.             'monthlyRevenueCapReached' => $monthlyRevenueCapReached,
1533.             'cappingReached' => $cappingReached
1534.         ];
1535.     }
1538.     public function appsBlackAndWhiteList($data)
1539.     {
1541.         $dateRange = 30;
1542.         $minClicks = 100;
1543.         $dataToProcess = [];
1545.         foreach ($data as $key => $value) {
1546.             $value['offerId'] ? $dataToProcess['offer'][$value['offerId']][$value['param']][$value['listType']][] = $value['appId'] : false;
1547.             $value['advertiserId'] ? $dataToProcess['advertiser'][$value['advertiserId']][$value['param']][$value['listType']][] = $value['appId'] : false;
1548.             $value['affiliateId'] ? $dataToProcess['affiliate'][$value['affiliateId']][$value['param']][$value['listType']][] = $value['appId'] : false;
1549.         }
1551.         $dataToBlock = [];
1552.         foreach ($dataToProcess as $entityType => $entity) {
1553.             foreach ($entity as $entityId => $entityData) {
1554.                 foreach ($entityData as $param => $paramData) {
1556.                     $advertiserId = $entityType == 'advertiser' ? $entityId : null;
1557.                     $affiliateId = $entityType == 'affiliate' ? $entityId : null;
1558.                     $offerId = $entityType == 'offer' ? $entityId : null;
1560.                     if ($advertiserId) {
1561.                         $addedFrom = Config::DISABLE_LINK_FROM_APPS_BLACK_AND_WHITE_LIST_BY_ADVERTISER;
1562.                     } elseif ($affiliateId) {
1563.                         $addedFrom = Config::DISABLE_LINK_FROM_APPS_BLACK_AND_WHITE_LIST_BY_AFFILIATE;
1564.                     } else {
1565.                         $addedFrom = Config::DISABLE_LINK_FROM_APPS_BLACK_AND_WHITE_LIST_BY_OFFER;
1566.                     }
1568.                     if ($advertiserId == null && $affiliateId == null && $offerId == null) {
1569.                         continue;
1570.                     }
1572.                     $statData = $this->brandApi->getStatsForAppBlackAndWhiteList($offerId, $affiliateId, $advertiserId, $dateRange, $minClicks, $param)['response']['data']['data'];
1574.                     foreach ($paramData as $listType => $appIds) {
1575.                         foreach ($statData as $key => $value) {
1576.                             $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->findOneBy(['offerId' => $value['Stat']['offer_id']]);
1577.                             if (
1578.                                 !$offerInfo ||
1579.                                 !in_array($offerInfo->getAppId(), $appIds)
1580.                             ) {
1581.                                 continue;
1582.                             }
1583.                             $temp = [
1584.                                 'offerId' => $value['Stat']['offer_id'],
1585.                                 'affiliateId' => $value['Stat']['affiliate_id'],
1586.                                 'advertiserId' => $value['Stat']['advertiser_id'],
1587.                                 'param' => $param,
1588.                                 'paramValue' => $value['Stat'][$param],
1589.                                 'clicks' => $value['Stat']['clicks'],
1590.                                 'conversions' => $value['Stat']['conversions'],
1591.                                 'addedFrom' => $addedFrom,
1592.                                 'listType' => $listType
1593.                             ];
1595.                             if (array_key_exists('blacklist', $paramData) && in_array($value['Stat'][$param], $paramData['blacklist'])) {
1596.                                 $dataToBlock[] = $temp;
1597.                             }
1599.                             if (array_key_exists('whitelist', $paramData) && !in_array($value['Stat'][$param], $paramData['whitelist'])) {
1600.                                 $dataToBlock[] = $temp;
1601.                             }
1602.                         }
1603.                     }
1604.                 }
1605.             }
1606.         }
1608.         return $dataToBlock;
1609.     }
1611.     public function setAffiliateOfferApproval($offerId, $affiliateId, $status, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
1612.     {
1614.         $combinationExist = $this->doctrine->getRepository(AffiliateOfferApproval::class)->checkIfOfferApproved($offerId, $affiliateId, $tuneAccount);
1616.         if ($combinationExist && $combinationExist->getApprovalStatus() != $status) {
1617.             $hoResponse = $this->brandApi->setOfferApprovalForAffiliate($offerId, $affiliateId, $status, $tuneAccount);
1618.             if ($hoResponse['response']['status'] == 1) {
1619.                 $this->doctrine->getRepository(AffiliateOfferApproval::class)->updateAffiliateOfferApprovalById($combinationExist->getId(), [
1620.                     'approvalStatus' => $status
1621.                 ]);
1622.             }
1623.         } elseif (!$combinationExist) {
1624.             $hoResponse = $this->brandApi->setOfferApprovalForAffiliate($offerId, $affiliateId, $status, $tuneAccount);
1625.             if ($hoResponse['response']['status'] == 1) {
1626.                 $this->doctrine->getRepository(AffiliateOfferApproval::class)->insertToAffiliateOfferApproval(null, $affiliateId, null, $offerId, null, null, null, $status, null, null, $tuneAccount);
1627.             }
1628.         }
1629.     }
1631.     public function disableLinkByExternalUrl($offerId, $advertiserId, $affiliateId, $source, $affSub2, $affSub3, $affSub5)
1632.     {
1634.         $stat = [
1635.             'offerId' => $offerId,
1636.             'advertiserId' => $advertiserId,
1637.             'affiliateId' => $affiliateId,
1638.             'source' => $source,
1639.             'affSub2' => $affSub2,
1640.             'affSub3' => $affSub3,
1641.             'affSub5' => $affSub5
1642.         ];
1644.         $link = Config::DISABLE_LINK_EXTERNAL_ENDPOINT . '?token=' . base64_encode(json_encode($stat));
1646.         return $link;
1647.     }
1649.     public function getOfferInfoByKey($offerIdArr, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
1650.     {
1652.         if (!is_array($offerIdArr) || !sizeof($offerIdArr)) {
1653.             return [];
1654.         }
1655.         $offerData = $this->doctrine->getRepository(OfferInfo::class)->getOffersByOfferIdsArr($offerIdArr, $tuneAccount);
1656.         $offerInfo = [];
1657.         foreach ($offerData as $key => $value) {
1658.             $offerInfo[$value['offerId']] = $value;
1659.         }
1661.         return $offerInfo;
1662.     }
1664.     public function getMafoOfferInfoByKey($offerIdArr)
1665.     {
1667.         if (!is_array($offerIdArr) || !sizeof($offerIdArr)) {
1668.             return [];
1669.         }
1670.         $offerData = $this->doctrine->getRepository(MafoOffers::class)->getMafoOffersByOfferIdsArr($offerIdArr);
1671.         $offerInfo = [];
1672.         foreach ($offerData as $key => $value) {
1673.             $offerInfo[$value['id']] = $value;
1674.         }
1676.         return $offerInfo;
1677.     }
1679.     public function getEmployeesByEmployeeId()
1680.     {
1682.         $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HO_EMPLOYEES_LIST);
1684.         if (!$cachedList) {
1685.             $employeeList = $this->getWarmedUpEmployeesByEmployeeId();
1686.         } else {
1687.             $employeeList = json_decode($cachedList, true);
1688.         }
1690.         ksort($employeeList);
1692.         return $employeeList;
1693.     }
1695.     public function getWarmedUpEmployeesByEmployeeId()
1696.     {
1698.         $employeesData = $this->doctrine->getRepository(Employees::class)->getEmployees();
1699.         $data = [];
1700.         foreach ($employeesData as $key => $value) {
1701.             $data[$value['employeeId']] = [
1702.                 'firstName' => $value['firstName'],
1703.                 'lastName' => $value['lastName'],
1704.                 'email' => $value['email'],
1705.                 'fullName' => $value['fullName']
1706.             ];
1707.         }
1709.         return $data;
1710.     }
1712.     public function getMd5ForMmpReport($advertiser, $offerCountry, $offerRegion, $offerCity, $appId, $event, $revenueModel, $payoutModel)
1713.     {
1715.         return md5(strtolower($advertiser) . '#' . strtolower($offerCountry) . '#' . strtolower($offerRegion) . '#' . strtolower($offerCity) . '#' . strtolower($appId) . '#' . strtolower($event) . '#' . strtolower($revenueModel) . '#' . strtolower($payoutModel));
1716.     }
1718.     public function updateAffiliateDBByIds($affiliateIds, $metaData)
1719.     {
1721.         $createApiKeyIfNotExist = $metaData['createApiKeyIfNotExist'] ?? false;
1722.         $tuneAccount = $metaData['tuneAccount'] ?? Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE;
1724.         $affiliateInfoArr = $this->brandApi->getAffiliateInfoByAffiliateIdsArr($affiliateIds, $tuneAccount)['response']['data'];
1725.         foreach ($affiliateInfoArr as $key => $value) {
1726.             $affiliateDBInfo = $this->doctrine->getRepository(AffiliateInfo::class)->findOneBy(['affiliateId' => $value['Affiliate']['id'], 'tuneAccount' => $tuneAccount]);
1727.             if ($affiliateDBInfo) {
1728.                 $this->doctrine->getRepository(AffiliateInfo::class)->updateAffiliateInfoByAffiliateId($value['Affiliate']['id'], [
1729.                     'status' => $value['Affiliate']['status'],
1730.                     'accountManagerId' => $value['AccountManager'] !== null ? $value['AccountManager']['id'] : null,
1731.                     'company' => $value['Affiliate']['company']
1732.                 ], $tuneAccount);
1733.             } else {
1734.                 $this->doctrine->getRepository(AffiliateInfo::class)->insertToAffiliateInfo($value['Affiliate']['id'], $value['Affiliate']['company'], $value['AccountManager'] !== null ? $value['AccountManager']['id'] : null, $value['Affiliate']['status'], $tuneAccount);
1735.             }
1737.             //            $this->mafoObjectsComponents->createOrUpdateAffiliate(Config::MAFO_SYSTEM_IDENTIFIER_TUNE, $value['Affiliate']['id']);
1738.             //            $execCommand = "php " . $this->rootPath . "/bin/console app:updateCache " . Config::CACHE_REDIS_HO_AFFILIATE_LIST_FOR_MULTISELECT . " --env=prod > /dev/null &";
1739.             //            exec($execCommand);
1741.             if ($value['AffiliateUser'] !== null) {
1742.                 foreach ($value['AffiliateUser'] as $k => $v) {
1743.                     if ($v['status'] == Config::ACTIVE_STATUS) {
1745.                         if ($createApiKeyIfNotExist) {
1746.                             $apiKeyData = $this->doctrine->getRepository(UserApiKey::class)->findOneBy(['affiliateId' => $value['Affiliate']['id'], 'tuneAccount' => $tuneAccount]);
1747.                             if (!$apiKeyData) {
1748.                                 $this->brandApi->generateApiKeyByUserId($k, $tuneAccount);
1749.                             }
1750.                         }
1752.                         $userApiData = $this->brandApi->getUserApiKey($k)['response']['data'];
1753.                         if ($userApiData) {
1755.                             $userApiKey = $this->doctrine->getRepository(UserApiKey::class)->findOneBy(['userId' => $k, 'tuneAccount' => $tuneAccount]);
1756.                             if ($userApiKey) {
1757.                                 $this->doctrine->getRepository(UserApiKey::class)->updateUserApiKeyByUserId($k, [
1758.                                     'affiliateId' => $value['Affiliate']['id'],
1759.                                     'userType' => $userApiData['user_type'],
1760.                                     'apiKey' => $userApiData['api_key'],
1761.                                     'apiKeyStatus' => $userApiData['status'],
1762.                                     'userStatus' => $v['status']
1763.                                 ], $tuneAccount);
1764.                             } else {
1765.                                 $this->doctrine->getRepository(UserApiKey::class)->insertToUserApiKey($value['Affiliate']['id'], $k, $userApiData['user_type'], $userApiData['api_key'], $userApiData['status'], $v['status'], $tuneAccount);
1766.                             }
1767.                         }
1768.                     }
1769.                 }
1770.             }
1772.             if ($value['AccountManager'] !== null) {
1773.                 $affiliateAccountManagerDBInfo = $this->doctrine->getRepository(AffiliateAccountManager::class)->findOneBy(['affiliateId' => $value['Affiliate']['id'], 'tuneAccount' => $tuneAccount]);
1775.                 if ($affiliateAccountManagerDBInfo) {
1776.                     $this->doctrine->getRepository(AffiliateAccountManager::class)->updateDataByAffiliateId($value['Affiliate']['id'], [
1777.                         'employeeId' => $value['AccountManager']['id'],
1778.                         'email' => $value['AccountManager']['email'],
1779.                         'firstName' => $value['AccountManager']['first_name'],
1780.                         'lastName' => $value['AccountManager']['last_name'],
1781.                         'status' => $value['AccountManager']['status'],
1782.                     ], $tuneAccount);
1783.                 } else {
1784.                     $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);
1785.                 }
1786.             }
1788.             $affiliateTagRelationship = $this->brandApi->getAffiliateTagRelationByAffiliateId($value['Affiliate']['id'], $tuneAccount);
1790.             if ($affiliateTagRelationship['response']['status'] == 1) {
1791.                 $affiliateTags = [];
1792.                 foreach ($affiliateTagRelationship['response']['data']['data'] as $k => $v) {
1793.                     !in_array($v['AffiliatesTags']['tag_id'], $affiliateTags) ? array_push($affiliateTags, $v['AffiliatesTags']['tag_id']) : false;
1794.                 }
1795.                 $affiliateDBTagsData = $this->doctrine->getRepository(AffiliateTagRelationship::class)->getAffiliateTagRelationshipByAffiliateId($value['Affiliate']['id'], $tuneAccount);
1796.                 $affiliateDBTags = [];
1797.                 foreach ($affiliateDBTagsData as $k => $v) {
1798.                     !in_array($v['tagId'], $affiliateDBTags) ? array_push($affiliateDBTags, $v['tagId']) : false;
1799.                 }
1801.                 if ($affiliateDBTags != $affiliateTags) {
1802.                     $this->doctrine->getRepository(AffiliateTagRelationship::class)->deleteAffiliateTagRelationshipByAffiliateId($value['Affiliate']['id'], $tuneAccount);
1803.                     foreach ($affiliateTags as $affiliateTag) {
1804.                         $this->doctrine->getRepository(AffiliateTagRelationship::class)->insertToAffiliateTagRelationship($affiliateTag, $value['Affiliate']['id'], $tuneAccount);
1805.                     }
1806.                 }
1807.             }
1808.         }
1809.     }
1811.     public function updateAdvertiserDBById($advertiserId, $metaData, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
1812.     {
1813.         $this->updateAdvertiserDBByIds([$advertiserId], $tuneAccount);
1816.         if ($this->doctrine->getRepository(AdvertiserInfo::class)->findOneBy(['advertiserId' => $advertiserId, 'tuneAccount' => $tuneAccount])) {
1817.             $advertiserDiscountType = $metaData['advertiserDiscountType'] ?? Config::ADVERTISER_DISCOUNT_TYPE_NO_DISCOUNT;
1818.             $advertiserDiscountValue = $metaData['advertiserDiscountValue'] ?? null;
1819.             if ($advertiserDiscountValue < 1 || $advertiserDiscountValue > 100) {
1820.                 $advertiserDiscountType = Config::ADVERTISER_DISCOUNT_TYPE_NO_DISCOUNT;
1821.                 $advertiserDiscountValue = null;
1822.             }
1823.             $this->doctrine->getRepository(AdvertiserInfo::class)->updateAdvertiserInfoByAdvertiserId($advertiserId, [
1824.                 'discountValue' => $advertiserDiscountType !== Config::ADVERTISER_DISCOUNT_TYPE_NO_DISCOUNT ? $advertiserDiscountValue : 0,
1825.                 'discountType' => $advertiserDiscountType,
1826.             ], $tuneAccount);
1827.         }
1828.     }
1830.     public function updateAdvertiserDBByIds($advertiserIds, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
1831.     {
1833.         $advertiserInfoArr = $this->brandApi->getAdvertiserInfoByAdvertiserIdsArr($advertiserIds, $tuneAccount)['response']['data'];
1835.         foreach ($advertiserInfoArr as $key => $value) {
1836.             $advertiserDBInfo = $this->doctrine->getRepository(AdvertiserInfo::class)->findOneBy([
1837.                 'advertiserId' => $value['Advertiser']['id'],
1838.                 'tuneAccount' => $tuneAccount
1839.             ]);
1840.             if ($advertiserDBInfo) {
1841.                 $this->doctrine->getRepository(AdvertiserInfo::class)->updateAdvertiserInfoByAdvertiserId($value['Advertiser']['id'], [
1842.                     'status' => $value['Advertiser']['status'],
1843.                     'accountManagerId' => $value['AccountManager'] !== null ? $value['AccountManager']['id'] : null,
1844.                     'company' => $value['Advertiser']['company']
1845.                 ], $tuneAccount);
1846.             } else {
1847.                 $this->doctrine->getRepository(AdvertiserInfo::class)->insertToAdvertiserInfo($value['Advertiser']['id'], $value['Advertiser']['company'], $value['AccountManager'] !== null ? $value['AccountManager']['id'] : null, $value['Advertiser']['status'], $tuneAccount);
1848.             }
1850.             // $this->mafoObjectsComponents->createOrUpdateAdvertiser(Config::MAFO_SYSTEM_IDENTIFIER_TUNE, $value['Advertiser']['id']);
1851.             //            $execCommand = "php " . $this->rootPath . "/bin/console app:updateCache " . Config::CACHE_REDIS_HO_ADVERTISER_LIST_FOR_MULTISELECT . " --env=prod > /dev/null &";
1852.             //            exec($execCommand);
1854.             if ($value['AccountManager'] !== null) {
1855.                 $affiliateAccountManagerDBInfo = $this->doctrine->getRepository(AdvertiserAccountManager::class)->findOneBy(['advertiserId' => $value['Advertiser']['id']]);
1857.                 if ($affiliateAccountManagerDBInfo) {
1858.                     $this->doctrine->getRepository(AdvertiserAccountManager::class)->updateDataByAdvertiserId($value['Advertiser']['id'], [
1859.                         'employeeId' => $value['AccountManager']['id'],
1860.                         'email' => $value['AccountManager']['email'],
1861.                         'firstName' => $value['AccountManager']['first_name'],
1862.                         'lastName' => $value['AccountManager']['last_name'],
1863.                         'status' => $value['AccountManager']['status'],
1864.                     ], $tuneAccount);
1865.                 } else {
1866.                     $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);
1867.                 }
1868.             }
1870.             $advertiserTagRelationship = $this->brandApi->getAdvertiserTagRelationByAdvertiserId($value['Advertiser']['id'], $tuneAccount);
1872.             if ($advertiserTagRelationship['response']['status'] == 1) {
1873.                 $advertiserTags = [];
1874.                 foreach ($advertiserTagRelationship['response']['data']['data'] as $k => $v) {
1875.                     !in_array($v['AdvertisersTags']['tag_id'], $advertiserTags) ? array_push($advertiserTags, $v['AdvertisersTags']['tag_id']) : false;
1876.                 }
1877.                 $advertiserDBTagsData = $this->doctrine->getRepository(AdvertiserTagRelationship::class)->getAdvertiserTagRelationshipByAdvertiserId($value['Advertiser']['id'], $tuneAccount);
1878.                 $advertiserDBTags = [];
1879.                 foreach ($advertiserDBTagsData as $k => $v) {
1880.                     !in_array($v['tagId'], $advertiserDBTags) ? array_push($advertiserDBTags, $v['tagId']) : false;
1881.                 }
1883.                 if ($advertiserDBTags != $advertiserTags) {
1884.                     $this->doctrine->getRepository(AdvertiserTagRelationship::class)->deleteAdvertiserTagRelationshipByAdvertiserId($value['Advertiser']['id'], $tuneAccount);
1885.                     foreach ($advertiserTags as $advertiserTag) {
1886.                         $this->doctrine->getRepository(AdvertiserTagRelationship::class)->insertToAdvertiserTagRelationship($advertiserTag, $value['Advertiser']['id'], $tuneAccount);
1887.                     }
1888.                 }
1889.             }
1890.         }
1891.     }
1893.     public function getEmployeesWithEmailAsKey()
1894.     {
1896.         $employeesData = $this->doctrine->getRepository(Employees::class)->getEmployees();
1897.         $employees = [];
1899.         foreach ($employeesData as $key => $value) {
1900.             $employees[strtolower($value['email'])] = $value;
1901.         }
1903.         return $employees;
1904.     }
1906.     public function getNewsletterBuilderTemplate($offerIds, $introduction, $unsubscribeEmailId = '')
1907.     {
1909.         $offerInfoFromApi = [];
1910.         if ($offerIds) {
1911.             $offerInfoFromApi = $this->doctrine->getRepository(OfferInfo::class)->getOffersByOfferIdsArr($offerIds);
1912.         }
1914.         $offerInfoByOfferId = [];
1915.         foreach ($offerIds as $offerId) {
1916.             foreach ($offerInfoFromApi as $key => $value) {
1917.                 if ($offerId == $value['offerId']) {
1918.                     $value['geos'] = json_decode($value['geoIdsJson'], true);
1919.                     $offerInfoByOfferId[] = $value;
1920.                 }
1921.             }
1922.         }
1924.         return $this->template->render('components/newsletterBuilder.html.twig', [
1925.             'offerDetails' => $offerInfoByOfferId,
1926.             'introduction' => $introduction,
1927.             'unsubscribeLink' => "http://firehose.mobupps.com/api/unsubscribe/" . $unsubscribeEmailId
1928.         ]);
1929.     }
1931.     public function getOfferGoalInfoByOfferGoalIdArrWithKeys($offerGoalIdArr)
1932.     {
1934.         $offerGoalData = $this->doctrine->getRepository(OfferGoalsInfo::class)->getGoalInfoByGoalIdArr($offerGoalIdArr);
1935.         $data = [];
1936.         foreach ($offerGoalData as $key => $value) {
1937.             $data[$value['goalId']] = $value;
1938.         }
1940.         return $data;
1941.     }
1943.     public function getSkadNetworkMessageSeparator()
1944.     {
1945.         return mb_chr(Config::SKADNETWORK_MESSAGE_SEPARATOR_CODE);
1946.     }
1948.     public function setCommandLoggerData($identifier, $commandName, $meta)
1949.     {
1951.         $identifierExists = $this->doctrine->getRepository(CommandLogger::class)->findOneBy([
1952.             'identifier' => $identifier
1953.         ]);
1955.         if (is_array($meta)) {
1956.             $meta = json_encode($meta);
1957.         }
1959.         $currentTimestamp = strtotime('now');
1961.         if (!$identifierExists) {
1962.             $this->doctrine->getRepository(CommandLogger::class)->insertToCommandLogger($identifier, $commandName, $currentTimestamp, null, null, null);
1963.         } else {
1964.             $this->doctrine->getRepository(CommandLogger::class)->updateCommandLoggerById($identifierExists->getId(), [
1965.                 'endTimestamp' => $currentTimestamp,
1966.                 'timestampDiff' => $currentTimestamp - $identifierExists->getStartTimestamp(),
1967.                 'meta' => $meta
1968.             ]);
1969.         }
1970.     }
1972.     public function getMafoUsersWithEmailIdAsKey()
1973.     {
1974.         $users = $this->doctrine->getRepository('App\Entity\Users')->getUsers();
1976.         $arr = [];
1977.         foreach ($users as $key => $value) {
1978.             $name = explode(' ', $value['name']);
1979.             $value['firstName'] = $name[0];
1980.             $arr[$value['email']] = $value;
1981.         }
1983.         return $arr;
1984.     }
1987.     public function checkAlertMetaExists($identifier, $type)
1988.     {
1989.         $identifierExists = $this->doctrine->getRepository(AlertMeta::class)->findOneBy(['identifier' => $identifier]);
1991.         if (!$identifierExists) {
1992.             $this->doctrine->getRepository(AlertMeta::class)->insertToAlertMeta($identifier, $type);
1993.             return false;
1994.         } else {
1995.             return true;
1996.         }
1997.     }
1999.     public function getHourOffsetFromTimezoneString($timezone)
2000.     {
2001.         $hourOffset = '+0:00';
2002.         if (array_key_exists($timezone, Config::TIMEZONES)) {
2003.             $timezone = Config::TIMEZONES[$timezone];
2004.             $timezone = explode(" ", $timezone)[0];
2005.             $timezone = str_replace("(GMT", "", $timezone);
2006.             $hourOffset = str_replace(")", "", $timezone);
2007.         }
2008.         return $hourOffset;
2009.     }
2012.     public function processPendingPostback($postbackLogId)
2013.     {
2015.         $postbackLogData = $this->doctrine->getRepository(SkadNetworkPostbackLogs::class)->findOneBy(['id' => $postbackLogId]);
2016.         $endpoint = $postbackLogData->getEndpoint();
2017.         $appId = $postbackLogData->getAppId();
2018.         $campaignId = $postbackLogData->getCampaignId();
2019.         $payload = json_decode($postbackLogData->getRequest(), true);
2020.         $isAttributionSignatureValid = $postbackLogData->getIsAttributionSignatureValid();
2021.         $postbackTimestamp = $postbackLogData->getDateInserted()->getTimestamp();
2023.         $offerId = null;
2024.         $affiliateId = null;
2025.         $skadNetworkPostbackMappingExists = null;
2026.         if ($endpoint == Config::SKADNETWORK_POSTBACK_ENDPOINT_WMADV) {
2027.             $skadNetworkPostbackMappingExists = $this->doctrine->getRepository(SkadNetworkManualPostbackMapping::class)->findOneBy([
2028.                 'appId' => $appId,
2029.                 'campaignId' => $campaignId,
2030.                 'isDeleted' => 0
2031.             ]);
2033.             if ($skadNetworkPostbackMappingExists) {
2034.                 $offerId = $skadNetworkPostbackMappingExists->getOfferId();
2035.                 $affiliateId = $skadNetworkPostbackMappingExists->getAffiliateId();
2036.             }
2037.         } else {
2038.             $apiLogsData = $this->doctrine->getRepository(SkadNetworkApiLogs::class)->findOneBy(['appId' => $appId, 'campaignId' => $campaignId]);
2039.             if ($apiLogsData) {
2040.                 $offerId = $apiLogsData->getOfferId();
2041.                 $affiliateId = $apiLogsData->getAffiliateId();
2042.             }
2043.         }
2045.         $postbacksToMake = [];
2046.         if ($isAttributionSignatureValid && $postbackLogData->getDidWin()) {
2047.             if ($offerId) {
2048.                 $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->findOneBy(['offerId' => $offerId]);
2049.                 if ($offerInfo && $offerInfo->getSkadNetworkMmp() && in_array($offerInfo->getSkadNetworkMmp(), Config::SKADNETOWRK_MMP)) {
2050.                     if ($offerInfo->getSkadNetworkMmp() == Config::SKADNETWORK_MMP_ADJUST && $offerInfo->getSkadNetworkAdjustTracker()) {
2052.                         $offerGeoRelationship = $this->doctrine->getRepository(OfferGeoRelationship::class)->findOneBy(['offerId' => $offerInfo->getOfferId()]);
2054.                         $postbackParams = [
2055.                             'tracker' => $offerInfo->getSkadNetworkAdjustTracker(),
2056.                             'sk_payload' => urlencode($payload),
2057.                             'sk_ts' => strtotime('now')
2058.                         ];
2060.                         if ($offerGeoRelationship && $offerGeoRelationship->getGeo()) {
2061.                             $postbackParams['country'] = strtolower($offerGeoRelationship->getGeo());
2062.                         }
2064.                         $postbacksToMake[] = [
2065.                             'requestType' => Config::HTTP_METHOD_POST,
2066.                             'requestUrl' => Config::SKADNETOWRK_MMP_POSTBACK_URL[$offerInfo->getSkadNetworkMmp()] . '?' . http_build_query($postbackParams),
2067.                             'postbackForMmp' => true,
2068.                             'skadNetworkMmp' => Config::SKADNETWORK_MMP_ADJUST
2069.                         ];
2070.                     } else if ($offerInfo->getSkadNetworkMmp() == Config::SKADNETWORK_MMP_BRANCH) {
2071.                         $postbacksToMake[] = [
2072.                             'requestType' => Config::HTTP_METHOD_POST,
2073.                             'requestUrl' => Config::SKADNETOWRK_MMP_POSTBACK_URL[Config::SKADNETWORK_MMP_BRANCH],
2074.                             'postbackForMmp' => true,
2075.                             'skadNetworkMmp' => Config::SKADNETWORK_MMP_BRANCH
2076.                         ];
2077.                         if ($skadNetworkPostbackMappingExists) {
2078.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerCampaignId()) {
2079.                                 $payload['partner-campaign-id'] = $skadNetworkPostbackMappingExists->getBranchPartnerCampaignId();
2080.                             }
2081.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerCampaignName()) {
2082.                                 $payload['partner-campaign-name'] = $skadNetworkPostbackMappingExists->getBranchPartnerCampaignName();
2083.                             }
2084.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerAdSetId()) {
2085.                                 $payload['partner-ad-set-id'] = $skadNetworkPostbackMappingExists->getBranchPartnerAdSetId();
2086.                             }
2087.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerAdSetName()) {
2088.                                 $payload['partner-ad-set-name'] = $skadNetworkPostbackMappingExists->getBranchPartnerAdSetName();
2089.                             }
2090.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerAdId()) {
2091.                                 $payload['partner-ad-id'] = $skadNetworkPostbackMappingExists->getBranchPartnerAdId();
2092.                             }
2093.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerAdName()) {
2094.                                 $payload['partner-ad-name'] = $skadNetworkPostbackMappingExists->getBranchPartnerAdName();
2095.                             }
2096.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerCreativeId()) {
2097.                                 $payload['partner-creative-id'] = $skadNetworkPostbackMappingExists->getBranchPartnerCreativeId();
2098.                             }
2099.                             if ($skadNetworkPostbackMappingExists->getBranchPartnerCreativeName()) {
2100.                                 $payload['partner-creative-name'] = $skadNetworkPostbackMappingExists->getBranchPartnerCreativeName();
2101.                             }
2102.                         }
2103.                     } else if ($offerInfo->getSkadNetworkMmp() == Config::SKADNETWORK_MMP_APPSFLYER) {
2104.                         //                        $payload['ad-network-campaign-id'] = $campaignId . "";
2105.                         //                        $payload['ad-network-campaign-name'] = $offerId . "";
2106.                         //                        $payload['ad-network-country-code'] = implode(",", json_decode($offerInfo->getGeoIdsJson(), true));
2107.                         //                        $payload['timestamp'] = $postbackTimestamp;
2109.                         //                        if($affiliateId) {
2110.                         //                            $payload['source-app-id'] = $affiliateId."";
2111.                         //                            $payload['ad-network-source-app-id'] = $affiliateId."";
2112.                         //                        }
2114.                         $postbacksToMake[] = [
2115.                             'requestType' => Config::HTTP_METHOD_POST,
2116.                             'requestUrl' => Config::SKADNETOWRK_MMP_POSTBACK_URL[$offerInfo->getSkadNetworkMmp()],
2117.                             'postbackForMmp' => true,
2118.                             'skadNetworkMmp' => $offerInfo->getSkadNetworkMmp()
2119.                         ];
2120.                     } else {
2121.                         $postbacksToMake[] = [
2122.                             'requestType' => Config::HTTP_METHOD_POST,
2123.                             'requestUrl' => Config::SKADNETOWRK_MMP_POSTBACK_URL[$offerInfo->getSkadNetworkMmp()],
2124.                             'postbackForMmp' => true,
2125.                             'skadNetworkMmp' => $offerInfo->getSkadNetworkMmp()
2126.                         ];
2127.                     }
2128.                 }
2129.             }
2131.             if ($affiliateId) {
2132.                 $affiliateInfo = $this->doctrine->getRepository(AffiliateInfo::class)->findOneBy(['affiliateId' => $affiliateId]);
2133.                 if ($affiliateInfo && $affiliateInfo->getSkadNetworkPostbackUrl()) {
2134.                     $postbacksToMake[] = [
2135.                         'requestType' => Config::HTTP_METHOD_POST,
2136.                         'requestUrl' => $affiliateInfo->getSkadNetworkPostbackUrl(),
2137.                         'postbackForMmp' => false
2138.                     ];
2139.                 }
2140.             }
2142.             foreach ($postbacksToMake as $key => $value) {
2144.                 $result = false;
2145.                 if ($value['requestType'] == Config::HTTP_METHOD_POST) {
2146.                     $postdata = json_encode($payload);
2147.                     $ch = curl_init($value['requestUrl']);
2148.                     curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
2149.                     curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
2150.                     curl_setopt($ch, CURLOPT_POST, 1);
2151.                     curl_setopt($ch, CURLOPT_POSTFIELDS, $postdata);
2152.                     curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
2153.                     curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
2154.                     curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/json'));
2155.                     $result = curl_exec($ch);
2156.                     curl_close($ch);
2157.                 } elseif ($value['requestType'] == Config::HTTP_METHOD_GET) {
2158.                     $ch = curl_init($value['requestUrl']);
2159.                     curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
2160.                     curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
2161.                     curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/json'));
2162.                     $result = curl_exec($ch);
2163.                     curl_close($ch);
2164.                 }
2166.                 if ($result) {
2167.                     if (array_key_exists('postbackForMmp', $value) && $value['postbackForMmp']) {
2168.                         if (
2169.                             array_key_exists('skadNetworkMmp', $value) &&
2170.                             $value['skadNetworkMmp'] == Config::SKADNETWORK_MMP_BRANCH
2171.                         ) {
2172.                             $result = json_decode($result, true);
2173.                             if (array_key_exists('id', $result)) {
2174.                                 $this->doctrine->getRepository(SkadNetworkPostbackLogs::class)->updateSkadNetworkPostbackLogs($postbackLogId, [
2175.                                     'isPostbackScheduledForMmp' => false,
2176.                                     'branchPostbackId' => $result['id']
2177.                                 ]);
2178.                             }
2179.                         } else if ($value['skadNetworkMmp'] == Config::SKADNETWORK_MMP_APPSFLYER) {
2180.                             $this->doctrine->getRepository(SkadNetworkPostbackLogs::class)->updateSkadNetworkPostbackLogs($postbackLogId, [
2181.                                 'isPostbackScheduledForMmp' => false
2182.                             ]);
2183.                         }
2184.                     } else {
2185.                         $this->doctrine->getRepository(SkadNetworkPostbackLogs::class)->updateSkadNetworkPostbackLogs($postbackLogId, [
2186.                             'isPostbackScheduledForAffiliate' => false
2187.                         ]);
2188.                     }
2189.                 }
2190.             }
2191.         }
2192.     }
2194.     public function getAppInfoByAppIdArrWithKeys($appIdArr)
2195.     {
2196.         $appData = [];
2197.         if ($appIdArr) {
2198.             $appData = $this->doctrine->getRepository(AppInfo::class)->getDataByAppIds($appIdArr);
2199.         }
2201.         $arr = [];
2202.         foreach ($appData as $key => $value) {
2203.             $arr[$value['appId']] = $value;
2204.         }
2206.         return $arr;
2207.     }
2209.     public function getAppInfoWithKeys($fromCache = true)
2210.     {
2211.         $arr = [];
2212.         if ($fromCache) {
2213.             $arr = $this->elasticCache->redisGet(Config::CACHE_REDIS_APP_INFO_KEY);
2214.         }
2216.         if (!$arr) {
2217.             $appData = $this->doctrine->getRepository(AppInfo::class)->getAppIds();
2219.             $arr = [];
2220.             foreach ($appData as $key => $value) {
2221.                 $arr[$value['appId']] = $value;
2222.             }
2223.         } else {
2224.             $arr = json_decode($arr, true);
2225.         }
2227.         return $arr;
2228.     }
2230.     public function getDataFromJsonFile($jsonFileName)
2231.     {
2233.         $json = file_get_contents($this->rootPath . "/src/Resources/json/" . $jsonFileName . ".json");
2235.         if (in_array($jsonFileName, [Config::JSON_FILE_FINANCIAL_TOOLS_GAP_CONTROL, Config::JSON_FILE_FINANCIAL_TOOLS_MAFO_GAP_CONTROL])) {
2237.             $teamsByTeamId = $this->usersComponents->getTeamsByTeamId();
2238.             $usersByTeamId = $this->usersComponents->getMafoUsersByTeamIds();
2240.             $columnsData = json_decode($json, true);
2241.             foreach ($usersByTeamId as $teamId => $users) {
2242.                 if (sizeof($users)) {
2243.                     $columnsData[$teamsByTeamId[$teamId]['label'] . 'Cost'] = [
2244.                         'header' => $teamsByTeamId[$teamId]['label'] . ' Media Cost',
2245.                         'accessor' => $teamsByTeamId[$teamId]['label'] . 'Cost',
2246.                         'percentageWidth' => 5,
2247.                         'show' => true,
2248.                         'disabled' => false,
2249.                         'customClass' => 'text-right',
2250.                         'category' => 'statistics',
2251.                         'footerEnabled' => true,
2252.                         'aggregate' => 'sum',
2253.                         //                        'alwaysEnabled' => true
2254.                     ];
2255.                 }
2256.             }
2258.             $itemsToBePushedToEnd = ['totalAffiliateCost', 'gap'];
2259.             $arrToBePushedToEnd = [];
2260.             foreach ($itemsToBePushedToEnd as $key => $value) {
2261.                 $arrToBePushedToEnd[$value] = $columnsData[$value];
2262.                 unset($columnsData[$value]);
2263.             }
2264.             $columnsData = array_merge($columnsData, $arrToBePushedToEnd);
2266.             $json = json_encode($columnsData);
2267.         }
2269.         return json_decode($json, true);
2270.     }
2272.     public function changeColumnVisibilityForTable($tableColumns, $selectedColumns, $groupedColumns)
2273.     {
2274.         foreach ($tableColumns as $key => $value) {
2275.             $tableColumns[$key]['show'] = false;
2276.             foreach ($selectedColumns as $k => $v) {
2277.                 if ($value['accessor'] === $k && $v !== 'undefined') {
2278.                     $tableColumns[$key]['show'] = $v == '0' ? false : true;
2279.                     break;
2280.                 }
2281.             }
2282.             foreach ($groupedColumns as $k => $v) {
2283.                 if ($value['accessor'] === $k && $v !== 'undefined') {
2284.                     $tableColumns[$key]['groupBy'] = !($v == '0');
2285.                     !($v == '0') ? $tableColumns[$key]['show'] = true : null;
2286.                     break;
2287.                 }
2288.             }
2289.         }
2290.         return $tableColumns;
2291.     }
2293.     public function downloadCSV($tableColumns, $data, $reportNamePretty)
2294.     {
2296.         $reportName = str_replace(" ", "-", strtolower($reportNamePretty));
2297.         $header = [];
2298.         foreach ($tableColumns as $key => $value) {
2299.             if ($value['show'] == 1) {
2300.                 $headerValue = isset($value['Header']) ? $value['Header'] : (isset($value['header']) ? $value['header'] : null);
2301.                 array_push($header, $headerValue);
2302.             }
2303.         }
2305.         $rows = [$header];
2306.         foreach ($data as $key => $value) {
2307.             $row = [];
2308.             foreach ($tableColumns as $k => $v) {
2309.                 if ($v['show'] == 1) {
2311.                     if ($v['accessor'] == 'comments' && is_array($value[$v['accessor']])) {
2312.                         $comments = '';
2313.                         foreach ($value[$v['accessor']] as $commentKey => $commentValue) {
2314.                             $commentValue['comment'] = $commentValue['isDeleted'] ? "**This comment was deleted.**" : $commentValue['comment'];
2315.                             $comments .= "{$commentValue['addedByName']} [{$commentValue['dateInserted']}]: {$commentValue['comment']}\n";
2316.                         }
2317.                         $value[$v['accessor']] = $comments;
2318.                     } elseif ($v['accessor'] == 'attachedFiles') {
2319.                         $value[$v['accessor']] = $value['linkToFile'];
2320.                     } elseif (is_array($value[$v['accessor']])) {
2321.                         $items = '';
2322.                         if (array_key_exists('label', $value[$v['accessor']])) {
2323.                             $items .= $value[$v['accessor']]['label'];
2324.                         } else {
2325.                             foreach ($value[$v['accessor']] as $kk => $vv) {
2326.                                 if (array_key_Exists('label', $vv)) {
2327.                                     $items .= $vv['label'] . "\n";
2328.                                 }
2329.                             }
2330.                         }
2331.                         $value[$v['accessor']] = $items;
2332.                     }
2335.                     array_push($row, $value[$v['accessor']]);
2336.                 }
2337.             }
2338.             $rows[] = $row;
2339.         }
2341.         $spreadsheet = new Spreadsheet();
2342.         $spreadsheet->getProperties()->setCreator('MAFO')->setLastModifiedBy('MAFO')->setTitle($reportNamePretty . ' Report')->setSubject($reportNamePretty)->setDescription($reportNamePretty);
2344.         //        echo json_encode($rows);die;
2345.         $spreadsheet->getActiveSheet()->fromArray($rows, null, 'A1');
2347.         header('Content-Type: application/vnd.ms-excel');
2348.         header('Content-Disposition: attachment;filename="' . $reportName . '.xls"');
2349.         header('Cache-Control: max-age=0');
2350.         $writer = IOFactory::createWriter($spreadsheet, 'Xls');
2351.         $writer->save('php://output');
2352.         exit;
2353.     }
2355.     public function getReportResponse($finalArr, $tableColumns, $limit, $page, $sortBy, $sortType)
2356.     {
2358.         foreach ($finalArr as $key => $value) {
2359.             foreach ($tableColumns as $k => $v) {
2360.                 if (isset($v['footerEnabled'])) {
2361.                     if (!array_key_exists('Footer', $v)) {
2362.                         $tableColumns[$k]['Footer'] = 0;
2363.                     }
2365.                     if (array_key_exists($v['accessor'], $value)) {
2366.                         $tableColumns[$k]['Footer'] += $value[$v['accessor']];
2367.                     }
2368.                 }
2369.             }
2370.         }
2372.         foreach ($tableColumns as $key => $value) {
2373.             if (isset($value['footerEnabled']) && isset($value['Footer'])) {
2374.                 $tableColumns[$key]['Footer'] = round($value['Footer'], 2);
2375.             }
2376.         }
2378.         if (sizeof($finalArr)) {
2379.             $entity = $finalArr[0];
2380.             if (array_key_exists($sortBy, $entity)) {
2381.                 $sortFlag = 3;
2382.                 if ($sortType == Config::SORT_TYPE_ASC) {
2383.                     $sortFlag = 4;
2384.                 }
2385.                 array_multisort(array_column($finalArr, $sortBy), $sortFlag, $finalArr);
2386.             }
2387.         }
2389.         $offset = $limit * ($page - 1);
2391.         $totalRecordCount = sizeof($finalArr);
2392.         $noOfPages = ceil($totalRecordCount / $limit);
2393.         $finalArr = array_slice($finalArr, $offset, $limit);
2395.         return [
2396.             'response' => [
2397.                 'success' => true,
2398.                 'httpStatus' => Config::HTTP_STATUS_CODE_OK,
2399.                 'data' => [
2400.                     'tableColumns' => $tableColumns,
2401.                     'data' => $finalArr,
2402.                     'metaData' => [
2403.                         "total" => $totalRecordCount,
2404.                         "limit" => $limit,
2405.                         "page" => $page,
2406.                         "pages" => $noOfPages
2407.                     ]
2408.                 ],
2409.                 'error' => null
2410.             ]
2411.         ];
2412.     }
2414.     public function getDeductionForAdvertiserAndAffiliateForPeriod($offerId, $advertiserId, $affiliateId, $startDate, $endDate)
2415.     {
2416.         $totalDeduction = 0;
2417.         $approvedDeduction = 0;
2418.         if (
2419.             $this->doctrine->getRepository(AdvertiserInfo::class)->findOneBy(['advertiserId' => $advertiserId]) &&
2420.             $this->doctrine->getRepository(AffiliateInfo::class)->findOneBy(['affiliateId' => $affiliateId])
2421.         ) {
2422.             $deductionControlData = $this->doctrine->getRepository(DeductionControl::class)->getDeductionControlData($offerId ? [$offerId] : [], $advertiserId ? [$advertiserId] : [], $affiliateId ? [$affiliateId] : [], [], [], $startDate, $endDate, 0, []);
2423.             foreach ($deductionControlData as $key => $value) {
2424.                 $totalDeduction += $value['deductionValue'];
2425.                 if ($value['status'] === Config::REVENUE_CONTROL_STATUS_APPROVED) {
2426.                     $approvedDeduction += $value['deductionValue'];
2427.                 }
2428.             }
2429.         }
2431.         return [
2432.             'advertiserId' => $advertiserId,
2433.             'affiliateId' => $affiliateId,
2434.             'totalDeduction' => round($totalDeduction, 2),
2435.             'approvedDeduction' => round($approvedDeduction, 2),
2436.         ];
2437.     }
2439.     public function getMafoDeductionForAdvertiserAndAffiliateForPeriod($offerId, $advertiserId, $affiliateId, $startDate, $endDate)
2440.     {
2441.         $totalDeduction = 0;
2442.         $approvedDeduction = 0;
2443.         if (
2444.             $this->doctrine->getRepository(MafoAdvertisers::class)->findOneBy(['id' => $advertiserId]) &&
2445.             $this->doctrine->getRepository(MafoAffiliates::class)->findOneBy(['id' => $affiliateId])
2446.         ) {
2447.             $deductionControlData = $this->doctrine->getRepository(MafoDeductionControl::class)->getMafoDeductionControlData($offerId ? [$offerId] : [], $advertiserId ? [$advertiserId] : [], $affiliateId ? [$affiliateId] : [], [], [], $startDate, $endDate, 0, []);
2448.             foreach ($deductionControlData as $key => $value) {
2449.                 $totalDeduction += $value['deductionValue'];
2450.                 if ($value['status'] === Config::REVENUE_CONTROL_STATUS_APPROVED) {
2451.                     $approvedDeduction += $value['deductionValue'];
2452.                 }
2453.             }
2454.         }
2456.         return [
2457.             'advertiserId' => $advertiserId,
2458.             'affiliateId' => $affiliateId,
2459.             'totalDeduction' => round($totalDeduction, 2),
2460.             'approvedDeduction' => round($approvedDeduction, 2),
2461.         ];
2462.     }
2464.     public function getIndexedDeductionFromDeductionControlByAdvertiserAndAffiliate($startDate, $endDate)
2465.     {
2467.         $indexedDeduction = [];
2469.         $deductionControlData = $this->doctrine->getRepository(DeductionControl::class)->getDeductionControlData([], [], [], [], [], $startDate, $endDate, 0, []);
2471.         foreach ($deductionControlData as $key => $value) {
2473.             $deductionPeriod = $value['deductionPeriod']->format('Y-m');
2474.             if (!isset($indexedDeduction[$deductionPeriod])) {
2475.                 $indexedDeduction[$deductionPeriod] = [];
2476.             }
2477.             if (!isset($indexedDeduction[$deductionPeriod][$value['advertiserId']])) {
2478.                 $indexedDeduction[$deductionPeriod][$value['advertiserId']] = [];
2479.             }
2480.             if (!isset($indexedDeduction[$deductionPeriod][$value['advertiserId']][$value['affiliateId']])) {
2481.                 $indexedDeduction[$deductionPeriod][$value['advertiserId']][$value['affiliateId']] = [
2482.                     'advertiserId' => $value['advertiserId'],
2483.                     'affiliateId' => $value['affiliateId'],
2484.                     'totalDeduction' => 0,
2485.                     'approvedDeduction' => 0
2486.                 ];
2487.             }
2489.             $indexedDeduction[$deductionPeriod][$value['advertiserId']][$value['affiliateId']]['totalDeduction'] += $value['deductionValue'];
2490.             if ($value['status'] === Config::REVENUE_CONTROL_STATUS_APPROVED) {
2491.                 $indexedDeduction[$deductionPeriod][$value['advertiserId']][$value['affiliateId']]['approvedDeduction'] += $value['deductionValue'];
2492.             }
2493.         }
2495.         return $indexedDeduction;
2496.     }
2498.     public function detectCSVDelimiter($csvFile)
2499.     {
2500.         $delimiters = [";" => 0, "," => 0, "\t" => 0, "|" => 0];
2502.         $handle = fopen($csvFile, "r");
2503.         $firstLine = fgets($handle);
2504.         fclose($handle);
2505.         foreach ($delimiters as $delimiter => &$count) {
2506.             $count = count(str_getcsv($firstLine, $delimiter));
2507.         }
2509.         return array_search(max($delimiters), $delimiters);
2510.     }
2512.     public function assignTagsToOffers()
2513.     {
2514.         $activeOffers = $this->doctrine->getRepository(OfferInfo::class)->getOfferInfoByStatus(Config::ACTIVE_STATUS);
2516.         foreach ($activeOffers as $key => $value) {
2517.             if ($value['offerUrl']) {
2518.                 foreach (Config::HASOFFER_TRACKING_LINK_KEYWORDS_BY_TAG_ID as $k => $v) {
2519.                     if ($k == Config::HASOFFER_ADJUST_OFFER_TAG_ID) {
2520.                         $adjustAppDetails = $this->doctrine->getRepository(AdjustAppDetails::class)->getAdjustAppDetails();
2521.                         foreach ($adjustAppDetails as $kk => $vv) {
2522.                             if (
2523.                                 $this->checkForString($value['offerUrl'], $vv['appToken']) &&
2524.                                 array_key_exists($vv['account'], Config::MMP_ADJUST_ACCOUNT_TUNE_TAG_MAPPING)
2525.                             ) {
2526.                                 $this->brandApi->addTagToOffer($value['offerId'], Config::MMP_ADJUST_ACCOUNT_TUNE_TAG_MAPPING[$vv['account']]);
2527.                                 $this->populateDbByOfferId($value['offerId']);
2528.                                 break 2;
2529.                             }
2530.                         }
2531.                     } else {
2532.                         foreach ($v as $subLink) {
2533.                             if (
2534.                                 isset($value['offerUrl']) &&
2535.                                 $this->checkForString($value['offerUrl'], $subLink) &&
2536.                                 !$this->doctrine->getRepository(OfferTagRelationship::class)->findOneBy(['tagId' => $k, 'offerId' => $value['offerId']])
2537.                             ) {
2538.                                 $this->brandApi->addTagToOffer($value['offerId'], $k);
2539.                                 $this->populateDbByOfferId($value['offerId']);
2540.                                 break 2;
2541.                             }
2542.                         }
2543.                     }
2544.                 }
2545.             }
2546.         }
2547.     }
2549.     public function getReportsRowWiseDataByAggregation($tableColumns, $selectedColumns, $rowWiseData)
2550.     {
2552.         $finalArr = [];
2553.         foreach ($rowWiseData as $rowWiseIndex => $rowWiseValue) {
2555.             $indexArr = [];
2556.             foreach ($selectedColumns as $key => $value) {
2557.                 if (
2558.                     array_key_exists($key, $tableColumns) &&
2559.                     $value &&
2560.                     in_array($tableColumns[$key]['category'], ['data_fields', 'item_interval'])
2561.                 ) {
2562.                     $indexArr[] = $rowWiseValue[$key];
2563.                 }
2564.             }
2566.             $index = md5(implode("#", $indexArr));
2568.             if (!array_key_exists($index, $finalArr)) {
2569.                 foreach ($selectedColumns as $key => $value) {
2570.                     if (array_key_exists($key, $tableColumns) && $value && array_key_exists($key, $rowWiseValue)) {
2571.                         if (in_array($tableColumns[$key]['category'], ['data_fields', 'item_interval'])) {
2572.                             $finalArr[$index][$key] = $rowWiseValue[$key];
2573.                         }
2574.                     }
2575.                 }
2576.                 foreach ($tableColumns as $key => $value) {
2577.                     if ($value['category'] == 'statistics') {
2578.                         $finalArr[$index][$key] = 0;
2579.                     }
2580.                 }
2581.             }
2583.             foreach ($tableColumns as $key => $value) {
2584.                 if (
2585.                     (
2586.                         $value['category'] == 'statistics' && !isset($value['calculationType'])
2587.                     ) ||
2588.                     (
2589.                         isset($value['calculationType']) && $value['category'] == 'statistics' && $value['calculationType'] != 'percentage'
2590.                     )
2591.                 ) {
2592.                     $finalArr[$index][$key] += $rowWiseValue[$key];
2593.                     $finalArr[$index][$key] = round($finalArr[$index][$key], 2);
2594.                 }
2595.             }
2596.         }
2598.         return $finalArr;
2599.     }
2601.     public function getPaginatedResponseForReports($reportData, $tableColumns, $selectedColumns, $sortBy, $sortType, $limit, $page)
2602.     {
2604.         $reportData = array_values($reportData);
2606.         if (sizeof($reportData)) {
2607.             $entity = $reportData[0];
2608.             if (array_key_exists($sortBy, $entity)) {
2609.                 $sortFlag = 3;
2610.                 if ($sortType == Config::SORT_TYPE_ASC) {
2611.                     $sortFlag = 4;
2612.                 }
2613.                 array_multisort(array_column($reportData, $sortBy), $sortFlag, $reportData);
2614.             }
2615.         }
2617.         $offset = $limit * ($page - 1);
2619.         $totalRecordCount = sizeof($reportData);
2620.         $noOfPages = ceil($totalRecordCount / $limit);
2622.         foreach ($tableColumns as $key => $value) {
2623.             if (isset($value['aggregate'])) {
2624.                 if ($value['aggregate'] == 'sum') {
2625.                     $tableColumns[$key]['Footer'] = number_format(round(array_sum(array_column($reportData, $value['accessor'])), 2));
2626.                 }
2627.                 if ($value['aggregate'] == 'average' && count($reportData) > 0) {
2628.                     $tableColumns[$key]['Footer'] = number_format(round(array_sum(array_column($reportData, $value['accessor'])) / count($reportData), 2));
2629.                 }
2630.             }
2631.         }
2633.         $tableColumns = $this->changeColumnVisibilityForTable(array_values($tableColumns), $selectedColumns, []);
2635.         return [
2636.             'response' => [
2637.                 'success' => true,
2638.                 'httpStatus' => Config::HTTP_STATUS_CODE_OK,
2639.                 'data' => [
2640.                     'tableColumns' => array_values($tableColumns),
2641.                     'data' => array_slice($reportData, $offset, $limit),
2642.                     'metaData' => [
2643.                         'total' => $totalRecordCount,
2644.                         'limit' => (int)$limit,
2645.                         'page' => (int)$page,
2646.                         'pages' => (int)$noOfPages,
2647.                     ]
2648.                 ],
2649.                 'error' => null
2650.             ]
2651.         ];
2652.     }
2654.     public function getAffiliateCategoryByAffiliateId($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
2655.     {
2656.         $affiliateTagRelationshipData = $this->doctrine->getRepository(AffiliateTagRelationship::class)->getAffiliateTagRelationshipByTagIdArr([Config::HASOFFER_AFFILIATE_CATEGORY_A_TAG_ID, Config::HASOFFER_AFFILIATE_CATEGORY_B_TAG_ID], $tuneAccount);
2658.         $data = [];
2659.         foreach ($affiliateTagRelationshipData as $key => $value) {
2660.             $data[$key] = [
2661.                 'category' => Config::HASOFFER_AFFILIATE_CATEGORY_ARRAY[$value['tagId']],
2662.                 'affiliateId' => $value['affiliateId']
2663.             ];
2664.         }
2666.         $affiliateData = $this->doctrine->getRepository(AffiliateInfo::class)->getAffiliateListByArrToSearch([], $tuneAccount);
2668.         foreach ($affiliateData as $key => $value) {
2669.             if (!array_key_exists($value['affiliateId'], $data)) {
2670.                 $data[$value['affiliateId']] = [
2671.                     'category' => Config::HASOFFER_AFFILIATE_CATEGORY_UNCATEGORISED_TAG_NAME,
2672.                     'affiliateId' => $value['affiliateId']
2673.                 ];
2674.             }
2675.         }
2677.         return $data;
2678.     }
2680.     public function getPidByOfferId($offerId, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
2681.     {
2683.         $tunePid = null;
2684.         $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->findOneBy(['offerId' => $offerId, 'tuneAccount' => $tuneAccount]);
2686.         if ($offerInfo) {
2687.             $parsedUrl = parse_url($offerInfo->getOfferUrl());
2688.             if (isset($parsedUrl['query'])) {
2689.                 parse_str($parsedUrl['query'], $query);
2690.                 if (isset($query['pid']) && in_array($query['pid'], Config::TUNE_APPSFLYER_PIDS)) {
2691.                     $tunePid = $query['pid'];
2692.                 }
2693.             }
2694.         }
2696.         return $tunePid;
2697.     }
2699.     public function getWhitelistIPsAppsflyerOrAdjust($offerUrl)
2700.     {
2702.         $whitelistIps = [];
2704.         if (stripos($offerUrl, Config::APPSFLYER_DOMAIN) !== false) {
2705.             $whitelistIps = Config::WIZARD_APPSFLYER_WHITE_LIST;
2706.         }
2708.         if (
2709.             stripos($offerUrl, Config::ADJUST_IO_DOMAIN) !== false
2710.             || stripos($offerUrl, Config::ADJUST_COM_DOMAIN) !== false
2711.         ) {
2712.             $whitelistIps = Config::WIZARD_ADJUST_WHITE_LIST;
2713.         }
2715.         return $whitelistIps;
2716.     }
2718.     public function updateNotificationUnreadCountByUser($userEmail, $unreadNotificationCount)
2719.     {
2721.         $cacheKey = Config::CACHE_REDIS_UNREAD_NOTIFICATION_COUNT_BY_USER . $userEmail;
2722.         if (is_null($this->elasticCache->redisGet($cacheKey))) {
2723.             $userData = $this->doctrine->getRepository(MafoUserNotifications::class)->findBy([
2724.                 'sentToUserId' => $userEmail,
2725.                 'isRead' => 0
2726.             ]);
2727.             $notificationCount = count($userData);
2728.         } else {
2729.             $notificationCount = $this->elasticCache->redisGet($cacheKey);
2730.         }
2732.         $unreadNotificationCount += $notificationCount;
2734.         $this->elasticCache->redisSet($cacheKey, $unreadNotificationCount);
2735.     }
2737.     public function getUnreadNotificationCountByUser($userEmail)
2738.     {
2740.         $cacheKey = Config::CACHE_REDIS_UNREAD_NOTIFICATION_COUNT_BY_USER . $userEmail;
2741.         if (is_null($this->elasticCache->redisGet($cacheKey))) {
2742.             $userData = $this->doctrine->getRepository(MafoUserNotifications::class)->findBy([
2743.                 'sentToUserId' => $userEmail,
2744.                 'isRead' => 0
2745.             ]);
2746.             $notificationCount = count($userData);
2747.         } else {
2748.             $notificationCount = $this->elasticCache->redisGet($cacheKey);
2749.         }
2751.         return $notificationCount;
2752.     }
2754.     public function sendPushNotification($topic, $topicData)
2755.     {
2756.         try {
2757.             $update = new Update(
2758.                 $topic,
2759.                 $topicData
2760.                 //               ,true
2761.             );
2763.             $this->hub->publish($update);
2764.         } catch (\Exception $e) {
2765.             $this->logger->error('Error occurred: ' . $e);
2766.         }
2767.     }
2769.     public function getEmployeesByUserId()
2770.     {
2772.         $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HO_EMPLOYEES_LIST);
2774.         if (!$cachedList) {
2775.             $employeeList = $this->getWarmedUpUsersByUserId();
2776.         } else {
2777.             $employeeList = json_decode($cachedList, true);
2778.         }
2780.         ksort($employeeList);
2782.         return $employeeList;
2783.     }
2785.     public function getWarmedUpUsersByUserId()
2786.     {
2788.         $employeesData = $this->doctrine->getRepository(Users::class)->getEmployees();
2789.         $data = [];
2790.         foreach ($employeesData as $key => $value) {
2791.             $data[$value['email']] = [
2792.                 'firstName' => $value['name'],
2793.                 'email' => $value['email']
2794.             ];
2795.         }
2796.         return $data;
2797.     }
2798. }