fix: Check failure data from 2 minutes ago

zongzibinbin · Dec 12, 2023 · 99d578a · 99d578a
1 parent 7c2c4d9
commit 99d578a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...at-transaction/src/main/java/com/abin/mallchat/transaction/dao/SecureInvokeRecordDao.java b/...at-transaction/src/main/java/com/abin/mallchat/transaction/dao/SecureInvokeRecordDao.java
@@ -22,7 +22,7 @@ public class SecureInvokeRecordDao extends ServiceImpl<SecureInvokeRecordMapper,
     public List<SecureInvokeRecord> getWaitRetryRecords() {
         Date now = new Date();
         //查2分钟前的失败数据。避免刚入库的数据被查出来
-        DateTime afterTime = DateUtil.offsetMinute(now, (int) SecureInvokeService.RETRY_INTERVAL_MINUTES);
+        DateTime afterTime = DateUtil.offsetMinute(now, -(int) SecureInvokeService.RETRY_INTERVAL_MINUTES);
         return lambdaQuery()
                 .eq(SecureInvokeRecord::getStatus, SecureInvokeRecord.STATUS_WAIT)
                 .lt(SecureInvokeRecord::getNextRetryTime, new Date())