69: lv_retcode NUMBER;
70:
71: BEGIN
72:
73: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
74: lv_tbl:= 'JOB_OP_RES_INSTANCES_'||MSC_CL_COLLECTION.v_instance_code;
75: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
76: ELSE
77: lv_tbl:= 'MSC_JOB_OP_RES_INSTANCES';
70:
71: BEGIN
72:
73: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
74: lv_tbl:= 'JOB_OP_RES_INSTANCES_'||MSC_CL_COLLECTION.v_instance_code;
75: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
76: ELSE
77: lv_tbl:= 'MSC_JOB_OP_RES_INSTANCES';
78: lv_supplies_tbl:= 'MSC_SUPPLIES';
71: BEGIN
72:
73: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
74: lv_tbl:= 'JOB_OP_RES_INSTANCES_'||MSC_CL_COLLECTION.v_instance_code;
75: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
76: ELSE
77: lv_tbl:= 'MSC_JOB_OP_RES_INSTANCES';
78: lv_supplies_tbl:= 'MSC_SUPPLIES';
79: END IF;
77: lv_tbl:= 'MSC_JOB_OP_RES_INSTANCES';
78: lv_supplies_tbl:= 'MSC_SUPPLIES';
79: END IF;
80:
81: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
82:
83: lv_cursor_stmt:=
84: 'SELECT'
85: ||' ms.TRANSACTION_ID,'
92: ||' resi.SR_INSTANCE_ID'
93: ||' FROM '||lv_supplies_tbl||' ms,'
94: ||' MSC_ST_JOB_OP_RES_INSTANCES resi,'
95: ||' MSC_ITEM_ID_LID t1 '
96: ||' WHERE resi.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
97: ||' AND ms.PLAN_ID= -1'
98: ||' AND ms.SR_INSTANCE_ID= resi.SR_INSTANCE_ID'
99: ||' AND ms.DISPOSITION_ID= resi.WIP_ENTITY_ID'
100: ||' AND ms.ORDER_TYPE IN ( 3, 7)'
160: ||' resi.BATCH_NUMBER'
161: ||' FROM '||lv_supplies_tbl||' ms,'
162: ||' MSC_ST_JOB_OP_RES_INSTANCES resi, '
163: ||' MSC_ITEM_ID_LID t1 '
164: ||' WHERE resi.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
165: ||' AND ms.PLAN_ID= -1'
166: ||' AND ms.SR_INSTANCE_ID= resi.SR_INSTANCE_ID'
167: ||' AND ms.DISPOSITION_ID= resi.WIP_ENTITY_ID'
168: ||' AND ms.ORDER_TYPE IN ( 3, 7)'
233: EXIT WHEN cgen%NOTFOUND;
234:
235: BEGIN
236:
237: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
238: /* we can get rid of thsi update if we insert in ad table when instance is updated */
239: UPDATE MSC_JOB_OP_RES_INSTANCES
240: SET
241: START_DATE = lv_START_DATE,
240: SET
241: START_DATE = lv_START_DATE,
242: COMPLETION_DATE = lv_COMPLETION_DATE,
243: BATCH_NUMBER = lv_BATCH_NUMBER,
244: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
245: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
246: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
247: WHERE PLAN_ID= -1
248: AND SR_INSTANCE_ID = lv_SR_INSTANCE_ID
241: START_DATE = lv_START_DATE,
242: COMPLETION_DATE = lv_COMPLETION_DATE,
243: BATCH_NUMBER = lv_BATCH_NUMBER,
244: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
245: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
246: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
247: WHERE PLAN_ID= -1
248: AND SR_INSTANCE_ID = lv_SR_INSTANCE_ID
249: AND TRANSACTION_ID = lv_TRANSACTION_ID
242: COMPLETION_DATE = lv_COMPLETION_DATE,
243: BATCH_NUMBER = lv_BATCH_NUMBER,
244: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
245: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
246: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
247: WHERE PLAN_ID= -1
248: AND SR_INSTANCE_ID = lv_SR_INSTANCE_ID
249: AND TRANSACTION_ID = lv_TRANSACTION_ID
250: AND ORGANIZATION_ID = lv_ORGANIZATION_ID
254: AND SERIAL_NUMBER = lv_SERIAL_NUMBER;
255:
256: END IF;
257:
258: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
259:
260: EXECUTE IMMEDIATE lv_sql_stmt
261: USING
262: lv_TRANSACTION_ID ,
270: lv_COMPLETION_DATE,
271: lv_ORGANIZATION_ID ,
272: lv_BATCH_NUMBER,
273: lv_SR_INSTANCE_ID,
274: MSC_CL_COLLECTION.v_last_collection_id,
275: MSC_CL_COLLECTION.v_current_date,
276: MSC_CL_COLLECTION.v_current_user,
277: MSC_CL_COLLECTION.v_current_date,
278: MSC_CL_COLLECTION.v_current_user;
271: lv_ORGANIZATION_ID ,
272: lv_BATCH_NUMBER,
273: lv_SR_INSTANCE_ID,
274: MSC_CL_COLLECTION.v_last_collection_id,
275: MSC_CL_COLLECTION.v_current_date,
276: MSC_CL_COLLECTION.v_current_user,
277: MSC_CL_COLLECTION.v_current_date,
278: MSC_CL_COLLECTION.v_current_user;
279: END IF;
272: lv_BATCH_NUMBER,
273: lv_SR_INSTANCE_ID,
274: MSC_CL_COLLECTION.v_last_collection_id,
275: MSC_CL_COLLECTION.v_current_date,
276: MSC_CL_COLLECTION.v_current_user,
277: MSC_CL_COLLECTION.v_current_date,
278: MSC_CL_COLLECTION.v_current_user;
279: END IF;
280: total_count := total_count + 1;
273: lv_SR_INSTANCE_ID,
274: MSC_CL_COLLECTION.v_last_collection_id,
275: MSC_CL_COLLECTION.v_current_date,
276: MSC_CL_COLLECTION.v_current_user,
277: MSC_CL_COLLECTION.v_current_date,
278: MSC_CL_COLLECTION.v_current_user;
279: END IF;
280: total_count := total_count + 1;
281: c_count:= c_count+1;
274: MSC_CL_COLLECTION.v_last_collection_id,
275: MSC_CL_COLLECTION.v_current_date,
276: MSC_CL_COLLECTION.v_current_user,
277: MSC_CL_COLLECTION.v_current_date,
278: MSC_CL_COLLECTION.v_current_user;
279: END IF;
280: total_count := total_count + 1;
281: c_count:= c_count+1;
282:
279: END IF;
280: total_count := total_count + 1;
281: c_count:= c_count+1;
282:
283: IF c_count> MSC_CL_COLLECTION.PBS THEN
284: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN COMMIT; END IF;
285: c_count:= 0;
286: END IF;
287:
280: total_count := total_count + 1;
281: c_count:= c_count+1;
282:
283: IF c_count> MSC_CL_COLLECTION.PBS THEN
284: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN COMMIT; END IF;
285: c_count:= 0;
286: END IF;
287:
288: EXCEPTION
300: RAISE;
301:
302: ELSE
303:
304: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
305:
306: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
307: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
308: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_JOB_OP_RES_INSTANCE');
312: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
313: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
314: FND_MESSAGE.SET_TOKEN('VALUE',
315: MSC_GET_NAME.ORG_CODE( lv_ORGANIZATION_ID,
316: MSC_CL_COLLECTION.v_instance_id));
317: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
318:
319: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
320: END IF;
330: COMMIT;
331:
332: BEGIN
333:
334: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
335:
336: lv_tbl:= 'JOB_OP_RES_INSTANCES_'||MSC_CL_COLLECTION.v_instance_code;
337:
338: lv_sql_stmt:=
332: BEGIN
333:
334: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
335:
336: lv_tbl:= 'JOB_OP_RES_INSTANCES_'||MSC_CL_COLLECTION.v_instance_code;
337:
338: lv_sql_stmt:=
339: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
340: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_JOB_OP_RES_INSTANCES'
337:
338: lv_sql_stmt:=
339: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
340: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_JOB_OP_RES_INSTANCES'
341: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
342: ||' AND plan_id = -1 '
343: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
344:
345: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '||lv_sql_stmt);
355: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
356: RAISE;
357: END;
358:
359: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
360: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
361: lv_retcode,
362: 'MSC_JOB_OP_RES_INSTANCES',
363: MSC_CL_COLLECTION.v_instance_code,
356: RAISE;
357: END;
358:
359: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
360: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
361: lv_retcode,
362: 'MSC_JOB_OP_RES_INSTANCES',
363: MSC_CL_COLLECTION.v_instance_code,
364: MSC_UTIL.G_WARNING
359: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
360: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
361: lv_retcode,
362: 'MSC_JOB_OP_RES_INSTANCES',
363: MSC_CL_COLLECTION.v_instance_code,
364: MSC_UTIL.G_WARNING
365: );
366:
367: IF lv_retcode = MSC_UTIL.G_ERROR THEN
365: );
366:
367: IF lv_retcode = MSC_UTIL.G_ERROR THEN
368: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
369: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
370: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
371: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
372: END IF;
373:
367: IF lv_retcode = MSC_UTIL.G_ERROR THEN
368: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
369: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
370: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
371: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
372: END IF;
373:
374: END IF;
375:
433: lv_actual_end_date DATE;
434: lv_Operation_desc VARCHAR2(240) ;
435: BEGIN
436:
437: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
438: lv_tbl:= 'JOB_OPERATIONS_'||MSC_CL_COLLECTION.v_instance_code;
439: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
440: ELSE
441: lv_tbl:= 'MSC_JOB_OPERATIONS';
434: lv_Operation_desc VARCHAR2(240) ;
435: BEGIN
436:
437: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
438: lv_tbl:= 'JOB_OPERATIONS_'||MSC_CL_COLLECTION.v_instance_code;
439: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
440: ELSE
441: lv_tbl:= 'MSC_JOB_OPERATIONS';
442: lv_supplies_tbl:= 'MSC_SUPPLIES';
435: BEGIN
436:
437: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
438: lv_tbl:= 'JOB_OPERATIONS_'||MSC_CL_COLLECTION.v_instance_code;
439: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
440: ELSE
441: lv_tbl:= 'MSC_JOB_OPERATIONS';
442: lv_supplies_tbl:= 'MSC_SUPPLIES';
443: END IF;
441: lv_tbl:= 'MSC_JOB_OPERATIONS';
442: lv_supplies_tbl:= 'MSC_SUPPLIES';
443: END IF;
444:
445: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
446:
447: lv_cursor_stmt:=
448: 'SELECT'
449: ||' ms.TRANSACTION_ID,'
450: ||' opr.OPERATION_SEQ_NUM,'
451: ||' opr.SR_INSTANCE_ID'
452: ||' FROM '||lv_supplies_tbl||' ms,'
453: ||' MSC_ST_JOB_OPERATIONS opr'
454: ||' WHERE opr.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
455: ||' AND ms.PLAN_ID= -1'
456: ||' AND ms.SR_INSTANCE_ID= opr.SR_INSTANCE_ID'
457: ||' AND ms.DISPOSITION_ID= opr.WIP_ENTITY_ID'
458: ||' AND ms.ORDER_TYPE IN ( 3, 7,70)'
515: ||' opr.actual_end_date,'
516: ||' opr.Operation_desc'
517: ||' FROM '||lv_supplies_tbl||' ms,'
518: ||' MSC_ST_JOB_OPERATIONS opr'
519: ||' WHERE opr.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
520: ||' AND ms.PLAN_ID= -1'
521: ||' AND ms.SR_INSTANCE_ID= opr.SR_INSTANCE_ID'
522: ||' AND ms.DISPOSITION_ID= opr.WIP_ENTITY_ID'
523: ||' AND ms.ORDER_TYPE IN ( 3, 7,70)'
624: EXIT WHEN cgen%NOTFOUND;
625:
626: BEGIN
627:
628: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
629:
630: UPDATE MSC_JOB_OPERATIONS
631: SET
632: RECOMMENDED = lv_RECOMMENDED,
644: YIELD = lv_YIELD,
645: CUMULATIVE_YIELD = lv_CUMULATIVE_YIELD,
646: REVERSE_CUMULATIVE_YIELD = lv_REVERSE_CUMULATIVE_YIELD,
647: NET_PLANNING_PERCENT = lv_NET_PLANNING_PERCENT,
648: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
649: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
650: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
651: WHERE PLAN_ID= -1
652: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
645: CUMULATIVE_YIELD = lv_CUMULATIVE_YIELD,
646: REVERSE_CUMULATIVE_YIELD = lv_REVERSE_CUMULATIVE_YIELD,
647: NET_PLANNING_PERCENT = lv_NET_PLANNING_PERCENT,
648: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
649: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
650: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
651: WHERE PLAN_ID= -1
652: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
653: AND TRANSACTION_ID= lv_TRANSACTION_ID
646: REVERSE_CUMULATIVE_YIELD = lv_REVERSE_CUMULATIVE_YIELD,
647: NET_PLANNING_PERCENT = lv_NET_PLANNING_PERCENT,
648: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
649: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
650: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
651: WHERE PLAN_ID= -1
652: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
653: AND TRANSACTION_ID= lv_TRANSACTION_ID
654: AND ORGANIZATION_ID= lv_ORGANIZATION_ID
656:
657:
658: END IF;
659:
660: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
661:
662: EXECUTE IMMEDIATE lv_sql_stmt
663: USING
664: lv_TRANSACTION_ID,
684: lv_actual_start_date,
685: lv_actual_end_date,
686: lv_Operation_desc,
687: lv_SR_INSTANCE_ID,
688: MSC_CL_COLLECTION.v_last_collection_id,
689: MSC_CL_COLLECTION.v_current_date,
690: MSC_CL_COLLECTION.v_current_user,
691: MSC_CL_COLLECTION.v_current_date,
692: MSC_CL_COLLECTION.v_current_user;
685: lv_actual_end_date,
686: lv_Operation_desc,
687: lv_SR_INSTANCE_ID,
688: MSC_CL_COLLECTION.v_last_collection_id,
689: MSC_CL_COLLECTION.v_current_date,
690: MSC_CL_COLLECTION.v_current_user,
691: MSC_CL_COLLECTION.v_current_date,
692: MSC_CL_COLLECTION.v_current_user;
693: total_count := total_count + 1;
686: lv_Operation_desc,
687: lv_SR_INSTANCE_ID,
688: MSC_CL_COLLECTION.v_last_collection_id,
689: MSC_CL_COLLECTION.v_current_date,
690: MSC_CL_COLLECTION.v_current_user,
691: MSC_CL_COLLECTION.v_current_date,
692: MSC_CL_COLLECTION.v_current_user;
693: total_count := total_count + 1;
694: END IF;
687: lv_SR_INSTANCE_ID,
688: MSC_CL_COLLECTION.v_last_collection_id,
689: MSC_CL_COLLECTION.v_current_date,
690: MSC_CL_COLLECTION.v_current_user,
691: MSC_CL_COLLECTION.v_current_date,
692: MSC_CL_COLLECTION.v_current_user;
693: total_count := total_count + 1;
694: END IF;
695:
688: MSC_CL_COLLECTION.v_last_collection_id,
689: MSC_CL_COLLECTION.v_current_date,
690: MSC_CL_COLLECTION.v_current_user,
691: MSC_CL_COLLECTION.v_current_date,
692: MSC_CL_COLLECTION.v_current_user;
693: total_count := total_count + 1;
694: END IF;
695:
696:
709: RAISE;
710:
711: ELSE
712:
713: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
714:
715: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
716: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
717: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_JOB_OP');
721: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
722: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
723: FND_MESSAGE.SET_TOKEN('VALUE',
724: MSC_GET_NAME.ORG_CODE( lv_ORGANIZATION_ID,
725: MSC_CL_COLLECTION.v_instance_id));
726: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
727:
728: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
729: END IF;
740: COMMIT;
741:
742: BEGIN
743:
744: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
745:
746: lv_tbl:= 'JOB_OPERATIONS_'||MSC_CL_COLLECTION.v_instance_code;
747:
748: lv_sql_stmt:=
742: BEGIN
743:
744: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
745:
746: lv_tbl:= 'JOB_OPERATIONS_'||MSC_CL_COLLECTION.v_instance_code;
747:
748: lv_sql_stmt:=
749: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
750: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_JOB_OPERATIONS'
747:
748: lv_sql_stmt:=
749: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
750: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_JOB_OPERATIONS'
751: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
752: ||' AND plan_id = -1 '
753: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
754:
755: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '||lv_sql_stmt);
765: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
766: RAISE;
767: END;
768:
769: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
770: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
771: lv_retcode,
772: 'MSC_JOB_OPERATIONS',
773: MSC_CL_COLLECTION.v_instance_code,
766: RAISE;
767: END;
768:
769: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
770: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
771: lv_retcode,
772: 'MSC_JOB_OPERATIONS',
773: MSC_CL_COLLECTION.v_instance_code,
774: MSC_UTIL.G_WARNING
769: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
770: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
771: lv_retcode,
772: 'MSC_JOB_OPERATIONS',
773: MSC_CL_COLLECTION.v_instance_code,
774: MSC_UTIL.G_WARNING
775: );
776:
777: IF lv_retcode = MSC_UTIL.G_ERROR THEN
775: );
776:
777: IF lv_retcode = MSC_UTIL.G_ERROR THEN
778: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
779: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
780: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
781: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
782: END IF;
783:
777: IF lv_retcode = MSC_UTIL.G_ERROR THEN
778: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
779: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
780: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
781: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
782: END IF;
783:
784: END IF;
785:
843: lv_retcode NUMBER;
844:
845: BEGIN
846:
847: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
848: lv_tbl:= 'JOB_OP_RESOURCES_'||MSC_CL_COLLECTION.v_instance_code;
849: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
850: ELSE
851: lv_tbl:= 'MSC_JOB_OP_RESOURCES';
844:
845: BEGIN
846:
847: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
848: lv_tbl:= 'JOB_OP_RESOURCES_'||MSC_CL_COLLECTION.v_instance_code;
849: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
850: ELSE
851: lv_tbl:= 'MSC_JOB_OP_RESOURCES';
852: lv_supplies_tbl:= 'MSC_SUPPLIES';
845: BEGIN
846:
847: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
848: lv_tbl:= 'JOB_OP_RESOURCES_'||MSC_CL_COLLECTION.v_instance_code;
849: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
850: ELSE
851: lv_tbl:= 'MSC_JOB_OP_RESOURCES';
852: lv_supplies_tbl:= 'MSC_SUPPLIES';
853: END IF;
851: lv_tbl:= 'MSC_JOB_OP_RESOURCES';
852: lv_supplies_tbl:= 'MSC_SUPPLIES';
853: END IF;
854:
855: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
856:
857: lv_cursor_stmt:=
858: 'SELECT'
859: ||' ms.TRANSACTION_ID,'
861: ||' res.RESOURCE_SEQ_NUM,'
862: ||' res.SR_INSTANCE_ID'
863: ||' FROM '||lv_supplies_tbl||' ms,'
864: ||' MSC_ST_JOB_OP_RESOURCES res'
865: ||' WHERE res.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
866: ||' AND ms.PLAN_ID= -1'
867: ||' AND ms.SR_INSTANCE_ID= res.SR_INSTANCE_ID'
868: ||' AND ms.DISPOSITION_ID= res.WIP_ENTITY_ID'
869: ||' AND ms.ORDER_TYPE IN ( 3, 7)'
931: ||' res.PARENT_SEQ_NUM,'
932: ||' res.MAXIMUM_ASSIGNED_UNITS' /* ds change change end */
933: ||' FROM '||lv_supplies_tbl||' ms,'
934: ||' MSC_ST_JOB_OP_RESOURCES res'
935: ||' WHERE res.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
936: ||' AND ms.PLAN_ID= -1'
937: ||' AND ms.SR_INSTANCE_ID= res.SR_INSTANCE_ID'
938: ||' AND ms.DISPOSITION_ID= res.WIP_ENTITY_ID'
939: ||' AND ms.ORDER_TYPE IN ( 3, 7)'
1051: EXIT WHEN cgen%NOTFOUND;
1052:
1053: BEGIN
1054:
1055: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
1056:
1057: UPDATE MSC_JOB_OP_RESOURCES
1058: SET
1059: RECOMMENDED = lv_RECOMMENDED,
1076: FIRM_FLAG = lv_FIRM_FLAG,
1077: SETUP_ID = lv_SETUP_ID,
1078: PARENT_SEQ_NUM = lv_PARENT_SEQ_NUM,
1079: MAXIMUM_ASSIGNED_UNITS = lv_MAXIMUM_ASSIGNED_UNITS, /* ds change change end */
1080: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1081: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1082: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1083: WHERE PLAN_ID= -1
1084: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
1077: SETUP_ID = lv_SETUP_ID,
1078: PARENT_SEQ_NUM = lv_PARENT_SEQ_NUM,
1079: MAXIMUM_ASSIGNED_UNITS = lv_MAXIMUM_ASSIGNED_UNITS, /* ds change change end */
1080: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1081: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1082: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1083: WHERE PLAN_ID= -1
1084: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
1085: AND TRANSACTION_ID= lv_TRANSACTION_ID
1078: PARENT_SEQ_NUM = lv_PARENT_SEQ_NUM,
1079: MAXIMUM_ASSIGNED_UNITS = lv_MAXIMUM_ASSIGNED_UNITS, /* ds change change end */
1080: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1081: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1082: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1083: WHERE PLAN_ID= -1
1084: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
1085: AND TRANSACTION_ID= lv_TRANSACTION_ID
1086: AND ORGANIZATION_ID= lv_ORGANIZATION_ID
1090:
1091:
1092: END IF;
1093:
1094: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
1095:
1096: EXECUTE IMMEDIATE lv_sql_stmt
1097: USING
1098: lv_TRANSACTION_ID ,
1121: lv_SETUP_ID,
1122: lv_PARENT_SEQ_NUM,
1123: lv_MAXIMUM_ASSIGNED_UNITS, /* ds change change end */
1124: lv_SR_INSTANCE_ID,
1125: MSC_CL_COLLECTION.v_last_collection_id,
1126: MSC_CL_COLLECTION.v_current_date,
1127: MSC_CL_COLLECTION.v_current_user,
1128: MSC_CL_COLLECTION.v_current_date,
1129: MSC_CL_COLLECTION.v_current_user;
1122: lv_PARENT_SEQ_NUM,
1123: lv_MAXIMUM_ASSIGNED_UNITS, /* ds change change end */
1124: lv_SR_INSTANCE_ID,
1125: MSC_CL_COLLECTION.v_last_collection_id,
1126: MSC_CL_COLLECTION.v_current_date,
1127: MSC_CL_COLLECTION.v_current_user,
1128: MSC_CL_COLLECTION.v_current_date,
1129: MSC_CL_COLLECTION.v_current_user;
1130:
1123: lv_MAXIMUM_ASSIGNED_UNITS, /* ds change change end */
1124: lv_SR_INSTANCE_ID,
1125: MSC_CL_COLLECTION.v_last_collection_id,
1126: MSC_CL_COLLECTION.v_current_date,
1127: MSC_CL_COLLECTION.v_current_user,
1128: MSC_CL_COLLECTION.v_current_date,
1129: MSC_CL_COLLECTION.v_current_user;
1130:
1131: total_count := total_count +1;
1124: lv_SR_INSTANCE_ID,
1125: MSC_CL_COLLECTION.v_last_collection_id,
1126: MSC_CL_COLLECTION.v_current_date,
1127: MSC_CL_COLLECTION.v_current_user,
1128: MSC_CL_COLLECTION.v_current_date,
1129: MSC_CL_COLLECTION.v_current_user;
1130:
1131: total_count := total_count +1;
1132: END IF;
1125: MSC_CL_COLLECTION.v_last_collection_id,
1126: MSC_CL_COLLECTION.v_current_date,
1127: MSC_CL_COLLECTION.v_current_user,
1128: MSC_CL_COLLECTION.v_current_date,
1129: MSC_CL_COLLECTION.v_current_user;
1130:
1131: total_count := total_count +1;
1132: END IF;
1133:
1146: RAISE;
1147:
1148: ELSE
1149:
1150: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1151:
1152: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1153: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1154: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_JOB_OP_RES');
1158: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1159: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
1160: FND_MESSAGE.SET_TOKEN('VALUE',
1161: MSC_GET_NAME.ORG_CODE( lv_ORGANIZATION_ID,
1162: MSC_CL_COLLECTION.v_instance_id));
1163: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1164:
1165: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1166: END IF;
1176: COMMIT;
1177:
1178: BEGIN
1179:
1180: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
1181:
1182: lv_tbl:= 'JOB_OP_RESOURCES_'||MSC_CL_COLLECTION.v_instance_code;
1183:
1184: lv_sql_stmt:=
1178: BEGIN
1179:
1180: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
1181:
1182: lv_tbl:= 'JOB_OP_RESOURCES_'||MSC_CL_COLLECTION.v_instance_code;
1183:
1184: lv_sql_stmt:=
1185: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
1186: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_JOB_OP_RESOURCES'
1183:
1184: lv_sql_stmt:=
1185: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
1186: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_JOB_OP_RESOURCES'
1187: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
1188: ||' AND plan_id = -1 '
1189: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
1190:
1191: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '||lv_sql_stmt);
1201: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1202: RAISE;
1203: END;
1204:
1205: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1206: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
1207: lv_retcode,
1208: 'MSC_JOB_OP_RESOURCES',
1209: MSC_CL_COLLECTION.v_instance_code,
1202: RAISE;
1203: END;
1204:
1205: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1206: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
1207: lv_retcode,
1208: 'MSC_JOB_OP_RESOURCES',
1209: MSC_CL_COLLECTION.v_instance_code,
1210: MSC_UTIL.G_WARNING
1205: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1206: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
1207: lv_retcode,
1208: 'MSC_JOB_OP_RESOURCES',
1209: MSC_CL_COLLECTION.v_instance_code,
1210: MSC_UTIL.G_WARNING
1211: );
1212:
1213: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1211: );
1212:
1213: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1214: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
1215: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
1216: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
1217: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1218: END IF;
1219:
1213: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1214: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
1215: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
1216: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
1217: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1218: END IF;
1219:
1220: END IF;
1221:
1281: lv_retcode NUMBER;
1282:
1283: BEGIN
1284:
1285: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1286: lv_tbl:= 'JOB_REQUIREMENT_OPS_'||MSC_CL_COLLECTION.v_instance_code;
1287: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
1288: ELSE
1289: lv_tbl:= 'MSC_JOB_REQUIREMENT_OPS';
1282:
1283: BEGIN
1284:
1285: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1286: lv_tbl:= 'JOB_REQUIREMENT_OPS_'||MSC_CL_COLLECTION.v_instance_code;
1287: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
1288: ELSE
1289: lv_tbl:= 'MSC_JOB_REQUIREMENT_OPS';
1290: lv_supplies_tbl:= 'MSC_SUPPLIES';
1283: BEGIN
1284:
1285: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1286: lv_tbl:= 'JOB_REQUIREMENT_OPS_'||MSC_CL_COLLECTION.v_instance_code;
1287: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
1288: ELSE
1289: lv_tbl:= 'MSC_JOB_REQUIREMENT_OPS';
1290: lv_supplies_tbl:= 'MSC_SUPPLIES';
1291: END IF;
1289: lv_tbl:= 'MSC_JOB_REQUIREMENT_OPS';
1290: lv_supplies_tbl:= 'MSC_SUPPLIES';
1291: END IF;
1292:
1293: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
1294:
1295: lv_cursor_stmt:=
1296: 'SELECT'
1297: ||' ms.TRANSACTION_ID,'
1305: ||' MSC_ST_JOB_REQUIREMENT_OPS req,'
1306: ||' MSC_ITEM_ID_LID cmp_itm, '
1307: ||' MSC_ITEM_ID_LID pri_cmp, '
1308: ||' MSC_ITEM_ID_LID src_ptm '
1309: ||' WHERE req.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
1310: ||' AND ms.PLAN_ID= -1'
1311: ||' AND ms.SR_INSTANCE_ID= req.SR_INSTANCE_ID'
1312: ||' AND ms.DISPOSITION_ID= req.WIP_ENTITY_ID'
1313: ||' AND ms.ORDER_TYPE IN ( 3, 7)'
1388: ||' MSC_ST_JOB_REQUIREMENT_OPS req,'
1389: ||' MSC_ITEM_ID_LID cmp_itm, '
1390: ||' MSC_ITEM_ID_LID pri_cmp, '
1391: ||' MSC_ITEM_ID_LID src_ptm '
1392: ||' WHERE req.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
1393: ||' AND ms.PLAN_ID= -1'
1394: ||' AND ms.SR_INSTANCE_ID= req.SR_INSTANCE_ID'
1395: ||' AND ms.DISPOSITION_ID= req.WIP_ENTITY_ID'
1396: ||' AND ms.ORDER_TYPE IN ( 3, 7)'
1506: EXIT WHEN cgen%NOTFOUND;
1507:
1508: BEGIN
1509:
1510: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
1511:
1512: UPDATE MSC_JOB_REQUIREMENT_OPS
1513: SET
1514: RECOMMENDED = lv_RECOMMENDED,
1526: WIP_SUPPLY_TYPE = lv_WIP_SUPPLY_TYPE,
1527: FROM_END_ITEM_UNIT_NUMBER = lv_FROM_END_ITEM_UNIT_NUMBER,
1528: TO_END_ITEM_UNIT_NUMBER = lv_TO_END_ITEM_UNIT_NUMBER,
1529: COMPONENT_SCALING_TYPE = lv_COMPONENT_SCALING_TYPE,
1530: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1531: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1532: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1533: WHERE PLAN_ID= -1
1534: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
1527: FROM_END_ITEM_UNIT_NUMBER = lv_FROM_END_ITEM_UNIT_NUMBER,
1528: TO_END_ITEM_UNIT_NUMBER = lv_TO_END_ITEM_UNIT_NUMBER,
1529: COMPONENT_SCALING_TYPE = lv_COMPONENT_SCALING_TYPE,
1530: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1531: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1532: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1533: WHERE PLAN_ID= -1
1534: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
1535: AND TRANSACTION_ID= lv_TRANSACTION_ID
1528: TO_END_ITEM_UNIT_NUMBER = lv_TO_END_ITEM_UNIT_NUMBER,
1529: COMPONENT_SCALING_TYPE = lv_COMPONENT_SCALING_TYPE,
1530: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1531: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1532: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1533: WHERE PLAN_ID= -1
1534: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
1535: AND TRANSACTION_ID= lv_TRANSACTION_ID
1536: AND ORGANIZATION_ID= lv_ORGANIZATION_ID
1542:
1543:
1544: END IF;
1545:
1546: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
1547:
1548: EXECUTE IMMEDIATE lv_sql_stmt
1549: USING
1550: lv_TRANSACTION_ID,
1570: lv_FROM_END_ITEM_UNIT_NUMBER,
1571: lv_TO_END_ITEM_UNIT_NUMBER,
1572: lv_COMPONENT_SCALING_TYPE,
1573: lv_SR_INSTANCE_ID,
1574: MSC_CL_COLLECTION.v_last_collection_id,
1575: MSC_CL_COLLECTION.v_current_date,
1576: MSC_CL_COLLECTION.v_current_user,
1577: MSC_CL_COLLECTION.v_current_date,
1578: MSC_CL_COLLECTION.v_current_user;
1571: lv_TO_END_ITEM_UNIT_NUMBER,
1572: lv_COMPONENT_SCALING_TYPE,
1573: lv_SR_INSTANCE_ID,
1574: MSC_CL_COLLECTION.v_last_collection_id,
1575: MSC_CL_COLLECTION.v_current_date,
1576: MSC_CL_COLLECTION.v_current_user,
1577: MSC_CL_COLLECTION.v_current_date,
1578: MSC_CL_COLLECTION.v_current_user;
1579: total_count := total_count +1;
1572: lv_COMPONENT_SCALING_TYPE,
1573: lv_SR_INSTANCE_ID,
1574: MSC_CL_COLLECTION.v_last_collection_id,
1575: MSC_CL_COLLECTION.v_current_date,
1576: MSC_CL_COLLECTION.v_current_user,
1577: MSC_CL_COLLECTION.v_current_date,
1578: MSC_CL_COLLECTION.v_current_user;
1579: total_count := total_count +1;
1580: END IF;
1573: lv_SR_INSTANCE_ID,
1574: MSC_CL_COLLECTION.v_last_collection_id,
1575: MSC_CL_COLLECTION.v_current_date,
1576: MSC_CL_COLLECTION.v_current_user,
1577: MSC_CL_COLLECTION.v_current_date,
1578: MSC_CL_COLLECTION.v_current_user;
1579: total_count := total_count +1;
1580: END IF;
1581:
1574: MSC_CL_COLLECTION.v_last_collection_id,
1575: MSC_CL_COLLECTION.v_current_date,
1576: MSC_CL_COLLECTION.v_current_user,
1577: MSC_CL_COLLECTION.v_current_date,
1578: MSC_CL_COLLECTION.v_current_user;
1579: total_count := total_count +1;
1580: END IF;
1581:
1582: EXCEPTION
1594: RAISE;
1595:
1596: ELSE
1597:
1598: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1599:
1600: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1601: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1602: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_JOB_REQ_OP');
1606: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1607: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
1608: FND_MESSAGE.SET_TOKEN('VALUE',
1609: MSC_GET_NAME.ORG_CODE( lv_ORGANIZATION_ID,
1610: MSC_CL_COLLECTION.v_instance_id));
1611: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1612:
1613: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1614: END IF;
1625: COMMIT;
1626:
1627: BEGIN
1628:
1629: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
1630:
1631: lv_tbl:= 'JOB_REQUIREMENT_OPS_'||MSC_CL_COLLECTION.v_instance_code;
1632:
1633: lv_sql_stmt:=
1627: BEGIN
1628:
1629: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
1630:
1631: lv_tbl:= 'JOB_REQUIREMENT_OPS_'||MSC_CL_COLLECTION.v_instance_code;
1632:
1633: lv_sql_stmt:=
1634: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
1635: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_JOB_REQUIREMENT_OPS'
1632:
1633: lv_sql_stmt:=
1634: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
1635: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_JOB_REQUIREMENT_OPS'
1636: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
1637: ||' AND plan_id = -1 '
1638: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
1639:
1640: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '||lv_sql_stmt);
1650: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1651: RAISE;
1652: END;
1653:
1654: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1655: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
1656: lv_retcode,
1657: 'MSC_JOB_REQUIREMENT_OPS',
1658: MSC_CL_COLLECTION.v_instance_code,
1651: RAISE;
1652: END;
1653:
1654: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1655: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
1656: lv_retcode,
1657: 'MSC_JOB_REQUIREMENT_OPS',
1658: MSC_CL_COLLECTION.v_instance_code,
1659: MSC_UTIL.G_WARNING
1654: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1655: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
1656: lv_retcode,
1657: 'MSC_JOB_REQUIREMENT_OPS',
1658: MSC_CL_COLLECTION.v_instance_code,
1659: MSC_UTIL.G_WARNING
1660: );
1661:
1662: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1660: );
1661:
1662: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1663: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
1664: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
1665: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
1666: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1667: END IF;
1668:
1662: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1663: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
1664: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
1665: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
1666: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1667: END IF;
1668:
1669: END IF;
1670:
1724: lv_retcode NUMBER;
1725:
1726: BEGIN
1727:
1728: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1729: lv_tbl:= 'JOB_OPERATION_NETWORKS_'||MSC_CL_COLLECTION.v_instance_code;
1730: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
1731: ELSE
1732: lv_tbl:= 'MSC_JOB_OPERATION_NETWORKS';
1725:
1726: BEGIN
1727:
1728: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1729: lv_tbl:= 'JOB_OPERATION_NETWORKS_'||MSC_CL_COLLECTION.v_instance_code;
1730: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
1731: ELSE
1732: lv_tbl:= 'MSC_JOB_OPERATION_NETWORKS';
1733: lv_supplies_tbl:= 'MSC_SUPPLIES';
1726: BEGIN
1727:
1728: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1729: lv_tbl:= 'JOB_OPERATION_NETWORKS_'||MSC_CL_COLLECTION.v_instance_code;
1730: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
1731: ELSE
1732: lv_tbl:= 'MSC_JOB_OPERATION_NETWORKS';
1733: lv_supplies_tbl:= 'MSC_SUPPLIES';
1734: END IF;
1732: lv_tbl:= 'MSC_JOB_OPERATION_NETWORKS';
1733: lv_supplies_tbl:= 'MSC_SUPPLIES';
1734: END IF;
1735:
1736: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
1737:
1738: /* for eam work dependency */
1739: lv_cursor_stmt:=
1740: 'SELECT'
1743: ||' nwk.TO_OP_SEQ_NUM,'
1744: ||' nwk.SR_INSTANCE_ID'
1745: ||' FROM '||lv_supplies_tbl||' ms,'
1746: ||' MSC_ST_JOB_OPERATION_NETWORKS nwk'
1747: ||' WHERE nwk.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
1748: ||' AND ms.PLAN_ID= -1'
1749: ||' AND ms.SR_INSTANCE_ID= nwk.SR_INSTANCE_ID'
1750: ||' AND ms.DISPOSITION_ID= nwk.WIP_ENTITY_ID'
1751: ||' AND ms.ORDER_TYPE IN ( 3, 7, 70)' /* ds change change: 70 eam supply */
1760: ||' nwk.SR_INSTANCE_ID'
1761: ||' FROM '||lv_supplies_tbl||' ms_from,'
1762: || lv_supplies_tbl||' ms_to,'
1763: ||' MSC_ST_JOB_OPERATION_NETWORKS nwk'
1764: ||' WHERE nwk.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
1765: ||' AND ms_from.PLAN_ID= -1'
1766: ||' AND ms_from.SR_INSTANCE_ID= nwk.SR_INSTANCE_ID'
1767: ||' AND ms_from.DISPOSITION_ID= nwk.WIP_ENTITY_ID'
1768: ||' AND ms_from.ORDER_TYPE = 70 '
1861: ||' '||lv_supplies_tbl||' ms1,'
1862: ||' '||lv_supplies_tbl||' ms2,'
1863: ||' MSC_ST_JOB_OPERATION_NETWORKS nwk,'
1864: ||' MSC_ITEM_ID_LID t1'
1865: ||' WHERE nwk.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
1866: ||' AND ms.PLAN_ID= -1'
1867: ||' AND ms.SR_INSTANCE_ID= nwk.SR_INSTANCE_ID'
1868: ||' AND ms.DISPOSITION_ID= nwk.WIP_ENTITY_ID'
1869: ||' AND ms1.PLAN_ID (+) = -1' /* ds change change */
1977: EXIT WHEN cgen%NOTFOUND;
1978:
1979: BEGIN
1980:
1981: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
1982: /* opm is full collection. eam when there is change in
1983: relationship, it is deleter then insert */
1984:
1985: UPDATE MSC_JOB_OPERATION_NETWORKS
1988: TO_OP_SEQ_ID= lv_TO_OP_SEQ_ID,
1989: RECOMMENDED= lv_RECOMMENDED,
1990: TRANSITION_TYPE= lv_TRANSITION_TYPE,
1991: PLANNING_PCT= lv_PLANNING_PCT,
1992: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1993: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1994: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1995: WHERE PLAN_ID= -1
1996: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
1989: RECOMMENDED= lv_RECOMMENDED,
1990: TRANSITION_TYPE= lv_TRANSITION_TYPE,
1991: PLANNING_PCT= lv_PLANNING_PCT,
1992: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1993: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1994: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1995: WHERE PLAN_ID= -1
1996: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
1997: AND TRANSACTION_ID= lv_TRANSACTION_ID
1990: TRANSITION_TYPE= lv_TRANSITION_TYPE,
1991: PLANNING_PCT= lv_PLANNING_PCT,
1992: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1993: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1994: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1995: WHERE PLAN_ID= -1
1996: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
1997: AND TRANSACTION_ID= lv_TRANSACTION_ID
1998: AND ORGANIZATION_ID= lv_ORGANIZATION_ID
1999: AND FROM_OP_SEQ_NUM = lv_FROM_OP_SEQ_NUM
2000: AND TO_OP_SEQ_NUM = lv_TO_OP_SEQ_NUM;
2001: END IF;
2002:
2003: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
2004: EXECUTE IMMEDIATE lv_sql_stmt
2005: USING
2006: lv_TRANSACTION_ID,
2007: lv_FROM_OP_SEQ_NUM,
2023: lv_MINIMUM_TIME_OFFSET,
2024: lv_MAXIMUM_TIME_OFFSET,
2025: lv_DEPENDENCY_TYPE, /* ds change change end */
2026: lv_SR_INSTANCE_ID,
2027: MSC_CL_COLLECTION.v_last_collection_id,
2028: MSC_CL_COLLECTION.v_current_date,
2029: MSC_CL_COLLECTION.v_current_user,
2030: MSC_CL_COLLECTION.v_current_date,
2031: MSC_CL_COLLECTION.v_current_user;
2024: lv_MAXIMUM_TIME_OFFSET,
2025: lv_DEPENDENCY_TYPE, /* ds change change end */
2026: lv_SR_INSTANCE_ID,
2027: MSC_CL_COLLECTION.v_last_collection_id,
2028: MSC_CL_COLLECTION.v_current_date,
2029: MSC_CL_COLLECTION.v_current_user,
2030: MSC_CL_COLLECTION.v_current_date,
2031: MSC_CL_COLLECTION.v_current_user;
2032: total_count := total_count + 1;
2025: lv_DEPENDENCY_TYPE, /* ds change change end */
2026: lv_SR_INSTANCE_ID,
2027: MSC_CL_COLLECTION.v_last_collection_id,
2028: MSC_CL_COLLECTION.v_current_date,
2029: MSC_CL_COLLECTION.v_current_user,
2030: MSC_CL_COLLECTION.v_current_date,
2031: MSC_CL_COLLECTION.v_current_user;
2032: total_count := total_count + 1;
2033: END IF;
2026: lv_SR_INSTANCE_ID,
2027: MSC_CL_COLLECTION.v_last_collection_id,
2028: MSC_CL_COLLECTION.v_current_date,
2029: MSC_CL_COLLECTION.v_current_user,
2030: MSC_CL_COLLECTION.v_current_date,
2031: MSC_CL_COLLECTION.v_current_user;
2032: total_count := total_count + 1;
2033: END IF;
2034:
2027: MSC_CL_COLLECTION.v_last_collection_id,
2028: MSC_CL_COLLECTION.v_current_date,
2029: MSC_CL_COLLECTION.v_current_user,
2030: MSC_CL_COLLECTION.v_current_date,
2031: MSC_CL_COLLECTION.v_current_user;
2032: total_count := total_count + 1;
2033: END IF;
2034:
2035: EXCEPTION
2047: RAISE;
2048:
2049: ELSE
2050:
2051: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2052:
2053: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2054: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2055: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_JOB_OP_NWK');
2059: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2060: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
2061: FND_MESSAGE.SET_TOKEN('VALUE',
2062: MSC_GET_NAME.ORG_CODE( lv_ORGANIZATION_ID,
2063: MSC_CL_COLLECTION.v_instance_id));
2064: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2065:
2066: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2067: END IF;
2076:
2077: COMMIT;
2078:
2079: BEGIN
2080: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
2081:
2082: lv_tbl:= 'JOB_OPERATION_NETWORKS_'||MSC_CL_COLLECTION.v_instance_code;
2083:
2084: lv_sql_stmt:=
2078:
2079: BEGIN
2080: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
2081:
2082: lv_tbl:= 'JOB_OPERATION_NETWORKS_'||MSC_CL_COLLECTION.v_instance_code;
2083:
2084: lv_sql_stmt:=
2085: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
2086: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_JOB_OPERATION_NETWORKS'
2083:
2084: lv_sql_stmt:=
2085: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
2086: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_JOB_OPERATION_NETWORKS'
2087: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
2088: ||' AND plan_id = -1 '
2089: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
2090:
2091: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '||lv_sql_stmt);
2101: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2102: RAISE;
2103: END;
2104:
2105: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
2106: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
2107: lv_retcode,
2108: 'MSC_JOB_OPERATION_NETWORKS',
2109: MSC_CL_COLLECTION.v_instance_code,
2102: RAISE;
2103: END;
2104:
2105: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
2106: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
2107: lv_retcode,
2108: 'MSC_JOB_OPERATION_NETWORKS',
2109: MSC_CL_COLLECTION.v_instance_code,
2110: MSC_UTIL.G_WARNING
2105: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
2106: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
2107: lv_retcode,
2108: 'MSC_JOB_OPERATION_NETWORKS',
2109: MSC_CL_COLLECTION.v_instance_code,
2110: MSC_UTIL.G_WARNING
2111: );
2112:
2113: IF lv_retcode = MSC_UTIL.G_ERROR THEN
2111: );
2112:
2113: IF lv_retcode = MSC_UTIL.G_ERROR THEN
2114: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
2115: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
2116: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
2117: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2118: END IF;
2119:
2113: IF lv_retcode = MSC_UTIL.G_ERROR THEN
2114: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
2115: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
2116: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
2117: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2118: END IF;
2119:
2120: END IF;
2121:
2155: msrir.SR_INSTANCE_ID,
2156: msrir.SERIAL_NUMBER,
2157: msrir.RES_INSTANCE_ID
2158: FROM MSC_ST_RESOURCE_INSTANCE_REQS msrir
2159: WHERE msrir.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
2160: AND msrir.DELETED_FLAG= MSC_UTIL.SYS_YES;
2161:
2162: lv_DEPARTMENT_ID NUMBER;
2163: lv_RESOURCE_ID NUMBER;
2186:
2187: BEGIN
2188:
2189:
2190: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2191: COMMIT;
2192: END IF;
2193:
2194: c_count:= 0;
2192: END IF;
2193:
2194: c_count:= 0;
2195: total_count := 0;
2196: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
2197: lv_tbl:= 'RESOURCE_INSTANCE_REQS_'||MSC_CL_COLLECTION.v_instance_code;
2198: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
2199: ELSE
2200: lv_tbl:= 'MSC_RESOURCE_INSTANCE_REQS';
2193:
2194: c_count:= 0;
2195: total_count := 0;
2196: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
2197: lv_tbl:= 'RESOURCE_INSTANCE_REQS_'||MSC_CL_COLLECTION.v_instance_code;
2198: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
2199: ELSE
2200: lv_tbl:= 'MSC_RESOURCE_INSTANCE_REQS';
2201: lv_supplies_tbl:= 'MSC_SUPPLIES';
2194: c_count:= 0;
2195: total_count := 0;
2196: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
2197: lv_tbl:= 'RESOURCE_INSTANCE_REQS_'||MSC_CL_COLLECTION.v_instance_code;
2198: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
2199: ELSE
2200: lv_tbl:= 'MSC_RESOURCE_INSTANCE_REQS';
2201: lv_supplies_tbl:= 'MSC_SUPPLIES';
2202: END IF;
2223: ||' t1.INVENTORY_ITEM_ID equipment_item_id'
2224: ||' FROM '||lv_supplies_tbl||' ms,'
2225: ||' MSC_ST_RESOURCE_INSTANCE_REQS msrir,'
2226: ||' MSC_ITEM_ID_LID t1'
2227: ||' WHERE msrir.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
2228: ||' AND ms.PLAN_ID= -1'
2229: ||' AND ms.SR_INSTANCE_ID= msrir.SR_INSTANCE_ID'
2230: ||' AND ms.DISPOSITION_ID= msrir.WIP_ENTITY_ID'
2231: ||' AND ms.ORDER_TYPE IN ( 3, 7,70)'
2284: ||' :v_current_user,'
2285: ||' :v_current_date,'
2286: ||' :v_current_user)';
2287:
2288: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) AND MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
2289: BEGIN
2290: lv_sql_ins:=
2291: 'insert into '||lv_tbl
2292: ||' ( PLAN_ID,'
2338: ||' :v_current_user '
2339: ||' FROM '||lv_supplies_tbl||' ms, '
2340: ||' MSC_ST_RESOURCE_INSTANCE_REQS msrir, '
2341: ||' MSC_ITEM_ID_LID t1 '
2342: ||' WHERE msrir.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
2343: ||' AND ms.PLAN_ID= -1 '
2344: ||' AND ms.SR_INSTANCE_ID= msrir.SR_INSTANCE_ID '
2345: ||' AND ms.DISPOSITION_ID= msrir.WIP_ENTITY_ID '
2346: ||' AND ms.ORDER_TYPE IN ( 3, 7,70) '
2348: ||' AND t1.sr_inventory_item_id (+) = msrir.equipment_item_id '
2349: ||' AND t1.SR_INSTANCE_ID (+) = msrir.SR_INSTANCE_ID ';
2350:
2351: EXECUTE IMMEDIATE lv_sql_ins
2352: USING MSC_CL_COLLECTION.v_last_collection_id,MSC_CL_COLLECTION.v_current_date,MSC_CL_COLLECTION.v_current_user,MSC_CL_COLLECTION.v_current_date,MSC_CL_COLLECTION.v_current_user;
2353:
2354: COMMIT;
2355: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'res instance req loaded');
2356:
2383: lb_refresh_failed := TRUE;
2384: END IF;
2385: END;
2386:
2387: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh
2388:
2389: IF MSC_CL_COLLECTION.v_is_incremental_refresh OR lb_refresh_failed THEN
2390:
2391: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
2385: END;
2386:
2387: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh
2388:
2389: IF MSC_CL_COLLECTION.v_is_incremental_refresh OR lb_refresh_failed THEN
2390:
2391: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
2392:
2393: FOR c_rec IN res_inst_req_d LOOP
2387: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh
2388:
2389: IF MSC_CL_COLLECTION.v_is_incremental_refresh OR lb_refresh_failed THEN
2390:
2391: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
2392:
2393: FOR c_rec IN res_inst_req_d LOOP
2394: DELETE MSC_RESOURCE_INSTANCE_REQS
2395: WHERE PLAN_ID = -1
2400: AND RES_INSTANCE_ID = nvl( c_rec.RES_INSTANCE_ID,RES_INSTANCE_ID)
2401: AND SERIAL_NUMBER = nvl(c_rec.SERIAL_NUMBER,SERIAL_NUMBER);
2402: END LOOP;
2403:
2404: END IF; /* MSC_CL_COLLECTION.v_is_incremental_refresh */
2405:
2406: --log_debug('insert lv_sql_stmt:='||lv_sql_stmt);
2407: OPEN res_inst_req FOR lv_cursor_stmt;
2408:
2434:
2435:
2436: BEGIN
2437:
2438: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
2439: /* we can get rid of thsi update and just insert as we are puting
2440: record in ad table when instance is updated */
2441: UPDATE MSC_RESOURCE_INSTANCE_REQS mrir
2442: SET
2443: START_DATE = lv_START_DATE,
2444: RESOURCE_INSTANCE_HOURS= lv_OPERATION_HOURS_REQUIRED ,
2445: END_DATE = lv_END_DATE,
2446: SUPPLY_ID = lv_SUPPLY_ID,
2447: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
2448: RESOURCE_SEQ_NUM = lv_RESOURCE_SEQ_NUM,
2449: BATCH_NUMBER = lv_BATCH_NUMBER,
2450: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2451: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2446: SUPPLY_ID = lv_SUPPLY_ID,
2447: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
2448: RESOURCE_SEQ_NUM = lv_RESOURCE_SEQ_NUM,
2449: BATCH_NUMBER = lv_BATCH_NUMBER,
2450: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2451: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2452: WHERE PLAN_ID= -1
2453: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
2454: AND NVL(ORIG_RESOURCE_SEQ_NUM, RESOURCE_SEQ_NUM) =
2447: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
2448: RESOURCE_SEQ_NUM = lv_RESOURCE_SEQ_NUM,
2449: BATCH_NUMBER = lv_BATCH_NUMBER,
2450: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2451: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2452: WHERE PLAN_ID= -1
2453: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
2454: AND NVL(ORIG_RESOURCE_SEQ_NUM, RESOURCE_SEQ_NUM) =
2455: NVL(lv_ORIG_RESOURCE_SEQ_NUM, lv_RESOURCE_SEQ_NUM)
2459: AND RES_INSTANCE_ID = lv_RES_INSTANCE_ID
2460: AND SERIAL_NUMBER = lv_SERIAL_NUMBER;
2461: END IF;
2462:
2463: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
2464:
2465: EXECUTE IMMEDIATE lv_sql_stmt
2466: USING
2467: lv_SR_INSTANCE_ID,
2478: lv_EQUIPMENT_ITEM_ID,
2479: lv_START_DATE,
2480: lv_END_DATE,
2481: lv_OPERATION_HOURS_REQUIRED,
2482: MSC_CL_COLLECTION.v_last_collection_id,
2483: lv_BATCH_NUMBER,
2484: MSC_CL_COLLECTION.v_current_date,
2485: MSC_CL_COLLECTION.v_current_user,
2486: MSC_CL_COLLECTION.v_current_date,
2480: lv_END_DATE,
2481: lv_OPERATION_HOURS_REQUIRED,
2482: MSC_CL_COLLECTION.v_last_collection_id,
2483: lv_BATCH_NUMBER,
2484: MSC_CL_COLLECTION.v_current_date,
2485: MSC_CL_COLLECTION.v_current_user,
2486: MSC_CL_COLLECTION.v_current_date,
2487: MSC_CL_COLLECTION.v_current_user;
2488:
2481: lv_OPERATION_HOURS_REQUIRED,
2482: MSC_CL_COLLECTION.v_last_collection_id,
2483: lv_BATCH_NUMBER,
2484: MSC_CL_COLLECTION.v_current_date,
2485: MSC_CL_COLLECTION.v_current_user,
2486: MSC_CL_COLLECTION.v_current_date,
2487: MSC_CL_COLLECTION.v_current_user;
2488:
2489: END IF;
2482: MSC_CL_COLLECTION.v_last_collection_id,
2483: lv_BATCH_NUMBER,
2484: MSC_CL_COLLECTION.v_current_date,
2485: MSC_CL_COLLECTION.v_current_user,
2486: MSC_CL_COLLECTION.v_current_date,
2487: MSC_CL_COLLECTION.v_current_user;
2488:
2489: END IF;
2490: total_count := total_count + 1;
2483: lv_BATCH_NUMBER,
2484: MSC_CL_COLLECTION.v_current_date,
2485: MSC_CL_COLLECTION.v_current_user,
2486: MSC_CL_COLLECTION.v_current_date,
2487: MSC_CL_COLLECTION.v_current_user;
2488:
2489: END IF;
2490: total_count := total_count + 1;
2491: c_count:= c_count+1;
2489: END IF;
2490: total_count := total_count + 1;
2491: c_count:= c_count+1;
2492:
2493: IF c_count> MSC_CL_COLLECTION.PBS THEN
2494: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN COMMIT; END IF;
2495: c_count:= 0;
2496: END IF;
2497:
2490: total_count := total_count + 1;
2491: c_count:= c_count+1;
2492:
2493: IF c_count> MSC_CL_COLLECTION.PBS THEN
2494: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN COMMIT; END IF;
2495: c_count:= 0;
2496: END IF;
2497:
2498: EXCEPTION
2510: RAISE;
2511:
2512: ELSE
2513:
2514: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2515:
2516: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2517: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2518: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_RES_INST_REQ');
2523:
2524: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
2525: FND_MESSAGE.SET_TOKEN('VALUE',
2526: MSC_GET_NAME.ORG_CODE( lv_ORGANIZATION_ID,
2527: MSC_CL_COLLECTION.v_instance_id));
2528: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2529:
2530: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2531: FND_MESSAGE.SET_TOKEN('COLUMN', 'DEPARTMENT_ID');
2548: END;
2549:
2550: END LOOP;
2551:
2552: END IF; -- MSC_CL_COLLECTION.v_is_incremental_refresh OR lb_refresh_failed
2553:
2554: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2555: COMMIT;
2556: END IF;
2550: END LOOP;
2551:
2552: END IF; -- MSC_CL_COLLECTION.v_is_incremental_refresh OR lb_refresh_failed
2553:
2554: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2555: COMMIT;
2556: END IF;
2557:
2558: BEGIN
2556: END IF;
2557:
2558: BEGIN
2559:
2560: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
2561:
2562: lv_tbl:= 'RESOURCE_INSTANCE_REQS_'||MSC_CL_COLLECTION.v_instance_code;
2563: lv_sql_stmt:=
2564: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
2558: BEGIN
2559:
2560: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
2561:
2562: lv_tbl:= 'RESOURCE_INSTANCE_REQS_'||MSC_CL_COLLECTION.v_instance_code;
2563: lv_sql_stmt:=
2564: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
2565: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_RESOURCE_INSTANCE_REQS'
2566: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
2562: lv_tbl:= 'RESOURCE_INSTANCE_REQS_'||MSC_CL_COLLECTION.v_instance_code;
2563: lv_sql_stmt:=
2564: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
2565: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_RESOURCE_INSTANCE_REQS'
2566: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
2567: ||' AND plan_id = -1 '
2568: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
2569:
2570:
2580: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2581: RAISE;
2582: END;
2583:
2584: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
2585: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
2586: lv_retcode,
2587: 'MSC_RESOURCE_INSTANCE_REQS',
2588: MSC_CL_COLLECTION.v_instance_code,
2581: RAISE;
2582: END;
2583:
2584: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
2585: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
2586: lv_retcode,
2587: 'MSC_RESOURCE_INSTANCE_REQS',
2588: MSC_CL_COLLECTION.v_instance_code,
2589: MSC_UTIL.G_WARNING
2584: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
2585: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
2586: lv_retcode,
2587: 'MSC_RESOURCE_INSTANCE_REQS',
2588: MSC_CL_COLLECTION.v_instance_code,
2589: MSC_UTIL.G_WARNING
2590: );
2591:
2592: IF lv_retcode = MSC_UTIL.G_ERROR THEN
2590: );
2591:
2592: IF lv_retcode = MSC_UTIL.G_ERROR THEN
2593: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
2594: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
2595: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
2596: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2597: END IF;
2598:
2592: IF lv_retcode = MSC_UTIL.G_ERROR THEN
2593: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
2594: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
2595: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
2596: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2597: END IF;
2598:
2599: END IF;
2600:
2635: msd.SR_INSTANCE_ID,
2636: msd.ORGANIZATION_ID
2637: FROM MSC_ITEM_ID_LID t1,
2638: MSC_ST_DEMANDS msd
2639: WHERE msd.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
2640: AND msd.ORIGINATION_TYPE IN (2,3,4,25,50,70) /* ds change change 50 eam demand */
2641: AND msd.DELETED_FLAG= MSC_UTIL.SYS_YES
2642: AND t1.SR_INVENTORY_ITEM_ID(+)= msd.inventory_item_id
2643: AND t1.sr_instance_id(+)= MSC_CL_COLLECTION.v_instance_id;
2639: WHERE msd.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
2640: AND msd.ORIGINATION_TYPE IN (2,3,4,25,50,70) /* ds change change 50 eam demand */
2641: AND msd.DELETED_FLAG= MSC_UTIL.SYS_YES
2642: AND t1.SR_INVENTORY_ITEM_ID(+)= msd.inventory_item_id
2643: AND t1.sr_instance_id(+)= MSC_CL_COLLECTION.v_instance_id;
2644:
2645: lv_DISPOSITION_ID NUMBER;
2646: lv_INVENTORY_ITEM_ID NUMBER;
2647: lv_ORGANIZATION_ID NUMBER;
2677:
2678: --========================= WIP DEMANDS ======================
2679: -- link disposition_id to MSC_supplies.transaction_id
2680:
2681: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
2682:
2683: FOR c_rec IN c2_d LOOP
2684:
2685: IF c_rec.ORIGINATION_TYPE IN (2, 3, 50, 70) THEN -- DISCRETE JOB COMPONENT /* ds change 50 eam demand */
2686:
2687: UPDATE MSC_DEMANDS
2688: SET USING_REQUIREMENT_QUANTITY= 0,
2689: DAILY_DEMAND_RATE= 0,
2690: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2691: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2692: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2693: WHERE PLAN_ID= -1
2694: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
2687: UPDATE MSC_DEMANDS
2688: SET USING_REQUIREMENT_QUANTITY= 0,
2689: DAILY_DEMAND_RATE= 0,
2690: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2691: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2692: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2693: WHERE PLAN_ID= -1
2694: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
2695: AND ORIGINATION_TYPE= c_rec.ORIGINATION_TYPE
2688: SET USING_REQUIREMENT_QUANTITY= 0,
2689: DAILY_DEMAND_RATE= 0,
2690: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2691: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2692: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2693: WHERE PLAN_ID= -1
2694: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
2695: AND ORIGINATION_TYPE= c_rec.ORIGINATION_TYPE
2696: AND WIP_ENTITY_ID= c_rec.WIP_ENTITY_ID
2702:
2703: UPDATE MSC_DEMANDS
2704: SET USING_REQUIREMENT_QUANTITY= 0,
2705: DAILY_DEMAND_RATE= 0,
2706: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2707: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2708: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2709: WHERE PLAN_ID= -1
2710: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
2703: UPDATE MSC_DEMANDS
2704: SET USING_REQUIREMENT_QUANTITY= 0,
2705: DAILY_DEMAND_RATE= 0,
2706: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2707: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2708: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2709: WHERE PLAN_ID= -1
2710: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
2711: AND ORIGINATION_TYPE= c_rec.ORIGINATION_TYPE
2704: SET USING_REQUIREMENT_QUANTITY= 0,
2705: DAILY_DEMAND_RATE= 0,
2706: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2707: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2708: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2709: WHERE PLAN_ID= -1
2710: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
2711: AND ORIGINATION_TYPE= c_rec.ORIGINATION_TYPE
2712: AND WIP_ENTITY_ID= NVL(c_rec.WIP_ENTITY_ID,WIP_ENTITY_ID)
2729: END LOOP;
2730:
2731: END IF; -- refresh mode
2732:
2733: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN COMMIT; END IF;
2734:
2735: c_count:=0;
2736:
2737: -- ========= Prepare the Cursor Statement ==========
2734:
2735: c_count:=0;
2736:
2737: -- ========= Prepare the Cursor Statement ==========
2738: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
2739: lv_tbl:= 'DEMANDS_'||MSC_CL_COLLECTION.v_instance_code;
2740: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
2741: ELSE
2742: lv_tbl:= 'MSC_DEMANDS';
2735: c_count:=0;
2736:
2737: -- ========= Prepare the Cursor Statement ==========
2738: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
2739: lv_tbl:= 'DEMANDS_'||MSC_CL_COLLECTION.v_instance_code;
2740: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
2741: ELSE
2742: lv_tbl:= 'MSC_DEMANDS';
2743: lv_supplies_tbl:= 'MSC_SUPPLIES';
2736:
2737: -- ========= Prepare the Cursor Statement ==========
2738: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
2739: lv_tbl:= 'DEMANDS_'||MSC_CL_COLLECTION.v_instance_code;
2740: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
2741: ELSE
2742: lv_tbl:= 'MSC_DEMANDS';
2743: lv_supplies_tbl:= 'MSC_SUPPLIES';
2744: END IF;
2805: ||' MSC_ITEM_ID_LID t2,'
2806: ||' MSC_ITEM_ID_LID t3,'
2807: || lv_supplies_tbl||' ms,'
2808: ||' MSC_ST_DEMANDS msd'
2809: ||' WHERE msd.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
2810: ||' AND msd.ORIGINATION_TYPE IN (2,3,4,25,50)' /* 50 eam demand: ds change change*/
2811: ||' AND msd.DELETED_FLAG= '||MSC_UTIL.SYS_NO
2812: ||' AND t1.SR_INVENTORY_ITEM_ID= msd.inventory_item_id'
2813: ||' AND t1.sr_instance_id= msd.SR_INSTANCE_ID'
2822: ||' msd.WIP_ENTITY_ID)'
2823: ||' AND ms.plan_id(+)=-1'
2824: ||' AND ms.ORDER_TYPE(+)= DECODE( msd.ORIGINATION_TYPE, 2,7,3,3,4,4,25,27,50,70)'; /* ds change change*/
2825:
2826: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2827: lv_sql_stmt:=
2828: 'INSERT /*+ APPEND */ INTO '||lv_tbl
2829: ||'( PLAN_ID,'
2830: ||' DEMAND_ID,'
2870:
2871: SAVEPOINT Load_wip_SP;
2872: EXECUTE IMMEDIATE lv_sql_stmt
2873: USING
2874: MSC_CL_COLLECTION.v_chr10,
2875: MSC_CL_COLLECTION.v_chr13,
2876: v_srp_profile_vlaue,
2877: v_srp_profile_vlaue,
2878: MSC_CL_COLLECTION.v_last_collection_id,
2871: SAVEPOINT Load_wip_SP;
2872: EXECUTE IMMEDIATE lv_sql_stmt
2873: USING
2874: MSC_CL_COLLECTION.v_chr10,
2875: MSC_CL_COLLECTION.v_chr13,
2876: v_srp_profile_vlaue,
2877: v_srp_profile_vlaue,
2878: MSC_CL_COLLECTION.v_last_collection_id,
2879: MSC_CL_COLLECTION.v_current_date,
2874: MSC_CL_COLLECTION.v_chr10,
2875: MSC_CL_COLLECTION.v_chr13,
2876: v_srp_profile_vlaue,
2877: v_srp_profile_vlaue,
2878: MSC_CL_COLLECTION.v_last_collection_id,
2879: MSC_CL_COLLECTION.v_current_date,
2880: MSC_CL_COLLECTION.v_current_user,
2881: MSC_CL_COLLECTION.v_current_date,
2882: MSC_CL_COLLECTION.v_current_user;
2875: MSC_CL_COLLECTION.v_chr13,
2876: v_srp_profile_vlaue,
2877: v_srp_profile_vlaue,
2878: MSC_CL_COLLECTION.v_last_collection_id,
2879: MSC_CL_COLLECTION.v_current_date,
2880: MSC_CL_COLLECTION.v_current_user,
2881: MSC_CL_COLLECTION.v_current_date,
2882: MSC_CL_COLLECTION.v_current_user;
2883:
2876: v_srp_profile_vlaue,
2877: v_srp_profile_vlaue,
2878: MSC_CL_COLLECTION.v_last_collection_id,
2879: MSC_CL_COLLECTION.v_current_date,
2880: MSC_CL_COLLECTION.v_current_user,
2881: MSC_CL_COLLECTION.v_current_date,
2882: MSC_CL_COLLECTION.v_current_user;
2883:
2884: COMMIT;
2877: v_srp_profile_vlaue,
2878: MSC_CL_COLLECTION.v_last_collection_id,
2879: MSC_CL_COLLECTION.v_current_date,
2880: MSC_CL_COLLECTION.v_current_user,
2881: MSC_CL_COLLECTION.v_current_date,
2882: MSC_CL_COLLECTION.v_current_user;
2883:
2884: COMMIT;
2885: RETURN;
2878: MSC_CL_COLLECTION.v_last_collection_id,
2879: MSC_CL_COLLECTION.v_current_date,
2880: MSC_CL_COLLECTION.v_current_user,
2881: MSC_CL_COLLECTION.v_current_date,
2882: MSC_CL_COLLECTION.v_current_user;
2883:
2884: COMMIT;
2885: RETURN;
2886:
3016: ||' MSC_ITEM_ID_LID t2,'
3017: ||' MSC_ITEM_ID_LID t3,'
3018: || lv_supplies_tbl||' ms,'
3019: ||' MSC_ST_DEMANDS msd'
3020: ||' WHERE msd.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
3021: ||' AND msd.ORIGINATION_TYPE IN (2,3,4,25,50)' /* 50 eam demand: ds change change*/
3022: ||' AND msd.DELETED_FLAG= '||MSC_UTIL.SYS_NO
3023: ||' AND t1.SR_INVENTORY_ITEM_ID= msd.inventory_item_id'
3024: ||' AND t1.sr_instance_id= msd.SR_INSTANCE_ID'
3034: ||' AND ms.plan_id(+)=-1'
3035: ||' AND ms.ORDER_TYPE(+)= DECODE( msd.ORIGINATION_TYPE, 2,7,3,3,4,4,25,27,50,70)' /* ds change change*/
3036: ||' order by msd.SOURCE_WIP_ENTITY_ID, msd.SOURCE_INVENTORY_ITEM_ID,msd.SOURCE_ORGANIZATION_ID,msd.ORIGINATION_TYPE';
3037:
3038: OPEN c2 FOR lv_cursor_stmt USING MSC_CL_COLLECTION.v_chr10, MSC_CL_COLLECTION.v_chr13;
3039:
3040: LOOP
3041:
3042: FETCH c2 INTO
3074: EXIT WHEN c2%NOTFOUND;
3075:
3076: BEGIN
3077:
3078: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
3079:
3080: --================= wip discrete job components ==================
3081: IF lv_ORIGINATION_TYPE IN (2, 3, 50) THEN /* ds change 50 eam demand*/
3082:
3107: ASSET_ITEM_ID= lv_ASSET_ITEM_ID, /* ds change change */
3108: ASSET_SERIAL_NUMBER= lv_ASSET_SERIAL_NUMBER, /* ds changechange */
3109: COMPONENT_SCALING_TYPE = lv_COMPONENT_SCALING_TYPE, /* Discrete Mfg Enahancements Bug 4492736 */
3110: COMPONENT_YIELD_FACTOR = lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
3111: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
3112: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
3113: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
3114: WHERE PLAN_ID= -1
3115: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
3108: ASSET_SERIAL_NUMBER= lv_ASSET_SERIAL_NUMBER, /* ds changechange */
3109: COMPONENT_SCALING_TYPE = lv_COMPONENT_SCALING_TYPE, /* Discrete Mfg Enahancements Bug 4492736 */
3110: COMPONENT_YIELD_FACTOR = lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
3111: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
3112: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
3113: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
3114: WHERE PLAN_ID= -1
3115: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
3116: AND ORIGINATION_TYPE= lv_ORIGINATION_TYPE
3109: COMPONENT_SCALING_TYPE = lv_COMPONENT_SCALING_TYPE, /* Discrete Mfg Enahancements Bug 4492736 */
3110: COMPONENT_YIELD_FACTOR = lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
3111: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
3112: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
3113: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
3114: WHERE PLAN_ID= -1
3115: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
3116: AND ORIGINATION_TYPE= lv_ORIGINATION_TYPE
3117: AND ORGANIZATION_ID= lv_ORGANIZATION_ID
3145: WIP_SUPPLY_TYPE= lv_WIP_SUPPLY_TYPE,
3146: DISPOSITION_ID= lv_DISPOSITION_ID,
3147: COMPONENT_SCALING_TYPE = lv_COMPONENT_SCALING_TYPE, /* Discrete Mfg Enahancements Bug 4492736 */
3148: COMPONENT_YIELD_FACTOR = lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
3149: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
3150: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
3151: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
3152: WHERE PLAN_ID= -1
3153: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
3146: DISPOSITION_ID= lv_DISPOSITION_ID,
3147: COMPONENT_SCALING_TYPE = lv_COMPONENT_SCALING_TYPE, /* Discrete Mfg Enahancements Bug 4492736 */
3148: COMPONENT_YIELD_FACTOR = lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
3149: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
3150: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
3151: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
3152: WHERE PLAN_ID= -1
3153: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
3154: AND ORIGINATION_TYPE= lv_ORIGINATION_TYPE
3147: COMPONENT_SCALING_TYPE = lv_COMPONENT_SCALING_TYPE, /* Discrete Mfg Enahancements Bug 4492736 */
3148: COMPONENT_YIELD_FACTOR = lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
3149: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
3150: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
3151: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
3152: WHERE PLAN_ID= -1
3153: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
3154: AND ORIGINATION_TYPE= lv_ORIGINATION_TYPE
3155: AND ORGANIZATION_ID= lv_ORGANIZATION_ID
3161: END IF; -- Origination_Type
3162:
3163: END IF; -- refresh mode
3164:
3165: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) OR
3166: ( lv_DELETED_FLAG<> MSC_UTIL.SYS_YES AND SQL%NOTFOUND) OR
3167: ( lv_ORIGINATION_TYPE= 25) THEN
3168:
3169: EXECUTE IMMEDIATE lv_sql_stmt
3196: lv_ASSET_ITEM_ID, /* ds change change */
3197: lv_ASSET_SERIAL_NUMBER, /* ds changechange */
3198: lv_COMPONENT_SCALING_TYPE, /* Discrete Mfg Enahancements Bug 4492736 */
3199: lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
3200: MSC_CL_COLLECTION.v_last_collection_id,
3201: MSC_CL_COLLECTION.v_current_date,
3202: MSC_CL_COLLECTION.v_current_user,
3203: MSC_CL_COLLECTION.v_current_date,
3204: MSC_CL_COLLECTION.v_current_user;
3197: lv_ASSET_SERIAL_NUMBER, /* ds changechange */
3198: lv_COMPONENT_SCALING_TYPE, /* Discrete Mfg Enahancements Bug 4492736 */
3199: lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
3200: MSC_CL_COLLECTION.v_last_collection_id,
3201: MSC_CL_COLLECTION.v_current_date,
3202: MSC_CL_COLLECTION.v_current_user,
3203: MSC_CL_COLLECTION.v_current_date,
3204: MSC_CL_COLLECTION.v_current_user;
3205:
3198: lv_COMPONENT_SCALING_TYPE, /* Discrete Mfg Enahancements Bug 4492736 */
3199: lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
3200: MSC_CL_COLLECTION.v_last_collection_id,
3201: MSC_CL_COLLECTION.v_current_date,
3202: MSC_CL_COLLECTION.v_current_user,
3203: MSC_CL_COLLECTION.v_current_date,
3204: MSC_CL_COLLECTION.v_current_user;
3205:
3206: END IF;
3199: lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
3200: MSC_CL_COLLECTION.v_last_collection_id,
3201: MSC_CL_COLLECTION.v_current_date,
3202: MSC_CL_COLLECTION.v_current_user,
3203: MSC_CL_COLLECTION.v_current_date,
3204: MSC_CL_COLLECTION.v_current_user;
3205:
3206: END IF;
3207:
3200: MSC_CL_COLLECTION.v_last_collection_id,
3201: MSC_CL_COLLECTION.v_current_date,
3202: MSC_CL_COLLECTION.v_current_user,
3203: MSC_CL_COLLECTION.v_current_date,
3204: MSC_CL_COLLECTION.v_current_user;
3205:
3206: END IF;
3207:
3208: EXCEPTION
3220: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
3221: RAISE;
3222:
3223: ELSE
3224: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
3225:
3226: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
3227: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
3228: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SUPPLY');
3242: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
3243: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
3244: FND_MESSAGE.SET_TOKEN('VALUE',
3245: MSC_GET_NAME.ORG_CODE( lv_ORGANIZATION_ID,
3246: MSC_CL_COLLECTION.v_instance_id));
3247: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
3248:
3249: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
3250: FND_MESSAGE.SET_TOKEN('COLUMN', 'DEMAND_TYPE');
3264: END;
3265:
3266: c_count:= c_count+1;
3267:
3268: IF c_count> MSC_CL_COLLECTION.PBS THEN
3269: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN COMMIT; END IF;
3270: c_count:= 0;
3271: END IF;
3272:
3265:
3266: c_count:= c_count+1;
3267:
3268: IF c_count> MSC_CL_COLLECTION.PBS THEN
3269: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN COMMIT; END IF;
3270: c_count:= 0;
3271: END IF;
3272:
3273: END LOOP; -- cursor c2
3273: END LOOP; -- cursor c2
3274:
3275: CLOSE c2;
3276:
3277: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN COMMIT; END IF;
3278:
3279: EXCEPTION
3280: WHEN OTHERS THEN
3281: IF c2%ISOPEN THEN CLOSE c2; END IF;
3311: msrr.OPERATION_SEQ_NUM,
3312: msrr.ORIG_RESOURCE_SEQ_NUM,
3313: msrr.SR_INSTANCE_ID
3314: FROM MSC_ST_RESOURCE_REQUIREMENTS msrr
3315: WHERE msrr.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3316: AND msrr.DELETED_FLAG= MSC_UTIL.SYS_YES;
3317:
3318: lv_DEPARTMENT_ID NUMBER;
3319: lv_RESOURCE_ID NUMBER;
3378:
3379: -- link supply_id to MSC_supplies.transaction_id
3380:
3381:
3382: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3383: COMMIT;
3384: END IF;
3385:
3386: c_count:= 0;
3385:
3386: c_count:= 0;
3387:
3388: -- ========= Prepare the Cursor Statement ==========
3389: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
3390: lv_tbl:= 'RESOURCE_REQUIREMENTS_'||MSC_CL_COLLECTION.v_instance_code;
3391: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
3392: ELSE
3393: lv_tbl:= 'MSC_RESOURCE_REQUIREMENTS';
3386: c_count:= 0;
3387:
3388: -- ========= Prepare the Cursor Statement ==========
3389: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
3390: lv_tbl:= 'RESOURCE_REQUIREMENTS_'||MSC_CL_COLLECTION.v_instance_code;
3391: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
3392: ELSE
3393: lv_tbl:= 'MSC_RESOURCE_REQUIREMENTS';
3394: lv_supplies_tbl:= 'MSC_SUPPLIES';
3387:
3388: -- ========= Prepare the Cursor Statement ==========
3389: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
3390: lv_tbl:= 'RESOURCE_REQUIREMENTS_'||MSC_CL_COLLECTION.v_instance_code;
3391: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
3392: ELSE
3393: lv_tbl:= 'MSC_RESOURCE_REQUIREMENTS';
3394: lv_supplies_tbl:= 'MSC_SUPPLIES';
3395: END IF;
3459: ||' msrr.OPERATION_NAME '
3460: ||' FROM '||lv_supplies_tbl||' ms,'
3461: ||' MSC_ST_RESOURCE_REQUIREMENTS msrr,'
3462: ||' MSC_ITEM_ID_LID miil'
3463: ||' WHERE msrr.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
3464: ||' AND ms.PLAN_ID= -1'
3465: ||' AND ms.SR_INSTANCE_ID= msrr.SR_INSTANCE_ID'
3466: ||' AND ms.DISPOSITION_ID= msrr.WIP_ENTITY_ID'
3467: ||' AND ms.ORDER_TYPE IN ( 3, 7,70)' /* 70 esm suply:ds change change */
3593: ||' :v_current_user,'
3594: ||' :v_current_date,'
3595: ||' :v_current_user)';
3596:
3597: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) AND MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
3598: BEGIN
3599: lv_sql_ins:=
3600: 'insert into '||lv_tbl
3601: ||' ( PLAN_ID,'
3721: ||' :v_current_user '
3722: ||' FROM '||lv_supplies_tbl||' ms, '
3723: ||' MSC_ST_RESOURCE_REQUIREMENTS msrr, '
3724: ||' MSC_ITEM_ID_LID miil '
3725: ||' WHERE msrr.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
3726: ||' AND ms.PLAN_ID= -1'
3727: ||' AND ms.SR_INSTANCE_ID= msrr.SR_INSTANCE_ID'
3728: ||' AND ms.DISPOSITION_ID= msrr.WIP_ENTITY_ID'
3729: ||' AND ms.ORDER_TYPE IN ( 3, 7,70)' /* 70 esm suply:ds change change */
3731: ||' AND miil.SR_INVENTORY_ITEM_ID(+)= msrr.INVENTORY_ITEM_ID'
3732: ||' AND miil.SR_INSTANCE_ID(+)= msrr.SR_INSTANCE_ID';
3733:
3734: EXECUTE IMMEDIATE lv_sql_ins
3735: USING MSC_CL_COLLECTION.v_last_collection_id,MSC_CL_COLLECTION.v_current_date,MSC_CL_COLLECTION.v_current_user,MSC_CL_COLLECTION.v_current_date,MSC_CL_COLLECTION.v_current_user;
3736:
3737: COMMIT;
3738: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'res req loaded');
3739:
3766: lb_refresh_failed := TRUE;
3767: END IF;
3768: END;
3769:
3770: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh
3771:
3772:
3773: IF MSC_CL_COLLECTION.v_is_incremental_refresh OR lb_refresh_failed THEN
3774:
3769:
3770: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh
3771:
3772:
3773: IF MSC_CL_COLLECTION.v_is_incremental_refresh OR lb_refresh_failed THEN
3774:
3775: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
3776:
3777: FOR c_rec IN c4_d LOOP
3771:
3772:
3773: IF MSC_CL_COLLECTION.v_is_incremental_refresh OR lb_refresh_failed THEN
3774:
3775: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
3776:
3777: FOR c_rec IN c4_d LOOP
3778:
3779: -- BUG 7521174
3789:
3790: /*
3791: UPDATE MSC_RESOURCE_REQUIREMENTS
3792: SET RESOURCE_HOURS= 0,
3793: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
3794: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
3795: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
3796: WHERE PLAN_ID= -1
3797: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
3790: /*
3791: UPDATE MSC_RESOURCE_REQUIREMENTS
3792: SET RESOURCE_HOURS= 0,
3793: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
3794: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
3795: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
3796: WHERE PLAN_ID= -1
3797: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
3798: AND WIP_ENTITY_ID= c_rec.WIP_ENTITY_ID
3791: UPDATE MSC_RESOURCE_REQUIREMENTS
3792: SET RESOURCE_HOURS= 0,
3793: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
3794: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
3795: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
3796: WHERE PLAN_ID= -1
3797: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
3798: AND WIP_ENTITY_ID= c_rec.WIP_ENTITY_ID
3799: AND OPERATION_SEQ_NUM= NVL( c_rec.OPERATION_SEQ_NUM, OPERATION_SEQ_NUM)
3800: AND ORIG_RESOURCE_SEQ_NUM= NVL(c_rec.ORIG_RESOURCE_SEQ_NUM, ORIG_RESOURCE_SEQ_NUM);
3801: */
3802: END LOOP;
3803:
3804: END IF; -- MSC_CL_COLLECTION.v_is_incremental_refresh
3805:
3806: OPEN c4 FOR lv_cursor_stmt;
3807:
3808: LOOP
3865: EXIT WHEN c4%NOTFOUND;
3866:
3867: BEGIN
3868:
3869: IF MSC_CL_COLLECTION.v_is_legacy_refresh = TRUE THEN /* bug 3768813 */
3870: lv_legacy_refresh := 1;
3871: ELSE
3872: lv_legacy_refresh := 2;
3873: END IF;
3871: ELSE
3872: lv_legacy_refresh := 2;
3873: END IF;
3874:
3875: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
3876:
3877: UPDATE MSC_RESOURCE_REQUIREMENTS
3878: SET
3879: DEPARTMENT_ID= lv_DEPARTMENT_ID,
3895: END_DATE= lv_END_DATE,
3896: SUPPLY_ID= lv_SUPPLY_ID,
3897: STD_OP_CODE= lv_STD_OP_CODE,
3898: SHUTDOWN_TYPE = lv_SHUTDOWN_TYPE,
3899: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
3900: minimum_transfer_quantity= lv_minimum_transfer_quantity,
3901: firm_flag = lv_firm_flag,
3902: SCHEDULE_FLAG = lv_schedule_flag,
3903: PARENT_SEQ_NUM=lv_PARENT_SEQ_NUM,
3923: UNADJUSTED_RESOURCE_HOURS = lv_UNADJUSTED_RESOURCE_HOURS,
3924: TOUCH_TIME = lv_TOUCH_TIME,
3925: ACTIVITY_NAME=lv_ACTIVITY_NAME,
3926: OPERATION_NAME=lv_OPERATION_NAME,
3927: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
3928: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
3929: WHERE PLAN_ID= -1
3930: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
3931: AND NVL(ORIG_RESOURCE_SEQ_NUM, RESOURCE_SEQ_NUM) = NVL(lv_ORIG_RESOURCE_SEQ_NUM, lv_RESOURCE_SEQ_NUM)
3924: TOUCH_TIME = lv_TOUCH_TIME,
3925: ACTIVITY_NAME=lv_ACTIVITY_NAME,
3926: OPERATION_NAME=lv_OPERATION_NAME,
3927: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
3928: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
3929: WHERE PLAN_ID= -1
3930: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
3931: AND NVL(ORIG_RESOURCE_SEQ_NUM, RESOURCE_SEQ_NUM) = NVL(lv_ORIG_RESOURCE_SEQ_NUM, lv_RESOURCE_SEQ_NUM)
3932: AND ORGANIZATION_ID= lv_ORGANIZATION_ID
3935: AND decode(lv_legacy_refresh,1,resource_id,-1) = decode(lv_legacy_refresh,1,lv_RESOURCE_ID, -1); /* bug 3768813 */
3936:
3937: END IF;
3938:
3939: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
3940:
3941: EXECUTE IMMEDIATE lv_sql_stmt
3942: USING
3943: lv_DEPARTMENT_ID,
3968: lv_ACTIVITY_GROUP_ID,
3969: lv_ALTERNATE_NUMBER,
3970: lv_PRINCIPAL_FLAG,
3971: lv_SR_INSTANCE_ID,
3972: MSC_CL_COLLECTION.v_last_collection_id,
3973: lv_minimum_transfer_quantity,
3974: lv_firm_flag,
3975: lv_schedule_flag,
3976: lv_PARENT_SEQ_NUM,
3993: lv_UNADJUSTED_RESOURCE_HOURS,
3994: lv_TOUCH_TIME,
3995: lv_ACTIVITY_NAME,
3996: lv_OPERATION_NAME,
3997: MSC_CL_COLLECTION.v_current_date,
3998: MSC_CL_COLLECTION.v_current_user,
3999: MSC_CL_COLLECTION.v_current_date,
4000: MSC_CL_COLLECTION.v_current_user;
4001:
3994: lv_TOUCH_TIME,
3995: lv_ACTIVITY_NAME,
3996: lv_OPERATION_NAME,
3997: MSC_CL_COLLECTION.v_current_date,
3998: MSC_CL_COLLECTION.v_current_user,
3999: MSC_CL_COLLECTION.v_current_date,
4000: MSC_CL_COLLECTION.v_current_user;
4001:
4002: END IF;
3995: lv_ACTIVITY_NAME,
3996: lv_OPERATION_NAME,
3997: MSC_CL_COLLECTION.v_current_date,
3998: MSC_CL_COLLECTION.v_current_user,
3999: MSC_CL_COLLECTION.v_current_date,
4000: MSC_CL_COLLECTION.v_current_user;
4001:
4002: END IF;
4003:
3996: lv_OPERATION_NAME,
3997: MSC_CL_COLLECTION.v_current_date,
3998: MSC_CL_COLLECTION.v_current_user,
3999: MSC_CL_COLLECTION.v_current_date,
4000: MSC_CL_COLLECTION.v_current_user;
4001:
4002: END IF;
4003:
4004: c_count:= c_count+1;
4002: END IF;
4003:
4004: c_count:= c_count+1;
4005:
4006: IF c_count> MSC_CL_COLLECTION.PBS THEN
4007: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN COMMIT; END IF;
4008: c_count:= 0;
4009: END IF;
4010:
4003:
4004: c_count:= c_count+1;
4005:
4006: IF c_count> MSC_CL_COLLECTION.PBS THEN
4007: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN COMMIT; END IF;
4008: c_count:= 0;
4009: END IF;
4010:
4011: EXCEPTION
4023: RAISE;
4024:
4025: ELSE
4026:
4027: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
4028:
4029: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
4030: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
4031: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SUPPLY');
4035: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
4036: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
4037: FND_MESSAGE.SET_TOKEN('VALUE',
4038: MSC_GET_NAME.ORG_CODE( lv_ORGANIZATION_ID,
4039: MSC_CL_COLLECTION.v_instance_id));
4040: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
4041:
4042: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
4043: FND_MESSAGE.SET_TOKEN('COLUMN', 'DEPARTMENT_ID');
4055: END;
4056:
4057: END LOOP;
4058:
4059: END IF; -- MSC_CL_COLLECTION.v_is_incremental_refresh OR lb_refresh_failed
4060:
4061: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
4062: COMMIT;
4063: END IF;
4057: END LOOP;
4058:
4059: END IF; -- MSC_CL_COLLECTION.v_is_incremental_refresh OR lb_refresh_failed
4060:
4061: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
4062: COMMIT;
4063: END IF;
4064: /*
4065: BEGIN
4063: END IF;
4064: /*
4065: BEGIN
4066:
4067: IF (((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND
4068: (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) AND
4069: NOT (MSC_CL_COLLECTION.v_apps_ver >= MSC_UTIL.G_EAM_CMRO_SUP_VER
4070: AND MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y')) THEN
4071:
4064: /*
4065: BEGIN
4066:
4067: IF (((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND
4068: (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) AND
4069: NOT (MSC_CL_COLLECTION.v_apps_ver >= MSC_UTIL.G_EAM_CMRO_SUP_VER
4070: AND MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y')) THEN
4071:
4072: lv_tbl:= 'RESOURCE_REQUIREMENTS_'||MSC_CL_COLLECTION.v_instance_code;
4065: BEGIN
4066:
4067: IF (((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <> MSC_UTIL.G_ALL_ORGANIZATIONS ) AND
4068: (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) AND
4069: NOT (MSC_CL_COLLECTION.v_apps_ver >= MSC_UTIL.G_EAM_CMRO_SUP_VER
4070: AND MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y')) THEN
4071:
4072: lv_tbl:= 'RESOURCE_REQUIREMENTS_'||MSC_CL_COLLECTION.v_instance_code;
4073:
4068: (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) AND
4069: NOT (MSC_CL_COLLECTION.v_apps_ver >= MSC_UTIL.G_EAM_CMRO_SUP_VER
4070: AND MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y')) THEN
4071:
4072: lv_tbl:= 'RESOURCE_REQUIREMENTS_'||MSC_CL_COLLECTION.v_instance_code;
4073:
4074: lv_sql_stmt:=
4075: 'INSERT INTO '||lv_tbl
4076: ||' SELECT * from MSC_RESOURCE_REQUIREMENTS'
4073:
4074: lv_sql_stmt:=
4075: 'INSERT INTO '||lv_tbl
4076: ||' SELECT * from MSC_RESOURCE_REQUIREMENTS'
4077: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
4078: ||' AND plan_id = -1 '
4079: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
4080:
4081: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '||lv_sql_stmt);
4093: END;
4094: */
4095: MSC_CL_BOM_ODS_LOAD.LOAD_RESOURCE_CHARGES; /* ds change */
4096:
4097: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
4098: IF (MSC_CL_COLLECTION.v_apps_ver >= MSC_UTIL.G_EAM_CMRO_SUP_VER
4099: AND MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y')
4100: THEN
4101: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'alter temp table for res_req not handled here');
4094: */
4095: MSC_CL_BOM_ODS_LOAD.LOAD_RESOURCE_CHARGES; /* ds change */
4096:
4097: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
4098: IF (MSC_CL_COLLECTION.v_apps_ver >= MSC_UTIL.G_EAM_CMRO_SUP_VER
4099: AND MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y')
4100: THEN
4101: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'alter temp table for res_req not handled here');
4102: ELSE
4099: AND MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y')
4100: THEN
4101: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'alter temp table for res_req not handled here');
4102: ELSE
4103: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
4104: lv_retcode,
4105: 'MSC_RESOURCE_REQUIREMENTS',
4106: MSC_CL_COLLECTION.v_instance_code,
4107: MSC_UTIL.G_WARNING
4102: ELSE
4103: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
4104: lv_retcode,
4105: 'MSC_RESOURCE_REQUIREMENTS',
4106: MSC_CL_COLLECTION.v_instance_code,
4107: MSC_UTIL.G_WARNING
4108: );
4109: IF lv_retcode = MSC_UTIL.G_ERROR THEN
4110: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
4107: MSC_UTIL.G_WARNING
4108: );
4109: IF lv_retcode = MSC_UTIL.G_ERROR THEN
4110: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
4111: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
4112: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
4113: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
4114: END IF;
4115:
4109: IF lv_retcode = MSC_UTIL.G_ERROR THEN
4110: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
4111: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
4112: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
4113: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
4114: END IF;
4115:
4116: END IF;
4117: END IF;
4145: lv_temp_res_req_tbl VARCHAR2(30);
4146: lv_sql_stmt VARCHAR2(32767);
4147: lv_where_clause VARCHAR2(2000);
4148: BEGIN
4149: IF (((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND
4150: (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES) AND
4151: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) AND
4152: (MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS))
4153: OR
4146: lv_sql_stmt VARCHAR2(32767);
4147: lv_where_clause VARCHAR2(2000);
4148: BEGIN
4149: IF (((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND
4150: (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES) AND
4151: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) AND
4152: (MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS))
4153: OR
4154: ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_NO) AND
4147: lv_where_clause VARCHAR2(2000);
4148: BEGIN
4149: IF (((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND
4150: (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES) AND
4151: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) AND
4152: (MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS))
4153: OR
4154: ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_NO) AND
4155: (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_NO) AND
4148: BEGIN
4149: IF (((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND
4150: (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES) AND
4151: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) AND
4152: (MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS))
4153: OR
4154: ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_NO) AND
4155: (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_NO) AND
4156: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_NO))) THEN
4150: (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES) AND
4151: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) AND
4152: (MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS))
4153: OR
4154: ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_NO) AND
4155: (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_NO) AND
4156: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_NO))) THEN
4157: -- We do not need to do anything as, we are collecting both WIP and CMRO
4158: -- forecasts and the are there in the staging table.
4151: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) AND
4152: (MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS))
4153: OR
4154: ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_NO) AND
4155: (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_NO) AND
4156: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_NO))) THEN
4157: -- We do not need to do anything as, we are collecting both WIP and CMRO
4158: -- forecasts and the are there in the staging table.
4159: -- Or, we need not change any data in msc_resource_requirements.
4152: (MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS))
4153: OR
4154: ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_NO) AND
4155: (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_NO) AND
4156: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_NO))) THEN
4157: -- We do not need to do anything as, we are collecting both WIP and CMRO
4158: -- forecasts and the are there in the staging table.
4159: -- Or, we need not change any data in msc_resource_requirements.
4160: RETURN;
4159: -- Or, we need not change any data in msc_resource_requirements.
4160: RETURN;
4161: END IF;
4162:
4163: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
4164: lv_temp_res_req_tbl := 'RESOURCE_REQUIREMENTS_'||MSC_CL_COLLECTION.v_instance_code;
4165:
4166: lv_sql_stmt :=
4167: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_temp_res_req_tbl
4160: RETURN;
4161: END IF;
4162:
4163: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
4164: lv_temp_res_req_tbl := 'RESOURCE_REQUIREMENTS_'||MSC_CL_COLLECTION.v_instance_code;
4165:
4166: lv_sql_stmt :=
4167: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_temp_res_req_tbl
4168: ||' SELECT * FROM '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_RESOURCE_REQUIREMENTS '
4165:
4166: lv_sql_stmt :=
4167: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_temp_res_req_tbl
4168: ||' SELECT * FROM '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_RESOURCE_REQUIREMENTS '
4169: ||' WHERE sr_instance_id =' ||MSC_CL_COLLECTION.v_instance_id
4170: ||' AND plan_id = -1 and (';
4171:
4172: IF NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
4173: lv_sql_stmt := lv_sql_stmt||' organization_id NOT '||MSC_UTIL.v_in_org_str;
4168: ||' SELECT * FROM '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_RESOURCE_REQUIREMENTS '
4169: ||' WHERE sr_instance_id =' ||MSC_CL_COLLECTION.v_instance_id
4170: ||' AND plan_id = -1 and (';
4171:
4172: IF NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
4173: lv_sql_stmt := lv_sql_stmt||' organization_id NOT '||MSC_UTIL.v_in_org_str;
4174: END IF;
4175: /*
4176: IF NOT MSC_CL_COLLECTION.v_is_complete_refresh
4172: IF NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
4173: lv_sql_stmt := lv_sql_stmt||' organization_id NOT '||MSC_UTIL.v_in_org_str;
4174: END IF;
4175: /*
4176: IF NOT MSC_CL_COLLECTION.v_is_complete_refresh
4177: OR NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
4178: lv_sql_stmt := lv_sql_stmt||' OR (';
4179: END IF;*/
4180:
4173: lv_sql_stmt := lv_sql_stmt||' organization_id NOT '||MSC_UTIL.v_in_org_str;
4174: END IF;
4175: /*
4176: IF NOT MSC_CL_COLLECTION.v_is_complete_refresh
4177: OR NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
4178: lv_sql_stmt := lv_sql_stmt||' OR (';
4179: END IF;*/
4180:
4181: IF ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND
4177: OR NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
4178: lv_sql_stmt := lv_sql_stmt||' OR (';
4179: END IF;*/
4180:
4181: IF ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND
4182: (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES)) THEN
4183: lv_where_clause :=' NOT ( supply_type =92 ) ';
4184: ELSIF MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES THEN
4185: lv_where_clause :=' NOT ( supply_type =92 AND MAINTENANCE_OBJECT_SOURCE =2 ) ';
4178: lv_sql_stmt := lv_sql_stmt||' OR (';
4179: END IF;*/
4180:
4181: IF ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND
4182: (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES)) THEN
4183: lv_where_clause :=' NOT ( supply_type =92 ) ';
4184: ELSIF MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES THEN
4185: lv_where_clause :=' NOT ( supply_type =92 AND MAINTENANCE_OBJECT_SOURCE =2 ) ';
4186: ELSIF MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES THEN
4180:
4181: IF ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND
4182: (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES)) THEN
4183: lv_where_clause :=' NOT ( supply_type =92 ) ';
4184: ELSIF MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES THEN
4185: lv_where_clause :=' NOT ( supply_type =92 AND MAINTENANCE_OBJECT_SOURCE =2 ) ';
4186: ELSIF MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES THEN
4187: lv_where_clause :=' NOT ( supply_type =92 AND MAINTENANCE_OBJECT_SOURCE =1 ) ';
4188: END IF;
4182: (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES)) THEN
4183: lv_where_clause :=' NOT ( supply_type =92 ) ';
4184: ELSIF MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES THEN
4185: lv_where_clause :=' NOT ( supply_type =92 AND MAINTENANCE_OBJECT_SOURCE =2 ) ';
4186: ELSIF MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES THEN
4187: lv_where_clause :=' NOT ( supply_type =92 AND MAINTENANCE_OBJECT_SOURCE =1 ) ';
4188: END IF;
4189:
4190: IF lv_where_clause is not NULL and MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES then
4186: ELSIF MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES THEN
4187: lv_where_clause :=' NOT ( supply_type =92 AND MAINTENANCE_OBJECT_SOURCE =1 ) ';
4188: END IF;
4189:
4190: IF lv_where_clause is not NULL and MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES then
4191: lv_where_clause := lv_where_clause ||' AND supply_type NOT IN (1,3,50,70)';
4192: ELSIF MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES THEN
4193: lv_where_clause :=' supply_type NOT IN (1,3,50,70)';
4194: END IF;
4188: END IF;
4189:
4190: IF lv_where_clause is not NULL and MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES then
4191: lv_where_clause := lv_where_clause ||' AND supply_type NOT IN (1,3,50,70)';
4192: ELSIF MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES THEN
4193: lv_where_clause :=' supply_type NOT IN (1,3,50,70)';
4194: END IF;
4195:
4196: IF NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS
4192: ELSIF MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES THEN
4193: lv_where_clause :=' supply_type NOT IN (1,3,50,70)';
4194: END IF;
4195:
4196: IF NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS
4197: and lv_where_clause IS NOT NULL THEN
4198: lv_sql_stmt := lv_sql_stmt||' OR ';
4199: END IF;
4200:
4219: lv_copySQL_variablepart VARCHAR2 (5000);
4220: firstcondn BOOLEAN;
4221:
4222: BEGIN
4223: IF (((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND
4224: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES)) OR
4225: ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_NO) AND
4226: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_NO)) AND
4227: (MSC_CL_COLLECTION.v_coll_prec.org_group_flag =
4220: firstcondn BOOLEAN;
4221:
4222: BEGIN
4223: IF (((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND
4224: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES)) OR
4225: ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_NO) AND
4226: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_NO)) AND
4227: (MSC_CL_COLLECTION.v_coll_prec.org_group_flag =
4228: MSC_UTIL.G_ALL_ORGANIZATIONS)) THEN
4221:
4222: BEGIN
4223: IF (((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND
4224: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES)) OR
4225: ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_NO) AND
4226: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_NO)) AND
4227: (MSC_CL_COLLECTION.v_coll_prec.org_group_flag =
4228: MSC_UTIL.G_ALL_ORGANIZATIONS)) THEN
4229: -- We do not need to do anything as, we are collecting both WIP and CMRO
4222: BEGIN
4223: IF (((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND
4224: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES)) OR
4225: ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_NO) AND
4226: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_NO)) AND
4227: (MSC_CL_COLLECTION.v_coll_prec.org_group_flag =
4228: MSC_UTIL.G_ALL_ORGANIZATIONS)) THEN
4229: -- We do not need to do anything as, we are collecting both WIP and CMRO
4230: -- forecasts and the are there in the staging table.
4223: IF (((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND
4224: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES)) OR
4225: ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_NO) AND
4226: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_NO)) AND
4227: (MSC_CL_COLLECTION.v_coll_prec.org_group_flag =
4228: MSC_UTIL.G_ALL_ORGANIZATIONS)) THEN
4229: -- We do not need to do anything as, we are collecting both WIP and CMRO
4230: -- forecasts and the are there in the staging table.
4231: -- Or, we need not change any data in msc_resource_requirements.
4231: -- Or, we need not change any data in msc_resource_requirements.
4232: RETURN;
4233: END IF;
4234:
4235: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
4236: lv_temp_res_req_tbl := 'RESOURCE_REQUIREMENTS_'||MSC_CL_COLLECTION.v_instance_code;
4237:
4238: lv_copySQL_fixedpart :=
4239: 'INSERT INTO '||lv_temp_res_req_tbl
4232: RETURN;
4233: END IF;
4234:
4235: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
4236: lv_temp_res_req_tbl := 'RESOURCE_REQUIREMENTS_'||MSC_CL_COLLECTION.v_instance_code;
4237:
4238: lv_copySQL_fixedpart :=
4239: 'INSERT INTO '||lv_temp_res_req_tbl
4240: ||' SELECT * FROM MSC_RESOURCE_REQUIREMENTS '
4237:
4238: lv_copySQL_fixedpart :=
4239: 'INSERT INTO '||lv_temp_res_req_tbl
4240: ||' SELECT * FROM MSC_RESOURCE_REQUIREMENTS '
4241: ||' WHERE sr_instance_id =' ||MSC_CL_COLLECTION.v_instance_id
4242: ||' AND plan_id = -1 ';
4243:
4244:
4245: IF --((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND USAF
4241: ||' WHERE sr_instance_id =' ||MSC_CL_COLLECTION.v_instance_id
4242: ||' AND plan_id = -1 ';
4243:
4244:
4245: IF --((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND USAF
4246: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) THEN
4247:
4248: lv_collected_ordertypes :='70';
4249: END IF;
4242: ||' AND plan_id = -1 ';
4243:
4244:
4245: IF --((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) AND USAF
4246: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) THEN
4247:
4248: lv_collected_ordertypes :='70';
4249: END IF;
4250: /*ELSIF -- ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_NO) AND USAF
4246: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) THEN
4247:
4248: lv_collected_ordertypes :='70';
4249: END IF;
4250: /*ELSIF -- ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_NO) AND USAF
4251: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) THEN
4252:
4253: lv_sql_stmt :=lv_sql_stmt
4254: ||' AND supply_type NOT IN (70)'; */
4247:
4248: lv_collected_ordertypes :='70';
4249: END IF;
4250: /*ELSIF -- ((MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_NO) AND USAF
4251: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) THEN
4252:
4253: lv_sql_stmt :=lv_sql_stmt
4254: ||' AND supply_type NOT IN (70)'; */
4255:
4254: ||' AND supply_type NOT IN (70)'; */
4255:
4256:
4257: /* start of code to prepare lv_collected_entites_filter2
4258: IF ( (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4259: MSC_UTIL.SYS_YES)
4260: AND (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4261: MSC_UTIL.SYS_YES))
4262: THEN
4256:
4257: /* start of code to prepare lv_collected_entites_filter2
4258: IF ( (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4259: MSC_UTIL.SYS_YES)
4260: AND (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4261: MSC_UTIL.SYS_YES))
4262: THEN
4263: lv_collected_entites_filter2 := '(supply_type =92)';
4264: ELSIF ( (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4260: AND (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4261: MSC_UTIL.SYS_YES))
4262: THEN
4263: lv_collected_entites_filter2 := '(supply_type =92)';
4264: ELSIF ( (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4265: MSC_UTIL.SYS_NO)
4266: AND (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4267: MSC_UTIL.SYS_YES))
4268: THEN
4262: THEN
4263: lv_collected_entites_filter2 := '(supply_type =92)';
4264: ELSIF ( (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4265: MSC_UTIL.SYS_NO)
4266: AND (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4267: MSC_UTIL.SYS_YES))
4268: THEN
4269: Lv_collected_entites_filter2 :=
4270: '( supply_type =92 AND MAINTENANCE_OBJECT_SOURCE =2 ) ';
4267: MSC_UTIL.SYS_YES))
4268: THEN
4269: Lv_collected_entites_filter2 :=
4270: '( supply_type =92 AND MAINTENANCE_OBJECT_SOURCE =2 ) ';
4271: ELSIF ( (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4272: MSC_UTIL.SYS_YES)
4273: AND (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4274: MSC_UTIL.SYS_NO))
4275: THEN
4269: Lv_collected_entites_filter2 :=
4270: '( supply_type =92 AND MAINTENANCE_OBJECT_SOURCE =2 ) ';
4271: ELSIF ( (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4272: MSC_UTIL.SYS_YES)
4273: AND (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4274: MSC_UTIL.SYS_NO))
4275: THEN
4276: lv_collected_entites_filter2 :=
4277: '( supply_type =92 AND MAINTENANCE_OBJECT_SOURCE =1 ) ';
4274: MSC_UTIL.SYS_NO))
4275: THEN
4276: lv_collected_entites_filter2 :=
4277: '( supply_type =92 AND MAINTENANCE_OBJECT_SOURCE =1 ) ';
4278: ELSIF ( (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4279: MSC_UTIL.SYS_NO)
4280: AND (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4281: MSC_UTIL.SYS_NO))
4282: THEN
4276: lv_collected_entites_filter2 :=
4277: '( supply_type =92 AND MAINTENANCE_OBJECT_SOURCE =1 ) ';
4278: ELSIF ( (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4279: MSC_UTIL.SYS_NO)
4280: AND (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4281: MSC_UTIL.SYS_NO))
4282: THEN
4283: lv_collected_entites_filter2 := NULL;
4284: END IF;
4284: END IF;
4285:
4286: firstcondn := TRUE;
4287:
4288: IF (NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag =
4289: MSC_UTIL.G_ALL_ORGANIZATIONS)
4290: THEN
4291: IF (NOT firstcondn)
4292: THEN
4297: '(ORGANIZATION_ID NOT ' || MSC_UTIL.v_in_org_str || ')';
4298: firstcondn := FALSE;
4299: END IF;
4300:
4301: IF NOT ( MSC_CL_COLLECTION.v_is_complete_refresh
4302: AND lv_collected_ordertypes IS NOT NULL)
4303: THEN
4304: IF (NOT firstcondn)
4305: THEN
4314: firstcondn := FALSE;
4315: end if ;
4316: END IF;
4317:
4318: IF NOT ( MSC_CL_COLLECTION.v_is_complete_refresh)
4319: AND (lv_collected_entites_filter2 IS NOT NULL)
4320: THEN
4321: IF (NOT firstcondn)
4322: THEN
4354: MSC_UTIL.LOG_MSG (MSC_UTIL.G_D_STATUS, 'Load ODS demand :sql stmt being executed: ' || lv_sql_stmt);
4355: EXECUTE IMMEDIATE lv_sql_stmt;
4356:
4357: /*
4358: IF (MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS)
4359: THEN
4360: null;
4361: ELSIF (MSC_CL_COLLECTION.v_is_complete_refresh) then
4362: lv_sql_stmt :=lv_sql_stmt
4357: /*
4358: IF (MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS)
4359: THEN
4360: null;
4361: ELSIF (MSC_CL_COLLECTION.v_is_complete_refresh) then
4362: lv_sql_stmt :=lv_sql_stmt
4363: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
4364:
4365: END IF;