导购刷新好友超时时间

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/friend/SelfFriendSyncNewOperation.java

@@ -25,6 +25,7 @@ import org.springframework.stereotype.Service;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 @Service
@@ -108,8 +109,15 @@ public class SelfFriendSyncNewOperation implements BaseSyncOperation {
             return;
         }
         logger.info("同步第三方服务商好友：{},{}", taskId, pDataId);
-        String key = "haoban_sync_self_friend_task_" + taskId;
-        RedisUtil.lock(key, 3L);
+        String key = "haoban_sync_self_friend_task_" + taskId + ":" + pDataId;
+        String lockKey = "haoban_sync_self_friend_task_lock_" + taskId + ":" + pDataId;
+        RedisUtil.lock(lockKey, 3L);
+        Object hasDealCheck = RedisUtil.getCache(key);
+        if (hasDealCheck != null) {
+            RedisUtil.unlock(lockKey);
+            return;
+        }
+        RedisUtil.setCache(key, pDataId, 1L, TimeUnit.MINUTES);
         List<String> dataIds = preDealService.listReDataIdByPDataId(taskId, pDataId, PreDealTypeEnum.friend.getVal());
         if (CollectionUtils.isEmpty(dataIds)) {
             //更新父级别