From 318ebac926b9627a683c4ab90d4e2b7451b1e573 Mon Sep 17 00:00:00 2001
From: baoshiwei <baoshiwei@shlanbao.cn>
Date: 星期三, 18 六月 2025 13:43:55 +0800
Subject: [PATCH] feat(engine): 新增全厂总电量统计功能
---
src/main/java/com/zhitan/engine/service/impl/DataCleaningServiceImpl.java | 101 ++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 100 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/zhitan/engine/service/impl/DataCleaningServiceImpl.java b/src/main/java/com/zhitan/engine/service/impl/DataCleaningServiceImpl.java
index 1d41cd3..9a7a1c3 100644
--- a/src/main/java/com/zhitan/engine/service/impl/DataCleaningServiceImpl.java
+++ b/src/main/java/com/zhitan/engine/service/impl/DataCleaningServiceImpl.java
@@ -1,5 +1,8 @@
package com.zhitan.engine.service.impl;
+import com.influxdb.client.domain.WritePrecision;
+import com.influxdb.client.write.Point;
+import com.zhitan.engine.config.InfluxDBConfig;
import com.zhitan.engine.influxdb.InfluxdbRepository;
import com.zhitan.engine.entity.*;
import com.zhitan.engine.repository.*;
@@ -20,13 +23,18 @@
import java.util.regex.Pattern;
import java.util.stream.Collectors;
+import static java.util.List.*;
+
/**
* 鏁版嵁娓呮礂鏈嶅姟瀹炵幇绫�
*/
@Slf4j
@Service
public class DataCleaningServiceImpl implements DataCleaningService {
-
+ private final String TAG = "tag";
+ private final String FIELD_VALUE = "value";
+ @Autowired
+ private InfluxDBConfig influxDBConfig;
@Autowired
private InfluxdbRepository influxdbRepository;
@@ -164,6 +172,97 @@
}
@Override
+ public void calculateTotalElectricity(LocalDateTime dateTime) {
+ log.info("寮�濮嬫墽琛屽叏鍘傛�荤數閲忕粺璁★紝鏃堕棿鐐癸細{}", dateTime);
+
+ // 瀹氫箟闇�瑕佺粺璁＄殑鐢佃〃缃戝叧鍒楄〃
+ List<String> gatewayCodes = new java.util.ArrayList<>(List.of("00601925032100028432", "00601925032100026840", "00601925032100028685", "00601925032100027392", "00601925032100028050", "00601925032100028751"));
+ gatewayCodes.add("00601925032100026275");
+ gatewayCodes.add("00601925032100028117");
+ gatewayCodes.add("00601925032100028814");
+ gatewayCodes.add("00601925032100028990");
+ gatewayCodes.add("00601925032100031307");
+
+
+ // 瀹氫箟闇�瑕佺粺璁＄殑鍙傛暟绫诲瀷鍙婂叾缁熻鏂瑰紡
+ Map<String, String> parameterTypes = new java.util.HashMap<>(Map.of(
+ "ActiveZT", "SUM" // 姝ｅ悜鎬绘湁鍔熺數鑳� - 姹傚拰
+ , "ActiveZN", "SUM" // 姝ｅ悜鎬绘棤鍔熺數鑳� - 姹傚拰
+ , "ActiveElectricity", "SUM" // 鏈夊姛鐢佃兘 - 姹傚拰
+ , "NoActiveElectricity", "SUM" // 鏃犲姛鍔熺巼 - 姹傚拰
+ , "ExpZN", "SUM" // 鍙嶅悜鎬绘棤鍔熺數鑳� - 姹傚拰
+ , "Exp", "SUM" // 鍙嶅悜鏈夊姛鐢佃兘 - 姹傚拰
+ , "ActivePow", "SUM" // 姝ｅ悜鏈夊姛鍔熺巼 - 姹傚拰
+ , "VoltageUAB", "AVG" // 鎬荤數鍘� - 骞冲潎鍊�
+ , "VoltageUBC", "AVG" // 鎬荤數鍘� - 骞冲潎鍊�
+ , "VoltageUCA", "AVG" // 鎬荤數鍘� - 骞冲潎鍊�
+// ,"CurrentA", "SUM" // 鎬荤數娴� - 姹傚拰
+// ,"CurrentB", "SUM" // 鎬荤數娴� - 姹傚拰
+// ,"CurrentC", "SUM" // 鎬荤數娴� - 姹傚拰
+// ,"Io", "SUM" // 鎬荤數娴� - 姹傚拰
+// ,"VoltageA", "AVG" // 鎬荤數鍘� - 骞冲潎鍊�
+// ,"VoltageB", "AVG" // 鎬荤數鍘� - 骞冲潎鍊�
+// ,"VoltageC", "AVG"
+ ));
+ parameterTypes.put("CurrentA", "SUM");
+ parameterTypes.put("CurrentB", "SUM");
+ parameterTypes.put("CurrentC", "SUM");
+ parameterTypes.put("Io", "SUM");
+ parameterTypes.put("VoltageA", "AVG");
+ parameterTypes.put("VoltageB", "AVG");
+ parameterTypes.put("VoltageC", "AVG");
+
+ // 璁＄畻鏃堕棿鑼冨洿锛堝綋鍓嶅垎閽燂級
+ LocalDateTime startTime = dateTime.withSecond(0).withNano(0);
+ LocalDateTime endTime = startTime.plusMinutes(1);
+
+ // 閬嶅巻鎵�鏈夊弬鏁扮被鍨嬭繘琛岀粺璁�
+ parameterTypes.forEach((paramType, calcType) -> {
+ try {
+ double totalValue = 0;
+ int meterCount = 0;
+
+ // 閬嶅巻鎵�鏈夌綉鍏充笅鐨勭數琛�
+ for (String gatewayCode : gatewayCodes) {
+ // 閬嶅巻姣忎釜缃戝叧涓嬬殑8涓數琛�
+ for (int i = 1; i <= 8; i++) {
+ // 鏋勫缓tag鍚嶇О鏍煎紡锛氱綉鍏崇紪鍙穇鐢佃〃搴忓彿_鍙傛暟绫诲瀷
+ // 绀轰緥锛�00601925032100028432_1_ActiveZT
+ String tag = String.format("%s_%d_%s", gatewayCode, i, paramType);
+ // 鏌ヨ鏈�鍚庝竴娆′繚瀛樻暟鎹�
+
+ Double value = influxdbRepository.getLastPoint(influxDBConfig.getMeasurement(),TAG,tag);
+ if (value != null) {
+ totalValue += value ;
+ meterCount++;
+ }
+ }
+ }
+
+ // 璁＄畻鏈�缁堝��
+ double finalValue = "SUM".equals(calcType) ? totalValue : (meterCount > 0 ? totalValue / meterCount : 0);
+
+ // 淇濆瓨鎬昏〃鏁版嵁
+ String totalTag = "total_" + paramType;
+
+ Point point = Point
+ .measurement(influxDBConfig.getMeasurement())
+ .addTag(TAG, totalTag)
+ .addField(FIELD_VALUE, finalValue)
+ .time(Instant.now(), WritePrecision.S);
+
+ influxdbRepository.writePoint(point);
+
+ log.info("缁熻瀹屾垚锛歿}={} ({}涓數琛�)", totalTag, finalValue, meterCount);
+ } catch (Exception e) {
+ log.error("缁熻鍙傛暟{}澶辫触锛歿}", paramType, e.getMessage(), e);
+ }
+ });
+
+ log.info("鍏ㄥ巶鎬荤數閲忕粺璁″畬鎴愶紝鏃堕棿鐐癸細{}", dateTime);
+ }
+
+ @Override
@Transactional
public void calculatePeakValleyElectricity(String indexId, LocalDateTime dateTime) {
log.info("寮�濮嬭绠楀皷宄板钩璋风敤鐢甸噺锛岀储寮旾D锛歿}锛屾椂闂寸偣锛歿}", indexId, dateTime);
--
Gitblit v1.9.3