feat(无人值守): 设备远程监控新增监测历史数据接口(趋势曲线)
| | |
| | | |
| | | // ==================== 数据采集 ==================== |
| | | |
| | | @ApiOperation("监测历史数据(实时监测趋势曲线)") |
| | | @GetMapping("/monitorDataHistory") |
| | | public AjaxResult dataHistory(@RequestParam Long deviceId, |
| | | @RequestParam(required = false) String metricCode, |
| | | @RequestParam(required = false) String startTime, |
| | | @RequestParam(required = false) String endTime) { |
| | | return AjaxResult.success(monitorService.dataHistory(deviceId, metricCode, startTime, endTime)); |
| | | } |
| | | |
| | | @ApiOperation("采集数据上报(自动采集/人工补录)") |
| | | @PostMapping("/monitorDataReport") |
| | | public AjaxResult dataReport(@RequestParam Long deviceId, |
| | |
| | | |
| | | // ==================== 数据采集与报警 ==================== |
| | | |
| | | /** 监测历史数据(用于实时监测趋势曲线) */ |
| | | public List<MonitorData> dataHistory(Long deviceId, String metricCode, String startTime, String endTime) { |
| | | return dataMapper.selectList(Wrappers.<MonitorData>lambdaQuery() |
| | | .eq(deviceId != null, MonitorData::getDeviceId, deviceId) |
| | | .eq(StringUtils.hasText(metricCode), MonitorData::getMetricCode, metricCode) |
| | | .ge(StringUtils.hasText(startTime), MonitorData::getCollectTime, startTime) |
| | | .le(StringUtils.hasText(endTime), MonitorData::getCollectTime, endTime) |
| | | .orderByAsc(MonitorData::getCollectTime) |
| | | .last("limit 500")); |
| | | } |
| | | |
| | | /** |
| | | * 采集数据上报(自动采集端调用,也可由页面模拟采集) |
| | | * 写入历史数据、更新指标当前值,并做阈值报警判定 |