From 5b017324148ea92d96f9f16ade215463d6c712e5 Mon Sep 17 00:00:00 2001 From: liusuyi <1951119284@qq.com> Date: 星期六, 10 八月 2024 14:15:02 +0800 Subject: [PATCH] 优化:海康大华sdk断线重连机制 --- ard-work/src/main/java/com/ruoyi/sy/controller/ArdTankLockController.java | 158 ++++++++++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 145 insertions(+), 13 deletions(-) diff --git a/ard-work/src/main/java/com/ruoyi/sy/controller/ArdTankLockController.java b/ard-work/src/main/java/com/ruoyi/sy/controller/ArdTankLockController.java index 3dfbfd2..f50f023 100644 --- a/ard-work/src/main/java/com/ruoyi/sy/controller/ArdTankLockController.java +++ b/ard-work/src/main/java/com/ruoyi/sy/controller/ArdTankLockController.java @@ -8,9 +8,9 @@ import com.github.pagehelper.PageInfo; import com.ruoyi.common.utils.SecurityUtils; import com.ruoyi.common.utils.uuid.IdUtils; +import com.ruoyi.sy.domain.ArdTankLockProcessLog; import com.ruoyi.sy.domain.ArdTankWall; -import com.ruoyi.sy.service.IArdTankWallLockService; -import com.ruoyi.sy.service.IArdTankWallService; +import com.ruoyi.sy.service.*; import com.ruoyi.utils.result.Results; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; @@ -29,7 +29,6 @@ import com.ruoyi.common.core.domain.AjaxResult; import com.ruoyi.common.enums.BusinessType; import com.ruoyi.sy.domain.ArdTankLock; -import com.ruoyi.sy.service.IArdTankLockService; import com.ruoyi.common.utils.poi.ExcelUtil; import com.ruoyi.common.core.page.TableDataInfo; @@ -51,6 +50,18 @@ @Autowired private IArdTankWallLockService ardTankWallLockService; + + @Autowired + private IArdTankLockProcessLogService ardTankLockProcessLogService; + + @Autowired + private IArdTankLockAlarmService ardTankLockAlarmService; + + @Autowired + private IArdTankLockPasswordService ardTankLockPasswordService; + + @Autowired + private IArdTankWallTemporaryService ardTankWallTemporaryService; /** * 鏌ヨ鐢电閿佸垪琛� @@ -158,11 +169,11 @@ PageHelper.startPage((Integer) para.get("pageNum"), (Integer) para.get("pageSize")); String userId = SecurityUtils.getUserId(); - List<Map<String,Object>> result = ardTankLockService.getAll(userId); + Map<String,Object> result = ardTankLockService.getAll(userId); TableDataInfo dataTable = new TableDataInfo(); - dataTable.setRows(result); - dataTable.setTotal(result.size()); + dataTable.setRows((List<Map<String,Object>>) result.get("list")); + dataTable.setTotal((Long) result.get("total")); dataTable.setCode(200); dataTable.setMsg("鏌ヨ鎴愬姛"); return dataTable; @@ -250,11 +261,11 @@ PageHelper.startPage((Integer) para.get("pageNum"), (Integer) para.get("pageSize")); ArdTankWall ardTankWall = new ArdTankWall(); ardTankWall.setWallName((String) para.get("wallName")); - List<ArdTankWall> list = ardTankWallService.selectArdTankWallList(ardTankWall); + Map<String,Object> result = ardTankWallService.selectArdTankWallList(ardTankWall); TableDataInfo dataTable = new TableDataInfo(); - dataTable.setRows(list); - dataTable.setTotal(list.size()); + dataTable.setRows((List<ArdTankWall>) result.get("list")); + dataTable.setTotal((Long) result.get("total")); dataTable.setCode(200); dataTable.setMsg("鏌ヨ鎴愬姛"); return dataTable; @@ -278,13 +289,13 @@ String userId = SecurityUtils.getUserId(); List<Map<String,String>> result = ardTankLockService.getLockByCarPlate(userId,para.get("carPlate")); return getDataTable(result);*/ - PageHelper.startPage((Integer) para.get("pageNum"), (Integer) para.get("pageSize")); + //PageHelper.startPage((Integer) para.get("pageNum"), (Integer) para.get("pageSize")); String userId = SecurityUtils.getUserId(); - List<Map<String,Object>> result = ardTankLockService.getLockByCarPlate(userId, (String) para.get("carPlate")); + Map<String,Object> result = ardTankLockService.getLockByCarPlate(userId, (String) para.get("carPlate"),(Integer) para.get("pageNum"), (Integer) para.get("pageSize")); TableDataInfo dataTable = new TableDataInfo(); - dataTable.setRows(result); - dataTable.setTotal(result.size()); + dataTable.setRows((List<Map<String,Object>>) result.get("list")); + dataTable.setTotal((Long) result.get("total")); dataTable.setCode(200); dataTable.setMsg("鏌ヨ鎴愬姛"); return dataTable; @@ -318,4 +329,125 @@ public AjaxResult deleteArdTankWallLockByLockId(@PathVariable String id) { return toAjax(ardTankWallLockService.deleteArdTankWallLockByLockId(id)); } + + /** + * 鎿嶆帶鐢电閿� + */ + @ApiOperation("鎿嶆帶鐢电閿�") + @PreAuthorize("@ss.hasPermi('sy:lock:processArdTankLockByLockId')") + @Log(title = "鐢电閿�" , businessType = BusinessType.INSERT) + @PostMapping("/processArdTankLockByLockId") + public AjaxResult processArdTankLockByLockId(@RequestBody Map<String,String> para) { + String userId = SecurityUtils.getUserId(); + String username = SecurityUtils.getUsername(); + return ardTankLockProcessLogService.processArdTankLockByLockId(userId,username,para); + } + + @ApiOperation("鏌ヨ鐢电閿佹姤璀�") + @PreAuthorize("@ss.hasPermi('sy:lock:getAlarm')") + @PostMapping("/getAlarm") + public TableDataInfo getAlarm(@RequestBody Map<String,Object> para) { + String userId = SecurityUtils.getUserId(); + Map<String,Object> result = ardTankLockAlarmService.getAlarm(userId,para); + + TableDataInfo dataTable = new TableDataInfo(); + dataTable.setRows((List<Map<String,Object>>) result.get("list")); + dataTable.setTotal((Long) result.get("total")); + dataTable.setCode(200); + dataTable.setMsg("鏌ヨ鎴愬姛"); + return dataTable; + } + + @ApiOperation("鏍规嵁閿佷富閿煡璇㈢數纾侀攣瀵嗙爜") + @PreAuthorize("@ss.hasPermi('sy:lock:getLockPasswordByLockId')") + @PostMapping("/getLockPasswordByLockId") + public TableDataInfo getLockPasswordByLockId(@RequestBody Map<String,Object> para) { + Map<String,Object> result = ardTankLockPasswordService.getLockPasswordByLockId(para); + + TableDataInfo dataTable = new TableDataInfo(); + dataTable.setRows((List<Map<String,Object>>) result.get("list")); + dataTable.setTotal((Long) result.get("total")); + dataTable.setCode(200); + dataTable.setMsg("鏌ヨ鎴愬姛"); + return dataTable; + } + + @ApiOperation("鏍规嵁涓変竴涓婚敭鏌ヨ鐢电閿佸瘑鐮�") + @PreAuthorize("@ss.hasPermi('sy:lock:getLockPasswordByCarId')") + @PostMapping("/getLockPasswordByCarId") + public TableDataInfo getLockPasswordByCarId(@RequestBody Map<String,Object> para) { + String userId = SecurityUtils.getUserId(); + Map<String,Object> result = ardTankLockPasswordService.getLockPasswordByCarId(userId,para); + + TableDataInfo dataTable = new TableDataInfo(); + dataTable.setRows((List<Map<String,Object>>) result.get("list")); + dataTable.setTotal((Long) result.get("total")); + dataTable.setCode(200); + dataTable.setMsg("鏌ヨ鎴愬姛"); + return dataTable; + } + + @ApiOperation("鏂板涓存椂鐢靛瓙鍥存爮") + @PreAuthorize("@ss.hasPermi('sy:lock:insertArdTankWallTemporary')") + @PostMapping("/insertArdTankWallTemporary") + public AjaxResult insertArdTankWallTemporary(@RequestBody Map<String,Object> para) { + String userId = SecurityUtils.getUserId(); + String userName = SecurityUtils.getUsername(); + return toAjax(ardTankWallTemporaryService.insertArdTankWallTemporary(userId,userName,para)); + } + + @ApiOperation("鏇存敼涓存椂鐢靛瓙鍥存爮") + @PreAuthorize("@ss.hasPermi('sy:lock:updateArdTankWallTemporary')") + @PostMapping("/updateArdTankWallTemporary") + public AjaxResult updateArdTankWallTemporary(@RequestBody Map<String,Object> para) { + String userId = SecurityUtils.getUserId(); + String userName = SecurityUtils.getUsername(); + return toAjax(ardTankWallTemporaryService.updateArdTankWallTemporary(userId,userName,para)); + } + + @ApiOperation("鏍规嵁涓変竴涓婚敭鏌ヨ涓存椂鐢靛瓙鍥存爮") + @PreAuthorize("@ss.hasPermi('sy:lock:getArdTankWallTemporaryByCarId')") + @PostMapping("/getArdTankWallTemporaryByCarId") + public TableDataInfo getArdTankWallTemporaryByCarId(@RequestBody Map<String,Object> para) { + Map<String,Object> result = ardTankWallTemporaryService.getArdTankWallTemporaryByCarId(para); + + TableDataInfo dataTable = new TableDataInfo(); + dataTable.setRows((List<Map<String,Object>>) result.get("list")); + dataTable.setTotal((Long) result.get("total")); + dataTable.setCode(200); + dataTable.setMsg("鏌ヨ鎴愬姛"); + return dataTable; + } + + @ApiOperation("淇敼鐢电閿佷娇鑳�") + @PreAuthorize("@ss.hasPermi('sy:lock:updateLockEnableByCarId')") + @Log(title = "鐢电閿�" , businessType = BusinessType.UPDATE) + @PutMapping("/updateLockEnableByCarId") + public AjaxResult updateLockEnableByCarId(@RequestBody Map<String,Object> para) { + return toAjax(ardTankLockService.updateLockEnableByCarId(para)); + } + + @ApiOperation("鏍规嵁杞︾墝鍙锋煡璇㈢數纾侀攣鎵嬪姩鎿嶆帶璁板綍") + @PreAuthorize("@ss.hasPermi('sy:lock:getArdTankLockProcessLogByCarPlate')") + @PostMapping("/getArdTankLockProcessLogByCarPlate") + public TableDataInfo getArdTankLockProcessLogByCarPlate(@RequestBody Map<String,Object> para) { + Map<String,Object> result = ardTankLockProcessLogService.getArdTankLockProcessLogByCarPlate(para); + + TableDataInfo dataTable = new TableDataInfo(); + dataTable.setRows((List<Map<String,Object>>) result.get("list")); + dataTable.setTotal((Long) result.get("total")); + dataTable.setCode(200); + dataTable.setMsg("鏌ヨ鎴愬姛"); + return dataTable; + } + + /*@ApiOperation("鏍规嵁杞︾墝鍙峰鍑虹數纾侀攣鎵嬪姩鎿嶆帶璁板綍") + @PreAuthorize("@ss.hasPermi('sy:lock:exportArdTankLockProcessLog')") + @PostMapping("/exportArdTankLockProcessLog") + public void exportArdTankLockProcessLog(HttpServletResponse response, ArdTankLockProcessLog ardTankLockProcessLog) { + List<ArdTankLockProcessLog> list = ardTankLockProcessLogService.exportArdTankLockProcessLog(ardTankLockProcessLog.getCarPlate()); + ExcelUtil<ArdTankLockProcessLog> util = new ExcelUtil<ArdTankLockProcessLog>(ArdTankLockProcessLog. class); + util.exportExcel(response, list, "缃愯溅閿佹搷鎺ф棩蹇楁暟鎹�"); + }*/ + } -- Gitblit v1.9.3