From e50d8c30b43dd30daa77da27101ce21d8ef2fcef Mon Sep 17 00:00:00 2001
From: whycxzp <glperry@163.com>
Date: 星期一, 17 三月 2025 17:20:10 +0800
Subject: [PATCH] 锂电设备相关代码更新
---
src/main/java/com/whyc/webSocket/DevLithiumAlarmSocket.java | 20 ++++++++++----------
1 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/src/main/java/com/whyc/webSocket/DevInfSocket.java b/src/main/java/com/whyc/webSocket/DevLithiumAlarmSocket.java
similarity index 81%
copy from src/main/java/com/whyc/webSocket/DevInfSocket.java
copy to src/main/java/com/whyc/webSocket/DevLithiumAlarmSocket.java
index 0b37f68..8afae37 100644
--- a/src/main/java/com/whyc/webSocket/DevInfSocket.java
+++ b/src/main/java/com/whyc/webSocket/DevLithiumAlarmSocket.java
@@ -1,10 +1,10 @@
package com.whyc.webSocket;
import com.whyc.config.WebSocketConfig;
-import com.whyc.dto.DevInfDto;
+import com.whyc.dto.DevA200AlarmDto;
import com.whyc.dto.Response;
import com.whyc.pojo.db_user.UserInf;
-import com.whyc.service.DevInfService;
+import com.whyc.service.DevLithiumAlarmDataService;
import com.whyc.util.ActionUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -20,13 +20,13 @@
* 璁惧瀹炴椂杩炴帴淇℃伅
*/
@Component
-@ServerEndpoint(value = "/dinfSocket",encoders = WebSocketEncoder.class,configurator = WebSocketConfig.class)
-public class DevInfSocket {
+@ServerEndpoint(value = "/devLithiumAlarm",encoders = WebSocketEncoder.class,configurator = WebSocketConfig.class)
+public class DevLithiumAlarmSocket {
private Session session;
private Thread thread;
- private static DevInfService dinfService;
+ private static DevLithiumAlarmDataService service;
private HttpSession httpSession;
@@ -37,8 +37,8 @@
private volatile Map<Long,Boolean> threadFlagMap = new HashMap<>();
@Autowired
- public void setDevInfService(DevInfService dinfService) {
- DevInfSocket.dinfService = dinfService;
+ public void setService(DevLithiumAlarmDataService service) {
+ DevLithiumAlarmSocket.service = service;
}
@OnOpen
@@ -48,18 +48,18 @@
}
@OnMessage
public void onMessage(Session session, String message) {
- DevInfDto devInfDto = ActionUtil.getGson("yyyy-MM-dd").fromJson(message, DevInfDto.class);
+ DevA200AlarmDto dto = ActionUtil.getGson("yyyy-MM-dd HH:mm:ss").fromJson(message, DevA200AlarmDto.class);
UserInf user = (UserInf) this.httpSession.getAttribute("user");
final int userId = user.getUid();
//final int userId = 101;
- thread = new Thread("Thread_DinfSocket") {
+ thread = new Thread("Thread_DevLithiumAlarmSocket") {
@Override
public void run() {
while (runFlag && !isInterrupted()) {
Thread thread = currentThread();
threadFlagMap.put(thread.getId(), true);
try {
- Response res=dinfService.getAllInf(userId, devInfDto);
+ Response res=service.getPage(userId, dto);
if (session.isOpen()) {
//鎺ㄩ�佷俊鎭�
synchronized (session) {
--
Gitblit v1.9.1