12: v_temp_sql3 VARCHAR2(1000);
13: v_temp_sql4 VARCHAR2(1000);
14:
15: -- NULL_DBLINK CONSTANT VARCHAR2(1):= ' ';
16: -- NULL_DBLINK CONSTANT VARCHAR2(1) :=MSC_UTIL.NULL_DBLINK;
17:
18: v_msc_so_offset_days NUMBER := NVL(FND_PROFILE.VALUE('MSC_SO_OFFSET_DAYS'),99999);
19: v_msc_x_vmi_om_order_type varchar2(50) := FND_PROFILE.VALUE('MSC_X_VMI_OM_ORDER_TYPE');
20:
23: PROCEDURE LOAD_FORECASTS IS
24:
25: BEGIN
26:
27: IF MSC_CL_PULL.FORECAST_ENABLED= MSC_UTIL.SYS_YES THEN
28:
29: MSC_CL_PULL.v_table_name:= 'MSC_ST_DESIGNATORS';
30: MSC_CL_PULL.v_view_name := 'MRP_AP_FORECAST_DSGN_V';
31:
74: ||' 2,'
75: ||' :v_refresh_id,'
76: ||' :v_instance_id'
77: ||' from MRP_AP_FORECAST_DSGN_V'||MSC_CL_PULL.v_dblink||' x'
78: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
79: ||' AND x.RN1>'||MSC_CL_PULL.v_lrn;
80:
81: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
82:
102: ||' 1,'
103: ||' :v_refresh_id,'
104: ||' :v_instance_id'
105: ||' from MRP_AD_FORECAST_DSGN_V'||MSC_CL_PULL.v_dblink||' x'
106: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
107: ||' AND x.RN> '||MSC_CL_PULL.v_lrn
108: ||' AND x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str;
109:
110:
104: ||' :v_instance_id'
105: ||' from MRP_AD_FORECAST_DSGN_V'||MSC_CL_PULL.v_dblink||' x'
106: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
107: ||' AND x.RN> '||MSC_CL_PULL.v_lrn
108: ||' AND x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str;
109:
110:
111: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
112:
120:
121: PROCEDURE LOAD_ITEM_FORECASTS IS
122: BEGIN
123:
124: IF MSC_CL_PULL.FORECAST_ENABLED = MSC_UTIL.SYS_YES THEN
125:
126: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
127:
128: MSC_CL_PULL.v_table_name:= 'MSC_ST_DEMANDS';
147: ||' 1,'
148: ||' :v_refresh_id,'
149: ||' :v_instance_id'
150: ||' from MRP_AD_FORECAST_DEMAND_V'||MSC_CL_PULL.v_dblink||' x'
151: ||' WHERE x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str
152: ||' AND x.RN>'||MSC_CL_PULL.v_lrn;
153:
154: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
155:
193: ||' x.FORECAST_DATE,'
194: ||' x.RATE_END_DATE,'
195: ||' x.ORIGINAL_FORECAST_QUANTITY,'
196: ||' x.DEMAND_CLASS,'
197: -- for bug13562886 ,there are some junk date time value in the AttributeX column ,so use MSC_UTIL.MSC_NUMVAL to filter those date time value.
198: ||' MSC_UTIL.MSC_NUMVAL(DECODE( :v_msc_fcst_priority_flex_num,'
199: ||' 1, x.Attribute1,'
200: ||' 2, x.Attribute2,'
201: ||' 3, x.Attribute3,'
194: ||' x.RATE_END_DATE,'
195: ||' x.ORIGINAL_FORECAST_QUANTITY,'
196: ||' x.DEMAND_CLASS,'
197: -- for bug13562886 ,there are some junk date time value in the AttributeX column ,so use MSC_UTIL.MSC_NUMVAL to filter those date time value.
198: ||' MSC_UTIL.MSC_NUMVAL(DECODE( :v_msc_fcst_priority_flex_num,'
199: ||' 1, x.Attribute1,'
200: ||' 2, x.Attribute2,'
201: ||' 3, x.Attribute3,'
202: ||' 4, x.Attribute4,'
226: ||' x.PLANNING_GROUP,'
227: ||' :v_instance_id,'
228: ||' x.TRANSACTION_ID '
229: ||' from MRP_AP_FORECAST_DEMAND_V'||MSC_CL_PULL.v_dblink||' x'
230: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
231: ||' AND x.RN1>'||MSC_CL_PULL.v_lrn;
232:
233:
234: EXECUTE IMMEDIATE v_sql_stmt
246:
247: PROCEDURE LOAD_MDS_DEMAND IS
248: BEGIN
249:
250: IF MSC_CL_PULL.MDS_ENABLED= MSC_UTIL.SYS_YES THEN
251:
252: --=================== Net Change Mode: Delete ==================
253:
254: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
276: ||' :v_refresh_id,'
277: ||' :v_instance_id'
278: ||' from MRP_AD_MDS_DEMANDS_V'||MSC_CL_PULL.v_dblink||' x'
279: ||' WHERE x.RN>'||MSC_CL_PULL.v_lrn
280: ||' AND x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str;
281:
282: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
283:
284: COMMIT;
284: COMMIT;
285:
286: END IF;
287:
288: IF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115) THEN
289:
290: v_temp_sql := 'x.original_system_line_reference,x.original_system_reference,x.demand_source_type,x.demand_class,x.PROMISE_DATE,x.LINK_TO_LINE_ID,x.ORDER_DATE_TYPE_CODE,x.SCHEDULE_ARRIVAL_DATE,x.LATEST_ACCEPTABLE_DATE,x.SHIPPING_METHOD_CODE, ';
291:
292:
309: ||' 15, x.Attribute15,NULL),'
310: ||' 3,x.LATE_DEMAND_PENALTY_FACTOR) ), ';
311: ELSE
312:
313: IF (MSC_CL_PULL.v_apps_ver = MSC_UTIL.G_APPS110) THEN
314: v_temp_sql :='x.original_system_line_reference ,x.original_system_reference,x.demand_source_type,NULL,x.PROMISE_DATE,NULL,';
315: ELSE
316: v_temp_sql :=' NULL, NULL,NULL,NULL,NULL,NULL,NULL, NULL,NULL,NULL, ';
317: END IF;
408: || v_temp_sql
409: ||' :v_refresh_id,'
410: ||' :v_instance_id'
411: ||' from MRP_AP_MDS_DEMANDS_V'||MSC_CL_PULL.v_dblink||' x'
412: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
413: ||' AND ( x.RN3>'||MSC_CL_PULL.v_lrn||')'; --NCP: changed to RN3
414:
415: ELSE
416: v_union_sql :=
528: || v_temp_sql
529: ||' :v_refresh_id,'
530: ||' :v_instance_id'
531: ||' from MRP_AP_MDS_DEMANDS_V'||MSC_CL_PULL.v_dblink||' x'
532: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
533: || v_union_sql ;
534:
535: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
536: IF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115) THEN
532: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
533: || v_union_sql ;
534:
535: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
536: IF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115) THEN
537: EXECUTE IMMEDIATE v_sql_stmt
538: USING MSC_CL_PULL.v_dgmt,
539: MSC_CL_PULL.v_dgmt,
540: MSC_CL_PULL.v_dgmt,
573: MSC_CL_PULL.v_instance_id;
574: END IF;
575:
576: ELSE -- Targeted - Complete Refresh collections
577: IF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115) THEN
578: EXECUTE IMMEDIATE v_sql_stmt
579: USING MSC_CL_PULL.v_dgmt,
580: MSC_CL_PULL.v_dgmt,
581: MSC_CL_PULL.v_dgmt,
618:
619: v_union_sql := ' ';
620: v_temp_sql4 := NULL;
621:
622: if(MSC_CL_PULL.v_apps_ver>= MSC_UTIL.G_APPS115) then
623: v_temp_sql1:='x.SCHEDULE_ARRIVAL_DATE,x.LATEST_ACCEPTABLE_DATE,x.SHIPPING_METHOD_CODE,x.ATO_LINE_ID,x.ORDER_DATE_TYPE_CODE,x.DELIVERY_LEAD_TIME ';
624: else
625: v_temp_sql1:='NULL,NULL,NULL,NULL,NULL,NULL ';
626: end if;
624: else
625: v_temp_sql1:='NULL,NULL,NULL,NULL,NULL,NULL ';
626: end if;
627:
628: IF MSC_CL_PULL.v_apps_ver>= MSC_UTIL.G_APPS121 THEN
629: v_temp_sql10 := ' DECODE(x.OSP_FLAG , ''Y'',''N'',''N'', ''Y'',''Y''), ' ;
630: v_temp_sql11 := ' DECODE(x.OSP_FLAG,''Y'',' ||MSC_UTIL.G_PARTCONDN_ITEMTYPEID || '),'
631: ||' DECODE(x.OSP_FLAG , ''Y'',2,''N'', NULL), ' ;
632:
626: end if;
627:
628: IF MSC_CL_PULL.v_apps_ver>= MSC_UTIL.G_APPS121 THEN
629: v_temp_sql10 := ' DECODE(x.OSP_FLAG , ''Y'',''N'',''N'', ''Y'',''Y''), ' ;
630: v_temp_sql11 := ' DECODE(x.OSP_FLAG,''Y'',' ||MSC_UTIL.G_PARTCONDN_ITEMTYPEID || '),'
631: ||' DECODE(x.OSP_FLAG , ''Y'',2,''N'', NULL), ' ;
632:
633: ELSE
634:
646: if (lv_complete_ref = 1 and lv_so_param = 2 ) then
647: lv_net_sales_order := 1;
648: end if;
649:
650: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'lv_net_sales :'||lv_net_sales_order);
651:
652: IF ( p_worker_num = 3) THEN
653:
654: IF MSC_CL_PULL.v_so_lrn<> -1 THEN -- incremental refresh
657: MSC_CL_PULL.v_view_name := 'MRP_AD_SALES_ORDERS_V';
658:
659: Begin
660:
661: IF MSC_CL_PULL.v_apps_ver = MSC_UTIL.G_APPS107 THEN
662: v_temp_sql:= ' 2 ,';
663: ELSE
664: v_temp_sql:= ' x.CTO_FLAG,';
665: END IF ;
667:
668: End;
669: /*Added By raraghav */
670:
671: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
672: lv_temp_sql := ' AND x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
673: ELSE
674: lv_temp_sql := NULL;
675: END IF;
668: End;
669: /*Added By raraghav */
670:
671: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
672: lv_temp_sql := ' AND x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
673: ELSE
674: lv_temp_sql := NULL;
675: END IF;
676:
698: ||' from MRP_AD_HARD_RESERVATIONS_V'||MSC_CL_PULL.v_dblink||' x'
699: ||' where x.RN> :v_so_sr_lrn '
700: || lv_temp_sql;
701:
702: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,v_sql_stmt);
703: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id, MSC_CL_PULL.v_so_lrn;
704:
705: COMMIT;
706:
725: ||' :v_instance_id'
726: ||' from MRP_AD_SALES_ORDERS_V'||MSC_CL_PULL.v_dblink||' x'
727: ||' WHERE x.RN> :v_so_lrn '
728: || lv_temp_sql;
729: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,v_sql_stmt);
730: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id, MSC_CL_PULL.v_so_lrn;
731:
732: COMMIT;
733:
734: END IF; --- MSC_CL_PULL.v_lrnn<> -1
735:
736: MSC_CL_PULL.v_table_name:= 'MSC_ST_SALES_ORDERS';
737:
738: IF MSC_CL_PULL.v_apps_ver < MSC_UTIL.G_APPS115 THEN -- 107 or 110 source instance
739: MSC_CL_PULL.v_view_name := 'MRP_AP_SALES_ORDERS_V';
740: v_temp_sql3 := ' AND (x.RN1 > :v_lrn OR x.RN2> :v_lrn OR x.RN3> :v_lrn )';
741:
742: /* Changed for the fix 2521038, */
777: IF (MSC_CL_PULL.v_so_lrn<> -1 )
778: THEN -- incremental refresh or complete with SO No
779: MSC_CL_PULL.v_view_name := 'MRP_AN'||p_worker_num||'_SALES_ORDERS_V';
780:
781: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Coming here :'||lv_net_sales_order);
782: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Coming here :'||MSC_CL_PULL.v_so_lrn);
783: if p_worker_num <> 2 then
784: if p_worker_num = 1 then
785: v_temp_sql3 := ' AND (x.RN1 > :v_so_lrn OR x.RN2> :v_so_lrn OR x.RN3> :v_so_lrn )';
778: THEN -- incremental refresh or complete with SO No
779: MSC_CL_PULL.v_view_name := 'MRP_AN'||p_worker_num||'_SALES_ORDERS_V';
780:
781: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Coming here :'||lv_net_sales_order);
782: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Coming here :'||MSC_CL_PULL.v_so_lrn);
783: if p_worker_num <> 2 then
784: if p_worker_num = 1 then
785: v_temp_sql3 := ' AND (x.RN1 > :v_so_lrn OR x.RN2> :v_so_lrn OR x.RN3> :v_so_lrn )';
786: /* elsif p_worker_num = 3 then
821: ||v_temp_sql10
822: ||' x.DEMAND_VISIBLE,'
823: ||' x.SALESREP_CONTACT,';
824:
825: if MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 then
826: v_union_sql := v_union_sql ||' x.SALESREP_ID,';
827: else
828: v_union_sql := v_union_sql ||' NULL,';
829: end if;
861: ||' :v_refresh_id,'
862: ||' :v_instance_id, '
863: || v_temp_sql1
864: ||' FROM '||MSC_CL_PULL.v_view_name||MSC_CL_PULL.v_dblink||' x'
865: ||' WHERE x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str
866: || v_temp_sql2
867: ||' and ( x.rn1 > :v_so_lrn ) ' ; /*10201485*/
868:
869: v_temp_sql3 := ' AND (x.RN1 > :v_so_lrn ) ';
879: v_temp_sql := ' x.END_ITEM_UNIT_NUMBER , x.ordered_item_id,x.ORIGINAL_INVENTORY_ITEM_ID , '
880: ||' x.LINK_TO_LINE_ID, x.cust_po_number,x.customer_line_number,x.MFG_LEAD_TIME,x.FIRM_DEMAND_FLAG,x.SHIP_SET_ID,x.ARRIVAL_SET_ID,x.SHIP_SET_NAME,x.ARRIVAL_SET_NAME, ';
881:
882: IF (p_worker_num = 2 AND -- Bug 4245915
883: MSC_CL_PULL.v_apps_ver>= MSC_UTIL.G_APPS120) THEN --bug#5684183 (bcaru)
884: v_temp_sql4 := ' AND ( x.visible_demand_flag = ''Y'' OR (x.visible_demand_flag = ''N'' AND x.order_type='''||v_msc_x_vmi_om_order_type||''')) ';
885: END IF;
886:
887: END IF; --- (p_worker_num = 4 ) condition
886:
887: END IF; --- (p_worker_num = 4 ) condition
888:
889:
890: IF (MSC_CL_PULL.v_apps_ver= MSC_UTIL.G_APPS110 OR
891: MSC_CL_PULL.v_apps_ver>= MSC_UTIL.G_APPS115) THEN
892:
893: /* Changed for the fix 2521038, note the views MRP_AP_SALES_ORDERS_V and MRP_AN_SALES_ORDERS_V
894: have also been changed for this. Only if the source is 115 the new columns ORIGINAL_ORDERED_QUANTITY,
887: END IF; --- (p_worker_num = 4 ) condition
888:
889:
890: IF (MSC_CL_PULL.v_apps_ver= MSC_UTIL.G_APPS110 OR
891: MSC_CL_PULL.v_apps_ver>= MSC_UTIL.G_APPS115) THEN
892:
893: /* Changed for the fix 2521038, note the views MRP_AP_SALES_ORDERS_V and MRP_AN_SALES_ORDERS_V
894: have also been changed for this. Only if the source is 115 the new columns ORIGINAL_ORDERED_QUANTITY,
895: ORIGINAL_COMPLETED_QUANTITY are applicable.
894: have also been changed for this. Only if the source is 115 the new columns ORIGINAL_ORDERED_QUANTITY,
895: ORIGINAL_COMPLETED_QUANTITY are applicable.
896: */
897:
898: IF MSC_CL_PULL.v_apps_ver = MSC_UTIL.G_APPS110 THEN
899:
900: v_temp_sql2 := ' AND (x.PRIMARY_UOM_QUANTITY > x.COMPLETED_QUANTITY '
901: ||' OR (x.PRIMARY_UOM_QUANTITY = x.COMPLETED_QUANTITY ';
902:
901: ||' OR (x.PRIMARY_UOM_QUANTITY = x.COMPLETED_QUANTITY ';
902:
903: v_temp_sql2 := v_temp_sql2 ||' AND x.requirement_date >= trunc( sysdate - (' || v_msc_so_offset_days ||' )))) ';
904:
905: END IF; /* MSC_UTIL.G_APPS110 */
906:
907: IF MSC_CL_PULL.v_apps_ver>= MSC_UTIL.G_APPS115 AND (p_worker_num <> 2) THEN
908: IF (MSC_CL_PULL.v_so_lrn <> -1) THEN -- incremental collections
909: v_temp_sql2 := ' AND (x.ORIGINAL_ORDERED_QUANTITY >= x.ORIGINAL_COMPLETED_QUANTITY) ';
903: v_temp_sql2 := v_temp_sql2 ||' AND x.requirement_date >= trunc( sysdate - (' || v_msc_so_offset_days ||' )))) ';
904:
905: END IF; /* MSC_UTIL.G_APPS110 */
906:
907: IF MSC_CL_PULL.v_apps_ver>= MSC_UTIL.G_APPS115 AND (p_worker_num <> 2) THEN
908: IF (MSC_CL_PULL.v_so_lrn <> -1) THEN -- incremental collections
909: v_temp_sql2 := ' AND (x.ORIGINAL_ORDERED_QUANTITY >= x.ORIGINAL_COMPLETED_QUANTITY) ';
910:
911: ELSE
1025: ||v_temp_sql10
1026: ||' x.DEMAND_VISIBLE,'
1027: ||' x.SALESREP_CONTACT,';
1028:
1029: if MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 then
1030: v_sql_stmt := v_sql_stmt ||' x.SALESREP_ID,';
1031: else
1032: v_sql_stmt := v_sql_stmt ||' NULL,';
1033: end if;
1054: ||' :v_refresh_id,'
1055: ||' :v_instance_id,'
1056: || v_temp_sql1
1057: ||' FROM '||MSC_CL_PULL.v_view_name||MSC_CL_PULL.v_dblink||' x'
1058: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
1059: || v_temp_sql2
1060: || v_temp_sql3
1061: || v_temp_sql4
1062: || v_union_sql ;
1060: || v_temp_sql3
1061: || v_temp_sql4
1062: || v_union_sql ;
1063:
1064: IF MSC_CL_PULL.v_apps_ver < MSC_UTIL.G_APPS115 THEN
1065: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,v_sql_stmt);
1066: EXECUTE IMMEDIATE v_sql_stmt
1067: USING MSC_CL_PULL.v_refresh_id,
1068: MSC_CL_PULL.v_instance_id,
1061: || v_temp_sql4
1062: || v_union_sql ;
1063:
1064: IF MSC_CL_PULL.v_apps_ver < MSC_UTIL.G_APPS115 THEN
1065: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,v_sql_stmt);
1066: EXECUTE IMMEDIATE v_sql_stmt
1067: USING MSC_CL_PULL.v_refresh_id,
1068: MSC_CL_PULL.v_instance_id,
1069: MSC_CL_PULL.v_so_lrn,
1073: ELSE -- 11i source instance
1074:
1075: IF (MSC_CL_PULL.v_so_lrn <> -1) THEN -- incremental collections
1076: if (p_worker_num = 2) then
1077: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_2,v_sql_stmt);
1078: EXECUTE IMMEDIATE v_sql_stmt
1079: USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id, MSC_CL_PULL.v_so_lrn,
1080: MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id, MSC_CL_PULL.v_so_lrn;
1081: elsif (p_worker_num in (3)) then
1078: EXECUTE IMMEDIATE v_sql_stmt
1079: USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id, MSC_CL_PULL.v_so_lrn,
1080: MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id, MSC_CL_PULL.v_so_lrn;
1081: elsif (p_worker_num in (3)) then
1082: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_2,v_sql_stmt);
1083: EXECUTE IMMEDIATE v_sql_stmt USING
1084: MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id
1085: ,MSC_CL_PULL.v_so_lrn,MSC_CL_PULL.v_so_lrn;
1086:
1084: MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id
1085: ,MSC_CL_PULL.v_so_lrn,MSC_CL_PULL.v_so_lrn;
1086:
1087: else
1088: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_2,v_sql_stmt);
1089: EXECUTE IMMEDIATE v_sql_stmt
1090: USING MSC_CL_PULL.v_refresh_id,
1091: MSC_CL_PULL.v_instance_id,
1092: MSC_CL_PULL.v_so_lrn,
1094: MSC_CL_PULL.v_so_lrn;
1095: end if;
1096:
1097: ELSE --- complete/targeted collections
1098: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_2,v_sql_stmt);
1099: EXECUTE IMMEDIATE v_sql_stmt
1100: USING MSC_CL_PULL.v_refresh_id,
1101: MSC_CL_PULL.v_instance_id;
1102: END IF;
1165: ||' x.TASK_ID,'
1166: ||' x.PLANNING_GROUP,'
1167: ||' :v_instance_id'
1168: ||' FROM MRP_AP_SALES_ORDERS_V'||MSC_CL_PULL.v_dblink||' x'
1169: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
1170: ||' AND (x.RN1>'||MSC_CL_PULL.v_so_lrn
1171: ||' OR x.RN2>'||MSC_CL_PULL.v_so_lrn
1172: ||' OR x.RN3>'||MSC_CL_PULL.v_so_lrn||')';
1173:
1170: ||' AND (x.RN1>'||MSC_CL_PULL.v_so_lrn
1171: ||' OR x.RN2>'||MSC_CL_PULL.v_so_lrn
1172: ||' OR x.RN3>'||MSC_CL_PULL.v_so_lrn||')';
1173:
1174: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_2,v_sql_stmt);
1175: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
1176:
1177: END IF;
1178: COMMIT;
1183:
1184: PROCEDURE LOAD_HARD_RESERVATION IS
1185: BEGIN
1186:
1187: IF MSC_CL_PULL.HARD_RESRVS_ENABLED= MSC_UTIL.SYS_YES THEN
1188:
1189: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
1190:
1191: MSC_CL_PULL.v_table_name:= 'MSC_ST_RESERVATIONS';
1190:
1191: MSC_CL_PULL.v_table_name:= 'MSC_ST_RESERVATIONS';
1192: MSC_CL_PULL.v_view_name := 'MRP_AD_HARD_RESERVATIONS_V';
1193:
1194: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
1195: v_temp_sql := ' AND x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1196: ELSE
1197: v_temp_sql := NULL;
1198: END IF;
1191: MSC_CL_PULL.v_table_name:= 'MSC_ST_RESERVATIONS';
1192: MSC_CL_PULL.v_view_name := 'MRP_AD_HARD_RESERVATIONS_V';
1193:
1194: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
1195: v_temp_sql := ' AND x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1196: ELSE
1197: v_temp_sql := NULL;
1198: END IF;
1199:
1217: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
1218:
1219: COMMIT;
1220: /* Changes For Bug 6147734 */
1221: if (MSC_UTIL.G_COLLECT_SRP_DATA='Y' AND MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS120) Then
1222: v_sql_stmt:=
1223: 'insert into MSC_ST_RESERVATIONS'
1224: ||' ( TRANSACTION_ID,'
1225: ||' SUPPLY_SOURCE_TYPE_ID,'
1253: COMMIT;
1254: End If; -- Srp Profile Check
1255: END IF; -- Incremental Refresh
1256:
1257: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
1258: v_temp_sql := ' AND x.GET_ORDERED_QUANTITY > x.GET_SHIPPED_QUANTITY ';
1259: ELSE
1260: v_temp_sql := ' ';
1261: END IF;
1259: ELSE
1260: v_temp_sql := ' ';
1261: END IF;
1262:
1263: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
1264: v_temp_sql1 := ' AND x.RN1 > :v_lrn';
1265: /* ds change */
1266: v_temp_sql2 := ' SUPPLY_SOURCE_HEADER_ID,SUPPLY_SOURCE_TYPE_ID, ';
1267: v_temp_sql3 := ' x.SUPPLY_SOURCE_HEADER_ID,x.SUPPLY_SOURCE_TYPE_ID, ';
1320: ||' 2,'
1321: ||' :v_refresh_id,'
1322: ||' :v_instance_id'
1323: ||' from MRP_AP_HARD_RESERVATIONS_V'||MSC_CL_PULL.v_dblink||' x'
1324: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str|| v_temp_sql || v_temp_sql1;
1325:
1326: /*||' AND (' -- NCP: x.RN1>'||MSC_CL_PULL.v_lrn
1327: ||' x.RN2>'||MSC_CL_PULL.v_lrn||')';
1328:
1333:
1334: --EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_dgmt, MSC_CL_PULL.V_ICODE, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
1335: -- EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
1336:
1337: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
1338: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id, MSC_CL_PULL.v_lrn;
1339: ELSE
1340: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id, MSC_CL_PULL.v_lrn, MSC_CL_PULL.v_lrn, MSC_CL_PULL.v_lrn, MSC_CL_PULL.v_lrn, MSC_CL_PULL.v_lrn, MSC_CL_PULL.v_lrn;
1341: END IF;
1342:
1343: COMMIT;
1344:
1345:
1346: if (MSC_UTIL.G_COLLECT_SRP_DATA='Y' AND MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS120) Then -- SRP Changes For Bug 5988024
1347:
1348: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
1349: v_temp_sql1 := ' OR x.date1 > :date1 OR x.date2 > :date2 ';
1350: ELSE
1384: ||' 2,'
1385: ||' :v_refresh_id,'
1386: ||' :v_instance_id'
1387: ||' from MRP_AP_REPAIR_TRANSFERS_RESV_V'||MSC_CL_PULL.v_dblink||' x'
1388: ||' WHERE x.ORGANIZATION_ID '||MSC_UTIL.v_depot_org_str
1389: ||' AND x.RN1 > :v_lrn'
1390: || v_temp_sql1;
1391:
1392:
1421: ||' 1,'
1422: ||' :v_refresh_id,'
1423: ||' :v_instance_id'
1424: ||' from MRP_AP_REPAIR_ORDERS_V'||MSC_CL_PULL.v_dblink ||' x'
1425: ||' where x.organization_id '||MSC_UTIL.v_depot_org_str
1426: || ' AND x.RO_STATUS_CODE = '||'''C'''
1427: ||' AND x. LAST_UPDATE_DATE > :date1' ;
1428:
1429:
1475: ||' 2,'
1476: ||' :v_refresh_id,'
1477: ||' :v_instance_id'
1478: ||' from MRP_AP_EXT_REP_RESERVATIONS_V'||MSC_CL_PULL.v_dblink||' x'
1479: ||' WHERE x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str
1480: ||' AND ((x.RN > :v_lrn) OR (x.RN1 > :v_lrn) OR (x.RN2 > :v_lrn) OR (x.RN3 > :v_lrn)
1481: OR (x.RN4 > :v_lrn) OR (x.RN5 > :v_lrn) OR (x.RN6 > :v_lrn))'
1482: ;
1483:
1503:
1504: PROCEDURE LOAD_USER_DEMAND IS
1505: BEGIN
1506:
1507: IF MSC_CL_PULL.v_apps_ver<> MSC_UTIL.G_APPS107 AND
1508: MSC_CL_PULL.v_apps_ver<> MSC_UTIL.G_APPS110 THEN
1509:
1510: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
1511:
1504: PROCEDURE LOAD_USER_DEMAND IS
1505: BEGIN
1506:
1507: IF MSC_CL_PULL.v_apps_ver<> MSC_UTIL.G_APPS107 AND
1508: MSC_CL_PULL.v_apps_ver<> MSC_UTIL.G_APPS110 THEN
1509:
1510: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
1511:
1512: MSC_CL_PULL.v_table_name:= 'MSC_ST_DEMANDS';
1511:
1512: MSC_CL_PULL.v_table_name:= 'MSC_ST_DEMANDS';
1513: MSC_CL_PULL.v_view_name := 'MRP_AD_USER_DEMANDS_V';
1514:
1515: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
1516: v_temp_sql := ' AND x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1517: ELSE
1518: v_temp_sql := NULL;
1519: END IF;
1512: MSC_CL_PULL.v_table_name:= 'MSC_ST_DEMANDS';
1513: MSC_CL_PULL.v_view_name := 'MRP_AD_USER_DEMANDS_V';
1514:
1515: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
1516: v_temp_sql := ' AND x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
1517: ELSE
1518: v_temp_sql := NULL;
1519: END IF;
1520:
1576: ||' 2,'
1577: ||' :v_refresh_id,'
1578: ||' :v_instance_id'
1579: ||' FROM MRP_AP_USER_DEMANDS_V'||MSC_CL_PULL.v_dblink||' x'
1580: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
1581: ||' AND (x.RN1>'||MSC_CL_PULL.v_lrn
1582: ||' OR x.RN2>'||MSC_CL_PULL.v_lrn||')';
1583:
1584: --EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.V_ICODE, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
1610: v_temp_sql3 := ' ';
1611:
1612: END IF;
1613:
1614: IF ((MSC_UTIL.g_collect_cmro_data = 'Y' and
1615: MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS121) OR
1616: (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_EAM_CMRO_SUP_VER
1617: AND MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y' )) THEN
1618: lv_usaf_temp_sql := '2,' ;
1611:
1612: END IF;
1613:
1614: IF ((MSC_UTIL.g_collect_cmro_data = 'Y' and
1615: MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS121) OR
1616: (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_EAM_CMRO_SUP_VER
1617: AND MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y' )) THEN
1618: lv_usaf_temp_sql := '2,' ;
1619: v_temp_sql3 := v_temp_sql3 ||' AND x.ATP_FLAG = ''Y''' ;
1612: END IF;
1613:
1614: IF ((MSC_UTIL.g_collect_cmro_data = 'Y' and
1615: MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS121) OR
1616: (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_EAM_CMRO_SUP_VER
1617: AND MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y' )) THEN
1618: lv_usaf_temp_sql := '2,' ;
1619: v_temp_sql3 := v_temp_sql3 ||' AND x.ATP_FLAG = ''Y''' ;
1620: ELSE
1613:
1614: IF ((MSC_UTIL.g_collect_cmro_data = 'Y' and
1615: MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS121) OR
1616: (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_EAM_CMRO_SUP_VER
1617: AND MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y' )) THEN
1618: lv_usaf_temp_sql := '2,' ;
1619: v_temp_sql3 := v_temp_sql3 ||' AND x.ATP_FLAG = ''Y''' ;
1620: ELSE
1621: lv_usaf_temp_sql := '1,';
1743: -- ||' x.SHIPPING_METHOD_CODE,'
1744: -- ||' x.ATO_LINE_ID,'
1745: -- ||' x.ORDER_DATE_TYPE_CODE '
1746: ||' FROM '||MSC_CL_PULL.v_view_name||MSC_CL_PULL.v_dblink||' x'
1747: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
1748: ||' AND x.ORIGINAL_ORDERED_QUANTITY > x.ORIGINAL_COMPLETED_QUANTITY '
1749: || v_temp_sql3 ;
1750:
1751:
1770:
1771: PROCEDURE LOAD_OPEN_PAYBACKS IS
1772: BEGIN
1773:
1774: IF MSC_CL_PULL.v_lrn = -1 AND MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
1775:
1776: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'PROCEDURE LOAD_OPEN_PAYBACKS');
1777: MSC_CL_PULL.v_table_name:= 'MSC_ST_OPEN_PAYBACKS';
1778: MSC_CL_PULL.v_view_name := 'MRP_AP_OPEN_PAYBACK_QTY_V';
1772: BEGIN
1773:
1774: IF MSC_CL_PULL.v_lrn = -1 AND MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
1775:
1776: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'PROCEDURE LOAD_OPEN_PAYBACKS');
1777: MSC_CL_PULL.v_table_name:= 'MSC_ST_OPEN_PAYBACKS';
1778: MSC_CL_PULL.v_view_name := 'MRP_AP_OPEN_PAYBACK_QTY_V';
1779:
1780: v_sql_stmt:=
1804: PLANNING_GROUP,
1805: LENDING_PROJ_PLANNING_GROUP,
1806: END_ITEM_UNIT_NUMBER
1807: FROM MRP_AP_OPEN_PAYBACK_QTY_V'||MSC_CL_PULL.v_dblink||
1808: ' WHERE ORGANIZATION_ID '|| MSC_UTIL.v_in_org_str;
1809:
1810: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_instance_id;
1811: COMMIT;
1812: