src/Services/Common.php line 96

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\MafoId\MafoAffiliates;
14. use App\Entity\AlertMeta;
15. use App\Entity\AppInfo;
16. use App\Entity\CommandLogger;
17. use App\Entity\DeductionControl;
18. use App\Entity\MafoId\MafoDeductionControl;
19. use App\Entity\Employees;
20. use App\Entity\MafoUserNotifications;
21. use App\Entity\MmpAdvertisers;
22. use App\Entity\MmpMobileApps;
23. use App\Entity\ObjectMappingWithTuneWebAccount;
24. use App\Entity\OfferCategories;
25. use App\Entity\OfferCategoryRelationship;
26. use App\Entity\OfferCreativeFile;
27. use App\Entity\OfferGeoRelationship;
28. use App\Entity\OfferGoalsInfo;
29. use App\Entity\Tune\OfferInfo;
30. use App\Entity\OfferTagRelationship;
31. use App\Entity\OfferWhitelist;
32. use App\Entity\SkadNetworkApiLogs;
33. use App\Entity\SkadNetworkManualPostbackMapping;
34. use App\Entity\SkadNetworkPostbackLogs;
35. use App\Entity\Tag;
36. use App\Entity\UserApiKey;
37. use App\Entity\Users;
38. use App\Entity\MafoId\MafoAdvertisers;
39. use App\Entity\MafoId\MafoOffers;
40. use App\Repository\AdvertiserAccountManagerRepository;
41. use Aws\Credentials\Credentials;
42. use Aws\S3\Exception\S3Exception;
43. use Aws\Exception\MultipartUploadException;
44. use Aws\S3\MultipartUploader;
45. use Aws\S3\ObjectUploader;
46. use Aws\S3\S3Client;
47. use Doctrine\ORM\EntityManagerInterface;
48. use PhpOffice\PhpSpreadsheet\IOFactory;
49. use PhpOffice\PhpSpreadsheet\Spreadsheet;
50. use Psr\Log\LoggerInterface;
51. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
52. use Symfony\Component\Mercure\HubInterface;
53. use Symfony\Component\Mercure\Update;
54. use Twig\Environment;
56. /**
57. *
58. * Common functions which are used throughout the project
59. *
60. * Class Common
61. * @package App\Services
62. */
63. class Common
64. {
66. private $em;
67. private $brandApi;
68. private $doctrine;
69. private $scraper;
70. private $elasticCache;
71. private $rootPath;
72. private $usersComponents;
73. private $mafoObjectsComponents;
74. private $hyperApis;
75. private LoggerInterface $logger;
76. private HubInterface $hub;
78. public function __construct(
79. MysqlQueries $em,
80. BrandHasofferAPI $brandApi,
81. EntityManagerInterface $doctrine,
82. Scraper $scraper,
83. Environment $templating,
84. Aws\ElasticCache $elasticCache,
85. ParameterBagInterface $params,
86. UsersComponents $usersComponents,
87. MafoObjectsComponents $mafoObjectsComponents,
88. HyperApis $hyperApis,
89. LoggerInterface $logger,
90. HubInterface $hub
91. ) {
92. $this->em = $em;
93. $this->brandApi = $brandApi;
94. $this->doctrine = $doctrine;
95. $this->scraper = $scraper;
96. $this->template = $templating;
97. $this->elasticCache = $elasticCache;
98. $this->rootPath = $params->get('kernel.project_dir');
99. $this->usersComponents = $usersComponents;
100. $this->mafoObjectsComponents = $mafoObjectsComponents;
101. $this->hyperApis = $hyperApis;
102. $this->logger = $logger;
103. $this->hub = $hub;
104. }
106. public function getAdvertisersListByStatusWithKeys($arr = [])
107. {
108. $statuses = isset($arr['statuses']) && sizeof($arr['statuses']) > 0 ? $arr['statuses'] : [Config::ACTIVE_STATUS];
109. $tuneAccount = isset($arr['tuneAccount']) ? $arr['tuneAccount'] : Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE;
111. $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HO_ADVERTISER_LIST_FOR_MULTISELECT . '_' . $tuneAccount);
113. if (!$cachedList || (count($statuses) == 1 && !in_array(Config::ACTIVE_STATUS, $statuses))) {
114. $advertiserList = $this->getWarmedUpHoAdvertiserList($statuses, $tuneAccount);
115. } else {
116. $advertiserList = json_decode($cachedList, true);
117. }
119. ksort($advertiserList);
121. return $advertiserList;
122. }
124. public function getWarmedUpHoAdvertiserList($statuses, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
125. {
126. $advertiserList = [];
127. $advertiserData = $this->doctrine->getRepository(AdvertiserInfo::class)->getAdvertiserListByStatus($statuses, $tuneAccount);
129. $employeesInfo = $this->getEmployeesByEmployeeId();
131. foreach ($advertiserData as $key => $value) {
132. $temp = [
133. 'status' => $value['status'],
134. 'name' => $value['company'],
135. 'accountManagerId' => $value['accountManagerId'],
136. 'accountManagerEmail' => null,
137. 'accountManagerName' => null,
138. 'id' => (int)$value['advertiserId']
139. ];
140. if (array_key_exists($value['accountManagerId'], $employeesInfo)) {
141. $temp['accountManagerEmail'] = $employeesInfo[$value['accountManagerId']]['email'];
142. $temp['accountManagerName'] = $employeesInfo[$value['accountManagerId']]['fullName'];
143. }
145. $advertiserList[$value['advertiserId']] = $temp;
146. }
147. return $advertiserList;
148. }
150. public function getAffiliateListByStatusWithKeys($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
151. {
152. $statuses = [Config::ACTIVE_STATUS];
154. $tuneAccountCacheKey = Config::CACHE_REDIS_HO_AFFILIATE_LIST_FOR_MULTISELECT . '_' . $tuneAccount;
156. $cachedList = $this->elasticCache->redisGet($tuneAccountCacheKey);
158. if (!$cachedList || (count($statuses) == 1 && !in_array(Config::ACTIVE_STATUS, $statuses))) {
159. $affiliateList = $this->getWarmedUpHoAffiliateList($statuses, $tuneAccount);
160. } else {
161. $affiliateList = json_decode($cachedList, true);
162. }
164. ksort($affiliateList);
166. return $affiliateList;
167. }
169. public function getPublisherAffiliateListByStatusWithKeys($statuses = [Config::ACTIVE_STATUS], $affiliateIds = null)
170. {
171. // $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HO_AFFILIATE_LIST_FOR_MULTISELECT);
172. //
173. // if (!$cachedList || (count($statuses) == 1 && !in_array(Config::ACTIVE_STATUS, $statuses))) {
174. // $affiliateList = $this->getWarmedUpHoPublisherAffiliateList($statuses);
175. // } else {
176. // $affiliateList = json_decode($cachedList, true);
177. // }
179. $affiliateList = $this->getWarmedUpHoPublisherAffiliateList($statuses, $affiliateIds);
182. ksort($affiliateList);
184. return $affiliateList;
185. }
187. public function getWarmedUpHoAffiliateList($statuses, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
188. {
189. $affiliateList = [];
190. $affiliateData = $this->doctrine->getRepository(AffiliateInfo::class)->getAffiliateListByStatusArr($statuses, $tuneAccount);
192. $employeesInfo = $this->getEmployeesByEmployeeId();
194. foreach ($affiliateData as $key => $value) {
195. $temp = [
196. 'status' => $value['status'],
197. 'name' => $value['company'],
198. 'accountManagerId' => $value['accountManagerId'],
199. 'accountManagerEmail' => null,
200. 'accountManagerName' => null,
201. 'id' => (int)$value['affiliateId']
202. ];
204. if (array_key_exists($value['accountManagerId'], $employeesInfo)) {
205. $temp['accountManagerEmail'] = $employeesInfo[$value['accountManagerId']]['email'];
206. $temp['accountManagerName'] = $employeesInfo[$value['accountManagerId']]['fullName'];
207. }
209. $affiliateList[$value['affiliateId']] = $temp;
210. }
211. return $affiliateList;
212. }
216. public function getWarmedUpHoPublisherAffiliateList(array $statuses, array $affiliateIds = [])
217. {
218. $affiliateList = [];
220. // Fetch affiliate data based on status
221. $affiliateData = $this->doctrine->getRepository(AffiliateInfo::class)->getAffiliateListByStatusArr($statuses);
223. // Get employee information
224. $employeesInfo = $this->getEmployeesByEmployeeId();
226. foreach ($affiliateData as $value) {
227. // Only process if the affiliateId is in the provided $affiliateIds array, or if $affiliateIds is empty
228. if (empty($affiliateIds) || in_array($value['affiliateId'], $affiliateIds)) {
229. $temp = [
230. 'status' => $value['status'],
231. 'name' => $value['company'],
232. 'accountManagerId' => $value['accountManagerId'],
233. 'accountManagerEmail' => null,
234. 'accountManagerName' => null,
235. 'id' => (int)$value['affiliateId']
236. ];
238. // Check if account manager info is available
239. if (array_key_exists($value['accountManagerId'], $employeesInfo)) {
240. $temp['accountManagerEmail'] = $employeesInfo[$value['accountManagerId']]['email'];
241. $temp['accountManagerName'] = $employeesInfo[$value['accountManagerId']]['fullName'];
242. }
244. // Add to affiliate list
245. $affiliateList[$value['affiliateId']] = $temp;
246. }
247. }
249. return $affiliateList;
250. }
253. public function getWarmedUpHoPublisherMafoAffiliateList(array $statuses, array $affiliateIds = [])
254. {
255. $affiliateList = [];
257. // Fetch affiliate data based on status
258. $affiliateData = $this->doctrine->getRepository(MafoAffiliates::class)->getAffiliateListByStatusArr($statuses);
260. // Get employee information
261. $employeesInfo = $this->getEmployeesByEmployeeId();
263. foreach ($affiliateData as $value) {
264. // Only process if the affiliateId is in the provided $affiliateIds array, or if $affiliateIds is empty
265. if (empty($affiliateIds) || in_array($value['affiliateId'], $affiliateIds)) {
266. $temp = [
267. 'status' => $value['status'],
268. 'name' => $value['name'],
269. 'accountManagerId' => $value['accountManagerId'],
270. 'accountManagerEmail' => null,
271. 'accountManagerName' => null,
272. 'id' => (int)$value['id']
273. ];
275. // Check if account manager info is available
276. if (array_key_exists($value['accountManagerId'], $employeesInfo)) {
277. $temp['accountManagerEmail'] = $employeesInfo[$value['accountManagerId']]['email'];
278. $temp['accountManagerName'] = $employeesInfo[$value['accountManagerId']]['fullName'];
279. }
281. // Add to affiliate list
282. $affiliateList[$value['id']] = $temp;
283. }
284. }
286. return $affiliateList;
287. }
290. public function getHyperClientCachedListByKeys()
291. {
293. $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HYPER_CLIENT_LIST);
295. if (!$cachedList) {
296. $clientList = $this->getHyperClientListByKeys();
297. } else {
298. $clientList = json_decode($cachedList, true);
299. }
301. return $clientList;
302. }
304. public function getHyperClientListByKeys()
305. {
307. $hyperData = $this->hyperApis->getHyperClientList();
309. $clientList = [];
310. if ($hyperData && isset($hyperData['Result']) && $hyperData['Result'] == 'Ok') {
311. foreach ($hyperData['ResultData']['Data'] as $key => $value) {
314. $countryCode = null;
315. foreach (Config::COUNTRIES as $k => $v) {
316. if ($this->checkForString($value['Country'], $v['name'])) {
317. $countryCode = $k;
318. break;
319. }
320. }
322. $value['countryCode'] = $countryCode;
324. $clientList[$value['ClientNumber']] = $value;
325. }
326. }
328. $this->elasticCache->redisSet(Config::CACHE_REDIS_HYPER_CLIENT_LIST, json_encode($clientList));
329. return $clientList;
330. }
333. public function getHyperPublisherCachedListByKeys()
334. {
336. $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HYPER_PUBLISHER_LIST);
338. if (!$cachedList) {
339. $clientList = $this->getHyperPublisherListByKeys();
340. } else {
341. $clientList = json_decode($cachedList, true);
342. }
344. return $clientList;
345. }
347. public function getHyperPublisherListByKeys()
348. {
350. $hyperData = $this->hyperApis->getHyperPublisherInfo();
352. $clientList = [];
353. if ($hyperData && isset($hyperData['Result']) && $hyperData['Result'] == 'Ok') {
354. foreach ($hyperData['ResultData']['Data'] as $key => $value) {
357. $countryCode = null;
358. foreach (Config::COUNTRIES as $k => $v) {
359. if ($this->checkForString($value['Country'], $v['name'])) {
360. $countryCode = $k;
361. break;
362. }
363. }
365. $value['countryCode'] = $countryCode;
367. $clientList[$value['SupplierNumber']] = $value;
368. }
369. }
372. return $clientList;
373. }
375. public function getHyperAffiliateListByKeys()
376. {
378. $hyperData = $this->hyperApis->getHyperClientList();
380. $clientList = [];
381. if ($hyperData && isset($hyperData['Result']) && $hyperData['Result'] == 'Ok') {
382. foreach ($hyperData['ResultData']['Data'] as $key => $value) {
385. $countryCode = null;
386. foreach (Config::COUNTRIES as $k => $v) {
387. if ($this->checkForString($value['Country'], $v['name'])) {
388. $countryCode = $k;
389. break;
390. }
391. }
393. $value['countryCode'] = $countryCode;
395. $clientList[$value['ClientNumber']] = $value;
396. }
397. }
399. $this->elasticCache->redisSet(Config::CACHE_REDIS_HYPER_CLIENT_LIST, json_encode($clientList));
400. return $clientList;
401. }
404. public function getMmpAdvertisersListWithKeys()
405. {
406. $advertisers = $this->doctrine->getRepository(MmpAdvertisers::class)->getMmpAdvertisers();
408. $data = [];
409. foreach ($advertisers as $key => $value) {
410. $data[$value['id']] = [
411. 'value' => $value['id'],
412. 'label' => $value['name']
413. ];
414. }
415. ksort($data);
417. return $data;
418. }
421. public function getAffiliateTagListByStatusWithKeys($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
422. {
423. $tagsInDb = $this->doctrine->getRepository(Tag::class)->getTags(1, null, null, 1, $tuneAccount);
424. $tagList = [];
425. foreach ($tagsInDb as $key => $value) {
426. $tagList[$value['tagId']] = [
427. 'value' => $value['tagId'],
428. 'name' => $value['name']
429. ];
430. }
431. ksort($tagList);
433. return $tagList;
434. }
436. public function getOfferCategoriesListByStatusWithKeys($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
437. {
438. $status = Config::ACTIVE_STATUS;
439. $offerCategoriesData = $this->doctrine->getRepository(OfferCategories::class)->getOfferCategoriesByStatus($status, $tuneAccount);
440. $offerCategoryList = [];
441. foreach ($offerCategoriesData as $key => $value) {
442. $offerCategoryList[$value['categoryId']] = [
443. 'name' => $value['name'],
444. 'id' => (int)$value['categoryId']
445. ];
446. }
447. ksort($offerCategoryList);
449. return $offerCategoryList;
450. }
452. public function getAdvertiserListByAdvertiserIdArr($advertiserIdArr, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
453. {
455. $advertiserDataByAdvertiserId = [];
457. if ($advertiserIdArr) {
458. $advertiserInfo = $this->doctrine->getRepository(AdvertiserInfo::class)->getAdvertiserInfoByAdvertiserIdArr($advertiserIdArr, $tuneAccount);
460. foreach ($advertiserInfo as $key => $value) {
461. $advertiserDataByAdvertiserId[$value['advertiserId']] = [
462. 'id' => (int)$value['advertiserId'],
463. 'name' => $value['company']
464. ];
465. }
466. }
468. return $advertiserDataByAdvertiserId;
469. }
471. public function getGoalDisableLinkData($offerId)
472. {
474. $data = $this->em->getGoalDisableLinkData($offerId);
476. $distinctOfferIds = [];
477. foreach ($data as $key => $value) {
478. if (!in_array($value['offerId'], $distinctOfferIds)) {
479. $distinctOfferIds[] = $value['offerId'];
480. }
481. }
482. $offerGoalsByOfferId = [];
484. if ($distinctOfferIds) {
485. $offerGoalData = $this->doctrine->getRepository(OfferGoalsInfo::class)->getGoalsDataByOfferIdArr($distinctOfferIds);
487. if ($offerGoalData) {
488. foreach ($offerGoalData as $key => $value) {
489. $offerGoalsByOfferId[$value['offerId']][] = $value['goalId'];
490. }
491. }
492. }
494. $bifurcatedData = [];
495. foreach ($data as $key => $value) {
496. if (array_key_exists($value['offerId'], $offerGoalsByOfferId) && in_array($value['goalId'], $offerGoalsByOfferId[$value['offerId']])) {
497. $bifurcatedData[$value['addedFrom']][] = $value;
498. }
499. }
501. return $bifurcatedData;
502. }
504. public function disableLink($offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $addedFrom, $advertiserId, $jsonMetaDataStr, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
505. {
506. $disableLinkMd5 = $this->getDisableLinkMd5($offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $tuneAccount);
507. $md5Exist = $this->em->getDisableLinkByMd5($disableLinkMd5);
508. if (!$md5Exist) {
509. $data = $this->brandApi->saveOfferDisabledLink($offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $tuneAccount);
510. if ($data['response']['status'] === 1) {
511. $this->em->insertToDisableLink($disableLinkMd5, $offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $addedFrom, $advertiserId, $jsonMetaDataStr);
512. }
513. }
514. }
516. public function getDisableLinkMd5($offerId, $affiliateId, $source, $affsub2, $affSub3, $affSub5, $trackingAccount = Config::TUNE_ACCOUNT_DEFAULT, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
517. {
519. $trackingAccountStr = $trackingAccount == Config::TUNE_ACCOUNT_DEFAULT ? '' : Config::TUNE_ACCOUNT_WEB;
520. return md5($offerId . $affiliateId . $source . $affsub2 . $affSub3 . $affSub5 . $trackingAccountStr . $tuneAccount);
521. }
523. public function automaticDisableLinkData($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
524. {
526. $automaticDisableLinkData = $this->em->getAutomaticDisableLinkData($tuneAccount);
528. $finalArr['byAdvertiser'] = [];
529. $finalArr['byAffiliate'] = [];
530. $finalArr['byOffer'] = [];
531. foreach ($automaticDisableLinkData as $key => $value) {
533. $value['tuneAccountPretty'] = Config::MAFO_SYSTEM_IDENTIFIER_PRETTY[$value['tuneAccount']];
534. $value['dateInserted'] = $value['dateInserted']->format('Y-m-d H:i:s');
535. if ($value['advertiserId']) {
536. $finalArr['byAdvertiser'][] = $value;
537. }
538. if ($value['affiliateId']) {
539. $finalArr['byAffiliate'][] = $value;
540. }
541. if ($value['offerId']) {
542. $finalArr['byOffer'][] = $value;
543. }
544. }
546. return $finalArr;
547. }
549. public function deleteDisableLinkByMd5($md5, $id, $trackingAccount = Config::TUNE_ACCOUNT_DEFAULT)
550. {
552. $disableLink = $this->em->getDisableLinkByMd5($md5);
554. if ($disableLink) {
555. $offerId = $disableLink->getOfferId();
556. $affiliateId = $disableLink->getAffiliateId();
557. $source = $disableLink->getSource();
558. $affSub2 = $disableLink->getAffsub2();
559. $affSub3 = $disableLink->getAffsub3();
560. $affSub5 = $disableLink->getAffsub5();
561. $advertiserId = $disableLink->getAdvertiserId();
562. $addedFrom = $disableLink->getAddedFrom();
563. $meta = $disableLink->getMeta();
564. $wasInsertedOn = $disableLink->getDateInserted();
565. $trackingAccount = $disableLink->getTrackingAccount();
566. $strict = 0;
568. $disableLinkData = $this->brandApi->findDisableLink($offerId, $affiliateId, $source, $strict, $affSub2, $affSub3, $affSub5, $trackingAccount)['response']['data'];
570. foreach ($disableLinkData as $k => $v) {
571. $this->brandApi->deleteDisableLink($k, $trackingAccount);
572. }
574. $this->em->deleteDisableLinkByMd5($md5);
575. // Removing dump from mysql and added dump of DisableLinks to mongo
576. // $this->em->insertToDisableLinkDump($md5, $offerId, $affiliateId, $source, $affSub2, $addedFrom, $advertiserId, $meta, $wasInsertedOn, $affSub3, $affSub5, $trackingAccount);
577. } else {
578. $this->brandApi->deleteDisableLink($id);
579. }
580. }
582. public function checkForNonIncentInString($string)
583. {
584. 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')) {
585. return true;
586. }
588. return false;
589. }
592. public function checkForString($superString, $checkString)
593. {
594. if (strpos(strtolower($superString), strtolower($checkString)) !== false) {
595. return true;
596. } else {
597. return false;
598. }
599. }
601. public function filterSource($source)
602. {
603. if ($this->checkForString($source, "_")) {
604. $source = explode("_", $source);
605. if (($source[0] == "" && $source[1] != "") || ($source[0] != "" && $source[1] == "") || ($source[0] == "" && $source[1] == "")) {
606. $source = implode("_", $source);
607. } else {
608. $source = $source[0];
609. }
610. }
612. return $source;
613. }
615. public function filterSourceByAffiliate($source, $affiliateId)
616. {
617. if ($affiliateId == 3467) {
619. $actualSource = $source;
620. if (substr($source, 0, 4) === "114_") {
621. $actualSource = substr($source, 4);
622. }
624. return $actualSource;
625. }
627. return $source;
628. }
630. public function filterSourceByAffiliateAndLtr($source, $affiliateId, $clicks, $conversions)
631. {
632. if ($affiliateId == 3467) {
634. $actualSource = $source;
635. if (substr($source, 0, 4) === "114_") {
636. $actualSource = substr($source, 4);
637. }
639. if ($conversions > 15 && (($conversions / $clicks) * 100 > 30)) {
640. return $actualSource;
641. } else {
642. return false;
643. }
644. }
646. return $source;
647. }
649. public function getBulkCapData()
650. {
651. $bulkData = $this->em->getBulkCapData();
653. foreach ($bulkData as $key => $value) {
654. $bulkData[$key]['affiliateOfferCapType'] = str_replace("_", " ", ucfirst($value['affiliateOfferCapType']));
655. $bulkData[$key]['dateInserted'] = $value['dateInserted']->format('Y-m-d H:s:i');
656. }
658. return $bulkData;
659. }
661. public function getBulkCapByAffiliateData()
662. {
663. $bulkData = $this->em->getBulkCapByAffiliateData();
665. foreach ($bulkData as $key => $value) {
666. $bulkData[$key]['affiliateOfferCapType'] = str_replace("_", " ", ucfirst($value['affiliateOfferCapType']));
667. $bulkData[$key]['dateInserted'] = $value['dateInserted']->format('Y-m-d H:s:i');
668. }
670. return $bulkData;
671. }
673. public function getAccountManagerInfoByTuneAdvertiserId($advertiserId, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
674. {
676. $accountManagerInfo = $this->doctrine->getRepository(AdvertiserAccountManager::class)->getAdvertiserAccountManagerByAdvertiserId($advertiserId, $tuneAccount);
678. $email = Config::ALERT_RECIPIENT_DEFAULT_EMAIL;
679. $firstName = '';
680. $lastName = '';
681. if ($accountManagerInfo) {
682. $email = $accountManagerInfo->getEmail();
683. $firstName = $accountManagerInfo->getFirstName();
684. $lastName = $accountManagerInfo->getLastName();
685. }
687. return [
688. 'emailId' => $email,
689. 'firstName' => $firstName,
690. 'lastName' => $lastName
691. ];
692. }
694. public function getAccountManagerInfoByMafoAdvertiserId($advertiserId)
695. {
696. $mafoAdvertiserInfo = $this->doctrine->getRepository(MafoAdvertisers::class)->findOneBy(['id' => $advertiserId]);
698. $email = Config::ALERT_RECIPIENT_DEFAULT_EMAIL;
699. $firstName = '';
700. $lastName = '';
701. if ($mafoAdvertiserInfo) {
702. $accountManagerInfo = $this->doctrine->getRepository(Users::class)->findOneBy(['email' => $mafoAdvertiserInfo->getAccountManagerEmail()]);
703. $email = $mafoAdvertiserInfo->getAccountManagerEmail();
704. $name = $accountManagerInfo->getName();
705. $nameArr = explode(" ", $name);
706. $firstName = $nameArr[0];
707. $lastName = $nameArr[1];
708. }
710. return [
711. 'emailId' => $email,
712. 'firstName' => $firstName,
713. 'lastName' => $lastName
714. ];
715. }
717. public function getAccountManagerInfoByTuneAffiliateId($affiliateId, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
718. {
720. $accountManagerInfo = $this->doctrine->getRepository(AffiliateAccountManager::class)->getAffiliateAccountManagerByAffiliateId($affiliateId, $tuneAccount);
722. $email = Config::ALERT_RECIPIENT_DEFAULT_EMAIL;
723. $firstName = '';
724. $lastName = '';
725. if ($accountManagerInfo) {
726. $email = $accountManagerInfo->getEmail();
727. $firstName = $accountManagerInfo->getFirstName();
728. $lastName = $accountManagerInfo->getLastName();
729. }
731. return [
732. 'emailId' => $email,
733. 'firstName' => $firstName,
734. 'lastName' => $lastName
735. ];
736. }
738. public function getAccountManagerInfoByMafoAffiliateId($affiliateId)
739. {
740. $mafoAffiliateInfo = $this->doctrine->getRepository(MafoAffiliates::class)->findOneBy(['id' => $affiliateId]);
742. $email = Config::ALERT_RECIPIENT_DEFAULT_EMAIL;
743. $firstName = '';
744. $lastName = '';
745. if ($mafoAffiliateInfo) {
746. $accountManagerInfo = $this->doctrine->getRepository(Users::class)->findOneBy(['email' => $mafoAffiliateInfo->getAccountManagerEmail()]);
747. $email = $mafoAffiliateInfo->getAccountManagerEmail();
748. $name = $accountManagerInfo->getName();
749. $nameArr = explode(" ", $name);
750. $firstName = $nameArr[0];
751. $lastName = $nameArr[1];
752. }
754. return [
755. 'emailId' => $email,
756. 'firstName' => $firstName,
757. 'lastName' => $lastName
758. ];
759. }
761. public function getAccountManagerInfoByAffiliateIdArrWithKeys($affiliateIdArr, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
762. {
764. $accountManagerInfoDB = $this->doctrine->getRepository(AffiliateAccountManager::class)->getDataByAffiliateIds($affiliateIdArr, $tuneAccount);
765. $accountManagerInfo = [];
767. foreach ($accountManagerInfoDB as $key => $value) {
768. $accountManagerInfo[$value['affiliateId']] = $value;
769. $accountManagerInfo[$value['affiliateId']]['id'] = $value['employeeId'];
770. $accountManagerInfo[$value['affiliateId']]['name'] = $value['firstName'] . ' ' . $value['lastName'];
771. }
773. return $accountManagerInfo;
774. }
776. public function getAccountManagerInfoByOfferId($offerId)
777. {
779. $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->checkOfferIdExist($offerId);
780. return $this->getAccountManagerInfoByTuneAdvertiserId($offerInfo ? $offerInfo->getAdvertiserId() : null);
781. }
783. public function getDisableLinkLogs($affiliateIdArray, $offerIdArray, $sourceIdArray, $advertiserArray, $addedFromArr, $dateStart, $dateEnd, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
784. {
786. $disableLinksMyMd5 = [];
787. $disableLinkData = [];
788. if (empty($addedFromArr) || in_array(Config::DISABLE_LINKS_FROM_HO_PANEL, $addedFromArr)) {
790. $disableLinkDataFromHO = $this->brandApi->findDisableLinksDyDateRange($offerIdArray, $affiliateIdArray, $sourceIdArray, [], $dateStart, $dateEnd, $tuneAccount)['response']['data']['data'];
792. $disableLinkData = [];
793. $md5Arr = [];
794. foreach ($disableLinkDataFromHO as $key => $value) {
796. $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);
797. $disableLinkData[] = [
798. 'affiliateId' => $value['OfferDisabledLink']['affiliate_id'],
799. 'offerId' => $value['OfferDisabledLink']['offer_id'],
800. 'source' => $value['OfferDisabledLink']['source'],
801. 'advertiserId' => null,
802. 'dateInserted' => $value['OfferDisabledLink']['datetime'],
803. 'addedFrom' => null,
804. 'md5' => $md5,
805. 'tuneAccount' => $tuneAccount,
806. 'id' => $value['OfferDisabledLink']['id']
807. ];
809. $md5Arr[] = $md5;
810. }
813. if (!empty($md5Arr)) {
814. $savedDisableLinkData = $this->em->getDisableLinksByMd5Arr($md5Arr);
815. foreach ($savedDisableLinkData as $key => $value) {
816. $disableLinksMyMd5[$value['md5']] = $value;
817. }
818. }
819. } else {
821. $disableLinkData = $this->em->getDisableLinkLogs($affiliateIdArray, $offerIdArray, $advertiserArray, $sourceIdArray, $addedFromArr, $dateStart, $dateEnd);
823. foreach ($disableLinkData as $key => $value) {
824. $disableLinksMyMd5[$value['md5']] = $value;
825. $disableLinkData[$key]['dateInserted'] = $value['dateInserted']->format('Y-m-d H:i:s');
826. }
827. }
830. $distinctOfferIdArr = [];
831. $distinctAffiliateIdArr = [];
833. foreach ($disableLinkData as $key => $value) {
835. if (!in_array($value['offerId'], $distinctOfferIdArr)) {
836. array_push($distinctOfferIdArr, $value['offerId']);
837. }
839. if (!in_array($value['affiliateId'], $distinctAffiliateIdArr)) {
840. array_push($distinctAffiliateIdArr, $value['affiliateId']);
841. }
843. $disableLinkData[$key]['date_inserted'] = $value['dateInserted'];
844. }
846. $offerInfo = [];
847. if (!empty($distinctOfferIdArr)) {
848. $offerInfo = $this->getOfferInfoByKey($distinctOfferIdArr, $tuneAccount);
849. }
851. $advertiserList = $this->getAdvertisersListByStatusWithKeys([
852. 'tuneAccount' => $tuneAccount
853. ]);
854. $affiliateList = $this->getAffiliateListByStatusWithKeys($tuneAccount);
856. foreach ($disableLinkData as $key => $value) {
858. if (!array_key_exists($value['offerId'], $offerInfo)) {
859. unset($disableLinkData[$key]);
860. continue;
861. }
862. $offerName = $offerInfo[$value['offerId']]['name'] ?? '';
863. $advertiserName = array_key_exists($offerInfo[$value['offerId']]['advertiserId'], $advertiserList) ? $advertiserList[$offerInfo[$value['offerId']]['advertiserId']]['name'] : '';
864. $advertiserId = $offerInfo[$value['offerId']]['advertiserId'] ?? '';
865. $affiliateName = array_key_exists($value['affiliateId'], $affiliateList) ? $affiliateList[$value['affiliateId']]['name'] : '';
866. $meta = [];
867. $addedFrom = Config::DISABLE_LINKS_FROM_HO_PANEL;
869. if (array_key_exists($value['md5'], $disableLinksMyMd5)) {
870. $meta = json_decode($disableLinksMyMd5[$value['md5']]['meta'], true) != null ? json_decode($disableLinksMyMd5[$value['md5']]['meta'], true) : [];
871. $addedFrom = $disableLinksMyMd5[$value['md5']]['addedFrom'];
872. }
874. if (
875. (!empty($addedFromArr) && !in_array($addedFrom, $addedFromArr)) ||
876. (sizeof($advertiserArray) && !in_array($advertiserId, $advertiserArray))
877. ) {
878. unset($disableLinkData[$key]);
879. continue;
880. }
882. $disableLinkData[$key]['affiliateName'] = $affiliateName;
883. $disableLinkData[$key]['advertiserName'] = $advertiserName;
884. $disableLinkData[$key]['advertiserId'] = $advertiserId;
885. $disableLinkData[$key]['offerName'] = $offerName;
886. $disableLinkData[$key]['addedFrom'] = $addedFrom;
887. $disableLinkData[$key]['meta'] = $meta;
888. }
890. return $disableLinkData;
891. }
893. public function createUpdateRetentionOptimisation($offerId, $goalId, $retentionRate, $minimumBudget, $sendAlert, $autoBlock, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
894. {
896. $retentionOptimisationExist = $this->em->getRetentionOptimisationByParams($offerId, $goalId, $tuneAccount);
898. if ($retentionOptimisationExist) {
899. if ($sendAlert === null) {
900. $sendAlert = $retentionOptimisationExist->getSendAlert();
901. }
902. if ($autoBlock === null) {
903. $autoBlock = $retentionOptimisationExist->getAutoBlock();
904. }
905. $this->em->updateRetentionOptimisation($offerId, $goalId, $retentionRate, $minimumBudget, $sendAlert, $autoBlock, $tuneAccount);
906. } else {
907. $this->em->insertRetentionOptimisation($offerId, $goalId, $retentionRate, $minimumBudget, $sendAlert, $autoBlock, $tuneAccount);
908. }
909. }
911. public function getRetentionOptimisationData($offerId, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
912. {
914. $retentionOptimisationData = $this->em->getRetentionOptimisation($offerId, $tuneAccount);
916. $distinctOfferIds = [];
917. foreach ($retentionOptimisationData as $key => $value) {
918. if (!in_array($value['offerId'], $distinctOfferIds)) {
919. array_push($distinctOfferIds, $value['offerId']);
920. }
921. }
925. foreach ($retentionOptimisationData as $key => $value) {
928. // $retentionOptimisationData[$key]['offerName'] = $offerInfo[$value['offerId']]['name'] ?? "";
929. // $retentionOptimisationData[$key]['advertiserId'] = $offerInfo[$value['offerId']]['advertiserId'] ?? "";
930. // $retentionOptimisationData[$key]['advertiserName'] = $offerInfo[$value['offerId']]['Advertiser']['company'] ?? "";
931. // $retentionOptimisationData[$key]['advertiserName'] = array_key_exists($offerInfo[$value['offerId']]['advertiserId'], $advertiserList) ? $advertiserList[$offerInfo[$value['offerId']]['advertiserId']]['name'] : '';
932. // $retentionOptimisationData[$key]['goalName'] = $offerInfo[$value['offerId']]['Goal'][$value['goalId']]['name'] ?? "";
933. $retentionOptimisationData[$key]['dateInserted'] = $value['dateUpdated']->format("Y-m-d H:s:i");
934. }
936. return array_values($retentionOptimisationData);
937. }
939. public function changeCamelCaseToWords($camelCaseString)
940. {
942. return ucfirst(implode(" ", preg_split('/(?=[A-Z])/', $camelCaseString)));
943. }
945. public function setOfferAffiliateCap($affiliateId, $offerId, $affiliateOfferCapType, $capValue, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
946. {
947. $capExist = $this->em->getCombinationFromAffiliateOfferCapping($affiliateId, $offerId, $affiliateOfferCapType, $tuneAccount);
949. if (!$capExist || ($capExist->getCapValue() != $capValue)) {
950. if ($capExist) {
951. $this->em->deleteAffiliateOfferCapById($capExist->getId());
952. }
954. $hoResponse = $this->brandApi->setAffiliateOfferCap($affiliateId, $offerId, $affiliateOfferCapType, $capValue, $tuneAccount);
956. if ($hoResponse['response']['status'] == 1) {
957. $this->em->insertToAffiliateOfferCap($affiliateId, $offerId, $affiliateOfferCapType, $capValue, $tuneAccount);
958. }
959. }
960. }
962. public function getImpressionOptimisationData()
963. {
964. $impressionOptimisations = $this->em->getActiveImpressionOptimisation();
965. foreach ($impressionOptimisations as $key => $value) {
966. $impressionOptimisations[$key]['dateUpdated'] = $value['dateUpdated']->format("Y-m-d H:s:i");
967. $impressionOptimisations[$key]['dateInserted'] = $value['dateInserted']->format("Y-m-d H:s:i");
968. }
970. return $impressionOptimisations;
971. }
973. public function createUpdateImpressionOptimisation($offerId, $affiliate_id, $ctr, $addedBy)
974. {
976. return $this->em->createUpdateImpression($offerId, $affiliate_id, $ctr, $addedBy);
977. }
979. public function getFraudFlagLogs($affiliateIdArray, $offerIdArray, $advertiserArray, $dateStart, $dateEnd)
980. {
983. $fraudFlagData = [];
985. $fraudFlagData = $this->em->getFraudFlagLogs($affiliateIdArray, $offerIdArray, $advertiserArray, $dateStart, $dateEnd);
987. // foreach ($fraudFlagData as $key => $value) {
988. // $fraudFlagData[$key]['dateInserted'] = $value['dateInserted']->format('Y-m-d H:i:s');
989. // }
990. $distinctOfferIdArr = [];
991. $distinctAffiliateIdArr = [];
993. foreach ($fraudFlagData as $key => $value) {
995. if (!in_array($value['offerId'], $distinctOfferIdArr)) {
996. array_push($distinctOfferIdArr, $value['offerId']);
997. }
999. if (!in_array($value['affiliateId'], $distinctAffiliateIdArr)) {
1000. array_push($distinctAffiliateIdArr, $value['affiliateId']);
1001. }
1003. $fraudFlagData[$key]['date_inserted'] = $value['dateInserted']->format('Y-m-d H:i:s');
1004. }
1006. if (!empty($distinctOfferIdArr)) {
1007. $offerInfo = $this->brandApi->getOffersByOfferIdsArr($distinctOfferIdArr)['response']['data'];
1008. }
1009. if (!empty($distinctAffiliateIdArr)) {
1010. $affiliateInfo = $this->brandApi->getAffiliatesByAffiliateIdArr($distinctAffiliateIdArr)['response']['data'];
1011. }
1013. foreach ($fraudFlagData as $key => $value) {
1014. $offerName = $offerInfo[$value['offerId']]['Offer']['name'] ?? '';
1015. $advertiserName = $offerInfo[$value['offerId']]['Advertiser']['company'] ?? '';
1016. $advertiserId = $offerInfo[$value['offerId']]['Advertiser']['id'] ?? '';
1017. $affiliateName = $affiliateInfo[$value['affiliateId']]['Affiliate']['company'] ?? '';
1020. $fraudFlagData[$key]['affiliateName'] = $affiliateName;
1021. $fraudFlagData[$key]['advertiserName'] = $advertiserName;
1022. $fraudFlagData[$key]['advertiserId'] = $advertiserId;
1023. $fraudFlagData[$key]['offerName'] = $offerName;
1024. }
1026. return $fraudFlagData;
1027. }
1029. public function deleteFraudFlagLogs($id)
1030. {
1031. $this->em->deleteFraudFlagLogs($id);
1032. }
1034. public function blockOfferForAffiliate($offerId, $affiliateId, $blockType, $blockedFrom, $conversions, $clicks, $ltr, $trackingAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
1035. {
1037. $combinationExist = $this->doctrine->getRepository('App\Entity\AffiliateOfferBlock')->findOneBy([
1038. 'offerId' => $offerId,
1039. 'affiliateId' => $affiliateId,
1040. 'trackingAccount' => $trackingAccount
1041. ]);
1043. $affiliateOfferBlockedInHO = $this->brandApi->getAffiliateOfferBlock($offerId, $affiliateId, $trackingAccount)['response']['data']['data'];
1045. if (array_key_exists($offerId, $affiliateOfferBlockedInHO) && $affiliateOfferBlockedInHO[$offerId]['OfferAffiliateBlock']['affiliate_id'] == $affiliateId && !$combinationExist) {
1046. return false;
1047. }
1050. if (!$combinationExist) {
1051. if ($blockType === Config::AFFILIATE_OFFER_BLOCK_MACRO) {
1052. $hoResponse = $this->brandApi->blockOfferAffiliate($offerId, $affiliateId, $trackingAccount);
1053. } elseif ($blockType === Config::AFFILIATE_OFFER_UNBLOCK_MACRO) {
1054. $hoResponse = $this->brandApi->unblockOfferAffiliate($offerId, $affiliateId, $trackingAccount);
1055. }
1056. if (isset($hoResponse['response']['status']) && $hoResponse['response']['status'] == 1) {
1057. $this->doctrine->getRepository('App\Entity\AffiliateOfferBlock')->insertToOfferAffiliateBlock($offerId, $affiliateId, $blockType, $blockedFrom, $conversions, $clicks, $ltr, $trackingAccount);
1059. // Removing dump from mysql and added dump of AffiliateOfferBlock to mongo
1060. // $this->doctrine->getRepository('App\Entity\AffiliateOfferBlockLogs')->insertToOfferAffiliateBlockLogs($offerId, $affiliateId, $blockType, $blockedFrom, $conversions, $clicks, $ltr, $trackingAccount);
1061. return true;
1062. }
1063. }
1064. return false;
1065. }
1067. public function deleteOfferAffiliateBlock($offerId, $affiliateId, $trackingAccount)
1068. {
1070. $hoResponse = $this->brandApi->unblockOfferAffiliate($offerId, $affiliateId, $trackingAccount);
1071. if ($hoResponse['response']['status'] == 1) {
1072. $this->doctrine->getRepository('App\Entity\AffiliateOfferBlock')->deleteOfferAffiliateBlock($offerId, $affiliateId, $trackingAccount);
1073. }
1074. }
1076. public function populateDbByOfferId($offerId, $metaData = [])
1077. {
1078. $calledFromCronJob = $metaData['calledFromCronJob'] ?? true;
1079. $tuneAccount = $metaData['tuneAccount'] ?? Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE;
1081. $offerExistInDB = $this->doctrine->getRepository('App\Entity\Tune\OfferInfo')->findOneBy([
1082. 'offerId' => $offerId,
1083. 'tuneAccount' => $tuneAccount
1084. ]);
1085. $offerInfo[$offerId] = $this->brandApi->getOfferByOfferId($offerId, $tuneAccount)['response']['data'];
1086. $offerIpWhitelistHoData = $this->brandApi->getIpWhitelistByOfferId($offerId, $tuneAccount)['response']['data'];
1087. $offerFileCreativesHoData = $this->brandApi->getOfferFilesByOfferId($offerId, $tuneAccount);
1089. $offerIpWhitelistArray = [];
1090. foreach ($offerIpWhitelistHoData as $key => $value) {
1091. if ($value['OfferWhitelist']['type'] == Config::OFFER_IP_WHITELIST_TYPE_POSTBACK) {
1092. array_push($offerIpWhitelistArray, $value['OfferWhitelist']['content']);
1093. }
1094. }
1096. $offerCountryIdArray = isset($offerInfo[$offerId]['Country']) ? array_keys($offerInfo[$offerId]['Country']) : [];
1097. $offerCategoryIdArray = isset($offerInfo[$offerId]['OfferCategory']) ? array_keys($offerInfo[$offerId]['OfferCategory']) : [];
1098. $offerTagIdArray = isset($offerInfo[$offerId]['OfferTag']) ? array_keys($offerInfo[$offerId]['OfferTag']) : [];
1100. $offerGoalArray = isset($offerInfo[$offerId]['Goal']) ? array_values($offerInfo[$offerId]['Goal']) : [];
1101. foreach ($offerGoalArray as $key => $value) {
1102. foreach ($value as $k => $v) {
1103. $offerGoalArray[$key][lcfirst(implode('', array_map('ucfirst', explode('_', $k))))] = $v;
1104. if ($this->checkForString($k, '_')) {
1105. unset($offerGoalArray[$key][$k]);
1106. }
1107. }
1108. }
1110. if ($offerExistInDB) {
1112. $offerDataToUpdate = [];
1113. foreach ($offerInfo[$offerId]['Offer'] as $key => $value) {
1114. $appId = $this->scraper->getAppId($offerInfo[$offerId]['Offer']['preview_url']);
1115. if (!$appId) {
1116. $appId = 'Not Found';
1117. }
1118. $offerDataToUpdate['appId'] = $appId;
1119. $offerDataToUpdate[lcfirst(implode('', array_map('ucfirst', explode('_', $key))))] = $value;
1120. }
1122. $offerDataToUpdate['geoIdsJson'] = json_encode($offerCountryIdArray);
1123. $offerDataToUpdate['categoryIdsJson'] = json_encode($offerCategoryIdArray);
1124. $offerDataToUpdate['tagIdsJson'] = json_encode($offerTagIdArray);
1125. // $offerDataToUpdate['whitelistIpsJson'] = json_encode($offerIpWhitelistArray);
1127. if ($offerInfo[$offerId]['Thumbnail'] && isset($offerInfo[$offerId]['Thumbnail']['preview_uri'])) {
1128. $offerDataToUpdate['thumbnail'] = $offerInfo[$offerId]['Thumbnail']['preview_uri'];
1129. }
1131. $this->doctrine->getRepository(OfferInfo::class)->updateOfferByOfferId($offerId, $offerDataToUpdate, $tuneAccount);
1132. } else {
1134. $offerValue = $offerInfo[$offerId];
1136. $domain = $offerInfo[$offerId]['Hostname']['domain'] ?? '';
1138. $appId = $this->scraper->getAppId($offerValue['Offer']['preview_url']);
1139. if (!$appId) {
1140. $appId = 'Not Found';
1141. }
1142. $offerValue['Offer']['app_id'] = $appId;
1143. if (!$offerValue['Offer']['advertiser_id']) {
1144. $offerValue['Offer']['advertiser_id'] = 0;
1145. }
1146. $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);
1147. }
1149. $this->mafoObjectsComponents->createOrUpdateOffer($tuneAccount, $offerId);
1151. foreach ($offerGoalArray as $key => $value) {
1152. $goalExistInDB = $this->doctrine->getRepository(OfferGoalsInfo::class)->findOneBy(['goalId' => $value['id'], 'tuneAccount' => $tuneAccount]);
1154. if ($goalExistInDB) {
1155. $this->doctrine->getRepository(OfferGoalsInfo::class)->updateGoalByGoalId($value['id'], $value, $tuneAccount);
1156. } else {
1157. $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);
1158. }
1159. }
1161. if ($calledFromCronJob) {
1162. $this->scraper->getAppDetailsByPreviewUrl($offerInfo[$offerId]['Offer']['preview_url']);
1165. if (is_array($offerTagIdArray)) {
1166. $this->doctrine->getRepository(OfferTagRelationship::class)->deleteOfferTagRelationByOfferId($offerId, $tuneAccount);
1167. foreach ($offerTagIdArray as $tagId) {
1168. $this->doctrine->getRepository(OfferTagRelationship::class)->insertToOfferTagRelationship($offerId, $tagId, $tuneAccount);
1169. }
1170. }
1172. if (is_array($offerCategoryIdArray)) {
1173. $this->doctrine->getRepository(OfferCategoryRelationship::class)->deleteOfferCategoryRelationByOfferId($offerId, $tuneAccount);
1174. foreach ($offerCategoryIdArray as $categoryId) {
1175. $this->doctrine->getRepository(OfferCategoryRelationship::class)->insertToOfferCategoryRelationship($offerId, $categoryId, $tuneAccount);
1176. }
1177. }
1179. if (is_array($offerCountryIdArray)) {
1180. $this->doctrine->getRepository(OfferGeoRelationship::class)->deleteOfferGeoRelationByOfferId($offerId, $tuneAccount);
1181. foreach ($offerCountryIdArray as $geo) {
1182. $this->doctrine->getRepository(OfferGeoRelationship::class)->insertToOfferGeoRelationship($offerId, $geo, $tuneAccount);
1183. }
1184. }
1185. }
1187. if (!$calledFromCronJob) {
1189. $offerWhitelistIdArrFromHO = [];
1190. foreach ($offerIpWhitelistHoData as $key => $value) {
1191. $value = $value['OfferWhitelist'];
1192. $value['tuneAccount'] = $tuneAccount;
1194. $offerWhitelistExist = $this->doctrine->getRepository(OfferWhitelist::class)->findOneBy(['whitelistId' => $value['id'], 'tuneAccount' => $tuneAccount]);
1196. if (!$offerWhitelistExist) {
1197. $this->doctrine->getRepository(OfferWhitelist::class)->insertToOfferWhitelist($value['id'], $value['offer_id'], $value['type'], $value['content_type'], $value['content'], $tuneAccount);
1198. } else {
1199. $this->doctrine->getRepository(OfferWhitelist::class)->updateOfferWhitelistByWhitelistId($value['id'], $value, $tuneAccount);
1200. }
1201. array_push($offerWhitelistIdArrFromHO, $value['id']);
1202. }
1204. if (sizeof($offerWhitelistIdArrFromHO)) {
1205. $offerWhitelistToBeDeleted = $this->doctrine->getRepository(OfferWhitelist::class)->getDeletedOfferWhitelistIds($offerId, $offerWhitelistIdArrFromHO, $tuneAccount);
1206. foreach ($offerWhitelistToBeDeleted as $key => $value) {
1207. $this->doctrine->getRepository(OfferWhitelist::class)->deleteByWhitelistId($value['whitelistId'], $tuneAccount);
1208. }
1209. }
1212. foreach ($offerFileCreativesHoData as $key => $value) {
1213. $fileExist = $this->doctrine->getRepository(OfferCreativeFile::class)->findOneBy(['fileId' => $key, 'tuneAccount' => $tuneAccount]);
1214. if (isset($value['OfferFile'])) {
1215. if (!$fileExist) {
1216. $response = $value['OfferFile'];
1217. if ($response['status'] == Config::DELETED_STATUS || $response['status'] == Config::PENDING_STATUS) {
1218. continue;
1219. }
1220. $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);
1221. } elseif ($fileExist->getStatus() != $value['OfferFile']['status']) {
1222. $this->doctrine->getRepository(OfferCreativeFile::class)->updateStatusByFileId($value['OfferFile']['id'], $value['OfferFile']['status'], $tuneAccount);
1223. }
1224. }
1225. }
1226. }
1227. }
1229. public function updateOffer($offerId, $offerDetails, $offerCountries, $offerCategories, $offerTags, $offerWhitelistIps, $tuneAccount)
1230. {
1231. $offerCreateHoResponse = $this->brandApi->createOrUpdateOffer($offerId, $offerDetails, $tuneAccount);
1233. if ($offerCreateHoResponse['response']['status'] === 1) {
1234. $offerInfo = $offerCreateHoResponse['response']['data']['Offer'];
1235. $offerId = $offerInfo['id'];
1237. $this->doctrine->getRepository(OfferInfo::class)->updateOfferByOfferId($offerId, $offerDetails, $tuneAccount);
1239. $this->updateOfferCountries($offerId, $offerCountries, $tuneAccount);
1240. $this->updateOfferCategories($offerId, $offerCategories, $tuneAccount);
1241. $this->updateOfferTags($offerId, $offerTags, $tuneAccount);
1242. $this->updateOfferWhitelist($offerId, $offerWhitelistIps, $tuneAccount);
1243. $this->mafoObjectsComponents->createOrUpdateOffer($tuneAccount, $offerId);
1244. }
1246. return $offerCreateHoResponse;
1247. }
1249. public function createNewOffer($offerDetails, $offerCountries, $offerCategories, $offerTags, $offerWhitelistIps, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
1250. {
1252. $offerCreateHoResponse = $this->brandApi->createOrUpdateOffer(null, $offerDetails, $tuneAccount);
1254. if ($offerCreateHoResponse['response']['status'] === 1) {
1256. $offerInfo = $offerCreateHoResponse['response']['data']['Offer'];
1257. $offerId = $offerInfo['id'];
1259. $appId = $this->scraper->getAppId($offerInfo['preview_url']);
1260. if (!$appId) {
1261. $appId = 'Not Found';
1262. }
1263. $offerInfo['app_id'] = $appId;
1265. $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);
1267. $this->updateOfferCountries($offerId, $offerCountries, $tuneAccount);
1268. $this->updateOfferCategories($offerId, $offerCategories, $tuneAccount);
1269. $this->updateOfferTags($offerId, $offerTags, $tuneAccount);
1270. $this->updateOfferWhitelist($offerId, $offerWhitelistIps, $tuneAccount);
1271. $this->mafoObjectsComponents->createOrUpdateOffer($tuneAccount, $offerId);
1274. $appDetails = $this->scraper->getAppDetailsByPreviewUrl($offerInfo['preview_url']);
1276. if ($appDetails) {
1277. $fileResponse = $this->uploadFile($offerId, $appDetails['icon'], Config::FILE_TYPE_THUMBNAIL, 0);
1278. if ($fileResponse['response']['status'] == 1) {
1279. $this->doctrine->getRepository('App\Entity\Tune\OfferInfo')->updateOfferByOfferId($offerId, ['thumbnail' => $fileResponse['response']['data']['OfferFile']['url']], $tuneAccount);
1280. }
1281. }
1282. }
1284. return $offerCreateHoResponse;
1285. }
1287. public function updateOfferCountries($offerId, $offerCountries, $tuneAccount)
1288. {
1290. $savedOfferInfo = $this->doctrine->getRepository('App\Entity\Tune\OfferInfo')->findOneBy(['offerId' => $offerId, 'tuneAccount' => $tuneAccount]);
1291. $savedGeos = json_decode($savedOfferInfo->getGeoIdsJson(), true);
1292. foreach ($savedGeos as $geo) {
1293. if (!in_array($geo, $offerCountries)) {
1294. $this->brandApi->removeGeoFromOffer($offerId, $geo, $tuneAccount);
1295. }
1296. }
1297. foreach ($offerCountries as $geo) {
1298. $this->brandApi->addGeoToOffer($offerId, $geo, $tuneAccount);
1299. }
1301. $this->doctrine->getRepository('App\Entity\Tune\OfferInfo')->updateOfferByOfferId($offerId, ['geoIdsJson' => json_encode($offerCountries)], $tuneAccount);
1302. }
1304. public function updateOfferCategories($offerId, $offerCategories, $tuneAccount)
1305. {
1306. if (is_array($offerCategories) && count($offerCategories) > 0) {
1307. $this->brandApi->setCategoryToOffer($offerId, $offerCategories, $tuneAccount);
1308. $this->doctrine->getRepository('App\Entity\Tune\OfferInfo')->updateOfferByOfferId($offerId, ['categoryIdsJson' => json_encode($offerCategories)], $tuneAccount);
1309. }
1310. }
1312. public function updateOfferTags($offerId, $offerTags, $tuneAccount)
1313. {
1314. if (is_array($offerTags) && count($offerTags) > 0) {
1315. foreach ($offerTags as $tagId) {
1316. $this->brandApi->addTagToOffer($offerId, $tagId, $tuneAccount);
1317. }
1318. $this->doctrine->getRepository('App\Entity\Tune\OfferInfo')->updateOfferByOfferId($offerId, ['tagIdsJson' => json_encode($offerTags)], $tuneAccount);
1319. }
1320. }
1322. public function updateOfferWhitelist($offerId, $offerWhitelistIps, $tuneAccount)
1323. {
1324. if (is_array($offerWhitelistIps) && count($offerWhitelistIps) > 0) {
1325. foreach ($offerWhitelistIps as $whitelistIp) {
1326. $this->brandApi->addIpWhitelistToOffer($offerId, $whitelistIp, Config::OFFER_IP_WHITELIST_CONTENT_TYPE_IP_ADDRESS, Config::OFFER_IP_WHITELIST_TYPE_POSTBACK, $tuneAccount);
1327. }
1328. // echo json_encode($offerWhitelistIps);
1329. // $this->doctrine->getRepository('App\Entity\Tune\OfferInfo')->updateOfferByOfferId($offerId, ['whitelistIpsJson' => json_encode($offerWhitelistIps)], $tuneAccount);
1330. }
1331. }
1333. public function updateOfferGoal($goalId, $offerGoalDetails, $tuneAccount)
1334. {
1336. if (isset($offerGoalDetails['goal_id'])) {
1337. unset($offerGoalDetails['goal_id']);
1338. }
1339. $offerGoalCreateHoResponse = $this->brandApi->createOrUpdateOfferGoal($goalId, $offerGoalDetails, $tuneAccount);
1341. if ($offerGoalCreateHoResponse['response']['status'] === 1) {
1342. $dataToUpdate = [];
1343. foreach ($offerGoalCreateHoResponse['response']['data']['Goal'] as $key => $value) {
1344. if ($key === 'id') {
1345. continue;
1346. }
1347. $dataToUpdate[$this->convertStringFromSnakeCaseToCamelCase($key)] = $value;
1348. }
1350. $this->doctrine->getRepository(OfferGoalsInfo::class)->updateGoalByGoalId($goalId, $dataToUpdate, $tuneAccount);
1351. }
1353. return $offerGoalCreateHoResponse;
1354. }
1357. public function createNewOfferGoal($offerGoalDetails, $tuneAccount)
1358. {
1359. $offerGoalCreateHoResponse = $this->brandApi->createOrUpdateOfferGoal(null, $offerGoalDetails, $tuneAccount);
1360. if ($offerGoalCreateHoResponse['response']['status'] === 1) {
1361. $offerGoalCreateHoResponseData = $offerGoalCreateHoResponse['response']['data']['Goal'];
1362. $this->doctrine->getRepository(OfferGoalsInfo::class)->insertToOfferGoalsInfo(
1363. $offerGoalCreateHoResponseData['id'],
1364. $offerGoalCreateHoResponseData['offer_id'],
1365. $offerGoalCreateHoResponseData['name'],
1366. $offerGoalCreateHoResponseData['description'],
1367. $offerGoalCreateHoResponseData['status'],
1368. $offerGoalCreateHoResponseData['is_private'],
1369. $offerGoalCreateHoResponseData['payout_type'],
1370. $offerGoalCreateHoResponseData['default_payout'],
1371. $offerGoalCreateHoResponseData['revenue_type'],
1372. $offerGoalCreateHoResponseData['max_payout'],
1373. $offerGoalCreateHoResponseData['tiered_payout'],
1374. $offerGoalCreateHoResponseData['tiered_revenue'],
1375. $offerGoalCreateHoResponseData['use_payout_groups'],
1376. $offerGoalCreateHoResponseData['use_revenue_groups'],
1377. $offerGoalCreateHoResponseData['advertiser_id'],
1378. $offerGoalCreateHoResponseData['protocol'],
1379. $offerGoalCreateHoResponseData['allow_multiple_conversions'],
1380. $offerGoalCreateHoResponseData['approve_conversions'],
1381. $offerGoalCreateHoResponseData['enforce_encrypt_tracking_pixels'],
1382. $offerGoalCreateHoResponseData['is_end_point'],
1383. $offerGoalCreateHoResponseData['ref_id'],
1384. $tuneAccount
1385. );
1386. }
1388. return $offerGoalCreateHoResponse;
1389. }
1391. public function uploadFile($offerId, $fileUrlToUpload, $creativeType, $isPrivate)
1392. {
1393. $fileData = @file_get_contents($fileUrlToUpload);
1394. $fileExtension = pathinfo($fileUrlToUpload, PATHINFO_EXTENSION);
1395. $fileName = $fileExtension === '' ? $offerId . "_" . basename($fileUrlToUpload) . '.png' : $offerId . "_" . basename($fileUrlToUpload);
1396. file_put_contents($fileName, $fileData);
1397. $fileResponse = $this->brandApi->offerFileAPI($offerId, $creativeType, $fileName, $fileName, $isPrivate);
1398. unlink($fileName);
1399. return $fileResponse;
1400. }
1402. public function convertStringFromCamelCaseToSnakeCase($input)
1403. {
1404. preg_match_all('!([A-Z][A-Z0-9]*(?=$|[A-Z][a-z0-9])|[A-Za-z][a-z0-9]+)!', $input, $matches);
1405. $ret = $matches[0];
1406. foreach ($ret as &$match) {
1407. $match = $match == strtoupper($match) ? strtolower($match) : lcfirst($match);
1408. }
1409. return implode('_', $ret);
1410. }
1412. public function convertStringFromSnakeCaseToCamelCase($input)
1413. {
1414. return lcfirst(implode('', array_map('ucfirst', explode('_', $input))));
1415. }
1417. public function getScraper()
1418. {
1419. return $this->scraper;
1420. }
1422. public function getOfferListByOfferIdArr($offerIdArr)
1423. {
1425. $response = [];
1427. if ($offerIdArr) {
1428. $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->getOffersByOfferIdsArr($offerIdArr);
1430. foreach ($offerInfo as $key => $value) {
1431. $response[$value['offerId']] = [
1432. 'id' => (int)$value['offerId'],
1433. 'name' => $value['name']
1434. ];
1435. }
1436. }
1438. return $response;
1439. }
1441. public function checkOfferAffiliateCapping($offerId, $affiliateId, $goalId)
1442. {
1444. $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->getOfferDataByOfferId($offerId);
1446. if (!$offerInfo) {
1447. return false;
1448. }
1450. $conversionCapByOfferIdHOData = $this->brandApi->getCappingByOfferId($offerId)['response']['data'];
1452. $conversionCap = $offerInfo->getConversionCap();
1453. $payoutCap = $offerInfo->getPayoutCap();
1454. $revenueCap = $offerInfo->getRevenueCap();
1456. $monthlyConversionCap = $offerInfo->getMonthlyConversionCap();
1457. $monthlyPayoutCap = $offerInfo->getMonthlyPayoutCap();
1458. $monthlyRevenueCap = $offerInfo->getMonthlyRevenueCap();
1460. foreach ($conversionCapByOfferIdHOData as $key => $value) {
1461. if ($value['OfferConversionCap']['offer_id'] == $offerId && $value['OfferConversionCap']['affiliate_id'] == $affiliateId) {
1463. $conversionCap = $value['OfferConversionCap']['conversion_cap'];
1464. $payoutCap = $value['OfferConversionCap']['payout_cap'];
1465. $revenueCap = $value['OfferConversionCap']['revenue_cap'];
1467. $monthlyConversionCap = $value['OfferConversionCap']['monthly_conversion_cap'];
1468. $monthlyPayoutCap = $value['OfferConversionCap']['monthly_payout_cap'];
1469. $monthlyRevenueCap = $value['OfferConversionCap']['monthly_revenue_cap'];
1471. break;
1472. }
1473. }
1475. $dailyConversionGenerated = 0;
1476. $dailyPayoutGenerated = 0;
1477. $dailyRevenueGenerated = 0;
1479. $monthlyConversionGenerated = 0;
1480. $monthlyPayoutGenerated = 0;
1481. $monthlyRevenueGenerated = 0;
1483. $statByDay = $this->brandApi->getStatsForCappingCheck($offerId, $affiliateId, $goalId, true, false)['response']['data']['data'];
1485. if (!empty($statByDay)) {
1486. $dailyConversionGenerated = $statByDay[0]['Stat']['conversions'];
1487. $dailyPayoutGenerated = $statByDay[0]['Stat']['payout'];
1488. $dailyRevenueGenerated = $statByDay[0]['Stat']['revenue'];
1489. }
1491. $statByMonth = $this->brandApi->getStatsForCappingCheck($offerId, $affiliateId, $goalId, false, true)['response']['data']['data'];
1493. if (!empty($statByMonth) && isset($statByDay[0])) {
1494. $monthlyConversionGenerated = $statByDay[0]['Stat']['conversions'];
1495. $monthlyPayoutGenerated = $statByDay[0]['Stat']['payout'];
1496. $monthlyRevenueGenerated = $statByDay[0]['Stat']['revenue'];
1497. }
1499. $conversionCapReached = $dailyConversionGenerated >= $conversionCap && $conversionCap != 0;
1500. $payoutCapReached = $dailyPayoutGenerated >= $payoutCap && $payoutCap != 0;
1501. $revenueCapReached = $dailyRevenueGenerated >= $revenueCap && $revenueCap != 0;
1503. $monthlyConversionCapReached = $monthlyConversionGenerated >= $monthlyConversionCap && $monthlyConversionCap != 0;
1504. $monthlyPayoutCapReached = $monthlyPayoutGenerated >= $monthlyPayoutCap && $monthlyPayoutCap != 0;
1505. $monthlyRevenueCapReached = $monthlyRevenueGenerated >= $monthlyRevenueCap && $monthlyRevenueCap != 0;
1507. $cappingReached = false;
1508. if ($conversionCapReached || $payoutCapReached || $revenueCapReached || $monthlyConversionCapReached || $monthlyPayoutCapReached || $monthlyRevenueCapReached) {
1509. $cappingReached = true;
1510. }
1512. return [
1513. 'conversionCap' => $conversionCap,
1514. 'payoutCap' => $payoutCap,
1515. 'revenueCap' => $revenueCap,
1516. 'monthlyConversionCap' => $monthlyConversionCap,
1517. 'monthlyPayoutCap' => $monthlyPayoutCap,
1518. 'monthlyRevenueCap' => $monthlyRevenueCap,
1519. 'dailyConversionGenerated' => $dailyConversionGenerated,
1520. 'dailyPayoutGenerated' => $dailyPayoutGenerated,
1521. 'dailyRevenueGenerated' => $dailyRevenueGenerated,
1522. 'monthlyConversionGenerated' => $monthlyConversionGenerated,
1523. 'monthlyPayoutGenerated' => $monthlyPayoutGenerated,
1524. 'monthlyRevenueGenerated' => $monthlyRevenueGenerated,
1525. 'conversionCapReached' => $conversionCapReached,
1526. 'payoutCapReached' => $payoutCapReached,
1527. 'revenueCapReached' => $revenueCapReached,
1528. 'monthlyConversionCapReached' => $monthlyConversionCapReached,
1529. 'monthlyPayoutCapReached' => $monthlyPayoutCapReached,
1530. 'monthlyRevenueCapReached' => $monthlyRevenueCapReached,
1531. 'cappingReached' => $cappingReached
1532. ];
1533. }
1536. public function appsBlackAndWhiteList($data)
1537. {
1539. $dateRange = 30;
1540. $minClicks = 100;
1541. $dataToProcess = [];
1543. foreach ($data as $key => $value) {
1544. $value['offerId'] ? $dataToProcess['offer'][$value['offerId']][$value['param']][$value['listType']][] = $value['appId'] : false;
1545. $value['advertiserId'] ? $dataToProcess['advertiser'][$value['advertiserId']][$value['param']][$value['listType']][] = $value['appId'] : false;
1546. $value['affiliateId'] ? $dataToProcess['affiliate'][$value['affiliateId']][$value['param']][$value['listType']][] = $value['appId'] : false;
1547. }
1549. $dataToBlock = [];
1550. foreach ($dataToProcess as $entityType => $entity) {
1551. foreach ($entity as $entityId => $entityData) {
1552. foreach ($entityData as $param => $paramData) {
1554. $advertiserId = $entityType == 'advertiser' ? $entityId : null;
1555. $affiliateId = $entityType == 'affiliate' ? $entityId : null;
1556. $offerId = $entityType == 'offer' ? $entityId : null;
1558. if ($advertiserId) {
1559. $addedFrom = Config::DISABLE_LINK_FROM_APPS_BLACK_AND_WHITE_LIST_BY_ADVERTISER;
1560. } elseif ($affiliateId) {
1561. $addedFrom = Config::DISABLE_LINK_FROM_APPS_BLACK_AND_WHITE_LIST_BY_AFFILIATE;
1562. } else {
1563. $addedFrom = Config::DISABLE_LINK_FROM_APPS_BLACK_AND_WHITE_LIST_BY_OFFER;
1564. }
1566. if ($advertiserId == null && $affiliateId == null && $offerId == null) {
1567. continue;
1568. }
1570. $statData = $this->brandApi->getStatsForAppBlackAndWhiteList($offerId, $affiliateId, $advertiserId, $dateRange, $minClicks, $param)['response']['data']['data'];
1572. foreach ($paramData as $listType => $appIds) {
1573. foreach ($statData as $key => $value) {
1574. $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->findOneBy(['offerId' => $value['Stat']['offer_id']]);
1575. if (
1576. !$offerInfo ||
1577. !in_array($offerInfo->getAppId(), $appIds)
1578. ) {
1579. continue;
1580. }
1581. $temp = [
1582. 'offerId' => $value['Stat']['offer_id'],
1583. 'affiliateId' => $value['Stat']['affiliate_id'],
1584. 'advertiserId' => $value['Stat']['advertiser_id'],
1585. 'param' => $param,
1586. 'paramValue' => $value['Stat'][$param],
1587. 'clicks' => $value['Stat']['clicks'],
1588. 'conversions' => $value['Stat']['conversions'],
1589. 'addedFrom' => $addedFrom,
1590. 'listType' => $listType
1591. ];
1593. if (array_key_exists('blacklist', $paramData) && in_array($value['Stat'][$param], $paramData['blacklist'])) {
1594. $dataToBlock[] = $temp;
1595. }
1597. if (array_key_exists('whitelist', $paramData) && !in_array($value['Stat'][$param], $paramData['whitelist'])) {
1598. $dataToBlock[] = $temp;
1599. }
1600. }
1601. }
1602. }
1603. }
1604. }
1606. return $dataToBlock;
1607. }
1609. public function setAffiliateOfferApproval($offerId, $affiliateId, $status, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
1610. {
1612. $combinationExist = $this->doctrine->getRepository(AffiliateOfferApproval::class)->checkIfOfferApproved($offerId, $affiliateId, $tuneAccount);
1614. if ($combinationExist && $combinationExist->getApprovalStatus() != $status) {
1615. $hoResponse = $this->brandApi->setOfferApprovalForAffiliate($offerId, $affiliateId, $status, $tuneAccount);
1616. if ($hoResponse['response']['status'] == 1) {
1617. $this->doctrine->getRepository(AffiliateOfferApproval::class)->updateAffiliateOfferApprovalById($combinationExist->getId(), [
1618. 'approvalStatus' => $status
1619. ]);
1620. }
1621. } elseif (!$combinationExist) {
1622. $hoResponse = $this->brandApi->setOfferApprovalForAffiliate($offerId, $affiliateId, $status, $tuneAccount);
1623. if ($hoResponse['response']['status'] == 1) {
1624. $this->doctrine->getRepository(AffiliateOfferApproval::class)->insertToAffiliateOfferApproval(null, $affiliateId, null, $offerId, null, null, null, $status, null, null, $tuneAccount);
1625. }
1626. }
1627. }
1629. public function disableLinkByExternalUrl($offerId, $advertiserId, $affiliateId, $source, $affSub2, $affSub3, $affSub5)
1630. {
1632. $stat = [
1633. 'offerId' => $offerId,
1634. 'advertiserId' => $advertiserId,
1635. 'affiliateId' => $affiliateId,
1636. 'source' => $source,
1637. 'affSub2' => $affSub2,
1638. 'affSub3' => $affSub3,
1639. 'affSub5' => $affSub5
1640. ];
1642. $link = Config::DISABLE_LINK_EXTERNAL_ENDPOINT . '?token=' . base64_encode(json_encode($stat));
1644. return $link;
1645. }
1647. public function getOfferInfoByKey($offerIdArr, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
1648. {
1650. if (!is_array($offerIdArr) || !sizeof($offerIdArr)) {
1651. return [];
1652. }
1653. $offerData = $this->doctrine->getRepository(OfferInfo::class)->getOffersByOfferIdsArr($offerIdArr, $tuneAccount);
1654. $offerInfo = [];
1655. foreach ($offerData as $key => $value) {
1656. $offerInfo[$value['offerId']] = $value;
1657. }
1659. return $offerInfo;
1660. }
1662. public function getMafoOfferInfoByKey($offerIdArr)
1663. {
1665. if (!is_array($offerIdArr) || !sizeof($offerIdArr)) {
1666. return [];
1667. }
1668. $offerData = $this->doctrine->getRepository(MafoOffers::class)->getMafoOffersByOfferIdsArr($offerIdArr);
1669. $offerInfo = [];
1670. foreach ($offerData as $key => $value) {
1671. $offerInfo[$value['id']] = $value;
1672. }
1674. return $offerInfo;
1675. }
1677. public function getEmployeesByEmployeeId()
1678. {
1680. $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HO_EMPLOYEES_LIST);
1682. if (!$cachedList) {
1683. $employeeList = $this->getWarmedUpEmployeesByEmployeeId();
1684. } else {
1685. $employeeList = json_decode($cachedList, true);
1686. }
1688. ksort($employeeList);
1690. return $employeeList;
1691. }
1693. public function getWarmedUpEmployeesByEmployeeId()
1694. {
1696. $employeesData = $this->doctrine->getRepository(Employees::class)->getEmployees();
1697. $data = [];
1698. foreach ($employeesData as $key => $value) {
1699. $data[$value['employeeId']] = [
1700. 'firstName' => $value['firstName'],
1701. 'lastName' => $value['lastName'],
1702. 'email' => $value['email'],
1703. 'fullName' => $value['fullName']
1704. ];
1705. }
1707. return $data;
1708. }
1710. public function getMd5ForMmpReport($advertiser, $offerCountry, $offerRegion, $offerCity, $appId, $event, $revenueModel, $payoutModel)
1711. {
1713. return md5(strtolower($advertiser) . '#' . strtolower($offerCountry) . '#' . strtolower($offerRegion) . '#' . strtolower($offerCity) . '#' . strtolower($appId) . '#' . strtolower($event) . '#' . strtolower($revenueModel) . '#' . strtolower($payoutModel));
1714. }
1716. public function updateAffiliateDBByIds($affiliateIds, $metaData)
1717. {
1719. $createApiKeyIfNotExist = $metaData['createApiKeyIfNotExist'] ?? false;
1720. $tuneAccount = $metaData['tuneAccount'] ?? Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE;
1722. $affiliateInfoArr = $this->brandApi->getAffiliateInfoByAffiliateIdsArr($affiliateIds, $tuneAccount)['response']['data'];
1723. foreach ($affiliateInfoArr as $key => $value) {
1724. $affiliateDBInfo = $this->doctrine->getRepository(AffiliateInfo::class)->findOneBy(['affiliateId' => $value['Affiliate']['id'], 'tuneAccount' => $tuneAccount]);
1725. if ($affiliateDBInfo) {
1726. $this->doctrine->getRepository(AffiliateInfo::class)->updateAffiliateInfoByAffiliateId($value['Affiliate']['id'], [
1727. 'status' => $value['Affiliate']['status'],
1728. 'accountManagerId' => $value['AccountManager'] !== null ? $value['AccountManager']['id'] : null,
1729. 'company' => $value['Affiliate']['company']
1730. ], $tuneAccount);
1731. } else {
1732. $this->doctrine->getRepository(AffiliateInfo::class)->insertToAffiliateInfo($value['Affiliate']['id'], $value['Affiliate']['company'], $value['AccountManager'] !== null ? $value['AccountManager']['id'] : null, $value['Affiliate']['status'], $tuneAccount);
1733. }
1735. // $this->mafoObjectsComponents->createOrUpdateAffiliate(Config::MAFO_SYSTEM_IDENTIFIER_TUNE, $value['Affiliate']['id']);
1736. // $execCommand = "php " . $this->rootPath . "/bin/console app:updateCache " . Config::CACHE_REDIS_HO_AFFILIATE_LIST_FOR_MULTISELECT . " --env=prod > /dev/null &";
1737. // exec($execCommand);
1739. if ($value['AffiliateUser'] !== null) {
1740. foreach ($value['AffiliateUser'] as $k => $v) {
1741. if ($v['status'] == Config::ACTIVE_STATUS) {
1743. if ($createApiKeyIfNotExist) {
1744. $apiKeyData = $this->doctrine->getRepository(UserApiKey::class)->findOneBy(['affiliateId' => $value['Affiliate']['id'], 'tuneAccount' => $tuneAccount]);
1745. if (!$apiKeyData) {
1746. $this->brandApi->generateApiKeyByUserId($k, $tuneAccount);
1747. }
1748. }
1750. $userApiData = $this->brandApi->getUserApiKey($k)['response']['data'];
1751. if ($userApiData) {
1753. $userApiKey = $this->doctrine->getRepository(UserApiKey::class)->findOneBy(['userId' => $k, 'tuneAccount' => $tuneAccount]);
1754. if ($userApiKey) {
1755. $this->doctrine->getRepository(UserApiKey::class)->updateUserApiKeyByUserId($k, [
1756. 'affiliateId' => $value['Affiliate']['id'],
1757. 'userType' => $userApiData['user_type'],
1758. 'apiKey' => $userApiData['api_key'],
1759. 'apiKeyStatus' => $userApiData['status'],
1760. 'userStatus' => $v['status']
1761. ], $tuneAccount);
1762. } else {
1763. $this->doctrine->getRepository(UserApiKey::class)->insertToUserApiKey($value['Affiliate']['id'], $k, $userApiData['user_type'], $userApiData['api_key'], $userApiData['status'], $v['status'], $tuneAccount);
1764. }
1765. }
1766. }
1767. }
1768. }
1770. if ($value['AccountManager'] !== null) {
1771. $affiliateAccountManagerDBInfo = $this->doctrine->getRepository(AffiliateAccountManager::class)->findOneBy(['affiliateId' => $value['Affiliate']['id'], 'tuneAccount' => $tuneAccount]);
1773. if ($affiliateAccountManagerDBInfo) {
1774. $this->doctrine->getRepository(AffiliateAccountManager::class)->updateDataByAffiliateId($value['Affiliate']['id'], [
1775. 'employeeId' => $value['AccountManager']['id'],
1776. 'email' => $value['AccountManager']['email'],
1777. 'firstName' => $value['AccountManager']['first_name'],
1778. 'lastName' => $value['AccountManager']['last_name'],
1779. 'status' => $value['AccountManager']['status'],
1780. ], $tuneAccount);
1781. } else {
1782. $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);
1783. }
1784. }
1786. $affiliateTagRelationship = $this->brandApi->getAffiliateTagRelationByAffiliateId($value['Affiliate']['id'], $tuneAccount);
1788. if ($affiliateTagRelationship['response']['status'] == 1) {
1789. $affiliateTags = [];
1790. foreach ($affiliateTagRelationship['response']['data']['data'] as $k => $v) {
1791. !in_array($v['AffiliatesTags']['tag_id'], $affiliateTags) ? array_push($affiliateTags, $v['AffiliatesTags']['tag_id']) : false;
1792. }
1793. $affiliateDBTagsData = $this->doctrine->getRepository(AffiliateTagRelationship::class)->getAffiliateTagRelationshipByAffiliateId($value['Affiliate']['id'], $tuneAccount);
1794. $affiliateDBTags = [];
1795. foreach ($affiliateDBTagsData as $k => $v) {
1796. !in_array($v['tagId'], $affiliateDBTags) ? array_push($affiliateDBTags, $v['tagId']) : false;
1797. }
1799. if ($affiliateDBTags != $affiliateTags) {
1800. $this->doctrine->getRepository(AffiliateTagRelationship::class)->deleteAffiliateTagRelationshipByAffiliateId($value['Affiliate']['id'], $tuneAccount);
1801. foreach ($affiliateTags as $affiliateTag) {
1802. $this->doctrine->getRepository(AffiliateTagRelationship::class)->insertToAffiliateTagRelationship($affiliateTag, $value['Affiliate']['id'], $tuneAccount);
1803. }
1804. }
1805. }
1806. }
1807. }
1809. public function updateAdvertiserDBById($advertiserId, $metaData, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
1810. {
1811. $this->updateAdvertiserDBByIds([$advertiserId], $tuneAccount);
1814. if ($this->doctrine->getRepository(AdvertiserInfo::class)->findOneBy(['advertiserId' => $advertiserId, 'tuneAccount' => $tuneAccount])) {
1815. $advertiserDiscountType = $metaData['advertiserDiscountType'] ?? Config::ADVERTISER_DISCOUNT_TYPE_NO_DISCOUNT;
1816. $advertiserDiscountValue = $metaData['advertiserDiscountValue'] ?? null;
1817. if ($advertiserDiscountValue < 1 || $advertiserDiscountValue > 100) {
1818. $advertiserDiscountType = Config::ADVERTISER_DISCOUNT_TYPE_NO_DISCOUNT;
1819. $advertiserDiscountValue = null;
1820. }
1821. $this->doctrine->getRepository(AdvertiserInfo::class)->updateAdvertiserInfoByAdvertiserId($advertiserId, [
1822. 'discountValue' => $advertiserDiscountType !== Config::ADVERTISER_DISCOUNT_TYPE_NO_DISCOUNT ? $advertiserDiscountValue : 0,
1823. 'discountType' => $advertiserDiscountType,
1824. ], $tuneAccount);
1825. }
1826. }
1828. public function updateAdvertiserDBByIds($advertiserIds, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
1829. {
1831. $advertiserInfoArr = $this->brandApi->getAdvertiserInfoByAdvertiserIdsArr($advertiserIds, $tuneAccount)['response']['data'];
1833. foreach ($advertiserInfoArr as $key => $value) {
1834. $advertiserDBInfo = $this->doctrine->getRepository(AdvertiserInfo::class)->findOneBy([
1835. 'advertiserId' => $value['Advertiser']['id'],
1836. 'tuneAccount' => $tuneAccount
1837. ]);
1838. if ($advertiserDBInfo) {
1839. $this->doctrine->getRepository(AdvertiserInfo::class)->updateAdvertiserInfoByAdvertiserId($value['Advertiser']['id'], [
1840. 'status' => $value['Advertiser']['status'],
1841. 'accountManagerId' => $value['AccountManager'] !== null ? $value['AccountManager']['id'] : null,
1842. 'company' => $value['Advertiser']['company']
1843. ], $tuneAccount);
1844. } else {
1845. $this->doctrine->getRepository(AdvertiserInfo::class)->insertToAdvertiserInfo($value['Advertiser']['id'], $value['Advertiser']['company'], $value['AccountManager'] !== null ? $value['AccountManager']['id'] : null, $value['Advertiser']['status'], $tuneAccount);
1846. }
1848. // $this->mafoObjectsComponents->createOrUpdateAdvertiser(Config::MAFO_SYSTEM_IDENTIFIER_TUNE, $value['Advertiser']['id']);
1849. // $execCommand = "php " . $this->rootPath . "/bin/console app:updateCache " . Config::CACHE_REDIS_HO_ADVERTISER_LIST_FOR_MULTISELECT . " --env=prod > /dev/null &";
1850. // exec($execCommand);
1852. if ($value['AccountManager'] !== null) {
1853. $affiliateAccountManagerDBInfo = $this->doctrine->getRepository(AdvertiserAccountManager::class)->findOneBy(['advertiserId' => $value['Advertiser']['id']]);
1855. if ($affiliateAccountManagerDBInfo) {
1856. $this->doctrine->getRepository(AdvertiserAccountManager::class)->updateDataByAdvertiserId($value['Advertiser']['id'], [
1857. 'employeeId' => $value['AccountManager']['id'],
1858. 'email' => $value['AccountManager']['email'],
1859. 'firstName' => $value['AccountManager']['first_name'],
1860. 'lastName' => $value['AccountManager']['last_name'],
1861. 'status' => $value['AccountManager']['status'],
1862. ], $tuneAccount);
1863. } else {
1864. $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);
1865. }
1866. }
1868. $advertiserTagRelationship = $this->brandApi->getAdvertiserTagRelationByAdvertiserId($value['Advertiser']['id'], $tuneAccount);
1870. if ($advertiserTagRelationship['response']['status'] == 1) {
1871. $advertiserTags = [];
1872. foreach ($advertiserTagRelationship['response']['data']['data'] as $k => $v) {
1873. !in_array($v['AdvertisersTags']['tag_id'], $advertiserTags) ? array_push($advertiserTags, $v['AdvertisersTags']['tag_id']) : false;
1874. }
1875. $advertiserDBTagsData = $this->doctrine->getRepository(AdvertiserTagRelationship::class)->getAdvertiserTagRelationshipByAdvertiserId($value['Advertiser']['id'], $tuneAccount);
1876. $advertiserDBTags = [];
1877. foreach ($advertiserDBTagsData as $k => $v) {
1878. !in_array($v['tagId'], $advertiserDBTags) ? array_push($advertiserDBTags, $v['tagId']) : false;
1879. }
1881. if ($advertiserDBTags != $advertiserTags) {
1882. $this->doctrine->getRepository(AdvertiserTagRelationship::class)->deleteAdvertiserTagRelationshipByAdvertiserId($value['Advertiser']['id'], $tuneAccount);
1883. foreach ($advertiserTags as $advertiserTag) {
1884. $this->doctrine->getRepository(AdvertiserTagRelationship::class)->insertToAdvertiserTagRelationship($advertiserTag, $value['Advertiser']['id'], $tuneAccount);
1885. }
1886. }
1887. }
1888. }
1889. }
1891. public function getEmployeesWithEmailAsKey()
1892. {
1894. $employeesData = $this->doctrine->getRepository(Employees::class)->getEmployees();
1895. $employees = [];
1897. foreach ($employeesData as $key => $value) {
1898. $employees[strtolower($value['email'])] = $value;
1899. }
1901. return $employees;
1902. }
1904. public function getNewsletterBuilderTemplate($offerIds, $introduction, $unsubscribeEmailId = '')
1905. {
1907. $offerInfoFromApi = [];
1908. if ($offerIds) {
1909. $offerInfoFromApi = $this->doctrine->getRepository(OfferInfo::class)->getOffersByOfferIdsArr($offerIds);
1910. }
1912. $offerInfoByOfferId = [];
1913. foreach ($offerIds as $offerId) {
1914. foreach ($offerInfoFromApi as $key => $value) {
1915. if ($offerId == $value['offerId']) {
1916. $value['geos'] = json_decode($value['geoIdsJson'], true);
1917. $offerInfoByOfferId[] = $value;
1918. }
1919. }
1920. }
1922. return $this->template->render('components/newsletterBuilder.html.twig', [
1923. 'offerDetails' => $offerInfoByOfferId,
1924. 'introduction' => $introduction,
1925. 'unsubscribeLink' => "http://firehose.mobupps.com/api/unsubscribe/" . $unsubscribeEmailId
1926. ]);
1927. }
1929. public function getOfferGoalInfoByOfferGoalIdArrWithKeys($offerGoalIdArr)
1930. {
1932. $offerGoalData = $this->doctrine->getRepository(OfferGoalsInfo::class)->getGoalInfoByGoalIdArr($offerGoalIdArr);
1933. $data = [];
1934. foreach ($offerGoalData as $key => $value) {
1935. $data[$value['goalId']] = $value;
1936. }
1938. return $data;
1939. }
1941. public function getSkadNetworkMessageSeparator()
1942. {
1943. return mb_chr(Config::SKADNETWORK_MESSAGE_SEPARATOR_CODE);
1944. }
1946. public function setCommandLoggerData($identifier, $commandName, $meta)
1947. {
1949. $identifierExists = $this->doctrine->getRepository(CommandLogger::class)->findOneBy([
1950. 'identifier' => $identifier
1951. ]);
1953. if (is_array($meta)) {
1954. $meta = json_encode($meta);
1955. }
1957. $currentTimestamp = strtotime('now');
1959. if (!$identifierExists) {
1960. $this->doctrine->getRepository(CommandLogger::class)->insertToCommandLogger($identifier, $commandName, $currentTimestamp, null, null, null);
1961. } else {
1962. $this->doctrine->getRepository(CommandLogger::class)->updateCommandLoggerById($identifierExists->getId(), [
1963. 'endTimestamp' => $currentTimestamp,
1964. 'timestampDiff' => $currentTimestamp - $identifierExists->getStartTimestamp(),
1965. 'meta' => $meta
1966. ]);
1967. }
1968. }
1970. public function getMafoUsersWithEmailIdAsKey()
1971. {
1972. $users = $this->doctrine->getRepository('App\Entity\Users')->getUsers();
1974. $arr = [];
1975. foreach ($users as $key => $value) {
1976. $name = explode(' ', $value['name']);
1977. $value['firstName'] = $name[0];
1978. $arr[$value['email']] = $value;
1979. }
1981. return $arr;
1982. }
1985. public function checkAlertMetaExists($identifier, $type)
1986. {
1987. $identifierExists = $this->doctrine->getRepository(AlertMeta::class)->findOneBy(['identifier' => $identifier]);
1989. if (!$identifierExists) {
1990. $this->doctrine->getRepository(AlertMeta::class)->insertToAlertMeta($identifier, $type);
1991. return false;
1992. } else {
1993. return true;
1994. }
1995. }
1997. public function getHourOffsetFromTimezoneString($timezone)
1998. {
1999. $hourOffset = '+0:00';
2000. if (array_key_exists($timezone, Config::TIMEZONES)) {
2001. $timezone = Config::TIMEZONES[$timezone];
2002. $timezone = explode(" ", $timezone)[0];
2003. $timezone = str_replace("(GMT", "", $timezone);
2004. $hourOffset = str_replace(")", "", $timezone);
2005. }
2006. return $hourOffset;
2007. }
2010. public function processPendingPostback($postbackLogId)
2011. {
2013. $postbackLogData = $this->doctrine->getRepository(SkadNetworkPostbackLogs::class)->findOneBy(['id' => $postbackLogId]);
2014. $endpoint = $postbackLogData->getEndpoint();
2015. $appId = $postbackLogData->getAppId();
2016. $campaignId = $postbackLogData->getCampaignId();
2017. $payload = json_decode($postbackLogData->getRequest(), true);
2018. $isAttributionSignatureValid = $postbackLogData->getIsAttributionSignatureValid();
2019. $postbackTimestamp = $postbackLogData->getDateInserted()->getTimestamp();
2021. $offerId = null;
2022. $affiliateId = null;
2023. $skadNetworkPostbackMappingExists = null;
2024. if ($endpoint == Config::SKADNETWORK_POSTBACK_ENDPOINT_WMADV) {
2025. $skadNetworkPostbackMappingExists = $this->doctrine->getRepository(SkadNetworkManualPostbackMapping::class)->findOneBy([
2026. 'appId' => $appId,
2027. 'campaignId' => $campaignId,
2028. 'isDeleted' => 0
2029. ]);
2031. if ($skadNetworkPostbackMappingExists) {
2032. $offerId = $skadNetworkPostbackMappingExists->getOfferId();
2033. $affiliateId = $skadNetworkPostbackMappingExists->getAffiliateId();
2034. }
2035. } else {
2036. $apiLogsData = $this->doctrine->getRepository(SkadNetworkApiLogs::class)->findOneBy(['appId' => $appId, 'campaignId' => $campaignId]);
2037. if ($apiLogsData) {
2038. $offerId = $apiLogsData->getOfferId();
2039. $affiliateId = $apiLogsData->getAffiliateId();
2040. }
2041. }
2043. $postbacksToMake = [];
2044. if ($isAttributionSignatureValid && $postbackLogData->getDidWin()) {
2045. if ($offerId) {
2046. $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->findOneBy(['offerId' => $offerId]);
2047. if ($offerInfo && $offerInfo->getSkadNetworkMmp() && in_array($offerInfo->getSkadNetworkMmp(), Config::SKADNETOWRK_MMP)) {
2048. if ($offerInfo->getSkadNetworkMmp() == Config::SKADNETWORK_MMP_ADJUST && $offerInfo->getSkadNetworkAdjustTracker()) {
2050. $offerGeoRelationship = $this->doctrine->getRepository(OfferGeoRelationship::class)->findOneBy(['offerId' => $offerInfo->getOfferId()]);
2052. $postbackParams = [
2053. 'tracker' => $offerInfo->getSkadNetworkAdjustTracker(),
2054. 'sk_payload' => urlencode($payload),
2055. 'sk_ts' => strtotime('now')
2056. ];
2058. if ($offerGeoRelationship && $offerGeoRelationship->getGeo()) {
2059. $postbackParams['country'] = strtolower($offerGeoRelationship->getGeo());
2060. }
2062. $postbacksToMake[] = [
2063. 'requestType' => Config::HTTP_METHOD_POST,
2064. 'requestUrl' => Config::SKADNETOWRK_MMP_POSTBACK_URL[$offerInfo->getSkadNetworkMmp()] . '?' . http_build_query($postbackParams),
2065. 'postbackForMmp' => true,
2066. 'skadNetworkMmp' => Config::SKADNETWORK_MMP_ADJUST
2067. ];
2068. } else if ($offerInfo->getSkadNetworkMmp() == Config::SKADNETWORK_MMP_BRANCH) {
2069. $postbacksToMake[] = [
2070. 'requestType' => Config::HTTP_METHOD_POST,
2071. 'requestUrl' => Config::SKADNETOWRK_MMP_POSTBACK_URL[Config::SKADNETWORK_MMP_BRANCH],
2072. 'postbackForMmp' => true,
2073. 'skadNetworkMmp' => Config::SKADNETWORK_MMP_BRANCH
2074. ];
2075. if ($skadNetworkPostbackMappingExists) {
2076. if ($skadNetworkPostbackMappingExists->getBranchPartnerCampaignId()) {
2077. $payload['partner-campaign-id'] = $skadNetworkPostbackMappingExists->getBranchPartnerCampaignId();
2078. }
2079. if ($skadNetworkPostbackMappingExists->getBranchPartnerCampaignName()) {
2080. $payload['partner-campaign-name'] = $skadNetworkPostbackMappingExists->getBranchPartnerCampaignName();
2081. }
2082. if ($skadNetworkPostbackMappingExists->getBranchPartnerAdSetId()) {
2083. $payload['partner-ad-set-id'] = $skadNetworkPostbackMappingExists->getBranchPartnerAdSetId();
2084. }
2085. if ($skadNetworkPostbackMappingExists->getBranchPartnerAdSetName()) {
2086. $payload['partner-ad-set-name'] = $skadNetworkPostbackMappingExists->getBranchPartnerAdSetName();
2087. }
2088. if ($skadNetworkPostbackMappingExists->getBranchPartnerAdId()) {
2089. $payload['partner-ad-id'] = $skadNetworkPostbackMappingExists->getBranchPartnerAdId();
2090. }
2091. if ($skadNetworkPostbackMappingExists->getBranchPartnerAdName()) {
2092. $payload['partner-ad-name'] = $skadNetworkPostbackMappingExists->getBranchPartnerAdName();
2093. }
2094. if ($skadNetworkPostbackMappingExists->getBranchPartnerCreativeId()) {
2095. $payload['partner-creative-id'] = $skadNetworkPostbackMappingExists->getBranchPartnerCreativeId();
2096. }
2097. if ($skadNetworkPostbackMappingExists->getBranchPartnerCreativeName()) {
2098. $payload['partner-creative-name'] = $skadNetworkPostbackMappingExists->getBranchPartnerCreativeName();
2099. }
2100. }
2101. } else if ($offerInfo->getSkadNetworkMmp() == Config::SKADNETWORK_MMP_APPSFLYER) {
2102. // $payload['ad-network-campaign-id'] = $campaignId . "";
2103. // $payload['ad-network-campaign-name'] = $offerId . "";
2104. // $payload['ad-network-country-code'] = implode(",", json_decode($offerInfo->getGeoIdsJson(), true));
2105. // $payload['timestamp'] = $postbackTimestamp;
2107. // if($affiliateId) {
2108. // $payload['source-app-id'] = $affiliateId."";
2109. // $payload['ad-network-source-app-id'] = $affiliateId."";
2110. // }
2112. $postbacksToMake[] = [
2113. 'requestType' => Config::HTTP_METHOD_POST,
2114. 'requestUrl' => Config::SKADNETOWRK_MMP_POSTBACK_URL[$offerInfo->getSkadNetworkMmp()],
2115. 'postbackForMmp' => true,
2116. 'skadNetworkMmp' => $offerInfo->getSkadNetworkMmp()
2117. ];
2118. } else {
2119. $postbacksToMake[] = [
2120. 'requestType' => Config::HTTP_METHOD_POST,
2121. 'requestUrl' => Config::SKADNETOWRK_MMP_POSTBACK_URL[$offerInfo->getSkadNetworkMmp()],
2122. 'postbackForMmp' => true,
2123. 'skadNetworkMmp' => $offerInfo->getSkadNetworkMmp()
2124. ];
2125. }
2126. }
2127. }
2129. if ($affiliateId) {
2130. $affiliateInfo = $this->doctrine->getRepository(AffiliateInfo::class)->findOneBy(['affiliateId' => $affiliateId]);
2131. if ($affiliateInfo && $affiliateInfo->getSkadNetworkPostbackUrl()) {
2132. $postbacksToMake[] = [
2133. 'requestType' => Config::HTTP_METHOD_POST,
2134. 'requestUrl' => $affiliateInfo->getSkadNetworkPostbackUrl(),
2135. 'postbackForMmp' => false
2136. ];
2137. }
2138. }
2140. foreach ($postbacksToMake as $key => $value) {
2142. $result = false;
2143. if ($value['requestType'] == Config::HTTP_METHOD_POST) {
2144. $postdata = json_encode($payload);
2145. $ch = curl_init($value['requestUrl']);
2146. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
2147. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
2148. curl_setopt($ch, CURLOPT_POST, 1);
2149. curl_setopt($ch, CURLOPT_POSTFIELDS, $postdata);
2150. curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
2151. curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
2152. curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/json'));
2153. $result = curl_exec($ch);
2154. curl_close($ch);
2155. } elseif ($value['requestType'] == Config::HTTP_METHOD_GET) {
2156. $ch = curl_init($value['requestUrl']);
2157. curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
2158. curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
2159. curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/json'));
2160. $result = curl_exec($ch);
2161. curl_close($ch);
2162. }
2164. if ($result) {
2165. if (array_key_exists('postbackForMmp', $value) && $value['postbackForMmp']) {
2166. if (
2167. array_key_exists('skadNetworkMmp', $value) &&
2168. $value['skadNetworkMmp'] == Config::SKADNETWORK_MMP_BRANCH
2169. ) {
2170. $result = json_decode($result, true);
2171. if (array_key_exists('id', $result)) {
2172. $this->doctrine->getRepository(SkadNetworkPostbackLogs::class)->updateSkadNetworkPostbackLogs($postbackLogId, [
2173. 'isPostbackScheduledForMmp' => false,
2174. 'branchPostbackId' => $result['id']
2175. ]);
2176. }
2177. } else if ($value['skadNetworkMmp'] == Config::SKADNETWORK_MMP_APPSFLYER) {
2178. $this->doctrine->getRepository(SkadNetworkPostbackLogs::class)->updateSkadNetworkPostbackLogs($postbackLogId, [
2179. 'isPostbackScheduledForMmp' => false
2180. ]);
2181. }
2182. } else {
2183. $this->doctrine->getRepository(SkadNetworkPostbackLogs::class)->updateSkadNetworkPostbackLogs($postbackLogId, [
2184. 'isPostbackScheduledForAffiliate' => false
2185. ]);
2186. }
2187. }
2188. }
2189. }
2190. }
2192. public function getAppInfoByAppIdArrWithKeys($appIdArr)
2193. {
2194. $appData = [];
2195. if ($appIdArr) {
2196. $appData = $this->doctrine->getRepository(AppInfo::class)->getDataByAppIds($appIdArr);
2197. }
2199. $arr = [];
2200. foreach ($appData as $key => $value) {
2201. $arr[$value['appId']] = $value;
2202. }
2204. return $arr;
2205. }
2207. public function getAppInfoWithKeys($fromCache = true)
2208. {
2209. $arr = [];
2210. if ($fromCache) {
2211. $arr = $this->elasticCache->redisGet(Config::CACHE_REDIS_APP_INFO_KEY);
2212. }
2214. if (!$arr) {
2215. $appData = $this->doctrine->getRepository(AppInfo::class)->getAppIds();
2217. $arr = [];
2218. foreach ($appData as $key => $value) {
2219. $arr[$value['appId']] = $value;
2220. }
2221. } else {
2222. $arr = json_decode($arr, true);
2223. }
2225. return $arr;
2226. }
2228. public function getDataFromJsonFile($jsonFileName)
2229. {
2231. $json = file_get_contents($this->rootPath . "/src/Resources/json/" . $jsonFileName . ".json");
2233. if (in_array($jsonFileName, [Config::JSON_FILE_FINANCIAL_TOOLS_GAP_CONTROL, Config::JSON_FILE_FINANCIAL_TOOLS_MAFO_GAP_CONTROL])) {
2235. $teamsByTeamId = $this->usersComponents->getTeamsByTeamId();
2236. $usersByTeamId = $this->usersComponents->getMafoUsersByTeamIds();
2238. $columnsData = json_decode($json, true);
2239. foreach ($usersByTeamId as $teamId => $users) {
2240. if (sizeof($users)) {
2241. $columnsData[$teamsByTeamId[$teamId]['label'] . 'Cost'] = [
2242. 'header' => $teamsByTeamId[$teamId]['label'] . ' Media Cost',
2243. 'accessor' => $teamsByTeamId[$teamId]['label'] . 'Cost',
2244. 'percentageWidth' => 5,
2245. 'show' => true,
2246. 'disabled' => false,
2247. 'customClass' => 'text-right',
2248. 'category' => 'statistics',
2249. 'footerEnabled' => true,
2250. 'aggregate' => 'sum',
2251. // 'alwaysEnabled' => true
2252. ];
2253. }
2254. }
2256. $itemsToBePushedToEnd = ['totalAffiliateCost', 'gap'];
2257. $arrToBePushedToEnd = [];
2258. foreach ($itemsToBePushedToEnd as $key => $value) {
2259. $arrToBePushedToEnd[$value] = $columnsData[$value];
2260. unset($columnsData[$value]);
2261. }
2262. $columnsData = array_merge($columnsData, $arrToBePushedToEnd);
2264. $json = json_encode($columnsData);
2265. }
2267. return json_decode($json, true);
2268. }
2270. public function changeColumnVisibilityForTable($tableColumns, $selectedColumns, $groupedColumns)
2271. {
2272. foreach ($tableColumns as $key => $value) {
2273. $tableColumns[$key]['show'] = false;
2274. foreach ($selectedColumns as $k => $v) {
2275. if ($value['accessor'] === $k && $v !== 'undefined') {
2276. $tableColumns[$key]['show'] = $v == '0' ? false : true;
2277. break;
2278. }
2279. }
2280. foreach ($groupedColumns as $k => $v) {
2281. if ($value['accessor'] === $k && $v !== 'undefined') {
2282. $tableColumns[$key]['groupBy'] = !($v == '0');
2283. !($v == '0') ? $tableColumns[$key]['show'] = true : null;
2284. break;
2285. }
2286. }
2287. }
2288. return $tableColumns;
2289. }
2291. public function downloadCSV($tableColumns, $data, $reportNamePretty)
2292. {
2294. $reportName = str_replace(" ", "-", strtolower($reportNamePretty));
2295. $header = [];
2296. foreach ($tableColumns as $key => $value) {
2297. if ($value['show'] == 1) {
2298. $headerValue = isset($value['Header']) ? $value['Header'] : (isset($value['header']) ? $value['header'] : null);
2299. array_push($header, $headerValue);
2300. }
2301. }
2303. $rows = [$header];
2304. foreach ($data as $key => $value) {
2305. $row = [];
2306. foreach ($tableColumns as $k => $v) {
2307. if ($v['show'] == 1) {
2309. if ($v['accessor'] == 'comments' && is_array($value[$v['accessor']])) {
2310. $comments = '';
2311. foreach ($value[$v['accessor']] as $commentKey => $commentValue) {
2312. $commentValue['comment'] = $commentValue['isDeleted'] ? "**This comment was deleted.**" : $commentValue['comment'];
2313. $comments .= "{$commentValue['addedByName']} [{$commentValue['dateInserted']}]: {$commentValue['comment']}\n";
2314. }
2315. $value[$v['accessor']] = $comments;
2316. } elseif ($v['accessor'] == 'attachedFiles') {
2317. $value[$v['accessor']] = $value['linkToFile'];
2318. } elseif (is_array($value[$v['accessor']])) {
2319. $items = '';
2320. if (array_key_exists('label', $value[$v['accessor']])) {
2321. $items .= $value[$v['accessor']]['label'];
2322. } else {
2323. foreach ($value[$v['accessor']] as $kk => $vv) {
2324. if (array_key_Exists('label', $vv)) {
2325. $items .= $vv['label'] . "\n";
2326. }
2327. }
2328. }
2329. $value[$v['accessor']] = $items;
2330. }
2333. array_push($row, $value[$v['accessor']]);
2334. }
2335. }
2336. $rows[] = $row;
2337. }
2339. $spreadsheet = new Spreadsheet();
2340. $spreadsheet->getProperties()->setCreator('MAFO')->setLastModifiedBy('MAFO')->setTitle($reportNamePretty . ' Report')->setSubject($reportNamePretty)->setDescription($reportNamePretty);
2342. // echo json_encode($rows);die;
2343. $spreadsheet->getActiveSheet()->fromArray($rows, null, 'A1');
2345. header('Content-Type: application/vnd.ms-excel');
2346. header('Content-Disposition: attachment;filename="' . $reportName . '.xls"');
2347. header('Cache-Control: max-age=0');
2348. $writer = IOFactory::createWriter($spreadsheet, 'Xls');
2349. $writer->save('php://output');
2350. exit;
2351. }
2353. public function getReportResponse($finalArr, $tableColumns, $limit, $page, $sortBy, $sortType)
2354. {
2356. foreach ($finalArr as $key => $value) {
2357. foreach ($tableColumns as $k => $v) {
2358. if (isset($v['footerEnabled'])) {
2359. if (!array_key_exists('Footer', $v)) {
2360. $tableColumns[$k]['Footer'] = 0;
2361. }
2363. if (array_key_exists($v['accessor'], $value)) {
2364. $tableColumns[$k]['Footer'] += $value[$v['accessor']];
2365. }
2366. }
2367. }
2368. }
2370. foreach ($tableColumns as $key => $value) {
2371. if (isset($value['footerEnabled']) && isset($value['Footer'])) {
2372. $tableColumns[$key]['Footer'] = round($value['Footer'], 2);
2373. }
2374. }
2376. if (sizeof($finalArr)) {
2377. $entity = $finalArr[0];
2378. if (array_key_exists($sortBy, $entity)) {
2379. $sortFlag = 3;
2380. if ($sortType == Config::SORT_TYPE_ASC) {
2381. $sortFlag = 4;
2382. }
2383. array_multisort(array_column($finalArr, $sortBy), $sortFlag, $finalArr);
2384. }
2385. }
2387. $offset = $limit * ($page - 1);
2389. $totalRecordCount = sizeof($finalArr);
2390. $noOfPages = ceil($totalRecordCount / $limit);
2391. $finalArr = array_slice($finalArr, $offset, $limit);
2393. return [
2394. 'response' => [
2395. 'success' => true,
2396. 'httpStatus' => Config::HTTP_STATUS_CODE_OK,
2397. 'data' => [
2398. 'tableColumns' => $tableColumns,
2399. 'data' => $finalArr,
2400. 'metaData' => [
2401. "total" => $totalRecordCount,
2402. "limit" => $limit,
2403. "page" => $page,
2404. "pages" => $noOfPages
2405. ]
2406. ],
2407. 'error' => null
2408. ]
2409. ];
2410. }
2412. public function getDeductionForAdvertiserAndAffiliateForPeriod($offerId, $advertiserId, $affiliateId, $startDate, $endDate)
2413. {
2414. $totalDeduction = 0;
2415. $approvedDeduction = 0;
2416. if (
2417. $this->doctrine->getRepository(AdvertiserInfo::class)->findOneBy(['advertiserId' => $advertiserId]) &&
2418. $this->doctrine->getRepository(AffiliateInfo::class)->findOneBy(['affiliateId' => $affiliateId])
2419. ) {
2420. $deductionControlData = $this->doctrine->getRepository(DeductionControl::class)->getDeductionControlData($offerId ? [$offerId] : [], $advertiserId ? [$advertiserId] : [], $affiliateId ? [$affiliateId] : [], [], [], $startDate, $endDate, 0, []);
2421. foreach ($deductionControlData as $key => $value) {
2422. $totalDeduction += $value['deductionValue'];
2423. if ($value['status'] === Config::REVENUE_CONTROL_STATUS_APPROVED) {
2424. $approvedDeduction += $value['deductionValue'];
2425. }
2426. }
2427. }
2429. return [
2430. 'advertiserId' => $advertiserId,
2431. 'affiliateId' => $affiliateId,
2432. 'totalDeduction' => round($totalDeduction, 2),
2433. 'approvedDeduction' => round($approvedDeduction, 2),
2434. ];
2435. }
2437. public function getMafoDeductionForAdvertiserAndAffiliateForPeriod($offerId, $advertiserId, $affiliateId, $startDate, $endDate)
2438. {
2439. $totalDeduction = 0;
2440. $approvedDeduction = 0;
2441. if (
2442. $this->doctrine->getRepository(MafoAdvertisers::class)->findOneBy(['id' => $advertiserId]) &&
2443. $this->doctrine->getRepository(MafoAffiliates::class)->findOneBy(['id' => $affiliateId])
2444. ) {
2445. $deductionControlData = $this->doctrine->getRepository(MafoDeductionControl::class)->getMafoDeductionControlData($offerId ? [$offerId] : [], $advertiserId ? [$advertiserId] : [], $affiliateId ? [$affiliateId] : [], [], [], $startDate, $endDate, 0, []);
2446. foreach ($deductionControlData as $key => $value) {
2447. $totalDeduction += $value['deductionValue'];
2448. if ($value['status'] === Config::REVENUE_CONTROL_STATUS_APPROVED) {
2449. $approvedDeduction += $value['deductionValue'];
2450. }
2451. }
2452. }
2454. return [
2455. 'advertiserId' => $advertiserId,
2456. 'affiliateId' => $affiliateId,
2457. 'totalDeduction' => round($totalDeduction, 2),
2458. 'approvedDeduction' => round($approvedDeduction, 2),
2459. ];
2460. }
2462. public function getIndexedDeductionFromDeductionControlByAdvertiserAndAffiliate($startDate, $endDate)
2463. {
2465. $indexedDeduction = [];
2467. $deductionControlData = $this->doctrine->getRepository(DeductionControl::class)->getDeductionControlData([], [], [], [], [], $startDate, $endDate, 0, []);
2469. foreach ($deductionControlData as $key => $value) {
2471. $deductionPeriod = $value['deductionPeriod']->format('Y-m');
2472. if (!isset($indexedDeduction[$deductionPeriod])) {
2473. $indexedDeduction[$deductionPeriod] = [];
2474. }
2475. if (!isset($indexedDeduction[$deductionPeriod][$value['advertiserId']])) {
2476. $indexedDeduction[$deductionPeriod][$value['advertiserId']] = [];
2477. }
2478. if (!isset($indexedDeduction[$deductionPeriod][$value['advertiserId']][$value['affiliateId']])) {
2479. $indexedDeduction[$deductionPeriod][$value['advertiserId']][$value['affiliateId']] = [
2480. 'advertiserId' => $value['advertiserId'],
2481. 'affiliateId' => $value['affiliateId'],
2482. 'totalDeduction' => 0,
2483. 'approvedDeduction' => 0
2484. ];
2485. }
2487. $indexedDeduction[$deductionPeriod][$value['advertiserId']][$value['affiliateId']]['totalDeduction'] += $value['deductionValue'];
2488. if ($value['status'] === Config::REVENUE_CONTROL_STATUS_APPROVED) {
2489. $indexedDeduction[$deductionPeriod][$value['advertiserId']][$value['affiliateId']]['approvedDeduction'] += $value['deductionValue'];
2490. }
2491. }
2493. return $indexedDeduction;
2494. }
2496. public function detectCSVDelimiter($csvFile)
2497. {
2498. $delimiters = [";" => 0, "," => 0, "\t" => 0, "|" => 0];
2500. $handle = fopen($csvFile, "r");
2501. $firstLine = fgets($handle);
2502. fclose($handle);
2503. foreach ($delimiters as $delimiter => &$count) {
2504. $count = count(str_getcsv($firstLine, $delimiter));
2505. }
2507. return array_search(max($delimiters), $delimiters);
2508. }
2510. public function assignTagsToOffers()
2511. {
2512. $activeOffers = $this->doctrine->getRepository(OfferInfo::class)->getOfferInfoByStatus(Config::ACTIVE_STATUS);
2514. foreach ($activeOffers as $key => $value) {
2515. if ($value['offerUrl']) {
2516. foreach (Config::HASOFFER_TRACKING_LINK_KEYWORDS_BY_TAG_ID as $k => $v) {
2517. if ($k == Config::HASOFFER_ADJUST_OFFER_TAG_ID) {
2518. $adjustAppDetails = $this->doctrine->getRepository(AdjustAppDetails::class)->getAdjustAppDetails();
2519. foreach ($adjustAppDetails as $kk => $vv) {
2520. if (
2521. $this->checkForString($value['offerUrl'], $vv['appToken']) &&
2522. array_key_exists($vv['account'], Config::MMP_ADJUST_ACCOUNT_TUNE_TAG_MAPPING)
2523. ) {
2524. $this->brandApi->addTagToOffer($value['offerId'], Config::MMP_ADJUST_ACCOUNT_TUNE_TAG_MAPPING[$vv['account']]);
2525. $this->populateDbByOfferId($value['offerId']);
2526. break 2;
2527. }
2528. }
2529. } else {
2530. foreach ($v as $subLink) {
2531. if (
2532. isset($value['offerUrl']) &&
2533. $this->checkForString($value['offerUrl'], $subLink) &&
2534. !$this->doctrine->getRepository(OfferTagRelationship::class)->findOneBy(['tagId' => $k, 'offerId' => $value['offerId']])
2535. ) {
2536. $this->brandApi->addTagToOffer($value['offerId'], $k);
2537. $this->populateDbByOfferId($value['offerId']);
2538. break 2;
2539. }
2540. }
2541. }
2542. }
2543. }
2544. }
2545. }
2547. public function getReportsRowWiseDataByAggregation($tableColumns, $selectedColumns, $rowWiseData)
2548. {
2550. $finalArr = [];
2551. foreach ($rowWiseData as $rowWiseIndex => $rowWiseValue) {
2553. $indexArr = [];
2554. foreach ($selectedColumns as $key => $value) {
2555. if (
2556. array_key_exists($key, $tableColumns) &&
2557. $value &&
2558. in_array($tableColumns[$key]['category'], ['data_fields', 'item_interval'])
2559. ) {
2560. $indexArr[] = $rowWiseValue[$key];
2561. }
2562. }
2564. $index = md5(implode("#", $indexArr));
2566. if (!array_key_exists($index, $finalArr)) {
2567. foreach ($selectedColumns as $key => $value) {
2568. if (array_key_exists($key, $tableColumns) && $value && array_key_exists($key, $rowWiseValue)) {
2569. if (in_array($tableColumns[$key]['category'], ['data_fields', 'item_interval'])) {
2570. $finalArr[$index][$key] = $rowWiseValue[$key];
2571. }
2572. }
2573. }
2574. foreach ($tableColumns as $key => $value) {
2575. if ($value['category'] == 'statistics') {
2576. $finalArr[$index][$key] = 0;
2577. }
2578. }
2579. }
2581. foreach ($tableColumns as $key => $value) {
2582. if (
2583. (
2584. $value['category'] == 'statistics' && !isset($value['calculationType'])
2585. ) ||
2586. (
2587. isset($value['calculationType']) && $value['category'] == 'statistics' && $value['calculationType'] != 'percentage'
2588. )
2589. ) {
2590. $finalArr[$index][$key] += $rowWiseValue[$key];
2591. $finalArr[$index][$key] = round($finalArr[$index][$key], 2);
2592. }
2593. }
2594. }
2596. return $finalArr;
2597. }
2599. public function getPaginatedResponseForReports($reportData, $tableColumns, $selectedColumns, $sortBy, $sortType, $limit, $page)
2600. {
2602. $reportData = array_values($reportData);
2604. if (sizeof($reportData)) {
2605. $entity = $reportData[0];
2606. if (array_key_exists($sortBy, $entity)) {
2607. $sortFlag = 3;
2608. if ($sortType == Config::SORT_TYPE_ASC) {
2609. $sortFlag = 4;
2610. }
2611. array_multisort(array_column($reportData, $sortBy), $sortFlag, $reportData);
2612. }
2613. }
2615. $offset = $limit * ($page - 1);
2617. $totalRecordCount = sizeof($reportData);
2618. $noOfPages = ceil($totalRecordCount / $limit);
2620. foreach ($tableColumns as $key => $value) {
2621. if (isset($value['aggregate'])) {
2622. if ($value['aggregate'] == 'sum') {
2623. $tableColumns[$key]['Footer'] = number_format(round(array_sum(array_column($reportData, $value['accessor'])), 2));
2624. }
2625. if ($value['aggregate'] == 'average' && count($reportData) > 0) {
2626. $tableColumns[$key]['Footer'] = number_format(round(array_sum(array_column($reportData, $value['accessor'])) / count($reportData), 2));
2627. }
2628. }
2629. }
2631. $tableColumns = $this->changeColumnVisibilityForTable(array_values($tableColumns), $selectedColumns, []);
2633. return [
2634. 'response' => [
2635. 'success' => true,
2636. 'httpStatus' => Config::HTTP_STATUS_CODE_OK,
2637. 'data' => [
2638. 'tableColumns' => array_values($tableColumns),
2639. 'data' => array_slice($reportData, $offset, $limit),
2640. 'metaData' => [
2641. 'total' => $totalRecordCount,
2642. 'limit' => (int)$limit,
2643. 'page' => (int)$page,
2644. 'pages' => (int)$noOfPages,
2645. ]
2646. ],
2647. 'error' => null
2648. ]
2649. ];
2650. }
2652. public function getAffiliateCategoryByAffiliateId($tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
2653. {
2654. $affiliateTagRelationshipData = $this->doctrine->getRepository(AffiliateTagRelationship::class)->getAffiliateTagRelationshipByTagIdArr([Config::HASOFFER_AFFILIATE_CATEGORY_A_TAG_ID, Config::HASOFFER_AFFILIATE_CATEGORY_B_TAG_ID], $tuneAccount);
2656. $data = [];
2657. foreach ($affiliateTagRelationshipData as $key => $value) {
2658. $data[$key] = [
2659. 'category' => Config::HASOFFER_AFFILIATE_CATEGORY_ARRAY[$value['tagId']],
2660. 'affiliateId' => $value['affiliateId']
2661. ];
2662. }
2664. $affiliateData = $this->doctrine->getRepository(AffiliateInfo::class)->getAffiliateListByArrToSearch([], $tuneAccount);
2666. foreach ($affiliateData as $key => $value) {
2667. if (!array_key_exists($value['affiliateId'], $data)) {
2668. $data[$value['affiliateId']] = [
2669. 'category' => Config::HASOFFER_AFFILIATE_CATEGORY_UNCATEGORISED_TAG_NAME,
2670. 'affiliateId' => $value['affiliateId']
2671. ];
2672. }
2673. }
2675. return $data;
2676. }
2678. public function getPidByOfferId($offerId, $tuneAccount = Config::MAFO_SYSTEM_IDENTIFIER_TUNE_MOBILE)
2679. {
2681. $tunePid = null;
2682. $offerInfo = $this->doctrine->getRepository(OfferInfo::class)->findOneBy(['offerId' => $offerId, 'tuneAccount' => $tuneAccount]);
2684. if ($offerInfo) {
2685. $parsedUrl = parse_url($offerInfo->getOfferUrl());
2686. if (isset($parsedUrl['query'])) {
2687. parse_str($parsedUrl['query'], $query);
2688. if (isset($query['pid']) && in_array($query['pid'], Config::TUNE_APPSFLYER_PIDS)) {
2689. $tunePid = $query['pid'];
2690. }
2691. }
2692. }
2694. return $tunePid;
2695. }
2697. public function getWhitelistIPsAppsflyerOrAdjust($offerUrl)
2698. {
2700. $whitelistIps = [];
2702. if (stripos($offerUrl, Config::APPSFLYER_DOMAIN) !== false) {
2703. $whitelistIps = Config::WIZARD_APPSFLYER_WHITE_LIST;
2704. }
2706. if (
2707. stripos($offerUrl, Config::ADJUST_IO_DOMAIN) !== false
2708. || stripos($offerUrl, Config::ADJUST_COM_DOMAIN) !== false
2709. ) {
2710. $whitelistIps = Config::WIZARD_ADJUST_WHITE_LIST;
2711. }
2713. return $whitelistIps;
2714. }
2716. public function updateNotificationUnreadCountByUser($userEmail, $unreadNotificationCount)
2717. {
2719. $cacheKey = Config::CACHE_REDIS_UNREAD_NOTIFICATION_COUNT_BY_USER . $userEmail;
2720. if (is_null($this->elasticCache->redisGet($cacheKey))) {
2721. $userData = $this->doctrine->getRepository(MafoUserNotifications::class)->findBy([
2722. 'sentToUserId' => $userEmail,
2723. 'isRead' => 0
2724. ]);
2725. $notificationCount = count($userData);
2726. } else {
2727. $notificationCount = $this->elasticCache->redisGet($cacheKey);
2728. }
2730. $unreadNotificationCount += $notificationCount;
2732. $this->elasticCache->redisSet($cacheKey, $unreadNotificationCount);
2733. }
2735. public function getUnreadNotificationCountByUser($userEmail)
2736. {
2738. $cacheKey = Config::CACHE_REDIS_UNREAD_NOTIFICATION_COUNT_BY_USER . $userEmail;
2739. if (is_null($this->elasticCache->redisGet($cacheKey))) {
2740. $userData = $this->doctrine->getRepository(MafoUserNotifications::class)->findBy([
2741. 'sentToUserId' => $userEmail,
2742. 'isRead' => 0
2743. ]);
2744. $notificationCount = count($userData);
2745. } else {
2746. $notificationCount = $this->elasticCache->redisGet($cacheKey);
2747. }
2749. return $notificationCount;
2750. }
2752. public function sendPushNotification($topic, $topicData)
2753. {
2754. try {
2755. $update = new Update(
2756. $topic,
2757. $topicData
2758. // ,true
2759. );
2761. $this->hub->publish($update);
2762. } catch (\Exception $e) {
2763. $this->logger->error('Error occurred: ' . $e);
2764. }
2765. }
2767. public function getEmployeesByUserId()
2768. {
2770. $cachedList = $this->elasticCache->redisGet(Config::CACHE_REDIS_HO_EMPLOYEES_LIST);
2772. if (!$cachedList) {
2773. $employeeList = $this->getWarmedUpUsersByUserId();
2774. } else {
2775. $employeeList = json_decode($cachedList, true);
2776. }
2778. ksort($employeeList);
2780. return $employeeList;
2781. }
2783. public function getWarmedUpUsersByUserId()
2784. {
2786. $employeesData = $this->doctrine->getRepository(Users::class)->getEmployees();
2787. $data = [];
2788. foreach ($employeesData as $key => $value) {
2789. $data[$value['email']] = [
2790. 'firstName' => $value['name'],
2791. 'email' => $value['email']
2792. ];
2793. }
2794. return $data;
2795. }
2797. /**
2798. * Transform array data to dropdown format
2799. *
2800. * @param array $data Array of data to transform
2801. * @param string $valueKey Key to use as the value (default: 'id')
2802. * @param array $labelKeys Array of keys to concatenate for label (default: ['firstName', 'lastName'])
2803. * @param string $fallbackKey Key to use as fallback if label is empty (default: 'email')
2804. * @param string $separator Separator to use between label keys (default: ' ')
2805. * @return array Transformed dropdown data
2806. */
2807. public function transformToDropdownFormat(array $data, string $valueKey = 'id', array $labelKeys = ['firstName', 'lastName'], string $fallbackKey = 'email', string $separator = ' '): array
2808. {
2809. return array_map(function ($item) use ($valueKey, $labelKeys, $fallbackKey, $separator) {
2810. $labelParts = [];
2811. foreach ($labelKeys as $key) {
2812. if (isset($item[$key]) && !empty($item[$key])) {
2813. $labelParts[] = trim($item[$key]);
2814. }
2815. }
2817. $label = implode($separator, $labelParts);
2819. if (empty($label) && isset($item[$fallbackKey])) {
2820. $label = $item[$fallbackKey];
2821. }
2823. return [
2824. 'value' => $item[$valueKey] ?? null,
2825. 'label' => $label
2826. ];
2827. }, $data);
2828. }
2829. }