DBA Data[Home] [Help]

APPS.POA_DBI_PO_DIST_F_C dependencies on BIS_COLLECTION_UTILITIES

Line 109: l_go_ahead := bis_collection_utilities.setup('POAPODIST');

105:
106: DBMS_APPLICATION_INFO.SET_MODULE(module_name => 'DBI POD COLLECT', action_name => 'start');
107: l_dop := bis_common_parameters.get_degree_of_parallelism;
108: -- default DOP to profile in EDW_PARALLEL_SRC if 2nd param is not passed
109: l_go_ahead := bis_collection_utilities.setup('POAPODIST');
110: if (g_init) then
111: execute immediate 'alter session set hash_area_size=104857600';
112: execute immediate 'alter session set sort_area_size=104857600';
113: -- execute immediate 'alter session disable parallel dml' ;

Line 119: bis_collection_utilities.g_debug := FALSE;

115: IF (NOT l_go_ahead) THEN
116: errbuf := fnd_message.get;
117: RAISE_APPLICATION_ERROR (-20000, 'Error in SETUP: ' || errbuf);
118: END IF;
119: bis_collection_utilities.g_debug := FALSE;
120:
121:
122: IF(g_init) THEN
123: l_start_date := To_char(bis_common_parameters.get_global_start_date

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

123: l_start_date := To_char(bis_common_parameters.get_global_start_date
124: , 'YYYY/MM/DD HH24:MI:SS');
125: d_start_date := bis_common_parameters.get_global_start_date;
126: ELSE
127: l_start_date := To_char(fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POAPODIST')) - 0.004,'YYYY/MM/DD HH24:MI:SS');
128: /* note that if there is not a success record in the log, we should get global start date as l_start_date */
129: d_start_date := fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POAPODIST')) - 0.004;
130: END IF;
131:

Line 129: d_start_date := fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POAPODIST')) - 0.004;

125: d_start_date := bis_common_parameters.get_global_start_date;
126: ELSE
127: l_start_date := To_char(fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POAPODIST')) - 0.004,'YYYY/MM/DD HH24:MI:SS');
128: /* note that if there is not a success record in the log, we should get global start date as l_start_date */
129: d_start_date := fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period('POAPODIST')) - 0.004;
130: END IF;
131:
132:
133: l_end_date := To_char(Sysdate, 'YYYY/MM/DD HH24:MI:SS');

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

132:
133: l_end_date := To_char(Sysdate, 'YYYY/MM/DD HH24:MI:SS');
134: d_end_date := Sysdate;
135:
136: bis_collection_utilities.log( 'The collection range is from '||
137: l_start_date ||' to '|| l_end_date, 0);
138:
139:
140: IF (l_batch_size IS NULL) THEN

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

140: IF (l_batch_size IS NULL) THEN
141: l_batch_size := 10000;
142: END if;
143:
144: bis_collection_utilities.log('Truncate INC table: '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
145: IF (NOT(FND_INSTALLATION.GET_APP_INFO('POA', l_status, l_industry, l_poa_schema))) THEN
146: bis_collection_utilities.log('Error getting app info '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
147: RAISE_APPLICATION_ERROR (-20000, 'Error in GET_APP_INFO: ' || errbuf);
148: END IF;

Line 146: bis_collection_utilities.log('Error getting app info '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

142: END if;
143:
144: bis_collection_utilities.log('Truncate INC table: '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
145: IF (NOT(FND_INSTALLATION.GET_APP_INFO('POA', l_status, l_industry, l_poa_schema))) THEN
146: bis_collection_utilities.log('Error getting app info '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
147: RAISE_APPLICATION_ERROR (-20000, 'Error in GET_APP_INFO: ' || errbuf);
148: END IF;
149: l_stmt := 'TRUNCATE TABLE ' || l_poa_schema || '.POA_DBI_POD_INC';
150: EXECUTE IMMEDIATE l_stmt;

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

155: l_stmt := 'TRUNCATE TABLE ' || l_poa_schema || '.POA_DBI_NEG_DETAILS';
156: EXECUTE IMMEDIATE l_stmt;
157:
158: DBMS_APPLICATION_INFO.SET_ACTION('inc');
159: bis_collection_utilities.log('Populate INC table '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
160: l_glob_date := To_char(bis_common_parameters.get_global_start_date, 'YYYY/MM/DD HH24:MI:SS');
161: d_glob_date := bis_common_parameters.get_global_start_date;
162:
163: if(g_init) then

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

1185: TABNAME => 'POA_DBI_POD_RATES') ;
1186: FND_STATS.GATHER_TABLE_STATS(OWNNAME => l_poa_schema,
1187: TABNAME => 'POA_DBI_NEG_DETAILS') ;
1188:
1189: bis_collection_utilities.log('Populate base table: '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
1190:
1191: select max(batch_id), COUNT(1) into l_no_batch, l_count from poa_dbi_pod_inc;
1192: bis_collection_utilities.log('Identified '|| l_count ||' changed records. Batch size='|| l_batch_size || '. # of Batches=' || l_no_batch
1193: || '. Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

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

1188:
1189: bis_collection_utilities.log('Populate base table: '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
1190:
1191: select max(batch_id), COUNT(1) into l_no_batch, l_count from poa_dbi_pod_inc;
1192: bis_collection_utilities.log('Identified '|| l_count ||' changed records. Batch size='|| l_batch_size || '. # of Batches=' || l_no_batch
1193: || '. Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
1194:
1195: /* missing currency handling */
1196:

Line 1205: bis_collection_utilities.log('There are missing currencies '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

1201: END IF;
1202:
1203: /*
1204: IF (l_rate = -1) THEN
1205: bis_collection_utilities.log('There are missing currencies '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
1206: RAISE_APPLICATION_ERROR (-20000, 'Error in INC table collection: ' || errbuf);
1207: ELSIF (l_rate = -2) THEN
1208: bis_collection_utilities.log('There are invalid currencies '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
1209: RAISE_APPLICATION_ERROR (-20000, 'Error in INC table collection: ' || errbuf);

Line 1208: bis_collection_utilities.log('There are invalid currencies '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

1204: IF (l_rate = -1) THEN
1205: bis_collection_utilities.log('There are missing currencies '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
1206: RAISE_APPLICATION_ERROR (-20000, 'Error in INC table collection: ' || errbuf);
1207: ELSIF (l_rate = -2) THEN
1208: bis_collection_utilities.log('There are invalid currencies '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
1209: RAISE_APPLICATION_ERROR (-20000, 'Error in INC table collection: ' || errbuf);
1210: END IF;
1211: */
1212:

Line 1220: bis_collection_utilities.log('Initial Load - populate match table. '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

1216: DBMS_APPLICATION_INFO.SET_ACTION('collect');
1217:
1218: if (l_no_batch is NOT NULL) then
1219: IF (g_init) THEN
1220: bis_collection_utilities.log('Initial Load - populate match table. '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
1221:
1222: INSERT /*+ APPEND PARALLEL(poa_dbi_pod_match_temp) */ INTO
1223: poa_dbi_pod_match_temp
1224: ( po_distribution_id,

Line 1365: bis_collection_utilities.log('Initial Load - populate lowest price table. '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);

1361:
1362: FND_STATS.GATHER_TABLE_STATS(OWNNAME => l_poa_schema,
1363: TABNAME => 'POA_DBI_POD_MATCH_TEMP') ;
1364:
1365: bis_collection_utilities.log('Initial Load - populate lowest price table. '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
1366:
1367: INSERT /*+ APPEND PARALLEL(t) */ INTO poa_dbi_pod_lowest_all_temp t(po_distribution_id, po_header_id, shipto_price, generic_price, unit_price)
1368: WITH bb AS (
1369: select /*+ PARALLEL(b) PARALLEL(ptmp) PARALLEL(std) PARALLEL(poa_gl) PARALLEL(fsp) no_merge leading(ptmp) use_hash(l, b, pgoa, std) */

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

1534:
1535: FND_STATS.GATHER_TABLE_STATS(OWNNAME => l_poa_schema,
1536: TABNAME => 'POA_DBI_POD_LOWEST_PRICE_TEMP') ;
1537:
1538: bis_collection_utilities.log('Initial Load - using one batch approach, populate base fact. '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
1539: INSERT /*+ APPEND PARALLEL(t) */ INTO
1540: poa_dbi_pod_f t
1541: (
1542: t.po_distribution_id,

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

1969: COMMIT;
1970: else
1971:
1972: FOR v_batch_no IN 1..l_no_batch LOOP
1973: bis_collection_utilities.log('batch no='||v_batch_no || ' Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 1);
1974:
1975: merge INTO poa_dbi_pod_f T
1976: using
1977: (

Line 2527: bis_collection_utilities.log('best price calculation hit='|| poa_dbi_savings_pkg.g_hit_count, 2);

2523: s.negotiated_by_preparer_flag
2524: );
2525:
2526: COMMIT;
2527: bis_collection_utilities.log('best price calculation hit='|| poa_dbi_savings_pkg.g_hit_count, 2);
2528: poa_dbi_savings_pkg.g_hit_count := 0;
2529:
2530: DBMS_APPLICATION_INFO.SET_ACTION('batch ' || v_batch_no || ' done');
2531: END LOOP;

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

2533: END IF;
2534: /*
2535: if (l_no_batch is NOT NULL) then
2536: FOR v_batch_no IN 1..l_no_batch LOOP
2537: bis_collection_utilities.log('EAD batch no='||v_batch_no || ' Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 1);
2538: update poa_dbi_pod_f f
2539: set (approved_date, po_approval_cycle_time) = (SELECT min(approved_date), MIN(approved_date - pod.creation_date)
2540: from po_line_locations_archive_all pll
2541: ,po_distributions_all pod

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

2549: END LOOP;
2550: END IF;
2551: */
2552:
2553: bis_collection_utilities.log('Collection complete '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
2554: bis_collection_utilities.wrapup(TRUE, l_count, 'POA DBI PO DIST COLLECTION SUCEEDED', To_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), To_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));
2555: g_init := false;
2556: DBMS_APPLICATION_INFO.set_module(NULL, NULL);
2557: EXCEPTION

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

2550: END IF;
2551: */
2552:
2553: bis_collection_utilities.log('Collection complete '|| 'Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
2554: bis_collection_utilities.wrapup(TRUE, l_count, 'POA DBI PO DIST COLLECTION SUCEEDED', To_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), To_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));
2555: g_init := false;
2556: DBMS_APPLICATION_INFO.set_module(NULL, NULL);
2557: EXCEPTION
2558: WHEN OTHERS THEN

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

2558: WHEN OTHERS THEN
2559: DBMS_APPLICATION_INFO.SET_ACTION('error');
2560: errbuf:=sqlerrm;
2561: retcode:=sqlcode;
2562: bis_collection_utilities.log('Collection failed with '||errbuf||':'||retcode||' Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
2563: -- dbms_output.put_line(l_start_date || l_end_date);
2564: bis_collection_utilities.wrapup(FALSE, l_count, errbuf||':'||retcode,
2565: To_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), To_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));
2566:

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

2560: errbuf:=sqlerrm;
2561: retcode:=sqlcode;
2562: bis_collection_utilities.log('Collection failed with '||errbuf||':'||retcode||' Sysdate=' ||To_char(Sysdate, 'DD/MM/YYYY HH24:MI:SS'), 0);
2563: -- dbms_output.put_line(l_start_date || l_end_date);
2564: bis_collection_utilities.wrapup(FALSE, l_count, errbuf||':'||retcode,
2565: To_date(l_start_date, '''YYYY/MM/DD HH24:MI:SS'''), To_date(l_end_date, '''YYYY/MM/DD HH24:MI:SS'''));
2566:
2567:
2568: RAISE;