Commit d183c7e5 by Евгений

Улучшение #19474

Синхронизация фраз и групп
1 parent d2a9fc28
...@@ -57,7 +57,7 @@ class ProcessCallAPI implements ShouldQueue ...@@ -57,7 +57,7 @@ class ProcessCallAPI implements ShouldQueue
$maxObjects = $limits->countObjectsLimitReserve($this->api, $limit); $maxObjects = $limits->countObjectsLimitReserve($this->api, $limit);
} }
if ($maxObjects and $maxObjects !== $limits::NAN && $this->api->getObjectsCount() > $maxObjects) { if ($maxObjects && $maxObjects !== $limits::NAN && $this->api->getObjectsCount() > $maxObjects) {
//те на которые не хватило баллов помещаем в очередь //те на которые не хватило баллов помещаем в очередь
if ($apiR = $this->api->slice($maxObjects)) { if ($apiR = $this->api->slice($maxObjects)) {
dispatch(new ProcessCallLimitedAPI($apiR))->onQueue('limits'); dispatch(new ProcessCallLimitedAPI($apiR))->onQueue('limits');
...@@ -68,8 +68,6 @@ class ProcessCallAPI implements ShouldQueue ...@@ -68,8 +68,6 @@ class ProcessCallAPI implements ShouldQueue
$handler->checkError($response); $handler->checkError($response);
$limits->acceptRezerv($this->limitId, new HeaderLimits($response->headers())); $limits->acceptRezerv($this->limitId, new HeaderLimits($response->headers()));
//TODO: обработать результат.
// если не хватило баллов на все что хотели запросить, то в очередь отправляем новый запрос на получение новых данных
$handler->handle($response); $handler->handle($response);
} catch (\Exception $e) { } catch (\Exception $e) {
//TODO: надо отдельно выделить ошибки вызовов, за которые списываются баллы //TODO: надо отдельно выделить ошибки вызовов, за которые списываются баллы
......
...@@ -23,7 +23,6 @@ class AddAdGroups extends DirectRequest ...@@ -23,7 +23,6 @@ class AddAdGroups extends DirectRequest
public function call($params = null) public function call($params = null)
{ {
$this->requestPrepare($params); $this->requestPrepare($params);
Log::debug($this->getParams());
$process = new ProcessCallLimitedAPI($this); $process = new ProcessCallLimitedAPI($this);
dispatch($process)->onQueue('limits'); dispatch($process)->onQueue('limits');
} }
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!