新增国内外和企业标准更新文本状态的定时任务

adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/dao/SarBussionessStandDao.java

@@ -133,5 +133,8 @@ public interface SarBussionessStandDao extends BaseMapper<SarBussionessStand> {
     String selectByStandCode(String standCode);
 
     SarBussionessStand selectByReplaceStandNum(String standCode);
+
+    @Select("select * from sar_bussioness_stand where TEXT_STATUS_BUSS is not null")
+    List<SarBussionessStand> selectAllStandStatus();
 }
 

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<SarBussionessStand> 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<SarStandardsInfo> 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<SarStandardsInfo> 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<SarStandardsInfo> 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);
+                                    }
+                                }
+                            }
+                        }
+                    }
+                }
+            }
+        }
+    }
 }