去除算法异常执行注解

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/executor/MeasurementExecutor.java

@@ -10,7 +10,6 @@ import com.njcn.prepare.harmonic.service.mysql.line.RMpEventDetailDService;
 import com.njcn.prepare.harmonic.service.mysql.line.RMpEventDetailService;
 import com.njcn.prepare.harmonic.service.mysql.line.RMpMonitorEvaluateDService;
 import com.njcn.prepare.harmonic.service.mysql.line.*;
-import com.njcn.prepare.harmonic.service.mysql.newalgorithm.RStatSubstationService;
 import com.yomahub.liteflow.annotation.LiteflowComponent;
 import com.yomahub.liteflow.annotation.LiteflowMethod;
 import com.yomahub.liteflow.core.NodeComponent;
@@ -54,8 +53,6 @@ public class MeasurementExecutor extends BaseExecutor {
     private final PollutionService pollutionService;
     private final RStatDevSignalDPOService rStatDevSignalDPOService;
     private final RMpDevEvaluateDetailPOService rMpDevEvaluateDetailPOService;
-    private final RStatSubstationService rStatSubstationService;
-
 
     /**
      * 算法名: 3.3.1.1-----监测点评价

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/area/RMpDevEvaluateDetailPOServiceImpl.java

@@ -107,8 +107,6 @@ public class RMpDevEvaluateDetailPOServiceImpl extends MppServiceImpl<RMpDevEval
 
     @Override
     @Transactional(rollbackFor = {Exception.class})
-    @Async("asyncExecutor")
-    @SneakyThrows
     public void devEvaluateDetail(CalculatedParam calculatedParam) {
         log.info(LocalDateTime.now()+"===>终端评价详情-日统计算法开始");
         List<RMpDevEvaluateDetailPO> rMpDevEvaluateDetailPOList = new ArrayList<>();

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/area/RMpMonitorAlarmCountMServiceImpl.java

@@ -103,7 +103,6 @@ public class RMpMonitorAlarmCountMServiceImpl extends MppServiceImpl<RMpMonitorA
 
     @Override
     @Transactional(rollbackFor = {Exception.class})
-    @Async("asyncExecutor")
     public void alarmMonth(CalculatedParam calculatedParam) {
         log.info(LocalDateTime.now()+"===>监测点指标告警月统计算法开始");
         List<String> lineIds = calculatedParam.getIdList();

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/area/RMpTargetWarnDServiceImpl.java

@@ -79,7 +79,6 @@ public class RMpTargetWarnDServiceImpl extends MppServiceImpl<RMpTargetWarnDMapp
     /*******************************************新算法***********************************************************************/
     @Override
     @Transactional(rollbackFor = {Exception.class})
-    @Async("asyncExecutor")
     public void alarmDay(CalculatedParam calculatedParam) {
         log.info(LocalDateTime.now()+"===>监测点指标告警日统计算法开始");
         List<String> lineIds = calculatedParam.getIdList();

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/device/RStatDevSignalDPOServiceImpl.java

@@ -51,8 +51,6 @@ public class RStatDevSignalDPOServiceImpl extends MppServiceImpl<RStatDevSignalD
 
     @Override
     @Transactional(rollbackFor = {Exception.class})
-    @Async("asyncExecutor")
-    @SneakyThrows
     public void devSignalD(CalculatedParam calculatedParam) {
         log.info(LocalDateTime.now()+"===>终端通信管理日统计算法开始");
         List<LineDevGetDTO> lineDevGetList = new ArrayList<>();

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/AlarmDetailServiceImpl.java

@@ -84,7 +84,6 @@ public class AlarmDetailServiceImpl extends MppServiceImpl<AlarmMapper, RMpTarge
     /*******************************************新算法***********************************************************************/
     @Override
     @Transactional(rollbackFor = {Exception.class})
-    @Async("asyncExecutor")
     public void targetDiff(CalculatedParam calculatedParam) {
         log.info(LocalDateTime.now()+"===>监测点稳态指标差值日表开始执行");
         List<String> lineIds = calculatedParam.getIdList();

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java

@@ -93,7 +93,6 @@ public class DayDataServiceImpl implements DayDataService {
 
     @Override
     @Transactional(rollbackFor = {Exception.class})
-    @Async("asyncExecutor")
     public void dataToDayHandler(CalculatedParam calculatedParam) {
         log.info(LocalDateTime.now() + "data表转day开始=====》");
         //influxdb实体

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/IntegrityServiceImpl.java

@@ -88,7 +88,6 @@ public class IntegrityServiceImpl extends MppServiceImpl<RStatIntegrityDMapper,
 
     /********************************新算法************************************************/
     @Override
-    @Async("asyncExecutor")
     public void dataIntegrity(CalculatedParam calculatedParam) {
         List<RStatIntegrityD> list = new ArrayList<>();
         List<String> lineIds = calculatedParam.getIdList();

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/LimitRateServiceImpl.java

@@ -55,7 +55,6 @@ public class LimitRateServiceImpl extends MppServiceImpl<LimitRatePOMapper, Limi
     /*********************************************新算法***********************************************************/
     @Override
     @Transactional(rollbackFor = {Exception.class})
-    @Async("asyncExecutor")
     public void limitRate(CalculatedParam calculatedParam) {
         log.info(LocalDateTime.now()+"r_stat_limit_rate_d开始执行=======》");
         List<RStatLimitRateDPO> list = new ArrayList<>();

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/LimitTargetServiceImpl.java

@@ -96,7 +96,6 @@ public class LimitTargetServiceImpl extends MppServiceImpl<RStatLimitTargetDMapp
 
     /***********************************************新算法*******************************************************************/
     @Override
-    @Async("asyncExecutor")
     public void limitTargetData(CalculatedParam calculatedParam) {
         log.info(LocalDateTime.now()+"r_stat_limit_target_d开始执行=======》");
         List<RStatLimitTargetDPO> list = new ArrayList<>();

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/RMpMonitorEvaluateDServiceImpl.java

@@ -128,7 +128,7 @@ public class RMpMonitorEvaluateDServiceImpl extends MppServiceImpl<RMpMonitorEva
                     rMpMonitorEvaluateDPO = calculateRMpMonitorEvaluateDPO(rMpMonitorEvaluateDPO, fiveItems, pmsAbnormalRules, voltage, lineDTO);
                     Date date = DateUtil.parse(beginDay);
                     DataFlicker twoFlickerData = dataIntegrityRateInfluxService.getTwoFlickerData(lineDTO.getLineId(), date, 5);
-                    LocalDate localDate = LocalDateTimeUtil.parseDate(beginDay, DatePattern.NORM_DATE_PATTERN);
+                    LocalDate localDate = LocalDateTimeUtil.parseDate(beginDay, DatePattern.NORM_DATETIME_PATTERN);
 
                     if (Objects.isNull(twoFlickerData)) {
                         rMpMonitorEvaluateDPO.setPltCount(0);

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/RMpPartHarmonicDetailDServiceImpl.java

@@ -30,7 +30,6 @@ public class RMpPartHarmonicDetailDServiceImpl extends MppServiceImpl<RMpPartHar
     /***********************************************新算法********************************************************************/
     @Override
     @Transactional(rollbackFor = {Exception.class})
-    @Async("asyncExecutor")
     public void insertHarmonicDetailDayOne(CalculatedParam calculatedParam) {
         log.info(LocalDateTime.now()+"===>监测点稳态指标超标明细日表1开始执行");
         List<String> lineIds = calculatedParam.getIdList();

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/RMpPartHarmonicDetailMServiceImpl.java

@@ -31,7 +31,6 @@ public class RMpPartHarmonicDetailMServiceImpl extends MppServiceImpl<RMpPartHar
 
     @Override
     @Transactional(rollbackFor = {Exception.class})
-    @Async("asyncExecutor")
     public void insertHarmonicDetailMonthOne(CalculatedParam calculatedParam) {
         log.info(LocalDateTime.now()+"===>监测点稳态指标超标明细月表1开始执行");
         DateTime beginMonth = DateUtil.beginOfMonth(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN));

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/RMpSurplusHarmonicDetailDServiceImpl.java

@@ -28,7 +28,6 @@ public class RMpSurplusHarmonicDetailDServiceImpl extends MppServiceImpl<RMpSurp
 
     @Override
     @Transactional(rollbackFor = {Exception.class})
-    @Async("asyncExecutor")
     public void insertHarmonicDetailDayTwo(CalculatedParam calculatedParam) {
         log.info(LocalDateTime.now()+"===>监测点稳态指标超标明细日表2开始执行");
         List<String> lineIds = calculatedParam.getIdList();

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/RMpSurplusHarmonicDetailMServiceImpl.java

@@ -31,7 +31,6 @@ public class RMpSurplusHarmonicDetailMServiceImpl extends MppServiceImpl<RMpSurp
 
     @Override
     @Transactional(rollbackFor = {Exception.class})
-    @Async("asyncExecutor")
     public void insertHarmonicDetailMonthTwo(CalculatedParam calculatedParam) {
         log.info(LocalDateTime.now()+"===>监测点稳态指标超标明细月表2开始执行");
         DateTime beginMonth = DateUtil.beginOfMonth(DateUtil.parse(calculatedParam.getDataDate(), DatePattern.NORM_DATE_PATTERN));

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/RMpVThdServiceImpl.java

@@ -29,7 +29,6 @@ public class RMpVThdServiceImpl extends MppServiceImpl<RMpVThdMapper, RMpVThd> i
 
     @Override
     @Transactional(rollbackFor = {Exception.class})
-    @Async("asyncExecutor")
     public void insertHarmonicVThdDay(CalculatedParam calculatedParam) {
         log.info(LocalDateTime.now()+"===>监测点谐波畸变率开始执行");
         List<String> lineIds = calculatedParam.getIdList();