微调

src/main/java/com/system/api/CommonApi.java

@@ -3,6 +3,7 @@ package com.system.api;
 import com.system.constants.Constants;
 import com.system.transfer.form.MallFieldMappingListOutVoRecords;
 import com.system.utils.JsonUtil;
+import com.system.utils.SnowFlakeIdUtil;
 import org.springframework.util.CollectionUtils;
 
 import java.math.BigDecimal;
@@ -16,11 +17,11 @@ import java.util.Map;
  */
 public class CommonApi {
 
-    public static String encapsulationData(Map<String, String> config, String queueId, List<Map<String, Object>> dataList, List<MallFieldMappingListOutVoRecords> fieldList) {
+    public static String encapsulationData(Map<String, String> config, List<Map<String, Object>> dataList, List<MallFieldMappingListOutVoRecords> fieldList) {
         if (Integer.parseInt(config.get(Constants.ENCAPSULATION_FORMAT)) == 1) {
-            return encapsulationDataOnWhole(queueId, dataList, fieldList);
+            return encapsulationDataOnWhole(SnowFlakeIdUtil.generateId().toString(), dataList, fieldList);
         } else {
-            return encapsulationDataOnPolymerization(queueId, config.get("entryName"), dataList, fieldList);
+            return encapsulationDataOnPolymerization(SnowFlakeIdUtil.generateId().toString(), config.get("entryName"), dataList, fieldList);
         }
     }
 

src/main/java/com/system/mall/MallCommonApi.java

@@ -39,7 +39,7 @@ public class MallCommonApi {
     }
 
     public void mallSynchronizedRecordsUpdate(List<Map<String, Object>> tempList) {
-        List<String> idList = tempList.stream().filter(m -> !"LQKJ_IMSSync".equals(m.get("formId"))).map(m -> String.valueOf(m.get("fid"))).collect(Collectors.toList());
+        List<Integer> idList = tempList.stream().filter(m -> !"LQKJ_IMSSync".equals(m.get("formId"))).map(m -> Integer.valueOf(String.valueOf(m.get("fid")))).collect(Collectors.toList());
 
         if (!CollectionUtils.isEmpty(idList)) {
             //修改商城是否同步

src/main/java/com/system/utils/ProductLogUtil.java

 package com.system.utils;
 
 import com.system.config.ThreadLocalConfig;
+import com.system.constants.Constants;
 import com.system.constants.MallConstants;
 import com.system.dao.ProductLogMapper;
 import com.system.dao.SynchronizationRecordsMapper;
@@ -129,6 +130,15 @@ public class ProductLogUtil {
     public void productSyncLogCreate(Integer productId, String queueId, String name, String code, String direction, String request, String response) {
         ProductLogCreateInVo inVo = this.encapsulationInVo(productId, queueId, name, code, direction, request, response);
 
+        Map<String, Object> map = JsonUtil.toMap(response, String.class, Object.class);
+        if (!CollectionUtils.isEmpty(map)) {
+            if (MallConstants.SUCCESS_CODE.equals(String.valueOf(map.get(Constants.CODE_NAME)))) {
+                inVo.setFlag(1);
+            }
+        } else {
+            inVo.setFlag(0);
+            inVo.setMessage(String.valueOf(map.get(Constants.ERROR_MESSAGE)));
+        }
         productLogMapper.productLogCreate(inVo);
     }