feat : phone pool

app/Service/Admin/Catering/Meal/CateringService.php

@@ -19,6 +19,8 @@ use App\Model\OrderMealCateringLog;
 use App\Model\Site;
 use App\Service\Admin\Catering\CateringBaseService;
 use App\Service\ServiceTrait\Admin\Catering\PrintTrait;
+use Exception;
+use Hyperf\DbConnection\Db;
 use Hyperf\Di\Annotation\Inject;
 use Psr\Container\ContainerExceptionInterface;
 use Psr\Container\NotFoundExceptionInterface;
@@ -84,16 +86,24 @@ class CateringService extends CateringBaseService
         // 生成 key
         $this->__initMealRedisKey();
 
-        // 配餐
-        $this->catering();
+        try {
+            Db::beginTransaction();
 
+            // 配餐
+            $this->catering();
+
+            // 查询该点所有套餐是否已经配餐 如果是就缓存关闭该点
+            $this->isCloseMealSite();
+
+            Db::commit();
+        }catch (Exception|ErrException $e) {
+            Db::rollBack();
+            throw new ErrException($e->getMessage());
+        }
         // 加缓存
         $this->joinMealCateringCache();
 
-        // 查询该点所有套餐是否已经配餐 如果是就缓存关闭该点
-        $this->isCloseMealSite();
-
-        // 关闭线路
+        // 关闭线路缓存
         if ($this->closeSiteFlag == 1) $this->closeMealWholeLine();
 
         return $this->return->success('success',['num' => $this->resCount]);
@@ -116,6 +126,18 @@ class CateringService extends CateringBaseService
 
         $this->closeMealSite();
 
+        $orderIds = $this->orderModel
+            ->where('site_id', $this->siteInfo->id)
+            ->where('cycle_id', $this->logInfo->cycle_id)
+            ->where('type',OrderCode::ORDER_TYPE_MEAL)
+            ->pluck('order_id')
+            ->toArray();
+        if (empty($orderIds)) throw new ErrException('配餐失败，更新逻辑失败');
+
+        foreach (array_chunk($orderIds, 100) as $chunk) {
+            if (!$this->orderModel->isCateringByOrderIds($chunk) || !$this->orderGoodModel->isCateringByOrderIds($chunk)) throw new ErrException('修改订单数据状态失败');
+        }
+
         $this->closeSiteFlag = 1;
     }