Merge branch 'lhr'

BIZ/jeecg-boot-module-zrzyqc/src/main/java/org/jeecg/modules/zrzyqc/qcsb/controller/QcSsgqzysytdqkController.java

@@ -1225,6 +1225,28 @@ public class QcSsgqzysytdqkController extends JeecgController<QcSsgqzysytdqk, IQ
         return Result.OK(map);
     }
 
+    /**
+     * 列表查询图表统计
+     *
+     * @param qcSsgqzysytdqk
+     * @param req
+     * @return
+     */
+    /**
+     * @AutoLog(value = "省直列表数据查询)
+     */
+    @ApiOperation(value = "省直列表数据查询", notes = "省直列表数据查询")
+    @GetMapping(value = "/sumListBysz")
+    public Result<?> sumListBysz(QcSsgqzysytdqk qcSsgqzysytdqk,
+                                 HttpServletRequest req) {
+        QueryWrapper<QcSsgqzysytdqk> queryWrapper = QueryGenerator.initQueryWrapper(qcSsgqzysytdqk, req.getParameterMap());
+        queryWrapper.likeRight("sys_org_code", "A03");
+        queryWrapper.gt("sfsb", 0);
+        List<QcSsgqzysytdqk> list = qcSsgqzysytdqkService.list(queryWrapper);
+        List<Map<String, Double>> map = qcSsgqzysytdqkService.sumListBysz(list);
+        return Result.OK(map);
+    }
+
 
    /* *//**
      * 更新图片

BIZ/jeecg-boot-module-zrzyqc/src/main/java/org/jeecg/modules/zrzyqc/qcsb/service/IQcSsgqzysytdqkService.java

@@ -26,4 +26,6 @@ public interface IQcSsgqzysytdqkService extends IService<QcSsgqzysytdqk> {
     void insertDkxx(HashMap<String, Object> map);
 
     List<Map<String, Double>> sumList(List<QcSsgqzysytdqk> list);
+
+    List<Map<String, Double>> sumListBysz(List<QcSsgqzysytdqk> list);
 }

BIZ/jeecg-boot-module-zrzyqc/src/main/java/org/jeecg/modules/zrzyqc/qcsb/service/impl/QcSsgqzysytdqkServiceImpl.java

@@ -123,4 +123,69 @@ public class QcSsgqzysytdqkServiceImpl extends ServiceImpl<QcSsgqzysytdqkMapper,
         return result;
     }
 
+    @Override
+    public List<Map<String, Double>> sumListBysz(List<QcSsgqzysytdqk> list) {
+        List<DictModel> xzqh = sysBaseAPI.getDictItems("xq");
+        List<SysCategoryModel> sysCategoryModels = sysBaseAPI.queryAllSysCategory();
+        Double num = Double.valueOf(0);
+        List<Map<String, Double>> result = new ArrayList<>();
+        Map<String, Double> map = new HashMap<>();
+        Map<String, Double> sjytMap = new HashMap<>();
+        Map<String, Double> syxzMap = new HashMap<>();
+        Map<String, Double> wjbhMap = new HashMap<>();
+        Map<String, List<QcSsgqzysytdqk>> collect = list.stream().collect(Collectors.groupingBy((QcSsgqzysytdqk::getSyqsyfs)));
+        for (String s : collect.keySet()) {
+            map.put(s, (double) collect.get(s).size());
+        }
+        result.add(map);
+
+        for (QcSsgqzysytdqk qcSsgqzysytdqk : list) {
+            String qh = qcSsgqzysytdqk.getXzqh().substring(0, 4);
+            for (DictModel dictModel : xzqh) {
+                if (qh.equals(dictModel.getValue())) {
+                    qcSsgqzysytdqk.setXzqh(dictModel.getText());
+                }
+            }
+        }
+        Map<String, Double> xzqhByAreaCollect = list.stream().collect(
+                Collectors.groupingBy(QcSsgqzysytdqk::getXzqh,
+                        Collectors.summingDouble(s -> Optional.ofNullable(s.getSjzytdmj()).orElse(0.0))));
+        result.add(xzqhByAreaCollect);
+
+        Map<String, List<QcSsgqzysytdqk>> syxzCollect = list.stream().collect(
+                Collectors.groupingBy((QcSsgqzysytdqk::getTdsyxz)));
+        for (String s : syxzCollect.keySet()) {
+            syxzMap.put(s, (double) syxzCollect.get(s).size());
+        }
+        result.add(syxzMap);
+
+        Map<String, Double> syxzByAreaCollect = list.stream().collect(
+                Collectors.groupingBy(QcSsgqzysytdqk::getSyqsyfs,
+                        Collectors.summingDouble(s -> Optional.ofNullable(s.getSjzytdmj()).orElse(0.0))));
+        result.add(syxzByAreaCollect);
+
+        Map<String, Long> wjlxCollect = list.stream().collect(
+                Collectors.groupingBy(QcSsgqzysytdqk::getZslx,
+                        Collectors.counting())
+        );
+        for (String s : wjlxCollect.keySet()) {
+            wjbhMap.put(s, (double) wjlxCollect.get(s));
+        }
+        result.add(wjbhMap);
+
+        for (QcSsgqzysytdqk qcSsgqzysytdqk : list) {
+            for (SysCategoryModel sysCategoryModel : sysCategoryModels) {
+                if (qcSsgqzysytdqk.getPzyt().equals(sysCategoryModel.getId())) {
+                    qcSsgqzysytdqk.setPzyt(sysCategoryModel.getName());
+                }
+            }
+        }
+        Map<String, List<QcSsgqzysytdqk>> collectBysjyt = list.stream().collect(Collectors.groupingBy((QcSsgqzysytdqk::getSjyt)));
+        for (String s : collectBysjyt.keySet()) {
+            sjytMap.put(s, (double) collectBysjyt.get(s).size());
+        }
+        result.add(sjytMap);
+        return result;
+    }
+
 }