DBA Data[Home] [Help]

APPS.POA_DBI_NEG_F_C dependencies on BIS_COLLECTION_UTILITIES

Line 87: l_go_ahead := bis_collection_utilities.setup('POADBINEGF');

83:
84: dbms_application_info.set_module(module_name => 'DBI NEGOTIATION COLLECT', action_name => 'start');
85: l_dop := bis_common_parameters.get_degree_of_parallelism;
86: -- default DOP to profile in EDW_PARALLEL_SRC if 2nd param is not passed
87: l_go_ahead := bis_collection_utilities.setup('POADBINEGF');
88:
89: IF (g_init)
90: then
91: execute immediate 'alter session set hash_area_size=104857600';

Line 99: bis_collection_utilities.g_debug := false;

95: IF (NOT l_go_ahead) THEN
96: errbuf := fnd_message.get;
97: raise_application_error (-20000, 'Error in SETUP: ' || errbuf);
98: END IF;
99: bis_collection_utilities.g_debug := false;
100:
101: -- --------------------------------------------
102: -- Taking care of cases where the input from/to
103: -- date is NULL.

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

106: IF (g_init) THEN
107: l_start_date := To_char(bis_common_parameters.get_global_start_date,'YYYY/MM/DD HH24:MI:SS');
108: d_start_date := bis_common_parameters.get_global_start_date;
109: ELSE
110: l_start_date := '''' || to_char(fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POADBINEGF'))-0.004,'YYYY/MM/DD HH24:MI:SS') || '''';
111: /* if there is not a success record in the bis refresh log, then we have to get the global start date as l_start_date*/
112: d_start_date := fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POADBINEGF'))-0.004;
113: END IF;
114:

Line 112: d_start_date := fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POADBINEGF'))-0.004;

108: d_start_date := bis_common_parameters.get_global_start_date;
109: ELSE
110: l_start_date := '''' || to_char(fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POADBINEGF'))-0.004,'YYYY/MM/DD HH24:MI:SS') || '''';
111: /* if there is not a success record in the bis refresh log, then we have to get the global start date as l_start_date*/
112: d_start_date := fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POADBINEGF'))-0.004;
113: END IF;
114:
115:
116: l_end_date := '''' || To_char(SYSDATE, 'YYYY/MM/DD HH24:MI:SS') || '''';

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

116: l_end_date := '''' || To_char(SYSDATE, 'YYYY/MM/DD HH24:MI:SS') || '''';
117: d_end_date := SYSDATE;
118:
119:
120: bis_collection_utilities.log( 'The collection range is from '||
121: l_start_date ||' to '|| l_end_date, 0);
122:
123:
124: IF (l_batch_size is null) THEN

