完成代码

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

@@ -153,6 +153,11 @@ public class IMallSyncServiceImpl implements IMallSyncService {
 
 
     private void encapsulationRequest(Map<String, String> config, String queueId, Integer id, List<Object> data) {
+        String qId = SnowFlakeIdUtil.generateId().toString();
+    	for(Object curData:data)
+    	{
+    		((Map<String, Object>)curData).put("QUEUE_ID", qId);
+    	}
         Map<String, Object> request = new HashMap<>(3);
         request.put("docType", config.get("docType"));
         request.put("updateType", "update");