向pc端转发三一车辆位置申请提交

zhangnaisong

2024-01-29 dec2e65f7d3917e8843564dc26184f9be7c48af3

 ard-work/src/main/java/com/ruoyi/app/application/service/impl/ArdAppApplicationServiceImpl.java

@@ -2,7 +2,10 @@

import java.util.*;

import com.ruoyi.common.core.domain.entity.SysRole;
import com.ruoyi.common.utils.uuid.IdUtils;
import com.ruoyi.system.mapper.SysRoleMapper;
import com.ruoyi.utils.websocket.util.WebSocketUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@@ -14,6 +17,9 @@

import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import javax.websocket.Session;

import static com.ruoyi.utils.websocket.util.WebSocketUtils.ONLINE_USER_SESSIONS;

/**
 * 单兵端申请查看指挥端位置或三一车辆位置Service业务层处理
@@ -25,6 +31,9 @@
public class ArdAppApplicationServiceImpl implements IArdAppApplicationService {
    @Resource
    private ArdAppApplicationMapper ardAppApplicationMapper;

    @Resource
    private SysRoleMapper sysRoleMapper;

    private Map<String,Thread> threadMap = new HashMap();

@@ -182,6 +191,23 @@
                resultSingle = ardAppApplicationMapper.insertArdAppApplication(ardAppApplication);
                result = result + resultSingle;
            }
            //加入给pc端websocket转发
            List<SysRole> sysRoleList = sysRoleMapper.selectRolePermissionByUserId(commanderId);
            for(SysRole sysRole : sysRoleList){
                if(!sysRole.getRoleKey().equals("appLeader")){
                    Map<String,Object> resultMap = ardAppApplicationMapper.selectSYCarApplicationByPCIdAndSoilderId(commanderId,usersId);
                    Map<String,Map<String,Object>> msg = new HashMap();
                    msg.put("60000",resultMap);
                    for(String id : ONLINE_USER_SESSIONS.keySet()){
                        if(id.startsWith(commanderId)){
                            Session session = ONLINE_USER_SESSIONS.get(id);
                            WebSocketUtils.sendMessage(session,msg);
                            break;
                        }
                    }
                    break;//一个pc端用户可能挂接多个角色，每个pc端只转发一次
                }
            }
        }
        return result;
    }
@@ -264,29 +290,32 @@
        List<Map<String,Object>> ardAppApplicationList = ardAppApplicationMapper.selectArdAppApplicationByCommanderIdTrue(commanderId);
        Date date = new Date();
        //查看指挥端位置申请
        /*List<Map<String, Object>> resultCommanderPosition = new ArrayList();
        List<Map<String, Object>> resultCommanderPosition = new ArrayList();
        //查看车辆位置申请
        List<Map<String, Object>> resultSYCarsPosition = new ArrayList();
        for(Map<String, Object> map : ardAppApplicationList){
            Long interval = date.getTime() - Long.parseLong((String)map.get("begin"));
            interval = 24 * 60 * 60 * 1000 - interval;
            Long hour = interval / (60 * 60 * 1000);
            Long min = (interval - hour * 60 * 60 * 1000) / (60 * 1000);
            map.put("time",hour + "时" + min + "分");
            Long second = (interval - hour * 60 * 60 * 1000 - min * 60 * 1000) / 1000;
            map.put("time",hour + "时" + min + "分" + second + "秒");
            if(((String)map.get("applicationType")).equals("Commander")){
                resultCommanderPosition.add(map);
            }
        }*/
        //查看车辆位置申请
        /*List<Map<String, Object>> resultSYCarsPosition = new ArrayList();
        for(Map<String, Object> map : ardAppApplicationList){
            Long interval = date.getTime() - Long.parseLong((String)map.get("begin"));
            interval = 24 * 60 * 60 * 1000 - interval;
            Long hour = interval / (60 * 60 * 1000);
            Long min = (interval - hour * 60 * 60 * 1000) / (60 * 1000);
            map.put("time",hour + "时" + min + "分");
            if(((String)map.get("applicationType")).equals("SYCar")){
            }else if(((String)map.get("applicationType")).equals("SYCar")){
                resultSYCarsPosition.add(map);
            }
        }*/
        }
        result.put("commander",resultCommanderPosition);
        result.put("SYCars",resultSYCarsPosition);
        return result;
    }

    @Override
    public Map<String, List<Map<String, Object>>> getSendPositionTrue(String soilderId) {
        Map<String, List<Map<String, Object>>> result = new HashMap();
        List<Map<String,Object>> ardAppApplicationList = ardAppApplicationMapper.selectArdAppApplicationBySoilderIdTrue(soilderId);
        Date date = new Date();
        //查看指挥端位置申请
        List<Map<String, Object>> resultCommanderPosition = new ArrayList();
        //查看车辆位置申请
@@ -296,7 +325,8 @@
            interval = 24 * 60 * 60 * 1000 - interval;
            Long hour = interval / (60 * 60 * 1000);
            Long min = (interval - hour * 60 * 60 * 1000) / (60 * 1000);
            map.put("time",hour + "时" + min + "分");
            Long second = (interval - hour * 60 * 60 * 1000 - min * 60 * 1000) / 1000;
            map.put("time",hour + "时" + min + "分" + second + "秒");
            if(((String)map.get("applicationType")).equals("Commander")){
                resultCommanderPosition.add(map);
            }else if(((String)map.get("applicationType")).equals("SYCar")){