DBA Data[Home] [Help]

APPS.POA_DBI_RCV_TXN_F_C dependencies on BIS_COLLECTION_UTILITIES

Line 98: l_go_ahead := bis_collection_utilities.setup('POARCVTXN');

94:
95: DBMS_APPLICATION_INFO.SET_MODULE(module_name => 'DBI RTX COLLECT', action_name => 'start');
96: l_dop := bis_common_parameters.get_degree_of_parallelism;
97: -- default DOP to profile in EDW_PARALLEL_SRC if 2nd param is not passed
98: l_go_ahead := bis_collection_utilities.setup('POARCVTXN');
99: if (g_init) then
100: execute immediate 'alter session set hash_area_size=104857600';
101: execute immediate 'alter session set sort_area_size=104857600';
102: -- execute immediate 'alter session disable parallel dml' ;

Line 108: bis_collection_utilities.g_debug := FALSE;

104: IF (NOT l_go_ahead) THEN
105: errbuf := fnd_message.get;
106: RAISE_APPLICATION_ERROR (-20000, 'Error in SETUP: ' || errbuf);
107: END IF;
108: bis_collection_utilities.g_debug := FALSE;
109:
110: -- --------------------------------------------
111: -- Taking care of cases where the input from/to
112: -- date is NULL.

Line 120: l_start_date := '''' || To_char(fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POARCVTXN')) - 0.004,'YYYY/MM/DD HH24:MI:SS') || '''';

116: l_start_date := To_char(bis_common_parameters.get_global_start_date
117: , 'YYYY/MM/DD HH24:MI:SS');
118: d_start_date := bis_common_parameters.get_global_start_date;
119: ELSE
120: l_start_date := '''' || To_char(fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POARCVTXN')) - 0.004,'YYYY/MM/DD HH24:MI:SS') || '''';
121: /* note that if there is not a success record in the log, we should get global start date as l_start_date */
122: d_start_date := fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POARCVTXN')) - 0.004;
123: END IF;
124:

Line 122: d_start_date := fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POARCVTXN')) - 0.004;

118: d_start_date := bis_common_parameters.get_global_start_date;
119: ELSE
120: l_start_date := '''' || To_char(fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POARCVTXN')) - 0.004,'YYYY/MM/DD HH24:MI:SS') || '''';
121: /* note that if there is not a success record in the log, we should get global start date as l_start_date */
122: d_start_date := fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POARCVTXN')) - 0.004;
123: END IF;
124:
125: l_end_date := '''' || To_char(Sysdate, 'YYYY/MM/DD HH24:MI:SS') || '''';
126: d_end_date := Sysdate;