Line 128: bis_collection_utilities.log('Truncate Currency Conversion table: '|| 'Sysdate=' ||to_char(sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

124: IF (l_batch_size is null) THEN
125: l_batch_size := 10000;
126: END IF;
127:
128: bis_collection_utilities.log('Truncate Currency Conversion table: '|| 'Sysdate=' ||to_char(sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
129: IF (fnd_installation.GET_APP_INFO('POA', l_status, l_industry, l_poa_schema)) THEN
130: l_stmt := 'TRUNCATE TABLE ' || l_poa_schema || '.POA_DBI_NEG_INC';
131: EXECUTE IMMEDIATE l_stmt;
132: l_stmt := 'TRUNCATE TABLE ' || l_poa_schema || '.POA_DBI_NEG_RATES';

Line 137: bis_collection_utilities.log('Populate Currency Conversion table '|| 'Sysdate=' ||to_char(sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

133: EXECUTE IMMEDIATE l_stmt;
134: END IF;
135:
136: dbms_application_info.set_action('inc');
137: bis_collection_utilities.log('Populate Currency Conversion table '|| 'Sysdate=' ||to_char(sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
138: l_glob_date := '''' || To_char(bis_common_parameters.get_global_start_date, 'YYYY/MM/DD HH24:MI:SS') || '''';
139: d_glob_date := bis_common_parameters.get_global_start_date;
140:
141: IF (g_init) THEN

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

289: fnd_stats.gather_table_stats(ownname => l_poa_schema,
290: tabname => 'POA_DBI_NEG_RATES') ;
291: END IF;
292:
293: bis_collection_utilities.log('Populate base table: '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
294: select max(batch_id), COUNT(1) into l_no_batch, l_count from poa_dbi_neg_inc;
295: bis_collection_utilities.log('Identified '|| l_count ||' changed records. Batch size='|| l_batch_size || '. # of Batches=' || l_no_batch
296: || '. Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
297:

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

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

Line 313: bis_collection_utilities.log('Initial Load - using one batch approach, populate base fact. '|| 'Sysdate=' ||to_char(sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

309: l_user := fnd_global.user_id;
310: dbms_application_info.set_action('collect');
311: IF (l_no_batch is NOT NULL) then
312: IF (g_init) THEN
313: bis_collection_utilities.log('Initial Load - using one batch approach, populate base fact. '|| 'Sysdate=' ||to_char(sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
314: INSERT /*+ append parallel(t) */ INTO poa_dbi_neg_f t (
315: t.auction_header_id , /* Auction Header ID */
316: t.auction_line_number, /* Auction Line Number */
317: t.bid_number, /* Awarded Bid Number */

Line 559: bis_collection_utilities.log('incremental collection');

555: )s;
556: COMMIT;
557: ELSE
558: -- Incremental load (process in batches)
559: bis_collection_utilities.log('incremental collection');
560: FOR v_batch_no IN 1..l_no_batch LOOP
561: bis_collection_utilities.log('batch no='||v_batch_no || ' Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 1);
562:
563: MERGE INTO poa_dbi_neg_f t using

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

557: ELSE
558: -- Incremental load (process in batches)
559: bis_collection_utilities.log('incremental collection');
560: FOR v_batch_no IN 1..l_no_batch LOOP
561: bis_collection_utilities.log('batch no='||v_batch_no || ' Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 1);
562:
563: MERGE INTO poa_dbi_neg_f t using
564: ( SELECT /*+ cardinality(inc,1) */
565: ponh_multi.auction_header_id,

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

1012: DBMS_APPLICATION_INFO.SET_ACTION('batch ' || v_batch_no || ' done');
1013: END LOOP;
1014: END IF;
1015: END IF;
1016: bis_collection_utilities.log('Collection complete '|| 'Sysdate=' ||to_char(sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
1017: bis_collection_utilities.wrapup(TRUE, l_count, 'POA_DBI_NEG_F COLLECTION SUCEEDED', to_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), To_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));
1018: g_init := false;
1019: dbms_application_info.set_module(null, null);
1020: EXCEPTION

Line 1017: bis_collection_utilities.wrapup(TRUE, l_count, 'POA_DBI_NEG_F COLLECTION SUCEEDED', to_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), To_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));

1013: END LOOP;
1014: END IF;
1015: END IF;
1016: bis_collection_utilities.log('Collection complete '|| 'Sysdate=' ||to_char(sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
1017: bis_collection_utilities.wrapup(TRUE, l_count, 'POA_DBI_NEG_F COLLECTION SUCEEDED', to_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), To_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));
1018: g_init := false;
1019: dbms_application_info.set_module(null, null);
1020: EXCEPTION
1021: WHEN others THEN

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

1021: WHEN others THEN
1022: dbms_application_info.set_action('error');
1023: errbuf:=sqlerrm;
1024: retcode:=sqlcode;
1025: bis_collection_utilities.log('Collection failed with '||errbuf||':'||retcode||' Sysdate=' ||to_char(sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
1026: bis_collection_utilities.wrapup(FALSE, l_count, errbuf||':'||retcode, to_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), to_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));
1027: RAISE;
1028: END populate_neg_facts;
1029:

Line 1026: bis_collection_utilities.wrapup(FALSE, l_count, errbuf||':'||retcode, to_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), to_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));

1022: dbms_application_info.set_action('error');
1023: errbuf:=sqlerrm;
1024: retcode:=sqlcode;
1025: bis_collection_utilities.log('Collection failed with '||errbuf||':'||retcode||' Sysdate=' ||to_char(sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
1026: bis_collection_utilities.wrapup(FALSE, l_count, errbuf||':'||retcode, to_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), to_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));
1027: RAISE;
1028: END populate_neg_facts;
1029:
1030: END POA_DBI_NEG_F_C;