资源表添加pubid，发布表去除regid、添加layerid和serviceid

13693261870

2023-09-02 e64b967ba5eba17e3b497fa35abc1aa39e7f07aa

资源表添加pubid，发布表去除regid、添加layerid和serviceid

 src/main/java/com/moon/server/entity/data/PublishEntity.java

@@ -12,8 +12,6 @@

    private int id;

    private String regid;

    private String name;

    private String url;
@@ -54,6 +52,10 @@

    private String updateName;

    private Integer layerid;

    private Integer serviceid;

    public PublishEntity() {
    }

@@ -63,14 +65,6 @@

    public void setId(int id) {
        this.id = id;
    }

    public String getRegid() {
        return regid;
    }

    public void setRegid(String regid) {
        this.regid = regid;
    }

    public String getName() {
@@ -232,4 +226,20 @@
    public void setUpdateName(String updateName) {
        this.updateName = updateName;
    }

    public Integer getLayerid() {
        return layerid;
    }

    public void setLayerid(Integer layerid) {
        this.layerid = layerid;
    }

    public Integer getServiceid() {
        return serviceid;
    }

    public void setServiceid(Integer serviceid) {
        this.serviceid = serviceid;
    }
}

 src/main/java/com/moon/server/entity/shujian/ColorTableEntity.java

@@ -1,4 +1,17 @@
package com.moon.server.entity.shujian;

public class ColorTableEntity {
import java.io.Serializable;

/**
 * 数简.颜色表实体类
 *
 * @author WWW
 * @date 2023-08-31
 */
@SuppressWarnings("AlibabaLowerCamelCaseVariableNaming")
public class ColorTableEntity implements Serializable {
    private static final long serialVersionUID = -7178280280689493423L;

    public ColorTableEntity() {
    }
}

 src/main/java/com/moon/server/entity/shujian/GradientColorTableEntity.java

@@ -1,13 +1,17 @@
package com.moon.server.entity.shujian;

import java.io.Serializable;

/**
 * 数简.颜色表实体类
 * 数简.渐变颜色表实体类
 *
 * @author WWW
 * @date 2023-08-31
 */
@SuppressWarnings("AlibabaLowerCamelCaseVariableNaming")
public class GradientColorTableEntity {
public class GradientColorTableEntity implements Serializable {
    private static final long serialVersionUID = 3436664443231697504L;

    private Double r_start;

    private Double g_start;

 src/main/java/com/moon/server/entity/sys/ResEntity.java

@@ -56,6 +56,8 @@

    private String updateName;

    private Integer pubid;

    public ResEntity() {
    }

@@ -242,4 +244,12 @@
    public void setUpdateName(String updateName) {
        this.updateName = updateName;
    }

    public Integer getPubid() {
        return pubid;
    }

    public void setPubid(Integer pubid) {
        this.pubid = pubid;
    }
}

 src/main/java/com/moon/server/service/data/PublishService.java

@@ -179,10 +179,6 @@
            return 0;
        }

        if (msg.getCount() > 0) {
            serverRegister(msg.getResult(), req);
        }

        return msg.getCount();
    }

