From b20fd29dc3864405af4afa0aeb99d13d74fbfcdc Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期四, 21 三月 2024 15:07:44 +0800
Subject: [PATCH] 解决导出xls异常

---
 src/main/java/com/lf/server/service/sys/ReportService.java |  431 ++++++++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 375 insertions(+), 56 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 df5813e..376bd4c 100644
--- a/src/main/java/com/lf/server/service/sys/ReportService.java
+++ b/src/main/java/com/lf/server/service/sys/ReportService.java
@@ -1,46 +1,74 @@
 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;
 import com.lf.server.entity.sys.ReportEntity;
+import com.lf.server.entity.sys.UserEntity;
 import com.lf.server.helper.*;
 import com.lf.server.mapper.sys.ReportMapper;
-import org.springframework.beans.factory.annotation.Autowired;
+import com.lf.server.service.all.RedisService;
+import com.lf.server.service.data.DirService;
+import com.lf.server.service.data.DownloadService;
+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 org.springframework.util.StringUtils;
 
+import javax.annotation.Resource;
 import javax.servlet.http.HttpServletResponse;
 import java.io.File;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
+import java.lang.reflect.Method;
+import java.util.*;
 
 /**
  * 鎶ュ憡妯℃澘
+ *
  * @author WWW
+ * @date 2024-03-06
  */
 @Service
