| | |
| | | import com.moon.server.entity.data.PublishEntity; |
| | | import com.moon.server.helper.GeoHelper; |
| | | import com.moon.server.helper.PathHelper; |
| | | import com.moon.server.helper.WebHelper; |
| | | import com.moon.server.service.all.WebSocketService; |
| | | import org.apache.commons.logging.Log; |
| | | import org.apache.commons.logging.LogFactory; |
| | |
| | | map.put("analysisForPost", entity); |
| | | |
| | | String json = JSONObject.toJSONString(map); |
| | | // System.out.println(json) |
| | | WebSocketService.broadCastInfo(json); |
| | | } |
| | | |
| | |
| | | private void openRaster(AnalysisResultEntity entity, String filePath, Geometry geo, int size) { |
| | | Dataset ds = null; |
| | | try { |
| | | // filePath = "D:\\Moon\\data\\DOM\\test.tif" |
| | | ds = gdal.Open(filePath); |
| | | if (null == ds) { |
| | | throw new Exception("打开栅格数据失败"); |
| | |
| | | } |
| | | |
| | | /** |
| | | * 分析点 |
| | | */ |
| | | public void analysisPoint2(AnalysisResultEntity entity, Dataset ds, Geometry geo, int size) { |
| | | double x = geo.GetX(), y = geo.GetY(); |
| | | double[] transform = ds.GetGeoTransform(); |
| | | // double rotationX = transform[2]; double rotationY = transform[4] |
| | | double minX = transform[0], pixelWidth = transform[1], maxY = transform[3], pixelHeight = transform[5]; |
| | | |
| | | int bandCount = ds.getRasterCount(); |
| | | int xPixel = (int) Math.floor((x - minX) / pixelWidth); |
| | | int yPixel = (int) Math.floor((maxY - y) / Math.abs(pixelHeight)); |
| | | |
| | | for (int i = 1; i <= bandCount; i++) { |
| | | double[] pixelValues = new double[size * size]; |
| | | Band band = ds.GetRasterBand(i); |
| | | band.ReadRaster(xPixel, yPixel, size, size, pixelValues); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 分析线 |
| | | */ |
| | | public void analysisPolyline(AnalysisResultEntity entity, Dataset ds, Geometry geo, int size) { |
| | | double[] transform = ds.GetGeoTransform(); |
| | | // double rotationX = transform[2]; double rotationY = transform[4] |
| | | int xSize = ds.getRasterXSize(), ySize = ds.getRasterYSize(); |
| | | double minX = transform[0], pixelWidth = transform[1], maxY = transform[3], pixelHeight = transform[5]; |
| | | |
| | | double len = 0; |
| | |
| | | |
| | | int xPixel = (int) Math.floor((xy[0] - minX) / pixelWidth); |
| | | int yPixel = (int) Math.floor((maxY - xy[1]) / Math.abs(pixelHeight)); |
| | | if (xPixel < 1 || xPixel > xSize || yPixel < 1 || yPixel > ySize) { |
| | | continue; |
| | | } |
| | | |
| | | List<Double> vals = new ArrayList<>(); |
| | | for (int j = 1; j <= bandCount; j++) { |
| | | double[] pixelValues = new double[1]; |
| | | ds.GetRasterBand(j).ReadRaster(xPixel, yPixel, 1, 1, pixelValues); |
| | | vals.add(pixelValues[0]); |
| | | } |
| | | entity.addPoint(xy[0], xy[1], len, vals); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 分析线 |
| | | */ |
| | | public void analysisPolyline2(AnalysisResultEntity entity, Dataset ds, Geometry geo, int size) { |
| | | double[] transform = ds.GetGeoTransform(); |
| | | // double rotationX = transform[2]; double rotationY = transform[4] |
| | | double minX = transform[0], pixelWidth = transform[1], maxY = transform[3], pixelHeight = Math.abs(transform[5]); |
| | | |
| | | double buffer = Math.max(pixelWidth, pixelHeight) * size; |
| | | double[] env = new double[4]; |
| | | geo = geo.Buffer(buffer); |
| | | geo.GetEnvelope(env); |
| | | |
| | | int xMinPixel = (int) Math.floor((env[0] - minX) / pixelWidth); |
| | | int yMinPixel = (int) Math.floor((maxY - env[3]) / pixelHeight); |
| | | int xMaxPixel = (int) Math.floor((env[1] - minX) / pixelWidth); |
| | | int yMaxPixel = (int) Math.floor((maxY - env[2]) / pixelHeight); |
| | | |
| | | int bandCount = ds.getRasterCount(); |
| | | int xMin = Math.min(xMinPixel, xMaxPixel); |
| | | int xMax = Math.max(xMinPixel, xMaxPixel); |
| | | int yMin = Math.min(yMinPixel, yMaxPixel); |
| | | int yMax = Math.max(yMinPixel, yMaxPixel); |
| | | |
| | | List<Double> list = new ArrayList<>(); |
| | | for (int y = yMin; y <= yMax; y++) { |
| | | for (int x = xMin; x <= xMax; x++) { |
| | | Geometry point = new Geometry(ogr.wkbPoint); |
| | | point.AddPoint(minX + pixelWidth * x, maxY - pixelHeight * y); |
| | | if (geo.Intersects(point)) { |
| | | for (int i = 1; i <= bandCount; i++) { |
| | | double[] values = new double[1]; |
| | | ds.GetRasterBand(i).ReadRaster(x, y, 1, 1, values); |
| | | list.add(values[0]); |
| | | } |
| | | if (!Double.isNaN(pixelValues[0])) { |
| | | vals.add(WebHelper.round(pixelValues[0], 3)); |
| | | } |
| | | } |
| | | if (vals.size() > 0) { |
| | | entity.addPoint(xy[0], xy[1], len, vals); |
| | | } |
| | | } |
| | | // processResult(list, entity) |
| | | } |
| | | |
| | | /** |
| | |
| | | */ |
| | | public void analysisPolygon(AnalysisResultEntity entity, Dataset ds, Geometry geo) { |
| | | double[] transform = ds.GetGeoTransform(); |
| | | // double rotationX = transform[2]; double rotationY = transform[4] |
| | | double minX = transform[0], pixelWidth = transform[1], maxY = transform[3], pixelHeight = Math.abs(transform[5]); |
| | | int xSize = ds.getRasterXSize(), ySize = ds.getRasterYSize(); |
| | | double minX = transform[0], pixelWidth = transform[1], maxY = transform[3], pixelHeight = Math.abs(transform[5]), rotationX = transform[2], rotationY = transform[4]; |
| | | double[] env = new double[4]; |
| | | geo.GetEnvelope(env); |
| | | entity.addPoint(geo.Centroid().GetX(), geo.Centroid().GetY(), 0, null); |
| | | |
| | | int xMinPixel = (int) Math.floor((env[0] - minX) / pixelWidth); |
| | | int yMinPixel = (int) Math.floor((maxY - env[3]) / pixelHeight); |
| | | int xMaxPixel = (int) Math.floor((env[1] - minX) / pixelWidth); |
| | | int yMaxPixel = (int) Math.floor((maxY - env[2]) / pixelHeight); |
| | | int xMinPixel = Math.max((int) Math.floor((env[0] - minX) / pixelWidth), 1); |
| | | int yMinPixel = Math.max((int) Math.floor((maxY - env[3]) / pixelHeight), 1); |
| | | int xMaxPixel = Math.min((int) Math.floor((env[1] - minX) / pixelWidth), xSize); |
| | | int yMaxPixel = Math.min((int) Math.floor((maxY - env[2]) / pixelHeight), ySize); |
| | | if (xMaxPixel < 1 || yMaxPixel < 1 || xMaxPixel - xMinPixel < 0 || yMaxPixel - yMinPixel < 0) { |
| | | setError(entity, "查询范围无效"); |
| | | return; |
| | | } |
| | | |
| | | int bandCount = ds.getRasterCount(); |
| | | int width = Math.abs(xMaxPixel - xMinPixel); |
| | | int height = Math.abs(yMaxPixel - yMinPixel); |
| | | |
| | | int width = xMaxPixel - xMinPixel; |
| | | int height = yMaxPixel - yMinPixel; |
| | | if (width * height > StaticData.I64 * StaticData.I64) { |
| | | readRasterForBlocks(entity, ds, bandCount, xMinPixel, yMinPixel, width, height); |
| | | return; |
| | |
| | | * 按照块读取栅格数据 |
| | | */ |
| | | private void readRasterForBlocks(AnalysisResultEntity entity, Dataset ds, int bandCount, int xMinPixel, int yMinPixel, int width, int height) { |
| | | List<Integer> xList = getSamples(xMinPixel, width); |
| | | List<Integer> yList = getSamples(yMinPixel, height); |
| | | List<Integer> xList = getSamples(xMinPixel, width - 1); |
| | | List<Integer> yList = getSamples(yMinPixel, height - 1); |
| | | |
| | | double[] pixelValues = new double[1]; |
| | | for (int i = 1; i <= bandCount; i++) { |
| | |
| | | for (Integer x : xList) { |
| | | for (Integer y : yList) { |
| | | ds.GetRasterBand(i).ReadRaster(x, y, 1, 1, pixelValues); |
| | | list.add(pixelValues[0]); |
| | | if (!Double.isNaN(pixelValues[0])) { |
| | | list.add(pixelValues[0]); |
| | | } |
| | | } |
| | | } |
| | | setBandVals(entity, list); |
| | |
| | | |
| | | List<Double> list = new ArrayList<>(); |
| | | for (double val : pixelValues) { |
| | | list.add(val); |
| | | if (!Double.isNaN(val)) { |
| | | list.add(val); |
| | | } |
| | | } |
| | | setBandVals(entity, list); |
| | | } |
| | |
| | | * 设置Band值 |
| | | */ |
| | | private void setBandVals(AnalysisResultEntity entity, List<Double> list) { |
| | | if (null == list || list.isEmpty()) { |
| | | return; |
| | | } |
| | | |
| | | double min = Collections.min(list); |
| | | double max = Collections.max(list); |
| | | double avg = list.stream().mapToDouble(Double::valueOf).average().getAsDouble(); |
| | |
| | | d += distance; |
| | | } |
| | | } |
| | | |
| | | list.add(geo.GetPoint(c)); |
| | | |
| | | return list; |
| | | } |
| | | |
| | | /** |
| | | * 分析点 2 |
| | | */ |
| | | public void analysisPoint2(AnalysisResultEntity entity, Dataset ds, Geometry geo, int size) { |
| | | double x = geo.GetX(), y = geo.GetY(); |
| | | double[] transform = ds.GetGeoTransform(); |
| | | // double rotationX = transform[2]; double rotationY = transform[4] |
| | | double minX = transform[0], pixelWidth = transform[1], maxY = transform[3], pixelHeight = transform[5]; |
| | | |
| | | int bandCount = ds.getRasterCount(); |
| | | int xPixel = (int) Math.floor((x - minX) / pixelWidth); |
| | | int yPixel = (int) Math.floor((maxY - y) / Math.abs(pixelHeight)); |
| | | |
| | | for (int i = 1; i <= bandCount; i++) { |
| | | double[] pixelValues = new double[size * size]; |
| | | Band band = ds.GetRasterBand(i); |
| | | band.ReadRaster(xPixel, yPixel, size, size, pixelValues); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 分析线 2 |
| | | */ |
| | | public void analysisPolyline2(AnalysisResultEntity entity, Dataset ds, Geometry geo, int size) { |
| | | double[] transform = ds.GetGeoTransform(); |
| | | // double rotationX = transform[2]; double rotationY = transform[4] |
| | | double minX = transform[0], pixelWidth = transform[1], maxY = transform[3], pixelHeight = Math.abs(transform[5]); |
| | | |
| | | double buffer = Math.max(pixelWidth, pixelHeight) * size; |
| | | double[] env = new double[4]; |
| | | geo = geo.Buffer(buffer); |
| | | geo.GetEnvelope(env); |
| | | |
| | | int xMinPixel = (int) Math.floor((env[0] - minX) / pixelWidth); |
| | | int yMinPixel = (int) Math.floor((maxY - env[3]) / pixelHeight); |
| | | int xMaxPixel = (int) Math.floor((env[1] - minX) / pixelWidth); |
| | | int yMaxPixel = (int) Math.floor((maxY - env[2]) / pixelHeight); |
| | | |
| | | int bandCount = ds.getRasterCount(); |
| | | int xMin = Math.min(xMinPixel, xMaxPixel); |
| | | int xMax = Math.max(xMinPixel, xMaxPixel); |
| | | int yMin = Math.min(yMinPixel, yMaxPixel); |
| | | int yMax = Math.max(yMinPixel, yMaxPixel); |
| | | |
| | | List<Double> list = new ArrayList<>(); |
| | | for (int y = yMin; y <= yMax; y++) { |
| | | for (int x = xMin; x <= xMax; x++) { |
| | | Geometry point = new Geometry(ogr.wkbPoint); |
| | | point.AddPoint(minX + pixelWidth * x, maxY - pixelHeight * y); |
| | | if (geo.Intersects(point)) { |
| | | for (int i = 1; i <= bandCount; i++) { |
| | | double[] values = new double[1]; |
| | | ds.GetRasterBand(i).ReadRaster(x, y, 1, 1, values); |
| | | list.add(values[0]); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | // processResult(list, entity) |
| | | } |
| | | |
| | | private void processClippedDataByLine(String imagePath, String geometryString) { |
| | | // 注册GDAL驱动 |
| | | gdal.AllRegister(); |