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 2dad34677..689f7af6d 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 @@ -36,7 +36,7 @@ public class BillTask extends BaseTask { String messId = entry.getKey(); BillMessage val = entry.getValue(); if (curTime - val.getCreateTime().getTime() > gapTime) { - billMessageService.handleBillMessage(val); + billMessageService.handleBillMessageV2(val); } } catch (Exception e) { log.error("retryBillQueue error", e);