GetBidModifiers.php

<?php

namespace App\Service\Requests\Direct;

use App\Jobs\ProcessCallLimitedAPI;
use App\Models\AdGroup;
use App\Models\Advertisement;
use App\Models\BidModifier;
use App\Models\Campaigns;
use App\Service\Contract\APIRequest;
use App\Service\Requests\DirectRequest;
use Carbon\Carbon;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

class GetBidModifiers extends DirectRequest
{
    protected $max_count = -1;
    protected $max_count_CampaignIds = 10;
    protected $max_count_AdGroupIds = 1000;
    protected $max_count_Ids = 10000;

    function call($params = null)
    {
        $this->requestPrepare($params);
        $process = new ProcessCallLimitedAPI($this);
        dispatch($process)->onQueue('limits');
    }

    public function getObjectsCount()
    {
        $params = $this->getParams();
        if (isset($params['SelectionCriteria']['CampaignIds'])) {
            return -1;
        }
        if (isset($params['SelectionCriteria']['AdGroupIds'])) {
            return -1;
        }
        if (isset($params['SelectionCriteria']['Ids'])) {
            return count($params['SelectionCriteria']['Ids']);
        }
        return -1;
    }

    public function slice($maxObjects): ?APIRequest
    {
        $params = $this->getParams();

        if (isset($params['SelectionCriteria']['Ids'])) {
            return $this->sliceByKey($maxObjects, ['SelectionCriteria', 'Ids']);
        }

        return null;
    }

    function handle($response)
    {
        try {
            if (!isset($response['result']['BidModifiers'])) {
                return;
            }
            $campaigns_external_ids = [];
            $ad_groups_external_ids = [];

            foreach ($response['result']['BidModifiers'] as $ad) {
                $campaignId = (string)$ad['CampaignId'];
                $adGroupId = (string)$ad['AdGroupId'];

                if (!isset($campaigns_external_ids[$campaignId])) {
                    $campaigns_external_ids[$campaignId] = true;
                }
                if (!isset($ad_groups_external_ids[$adGroupId])) {
                    $ad_groups_external_ids[$adGroupId] = true;
                }
            }

            if (!count($campaigns_external_ids)) {
                return;
            }


            if ($this->getToken()->isMain()) {
                $campaigns = Campaigns::whereIn('external_id', array_keys($campaigns_external_ids))
                    ->get()
                    ->keyBy('external_id');

                $adGroups = AdGroup::whereIn('external_id', array_keys($ad_groups_external_ids))
                    ->get()
                    ->keyBy('external_id');
            } else {
                //
            }

            foreach ($response['result']['BidModifiers'] as $bid_modifier) {

                /* @var $campaign Campaigns|null */
                $campaign = $campaigns->get((string)$bid_modifier['CampaignId']);

                if (!$campaign)
                    continue;

                /* @var $adGroup AdGroup|null */
                $adGroup = null;

                $ad_group_external_id = (string)$bid_modifier['AdGroupId'];

                if ($ad_group_external_id) {
                    $adGroup = $adGroups->get($ad_group_external_id);
                }

                $external_id = (string)$bid_modifier['Id'];

                if ($this->getToken()->isMain()) {

                    $data = [
                        'external_id' => $external_id,
                        'campaign_external_id' => $campaign->external_id,
                        'ad_group_external_id' => $adGroup ? $adGroup->external_id : null,
                        'campaign_id' => $campaign->getKey(),
                        'ad_group_id' => $adGroup ? $adGroup->getKey() : null,

                        'level' => $bid_modifier['Level'],
                        'type' => $bid_modifier['Type'],
                        'mobile_adjustment' => $bid_modifier['MobileAdjustment'] ?? null,
                        'desktop_adjustment' => $bid_modifier['DesktopAdjustment'] ?? null,
                        'demographics_adjustment' => $bid_modifier['DemographicsAdjustment'] ?? null,
                        'retargeting_adjustment' => $bid_modifier['RetargetingAdjustment'] ?? null,
                        'video_adjustment' => $bid_modifier['VideoAdjustment'] ?? null,

                        'updated_self' => null,

                        'updated_at'    =>  Carbon::now(),
                        'deleted_at'    =>  null,
                    ];

                    $bidModifierOld = BidModifier::firstWhere('external_id', $external_id);

                    $bidModifier = BidModifier::updateOrCreate([
                        'external_id' => $external_id
                    ], $data);

                    if ($bidModifierOld && $bidModifier->bidModifierValue !== $bidModifierOld->bidModifierValue) {
                        $bidModifier->goalBidModifiers()->has('dictionaryCampaign')->forExternal()->update([
                            'updated_need' => Carbon::now(),
                        ]);
                    }

                } else {
                    //
                }

            }

            if (!isset($response['result']['LimitedBy'])) {
                if (!empty($this->getParams()['SelectionCriteria']['AdGroupIds'])) {

                    $ag_group_external_ids = $this->getParams()['SelectionCriteria']['AdGroupIds'];

                    $sql = "UPDATE bid_modifiers bm
                            INNER JOIN ad_groups ag ON bm.ad_group_id = ag.id
                    SET bm.deleted_at = now()
                    WHERE bm.updated_at <= ag.bid_modifiers_loaded_at
                        AND bm.deleted_at is null
                        AND ag.external_id in (" . implode(", ", $ag_group_external_ids) . ")";

                    DB::update($sql);
                    AdGroup::whereIn('external_id', $ag_group_external_ids)->update([
                        'bid_modifiers_loaded_at' => Carbon::now()
                    ]);
                } elseif (!empty($this->getParams()['SelectionCriteria']['CampaignIds'])) {

                    $campaign_external_ids = $this->getParams()['SelectionCriteria']['CampaignIds'];

                    $sql = "UPDATE bid_modifiers bm
                                INNER JOIN campaigns ca ON bm.campaign_id = ca.id
                        SET bm.deleted_at = now()
                        WHERE bm.updated_at <= ca.bid_modifiers_loaded_at
                            AND bm.deleted_at is null
                            AND ca.external_id in (" . implode(", ", $campaign_external_ids) . ")";

                    DB::update($sql);
                    Campaigns::whereIn('external_id', $campaign_external_ids)->update([
                        'bid_modifiers_loaded_at' => Carbon::now()
                    ]);

                }
            }

        } catch (\Exception $e) {
            Log::debug($e);
            throw $e;
        }
    }

