From 87f1caa555a18e0fb37d7b8f91ce62b864ee88a9 Mon Sep 17 00:00:00 2001
From: wucongxing <815046773@qq.com>
Date: Mon, 18 Dec 2023 09:24:34 +0800
Subject: [PATCH] =?UTF-8?q?=E9=98=9F=E5=88=97=E6=97=A5=E5=BF=97=E7=B1=BB?=
 =?UTF-8?q?=E5=9E=8B=E4=BD=BF=E7=94=A8=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../PrescriptionExpiredDelayDirectConsumer.php     | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/app/Amqp/Consumer/PrescriptionExpiredDelayDirectConsumer.php b/app/Amqp/Consumer/PrescriptionExpiredDelayDirectConsumer.php
index 9e82838..6073657 100644
--- a/app/Amqp/Consumer/PrescriptionExpiredDelayDirectConsumer.php
+++ b/app/Amqp/Consumer/PrescriptionExpiredDelayDirectConsumer.php
@@ -34,14 +34,14 @@ class PrescriptionExpiredDelayDirectConsumer extends ConsumerMessage
 
     public function consumeMessage($data, AMQPMessage $message): string
     {
-        Log::getInstance()->error("开始执行 处方过期 队列：" . json_encode($data, JSON_UNESCAPED_UNICODE));
+        Log::getInstance("queue-PrescriptionExpired")->info(json_encode($data, JSON_UNESCAPED_UNICODE));
 
         Db::beginTransaction();
         try {
             // 验证参数
             if (!isset($data['order_prescription_id'])){
                 Db::rollBack();
-                Log::getInstance()->error("处方过期队列执行失败：入参错误");
+                Log::getInstance("queue-PrescriptionExpired")->error("入参错误");
                 return Result::DROP;
             }
 
@@ -51,7 +51,7 @@ class PrescriptionExpiredDelayDirectConsumer extends ConsumerMessage
             $order_prescription = OrderPrescription::getOne($params);
             if (empty($order_prescription)){
                 Db::rollBack();
-                Log::getInstance()->error("处方过期处方队列执行失败：获取处方数据为空");
+                Log::getInstance("queue-PrescriptionExpired")->error("获取处方数据为空");
                 return Result::DROP;
             }
 
@@ -66,11 +66,11 @@ class PrescriptionExpiredDelayDirectConsumer extends ConsumerMessage
             $this->handlePrescription($order_prescription);
 
             Db::commit();
-            Log::getInstance()->info("处方过期 队列执行成功");
+            Log::getInstance("queue-PrescriptionExpired")->info("成功");
             return Result::ACK;
         } catch (\Exception $e) {
             Db::rollBack();
-            Log::getInstance()->error("处方过期 执行失败：" . $e->getMessage());
+            Log::getInstance("queue-PrescriptionExpired")->error($e->getMessage());
             return Result::ACK; // 重回队列
         }
     }
@@ -84,13 +84,13 @@ class PrescriptionExpiredDelayDirectConsumer extends ConsumerMessage
     {
         if ($order_prescription['prescription_status'] == 3){
             Db::rollBack();
-            Log::getInstance()->info("处方过期 队列执行失败：处方已失效，无需处理");
+            Log::getInstance("queue-PrescriptionExpired")->info("处方已失效，无需处理");
             return false;
         }
 
         if ($order_prescription['prescription_status'] == 4){
             Db::rollBack();
-            Log::getInstance()->info("处方过期 队列执行失败：处方已使用，无需处理");
+            Log::getInstance("queue-PrescriptionExpired")->info("处方已使用，无需处理");
             return false;
         }
         return true;