Line 130: bis_collection_utilities.log( 'The collection range is from '||

126: d_end_date := Sysdate;
127:
128:
129:
130: bis_collection_utilities.log( 'The collection range is from '||
131: l_start_date ||' to '|| l_end_date, 0);
132:
133:
134: IF (l_batch_size IS NULL) THEN

Line 138: bis_collection_utilities.log('Truncate INC table: '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

134: IF (l_batch_size IS NULL) THEN
135: l_batch_size := 10000;
136: END if;
137:
138: bis_collection_utilities.log('Truncate INC table: '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
139: IF (FND_INSTALLATION.GET_APP_INFO('POA', l_status, l_industry, l_poa_schema)) THEN
140: l_stmt := 'TRUNCATE TABLE ' || l_poa_schema || '.POA_DBI_RTX_INC';
141: EXECUTE IMMEDIATE l_stmt;
142:

Line 148: bis_collection_utilities.log('Populate INC table '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

144: EXECUTE IMMEDIATE l_stmt;
145: END IF;
146:
147: DBMS_APPLICATION_INFO.SET_ACTION('inc');
148: bis_collection_utilities.log('Populate INC table '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
149: l_glob_date := '''' || To_char(bis_common_parameters.get_global_start_date, 'YYYY/MM/DD HH24:MI:SS') || '''';
150: d_glob_date := bis_common_parameters.get_global_start_date;
151:
152: if (g_init) then

Line 295: bis_collection_utilities.log('Populate base table: '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

291: FND_STATS.GATHER_TABLE_STATS(OWNNAME => l_poa_schema,
292: TABNAME => 'POA_DBI_RTX_RATES') ;
293: END IF;
294:
295: bis_collection_utilities.log('Populate base table: '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
296:
297: select max(batch_id), COUNT(1) into l_no_batch, l_count from poa_dbi_rtx_inc;
298: bis_collection_utilities.log('Identified '|| l_count ||' changed records. Batch size='|| l_batch_size || '. # of Batches=' || l_no_batch
299: || '. Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

Line 298: bis_collection_utilities.log('Identified '|| l_count ||' changed records. Batch size='|| l_batch_size || '. # of Batches=' || l_no_batch

294:
295: bis_collection_utilities.log('Populate base table: '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
296:
297: select max(batch_id), COUNT(1) into l_no_batch, l_count from poa_dbi_rtx_inc;
298: bis_collection_utilities.log('Identified '|| l_count ||' changed records. Batch size='|| l_batch_size || '. # of Batches=' || l_no_batch
299: || '. Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
300:
301: /* missing currency handling */
302:

Line 444: bis_collection_utilities.log('batch no='||v_batch_no || ' Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 1);

440: COMMIT;
441: else
442:
443: FOR v_batch_no IN 1..l_no_batch LOOP
444: bis_collection_utilities.log('batch no='||v_batch_no || ' Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 1);
445: merge INTO poa_dbi_rtx_f T
446: using (
447: select /*+ cardinality(inc,1) */
448: val.transaction_id,

Line 648: bis_collection_utilities.log('Collection complete '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

644: END LOOP;
645: END IF; -- init load
646: END IF; -- no data
647:
648: bis_collection_utilities.log('Collection complete '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
649: bis_collection_utilities.wrapup(TRUE, l_count, 'POA DBI RCV TXN COLLECTION SUCEEDED', To_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), To_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));
650: g_init := false;
651: DBMS_APPLICATION_INFO.set_module(NULL, NULL);
652: EXCEPTION

Line 649: bis_collection_utilities.wrapup(TRUE, l_count, 'POA DBI RCV TXN COLLECTION SUCEEDED', To_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), To_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));

645: END IF; -- init load
646: END IF; -- no data
647:
648: bis_collection_utilities.log('Collection complete '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
649: bis_collection_utilities.wrapup(TRUE, l_count, 'POA DBI RCV TXN COLLECTION SUCEEDED', To_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), To_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));
650: g_init := false;
651: DBMS_APPLICATION_INFO.set_module(NULL, NULL);
652: EXCEPTION
653: WHEN OTHERS THEN

Line 657: bis_collection_utilities.log('Collection failed with '||errbuf||':'||retcode||' Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

653: WHEN OTHERS THEN
654: DBMS_APPLICATION_INFO.SET_ACTION('error');
655: errbuf:=sqlerrm;
656: retcode:=sqlcode;
657: bis_collection_utilities.log('Collection failed with '||errbuf||':'||retcode||' Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
658: -- dbms_output.put_line(l_start_date || l_end_date);
659: bis_collection_utilities.wrapup(FALSE, l_count, errbuf||':'||retcode,
660: To_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), To_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));
661:

Line 659: bis_collection_utilities.wrapup(FALSE, l_count, errbuf||':'||retcode,

655: errbuf:=sqlerrm;
656: retcode:=sqlcode;
657: bis_collection_utilities.log('Collection failed with '||errbuf||':'||retcode||' Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
658: -- dbms_output.put_line(l_start_date || l_end_date);
659: bis_collection_utilities.wrapup(FALSE, l_count, errbuf||':'||retcode,
660: To_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), To_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));
661:
662: ROLLBACK;
663: RAISE_APPLICATION_ERROR(-20000,'Stack Dump Follows =>', true);