测试提交

zhangnaisong

2024-01-29 6d754022e36ce1b83c8f23bbd82178258304d493

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

@@ -1,15 +1,13 @@
package com.ruoyi.app.application.service.impl;

import java.util.HashMap;
import java.util.List;
import java.util.*;

import com.alibaba.fastjson2.JSON;
import com.ruoyi.common.core.domain.entity.SysUser;
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;
import java.util.ArrayList;
import java.util.Map;

import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.SecurityUtils;
@@ -17,28 +15,79 @@
import com.ruoyi.app.application.domain.ArdAppApplication;
import com.ruoyi.app.application.service.IArdAppApplicationService;

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

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

/**
 * 单兵端申请查看指挥端位置或三一车辆位置Service业务层处理
 *
 * @author ard
 * @date 2024-01-23
 * @date 2024-01-25
 */
@Service
public class ArdAppApplicationServiceImpl implements IArdAppApplicationService {
    @Resource
    private ArdAppApplicationMapper ardAppApplicationMapper;

    @Resource
    private SysRoleMapper sysRoleMapper;

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

    @PostConstruct
    public void init(){
        ArdAppApplication para = new ArdAppApplication();
        para.setState("1");//查询同意的申请
        List<ArdAppApplication> ardAppApplicationList = ardAppApplicationMapper.selectArdAppApplicationList(para);
        Date date = new Date();
        Long now = date.getTime();
        for(ArdAppApplication ardAppApplication : ardAppApplicationList){
            Long begin = Long.parseLong(ardAppApplication.getBegin());
            //判断是否超时
            if(now - begin <= 24*60*60*1000){//未超时从新创建线程
                String key = ardAppApplication.getCommanderId() + "," + ardAppApplication.getSoilderId() + "," + ardAppApplication.getApplicationType();
                Thread thread = new Thread(key){//创建线程计时剩余时长
                    @Override
                    public void run() {
                        try {
                            Thread.sleep(24*60*60*1000 - (now - begin));//剩余时长
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                            return;
                        }
                        Thread currentThread = Thread.currentThread();
                        String state = "000";//state为000，即超时
                        String commanderId = currentThread.getName().split(",")[0];
                        String soilderId = currentThread.getName().split(",")[1];
                        String applicationType = currentThread.getName().split(",")[2];
                        int result = ardAppApplicationMapper.updateArdAppApplicationBeginByCommanderIdAndSoilderIdAndType(commanderId,soilderId,applicationType,"",state);
                        threadMap.remove(currentThread.getName());
                    }
                };
                thread.start();
                this.threadMap.put(key,thread);
            }else{//超时更改状态
                String state = "000";//state为000，即超时
                String commanderId = ardAppApplication.getCommanderId();
                String soilderId = ardAppApplication.getSoilderId();
                String applicationType = ardAppApplication.getApplicationType();
                int result = ardAppApplicationMapper.updateArdAppApplicationBeginByCommanderIdAndSoilderIdAndType(commanderId,soilderId,applicationType,"",state);
            }
        }
    }

