diff --git a/app/Amqp/Consumer/Statement/FinancesConsumer.php b/app/Amqp/Consumer/Statement/FinancesConsumer.php index df208bf..20dba94 100644 --- a/app/Amqp/Consumer/Statement/FinancesConsumer.php +++ b/app/Amqp/Consumer/Statement/FinancesConsumer.php @@ -90,10 +90,10 @@ class FinancesConsumer extends ConsumerMessage 'data' => $data, ])); } - + $this->log->error('FinancesConsumer1'); $statementInfo = $this->financesStatementModel->getStatementByCycleIdAndKitchenId((int)$data['cycle_id'],(int)$data['kitchen_id']); if (!empty($statementInfo)) $statementInfo->delete(); - + $this->log->error('FinancesConsumer2'); $statement = new FinancesStatement(); $statement->date = $cycle->dates; @@ -106,21 +106,21 @@ class FinancesConsumer extends ConsumerMessage $statement->option_copies = $this->orderModel->getCopiesByCycleIdAndKitchenId($cycle->id, $kitchen->id, OrderCode::ORDER_TYPE_OPTIONAL); $statement->meal_order_number = $this->orderModel->getOrderNumberByCycleIdAndKitchenId($cycle->id, $kitchen->id, OrderCode::ORDER_TYPE_MEAL); $statement->meal_copies = $this->orderModel->getCopiesByCycleIdAndKitchenId($cycle->id, $kitchen->id, OrderCode::ORDER_TYPE_MEAL); - + $this->log->error('FinancesConsumer3'); if (!$statement->save()) { throw new Exception('FinancesConsumer:error:FinancesStatement:'.json_encode([ 'statement' => $statement, 'data' => $data, ])); } - + $this->log->error('FinancesConsumer4'); // 厨师商品结算节点 消息队列 - 生成结算数据 $chefMessage = new ChefProducer([ 'cycle_id' => $data['cycle_id'], 'kitchen_id' => $data['kitchen_id'], ]); $this->producer->produce($chefMessage); - + $this->log->error('FinancesConsumer5'); return Result::ACK; } catch (Exception $e) { $this->log->error($e->getMessage());