src/Services/Base/Batch.php line 93

Open in your IDE?
  1. <?php
  3. namespace App\Services\Base;
  5. class Batch
  6. {
  7.     const BATCH_CAPACITY = 49;
  8.     const BATCH_COUNT = 50;
  10.     public function listBatch($crest, $method, $params, $next_count = 4, $col = null)
  11.     {
  12.         $resultBatch = $crest->call($method, $params);
  14.         if (isset($resultBatch['total']) && isset($resultBatch['next']) && ($resultBatch['total'] - $resultBatch['next']) >= 0) {
  15.             $count = 0;
  16.             while ($resultBatch['next'] < $resultBatch['total'] && $count < $next_count) {
  17.                 $count++;
  19.                 $params['start'] = $resultBatch['next'];
  20.                 $batch = [];
  21.                 if (($resultBatch['total'] - $params['start']) >= self::BATCH_CAPACITY) {
  22.                     $batchTotal = ceil(($resultBatch['total'] - $params['start']) / self::BATCH_COUNT);  // 1=54/50
  23.                     $batchCount = 0;
  24.                     $params2 = $params;
  26.                     while ($batchCount < $batchTotal && $batchCount < ($col ? $col : self::BATCH_COUNT)) {
  28.                         $params2['start'] = $params['start'] + ($batchCount * (self::BATCH_COUNT));
  29.                         $batch[] = [
  30.                             'method' => $method,
  31.                             'params' => $params2
  32.                         ];
  33.                         $batchCount++;
  34.                     }
  35.                 } else {
  36.                     $batch[] = [
  37.                         'method' => $method,
  38.                         'params' => $params
  39.                     ];
  40.                 }
  41. //                dump($batch);
  42.                 $result = $crest->callBatch($batch);
  44. //                dump($result);exit();
  46.                 if (isset($result['result']['result'])) {
  47.                     foreach ($result['result']['result'] as $key => $value) {
  48.                         foreach ($value as $val) {
  49.                             $resultBatch['result'][] = $val;
  50.                         }
  51.                         if (array_key_exists($key, $result['result']['result_next'])) {
  52.                             $resultBatch['next'] = $result['result']['result_next'][$key];
  53.                         } else {
  54.                             $resultBatch['next'] = $resultBatch['total'];
  55.                         }
  56.                     }
  57.                 }
  58.             }
  59.         }
  61.         return $resultBatch;
  62.     }
  64.     public function updateBatch($crest, $quantity, $dateId, $method, $fields) //$date должны обязательно лежать ID чтобы вызвать их можно было $date['ID']
  65.     {
  66. //        if (is_array($dateId)) {
  67.         if ($quantity > self::BATCH_CAPACITY) {
  68.             $batchTotal = $quantity / self::BATCH_CAPACITY + 1;
  69.             $batchCount = 1;
  71.             while ($batchCount <= $batchTotal) {
  72.                 $batchCount++;
  73.                 $batch = [];
  74.                 $i = 1;
  76.                 while ($i <= self::BATCH_CAPACITY) {
  77.                     $batch[$i] = [
  78.                         'method' => $method,
  79.                         'params' => [
  80.                             'id' => array_shift($dateId)['ID'], //$deals['result']
  81.                             'fields' => $fields
  82.                         ]
  83.                     ];
  84.                     $i++;
  85.                     if (!$dateId) {
  86.                         break;
  87.                     }
  88.                 }
  89.                 $crest->callBatch($batch);
  90.             }
  91.         } else {
  92.             $batch = [];
  93.             foreach ($dateId as $key => $value) {
  94.                 $batch[$key + 1] = [
  95.                     'method' => $method,
  96.                     'params' => [
  97.                         'id' => $value['ID'],
  98.                         'fields' => $fields
  99.                     ]
  100.                 ];
  101.             }
  102.             $crest->callBatch($batch);
  103.         }
  104. //        } else {
  105. //            dump('не массив');
  106. //            $res = $crest->call($method, [
  107. //                    'id' => $dateId,
  108. //                    'fields' => $fields
  109. //                ]
  110. //            );
  111. //        }
  112.         return true;
  113.     }
  114. }