From 07a68b8d93aa059968a9709f2c81e6625338032c Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期一, 21 十一月 2022 20:19:49 +0800
Subject: [PATCH] 12

---
 src/main/java/com/lf/server/service/all/BaseQueryService.java |   81 ++++++++++++++++++----------------------
 1 files changed, 37 insertions(+), 44 deletions(-)

diff --git a/src/main/java/com/lf/server/service/all/BaseQueryService.java b/src/main/java/com/lf/server/service/all/BaseQueryService.java
index bf20e0a..5f554f1 100644
--- a/src/main/java/com/lf/server/service/all/BaseQueryService.java
+++ b/src/main/java/com/lf/server/service/all/BaseQueryService.java
@@ -2,6 +2,8 @@
 
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.lf.server.entity.all.RedisCacheKey;
 import com.lf.server.entity.ctrl.IdNameEntity;
 import com.lf.server.entity.ctrl.TabEntity;
 import com.lf.server.entity.data.DictEntity;
@@ -13,11 +15,13 @@
 import com.lf.server.mapper.all.BasicMapper;
 import com.lf.server.mapper.all.GeomBaseMapper;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.cache.RedisCache;
 import org.springframework.stereotype.Service;
 
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.TimeUnit;
 
 /**
  * 鐖舵煡璇㈡湇鍔$被
@@ -28,48 +32,13 @@
     @Autowired
     BaseQueryMapper baseQueryMapper;
 
+    @Autowired
+    RedisService redisService;
+
     /**
      * 琛ㄥ悕Map
      */
     private static Map<String, String> tabMap = new HashMap<String, String>(3);
-
-    /**
-     * 鑾峰彇鐖禡apper
-     *
-     * @param name Mapper鍚�
-     * @return BaseMapper
-     */
-    public BasicMapper getBasicMapper(String name) {
-        if (StringHelper.isEmpty(name)) {
-            return null;
-        }
-
-        Object obj = ClassHelper.getBean(name.trim() + "Mapper");
-        if (!(obj instanceof BasicMapper)) {
-            return null;
-        }
-
-        return (BasicMapper) obj;
-    }
-
-    /**
-     * 鑾峰彇绌洪棿鐖禡apper
-     *
-     * @param name Mapper鍚�
-     * @return GeomBaseMapper
-     */
-    public GeomBaseMapper getGeoBaseMapper(String name) {
-        if (StringHelper.isEmpty(name)) {
-            return null;
-        }
-
-        Object obj = ClassHelper.getBean(name.trim() + "Mapper");
-        if (!(obj instanceof GeomBaseMapper)) {
-            return null;
-        }
-
-        return (GeomBaseMapper) obj;
-    }
 
     /**
      * 娣诲姞杩囨护鏉′欢
@@ -161,14 +130,38 @@
      * @param basicMapper 鐖禡apper
      * @param wrapper     QueryWrapper
      * @param wkt         WKT锛堣憲鍚嶆枃鏈級
-     * @param srid        绌洪棿寮曠敤鏍囪瘑绗�
      * @throws Exception 寮傚父
      */
-    public void addGeomWrapper(BasicMapper basicMapper, QueryWrapper wrapper, String wkt, Integer srid) throws Exception {
-        if (basicMapper instanceof GeomBaseMapper && !StringHelper.isEmpty(wkt) && srid != null) {
+    public void addGeomWrapper(BasicMapper basicMapper, QueryWrapper wrapper, String wkt) throws Exception {
+        if (basicMapper instanceof GeomBaseMapper && !StringHelper.isEmpty(wkt)) {
             wkt = AesHelper.decrypt(wkt);
-            wrapper.apply(String.format("ST_Intersects(geom, ST_PolygonFromText('%s', %d))", wkt, srid));
+
+            Integer srid = getSrid((GeomBaseMapper) basicMapper);
+            wrapper.apply(String.format("ST_Intersects(ST_PolygonFromText('%s', %d), geom)", wkt, srid));
         }
+    }
+
+    /**
+     * 鑾峰彇鍑犱綍瀵硅薄鐨勭┖闂村弬鑰�
+     *
+     * @param basicMapper 绌洪棿鍩虹Mapper
+     * @return SRID
+     */
+    private Integer getSrid(GeomBaseMapper basicMapper) {
+        String tab = getTabName(basicMapper);
+        String key = RedisCacheKey.sridKey(tab);
+
+        Object obj = redisService.get(key);
+        if (obj instanceof Integer) {
+            return (Integer) obj;
+        }
+
+        Integer srid = basicMapper.selectSrid(tab);
+        if (srid != null) {
+            redisService.put(key, srid, 5, TimeUnit.MINUTES);
+        }
+
+        return srid;
     }
 
     /**
@@ -177,7 +170,7 @@
      * @param basicMapper Mapper
      * @return 琛ㄥ悕
      */
-    public String getTabName(BasicMapper basicMapper) {
+    public static String getTabName(BasicMapper basicMapper) {
         String className = ClassHelper.getClassName(basicMapper);
         if (tabMap.containsKey(className)) {
             return tabMap.get(className);
@@ -192,7 +185,7 @@
      * @param className Mapper绫诲悕
      * @return 琛ㄥ悕
      */
-    private String getTabName(String className) {
+    private static String getTabName(String className) {
         Class clazz = ClassHelper.getEntityClass(className);
         if (clazz == null) {
             return null;

--
Gitblit v1.9.3