DeleteBidModifiers.php 2.04 KB
<?php

namespace App\Service\Requests\Direct;

use App\Jobs\ProcessCallLimitedAPI;
use App\Models\Pivots\GoalBidModifier;
use App\Service\Contract\APIRequest;
use App\Service\Requests\DirectRequest;
use Illuminate\Support\Facades\Log;

class DeleteBidModifiers extends DirectRequest
{
    protected $max_count = 10000;

    protected $timestamp;

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

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

    public function slice($maxObjects): ?APIRequest
    {
        return $this->sliceByKey($maxObjects, ['SelectionCriteria', 'Ids']);
    }

    public function handle($response)
    {
        if (!isset($response['result']['DeleteResults'])) {
            return;
        }

        foreach ($response['result']['DeleteResults'] as $key => $delete_result) {
            if (!isset($delete_result['Id'])) {

                if (isset($delete_result['Errors'][0]['Message']) && $delete_result['Errors'][0]['Message'] === 'Object not found') {
                    GoalBidModifier::where('external_id', $this->getParams()['SelectionCriteria']['Ids'][$key])->delete();
                    continue;
                }

                Log::debug("DeleteBidModifier, empty Id, token_id {$this->getToken()->getKey()}");
                Log::debug($delete_result);
                Log::debug($this->getParams()['SelectionCriteria']['Ids'][$key]);
                continue;
            }

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

            GoalBidModifier::where('external_id', $external_id)->delete();

        }
    }

    private function requestPrepare($params)
    {
        $this->setService('BidModifiers');
        $this->setMethod('delete');

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

}