mq

aijinhui

2023-12-16 c1d388bdd237aa3418d072a68234259e35ea93e5

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

@@ -95,7 +95,7 @@
                    String carModel = (String) result.get("carModel");//获取车辆模型
                    Integer drct = (Integer) gpsMap.get("drct");//获取车辆模型
                    Integer speed = (Integer) gpsMap.get("speed");
                    log.info("定位数据：carId:"+carId+"lng:"+lng+"lat:"+lat);
                    log.debug("定位数据：carId:"+carId+"lng:"+lng+"lat:"+lat);
                    //定义2维空间
                    Point2D.Double point = new Point2D.Double(Double.parseDouble(lng), Double.parseDouble(lat));
                    List<Point2D.Double> pts = new ArrayList<Point2D.Double>();
@@ -115,14 +115,6 @@
                    List<ArdOilWall> ardOilWalls = ardOilWallService.accessAll();
                    //日期格式
                    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                    //车速标记
                    Boolean stop = true;
                    //判断车速
                    if(speed>5){
                        //mqtt发送既定Rtu状态
                        feng(carId,"施封",carRtuService,lockService);
                        stop = false;
                    }
                    //如果没有说明车辆未进入装油点，需要匹配所有装油点围栏
                    if(ardAccessFence==null){
                        //车辆未进入装油点
@@ -152,14 +144,20 @@
                                ardAccessFence1.setDrct(drct);
                                ardAccessFence1.setIsAlarm(0);
                                ardAccessFenceService.access(ardAccessFence1);
                                if(stop){
                                    //mqtt发送既定Rtu状态
                                    feng(carId,"装油点",carRtuService,lockService);
                                }
                                //mqtt发送既定Rtu状态
                                feng(carId,"装油点",carRtuService,lockService);
                                break;
                            }
                        }
                    }else {
                        //车速标记
                        Boolean stop = true;
                        //判断车速
                        if(speed>5){
                            //mqtt发送既定Rtu状态
                            feng(carId,"施封",carRtuService,lockService);
                            stop = false;
                        }
                        //带锁车辆有值优先判断是否为手动添加车辆
                        if(ardAccessFence.getIsAlarm()==1){
                            //1为手动添加车辆无需报警信息，更新位置即可
@@ -458,77 +456,78 @@
                //1解封
                if(fengType==1){
                    //如果不是解封封状态，则发送施封命令
                    if(ardSyCarLocks.get(0).getRelayInfo()!=null){
                        if(ardSyCarLocks.get(0).getRelayInfo()==0){
                    if(ardSyCarLocks.get(0).getRelayInfo()==0 || ardSyCarLocks.get(0).getRelayInfo()==null){
//                            Map<String,Object> map = new HashMap<>();
//                            map.put("A01", 110000);//导通第一路继电器
//                            map.put("A02", 110000);//导通第二路继电器
//                            map.put("res", String.valueOf(System.currentTimeMillis()));
//                            String mapString = com.alibaba.fastjson.JSON.toJSONString(map);
                            String mapString = "{\"A01\":110000,\"A02\":110000,\"res\":\""+String.valueOf(System.currentTimeMillis())+"\"}";
                            log.info("自动解封："+mapString);
                            EmqClient emqClient = new EmqClient(carId+"mqttPublish"+UUID.randomUUID());
                            emqClient.connect();
                            emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);
                            log.info("车辆"+carId+"解封命令发送成功！");
                            //                mqttOnce.publishCar(carId,ardSyCarRtu.getTopicPublish(),String.valueOf(new JSONObject(map)),"解封");
                        }
                        String mapString = "{\"A01\":110000,\"A02\":110000,\"res\":\""+String.valueOf(System.currentTimeMillis())+"\"}";
                        log.debug("自动解封："+mapString);
                        EmqClient emqClient = new EmqClient(carId+"mqttPublish"+UUID.randomUUID());
                        emqClient.connect();
                        emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);
                        log.debug("车辆"+carId+"解封命令发送成功！");
                        //                mqttOnce.publishCar(carId,ardSyCarRtu.getTopicPublish(),String.valueOf(new JSONObject(map)),"解封");
                    }
                }

                //0施封
                if(fengType==0){
                    //锁开关状态
                    int lockCloseNum = 0;
                    //如果不是施封状态，则发送施封命令
                    if(ardSyCarLocks.get(0).getRelayInfo()!=null){
                        if(ardSyCarLocks.get(0).getRelayInfo()==1){
                            for (int j = 0; j < ardSyCarLocks.size(); j++) {
                                ArdSyCarLock ardSyCarLock = ardSyCarLocks.get(j);
                                String currents = ardSyCarLock.getCurrents();
                                Double currentInfo = ardSyCarLock.getCurrentInfo();
                                //电流值为4.0是关锁状态
                                if(currentInfo.equals(4.00) || currentInfo.equals(4)){
                                    lockCloseNum += 1;
                                }else {
                                    String key = "";
                                    if(currents.equals("C01")){
                                        key = "D03";
                                    }else if(currents.equals("C02")){
                                        key = "D04";
                                    }
                    if(ardSyCarLocks.get(0).getRelayInfo()==1 || ardSyCarLocks.get(0).getRelayInfo()==null){
                        //锁开关状态
                        int lockCloseNum = 0;
                        String mapString1 = "{\"A01\":100000,\"A02\":100000,\"res\":\""+String.valueOf(System.currentTimeMillis())+"\"}";
                        System.out.println("自动施封："+mapString1);
                        EmqClient emqClient1 = new EmqClient(carId+"mqttPublish"+UUID.randomUUID());
                        emqClient1.connect();
                        emqClient1.publish(ardSyCarRtu.getTopicPublish(),mapString1, QosEnum.QoS2,false);
                        //如果不是施封状态，则发送施封命令
                        if(ardSyCarLocks.get(0).getRelayInfo()!=null){
                            if(ardSyCarLocks.get(0).getRelayInfo()==1){
                                for (int j = 0; j < ardSyCarLocks.size(); j++) {
                                    ArdSyCarLock ardSyCarLock = ardSyCarLocks.get(j);
                                    String currents = ardSyCarLock.getCurrents();
                                    Double currentInfo = ardSyCarLock.getCurrentInfo();
                                    //电流值为4.0是关锁状态
                                    if(currentInfo.equals(4.00) || currentInfo.equals(4)){
                                        lockCloseNum += 1;
                                    }else {
                                        String key = "";
                                        if(currents.equals("C01")){
                                            key = "D03";
                                        }else if(currents.equals("C02")){
                                            key = "D04";
                                        }
//                                    Map<String,Object> map = new HashMap();
//                                    map.put(key, 0.01);
//                                    map.put("res", String.valueOf(System.currentTimeMillis()));
//                                    String mapString = com.alibaba.fastjson.JSON.toJSONString(map);
                                    String mapString = "{\""+key+"\":0.01,\"res\":\""+String.valueOf(System.currentTimeMillis())+"\"}";
                                    log.info("自动关锁："+mapString);
                                    EmqClient emqClient = new EmqClient(carId+"mqttPublish"+UUID.randomUUID());
                                    emqClient.connect();
                                    emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);
                                    //                        mqttOnce.publishCar("carId",ardSyCarRtu.getTopicPublish(),String.valueOf(new JSONObject(map)),"开锁："+currents);
                                    while(true){
                                        ArdSyCarLock ardSyCarLock1 = lockService.getCurrentInfo(ardSyCarRtu.getId(),currents);
                                        Double currentInfo1 = ardSyCarLock1.getCurrentInfo();
                                        if(currentInfo1.equals(4.00) || currentInfo1.equals(4)){
                                            lockCloseNum +=1;
                                            break;
                                        String mapString = "{\""+key+"\":0.01,\"res\":\""+String.valueOf(System.currentTimeMillis())+"\"}";
                                        log.debug("自动关锁："+mapString);
                                        EmqClient emqClient = new EmqClient(carId+"mqttPublish"+UUID.randomUUID());
                                        emqClient.connect();
                                        emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);
                                        //                        mqttOnce.publishCar("carId",ardSyCarRtu.getTopicPublish(),String.valueOf(new JSONObject(map)),"开锁："+currents);
                                        while(true){
                                            ArdSyCarLock ardSyCarLock1 = lockService.getCurrentInfo(ardSyCarRtu.getId(),currents);
                                            Double currentInfo1 = ardSyCarLock1.getCurrentInfo();
                                            if(currentInfo1.equals(4.00) || currentInfo1.equals(4)){
                                                lockCloseNum +=1;
                                                break;
                                            }
                                        }
                                    }
                                }
                            }
                            if(lockCloseNum == 2){
                                if(lockCloseNum == 2){
//                                Map<String,Object> map = new HashMap<>();
//                                map.put("A01", 100000);//断开第一路继电器
//                                map.put("A02", 100000);//断开第二路继电器
//                                map.put("res", String.valueOf(System.currentTimeMillis()));
//                                String mapString = com.alibaba.fastjson.JSON.toJSONString(map);
                                String mapString = "{\"A01\":100000,\"A02\":100000,\"res\":\""+String.valueOf(System.currentTimeMillis())+"\"}";
                                System.out.println("自动施封："+mapString);
                                EmqClient emqClient = new EmqClient(carId+"mqttPublish"+UUID.randomUUID());
                                emqClient.connect();
                                emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);
                                log.info("车辆"+carId+"施封命令发送成功！");
                                //                    mqttOnce.publishCar(carId,ardSyCarRtu.getTopicPublish(),String.valueOf(new JSONObject(map)),"施封");
                                    log.debug("车辆"+carId+"施封命令发送成功！");
                                    //                    mqttOnce.publishCar(carId,ardSyCarRtu.getTopicPublish(),String.valueOf(new JSONObject(map)),"施封");
                                }
                            }
                        }
                    }