算法注解删除
This commit is contained in:
@@ -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.pojo.po.RStatSubstationYPO;
|
||||||
import com.njcn.prepare.harmonic.service.mysql.newalgorithm.*;
|
import com.njcn.prepare.harmonic.service.mysql.newalgorithm.*;
|
||||||
import lombok.RequiredArgsConstructor;
|
import lombok.RequiredArgsConstructor;
|
||||||
import lombok.SneakyThrows;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.apache.commons.collections4.ListUtils;
|
import org.apache.commons.collections4.ListUtils;
|
||||||
import org.springframework.scheduling.annotation.Async;
|
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
import org.springframework.util.CollectionUtils;
|
import org.springframework.util.CollectionUtils;
|
||||||
@@ -95,8 +93,6 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
@Transactional(rollbackFor = {Exception.class})
|
@Transactional(rollbackFor = {Exception.class})
|
||||||
@Async("asyncExecutor")
|
|
||||||
@SneakyThrows
|
|
||||||
public void handlerD(CalculatedParam calculatedParam) {
|
public void handlerD(CalculatedParam calculatedParam) {
|
||||||
log.info(LocalDateTime.now()+"===>变电站指标统计日表算法开始");
|
log.info(LocalDateTime.now()+"===>变电站指标统计日表算法开始");
|
||||||
List<RStatSubstationDPO> rStatSubstationDPOS = new ArrayList<>();
|
List<RStatSubstationDPO> rStatSubstationDPOS = new ArrayList<>();
|
||||||
@@ -225,8 +221,6 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
@Transactional(rollbackFor = {Exception.class})
|
@Transactional(rollbackFor = {Exception.class})
|
||||||
@Async("asyncExecutor")
|
|
||||||
@SneakyThrows
|
|
||||||
public void handlerM(CalculatedParam calculatedParam) {
|
public void handlerM(CalculatedParam calculatedParam) {
|
||||||
log.info(LocalDateTime.now()+"===>变电站指标统计月表算法开始");
|
log.info(LocalDateTime.now()+"===>变电站指标统计月表算法开始");
|
||||||
List<RStatSubstationMPO> rStatSubstationMPOS = new ArrayList<>();
|
List<RStatSubstationMPO> rStatSubstationMPOS = new ArrayList<>();
|
||||||
@@ -404,8 +398,6 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
@Transactional(rollbackFor = {Exception.class})
|
@Transactional(rollbackFor = {Exception.class})
|
||||||
@Async("asyncExecutor")
|
|
||||||
@SneakyThrows
|
|
||||||
public void handlerQ(CalculatedParam calculatedParam) {
|
public void handlerQ(CalculatedParam calculatedParam) {
|
||||||
log.info(LocalDateTime.now()+"===>变电站指标统计季表算法开始");
|
log.info(LocalDateTime.now()+"===>变电站指标统计季表算法开始");
|
||||||
DecimalFormat df = new DecimalFormat("0.00");
|
DecimalFormat df = new DecimalFormat("0.00");
|
||||||
@@ -556,8 +548,6 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
@Transactional(rollbackFor = {Exception.class})
|
@Transactional(rollbackFor = {Exception.class})
|
||||||
@Async("asyncExecutor")
|
|
||||||
@SneakyThrows
|
|
||||||
public void handlerY(CalculatedParam calculatedParam) {
|
public void handlerY(CalculatedParam calculatedParam) {
|
||||||
log.info(LocalDateTime.now()+"===>变电站指标统计年表算法开始");
|
log.info(LocalDateTime.now()+"===>变电站指标统计年表算法开始");
|
||||||
DecimalFormat df = new DecimalFormat("0.00");
|
DecimalFormat df = new DecimalFormat("0.00");
|
||||||
|
|||||||
Reference in New Issue
Block a user