diff --git a/app/Service/Amqp/Statement/ChefService.php b/app/Service/Amqp/Statement/ChefService.php index 4aa003a..774e018 100644 --- a/app/Service/Amqp/Statement/ChefService.php +++ b/app/Service/Amqp/Statement/ChefService.php @@ -130,11 +130,11 @@ class ChefService if (empty($insertData)) throw new Exception('insertDataError:dataNull'); Db::transaction(function () use ($insertData) { - $delFlag = $this->chefStatementModel->where('cycle_id',$this->cycleId)->where('kitchen_id',$this->kitchenId)->delete(); + $this->chefStatementModel->where('cycle_id',$this->cycleId)->where('kitchen_id',$this->kitchenId)->delete(); $insertFlag = (new ChefStatement)->insert($insertData); - if (!$delFlag || !$insertFlag) { + if (!$insertFlag) { throw new Exception('insertDataError:'.json_encode([ 'data' => $insertData, 'cycle_id' => $this->cycleId,