From 0612cb210a0498d00cc505dfe91e3139fc1fca8f Mon Sep 17 00:00:00 2001 From: "zhaokaiyao@91isoft.com" <6922339zky> Date: Wed, 19 Jan 2022 15:14:43 +0800 Subject: [PATCH 1/4] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=20VALI?= =?UTF-8?q?D=5FFLAG=3D'0'?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/adc/da/scheduled/ScheduledJob.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java b/adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java index 8c776893..f11f49ca 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java +++ b/adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java @@ -227,7 +227,8 @@ public class ScheduledJob { */ QueryWrapper columnForDTBJH = new QueryWrapper<>(); - columnForDTBJH.select("DTBJH"); + columnForDTBJH.select("DTBJH") + .eq("VALID_FLAG","0"); //查询代替标准字段得到一个 被代替了的标准的id的键值对列表 List> replaceStandIdMaps = sarStandAttrInfoDao.selectMaps(columnForDTBJH); HashMap replaceIdCountMap = new HashMap<>(); From d49893bdf101cce16c071c495040229be04ebd0e Mon Sep 17 00:00:00 2001 From: "zhaokaiyao@91isoft.com" <6922339zky> Date: Wed, 19 Jan 2022 17:46:23 +0800 Subject: [PATCH 2/4] =?UTF-8?q?=E4=B8=BA=E5=AE=9A=E6=97=B6=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E5=8A=A0=E4=B8=8A=E4=BA=86=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/adc/da/scheduled/ScheduledJob.java | 54 ++++++++++++++++--- .../service/impl/SarUpdLogServiceImpl.java | 2 + 2 files changed, 49 insertions(+), 7 deletions(-) diff --git a/adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java b/adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java index f11f49ca..46aec11b 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java +++ b/adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java @@ -20,6 +20,8 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import lombok.extern.slf4j.Slf4j; +import net.sf.json.JSONObject; +import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.BeanUtils; @@ -228,10 +230,13 @@ public class ScheduledJob { QueryWrapper columnForDTBJH = new QueryWrapper<>(); columnForDTBJH.select("DTBJH") - .eq("VALID_FLAG","0"); + .eq("VALID_FLAG","0") + .ne("DTBJH",""); //查询代替标准字段得到一个 被代替了的标准的id的键值对列表 - List> replaceStandIdMaps = sarStandAttrInfoDao.selectMaps(columnForDTBJH); + List> replaceStandIdMaps = sarStandAttrInfoDao.selectMaps(columnForDTBJH).subList(0,100); HashMap replaceIdCountMap = new HashMap<>(); + + // 格式为 T/CSAE 175-2021 /** * 国内外表准号格式不统一 @@ -287,22 +292,37 @@ public class ScheduledJob { //一个被代替标准号时,文本状态更新为废止状态,两个及以上时更新为被代替状态 - SarStandardsInfo sarStandardsInfo = new SarStandardsInfo(); for (String key : replaceIdCountMap.keySet()) { + SarStandardsInfo sarStandardsInfo = new SarStandardsInfo(); + String reasonMsg=""; switch (replaceIdCountMap.get(key)){ case 1 : - sarStandardsInfo.setTextStatus("chblaarg77");//废止状态 + //废止状态 + sarStandardsInfo.setTextStatus("chblaarg77"); sarStandardsInfo.setId(key); + reasonMsg="该标准被一个标准代替"; break; - default : - sarStandardsInfo.setTextStatus("qke0ckro2p");//被代替状态 + case 2 : + //被代替状态 + sarStandardsInfo.setTextStatus("qke0ckro2p"); sarStandardsInfo.setId(key); + reasonMsg="该标准被一个以上标准代替"; + break; + default: break; } try { -// sarUpdLogEOService.createUpdateLog(sarStandardsInfoEO.getStandType() + "_STAND", sarStandardsInfoEO.getId(), oldMap, newMap, content); + //更新日志 + SarStandardsInfo beforeSarStandardsInfoEO = sarStandardsInfoDao.selectById(sarStandardsInfo.getId()); + sarStandardsInfo.setStandType(beforeSarStandardsInfoEO.getStandType()); + sarStandardsInfo.setStandSort(beforeSarStandardsInfoEO.getStandSort()); + sarStandardsInfo.setStandNumber(beforeSarStandardsInfoEO.getStandNumber()); + sarStandardsInfo.setStandYear(beforeSarStandardsInfoEO.getStandYear()); + sarStandardsInfo.setStandName(beforeSarStandardsInfoEO.getStandName()); + saveUpdateLog(sarStandardsInfo,beforeSarStandardsInfoEO,reasonMsg); + //更新日志 sarStandardsInfoDao.updateById(sarStandardsInfo); }catch (Exception e){ System.out.println("代替标准状态更新:id为"+key+"文本状态更新失败"); @@ -312,4 +332,24 @@ public class ScheduledJob { logger.info("==================================更新文本状态结束======================================"); } + + + + public void saveUpdateLog(SarStandardsInfo sarStandardsInfoEO, SarStandardsInfo beforeSarStandardsInfo,String reasonMsg) throws Exception { + Map newMap = new HashMap<>(); + Map oldMap = new HashMap<>(); + String attrStr = sarStandardsInfoEO.getSarStandAttrEOStr(); + if (StringUtils.isNotBlank(attrStr)) { + newMap = JSONObject.fromObject(attrStr); + } + newMap.put("textStatus",sarStandardsInfoEO.getTextStatus()); + oldMap.put("textStatus",beforeSarStandardsInfo.getTextStatus()); + // 增加关联事件 + String number = sarStandardsInfoEO.getStandSort() + " " + sarStandardsInfoEO.getStandNumber(); + if (StringUtils.isNotBlank(sarStandardsInfoEO.getStandYear())) { + number += "-" + sarStandardsInfoEO.getStandYear(); + } + String content ="==定时任务执行修改==:" + number + " 《" + sarStandardsInfoEO.getStandName() + "》"+reasonMsg; + sarUpdLogEOService.createUpdateLog(sarStandardsInfoEO.getStandType() + "_STAND", sarStandardsInfoEO.getId(), oldMap, newMap, content); + } } diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarUpdLog/service/impl/SarUpdLogServiceImpl.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarUpdLog/service/impl/SarUpdLogServiceImpl.java index 2bf7bade..33a432fb 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarUpdLog/service/impl/SarUpdLogServiceImpl.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarUpdLog/service/impl/SarUpdLogServiceImpl.java @@ -135,6 +135,7 @@ public class SarUpdLogServiceImpl extends ServiceImpl i selectFieldMap.put("standSort","STANDCLASSIFY"); selectFieldMap.put("standState","STANDSTATE"); selectFieldMap.put("standNature","STANDNATURE"); + selectFieldMap.put("textStatus","TEXTSTATUS"); } else if (SarTypeEnum.INLAND_LAWS.getValue().equals(sarType) || SarTypeEnum.FOREIGN_LAWS.getValue().equals(sarType)) { selectFieldMap = InitStandAttrUtil.selectFieldMapLaws; selectFieldMap.put("isRelateAccess","SHIFOUGL"); @@ -199,6 +200,7 @@ public class SarUpdLogServiceImpl extends ServiceImpl i public String changeStandName (String field,String sarType) throws Exception{ switch (field) { + case "textStatus":return "文本状态"; case "country": return "适用区域"; case "isRelateAccess": return "重要度"; case "issueTime": return "发布日期"; From a2b38c85d37d2e6cc98472dca293af8c18edd1c1 Mon Sep 17 00:00:00 2001 From: yuezhihang Date: Wed, 19 Jan 2022 18:23:10 +0800 Subject: [PATCH 3/4] =?UTF-8?q?=E8=B0=83=E7=A0=94=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../adc/da/slrs/sarUser/controller/TsUserController.java | 7 ++++--- .../main/java/com/adc/da/slrs/sarUser/dao/TsUserDao.java | 2 ++ .../resources/mybatis/mapper/sarUser/TsUserMapper.xml | 9 +++++++++ 3 files changed, 15 insertions(+), 3 deletions(-) diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarUser/controller/TsUserController.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarUser/controller/TsUserController.java index 118e43d2..09e8d111 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarUser/controller/TsUserController.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarUser/controller/TsUserController.java @@ -24,6 +24,8 @@ import io.swagger.annotations.Api; import com.adc.da.base.web.BaseController; import javax.validation.Valid; +import java.util.ArrayList; +import java.util.Arrays; import java.util.List; /** @@ -100,9 +102,8 @@ public class TsUserController extends BaseController { @ApiOperation("调研流程查询人 部门专用接口") @GetMapping("/selectDeptByDY") public ResponseMessage> selectDeptByDY(@Param("ids") String ids) throws Exception { - QueryWrapper queryWrapper=new QueryWrapper<>(); - queryWrapper.in("USID",ids.split(",")); - return Result.success(tsUserService.list(queryWrapper)); + List strings=new ArrayList<>(Arrays.asList(ids.split(","))); + return Result.success(tsUserDao.selectDeptByDY(strings)); } diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarUser/dao/TsUserDao.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarUser/dao/TsUserDao.java index 9f231fe6..d3a8ad84 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarUser/dao/TsUserDao.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarUser/dao/TsUserDao.java @@ -56,4 +56,6 @@ public interface TsUserDao extends BaseMapper { * @return List */ List getUserIdsByPositionIds(List positionIds); + + List selectDeptByDY(@Param("list") List strings); } diff --git a/adc-da-slrs/src/main/resources/mybatis/mapper/sarUser/TsUserMapper.xml b/adc-da-slrs/src/main/resources/mybatis/mapper/sarUser/TsUserMapper.xml index b5e3c5f8..47413212 100644 --- a/adc-da-slrs/src/main/resources/mybatis/mapper/sarUser/TsUserMapper.xml +++ b/adc-da-slrs/src/main/resources/mybatis/mapper/sarUser/TsUserMapper.xml @@ -75,4 +75,13 @@ ) + + From ebe6cd5bf70d40841446303957705db213f314ed Mon Sep 17 00:00:00 2001 From: "zhaokaiyao@91isoft.com" <6922339zky> Date: Wed, 19 Jan 2022 19:29:40 +0800 Subject: [PATCH 4/4] =?UTF-8?q?=E7=BC=96=E8=BE=91=E5=88=A4=E6=96=AD?= =?UTF-8?q?=E4=B8=8D=E8=83=BD=E9=87=8D=E5=A4=8D=E6=97=B6=E6=8E=92=E9=99=A4?= =?UTF-8?q?=E8=87=AA=E8=BA=AB=20=E8=A7=84=E8=8C=83=E4=BA=86=E8=BF=94?= =?UTF-8?q?=E5=9B=9E=E5=80=BC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/WorkGroupController.java | 41 ++++++++++++------- 1 file changed, 26 insertions(+), 15 deletions(-) diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/customWorkGroup/controller/WorkGroupController.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/customWorkGroup/controller/WorkGroupController.java index dfeab7da..7685ce67 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/customWorkGroup/controller/WorkGroupController.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/customWorkGroup/controller/WorkGroupController.java @@ -8,6 +8,7 @@ import com.adc.da.slrs.customWorkGroup.service.IWorkGroupService; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import io.swagger.annotations.ApiModelProperty; +import org.apache.commons.codec.language.Nysiis; import org.apache.ibatis.annotations.Delete; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @@ -37,18 +38,21 @@ public class WorkGroupController extends BaseController { @ApiModelProperty("新增工作组") @PostMapping public ResponseMessage addWorkGroup(WorkGroup workGroup) { - String meg=""; - if (isDistinct(workGroup.getWorkGroup())){ + ResponseMessage result = Result.success(); + + if (isDistinct(workGroup.getWorkGroup(),null)){ if (iWorkGroupService.add(workGroup)){ - meg="新增成功!"; + result=Result.success("200","新增成功"); }else { - meg="新增失败!"; + result=Result.error("201","新增失败"); + } }else { - meg="组名已存在!"; + result=Result.error("202","组名已存在"); + } - return Result.success("200",meg); + return result; } @@ -72,32 +76,39 @@ public class WorkGroupController extends BaseController { @ApiModelProperty("修改工作组") @PutMapping public ResponseMessage updateWorkGroup(WorkGroup workGroup){ - String meg=""; - if (isDistinct(workGroup.getWorkGroup())){ + + ResponseMessage result = Result.success(); + + if (isDistinct(workGroup.getWorkGroup(),workGroup.getId())){ if (iWorkGroupService.update(workGroup)){ - meg="修改成功!"; + result=Result.success("200", "修改成功"); }else { - meg="修改失败"; + result=Result.error("201", "修改失败"); } }else { - meg="组名已存在!"; + result=Result.error("202", "组名已存在"); } - return Result.success("200",meg); + return result; } /** * 判断提交的工作组名称是否重复 - * @param groupName - * @return true 没有重复 false 有重复 + * @param groupName 条件 + * @param id 排除id + * @returntrue 没有重复 false 有重复 */ - private boolean isDistinct(String groupName){ + private boolean isDistinct(String groupName,String id){ QueryWrapper ew = new QueryWrapper<>(); ew.eq("work_group_name",groupName); + if (id!=null){ + ew.ne("id",id); + } + List list = iWorkGroupService.list(ew); return list.isEmpty(); }