微调

src/main/java/com/system/serivce/impl/IMallSyncServiceImpl.java

@@ -59,6 +59,7 @@ public class IMallSyncServiceImpl implements IMallSyncService {
             if (StringUtil.isNotBlank(customSql)) {
                 //TODO SQL查询
             } else {
+                //TODO 重组List传值
                 Map<String, Object> where = new HashMap<>(3);
                 where.put("dataId", dataId);
                 if (StringUtil.isNotNull(entryId)) {
@@ -73,6 +74,8 @@ public class IMallSyncServiceImpl implements IMallSyncService {
             }
 
             //TODO 插件请求
+
+            //TODO 循环调用前先筛选分组
             this.encapsulationRequest(config, queueId, id, map);
         }
     }
@@ -97,7 +100,7 @@ public class IMallSyncServiceImpl implements IMallSyncService {
             if (MallConstants.OVERTIME_CODE.equals(map.get(MallConstants.CODE_NAME))) {
                 Thread.currentThread().interrupt();
             }
-        }else {
+        } else {
             if (StringUtil.isNotNull(records)) {
                 mallCommonSyncApi.databaseTableDataDelete(records.getDbTableName(), queueId);
             }

src/main/java/com/system/serivce/impl/SynchronizationServiceImpl.java

@@ -84,6 +84,10 @@ public class SynchronizationServiceImpl implements ISynchronizationService {
                 synchronizationRecordsMapper.synchronizationRecordsUpdateByIdList(idList);
             }
 
+            //TODO 筛选FID相同的数据
+            List<String> fidList = recordsList.stream().map(SynchronizationRecordsListOutVoRecords::getFid).distinct().collect(Collectors.toList());
+            for (String fid : fidList) {
+            }
             for (SynchronizationRecordsListOutVoRecords records : recordsList) {
                 if (!"LQKJ_IMSSync".equals(records.getForm())) {
                     mallSyncService.synchronization(records.getId(), records.getForm(), records.getDataId(), records.getEntryId());