forked from uav/ard-uav-server
blame | history | patch | commit | commitdiff | ignore whitespace
liusuyi
2025-10-30 27b3ffa1dcf89f4dc5fdd13a96f7c985d0eba68d 
 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;


@@ -7,26 +10,30 @@


import com.ard.work.domain.dto.state.UavState;


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


@Component


public class UavAllManager extends BaseSubscriptionManager<Map<String,Object>> {


public class UavAllManager extends BaseSubscriptionManager<Map<String, Object>> {




    @Resource


    private UavControlService uavControlService;


    @Autowired


    private RedisCache redisCache;




    @Override


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


        Map<String,Object> map=new HashMap<>();


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


        log.debug("获取无人机所有数据");


        Map<String, Object> map = new HashMap<>();


        map.put("boxSn", boxSn);


        UavState uavState = UavStateCache.get(boxSn);


        if (uavState != null) {


            uavState.calculateFieldAngle();// 计算当前无人机的FieldAngle


        }


        map.put("boxSn", uavState.getBoxSn());


        map.put("state", uavState);


        TelemetryData uavTelemetryData = UavTelemetryDataCache.get(boxSn);


        map.put("telemetry", uavTelemetryData);


@@ -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;


    }