DBA Data[Home] [Help]

APPS.OPI_EDW_OPMCOGS_F_C dependencies on OPI_EDW_OPMCOGS_INC

Line 80: DELETE OPI_EDW_OPMCOGS_INC WHERE SEQ_ID IS NOT NULL;

76: IS
77: l_count number;
78: BEGIN
79: /* Delete the incremental table before inserting new data */
80: DELETE OPI_EDW_OPMCOGS_INC WHERE SEQ_ID IS NOT NULL;
81: edw_log.put_line(' ');
82: SELECT count(*) into l_count from OPI_EDW_COGS_FSTG
83: WHERE COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
84: AND COGS_PK like '%OPM%';

Line 90: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */

86: edw_log.put_line(' ');
87: edw_log.Put_line('Identifying Missing Rate Rows ');
88: edw_log.put_line(' ');
89: /* insert into Incremental table all line_id where Currency is missing */
90: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */
91: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)
92: SELECT
93: SUBSTRB(ORDER_LINE_ID,1,instrB(ORDER_LINE_ID,'-',1,1)-1),
94: 1,

Line 91: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)

87: edw_log.Put_line('Identifying Missing Rate Rows ');
88: edw_log.put_line(' ');
89: /* insert into Incremental table all line_id where Currency is missing */
90: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */
91: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)
92: SELECT
93: SUBSTRB(ORDER_LINE_ID,1,instrB(ORDER_LINE_ID,'-',1,1)-1),
94: 1,
95: NULL

Line 107: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */

103: AND COGS_PK like '%OPM%');
104:
105: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion for View Type 1');
106:
107: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */
108: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)
109: SELECT
110: SUBSTRB(ORDER_LINE_ID,1,instrB(ORDER_LINE_ID,'-',1,1)-1),
111: 2,

Line 108: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)

104:
105: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion for View Type 1');
106:
107: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */
108: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)
109: SELECT
110: SUBSTRB(ORDER_LINE_ID,1,instrB(ORDER_LINE_ID,'-',1,1)-1),
111: 2,
112: NULL

Line 398: select OPI_EDW_OPMCOGS_INC_S.nextval into l_seq_id from dual;

394: l_status VARCHAR2(30);
395: l_industry VARCHAR2(30);
396: BEGIN
397: p_count := 0;
398: select OPI_EDW_OPMCOGS_INC_S.nextval into l_seq_id from dual;
399: IF p_view_id = 1 THEN
400: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */
401: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)
402: SELECT

Line 400: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */

396: BEGIN
397: p_count := 0;
398: select OPI_EDW_OPMCOGS_INC_S.nextval into l_seq_id from dual;
399: IF p_view_id = 1 THEN
400: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */
401: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)
402: SELECT
403: SD.LINE_ID,
404: 1,

Line 401: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)

397: p_count := 0;
398: select OPI_EDW_OPMCOGS_INC_S.nextval into l_seq_id from dual;
399: IF p_view_id = 1 THEN
400: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */
401: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)
402: SELECT
403: SD.LINE_ID,
404: 1,
405: l_seq_id

Line 418: (select LINE_ID from OPI_EDW_OPMCOGS_INC

414: AND SD.LINE_STATUS >= 20
415: AND GREATEST(SH.LAST_UPDATE_DATE, SD.LAST_UPDATE_DATE,PM.LAST_UPDATE_DATE)
416: between g_push_from_date and g_push_to_date and
417: sd.line_id not in
418: (select LINE_ID from OPI_EDW_OPMCOGS_INC
419: WHERE VIEW_ID = 1 AND SEQ_ID is NULL);
420: p_count := sql%rowcount;
421:
422: UPDATE OPI_EDW_OPMCOGS_INC set SEQ_Id=l_SEQ_ID

Line 422: UPDATE OPI_EDW_OPMCOGS_INC set SEQ_Id=l_SEQ_ID

418: (select LINE_ID from OPI_EDW_OPMCOGS_INC
419: WHERE VIEW_ID = 1 AND SEQ_ID is NULL);
420: p_count := sql%rowcount;
421:
422: UPDATE OPI_EDW_OPMCOGS_INC set SEQ_Id=l_SEQ_ID
423: WHERE VIEW_ID=1 AND SEQ_ID is NULL;
424:
425: p_count := P_count+sql%rowcount;
426:

Line 428: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */

424:
425: p_count := P_count+sql%rowcount;
426:
427: ELSIF p_view_id =2 THEN
428: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */
429: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)
430: SELECT
431: IT.LINE_ID,
432: 2,

Line 429: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)

425: p_count := P_count+sql%rowcount;
426:
427: ELSIF p_view_id =2 THEN
428: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */
429: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)
430: SELECT
431: IT.LINE_ID,
432: 2,
433: l_seq_id

Line 447: (select LINE_ID from OPI_EDW_OPMCOGS_INC

443: IT.DOC_TYPE = 'OMSO' AND
444: GREATEST(OOL.LAST_UPDATE_DATE, OOH.LAST_UPDATE_DATE)
445: between g_push_from_date and g_push_to_date AND
446: IT.LINE_ID not in
447: (select LINE_ID from OPI_EDW_OPMCOGS_INC
448: WHERE VIEW_ID = 2 AND SEQ_ID is NULL);
449: p_count := sql%rowcount;
450:
451: UPDATE OPI_EDW_OPMCOGS_INC set SEQ_Id=l_SEQ_ID

Line 451: UPDATE OPI_EDW_OPMCOGS_INC set SEQ_Id=l_SEQ_ID

447: (select LINE_ID from OPI_EDW_OPMCOGS_INC
448: WHERE VIEW_ID = 2 AND SEQ_ID is NULL);
449: p_count := sql%rowcount;
450:
451: UPDATE OPI_EDW_OPMCOGS_INC set SEQ_Id=l_SEQ_ID
452: WHERE VIEW_ID=2 AND SEQ_ID is NULL;
453: p_count := P_count+sql%rowcount;
454: END IF;
455:

Line 460: TABNAME => 'OPI_EDW_OPMCOGS_INC');

456: Commit;
457:
458: IF (FND_INSTALLATION.GET_APP_INFO('OPI', l_status, l_industry, l_pmi_schema)) THEN
459: FND_STATS.GATHER_TABLE_STATS(OWNNAME => l_pmi_schema,
460: TABNAME => 'OPI_EDW_OPMCOGS_INC');
461: END IF;
462:
463:
464: RETURN(l_seq_id);

Line 548: TABNAME => 'OPI_EDW_OPMCOGS_INC');

544: -- Analyze the incremental table
545: -- --------------------------------------------
546: IF (FND_INSTALLATION.GET_APP_INFO('OPI', l_status, l_industry, l_pmi_schema)) THEN
547: FND_STATS.GATHER_TABLE_STATS(OWNNAME => l_pmi_schema,
548: TABNAME => 'OPI_EDW_OPMCOGS_INC');
549: END IF;
550: -- --------------------------------------------
551: -- Push to local staging table
552: -- --------------------------------------------

Line 591: delete OPI_EDW_OPMCOGS_INC;

587:
588: -- --------------------------------------------
589: -- Delete all incremental tables record
590: -- --------------------------------------------
591: delete OPI_EDW_OPMCOGS_INC;
592: commit;
593: -- --------------------------------------------
594: -- No exception raised so far. Call wrapup to transport
595: -- data to target database, and insert messages into logs

Line 616: delete OPI_EDW_OPMCOGS_INC;

612: edw_log.put_line('Inserting into local staging have failed');
613: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,
614: g_push_from_date, g_push_to_date);
615: l_exception_msg := Retcode || ':' || Errbuf;
616: delete OPI_EDW_OPMCOGS_INC;
617: commit;
618: raise;
619: WHEN L_IDEN_CHANGE_FAILURE THEN
620: Errbuf:=g_errbuf;

Line 623: delete OPI_EDW_OPMCOGS_INC;

619: WHEN L_IDEN_CHANGE_FAILURE THEN
620: Errbuf:=g_errbuf;
621: Retcode:=g_retcode;
622: l_exception_msg := Retcode || ':' || Errbuf;
623: delete OPI_EDW_OPMCOGS_INC;
624: commit;
625: edw_log.put_line('Identifying changed records have Failed');
626: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,
627: g_push_from_date, g_push_to_date);

Line 638: delete OPI_EDW_OPMCOGS_INC;

634: edw_log.put_line('Other errors');
635: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,
636: g_push_from_date, g_push_to_date);
637: l_exception_msg := Retcode || ':' || Errbuf;
638: delete OPI_EDW_OPMCOGS_INC;
639: commit;
640: raise;
641: END;
642: END OPI_EDW_OPMCOGS_F_C;