2025-11-15 zwy 航线任务模块更改； 1、航线文件从夏吉建航线表中取； 2、修改增加循环任务功能； 3、增加字段及字段注释，对应JSON字...

zhaowenyu

2025-11-15 3cd13607fe569164f6ab5284558ab8e258852940

 ard-sample/src/main/java/com/ard/sample/component/websocket/handler/DockWebSocketHandler.java

@@ -5,7 +5,6 @@
import com.ard.sample.component.websocket.model.Payload;
import com.ard.sample.component.websocket.model.WebSocketMessage;
import lombok.extern.slf4j.Slf4j;
import org.checkerframework.checker.units.qual.A;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.socket.CloseStatus;
@@ -101,11 +100,12 @@
                _liveStreamService.StartLiveStreaming(sn);
            }
        } else {
            // 停止直播
            if(MessageType.LIVESTREAM.getType().equals(type)){
                System.out.println("停止直播");
                _liveStreamService.StopLiveStreaming(sn);
            }
            // 停止直播--前端不主动关注直播，则在断开连接时停止
//            if(MessageType.LIVESTREAM.getType().equals(type)){
//                System.out.println("停止直播");
//
//                _liveStreamService.StopLiveStreaming(sn);
//            }
            // 取消订阅操作
            if (subscriptions.containsKey(subscriptionKey)) {
                subscriptions.get(subscriptionKey).remove(userId);
@@ -139,12 +139,13 @@
     */
    private void removeUserAllSubscriptions(String userId) {
        for (Map.Entry<String, Set<String>> entry : subscriptions.entrySet()) {
            if (entry.getKey().contains(MessageType.LIVESTREAM.getType())) {
                String sn = entry.getKey().split(":")[0];
                _liveStreamService.StopLiveStreaming(sn);
            }
            // 停止直播逻辑
            entry.getValue().remove(userId);
            if (entry.getValue().isEmpty()) {
                if (entry.getKey().contains(MessageType.LIVESTREAM.getType())) {
                    String sn = entry.getKey().split(":")[0];
                    _liveStreamService.StopLiveStreaming(sn);
                }
                subscriptions.remove(entry.getKey());
            }
        }