From e7c3276f2f5091fe8626af61ba5d7b41b2a1f2df Mon Sep 17 00:00:00 2001
From: suerprisePlus <15810472099@163.com>
Date: 星期一, 23 九月 2024 15:42:14 +0800
Subject: [PATCH] 添加历史记录接口,坐标转换,功能优化

---
 src/main/java/com/yb/service/XzService.java |  114 +++++++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 95 insertions(+), 19 deletions(-)

diff --git a/src/main/java/com/yb/service/XzService.java b/src/main/java/com/yb/service/XzService.java
index 622fbbc..d2b0313 100644
--- a/src/main/java/com/yb/service/XzService.java
+++ b/src/main/java/com/yb/service/XzService.java
@@ -11,9 +11,19 @@
 import org.springframework.stereotype.Service;
 import org.locationtech.jts.geom.*;
 import org.locationtech.jts.operation.buffer.BufferOp;
-
-
-import java.util.*;
+import org.geotools.geometry.jts.JTS;
+import org.geotools.referencing.CRS;
+import org.locationtech.jts.geom.Coordinate;
+import org.locationtech.jts.geom.GeometryFactory;
+import org.locationtech.jts.geom.Point;
+//import org.opengis.referencing.FactoryException;
+//import org.opengis.referencing.crs.CoordinateReferenceSystem;
+//import org.opengis.referencing.operation.MathTransform;
+import org.locationtech.proj4j.CRSFactory;
+import org.locationtech.proj4j.CoordinateReferenceSystem;
+import org.locationtech.proj4j.CoordinateTransform;
+import org.locationtech.proj4j.CoordinateTransformFactory;
+import org.locationtech.proj4j.ProjCoordinate;
 import java.util.HashMap;
 
 @Service
