78: BEGIN
79: NULL;
80: c_count:=0;
81: -- ========= Prepare the Cursor Statement ==========
82: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
83: lv_tbl:= 'DEMANDS_'||MSC_CL_COLLECTION.v_instance_code;
84: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
85: ELSE
86: lv_tbl:= 'MSC_DEMANDS';
79: NULL;
80: c_count:=0;
81: -- ========= Prepare the Cursor Statement ==========
82: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
83: lv_tbl:= 'DEMANDS_'||MSC_CL_COLLECTION.v_instance_code;
84: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
85: ELSE
86: lv_tbl:= 'MSC_DEMANDS';
87: lv_supplies_tbl:= 'MSC_SUPPLIES';
80: c_count:=0;
81: -- ========= Prepare the Cursor Statement ==========
82: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
83: lv_tbl:= 'DEMANDS_'||MSC_CL_COLLECTION.v_instance_code;
84: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
85: ELSE
86: lv_tbl:= 'MSC_DEMANDS';
87: lv_supplies_tbl:= 'MSC_SUPPLIES';
88: END IF;
87: lv_supplies_tbl:= 'MSC_SUPPLIES';
88: END IF;
89:
90: IF MSC_UTIL.G_COLLECT_SRP_DATA = 'Y' THEN
91: IF MSC_CL_COLLECTION.v_is_legacy_refresh THEN
92: lv_ITEM_TYPE_ID := MSC_UTIL.G_PARTCONDN_ITEMTYPEID;
93: lv_sel_sql_stmt := 'ITEM_TYPE_ID,ITEM_TYPE_VALUE';
94: lv_data_sql_stmt := lv_ITEM_TYPE_ID||','||'msdd.ITEM_TYPE_VALUE,';
95: ELSE
122: mshr.Origination_type ,
123: mshr.SR_INSTANCE_ID
124: From MSC_ST_DEMANDS mshr ,
125: msc_item_id_lid t1
126: Where mshr.sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
127: ||' And mshr.ro_status_code=''C''
128: And mshr.origination_type= 77
129: AND t1.SR_INVENTORY_ITEM_ID(+)= mshr.inventory_item_id
130: AND t1.sr_instance_id(+)= mshr.sr_instance_id ';
128: And mshr.origination_type= 77
129: AND t1.SR_INVENTORY_ITEM_ID(+)= mshr.inventory_item_id
130: AND t1.sr_instance_id(+)= mshr.sr_instance_id ';
131:
132: if MSC_CL_COLLECTION.v_is_legacy_refresh then
133: lv_del_stmt := lv_del_stmt || ' And mshr.ENTITY=''IRO''' ;
134: else
135: lv_del_stmt := lv_del_stmt || ' And mshr.organization_id '||MSC_UTIL.v_depot_org_str;
136: end if ;
145: mshr.WIP_ENTITY_ID,
146: mshr.wip_entity_name
147: FROM MSC_ST_DEMANDS mshr,
148: msc_item_id_lid t1
149: WHERE mshr.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
150: ||' AND mshr.DELETED_FLAG= '||MSC_UTIL.SYS_YES
151: ||' AND mshr.ORIGINATION_TYPE=77
152: AND t1.SR_INVENTORY_ITEM_ID(+)= mshr.inventory_item_id
153: AND t1.sr_instance_id(+)= mshr.sr_instance_id ';
152: AND t1.SR_INVENTORY_ITEM_ID(+)= mshr.inventory_item_id
153: AND t1.sr_instance_id(+)= mshr.sr_instance_id ';
154:
155:
156: if MSC_CL_COLLECTION.v_is_legacy_refresh then
157: lv_del_stmt2 := lv_del_stmt2 || ' And mshr.ENTITY=''IRO''' ;
158: else
159: lv_del_stmt2 := lv_del_stmt2 || 'And mshr.organization_id '||MSC_UTIL.v_depot_org_str;
160: end if ;
203: ||' MSC_ITEM_ID_LID t2,'
204: ||' MSC_ITEM_ID_LID t3,'
205: || lv_supplies_tbl||' ms,'
206: ||' MSC_ST_DEMANDS msdd'
207: ||' WHERE msdd.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
208: ||' AND msdd.ORIGINATION_TYPE = 77' /* 50 eam demand: ds change change SRP Change 5909379*/
209: ||' AND msdd.DELETED_FLAG= '||MSC_UTIL.SYS_NO
210: ||' AND t1.SR_INVENTORY_ITEM_ID= msdd.inventory_item_id'
211: ||' AND t1.sr_instance_id= msdd.SR_INSTANCE_ID'
262: ||' CREATED_BY)'
263: || lv_cursor_stmt;
264:
265:
266: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN -- incremental Refresh
267:
268:
269:
270: --=================================================
316: lv_WIP_ENTITY_NAME ;
317:
318:
319: EXIT WHEN C11_d%NOTFOUND;
320: if MSC_CL_COLLECTION.v_is_legacy_refresh then
321: Delete from msc_demands
322: WHERE PLAN_ID= -1
323: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
324: AND ORIGINATION_TYPE= lv_ORIGINATION_TYPE
347:
348: /* Opening The cursor ... Perofrom Update ... If not found the n inser ... row operation */
349:
350:
351: OPEN c2 FOR lv_cursor_stmt USING MSC_CL_COLLECTION.v_chr10,
352: MSC_CL_COLLECTION.v_chr13,
353: MSC_CL_COLLECTION.v_last_collection_id,
354: MSC_CL_COLLECTION.v_current_date,
355: MSC_CL_COLLECTION.v_current_user,
348: /* Opening The cursor ... Perofrom Update ... If not found the n inser ... row operation */
349:
350:
351: OPEN c2 FOR lv_cursor_stmt USING MSC_CL_COLLECTION.v_chr10,
352: MSC_CL_COLLECTION.v_chr13,
353: MSC_CL_COLLECTION.v_last_collection_id,
354: MSC_CL_COLLECTION.v_current_date,
355: MSC_CL_COLLECTION.v_current_user,
356: MSC_CL_COLLECTION.v_current_date,
349:
350:
351: OPEN c2 FOR lv_cursor_stmt USING MSC_CL_COLLECTION.v_chr10,
352: MSC_CL_COLLECTION.v_chr13,
353: MSC_CL_COLLECTION.v_last_collection_id,
354: MSC_CL_COLLECTION.v_current_date,
355: MSC_CL_COLLECTION.v_current_user,
356: MSC_CL_COLLECTION.v_current_date,
357: MSC_CL_COLLECTION.v_current_user;
350:
351: OPEN c2 FOR lv_cursor_stmt USING MSC_CL_COLLECTION.v_chr10,
352: MSC_CL_COLLECTION.v_chr13,
353: MSC_CL_COLLECTION.v_last_collection_id,
354: MSC_CL_COLLECTION.v_current_date,
355: MSC_CL_COLLECTION.v_current_user,
356: MSC_CL_COLLECTION.v_current_date,
357: MSC_CL_COLLECTION.v_current_user;
358:
351: OPEN c2 FOR lv_cursor_stmt USING MSC_CL_COLLECTION.v_chr10,
352: MSC_CL_COLLECTION.v_chr13,
353: MSC_CL_COLLECTION.v_last_collection_id,
354: MSC_CL_COLLECTION.v_current_date,
355: MSC_CL_COLLECTION.v_current_user,
356: MSC_CL_COLLECTION.v_current_date,
357: MSC_CL_COLLECTION.v_current_user;
358:
359: LOOP
352: MSC_CL_COLLECTION.v_chr13,
353: MSC_CL_COLLECTION.v_last_collection_id,
354: MSC_CL_COLLECTION.v_current_date,
355: MSC_CL_COLLECTION.v_current_user,
356: MSC_CL_COLLECTION.v_current_date,
357: MSC_CL_COLLECTION.v_current_user;
358:
359: LOOP
360:
353: MSC_CL_COLLECTION.v_last_collection_id,
354: MSC_CL_COLLECTION.v_current_date,
355: MSC_CL_COLLECTION.v_current_user,
356: MSC_CL_COLLECTION.v_current_date,
357: MSC_CL_COLLECTION.v_current_user;
358:
359: LOOP
360:
361: FETCH c2 INTO
403:
404: EXIT WHEN c2%NOTFOUND;
405:
406: BEGIN
407: if MSC_CL_COLLECTION.v_is_legacy_refresh then
408: Update MSC_DEMANDS
409: Set
410: USING_ASSEMBLY_ITEM_ID = lv_USING_ASSEMBLY_ITEM_ID ,
411: USING_ASSEMBLY_DEMAND_DATE = lv_USING_ASSEMBLY_DEMAND_DATE ,
591: lv_COMPONENT_SCALING_TYPE,
592: lv_COMPONENT_YIELD_FACTOR,
593: lv_ITEM_TYPE_ID,
594: lv_ITEM_TYPE_VALUE,
595: MSC_CL_COLLECTION.v_last_collection_id,
596: MSC_CL_COLLECTION.v_current_date,
597: MSC_CL_COLLECTION.v_current_user,
598: MSC_CL_COLLECTION.v_current_date,
599: MSC_CL_COLLECTION.v_current_user;
592: lv_COMPONENT_YIELD_FACTOR,
593: lv_ITEM_TYPE_ID,
594: lv_ITEM_TYPE_VALUE,
595: MSC_CL_COLLECTION.v_last_collection_id,
596: MSC_CL_COLLECTION.v_current_date,
597: MSC_CL_COLLECTION.v_current_user,
598: MSC_CL_COLLECTION.v_current_date,
599: MSC_CL_COLLECTION.v_current_user;
600:
593: lv_ITEM_TYPE_ID,
594: lv_ITEM_TYPE_VALUE,
595: MSC_CL_COLLECTION.v_last_collection_id,
596: MSC_CL_COLLECTION.v_current_date,
597: MSC_CL_COLLECTION.v_current_user,
598: MSC_CL_COLLECTION.v_current_date,
599: MSC_CL_COLLECTION.v_current_user;
600:
601: END IF;
594: lv_ITEM_TYPE_VALUE,
595: MSC_CL_COLLECTION.v_last_collection_id,
596: MSC_CL_COLLECTION.v_current_date,
597: MSC_CL_COLLECTION.v_current_user,
598: MSC_CL_COLLECTION.v_current_date,
599: MSC_CL_COLLECTION.v_current_user;
600:
601: END IF;
602: EXCEPTION
595: MSC_CL_COLLECTION.v_last_collection_id,
596: MSC_CL_COLLECTION.v_current_date,
597: MSC_CL_COLLECTION.v_current_user,
598: MSC_CL_COLLECTION.v_current_date,
599: MSC_CL_COLLECTION.v_current_user;
600:
601: END IF;
602: EXCEPTION
603:
616: END LOOP;
617:
618: END IF; -- incremental Refresh
619:
620: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh) THEN
621:
622: BEGIN
623:
624:
623:
624:
625: EXECUTE IMMEDIATE lv_sql_stmt
626: USING
627: MSC_CL_COLLECTION.v_chr10,
628: MSC_CL_COLLECTION.v_chr13,
629: MSC_CL_COLLECTION.v_last_collection_id,
630: MSC_CL_COLLECTION.v_current_date,
631: MSC_CL_COLLECTION.v_current_user,
624:
625: EXECUTE IMMEDIATE lv_sql_stmt
626: USING
627: MSC_CL_COLLECTION.v_chr10,
628: MSC_CL_COLLECTION.v_chr13,
629: MSC_CL_COLLECTION.v_last_collection_id,
630: MSC_CL_COLLECTION.v_current_date,
631: MSC_CL_COLLECTION.v_current_user,
632: MSC_CL_COLLECTION.v_current_date,
625: EXECUTE IMMEDIATE lv_sql_stmt
626: USING
627: MSC_CL_COLLECTION.v_chr10,
628: MSC_CL_COLLECTION.v_chr13,
629: MSC_CL_COLLECTION.v_last_collection_id,
630: MSC_CL_COLLECTION.v_current_date,
631: MSC_CL_COLLECTION.v_current_user,
632: MSC_CL_COLLECTION.v_current_date,
633: MSC_CL_COLLECTION.v_current_user;
626: USING
627: MSC_CL_COLLECTION.v_chr10,
628: MSC_CL_COLLECTION.v_chr13,
629: MSC_CL_COLLECTION.v_last_collection_id,
630: MSC_CL_COLLECTION.v_current_date,
631: MSC_CL_COLLECTION.v_current_user,
632: MSC_CL_COLLECTION.v_current_date,
633: MSC_CL_COLLECTION.v_current_user;
634:
627: MSC_CL_COLLECTION.v_chr10,
628: MSC_CL_COLLECTION.v_chr13,
629: MSC_CL_COLLECTION.v_last_collection_id,
630: MSC_CL_COLLECTION.v_current_date,
631: MSC_CL_COLLECTION.v_current_user,
632: MSC_CL_COLLECTION.v_current_date,
633: MSC_CL_COLLECTION.v_current_user;
634:
635:
628: MSC_CL_COLLECTION.v_chr13,
629: MSC_CL_COLLECTION.v_last_collection_id,
630: MSC_CL_COLLECTION.v_current_date,
631: MSC_CL_COLLECTION.v_current_user,
632: MSC_CL_COLLECTION.v_current_date,
633: MSC_CL_COLLECTION.v_current_user;
634:
635:
636: COMMIT;
629: MSC_CL_COLLECTION.v_last_collection_id,
630: MSC_CL_COLLECTION.v_current_date,
631: MSC_CL_COLLECTION.v_current_user,
632: MSC_CL_COLLECTION.v_current_date,
633: MSC_CL_COLLECTION.v_current_user;
634:
635:
636: COMMIT;
637:
673: msd.SR_INSTANCE_ID,
674: msd.ORGANIZATION_ID
675: FROM MSC_ITEM_ID_LID t1,
676: MSC_ST_DEMANDS msd
677: WHERE msd.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
678: AND msd.ORIGINATION_TYPE = 77
679: AND msd.DELETED_FLAG= MSC_UTIL.SYS_YES
680: AND t1.SR_INVENTORY_ITEM_ID(+)= msd.inventory_item_id
681: AND t1.sr_instance_id(+)= MSC_CL_COLLECTION.v_instance_id;*/
677: WHERE msd.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
678: AND msd.ORIGINATION_TYPE = 77
679: AND msd.DELETED_FLAG= MSC_UTIL.SYS_YES
680: AND t1.SR_INVENTORY_ITEM_ID(+)= msd.inventory_item_id
681: AND t1.sr_instance_id(+)= MSC_CL_COLLECTION.v_instance_id;*/
682:
683: lv_DISPOSITION_ID NUMBER;
684: lv_INVENTORY_ITEM_ID NUMBER;
685: lv_ORGANIZATION_ID NUMBER;
714: lv_data_sql_stmt VARCHAR2(1000);
715:
716: BEGIN
717:
718: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN -- incremental Refresh
719:
720: lv_del_stmt := 'SELECT msd1.WIP_ENTITY_ID,
721: msd1.OPERATION_SEQ_NUM,
722: t1.INVENTORY_ITEM_ID,
724: msd1.SR_INSTANCE_ID,
725: msd1.ORGANIZATION_ID
726: FROM MSC_ITEM_ID_LID t1,
727: MSC_ST_DEMANDS msd1
728: WHERE msd1.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
729: ||' AND msd1.ORIGINATION_TYPE = 77
730: AND msd1.DELETED_FLAG= '|| MSC_UTIL.SYS_YES
731: ||' AND t1.SR_INVENTORY_ITEM_ID(+)= msd1.inventory_item_id
732: AND t1.sr_instance_id(+)= '||MSC_CL_COLLECTION.v_instance_id ;
728: WHERE msd1.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
729: ||' AND msd1.ORIGINATION_TYPE = 77
730: AND msd1.DELETED_FLAG= '|| MSC_UTIL.SYS_YES
731: ||' AND t1.SR_INVENTORY_ITEM_ID(+)= msd1.inventory_item_id
732: AND t1.sr_instance_id(+)= '||MSC_CL_COLLECTION.v_instance_id ;
733:
734: if MSC_CL_COLLECTION.v_is_legacy_refresh then
735: lv_del_stmt:=lv_del_stmt ||' AND msd1.ENTITY=''ERO''';
736: else
730: AND msd1.DELETED_FLAG= '|| MSC_UTIL.SYS_YES
731: ||' AND t1.SR_INVENTORY_ITEM_ID(+)= msd1.inventory_item_id
732: AND t1.sr_instance_id(+)= '||MSC_CL_COLLECTION.v_instance_id ;
733:
734: if MSC_CL_COLLECTION.v_is_legacy_refresh then
735: lv_del_stmt:=lv_del_stmt ||' AND msd1.ENTITY=''ERO''';
736: else
737: lv_del_stmt:=lv_del_stmt ||' AND msd1.ORGANIZATION_ID '||MSC_UTIL.v_non_depot_org_str;
738: end if ;
754:
755: UPDATE MSC_DEMANDS
756: SET USING_REQUIREMENT_QUANTITY= 0,
757: DAILY_DEMAND_RATE= 0,
758: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
759: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
760: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
761: WHERE PLAN_ID= -1
762: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
755: UPDATE MSC_DEMANDS
756: SET USING_REQUIREMENT_QUANTITY= 0,
757: DAILY_DEMAND_RATE= 0,
758: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
759: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
760: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
761: WHERE PLAN_ID= -1
762: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
763: AND ORIGINATION_TYPE= lv_ORIGINATION_TYPE
756: SET USING_REQUIREMENT_QUANTITY= 0,
757: DAILY_DEMAND_RATE= 0,
758: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
759: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
760: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
761: WHERE PLAN_ID= -1
762: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
763: AND ORIGINATION_TYPE= lv_ORIGINATION_TYPE
764: AND WIP_ENTITY_ID= lv_WIP_ENTITY_ID
772:
773: c_count:=0;
774:
775: -- ========= Prepare the Cursor Statement ==========
776: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
777: lv_tbl:= 'DEMANDS_'||MSC_CL_COLLECTION.v_instance_code;
778: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
779: ELSE
780: lv_tbl:= 'MSC_DEMANDS';
773: c_count:=0;
774:
775: -- ========= Prepare the Cursor Statement ==========
776: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
777: lv_tbl:= 'DEMANDS_'||MSC_CL_COLLECTION.v_instance_code;
778: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
779: ELSE
780: lv_tbl:= 'MSC_DEMANDS';
781: lv_supplies_tbl:= 'MSC_SUPPLIES';
774:
775: -- ========= Prepare the Cursor Statement ==========
776: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
777: lv_tbl:= 'DEMANDS_'||MSC_CL_COLLECTION.v_instance_code;
778: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
779: ELSE
780: lv_tbl:= 'MSC_DEMANDS';
781: lv_supplies_tbl:= 'MSC_SUPPLIES';
782: END IF;
837: ||' MSC_ITEM_ID_LID t2,'
838: ||' MSC_ITEM_ID_LID t3,'
839: || lv_supplies_tbl||' ms,'
840: ||' MSC_ST_DEMANDS msd'
841: ||' WHERE msd.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
842: ||' AND msd.ORIGINATION_TYPE = 77' /* 50 eam demand: ds change change SRP Change 5909379*/
843: ||' AND msd.DELETED_FLAG= '||MSC_UTIL.SYS_NO
844: ||' AND t1.SR_INVENTORY_ITEM_ID= msd.inventory_item_id'
845: ||' AND t1.sr_instance_id= msd.SR_INSTANCE_ID'
852: ||' AND ms.DISPOSITION_ID= msd.wip_entity_id '
853: ||' AND ms.plan_id=-1'
854: ||' AND ms.ORDER_TYPE= 86'; /* ds change change*/
855:
856: IF NOT MSC_CL_COLLECTION.v_is_incremental_refresh THEN
857: lv_sql_stmt:=
858: 'INSERT /*+ APPEND */ INTO '||lv_tbl
859: ||'( PLAN_ID,'
860: ||' DEMAND_ID,'
901:
902:
903: EXECUTE IMMEDIATE lv_sql_stmt
904: USING
905: MSC_CL_COLLECTION.v_chr10,
906: MSC_CL_COLLECTION.v_chr13,
907: MSC_CL_COLLECTION.v_last_collection_id,
908: MSC_CL_COLLECTION.v_current_date,
909: MSC_CL_COLLECTION.v_current_user,
902:
903: EXECUTE IMMEDIATE lv_sql_stmt
904: USING
905: MSC_CL_COLLECTION.v_chr10,
906: MSC_CL_COLLECTION.v_chr13,
907: MSC_CL_COLLECTION.v_last_collection_id,
908: MSC_CL_COLLECTION.v_current_date,
909: MSC_CL_COLLECTION.v_current_user,
910: MSC_CL_COLLECTION.v_current_date,
903: EXECUTE IMMEDIATE lv_sql_stmt
904: USING
905: MSC_CL_COLLECTION.v_chr10,
906: MSC_CL_COLLECTION.v_chr13,
907: MSC_CL_COLLECTION.v_last_collection_id,
908: MSC_CL_COLLECTION.v_current_date,
909: MSC_CL_COLLECTION.v_current_user,
910: MSC_CL_COLLECTION.v_current_date,
911: MSC_CL_COLLECTION.v_current_user;
904: USING
905: MSC_CL_COLLECTION.v_chr10,
906: MSC_CL_COLLECTION.v_chr13,
907: MSC_CL_COLLECTION.v_last_collection_id,
908: MSC_CL_COLLECTION.v_current_date,
909: MSC_CL_COLLECTION.v_current_user,
910: MSC_CL_COLLECTION.v_current_date,
911: MSC_CL_COLLECTION.v_current_user;
912:
905: MSC_CL_COLLECTION.v_chr10,
906: MSC_CL_COLLECTION.v_chr13,
907: MSC_CL_COLLECTION.v_last_collection_id,
908: MSC_CL_COLLECTION.v_current_date,
909: MSC_CL_COLLECTION.v_current_user,
910: MSC_CL_COLLECTION.v_current_date,
911: MSC_CL_COLLECTION.v_current_user;
912:
913:
906: MSC_CL_COLLECTION.v_chr13,
907: MSC_CL_COLLECTION.v_last_collection_id,
908: MSC_CL_COLLECTION.v_current_date,
909: MSC_CL_COLLECTION.v_current_user,
910: MSC_CL_COLLECTION.v_current_date,
911: MSC_CL_COLLECTION.v_current_user;
912:
913:
914: COMMIT;
907: MSC_CL_COLLECTION.v_last_collection_id,
908: MSC_CL_COLLECTION.v_current_date,
909: MSC_CL_COLLECTION.v_current_user,
910: MSC_CL_COLLECTION.v_current_date,
911: MSC_CL_COLLECTION.v_current_user;
912:
913:
914: COMMIT;
915:
927: END;
928: END IF; --v_is_complete_refresh
929:
930: --==========================
931: IF MSC_CL_COLLECTION.v_is_incremental_refresh THEN -- incremental Refresh
932: -- ========= Prepare SQL Statement for INSERT ==========
933: lv_sql_stmt:=
934: 'INSERT INTO '||lv_tbl
935: ||'( PLAN_ID,'
1050: ||' MSC_ITEM_ID_LID t2,'
1051: ||' MSC_ITEM_ID_LID t3,'
1052: || lv_supplies_tbl||' ms,'
1053: ||' MSC_ST_DEMANDS msd'
1054: ||' WHERE msd.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
1055: ||' AND msd.ORIGINATION_TYPE = 77' /* 50 eam demand: ds change change*/
1056: ||' AND msd.DELETED_FLAG= '||MSC_UTIL.SYS_NO
1057: ||' AND t1.SR_INVENTORY_ITEM_ID= msd.inventory_item_id'
1058: ||' AND t1.sr_instance_id= msd.SR_INSTANCE_ID'
1066: ||' AND ms.plan_id=-1'
1067: ||' AND ms.ORDER_TYPE= 86' /* ds change change*/
1068: ||' order by msd.SOURCE_WIP_ENTITY_ID, msd.SOURCE_INVENTORY_ITEM_ID,msd.SOURCE_ORGANIZATION_ID,msd.ORIGINATION_TYPE';
1069:
1070: OPEN c2 FOR lv_cursor_stmt USING MSC_CL_COLLECTION.v_chr10, MSC_CL_COLLECTION.v_chr13;
1071:
1072: LOOP
1073:
1074: FETCH c2 INTO
1132: WIP_SUPPLY_TYPE= lv_WIP_SUPPLY_TYPE,
1133: DISPOSITION_ID= lv_DISPOSITION_ID,
1134: COMPONENT_SCALING_TYPE = lv_COMPONENT_SCALING_TYPE, /* Discrete Mfg Enahancements Bug 4492736 */
1135: COMPONENT_YIELD_FACTOR = lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
1136: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1137: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1138: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1139: WHERE PLAN_ID= -1
1140: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
1133: DISPOSITION_ID= lv_DISPOSITION_ID,
1134: COMPONENT_SCALING_TYPE = lv_COMPONENT_SCALING_TYPE, /* Discrete Mfg Enahancements Bug 4492736 */
1135: COMPONENT_YIELD_FACTOR = lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
1136: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1137: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1138: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1139: WHERE PLAN_ID= -1
1140: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
1141: AND ORIGINATION_TYPE= lv_ORIGINATION_TYPE
1134: COMPONENT_SCALING_TYPE = lv_COMPONENT_SCALING_TYPE, /* Discrete Mfg Enahancements Bug 4492736 */
1135: COMPONENT_YIELD_FACTOR = lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
1136: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1137: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1138: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1139: WHERE PLAN_ID= -1
1140: AND SR_INSTANCE_ID= lv_SR_INSTANCE_ID
1141: AND ORIGINATION_TYPE= lv_ORIGINATION_TYPE
1142: AND ORGANIZATION_ID= lv_ORGANIZATION_ID
1182: lv_COMPONENT_SCALING_TYPE, /* Discrete Mfg Enahancements Bug 4492736 */
1183: lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
1184: lv_item_type_id,
1185: lv_item_type_value,
1186: MSC_CL_COLLECTION.v_last_collection_id,
1187: MSC_CL_COLLECTION.v_current_date,
1188: MSC_CL_COLLECTION.v_current_user,
1189: MSC_CL_COLLECTION.v_current_date,
1190: MSC_CL_COLLECTION.v_current_user;
1183: lv_COMPONENT_YIELD_FACTOR, /* Discrete Mfg Enahancements Bug 4492743 */
1184: lv_item_type_id,
1185: lv_item_type_value,
1186: MSC_CL_COLLECTION.v_last_collection_id,
1187: MSC_CL_COLLECTION.v_current_date,
1188: MSC_CL_COLLECTION.v_current_user,
1189: MSC_CL_COLLECTION.v_current_date,
1190: MSC_CL_COLLECTION.v_current_user;
1191:
1184: lv_item_type_id,
1185: lv_item_type_value,
1186: MSC_CL_COLLECTION.v_last_collection_id,
1187: MSC_CL_COLLECTION.v_current_date,
1188: MSC_CL_COLLECTION.v_current_user,
1189: MSC_CL_COLLECTION.v_current_date,
1190: MSC_CL_COLLECTION.v_current_user;
1191:
1192: END IF;
1185: lv_item_type_value,
1186: MSC_CL_COLLECTION.v_last_collection_id,
1187: MSC_CL_COLLECTION.v_current_date,
1188: MSC_CL_COLLECTION.v_current_user,
1189: MSC_CL_COLLECTION.v_current_date,
1190: MSC_CL_COLLECTION.v_current_user;
1191:
1192: END IF;
1193:
1186: MSC_CL_COLLECTION.v_last_collection_id,
1187: MSC_CL_COLLECTION.v_current_date,
1188: MSC_CL_COLLECTION.v_current_user,
1189: MSC_CL_COLLECTION.v_current_date,
1190: MSC_CL_COLLECTION.v_current_user;
1191:
1192: END IF;
1193:
1194: EXCEPTION
1206: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1207: RAISE;
1208:
1209: ELSE
1210: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
1211:
1212: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
1213:
1214: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1219: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1220: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
1221: FND_MESSAGE.SET_TOKEN('VALUE',
1222: MSC_GET_NAME.ORG_CODE( lv_ORGANIZATION_ID,
1223: MSC_CL_COLLECTION.v_instance_id));
1224: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1225:
1226: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
1227: FND_MESSAGE.SET_TOKEN('COLUMN', 'DEMAND_TYPE');
1240: END;
1241:
1242: c_count:= c_count+1;
1243:
1244: IF c_count> MSC_CL_COLLECTION.PBS THEN
1245: c_count:= 0;
1246: END IF;
1247: END LOOP; -- cursor c2
1248:
1247: END LOOP; -- cursor c2
1248:
1249: CLOSE c2;
1250:
1251: END IF; -- MSC_CL_COLLECTION.v_is_incremental_refresh THEN -- incremental Refresh
1252: --==========================
1253: EXCEPTION
1254: WHEN OTHERS THEN
1255: IF c2%ISOPEN THEN CLOSE c2; END IF;