diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java index 96f871a..3d8c028 100644 --- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java +++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java @@ -191,7 +191,10 @@ public abstract class SyncAccountsJobAbstract { String asynchronous = getAsynchronousKey(cjt); redisCache.deleteObject(asynchronous); } else { - larkRobotHelper.sendMessageByBot(ROBOT_GROUP, buildRobotErrorCountMessage2(e, queryFromTime,queryToTime)); + String errorInfo = buildRobotErrorCountMessage2(e, queryFromTime, queryToTime); + if (!StringUtils.isEmpty(errorInfo) && !errorInfo.contains("openToken已失效")) { + larkRobotHelper.sendMessageByBot(ROBOT_GROUP, errorInfo); + } // CJTRetryRequest request = new CJTRetryRequest(now, 1, cjt); // redisCache.rightPush(getRetryKey(cjt), request); } @@ -492,7 +495,7 @@ public abstract class SyncAccountsJobAbstract { body.put(larkLabel, this.changeValueType(value, cjtSyncTypeRelation)); } uniqueKey = String.join("_", uniqueKeyList).toUpperCase() + "_" + addRecordRequest.getAppTable(); - Boolean existFlag = redisCache.setCacheObjectIfAbsent("CJT_JOB_CACHE:"+uniqueKey, "1", 5L, TimeUnit.MINUTES); + Boolean existFlag = redisCache.setCacheObjectIfAbsent("CJT_JOB_CACHE:"+uniqueKey, "1", 2L, TimeUnit.HOURS); if (repeatMap.containsKey(uniqueKey) || !existFlag) { continue; }