diff --git a/app/Amqp/Consumer/AutoCompleteInquiryDelayDirectConsumer.php b/app/Amqp/Consumer/AutoCompleteInquiryDelayDirectConsumer.php
index a7b2596..95fe4c4 100644
--- a/app/Amqp/Consumer/AutoCompleteInquiryDelayDirectConsumer.php
+++ b/app/Amqp/Consumer/AutoCompleteInquiryDelayDirectConsumer.php
@@ -45,7 +45,7 @@ class AutoCompleteInquiryDelayDirectConsumer extends ConsumerMessage
 
     public function consumeMessage($data, AMQPMessage $message): string
     {
-        Log::getInstance("queue-AutoCompleteInquiry")->error(json_encode($data, JSON_UNESCAPED_UNICODE));
+        Log::getInstance("queue-AutoCompleteInquiry")->info(json_encode($data, JSON_UNESCAPED_UNICODE));
 
         Db::beginTransaction();
         try {
@@ -104,7 +104,7 @@ class AutoCompleteInquiryDelayDirectConsumer extends ConsumerMessage
             $patient_history_inquiry = PatientHistoryInquiry::addPatientHistoryInquiry($data);
             if (empty($patient_history_inquiry)){
                 Db::rollBack();
-                Log::getInstance("queue-AutoCompleteInquiry")->info("新增患者历史问诊表失败");
+                Log::getInstance("queue-AutoCompleteInquiry")->error("新增患者历史问诊表失败");
                 return Result::REQUEUE;
             }
 
@@ -114,7 +114,7 @@ class AutoCompleteInquiryDelayDirectConsumer extends ConsumerMessage
             $user_doctor = UserDoctor::getOne($params);
             if(empty($user_doctor)){
                 Db::rollBack();
-                Log::getInstance("queue-AutoCompleteInquiry")->info("缺少医生数据");
+                Log::getInstance("queue-AutoCompleteInquiry")->error("缺少医生数据");
                 return Result::DROP;
             }
 
diff --git a/app/Amqp/Consumer/UserCouponExpiredNoticeDelayDirectConsumer.php b/app/Amqp/Consumer/UserCouponExpiredNoticeDelayDirectConsumer.php
index cf23ed0..e786523 100644
--- a/app/Amqp/Consumer/UserCouponExpiredNoticeDelayDirectConsumer.php
+++ b/app/Amqp/Consumer/UserCouponExpiredNoticeDelayDirectConsumer.php
@@ -36,7 +36,7 @@ class UserCouponExpiredNoticeDelayDirectConsumer extends ConsumerMessage
 
     public function consumeMessage($data, AMQPMessage $message): string
     {
-        Log::getInstance("queue-UserCouponExpiredNotice")->error("开始：" . json_encode($data, JSON_UNESCAPED_UNICODE));
+        Log::getInstance("queue-UserCouponExpiredNotice")->info("开始：" . json_encode($data, JSON_UNESCAPED_UNICODE));
 
         // 检测参数
         if (!isset($data['user_coupon_id'])){