指标管理 安全追溯 / 按隐患类型隐患数量排名 代码提交

amos-boot-system-tzs/amos-boot-module-common/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/enums/ZBGLEnum.java

@@ -15,8 +15,8 @@ public enum ZBGLEnum {
     JDGL("监督管理","jdgl",true,null,""),
     YWBLPJSXTJ("业务办理平均时效统计","ywblpjsxtj",false,"jdgl",""),
     AQZS("安全追溯","aqzs",true,null,""),
-    YHSLQS("隐患数量趋势（近12个月）","yhslqs",false,"aqzs",""),
-    AYHLXYHSLPM("按隐患类型隐患数量排名（Top10）","ayhlxyhslpm",false,"aqzs",""),
+//    YHSLQS("隐患数量趋势（近12个月）","yhslqs",false,"aqzs",""),
+    AYHLXYHSLPM("按隐患类型隐患数量排名（Top10）","ayhlxyhslpm",false,"aqzs","ayhlxyhslpmServiceImpl"),
     DNZTDWYHPM("当年主体单位隐患排名（Top10）","dnztdwyhpm",false,"aqzs",""),
     QP("气瓶","qp",true,null,""),
     QYAQZSTJ("区域安全指数统计","qyaqzstj",false,"qp",""),

amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-api/src/main/java/com/yeejoin/amos/boot/module/statistics/api/mapper/ZBGLStatisticsMapper.java

@@ -26,4 +26,7 @@ public interface ZBGLStatisticsMapper {
 
     Map<String, Long> getKRJYYDQKChartData(@Param("dpFilterParamForDetailDto") DPFilterParamForDetailDto dpFilterParamForDetailDto, @Param("time") String time);
 
+    Map<String,Long> getAYHLXYHSLPMChartData(@Param("dpFilterParamForDetailDto") DPFilterParamForDetailDto dpFilterParamForDetailDto);
+
+    List<Map<String,Long>> getAYHLXYHSLPMPageData(@Param("dpFilterParamForDetailDto") DPFilterParamForDetailDto dpFilterParamForDetailDto);
 }

amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-api/src/main/resources/mapper/ZBGLStatisticsMapper.xml

@@ -82,6 +82,26 @@
             supervisory_unit_org_code
         LIMIT 1
     </select>
+    <select id="getAYHLXYHSLPMChartData" resultType="java.util.Map">
+        SELECT COUNT
+                   ( 1 ) AS allCount,
+               SUM ( CASE problem_status_code WHEN '1' THEN 1 ELSE 0 END ) AS endCount
+        FROM
+            tzs_safety_problem_tracing
+        WHERE
+            governing_body_org_code LIKE concat ( #{dpFilterParamForDetailDto.orgCode}, '%' )
+    </select>
+    <select id="getAYHLXYHSLPMPageData" resultType="java.util.Map">
+        SELECT COUNT
+                   ( 1 ) AS longValue,
+               problem_type_code AS fieldValueCode
+        FROM
+            tzs_safety_problem_tracing
+        WHERE
+            governing_body_org_code LIKE concat ( #{dpFilterParamForDetailDto.orgCode}, '%' )
+        GROUP BY
+            problem_type_code
+    </select>
 
 
 </mapper>

amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-biz/src/main/java/com/yeejoin/amos/boot/module/statistcs/biz/service/impl/ZBGLImpl/AyhlxyhslpmServiceImpl.java

+package com.yeejoin.amos.boot.module.statistcs.biz.service.impl.ZBGLImpl;
+
+import cn.hutool.core.lang.UUID;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.boot.module.common.api.dto.DPFilterParamForDetailDto;
+import com.yeejoin.amos.boot.module.statistcs.biz.service.IZBGLService;
+import com.yeejoin.amos.boot.module.statistcs.biz.service.impl.StCommonServiceImpl;
+import com.yeejoin.amos.boot.module.statistics.api.mapper.ZBGLStatisticsMapper;
+import com.yeejoin.amos.feign.systemctl.model.RegionModel;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.text.DecimalFormat;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+@Component
+public class AyhlxyhslpmServiceImpl implements IZBGLService {
+    @Resource
+    private StCommonServiceImpl stCommonService;
+
+    @Resource
+    private ZBGLStatisticsMapper zbglStatisticsMapper;
+    @Override
+    public Map<String, Object> getChart(DPFilterParamForDetailDto dpFilterParamForDetailDto) {
+        List<RegionModel> regionModels = stCommonService.setRegionIfRootParent(dpFilterParamForDetailDto.getCityCode());
+        List<Map<String,Object>> result =  regionModels.parallelStream().map(r -> {
+            String orgCode = stCommonService.getAndSetOrgCode(r.getRegionCode()+"");
+            DPFilterParamForDetailDto dpFilterParamForDetailDtoNew = new DPFilterParamForDetailDto();
+            dpFilterParamForDetailDtoNew.setOrgCode(orgCode);
+            Map<String, Object> itemResult = new HashMap<>();
+            Map<String,Long> map = zbglStatisticsMapper.getAYHLXYHSLPMChartData(dpFilterParamForDetailDtoNew);
+            if(map.get("allCount") != 0 && map.get("endCount") != 0){
+                itemResult.put("rate",BigDecimal.valueOf(map.get("endCount")).divide(BigDecimal.valueOf(map.get("allCount")),2, RoundingMode.HALF_UP).stripTrailingZeros().toPlainString());
+            }else{
+                itemResult.put("rate","0");
+            }
+            itemResult.put("count",map.get("allCount"));
+            itemResult.put("xdata",r.getRegionName());
+            return itemResult;
+        }).collect(Collectors.toList());
+
+        Map<String,Object> returnMap = new HashMap<>();
+        List<Map<String,Object>> legendData = new ArrayList<>();
+        for(int i = 0;i<2; i++){
+            Map<String,Object> map = new HashMap<>();
+            if(i == 0){
+                map.put("dataKey","count");
+                map.put("value","隐患总数");
+                map.put("chartType","bar");
+            }else{
+                map.put("dataKey","rate");
+                map.put("value","完结率");
+                map.put("chartType","line");
+            }
+            legendData.add(map);
+        }
+        returnMap.put("legendData",legendData);
+
+        List xdata = new ArrayList();
+        List count = new ArrayList();
+        List rate = new ArrayList();
+        Long sum = 0L;
+        for(int i = 0;i<result.size();i++){
+            sum = sum + (Long)result.get(i).get("count");
+        }
+        DecimalFormat decimalFormat = new DecimalFormat("0.00");
+        for(int i = 0;i<result.size();i++){
+            xdata.add(result.get(i).get("xdata"));
+            count.add(result.get(i).get("count") == null ? "0" : result.get(i).get("count")+"");
+            rate.add(result.get(i).get("rate") == null ? "0" : result.get(i).get("rate")+"");
+        }
+
+        returnMap.put("xdata",xdata);
+        returnMap.put("count",count);
+        returnMap.put("rate",rate);
+
+        return returnMap;
+    }
+
+    @Override
+    public Page<Map<String, Object>> getPage(Page page,DPFilterParamForDetailDto dpFilterParamForDetailDto) {
+        List<RegionModel> regionModels = stCommonService.setRegionIfRootParent(dpFilterParamForDetailDto.getCityCode());
+        List<Map<String,Object>> result =  regionModels.parallelStream().map(r -> {
+            String orgCode = stCommonService.getAndSetOrgCode(r.getRegionCode()+"");
+            DPFilterParamForDetailDto dpFilterParamForDetailDtoNew = new DPFilterParamForDetailDto();
+            dpFilterParamForDetailDtoNew.setOrgCode(orgCode);
+            Map<String, Object> itemResult = new HashMap<>();
+            List<Map<String,Long>> list = zbglStatisticsMapper.getAYHLXYHSLPMPageData(dpFilterParamForDetailDtoNew);
+            Long sum = 0L;
+            for(int i = 0;i<list.size();i++){
+                sum = sum + (Long)list.get(i).get("longValue");
+            }
+            for(int i = 0;i<list.size();i++){
+                if(sum != 0 && (Long)list.get(i).get("longValue") != 0){
+                    itemResult.put(list.get(i).get("fieldValueCode")+"",list.get(i).get("longValue")+" / "+new BigDecimal(list.get(i).get("longValue")+"").divide(BigDecimal.valueOf(sum),2, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)).stripTrailingZeros().toPlainString()+"%");
+                }
+            }
+            itemResult.put("area",r.getRegionName());
+            itemResult.put("sequenceNbr", UUID.fastUUID().toString());
+            return itemResult;
+        }).collect(Collectors.toList());
+        page.setRecords(result);
+        page.setTotal(result.size());
+        return page;
+    }
+
+    @Override
+    public List<Map<String, String>> getTitle(DPFilterParamForDetailDto dpFilterParamForDetailDto) {
+        List<Map<String, String>> list = zbglStatisticsMapper.getTypeList("ISSUE_TYPE");
+        Map<String,String> map = new HashMap<>();
+        map.put("dataIndex","area");
+        map.put("title","区域");
+        list.add(0,map);
+        return list;
+    }
+}