nzy上传接口

YHYZT/server/src/main/java/com/zjugis/yzt/dao/StNzydkMapper.java

@@ -13,13 +13,12 @@ import org.apache.ibatis.annotations.Update;
  **/
 @Mapper
 public interface StNzydkMapper extends BaseMapper<StNzydk> {
-    
     /**
-     * 根据主键更新shape字段
-     * @param id 主键
-     * @param shape 空间数据
-     * @return 更新成功的记录数
+     * @param id
+     * @param shape
+     * @param wkid
+     * @return
      */
-    @Update("UPDATE st_nzydk SET shape = #{shape} WHERE objectid = #{id}")
-    int updateShapeById(Integer id, String shape);
+    @Update("UPDATE st_nzydk SET shape = st_geometry(#{shape}, #{wkid}) WHERE objectid = #{id}")
+    int updateShapeById(Integer id, String shape, int wkid);
 } 

YHYZT/server/src/main/java/com/zjugis/yzt/service/impl/StNzydkUploadServiceImpl.java

@@ -165,9 +165,8 @@ public class StNzydkUploadServiceImpl extends ServiceImpl<StNzydkMapper, StNzydk
                         TxtReader txtReader = new TxtReader(txtInputStream);
                         ParseResult parseResult = txtReader.read();
                         if (parseResult != null && parseResult.getGeometry() != null) {
-                            String wkt= parseResult.getGeometry().toText();
-                            String wkb= GisUtils.convertGeometry2WKB(parseResult.getGeometry());
-                            stNzydkMapper.updateShapeById(objectId, wkb);
+                            String wkt = parseResult.getGeometry().toText();
+                            stNzydkMapper.updateShapeById(objectId, wkt, 4528);
                         } else {
                             log.warn("项目 {} 的TXT文件解析失败或未获取到Geometry数据。", projectCode);
                         }