同步通讯录并发

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/DealSyncOperationApiServiceImpl.java

@@ -998,12 +998,19 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
             logger.info("企微通讯录成员成功:{}", taskId);
             String key = "haoban_sync_clerk_task_" + taskId;
             RedisUtil.lock(key, 3L);
+            String cacheId = "haoban_sync_clerk_task_cache_"+taskId ;
+            if(null != RedisUtil.getCache(cacheId)) {
+                logger.info("进行中,未完成{}", cacheId);
+                return false ;
+            }
+            RedisUtil.setCache(cacheId,1 , 15*60L) ;
             TabHaobanSyncTask syncTask = syncTaskService.getSyncTask(taskId);
             String wxEnterpriseId = syncTask.getWxEnterpriseId();
             this.unlockTask(wxEnterpriseId) ;
             this.cleanDiffrence(wxEnterpriseId, taskId);
             logger.info("同步通讯录完成");
             String conectkey = "get_follow_user_list:"+wxEnterpriseId ;
+            RedisUtil.delCache(cacheId) ;
             RedisUtil.delCache(conectkey) ;
             RedisUtil.unlock(key);
         }