|
@@ -1,16 +1,21 @@
|
|
|
package com.onemap.apply.service.gdbh.impl;
|
|
|
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
-import com.onemap.apply.domain.gdbh.*;
|
|
|
+import com.onemap.apply.domain.gdbh.GdbhDto;
|
|
|
+import com.onemap.apply.domain.gdbh.GdbhRwMxDto;
|
|
|
+import com.onemap.apply.domain.gdbh.GdbhRwMxYzDto;
|
|
|
+import com.onemap.apply.domain.gdbh.GdbhYzDTO;
|
|
|
+import com.onemap.apply.domain.res.ApiTTable;
|
|
|
+import com.onemap.apply.domain.res.ApiTTableFiled;
|
|
|
import com.onemap.apply.mapper.gdbh.*;
|
|
|
import com.onemap.apply.service.analyse.HttpAnalyseService;
|
|
|
import com.onemap.common.core.utils.NumberUtil;
|
|
|
import com.onemap.common.core.utils.StringUtils;
|
|
|
+import com.onemap.common.core.web.domain.AjaxResult;
|
|
|
import com.onemap.common.core.web.domain.RequestResult;
|
|
|
-import com.onemap.system.api.domain.IntersectionTableWktVo;
|
|
|
-import com.onemap.system.api.domain.IntersectsTableWktVo;
|
|
|
+import com.onemap.system.api.TableFiledRelationService;
|
|
|
import com.onemap.system.api.domain.RawTableVo;
|
|
|
-import com.onemap.system.api.domain.TargetTableVo;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
@@ -33,6 +38,8 @@ public class GdbhJgService {
|
|
|
private GdbhRwMxMapper gdbhRwMxMapper;
|
|
|
@Autowired
|
|
|
private GdbhRwMxYzMapper gdbhRwMxYzMapper;
|
|
|
+ @Autowired
|
|
|
+ private TableFiledRelationService tableFiledRelationService;
|
|
|
|
|
|
public RequestResult gdbhAnalysisHandle(String rwBsm) {
|
|
|
QueryWrapper<GdbhDto> wrapper0_1 = new QueryWrapper<>();
|
|
@@ -42,23 +49,6 @@ public class GdbhJgService {
|
|
|
return RequestResult.error("未查询到数据");
|
|
|
}
|
|
|
|
|
|
- //
|
|
|
- gdbhDto.setSumMj(255D);
|
|
|
- gdbhDto.setSumNumber(255);
|
|
|
-
|
|
|
- //获取范围
|
|
|
- Map xzfw = gdbhMapper.selectGdbhXzfw(gdbhDto.getXzfw());
|
|
|
- if (StringUtils.isEmpty(xzfw)) {
|
|
|
- return RequestResult.error("选址范围参数为空");
|
|
|
- }
|
|
|
- Double area = Double.valueOf(xzfw.get("area").toString());
|
|
|
- String ewkt = (String) xzfw.get("geom");
|
|
|
- if (StringUtils.isEmpty(ewkt)) {
|
|
|
- return RequestResult.error("选址范围参数为空");
|
|
|
- }
|
|
|
- gdbhDto.setGeom(ewkt);
|
|
|
- gdbhDto.setXzmj(area);
|
|
|
-
|
|
|
//计算1 模型
|
|
|
QueryWrapper<GdbhRwMxDto> wrapper0_2 = new QueryWrapper<>();
|
|
|
wrapper0_2.eq("rwbsm", rwBsm);
|
|
@@ -129,7 +119,15 @@ public class GdbhJgService {
|
|
|
if (StringUtils.isEmpty(yzbsm)) {
|
|
|
return RequestResult.error("yzbsm参数为空");
|
|
|
}
|
|
|
- String d_RawTableName = "TB_GPL0";
|
|
|
+
|
|
|
+ QueryWrapper<GdbhDto> wrapper0_1 = new QueryWrapper<>();
|
|
|
+ wrapper0_1.eq("bsm", bsm);
|
|
|
+ GdbhDto gdbhDto = gdbhMapper.selectOne(wrapper0_1);
|
|
|
+ if (StringUtils.isNull(gdbhDto)) {
|
|
|
+ return RequestResult.error("未查询到数据");
|
|
|
+ }
|
|
|
+ String d_RawTableName = gdbhDto.getXzfwTbaleName();
|
|
|
+
|
|
|
List<Map<String, Object>> d_sandiao = gdbhRwJgMapper.selectGdbhRwJgGroup(bsm, mxbsm, yzbsm);
|
|
|
List<String> ids = new ArrayList<>();
|
|
|
for (Map<String, Object> mx : d_sandiao) {
|
|
@@ -173,23 +171,6 @@ public class GdbhJgService {
|
|
|
return RequestResult.error("未查询到数据");
|
|
|
}
|
|
|
|
|
|
- //
|
|
|
- gdbhDto.setSumMj(255D);
|
|
|
- gdbhDto.setSumNumber(255);
|
|
|
-
|
|
|
- //获取范围
|
|
|
- Map xzfw = gdbhMapper.selectGdbhXzfw(gdbhDto.getXzfw());
|
|
|
- if (StringUtils.isEmpty(xzfw)) {
|
|
|
- return RequestResult.error("选址范围参数为空");
|
|
|
- }
|
|
|
- Double area = Double.valueOf(xzfw.get("area").toString());
|
|
|
- String ewkt = (String) xzfw.get("geom");
|
|
|
- if (StringUtils.isEmpty(ewkt)) {
|
|
|
- return RequestResult.error("选址范围参数为空");
|
|
|
- }
|
|
|
- gdbhDto.setGeom(ewkt);
|
|
|
- gdbhDto.setXzmj(area);
|
|
|
-
|
|
|
//计算1 模型
|
|
|
QueryWrapper<GdbhRwMxDto> wrapper0_2 = new QueryWrapper<>();
|
|
|
wrapper0_2.eq("rwbsm", rwBsm);
|
|
@@ -238,26 +219,25 @@ public class GdbhJgService {
|
|
|
ret.add(mxMap);
|
|
|
}
|
|
|
|
|
|
- String d_RawTableName = "TB_GPL0";
|
|
|
+ String d_RawTableName = gdbhDto.getXzfwTbaleName();
|
|
|
+
|
|
|
+ //查询tableid
|
|
|
+ String tableId = gdbhDto.getXzfwTbaleId();
|
|
|
+ AjaxResult ajaxResult = tableFiledRelationService.QueryTableFiledRelation(tableId);
|
|
|
+ if (!ajaxResult.isSuccess()) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ Object tableStr = ajaxResult.get(AjaxResult.DATA_TAG);
|
|
|
+ ApiTTable tTable = JSON.parseObject(JSON.toJSONString(tableStr), ApiTTable.class);
|
|
|
+
|
|
|
List<String> ids = new ArrayList<>();
|
|
|
ids.add(id);
|
|
|
|
|
|
+ List<ApiTTableFiled> filedList = tTable.getTableFiledlist();
|
|
|
List<String> columns = new ArrayList<>(); // 列名
|
|
|
- columns.add("tbbh");
|
|
|
- columns.add("nfqsmc");
|
|
|
- columns.add("xfrq");
|
|
|
- columns.add("mj");
|
|
|
- columns.add("zygdmj");
|
|
|
- columns.add("zyjbntmj");
|
|
|
- columns.add("qsx");
|
|
|
- columns.add("hsx");
|
|
|
- columns.add("qqyxmc");
|
|
|
- columns.add("dqyxmc");
|
|
|
- columns.add("tbfl");
|
|
|
- columns.add("bz");
|
|
|
- columns.add("sfhcmc");
|
|
|
- columns.add("sfdcmc");
|
|
|
-
|
|
|
+ for (ApiTTableFiled filed : filedList) {
|
|
|
+ columns.add(filed.getFiledName());
|
|
|
+ }
|
|
|
RawTableVo d0_vo = new RawTableVo();
|
|
|
d0_vo.setIds(ids);
|
|
|
d0_vo.setSrid(4525);
|