diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/CJTOperateCallBackAbstract.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/CJTOperateCallBackAbstract.java index b647cc1..090536d 100644 --- a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/CJTOperateCallBackAbstract.java +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/CJTOperateCallBackAbstract.java @@ -66,7 +66,7 @@ public abstract class CJTOperateCallBackAbstract { CjtCallBackOperateEnum msgTypeEnum = req.getMsgTypeEnum(); String operateCallBackFlag = buildCacheUniqueKey(RedisConstants.CJT_CALLBACK_OPERATE, req.getAppId() + msgTypeEnum.getLarkCompanyCode() + req.getVoucherId()); try { - Boolean operateFlag = redisCache.setCacheObjectIfAbsent(operateCallBackFlag, operateCallBackFlag, 10L, TimeUnit.MINUTES); + Boolean operateFlag = redisCache.setCacheObjectIfAbsent(operateCallBackFlag, operateCallBackFlag, 2L, TimeUnit.MINUTES); if (!operateFlag) { return; } @@ -77,15 +77,13 @@ public abstract class CJTOperateCallBackAbstract { endHandle(req); } catch (Exception e) { log.error("{} execute error", this.getClass().getSimpleName(), e); - if (req.getRetry() && req.getRetryCount() < 3) { + if (req.getRetry() && req.getRetryCount() < 2) { req.addRetryCount(); execute(req); } else { errorHandle(req, e); larkRobotHelper.sendMessageByBot(ROBOT_GROUP, buildRobotErrorCountMessage(req, e)); } - } finally { - redisCache.deleteObject(operateCallBackFlag); } }