diff --git a/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/controller/WebStatisticsController.java b/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/controller/WebStatisticsController.java index f28a02d5..4373e5c3 100644 --- a/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/controller/WebStatisticsController.java +++ b/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/controller/WebStatisticsController.java @@ -88,7 +88,7 @@ public class WebStatisticsController { @GetMapping("findAlertSohPage") @ApiOperation(value = "台站报警数据分页查询", notes = "台站报警数据分页查询") - public Result findAlertSohPage(QueryRequest queryRequest, Integer[] stationIds,@DateTimeFormat(pattern = "yyyy-MM-dd") Date startTime,@DateTimeFormat(pattern = "yyyy-MM-dd") Date endTime){ + public Result findAlertSohPage(QueryRequest queryRequest, Integer[] stationIds, String startTime, String endTime){ return gardsSohDataService.findAlertSohPage(queryRequest, stationIds, startTime, endTime); } diff --git a/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/entity/GardsAlertDataWeb.java b/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/entity/GardsAlertDataWeb.java index e0369000..b7ad2cf1 100644 --- a/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/entity/GardsAlertDataWeb.java +++ b/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/entity/GardsAlertDataWeb.java @@ -14,4 +14,6 @@ public class GardsAlertDataWeb extends GardsAlertData { @TableField(exist = false) private Integer no; + @TableField(exist = false) + private Integer category; } diff --git a/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/mapper/GardsAlertDataMapper.java b/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/mapper/GardsAlertDataMapper.java index c2a8c1c1..0071b991 100644 --- a/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/mapper/GardsAlertDataMapper.java +++ b/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/mapper/GardsAlertDataMapper.java @@ -1,8 +1,12 @@ package org.jeecg.modules.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import org.jeecg.modules.entity.GardsAlertDataWeb; -public interface GardsAlertDataMapper extends BaseMapper { +import java.util.List; +import java.util.Map; +public interface GardsAlertDataMapper extends BaseMapper { + Page page(Page page, Map params); } diff --git a/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/mapper/xml/GardsAlertDataMapper.xml b/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/mapper/xml/GardsAlertDataMapper.xml new file mode 100644 index 00000000..313291df --- /dev/null +++ b/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/mapper/xml/GardsAlertDataMapper.xml @@ -0,0 +1,23 @@ + + + + + + + \ No newline at end of file diff --git a/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/service/IGardsSohDataService.java b/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/service/IGardsSohDataService.java index 03392863..0549cb72 100644 --- a/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/service/IGardsSohDataService.java +++ b/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/service/IGardsSohDataService.java @@ -29,7 +29,7 @@ public interface IGardsSohDataService extends IService { * @param endTime * @return */ - Result findAlertSohPage(QueryRequest queryRequest, Integer[] stationIds, Date startTime, Date endTime); + Result findAlertSohPage(QueryRequest queryRequest, Integer[] stationIds, String startTime, String endTime); /** * 获取单个SOH对象 diff --git a/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/service/impl/GardsSohDataServiceImpl.java b/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/service/impl/GardsSohDataServiceImpl.java index 091ba4e2..e4e2ee7a 100644 --- a/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/service/impl/GardsSohDataServiceImpl.java +++ b/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/service/impl/GardsSohDataServiceImpl.java @@ -95,58 +95,32 @@ public class GardsSohDataServiceImpl extends ServiceImpl detectorsMap = (Map)redisUtil.get("detectorsMap"); - Page page = new Page<>(queryRequest.getPageNo(), queryRequest.getPageSize()); - LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.in(GardsAlertDataWeb::getStationId, stationIds); - queryWrapper.ge(GardsAlertDataWeb::getTime, startDate); - queryWrapper.le(GardsAlertDataWeb::getTime, endDate); - queryWrapper.orderByDesc(GardsAlertDataWeb::getTime); - Page alertDataPage = gardsAlertDataMapper.selectPage(page, queryWrapper); - List records = alertDataPage.getRecords(); - if (CollUtil.isEmpty(records)) - return Result.OK(alertDataPage); - // 获取Map(key: code, value: code对应内容) - Map codeMap = systemClient.codeMap(); - String flag = "Error code: "; - String regex = flag + "(\\S+)"; - for (GardsAlertDataWeb record : records) { - String alertType = record.getAlertType(); - if (!StrUtil.equals(alertType, "ALERT_SYSTEM")) - continue; - String alertText = record.getAlertText(); - if (!StrUtil.contains(alertText, flag)) - continue; - // 获取code并通过code获取对应code内容 - String code = ReUtil.getGroup1(regex, alertText); - String replace = flag + codeMap.get(code); - String replaced = ReUtil.getGroup0(regex, alertText); - // 将code替换为对应内容 - alertText = StrUtil.replace(alertText, replaced, replace); - record.setAlertText(alertText); - } + public Result findAlertSohPage(QueryRequest queryRequest, Integer[] stationIds, String startTime, String endTime) { + + Page alertDataPage = gardsAlertDataMapper.page(null, null); + List records = alertDataPage.getRecords(); + if (CollUtil.isEmpty(records)) return Result.OK(alertDataPage); - } catch (ParseException e) { - throw new RuntimeException(e); + // 获取Map(key: code, value: code对应内容) + Map codeMap = systemClient.codeMap(); + String flag = "Error code: "; + String regex = flag + "(\\S+)"; + for (GardsAlertDataWeb record : records) { + String alertType = record.getAlertType(); + if (!StrUtil.equals(alertType, "ALERT_SYSTEM")) + continue; + String alertText = record.getAlertText(); + if (!StrUtil.contains(alertText, flag)) + continue; + // 获取code并通过code获取对应code内容 + String code = ReUtil.getGroup1(regex, alertText); + String replace = flag + codeMap.get(code); + String replaced = ReUtil.getGroup0(regex, alertText); + // 将code替换为对应内容 + alertText = StrUtil.replace(alertText, replaced, replace); + record.setAlertText(alertText); } + return Result.OK(alertDataPage); } @Override