    /**
     * 查询单兵端申请查看指挥端位置或三一车辆位置
     *
     * @param applicationId 单兵端申请查看指挥端位置或三一车辆位置主键
     * @param soilderId 单兵端申请查看指挥端位置或三一车辆位置主键
     * @return 单兵端申请查看指挥端位置或三一车辆位置
     */
    @Override
    public ArdAppApplication selectArdAppApplicationByApplicationId(String applicationId) {
        return ardAppApplicationMapper.selectArdAppApplicationByApplicationId(applicationId);
    public ArdAppApplication selectArdAppApplicationBySoilderId(String soilderId) {
        return ardAppApplicationMapper.selectArdAppApplicationBySoilderId(soilderId);
    }

    /**
@@ -77,23 +126,23 @@
    /**
     * 批量删除单兵端申请查看指挥端位置或三一车辆位置
     *
     * @param applicationIds 需要删除的单兵端申请查看指挥端位置或三一车辆位置主键
     * @param soilderIds 需要删除的单兵端申请查看指挥端位置或三一车辆位置主键
     * @return 结果
     */
    @Override
    public int deleteArdAppApplicationByApplicationIds(String[] applicationIds) {
        return ardAppApplicationMapper.deleteArdAppApplicationByApplicationIds(applicationIds);
    public int deleteArdAppApplicationBySoilderIds(String[] soilderIds) {
        return ardAppApplicationMapper.deleteArdAppApplicationBySoilderIds(soilderIds);
    }

    /**
     * 删除单兵端申请查看指挥端位置或三一车辆位置信息
     *
     * @param applicationId 单兵端申请查看指挥端位置或三一车辆位置主键
     * @param soilderId 单兵端申请查看指挥端位置或三一车辆位置主键
     * @return 结果
     */
    @Override
    public int deleteArdAppApplicationByApplicationId(String applicationId) {
        return ardAppApplicationMapper.deleteArdAppApplicationByApplicationId(applicationId);
    public int deleteArdAppApplicationBySoilderId(String soilderId) {
        return ardAppApplicationMapper.deleteArdAppApplicationBySoilderId(soilderId);
    }

    @Override
@@ -109,6 +158,7 @@
            ardAppApplication.setApplicationType("Commander");
            ardAppApplication.setBegin("");
            ardAppApplication.setState("0");
            ardAppApplication.setSoilderCheck("true");//指挥端未审批也设为true,不需要单兵端查看
            int resultSingle = ardAppApplicationMapper.updateArdAppApplicationByCommanderIdAndSoilderIdAndType(ardAppApplication);
            result = result + resultSingle;
            if(resultSingle == 0){
@@ -133,12 +183,30 @@
            ardAppApplication.setApplicationType("SYCar");
            ardAppApplication.setBegin("");
            ardAppApplication.setState("0");
            ardAppApplication.setSoilderCheck("true");//指挥端未审批也设为true,不需要单兵端查看
            int resultSingle = ardAppApplicationMapper.updateArdAppApplicationByCommanderIdAndSoilderIdAndType(ardAppApplication);
            result = result + resultSingle;
            if(resultSingle == 0){
                ardAppApplication.setApplicationId(IdUtils.simpleUUID());
                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;
@@ -147,8 +215,8 @@
    @Override
    public Map<String, List<Map<String, Object>>> getCheckPosition(String usersId) {
        Map<String, List<Map<String, Object>>> result = new HashMap();
        //查看指挥端位置申请
        List<Map<String,Object>> ardAppApplicationList = ardAppApplicationMapper.selectArdAppApplicationByCommanderId(usersId);
        //查看指挥端位置申请
        List<Map<String, Object>> resultCommanderPosition = new ArrayList();
        for(Map<String, Object> map : ardAppApplicationList){
            if(((String)map.get("applicationType")).equals("Commander")){
@@ -166,4 +234,174 @@
        result.put("SYCars",resultSYCarsPosition);
        return result;
    }

    @Override
    public int approvalCheckPosition(String commanderId, Map<String, String> para) {
        String applicationType = para.get("applicationType");
        String soilderId = para.get("soilderId");
        String state = para.get("state");
        String begin = "";
        if(state.equals("1")){//state为1，即同意
            begin = String.valueOf(new Date().getTime());//设置开始时间
            int result = ardAppApplicationMapper.updateArdAppApplicationBeginByCommanderIdAndSoilderIdAndType(commanderId,soilderId,applicationType,begin,state);
            String key = commanderId + "," + soilderId + "," + applicationType;
            Thread thread = new Thread(key){//创建线程计时24小时
                @Override
                public void run() {
                    try {
                        Thread.sleep(24*60*60*1000);
                        //Thread.sleep(3*60*1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                        return;
                    }
                    Thread currentThread = Thread.currentThread();
                    String state = "000";//state为000，即超时
                    String commanderId = currentThread.getName().split(",")[0];
                    String soilderId = currentThread.getName().split(",")[1];
                    String applicationType = currentThread.getName().split(",")[2];
                    int result = ardAppApplicationMapper.updateArdAppApplicationBeginByCommanderIdAndSoilderIdAndType(commanderId,soilderId,applicationType,"",state);
                    threadMap.remove(currentThread.getName());
                }
            };
            thread.start();
            this.threadMap.put(key,thread);
            return result;
        }else if(state.equals("-1")){//state为1，即驳回
            int result = ardAppApplicationMapper.updateArdAppApplicationBeginByCommanderIdAndSoilderIdAndType(commanderId,soilderId,applicationType,"",state);
            return result;
        }else if(state.equals("00")){//state为00，即撤销
            String key = commanderId + "," + soilderId + "," + applicationType;
            try{
                this.threadMap.get(key).interrupt();//撤销后线程销毁
            }catch(Exception e){
                e.printStackTrace();
            }
            this.threadMap.remove(key);
            int result = ardAppApplicationMapper.updateArdAppApplicationBeginByCommanderIdAndSoilderIdAndType(commanderId,soilderId,applicationType,"",state);
            return result;
        }
        return 0;
    }

    @Override
    public Map<String, List<Map<String, Object>>> getCheckPositionTrue(String commanderId) {
        Map<String, List<Map<String, Object>>> result = new HashMap();
        List<Map<String,Object>> ardAppApplicationList = ardAppApplicationMapper.selectArdAppApplicationByCommanderIdTrue(commanderId);
        Date date = new Date();
        //查看指挥端位置申请
        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);
            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")){
                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();
        //查看车辆位置申请
        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);
            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")){
                resultSYCarsPosition.add(map);
            }
        }
        result.put("commander",resultCommanderPosition);
        result.put("SYCars",resultSYCarsPosition);
        return result;
    }

    @Override
    public Map<String, List<Map<String, Object>>> getCheckPositionOwn(String soilderId) {
        Map<String, List<Map<String, Object>>> result = new HashMap();
        List<Map<String,Object>> ardAppApplicationList = ardAppApplicationMapper.selectArdAppApplicationBySoilderIdFalse(soilderId);
        Date date = new Date();
        //查看指挥端位置申请
        List<Map<String, Object>> resultCommanderPosition = new ArrayList();
        //查看车辆位置申请
        List<Map<String, Object>> resultSYCarsPosition = new ArrayList();
        for(Map<String, Object> map : ardAppApplicationList){
            /*if(((String)map.get("state")).equals("1")){
                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("Commander")){
                    resultCommanderPosition.add(map);
                }else if(((String)map.get("applicationType")).equals("SYCar")){
                    resultSYCarsPosition.add(map);
                }
            }else{
                map.put("time","");
                if(((String)map.get("applicationType")).equals("Commander")){
                    resultCommanderPosition.add(map);
                }else if(((String)map.get("applicationType")).equals("SYCar")){
                    resultSYCarsPosition.add(map);
                }
            }*/
            if(((String)map.get("applicationType")).equals("Commander")){
                resultCommanderPosition.add(map);
            }else if(((String)map.get("applicationType")).equals("SYCar")){
                resultSYCarsPosition.add(map);
            }
        }
        result.put("commander",resultCommanderPosition);
        result.put("SYCars",resultSYCarsPosition);
        return result;
    }

    @Override
    public int approvalCheckPositionOwn(String soilderId, Map<String, String> para) {
        String applicationType = para.get("applicationType");
        String commanderId = para.get("commanderId");
        int result = ardAppApplicationMapper.updateSoilderCheckByCommanderIdAndSoilderIdAndType(soilderId,commanderId,applicationType);
        return result;
    }

    @Override
    public List<Map<String, Object>> getCheckPositionNo(String commanderId) {///
        List<Map<String,Object>> ardAppApplicationList = ardAppApplicationMapper.selectArdAppApplicationByCommanderIdNoCheck(commanderId);
        Date date = new Date();
        for(Map<String, Object> map : ardAppApplicationList){
            if(((String)map.get("begin")).equals("")){
                map.put("time","");
            }else{
                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);
                Long second = (interval - hour * 60 * 60 * 1000 - min * 60 * 1000) / 1000;
                map.put("time",hour + "时" + min + "分" + second + "秒");
            }
        }
        return ardAppApplicationList;
    }
}