From f849c87a07300020dbef300c79d1eacfc1439f84 Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期三, 06 三月 2024 15:41:58 +0800
Subject: [PATCH] 修改数据统计控制器

---
 src/main/java/com/lf/server/service/sys/ReportService.java |  464 ++++++++++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 420 insertions(+), 44 deletions(-)

diff --git a/src/main/java/com/lf/server/service/sys/ReportService.java b/src/main/java/com/lf/server/service/sys/ReportService.java
index ced9c23..a5bbecd 100644
--- a/src/main/java/com/lf/server/service/sys/ReportService.java
+++ b/src/main/java/com/lf/server/service/sys/ReportService.java
@@ -1,6 +1,8 @@
 package com.lf.server.service.sys;
 
+import com.lf.server.entity.all.RedisCacheKey;
 import com.lf.server.entity.all.StaticData;
+import com.lf.server.entity.ctrl.CoordinateEntity;
 import com.lf.server.entity.ctrl.CountEntity;
 import com.lf.server.entity.data.DownloadEntity;
 import com.lf.server.entity.sys.AttachEntity;
@@ -8,10 +10,14 @@
 import com.lf.server.entity.sys.UserEntity;
 import com.lf.server.helper.*;
 import com.lf.server.mapper.sys.ReportMapper;
+import com.lf.server.service.all.RedisService;
 import com.lf.server.service.data.DownloadService;
-import org.springframework.beans.factory.annotation.Autowired;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.Resource;
 import javax.servlet.http.HttpServletResponse;
 import java.io.File;
 import java.util.*;