    private function requestPrepare($filter)
    {
        $this->setService('BidModifiers');
        $this->setMethod('get');
        $params = [
            "SelectionCriteria" => [
                "Types" => [
                    BidModifier::TYPE_MOBILE_ADJUSTMENT,
                    BidModifier::TYPE_DESKTOP_ADJUSTMENT,
                    BidModifier::TYPE_DEMOGRAPHICS_ADJUSTMENT,
                    BidModifier::TYPE_RETARGETING_ADJUSTMENT,
                    BidModifier::TYPE_VIDEO_ADJUSTMENT,
                ],
                "Levels" => [
                    BidModifier::LEVEL_AD_GROUP,
                    BidModifier::LEVEL_CAMPAIGN,
                ],
            ],
            "FieldNames" => [
                "Id", "CampaignId", "AdGroupId", "Level", "Type",
            ],
            "MobileAdjustmentFieldNames" => [
                "BidModifier", "OperatingSystemType",
            ],
            "DesktopAdjustmentFieldNames" => [
                "BidModifier",
            ],
            "VideoAdjustmentFieldNames" => [
                "BidModifier",
            ],
            "RegionalAdjustmentFieldNames" => [
                "RegionId", "BidModifier", "Enabled",
            ],
            "DemographicsAdjustmentFieldNames" => [
                "Gender", "Age", "BidModifier", "Enabled",
            ],
            "RetargetingAdjustmentFieldNames" => [
                "RetargetingConditionId", "BidModifier", "Accessible", "Enabled",
            ],
        ];
        if (isset($filter['CampaignIds'])) {
            $params['SelectionCriteria']['CampaignIds'] = $filter['CampaignIds'];
        }
        if (isset($filter['AdGroupIds'])) {
            $params['SelectionCriteria']['AdGroupIds'] = $filter['AdGroupIds'];
        }
        if (isset($filter['Ids'])) {

            $this->max_count = $this->max_count_Ids;

            $params['SelectionCriteria']['Ids'] = $filter['Ids'];
        }
        $this->setParams($params);
    }
}