diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatSubstationServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatSubstationServiceImpl.java index 78909b236..4faa42aa5 100644 --- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatSubstationServiceImpl.java +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatSubstationServiceImpl.java @@ -17,10 +17,8 @@ import com.njcn.prepare.harmonic.pojo.po.RStatSubstationQPO; import com.njcn.prepare.harmonic.pojo.po.RStatSubstationYPO; import com.njcn.prepare.harmonic.service.mysql.newalgorithm.*; import lombok.RequiredArgsConstructor; -import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.ListUtils; -import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; @@ -95,8 +93,6 @@ public class RStatSubstationServiceImpl implements RStatSubstationService { @Override @Transactional(rollbackFor = {Exception.class}) - @Async("asyncExecutor") - @SneakyThrows public void handlerD(CalculatedParam calculatedParam) { log.info(LocalDateTime.now()+"===>变电站指标统计日表算法开始"); List rStatSubstationDPOS = new ArrayList<>(); @@ -225,8 +221,6 @@ public class RStatSubstationServiceImpl implements RStatSubstationService { @Override @Transactional(rollbackFor = {Exception.class}) - @Async("asyncExecutor") - @SneakyThrows public void handlerM(CalculatedParam calculatedParam) { log.info(LocalDateTime.now()+"===>变电站指标统计月表算法开始"); List rStatSubstationMPOS = new ArrayList<>(); @@ -404,8 +398,6 @@ public class RStatSubstationServiceImpl implements RStatSubstationService { @Override @Transactional(rollbackFor = {Exception.class}) - @Async("asyncExecutor") - @SneakyThrows public void handlerQ(CalculatedParam calculatedParam) { log.info(LocalDateTime.now()+"===>变电站指标统计季表算法开始"); DecimalFormat df = new DecimalFormat("0.00"); @@ -556,8 +548,6 @@ public class RStatSubstationServiceImpl implements RStatSubstationService { @Override @Transactional(rollbackFor = {Exception.class}) - @Async("asyncExecutor") - @SneakyThrows public void handlerY(CalculatedParam calculatedParam) { log.info(LocalDateTime.now()+"===>变电站指标统计年表算法开始"); DecimalFormat df = new DecimalFormat("0.00");