DBA Data[Home] [Help]

APPS.OPI_EDW_OPM_JOB_RSRC_F_C dependencies on EDW_LOG

Line 55: edw_log.put_line(' ');

51: WHERE SEQ_ID is NULL);
52:
53: BEGIN
54: /* Print Header */
55: edw_log.put_line(' ');
56: edw_log.put_line ('Identified Missing Rows Date:'||SYSDATE);
57:
58: edw_log.put_line (' ');
59: edw_log.put_line (' ');

Line 56: edw_log.put_line ('Identified Missing Rows Date:'||SYSDATE);

52:
53: BEGIN
54: /* Print Header */
55: edw_log.put_line(' ');
56: edw_log.put_line ('Identified Missing Rows Date:'||SYSDATE);
57:
58: edw_log.put_line (' ');
59: edw_log.put_line (' ');
60:

Line 58: edw_log.put_line (' ');

54: /* Print Header */
55: edw_log.put_line(' ');
56: edw_log.put_line ('Identified Missing Rows Date:'||SYSDATE);
57:
58: edw_log.put_line (' ');
59: edw_log.put_line (' ');
60:
61: edw_log.put_line ('Primary Key is PM_BTCH_HDR.Batch_id - PM_MATL_DTL.line_id -
62: PM_OPRN_DTL.BATCHSTEP_NO - PM_OPRN_DTL.RESOURCES - PM_OPRN_DTL.ACTIVITY

Line 59: edw_log.put_line (' ');

55: edw_log.put_line(' ');
56: edw_log.put_line ('Identified Missing Rows Date:'||SYSDATE);
57:
58: edw_log.put_line (' ');
59: edw_log.put_line (' ');
60:
61: edw_log.put_line ('Primary Key is PM_BTCH_HDR.Batch_id - PM_MATL_DTL.line_id -
62: PM_OPRN_DTL.BATCHSTEP_NO - PM_OPRN_DTL.RESOURCES - PM_OPRN_DTL.ACTIVITY
63: - PM_OPRN_DTL.BATCHSTEPLINE_ID - instance_code - OPM');

Line 61: edw_log.put_line ('Primary Key is PM_BTCH_HDR.Batch_id - PM_MATL_DTL.line_id -

57:
58: edw_log.put_line (' ');
59: edw_log.put_line (' ');
60:
61: edw_log.put_line ('Primary Key is PM_BTCH_HDR.Batch_id - PM_MATL_DTL.line_id -
62: PM_OPRN_DTL.BATCHSTEP_NO - PM_OPRN_DTL.RESOURCES - PM_OPRN_DTL.ACTIVITY
63: - PM_OPRN_DTL.BATCHSTEPLINE_ID - instance_code - OPM');
64: edw_log.put_line ('-----------------------------------------');
65: edw_log.put_line ('Primary Key / Currency / Transaction Date');

Line 64: edw_log.put_line ('-----------------------------------------');

60:
61: edw_log.put_line ('Primary Key is PM_BTCH_HDR.Batch_id - PM_MATL_DTL.line_id -
62: PM_OPRN_DTL.BATCHSTEP_NO - PM_OPRN_DTL.RESOURCES - PM_OPRN_DTL.ACTIVITY
63: - PM_OPRN_DTL.BATCHSTEPLINE_ID - instance_code - OPM');
64: edw_log.put_line ('-----------------------------------------');
65: edw_log.put_line ('Primary Key / Currency / Transaction Date');
66: edw_log.put_line ('-----------------------------------------');
67: /* Print Rows */
68:

Line 65: edw_log.put_line ('Primary Key / Currency / Transaction Date');

61: edw_log.put_line ('Primary Key is PM_BTCH_HDR.Batch_id - PM_MATL_DTL.line_id -
62: PM_OPRN_DTL.BATCHSTEP_NO - PM_OPRN_DTL.RESOURCES - PM_OPRN_DTL.ACTIVITY
63: - PM_OPRN_DTL.BATCHSTEPLINE_ID - instance_code - OPM');
64: edw_log.put_line ('-----------------------------------------');
65: edw_log.put_line ('Primary Key / Currency / Transaction Date');
66: edw_log.put_line ('-----------------------------------------');
67: /* Print Rows */
68:
69: For l_rows in missing_rate loop

Line 66: edw_log.put_line ('-----------------------------------------');

62: PM_OPRN_DTL.BATCHSTEP_NO - PM_OPRN_DTL.RESOURCES - PM_OPRN_DTL.ACTIVITY
63: - PM_OPRN_DTL.BATCHSTEPLINE_ID - instance_code - OPM');
64: edw_log.put_line ('-----------------------------------------');
65: edw_log.put_line ('Primary Key / Currency / Transaction Date');
66: edw_log.put_line ('-----------------------------------------');
67: /* Print Rows */
68:
69: For l_rows in missing_rate loop
70: edw_log.put_line (l_rows.JOB_RSRC_PK||' / '||l_rows.SOB_CURRENCY_FK||' / '||l_rows.TRX_DATE_FK);

Line 70: edw_log.put_line (l_rows.JOB_RSRC_PK||' / '||l_rows.SOB_CURRENCY_FK||' / '||l_rows.TRX_DATE_FK);

66: edw_log.put_line ('-----------------------------------------');
67: /* Print Rows */
68:
69: For l_rows in missing_rate loop
70: edw_log.put_line (l_rows.JOB_RSRC_PK||' / '||l_rows.SOB_CURRENCY_FK||' / '||l_rows.TRX_DATE_FK);
71: end loop;
72: edw_log.put_line(' ');
73: edw_log.put_line(' ');
74: EXCEPTION

Line 72: edw_log.put_line(' ');

68:
69: For l_rows in missing_rate loop
70: edw_log.put_line (l_rows.JOB_RSRC_PK||' / '||l_rows.SOB_CURRENCY_FK||' / '||l_rows.TRX_DATE_FK);
71: end loop;
72: edw_log.put_line(' ');
73: edw_log.put_line(' ');
74: EXCEPTION
75: WHEN OTHERS THEN
76: g_errbuf:=sqlerrm;

Line 73: edw_log.put_line(' ');

69: For l_rows in missing_rate loop
70: edw_log.put_line (l_rows.JOB_RSRC_PK||' / '||l_rows.SOB_CURRENCY_FK||' / '||l_rows.TRX_DATE_FK);
71: end loop;
72: edw_log.put_line(' ');
73: edw_log.put_line(' ');
74: EXCEPTION
75: WHEN OTHERS THEN
76: g_errbuf:=sqlerrm;
77: g_retcode:=sqlcode;

Line 78: edw_log.put_line('Raised Exception from PRINT_MISSING_RATE '||sqlerrm);

74: EXCEPTION
75: WHEN OTHERS THEN
76: g_errbuf:=sqlerrm;
77: g_retcode:=sqlcode;
78: edw_log.put_line('Raised Exception from PRINT_MISSING_RATE '||sqlerrm);
79: END;
80:
81: /* Procedure to Push missing rows */
82: PROCEDURE PUSH_MISSING_ROWS

Line 88: edw_log.put_line(' ');

84: l_count number;
85: BEGIN
86: /* Delete the incremental table before inserting new data */
87: DELETE OPI_EDW_OPM_JOB_RSRC_INC;
88: edw_log.put_line(' ');
89: edw_log.Put_line('Identifying Missing Rate Rows ');
90: edw_log.put_line(' ');
91: SELECT count(*) into l_count from OPI_EDW_JOB_RSRC_FSTG where
92: COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')

Line 89: edw_log.Put_line('Identifying Missing Rate Rows ');

85: BEGIN
86: /* Delete the incremental table before inserting new data */
87: DELETE OPI_EDW_OPM_JOB_RSRC_INC;
88: edw_log.put_line(' ');
89: edw_log.Put_line('Identifying Missing Rate Rows ');
90: edw_log.put_line(' ');
91: SELECT count(*) into l_count from OPI_EDW_JOB_RSRC_FSTG where
92: COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
93: AND JOB_RSRC_PK like '%OPM';

Line 90: edw_log.put_line(' ');

86: /* Delete the incremental table before inserting new data */
87: DELETE OPI_EDW_OPM_JOB_RSRC_INC;
88: edw_log.put_line(' ');
89: edw_log.Put_line('Identifying Missing Rate Rows ');
90: edw_log.put_line(' ');
91: SELECT count(*) into l_count from OPI_EDW_JOB_RSRC_FSTG where
92: COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
93: AND JOB_RSRC_PK like '%OPM';
94: IF l_count > 0 THEN

Line 113: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion');

109: from OPI_EDW_JOB_RSRC_FSTG
110: WHERE COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
111: AND JOB_RSRC_PK like '%OPM');
112: /* The above Sub selcet has a reverse string traverse as the batchlineid is 3 from right in PK KEY */
113: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion');
114: edw_log.put_line(' ');
115: Commit;
116: edw_log.put_line ('Printing Missing Rate Rows Output');
117: edw_log.put_line(' ');

Line 114: edw_log.put_line(' ');

110: WHERE COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
111: AND JOB_RSRC_PK like '%OPM');
112: /* The above Sub selcet has a reverse string traverse as the batchlineid is 3 from right in PK KEY */
113: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion');
114: edw_log.put_line(' ');
115: Commit;
116: edw_log.put_line ('Printing Missing Rate Rows Output');
117: edw_log.put_line(' ');
118: PRINT_MISSING_ROWS;

Line 116: edw_log.put_line ('Printing Missing Rate Rows Output');

112: /* The above Sub selcet has a reverse string traverse as the batchlineid is 3 from right in PK KEY */
113: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion');
114: edw_log.put_line(' ');
115: Commit;
116: edw_log.put_line ('Printing Missing Rate Rows Output');
117: edw_log.put_line(' ');
118: PRINT_MISSING_ROWS;
119: edw_log.put_line ('Output Printed. You can view the output using ''View output'' option from Request page');
120: edw_log.put_line(' ');

Line 117: edw_log.put_line(' ');

113: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion');
114: edw_log.put_line(' ');
115: Commit;
116: edw_log.put_line ('Printing Missing Rate Rows Output');
117: edw_log.put_line(' ');
118: PRINT_MISSING_ROWS;
119: edw_log.put_line ('Output Printed. You can view the output using ''View output'' option from Request page');
120: edw_log.put_line(' ');
121:

Line 119: edw_log.put_line ('Output Printed. You can view the output using ''View output'' option from Request page');

115: Commit;
116: edw_log.put_line ('Printing Missing Rate Rows Output');
117: edw_log.put_line(' ');
118: PRINT_MISSING_ROWS;
119: edw_log.put_line ('Output Printed. You can view the output using ''View output'' option from Request page');
120: edw_log.put_line(' ');
121:
122: /*Delete all missing rows from FSTG table if source and target are on same instance*/
123: IF (LOCAL_SAME_AS_REMOTE) THEN

Line 120: edw_log.put_line(' ');

116: edw_log.put_line ('Printing Missing Rate Rows Output');
117: edw_log.put_line(' ');
118: PRINT_MISSING_ROWS;
119: edw_log.put_line ('Output Printed. You can view the output using ''View output'' option from Request page');
120: edw_log.put_line(' ');
121:
122: /*Delete all missing rows from FSTG table if source and target are on same instance*/
123: IF (LOCAL_SAME_AS_REMOTE) THEN
124: DELETE OPI_EDW_JOB_RSRC_FSTG

Line 127: edw_log.Put_line(to_char(sql%rowcount) ||' missing Currency Rate Conversion rows deleted from Staging table');

123: IF (LOCAL_SAME_AS_REMOTE) THEN
124: DELETE OPI_EDW_JOB_RSRC_FSTG
125: WHERE COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
126: AND JOB_RSRC_PK like '%OPM';
127: edw_log.Put_line(to_char(sql%rowcount) ||' missing Currency Rate Conversion rows deleted from Staging table');
128: END IF;
129: /* Deletion completed */
130: ELSE
131: edw_log.Put_line('0 rows missing Currency Rate Conversion');

Line 131: edw_log.Put_line('0 rows missing Currency Rate Conversion');

127: edw_log.Put_line(to_char(sql%rowcount) ||' missing Currency Rate Conversion rows deleted from Staging table');
128: END IF;
129: /* Deletion completed */
130: ELSE
131: edw_log.Put_line('0 rows missing Currency Rate Conversion');
132: END IF;
133: EXCEPTION
134: WHEN OTHERS THEN
135: g_errbuf:=sqlerrm;

Line 137: edw_log.put_line('Raised Exception '||sqlerrm);

133: EXCEPTION
134: WHEN OTHERS THEN
135: g_errbuf:=sqlerrm;
136: g_retcode:=sqlcode;
137: edw_log.put_line('Raised Exception '||sqlerrm);
138: END;
139:
140: -----------------------------------------------------------
141: --PROCEDURE PUSH_TO_LOCAL

Line 400: edw_log.put_line( 'The collection range is from '||

396: EDW_COLLECTION_UTIL.G_local_last_push_start_date -
397: EDW_COLLECTION_UTIL.g_offset);
398: g_push_to_date := nvl(l_to_date,
399: EDW_COLLECTION_UTIL.G_local_curr_push_start_date);
400: edw_log.put_line( 'The collection range is from '||
401: to_char(g_push_from_date,'MM/DD/YYYY HH24:MI:SS')||' to '||
402: to_char(g_push_to_date,'MM/DD/YYYY HH24:MI:SS'));
403: edw_log.put_line(' ');
404: l_seq_id := IDENTIFY_OPM_CHANGE(1,l_row_count);

Line 403: edw_log.put_line(' ');

399: EDW_COLLECTION_UTIL.G_local_curr_push_start_date);
400: edw_log.put_line( 'The collection range is from '||
401: to_char(g_push_from_date,'MM/DD/YYYY HH24:MI:SS')||' to '||
402: to_char(g_push_to_date,'MM/DD/YYYY HH24:MI:SS'));
403: edw_log.put_line(' ');
404: l_seq_id := IDENTIFY_OPM_CHANGE(1,l_row_count);
405: if (l_seq_id = -1) THEN
406: RAISE l_iden_change_failure;
407: end if;

Line 412: edw_log.put_line(' ');

408:
409: -- --------------------------------------------
410: -- Push to local staging table
411: -- --------------------------------------------
412: edw_log.put_line(' ');
413: edw_log.put_line('Inserting into local staging table ');
414: l_row_count1 := PUSH_TO_LOCAL(1,l_seq_id);
415: IF (l_row_count1 = -1) THEN RAISE L_push_local_failure; END IF;
416: edw_log.put_line('Inserted '||nvl(l_row_count1,0)||

Line 413: edw_log.put_line('Inserting into local staging table ');

409: -- --------------------------------------------
410: -- Push to local staging table
411: -- --------------------------------------------
412: edw_log.put_line(' ');
413: edw_log.put_line('Inserting into local staging table ');
414: l_row_count1 := PUSH_TO_LOCAL(1,l_seq_id);
415: IF (l_row_count1 = -1) THEN RAISE L_push_local_failure; END IF;
416: edw_log.put_line('Inserted '||nvl(l_row_count1,0)||
417: ' rows into the local staging table ');

Line 416: edw_log.put_line('Inserted '||nvl(l_row_count1,0)||

412: edw_log.put_line(' ');
413: edw_log.put_line('Inserting into local staging table ');
414: l_row_count1 := PUSH_TO_LOCAL(1,l_seq_id);
415: IF (l_row_count1 = -1) THEN RAISE L_push_local_failure; END IF;
416: edw_log.put_line('Inserted '||nvl(l_row_count1,0)||
417: ' rows into the local staging table ');
418: edw_log.put_line(' ');
419: g_row_count:= l_row_count1;
420: edw_log.put_line(' ');

Line 418: edw_log.put_line(' ');

414: l_row_count1 := PUSH_TO_LOCAL(1,l_seq_id);
415: IF (l_row_count1 = -1) THEN RAISE L_push_local_failure; END IF;
416: edw_log.put_line('Inserted '||nvl(l_row_count1,0)||
417: ' rows into the local staging table ');
418: edw_log.put_line(' ');
419: g_row_count:= l_row_count1;
420: edw_log.put_line(' ');
421: edw_log.put_line('For all views types, inserted '||nvl(g_row_count,0)||
422: ' rows into local staging table ');

Line 420: edw_log.put_line(' ');

416: edw_log.put_line('Inserted '||nvl(l_row_count1,0)||
417: ' rows into the local staging table ');
418: edw_log.put_line(' ');
419: g_row_count:= l_row_count1;
420: edw_log.put_line(' ');
421: edw_log.put_line('For all views types, inserted '||nvl(g_row_count,0)||
422: ' rows into local staging table ');
423: -- --------------------------------------------
424: -- No exception raised so far. Call wrapup to transport

Line 421: edw_log.put_line('For all views types, inserted '||nvl(g_row_count,0)||

417: ' rows into the local staging table ');
418: edw_log.put_line(' ');
419: g_row_count:= l_row_count1;
420: edw_log.put_line(' ');
421: edw_log.put_line('For all views types, inserted '||nvl(g_row_count,0)||
422: ' rows into local staging table ');
423: -- --------------------------------------------
424: -- No exception raised so far. Call wrapup to transport
425: -- data to target database, and insert messages into logs

Line 427: edw_log.put_line(' ');

423: -- --------------------------------------------
424: -- No exception raised so far. Call wrapup to transport
425: -- data to target database, and insert messages into logs
426: -- -----------------------------------------------
427: edw_log.put_line(' ');
428: edw_log.put_line('Inserted '||nvl(g_row_count,0)||
429: ' rows into the staging table');
430: edw_log.put_line(' ');
431: EDW_COLLECTION_UTIL.wrapup(TRUE, g_row_count, l_exception_msg,

Line 428: edw_log.put_line('Inserted '||nvl(g_row_count,0)||

424: -- No exception raised so far. Call wrapup to transport
425: -- data to target database, and insert messages into logs
426: -- -----------------------------------------------
427: edw_log.put_line(' ');
428: edw_log.put_line('Inserted '||nvl(g_row_count,0)||
429: ' rows into the staging table');
430: edw_log.put_line(' ');
431: EDW_COLLECTION_UTIL.wrapup(TRUE, g_row_count, l_exception_msg,
432: g_push_from_date, g_push_to_date);

Line 430: edw_log.put_line(' ');

426: -- -----------------------------------------------
427: edw_log.put_line(' ');
428: edw_log.put_line('Inserted '||nvl(g_row_count,0)||
429: ' rows into the staging table');
430: edw_log.put_line(' ');
431: EDW_COLLECTION_UTIL.wrapup(TRUE, g_row_count, l_exception_msg,
432: g_push_from_date, g_push_to_date);
433: -- ---------------------------------------------------------------------------
434: -- END OF Collection , Developer Customizable Section

Line 442: edw_log.put_line('Inserting into local staging have failed');

438: Errbuf:=g_errbuf;
439: Retcode:=g_retcode;
440: l_exception_msg := Retcode || ':' || Errbuf;
441: rollback; -- Rollback insert into local staging
442: edw_log.put_line('Inserting into local staging have failed');
443: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,g_push_from_date,g_push_to_date);
444: raise;
445: WHEN L_IDEN_CHANGE_FAILURE THEN
446: Errbuf:=g_errbuf;

Line 449: edw_log.put_line('Identifying changed records have Failed');

445: WHEN L_IDEN_CHANGE_FAILURE THEN
446: Errbuf:=g_errbuf;
447: Retcode:=g_retcode;
448: l_exception_msg := Retcode || ':' || Errbuf;
449: edw_log.put_line('Identifying changed records have Failed');
450: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,g_push_from_date,g_push_to_date);
451: raise;
452: WHEN OTHERS THEN
453: Errbuf:=g_errbuf;

Line 457: edw_log.put_line('Other errors');

453: Errbuf:=g_errbuf;
454: Retcode:=g_retcode;
455: l_exception_msg := Retcode || ':' || Errbuf;
456: rollback;
457: edw_log.put_line('Other errors');
458: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,
459: g_push_from_date, g_push_to_date);
460: raise;
461: END;