管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-03-24 58dd3c49946f2960fbf5c20d55acbd162108eb2d
1
已修改3个文件
77 ■■■■ 文件已修改
data/db_fn.sql 73 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/entity/ctrl/RegisterEntity.java 1 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/data/UploadService.java 3 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
data/db_fn.sql
@@ -458,24 +458,85 @@
-- drop trigger if exists fn_m_pipeline_trigger on bs.m_pipeline; -- 管线 
create or replace trigger fn_m_pipeline_trigger before insert on bs.m_pipeline for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_m_pipesegment_trigger on bs.m_pipeline; -- 管段
-- drop trigger if exists fn_m_pipesegment_trigger on bs.m_pipesegment; -- 管段
create or replace trigger fn_m_pipesegment_trigger before insert on bs.m_pipesegment for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_m_sitepoint_trigger on bs.m_pipeline; -- 站场点
-- drop trigger if exists fn_m_sitepoint_trigger on bs.m_sitepoint; -- 站场点
create or replace trigger fn_m_sitepoint_trigger before insert on bs.m_sitepoint for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_m_valvehousepoint_trigger on bs.m_pipeline; -- 阀室点
-- drop trigger if exists fn_m_valvehousepoint_trigger on bs.m_valvehousepoint; -- 阀室点
create or replace trigger fn_m_valvehousepoint_trigger before insert on bs.m_valvehousepoint for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_m_crossing_trigger on bs.m_pipeline; -- 穿跨越
-- drop trigger if exists fn_m_crossing_trigger on bs.m_crossing; -- 穿跨越
create or replace trigger fn_m_crossing_trigger before insert on bs.m_crossing for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_m_marker_trigger on bs.m_pipeline; -- 三桩一牌
-- drop trigger if exists fn_m_marker_trigger on bs.m_marker; -- 三桩一牌
create or replace trigger fn_m_markert_trigger before insert on bs.m_marker for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_m_hydraulic_protection_trigger on bs.m_pipeline; -- 水工保护
-- drop trigger if exists fn_m_hydraulic_protection_trigger on bs.m_hydraulic_protection; -- 水工保护
create or replace trigger fn_m_hydraulic_protection_trigger before insert on bs.m_hydraulic_protection for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_g_collapse_trigger on bs.g_collapse; -- 崩塌
create or replace trigger fn_g_collapse_trigger before insert on bs.g_collapse for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_g_debrisflow_trigger on bs.g_debrisflow; -- 泥石流
create or replace trigger fn_g_debrisflow_trigger before insert on bs.g_debrisflow for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_g_ground_collapse_trigger on bs.g_ground_collapse; -- 地面塌陷
create or replace trigger fn_g_ground_collapse_trigger before insert on bs.g_ground_collapse for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_g_highandsteep_slope_trigger on bs.g_highandsteep_slope; -- 高陡边坡
create or replace trigger fn_g_highandsteep_slope_trigger before insert on bs.g_highandsteep_slope for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_g_landslide_trigger on bs.g_landslide; -- 滑坡
create or replace trigger fn_g_landslide_trigger before insert on bs.g_landslide for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_g_unstable_slope_trigger on bs.g_unstable_slope; -- 不稳定斜坡
create or replace trigger fn_g_unstable_slope_trigger before insert on bs.g_unstable_slope for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_g_water_damage_trigger on bs.g_water_damage; -- 水毁
create or replace trigger fn_g_water_damage_trigger before insert on bs.g_water_damage for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_u_underground_hm_trigger on bs.u_underground_hydrological_monitoring; -- 地下水文监测
create or replace trigger fn_u_underground_hm_trigger before insert on bs.u_underground_hydrological_monitoring for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_u_sectionline_trigger on bs.u_sectionline; -- 工程地质剖面线
create or replace trigger fn_u_sectionline_trigger before insert on bs.u_sectionline for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_m_detaction_pipelinepoint_trigger on bs.m_detaction_pipelinepoint; -- 地下管线探测成果表
create or replace trigger fn_m_detaction_pipelinepoint_trigger before insert on bs.m_detaction_pipelinepoint for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_m_equipment_nameplate_trigger on bs.m_equipment_nameplate; -- 设备铭牌
create or replace trigger fn_m_equipment_nameplate_trigger before insert on bs.m_equipment_nameplate for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_m_geocontrolpoint_trigger on bs.m_geocontrolpoint; -- 控制点表
create or replace trigger fn_m_geocontrolpoint_trigger before insert on bs.m_geocontrolpoint for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_m_groundline_trigger on bs.m_groundline; -- 地面线表
create or replace trigger fn_m_groundline_trigger before insert on bs.m_groundline for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_m_pipelinepoint_trigger on bs.m_pipelinepoint; -- 中线成果表
create or replace trigger fn_m_pipelinepoint_trigger before insert on bs.m_pipelinepoint for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_m_poi_trigger on bs.m_poi; -- 兴趣点
create or replace trigger fn_m_poi_trigger before insert on bs.m_poi for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_m_scatterpoint_trigger on bs.m_scatterpoint; -- 离散点表
create or replace trigger fn_m_scatterpoint_trigger before insert on bs.m_scatterpoint for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_m_surface_deformation_data_trigger on bs.m_surface_deformation_data; -- 地表形变数据表
create or replace trigger fn_m_surface_deformation_data_trigger before insert on bs.m_surface_deformation_data for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_s_explorationpoint_trigger on bs.s_explorationpoint; -- 勘探点表
create or replace trigger fn_s_explorationpoint_trigger before insert on bs.s_explorationpoint for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_s_surveyworksite_trigger on bs.s_surveyworksite; -- 勘察工点
create or replace trigger fn_s_surveyworksitet_trigger before insert on bs.s_surveyworksite for each row execute procedure fn_bs_prj();
-- drop trigger if exists fn_s_survey_information_trigger on bs.s_survey_information; -- 勘察信息表
create or replace trigger fn_s_survey_information_trigger before insert on bs.s_survey_information for each row execute procedure fn_bs_prj();
select gid,projname,eventid,pipename,dirid from bs.m_pipeline order by gid desc;
/* insert into bs.m_pipeline (eventid,pipename,dirid) values (new_guid(),'Test','01'); delete from bs.m_pipeline where gid > 52; */
src/main/java/com/lf/server/entity/ctrl/RegisterEntity.java
@@ -15,7 +15,6 @@
    public RegisterEntity(String name, String uri, String type) {
        tags = new ArrayList<>();
        tags.add(name);
        tags.add(type);
        this.name = name;
src/main/java/com/lf/server/service/data/UploadService.java
@@ -69,7 +69,6 @@
        excelLoader(list, req);
        loadData(list);
        copyFiles(list);
        // publishFiles(list)
        insertMetas(list);
    }
@@ -128,7 +127,7 @@
            if (null != mf.getMsg()) {
                continue;
            }
            if (StaticData.XLS.equals(mf.getExtName()) || StaticData.XLSX.equals(mf.getExtName())) {
            if (StaticData.XLS.equals(mf.getExtName()) || StaticData.XLSX.equals(mf.getExtName()) || mf.getName().contains("WBS")) {
                xlsList.add(mf);
            }
        }