From 99d578a89561d137bf24f9dba4e0ca97d24f341d Mon Sep 17 00:00:00 2001
From: zengliang <zengliang@dragoninfo.com.cn>
Date: Tue, 12 Dec 2023 21:16:24 +0800
Subject: [PATCH] fix: Check failure data from 2 minutes ago

---
 .../abin/mallchat/transaction/dao/SecureInvokeRecordDao.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/mallchat-tools/mallchat-transaction/src/main/java/com/abin/mallchat/transaction/dao/SecureInvokeRecordDao.java b/mallchat-tools/mallchat-transaction/src/main/java/com/abin/mallchat/transaction/dao/SecureInvokeRecordDao.java
index cd5360bd..dc84e70f 100644
--- a/mallchat-tools/mallchat-transaction/src/main/java/com/abin/mallchat/transaction/dao/SecureInvokeRecordDao.java
+++ b/mallchat-tools/mallchat-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())