From 1cf4e129cf3387f40bd6a853f6d5f177d3f6705b Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期五, 10 一月 2025 15:48:56 +0800
Subject: [PATCH] lockRt锁实时状态socket
---
src/main/java/com/whyc/webSocket/LockRtSocket.java | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/whyc/webSocket/LockRtSocket.java b/src/main/java/com/whyc/webSocket/LockRtSocket.java
index 3112459..904be0d 100644
--- a/src/main/java/com/whyc/webSocket/LockRtSocket.java
+++ b/src/main/java/com/whyc/webSocket/LockRtSocket.java
@@ -1,8 +1,10 @@
package com.whyc.webSocket;
import com.whyc.config.WebSocketConfig;
+import com.whyc.dto.LockRDto;
import com.whyc.dto.Response;
import com.whyc.service.LockInfService;
+import com.whyc.util.JsonUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -43,7 +45,7 @@
}
@OnMessage
public void onMessage(Session session, String message) {
- Integer areaId=Integer.valueOf(message);
+ LockRDto dto= JsonUtil.getGson().fromJson(message,LockRDto.class);
thread = new Thread("Thread_lockRtSocket") {
@Override
public void run() {
@@ -51,7 +53,7 @@
Thread thread = currentThread();
threadFlagMap.put(thread.getId(), true);
try {
- Response res=getLockRt(areaId);
+ Response res=getLockRt(dto);
if (session.isOpen()) {
//鎺ㄩ�佷俊鎭�
synchronized (session) {
@@ -79,8 +81,8 @@
threadMap.put(session.getId(), this.thread);
}
//鑾峰彇鍖哄煙涓嬫墍鏈夐攣鐨勭姸鎬�
- private Response getLockRt(int areaId) {
- Response res=lockInfService.getLockRt(areaId);
+ private Response getLockRt(LockRDto dto) {
+ Response res=lockInfService.getAllLockInf(dto.getLockName(),dto.getLockType(),dto.getLockState(),dto.getAreaId(),dto.getPageNum(),dto.getPageSize());
return new Response().setII(1,true,res,"鑾峰彇鍖哄煙涓嬫墍鏈夐攣鐨勭姸鎬�");
}
--
Gitblit v1.9.1