12.28

13693261870

2022-12-28 049e8125cd972b564c20dcdc153dfec55b6ae810

12.28

 data/ts.sql

@@ -97,6 +97,42 @@
from lf.sys_user a inner join lf.sys_role_user b on a.id = b.userid inner join lf.sys_role c on b.roleid = c.id
where c.id = 15

select *, st_astext(geom) as wkt from bs.m_pipesegment;
select * from bs.m_pipesegment;
select gid, pipename, segname from bs.m_pipesegment order by pipename, segname;

select * from bd.dlg_25w_hydl;
select * from bd.dlg_25w_lrdl;
select * from bd.dlg_25w_lrrl;
select * from bd.dlg_25w_hyda;

SELECT a.name as acrossName,
       b.segname as segName,
       b.remarks,
       b.pipename as pipeName,
       st_length( st_geographyfromtext( st_astext( st_intersection( ST_MakeValid(a.geom), ST_MakeValid(b.geom) ) ) ) ) AS acrossLength,
       st_astext(b.geom) as wkt
FROM bd.dlg_25w_hyda AS a,
     (SELECT *
      FROM bs.m_pipesegment
      WHERE segname = 'DD' ) AS b
WHERE ST_Intersects(a.geom, b.geom)

select a.name as acrossName, b.segname as segName, b.remarks, b.pipename as pipeName,
  cast( st_length( st_geographyfromtext( st_astext( st_intersection(ST_MakeValid(a.geom), ST_MakeValid(b.geom) ) ) ) ) as decimal(12, 3) ) AS acrossLength,
  st_astext( st_intersection( ST_MakeValid(a.geom), ST_MakeValid(b.geom) ) ) as wkt
from bd.dlg_25w_hyda as a, (select segname, remarks, pipename, geom from bs.m_pipesegment where gid = 24) as b
where ST_Intersects(a.geom, b.geom)














 src/main/java/com/lf/server/controller/show/ApplyController.java

@@ -28,7 +28,7 @@
 * æ•°æ®ç”³è¯·
 * @author WWW
 */
@Api(tags = "运维管理\\数据申请")
@Api(tags = "综合展示\\数据申请")
@RestController
@RequestMapping("/apply")
public class ApplyController extends BaseController {

 src/main/java/com/lf/server/controller/show/PipelineController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,85 @@
package com.lf.server.controller.show;

import com.lf.server.annotation.SysLog;
import com.lf.server.controller.all.BaseController;
import com.lf.server.entity.all.ResponseMsg;
import com.lf.server.entity.all.StaticData;
import com.lf.server.entity.show.PipelineEntity;
import com.lf.server.service.show.PipelineService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.*;

/**
 * ç®¡é“分析
 * @author WWW
 */
@Api(tags = "综合展示\\管道分析")
@RestController
@RequestMapping("/pipeline")
public class PipelineController extends BaseController {
    @Autowired
    PipelineService pipelineService;

    @SysLog()
    @ApiOperation(value = "查询管段")
    @GetMapping(value = "/selectSegNames")
    public ResponseMsg<Object> selectSegNames() {
        try {
            List<PipelineEntity> rs = pipelineService.selectSegNames();

            return success(rs);
        } catch (Exception ex) {
            return fail(ex.getMessage(), null);
        }
    }

    @SysLog()
    @ApiOperation(value = "查询管线分析")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "pe", value = "管道分析实体类", dataType = "PipelineEntity", paramType = "body")
    })
    @ResponseBody
    @PostMapping(value = "/selectPipeAnalysis")
    public ResponseMsg<Object> selectPipeAnalysis(@RequestBody PipelineEntity pe) {
        try {
            if (null == pe.getGid() || pe.getGid() < 1) {
                return fail("请输入管段ID");
            }
            if (null == pe.getTabs() || 0 == pe.getTabs().size()) {
                return fail("请输入表名");
            }
            if (!checkTabs(pe.getTabs())) {
                return fail("存在非法表名");
            }

            Map<String, Object> map = new HashMap<>();
            for (String tab : pe.getTabs()) {
                List<PipelineEntity> rs = pipelineService.selectPipeAnalysis(tab, pe.getGid());
                map.put(tab, rs);
            }

            return success(map);
        } catch (Exception ex) {
            return fail(ex.getMessage(), null);
        }
    }

    /**
     * æ£€æŸ¥è¡¨å
     */
    private boolean checkTabs(List<String> tabs) {
        for (String tab : tabs) {
            if (!StaticData.PIPE_ANALYSIS_TABS.contains(tab)) {
                return false;
            }
        }

        return true;
    }
}

 src/main/java/com/lf/server/entity/all/StaticData.java

@@ -103,4 +103,9 @@
     * GDB排除字段
     */
    public final static List<String> GDB_EXCLUDE_FIELDS = new ArrayList<>(Arrays.asList("geom", "objectid", "shape_leng", "shape_area", "serialVersionUID", "dirName", "depName", "verName", "createName", "updateName"));

    /**
     * ç®¡çº¿åˆ†æžè¡¨åé›†åˆ
     */
    public final static List<String> PIPE_ANALYSIS_TABS = new ArrayList<>(Arrays.asList("bd.dlg_25w_hydl", "bd.dlg_25w_lrdl", "bd.dlg_25w_lrrl", "bd.dlg_25w_hyda"));
}

 src/main/java/com/lf/server/entity/show/PipelineEntity.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,123 @@
