Merge remote-tracking branch 'origin/develop_master' into develop_master

This commit is contained in:
yuezhihang
2022-02-24 17:55:28 +08:00
10 changed files with 221 additions and 60 deletions
@@ -38,8 +38,8 @@ public class ActSarItemsBussEOController extends BaseController<ActSarItemsEO> {
@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不能为空");
}
@@ -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<String,Object> 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<String,Object> addAttInfoMap,Map<String,Object> oldAttInfoMap){
@@ -50,6 +50,7 @@ public class SarBussStandMenuController extends BaseController<SarBussStandMenu>
SarBussStandMenu menuEO = new SarBussStandMenu();
menuEO.setBussStandId(id);
menuEO.setMenuId(standardsInfoEO.getMenuId());
menuEO.setTreeType(standardsInfoEO.getTreeType());
//删除所选目录下关联
String oldMenuId = standardsInfoEO.getOldMenuId();
if (StringUtils.isEmpty(oldMenuId)) {
@@ -404,6 +404,13 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
}
public void attrInfoShowExport (List<SarBussionessStand> sarlist) throws Exception {
//查询字典表,形成Hash映射提升速度
List<DicTypeEO> dicInfo = dicTypeEODao.getDicInfo("dic_type_code", "dic_type_name");
Map<String, String> 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<String, Object> getAttrMap = row.getAttrInfoMap();
@@ -424,16 +431,17 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
value = String.valueOf(getAttrMap.get("SVPPSName"));
entry.setValue(value);
} else if (entry.getValue() != null && InitStandAttrUtil.fileFieldListBuss != null && InitStandAttrUtil.fileFieldListBuss.size() > 0 && InitStandAttrUtil.fileFieldListBuss.contains(name)) {
value = entry.getValue().toString();
if (StringUtils.isNotBlank(value)) {
List<AttFileEO> fileObj = attFileEOService.getMultiFileInfos(value);
entry.setValue(fileObj);
}
// value = entry.getValue().toString();
// if (StringUtils.isNotBlank(value)) {
// List<AttFileEO> 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<SarBussionessStan
}
} else {
List<String> 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<SarBussionessStan
sarStandMenuEO.setBussStandId(standId);
sarStandMenuEO.setId(null);
sarStandMenuEO.setValidFlag(0);
sarStandMenuEO.setTreeType("sarMs");
// 根据当前目录查询所在父节点
String secondLevelId = "";
List<String> 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<SarBussionessStan
}
//查询标准是否已在 当前父节点中
SarBussStandMenu standMenuEOQuery = new SarBussStandMenu();
standMenuEOQuery.setMenuId(secondLevelId);
standMenuEOQuery.setBussStandId(standardsInfoEO.getIdlist()[i]);
List<String> 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<SarBussStandMenu> getInfo = sarBussStandMenuEODao.selectMenuByMenuParentId(standMenuEOQuery);
//删除节点与根节点的关联
SarBussStandMenu sarStandMenuDel = new SarBussStandMenu();
@@ -925,27 +949,32 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
int op = 0;
if (getInfo == null || getInfo.isEmpty()) {
sarStandMenuEO.setId(UUIDUtils.randomUUID20());
op = sarBussStandMenuEODao.insert(sarStandMenuEO);
op = sarBussStandMenuEODao.insertSelective(sarStandMenuEO);
} else {
sarStandMenuEO.setOldMenuId(secondLevelId);
List<String> 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<SarBussStandAttrInfo> 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<SarBussStandAttrInfo> 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);
}
@@ -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<SarBussionessStand> standList = sarBussionessStandDao.queryByBussStateSync(stand);
if(!standList.isEmpty()){
List<SarBussionessStandState> filterList = new ArrayList<>();
@@ -85,7 +91,7 @@ public class StateSync {
List<SarBussionessStandState> updList = new ArrayList<>();
QueryWrapper wrapper = new QueryWrapper();
wrapper.isNull("REVIEW_RESULTS");
wrapper.between("REVIEW_TIME",nowFirst,nowFinByQuery);
wrapper.between("REVIEW_TIME",nextFirst,nextFinByQuery);
List<SarBussionessStandState> 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
@@ -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;
@@ -1187,6 +1187,8 @@ public class SarStandardsInfoServiceImpl extends ServiceImpl<SarStandardsInfoDao
newCiteStand = sarStandardsInfoEO.getRelateStand();
} else if ("DTBJH".equals(upField)) {
newCiteStand = sarStandardsInfoEO.getReplaceStandNum();
}else if ("DTBZH".equals(upField)) {
newCiteStand = sarStandardsInfoEO.getReplaceStandNum();
}else if ("BFDTBZ".equals(upField)) {
newCiteStand = sarStandardsInfoEO.getReplacePartStandNum();
}
@@ -1195,17 +1197,17 @@ public class SarStandardsInfoServiceImpl extends ServiceImpl<SarStandardsInfoDao
String nowEOrepNums[] = newCiteStand.split(",");
for (String citeStand : nowEOrepNums) {
sarStandardsSelectEO.setStandNumber(citeStand);
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);
}
}
// 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<SarStandardsInfo> result = dao.selectStandardsByStandnumber(sarStandardsSelectEO);
if (result != null && result.size() > 0) {
String standId = result.get(0).getId();
@@ -1576,6 +1578,10 @@ public class SarStandardsInfoServiceImpl extends ServiceImpl<SarStandardsInfoDao
// updateReplacedNumber(sarStandardsInfoEO,beforeSarStandardsInfo);
// 根据引用标准修改其他被引用标准
updateCiteStand(sarStandardsInfoEO, null, "YYBJ", "BYYBJ");
/**
* 新增代替标准号修改其他被代替标准号
*/
updateCiteStand(sarStandardsInfoEO, null, "DTBZH", "BDTBZH");
updateCiteStand(sarStandardsInfoEO, null, "BFDTBZ", "BBFDTBZ");
// 根据对应其他标准修改其他对应其他标准
// updateRelateStand(sarStandardsInfoEO, "CBBH");
@@ -107,11 +107,13 @@ public class BussStandExportUtil {
break;
case "标准实施日期":
String putTime="";
if (Date.class.equals(sarStandardsInfoEO.getPutTime())) {
putTime = sdf.format(sarStandardsInfoEO.getPutTime());
if(sarStandardsInfoEO.getPutTime() != null){
if (Date.class.equals(sarStandardsInfoEO.getPutTime())) {
putTime = sdf.format(sarStandardsInfoEO.getPutTime());
}else {
putTime=sarStandardsInfoEO.getPutTime();
}else {
putTime=sarStandardsInfoEO.getPutTime();
}
}
value = putTime;
break;
@@ -123,10 +125,12 @@ public class BussStandExportUtil {
break;
case "发布日期":
String issueTime="";
if (Date.class.equals(sarStandardsInfoEO.getIssueTime().getClass())){
issueTime = sdf.format(sarStandardsInfoEO.getIssueTime());
}else {
issueTime=sarStandardsInfoEO.getIssueTime();
if(sarStandardsInfoEO.getIssueTime() != null){
if (Date.class.equals(sarStandardsInfoEO.getIssueTime().getClass())){
issueTime = sdf.format(sarStandardsInfoEO.getIssueTime());
}else {
issueTime=sarStandardsInfoEO.getIssueTime();
}
}
value = issueTime;
break;
@@ -53,12 +53,14 @@
<if test="bussStandId != null" >buss_stand_id,</if>
<if test="id != null" >id,</if>
<if test="validFlag != null" >valid_flag,</if>
<if test="treeType != null" >tree_type,</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides="," >
<if test="menuId != null" >#{menuId, jdbcType=VARCHAR},</if>
<if test="bussStandId != null" >#{bussStandId, jdbcType=VARCHAR},</if>
<if test="id != null" >#{id, jdbcType=VARCHAR},</if>
<if test="validFlag != null" >#{validFlag, jdbcType=INTEGER},</if>
<if test="treeType != null" >#{treeType, jdbcType=INTEGER},</if>
</trim>
</insert>
@@ -161,10 +163,15 @@
<select id="selectMenuByMenuParentId" resultMap="BaseResultMap" parameterType="com.adc.da.slrs.sarBussStandMenu.entity.SarBussStandMenu">
select <include refid="Base_Column_List"/> from SAR_BUSS_STAND_MENU
where buss_stand_id = #{bussStandId} and valid_flag=0
and MENU_ID in
<foreach collection="menuIds" index="index" item="item" open="(" separator="," close=")">
#{item}
</foreach>
<if test="treeType != null and treeType != ''">
and TREE_TYPE = #{treeType}
</if>
<if test="menuIds != null and menuIds.size !=0">
and MENU_ID in
<foreach collection="menuIds" index="index" item="item" open="(" separator="," close=")">
#{item}
</foreach>
</if>
</select>
<update id="updateByStandIdAndMenuId" parameterType="com.adc.da.slrs.sarBussStandMenu.entity.SarBussStandMenu" >
@@ -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)
</select>