支付查询mq打印日志排查问题

order-application-service/src/main/java/cn/freemud/amp/config/DlPayQueryMqConfig.java

@@ -36,7 +36,7 @@ public class DlPayQueryMqConfig {
      * @return
      */
     @Bean("payQueueName")
-    public Queue paymentChangeQueue() {
+    public Queue payQueueName() {
         return QueueBuilder.durable(KGD_PAY_QUERY_QUEUE).build();
     }
 
@@ -54,7 +54,7 @@ public class DlPayQueryMqConfig {
 
 
     @Bean("payChangeDlQueue")
-    public Queue paymentChangeDlQueue() {
+    public Queue payChangeDlQueue() {
         Map<String, Object> delayQueueParams = new HashMap<>(2);
         // DLX，dead letter发送到的exchange
         delayQueueParams.put("x-dead-letter-exchange", TopicExchangeConfig.EXCHANGE_NAME);
@@ -66,7 +66,7 @@ public class DlPayQueryMqConfig {
     }
 
     @Bean("bindingPayDlChange")
-    Binding bindingPaymentDlChange(@Qualifier("payChangeDlQueue") Queue queue, @Qualifier("dlPayMqTopicExchange") Exchange topicExchange) {
+    Binding bindingPayDlChange(@Qualifier("payChangeDlQueue") Queue queue, @Qualifier("dlPayMqTopicExchange") Exchange topicExchange) {
         Map<String, Object> args = new HashMap<>(2);
         args.put("x-dead-letter-exchange", TopicExchangeConfig.EXCHANGE_NAME);
         args.put("x-dead-letter-routing-key", KGD_PAY_QUERY_KEY);

order-application-service/src/main/java/cn/freemud/service/impl/OrderQueueService.java

@@ -126,6 +126,7 @@ public class OrderQueueService {
         messageProperties.setContentType(MessageProperties.CONTENT_TYPE_JSON);
         Message delmessage = new Message(notifyMsgBytes, messageProperties);
         mqService.convertAndSend(TopicExchangeConfig.EXCHANGE_NAME, DlPaymentMqConfig.OPEN_STORE_PAYMENT_QUERY_DL_KEY, delmessage);
+        AppLogUtil.infoLog("paymentCallback oid:{} fmId:{}", dto.getOrderId(),dto.getFmId());
     }
 
     /**
@@ -142,5 +143,6 @@ public class OrderQueueService {
         messageProperties.setExpiration("5000"); //5秒
         messageProperties.setContentType(MessageProperties.CONTENT_TYPE_JSON);
         mqService.convertAndSend(TopicExchangeConfig.EXCHANGE_NAME, DlPayQueryMqConfig.KGD_PAY_QUERY_DL_KEY, new Message(notifyMsgBytes, messageProperties));
+        AppLogUtil.infoLog("putPayQueryDelMq oid:{} fmId:{}", dto.getOrderId(),dto.getFmId());
     }
 }

order-application-service/src/main/java/cn/freemud/service/impl/PayServiceImpl.java

@@ -1233,6 +1233,7 @@ public class PayServiceImpl {
         dto.setPayChannelType(payChanelType);
         dto.setTrackingNo(LogThreadLocal.getTrackingNo());
         try {
+            orderQueueService.paymentCallback(dto);
             orderQueueService.putPayQueryDelMq(dto);
         } catch (Exception e) {
             AppLogUtil.errorLog("paymentQueueService.paymentCallback,orderId:{}", orderId, null, e);