管道基础大数据平台系统开发-【后端】-Server
上一版本: 8a28d491 | 补丁 | 提交 | 忽略空白
1
13693261870
2023-01-12 607b050250e7ad092a2f91a1e274bea165062829 
1
已修改2个文件
90 ■■■■■ 文件已修改
data/db_fn.sql 50 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
data/日报.txt 40 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 
 data/db_fn.sql


@@ -1,4 +1,4 @@


----------------------------------------------------------------------------------------------------- 0.查询连接数


----------------------------------------------------------------------------------------------------- a.查询连接数


show max_connections;


select count(1) from pg_stat_activity;




@@ -13,7 +13,7 @@


inner join pg_type on pg_type.oid = pg_attribute.atttypid where pg_class.relname = 'sys_user' and pg_constraint.contype='p';




st_length( st_geographyfromtext( st_astext( st_intersection( ST_MakeValid(a.geom), ST_MakeValid(b.geom) ) ) ) ) AS acrossLength


----------------------------------------------------------------------------------------------------- a.递归查询


----------------------------------------------------------------------------------------------------- b.递归查询


with recursive rs as(


  select * from lf.sys_menu where cn_name='管道基础大数据平台'


union


@@ -31,7 +31,7 @@


union


  select a.* from lf.sys_dir a, rs b where a.pid=b.id


) select * FROM rs order by order_num; -- æ•°æ®ç›®å½•


----------------------------------------------------------------------------------------------------- b.查询表结构


----------------------------------------------------------------------------------------------------- c.查询表结构


select * from pg_tables; select * from pg_class order by relnamespace;


select relnamespace,relkind,relname from pg_class where relnamespace in (select oid from pg_namespace) and relkind='r' order by 1,2;




@@ -41,7 +41,7 @@


left join pg_class c on a.attrelid = c.oid left join pg_type t on a.atttypid = t.oid


where a.attnum >= 0 and c.relname like 'sys_%' and obj_description(c.oid) is not null --and relnamespace=20582


order by c.relname desc, a.attnum asc; 


----------------------------------------------------------------------------------------------------- c.GUID生成函数


----------------------------------------------------------------------------------------------------- d.GUID生成函数


create or replace function new_guid()


returns "pg_catalog"."varchar" as $body$


declare


@@ -59,7 +59,7 @@


$body$ language 'plpgsql' volatile security definer;




select new_guid();


----------------------------------------------------------------------------------------------------- d.递归查询函数


----------------------------------------------------------------------------------------------------- e.递归查询函数


-- drop function rec_query_dep(id integer, tab varchar);


create or replace function fn_rec_query(id integer, tab varchar)


returns varchar as $$


@@ -89,7 +89,7 @@




select fn_rec_query(1, 'dep'); select fn_rec_query(21, 'dep'); select fn_rec_query(null, 'dep');


select fn_rec_query(10, 'dir'); select fn_rec_query(28, 'dir');


----------------------------------------------------------------------------------------------------- e.查询用户名


----------------------------------------------------------------------------------------------------- f.查询用户名


-- execute format('select uname from lf.sys_user where id = %s', id) into str;


-- drop function fn_uname(id integer);


create or replace function fn_uname(id integer)


@@ -108,7 +108,7 @@


$$ language plpgsql;




select fn_uname(null); select fn_uname(1);


----------------------------------------------------------------------------------------------------- e.查询版本名


----------------------------------------------------------------------------------------------------- g.查询版本名


-- drop function fn_ver(id integer);


create or replace function fn_ver(id integer)


returns varchar as $$


@@ -126,7 +126,7 @@


$$ language plpgsql;




select fn_ver(0);


----------------------------------------------------------------------------------------------------- f.递归查询ID数组


----------------------------------------------------------------------------------------------------- h.递归查询ID数组


-- drop function fn_rec_array(id integer, tab varchar);


create or replace function fn_rec_array(id integer, tab varchar)


returns integer[] as $$


@@ -148,7 +148,7 @@




select fn_rec_array(1, 'dep'); select fn_rec_array(10, 'dir');


select * from lf.sys_user a where a.depid=ANY(fn_rec_array(15,'dep'));


----------------------------------------------------------------------------------------------------- g.获取实体名


----------------------------------------------------------------------------------------------------- i.获取实体名


create or replace function fn_get_entity(tab varchar)


returns varchar as $$


  declare


@@ -179,8 +179,26 @@


  end;


$$ language plpgsql;




select fn_get_entity('dlg_25w_boua_s'); select fn_get_entity('dlg_25w_vega'); 


----------------------------------------------------------------------------------------------------- h.索引


select fn_get_entity('dlg_25w_boua_s'); select fn_get_entity('dlg_25w_vega');


----------------------------------------------------------------------------------------------------- j.FME日志触发器


create 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;


	


    return new;


  end;


$$ language plpgsql;




select * from lf.sys_meta;




select id,eventid,name,tab,rows,dirid,depid,verid,create_user,create_time from lf.sys_meta where eventid='8fb3c3dd-6a12-488d-80ae-a93cc7e8b2e3';


select * from lf.sys_fme_log where tcmc = '中线成果表';


insert into lf.sys_fme_log (parentid,dirpath,pg_ns,tcmc,tcdm,count) values ('8fb3c3dd-6a12-488d-80ae-a93cc7e8b2e3','','bs','中线成果表','m_pipelinepoint',0);


select * from bs.m_pipelinepoint where parentid='8fb3c3dd-6a12-488d-80ae-a93cc7e8b2e3';


