From c9215b2e705e8314f9c5907e4b5c679291cbdc71 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=9B=B7=E6=AC=A7=EF=BC=88=E6=9E=97=E5=B9=B3=E5=87=A1?= =?UTF-8?q?=EF=BC=89?= Date: Wed, 22 Jan 2025 15:48:54 +0800 Subject: [PATCH] 1 --- src/main/java/cn/van/business/mq/MessageConsumerService.java | 2 +- src/main/java/cn/van/business/util/JDUtil.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/cn/van/business/mq/MessageConsumerService.java b/src/main/java/cn/van/business/mq/MessageConsumerService.java index 2daec83..516901a 100644 --- a/src/main/java/cn/van/business/mq/MessageConsumerService.java +++ b/src/main/java/cn/van/business/mq/MessageConsumerService.java @@ -45,7 +45,7 @@ public class MessageConsumerService implements RocketMQListener { // 处理消息 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); diff --git a/src/main/java/cn/van/business/util/JDUtil.java b/src/main/java/cn/van/business/util/JDUtil.java index 227833b..5691544 100644 --- a/src/main/java/cn/van/business/util/JDUtil.java +++ b/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) {