统计美化
This commit is contained in:
@@ -44,7 +44,7 @@ public class MessageConsumerService implements RocketMQListener<JSONObject> {
|
|||||||
@Override
|
@Override
|
||||||
public void onMessage(JSONObject message) {
|
public void onMessage(JSONObject message) {
|
||||||
try {
|
try {
|
||||||
logger.debug("消费消息:{}", message);
|
logger.info("消费消息:{}", message);
|
||||||
//logger.info("[RateLimiter] 开始处理消息,当前时间:{}", System.currentTimeMillis());
|
//logger.info("[RateLimiter] 开始处理消息,当前时间:{}", System.currentTimeMillis());
|
||||||
rateLimiter.acquire();
|
rateLimiter.acquire();
|
||||||
//logger.info("[RateLimiter] 获得令牌,当前时间:{}", System.currentTimeMillis());
|
//logger.info("[RateLimiter] 获得令牌,当前时间:{}", System.currentTimeMillis());
|
||||||
|
|||||||
@@ -172,7 +172,7 @@ public class JDScheduleJob {
|
|||||||
// 只有没有订单的才进行标记为已拉取
|
// 只有没有订单的才进行标记为已拉取
|
||||||
if (unionOpenOrderRowQueryResponse != null && unionOpenOrderRowQueryResponse.getQueryResult() != null && unionOpenOrderRowQueryResponse.getQueryResult().getData() == null) {
|
if (unionOpenOrderRowQueryResponse != null && unionOpenOrderRowQueryResponse.getQueryResult() != null && unionOpenOrderRowQueryResponse.getQueryResult().getData() == null) {
|
||||||
hashOps.put(newTimeTag, hourMinuteTag, "done");
|
hashOps.put(newTimeTag, hourMinuteTag, "done");
|
||||||
logger.debug(" 账号 {} -- 没有订单 -- 开始时间:{} --- 结束时间:{}", appKey.substring(appKey.length() - 4), startTime.format(DATE_TIME_FORMATTER), endTime.format(DATE_TIME_FORMATTER));
|
logger.info(" 账号 {} -- 没有订单 -- 开始时间:{} --- 结束时间:{}", appKey.substring(appKey.length() - 4), startTime.format(DATE_TIME_FORMATTER), endTime.format(DATE_TIME_FORMATTER));
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user