优化：获取会话

liusuyi

2024-08-08 57c673aa3e83677bcf5d30b4b45d06bae6609db8

 ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplSerialPort.java

@@ -14,24 +14,30 @@
import com.gps31.push.util.MapUtil;
import com.ruoyi.common.core.domain.entity.SysConfig;
import com.ruoyi.common.utils.spring.SpringUtils;
import com.ruoyi.common.utils.uuid.IdUtils;
import com.ruoyi.sy.domain.ArdSyCarLock;
import com.ruoyi.sy.domain.ArdSyCarRtu;
import com.ruoyi.sy.domain.ArdTankLock;
import com.ruoyi.sy.domain.ArdTankLockState;
import com.ruoyi.sy.service.ArdSyCarLockService;
import com.ruoyi.sy.service.ArdSyCarRtuService;
import com.ruoyi.sy.service.impl.ArdSyCarDayServiceImpl;
import com.ruoyi.sy.service.impl.ArdSyCarServiceImpl;
import com.ruoyi.sy.service.impl.ArdTankAbnormalParkAlarmServiceImpl;
import com.ruoyi.sy.service.impl.ArdTankLockServiceImpl;
import com.ruoyi.sy.service.impl.*;
import com.ruoyi.system.service.impl.SysConfigServiceImpl;
import com.ruoyi.utils.forest.SYClient;
import com.ruoyi.utils.qymqtt.newM.EmqClient;
import com.ruoyi.utils.qymqtt.newM.QosEnum;
import lombok.extern.slf4j.Slf4j;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import org.apache.commons.codec.digest.DigestUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.eclipse.paho.client.mqttv3.MqttException;

import java.io.IOException;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.*;

/**
@@ -41,73 +47,22 @@
 * @author chencq
 * @version 1.0
 */
@Slf4j(topic = "mqttCar")
public class PushClientImplSerialPort extends PushClient implements Runnable {

//    private static final Log log = LogFactory.getLog(PushClientImplPosition.class);
    private static final Log log = LogFactory.getLog(PushClientImplSerialPort.class);

    private String ip;
    private static String ip;

    private String userId;
    private static String userId;

    private String password;
    private static String password;

    private Timer lockStateTimer;
    private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    public PushClientImplSerialPort(String ip, String userId, String password) {
        this.ip = ip;
        this.userId = userId;
        this.password = password;

        /*Date date = new Date();
        this.lockStateTimer = new Timer();//定时获取各个锁的状态
        TimerTask lockStateTask =new TimerTask(){
            @Override
            public void run(){
                SysConfig config = new SysConfig();
                config.setConfigKey("syCarPT");
                List<SysConfig> sysConfigResult = ((SysConfigServiceImpl)SpringUtils.getBean("sysConfigServiceImpl")).selectConfigList(config);
                String syURL = "";

                if(sysConfigResult.size() == 0){//三一车辆加入开关
                    return;
                }else{
                    syURL = sysConfigResult.get(0).getConfigValue();
                }
                String passwordMd5 = DigestUtils.md5Hex(password);
                Map<String, Object> LogInResult = ((SYClient)SpringUtils.getBean("sYClient")).logIn(syURL, passwordMd5, userId);
                String sessionId = (String) LogInResult.get("sessionId");

                String finalSyURL = syURL;
                Thread thread = new Thread(finalSyURL){
                    @Override
                    public void run() {
                        List<ArdTankLock> result = ((ArdTankLockServiceImpl)SpringUtils.getBean("ardTankLockServiceImpl")).getArdTankLockAll();//查询全部电磁锁
                        for(ArdTankLock ardTankLock : result){
                            //Thread LockThread = new Thread(finalSyURL){
                                String lockNumHead = ardTankLock.getLockNum().substring(0,2);
                                String lockNumTail = ardTankLock.getLockNum().substring(2,4);
                                //计算校验
                                String checkNum = Integer.toHexString(Integer.parseInt(lockNumHead, 16) + Integer.parseInt(lockNumTail, 16) + Integer.parseInt("01", 16));

                                if(checkNum.length() == 1){
                                    checkNum = "0" + checkNum;
                                }else if(checkNum.length() > 2){
                                    checkNum = checkNum.substring(checkNum.length() - 2,checkNum.length());
                                }

                                String paramsStr = "%7B%22type%22%3A%22ff%22%2C%22dataCnt%22%3A%22" + ardTankLock.getLockNum() + "01" + checkNum + "%22%7D";

                               //Map<String,Object> result = ((SYClient)SpringUtils.getBean("sYClient")).sendCmd(finalSyURL,userId,ardTankLock.getCarId(),199,"DataDownTransfer", paramsStr,sessionId);
                            //};
                            //LockThread.start();
                        }
                    }
                };
                thread.start();
            }
        };
        lockStateTimer.scheduleAtFixedRate(lockStateTask,date,1000);*/
    }

