From 60ff64138cb46922822868b3150b2e9be7c04e39 Mon Sep 17 00:00:00 2001 From: ‘liusuyi’ <1951119284@qq.com> Date: 星期六, 16 九月 2023 09:18:35 +0800 Subject: [PATCH] 增加热力图数据接口 --- ard-work/src/main/java/com/ruoyi/alarm/global/controller/GlobalAlarmController.java | 8 ++ ard-work/src/main/java/com/ruoyi/alarm/global/domain/GlobalAlarmCondition.java | 2 ard-work/src/main/java/com/ruoyi/alarm/global/service/IGlobalAlarmService.java | 1 ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/GlobalAlarmServiceImpl.java | 155 +++++++++++++++++++++++++++++++++++++++++++++++++++ 4 files changed, 166 insertions(+), 0 deletions(-) diff --git a/ard-work/src/main/java/com/ruoyi/alarm/global/controller/GlobalAlarmController.java b/ard-work/src/main/java/com/ruoyi/alarm/global/controller/GlobalAlarmController.java index 0b7e7a6..3ef2d72 100644 --- a/ard-work/src/main/java/com/ruoyi/alarm/global/controller/GlobalAlarmController.java +++ b/ard-work/src/main/java/com/ruoyi/alarm/global/controller/GlobalAlarmController.java @@ -87,4 +87,12 @@ Map<String, PriorityBlockingQueue<GuideTask>> cameraQueueMap = GuidePriorityQueue.cameraQueueMap; return AjaxResult.success(cameraQueueMap); } + + @PostMapping("/ThermalMapList") + @ApiOperation(value = "鐑姏鍥炬帴鍙�",notes = "鎸夋姤璀﹀埛鏂版椂闂存寜鎶ヨ绫诲埆鑱氬悎鏌ヨ") + @ApiOperationSupport(includeParameters = {"command","refreshTime"},order = 1) + public AjaxResult selectThermalMap(@RequestBody GlobalAlarmCondition condition) { + List<GlobalAlarmData> result = globalAlarmService.selectThermalMap(condition); + return AjaxResult.success(result); + } } diff --git a/ard-work/src/main/java/com/ruoyi/alarm/global/domain/GlobalAlarmCondition.java b/ard-work/src/main/java/com/ruoyi/alarm/global/domain/GlobalAlarmCondition.java index 7747840..79cf543 100644 --- a/ard-work/src/main/java/com/ruoyi/alarm/global/domain/GlobalAlarmCondition.java +++ b/ard-work/src/main/java/com/ruoyi/alarm/global/domain/GlobalAlarmCondition.java @@ -24,4 +24,6 @@ String id; Date beginTime; Date endTime; + String refreshTime; + } diff --git a/ard-work/src/main/java/com/ruoyi/alarm/global/service/IGlobalAlarmService.java b/ard-work/src/main/java/com/ruoyi/alarm/global/service/IGlobalAlarmService.java index c4b6d45..91ebeb1 100644 --- a/ard-work/src/main/java/com/ruoyi/alarm/global/service/IGlobalAlarmService.java +++ b/ard-work/src/main/java/com/ruoyi/alarm/global/service/IGlobalAlarmService.java @@ -20,4 +20,5 @@ public void receiveAlarm(String topic,String message); public Map<String,Object> selectAlarmLogsCount(); Object selectAlarmList(Integer command, String beginTime, String endTime,Integer pageNum,Integer pageSize); + public List<GlobalAlarmData> selectThermalMap(GlobalAlarmCondition condition); } diff --git a/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/GlobalAlarmServiceImpl.java b/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/GlobalAlarmServiceImpl.java index b6c55f2..f6b19e8 100644 --- a/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/GlobalAlarmServiceImpl.java +++ b/ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/GlobalAlarmServiceImpl.java @@ -309,6 +309,161 @@ return null; } } + /** + * 鑾峰彇鐑姏鍥炬暟鎹� + * 鍒樿嫃涔� + * 2023/9/16 8:38:54 + */ + @Override + public List<GlobalAlarmData> selectThermalMap(GlobalAlarmCondition condition) { + String refreshTime = condition.getRefreshTime(); + switch (condition.getCommand()) { + case 1001: + List<ArdAlarmStealelec> ardAlarmStealelecs = ardAlarmStealelecMapper.selectListAllByCommand(refreshTime); + return ardAlarmStealelecs.stream() + .map(ardAlarmStealelec -> { + GlobalAlarmData globalAlarmData = new GlobalAlarmData() + .setId(ardAlarmStealelec.getId()) + .setName(ardAlarmStealelec.getDescribe()) + .setAlarmTime(ardAlarmStealelec.getStartTime()) + .setLongitude(ardAlarmStealelec.getLongitude()) + .setLatitude(ardAlarmStealelec.getLatitude()) + .setAltitude(ardAlarmStealelec.getAltitude()) + .setCount(ardAlarmStealelec.getCount()) + .setTotal(ardAlarmStealelec.getTotal()); + return globalAlarmData; + }).collect(Collectors.toList()); + case 1002: + List<ArdAlarmCamera> ardAlarmCameras = ardAlarmCameraMapper.selectListAllByCommand(refreshTime); + return ardAlarmCameras.stream() + .map(ardAlarmCamera -> { + GlobalAlarmData globalAlarmData = new GlobalAlarmData() + .setId(ardAlarmCamera.getId()) + .setName(ardAlarmCamera.getCameraName()) + .setAlarmTime(ardAlarmCamera.getAlarmTime()) + .setLongitude(ardAlarmCamera.getLongitude()) + .setLatitude(ardAlarmCamera.getLatitude()) + .setCount(ardAlarmCamera.getCount()) + .setTotal(ardAlarmCamera.getTotal()); + return globalAlarmData; + }).collect(Collectors.toList()); + case 1003: + List<ArdAlarmRadarMove> ardAlarmRadarMoves = ardAlarmRadarMoveMapper.selectListAllByCommand(refreshTime); + return ardAlarmRadarMoves.stream() + .map(ardAlarmRadarMove -> { + GlobalAlarmData globalAlarmData = new GlobalAlarmData() + .setId(ardAlarmRadarMove.getId()) + .setName(ardAlarmRadarMove.getName()) + .setAlarmTime(ardAlarmRadarMove.getAlarmTime()) + .setLongitude(ardAlarmRadarMove.getLongitude()) + .setLatitude(ardAlarmRadarMove.getLatitude()) + .setCount(ardAlarmRadarMove.getCount()) + .setTotal(ardAlarmRadarMove.getTotal()); + return globalAlarmData; + }).collect(Collectors.toList()); + case 1004: + List<ArdAlarmRadarFire> ardAlarmRadarFires = ardAlarmRadarFireMapper.selectListAllByCommand(refreshTime); + return ardAlarmRadarFires.stream() + .map(ardAlarmRadarFire -> { + GlobalAlarmData globalAlarmData = new GlobalAlarmData() + .setId(ardAlarmRadarFire.getId()) + .setName(ardAlarmRadarFire.getName()) + .setAlarmTime(ardAlarmRadarFire.getAlarmTime()) + .setLongitude(ardAlarmRadarFire.getLongitude()) + .setLatitude(ardAlarmRadarFire.getLatitude()) + .setCount(ardAlarmRadarFire.getCount()) + .setTotal(ardAlarmRadarFire.getTotal()); + return globalAlarmData; + }).collect(Collectors.toList()); + case 1005: + List<ArdAlarmExternal> ardAlarmExternals = ardAlarmExternalMapper.selectListAllByCommand(refreshTime, "闃插尯鎶ヨ"); + return ardAlarmExternals.stream() + .map(ardAlarmExternal -> { + GlobalAlarmData globalAlarmData = new GlobalAlarmData() + .setId(ardAlarmExternal.getId()) + .setName(ardAlarmExternal.getAlarmName()) + .setAlarmTime(ardAlarmExternal.getAlarmTime()) + .setLongitude(ardAlarmExternal.getLongitude()) + .setLatitude(ardAlarmExternal.getLatitude()) + .setCount(ardAlarmExternal.getCount()) + .setTotal(ardAlarmExternal.getTotal()); + return globalAlarmData; + }).collect(Collectors.toList()); + case 1006: + List<ArdAlarmAccess> ardAlarmAccesses = ardAlarmAccessMapper.selectListAllByCommand(refreshTime); + return ardAlarmAccesses.stream() + .map(ardAlarmAccess -> { + GlobalAlarmData globalAlarmData = new GlobalAlarmData() + .setId(ardAlarmAccess.getId()) + .setName(ardAlarmAccess.getAcsName()) + .setAlarmTime(ardAlarmAccess.getAlarmTime()) + .setLongitude(ardAlarmAccess.getLongitude()) + .setLatitude(ardAlarmAccess.getLatitude()) + .setCount(ardAlarmAccess.getCount()) + .setTotal(ardAlarmAccess.getTotal()); + return globalAlarmData; + }).collect(Collectors.toList()); + case 1007: + List<ArdAlarmRadarPump> ardAlarmRadarPumps = ardAlarmRadarPumpMapper.selectListAllByCommand(refreshTime); + return ardAlarmRadarPumps.stream() + .map(ardAlarmRadarPump -> { + GlobalAlarmData globalAlarmData = new GlobalAlarmData() + .setId(ardAlarmRadarPump.getId()) + .setName(ardAlarmRadarPump.getName()) + .setAlarmTime(ardAlarmRadarPump.getAlarmTime()) + .setLongitude(ardAlarmRadarPump.getLongitude()) + .setLatitude(ardAlarmRadarPump.getLatitude()) + .setCount(ardAlarmRadarPump.getCount()) + .setTotal(ardAlarmRadarPump.getTotal()); + return globalAlarmData; + }).collect(Collectors.toList()); + case 1009: + List<ArdAlarmApponekey> ardAlarmApponekeys = ardAlarmApponekeyMapper.selectListAllByCommand(refreshTime); + return ardAlarmApponekeys.stream() + .map(ardAlarmApponekey -> { + GlobalAlarmData globalAlarmData = new GlobalAlarmData() + .setId(ardAlarmApponekey.getId()) + .setName(ardAlarmApponekey.getName()) + .setAlarmTime(ardAlarmApponekey.getCreateTime()) + .setLongitude(ardAlarmApponekey.getLongitude()) + .setLatitude(ardAlarmApponekey.getLatitude()) + .setCount(ardAlarmApponekey.getCount()) + .setTotal(ardAlarmApponekey.getTotal()); + return globalAlarmData; + }).collect(Collectors.toList()); + case 1010: + List<ArdAlarmWall> ardAlarmWalls = ardAlarmWallMapper.selectListAllByCommand(refreshTime); + return ardAlarmWalls.stream() + .map(ardAlarmWall -> { + GlobalAlarmData globalAlarmData = new GlobalAlarmData() + .setId(ardAlarmWall.getId()) + .setName(ardAlarmWall.getWallName()) + .setAlarmTime(ardAlarmWall.getAlarmTime()) + .setLongitude(ardAlarmWall.getLongitude()) + .setLatitude(ardAlarmWall.getLatitude()) + .setCount(ardAlarmWall.getCount()) + .setTotal(ardAlarmWall.getTotal()); + return globalAlarmData; + }).collect(Collectors.toList()); + case 1014: + List<ArdAlarmTube> ardAlarmTubes = ardAlarmTubeMapper.selectListAllByCommand(refreshTime); + return ardAlarmTubes.stream() + .map(ardAlarmTube -> { + GlobalAlarmData globalAlarmData = new GlobalAlarmData() + .setId(ardAlarmTube.getId()) + .setName(ardAlarmTube.getTubeName()) + .setAlarmTime(ardAlarmTube.getAlarmTime()) + .setLongitude(ardAlarmTube.getLongitude()) + .setLatitude(ardAlarmTube.getLatitude()) + .setAltitude(ardAlarmTube.getAltitude()) + .setCount(ardAlarmTube.getCount()) + .setTotal(ardAlarmTube.getTotal()); + return globalAlarmData; + }).collect(Collectors.toList()); + default: + return null; + } + } @Override public List<GlobalAlarmData> selectAlarmLogsAll() { -- Gitblit v1.9.3