mq

aijinhui

2023-12-16 c1d388bdd237aa3418d072a68234259e35ea93e5

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

@@ -78,7 +78,7 @@
            /*String carName = MapUtil.getStrVal(gpsMap, "carName","");//获取车牌号
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            System.out.println(sdf.format(new Date()));*/
            log.info(String.format("   ---->收到定位数据:%s",JSON.toJSONString(gpsMap)));
//            log.info(String.format("   ---->收到定位数据:%s",JSON.toJSONString(gpsMap)));
            String carId = (String)gpsMap.get("carId");

            ((ArdSyCarDayServiceImpl)SpringUtils.getBean("ardSyCarDayServiceImpl")).insertArdSyCarDay(carId);//新增车辆上报时间
@@ -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){
                        //车辆未进入装油点
@@ -146,20 +138,26 @@
                                ardAccessFence1.setLng(lng);
                                ardAccessFence1.setLat(lat);
                                ardAccessFence1.setLastTime(time);
                                ardAccessFence1.setNowWallName(ardOilWall.getName());
                                ardAccessFence1.setNowWallName("进入装油点："+ardOilWall.getName());
                                ardAccessFence1.setCarModel(carModel);
                                ardAccessFence1.setIsWarning(0);
                                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为手动添加车辆无需报警信息，更新位置即可
@@ -210,7 +208,7 @@
                                        //进入装油点入库
                                        ardAccessFence.setIntoShipmentId(ardOilWall.getId());
                                        ardAccessFence.setIntoShipmentTime(time);
                                        ardAccessFence.setNowWallName(ardOilWall.getName());
                                        ardAccessFence.setNowWallName("进入装油点："+ardOilWall.getName());
                                        ardAccessFence.setLastTime(time);
                                        if(stop){
                                            //mqtt发送既定Rtu状态
@@ -237,7 +235,7 @@
                                        //车辆开出装油点
                                        ardAccessFence.setOutShipmentId(into);
                                        ardAccessFence.setOutShipmentTime(time);
                                        ardAccessFence.setNowWallName(ardOilWall.getName());
                                        ardAccessFence.setNowWallName("开出装油点："+ardOilWall.getName());
                                        ardAccessFence.setLastTime(time);
                                        ardAccessFence.setLng(lng);
                                        ardAccessFence.setLat(lat);
@@ -268,7 +266,7 @@
                                                ardAccessFence.setIntoUnloadTime(time);
                                                ardAccessFence.setLng(lng);
                                                ardAccessFence.setLat(lat);
                                                ardAccessFence.setNowWallName(ardOilWall.getName());
                                                ardAccessFence.setNowWallName("进入卸油点："+ardOilWall.getName());
                                                ardAccessFence.setLastTime(time);
                                                ardAccessFenceService.updAccess(ardAccessFence);
                                                //已经进入卸油点，不在路上不需要停车报警
@@ -283,22 +281,27 @@
                                        //不在卸油点就是在路上
                                        if(isRoad){
                                            //所在围栏名称赋null
                                            ardAccessFence.setNowWallName(null);
                                            ardAccessFence.setNowWallName("在路上");
                                            //如果在路上判断坐标是否与上次一样
                                            if(ardAccessFence.getLng().equals(lng) && ardAccessFence.getLat().equals(lat)){
                                                //如果坐标一样相减
                                                Date nowTime = sdf.parse(time);
                                                Date lastTime = sdf.parse(ardAccessFence.getLastTime());
                                                Long diff = (nowTime.getTime() - lastTime.getTime())/1000;
                                                ArdAccessNum list = accessNumService.queryNum();
                                                if(list==null){
                                                    int alarm = list.getAlarm();
                                                    if(diff>=alarm){
                                                        ardAccessFence.setIsWarning(1);
                                                        ardAccessFence.setAlarmLat(lat);
                                                        ardAccessFence.setAlarmLng(lng);
                                                        ardAccessFenceService.updAccess(ardAccessFence);
                                                if(ardAccessFence.getLastTime()!=null){
                                                    //如果坐标一样相减
                                                    Date nowTime = sdf.parse(time);
                                                    Date lastTime = sdf.parse(ardAccessFence.getLastTime());
                                                    Long diff = (nowTime.getTime() - lastTime.getTime())/1000;
                                                    ArdAccessNum list = accessNumService.queryNum();
                                                    if(list==null){
                                                        int alarm = list.getAlarm();
                                                        if(diff>=alarm){
                                                            ardAccessFence.setIsWarning(1);
                                                            ardAccessFence.setAlarmLat(lat);
                                                            ardAccessFence.setAlarmLng(lng);
                                                            ardAccessFenceService.updAccess(ardAccessFence);
                                                        }
                                                    }
                                                }else {
                                                    ardAccessFence.setLastTime(time);
                                                    ardAccessFenceService.updAccess(ardAccessFence);
                                                }
                                            }else {
                                                //如果不一样更新坐标
@@ -453,71 +456,78 @@
                //1解封
                if(fengType==1){
                    //如果不是解封封状态，则发送施封命令
                    if(ardSyCarLocks.get(0).getRelayInfo()!=null){
                        if(ardSyCarLocks.get(0).getRelayInfo()==0){
                            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);
                            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)),"解封");
                        }
                    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.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";
                                    }
                                    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);
                                    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(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.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){
                                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);
                                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)),"施封");
                                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);
                                    log.debug("车辆"+carId+"施封命令发送成功！");
                                    //                    mqttOnce.publishCar(carId,ardSyCarRtu.getTopicPublish(),String.valueOf(new JSONObject(map)),"施封");
                                }
                            }
                        }
                    }