diff --git a/com.awspaas.user.apps.app20221008163300/src/com/awspaas/user/apps/app/reportform/controller/SyncFrameData_job_Controller.java b/com.awspaas.user.apps.app20221008163300/src/com/awspaas/user/apps/app/reportform/controller/SyncFrameData_job_Controller.java index 2df7260d..559c1412 100644 --- a/com.awspaas.user.apps.app20221008163300/src/com/awspaas/user/apps/app/reportform/controller/SyncFrameData_job_Controller.java +++ b/com.awspaas.user.apps.app20221008163300/src/com/awspaas/user/apps/app/reportform/controller/SyncFrameData_job_Controller.java @@ -30,338 +30,367 @@ import com.awspaas.user.apps.app.util.RepositoryAttribute; */ @Controller public class SyncFrameData_job_Controller { - @Mapping("com.awspaas.user.apps.app.reportform.controller.SyncFrameData_job_Controller") - public ResponseObject CheckUser(String sid,String fileName) { - ResponseObject ro = ResponseObject.newOkResponse(); - syncFileData(); - sre2(); - ro.put("reslut", "ok"); - return ro; - } - - @Mapping("com.awspaas.user.apps.app.reportform.controller.SyncFrameData_job_Controller_resul") - public ResponseObject CheckUser2(String sid,String fileName) { - System.err.println("刷新模型架构属性开始=============>"); - ResponseObject ro = ResponseObject.newOkResponse(); - sre(); - sre2(); - ro.put("reslut", "ok"); - return ro; - } - - - - //刷新架构名称 - public void sre() { - List palRepositoryModels = CoeProcessLevelDaoFacotory.createCoeProcessLevel() - .getAllCoeProcessLevelByWsId("7d3ca852-a0bd-42e6-80b1-3dcea6f55083"); - for (PALRepositoryModel palRepositoryModel : palRepositoryModels) { - BO bo = new BO(); - - boolean isResul = true; - String name = palRepositoryModel.getName(); - String methodId = palRepositoryModel.getMethodId(); - String uuid = palRepositoryModel.getId(); - bo.set("PLNAME", name); - bo.set("PLID", uuid); - if (("process.epc".equals(methodId) || "control.policy".equals(methodId) - || "process.flowchart".equals(methodId))|| "data.form".equals(methodId)) { - try { - String frameworkName1 = ""; - //String frameworkName2 = ""; - //String frameworkName3 = ""; - // 获取一级架构名称 - String parentId1 = palRepositoryModel.getParentId(); - //String parentId2 = ""; - //String parentId3 = ""; - PALRepositoryModel parentMode1 = PALRepositoryCache.getCache().get(parentId1); - if (parentMode1 != null) { - frameworkName1 = parentMode1.getName(); - /* - * parentId2 = parentMode1.getParentId(); PALRepositoryModel parentMode2 = - * PALRepositoryCache.getCache().get(parentId2); if (parentMode2 != null) { - * frameworkName2 = parentMode2.getName(); parentId3 = - * parentMode2.getParentId(); PALRepositoryModel parentMode3 = - * PALRepositoryCache.getCache().get(parentId3); if (parentMode3 != null) { - * frameworkName3 = parentMode3.getName(); - * - * } } - */ + @Mapping("com.awspaas.user.apps.app.reportform.controller.SyncFrameData_job_Controller") + public ResponseObject CheckUser(String sid,String fileName) { + ResponseObject ro = ResponseObject.newOkResponse(); + syncFileData(); + sre2(); + ro.put("reslut", "ok"); + return ro; + } - } - /* - * String update = "UPDATE App_Act_Coe_Pal_Repository SET PLPARENTID = '" + - * maprightId + "' WHERE ID ='" + uuid + "'"; - */ - // int update2 = DBSql.update(update); - PALRepositoryPropertyDao propertyDao = new PALRepositoryPropertyDao(); - if (isResul) { - String name1 = frameworkName1.substring(frameworkName1.lastIndexOf(".") + 2).trim(); - // 设置三级架构名称 - bo.set("L3", name1); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L3", name1); - // 设置二级架构名称 - String sql2 = "SELECT PLPARENTID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + parentId1 - + "'"; - String prd2 = DBSql.getString(sql2); - String sqlp2 = "SELECT PLNAME,ID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + prd2 + "'"; - RowMap map2 = DBSql.getMap(sqlp2); - if (map2 != null) { - String uuid2 = map2.getString("ID"); - String plName2 = map2.getString("PLNAME"); - String name2 = plName2.substring(plName2.lastIndexOf(".") + 2).trim(); - bo.set("L2", name2); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L2", name2); + @Mapping("com.awspaas.user.apps.app.reportform.controller.SyncFrameData_job_Controller_resul") + public ResponseObject CheckUser2(String sid,String fileName) { + System.err.println("刷新模型架构属性开始=============>"); + ResponseObject ro = ResponseObject.newOkResponse(); + sre(); + sre2(); + ro.put("reslut", "ok"); + return ro; + } - // 设置一级架构名称 - String sql1 = "SELECT PLPARENTID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + uuid2 - + "'"; - String prd1 = DBSql.getString(sql1); - String sqlp1 = "SELECT PLNAME,ID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + prd1 - + "'"; - RowMap map1 = DBSql.getMap(sqlp1); - if (map1 != null) { - String plName1 = map1.getString("PLNAME"); - String name3 = plName1.substring(plName1.lastIndexOf(".") + 2).trim(); - bo.set("L1", name3); - bo.set("LEVELS", "4"); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L1", name3); - DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '4' WHERE ID ='"+uuid+"' AND PLMETHODID != 'process.framework'"); - } else { - bo.set("L1", name1); - bo.set("L2", name2); - bo.set("L3", "/"); - bo.set("LEVELS", "3"); - DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '3' WHERE ID ='"+uuid+"' AND PLMETHODID != 'process.framework'"); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L3", "/"); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L1", name2); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L2", name1); - } - } else { - DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '2' WHERE ID ='"+uuid+"' AND PLMETHODID != 'process.framework'"); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L2", "/"); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L3", "/"); - bo.set("L1", name1); - bo.set("L2", "/"); - bo.set("L3", "/"); - bo.set("LEVELS", "2"); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L1", name1); + //刷新架构名称 + public void sre() { + List palRepositoryModels = CoeProcessLevelDaoFacotory.createCoeProcessLevel() + .getAllCoeProcessLevelByWsId("7d3ca852-a0bd-42e6-80b1-3dcea6f55083"); + for (PALRepositoryModel palRepositoryModel : palRepositoryModels) { + BO bo = new BO(); - } - - bo.set("RESULT", "成功"); - //System.err.println("============》"+palRepositoryModel.getName()); - } - } catch (Exception e) { - - bo.set("RESULT", "失败"); - //System.err.println("刷新架构异常文件======》"+palRepositoryModel.getName()); - // TODO: handle exception - }finally { - - SDK.getBOAPI().createDataBO("BO_EU_PAL_RES_FRARMWORK", bo, UserContext.fromUID("admin")); - - } + boolean isResul = true; + String name = palRepositoryModel.getName(); + String methodId = palRepositoryModel.getMethodId(); + String uuid = palRepositoryModel.getId(); + bo.set("PLNAME", name); + bo.set("PLID", uuid); + if (("process.epc".equals(methodId) || "control.policy".equals(methodId) + || "process.flowchart".equals(methodId))|| "data.form".equals(methodId)) { + try { + String frameworkName1 = ""; + //String frameworkName2 = ""; + //String frameworkName3 = ""; + // 获取一级架构名称 + String parentId1 = palRepositoryModel.getParentId(); + //String parentId2 = ""; + //String parentId3 = ""; + PALRepositoryModel parentMode1 = PALRepositoryCache.getCache().get(parentId1); + if (parentMode1 != null) { + frameworkName1 = parentMode1.getName(); + /* + * parentId2 = parentMode1.getParentId(); PALRepositoryModel parentMode2 = + * PALRepositoryCache.getCache().get(parentId2); if (parentMode2 != null) { + * frameworkName2 = parentMode2.getName(); parentId3 = + * parentMode2.getParentId(); PALRepositoryModel parentMode3 = + * PALRepositoryCache.getCache().get(parentId3); if (parentMode3 != null) { + * frameworkName3 = parentMode3.getName(); + * + * } } + */ - + } + /* + * String update = "UPDATE App_Act_Coe_Pal_Repository SET PLPARENTID = '" + + * maprightId + "' WHERE ID ='" + uuid + "'"; + */ + // int update2 = DBSql.update(update); + PALRepositoryPropertyDao propertyDao = new PALRepositoryPropertyDao(); + if (isResul) { + String name1 = frameworkName1.substring(frameworkName1.lastIndexOf(".") + 2).trim(); + // 设置四级架构名称 + bo.set("L4", name1); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L4", name1); + // 设置三级架构名称 + String sql4 = "SELECT PLPARENTID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + parentId1 + + "'"; + String prd4 = DBSql.getString(sql4); + String sqlp4 = "SELECT PLNAME,ID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + prd4 + "'"; + RowMap map4 = DBSql.getMap(sqlp4); + if (map4 != null) { + String uuid4 = map4.getString("ID"); + String plName4 = map4.getString("PLNAME"); + String name4 = plName4.substring(plName4.lastIndexOf(".") + 2).trim(); + bo.set("L3", name4); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L3", name4); - } - } - System.err.println("刷新模型架构属性结束=============>"); - } - - - //更新架构层级错误 - public void sre2() { - int count = 0; - String slq = "SELECT * FROM APP_ACT_COE_PAL_REPOSITORY WHERE PLMETHODID = 'process.framework'"; - List maps2 = DBSql.getMaps(slq); - for (RowMap rowMap : maps2) { - String plname = rowMap.getString("PLNAME"); - String plId = rowMap.getString("ID"); - String[] split = plname.split("\\."); - if(split.length>2) { - DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '3',EXT5 = '1' WHERE ID = '"+plId+"'"); - }else{ - if(split.length>1) { - String ff = split[1]; - if(ff.contains("0")) { - DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '1',EXT5 = '1' WHERE ID = '"+plId+"'"); - }else { - DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '2',EXT5 = '1' WHERE ID = '"+plId+"'"); - } - } - } - /* - * String sql = - * "SELECT PLLEVEL FROM APP_ACT_COE_PAL_REPOSITORY WHERE PLPARENTID = '"+plId+ - * "'"; String plLevel = DBSql.getString(sql); - * if(UtilString.isNotEmpty(plLevel)) { - * DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '"+(Integer. - * parseInt(plLevel)-1)+""+"' WHERE ID = '"+plId+"'"); }else { - * - * - * } - */ - - } - - - String sql = "SELECT PLLEVEL,ID FROM APP_ACT_COE_PAL_REPOSITORY WHERE PLMETHODID = 'process.framework'"; - List maps = DBSql.getMaps(sql); - for (RowMap rowMap : maps) { - String id = rowMap.getString("ID"); - String level = rowMap.getString("PLLEVEL"); - //count+=DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '"+level+"' WHERE ID = '"+id+"'"); - count+=DBSql.update("UPDATE BO_EU_PAL_FRAME SET FRAMELEVEL = '"+level+"' WHERE FRAMEID = '"+id+"'"); - } - System.err.println("共刷新数据=====》"+count); - - - } - public void syncFileData() { - SDK.getLogAPI().consoleInfo("同步架构表信息开始执行"); - long startTime = System.currentTimeMillis(); - Date nowDateJ = new Date(System.currentTimeMillis()); - SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - String format = sdf2.format(nowDateJ); - SDK.getLogAPI().consoleInfo("开始时间" + format); - String wsId = "7d3ca852-a0bd-42e6-80b1-3dcea6f55083"; - //总文件集合 - String process = "process"; - String org = "org"; - String data = "data"; - String itsystem = "itsystem"; - String control = "control"; - List palProcessList = new ArrayList<>(); - Set palProcessIds = new HashSet<>(); - List palOrgList = new ArrayList<>(); - Set palOrgIds = new HashSet<>(); - List palDataList = new ArrayList<>(); - Set palDataIds = new HashSet<>(); - List palItsystemList = new ArrayList<>(); - Set palItsystemIds = new HashSet<>(); - List palControlList = new ArrayList<>(); - Set palControlIds = new HashSet<>(); - PALRepositoryCache.getAllChildrenModelsByPid(wsId, process, palProcessList, palProcessIds); - PALRepositoryCache.getAllChildrenModelsByPid(wsId, org, palOrgList, palOrgIds); - PALRepositoryCache.getAllChildrenModelsByPid(wsId, data, palDataList, palDataIds); - PALRepositoryCache.getAllChildrenModelsByPid(wsId, itsystem, palItsystemList, palItsystemIds); - PALRepositoryCache.getAllChildrenModelsByPid(wsId, control, palControlList, palControlIds); - //合并为文件总量list - List palTotalList = new ArrayList<>(); - palTotalList.addAll(palProcessList); - palTotalList.addAll(palOrgList); - palTotalList.addAll(palDataList); - palTotalList.addAll(palItsystemList); - palTotalList.addAll(palControlList); - SDK.getLogAPI().consoleInfo("process下文件数量：" + palProcessList.size()); - SDK.getLogAPI().consoleInfo("org下文件数量：" + palOrgList.size()); - SDK.getLogAPI().consoleInfo("data下文件数量：" + palDataList.size()); - SDK.getLogAPI().consoleInfo("itsystem下文件数量：" + palItsystemList.size()); - SDK.getLogAPI().consoleInfo("control下文件数量：" + palControlList.size()); - SDK.getLogAPI().consoleInfo("文件总数量：" + palTotalList.size()); - //过滤出角色文件 + // 设置二级架构名称 + String sql2 = "SELECT PLPARENTID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + uuid4 + + "'"; + String prd2 = DBSql.getString(sql2); + String sqlp2 = "SELECT PLNAME,ID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + prd2 + "'"; + RowMap map2 = DBSql.getMap(sqlp2); + if (map2 != null) { + String uuid2 = map2.getString("ID"); + String plName2 = map2.getString("PLNAME"); + String name2 = plName2.substring(plName2.lastIndexOf(".") + 2).trim(); + bo.set("L2", name2); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L2", name2); + + // 设置一级架构名称 + String sql1 = "SELECT PLPARENTID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + uuid2 + + "'"; + String prd1 = DBSql.getString(sql1); + String sqlp1 = "SELECT PLNAME,ID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + prd1 + + "'"; + RowMap map1 = DBSql.getMap(sqlp1); + + if (map1 != null) { + String plName1 = map1.getString("PLNAME"); + String name3 = plName1.substring(plName1.lastIndexOf(".") + 2).trim(); + bo.set("L1", name3); + bo.set("LEVELS", "5"); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L1", name3); + DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '5' WHERE ID ='"+uuid+"' AND PLMETHODID != 'process.framework'"); + } else { + bo.set("L1", name1); + bo.set("L2", name2); + bo.set("L3", name4); + bo.set("L4", "/"); + bo.set("LEVELS", "4"); + DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '4' WHERE ID ='"+uuid+"' AND PLMETHODID != 'process.framework'"); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L4", "/"); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L3", name4); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L1", name2); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L2", name1); + } + + } else { + DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '3' WHERE ID ='"+uuid+"' AND PLMETHODID != 'process.framework'"); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L2", name4); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L3", "/"); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L4", "/"); + bo.set("L1", name1); + bo.set("L2", name4); + bo.set("L3", "/"); + bo.set("L4", "/"); + bo.set("LEVELS", "3"); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L1", name1); + + } + }else { + DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '2' WHERE ID ='"+uuid+"' AND PLMETHODID != 'process.framework'"); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L2", "/"); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L3", "/"); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L4", "/"); + bo.set("L1", name1); + bo.set("L2", "/"); + bo.set("L3", "/"); + bo.set("L4", "/"); + bo.set("LEVELS", "2"); + propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L1", name1); + } + + bo.set("RESULT", "成功"); + //System.err.println("============》"+palRepositoryModel.getName()); + } + } catch (Exception e) { + + bo.set("RESULT", "失败"); + //System.err.println("刷新架构异常文件======》"+palRepositoryModel.getName()); + // TODO: handle exception + }finally { + + SDK.getBOAPI().createDataBO("BO_EU_PAL_RES_FRARMWORK", bo, UserContext.fromUID("admin")); + + } + + + + } + } + System.err.println("刷新模型架构属性结束=============>"); + } + + + //更新架构层级错误 + public void sre2() { + int count = 0; + String slq = "SELECT * FROM APP_ACT_COE_PAL_REPOSITORY WHERE PLMETHODID = 'process.framework'"; + List maps2 = DBSql.getMaps(slq); + for (RowMap rowMap : maps2) { + String plname = rowMap.getString("PLNAME"); + String plId = rowMap.getString("ID"); + String[] split = plname.split("\\."); + if(split.length>2) { + DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '3',EXT5 = '1' WHERE ID = '"+plId+"'"); + }else{ + if(split.length>1) { + String ff = split[1]; + if(ff.contains("0")) { + DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '1',EXT5 = '1' WHERE ID = '"+plId+"'"); + }else { + DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '2',EXT5 = '1' WHERE ID = '"+plId+"'"); + } + } + } + /* + * String sql = + * "SELECT PLLEVEL FROM APP_ACT_COE_PAL_REPOSITORY WHERE PLPARENTID = '"+plId+ + * "'"; String plLevel = DBSql.getString(sql); + * if(UtilString.isNotEmpty(plLevel)) { + * DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '"+(Integer. + * parseInt(plLevel)-1)+""+"' WHERE ID = '"+plId+"'"); }else { + * + * + * } + */ + + } + + + String sql = "SELECT PLLEVEL,ID FROM APP_ACT_COE_PAL_REPOSITORY WHERE PLMETHODID = 'process.framework'"; + List maps = DBSql.getMaps(sql); + for (RowMap rowMap : maps) { + String id = rowMap.getString("ID"); + String level = rowMap.getString("PLLEVEL"); + //count+=DBSql.update("UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLLEVEL = '"+level+"' WHERE ID = '"+id+"'"); + count+=DBSql.update("UPDATE BO_EU_PAL_FRAME SET FRAMELEVEL = '"+level+"' WHERE FRAMEID = '"+id+"'"); + } + System.err.println("共刷新数据=====》"+count); + + + } + public void syncFileData() { + SDK.getLogAPI().consoleInfo("同步架构表信息开始执行"); + long startTime = System.currentTimeMillis(); + Date nowDateJ = new Date(System.currentTimeMillis()); + SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String format = sdf2.format(nowDateJ); + SDK.getLogAPI().consoleInfo("开始时间" + format); + String wsId = "7d3ca852-a0bd-42e6-80b1-3dcea6f55083"; + //总文件集合 + String process = "process"; + String org = "org"; + String data = "data"; + String itsystem = "itsystem"; + String control = "control"; + List palProcessList = new ArrayList<>(); + Set palProcessIds = new HashSet<>(); + List palOrgList = new ArrayList<>(); + Set palOrgIds = new HashSet<>(); + List palDataList = new ArrayList<>(); + Set palDataIds = new HashSet<>(); + List palItsystemList = new ArrayList<>(); + Set palItsystemIds = new HashSet<>(); + List palControlList = new ArrayList<>(); + Set palControlIds = new HashSet<>(); + PALRepositoryCache.getAllChildrenModelsByPid(wsId, process, palProcessList, palProcessIds); + PALRepositoryCache.getAllChildrenModelsByPid(wsId, org, palOrgList, palOrgIds); + PALRepositoryCache.getAllChildrenModelsByPid(wsId, data, palDataList, palDataIds); + PALRepositoryCache.getAllChildrenModelsByPid(wsId, itsystem, palItsystemList, palItsystemIds); + PALRepositoryCache.getAllChildrenModelsByPid(wsId, control, palControlList, palControlIds); + //合并为文件总量list + List palTotalList = new ArrayList<>(); + palTotalList.addAll(palProcessList); + palTotalList.addAll(palOrgList); + palTotalList.addAll(palDataList); + palTotalList.addAll(palItsystemList); + palTotalList.addAll(palControlList); + SDK.getLogAPI().consoleInfo("process下文件数量：" + palProcessList.size()); + SDK.getLogAPI().consoleInfo("org下文件数量：" + palOrgList.size()); + SDK.getLogAPI().consoleInfo("data下文件数量：" + palDataList.size()); + SDK.getLogAPI().consoleInfo("itsystem下文件数量：" + palItsystemList.size()); + SDK.getLogAPI().consoleInfo("control下文件数量：" + palControlList.size()); + SDK.getLogAPI().consoleInfo("文件总数量：" + palTotalList.size()); + //过滤出角色文件 /* List palRoleFileList = palOrgList.stream().filter(x -> x.getMethodId().equals("org.role")).collect(Collectors.toList()); SDK.getLogAPI().consoleInfo("角色文件数量：" + palRoleFileList.size());*/ - //初始化架构、文件、节点 old/new/del/fromDataID/dis list - ArrayList> oldFrameDataMaps = new ArrayList<>(); - ArrayList> newFrameDataMaps = new ArrayList<>(); - ArrayList> delFrameDataMaps = new ArrayList<>(); - ArrayList fromFrameDataIDMaps = new ArrayList<>(); - HashMap dataMap = new HashMap<>(); - //获取底表数据 - List frameIdList = DBSql.getList("SELECT FRAMEID FROM BO_EU_PAL_FRAME", String.class); - SDK.getLogAPI().consoleInfo("架构底表长度：" + frameIdList.size()); - //系统字段 - String uuId = SDK.getRuleAPI().executeAtScript("@uuid()"); - //遍历总文件集合 - for (PALRepositoryModel fileModel : palTotalList) { - String PLMETHODID = fileModel.getMethodId(); - String FILEID = fileModel.getId(); - String PLNAME = fileModel.getName(); - Timestamp MODIFYDATETIME = fileModel.getModifyDate(); - if (PLMETHODID.equals("process.framework")) { - //更新/新增架构 - Integer FRAMELEVEL = fileModel.getLevel(); - String FRAMETYPE = null; - String FRAMEPARENTID = fileModel.getParentId(); - Integer FRAMEORDERINDEX = fileModel.getOrderIndex(); - Map frameAttrs = new HashMap<>(); - try { - frameAttrs = new RepositoryAttribute().queryRepositoryAttributeById(FILEID); - } catch (Exception e) { - SDK.getLogAPI().consoleInfo("更新架构时文件ID" + FILEID + "数据异常"); - } - if (null != frameAttrs && !frameAttrs.isEmpty()) { - JSONObject Frame_type = frameAttrs.get("Frame_type"); - FRAMETYPE = Frame_type.getString("text"); - } + //初始化架构、文件、节点 old/new/del/fromDataID/dis list + ArrayList> oldFrameDataMaps = new ArrayList<>(); + ArrayList> newFrameDataMaps = new ArrayList<>(); + ArrayList> delFrameDataMaps = new ArrayList<>(); + ArrayList fromFrameDataIDMaps = new ArrayList<>(); + HashMap dataMap = new HashMap<>(); + //获取底表数据 + List frameIdList = DBSql.getList("SELECT FRAMEID FROM BO_EU_PAL_FRAME", String.class); + SDK.getLogAPI().consoleInfo("架构底表长度：" + frameIdList.size()); + //系统字段 + String uuId = SDK.getRuleAPI().executeAtScript("@uuid()"); + //遍历总文件集合 + for (PALRepositoryModel fileModel : palTotalList) { + String PLMETHODID = fileModel.getMethodId(); + String FILEID = fileModel.getId(); + String PLNAME = fileModel.getName(); + Timestamp MODIFYDATETIME = fileModel.getModifyDate(); + if (PLMETHODID.equals("process.framework")) { + //更新/新增架构 + Integer FRAMELEVEL = fileModel.getLevel(); + String FRAMETYPE = null; + String FRAMEPARENTID = fileModel.getParentId(); + Integer FRAMEORDERINDEX = fileModel.getOrderIndex(); + Map frameAttrs = new HashMap<>(); + try { + frameAttrs = new RepositoryAttribute().queryRepositoryAttributeById(FILEID); + } catch (Exception e) { + SDK.getLogAPI().consoleInfo("更新架构时文件ID" + FILEID + "数据异常"); + } + if (null != frameAttrs && !frameAttrs.isEmpty()) { + JSONObject Frame_type = frameAttrs.get("Frame_type"); + FRAMETYPE = Frame_type.getString("text"); + } - fromFrameDataIDMaps.add(FILEID); + fromFrameDataIDMaps.add(FILEID); + + if (frameIdList.contains(FILEID)) { + dataMap = new HashMap<>(); + nowDateJ = new Date(System.currentTimeMillis()); + Timestamp nowDateTime = new Timestamp(nowDateJ.getTime()); + dataMap.put("FRAMEID", FILEID); + dataMap.put("UPDATEDATE", nowDateTime); + dataMap.put("FRAMENAME", PLNAME); + dataMap.put("FRAMELEVEL", FRAMELEVEL); + dataMap.put("FRAMETYPE", FRAMETYPE); + dataMap.put("FRAMEPARENTID", FRAMEPARENTID); + dataMap.put("FRAMEORDERINDEX", FRAMEORDERINDEX); + dataMap.put("MODIFYDATETIME", MODIFYDATETIME); + oldFrameDataMaps.add(dataMap); + } else { + dataMap = new HashMap<>(); + uuId = SDK.getRuleAPI().executeAtScript("@uuid()"); + dataMap.put("uuId", uuId); + dataMap.put("FRAMEID", FILEID); + dataMap.put("FRAMENAME", PLNAME); + dataMap.put("FRAMELEVEL", FRAMELEVEL); + dataMap.put("FRAMETYPE", FRAMETYPE); + dataMap.put("FRAMEPARENTID", FRAMEPARENTID); + dataMap.put("FRAMEORDERINDEX", FRAMEORDERINDEX); + dataMap.put("MODIFYDATETIME", MODIFYDATETIME); + newFrameDataMaps.add(dataMap); + } + } else { + + } + } + + //执行批量新增、修改、删除 + if (null != frameIdList && !frameIdList.isEmpty()) { + for (String frameIdOfList : frameIdList) { + if (!fromFrameDataIDMaps.contains(frameIdOfList)) { + dataMap = new HashMap<>(); + dataMap.put("FRAMEID", frameIdOfList); + delFrameDataMaps.add(dataMap); + } + } + } + if (null != oldFrameDataMaps && !oldFrameDataMaps.isEmpty()) { + DBSql.batchUpdate("UPDATE BO_EU_PAL_FRAME SET" + + " FRAMENAME=:FRAMENAME, FRAMELEVEL=:FRAMELEVEL, FRAMETYPE=:FRAMETYPE, FRAMEPARENTID=:FRAMEPARENTID, FRAMEORDERINDEX=:FRAMEORDERINDEX, MODIFYDATETIME=:MODIFYDATETIME, UPDATEDATE=:UPDATEDATE WHERE FRAMEID=:FRAMEID", oldFrameDataMaps); + } + if (null != newFrameDataMaps && !newFrameDataMaps.isEmpty()) { + DBSql.batchUpdate("INSERT INTO BO_EU_PAL_FRAME(ID,FRAMEID,FRAMENAME,FRAMELEVEL,FRAMETYPE,FRAMEPARENTID,FRAMEORDERINDEX,MODIFYDATETIME) " + + " VALUES(:uuId, :FRAMEID, :FRAMENAME, :FRAMELEVEL, :FRAMETYPE, :FRAMEPARENTID, :FRAMEORDERINDEX, :MODIFYDATETIME)", newFrameDataMaps); + } + if (null != delFrameDataMaps && !delFrameDataMaps.isEmpty()) { + DBSql.batchUpdate("DELETE FROM BO_EU_PAL_FRAME WHERE FRAMEID=:FRAMEID", delFrameDataMaps); + } + SDK.getLogAPI().consoleInfo("新增架构" + newFrameDataMaps.size()); + SDK.getLogAPI().consoleInfo("修改架构" + oldFrameDataMaps.size()); + SDK.getLogAPI().consoleInfo("删除架构" + delFrameDataMaps.size()); + long endTime = System.currentTimeMillis(); + SDK.getLogAPI().consoleInfo("结束时间" + endTime); + SDK.getLogAPI().consoleInfo("运行时间" + (endTime - startTime)); + } - if (frameIdList.contains(FILEID)) { - dataMap = new HashMap<>(); - nowDateJ = new Date(System.currentTimeMillis()); - Timestamp nowDateTime = new Timestamp(nowDateJ.getTime()); - dataMap.put("FRAMEID", FILEID); - dataMap.put("UPDATEDATE", nowDateTime); - dataMap.put("FRAMENAME", PLNAME); - dataMap.put("FRAMELEVEL", FRAMELEVEL); - dataMap.put("FRAMETYPE", FRAMETYPE); - dataMap.put("FRAMEPARENTID", FRAMEPARENTID); - dataMap.put("FRAMEORDERINDEX", FRAMEORDERINDEX); - dataMap.put("MODIFYDATETIME", MODIFYDATETIME); - oldFrameDataMaps.add(dataMap); - } else { - dataMap = new HashMap<>(); - uuId = SDK.getRuleAPI().executeAtScript("@uuid()"); - dataMap.put("uuId", uuId); - dataMap.put("FRAMEID", FILEID); - dataMap.put("FRAMENAME", PLNAME); - dataMap.put("FRAMELEVEL", FRAMELEVEL); - dataMap.put("FRAMETYPE", FRAMETYPE); - dataMap.put("FRAMEPARENTID", FRAMEPARENTID); - dataMap.put("FRAMEORDERINDEX", FRAMEORDERINDEX); - dataMap.put("MODIFYDATETIME", MODIFYDATETIME); - newFrameDataMaps.add(dataMap); - } - } else { - - } - } - //执行批量新增、修改、删除 - if (null != frameIdList && !frameIdList.isEmpty()) { - for (String frameIdOfList : frameIdList) { - if (!fromFrameDataIDMaps.contains(frameIdOfList)) { - dataMap = new HashMap<>(); - dataMap.put("FRAMEID", frameIdOfList); - delFrameDataMaps.add(dataMap); - } - } - } - if (null != oldFrameDataMaps && !oldFrameDataMaps.isEmpty()) { - DBSql.batchUpdate("UPDATE BO_EU_PAL_FRAME SET" - + " FRAMENAME=:FRAMENAME, FRAMELEVEL=:FRAMELEVEL, FRAMETYPE=:FRAMETYPE, FRAMEPARENTID=:FRAMEPARENTID, FRAMEORDERINDEX=:FRAMEORDERINDEX, MODIFYDATETIME=:MODIFYDATETIME, UPDATEDATE=:UPDATEDATE WHERE FRAMEID=:FRAMEID", oldFrameDataMaps); - } - if (null != newFrameDataMaps && !newFrameDataMaps.isEmpty()) { - DBSql.batchUpdate("INSERT INTO BO_EU_PAL_FRAME(ID,FRAMEID,FRAMENAME,FRAMELEVEL,FRAMETYPE,FRAMEPARENTID,FRAMEORDERINDEX,MODIFYDATETIME) " - + " VALUES(:uuId, :FRAMEID, :FRAMENAME, :FRAMELEVEL, :FRAMETYPE, :FRAMEPARENTID, :FRAMEORDERINDEX, :MODIFYDATETIME)", newFrameDataMaps); - } - if (null != delFrameDataMaps && !delFrameDataMaps.isEmpty()) { - DBSql.batchUpdate("DELETE FROM BO_EU_PAL_FRAME WHERE FRAMEID=:FRAMEID", delFrameDataMaps); - } - SDK.getLogAPI().consoleInfo("新增架构" + newFrameDataMaps.size()); - SDK.getLogAPI().consoleInfo("修改架构" + oldFrameDataMaps.size()); - SDK.getLogAPI().consoleInfo("删除架构" + delFrameDataMaps.size()); - long endTime = System.currentTimeMillis(); - SDK.getLogAPI().consoleInfo("结束时间" + endTime); - SDK.getLogAPI().consoleInfo("运行时间" + (endTime - startTime)); - } - - }