From 256c1b584af7ed549e3efc3909c8c8b55a7a3331 Mon Sep 17 00:00:00 2001 From: dcb <dcb@163.com> Date: 星期四, 08 五月 2025 17:27:28 +0800 Subject: [PATCH] 生成流速图片 --- src/main/java/com/se/nsl/service/ResolveService.java | 22 ++++++++++ src/main/java/com/se/nsl/service/TestService.java | 67 +++++++++++++++++++++++++++++---- src/main/resources/application-dev.yml | 4 +- 3 files changed, 82 insertions(+), 11 deletions(-) diff --git a/src/main/java/com/se/nsl/service/ResolveService.java b/src/main/java/com/se/nsl/service/ResolveService.java index 8c84496..c4f0d3a 100644 --- a/src/main/java/com/se/nsl/service/ResolveService.java +++ b/src/main/java/com/se/nsl/service/ResolveService.java @@ -240,6 +240,26 @@ * 璋冪敤zarr2tif */ private String callZarr2tif(SimuData data) throws Exception { + String zarr2tifBat = config.getZarr2tifBat(); + File dir = new File(zarr2tifBat).getParentFile(); + String configJson = new File(dir, "config.json").getAbsolutePath(); + + String cmd = String.format("%s \"%s\"", zarr2tifBat, configJson); + String res = callBat(cmd); + + File resultTifDir = new File(dir, "result_tif"); + File targetDir = new File(config.getInPath(), data.getInPath() + File.separator + "depth"); + System.out.println("targetDir:" + targetDir); + File[] files = resultTifDir.listFiles(); + for (File file : files) { + File target = new File(targetDir, file.getName()); + Files.copy(file.toPath(), target.toPath()); + } + + return res; + } + + /*private String callZarr2tif(SimuData data) throws Exception { File uwBat = new File(config.getUwSolverBat()); String zarrFile = uwBat.getParent() + File.separator + "result.zarr"; String inPath = config.getInPath() + File.separator + data.getInPath(); @@ -249,7 +269,7 @@ String cmd = String.format("%s \"%s\" \"%s\" \"%s\" \"%s\"", config.getZarr2tifBat(), "depth", zarrFile, terrainFile, waterPath); return callBat(cmd); - } + }*/ private String callBat(String cmd) { try { diff --git a/src/main/java/com/se/nsl/service/TestService.java b/src/main/java/com/se/nsl/service/TestService.java index 32bb1bf..07575f8 100644 --- a/src/main/java/com/se/nsl/service/TestService.java +++ b/src/main/java/com/se/nsl/service/TestService.java @@ -87,7 +87,7 @@ copeTerrain(dto, layer); //copeBuilding(dto, layer); List<BuildingDepthVo> buildings = copeWater(dto, layer); - //copeFlow(dto, layer); + copeFlow(dto, layer); copeLayerJson(dto, layer); //copeRainFallJson(dto, layer); //copeBuildingDepthJson(dto, buildings); @@ -564,9 +564,8 @@ } public void copeFlow(ResultDto dto, LayerDto layer) { - List<String> files = getFiles(dto.getFlowPath(), ".tif"); - if (null == files || files.size() != layer.getWaters().getData().size()) return; - + List<String> files = layer.getWaters().getFiles(); + if (null == files || files.isEmpty()) return; for (int i = 0, c = files.size(); i < c; i++) { Dataset ds = null; try { @@ -603,17 +602,69 @@ ds = gdal.Open(tif, gdalconstConstants.GA_ReadOnly); if (null == ds || 0 == ds.getRasterCount()) return; + float[] depthBuffer = new float[width * height]; + float[] vxBuffer = new float[width * height]; + float[] vyBuffer = new float[width * height]; + + ds.GetRasterBand(1).ReadRaster(0, 0, width, height, depthBuffer); + ds.GetRasterBand(2).ReadRaster(0, 0, width, height, vxBuffer); + ds.GetRasterBand(3).ReadRaster(0, 0, width, height, vyBuffer); + + createFlowPng(depthBuffer, vxBuffer, vyBuffer, png, width, height); + } finally { + if (null != ds) ds.delete(); + } + } + + public void createFlowPng(float[] depthBuffer, float[] vxBuffer, float[] vyBuffer, String png, int width, int height) { + BufferedImage image = new BufferedImage(width, height, BufferedImage.TYPE_INT_ARGB); + for (int x = 0; x < width; x++) { + for (int y = 0; y < height; y++) { + int offset = x + y * width; + float depth = ComHelper.getFloatValue(depthBuffer[offset]); + float fx = ComHelper.getFloatValue(vxBuffer[offset]); + float fy = ComHelper.getFloatValue(vyBuffer[offset]); + if (Float.isNaN(fx) && Float.isNaN(fy) || (fx < MIN_VAL && fy < MIN_VAL)) continue; + + if (depth == 0) { + fx = 0f; + fy = 0f; + } else { + fx = Float.isNaN(fx) ? 0 : fx / depth; + fy = Float.isNaN(fy) ? 0 : fy / depth; + } + double dr = Math.sqrt(Math.pow(fx, 2) + Math.pow(fy, 2)); + + int r = (int) (dr / 4 * 255); + int g = (int) ((fx / dr * 0.5 + 0.5) * 255); + int b = (int) ((fy / dr * 0.5 + 0.5) * 255); + + Color color = new Color(ComHelper.getSafeValue(r), ComHelper.getSafeValue(g), ComHelper.getSafeValue(b), 127); + image.setRGB(x, y, color.getRGB()); + } + } + ComHelper.savePng(image, png); + } + +/* + public void vxyTif2Png(LayerDto layer, String tif, String png, int width, int height) { + Dataset ds = null; + try { + ds = gdal.Open(tif, gdalconstConstants.GA_ReadOnly); + if (null == ds || 0 == ds.getRasterCount()) return; + float[] vxBuffer = new float[width * height], vyBuffer = new float[width * height]; - ds.GetRasterBand(1).ReadRaster(0, 0, width, height, vxBuffer); - ds.GetRasterBand(2).ReadRaster(0, 0, width, height, vyBuffer); + ds.GetRasterBand(2).ReadRaster(0, 0, width, height, vxBuffer); + ds.GetRasterBand(3).ReadRaster(0, 0, width, height, vyBuffer); createFlowPng(vxBuffer, vyBuffer, png, width, height); } finally { if (null != ds) ds.delete(); } } +*/ - public void createFlowPng(float[] vxBuffer, float[] vyBuffer, String png, int width, int height) { + /*public void createFlowPng(float[] vxBuffer, float[] vyBuffer, String png, int width, int height) { BufferedImage image = new BufferedImage(width, height, BufferedImage.TYPE_INT_ARGB); for (int x = 0; x < width; x++) { for (int y = 0; y < height; y++) { @@ -635,7 +686,7 @@ } } ComHelper.savePng(image, png); - } + }*/ public void copeLayerJson(ResultDto dto, LayerDto layer) throws IOException { layer.getWaters().setFiles(null); diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml index e60c586..a65cbba 100644 --- a/src/main/resources/application-dev.yml +++ b/src/main/resources/application-dev.yml @@ -142,8 +142,8 @@ solverBat: D:\other\simu\uwsolver\run_solver.bat sww2tifBat: D:\other\simu\uwsolver\sww2tif.bat uwSolverBat: D:\other\simu\CudaUWSolver.Demo.NoVis.20250430\start.bat - zarr2tifBat: D:\other\simu\zarr2tif1.0\start.bat - #zarr2tifBat: D:\other\simu\zarr2tif-2.0-mkl\start.bat +# zarr2tifBat: D:\other\simu\zarr2tif1.0\start.bat + zarr2tifBat: D:\other\simu\zarr2tif-2.0-mkl\start.bat createRainfall: '"C:\Program Files\Python310\python.exe" D:\terrait\NslServer\data\CreatRainfall.py' rainfallTitle: Station Longitude Latitude Year Month Day Hour Minute Intensity rainfallSite: beijing -- Gitblit v1.9.3