From 3417cf014a65765e02696c1d121ce58b2b4a8aed Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期二, 08 四月 2025 15:55:36 +0800
Subject: [PATCH] 修改pom.xml

---
 src/main/java/com/se/simu/service/GedbService.java |   55 ++++++++++++++++++++++++++++++++++++++++---------------
 1 files changed, 40 insertions(+), 15 deletions(-)

diff --git a/src/main/java/com/se/simu/service/GedbService.java b/src/main/java/com/se/simu/service/GedbService.java
index c13f549..9a82084 100644
--- a/src/main/java/com/se/simu/service/GedbService.java
+++ b/src/main/java/com/se/simu/service/GedbService.java
@@ -19,6 +19,7 @@
 import org.gdal.gdal.WarpOptions;
 import org.gdal.gdal.gdal;
 import org.gdal.gdalconst.gdalconst;
+import org.gdal.ogr.Geometry;
 import org.gdal.osr.SpatialReference;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
@@ -34,12 +35,6 @@
 import java.util.*;
 import java.util.stream.Collectors;
 
-/**
- * GEDB鏈嶅姟绫�
- *
- * @author WWW
- * @date   2024-09-12
- */
 @Slf4j
 @Service
 @SuppressWarnings("ALL")
@@ -51,6 +46,8 @@
 
     @Resource
     RestTemplate restTemplate;
+
+    private final static String DB_KEY = "gedb_db";
 
     private final static String TOKEN_KEY = "gedb_token";
 
@@ -112,7 +109,7 @@
         return password;
     }
 
-    private String getPublicKey() {
+    public String getPublicKey() {
         //{"datetime":"2024-09-12 17:24:38","code":200,"data":"MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCtFwJCh2taVTEi05C8qT2oG7Y+rDmJhlO4zicpSeRtiro9LsytePeWI7BXM6sfDU0WeKun1izawcfgGkZgnoJuMBluAOKI1tL0uCrR+DreNLqMVtnXHwoWEIk/hGJedDWaf3q22aGDyEB5h9qCq0JklSShP1Ih4ppap4LmgxdTPQIDAQAB"}
         JSONObject obj = restTemplate.getForObject(config.getHost() + "account-service/security/publickey", JSONObject.class);
 
@@ -120,24 +117,32 @@
     }
 
     public GeDb connectGedb(String token, DataPo data) {
-        GeDb db = getSeDb(token);
+        GeDb db = getGeDb(token);
         db.setBbox(data.getBbox());
         data.setEpsg(db.getEpsg());
 
         return db;
     }
 
-    private GeDb getSeDb(String token) {
+    public GeDb getGeDb(String token) {
+        Object obj = CaffeineHelper.get(DB_KEY);
+        if (obj instanceof GeDb) {
+            return (GeDb) obj;
+        }
+
         Map<String, Object> map = new HashMap<>(1);
         map.put("token", token);
 
-        JSONObject obj = restTemplate.postForObject(config.getHost() + "geo-service/entitydb/list/canview", map, JSONObject.class);
-        JSONArray data = obj.getJSONArray("data");
+        JSONObject jsonObject = restTemplate.postForObject(config.getHost() + "geo-service/entitydb/list/canview", map, JSONObject.class);
+        JSONArray data = jsonObject.getJSONArray("data");
 
         List<GeDb> list = JSONUtil.toList(data, GeDb.class);
         if (CollectionUtils.isEmpty(list)) return null;
 
-        return list.stream().filter(db -> null != db.getName() && db.getName().contains(config.getDbName())).findFirst().orElse(null);
+        GeDb gedb = list.stream().filter(db -> null != db.getName() && db.getName().contains(config.getDbName())).findFirst().orElse(null);
+        if (null != gedb) CaffeineHelper.put(DB_KEY, gedb);
+
+        return gedb;
     }
 
     public List<GeLayer> getLayers(String token, GeDb db) {
@@ -166,7 +171,7 @@
         return layers;
     }
 
-    private String getQueryType(JSONObject jb) {
+    public static String getQueryType(JSONObject jb) {
         String qt = jb.getStr("pointlod");
         if (!StringHelper.isEmpty(qt)) {
             return "point";
@@ -244,7 +249,7 @@
 
         List<GeLayer> layers = getLayers(token, db);
         queryData(token, db, layers);
-        checkData(layers);
+        checkData(data, db, layers);
         createShps(basePath, layers);
         createZoneShp(basePath, data, db.getSpatialReference());
         if (data.getPid() > 0) {
@@ -252,9 +257,14 @@
         }
     }
 
-    private void checkData(List<GeLayer> layers) {
+    private void checkData(DataPo data, GeDb db, List<GeLayer> layers) {
         GeLayer point = getLayerByName(layers, config.getLayerNames().get(0));
         GeLayer line = getLayerByName(layers, config.getLayerNames().get(1));
+        GeLayer build = getLayerByName(layers, config.getLayerNames().get(2));
+
+        Geometry extent = ShpHelper.createPolygon(db.getSpatialReference(), data.getMinx(), data.getMiny(), data.getMaxx(), data.getMaxy());
+        checkSpatialRange(extent, point);
+        checkSpatialRange(extent, build);
 
         List<String> bsm = getValues(point, "bsm");
         List<String> bsm2 = new ArrayList<>(bsm);
@@ -280,6 +290,21 @@
         layers.add(juncLayer);
     }
 
+    private void checkSpatialRange(Geometry extent, GeLayer geLayer) {
+        int i = 0;
+        while (i < geLayer.getData().size()) {
+            JSONObject geom = geLayer.getData().getJSONObject(i).getJSONObject("geometry");
+            Geometry g = ShpHelper.createGeometry(geLayer, geom);
+            g.AssignSpatialReference(extent.GetSpatialReference());
+
+            if (!extent.Intersects(g)) {
+                geLayer.getData().remove(i);
+                continue;
+            }
+            i++;
+        }
+    }
+
     private GeLayer getLayerByName(List<GeLayer> layers, String name) {
         return layers.stream().filter(a -> a.getName().equals(name)).findFirst().orElse(null);
     }

--
Gitblit v1.9.3