DBA Data[Home] [Help]

APPS.ISC_FS_INV_USG_ETL_PKG dependencies on BIS_COLLECTION_UTILITIES

Line 27: bis_collection_utilities.log( g_pkg_name || '.' || p_proc_name ||

23: , p_message varchar2
24: )
25: AS
26: BEGIN
27: bis_collection_utilities.log( g_pkg_name || '.' || p_proc_name ||
28: ' #' || p_stmt_id || ' ' ||
29: p_message
30: , 3 );
31: END LOGGER;

Line 161: BIS_COLLECTION_UTILITIES.LOG( 'Begin Currency Conversion', 1 );

157: l_row_count number;
158:
159: BEGIN
160:
161: BIS_COLLECTION_UTILITIES.LOG( 'Begin Currency Conversion', 1 );
162:
163: -- get the primary global currency code
164: l_stmt_num := 10;
165: l_global_currency_code1 := BIS_COMMON_PARAMETERS.GET_CURRENCY_CODE;

Line 172: BIS_COLLECTION_UTILITIES.LOG( 'Primary global currency code: ' || l_global_currency_code1, 2

168: logger( l_proc_name, l_stmt_num, l_err_msg );
169: RAISE l_exception;
170: END IF;
171:
172: BIS_COLLECTION_UTILITIES.LOG( 'Primary global currency code: ' || l_global_currency_code1, 2
173: );
174:
175: -- get the primary global rate type
176: l_stmt_num := 20;

Line 184: BIS_COLLECTION_UTILITIES.LOG( 'Primary global rate type: ' || l_global_rate_type1, 2 );

180: logger( l_proc_name, l_stmt_num, l_err_msg );
181: RAISE l_exception;
182: END IF;
183:
184: BIS_COLLECTION_UTILITIES.LOG( 'Primary global rate type: ' || l_global_rate_type1, 2 );
185:
186: -- get the secondary global currency code
187: l_stmt_num := 30;
188: l_global_currency_code2 := bis_common_parameters.get_secondary_currency_code;

Line 191: BIS_COLLECTION_UTILITIES.LOG( 'Secondary global currency code: ' ||

187: l_stmt_num := 30;
188: l_global_currency_code2 := bis_common_parameters.get_secondary_currency_code;
189:
190: IF l_global_currency_code2 IS NOT NULL THEN
191: BIS_COLLECTION_UTILITIES.LOG( 'Secondary global currency code: ' ||
192: l_global_currency_code2, 2 );
193: ELSE
194: BIS_COLLECTION_UTILITIES.LOG( 'Secondary global currency code is not defined', 2 );
195: END IF;

Line 194: BIS_COLLECTION_UTILITIES.LOG( 'Secondary global currency code is not defined', 2 );

190: IF l_global_currency_code2 IS NOT NULL THEN
191: BIS_COLLECTION_UTILITIES.LOG( 'Secondary global currency code: ' ||
192: l_global_currency_code2, 2 );
193: ELSE
194: BIS_COLLECTION_UTILITIES.LOG( 'Secondary global currency code is not defined', 2 );
195: END IF;
196:
197: -- get the secondary global rate type
198: l_stmt_num := 40;

Line 207: BIS_COLLECTION_UTILITIES.LOG( 'Secondary global rate type: ' || l_global_rate_type2, 2 );

203: RAISE l_exception;
204: END IF;
205:
206: IF l_global_currency_code2 IS NOT NULL THEN
207: BIS_COLLECTION_UTILITIES.LOG( 'Secondary global rate type: ' || l_global_rate_type2, 2 );
208: END IF;
209:
210: -- truncate the conversion rates work table
211: l_stmt_num := 50;

Line 220: BIS_COLLECTION_UTILITIES.LOG( 'Currency conversion table truncated', 2 );

216: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
217: RAISE l_exception;
218: END IF;
219:
220: BIS_COLLECTION_UTILITIES.LOG( 'Currency conversion table truncated', 2 );
221:
222: -- Get all the distinct organization and date pairs and the
223: -- base currency codes for the orgs into the conversion rates
224: -- work table.

Line 301: BIS_COLLECTION_UTILITIES.LOG( l_row_count || ' rows inserted into currency conversion

297:
298: l_row_count := sql%rowcount;
299: COMMIT;
300:
301: BIS_COLLECTION_UTILITIES.LOG( l_row_count || ' rows inserted into currency conversion
302: table', 2 );
303:
304: l_all_rates_found := true;
305:

Line 316: BIS_COLLECTION_UTILITIES.LOG( 'Currency conversion table analyzed', 2 );

312: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
313: RAISE l_exception;
314: END IF;
315:
316: BIS_COLLECTION_UTILITIES.LOG( 'Currency conversion table analyzed', 2 );
317:
318: -- Check that all rates have been found and are non-negative.
319: -- If there is a problem, notify user.
320: l_stmt_num := 80;

Line 325: bis_collection_utilities.writeMissingRateHeader;

321: FOR invalid_rate_rec IN c_invalid_rates LOOP
322:
323: -- print the header out
324: IF c_invalid_rates%rowcount = 1 THEN
325: bis_collection_utilities.writeMissingRateHeader;
326: END IF;
327:
328: l_all_rates_found := false;
329:

Line 331: bis_collection_utilities.writeMissingRate

327:
328: l_all_rates_found := false;
329:
330: IF invalid_rate_rec.primary_rate < 0 THEN
331: bis_collection_utilities.writeMissingRate
332: ( l_global_rate_type1
333: , invalid_rate_rec.base_currency_code
334: , l_global_currency_code1
335: , invalid_rate_rec.transaction_date );

Line 339: bis_collection_utilities.writeMissingRate

335: , invalid_rate_rec.transaction_date );
336: END IF;
337:
338: IF invalid_rate_rec.secondary_rate < 0 THEN
339: bis_collection_utilities.writeMissingRate
340: ( l_global_rate_type2
341: , invalid_rate_rec.base_currency_code
342: , l_global_currency_code2
343: , invalid_rate_rec.transaction_date );

Line 355: BIS_COLLECTION_UTILITIES.LOG( 'End Currency Conversion', 1 );

351: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
352: RAISE l_exception;
353: END IF;
354:
355: BIS_COLLECTION_UTILITIES.LOG( 'End Currency Conversion', 1 );
356:
357: RETURN g_ok;
358:
359: EXCEPTION

Line 396: BIS_COLLECTION_UTILITIES.LOG( 'Begin Initial Load' );

392: BEGIN
393:
394: l_list(1) := 'BIS_GLOBAL_START_DATE';
395:
396: BIS_COLLECTION_UTILITIES.LOG( 'Begin Initial Load' );
397:
398: IF (bis_common_parameters.check_global_parameters(l_list)) THEN
399:
400: l_stmt_num := 0;

Line 401: IF NOT BIS_COLLECTION_UTILITIES.SETUP( g_object_name ) THEN

397:
398: IF (bis_common_parameters.check_global_parameters(l_list)) THEN
399:
400: l_stmt_num := 0;
401: IF NOT BIS_COLLECTION_UTILITIES.SETUP( g_object_name ) THEN
402: l_err_msg := 'Error in BIS_COLLECTION_UTILITIES.Setup';
403: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
404: RAISE g_bis_setup_exception;
405: END IF;

Line 402: l_err_msg := 'Error in BIS_COLLECTION_UTILITIES.Setup';

398: IF (bis_common_parameters.check_global_parameters(l_list)) THEN
399:
400: l_stmt_num := 0;
401: IF NOT BIS_COLLECTION_UTILITIES.SETUP( g_object_name ) THEN
402: l_err_msg := 'Error in BIS_COLLECTION_UTILITIES.Setup';
403: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
404: RAISE g_bis_setup_exception;
405: END IF;
406:

Line 426: BIS_COLLECTION_UTILITIES.LOG( 'Log table truncated', 1 );

422: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
423: RAISE l_exception;
424: END IF;
425:
426: BIS_COLLECTION_UTILITIES.LOG( 'Log table truncated', 1 );
427:
428: /* Insert into our log table the upper transaction boundaries for every organization to
429: be extracted. We will access OPI_DBI_CONC_PROG_RUN_LOG to obtain these upper boundaries. The
430: incremental load will use these boundaries as starting points. */

Line 526: BIS_COLLECTION_UTILITIES.LOG( 'Staging table truncated', 1 );

522: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
523: RAISE l_exception;
524: END IF;
525:
526: BIS_COLLECTION_UTILITIES.LOG( 'Staging table truncated', 1 );
527:
528: l_stmt_num := 40;
529: /* Insert field service material issue transaction values into staging table */
530: INSERT /*+ append parallel(ISC_FS_INV_USG_VALUE_STG) */ INTO ISC_FS_INV_USG_VALUE_STG

Line 626: BIS_COLLECTION_UTILITIES.LOG( l_row_count || ' rows inserted into staging table', 1 );

622:
623: l_row_count := sql%rowcount;
624: COMMIT;
625:
626: BIS_COLLECTION_UTILITIES.LOG( l_row_count || ' rows inserted into staging table', 1 );
627:
628: -- gather statistics on staging table before computing
629: -- conversion rates
630: l_stmt_num := 50;

Line 639: BIS_COLLECTION_UTILITIES.LOG( 'Staging table analyzed', 1 );

635: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
636: RAISE l_exception;
637: END IF;
638:
639: BIS_COLLECTION_UTILITIES.LOG( 'Staging table analyzed', 1 );
640:
641: -- check currency conversion rates
642: l_stmt_num := 60;
643: IF COMPUTE_INV_CONV_RATES

Line 660: BIS_COLLECTION_UTILITIES.LOG( 'Base summary table truncated', 1 );

656: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
657: RAISE l_exception;
658: END IF;
659:
660: BIS_COLLECTION_UTILITIES.LOG( 'Base summary table truncated', 1 );
661:
662: /* Insert field service inventory usage value data into the DBI Field Service Inventory
663: Usage Value Base Summary table based on Staging table and Current Conversion table */
664: l_stmt_num := 80;

Line 711: BIS_COLLECTION_UTILITIES.LOG( l_row_count || ' rows inserted into base summary', 1 );

707:
708: l_row_count := sql%rowcount;
709: COMMIT;
710:
711: BIS_COLLECTION_UTILITIES.LOG( l_row_count || ' rows inserted into base summary', 1 );
712:
713: -- cleanup staging/currency conversion tables
714: l_stmt_num := 90;
715: IF TRUNCATE_TABLE

Line 723: BIS_COLLECTION_UTILITIES.LOG( 'Staging table truncated', 1 );

719: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
720: RAISE l_exception;
721: END IF;
722:
723: BIS_COLLECTION_UTILITIES.LOG( 'Staging table truncated', 1 );
724:
725: l_stmt_num := 100;
726: IF TRUNCATE_TABLE
727: ( l_isc_schema

Line 734: BIS_COLLECTION_UTILITIES.LOG( 'Currency conversion table truncated', 1 );

730: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
731: RAISE l_exception;
732: END IF;
733:
734: BIS_COLLECTION_UTILITIES.LOG( 'Currency conversion table truncated', 1 );
735:
736: l_stmt_num := 110;
737: BIS_COLLECTION_UTILITIES.WRAPUP(
738: p_status => TRUE,

Line 737: BIS_COLLECTION_UTILITIES.WRAPUP(

733:
734: BIS_COLLECTION_UTILITIES.LOG( 'Currency conversion table truncated', 1 );
735:
736: l_stmt_num := 110;
737: BIS_COLLECTION_UTILITIES.WRAPUP(
738: p_status => TRUE,
739: p_count => l_row_count,
740: p_message => 'Successfully loaded Field Service Inventory Usage Base Table at ' ||
741: TO_CHAR(SYSDATE, 'DD-MON-YYYY HH24:MI:SS')

Line 744: BIS_COLLECTION_UTILITIES.LOG('End Initial Load');

740: p_message => 'Successfully loaded Field Service Inventory Usage Base Table at ' ||
741: TO_CHAR(SYSDATE, 'DD-MON-YYYY HH24:MI:SS')
742: );
743:
744: BIS_COLLECTION_UTILITIES.LOG('End Initial Load');
745:
746: errbuf := null;
747: retcode := g_ok;
748:

Line 751: BIS_COLLECTION_UTILITIES.LOG('Global Parameters are not setup.');

747: retcode := g_ok;
748:
749: ELSE
750: retcode := g_error;
751: BIS_COLLECTION_UTILITIES.LOG('Global Parameters are not setup.');
752: BIS_COLLECTION_UTILITIES.LOG('Please check that the profile option BIS_GLOBAL_START_DATE
753: is setup.');
754:
755: END IF;

Line 752: BIS_COLLECTION_UTILITIES.LOG('Please check that the profile option BIS_GLOBAL_START_DATE

748:
749: ELSE
750: retcode := g_error;
751: BIS_COLLECTION_UTILITIES.LOG('Global Parameters are not setup.');
752: BIS_COLLECTION_UTILITIES.LOG('Please check that the profile option BIS_GLOBAL_START_DATE
753: is setup.');
754:
755: END IF;
756:

Line 763: BIS_COLLECTION_UTILITIES.WRAPUP( p_status => FALSE

759: rollback;
760: IF l_err_msg is null THEN
761: l_err_msg := substr(sqlerrm,1,4000);
762: END IF;
763: BIS_COLLECTION_UTILITIES.WRAPUP( p_status => FALSE
764: , p_message => l_err_msg
765: );
766: errbuf := l_err_msg;
767: retcode := g_error;

Line 790: BIS_COLLECTION_UTILITIES.LOG( 'Begin Incremental Load' );

786: BEGIN
787:
788: l_list(1) := 'BIS_GLOBAL_START_DATE';
789:
790: BIS_COLLECTION_UTILITIES.LOG( 'Begin Incremental Load' );
791:
792: IF (bis_common_parameters.check_global_parameters(l_list)) THEN
793:
794: l_stmt_num := 0;

Line 795: IF NOT BIS_COLLECTION_UTILITIES.SETUP( g_object_name ) THEN

791:
792: IF (bis_common_parameters.check_global_parameters(l_list)) THEN
793:
794: l_stmt_num := 0;
795: IF NOT BIS_COLLECTION_UTILITIES.SETUP( g_object_name ) THEN
796: l_err_msg := 'Error in BIS_COLLECTION_UTILITIES.Setup';
797: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
798: RAISE g_bis_setup_exception;
799: END IF;

Line 796: l_err_msg := 'Error in BIS_COLLECTION_UTILITIES.Setup';

792: IF (bis_common_parameters.check_global_parameters(l_list)) THEN
793:
794: l_stmt_num := 0;
795: IF NOT BIS_COLLECTION_UTILITIES.SETUP( g_object_name ) THEN
796: l_err_msg := 'Error in BIS_COLLECTION_UTILITIES.Setup';
797: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
798: RAISE g_bis_setup_exception;
799: END IF;
800:

Line 872: BIS_COLLECTION_UTILITIES.LOG( 'Log Table updated', 1);

868: ,g_program_application_id
869: ,g_request_id
870: );
871:
872: BIS_COLLECTION_UTILITIES.LOG( 'Log Table updated', 1);
873:
874: -- get the isc schema name
875: l_stmt_num := 10;
876: IF get_schema_name

Line 893: BIS_COLLECTION_UTILITIES.LOG( 'Staging table truncated', 1);

889: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
890: RAISE l_exception;
891: END IF;
892:
893: BIS_COLLECTION_UTILITIES.LOG( 'Staging table truncated', 1);
894:
895: /* Insert field service material issue transaction values into staging table */
896: l_stmt_num := 30;
897: INSERT /*+ append parallel(ISC_FS_INV_USG_VALUE_STG) */ INTO ISC_FS_INV_USG_VALUE_STG

Line 991: BIS_COLLECTION_UTILITIES.LOG( l_row_count || ' rows inserted into staging table', 1 );

987: ,trunc(mta.TRANSACTION_DATE);
988:
989: l_row_count := sql%rowcount;
990: COMMIT;
991: BIS_COLLECTION_UTILITIES.LOG( l_row_count || ' rows inserted into staging table', 1 );
992:
993: -- gather statistics on staging table before computing
994: -- conversion rates
995: l_stmt_num := 40;

Line 1004: BIS_COLLECTION_UTILITIES.LOG( 'Staging table analyzed', 1 );

1000: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
1001: RAISE l_exception;
1002: END IF;
1003:
1004: BIS_COLLECTION_UTILITIES.LOG( 'Staging table analyzed', 1 );
1005:
1006: -- check currency conversion rates
1007: l_stmt_num := 50;
1008: IF COMPUTE_INV_CONV_RATES

Line 1096: BIS_COLLECTION_UTILITIES.LOG( l_row_count || ' rows inserted into base summary', 1 );

1092:
1093: l_row_count := sql%rowcount;
1094: COMMIT;
1095:
1096: BIS_COLLECTION_UTILITIES.LOG( l_row_count || ' rows inserted into base summary', 1 );
1097:
1098: -- cleanup staging
1099: l_stmt_num := 70;
1100: IF TRUNCATE_TABLE

Line 1108: BIS_COLLECTION_UTILITIES.LOG( 'Staging table truncated', 1 );

1104: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
1105: RAISE l_exception;
1106: END IF;
1107:
1108: BIS_COLLECTION_UTILITIES.LOG( 'Staging table truncated', 1 );
1109:
1110: l_stmt_num := 80;
1111: IF TRUNCATE_TABLE
1112: ( l_isc_schema

Line 1119: BIS_COLLECTION_UTILITIES.LOG( 'Currency conversion table truncated', 1 );

1115: LOGGER( l_proc_name, l_stmt_num, l_err_msg );
1116: RAISE l_exception;
1117: END IF;
1118:
1119: BIS_COLLECTION_UTILITIES.LOG( 'Currency conversion table truncated', 1 );
1120:
1121: l_stmt_num := 90;
1122: UPDATE ISC_FS_INV_USG_LOG
1123: SET from_transaction_id = to_transaction_id,to_transaction_id = from_transaction_id;

Line 1127: BIS_COLLECTION_UTILITIES.LOG( 'Log table updated', 1 );

1123: SET from_transaction_id = to_transaction_id,to_transaction_id = from_transaction_id;
1124:
1125: COMMIT;
1126:
1127: BIS_COLLECTION_UTILITIES.LOG( 'Log table updated', 1 );
1128:
1129: l_stmt_num := 100;
1130: BIS_COLLECTION_UTILITIES.WRAPUP(
1131: p_status => TRUE,

Line 1130: BIS_COLLECTION_UTILITIES.WRAPUP(

1126:
1127: BIS_COLLECTION_UTILITIES.LOG( 'Log table updated', 1 );
1128:
1129: l_stmt_num := 100;
1130: BIS_COLLECTION_UTILITIES.WRAPUP(
1131: p_status => TRUE,
1132: p_count => l_row_count,
1133: p_message => 'Successfully loaded Field Service Inventory Usage Base Table at ' ||
1134: TO_CHAR(SYSDATE, 'DD-MON-YYYY HH24:MI:SS')

Line 1137: BIS_COLLECTION_UTILITIES.LOG('End Incremental Load');

1133: p_message => 'Successfully loaded Field Service Inventory Usage Base Table at ' ||
1134: TO_CHAR(SYSDATE, 'DD-MON-YYYY HH24:MI:SS')
1135: );
1136:
1137: BIS_COLLECTION_UTILITIES.LOG('End Incremental Load');
1138:
1139: errbuf := null;
1140: retcode := g_ok;
1141:

Line 1144: BIS_COLLECTION_UTILITIES.LOG('Global Parameters are not setup.');

1140: retcode := g_ok;
1141:
1142: ELSE
1143: retcode := g_error;
1144: BIS_COLLECTION_UTILITIES.LOG('Global Parameters are not setup.');
1145: BIS_COLLECTION_UTILITIES.LOG('Please check that the profile option BIS_GLOBAL_START_DATE
1146: is setup.');
1147:
1148: END IF;

Line 1145: BIS_COLLECTION_UTILITIES.LOG('Please check that the profile option BIS_GLOBAL_START_DATE

1141:
1142: ELSE
1143: retcode := g_error;
1144: BIS_COLLECTION_UTILITIES.LOG('Global Parameters are not setup.');
1145: BIS_COLLECTION_UTILITIES.LOG('Please check that the profile option BIS_GLOBAL_START_DATE
1146: is setup.');
1147:
1148: END IF;
1149:

Line 1156: BIS_COLLECTION_UTILITIES.WRAPUP( p_status => FALSE

1152: ROLLBACK;
1153: IF l_err_msg is null THEN
1154: l_err_msg := substr(sqlerrm,1,4000);
1155: END IF;
1156: BIS_COLLECTION_UTILITIES.WRAPUP( p_status => FALSE
1157: , p_message => l_err_msg
1158: );
1159: errbuf := l_err_msg;
1160: retcode := g_error;