+@SuppressWarnings("ALL")
 public class ReportService implements ReportMapper {
-    @Autowired
+    @Value("${sys.turfServer}")
+    private String turfServer;
+
+    @Resource
     ReportMapper reportMapper;
 
-    @Autowired
+    @Resource
     AttachService attachService;
 
-    @Autowired
+    @Resource
     PathHelper pathHelper;
 
-    @Override
-    public Integer selectCount(String name) {
-        name = StringHelper.getLikeStr(name);
+    @Resource
+    DownloadService downloadService;
 
-        return reportMapper.selectCount(name);
+    @Resource
+    RedisService redisService;
+
+    @Resource
+    DirService dirService;
+
+    private final static Log log = LogFactory.getLog(ReportService.class);
+
+    @Override
+    public Integer selectCount(String name, String code) {
+        name = StringHelper.getLikeUpperStr(name);
+
+        return reportMapper.selectCount(name, code);
     }
 
     @Override
-    public List<ReportEntity> selectByPage(String name, Integer limit, Integer offset) {
-        name = StringHelper.getLikeStr(name);
+    public List<ReportEntity> selectByPage(String name, String code, Integer limit, Integer offset) {
+        name = StringHelper.getLikeUpperStr(name);
 
-        return reportMapper.selectByPage(name, limit, offset);
+        return reportMapper.selectByPage(name, code, limit, offset);
     }
 
     @Override
@@ -89,6 +117,11 @@
     }
 
     @Override
+    public List<CountEntity> countSizesByType() {
+        return reportMapper.countSizesByType();
+    }
+
+    @Override
     public List<CountEntity> countServices() {
         return reportMapper.countServices();
     }
@@ -98,10 +131,182 @@
         return reportMapper.countOperates();
     }
 
+    @Override
+    public List<CountEntity> countSizesByPrj() {
+        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();
+    }
+
+    @Override
+    public List<CountEntity> countDlgAreaByPrj() {
+        return reportMapper.countDlgAreaByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countDomAreaByPrj() {
+        return reportMapper.countDomAreaByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countLineLength() {
+        return reportMapper.countLineLength();
+    }
+
+    @Override
+    public List<CountEntity> countExplorationPointByPrj() {
+        return reportMapper.countExplorationPointByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countGeoModelAreaByPrj() {
+        return reportMapper.countGeoModelAreaByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countGeologicHazardByPrj() {
+        return reportMapper.countGeologicHazardByPrj();
+    }
+
+    @Override
+    public List<CountEntity> countVariousDataByPrj(String code) {
+        code = StringHelper.getRightLike(code);
+        return reportMapper.countVariousDataByPrj(code);
+    }
+
+    /**
+     * 缁熻閽诲瓟鐐归潰绉�
+     */
+    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;
+    }
+
     /**
      * 鍒涘缓鎶ュ憡
      */
-    public void createReport(ReportEntity re, HttpServletResponse res) throws Exception {
+    public void createReport(UserEntity ue, ReportEntity re, String code, HttpServletResponse res) throws Exception {
         AttachEntity ae = attachService.selectByGuid(re.getGuid());
         if (null == ae) {
             return;
@@ -109,97 +314,211 @@
 
         String source = pathHelper.getConfig().getUploadPath() + File.separator + ae.getPath();
         String targetName = StringHelper.YMDHMS2_FORMAT.format(new Date()) + FileHelper.getExtension(ae.getName());
-        String target = pathHelper.getShareFullPath() + File.separator + targetName;
+        String target = pathHelper.getDownloadFullPath() + File.separator + targetName;
 
         File sourceFile = new File(source);
         if (!sourceFile.exists() || sourceFile.isDirectory()) {
             return;
         }
-        generateReport(source, target, re);
+        generateReport(source, target, re, code);
 
         File targetFile = new File(target);
         if (!targetFile.exists() || sourceFile.isDirectory()) {
             return;
         }
 
-        WebHelper.download(target, targetName, res);
+        DownloadEntity de = getDownloadEntity(ue, target);
+        int rows = downloadService.insert(de);
+        if (rows > 0) {
+            WebHelper.download(target, targetName, res);
+        }
     }
 
     /**
      * 鐢熸垚鎶ュ憡
      */
-    private void generateReport(String source, String target, ReportEntity re) {
-        if ("1".equals(re.getType())) {
+    private void generateReport(String source, String target, ReportEntity re, String code) {
+        if (StaticData.S1.equals(re.getType())) {
+            createWord(source, target, re, code);
+        } else {
+            createExcel(source, target, re, code);
+        }
+    }
+
+    /**
+     * 鐢熸垚Word
+     */
+    private void createWord(String source, String target, ReportEntity re, String code) {
+        List<CountEntity> list = selectListByMethodName(re, code);
+        list = processListData(list);
+
+        Map<String, String> textMap = new HashMap<>();
+        if (!StringHelper.isEmpty(code)) {
+            textMap.put("title", dirService.selectNameByCode(code));
+            list.remove(list.size() - 1);
+        }
+
+        List<String[]> tableList = new ArrayList<>();
+        for (CountEntity ce : list) {
             switch (re.getCode()) {
-                case "countOperates ":
-                    createCountOperatesWord(source, target);
+                case "countSizesByType":
+                case "countSizesByPrj":
+                    tableList.add(new String[]{"" + ce.getNo(), ce.getM1(), "" + ce.getCount(), ce.getM2()});
                     break;
                 case "countSizes":
-                    createCountSizesWord(source, target);
+                    tableList.add(new String[]{"" + ce.getNo(), ce.getM1(), ce.getM2()});
+                    break;
+                case "countOperates":
+                    tableList.add(new String[]{"" + ce.getNo(), ce.getM1(), ce.getM2(), "" + ce.getCount()});
+                    break;
+                case "countExplorationPoints":
+                    tableList.add(new String[]{"" + ce.getNo(), ce.getM1(), "" + ce.getCount(), ce.getM2(), ce.getM3()});
+                    break;
+                case "countDemAreaByPrj":
+                case "countMptAreaByPrj":
+                case "countOsgbAreaByPrj":
+                case "countLasAreaByPrj":
+                case "countDlgAreaByPrj":
+                case "countDomAreaByPrj":
+                case "countGeoModelAreaByPrj":
+                    tableList.add(new String[]{"" + ce.getNo(), ce.getM1(), ce.getM3()});
+                    break;
+                case "countLineLength":
+                    tableList.add(new String[]{"" + ce.getNo(), ce.getM1(), "" + ce.getLen()});
+                    break;
+                case "countVariousDataByPrj":
+                    String str = "count".equals(ce.getM2()) ? ce.getCount() + "涓�" : ("area".equals(ce.getM2()) ? ce.getM3() : ce.getLen() + "鍗冪背");
+                    tableList.add(new String[]{"" + ce.getNo(), ce.getM1(), str});
                     break;
                 default:
-                    createCountServicesWord(source, target);
+                    tableList.add(new String[]{"" + ce.getNo(), ce.getM1(), "" + ce.getCount()});
                     break;
             }
-        } else {
-            //
         }
+
+        WordHelper.generateWord(source, target, textMap, tableList);
     }
 
     /**
-     * 鍒涘缓 鐢ㄦ埛娴侀噺缁熻 Word
+     * 鐢熸垚Excel
      */
-    public void createCountOperatesWord(String source, String target) {
-        List<CountEntity> list = countOperates();
-        if (null == list || list.isEmpty()) {
-            return;
+    private void createExcel(String source, String target, ReportEntity re, String code) {
+        List<CountEntity> list = selectListByMethodName(re, code);
+        list = processListData(list);
+
+        Map<String, Object> map = new HashMap<>();
+        if (!StringHelper.isEmpty(code)) {
+            map.put("title", dirService.selectNameByCode(code));
+            list.remove(list.size() - 1);
+            for (CountEntity ce : list) {
+                ce.setM2("count".equals(ce.getM2()) ? ce.getCount() + "涓�" : ("area".equals(ce.getM2()) ? ce.getM3() : ce.getLen() + "鍗冪背"));
+            }
         }
 
-        int rows = 1;
-        ArrayList<String[]> addList = new ArrayList<>();
-        for (CountEntity ce : list) {
-            String[] strs = new String[]{"" + rows++, ce.getM1(), ce.getM2(), ce.getCount().toString()};
-            addList.add(strs);
-        }
+        Map<String, List<CountEntity>> listMap = new HashMap<>(1);
+        listMap.put("data", list);
 
-        WordHelper.generateWord(source, target, null, addList);
+        ExcelHelper.writeToTemplate(source, target, map, listMap);
     }
 
     /**
-     * 鍒涘缓 鏈嶅姟璋冪敤閲忕粺璁� Word
+     * 澶勭悊鍒楄〃鏁版嵁
      */
-    public void createCountServicesWord(String source, String target) {
-        List<CountEntity> list = countServices();
+    private List<CountEntity> processListData(List<CountEntity> list) {
         if (null == list || list.isEmpty()) {
-            return;
+            return null;
         }
 
         int rows = 1;
-        ArrayList<String[]> addList = new ArrayList<>();
+        long allCount = 0;
+        Double allSize = 0d, allArea = 0d, allLen = 0d;
         for (CountEntity ce : list) {
-            String[] strs = new String[]{"" + rows++, ce.getM1(), ce.getCount().toString()};
-            addList.add(strs);
+            ce.setNo(rows++);
+            if (StringUtils.isEmpty(ce.getM2())) {
+                ce.setM2(FileHelper.getSizes(ce.getSizes()));
+            }
+            ce.setM3(FileHelper.getSquareMeter(ce.getArea()));
+            allCount += ce.getCount();
+            allSize += ce.getSizes();
+            allArea += ce.getArea();
+            allLen += ce.getLen();
+        }
+        if (list.size() > 0) {
+            CountEntity ce = new CountEntity();
+            ce.setNo(rows);
+            ce.setM1("鎬昏");
+            ce.setCount(allCount);
+            if (StringUtils.isEmpty(list.get(0).getM2())) {
+                ce.setM2(FileHelper.getSizes(allSize));
+            }
+            ce.setM3(FileHelper.getSquareMeter(allArea));
+            ce.setLen(allLen);
+            list.add(ce);
         }
 
-        WordHelper.generateWord(source, target, null, addList);
+        return list;
     }
 
     /**
-     * 鍒涘缓 鏁版嵁閲忕粺璁� Word
+     * 鏍规嵁鏂规硶鍚嶇О鏌ヨ鏁版嵁鍒楄〃
      */
-    public void createCountSizesWord(String source, String target) {
-        List<CountEntity> list = countSizes();
+    private List<CountEntity> selectListByMethodName(ReportEntity re, String code) {
+        List<CountEntity> list = null;
+        try {
+            Object obj;
+            if (null != code) {
+                Method method = ReportService.class.getDeclaredMethod(re.getCode(), String.class);
+                obj = method.invoke(this, code);
+            } else {
+                Method method = ReportService.class.getDeclaredMethod(re.getCode());
+                obj = method.invoke(this);
+            }
+            if (obj instanceof List<?>) {
+                list = (List<CountEntity>) obj;
+            }
+        } catch (Exception ex) {
+            log.error(ex.getMessage(), ex);
+        }
+
         if (null == list || list.isEmpty()) {
-            return;
+            return list;
         }
-
-        int rows = 1;
-        ArrayList<String[]> addList = new ArrayList<>();
         for (CountEntity ce : list) {
-            String[] strs = new String[]{"" + rows++, ce.getM1(), FileHelper.getSizes(ce.getSizes())};
-            addList.add(strs);
+            if (null == ce.getCount()) {
+                ce.setCount(0L);
+            }
+            if (null == ce.getSizes()) {
+                ce.setSizes(0d);
+            }
+            if (null == ce.getArea()) {
+                ce.setArea(0d);
+            }
+            if (null == ce.getLen()) {
+                ce.setLen(0d);
+            }
         }
 
-        WordHelper.generateWord(source, target, null, addList);
+        return list;
+    }
+
+    /**
+     * 鑾峰彇涓嬭浇瀹炰綋绫�
+     */
+    private DownloadEntity getDownloadEntity(UserEntity ue, String file) {
+        DownloadEntity de = new DownloadEntity();
+        de.setName(FileHelper.getFileName(file));
+        // 1-Shp鏂囦欢锛�2-涓撻鍥撅紝3-鍏冩暟鎹紝4-涓氬姟鏁版嵁锛�5-绠¢亾鍒嗘瀽锛�6-缁熻鎶ュ憡锛�7-闄勪欢鏂囦欢锛�8-鐡︾墖鏂囦欢
+        de.setType(6);
+        de.setSizes(FileHelper.sizeToMb(new File(file).length()));
+        de.setDepid(ue.getDepid());
+        de.setDcount(1);
+        de.setPwd(null);
+        de.setUrl(FileHelper.getRelativePath(file));
+        de.setDescr("缁熻鎶ュ憡");
+        de.setGuid(FileHelper.getFileMd5(file));
+        de.setCreateUser(ue.getId());
+        // de.setGeom(null)
+
+        return de;
     }
 }

--
Gitblit v1.9.3