提交 bb14e367 authored 作者: 李炎's avatar 李炎

添加docType

上级 94caeceb
...@@ -44,10 +44,6 @@ public class KingDeeCommonSyncServiceImpl implements IKingDeeCommonSyncService { ...@@ -44,10 +44,6 @@ public class KingDeeCommonSyncServiceImpl implements IKingDeeCommonSyncService {
@Override @Override
public void synchronization(Integer id, String sFormId, String dataId, String entryId) { public void synchronization(Integer id, String sFormId, String dataId, String entryId) {
System.out.println("id"+id);
System.out.println("sFormId"+sFormId);
System.out.println("dataId"+dataId);
System.out.println("entryId"+entryId);
//查询表单配置 //查询表单配置
List<Map<String, String>> configList = kingDeeCommonSyncConstants.get(sFormId); List<Map<String, String>> configList = kingDeeCommonSyncConstants.get(sFormId);
if (CollectionUtils.isEmpty(configList)) { if (CollectionUtils.isEmpty(configList)) {
...@@ -74,11 +70,9 @@ public class KingDeeCommonSyncServiceImpl implements IKingDeeCommonSyncService { ...@@ -74,11 +70,9 @@ public class KingDeeCommonSyncServiceImpl implements IKingDeeCommonSyncService {
Map<String, Object> response = new LinkedHashMap<>(); Map<String, Object> response = new LinkedHashMap<>();
KingDeeCommonSyncConstants.encapsulationThirdPartyFieldBySql(dataList, fieldList, response); KingDeeCommonSyncConstants.encapsulationThirdPartyFieldBySql(dataList, fieldList, response);
request.add(response); request.add(response);
System.out.println("response===="+response);
kingDeeCommonSyncApi.databaseTableDataCreateBySql(config.get("docType"), queueId, dataList, fieldList, primaryKeyField); kingDeeCommonSyncApi.databaseTableDataCreateBySql(config.get("docType"), queueId, dataList, fieldList, primaryKeyField);
} }
System.out.println("request1===="+request);
} else { } else {
//设置需要同步的主键 //设置需要同步的主键
Map<String, String> where = new HashMap<>(1); Map<String, String> where = new HashMap<>(1);
...@@ -91,7 +85,6 @@ public class KingDeeCommonSyncServiceImpl implements IKingDeeCommonSyncService { ...@@ -91,7 +85,6 @@ public class KingDeeCommonSyncServiceImpl implements IKingDeeCommonSyncService {
} }
request = kingDeeCommonSyncApi.synchronization(config, queueId, fieldList, where); request = kingDeeCommonSyncApi.synchronization(config, queueId, fieldList, where);
System.out.println("request2===="+request);
if (request.get(0).containsKey(Constants.FALSE)) { if (request.get(0).containsKey(Constants.FALSE)) {
synchronizationRecordsMapper.synchronizationRecordsUpdate(new SynchronizationRecordsUpdateInVo(id, queueId, request.get(0).get(Constants.FALSE).toString(), 2)); synchronizationRecordsMapper.synchronizationRecordsUpdate(new SynchronizationRecordsUpdateInVo(id, queueId, request.get(0).get(Constants.FALSE).toString(), 2));
return; return;
...@@ -102,10 +95,8 @@ public class KingDeeCommonSyncServiceImpl implements IKingDeeCommonSyncService { ...@@ -102,10 +95,8 @@ public class KingDeeCommonSyncServiceImpl implements IKingDeeCommonSyncService {
if (StringUtil.isNotBlank(plugInUrl)) { if (StringUtil.isNotBlank(plugInUrl)) {
List<Map<String, Object>> tempList = this.encapsulationGetByHttp(config, queueId, id, plugInUrl, request, dataList); List<Map<String, Object>> tempList = this.encapsulationGetByHttp(config, queueId, id, plugInUrl, request, dataList);
if (!CollectionUtils.isEmpty(tempList)) { if (!CollectionUtils.isEmpty(tempList)) {
System.out.println("tempList===="+tempList);
request = tempList; request = tempList;
} }
System.out.println("request3===="+request);
} }
this.encapsulationRequest(config, queueId, id, request); this.encapsulationRequest(config, queueId, id, request);
...@@ -194,8 +185,8 @@ public class KingDeeCommonSyncServiceImpl implements IKingDeeCommonSyncService { ...@@ -194,8 +185,8 @@ public class KingDeeCommonSyncServiceImpl implements IKingDeeCommonSyncService {
* 同步至第三方 * 同步至第三方
*/ */
private void encapsulationRequest(Map<String, String> config, String queueId, Integer id, List<Map<String, Object>> dataList) { private void encapsulationRequest(Map<String, String> config, String queueId, Integer id, List<Map<String, Object>> dataList) {
System.out.println("dataList"+dataList);
for(Map<String, Object> curData:dataList){ for(Map<String, Object> curData:dataList){
curData.put("docType",config.get("docType"));
String response = kingDeeCommonSyncApi.sendThirdParty(JsonUtil.toString(curData)); String response = kingDeeCommonSyncApi.sendThirdParty(JsonUtil.toString(curData));
response = unicodeToString(response); response = unicodeToString(response);
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论