From 2d0ba2ef450700c7b8b1c490d81a5978d185a592 Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期四, 29 八月 2024 11:42:18 +0800
Subject: [PATCH] 设备信息实时推送
---
src/main/java/com/whyc/webSocket/DevInfSocket.java | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/whyc/webSocket/DevInfSocket.java b/src/main/java/com/whyc/webSocket/DevInfSocket.java
index 8ec03cf..4535059 100644
--- a/src/main/java/com/whyc/webSocket/DevInfSocket.java
+++ b/src/main/java/com/whyc/webSocket/DevInfSocket.java
@@ -1,7 +1,7 @@
package com.whyc.webSocket;
import com.whyc.config.WebSocketConfig;
-import com.whyc.dto.Page;
+import com.whyc.dto.DevInfDto;
import com.whyc.dto.Response;
import com.whyc.service.DevInfService;
import com.whyc.util.ActionUtil;
@@ -47,7 +47,7 @@
}
@OnMessage
public void onMessage(Session session, String message) {
- Page page= ActionUtil.getGson().fromJson(message,Page.class);
+ DevInfDto devInfDto = ActionUtil.getGson().fromJson(message, DevInfDto.class);
//UserInf user = (UserInf) this.httpSession.getAttribute("user");
//final int userId = user.getUid();
final int userId = 101;
@@ -58,7 +58,7 @@
Thread thread = currentThread();
threadFlagMap.put(thread.getId(), true);
try {
- Response res=dinfService.getAllInf(userId,page);
+ Response res=dinfService.getAllInf(userId, devInfDto);
if (session.isOpen()) {
//鎺ㄩ�佷俊鎭�
synchronized (session) {
--
Gitblit v1.9.1