From a50e2b2d6f92040abfc98a027a966990fc27a278 Mon Sep 17 00:00:00 2001
From: 张洋洋 <10611411+yang-yang-z@user.noreply.gitee.com>
Date: 星期五, 14 二月 2025 13:36:19 +0800
Subject: [PATCH] [add]tif裁剪

---
 src/main/java/com/se/simu/controller/SimuController.java |  631 +++++++++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 588 insertions(+), 43 deletions(-)

diff --git a/src/main/java/com/se/simu/controller/SimuController.java b/src/main/java/com/se/simu/controller/SimuController.java
index 100e534..555d33f 100644
--- a/src/main/java/com/se/simu/controller/SimuController.java
+++ b/src/main/java/com/se/simu/controller/SimuController.java
@@ -3,30 +3,32 @@
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.google.common.io.Resources;
 import com.se.simu.config.PropertiesConfig;
 import com.se.simu.domain.dto.GeDb;
 import com.se.simu.domain.dto.GeLayer;
+import com.se.simu.domain.dto.GridDto;
 import com.se.simu.domain.po.DataPo;
 import com.se.simu.domain.po.SimuPo;
-import com.se.simu.domain.vo.CreateFilesSimuVo;
-import com.se.simu.domain.vo.CreateSimuVo;
-import com.se.simu.domain.vo.R;
-import com.se.simu.domain.vo.SimuVo;
+import com.se.simu.domain.vo.*;
 import com.se.simu.service.*;
-import com.se.simu.utils.CsvToSQLiteUtils;
-import com.se.simu.utils.ShpToolUtils;
+import com.se.simu.utils.*;
 import io.swagger.annotations.*;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.codec.binary.Base64;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.core.io.ClassPathResource;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.web.util.UriUtils;
 
 import javax.annotation.Resource;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Date;
-import java.util.List;
+import java.io.*;
+import java.net.URL;
+import java.net.URLEncoder;
+import java.nio.charset.StandardCharsets;
+import java.util.*;
+import java.util.stream.Collectors;
 
 @Api(tags = "浠跨湡绠$悊")
 @Slf4j
@@ -51,6 +53,12 @@
 
     @Value("${simu-app.filePath}")
     private String uploadedFolder;
+
+    @Value("${config.outPath}")
+    private String outPath;
+
+    @Value("${config.inPath}")
+    private String inPath;
 
 
     @Resource
