管道基础大数据平台系统开发-【后端】-Server
13693261870
2023-01-23 5107fe96747cc93c33c7498e50e958ecbee9ad7f
1.23
已修改6个文件
51 ■■■■■ 文件已修改
data/db_fn.sql 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
data/update.sql 13 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/mapper/data/MetaMapper.java 3 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/data/MetaService.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/data/UploadService.java 21 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/data/MetaMapper.xml 6 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
data/db_fn.sql
@@ -180,13 +180,13 @@
$$ language plpgsql;
select fn_get_entity('dlg_25w_boua_s'); select fn_get_entity('dlg_25w_vega');
----------------------------------------------------------------------------------------------------- j.FME日志触发器
----------------------------------------------------------------------------------------------------- j.FME日志触发器 *
create or replace trigger fme_log_trigger after insert on lf.sys_fme_log
for each row execute procedure fn_meta_insert();
create or replace function fn_meta_insert() returns trigger as $$
  begin
    update lf.sys_meta set tab = new.pg_ns || '.' || new.tcdm, rows = new.count where eventid = new.parentid;
    update lf.sys_meta set tab = new.pg_ns || '.' || new.tcdm, layer = new.tcmc, rows = new.count where eventid = new.parentid;
    
    return new;
  end;
data/update.sql
@@ -1,10 +1,17 @@
------------------------------------------------------ 补充字段
------------------------------------------------------ 补充字段 *
-- alter table lf.sys_meta rename column bstab to tab; alter table lf.sys_meta drop column mdtab;
alter table lf.sys_fme_log add column create_time timestamp(6) without time zone default now();
alter table lf.sys_meta add column layer varchar(50);
comment on column lf.sys_meta.layer is '图层';
select * from lf.sys_fme_log;
select * from lf.sys_meta;
select * from lf.sys_token where create_time < '2023-01-10';
-- delete from lf.sys_token where create_time < '2023-01-10';
select * from lf.sys_operate where optime < '2023-01-10';
-- delete from lf.sys_operate where optime < '2023-01-10';
select * from lf.sys_login where optime < '2023-01-10';
-- delete from lf.sys_login where optime < '2023-01-10';
------------------------------------------------------ 
select * from lf.sys_menu where position('http://' in url) > 0;
select url, replace(url, 'pipe.cppe.com', '{host}') from lf.sys_menu where position('http://' in url) > 0;
@@ -127,8 +134,8 @@
select * from lf.sys_user
select * from lf.sys_menu where cn_name='数据管理'
delete   from lf.sys_menu
select * from lf.sys_menu
delete   from lf.sys_meta
select * from lf.sys_meta
select * from lf.sys_fme_log
src/main/java/com/lf/server/mapper/data/MetaMapper.java
@@ -76,9 +76,10 @@
     * 根据GUID查询
     *
     * @param guid 文件GUID
     * @param tab  表名
     * @return
     */
    public MetaEntity selectByGuid(String guid);
    public MetaEntity selectByGuid(String guid, String tab);
    /**
     * 查询元数据文件
src/main/java/com/lf/server/service/data/MetaService.java
@@ -56,8 +56,8 @@
    }
    @Override
    public MetaEntity selectByGuid(String guid) {
        return metaMapper.selectByGuid(guid);
    public MetaEntity selectByGuid(String guid, String tab) {
        return metaMapper.selectByGuid(guid, tab);
    }
    @Override
src/main/java/com/lf/server/service/data/UploadService.java
@@ -125,7 +125,16 @@
            return;
        }
        List<?> list = null;
        MetaEntity old = metaService.selectByGuid(mf.getGuid(), tabName);
        if (old != null) {
            mf.setPath(old.getPath());
            mf.setEntity(old.getLayer());
            mf.setTab(old.getTab());
            mf.setRows(old.getRows());
            return;
        }
        List<?> list;
        if (StaticData.SHP.equals(mf.getExtName())) {
            list = ShpHelper.readData(clazz, mf.getPath());
        } else {
@@ -219,7 +228,7 @@
            return -1;
        }
        MetaEntity old = metaService.selectByGuid(mf.getGuid());
        MetaEntity old = metaService.selectByGuid(mf.getGuid(), null);
        if (null != old) {
            mf.setPath(old.getPath());
            mf.setTab(old.getTab());
@@ -292,12 +301,8 @@
            return;
        }
        MetaEntity old = metaService.selectByGuid(mf.getGuid());
        MetaEntity old = metaService.selectByGuid(mf.getGuid(), null);
        if (null != old) {
            mf.setPath(old.getPath());
            mf.setTab(old.getTab());
            mf.setEntity(old.getLayer());
            mf.setRows(old.getRows());
            FileHelper.deleteFiles(file);
            return;
        }
@@ -413,7 +418,7 @@
        for (MetaFileEntity mf : list) {
            boolean isXls = StaticData.XLS.equals(mf.getExtName()) || StaticData.XLSX.equals(mf.getExtName());
            if (mf.getRows() > -1 && isXls) {
                MetaEntity old = metaService.selectByGuid(mf.getGuid());
                MetaEntity old = metaService.selectByGuid(mf.getGuid(), null);
                if (null == old) {
                    xlsList.add(mf);
                } else {
src/main/resources/mapper/data/MetaMapper.xml
@@ -79,7 +79,11 @@
    <select id="selectByGuid" resultType="com.lf.server.entity.data.MetaEntity">
        select a.*,fn_uname(a.create_user) uname,fn_rec_query(a.depid, 'dep') depName,fn_ver(a.verid) verName,fn_rec_query(a.dirid, 'dir') dirName
        from lf.sys_meta a
        where guid = #{guid} limit 1
        where guid = #{guid}
        <if test="tab != null">
            and tab = #{tab}
        </if>
        limit 1
    </select>
    <select id="selectMetaFiles" resultType="com.lf.server.entity.data.MetaEntity">