卡充值消费和接受日志

src/main/java/com/usky/dxtop/service/impl/OrderServiceImpl.java

@@ -203,6 +203,7 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
             msgLogService.save(msgLog);
             chargeVo.setSeq(msgLog.getId());
             CorrelationData correlationData = new CorrelationData(msgLog.getId().toString());
+            log.info("卡充值发送日志-------"+"时间:"+DateUtils.format(new Date(),null)+","+"msg:"+chargeVo);
             RabbitmqUtils.getRabbitmqTemplate(RabbitmqBeenCode.CART_CHARGE_CONSUMER).convertAndSend(msgLog.getExchange(), msgLog.getRoutingKey(), chargeVo,correlationData);
         }catch (Exception e){
             b = false;

src/main/java/com/usky/dxtop/service/listener/ChargeMqListener.java

@@ -1,6 +1,7 @@
 package com.usky.dxtop.service.listener;
 
 import com.usky.dxtop.common.exception.CustomException;
+import com.usky.dxtop.common.utils.DateUtils;
 import com.usky.dxtop.common.utils.StringUtils;
 import com.usky.dxtop.model.Order;
 import com.usky.dxtop.service.MsgLogService;
@@ -11,12 +12,12 @@ import com.usky.dxtop.service.emun.OrderStatus;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.nio.charset.StandardCharsets;
+import java.util.Date;
 
 /**
  * @author yq
@@ -42,6 +43,7 @@ public class ChargeMqListener {
     public void dealDeclareMessage(Message message) {
         try {
             String s = new String(message.getBody(), StandardCharsets.UTF_8);
+            log.info("卡充值接受日志-------"+"时间:"+ DateUtils.format(new Date(),null)+","+"msg:"+s);
             msgLogService.consumerSuccess(s,msgLog -> {
                 Order order = new Order();
                 String orderId = StringUtils.remove(msgLog.getBusinessId(), MsgLogBusinessCode.ORDER);