From b1e8a099eb3117bcbd5f2e0c9a2eb0accabd8cbf Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Tue, 11 Feb 2025 08:56:46 +0800
Subject: [PATCH] 通过风险源点位分析三级防控点查询修改
---
src/main/java/org/springblade/modules/yw/service/impl/GeomInfoServiceImpl.java | 60 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 57 insertions(+), 3 deletions(-)
diff --git a/src/main/java/org/springblade/modules/yw/service/impl/GeomInfoServiceImpl.java b/src/main/java/org/springblade/modules/yw/service/impl/GeomInfoServiceImpl.java
index 75be953..497881c 100644
--- a/src/main/java/org/springblade/modules/yw/service/impl/GeomInfoServiceImpl.java
+++ b/src/main/java/org/springblade/modules/yw/service/impl/GeomInfoServiceImpl.java
@@ -1,9 +1,17 @@
package org.springblade.modules.yw.service.impl;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.logging.log4j.util.Strings;
+import org.geotools.feature.FeatureCollection;
+import org.geotools.feature.FeatureIterator;
+import org.geotools.geojson.feature.FeatureJSON;
+import org.geotools.geojson.geom.GeometryJSON;
+import org.locationtech.jts.geom.Geometry;
+import org.opengis.feature.simple.SimpleFeature;
import org.springblade.common.utils.FileUtil;
import org.springblade.common.utils.ShapeFileUtil;
import org.springblade.core.tool.api.R;
@@ -17,7 +25,8 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
-import java.io.File;
+
+import java.io.*;
import java.util.*;
/**
@@ -80,7 +89,6 @@
/**
* 导出 空间信息shp zip 包
* @param ids
- * @param response
* @return
*/
@Override
@@ -146,7 +154,7 @@
private void setFirmId(GeomInfoEntity geomInfoEntity,String firmName) {
if (!Strings.isBlank(firmName)) {
QueryWrapper<FirmInfo> wrapper = new QueryWrapper<>();
- wrapper.eq("name", firmName);
+ wrapper.like("name", '%' +firmName + '%');
FirmInfo one = firmInfoService.getOne(wrapper);
if (null!=one)
geomInfoEntity.setFirmId(one.getId());
@@ -167,4 +175,50 @@
}
return null;
}
+
+ /**
+ * 导入 geojson 文件解析空间信息
+ * @param multipartFile
+ * @return
+ */
+ @Override
+ public R importGeoJson(MultipartFile multipartFile) {
+ // 转 file
+ File file = FileUtil.toFile(multipartFile);
+
+ FeatureJSON featureJSON = new FeatureJSON();
+ try {
+ FeatureCollection featureCollection = featureJSON.readFeatureCollection(file);
+ FeatureIterator iterator = featureCollection.features();
+ // 遍历feature转为json对象
+ while (iterator.hasNext()) {
+ SimpleFeature feature = (SimpleFeature) iterator.next();
+ StringWriter writer = new StringWriter();
+ featureJSON.writeFeature(feature, writer);
+ String temp = writer.toString();
+ JSONObject json = JSONObject.parseObject(temp);
+ Object value = feature.getDefaultGeometryProperty().getValue();
+ System.out.println("value = " + value);
+ try {
+ GeomInfoEntity geomInfoEntity = new GeomInfoEntity();
+ // 空间坐标
+ geomInfoEntity.setGeom("'" + value + "'");
+ // 空间类型
+ if (json.getJSONObject("geometry").get("type") != null) {
+ geomInfoEntity.setType(json.getJSONObject("geometry").getString("type"));
+ }
+ // 保存
+ baseMapper.saveGeoInfo(geomInfoEntity);
+ } catch (NumberFormatException e) {
+ log.error("NumberFormatException: {}", e);
+ } catch (Exception e) {
+ log.error("Exception: {}", e);
+ }
+ }
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ // 返回
+ return R.data(200,"","操作成功！");
+ }
}
--
Gitblit v1.9.3