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; }