@@ -212,36 +208,6 @@
    }

    /**
     * 服务注册
     */
    private void serverRegister(String ids, HttpServletRequest req) {
        List<PublishEntity> list = selectByIds(ids);
        if (null == list || list.isEmpty()) {
            return;
        }

        for (PublishEntity entity : list) {
            // 避免重复注册
            if (null != entity.getUpdateTime()) {
                continue;
            }

            String url = entity.getUrl().replace("{host}", iisHost);
            String type = getServerType(entity);

            RegisterEntity reg = fmeService.serverRegister(entity.getName(), url, type, req);
            if (null == reg || StringHelper.isEmpty(reg.getSerialnum())) {
                continue;
            }

            fmeService.serverApply(reg.getSerialnum(), entity.getId(), req);

            entity.setRegid(reg.getHashid());
            update(entity);
        }
    }

    /**
     * 获取服务类型
     */
    private String getServerType(PublishEntity entity) {
@@ -267,31 +233,7 @@
    public Integer deletes(List<Integer> idList, HttpServletRequest req) {
        String ids = StringHelper.join(idList, ",");

        deleteRes(ids, req);

        return deletes(ids);
    }

    /**
     * 删除资源
     */
    private void deleteRes(String ids, HttpServletRequest req) {
        List<PublishEntity> list = selectByIds(ids);
        if (null == list || list.isEmpty()) {
            return;
        }

        for (PublishEntity entity : list) {
            if (StringHelper.isEmpty(entity.getRegid())) {
                continue;
            }

            try {
                fmeService.deleteRes(entity.getRegid(), req);
            } catch (Exception ex) {
                log.error(ex.getMessage(), ex);
            }
        }
    }

    /**

 src/main/resources/application.yml

@@ -47,7 +47,7 @@
    # JDBC 基本配置 &currentSchema=public
    url: jdbc:postgresql://192.168.20.83:5433/moon?useAffectedRows=true
    #url: jdbc:postgresql://127.0.0.1:5433/moon?useAffectedRows=true
    username : postgres
    username: postgres
    password: Postgres!_14_moon
    #password: postgres
    driver-class-name: org.postgresql.Driver

 src/main/resources/mapper/data/PublishMapper.xml

@@ -24,7 +24,7 @@
        select
            (select c.url from lf.sys_meta_pub b inner join lf.sys_publish c on b.pubid = c.id where b.metaid = a.id limit 1) "url",
            (select ST_AsText(c.geom) from lf.sys_meta_pub b inner join lf.sys_publish c on b.pubid = c.id where b.metaid = a.id limit 1) "geom",
            a.*, fn_uname(a.create_user) uname, fn_get_fullname(a.depcode, 1) depName, fn_get_fullname(a.dircode, 2) dirName, fn_ver(a.verid) verName
            a.*, fn_uname(a.create_user) createName, fn_uname(a.update_user) updateName, fn_get_fullname(a.depcode, 1) depName, fn_get_fullname(a.dircode, 2) dirName, fn_ver(a.verid) verName
        from lf.sys_meta a
        <where>
            ${types}
@@ -115,9 +115,9 @@

    <insert id="insert" parameterType="com.moon.server.entity.data.PublishEntity">
        insert into lf.sys_publish
        (regid,name,url,path,type,status,dirid,depid,min,max,json,create_user,create_time,bak)
        (layerid,serviceid,name,url,path,type,status,dirid,depid,min,max,json,create_user,create_time,geom,bak)
        values
        (#{regid},#{name},#{url},#{path},#{type},#{status},#{dirid},#{depid},#{min},#{max},#{json},#{createUser},now(),#{bak})
        (#{layerid},#{serviceid},#{name},#{url},#{path},#{type},#{status},#{dirid},#{depid},#{min},#{max},#{json},#{createUser},now(),${geom},#{bak})
    </insert>

    <insert id="insertPubDown">
@@ -126,10 +126,10 @@

    <insert id="inserts">
        insert into lf.sys_publish
        (regid,name,url,path,type,status,dirid,depid,min,max,json,create_user,create_time,bak)
        (layerid,serviceid,,name,url,path,type,status,dirid,depid,min,max,json,create_user,create_time,geom,bak)
        values
        <foreach collection="list" item="item" index="index" separator=",">
            (#{item.regid},#{item.name},#{item.url},#{item.path},#{item.type},#{item.status},#{item.dirid},#{item.depid},#{item.min},#{item.max},#{item.json},#{item.createUser},now(),#{item.bak})
            (#{item.layerid},#{item.serviceid},#{item.name},#{item.url},#{item.path},#{item.type},#{item.status},#{item.dirid},#{item.depid},#{item.min},#{item.max},#{item.json},#{item.createUser},now(),${item.geom},#{item.bak})
        </foreach>
    </insert>

@@ -145,7 +145,7 @@

    <update id="update">
        update lf.sys_publish
        set regid=#{regid},name=#{name},url=#{url},path=#{path},type=#{type},status=#{status},dirid=#{dirid},depid=#{depid},min=#{min},max=#{max},json=#{json},update_user=#{updateUser},update_time=now(),bak=#{bak}
        set layerid=#{layerid},serviceid=#{serviceid},name=#{name},url=#{url},path=#{path},type=#{type},status=#{status},dirid=#{dirid},depid=#{depid},min=#{min},max=#{max},json=#{json},update_user=#{updateUser},update_time=now(),geom=${geom},bak=#{bak}
        where id=#{id}
    </update>

@@ -153,7 +153,7 @@
        <foreach collection="list" item="item" index="index" separator=";">
            update lf.sys_publish
            <set>
                regid=#{item.regid},name=#{item.name},url=#{item.url},path=#{item.path},type=#{item.type},status=#{item.status},dirid=#{item.dirid},depid=#{item.depid},min=#{item.min},max=#{item.max},json=#{item.json},update_user=#{item.updateUser},update_time=now(),bak=#{item.bak}
                layerid=#{item.layerid},serviceid=#{item.serviceid},name=#{item.name},url=#{item.url},path=#{item.path},type=#{item.type},status=#{item.status},dirid=#{item.dirid},depid=#{item.depid},min=#{item.min},max=#{item.max},json=#{item.json},update_user=#{item.updateUser},update_time=now(),geom=#{item.geom},bak=#{item.bak}
            </set>
            where id = #{item.id}
        </foreach>

 src/main/resources/mapper/sys/ResMapper.xml

@@ -85,17 +85,17 @@

    <insert id="insert" parameterType="com.moon.server.entity.sys.ResEntity">
        insert into lf.sys_res
        (cn_name,en_name,status,type,data,category,url,test,descr,depid,dirid,img,create_user,create_time,bak,tab,args)
        (cn_name,en_name,status,type,data,category,url,test,descr,depid,dirid,img,create_user,create_time,bak,tab,args,pubid)
        values
        (#{cnName},#{enName},#{status},#{type},#{data},#{category},#{url},#{test},#{descr},#{depid},#{dirid},#{img},#{createUser},now(),#{bak},#{tab},#{args})
        (#{cnName},#{enName},#{status},#{type},#{data},#{category},#{url},#{test},#{descr},#{depid},#{dirid},#{img},#{createUser},now(),#{bak},#{tab},#{args},#{pubid})
    </insert>

    <insert id="inserts">
        insert into lf.sys_res
        (cn_name,en_name,status,type,data,category,url,test,descr,depid,dirid,img,create_user,create_time,bak,tab,args)
        (cn_name,en_name,status,type,data,category,url,test,descr,depid,dirid,img,create_user,create_time,bak,tab,args,pubid)
        values
        <foreach collection="list" item="item" index="index" separator=",">
            (#{item.cnName},#{item.enName},#{item.status},#{item.type},#{item.data},#{item.category},#{item.url},#{item.test},#{item.descr},#{item.depid},#{item.dirid},#{item.img},#{item.createUser},now(),#{item.bak},#{item.tab},#{item.args})
            (#{item.cnName},#{item.enName},#{item.status},#{item.type},#{item.data},#{item.category},#{item.url},#{item.test},#{item.descr},#{item.depid},#{item.dirid},#{item.img},#{item.createUser},now(),#{item.bak},#{item.tab},#{item.args},#{item.pubid})
        </foreach>
    </insert>

@@ -112,14 +112,14 @@

    <update id="update">
        update lf.sys_res
        set cn_name=#{cnName},en_name=#{enName},status=#{status},type=#{type},data=#{data},category=#{category},url=#{url},test=#{test},descr=#{descr},depid=#{depid},dirid=#{dirid},img=#{img},update_user=#{updateUser},update_time=now(),bak=#{bak},tab=#{tab},args=#{args}
        set cn_name=#{cnName},en_name=#{enName},status=#{status},type=#{type},data=#{data},category=#{category},url=#{url},test=#{test},descr=#{descr},depid=#{depid},dirid=#{dirid},img=#{img},update_user=#{updateUser},update_time=now(),bak=#{bak},tab=#{tab},args=#{args},pubid=#{pubid}
        where id=#{id}
    </update>

    <update id="updates">
        <foreach collection="list" item="item" index="index" separator=";">
            update lf.sys_res
            set cn_name=#{item.cnName},en_name=#{item.enName},status=#{item.status},type=#{item.type},data=#{item.data},category=#{item.category},url=#{item.url},test=#{item.test},descr=#{item.descr},depid=#{item.depid},dirid=#{item.dirid},img=#{item.img},update_user=#{item.updateUser},update_time=now(),bak=#{item.bak},tab=#{item.tab},args=#{item.args}
            set cn_name=#{item.cnName},en_name=#{item.enName},status=#{item.status},type=#{item.type},data=#{item.data},category=#{item.category},url=#{item.url},test=#{item.test},descr=#{item.descr},depid=#{item.depid},dirid=#{item.dirid},img=#{item.img},update_user=#{item.updateUser},update_time=now(),bak=#{item.bak},tab=#{item.tab},args=#{item.args},pubid=#{item.pubid}
            where id = #{item.id}
        </foreach>
    </update>