@@ -27,8 +37,23 @@
 
     // 鍏抽敭瀛楁煡璇�
     public String getQueryFiled(String place, String filed, String layerId, String dbId, String queryEntity) throws Exception {
-        String query = filed + " like '%" + place + "%'" + "";
+        String query = "";
+        String valSql = " like '%" + place + "%'";
         String key = getPublickey();
+        if (filed.indexOf(",") > -1) {
+            String[] fileds = filed.split(",");
+            for (int i = 0; i < fileds.length; i++) {
+                String name = fileds[i];
+                if (i > 0) {
+                    query += " or ";
+                }
+                query += name + valSql;
+            }
+        } else {
+            query += filed + valSql;
+        }
+        query += "";
+        System.out.println("rec getQueryFiled:" + query);
         String encrypt = RsaHelper.encrypt(key, query);
         HashMap formData = getHashMap(layerId, dbId, "1", "0", encrypt, null);
         String jsonString = entityHttpUtil.getPostMessage(queryEntity, formData);
@@ -44,8 +69,22 @@
 
     // 鍏抽敭瀛楁煡璇�
     public String getQueryEntity(String place, String filed, String layerId, String dbId, String queryEntity) throws Exception {
-        String query = filed + " like '%" + place + "%'" + "";
+        String query = "";
+        String valSql = " like '%" + place + "%'";
         String key = getPublickey();
+        if (filed.indexOf(",") > -1) {
+            String[] fileds = filed.split(",");
+            for (int i = 0; i < fileds.length; i++) {
+                String name = fileds[i];
+                if (i > 0) {
+                    query += " or ";
+                }
+                query += name + valSql;
+            }
+        } else {
+            query += filed + valSql;
+        }
+        query += "";
         String encrypt = RsaHelper.encrypt(key, query);
         HashMap formData = getHashMap(layerId, dbId, "1", "100", encrypt, null);
         formData.put("querytype", "entity");
@@ -54,7 +93,7 @@
         JSONObject jsonObject = JSON.parseObject(jsonString1);
         JSONObject dataObjject = jsonObject.getJSONObject("data");
         JSONArray dataArray = dataObjject.getJSONArray("items");
-        if(dataArray.size()<=0){
+        if (dataArray.size() <= 0) {
             return null;
         }
         return dataArray.getJSONObject(0).toString();
@@ -67,6 +106,7 @@
         String query = filed + " like '%" + type + "%'" + "";
         String encrypt = RsaHelper.encrypt(getPublickey(), query);
         HashMap formData = getHashMap(layerId, dbid, "1", "0", encrypt, wkt);
+        formData.put("querytype","entity");
         String jsonString = entityHttpUtil.getPostMessage(entity, formData);
         JSONObject jsonObject = JSON.parseObject(jsonString);
         JSONObject dataObj = jsonObject.getJSONObject("data");
@@ -123,14 +163,16 @@
             hashMap.put("where", where);
         }
         if (box != null && box != "") {
-            hashMap.put("box", box);
+            hashMap.put("bbox", box);
         }
 
         return hashMap;
     }
 
+
+
     //鐢熸垚WKT
-    public String getWKt(double lon, double lat, int radius) {
+    public String getWKt(double lon, double lat, int radius) throws Exception {
         // 鍒涘缓涓�涓潗鏍囩偣
         Coordinate coord = new Coordinate(lon, lat);
         // 鍒涘缓GeometryFactory瀹炰緥锛屽苟鎸囧畾鍧愭爣鍙傝�冪郴缁熶负WGS84
@@ -140,9 +182,9 @@
         // 鍒涘缓BufferOp瀹炰緥锛岀敤浜庣敓鎴愮紦鍐插尯
         BufferOp bufferOp = new BufferOp(point);
         int dis = 500;
-        if (radius != 0) {
-            dis = radius;
-        }
+//        if (radius != 0) {
+//            dis = radius;
+//        }
         // 璁剧疆缂撳啿鍖鸿窛绂讳负500绫�
         Geometry bufferedGeometry = bufferOp.getResultGeometry(dis / 111319.9);
         // 鍒涘缓WKTWriter瀹炰緥锛岀敤浜庡皢Geometry杞崲涓篧KT鏍煎紡
@@ -153,14 +195,48 @@
         // 杈撳嚭WKT
 //        System.out.println("WKT: " + wkt);
         Envelope envelope = bufferedGeometry.getEnvelopeInternal();
-        double[] wkt = new double[4];
-        wkt[0] = envelope.getMinX();
-        wkt[1] = envelope.getMinY();
-        wkt[2] = envelope.getMaxX();
-        wkt[3] = envelope.getMaxY();
-        String arrayAsString = Arrays.toString(wkt);
-        System.out.println("arrayAsString: " + arrayAsString);
-        return arrayAsString;
+
+//        double[] wkt = new double[4];
+//        wkt[0] = ;
+//        wkt[1] =;
+//        wkt[2] = envelope.getMaxX();
+//        wkt[3] = envelope.getMaxY();
+//
+//        wkt += envelope.getMinX();
+//        wkt += ","+envelope.getMinY();
+//        wkt += ","+envelope.getMaxX();
+//        wkt += ","+envelope.getMaxY();
+//                System.out.println("WKT: " + wkt);
+//        String arrayAsString = Arrays.toString(wkt);
+//        System.out.println("wkt: " + wkt);
+
+        CoordinateTransformFactory ctFactory = new CoordinateTransformFactory();
+
+        // 瀹氫箟婧愬潗鏍囩郴锛圵GS 84锛�
+        String srcCRS = "EPSG:4326";
+        // 瀹氫箟鐩爣鍧愭爣绯伙紙涓浗澶у湴鍧愭爣绯伙級
+        String destCRS = "EPSG:4550";
+
+        // 鍒涘缓鍧愭爣鍙傝�冪郴缁�
+        CRSFactory crsFactory = new CRSFactory();
+        CoordinateReferenceSystem src = crsFactory.createFromName(srcCRS);
+        CoordinateReferenceSystem dest = crsFactory.createFromName(destCRS);
+
+        // 鍒涘缓鍧愭爣杞崲鍣�
+        CoordinateTransform transform = ctFactory.createTransform(src, dest);
+
+        // 瀹氫箟涓�涓簮鍧愭爣鐐癸紙缁忓害锛岀含搴︼級
+        ProjCoordinate srcgetMin = new ProjCoordinate( envelope.getMinX(),  envelope.getMinY()); // 渚嬪锛氬寳浜殑缁忕含搴�
+        ProjCoordinate srcgetMax = new ProjCoordinate( envelope.getMaxX(),  envelope.getMaxY()); // 渚嬪锛氬寳浜殑缁忕含搴�
+        // 鎵ц杞崲
+        ProjCoordinate destgetMin = new ProjCoordinate();
+        ProjCoordinate destgetMax = new ProjCoordinate();
+        transform.transform(srcgetMin, destgetMin);
+        transform.transform(srcgetMax, destgetMax);
+        String wkt =destgetMin.x+","+destgetMin.y+","+destgetMax.x+","+destgetMax.y;
+        System.out.println("杞崲鍚庣殑鍧愭爣锛歑 = " +wkt);
+        return wkt;
+
     }
 
 

--
Gitblit v1.9.3