yili/apps
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

将原来同步到BO_EU_PAL_FILENODE5表中修改为同步到表BO_EU_PAL_FILENODE6中

Browse Source
This commit is contained in:
Mr-wang 2023-10-17 09:14:37 +08:00
parent 28433c4c59
commit 68bf0a0ebd
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
com.awspaas.user.apps.yili.reportform/src/com/awspaas/user/apps/yili/reportform/job/SyncData_job.java
View File

@ -39,10 +39,10 @@ public class SyncData_job implements IJob {
syncNodeData(); syncNodeData();
} }
//同步节点数据到 BO_EU_PAL_FILENODE5 //同步节点数据到 BO_EU_PAL_FILENODE6
public void syncNodeData() { public void syncNodeData() {
DBSql.update("DELETE FROM BO_EU_NODESYN_EXCEPTION"); DBSql.update("DELETE FROM BO_EU_NODESYN_EXCEPTION");
//DBSql.update("DELETE FROM BO_EU_PAL_FILENODE5"); //DBSql.update("DELETE FROM BO_EU_PAL_FILENODE6");
HashMap<String, Object> dataMap = new HashMap<>(); HashMap<String, Object> dataMap = new HashMap<>();
ArrayList<String> fromNodeDataIDMaps = new ArrayList<>(); ArrayList<String> fromNodeDataIDMaps = new ArrayList<>();
ArrayList<Map<String, ?>> oldNodeDataMaps = new ArrayList<>(); ArrayList<Map<String, ?>> oldNodeDataMaps = new ArrayList<>();
@ -85,7 +85,7 @@ public class SyncData_job implements IJob {
SDK.getLogAPI().consoleInfo("文件总数量：" + palTotalList.size()); SDK.getLogAPI().consoleInfo("文件总数量：" + palTotalList.size());
long startTime = System.currentTimeMillis(); long startTime = System.currentTimeMillis();
List<String> nodeIdList = DBSql.getList("SELECT NODEID FROM BO_EU_PAL_FILENODE5", String.class); List<String> nodeIdList = DBSql.getList("SELECT NODEID FROM BO_EU_PAL_FILENODE6", String.class);
for (PALRepositoryModel fileModel : palTotalList) { for (PALRepositoryModel fileModel : palTotalList) {
List<Map<String, Object>> nodeElements = new ArrayList<>(); List<Map<String, Object>> nodeElements = new ArrayList<>();
String PLMETHODID = fileModel.getMethodId(); String PLMETHODID = fileModel.getMethodId();
@ -248,7 +248,7 @@ public class SyncData_job implements IJob {
dataMap.put("MODIFYDATETIME", MODIFYDATETIME); dataMap.put("MODIFYDATETIME", MODIFYDATETIME);
//System.err.println("更新节点信息===========>"+dataMap); //System.err.println("更新节点信息===========>"+dataMap);
try { try {
DBSql.update("UPDATE BO_EU_PAL_FILENODE5 SET" DBSql.update("UPDATE BO_EU_PAL_FILENODE6 SET"
+ " NODENAME=:NODENAME, NODETYPE=:NODETYPE, PLNAME=:PLNAME, NODECATEGORY=:NODECATEGORY, ITSYSVAL=:ITSYSVAL, " + " NODENAME=:NODENAME, NODETYPE=:NODETYPE, PLNAME=:PLNAME, NODECATEGORY=:NODECATEGORY, ITSYSVAL=:ITSYSVAL, "
+ " ACTIVITYNUMBER=:ACTIVITYNUMBER, ACTIVITYDESC=:ACTIVITYDESC, ROLE=:ROLE, POST=:POST, ROLENAME=:ROLENAME, POSTNAME=:POSTNAME, MODIFYDATETIME=:MODIFYDATETIME, UPDATEDATE=:UPDATEDATE " + " ACTIVITYNUMBER=:ACTIVITYNUMBER, ACTIVITYDESC=:ACTIVITYDESC, ROLE=:ROLE, POST=:POST, ROLENAME=:ROLENAME, POSTNAME=:POSTNAME, MODIFYDATETIME=:MODIFYDATETIME, UPDATEDATE=:UPDATEDATE "
+ " WHERE PLID=:PLID AND NODEID=:NODEID", dataMap); + " WHERE PLID=:PLID AND NODEID=:NODEID", dataMap);
@ -283,7 +283,7 @@ public class SyncData_job implements IJob {
//System.err.println("同步节点信息===========>"+dataMap); //System.err.println("同步节点信息===========>"+dataMap);
try { try {
DBSql.update("INSERT INTO BO_EU_PAL_FILENODE5" DBSql.update("INSERT INTO BO_EU_PAL_FILENODE6"
+ " (ID, NODEID, NODENAME, NODETYPE, PLID, PLNAME, NODECATEGORY, ITSYSVAL, ACTIVITYNUMBER, ACTIVITYDESC, ROLE, POST, ROLENAME, POSTNAME, MODIFYDATETIME) " + " (ID, NODEID, NODENAME, NODETYPE, PLID, PLNAME, NODECATEGORY, ITSYSVAL, ACTIVITYNUMBER, ACTIVITYDESC, ROLE, POST, ROLENAME, POSTNAME, MODIFYDATETIME) "
+ " VALUES(:uuId, :NODEID, :NODENAME, :NODETYPE, :PLID, :PLNAME, :NODECATEGORY, :ITSYSVAL, :ACTIVITYNUMBER, :ACTIVITYDESC, :ROLE, :POST, :ROLENAME, :POSTNAME, :MODIFYDATETIME)", dataMap); + " VALUES(:uuId, :NODEID, :NODENAME, :NODETYPE, :PLID, :PLNAME, :NODECATEGORY, :ITSYSVAL, :ACTIVITYNUMBER, :ACTIVITYDESC, :ROLE, :POST, :ROLENAME, :POSTNAME, :MODIFYDATETIME)", dataMap);
} catch (Exception e) { } catch (Exception e) {
@ -311,26 +311,26 @@ public class SyncData_job implements IJob {
if (!fromNodeDataIDMaps.contains(nodeIdOfList)) { if (!fromNodeDataIDMaps.contains(nodeIdOfList)) {
dataMap = new HashMap<>(); dataMap = new HashMap<>();
dataMap.put("NODEID", nodeIdOfList); dataMap.put("NODEID", nodeIdOfList);
DBSql.update("DELETE FROM BO_EU_PAL_FILENODE5 WHERE NODEID=:NODEID", dataMap); DBSql.update("DELETE FROM BO_EU_PAL_FILENODE6 WHERE NODEID=:NODEID", dataMap);
delNodeDataMaps.add(dataMap); delNodeDataMaps.add(dataMap);
} }
} }
} }
/* /*
* if (null != oldNodeDataMaps && !oldNodeDataMaps.isEmpty()) { * if (null != oldNodeDataMaps && !oldNodeDataMaps.isEmpty()) {
* DBSql.batchUpdate("UPDATE BO_EU_PAL_FILENODE5 SET" + * DBSql.batchUpdate("UPDATE BO_EU_PAL_FILENODE6 SET" +
* " NODENAME=:NODENAME, NODETYPE=:NODETYPE, PLNAME=:PLNAME, NODECATEGORY=:NODECATEGORY, ITSYSVAL=:ITSYSVAL, " * " NODENAME=:NODENAME, NODETYPE=:NODETYPE, PLNAME=:PLNAME, NODECATEGORY=:NODECATEGORY, ITSYSVAL=:ITSYSVAL, "
* + * +
* " ACTIVITYNUMBER=:ACTIVITYNUMBER, ACTIVITYDESC=:ACTIVITYDESC, ROLE=:ROLE, POST=:POST, ROLENAME=:ROLENAME, POSTNAME=:POSTNAME, MODIFYDATETIME=:MODIFYDATETIME, UPDATEDATE=:UPDATEDATE " * " ACTIVITYNUMBER=:ACTIVITYNUMBER, ACTIVITYDESC=:ACTIVITYDESC, ROLE=:ROLE, POST=:POST, ROLENAME=:ROLENAME, POSTNAME=:POSTNAME, MODIFYDATETIME=:MODIFYDATETIME, UPDATEDATE=:UPDATEDATE "
* + " WHERE PLID=:PLID AND NODEID=:NODEID", oldNodeDataMaps); } if (null != * + " WHERE PLID=:PLID AND NODEID=:NODEID", oldNodeDataMaps); } if (null !=
* newNodeDataMaps && !newNodeDataMaps.isEmpty()) { * newNodeDataMaps && !newNodeDataMaps.isEmpty()) {
* DBSql.batchUpdate("INSERT INTO BO_EU_PAL_FILENODE5" + * DBSql.batchUpdate("INSERT INTO BO_EU_PAL_FILENODE6" +
* " (ID, NODEID, NODENAME, NODETYPE, PLID, PLNAME, NODECATEGORY, ITSYSVAL, ACTIVITYNUMBER, ACTIVITYDESC, ROLE, POST, ROLENAME, POSTNAME, MODIFYDATETIME) " * " (ID, NODEID, NODENAME, NODETYPE, PLID, PLNAME, NODECATEGORY, ITSYSVAL, ACTIVITYNUMBER, ACTIVITYDESC, ROLE, POST, ROLENAME, POSTNAME, MODIFYDATETIME) "
* + * +
* " VALUES(:uuId, :NODEID, :NODENAME, :NODETYPE, :PLID, :PLNAME, :NODECATEGORY, :ITSYSVAL, :ACTIVITYNUMBER, :ACTIVITYDESC, :ROLE, :POST, :ROLENAME, :POSTNAME, :MODIFYDATETIME)" * " VALUES(:uuId, :NODEID, :NODENAME, :NODETYPE, :PLID, :PLNAME, :NODECATEGORY, :ITSYSVAL, :ACTIVITYNUMBER, :ACTIVITYDESC, :ROLE, :POST, :ROLENAME, :POSTNAME, :MODIFYDATETIME)"
* , newNodeDataMaps); } if (null != delNodeDataMaps && * , newNodeDataMaps); } if (null != delNodeDataMaps &&
* !delNodeDataMaps.isEmpty()) { * !delNodeDataMaps.isEmpty()) {
* DBSql.batchUpdate("DELETE FROM BO_EU_PAL_FILENODE5 WHERE NODEID=:NODEID", * DBSql.batchUpdate("DELETE FROM BO_EU_PAL_FILENODE6 WHERE NODEID=:NODEID",
* delNodeDataMaps); } * delNodeDataMaps); }
*/ */
SDK.getLogAPI().consoleInfo("新增节点" + newNodeDataMaps.size()); SDK.getLogAPI().consoleInfo("新增节点" + newNodeDataMaps.size());