diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/controller/HiddenDangerController.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/controller/HiddenDangerController.java index b4b82f1..bebcfae 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/controller/HiddenDangerController.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/controller/HiddenDangerController.java @@ -1,20 +1,16 @@ package com.hbt.safety.supervision.controller; -import java.util.List; - import com.alibaba.fastjson.JSONObject; +import com.github.pagehelper.PageInfo; +import com.hbt.common.core.domain.R; import com.hbt.safety.supervision.pojo.HiddenDanger; import com.hbt.safety.supervision.service.IHiddenDangerService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.bind.annotation.*; import com.hbt.common.core.web.controller.BaseController; import com.hbt.common.core.web.domain.AjaxResult; -import com.hbt.common.core.web.page.TableDataInfo; /** * 隐患Controller @@ -31,15 +27,17 @@ public class HiddenDangerController extends BaseController /** * 查询隐患列表 + * + * @param currentPage 当前页 + * @param pageSize 每页条数 + * @return 返回值 */ @ApiOperation("查询隐患列表") @GetMapping("/list") - public String list() + public R> list(@RequestParam(value = "currentPage") int currentPage, @RequestParam(value = "pageSize") int pageSize) { - startPage(); - List list = hiddenDangerService.selectHiddenDangerList(); - TableDataInfo tableDataInfo = getDataTable(list); - return JSONObject.toJSONString(tableDataInfo); + PageInfo pageInfo = hiddenDangerService.selectHiddenDangerList(currentPage, pageSize); + return R.ok(pageInfo); } /** diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/controller/LawEnforcementInspectionController.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/controller/LawEnforcementInspectionController.java index a41f7e1..5887f24 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/controller/LawEnforcementInspectionController.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/controller/LawEnforcementInspectionController.java @@ -1,20 +1,16 @@ package com.hbt.safety.supervision.controller; -import java.util.List; - import com.alibaba.fastjson.JSONObject; +import com.github.pagehelper.PageInfo; +import com.hbt.common.core.domain.R; import com.hbt.safety.supervision.pojo.LawEnforcementInspection; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.bind.annotation.*; import com.hbt.safety.supervision.service.ILawEnforcementInspectionService; import com.hbt.common.core.web.controller.BaseController; import com.hbt.common.core.web.domain.AjaxResult; -import com.hbt.common.core.web.page.TableDataInfo; /** * 执法巡查Controller @@ -31,14 +27,17 @@ public class LawEnforcementInspectionController extends BaseController /** * 查询执法巡查列表 + * + * @param currentPage 当前页 + * @param pageSize 每页条数 + * @return 返回值 */ @ApiOperation("查询执法巡查列表") @GetMapping("/list") - public String list() + public R> list(@RequestParam(value = "currentPage") int currentPage, @RequestParam(value = "pageSize") int pageSize) { - List list = lawEnforcementInspectionService.selectLawEnforcementInspectionList(); - TableDataInfo tableDataInfo = getDataTable(list); - return JSONObject.toJSONString(tableDataInfo); + PageInfo pageInfo = lawEnforcementInspectionService.selectLawEnforcementInspectionList(currentPage, pageSize); + return R.ok(pageInfo); } /** diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/controller/RiskController.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/controller/RiskController.java index 2c178ad..8146f32 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/controller/RiskController.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/controller/RiskController.java @@ -1,16 +1,13 @@ package com.hbt.safety.supervision.controller; -import java.util.List; - import com.alibaba.fastjson.JSONObject; +import com.github.pagehelper.PageInfo; +import com.hbt.common.core.domain.R; import com.hbt.safety.supervision.pojo.Risk; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.bind.annotation.*; import com.hbt.safety.supervision.service.IRiskService; import com.hbt.common.core.web.controller.BaseController; import com.hbt.common.core.web.domain.AjaxResult; @@ -30,13 +27,17 @@ public class RiskController extends BaseController /** * 查询风险列表 + * + * @param currentPage 当前页 + * @param pageSize 每页条数 + * @return 返回值 */ @ApiOperation("查询风险列表") @GetMapping("/list") - public String list() + public R> list(@RequestParam(value = "currentPage") int currentPage, @RequestParam(value = "pageSize") int pageSize) { - List list = riskService.selectRiskList(); - return JSONObject.toJSONString(list); + PageInfo pageInfo = riskService.selectRiskList(currentPage, pageSize); + return R.ok(pageInfo); } /** diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/EnterpriseInformationMapper.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/EnterpriseInformationMapper.java index 217718c..85f1823 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/EnterpriseInformationMapper.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/EnterpriseInformationMapper.java @@ -4,6 +4,7 @@ import java.util.List; import java.util.Map; import com.hbt.safety.supervision.pojo.EnterpriseInformation; +import com.hbt.safety.supervision.pojo.vo.StatisticsVo; /** * 企业信息Mapper接口 @@ -71,7 +72,7 @@ public interface EnterpriseInformationMapper * * @return 统计信息 */ - List> enterpriseStatistics(); + List enterpriseStatistics(); /** * 获取在管企业数量 diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/EscalateHiddenDangerMapper.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/EscalateHiddenDangerMapper.java index c5fe7c9..169c099 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/EscalateHiddenDangerMapper.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/EscalateHiddenDangerMapper.java @@ -9,7 +9,6 @@ import com.hbt.safety.supervision.pojo.HiddenDanger; * 上报隐患Mapper接口 * * @author 张雨 - * @date 2023-02-14 */ public interface EscalateHiddenDangerMapper { diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/EscalateRiskMapper.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/EscalateRiskMapper.java index f88a604..ea1b1bf 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/EscalateRiskMapper.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/EscalateRiskMapper.java @@ -7,7 +7,6 @@ import com.hbt.safety.supervision.pojo.EscalateRisk; * 上报风险Mapper接口 * * @author 张雨 - * @date 2023-02-14 */ public interface EscalateRiskMapper { diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/HazardousOperationMapper.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/HazardousOperationMapper.java index 96d5f40..8705a06 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/HazardousOperationMapper.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/HazardousOperationMapper.java @@ -9,7 +9,6 @@ import com.hbt.safety.supervision.pojo.HazardousOperation; * 危险作业Mapper接口 * * @author zhangyu - * @date 2023-02-14 */ public interface HazardousOperationMapper { diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/HiddenDangerMapper.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/HiddenDangerMapper.java index 0bceb00..71b1cd2 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/HiddenDangerMapper.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/HiddenDangerMapper.java @@ -10,7 +10,6 @@ import org.apache.ibatis.annotations.Param; * 隐患Mapper接口 * * @author hbt - * @date 2023-02-14 */ public interface HiddenDangerMapper { diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/LawEnforcementInspectionMapper.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/LawEnforcementInspectionMapper.java index bee9ab5..9247d12 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/LawEnforcementInspectionMapper.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/LawEnforcementInspectionMapper.java @@ -10,7 +10,6 @@ import com.hbt.safety.supervision.pojo.vo.LawEnforcementInspectionVo; * 执法巡查Mapper接口 * * @author zhangyu - * @date 2023-02-14 */ public interface LawEnforcementInspectionMapper { diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/MajorHazardSourcesMapper.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/MajorHazardSourcesMapper.java index a9f8242..04a4e37 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/MajorHazardSourcesMapper.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/MajorHazardSourcesMapper.java @@ -8,7 +8,6 @@ import com.hbt.safety.supervision.pojo.MajorHazardSources; * 重大危险源Mapper接口 * * @author zhangyu - * @date 2023-02-14 */ public interface MajorHazardSourcesMapper { diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/PersonMapper.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/PersonMapper.java index 1add5c8..61743d7 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/PersonMapper.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/PersonMapper.java @@ -8,7 +8,6 @@ import com.hbt.safety.supervision.pojo.Person; * 人员信息Mapper接口 * * @author 张雨 - * @date 2023-02-14 */ public interface PersonMapper { /** diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/RiskAreaMapper.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/RiskAreaMapper.java index 16ba966..7c799a0 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/RiskAreaMapper.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/RiskAreaMapper.java @@ -7,7 +7,6 @@ import com.hbt.safety.supervision.pojo.RiskArea; * 风险区域Mapper接口 * * @author 张雨 - * @date 2023-02-14 */ public interface RiskAreaMapper { diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/RiskMapper.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/RiskMapper.java index fb24383..0c9819d 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/RiskMapper.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/mapper/RiskMapper.java @@ -12,7 +12,6 @@ import org.apache.ibatis.annotations.Param; * 风险Mapper接口 * * @author 张雨 - * @date 2023-02-14 */ @Mapper public interface RiskMapper @@ -69,7 +68,7 @@ public interface RiskMapper * * @return 返回值 */ - List> riskStatistics(); + List riskStatistics(); /** * 查询风险列表 diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/EnterpriseInformation.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/EnterpriseInformation.java index 1431c0d..2be695d 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/EnterpriseInformation.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/EnterpriseInformation.java @@ -9,7 +9,6 @@ import lombok.Data; * 企业信息对象 enterprise_information * * @author zhangyu - * @date 2023-02-14 */ @ApiModel @Data diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/EscalateHiddenDanger.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/EscalateHiddenDanger.java index 06eed76..ff5f4c6 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/EscalateHiddenDanger.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/EscalateHiddenDanger.java @@ -8,7 +8,6 @@ import lombok.Data; * 上报隐患对象 escalate_hidden_danger * * @author 张雨 - * @date 2023-02-14 */ @Data public class EscalateHiddenDanger extends BaseEntity diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/EscalateRisk.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/EscalateRisk.java index 45bdb85..714a978 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/EscalateRisk.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/EscalateRisk.java @@ -8,7 +8,6 @@ import lombok.Data; * 上报风险对象 escalate_risk * * @author 张雨 - * @date 2023-02-14 */ @Data public class EscalateRisk extends BaseEntity diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/HazardousOperation.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/HazardousOperation.java index 39bfb56..aad280c 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/HazardousOperation.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/HazardousOperation.java @@ -9,7 +9,6 @@ import lombok.Data; * 危险作业对象 hazardous_operation * * @author zhangyu - * @date 2023-02-14 */ @ApiModel @Data diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/HiddenDanger.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/HiddenDanger.java index 2d71868..5215ba0 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/HiddenDanger.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/HiddenDanger.java @@ -9,7 +9,6 @@ import lombok.Data; * 隐患对象 hidden_danger * * @author hbt - * @date 2023-02-14 */ @ApiModel @Data diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/MajorHazardSources.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/MajorHazardSources.java index 202ec60..cc28253 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/MajorHazardSources.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/MajorHazardSources.java @@ -9,7 +9,6 @@ import lombok.Data; * 重大危险源对象 major_hazard_sources * * @author zhangyu - * @date 2023-02-14 */ @ApiModel @Data diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/Person.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/Person.java index f75572b..833b221 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/Person.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/Person.java @@ -7,7 +7,6 @@ import lombok.Data; * 人员信息对象 person * * @author 张雨 - * @date 2023-02-14 */ @Data public class Person extends BaseEntity diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/Risk.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/Risk.java index 79ade0d..6c5b789 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/Risk.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/Risk.java @@ -9,7 +9,6 @@ import lombok.Data; * 风险对象 risk * * @author 张雨 - * @date 2023-02-14 */ @ApiModel @Data diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/RiskArea.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/RiskArea.java index 0bdef43..53616c4 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/RiskArea.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/RiskArea.java @@ -8,7 +8,6 @@ import lombok.Data; * 风险区域对象 risk_area * * @author 张雨 - * @date 2023-02-14 */ @Data public class RiskArea extends BaseEntity diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/vo/StatisticsVo.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/vo/StatisticsVo.java index 308f0d4..3945b77 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/vo/StatisticsVo.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/pojo/vo/StatisticsVo.java @@ -1,14 +1,21 @@ package com.hbt.safety.supervision.pojo.vo; import lombok.Data; +import lombok.NoArgsConstructor; /** * 统计数据vo */ @Data +@NoArgsConstructor public class StatisticsVo { private int classify; // 分类 private int count; // 数量 + + public StatisticsVo(int classify, int count) { + this.classify = classify; + this.count = count; + } } diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IEnterpriseInformationService.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IEnterpriseInformationService.java index 1f2b822..b0fcccd 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IEnterpriseInformationService.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IEnterpriseInformationService.java @@ -8,7 +8,6 @@ import com.hbt.safety.supervision.pojo.EnterpriseInformation; * 企业信息Service接口 * * @author zhangyu - * @date 2023-02-14 */ public interface IEnterpriseInformationService { diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IEscalateHiddenDangerService.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IEscalateHiddenDangerService.java index 2b336c3..61472a7 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IEscalateHiddenDangerService.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IEscalateHiddenDangerService.java @@ -9,7 +9,6 @@ import com.hbt.safety.supervision.pojo.HiddenDanger; * 上报隐患Service接口 * * @author 张雨 - * @date 2023-02-14 */ public interface IEscalateHiddenDangerService { diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IEscalateRiskService.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IEscalateRiskService.java index 64c3ded..6bec48d 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IEscalateRiskService.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IEscalateRiskService.java @@ -8,7 +8,6 @@ import com.hbt.safety.supervision.pojo.EscalateRisk; * 上报风险Service接口 * * @author 张雨 - * @date 2023-02-14 */ public interface IEscalateRiskService { diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IHazardousOperationService.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IHazardousOperationService.java index 83e0764..01dab44 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IHazardousOperationService.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IHazardousOperationService.java @@ -8,7 +8,6 @@ import com.hbt.safety.supervision.pojo.HazardousOperation; * 危险作业Service接口 * * @author zhangyu - * @date 2023-02-14 */ public interface IHazardousOperationService { diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IHiddenDangerService.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IHiddenDangerService.java index 6839923..2c809d7 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IHiddenDangerService.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IHiddenDangerService.java @@ -1,14 +1,12 @@ package com.hbt.safety.supervision.service; -import java.util.List; - +import com.github.pagehelper.PageInfo; import com.hbt.safety.supervision.pojo.HiddenDanger; /** * 隐患Service接口 * * @author hbt - * @date 2023-02-14 */ public interface IHiddenDangerService { @@ -23,9 +21,11 @@ public interface IHiddenDangerService /** * 查询隐患列表 * - * @return 隐患集合 + * @param currentPage 当前页 + * @param pageSize 每页条数 + * @return 返回值 */ - List selectHiddenDangerList(); + PageInfo selectHiddenDangerList(int currentPage, int pageSize); /** * 新增隐患 diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/ILawEnforcementInspectionService.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/ILawEnforcementInspectionService.java index a77a086..411a0a8 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/ILawEnforcementInspectionService.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/ILawEnforcementInspectionService.java @@ -1,14 +1,13 @@ package com.hbt.safety.supervision.service; -import java.util.List; +import com.github.pagehelper.PageInfo; import com.hbt.safety.supervision.pojo.LawEnforcementInspection; /** * 执法巡查Service接口 * * @author zhangyu - * @date 2023-02-14 */ public interface ILawEnforcementInspectionService { @@ -23,9 +22,11 @@ public interface ILawEnforcementInspectionService /** * 查询执法巡查列表 * - * @return 执法巡查集合 + * @param currentPage 当前页 + * @param pageSize 每页条数 + * @return 返回值 */ - List selectLawEnforcementInspectionList(); + PageInfo selectLawEnforcementInspectionList(int currentPage, int pageSize); /** * 新增执法巡查 diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IMajorHazardSourcesService.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IMajorHazardSourcesService.java index d0790b4..905f233 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IMajorHazardSourcesService.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IMajorHazardSourcesService.java @@ -7,7 +7,6 @@ import com.hbt.safety.supervision.pojo.MajorHazardSources; * 重大危险源Service接口 * * @author zhangyu - * @date 2023-02-14 */ public interface IMajorHazardSourcesService { diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IPersonService.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IPersonService.java index 909a28a..e250f5e 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IPersonService.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IPersonService.java @@ -8,7 +8,6 @@ import com.hbt.safety.supervision.pojo.Person; * 人员信息Service接口 * * @author 张雨 - * @date 2023-02-14 */ public interface IPersonService { diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IRiskAreaService.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IRiskAreaService.java index 31e179e..73f9b66 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IRiskAreaService.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IRiskAreaService.java @@ -7,7 +7,6 @@ import com.hbt.safety.supervision.pojo.RiskArea; * 风险区域Service接口 * * @author 张雨 - * @date 2023-02-14 */ public interface IRiskAreaService { diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IRiskService.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IRiskService.java index 2e43ad5..b59f142 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IRiskService.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/IRiskService.java @@ -1,14 +1,12 @@ package com.hbt.safety.supervision.service; -import java.util.List; - +import com.github.pagehelper.PageInfo; import com.hbt.safety.supervision.pojo.Risk; /** * 风险Service接口 * * @author 张雨 - * @date 2023-02-14 */ public interface IRiskService { @@ -23,9 +21,11 @@ public interface IRiskService /** * 查询风险列表 * - * @return 风险集合 + * @param currentPage 当前页 + * @param pageSize 每页条数 + * @return 返回值 */ - List selectRiskList(); + PageInfo selectRiskList(int currentPage, int pageSize); /** * 新增风险 diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/EnterpriseInformationServiceImpl.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/EnterpriseInformationServiceImpl.java index 3ecacca..637ebf4 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/EnterpriseInformationServiceImpl.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/EnterpriseInformationServiceImpl.java @@ -3,23 +3,30 @@ package com.hbt.safety.supervision.service.impl; import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.stream.Collectors; import com.alibaba.fastjson.JSONObject; import com.hbt.safety.supervision.mapper.EnterpriseInformationMapper; import com.hbt.safety.supervision.pojo.EnterpriseInformation; +import com.hbt.safety.supervision.pojo.MajorHazardSources; +import com.hbt.safety.supervision.pojo.vo.StatisticsVo; import com.hbt.safety.supervision.service.IEnterpriseInformationService; import com.hbt.safety.supervision.mapper.PersonMapper; +import com.hbt.safety.supervision.util.StatisticsResultUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.util.CollectionUtils; /** * 企业信息Service业务层处理 * * @author zhangyu - * @date 2023-02-14 */ @Service public class EnterpriseInformationServiceImpl implements IEnterpriseInformationService { + + /** 企业分类 */ + private static final int ENTERPRISE_CLASSIFY = 3; @Autowired private EnterpriseInformationMapper enterpriseInformationMapper; @@ -100,18 +107,28 @@ public class EnterpriseInformationServiceImpl implements IEnterpriseInformationS public String enterpriseStatistics() { Map map = new HashMap<>(); // 企业分类及数量 - List> list = enterpriseInformationMapper.enterpriseStatistics(); - // 在管企业数量 - int enterpriseCount = enterpriseInformationMapper.getEnterpriseCount(); - // 企业员工数 - int personCount = personMapper.getPersonCount(); + List list = enterpriseInformationMapper.enterpriseStatistics(); + if (CollectionUtils.isEmpty(list)) { + map.put("enterpriseClassification", StatisticsResultUtil.defaultResultStatistics(ENTERPRISE_CLASSIFY)); + map.put("enterpriseCount", 0); + map.put("personCount", 0); + map.put("carCount", 0); + } else { + Map enterpriseMap = list.stream() + .collect(Collectors.groupingBy(EnterpriseInformation :: getType, Collectors.counting())); + // 在管企业数量 + int enterpriseCount = enterpriseInformationMapper.getEnterpriseCount(); + // 企业员工数 + int personCount = personMapper.getPersonCount(); + + // 等级车辆数 + int carCount = enterpriseInformationMapper.getCarCount(); + map.put("enterpriseClassification", StatisticsResultUtil.resultStatistics(ENTERPRISE_CLASSIFY, enterpriseMap)); + map.put("enterpriseCount", enterpriseCount); + map.put("personCount", personCount); + map.put("carCount", carCount); + } - // 等级车辆数 - int carCount = enterpriseInformationMapper.getCarCount(); - map.put("enterpriseClassification", list); - map.put("enterpriseCount", enterpriseCount); - map.put("personCount", personCount); - map.put("carCount", carCount); return JSONObject.toJSONString(map); } } diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/EscalateHiddenDangerServiceImpl.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/EscalateHiddenDangerServiceImpl.java index 453a1bb..0069134 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/EscalateHiddenDangerServiceImpl.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/EscalateHiddenDangerServiceImpl.java @@ -13,7 +13,6 @@ import org.springframework.stereotype.Service; * 上报隐患Service业务层处理 * * @author 张雨 - * @date 2023-02-14 */ @Service public class EscalateHiddenDangerServiceImpl implements IEscalateHiddenDangerService diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/EscalateRiskServiceImpl.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/EscalateRiskServiceImpl.java index 78ca24f..e88453a 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/EscalateRiskServiceImpl.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/EscalateRiskServiceImpl.java @@ -12,7 +12,6 @@ import com.hbt.safety.supervision.service.IEscalateRiskService; * 上报风险Service业务层处理 * * @author 张雨 - * @date 2023-02-14 */ @Service public class EscalateRiskServiceImpl implements IEscalateRiskService diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/HazardousOperationServiceImpl.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/HazardousOperationServiceImpl.java index 5990540..844cf36 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/HazardousOperationServiceImpl.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/HazardousOperationServiceImpl.java @@ -9,6 +9,7 @@ import com.hbt.safety.supervision.pojo.HazardousOperation; import com.hbt.safety.supervision.pojo.vo.DateVo; import com.hbt.safety.supervision.pojo.vo.HazardousOperationWeekDateVo; import com.hbt.safety.supervision.pojo.vo.StatisticsVo; +import com.hbt.safety.supervision.util.StatisticsResultUtil; import com.hbt.safety.supervision.util.YearWeeksUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -19,11 +20,13 @@ import com.hbt.safety.supervision.service.IHazardousOperationService; * 危险作业Service业务层处理 * * @author zhangyu - * @date 2023-02-14 */ @Service public class HazardousOperationServiceImpl implements IHazardousOperationService { + + /** 危险作业类型 */ + private static final int OPRATION_TYPE = 9; @Autowired private HazardousOperationMapper hazardousOperationMapper; @@ -113,42 +116,39 @@ public class HazardousOperationServiceImpl implements IHazardousOperationService // 查询危险作业信息 List list = hazardousOperationMapper.selectHazardousOperations(); if (list == null) { - return ""; + map.put("operationTypeList", StatisticsResultUtil.defaultResultStatistics(OPRATION_TYPE)); + map.put("underwayHazardousOperation",0); + map.put("underwayEnterprise", 0); + map.put("toBeStarted", 0); + map.put("historyHazardousOperation", 0); + } else { + Map typeList = list.stream() + .collect(Collectors.groupingBy(HazardousOperation::getOperationType, Collectors.counting())); + map.put("operationTypeList", StatisticsResultUtil.resultStatistics(OPRATION_TYPE, typeList)); + + // 进行中的危险作业 + List hazardousOperations = list.stream() + .filter(s -> s.getOperationStart().compareTo(dateNowStr) <= 0 + && s.getOperationEnd().compareTo(dateNowStr) >= 0) + .collect(Collectors.toList()); + map.put("underwayHazardousOperation", hazardousOperations.size()); + + // 进行危险作业企业 + int underwayEnterprise =hazardousOperations.stream() + .collect(Collectors.groupingBy(HazardousOperation :: getEnterpriseId)).keySet().size(); + map.put("underwayEnterprise", underwayEnterprise); + + // 待开始危险作业 + int toBeStarted = (int) list.stream() + .filter(s -> s.getOperationStart().compareTo(dateNowStr) > 0).count(); + map.put("toBeStarted", toBeStarted); + + // 历史危险作业 + int historyHazardousOperation = (int) list.stream() + .filter(s -> s.getOperationEnd().compareTo(dateNowStr) < 0).count(); + map.put("historyHazardousOperation", historyHazardousOperation); } - Map> typeList = list.stream() - .collect(Collectors.groupingBy(HazardousOperation::getOperationType)); - // 组装类型统计数据 - List operationTypeList = new ArrayList<>(); - for(Object key : typeList.keySet()) { - StatisticsVo statisticsVo = new StatisticsVo(); - statisticsVo.setClassify(Integer.parseInt(key.toString())); - statisticsVo.setCount(typeList.get(key).size()); - operationTypeList.add(statisticsVo); - } - map.put("operationTypeList", JSONObject.toJSONString(operationTypeList)); - // 进行中的危险作业 - List hazardousOperations = list.stream() - .filter(s -> s.getOperationStart().compareTo(dateNowStr) <= 0 &&s.getOperationEnd().compareTo(dateNowStr) >= 0) - .collect(Collectors.toList()); - map.put("underwayHazardousOperation", hazardousOperations.size()); - - // 进行危险作业企业 - int underwayEnterprise = hazardousOperations.stream().collect( - Collectors.collectingAndThen( - Collectors.toCollection(() -> new TreeSet<> - (Comparator.comparing(HazardousOperation :: getEnterpriseId))), ArrayList:: new)).size(); - map.put("underwayEnterprise", underwayEnterprise); - - // 待开始危险作业 - int toBeStarted = (int) list.stream() - .filter(s -> s.getOperationStart().compareTo(dateNowStr) > 0).count(); - map.put("toBeStarted", toBeStarted); - - // 历史危险作业 - int historyHazardousOperation = (int) list.stream() - .filter(s -> s.getOperationEnd().compareTo(dateNowStr) < 0).count(); - map.put("historyHazardousOperation", historyHazardousOperation); return JSONObject.toJSONString(map); } diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/HiddenDangerServiceImpl.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/HiddenDangerServiceImpl.java index 4f025d9..ad42350 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/HiddenDangerServiceImpl.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/HiddenDangerServiceImpl.java @@ -5,14 +5,18 @@ import java.util.stream.Collectors; import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson2.JSON; +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; import com.hbt.safety.supervision.mapper.HiddenDangerMapper; import com.hbt.safety.supervision.pojo.HiddenDanger; import com.hbt.safety.supervision.pojo.vo.DateVo; import com.hbt.safety.supervision.pojo.vo.StatisticsVo; import com.hbt.safety.supervision.service.IHiddenDangerService; +import com.hbt.safety.supervision.util.StatisticsResultUtil; import com.hbt.safety.supervision.util.YearWeeksUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.util.CollectionUtils; /** * 隐患Service业务层处理 @@ -22,6 +26,8 @@ import org.springframework.stereotype.Service; @Service public class HiddenDangerServiceImpl implements IHiddenDangerService { + /** 隐患治理状态 */ + private static final int HIDDENDANGER_STATUS = 4; @Autowired private HiddenDangerMapper hiddenDangerMapper; @@ -40,12 +46,16 @@ public class HiddenDangerServiceImpl implements IHiddenDangerService /** * 查询隐患列表 * - * @return 隐患 + * @param currentPage 当前页 + * @param pageSize 每页条数 + * @return 返回值 */ @Override - public List selectHiddenDangerList() + public PageInfo selectHiddenDangerList(int currentPage, int pageSize) { - return hiddenDangerMapper.selectHiddenDangerList(); + PageHelper.startPage(currentPage, pageSize); + List list = hiddenDangerMapper.selectHiddenDangerList(); + return new PageInfo<>(list); } /** @@ -103,20 +113,13 @@ public class HiddenDangerServiceImpl implements IHiddenDangerService Map map = new HashMap<>(); List list = hiddenDangerMapper.selectHiddenDangers(); - if (list == null) { - return ""; + if (CollectionUtils.isEmpty(list)) { + map.put("hiddenDangerList", StatisticsResultUtil.defaultResultStatistics(HIDDENDANGER_STATUS)); + return JSONObject.toJSONString(map); } - Map> hiddenDangerMap = list.stream() - .collect(Collectors.groupingBy(HiddenDanger::getReformStatus)); - // 组装隐患状态统计数据 - List hiddenDangerList = new ArrayList<>(); - for(Object key : hiddenDangerMap.keySet()) { - StatisticsVo statisticsVo = new StatisticsVo(); - statisticsVo.setClassify(Integer.parseInt(key.toString())); - statisticsVo.setCount(hiddenDangerMap.get(key).size()); - hiddenDangerList.add(statisticsVo); - } - map.put("hiddenDangerList", JSONObject.toJSONString(hiddenDangerList)); + Map hiddenDangerMap = list.stream() + .collect(Collectors.groupingBy(HiddenDanger::getReformStatus, Collectors.counting())); + map.put("hiddenDangerList", StatisticsResultUtil.resultStatistics(HIDDENDANGER_STATUS, hiddenDangerMap)); return JSONObject.toJSONString(map); } diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/LawEnforcementInspectionServiceImpl.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/LawEnforcementInspectionServiceImpl.java index 4437202..fb71e5e 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/LawEnforcementInspectionServiceImpl.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/LawEnforcementInspectionServiceImpl.java @@ -4,6 +4,8 @@ import java.util.*; import java.util.stream.Collectors; import com.alibaba.fastjson.JSONObject; +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; import com.hbt.safety.supervision.mapper.EscalateHiddenDangerMapper; import com.hbt.safety.supervision.mapper.EscalateRiskMapper; import com.hbt.safety.supervision.mapper.LawEnforcementInspectionMapper; @@ -19,7 +21,6 @@ import com.hbt.safety.supervision.service.ILawEnforcementInspectionService; * 执法巡查Service业务层处理 * * @author zhangyu - * @date 2023-02-14 */ @Service public class LawEnforcementInspectionServiceImpl implements ILawEnforcementInspectionService @@ -48,12 +49,16 @@ public class LawEnforcementInspectionServiceImpl implements ILawEnforcementInspe /** * 查询执法巡查列表 * - * @return 执法巡查 + * @param currentPage 当前页 + * @param pageSize 每页条数 + * @return 返回值 */ @Override - public List selectLawEnforcementInspectionList() + public PageInfo selectLawEnforcementInspectionList(int currentPage, int pageSize) { - return lawEnforcementInspectionMapper.selectLawEnforcementInspectionList(); + PageHelper.startPage(currentPage, pageSize); + List list = lawEnforcementInspectionMapper.selectLawEnforcementInspectionList(); + return new PageInfo<>(list); } /** diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/MajorHazardSourcesServiceImpl.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/MajorHazardSourcesServiceImpl.java index fb86471..f5d722b 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/MajorHazardSourcesServiceImpl.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/MajorHazardSourcesServiceImpl.java @@ -9,19 +9,22 @@ import com.alibaba.fastjson.JSONObject; import com.hbt.safety.supervision.pojo.vo.StatisticsVo; import com.hbt.safety.supervision.service.IMajorHazardSourcesService; import com.hbt.safety.supervision.pojo.MajorHazardSources; +import com.hbt.safety.supervision.util.StatisticsResultUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.hbt.safety.supervision.mapper.MajorHazardSourcesMapper; +import org.springframework.util.CollectionUtils; /** * 重大危险源Service业务层处理 * * @author zhangyu - * @date 2023-02-14 */ @Service public class MajorHazardSourcesServiceImpl implements IMajorHazardSourcesService { + + private static final int DANGER_LEVEL = 4; @Autowired private MajorHazardSourcesMapper majorHazardSourcesMapper; @@ -104,34 +107,27 @@ public class MajorHazardSourcesServiceImpl implements IMajorHazardSourcesService // 查询重大危险源信息 List list = majorHazardSourcesMapper.majorHazardSourcesStatistics(); - if (list == null) { - return ""; + if (CollectionUtils.isEmpty(list)) { + // 返回默认值 + map.put("dangerLevelList", StatisticsResultUtil.defaultResultStatistics(DANGER_LEVEL)); + map.put("productionUnit", 0); + map.put("storageCell", 0); + } else { + // 根据风险等级分组 + Map typeList = list.stream() + .collect(Collectors.groupingBy(MajorHazardSources::getDangerLevel, Collectors.counting())); + map.put("dangerLevelList", StatisticsResultUtil.resultStatistics(DANGER_LEVEL, typeList)); + // 获取生产单元数量 + int productionUnit = (int) list.stream() + .filter(s -> s.getUnitType() == 0).count(); + map.put("productionUnit", productionUnit); + + // 获取存储单元数量 + int storageCell = (int) list.stream() + .filter(s -> s.getUnitType() == 0).count(); + map.put("storageCell", storageCell); } - // 根据风险等级分组 - Map> typeList = list.stream() - .collect(Collectors.groupingBy(MajorHazardSources::getDangerLevel)); - - // 组装风险等级统计数据 - List dangerLevelList = new ArrayList<>(); - for(Object key : typeList.keySet()) { - StatisticsVo statisticsVo = new StatisticsVo(); - statisticsVo.setClassify(Integer.parseInt(key.toString())); - statisticsVo.setCount(typeList.get(key).size()); - dangerLevelList.add(statisticsVo); - } - map.put("dangerLevelList", JSONObject.toJSONString(dangerLevelList)); - - // 获取生产单元数量 - int productionUnit = (int) list.stream() - .filter(s -> s.getUnitType() == 0).count(); - map.put("productionUnit", productionUnit); - - // 获取存储单元数量 - int storageCell = (int) list.stream() - .filter(s -> s.getUnitType() == 0).count(); - map.put("storageCell", storageCell); - return JSONObject.toJSONString(map); } } diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/PersonServiceImpl.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/PersonServiceImpl.java index f2c8e7b..2c7dbe0 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/PersonServiceImpl.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/PersonServiceImpl.java @@ -12,7 +12,6 @@ import com.hbt.safety.supervision.service.IPersonService; * 人员信息Service业务层处理 * * @author 张雨 - * @date 2023-02-14 */ @Service public class PersonServiceImpl implements IPersonService diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/RiskAreaServiceImpl.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/RiskAreaServiceImpl.java index 34e5367..259fd3d 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/RiskAreaServiceImpl.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/RiskAreaServiceImpl.java @@ -12,7 +12,6 @@ import org.springframework.stereotype.Service; * 风险区域Service业务层处理 * * @author 张雨 - * @date 2023-02-14 */ @Service public class RiskAreaServiceImpl implements IRiskAreaService diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/RiskServiceImpl.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/RiskServiceImpl.java index d0c93cb..79f5d82 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/RiskServiceImpl.java +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/service/impl/RiskServiceImpl.java @@ -4,23 +4,28 @@ import java.util.*; import java.util.stream.Collectors; import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSONObject; +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; import com.hbt.safety.supervision.mapper.RiskMapper; import com.hbt.safety.supervision.pojo.Risk; import com.hbt.safety.supervision.pojo.vo.DateVo; import com.hbt.safety.supervision.service.IRiskService; +import com.hbt.safety.supervision.util.StatisticsResultUtil; import com.hbt.safety.supervision.util.YearWeeksUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.util.CollectionUtils; /** * 风险Service业务层处理 * * @author 张雨 - * @date 2023-02-14 */ @Service public class RiskServiceImpl implements IRiskService { + /** 风险等级 */ + private static final int RISK_LEVEL = 4; @Autowired private RiskMapper riskMapper; @@ -37,14 +42,18 @@ public class RiskServiceImpl implements IRiskService } /** - * 查询风险列表 + * 查询执法巡查列表 * - * @return 风险 + * @param currentPage 当前页 + * @param pageSize 每页条数 + * @return 返回值 */ @Override - public List selectRiskList() + public PageInfo selectRiskList(int currentPage, int pageSize) { - return riskMapper.selectRiskList(); + PageHelper.startPage(currentPage, pageSize); + List list = riskMapper.selectRiskList(); + return new PageInfo<>(list); } /** @@ -96,8 +105,13 @@ public class RiskServiceImpl implements IRiskService } public String riskStatistics() { - List> map = riskMapper.riskStatistics(); - return JSONObject.toJSONString(map); + List list = riskMapper.riskStatistics(); + if (CollectionUtils.isEmpty(list)) { + return StatisticsResultUtil.defaultResultStatistics(RISK_LEVEL); + } + Map typeList = list.stream() + .collect(Collectors.groupingBy(Risk :: getLevel, Collectors.counting())); + return StatisticsResultUtil.resultStatistics(RISK_LEVEL, typeList); } /** diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/util/StatisticsResultUtil.java b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/util/StatisticsResultUtil.java new file mode 100644 index 0000000..21f0a2f --- /dev/null +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/java/com/hbt/safety/supervision/util/StatisticsResultUtil.java @@ -0,0 +1,32 @@ +package com.hbt.safety.supervision.util; + +import com.alibaba.fastjson2.JSONObject; +import com.hbt.safety.supervision.pojo.vo.StatisticsVo; + +import java.util.ArrayList; +import java.util.List; +import java.util.Map; + +public class StatisticsResultUtil { + + public static String defaultResultStatistics(int count) { + List list = new ArrayList<>(); + for (int i = 1; i <= count; i++) { + StatisticsVo statisticsVo = new StatisticsVo(i, 0); + list.add(statisticsVo); + } + return JSONObject.toJSONString(list); + } + + public static String resultStatistics(int count, Map map) { + List list = new ArrayList<>(); + // 组装数据数据 + for (int i =1; i <= count; i ++) { + StatisticsVo statisticsVo = new StatisticsVo(); + statisticsVo.setClassify(i); + statisticsVo.setCount(map.getOrDefault(i, 0L).intValue()); + list.add(statisticsVo); + } + return JSONObject.toJSONString(list); + } +} diff --git a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/resources/mapper/EnterpriseInformationMapper.xml b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/resources/mapper/EnterpriseInformationMapper.xml index 66b695b..d74c032 100644 --- a/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/resources/mapper/EnterpriseInformationMapper.xml +++ b/hbt-safety-supervision/hbt-safety-supervision-biz/src/main/resources/mapper/EnterpriseInformationMapper.xml @@ -101,8 +101,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" select from enterprise_information - + select type from enterprise_information - select level as level, count(id) as num from risk group by level +