Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

算法优化

Browse Source
This commit is contained in:
xy
2025-06-10 15:01:52 +08:00
parent 6179e7f434
commit 02947219f4
2 changed files with 20 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java
View File

@@ -487,6 +487,7 @@ public class DataCleanServiceImpl implements IDataCleanService {
} }
} }
if (CollUtil.isNotEmpty(resultData)) { if (CollUtil.isNotEmpty(resultData)) {
bak.setState(1);
//存储文件 //存储文件
InputStream reportStream = IoUtil.toStream(new Gson().toJson(resultData), CharsetUtil.UTF_8); InputStream reportStream = IoUtil.toStream(new Gson().toJson(resultData), CharsetUtil.UTF_8);
String fileName = fileStorageUtil.uploadStreamSpecifyName( String fileName = fileStorageUtil.uploadStreamSpecifyName(
@@ -695,7 +696,12 @@ public class DataCleanServiceImpl implements IDataCleanService {
dataCleanJsonDTO.setPhasic(k); dataCleanJsonDTO.setPhasic(k);
dataCleanJsonDTO.setValueType(k2); dataCleanJsonDTO.setValueType(k2);
dataCleanJsonDTO.setTime(v2.stream().map(dt -> dt.getTime().format(DateTimeFormatter.ofPattern(DatePattern.NORM_TIME_PATTERN))).collect(Collectors.toList())); dataCleanJsonDTO.setTime(v2.stream().map(dt -> dt.getTime().format(DateTimeFormatter.ofPattern(DatePattern.NORM_TIME_PATTERN))).collect(Collectors.toList()));
dataCleanJsonDTO.setValue(v2.stream().map(PqDataVerify::getAbnormalValue).collect(Collectors.toList())); dataCleanJsonDTO.setValue(v2.stream()
.map(pq -> {
Double value = pq.getAbnormalValue();
return value != null ? Math.round(value * 100) / 100.0 : null;
})
.collect(Collectors.toList()));
list1.add(dataCleanJsonDTO); list1.add(dataCleanJsonDTO);
}); });
dto.setList(list1); dto.setList(list1);
@@ -721,7 +727,12 @@ public class DataCleanServiceImpl implements IDataCleanService {
dto1.setPhasic(k2); dto1.setPhasic(k2);
dto1.setValueType(k3); dto1.setValueType(k3);
dto1.setTime(v3.stream().map(dt -> dt.getTime().format(DateTimeFormatter.ofPattern(DatePattern.NORM_TIME_PATTERN))).collect(Collectors.toList())); dto1.setTime(v3.stream().map(dt -> dt.getTime().format(DateTimeFormatter.ofPattern(DatePattern.NORM_TIME_PATTERN))).collect(Collectors.toList()));
dto1.setValue(v3.stream().map(PqDataVerify::getAbnormalValue).collect(Collectors.toList())); dto1.setValue(v3.stream()
.map(pq -> {
Double value = pq.getAbnormalValue();
return value != null ? Math.round(value * 100) / 100.0 : null;
})
.collect(Collectors.toList()));
dataCleanJsonDTOList.add(dto1); dataCleanJsonDTOList.add(dto1);
}); });
dto.setList(dataCleanJsonDTOList); dto.setList(dataCleanJsonDTOList);

7
data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/pojo/po/PqDataVerifyBak.java
View File

@@ -40,6 +40,13 @@ public class PqDataVerifyBak implements Serializable {
@JsonFormat(pattern = "yyyy-MM-dd",timezone="GMT+8") @JsonFormat(pattern = "yyyy-MM-dd",timezone="GMT+8")
private LocalDate time; private LocalDate time;
/**
* 监测点状态
* 判断所有指标 0:无异常 1:异常
*/
@TableField(value = "state")
private Integer state = 0;
/** /**
* 频率指标 * 频率指标
*/ */