@@ -213,35 +221,36 @@
         String floodFile = vo.getFloodFile();
         log.info("鑼冨洿鏂囦欢鍦板潃锛歿}", floodFile);
         try {
-            // 鍒ゆ柇鍦板潃涓嶄负绌�
-            if (StringUtils.isEmpty(floodFile)) {
-                return fail("鑼冨洿鏂囦欢鍦板潃涓嶈兘涓虹┖", false);
-            } else {
-                // 鑾峰彇鏂囦欢鐨勫悗缂�鍚�
-                String fileName = floodFile.substring(floodFile.lastIndexOf("."));
-                // 鍒ゆ柇鍚庣紑鍚嶆槸鍚︿负.shp
-                if (!fileName.equalsIgnoreCase(".shp")) {
-                    return fail("鑼冨洿鏂囦欢鏍煎紡涓嶆纭�", false);
+            // 鍒ゆ柇鏄惁缁樺埗鍖哄煙
+            if (!StringUtils.isEmpty(vo.getMaxx().toString()) && !Objects.isNull(vo.getMaxx())) {
+                rangeVerify(vo.getMinx(), vo.getMaxx(), vo.getMiny(), vo.getMaxy());
+                log.info("缁樺埗鍖哄煙鑼冨洿楠岃瘉閫氳繃!");
+            } else
+                // 鍒ゆ柇鍦板潃涓嶄负绌�
+                if (StringUtils.isEmpty(floodFile)) {
+                    return fail("鑼冨洿鏂囦欢鍦板潃涓嶈兘涓虹┖", false);
                 } else {
-                    // 1 璇诲彇shp鏂囦欢锛岃幏鍙栬寖鍥村��
-                    JSONObject jsonObject = ShpToolUtils.readShp(floodFile);
-                    // 2 鑾峰彇jsonObject涓殑鑼冨洿鍊�
-                    Double minX = jsonObject.getDouble("minY");
-                    Double maxX = jsonObject.getDouble("maxY");
-                    Double minY = jsonObject.getDouble("minX");
-                    Double maxY = jsonObject.getDouble("maxX");
-                    // 3 鍒ゆ柇鑼冨洿鍊兼槸鍚︿负绌�
-                    // vo.setMinx(jsonObject.getDouble("minX"));
-                    // vo.setMaxx(jsonObject.getDouble("maxX"));
-                    // vo.setMiny(jsonObject.getDouble("minY"));
-                    // vo.setMaxy(jsonObject.getDouble("maxY"));
-                    vo.setMinx(jsonObject.getDouble("minY"));
-                    vo.setMaxx(jsonObject.getDouble("maxY"));
-                    vo.setMiny(jsonObject.getDouble("minX"));
-                    vo.setMaxy(jsonObject.getDouble("maxX"));
-                    rangeVerify(minX,maxX, minY, maxY);
+                    // 鑾峰彇鏂囦欢鐨勫悗缂�鍚�
+                    String fileName = floodFile.substring(floodFile.lastIndexOf("."));
+                    // 鍒ゆ柇鍚庣紑鍚嶆槸鍚︿负.shp
+                    if (!fileName.equalsIgnoreCase(".shp")) {
+                        return fail("鑼冨洿鏂囦欢鏍煎紡涓嶆纭�", false);
+                    } else {
+                        // 1 璇诲彇shp鏂囦欢锛岃幏鍙栬寖鍥村��
+                        JSONObject jsonObject = ShpToolUtils.readShp(floodFile);
+                        // 2 鑾峰彇jsonObject涓殑鑼冨洿鍊�
+                        Double minX = jsonObject.getDouble("minY");
+                        Double maxX = jsonObject.getDouble("maxY");
+                        Double minY = jsonObject.getDouble("minX");
+                        Double maxY = jsonObject.getDouble("maxX");
+                        // 3 鍒ゆ柇鑼冨洿鍊兼槸鍚︿负绌�
+                        vo.setMinx(jsonObject.getDouble("minY"));
+                        vo.setMaxx(jsonObject.getDouble("maxY"));
+                        vo.setMiny(jsonObject.getDouble("minX"));
+                        vo.setMaxy(jsonObject.getDouble("maxX"));
+                        rangeVerify(minX, maxX, minY, maxY);
+                    }
                 }
-            }
             // todo: 瑙f瀽鑼冨洿鏂囦欢 鏍规嵁涓嶅悓鐨勭殑鏍煎紡鏂囦欢杩涜涓嶅悓鐨勮В鏋愶紝鑾峰彇闇�瑕佽绠楃殑鑼冨洿鍊�
             //  涓婁紶鏍煎紡锛�.shp/.tiff/.img/.geojson
             //  閲嶆柊缁檝o璧嬪��
@@ -251,7 +260,7 @@
                 return fail("瑙f瀽鑼冨洿鏂囦欢澶辫触锛侀�夋嫨鑼冨洿涓嶈兘涓虹┖锛岃閲嶆柊閫夋嫨鏂囦欢锛�", false);
             }
         }
-
+        JSONArray jsonArray = new JSONArray();
         String stationFile = vo.getStationFile();
         log.info("绔欑偣鏂囦欢shp鍦板潃锛歿}", stationFile);
         try {
@@ -260,7 +269,7 @@
                 return fail("绔欑偣鏂囦欢shp鍦板潃涓嶈兘涓虹┖", false);
             }
             // 1 璇诲彇shp鏂囦欢锛岃幏鍙栫珯鐐瑰潗鏍囧��
-            JSONArray jsonArray = ShpToolUtils.readShpGetLocal(stationFile);
+            jsonArray = ShpToolUtils.readShpGetLocal(stationFile);
             System.out.println("jsonArray = " + jsonArray);
         } catch (Exception e) {
             log.error("瑙f瀽绔欑偣鏂囦欢shp澶辫触");
@@ -268,15 +277,16 @@
 
         String stationRainFile = vo.getStationRainFile();
         log.info("绔欑偣闆ㄩ噺CSV鏂囦欢鍦板潃锛歿}", floodFile);
+        JSONArray array = new JSONArray();
+        // 鍒涘缓琛ㄥ悕 鏃堕棿鎴�
+        String tableName = "station_rain_" + System.currentTimeMillis();
         try {
             // 鍒ゆ柇鍦板潃涓嶄负绌�
             if (StringUtils.isEmpty(stationRainFile)) {
                 return fail("绔欑偣闆ㄩ噺CSV鏂囦欢鍦板潃涓嶈兘涓虹┖", false);
             }
-            // 鍒涘缓琛ㄥ悕 鏃堕棿鎴�
-            String tableName = "station_rain_" + System.currentTimeMillis();
             // 1 璇诲彇CSV 鏂囦欢
-            CsvToSQLiteUtils.readCsvSaveLocal(stationRainFile, tableName);
+            array = CsvToSQLiteUtils.readCsvSaveLocal(stationRainFile, tableName);
             // 鑾峰彇浠跨湡鏃堕棿 duration
             Integer duration = CsvToSQLiteUtils.getDuration(tableName);
             log.info("浠跨湡鏃堕棿 duration = {}", duration);
@@ -326,6 +336,12 @@
                     return fail("闃叉睕鑼冨洿涓嶈兘涓虹┖", false);
                 }
             }
