ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarLockController.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarLockServiceImpl.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
ard-work/src/main/java/com/ruoyi/sy/vo/CarVo.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
ard-work/src/main/java/com/ruoyi/sy/vo/RtuVo.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
ard-work/src/main/java/com/ruoyi/utils/data/Query.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarLockController.java
@@ -98,6 +98,9 @@ carLockVo.setCar(carVo); String rtu = carVo.getRtu(); carLockVo.setCarLockList(ardSyCarLockService.carLock(rtu)); ArdSyCarRtu ardSyCarRtu = ardSyCarRtuService.one(carId); carVo.setInstallType(ardSyCarRtu.getInstallType()); carVo.setUnloadType(ardSyCarRtu.getUnloadType()); return AjaxResult.success(carLockVo); } @@ -115,9 +118,9 @@ return Results.succeed("成功添加/修改"+ardSyCarLockService.addUpdLock(locks)+"条数据"); } @GetMapping("/onrRtu") @GetMapping("/oneRtu") @ApiOperation("更改Rtu前查询") public Results onrRtu(String carId){ public Results oneRtu(String carId){ RtuVo rtuVo = ardSyCarLockService.updRtu(carId); String usersId = SecurityUtils.getUserId(); ArdSyUser ardSyUser = iArdSyUserService.userById(usersId); ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java
@@ -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); } break; } } }else { //车速标记 Boolean stop = true; //判断车速 if(speed>5){ //mqtt发送既定Rtu状态 feng(carId,"施封",carRtuService,lockService); stop = false; } //带锁车辆有值优先判断是否为手动添加车辆 if(ardAccessFence.getIsAlarm()==1){ //1为手动添加车辆无需报警信息,更新位置即可 @@ -458,8 +456,7 @@ //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);//导通第二路继电器 @@ -474,9 +471,10 @@ // mqttOnce.publishCar(carId,ardSyCarRtu.getTopicPublish(),String.valueOf(new JSONObject(map)),"解封"); } } } //0施封 if(fengType==0){ 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())+"\"}"; @@ -537,3 +535,4 @@ } } } } ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarLockServiceImpl.java
@@ -177,6 +177,8 @@ rtuVo.setRtu(ardSyCar.getReserved1()); rtuVo.setTopicPublish(ardSyCarRtu.getTopicPublish()); rtuVo.setTopicSubscribe(ardSyCarRtu.getTopicSubscribe()); rtuVo.setInstallType(ardSyCarRtu.getInstallType()); rtuVo.setUnloadType(ardSyCarRtu.getUnloadType()); return rtuVo; } ard-work/src/main/java/com/ruoyi/sy/vo/CarVo.java
@@ -17,4 +17,6 @@ private String deptId; private String deptName; private String rtu; private Integer installType; //装油点 0施封 1解封 private Integer unloadType; //卸油点 0施封 1解封 } ard-work/src/main/java/com/ruoyi/sy/vo/RtuVo.java
@@ -15,4 +15,6 @@ private String rtu; private String topicPublish; private String topicSubscribe; private Integer installType; //装油点 0施封 1解封 private Integer unloadType; //卸油点 0施封 1解封 } ard-work/src/main/java/com/ruoyi/utils/data/Query.java
@@ -70,16 +70,11 @@ rtu_data_yj_8.setZHS(rs.getInt("ZHS")); dataBridgeList.add(rtu_data_yj_8); } conn.close(); return dataBridgeList; } catch (Exception e) { log.error("设备运行状态查询异常:" + e.getMessage()); return dataBridgeList; } finally { try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } }