DBA Data[Home] [Help]

APPS.OPI_EDW_OPMINV_DAILY_STAT_F_C dependencies on EDW_LOG

Line 52: edw_log.put_line(' ');

48: AND INV_DAILY_STATUS_PK like '%OPM';
49:
50: BEGIN
51: /* Print Header */
52: edw_log.put_line(' ');
53: edw_log.put_line ('Identified Missing Rows Date:'||SYSDATE);
54:
55: edw_log.put_line (' ');
56: edw_log.put_line (' ');

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

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

Line 55: edw_log.put_line (' ');

51: /* Print Header */
52: edw_log.put_line(' ');
53: edw_log.put_line ('Identified Missing Rows Date:'||SYSDATE);
54:
55: edw_log.put_line (' ');
56: edw_log.put_line (' ');
57:
58: edw_log.put_line ('Primary Key is OPMSUM.CO_CODE-OPMSUM.ORGN_CODE-OPMSUM.WHSE_CODE-
59: OPMSUM.LOCATION-OPMSUM.ITEM_ID-OPMSUM.TRX_DATE -OPMSUM.LOT_ID - OPMCOSTGROUP - INST.INSTANCE_CODE -OPM');

Line 56: edw_log.put_line (' ');

52: edw_log.put_line(' ');
53: edw_log.put_line ('Identified Missing Rows Date:'||SYSDATE);
54:
55: edw_log.put_line (' ');
56: edw_log.put_line (' ');
57:
58: edw_log.put_line ('Primary Key is OPMSUM.CO_CODE-OPMSUM.ORGN_CODE-OPMSUM.WHSE_CODE-
59: OPMSUM.LOCATION-OPMSUM.ITEM_ID-OPMSUM.TRX_DATE -OPMSUM.LOT_ID - OPMCOSTGROUP - INST.INSTANCE_CODE -OPM');
60: edw_log.put_line ('-----------------------------------------');

Line 58: edw_log.put_line ('Primary Key is OPMSUM.CO_CODE-OPMSUM.ORGN_CODE-OPMSUM.WHSE_CODE-

54:
55: edw_log.put_line (' ');
56: edw_log.put_line (' ');
57:
58: edw_log.put_line ('Primary Key is OPMSUM.CO_CODE-OPMSUM.ORGN_CODE-OPMSUM.WHSE_CODE-
59: OPMSUM.LOCATION-OPMSUM.ITEM_ID-OPMSUM.TRX_DATE -OPMSUM.LOT_ID - OPMCOSTGROUP - INST.INSTANCE_CODE -OPM');
60: edw_log.put_line ('-----------------------------------------');
61: edw_log.put_line ('Primary Key / Currency / Transaction Date');
62: edw_log.put_line ('-----------------------------------------');

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

56: edw_log.put_line (' ');
57:
58: edw_log.put_line ('Primary Key is OPMSUM.CO_CODE-OPMSUM.ORGN_CODE-OPMSUM.WHSE_CODE-
59: OPMSUM.LOCATION-OPMSUM.ITEM_ID-OPMSUM.TRX_DATE -OPMSUM.LOT_ID - OPMCOSTGROUP - INST.INSTANCE_CODE -OPM');
60: edw_log.put_line ('-----------------------------------------');
61: edw_log.put_line ('Primary Key / Currency / Transaction Date');
62: edw_log.put_line ('-----------------------------------------');
63: /* Print Rows */
64:

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

57:
58: edw_log.put_line ('Primary Key is OPMSUM.CO_CODE-OPMSUM.ORGN_CODE-OPMSUM.WHSE_CODE-
59: OPMSUM.LOCATION-OPMSUM.ITEM_ID-OPMSUM.TRX_DATE -OPMSUM.LOT_ID - OPMCOSTGROUP - INST.INSTANCE_CODE -OPM');
60: edw_log.put_line ('-----------------------------------------');
61: edw_log.put_line ('Primary Key / Currency / Transaction Date');
62: edw_log.put_line ('-----------------------------------------');
63: /* Print Rows */
64:
65: For l_rows in missing_rate loop

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

58: edw_log.put_line ('Primary Key is OPMSUM.CO_CODE-OPMSUM.ORGN_CODE-OPMSUM.WHSE_CODE-
59: OPMSUM.LOCATION-OPMSUM.ITEM_ID-OPMSUM.TRX_DATE -OPMSUM.LOT_ID - OPMCOSTGROUP - INST.INSTANCE_CODE -OPM');
60: edw_log.put_line ('-----------------------------------------');
61: edw_log.put_line ('Primary Key / Currency / Transaction Date');
62: edw_log.put_line ('-----------------------------------------');
63: /* Print Rows */
64:
65: For l_rows in missing_rate loop
66: edw_log.put_line (l_rows.INV_DAILY_STATUS_PK||' / '||l_rows.BASE_CURRENCY_FK||' / '||l_rows.TRX_DATE_FK);

Line 66: edw_log.put_line (l_rows.INV_DAILY_STATUS_PK||' / '||l_rows.BASE_CURRENCY_FK||' / '||l_rows.TRX_DATE_FK);

62: edw_log.put_line ('-----------------------------------------');
63: /* Print Rows */
64:
65: For l_rows in missing_rate loop
66: edw_log.put_line (l_rows.INV_DAILY_STATUS_PK||' / '||l_rows.BASE_CURRENCY_FK||' / '||l_rows.TRX_DATE_FK);
67: end loop;
68: edw_log.put_line(' ');
69: edw_log.put_line(' ');
70: EXCEPTION

Line 68: edw_log.put_line(' ');

64:
65: For l_rows in missing_rate loop
66: edw_log.put_line (l_rows.INV_DAILY_STATUS_PK||' / '||l_rows.BASE_CURRENCY_FK||' / '||l_rows.TRX_DATE_FK);
67: end loop;
68: edw_log.put_line(' ');
69: edw_log.put_line(' ');
70: EXCEPTION
71: WHEN OTHERS THEN
72: g_errbuf:=sqlerrm;

Line 69: edw_log.put_line(' ');

65: For l_rows in missing_rate loop
66: edw_log.put_line (l_rows.INV_DAILY_STATUS_PK||' / '||l_rows.BASE_CURRENCY_FK||' / '||l_rows.TRX_DATE_FK);
67: end loop;
68: edw_log.put_line(' ');
69: edw_log.put_line(' ');
70: EXCEPTION
71: WHEN OTHERS THEN
72: g_errbuf:=sqlerrm;
73: g_retcode:=sqlcode;

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

70: EXCEPTION
71: WHEN OTHERS THEN
72: g_errbuf:=sqlerrm;
73: g_retcode:=sqlcode;
74: edw_log.put_line('Raised Exception from PRINT_MISSING_RATE '||sqlerrm);
75: END;
76:
77: PROCEDURE PUSH_MISSING_ROWS
78: IS

Line 83: edw_log.put_line(' ');

79: l_count number;
80: BEGIN
81: /* Delete the incremental table before inserting new data */
82: DELETE OPI_EDW_OPMINV_DAILY_STAT_INC WHERE SEQ_ID IS NOT NULL;
83: edw_log.put_line(' ');
84: edw_log.Put_line('Identifying Missing Rate Rows ');
85: edw_log.put_line(' ');
86: SELECT count(*) into l_count from opi_edw_inv_daily_stat_fstg where
87: COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')

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

80: BEGIN
81: /* Delete the incremental table before inserting new data */
82: DELETE OPI_EDW_OPMINV_DAILY_STAT_INC WHERE SEQ_ID IS NOT NULL;
83: edw_log.put_line(' ');
84: edw_log.Put_line('Identifying Missing Rate Rows ');
85: edw_log.put_line(' ');
86: SELECT count(*) into l_count from opi_edw_inv_daily_stat_fstg where
87: COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
88: AND INV_DAILY_STATUS_PK like '%OPM';

Line 85: edw_log.put_line(' ');

81: /* Delete the incremental table before inserting new data */
82: DELETE OPI_EDW_OPMINV_DAILY_STAT_INC WHERE SEQ_ID IS NOT NULL;
83: edw_log.put_line(' ');
84: edw_log.Put_line('Identifying Missing Rate Rows ');
85: edw_log.put_line(' ');
86: SELECT count(*) into l_count from opi_edw_inv_daily_stat_fstg where
87: COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
88: AND INV_DAILY_STATUS_PK like '%OPM';
89: IF l_count > 0 THEN

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

115: INV_DAILY_STATUS_PK in ( SELECT INV_DAILY_STATUS_PK
116: FROM opi_edw_inv_daily_stat_fstg
117: WHERE COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
118: AND INV_DAILY_STATUS_PK like '%OPM');
119: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion');
120: edw_log.put_line(' ');
121: Commit;
122: edw_log.put_line ('Printing Missing Rate Rows Output');
123: edw_log.put_line(' ');

Line 120: edw_log.put_line(' ');

116: FROM opi_edw_inv_daily_stat_fstg
117: WHERE COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
118: AND INV_DAILY_STATUS_PK like '%OPM');
119: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion');
120: edw_log.put_line(' ');
121: Commit;
122: edw_log.put_line ('Printing Missing Rate Rows Output');
123: edw_log.put_line(' ');
124: PRINT_MISSING_ROWS;

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

118: AND INV_DAILY_STATUS_PK like '%OPM');
119: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion');
120: edw_log.put_line(' ');
121: Commit;
122: edw_log.put_line ('Printing Missing Rate Rows Output');
123: edw_log.put_line(' ');
124: PRINT_MISSING_ROWS;
125: edw_log.put_line ('Output Printed. You can view the output using ''View output'' option from Request page');
126: edw_log.put_line(' ');

Line 123: edw_log.put_line(' ');

119: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion');
120: edw_log.put_line(' ');
121: Commit;
122: edw_log.put_line ('Printing Missing Rate Rows Output');
123: edw_log.put_line(' ');
124: PRINT_MISSING_ROWS;
125: edw_log.put_line ('Output Printed. You can view the output using ''View output'' option from Request page');
126: edw_log.put_line(' ');
127:

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

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

Line 126: edw_log.put_line(' ');

122: edw_log.put_line ('Printing Missing Rate Rows Output');
123: edw_log.put_line(' ');
124: PRINT_MISSING_ROWS;
125: edw_log.put_line ('Output Printed. You can view the output using ''View output'' option from Request page');
126: edw_log.put_line(' ');
127:
128: /*Delete all missing rows from FSTG table if source and target are on same instance*/
129: IF (LOCAL_SAME_AS_REMOTE) THEN
130: DELETE opi_edw_inv_daily_stat_fstg

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

129: IF (LOCAL_SAME_AS_REMOTE) THEN
130: DELETE opi_edw_inv_daily_stat_fstg
131: WHERE COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
132: AND INV_DAILY_STATUS_PK like '%OPM';
133: edw_log.Put_line(to_char(sql%rowcount) ||' missing Currency Rate Conversion rows deleted from Staging table');
134: END IF;
135: /* Deletion completed */
136: ELSE
137: edw_log.Put_line('0 rows missing Currency Rate Conversion');

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

133: edw_log.Put_line(to_char(sql%rowcount) ||' missing Currency Rate Conversion rows deleted from Staging table');
134: END IF;
135: /* Deletion completed */
136: ELSE
137: edw_log.Put_line('0 rows missing Currency Rate Conversion');
138: END IF;
139: EXCEPTION
140: WHEN OTHERS THEN
141: g_errbuf:=sqlerrm;

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

139: EXCEPTION
140: WHEN OTHERS THEN
141: g_errbuf:=sqlerrm;
142: g_retcode:=sqlcode;
143: edw_log.put_line('Raised Exception '||sqlerrm);
144: END;
145:
146: -- ---------------------------------
147: -- PUBLIC PROCEDURES

Line 207: edw_log.put_line('Sequence is '||to_char(l_seq_id));

203: FND_STATS.GATHER_TABLE_STATS(OWNNAME => l_OPI_schema,
204: TABNAME => 'OPI_EDW_OPMINV_DAILY_STAT_INC');
205: END IF;
206:
207: edw_log.put_line('Sequence is '||to_char(l_seq_id));
208: RETURN(l_seq_id);
209: EXCEPTION
210: WHEN OTHERS THEN
211: g_errbuf:=sqlerrm;

Line 213: edw_log.put_line('Rasied Exception '||sqlerrm);

209: EXCEPTION
210: WHEN OTHERS THEN
211: g_errbuf:=sqlerrm;
212: g_retcode:=sqlcode;
213: edw_log.put_line('Rasied Exception '||sqlerrm);
214:
215: RETURN(-1);
216: END;
217:

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

514: EDW_COLLECTION_UTIL.G_local_last_push_start_date -
515: EDW_COLLECTION_UTIL.g_offset);
516: g_push_to_date := nvl(l_to_date,
517: EDW_COLLECTION_UTIL.G_local_curr_push_start_date);
518: edw_log.put_line( 'The collection range is from '||
519: to_char(g_push_from_date,'MM/DD/YYYY HH24:MI:SS')||' to '||
520: to_char(g_push_to_date,'MM/DD/YYYY HH24:MI:SS'));
521: edw_log.put_line(' ');
522:

Line 521: edw_log.put_line(' ');

517: EDW_COLLECTION_UTIL.G_local_curr_push_start_date);
518: edw_log.put_line( 'The collection range is from '||
519: to_char(g_push_from_date,'MM/DD/YYYY HH24:MI:SS')||' to '||
520: to_char(g_push_to_date,'MM/DD/YYYY HH24:MI:SS'));
521: edw_log.put_line(' ');
522:
523: edw_log.put_line(' ');
524: edw_log.put_line('Identifying changes in view type 1');
525: l_seq_id1 := IDENTIFY_OPM_CHANGE(1,l_row_count);

Line 523: edw_log.put_line(' ');

519: to_char(g_push_from_date,'MM/DD/YYYY HH24:MI:SS')||' to '||
520: to_char(g_push_to_date,'MM/DD/YYYY HH24:MI:SS'));
521: edw_log.put_line(' ');
522:
523: edw_log.put_line(' ');
524: edw_log.put_line('Identifying changes in view type 1');
525: l_seq_id1 := IDENTIFY_OPM_CHANGE(1,l_row_count);
526: edw_log.put_line('Sequence is '||to_char(l_seq_id1));
527:

Line 524: edw_log.put_line('Identifying changes in view type 1');

520: to_char(g_push_to_date,'MM/DD/YYYY HH24:MI:SS'));
521: edw_log.put_line(' ');
522:
523: edw_log.put_line(' ');
524: edw_log.put_line('Identifying changes in view type 1');
525: l_seq_id1 := IDENTIFY_OPM_CHANGE(1,l_row_count);
526: edw_log.put_line('Sequence is '||to_char(l_seq_id1));
527:
528: if (l_seq_id1 = -1) THEN

Line 526: edw_log.put_line('Sequence is '||to_char(l_seq_id1));

522:
523: edw_log.put_line(' ');
524: edw_log.put_line('Identifying changes in view type 1');
525: l_seq_id1 := IDENTIFY_OPM_CHANGE(1,l_row_count);
526: edw_log.put_line('Sequence is '||to_char(l_seq_id1));
527:
528: if (l_seq_id1 = -1) THEN
529: RAISE l_iden_change_failure;
530: end if;

Line 531: edw_log.put_line ('Identified '||l_row_count||' changed records in view type 1');

527:
528: if (l_seq_id1 = -1) THEN
529: RAISE l_iden_change_failure;
530: end if;
531: edw_log.put_line ('Identified '||l_row_count||' changed records in view type 1');
532:
533: -- --------------------------------------------
534: -- Push to local staging table
535: -- --------------------------------------------

Line 537: edw_log.put_line(' ');

533: -- --------------------------------------------
534: -- Push to local staging table
535: -- --------------------------------------------
536:
537: edw_log.put_line(' ');
538: edw_log.put_line('Inserting into local staging table ');
539: l_row_count1 := PUSH_TO_LOCAL(1,l_seq_id1);
540:
541: IF (l_row_count1 = -1) THEN RAISE L_push_local_failure; END IF;

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

534: -- Push to local staging table
535: -- --------------------------------------------
536:
537: edw_log.put_line(' ');
538: edw_log.put_line('Inserting into local staging table ');
539: l_row_count1 := PUSH_TO_LOCAL(1,l_seq_id1);
540:
541: IF (l_row_count1 = -1) THEN RAISE L_push_local_failure; END IF;
542:

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

539: l_row_count1 := PUSH_TO_LOCAL(1,l_seq_id1);
540:
541: IF (l_row_count1 = -1) THEN RAISE L_push_local_failure; END IF;
542:
543: edw_log.put_line('Inserted '||nvl(l_row_count1,0)||
544: ' rows into the local staging table ');
545: edw_log.put_line(' ');
546:
547: g_row_count:= l_row_count1;

Line 545: edw_log.put_line(' ');

541: IF (l_row_count1 = -1) THEN RAISE L_push_local_failure; END IF;
542:
543: edw_log.put_line('Inserted '||nvl(l_row_count1,0)||
544: ' rows into the local staging table ');
545: edw_log.put_line(' ');
546:
547: g_row_count:= l_row_count1;
548:
549: edw_log.put_line(' ');

Line 549: edw_log.put_line(' ');

545: edw_log.put_line(' ');
546:
547: g_row_count:= l_row_count1;
548:
549: edw_log.put_line(' ');
550: edw_log.put_line('For all views types, inserted '||nvl(g_row_count,0)||
551: ' rows into local staging table ');
552:
553:

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

546:
547: g_row_count:= l_row_count1;
548:
549: edw_log.put_line(' ');
550: edw_log.put_line('For all views types, inserted '||nvl(g_row_count,0)||
551: ' rows into local staging table ');
552:
553:
554: -- --------------------------------------------

Line 558: edw_log.put_line(' ');

554: -- --------------------------------------------
555: -- No exception raised so far. Call wrapup to transport
556: -- data to target database, and insert messages into logs
557: -- -----------------------------------------------
558: edw_log.put_line(' ');
559: edw_log.put_line('Inserted '||nvl(g_row_count,0)||
560: ' rows into the staging table');
561: edw_log.put_line(' ');
562: /* Update Data Which has been pushed */

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

555: -- No exception raised so far. Call wrapup to transport
556: -- data to target database, and insert messages into logs
557: -- -----------------------------------------------
558: edw_log.put_line(' ');
559: edw_log.put_line('Inserted '||nvl(g_row_count,0)||
560: ' rows into the staging table');
561: edw_log.put_line(' ');
562: /* Update Data Which has been pushed */
563: UPDATE OPI_PMI_INV_DAILY_STAT_SUM

Line 561: edw_log.put_line(' ');

557: -- -----------------------------------------------
558: edw_log.put_line(' ');
559: edw_log.put_line('Inserted '||nvl(g_row_count,0)||
560: ' rows into the staging table');
561: edw_log.put_line(' ');
562: /* Update Data Which has been pushed */
563: UPDATE OPI_PMI_INV_DAILY_STAT_SUM
564: SET DATA_PUSHED_IND = 1
565: WHERE LAST_UPDATE_DATE BETWEEN g_push_from_date AND g_push_to_date AND

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

585: Errbuf:=g_errbuf;
586: Retcode:=g_retcode;
587: l_exception_msg := Retcode || ':' || Errbuf;
588: rollback; -- Rollback insert into local staging
589: edw_log.put_line('Inserting into local staging have failed');
590: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,g_push_from_date,g_push_to_date);
591: raise;
592:
593: WHEN L_IDEN_CHANGE_FAILURE THEN

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

593: WHEN L_IDEN_CHANGE_FAILURE THEN
594: Errbuf:=g_errbuf;
595: Retcode:=g_retcode;
596: l_exception_msg := Retcode || ':' || Errbuf;
597: edw_log.put_line('Identifying changed records have Failed');
598: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,g_push_from_date,g_push_to_date);
599: raise;
600:
601: WHEN OTHERS THEN

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

602: Errbuf:=g_errbuf;
603: Retcode:=g_retcode;
604: l_exception_msg := Retcode || ':' || Errbuf;
605: rollback;
606: edw_log.put_line('Other errors');
607: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,
608: g_push_from_date, g_push_to_date);
609: raise;
610: