内涝仿真服务
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
张洋洋
2025-02-11 49aa6ed510d18506cc11d24299899ab0b35047b3 
 src/main/java/com/se/simu/controller/SimuController.java


@@ -7,6 +7,7 @@


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.*;


@@ -14,14 +15,17 @@


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.*;


import java.net.URL;


import java.net.URLEncoder;


import java.nio.charset.StandardCharsets;


import java.util.*;


import java.util.stream.Collectors;


@@ -52,6 +56,9 @@




    @Value("${config.outPath}")


    private String outPath;




    @Value("${config.inPath}")


    private String inPath;






    @Resource


@@ -343,7 +350,7 @@




    @ApiOperation(value = "tarr文件组装")


    @GetMapping(value = "/saveZarr", produces = "application/json; charset=UTF-8")


    public R<Boolean> saveZarr(@RequestParam("name") String tableName) throws IOException {


    public R<String> saveZarr(@RequestParam("name") String tableName) throws Exception {


        List<String> list = CsvToSQLiteUtils.getNameList(tableName);


        String path = outPath + "\\";


        String rainfall = "rainfall\\";


@@ -387,7 +394,7 @@


            metry.put("type", "MultiPoint");


            metry.put("lod", 0);


            JSONArray boundarie = new JSONArray();


            boundarie.add(jsonObject.getJSONArray("vertices").size()-1);


            boundarie.add(jsonObject.getJSONArray("vertices").size() - 1);


            metry.put("boundaries", boundarie);


            geometry.add(metry);


            cityObject.put("geometry", geometry);


@@ -400,7 +407,13 @@


        FileWriter fileWriter = new FileWriter(path + tableName + "\\降雨量.json");


        fileWriter.write(jsonObject.toJSONString());


        fileWriter.close();


        return success(true);


        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 = "管点转cityjson")


@@ -428,7 +441,7 @@


            metry.put("type", "MultiPoint");


            metry.put("lod", 0);


            JSONArray boundarie = new JSONArray();


            boundarie.add(jsonObject.getJSONArray("vertices").size()-1);


            boundarie.add(jsonObject.getJSONArray("vertices").size() - 1);


            metry.put("boundaries", boundarie);


            geometry.add(metry);


            cityObject.put("geometry", geometry);


@@ -443,14 +456,46 @@


        FileWriter fileWriter = new FileWriter(pointPath);


        fileWriter.write(jsonObject.toJSONString());


        fileWriter.close();


        return success(pointPath);


        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 = "管线转cityjson")


    @GetMapping(value = "/lineToCityJson", produces = "application/json; charset=UTF-8")


    public R<String> lineToCityJson(@RequestParam("shpPath") String shpPath) throws Exception {


    @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\\";


        List<Map<String, Object>> list = ShpReadUtils.readPointShp(shpPath);


        JSONArray jsonArrayList = EntityLibraryUtils.getPointInfo(dtos);


        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) + ")";


        String publicKey = EntityLibraryUtils.getPublicKey();


        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.getPointDetail(src);


        //todo 替换mapencodedString


        List<Map<String, Object>> list = new ArrayList<>();


        JSONObject jsonObject = getModule("linemodule.json");


        for (Map<String, Object> map : list


        ) {


@@ -467,14 +512,16 @@


            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);


                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 jsonArray = new JSONArray();


            jsonArray.add(boundarie);


            metry.put("boundaries", jsonArray);


            cityObject.put("geometry",metry);


            cityObject.put("attributes",attribute);


            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);


@@ -488,7 +535,166 @@


        FileWriter fileWriter = new FileWriter(pointPath);


        fileWriter.write(jsonObject.toJSONString());


        fileWriter.close();


        return success(pointPath);


        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 = "管线转cityjson")


//    @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 = "地形转cityjson")


    @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转cityjson")


    @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转sem")


    @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转sem")


    @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) {