From c9b04383c77f91ac309e37e70783edcf8a9298b5 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期六, 18 五月 2024 23:24:12 +0800
Subject: [PATCH] websocket代码整理
---
smart-man-boot/src/main/java/com/qianwen/smartman/common/websocket/realtime/RealTimeDataJsonSubscriptionFilter.java | 4 ++--
1 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/common/websocket/realtime/RealTimeDataJsonSubscriptionFilter.java b/smart-man-boot/src/main/java/com/qianwen/smartman/common/websocket/realtime/RealTimeDataJsonSubscriptionFilter.java
index cd4c1b4..5a4c3db 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/common/websocket/realtime/RealTimeDataJsonSubscriptionFilter.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/common/websocket/realtime/RealTimeDataJsonSubscriptionFilter.java
@@ -11,7 +11,7 @@
@Component
public class RealTimeDataJsonSubscriptionFilter implements SubscriptionSessionFilter<RealTimeDataRequestJsonWebSocketMessage> {
- private static Map<String, RealTimeDataRequestJsonWebSocketMessage> map = new HashMap();
+ private static Map<String, RealTimeDataRequestJsonWebSocketMessage> map = new HashMap<>();
public String type() {
return "realTimeData";
@@ -23,7 +23,7 @@
public List<String> onResponse(String messageText) {
RealTimeDaraResponseJsonWebSocketMessage responseMessage = (RealTimeDaraResponseJsonWebSocketMessage) JSONObject.parseObject(messageText, RealTimeDaraResponseJsonWebSocketMessage.class);
- return (List) map.keySet().stream().filter(key -> {
+ return map.keySet().stream().filter(key -> {
return map.get(key).getWorkstationIdList() == null || map.get(key).getWorkstationIdList().isEmpty() || (map.get(key).getWorkstationIdList().contains(responseMessage.getId()) && responseMessage.getType().equals(map.get(key).getType()));
}).collect(Collectors.toList());
}
--
Gitblit v1.9.3