Microservice/iot
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

实时数据调整

Browse Source
This commit is contained in:
xy
2024-11-12 13:20:18 +08:00
parent 5c6d05b307
commit 82b5cfcf8d
3 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
iot-analysis/analysis-rt/rt-api/src/main/java/com/njcn/rt/pojo/dto/BaseRealDataSet.java
View File

@@ -11,6 +11,9 @@ import java.io.Serializable;
@Data
public class BaseRealDataSet implements Serializable {
@ApiModelProperty("用户ID")
private String userId;
@ApiModelProperty("监测点id")
private String lineId;

3
iot-analysis/analysis-rt/rt-api/src/main/java/com/njcn/rt/pojo/dto/HarmRealDataSet.java
View File

@@ -12,6 +12,9 @@ import java.io.Serializable;
@Data
public class HarmRealDataSet implements Serializable {
@ApiModelProperty("用户ID")
private String userId;
@ApiModelProperty("监测点id")
private String lineId;

4
iot-analysis/analysis-rt/rt-boot/src/main/java/com/njcn/rt/service/impl/RtServiceImpl.java
View File

@@ -52,6 +52,8 @@ public class RtServiceImpl implements IRtService {
List<CsDataArray> dataArrayList;
//监测点id
String lineId = appAutoDataMessage.getId() + appAutoDataMessage.getMsg().getClDid();
//用户Id
String userId = redisUtil.getObjectByKey("rtDataUserId:"+lineId).toString();
//获取监测点基础信息
CsLinePO po = csLineFeignClient.getById(lineId).getData();
//获取数据集 dataSet
@@ -72,6 +74,7 @@ public class RtServiceImpl implements IRtService {
//基础数据
if (dataSet.getName().contains("Ds$Pqd$Rt$Basic$")) {
BaseRealDataSet baseRealDataSet = assembleData(dataArrayList,item,po.getConType());
baseRealDataSet.setUserId(userId);
baseRealDataSet.setLineId(lineId);
baseRealDataSet.setPt(po.getPtRatio().floatValue());
baseRealDataSet.setCt(po.getCtRatio().floatValue());
@@ -83,6 +86,7 @@ public class RtServiceImpl implements IRtService {
//fixme 目前实时数据只有基础数据和谐波数据，后期拓展，这边需要再判断
else {
HarmRealDataSet harmRealDataSet = harmData(dataArrayList,item);
harmRealDataSet.setUserId(userId);
harmRealDataSet.setLineId(lineId);
harmRealDataSet.setPt(po.getPtRatio().floatValue());
harmRealDataSet.setCt(po.getCtRatio().floatValue());