diff --git a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/controller/BigScreenControllerP2.java b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/controller/BigScreenControllerP2.java index 36ab88e..d7b5138 100644 --- a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/controller/BigScreenControllerP2.java +++ b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/controller/BigScreenControllerP2.java @@ -1,6 +1,7 @@ package org.jeecg.modules.appmana.controller; import cn.hutool.core.lang.Assert; +import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; @@ -11,14 +12,17 @@ import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.jeecg.common.api.vo.Result; import org.jeecg.common.constant.enums.PollutionEnum; +import org.jeecg.common.entity.SurvAlertRecord; import org.jeecg.common.entity.SurvDeviceDeploy; import org.jeecg.common.entity.SurvMaintainRecord; import org.jeecg.common.iot.common.VOIntegrateStatistic; +import org.jeecg.common.util.R; import org.jeecg.common.vo.VOBigScreenSurvQ; import org.jeecg.common.vo.VOHisFormResult; import org.jeecg.common.vo.VOHisResult; import org.jeecg.common.vo.params.StationMaintainPage; import org.jeecg.common.vo.statistic.DeploySummaryVo; +import org.jeecg.modules.appmana.service.ISurvAlertRecordService; import org.jeecg.modules.appmana.service.ISurvDeviceDeployService; import org.jeecg.modules.appmana.service.ISurvMaintainRecordService; import org.jeecg.modules.appmana.service.impl.CommonServiceImpl; @@ -32,6 +36,7 @@ import java.time.LocalDateTime; import java.time.LocalTime; import java.time.format.DateTimeFormatter; import java.util.ArrayList; +import java.util.Arrays; import java.util.List; @Api(tags="大屏接口part.2") @@ -50,7 +55,8 @@ public class BigScreenControllerP2 { private IotCommonP3ServiceImpl iotCommonP3Service; @Autowired private ISurvMaintainRecordService maintainRecordService; - + @Autowired + private ISurvAlertRecordService alertRecordService; @ApiOperationSupport(order = 1) @ApiOperation(value = "01. 查询设备下各检测项的历史数据", notes = "") @@ -137,4 +143,30 @@ public class BigScreenControllerP2 { return Result.OK(voIntegrateStatistic); } + + + + @GetMapping("/alertRecord") + @ApiOperation("获取预警数据") + public Result> getAlertRecord(@RequestParam(name="pageNo", defaultValue="1") Integer pageNo, + @RequestParam(name="pageSize", defaultValue="10") Integer pageSize, + @RequestParam(value = "stationCode",required = false)String stationCode, + @RequestParam(value = "deployId",required = false)String deployId, + @RequestParam(value = "yearStr",required = false)String yearStr + ){ + commonService.getTenantId(null); + //效果评价 + Page page = new Page(pageNo, pageSize); + //查询站点里的所有设备 + List allList =new ArrayList<>(); + if(StringUtils.isNotBlank(stationCode)){ + List dList = survDeviceDeployService.getDeviceListByStation(stationCode, new ArrayList<>()); + dList.forEach(item->allList.add(item.getId())); + } else if (StringUtils.isNotBlank(deployId)) { + allList.add(deployId); + } + + IPage pageList = alertRecordService.pageByDevice(page, allList,yearStr); + return Result.OK(pageList); + } } diff --git a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/mapper/SurvAlertRecordMapper.java b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/mapper/SurvAlertRecordMapper.java index 21bca0e..e9c14d2 100644 --- a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/mapper/SurvAlertRecordMapper.java +++ b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/mapper/SurvAlertRecordMapper.java @@ -2,8 +2,11 @@ package org.jeecg.modules.appmana.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.metadata.IPage; +import org.apache.ibatis.annotations.Param; import org.jeecg.common.entity.SurvAlertRecord; +import java.util.List; + /** * @Description: surv_alert_record * @Author: jeecg-boot @@ -13,4 +16,8 @@ import org.jeecg.common.entity.SurvAlertRecord; public interface SurvAlertRecordMapper extends BaseMapper { IPage pages(IPage page, SurvAlertRecord survAlertRecord); + + + IPage pageByDevice(IPage page, @Param("deviceList") List deviceList, @Param("yearStr") String yearStr); + } diff --git a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/mapper/xml/SurvAlertRecordMapper.xml b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/mapper/xml/SurvAlertRecordMapper.xml index 7cfca38..b07a7e5 100644 --- a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/mapper/xml/SurvAlertRecordMapper.xml +++ b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/mapper/xml/SurvAlertRecordMapper.xml @@ -35,14 +35,33 @@ select s.STATION_NAME from surv_device_deploy t left join surv_station_info s on t.STATION_CODE = s.STATION_CODE where t.IS_DEL = 0 AND t.DEPLOY_CODE= #{DEPLOY_CODE} - + select + + from surv_alert_record where 1=1 + + and DEPLOY_CODE = #{param2.deployCode} + + + and DATE_FORMAT(ALERT_TIME,'%Y-%m-%d %H') = DATE_FORMAT(#{param2.alertTime},'%Y-%m-%d %H') + + + + + \ No newline at end of file diff --git a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/ISurvAlertRecordService.java b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/ISurvAlertRecordService.java index 9c5175b..bf73596 100644 --- a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/ISurvAlertRecordService.java +++ b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/ISurvAlertRecordService.java @@ -4,6 +4,8 @@ import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.service.IService; import org.jeecg.common.entity.SurvAlertRecord; +import java.util.List; + /** * @Description: surv_alert_record * @Author: jeecg-boot @@ -13,4 +15,6 @@ import org.jeecg.common.entity.SurvAlertRecord; public interface ISurvAlertRecordService extends IService { IPage pages(IPage page, SurvAlertRecord survAlertRecord); + + IPage pageByDevice(IPage page, List deviceList, String yearStr); } diff --git a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/impl/SurvAlertRecordServiceImpl.java b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/impl/SurvAlertRecordServiceImpl.java index 6cebc2d..456680c 100644 --- a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/impl/SurvAlertRecordServiceImpl.java +++ b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/impl/SurvAlertRecordServiceImpl.java @@ -7,6 +7,8 @@ import org.jeecg.modules.appmana.mapper.SurvAlertRecordMapper; import org.jeecg.modules.appmana.service.ISurvAlertRecordService; import org.springframework.stereotype.Service; +import java.util.List; + /** * @Description: surv_alert_record * @Author: jeecg-boot @@ -20,4 +22,9 @@ public class SurvAlertRecordServiceImpl extends ServiceImpl pages(IPage page, SurvAlertRecord survAlertRecord) { return baseMapper.pages(page,survAlertRecord); } + + @Override + public IPage pageByDevice(IPage page, List deviceList, String yearStr) { + return baseMapper.pageByDevice(page,deviceList,yearStr); + } }