Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

调整预处理模块-监测点暂态指标明细_日统计

Browse Source
This commit is contained in:
hongawen
2023-10-31 11:38:42 +08:00
parent 30e52e96fe
commit e77ad50762
8 changed files with 97 additions and 426 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pqs-prepare/prepare-api/pom.xml
View File

@@ -12,11 +12,6 @@
<name>预处理对外接口模块</name> <name>预处理对外接口模块</name>
<dependencies> <dependencies>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>common-core</artifactId>
<version>${project.version}</version>
</dependency>
<dependency> <dependency>
<groupId>com.njcn</groupId> <groupId>com.njcn</groupId>
<artifactId>common-db</artifactId> <artifactId>common-db</artifactId>

93
pqs-prepare/prepare-boot/pom.xml
View File

@@ -19,32 +19,6 @@
<dependencies> <dependencies>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>user-api</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>common-core</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>process-api</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>harmonic-api</artifactId>
<version>${project.version}</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>common-web</artifactId>
<version>${project.version}</version>
</dependency>
<dependency> <dependency>
<groupId>com.njcn</groupId> <groupId>com.njcn</groupId>
<artifactId>common-swagger</artifactId> <artifactId>common-swagger</artifactId>
@@ -60,7 +34,33 @@
<artifactId>common-redis</artifactId> <artifactId>common-redis</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
</dependency> </dependency>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>prepare-api</artifactId>
<version>${project.version}</version>
</dependency>
<!--pqs-influx-->
<dependency>
<groupId>com.njcn</groupId>
<artifactId>pqs-influx</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>user-api</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>process-api</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>harmonic-api</artifactId>
<version>${project.version}</version>
<scope>compile</scope>
</dependency>
<dependency> <dependency>
<groupId>com.njcn</groupId> <groupId>com.njcn</groupId>
<artifactId>system-api</artifactId> <artifactId>system-api</artifactId>
@@ -77,7 +77,6 @@
<artifactId>mapstruct</artifactId> <artifactId>mapstruct</artifactId>
<version>${org.mapstruct.version}</version> <version>${org.mapstruct.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.mapstruct</groupId> <groupId>org.mapstruct</groupId>
<artifactId>mapstruct-processor</artifactId> <artifactId>mapstruct-processor</artifactId>
@@ -88,7 +87,6 @@
<artifactId>lombok-mapstruct-binding</artifactId> <artifactId>lombok-mapstruct-binding</artifactId>
<version>0.2.0</version> <version>0.2.0</version>
</dependency> </dependency>
<!-- 要与mapstruct版本匹配，用同一时间的版本,不然会出现各种问题 --> <!-- 要与mapstruct版本匹配，用同一时间的版本,不然会出现各种问题 -->
<dependency> <dependency>
<groupId>org.projectlombok</groupId> <groupId>org.projectlombok</groupId>
@@ -96,17 +94,12 @@
<version>${org.projectlombok.version}</version> <version>${org.projectlombok.version}</version>
<scope>provided</scope> <scope>provided</scope>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.njcn</groupId> <groupId>com.njcn</groupId>
<artifactId>common-oss</artifactId> <artifactId>common-oss</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
</dependency> </dependency>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>prepare-api</artifactId>
<version>${project.version}</version>
</dependency>
<!-- 多数据源切换，当数据源为oracle时需要使用 --> <!-- 多数据源切换，当数据源为oracle时需要使用 -->
<dependency> <dependency>
@@ -115,35 +108,13 @@
<version>3.5.1</version> <version>3.5.1</version>
</dependency> </dependency>
<!--pqs-influx-->
<dependency> <dependency>
<groupId>com.njcn</groupId>
<artifactId>pqs-influx</artifactId>
<version>${project.version}</version>
</dependency>
<!-- &lt;!&ndash;oracle驱动&ndash;&gt;-->
<!-- <dependency>-->
<!-- <groupId>com.oracle.database.jdbc</groupId>-->
<!-- <artifactId>ojdbc8</artifactId>-->
<!-- <version>21.6.0.0</version>-->
<!-- </dependency>-->
<!-- &lt;!&ndash; 不支持的字符集 (在类路径中添加 orai18n.jar): ZHS16GBK &ndash;&gt;-->
<!-- <dependency>-->
<!-- <groupId>com.oracle.database.nls</groupId>-->
<!-- <artifactId>orai18n</artifactId>-->
<!-- <version>21.1.0.0</version>-->
<!-- </dependency>-->
<!-- <dependency>
<groupId>com.yomahub</groupId> <groupId>com.yomahub</groupId>
<artifactId>liteflow-spring-boot-starter</artifactId> <artifactId>liteflow-spring-boot-starter</artifactId>
<version>2.11.0</version> <version>2.11.2</version>
</dependency>--> </dependency>
<!-- <dependency>--> <!-- <dependency>-->
<!-- <groupId>com.yomahub</groupId>--> <!-- <groupId>com.yomahub</groupId>-->

67
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/line/PqsEventdetailController.java
View File

@@ -1,67 +0,0 @@
package com.njcn.prepare.harmonic.controller.line;
import com.njcn.common.pojo.annotation.OperateInfo;
import com.njcn.common.pojo.enums.common.LogEnum;
import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil;
import com.njcn.device.biz.commApi.CommTerminalGeneralClient;
import com.njcn.device.pq.api.LineFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.mysql.line.PqsEventdetailHandlerService;
import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.util.CollectionUtils;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
/**
* Description:
* 接口文档访问地址：http://serverIP:port/swagger-ui.html
* Date: 2022/12/28 13:47【需求编号】
*
* @author clam
* @version V1.0.0
*/
@Slf4j
@Api(tags = "监测点暂态指标超标明细")
@RestController
@RequestMapping("/eventdetail")
@RequiredArgsConstructor
public class PqsEventdetailController extends BaseController {
private final LineFeignClient lineFeignClient;
private final CommTerminalGeneralClient commTerminalGeneralClient;
private final PqsEventdetailHandlerService pqsEventdetailHandlerService;
@OperateInfo(info = LogEnum.BUSINESS_COMMON)
@PostMapping("/eventdetailHandler")
@ApiOperation("监测点暂态指标处理")
@ApiImplicitParam(name = "lineParam", value = "参数", required = true)
public HttpResult<String> eventdetailHandler(@RequestBody @Validated LineParam lineParam){
log.info(LocalDateTime.now()+"eventdetailHandler始执行");
String methodDescribe = getMethodDescribe("eventdetailHandler");
List<String> indexLists = new ArrayList<> ();
if(CollectionUtils.isEmpty (lineParam.getLineIds ())){
indexLists = commTerminalGeneralClient.getRunMonitorIds ().getData ();
}else{
indexLists = lineParam.getLineIds ();
}
lineParam.setLineIds (indexLists);
pqsEventdetailHandlerService.eventdetailHandler (lineParam);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}
}

23
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/newalgorithm/RMpEventdetailController.java
View File

@@ -5,6 +5,7 @@ import com.njcn.common.pojo.enums.common.LogEnum;
import com.njcn.common.pojo.enums.response.CommonResponseEnum; import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil; import com.njcn.common.utils.HttpResultUtil;
import com.njcn.device.biz.commApi.CommTerminalGeneralClient;
import com.njcn.device.pq.api.LineFeignClient; import com.njcn.device.pq.api.LineFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.mysql.line.RMpEventDetailService; import com.njcn.prepare.harmonic.service.mysql.line.RMpEventDetailService;
@@ -40,25 +41,27 @@ import java.util.List;
@RequiredArgsConstructor @RequiredArgsConstructor
public class RMpEventdetailController extends BaseController { public class RMpEventdetailController extends BaseController {
private final LineFeignClient lineFeignClient;
private final CommTerminalGeneralClient commTerminalGeneralClient;
private final RMpEventDetailService rMpEventDetailService; private final RMpEventDetailService rMpEventDetailService;
@OperateInfo(info = LogEnum.BUSINESS_COMMON) @OperateInfo(info = LogEnum.BUSINESS_COMMON)
@PostMapping("/eventdetailHandler") @PostMapping("/eventdetailHandler")
@ApiOperation("监测点暂态指标处理") @ApiOperation("监测点暂态指标处理")
@ApiImplicitParam(name = "lineParam", value = "参数", required = true) @ApiImplicitParam(name = "lineParam", value = "参数", required = true)
public HttpResult<String> eventdetailHandler(@RequestBody @Validated LineParam lineParam){ public HttpResult<String> eventdetailHandler(@RequestBody @Validated LineParam lineParam) {
log.info(LocalDateTime.now()+"eventdetailHandler始执行"); log.info(LocalDateTime.now() + "eventdetailHandler始执行");
String methodDescribe = getMethodDescribe("eventdetailHandler"); String methodDescribe = getMethodDescribe("eventdetailHandler");
List<String> indexLists = new ArrayList<> (); List<String> indexLists;
if(CollectionUtils.isEmpty (lineParam.getLineIds ())){ if (CollectionUtils.isEmpty(lineParam.getLineIds())) {
indexLists = lineFeignClient.getLineList ( ).getData ( ); indexLists = commTerminalGeneralClient.getRunMonitorIds().getData();
}else{ } else {
indexLists = lineParam.getLineIds (); indexLists = lineParam.getLineIds();
} }
lineParam.setLineIds (indexLists); lineParam.setLineIds(indexLists);
rMpEventDetailService.eventdetailHandler (lineParam); rMpEventDetailService.eventdetailHandler(lineParam);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
} }
} }

209
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/PqsEventdetailHandlerServiceImpl.java
View File

@@ -1,209 +0,0 @@
package com.njcn.prepare.harmonic.service.mysql.Impl.line;
import com.njcn.harmonic.pojo.po.RMpEventDetailDPO;
import com.njcn.harmonic.pojo.po.RMpEventDetailMPO;
import com.njcn.harmonic.pojo.po.RMpEventDetailQPO;
import com.njcn.harmonic.pojo.po.RMpEventDetailYPO;
import com.njcn.prepare.harmonic.constant.AlgorithmParam;
import com.njcn.prepare.harmonic.pojo.oracle.PqLinedetailPO;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.mysql.line.*;
import com.njcn.prepare.harmonic.service.oracle.PqLinedetailPOService;
import com.njcn.prepare.harmonic.service.oracle.PqsEventdetailService;
import lombok.AllArgsConstructor;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Objects;
/**
* Description:
* 接口文档访问地址：http://serverIP:port/swagger-ui.html
* Date: 2022/12/28 14:11【需求编号】
*
* @author clam
* @version V1.0.0
*/
@Slf4j
@Service
@AllArgsConstructor
public class PqsEventdetailHandlerServiceImpl implements PqsEventdetailHandlerService {
private final PqLinedetailPOService pqLinedetailPOService;
private final PqsEventdetailService pqsEventdetailService;
private final RMpEventDetailDService rMpEventDetailDService;
private final RMpEventDetailMService rMpEventDetailMService;
private final RMpEventDetailQService rMpEventDetailQService;
private final RMpEventDetailYService rMpEventDetailYService;
@Override
@Async("asyncExecutor")
public void eventdetailHandler(LineParam lineParam) {
/*if (Objects.equals (lineParam.getDataSource ( ), AlgorithmParam.ORACLE_DATA)) {
hanlderOracleData (lineParam);
} else if (Objects.equals (lineParam.getDataSource ( ), AlgorithmParam.INFLUX_DATA)) {*/
hanlderInfludxbData (lineParam);
// }
}
/**
* @Description: hanlderInfludxbData
* @Param: [lineParam]
* @return: void
* @Author: clam
* @Date: 2022/12/28
*/
private void hanlderInfludxbData(LineParam lineParam) {
}
/**
* @Description: hanlderOracleData
* @Param: [lineParam]
* @return: void
* @Author: clam
* @Date: 2022/12/28
*/
private void hanlderOracleData(LineParam lineParam) {
Integer type = lineParam.getType ( );
switch (type) {
case 1:
this.hanlderOracleYear (lineParam);
break;
case 2:
this.hanlderOracleQtr (lineParam);
break;
case 3:
this.hanlderOracleMonth (lineParam);
break;
case 5:
this.hanlderOracleDay (lineParam);
break;
default:
break;
}
}
@SneakyThrows
private void hanlderOracleYear(LineParam lineParam) {
List<String> lineIds = lineParam.getLineIds ( );
String dataDate = lineParam.getDataDate ( );
final Date tempDate = new SimpleDateFormat ("yyyy-MM-dd").parse (dataDate);
List<RMpEventDetailYPO> rMpEventDetailYPOList = new ArrayList<> ( );
lineIds.forEach (lineId -> {
/*查询月表数据生成年表数据*/
List<RMpEventDetailMPO> rMpEventDetailMPOList = rMpEventDetailMService.queryOneYearData(lineId,dataDate);
int sagCount = rMpEventDetailMPOList.stream ( ).mapToInt (RMpEventDetailMPO::getSagTimes).sum ( );
int riseCount = rMpEventDetailMPOList.stream ( ).mapToInt (RMpEventDetailMPO::getSwellTimes).sum ( );
int interruptCount = rMpEventDetailMPOList.stream ( ).mapToInt (RMpEventDetailMPO::getInterruptTimes).sum ( );
RMpEventDetailYPO rMpEventDetailYPO = new RMpEventDetailYPO();
rMpEventDetailYPO.setMeasurementPointId (lineId);
rMpEventDetailYPO.setDataDate (tempDate);
rMpEventDetailYPO.setSagTimes (sagCount);
rMpEventDetailYPO.setSwellTimes (riseCount);
rMpEventDetailYPO.setInterruptTimes (interruptCount);
rMpEventDetailYPOList.add (rMpEventDetailYPO);
});
rMpEventDetailYService.saveOrUpdateBatchByMultiId (rMpEventDetailYPOList,500);
}
@SneakyThrows
private void hanlderOracleQtr(LineParam lineParam) {
List<String> lineIds = lineParam.getLineIds ( );
String dataDate = lineParam.getDataDate ( );
final Date tempDate = new SimpleDateFormat ("yyyy-MM-dd").parse (dataDate);
List<RMpEventDetailQPO> rMpEventDetailQPOList = new ArrayList<> ( );
lineIds.forEach (lineId -> {
/*查询月表数据生成季表数据*/
List<RMpEventDetailMPO> rMpEventDetailMPOList = rMpEventDetailMService.queryOneQtrData(lineId,dataDate);
int sagCount = rMpEventDetailMPOList.stream ( ).mapToInt (RMpEventDetailMPO::getSagTimes).sum ( );
int riseCount = rMpEventDetailMPOList.stream ( ).mapToInt (RMpEventDetailMPO::getSwellTimes).sum ( );
int interruptCount = rMpEventDetailMPOList.stream ( ).mapToInt (RMpEventDetailMPO::getInterruptTimes).sum ( );
RMpEventDetailQPO rMpEventDetailQPO = new RMpEventDetailQPO();
rMpEventDetailQPO.setMeasurementPointId (lineId);
rMpEventDetailQPO.setDataDate (tempDate);
rMpEventDetailQPO.setSagTimes (sagCount);
rMpEventDetailQPO.setSwellTimes (riseCount);
rMpEventDetailQPO.setInterruptTimes (interruptCount);
rMpEventDetailQPOList.add (rMpEventDetailQPO);
});
rMpEventDetailQService.saveOrUpdateBatchByMultiId (rMpEventDetailQPOList,500);
}
@SneakyThrows
private void hanlderOracleMonth(LineParam lineParam) {
List<String> lineIds = lineParam.getLineIds ( );
String dataDate = lineParam.getDataDate ( );
final Date tempDate = new SimpleDateFormat ("yyyy-MM-dd").parse (dataDate);
List<RMpEventDetailMPO> rMpEventDetailMPOList = new ArrayList<> ( );
lineIds.forEach (lineId -> {
/*查询day表数据生成月表数据*/
List<RMpEventDetailDPO> rMpEventDetailDPOList = rMpEventDetailDService.queryOneMothData(lineId,dataDate);
int sagCount = rMpEventDetailDPOList.stream ( ).mapToInt (RMpEventDetailDPO::getSagTimes).sum ( );
int riseCount = rMpEventDetailDPOList.stream ( ).mapToInt (RMpEventDetailDPO::getSwellTimes).sum ( );
int interruptCount = rMpEventDetailDPOList.stream ( ).mapToInt (RMpEventDetailDPO::getInterruptTimes).sum ( );
RMpEventDetailMPO rMpEventDetailMPO = new RMpEventDetailMPO();
rMpEventDetailMPO.setMeasurementPointId (lineId);
rMpEventDetailMPO.setDataDate (tempDate);
rMpEventDetailMPO.setSagTimes (sagCount);
rMpEventDetailMPO.setSwellTimes (riseCount);
rMpEventDetailMPO.setInterruptTimes (interruptCount);
rMpEventDetailMPOList.add (rMpEventDetailMPO);
});
rMpEventDetailMService.saveOrUpdateBatchByMultiId (rMpEventDetailMPOList,500);
}
@SneakyThrows
private void hanlderOracleDay(LineParam lineParam) {
List<String> lineIds = lineParam.getLineIds ( );
String dataDate = lineParam.getDataDate ( );
final Date tempDate = new SimpleDateFormat ("yyyy-MM-dd").parse (dataDate);
List<RMpEventDetailDPO> rMpEventDetailDPOList = new ArrayList<> ( );
lineIds.forEach (lineId -> {
/*获取mysql与Oracle监测点id对应关系*/
PqLinedetailPO oracleIndexIdByMonitorId = pqLinedetailPOService.getOracleIndexIdByMonitorId (lineId);
Integer sagCount = pqsEventdetailService.queryByCondition (oracleIndexIdByMonitorId.getLineIndex(),dataDate,AlgorithmParam.SAG);
Integer riseCount = pqsEventdetailService.queryByCondition (oracleIndexIdByMonitorId.getLineIndex(),dataDate,AlgorithmParam.RISE);
Integer interruptCount = pqsEventdetailService.queryByCondition (oracleIndexIdByMonitorId.getLineIndex(),dataDate,AlgorithmParam.INTERRUPT);
RMpEventDetailDPO rMpEventDetailDPO = new RMpEventDetailDPO();
rMpEventDetailDPO.setMeasurementPointId (lineId);
rMpEventDetailDPO.setDataDate (tempDate);
rMpEventDetailDPO.setSagTimes (sagCount);
rMpEventDetailDPO.setSwellTimes (riseCount);
rMpEventDetailDPO.setInterruptTimes (interruptCount);
rMpEventDetailDPOList.add (rMpEventDetailDPO);
});
rMpEventDetailDService.saveOrUpdateBatchByMultiId (rMpEventDetailDPOList,500);
}
}

107
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/RMpEventDetailServiceImpl.java
View File

@@ -27,7 +27,6 @@ import java.util.List;
import java.util.Optional; import java.util.Optional;
/** /**
*
* Description: * Description:
* 接口文档访问地址：http://serverIP:port/swagger-ui.html * 接口文档访问地址：http://serverIP:port/swagger-ui.html
* Date: 2023/4/23 13:50【需求编号】 * Date: 2023/4/23 13:50【需求编号】
@@ -37,7 +36,7 @@ import java.util.Optional;
*/ */
@Service @Service
@RequiredArgsConstructor @RequiredArgsConstructor
public class RMpEventDetailServiceImpl extends ServiceImpl<RMpEventDetailMapper, RMpEventDetailPO> implements RMpEventDetailService{ public class RMpEventDetailServiceImpl extends ServiceImpl<RMpEventDetailMapper, RMpEventDetailPO> implements RMpEventDetailService {
private final RMpEventDetailDService rMpEventDetailDService; private final RMpEventDetailDService rMpEventDetailDService;
@@ -54,18 +53,6 @@ public class RMpEventDetailServiceImpl extends ServiceImpl<RMpEventDetailMapper,
this.hanlderData(lineParam); this.hanlderData(lineParam);
} }
@Override
public Integer queryByCondition(String measurementPointId, String dataDate, String eventType) {
QueryWrapper<RMpEventDetailPO> queryWrapper = new QueryWrapper ( );
queryWrapper.select ("1").
eq ("measurement_point_id", measurementPointId).
eq ("event_type",eventType).
eq("DATE_FORMAT( start_time ,'%Y-%m-%d')",dataDate);
Integer integer = this.getBaseMapper ().selectCount (queryWrapper);
return integer;
}
/** /**
* @Description: hanlderOracleData * @Description: hanlderOracleData
@@ -75,7 +62,7 @@ public class RMpEventDetailServiceImpl extends ServiceImpl<RMpEventDetailMapper,
* @Date: 2022/12/28 * @Date: 2022/12/28
*/ */
private void hanlderData(LineParam lineParam) { private void hanlderData(LineParam lineParam) {
Integer type = lineParam.getType ( ); Integer type = lineParam.getType();
switch (type) { switch (type) {
// case 1: // case 1:
// this.hanlderYear (lineParam); // this.hanlderYear (lineParam);
@@ -84,78 +71,88 @@ public class RMpEventDetailServiceImpl extends ServiceImpl<RMpEventDetailMapper,
// this.hanlderQtr (lineParam); // this.hanlderQtr (lineParam);
// break; // break;
case 3: case 3:
this.hanlderMonth (lineParam); this.hanlderMonth(lineParam);
break; break;
case 5: case 5:
this.hanlderDay (lineParam); this.hanlderDay(lineParam);
break; break;
default: default:
break; break;
} }
} }
@SneakyThrows @SneakyThrows
private void hanlderMonth(LineParam lineParam) { private void hanlderMonth(LineParam lineParam) {
List<String> lineIds = lineParam.getLineIds();
String dataDate = lineParam.getDataDate();
final Date tempDate = new SimpleDateFormat("yyyy-MM-dd").parse(dataDate);
List<RMpEventDetailMPO> rMpEventDetailMPOList = new ArrayList<>();
List<String> lineIds = lineParam.getLineIds ( ); lineIds.forEach(measurementPointId -> {
String dataDate = lineParam.getDataDate ( );
final Date tempDate = new SimpleDateFormat ("yyyy-MM-dd").parse (dataDate);
List<RMpEventDetailMPO> rMpEventDetailMPOList = new ArrayList<> ( );
lineIds.forEach (measurementPointId -> {
/*查询day表数据生成月表数据*/ /*查询day表数据生成月表数据*/
List<RMpEventDetailDPO> rMpEventDetailDPOList = rMpEventDetailDService.queryOneMothData(measurementPointId,dataDate); List<RMpEventDetailDPO> rMpEventDetailDPOList = rMpEventDetailDService.queryOneMothData(measurementPointId, dataDate);
int sagCount = rMpEventDetailDPOList.stream ( ).mapToInt (RMpEventDetailDPO::getSagTimes).sum ( ); int sagCount = rMpEventDetailDPOList.stream().mapToInt(RMpEventDetailDPO::getSagTimes).sum();
int riseCount = rMpEventDetailDPOList.stream ( ).mapToInt (RMpEventDetailDPO::getSwellTimes).sum ( ); int riseCount = rMpEventDetailDPOList.stream().mapToInt(RMpEventDetailDPO::getSwellTimes).sum();
int interruptCount = rMpEventDetailDPOList.stream ( ).mapToInt (RMpEventDetailDPO::getInterruptTimes).sum ( ); int interruptCount = rMpEventDetailDPOList.stream().mapToInt(RMpEventDetailDPO::getInterruptTimes).sum();
RMpEventDetailMPO rMpEventDetailMPO = new RMpEventDetailMPO(); RMpEventDetailMPO rMpEventDetailMPO = new RMpEventDetailMPO();
rMpEventDetailMPO.setMeasurementPointId (measurementPointId); rMpEventDetailMPO.setMeasurementPointId(measurementPointId);
rMpEventDetailMPO.setDataDate (tempDate); rMpEventDetailMPO.setDataDate(tempDate);
rMpEventDetailMPO.setSagTimes (sagCount); rMpEventDetailMPO.setSagTimes(sagCount);
rMpEventDetailMPO.setSwellTimes (riseCount); rMpEventDetailMPO.setSwellTimes(riseCount);
rMpEventDetailMPO.setInterruptTimes (interruptCount); rMpEventDetailMPO.setInterruptTimes(interruptCount);
rMpEventDetailMPOList.add (rMpEventDetailMPO); rMpEventDetailMPOList.add(rMpEventDetailMPO);
}); });
rMpEventDetailMService.saveOrUpdateBatchByMultiId (rMpEventDetailMPOList,500); rMpEventDetailMService.saveOrUpdateBatchByMultiId(rMpEventDetailMPOList, 500);
} }
@SneakyThrows @SneakyThrows
private void hanlderDay(LineParam lineParam) { private void hanlderDay(LineParam lineParam) {
List<String> lineIds = lineParam.getLineIds ( ); List<String> lineIds = lineParam.getLineIds();
String dataDate = lineParam.getDataDate ( ); String dataDate = lineParam.getDataDate();
final Date tempDate = new SimpleDateFormat ("yyyy-MM-dd").parse (dataDate); final Date tempDate = new SimpleDateFormat("yyyy-MM-dd").parse(dataDate);
List<RMpEventDetailDPO> rMpEventDetailDPOList = new ArrayList<> ( ); List<RMpEventDetailDPO> rMpEventDetailDPOList = new ArrayList<>();
lineIds.forEach (measurementPointId -> { lineIds.forEach(measurementPointId -> {
Integer sagCount = this.queryByCondition (measurementPointId,dataDate, getEventTypeId(DicDataEnum.VOLTAGE_DIP.getCode ( ))); Integer sagCount = this.queryByCondition(measurementPointId, dataDate, getEventTypeId(DicDataEnum.VOLTAGE_DIP.getCode()));
Integer riseCount = this.queryByCondition (measurementPointId,dataDate,getEventTypeId(DicDataEnum.VOLTAGE_RISE.getCode ( ))); Integer riseCount = this.queryByCondition(measurementPointId, dataDate, getEventTypeId(DicDataEnum.VOLTAGE_RISE.getCode()));
Integer interruptCount = this.queryByCondition (measurementPointId,dataDate,getEventTypeId(DicDataEnum.SHORT_INTERRUPTIONS.getCode ( ))); Integer interruptCount = this.queryByCondition(measurementPointId, dataDate, getEventTypeId(DicDataEnum.SHORT_INTERRUPTIONS.getCode()));
RMpEventDetailDPO rMpEventDetailDPO = new RMpEventDetailDPO(); RMpEventDetailDPO rMpEventDetailDPO = new RMpEventDetailDPO();
rMpEventDetailDPO.setMeasurementPointId (measurementPointId); rMpEventDetailDPO.setMeasurementPointId(measurementPointId);
rMpEventDetailDPO.setDataDate (tempDate); rMpEventDetailDPO.setDataDate(tempDate);
rMpEventDetailDPO.setSagTimes (sagCount); rMpEventDetailDPO.setSagTimes(sagCount);
rMpEventDetailDPO.setSwellTimes (riseCount); rMpEventDetailDPO.setSwellTimes(riseCount);
rMpEventDetailDPO.setInterruptTimes (interruptCount); rMpEventDetailDPO.setInterruptTimes(interruptCount);
rMpEventDetailDPOList.add (rMpEventDetailDPO); rMpEventDetailDPOList.add(rMpEventDetailDPO);
}); });
rMpEventDetailDService.saveOrUpdateBatchByMultiId (rMpEventDetailDPOList,500); rMpEventDetailDService.saveOrUpdateBatchByMultiId(rMpEventDetailDPOList, 500);
} }
public String getEventTypeId(String code){ public Integer queryByCondition(String measurementPointId, String dataDate, String eventType) {
QueryWrapper<RMpEventDetailPO> queryWrapper = new QueryWrapper();
queryWrapper.select("1").
eq("measurement_point_id", measurementPointId).
eq("event_type", eventType).
eq("DATE_FORMAT( start_time ,'%Y-%m-%d')", dataDate);
String eventType =redisUtil.getStringByKey (code); return this.getBaseMapper().selectCount(queryWrapper);
eventType = Optional.ofNullable (eventType).orElseGet (() ->{ }
DictData data = dicDataFeignClient.getDicDataByCode (code).getData ( );
redisUtil.saveByKey (data.getCode (),data.getId ()); public String getEventTypeId(String code) {
return data.getId ();
String eventType = redisUtil.getStringByKey(code);
eventType = Optional.ofNullable(eventType).orElseGet(() -> {
DictData data = dicDataFeignClient.getDicDataByCode(code).getData();
redisUtil.saveByKey(data.getCode(), data.getId());
return data.getId();
}); });
return eventType; return eventType;

18
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/line/PqsEventdetailHandlerService.java
View File

@@ -1,18 +0,0 @@
package com.njcn.prepare.harmonic.service.mysql.line;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
/**
*
* Description:
* 接口文档访问地址：http://serverIP:port/swagger-ui.html
* Date: 2022/12/28 13:46【需求编号】
*
* @author clam
* @version V1.0.0
*/
public interface PqsEventdetailHandlerService {
void eventdetailHandler(LineParam lineParam);
}

1
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/line/RMpEventDetailService.java
View File

@@ -24,5 +24,4 @@ public interface RMpEventDetailService extends IService<RMpEventDetailPO>{
*/ */
void eventdetailHandler(LineParam lineParam); void eventdetailHandler(LineParam lineParam);
Integer queryByCondition(String lineId, String dataDate, String eventType);
} }