deepthi/MMT
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

added deployment folder with latest code

Browse Source
This commit is contained in:
Deepthi
2021-04-27 16:13:33 +05:30
parent 37f73d5dfd
commit c8985b2d62
112 changed files with 42492 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

373
deployment-20210427T103328Z-001/deployment/pto-V1-April22/PTO-GVG_stg2.txt Normal file
View File

@@ -0,0 +1,373 @@
drop function if exists mmt_staging2.fn_PTO_GVG_block;
CREATE OR REPLACE FUNCTION mmt_staging2.fn_PTO_GVG_block(p_client_id int,p_function_id int, p_file_format text,
p_sheet_mnemonic text, p_file_syspk int)
RETURNS text AS $$
declare __make text;
declare __model text;
declare __client_id int :=p_client_id;
declare __function_id int :=p_function_id;
declare __file_format text :=p_file_format;
declare __sheet_mnemonic text :=p_sheet_mnemonic;
declare __file_syspk int :=p_file_syspk;
declare v_state text;
declare v_msg text;
declare v_detail text;
declare v_hint text;
declare v_context text;
declare _error int;
declare v_block text;
begin
/**************************************************************************************
Function Name:fn_PTO_GVG_block
Function Desc: This function populates data into staging2 blocks
File Format: PTOBST
Sheet Format: PTOBST_GVG
Creation Date: March 25 2021
Updation Date:
Author: compegence team
Function Call: select mmt_staging2.fn_PTO_GVG_block(1,1,'PTOBST','PTOBST_GVG',880)
***************************************************************************************/
SET search_path TO mmt_staging2;
/* rerunnability - delete block tables and update config tables to null */
truncate table mmt_staging2.stg_specific_table_PTO_GVG;
truncate table mmt_staging2.stg_process_table_PTO_GVG;
truncate table mmt_staging2.PTOBST_GVG_performance_governing_trails_block;
execute 'delete from mmt_ods.fw_jobctrl_file_sheet_block_run_schedule where file_syspk='||p_file_syspk||' and sheet_mnemonic='''||p_sheet_mnemonic||'''';
execute 'update mmt_ods.mmt_config a
set row_number_start=null,
row_previous_number=null,
row_read_end=null,
run_time=null
where a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||'''';
/* transfer data from generic to specific for PTOBST */
execute 'insert into mmt_staging2.stg_specific_table_PTO_GVG
select * from mmt_staging1.mmt_staging_generic_table a
where a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||'''
and a.file_syspk='||p_file_syspk||'';
/* trimming data */
update mmt_staging2.stg_specific_table_PTO_GVG set column3 = TRIM (TRAILING FROM column3 );
update mmt_staging2.stg_specific_table_PTO_GVG set column3 = TRIM (LEADING FROM column3 );
update mmt_ods.mmt_config set F1_modified = TRIM (TRAILING FROM F1_modified) ;
update mmt_ods.mmt_config set F1_modified = TRIM (LEADING FROM F1_modified) ;
update mmt_ods.mmt_config set F1_source=F1_modified ;
update mmt_ods.mmt_config set F1_source = TRIM (TRAILING FROM F1_source);
update mmt_ods.mmt_config set F1_source = TRIM (LEADING FROM F1_source);
execute 'update mmt_ods.mmt_config a
set row_number_start=(select min(b.row_number)
from mmt_staging2.stg_specific_table_PTO_GVG b
where trim(upper(F1_modified))=trim(upper(column2))
and b.is_rownumber_fetched is null)
where a.row_number_start is null
and a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||'''';
/* keyword match in config table*/
execute 'update mmt_staging2.stg_specific_table_PTO_GVG a
set is_rownumber_fetched=1
from mmt_ods.mmt_config b
where trim(upper(F1_modified))=trim(upper(column3))
and b.row_number_start=a.row_number
and is_rownumber_fetched is null
and a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||'''';
execute 'update mmt_ods.mmt_config a set row_previous_number=row_number_start-1
where a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||'''';
execute 'update mmt_ods.mmt_config a
set row_read_end= (select b.row_number_start
from mmt_ods.mmt_config b
where b.syspk=a.syspk+1 and file_format='''||p_file_format||''' and sheet_mnemonic='''||p_sheet_mnemonic||''' )
where a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||'''';
/* config file last field update as null otherwise it picks up next format row number*/
execute 'update mmt_ods.mmt_config a
set row_read_end = null ,run_time=current_timestamp
where f1_modified =''Graphs - for Example''
and a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||'''';
/* tagging ranks*/
execute 'insert into mmt_staging2.stg_process_table_PTO_GVG
select a.* , RANK () OVER ( ORDER BY row_number) as rank,b.rank_tag as rank_tag
from mmt_staging2.stg_specific_table_PTO_GVG a
join mmt_ods.mmt_config b
on a.row_number >=row_number_start
and (a.row_number< row_read_end or row_read_end is null)
and f1_modified=''Governing Trails on Boost Mode''
and b.file_format='''||p_file_format||''' and b.sheet_mnemonic='''||p_sheet_mnemonic||'''';
execute 'insert into mmt_staging2.stg_process_table_PTO_GVG
select a.* , RANK () OVER ( ORDER BY row_number) as rank,b.rank_tag as rank_tag
from mmt_staging2.stg_specific_table_PTO_GVG a
join mmt_ods.mmt_config b
on a.row_number >=row_number_start
and (a.row_number< row_read_end or row_read_end is null)
and f1_modified=''Graphs - for Example''
and b.file_format='''||p_file_format||''' and b.sheet_mnemonic='''||p_sheet_mnemonic||'''';
select column3 into __make from mmt_staging2.stg_process_table_PTO_report a
where rank_tag='PTOBST_RPT_test_tractor_specifiactions' and rank=3 ;
select column4 into __model from mmt_staging2.stg_process_table_PTO_report a
where rank_tag='PTOBST_RPT_test_tractor_specifiactions' and rank=3;
/* block PTOBST_GVG_performance_governing_trails_block */
perform mmt_staging2.fn_jobctrl_block_begin(__client_id,__function_id,__file_syspk,
'PTOBST_GVG_performance_governing_trails_block',__file_format,__sheet_mnemonic,1);
v_block := 'PTOBST_GVG_performance_governing_trails_block';
insert into mmt_staging2.PTOBST_GVG_performance_governing_trails_block
(
c2,
c3,
c4,
c5,
c6,
c7,
c8,
c9,
c10,
c11,
c12,
c13,
c14,
c15,
c16,
c17,
c18,
c19,
c20,
c21,
c22,
c23,
c24,
c25,
c26,
c27,
c28,
c29,
c30,
c31,
c32,
c33,
c34,
c35,
c36,
rank
)
select column2,
column3,
column4,
column5,
column6,
column7,
column8,
column9,
column10,
column11,
column12,
column13,
column14,
column15,
column16,
column17,
column18,
column19,
column20,
column21,
column22,
column23,
column24,
column25,
column26,
column27,
column28,
column29,
column30,
column31,
column32,
column33,
column34,
column35,
column36,
rank
from mmt_staging2.stg_process_table_PTO_GVG a
where rank_tag='PTOBST_GVG_performance_governing_trails';
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block
set test_condition=c2
where rank=1;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block
set c2=null
where rank=1;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block a
set test_condition= b.first_value from (SELECT
rank, test_condition, value_partition, first_value(test_condition) over (partition by value_partition order by rank)
FROM (
SELECT
rank,
test_condition,
sum(case when test_condition is null then 0 else 1 end) over (order by rank) as value_partition
FROM mmt_staging2.PTOBST_GVG_performance_governing_trails_block
ORDER BY rank ASC
) as q) b where a.rank = b.rank ;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block
set c1=c2 where rank=4;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block a
set c1= b.first_value from (SELECT
rank, c1, value_partition, first_value(c1) over (partition by value_partition order by rank)
FROM (
SELECT
rank,
c1,
sum(case when c1 is null then 0 else 1 end) over (order by rank) as value_partition
FROM mmt_staging2.PTOBST_GVG_performance_governing_trails_block
ORDER BY rank ASC
) as q) b where a.rank = b.rank ;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block
set c7_1=c7 where rank=4;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block a
set c7_1= b.first_value from (SELECT
rank, c7_1, value_partition, first_value(c7_1) over (partition by value_partition order by rank)
FROM (
SELECT
rank,
c7_1,
sum(case when c7_1 is null then 0 else 1 end) over (order by rank) as value_partition
FROM mmt_staging2.PTOBST_GVG_performance_governing_trails_block
ORDER BY rank ASC
) as q) b where a.rank = b.rank ;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block
set c12_1=c12 where rank=4;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block a
set c12_1= b.first_value from (SELECT
rank, c12_1, value_partition, first_value(c12_1) over (partition by value_partition order by rank)
FROM (
SELECT
rank,
c12_1,
sum(case when c12_1 is null then 0 else 1 end) over (order by rank) as value_partition
FROM mmt_staging2.PTOBST_GVG_performance_governing_trails_block
ORDER BY rank ASC
) as q) b where a.rank = b.rank ;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block
set c17_1=c17 where rank=4;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block a
set c17_1= b.first_value from (SELECT
rank, c17_1, value_partition, first_value(c17_1) over (partition by value_partition order by rank)
FROM (
SELECT
rank,
c17_1,
sum(case when c17_1 is null then 0 else 1 end) over (order by rank) as value_partition
FROM mmt_staging2.PTOBST_GVG_performance_governing_trails_block
ORDER BY rank ASC
) as q) b where a.rank = b.rank ;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block
set c22_1=c22 where rank=4;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block a
set c22_1= b.first_value from (SELECT
rank, c22_1, value_partition, first_value(c22_1) over (partition by value_partition order by rank)
FROM (
SELECT
rank,
c22_1,
sum(case when c22_1 is null then 0 else 1 end) over (order by rank) as value_partition
FROM mmt_staging2.PTOBST_GVG_performance_governing_trails_block
ORDER BY rank ASC
) as q) b where a.rank = b.rank ;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block
set c27_1=c27 where rank=4;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block a
set c27_1= b.first_value from (SELECT
rank, c27_1, value_partition, first_value(c27_1) over (partition by value_partition order by rank)
FROM (
SELECT
rank,
c27_1,
sum(case when c27_1 is null then 0 else 1 end) over (order by rank) as value_partition
FROM mmt_staging2.PTOBST_GVG_performance_governing_trails_block
ORDER BY rank ASC
) as q) b where a.rank = b.rank ;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block
set c32_1=c32 where rank=4;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block a
set c32_1= b.first_value from (SELECT
rank, c32_1, value_partition, first_value(c32_1) over (partition by value_partition order by rank)
FROM (
SELECT
rank,
c32_1,
sum(case when c32_1 is null then 0 else 1 end) over (order by rank) as value_partition
FROM mmt_staging2.PTOBST_GVG_performance_governing_trails_block
ORDER BY rank ASC
) as q) b where a.rank = b.rank ;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block
set ods_record=0 where rank in (1,2,3,4);
execute 'update mmt_staging2.PTOBST_GVG_performance_governing_trails_block set client_id='||p_client_id||'';
execute 'update mmt_staging2.PTOBST_GVG_performance_governing_trails_block set function_id='||p_function_id||'';
execute 'update mmt_staging2.PTOBST_GVG_performance_governing_trails_block set file_format='''||p_file_format||'''';
execute 'update mmt_staging2.PTOBST_GVG_performance_governing_trails_block set sheet_mnemonic='''||p_sheet_mnemonic||'''';
execute 'update mmt_staging2.PTOBST_GVG_performance_governing_trails_block set file_syspk='||p_file_syspk||'';
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block set make=__make;
update mmt_staging2.PTOBST_GVG_performance_governing_trails_block set model=__model;
perform mmt_staging2.fn_jobctrl_block_end(__file_syspk,'PTOBST_GVG_performance_governing_trails_block');
v_context := '';
perform mmt_staging2.mmt_insert_db_error ( __client_id, __function_id, 1001, 'Compegence', __file_syspk ,__file_format,__sheet_mnemonic ,null,'stg2', 'fn_PTO_GVG_block', v_state, v_msg, v_detail, v_hint, v_context,'success');
return v_context;
EXCEPTION when OTHERS then
GET STACKED DIAGNOSTICS
v_state = returned_sqlstate,
v_msg = message_text,
v_detail = pg_exception_detail,
v_hint = pg_exception_hint,
v_context = pg_exception_context;
perform mmt_staging2.mmt_insert_db_error ( __client_id, __function_id, 1001, 'Compegence', __file_syspk ,__file_format,__sheet_mnemonic ,v_block,'stg2', 'fn_PTO_GVG_block', v_state, v_msg, v_detail, v_hint, v_context,'error');
return v_context;
end
$$ LANGUAGE plpgsql;