diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java index a56a2781..1e53cbe1 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java @@ -61,10 +61,6 @@ public class SchdWaitRunner implements Runnable { sleepInMs(intervalMs); continue ; } - - - //更新返回消息为已处理 - cminmsgService.updateBatchProcessed(Arrays.asList(opCminmsg.get())); //更新 @@ -77,6 +73,9 @@ public class SchdWaitRunner implements Runnable { continue ; } + //更新返回消息为已处理 + cminmsgService.updateBatchProcessed(Arrays.asList(opCminmsg.get())); + //状态记录 Long beginId = opCminmsg.get().getCminmsgsId(); redisService.set(RedisKeyConstant.KEY_LASTBEGINID,beginId);