From a189f6e8046f0dc7048c9329a952a1ef499a88c7 Mon Sep 17 00:00:00 2001
From: 张洋洋 <10611411+yang-yang-z@user.noreply.gitee.com>
Date: 星期二, 14 一月 2025 17:49:21 +0800
Subject: [PATCH] [add]管线json
---
src/main/java/com/se/simu/controller/SimuController.java | 110 ++++++++++++++++++++++++++++++++++++++++++++++++------
1 files changed, 97 insertions(+), 13 deletions(-)
diff --git a/src/main/java/com/se/simu/controller/SimuController.java b/src/main/java/com/se/simu/controller/SimuController.java
index f461d3b..f9bc490 100644
--- a/src/main/java/com/se/simu/controller/SimuController.java
+++ b/src/main/java/com/se/simu/controller/SimuController.java
@@ -11,10 +11,7 @@
import com.se.simu.domain.po.SimuPo;
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.ZarrUtils;
-import com.se.simu.utils.ZipUtils;
+import com.se.simu.utils.*;
import io.swagger.annotations.*;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
@@ -52,6 +49,9 @@
@Value("${simu-app.filePath}")
private String uploadedFolder;
+
+ @Value("${config.outPath}")
+ private String outPath;
@Resource
@@ -333,10 +333,6 @@
return fail("闃叉睕鑼冨洿涓嶈兘涓虹┖", false);
}
}
- //todo 缁勮cityjson
- JSONObject jsonObject = new JSONObject();
- jsonObject.put("shp", jsonArray);
- jsonObject.put("csv", array);
// 寮�濮嬫ā鎷熻绠�
boolean flag = simuFilesService.createByfiles(vo);
return success(flag, flag ? "鎴愬姛" : "澶辫触");
@@ -346,10 +342,10 @@
}
@ApiOperation(value = "tarr鏂囦欢缁勮")
- @GetMapping(value = "/testZarr", produces = "application/json; charset=UTF-8")
- public R<Boolean> testZarr(@RequestParam("name") String tableName) throws IOException {
+ @GetMapping(value = "/saveZarr", produces = "application/json; charset=UTF-8")
+ public R<Boolean> saveZarr(@RequestParam("name") String tableName) throws IOException {
List<String> list = CsvToSQLiteUtils.getNameList(tableName);
- String path = "D:\\鍩庡競鍐呮稘\\sem\\闆ㄩ噺绔欑偣鏁版嵁\\";
+ String path = outPath + "\\";
String rainfall = "rainfall\\";
String basePath = path + tableName + "\\" + rainfall;
JSONObject jsonObject = getModule("rainfallmodule.json");
@@ -371,7 +367,7 @@
String uuid = "UUID_" + UUID.randomUUID().toString();
//鎷艰zarr
JSONObject dynamizer = new JSONObject();
- dynamizer.put("url", rainfall.replace("\\","/") + src + ".zarr");
+ dynamizer.put("url", rainfall.replace("\\", "/") + src + ".zarr");
dynamizer.put("gmlId", uuid);
jsonObject.getJSONArray("Dynamizers").add(dynamizer);
//鎷艰鍧愭爣
@@ -391,7 +387,7 @@
metry.put("type", "MultiPoint");
metry.put("lod", 0);
JSONArray boundarie = new JSONArray();
- boundarie.add(jsonObject.getJSONArray("vertices").size());
+ boundarie.add(jsonObject.getJSONArray("vertices").size()-1);
metry.put("boundaries", boundarie);
geometry.add(metry);
cityObject.put("geometry", geometry);
@@ -407,6 +403,94 @@
return success(true);
}
+ @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();
+ return success(pointPath);
+ }
+
+ @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);
+ cityObject.put("geometry",metry);
+ 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();
+ return success(pointPath);
+ }
+
public JSONObject getModule(String moduleName) {
JSONObject jsonObject = new JSONObject();
try {
--
Gitblit v1.9.3