diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsBussEOController.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsBussEOController.java index 39f05ec2..f203eda4 100644 --- a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsBussEOController.java +++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsBussEOController.java @@ -38,8 +38,8 @@ public class ActSarItemsBussEOController extends BaseController { @PostMapping("/processCreateBuss") public ResponseMessage processCreateBuss(String infoJson) throws Exception { if (StringUtils.isNotBlank(infoJson)) { - actSarItemsEOService.processCreateBuss(infoJson); - return Result.success("入库成功"); + String bussId = actSarItemsEOService.processCreateBuss(infoJson); + return Result.success(bussId); } else { return Result.error("传入数据json不能为空"); } diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/service/ActSarItemsBussEOService.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/service/ActSarItemsBussEOService.java index 2c238a02..48950bf4 100644 --- a/adc-da-activiti/src/main/java/com/adc/da/workFlow/service/ActSarItemsBussEOService.java +++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/service/ActSarItemsBussEOService.java @@ -217,9 +217,10 @@ public class ActSarItemsBussEOService { * @Param: [standJson] * @Return: void */ - public void processCreateBuss(String standJson) throws Exception{ + public String processCreateBuss(String standJson) throws Exception{ Map standMap = new HashMap(); standMap = JSONObject.parseObject(standJson); + String bussId = ""; if (standMap != null && !standMap.isEmpty()) { String prcNum = String.valueOf(standMap.get("prcNum")); String pid = String.valueOf(standMap.get("topId")); @@ -286,7 +287,6 @@ public class ActSarItemsBussEOService { // sarStandardsInfoEO.setMenuId("22179d54d4e640098e29"); // } //此处判断是否是带入的标准 - String bussId = ""; if(StringUtils.isNotBlank(sarBussionessStand.getId())) { bussId = sarBussionessStand.getId(); SarBussionessStand query = new SarBussionessStand(); @@ -413,7 +413,7 @@ public class ActSarItemsBussEOService { } } - + return bussId; } private void updateStandFileFieldData(Map addAttInfoMap,Map oldAttInfoMap){ diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussStandMenu/controller/SarBussStandMenuController.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussStandMenu/controller/SarBussStandMenuController.java index c5f214de..20aa0e53 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussStandMenu/controller/SarBussStandMenuController.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussStandMenu/controller/SarBussStandMenuController.java @@ -50,6 +50,7 @@ public class SarBussStandMenuController extends BaseController SarBussStandMenu menuEO = new SarBussStandMenu(); menuEO.setBussStandId(id); menuEO.setMenuId(standardsInfoEO.getMenuId()); + menuEO.setTreeType(standardsInfoEO.getTreeType()); //删除所选目录下关联 String oldMenuId = standardsInfoEO.getOldMenuId(); if (StringUtils.isEmpty(oldMenuId)) { diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/impl/SarBussionessStandServiceImpl.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/impl/SarBussionessStandServiceImpl.java index ae6df3f8..8ba9a104 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/impl/SarBussionessStandServiceImpl.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/impl/SarBussionessStandServiceImpl.java @@ -404,6 +404,13 @@ public class SarBussionessStandServiceImpl extends ServiceImpl sarlist) throws Exception { + + //查询字典表,形成Hash映射提升速度 + List dicInfo = dicTypeEODao.getDicInfo("dic_type_code", "dic_type_name"); + Map dicMap = dicInfo.stream() + .filter(item-> !item.getDicTypeCode().isEmpty()) + .collect(Collectors.toMap(DicTypeEO::getDicTypeCode,DicTypeEO::getDicTypeName,(value1, value2 )->value2)); + for(SarBussionessStand row : sarlist){ attrInfoDetailsExport(row); Map getAttrMap = row.getAttrInfoMap(); @@ -424,16 +431,17 @@ public class SarBussionessStandServiceImpl extends ServiceImpl 0 && InitStandAttrUtil.fileFieldListBuss.contains(name)) { - value = entry.getValue().toString(); - if (StringUtils.isNotBlank(value)) { - List fileObj = attFileEOService.getMultiFileInfos(value); - entry.setValue(fileObj); - } +// value = entry.getValue().toString(); +// if (StringUtils.isNotBlank(value)) { +// List fileObj = attFileEOService.getMultiFileInfos(value); +// entry.setValue(fileObj); +// } } else if (entry.getValue() != null && InitStandAttrUtil.selectionFieldListBuss != null && InitStandAttrUtil.selectionFieldListBuss.size() > 0 && InitStandAttrUtil.selectionFieldListBuss.contains(name)) { value = entry.getValue().toString(); String selVal = InitStandAttrUtil.selectFieldMapBuss.get(name); if (SelectionTypeEnum.ORGLIST.getValue().equals(selVal) || SelectionTypeEnum.USERLIST.getValue().equals(selVal) || SelectionTypeEnum.ROLELIST.getValue().equals(selVal)) { if("ZYQCR".equals(name)||"QTQCR".equals(name)){ + if(getAttrMap.get(name + "Name")!=null && !getAttrMap.get(name + "Name").equals("")){ value = String.valueOf(getAttrMap.get(name + "Name")); } @@ -442,7 +450,21 @@ public class SarBussionessStandServiceImpl extends ServiceImpl valArr = Arrays.asList(value.split(",")); - value = dicTypeEODao.getDicNamesByCodes(valArr); + if(entry.getValue()!=null) { + StringBuilder builder = new StringBuilder(""); + for (String s : valArr) { + if (dicMap.containsKey(s) && !"ZRBM".equals(name)){ + builder.append(dicMap.get(s)+" "); + } + + } + + if (builder.toString().isEmpty()){ + value = entry.getValue().toString(); + }else { + value = builder.toString(); + } + } } entry.setValue(value); } @@ -889,11 +911,11 @@ public class SarBussionessStandServiceImpl extends ServiceImpl getMenuPIds = new ArrayList<>(); if(StringUtils.isNotBlank(treeType) && "sarMs".equals(treeType)){ + sarStandMenuEO.setTreeType("sarMs"); getMenuPIds = iSarMenuStandardService.getChildMenuList(nowMenuId); }else { getMenuPIds = iTsResourceService.getParentMenuId(nowMenuId); @@ -906,16 +928,18 @@ public class SarBussionessStandServiceImpl extends ServiceImpl menuIds = new ArrayList<>(); if(StringUtils.isNotBlank(treeType) && "sarMs".equals(treeType)) { + // sarMs 技术体系 标准只可选一个 根据标准查询唯一 + standMenuEOQuery.setTreeType("sarMs"); menuIds = iSarMenuStandardService.getChildMenuList(secondLevelId); }else { + standMenuEOQuery.setMenuId(secondLevelId); menuIds = iTsResourceService.getChildMenuList(secondLevelId); + standMenuEOQuery.setMenuIds(menuIds); } - standMenuEOQuery.setMenuIds(menuIds); List getInfo = sarBussStandMenuEODao.selectMenuByMenuParentId(standMenuEOQuery); //删除节点与根节点的关联 SarBussStandMenu sarStandMenuDel = new SarBussStandMenu(); @@ -925,27 +949,32 @@ public class SarBussionessStandServiceImpl extends ServiceImpl menuOldIds = new ArrayList<>(); if(StringUtils.isNotBlank(treeType) && "sarMs".equals(treeType)) { menuOldIds = iSarMenuStandardService.getChildMenuList(secondLevelId); + sarStandMenuEO.setMenuIds(menuOldIds); + sarStandMenuEO.setId(getInfo.get(0).getId()); + op = sarBussStandMenuEODao.updateById(sarStandMenuEO); }else { menuOldIds= iTsResourceService.getChildMenuList(secondLevelId); + sarStandMenuEO.setMenuIds(menuOldIds); + op = sarBussStandMenuEODao.updateByStandIdAndMenuId(sarStandMenuEO); } - sarStandMenuEO.setMenuIds(menuOldIds); - op = sarBussStandMenuEODao.updateByStandIdAndMenuId(sarStandMenuEO); } - QueryWrapper qw = new QueryWrapper(); - qw.eq("STAND_ID",standId); - List infoList = sarBussStandAttrInfoEODao.selectList(qw); - if(!infoList.isEmpty()){ - SarBussStandAttrInfo attrInfo = new SarBussStandAttrInfo(); - attrInfo.setId(infoList.get(0).getId()); - attrInfo.setTxlbbuss(menuName); - attrInfo.setValidFlag("0"); - sarBussStandAttrInfoEODao.updateById(attrInfo); + if(StringUtils.isNotBlank(treeType) && "sarMs".equals(treeType)) { + QueryWrapper qw = new QueryWrapper(); + qw.eq("STAND_ID",standId); + List infoList = sarBussStandAttrInfoEODao.selectList(qw); + if(!infoList.isEmpty()){ + SarBussStandAttrInfo attrInfo = new SarBussStandAttrInfo(); + attrInfo.setId(infoList.get(0).getId()); + attrInfo.setTxlbbuss(menuName); + attrInfo.setValidFlag("0"); + sarBussStandAttrInfoEODao.updateById(attrInfo); + } } // sarBussStandMenuEODao.updateByStandIDSelective(sarStandMenuEO); } diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStandState/sync/StateSync.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStandState/sync/StateSync.java index 732969b5..61ac7740 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStandState/sync/StateSync.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStandState/sync/StateSync.java @@ -54,15 +54,21 @@ public class StateSync { try{ Thread.sleep(2000); logger.info("月初:"+Thread.currentThread().getName() + " cron=0 0 1 1 * ? --- " + new Date()+"---START-01"); - String nowFirst = DateUtil.firstOneDay(DateUtil.printDate(new Date())); - String nowFin = DateUtil.finOneDay(DateUtil.printDate(new Date())); - String nowFinByQuery = DateUtil.addDay(DateUtil.finOneDay(DateUtil.printDate(new Date())),1); - System.out.println("当前月第一日:"+nowFirst); - System.out.println("当前月最后一日:"+nowFin); +// String nowFirst = DateUtil.firstOneDay(DateUtil.printDate(new Date())); +// String nowFin = DateUtil.finOneDay(DateUtil.printDate(new Date())); +// String nowFinByQuery = DateUtil.addDay(DateUtil.finOneDay(DateUtil.printDate(new Date())),1); +// System.out.println("当前月第一日:"+nowFirst); +// System.out.println("当前月最后一日:"+nowFin); + // 改为下月整月 + String nextFirst = DateUtil.printDate(DateUtil.nextMonthFirstDate()); + String nextFin = DateUtil.finOneDay(DateUtil.printDate(DateUtil.nextMonthFirstDate())); + String nextFinByQuery = DateUtil.addDay(DateUtil.finOneDay(DateUtil.printDate(DateUtil.nextMonthFirstDate())),1); + System.out.println("下个月第一日:"+ nextFirst); + System.out.println("下个月最后一日:"+nextFin); SarBussionessStand stand = new SarBussionessStand(); - stand.setIssueTimeStart(nowFirst); - stand.setIssueTimeEnd(nowFin); + stand.setIssueTimeStart(nextFirst); + stand.setIssueTimeEnd(nextFin); List standList = sarBussionessStandDao.queryByBussStateSync(stand); if(!standList.isEmpty()){ List filterList = new ArrayList<>(); @@ -85,7 +91,7 @@ public class StateSync { List updList = new ArrayList<>(); QueryWrapper wrapper = new QueryWrapper(); wrapper.isNull("REVIEW_RESULTS"); - wrapper.between("REVIEW_TIME",nowFirst,nowFinByQuery); + wrapper.between("REVIEW_TIME",nextFirst,nextFinByQuery); List stateList = bussionessStandStateService.list(wrapper); if(!stateList.isEmpty()){ // 差集 (list1 - list2) 新增复审表 @@ -143,7 +149,7 @@ public class StateSync { } } - // 月末 + // 月末 (逻辑和 月初 一样 月末需跑一次下整月 防止特殊原因导致遗漏) @Scheduled(cron="0 0 1 28-31 * ?") // @Scheduled(cron="*/5 * * * * ?") @Async diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/entity/SarBussionessStandEOPage.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/entity/SarBussionessStandEOPage.java index 9611381c..120a195d 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/entity/SarBussionessStandEOPage.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/entity/SarBussionessStandEOPage.java @@ -156,6 +156,114 @@ public class SarBussionessStandEOPage extends BasePage { private String XCSJBUSS; private String BARQ; private String XGD; + private String LLCS; + private String CS; + private String CYCVPPSBMBUSS; + private String CYCVPPSCNBUSS; + private String KCVPPSBMBUSS; + private String KCVPPSCNBUSS; + private String DYBXHBUSS; + private String DYMCBUSS; + private String YYBZ; + private String CBCD; + private String CYCD; + private String CYBZ; + + public String getLLCS() { + return LLCS; + } + + public void setLLCS(String LLCS) { + this.LLCS = LLCS; + } + + public String getCS() { + return CS; + } + + public void setCS(String CS) { + this.CS = CS; + } + + public String getCYCVPPSBMBUSS() { + return CYCVPPSBMBUSS; + } + + public void setCYCVPPSBMBUSS(String CYCVPPSBMBUSS) { + this.CYCVPPSBMBUSS = CYCVPPSBMBUSS; + } + + public String getCYCVPPSCNBUSS() { + return CYCVPPSCNBUSS; + } + + public void setCYCVPPSCNBUSS(String CYCVPPSCNBUSS) { + this.CYCVPPSCNBUSS = CYCVPPSCNBUSS; + } + + public String getKCVPPSBMBUSS() { + return KCVPPSBMBUSS; + } + + public void setKCVPPSBMBUSS(String KCVPPSBMBUSS) { + this.KCVPPSBMBUSS = KCVPPSBMBUSS; + } + + public String getKCVPPSCNBUSS() { + return KCVPPSCNBUSS; + } + + public void setKCVPPSCNBUSS(String KCVPPSCNBUSS) { + this.KCVPPSCNBUSS = KCVPPSCNBUSS; + } + + public String getDYBXHBUSS() { + return DYBXHBUSS; + } + + public void setDYBXHBUSS(String DYBXHBUSS) { + this.DYBXHBUSS = DYBXHBUSS; + } + + public String getDYMCBUSS() { + return DYMCBUSS; + } + + public void setDYMCBUSS(String DYMCBUSS) { + this.DYMCBUSS = DYMCBUSS; + } + + public String getYYBZ() { + return YYBZ; + } + + public void setYYBZ(String YYBZ) { + this.YYBZ = YYBZ; + } + + public String getCBCD() { + return CBCD; + } + + public void setCBCD(String CBCD) { + this.CBCD = CBCD; + } + + public String getCYCD() { + return CYCD; + } + + public void setCYCD(String CYCD) { + this.CYCD = CYCD; + } + + public String getCYBZ() { + return CYBZ; + } + + public void setCYBZ(String CYBZ) { + this.CYBZ = CYBZ; + } public String getBARQ() { return BARQ; diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/impl/SarStandardsInfoServiceImpl.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/impl/SarStandardsInfoServiceImpl.java index 5adc11b2..7091d233 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/impl/SarStandardsInfoServiceImpl.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/impl/SarStandardsInfoServiceImpl.java @@ -1187,6 +1187,8 @@ public class SarStandardsInfoServiceImpl extends ServiceImpl 3) { - sort = sarStandardsSelectEO.getStandNumber().substring(0, 3); - } - if ("ECE".equals(sort)) { - int length = sarStandardsSelectEO.getStandNumber().length(); - String number = sarStandardsSelectEO.getStandNumber().substring(3, length); - sarStandardsSelectEO.setStandNumber("UN(ECE)" + number); - } - } +// if (StringUtils.isNotBlank(sarStandardsSelectEO.getStandNumber())) { +// String sort = ""; +// if (sarStandardsSelectEO.getStandNumber().length() > 3) { +// sort = sarStandardsSelectEO.getStandNumber().substring(0, 3); +// } +// if ("ECE".equals(sort)) { +// int length = sarStandardsSelectEO.getStandNumber().length(); +// String number = sarStandardsSelectEO.getStandNumber().substring(3, length); +// sarStandardsSelectEO.setStandNumber("UN(ECE)" + number); +// } +// } List result = dao.selectStandardsByStandnumber(sarStandardsSelectEO); if (result != null && result.size() > 0) { String standId = result.get(0).getId(); @@ -1576,6 +1578,10 @@ public class SarStandardsInfoServiceImpl extends ServiceImplbuss_stand_id, id, valid_flag, + tree_type, #{menuId, jdbcType=VARCHAR}, #{bussStandId, jdbcType=VARCHAR}, #{id, jdbcType=VARCHAR}, #{validFlag, jdbcType=INTEGER}, + #{treeType, jdbcType=INTEGER}, @@ -161,10 +163,15 @@ diff --git a/adc-da-slrs/src/main/resources/mybatis/mapper/sarBussionessStand/SarBussionessStandMapper.xml b/adc-da-slrs/src/main/resources/mybatis/mapper/sarBussionessStand/SarBussionessStandMapper.xml index c8e9c909..bd61bf27 100644 --- a/adc-da-slrs/src/main/resources/mybatis/mapper/sarBussionessStand/SarBussionessStandMapper.xml +++ b/adc-da-slrs/src/main/resources/mybatis/mapper/sarBussionessStand/SarBussionessStandMapper.xml @@ -375,7 +375,7 @@ FROM sar_bussioness_stand WHERE stand_sort = 'Q/QCBFC' AND ISSUE_TIME IS NOT NULL - AND DATE_FORMAT(DATE_SUB(DATE_ADD(ISSUE_TIME, INTERVAL 5 YEAR),INTERVAL 1 MONTH),'%Y-%m-%d') + AND DATE_FORMAT(DATE_SUB(DATE_ADD(ISSUE_TIME, INTERVAL 3 YEAR),INTERVAL 1 MONTH),'%Y-%m-%d') BETWEEN DATE_FORMAT(#{issueTimeStart}, '%Y-%m-%d') AND DATE_ADD(DATE_FORMAT(#{issueTimeEnd}, '%Y-%m-%d'),INTERVAL 1 DAY) UNION SELECT @@ -384,7 +384,7 @@ FROM sar_bussioness_stand WHERE stand_sort != 'Q/QCBFC' AND ISSUE_TIME IS NOT NULL - AND DATE_FORMAT(DATE_SUB(DATE_ADD(ISSUE_TIME, INTERVAL 3 YEAR),INTERVAL 1 MONTH),'%Y-%m-%d') + AND DATE_FORMAT(DATE_SUB(DATE_ADD(ISSUE_TIME, INTERVAL 5 YEAR),INTERVAL 1 MONTH),'%Y-%m-%d') BETWEEN DATE_FORMAT(#{issueTimeStart}, '%Y-%m-%d') AND DATE_ADD(DATE_FORMAT(#{issueTimeEnd}, '%Y-%m-%d'),INTERVAL 1 DAY)