去重

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

@@ -41,10 +41,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
+import java.util.*;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
@@ -285,7 +282,13 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
         eidListMap.forEach((k, v) -> {
             //获取所有分组列表
             List<StoreGroupDTO> groupDTOList = storeGroupService.listStoreGroupAndChildren(v.toArray(new String[]{}), k);
-            List<TabHaobanPreDealLog> dealList = groupDTOList.stream().map(storeGroupDTO -> {
+            List<String> hasKey=new ArrayList<>();
+            List<TabHaobanPreDealLog> dealList = groupDTOList.stream().filter(dto->{
+                if (hasKey.contains(dto.getStoreGroupId())) {
+                    return false;
+                }
+                return true;
+            }).map(storeGroupDTO -> {
                 TabHaobanPreDealLog dealLog = new TabHaobanPreDealLog();
                 dealLog.setDataId(storeGroupDTO.getStoreGroupId());
                 if (pMap.containsKey(storeGroupDTO.getStoreGroupId())) {

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/SyncDealContoller.java

@@ -67,6 +67,7 @@ public class SyncDealContoller extends WebBaseController {
         String wxEnterpriseId = login.getWxEnterpriseId();
 
         logger.info("login:{}", JSONObject.toJSONString(login));
+        logger.info("data:{}", JSONObject.toJSONString(qo));
 
         String taskLock = dealSyncOperationApiService.getTaskLock(wxEnterpriseId);
         if (null != taskLock) {