Explorar o código

开始消费日志

lyhzzz %!s(int64=2) %!d(string=hai) anos
pai
achega
0ded21b6d7

+ 3 - 4
src/main/java/com/fdkankan/ucenter/mq/consumer/OrderDownConsumer.java

@@ -31,8 +31,6 @@ public class OrderDownConsumer {
 
 
 
 
     @Autowired
     @Autowired
-    RabbitMqProducer rabbitMqProducer;
-    @Autowired
     IncrementOrderImpl incrementOrder;
     IncrementOrderImpl incrementOrder;
     @Autowired
     @Autowired
     DownloadOrderImpl downloadOrder;
     DownloadOrderImpl downloadOrder;
@@ -44,6 +42,7 @@ public class OrderDownConsumer {
             queuesToDeclare = @Queue("${queue.orderPay.order-payResult:order-payResult}")
             queuesToDeclare = @Queue("${queue.orderPay.order-payResult:order-payResult}")
     )
     )
     public void consumerQueue(Channel channel, Message message)  {
     public void consumerQueue(Channel channel, Message message)  {
+        log.info("order-payResult----开始消费");
         try {
         try {
             String messageId = message.getMessageProperties().getMessageId();
             String messageId = message.getMessageProperties().getMessageId();
             String msg = new String(message.getBody(), StandardCharsets.UTF_8);
             String msg = new String(message.getBody(), StandardCharsets.UTF_8);
@@ -73,10 +72,10 @@ public class OrderDownConsumer {
                 entityOrder.handleOrder(order.getOrderSn(),order.getTradeNo(),order.getOpenId(),payType,null);
                 entityOrder.handleOrder(order.getOrderSn(),order.getTradeNo(),order.getOpenId(),payType,null);
             }
             }
         }catch (Exception e){
         }catch (Exception e){
+            log.error("order-payResult----消费失败",e);
+        }finally {
 
 
         }
         }
 
 
-
-
     }
     }
 }
 }