Symfony Profiler

<?php
namespace App\Controller;
use App\Config;
use App\Entity\MafoId\MafoAffiliates;
use App\Entity\MafoId\MafoOffers;
use App\Entity\Tune\AffiliateInfo;
use App\Entity\Employees;
use App\Entity\AgentControl;
use App\Entity\MmpMobileApps;
use App\Entity\MmpOffers;
use App\Entity\Tune\OfferInfo;
use App\Entity\NewsletterBuilder;
use App\Entity\OfferGeoRelationship;
use App\Services\AffiliateHasofferAPI;
use App\Services\Alerts;
use App\Services\Aws\ElasticCache;
use App\Services\Aws\S3;
use App\Services\BrandHasofferAPI;
use App\Services\Common;
use App\Services\MafoFinancialToolsComponents;
use App\Services\ImpressionsApis;
use App\Services\Metrics24APICalls;
use App\Services\MmpComponents;
use App\Services\MysqlQueries;
use App\Services\UsersComponents;
use Doctrine\Persistence\ManagerRegistry;
use Mmoreram\GearmanBundle\Service\GearmanClientInterface;
use Symfony\Component\Routing\Annotation\Route;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpFoundation\Request;
use App\Repository\MafoPublisherCabinetManagerMappingWithAffiliateRepository;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Security\Http\Authentication\AuthenticationUtils;
use function GuzzleHttp\json_encode;
use App\Traits\TrafficReportTrait;
/**
*
* Offer related routes with endpoint /api/offers/{route}
*
* @Route("/api/client/publisher", name="client_publisher_", host="%publishers_subdomain%")
*/
class ClientSidePublisherController extends AbstractController
{
use TrafficReportTrait;
private $commonCalls;
private $doctrine;
private $mysqlQueries;
private $mafoFinancialToolsComponents;
private $alerts;
private $brandHasofferApi;
private $mmpComponents;
private $affiliateHasofferAPI;
private $usersComponents;
private $elasticCache;
private $projectDir;
private $s3;
private $impressionsApis;
private $metrics24APICalls;
private $gearmanClientInterface;
private $mappingRepository;
public function __construct(
Common $commonCalls,
ManagerRegistry $doctrine,
MysqlQueries $mysqlQueries,
MafoPublisherCabinetManagerMappingWithAffiliateRepository $mappingRepository,
MafoFinancialToolsComponents $mafoFinancialToolsComponents,
Alerts $alerts,
BrandHasofferApi $brandHasofferApi,
MmpComponents $mmpComponents,
AffiliateHasofferAPI $affiliateHasofferAPI,
UsersComponents $usersComponents,
ElasticCache $elasticCache,
S3 $s3,
ImpressionsApis $impressionsApis,
Metrics24APICalls $metrics24APICalls,
GearmanClientInterface $gearmanClientInterface,
string $projectDir
)
{
$this->commonCalls = $commonCalls;
$this->doctrine = $doctrine;
$this->mysqlQueries = $mysqlQueries;
$this->mafoFinancialToolsComponents = $mafoFinancialToolsComponents;
$this->alerts = $alerts;
$this->brandHasofferApi = $brandHasofferApi;
$this->mmpComponents = $mmpComponents;
$this->affiliateHasofferAPI = $affiliateHasofferAPI;
$this->usersComponents = $usersComponents;
$this->elasticCache = $elasticCache;
$this->s3 = $s3;
$this->impressionsApis = $impressionsApis;
$this->metrics24APICalls = $metrics24APICalls;
$this->gearmanClientInterface = $gearmanClientInterface;
$this->projectDir = $projectDir;
$this->mappingRepository = $mappingRepository;
}
/**
* @Route("/validate", name="validate", methods={"GET"})
*/
public function getValidateAction(Request $request)
{
return new JsonResponse(true);
}
/**
* @Route("/test", name="test", methods={"GET"})
*/
public function getAgentControlAction(Request $request)
{
return new JsonResponse(true);
}
/**
* @Route("/login", name="login")
*/
public function indexAction(AuthenticationUtils $authenticationUtils)
{
// $authenticationUtils = $authenticationUtils->get('security.authentication_utils');
// get the login error if there is one
$error = $authenticationUtils->getLastAuthenticationError();
// last username entered by the user
$lastUsername = $authenticationUtils->getLastUsername();
return $this->render('/publisher/login/index.html.twig', [
'last_username' => $lastUsername,
'error' => $error,
]);
}
/**
* @Route("/details", name="get_publisher_details", methods={"GET"})
*/
public function getPublishersDetails(Request $request): Response
{
$publisherInfo = $this->getUser();
$publisherId = $publisherInfo->getId();
$mappedAffiliateIds = $this->mappingRepository->findMappedAffiliateIdsByPublisherId($publisherId);
$publisherData = [
'id' => $publisherInfo->getId(),
'email' => $publisherInfo->getEmail(),
'firstName' => $publisherInfo->getFirstName(),
'lastName' => $publisherInfo->getLastName(),
'status' => $publisherInfo->getStatus(),
'lastLoginAt' => $publisherInfo->getLastLoginAt(),
'dateUpdated' => $publisherInfo->getDateUpdated(),
];
return $this->json($publisherData);
}
/**
* @Route("/report-columns/{report}", name="get_report_columns", methods={"GET"})
*/
public function getReportColumnsAction(Request $request, $report)
{
if (in_array($report, array_keys(Config::TABLE_COLUMNS_WITH_JSON_FILE))) {
return new JsonResponse(array_values($this->commonCalls->getDataFromJsonFile(Config::TABLE_COLUMNS_WITH_JSON_FILE[$report])));
}
}
/**
* @Route("/hyper-statuses", name="get_hyper_statuses", methods={"GET"})
*/
public function getHyperStatusesAction(Request $request)
{
$arr = [];
foreach (array_values(Config::HYPER_STATUS_MAFO_MACROS) as $key => $value) {
$arr[$value] = [
'value' => $value,
'label' => $value,
];
}
return new JsonResponse(array_values($arr));
}
/**
* @Route("/affiliates", name="get_affiliates", methods={"GET"})
*/
public function getAffiliatesAction(Request $request)
{
$publisherInfo = $this->getUser();
$publisherId = $publisherInfo->getId();
$mappedAffiliateIds = $this->mappingRepository->findMappedAffiliateIdsByPublisherId($publisherId);
$keyword = $request->query->get('keyword');
$dataByKeyword = [];
if ($keyword) {
$dataByKeyword = $this->doctrine->getRepository(AffiliateInfo::class)->getAffiliateByKeyword($keyword);
}
$statusArr = $request->query->get('status') != '' ? $request->query->get('status') : [Config::ACTIVE_STATUS];
$affiliateData = $this->commonCalls->getPublisherAffiliateListByStatusWithKeys($statusArr, $mappedAffiliateIds);
$affiliateList = [];
foreach ($affiliateData as $key => $value) {
$affiliateList[$value['id']] = [
'value' => $value['id'],
'label' => $value['id'] . ' - ' . $value['name'],
'status' => $value['status']
];
}
foreach ($dataByKeyword as $key => $value) {
if (!array_key_exists($value['affiliateId'], $affiliateList)) {
$temp = [
'value' => (int)$value['affiliateId'],
'label' => $value['affiliateId'] . ' - ' . $value['company'],
'status' => $value['status']
];
$affiliateList[$value['affiliateId']] = $temp;
}
}
ksort($affiliateList);
return new JsonResponse(array_values($affiliateList));
}
/**
* @Route("/mafo-users", name="get_mafo_users", methods={"GET"})
*/
public function getAffiliateManagersAction(Request $request)
{
$affiliateData = $this->getAffiliateAndManagerData();
$mappedAffiliateIds = $affiliateData['mappedAffiliateIds'];
if (empty($mappedAffiliateIds)) {
return new JsonResponse([]);
}
$accountManagerEmails = $this->doctrine->getRepository(MafoAffiliates::class)
->getAccountManagerEmailsByAffiliateIds($mappedAffiliateIds);
if (empty($accountManagerEmails)) {
return new JsonResponse([]);
}
$employeesInfo = $this->doctrine->getRepository(Employees::class)
->getEmployeesByEmails($accountManagerEmails);
$responseArr = [];
foreach ($employeesInfo as $email => $employee) {
$responseArr[] = [
'value' => $employee['email'] ?? '',
'label' => $employee['fullName'] . "[{$employee['email']}]"
];
}
usort($responseArr, fn($a, $b) => strcmp($a['label'], $b['label']));
return new JsonResponse($responseArr);
}
private function getAffiliateAndManagerData()
{
$publisherInfo = $this->getUser();
$publisherId = $publisherInfo->getId();
$mappedAffiliateIds = $this->mappingRepository->findMappedAffiliateIdsByPublisherId($publisherId);
$accountManagerEmails = $this->doctrine->getRepository(MafoAffiliates::class)
->getAccountManagerEmailsByAffiliateIds($mappedAffiliateIds);
$mappedAffiliateIds = array_map('strval', $mappedAffiliateIds);
return [
'formattedArray' => [
'MULTISELECT_MAFO_AFFILIATES' => $mappedAffiliateIds,
],
'formattedTrafficReportArray' => [
'MULTISELECT_MAFO_AFFILIATES' => $mappedAffiliateIds,
],
'mappedAffiliateIds' => $mappedAffiliateIds,
'accountManagerEmails' => $accountManagerEmails,
];
}
/**
* @Route("/financial-report", name="get_financial_report", methods={"GET"})
*/
public function getfinancialReportAction(Request $request)
{
$affiliateData = $this->getAffiliateAndManagerData();
$formattedArray = $affiliateData['formattedArray'];
$mappedAffiliateIds = $affiliateData['mappedAffiliateIds'];
$mappedAccountManagerEmails = $affiliateData['accountManagerEmails'];
if (empty($mappedAffiliateIds)) {
return new JsonResponse([
'response' => [
'success' => true,
'httpStatus' => Config::HTTP_STATUS_CODE_OK,
'data' => [],
'message' => 'No data available.',
'error' => null
]
], Config::HTTP_STATUS_CODE_OK);
}
$selectedColumns = $request->query->get('data') != '' ? $request->query->get('data') : [];
$validationError = $this->validatePublisherFinancialReportFields($selectedColumns);
if ($validationError !== null) {
return new JsonResponse($validationError, Config::HTTP_STATUS_CODE_BAD_REQUEST);
}
$filtersSelected = $request->query->get('filters') ?? [];
$excludedFlagForFilters = $request->query->get('excludedFlagForFilters') ?? [];
$processedFilters = $this->processPublisherFinancialReportFilters(
$filtersSelected,
$excludedFlagForFilters,
$mappedAffiliateIds
);
$filters = $processedFilters['filters'];
$excludedFiltersFlags = $processedFilters['excludedFiltersFlags'];
$limit = $request->query->get('limit') ? $request->query->get('limit') : Config::REPORTS_PAGINATION_DEFAULT_PAGE_SIZE;
$page = $request->query->get('page') ? $request->query->get('page') : Config::REPORTS_PAGINATION_DEFAULT_PAGE_NUMBER;
$sortBy = $request->query->get('sortBy') ?? Config::REPORTS_PAGINATION_DEFAULT_SORT_BY;
$sortType = $request->query->get('sortType') ?? Config::REPORTS_PAGINATION_DEFAULT_SORT_TYPE;
$dateStart = date('Y-m-1', strtotime('-0 month', strtotime($request->query->get('startDate'))));
$dateEnd = date('Y-m-1', strtotime('+0 month ', strtotime($request->query->get('endDate'))));
if ($request->query->get('downloadCSV') == 'true') {
$limit = Config::REPORTS_PAGINATION_DEFAULT_CSV_PAGE_SIZE;
$page = Config::REPORTS_PAGINATION_DEFAULT_PAGE_NUMBER;
}
$finalArr = $this->mafoFinancialToolsComponents->getPayoutTotalAggregatedData($dateStart, $dateEnd, $filters, $excludedFiltersFlags, $selectedColumns, null);
$allowedStatuses = array_values(Config::HYPER_STATUS_AFFILIATE_MAFO_MACROS);
foreach ($finalArr as &$record) {
if (!in_array($record['hyperStatus'], $allowedStatuses)) {
$record['hyperStatus'] = '';
}
}
$tableColumns = $this->commonCalls->changeColumnVisibilityForTable(array_values($this->commonCalls->getDataFromJsonFile(Config::JSON_FILE_CLIENT_SIDE_PUBLIHSER_FINANCIAL_REPORT)), $selectedColumns, []);
if ($request->query->get('downloadCSV') == 'true') {
$this->commonCalls->downloadCSV($tableColumns, $finalArr, 'Financial Report ' . $dateStart . '_' . $dateEnd);
}
return new JsonResponse($this->commonCalls->getReportResponse($finalArr, $tableColumns, $limit, $page, $sortBy, $sortType));
}
/**
* @Route("/traffic-report", methods={"GET"})
*/
public function getTrafficReport(Request $request)
{
$affiliateData = $this->getAffiliateAndManagerData();
$formattedTrafficReportArray = $affiliateData['formattedTrafficReportArray'];
$mappedAffiliateIds = $affiliateData['mappedAffiliateIds'];
if (empty($mappedAffiliateIds)) {
return new JsonResponse([
'response' => [
'success' => true,
'httpStatus' => Config::HTTP_STATUS_CODE_OK,
'data' => [],
'message' => 'No data available.',
'error' => null]
], Config::HTTP_STATUS_CODE_OK);
}
$selectedColumns = $request->query->get('data') != '' ? $request->query->get('data') : [];
$validationError = $this->validatePublisherTrafficReportFields($selectedColumns);
if ($validationError !== null) {
return new JsonResponse($validationError, Config::HTTP_STATUS_CODE_BAD_REQUEST);
}
$filtersSelected = $request->query->get('filters') ?? [];
$excludedFlagForFilters = $request->query->get('excludedFlagForFilters') ?? [];
$processedFilters = $this->processPublisherTrafficReportFilters(
$filtersSelected,
$excludedFlagForFilters,
$mappedAffiliateIds
);
$filters = $processedFilters['filters'];
$excludedFiltersFlags = $processedFilters['excludedFiltersFlags'];
$selectedColumns = $request->query->get('data') != '' ? $request->query->get('data') : [];
$groupedColumns = $request->query->get('groups') != '' ? $request->query->get('groups') : [];
$dateStart = date('Y-m-d', strtotime($request->query->get('startDate')));
$dateEnd = date('Y-m-d', strtotime($request->query->get('endDate')));
$eventTimestampFrom = strtotime($dateStart);
$eventTimeStampTo = strtotime($dateEnd);
$sortBy = $request->query->get('sortBy') ?? Config::REPORTS_PAGINATION_MMP_REPORT_DEFAULT_SORT_BY;
$sortType = $request->query->get('sortType') ?? Config::REPORTS_PAGINATION_DEFAULT_SORT_TYPE;
$page = $request->query->get('page') ?? Config::REPORTS_PAGINATION_DEFAULT_PAGE_NUMBER;
$limit = $request->query->get('limit') ?? Config::REPORTS_PAGINATION_DEFAULT_PAGE_SIZE;
$downloadDataAsCSV = $request->query->get('downloadCSV') == 'true';
$tableColumns = $this->commonCalls->changeColumnVisibilityForTable(
array_values($this->commonCalls->getDataFromJsonFile(Config::JSON_FILE_GLOBAL_NETWORK_REPORT)),
$selectedColumns,
[]
);
$finalReportData = $this->mmpComponents->getMmpCumulativeData(
$filters,
$excludedFiltersFlags,
$eventTimestampFrom,
$eventTimeStampTo,
$selectedColumns,
$groupedColumns
);
$finalReportData = $this->mmpComponents->normalizeMmpSource($finalReportData);
foreach ($tableColumns as $key => $value) {
if (isset($value['aggregate']) && $value['aggregate'] == 'sum') {
$num = round(array_sum(array_column($finalReportData, $value['accessor'])), 2);
if ($value['category'] == 'statistics') {
$tableColumns[$key]['Footer'] = number_format($num);
} else {
$tableColumns[$key]['Footer'] = number_format($num, 2);
}
}
}
if ($downloadDataAsCSV) {
$this->commonCalls->downloadCSV($tableColumns, $finalReportData, 'Traffic Report ' . $dateStart . '_' . $dateEnd);
} else {
$finalReportData = array_values($finalReportData);
if (sizeof($finalReportData)) {
$entity = $finalReportData[0];
if (array_key_exists($sortBy, $entity)) {
$sortFlag = 3;
if ($sortType == Config::SORT_TYPE_ASC) {
$sortFlag = 4;
}
array_multisort(array_column($finalReportData, $sortBy), $sortFlag, $finalReportData);
}
}
$offset = $limit * ($page - 1);
$totalRecordCount = sizeof($finalReportData);
$noOfPages = ceil($totalRecordCount / $limit);
return new JsonResponse([
'response' => [
'success' => true,
'httpStatus' => Config::HTTP_STATUS_CODE_OK,
'data' => [
'tableColumns' => $tableColumns,
'data' => array_slice($finalReportData, $offset, $limit),
'metaData' => [
'total' => $totalRecordCount,
'limit' => (int)$limit,
'page' => (int)$page,
'pages' => (int)$noOfPages,
]
],
'error' => null
]
], Config::HTTP_STATUS_CODE_OK);
}
}
/**
* @Route("/table-columns/{table}", name="get_table_columns", methods={"GET"})
*/
public function getTableColumnsAction(Request $request, $table)
{
return new JsonResponse(array_values($this->commonCalls->getDataFromJsonFile(Config::TABLE_COLUMNS_WITH_JSON_FILE[$table])));
}
/**
* @Route("/mobile-apps-list", name="get_mobile_apps_list", methods={"GET"})
*/
public function getMobileAppsListAction(Request $request)
{
$mobileAppsData = $this->doctrine->getRepository(MmpMobileApps::class)->getMmpMobileAppByIsDeleted(0);
$appIds = array_values(array_unique(array_merge(array_column($mobileAppsData, 'bundleId'), [])));
$appData = $this->commonCalls->getAppInfoWithKeys();
$data = [];
foreach ($appIds as $key => $value) {
if (preg_match("/\t/", $value)) {
continue;
}
$appName = array_key_exists($value, $appData) ? " - " . $appData[$value]['title'] : '';
$data[$value] = [
'value' => $value,
'label' => $value . $appName
];
}
return new JsonResponse(array_values($data));
}
/**
* @Route("/countries", name="get_countries", methods={"GET"})
*/
public function getCountriesAction()
{
$countryList = [];
foreach (Config::COUNTRIES as $key => $value) {
$countryList[$key] = [
'value' => $key,
'label' => $key . ' - ' . $value['name']
];
}
ksort($countryList);
return new JsonResponse(array_values($countryList));
}
/**
* @Route("/mafo-affiliates", methods={"GET"})
*/
public
function getMafoAffiliatesAction(Request $request)
{
$affiliateData = $this->getAffiliateAndManagerData();
$mappedAffiliateIds = $affiliateData['mappedAffiliateIds'];
if (empty($mappedAffiliateIds)) {
return new JsonResponse([]);
}
$affiliates = $this->doctrine->getRepository(MafoAffiliates::class)->getAffiliates([], [], Config::REPORTS_PAGINATION_DEFAULT_CSV_PAGE_SIZE, Config::REPORTS_PAGINATION_DEFAULT_PAGE_NUMBER, Config::REPORTS_PAGINATION_DEFAULT_SORT_BY, Config::REPORTS_PAGINATION_DEFAULT_SORT_TYPE);
$arr = [];
foreach ($affiliates as $key => $value) {
if (in_array((string)$value['id'], $mappedAffiliateIds)) {
$arr[] = [
'value' => $value['id'],
'label' => $value['id'] . ' - ' . $value['name']
];
}
}
return new JsonResponse($arr);
}
/**
* @Route("/offers", name="get_offers", methods={"GET"})
*/
public function getPublisherOffersAction(Request $request)
{
$filters = $request->query->get('filters') ?? [];
$excludedFlagForFilters = $request->query->get('excludedFlagForFilters') ?? [];
$publisherInfo = $this->getUser();
$publisherId = $publisherInfo->getId();
$limit = $request->query->get('limit') ? $request->query->get('limit') : Config::REPORTS_PAGINATION_DEFAULT_PAGE_SIZE;
$page = $request->query->get('page') ? $request->query->get('page') : Config::REPORTS_PAGINATION_DEFAULT_PAGE_NUMBER;
$mmpOfferIds = $appIds = $mafoAdvertiserIds = $geos = [];
if (isset($filters)) {
foreach ($filters as $key => $value) {
$key === 'MULTISELECT_MMP_OFFERS' ? $mmpOfferIds = $value : false;
$key === 'MULTISELECT_MMP_STATISTICS_APP' ? $appIds = $value : false;
$key === 'MULTISELECT_MAFO_ADVERTISERS' ? $mafoAdvertiserIds = $value : false;
$key === 'MULTISELECT_GEO' ? $geos = $value : false;
}
}
$mmpOfferIdsExcluded = $appIdsExcluded = $mafoAdvertiserIdsExcluded = $excludeGeos = [];
if (isset($excludedFlagForFilters)) {
foreach ($excludedFlagForFilters as $key => $value) {
$key === 'MULTISELECT_MMP_OFFERS' ? $mmpOfferIdsExcluded = $value : false;
$key === 'MULTISELECT_MMP_STATISTICS_APP' ? $appIdsExcluded = $value : false;
$key === 'MULTISELECT_MAFO_ADVERTISERS' ? $mafoAdvertiserIdsExcluded = $value : false;
$key === 'MULTISELECT_GEO' ? $excludeGeos = $value : false;
}
}
$selectedColumns = $request->query->get('data') != '' ? $request->query->get('data') : [];
$publisherOfferIds = $this->mmpComponents->getVisibleOfferIdsForPublisherManager($publisherId);
$mappedAffiliateIds = $this->mappingRepository->findMappedAffiliateIdsByPublisherId($publisherId);
// If no offers found for this publisher, return empty result
if (empty($publisherOfferIds)) {
return new JsonResponse([
'response' => [
'success' => true,
'httpStatus' => Config::HTTP_STATUS_CODE_OK,
'data' => [
'tableColumns' => [],
'data' => [],
'metaData' => [
'total' => 0,
'limit' => (int)$limit,
'page' => (int)$page,
'pages' => 0,
]
],
'error' => null
]
], Config::HTTP_STATUS_CODE_OK);
}
// Merge with existing mmpOfferIds filter
if (!empty($mmpOfferIds)) {
$mmpOfferIds = array_intersect($mmpOfferIds, $publisherOfferIds);
} else {
$mmpOfferIds = $publisherOfferIds;
}
// Use the common service to get and process offers data
$filters = [
'MULTISELECT_MMP_OFFERS' => $mmpOfferIds,
'MULTISELECT_MMP_STATISTICS_APP' => $appIds,
'MULTISELECT_MAFO_ADVERTISERS' => $mafoAdvertiserIds,
'MULTISELECT_GEO' => $geos,
];
$excludedFlagForFilters = [
'MULTISELECT_MMP_OFFERS' => $mmpOfferIdsExcluded,
'MULTISELECT_MMP_STATISTICS_APP' => $appIdsExcluded,
'MULTISELECT_MAFO_ADVERTISERS' => $mafoAdvertiserIdsExcluded,
'MULTISELECT_GEO' => $excludeGeos,
];
$offersData = $this->mmpComponents->getMmpOffersData($filters, $excludedFlagForFilters);
$hoAffiliateListList = $this->commonCalls->getAffiliateListByStatusWithKeys();
$processedData = $this->mmpComponents->processOffersData($offersData, $hoAffiliateListList);
$offersData = $processedData['offersData'];
$publisherPermissionsByOfferId = $processedData['publisherPermissionsByOfferId'];
$tableColumns = $this->commonCalls->changeColumnVisibilityForTable(array_values($this->commonCalls->getDataFromJsonFile(Config::JSON_FILE_MMP_STATISTICS_MMP_OFFERS)), $selectedColumns, []);
// Pass publisher manager ID to filter allowed/blocked lists to show only managed affiliates
$finalArr = $this->mmpComponents->formatOffersForResponse($offersData, $publisherPermissionsByOfferId, $publisherId);
$finalArr = $this->mmpComponents->normalizeMmpSource($finalArr);
$finalArr = $this->replacePayoutFromPartnerRules($finalArr, $selectedColumns, $mappedAffiliateIds);
$downloadCSV = $request->query->get('downloadCSV');
if ($downloadCSV == 1 || $downloadCSV === 'true' || $downloadCSV === true) {
$this->commonCalls->downloadCSV($tableColumns, $finalArr, 'MMP Offers');
}
$offset = $limit * ($page - 1);
$totalRecordCount = sizeof($finalArr);
$noOfPages = ceil($totalRecordCount / $limit);
return new JsonResponse([
'response' => [
'success' => true,
'httpStatus' => Config::HTTP_STATUS_CODE_OK,
'data' => [
'tableColumns' => $tableColumns,
'data' => array_slice($finalArr, $offset, $limit),
'metaData' => [
'total' => $totalRecordCount,
'limit' => (int)$limit,
'page' => (int)$page,
'pages' => (int)$noOfPages,
]
],
'error' => null
]
], Config::HTTP_STATUS_CODE_OK);
}
/**
* Get visible offers for a Publisher Manager based on new affiliate mapping logic
* @param int $publisherManagerId The Publisher Manager (PAM) ID
* @return array Array of visible offer IDs
*/
/**
* @Route("/mmp-tracking-system", name="get_mmp-tracking-system", methods={"GET"})
*/
public function getMmpTrackingSystem(Request $request)
{
$mmpTrackingSystem = [];
foreach (Config::MMP_TRACKING_SYSTEM_ADVERTISER_CABINET_SIMPLIFIED as $key => $value) {
$mmpTrackingSystem[] = [
'value' => $key,
'label' => $value
];
}
return new JsonResponse($mmpTrackingSystem);
}
/**
* @Route("/mafo-offers", methods={"GET"})
*/
public
function getMafoOffersAction(Request $request)
{
$offers = $this->doctrine->getRepository(MafoOffers::class)->getOffersList();
$arr = [];
foreach ($offers as $key => $value) {
$arr[] = [
'value' => $value['id'],
'label' => $value['id'] . ' - ' . $value['name']
];
}
return new JsonResponse($arr);
}
/**
* @Route("/advertiser-manager", name="get_advertiser_managers", methods={"GET"})
*/
public function getMafoUsersAction(Request $request)
{
// Forward to UtilitiesController logic
return $this->forward('App\Controller\UtilitiesController::getMafoUsersAction', [
'request' => $request,
]);
}
/**
* Replace payout and payoutModelPretty values from mmp_partner_rules table
*
* @param array $finalArr - The formatted offers array
* @param array $selectedColumns - The columns selected by the user
* @param array $mappedAffiliateIds - The affiliate IDs mapped to the publisher
* @return array - The modified offers array with replaced payout values
*/
private function replacePayoutFromPartnerRules(array $finalArr, array $selectedColumns, array $mappedAffiliateIds): array
{
if (empty($finalArr)) {
return $finalArr;
}
$mmpOfferIds = array_unique(array_column($finalArr, 'mmpOfferId'));
if (empty($mmpOfferIds)) {
return $finalArr;
}
$mmpPartnerRulesRepo = $this->doctrine->getRepository(\App\Entity\MmpPartnerRules::class);
$partnerRules = $mmpPartnerRulesRepo->getPayoutRulesByMmpOfferIds($mmpOfferIds);
if (empty($partnerRules)) {
return $finalArr;
}
$payoutMap = [];
foreach ($partnerRules as $rule) {
$mmpOfferId = $rule['mmpOfferId'];
if (!isset($payoutMap[$mmpOfferId])) {
$payoutMap[$mmpOfferId] = [
'payout' => $rule['payout'],
'payoutModel' => $rule['payoutModel']
];
}
}
foreach ($finalArr as &$offer) {
$mmpOfferId = $offer['mmpOfferId'];
if (isset($payoutMap[$mmpOfferId])) {
$partnerPayout = $payoutMap[$mmpOfferId];
if ($partnerPayout['payout'] !== null) {
$offer['payout'] = $partnerPayout['payout'];
}
if ($partnerPayout['payoutModel'] !== null) {
$offer['payoutModelPretty'] = strtoupper($partnerPayout['payoutModel']);
}
}
}
return $finalArr;
}
}

src/Controller/ClientSidePublisherController.php line 126