@@ -22,17 +28,25 @@
  */
 @Service
 public class ReportService implements ReportMapper {
-    @Autowired
+    @Value("${sys.turfServer}")
+    private String turfServer;
+
+    @Resource
     ReportMapper reportMapper;
 
-    @Autowired
+    @Resource
     AttachService attachService;
 
-    @Autowired
+    @Resource
     PathHelper pathHelper;
 
-    @Autowired
+    @Resource
     DownloadService downloadService;
+
+    @Resource
+    RedisService redisService;
+
+    private final static Log log = LogFactory.getLog(ReportService.class);
 
     @Override
     public Integer selectCount(String name, String code) {
@@ -113,6 +127,137 @@
         return reportMapper.countSizesByPrj();
     }
 
+    @Override
+    public List<CountEntity> countExplorationPoints() {
+        String key = RedisCacheKey.dataCountKey("countExplorationPoints");
+        List<CountEntity> list = redisService.getListByKey(key);
+        if (null == list) {
+            list = reportMapper.countExplorationPoints();
+            countExplorationArea(list);
+            redisService.saveListByKey(key, list, StaticData.I2);
+        }
+
+        return list;
+    }
+
+    @Override
+    public List<CoordinateEntity> selectExplorationPoints(String code) {
+        return reportMapper.selectExplorationPoints(StringHelper.getRightLike(code));
+    }
+
+    @Override
+    public List<CountEntity> countDemAreaByPrj() {
+        return reportMapper.countDemAreaByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countMptAreaByPrj() {
+        return reportMapper.countMptAreaByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countOsgbAreaByPrj() {
+        return reportMapper.countOsgbAreaByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countLasAreaByPrj() {
+        return reportMapper.countLasAreaByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countSurveyWorksiteByPrj() {
+        return reportMapper.countSurveyWorksiteByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countExplorationReportByPrj() {
+        return reportMapper.countExplorationReportByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countCollapseByPrj() {
+        return reportMapper.countCollapseByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countDebrisFlowByPrj() {
+        return reportMapper.countDebrisFlowByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countGroundCollapseByPrj() {
+        return reportMapper.countGroundCollapseByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countHighSteepSlopeByPrj() {
+        return reportMapper.countHighSteepSlopeByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countLandSlideByPrj() {
+        return reportMapper.countLandSlideByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countUnstableSlopeByPrj() {
+        return reportMapper.countUnstableSlopeByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countWaterDamageByPrj() {
+        return reportMapper.countWaterDamageByPrj();
+    }
+
+    /**
+     * 缁熻閽诲瓟鐐归潰绉�
+     */
+    private void countExplorationArea(List<CountEntity> list) {
+        if (null == list) {
+            return;
+        }
+        for (CountEntity ce : list) {
+            if (0 == ce.getCount()) {
+                continue;
+            }
+
+            double area = calcPolygonArea(ce.getM3());
+            ce.setArea(area);
+        }
+    }
+
+    /**
+     * 璁$畻澶氳竟褰㈤潰绉�
+     */
+    private double calcPolygonArea(String code) {
+        try {
+            String url = turfServer + "/Call/CalcArea?code=" + code;
+            String str = RestHelper.get(url);
+            if (StringHelper.isEmpty(str)) {
+                return 0d;
+            }
+
+            return Double.parseDouble(str);
+        } catch (Exception ex) {
+            log.error(ex.getMessage(), ex);
+            return 0d;
+        }
+    }
+
+    /**
+     * 璋冪敤JS鏂规硶 *
+     */
+    private double callJsFn(String str) {
+        String staticPath = PathHelper.getStaticPath();
+        Object obj = JsHelper.callJsFn(staticPath + "js/turf.min.6.5.js", "pointsToPolygon", str);
+        if (null == obj) {
+            return 0d;
+        }
+
+        return (double) obj;
+    }
+
     /**
      * 鍒涘缓鎶ュ憡
      */
@@ -159,6 +304,15 @@
                 case "countServices":
                     createCountServicesWord(source, target);
                     break;
+                case "countExplorationPoints":
+                    createCountExplorationPointsWord(source, target);
+                    break;
+                case "countSizesByType":
+                    createCountSizesByTypeWord(source, target);
+                    break;
+                case "countSizesByPrj":
+                    createCountSizesByPrjWord(source, target);
+                    break;
                 default:
                     break;
             }
@@ -172,6 +326,15 @@
                     break;
                 case "countServices":
                     createCountServicesExcel(source, target);
+                    break;
+                case "countExplorationPoints":
+                    createCountExplorationPointsExcel(source, target);
+                    break;
+                case "countSizesByType":
+                    createCountSizesByTypeExcel(source, target);
+                    break;
+                case "countSizesByPrj":
+                    createCountSizesByPrjExcel(source, target);
                     break;
                 default:
                     break;
@@ -188,30 +351,15 @@
             return;
         }
 
-        int rows = 1;
+        int rows = 1, allCount = 0;
         ArrayList<String[]> addList = new ArrayList<>();
         for (CountEntity ce : list) {
+            allCount += ce.getCount();
             String[] strs = new String[]{"" + rows++, ce.getM1(), ce.getM2(), ce.getCount().toString()};
             addList.add(strs);
         }
-
-        WordHelper.generateWord(source, target, null, addList);
-    }
-
-    /**
-     * 鍒涘缓 鏈嶅姟璋冪敤閲忕粺璁� Word
-     */
-    public void createCountServicesWord(String source, String target) {
-        List<CountEntity> list = countServices();
-        if (null == list || list.isEmpty()) {
-            return;
-        }
-
-        int rows = 1;
-        ArrayList<String[]> addList = new ArrayList<>();
-        for (CountEntity ce : list) {
-            String[] strs = new String[]{"" + rows++, ce.getM1(), ce.getCount().toString()};
-            addList.add(strs);
+        if (addList.size() > 0) {
+            addList.add(new String[]{"" + rows, "鎬昏", " ", "" + allCount});
         }
 
         WordHelper.generateWord(source, target, null, addList);
@@ -227,10 +375,114 @@
         }
 
         int rows = 1;
+        Double allSize = 0d;
         ArrayList<String[]> addList = new ArrayList<>();
         for (CountEntity ce : list) {
+            allSize += ce.getSizes();
             String[] strs = new String[]{"" + rows++, ce.getM1(), FileHelper.getSizes(ce.getSizes())};
             addList.add(strs);
+        }
+        if (addList.size() > 0) {
+            addList.add(new String[]{"" + rows, "鎬昏", FileHelper.getSizes(allSize)});
+        }
+
+        WordHelper.generateWord(source, target, null, addList);
+    }
+
+    /**
+     * 鍒涘缓 鏈嶅姟璋冪敤閲忕粺璁� Word
+     */
+    public void createCountServicesWord(String source, String target) {
+        List<CountEntity> list = countServices();
+        if (null == list || list.isEmpty()) {
+            return;
+        }
+
+        int rows = 1, allCount = 0;
+        ArrayList<String[]> addList = new ArrayList<>();
+        for (CountEntity ce : list) {
+            allCount += ce.getCount();
+            String[] strs = new String[]{"" + rows++, ce.getM1(), ce.getCount().toString()};
+            addList.add(strs);
+        }
+        if (addList.size() > 0) {
+            addList.add(new String[]{"" + rows, "鎬昏", "" + allCount});
+        }
+
+        WordHelper.generateWord(source, target, null, addList);
+    }
+
+    /**
+     * 鍒涘缓 閽诲瓟鏁版嵁缁熻 Word
+     */
+    public void createCountExplorationPointsWord(String source, String target) {
+        List<CountEntity> list = countExplorationPoints();
+        if (null == list || list.isEmpty()) {
+            return;
+        }
+
+        int rows = 1, allCount = 0;
+        Double allSize = 0d, allArea = 0d;
+        ArrayList<String[]> addList = new ArrayList<>();
+        for (CountEntity ce : list) {
+            allSize += ce.getSizes();
+            allCount += ce.getCount();
+            allArea += ce.getArea();
+            String[] strs = new String[]{"" + rows++, ce.getM1(), "" + ce.getCount(), FileHelper.getSizes(ce.getSizes()), FileHelper.getSquareMeter(ce.getArea())};
+            addList.add(strs);
+        }
+        if (addList.size() > 0) {
+            addList.add(new String[]{"" + rows, "鎬昏", "" + allCount, FileHelper.getSizes(allSize), FileHelper.getSquareMeter(allArea)});
+        }
+
+        WordHelper.generateWord(source, target, null, addList);
+    }
+
+    /**
+     * 鍒涘缓 鏁版嵁鏍煎紡缁熻 Word
+     */
+    public void createCountSizesByTypeWord(String source, String target) {
+        List<CountEntity> list = countSizesByType();
+        if (null == list || list.isEmpty()) {
+            return;
+        }
+
+        int rows = 1, allCount = 0;
+        Double allSize = 0d;
+        ArrayList<String[]> addList = new ArrayList<>();
+        for (CountEntity ce : list) {
+            allSize += ce.getSizes();
+            allCount += ce.getCount();
+            String[] strs = new String[]{"" + rows++, ce.getM1(), "" + ce.getCount(), FileHelper.getSizes(ce.getSizes())};
+            addList.add(strs);
+        }
+        if (addList.size() > 0) {
+            addList.add(new String[]{"" + rows, "鎬昏", "" + allCount, FileHelper.getSizes(allSize)});
+        }
+
+        WordHelper.generateWord(source, target, null, addList);
+    }
+
+    /**
+     * 鍒涘缓 椤圭洰鏁版嵁缁熻 Word
+     */
+    public void createCountSizesByPrjWord(String source, String target) {
+        List<CountEntity> list = countSizesByPrj();
+        if (null == list || list.isEmpty()) {
+            return;
+        }
+
+        int rows = 1, allCount = 0;
+        Double allSize = 0d;
+        ArrayList<String[]> addList = new ArrayList<>();
+        for (CountEntity ce : list) {
+            allSize += ce.getSizes();
+            allCount += ce.getCount();
+            String[] strs = new String[]{"" + rows++, ce.getM1(), "" + ce.getCount(), FileHelper.getSizes(ce.getSizes())};
+            addList.add(strs);
+        }
+        if (addList.size() > 0) {
+            addList.add(new String[]{"" + rows, "鎬昏", "" + allCount, FileHelper.getSizes(allSize)});
         }
 
         WordHelper.generateWord(source, target, null, addList);
@@ -245,29 +497,17 @@
             return;
         }
 
-        int rows = 1;
+        int rows = 1, allCount = 0;
         for (CountEntity ce : list) {
             ce.setNo(rows++);
+            allCount += ce.getCount();
         }
-
-        Map<String, List<CountEntity>> map = new HashMap<>(1);
-        map.put("data", list);
-
-        ExcelHelper.writeToTemplate(source, target, map);
-    }
-
-    /**
-     * 鍒涘缓 鏈嶅姟璋冪敤閲忕粺璁� Excel
-     */
-    public void createCountServicesExcel(String source, String target) {
-        List<CountEntity> list = countServices();
-        if (null == list || list.isEmpty()) {
-            return;
-        }
-
-        int rows = 1;
-        for (CountEntity ce : list) {
-            ce.setNo(rows++);
+        if (list.size() > 0) {
+            CountEntity ce = new CountEntity();
+            ce.setNo(rows);
+            ce.setM1("鎬昏");
+            ce.setCount((long) allCount);
+            list.add(ce);
         }
 
         Map<String, List<CountEntity>> map = new HashMap<>(1);
@@ -286,9 +526,145 @@
         }
 
         int rows = 1;
+        Double allSize = 0d;
         for (CountEntity ce : list) {
             ce.setNo(rows++);
             ce.setM2(FileHelper.getSizes(ce.getSizes()));
+            allSize += ce.getSizes();
+        }
+        if (list.size() > 0) {
+            CountEntity ce = new CountEntity();
+            ce.setNo(rows);
+            ce.setM1("鎬昏");
+            ce.setM2(FileHelper.getSizes(allSize));
+            list.add(ce);
+        }
+
+        Map<String, List<CountEntity>> map = new HashMap<>(1);
+        map.put("data", list);
+
+        ExcelHelper.writeToTemplate(source, target, map);
+    }
+
+    /**
+     * 鍒涘缓 鏈嶅姟璋冪敤閲忕粺璁� Excel
+     */
+    public void createCountServicesExcel(String source, String target) {
+        List<CountEntity> list = countServices();
+        if (null == list || list.isEmpty()) {
+            return;
+        }
+
+        int rows = 1, allCount = 0;
+        for (CountEntity ce : list) {
+            ce.setNo(rows++);
+            allCount += ce.getCount();
+        }
+        if (list.size() > 0) {
+            CountEntity ce = new CountEntity();
+            ce.setNo(rows);
+            ce.setM1("鎬昏");
+            ce.setCount((long) allCount);
+            list.add(ce);
+        }
+
+        Map<String, List<CountEntity>> map = new HashMap<>(1);
+        map.put("data", list);
+
+        ExcelHelper.writeToTemplate(source, target, map);
+    }
+
+    /**
+     * 鍒涘缓 閽诲瓟鏁版嵁缁熻 Excel
+     */
+    public void createCountExplorationPointsExcel(String source, String target) {
+        List<CountEntity> list = countExplorationPoints();
+        if (null == list || list.isEmpty()) {
+            return;
+        }
+
+        int rows = 1, allCount = 0;
+        Double allSize = 0d, allArea = 0d;
+        for (CountEntity ce : list) {
+            ce.setNo(rows++);
+            ce.setM2(FileHelper.getSizes(ce.getSizes()));
+            ce.setM3(FileHelper.getSquareMeter(ce.getArea()));
+            allCount += ce.getCount();
+            allSize += ce.getSizes();
+            allArea += ce.getArea();
+        }
+        if (list.size() > 0) {
+            CountEntity ce = new CountEntity();
+            ce.setNo(rows);
+            ce.setM1("鎬昏");
+            ce.setCount((long) allCount);
+            ce.setM2(FileHelper.getSizes(allSize));
+            ce.setM3(FileHelper.getSquareMeter(allArea));
+            list.add(ce);
+        }
+
+        Map<String, List<CountEntity>> map = new HashMap<>(1);
+        map.put("data", list);
+
+        ExcelHelper.writeToTemplate(source, target, map);
+    }
+
+    /**
+     * 鍒涘缓 鏁版嵁鏍煎紡缁熻 Excel
+     */
+    public void createCountSizesByTypeExcel(String source, String target) {
+        List<CountEntity> list = countSizesByType();
+        if (null == list || list.isEmpty()) {
+            return;
+        }
+
+        int rows = 1, allCount = 0;
+        Double allSize = 0d;
+        for (CountEntity ce : list) {
+            ce.setNo(rows++);
+            ce.setM2(FileHelper.getSizes(ce.getSizes()));
+            allCount += ce.getCount();
+            allSize += ce.getSizes();
+        }
+        if (list.size() > 0) {
+            CountEntity ce = new CountEntity();
+            ce.setNo(rows);
+            ce.setM1("鎬昏");
+            ce.setCount((long) allCount);
+            ce.setM2(FileHelper.getSizes(allSize));
+            list.add(ce);
+        }
+
+        Map<String, List<CountEntity>> map = new HashMap<>(1);
+        map.put("data", list);
+
+        ExcelHelper.writeToTemplate(source, target, map);
+    }
+
+    /**
+     * 鍒涘缓 椤圭洰鏁版嵁缁熻 Excel
+     */
+    public void createCountSizesByPrjExcel(String source, String target) {
+        List<CountEntity> list = countSizesByPrj();
+        if (null == list || list.isEmpty()) {
+            return;
+        }
+
+        int rows = 1, allCount = 0;
+        Double allSize = 0d;
+        for (CountEntity ce : list) {
+            ce.setNo(rows++);
+            ce.setM2(FileHelper.getSizes(ce.getSizes()));
+            allCount += ce.getCount();
+            allSize += ce.getSizes();
+        }
+        if (list.size() > 0) {
+            CountEntity ce = new CountEntity();
+            ce.setNo(rows);
+            ce.setM1("鎬昏");
+            ce.setCount((long) allCount);
+            ce.setM2(FileHelper.getSizes(allSize));
+            list.add(ce);
         }
 
         Map<String, List<CountEntity>> map = new HashMap<>(1);

--
Gitblit v1.9.3