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)
    {
        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()
                ]);

            }
        }
    }

    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);
    }
}