feat : chef statement

app/Amqp/Consumer/Statement/ChefConsumer.php

@@ -4,15 +4,24 @@ declare(strict_types=1);
 
 namespace App\Amqp\Consumer\Statement;
 
+use App\Lib\Log;
+use App\Service\Amqp\Statement\ChefService;
+use Exception;
 use Hyperf\Amqp\Message\Type;
 use Hyperf\Amqp\Result;
 use Hyperf\Amqp\Annotation\Consumer;
 use Hyperf\Amqp\Message\ConsumerMessage;
+use Hyperf\Di\Annotation\Inject;
 use PhpAmqpLib\Message\AMQPMessage;
 
-#[Consumer(exchange: 'hyperf', routingKey: 'hyperf', queue: 'hyperf', name: "ChefConsumer", nums: 1)]
+#[Consumer(exchange: 'chef', routingKey: 'chef', queue: 'chef.statement', name: "ChefConsumer", nums: 1)]
 class ChefConsumer extends ConsumerMessage
 {
+    /**
+     * @var Log
+     */
+    #[Inject]
+    protected Log $log;
 
     /**
      * @var Type|string 消息类型
@@ -20,6 +29,22 @@ class ChefConsumer extends ConsumerMessage
     protected Type|string $type = Type::DIRECT;
     public function consumeMessage($data, AMQPMessage $message): Result
     {
+        if (!$data['kitchen_id'] || !$data['cycle_id']) {
+            $this->log->error('ChefConsumer:error:NoData:'.json_encode($data));
+            return Result::ACK;
+        }
+
+        try {
+            $service = new ChefService();
+
+            $service->cycleId = (int)$data['cycle_id'];
+            $service->kitchenId = (int)$data['kitchen_id'];
+
+            $service->handle();
+        } catch (Exception $e) {
+            $this->log->error('ChefConsumer:error:'.$e->getMessage().':data:'.json_encode($data));
+        }
+
         return Result::ACK;
     }
 }