diff --git a/src/main/java/com/gunshi/project/ss/controller/WarningRuleController.java b/src/main/java/com/gunshi/project/ss/controller/WarningRuleController.java index 86896af..620816c 100644 --- a/src/main/java/com/gunshi/project/ss/controller/WarningRuleController.java +++ b/src/main/java/com/gunshi/project/ss/controller/WarningRuleController.java @@ -125,4 +125,10 @@ public class WarningRuleController{ public R audit(@RequestBody @Validated WarningAuditDto dto) { return R.ok(warningRuleInfoService.audit(dto)); } + + @Operation(summary = "预警信息审核统计") + @PostMapping("/audit/stat") + public R> auditStat(@RequestBody @Validated WarningRulePageSo page) { + return R.ok(warningRuleInfoService.auditStat(page)); + } } diff --git a/src/main/java/com/gunshi/project/ss/mapper/WarningRuleInfoMapper.java b/src/main/java/com/gunshi/project/ss/mapper/WarningRuleInfoMapper.java index 7c2c8ad..4e92067 100644 --- a/src/main/java/com/gunshi/project/ss/mapper/WarningRuleInfoMapper.java +++ b/src/main/java/com/gunshi/project/ss/mapper/WarningRuleInfoMapper.java @@ -9,6 +9,7 @@ import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Select; import java.util.List; +import java.util.Map; @Mapper public interface WarningRuleInfoMapper extends BaseMapper { @@ -85,4 +86,28 @@ public interface WarningRuleInfoMapper extends BaseMapper { """) Page auditPage(Page page,@Param("obj") WarningRulePageSo page1); + + @Select(""" + + """) + List auditStat(@Param("obj") WarningRulePageSo page); } diff --git a/src/main/java/com/gunshi/project/ss/model/AttResBuilding.java b/src/main/java/com/gunshi/project/ss/model/AttResBuilding.java index b771db4..c8ec0cc 100644 --- a/src/main/java/com/gunshi/project/ss/model/AttResBuilding.java +++ b/src/main/java/com/gunshi/project/ss/model/AttResBuilding.java @@ -145,7 +145,7 @@ public class AttResBuilding implements Serializable { private BigDecimal awaterLength; @Schema(description="副坝输水管-壁厚(m)") - private BigDecimal awaterThick; + private String awaterThick; @Schema(description="副坝输水管-最大流量(m³/s)") private BigDecimal awaterMaxFlow; @@ -190,10 +190,10 @@ public class AttResBuilding implements Serializable { private BigDecimal waterConveyanceInletElevation; @Schema(description="东输水隧洞-长度") - private BigDecimal waterConveyanceLength; + private String waterConveyanceLength; @Schema(description="东输水隧洞-壁厚(m)") - private BigDecimal waterConveyanceThick; + private String waterConveyanceThick; @Schema(description="东输水隧洞-最大流量(m³/s)") private BigDecimal waterConveyanceMaxFlow; diff --git a/src/main/java/com/gunshi/project/ss/service/WarningRuleInfoService.java b/src/main/java/com/gunshi/project/ss/service/WarningRuleInfoService.java index 124a135..930f6f3 100644 --- a/src/main/java/com/gunshi/project/ss/service/WarningRuleInfoService.java +++ b/src/main/java/com/gunshi/project/ss/service/WarningRuleInfoService.java @@ -1,6 +1,7 @@ package com.gunshi.project.ss.service; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; @@ -67,8 +68,14 @@ public class WarningRuleInfoService extends ServiceImpl().eq("warning_info_id",warningRuleInfo.getId())); objService.saveOrUpdateBatch(warningRuleInfo.getObjs()); return "发布成功"; } @@ -108,4 +115,9 @@ public class WarningRuleInfoService extends ServiceImpl auditStat(WarningRulePageSo page) { + List list= this.baseMapper.auditStat(page); + return list.stream().collect(Collectors.groupingBy(WarningRuleInfo::getWarningType, Collectors.counting())); + } }