forked from uav/ard-uav-server
blame | history | patch | commit | commitdiff | ignore whitespace
liusuyi
2025-10-30 9f911c1461ba33c1a561046eb1ac8e1c56fc9b9d 
 ard-work/src/main/java/com/ard/work/component/websocket/handler/UavAllManager.java


@@ -1,5 +1,8 @@


package com.ard.work.component.websocket.handler;




import com.ard.common.constant.CacheConstants;


import com.ard.common.core.domain.entity.SysUser;


import com.ard.common.core.redis.RedisCache;


import com.ard.work.domain.cache.UavSignalInfoCache;


import com.ard.work.domain.cache.UavStateCache;


import com.ard.work.domain.cache.UavTelemetryDataCache;


@@ -8,10 +11,12 @@


import com.ard.work.domain.dto.telemetry.TelemetryData;


import com.ard.work.service.control.UavControlService;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Component;




import javax.annotation.Resource;


import java.util.HashMap;


import java.util.List;


import java.util.Map;




@Slf4j


@@ -20,6 +25,8 @@




    @Resource


    private UavControlService uavControlService;


    @Autowired


    private RedisCache redisCache;




    @Override


    protected Map<String, Object> getData(String boxSn) {


@@ -34,12 +41,14 @@


        map.put("signal", uavSignalInfo);


        // 获取当前控制飞行的用户ID


        Long flyUserId = uavControlService.getCurrentController(boxSn, "fly");


        SysUser flyUser = redisCache.getCacheObject(CacheConstants.SYS_USER_KEY + flyUserId);


        // 将飞行当前控制者用户ID添加到映射中


        map.put("flyController", flyUserId);


        map.put("flyController", flyUser);


        // 获取当前控制载荷的用户ID


        Long payloadUserId = uavControlService.getCurrentController(boxSn, "payload");


        SysUser payloadUser = redisCache.getCacheObject(CacheConstants.SYS_USER_KEY + payloadUserId);


        // 将载荷当前控制者用户ID添加到映射中


        map.put("payloadController", payloadUserId);


        map.put("payloadController", payloadUser);


        return map;


    }