aijinhui
2023-11-13 f22a5485cbe6563447ace9cf7939405f7e06c6a6
ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java
@@ -137,6 +137,27 @@
                            ardAccessFence1.setDrct(drct);
                            ardAccessFence1.setIsAlarm(0);
                            ardAccessFenceService.access(ardAccessFence1);
                            //查询装油点既定Rtu状态
                            ArdSyCarRtu ardSyCarRtu = carRtuService.one(carId);
                            Integer installType = ardSyCarRtu.getInstallType();
                            //1解封
                            if(installType==1){
                                Map<String,Object> map = new HashMap<>();
                                map.put("A01", 110000);//导通第一路继电器
                                map.put("A02", 110000);//导通第二路继电器
                                map.put("res", String.valueOf(System.currentTimeMillis()));
                                MqttConsumer.publish(ardSyCarRtu.getTopicPublish(), String.valueOf(new JSONObject(map)));
                            }
                            //0施封
                            if(installType==0){
//关锁
                                Map<String,Object> map = new HashMap<>();
                                map.put("A01", 100000);//断开第一路继电器
                                map.put("A02", 100000);//断开第二路继电器
                                map.put("res", String.valueOf(System.currentTimeMillis()));
                                MqttConsumer.publish(ardSyCarRtu.getTopicPublish(), String.valueOf(new JSONObject(map)));
                            }
                            break;
                        }
                    }
@@ -195,6 +216,27 @@
                                    ardAccessFence.setIntoShipmentTime(time);
                                    ardAccessFence.setNowWallName(ardOilWall.getName());
                                    ardAccessFence.setLastTime(time);
                                    //查询装油点既定Rtu状态
                                    ArdSyCarRtu ardSyCarRtu = carRtuService.one(carId);
                                    Integer installType = ardSyCarRtu.getInstallType();
                                    //1解封
                                    if(installType==1){
                                        Map<String,Object> map = new HashMap<>();
                                        map.put("A01", 110000);//导通第一路继电器
                                        map.put("A02", 110000);//导通第二路继电器
                                        map.put("res", String.valueOf(System.currentTimeMillis()));
                                        MqttConsumer.publish(ardSyCarRtu.getTopicPublish(), String.valueOf(new JSONObject(map)));
                                    }
                                    //0施封
                                    if(installType==0){
//关锁
                                        Map<String,Object> map = new HashMap<>();
                                        map.put("A01", 100000);//断开第一路继电器
                                        map.put("A02", 100000);//断开第二路继电器
                                        map.put("res", String.valueOf(System.currentTimeMillis()));
                                        MqttConsumer.publish(ardSyCarRtu.getTopicPublish(), String.valueOf(new JSONObject(map)));
                                    }
                                    break;
                                }
                            }
@@ -221,10 +263,15 @@
                                    ardAccessFence.setLng(lng);
                                    ardAccessFence.setLat(lat);
                                    ardAccessFenceService.updAccess(ardAccessFence);
//开出装油点围栏,发送上锁及施封命令
                                    //开出装油点围栏,发送上锁及施封命令
                                    ArdSyCarRtu ardSyCarRtu = carRtuService.one(carId);
//关锁
                                    Map<String,Object> map = new HashMap<>();
                                    map.put("A01", 100000);//断开第一路继电器
                                    map.put("A02", 100000);//断开第二路继电器
                                    map.put("res", String.valueOf(System.currentTimeMillis()));
                                    MqttConsumer.publish(ardSyCarRtu.getTopicPublish(), String.valueOf(new JSONObject(map)));
                                }
                            }else {
@@ -255,6 +302,27 @@
                                            ardAccessFenceService.updAccess(ardAccessFence);
                                            //已经进入卸油点,不在路上不需要停车报警
                                            isRoad = false;
                                            //查询装油点既定Rtu状态
                                            ArdSyCarRtu ardSyCarRtu = carRtuService.one(carId);
                                            Integer unloadType = ardSyCarRtu.getUnloadType();
                                            //1解封
                                            if(unloadType==1){
                                                Map<String,Object> map = new HashMap<>();
                                                map.put("A01", 110000);//导通第一路继电器
                                                map.put("A02", 110000);//导通第二路继电器
                                                map.put("res", String.valueOf(System.currentTimeMillis()));
                                                MqttConsumer.publish(ardSyCarRtu.getTopicPublish(), String.valueOf(new JSONObject(map)));
                                            }
                                            //0施封
                                            if(unloadType==0){
//关锁
                                                Map<String,Object> map = new HashMap<>();
                                                map.put("A01", 100000);//断开第一路继电器
                                                map.put("A02", 100000);//断开第二路继电器
                                                map.put("res", String.valueOf(System.currentTimeMillis()));
                                                MqttConsumer.publish(ardSyCarRtu.getTopicPublish(), String.valueOf(new JSONObject(map)));
                                            }
                                            break;
                                        }
                                    }
@@ -296,10 +364,15 @@
                                        pts.add(new Point2D.Double(Double.parseDouble(coord[j]), Double.parseDouble(coord[j + 1])));
                                    }
                                    if (!GeoTools.IsPtInPoly(point, pts)) {
//开出了卸油点围栏,发送上锁及施解封指令
                                        //开出了卸油点围栏,发送上锁及施解封指令
                                        ArdSyCarRtu ardSyCarRtu = carRtuService.one(carId);
//关锁
                                        Map<String,Object> map = new HashMap<>();
                                        map.put("A01", 100000);//断开第一路继电器
                                        map.put("A02", 100000);//断开第二路继电器
                                        map.put("res", String.valueOf(System.currentTimeMillis()));
                                        MqttConsumer.publish(ardSyCarRtu.getTopicPublish(), String.valueOf(new JSONObject(map)));
                                        //删除该条车辆数据
                                        ardAccessFenceService.delAccess(carId);
                                    }else {