19: FROM MSC_ITEM_ID_LID t1,
20: MSC_ST_SAFETY_STOCKS msss
21: WHERE t1.SR_INVENTORY_ITEM_ID= msss.inventory_item_id
22: AND t1.sr_instance_id= msss.sr_instance_id
23: AND msss.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
24:
25: c_count NUMBER:= 0;
26: lv_ITEM_TYPE_VALUE NUMBER;
27: lv_ITEM_TYPE_ID NUMBER;
26: lv_ITEM_TYPE_VALUE NUMBER;
27: lv_ITEM_TYPE_ID NUMBER;
28: BEGIN
29:
30: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
31:
32: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SAFETY_STOCKS', MSC_CL_COLLECTION.v_instance_id, -1);
33:
34: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
28: BEGIN
29:
30: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
31:
32: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SAFETY_STOCKS', MSC_CL_COLLECTION.v_instance_id, -1);
33:
34: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
35: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SAFETY_STOCKS', MSC_CL_COLLECTION.v_instance_id, -1);
36: ELSE
30: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
31:
32: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SAFETY_STOCKS', MSC_CL_COLLECTION.v_instance_id, -1);
33:
34: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
35: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SAFETY_STOCKS', MSC_CL_COLLECTION.v_instance_id, -1);
36: ELSE
37: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
38: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SAFETY_STOCKS', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
31:
32: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SAFETY_STOCKS', MSC_CL_COLLECTION.v_instance_id, -1);
33:
34: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
35: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SAFETY_STOCKS', MSC_CL_COLLECTION.v_instance_id, -1);
36: ELSE
37: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
38: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SAFETY_STOCKS', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
39: END IF;
33:
34: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
35: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SAFETY_STOCKS', MSC_CL_COLLECTION.v_instance_id, -1);
36: ELSE
37: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
38: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SAFETY_STOCKS', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
39: END IF;
40:
41: END IF;
34: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
35: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SAFETY_STOCKS', MSC_CL_COLLECTION.v_instance_id, -1);
36: ELSE
37: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
38: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SAFETY_STOCKS', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
39: END IF;
40:
41: END IF;
42: -- SRP enhancement
52: FOR c_rec IN c1 LOOP
53:
54: BEGIN
55:
56: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
57:
58: UPDATE MSC_SAFETY_STOCKS
59: SET
60: SAFETY_STOCK_QUANTITY= c_rec.SAFETY_STOCK_QUANTITY,
59: SET
60: SAFETY_STOCK_QUANTITY= c_rec.SAFETY_STOCK_QUANTITY,
61: UPDATED= c_rec.UPDATED,
62: STATUS= c_rec.STATUS,
63: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
64: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
65: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
66: ITEM_TYPE_ID = lv_ITEM_TYPE_ID ,
67: ITEM_TYPE_VALUE = lv_ITEM_TYPE_VALUE
60: SAFETY_STOCK_QUANTITY= c_rec.SAFETY_STOCK_QUANTITY,
61: UPDATED= c_rec.UPDATED,
62: STATUS= c_rec.STATUS,
63: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
64: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
65: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
66: ITEM_TYPE_ID = lv_ITEM_TYPE_ID ,
67: ITEM_TYPE_VALUE = lv_ITEM_TYPE_VALUE
68: WHERE PLAN_ID= -1
61: UPDATED= c_rec.UPDATED,
62: STATUS= c_rec.STATUS,
63: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
64: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
65: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
66: ITEM_TYPE_ID = lv_ITEM_TYPE_ID ,
67: ITEM_TYPE_VALUE = lv_ITEM_TYPE_VALUE
68: WHERE PLAN_ID= -1
69: AND ORGANIZATION_ID= c_rec.ORGANIZATION_ID
72: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
73:
74: END IF;
75:
76: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
77:
78: INSERT INTO MSC_SAFETY_STOCKS
79: ( PLAN_ID,
80: ORGANIZATION_ID,
105: c_rec.PROJECT_ID,
106: c_rec.TASK_ID,
107: c_rec.PLANNING_GROUP,
108: c_rec.SR_INSTANCE_ID,
109: MSC_CL_COLLECTION.v_last_collection_id,
110: MSC_CL_COLLECTION.v_current_date,
111: MSC_CL_COLLECTION.v_current_user,
112: MSC_CL_COLLECTION.v_current_date,
113: MSC_CL_COLLECTION.v_current_user,
106: c_rec.TASK_ID,
107: c_rec.PLANNING_GROUP,
108: c_rec.SR_INSTANCE_ID,
109: MSC_CL_COLLECTION.v_last_collection_id,
110: MSC_CL_COLLECTION.v_current_date,
111: MSC_CL_COLLECTION.v_current_user,
112: MSC_CL_COLLECTION.v_current_date,
113: MSC_CL_COLLECTION.v_current_user,
114: lv_ITEM_TYPE_ID,
107: c_rec.PLANNING_GROUP,
108: c_rec.SR_INSTANCE_ID,
109: MSC_CL_COLLECTION.v_last_collection_id,
110: MSC_CL_COLLECTION.v_current_date,
111: MSC_CL_COLLECTION.v_current_user,
112: MSC_CL_COLLECTION.v_current_date,
113: MSC_CL_COLLECTION.v_current_user,
114: lv_ITEM_TYPE_ID,
115: lv_ITEM_TYPE_VALUE
108: c_rec.SR_INSTANCE_ID,
109: MSC_CL_COLLECTION.v_last_collection_id,
110: MSC_CL_COLLECTION.v_current_date,
111: MSC_CL_COLLECTION.v_current_user,
112: MSC_CL_COLLECTION.v_current_date,
113: MSC_CL_COLLECTION.v_current_user,
114: lv_ITEM_TYPE_ID,
115: lv_ITEM_TYPE_VALUE
116: );
109: MSC_CL_COLLECTION.v_last_collection_id,
110: MSC_CL_COLLECTION.v_current_date,
111: MSC_CL_COLLECTION.v_current_user,
112: MSC_CL_COLLECTION.v_current_date,
113: MSC_CL_COLLECTION.v_current_user,
114: lv_ITEM_TYPE_ID,
115: lv_ITEM_TYPE_VALUE
116: );
117:
118: END IF;
119:
120: c_count:= c_count+1;
121:
122: IF c_count> MSC_CL_COLLECTION.PBS THEN
123: COMMIT;
124: c_count:= 0;
125: END IF;
126:
138: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
139: RAISE;
140:
141: ELSE
142: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
143:
144: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
145: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
146: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SAFETY_STOCK');
155: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
156: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
157: FND_MESSAGE.SET_TOKEN('VALUE',
158: MSC_GET_NAME.ORG_CODE( c_rec.ORGANIZATION_ID,
159: MSC_CL_COLLECTION.v_instance_id));
160: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
161:
162: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
163: FND_MESSAGE.SET_TOKEN('COLUMN', 'PERIOD_START_DATE');
197: msas.DESCRIPTION,
198: msas.ASSIGNMENT_SET_NAME,
199: msas.SR_INSTANCE_ID
200: FROM MSC_ST_ASSIGNMENT_SETS msas
201: WHERE msas.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
202:
203: CURSOR c2 IS
204: SELECT
205: mssr.ORGANIZATION_ID,
210: mssr.SOURCING_RULE_TYPE,
211: mssr.PLANNING_ACTIVE,
212: mssr.SR_INSTANCE_ID
213: FROM MSC_ST_SOURCING_RULES mssr
214: WHERE mssr.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
215:
216: CURSOR c3 IS
217: SELECT
218: mssa.SR_ASSIGNMENT_ID,
248: AND miil.SR_INSTANCE_ID(+)= mssa.SR_ASSIGNMENT_INSTANCE_ID
249: AND mtil.SR_TP_ID(+)= mssa.PARTNER_ID -- TP
250: AND mtil.SR_INSTANCE_ID(+)= mssa.SR_ASSIGNMENT_INSTANCE_ID
251: AND mtil.Partner_Type(+)= 2
252: AND mssa.SR_ASSIGNMENT_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
253: AND
254: (
255: EXISTS
256: (
285: FROM MSC_Sourcing_Rules msr,
286: MSC_ST_SR_RECEIPT_ORG mssro
287: WHERE msr.SR_SOURCING_RULE_ID= mssro.SOURCING_RULE_ID
288: AND msr.SR_INSTANCE_ID= mssro.SR_INSTANCE_ID
289: AND mssro.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
290:
291:
292: CURSOR c5 IS
293: SELECT
313: AND mtil.Partner_Type(+)= 1
314: AND mtsil.SR_TP_SITE_ID(+)= mssso.SOURCE_PARTNER_SITE_ID
315: AND mtsil.SR_INSTANCE_ID(+)= mssso.SR_Instance_ID
316: AND mtsil.Partner_Type(+)= 1
317: AND mssso.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
318:
319: CURSOR c6 IS
320: SELECT
321: NVL(msism.FROM_ORGANIZATION_ID,-1) FROM_ORGANIZATION_ID,
344: msism.SHIPMENT_WEIGHT_UOM,
345: msism.SHIPMENT_VOLUME_UOM,
346: msism.LEADTIME_VARIABILITY
347: FROM MSC_ST_INTERORG_SHIP_METHODS msism
348: WHERE msism.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
349: /* Changed Refresh_id to Refresh_Number */
350: CURSOR c7 IS
351: SELECT msr.REGION_ID,
352: msr.REGION_TYPE,
381: msr.SR_INSTANCE_ID,
382: msr.REFRESH_NUMBER,
383: msr.ZONE_USAGE
384: FROM MSC_ST_REGIONS msr
385: WHERE msr.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
386:
387: /* Changed Refresh_id to Refresh_number */
388: CURSOR c8 IS
389: SELECT mszr.ZONE_REGION_ID,
397: mszr.LAST_UPDATE_LOGIN,
398: mszr.SR_INSTANCE_ID,
399: mszr.REFRESH_NUMBER
400: FROM MSC_ST_ZONE_REGIONS mszr
401: WHERE mszr.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
402: /* Changed Refresh_id to Refresh_number */
403: CURSOR c9 IS
404: SELECT
405: msrl.REGION_ID,
415: msrl.LAST_UPDATE_LOGIN,
416: msrl.SR_INSTANCE_ID,
417: msrl.REFRESH_NUMBER
418: FROM MSC_ST_REGION_LOCATIONS msrl
419: WHERE msrl.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
420:
421: CURSOR c10 IS
422: SELECT DISTINCT
423: msrs.REGION_ID,
427: msrs.SR_INSTANCE_ID,
428: msrs.REFRESH_ID
429: FROM MSC_ST_REGION_SITES msrs,
430: MSC_TP_SITE_ID_LID mtsil
431: WHERE msrs.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
432: AND mtsil.SR_TP_SITE_ID = msrs.VENDOR_SITE_ID
433: AND mtsil.SR_Instance_ID = msrs.SR_INSTANCE_ID
434: AND mtsil.Partner_Type = 1;
435:
442: mscs.SR_INSTANCE_ID,
443: mscs.REFRESH_ID
444: FROM MSC_ST_CARRIER_SERVICES mscs,
445: MSC_TP_ID_LID mtil
446: WHERE mscs.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
447: AND mtil.SR_TP_ID = mscs.CARRIER_ID
448: AND mtil.SR_Instance_ID = mscs.SR_INSTANCE_ID
449: AND mtil.Partner_Type = 4;
450:
478: lv_crt_ind_status NUMBER;
479: BEGIN
480:
481: --/* it's removed due to bug 1219661
482: IF ((MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh)
483: AND MSC_CL_COLLECTION.v_sourcing_flag=MSC_UTIL.SYS_YES ) THEN
484:
485: UPDATE MSC_ASSIGNMENT_SETS
486: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
479: BEGIN
480:
481: --/* it's removed due to bug 1219661
482: IF ((MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh)
483: AND MSC_CL_COLLECTION.v_sourcing_flag=MSC_UTIL.SYS_YES ) THEN
484:
485: UPDATE MSC_ASSIGNMENT_SETS
486: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
487: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
483: AND MSC_CL_COLLECTION.v_sourcing_flag=MSC_UTIL.SYS_YES ) THEN
484:
485: UPDATE MSC_ASSIGNMENT_SETS
486: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
487: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
488: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
489: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
490: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
491:
484:
485: UPDATE MSC_ASSIGNMENT_SETS
486: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
487: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
488: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
489: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
490: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
491:
492: END IF;
485: UPDATE MSC_ASSIGNMENT_SETS
486: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
487: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
488: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
489: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
490: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
491:
492: END IF;
493:
503: UPDATE MSC_ASSIGNMENT_SETS mas
504: SET mas.ASSIGNMENT_SET_NAME=c_rec.ASSIGNMENT_SET_NAME,
505: mas.Description= c_rec.Description,
506: mas.Deleted_Flag= MSC_UTIL.SYS_NO,
507: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
508: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
509: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
510: WHERE mas.SR_Assignment_Set_Id= c_rec.SR_Assignment_Set_Id
511: AND mas.SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
504: SET mas.ASSIGNMENT_SET_NAME=c_rec.ASSIGNMENT_SET_NAME,
505: mas.Description= c_rec.Description,
506: mas.Deleted_Flag= MSC_UTIL.SYS_NO,
507: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
508: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
509: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
510: WHERE mas.SR_Assignment_Set_Id= c_rec.SR_Assignment_Set_Id
511: AND mas.SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
512: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
505: mas.Description= c_rec.Description,
506: mas.Deleted_Flag= MSC_UTIL.SYS_NO,
507: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
508: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
509: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
510: WHERE mas.SR_Assignment_Set_Id= c_rec.SR_Assignment_Set_Id
511: AND mas.SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
512: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
513:
533: c_rec.ASSIGNMENT_SET_NAME,
534: MSC_UTIL.SYS_YES,
535: c_rec.SR_INSTANCE_ID,
536: MSC_UTIL.SYS_NO,
537: MSC_CL_COLLECTION.v_last_collection_id,
538: MSC_CL_COLLECTION.v_current_date,
539: MSC_CL_COLLECTION.v_current_user,
540: MSC_CL_COLLECTION.v_current_date,
541: MSC_CL_COLLECTION.v_current_user);
534: MSC_UTIL.SYS_YES,
535: c_rec.SR_INSTANCE_ID,
536: MSC_UTIL.SYS_NO,
537: MSC_CL_COLLECTION.v_last_collection_id,
538: MSC_CL_COLLECTION.v_current_date,
539: MSC_CL_COLLECTION.v_current_user,
540: MSC_CL_COLLECTION.v_current_date,
541: MSC_CL_COLLECTION.v_current_user);
542:
535: c_rec.SR_INSTANCE_ID,
536: MSC_UTIL.SYS_NO,
537: MSC_CL_COLLECTION.v_last_collection_id,
538: MSC_CL_COLLECTION.v_current_date,
539: MSC_CL_COLLECTION.v_current_user,
540: MSC_CL_COLLECTION.v_current_date,
541: MSC_CL_COLLECTION.v_current_user);
542:
543: END IF;
536: MSC_UTIL.SYS_NO,
537: MSC_CL_COLLECTION.v_last_collection_id,
538: MSC_CL_COLLECTION.v_current_date,
539: MSC_CL_COLLECTION.v_current_user,
540: MSC_CL_COLLECTION.v_current_date,
541: MSC_CL_COLLECTION.v_current_user);
542:
543: END IF;
544:
537: MSC_CL_COLLECTION.v_last_collection_id,
538: MSC_CL_COLLECTION.v_current_date,
539: MSC_CL_COLLECTION.v_current_user,
540: MSC_CL_COLLECTION.v_current_date,
541: MSC_CL_COLLECTION.v_current_user);
542:
543: END IF;
544:
545: c_count:= c_count+1;
543: END IF;
544:
545: c_count:= c_count+1;
546:
547: IF c_count> MSC_CL_COLLECTION.PBS THEN
548: COMMIT;
549: c_count:= 0;
550: END IF;
551:
564: RAISE;
565:
566: ELSE
567:
568: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
569:
570: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
571: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
572: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SOURCING');
594:
595: --/* it's removed due to bug 1219661
596: DELETE MSC_ASSIGNMENT_SETS
597: WHERE DELETED_FLAG= MSC_UTIL.SYS_YES
598: AND SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
599: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
600:
601: COMMIT;
602: --*/
600:
601: COMMIT;
602: --*/
603:
604: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
605:
606: msc_analyse_tables_pk.analyse_table( 'MSC_ASSIGNMENT_SETS');
607:
608: END IF;
607:
608: END IF;
609:
610: --/* it's removed due to bug 1219661
611: IF ((MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh)
612: AND MSC_CL_COLLECTION.v_sourcing_flag =MSC_UTIL.SYS_YES) THEN
613:
614: UPDATE MSC_SOURCING_RULES
615: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
608: END IF;
609:
610: --/* it's removed due to bug 1219661
611: IF ((MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh)
612: AND MSC_CL_COLLECTION.v_sourcing_flag =MSC_UTIL.SYS_YES) THEN
613:
614: UPDATE MSC_SOURCING_RULES
615: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
616: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
612: AND MSC_CL_COLLECTION.v_sourcing_flag =MSC_UTIL.SYS_YES) THEN
613:
614: UPDATE MSC_SOURCING_RULES
615: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
616: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
617: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
618: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
619: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
620:
613:
614: UPDATE MSC_SOURCING_RULES
615: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
616: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
617: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
618: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
619: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
620:
621: END IF;
614: UPDATE MSC_SOURCING_RULES
615: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
616: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
617: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
618: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
619: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
620:
621: END IF;
622:
635: msr.Sourcing_Rule_Type= c_rec.Sourcing_Rule_Type,
636: msr.sourcing_rule_name= c_rec.sourcing_rule_name,
637: msr.Planning_Active= c_rec.Planning_Active,
638: msr.Deleted_Flag= MSC_UTIL.SYS_NO,
639: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
640: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
641: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
642: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
643: CREATED_BY= MSC_CL_COLLECTION.v_current_user
636: msr.sourcing_rule_name= c_rec.sourcing_rule_name,
637: msr.Planning_Active= c_rec.Planning_Active,
638: msr.Deleted_Flag= MSC_UTIL.SYS_NO,
639: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
640: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
641: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
642: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
643: CREATED_BY= MSC_CL_COLLECTION.v_current_user
644: WHERE msr.SR_Sourcing_Rule_ID= c_rec.SR_Sourcing_Rule_ID
637: msr.Planning_Active= c_rec.Planning_Active,
638: msr.Deleted_Flag= MSC_UTIL.SYS_NO,
639: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
640: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
641: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
642: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
643: CREATED_BY= MSC_CL_COLLECTION.v_current_user
644: WHERE msr.SR_Sourcing_Rule_ID= c_rec.SR_Sourcing_Rule_ID
645: AND msr.SR_Instance_ID= c_rec.SR_Instance_ID
638: msr.Deleted_Flag= MSC_UTIL.SYS_NO,
639: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
640: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
641: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
642: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
643: CREATED_BY= MSC_CL_COLLECTION.v_current_user
644: WHERE msr.SR_Sourcing_Rule_ID= c_rec.SR_Sourcing_Rule_ID
645: AND msr.SR_Instance_ID= c_rec.SR_Instance_ID
646: AND msr.COLLECTED_FLAG= MSC_UTIL.SYS_YES;
639: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
640: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
641: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
642: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
643: CREATED_BY= MSC_CL_COLLECTION.v_current_user
644: WHERE msr.SR_Sourcing_Rule_ID= c_rec.SR_Sourcing_Rule_ID
645: AND msr.SR_Instance_ID= c_rec.SR_Instance_ID
646: AND msr.COLLECTED_FLAG= MSC_UTIL.SYS_YES;
647:
675: c_rec.PLANNING_ACTIVE,
676: MSC_UTIL.SYS_YES,
677: c_rec.SR_INSTANCE_ID,
678: MSC_UTIL.SYS_NO,
679: MSC_CL_COLLECTION.v_last_collection_id,
680: MSC_CL_COLLECTION.v_current_date,
681: MSC_CL_COLLECTION.v_current_user,
682: MSC_CL_COLLECTION.v_current_date,
683: MSC_CL_COLLECTION.v_current_user);
676: MSC_UTIL.SYS_YES,
677: c_rec.SR_INSTANCE_ID,
678: MSC_UTIL.SYS_NO,
679: MSC_CL_COLLECTION.v_last_collection_id,
680: MSC_CL_COLLECTION.v_current_date,
681: MSC_CL_COLLECTION.v_current_user,
682: MSC_CL_COLLECTION.v_current_date,
683: MSC_CL_COLLECTION.v_current_user);
684:
677: c_rec.SR_INSTANCE_ID,
678: MSC_UTIL.SYS_NO,
679: MSC_CL_COLLECTION.v_last_collection_id,
680: MSC_CL_COLLECTION.v_current_date,
681: MSC_CL_COLLECTION.v_current_user,
682: MSC_CL_COLLECTION.v_current_date,
683: MSC_CL_COLLECTION.v_current_user);
684:
685: END IF;
678: MSC_UTIL.SYS_NO,
679: MSC_CL_COLLECTION.v_last_collection_id,
680: MSC_CL_COLLECTION.v_current_date,
681: MSC_CL_COLLECTION.v_current_user,
682: MSC_CL_COLLECTION.v_current_date,
683: MSC_CL_COLLECTION.v_current_user);
684:
685: END IF;
686:
679: MSC_CL_COLLECTION.v_last_collection_id,
680: MSC_CL_COLLECTION.v_current_date,
681: MSC_CL_COLLECTION.v_current_user,
682: MSC_CL_COLLECTION.v_current_date,
683: MSC_CL_COLLECTION.v_current_user);
684:
685: END IF;
686:
687: c_count:= c_count+1;
685: END IF;
686:
687: c_count:= c_count+1;
688:
689: IF c_count> MSC_CL_COLLECTION.PBS THEN
690: COMMIT;
691: c_count:= 0;
692: END IF;
693:
704: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
705: RAISE;
706:
707: ELSE
708: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
709:
710: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
711: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
712: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SOURCING');
729:
730: --/* it's removed due to bug 1219661
731: DELETE MSC_SOURCING_RULES
732: WHERE DELETED_FLAG= MSC_UTIL.SYS_YES
733: AND SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
734: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
735:
736: COMMIT;
737: --*/
735:
736: COMMIT;
737: --*/
738:
739: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
740:
741: msc_analyse_tables_pk.analyse_table( 'MSC_SOURCING_RULES');
742:
743: END IF;
741: msc_analyse_tables_pk.analyse_table( 'MSC_SOURCING_RULES');
742:
743: END IF;
744:
745: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
746:
747: UPDATE MSC_SR_ASSIGNMENTS
748: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
749: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
745: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
746:
747: UPDATE MSC_SR_ASSIGNMENTS
748: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
749: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
750: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
751: WHERE SR_ASSIGNMENT_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
752: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
753:
746:
747: UPDATE MSC_SR_ASSIGNMENTS
748: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
749: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
750: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
751: WHERE SR_ASSIGNMENT_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
752: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
753:
754: END IF;
747: UPDATE MSC_SR_ASSIGNMENTS
748: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
749: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
750: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
751: WHERE SR_ASSIGNMENT_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
752: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
753:
754: END IF;
755:
816: msa.ORGANIZATION_ID = lb_ORGANIZATION_ID(j),
817: msa.SR_INSTANCE_ID = lb_SR_INSTANCE_ID(j),
818: msa.CATEGORY_NAME = lb_category_name(j),
819: msa.Deleted_Flag= MSC_UTIL.SYS_NO,
820: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
821: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
822: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
823: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
824: CREATED_BY= MSC_CL_COLLECTION.v_current_user
817: msa.SR_INSTANCE_ID = lb_SR_INSTANCE_ID(j),
818: msa.CATEGORY_NAME = lb_category_name(j),
819: msa.Deleted_Flag= MSC_UTIL.SYS_NO,
820: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
821: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
822: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
823: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
824: CREATED_BY= MSC_CL_COLLECTION.v_current_user
825: WHERE msa.SR_Assignment_ID= lb_SR_ASSIGNMENT_ID(j)
818: msa.CATEGORY_NAME = lb_category_name(j),
819: msa.Deleted_Flag= MSC_UTIL.SYS_NO,
820: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
821: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
822: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
823: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
824: CREATED_BY= MSC_CL_COLLECTION.v_current_user
825: WHERE msa.SR_Assignment_ID= lb_SR_ASSIGNMENT_ID(j)
826: AND msa.SR_Assignment_Instance_ID= lb_SR_ASSIGNMENT_INSTANCE_ID(j)
819: msa.Deleted_Flag= MSC_UTIL.SYS_NO,
820: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
821: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
822: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
823: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
824: CREATED_BY= MSC_CL_COLLECTION.v_current_user
825: WHERE msa.SR_Assignment_ID= lb_SR_ASSIGNMENT_ID(j)
826: AND msa.SR_Assignment_Instance_ID= lb_SR_ASSIGNMENT_INSTANCE_ID(j)
827: AND msa.COLLECTED_FLAG= MSC_UTIL.SYS_YES;
820: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
821: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
822: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
823: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
824: CREATED_BY= MSC_CL_COLLECTION.v_current_user
825: WHERE msa.SR_Assignment_ID= lb_SR_ASSIGNMENT_ID(j)
826: AND msa.SR_Assignment_Instance_ID= lb_SR_ASSIGNMENT_INSTANCE_ID(j)
827: AND msa.COLLECTED_FLAG= MSC_UTIL.SYS_YES;
828:
841: RAISE;
842:
843: ELSE
844:
845: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
846:
847: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
848: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
849: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SOURCING');
901: mssa.CATEGORY_NAME,
902: MSC_UTIL.SYS_YES,
903: mssa.SR_ASSIGNMENT_INSTANCE_ID,
904: MSC_UTIL.SYS_NO,
905: MSC_CL_COLLECTION.v_last_collection_id,
906: MSC_CL_COLLECTION.v_current_date,
907: MSC_CL_COLLECTION.v_current_user,
908: MSC_CL_COLLECTION.v_current_date,
909: MSC_CL_COLLECTION.v_current_user
902: MSC_UTIL.SYS_YES,
903: mssa.SR_ASSIGNMENT_INSTANCE_ID,
904: MSC_UTIL.SYS_NO,
905: MSC_CL_COLLECTION.v_last_collection_id,
906: MSC_CL_COLLECTION.v_current_date,
907: MSC_CL_COLLECTION.v_current_user,
908: MSC_CL_COLLECTION.v_current_date,
909: MSC_CL_COLLECTION.v_current_user
910: FROM MSC_ITEM_ID_LID miil,
903: mssa.SR_ASSIGNMENT_INSTANCE_ID,
904: MSC_UTIL.SYS_NO,
905: MSC_CL_COLLECTION.v_last_collection_id,
906: MSC_CL_COLLECTION.v_current_date,
907: MSC_CL_COLLECTION.v_current_user,
908: MSC_CL_COLLECTION.v_current_date,
909: MSC_CL_COLLECTION.v_current_user
910: FROM MSC_ITEM_ID_LID miil,
911: MSC_TP_ID_LID mtil,
904: MSC_UTIL.SYS_NO,
905: MSC_CL_COLLECTION.v_last_collection_id,
906: MSC_CL_COLLECTION.v_current_date,
907: MSC_CL_COLLECTION.v_current_user,
908: MSC_CL_COLLECTION.v_current_date,
909: MSC_CL_COLLECTION.v_current_user
910: FROM MSC_ITEM_ID_LID miil,
911: MSC_TP_ID_LID mtil,
912: MSC_TP_SITE_ID_LID mtsil,
905: MSC_CL_COLLECTION.v_last_collection_id,
906: MSC_CL_COLLECTION.v_current_date,
907: MSC_CL_COLLECTION.v_current_user,
908: MSC_CL_COLLECTION.v_current_date,
909: MSC_CL_COLLECTION.v_current_user
910: FROM MSC_ITEM_ID_LID miil,
911: MSC_TP_ID_LID mtil,
912: MSC_TP_SITE_ID_LID mtsil,
913: MSC_CATEGORY_SET_ID_LID mcsil,
927: AND miil.SR_INSTANCE_ID(+)= mssa.SR_ASSIGNMENT_INSTANCE_ID
928: AND mtil.SR_TP_ID(+)= mssa.PARTNER_ID -- TP
929: AND mtil.SR_INSTANCE_ID(+)= mssa.SR_ASSIGNMENT_INSTANCE_ID
930: AND mtil.Partner_Type(+)= 2
931: AND mssa.SR_ASSIGNMENT_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
932: AND
933: (
934: EXISTS
935: (
970: RAISE;
971:
972: ELSE
973:
974: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
975:
976: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
977: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
978: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SOURCING');
988: COMMIT;
989:
990: DELETE MSC_SR_ASSIGNMENTS
991: WHERE DELETED_FLAG= MSC_UTIL.SYS_YES
992: AND SR_ASSIGNMENT_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
993: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
994:
995: COMMIT;
996:
993: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
994:
995: COMMIT;
996:
997: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
998:
999: msc_analyse_tables_pk.analyse_table( 'MSC_SR_ASSIGNMENTS');
1000:
1001: END IF;
1000:
1001: END IF;
1002:
1003: --/* it's removed due to bug 1219661
1004: IF ((MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh)
1005: AND MSC_CL_COLLECTION.v_sourcing_flag=MSC_UTIL.SYS_YES ) THEN
1006:
1007: UPDATE MSC_SR_RECEIPT_ORG
1008: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
1001: END IF;
1002:
1003: --/* it's removed due to bug 1219661
1004: IF ((MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh)
1005: AND MSC_CL_COLLECTION.v_sourcing_flag=MSC_UTIL.SYS_YES ) THEN
1006:
1007: UPDATE MSC_SR_RECEIPT_ORG
1008: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
1009: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1005: AND MSC_CL_COLLECTION.v_sourcing_flag=MSC_UTIL.SYS_YES ) THEN
1006:
1007: UPDATE MSC_SR_RECEIPT_ORG
1008: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
1009: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1010: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1011: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1012: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
1013:
1006:
1007: UPDATE MSC_SR_RECEIPT_ORG
1008: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
1009: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1010: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1011: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1012: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
1013:
1014: END IF;
1007: UPDATE MSC_SR_RECEIPT_ORG
1008: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
1009: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1010: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1011: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1012: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
1013:
1014: END IF;
1015:
1030: msro.RECEIPT_PARTNER_SITE_ID= c_rec.Receipt_Partner_Site_ID,
1031: msro.EFFECTIVE_DATE= c_rec.Effective_Date,
1032: msro.DISABLE_DATE= c_rec.Disable_Date,
1033: msro.Deleted_Flag= MSC_UTIL.SYS_NO,
1034: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1035: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1036: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1037: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
1038: CREATED_BY= MSC_CL_COLLECTION.v_current_user
1031: msro.EFFECTIVE_DATE= c_rec.Effective_Date,
1032: msro.DISABLE_DATE= c_rec.Disable_Date,
1033: msro.Deleted_Flag= MSC_UTIL.SYS_NO,
1034: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1035: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1036: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1037: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
1038: CREATED_BY= MSC_CL_COLLECTION.v_current_user
1039: WHERE msro.SR_SR_Receipt_ID= c_rec.SR_Receipt_ID
1032: msro.DISABLE_DATE= c_rec.Disable_Date,
1033: msro.Deleted_Flag= MSC_UTIL.SYS_NO,
1034: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1035: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1036: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1037: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
1038: CREATED_BY= MSC_CL_COLLECTION.v_current_user
1039: WHERE msro.SR_SR_Receipt_ID= c_rec.SR_Receipt_ID
1040: AND msro.SR_Instance_ID= c_rec.SR_Instance_ID
1033: msro.Deleted_Flag= MSC_UTIL.SYS_NO,
1034: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1035: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1036: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1037: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
1038: CREATED_BY= MSC_CL_COLLECTION.v_current_user
1039: WHERE msro.SR_SR_Receipt_ID= c_rec.SR_Receipt_ID
1040: AND msro.SR_Instance_ID= c_rec.SR_Instance_ID
1041: AND msro.COLLECTED_FLAG= MSC_UTIL.SYS_YES;
1034: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1035: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1036: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1037: CREATION_DATE= MSC_CL_COLLECTION.v_current_date,
1038: CREATED_BY= MSC_CL_COLLECTION.v_current_user
1039: WHERE msro.SR_SR_Receipt_ID= c_rec.SR_Receipt_ID
1040: AND msro.SR_Instance_ID= c_rec.SR_Instance_ID
1041: AND msro.COLLECTED_FLAG= MSC_UTIL.SYS_YES;
1042:
1072: c_rec.DISABLE_DATE,
1073: MSC_UTIL.SYS_YES,
1074: c_rec.SR_INSTANCE_ID,
1075: MSC_UTIL.SYS_NO,
1076: MSC_CL_COLLECTION.v_last_collection_id,
1077: MSC_CL_COLLECTION.v_current_date,
1078: MSC_CL_COLLECTION.v_current_user,
1079: MSC_CL_COLLECTION.v_current_date,
1080: MSC_CL_COLLECTION.v_current_user);
1073: MSC_UTIL.SYS_YES,
1074: c_rec.SR_INSTANCE_ID,
1075: MSC_UTIL.SYS_NO,
1076: MSC_CL_COLLECTION.v_last_collection_id,
1077: MSC_CL_COLLECTION.v_current_date,
1078: MSC_CL_COLLECTION.v_current_user,
1079: MSC_CL_COLLECTION.v_current_date,
1080: MSC_CL_COLLECTION.v_current_user);
1081:
1074: c_rec.SR_INSTANCE_ID,
1075: MSC_UTIL.SYS_NO,
1076: MSC_CL_COLLECTION.v_last_collection_id,
1077: MSC_CL_COLLECTION.v_current_date,
1078: MSC_CL_COLLECTION.v_current_user,
1079: MSC_CL_COLLECTION.v_current_date,
1080: MSC_CL_COLLECTION.v_current_user);
1081:
1082: END IF;
1075: MSC_UTIL.SYS_NO,
1076: MSC_CL_COLLECTION.v_last_collection_id,
1077: MSC_CL_COLLECTION.v_current_date,
1078: MSC_CL_COLLECTION.v_current_user,
1079: MSC_CL_COLLECTION.v_current_date,
1080: MSC_CL_COLLECTION.v_current_user);
1081:
1082: END IF;
1083:
1076: MSC_CL_COLLECTION.v_last_collection_id,
1077: MSC_CL_COLLECTION.v_current_date,
1078: MSC_CL_COLLECTION.v_current_user,
1079: MSC_CL_COLLECTION.v_current_date,
1080: MSC_CL_COLLECTION.v_current_user);
1081:
1082: END IF;
1083:
1084: c_count:= c_count+1;
1082: END IF;
1083:
1084: c_count:= c_count+1;
1085:
1086: IF c_count> MSC_CL_COLLECTION.PBS THEN
1087: COMMIT;
1088: c_count:= 0;
1089: END IF;
1090:
1103: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1104: RAISE;
1105:
1106: ELSE
1107: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1108:
1109: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1110: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1111: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SOURCING');
1128:
1129: --/* it's removed due to bug 1219661
1130: DELETE MSC_SR_RECEIPT_ORG
1131: WHERE DELETED_FLAG= MSC_UTIL.SYS_YES
1132: AND SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1133: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
1134:
1135: COMMIT;
1136: --*/
1134:
1135: COMMIT;
1136: --*/
1137:
1138: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
1139:
1140: msc_analyse_tables_pk.analyse_table( 'MSC_SR_RECEIPT_ORG');
1141:
1142: END IF;
1141:
1142: END IF;
1143:
1144: --/* it's removed due to bug 1219661
1145: IF ((MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh)
1146: AND MSC_CL_COLLECTION.v_sourcing_flag=MSC_UTIL.SYS_YES ) THEN
1147:
1148: UPDATE MSC_SR_SOURCE_ORG
1149: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
1142: END IF;
1143:
1144: --/* it's removed due to bug 1219661
1145: IF ((MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh)
1146: AND MSC_CL_COLLECTION.v_sourcing_flag=MSC_UTIL.SYS_YES ) THEN
1147:
1148: UPDATE MSC_SR_SOURCE_ORG
1149: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
1150: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1146: AND MSC_CL_COLLECTION.v_sourcing_flag=MSC_UTIL.SYS_YES ) THEN
1147:
1148: UPDATE MSC_SR_SOURCE_ORG
1149: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
1150: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1151: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1152: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1153: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
1154:
1147:
1148: UPDATE MSC_SR_SOURCE_ORG
1149: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
1150: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1151: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1152: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1153: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
1154:
1155: END IF;
1148: UPDATE MSC_SR_SOURCE_ORG
1149: SET DELETED_FLAG= MSC_UTIL.SYS_YES,
1150: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1151: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1152: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1153: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
1154:
1155: END IF;
1156:
1173: msso.RANK= c_rec.Rank,
1174: msso.SHIP_METHOD= c_rec.Ship_Method,
1175: msso.SOURCE_TYPE= c_rec.Source_Type,
1176: msso.Deleted_Flag= MSC_UTIL.SYS_NO,
1177: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1178: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1179: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1180: WHERE msso.SR_SR_SOURCE_ID= c_rec.SR_SR_SOURCE_ID
1181: AND msso.SR_Instance_ID= c_rec.SR_Instance_ID
1174: msso.SHIP_METHOD= c_rec.Ship_Method,
1175: msso.SOURCE_TYPE= c_rec.Source_Type,
1176: msso.Deleted_Flag= MSC_UTIL.SYS_NO,
1177: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1178: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1179: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1180: WHERE msso.SR_SR_SOURCE_ID= c_rec.SR_SR_SOURCE_ID
1181: AND msso.SR_Instance_ID= c_rec.SR_Instance_ID
1182: AND msso.COLLECTED_FLAG= MSC_UTIL.SYS_YES;
1175: msso.SOURCE_TYPE= c_rec.Source_Type,
1176: msso.Deleted_Flag= MSC_UTIL.SYS_NO,
1177: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1178: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1179: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1180: WHERE msso.SR_SR_SOURCE_ID= c_rec.SR_SR_SOURCE_ID
1181: AND msso.SR_Instance_ID= c_rec.SR_Instance_ID
1182: AND msso.COLLECTED_FLAG= MSC_UTIL.SYS_YES;
1183:
1217: c_rec.SR_INSTANCE_ID,
1218: MSC_UTIL.SYS_NO,
1219: c_rec.SHIP_METHOD,
1220: c_rec.SOURCE_TYPE,
1221: MSC_CL_COLLECTION.v_last_collection_id,
1222: MSC_CL_COLLECTION.v_current_date,
1223: MSC_CL_COLLECTION.v_current_user,
1224: MSC_CL_COLLECTION.v_current_date,
1225: MSC_CL_COLLECTION.v_current_user);
1218: MSC_UTIL.SYS_NO,
1219: c_rec.SHIP_METHOD,
1220: c_rec.SOURCE_TYPE,
1221: MSC_CL_COLLECTION.v_last_collection_id,
1222: MSC_CL_COLLECTION.v_current_date,
1223: MSC_CL_COLLECTION.v_current_user,
1224: MSC_CL_COLLECTION.v_current_date,
1225: MSC_CL_COLLECTION.v_current_user);
1226:
1219: c_rec.SHIP_METHOD,
1220: c_rec.SOURCE_TYPE,
1221: MSC_CL_COLLECTION.v_last_collection_id,
1222: MSC_CL_COLLECTION.v_current_date,
1223: MSC_CL_COLLECTION.v_current_user,
1224: MSC_CL_COLLECTION.v_current_date,
1225: MSC_CL_COLLECTION.v_current_user);
1226:
1227: END IF;
1220: c_rec.SOURCE_TYPE,
1221: MSC_CL_COLLECTION.v_last_collection_id,
1222: MSC_CL_COLLECTION.v_current_date,
1223: MSC_CL_COLLECTION.v_current_user,
1224: MSC_CL_COLLECTION.v_current_date,
1225: MSC_CL_COLLECTION.v_current_user);
1226:
1227: END IF;
1228:
1221: MSC_CL_COLLECTION.v_last_collection_id,
1222: MSC_CL_COLLECTION.v_current_date,
1223: MSC_CL_COLLECTION.v_current_user,
1224: MSC_CL_COLLECTION.v_current_date,
1225: MSC_CL_COLLECTION.v_current_user);
1226:
1227: END IF;
1228:
1229: c_count:= c_count+1;
1227: END IF;
1228:
1229: c_count:= c_count+1;
1230:
1231: IF c_count> MSC_CL_COLLECTION.PBS THEN
1232: COMMIT;
1233: c_count:= 0;
1234: END IF;
1235:
1248: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1249: RAISE;
1250:
1251: ELSE
1252: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1253:
1254: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1255: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1256: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SOURCING');
1273:
1274: --/* it's removed due to bug 1219661
1275: DELETE MSC_SR_SOURCE_ORG
1276: WHERE DELETED_FLAG= MSC_UTIL.SYS_YES
1277: AND SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
1278: AND COLLECTED_FLAG= MSC_UTIL.SYS_YES;
1279:
1280: COMMIT;
1281: --*/
1279:
1280: COMMIT;
1281: --*/
1282:
1283: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
1284:
1285: msc_analyse_tables_pk.analyse_table( 'MSC_SR_SOURCE_ORG');
1286:
1287: END IF;
1299: AND mism.from_location_id = msism.from_location_id
1300: AND mism.to_location_id = msism.to_location_id
1301: AND mism.ship_method = msism.ship_method);
1302:
1303: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
1304:
1305: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_INTERORG_SHIP_METHODS', MSC_CL_COLLECTION.v_instance_id,-1, 'AND nvl(COLLECTED_FLAG,1) <> 2');
1306:
1307: END IF;
1301: AND mism.ship_method = msism.ship_method);
1302:
1303: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
1304:
1305: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_INTERORG_SHIP_METHODS', MSC_CL_COLLECTION.v_instance_id,-1, 'AND nvl(COLLECTED_FLAG,1) <> 2');
1306:
1307: END IF;
1308:
1309: c_count:= 0;
1369: c_rec.CURRENCY,
1370: c_rec.TRANSPORT_CAP_OVER_UTIL_COST,
1371: c_rec.SR_INSTANCE_ID,
1372: c_rec.SR_INSTANCE_ID2,
1373: MSC_CL_COLLECTION.v_last_collection_id,
1374: MSC_CL_COLLECTION.v_current_date,
1375: MSC_CL_COLLECTION.v_current_user,
1376: MSC_CL_COLLECTION.v_current_date,
1377: MSC_CL_COLLECTION.v_current_user,
1370: c_rec.TRANSPORT_CAP_OVER_UTIL_COST,
1371: c_rec.SR_INSTANCE_ID,
1372: c_rec.SR_INSTANCE_ID2,
1373: MSC_CL_COLLECTION.v_last_collection_id,
1374: MSC_CL_COLLECTION.v_current_date,
1375: MSC_CL_COLLECTION.v_current_user,
1376: MSC_CL_COLLECTION.v_current_date,
1377: MSC_CL_COLLECTION.v_current_user,
1378: c_rec.SHIPMENT_WEIGHT,
1371: c_rec.SR_INSTANCE_ID,
1372: c_rec.SR_INSTANCE_ID2,
1373: MSC_CL_COLLECTION.v_last_collection_id,
1374: MSC_CL_COLLECTION.v_current_date,
1375: MSC_CL_COLLECTION.v_current_user,
1376: MSC_CL_COLLECTION.v_current_date,
1377: MSC_CL_COLLECTION.v_current_user,
1378: c_rec.SHIPMENT_WEIGHT,
1379: c_rec.SHIPMENT_VOLUME,
1372: c_rec.SR_INSTANCE_ID2,
1373: MSC_CL_COLLECTION.v_last_collection_id,
1374: MSC_CL_COLLECTION.v_current_date,
1375: MSC_CL_COLLECTION.v_current_user,
1376: MSC_CL_COLLECTION.v_current_date,
1377: MSC_CL_COLLECTION.v_current_user,
1378: c_rec.SHIPMENT_WEIGHT,
1379: c_rec.SHIPMENT_VOLUME,
1380: c_rec.SHIPMENT_WEIGHT_UOM,
1373: MSC_CL_COLLECTION.v_last_collection_id,
1374: MSC_CL_COLLECTION.v_current_date,
1375: MSC_CL_COLLECTION.v_current_user,
1376: MSC_CL_COLLECTION.v_current_date,
1377: MSC_CL_COLLECTION.v_current_user,
1378: c_rec.SHIPMENT_WEIGHT,
1379: c_rec.SHIPMENT_VOLUME,
1380: c_rec.SHIPMENT_WEIGHT_UOM,
1381: c_rec.SHIPMENT_VOLUME_UOM,
1382: c_rec.LEADTIME_VARIABILITY);
1383: /*
1384: c_count:= c_count+1;
1385:
1386: IF c_count> MSC_CL_COLLECTION.PBS THEN
1387: COMMIT;
1388: c_count:= 0;
1389: END IF;
1390: */
1403: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1404: RAISE;
1405:
1406: ELSE
1407: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1408:
1409: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1410: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1411: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SOURCING');
1415: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1416: FND_MESSAGE.SET_TOKEN('COLUMN', 'FROM_ORGANIZATION_CODE');
1417: FND_MESSAGE.SET_TOKEN('VALUE',
1418: MSC_GET_NAME.ORG_CODE( c_rec.FROM_ORGANIZATION_ID,
1419: MSC_CL_COLLECTION.v_instance_id));
1420: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1421:
1422: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1423: FND_MESSAGE.SET_TOKEN('COLUMN', 'TO_ORGANIZATION_CODE');
1422: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1423: FND_MESSAGE.SET_TOKEN('COLUMN', 'TO_ORGANIZATION_CODE');
1424: FND_MESSAGE.SET_TOKEN('VALUE',
1425: MSC_GET_NAME.ORG_CODE( c_rec.TO_ORGANIZATION_ID,
1426: MSC_CL_COLLECTION.v_instance_id));
1427: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1428:
1429: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1430: FND_MESSAGE.SET_TOKEN('COLUMN', 'FROM_LOCATION_ID');
1450:
1451: COMMIT;
1452:
1453: /* Code added for Region Level Sourcing for ATP - Only for 11i Source */
1454: IF MSC_CL_COLLECTION.v_apps_ver >= 3 THEN
1455:
1456:
1457: IF (MSC_CL_COLLECTION.v_apps_ver = MSC_UTIL.G_APPS107) OR (MSC_CL_COLLECTION.v_apps_ver = MSC_UTIL.G_APPS110) THEN
1458: lv_msc_tp_coll_window := 0;
1453: /* Code added for Region Level Sourcing for ATP - Only for 11i Source */
1454: IF MSC_CL_COLLECTION.v_apps_ver >= 3 THEN
1455:
1456:
1457: IF (MSC_CL_COLLECTION.v_apps_ver = MSC_UTIL.G_APPS107) OR (MSC_CL_COLLECTION.v_apps_ver = MSC_UTIL.G_APPS110) THEN
1458: lv_msc_tp_coll_window := 0;
1459: ELSE
1460: BEGIN
1461: lv_msc_tp_coll_window:= NVL(TO_NUMBER(FND_PROFILE.VALUE('MSC_COLLECTION_WINDOW_FOR_TP_CHANGES')),0);
1496:
1497:
1498:
1499: /* ------------- MSC_REGIONS ------------- */
1500: IF ((MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh)) THEN
1501:
1502: BEGIN -- load for MSC_REGIONS
1503: /* Updating Who cols of Staging Tables */
1504: UPDATE MSC_ST_REGIONS
1502: BEGIN -- load for MSC_REGIONS
1503: /* Updating Who cols of Staging Tables */
1504: UPDATE MSC_ST_REGIONS
1505: SET
1506: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1507: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1508: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1509: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1510: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1503: /* Updating Who cols of Staging Tables */
1504: UPDATE MSC_ST_REGIONS
1505: SET
1506: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1507: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1508: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1509: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1510: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1511: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1504: UPDATE MSC_ST_REGIONS
1505: SET
1506: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1507: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1508: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1509: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1510: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1511: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1512: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1505: SET
1506: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1507: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1508: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1509: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1510: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1511: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1512: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1513:
1506: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1507: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1508: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1509: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1510: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1511: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1512: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1513:
1514: COMMIT;
1507: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1508: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1509: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1510: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1511: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1512: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1513:
1514: COMMIT;
1515:
1508: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1509: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1510: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1511: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1512: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1513:
1514: COMMIT;
1515:
1516: /* Initialize the list */
1513:
1514: COMMIT;
1515:
1516: /* Initialize the list */
1517: IF NOT MSC_CL_EXCHANGE_PARTTBL.Initialize_SWAP_Tbl_List(MSC_CL_COLLECTION.v_instance_id,MSC_CL_COLLECTION.v_instance_code) THEN
1518: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
1519: END IF;
1520: /* Get the swap table index number in the list*/
1521: i := MSC_CL_EXCHANGE_PARTTBL.get_SWAP_table_index('MSC_REGIONS'); --ods table name
1514: COMMIT;
1515:
1516: /* Initialize the list */
1517: IF NOT MSC_CL_EXCHANGE_PARTTBL.Initialize_SWAP_Tbl_List(MSC_CL_COLLECTION.v_instance_id,MSC_CL_COLLECTION.v_instance_code) THEN
1518: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
1519: END IF;
1520: /* Get the swap table index number in the list*/
1521: i := MSC_CL_EXCHANGE_PARTTBL.get_SWAP_table_index('MSC_REGIONS'); --ods table name
1522: IF i = -1 THEN
1520: /* Get the swap table index number in the list*/
1521: i := MSC_CL_EXCHANGE_PARTTBL.get_SWAP_table_index('MSC_REGIONS'); --ods table name
1522: IF i = -1 THEN
1523: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Table not in the list of SWAP partition');
1524: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
1525: END IF;
1526: /* Do phase 1 exchange*/
1527:
1528: IF NOT MSC_CL_EXCHANGE_PARTTBL.EXCHANGE_SINGLE_TAB_PARTN (
1530: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).stg_table_partn_name,
1531: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name,
1532: MSC_UTIL.SYS_NO ) THEN
1533: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Exchange partition failed');
1534: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
1535: END IF;
1536:
1537: EXECUTE IMMEDIATE ' Update msc_coll_parameters set '
1538: || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).column_name || ' = '
1535: END IF;
1536:
1537: EXECUTE IMMEDIATE ' Update msc_coll_parameters set '
1538: || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).column_name || ' = '
1539: || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1
1540: || ' where instance_id = ' || MSC_CL_COLLECTION.v_instance_id;
1541:
1542: commit;
1543: /* Add code to copy required data from ods table to this temp table*/
1536:
1537: EXECUTE IMMEDIATE ' Update msc_coll_parameters set '
1538: || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).column_name || ' = '
1539: || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1
1540: || ' where instance_id = ' || MSC_CL_COLLECTION.v_instance_id;
1541:
1542: commit;
1543: /* Add code to copy required data from ods table to this temp table*/
1544:
1546: lv_crt_ind_status := MSC_CL_EXCHANGE_PARTTBL.create_temp_table_index
1547: ( 'NONUNIQUE',
1548: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).ods_table_name,
1549: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name,
1550: MSC_CL_COLLECTION.v_instance_code,
1551: MSC_CL_COLLECTION.v_instance_id,
1552: MSC_UTIL.SYS_NO,
1553: MSC_CL_COLLECTION.G_WARNING
1554: );
1547: ( 'NONUNIQUE',
1548: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).ods_table_name,
1549: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name,
1550: MSC_CL_COLLECTION.v_instance_code,
1551: MSC_CL_COLLECTION.v_instance_id,
1552: MSC_UTIL.SYS_NO,
1553: MSC_CL_COLLECTION.G_WARNING
1554: );
1555:
1549: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name,
1550: MSC_CL_COLLECTION.v_instance_code,
1551: MSC_CL_COLLECTION.v_instance_id,
1552: MSC_UTIL.SYS_NO,
1553: MSC_CL_COLLECTION.G_WARNING
1554: );
1555:
1556: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN
1557: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1552: MSC_UTIL.SYS_NO,
1553: MSC_CL_COLLECTION.G_WARNING
1554: );
1555:
1556: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN
1557: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1558: ELSIF lv_crt_ind_status = MSC_CL_COLLECTION.G_ERROR THEN
1559: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Error during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1560: --RETURN ;
1554: );
1555:
1556: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN
1557: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1558: ELSIF lv_crt_ind_status = MSC_CL_COLLECTION.G_ERROR THEN
1559: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Error during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1560: --RETURN ;
1561: ELSE
1562: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'NonUnique index creation successful on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1566:
1567:
1568:
1569: EXCEPTION
1570: WHEN MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR THEN
1571: RAISE;
1572: WHEN OTHERS THEN
1573:
1574: IF SQLCODE IN (-01683,-01653,-01650,-01562) THEN
1582: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1583: RAISE;
1584:
1585: ELSE
1586: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1587:
1588: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1589: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1590: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SOURCING');
1601: BEGIN -- load for MSC_ZONE_REGIONS
1602: /* Updating Who cols of Staging Tables */
1603: UPDATE MSC_ST_ZONE_REGIONS
1604: SET
1605: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1606: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1607: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1608: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1609: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1602: /* Updating Who cols of Staging Tables */
1603: UPDATE MSC_ST_ZONE_REGIONS
1604: SET
1605: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1606: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1607: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1608: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1609: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1610: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1603: UPDATE MSC_ST_ZONE_REGIONS
1604: SET
1605: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1606: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1607: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1608: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1609: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1610: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1611: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1604: SET
1605: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1606: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1607: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1608: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1609: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1610: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1611: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1612:
1605: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1606: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1607: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1608: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1609: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1610: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1611: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1612:
1613: COMMIT;
1606: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1607: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1608: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1609: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1610: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1611: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1612:
1613: COMMIT;
1614:
1607: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1608: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1609: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1610: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1611: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1612:
1613: COMMIT;
1614:
1615: /* Initialize the list */
1612:
1613: COMMIT;
1614:
1615: /* Initialize the list */
1616: IF NOT MSC_CL_EXCHANGE_PARTTBL.Initialize_SWAP_Tbl_List(MSC_CL_COLLECTION.v_instance_id,MSC_CL_COLLECTION.v_instance_code) THEN
1617: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
1618: END IF;
1619: /* Get the swap table index number in the list*/
1620: i := MSC_CL_EXCHANGE_PARTTBL.get_SWAP_table_index('MSC_ZONE_REGIONS'); --ods table name
1613: COMMIT;
1614:
1615: /* Initialize the list */
1616: IF NOT MSC_CL_EXCHANGE_PARTTBL.Initialize_SWAP_Tbl_List(MSC_CL_COLLECTION.v_instance_id,MSC_CL_COLLECTION.v_instance_code) THEN
1617: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
1618: END IF;
1619: /* Get the swap table index number in the list*/
1620: i := MSC_CL_EXCHANGE_PARTTBL.get_SWAP_table_index('MSC_ZONE_REGIONS'); --ods table name
1621: IF i = -1 THEN
1619: /* Get the swap table index number in the list*/
1620: i := MSC_CL_EXCHANGE_PARTTBL.get_SWAP_table_index('MSC_ZONE_REGIONS'); --ods table name
1621: IF i = -1 THEN
1622: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Table not in the list of SWAP partition');
1623: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
1624: END IF;
1625: /* Do phase 1 exchange*/
1626:
1627: IF NOT MSC_CL_EXCHANGE_PARTTBL.EXCHANGE_SINGLE_TAB_PARTN (
1629: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).stg_table_partn_name,
1630: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name,
1631: MSC_UTIL.SYS_NO ) THEN
1632: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Exchange partition failed');
1633: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
1634: END IF;
1635:
1636: EXECUTE IMMEDIATE ' Update msc_coll_parameters set '
1637: || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).column_name || ' = '
1634: END IF;
1635:
1636: EXECUTE IMMEDIATE ' Update msc_coll_parameters set '
1637: || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).column_name || ' = '
1638: || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1
1639: || ' where instance_id = ' || MSC_CL_COLLECTION.v_instance_id;
1640:
1641: commit;
1642: /* Add code to copy required data from ods table to this temp table*/
1635:
1636: EXECUTE IMMEDIATE ' Update msc_coll_parameters set '
1637: || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).column_name || ' = '
1638: || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1
1639: || ' where instance_id = ' || MSC_CL_COLLECTION.v_instance_id;
1640:
1641: commit;
1642: /* Add code to copy required data from ods table to this temp table*/
1643:
1645: lv_crt_ind_status := MSC_CL_EXCHANGE_PARTTBL.create_temp_table_index
1646: ( 'NONUNIQUE',
1647: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).ods_table_name,
1648: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name,
1649: MSC_CL_COLLECTION.v_instance_code,
1650: MSC_CL_COLLECTION.v_instance_id,
1651: MSC_UTIL.SYS_NO,
1652: MSC_CL_COLLECTION.G_WARNING
1653: );
1646: ( 'NONUNIQUE',
1647: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).ods_table_name,
1648: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name,
1649: MSC_CL_COLLECTION.v_instance_code,
1650: MSC_CL_COLLECTION.v_instance_id,
1651: MSC_UTIL.SYS_NO,
1652: MSC_CL_COLLECTION.G_WARNING
1653: );
1654:
1648: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name,
1649: MSC_CL_COLLECTION.v_instance_code,
1650: MSC_CL_COLLECTION.v_instance_id,
1651: MSC_UTIL.SYS_NO,
1652: MSC_CL_COLLECTION.G_WARNING
1653: );
1654:
1655: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN
1656: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1651: MSC_UTIL.SYS_NO,
1652: MSC_CL_COLLECTION.G_WARNING
1653: );
1654:
1655: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN
1656: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1657: ELSIF lv_crt_ind_status = MSC_CL_COLLECTION.G_ERROR THEN
1658: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Error during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1659: -- RETURN ;
1653: );
1654:
1655: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN
1656: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1657: ELSIF lv_crt_ind_status = MSC_CL_COLLECTION.G_ERROR THEN
1658: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Error during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1659: -- RETURN ;
1660: ELSE
1661: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'NonUnique index creation successful on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1661: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'NonUnique index creation successful on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1662: END IF;
1663:
1664: EXCEPTION
1665: WHEN MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR THEN
1666: RAISE;
1667: WHEN OTHERS THEN
1668:
1669: IF SQLCODE IN (-01683,-01653,-01650,-01562) THEN
1677: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1678: RAISE;
1679:
1680: ELSE
1681: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1682:
1683: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1684: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1685: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SOURCING');
1694: BEGIN -- load for MSC_REGION_LOCATIONS
1695: /* Updating Who cols of Staging Tables */
1696: UPDATE MSC_ST_REGION_LOCATIONS
1697: SET
1698: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1699: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1700: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1701: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1702: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1695: /* Updating Who cols of Staging Tables */
1696: UPDATE MSC_ST_REGION_LOCATIONS
1697: SET
1698: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1699: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1700: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1701: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1702: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1703: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1696: UPDATE MSC_ST_REGION_LOCATIONS
1697: SET
1698: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1699: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1700: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1701: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1702: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1703: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1704: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1697: SET
1698: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1699: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1700: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1701: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1702: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1703: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1704: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1705:
1698: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
1699: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1700: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1701: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1702: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1703: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1704: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1705:
1706: COMMIT;
1699: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
1700: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1701: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1702: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1703: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1704: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1705:
1706: COMMIT;
1707:
1700: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
1701: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
1702: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
1703: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
1704: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
1705:
1706: COMMIT;
1707:
1708: /* Initialize the list */
1705:
1706: COMMIT;
1707:
1708: /* Initialize the list */
1709: IF NOT MSC_CL_EXCHANGE_PARTTBL.Initialize_SWAP_Tbl_List(MSC_CL_COLLECTION.v_instance_id,MSC_CL_COLLECTION.v_instance_code) THEN
1710: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
1711: END IF;
1712: /* Get the swap table index number in the list*/
1713: i := MSC_CL_EXCHANGE_PARTTBL.get_SWAP_table_index('MSC_REGION_LOCATIONS'); --ods table name
1706: COMMIT;
1707:
1708: /* Initialize the list */
1709: IF NOT MSC_CL_EXCHANGE_PARTTBL.Initialize_SWAP_Tbl_List(MSC_CL_COLLECTION.v_instance_id,MSC_CL_COLLECTION.v_instance_code) THEN
1710: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
1711: END IF;
1712: /* Get the swap table index number in the list*/
1713: i := MSC_CL_EXCHANGE_PARTTBL.get_SWAP_table_index('MSC_REGION_LOCATIONS'); --ods table name
1714: IF i = -1 THEN
1712: /* Get the swap table index number in the list*/
1713: i := MSC_CL_EXCHANGE_PARTTBL.get_SWAP_table_index('MSC_REGION_LOCATIONS'); --ods table name
1714: IF i = -1 THEN
1715: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Table not in the list of SWAP partition');
1716: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
1717: END IF;
1718: /* Do phase 1 exchange*/
1719:
1720: IF NOT MSC_CL_EXCHANGE_PARTTBL.EXCHANGE_SINGLE_TAB_PARTN (
1722: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).stg_table_partn_name,
1723: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name,
1724: MSC_UTIL.SYS_NO ) THEN
1725: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Exchange partition failed');
1726: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
1727: END IF;
1728:
1729: EXECUTE IMMEDIATE ' Update msc_coll_parameters set '
1730: || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).column_name || ' = '
1727: END IF;
1728:
1729: EXECUTE IMMEDIATE ' Update msc_coll_parameters set '
1730: || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).column_name || ' = '
1731: || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1
1732: || ' where instance_id = ' || MSC_CL_COLLECTION.v_instance_id;
1733:
1734: commit;
1735: /* Add code to copy required data from ods table to this temp table*/
1728:
1729: EXECUTE IMMEDIATE ' Update msc_coll_parameters set '
1730: || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).column_name || ' = '
1731: || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1
1732: || ' where instance_id = ' || MSC_CL_COLLECTION.v_instance_id;
1733:
1734: commit;
1735: /* Add code to copy required data from ods table to this temp table*/
1736:
1738: lv_crt_ind_status := MSC_CL_EXCHANGE_PARTTBL.create_temp_table_index
1739: ( 'NONUNIQUE',
1740: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).ods_table_name,
1741: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name,
1742: MSC_CL_COLLECTION.v_instance_code,
1743: MSC_CL_COLLECTION.v_instance_id,
1744: MSC_UTIL.SYS_NO,
1745: MSC_CL_COLLECTION.G_WARNING
1746: );
1739: ( 'NONUNIQUE',
1740: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).ods_table_name,
1741: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name,
1742: MSC_CL_COLLECTION.v_instance_code,
1743: MSC_CL_COLLECTION.v_instance_id,
1744: MSC_UTIL.SYS_NO,
1745: MSC_CL_COLLECTION.G_WARNING
1746: );
1747:
1741: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name,
1742: MSC_CL_COLLECTION.v_instance_code,
1743: MSC_CL_COLLECTION.v_instance_id,
1744: MSC_UTIL.SYS_NO,
1745: MSC_CL_COLLECTION.G_WARNING
1746: );
1747:
1748: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN
1749: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1744: MSC_UTIL.SYS_NO,
1745: MSC_CL_COLLECTION.G_WARNING
1746: );
1747:
1748: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN
1749: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1750: ELSIF lv_crt_ind_status = MSC_CL_COLLECTION.G_ERROR THEN
1751: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Error during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1752: -- RETURN ;
1746: );
1747:
1748: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN
1749: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1750: ELSIF lv_crt_ind_status = MSC_CL_COLLECTION.G_ERROR THEN
1751: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Error during nonunique index creation on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1752: -- RETURN ;
1753: ELSE
1754: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'NonUnique index creation successful on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1754: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'NonUnique index creation successful on table, ' || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name);
1755: END IF;
1756:
1757: EXCEPTION
1758: WHEN MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR THEN
1759: RAISE;
1760: WHEN OTHERS THEN
1761:
1762: IF SQLCODE IN (-01683,-01653,-01650,-01562) THEN
1770: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1771: RAISE;
1772:
1773: ELSE
1774: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1775:
1776: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1777: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1778: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SOURCING');
1780: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1781: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1782: END IF;
1783: END; -- load for MSC_REGION_LOCATIONS
1784: END IF; --IF ((MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh)) THEN
1785:
1786:
1787: /* ------------- MSC_REGION_SITES ------------- */
1788: BEGIN
1786:
1787: /* ------------- MSC_REGION_SITES ------------- */
1788: BEGIN
1789:
1790: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
1791: IF lv_control_flag = 2 THEN
1792: MSC_CL_COLLECTION.DELETE_MSC_TABLE('MSC_REGION_SITES', MSC_CL_COLLECTION.v_instance_id,NULL);
1793: ELSE
1794: MSC_CL_COLLECTION.TRUNCATE_MSC_TABLE('MSC_REGION_SITES');
1788: BEGIN
1789:
1790: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
1791: IF lv_control_flag = 2 THEN
1792: MSC_CL_COLLECTION.DELETE_MSC_TABLE('MSC_REGION_SITES', MSC_CL_COLLECTION.v_instance_id,NULL);
1793: ELSE
1794: MSC_CL_COLLECTION.TRUNCATE_MSC_TABLE('MSC_REGION_SITES');
1795: END IF;
1796: END IF;
1790: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
1791: IF lv_control_flag = 2 THEN
1792: MSC_CL_COLLECTION.DELETE_MSC_TABLE('MSC_REGION_SITES', MSC_CL_COLLECTION.v_instance_id,NULL);
1793: ELSE
1794: MSC_CL_COLLECTION.TRUNCATE_MSC_TABLE('MSC_REGION_SITES');
1795: END IF;
1796: END IF;
1797:
1798: lv_sql_stmt:=
1828: ||' AND mtsil.Partner_Type = 1 '
1829: ||' ) ';
1830:
1831: EXECUTE IMMEDIATE lv_sql_stmt
1832: USING MSC_CL_COLLECTION.v_last_collection_id,
1833: MSC_CL_COLLECTION.v_current_user,
1834: MSC_CL_COLLECTION.v_current_date,
1835: MSC_CL_COLLECTION.v_current_user,
1836: MSC_CL_COLLECTION.v_current_date,
1829: ||' ) ';
1830:
1831: EXECUTE IMMEDIATE lv_sql_stmt
1832: USING MSC_CL_COLLECTION.v_last_collection_id,
1833: MSC_CL_COLLECTION.v_current_user,
1834: MSC_CL_COLLECTION.v_current_date,
1835: MSC_CL_COLLECTION.v_current_user,
1836: MSC_CL_COLLECTION.v_current_date,
1837: MSC_CL_COLLECTION.v_current_user,
1830:
1831: EXECUTE IMMEDIATE lv_sql_stmt
1832: USING MSC_CL_COLLECTION.v_last_collection_id,
1833: MSC_CL_COLLECTION.v_current_user,
1834: MSC_CL_COLLECTION.v_current_date,
1835: MSC_CL_COLLECTION.v_current_user,
1836: MSC_CL_COLLECTION.v_current_date,
1837: MSC_CL_COLLECTION.v_current_user,
1838: MSC_CL_COLLECTION.v_instance_id;
1831: EXECUTE IMMEDIATE lv_sql_stmt
1832: USING MSC_CL_COLLECTION.v_last_collection_id,
1833: MSC_CL_COLLECTION.v_current_user,
1834: MSC_CL_COLLECTION.v_current_date,
1835: MSC_CL_COLLECTION.v_current_user,
1836: MSC_CL_COLLECTION.v_current_date,
1837: MSC_CL_COLLECTION.v_current_user,
1838: MSC_CL_COLLECTION.v_instance_id;
1839:
1832: USING MSC_CL_COLLECTION.v_last_collection_id,
1833: MSC_CL_COLLECTION.v_current_user,
1834: MSC_CL_COLLECTION.v_current_date,
1835: MSC_CL_COLLECTION.v_current_user,
1836: MSC_CL_COLLECTION.v_current_date,
1837: MSC_CL_COLLECTION.v_current_user,
1838: MSC_CL_COLLECTION.v_instance_id;
1839:
1840: COMMIT;
1833: MSC_CL_COLLECTION.v_current_user,
1834: MSC_CL_COLLECTION.v_current_date,
1835: MSC_CL_COLLECTION.v_current_user,
1836: MSC_CL_COLLECTION.v_current_date,
1837: MSC_CL_COLLECTION.v_current_user,
1838: MSC_CL_COLLECTION.v_instance_id;
1839:
1840: COMMIT;
1841: EXCEPTION
1834: MSC_CL_COLLECTION.v_current_date,
1835: MSC_CL_COLLECTION.v_current_user,
1836: MSC_CL_COLLECTION.v_current_date,
1837: MSC_CL_COLLECTION.v_current_user,
1838: MSC_CL_COLLECTION.v_instance_id;
1839:
1840: COMMIT;
1841: EXCEPTION
1842: WHEN OTHERS THEN
1851: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1852: RAISE;
1853:
1854: ELSE
1855: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1856:
1857: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1858: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1859: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SOURCING');
1866: END;
1867:
1868:
1869:
1870: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
1871:
1872: IF lv_control_flag = 2 THEN
1873: MSC_CL_COLLECTION.DELETE_MSC_TABLE('MSC_CARRIER_SERVICES', MSC_CL_COLLECTION.v_instance_id,-1);
1874: ELSE
1869:
1870: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
1871:
1872: IF lv_control_flag = 2 THEN
1873: MSC_CL_COLLECTION.DELETE_MSC_TABLE('MSC_CARRIER_SERVICES', MSC_CL_COLLECTION.v_instance_id,-1);
1874: ELSE
1875: MSC_CL_COLLECTION.TRUNCATE_MSC_TABLE('MSC_CARRIER_SERVICES');
1876: END IF;
1877:
1871:
1872: IF lv_control_flag = 2 THEN
1873: MSC_CL_COLLECTION.DELETE_MSC_TABLE('MSC_CARRIER_SERVICES', MSC_CL_COLLECTION.v_instance_id,-1);
1874: ELSE
1875: MSC_CL_COLLECTION.TRUNCATE_MSC_TABLE('MSC_CARRIER_SERVICES');
1876: END IF;
1877:
1878: END IF;
1879:
1899: c_rec.TP_ID,
1900: c_rec.SERVICE_LEVEL,
1901: c_rec.MODE_OF_TRANSPORT,
1902: c_rec.SR_INSTANCE_ID,
1903: MSC_CL_COLLECTION.v_last_collection_id,
1904: -1,
1905: MSC_CL_COLLECTION.v_current_user,
1906: MSC_CL_COLLECTION.v_current_date,
1907: MSC_CL_COLLECTION.v_current_user,
1901: c_rec.MODE_OF_TRANSPORT,
1902: c_rec.SR_INSTANCE_ID,
1903: MSC_CL_COLLECTION.v_last_collection_id,
1904: -1,
1905: MSC_CL_COLLECTION.v_current_user,
1906: MSC_CL_COLLECTION.v_current_date,
1907: MSC_CL_COLLECTION.v_current_user,
1908: MSC_CL_COLLECTION.v_current_date,
1909: MSC_CL_COLLECTION.v_current_user);
1902: c_rec.SR_INSTANCE_ID,
1903: MSC_CL_COLLECTION.v_last_collection_id,
1904: -1,
1905: MSC_CL_COLLECTION.v_current_user,
1906: MSC_CL_COLLECTION.v_current_date,
1907: MSC_CL_COLLECTION.v_current_user,
1908: MSC_CL_COLLECTION.v_current_date,
1909: MSC_CL_COLLECTION.v_current_user);
1910:
1903: MSC_CL_COLLECTION.v_last_collection_id,
1904: -1,
1905: MSC_CL_COLLECTION.v_current_user,
1906: MSC_CL_COLLECTION.v_current_date,
1907: MSC_CL_COLLECTION.v_current_user,
1908: MSC_CL_COLLECTION.v_current_date,
1909: MSC_CL_COLLECTION.v_current_user);
1910:
1911: EXCEPTION
1904: -1,
1905: MSC_CL_COLLECTION.v_current_user,
1906: MSC_CL_COLLECTION.v_current_date,
1907: MSC_CL_COLLECTION.v_current_user,
1908: MSC_CL_COLLECTION.v_current_date,
1909: MSC_CL_COLLECTION.v_current_user);
1910:
1911: EXCEPTION
1912: WHEN OTHERS THEN
1905: MSC_CL_COLLECTION.v_current_user,
1906: MSC_CL_COLLECTION.v_current_date,
1907: MSC_CL_COLLECTION.v_current_user,
1908: MSC_CL_COLLECTION.v_current_date,
1909: MSC_CL_COLLECTION.v_current_user);
1910:
1911: EXCEPTION
1912: WHEN OTHERS THEN
1913: IF SQLCODE IN (-01683,-01653,-01650,-01562) THEN
1921: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1922: RAISE;
1923:
1924: ELSE
1925: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1926:
1927: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1928: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1929: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SOURCING');
1959: mssi.condition_type, -- For Bug # 5660122 SRP Changes
1960: mssi.SR_RESOURCE_NAME,
1961: mssi.SR_CUSTOMER_ACCT_ID
1962: FROM MSC_ST_SUB_INVENTORIES mssi
1963: WHERE mssi.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
1964:
1965: c_count NUMBER:= 0;
1966:
1967: BEGIN
1965: c_count NUMBER:= 0;
1966:
1967: BEGIN
1968:
1969: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
1970:
1971: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUB_INVENTORIES', MSC_CL_COLLECTION.v_instance_id, -1);
1972:
1973: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1967: BEGIN
1968:
1969: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
1970:
1971: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUB_INVENTORIES', MSC_CL_COLLECTION.v_instance_id, -1);
1972:
1973: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1974: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUB_INVENTORIES', MSC_CL_COLLECTION.v_instance_id, -1);
1975: ELSE
1969: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
1970:
1971: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUB_INVENTORIES', MSC_CL_COLLECTION.v_instance_id, -1);
1972:
1973: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1974: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUB_INVENTORIES', MSC_CL_COLLECTION.v_instance_id, -1);
1975: ELSE
1976: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1977: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUB_INVENTORIES', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
1970:
1971: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUB_INVENTORIES', MSC_CL_COLLECTION.v_instance_id, -1);
1972:
1973: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1974: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUB_INVENTORIES', MSC_CL_COLLECTION.v_instance_id, -1);
1975: ELSE
1976: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1977: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUB_INVENTORIES', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
1978: END IF;
1972:
1973: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1974: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUB_INVENTORIES', MSC_CL_COLLECTION.v_instance_id, -1);
1975: ELSE
1976: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1977: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUB_INVENTORIES', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
1978: END IF;
1979:
1980: END IF;
1973: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
1974: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUB_INVENTORIES', MSC_CL_COLLECTION.v_instance_id, -1);
1975: ELSE
1976: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1977: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUB_INVENTORIES', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
1978: END IF;
1979:
1980: END IF;
1981:
1984: FOR c_rec IN c1 LOOP
1985:
1986: BEGIN
1987:
1988: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
1989:
1990: UPDATE MSC_SUB_INVENTORIES
1991: SET
1992: NETTING_TYPE= c_rec.NETTING_TYPE,
1991: SET
1992: NETTING_TYPE= c_rec.NETTING_TYPE,
1993: INVENTORY_ATP_CODE= c_rec.INVENTORY_ATP_CODE,
1994: DESCRIPTION= c_rec.DESCRIPTION,
1995: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1996: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1997: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1998: condition_type=c_rec.condition_type, -- For Bug # 5660122 SRP Changes
1999: SR_RESOURCE_NAME=c_rec.SR_RESOURCE_NAME,
1992: NETTING_TYPE= c_rec.NETTING_TYPE,
1993: INVENTORY_ATP_CODE= c_rec.INVENTORY_ATP_CODE,
1994: DESCRIPTION= c_rec.DESCRIPTION,
1995: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1996: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1997: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1998: condition_type=c_rec.condition_type, -- For Bug # 5660122 SRP Changes
1999: SR_RESOURCE_NAME=c_rec.SR_RESOURCE_NAME,
2000: SR_CUSTOMER_ACCT_ID=c_rec.SR_CUSTOMER_ACCT_ID
1993: INVENTORY_ATP_CODE= c_rec.INVENTORY_ATP_CODE,
1994: DESCRIPTION= c_rec.DESCRIPTION,
1995: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1996: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1997: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1998: condition_type=c_rec.condition_type, -- For Bug # 5660122 SRP Changes
1999: SR_RESOURCE_NAME=c_rec.SR_RESOURCE_NAME,
2000: SR_CUSTOMER_ACCT_ID=c_rec.SR_CUSTOMER_ACCT_ID
2001: WHERE PLAN_ID= -1
2004: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
2005:
2006: END IF;
2007:
2008: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
2009:
2010: INSERT INTO MSC_SUB_INVENTORIES
2011: ( PLAN_ID,
2012: ORGANIZATION_ID,
2033: c_rec.CONDITION_TYPE,
2034: c_rec.SR_RESOURCE_NAME,
2035: c_rec.SR_CUSTOMER_ACCT_ID, -- For Bug # 5660122 SRP Changes
2036: c_rec.SR_INSTANCE_ID,
2037: MSC_CL_COLLECTION.v_last_collection_id,
2038: MSC_CL_COLLECTION.v_current_date,
2039: MSC_CL_COLLECTION.v_current_user,
2040: MSC_CL_COLLECTION.v_current_date,
2041: MSC_CL_COLLECTION.v_current_user );
2034: c_rec.SR_RESOURCE_NAME,
2035: c_rec.SR_CUSTOMER_ACCT_ID, -- For Bug # 5660122 SRP Changes
2036: c_rec.SR_INSTANCE_ID,
2037: MSC_CL_COLLECTION.v_last_collection_id,
2038: MSC_CL_COLLECTION.v_current_date,
2039: MSC_CL_COLLECTION.v_current_user,
2040: MSC_CL_COLLECTION.v_current_date,
2041: MSC_CL_COLLECTION.v_current_user );
2042:
2035: c_rec.SR_CUSTOMER_ACCT_ID, -- For Bug # 5660122 SRP Changes
2036: c_rec.SR_INSTANCE_ID,
2037: MSC_CL_COLLECTION.v_last_collection_id,
2038: MSC_CL_COLLECTION.v_current_date,
2039: MSC_CL_COLLECTION.v_current_user,
2040: MSC_CL_COLLECTION.v_current_date,
2041: MSC_CL_COLLECTION.v_current_user );
2042:
2043:
2036: c_rec.SR_INSTANCE_ID,
2037: MSC_CL_COLLECTION.v_last_collection_id,
2038: MSC_CL_COLLECTION.v_current_date,
2039: MSC_CL_COLLECTION.v_current_user,
2040: MSC_CL_COLLECTION.v_current_date,
2041: MSC_CL_COLLECTION.v_current_user );
2042:
2043:
2044: END IF;
2037: MSC_CL_COLLECTION.v_last_collection_id,
2038: MSC_CL_COLLECTION.v_current_date,
2039: MSC_CL_COLLECTION.v_current_user,
2040: MSC_CL_COLLECTION.v_current_date,
2041: MSC_CL_COLLECTION.v_current_user );
2042:
2043:
2044: END IF;
2045:
2044: END IF;
2045:
2046: c_count:= c_count+1;
2047:
2048: IF c_count> MSC_CL_COLLECTION.PBS THEN
2049: COMMIT;
2050: c_count:= 0;
2051: END IF;
2052:
2065: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2066: RAISE;
2067:
2068: ELSE
2069: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2070:
2071: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2072: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2073: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SUB_INVENTORY');
2077: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2078: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
2079: FND_MESSAGE.SET_TOKEN('VALUE',
2080: MSC_GET_NAME.ORG_CODE( c_rec.ORGANIZATION_ID,
2081: MSC_CL_COLLECTION.v_instance_id));
2082: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2083:
2084: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2085: FND_MESSAGE.SET_TOKEN('COLUMN', 'SUB_INVENTORY_CODE');
2110: FROM MSC_ITEM_ID_LID t1,
2111: MSC_ST_Unit_Numbers msun
2112: WHERE t1.SR_INVENTORY_ITEM_ID= msun.end_item_id
2113: AND t1.sr_instance_id= msun.sr_instance_id
2114: AND msun.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
2115:
2116: c_count NUMBER:= 0;
2117:
2118: BEGIN
2116: c_count NUMBER:= 0;
2117:
2118: BEGIN
2119:
2120: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2121:
2122: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_UNIT_NUMBERS', MSC_CL_COLLECTION.v_instance_id, NULL);
2123:
2124: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2118: BEGIN
2119:
2120: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2121:
2122: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_UNIT_NUMBERS', MSC_CL_COLLECTION.v_instance_id, NULL);
2123:
2124: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2125: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_UNIT_NUMBERS', MSC_CL_COLLECTION.v_instance_id,NULL);
2126: ELSE
2120: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2121:
2122: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_UNIT_NUMBERS', MSC_CL_COLLECTION.v_instance_id, NULL);
2123:
2124: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2125: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_UNIT_NUMBERS', MSC_CL_COLLECTION.v_instance_id,NULL);
2126: ELSE
2127: MSC_CL_COLLECTION.v_sub_str :='AND MASTER_ORGANIZATION_ID'||MSC_UTIL.v_in_org_str;
2128: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_UNIT_NUMBERS', MSC_CL_COLLECTION.v_instance_id,NULL,MSC_CL_COLLECTION.v_sub_str);
2121:
2122: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_UNIT_NUMBERS', MSC_CL_COLLECTION.v_instance_id, NULL);
2123:
2124: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2125: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_UNIT_NUMBERS', MSC_CL_COLLECTION.v_instance_id,NULL);
2126: ELSE
2127: MSC_CL_COLLECTION.v_sub_str :='AND MASTER_ORGANIZATION_ID'||MSC_UTIL.v_in_org_str;
2128: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_UNIT_NUMBERS', MSC_CL_COLLECTION.v_instance_id,NULL,MSC_CL_COLLECTION.v_sub_str);
2129: END IF;
2123:
2124: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2125: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_UNIT_NUMBERS', MSC_CL_COLLECTION.v_instance_id,NULL);
2126: ELSE
2127: MSC_CL_COLLECTION.v_sub_str :='AND MASTER_ORGANIZATION_ID'||MSC_UTIL.v_in_org_str;
2128: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_UNIT_NUMBERS', MSC_CL_COLLECTION.v_instance_id,NULL,MSC_CL_COLLECTION.v_sub_str);
2129: END IF;
2130:
2131: END IF;
2124: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2125: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_UNIT_NUMBERS', MSC_CL_COLLECTION.v_instance_id,NULL);
2126: ELSE
2127: MSC_CL_COLLECTION.v_sub_str :='AND MASTER_ORGANIZATION_ID'||MSC_UTIL.v_in_org_str;
2128: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_UNIT_NUMBERS', MSC_CL_COLLECTION.v_instance_id,NULL,MSC_CL_COLLECTION.v_sub_str);
2129: END IF;
2130:
2131: END IF;
2132:
2135: FOR c_rec IN c1 LOOP
2136:
2137: BEGIN
2138:
2139: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
2140:
2141: UPDATE MSC_UNIT_NUMBERS
2142: SET
2143: END_ITEM_ID= c_rec.END_ITEM_ID,
2142: SET
2143: END_ITEM_ID= c_rec.END_ITEM_ID,
2144: MASTER_ORGANIZATION_ID= c_rec.MASTER_ORGANIZATION_ID,
2145: COMMENTS= c_rec.COMMENTS,
2146: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2147: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2148: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2149: WHERE UNIT_NUMBER= c_rec.UNIT_NUMBER
2150: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
2143: END_ITEM_ID= c_rec.END_ITEM_ID,
2144: MASTER_ORGANIZATION_ID= c_rec.MASTER_ORGANIZATION_ID,
2145: COMMENTS= c_rec.COMMENTS,
2146: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2147: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2148: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2149: WHERE UNIT_NUMBER= c_rec.UNIT_NUMBER
2150: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
2151:
2144: MASTER_ORGANIZATION_ID= c_rec.MASTER_ORGANIZATION_ID,
2145: COMMENTS= c_rec.COMMENTS,
2146: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2147: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2148: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2149: WHERE UNIT_NUMBER= c_rec.UNIT_NUMBER
2150: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
2151:
2152: END IF;
2150: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
2151:
2152: END IF;
2153:
2154: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
2155:
2156: INSERT INTO MSC_UNIT_NUMBERS
2157: ( UNIT_NUMBER,
2158: END_ITEM_ID,
2169: c_rec.END_ITEM_ID,
2170: c_rec.MASTER_ORGANIZATION_ID,
2171: c_rec.COMMENTS,
2172: c_rec.SR_INSTANCE_ID,
2173: MSC_CL_COLLECTION.v_last_collection_id,
2174: MSC_CL_COLLECTION.v_current_date,
2175: MSC_CL_COLLECTION.v_current_user,
2176: MSC_CL_COLLECTION.v_current_date,
2177: MSC_CL_COLLECTION.v_current_user );
2170: c_rec.MASTER_ORGANIZATION_ID,
2171: c_rec.COMMENTS,
2172: c_rec.SR_INSTANCE_ID,
2173: MSC_CL_COLLECTION.v_last_collection_id,
2174: MSC_CL_COLLECTION.v_current_date,
2175: MSC_CL_COLLECTION.v_current_user,
2176: MSC_CL_COLLECTION.v_current_date,
2177: MSC_CL_COLLECTION.v_current_user );
2178:
2171: c_rec.COMMENTS,
2172: c_rec.SR_INSTANCE_ID,
2173: MSC_CL_COLLECTION.v_last_collection_id,
2174: MSC_CL_COLLECTION.v_current_date,
2175: MSC_CL_COLLECTION.v_current_user,
2176: MSC_CL_COLLECTION.v_current_date,
2177: MSC_CL_COLLECTION.v_current_user );
2178:
2179: END IF;
2172: c_rec.SR_INSTANCE_ID,
2173: MSC_CL_COLLECTION.v_last_collection_id,
2174: MSC_CL_COLLECTION.v_current_date,
2175: MSC_CL_COLLECTION.v_current_user,
2176: MSC_CL_COLLECTION.v_current_date,
2177: MSC_CL_COLLECTION.v_current_user );
2178:
2179: END IF;
2180:
2173: MSC_CL_COLLECTION.v_last_collection_id,
2174: MSC_CL_COLLECTION.v_current_date,
2175: MSC_CL_COLLECTION.v_current_user,
2176: MSC_CL_COLLECTION.v_current_date,
2177: MSC_CL_COLLECTION.v_current_user );
2178:
2179: END IF;
2180:
2181: c_count:= c_count+1;
2179: END IF;
2180:
2181: c_count:= c_count+1;
2182:
2183: IF c_count> MSC_CL_COLLECTION.PBS THEN
2184: COMMIT;
2185: c_count:= 0;
2186: END IF;
2187:
2199: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2200: RAISE;
2201:
2202: ELSE
2203: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2204:
2205: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2206: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2207: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_UNIT_NUMBER');
2222: FND_MESSAGE.SET_TOKEN('COLUMN', 'MASTER_ORGANIZATION_CODE');
2223: FND_MESSAGE.SET_TOKEN('VALUE',
2224: MSC_GET_NAME.ORG_CODE(
2225: c_rec.MASTER_ORGANIZATION_ID,
2226: MSC_CL_COLLECTION.v_instance_id));
2227: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2228:
2229: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2230: END IF;
2258: msp.OPERATING_UNIT,
2259: msp.MANAGER_CONTACT,
2260: msp.SR_INSTANCE_ID
2261: FROM MSC_ST_PROJECTS msp
2262: WHERE msp.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
2263:
2264: CURSOR c2 IS
2265: SELECT
2266: mspt.PROJECT_ID,
2274: mspt.END_DATE,
2275: mspt.MANAGER_CONTACT,
2276: mspt.SR_INSTANCE_ID
2277: FROM MSC_ST_PROJECT_TASKS mspt
2278: WHERE mspt.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
2279:
2280: c_count NUMBER:= 0;
2281:
2282: BEGIN
2280: c_count NUMBER:= 0;
2281:
2282: BEGIN
2283:
2284: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2285:
2286: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECTS', MSC_CL_COLLECTION.v_instance_id, -1);
2287:
2288: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2282: BEGIN
2283:
2284: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2285:
2286: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECTS', MSC_CL_COLLECTION.v_instance_id, -1);
2287:
2288: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2289: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECTS', MSC_CL_COLLECTION.v_instance_id, -1);
2290: ELSE
2284: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2285:
2286: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECTS', MSC_CL_COLLECTION.v_instance_id, -1);
2287:
2288: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2289: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECTS', MSC_CL_COLLECTION.v_instance_id, -1);
2290: ELSE
2291: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
2292: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECTS', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
2285:
2286: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECTS', MSC_CL_COLLECTION.v_instance_id, -1);
2287:
2288: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2289: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECTS', MSC_CL_COLLECTION.v_instance_id, -1);
2290: ELSE
2291: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
2292: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECTS', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
2293: END IF;
2287:
2288: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2289: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECTS', MSC_CL_COLLECTION.v_instance_id, -1);
2290: ELSE
2291: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
2292: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECTS', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
2293: END IF;
2294:
2295: END IF;
2288: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2289: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECTS', MSC_CL_COLLECTION.v_instance_id, -1);
2290: ELSE
2291: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
2292: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECTS', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
2293: END IF;
2294:
2295: END IF;
2296:
2299: FOR c_rec IN c1 LOOP
2300:
2301: BEGIN
2302:
2303: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
2304:
2305: UPDATE MSC_PROJECTS
2306: SET
2307: PLANNING_GROUP= c_rec.PLANNING_GROUP,
2316: START_DATE= c_rec.START_DATE,
2317: COMPLETION_DATE= c_rec.COMPLETION_DATE,
2318: OPERATING_UNIT= c_rec.OPERATING_UNIT,
2319: MANAGER_CONTACT= c_rec.MANAGER_CONTACT,
2320: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2321: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2322: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2323: WHERE PLAN_ID= -1
2324: AND PROJECT_ID= c_rec.PROJECT_ID
2317: COMPLETION_DATE= c_rec.COMPLETION_DATE,
2318: OPERATING_UNIT= c_rec.OPERATING_UNIT,
2319: MANAGER_CONTACT= c_rec.MANAGER_CONTACT,
2320: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2321: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2322: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2323: WHERE PLAN_ID= -1
2324: AND PROJECT_ID= c_rec.PROJECT_ID
2325: AND ORGANIZATION_ID= c_rec.ORGANIZATION_ID
2318: OPERATING_UNIT= c_rec.OPERATING_UNIT,
2319: MANAGER_CONTACT= c_rec.MANAGER_CONTACT,
2320: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2321: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2322: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2323: WHERE PLAN_ID= -1
2324: AND PROJECT_ID= c_rec.PROJECT_ID
2325: AND ORGANIZATION_ID= c_rec.ORGANIZATION_ID
2326: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
2326: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
2327:
2328: END IF;
2329:
2330: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
2331:
2332: INSERT INTO MSC_PROJECTS
2333: ( PLAN_ID,
2334: PROJECT_ID,
2369: c_rec.COMPLETION_DATE,
2370: c_rec.OPERATING_UNIT,
2371: c_rec.MANAGER_CONTACT,
2372: c_rec.SR_INSTANCE_ID,
2373: MSC_CL_COLLECTION.v_last_collection_id,
2374: MSC_CL_COLLECTION.v_current_date,
2375: MSC_CL_COLLECTION.v_current_user,
2376: MSC_CL_COLLECTION.v_current_date,
2377: MSC_CL_COLLECTION.v_current_user );
2370: c_rec.OPERATING_UNIT,
2371: c_rec.MANAGER_CONTACT,
2372: c_rec.SR_INSTANCE_ID,
2373: MSC_CL_COLLECTION.v_last_collection_id,
2374: MSC_CL_COLLECTION.v_current_date,
2375: MSC_CL_COLLECTION.v_current_user,
2376: MSC_CL_COLLECTION.v_current_date,
2377: MSC_CL_COLLECTION.v_current_user );
2378:
2371: c_rec.MANAGER_CONTACT,
2372: c_rec.SR_INSTANCE_ID,
2373: MSC_CL_COLLECTION.v_last_collection_id,
2374: MSC_CL_COLLECTION.v_current_date,
2375: MSC_CL_COLLECTION.v_current_user,
2376: MSC_CL_COLLECTION.v_current_date,
2377: MSC_CL_COLLECTION.v_current_user );
2378:
2379: END IF;
2372: c_rec.SR_INSTANCE_ID,
2373: MSC_CL_COLLECTION.v_last_collection_id,
2374: MSC_CL_COLLECTION.v_current_date,
2375: MSC_CL_COLLECTION.v_current_user,
2376: MSC_CL_COLLECTION.v_current_date,
2377: MSC_CL_COLLECTION.v_current_user );
2378:
2379: END IF;
2380:
2373: MSC_CL_COLLECTION.v_last_collection_id,
2374: MSC_CL_COLLECTION.v_current_date,
2375: MSC_CL_COLLECTION.v_current_user,
2376: MSC_CL_COLLECTION.v_current_date,
2377: MSC_CL_COLLECTION.v_current_user );
2378:
2379: END IF;
2380:
2381: c_count:= c_count+1;
2379: END IF;
2380:
2381: c_count:= c_count+1;
2382:
2383: IF c_count> MSC_CL_COLLECTION.PBS THEN
2384: COMMIT;
2385: c_count:= 0;
2386: END IF;
2387:
2400: RAISE;
2401:
2402: ELSE
2403:
2404: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2405:
2406: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2407: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2408: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_PROJECT');
2412: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2413: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
2414: FND_MESSAGE.SET_TOKEN('VALUE',
2415: MSC_GET_NAME.ORG_CODE( c_rec.ORGANIZATION_ID,
2416: MSC_CL_COLLECTION.v_instance_id));
2417: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2418:
2419: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2420: FND_MESSAGE.SET_TOKEN('COLUMN', 'PROJECT_NAME');
2429: END LOOP;
2430:
2431: COMMIT;
2432:
2433: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2434:
2435: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECT_TASKS', MSC_CL_COLLECTION.v_instance_id, -1);
2436:
2437: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2431: COMMIT;
2432:
2433: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2434:
2435: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECT_TASKS', MSC_CL_COLLECTION.v_instance_id, -1);
2436:
2437: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2438: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECT_TASKS', MSC_CL_COLLECTION.v_instance_id, -1);
2439: ELSE
2433: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2434:
2435: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECT_TASKS', MSC_CL_COLLECTION.v_instance_id, -1);
2436:
2437: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2438: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECT_TASKS', MSC_CL_COLLECTION.v_instance_id, -1);
2439: ELSE
2440: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
2441: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECT_TASKS', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
2434:
2435: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECT_TASKS', MSC_CL_COLLECTION.v_instance_id, -1);
2436:
2437: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2438: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECT_TASKS', MSC_CL_COLLECTION.v_instance_id, -1);
2439: ELSE
2440: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
2441: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECT_TASKS', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
2442: END IF;
2436:
2437: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2438: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECT_TASKS', MSC_CL_COLLECTION.v_instance_id, -1);
2439: ELSE
2440: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
2441: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECT_TASKS', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
2442: END IF;
2443:
2444: END IF;
2437: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
2438: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECT_TASKS', MSC_CL_COLLECTION.v_instance_id, -1);
2439: ELSE
2440: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
2441: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PROJECT_TASKS', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
2442: END IF;
2443:
2444: END IF;
2445:
2448: FOR c_rec IN c2 LOOP
2449:
2450: BEGIN
2451:
2452: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
2453:
2454: UPDATE MSC_PROJECT_TASKS
2455: SET
2456: TASK_NUMBER= c_rec.TASK_NUMBER,
2459: MANAGER= c_rec.MANAGER,
2460: START_DATE= c_rec.START_DATE,
2461: END_DATE= c_rec.END_DATE,
2462: MANAGER_CONTACT= c_rec.MANAGER_CONTACT,
2463: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2464: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2465: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2466: WHERE PLAN_ID= -1
2467: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
2460: START_DATE= c_rec.START_DATE,
2461: END_DATE= c_rec.END_DATE,
2462: MANAGER_CONTACT= c_rec.MANAGER_CONTACT,
2463: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2464: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2465: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2466: WHERE PLAN_ID= -1
2467: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
2468: AND ORGANIZATION_ID= c_rec.ORGANIZATION_ID
2461: END_DATE= c_rec.END_DATE,
2462: MANAGER_CONTACT= c_rec.MANAGER_CONTACT,
2463: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
2464: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
2465: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
2466: WHERE PLAN_ID= -1
2467: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
2468: AND ORGANIZATION_ID= c_rec.ORGANIZATION_ID
2469: AND PROJECT_ID= c_rec.PROJECT_ID
2470: AND TASK_ID= c_rec.TASK_ID;
2471:
2472: END IF;
2473:
2474: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
2475:
2476: INSERT INTO MSC_PROJECT_TASKS
2477: ( PLAN_ID,
2478: PROJECT_ID,
2503: c_rec.START_DATE,
2504: c_rec.END_DATE,
2505: c_rec.MANAGER_CONTACT,
2506: c_rec.SR_INSTANCE_ID,
2507: MSC_CL_COLLECTION.v_last_collection_id,
2508: MSC_CL_COLLECTION.v_current_date,
2509: MSC_CL_COLLECTION.v_current_user,
2510: MSC_CL_COLLECTION.v_current_date,
2511: MSC_CL_COLLECTION.v_current_user );
2504: c_rec.END_DATE,
2505: c_rec.MANAGER_CONTACT,
2506: c_rec.SR_INSTANCE_ID,
2507: MSC_CL_COLLECTION.v_last_collection_id,
2508: MSC_CL_COLLECTION.v_current_date,
2509: MSC_CL_COLLECTION.v_current_user,
2510: MSC_CL_COLLECTION.v_current_date,
2511: MSC_CL_COLLECTION.v_current_user );
2512:
2505: c_rec.MANAGER_CONTACT,
2506: c_rec.SR_INSTANCE_ID,
2507: MSC_CL_COLLECTION.v_last_collection_id,
2508: MSC_CL_COLLECTION.v_current_date,
2509: MSC_CL_COLLECTION.v_current_user,
2510: MSC_CL_COLLECTION.v_current_date,
2511: MSC_CL_COLLECTION.v_current_user );
2512:
2513: END IF;
2506: c_rec.SR_INSTANCE_ID,
2507: MSC_CL_COLLECTION.v_last_collection_id,
2508: MSC_CL_COLLECTION.v_current_date,
2509: MSC_CL_COLLECTION.v_current_user,
2510: MSC_CL_COLLECTION.v_current_date,
2511: MSC_CL_COLLECTION.v_current_user );
2512:
2513: END IF;
2514:
2507: MSC_CL_COLLECTION.v_last_collection_id,
2508: MSC_CL_COLLECTION.v_current_date,
2509: MSC_CL_COLLECTION.v_current_user,
2510: MSC_CL_COLLECTION.v_current_date,
2511: MSC_CL_COLLECTION.v_current_user );
2512:
2513: END IF;
2514:
2515: c_count:= c_count+1;
2513: END IF;
2514:
2515: c_count:= c_count+1;
2516:
2517: IF c_count> MSC_CL_COLLECTION.PBS THEN
2518: COMMIT;
2519: c_count:= 0;
2520: END IF;
2521:
2535: RAISE;
2536:
2537: ELSE
2538:
2539: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2540:
2541: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2542: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2543: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_PROJECT');
2547: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2548: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
2549: FND_MESSAGE.SET_TOKEN('VALUE',
2550: MSC_GET_NAME.ORG_CODE( c_rec.ORGANIZATION_ID,
2551: MSC_CL_COLLECTION.v_instance_id));
2552: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2553:
2554: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2555: FND_MESSAGE.SET_TOKEN('COLUMN', 'PROJECT_ID');
2591: DIMENSION4_ID,
2592: DIMENSION5_ID,
2593: UNIT_OF_MEASURE_CLASS
2594: FROM MSC_ST_BIS_PFMC_MEASURES
2595: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
2596:
2597: c_count NUMBER:= 0;
2598:
2599: BEGIN
2597: c_count NUMBER:= 0;
2598:
2599: BEGIN
2600:
2601: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2602:
2603: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERFORMANCE_MEASURES', MSC_CL_COLLECTION.v_instance_id, NULL);
2604:
2605: END IF;
2599: BEGIN
2600:
2601: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2602:
2603: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERFORMANCE_MEASURES', MSC_CL_COLLECTION.v_instance_id, NULL);
2604:
2605: END IF;
2606:
2607: c_count:= 0;
2640: c_rec.DIMENSION3_ID,
2641: c_rec.DIMENSION4_ID,
2642: c_rec.DIMENSION5_ID,
2643: c_rec.UNIT_OF_MEASURE_CLASS,
2644: MSC_CL_COLLECTION.v_instance_id,
2645: MSC_CL_COLLECTION.v_current_date,
2646: MSC_CL_COLLECTION.v_current_user,
2647: MSC_CL_COLLECTION.v_current_date,
2648: MSC_CL_COLLECTION.v_current_user );
2641: c_rec.DIMENSION4_ID,
2642: c_rec.DIMENSION5_ID,
2643: c_rec.UNIT_OF_MEASURE_CLASS,
2644: MSC_CL_COLLECTION.v_instance_id,
2645: MSC_CL_COLLECTION.v_current_date,
2646: MSC_CL_COLLECTION.v_current_user,
2647: MSC_CL_COLLECTION.v_current_date,
2648: MSC_CL_COLLECTION.v_current_user );
2649:
2642: c_rec.DIMENSION5_ID,
2643: c_rec.UNIT_OF_MEASURE_CLASS,
2644: MSC_CL_COLLECTION.v_instance_id,
2645: MSC_CL_COLLECTION.v_current_date,
2646: MSC_CL_COLLECTION.v_current_user,
2647: MSC_CL_COLLECTION.v_current_date,
2648: MSC_CL_COLLECTION.v_current_user );
2649:
2650: c_count:= c_count+1;
2643: c_rec.UNIT_OF_MEASURE_CLASS,
2644: MSC_CL_COLLECTION.v_instance_id,
2645: MSC_CL_COLLECTION.v_current_date,
2646: MSC_CL_COLLECTION.v_current_user,
2647: MSC_CL_COLLECTION.v_current_date,
2648: MSC_CL_COLLECTION.v_current_user );
2649:
2650: c_count:= c_count+1;
2651:
2644: MSC_CL_COLLECTION.v_instance_id,
2645: MSC_CL_COLLECTION.v_current_date,
2646: MSC_CL_COLLECTION.v_current_user,
2647: MSC_CL_COLLECTION.v_current_date,
2648: MSC_CL_COLLECTION.v_current_user );
2649:
2650: c_count:= c_count+1;
2651:
2652: IF c_count> MSC_CL_COLLECTION.PBS THEN
2648: MSC_CL_COLLECTION.v_current_user );
2649:
2650: c_count:= c_count+1;
2651:
2652: IF c_count> MSC_CL_COLLECTION.PBS THEN
2653: COMMIT;
2654: c_count:= 0;
2655: END IF;
2656:
2668: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2669: RAISE;
2670:
2671: ELSE
2672: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2673:
2674: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2675: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2676: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_BIS');
2728: REPORT_FUNCTION_ID,
2729: UNIT_OF_MEASURE,
2730: SYSTEM_FLAG
2731: FROM MSC_ST_BIS_TARGET_LEVELS
2732: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
2733:
2734: c_count NUMBER:= 0;
2735:
2736: BEGIN
2734: c_count NUMBER:= 0;
2735:
2736: BEGIN
2737:
2738: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2739:
2740: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_TARGET_LEVELS', MSC_CL_COLLECTION.v_instance_id, NULL);
2741:
2742: END IF;
2736: BEGIN
2737:
2738: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2739:
2740: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_TARGET_LEVELS', MSC_CL_COLLECTION.v_instance_id, NULL);
2741:
2742: END IF;
2743:
2744: c_count:= 0;
2793: c_rec.COMPUTING_FUNCTION_ID,
2794: c_rec.REPORT_FUNCTION_ID,
2795: c_rec.UNIT_OF_MEASURE,
2796: c_rec.SYSTEM_FLAG,
2797: MSC_CL_COLLECTION.v_instance_id,
2798: MSC_CL_COLLECTION.v_current_date,
2799: MSC_CL_COLLECTION.v_current_user,
2800: MSC_CL_COLLECTION.v_current_date,
2801: MSC_CL_COLLECTION.v_current_user );
2794: c_rec.REPORT_FUNCTION_ID,
2795: c_rec.UNIT_OF_MEASURE,
2796: c_rec.SYSTEM_FLAG,
2797: MSC_CL_COLLECTION.v_instance_id,
2798: MSC_CL_COLLECTION.v_current_date,
2799: MSC_CL_COLLECTION.v_current_user,
2800: MSC_CL_COLLECTION.v_current_date,
2801: MSC_CL_COLLECTION.v_current_user );
2802:
2795: c_rec.UNIT_OF_MEASURE,
2796: c_rec.SYSTEM_FLAG,
2797: MSC_CL_COLLECTION.v_instance_id,
2798: MSC_CL_COLLECTION.v_current_date,
2799: MSC_CL_COLLECTION.v_current_user,
2800: MSC_CL_COLLECTION.v_current_date,
2801: MSC_CL_COLLECTION.v_current_user );
2802:
2803: c_count:= c_count+1;
2796: c_rec.SYSTEM_FLAG,
2797: MSC_CL_COLLECTION.v_instance_id,
2798: MSC_CL_COLLECTION.v_current_date,
2799: MSC_CL_COLLECTION.v_current_user,
2800: MSC_CL_COLLECTION.v_current_date,
2801: MSC_CL_COLLECTION.v_current_user );
2802:
2803: c_count:= c_count+1;
2804:
2797: MSC_CL_COLLECTION.v_instance_id,
2798: MSC_CL_COLLECTION.v_current_date,
2799: MSC_CL_COLLECTION.v_current_user,
2800: MSC_CL_COLLECTION.v_current_date,
2801: MSC_CL_COLLECTION.v_current_user );
2802:
2803: c_count:= c_count+1;
2804:
2805: IF c_count> MSC_CL_COLLECTION.PBS THEN
2801: MSC_CL_COLLECTION.v_current_user );
2802:
2803: c_count:= c_count+1;
2804:
2805: IF c_count> MSC_CL_COLLECTION.PBS THEN
2806: COMMIT;
2807: c_count:= 0;
2808: END IF;
2809:
2822: RAISE;
2823:
2824: ELSE
2825:
2826: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2827:
2828: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2829: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2830: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_BIS');
2890: NOTIFY_RESP2_SHORT_NAME,
2891: NOTIFY_RESP3_ID,
2892: NOTIFY_RESP3_SHORT_NAME
2893: FROM MSC_ST_BIS_TARGETS
2894: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
2895:
2896: c_count NUMBER:= 0;
2897:
2898: BEGIN
2896: c_count NUMBER:= 0;
2897:
2898: BEGIN
2899:
2900: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2901:
2902: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_TARGETS', MSC_CL_COLLECTION.v_instance_id, NULL);
2903:
2904: c_count:= 0;
2898: BEGIN
2899:
2900: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
2901:
2902: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_TARGETS', MSC_CL_COLLECTION.v_instance_id, NULL);
2903:
2904: c_count:= 0;
2905:
2906: FOR c_rec IN c3 LOOP
2959: c_rec.NOTIFY_RESP2_ID,
2960: c_rec.NOTIFY_RESP2_SHORT_NAME,
2961: c_rec.NOTIFY_RESP3_ID,
2962: c_rec.NOTIFY_RESP3_SHORT_NAME,
2963: MSC_CL_COLLECTION.v_instance_id,
2964: MSC_CL_COLLECTION.v_current_date,
2965: MSC_CL_COLLECTION.v_current_user,
2966: MSC_CL_COLLECTION.v_current_date,
2967: MSC_CL_COLLECTION.v_current_user );
2960: c_rec.NOTIFY_RESP2_SHORT_NAME,
2961: c_rec.NOTIFY_RESP3_ID,
2962: c_rec.NOTIFY_RESP3_SHORT_NAME,
2963: MSC_CL_COLLECTION.v_instance_id,
2964: MSC_CL_COLLECTION.v_current_date,
2965: MSC_CL_COLLECTION.v_current_user,
2966: MSC_CL_COLLECTION.v_current_date,
2967: MSC_CL_COLLECTION.v_current_user );
2968:
2961: c_rec.NOTIFY_RESP3_ID,
2962: c_rec.NOTIFY_RESP3_SHORT_NAME,
2963: MSC_CL_COLLECTION.v_instance_id,
2964: MSC_CL_COLLECTION.v_current_date,
2965: MSC_CL_COLLECTION.v_current_user,
2966: MSC_CL_COLLECTION.v_current_date,
2967: MSC_CL_COLLECTION.v_current_user );
2968:
2969: c_count:= c_count+1;
2962: c_rec.NOTIFY_RESP3_SHORT_NAME,
2963: MSC_CL_COLLECTION.v_instance_id,
2964: MSC_CL_COLLECTION.v_current_date,
2965: MSC_CL_COLLECTION.v_current_user,
2966: MSC_CL_COLLECTION.v_current_date,
2967: MSC_CL_COLLECTION.v_current_user );
2968:
2969: c_count:= c_count+1;
2970:
2963: MSC_CL_COLLECTION.v_instance_id,
2964: MSC_CL_COLLECTION.v_current_date,
2965: MSC_CL_COLLECTION.v_current_user,
2966: MSC_CL_COLLECTION.v_current_date,
2967: MSC_CL_COLLECTION.v_current_user );
2968:
2969: c_count:= c_count+1;
2970:
2971: IF c_count> MSC_CL_COLLECTION.PBS THEN
2967: MSC_CL_COLLECTION.v_current_user );
2968:
2969: c_count:= c_count+1;
2970:
2971: IF c_count> MSC_CL_COLLECTION.PBS THEN
2972: COMMIT;
2973: c_count:= 0;
2974: END IF;
2975:
2987: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2988: RAISE;
2989:
2990: ELSE
2991: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2992:
2993: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
2994: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2995: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_BIS');
3045: DESCRIPTION,
3046: VERSION_NO,
3047: CURRENT_PLAN_FLAG
3048: FROM MSC_ST_BIS_BUSINESS_PLANS
3049: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
3050:
3051: c_count NUMBER:= 0;
3052:
3053: BEGIN
3051: c_count NUMBER:= 0;
3052:
3053: BEGIN
3054:
3055: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3056:
3057: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_BUSINESS_PLANS', MSC_CL_COLLECTION.v_instance_id, NULL);
3058:
3059: END IF;
3053: BEGIN
3054:
3055: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3056:
3057: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_BUSINESS_PLANS', MSC_CL_COLLECTION.v_instance_id, NULL);
3058:
3059: END IF;
3060:
3061: c_count:= 0;
3081: c_rec.NAME,
3082: c_rec.DESCRIPTION,
3083: c_rec.VERSION_NO,
3084: c_rec.CURRENT_PLAN_FLAG,
3085: MSC_CL_COLLECTION.v_instance_id,
3086: MSC_CL_COLLECTION.v_current_date,
3087: MSC_CL_COLLECTION.v_current_user,
3088: MSC_CL_COLLECTION.v_current_date,
3089: MSC_CL_COLLECTION.v_current_user );
3082: c_rec.DESCRIPTION,
3083: c_rec.VERSION_NO,
3084: c_rec.CURRENT_PLAN_FLAG,
3085: MSC_CL_COLLECTION.v_instance_id,
3086: MSC_CL_COLLECTION.v_current_date,
3087: MSC_CL_COLLECTION.v_current_user,
3088: MSC_CL_COLLECTION.v_current_date,
3089: MSC_CL_COLLECTION.v_current_user );
3090:
3083: c_rec.VERSION_NO,
3084: c_rec.CURRENT_PLAN_FLAG,
3085: MSC_CL_COLLECTION.v_instance_id,
3086: MSC_CL_COLLECTION.v_current_date,
3087: MSC_CL_COLLECTION.v_current_user,
3088: MSC_CL_COLLECTION.v_current_date,
3089: MSC_CL_COLLECTION.v_current_user );
3090:
3091: c_count:= c_count+1;
3084: c_rec.CURRENT_PLAN_FLAG,
3085: MSC_CL_COLLECTION.v_instance_id,
3086: MSC_CL_COLLECTION.v_current_date,
3087: MSC_CL_COLLECTION.v_current_user,
3088: MSC_CL_COLLECTION.v_current_date,
3089: MSC_CL_COLLECTION.v_current_user );
3090:
3091: c_count:= c_count+1;
3092:
3085: MSC_CL_COLLECTION.v_instance_id,
3086: MSC_CL_COLLECTION.v_current_date,
3087: MSC_CL_COLLECTION.v_current_user,
3088: MSC_CL_COLLECTION.v_current_date,
3089: MSC_CL_COLLECTION.v_current_user );
3090:
3091: c_count:= c_count+1;
3092:
3093: IF c_count> MSC_CL_COLLECTION.PBS THEN
3089: MSC_CL_COLLECTION.v_current_user );
3090:
3091: c_count:= c_count+1;
3092:
3093: IF c_count> MSC_CL_COLLECTION.PBS THEN
3094: COMMIT;
3095: c_count:= 0;
3096: END IF;
3097:
3110: RAISE;
3111:
3112: ELSE
3113:
3114: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
3115:
3116: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
3117: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
3118: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_BIS');
3160: CONTEXT,
3161: YEAR_START_DATE,
3162: QUARTER_START_DATE
3163: FROM MSC_ST_BIS_PERIODS
3164: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
3165:
3166: c_count NUMBER:= 0;
3167:
3168: /************** LEGACY_CHANGE_START*************************/
3179: INTO lv_rec_count
3180: FROM dual
3181: WHERE EXISTS(SELECT 1
3182: FROM msc_st_bis_periods
3183: WHERE sr_instance_id = MSC_CL_COLLECTION.v_instance_id);
3184: EXCEPTION
3185: WHEN NO_DATA_FOUND THEN
3186: lv_rec_count := 0;
3187: END;
3185: WHEN NO_DATA_FOUND THEN
3186: lv_rec_count := 0;
3187: END;
3188:
3189: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) or
3190: (MSC_CL_COLLECTION.v_instance_type = MSC_UTIL.G_INS_OTHER AND lv_rec_count > 0) THEN
3191: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id, NULL);
3192:
3193: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3186: lv_rec_count := 0;
3187: END;
3188:
3189: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) or
3190: (MSC_CL_COLLECTION.v_instance_type = MSC_UTIL.G_INS_OTHER AND lv_rec_count > 0) THEN
3191: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id, NULL);
3192:
3193: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3194: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id,NULL);
3187: END;
3188:
3189: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) or
3190: (MSC_CL_COLLECTION.v_instance_type = MSC_UTIL.G_INS_OTHER AND lv_rec_count > 0) THEN
3191: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id, NULL);
3192:
3193: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3194: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id,NULL);
3195: ELSE
3189: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) or
3190: (MSC_CL_COLLECTION.v_instance_type = MSC_UTIL.G_INS_OTHER AND lv_rec_count > 0) THEN
3191: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id, NULL);
3192:
3193: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3194: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id,NULL);
3195: ELSE
3196: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
3197: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id,NULL,MSC_CL_COLLECTION.v_sub_str);
3190: (MSC_CL_COLLECTION.v_instance_type = MSC_UTIL.G_INS_OTHER AND lv_rec_count > 0) THEN
3191: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id, NULL);
3192:
3193: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3194: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id,NULL);
3195: ELSE
3196: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
3197: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id,NULL,MSC_CL_COLLECTION.v_sub_str);
3198: END IF;
3192:
3193: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3194: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id,NULL);
3195: ELSE
3196: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
3197: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id,NULL,MSC_CL_COLLECTION.v_sub_str);
3198: END IF;
3199:
3200: END IF;
3193: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3194: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id,NULL);
3195: ELSE
3196: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
3197: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_BIS_PERIODS', MSC_CL_COLLECTION.v_instance_id,NULL,MSC_CL_COLLECTION.v_sub_str);
3198: END IF;
3199:
3200: END IF;
3201:
3242: c_rec.DESCRIPTION,
3243: c_rec.CONTEXT,
3244: c_rec.YEAR_START_DATE,
3245: c_rec.QUARTER_START_DATE,
3246: MSC_CL_COLLECTION.v_instance_id,
3247: MSC_CL_COLLECTION.v_current_date,
3248: MSC_CL_COLLECTION.v_current_user,
3249: MSC_CL_COLLECTION.v_current_date,
3250: MSC_CL_COLLECTION.v_current_user );
3243: c_rec.CONTEXT,
3244: c_rec.YEAR_START_DATE,
3245: c_rec.QUARTER_START_DATE,
3246: MSC_CL_COLLECTION.v_instance_id,
3247: MSC_CL_COLLECTION.v_current_date,
3248: MSC_CL_COLLECTION.v_current_user,
3249: MSC_CL_COLLECTION.v_current_date,
3250: MSC_CL_COLLECTION.v_current_user );
3251:
3244: c_rec.YEAR_START_DATE,
3245: c_rec.QUARTER_START_DATE,
3246: MSC_CL_COLLECTION.v_instance_id,
3247: MSC_CL_COLLECTION.v_current_date,
3248: MSC_CL_COLLECTION.v_current_user,
3249: MSC_CL_COLLECTION.v_current_date,
3250: MSC_CL_COLLECTION.v_current_user );
3251:
3252: c_count:= c_count+1;
3245: c_rec.QUARTER_START_DATE,
3246: MSC_CL_COLLECTION.v_instance_id,
3247: MSC_CL_COLLECTION.v_current_date,
3248: MSC_CL_COLLECTION.v_current_user,
3249: MSC_CL_COLLECTION.v_current_date,
3250: MSC_CL_COLLECTION.v_current_user );
3251:
3252: c_count:= c_count+1;
3253:
3246: MSC_CL_COLLECTION.v_instance_id,
3247: MSC_CL_COLLECTION.v_current_date,
3248: MSC_CL_COLLECTION.v_current_user,
3249: MSC_CL_COLLECTION.v_current_date,
3250: MSC_CL_COLLECTION.v_current_user );
3251:
3252: c_count:= c_count+1;
3253:
3254: IF c_count> MSC_CL_COLLECTION.PBS THEN
3250: MSC_CL_COLLECTION.v_current_user );
3251:
3252: c_count:= c_count+1;
3253:
3254: IF c_count> MSC_CL_COLLECTION.PBS THEN
3255: COMMIT;
3256: c_count:= 0;
3257: END IF;
3258:
3271: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
3272: RAISE;
3273:
3274: ELSE
3275: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
3276:
3277: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
3278: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
3279: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_BIS');
3283: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
3284: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
3285: FND_MESSAGE.SET_TOKEN('VALUE',
3286: MSC_GET_NAME.ORG_CODE( c_rec.ORGANIZATION_ID,
3287: MSC_CL_COLLECTION.v_instance_id));
3288: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
3289:
3290: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
3291: FND_MESSAGE.SET_TOKEN('COLUMN', 'PERIOD_SET_NAME');
3354: MPS_DESIGNATOR,
3355: AGGREGATE_TIME_FENCE_CODE,
3356: AGGREGATE_TIME_FENCE
3357: FROM MSC_ST_ATP_RULES
3358: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
3359:
3360: c_count NUMBER:= 0;
3361:
3362: BEGIN
3360: c_count NUMBER:= 0;
3361:
3362: BEGIN
3363:
3364: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3365:
3366: DELETE MSC_ATP_RULES
3367: WHERE sr_instance_id= MSC_CL_COLLECTION.v_instance_id;
3368:
3363:
3364: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3365:
3366: DELETE MSC_ATP_RULES
3367: WHERE sr_instance_id= MSC_CL_COLLECTION.v_instance_id;
3368:
3369: -- MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_ATP_RULES', MSC_CL_COLLECTION.v_instance_id, NULL);
3370:
3371: END IF;
3365:
3366: DELETE MSC_ATP_RULES
3367: WHERE sr_instance_id= MSC_CL_COLLECTION.v_instance_id;
3368:
3369: -- MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_ATP_RULES', MSC_CL_COLLECTION.v_instance_id, NULL);
3370:
3371: END IF;
3372:
3373: c_count:= 0;
3460: c_rec.USER_ATP_DEMAND_TABLE_NAME,
3461: c_rec.MPS_DESIGNATOR,
3462: c_rec.AGGREGATE_TIME_FENCE_CODE,
3463: c_rec.AGGREGATE_TIME_FENCE,
3464: MSC_CL_COLLECTION.v_instance_id,
3465: MSC_CL_COLLECTION.v_current_date,
3466: MSC_CL_COLLECTION.v_current_user,
3467: MSC_CL_COLLECTION.v_current_date,
3468: MSC_CL_COLLECTION.v_current_user );
3461: c_rec.MPS_DESIGNATOR,
3462: c_rec.AGGREGATE_TIME_FENCE_CODE,
3463: c_rec.AGGREGATE_TIME_FENCE,
3464: MSC_CL_COLLECTION.v_instance_id,
3465: MSC_CL_COLLECTION.v_current_date,
3466: MSC_CL_COLLECTION.v_current_user,
3467: MSC_CL_COLLECTION.v_current_date,
3468: MSC_CL_COLLECTION.v_current_user );
3469: /*
3462: c_rec.AGGREGATE_TIME_FENCE_CODE,
3463: c_rec.AGGREGATE_TIME_FENCE,
3464: MSC_CL_COLLECTION.v_instance_id,
3465: MSC_CL_COLLECTION.v_current_date,
3466: MSC_CL_COLLECTION.v_current_user,
3467: MSC_CL_COLLECTION.v_current_date,
3468: MSC_CL_COLLECTION.v_current_user );
3469: /*
3470: c_count:= c_count+1;
3463: c_rec.AGGREGATE_TIME_FENCE,
3464: MSC_CL_COLLECTION.v_instance_id,
3465: MSC_CL_COLLECTION.v_current_date,
3466: MSC_CL_COLLECTION.v_current_user,
3467: MSC_CL_COLLECTION.v_current_date,
3468: MSC_CL_COLLECTION.v_current_user );
3469: /*
3470: c_count:= c_count+1;
3471:
3464: MSC_CL_COLLECTION.v_instance_id,
3465: MSC_CL_COLLECTION.v_current_date,
3466: MSC_CL_COLLECTION.v_current_user,
3467: MSC_CL_COLLECTION.v_current_date,
3468: MSC_CL_COLLECTION.v_current_user );
3469: /*
3470: c_count:= c_count+1;
3471:
3472: IF c_count> MSC_CL_COLLECTION.PBS THEN
3468: MSC_CL_COLLECTION.v_current_user );
3469: /*
3470: c_count:= c_count+1;
3471:
3472: IF c_count> MSC_CL_COLLECTION.PBS THEN
3473: COMMIT;
3474: c_count:= 0;
3475: END IF;
3476: */
3489: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
3490: RAISE;
3491:
3492: ELSE
3493: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
3494:
3495: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
3496: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
3497: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_ATP_RULES');
3533: x.EMPLOYEE_ID,
3534: x.CURRENT_EMPLOYEE_FLAG,
3535: x.USER_NAME
3536: FROM MSC_ST_PLANNERS x
3537: WHERE x.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
3538:
3539: /* added this cursor for bug: 1121172 */
3540: CURSOR c2 IS
3541: SELECT x.USER_NAME,
3547: WHERE UPPER(x.USER_NAME) = y.USER_NAME
3548: AND x.CURRENT_EMPLOYEE_FLAG = 1
3549: AND x.EMPLOYEE_ID IS NOT NULL
3550: AND x.ELECTRONIC_MAIL_ADDRESS IS NOT NULL
3551: AND x.SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
3552:
3553: c_count NUMBER:= 0;
3554:
3555: BEGIN
3553: c_count NUMBER:= 0;
3554:
3555: BEGIN
3556:
3557: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3558:
3559: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id, NULL);
3560: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3561: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id,NULL);
3555: BEGIN
3556:
3557: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3558:
3559: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id, NULL);
3560: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3561: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id,NULL);
3562: ELSE
3563: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
3556:
3557: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3558:
3559: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id, NULL);
3560: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3561: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id,NULL);
3562: ELSE
3563: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
3564: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id,NULL,MSC_CL_COLLECTION.v_sub_str);
3557: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3558:
3559: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id, NULL);
3560: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3561: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id,NULL);
3562: ELSE
3563: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
3564: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id,NULL,MSC_CL_COLLECTION.v_sub_str);
3565: END IF;
3559: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id, NULL);
3560: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3561: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id,NULL);
3562: ELSE
3563: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
3564: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id,NULL,MSC_CL_COLLECTION.v_sub_str);
3565: END IF;
3566:
3567: c_count:= 0;
3560: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3561: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id,NULL);
3562: ELSE
3563: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
3564: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_PLANNERS', MSC_CL_COLLECTION.v_instance_id,NULL,MSC_CL_COLLECTION.v_sub_str);
3565: END IF;
3566:
3567: c_count:= 0;
3568:
3592: c_rec.ELECTRONIC_MAIL_ADDRESS,
3593: c_rec.EMPLOYEE_ID,
3594: c_rec.CURRENT_EMPLOYEE_FLAG,
3595: c_rec.USER_NAME,
3596: MSC_CL_COLLECTION.v_instance_id,
3597: MSC_CL_COLLECTION.v_current_date,
3598: MSC_CL_COLLECTION.v_current_user,
3599: MSC_CL_COLLECTION.v_current_date,
3600: MSC_CL_COLLECTION.v_current_user );
3593: c_rec.EMPLOYEE_ID,
3594: c_rec.CURRENT_EMPLOYEE_FLAG,
3595: c_rec.USER_NAME,
3596: MSC_CL_COLLECTION.v_instance_id,
3597: MSC_CL_COLLECTION.v_current_date,
3598: MSC_CL_COLLECTION.v_current_user,
3599: MSC_CL_COLLECTION.v_current_date,
3600: MSC_CL_COLLECTION.v_current_user );
3601:
3594: c_rec.CURRENT_EMPLOYEE_FLAG,
3595: c_rec.USER_NAME,
3596: MSC_CL_COLLECTION.v_instance_id,
3597: MSC_CL_COLLECTION.v_current_date,
3598: MSC_CL_COLLECTION.v_current_user,
3599: MSC_CL_COLLECTION.v_current_date,
3600: MSC_CL_COLLECTION.v_current_user );
3601:
3602: c_count:= c_count+1;
3595: c_rec.USER_NAME,
3596: MSC_CL_COLLECTION.v_instance_id,
3597: MSC_CL_COLLECTION.v_current_date,
3598: MSC_CL_COLLECTION.v_current_user,
3599: MSC_CL_COLLECTION.v_current_date,
3600: MSC_CL_COLLECTION.v_current_user );
3601:
3602: c_count:= c_count+1;
3603:
3596: MSC_CL_COLLECTION.v_instance_id,
3597: MSC_CL_COLLECTION.v_current_date,
3598: MSC_CL_COLLECTION.v_current_user,
3599: MSC_CL_COLLECTION.v_current_date,
3600: MSC_CL_COLLECTION.v_current_user );
3601:
3602: c_count:= c_count+1;
3603:
3604: IF c_count> MSC_CL_COLLECTION.PBS THEN
3600: MSC_CL_COLLECTION.v_current_user );
3601:
3602: c_count:= c_count+1;
3603:
3604: IF c_count> MSC_CL_COLLECTION.PBS THEN
3605: COMMIT;
3606: c_count:= 0;
3607: END IF;
3608:
3621: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
3622: RAISE;
3623:
3624: ELSE
3625: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
3626:
3627: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
3628: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
3629: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_PLANNERS');
3633: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
3634: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
3635: FND_MESSAGE.SET_TOKEN('VALUE',
3636: MSC_GET_NAME.ORG_CODE( c_rec.ORGANIZATION_ID,
3637: MSC_CL_COLLECTION.v_instance_id));
3638: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
3639:
3640: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
3641: FND_MESSAGE.SET_TOKEN('COLUMN', 'PLANNER_CODE');
3662: EXCEPTION
3663:
3664: WHEN OTHERS THEN
3665:
3666: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
3667:
3668: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
3669: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
3670: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_PLANNERS');
3699: msrg.FROM_DATE,
3700: msrg.TO_DATE,
3701: msrg.ENABLED_FLAG
3702: FROM MSC_ST_DEMAND_CLASSES msrg
3703: WHERE msrg.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
3704:
3705: c_count NUMBER:= 0;
3706:
3707: BEGIN
3705: c_count NUMBER:= 0;
3706:
3707: BEGIN
3708:
3709: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3710:
3711: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_DEMAND_CLASSES', MSC_CL_COLLECTION.v_instance_id, NULL);
3712:
3713: END IF;
3707: BEGIN
3708:
3709: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3710:
3711: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_DEMAND_CLASSES', MSC_CL_COLLECTION.v_instance_id, NULL);
3712:
3713: END IF;
3714:
3715: -- IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3711: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_DEMAND_CLASSES', MSC_CL_COLLECTION.v_instance_id, NULL);
3712:
3713: END IF;
3714:
3715: -- IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3716:
3717: FOR c_rec IN c1 LOOP
3718:
3719: BEGIN
3717: FOR c_rec IN c1 LOOP
3718:
3719: BEGIN
3720:
3721: IF MSC_CL_COLLECTION.v_is_legacy_refresh THEN
3722:
3723: UPDATE MSC_DEMAND_CLASSES
3724: SET
3725: MEANING = c_rec.MEANING,
3726: DESCRIPTION = c_rec.DESCRIPTION,
3727: FROM_DATE = c_rec.FROM_DATE,
3728: TO_DATE = c_rec.TO_DATE,
3729: ENABLED_FLAG = c_rec.ENABLED_FLAG,
3730: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
3731: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
3732: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3733: AND DEMAND_CLASS = c_rec.DEMAND_CLASS;
3734:
3727: FROM_DATE = c_rec.FROM_DATE,
3728: TO_DATE = c_rec.TO_DATE,
3729: ENABLED_FLAG = c_rec.ENABLED_FLAG,
3730: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
3731: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
3732: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3733: AND DEMAND_CLASS = c_rec.DEMAND_CLASS;
3734:
3735: END IF;
3728: TO_DATE = c_rec.TO_DATE,
3729: ENABLED_FLAG = c_rec.ENABLED_FLAG,
3730: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
3731: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
3732: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3733: AND DEMAND_CLASS = c_rec.DEMAND_CLASS;
3734:
3735: END IF;
3736:
3733: AND DEMAND_CLASS = c_rec.DEMAND_CLASS;
3734:
3735: END IF;
3736:
3737: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_partial_refresh) OR (MSC_CL_COLLECTION.v_is_legacy_refresh AND SQL%NOTFOUND) THEN
3738:
3739: INSERT INTO MSC_DEMAND_CLASSES
3740: ( DEMAND_CLASS,
3741: MEANING,
3754: c_rec.DESCRIPTION,
3755: c_rec.FROM_DATE,
3756: c_rec.TO_DATE,
3757: c_rec.ENABLED_FLAG,
3758: MSC_CL_COLLECTION.v_instance_id,
3759: MSC_CL_COLLECTION.v_current_date,
3760: MSC_CL_COLLECTION.v_current_user,
3761: MSC_CL_COLLECTION.v_current_date,
3762: MSC_CL_COLLECTION.v_current_user );
3755: c_rec.FROM_DATE,
3756: c_rec.TO_DATE,
3757: c_rec.ENABLED_FLAG,
3758: MSC_CL_COLLECTION.v_instance_id,
3759: MSC_CL_COLLECTION.v_current_date,
3760: MSC_CL_COLLECTION.v_current_user,
3761: MSC_CL_COLLECTION.v_current_date,
3762: MSC_CL_COLLECTION.v_current_user );
3763:
3756: c_rec.TO_DATE,
3757: c_rec.ENABLED_FLAG,
3758: MSC_CL_COLLECTION.v_instance_id,
3759: MSC_CL_COLLECTION.v_current_date,
3760: MSC_CL_COLLECTION.v_current_user,
3761: MSC_CL_COLLECTION.v_current_date,
3762: MSC_CL_COLLECTION.v_current_user );
3763:
3764: END IF;
3757: c_rec.ENABLED_FLAG,
3758: MSC_CL_COLLECTION.v_instance_id,
3759: MSC_CL_COLLECTION.v_current_date,
3760: MSC_CL_COLLECTION.v_current_user,
3761: MSC_CL_COLLECTION.v_current_date,
3762: MSC_CL_COLLECTION.v_current_user );
3763:
3764: END IF;
3765:
3758: MSC_CL_COLLECTION.v_instance_id,
3759: MSC_CL_COLLECTION.v_current_date,
3760: MSC_CL_COLLECTION.v_current_user,
3761: MSC_CL_COLLECTION.v_current_date,
3762: MSC_CL_COLLECTION.v_current_user );
3763:
3764: END IF;
3765:
3766: EXCEPTION
3778: RAISE;
3779:
3780: ELSE
3781:
3782: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
3783:
3784: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
3785: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
3786: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_DEMAND_CLASS');
3805:
3806: PROCEDURE LOAD_SALES_CHANNEL IS
3807:
3808: BEGIN
3809: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3810:
3811: MSC_CL_COLLECTION.DELETE_MSC_TABLE ('MSC_SALES_CHANNEL', MSC_CL_COLLECTION.v_instance_id, NULL);
3812:
3813: END IF;
3807:
3808: BEGIN
3809: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3810:
3811: MSC_CL_COLLECTION.DELETE_MSC_TABLE ('MSC_SALES_CHANNEL', MSC_CL_COLLECTION.v_instance_id, NULL);
3812:
3813: END IF;
3814:
3815: INSERT INTO MSC_SR_LOOKUPS (
3832: DESCRIPTION,
3833: FROM_DATE,
3834: TO_DATE,
3835: ENABLED_FLAG,
3836: MSC_CL_COLLECTION.v_instance_id,
3837: MSC_CL_COLLECTION.v_current_date,
3838: MSC_CL_COLLECTION.v_current_user,
3839: MSC_CL_COLLECTION.v_current_date,
3840: MSC_CL_COLLECTION.v_current_user
3833: FROM_DATE,
3834: TO_DATE,
3835: ENABLED_FLAG,
3836: MSC_CL_COLLECTION.v_instance_id,
3837: MSC_CL_COLLECTION.v_current_date,
3838: MSC_CL_COLLECTION.v_current_user,
3839: MSC_CL_COLLECTION.v_current_date,
3840: MSC_CL_COLLECTION.v_current_user
3841: FROM MSC_ST_SALES_CHANNEL
3834: TO_DATE,
3835: ENABLED_FLAG,
3836: MSC_CL_COLLECTION.v_instance_id,
3837: MSC_CL_COLLECTION.v_current_date,
3838: MSC_CL_COLLECTION.v_current_user,
3839: MSC_CL_COLLECTION.v_current_date,
3840: MSC_CL_COLLECTION.v_current_user
3841: FROM MSC_ST_SALES_CHANNEL
3842: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
3835: ENABLED_FLAG,
3836: MSC_CL_COLLECTION.v_instance_id,
3837: MSC_CL_COLLECTION.v_current_date,
3838: MSC_CL_COLLECTION.v_current_user,
3839: MSC_CL_COLLECTION.v_current_date,
3840: MSC_CL_COLLECTION.v_current_user
3841: FROM MSC_ST_SALES_CHANNEL
3842: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
3843:
3836: MSC_CL_COLLECTION.v_instance_id,
3837: MSC_CL_COLLECTION.v_current_date,
3838: MSC_CL_COLLECTION.v_current_user,
3839: MSC_CL_COLLECTION.v_current_date,
3840: MSC_CL_COLLECTION.v_current_user
3841: FROM MSC_ST_SALES_CHANNEL
3842: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
3843:
3844: COMMIT;
3838: MSC_CL_COLLECTION.v_current_user,
3839: MSC_CL_COLLECTION.v_current_date,
3840: MSC_CL_COLLECTION.v_current_user
3841: FROM MSC_ST_SALES_CHANNEL
3842: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
3843:
3844: COMMIT;
3845:
3846: EXCEPTION
3856: PROCEDURE LOAD_FISCAL_CALENDAR IS
3857:
3858: BEGIN
3859:
3860: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3861:
3862: MSC_CL_COLLECTION.DELETE_MSC_TABLE ('MSC_CALENDARS', MSC_CL_COLLECTION.v_instance_id, Null, 'AND CALENDAR_TYPE=''FISCAL''');
3863:
3864: END IF;
3858: BEGIN
3859:
3860: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3861:
3862: MSC_CL_COLLECTION.DELETE_MSC_TABLE ('MSC_CALENDARS', MSC_CL_COLLECTION.v_instance_id, Null, 'AND CALENDAR_TYPE=''FISCAL''');
3863:
3864: END IF;
3865:
3866: INSERT INTO MSC_CALENDARS
3877: SELECT
3878: DISTINCT
3879: CALENDAR_CODE,
3880: CALENDAR_TYPE,
3881: MSC_CL_COLLECTION.v_last_collection_id,
3882: MSC_CL_COLLECTION.v_instance_id,
3883: MSC_CL_COLLECTION.v_current_date,
3884: MSC_CL_COLLECTION.v_current_user,
3885: MSC_CL_COLLECTION.v_current_date,
3878: DISTINCT
3879: CALENDAR_CODE,
3880: CALENDAR_TYPE,
3881: MSC_CL_COLLECTION.v_last_collection_id,
3882: MSC_CL_COLLECTION.v_instance_id,
3883: MSC_CL_COLLECTION.v_current_date,
3884: MSC_CL_COLLECTION.v_current_user,
3885: MSC_CL_COLLECTION.v_current_date,
3886: MSC_CL_COLLECTION.v_current_user
3879: CALENDAR_CODE,
3880: CALENDAR_TYPE,
3881: MSC_CL_COLLECTION.v_last_collection_id,
3882: MSC_CL_COLLECTION.v_instance_id,
3883: MSC_CL_COLLECTION.v_current_date,
3884: MSC_CL_COLLECTION.v_current_user,
3885: MSC_CL_COLLECTION.v_current_date,
3886: MSC_CL_COLLECTION.v_current_user
3887: FROM MSC_ST_CALENDAR_MONTHS
3880: CALENDAR_TYPE,
3881: MSC_CL_COLLECTION.v_last_collection_id,
3882: MSC_CL_COLLECTION.v_instance_id,
3883: MSC_CL_COLLECTION.v_current_date,
3884: MSC_CL_COLLECTION.v_current_user,
3885: MSC_CL_COLLECTION.v_current_date,
3886: MSC_CL_COLLECTION.v_current_user
3887: FROM MSC_ST_CALENDAR_MONTHS
3888: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3881: MSC_CL_COLLECTION.v_last_collection_id,
3882: MSC_CL_COLLECTION.v_instance_id,
3883: MSC_CL_COLLECTION.v_current_date,
3884: MSC_CL_COLLECTION.v_current_user,
3885: MSC_CL_COLLECTION.v_current_date,
3886: MSC_CL_COLLECTION.v_current_user
3887: FROM MSC_ST_CALENDAR_MONTHS
3888: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3889: AND CALENDAR_TYPE='FISCAL';
3882: MSC_CL_COLLECTION.v_instance_id,
3883: MSC_CL_COLLECTION.v_current_date,
3884: MSC_CL_COLLECTION.v_current_user,
3885: MSC_CL_COLLECTION.v_current_date,
3886: MSC_CL_COLLECTION.v_current_user
3887: FROM MSC_ST_CALENDAR_MONTHS
3888: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3889: AND CALENDAR_TYPE='FISCAL';
3890:
3884: MSC_CL_COLLECTION.v_current_user,
3885: MSC_CL_COLLECTION.v_current_date,
3886: MSC_CL_COLLECTION.v_current_user
3887: FROM MSC_ST_CALENDAR_MONTHS
3888: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3889: AND CALENDAR_TYPE='FISCAL';
3890:
3891: COMMIT;
3892:
3890:
3891: COMMIT;
3892:
3893:
3894: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3895:
3896: MSC_CL_COLLECTION.DELETE_MSC_TABLE ('MSC_CALENDAR_MONTHS', MSC_CL_COLLECTION.v_instance_id, NULL);
3897:
3898: END IF;
3892:
3893:
3894: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
3895:
3896: MSC_CL_COLLECTION.DELETE_MSC_TABLE ('MSC_CALENDAR_MONTHS', MSC_CL_COLLECTION.v_instance_id, NULL);
3897:
3898: END IF;
3899:
3900: INSERT INTO MSC_CALENDAR_MONTHS (
3932: MONTH,
3933: MONTH_DESCRIPTION,
3934: MONTH_START_DATE,
3935: MONTH_END_DATE,
3936: MSC_CL_COLLECTION.v_instance_id,
3937: MSC_CL_COLLECTION.v_current_date,
3938: MSC_CL_COLLECTION.v_current_user,
3939: MSC_CL_COLLECTION.v_current_date,
3940: MSC_CL_COLLECTION.v_current_user,
3933: MONTH_DESCRIPTION,
3934: MONTH_START_DATE,
3935: MONTH_END_DATE,
3936: MSC_CL_COLLECTION.v_instance_id,
3937: MSC_CL_COLLECTION.v_current_date,
3938: MSC_CL_COLLECTION.v_current_user,
3939: MSC_CL_COLLECTION.v_current_date,
3940: MSC_CL_COLLECTION.v_current_user,
3941: MSC_CL_COLLECTION.v_current_user
3934: MONTH_START_DATE,
3935: MONTH_END_DATE,
3936: MSC_CL_COLLECTION.v_instance_id,
3937: MSC_CL_COLLECTION.v_current_date,
3938: MSC_CL_COLLECTION.v_current_user,
3939: MSC_CL_COLLECTION.v_current_date,
3940: MSC_CL_COLLECTION.v_current_user,
3941: MSC_CL_COLLECTION.v_current_user
3942: FROM MSC_ST_CALENDAR_MONTHS
3935: MONTH_END_DATE,
3936: MSC_CL_COLLECTION.v_instance_id,
3937: MSC_CL_COLLECTION.v_current_date,
3938: MSC_CL_COLLECTION.v_current_user,
3939: MSC_CL_COLLECTION.v_current_date,
3940: MSC_CL_COLLECTION.v_current_user,
3941: MSC_CL_COLLECTION.v_current_user
3942: FROM MSC_ST_CALENDAR_MONTHS
3943: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3936: MSC_CL_COLLECTION.v_instance_id,
3937: MSC_CL_COLLECTION.v_current_date,
3938: MSC_CL_COLLECTION.v_current_user,
3939: MSC_CL_COLLECTION.v_current_date,
3940: MSC_CL_COLLECTION.v_current_user,
3941: MSC_CL_COLLECTION.v_current_user
3942: FROM MSC_ST_CALENDAR_MONTHS
3943: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3944: AND CALENDAR_TYPE='FISCAL';
3937: MSC_CL_COLLECTION.v_current_date,
3938: MSC_CL_COLLECTION.v_current_user,
3939: MSC_CL_COLLECTION.v_current_date,
3940: MSC_CL_COLLECTION.v_current_user,
3941: MSC_CL_COLLECTION.v_current_user
3942: FROM MSC_ST_CALENDAR_MONTHS
3943: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3944: AND CALENDAR_TYPE='FISCAL';
3945:
3939: MSC_CL_COLLECTION.v_current_date,
3940: MSC_CL_COLLECTION.v_current_user,
3941: MSC_CL_COLLECTION.v_current_user
3942: FROM MSC_ST_CALENDAR_MONTHS
3943: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3944: AND CALENDAR_TYPE='FISCAL';
3945:
3946: COMMIT;
3947:
3969: mst.VOLUME_CAPACITY,
3970: mst.VOLUME_UOM,
3971: mst.SR_INSTANCE_ID
3972: FROM MSC_ST_TRIPS mst
3973: WHERE mst.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3974: AND mst.DELETED_FLAG= MSC_UTIL.SYS_NO;
3975:
3976: CURSOR c1_d IS
3977: SELECT
3977: SELECT
3978: mst.TRIP_ID,
3979: mst.SR_INSTANCE_ID
3980: FROM MSC_ST_TRIPS mst
3981: WHERE mst.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3982: AND mst.DELETED_FLAG= MSC_UTIL.SYS_YES;
3983:
3984: CURSOR c2 IS
3985: SELECT
3991: PLANNED_DEPARTURE_DATE,
3992: TRIP_ID,
3993: mst.SR_INSTANCE_ID
3994: FROM MSC_ST_TRIP_STOPS mst
3995: WHERE mst.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
3996: AND mst.DELETED_FLAG= MSC_UTIL.SYS_NO;
3997:
3998: CURSOR c2_d IS
3999: SELECT
3999: SELECT
4000: mst.STOP_ID,
4001: mst.SR_INSTANCE_ID
4002: FROM MSC_ST_TRIP_STOPS mst
4003: WHERE mst.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
4004: AND mst.DELETED_FLAG= MSC_UTIL.SYS_YES;
4005:
4006:
4007: c_count NUMBER:= 0;
4009: lv_sql_stmt VARCHAR2(5000);
4010:
4011: BEGIN
4012:
4013: IF MSC_CL_COLLECTION.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
4014:
4015: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
4016:
4017: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_TRIPS', MSC_CL_COLLECTION.v_instance_id, -1);
4011: BEGIN
4012:
4013: IF MSC_CL_COLLECTION.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
4014:
4015: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
4016:
4017: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_TRIPS', MSC_CL_COLLECTION.v_instance_id, -1);
4018:
4019: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_TRIP_STOPS', MSC_CL_COLLECTION.v_instance_id, -1);
4013: IF MSC_CL_COLLECTION.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
4014:
4015: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
4016:
4017: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_TRIPS', MSC_CL_COLLECTION.v_instance_id, -1);
4018:
4019: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_TRIP_STOPS', MSC_CL_COLLECTION.v_instance_id, -1);
4020:
4021: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh
4015: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
4016:
4017: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_TRIPS', MSC_CL_COLLECTION.v_instance_id, -1);
4018:
4019: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_TRIP_STOPS', MSC_CL_COLLECTION.v_instance_id, -1);
4020:
4021: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh
4022:
4023: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
4017: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_TRIPS', MSC_CL_COLLECTION.v_instance_id, -1);
4018:
4019: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_TRIP_STOPS', MSC_CL_COLLECTION.v_instance_id, -1);
4020:
4021: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh
4022:
4023: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
4024:
4025: FOR c_rec IN c1_d LOOP
4019: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_TRIP_STOPS', MSC_CL_COLLECTION.v_instance_id, -1);
4020:
4021: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh
4022:
4023: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
4024:
4025: FOR c_rec IN c1_d LOOP
4026:
4027: DELETE MSC_TRIPS
4047: FOR c_rec IN c1 LOOP
4048:
4049: BEGIN
4050:
4051: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
4052:
4053: UPDATE MSC_TRIPS
4054: SET
4055: NAME = c_rec.NAME,
4059: WEIGHT_CAPACITY = c_rec.WEIGHT_CAPACITY,
4060: WEIGHT_UOM = c_rec.WEIGHT_UOM,
4061: VOLUME_CAPACITY = c_rec.VOLUME_CAPACITY,
4062: VOLUME_UOM = c_rec.VOLUME_UOM,
4063: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
4064: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4065: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
4066: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
4067: WHERE PLAN_ID= -1
4060: WEIGHT_UOM = c_rec.WEIGHT_UOM,
4061: VOLUME_CAPACITY = c_rec.VOLUME_CAPACITY,
4062: VOLUME_UOM = c_rec.VOLUME_UOM,
4063: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
4064: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4065: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
4066: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
4067: WHERE PLAN_ID= -1
4068: AND TRIP_ID= c_rec.TRIP_ID
4061: VOLUME_CAPACITY = c_rec.VOLUME_CAPACITY,
4062: VOLUME_UOM = c_rec.VOLUME_UOM,
4063: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
4064: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4065: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
4066: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
4067: WHERE PLAN_ID= -1
4068: AND TRIP_ID= c_rec.TRIP_ID
4069: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
4062: VOLUME_UOM = c_rec.VOLUME_UOM,
4063: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
4064: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4065: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
4066: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
4067: WHERE PLAN_ID= -1
4068: AND TRIP_ID= c_rec.TRIP_ID
4069: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
4070:
4069: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
4070:
4071: END IF;
4072:
4073: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
4074:
4075: INSERT INTO MSC_TRIPS
4076: ( PLAN_ID,
4077: TRIP_ID,
4100: c_rec.WEIGHT_UOM,
4101: c_rec.VOLUME_CAPACITY,
4102: c_rec.VOLUME_UOM,
4103: c_rec.SR_INSTANCE_ID,
4104: MSC_CL_COLLECTION.v_last_collection_id,
4105: MSC_CL_COLLECTION.v_current_date,
4106: MSC_CL_COLLECTION.v_current_user,
4107: MSC_CL_COLLECTION.v_current_date,
4108: MSC_CL_COLLECTION.v_current_user );
4101: c_rec.VOLUME_CAPACITY,
4102: c_rec.VOLUME_UOM,
4103: c_rec.SR_INSTANCE_ID,
4104: MSC_CL_COLLECTION.v_last_collection_id,
4105: MSC_CL_COLLECTION.v_current_date,
4106: MSC_CL_COLLECTION.v_current_user,
4107: MSC_CL_COLLECTION.v_current_date,
4108: MSC_CL_COLLECTION.v_current_user );
4109:
4102: c_rec.VOLUME_UOM,
4103: c_rec.SR_INSTANCE_ID,
4104: MSC_CL_COLLECTION.v_last_collection_id,
4105: MSC_CL_COLLECTION.v_current_date,
4106: MSC_CL_COLLECTION.v_current_user,
4107: MSC_CL_COLLECTION.v_current_date,
4108: MSC_CL_COLLECTION.v_current_user );
4109:
4110: END IF; --SQL%NOTFOUND
4103: c_rec.SR_INSTANCE_ID,
4104: MSC_CL_COLLECTION.v_last_collection_id,
4105: MSC_CL_COLLECTION.v_current_date,
4106: MSC_CL_COLLECTION.v_current_user,
4107: MSC_CL_COLLECTION.v_current_date,
4108: MSC_CL_COLLECTION.v_current_user );
4109:
4110: END IF; --SQL%NOTFOUND
4111:
4104: MSC_CL_COLLECTION.v_last_collection_id,
4105: MSC_CL_COLLECTION.v_current_date,
4106: MSC_CL_COLLECTION.v_current_user,
4107: MSC_CL_COLLECTION.v_current_date,
4108: MSC_CL_COLLECTION.v_current_user );
4109:
4110: END IF; --SQL%NOTFOUND
4111:
4112: c_count:= c_count+1;
4110: END IF; --SQL%NOTFOUND
4111:
4112: c_count:= c_count+1;
4113:
4114: IF c_count> MSC_CL_COLLECTION.PBS THEN
4115: COMMIT;
4116: c_count:= 0;
4117: END IF;
4118:
4129: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
4130: RAISE;
4131:
4132: ELSE
4133: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
4134:
4135: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
4136: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
4137: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_TRIP');
4157: FOR c_rec IN c2 LOOP
4158:
4159: BEGIN
4160:
4161: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN
4162:
4163: UPDATE MSC_TRIP_STOPS
4164: SET
4165: STOP_LOCATION_ID = c_rec.STOP_LOCATION_ID,
4167: STOP_SEQUENCE_NUMBER = c_rec.STOP_SEQUENCE_NUMBER,
4168: PLANNED_ARRIVAL_DATE = c_rec.PLANNED_ARRIVAL_DATE,
4169: PLANNED_DEPARTURE_DATE = c_rec.PLANNED_DEPARTURE_DATE,
4170: TRIP_ID = c_rec.TRIP_ID,
4171: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
4172: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4173: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
4174: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
4175: WHERE PLAN_ID= -1
4168: PLANNED_ARRIVAL_DATE = c_rec.PLANNED_ARRIVAL_DATE,
4169: PLANNED_DEPARTURE_DATE = c_rec.PLANNED_DEPARTURE_DATE,
4170: TRIP_ID = c_rec.TRIP_ID,
4171: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
4172: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4173: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
4174: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
4175: WHERE PLAN_ID= -1
4176: AND STOP_ID= c_rec.STOP_ID
4169: PLANNED_DEPARTURE_DATE = c_rec.PLANNED_DEPARTURE_DATE,
4170: TRIP_ID = c_rec.TRIP_ID,
4171: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
4172: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4173: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
4174: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
4175: WHERE PLAN_ID= -1
4176: AND STOP_ID= c_rec.STOP_ID
4177: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
4170: TRIP_ID = c_rec.TRIP_ID,
4171: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
4172: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4173: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
4174: LAST_UPDATE_LOGIN = MSC_CL_COLLECTION.v_current_user
4175: WHERE PLAN_ID= -1
4176: AND STOP_ID= c_rec.STOP_ID
4177: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
4178:
4177: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID;
4178:
4179: END IF;
4180:
4181: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) OR SQL%NOTFOUND THEN
4182:
4183: INSERT INTO MSC_TRIP_STOPS
4184: ( PLAN_ID,
4185: STOP_ID,
4204: c_rec.PLANNED_ARRIVAL_DATE,
4205: c_rec.PLANNED_DEPARTURE_DATE,
4206: c_rec.TRIP_ID,
4207: c_rec.SR_INSTANCE_ID,
4208: MSC_CL_COLLECTION.v_last_collection_id,
4209: MSC_CL_COLLECTION.v_current_date,
4210: MSC_CL_COLLECTION.v_current_user,
4211: MSC_CL_COLLECTION.v_current_date,
4212: MSC_CL_COLLECTION.v_current_user );
4205: c_rec.PLANNED_DEPARTURE_DATE,
4206: c_rec.TRIP_ID,
4207: c_rec.SR_INSTANCE_ID,
4208: MSC_CL_COLLECTION.v_last_collection_id,
4209: MSC_CL_COLLECTION.v_current_date,
4210: MSC_CL_COLLECTION.v_current_user,
4211: MSC_CL_COLLECTION.v_current_date,
4212: MSC_CL_COLLECTION.v_current_user );
4213:
4206: c_rec.TRIP_ID,
4207: c_rec.SR_INSTANCE_ID,
4208: MSC_CL_COLLECTION.v_last_collection_id,
4209: MSC_CL_COLLECTION.v_current_date,
4210: MSC_CL_COLLECTION.v_current_user,
4211: MSC_CL_COLLECTION.v_current_date,
4212: MSC_CL_COLLECTION.v_current_user );
4213:
4214: END IF; --SQL%NOTFOUND
4207: c_rec.SR_INSTANCE_ID,
4208: MSC_CL_COLLECTION.v_last_collection_id,
4209: MSC_CL_COLLECTION.v_current_date,
4210: MSC_CL_COLLECTION.v_current_user,
4211: MSC_CL_COLLECTION.v_current_date,
4212: MSC_CL_COLLECTION.v_current_user );
4213:
4214: END IF; --SQL%NOTFOUND
4215:
4208: MSC_CL_COLLECTION.v_last_collection_id,
4209: MSC_CL_COLLECTION.v_current_date,
4210: MSC_CL_COLLECTION.v_current_user,
4211: MSC_CL_COLLECTION.v_current_date,
4212: MSC_CL_COLLECTION.v_current_user );
4213:
4214: END IF; --SQL%NOTFOUND
4215:
4216: c_count:= c_count+1;
4214: END IF; --SQL%NOTFOUND
4215:
4216: c_count:= c_count+1;
4217:
4218: IF c_count> MSC_CL_COLLECTION.PBS THEN
4219: COMMIT;
4220: c_count:= 0;
4221: END IF;
4222:
4233: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
4234: RAISE;
4235:
4236: ELSE
4237: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
4238:
4239: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
4240: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
4241: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_TRIP');
4269: v_sql_stmt VARCHAR2(2000);
4270:
4271: BEGIN
4272:
4273: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
4274:
4275: Begin
4276: select 1 into cnt from MSC_CURRENCY_CONVERSIONS
4277: where (to_currency = MSC_CL_OTHER_PULL.G_MSC_HUB_CURR_CODE and
4285: end;
4286:
4287:
4288: If (cnt = 0) then
4289: MSC_CL_COLLECTION.TRUNCATE_MSC_TABLE('MSC_CURRENCY_CONVERSIONS');
4290: End if;
4291:
4292:
4293: MERGE INTO MSC_CURRENCY_CONVERSIONS mcc
4290: End if;
4291:
4292:
4293: MERGE INTO MSC_CURRENCY_CONVERSIONS mcc
4294: USING (Select * from MSC_ST_CURRENCY_CONVERSIONS where sr_instance_id = MSC_CL_COLLECTION.v_instance_id) mst
4295: ON (mcc.from_currency = mst.from_currency
4296: AND mcc.to_currency = mst.to_currency
4297: AND mcc.conv_date = mst.conv_date
4298: AND mcc.conv_type = mst.conv_type
4356: lv_sql_stmt VARCHAR2(10000);
4357: i NUMBER := -1;
4358: reqid number;
4359: BEGIN
4360: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
4361: /* Updating Who cols of Staging Tables */
4362: UPDATE MSC_ST_DELIVERY_DETAILS
4363: SET
4364: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
4360: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
4361: /* Updating Who cols of Staging Tables */
4362: UPDATE MSC_ST_DELIVERY_DETAILS
4363: SET
4364: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
4365: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
4366: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4367: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
4368: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
4361: /* Updating Who cols of Staging Tables */
4362: UPDATE MSC_ST_DELIVERY_DETAILS
4363: SET
4364: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
4365: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
4366: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4367: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
4368: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
4369: LAST_UPDATE_LOGIN =MSC_CL_COLLECTION.v_current_user
4362: UPDATE MSC_ST_DELIVERY_DETAILS
4363: SET
4364: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
4365: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
4366: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4367: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
4368: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
4369: LAST_UPDATE_LOGIN =MSC_CL_COLLECTION.v_current_user
4370: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
4363: SET
4364: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
4365: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
4366: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4367: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
4368: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
4369: LAST_UPDATE_LOGIN =MSC_CL_COLLECTION.v_current_user
4370: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
4371:
4364: REFRESH_NUMBER = MSC_CL_COLLECTION.v_last_collection_id,
4365: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
4366: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4367: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
4368: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
4369: LAST_UPDATE_LOGIN =MSC_CL_COLLECTION.v_current_user
4370: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
4371:
4372: COMMIT;
4365: LAST_UPDATE_DATE = MSC_CL_COLLECTION.v_current_date,
4366: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4367: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
4368: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
4369: LAST_UPDATE_LOGIN =MSC_CL_COLLECTION.v_current_user
4370: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
4371:
4372: COMMIT;
4373:
4366: LAST_UPDATED_BY = MSC_CL_COLLECTION.v_current_user,
4367: CREATION_DATE = MSC_CL_COLLECTION.v_current_date,
4368: CREATED_BY = MSC_CL_COLLECTION.v_current_user,
4369: LAST_UPDATE_LOGIN =MSC_CL_COLLECTION.v_current_user
4370: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
4371:
4372: COMMIT;
4373:
4374: /* Initialize the list */
4371:
4372: COMMIT;
4373:
4374: /* Initialize the list */
4375: IF NOT MSC_CL_EXCHANGE_PARTTBL.Initialize_SWAP_Tbl_List(MSC_CL_COLLECTION.v_instance_id,MSC_CL_COLLECTION.v_instance_code) THEN
4376: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
4377: END IF;
4378: /* Get the swap table index number in the list*/
4379: i := MSC_CL_EXCHANGE_PARTTBL.get_SWAP_table_index('MSC_DELIVERY_DETAILS'); --ods table name
4372: COMMIT;
4373:
4374: /* Initialize the list */
4375: IF NOT MSC_CL_EXCHANGE_PARTTBL.Initialize_SWAP_Tbl_List(MSC_CL_COLLECTION.v_instance_id,MSC_CL_COLLECTION.v_instance_code) THEN
4376: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
4377: END IF;
4378: /* Get the swap table index number in the list*/
4379: i := MSC_CL_EXCHANGE_PARTTBL.get_SWAP_table_index('MSC_DELIVERY_DETAILS'); --ods table name
4380: IF i = -1 THEN
4378: /* Get the swap table index number in the list*/
4379: i := MSC_CL_EXCHANGE_PARTTBL.get_SWAP_table_index('MSC_DELIVERY_DETAILS'); --ods table name
4380: IF i = -1 THEN
4381: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Table not in the list of SWAP partition');
4382: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
4383: END IF;
4384: /* Do phase 1 exchange*/
4385:
4386: IF NOT MSC_CL_EXCHANGE_PARTTBL.EXCHANGE_SINGLE_TAB_PARTN (
4388: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).stg_table_partn_name,
4389: MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).temp_table_name,
4390: MSC_UTIL.SYS_NO ) THEN
4391: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Exchange partition failed');
4392: RAISE MSC_CL_COLLECTION.EXCHANGE_PARTN_ERROR;
4393: END IF;
4394:
4395: EXECUTE IMMEDIATE ' Update msc_coll_parameters set '
4396: || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).column_name || ' = '
4393: END IF;
4394:
4395: EXECUTE IMMEDIATE ' Update msc_coll_parameters set '
4396: || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).column_name || ' = '
4397: || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1
4398: || ' where instance_id = ' || MSC_CL_COLLECTION.v_instance_id;
4399:
4400: commit;
4401: /* Add code to copy required data from ods table to this temp table*/
4394:
4395: EXECUTE IMMEDIATE ' Update msc_coll_parameters set '
4396: || MSC_CL_EXCHANGE_PARTTBL.v_swapTblList(i).column_name || ' = '
4397: || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1
4398: || ' where instance_id = ' || MSC_CL_COLLECTION.v_instance_id;
4399:
4400: commit;
4401: /* Add code to copy required data from ods table to this temp table*/
4402:
4470: ||' CREATION_DATE,'
4471: ||' CREATED_BY,'
4472: ||' LAST_UPDATE_LOGIN'
4473: ||' FROM MSC_DELIVERY_DETAILS '
4474: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
4475: ||' and organization_id not '|| msc_Util.v_in_org_str;
4476:
4477:
4478: EXECUTE IMMEDIATE lv_sql_stmt;
4497: WHEN OTHERS THEN
4498: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
4499: RAISE;
4500: End;
4501: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh
4502: END LOAD_DELIVERY_DETAILS;
4503:
4504: PROCEDURE PURGE_STALE_CURRENCY_CONV IS
4505: v_pbs number;