From 02ea973d24cb9c3a1115b4b2b8cfd89882199ff2 Mon Sep 17 00:00:00 2001 From: Leo Date: Sun, 16 Mar 2025 20:00:02 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BB=9F=E8=AE=A1=E7=BE=8E=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/cn/van/business/mq/MessageConsumerService.java | 2 +- src/main/java/cn/van/business/util/JDScheduleJob.java | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/cn/van/business/mq/MessageConsumerService.java b/src/main/java/cn/van/business/mq/MessageConsumerService.java index 9abff13..a182bc4 100644 --- a/src/main/java/cn/van/business/mq/MessageConsumerService.java +++ b/src/main/java/cn/van/business/mq/MessageConsumerService.java @@ -5,7 +5,6 @@ import cn.hutool.http.HttpRequest; import cn.van.business.util.WxtsUtil; import com.alibaba.fastjson2.JSONObject; import com.google.common.util.concurrent.RateLimiter; -import org.apache.commons.lang3.StringUtils; import org.apache.rocketmq.spring.annotation.ConsumeMode; import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.apache.rocketmq.spring.core.RocketMQListener; @@ -45,6 +44,7 @@ public class MessageConsumerService implements RocketMQListener { @Override public void onMessage(JSONObject message) { try { + logger.debug("消费消息：{}", message); //logger.info("[RateLimiter] 开始处理消息，当前时间：{}", System.currentTimeMillis()); rateLimiter.acquire(); //logger.info("[RateLimiter] 获得令牌，当前时间：{}", System.currentTimeMillis()); diff --git a/src/main/java/cn/van/business/util/JDScheduleJob.java b/src/main/java/cn/van/business/util/JDScheduleJob.java index e214bad..4a62aa5 100644 --- a/src/main/java/cn/van/business/util/JDScheduleJob.java +++ b/src/main/java/cn/van/business/util/JDScheduleJob.java @@ -178,9 +178,9 @@ public class JDScheduleJob { } // 打印方法调用和开始结束时间 - if (isRealTime && (LocalDateTime.now().getMinute() % 10 == 0)) { - logger.debug(" {} --- 拉取订单, 分钟还是秒 {} , 开始时间：{} --- 结束时间：{}", appKey.substring(appKey.length() - 4), hourMinuteTag, startTime.format(DATE_TIME_FORMATTER), endTime.format(DATE_TIME_FORMATTER)); - } + //if (isRealTime && (LocalDateTime.now().getMinute() % 10 == 0)) { + // logger.debug(" {} --- 拉取订单, 分钟还是秒 {} , 开始时间：{} --- 结束时间：{}", appKey.substring(appKey.length() - 4), hourMinuteTag, startTime.format(DATE_TIME_FORMATTER), endTime.format(DATE_TIME_FORMATTER)); + //} return unionOpenOrderRowQueryResponse; } catch (Exception e) {