| | |
|---|
| | | // MqttCustomerClient mqttCustomerClient = new MqttCustomerClient(); |
|---|
| | | // mqttCustomerClient.connect(lockTypeParam.getCarId()+"change"+UUID.randomUUID()); |
|---|
| | | // mqttCustomerClient.pushlish(ardSyCarRtu.getTopicPublish(),mapString); |
|---|
| | | try { |
|---|
| | | while(true){ |
|---|
| | | TimeUnit.SECONDS.sleep(5); |
|---|
| | | int min = lockTypeParam.getNum() -5; int max = lockTypeParam.getNum() +5; |
|---|
| | | while(true){ |
|---|
| | | ArdSyCarLock ardSyCarLockLoop = lockMapper.selectById(lockTypeParam.getLockId()); |
|---|
| | | Double currentInfo = ardSyCarLockLoop.getCurrentInfo(); |
|---|
| | | int d = (int) ((int)(currentInfo*150/138.3 - 4)/0.16); |
|---|
| | | if(d >= min && d <= max){ |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | } catch (InterruptedException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | // TimeUnit.SECONDS.sleep(5); |
|---|
| | | } |
|---|
| | | return AjaxResult.success("开关锁命令发送成功,发送进度为"+lockTypeParam.getNum()); |
|---|
| | | return AjaxResult.success("开关锁成功,进度为"+lockTypeParam.getNum()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Boolean isLock(String carId) { |
|---|
| | | QueryWrapper<ArdSyCarRtu> queryWrapperRtu = new QueryWrapper<>(); |
|---|
| | | queryWrapperRtu.eq("car_id",carId); |
|---|
| | | ArdSyCarRtu ardSyCarRtu = rtuMapper.selectOne(queryWrapperRtu); |
|---|
| | | if(ardSyCarRtu!=null){ |
|---|
| | | List<ArdSyCarLock> ardSyCarLocks = lockMapper.lockList(ardSyCarRtu.getId()); |
|---|
| | | if(ardSyCarLocks.size()>0){ |
|---|
| | | return true; |
|---|
| | | }else { |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | }else { |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | //车辆列表封装 |
|---|
| | | public List<CarVo> carAnalysis(List<ArdSyCar> ardSyCars){ |
|---|
