From e532ce0da1ff3e6eb0a435153368a530b3b1822a Mon Sep 17 00:00:00 2001 From: wangchaoxu Date: Fri, 15 Sep 2023 23:05:17 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E9=99=A4=E8=B0=83=E8=AF=95=E6=97=A5?= =?UTF-8?q?=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/ms/api/service/impl/QueueServiceImpl.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/ms-biz/src/main/java/com/ms/api/service/impl/QueueServiceImpl.java b/ms-biz/src/main/java/com/ms/api/service/impl/QueueServiceImpl.java index 5b342128..d9484789 100644 --- a/ms-biz/src/main/java/com/ms/api/service/impl/QueueServiceImpl.java +++ b/ms-biz/src/main/java/com/ms/api/service/impl/QueueServiceImpl.java @@ -77,9 +77,9 @@ public class QueueServiceImpl implements QueueService { queueIdWhere.append(where); } queueIdWhere.append(String.format(" order by %s asc limit %s", queueIdColumnName, limit)); - log.info("whereStr: " + queueIdWhere); +// log.info("whereStr: " + queueIdWhere); List> queueList = queueMapper.select(queueName, queueIdWhere.toString()); - log.info("queueList size: " + queueList.size()); +// log.info("queueList size: " + queueList.size()); if (ObjectUtil.isEmpty(queueList)) { break; } @@ -100,12 +100,10 @@ public class QueueServiceImpl implements QueueService { Set tempRedisIds = new HashSet<>(); tempRedisIds.addAll(redisIds); tempRedisIds.addAll(newRedisIds); - log.info("allQueueList count: " + allQueueList.size()); - log.info("tempRedisIds count: " + tempRedisIds.size()); +// log.info("allQueueList count: " + allQueueList.size()); +// log.info("tempRedisIds count: " + tempRedisIds.size()); for (Map queue : allQueueList) { String queueIdStr = queue.get(queueIdColumnName).toString(); - Long queueId = Long.valueOf(queueIdStr); - log.info("queueId: " + queueId); if (redisIds.contains(queueIdStr)) { continue; }