完善更新逻辑,只有更新动态航班信息成功后才设定为已处理消息。
This commit is contained in:
@@ -61,10 +61,6 @@ public class SchdWaitRunner implements Runnable {
|
|||||||
sleepInMs(intervalMs);
|
sleepInMs(intervalMs);
|
||||||
continue ;
|
continue ;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
//更新返回消息为已处理
|
|
||||||
cminmsgService.updateBatchProcessed(Arrays.asList(opCminmsg.get()));
|
|
||||||
|
|
||||||
|
|
||||||
//更新
|
//更新
|
||||||
@@ -77,6 +73,9 @@ public class SchdWaitRunner implements Runnable {
|
|||||||
continue ;
|
continue ;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
//更新返回消息为已处理
|
||||||
|
cminmsgService.updateBatchProcessed(Arrays.asList(opCminmsg.get()));
|
||||||
|
|
||||||
//状态记录
|
//状态记录
|
||||||
Long beginId = opCminmsg.get().getCminmsgsId();
|
Long beginId = opCminmsg.get().getCminmsgsId();
|
||||||
redisService.set(RedisKeyConstant.KEY_LASTBEGINID,beginId);
|
redisService.set(RedisKeyConstant.KEY_LASTBEGINID,beginId);
|
||||||
|
|||||||
Reference in New Issue
Block a user