2: /* $Header: MSCLRTGB.pls 120.3 2007/06/11 09:49:18 sbyerram noship $ */
3:
4: v_sub_str VARCHAR2(4000):=NULL;
5: c_count NUMBER:= 0;
6: -- v_warning_flag NUMBER:= MSC_UTIL.SYS_NO; --2 be changed
7:
8: -- G_COLLECT_SRP_DATA VARCHAR2(1) := NVL(FND_PROFILE.VALUE('MSC_SRP_ENABLED'),'N');
9: -- To collect SRP Data when this profile is set to Yes neds to be deleted
10: -- v_is_cont_refresh BOOLEAN;
42:
43: BEGIN
44:
45: IF ((MSC_CL_COLLECTION.v_is_complete_refresh) OR (MSC_CL_COLLECTION.v_is_partial_refresh)) THEN
46: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
47: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_STD_OP_RESOURCES', MSC_CL_COLLECTION.v_instance_id, -1);
48: ELSE
49: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_STD_OP_RESOURCES', MSC_CL_COLLECTION.v_instance_id, -1,v_sub_str); /* ds change change */
50: END IF;
108: WHEN OTHERS THEN
109:
110: IF SQLCODE IN (-01683,-01653,-01650,-01562) THEN
111:
112: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
113: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
114: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_STD_OP_RESOURCES');
115: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SETUP_TRANSITIONS');
116: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
112: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
113: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
114: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_STD_OP_RESOURCES');
115: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SETUP_TRANSITIONS');
116: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
117:
118: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
119: RAISE;
120: ELSE
114: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_STD_OP_RESOURCES');
115: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SETUP_TRANSITIONS');
116: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
117:
118: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
119: RAISE;
120: ELSE
121: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
122:
117:
118: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
119: RAISE;
120: ELSE
121: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
122:
123: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
124: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
125: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_STD_OP_RESOURCES');
119: RAISE;
120: ELSE
121: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
122:
123: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
124: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
125: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_STD_OP_RESOURCES');
126: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SETUP_TRANSITIONS');
127: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
123: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
124: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
125: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_STD_OP_RESOURCES');
126: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SETUP_TRANSITIONS');
127: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
128:
129: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
130: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_CODE');
131: FND_MESSAGE.SET_TOKEN('VALUE',c_rec.OPERATION_CODE);
128:
129: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
130: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_CODE');
131: FND_MESSAGE.SET_TOKEN('VALUE',c_rec.OPERATION_CODE);
132: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
133:
134: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
135: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_ID');
136: FND_MESSAGE.SET_TOKEN('VALUE', c_rec.RESOURCE_ID);
133:
134: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
135: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_ID');
136: FND_MESSAGE.SET_TOKEN('VALUE', c_rec.RESOURCE_ID);
137: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
138:
139: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
140: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_SEQ_NUM');
141: FND_MESSAGE.SET_TOKEN('VALUE', c_rec.RESOURCE_SEQ_NUM);
138:
139: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
140: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_SEQ_NUM');
141: FND_MESSAGE.SET_TOKEN('VALUE', c_rec.RESOURCE_SEQ_NUM);
142: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
143:
144:
145: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
146: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_ID');
145: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
146: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_ID');
147: FND_MESSAGE.SET_TOKEN('VALUE', MSC_GET_NAME.ORG_CODE( c_rec.ORGANIZATION_ID,
148: MSC_CL_COLLECTION.v_instance_id));
149: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
150: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
151: END IF;
152:
153: END;
146: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_ID');
147: FND_MESSAGE.SET_TOKEN('VALUE', MSC_GET_NAME.ORG_CODE( c_rec.ORGANIZATION_ID,
148: MSC_CL_COLLECTION.v_instance_id));
149: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
150: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
151: END IF;
152:
153: END;
154:
152:
153: END;
154:
155: END LOOP;
156: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Total std op resources = '|| to_char(total_count));
157: COMMIT;
158:
159: END IF; /* MSC_CL_COLLECTION.v_is_complete_refresh) OR (MSC_CL_COLLECTION.v_is_partial_refresh */
160:
214: mon.SR_INSTANCE_ID
215: from MSC_ST_OPERATION_NETWORKS mon,
216: MSC_ITEM_ID_LID t1 /* ds change change */
217: WHERE mon.SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id
218: AND mon.DELETED_FLAG = MSC_UTIL.SYS_NO
219: AND mon.FROM_ITEM_ID = t1.SR_INVENTORY_ITEM_ID(+) /* ds change change */
220: AND mon.sr_instance_id = t1.sr_instance_id(+) ; /* ds change change */
221:
222:
228: mon.REFRESH_ID,
229: mon.SR_INSTANCE_ID
230: FROM MSC_ST_OPERATION_NETWORKS mon
231: WHERE mon.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
232: and mon.DELETED_FLAG= MSC_UTIL.SYS_YES;
233:
234: c_count NUMBER:= 0;
235: lv_tbl VARCHAR2(30);
236: lv_sql_stmt VARCHAR2(5000);
238: BEGIN
239:
240: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
241:
242: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
243: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_NETWORKS', MSC_CL_COLLECTION.v_instance_id, -1);
244: ELSE
245: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
246: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_NETWORKS', MSC_CL_COLLECTION.v_instance_id, -1,v_sub_str);
241:
242: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
243: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_NETWORKS', MSC_CL_COLLECTION.v_instance_id, -1);
244: ELSE
245: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
246: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_NETWORKS', MSC_CL_COLLECTION.v_instance_id, -1,v_sub_str);
247: END IF;
248:
249: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh
419: WHEN OTHERS THEN
420:
421: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
422:
423: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
424: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
425: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_NETWORKS');
426: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_NETWORKS');
427: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
423: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
424: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
425: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_NETWORKS');
426: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_NETWORKS');
427: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
428:
429: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
430: RAISE;
431:
425: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_NETWORKS');
426: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_NETWORKS');
427: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
428:
429: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
430: RAISE;
431:
432: ELSE
433: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
429: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
430: RAISE;
431:
432: ELSE
433: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
434:
435: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
436: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
437: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_NETWORKS');
431:
432: ELSE
433: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
434:
435: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
436: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
437: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_NETWORKS');
438: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_NETWORKS');
439: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
435: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
436: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
437: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_NETWORKS');
438: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_NETWORKS');
439: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
440:
441: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
442: FND_MESSAGE.SET_TOKEN('COLUMN', 'FROM_OP_SEQ_ID');
443: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.FROM_OP_SEQ_ID));
440:
441: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
442: FND_MESSAGE.SET_TOKEN('COLUMN', 'FROM_OP_SEQ_ID');
443: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.FROM_OP_SEQ_ID));
444: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
445:
446: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
447: FND_MESSAGE.SET_TOKEN('COLUMN', 'TO_OP_SEQ_ID');
448: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.TO_OP_SEQ_ID));
445:
446: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
447: FND_MESSAGE.SET_TOKEN('COLUMN', 'TO_OP_SEQ_ID');
448: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.TO_OP_SEQ_ID));
449: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
450:
451: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
452: FND_MESSAGE.SET_TOKEN('COLUMN', 'FROM_OP_SEQ_NUM');
453: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.FROM_OP_SEQ_NUM));
450:
451: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
452: FND_MESSAGE.SET_TOKEN('COLUMN', 'FROM_OP_SEQ_NUM');
453: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.FROM_OP_SEQ_NUM));
454: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
455:
456: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
457: FND_MESSAGE.SET_TOKEN('COLUMN', 'TO_OP_SEQ_NUM');
458: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.TO_OP_SEQ_NUM));
455:
456: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
457: FND_MESSAGE.SET_TOKEN('COLUMN', 'TO_OP_SEQ_NUM');
458: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.TO_OP_SEQ_NUM));
459: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
460:
461: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
462: END IF;
463: END;
457: FND_MESSAGE.SET_TOKEN('COLUMN', 'TO_OP_SEQ_NUM');
458: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.TO_OP_SEQ_NUM));
459: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
460:
461: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
462: END IF;
463: END;
464:
465: END LOOP;
496: MSC_ST_ROUTINGS msr
497: WHERE t1.SR_INVENTORY_ITEM_ID= msr.assembly_item_id
498: AND t1.sr_instance_id= msr.sr_instance_id
499: AND msr.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
500: AND msr.DELETED_FLAG= MSC_UTIL.SYS_NO;
501:
502: CURSOR c4_d IS
503: SELECT
504: msr.ROUTING_SEQUENCE_ID,
504: msr.ROUTING_SEQUENCE_ID,
505: msr.SR_INSTANCE_ID
506: FROM MSC_ST_ROUTINGS msr
507: WHERE msr.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
508: AND msr.DELETED_FLAG= MSC_UTIL.SYS_YES;
509:
510:
511: c_count NUMBER:= 0;
512: lv_tbl VARCHAR2(30);
520: -- We want to delete all ROUTING related data and get new stuff.
521:
522: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_ROUTINGS', MSC_CL_COLLECTION.v_instance_id, -1);
523:
524: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
525: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_ROUTINGS', MSC_CL_COLLECTION.v_instance_id, -1);
526: ELSE
527: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
528: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_ROUTINGS', MSC_CL_COLLECTION.v_instance_id, -1,v_sub_str);
523:
524: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
525: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_ROUTINGS', MSC_CL_COLLECTION.v_instance_id, -1);
526: ELSE
527: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
528: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_ROUTINGS', MSC_CL_COLLECTION.v_instance_id, -1,v_sub_str);
529: END IF;
530:
531: BEGIN
584: ||' MSC_ST_ROUTINGS msr'
585: ||' WHERE t1.SR_INVENTORY_ITEM_ID= msr.assembly_item_id'
586: ||' AND t1.sr_instance_id= msr.sr_instance_id'
587: ||' AND msr.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
588: ||' AND msr.DELETED_FLAG= '||MSC_UTIL.SYS_NO;
589:
590: EXECUTE IMMEDIATE lv_sql_ins
591: USING v_chr10, v_chr13, 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;
592:
590: EXECUTE IMMEDIATE lv_sql_ins
591: USING v_chr10, v_chr13, 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;
592:
593: COMMIT;
594: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'routings loaded');
595:
596: EXCEPTION
597: WHEN OTHERS THEN
598: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
596: EXCEPTION
597: WHEN OTHERS THEN
598: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
599:
600: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
601: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
602: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING');
603: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTINGS');
604: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
600: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
601: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
602: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING');
603: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTINGS');
604: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
605:
606: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
607: RAISE;
608:
602: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING');
603: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTINGS');
604: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
605:
606: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
607: RAISE;
608:
609: ELSE
610: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
606: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
607: RAISE;
608:
609: ELSE
610: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
611: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
612: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING');
613: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTINGS');
614: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
610: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
611: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
612: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING');
613: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTINGS');
614: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
615:
616: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
617:
618: --If Direct path load results in warning then the processing has to be
612: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING');
613: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTINGS');
614: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
615:
616: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
617:
618: --If Direct path load results in warning then the processing has to be
619: --switched back to row by row processing. This will help to identify the
620: --erroneous record and will also help in processing the rest of the records.
617:
618: --If Direct path load results in warning then the processing has to be
619: --switched back to row by row processing. This will help to identify the
620: --erroneous record and will also help in processing the rest of the records.
621: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'bulk insert failed - routings');
622: lb_refresh_failed := TRUE;
623: END IF;
624: END;
625:
744: WHEN OTHERS THEN
745:
746: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
747:
748: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
749: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
750: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING');
751: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTINGS');
752: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
748: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
749: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
750: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING');
751: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTINGS');
752: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
753:
754: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
755: RAISE;
756:
750: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING');
751: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTINGS');
752: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
753:
754: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
755: RAISE;
756:
757: ELSE
758: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
754: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
755: RAISE;
756:
757: ELSE
758: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
759:
760: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
761: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
762: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING');
756:
757: ELSE
758: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
759:
760: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
761: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
762: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING');
763: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTINGS');
764: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
760: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
761: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
762: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING');
763: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTINGS');
764: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
765:
766: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
767: FND_MESSAGE.SET_TOKEN('COLUMN', 'ASSEMBLY_ITEM_NAME');
768: FND_MESSAGE.SET_TOKEN('VALUE', MSC_CL_ITEM_ODS_LOAD.ITEM_NAME(c_rec.ASSEMBLY_ITEM_ID));
765:
766: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
767: FND_MESSAGE.SET_TOKEN('COLUMN', 'ASSEMBLY_ITEM_NAME');
768: FND_MESSAGE.SET_TOKEN('VALUE', MSC_CL_ITEM_ODS_LOAD.ITEM_NAME(c_rec.ASSEMBLY_ITEM_ID));
769: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
770:
771: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
772: FND_MESSAGE.SET_TOKEN('COLUMN', 'ROUTING_SEQUENCE_ID');
773: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.ROUTING_SEQUENCE_ID));
770:
771: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
772: FND_MESSAGE.SET_TOKEN('COLUMN', 'ROUTING_SEQUENCE_ID');
773: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.ROUTING_SEQUENCE_ID));
774: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
775:
776: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
777: END IF;
778: END;
772: FND_MESSAGE.SET_TOKEN('COLUMN', 'ROUTING_SEQUENCE_ID');
773: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.ROUTING_SEQUENCE_ID));
774: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
775:
776: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
777: END IF;
778: END;
779:
780: END LOOP;
797: ROUTING_SEQUENCE_ID,
798: SR_INSTANCE_ID
799: FROM MSC_ST_OPERATION_COMPONENTS msoc
800: WHERE msoc.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
801: AND msoc.DELETED_FLAG= MSC_UTIL.SYS_NO;
802:
803: CURSOR c9_d IS
804: SELECT
805: OPERATION_SEQUENCE_ID,
809: SR_INSTANCE_ID,
810: ORGANIZATION_ID
811: FROM MSC_ST_OPERATION_COMPONENTS msoc
812: WHERE msoc.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
813: AND msoc.DELETED_FLAG= MSC_UTIL.SYS_YES
814: UNION ALL
815: SELECT DISTINCT
816: TO_NUMBER(NULL),
817: TO_NUMBER(NULL),
825: AND msoc.Routing_Sequence_ID <> moc.Routing_Sequence_ID
826: AND msoc.Organization_ID= moc.Organization_ID
827: AND msoc.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
828: AND moc.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
829: AND msoc.DELETED_FLAG= MSC_UTIL.SYS_NO
830: AND moc.PLAN_ID= -1;
831:
832:
833: c_count NUMBER:= 0;
843: -- We want to delete all BOM related data and get new stuff.
844:
845: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_COMPONENTS', MSC_CL_COLLECTION.v_instance_id, -1);
846:
847: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
848: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_COMPONENTS', MSC_CL_COLLECTION.v_instance_id, -1);
849: ELSE
850: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
851: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_COMPONENTS', MSC_CL_COLLECTION.v_instance_id, -1,v_sub_str);
846:
847: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
848: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_COMPONENTS', MSC_CL_COLLECTION.v_instance_id, -1);
849: ELSE
850: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
851: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_COMPONENTS', MSC_CL_COLLECTION.v_instance_id, -1,v_sub_str);
852: END IF;
853: BEGIN
854: INSERT /*+ append */
879: MSC_CL_COLLECTION.v_current_date,
880: MSC_CL_COLLECTION.v_current_user
881: FROM MSC_ST_OPERATION_COMPONENTS msoc
882: WHERE msoc.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
883: AND msoc.DELETED_FLAG= MSC_UTIL.SYS_NO;
884:
885: COMMIT;
886: EXCEPTION
887: WHEN OTHERS THEN
887: WHEN OTHERS THEN
888:
889: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
890:
891: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
892: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
893: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
894: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_COMPONENTS');
895: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
891: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
892: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
893: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
894: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_COMPONENTS');
895: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
896:
897: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
898: RAISE;
899: ELSE
893: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
894: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_COMPONENTS');
895: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
896:
897: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
898: RAISE;
899: ELSE
900: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
901: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
896:
897: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
898: RAISE;
899: ELSE
900: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
901: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
902: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
903: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
904: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_COMPONENTS');
897: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
898: RAISE;
899: ELSE
900: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
901: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
902: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
903: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
904: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_COMPONENTS');
905: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
901: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
902: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
903: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
904: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_COMPONENTS');
905: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
906:
907: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
908: lb_refresh_failed := TRUE;
909: END IF;
903: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
904: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_COMPONENTS');
905: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
906:
907: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
908: lb_refresh_failed := TRUE;
909: END IF;
910: END;
911: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh
963: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
964: */
965: EXCEPTION
966: WHEN OTHERS THEN
967: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
968: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
969: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
970: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_COMPONENTS');
971: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
967: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
968: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
969: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
970: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_COMPONENTS');
971: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
972:
973: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
974: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_SEQUENCE_ID');
975: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.OPERATION_SEQUENCE_ID));
972:
973: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
974: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_SEQUENCE_ID');
975: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.OPERATION_SEQUENCE_ID));
976: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
977:
978: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
979: FND_MESSAGE.SET_TOKEN('COLUMN', 'COMPONENT_SEQUENCE_ID');
980: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.COMPONENT_SEQUENCE_ID));
977:
978: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
979: FND_MESSAGE.SET_TOKEN('COLUMN', 'COMPONENT_SEQUENCE_ID');
980: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.COMPONENT_SEQUENCE_ID));
981: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
982:
983: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
984: FND_MESSAGE.SET_TOKEN('COLUMN', 'ROUTING_SEQUENCE_ID');
985: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.ROUTING_SEQUENCE_ID));
982:
983: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
984: FND_MESSAGE.SET_TOKEN('COLUMN', 'ROUTING_SEQUENCE_ID');
985: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.ROUTING_SEQUENCE_ID));
986: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
987:
988: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
989: FND_MESSAGE.SET_TOKEN('COLUMN', 'BILL_SEQUENCE_ID');
990: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.BILL_SEQUENCE_ID));
987:
988: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
989: FND_MESSAGE.SET_TOKEN('COLUMN', 'BILL_SEQUENCE_ID');
990: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.BILL_SEQUENCE_ID));
991: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
992:
993: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
994:
995: END;
989: FND_MESSAGE.SET_TOKEN('COLUMN', 'BILL_SEQUENCE_ID');
990: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.BILL_SEQUENCE_ID));
991: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
992:
993: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
994:
995: END;
996:
997: END LOOP;
1063: WHEN OTHERS THEN
1064:
1065: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
1066:
1067: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1068: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1069: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
1070: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_COMPONENTS');
1071: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1067: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1068: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1069: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
1070: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_COMPONENTS');
1071: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1072:
1073: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1074: RAISE;
1075:
1069: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
1070: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_COMPONENTS');
1071: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1072:
1073: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1074: RAISE;
1075:
1076: ELSE
1077: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1073: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1074: RAISE;
1075:
1076: ELSE
1077: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1078:
1079: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1080: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1081: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
1075:
1076: ELSE
1077: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1078:
1079: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1080: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1081: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
1082: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_COMPONENTS');
1083: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1079: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1080: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1081: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_COMPONENTS');
1082: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_COMPONENTS');
1083: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1084:
1085: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1086: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
1087: FND_MESSAGE.SET_TOKEN('VALUE', MSC_GET_NAME.ORG_CODE( c_rec.ORGANIZATION_ID, MSC_CL_COLLECTION.v_instance_id));
1084:
1085: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1086: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
1087: FND_MESSAGE.SET_TOKEN('VALUE', MSC_GET_NAME.ORG_CODE( c_rec.ORGANIZATION_ID, MSC_CL_COLLECTION.v_instance_id));
1088: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1089:
1090: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1091: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_SEQUENCE_ID');
1092: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.OPERATION_SEQUENCE_ID));
1089:
1090: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1091: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_SEQUENCE_ID');
1092: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.OPERATION_SEQUENCE_ID));
1093: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1094:
1095: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1096: FND_MESSAGE.SET_TOKEN('COLUMN', 'COMPONENT_SEQUENCE_ID');
1097: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.COMPONENT_SEQUENCE_ID));
1094:
1095: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1096: FND_MESSAGE.SET_TOKEN('COLUMN', 'COMPONENT_SEQUENCE_ID');
1097: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.COMPONENT_SEQUENCE_ID));
1098: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1099:
1100: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1101: END IF;
1102:
1096: FND_MESSAGE.SET_TOKEN('COLUMN', 'COMPONENT_SEQUENCE_ID');
1097: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.COMPONENT_SEQUENCE_ID));
1098: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1099:
1100: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1101: END IF;
1102:
1103: END;
1104:
1125: msors.SR_INSTANCE_ID,
1126: msors.ORGANIZATION_ID
1127: FROM MSC_ST_OPERATION_RESOURCE_SEQS msors
1128: WHERE msors.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1129: AND msors.DELETED_FLAG= MSC_UTIL.SYS_NO;
1130:
1131: CURSOR c7_d IS
1132: SELECT
1133: msors.ROUTING_SEQUENCE_ID,
1135: msors.RESOURCE_SEQ_NUM,
1136: msors.SR_INSTANCE_ID
1137: FROM MSC_ST_OPERATION_RESOURCE_SEQS msors
1138: WHERE msors.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1139: AND msors.DELETED_FLAG= MSC_UTIL.SYS_YES;
1140:
1141:
1142: c_count NUMBER:= 0;
1143: lv_tbl VARCHAR2(30);
1149: lv_retcode NUMBER;
1150:
1151: BEGIN
1152:
1153: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1154: lv_tbl:= 'OPERATION_RESOURCE_SEQS_'||MSC_CL_COLLECTION.v_instance_code;
1155: ELSE
1156: lv_tbl:= 'MSC_OPERATION_RESOURCE_SEQS';
1157: END IF;
1159: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
1160: -- We want to delete all BOM related data and get new stuff.
1161: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_RESOURCE_SEQS', MSC_CL_COLLECTION.v_instance_id, -1);
1162:
1163: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_NO THEN
1164: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1165: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_RESOURCE_SEQS', MSC_CL_COLLECTION.v_instance_id, -1);
1166: ELSE
1167: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1160: -- We want to delete all BOM related data and get new stuff.
1161: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_RESOURCE_SEQS', MSC_CL_COLLECTION.v_instance_id, -1);
1162:
1163: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_NO THEN
1164: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1165: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_RESOURCE_SEQS', MSC_CL_COLLECTION.v_instance_id, -1);
1166: ELSE
1167: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1168: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_RESOURCE_SEQS', MSC_CL_COLLECTION.v_instance_id, -1,v_sub_str);
1163: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_NO THEN
1164: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1165: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_RESOURCE_SEQS', MSC_CL_COLLECTION.v_instance_id, -1);
1166: ELSE
1167: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1168: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_RESOURCE_SEQS', MSC_CL_COLLECTION.v_instance_id, -1,v_sub_str);
1169: END IF;
1170: END IF;
1171:
1205: ||' :v_current_date,'
1206: ||' :v_current_user '
1207: ||' FROM MSC_ST_OPERATION_RESOURCE_SEQS msors'
1208: ||' WHERE msors.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
1209: ||' AND msors.DELETED_FLAG= '||MSC_UTIL.SYS_NO;
1210:
1211: EXECUTE IMMEDIATE lv_sql_ins
1212: 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;
1213:
1211: EXECUTE IMMEDIATE lv_sql_ins
1212: 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;
1213:
1214: COMMIT;
1215: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'operation resource seqs loaded');
1216:
1217: EXCEPTION
1218: WHEN OTHERS THEN
1219: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
1217: EXCEPTION
1218: WHEN OTHERS THEN
1219: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
1220:
1221: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1222: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1223: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OP_RESOURCE_SEQ');
1224: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCE_SEQS');
1225: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1221: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1222: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1223: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OP_RESOURCE_SEQ');
1224: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCE_SEQS');
1225: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1226:
1227: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1228: RAISE;
1229:
1223: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OP_RESOURCE_SEQ');
1224: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCE_SEQS');
1225: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1226:
1227: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1228: RAISE;
1229:
1230: ELSE
1231: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1227: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1228: RAISE;
1229:
1230: ELSE
1231: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1232: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1233: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OP_RESOURCE_SEQ');
1234: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCE_SEQS');
1235: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1231: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1232: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1233: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OP_RESOURCE_SEQ');
1234: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCE_SEQS');
1235: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1236:
1237: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1238:
1239: --If Direct path load results in warning then the processing has to be
1233: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OP_RESOURCE_SEQ');
1234: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCE_SEQS');
1235: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1236:
1237: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1238:
1239: --If Direct path load results in warning then the processing has to be
1240: --switched back to row by row processing. This will help to identify the
1241: --erroneous record and will also help in processing the rest of the records.
1238:
1239: --If Direct path load results in warning then the processing has to be
1240: --switched back to row by row processing. This will help to identify the
1241: --erroneous record and will also help in processing the rest of the records.
1242: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'bulk insert failed - operation resource seqs');
1243: lb_refresh_failed := TRUE;
1244: END IF;
1245: END;
1246:
1367: WHEN OTHERS THEN
1368:
1369: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
1370:
1371: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1372: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1373: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OP_RESOURCE_SEQ');
1374: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCE_SEQS');
1375: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1371: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1372: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1373: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OP_RESOURCE_SEQ');
1374: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCE_SEQS');
1375: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1376:
1377: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1378: RAISE;
1379:
1373: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OP_RESOURCE_SEQ');
1374: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCE_SEQS');
1375: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1376:
1377: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1378: RAISE;
1379:
1380: ELSE
1381: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1377: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1378: RAISE;
1379:
1380: ELSE
1381: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1382:
1383: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1384: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1385: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OP_RESOURCE_SEQ');
1379:
1380: ELSE
1381: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1382:
1383: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1384: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1385: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OP_RESOURCE_SEQ');
1386: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCE_SEQS');
1387: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1383: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1384: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1385: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OP_RESOURCE_SEQ');
1386: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCE_SEQS');
1387: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1388:
1389: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1390: FND_MESSAGE.SET_TOKEN('COLUMN', 'ROUTING_SEQUENCE_ID');
1391: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.ROUTING_SEQUENCE_ID));
1388:
1389: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1390: FND_MESSAGE.SET_TOKEN('COLUMN', 'ROUTING_SEQUENCE_ID');
1391: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.ROUTING_SEQUENCE_ID));
1392: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1393:
1394: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1395: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_SEQUENCE_ID');
1396: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.OPERATION_SEQUENCE_ID));
1393:
1394: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1395: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_SEQUENCE_ID');
1396: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.OPERATION_SEQUENCE_ID));
1397: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1398:
1399: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1400: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_SEQ_NUM');
1401: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.RESOURCE_SEQ_NUM));
1398:
1399: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1400: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_SEQ_NUM');
1401: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.RESOURCE_SEQ_NUM));
1402: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1403:
1404: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1405:
1406: END IF;
1400: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_SEQ_NUM');
1401: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.RESOURCE_SEQ_NUM));
1402: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1403:
1404: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1405:
1406: END IF;
1407: END;
1408:
1412: COMMIT;
1413:
1414: BEGIN
1415:
1416: 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
1417:
1418: lv_tbl:= 'OPERATION_RESOURCE_SEQS_'||MSC_CL_COLLECTION.v_instance_code;
1419:
1420: lv_sql_stmt:=
1421: 'INSERT INTO '||lv_tbl
1422: ||' SELECT * from MSC_OPERATION_RESOURCE_SEQS'
1423: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
1424: ||' AND plan_id = -1 '
1425: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
1426:
1427: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '||lv_sql_stmt);
1428: EXECUTE IMMEDIATE lv_sql_stmt;
1429:
1423: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
1424: ||' AND plan_id = -1 '
1425: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
1426:
1427: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '||lv_sql_stmt);
1428: EXECUTE IMMEDIATE lv_sql_stmt;
1429:
1430: COMMIT;
1431:
1430: COMMIT;
1431:
1432: END IF;
1433:
1434: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1435: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
1436: lv_retcode,
1437: 'MSC_OPERATION_RESOURCE_SEQS',
1438: MSC_CL_COLLECTION.v_instance_code,
1435: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
1436: lv_retcode,
1437: 'MSC_OPERATION_RESOURCE_SEQS',
1438: MSC_CL_COLLECTION.v_instance_code,
1439: MSC_UTIL.G_WARNING
1440: );
1441:
1442: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1443: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
1438: MSC_CL_COLLECTION.v_instance_code,
1439: MSC_UTIL.G_WARNING
1440: );
1441:
1442: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1443: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
1444: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
1445: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
1446: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1439: MSC_UTIL.G_WARNING
1440: );
1441:
1442: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1443: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
1444: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
1445: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
1446: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1447: END IF;
1441:
1442: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1443: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
1444: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
1445: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
1446: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1447: END IF;
1448:
1449: END IF;
1442: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1443: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
1444: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
1445: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
1446: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1447: END IF;
1448:
1449: END IF;
1450:
1450:
1451: EXCEPTION
1452: WHEN OTHERS THEN
1453:
1454: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1455: RAISE;
1456: END;
1457:
1458: END LOAD_OP_RESOURCE_SEQ;
1490: msro.SR_INSTANCE_ID,
1491: msro.ORGANIZATION_ID
1492: FROM MSC_ST_ROUTING_OPERATIONS msro
1493: WHERE msro.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1494: AND msro.DELETED_FLAG= MSC_UTIL.SYS_NO;
1495:
1496: CURSOR c5_d IS
1497: SELECT
1498: msro.ROUTING_SEQUENCE_ID,
1499: msro.OPERATION_SEQUENCE_ID,
1500: msro.SR_INSTANCE_ID
1501: FROM MSC_ST_ROUTING_OPERATIONS msro
1502: WHERE msro.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1503: AND msro.DELETED_FLAG= MSC_UTIL.SYS_YES;
1504:
1505:
1506: c_count NUMBER:= 0;
1507: lv_tbl VARCHAR2(30);
1513: lv_retcode NUMBER;
1514:
1515: BEGIN
1516:
1517: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1518: lv_tbl:= 'ROUTING_OPERATIONS_'||MSC_CL_COLLECTION.v_instance_code;
1519: ELSE
1520: lv_tbl:= 'MSC_ROUTING_OPERATIONS';
1521: END IF;
1523: IF MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh THEN
1524: -- We want to delete all BOM related data and get new stuff
1525: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_ROUTING_OPERATIONS', MSC_CL_COLLECTION.v_instance_id, -1);
1526:
1527: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_NO THEN
1528: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1529: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_ROUTING_OPERATIONS', MSC_CL_COLLECTION.v_instance_id, -1);
1530: ELSE
1531: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1524: -- We want to delete all BOM related data and get new stuff
1525: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_ROUTING_OPERATIONS', MSC_CL_COLLECTION.v_instance_id, -1);
1526:
1527: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_NO THEN
1528: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1529: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_ROUTING_OPERATIONS', MSC_CL_COLLECTION.v_instance_id, -1);
1530: ELSE
1531: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1532: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_ROUTING_OPERATIONS', MSC_CL_COLLECTION.v_instance_id, -1,v_sub_str);
1527: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_NO THEN
1528: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1529: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_ROUTING_OPERATIONS', MSC_CL_COLLECTION.v_instance_id, -1);
1530: ELSE
1531: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1532: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_ROUTING_OPERATIONS', MSC_CL_COLLECTION.v_instance_id, -1,v_sub_str);
1533: END IF;
1534: END IF;
1535:
1602: ||' :v_current_date, '
1603: ||' :v_current_user '
1604: ||' FROM MSC_ST_ROUTING_OPERATIONS msro '
1605: ||' WHERE msro.SR_INSTANCE_ID= ' || MSC_CL_COLLECTION.v_instance_id
1606: ||' AND msro.DELETED_FLAG= ' || MSC_UTIL.SYS_NO;
1607:
1608: EXECUTE IMMEDIATE lv_sql_ins
1609: USING v_chr10, v_chr13, 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;
1610:
1608: EXECUTE IMMEDIATE lv_sql_ins
1609: USING v_chr10, v_chr13, 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;
1610:
1611: COMMIT;
1612: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'routing operations loaded');
1613:
1614: EXCEPTION
1615: WHEN OTHERS THEN
1616: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
1614: EXCEPTION
1615: WHEN OTHERS THEN
1616: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
1617:
1618: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1619: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1620: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING_OPERATIONS');
1621: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTING_OPERATIONS');
1622: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1618: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1619: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1620: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING_OPERATIONS');
1621: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTING_OPERATIONS');
1622: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1623:
1624: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1625: RAISE;
1626:
1620: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING_OPERATIONS');
1621: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTING_OPERATIONS');
1622: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1623:
1624: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1625: RAISE;
1626:
1627: ELSE
1628: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1624: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1625: RAISE;
1626:
1627: ELSE
1628: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1629: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1630: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING_OPERATIONS');
1631: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTING_OPERATIONS');
1632: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1628: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1629: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1630: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING_OPERATIONS');
1631: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTING_OPERATIONS');
1632: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1633:
1634: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1635:
1636: --If Direct path load results in warning then the processing has to be
1630: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING_OPERATIONS');
1631: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTING_OPERATIONS');
1632: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1633:
1634: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1635:
1636: --If Direct path load results in warning then the processing has to be
1637: --switched back to row by row processing. This will help to identify the
1638: --erroneous record and will also help in processing the rest of the records.
1635:
1636: --If Direct path load results in warning then the processing has to be
1637: --switched back to row by row processing. This will help to identify the
1638: --erroneous record and will also help in processing the rest of the records.
1639: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'bulk insert failed - routing operations');
1640: lb_refresh_failed := TRUE;
1641: END IF;
1642: END;
1643:
1817: WHEN OTHERS THEN
1818:
1819: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
1820:
1821: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1822: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1823: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING_OPERATIONS');
1824: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTING_OPERATIONS');
1825: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1821: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1822: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1823: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING_OPERATIONS');
1824: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTING_OPERATIONS');
1825: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1826:
1827: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1828: RAISE;
1829:
1823: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING_OPERATIONS');
1824: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTING_OPERATIONS');
1825: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1826:
1827: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1828: RAISE;
1829:
1830: ELSE
1831: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1827: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1828: RAISE;
1829:
1830: ELSE
1831: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1832:
1833: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1834: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1835: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING_OPERATIONS');
1829:
1830: ELSE
1831: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1832:
1833: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1834: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1835: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING_OPERATIONS');
1836: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTING_OPERATIONS');
1837: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1833: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1834: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1835: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ROUTING_OPERATIONS');
1836: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_ROUTING_OPERATIONS');
1837: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1838:
1839: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1840: FND_MESSAGE.SET_TOKEN('COLUMN', 'ROUTING_SEQUENCE_ID');
1841: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.ROUTING_SEQUENCE_ID));
1838:
1839: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1840: FND_MESSAGE.SET_TOKEN('COLUMN', 'ROUTING_SEQUENCE_ID');
1841: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.ROUTING_SEQUENCE_ID));
1842: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1843:
1844: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1845: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_SEQ_NUM');
1846: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.OPERATION_SEQ_NUM));
1843:
1844: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1845: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_SEQ_NUM');
1846: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.OPERATION_SEQ_NUM));
1847: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1848:
1849: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1850: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_SEQUENCE_ID');
1851: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.OPERATION_SEQUENCE_ID));
1848:
1849: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1850: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_SEQUENCE_ID');
1851: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.OPERATION_SEQUENCE_ID));
1852: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1853:
1854: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1855: END IF;
1856: END;
1850: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_SEQUENCE_ID');
1851: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.OPERATION_SEQUENCE_ID));
1852: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1853:
1854: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1855: END IF;
1856: END;
1857:
1858: END LOOP;
1861: COMMIT;
1862:
1863: BEGIN
1864:
1865: 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
1866:
1867: lv_tbl:= 'ROUTING_OPERATIONS_'||MSC_CL_COLLECTION.v_instance_code;
1868:
1869: lv_sql_stmt:=
1870: 'INSERT INTO '||lv_tbl
1871: ||' SELECT * from MSC_ROUTING_OPERATIONS'
1872: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
1873: ||' AND plan_id = -1 '
1874: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
1875:
1876: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '||lv_sql_stmt);
1877: EXECUTE IMMEDIATE lv_sql_stmt;
1878:
1872: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
1873: ||' AND plan_id = -1 '
1874: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
1875:
1876: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '||lv_sql_stmt);
1877: EXECUTE IMMEDIATE lv_sql_stmt;
1878:
1879: COMMIT;
1880:
1879: COMMIT;
1880:
1881: END IF;
1882:
1883: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1884: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
1885: lv_retcode,
1886: 'MSC_ROUTING_OPERATIONS',
1887: MSC_CL_COLLECTION.v_instance_code,
1884: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
1885: lv_retcode,
1886: 'MSC_ROUTING_OPERATIONS',
1887: MSC_CL_COLLECTION.v_instance_code,
1888: MSC_UTIL.G_WARNING
1889: );
1890:
1891: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1892: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
1887: MSC_CL_COLLECTION.v_instance_code,
1888: MSC_UTIL.G_WARNING
1889: );
1890:
1891: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1892: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
1893: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
1894: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
1895: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1888: MSC_UTIL.G_WARNING
1889: );
1890:
1891: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1892: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
1893: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
1894: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
1895: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1896: END IF;
1890:
1891: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1892: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
1893: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
1894: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
1895: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1896: END IF;
1897:
1898: END IF;
1891: IF lv_retcode = MSC_UTIL.G_ERROR THEN
1892: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
1893: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
1894: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
1895: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1896: END IF;
1897:
1898: END IF;
1899:
1899:
1900: EXCEPTION
1901: WHEN OTHERS THEN
1902:
1903: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1904: RAISE;
1905: END;
1906:
1907:
1933: msor.orig_resource_seq_num,
1934: msor.BREAKABLE_ACTIVITY_FLAG /*ds change change end */
1935: FROM MSC_ST_OPERATION_RESOURCES msor
1936: WHERE msor.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1937: AND msor.DELETED_FLAG= MSC_UTIL.SYS_NO;
1938:
1939: CURSOR c6_d IS
1940: SELECT
1941: msor.ROUTING_SEQUENCE_ID,
1945: msor.ALTERNATE_NUMBER,
1946: msor.SR_INSTANCE_ID
1947: FROM MSC_ST_OPERATION_RESOURCES msor
1948: WHERE msor.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1949: AND msor.DELETED_FLAG= MSC_UTIL.SYS_YES;
1950:
1951: CURSOR c6_corrupt_data IS
1952: SELECT
1953: msor.ROUTING_SEQUENCE_ID,
1954: msor.RESOURCE_ID,
1955: msor.RESOURCE_SEQ_NUM
1956: FROM MSC_ST_OPERATION_RESOURCES msor
1957: WHERE msor.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1958: AND msor.DELETED_FLAG= MSC_UTIL.SYS_NO
1959: AND nvl(msor.RESOURCE_SEQ_NUM,0)=0
1960: AND msor.ALTERNATE_NUMBER > 0;
1961:
1962: c_count NUMBER:= 0;
1971: lv_delete_flag BOOLEAN:= FALSE;
1972:
1973: BEGIN
1974:
1975: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
1976: lv_tbl:= 'OPERATION_RESOURCES_'||MSC_CL_COLLECTION.v_instance_code;
1977: ELSE
1978: lv_tbl:= 'MSC_OPERATION_RESOURCES';
1979: END IF;
1982:
1983: -- We want to delete all BOM related data and get new stuff.
1984: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_RESOURCES', MSC_CL_COLLECTION.v_instance_id, -1);
1985:
1986: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_NO THEN
1987: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1988: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_RESOURCES', MSC_CL_COLLECTION.v_instance_id, -1);
1989: ELSE
1990: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1983: -- We want to delete all BOM related data and get new stuff.
1984: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_RESOURCES', MSC_CL_COLLECTION.v_instance_id, -1);
1985:
1986: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_NO THEN
1987: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1988: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_RESOURCES', MSC_CL_COLLECTION.v_instance_id, -1);
1989: ELSE
1990: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1991: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_RESOURCES', MSC_CL_COLLECTION.v_instance_id, -1,v_sub_str);
1986: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_NO THEN
1987: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1988: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_RESOURCES', MSC_CL_COLLECTION.v_instance_id, -1);
1989: ELSE
1990: v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1991: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_OPERATION_RESOURCES', MSC_CL_COLLECTION.v_instance_id, -1,v_sub_str);
1992: END IF;
1993: END IF;
1994:
2047: ||' :v_current_date, '
2048: ||' :v_current_user '
2049: ||' FROM MSC_ST_OPERATION_RESOURCES msor'
2050: ||' WHERE msor.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
2051: ||' AND msor.DELETED_FLAG= '||MSC_UTIL.SYS_NO
2052: ||' AND NOT(nvl(msor.RESOURCE_SEQ_NUM,0)=0 AND msor.ALTERNATE_NUMBER > 0)';
2053:
2054: EXECUTE IMMEDIATE lv_sql_ins
2055: 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;
2054: EXECUTE IMMEDIATE lv_sql_ins
2055: 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;
2056:
2057: COMMIT;
2058: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'operation resources loaded');
2059:
2060: FOR c_rec IN c6_corrupt_data LOOP
2061:
2062: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2058: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'operation resources loaded');
2059:
2060: FOR c_rec IN c6_corrupt_data LOOP
2061:
2062: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2063:
2064: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2065:
2066: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2060: FOR c_rec IN c6_corrupt_data LOOP
2061:
2062: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2063:
2064: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2065:
2066: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2067: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2068: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2065:
2066: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2067: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2068: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2069: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2070:
2071: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2072: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_SEQ_NUM');
2073: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR(c_rec.RESOURCE_SEQ_NUM));
2070:
2071: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2072: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_SEQ_NUM');
2073: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR(c_rec.RESOURCE_SEQ_NUM));
2074: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2075:
2076: FND_MESSAGE.SET_NAME('MSC','MSC_INVALID_RES_SEQ_NUM');
2077: FND_MESSAGE.SET_TOKEN('ROUTING_SEQUENCE_ID', TO_CHAR(c_rec.ROUTING_SEQUENCE_ID));
2078: FND_MESSAGE.SET_TOKEN('RESOURCE_ID', TO_CHAR(c_rec.RESOURCE_ID));
2075:
2076: FND_MESSAGE.SET_NAME('MSC','MSC_INVALID_RES_SEQ_NUM');
2077: FND_MESSAGE.SET_TOKEN('ROUTING_SEQUENCE_ID', TO_CHAR(c_rec.ROUTING_SEQUENCE_ID));
2078: FND_MESSAGE.SET_TOKEN('RESOURCE_ID', TO_CHAR(c_rec.RESOURCE_ID));
2079: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2080:
2081: END LOOP;
2082:
2083: EXCEPTION
2083: EXCEPTION
2084: WHEN OTHERS THEN
2085: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
2086:
2087: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2088: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2089: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2090: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2091: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2087: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2088: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2089: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2090: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2091: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2092:
2093: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2094: RAISE;
2095:
2089: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2090: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2091: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2092:
2093: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2094: RAISE;
2095:
2096: ELSE
2097: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2093: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2094: RAISE;
2095:
2096: ELSE
2097: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2098: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2099: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2100: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2101: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2097: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2098: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2099: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2100: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2101: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2102:
2103: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2104:
2105: --If Direct path load results in warning then the processing has to be
2099: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2100: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2101: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2102:
2103: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2104:
2105: --If Direct path load results in warning then the processing has to be
2106: --switched back to row by row processing. This will help to identify the
2107: --erroneous record and will also help in processing the rest of the records.
2104:
2105: --If Direct path load results in warning then the processing has to be
2106: --switched back to row by row processing. This will help to identify the
2107: --erroneous record and will also help in processing the rest of the records.
2108: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'bulk insert failed - operation resources');
2109: lb_refresh_failed := TRUE;
2110: END IF;
2111:
2112: END;
2213: EXECUTE IMMEDIATE lv_sql_stmt1 USING MSC_CL_COLLECTION.v_last_collection_id, MSC_CL_COLLECTION.v_current_date, MSC_CL_COLLECTION.v_current_user, c_rec.SR_INSTANCE_ID ;
2214: end if;
2215: EXCEPTION
2216: WHEN OTHERS THEN
2217: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '------------------------------');
2218: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'SQL Executed: ' || lv_sql_stmt1);
2219: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Routing Sequence Id: ' || c_rec.ROUTING_SEQUENCE_ID);
2220: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Operation Sequence Id: ' || c_rec.OPERATION_SEQUENCE_ID );
2221: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Seq Num: ' || c_rec.RESOURCE_SEQ_NUM);
2214: end if;
2215: EXCEPTION
2216: WHEN OTHERS THEN
2217: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '------------------------------');
2218: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'SQL Executed: ' || lv_sql_stmt1);
2219: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Routing Sequence Id: ' || c_rec.ROUTING_SEQUENCE_ID);
2220: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Operation Sequence Id: ' || c_rec.OPERATION_SEQUENCE_ID );
2221: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Seq Num: ' || c_rec.RESOURCE_SEQ_NUM);
2222: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Id: ' || c_rec.RESOURCE_ID);
2215: EXCEPTION
2216: WHEN OTHERS THEN
2217: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '------------------------------');
2218: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'SQL Executed: ' || lv_sql_stmt1);
2219: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Routing Sequence Id: ' || c_rec.ROUTING_SEQUENCE_ID);
2220: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Operation Sequence Id: ' || c_rec.OPERATION_SEQUENCE_ID );
2221: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Seq Num: ' || c_rec.RESOURCE_SEQ_NUM);
2222: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Id: ' || c_rec.RESOURCE_ID);
2223: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Alternate Number: ' || c_rec.ALTERNATE_NUMBER);
2216: WHEN OTHERS THEN
2217: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '------------------------------');
2218: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'SQL Executed: ' || lv_sql_stmt1);
2219: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Routing Sequence Id: ' || c_rec.ROUTING_SEQUENCE_ID);
2220: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Operation Sequence Id: ' || c_rec.OPERATION_SEQUENCE_ID );
2221: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Seq Num: ' || c_rec.RESOURCE_SEQ_NUM);
2222: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Id: ' || c_rec.RESOURCE_ID);
2223: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Alternate Number: ' || c_rec.ALTERNATE_NUMBER);
2224: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '------------------------------');
2217: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '------------------------------');
2218: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'SQL Executed: ' || lv_sql_stmt1);
2219: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Routing Sequence Id: ' || c_rec.ROUTING_SEQUENCE_ID);
2220: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Operation Sequence Id: ' || c_rec.OPERATION_SEQUENCE_ID );
2221: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Seq Num: ' || c_rec.RESOURCE_SEQ_NUM);
2222: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Id: ' || c_rec.RESOURCE_ID);
2223: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Alternate Number: ' || c_rec.ALTERNATE_NUMBER);
2224: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '------------------------------');
2225: END;
2218: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'SQL Executed: ' || lv_sql_stmt1);
2219: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Routing Sequence Id: ' || c_rec.ROUTING_SEQUENCE_ID);
2220: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Operation Sequence Id: ' || c_rec.OPERATION_SEQUENCE_ID );
2221: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Seq Num: ' || c_rec.RESOURCE_SEQ_NUM);
2222: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Id: ' || c_rec.RESOURCE_ID);
2223: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Alternate Number: ' || c_rec.ALTERNATE_NUMBER);
2224: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '------------------------------');
2225: END;
2226:
2219: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Routing Sequence Id: ' || c_rec.ROUTING_SEQUENCE_ID);
2220: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Operation Sequence Id: ' || c_rec.OPERATION_SEQUENCE_ID );
2221: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Seq Num: ' || c_rec.RESOURCE_SEQ_NUM);
2222: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Id: ' || c_rec.RESOURCE_ID);
2223: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Alternate Number: ' || c_rec.ALTERNATE_NUMBER);
2224: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '------------------------------');
2225: END;
2226:
2227: /*
2220: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Operation Sequence Id: ' || c_rec.OPERATION_SEQUENCE_ID );
2221: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Seq Num: ' || c_rec.RESOURCE_SEQ_NUM);
2222: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Resource Id: ' || c_rec.RESOURCE_ID);
2223: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Alternate Number: ' || c_rec.ALTERNATE_NUMBER);
2224: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '------------------------------');
2225: END;
2226:
2227: /*
2228: UPDATE MSC_OPERATION_RESOURCES
2284: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
2285: /* Start changes for 3586386*/
2286: IF nvl(c_rec.RESOURCE_SEQ_NUM,0)=0 AND c_rec.ALTERNATE_NUMBER > 0 THEN
2287:
2288: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2289:
2290: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2291:
2292: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2286: IF nvl(c_rec.RESOURCE_SEQ_NUM,0)=0 AND c_rec.ALTERNATE_NUMBER > 0 THEN
2287:
2288: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2289:
2290: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2291:
2292: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2293: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2294: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2291:
2292: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2293: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2294: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2295: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2296:
2297: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2298: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_SEQ_NUM');
2299: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR(c_rec.RESOURCE_SEQ_NUM));
2296:
2297: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2298: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_SEQ_NUM');
2299: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR(c_rec.RESOURCE_SEQ_NUM));
2300: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2301:
2302: FND_MESSAGE.SET_NAME('MSC','MSC_INVALID_RES_SEQ_NUM');
2303: FND_MESSAGE.SET_TOKEN('ROUTING_SEQUENCE_ID', TO_CHAR(c_rec.ROUTING_SEQUENCE_ID));
2304: FND_MESSAGE.SET_TOKEN('RESOURCE_ID', TO_CHAR(c_rec.RESOURCE_ID));
2301:
2302: FND_MESSAGE.SET_NAME('MSC','MSC_INVALID_RES_SEQ_NUM');
2303: FND_MESSAGE.SET_TOKEN('ROUTING_SEQUENCE_ID', TO_CHAR(c_rec.ROUTING_SEQUENCE_ID));
2304: FND_MESSAGE.SET_TOKEN('RESOURCE_ID', TO_CHAR(c_rec.RESOURCE_ID));
2305: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2306:
2307: /* End changes for 3586386*/
2308: ELSE
2309: EXECUTE IMMEDIATE lv_sql_stmt USING
2346: WHEN OTHERS THEN
2347:
2348: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
2349:
2350: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2351: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2352: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2353: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2354: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2350: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2351: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2352: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2353: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2354: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2355:
2356: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2357: RAISE;
2358:
2352: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2353: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2354: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2355:
2356: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2357: RAISE;
2358:
2359: ELSE
2360: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2356: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2357: RAISE;
2358:
2359: ELSE
2360: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2361:
2362: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2363: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2364: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2358:
2359: ELSE
2360: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2361:
2362: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2363: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2364: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2365: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2366: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2362: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2363: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2364: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_OPERATION_RESOURCES');
2365: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_OPERATION_RESOURCES');
2366: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2367:
2368: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2369: FND_MESSAGE.SET_TOKEN('COLUMN', 'ROUTING_SEQUENCE_ID');
2370: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.ROUTING_SEQUENCE_ID));
2367:
2368: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2369: FND_MESSAGE.SET_TOKEN('COLUMN', 'ROUTING_SEQUENCE_ID');
2370: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.ROUTING_SEQUENCE_ID));
2371: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2372:
2373: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2374: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_SEQUENCE_ID');
2375: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.OPERATION_SEQUENCE_ID));
2372:
2373: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2374: FND_MESSAGE.SET_TOKEN('COLUMN', 'OPERATION_SEQUENCE_ID');
2375: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.OPERATION_SEQUENCE_ID));
2376: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2377:
2378: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2379: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_SEQ_NUM');
2380: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.RESOURCE_SEQ_NUM));
2377:
2378: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2379: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_SEQ_NUM');
2380: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.RESOURCE_SEQ_NUM));
2381: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2382:
2383: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2384: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_ID');
2385: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.RESOURCE_ID));
2382:
2383: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2384: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_ID');
2385: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.RESOURCE_ID));
2386: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2387:
2388: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2389: END IF;
2390: END;
2384: FND_MESSAGE.SET_TOKEN('COLUMN', 'RESOURCE_ID');
2385: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR( c_rec.RESOURCE_ID));
2386: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2387:
2388: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2389: END IF;
2390: END;
2391:
2392: END LOOP;
2395: COMMIT;
2396:
2397: BEGIN
2398:
2399: 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
2400:
2401: lv_tbl:= 'OPERATION_RESOURCES_'||MSC_CL_COLLECTION.v_instance_code;
2402:
2403: lv_sql_stmt:=
2404: 'INSERT INTO '||lv_tbl
2405: ||' SELECT * from MSC_OPERATION_RESOURCES'
2406: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
2407: ||' AND plan_id = -1 '
2408: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
2409:
2410: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '||lv_sql_stmt);
2411: EXECUTE IMMEDIATE lv_sql_stmt;
2412:
2406: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
2407: ||' AND plan_id = -1 '
2408: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
2409:
2410: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '||lv_sql_stmt);
2411: EXECUTE IMMEDIATE lv_sql_stmt;
2412:
2413: COMMIT;
2414:
2413: COMMIT;
2414:
2415: END IF;
2416:
2417: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
2418: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
2419: lv_retcode,
2420: 'MSC_OPERATION_RESOURCES',
2421: MSC_CL_COLLECTION.v_instance_code,
2418: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
2419: lv_retcode,
2420: 'MSC_OPERATION_RESOURCES',
2421: MSC_CL_COLLECTION.v_instance_code,
2422: MSC_UTIL.G_WARNING
2423: );
2424:
2425: IF lv_retcode = MSC_UTIL.G_ERROR THEN
2426: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
2421: MSC_CL_COLLECTION.v_instance_code,
2422: MSC_UTIL.G_WARNING
2423: );
2424:
2425: IF lv_retcode = MSC_UTIL.G_ERROR THEN
2426: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
2427: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
2428: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
2429: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2422: MSC_UTIL.G_WARNING
2423: );
2424:
2425: IF lv_retcode = MSC_UTIL.G_ERROR THEN
2426: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
2427: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
2428: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
2429: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2430: END IF;
2424:
2425: IF lv_retcode = MSC_UTIL.G_ERROR THEN
2426: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
2427: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
2428: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
2429: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2430: END IF;
2431:
2432: END IF;
2425: IF lv_retcode = MSC_UTIL.G_ERROR THEN
2426: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
2427: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
2428: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
2429: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2430: END IF;
2431:
2432: END IF;
2433:
2433:
2434: EXCEPTION
2435: WHEN OTHERS THEN
2436:
2437: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2438: RAISE;
2439: END;
2440:
2441: END LOAD_OPERATION_RESOURCES;