hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改数量

This commit is contained in:
lvleigang 2024-12-19 09:54:52 +08:00
parent b04d7f0709
commit 49a157ea28
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
buildpackage/src/main/java/com/hzya/frame/plugin/mdmDistribute/plugin/MdmModulePluginInitializer.java
View File

@ -544,7 +544,7 @@ public class MdmModulePluginInitializer extends PluginBaseEntity {
map1.put("tableName",mainDb); map1.put("tableName",mainDb);
map1.put("dataStatus", "N"); map1.put("dataStatus", "N");
map1.put("deleteStatus", "0"); map1.put("deleteStatus", "0");
map1.put("size", 50); map1.put("size", 10);
objects = mdmModuleDao.queryMdmSTs(map1); objects = mdmModuleDao.queryMdmSTs(map1);
objects = toLowerCaseKeys(objects); objects = toLowerCaseKeys(objects);
@ -739,7 +739,7 @@ public class MdmModulePluginInitializer extends PluginBaseEntity {
map1.put("tableName",mainDb); map1.put("tableName",mainDb);
//map1.put("dataStatus", "F"); //map1.put("dataStatus", "F");
map1.put("updateStatus", "0"); map1.put("updateStatus", "0");
map1.put("size", 50); map1.put("size", 10);
objects = mdmModuleDao.queryMdmSTs(map1); objects = mdmModuleDao.queryMdmSTs(map1);
objects = toLowerCaseKeys(objects); objects = toLowerCaseKeys(objects);
@ -927,7 +927,7 @@ public class MdmModulePluginInitializer extends PluginBaseEntity {
map1.put("tableName",mainDb); map1.put("tableName",mainDb);
//map1.put("dataStatus", "Y"); //map1.put("dataStatus", "Y");
map1.put("addStatus", "0"); map1.put("addStatus", "0");
map1.put("size", 50); map1.put("size", 10);
objects = mdmModuleDao.queryMdmSTs(map1); objects = mdmModuleDao.queryMdmSTs(map1);
objects = toLowerCaseKeys(objects); objects = toLowerCaseKeys(objects);
@ -965,14 +965,14 @@ public class MdmModulePluginInitializer extends PluginBaseEntity {
for (int i = 0; i < doObjects.size(); i++) { for (int i = 0; i < doObjects.size(); i++) {
saveMdmModuleSendLogEntity(mainCode,mdmModuleDistributeEntities.get(i1).getId(),"2","新增接口未查找到",mainDb,objects.get(i).getString("id"),null,null,null,null,doObjects.get(i).toJSONString(),"1"); saveMdmModuleSendLogEntity(mainCode,mdmModuleDistributeEntities.get(i1).getId(),"2","新增接口未查找到",mainDb,objects.get(i).getString("id"),null,null,null,null,doObjects.get(i).toJSONString(),"1");
} }
return ; continue ;
} }
SysApplicationEntity sysApplicationEntity = sysApplicationDao.get(apiEntity.getAppId()); SysApplicationEntity sysApplicationEntity = sysApplicationDao.get(apiEntity.getAppId());
if(sysApplicationEntity == null || sysApplicationEntity.getId() == null ){ if(sysApplicationEntity == null || sysApplicationEntity.getId() == null ){
for (int i = 0; i < doObjects.size(); i++) { for (int i = 0; i < doObjects.size(); i++) {
saveMdmModuleSendLogEntity(mainCode,mdmModuleDistributeEntities.get(i1).getId(),"2","应用未查找到",mainDb,objects.get(i).getString("id"),null,null,apiEntity.getApiName(),apiEntity.getId(),doObjects.get(i).toJSONString(),"1"); saveMdmModuleSendLogEntity(mainCode,mdmModuleDistributeEntities.get(i1).getId(),"2","应用未查找到",mainDb,objects.get(i).getString("id"),null,null,apiEntity.getApiName(),apiEntity.getId(),doObjects.get(i).toJSONString(),"1");
} }
return ; continue ;
} }
SysApplicationScriptEntity scriptEntity = null; SysApplicationScriptEntity scriptEntity = null;
@ -982,7 +982,7 @@ public class MdmModulePluginInitializer extends PluginBaseEntity {
for (int i = 0; i < doObjects.size(); i++) { for (int i = 0; i < doObjects.size(); i++) {
saveMdmModuleSendLogEntity(mainCode,mdmModuleDistributeEntities.get(i1).getId(),"2","脚本未查找到",mainDb,objects.get(i).getString("id"),sysApplicationEntity.getName(),sysApplicationEntity.getId(),apiEntity.getApiName(),apiEntity.getId(),doObjects.get(i).toJSONString(),"1"); saveMdmModuleSendLogEntity(mainCode,mdmModuleDistributeEntities.get(i1).getId(),"2","脚本未查找到",mainDb,objects.get(i).getString("id"),sysApplicationEntity.getName(),sysApplicationEntity.getId(),apiEntity.getApiName(),apiEntity.getId(),doObjects.get(i).toJSONString(),"1");
} }
return ; continue ;
} }
} }
@ -1136,14 +1136,14 @@ public class MdmModulePluginInitializer extends PluginBaseEntity {
//所有下发发送完成，修改数据状态 //所有下发发送完成，修改数据状态
for (int i = 0; i < objects.size(); i++) { for (int i = 0; i < objects.size(); i++) {
if(objects.get(i).getBoolean("sendsanfzt123")){ //if(objects.get(i).getBoolean("sendsanfzt123")){
Map<String, Object> updateMap = new HashMap<>(); Map<String, Object> updateMap = new HashMap<>();
updateMap.put("tableName",mainDb); updateMap.put("tableName",mainDb);
//updateMap.put("dataStatus", "Y"); //updateMap.put("dataStatus", "Y");
updateMap.put("addStatus", "1"); updateMap.put("addStatus", "1");
updateMap.put("id", objects.get(i).getString("id")); updateMap.put("id", objects.get(i).getString("id"));
mdmModuleDao.updateMdmSTs(updateMap); mdmModuleDao.updateMdmSTs(updateMap);
} //}
} }
} }