src/Services/Common.php line 98

1. <?php
3. namespace App\Services;
5. use App\Config;
6. use App\Entity\AdjustAppDetails;
7. use App\Entity\Tune\AdvertiserInfo;
8. use App\Entity\Tune\AffiliateAccountManager;
9. use App\Entity\Tune\AffiliateInfo;
10. use App\Entity\Tune\AffiliateOfferApproval;
11. use App\Entity\AffiliateOfferBlockLogs;
12. use App\Entity\AffiliateTagRelationship;
13. use App\Entity\Tune\AdvertiserAccountManager;
14. use App\Entity\Tune\AdvertiserTagRelationship;
15. use App\Entity\MafoId\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\MafoId\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\Tune\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\MafoId\MafoAdvertisers;
41. use App\Entity\MafoId\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\Tune\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\Tune\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\Tune\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\Tune\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\Tune\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\Tune\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\Tune\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\Tune\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. }
2799. /**
2800. * Transform array data to dropdown format
2801. *
2802. * @param array $data Array of data to transform
2803. * @param string $valueKey Key to use as the value (default: 'id')
2804. * @param array $labelKeys Array of keys to concatenate for label (default: ['firstName', 'lastName'])
2805. * @param string $fallbackKey Key to use as fallback if label is empty (default: 'email')
2806. * @param string $separator Separator to use between label keys (default: ' ')
2807. * @return array Transformed dropdown data
2808. */
2809. public function transformToDropdownFormat(array $data, string $valueKey = 'id', array $labelKeys = ['firstName', 'lastName'], string $fallbackKey = 'email', string $separator = ' '): array
2810. {
2811. return array_map(function ($item) use ($valueKey, $labelKeys, $fallbackKey, $separator) {
2812. $labelParts = [];
2813. foreach ($labelKeys as $key) {
2814. if (isset($item[$key]) && !empty($item[$key])) {
2815. $labelParts[] = trim($item[$key]);
2816. }
2817. }
2819. $label = implode($separator, $labelParts);
2821. if (empty($label) && isset($item[$fallbackKey])) {
2822. $label = $item[$fallbackKey];
2823. }
2825. return [
2826. 'value' => $item[$valueKey] ?? null,
2827. 'label' => $label
2828. ];
2829. }, $data);
2830. }
2831. }