From 8c7aca05fedd23081125a1ac0a7cafca0a2a0184 Mon Sep 17 00:00:00 2001 From: YXY <932687738@qq.com> Date: Mon, 23 Oct 2023 19:48:47 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=A4=E5=88=86=E9=92=9F=E5=86=85=E9=87=8D?= =?UTF-8?q?=E5=A4=8D=E7=9A=84=E6=95=B0=E6=8D=AE=E4=B8=8D=E8=BF=9B=E8=A1=8C?= =?UTF-8?q?=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../flyingbook/strategy/cjt/CJTOperateCallBackAbstract.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) 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); } }