From 917d23476bc766ba31c75e3d5090a11255b07d75 Mon Sep 17 00:00:00 2001
From: ctexthuang <ctexthuang@qq.com>
Date: Mon, 24 Mar 2025 14:18:37 +0800
Subject: [PATCH] feat : chef statement

---
 app/Amqp/Consumer/Statement/FinancesConsumer.php | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/app/Amqp/Consumer/Statement/FinancesConsumer.php b/app/Amqp/Consumer/Statement/FinancesConsumer.php
index 873a485..427639d 100644
--- a/app/Amqp/Consumer/Statement/FinancesConsumer.php
+++ b/app/Amqp/Consumer/Statement/FinancesConsumer.php
@@ -4,6 +4,7 @@ declare(strict_types=1);
 
 namespace App\Amqp\Consumer\Statement;
 
+use App\Amqp\Producer\Statement\ChefProducer;
 use App\Constants\Common\OrderCode;
 use App\Lib\Log;
 use App\Model\Cycle;
@@ -11,6 +12,7 @@ use App\Model\FinancesStatement;
 use App\Model\Kitchen;
 use App\Model\Order;
 use Hyperf\Amqp\Message\Type;
+use Hyperf\Amqp\Producer;
 use Hyperf\Amqp\Result;
 use Hyperf\Amqp\Annotation\Consumer;
 use Hyperf\Amqp\Message\ConsumerMessage;
@@ -52,6 +54,12 @@ class FinancesConsumer extends ConsumerMessage
     #[Inject]
     protected Order $orderModel;
 
+    /**
+     * @var Producer
+     */
+    #[Inject]
+    protected Producer $producer;
+
     /**
      * @var Log
      */
@@ -108,6 +116,13 @@ class FinancesConsumer extends ConsumerMessage
                 ]));
         }
 
+        // 厨师商品结算节点 消息队列 - 生成结算数据
+        $chefMessage = new ChefProducer([
+            'cycle_id' => $data['cycle_id'],
+            'kitchen_id' => $data['kitchen_id'],
+        ]);
+        $this->producer->produce($chefMessage);
+
         return Result::ACK;
     }
 }