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;