|
|
@@ -0,0 +1,628 @@
|
|
|
+CREATE OR REPLACE FUNCTION app_screen.a_pm_4g_poor_cell_day(vi_date character varying)
|
|
|
+ RETURNS text
|
|
|
+ LANGUAGE plpgsql
|
|
|
+AS $function$
|
|
|
+ DECLARE
|
|
|
+ v_date timestamp;
|
|
|
+ v_next_day timestamp;
|
|
|
+ v_befor_day timestamp;
|
|
|
+ v_befor1_day timestamp;
|
|
|
+ v_befor2_day timestamp;
|
|
|
+ v_befor3_day timestamp;
|
|
|
+ v_befor4_day timestamp;
|
|
|
+ v_befor5_day timestamp;
|
|
|
+
|
|
|
+ v_befor_day_s varchar;
|
|
|
+ v_befor1_day_s varchar;
|
|
|
+ v_befor2_day_s varchar;
|
|
|
+ v_befor3_day_s varchar;
|
|
|
+ v_befor4_day_s varchar;
|
|
|
+ v_befor5_day_s varchar;
|
|
|
+
|
|
|
+ v_begin_time timestamp;
|
|
|
+ v_sql text;
|
|
|
+BEGIN
|
|
|
+ v_date := vi_date::timestamp;
|
|
|
+ v_next_day := vi_date::timestamp + '1 day'::interval;
|
|
|
+ v_befor_day := vi_date::timestamp + '-1 day'::interval;
|
|
|
+ v_befor1_day := vi_date::timestamp + '-2 day'::interval;
|
|
|
+ v_befor2_day := vi_date::timestamp + '-3 day'::interval;
|
|
|
+ v_befor3_day := vi_date::timestamp + '-4 day'::interval;
|
|
|
+ v_befor4_day := vi_date::timestamp + '-5 day'::interval;
|
|
|
+ v_befor5_day := vi_date::timestamp + '-6 day'::interval;
|
|
|
+
|
|
|
+ v_befor_day_s := replace(date(vi_date::timestamp + '-1 day'::interval)::varchar,'-','');
|
|
|
+ v_befor1_day_s := replace(date(vi_date::timestamp + '-2 day'::interval)::varchar,'-','');
|
|
|
+ v_befor2_day_s := replace(date(vi_date::timestamp + '-3 day'::interval)::varchar,'-','');
|
|
|
+ v_befor3_day_s := replace(date(vi_date::timestamp + '-4 day'::interval)::varchar,'-','');
|
|
|
+ v_befor4_day_s := replace(date(vi_date::timestamp + '-5 day'::interval)::varchar,'-','');
|
|
|
+ v_befor5_day_s := replace(date(vi_date::timestamp + '-6 day'::interval)::varchar,'-','');
|
|
|
+
|
|
|
+
|
|
|
+ v_begin_time := clock_timestamp();
|
|
|
+
|
|
|
+
|
|
|
+/*
|
|
|
+ *
|
|
|
+ *
|
|
|
+ *联通部分共建共享统计
|
|
|
+ *
|
|
|
+ *
|
|
|
+ *
|
|
|
+*/
|
|
|
+
|
|
|
+-- 取联通区县信息
|
|
|
+v_sql := 'drop table if exists a_pm_4g_poor_cell_day_tmp01';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'create temporary table a_pm_4g_poor_cell_day_tmp01
|
|
|
+(
|
|
|
+city varchar
|
|
|
+,county varchar
|
|
|
+,vendor varchar
|
|
|
+,eci varchar
|
|
|
+,cell_name varchar
|
|
|
+)';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'insert into a_pm_4g_poor_cell_day_tmp01
|
|
|
+select
|
|
|
+a.city
|
|
|
+,a.county
|
|
|
+,b.vendor
|
|
|
+,b.eci
|
|
|
+,b.cellname
|
|
|
+from app_screen.county a
|
|
|
+left join pm_parse.per_cfg_cell b
|
|
|
+on a.city = replace(b.city,''市'','''') and a.county = b.quxian';
|
|
|
+execute v_sql;
|
|
|
+
|
|
|
+v_sql := 'drop table if exists a_pm_4g_poor_cell_day_tmp02';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'create temporary table a_pm_4g_poor_cell_day_tmp02
|
|
|
+(
|
|
|
+city varchar
|
|
|
+,county varchar
|
|
|
+,eci varchar
|
|
|
+,conn_suc_poor integer
|
|
|
+,lte_highdrop_poor integer
|
|
|
+,ho_out_suc_poor integer
|
|
|
+,volte_join_poor integer
|
|
|
+,volte_highdrop_poor integer
|
|
|
+,ul_pdcp_package_drop_poor integer
|
|
|
+,dl_pdcp_package_drop_poor integer
|
|
|
+)';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'insert into a_pm_4g_poor_cell_day_tmp02
|
|
|
+(
|
|
|
+city
|
|
|
+,county
|
|
|
+,eci
|
|
|
+,conn_suc_poor
|
|
|
+,lte_highdrop_poor
|
|
|
+,ho_out_suc_poor
|
|
|
+,volte_join_poor
|
|
|
+,volte_highdrop_poor
|
|
|
+,ul_pdcp_package_drop_poor
|
|
|
+,dl_pdcp_package_drop_poor
|
|
|
+)
|
|
|
+select
|
|
|
+a.city
|
|
|
+,a.county
|
|
|
+,a.eci
|
|
|
+,count(distinct case when radio_conn_suc_r <= 0.9 and rrc_suc > 1000 then sdate end) conn_suc_poor
|
|
|
+,count(distinct case when lte_drop_r >= 2 and lte_drop > 1000 then sdate end) lte_highdrop_poor
|
|
|
+,count(distinct case when ho_out_suc_r <= 0.9 and (s1_ho_out_req+x2_ho_out_req) > 500 then sdate end) ho_out_suc_poor
|
|
|
+,count(distinct case when erab_suc_r_qci1 < 0.98 or erab_suc_r_qci5 < 0.98 then sdate end) volte_join_poor
|
|
|
+,count(distinct case when lte_drop_r_qci1 > 0.01 then sdate end) volte_highdrop_poor
|
|
|
+,count(distinct case when ul_pdcp_package_drop_ratio_qci1 > 0.01 then sdate end) ul_pdcp_package_drop_poor
|
|
|
+,count(distinct case when dl_pdcp_package_drop_ratio_qci1 > 0.01 then sdate end) dl_pdcp_package_drop_poor
|
|
|
+from a_pm_4g_poor_cell_day_tmp01 a
|
|
|
+join pm_parse.pm_4g_day b
|
|
|
+on b.sdate >= '''|| v_date ||'''::timestamp - ''6 day''::interval and b.sdate < '''|| v_date ||'''::timestamp + ''1 day''::interval
|
|
|
+and b.isp = ''联通'' and b.share = ''是''
|
|
|
+and a.eci = b.eci
|
|
|
+group by a.city,a.county,a.eci';
|
|
|
+execute v_sql;
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+v_sql := 'drop table if exists busy_info';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'create temporary table busy_info
|
|
|
+(
|
|
|
+sdate timestamp
|
|
|
+,eci varchar
|
|
|
+,total_tra_mb numeric
|
|
|
+)';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'insert into busy_info
|
|
|
+select
|
|
|
+date(sdate),eci,max(total_tra_mb)
|
|
|
+from pm_parse.pm_4g_hour b
|
|
|
+where b.sdate >= '''|| v_date ||'''::timestamp - ''6 day''::interval and b.sdate < '''|| v_date ||'''::timestamp + ''1 day''::interval
|
|
|
+and b.isp = ''联通'' and b.share = ''是''
|
|
|
+group by date(sdate),eci';
|
|
|
+execute v_sql;
|
|
|
+
|
|
|
+
|
|
|
+v_sql := 'drop table if exists a_pm_4g_poor_cell_day_tmp03';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'create temporary table a_pm_4g_poor_cell_day_tmp03
|
|
|
+(
|
|
|
+eci varchar
|
|
|
+,cqi_poor integer
|
|
|
+,highload_prb integer
|
|
|
+,low_speed_mbps integer
|
|
|
+)';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'insert into a_pm_4g_poor_cell_day_tmp03
|
|
|
+(
|
|
|
+eci
|
|
|
+,cqi_poor
|
|
|
+,highload_prb
|
|
|
+,low_speed_mbps
|
|
|
+)
|
|
|
+select
|
|
|
+eci
|
|
|
+,case when sum(cqi_ge7)/7 > 0.2 then 1 else 0 end
|
|
|
+,case when avg(dl_prb_utilization) > 0.65 then 1 else 0 end
|
|
|
+,case when avg(dl_speed_mbps) < 5 then 1 else 0 end
|
|
|
+from (
|
|
|
+select
|
|
|
+t.sdate
|
|
|
+,t.eci
|
|
|
+,1-t.cqi_ge7 cqi_ge7
|
|
|
+,t.dl_prb_utilization
|
|
|
+,dl_speed_mbps
|
|
|
+,row_number() over (partition by a.sdate,a.eci order by t.sdate desc) rn
|
|
|
+from pm_parse.pm_4g_hour_'|| v_befor5_day_s ||' t
|
|
|
+join busy_info a
|
|
|
+on a.sdate = '''|| v_befor5_day ||'''
|
|
|
+and t.eci = a.eci
|
|
|
+and t.total_tra_mb = a.total_tra_mb
|
|
|
+and t.isp = ''联通'' and t.share = ''是''
|
|
|
+union all
|
|
|
+select
|
|
|
+t.sdate
|
|
|
+,t.eci
|
|
|
+,1-t.cqi_ge7
|
|
|
+,t.dl_prb_utilization
|
|
|
+,dl_speed_mbps
|
|
|
+,row_number() over (partition by a.sdate,a.eci order by t.sdate desc) rn
|
|
|
+from pm_parse.pm_4g_hour_'|| v_befor4_day_s ||' t
|
|
|
+join busy_info a
|
|
|
+on a.sdate = '''|| v_befor4_day ||'''
|
|
|
+and t.eci = a.eci
|
|
|
+and t.total_tra_mb = a.total_tra_mb
|
|
|
+and t.isp = ''联通'' and t.share = ''是''
|
|
|
+union all
|
|
|
+select
|
|
|
+t.sdate
|
|
|
+,t.eci
|
|
|
+,1-t.cqi_ge7
|
|
|
+,t.dl_prb_utilization
|
|
|
+,dl_speed_mbps
|
|
|
+,row_number() over (partition by a.sdate,a.eci order by t.sdate desc) rn
|
|
|
+from pm_parse.pm_4g_hour_'|| v_befor3_day_s ||' t
|
|
|
+join busy_info a
|
|
|
+on a.sdate = '''|| v_befor3_day ||'''
|
|
|
+and t.eci = a.eci
|
|
|
+and t.total_tra_mb = a.total_tra_mb
|
|
|
+and t.isp = ''联通'' and t.share = ''是''
|
|
|
+union all
|
|
|
+select
|
|
|
+t.sdate
|
|
|
+,t.eci
|
|
|
+,1-t.cqi_ge7
|
|
|
+,t.dl_prb_utilization
|
|
|
+,dl_speed_mbps
|
|
|
+,row_number() over (partition by a.sdate,a.eci order by t.sdate desc) rn
|
|
|
+from pm_parse.pm_4g_hour_'|| v_befor2_day_s ||' t
|
|
|
+join busy_info a
|
|
|
+on a.sdate = '''|| v_befor2_day ||'''
|
|
|
+and t.eci = a.eci
|
|
|
+and t.total_tra_mb = a.total_tra_mb
|
|
|
+and t.isp = ''联通'' and t.share = ''是''
|
|
|
+union all
|
|
|
+select
|
|
|
+t.sdate
|
|
|
+,t.eci
|
|
|
+,1-t.cqi_ge7
|
|
|
+,t.dl_prb_utilization
|
|
|
+,dl_speed_mbps
|
|
|
+,row_number() over (partition by a.sdate,a.eci order by t.sdate desc) rn
|
|
|
+from pm_parse.pm_4g_hour_'|| v_befor1_day_s ||' t
|
|
|
+join busy_info a
|
|
|
+on a.sdate = '''|| v_befor1_day ||'''
|
|
|
+and t.eci = a.eci
|
|
|
+and t.total_tra_mb = a.total_tra_mb
|
|
|
+and t.isp = ''联通'' and t.share = ''是''
|
|
|
+union all
|
|
|
+select
|
|
|
+t.sdate
|
|
|
+,t.eci
|
|
|
+,1-t.cqi_ge7
|
|
|
+,t.dl_prb_utilization
|
|
|
+,dl_speed_mbps
|
|
|
+,row_number() over (partition by a.sdate,a.eci order by t.sdate desc) rn
|
|
|
+from pm_parse.pm_4g_hour_'|| v_befor_day_s ||' t
|
|
|
+join busy_info a
|
|
|
+on a.sdate = '''|| v_befor_day ||'''
|
|
|
+and t.eci = a.eci
|
|
|
+and t.total_tra_mb = a.total_tra_mb
|
|
|
+and t.isp = ''联通'' and t.share = ''是''
|
|
|
+union all
|
|
|
+select
|
|
|
+t.sdate
|
|
|
+,t.eci
|
|
|
+,1-t.cqi_ge7
|
|
|
+,t.dl_prb_utilization
|
|
|
+,dl_speed_mbps
|
|
|
+,row_number() over (partition by a.sdate,a.eci order by t.sdate desc) rn
|
|
|
+from pm_parse.pm_4g_hour_'|| vi_date ||' t
|
|
|
+join busy_info a
|
|
|
+on a.sdate = '''|| v_date ||'''
|
|
|
+and t.eci = a.eci
|
|
|
+and t.total_tra_mb = a.total_tra_mb
|
|
|
+and t.isp = ''联通'' and t.share = ''是''
|
|
|
+) tb
|
|
|
+where tb.rn = 1
|
|
|
+group by eci';
|
|
|
+execute v_sql;
|
|
|
+
|
|
|
+
|
|
|
+--删除当期数据
|
|
|
+v_sql := 'delete from app_screen.a_pm_4g_poor_cell_day where sdate = '''|| v_date ||'''';
|
|
|
+execute v_sql;
|
|
|
+
|
|
|
+-- 插入目标数据
|
|
|
+v_sql := 'insert into app_screen.a_pm_4g_poor_cell_day
|
|
|
+(
|
|
|
+sdate
|
|
|
+,city
|
|
|
+,county
|
|
|
+,operators
|
|
|
+,share_cell_num
|
|
|
+,conn_suc_poor
|
|
|
+,lte_highdrop_poor
|
|
|
+,cqi_poor
|
|
|
+,low_speed_mbps
|
|
|
+,ho_out_suc_poor
|
|
|
+,volte_join_poor
|
|
|
+,volte_highdrop_poor
|
|
|
+,ul_pdcp_package_drop_poor
|
|
|
+,dl_pdcp_package_drop_poor
|
|
|
+,highload_prb
|
|
|
+,poor_cell_num
|
|
|
+,poor_cell_ratio
|
|
|
+)
|
|
|
+select
|
|
|
+'''|| v_date ||''' sdate
|
|
|
+,coalesce(a.city,''合计'')
|
|
|
+,coalesce(a.county,''合计'')
|
|
|
+,''联通'' operators
|
|
|
+,count(distinct b.eci) share_cell_num
|
|
|
+,sum(case when b.conn_suc_poor >= 3 then 1 else 0 end)
|
|
|
+,sum(case when b.lte_highdrop_poor >= 3 then 1 else 0 end)
|
|
|
+,sum(c.cqi_poor)
|
|
|
+,sum(c.low_speed_mbps)
|
|
|
+,sum(case when b.ho_out_suc_poor >= 3 then 1 else 0 end)
|
|
|
+,sum(case when b.volte_join_poor >= 3 then 1 else 0 end)
|
|
|
+,sum(case when b.volte_highdrop_poor >= 3 then 1 else 0 end)
|
|
|
+,sum(case when b.ul_pdcp_package_drop_poor >= 3 then 1 else 0 end)
|
|
|
+,sum(case when b.dl_pdcp_package_drop_poor >= 3 then 1 else 0 end)
|
|
|
+,sum(c.highload_prb)
|
|
|
+,count(distinct case when b.conn_suc_poor >= 3 or b.lte_highdrop_poor >= 3 or b.ho_out_suc_poor >= 3 or b.volte_join_poor >= 3
|
|
|
+ or b.volte_highdrop_poor >= 3 or b.ul_pdcp_package_drop_poor >= 3 or b.dl_pdcp_package_drop_poor >= 3
|
|
|
+ or c.cqi_poor = 1 or c.low_speed_mbps = 1 then b.eci end) poor_cell_num
|
|
|
+,count(distinct case when b.conn_suc_poor >= 3 or b.lte_highdrop_poor >= 3 or b.ho_out_suc_poor >= 3 or b.volte_join_poor >= 3
|
|
|
+ or b.volte_highdrop_poor >= 3 or b.ul_pdcp_package_drop_poor >= 3 or b.dl_pdcp_package_drop_poor >= 3
|
|
|
+ or c.cqi_poor = 1 or c.low_speed_mbps = 1 then b.eci end)*1.0/count(distinct b.eci)*100 poor_cell_ratio
|
|
|
+from a_pm_4g_poor_cell_day_tmp01 a
|
|
|
+join a_pm_4g_poor_cell_day_tmp02 b
|
|
|
+on a.eci = b.eci
|
|
|
+left join a_pm_4g_poor_cell_day_tmp03 c
|
|
|
+on b.eci = c.eci
|
|
|
+group by
|
|
|
+grouping sets((),(a.city),(a.city,a.county))';
|
|
|
+execute v_sql;
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+/*
|
|
|
+ *
|
|
|
+ *
|
|
|
+ *电信部分共建共享统计
|
|
|
+ *
|
|
|
+ *
|
|
|
+ *
|
|
|
+*/
|
|
|
+-- 电信小区区县信息表
|
|
|
+v_sql := 'drop table if exists a_pm_4g_poor_cell_day_tmp04';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'create temporary table a_pm_4g_poor_cell_day_tmp04
|
|
|
+(
|
|
|
+city varchar
|
|
|
+,county varchar
|
|
|
+,vendor varchar
|
|
|
+,enbid integer
|
|
|
+,cellid integer
|
|
|
+,eci varchar
|
|
|
+,cell_name varchar
|
|
|
+)';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'insert into a_pm_4g_poor_cell_day_tmp04
|
|
|
+(
|
|
|
+city
|
|
|
+,county
|
|
|
+,vendor
|
|
|
+,enbid
|
|
|
+,cellid
|
|
|
+,eci
|
|
|
+,cell_name
|
|
|
+)
|
|
|
+select
|
|
|
+city
|
|
|
+,county
|
|
|
+,vendor
|
|
|
+,enbid
|
|
|
+,cellid
|
|
|
+,''127.''||enbid||''.''||cellid
|
|
|
+,cell_name
|
|
|
+from pm_parse.pm_ct_cell_info_4g';
|
|
|
+execute v_sql;
|
|
|
+
|
|
|
+v_sql := 'drop table if exists a_pm_4g_poor_cell_day_tmp05';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'create temporary table a_pm_4g_poor_cell_day_tmp05
|
|
|
+(
|
|
|
+city varchar
|
|
|
+,county varchar
|
|
|
+,eci varchar
|
|
|
+,conn_suc_poor integer
|
|
|
+,lte_highdrop_poor integer
|
|
|
+,ho_out_suc_poor integer
|
|
|
+,volte_join_poor integer
|
|
|
+,volte_highdrop_poor integer
|
|
|
+,ul_pdcp_package_drop_poor integer
|
|
|
+,dl_pdcp_package_drop_poor integer
|
|
|
+)';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'insert into a_pm_4g_poor_cell_day_tmp05
|
|
|
+(
|
|
|
+city
|
|
|
+,county
|
|
|
+,eci
|
|
|
+,conn_suc_poor
|
|
|
+,lte_highdrop_poor
|
|
|
+,ho_out_suc_poor
|
|
|
+,volte_join_poor
|
|
|
+,volte_highdrop_poor
|
|
|
+,ul_pdcp_package_drop_poor
|
|
|
+,dl_pdcp_package_drop_poor
|
|
|
+)
|
|
|
+select
|
|
|
+a.city
|
|
|
+,a.county
|
|
|
+,a.eci
|
|
|
+,count(distinct case when radio_conn_suc_r <= 0.9 and rrc_suc > 1000 then sdate end) conn_suc_poor
|
|
|
+,count(distinct case when lte_drop_r >= 2 and lte_drop > 1000 then sdate end) lte_highdrop_poor
|
|
|
+,count(distinct case when ho_out_suc_r <= 0.9 and (s1_ho_out_req+x2_ho_out_req) > 500 then sdate end) ho_out_suc_poor
|
|
|
+,count(distinct case when erab_suc_r_qci1 < 0.98 or erab_suc_r_qci5 < 0.98 then sdate end) volte_join_poor
|
|
|
+,count(distinct case when lte_drop_r_qci1 > 0.01 then sdate end) volte_highdrop_poor
|
|
|
+,count(distinct case when ul_pdcp_package_drop_ratio_qci1 > 0.01 then sdate end) ul_pdcp_package_drop_poor
|
|
|
+,count(distinct case when dl_pdcp_package_drop_ratio_qci1 > 0.01 then sdate end) dl_pdcp_package_drop_poor
|
|
|
+from a_pm_4g_poor_cell_day_tmp04 a
|
|
|
+join pm_parse.pm_4g_day b
|
|
|
+on b.sdate >= '''|| v_date ||'''::timestamp - ''6 day''::interval and b.sdate < '''|| v_date ||'''::timestamp + ''1 day''::interval
|
|
|
+and b.isp = ''电信''
|
|
|
+and a.eci = b.eci
|
|
|
+group by a.city,a.county,a.eci';
|
|
|
+execute v_sql;
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+v_sql := 'drop table if exists busy_info_ct';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'create temporary table busy_info_ct
|
|
|
+(
|
|
|
+sdate timestamp
|
|
|
+,eci varchar
|
|
|
+,total_tra_mb numeric
|
|
|
+)';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'insert into busy_info_ct
|
|
|
+select
|
|
|
+date(sdate),eci,max(total_tra_mb)
|
|
|
+from pm_parse.pm_4g_hour b
|
|
|
+where b.sdate >= '''|| v_date ||'''::timestamp - ''6 day''::interval and b.sdate < '''|| v_date ||'''::timestamp + ''1 day''::interval
|
|
|
+and b.isp = ''电信''
|
|
|
+group by date(sdate),eci';
|
|
|
+execute v_sql;
|
|
|
+
|
|
|
+
|
|
|
+v_sql := 'drop table if exists a_pm_4g_poor_cell_day_tmp06';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'create temporary table a_pm_4g_poor_cell_day_tmp06
|
|
|
+(
|
|
|
+eci varchar
|
|
|
+,cqi_poor integer
|
|
|
+,highload_prb integer
|
|
|
+,low_speed_mbps integer
|
|
|
+)';
|
|
|
+execute v_sql;
|
|
|
+v_sql := 'insert into a_pm_4g_poor_cell_day_tmp06
|
|
|
+(
|
|
|
+eci
|
|
|
+,cqi_poor
|
|
|
+,highload_prb
|
|
|
+,low_speed_mbps
|
|
|
+)
|
|
|
+select
|
|
|
+eci
|
|
|
+,case when sum(cqi_ge7)/7 > 0.2 then 1 else 0 end
|
|
|
+,case when avg(dl_prb_utilization) > 0.65 then 1 else 0 end
|
|
|
+,case when avg(dl_speed_mbps) < 5 then 1 else 0 end
|
|
|
+from (
|
|
|
+select
|
|
|
+t.sdate
|
|
|
+,t.eci
|
|
|
+,1-t.cqi_ge7 cqi_ge7
|
|
|
+,t.dl_prb_utilization
|
|
|
+,dl_speed_mbps
|
|
|
+,row_number() over (partition by a.sdate,a.eci order by t.sdate desc) rn
|
|
|
+from pm_parse.pm_4g_hour_'|| v_befor5_day_s ||' t
|
|
|
+join busy_info_ct a
|
|
|
+on a.sdate = '''|| v_befor5_day ||'''
|
|
|
+and t.eci = a.eci
|
|
|
+and t.total_tra_mb = a.total_tra_mb
|
|
|
+and t.isp = ''电信''
|
|
|
+union all
|
|
|
+select
|
|
|
+t.sdate
|
|
|
+,t.eci
|
|
|
+,1-t.cqi_ge7
|
|
|
+,t.dl_prb_utilization
|
|
|
+,dl_speed_mbps
|
|
|
+,row_number() over (partition by a.sdate,a.eci order by t.sdate desc) rn
|
|
|
+from pm_parse.pm_4g_hour_'|| v_befor4_day_s ||' t
|
|
|
+join busy_info_ct a
|
|
|
+on a.sdate = '''|| v_befor4_day ||'''
|
|
|
+and t.eci = a.eci
|
|
|
+and t.total_tra_mb = a.total_tra_mb
|
|
|
+and t.isp = ''电信''
|
|
|
+union all
|
|
|
+select
|
|
|
+t.sdate
|
|
|
+,t.eci
|
|
|
+,1-t.cqi_ge7
|
|
|
+,t.dl_prb_utilization
|
|
|
+,dl_speed_mbps
|
|
|
+,row_number() over (partition by a.sdate,a.eci order by t.sdate desc) rn
|
|
|
+from pm_parse.pm_4g_hour_'|| v_befor3_day_s ||' t
|
|
|
+join busy_info_ct a
|
|
|
+on a.sdate = '''|| v_befor3_day ||'''
|
|
|
+and t.eci = a.eci
|
|
|
+and t.total_tra_mb = a.total_tra_mb
|
|
|
+and t.isp = ''电信''
|
|
|
+union all
|
|
|
+select
|
|
|
+t.sdate
|
|
|
+,t.eci
|
|
|
+,1-t.cqi_ge7
|
|
|
+,t.dl_prb_utilization
|
|
|
+,dl_speed_mbps
|
|
|
+,row_number() over (partition by a.sdate,a.eci order by t.sdate desc) rn
|
|
|
+from pm_parse.pm_4g_hour_'|| v_befor2_day_s ||' t
|
|
|
+join busy_info_ct a
|
|
|
+on a.sdate = '''|| v_befor2_day ||'''
|
|
|
+and t.eci = a.eci
|
|
|
+and t.total_tra_mb = a.total_tra_mb
|
|
|
+and t.isp = ''电信''
|
|
|
+union all
|
|
|
+select
|
|
|
+t.sdate
|
|
|
+,t.eci
|
|
|
+,1-t.cqi_ge7
|
|
|
+,t.dl_prb_utilization
|
|
|
+,dl_speed_mbps
|
|
|
+,row_number() over (partition by a.sdate,a.eci order by t.sdate desc) rn
|
|
|
+from pm_parse.pm_4g_hour_'|| v_befor1_day_s ||' t
|
|
|
+join busy_info_ct a
|
|
|
+on a.sdate = '''|| v_befor1_day ||'''
|
|
|
+and t.eci = a.eci
|
|
|
+and t.total_tra_mb = a.total_tra_mb
|
|
|
+and t.isp = ''电信''
|
|
|
+union all
|
|
|
+select
|
|
|
+t.sdate
|
|
|
+,t.eci
|
|
|
+,1-t.cqi_ge7
|
|
|
+,t.dl_prb_utilization
|
|
|
+,dl_speed_mbps
|
|
|
+,row_number() over (partition by a.sdate,a.eci order by t.sdate desc) rn
|
|
|
+from pm_parse.pm_4g_hour_'|| v_befor_day_s ||' t
|
|
|
+join busy_info_ct a
|
|
|
+on a.sdate = '''|| v_befor_day ||'''
|
|
|
+and t.eci = a.eci
|
|
|
+and t.total_tra_mb = a.total_tra_mb
|
|
|
+and t.isp = ''电信''
|
|
|
+union all
|
|
|
+select
|
|
|
+t.sdate
|
|
|
+,t.eci
|
|
|
+,1-t.cqi_ge7
|
|
|
+,t.dl_prb_utilization
|
|
|
+,dl_speed_mbps
|
|
|
+,row_number() over (partition by a.sdate,a.eci order by t.sdate desc) rn
|
|
|
+from pm_parse.pm_4g_hour_'|| vi_date ||' t
|
|
|
+join busy_info_ct a
|
|
|
+on a.sdate = '''|| v_date ||'''
|
|
|
+and t.eci = a.eci
|
|
|
+and t.total_tra_mb = a.total_tra_mb
|
|
|
+and t.isp = ''电信''
|
|
|
+) tb
|
|
|
+where tb.rn = 1
|
|
|
+group by eci';
|
|
|
+execute v_sql;
|
|
|
+
|
|
|
+-- 插入目标数据
|
|
|
+v_sql := 'insert into app_screen.a_pm_4g_poor_cell_day
|
|
|
+(
|
|
|
+sdate
|
|
|
+,city
|
|
|
+,county
|
|
|
+,operators
|
|
|
+,share_cell_num
|
|
|
+,conn_suc_poor
|
|
|
+,lte_highdrop_poor
|
|
|
+,cqi_poor
|
|
|
+,low_speed_mbps
|
|
|
+,ho_out_suc_poor
|
|
|
+,volte_join_poor
|
|
|
+,volte_highdrop_poor
|
|
|
+,ul_pdcp_package_drop_poor
|
|
|
+,dl_pdcp_package_drop_poor
|
|
|
+,highload_prb
|
|
|
+,poor_cell_num
|
|
|
+,poor_cell_ratio
|
|
|
+)
|
|
|
+select
|
|
|
+'''|| v_date ||''' sdate
|
|
|
+,coalesce(a.city,''合计'')
|
|
|
+,coalesce(a.county,''合计'')
|
|
|
+,''电信'' operators
|
|
|
+,count(distinct b.eci) share_cell_num
|
|
|
+,sum(case when b.conn_suc_poor >= 3 then 1 else 0 end)
|
|
|
+,sum(case when b.lte_highdrop_poor >= 3 then 1 else 0 end)
|
|
|
+,sum(c.cqi_poor)
|
|
|
+,sum(c.low_speed_mbps)
|
|
|
+,sum(case when b.ho_out_suc_poor >= 3 then 1 else 0 end)
|
|
|
+,sum(case when b.volte_join_poor >= 3 then 1 else 0 end)
|
|
|
+,sum(case when b.volte_highdrop_poor >= 3 then 1 else 0 end)
|
|
|
+,sum(case when b.ul_pdcp_package_drop_poor >= 3 then 1 else 0 end)
|
|
|
+,sum(case when b.dl_pdcp_package_drop_poor >= 3 then 1 else 0 end)
|
|
|
+,sum(c.highload_prb)
|
|
|
+,count(distinct case when b.conn_suc_poor >= 3 or b.lte_highdrop_poor >= 3 or b.ho_out_suc_poor >= 3 or b.volte_join_poor >= 3
|
|
|
+ or b.volte_highdrop_poor >= 3 or b.ul_pdcp_package_drop_poor >= 3 or b.dl_pdcp_package_drop_poor >= 3
|
|
|
+ or c.cqi_poor = 1 or c.low_speed_mbps = 1 then b.eci end) poor_cell_num
|
|
|
+,count(distinct case when b.conn_suc_poor >= 3 or b.lte_highdrop_poor >= 3 or b.ho_out_suc_poor >= 3 or b.volte_join_poor >= 3
|
|
|
+ or b.volte_highdrop_poor >= 3 or b.ul_pdcp_package_drop_poor >= 3 or b.dl_pdcp_package_drop_poor >= 3
|
|
|
+ or c.cqi_poor = 1 or c.low_speed_mbps = 1 then b.eci end)*1.0/count(distinct b.eci)*100 poor_cell_ratio
|
|
|
+from a_pm_4g_poor_cell_day_tmp04 a
|
|
|
+join a_pm_4g_poor_cell_day_tmp05 b
|
|
|
+on a.eci = b.eci
|
|
|
+left join a_pm_4g_poor_cell_day_tmp06 c
|
|
|
+on b.eci = c.eci
|
|
|
+group by
|
|
|
+grouping sets((),(a.city),(a.city,a.county))';
|
|
|
+execute v_sql;
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+return '0';
|
|
|
+END;
|
|
|
+$function$
|
|
|
+;
|
