AddAdGroups.php 5.85 KB
<?php

namespace App\Service\Requests\Direct;

use App\Jobs\ProcessCallLimitedAPI;
use App\Models\Campaigns;
use App\Models\Pivots\DictionaryCampaign;
use App\Models\Pivots\GoalAdGroup;
use App\Models\Variable;
use App\Service\Contract\APIRequest;
use App\Service\Requests\DirectRequest;
use App\Service\StrReplaceByVariables;
use Carbon\Carbon;
use Illuminate\Database\Eloquent\Collection;
use Illuminate\Support\Facades\Log;

class AddAdGroups extends DirectRequest
{
    protected $max_count = 1000;

    protected $timestamp;
    /* @var Collection|GoalAdGroup[] */
    protected $goalAdGroups;

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

    public function getObjectsCount()
    {
        return count($this->getParams()['AdGroups']);
    }

    public function slice($maxObjects): ?APIRequest
    {
        $splinter = $this->sliceByKey($maxObjects, 'AdGroups');

        $splinter->putParams([
            'goalAdGroups' => $this->goalAdGroups->slice($maxObjects)->values(),
        ]);

        $this->putParams([
            'goalAdGroups' => $this->goalAdGroups->slice(0, $maxObjects),
        ]);

        return $splinter;
    }

    public function handle($response)
    {
        try {
            if (!isset($response['result'])) {
                Log::debug($response);
                Log::debug($this->getParams());
            }

            foreach ($response['result']['AddResults'] as $key => $add_result) {
                if (!isset($add_result['Id'])) {
                    Log::debug("AddAdGroup, empty Id");
                    Log::debug($add_result);
                    Log::debug($this->getParams());
                    continue;
                }

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

                $goalAdGroup = $this->goalAdGroups->get($key);

                $goalAdGroup->update([
                    'external_id' => $external_id,
                    'external_upload_at' => Carbon::now(),
                ]);

                $goalAdGroup->goalKeywords()->update([
                    'goal_ad_group_external_id' => $external_id,
                ]);

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

    public function putParams($params)
    {
        $this->goalAdGroups = $params['goalAdGroups'];
    }

    private function requestPrepare($params)
    {
        $this->setService('AdGroups');
        $this->setMethod('add');

        $this->putParams($params);

        $variables = Variable::all();

        $this->setParams([
            'AdGroups' => $this->goalAdGroups->map(function (GoalAdGroup $goalAdGroup) use ($variables) {

                $list = Variable::getListVariablesByDictionaryCampaign($goalAdGroup->dictionaryCampaign, $variables);

                $data = [
                    'Name' => StrReplaceByVariables::getInstance($goalAdGroup->name, $list)->get(),
                    'CampaignId' => $goalAdGroup->dictionary_campaign_external_id,
                    'RegionIds' => $goalAdGroup->group->region_ids,
                ];

                if ($goalAdGroup->group->tracking_params) {
                    $data['TrackingParams'] = $goalAdGroup->group->tracking_params;
                }

                if ($goalAdGroup->group->mobile_app_ad_group && count($goalAdGroup->group->mobile_app_ad_group)) {
                    $data['MobileAppAdGroup'] = $goalAdGroup->group->mobile_app_ad_group;
                }

                if ($goalAdGroup->group->dynamic_text_ad_group && count($goalAdGroup->group->dynamic_text_ad_group)) {
                    $data['DynamicTextAdGroup'] = $goalAdGroup->group->dynamic_text_ad_group;
                }

                if ($goalAdGroup->group->dynamic_text_feed_ad_group && count($goalAdGroup->group->dynamic_text_feed_ad_group)) {
                    $data['DynamicTextFeedAdGroup'] = $goalAdGroup->group->dynamic_text_feed_ad_group;
                }

                /* TODO При создании есть параметр при получении в директ нет
                 * $data['CpmBannerKeywordsAdGroup']
                 */

                if ($goalAdGroup->group->cpm_banner_user_profile_ad_group && count($goalAdGroup->group->cpm_banner_user_profile_ad_group)) {
                    $data['CpmBannerUserProfileAdGroup'] = $goalAdGroup->group->cpm_banner_user_profile_ad_group;
                }

                if ($goalAdGroup->group->cpm_video_ad_group && count($goalAdGroup->group->cpm_video_ad_group)) {
                    $data['CpmVideoAdGroup'] = $goalAdGroup->group->cpm_video_ad_group;
                }

                if ($goalAdGroup->group->smart_ad_group && count($goalAdGroup->group->smart_ad_group)) {
                    $data['SmartAdGroup'] = $goalAdGroup->group->smart_ad_group;
                }

                if ($goalAdGroup->negative_keywords && isset($goalAdGroup->negative_keywords['Items']) && count($goalAdGroup->negative_keywords['Items'])) {
                    $data['NegativeKeywords'] = [
                        'Items' => array_map(function ($value) use ($list) {
                            return StrReplaceByVariables::getInstance($value, $list)->get();
                        }, $goalAdGroup->negative_keywords['Items']),
                    ];
                }

                if ($goalAdGroup->group->negative_keyword_shared_set_ids && isset($goalAdGroup->group->negative_keyword_shared_set_ids['Items']) && count($goalAdGroup->group->negative_keyword_shared_set_ids['Items'])) {
                    $data['NegativeKeywordSharedSetIds'] = [
                        'Items' => $goalAdGroup->group->negative_keyword_shared_set_ids['Items'],
                    ];
                }

                return $data;
            })->all(),
        ]);
    }

}