| | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.ruoyi.common.core.domain.AjaxResult; |
| | | import com.ruoyi.common.utils.SecurityUtils; |
| | | import com.ruoyi.common.utils.spring.SpringUtils; |
| | | import com.ruoyi.sy.domain.ArdAccessFence; |
| | | import com.ruoyi.sy.domain.ArdSyCarLock; |
| | | import com.ruoyi.sy.domain.ArdSyCarRtu; |
| | | import com.ruoyi.sy.domain.ArdSyUser; |
| | | import com.ruoyi.sy.mapper.ArdAccessFenceMapper; |
| | | import com.ruoyi.sy.param.AddCarParam; |
| | | import com.ruoyi.sy.service.ArdAccessFenceService; |
| | | import com.ruoyi.sy.service.ArdSyCarLockService; |
| | | import com.ruoyi.sy.service.IArdSyCarService; |
| | | import com.ruoyi.sy.service.IArdSyUserService; |
| | | import com.ruoyi.sy.param.AddRtuParam; |
| | | import com.ruoyi.sy.param.LockTypeParam; |
| | | import com.ruoyi.sy.param.RtuTypeParam; |
| | | import com.ruoyi.sy.service.*; |
| | | import com.ruoyi.sy.service.impl.ArdSyCarRtuServiceImpl; |
| | | import com.ruoyi.sy.vo.CarLockVo; |
| | | import com.ruoyi.sy.vo.CarVo; |
| | | import com.ruoyi.sy.vo.RtuVo; |
| | | import com.ruoyi.system.service.ISysConfigService; |
| | | import com.ruoyi.utils.mqtt.MqttConsumer; |
| | | import com.ruoyi.utils.result.Results; |
| | | import io.swagger.annotations.Api; |
| | | import io.swagger.annotations.ApiOperation; |
| | | import org.eclipse.paho.client.mqttv3.MqttException; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.web.bind.annotation.*; |
| | | |
| | |
| | | private ArdSyCarLockService ardSyCarLockService; |
| | | @Autowired |
| | | private ArdAccessFenceService ardAccessFenceService; |
| | | @Autowired |
| | | private ArdSyCarRtuService ardSyCarRtuService; |
| | | |
| | | @GetMapping("/car") |
| | | @ApiOperation("查询所有未挂锁的车辆") |
| | | public Results car(){ |
| | | public AjaxResult car(){ |
| | | List<CarVo> list = ardSyCarLockService.car(); |
| | | analysis(list); |
| | | return Results.succeed(list); |
| | | return AjaxResult.success(list); |
| | | } |
| | | |
| | | @GetMapping("/carAddOne") |
| | | @ApiOperation("查询所有未挂锁的车辆加本车辆信息") |
| | | public Results carAddOne(String carId){ |
| | | public AjaxResult carAddOne(String carId){ |
| | | List<CarVo> list = ardSyCarLockService.carAddOne(carId); |
| | | analysis(list); |
| | | return Results.succeed(list); |
| | | return AjaxResult.success(list); |
| | | } |
| | | |
| | | @PostMapping("/add") |
| | | @ApiOperation("添加rtu") |
| | | public Results add(String carId){ |
| | | return Results.succeed("成功添加"+ardSyCarLockService.addRtu(carId)+"条数据"); |
| | | public AjaxResult add(@RequestBody AddRtuParam addRtuParam){ |
| | | return AjaxResult.success("成功添加"+ardSyCarLockService.addRtu(addRtuParam)+"条数据,订阅车辆"+addRtuParam.getCarId()+"成功"); |
| | | } |
| | | |
| | | @DeleteMapping("/del") |
| | | @ApiOperation("删除rtu") |
| | | public Results del(String id){ |
| | | return Results.succeed("成功删除"+ardSyCarLockService.delCar(id)+"条数据"); |
| | | public AjaxResult del(String id){ |
| | | return AjaxResult.success("成功删除"+ardSyCarLockService.delCar(id)+"条数据"); |
| | | } |
| | | |
| | | @GetMapping("/one") |
| | | @ApiOperation("查询一条rtu及锁") |
| | | public Results one(String carId){ |
| | | public AjaxResult one(String carId){ |
| | | CarLockVo carLockVo = new CarLockVo(); |
| | | CarVo carVo = ardSyCarLockService.carOne(carId); |
| | | String usersId = SecurityUtils.getUserId(); |
| | |
| | | carLockVo.setCar(carVo); |
| | | String rtu = carVo.getRtu(); |
| | | carLockVo.setCarLockList(ardSyCarLockService.carLock(rtu)); |
| | | return Results.succeed(carLockVo); |
| | | return AjaxResult.success(carLockVo); |
| | | } |
| | | |
| | | @GetMapping("/query") |
| | |
| | | return AjaxResult.success(ardAccessFenceService.updCarAlarm(id)); |
| | | } |
| | | |
| | | @GetMapping("/onOff") |
| | | @ApiOperation("远程开锁") |
| | | public AjaxResult onOff(@RequestBody LockTypeParam lockTypeParam) { |
| | | return AjaxResult.success(ardSyCarLockService.onOff(lockTypeParam)); |
| | | } |
| | | |
| | | @GetMapping("/seal") |
| | | @ApiOperation("远程封印") |
| | | public AjaxResult seal(@RequestBody RtuTypeParam rtuTypeParam) { |
| | | return AjaxResult.success(ardSyCarLockService.seal(rtuTypeParam)); |
| | | } |
| | | |
| | | @GetMapping("/lockIng") |
| | | @ApiOperation("实时锁状态") |
| | | public AjaxResult lockIng(String carId) { |
| | | return AjaxResult.success(ardSyCarLockService.lockIng(carId)); |
| | | } |
| | | |
| | | |
| | | //获取31车辆车牌号驾驶员和电话 |
| | | public List<CarVo> analysis(List<CarVo> list){ |
| | | String usersId = SecurityUtils.getUserId(); |