From 97f71a9e41a124f204f13010f8d2e3cd7d9036b9 Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期四, 26 六月 2025 16:24:38 +0800
Subject: [PATCH] 实时数据曲线统计-交流单元实时推送
---
src/main/java/com/whyc/webSocket/RealDataStaticAcSocket.java | 114 ++++++++++++++++++++++++++++++++++++++
src/main/java/com/whyc/service/PwrdevAcdcdataService.java | 39 ++++++++++++
2 files changed, 152 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/whyc/service/PwrdevAcdcdataService.java b/src/main/java/com/whyc/service/PwrdevAcdcdataService.java
index 3006233..7a80f2d 100644
--- a/src/main/java/com/whyc/service/PwrdevAcdcdataService.java
+++ b/src/main/java/com/whyc/service/PwrdevAcdcdataService.java
@@ -3,11 +3,20 @@
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.whyc.dto.Real.PwrHisRealAcInDto;
import com.whyc.dto.Real.PwrHisRealDcoutInDto;
+import com.whyc.dto.RealDataStatic.ResRealDataAc;
+import com.whyc.dto.RealDataStatic.SticRealDataAc;
import com.whyc.mapper.PwrdevAcdcdataMapper;
+import com.whyc.pojo.db_data_history.PwrdevHistorydataId;
import com.whyc.pojo.db_ram_db.BattRtstate;
import com.whyc.pojo.db_ram_db.PwrdevAcdcdata;
+import com.whyc.util.ActionUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+
+import java.lang.reflect.Field;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
@Service
public class PwrdevAcdcdataService {
@@ -32,5 +41,33 @@
PwrHisRealDcoutInDto dcoutDto=mapper.getPwrRealDcOut(powerId);
return dcoutDto;
}
-
+ //瀹炴椂鏁版嵁缁熻鏇茬嚎-浜ゆ祦鍗曞厓
+ public ResRealDataAc getSticRealDataAc(SticRealDataAc realDataAc) throws NoSuchFieldException, IllegalAccessException {
+ Integer powerId=realDataAc.getPowerId();
+ Map<String,List<String>> propertyInfo=realDataAc.getPropertyInfo();
+ QueryWrapper wrapper=new QueryWrapper();
+ wrapper.eq("power_id",powerId);
+ wrapper.last("limit 1");
+ PwrdevAcdcdata pwr=mapper.selectOne(wrapper);
+ ResRealDataAc data=new ResRealDataAc();
+ if(pwr!=null){
+ data.setRecordDatetime(pwr.getRecordDatetime());
+ Map<String, Map<String,Float>>dataMap=new HashMap<>();
+ for (Map.Entry<String, List<String>> entry : propertyInfo.entrySet()) {
+ String key = entry.getKey();
+ List<String> valueList = entry.getValue();
+ Map<String,Float> propertyMap=new HashMap<>();
+ for (String value : valueList) {
+ String propertyName = ActionUtil.toCamelCase(value);
+ Field field = PwrdevAcdcdata.class.getDeclaredField(propertyName);
+ field.setAccessible(true); // 濡傛灉瀛楁鏄鏈夌殑锛岄渶瑕佽缃负鍙闂�
+ Float propertyValue = (Float) field.get(pwr);
+ propertyMap.put(value,propertyValue);
+ }
+ dataMap.put(key,propertyMap);
+ }
+ data.setPropertyInfo(dataMap);
+ }
+ return data;
+ }
}
\ No newline at end of file
diff --git a/src/main/java/com/whyc/webSocket/RealDataStaticAcSocket.java b/src/main/java/com/whyc/webSocket/RealDataStaticAcSocket.java
new file mode 100644
index 0000000..a7dd6a4
--- /dev/null
+++ b/src/main/java/com/whyc/webSocket/RealDataStaticAcSocket.java
@@ -0,0 +1,114 @@
+package com.whyc.webSocket;
+
+import com.whyc.config.WebSocketConfig;
+import com.whyc.dto.Real.PwrHisRealAcInDto;
+import com.whyc.dto.RealDataStatic.ResRealDataAc;
+import com.whyc.dto.RealDataStatic.SticRealDataAc;
+import com.whyc.dto.Response;
+import com.whyc.pojo.db_param.PowerheartParam;
+import com.whyc.service.PowerheartParamService;
+import com.whyc.service.PwrdevAcdcdataService;
+import com.whyc.util.ActionUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.servlet.http.HttpSession;
+import javax.websocket.*;
+import javax.websocket.server.ServerEndpoint;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 瀹炴椂鏁版嵁缁熻鎺ㄩ�佷氦娴佸崟鍏冿紝鏇存敼棰戠巼
+ */
+@Component
+@ServerEndpoint(value = "/realsticAc",encoders = WebSocketEncoder.class,configurator = WebSocketConfig.class)
+public class RealDataStaticAcSocket {
+ private Session session;
+
+ private Thread thread;
+
+ private static PwrdevAcdcdataService acdcdataService;
+
+ private static PowerheartParamService pwrHeartService;
+
+ private static HttpSession httpSession;
+
+ private volatile boolean runFlag = true;
+
+ private volatile Map<String, Thread> threadMap = new HashMap<>();
+
+ private volatile Map<Long,Boolean> threadFlagMap = new HashMap<>();
+
+ @Autowired
+ public void setPwrdevAcdcdataService(PwrdevAcdcdataService service) {
+ RealDataStaticAcSocket.acdcdataService = service;
+ }
+
+ @Autowired
+ public void setPowerheartParamService(PowerheartParamService service) {
+ RealDataStaticAcSocket.pwrHeartService = service;
+ }
+
+ @OnOpen
+ public void onOpen(Session session, EndpointConfig config) {
+ this.session = session;
+ this.httpSession = (HttpSession) config.getUserProperties().get("httpSession");
+ }
+ @OnMessage
+ public void onMessage(Session session, String message) {
+ SticRealDataAc realData= ActionUtil.getGson().fromJson(message,SticRealDataAc.class);
+ thread = new Thread("Thread_HeartacinSocket") {
+ @Override
+ public void run() {
+ while (runFlag && !isInterrupted()) {
+ Thread thread = currentThread();
+ threadFlagMap.put(thread.getId(), true);
+ try {
+ ResRealDataAc dataAc = acdcdataService.getSticRealDataAc(realData);
+ if (session.isOpen()) {
+ //鎺ㄩ�佷俊鎭�
+ synchronized (session) {
+ session.getBasicRemote().sendObject(new Response<>().setII(1,dataAc!=null,dataAc,"瀹炴椂鏁版嵁缁熻-浜ゆ祦鍗曞厓"));
+ }
+ threadFlagMap.put(thread.getId(), false);
+ }
+ PowerheartParam powerheartParam=pwrHeartService.getHeartParamByPowerId(realData.getPowerId());
+ sleep(1000*60*powerheartParam.getAcinInterverCfg());
+ } catch (Exception e) {
+ interrupt();
+ }
+ }
+ }
+ };
+ thread.start();
+ threadFlagMap.put(thread.getId(),true);
+ //鍋滄鑰佺殑socket绾跨▼
+ Thread threadBefore = threadMap.get(session.getId());
+ if(threadBefore !=null && threadBefore.isAlive()){
+ while (threadFlagMap.get(threadBefore.getId())){
+ }
+ threadBefore.interrupt();
+ }
+ //灏嗙嚎绋嬪瓨鍌�,渚夸簬璋冪敤瀹氫綅
+ threadMap.put(session.getId(), this.thread);
+ }
+ @OnClose
+ public void onClose(CloseReason closeReason){
+ System.err.println("closeReason = " + closeReason);
+ runFlag = false;
+ if (thread != null && thread.isAlive()) {
+ thread.interrupt();
+ }
+ threadMap.remove(session.getId());
+ }
+
+ @OnError
+ public void onError(Throwable error) {
+ error.printStackTrace();
+ if (thread != null && thread.isAlive()) {
+ thread.interrupt();
+ }
+ threadMap.remove(session.getId());
+ }
+}
\ No newline at end of file
--
Gitblit v1.9.1