增加redis缓存防止重复数据

ruoyi-common/src/main/java/com/ruoyi/common/core/redis/RedisCache.java

@@ -35,6 +35,15 @@ public class RedisCache {
         redisTemplate.opsForValue().set(key, value);
     }
 
+    public Boolean setCacheObjectIfAbsent(final String key, String value, Long time, TimeUnit timeUnit) {
+        try {
+            return redisTemplate.opsForValue().setIfAbsent(key, value,time,timeUnit);
+        }catch (Exception e){
+
+        }
+       return true;
+    }
+
     /**
      * 缓存基本的对象，Integer、String、实体类等
      *

ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java

@@ -469,7 +469,8 @@ public abstract class SyncAccountsJobAbstract {
                     body.put(larkLabel, this.changeValueType(value, cjtSyncTypeRelation));
                 }
                 uniqueKey = String.join("_", uniqueKeyList).toUpperCase() + "_" + addRecordRequest.getAppTable();
-                if (repeatMap.containsKey(uniqueKey)) {
+                Boolean existFlag = redisCache.setCacheObjectIfAbsent(uniqueKey, uniqueKey, 5L, TimeUnit.MINUTES);
+                if (repeatMap.containsKey(uniqueKey) || !existFlag) {
                     continue;
                 }
                 repeatMap.put(uniqueKey, 1);