feat : chef statement

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;
     }
 }