From 8ddd3598294d576c400798ec0b838e6e85526479 Mon Sep 17 00:00:00 2001 From: SUNJIABIN Date: Thu, 1 Jun 2023 13:59:50 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E5=9B=BD=E5=86=85=E5=A4=96?= =?UTF-8?q?=E5=92=8C=E4=BC=81=E4=B8=9A=E6=A0=87=E5=87=86=E6=9B=B4=E6=96=B0?= =?UTF-8?q?=E6=96=87=E6=9C=AC=E7=8A=B6=E6=80=81=E7=9A=84=E5=AE=9A=E6=97=B6?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dao/SarBussionessStandDao.java | 3 + .../sync/StateSync.java | 112 ++++++++++++++++++ 2 files changed, 115 insertions(+) diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/dao/SarBussionessStandDao.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/dao/SarBussionessStandDao.java index 851d0b52..65b42273 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/dao/SarBussionessStandDao.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/dao/SarBussionessStandDao.java @@ -133,5 +133,8 @@ public interface SarBussionessStandDao extends BaseMapper { String selectByStandCode(String standCode); SarBussionessStand selectByReplaceStandNum(String standCode); + + @Select("select * from sar_bussioness_stand where TEXT_STATUS_BUSS is not null") + List selectAllStandStatus(); } 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 466a6ae8..20f965d6 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 @@ -4,10 +4,17 @@ import com.adc.da.slrs.sarBussionessStand.dao.SarBussionessStandDao; import com.adc.da.slrs.sarBussionessStand.entity.SarBussionessStand; import com.adc.da.slrs.sarBussionessStandState.entity.SarBussionessStandState; import com.adc.da.slrs.sarBussionessStandState.service.ISarBussionessStandStateService; +import com.adc.da.slrs.sarStandAttrInfo.dao.SarStandAttrInfoDao; +import com.adc.da.slrs.sarStandAttrInfo.entity.SarStandAttrInfo; +import com.adc.da.slrs.sarStandardsInfo.dao.SarStandardsInfoDao; +import com.adc.da.slrs.sarStandardsInfo.entity.SarStandardsInfo; +import com.adc.da.slrs.sarUpdLog.service.ISarUpdLogService; import com.adc.da.util.DateUtils; import com.adc.da.utils.util.DateUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.ObjectUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; @@ -37,6 +44,15 @@ public class StateSync { @Autowired private ISarBussionessStandStateService bussionessStandStateService; + @Autowired + private SarStandardsInfoDao sarStandardsInfoDao; + + @Autowired + private SarStandAttrInfoDao sarStandAttrInfoEODao; + + @Autowired + private ISarUpdLogService sarUpdLogEOService; + /** * 根据配置文件设置是否开启定时器 */ @@ -270,4 +286,100 @@ public class StateSync { return false; } + + /** + * 企业标准更新文本状态定时器 + */ + @Scheduled(cron = "0 0 5 * * ?") //每天早晨五点执行 + public void timeSarBussionessStand(){ + if (isNotScheduled){ + logger.info("开始执行企业标准更新文本状态定时器"); + List list = sarBussionessStandDao.selectAllStandStatus(); + if (ObjectUtils.isNotEmpty(list) && list != null){ + for (SarBussionessStand sarBussionessStand : list){ + if (StringUtils.isNotBlank(sarBussionessStand.getReplaceStandNum()) && sarBussionessStand != null){ + SarBussionessStand sarBussionessStand2 = sarBussionessStandDao.selectByReplaceStandNum(sarBussionessStand.getReplaceStandNum()); + //9z741h2m3j 有效，3lqnlgmgcn 作废 + if (sarBussionessStand2 != null && (sarBussionessStand.getTextStatusBuss().equals("9z741h2m3j")|| sarBussionessStand.getTextStatusBuss().equals("3lqnlgmgcn"))){ + sarBussionessStand2.setTextStatusBuss("3lqnlgmgcn"); + sarBussionessStandDao.updateById(sarBussionessStand2); + logger.info("修改企业标准文本状态完成，修改的企业标准id为：" + sarBussionessStand2.getId() + ",企标名称为：" + sarBussionessStand2.getStandName() + ",企标编号为：" + sarBussionessStand2.getStandCode()); + } + } + } + } + } + } + + /** + * 国内外标准更新文本状态定时器 + */ + @Scheduled(cron = "0 0 5 * * ?") //每天早晨五点执行 + public void timeSarStandardsInfo()throws Exception{ + if (isNotScheduled){ + logger.info("开始执行国内外标准更新文本状态定时器"); + List sarStandardsInfoEOs = sarStandardsInfoDao.getSarStandardsInfo(); + if (ObjectUtils.isNotEmpty(sarStandardsInfoEOs) && sarStandardsInfoEOs != null) { + for (SarStandardsInfo sarStandardsInfoEO : sarStandardsInfoEOs) { + if (sarStandardsInfoEO != null && ObjectUtils.isNotEmpty(sarStandardsInfoEO)) { + SarStandAttrInfo sarStandAttrInfo = sarStandAttrInfoEODao.getSarStandAttrInfo(sarStandardsInfoEO.getId()); + if (sarStandAttrInfo != null && ObjectUtils.isNotEmpty(sarStandAttrInfo)){ + sarStandardsInfoEO.setReplacedStandNum(sarStandAttrInfo.getDtbjh()); + } + + if (org.apache.commons.lang3.StringUtils.isNotBlank(sarStandardsInfoEO.getReplaceStandNum())){ + sarStandardsInfoDao.updateById(sarStandardsInfoEO); + String id = sarStandardsInfoEO.getId(); + List sarStandardsInfos = sarStandardsInfoDao.selectBy(id); + if (ObjectUtils.isNotEmpty(sarStandardsInfos) && sarStandardsInfos != null){ + for (SarStandardsInfo sarStandardsInfo:sarStandardsInfos){ + if (sarStandardsInfo != null && sarStandardsInfo.getStandSort().equals("GB") && (sarStandardsInfoEO.getTextStatus().equals("vsaga7nwub") || sarStandardsInfoEO.getTextStatus().equals("chblaarg77") || sarStandardsInfoEO.getTextStatus().equals("qke0ckro2p"))){ + String textStatus = "chblaarg77"; + sarStandardsInfo.setTextStatus(textStatus); + sarStandardsInfoDao.updateById(sarStandardsInfo); + logger.info("原标准号："+ sarStandardsInfoEO.getReplaceStandNum() +"被代替标准号变更成废止状态"); + + String content = "标准号："+ sarStandardsInfoEO.getReplaceStandNum() +"被代替标准号变更成废止状态"; + sarUpdLogEOService.createBaseLog(sarStandardsInfo.getId(), sarStandardsInfo.getStandType() + "_STAND", content); + }else if (sarStandardsInfo != null && (sarStandardsInfoEO.getTextStatus().equals("vsaga7nwub") || sarStandardsInfoEO.getTextStatus().equals("chblaarg77") || sarStandardsInfoEO.getTextStatus().equals("qke0ckro2p"))){ + String textStatus = "qke0ckro2p"; + sarStandardsInfo.setTextStatus(textStatus); + sarStandardsInfoDao.updateById(sarStandardsInfo); + logger.info("原标准号："+ sarStandardsInfoEO.getReplaceStandNum() +"被代替标准号变更成被代替状态"); + + String content = "标准号："+ sarStandardsInfoEO.getReplaceStandNum() +"被代替标准号变更成被代替状态"; + sarUpdLogEOService.createBaseLog(sarStandardsInfo.getId(), sarStandardsInfo.getStandType() + "_STAND", content); + } + } + } + + + List sarStandardsInfo1s = sarStandardsInfoDao.selectBy1(id); + if (ObjectUtils.isNotEmpty(sarStandardsInfo1s) && sarStandardsInfo1s != null){ + for (SarStandardsInfo sarStandardsInfo1 : sarStandardsInfo1s){ + if (sarStandardsInfo1 != null && sarStandardsInfo1.getStandSort().equals("GB") && (sarStandardsInfoEO.getTextStatus().equals("vsaga7nwub") || sarStandardsInfoEO.getTextStatus().equals("chblaarg77") || sarStandardsInfoEO.getTextStatus().equals("qke0ckro2p"))){ + String textStatus = "chblaarg77"; + sarStandardsInfo1.setTextStatus(textStatus); + sarStandardsInfoDao.updateById(sarStandardsInfo1); + logger.info("原标准号："+ sarStandardsInfoEO.getReplaceStandNum() +"被代替标准号变更成废止状态"); + + String content = "标准号："+ sarStandardsInfoEO.getReplaceStandNum() +"被代替标准号变更成废止状态"; + sarUpdLogEOService.createBaseLog(sarStandardsInfo1.getId(), sarStandardsInfo1.getStandType() + "_STAND", content); + }else if (sarStandardsInfo1 != null && (sarStandardsInfoEO.getTextStatus().equals("vsaga7nwub") || sarStandardsInfoEO.getTextStatus().equals("chblaarg77") || sarStandardsInfoEO.getTextStatus().equals("qke0ckro2p"))){ + String textStatus = "qke0ckro2p"; + sarStandardsInfo1.setTextStatus(textStatus); + sarStandardsInfoDao.updateById(sarStandardsInfo1); + logger.info("原标准号："+ sarStandardsInfoEO.getReplaceStandNum() +"被代替标准号变更成被代替状态"); + + String content = "标准号："+ sarStandardsInfoEO.getReplaceStandNum() +"被代替标准号变更成被代替状态"; + sarUpdLogEOService.createBaseLog(sarStandardsInfo1.getId(), sarStandardsInfo1.getStandType() + "_STAND", content); + } + } + } + } + } + } + } + } + } }