package com.lf.server.entity.show;

import com.alibaba.fastjson.annotation.JSONField;
import com.fasterxml.jackson.annotation.JsonInclude;

import java.io.Serializable;
import java.util.List;

/**
 * ç®¡é“分析实体类
 *
 * @author xingjinshuang@smartearth.cn
 * @date 2022/12/26
 */
public class PipelineEntity implements Serializable {
    private static final long serialVersionUID = 1L;

    /**
     * è¡¨å
     */
    @JSONField(serialize = false)
    @JsonInclude(JsonInclude.Include.NON_NULL)
    private List<String> tabs;

    /**
     * ä¸»é”®ID
     */
    private Integer gid;

    /**
     * ç®¡çº¿
     */
    private String pipeName;

    /**
     * ç®¡æ®µ
     */
    private String segName;

    /**
     * ç©¿è¶Šåç§°
     */
    private String acrossName;

    /**
     * ç©¿è¶Šé•¿åº¦
     */
    private double acrossLength;

    /**
     * å¤‡æ³¨
     */
    private String remarks;

    /**
     * wkt
     */
    private String wkt;

    public Integer getGid() {
        return gid;
    }

    public void setGid(Integer gid) {
        this.gid = gid;
    }

    public List<String> getTabs() {
        return tabs;
    }

    public void setTabs(List<String> tabs) {
        this.tabs = tabs;
    }

    public String getPipeName() {
        return pipeName;
    }

    public void setPipeName(String pipeName) {
        this.pipeName = pipeName;
    }

    public String getSegName() {
        return segName;
    }

    public void setSegName(String segName) {
        this.segName = segName;
    }

    public String getAcrossName() {
        return acrossName;
    }

    public void setAcrossName(String acrossName) {
        this.acrossName = acrossName;
    }

    public double getAcrossLength() {
        return acrossLength;
    }

    public void setAcrossLength(double acrossLength) {
        this.acrossLength = acrossLength;
    }

    public String getRemarks() {
        return remarks;
    }

    public void setRemarks(String remarks) {
        this.remarks = remarks;
    }

    public String getWkt() {
        return wkt;
    }

    public void setWkt(String wkt) {
        this.wkt = wkt;
    }
}

 src/main/java/com/lf/server/mapper/show/PipelineMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,31 @@
package com.lf.server.mapper.show;

import com.lf.server.entity.show.PipelineEntity;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;

import java.util.List;

/**
 * ç®¡é“分析映射类
 * @author WWW
 */
@Mapper
@Repository
public interface PipelineMapper {
    /**
     * æŸ¥è¯¢ç®¡æ®µ
     *
     * @return ç®¡çº¿å®žä½“类集合
     */
    public List<PipelineEntity> selectSegNames();

    /**
     * æŸ¥è¯¢ç®¡çº¿åˆ†æž
     *
     * @param tab è¡¨å
     * @param gid ID
     * @return ç®¡çº¿å®žä½“类集合
     */
    public List<PipelineEntity> selectPipeAnalysis(String tab, Integer gid);
}

 src/main/java/com/lf/server/service/show/PipelineService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,28 @@
package com.lf.server.service.show;

import com.lf.server.entity.show.PipelineEntity;
import com.lf.server.mapper.show.PipelineMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * ç®¡é“分析服务类
 * @author WWW
 */
@Service
public class PipelineService implements PipelineMapper {
    @Autowired
    PipelineMapper pipelineMapper;

    @Override
    public List<PipelineEntity> selectSegNames() {
        return pipelineMapper.selectSegNames();
    }

    @Override
    public List<PipelineEntity> selectPipeAnalysis(String tab, Integer gid) {
        return pipelineMapper.selectPipeAnalysis(tab, gid);
    }
}

 src/main/resources/mapper/show/PipelineMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,15 @@
<?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.lf.server.mapper.show.PipelineMapper">
    <select id="selectSegNames" resultType="com.lf.server.entity.show.PipelineEntity">
        select gid, pipename, segname from bs.m_pipesegment order by pipename, segname;
    </select>

    <select id="selectPipeAnalysis" resultType="com.lf.server.entity.show.PipelineEntity">
        select a.name as acrossName, b.segname as segName, b.remarks, b.pipename as pipeName,
            cast( st_length( st_geographyfromtext( st_astext( st_intersection(ST_MakeValid(a.geom), ST_MakeValid(b.geom) ) ) ) ) as decimal(12, 2) ) AS acrossLength,
            st_astext( st_intersection( ST_MakeValid(a.geom), ST_MakeValid(b.geom) ) ) as wkt
        from ${tab} as a, (select segname, remarks, pipename, geom from bs.m_pipesegment where gid = #{gid} ) as b
        where ST_Intersects(a.geom, b.geom)
    </select>
</mapper>

 ˵Ã÷.txt

@@ -60,6 +60,7 @@
http://192.168.20.39:12306/
http://192.168.20.39:12315/
http://192.168.20.39:12316/
http://192.168.20.39:12316/server/druid/sql.html
-------------------------------------------------------------------------------
String path = System.getProperty("user.dir");
String uid = RsaHelper.decrypt(user.getUid());