+            List<GridDto> dtos = new ArrayList<>();
+            dtos.add(new GridDto(vo.getMinx(), vo.getMiny()));
+            dtos.add(new GridDto(vo.getMinx(), vo.getMaxy()));
+            dtos.add(new GridDto(vo.getMaxx(), vo.getMaxy()));
+            dtos.add(new GridDto(vo.getMaxx(), vo.getMiny()));
+            createSem(tableName, dtos);
             // 寮�濮嬫ā鎷熻绠�
             boolean flag = simuFilesService.createByfiles(vo);
             return success(flag, flag ? "鎴愬姛" : "澶辫触");
@@ -334,5 +350,534 @@
         }
     }
 
+    public R<Boolean> createSem(String tableName, List<GridDto> dtos) throws Exception {
+        //闄嶉洦鏂囦欢鐢熸垚
+        saveZarr(tableName);
+        //绠$偣鐢熸垚
+        pointTosem(dtos);
+        //绠$嚎鐢熸垚
+        lineToSem(dtos);
+        //鍦板舰鐢熸垚
+        terrainToSem(dtos);
+        //鑼冨洿鐢熸垚
+        gridToCityJson(dtos);
+        //娌虫祦鐢熸垚
+        riverToSem();
+        //鍦熷湴鍒╃敤鐢熸垚
+        landuseToSem();
+        return success(true);
+    }
+
+    @ApiOperation(value = "tarr鏂囦欢缁勮")
+    @GetMapping(value = "/saveZarr", produces = "application/json; charset=UTF-8")
+    public R<String> saveZarr(@RequestParam("name") String tableName) throws Exception {
+        List<String> list = CsvToSQLiteUtils.getNameList(tableName);
+        String path = outPath + "\\";
+        String rainfall = "rainfall\\";
+        String basePath = path + tableName + "\\" + rainfall;
+        JSONObject jsonObject = getModule("rainfallmodule.json");
+        for (String src : list
+        ) {
+            File directories = new File(basePath);
+            if (!directories.exists()) {
+                directories.mkdirs();
+                System.out.println("Directories created successfully.");
+            } else {
+                System.out.println("Directories already exist.");
+            }
+            List<StationRainVo> stationRainVos = CsvToSQLiteUtils.getList(tableName, src);
+            ZarrUtils.saveZarrRainfall(basePath + src, stationRainVos);
+            ZarrUtils.saveZarrTime(basePath + src, stationRainVos);
+            ZipUtils.toZarr(basePath + src, basePath + src + ".zip");
+            System.out.println(src + "鐨剒arr鏁版嵁鐢熸垚=====================");
+            //json鎷艰
+            String uuid = "UUID_" + UUID.randomUUID().toString();
+            //鎷艰zarr
+            JSONObject dynamizer = new JSONObject();
+            dynamizer.put("url", rainfall.replace("\\", "/") + src + ".zarr");
+            dynamizer.put("gmlId", uuid);
+            jsonObject.getJSONArray("Dynamizers").add(dynamizer);
+            //鎷艰鍧愭爣
+            JSONArray vertice = new JSONArray();
+            vertice.add(stationRainVos.get(0).getLongitude());
+            vertice.add(stationRainVos.get(0).getLatitude());
+            vertice.add(0.0);
+            jsonObject.getJSONArray("vertices").add(vertice);
+            //鎷艰鍩虹淇℃伅
+            JSONObject cityObject = new JSONObject();
+            cityObject.put("type", "+Rainfall");
+            JSONObject attribute = new JSONObject();
+            attribute.put("name", src);
+            cityObject.put("attributes", attribute);
+            JSONArray geometry = new JSONArray();
+            JSONObject metry = new JSONObject();
+            metry.put("type", "MultiPoint");
+            metry.put("lod", 0);
+            JSONArray boundarie = new JSONArray();
+            boundarie.add(jsonObject.getJSONArray("vertices").size() - 1);
+            metry.put("boundaries", boundarie);
+            geometry.add(metry);
+            cityObject.put("geometry", geometry);
+            jsonObject.getJSONObject("CityObjects").put(uuid, cityObject);
+        }
+        File jsonFile = new File(path + tableName + "\\闄嶉洦閲�.json");
+        if (jsonFile.exists()) {
+            jsonFile.createNewFile();
+        }
+        FileWriter fileWriter = new FileWriter(path + tableName + "\\闄嶉洦閲�.json");
+        fileWriter.write(jsonObject.toJSONString());
+        fileWriter.close();
+        String filePatn = inPath + "\\tongzhou\\";
+        File file = new File(filePatn);
+        if (!file.exists()) {
+            file.mkdirs();
+        }
+        SemUtils.cityJsonToSem(path + tableName + "\\闄嶉洦閲�.json", filePatn + "raingage.sem");
+        return success(filePatn + "raingage.sem");
+    }
+
+    @ApiOperation(value = "绠$偣杞瑂em")
+    @PostMapping(value = "/pointTosem", produces = "application/json; charset=UTF-8")
+    public R<String> pointTosem(@RequestBody List<GridDto> dtos) throws Exception {
+        String path = outPath + "\\point\\";
+        String publicKey = EntityLibraryUtils.getPublicKey();
+        String token = EntityLibraryUtils.login();
+        JSONArray jsonArrayList = EntityLibraryUtils.getPointInfo(dtos, token);
+        JSONObject jsonObject = getModule("pointmodule.json");
+        for (int s = 0; s < jsonArrayList.size(); s++) {
+            JSONObject pointObject = jsonArrayList.getJSONObject(s);
+            //鎷艰鍧愭爣
+            JSONArray vertice = new JSONArray();
+            vertice.add(Double.valueOf(pointObject.getString("lon")));
+            vertice.add(Double.valueOf(pointObject.getString("lat")));
+            vertice.add(0.0);
+            jsonObject.getJSONArray("vertices").add(vertice);
+            //鎷艰鍩虹淇℃伅
+            JSONObject cityObject = new JSONObject();
+            cityObject.put("type", "+PipePoint");
+            JSONObject attribute = new JSONObject();
+            attribute.put("缁存姢鏃堕棿", pointObject.get("operatetime"));
+            attribute.put("缁存姢浜�", pointObject.get("operator"));
+            attribute.put("鍞竴缂栫爜", pointObject.get("seid"));
+            attribute.put("ID", pointObject.get("id"));
+            attribute.put("enti_uuid", pointObject.get("enti_uuid"));
+            attribute.put("鏍囪瘑鐮�", pointObject.get("bsm"));
+            attribute.put("绠$嚎绉嶇被", pointObject.get("gxzl"));
+            attribute.put("鍦伴潰楂樼▼", pointObject.get("dmgc"));
+            attribute.put("鐗瑰緛", pointObject.get("tz"));
+            attribute.put("闄勫睘鐗�", pointObject.get("fsw"));
+            attribute.put("寤虹瓚鐗�", pointObject.get("jzw"));
+            attribute.put("浜曞簳楂樼▼", pointObject.get("jdgc"));
+            attribute.put("浜曞簳鍩嬫繁", pointObject.get("jdms"));
+            attribute.put("浜曡剸鍩嬫繁", pointObject.get("jbms"));
+            attribute.put("浜曠洊褰㈢姸", pointObject.get("jgxz"));
+            attribute.put("浜曠洊灏哄", pointObject.get("jgcc"));
+            attribute.put("浜曠洊鏉愯川", pointObject.get("jgcz"));
+            attribute.put("浜曠洊鐘舵��", pointObject.get("jgzt"));
+            attribute.put("浜曡剸鏉愯川", pointObject.get("jbcz"));
+            attribute.put("浜曡剸灏哄", pointObject.get("jbcc"));
+            attribute.put("浜曟潗璐�", pointObject.get("jcz"));
+            attribute.put("浜曞昂瀵�", pointObject.get("jcc"));
+            attribute.put("浣跨敤鐘跺喌", pointObject.get("syzk"));
+            attribute.put("lon", Double.valueOf(pointObject.getString("lon")));
+            attribute.put("lat", Double.valueOf(pointObject.getString("lat")));
+            attribute.put("atti", pointObject.get("atti"));
+            attribute.put("闆ㄦ按闆嗙粨鐐�", pointObject.get("ysjjd"));
+            cityObject.put("attributes", attribute);
+            JSONArray geometry = new JSONArray();
+            JSONObject metry = new JSONObject();
+            metry.put("type", "MultiPoint");
+            metry.put("lod", 0);
+            JSONArray boundarie = new JSONArray();
+            boundarie.add(jsonObject.getJSONArray("vertices").size() - 1);
+            metry.put("boundaries", boundarie);
+            geometry.add(metry);
+            cityObject.put("geometry", geometry);
+            jsonObject.getJSONObject("CityObjects").put("UUID_" + UUID.randomUUID().toString(), cityObject);
+        }
+        long times = System.currentTimeMillis();
+        String pointPath = path + times + "\\绠$偣.json";
+        File dirFile = new File(path + times);
+        if (!dirFile.exists()) {
+            dirFile.mkdirs();
+        }
+        FileWriter fileWriter = new FileWriter(pointPath);
+        fileWriter.write(jsonObject.toJSONString());
+        fileWriter.close();
+        String filePatn = inPath + "\\tongzhou\\";
+        File file = new File(filePatn);
+        if (!file.exists()) {
+            file.mkdirs();
+        }
+        SemUtils.cityJsonToSem(pointPath, filePatn + "node.sem");
+        return success(filePatn + "node.sem");
+    }
+
+    @ApiOperation(value = "绠$偣杞琧ityjson")
+    @GetMapping(value = "/pointToCityJson", produces = "application/json; charset=UTF-8")
+    public R<String> pointToCityJson(@RequestParam("shpPath") String shpPath) throws Exception {
+        String path = outPath + "\\point\\";
+        List<Map<String, Object>> list = ShpReadUtils.readPointShp(shpPath);
+        JSONObject jsonObject = getModule("pointmodule.json");
+        for (Map<String, Object> map : list
+        ) {
+            //鎷艰鍧愭爣
+            JSONArray vertice = new JSONArray();
+            vertice.add(map.get("lon"));
+            vertice.add(map.get("lat"));
+            vertice.add(0.0);
+            jsonObject.getJSONArray("vertices").add(vertice);
+            //鎷艰鍩虹淇℃伅
+            JSONObject cityObject = new JSONObject();
+            cityObject.put("type", "+PipePoint");
+            JSONObject attribute = new JSONObject();
+            attribute.put("name", map.get("fsw"));
+            cityObject.put("attributes", attribute);
+            JSONArray geometry = new JSONArray();
+            JSONObject metry = new JSONObject();
+            metry.put("type", "MultiPoint");
+            metry.put("lod", 0);
+            JSONArray boundarie = new JSONArray();
+            boundarie.add(jsonObject.getJSONArray("vertices").size() - 1);
+            metry.put("boundaries", boundarie);
+            geometry.add(metry);
+            cityObject.put("geometry", geometry);
+            jsonObject.getJSONObject("CityObjects").put("UUID_" + UUID.randomUUID().toString(), cityObject);
+        }
+        long times = System.currentTimeMillis();
+        String pointPath = path + times + "\\绠$偣.json";
+        File dirFile = new File(path + times);
+        if (!dirFile.exists()) {
+            dirFile.mkdirs();
+        }
+        FileWriter fileWriter = new FileWriter(pointPath);
+        fileWriter.write(jsonObject.toJSONString());
+        fileWriter.close();
+        String filePatn = inPath + "\\tongzhou\\";
+        File file = new File(filePatn);
+        if (!file.exists()) {
+            file.mkdirs();
+        }
+        SemUtils.cityJsonToSem(pointPath, filePatn + "node.sem");
+        return success(filePatn + "node.sem");
+    }
+
+    @ApiOperation(value = "绠$嚎sem鐢熸垚")
+    @PostMapping(value = "/lineToSem", produces = "application/json; charset=UTF-8")
+    public R<String> lineToSem(@RequestBody List<GridDto> dtos) throws Exception {
+        String path = outPath + "\\line\\";
+        String publicKey = EntityLibraryUtils.getPublicKey();
+        String token = EntityLibraryUtils.login();
+        JSONArray jsonArrayList = EntityLibraryUtils.getLineInfo(dtos, token);
+        if (jsonArrayList.size() == 0) {
+            return fail("璇ュ尯鍩熶笉瀛樺湪绠$嚎锛�");
+        }
+        StringBuffer stringBuffer = new StringBuffer("id in (");
+        for (int i = 0; i < jsonArrayList.size(); i++) {
+            jsonArrayList.getJSONObject(i).getInteger("id");
+            stringBuffer.append("'" + jsonArrayList.getJSONObject(i).getInteger("id") + "',");
+        }
+        String sql = stringBuffer.toString();
+        sql = sql.substring(0, sql.length() - 1) + ")";
+        StringBuffer paramBuffer = new StringBuffer("");
+        while (!"".equals(sql)) {
+            if (sql.length() > 110) {
+                String item = sql.substring(0, 110);
+                paramBuffer.append(EntityLibraryUtils.encrypt(item, publicKey) + ",");
+                sql = sql.replace(item, "");
+            } else {
+                paramBuffer.append(EntityLibraryUtils.encrypt(sql, publicKey) + ",");
+                sql = "";
+            }
+        }
+        String src = paramBuffer.toString().substring(0, paramBuffer.length() - 1);
+        JSONArray arrayDetail = EntityLibraryUtils.getLineDetail(src, token);
+        JSONObject jsonObject = getModule("linemodule.json");
+        for (int i = 0; i < arrayDetail.size(); i++) {
+            JSONObject detailJSONObject = arrayDetail.getJSONObject(i);
+            //鎷艰鍩虹淇℃伅
+            JSONObject cityObject = new JSONObject();
+            cityObject.put("type", "+PipeLine");
+            JSONObject attribute = new JSONObject();
+            attribute.put("缁存姢鏃堕棿", detailJSONObject.getJSONObject("properties").getLong("operatetime"));
+            attribute.put("缁存姢浜�", detailJSONObject.getJSONObject("properties").getString("operator"));
+            attribute.put("鍞竴缂栫爜", detailJSONObject.getJSONObject("properties").get("seid"));
+            attribute.put("ENTI_UUID", detailJSONObject.getJSONObject("properties").get("enti_uuid"));
+            attribute.put("ID", detailJSONObject.getJSONObject("properties").get("id"));
+            attribute.put("lon", detailJSONObject.getJSONObject("properties").get("lon"));
+            attribute.put("lat", detailJSONObject.getJSONObject("properties").get("lat"));
+            attribute.put("atti", detailJSONObject.getJSONObject("properties").get("atti"));
+            attribute.put("绠$嚎绉嶇被", detailJSONObject.getJSONObject("properties").get("gxzl"));
+            attribute.put("璧风偣鏍囪瘑鐮�", detailJSONObject.getJSONObject("properties").get("qdbsm"));
+            attribute.put("姝㈢偣鏍囪瘑鐮�", detailJSONObject.getJSONObject("properties").get("zdbsm"));
+            attribute.put("璧风偣楂樼▼", detailJSONObject.getJSONObject("properties").get("qdgc"));
+            attribute.put("璧烽珮绋嬬被鍨�", detailJSONObject.getJSONObject("properties").get("qgclx"));
+            attribute.put("璧风偣鍩嬫繁", detailJSONObject.getJSONObject("properties").get("qdms"));
+            attribute.put("姝㈢偣楂樼▼", detailJSONObject.getJSONObject("properties").get("zdgc"));
+            attribute.put("姝㈤珮绋嬬被鍨�", detailJSONObject.getJSONObject("properties").get("zgclx"));
+            attribute.put("姝㈢偣鍩嬫繁", detailJSONObject.getJSONObject("properties").get("zdms"));
+            attribute.put("鏉愯川", detailJSONObject.getJSONObject("properties").get("cz"));
+            attribute.put("鍩嬭鏂瑰紡", detailJSONObject.getJSONObject("properties").get("msfs"));
+            attribute.put("绠″緞1", detailJSONObject.getJSONObject("properties").get("gja"));
+            attribute.put("绠″緞2", detailJSONObject.getJSONObject("properties").get("gjb"));
+            attribute.put("浣跨敤鐘跺喌", detailJSONObject.getJSONObject("properties").get("syzk"));
+            attribute.put("绠$嚎娈甸暱搴�", detailJSONObject.getJSONObject("properties").get("gxdcd"));
+            attribute.put("groupID", detailJSONObject.getJSONObject("properties").get("groupid"));
+            attribute.put("Shape_Length", detailJSONObject.getJSONObject("properties").get("shape_length"));
+            attribute.put("鏍囪瘑鐮�", detailJSONObject.getJSONObject("properties").get("bsm"));
+            JSONArray geometry = new JSONArray();
+            JSONObject metry = new JSONObject();
+            metry.put("type", "MultiLineString");
+            metry.put("lod", 0);
+            JSONArray boundarie = new JSONArray();
+            JSONArray array = detailJSONObject.getJSONObject("geometry").getJSONArray("coordinates").getJSONArray(0);
+            for (int m = 0; m < array.size(); m++) {
+                JSONArray object = array.getJSONArray(m);
+                jsonObject.getJSONArray("vertices").add(ProjectionToGeographicUtil.getPoint(object.getDouble(0), object.getDouble(1)));
+                boundarie.add(jsonObject.getJSONArray("vertices").size() - 1);
+            }
+            JSONArray jsonArray = new JSONArray();
+            jsonArray.add(boundarie);
+            metry.put("boundaries", jsonArray);
+            JSONArray metryArray = new JSONArray();
+            metryArray.add(metry);
+            cityObject.put("geometry", metryArray);
+            cityObject.put("attributes", attribute);
+            cityObject.put("attributes", attribute);
+            geometry.add(metry);
+            jsonObject.getJSONObject("CityObjects").put("UUID_" + UUID.randomUUID().toString(), cityObject);
+        }
+        long times = System.currentTimeMillis();
+        String pointPath = path + times + "\\绠$嚎.json";
+        File dirFile = new File(path + times);
+        if (!dirFile.exists()) {
+            dirFile.mkdirs();
+        }
+        FileWriter fileWriter = new FileWriter(pointPath);
+        fileWriter.write(jsonObject.toJSONString());
+        fileWriter.close();
+        String filePatn = inPath + "\\tongzhou\\";
+        File file = new File(filePatn);
+        if (!file.exists()) {
+            file.mkdirs();
+        }
+        SemUtils.cityJsonToSem(pointPath, filePatn + "link.sem");
+        return success(filePatn + "link.sem");
+    }
+
+    @ApiOperation(value = "绠$嚎杞琧ityjson")
+    @GetMapping(value = "/lineToCityJson", produces = "application/json; charset=UTF-8")
+    public R<String> lineToCityJson(@RequestParam("shpPath") String shpPath) throws Exception {
+        String path = outPath + "\\line\\";
+        List<Map<String, Object>> list = ShpReadUtils.readPointShp(shpPath);
+        JSONObject jsonObject = getModule("linemodule.json");
+        for (Map<String, Object> map : list
+        ) {
+            //鎷艰鍩虹淇℃伅
+            JSONObject cityObject = new JSONObject();
+            cityObject.put("type", "+PipeLine");
+            JSONObject attribute = new JSONObject();
+            attribute.put("name", map.get("msfs"));
+            JSONArray geometry = new JSONArray();
+            JSONObject metry = new JSONObject();
+            metry.put("type", "MultiLineString");
+            metry.put("lod", 0);
+            JSONArray boundarie = new JSONArray();
+            JSONArray array = JSONObject.parseObject(map.get("the_geom").toString()).getJSONArray("coordinates");
+            for (int i = 0; i < array.size(); i++) {
+                JSONObject object = JSONObject.parseObject(array.get(i).toString());
+                jsonObject.getJSONArray("vertices").add(ProjectionToGeographicUtil.getPoint(Double.valueOf(object.get("x").toString()), Double.valueOf(object.get("y").toString())));
+                boundarie.add(jsonObject.getJSONArray("vertices").size() - 1);
+            }
+            JSONArray jsonArray = new JSONArray();
+            jsonArray.add(boundarie);
+            metry.put("boundaries", jsonArray);
+            JSONArray metryArray = new JSONArray();
+            metryArray.add(metry);
+            cityObject.put("geometry", metryArray);
+            cityObject.put("attributes", attribute);
+            cityObject.put("attributes", attribute);
+            geometry.add(metry);
+            jsonObject.getJSONObject("CityObjects").put("UUID_" + UUID.randomUUID().toString(), cityObject);
+        }
+        long times = System.currentTimeMillis();
+        String pointPath = path + times + "\\绠$嚎.json";
+        File dirFile = new File(path + times);
+        if (!dirFile.exists()) {
+            dirFile.mkdirs();
+        }
+        FileWriter fileWriter = new FileWriter(pointPath);
+        fileWriter.write(jsonObject.toJSONString());
+        fileWriter.close();
+        String filePatn = inPath + "\\tongzhou\\";
+        File file = new File(filePatn);
+        if (!file.exists()) {
+            file.mkdirs();
+        }
+        SemUtils.cityJsonToSem(pointPath, filePatn + "link.sem");
+        return success(filePatn + "link.sem");
+    }
+
+    @ApiOperation(value = "鍦板舰杞瑂em")
+    @PostMapping(value = "/terrainToSem", produces = "application/json; charset=UTF-8")
+    public R<String> terrainToSem(@RequestBody List<GridDto> dtos) throws Exception {
+        long times = System.currentTimeMillis();
+        String path = outPath + "\\terrain\\" + times + "\\";
+        File dirFile = new File(path + "appearance");
+        if (!dirFile.exists()) {
+            dirFile.mkdirs();
+        }
+        double minx = 180.0;
+        double maxx = 0.0;
+        double miny = 180.0;
+        double maxy = 0.0;
+        for (GridDto dto : dtos
+        ) {
+            if (dto.getLon() > maxx) {
+                maxx = dto.getLon();
+            }
+            if (dto.getLon() < minx) {
+                minx = dto.getLon();
+            }
+            if (dto.getLat() > maxy) {
+                maxy = dto.getLat();
+            }
+            if (dto.getLat() < miny) {
+                miny = dto.getLat();
+            }
+        }
+        JSONArray min = ProjectionToGeographicUtil.get4548Point(minx, miny);
+        JSONArray max = ProjectionToGeographicUtil.get4548Point(maxx, maxy);
+        String tifPath = path + "terrain.tif";
+        TiffClipper.cropTiffByLatLon(config.getTifPath(), tifPath, min.getDouble(0), min.getDouble(1), max.getDouble(0), max.getDouble(1));
+        String pngPath = path + "appearance\\terrain.png";
+        TiffToRGBUtil.tifToPng(tifPath, pngPath);
+        JSONObject jsonObject = getModule("terrainmodule.json");
+        jsonObject.put("vertices", TiffCoordinateExtractorUtil.getCoordinate(tifPath));
+        FileWriter fileWriter = new FileWriter(path + "terrain.json");
+        fileWriter.write(jsonObject.toJSONString());
+        fileWriter.close();
+        String filePatn = inPath + "\\tongzhou\\";
+        File file = new File(filePatn);
+        if (!file.exists()) {
+            file.mkdirs();
+        }
+        SemUtils.cityJsonToSem(path + "terrain.json", filePatn + "terrain.sem");
+        return success(filePatn + "terrain.sem");
+    }
+
+    @ApiOperation(value = "鍦板舰杞琧ityjson")
+    @GetMapping(value = "/terrainToCityJson", produces = "application/json; charset=UTF-8")
+    public R<String> terrainToCityJson(@RequestParam("tifPath") String tifPath) throws Exception {
+        long times = System.currentTimeMillis();
+        String path = outPath + "\\terrain\\" + times + "\\";
+        File dirFile = new File(path + "appearance");
+        if (!dirFile.exists()) {
+            dirFile.mkdirs();
+        }
+        String pngPath = path + "appearance\\terrain.png";
+        TiffToRGBUtil.tifToPng(tifPath, pngPath);
+        JSONObject jsonObject = getModule("terrainmodule.json");
+        jsonObject.put("vertices", TiffCoordinateExtractorUtil.getCoordinate(tifPath));
+        FileWriter fileWriter = new FileWriter(path + "terrain.json");
+        fileWriter.write(jsonObject.toJSONString());
+        fileWriter.close();
+        String filePatn = inPath + "\\tongzhou\\";
+        File file = new File(filePatn);
+        if (!file.exists()) {
+            file.mkdirs();
+        }
+        SemUtils.cityJsonToSem(path + "terrain.json", filePatn + "terrain.sem");
+        return success(filePatn + "terrain.sem");
+    }
+
+    @ApiOperation(value = "grid杞琧ityjson")
+    @PostMapping(value = "/gridToCityJson", produces = "application/json; charset=UTF-8")
+    public R<String> gridToCityJson(@RequestBody List<GridDto> dtos) throws Exception {
+        long times = System.currentTimeMillis();
+        String path = outPath + "\\grid\\" + times + "\\";
+        File dirFile = new File(path);
+        if (!dirFile.exists()) {
+            dirFile.mkdirs();
+        }
+        JSONObject jsonObject = getModule("grid.json");
+        JSONArray array = jsonObject.getJSONArray("vertices");
+        for (GridDto dto : dtos
+        ) {
+            JSONArray jsonArray = new JSONArray();
+            jsonArray.add(dto.getLon());
+            jsonArray.add(dto.getLat());
+            jsonArray.add(0);
+            array.add(jsonArray);
+        }
+        jsonObject.put("vertices", array);
+        FileWriter fileWriter = new FileWriter(path + "grid.json");
+        fileWriter.write(jsonObject.toJSONString());
+        fileWriter.close();
+        String filePatn = inPath + "\\tongzhou\\";
+        File file = new File(filePatn);
+        if (!file.exists()) {
+            file.mkdirs();
+        }
+        SemUtils.cityJsonToSem(path + "grid.json", filePatn + "grid.sem");
+        return success(filePatn + "grid.sem");
+    }
+
+    @ApiOperation(value = "river杞瑂em")
+    @GetMapping(value = "/riverToSem", produces = "application/json; charset=UTF-8")
+    public R<String> riverToSem() throws Exception {
+        long times = System.currentTimeMillis();
+        String path = outPath + "\\river\\" + times + "\\";
+        File dirFile = new File(path);
+        if (!dirFile.exists()) {
+            dirFile.mkdirs();
+        }
+        JSONObject jsonObject = getModule("river.json");
+        FileWriter fileWriter = new FileWriter(path + "river.json");
+        fileWriter.write(jsonObject.toJSONString());
+        fileWriter.close();
+        String filePatn = inPath + "\\tongzhou\\";
+        File file = new File(filePatn);
+        if (!file.exists()) {
+            file.mkdirs();
+        }
+        SemUtils.cityJsonToSem(path + "river.json", filePatn + "river.sem");
+        return success(filePatn + "river.sem");
+    }
+
+    @ApiOperation(value = "landuse杞瑂em")
+    @GetMapping(value = "/landuseToSem", produces = "application/json; charset=UTF-8")
+    public R<String> landuseToSem() throws Exception {
+        long times = System.currentTimeMillis();
+        String path = outPath + "\\landuse\\" + times + "\\";
+        File dirFile = new File(path);
+        if (!dirFile.exists()) {
+            dirFile.mkdirs();
+        }
+        JSONObject jsonObject = getModule("landuse.json");
+        FileWriter fileWriter = new FileWriter(path + "landuse.json");
+        fileWriter.write(jsonObject.toJSONString());
+        fileWriter.close();
+        String filePatn = inPath + "\\tongzhou\\";
+        File file = new File(filePatn);
+        if (!file.exists()) {
+            file.mkdirs();
+        }
+        SemUtils.cityJsonToSem(path + "landuse.json", filePatn + "landuse.sem");
+        return success(filePatn + "landuse.sem");
+    }
+
+    public JSONObject getModule(String moduleName) {
+        JSONObject jsonObject = new JSONObject();
+        try {
+            URL resource = Resources.getResource(moduleName);
+            String fileContent = Resources.toString(resource, StandardCharsets.UTF_8);
+            jsonObject = JSONObject.parseObject(fileContent);
+            System.out.println(fileContent);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return jsonObject;
+    }
 
 }

--
Gitblit v1.9.3