From 92dba8e44a911c92832ecc22e4c98968409d5c68 Mon Sep 17 00:00:00 2001 From: aijinhui <aijinhui> Date: 星期二, 14 十一月 2023 15:01:37 +0800 Subject: [PATCH] 远程封印 --- ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarLockServiceImpl.java | 13 +++++++------ 1 files changed, 7 insertions(+), 6 deletions(-) diff --git a/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarLockServiceImpl.java b/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarLockServiceImpl.java index 6f80f7c..0dd636a 100644 --- a/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarLockServiceImpl.java +++ b/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarLockServiceImpl.java @@ -12,6 +12,7 @@ import com.ruoyi.sy.mapper.ArdSyCarRtuMapper; import com.ruoyi.sy.param.AddRtuParam; import com.ruoyi.sy.param.LockTypeParam; +import com.ruoyi.sy.param.RtuTypeParam; import com.ruoyi.sy.service.ArdSyCarLockService; import com.ruoyi.sy.vo.CarVo; import com.ruoyi.sy.vo.RtuVo; @@ -228,25 +229,25 @@ } @Override - public AjaxResult seal(LockTypeParam lockTypeParam) { + public AjaxResult seal(RtuTypeParam rtuTypeParam) { QueryWrapper<ArdSyCarRtu> queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("carId",lockTypeParam.getCarId()); + queryWrapper.eq("carId",rtuTypeParam.getCarId()); ArdSyCarRtu ardSyCarRtu = rtuMapper.selectOne(queryWrapper); MqttOnce mqttOnce = new MqttOnce(); //1瑙e皝 - if(lockTypeParam.getType()==1){ + if(rtuTypeParam.getType()==1){ Map<String,Object> map = new HashMap<>(); map.put("A01", 110000);//瀵奸�氱涓�璺户鐢靛櫒 map.put("A02", 110000);//瀵奸�氱浜岃矾缁х數鍣� map.put("res", String.valueOf(System.currentTimeMillis())); try { - return AjaxResult.success(mqttOnce.publishCar(lockTypeParam.getCarId(),ardSyCarRtu.getTopicPublish(),String.valueOf(new com.alibaba.fastjson2.JSONObject(map)),"瑙e皝")); + return AjaxResult.success(mqttOnce.publishCar(rtuTypeParam.getCarId(),ardSyCarRtu.getTopicPublish(),String.valueOf(new com.alibaba.fastjson2.JSONObject(map)),"瑙e皝")); } catch (MqttException e) { log.debug("瑙e皝鎸囦护鍙戠敓澶辫触"+e); } } //0鏂藉皝 - if(lockTypeParam.getType()==0){ + if(rtuTypeParam.getType()==0){ //閿佸紑鍏崇姸鎬� int lockCloseNum = 0; //鏌ヨ閿佷俊鎭� @@ -289,7 +290,7 @@ map.put("A02", 100000);//鏂紑绗簩璺户鐢靛櫒 map.put("res", String.valueOf(System.currentTimeMillis())); try { - return AjaxResult.success(mqttOnce.publishCar(lockTypeParam.getCarId(),ardSyCarRtu.getTopicPublish(),String.valueOf(new com.alibaba.fastjson2.JSONObject(map)),"鏂藉皝")); + return AjaxResult.success(mqttOnce.publishCar(rtuTypeParam.getCarId(),ardSyCarRtu.getTopicPublish(),String.valueOf(new com.alibaba.fastjson2.JSONObject(map)),"鏂藉皝")); } catch (MqttException e) { log.debug("鏂藉皝鎸囦护鍙戠敓澶辫触"+e); } -- Gitblit v1.9.3