28: BEGIN
29:
30: lv_task_start_time := sysdate;
31:
32: IF MSC_CL_PULL.PO_ENABLED= MSC_UTIL.SYS_YES THEN
33:
34: -- =================== DELETED DATA ======================
35:
36: --=================== Net Change Mode: Delete ==================
34: -- =================== DELETED DATA ======================
35:
36: --=================== Net Change Mode: Delete ==================
37:
38: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
39:
40: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
41: MSC_CL_PULL.v_view_name := 'MRP_AD_PO_SUPPLIES_V';
42:
36: --=================== Net Change Mode: Delete ==================
37:
38: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
39:
40: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
41: MSC_CL_PULL.v_view_name := 'MRP_AD_PO_SUPPLIES_V';
42:
43: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
44: v_temp_sql := ' AND x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
37:
38: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
39:
40: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
41: MSC_CL_PULL.v_view_name := 'MRP_AD_PO_SUPPLIES_V';
42:
43: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
44: v_temp_sql := ' AND x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
45: ELSE
39:
40: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
41: MSC_CL_PULL.v_view_name := 'MRP_AD_PO_SUPPLIES_V';
42:
43: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
44: v_temp_sql := ' AND x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
45: ELSE
46: v_temp_sql := NULL;
47: END IF;
58: ||' 1,' -- using 1, such that the MSCCLBAB.LOAD_SUPPLY
59: ||' 1,' -- can pick this PO record up for delete
60: ||' :v_refresh_id,'
61: ||' :v_instance_id'
62: ||' from MRP_AD_PO_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
63: ||' where x.RN>'||MSC_CL_PULL.v_lrn
64: || v_temp_sql;
65:
66: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
59: ||' 1,' -- can pick this PO record up for delete
60: ||' :v_refresh_id,'
61: ||' :v_instance_id'
62: ||' from MRP_AD_PO_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
63: ||' where x.RN>'||MSC_CL_PULL.v_lrn
64: || v_temp_sql;
65:
66: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
67:
62: ||' from MRP_AD_PO_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
63: ||' where x.RN>'||MSC_CL_PULL.v_lrn
64: || v_temp_sql;
65:
66: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
67:
68: COMMIT;
69:
70: END IF;
69:
70: END IF;
71:
72:
73: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
74: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_SHIP_SUPPLY_V';
75:
76: /* Added this code for VMI changes */
77: Begin
70: END IF;
71:
72:
73: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
74: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_SHIP_SUPPLY_V';
75:
76: /* Added this code for VMI changes */
77: Begin
78:
75:
76: /* Added this code for VMI changes */
77: Begin
78:
79: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
80: v_temp_sql := 'x.VMI_FLAG,x.VENDOR_ID,x.VENDOR_SITE_ID,x.POSTPROCESSING_LEAD_TIME,';
81: ELSE
82: v_temp_sql := 'NULL,NULL,NULL,NULL,';
83: END IF;
83: END IF;
84:
85: End;
86:
87: IF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 AND MSC_UTIL.G_COLLECT_SRP_DATA='Y') THEN
88: v_temp_sql1 := 'ITEM_TYPE_VALUE,';
89: v_temp_sql2 := 'DECODE(nvl(x.CONDITION_TYPE,''G''),''G'',1,''B'',2),';
90: ELSE
91: v_temp_sql1 :=NULL;
173: ||' x.INTRANSIT_OWNING_ORG_ID,'
174: ||' x.REQUISITION_LINE_ID,'
175: ||' :v_refresh_id,'
176: ||' :v_instance_id'
177: ||' from PJM_PROJECT_PARAMETERS'||MSC_CL_PULL.v_dblink||' mpp,'
178: ||' MRP_AP_PO_SHIP_SUPPLY_V'||MSC_CL_PULL.v_dblink||' x'
179: ||' where x.TO_ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
180: ||' AND mpp.project_id (+)= x.project_id'
181: ||' and mpp.organization_id (+)= DECODE( :v_mps_consume_profile_value,'
174: ||' x.REQUISITION_LINE_ID,'
175: ||' :v_refresh_id,'
176: ||' :v_instance_id'
177: ||' from PJM_PROJECT_PARAMETERS'||MSC_CL_PULL.v_dblink||' mpp,'
178: ||' MRP_AP_PO_SHIP_SUPPLY_V'||MSC_CL_PULL.v_dblink||' x'
179: ||' where x.TO_ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
180: ||' AND mpp.project_id (+)= x.project_id'
181: ||' and mpp.organization_id (+)= DECODE( :v_mps_consume_profile_value,'
182: ||' 1, x.MRP_TO_Organization_ID,'
183: ||' x.Organization_ID)'
184: ||' and DECODE( :v_mps_consume_profile_value,'
185: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
186: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
187: ||' AND (' -- x.RN1>'||MSC_CL_PULL.v_lrn
188: ||' x.RN2>'||MSC_CL_PULL.v_lrn
189: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
190:
191: v_temp_sql1 :=NULL;
184: ||' and DECODE( :v_mps_consume_profile_value,'
185: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
186: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
187: ||' AND (' -- x.RN1>'||MSC_CL_PULL.v_lrn
188: ||' x.RN2>'||MSC_CL_PULL.v_lrn
189: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
190:
191: v_temp_sql1 :=NULL;
192: v_temp_sql2 :=NULL;
185: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
186: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
187: ||' AND (' -- x.RN1>'||MSC_CL_PULL.v_lrn
188: ||' x.RN2>'||MSC_CL_PULL.v_lrn
189: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
190:
191: v_temp_sql1 :=NULL;
192: v_temp_sql2 :=NULL;
193: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
189: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
190:
191: v_temp_sql1 :=NULL;
192: v_temp_sql2 :=NULL;
193: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
194: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
195: MSC_CL_PULL.v_mps_consume_profile_value,
196: MSC_CL_PULL.v_mps_consume_profile_value,
197: MSC_CL_PULL.v_mps_consume_profile_value,
190:
191: v_temp_sql1 :=NULL;
192: v_temp_sql2 :=NULL;
193: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
194: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
195: MSC_CL_PULL.v_mps_consume_profile_value,
196: MSC_CL_PULL.v_mps_consume_profile_value,
197: MSC_CL_PULL.v_mps_consume_profile_value,
198: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
191: v_temp_sql1 :=NULL;
192: v_temp_sql2 :=NULL;
193: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
194: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
195: MSC_CL_PULL.v_mps_consume_profile_value,
196: MSC_CL_PULL.v_mps_consume_profile_value,
197: MSC_CL_PULL.v_mps_consume_profile_value,
198: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
199: MSC_CL_PULL.v_mps_consume_profile_value,
192: v_temp_sql2 :=NULL;
193: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
194: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
195: MSC_CL_PULL.v_mps_consume_profile_value,
196: MSC_CL_PULL.v_mps_consume_profile_value,
197: MSC_CL_PULL.v_mps_consume_profile_value,
198: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
199: MSC_CL_PULL.v_mps_consume_profile_value,
200: MSC_CL_PULL.v_mps_consume_profile_value;
193: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
194: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
195: MSC_CL_PULL.v_mps_consume_profile_value,
196: MSC_CL_PULL.v_mps_consume_profile_value,
197: MSC_CL_PULL.v_mps_consume_profile_value,
198: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
199: MSC_CL_PULL.v_mps_consume_profile_value,
200: MSC_CL_PULL.v_mps_consume_profile_value;
201:
194: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
195: MSC_CL_PULL.v_mps_consume_profile_value,
196: MSC_CL_PULL.v_mps_consume_profile_value,
197: MSC_CL_PULL.v_mps_consume_profile_value,
198: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
199: MSC_CL_PULL.v_mps_consume_profile_value,
200: MSC_CL_PULL.v_mps_consume_profile_value;
201:
202: COMMIT;
195: MSC_CL_PULL.v_mps_consume_profile_value,
196: MSC_CL_PULL.v_mps_consume_profile_value,
197: MSC_CL_PULL.v_mps_consume_profile_value,
198: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
199: MSC_CL_PULL.v_mps_consume_profile_value,
200: MSC_CL_PULL.v_mps_consume_profile_value;
201:
202: COMMIT;
203:
196: MSC_CL_PULL.v_mps_consume_profile_value,
197: MSC_CL_PULL.v_mps_consume_profile_value,
198: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
199: MSC_CL_PULL.v_mps_consume_profile_value,
200: MSC_CL_PULL.v_mps_consume_profile_value;
201:
202: COMMIT;
203:
204:
202: COMMIT;
203:
204:
205:
206: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
207: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_SHIP_RCV_SUPPLY_V';
208:
209:
210: /* Added this code for VMI changes */
203:
204:
205:
206: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
207: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_SHIP_RCV_SUPPLY_V';
208:
209:
210: /* Added this code for VMI changes */
211: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
207: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_SHIP_RCV_SUPPLY_V';
208:
209:
210: /* Added this code for VMI changes */
211: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
212: v_temp_sql := 'x.VMI_FLAG,';
213: ELSE
214: v_temp_sql := ' NULL, ';
215: END IF;
280: || v_temp_sql
281: ||' 2,'
282: ||' :v_refresh_id,'
283: ||' :v_instance_id'
284: ||' from PJM_PROJECT_PARAMETERS'||MSC_CL_PULL.v_dblink||' mpp,'
285: ||' MRP_AP_PO_SHIP_RCV_SUPPLY_V'||MSC_CL_PULL.v_dblink||' x'
286: ||' where x.TO_ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
287: ||' AND mpp.project_id (+)= x.project_id'
288: ||' and mpp.organization_id (+)= DECODE( :v_mps_consume_profile_value,'
281: ||' 2,'
282: ||' :v_refresh_id,'
283: ||' :v_instance_id'
284: ||' from PJM_PROJECT_PARAMETERS'||MSC_CL_PULL.v_dblink||' mpp,'
285: ||' MRP_AP_PO_SHIP_RCV_SUPPLY_V'||MSC_CL_PULL.v_dblink||' x'
286: ||' where x.TO_ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
287: ||' AND mpp.project_id (+)= x.project_id'
288: ||' and mpp.organization_id (+)= DECODE( :v_mps_consume_profile_value,'
289: ||' 1, x.MRP_TO_Organization_ID,'
290: ||' x.Organization_ID)'
291: ||' and DECODE( :v_mps_consume_profile_value,'
292: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
293: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
294: ||' AND (' -- x.RN1>'||MSC_CL_PULL.v_lrn
295: ||' x.RN2>'||MSC_CL_PULL.v_lrn
296: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
297:
298: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
291: ||' and DECODE( :v_mps_consume_profile_value,'
292: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
293: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
294: ||' AND (' -- x.RN1>'||MSC_CL_PULL.v_lrn
295: ||' x.RN2>'||MSC_CL_PULL.v_lrn
296: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
297:
298: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
299: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
292: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
293: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
294: ||' AND (' -- x.RN1>'||MSC_CL_PULL.v_lrn
295: ||' x.RN2>'||MSC_CL_PULL.v_lrn
296: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
297:
298: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
299: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
300: MSC_CL_PULL.v_mps_consume_profile_value,
294: ||' AND (' -- x.RN1>'||MSC_CL_PULL.v_lrn
295: ||' x.RN2>'||MSC_CL_PULL.v_lrn
296: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
297:
298: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
299: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
300: MSC_CL_PULL.v_mps_consume_profile_value,
301: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
302: MSC_CL_PULL.v_mps_consume_profile_value,
295: ||' x.RN2>'||MSC_CL_PULL.v_lrn
296: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
297:
298: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
299: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
300: MSC_CL_PULL.v_mps_consume_profile_value,
301: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
302: MSC_CL_PULL.v_mps_consume_profile_value,
303: MSC_CL_PULL.v_mps_consume_profile_value;
296: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
297:
298: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
299: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
300: MSC_CL_PULL.v_mps_consume_profile_value,
301: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
302: MSC_CL_PULL.v_mps_consume_profile_value,
303: MSC_CL_PULL.v_mps_consume_profile_value;
304:
297:
298: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
299: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
300: MSC_CL_PULL.v_mps_consume_profile_value,
301: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
302: MSC_CL_PULL.v_mps_consume_profile_value,
303: MSC_CL_PULL.v_mps_consume_profile_value;
304:
305: COMMIT;
298: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
299: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
300: MSC_CL_PULL.v_mps_consume_profile_value,
301: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
302: MSC_CL_PULL.v_mps_consume_profile_value,
303: MSC_CL_PULL.v_mps_consume_profile_value;
304:
305: COMMIT;
306:
299: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
300: MSC_CL_PULL.v_mps_consume_profile_value,
301: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
302: MSC_CL_PULL.v_mps_consume_profile_value,
303: MSC_CL_PULL.v_mps_consume_profile_value;
304:
305: COMMIT;
306:
307: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
303: MSC_CL_PULL.v_mps_consume_profile_value;
304:
305: COMMIT;
306:
307: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
308: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_RCV_SUPPLY_V';
309:
310: /* Added this code for VMI changes */
311: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
304:
305: COMMIT;
306:
307: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
308: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_RCV_SUPPLY_V';
309:
310: /* Added this code for VMI changes */
311: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
312: v_temp_sql := 'x.VMI_FLAG,';
307: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
308: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_RCV_SUPPLY_V';
309:
310: /* Added this code for VMI changes */
311: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
312: v_temp_sql := 'x.VMI_FLAG,';
313: ELSE
314: v_temp_sql := ' NULL, ';
315: END IF;
382: || v_temp_sql
383: ||' 2,'
384: ||' :v_refresh_id,'
385: ||' :v_instance_id'
386: ||' from PJM_PROJECT_PARAMETERS'||MSC_CL_PULL.v_dblink||' mpp,'
387: ||' MRP_AP_PO_RCV_SUPPLY_V'||MSC_CL_PULL.v_dblink||' x'
388: ||' where x.TO_ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
389: ||' AND mpp.project_id (+)= x.project_id'
390: ||' and mpp.organization_id (+)= DECODE( :v_mps_consume_profile_value,'
383: ||' 2,'
384: ||' :v_refresh_id,'
385: ||' :v_instance_id'
386: ||' from PJM_PROJECT_PARAMETERS'||MSC_CL_PULL.v_dblink||' mpp,'
387: ||' MRP_AP_PO_RCV_SUPPLY_V'||MSC_CL_PULL.v_dblink||' x'
388: ||' where x.TO_ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
389: ||' AND mpp.project_id (+)= x.project_id'
390: ||' and mpp.organization_id (+)= DECODE( :v_mps_consume_profile_value,'
391: ||' 1, x.MRP_TO_Organization_ID,'
392: ||' x.Organization_ID)'
393: ||' and DECODE( :v_mps_consume_profile_value,'
394: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
395: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
396: ||' AND (' /* x.RN1>'||MSC_CL_PULL.v_lrn */
397: ||' x.RN2>'||MSC_CL_PULL.v_lrn
398: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
399:
400: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
393: ||' and DECODE( :v_mps_consume_profile_value,'
394: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
395: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
396: ||' AND (' /* x.RN1>'||MSC_CL_PULL.v_lrn */
397: ||' x.RN2>'||MSC_CL_PULL.v_lrn
398: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
399:
400: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
401: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
394: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
395: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
396: ||' AND (' /* x.RN1>'||MSC_CL_PULL.v_lrn */
397: ||' x.RN2>'||MSC_CL_PULL.v_lrn
398: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
399:
400: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
401: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
402: MSC_CL_PULL.v_mps_consume_profile_value,
396: ||' AND (' /* x.RN1>'||MSC_CL_PULL.v_lrn */
397: ||' x.RN2>'||MSC_CL_PULL.v_lrn
398: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
399:
400: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
401: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
402: MSC_CL_PULL.v_mps_consume_profile_value,
403: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
404: MSC_CL_PULL.v_mps_consume_profile_value,
397: ||' x.RN2>'||MSC_CL_PULL.v_lrn
398: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
399:
400: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
401: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
402: MSC_CL_PULL.v_mps_consume_profile_value,
403: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
404: MSC_CL_PULL.v_mps_consume_profile_value,
405: MSC_CL_PULL.v_mps_consume_profile_value;
398: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
399:
400: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
401: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
402: MSC_CL_PULL.v_mps_consume_profile_value,
403: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
404: MSC_CL_PULL.v_mps_consume_profile_value,
405: MSC_CL_PULL.v_mps_consume_profile_value;
406:
399:
400: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
401: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
402: MSC_CL_PULL.v_mps_consume_profile_value,
403: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
404: MSC_CL_PULL.v_mps_consume_profile_value,
405: MSC_CL_PULL.v_mps_consume_profile_value;
406:
407: COMMIT;
400: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
401: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
402: MSC_CL_PULL.v_mps_consume_profile_value,
403: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
404: MSC_CL_PULL.v_mps_consume_profile_value,
405: MSC_CL_PULL.v_mps_consume_profile_value;
406:
407: COMMIT;
408:
401: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
402: MSC_CL_PULL.v_mps_consume_profile_value,
403: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
404: MSC_CL_PULL.v_mps_consume_profile_value,
405: MSC_CL_PULL.v_mps_consume_profile_value;
406:
407: COMMIT;
408:
409: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
405: MSC_CL_PULL.v_mps_consume_profile_value;
406:
407: COMMIT;
408:
409: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
410: MSC_CL_PULL.v_view_name := 'MRP_AP_INTRANSIT_SUPPLIES_V';
411:
412: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
413: v_temp_sql := 'x.POSTPROCESSING_LEAD_TIME,';
406:
407: COMMIT;
408:
409: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
410: MSC_CL_PULL.v_view_name := 'MRP_AP_INTRANSIT_SUPPLIES_V';
411:
412: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
413: v_temp_sql := 'x.POSTPROCESSING_LEAD_TIME,';
414: ELSE
408:
409: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
410: MSC_CL_PULL.v_view_name := 'MRP_AP_INTRANSIT_SUPPLIES_V';
411:
412: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
413: v_temp_sql := 'x.POSTPROCESSING_LEAD_TIME,';
414: ELSE
415: v_temp_sql := 'NULL,';
416: END IF;
449: || v_temp_sql
450: ||' 2,'
451: ||' :v_refresh_id,'
452: ||' :v_instance_id'
453: ||' from MRP_AP_INTRANSIT_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
454: ||' where x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
455: ||' AND (DECODE( :v_so_ship_arrive_value,'
456: ||' 1, NVL(x.arrived_flag, 2), 2)= 2)'
457: ||' AND (x.RN2>'||MSC_CL_PULL.v_lrn||')';
453: ||' from MRP_AP_INTRANSIT_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
454: ||' where x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
455: ||' AND (DECODE( :v_so_ship_arrive_value,'
456: ||' 1, NVL(x.arrived_flag, 2), 2)= 2)'
457: ||' AND (x.RN2>'||MSC_CL_PULL.v_lrn||')';
458:
459:
460: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
461: MSC_CL_PULL.v_so_ship_arrive_value;
456: ||' 1, NVL(x.arrived_flag, 2), 2)= 2)'
457: ||' AND (x.RN2>'||MSC_CL_PULL.v_lrn||')';
458:
459:
460: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
461: MSC_CL_PULL.v_so_ship_arrive_value;
462:
463: COMMIT;
464:
457: ||' AND (x.RN2>'||MSC_CL_PULL.v_lrn||')';
458:
459:
460: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
461: MSC_CL_PULL.v_so_ship_arrive_value;
462:
463: COMMIT;
464:
465: END IF; -- MSC_CL_PULL.PO_ENABLED
461: MSC_CL_PULL.v_so_ship_arrive_value;
462:
463: COMMIT;
464:
465: END IF; -- MSC_CL_PULL.PO_ENABLED
466:
467:
468: END LOAD_PO_SUPPLY;
469:
474:
475:
476: -- ====================== 6: On Hand ====================
477:
478: IF MSC_CL_PULL.OH_ENABLED= MSC_UTIL.SYS_YES THEN
479:
480: --=================== Net Change Mode: Delete ==================
481:
482: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
478: IF MSC_CL_PULL.OH_ENABLED= MSC_UTIL.SYS_YES THEN
479:
480: --=================== Net Change Mode: Delete ==================
481:
482: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
483:
484: -- delete
485: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
486: v_temp_sql := ' x.QUANTITY, x.PROJECT_ID,x.TASK_ID,x.END_ITEM_UNIT_NUMBER,
481:
482: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
483:
484: -- delete
485: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
486: v_temp_sql := ' x.QUANTITY, x.PROJECT_ID,x.TASK_ID,x.END_ITEM_UNIT_NUMBER,
487: decode(x.PLANNING_ORGANIZATION_ID, -1, NULL, x.PLANNING_ORGANIZATION_ID),
488: decode(x.PLANNING_TP_TYPE, -1, NULL, x.PLANNING_TP_TYPE),
489: decode(x.OWNING_ORGANIZATION_ID, -1, NULL, x.OWNING_ORGANIZATION_ID),
496: NULL,
497: NULL, ';
498: END IF;
499:
500: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
501: MSC_CL_PULL.v_view_name := 'MRP_AD_ONHAND_SUPPLIES_V';
502:
503: v_sql_stmt:=
504: ' insert into MSC_ST_SUPPLIES'
497: NULL, ';
498: END IF;
499:
500: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
501: MSC_CL_PULL.v_view_name := 'MRP_AD_ONHAND_SUPPLIES_V';
502:
503: v_sql_stmt:=
504: ' insert into MSC_ST_SUPPLIES'
505: ||' ( INVENTORY_ITEM_ID,'
527: ||' 1,'
528: || v_temp_sql --for 11i sources
529: ||' :v_refresh_id,'
530: ||' :v_instance_id'
531: ||' from MRP_AD_ONHAND_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
532: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
533: ||' AND x.RN>'||MSC_CL_PULL.v_lrn;
534:
535: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
529: ||' :v_refresh_id,'
530: ||' :v_instance_id'
531: ||' from MRP_AD_ONHAND_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
532: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
533: ||' AND x.RN>'||MSC_CL_PULL.v_lrn;
534:
535: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
536:
537: COMMIT;
531: ||' from MRP_AD_ONHAND_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
532: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
533: ||' AND x.RN>'||MSC_CL_PULL.v_lrn;
534:
535: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
536:
537: COMMIT;
538:
539: -- insert/update
538:
539: -- insert/update
540:
541: /* Added this code for VMI changes */
542: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
543: v_temp_sql := ' decode(x.PLANNING_ORGANIZATION_ID, -1, NULL, x.PLANNING_ORGANIZATION_ID),
544: decode(x.PLANNING_TP_TYPE, -1, NULL, x.PLANNING_TP_TYPE),
545: decode(x.OWNING_ORGANIZATION_ID, -1, NULL, x.OWNING_ORGANIZATION_ID),
546: decode(x.OWNING_TP_TYPE, -1, NULL, x.OWNING_TP_TYPE), ';
548: ELSE
549: v_temp_sql := ' NULL, NULL, NULL, NULL, ';
550: END IF;
551:
552: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
553:
554: IF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 AND MSC_UTIL.G_COLLECT_SRP_DATA='Y') THEN -- SRP Changes Bug # 5684159
555: MSC_CL_PULL.v_view_name := 'MRP_AP1_ONHAND_SUPPLIES_V';
556: v_Decode := ',DECODE(NVL(x.CONDITION_TYPE, '||''''||'G'||''''||'),'||''''||'G'||''''||', '||v_item_type_good||','||v_item_type_bad||'),';
550: END IF;
551:
552: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
553:
554: IF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 AND MSC_UTIL.G_COLLECT_SRP_DATA='Y') THEN -- SRP Changes Bug # 5684159
555: MSC_CL_PULL.v_view_name := 'MRP_AP1_ONHAND_SUPPLIES_V';
556: v_Decode := ',DECODE(NVL(x.CONDITION_TYPE, '||''''||'G'||''''||'),'||''''||'G'||''''||', '||v_item_type_good||','||v_item_type_bad||'),';
557: v_temp_sql := v_temp_sql ||'x.SR_CUSTOMER_ACCT_ID,'||v_item_type_id ||v_Decode;
558:
551:
552: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
553:
554: IF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 AND MSC_UTIL.G_COLLECT_SRP_DATA='Y') THEN -- SRP Changes Bug # 5684159
555: MSC_CL_PULL.v_view_name := 'MRP_AP1_ONHAND_SUPPLIES_V';
556: v_Decode := ',DECODE(NVL(x.CONDITION_TYPE, '||''''||'G'||''''||'),'||''''||'G'||''''||', '||v_item_type_good||','||v_item_type_bad||'),';
557: v_temp_sql := v_temp_sql ||'x.SR_CUSTOMER_ACCT_ID,'||v_item_type_id ||v_Decode;
558:
559: ELSE
556: v_Decode := ',DECODE(NVL(x.CONDITION_TYPE, '||''''||'G'||''''||'),'||''''||'G'||''''||', '||v_item_type_good||','||v_item_type_bad||'),';
557: v_temp_sql := v_temp_sql ||'x.SR_CUSTOMER_ACCT_ID,'||v_item_type_id ||v_Decode;
558:
559: ELSE
560: MSC_CL_PULL.v_view_name := 'MRP_AP_ONHAND_SUPPLIES_V';
561: v_temp_sql := v_temp_sql || ' NULL, NULL, NULL,';
562: end if;
563:
564:
604: ||' 2,'
605: || v_temp_sql
606: ||' :v_refresh_id,'
607: ||' :v_instance_id'
608: ||' FROM '||MSC_CL_PULL.v_view_name||MSC_CL_PULL.v_dblink||' x '
609: /*
610: ||' ( SELECT DISTINCT'
611: ||' inventory_item_id,'
612: ||' organization_id,'
611: ||' inventory_item_id,'
612: ||' organization_id,'
613: ||' subinventory_code,'
614: ||' lot_number'
615: ||' FROM MRP_AN_ONHAND_SUPPLIES_V'||MSC_CL_PULL.v_dblink
616: ||' WHERE ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
617: ||' AND rn>'||MSC_CL_PULL.v_lrn||') a'
618: ||' WHERE a.inventory_item_id= x.inventory_item_id'
619: ||' AND a.organization_id= x.organization_id'
613: ||' subinventory_code,'
614: ||' lot_number'
615: ||' FROM MRP_AN_ONHAND_SUPPLIES_V'||MSC_CL_PULL.v_dblink
616: ||' WHERE ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
617: ||' AND rn>'||MSC_CL_PULL.v_lrn||') a'
618: ||' WHERE a.inventory_item_id= x.inventory_item_id'
619: ||' AND a.organization_id= x.organization_id'
620: ||' AND NVL(a.subinventory_code,'' '')= NVL( x.subinventory_code,'' '')'
621: ||' AND NVL(a.lot_number,'' '')= NVL( x.lot_number,'' '')';*/
619: ||' AND a.organization_id= x.organization_id'
620: ||' AND NVL(a.subinventory_code,'' '')= NVL( x.subinventory_code,'' '')'
621: ||' AND NVL(a.lot_number,'' '')= NVL( x.lot_number,'' '')';*/
622: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
623: ||' AND (x.RN1>'||MSC_CL_PULL.v_lrn
624: ||' OR x.RN2>'||MSC_CL_PULL.v_lrn||')';
625:
626: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
627:
620: ||' AND NVL(a.subinventory_code,'' '')= NVL( x.subinventory_code,'' '')'
621: ||' AND NVL(a.lot_number,'' '')= NVL( x.lot_number,'' '')';*/
622: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
623: ||' AND (x.RN1>'||MSC_CL_PULL.v_lrn
624: ||' OR x.RN2>'||MSC_CL_PULL.v_lrn||')';
625:
626: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
627:
628: COMMIT;
622: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
623: ||' AND (x.RN1>'||MSC_CL_PULL.v_lrn
624: ||' OR x.RN2>'||MSC_CL_PULL.v_lrn||')';
625:
626: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
627:
628: COMMIT;
629:
630: ELSE -- complete refresh
628: COMMIT;
629:
630: ELSE -- complete refresh
631:
632: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
633: MSC_CL_PULL.v_view_name := 'MRP_AP_ONHAND_SUPPLIES_V';
634:
635: /* Added this code for VMI changes */
636: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
629:
630: ELSE -- complete refresh
631:
632: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
633: MSC_CL_PULL.v_view_name := 'MRP_AP_ONHAND_SUPPLIES_V';
634:
635: /* Added this code for VMI changes */
636: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
637: v_temp_sql := ' decode(x.PLANNING_ORGANIZATION_ID, -1, NULL, x.PLANNING_ORGANIZATION_ID),
632: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
633: MSC_CL_PULL.v_view_name := 'MRP_AP_ONHAND_SUPPLIES_V';
634:
635: /* Added this code for VMI changes */
636: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
637: v_temp_sql := ' decode(x.PLANNING_ORGANIZATION_ID, -1, NULL, x.PLANNING_ORGANIZATION_ID),
638: decode(x.PLANNING_TP_TYPE, -1, NULL, x.PLANNING_TP_TYPE),
639: decode(x.OWNING_ORGANIZATION_ID, -1, NULL, x.OWNING_ORGANIZATION_ID),
640: decode(x.OWNING_TP_TYPE, -1, NULL, x.OWNING_TP_TYPE), ';
643: v_temp_sql := ' NULL, NULL, NULL, NULL, ';
644: END IF;
645:
646:
647: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
648:
649: IF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 AND MSC_UTIL.G_COLLECT_SRP_DATA='Y') THEN -- SRP Changes Bug # 5684159
650: MSC_CL_PULL.v_view_name := 'MRP_AP1_ONHAND_SUPPLIES_V';
651: v_Decode := ',DECODE(NVL(x.CONDITION_TYPE, '||''''||'G'||''''||'),'||''''||'G'||''''||', '||v_item_type_good||','||v_item_type_bad||'),';
645:
646:
647: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
648:
649: IF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 AND MSC_UTIL.G_COLLECT_SRP_DATA='Y') THEN -- SRP Changes Bug # 5684159
650: MSC_CL_PULL.v_view_name := 'MRP_AP1_ONHAND_SUPPLIES_V';
651: v_Decode := ',DECODE(NVL(x.CONDITION_TYPE, '||''''||'G'||''''||'),'||''''||'G'||''''||', '||v_item_type_good||','||v_item_type_bad||'),';
652: v_temp_sql := v_temp_sql ||'x.SR_CUSTOMER_ACCT_ID,'||v_item_type_id ||v_Decode;
653:
646:
647: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
648:
649: IF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 AND MSC_UTIL.G_COLLECT_SRP_DATA='Y') THEN -- SRP Changes Bug # 5684159
650: MSC_CL_PULL.v_view_name := 'MRP_AP1_ONHAND_SUPPLIES_V';
651: v_Decode := ',DECODE(NVL(x.CONDITION_TYPE, '||''''||'G'||''''||'),'||''''||'G'||''''||', '||v_item_type_good||','||v_item_type_bad||'),';
652: v_temp_sql := v_temp_sql ||'x.SR_CUSTOMER_ACCT_ID,'||v_item_type_id ||v_Decode;
653:
654: ELSE
651: v_Decode := ',DECODE(NVL(x.CONDITION_TYPE, '||''''||'G'||''''||'),'||''''||'G'||''''||', '||v_item_type_good||','||v_item_type_bad||'),';
652: v_temp_sql := v_temp_sql ||'x.SR_CUSTOMER_ACCT_ID,'||v_item_type_id ||v_Decode;
653:
654: ELSE
655: MSC_CL_PULL.v_view_name := 'MRP_AP_ONHAND_SUPPLIES_V';
656: v_temp_sql := v_temp_sql || ' NULL, NULL, NULL,';
657: end if;
658:
659:
699: ||' SYSDATE,'
700: ||' 2,'
701: ||' :v_refresh_id,'
702: ||' :v_instance_id'
703: ||' FROM '||MSC_CL_PULL.v_view_name||MSC_CL_PULL.v_dblink||' x'
704: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str;
705:
706: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
707:
702: ||' :v_instance_id'
703: ||' FROM '||MSC_CL_PULL.v_view_name||MSC_CL_PULL.v_dblink||' x'
704: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str;
705:
706: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
707:
708: COMMIT;
709:
710: END IF; -- incremental refresh
708: COMMIT;
709:
710: END IF; -- incremental refresh
711:
712: END IF; -- MSC_CL_PULL.OH_ENABLED
713:
714: END LOAD_OH_SUPPLY;
715:
716:
719: BEGIN
720:
721: -- ====================== 8: MPS ====================
722:
723: IF MSC_CL_PULL.MPS_ENABLED= MSC_UTIL.SYS_YES THEN
724:
725: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
726:
727: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
721: -- ====================== 8: MPS ====================
722:
723: IF MSC_CL_PULL.MPS_ENABLED= MSC_UTIL.SYS_YES THEN
724:
725: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
726:
727: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
728: MSC_CL_PULL.v_view_name := 'MRP_AD_MPS_SUPPLIES_V';
729:
723: IF MSC_CL_PULL.MPS_ENABLED= MSC_UTIL.SYS_YES THEN
724:
725: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
726:
727: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
728: MSC_CL_PULL.v_view_name := 'MRP_AD_MPS_SUPPLIES_V';
729:
730: v_sql_stmt:=
731: 'insert into MSC_ST_SUPPLIES'
724:
725: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
726:
727: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
728: MSC_CL_PULL.v_view_name := 'MRP_AD_MPS_SUPPLIES_V';
729:
730: v_sql_stmt:=
731: 'insert into MSC_ST_SUPPLIES'
732: ||' ( DISPOSITION_ID,'
743: ||' x.ORDER_TYPE,'
744: ||' 1,'
745: ||' :v_refresh_id,'
746: ||' :v_instance_id'
747: ||' from MRP_AD_MPS_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
748: ||' WHERE x.RN>'||MSC_CL_PULL.v_lrn
749: ||' AND x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str;
750:
751: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
744: ||' 1,'
745: ||' :v_refresh_id,'
746: ||' :v_instance_id'
747: ||' from MRP_AD_MPS_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
748: ||' WHERE x.RN>'||MSC_CL_PULL.v_lrn
749: ||' AND x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str;
750:
751: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
752:
747: ||' from MRP_AD_MPS_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
748: ||' WHERE x.RN>'||MSC_CL_PULL.v_lrn
749: ||' AND x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str;
750:
751: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
752:
753: COMMIT;
754:
755: END IF;
753: COMMIT;
754:
755: END IF;
756:
757: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
758: MSC_CL_PULL.v_view_name := 'MRP_AP_MPS_SUPPLIES_V';
759:
760: v_sql_stmt:=
761: 'insert into MSC_ST_SUPPLIES'
754:
755: END IF;
756:
757: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
758: MSC_CL_PULL.v_view_name := 'MRP_AP_MPS_SUPPLIES_V';
759:
760: v_sql_stmt:=
761: 'insert into MSC_ST_SUPPLIES'
762: ||' ( DISPOSITION_ID,'
802: ||' 2,'
803: ||' :v_refresh_id,'
804: ||' :v_instance_id,'
805: ||' x.schedule_origination_type '
806: ||' from MRP_AP_MPS_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
807: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
808: ||' AND (' --x.RN1>'||MSC_CL_PULL.v_lrn
809: ||' x.RN2>'||MSC_CL_PULL.v_lrn
810: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
804: ||' :v_instance_id,'
805: ||' x.schedule_origination_type '
806: ||' from MRP_AP_MPS_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
807: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
808: ||' AND (' --x.RN1>'||MSC_CL_PULL.v_lrn
809: ||' x.RN2>'||MSC_CL_PULL.v_lrn
810: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
811: --||' OR x.RN4>'||MSC_CL_PULL.v_lrn||')';
812:
805: ||' x.schedule_origination_type '
806: ||' from MRP_AP_MPS_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
807: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
808: ||' AND (' --x.RN1>'||MSC_CL_PULL.v_lrn
809: ||' x.RN2>'||MSC_CL_PULL.v_lrn
810: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
811: --||' OR x.RN4>'||MSC_CL_PULL.v_lrn||')';
812:
813: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_dgmt,
806: ||' from MRP_AP_MPS_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
807: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
808: ||' AND (' --x.RN1>'||MSC_CL_PULL.v_lrn
809: ||' x.RN2>'||MSC_CL_PULL.v_lrn
810: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
811: --||' OR x.RN4>'||MSC_CL_PULL.v_lrn||')';
812:
813: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_dgmt,
814: MSC_CL_PULL.v_instance_id, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
807: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
808: ||' AND (' --x.RN1>'||MSC_CL_PULL.v_lrn
809: ||' x.RN2>'||MSC_CL_PULL.v_lrn
810: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
811: --||' OR x.RN4>'||MSC_CL_PULL.v_lrn||')';
812:
813: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_dgmt,
814: MSC_CL_PULL.v_instance_id, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
815:
809: ||' x.RN2>'||MSC_CL_PULL.v_lrn
810: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
811: --||' OR x.RN4>'||MSC_CL_PULL.v_lrn||')';
812:
813: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_dgmt,
814: MSC_CL_PULL.v_instance_id, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
815:
816: COMMIT;
817:
810: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
811: --||' OR x.RN4>'||MSC_CL_PULL.v_lrn||')';
812:
813: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_dgmt,
814: MSC_CL_PULL.v_instance_id, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
815:
816: COMMIT;
817:
818: END IF; -- MSC_CL_PULL.MPS_ENABLED
814: MSC_CL_PULL.v_instance_id, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
815:
816: COMMIT;
817:
818: END IF; -- MSC_CL_PULL.MPS_ENABLED
819:
820: --VENDOR_ID, VENDOR_SITE_ID
821:
822: END LOAD_MPS_SUPPLY;
824:
825: PROCEDURE LOAD_USER_SUPPLY IS
826: BEGIN
827:
828: IF MSC_CL_PULL.v_apps_ver<> MSC_UTIL.G_APPS107 AND
829: MSC_CL_PULL.v_apps_ver<> MSC_UTIL.G_APPS110 THEN
830:
831: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
832:
825: PROCEDURE LOAD_USER_SUPPLY IS
826: BEGIN
827:
828: IF MSC_CL_PULL.v_apps_ver<> MSC_UTIL.G_APPS107 AND
829: MSC_CL_PULL.v_apps_ver<> MSC_UTIL.G_APPS110 THEN
830:
831: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
832:
833: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
827:
828: IF MSC_CL_PULL.v_apps_ver<> MSC_UTIL.G_APPS107 AND
829: MSC_CL_PULL.v_apps_ver<> MSC_UTIL.G_APPS110 THEN
830:
831: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
832:
833: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
834: MSC_CL_PULL.v_view_name := 'MRP_AD_USER_SUPPLIES_V';
835:
829: MSC_CL_PULL.v_apps_ver<> MSC_UTIL.G_APPS110 THEN
830:
831: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
832:
833: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
834: MSC_CL_PULL.v_view_name := 'MRP_AD_USER_SUPPLIES_V';
835:
836: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
837: v_temp_sql := ' AND x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
830:
831: IF MSC_CL_PULL.v_lrnn<> -1 THEN -- incremental refresh
832:
833: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
834: MSC_CL_PULL.v_view_name := 'MRP_AD_USER_SUPPLIES_V';
835:
836: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
837: v_temp_sql := ' AND x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
838: ELSE
832:
833: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
834: MSC_CL_PULL.v_view_name := 'MRP_AD_USER_SUPPLIES_V';
835:
836: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
837: v_temp_sql := ' AND x.ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
838: ELSE
839: v_temp_sql := NULL;
840: END IF;
853: ||' x.ORGANIZATION_ID,'
854: ||' 1,'
855: ||' :v_refresh_id,'
856: ||' :v_instance_id'
857: ||' FROM MRP_AD_USER_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
858: ||' WHERE x.RN>'||MSC_CL_PULL.v_lrn
859: || v_temp_sql;
860:
861: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
854: ||' 1,'
855: ||' :v_refresh_id,'
856: ||' :v_instance_id'
857: ||' FROM MRP_AD_USER_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
858: ||' WHERE x.RN>'||MSC_CL_PULL.v_lrn
859: || v_temp_sql;
860:
861: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
862:
857: ||' FROM MRP_AD_USER_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
858: ||' WHERE x.RN>'||MSC_CL_PULL.v_lrn
859: || v_temp_sql;
860:
861: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
862:
863: COMMIT;
864:
865: END IF;
863: COMMIT;
864:
865: END IF;
866:
867: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
868: MSC_CL_PULL.v_view_name := 'MRP_AP_USER_SUPPLIES_V';
869:
870: v_sql_stmt:=
871: ' INSERT INTO MSC_ST_SUPPLIES'
864:
865: END IF;
866:
867: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
868: MSC_CL_PULL.v_view_name := 'MRP_AP_USER_SUPPLIES_V';
869:
870: v_sql_stmt:=
871: ' INSERT INTO MSC_ST_SUPPLIES'
872: ||'( DISPOSITION_ID,'
894: ||' x.DEMAND_CLASS,'
895: ||' 2,'
896: ||' :v_refresh_id,'
897: ||' :v_instance_id'
898: ||' FROM MRP_AP_USER_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
899: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
900: ||' AND (x.RN1>'||MSC_CL_PULL.v_lrn
901: ||' OR x.RN2>'||MSC_CL_PULL.v_lrn||')';
902:
896: ||' :v_refresh_id,'
897: ||' :v_instance_id'
898: ||' FROM MRP_AP_USER_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
899: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
900: ||' AND (x.RN1>'||MSC_CL_PULL.v_lrn
901: ||' OR x.RN2>'||MSC_CL_PULL.v_lrn||')';
902:
903: --EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.V_ICODE, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
904: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
897: ||' :v_instance_id'
898: ||' FROM MRP_AP_USER_SUPPLIES_V'||MSC_CL_PULL.v_dblink||' x'
899: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
900: ||' AND (x.RN1>'||MSC_CL_PULL.v_lrn
901: ||' OR x.RN2>'||MSC_CL_PULL.v_lrn||')';
902:
903: --EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.V_ICODE, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
904: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
905:
899: ||' WHERE x.ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
900: ||' AND (x.RN1>'||MSC_CL_PULL.v_lrn
901: ||' OR x.RN2>'||MSC_CL_PULL.v_lrn||')';
902:
903: --EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.V_ICODE, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
904: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
905:
906: COMMIT;
907:
900: ||' AND (x.RN1>'||MSC_CL_PULL.v_lrn
901: ||' OR x.RN2>'||MSC_CL_PULL.v_lrn||')';
902:
903: --EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.V_ICODE, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
904: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id;
905:
906: COMMIT;
907:
908: END IF;
920: BEGIN
921:
922: lv_task_start_time := sysdate;
923:
924: IF MSC_CL_PULL.PO_ENABLED= MSC_UTIL.SYS_YES THEN
925: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
926: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_PO_SUPPLY_V';
927:
928: /* Added this code for VMI changes */
921:
922: lv_task_start_time := sysdate;
923:
924: IF MSC_CL_PULL.PO_ENABLED= MSC_UTIL.SYS_YES THEN
925: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
926: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_PO_SUPPLY_V';
927:
928: /* Added this code for VMI changes */
929: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
922: lv_task_start_time := sysdate;
923:
924: IF MSC_CL_PULL.PO_ENABLED= MSC_UTIL.SYS_YES THEN
925: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
926: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_PO_SUPPLY_V';
927:
928: /* Added this code for VMI changes */
929: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
930: v_temp_sql := 'x.VMI_FLAG,x.PO_LINE_LOCATION_ID,x.PO_DISTRIBUTION_ID, ';
925: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
926: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_PO_SUPPLY_V';
927:
928: /* Added this code for VMI changes */
929: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
930: v_temp_sql := 'x.VMI_FLAG,x.PO_LINE_LOCATION_ID,x.PO_DISTRIBUTION_ID, ';
931: ELSE
932: v_temp_sql := ' NULL,NULL,NULL, ';
933: END IF;
932: v_temp_sql := ' NULL,NULL,NULL, ';
933: END IF;
934:
935: /* Added this code for SRP changes Bug 6324690 */
936: IF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS120 AND MSC_UTIL.G_COLLECT_SRP_DATA='Y') THEN -- SRP Changes Bug # 6324690
937: v_view_name := 'MRP_AP_PO_CSP_SUPPLY_V';
938: v_order_type := 'x.order_type,';
939: ELSIF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 AND MSC_UTIL.G_COLLECT_SRP_DATA='Y') THEN
940: v_view_name := 'MRP_AP_PO_PO_SUPPLY_V';
935: /* Added this code for SRP changes Bug 6324690 */
936: IF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS120 AND MSC_UTIL.G_COLLECT_SRP_DATA='Y') THEN -- SRP Changes Bug # 6324690
937: v_view_name := 'MRP_AP_PO_CSP_SUPPLY_V';
938: v_order_type := 'x.order_type,';
939: ELSIF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 AND MSC_UTIL.G_COLLECT_SRP_DATA='Y') THEN
940: v_view_name := 'MRP_AP_PO_PO_SUPPLY_V';
941: v_order_type := ' decode(INSTR('''||MSC_UTIL.v_ext_repair_sup_id_str||''','',''||x.VENDOR_ID||'',''),'
942: || '0,decode(INSTR('''||MSC_UTIL.v_ext_repair_sup_id_str||''','',''||x.VENDOR_ID||'')''),'
943: || '0,decode(INSTR('''||MSC_UTIL.v_ext_repair_sup_id_str||''',''(''||x.VENDOR_ID||'',''),'
1054: ||' x.ACCEPTANCE_REQUIRED_FLAG,'
1055: ||' x.POSTPROCESSING_LEAD_TIME,'
1056: /* CP-ACK ends */
1057: ||' :v_instance_id'
1058: ||' from PJM_PROJECT_PARAMETERS'||MSC_CL_PULL.v_dblink||' mpp,'
1059: ||v_view_name||MSC_CL_PULL.v_dblink||' x'
1060: ||' where x.TO_ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
1061: ||' AND mpp.project_id (+)= x.project_id'
1062: ||' and mpp.organization_id (+)= DECODE( :v_mps_consume_profile_value,'
1055: ||' x.POSTPROCESSING_LEAD_TIME,'
1056: /* CP-ACK ends */
1057: ||' :v_instance_id'
1058: ||' from PJM_PROJECT_PARAMETERS'||MSC_CL_PULL.v_dblink||' mpp,'
1059: ||v_view_name||MSC_CL_PULL.v_dblink||' x'
1060: ||' where x.TO_ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
1061: ||' AND mpp.project_id (+)= x.project_id'
1062: ||' and mpp.organization_id (+)= DECODE( :v_mps_consume_profile_value,'
1063: ||' 1, x.MRP_TO_Organization_ID,'
1064: ||' x.Organization_ID)'
1065: ||' and DECODE( :v_mps_consume_profile_value,'
1066: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
1067: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
1068: ||' AND (' -- x.RN1>'||MSC_CL_PULL.v_lrn
1069: ||' x.RN2>'||MSC_CL_PULL.v_lrn
1070: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
1071:
1072: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Test Sql :'||v_sql_stmt);
1065: ||' and DECODE( :v_mps_consume_profile_value,'
1066: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
1067: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
1068: ||' AND (' -- x.RN1>'||MSC_CL_PULL.v_lrn
1069: ||' x.RN2>'||MSC_CL_PULL.v_lrn
1070: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
1071:
1072: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Test Sql :'||v_sql_stmt);
1073:
1066: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
1067: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
1068: ||' AND (' -- x.RN1>'||MSC_CL_PULL.v_lrn
1069: ||' x.RN2>'||MSC_CL_PULL.v_lrn
1070: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
1071:
1072: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Test Sql :'||v_sql_stmt);
1073:
1074: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
1070: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
1071:
1072: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Test Sql :'||v_sql_stmt);
1073:
1074: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
1075: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
1076: MSC_CL_PULL.v_mps_consume_profile_value,
1077: MSC_CL_PULL.v_mps_consume_profile_value,
1078: MSC_CL_PULL.v_mps_consume_profile_value,
1071:
1072: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Test Sql :'||v_sql_stmt);
1073:
1074: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
1075: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
1076: MSC_CL_PULL.v_mps_consume_profile_value,
1077: MSC_CL_PULL.v_mps_consume_profile_value,
1078: MSC_CL_PULL.v_mps_consume_profile_value,
1079: MSC_CL_PULL.v_dgmt,
1072: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Test Sql :'||v_sql_stmt);
1073:
1074: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
1075: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
1076: MSC_CL_PULL.v_mps_consume_profile_value,
1077: MSC_CL_PULL.v_mps_consume_profile_value,
1078: MSC_CL_PULL.v_mps_consume_profile_value,
1079: MSC_CL_PULL.v_dgmt,
1080: MSC_CL_PULL.v_refresh_id,
1073:
1074: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
1075: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
1076: MSC_CL_PULL.v_mps_consume_profile_value,
1077: MSC_CL_PULL.v_mps_consume_profile_value,
1078: MSC_CL_PULL.v_mps_consume_profile_value,
1079: MSC_CL_PULL.v_dgmt,
1080: MSC_CL_PULL.v_refresh_id,
1081: MSC_UTIL.G_MSC_CONFIGURATION, MSC_UTIL.G_CONF_APS,
1074: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
1075: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
1076: MSC_CL_PULL.v_mps_consume_profile_value,
1077: MSC_CL_PULL.v_mps_consume_profile_value,
1078: MSC_CL_PULL.v_mps_consume_profile_value,
1079: MSC_CL_PULL.v_dgmt,
1080: MSC_CL_PULL.v_refresh_id,
1081: MSC_UTIL.G_MSC_CONFIGURATION, MSC_UTIL.G_CONF_APS,
1082: MSC_UTIL.G_MSC_CONFIGURATION, MSC_UTIL.G_CONF_APS,
1075: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
1076: MSC_CL_PULL.v_mps_consume_profile_value,
1077: MSC_CL_PULL.v_mps_consume_profile_value,
1078: MSC_CL_PULL.v_mps_consume_profile_value,
1079: MSC_CL_PULL.v_dgmt,
1080: MSC_CL_PULL.v_refresh_id,
1081: MSC_UTIL.G_MSC_CONFIGURATION, MSC_UTIL.G_CONF_APS,
1082: MSC_UTIL.G_MSC_CONFIGURATION, MSC_UTIL.G_CONF_APS,
1083: MSC_CL_PULL.v_instance_id,
1076: MSC_CL_PULL.v_mps_consume_profile_value,
1077: MSC_CL_PULL.v_mps_consume_profile_value,
1078: MSC_CL_PULL.v_mps_consume_profile_value,
1079: MSC_CL_PULL.v_dgmt,
1080: MSC_CL_PULL.v_refresh_id,
1081: MSC_UTIL.G_MSC_CONFIGURATION, MSC_UTIL.G_CONF_APS,
1082: MSC_UTIL.G_MSC_CONFIGURATION, MSC_UTIL.G_CONF_APS,
1083: MSC_CL_PULL.v_instance_id,
1084: MSC_CL_PULL.v_mps_consume_profile_value,
1079: MSC_CL_PULL.v_dgmt,
1080: MSC_CL_PULL.v_refresh_id,
1081: MSC_UTIL.G_MSC_CONFIGURATION, MSC_UTIL.G_CONF_APS,
1082: MSC_UTIL.G_MSC_CONFIGURATION, MSC_UTIL.G_CONF_APS,
1083: MSC_CL_PULL.v_instance_id,
1084: MSC_CL_PULL.v_mps_consume_profile_value,
1085: MSC_CL_PULL.v_mps_consume_profile_value;
1086:
1087: COMMIT;
1080: MSC_CL_PULL.v_refresh_id,
1081: MSC_UTIL.G_MSC_CONFIGURATION, MSC_UTIL.G_CONF_APS,
1082: MSC_UTIL.G_MSC_CONFIGURATION, MSC_UTIL.G_CONF_APS,
1083: MSC_CL_PULL.v_instance_id,
1084: MSC_CL_PULL.v_mps_consume_profile_value,
1085: MSC_CL_PULL.v_mps_consume_profile_value;
1086:
1087: COMMIT;
1088:
1081: MSC_UTIL.G_MSC_CONFIGURATION, MSC_UTIL.G_CONF_APS,
1082: MSC_UTIL.G_MSC_CONFIGURATION, MSC_UTIL.G_CONF_APS,
1083: MSC_CL_PULL.v_instance_id,
1084: MSC_CL_PULL.v_mps_consume_profile_value,
1085: MSC_CL_PULL.v_mps_consume_profile_value;
1086:
1087: COMMIT;
1088:
1089: END IF ;
1097: BEGIN
1098:
1099: lv_task_start_time := sysdate;
1100:
1101: IF MSC_CL_PULL.PO_ENABLED= MSC_UTIL.SYS_YES THEN
1102: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
1103: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_REQ_SUPPLY_V';
1104:
1105: /* Added this code for VMI changes */
1098:
1099: lv_task_start_time := sysdate;
1100:
1101: IF MSC_CL_PULL.PO_ENABLED= MSC_UTIL.SYS_YES THEN
1102: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
1103: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_REQ_SUPPLY_V';
1104:
1105: /* Added this code for VMI changes */
1106: /*Begin
1099: lv_task_start_time := sysdate;
1100:
1101: IF MSC_CL_PULL.PO_ENABLED= MSC_UTIL.SYS_YES THEN
1102: MSC_CL_PULL.v_table_name:= 'MSC_ST_SUPPLIES';
1103: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_REQ_SUPPLY_V';
1104:
1105: /* Added this code for VMI changes */
1106: /*Begin
1107: Select decode(MSC_CL_PULL.v_apps_ver,MSC_UTIL.G_APPS120,'x.VMI_FLAG,',MSC_UTIL.G_APPS115,'x.VMI_FLAG,',' NULL, ')
1103: MSC_CL_PULL.v_view_name := 'MRP_AP_PO_REQ_SUPPLY_V';
1104:
1105: /* Added this code for VMI changes */
1106: /*Begin
1107: Select decode(MSC_CL_PULL.v_apps_ver,MSC_UTIL.G_APPS120,'x.VMI_FLAG,',MSC_UTIL.G_APPS115,'x.VMI_FLAG,',' NULL, ')
1108: into v_temp_sql
1109: from dual;
1110: End;*/
1111:
1108: into v_temp_sql
1109: from dual;
1110: End;*/
1111:
1112: IF MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 THEN
1113: v_temp_sql := ' x.VMI_FLAG, x.POSTPROCESSING_LEAD_TIME, ';
1114: ELSE
1115: v_temp_sql := ' NULL, NULL, ';
1116: END IF;
1122: Order_type is 2.4 - Normal Ireq From Good Sub inv --- Cond Good
1123: Order_type is 2.5 - Normal Ireq From BAD Sub inv --- Cond Bad
1124: Order_type is 2 - Normal Ireq without any Subinv attached --- Cond N/A
1125: */
1126: IF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS120 AND MSC_UTIL.G_COLLECT_SRP_DATA='Y') THEN
1127: v_temp_sql := v_temp_sql||' decode(x.order_type,2.2,73,2.3,87,2) , ';
1128: v_temp_sql := v_temp_sql ||' decode(x.order_type,
1129: 2.1,'||MSC_UTIL.G_PARTCONDN_ITEMTYPEID
1130: ||',2.2,'||MSC_UTIL.G_PARTCONDN_ITEMTYPEID
1138: ||',2.3,'||MSC_UTIL.G_PARTCONDN_GOOD
1139: ||',2.4,'||MSC_UTIL.G_PARTCONDN_GOOD
1140: ||',2.5,'||MSC_UTIL.G_PARTCONDN_BAD
1141: || '), ';
1142: ELSIF (MSC_CL_PULL.v_apps_ver >= MSC_UTIL.G_APPS115 AND MSC_UTIL.G_COLLECT_SRP_DATA='Y') THEN
1143: v_temp_sql := v_temp_sql||' decode(INSTR('''||MSC_UTIL.v_depot_org_str||''','',''||x.FROM_ORGANIZATION_ID||'',''),'
1144: || '0,decode(INSTR('''||MSC_UTIL.v_depot_org_str||''','',''||x.FROM_ORGANIZATION_ID||'')''), '
1145: || '0,decode(INSTR('''||MSC_UTIL.v_depot_org_str||''',''(''||x.FROM_ORGANIZATION_ID||'',''), '
1146: || '0,decode(INSTR('''||MSC_UTIL.v_depot_org_str||''',''(''||x.FROM_ORGANIZATION_ID||'')''), '
1233: /* CP change starts */
1234: ||' x.NEW_ORDER_PLACEMENT_DATE,'
1235: /* CP change starts */
1236: ||' :v_instance_id'
1237: ||' from PJM_PROJECT_PARAMETERS'||MSC_CL_PULL.v_dblink||' mpp,'
1238: ||' MRP_AP_PO_REQ_SUPPLY_V'||MSC_CL_PULL.v_dblink||' x'
1239: ||' where x.TO_ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
1240: ||' AND mpp.project_id (+)= x.project_id'
1241: ||' and mpp.organization_id (+)= DECODE( :v_mps_consume_profile_value,'
1234: ||' x.NEW_ORDER_PLACEMENT_DATE,'
1235: /* CP change starts */
1236: ||' :v_instance_id'
1237: ||' from PJM_PROJECT_PARAMETERS'||MSC_CL_PULL.v_dblink||' mpp,'
1238: ||' MRP_AP_PO_REQ_SUPPLY_V'||MSC_CL_PULL.v_dblink||' x'
1239: ||' where x.TO_ORGANIZATION_ID'||MSC_UTIL.v_in_org_str
1240: ||' AND mpp.project_id (+)= x.project_id'
1241: ||' and mpp.organization_id (+)= DECODE( :v_mps_consume_profile_value,'
1242: ||' 1, x.MRP_TO_Organization_ID,'
1243: ||' x.Organization_ID)'
1244: ||' and DECODE( :v_mps_consume_profile_value,'
1245: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
1246: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
1247: ||' AND (' --x.RN1>'||MSC_CL_PULL.v_lrn
1248: ||' x.RN2>'||MSC_CL_PULL.v_lrn
1249: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
1250: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Test Sql PO_REC INSERT :'||v_sql_stmt);
1251: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
1244: ||' and DECODE( :v_mps_consume_profile_value,'
1245: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
1246: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
1247: ||' AND (' --x.RN1>'||MSC_CL_PULL.v_lrn
1248: ||' x.RN2>'||MSC_CL_PULL.v_lrn
1249: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
1250: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Test Sql PO_REC INSERT :'||v_sql_stmt);
1251: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
1252: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
1245: ||' 1, x.MRP_DESTINATION_TYPE_CODE,'
1246: ||' x.DESTINATION_TYPE_CODE)= ''INVENTORY'''
1247: ||' AND (' --x.RN1>'||MSC_CL_PULL.v_lrn
1248: ||' x.RN2>'||MSC_CL_PULL.v_lrn
1249: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
1250: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Test Sql PO_REC INSERT :'||v_sql_stmt);
1251: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
1252: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
1253: MSC_CL_PULL.v_mps_consume_profile_value,
1247: ||' AND (' --x.RN1>'||MSC_CL_PULL.v_lrn
1248: ||' x.RN2>'||MSC_CL_PULL.v_lrn
1249: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
1250: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Test Sql PO_REC INSERT :'||v_sql_stmt);
1251: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
1252: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
1253: MSC_CL_PULL.v_mps_consume_profile_value,
1254: MSC_CL_PULL.v_mps_consume_profile_value,
1255: MSC_CL_PULL.v_mps_consume_profile_value,
1248: ||' x.RN2>'||MSC_CL_PULL.v_lrn
1249: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
1250: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Test Sql PO_REC INSERT :'||v_sql_stmt);
1251: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
1252: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
1253: MSC_CL_PULL.v_mps_consume_profile_value,
1254: MSC_CL_PULL.v_mps_consume_profile_value,
1255: MSC_CL_PULL.v_mps_consume_profile_value,
1256: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
1249: ||' OR x.RN3>'||MSC_CL_PULL.v_lrn||')';
1250: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Test Sql PO_REC INSERT :'||v_sql_stmt);
1251: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
1252: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
1253: MSC_CL_PULL.v_mps_consume_profile_value,
1254: MSC_CL_PULL.v_mps_consume_profile_value,
1255: MSC_CL_PULL.v_mps_consume_profile_value,
1256: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
1257: MSC_CL_PULL.v_mps_consume_profile_value,
1250: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Test Sql PO_REC INSERT :'||v_sql_stmt);
1251: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
1252: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
1253: MSC_CL_PULL.v_mps_consume_profile_value,
1254: MSC_CL_PULL.v_mps_consume_profile_value,
1255: MSC_CL_PULL.v_mps_consume_profile_value,
1256: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
1257: MSC_CL_PULL.v_mps_consume_profile_value,
1258: MSC_CL_PULL.v_mps_consume_profile_value;
1251: EXECUTE IMMEDIATE v_sql_stmt USING MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_instance_id,
1252: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
1253: MSC_CL_PULL.v_mps_consume_profile_value,
1254: MSC_CL_PULL.v_mps_consume_profile_value,
1255: MSC_CL_PULL.v_mps_consume_profile_value,
1256: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
1257: MSC_CL_PULL.v_mps_consume_profile_value,
1258: MSC_CL_PULL.v_mps_consume_profile_value;
1259:
1252: MSC_CL_PULL.v_mps_consume_profile_value, MSC_CL_PULL.v_dgmt,
1253: MSC_CL_PULL.v_mps_consume_profile_value,
1254: MSC_CL_PULL.v_mps_consume_profile_value,
1255: MSC_CL_PULL.v_mps_consume_profile_value,
1256: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
1257: MSC_CL_PULL.v_mps_consume_profile_value,
1258: MSC_CL_PULL.v_mps_consume_profile_value;
1259:
1260: COMMIT;
1253: MSC_CL_PULL.v_mps_consume_profile_value,
1254: MSC_CL_PULL.v_mps_consume_profile_value,
1255: MSC_CL_PULL.v_mps_consume_profile_value,
1256: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
1257: MSC_CL_PULL.v_mps_consume_profile_value,
1258: MSC_CL_PULL.v_mps_consume_profile_value;
1259:
1260: COMMIT;
1261:
1254: MSC_CL_PULL.v_mps_consume_profile_value,
1255: MSC_CL_PULL.v_mps_consume_profile_value,
1256: MSC_CL_PULL.v_dgmt, MSC_CL_PULL.v_refresh_id, MSC_CL_PULL.v_instance_id,
1257: MSC_CL_PULL.v_mps_consume_profile_value,
1258: MSC_CL_PULL.v_mps_consume_profile_value;
1259:
1260: COMMIT;
1261:
1262: END IF ;