1

src/main/java/cn/van/business/mq/MessageConsumerService.java

@@ -45,7 +45,7 @@ public class MessageConsumerService implements RocketMQListener<JSONObject> {
         // 处理消息
         try {
             rateLimiter.acquire(); // 请求许可。如果超过速率，则此方法会阻塞
-            //logger.info("消费到消息：{}", jsonObject);
+            logger.info("消费到消息：{}", jsonObject);
             String body = jsonObject.getString("body");
             byte[] decodedBody = Base64.getDecoder().decode(body);
             String decodedBodyStr = new String(decodedBody, StandardCharsets.UTF_8);

src/main/java/cn/van/business/util/JDUtil.java

@@ -565,7 +565,7 @@ public class JDUtil {
             }
 
             // 打印方法调用和开始结束时间
-            logger.info(" {} --- 拉取订单, 分钟还是秒 {} , 开始时间：{} --- 结束时间：{}", appKey.substring(appKey.length()-4) ,hourMinuteTag, startTime.format(DATE_TIME_FORMATTER), endTime.format(DATE_TIME_FORMATTER));
+            //logger.info(" {} --- 拉取订单, 分钟还是秒 {} , 开始时间：{} --- 结束时间：{}", appKey.substring(appKey.length()-4) ,hourMinuteTag, startTime.format(DATE_TIME_FORMATTER), endTime.format(DATE_TIME_FORMATTER));
 
             return unionOpenOrderRowQueryResponse;
         } catch (Exception e) {