From ac69fbcd2ace5d0f90b0ca6de5f7679526319316 Mon Sep 17 00:00:00 2001
From: rain <167982779@qq.com>
Date: Wed, 27 Mar 2024 17:18:48 +0800
Subject: [PATCH] 修改图斑入库的格式

---
 src/main/java/com/dji/sample/component/websocket/service/impl/SendMessageServiceImpl.java |   41 +++++++++++++++++++++++++++++++++++------
 1 files changed, 35 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/dji/sample/component/websocket/service/impl/SendMessageServiceImpl.java b/src/main/java/com/dji/sample/component/websocket/service/impl/SendMessageServiceImpl.java
index 0546728..727df3a 100644
--- a/src/main/java/com/dji/sample/component/websocket/service/impl/SendMessageServiceImpl.java
+++ b/src/main/java/com/dji/sample/component/websocket/service/impl/SendMessageServiceImpl.java
@@ -3,14 +3,17 @@
 import com.dji.sample.component.websocket.config.ConcurrentWebSocketSession;
 import com.dji.sample.component.websocket.model.CustomWebSocketMessage;
 import com.dji.sample.component.websocket.service.ISendMessageService;
+import com.dji.sample.component.websocket.service.IWebSocketManageService;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.util.StringUtils;
 import org.springframework.web.socket.TextMessage;
 
 import java.io.IOException;
 import java.util.Collection;
+import java.util.Objects;
 
 /**
  * @author sean.zhou
@@ -23,6 +26,9 @@
 
     @Autowired
     private ObjectMapper mapper;
+
+    @Autowired
+    private IWebSocketManageService webSocketManageService;
 
     @Override
     public void sendMessage(ConcurrentWebSocketSession session, CustomWebSocketMessage message) {
@@ -56,12 +62,14 @@
             TextMessage data = new TextMessage(mapper.writeValueAsBytes(message));
 
             for (ConcurrentWebSocketSession session : sessions) {
-                if (!session.isOpen()) {
-                    session.close();
-                    log.debug("This session is closed.");
-                    return;
+                if (!Objects.isNull(session)) {
+                    if (!session.isOpen()) {
+                        session.close();
+                        log.debug("This session is closed.");
+                        return;
+                    }
+                    session.sendMessage(data);
                 }
-                session.sendMessage(data);
             }
 
         } catch (IOException e) {
@@ -70,4 +78,25 @@
             e.printStackTrace();
         }
     }
-}
\ No newline at end of file
+
+    @Override
+    public void sendBatch(String workspaceId, Integer userType, String bizCode, Object data) {
+        if (!StringUtils.hasText(workspaceId)) {
+            throw new RuntimeException("项目id不存在:"+workspaceId);
+        }
+        Collection<ConcurrentWebSocketSession> sessions = Objects.isNull(userType) ?
+                webSocketManageService.getValueWithWorkspace(workspaceId) :
+                webSocketManageService.getValueWithWorkspaceAndUserType(workspaceId, userType);
+
+        this.sendBatch(sessions, CustomWebSocketMessage.builder()
+                        .data(data)
+                        .timestamp(System.currentTimeMillis())
+                        .bizCode(bizCode)
+                        .build());
+    }
+
+    @Override
+    public void sendBatch(String workspaceId, String bizCode, Object data) {
+        this.sendBatch(workspaceId, null, bizCode, data);
+    }
+}

--
Gitblit v1.9.3