选址逻辑修改

onemap-common/onemap-common-datasource/src/main/java/com/onemap/common/datasource/annotation/Master.java

@@ -5,18 +5,18 @@ import java.lang.annotation.ElementType;
 import java.lang.annotation.Retention;
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
+
 import com.baomidou.dynamic.datasource.annotation.DS;
 
 /**
  * 主库数据源
- * 
+ *
  * @author onemap
  */
-@Target({ ElementType.TYPE, ElementType.METHOD })
+@Target({ElementType.TYPE, ElementType.METHOD})
 @Retention(RetentionPolicy.RUNTIME)
 @Documented
 @DS("master")
-public @interface Master
-{
+public @interface Master {
 
 }

onemap-common/onemap-common-datasource/src/main/java/com/onemap/common/datasource/annotation/Slave.java

@@ -5,18 +5,18 @@ import java.lang.annotation.ElementType;
 import java.lang.annotation.Retention;
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
+
 import com.baomidou.dynamic.datasource.annotation.DS;
 
 /**
  * 从库数据源
- * 
+ *
  * @author onemap
  */
-@Target({ ElementType.TYPE, ElementType.METHOD })
+@Target({ElementType.TYPE, ElementType.METHOD})
 @Retention(RetentionPolicy.RUNTIME)
 @Documented
 @DS("slave")
-public @interface Slave
-{
+public @interface Slave {
 
 }

onemap-modules/onemap-analyse/pom.xml

@@ -137,7 +137,7 @@
             <systemPath>${project.basedir}/lib/jts-1.13.jar</systemPath>
         </dependency>
 
-        <!--supermap-->
+        <!--        supermap-->
 <!--        <dependency>-->
 <!--            <groupId>com.supermap</groupId>-->
 <!--            <artifactId>analyst.spatialanalyst</artifactId>-->
@@ -160,6 +160,7 @@
 <!--            <scope>system</scope>-->
 <!--            <systemPath>${basedir}/lib/com.supermap.data.conversion.jar</systemPath>-->
 <!--        </dependency>-->
+
         <!--    简繁体转换    -->
         <dependency>
             <groupId>com.ibm.icu</groupId>

onemap-modules/onemap-analyse/src/main/java/com/onemap/analyse/controller/FzssController.java

@@ -1,5 +1,6 @@
 package com.onemap.analyse.controller;
 
+import com.onemap.analyse.domain.calculation.FzxzCalc;
 import com.onemap.analyse.service.IFzssService;
 import com.onemap.analyse.domain.HgxfxEntityDTO;
 import com.onemap.common.core.web.controller.BaseController;
@@ -38,7 +39,9 @@ public class FzssController extends BaseController {
      */
     @PostMapping("/AddFzxz")
     public RequestResult AddFzxz(@RequestBody Map params) {
-        RequestResult res = fzssService.AddFzxz(params);
+        FzxzCalc fzxzCalc = fzssService.GetFzxzParam(params);
+        fzssService.saveScheduleParam(fzxzCalc);
+        RequestResult res = fzssService.startSchedule(fzxzCalc);
         return res;
     }
 

onemap-modules/onemap-analyse/src/main/java/com/onemap/analyse/domain/calculation/FzxzCalc.java

@@ -0,0 +1,12 @@
+package com.onemap.analyse.domain.calculation;
+
+import com.onemap.analyse.domain.FzxzDTO;
+import com.onemap.analyse.domain.FzxzXzyzDTO;
+import lombok.Data;
+
+import java.util.List;
+@Data
+public class FzxzCalc {
+    FzxzDTO fzxzDTO;
+    List<FzxzXzyzDTO> xzyxList;
+}

onemap-modules/onemap-analyse/src/main/java/com/onemap/analyse/domain/query/GhdkaFilter.java

@@ -0,0 +1,12 @@
+package com.onemap.analyse.domain.query;
+
+import lombok.Data;
+
+/**
+ * 规划选址地块筛选条件
+ */
+@Data
+public class GhdkaFilter {
+    // 筛选区域，wkt格式
+    String geom;
+}

onemap-modules/onemap-analyse/src/main/java/com/onemap/analyse/domain/vector/GhdkaDTO.java

@@ -0,0 +1,10 @@
+package com.onemap.analyse.domain.vector;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+
+/**
+ * 规划地块
+ */
+@TableName("GHDKA")
+public class GhdkaDTO {
+}

onemap-modules/onemap-analyse/src/main/java/com/onemap/analyse/mapper/vector/GhdkaMapper.java

@@ -0,0 +1,10 @@
+package com.onemap.analyse.mapper.vector;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.onemap.analyse.domain.query.GhdkaFilter;
+import com.onemap.analyse.domain.vector.GhdkaDTO;
+
+import java.util.List;
+public interface GhdkaMapper extends BaseMapper<GhdkaDTO> {
+    List<Integer> filter(GhdkaFilter ghdkaFilter);
+}

onemap-modules/onemap-analyse/src/main/java/com/onemap/analyse/service/IFzssService.java

@@ -1,6 +1,7 @@
 package com.onemap.analyse.service;
 
 import com.onemap.analyse.domain.HgxfxEntityDTO;
+import com.onemap.analyse.domain.calculation.FzxzCalc;
 import com.onemap.common.core.web.domain.RequestResult;
 
 import java.io.IOException;
@@ -10,7 +11,10 @@ import java.util.Map;
 public interface IFzssService {
     RequestResult AddHgxfx(HgxfxEntityDTO hgxfxEntityDTO) throws IOException;
 
-    RequestResult AddFzxz(Map params);
+    FzxzCalc GetFzxzParam(Map params);
+
+    void saveScheduleParam(FzxzCalc fzxzCalc);
+    RequestResult startSchedule(FzxzCalc fzxzCalc);
 
     RequestResult GetXzjg(String bsm);
 

onemap-modules/onemap-analyse/src/main/java/com/onemap/analyse/service/impl/FzssServiceImpl.java

@@ -2,13 +2,17 @@ package com.onemap.analyse.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.onemap.analyse.domain.*;
+import com.onemap.analyse.domain.calculation.FzxzCalc;
+import com.onemap.analyse.domain.query.GhdkaFilter;
 import com.onemap.analyse.mapper.*;
+import com.onemap.analyse.mapper.vector.GhdkaMapper;
 import com.onemap.analyse.service.IFzssService;
-import com.onemap.analyse.task.FzxzPlanSchedule;
 import com.onemap.analyse.task.FzxzSchedule;
 import com.onemap.analyse.utils.DozerUtils;
 import com.onemap.common.core.utils.StringUtils;
 import com.onemap.common.core.web.domain.RequestResult;
+import com.onemap.common.datasource.annotation.Master;
+import com.onemap.common.datasource.annotation.Slave;
 import com.onemap.common.security.utils.SecurityUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -28,11 +32,11 @@ public class FzssServiceImpl implements IFzssService {
     private FxfwDictDTO fxfwDictDTO = new FxfwDictDTO();
     @Value("${Hgxfx.temp}")
     private String temp;
-    //任务状态标识码
+    // 任务状态标识码
     private RwztDTO Rwzt = new RwztDTO();
-    //shp入库的方法标识码
+    // shp入库的方法标识码
     private String shpPyFun = "shp2sde";
-    //esrijson入库的方法标识码
+    // esrijson入库的方法标识码
     private String esrijsonPyFun = "esriJson2sde";
     @Autowired
     private HgxfxScxMapper hgxfxScxMapper;
@@ -51,6 +55,10 @@ public class FzssServiceImpl implements IFzssService {
     @Autowired
     FzxzSchedule fzxzSchedule;
 
+    //**后写逻辑**//
+    @Autowired
+    GhdkaMapper ghdkaMapper;
+
     @Transactional(rollbackFor = Exception.class)
     @Override
     public RequestResult AddHgxfx(HgxfxEntityDTO hgxfxEntityDTO) throws IOException {
@@ -61,17 +69,17 @@ public class FzssServiceImpl implements IFzssService {
         requestHgxfxDTO.setCjsj(new Date());
         requestHgxfxDTO.setBsm(StringUtils.getUUID());
         requestHgxfxDTO.setCjyh(SecurityUtils.getUsername());
-        //将分析范围矢量数据插入到KJGH.T_FZSS_FXRW_GIS
+        // 将分析范围矢量数据插入到KJGH.T_FZSS_FXRW_GIS
         RequestResult info = vector2Sde(hgxfxEntityDTO, requestHgxfxDTO);
         if (info != null) {
             return info;
         }
-        //查询审查项 默认把控制线级别等于0的也添加进去
+        // 查询审查项 默认把控制线级别等于0的也添加进去
         QueryWrapper<HgxfxScxDTO> wrapper = new QueryWrapper<HgxfxScxDTO>();
         wrapper.eq("kzxjb", 0).or().in("bsm", hgxfxEntityDTO.getScxs().split(",")).orderByAsc("xssx");
         List<HgxfxScxDTO> res = hgxfxScxMapper.selectList(wrapper);
         if (res.size() > 0) {
-            //插入审查项列表
+            // 插入审查项列表
             for (HgxfxScxDTO cur : res) {
                 HgxfxHgscxDTO scx = new HgxfxHgscxDTO();
                 scx.setBsm(StringUtils.getUUID());
@@ -81,73 +89,71 @@ public class FzssServiceImpl implements IFzssService {
                 hgxfxHgscxMapper.insert(scx);
             }
         }
-        //插入合规性检查表 并返回任务标识码
+        // 插入合规性检查表 并返回任务标识码
         hgxfxMapper.insert(requestHgxfxDTO);
         return RequestResult.success("保存成功！", requestHgxfxDTO.getBsm());
     }
 
-    /**
-     * 新建辅助选址任务
-     *
-     * @param params
-     * @return
-     * @throws IOException
-     */
-    @Transactional(rollbackFor = Exception.class)
     @Override
-    public RequestResult AddFzxz(Map params) {
-        try {
-            //辅助选址
-            FzxzDTO fzxzDTO = DozerUtils.map(params, FzxzDTO.class);
-            fzxzDTO.setBsm(StringUtils.getUUID());
-            fzxzDTO.setCjsj(new Date());
-            fzxzDTO.setYdxz_bsm(fzxzDTO.getYdxz_bsm().replaceAll("\\[", "").replaceAll("\\]", ""));
-            ////将分析范围矢量数据插入到KJGH.T_FZSS_FXRW_GIS
-            //RequestResult info = fzxzvector2Sde(fzxzDTO, null);
-            //if (info != null) {
-            //    return info;
-            //}
+    public FzxzCalc GetFzxzParam(Map params) {
+        FzxzCalc fzxzCalc = new FzxzCalc();
+        // 辅助选址
+        FzxzDTO fzxzDTO = DozerUtils.map(params, FzxzDTO.class);
+        fzxzDTO.setBsm(StringUtils.getUUID());
+        fzxzDTO.setCjsj(new Date());
+        fzxzDTO.setYdxz_bsm(fzxzDTO.getYdxz_bsm().replaceAll("\\[", "").replaceAll("\\]", ""));
 
-            //选址因子
-            ArrayList xzyx = (ArrayList) params.get("yxyz");
-            List<FzxzXzyzDTO> xzyxList = new ArrayList<>();
-            for (int i = 0; i < xzyx.size(); i++) {
-                FzxzXzyzDTO dto = DozerUtils.map(xzyx.get(i), FzxzXzyzDTO.class);
-                dto.setBsm(StringUtils.getUUID());
-                dto.setRwbsm(fzxzDTO.getBsm());
-                fzxzXzyzMapper.insert(dto);
+        // 选址因子
+        ArrayList xzyx = (ArrayList) params.get("yxyz");
+        List<FzxzXzyzDTO> xzyxList = new ArrayList<>();
+        for (int i = 0; i < xzyx.size(); i++) {
+            FzxzXzyzDTO dto = DozerUtils.map(xzyx.get(i), FzxzXzyzDTO.class);
+            dto.setBsm(StringUtils.getUUID());
+            dto.setRwbsm(fzxzDTO.getBsm());
+            xzyxList.add(dto);
+        }
 
-                xzyxList.add(dto);
-            }
+        // 存储规划任务
+        fzxzDTO.setRwzt(Rwzt.getCreate());
+        fzxzDTO.setCjyh(SecurityUtils.getUsername());
 
-            //存储规划任务
-            String xzfw = fzxzDTO.getXzfw();
-            //TODO：需要判断
-            //if (fzxzDTO.getFwlx() == 1) {
-            // 绘制不需要存储空间数据
-            fzxzDTO.setXzfw("");
-            //}
-            fzxzDTO.setRwzt(Rwzt.getCreate());
-            fzxzDTO.setCjyh(SecurityUtils.getUsername());
-            fzxzMapper.insert(fzxzDTO);
+        fzxzCalc.setFzxzDTO(fzxzDTO);
+        fzxzCalc.setXzyxList(xzyxList);
+        return fzxzCalc;
+    }
 
-            //开始选址规划
-            fzxzDTO.setXzfw(xzfw);
-            FzxzPlanSchedule.startPlan(fzxzDTO, xzyxList);
+    @Override
+    @Master
+    public void saveScheduleParam(FzxzCalc fzxzCalc) {
+        for (FzxzXzyzDTO dto : fzxzCalc.getXzyxList()) {
+            fzxzXzyzMapper.insert(dto);
+        }
+        fzxzMapper.insert(fzxzCalc.getFzxzDTO());
+    }
 
-            return RequestResult.success("保存成功！", fzxzDTO.getBsm());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return RequestResult.success("保存失败！", 0);
+    @Override
+    @Slave
+    public RequestResult startSchedule(FzxzCalc fzxzCalc) {
+        FzxzDTO fzxzDTO = fzxzCalc.getFzxzDTO();
+        GhdkaFilter ghdkaFilter = new GhdkaFilter();
+        if (fzxzDTO.getFwlx() == 1) {
+            // 绘制
+            String geoWkt = fzxzDTO.getXzfw();
+            ghdkaFilter.setGeom(geoWkt);
+        } else if (fzxzDTO.getFwlx() == 2) {
+            // shp文件
         }
+        List<Integer> ids = ghdkaMapper.filter(ghdkaFilter);
+        return RequestResult.success(ids);
     }
 
+
     @Override
     public RequestResult GetXzjg(String bsm) {
         if (StringUtils.isEmpty(bsm)) {
             return RequestResult.error("标识码参数未传递！", null);
         }
-        //查询辅助选址基本信息
+        // 查询辅助选址基本信息
         QueryWrapper<FzxzDTO> fzxzwrapper = new QueryWrapper<FzxzDTO>();
         fzxzwrapper.eq("bsm", bsm);
         FzxzDTO fzxzinfo = fzxzMapper.selectOne(fzxzwrapper);
@@ -155,13 +161,13 @@ public class FzssServiceImpl implements IFzssService {
             return RequestResult.error("辅助选址记录查为未空！", null);
         }
         FzxzResultDTO result = DozerUtils.map(fzxzinfo, FzxzResultDTO.class);
-        //查询分析结果图斑信息
+        // 查询分析结果图斑信息
         QueryWrapper<FzxzJgGisDTO> giswrapper = new QueryWrapper<FzxzJgGisDTO>();
         giswrapper.eq("rwbsm", result.getBsm());
         List<FzxzJgGisDTO> gisinfo = fzxzJgGISMapper.selectList(giswrapper);
         if (gisinfo.size() > 0) {
             for (FzxzJgGisDTO gisDto : gisinfo) {
-                //查询分析因子结果信息
+                // 查询分析因子结果信息
                 QueryWrapper<FzxzJgyzDTO> jgyzwrapper = new QueryWrapper<FzxzJgyzDTO>();
                 jgyzwrapper.eq("jbbsm", gisDto.getBsm()).eq("yztj", "F");
                 List<FzxzJgyzDTO> jgyzinfo = fzxzJgyzMapper.selectList(jgyzwrapper);

onemap-modules/onemap-analyse/src/main/java/com/onemap/analyse/task/FzxzPlanSchedule.java

@@ -3,8 +3,6 @@ package com.onemap.analyse.task;
 import com.onemap.analyse.domain.FzxzDTO;
 import com.onemap.analyse.domain.FzxzXzyzDTO;
 import com.onemap.common.core.web.domain.StatusMsg;
-// import com.supermap.analyst.spatialanalyst.OverlayAnalyst;
-// import com.supermap.analyst.spatialanalyst.OverlayAnalystParameter;
 // import com.supermap.data.*;
 // import com.supermap.data.conversion.DataImport;
 // import com.supermap.data.conversion.ImportMode;
@@ -20,62 +18,65 @@ import java.util.List;
  */
 @Component
 public class FzxzPlanSchedule {
-
+    private static String dbUrl = "192.168.100.30:5432";
+    private static String dbName = "real";
+    private static String dbUser = "postgres";
+    private static String dbPwd = "postgis";
 
     /**
      * @param fzxzDTO  选址任务
      * @param xzyzList 选址因子
      */
-    public static void startPlan(FzxzDTO fzxzDTO, List<FzxzXzyzDTO> xzyzList) {
-        // StatusMsg statusMsg = new StatusMsg();
-        // //初始化失败返回结果
-        // if (fzxzDTO.getFwlx() == 1) {
-        //     //statusMsg = setWorkspace();
-        //     // 绘制
-        //     String geoWkt = fzxzDTO.getXzfw();
-        //     Geometry geometry = Toolkit.WKTToGeometry(geoWkt);
-        //     statusMsg = siteAnalysis(geometry, xzyzList);
-        //     //拿到图层
-        // } else if (fzxzDTO.getFwlx() == 2) {
-        //     // shp文件
-        //     statusMsg = siteAnalysis(fzxzDTO.getXzfw());
-        // }
-    }
-
-    //private static StatusMsg setWorkspace() {
-    //    StatusMsg statusMsg = new StatusMsg();
-    //
-    //    DatasourceConnectionInfo info = new DatasourceConnectionInfo();
-    //    info.setEngineType(EngineType.PGGIS);
-    //    //TODO:配置信息放到配置文件中
-    //    info.setServer("192.168.60.202:5432");
-    //    info.setDatabase("real3d");
-    //    info.setUser("postgres");
-    //    info.setPassword("postgres");
-    //
-    //    Workspace mWorkspace = new Workspace();
-    //    Datasource datasource = mWorkspace.getDatasources().open(info);
-    //
-    //    if (datasource == null) {
-    //        statusMsg.setMsg("创建数据源失败");
-    //        statusMsg.setB(false);
-    //        return statusMsg;
-    //    }
-    //    return statusMsg;
-    //}
-
-    // //TODO:这里暂时导入不成功
+    // public static void startPlan(FzxzDTO fzxzDTO, List<FzxzXzyzDTO> xzyzList) {
+    //     StatusMsg statusMsg = new StatusMsg();
+    //     // setWorkspace();
+    //     // 初始化失败返回结果
+    //     if (fzxzDTO.getFwlx() == 1) {
+    //           // 绘制
+    //         String geoWkt = fzxzDTO.getXzfw();
+    //         Geometry geometry = Toolkit.WKTToGeometry(geoWkt);
+    //         statusMsg = siteAnalysis(geometry, xzyzList);
+    //         // 拿到图层
+    //     } else if (fzxzDTO.getFwlx() == 2) {
+    //         // shp文件
+    //         statusMsg = siteAnalysis(fzxzDTO.getXzfw());
+    //     }
+    // }
+    //
+    // private static StatusMsg setWorkspace() {
+    //     StatusMsg statusMsg = new StatusMsg();
+    //
+    //     DatasourceConnectionInfo info = new DatasourceConnectionInfo();
+    //     info.setEngineType(EngineType.PGGIS);
+    //     // TODO:配置信息放到配置文件中
+    //     info.setServer(dbUrl);
+    //     info.setDatabase(dbName);
+    //     info.setUser(dbUser);
+    //     info.setPassword(dbPwd);
+    //
+    //     Workspace mWorkspace = new Workspace();
+    //     Datasource datasource = mWorkspace.getDatasources().create(info);
+    //
+    //     if (datasource == null) {
+    //         statusMsg.setMsg("创建数据源失败");
+    //         statusMsg.setB(false);
+    //         return statusMsg;
+    //     }
+    //     return statusMsg;
+    // }
+    //
+    // // TODO:这里暂时导入不成功
     // private static StatusMsg siteAnalysis(String filePath) {
     //     StatusMsg statusMsg = new StatusMsg();
     //
-    //     //1.创建数据源
+    //     // 1.创建数据源
     //     DatasourceConnectionInfo info = new DatasourceConnectionInfo();
     //     info.setEngineType(EngineType.PGGIS);
-    //     //TODO:配置信息放到配置文件中
-    //     info.setServer("192.168.60.202:5432");
-    //     info.setDatabase("plan");
-    //     info.setUser("postgres");
-    //     info.setPassword("postgres");
+    //     // TODO:配置信息放到配置文件中
+    //     info.setServer(dbUrl);
+    //     info.setDatabase(dbName);
+    //     info.setUser(dbUser);
+    //     info.setPassword(dbPwd);
     //
     //     Workspace mWorkspace = new Workspace();
     //     Datasource datasource = mWorkspace.getDatasources().open(info);
@@ -86,21 +87,21 @@ public class FzxzPlanSchedule {
     //         return statusMsg;
     //     }
     //
-    //     //2.导入数据
+    //     // 2.导入数据
     //     // 构建目标文件路径
     //     String projectRootDir = System.getProperty("user.dir");
     //     String targetFilePath = projectRootDir + File.separator + "data" + File.separator + "shp" + File.separator + "xzqh.shp";
     //
-    //     //导入shp文件
+    //     // 导入shp文件
     //     String originalRegions = "original_regions";
     //     ImportSettingSHP importSettingSHP = new ImportSettingSHP();
     //     importSettingSHP.setImportMode(ImportMode.OVERWRITE);
     //     importSettingSHP.setSourceFilePath(targetFilePath);
-    //     //设置需要导入的数据编码类型，因为有中文字段，所以用ASCII编码
+    //     // 设置需要导入的数据编码类型，因为有中文字段，所以用ASCII编码
     //     importSettingSHP.setSourceFileCharset(Charset.ANSI);
     //     importSettingSHP.setTargetDatasetName(originalRegions);
     //
-    //     //设置要导入的目标数据源
+    //     // 设置要导入的目标数据源
     //     importSettingSHP.setTargetDatasource(datasource);
     //     DataImport dataImport = new DataImport();
     //     dataImport.getImportSettings().add(importSettingSHP);
@@ -112,21 +113,22 @@ public class FzxzPlanSchedule {
     //         return statusMsg;
     //     }
     //
-    //     //3.圈选数据
-    //     //源数据
+    //     // 3.圈选数据
+    //     // 源数据
     //     DatasourceConnectionInfo infoReal3d = new DatasourceConnectionInfo();
     //     infoReal3d.setEngineType(EngineType.PGGIS);
-    //     //TODO:配置信息放到配置文件中
-    //     infoReal3d.setServer("192.168.60.202:5432");
-    //     infoReal3d.setDatabase("real3d");
-    //     infoReal3d.setUser("postgres");
-    //     infoReal3d.setPassword("postgres");
+    //     // TODO:配置信息放到配置文件中
+    //     infoReal3d.setServer(dbUrl);
+    //     infoReal3d.setDatabase(dbName);
+    //     infoReal3d.setUser(dbUser);
+    //     infoReal3d.setPassword(dbPwd);
     //
     //     Workspace real3dWorkspace = new Workspace();
     //     Datasource real3dResource = real3dWorkspace.getDatasources().open(infoReal3d);
+    //     String[] names = real3dResource.getDatasets().getDatasetNames();
     //     DatasetVector ghdkaDataset = (DatasetVector) real3dResource.getDatasets().get("vector_GHDKA");
     //
-    //     //圈选区域
+    //     // 圈选区域
     //     Datasets datasets = datasource.getDatasets();
     //     DatasetVector originalDataset = (DatasetVector) datasets.get(originalRegions);
     //
@@ -138,12 +140,12 @@ public class FzxzPlanSchedule {
     //     Recordset recordsetRes = ghdkaDataset.query(parameter);
     //     int featureCount = recordsetRes.getAllFeatures().size();
     //
-    //     //4.创建圈选后的数据集，并存储数据
+    //     // 4.创建圈选后的数据集，并存储数据
     //     DatasetVector dataset_result = (DatasetVector) datasets.createFromTemplate(datasets.getAvailableDatasetName("new_GHDKA"), ghdkaDataset);
     //     // 将空间查询结果追加到新建的数据集中
     //     dataset_result.append(recordsetRes);
     //
-    //     //释放工作空间占有的资源
+    //     // 释放工作空间占有的资源
     //     infoReal3d.dispose();
     //     real3dWorkspace.dispose();
     //
@@ -151,29 +153,30 @@ public class FzxzPlanSchedule {
     //     mWorkspace.dispose();
     //     return statusMsg;
     // }
-
-
-    // 选址分析
+    //
+    //
+    // // 选址分析
     // private static StatusMsg siteAnalysis(Geometry geometry, List<FzxzXzyzDTO> xzyzList) {
     //     StatusMsg statusMsg = new StatusMsg();
-    //     //1.创建数据源
+    //     // 1.创建数据源
     //     DatasourceConnectionInfo info = new DatasourceConnectionInfo();
     //     info.setEngineType(EngineType.PGGIS);
-    //     //TODO:配置信息放到配置文件中
-    //     info.setServer("192.168.60.202:5432");
-    //     info.setDatabase("real3d");
-    //     info.setUser("postgres");
-    //     info.setPassword("postgres");
+    //     // info.setEngineType(EngineType);
+    //     // TODO:配置信息放到配置文件中
+    //     info.setServer(dbUrl);
+    //     info.setDatabase(dbName);
+    //     info.setUser(dbUser);
+    //     info.setPassword(dbPwd);
     //
     //     Workspace mWorkspace = new Workspace();
     //     Datasource datasource = mWorkspace.getDatasources().open(info);
     //
-    //     //1.打开数据源
+    //     // 1.打开数据源
     //     Datasets datasets = datasource.getDatasets();
     //     DatasetVector ghdkaDataset = (DatasetVector) datasets.get("vector_GHDKA");
-    //     //int allSize = ghdkaDataset.getAllFeatures().size();
+    //     // int allSize = ghdkaDataset.getAllFeatures().size();
     //
-    //     //2.空间数据圈选
+    //     // 2.空间数据圈选
     //     QueryParameter parameter = new QueryParameter();
     //     parameter.setCursorType(CursorType.STATIC);
     //     parameter.setSpatialQueryMode(SpatialQueryMode.CONTAIN);
@@ -182,7 +185,7 @@ public class FzxzPlanSchedule {
     //     Recordset recordsetRes = ghdkaDataset.query(parameter);
     //     int featureCount = recordsetRes.getAllFeatures().size();
     //
-    //     //3.创建圈选后的数据集，并存储数据
+    //     // 3.创建圈选后的数据集，并存储数据
     //     DatasetVector dataset_result = (DatasetVector) datasets.createFromTemplate(datasets.getAvailableDatasetName("new_GHDKA"), ghdkaDataset);
     //     // 将空间查询结果追加到新建的数据集中
     //     dataset_result.append(recordsetRes);

onemap-modules/onemap-analyse/src/main/resources/mapper/oracle/vector/GhdkaMapper.xml

@@ -0,0 +1,10 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.onemap.analyse.mapper.vector.GhdkaMapper">
+    <select id="filter" parameterType="com.onemap.analyse.domain.query.GhdkaFilter" resultType="java.lang.Integer">
+        SELECT id
+        FROM "GHDKA" where id=1
+    </select>
+</mapper>