From 7f13f3c0e756864d0117ba949661c7eab4208181 Mon Sep 17 00:00:00 2001 From: zhouhy Date: Thu, 14 Sep 2023 15:25:43 +0800 Subject: [PATCH] =?UTF-8?q?1.1.3=20=E7=9B=91=E6=8E=A7=E5=8D=95=E5=85=83Con?= =?UTF-8?q?troller=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../HwMonitorPlatformController.java | 20 +++++++++----- .../service/IHwMonitorUnitService.java | 7 ++++- .../impl/HwMonitorUnitServiceImpl.java | 26 +++++++++++++------ .../mapper/business/HwMonitorUnitMapper.xml | 2 +- 4 files changed, 39 insertions(+), 16 deletions(-) diff --git a/ruoyi-modules/hw-business/src/main/java/com/ruoyi/business/controller/HwMonitorPlatformController.java b/ruoyi-modules/hw-business/src/main/java/com/ruoyi/business/controller/HwMonitorPlatformController.java index 2b53ea4..e170d66 100644 --- a/ruoyi-modules/hw-business/src/main/java/com/ruoyi/business/controller/HwMonitorPlatformController.java +++ b/ruoyi-modules/hw-business/src/main/java/com/ruoyi/business/controller/HwMonitorPlatformController.java @@ -44,6 +44,7 @@ public class HwMonitorPlatformController extends BaseController { private IHwElectronicFenceService hwElectronicFenceService; + /** * 树状获取监控单元列表 * @param hwMonitorUnits 监控单元对象 @@ -51,7 +52,7 @@ public class HwMonitorPlatformController extends BaseController { * @throws * */ @GetMapping("/treeList") - public TableDataInfo treeList(List hwMonitorUnits){ + public TableDataInfo treeList(@RequestBody List hwMonitorUnits){ List list = hwMonitorUnitService.selectTreeList(hwMonitorUnits); return getDataTable(list); @@ -113,6 +114,7 @@ public class HwMonitorPlatformController extends BaseController { } /** * 查询区域数量站场景区总数百分比 + * 1-左上 * */ @GetMapping("/monitorPercentage") public TableDataInfo monitorPercentage(){ @@ -181,11 +183,11 @@ public class HwMonitorPlatformController extends BaseController { * */ @PostMapping("/selectMonitorUnitSub") //ok - public HwMonitorUnit selectMonitorUnitSub(Long monitorUnitId){ + public AjaxResult selectMonitorUnitSub(Long monitorUnitId){ HwMonitorUnit hwMonitorUnits = hwMonitorUnitService.selectHwMonitorUnitByMonitorUnitId(monitorUnitId); - return hwMonitorUnits; + return AjaxResult.success(monitorUnitId); } /** * 2. 设备实时在运数量曲线图 @@ -194,9 +196,10 @@ public class HwMonitorPlatformController extends BaseController { * @param sceneId 场景id * */ @PostMapping("/getDeviceOperations") - public int[] selectTdengine(String beginTime,String endTime,Long sceneId){ - int ints[] = hwMonitorUnitService.selectTdengine(beginTime,endTime,sceneId); - return ints; + public R> selectTdengine(String beginTime,String endTime,Long sceneId){ + + Map objectIntegerMap = hwMonitorUnitService.selectTdengine(beginTime, endTime, sceneId); + return R.ok(objectIntegerMap); } /** * 设备汇总 @@ -222,4 +225,9 @@ public class HwMonitorPlatformController extends BaseController { hwScenes.get(0).setDefaultFlag("1");} return getDataTable(hwScenes); } + /** + * 报警列表 + * 无alarminfo表 + * */ + } diff --git a/ruoyi-modules/hw-business/src/main/java/com/ruoyi/business/service/IHwMonitorUnitService.java b/ruoyi-modules/hw-business/src/main/java/com/ruoyi/business/service/IHwMonitorUnitService.java index 65f7299..5c6fdd4 100644 --- a/ruoyi-modules/hw-business/src/main/java/com/ruoyi/business/service/IHwMonitorUnitService.java +++ b/ruoyi-modules/hw-business/src/main/java/com/ruoyi/business/service/IHwMonitorUnitService.java @@ -38,6 +38,11 @@ public interface IHwMonitorUnitService * */ public List selectLimitSubMonitorUnit(); + /** + * 报警信息列表 + * */ + + /** @@ -72,7 +77,7 @@ public interface IHwMonitorUnitService * 通过tdengine获取设备运行情况 * * @return*/ - public int[] selectTdengine(String beginTime, String endTime, Long sceneId); + public Map selectTdengine(String beginTime, String endTime, Long sceneId); /** * 设备汇总 * diff --git a/ruoyi-modules/hw-business/src/main/java/com/ruoyi/business/service/impl/HwMonitorUnitServiceImpl.java b/ruoyi-modules/hw-business/src/main/java/com/ruoyi/business/service/impl/HwMonitorUnitServiceImpl.java index 253394b..c7c5784 100644 --- a/ruoyi-modules/hw-business/src/main/java/com/ruoyi/business/service/impl/HwMonitorUnitServiceImpl.java +++ b/ruoyi-modules/hw-business/src/main/java/com/ruoyi/business/service/impl/HwMonitorUnitServiceImpl.java @@ -211,11 +211,12 @@ public class HwMonitorUnitServiceImpl implements IHwMonitorUnitService @Override // 加一个begintime参数，endtime参数 stream时间戳 从开始时间0点开始，结束时间23.59.59结束 - public int[] selectTdengine(String beginTime, String endTime, Long sceneId) { + public Map selectTdengine(String beginTime, String endTime, Long sceneId) { DeviceStatus queryDeviceStatus = new DeviceStatus(); Map params = queryDeviceStatus.getParams(); DateTimeFormatter ofPattern = DateTimeFormatter.ofPattern("yyyy-MM-dd", Locale.CHINA); + System.out.println(ofPattern); LocalDate parse = LocalDate.parse(beginTime, ofPattern); long begintime = parse.atStartOfDay().toInstant(ZoneOffset.of("+8")).toEpochMilli(); @@ -232,18 +233,27 @@ public class HwMonitorUnitServiceImpl implements IHwMonitorUnitService int sum = 0; int values[] = new int[10]; + Map valuesMap = new HashMap<>(); //todo 使用id(以解决) //map key时间戳，value List 对象 + R r = remoteTdEgineService.getOnlineDevicesGroupByDay(queryDeviceStatus); + Map> deviceStatusMap = (Map>) r.getData(); List list = (List) remoteTdEgineService.getOnlineDevicesGroupByDay(queryDeviceStatus); - for (int i = 0; i < list.size(); i++) { - if (list.get(i).getDeviceType()==1) { - values[i]=hwMonitorUnitMapper.selectReleatedDeviceIdNums(list.get(i).getDeviceId()); - } - else { - values[i] = hwDeviceMapper.selectSumDeviceFlagNot0(); + Set longs = deviceStatusMap.keySet(); + for (Object key:longs){ + List deviceStatuses = deviceStatusMap.get(key); + for (int i=0;i