    public PushClientImplSerialPort() {
@@ -151,8 +106,216 @@
             */
        }else if("0401".equals(pushMsg.getCmd())) {//透传消息
            Map<String,Object> dataMap = pushMsg.getJsonMap();
            String carName = MapUtil.getStrVal(dataMap, "carName","");//获取车牌号
            //String carName = MapUtil.getStrVal(dataMap, "carName","");//获取车牌号
            //log.error(String.format("   ---->收到透传数据:%s",JSON.toJSONString(dataMap)));
            Thread thread = new Thread(){
                @Override
                public void run() {
                    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                    Date now = new Date();
                    try {
                        String data = (String) dataMap.get("data");
                        if(data.length() %2 != 0){//长度不是偶数，就返回
                            return;
                        }

                        Integer sum = 0;
                        for(int i = 0;i <= data.length() - 4;i = i + 2){
                            String str = data.substring(i, i + 2);
                            sum = sum + Integer.parseInt(str, 16);
                        }//求和
                        String checkNum = data.substring(data.length() - 2, data.length());
                        String checkNumComputed = Integer.toHexString(sum).toUpperCase();//计算校验
                        //当校验数据大于2个字符，截取最后两位
                        if(checkNumComputed.length() != 2){
                            checkNumComputed = checkNumComputed.substring(checkNumComputed.length() - 2,checkNumComputed.length());
                        }
                        if(!checkNum.equals(checkNumComputed)){//校验不通过，就返回
                            return;
                        }

                        String lockNum = data.substring(0, 4);
                        String code = data.substring(4, 6);
                        if(code.equals("01")){//功能码01为锁实时状态
                            String lockState = data.substring(6, 8);
                            String lockPositionState = data.substring(8, 10);
                            String lockShellState = data.substring(10, 12);
                            String restartState = data.substring(12, 14);
                            String batterVoltage = data.substring(14, 18);
                            String powerVoltage = data.substring(18, 22);
                            //String time = data.substring(22, 34);
                            String time = sdf.format(new Date());

                            ArdTankLock ardTankLock = new ArdTankLock();
                            ardTankLock.setLockNum(lockNum);
                            List<ArdTankLock> ardTankLockResult = ((ArdTankLockServiceImpl)SpringUtils.getBean("ardTankLockServiceImpl")).selectArdTankLockList(ardTankLock);

                            if(ardTankLockResult.isEmpty()){//锁没有录入则返回
                                return;
                            }

                            ArdTankLockState ardTankLockState = new ArdTankLockState();
                            ardTankLockState.setId(IdUtils.simpleUUID());
                            ardTankLockState.setLockId(ardTankLockResult.get(0).getId());
                            ardTankLockState.setLockNum(lockNum);
                            switch (lockState) {//锁芯状态
                                case "01": ardTankLockState.setLockState("开锁状态");break;
                                case "02": ardTankLockState.setLockState("关锁状态");break;
                                case "03": ardTankLockState.setLockState("异常状态");break;
                                case "04": ardTankLockState.setLockState("操控中...");break;
                                default:
                                    break;
                            }
                            switch (lockPositionState) {//位置状态
                                case "01": ardTankLockState.setLockPositionState("正常");break;
                                case "02": ardTankLockState.setLockPositionState("异常");break;
                                default:
                                    break;
                            }
                            switch (lockShellState) {//外壳状态
                                case "01": ardTankLockState.setLockShellState("正常");break;
                                case "02": ardTankLockState.setLockShellState("异常");break;
                                default:
                                    break;
                            }
                            switch (restartState) {//复位状态
                                case "01": ardTankLockState.setRestartState("开锁状态");break;
                                case "02": ardTankLockState.setRestartState("关锁状态");break;
                                default:
                                    break;
                            }
                            Number batterVoltageNum = Integer.parseInt(batterVoltage,16) * 0.1;
                            String batterVoltageStr = String.valueOf(batterVoltageNum);
                            if(batterVoltageStr.length() > 4){
                                batterVoltageStr = batterVoltageStr.substring(0,4);
                            }
                            if(batterVoltageStr.contains(".")){//四舍五入
                                String decimalPart = batterVoltageStr.split("\\.")[1];
                                if(Integer.parseInt(decimalPart) > 5){
                                    batterVoltageStr = batterVoltageStr.split("\\.")[0] + ".5";
                                }else if(Integer.parseInt(decimalPart) <= 5){
                                    batterVoltageStr = batterVoltageStr.split("\\.")[0] + ".0";
                                }
                            }else{
                                batterVoltageStr = batterVoltageStr + ".0";
                            }
                            ardTankLockState.setBatterVoltage(batterVoltageStr);


                            Number powerVoltageNum = Integer.parseInt(powerVoltage,16) * 0.1;
                            String powerVoltageStr = String.valueOf(powerVoltageNum);
                            if(powerVoltageStr.length() > 4){
                                powerVoltageStr = powerVoltageStr.substring(0,4);
                            }
                            if(powerVoltageStr.contains(".")){//四舍五入
                                String decimalPart = powerVoltageStr.split("\\.")[1];
                                if(Integer.parseInt(decimalPart) > 5){
                                    powerVoltageStr = powerVoltageStr.split("\\.")[0] + ".5";
                                }else if(Integer.parseInt(decimalPart) <= 5){
                                    powerVoltageStr = powerVoltageStr.split("\\.")[0] + ".0";
                                }
                            }else{
                                powerVoltageStr = powerVoltageStr + ".0";
                            }
                            ardTankLockState.setPowerVoltage(powerVoltageStr);

                            String uniqueMark = lockNum + "," + lockState + "," + lockPositionState + "," + lockShellState
                                    + "," + restartState + "," + batterVoltageStr + "," + powerVoltageStr;

                            ardTankLockState.setUploadTime(time);
                            ardTankLockState.setUniqueMark(uniqueMark);
                            ((ArdTankLockStateServiceImpl)SpringUtils.getBean("ardTankLockStateServiceImpl")).insertOrUpdateArdTankLockState(ardTankLockState);
                        }else if(code.equals("05")){//功能码05为读取锁密码
                            Set<String> passwordAndTimeSet = new HashSet();
                            for(int i = 1;i <= 10;i++){
                                String passwordAndTime = data.substring(6 + 24*(i - 1),6 + 24 * i);
                                passwordAndTimeSet.add(passwordAndTime);//拆分出密码和使用时间
                            }
                            if(passwordAndTimeSet.size() == 1){//全部为初始密码，则从新设置
                                Set<String> passwordSet = new HashSet();
                                while(passwordSet.size() != 10){
                                    String password = "";
                                    for(int i = 0;i <= 5;i++){
                                        password = password + String.valueOf(10 * Math.random()).split("\\.")[0];
                                    }
                                    passwordSet.add(password);
                                }
                                if(PositionContainer.getCarLockPasswordMap().get(lockNum) == null){
                                    PositionContainer.getCarLockPasswordMap().put(lockNum,passwordSet);
                                }
                            }else{//查看哪些密码使用过
                                for(String passwordAndTime : passwordAndTimeSet){
                                    String time = passwordAndTime.substring(12,24);
                                    if(!time.equals("FFFFFFFFFFFF")){
                                        String passwordHex = passwordAndTime.substring(0,12);//16进制密码
                                        String password = "";//实际密码
                                        for(int i = 0;i <= 10;i = i + 2){
                                            String passwordHexByte = passwordHex.substring(i, i+2);
                                            password = password + passwordHexByte.split("")[1];
                                        }

                                        String useTimeHex = passwordAndTime.substring(12,24);//16进制时间
                                        String yearHex = useTimeHex.substring(0, 2);
                                        String monthHex = useTimeHex.substring(2, 4);
                                        String dayHex = useTimeHex.substring(4, 6);
                                        String hourHex = useTimeHex.substring(6, 8);
                                        String minuteHex = useTimeHex.substring(8, 10);
                                        String secondHex = useTimeHex.substring(10, 12);

                                        String useTime = "";
                                        Integer yearNum = Integer.parseInt(yearHex, 16);
                                        if(yearNum <= 9){
                                            useTime = "200" + yearNum + "-";
                                        }else{
                                            useTime = "20" + yearNum + "-";
                                        }

                                        Integer monthNum = Integer.parseInt(monthHex, 16);
                                        if(monthNum <= 9){
                                            useTime = useTime + "0" + monthNum + "-";
                                        }else{
                                            useTime = useTime + monthNum + "-";
                                        }

                                        Integer dayNum = Integer.parseInt(dayHex, 16);
                                        if(dayNum <= 9){
                                            useTime = useTime + "0" + dayNum + " ";
                                        }else{
                                            useTime = useTime + dayNum + " ";
                                        }

                                        Integer hourNum = Integer.parseInt(hourHex, 16);
                                        if(hourNum <= 9){
                                            useTime = useTime + "0" + hourNum + ":";
                                        }else{
                                            useTime = useTime + hourNum + ":";
                                        }

                                        Integer minuteNum = Integer.parseInt(minuteHex, 16);
                                        if(minuteNum <= 9){
                                            useTime = useTime + "0" + minuteNum + ":";
                                        }else{
                                            useTime = useTime + minuteNum + ":";
                                        }

                                        Integer secondNum = Integer.parseInt(secondHex, 16);
                                        if(secondNum <= 9){
                                            useTime = useTime + "0" + secondNum;
                                        }else{
                                            useTime = useTime + secondNum;
                                        }
                                        ((ArdTankLockPasswordServiceImpl)SpringUtils.getBean("ardTankLockPasswordServiceImpl")).updateArdTankLockPasswordByLockNum(lockNum,password,useTime);
                                    }
                                }
                            }
                        }
                    }catch (Exception e){
                        e.printStackTrace();
                        return;//强转失败返回
                    }
                }
            };
            thread.start();
            /**
             *
             * 请加入三方集成方的业务逻辑
@@ -164,7 +327,7 @@
    public void sendMassage() {
        try {
            PushClientImplSerialPort client = new PushClientImplSerialPort();
            client.setLog(true);//是否打印明文
            client.setLog(false);//是否打印明文
            client.setHost(this.ip);//服务器IP
            client.setPort(10100);//服务器端口
            client.setUserName(this.userId);//系统用户名
@@ -185,4 +348,65 @@
        sendMassage();
    }

    public static Map<String,Object> loginIn(String syURL,String userId,String password){//登录
        OkHttpClient okHttpClient = new OkHttpClient();

        String passwordMd5 = DigestUtils.md5Hex(password);

        Request request = new Request.Builder()
                .url(syURL + "/gps-web/api/login.jsp?"+"password="+passwordMd5+"&userId="+userId+"&loginType=user&loginWay=interface&loginLang=zh_CN")
                .build();
        Response response = null;
        try {
            response = okHttpClient.newCall(request).execute();
        } catch (IOException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        }

        response.headers(); //响应头

        okhttp3.ResponseBody responseBody = response.body();

        try {
            String message = responseBody.string();// 响应体
            Map<String,Object> map = (Map<String, Object>) JSON.parse(message);
            map.put("passwordMd5", passwordMd5);
            //System.out.println(message);
            return map;
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return new HashMap();
        }
    }

    public Map<String,Object> sendCmd(String syURL,String userId,String carId,Integer cmdId,String cmd,String paramsStr,String sessionId){
        OkHttpClient okHttpClient = new OkHttpClient();

        Request request = new Request.Builder()
                .url(syURL + "/gps-web/api/send_cmd.jsp?params="+paramsStr+"&userId="+userId+"&carId="+carId+"&cmdId="+cmdId+"&cmd="+cmd+"&sessionId="+sessionId)
                .build();
        //System.out.println("url = " + syURL + "/gps-web/api/send_cmd.jsp?params="+paramsStr+"&userId="+userId+"&carId="+carId+"&cmdId="+cmdId+"&cmd="+cmd+"&sessionId="+sessionId);
        Response response = null;
        try {
            response = okHttpClient.newCall(request).execute();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        okhttp3.ResponseBody responseBody = response.body();

        try {
            String message = responseBody.string();// 响应体
            Map<String,Object> map = (Map<String, Object>) JSON.parse(message);
            return map;
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return new HashMap();
        }
    }

}