----------------------------------------------------------------------------------------------------- k.索引


alter table lf.sys_role_user add constraint idx_unique_role_user unique (roleid, userid); -- è”合唯一索引


insert into lf.sys_role_user (roleid,userid) values (1,1); -- æµ‹è¯•


select * from lf.sys_role_user;


@@ -196,7 +214,7 @@


alter table lf.sys_role_menu_auth add constraint idx_unique_role_menu_auth unique (roleid,menu_auth_id); -- è”合唯一索引


insert into lf.sys_role_menu_auth (roleid,menu_auth_id) values (1,1);


select * from lf.sys_role_menu_auth;


----------------------------------------------------------------------------------------------------- i.联合查询


----------------------------------------------------------------------------------------------------- l.联合查询


select a.*,fn_uname(a.create_user) createUserName,fn_uname(a.update_user) updateUserName from lf.sys_blacklist a order by a.id;


select * from lf.sys_user a where uname like '%' and a.depid=ANY(fn_rec_array(1,'dep'));


select * from lf.sys_user a left join lf.sys_role_user b on a.id=b.userid;


@@ -223,7 +241,7 @@


update lf.sys_operate set modular1='运维管理',modular2='资源管理' where position('/res/select' in url)>0 and (modular1 is null or modular2 is null);




delete from lf.sys_operate where modular1 is null or modular2 is null;


----------------------------------------------------------------------------------------------------- j.查询授权


----------------------------------------------------------------------------------------------------- m.查询授权


select gid,gb,name,st_astext(a.geom) from bd.dlg_agnp a;




-- æ ¹æ®ç”¨æˆ·Uid查询资源


@@ -257,7 +275,7 @@


inner join lf.sys_menu e on d.menuid = e.id


inner join lf.sys_auth f on d.authid = f.id


where a.uid = 'admin';


---------------------------------------------------------------------------------------------- k.数据统计 


---------------------------------------------------------------------------------------------- n.数据统计 


select modular2,count(*) from lf.sys_operate group by modular2;




select to_char(optime,'yyyy-mm-dd') as optime,count(*) from lf.sys_login where optime between (select optime - interval '30 day')


@@ -293,7 +311,7 @@




select a.* from lf.sys_domain a where exists (select * from lf.sys_dict b where b.ns = 'bd' and b.tab = 'dlg_25w_hyda') and a.dom_code like '210%' order by a.id


select * from lf.sys_download a where create_user = 1 and type = 2;


----------------------------------------------------------------------------------------------


---------------------------------------------------------------------------------------------- o.查询空间数据


select to_char(create_time, 'yyyy-mm-dd hh24:mi:ss') from lf.sys_meta;


select to_timestamp('2018-08-15 12:10:10', 'yyyy-MM-dd hh24:mi:ss');


select a.*,fn_uname(a.create_user) uname from lf.sys_token a


@@ -329,7 +347,7 @@


select * from lf.sys_meta_file a where metaid in (113,120,121,122);


alter sequence bd.dlg_agnp_gid_seq restart with 4000;


select max(gid) from  bd.dlg_agnp;


----------------------------------------------------------------------------------------------


---------------------------------------------------------------------------------------------- p.测试


select * from bd.dlg_25w_boul where gid<11; -- delete from bd.dlg_25w_boul where gid>10; alter sequence bd.dlg_25w_boul_gid_seq restart with 20;


select * from bd.dlg_25w_resa where gid<12; -- delete from bd.dlg_25w_resa where gid>11; alter sequence bd.dlg_25w_resa_gid_seq restart with 20;


select * from bd.dlg_agnp where gid<13;     -- delete from bd.dlg_agnp where gid>12;     alter sequence bd.dlg_agnp_gid_seq restart with 20;




 data/ÈÕ±¨.txt


@@ -371,4 +371,44 @@


2 æœåŠ¡å¼€å‘：


补充包2需要的应用接口


开发元数据入库接口


=========================================2023-01-12


本周：


1 Web开发：


1）综合展示：




2）数据管理




2 æœåŠ¡å¼€å‘：


2.1 ç®¡é“分析添加将分析结果导出GDB，再打包下载功能


2.2 ç®¡é“分析添加分页查询下载文件、下载文件接口


2.3 ä¼˜åŒ–获取文件MD5方法，以提升获取速度


2.4 å¯¹æŽ¥FME的12类数据质检接口


2.5 å¯¹æŽ¥FME的获取任务状态、质检结果下载接口


2.6 å¼€å‘提交数据质检接口


2.7 ä¿®æ”¹å…¥åº“元数据表结构，根据新结构调整入库流程


2.8 ä¿®æ”¹å•ä½é€’归函数和数据字典，解决数据检索里部分表查询失败


2.9 ç¼–排数据目录及示例数据结构给FME提供数据打包环境


2.10 è§£å†³FME的接口调用异常、令牌无效等问题




3 ç³»ç»Ÿå‘布：


3.1 åœ¨æ›´æ–°å‘布系统


3.2 è§£å†³GDB操作驱动为空


3.3 è§£å†³QGIS+GeoServer部署出错




下周：


1 Web开发：


修改综合展示页面


完成数据上传功能


完善元数据管理功能


完善数据检索功能


完善权限管理及授权功能




2 æœåŠ¡å¼€å‘：


修改元数据打包功能


完善GDB数据写入功能


完善FME接口的对接




3.系统发布：


在公网环境下部署系统


部署SG的打包、下载环境


=========================================