diff --git a/accompany-scheduler/accompany-scheduler-service/src/main/java/com/accompany/scheduler/task/BillTask.java b/accompany-scheduler/accompany-scheduler-service/src/main/java/com/accompany/scheduler/task/BillTask.java index 2d31c0ff0..2dad34677 100644 --- a/accompany-scheduler/accompany-scheduler-service/src/main/java/com/accompany/scheduler/task/BillTask.java +++ b/accompany-scheduler/accompany-scheduler-service/src/main/java/com/accompany/scheduler/task/BillTask.java @@ -24,7 +24,7 @@ public class BillTask extends BaseTask { @Scheduled(cron = "0 */5 * * * ?") public void retryBillQueue() { log.info("retryBillQueue start ..."); - Map map = billMessageService.getRecordMessMap().readAllMap(); + Map map = billMessageService.getRecordMessMap().randomEntries(20000); if (CollectionUtils.isEmpty(map)) { return; } diff --git a/accompany-scheduler/accompany-scheduler-service/src/main/java/com/accompany/scheduler/task/luckyBag/BravoTask.java b/accompany-scheduler/accompany-scheduler-service/src/main/java/com/accompany/scheduler/task/luckyBag/BravoTask.java index 608e77df2..683f3d1b5 100644 --- a/accompany-scheduler/accompany-scheduler-service/src/main/java/com/accompany/scheduler/task/luckyBag/BravoTask.java +++ b/accompany-scheduler/accompany-scheduler-service/src/main/java/com/accompany/scheduler/task/luckyBag/BravoTask.java @@ -46,7 +46,7 @@ public class BravoTask { @Scheduled(cron = "0 */5 * * * ?") public void retryBravoQueue() { log.info("retryBravoQueue start ..."); - Map map = jedisService.hgetAll(RedisKey.lucky_24_status.getKey()); + Map map = jedisService.hgetAll(RedisKey.bravo_status.getKey()); if (map == null || map.isEmpty()) { return; }