From a3686cfa49bf53fb91a2ceb960cf15b3ebdac641 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期四, 30 五月 2024 16:38:00 +0800
Subject: [PATCH] 测试代码
---
smart-man-boot/src/main/java/com/qianwen/smartman/common/websocket/realtime/RealTimeDataJsonSubscriptionFilter.java | 5 ++---
1 files changed, 2 insertions(+), 3 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 cb48492..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
@@ -10,9 +10,8 @@
import org.springframework.web.socket.WebSocketSession;
@Component
-/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/common/websocket/realtime/RealTimeDataJsonSubscriptionFilter.class */
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";
@@ -24,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