1: PACKAGE BODY MSC_CL_SUPPLY_ODS_LOAD AS -- body
2: /*$Header: MSCLSUPB.pls 120.32.12020000.7 2013/02/06 10:02:23 swundapa ship $*/
3: -- G_JOB_DONE NUMBER := MSC_CL_COLLECTION.G_JOB_DONE;
4: -- G_JOB_NOT_DONE NUMBER := MSC_CL_COLLECTION.G_JOB_NOT_DONE;
5: -- G_JOB_ERROR NUMBER := MSC_CL_COLLECTION.G_JOB_ERROR;
6: -- G_MRP_PO_ACK NUMBER := MSC_CL_COLLECTION.G_MRP_PO_ACK;
7: -- SYS_YES Number:= MSC_CL_COLLECTION.SYS_YES ;
1: PACKAGE BODY MSC_CL_SUPPLY_ODS_LOAD AS -- body
2: /*$Header: MSCLSUPB.pls 120.32.12020000.7 2013/02/06 10:02:23 swundapa ship $*/
3: -- G_JOB_DONE NUMBER := MSC_CL_COLLECTION.G_JOB_DONE;
4: -- G_JOB_NOT_DONE NUMBER := MSC_CL_COLLECTION.G_JOB_NOT_DONE;
5: -- G_JOB_ERROR NUMBER := MSC_CL_COLLECTION.G_JOB_ERROR;
6: -- G_MRP_PO_ACK NUMBER := MSC_CL_COLLECTION.G_MRP_PO_ACK;
7: -- SYS_YES Number:= MSC_CL_COLLECTION.SYS_YES ;
8: -- SYS_NO Number:= MSC_CL_COLLECTION.SYS_NO ;
1: PACKAGE BODY MSC_CL_SUPPLY_ODS_LOAD AS -- body
2: /*$Header: MSCLSUPB.pls 120.32.12020000.7 2013/02/06 10:02:23 swundapa ship $*/
3: -- G_JOB_DONE NUMBER := MSC_CL_COLLECTION.G_JOB_DONE;
4: -- G_JOB_NOT_DONE NUMBER := MSC_CL_COLLECTION.G_JOB_NOT_DONE;
5: -- G_JOB_ERROR NUMBER := MSC_CL_COLLECTION.G_JOB_ERROR;
6: -- G_MRP_PO_ACK NUMBER := MSC_CL_COLLECTION.G_MRP_PO_ACK;
7: -- SYS_YES Number:= MSC_CL_COLLECTION.SYS_YES ;
8: -- SYS_NO Number:= MSC_CL_COLLECTION.SYS_NO ;
9: -- PROMISED_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
2: /*$Header: MSCLSUPB.pls 120.32.12020000.7 2013/02/06 10:02:23 swundapa ship $*/
3: -- G_JOB_DONE NUMBER := MSC_CL_COLLECTION.G_JOB_DONE;
4: -- G_JOB_NOT_DONE NUMBER := MSC_CL_COLLECTION.G_JOB_NOT_DONE;
5: -- G_JOB_ERROR NUMBER := MSC_CL_COLLECTION.G_JOB_ERROR;
6: -- G_MRP_PO_ACK NUMBER := MSC_CL_COLLECTION.G_MRP_PO_ACK;
7: -- SYS_YES Number:= MSC_CL_COLLECTION.SYS_YES ;
8: -- SYS_NO Number:= MSC_CL_COLLECTION.SYS_NO ;
9: -- PROMISED_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
10: -- NEED_BY_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
3: -- G_JOB_DONE NUMBER := MSC_CL_COLLECTION.G_JOB_DONE;
4: -- G_JOB_NOT_DONE NUMBER := MSC_CL_COLLECTION.G_JOB_NOT_DONE;
5: -- G_JOB_ERROR NUMBER := MSC_CL_COLLECTION.G_JOB_ERROR;
6: -- G_MRP_PO_ACK NUMBER := MSC_CL_COLLECTION.G_MRP_PO_ACK;
7: -- SYS_YES Number:= MSC_CL_COLLECTION.SYS_YES ;
8: -- SYS_NO Number:= MSC_CL_COLLECTION.SYS_NO ;
9: -- PROMISED_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
10: -- NEED_BY_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
11: -- G_ALL_ORGANIZATIONS VARCHAR2(6):= MSC_CL_COLLECTION.G_ALL_ORGANIZATIONS;
4: -- G_JOB_NOT_DONE NUMBER := MSC_CL_COLLECTION.G_JOB_NOT_DONE;
5: -- G_JOB_ERROR NUMBER := MSC_CL_COLLECTION.G_JOB_ERROR;
6: -- G_MRP_PO_ACK NUMBER := MSC_CL_COLLECTION.G_MRP_PO_ACK;
7: -- SYS_YES Number:= MSC_CL_COLLECTION.SYS_YES ;
8: -- SYS_NO Number:= MSC_CL_COLLECTION.SYS_NO ;
9: -- PROMISED_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
10: -- NEED_BY_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
11: -- G_ALL_ORGANIZATIONS VARCHAR2(6):= MSC_CL_COLLECTION.G_ALL_ORGANIZATIONS;
12: -- SYS_INCR Number:=MSC_CL_COLLECTION.SYS_INCR;
5: -- G_JOB_ERROR NUMBER := MSC_CL_COLLECTION.G_JOB_ERROR;
6: -- G_MRP_PO_ACK NUMBER := MSC_CL_COLLECTION.G_MRP_PO_ACK;
7: -- SYS_YES Number:= MSC_CL_COLLECTION.SYS_YES ;
8: -- SYS_NO Number:= MSC_CL_COLLECTION.SYS_NO ;
9: -- PROMISED_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
10: -- NEED_BY_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
11: -- G_ALL_ORGANIZATIONS VARCHAR2(6):= MSC_CL_COLLECTION.G_ALL_ORGANIZATIONS;
12: -- SYS_INCR Number:=MSC_CL_COLLECTION.SYS_INCR;
13: -- SYS_TGT Number:=MSC_CL_COLLECTION.SYS_TGT;
6: -- G_MRP_PO_ACK NUMBER := MSC_CL_COLLECTION.G_MRP_PO_ACK;
7: -- SYS_YES Number:= MSC_CL_COLLECTION.SYS_YES ;
8: -- SYS_NO Number:= MSC_CL_COLLECTION.SYS_NO ;
9: -- PROMISED_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
10: -- NEED_BY_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
11: -- G_ALL_ORGANIZATIONS VARCHAR2(6):= MSC_CL_COLLECTION.G_ALL_ORGANIZATIONS;
12: -- SYS_INCR Number:=MSC_CL_COLLECTION.SYS_INCR;
13: -- SYS_TGT Number:=MSC_CL_COLLECTION.SYS_TGT;
14: -- NULL_VALUE NUMBER:= MSC_UTIL.NULL_VALUE;
7: -- SYS_YES Number:= MSC_CL_COLLECTION.SYS_YES ;
8: -- SYS_NO Number:= MSC_CL_COLLECTION.SYS_NO ;
9: -- PROMISED_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
10: -- NEED_BY_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
11: -- G_ALL_ORGANIZATIONS VARCHAR2(6):= MSC_CL_COLLECTION.G_ALL_ORGANIZATIONS;
12: -- SYS_INCR Number:=MSC_CL_COLLECTION.SYS_INCR;
13: -- SYS_TGT Number:=MSC_CL_COLLECTION.SYS_TGT;
14: -- NULL_VALUE NUMBER:= MSC_UTIL.NULL_VALUE;
15: -- NULL_CHAR VARCHAR2(6):=MSC_UTIL.NULL_CHAR;
8: -- SYS_NO Number:= MSC_CL_COLLECTION.SYS_NO ;
9: -- PROMISED_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
10: -- NEED_BY_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
11: -- G_ALL_ORGANIZATIONS VARCHAR2(6):= MSC_CL_COLLECTION.G_ALL_ORGANIZATIONS;
12: -- SYS_INCR Number:=MSC_CL_COLLECTION.SYS_INCR;
13: -- SYS_TGT Number:=MSC_CL_COLLECTION.SYS_TGT;
14: -- NULL_VALUE NUMBER:= MSC_UTIL.NULL_VALUE;
15: -- NULL_CHAR VARCHAR2(6):=MSC_UTIL.NULL_CHAR;
16: -- G_CONF_APS_SCE NUMBER :=MSC_CL_COLLECTION.G_CONF_APS_SCE;
9: -- PROMISED_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
10: -- NEED_BY_DATE_PREF NUMBER := MSC_CL_COLLECTION.PROMISED_DATE_PREF;
11: -- G_ALL_ORGANIZATIONS VARCHAR2(6):= MSC_CL_COLLECTION.G_ALL_ORGANIZATIONS;
12: -- SYS_INCR Number:=MSC_CL_COLLECTION.SYS_INCR;
13: -- SYS_TGT Number:=MSC_CL_COLLECTION.SYS_TGT;
14: -- NULL_VALUE NUMBER:= MSC_UTIL.NULL_VALUE;
15: -- NULL_CHAR VARCHAR2(6):=MSC_UTIL.NULL_CHAR;
16: -- G_CONF_APS_SCE NUMBER :=MSC_CL_COLLECTION.G_CONF_APS_SCE;
17: -- G_CONF_SCE NUMBER :=MSC_CL_COLLECTION.G_CONF_SCE;
12: -- SYS_INCR Number:=MSC_CL_COLLECTION.SYS_INCR;
13: -- SYS_TGT Number:=MSC_CL_COLLECTION.SYS_TGT;
14: -- NULL_VALUE NUMBER:= MSC_UTIL.NULL_VALUE;
15: -- NULL_CHAR VARCHAR2(6):=MSC_UTIL.NULL_CHAR;
16: -- G_CONF_APS_SCE NUMBER :=MSC_CL_COLLECTION.G_CONF_APS_SCE;
17: -- G_CONF_SCE NUMBER :=MSC_CL_COLLECTION.G_CONF_SCE;
18:
19: FUNCTION IS_SUPPLIES_LOAD_DONE
20: RETURN boolean
13: -- SYS_TGT Number:=MSC_CL_COLLECTION.SYS_TGT;
14: -- NULL_VALUE NUMBER:= MSC_UTIL.NULL_VALUE;
15: -- NULL_CHAR VARCHAR2(6):=MSC_UTIL.NULL_CHAR;
16: -- G_CONF_APS_SCE NUMBER :=MSC_CL_COLLECTION.G_CONF_APS_SCE;
17: -- G_CONF_SCE NUMBER :=MSC_CL_COLLECTION.G_CONF_SCE;
18:
19: FUNCTION IS_SUPPLIES_LOAD_DONE
20: RETURN boolean
21: IS
27: so that other procedures (Demand-WIP Demand - Sales orders - Resource Reqmnts) can start loading */
28:
29: LOOP
30:
31: select nvl(SUPPLIES_LOAD_FLAG,MSC_CL_COLLECTION.G_JOB_NOT_DONE)
32: into lv_is_job_done
33: from msc_apps_instances
34: where instance_id = MSC_CL_COLLECTION.v_instance_id;
35:
30:
31: select nvl(SUPPLIES_LOAD_FLAG,MSC_CL_COLLECTION.G_JOB_NOT_DONE)
32: into lv_is_job_done
33: from msc_apps_instances
34: where instance_id = MSC_CL_COLLECTION.v_instance_id;
35:
36: select (SYSDATE- MSC_CL_COLLECTION.START_TIME) into lv_process_time from dual;
37:
38: IF lv_process_time > MSC_CL_COLLECTION.p_TIMEOUT/1440.0 THEN
32: into lv_is_job_done
33: from msc_apps_instances
34: where instance_id = MSC_CL_COLLECTION.v_instance_id;
35:
36: select (SYSDATE- MSC_CL_COLLECTION.START_TIME) into lv_process_time from dual;
37:
38: IF lv_process_time > MSC_CL_COLLECTION.p_TIMEOUT/1440.0 THEN
39: lv_is_job_done := MSC_CL_COLLECTION.G_JOB_ERROR;
40: END IF;
34: where instance_id = MSC_CL_COLLECTION.v_instance_id;
35:
36: select (SYSDATE- MSC_CL_COLLECTION.START_TIME) into lv_process_time from dual;
37:
38: IF lv_process_time > MSC_CL_COLLECTION.p_TIMEOUT/1440.0 THEN
39: lv_is_job_done := MSC_CL_COLLECTION.G_JOB_ERROR;
40: END IF;
41:
42: EXIT WHEN (lv_is_job_done = MSC_CL_COLLECTION.G_JOB_DONE) OR (lv_is_job_done= MSC_CL_COLLECTION.G_JOB_ERROR);
35:
36: select (SYSDATE- MSC_CL_COLLECTION.START_TIME) into lv_process_time from dual;
37:
38: IF lv_process_time > MSC_CL_COLLECTION.p_TIMEOUT/1440.0 THEN
39: lv_is_job_done := MSC_CL_COLLECTION.G_JOB_ERROR;
40: END IF;
41:
42: EXIT WHEN (lv_is_job_done = MSC_CL_COLLECTION.G_JOB_DONE) OR (lv_is_job_done= MSC_CL_COLLECTION.G_JOB_ERROR);
43: END LOOP;
38: IF lv_process_time > MSC_CL_COLLECTION.p_TIMEOUT/1440.0 THEN
39: lv_is_job_done := MSC_CL_COLLECTION.G_JOB_ERROR;
40: END IF;
41:
42: EXIT WHEN (lv_is_job_done = MSC_CL_COLLECTION.G_JOB_DONE) OR (lv_is_job_done= MSC_CL_COLLECTION.G_JOB_ERROR);
43: END LOOP;
44:
45: IF (lv_is_job_done = MSC_CL_COLLECTION.G_JOB_DONE) THEN
46: RETURN TRUE;
41:
42: EXIT WHEN (lv_is_job_done = MSC_CL_COLLECTION.G_JOB_DONE) OR (lv_is_job_done= MSC_CL_COLLECTION.G_JOB_ERROR);
43: END LOOP;
44:
45: IF (lv_is_job_done = MSC_CL_COLLECTION.G_JOB_DONE) THEN
46: RETURN TRUE;
47: ELSIF (lv_is_job_done = MSC_CL_COLLECTION.G_JOB_ERROR) THEN
48: RETURN FALSE;
49: END IF;
43: END LOOP;
44:
45: IF (lv_is_job_done = MSC_CL_COLLECTION.G_JOB_DONE) THEN
46: RETURN TRUE;
47: ELSIF (lv_is_job_done = MSC_CL_COLLECTION.G_JOB_ERROR) THEN
48: RETURN FALSE;
49: END IF;
50:
51: RETURN TRUE;
66: lv_dummy2 varchar2(32);
67:
68: BEGIN
69:
70: lv_retval := FND_INSTALLATION.GET_APP_INFO ( 'FND', lv_dummy1, lv_dummy2, MSC_CL_COLLECTION.v_applsys_schema);
71:
72: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
73: application_short_name => 'MSC',
74: statement_type => AD_DDL.CREATE_INDEX,
68: BEGIN
69:
70: lv_retval := FND_INSTALLATION.GET_APP_INFO ( 'FND', lv_dummy1, lv_dummy2, MSC_CL_COLLECTION.v_applsys_schema);
71:
72: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
73: application_short_name => 'MSC',
74: statement_type => AD_DDL.CREATE_INDEX,
75: statement =>
76: 'create index supplies_nx_'||MSC_CL_COLLECTION.v_instance_code
72: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
73: application_short_name => 'MSC',
74: statement_type => AD_DDL.CREATE_INDEX,
75: statement =>
76: 'create index supplies_nx_'||MSC_CL_COLLECTION.v_instance_code
77: ||' on '||'supplies_'||MSC_CL_COLLECTION.v_instance_code
78: ||'(disposition_id, order_type) '
79: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
80: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
73: application_short_name => 'MSC',
74: statement_type => AD_DDL.CREATE_INDEX,
75: statement =>
76: 'create index supplies_nx_'||MSC_CL_COLLECTION.v_instance_code
77: ||' on '||'supplies_'||MSC_CL_COLLECTION.v_instance_code
78: ||'(disposition_id, order_type) '
79: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
80: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
81: object_name => 'supplies_nx_'||MSC_CL_COLLECTION.v_instance_code);
75: statement =>
76: 'create index supplies_nx_'||MSC_CL_COLLECTION.v_instance_code
77: ||' on '||'supplies_'||MSC_CL_COLLECTION.v_instance_code
78: ||'(disposition_id, order_type) '
79: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
80: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
81: object_name => 'supplies_nx_'||MSC_CL_COLLECTION.v_instance_code);
82:
83: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, ' Index SUPPLIES_NX_'||MSC_CL_COLLECTION.v_instance_code||' created.');
77: ||' on '||'supplies_'||MSC_CL_COLLECTION.v_instance_code
78: ||'(disposition_id, order_type) '
79: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
80: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
81: object_name => 'supplies_nx_'||MSC_CL_COLLECTION.v_instance_code);
82:
83: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, ' Index SUPPLIES_NX_'||MSC_CL_COLLECTION.v_instance_code||' created.');
84:
85: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
79: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
80: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
81: object_name => 'supplies_nx_'||MSC_CL_COLLECTION.v_instance_code);
82:
83: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, ' Index SUPPLIES_NX_'||MSC_CL_COLLECTION.v_instance_code||' created.');
84:
85: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
86: application_short_name => 'MSC',
87: statement_type => AD_DDL.CREATE_INDEX,
81: object_name => 'supplies_nx_'||MSC_CL_COLLECTION.v_instance_code);
82:
83: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, ' Index SUPPLIES_NX_'||MSC_CL_COLLECTION.v_instance_code||' created.');
84:
85: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
86: application_short_name => 'MSC',
87: statement_type => AD_DDL.CREATE_INDEX,
88: statement =>
89: 'create index supplies_nx1_'||MSC_CL_COLLECTION.v_instance_code
85: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
86: application_short_name => 'MSC',
87: statement_type => AD_DDL.CREATE_INDEX,
88: statement =>
89: 'create index supplies_nx1_'||MSC_CL_COLLECTION.v_instance_code
90: ||' on '||'supplies_'||MSC_CL_COLLECTION.v_instance_code
91: ||'(plan_id, sr_instance_id, order_number, purch_line_num) '
92: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
93: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
86: application_short_name => 'MSC',
87: statement_type => AD_DDL.CREATE_INDEX,
88: statement =>
89: 'create index supplies_nx1_'||MSC_CL_COLLECTION.v_instance_code
90: ||' on '||'supplies_'||MSC_CL_COLLECTION.v_instance_code
91: ||'(plan_id, sr_instance_id, order_number, purch_line_num) '
92: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
93: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
94: object_name => 'supplies_nx1_'||MSC_CL_COLLECTION.v_instance_code);
88: statement =>
89: 'create index supplies_nx1_'||MSC_CL_COLLECTION.v_instance_code
90: ||' on '||'supplies_'||MSC_CL_COLLECTION.v_instance_code
91: ||'(plan_id, sr_instance_id, order_number, purch_line_num) '
92: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
93: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
94: object_name => 'supplies_nx1_'||MSC_CL_COLLECTION.v_instance_code);
95:
96: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, ' Index SUPPLIES_NX1_'||MSC_CL_COLLECTION.v_instance_code||' created.');
90: ||' on '||'supplies_'||MSC_CL_COLLECTION.v_instance_code
91: ||'(plan_id, sr_instance_id, order_number, purch_line_num) '
92: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
93: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
94: object_name => 'supplies_nx1_'||MSC_CL_COLLECTION.v_instance_code);
95:
96: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, ' Index SUPPLIES_NX1_'||MSC_CL_COLLECTION.v_instance_code||' created.');
97:
98: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
92: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
93: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
94: object_name => 'supplies_nx1_'||MSC_CL_COLLECTION.v_instance_code);
95:
96: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, ' Index SUPPLIES_NX1_'||MSC_CL_COLLECTION.v_instance_code||' created.');
97:
98: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
99: application_short_name => 'MSC',
100: statement_type => AD_DDL.CREATE_INDEX,
94: object_name => 'supplies_nx1_'||MSC_CL_COLLECTION.v_instance_code);
95:
96: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, ' Index SUPPLIES_NX1_'||MSC_CL_COLLECTION.v_instance_code||' created.');
97:
98: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
99: application_short_name => 'MSC',
100: statement_type => AD_DDL.CREATE_INDEX,
101: statement =>
102: 'create index supplies_nx2_'||MSC_CL_COLLECTION.v_instance_code
98: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
99: application_short_name => 'MSC',
100: statement_type => AD_DDL.CREATE_INDEX,
101: statement =>
102: 'create index supplies_nx2_'||MSC_CL_COLLECTION.v_instance_code
103: ||' on '||'supplies_'||MSC_CL_COLLECTION.v_instance_code
104: ||'(plan_id, sr_instance_id, disposition_id, po_line_id ) '
105: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
106: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
99: application_short_name => 'MSC',
100: statement_type => AD_DDL.CREATE_INDEX,
101: statement =>
102: 'create index supplies_nx2_'||MSC_CL_COLLECTION.v_instance_code
103: ||' on '||'supplies_'||MSC_CL_COLLECTION.v_instance_code
104: ||'(plan_id, sr_instance_id, disposition_id, po_line_id ) '
105: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
106: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
107: object_name => 'supplies_nx2_'||MSC_CL_COLLECTION.v_instance_code);
101: statement =>
102: 'create index supplies_nx2_'||MSC_CL_COLLECTION.v_instance_code
103: ||' on '||'supplies_'||MSC_CL_COLLECTION.v_instance_code
104: ||'(plan_id, sr_instance_id, disposition_id, po_line_id ) '
105: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
106: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
107: object_name => 'supplies_nx2_'||MSC_CL_COLLECTION.v_instance_code);
108: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, ' Index SUPPLIES_NX2_'||MSC_CL_COLLECTION.v_instance_code||' created.');
109:
103: ||' on '||'supplies_'||MSC_CL_COLLECTION.v_instance_code
104: ||'(plan_id, sr_instance_id, disposition_id, po_line_id ) '
105: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
106: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
107: object_name => 'supplies_nx2_'||MSC_CL_COLLECTION.v_instance_code);
108: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, ' Index SUPPLIES_NX2_'||MSC_CL_COLLECTION.v_instance_code||' created.');
109:
110: RETURN TRUE;
111:
104: ||'(plan_id, sr_instance_id, disposition_id, po_line_id ) '
105: ||' PARALLEL ' || MSC_CL_COLLECTION.G_DEG_PARALLEL
106: ||' STORAGE (INITIAL 100K NEXT 1M PCTINCREASE 0) ',
107: object_name => 'supplies_nx2_'||MSC_CL_COLLECTION.v_instance_code);
108: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, ' Index SUPPLIES_NX2_'||MSC_CL_COLLECTION.v_instance_code||' created.');
109:
110: RETURN TRUE;
111:
112: EXCEPTION
112: EXCEPTION
113: WHEN OTHERS THEN
114: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
115: update msc_apps_instances
116: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
117: where instance_id = MSC_CL_COLLECTION.v_instance_id;
118: commit;
119: RETURN FALSE;
120: END create_supplies_tmp_ind;
113: WHEN OTHERS THEN
114: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
115: update msc_apps_instances
116: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
117: where instance_id = MSC_CL_COLLECTION.v_instance_id;
118: commit;
119: RETURN FALSE;
120: END create_supplies_tmp_ind;
121:
134:
135: BEGIN
136:
137: lv_retval := FND_INSTALLATION.GET_APP_INFO('FND', lv_dummy1, lv_dummy2
138: , MSC_CL_COLLECTION.v_applsys_schema);
139:
140: lv_retval := FND_INSTALLATION.GET_APP_INFO ('MSC', lv_dummy1, lv_dummy2,lv_msc_schema);
141:
142: lv_temp_sql_stmt := ' SELECT 1 '
144: ||' where owner = :p_schema '
145: ||' and table_owner = :p_schema '
146: ||' and index_name = upper(:ind_name) ' ;
147:
148: lv_ind_name := 'SUPPLIES_NX_'||MSC_CL_COLLECTION.v_instance_code;
149:
150: EXECUTE IMMEDIATE lv_temp_sql_stmt
151: INTO lv_drop_index
152: USING lv_msc_schema,lv_msc_schema,lv_ind_name;
153:
154: IF (lv_drop_index = 1) THEN
155:
156: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Dropping the index :'||lv_ind_name);
157: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
158: application_short_name => 'MSC',
159: statement_type => AD_DDL.DROP_INDEX,
160: statement =>
161: 'drop index supplies_nx_'||MSC_CL_COLLECTION.v_instance_code,
157: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
158: application_short_name => 'MSC',
159: statement_type => AD_DDL.DROP_INDEX,
160: statement =>
161: 'drop index supplies_nx_'||MSC_CL_COLLECTION.v_instance_code,
162: object_name => 'supplies_nx_'||MSC_CL_COLLECTION.v_instance_code);
163: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Dropped the index :'||lv_ind_name);
164:
165: lv_drop_index := 2;
158: application_short_name => 'MSC',
159: statement_type => AD_DDL.DROP_INDEX,
160: statement =>
161: 'drop index supplies_nx_'||MSC_CL_COLLECTION.v_instance_code,
162: object_name => 'supplies_nx_'||MSC_CL_COLLECTION.v_instance_code);
163: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Dropped the index :'||lv_ind_name);
164:
165: lv_drop_index := 2;
166: END IF;
164:
165: lv_drop_index := 2;
166: END IF;
167:
168: lv_ind_name := 'SUPPLIES_NX1_'||MSC_CL_COLLECTION.v_instance_code;
169:
170: EXECUTE IMMEDIATE lv_temp_sql_stmt
171: INTO lv_drop_index
172: USING lv_msc_schema,lv_msc_schema,lv_ind_name;
172: USING lv_msc_schema,lv_msc_schema,lv_ind_name;
173:
174: IF (lv_drop_index = 1) THEN
175: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Dropping the index :'||lv_ind_name);
176: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
177: application_short_name => 'MSC',
178: statement_type => AD_DDL.DROP_INDEX,
179: statement =>
180: 'drop index supplies_nx1_'||MSC_CL_COLLECTION.v_instance_code,
176: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
177: application_short_name => 'MSC',
178: statement_type => AD_DDL.DROP_INDEX,
179: statement =>
180: 'drop index supplies_nx1_'||MSC_CL_COLLECTION.v_instance_code,
181: object_name => 'supplies_nx1_'||MSC_CL_COLLECTION.v_instance_code);
182:
183: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Dropped the index :'||lv_ind_name);
184: lv_drop_index :=2 ;
177: application_short_name => 'MSC',
178: statement_type => AD_DDL.DROP_INDEX,
179: statement =>
180: 'drop index supplies_nx1_'||MSC_CL_COLLECTION.v_instance_code,
181: object_name => 'supplies_nx1_'||MSC_CL_COLLECTION.v_instance_code);
182:
183: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Dropped the index :'||lv_ind_name);
184: lv_drop_index :=2 ;
185: END IF;
183: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Dropped the index :'||lv_ind_name);
184: lv_drop_index :=2 ;
185: END IF;
186:
187: lv_ind_name := 'SUPPLIES_NX2_'||MSC_CL_COLLECTION.v_instance_code;
188:
189: EXECUTE IMMEDIATE lv_temp_sql_stmt
190: INTO lv_drop_index
191: USING lv_msc_schema,lv_msc_schema,lv_ind_name;
191: USING lv_msc_schema,lv_msc_schema,lv_ind_name;
192:
193: IF (lv_drop_index = 1) THEN
194: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Dropping the index :'||lv_ind_name);
195: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
196: application_short_name => 'MSC',
197: statement_type => AD_DDL.DROP_INDEX,
198: statement =>
199: 'drop index supplies_nx2_'||MSC_CL_COLLECTION.v_instance_code,
195: ad_ddl.do_ddl( applsys_schema => MSC_CL_COLLECTION.v_applsys_schema,
196: application_short_name => 'MSC',
197: statement_type => AD_DDL.DROP_INDEX,
198: statement =>
199: 'drop index supplies_nx2_'||MSC_CL_COLLECTION.v_instance_code,
200: object_name => 'supplies_nx2_'||MSC_CL_COLLECTION.v_instance_code);
201: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Dropped the index :'||lv_ind_name);
202: lv_drop_index := 2;
203: END IF;
196: application_short_name => 'MSC',
197: statement_type => AD_DDL.DROP_INDEX,
198: statement =>
199: 'drop index supplies_nx2_'||MSC_CL_COLLECTION.v_instance_code,
200: object_name => 'supplies_nx2_'||MSC_CL_COLLECTION.v_instance_code);
201: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Dropped the index :'||lv_ind_name);
202: lv_drop_index := 2;
203: END IF;
204:
332: x.NEW_SHIP_DATE,
333: /* CP-ACK starts */
334: -- bug 2773881 - Use either PROMISED_DATE or NEED_BY_DATE
335: nvl(decode(lv_po_dock_date_ref,
336: MSC_CL_COLLECTION.PROMISED_DATE_PREF, nvl(x.PROMISED_DATE, x.NEED_BY_DATE),
337: MSC_CL_COLLECTION.NEED_BY_DATE_PREF , nvl(x.NEED_BY_DATE, x.PROMISED_DATE)
338: --PROMISED_DATE_PREF, x.NEW_DOCK_DATE,
339: --MSC_CL_COLLECTION.NEED_BY_DATE_PREF , nvl(x.NEED_BY_DATE, x.NEW_DOCK_DATE)
340: ),new_dock_date) NEW_DOCK_DATE,
333: /* CP-ACK starts */
334: -- bug 2773881 - Use either PROMISED_DATE or NEED_BY_DATE
335: nvl(decode(lv_po_dock_date_ref,
336: MSC_CL_COLLECTION.PROMISED_DATE_PREF, nvl(x.PROMISED_DATE, x.NEED_BY_DATE),
337: MSC_CL_COLLECTION.NEED_BY_DATE_PREF , nvl(x.NEED_BY_DATE, x.PROMISED_DATE)
338: --PROMISED_DATE_PREF, x.NEW_DOCK_DATE,
339: --MSC_CL_COLLECTION.NEED_BY_DATE_PREF , nvl(x.NEED_BY_DATE, x.NEW_DOCK_DATE)
340: ),new_dock_date) NEW_DOCK_DATE,
341: /* CP-ACK ends */
335: nvl(decode(lv_po_dock_date_ref,
336: MSC_CL_COLLECTION.PROMISED_DATE_PREF, nvl(x.PROMISED_DATE, x.NEED_BY_DATE),
337: MSC_CL_COLLECTION.NEED_BY_DATE_PREF , nvl(x.NEED_BY_DATE, x.PROMISED_DATE)
338: --PROMISED_DATE_PREF, x.NEW_DOCK_DATE,
339: --MSC_CL_COLLECTION.NEED_BY_DATE_PREF , nvl(x.NEED_BY_DATE, x.NEW_DOCK_DATE)
340: ),new_dock_date) NEW_DOCK_DATE,
341: /* CP-ACK ends */
342: x.LINE_ID,
343: x.PROJECT_ID,
344: x.TASK_ID,
345: x.PLANNING_GROUP,
346: x.NUMBER1,
347: x.SOURCE_ITEM_ID,
348: REPLACE(REPLACE(x.ORDER_NUMBER,MSC_CL_COLLECTION.v_chr10),MSC_CL_COLLECTION.v_chr13) ORDER_NUMBER,
349: x.SCHEDULE_GROUP_ID,
350: x.BUILD_SEQUENCE,
351: REPLACE(REPLACE(x.WIP_ENTITY_NAME,MSC_CL_COLLECTION.v_chr10),MSC_CL_COLLECTION.v_chr13) WIP_ENTITY_NAME,
352: x.IMPLEMENT_PROCESSING_DAYS,
347: x.SOURCE_ITEM_ID,
348: REPLACE(REPLACE(x.ORDER_NUMBER,MSC_CL_COLLECTION.v_chr10),MSC_CL_COLLECTION.v_chr13) ORDER_NUMBER,
349: x.SCHEDULE_GROUP_ID,
350: x.BUILD_SEQUENCE,
351: REPLACE(REPLACE(x.WIP_ENTITY_NAME,MSC_CL_COLLECTION.v_chr10),MSC_CL_COLLECTION.v_chr13) WIP_ENTITY_NAME,
352: x.IMPLEMENT_PROCESSING_DAYS,
353: x.DELIVERY_PRICE,
354: x.LATE_SUPPLY_DATE,
355: x.LATE_SUPPLY_QTY,
442: AND tps1.PARTNER_TYPE(+)= 1
443: AND tps2.SR_TP_SITE_ID(+)= x.OWNING_PARTNER_SITE_ID
444: AND tps2.SR_INSTANCE_ID(+)= x.SR_INSTANCE_ID
445: AND tps2.PARTNER_TYPE(+)= 1
446: AND x.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
447: AND x.DELETED_FLAG= MSC_UTIL.SYS_NO
448: AND md.SR_INSTANCE_ID(+)= x.SR_INSTANCE_ID
449: AND md.DESIGNATOR(+)= x.SCHEDULE_DESIGNATOR
450: AND md.Organization_ID(+)= x.Organization_ID
455: /*KAL enh: closed visit workorders of order type 90 to be skipped in this sql */
456: AND x.order_type not in (90)
457: AND nvl(x.coll_order_type,-1) <> 974 /*osp supply*/
458: /* CP-ACK starts */
459: AND x.ORDER_TYPE NOT IN (MSC_CL_COLLECTION.G_MRP_PO_ACK)
460: /* CP-ACK ends */
461: order by x.Organization_ID;
462:
463:
493: MSC_ST_SUPPLIES x,
494: MSC_TP_SITE_ID_LID tps1,
495: MSC_TP_SITE_ID_LID tps2
496: WHERE x.DELETED_FLAG= MSC_UTIL.SYS_YES
497: AND x.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
498: AND t1.SR_INVENTORY_ITEM_ID(+)= x.INVENTORY_ITEM_ID
499: AND t1.SR_INSTANCE_ID(+)= x.SR_INSTANCE_ID
500: AND tps1.SR_TP_SITE_ID(+)= x.PLANNING_PARTNER_SITE_ID
501: AND tps1.SR_INSTANCE_ID(+)= x.SR_INSTANCE_ID
511: mshr.ORGANIZATION_ID,
512: mshr.ORDER_TYPE
513: FROM MSC_ST_SUPPLIES mshr,
514: MSC_ITEM_ID_LID t1
515: WHERE mshr.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
516: AND mshr.RO_STATUS_CODE= 'C'
517: AND mshr.ORDER_TYPE=75
518: AND t1.SR_INVENTORY_ITEM_ID(+)= mshr.inventory_item_id
519: AND t1.sr_instance_id(+)= MSC_CL_COLLECTION.v_instance_id ;
515: WHERE mshr.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
516: AND mshr.RO_STATUS_CODE= 'C'
517: AND mshr.ORDER_TYPE=75
518: AND t1.SR_INVENTORY_ITEM_ID(+)= mshr.inventory_item_id
519: AND t1.sr_instance_id(+)= MSC_CL_COLLECTION.v_instance_id ;
520:
521:
522: BEGIN
523:
521:
522: BEGIN
523:
524: /* CP-ACK starts */
525: lv_po_dock_date_ref := nvl(fnd_profile.value('MSC_PO_DOCK_DATE_CALC_PREF'), MSC_CL_COLLECTION.PROMISED_DATE_PREF);
526: /* CP-ACk ends */
527:
528: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
529: lv_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
524: /* CP-ACK starts */
525: lv_po_dock_date_ref := nvl(fnd_profile.value('MSC_PO_DOCK_DATE_CALC_PREF'), MSC_CL_COLLECTION.PROMISED_DATE_PREF);
526: /* CP-ACk ends */
527:
528: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
529: lv_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
530: ELSE
531: lv_tbl:= 'MSC_SUPPLIES';
532: END IF;
525: lv_po_dock_date_ref := nvl(fnd_profile.value('MSC_PO_DOCK_DATE_CALC_PREF'), MSC_CL_COLLECTION.PROMISED_DATE_PREF);
526: /* CP-ACk ends */
527:
528: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
529: lv_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
530: ELSE
531: lv_tbl:= 'MSC_SUPPLIES';
532: END IF;
533:
818:
819:
820: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply');
821:
822: IF MSC_CL_COLLECTION.v_is_complete_refresh AND MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_NO THEN
823:
824: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUPPLIES', MSC_CL_COLLECTION.v_instance_id, -1);
825:
826: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
820: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply');
821:
822: IF MSC_CL_COLLECTION.v_is_complete_refresh AND MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_NO THEN
823:
824: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUPPLIES', MSC_CL_COLLECTION.v_instance_id, -1);
825:
826: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
827: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUPPLIES', MSC_CL_COLLECTION.v_instance_id, -1);
828: ELSE
822: IF MSC_CL_COLLECTION.v_is_complete_refresh AND MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_NO THEN
823:
824: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUPPLIES', MSC_CL_COLLECTION.v_instance_id, -1);
825:
826: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
827: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUPPLIES', MSC_CL_COLLECTION.v_instance_id, -1);
828: ELSE
829: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
830: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUPPLIES', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
823:
824: --MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUPPLIES', MSC_CL_COLLECTION.v_instance_id, -1);
825:
826: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
827: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUPPLIES', MSC_CL_COLLECTION.v_instance_id, -1);
828: ELSE
829: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
830: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUPPLIES', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
831: END IF;
825:
826: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
827: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUPPLIES', MSC_CL_COLLECTION.v_instance_id, -1);
828: ELSE
829: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
830: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUPPLIES', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
831: END IF;
832:
833: END IF;
826: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
827: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUPPLIES', MSC_CL_COLLECTION.v_instance_id, -1);
828: ELSE
829: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
830: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_SUPPLIES', MSC_CL_COLLECTION.v_instance_id, -1,MSC_CL_COLLECTION.v_sub_str);
831: END IF;
832:
833: END IF;
834:
834:
835: --================= DELETE ==============
836: --agmcont
837:
838: IF (MSC_CL_COLLECTION.v_is_incremental_refresh or MSC_CL_COLLECTION.v_is_cont_refresh) THEN
839:
840: /* These intransit shipment supplies isn't supported for incremental
841: refresh.
842: In order to keep the transaction_id, set the quantitiy to zero
843: for delete. */
844:
845: /*UPDATE MSC_SUPPLIES
846: SET NEW_ORDER_QUANTITY= 0.0,
847: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
848: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
849: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
850: WHERE PLAN_ID= -1
851: AND SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
844:
845: /*UPDATE MSC_SUPPLIES
846: SET NEW_ORDER_QUANTITY= 0.0,
847: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
848: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
849: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
850: WHERE PLAN_ID= -1
851: AND SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
852: AND ORDER_TYPE= 11
845: /*UPDATE MSC_SUPPLIES
846: SET NEW_ORDER_QUANTITY= 0.0,
847: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
848: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
849: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
850: WHERE PLAN_ID= -1
851: AND SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
852: AND ORDER_TYPE= 11
853: AND SR_MTL_SUPPLY_ID= -1;*/
847: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
848: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
849: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
850: WHERE PLAN_ID= -1
851: AND SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
852: AND ORDER_TYPE= 11
853: AND SR_MTL_SUPPLY_ID= -1;*/
854:
855: lv_sql_stmt1 := ' UPDATE MSC_SUPPLIES '
863: ||' AND SR_INSTANCE_ID= :v_instance_id '
864: ||' AND ORDER_TYPE= 11 ' --Intransit shipment
865: ||' AND SR_MTL_SUPPLY_ID= -1 ';
866:
867: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
868: EXECUTE IMMEDIATE lv_sql_stmt1 USING MSC_CL_COLLECTION.v_last_collection_id,
869: MSC_CL_COLLECTION.v_current_date,
870: MSC_CL_COLLECTION.v_current_user,
871: MSC_CL_COLLECTION.v_instance_id;
864: ||' AND ORDER_TYPE= 11 ' --Intransit shipment
865: ||' AND SR_MTL_SUPPLY_ID= -1 ';
866:
867: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
868: EXECUTE IMMEDIATE lv_sql_stmt1 USING MSC_CL_COLLECTION.v_last_collection_id,
869: MSC_CL_COLLECTION.v_current_date,
870: MSC_CL_COLLECTION.v_current_user,
871: MSC_CL_COLLECTION.v_instance_id;
872: ELSE
865: ||' AND SR_MTL_SUPPLY_ID= -1 ';
866:
867: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
868: EXECUTE IMMEDIATE lv_sql_stmt1 USING MSC_CL_COLLECTION.v_last_collection_id,
869: MSC_CL_COLLECTION.v_current_date,
870: MSC_CL_COLLECTION.v_current_user,
871: MSC_CL_COLLECTION.v_instance_id;
872: ELSE
873: lv_sql_stmt1:=lv_sql_stmt1||' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
866:
867: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
868: EXECUTE IMMEDIATE lv_sql_stmt1 USING MSC_CL_COLLECTION.v_last_collection_id,
869: MSC_CL_COLLECTION.v_current_date,
870: MSC_CL_COLLECTION.v_current_user,
871: MSC_CL_COLLECTION.v_instance_id;
872: ELSE
873: lv_sql_stmt1:=lv_sql_stmt1||' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
874: EXECUTE IMMEDIATE lv_sql_stmt1 USING MSC_CL_COLLECTION.v_last_collection_id,
867: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
868: EXECUTE IMMEDIATE lv_sql_stmt1 USING MSC_CL_COLLECTION.v_last_collection_id,
869: MSC_CL_COLLECTION.v_current_date,
870: MSC_CL_COLLECTION.v_current_user,
871: MSC_CL_COLLECTION.v_instance_id;
872: ELSE
873: lv_sql_stmt1:=lv_sql_stmt1||' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
874: EXECUTE IMMEDIATE lv_sql_stmt1 USING MSC_CL_COLLECTION.v_last_collection_id,
875: MSC_CL_COLLECTION.v_current_date,
870: MSC_CL_COLLECTION.v_current_user,
871: MSC_CL_COLLECTION.v_instance_id;
872: ELSE
873: lv_sql_stmt1:=lv_sql_stmt1||' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
874: EXECUTE IMMEDIATE lv_sql_stmt1 USING MSC_CL_COLLECTION.v_last_collection_id,
875: MSC_CL_COLLECTION.v_current_date,
876: MSC_CL_COLLECTION.v_current_user,
877: MSC_CL_COLLECTION.v_instance_id;
878:
871: MSC_CL_COLLECTION.v_instance_id;
872: ELSE
873: lv_sql_stmt1:=lv_sql_stmt1||' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
874: EXECUTE IMMEDIATE lv_sql_stmt1 USING MSC_CL_COLLECTION.v_last_collection_id,
875: MSC_CL_COLLECTION.v_current_date,
876: MSC_CL_COLLECTION.v_current_user,
877: MSC_CL_COLLECTION.v_instance_id;
878:
879: END IF;
872: ELSE
873: lv_sql_stmt1:=lv_sql_stmt1||' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
874: EXECUTE IMMEDIATE lv_sql_stmt1 USING MSC_CL_COLLECTION.v_last_collection_id,
875: MSC_CL_COLLECTION.v_current_date,
876: MSC_CL_COLLECTION.v_current_user,
877: MSC_CL_COLLECTION.v_instance_id;
878:
879: END IF;
880:
873: lv_sql_stmt1:=lv_sql_stmt1||' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
874: EXECUTE IMMEDIATE lv_sql_stmt1 USING MSC_CL_COLLECTION.v_last_collection_id,
875: MSC_CL_COLLECTION.v_current_date,
876: MSC_CL_COLLECTION.v_current_user,
877: MSC_CL_COLLECTION.v_instance_id;
878:
879: END IF;
880:
881: COMMIT;
883: c_count:= 0;
884:
885: FOR c_rec IN c1_d LOOP
886: --1 =PO, 2 = PO REQ, 8 = PO receiving, 12= Intrasit Receipt
887: IF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (1,2,8,11,12,73,74,87)) or
888: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (1,2,8,11,12,73,74,87)) and
889: (MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- PO
890:
891: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd PO-0');
884:
885: FOR c_rec IN c1_d LOOP
886: --1 =PO, 2 = PO REQ, 8 = PO receiving, 12= Intrasit Receipt
887: IF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (1,2,8,11,12,73,74,87)) or
888: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (1,2,8,11,12,73,74,87)) and
889: (MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- PO
890:
891: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd PO-0');
892:
885: FOR c_rec IN c1_d LOOP
886: --1 =PO, 2 = PO REQ, 8 = PO receiving, 12= Intrasit Receipt
887: IF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (1,2,8,11,12,73,74,87)) or
888: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (1,2,8,11,12,73,74,87)) and
889: (MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- PO
890:
891: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd PO-0');
892:
893:
894: UPDATE MSC_SUPPLIES ms
895: SET OLD_NEW_SCHEDULE_DATE = NEW_SCHEDULE_DATE,
896: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
897: NEW_ORDER_QUANTITY= 0.0,
898: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
899: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
900: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
901: WHERE PLAN_ID= -1
902: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
895: SET OLD_NEW_SCHEDULE_DATE = NEW_SCHEDULE_DATE,
896: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
897: NEW_ORDER_QUANTITY= 0.0,
898: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
899: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
900: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
901: WHERE PLAN_ID= -1
902: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
903: AND ORDER_TYPE IN (1,2,8,11,12,73,74,87)
896: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
897: NEW_ORDER_QUANTITY= 0.0,
898: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
899: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
900: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
901: WHERE PLAN_ID= -1
902: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
903: AND ORDER_TYPE IN (1,2,8,11,12,73,74,87)
904: AND SR_MTL_SUPPLY_ID= c_rec.SR_MTL_SUPPLY_ID;
903: AND ORDER_TYPE IN (1,2,8,11,12,73,74,87)
904: AND SR_MTL_SUPPLY_ID= c_rec.SR_MTL_SUPPLY_ID;
905:
906: /*3 Discret Job, 7 Non STandard Job, 27 Flow schedule, 70 Eam supply: ds change change,86 External Repair Order */
907: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (3,7,27, 70,86)) or
908: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (3,7,27,70)) and
909: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- WIP_JOB
910:
911: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP-0');
904: AND SR_MTL_SUPPLY_ID= c_rec.SR_MTL_SUPPLY_ID;
905:
906: /*3 Discret Job, 7 Non STandard Job, 27 Flow schedule, 70 Eam supply: ds change change,86 External Repair Order */
907: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (3,7,27, 70,86)) or
908: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (3,7,27,70)) and
909: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- WIP_JOB
910:
911: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP-0');
912: if c_rec.ORDER_TYPE = 70 then
905:
906: /*3 Discret Job, 7 Non STandard Job, 27 Flow schedule, 70 Eam supply: ds change change,86 External Repair Order */
907: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (3,7,27, 70,86)) or
908: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (3,7,27,70)) and
909: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- WIP_JOB
910:
911: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP-0');
912: if c_rec.ORDER_TYPE = 70 then
913: MSC_CL_COLLECTION.link_top_transaction_id_req := TRUE;
909: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- WIP_JOB
910:
911: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP-0');
912: if c_rec.ORDER_TYPE = 70 then
913: MSC_CL_COLLECTION.link_top_transaction_id_req := TRUE;
914: end if;
915:
916: UPDATE MSC_SUPPLIES ms
917: SET OLD_NEW_SCHEDULE_DATE = NEW_SCHEDULE_DATE,
916: UPDATE MSC_SUPPLIES ms
917: SET OLD_NEW_SCHEDULE_DATE = NEW_SCHEDULE_DATE,
918: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
919: NEW_ORDER_QUANTITY= 0.0,
920: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
921: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
922: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
923: WHERE ms.PLAN_ID= -1
924: AND ms.SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
917: SET OLD_NEW_SCHEDULE_DATE = NEW_SCHEDULE_DATE,
918: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
919: NEW_ORDER_QUANTITY= 0.0,
920: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
921: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
922: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
923: WHERE ms.PLAN_ID= -1
924: AND ms.SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
925: AND ms.ORDER_TYPE= c_rec.ORDER_TYPE
918: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
919: NEW_ORDER_QUANTITY= 0.0,
920: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
921: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
922: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
923: WHERE ms.PLAN_ID= -1
924: AND ms.SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
925: AND ms.ORDER_TYPE= c_rec.ORDER_TYPE
926: AND ms.DISPOSITION_ID= c_rec.DISPOSITION_ID;
926: AND ms.DISPOSITION_ID= c_rec.DISPOSITION_ID;
927:
928:
929: -- 14=discrete job co product, 15 non stanstard job co-product
930: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (14,15)) or
931: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (14,15)) and
932: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- DISCRETE JOB COMPONENT
933:
934: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP DSC JOB-0');
927:
928:
929: -- 14=discrete job co product, 15 non stanstard job co-product
930: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (14,15)) or
931: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (14,15)) and
932: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- DISCRETE JOB COMPONENT
933:
934: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP DSC JOB-0');
935:
928:
929: -- 14=discrete job co product, 15 non stanstard job co-product
930: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (14,15)) or
931: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (14,15)) and
932: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- DISCRETE JOB COMPONENT
933:
934: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP DSC JOB-0');
935:
936:
937: UPDATE MSC_SUPPLIES ms
938: SET OLD_NEW_SCHEDULE_DATE = NEW_SCHEDULE_DATE,
939: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
940: NEW_ORDER_QUANTITY= 0.0,
941: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
942: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
943: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
944: WHERE PLAN_ID= -1
945: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
938: SET OLD_NEW_SCHEDULE_DATE = NEW_SCHEDULE_DATE,
939: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
940: NEW_ORDER_QUANTITY= 0.0,
941: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
942: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
943: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
944: WHERE PLAN_ID= -1
945: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
946: AND ORDER_TYPE= c_rec.ORDER_TYPE
939: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
940: NEW_ORDER_QUANTITY= 0.0,
941: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
942: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
943: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
944: WHERE PLAN_ID= -1
945: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
946: AND ORDER_TYPE= c_rec.ORDER_TYPE
947: AND INVENTORY_ITEM_ID= NVL(c_rec.INVENTORY_ITEM_ID,INVENTORY_ITEM_ID)
947: AND INVENTORY_ITEM_ID= NVL(c_rec.INVENTORY_ITEM_ID,INVENTORY_ITEM_ID)
948: AND DISPOSITION_ID= c_rec.DISPOSITION_ID
949: AND OPERATION_SEQ_NUM= NVL(c_rec.OPERATION_SEQ_NUM,OPERATION_SEQ_NUM);
950:
951: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 30) or
952: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 30) and
953: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- REPT ITEM
954:
955: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP REPT ITEM-0');
948: AND DISPOSITION_ID= c_rec.DISPOSITION_ID
949: AND OPERATION_SEQ_NUM= NVL(c_rec.OPERATION_SEQ_NUM,OPERATION_SEQ_NUM);
950:
951: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 30) or
952: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 30) and
953: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- REPT ITEM
954:
955: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP REPT ITEM-0');
956:
949: AND OPERATION_SEQ_NUM= NVL(c_rec.OPERATION_SEQ_NUM,OPERATION_SEQ_NUM);
950:
951: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 30) or
952: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 30) and
953: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- REPT ITEM
954:
955: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP REPT ITEM-0');
956:
957:
962: OLD_FIRST_UNIT_START_DATE= FIRST_UNIT_START_DATE,
963: OLD_LAST_UNIT_COMPLETION_DATE= LAST_UNIT_COMPLETION_DATE,
964: NEW_ORDER_QUANTITY= 0.0,
965: DAILY_RATE = 0.0,
966: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
967: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
968: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
969: WHERE PLAN_ID= -1
970: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
963: OLD_LAST_UNIT_COMPLETION_DATE= LAST_UNIT_COMPLETION_DATE,
964: NEW_ORDER_QUANTITY= 0.0,
965: DAILY_RATE = 0.0,
966: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
967: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
968: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
969: WHERE PLAN_ID= -1
970: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
971: AND ORDER_TYPE= c_rec.ORDER_TYPE
964: NEW_ORDER_QUANTITY= 0.0,
965: DAILY_RATE = 0.0,
966: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
967: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
968: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
969: WHERE PLAN_ID= -1
970: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
971: AND ORDER_TYPE= c_rec.ORDER_TYPE
972: AND DISPOSITION_ID= c_rec.DISPOSITION_ID
971: AND ORDER_TYPE= c_rec.ORDER_TYPE
972: AND DISPOSITION_ID= c_rec.DISPOSITION_ID
973: AND ORGANIZATION_ID = c_rec.ORGANIZATION_ID;
974:
975: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 18) or
976: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 18) and
977: (MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- ONHAND
978:
979: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd OH-0');
972: AND DISPOSITION_ID= c_rec.DISPOSITION_ID
973: AND ORGANIZATION_ID = c_rec.ORGANIZATION_ID;
974:
975: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 18) or
976: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 18) and
977: (MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- ONHAND
978:
979: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd OH-0');
980:
973: AND ORGANIZATION_ID = c_rec.ORGANIZATION_ID;
974:
975: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 18) or
976: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 18) and
977: (MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- ONHAND
978:
979: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd OH-0');
980:
981:
983: --SET NEW_ORDER_QUANTITY= 0.0,
984: SET OLD_NEW_SCHEDULE_DATE = NEW_SCHEDULE_DATE,
985: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
986: NEW_ORDER_QUANTITY= NEW_ORDER_QUANTITY-c_rec.NEW_ORDER_QUANTITY, /*Bug: 2791310 */
987: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
988: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
989: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
990: WHERE PLAN_ID= -1
991: AND SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
984: SET OLD_NEW_SCHEDULE_DATE = NEW_SCHEDULE_DATE,
985: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
986: NEW_ORDER_QUANTITY= NEW_ORDER_QUANTITY-c_rec.NEW_ORDER_QUANTITY, /*Bug: 2791310 */
987: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
988: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
989: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
990: WHERE PLAN_ID= -1
991: AND SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
992: AND ORDER_TYPE= 18
985: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
986: NEW_ORDER_QUANTITY= NEW_ORDER_QUANTITY-c_rec.NEW_ORDER_QUANTITY, /*Bug: 2791310 */
987: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
988: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
989: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
990: WHERE PLAN_ID= -1
991: AND SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
992: AND ORDER_TYPE= 18
993: AND INVENTORY_ITEM_ID= c_rec.INVENTORY_ITEM_ID
987: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
988: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
989: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
990: WHERE PLAN_ID= -1
991: AND SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
992: AND ORDER_TYPE= 18
993: AND INVENTORY_ITEM_ID= c_rec.INVENTORY_ITEM_ID
994: AND ORGANIZATION_ID= c_rec.ORGANIZATION_ID
995: AND NVL(SUBINVENTORY_CODE, MSC_UTIL.NULL_CHAR)= NVL( c_rec.SUBINVENTORY_CODE, MSC_UTIL.NULL_CHAR)
1002: AND NVL(PLANNING_PARTNER_SITE_ID,MSC_UTIL.NULL_VALUE)= NVL(c_rec.PLANNING_PARTNER_SITE_ID,MSC_UTIL.NULL_VALUE)
1003: AND NVL(PLANNING_TP_TYPE,MSC_UTIL.NULL_VALUE)= NVL(c_rec.PLANNING_TP_TYPE,MSC_UTIL.NULL_VALUE);
1004:
1005: /* planned order */
1006: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (5,81)) or
1007: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 5) and
1008: (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- MPS
1009:
1010:
1003: AND NVL(PLANNING_TP_TYPE,MSC_UTIL.NULL_VALUE)= NVL(c_rec.PLANNING_TP_TYPE,MSC_UTIL.NULL_VALUE);
1004:
1005: /* planned order */
1006: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (5,81)) or
1007: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 5) and
1008: (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- MPS
1009:
1010:
1011:
1004:
1005: /* planned order */
1006: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (5,81)) or
1007: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 5) and
1008: (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- MPS
1009:
1010:
1011:
1012:
1014: SET OLD_NEW_SCHEDULE_DATE = NEW_SCHEDULE_DATE,
1015: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
1016: NEW_ORDER_QUANTITY= 0.0,
1017: DAILY_RATE= 0.0,
1018: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1019: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1020: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1021: WHERE PLAN_ID= -1
1022: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
1015: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
1016: NEW_ORDER_QUANTITY= 0.0,
1017: DAILY_RATE= 0.0,
1018: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1019: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1020: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1021: WHERE PLAN_ID= -1
1022: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
1023: AND DISPOSITION_ID= c_rec.DISPOSITION_ID
1016: NEW_ORDER_QUANTITY= 0.0,
1017: DAILY_RATE= 0.0,
1018: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1019: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1020: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1021: WHERE PLAN_ID= -1
1022: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
1023: AND DISPOSITION_ID= c_rec.DISPOSITION_ID
1024: AND ORDER_TYPE= c_rec.ORDER_TYPE
1023: AND DISPOSITION_ID= c_rec.DISPOSITION_ID
1024: AND ORDER_TYPE= c_rec.ORDER_TYPE
1025: AND ORGANIZATION_ID = c_rec.ORGANIZATION_ID;
1026:
1027: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 41) or
1028: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 41) and
1029: (MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- USER DEFINED
1030:
1031: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd USUP-0');
1024: AND ORDER_TYPE= c_rec.ORDER_TYPE
1025: AND ORGANIZATION_ID = c_rec.ORGANIZATION_ID;
1026:
1027: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 41) or
1028: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 41) and
1029: (MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- USER DEFINED
1030:
1031: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd USUP-0');
1032:
1025: AND ORGANIZATION_ID = c_rec.ORGANIZATION_ID;
1026:
1027: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 41) or
1028: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 41) and
1029: (MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- USER DEFINED
1030:
1031: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd USUP-0');
1032:
1033:
1034: UPDATE MSC_SUPPLIES
1035: SET OLD_NEW_SCHEDULE_DATE = NEW_SCHEDULE_DATE,
1036: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
1037: NEW_ORDER_QUANTITY= 0.0,
1038: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1039: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1040: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1041: WHERE PLAN_ID= -1
1042: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
1035: SET OLD_NEW_SCHEDULE_DATE = NEW_SCHEDULE_DATE,
1036: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
1037: NEW_ORDER_QUANTITY= 0.0,
1038: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1039: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1040: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1041: WHERE PLAN_ID= -1
1042: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
1043: AND DISPOSITION_ID= c_rec.DISPOSITION_ID
1036: OLD_NEW_ORDER_QUANTITY = NEW_ORDER_QUANTITY,
1037: NEW_ORDER_QUANTITY= 0.0,
1038: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1039: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1040: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user
1041: WHERE PLAN_ID= -1
1042: AND SR_INSTANCE_ID= c_rec.SR_INSTANCE_ID
1043: AND DISPOSITION_ID= c_rec.DISPOSITION_ID
1044: AND ORDER_TYPE= c_rec.ORDER_TYPE
1047: END IF; -- ORDER_TYPE
1048:
1049: c_count:= c_count+1;
1050:
1051: IF c_count> MSC_CL_COLLECTION.PBS THEN
1052: COMMIT;
1053: c_count:= 0;
1054: END IF;
1055:
1061: Delete from msc_supplies
1062: Where DISPOSITION_ID = c_rec.DISPOSITION_ID
1063: And organization_id = c_rec.organization_id
1064: And order_type = c_rec.order_type
1065: And sr_instance_id = MSC_CL_COLLECTION.v_instance_id
1066: And plan_id = -1;
1067:
1068: END LOOP; -- c10_d
1069:
1068: END LOOP; -- c10_d
1069:
1070: END IF; -- refresh type
1071:
1072: IF MSC_CL_COLLECTION.v_is_complete_refresh THEN
1073: COMMIT;
1074: END IF;
1075:
1076:
1180: END IF ;
1181: END IF ;
1182: /* end bug 5937871*/
1183:
1184: IF (MSC_CL_COLLECTION.v_is_incremental_refresh or MSC_CL_COLLECTION.v_is_cont_refresh) THEN
1185:
1186: --=================== PO SUPPLIES =====================
1187:
1188: IF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (1,2,8,11,12,73,74,87)) or
1184: IF (MSC_CL_COLLECTION.v_is_incremental_refresh or MSC_CL_COLLECTION.v_is_cont_refresh) THEN
1185:
1186: --=================== PO SUPPLIES =====================
1187:
1188: IF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (1,2,8,11,12,73,74,87)) or
1189: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (1,2,8,11,12,73,74,87)) and
1190: (MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- PO
1191:
1192: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd PO');
1185:
1186: --=================== PO SUPPLIES =====================
1187:
1188: IF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (1,2,8,11,12,73,74,87)) or
1189: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (1,2,8,11,12,73,74,87)) and
1190: (MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- PO
1191:
1192: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd PO');
1193:
1186: --=================== PO SUPPLIES =====================
1187:
1188: IF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (1,2,8,11,12,73,74,87)) or
1189: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (1,2,8,11,12,73,74,87)) and
1190: (MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- PO
1191:
1192: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd PO');
1193:
1194:
1201: OLD_FIRST_UNIT_START_DATE= FIRST_UNIT_START_DATE,
1202: OLD_LAST_UNIT_COMPLETION_DATE= LAST_UNIT_COMPLETION_DATE,
1203: OLD_NEW_SCHEDULE_DATE= NEW_SCHEDULE_DATE,
1204: OLD_QTY_COMPLETED= QTY_COMPLETED,
1205: OLD_NEW_ORDER_QUANTITY= decode(REFRESH_NUMBER,MSC_CL_COLLECTION.v_last_collection_id,OLD_NEW_ORDER_QUANTITY,NEW_ORDER_QUANTITY),
1206: OLD_FIRM_QUANTITY= FIRM_QUANTITY,
1207: OLD_FIRM_DATE= FIRM_DATE,
1208: INVENTORY_ITEM_ID= c_rec.INVENTORY_ITEM_ID,
1209: ORGANIZATION_ID= c_rec.ORGANIZATION_ID,
1278: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1279: VMI_FLAG=c_rec.VMI_FLAG,
1280: PO_LINE_LOCATION_ID = c_rec.PO_LINE_LOCATION_ID,
1281: PO_DISTRIBUTION_ID = c_rec.PO_DISTRIBUTION_ID,
1282: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1283: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1284: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1285: /* CP-ACK starts */
1286: PROMISED_DATE = c_rec.PROMISED_DATE,
1279: VMI_FLAG=c_rec.VMI_FLAG,
1280: PO_LINE_LOCATION_ID = c_rec.PO_LINE_LOCATION_ID,
1281: PO_DISTRIBUTION_ID = c_rec.PO_DISTRIBUTION_ID,
1282: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1283: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1284: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1285: /* CP-ACK starts */
1286: PROMISED_DATE = c_rec.PROMISED_DATE,
1287: NEED_BY_DATE = c_rec.NEED_BY_DATE,
1280: PO_LINE_LOCATION_ID = c_rec.PO_LINE_LOCATION_ID,
1281: PO_DISTRIBUTION_ID = c_rec.PO_DISTRIBUTION_ID,
1282: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1283: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1284: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1285: /* CP-ACK starts */
1286: PROMISED_DATE = c_rec.PROMISED_DATE,
1287: NEED_BY_DATE = c_rec.NEED_BY_DATE,
1288: ACCEPTANCE_REQUIRED_FLAG = c_rec.ACCEPTANCE_REQUIRED_FLAG,
1303:
1304: END IF;
1305:
1306: --=================== WIP JOB SUPPLIES =====================
1307: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (3,7,27,70,75,86)) or /* 70 eam supply*/
1308: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (3,7,27,70)) and
1309: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- WIP_JOB
1310:
1311:
1304: END IF;
1305:
1306: --=================== WIP JOB SUPPLIES =====================
1307: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (3,7,27,70,75,86)) or /* 70 eam supply*/
1308: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (3,7,27,70)) and
1309: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- WIP_JOB
1310:
1311:
1312: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP JOB');
1305:
1306: --=================== WIP JOB SUPPLIES =====================
1307: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (3,7,27,70,75,86)) or /* 70 eam supply*/
1308: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (3,7,27,70)) and
1309: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- WIP_JOB
1310:
1311:
1312: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP JOB');
1313:
1319: OLD_FIRST_UNIT_START_DATE= FIRST_UNIT_START_DATE,
1320: OLD_LAST_UNIT_COMPLETION_DATE= LAST_UNIT_COMPLETION_DATE,
1321: OLD_NEW_SCHEDULE_DATE= NEW_SCHEDULE_DATE,
1322: OLD_QTY_COMPLETED= QTY_COMPLETED,
1323: OLD_NEW_ORDER_QUANTITY= decode(REFRESH_NUMBER,MSC_CL_COLLECTION.v_last_collection_id,OLD_NEW_ORDER_QUANTITY,NEW_ORDER_QUANTITY),
1324: OLD_FIRM_QUANTITY= FIRM_QUANTITY,
1325: OLD_FIRM_DATE= FIRM_DATE,
1326: INVENTORY_ITEM_ID= c_rec.INVENTORY_ITEM_ID,
1327: ORGANIZATION_ID= c_rec.ORGANIZATION_ID,
1398: WIP_SUPPLY_TYPE= c_rec.WIP_SUPPLY_TYPE,
1399: NON_NETTABLE_QTY=c_rec.NON_NETTABLE_QTY,
1400: LOT_NUMBER= c_rec.LOT_NUMBER,
1401: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1402: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1403: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1404: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1405: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1406: /* ds change start */
1399: NON_NETTABLE_QTY=c_rec.NON_NETTABLE_QTY,
1400: LOT_NUMBER= c_rec.LOT_NUMBER,
1401: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1402: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1403: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1404: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1405: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1406: /* ds change start */
1407: REQUESTED_START_DATE = c_rec.REQUESTED_START_DATE,
1400: LOT_NUMBER= c_rec.LOT_NUMBER,
1401: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1402: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1403: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1404: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1405: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1406: /* ds change start */
1407: REQUESTED_START_DATE = c_rec.REQUESTED_START_DATE,
1408: REQUESTED_COMPLETION_DATE = c_rec.REQUESTED_COMPLETION_DATE,
1429: AND DISPOSITION_ID= c_rec.DISPOSITION_ID
1430: AND ORGANIZATION_ID = c_rec.ORGANIZATION_ID;
1431:
1432: --=================== WIP DISCRETE JOB COMPONENT SUPPLIES =====================
1433: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (14,15)) or
1434: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (14,15)) and
1435: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- DISCRETE JOB COMPONENT
1436:
1437: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP DSC JOB');
1430: AND ORGANIZATION_ID = c_rec.ORGANIZATION_ID;
1431:
1432: --=================== WIP DISCRETE JOB COMPONENT SUPPLIES =====================
1433: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (14,15)) or
1434: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (14,15)) and
1435: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- DISCRETE JOB COMPONENT
1436:
1437: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP DSC JOB');
1438:
1431:
1432: --=================== WIP DISCRETE JOB COMPONENT SUPPLIES =====================
1433: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (14,15)) or
1434: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE IN (14,15)) and
1435: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- DISCRETE JOB COMPONENT
1436:
1437: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd WIP DSC JOB');
1438:
1439:
1444: OLD_FIRST_UNIT_START_DATE= FIRST_UNIT_START_DATE,
1445: OLD_LAST_UNIT_COMPLETION_DATE= LAST_UNIT_COMPLETION_DATE,
1446: OLD_NEW_SCHEDULE_DATE= NEW_SCHEDULE_DATE,
1447: OLD_QTY_COMPLETED= QTY_COMPLETED,
1448: OLD_NEW_ORDER_QUANTITY= decode(REFRESH_NUMBER,MSC_CL_COLLECTION.v_last_collection_id,OLD_NEW_ORDER_QUANTITY,NEW_ORDER_QUANTITY),
1449: OLD_FIRM_QUANTITY= FIRM_QUANTITY,
1450: OLD_FIRM_DATE= FIRM_DATE,
1451: ORGANIZATION_ID= c_rec.ORGANIZATION_ID,
1452: REVISION= c_rec.REVISION,
1520: WIP_SUPPLY_TYPE= c_rec.WIP_SUPPLY_TYPE,
1521: NON_NETTABLE_QTY=c_rec.NON_NETTABLE_QTY,
1522: LOT_NUMBER= c_rec.LOT_NUMBER,
1523: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1524: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1525: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1526: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1527: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1528: /* ds change start */
1521: NON_NETTABLE_QTY=c_rec.NON_NETTABLE_QTY,
1522: LOT_NUMBER= c_rec.LOT_NUMBER,
1523: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1524: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1525: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1526: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1527: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1528: /* ds change start */
1529: REQUESTED_START_DATE = c_rec.REQUESTED_START_DATE,
1522: LOT_NUMBER= c_rec.LOT_NUMBER,
1523: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1524: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1525: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1526: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1527: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1528: /* ds change start */
1529: REQUESTED_START_DATE = c_rec.REQUESTED_START_DATE,
1530: REQUESTED_COMPLETION_DATE = c_rec.REQUESTED_COMPLETION_DATE,
1543: AND OPERATION_SEQ_NUM= c_rec.OPERATION_SEQ_NUM
1544: AND ORGANIZATION_ID = c_rec.ORGANIZATION_ID;
1545:
1546: --=================== REPETITIVE ITEM SUPPLIES =====================
1547: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 30) or
1548: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 30) and
1549: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- REPT ITEM
1550:
1551: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd REPT ITEMS');
1544: AND ORGANIZATION_ID = c_rec.ORGANIZATION_ID;
1545:
1546: --=================== REPETITIVE ITEM SUPPLIES =====================
1547: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 30) or
1548: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 30) and
1549: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- REPT ITEM
1550:
1551: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd REPT ITEMS');
1552:
1545:
1546: --=================== REPETITIVE ITEM SUPPLIES =====================
1547: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 30) or
1548: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 30) and
1549: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- REPT ITEM
1550:
1551: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd REPT ITEMS');
1552:
1553: /* ATP SUMMARY CHANGES Added the OLD_**** Columns */
1557: OLD_FIRST_UNIT_START_DATE= FIRST_UNIT_START_DATE,
1558: OLD_LAST_UNIT_COMPLETION_DATE= LAST_UNIT_COMPLETION_DATE,
1559: OLD_NEW_SCHEDULE_DATE= NEW_SCHEDULE_DATE,
1560: OLD_QTY_COMPLETED= QTY_COMPLETED,
1561: OLD_NEW_ORDER_QUANTITY= decode(REFRESH_NUMBER,MSC_CL_COLLECTION.v_last_collection_id,OLD_NEW_ORDER_QUANTITY,NEW_ORDER_QUANTITY),
1562: OLD_FIRM_QUANTITY= FIRM_QUANTITY,
1563: OLD_FIRM_DATE= FIRM_DATE,
1564: INVENTORY_ITEM_ID= c_rec.INVENTORY_ITEM_ID,
1565: ORGANIZATION_ID= c_rec.ORGANIZATION_ID,
1630: WIP_STATUS_CODE= c_rec.WIP_STATUS_CODE,
1631: WIP_SUPPLY_TYPE= c_rec.WIP_SUPPLY_TYPE,
1632: LOT_NUMBER= c_rec.LOT_NUMBER,
1633: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1634: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1635: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1636: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1637: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1638: RO_CREATION_DATE =c_rec.RO_CREATION_DATE,
1631: WIP_SUPPLY_TYPE= c_rec.WIP_SUPPLY_TYPE,
1632: LOT_NUMBER= c_rec.LOT_NUMBER,
1633: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1634: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1635: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1636: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1637: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1638: RO_CREATION_DATE =c_rec.RO_CREATION_DATE,
1639: REPAIR_LEAD_TIME= c_rec.REPAIR_LEAD_TIME
1632: LOT_NUMBER= c_rec.LOT_NUMBER,
1633: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1634: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1635: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1636: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1637: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1638: RO_CREATION_DATE =c_rec.RO_CREATION_DATE,
1639: REPAIR_LEAD_TIME= c_rec.REPAIR_LEAD_TIME
1640: WHERE PLAN_ID= -1
1643: AND DISPOSITION_ID= c_rec.DISPOSITION_ID
1644: AND ORGANIZATION_ID = c_rec.ORGANIZATION_ID;
1645:
1646: --=================== ONHAND SUPPLIES =====================
1647: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 18) or
1648: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 18) and
1649: (MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- ONHAND
1650:
1651:
1644: AND ORGANIZATION_ID = c_rec.ORGANIZATION_ID;
1645:
1646: --=================== ONHAND SUPPLIES =====================
1647: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 18) or
1648: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 18) and
1649: (MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- ONHAND
1650:
1651:
1652: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd OH');
1645:
1646: --=================== ONHAND SUPPLIES =====================
1647: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 18) or
1648: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 18) and
1649: (MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- ONHAND
1650:
1651:
1652: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd OH');
1653:
1659: OLD_FIRST_UNIT_START_DATE= FIRST_UNIT_START_DATE,
1660: OLD_LAST_UNIT_COMPLETION_DATE= LAST_UNIT_COMPLETION_DATE,
1661: OLD_NEW_SCHEDULE_DATE= NEW_SCHEDULE_DATE,
1662: OLD_QTY_COMPLETED= QTY_COMPLETED,
1663: OLD_NEW_ORDER_QUANTITY= decode(REFRESH_NUMBER,MSC_CL_COLLECTION.v_last_collection_id,OLD_NEW_ORDER_QUANTITY,NEW_ORDER_QUANTITY),
1664: OLD_FIRM_QUANTITY= FIRM_QUANTITY,
1665: OLD_FIRM_DATE= FIRM_DATE,
1666: NEW_ORDER_QUANTITY= c_rec.NEW_ORDER_QUANTITY,
1667: NEW_SCHEDULE_DATE=lv_schedule_date,
1673: PLANNING_TP_TYPE=c_rec.PLANNING_TP_TYPE,
1674: OWNING_PARTNER_SITE_ID=c_rec.OWNING_PARTNER_SITE_ID,
1675: OWNING_TP_TYPE=c_rec.OWNING_TP_TYPE,
1676: VMI_FLAG=c_rec.VMI_FLAG,
1677: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1678: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1679: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1680: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1681: SR_CUSTOMER_ACCT_ID=c_rec.SR_CUSTOMER_ACCT_ID,
1674: OWNING_PARTNER_SITE_ID=c_rec.OWNING_PARTNER_SITE_ID,
1675: OWNING_TP_TYPE=c_rec.OWNING_TP_TYPE,
1676: VMI_FLAG=c_rec.VMI_FLAG,
1677: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1678: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1679: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1680: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1681: SR_CUSTOMER_ACCT_ID=c_rec.SR_CUSTOMER_ACCT_ID,
1682: ITEM_TYPE_VALUE=c_rec.ITEM_TYPE_VALUE,
1675: OWNING_TP_TYPE=c_rec.OWNING_TP_TYPE,
1676: VMI_FLAG=c_rec.VMI_FLAG,
1677: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1678: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1679: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1680: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1681: SR_CUSTOMER_ACCT_ID=c_rec.SR_CUSTOMER_ACCT_ID,
1682: ITEM_TYPE_VALUE=c_rec.ITEM_TYPE_VALUE,
1683: ITEM_TYPE_ID=c_rec.ITEM_TYPE_ID,
1698: AND NVL(PLANNING_PARTNER_SITE_ID,MSC_UTIL.NULL_VALUE)= NVL(c_rec.PLANNING_PARTNER_SITE_ID,MSC_UTIL.NULL_VALUE)
1699: AND NVL(PLANNING_TP_TYPE,MSC_UTIL.NULL_VALUE)= NVL(c_rec.PLANNING_TP_TYPE,MSC_UTIL.NULL_VALUE);
1700:
1701: --=================== MPS SUPPLIES =====================
1702: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (5,81)) or
1703: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 5) and
1704: (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- MPS
1705:
1706: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd MPS');
1699: AND NVL(PLANNING_TP_TYPE,MSC_UTIL.NULL_VALUE)= NVL(c_rec.PLANNING_TP_TYPE,MSC_UTIL.NULL_VALUE);
1700:
1701: --=================== MPS SUPPLIES =====================
1702: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (5,81)) or
1703: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 5) and
1704: (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- MPS
1705:
1706: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd MPS');
1707:
1700:
1701: --=================== MPS SUPPLIES =====================
1702: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE IN (5,81)) or
1703: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 5) and
1704: (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- MPS
1705:
1706: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd MPS');
1707:
1708:
1713: OLD_FIRST_UNIT_START_DATE= FIRST_UNIT_START_DATE,
1714: OLD_LAST_UNIT_COMPLETION_DATE= LAST_UNIT_COMPLETION_DATE,
1715: OLD_NEW_SCHEDULE_DATE= NEW_SCHEDULE_DATE,
1716: OLD_QTY_COMPLETED= QTY_COMPLETED,
1717: OLD_NEW_ORDER_QUANTITY= decode(REFRESH_NUMBER,MSC_CL_COLLECTION.v_last_collection_id,OLD_NEW_ORDER_QUANTITY,NEW_ORDER_QUANTITY),
1718: OLD_FIRM_QUANTITY= FIRM_QUANTITY,
1719: OLD_FIRM_DATE= FIRM_DATE,
1720: INVENTORY_ITEM_ID= c_rec.INVENTORY_ITEM_ID,
1721: ORGANIZATION_ID= c_rec.ORGANIZATION_ID,
1787: QTY_COMPLETED= c_rec.QTY_COMPLETED,
1788: SCHEDULE_GROUP_NAME= c_rec.SCHEDULE_GROUP_NAME,
1789: LOT_NUMBER= c_rec.LOT_NUMBER,
1790: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1791: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1792: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1793: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1794: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1795: /* ds change start */
1788: SCHEDULE_GROUP_NAME= c_rec.SCHEDULE_GROUP_NAME,
1789: LOT_NUMBER= c_rec.LOT_NUMBER,
1790: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1791: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1792: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1793: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1794: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1795: /* ds change start */
1796: REQUESTED_START_DATE = c_rec.REQUESTED_START_DATE,
1789: LOT_NUMBER= c_rec.LOT_NUMBER,
1790: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1791: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1792: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1793: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1794: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1795: /* ds change start */
1796: REQUESTED_START_DATE = c_rec.REQUESTED_START_DATE,
1797: REQUESTED_COMPLETION_DATE = c_rec.REQUESTED_COMPLETION_DATE,
1810: AND ORDER_TYPE= c_rec.ORDER_TYPE
1811: AND ORGANIZATION_ID = c_rec.ORGANIZATION_ID;
1812:
1813: --=================== USER DEFINED SUPPLIES =====================
1814: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 41) or
1815: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 41) and
1816: (MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- USER DEFINED
1817:
1818: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd USUP');
1811: AND ORGANIZATION_ID = c_rec.ORGANIZATION_ID;
1812:
1813: --=================== USER DEFINED SUPPLIES =====================
1814: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 41) or
1815: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 41) and
1816: (MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- USER DEFINED
1817:
1818: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd USUP');
1819:
1812:
1813: --=================== USER DEFINED SUPPLIES =====================
1814: ELSIF (MSC_CL_COLLECTION.v_is_incremental_refresh and c_rec.ORDER_TYPE= 41) or
1815: (MSC_CL_COLLECTION.v_is_cont_refresh and (c_rec.ORDER_TYPE = 41) and
1816: (MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_INCR)) THEN -- USER DEFINED
1817:
1818: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_supply: upd USUP');
1819:
1820:
1825: OLD_FIRST_UNIT_START_DATE= FIRST_UNIT_START_DATE,
1826: OLD_LAST_UNIT_COMPLETION_DATE= LAST_UNIT_COMPLETION_DATE,
1827: OLD_NEW_SCHEDULE_DATE= NEW_SCHEDULE_DATE,
1828: OLD_QTY_COMPLETED= QTY_COMPLETED,
1829: OLD_NEW_ORDER_QUANTITY= decode(REFRESH_NUMBER,MSC_CL_COLLECTION.v_last_collection_id,OLD_NEW_ORDER_QUANTITY,NEW_ORDER_QUANTITY),
1830: OLD_FIRM_QUANTITY= FIRM_QUANTITY,
1831: OLD_FIRM_DATE= FIRM_DATE,
1832: INVENTORY_ITEM_ID= c_rec.INVENTORY_ITEM_ID,
1833: ORGANIZATION_ID= c_rec.ORGANIZATION_ID,
1898: QTY_COMPLETED= c_rec.QTY_COMPLETED,
1899: SCHEDULE_GROUP_NAME= c_rec.SCHEDULE_GROUP_NAME,
1900: LOT_NUMBER= c_rec.LOT_NUMBER,
1901: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1902: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1903: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1904: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1905: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1906: RO_CREATION_DATE =c_rec.RO_CREATION_DATE,
1899: SCHEDULE_GROUP_NAME= c_rec.SCHEDULE_GROUP_NAME,
1900: LOT_NUMBER= c_rec.LOT_NUMBER,
1901: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1902: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1903: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1904: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1905: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1906: RO_CREATION_DATE =c_rec.RO_CREATION_DATE,
1907: REPAIR_LEAD_TIME= c_rec.REPAIR_LEAD_TIME
1900: LOT_NUMBER= c_rec.LOT_NUMBER,
1901: DEMAND_CLASS= c_rec.DEMAND_CLASS,
1902: REFRESH_NUMBER= MSC_CL_COLLECTION.v_last_collection_id,
1903: LAST_UPDATE_DATE= MSC_CL_COLLECTION.v_current_date,
1904: LAST_UPDATED_BY= MSC_CL_COLLECTION.v_current_user,
1905: COPRODUCTS_SUPPLY = c_rec.COPRODUCTS_SUPPLY,
1906: RO_CREATION_DATE =c_rec.RO_CREATION_DATE,
1907: REPAIR_LEAD_TIME= c_rec.REPAIR_LEAD_TIME
1908: WHERE PLAN_ID= -1
1914: END IF; -- ORDER_TYPE
1915:
1916: END IF; -- refresh mode
1917:
1918: IF MSC_CL_COLLECTION.v_is_complete_refresh OR
1919: SQL%NOTFOUND OR
1920: c_rec.SR_MTL_SUPPLY_ID= -1 THEN
1921: if(SQL%NOTFOUND) Then
1922: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Load supply: not found:' || c_rec.SR_MTL_SUPPLY_ID);
2022: c_rec.VMI_FLAG,
2023: c_rec.PO_LINE_LOCATION_ID,
2024: c_rec.PO_DISTRIBUTION_ID,
2025: c_rec.SR_MTL_SUPPLY_ID,
2026: MSC_CL_COLLECTION.v_last_collection_id,
2027: MSC_CL_COLLECTION.v_current_date,
2028: MSC_CL_COLLECTION.v_current_user,
2029: MSC_CL_COLLECTION.v_current_date,
2030: MSC_CL_COLLECTION.v_current_user,
2023: c_rec.PO_LINE_LOCATION_ID,
2024: c_rec.PO_DISTRIBUTION_ID,
2025: c_rec.SR_MTL_SUPPLY_ID,
2026: MSC_CL_COLLECTION.v_last_collection_id,
2027: MSC_CL_COLLECTION.v_current_date,
2028: MSC_CL_COLLECTION.v_current_user,
2029: MSC_CL_COLLECTION.v_current_date,
2030: MSC_CL_COLLECTION.v_current_user,
2031: /* CP-ACK starts */
2024: c_rec.PO_DISTRIBUTION_ID,
2025: c_rec.SR_MTL_SUPPLY_ID,
2026: MSC_CL_COLLECTION.v_last_collection_id,
2027: MSC_CL_COLLECTION.v_current_date,
2028: MSC_CL_COLLECTION.v_current_user,
2029: MSC_CL_COLLECTION.v_current_date,
2030: MSC_CL_COLLECTION.v_current_user,
2031: /* CP-ACK starts */
2032: c_rec.ORIGINAL_NEED_BY_DATE,
2025: c_rec.SR_MTL_SUPPLY_ID,
2026: MSC_CL_COLLECTION.v_last_collection_id,
2027: MSC_CL_COLLECTION.v_current_date,
2028: MSC_CL_COLLECTION.v_current_user,
2029: MSC_CL_COLLECTION.v_current_date,
2030: MSC_CL_COLLECTION.v_current_user,
2031: /* CP-ACK starts */
2032: c_rec.ORIGINAL_NEED_BY_DATE,
2033: c_rec.ORIGINAL_QUANTITY,
2026: MSC_CL_COLLECTION.v_last_collection_id,
2027: MSC_CL_COLLECTION.v_current_date,
2028: MSC_CL_COLLECTION.v_current_user,
2029: MSC_CL_COLLECTION.v_current_date,
2030: MSC_CL_COLLECTION.v_current_user,
2031: /* CP-ACK starts */
2032: c_rec.ORIGINAL_NEED_BY_DATE,
2033: c_rec.ORIGINAL_QUANTITY,
2034: c_rec.PROMISED_DATE,
2072: END IF;
2073:
2074: c_count:= c_count+1;
2075:
2076: IF c_count> MSC_CL_COLLECTION.PBS THEN
2077: IF MSC_CL_COLLECTION.v_is_complete_refresh THEN COMMIT; END IF;
2078: c_count:= 0;
2079: END IF;
2080: /* ds change */
2073:
2074: c_count:= c_count+1;
2075:
2076: IF c_count> MSC_CL_COLLECTION.PBS THEN
2077: IF MSC_CL_COLLECTION.v_is_complete_refresh THEN COMMIT; END IF;
2078: c_count:= 0;
2079: END IF;
2080: /* ds change */
2081: if c_rec.ORDER_TYPE = 70 then /* 70 eam supply*/
2078: c_count:= 0;
2079: END IF;
2080: /* ds change */
2081: if c_rec.ORDER_TYPE = 70 then /* 70 eam supply*/
2082: MSC_CL_COLLECTION.link_top_transaction_id_req := TRUE;
2083: end if;
2084: /* ds change */
2085:
2086: EXCEPTION
2095: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SUPPLIES');
2096: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2097:
2098: update msc_apps_instances
2099: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
2100: where instance_id = MSC_CL_COLLECTION.v_instance_id;
2101: commit;
2102:
2103: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2096: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2097:
2098: update msc_apps_instances
2099: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
2100: where instance_id = MSC_CL_COLLECTION.v_instance_id;
2101: commit;
2102:
2103: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2104: RAISE;
2103: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2104: RAISE;
2105:
2106: ELSE
2107: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
2108:
2109: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'OTHER========================================');
2110: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
2111: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SUPPLY');
2120: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2121: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
2122: FND_MESSAGE.SET_TOKEN('VALUE',
2123: MSC_GET_NAME.ORG_CODE( c_rec.ORGANIZATION_ID,
2124: MSC_CL_COLLECTION.v_instance_id));
2125: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
2126:
2127: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
2128: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORDER_TYPE');
2146:
2147: IF (MSC_UTIL.G_MSC_CONFIGURATION = MSC_UTIL.G_CONF_APS_SCE
2148: OR MSC_UTIL.G_MSC_CONFIGURATION = MSC_UTIL.G_CONF_SCE) THEN
2149:
2150: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_incremental_refresh) THEN
2151:
2152: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
2153: ( MSC_CL_COLLECTION.v_instance_id,
2154: MSC_CL_COLLECTION.v_is_complete_refresh,
2149:
2150: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_incremental_refresh) THEN
2151:
2152: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
2153: ( MSC_CL_COLLECTION.v_instance_id,
2154: MSC_CL_COLLECTION.v_is_complete_refresh,
2155: MSC_CL_COLLECTION.v_is_partial_refresh,
2156: MSC_CL_COLLECTION.v_is_incremental_refresh,
2157: lv_tbl,
2150: IF (MSC_CL_COLLECTION.v_is_complete_refresh or MSC_CL_COLLECTION.v_is_incremental_refresh) THEN
2151:
2152: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
2153: ( MSC_CL_COLLECTION.v_instance_id,
2154: MSC_CL_COLLECTION.v_is_complete_refresh,
2155: MSC_CL_COLLECTION.v_is_partial_refresh,
2156: MSC_CL_COLLECTION.v_is_incremental_refresh,
2157: lv_tbl,
2158: MSC_CL_COLLECTION.v_current_user,
2151:
2152: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
2153: ( MSC_CL_COLLECTION.v_instance_id,
2154: MSC_CL_COLLECTION.v_is_complete_refresh,
2155: MSC_CL_COLLECTION.v_is_partial_refresh,
2156: MSC_CL_COLLECTION.v_is_incremental_refresh,
2157: lv_tbl,
2158: MSC_CL_COLLECTION.v_current_user,
2159: MSC_CL_COLLECTION.v_last_collection_id);
2152: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
2153: ( MSC_CL_COLLECTION.v_instance_id,
2154: MSC_CL_COLLECTION.v_is_complete_refresh,
2155: MSC_CL_COLLECTION.v_is_partial_refresh,
2156: MSC_CL_COLLECTION.v_is_incremental_refresh,
2157: lv_tbl,
2158: MSC_CL_COLLECTION.v_current_user,
2159: MSC_CL_COLLECTION.v_last_collection_id);
2160:
2154: MSC_CL_COLLECTION.v_is_complete_refresh,
2155: MSC_CL_COLLECTION.v_is_partial_refresh,
2156: MSC_CL_COLLECTION.v_is_incremental_refresh,
2157: lv_tbl,
2158: MSC_CL_COLLECTION.v_current_user,
2159: MSC_CL_COLLECTION.v_last_collection_id);
2160:
2161: ELSIF (MSC_CL_COLLECTION.v_is_cont_refresh) THEN
2162:
2155: MSC_CL_COLLECTION.v_is_partial_refresh,
2156: MSC_CL_COLLECTION.v_is_incremental_refresh,
2157: lv_tbl,
2158: MSC_CL_COLLECTION.v_current_user,
2159: MSC_CL_COLLECTION.v_last_collection_id);
2160:
2161: ELSIF (MSC_CL_COLLECTION.v_is_cont_refresh) THEN
2162:
2163: IF (MSC_CL_COLLECTION.v_coll_prec.supplier_response_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.suprep_sn_flag = MSC_UTIL.SYS_INCR) THEN
2157: lv_tbl,
2158: MSC_CL_COLLECTION.v_current_user,
2159: MSC_CL_COLLECTION.v_last_collection_id);
2160:
2161: ELSIF (MSC_CL_COLLECTION.v_is_cont_refresh) THEN
2162:
2163: IF (MSC_CL_COLLECTION.v_coll_prec.supplier_response_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.suprep_sn_flag = MSC_UTIL.SYS_INCR) THEN
2164:
2165: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
2159: MSC_CL_COLLECTION.v_last_collection_id);
2160:
2161: ELSIF (MSC_CL_COLLECTION.v_is_cont_refresh) THEN
2162:
2163: IF (MSC_CL_COLLECTION.v_coll_prec.supplier_response_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.suprep_sn_flag = MSC_UTIL.SYS_INCR) THEN
2164:
2165: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
2166: ( MSC_CL_COLLECTION.v_instance_id,
2167: FALSE, --MSC_CL_COLLECTION.v_is_complete_refresh,
2162:
2163: IF (MSC_CL_COLLECTION.v_coll_prec.supplier_response_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.suprep_sn_flag = MSC_UTIL.SYS_INCR) THEN
2164:
2165: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
2166: ( MSC_CL_COLLECTION.v_instance_id,
2167: FALSE, --MSC_CL_COLLECTION.v_is_complete_refresh,
2168: FALSE, --MSC_CL_COLLECTION.v_is_partial_refresh,
2169: TRUE, --MSC_CL_COLLECTION.v_is_incremental_refresh,
2170: lv_tbl,
2163: IF (MSC_CL_COLLECTION.v_coll_prec.supplier_response_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.suprep_sn_flag = MSC_UTIL.SYS_INCR) THEN
2164:
2165: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
2166: ( MSC_CL_COLLECTION.v_instance_id,
2167: FALSE, --MSC_CL_COLLECTION.v_is_complete_refresh,
2168: FALSE, --MSC_CL_COLLECTION.v_is_partial_refresh,
2169: TRUE, --MSC_CL_COLLECTION.v_is_incremental_refresh,
2170: lv_tbl,
2171: MSC_CL_COLLECTION.v_current_user,
2164:
2165: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
2166: ( MSC_CL_COLLECTION.v_instance_id,
2167: FALSE, --MSC_CL_COLLECTION.v_is_complete_refresh,
2168: FALSE, --MSC_CL_COLLECTION.v_is_partial_refresh,
2169: TRUE, --MSC_CL_COLLECTION.v_is_incremental_refresh,
2170: lv_tbl,
2171: MSC_CL_COLLECTION.v_current_user,
2172: MSC_CL_COLLECTION.v_last_collection_id);
2165: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
2166: ( MSC_CL_COLLECTION.v_instance_id,
2167: FALSE, --MSC_CL_COLLECTION.v_is_complete_refresh,
2168: FALSE, --MSC_CL_COLLECTION.v_is_partial_refresh,
2169: TRUE, --MSC_CL_COLLECTION.v_is_incremental_refresh,
2170: lv_tbl,
2171: MSC_CL_COLLECTION.v_current_user,
2172: MSC_CL_COLLECTION.v_last_collection_id);
2173:
2167: FALSE, --MSC_CL_COLLECTION.v_is_complete_refresh,
2168: FALSE, --MSC_CL_COLLECTION.v_is_partial_refresh,
2169: TRUE, --MSC_CL_COLLECTION.v_is_incremental_refresh,
2170: lv_tbl,
2171: MSC_CL_COLLECTION.v_current_user,
2172: MSC_CL_COLLECTION.v_last_collection_id);
2173:
2174: END IF;
2175:
2168: FALSE, --MSC_CL_COLLECTION.v_is_partial_refresh,
2169: TRUE, --MSC_CL_COLLECTION.v_is_incremental_refresh,
2170: lv_tbl,
2171: MSC_CL_COLLECTION.v_current_user,
2172: MSC_CL_COLLECTION.v_last_collection_id);
2173:
2174: END IF;
2175:
2176: END IF; -- IF (v_is_complete_....
2177:
2178: END IF; --IF (G_MSC_CONFIGURA....
2179:
2180: IF(MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y'
2181: -- and MSC_CL_COLLECTION.v_coll_prec.eam_info_flag = MSC_UTIL.SYS_YES
2182: and MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES)
2183: THEN
2184:
2185: /*We will not pass the type of refresh here, it'll be determined in
2178: END IF; --IF (G_MSC_CONFIGURA....
2179:
2180: IF(MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y'
2181: -- and MSC_CL_COLLECTION.v_coll_prec.eam_info_flag = MSC_UTIL.SYS_YES
2182: and MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES)
2183: THEN
2184:
2185: /*We will not pass the type of refresh here, it'll be determined in
2186: * package: MSC_CL_AHL_ODS_LOAD itself */
2190: /*Call to procedure in MSCLAHLB.pls */
2191:
2192:
2193: IF(MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y'
2194: -- and MSC_CL_COLLECTION.v_coll_prec.cmro_flag = MSC_UTIL.SYS_YES
2195: and MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES)
2196: THEN
2197:
2198: /*We will not pass the type of refresh here, it'll be determined in
2191:
2192:
2193: IF(MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y'
2194: -- and MSC_CL_COLLECTION.v_coll_prec.cmro_flag = MSC_UTIL.SYS_YES
2195: and MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES)
2196: THEN
2197:
2198: /*We will not pass the type of refresh here, it'll be determined in
2199: * package: MSC_CL_AHL_ODS_LOAD itself */
2196: THEN
2197:
2198: /*We will not pass the type of refresh here, it'll be determined in
2199: * package: MSC_CL_AHL_ODS_LOAD itself */
2200: /* MSC_CL_AHL_ODS_LOAD.LOAD_CMRO_FORECASTS(MSC_CL_COLLECTION.v_instance_id,
2201: MSC_CL_COLLECTION.v_current_user,
2202: MSC_CL_COLLECTION.v_last_collection_id);
2203: */
2204: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'In MSCLSUPB.pls before call to LOAD_CMRO_FORECAST_SUPPLIES');
2197:
2198: /*We will not pass the type of refresh here, it'll be determined in
2199: * package: MSC_CL_AHL_ODS_LOAD itself */
2200: /* MSC_CL_AHL_ODS_LOAD.LOAD_CMRO_FORECASTS(MSC_CL_COLLECTION.v_instance_id,
2201: MSC_CL_COLLECTION.v_current_user,
2202: MSC_CL_COLLECTION.v_last_collection_id);
2203: */
2204: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'In MSCLSUPB.pls before call to LOAD_CMRO_FORECAST_SUPPLIES');
2205: MSC_CL_AHL_ODS_LOAD.LOAD_CMRO_FORECAST_SUPPLIES;
2198: /*We will not pass the type of refresh here, it'll be determined in
2199: * package: MSC_CL_AHL_ODS_LOAD itself */
2200: /* MSC_CL_AHL_ODS_LOAD.LOAD_CMRO_FORECASTS(MSC_CL_COLLECTION.v_instance_id,
2201: MSC_CL_COLLECTION.v_current_user,
2202: MSC_CL_COLLECTION.v_last_collection_id);
2203: */
2204: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'In MSCLSUPB.pls before call to LOAD_CMRO_FORECAST_SUPPLIES');
2205: MSC_CL_AHL_ODS_LOAD.LOAD_CMRO_FORECAST_SUPPLIES;
2206: /* MSC_CL_AHL_ODS_LOAD.LOAD_CMRO_FORECAST_DEMANDS;
2208:
2209: END IF;
2210:
2211: IF(MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y'
2212: and MSC_CL_COLLECTION.v_coll_prec.osp_supply = MSC_UTIL.SYS_YES)
2213: THEN
2214: MSC_CL_AHL_ODS_LOAD.LOAD_OSP_SUPPLY;
2215: END IF;
2216:
2214: MSC_CL_AHL_ODS_LOAD.LOAD_OSP_SUPPLY;
2215: END IF;
2216:
2217: -- agmcont
2218: if MSC_CL_COLLECTION.v_is_cont_refresh then return; end if;
2219:
2220: IF MSC_CL_COLLECTION.v_is_complete_refresh THEN
2221: COMMIT;
2222: END IF;
2216:
2217: -- agmcont
2218: if MSC_CL_COLLECTION.v_is_cont_refresh then return; end if;
2219:
2220: IF MSC_CL_COLLECTION.v_is_complete_refresh THEN
2221: COMMIT;
2222: END IF;
2223:
2224:
2222: END IF;
2223:
2224:
2225: /* analyze msc_supplies here */
2226: IF MSC_CL_COLLECTION.v_is_complete_refresh THEN
2227: IF MSC_CL_COLLECTION.v_exchange_mode= MSC_UTIL.SYS_YES THEN
2228: /* create temporay index */
2229: IF MSC_CL_SUPPLY_ODS_LOAD.create_supplies_tmp_ind THEN
2230: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Index creation on Temp Supplies table successful.');
2223:
2224:
2225: /* analyze msc_supplies here */
2226: IF MSC_CL_COLLECTION.v_is_complete_refresh THEN
2227: IF MSC_CL_COLLECTION.v_exchange_mode= MSC_UTIL.SYS_YES THEN
2228: /* create temporay index */
2229: IF MSC_CL_SUPPLY_ODS_LOAD.create_supplies_tmp_ind THEN
2230: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Index creation on Temp Supplies table successful.');
2231: ELSE
2230: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Index creation on Temp Supplies table successful.');
2231: ELSE
2232: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2233: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Index creation on Temp Supplies table failed.');
2234: RAISE MSC_CL_COLLECTION.SUPPLIES_INDEX_FAIL;
2235: END IF;
2236: END IF;
2237: msc_analyse_tables_pk.analyse_table( lv_tbl, MSC_CL_COLLECTION.v_instance_id, -1);
2238: END IF;
2233: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Index creation on Temp Supplies table failed.');
2234: RAISE MSC_CL_COLLECTION.SUPPLIES_INDEX_FAIL;
2235: END IF;
2236: END IF;
2237: msc_analyse_tables_pk.analyse_table( lv_tbl, MSC_CL_COLLECTION.v_instance_id, -1);
2238: END IF;
2239:
2240: EXCEPTION
2241:
2238: END IF;
2239:
2240: EXCEPTION
2241:
2242: WHEN MSC_CL_COLLECTION.SUPPLIES_INDEX_FAIL THEN
2243:
2244: update msc_apps_instances
2245: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
2246: where instance_id = MSC_CL_COLLECTION.v_instance_id;
2241:
2242: WHEN MSC_CL_COLLECTION.SUPPLIES_INDEX_FAIL THEN
2243:
2244: update msc_apps_instances
2245: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
2246: where instance_id = MSC_CL_COLLECTION.v_instance_id;
2247: commit;
2248: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'MSC_CL_COLLECTION.SUPPLIES_INDEX_FAIL failed');
2249: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2242: WHEN MSC_CL_COLLECTION.SUPPLIES_INDEX_FAIL THEN
2243:
2244: update msc_apps_instances
2245: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
2246: where instance_id = MSC_CL_COLLECTION.v_instance_id;
2247: commit;
2248: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'MSC_CL_COLLECTION.SUPPLIES_INDEX_FAIL failed');
2249: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2250: RAISE;
2244: update msc_apps_instances
2245: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
2246: where instance_id = MSC_CL_COLLECTION.v_instance_id;
2247: commit;
2248: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'MSC_CL_COLLECTION.SUPPLIES_INDEX_FAIL failed');
2249: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2250: RAISE;
2251:
2252: WHEN OTHERS THEN
2251:
2252: WHEN OTHERS THEN
2253:
2254: update msc_apps_instances
2255: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
2256: where instance_id = MSC_CL_COLLECTION.v_instance_id;
2257: commit;
2258:
2259: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load supply other exception');
2252: WHEN OTHERS THEN
2253:
2254: update msc_apps_instances
2255: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
2256: where instance_id = MSC_CL_COLLECTION.v_instance_id;
2257: commit;
2258:
2259: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load supply other exception');
2260: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2433: x.UNIT_NUMBER,
2434: /* decode(x.ORDER_TYPE, 1,
2435: decode(lv_po_dock_date_ref,
2436: PROMISED_DATE_PREF , x.NEW_SCHEDULE_DATE,
2437: MSC_CL_COLLECTION.NEED_BY_DATE_PREF, MSC_CALENDAR.DATE_OFFSET(x.ORGANIZATION_ID,
2438: x.SR_INSTANCE_ID,
2439: TYPE_DAILY_BUCKET,
2440: (MSC_CALENDAR.NEXT_WORK_DAY
2441: (x.ORGANIZATION_ID,
2496: x.VOLUME_CAPACITY_USED,
2497: x.NEW_SHIP_DATE,
2498: /* CP-ACK starts */
2499: nvl(decode(lv_po_dock_date_ref,
2500: MSC_CL_COLLECTION.PROMISED_DATE_PREF, nvl(x.PROMISED_DATE, x.NEED_BY_DATE),
2501: MSC_CL_COLLECTION.NEED_BY_DATE_PREF , nvl(x.NEED_BY_DATE, x.PROMISED_DATE)
2502: ),new_dock_date) NEW_DOCK_DATE,
2503: /* CP-ACK ends */
2504: x.LINE_ID,
2497: x.NEW_SHIP_DATE,
2498: /* CP-ACK starts */
2499: nvl(decode(lv_po_dock_date_ref,
2500: MSC_CL_COLLECTION.PROMISED_DATE_PREF, nvl(x.PROMISED_DATE, x.NEED_BY_DATE),
2501: MSC_CL_COLLECTION.NEED_BY_DATE_PREF , nvl(x.NEED_BY_DATE, x.PROMISED_DATE)
2502: ),new_dock_date) NEW_DOCK_DATE,
2503: /* CP-ACK ends */
2504: x.LINE_ID,
2505: x.PROJECT_ID,
2506: x.TASK_ID,
2507: x.PLANNING_GROUP,
2508: x.NUMBER1,
2509: x.SOURCE_ITEM_ID,
2510: REPLACE(REPLACE(x.ORDER_NUMBER,MSC_CL_COLLECTION.v_chr10),MSC_CL_COLLECTION.v_chr13) ORDER_NUMBER,
2511: x.SCHEDULE_GROUP_ID,
2512: x.BUILD_SEQUENCE,
2513: REPLACE(REPLACE(x.WIP_ENTITY_NAME,MSC_CL_COLLECTION.v_chr10),MSC_CL_COLLECTION.v_chr13) WIP_ENTITY_NAME,
2514: x.IMPLEMENT_PROCESSING_DAYS,
2509: x.SOURCE_ITEM_ID,
2510: REPLACE(REPLACE(x.ORDER_NUMBER,MSC_CL_COLLECTION.v_chr10),MSC_CL_COLLECTION.v_chr13) ORDER_NUMBER,
2511: x.SCHEDULE_GROUP_ID,
2512: x.BUILD_SEQUENCE,
2513: REPLACE(REPLACE(x.WIP_ENTITY_NAME,MSC_CL_COLLECTION.v_chr10),MSC_CL_COLLECTION.v_chr13) WIP_ENTITY_NAME,
2514: x.IMPLEMENT_PROCESSING_DAYS,
2515: x.DELIVERY_PRICE,
2516: x.LATE_SUPPLY_DATE,
2517: x.LATE_SUPPLY_QTY,
2604: AND tps1.PARTNER_TYPE(+)= 1
2605: AND tps2.SR_TP_SITE_ID(+)= x.OWNING_PARTNER_SITE_ID
2606: AND tps2.SR_INSTANCE_ID(+)= x.SR_INSTANCE_ID
2607: AND tps2.PARTNER_TYPE(+)= 1
2608: AND x.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
2609: AND x.DELETED_FLAG= MSC_UTIL.SYS_NO
2610: AND md.SR_INSTANCE_ID(+)= x.SR_INSTANCE_ID
2611: AND md.DESIGNATOR(+)= x.SCHEDULE_DESIGNATOR
2612: AND md.Organization_ID(+)= x.Organization_ID
2616: /*KAL enh: closed visit workorders of order type 90 to be skipped in this sql */
2617: AND x.order_type not in (90)
2618: AND nvl(x.coll_order_type,-1) <> 974 /*osp supply*/
2619: /* CP-ACK starts */
2620: AND x.ORDER_TYPE NOT IN (MSC_CL_COLLECTION.G_MRP_PO_ACK)
2621: /* CP-ACK ends */
2622: order by x.Organization_ID;
2623:
2624:
2625: /* PREPLACE START */ -- Could this be performance intensive
2626: CURSOR c2 IS
2627: SELECT x.INVENTORY_ITEM_ID
2628: FROM MSC_ST_SUPPLIES x
2629: WHERE x.SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id
2630: MINUS
2631: SELECT SR_INVENTORY_ITEM_ID INVENTORY_ITEM_ID
2632: FROM MSC_ITEM_ID_LID
2633: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
2629: WHERE x.SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id
2630: MINUS
2631: SELECT SR_INVENTORY_ITEM_ID INVENTORY_ITEM_ID
2632: FROM MSC_ITEM_ID_LID
2633: WHERE SR_INSTANCE_ID = MSC_CL_COLLECTION.v_instance_id;
2634:
2635: c_count NUMBER;
2636:
2637: BEGIN
2637: BEGIN
2638:
2639:
2640: /* CP-ACK starts */
2641: lv_po_dock_date_ref := nvl(fnd_profile.value('MSC_PO_DOCK_DATE_CALC_PREF'), MSC_CL_COLLECTION.PROMISED_DATE_PREF);
2642: /* CP-ACk ends */
2643:
2644: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_staging_supply');
2645:
2643:
2644: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_staging_supply');
2645:
2646:
2647: lv_temp_supply_tbl := 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
2648: c_count := 0;
2649:
2650: lv_sql_stmt :=
2651: 'INSERT INTO ' || lv_temp_supply_tbl
2928:
2929: -- MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '||lv_sql_stmt);
2930:
2931: --agmcont:
2932: if (MSC_CL_COLLECTION.v_is_cont_refresh = FALSE) then
2933:
2934: FOR c_rec IN c1 LOOP
2935: -- MSC_CL_COLLECTION.log_debug('in calendar loop ');
2936:
2931: --agmcont:
2932: if (MSC_CL_COLLECTION.v_is_cont_refresh = FALSE) then
2933:
2934: FOR c_rec IN c1 LOOP
2935: -- MSC_CL_COLLECTION.log_debug('in calendar loop ');
2936:
2937: BEGIN
2938:
2939: --logic for calculating dock date and schedule date
3140: c_rec.VMI_FLAG ,
3141: c_rec.PO_LINE_LOCATION_ID,
3142: c_rec.PO_DISTRIBUTION_ID,
3143: c_rec.SR_MTL_SUPPLY_ID,
3144: MSC_CL_COLLECTION.v_last_collection_id,
3145: MSC_CL_COLLECTION.v_current_date,
3146: MSC_CL_COLLECTION.v_current_user,
3147: MSC_CL_COLLECTION.v_current_date,
3148: MSC_CL_COLLECTION.v_current_user,
3141: c_rec.PO_LINE_LOCATION_ID,
3142: c_rec.PO_DISTRIBUTION_ID,
3143: c_rec.SR_MTL_SUPPLY_ID,
3144: MSC_CL_COLLECTION.v_last_collection_id,
3145: MSC_CL_COLLECTION.v_current_date,
3146: MSC_CL_COLLECTION.v_current_user,
3147: MSC_CL_COLLECTION.v_current_date,
3148: MSC_CL_COLLECTION.v_current_user,
3149: /* CP-ACK starts */
3142: c_rec.PO_DISTRIBUTION_ID,
3143: c_rec.SR_MTL_SUPPLY_ID,
3144: MSC_CL_COLLECTION.v_last_collection_id,
3145: MSC_CL_COLLECTION.v_current_date,
3146: MSC_CL_COLLECTION.v_current_user,
3147: MSC_CL_COLLECTION.v_current_date,
3148: MSC_CL_COLLECTION.v_current_user,
3149: /* CP-ACK starts */
3150: c_rec.ORIGINAL_NEED_BY_DATE,
3143: c_rec.SR_MTL_SUPPLY_ID,
3144: MSC_CL_COLLECTION.v_last_collection_id,
3145: MSC_CL_COLLECTION.v_current_date,
3146: MSC_CL_COLLECTION.v_current_user,
3147: MSC_CL_COLLECTION.v_current_date,
3148: MSC_CL_COLLECTION.v_current_user,
3149: /* CP-ACK starts */
3150: c_rec.ORIGINAL_NEED_BY_DATE,
3151: c_rec.ORIGINAL_QUANTITY,
3144: MSC_CL_COLLECTION.v_last_collection_id,
3145: MSC_CL_COLLECTION.v_current_date,
3146: MSC_CL_COLLECTION.v_current_user,
3147: MSC_CL_COLLECTION.v_current_date,
3148: MSC_CL_COLLECTION.v_current_user,
3149: /* CP-ACK starts */
3150: c_rec.ORIGINAL_NEED_BY_DATE,
3151: c_rec.ORIGINAL_QUANTITY,
3152: c_rec.PROMISED_DATE,
3189: --END IF;
3190:
3191: c_count:= c_count+1;
3192:
3193: IF c_count> MSC_CL_COLLECTION.PBS THEN
3194: COMMIT;
3195: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The total record count inserted is '||TO_CHAR(c_count));
3196: c_count:= 0;
3197: END IF;
3207: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SUPPLIES');
3208: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
3209:
3210: update msc_apps_instances
3211: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
3212: where instance_id = MSC_CL_COLLECTION.v_instance_id;
3213: commit;
3214:
3215: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
3208: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
3209:
3210: update msc_apps_instances
3211: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
3212: where instance_id = MSC_CL_COLLECTION.v_instance_id;
3213: commit;
3214:
3215: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
3216: RAISE;
3215: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
3216: RAISE;
3217:
3218: ELSE
3219: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
3220:
3221: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'E========================================');
3222: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
3223: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_STAGING_SUPPLY');
3232: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
3233: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
3234: FND_MESSAGE.SET_TOKEN('VALUE',
3235: MSC_GET_NAME.ORG_CODE( c_rec.ORGANIZATION_ID,
3236: MSC_CL_COLLECTION.v_instance_id));
3237: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
3238:
3239: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
3240: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORDER_TYPE');
3250: END LOOP;
3251:
3252: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The total record count inserted is '||TO_CHAR(c_count));
3253:
3254: IF(MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) THEN
3255: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3256: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_ATTRIBUTES', MSC_CL_COLLECTION.v_instance_id,NULL);
3257: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_OPERATION_REL',MSC_CL_COLLECTION.v_instance_id,NULL );
3258: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_TASK_HIERARCHY',MSC_CL_COLLECTION.v_instance_id, NULL );
3251:
3252: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The total record count inserted is '||TO_CHAR(c_count));
3253:
3254: IF(MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) THEN
3255: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3256: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_ATTRIBUTES', MSC_CL_COLLECTION.v_instance_id,NULL);
3257: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_OPERATION_REL',MSC_CL_COLLECTION.v_instance_id,NULL );
3258: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_TASK_HIERARCHY',MSC_CL_COLLECTION.v_instance_id, NULL );
3259:
3252: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The total record count inserted is '||TO_CHAR(c_count));
3253:
3254: IF(MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) THEN
3255: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3256: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_ATTRIBUTES', MSC_CL_COLLECTION.v_instance_id,NULL);
3257: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_OPERATION_REL',MSC_CL_COLLECTION.v_instance_id,NULL );
3258: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_TASK_HIERARCHY',MSC_CL_COLLECTION.v_instance_id, NULL );
3259:
3260: commit;
3253:
3254: IF(MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) THEN
3255: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3256: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_ATTRIBUTES', MSC_CL_COLLECTION.v_instance_id,NULL);
3257: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_OPERATION_REL',MSC_CL_COLLECTION.v_instance_id,NULL );
3258: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_TASK_HIERARCHY',MSC_CL_COLLECTION.v_instance_id, NULL );
3259:
3260: commit;
3261: ELSE
3254: IF(MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) THEN
3255: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
3256: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_ATTRIBUTES', MSC_CL_COLLECTION.v_instance_id,NULL);
3257: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_OPERATION_REL',MSC_CL_COLLECTION.v_instance_id,NULL );
3258: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_TASK_HIERARCHY',MSC_CL_COLLECTION.v_instance_id, NULL );
3259:
3260: commit;
3261: ELSE
3262: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
3258: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_TASK_HIERARCHY',MSC_CL_COLLECTION.v_instance_id, NULL );
3259:
3260: commit;
3261: ELSE
3262: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
3263: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_ATTRIBUTES', MSC_CL_COLLECTION.v_instance_id, NULL ,MSC_CL_COLLECTION.v_sub_str);
3264: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_OPERATION_REL',MSC_CL_COLLECTION.v_instance_id, NULL ,MSC_CL_COLLECTION.v_sub_str);
3265: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_TASK_HIERARCHY', MSC_CL_COLLECTION.v_instance_id, NULL ,MSC_CL_COLLECTION.v_sub_str);
3266: commit;
3259:
3260: commit;
3261: ELSE
3262: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
3263: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_ATTRIBUTES', MSC_CL_COLLECTION.v_instance_id, NULL ,MSC_CL_COLLECTION.v_sub_str);
3264: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_OPERATION_REL',MSC_CL_COLLECTION.v_instance_id, NULL ,MSC_CL_COLLECTION.v_sub_str);
3265: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_TASK_HIERARCHY', MSC_CL_COLLECTION.v_instance_id, NULL ,MSC_CL_COLLECTION.v_sub_str);
3266: commit;
3267: END IF;
3260: commit;
3261: ELSE
3262: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
3263: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_ATTRIBUTES', MSC_CL_COLLECTION.v_instance_id, NULL ,MSC_CL_COLLECTION.v_sub_str);
3264: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_OPERATION_REL',MSC_CL_COLLECTION.v_instance_id, NULL ,MSC_CL_COLLECTION.v_sub_str);
3265: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_TASK_HIERARCHY', MSC_CL_COLLECTION.v_instance_id, NULL ,MSC_CL_COLLECTION.v_sub_str);
3266: commit;
3267: END IF;
3268: END IF;
3261: ELSE
3262: MSC_CL_COLLECTION.v_sub_str :=' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
3263: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_ATTRIBUTES', MSC_CL_COLLECTION.v_instance_id, NULL ,MSC_CL_COLLECTION.v_sub_str);
3264: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_OPERATION_REL',MSC_CL_COLLECTION.v_instance_id, NULL ,MSC_CL_COLLECTION.v_sub_str);
3265: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_WO_TASK_HIERARCHY', MSC_CL_COLLECTION.v_instance_id, NULL ,MSC_CL_COLLECTION.v_sub_str);
3266: commit;
3267: END IF;
3268: END IF;
3269:
3286: IF ( MSC_UTIL.G_MSC_CONFIGURATION = MSC_UTIL.G_CONF_APS_SCE
3287: OR MSC_UTIL.G_MSC_CONFIGURATION = MSC_UTIL.G_CONF_SCE
3288: ) THEN
3289:
3290: IF (MSC_CL_COLLECTION.v_coll_prec.supplier_response_flag = MSC_UTIL.SYS_YES) THEN
3291:
3292: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Loading Supplier Responses from iSupplier Portal');
3293:
3294: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
3291:
3292: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Loading Supplier Responses from iSupplier Portal');
3293:
3294: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
3295: ( MSC_CL_COLLECTION.v_instance_id,
3296: MSC_CL_COLLECTION.v_is_complete_refresh,
3297: MSC_CL_COLLECTION.v_is_partial_refresh,
3298: MSC_CL_COLLECTION.v_is_incremental_refresh,
3299: lv_temp_supply_tbl,
3292: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Loading Supplier Responses from iSupplier Portal');
3293:
3294: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
3295: ( MSC_CL_COLLECTION.v_instance_id,
3296: MSC_CL_COLLECTION.v_is_complete_refresh,
3297: MSC_CL_COLLECTION.v_is_partial_refresh,
3298: MSC_CL_COLLECTION.v_is_incremental_refresh,
3299: lv_temp_supply_tbl,
3300: MSC_CL_COLLECTION.v_current_user,
3293:
3294: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
3295: ( MSC_CL_COLLECTION.v_instance_id,
3296: MSC_CL_COLLECTION.v_is_complete_refresh,
3297: MSC_CL_COLLECTION.v_is_partial_refresh,
3298: MSC_CL_COLLECTION.v_is_incremental_refresh,
3299: lv_temp_supply_tbl,
3300: MSC_CL_COLLECTION.v_current_user,
3301: MSC_CL_COLLECTION.v_last_collection_id);
3294: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
3295: ( MSC_CL_COLLECTION.v_instance_id,
3296: MSC_CL_COLLECTION.v_is_complete_refresh,
3297: MSC_CL_COLLECTION.v_is_partial_refresh,
3298: MSC_CL_COLLECTION.v_is_incremental_refresh,
3299: lv_temp_supply_tbl,
3300: MSC_CL_COLLECTION.v_current_user,
3301: MSC_CL_COLLECTION.v_last_collection_id);
3302:
3296: MSC_CL_COLLECTION.v_is_complete_refresh,
3297: MSC_CL_COLLECTION.v_is_partial_refresh,
3298: MSC_CL_COLLECTION.v_is_incremental_refresh,
3299: lv_temp_supply_tbl,
3300: MSC_CL_COLLECTION.v_current_user,
3301: MSC_CL_COLLECTION.v_last_collection_id);
3302:
3303: END IF;
3304:
3297: MSC_CL_COLLECTION.v_is_partial_refresh,
3298: MSC_CL_COLLECTION.v_is_incremental_refresh,
3299: lv_temp_supply_tbl,
3300: MSC_CL_COLLECTION.v_current_user,
3301: MSC_CL_COLLECTION.v_last_collection_id);
3302:
3303: END IF;
3304:
3305: END IF;
3305: END IF;
3306:
3307: /* CP-ACK ends */
3308: IF(MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y'
3309: -- AND MSC_CL_COLLECTION.v_coll_prec.cmro_flag = MSC_UTIL.SYS_YES
3310: AND MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES)
3311: THEN
3312:
3313: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
3306:
3307: /* CP-ACK ends */
3308: IF(MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y'
3309: -- AND MSC_CL_COLLECTION.v_coll_prec.cmro_flag = MSC_UTIL.SYS_YES
3310: AND MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES)
3311: THEN
3312:
3313: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
3314: 'In MSCLSUPB.pls before call to
3331: targeted basis then we need not to execute lv_cur_sql_stmt because there
3332: is seperate API to take care of Supplier Responses. */
3333:
3334:
3335: IF ((MSC_CL_COLLECTION.v_coll_prec.mps_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_TGT) OR
3336: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_TGT) OR
3337: (MSC_CL_COLLECTION.v_coll_prec.po_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_TGT) OR
3338: (MSC_CL_COLLECTION.v_coll_prec.oh_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_TGT) OR
3339: (MSC_CL_COLLECTION.v_coll_prec.user_supply_demand_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_TGT)
3332: is seperate API to take care of Supplier Responses. */
3333:
3334:
3335: IF ((MSC_CL_COLLECTION.v_coll_prec.mps_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_TGT) OR
3336: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_TGT) OR
3337: (MSC_CL_COLLECTION.v_coll_prec.po_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_TGT) OR
3338: (MSC_CL_COLLECTION.v_coll_prec.oh_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_TGT) OR
3339: (MSC_CL_COLLECTION.v_coll_prec.user_supply_demand_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_TGT)
3340: ) THEN
3333:
3334:
3335: IF ((MSC_CL_COLLECTION.v_coll_prec.mps_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_TGT) OR
3336: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_TGT) OR
3337: (MSC_CL_COLLECTION.v_coll_prec.po_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_TGT) OR
3338: (MSC_CL_COLLECTION.v_coll_prec.oh_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_TGT) OR
3339: (MSC_CL_COLLECTION.v_coll_prec.user_supply_demand_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_TGT)
3340: ) THEN
3341:
3334:
3335: IF ((MSC_CL_COLLECTION.v_coll_prec.mps_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_TGT) OR
3336: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_TGT) OR
3337: (MSC_CL_COLLECTION.v_coll_prec.po_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_TGT) OR
3338: (MSC_CL_COLLECTION.v_coll_prec.oh_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_TGT) OR
3339: (MSC_CL_COLLECTION.v_coll_prec.user_supply_demand_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_TGT)
3340: ) THEN
3341:
3342: lv_cur_sql_stmt :=
3335: IF ((MSC_CL_COLLECTION.v_coll_prec.mps_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_TGT) OR
3336: (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_TGT) OR
3337: (MSC_CL_COLLECTION.v_coll_prec.po_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_TGT) OR
3338: (MSC_CL_COLLECTION.v_coll_prec.oh_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_TGT) OR
3339: (MSC_CL_COLLECTION.v_coll_prec.user_supply_demand_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_TGT)
3340: ) THEN
3341:
3342: lv_cur_sql_stmt :=
3343: 'SELECT'
3351: || ' x.UNIT_NUMBER,'
3352: /*|| ' decode(x.ORDER_TYPE, 1,'
3353: || ' decode( '||lv_po_dock_date_ref|| ' ,'
3354: || PROMISED_DATE_PREF ||', x.NEW_SCHEDULE_DATE,'
3355: || MSC_CL_COLLECTION.NEED_BY_DATE_PREF ||', MSC_CALENDAR.DATE_OFFSET(x.ORGANIZATION_ID,'
3356: || ' x.SR_INSTANCE_ID,'
3357: || TYPE_DAILY_BUCKET ||' ,'
3358: || ' (MSC_CALENDAR.NEXT_WORK_DAY'
3359: || ' (x.ORGANIZATION_ID,'
3414: || ' x.VOLUME_CAPACITY_USED,'
3415: || ' x.NEW_SHIP_DATE,'
3416: /* CP-ACK starts */
3417: || ' nvl(decode( '||lv_po_dock_date_ref ||', '
3418: || MSC_CL_COLLECTION.PROMISED_DATE_PREF ||' , nvl(x.PROMISED_DATE, x.NEED_BY_DATE), '
3419: || MSC_CL_COLLECTION.NEED_BY_DATE_PREF ||' , nvl(x.NEED_BY_DATE, x.PROMISED_DATE) '
3420: || ' ),new_dock_date) NEW_DOCK_DATE, '
3421: /* CP-ACK ends */
3422: -- || ' x.NEW_DOCK_DATE,'
3415: || ' x.NEW_SHIP_DATE,'
3416: /* CP-ACK starts */
3417: || ' nvl(decode( '||lv_po_dock_date_ref ||', '
3418: || MSC_CL_COLLECTION.PROMISED_DATE_PREF ||' , nvl(x.PROMISED_DATE, x.NEED_BY_DATE), '
3419: || MSC_CL_COLLECTION.NEED_BY_DATE_PREF ||' , nvl(x.NEED_BY_DATE, x.PROMISED_DATE) '
3420: || ' ),new_dock_date) NEW_DOCK_DATE, '
3421: /* CP-ACK ends */
3422: -- || ' x.NEW_DOCK_DATE,'
3423: || ' x.LINE_ID,'
3522: || ' AND tps1.PARTNER_TYPE(+)= 1'
3523: || ' AND tps2.SR_TP_SITE_ID(+)= x.OWNING_PARTNER_SITE_ID'
3524: || ' AND tps2.SR_INSTANCE_ID(+)= x.SR_INSTANCE_ID'
3525: || ' AND tps2.PARTNER_TYPE(+)= 1'
3526: || ' AND x.SR_INSTANCE_ID=' || MSC_CL_COLLECTION.v_instance_id
3527: || ' AND x.DELETED_FLAG=' || MSC_UTIL.SYS_NO
3528: || ' AND md.SR_INSTANCE_ID(+)= x.SR_INSTANCE_ID'
3529: || ' AND md.DESIGNATOR(+)= x.SCHEDULE_DESIGNATOR'
3530: || ' AND md.Organization_ID(+)= x.Organization_ID'
3539:
3540:
3541: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_staging_supply: 5');
3542:
3543: if (MSC_CL_COLLECTION.v_coll_prec.mps_flag = MSC_UTIL.SYS_YES) and
3544: (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_TGT) then
3545: lv_where_clause := '5';
3546: end if;
3547:
3540:
3541: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'load_staging_supply: 5');
3542:
3543: if (MSC_CL_COLLECTION.v_coll_prec.mps_flag = MSC_UTIL.SYS_YES) and
3544: (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_TGT) then
3545: lv_where_clause := '5';
3546: end if;
3547:
3548: if (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) and
3544: (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_TGT) then
3545: lv_where_clause := '5';
3546: end if;
3547:
3548: if (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) and
3549: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_TGT) then
3550: if (lv_where_clause is null) then
3551: lv_where_clause := '3,7,14,15,16,27,30,70';
3552: else
3545: lv_where_clause := '5';
3546: end if;
3547:
3548: if (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) and
3549: (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_TGT) then
3550: if (lv_where_clause is null) then
3551: lv_where_clause := '3,7,14,15,16,27,30,70';
3552: else
3553: lv_where_clause := lv_where_clause||',3,7,14,15,16,27,30,70';
3553: lv_where_clause := lv_where_clause||',3,7,14,15,16,27,30,70';
3554: end if;
3555: end if;
3556:
3557: if (MSC_CL_COLLECTION.v_coll_prec.po_flag = MSC_UTIL.SYS_YES) and
3558: (MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_TGT) then
3559: if (lv_where_clause is null) then
3560: lv_where_clause := '1,2,8,11,12,73,74,87';
3561: else
3554: end if;
3555: end if;
3556:
3557: if (MSC_CL_COLLECTION.v_coll_prec.po_flag = MSC_UTIL.SYS_YES) and
3558: (MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_TGT) then
3559: if (lv_where_clause is null) then
3560: lv_where_clause := '1,2,8,11,12,73,74,87';
3561: else
3562: lv_where_clause := lv_where_clause||',1,2,8,11,12,73,74,87';
3562: lv_where_clause := lv_where_clause||',1,2,8,11,12,73,74,87';
3563: end if;
3564: end if;
3565:
3566: if (MSC_CL_COLLECTION.v_coll_prec.oh_flag = MSC_UTIL.SYS_YES) and
3567: (MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_TGT) then
3568: if (lv_where_clause is null) then
3569: lv_where_clause := '18';
3570: else
3563: end if;
3564: end if;
3565:
3566: if (MSC_CL_COLLECTION.v_coll_prec.oh_flag = MSC_UTIL.SYS_YES) and
3567: (MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_TGT) then
3568: if (lv_where_clause is null) then
3569: lv_where_clause := '18';
3570: else
3571: lv_where_clause := lv_where_clause||',18';
3571: lv_where_clause := lv_where_clause||',18';
3572: end if;
3573: end if;
3574:
3575: if (MSC_CL_COLLECTION.v_coll_prec.user_supply_demand_flag = MSC_UTIL.SYS_YES) and
3576: (MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_TGT) then
3577: if (lv_where_clause is null) then
3578: lv_where_clause := '41';
3579: else
3572: end if;
3573: end if;
3574:
3575: if (MSC_CL_COLLECTION.v_coll_prec.user_supply_demand_flag = MSC_UTIL.SYS_YES) and
3576: (MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_TGT) then
3577: if (lv_where_clause is null) then
3578: lv_where_clause := '41';
3579: else
3580: lv_where_clause := lv_where_clause||',41';
3588: lv_cur_sql_stmt:=lv_cur_sql_stmt|| ' order by x.ORGANIZATION_ID ';
3589:
3590: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'lv_cur_sql_stmt=' || lv_cur_sql_stmt);
3591:
3592: open cur for lv_cur_sql_stmt USING MSC_CL_COLLECTION.v_chr10, MSC_CL_COLLECTION.v_chr13, MSC_CL_COLLECTION.v_chr10, MSC_CL_COLLECTION.v_chr13;
3593:
3594: LOOP
3595:
3596: fetch cur into
3896: lv_VMI_FLAG ,
3897: lv_PO_LINE_LOCATION_ID,
3898: lv_PO_DISTRIBUTION_ID,
3899: lv_SR_MTL_SUPPLY_ID,
3900: MSC_CL_COLLECTION.v_last_collection_id,
3901: MSC_CL_COLLECTION.v_current_date,
3902: MSC_CL_COLLECTION.v_current_user,
3903: MSC_CL_COLLECTION.v_current_date,
3904: MSC_CL_COLLECTION.v_current_user,
3897: lv_PO_LINE_LOCATION_ID,
3898: lv_PO_DISTRIBUTION_ID,
3899: lv_SR_MTL_SUPPLY_ID,
3900: MSC_CL_COLLECTION.v_last_collection_id,
3901: MSC_CL_COLLECTION.v_current_date,
3902: MSC_CL_COLLECTION.v_current_user,
3903: MSC_CL_COLLECTION.v_current_date,
3904: MSC_CL_COLLECTION.v_current_user,
3905: /* CP-ACK starts */
3898: lv_PO_DISTRIBUTION_ID,
3899: lv_SR_MTL_SUPPLY_ID,
3900: MSC_CL_COLLECTION.v_last_collection_id,
3901: MSC_CL_COLLECTION.v_current_date,
3902: MSC_CL_COLLECTION.v_current_user,
3903: MSC_CL_COLLECTION.v_current_date,
3904: MSC_CL_COLLECTION.v_current_user,
3905: /* CP-ACK starts */
3906: lv_original_need_by_date,
3899: lv_SR_MTL_SUPPLY_ID,
3900: MSC_CL_COLLECTION.v_last_collection_id,
3901: MSC_CL_COLLECTION.v_current_date,
3902: MSC_CL_COLLECTION.v_current_user,
3903: MSC_CL_COLLECTION.v_current_date,
3904: MSC_CL_COLLECTION.v_current_user,
3905: /* CP-ACK starts */
3906: lv_original_need_by_date,
3907: lv_original_quantity,
3900: MSC_CL_COLLECTION.v_last_collection_id,
3901: MSC_CL_COLLECTION.v_current_date,
3902: MSC_CL_COLLECTION.v_current_user,
3903: MSC_CL_COLLECTION.v_current_date,
3904: MSC_CL_COLLECTION.v_current_user,
3905: /* CP-ACK starts */
3906: lv_original_need_by_date,
3907: lv_original_quantity,
3908: lv_promised_date,
3942: --END IF;
3943:
3944: c_count:= c_count+1;
3945:
3946: IF c_count> MSC_CL_COLLECTION.PBS THEN
3947: COMMIT;
3948: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The total record count inserted is '||TO_CHAR(c_count));
3949: c_count:= 0;
3950: END IF;
3961: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SUPPLIES');
3962: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
3963:
3964: update msc_apps_instances
3965: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
3966: where instance_id = MSC_CL_COLLECTION.v_instance_id;
3967: commit;
3968:
3969: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
3962: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
3963:
3964: update msc_apps_instances
3965: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
3966: where instance_id = MSC_CL_COLLECTION.v_instance_id;
3967: commit;
3968:
3969: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
3970: RAISE;
3969: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
3970: RAISE;
3971:
3972: ELSE
3973: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
3974:
3975: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
3976: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
3977: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_SUPPLY');
3978: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SUPPLIES');
3979: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
3980:
3981: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
3982: FND_MESSAGE.SET_TOKEN('COLUMN', 'MSC_CL_COLLECTION.ITEM_NAME');
3983: FND_MESSAGE.SET_TOKEN('VALUE', MSC_CL_ITEM_ODS_LOAD.ITEM_NAME( lv_INVENTORY_ITEM_ID));
3984: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
3985:
3986: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
3986: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
3987: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
3988: FND_MESSAGE.SET_TOKEN('VALUE',
3989: MSC_GET_NAME.ORG_CODE( lv_ORGANIZATION_ID,
3990: MSC_CL_COLLECTION.v_instance_id));
3991: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
3992:
3993: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
3994: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORDER_TYPE');
4016: */
4017:
4018: /* CP-AUTO */
4019:
4020: END IF; -- IF ((MSC_CL_COLLECTION.v_coll_prec.mps_flag = SYS_YES and.....................
4021: /* CP-AUTO starts */
4022: --===================================================
4023: -- Call the API to load PO Supplier responses in
4024: -- msc_supplies. The same needs to be called in
4031: IF ( MSC_UTIL.G_MSC_CONFIGURATION = MSC_UTIL.G_CONF_APS_SCE
4032: OR MSC_UTIL.G_MSC_CONFIGURATION = MSC_UTIL.G_CONF_SCE
4033: ) THEN
4034:
4035: IF (MSC_CL_COLLECTION.v_coll_prec.supplier_response_flag = MSC_UTIL.SYS_YES and MSC_CL_COLLECTION.v_coll_prec.suprep_sn_flag = MSC_UTIL.SYS_TGT) THEN
4036:
4037: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Loading Supplier Responses from iSupplier Portal');
4038:
4039: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
4036:
4037: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Loading Supplier Responses from iSupplier Portal');
4038:
4039: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
4040: ( MSC_CL_COLLECTION.v_instance_id,
4041: FALSE, --MSC_CL_COLLECTION.v_is_complete_refresh,
4042: TRUE, --MSC_CL_COLLECTION.v_is_partial_refresh,
4043: FALSE, --MSC_CL_COLLECTION.v_is_incremental_refresh,
4044: lv_temp_supply_tbl,
4037: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Loading Supplier Responses from iSupplier Portal');
4038:
4039: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
4040: ( MSC_CL_COLLECTION.v_instance_id,
4041: FALSE, --MSC_CL_COLLECTION.v_is_complete_refresh,
4042: TRUE, --MSC_CL_COLLECTION.v_is_partial_refresh,
4043: FALSE, --MSC_CL_COLLECTION.v_is_incremental_refresh,
4044: lv_temp_supply_tbl,
4045: MSC_CL_COLLECTION.v_current_user,
4038:
4039: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
4040: ( MSC_CL_COLLECTION.v_instance_id,
4041: FALSE, --MSC_CL_COLLECTION.v_is_complete_refresh,
4042: TRUE, --MSC_CL_COLLECTION.v_is_partial_refresh,
4043: FALSE, --MSC_CL_COLLECTION.v_is_incremental_refresh,
4044: lv_temp_supply_tbl,
4045: MSC_CL_COLLECTION.v_current_user,
4046: MSC_CL_COLLECTION.v_last_collection_id);
4039: MSC_CL_SUPPLIER_RESP.LOAD_SUPPLIER_RESPONSE
4040: ( MSC_CL_COLLECTION.v_instance_id,
4041: FALSE, --MSC_CL_COLLECTION.v_is_complete_refresh,
4042: TRUE, --MSC_CL_COLLECTION.v_is_partial_refresh,
4043: FALSE, --MSC_CL_COLLECTION.v_is_incremental_refresh,
4044: lv_temp_supply_tbl,
4045: MSC_CL_COLLECTION.v_current_user,
4046: MSC_CL_COLLECTION.v_last_collection_id);
4047:
4041: FALSE, --MSC_CL_COLLECTION.v_is_complete_refresh,
4042: TRUE, --MSC_CL_COLLECTION.v_is_partial_refresh,
4043: FALSE, --MSC_CL_COLLECTION.v_is_incremental_refresh,
4044: lv_temp_supply_tbl,
4045: MSC_CL_COLLECTION.v_current_user,
4046: MSC_CL_COLLECTION.v_last_collection_id);
4047:
4048: END IF;
4049:
4042: TRUE, --MSC_CL_COLLECTION.v_is_partial_refresh,
4043: FALSE, --MSC_CL_COLLECTION.v_is_incremental_refresh,
4044: lv_temp_supply_tbl,
4045: MSC_CL_COLLECTION.v_current_user,
4046: MSC_CL_COLLECTION.v_last_collection_id);
4047:
4048: END IF;
4049:
4050: END IF;
4050: END IF;
4051: end if;
4052:
4053: IF(MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y'
4054: -- and MSC_CL_COLLECTION.v_coll_prec.eam_info_flag = MSC_UTIL.SYS_YES
4055: and MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES)
4056: THEN
4057:
4058: /*We will not pass the type of refresh here, it'll be determined in
4051: end if;
4052:
4053: IF(MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y'
4054: -- and MSC_CL_COLLECTION.v_coll_prec.eam_info_flag = MSC_UTIL.SYS_YES
4055: and MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES)
4056: THEN
4057:
4058: /*We will not pass the type of refresh here, it'll be determined in
4059: * package: MSC_CL_AHL_ODS_LOAD itself */
4060: MSC_CL_EAM_ODS_LOAD.LOAD_EAM_FORECASTS;
4061: END IF;
4062:
4063: IF(MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y'
4064: and MSC_CL_COLLECTION.v_coll_prec.osp_supply = MSC_UTIL.SYS_YES)
4065: THEN
4066: MSC_CL_AHL_ODS_LOAD.LOAD_OSP_SUPPLY;
4067: END IF;
4068:
4077: v_temp_sql VARCHAR2(5000);
4078:
4079: BEGIN
4080:
4081: lv_temp_supply_tbl := 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
4082: lv_sql_stmt:=
4083: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_temp_supply_tbl
4084: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_SUPPLIES '
4085: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
4081: lv_temp_supply_tbl := 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
4082: lv_sql_stmt:=
4083: 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_temp_supply_tbl
4084: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_SUPPLIES '
4085: ||' WHERE sr_instance_id = '||MSC_CL_COLLECTION.v_instance_id
4086: ||' AND plan_id = -1 AND ( ' ;
4087:
4088: -- agmcont:
4089:
4086: ||' AND plan_id = -1 AND ( ' ;
4087:
4088: -- agmcont:
4089:
4090: IF MSC_CL_COLLECTION.v_coll_prec.mps_flag = MSC_UTIL.SYS_YES THEN
4091: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4092: if (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_TGT) then
4093: lv_where_clause := '5';
4094: end if;
4087:
4088: -- agmcont:
4089:
4090: IF MSC_CL_COLLECTION.v_coll_prec.mps_flag = MSC_UTIL.SYS_YES THEN
4091: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4092: if (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_TGT) then
4093: lv_where_clause := '5';
4094: end if;
4095: else
4088: -- agmcont:
4089:
4090: IF MSC_CL_COLLECTION.v_coll_prec.mps_flag = MSC_UTIL.SYS_YES THEN
4091: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4092: if (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_TGT) then
4093: lv_where_clause := '5';
4094: end if;
4095: else
4096: lv_where_clause := '5';
4095: else
4096: lv_where_clause := '5';
4097: end if;
4098: END IF;
4099: IF (MSC_CL_COLLECTION.v_coll_prec.payback_demand_supply_flag = MSC_UTIL.SYS_YES) THEN
4100: IF (lv_where_clause IS NULL) THEN
4101: lv_where_clause := '29';
4102: ELSE
4103: lv_where_clause := lv_where_clause||', 29';
4102: ELSE
4103: lv_where_clause := lv_where_clause||', 29';
4104: END IF;
4105: END IF;
4106: IF (MSC_CL_COLLECTION.v_coll_prec.cmro_closed_wo = MSC_UTIL.SYS_YES) THEN
4107: IF (lv_where_clause IS NULL) THEN
4108: lv_where_clause := '90';
4109: ELSE
4110: lv_where_clause := lv_where_clause||', 90';
4109: ELSE
4110: lv_where_clause := lv_where_clause||', 90';
4111: END IF;
4112: END IF;
4113: IF (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) THEN
4114:
4115: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4116: if (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_TGT) then
4117: IF (lv_where_clause IS NULL) THEN
4111: END IF;
4112: END IF;
4113: IF (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) THEN
4114:
4115: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4116: if (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_TGT) then
4117: IF (lv_where_clause IS NULL) THEN
4118: lv_where_clause := '3,7,14,15,16,27,30,70';
4119: ELSE
4112: END IF;
4113: IF (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES) THEN
4114:
4115: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4116: if (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_TGT) then
4117: IF (lv_where_clause IS NULL) THEN
4118: lv_where_clause := '3,7,14,15,16,27,30,70';
4119: ELSE
4120: lv_where_clause := lv_where_clause||', 3,7,14,15,16,27,30,70';
4131:
4132: -- Question what does REPT item - 16 represent?
4133: -- It is assumed that it should be grouped with WIP flag.
4134:
4135: IF (MSC_CL_COLLECTION.v_coll_prec.po_flag = MSC_UTIL.SYS_YES) THEN
4136: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4137: if (MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_TGT) then
4138: IF (lv_where_clause IS NULL) THEN
4139: lv_where_clause := '1,2,8,11,12,73,74,87';
4132: -- Question what does REPT item - 16 represent?
4133: -- It is assumed that it should be grouped with WIP flag.
4134:
4135: IF (MSC_CL_COLLECTION.v_coll_prec.po_flag = MSC_UTIL.SYS_YES) THEN
4136: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4137: if (MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_TGT) then
4138: IF (lv_where_clause IS NULL) THEN
4139: lv_where_clause := '1,2,8,11,12,73,74,87';
4140: ELSE
4133: -- It is assumed that it should be grouped with WIP flag.
4134:
4135: IF (MSC_CL_COLLECTION.v_coll_prec.po_flag = MSC_UTIL.SYS_YES) THEN
4136: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4137: if (MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_TGT) then
4138: IF (lv_where_clause IS NULL) THEN
4139: lv_where_clause := '1,2,8,11,12,73,74,87';
4140: ELSE
4141: lv_where_clause := lv_where_clause||', 1,2,8,11,12,73,74,87';
4149: END IF;
4150: end if;
4151: END IF;
4152:
4153: IF (MSC_CL_COLLECTION.v_coll_prec.oh_flag = MSC_UTIL.SYS_YES) THEN
4154: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4155: if (MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_TGT) then
4156: IF (lv_where_clause IS NULL) THEN
4157: lv_where_clause := '18';
4150: end if;
4151: END IF;
4152:
4153: IF (MSC_CL_COLLECTION.v_coll_prec.oh_flag = MSC_UTIL.SYS_YES) THEN
4154: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4155: if (MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_TGT) then
4156: IF (lv_where_clause IS NULL) THEN
4157: lv_where_clause := '18';
4158: ELSE
4151: END IF;
4152:
4153: IF (MSC_CL_COLLECTION.v_coll_prec.oh_flag = MSC_UTIL.SYS_YES) THEN
4154: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4155: if (MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_TGT) then
4156: IF (lv_where_clause IS NULL) THEN
4157: lv_where_clause := '18';
4158: ELSE
4159: lv_where_clause := lv_where_clause||', 18';
4167: END IF;
4168: end if;
4169: END IF;
4170:
4171: IF (MSC_CL_COLLECTION.v_coll_prec.internal_repair_flag = MSC_UTIL.SYS_YES) THEN
4172: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4173: NULL;
4174: Else
4175:
4168: end if;
4169: END IF;
4170:
4171: IF (MSC_CL_COLLECTION.v_coll_prec.internal_repair_flag = MSC_UTIL.SYS_YES) THEN
4172: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4173: NULL;
4174: Else
4175:
4176: IF (lv_where_clause IS NULL) THEN
4181: end if;
4182:
4183: END IF; -- Added for 5909379 SRP Additions
4184:
4185: IF (MSC_CL_COLLECTION.v_coll_prec.external_repair_flag = MSC_UTIL.SYS_YES) THEN
4186: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4187: NULL;
4188: Else
4189:
4182:
4183: END IF; -- Added for 5909379 SRP Additions
4184:
4185: IF (MSC_CL_COLLECTION.v_coll_prec.external_repair_flag = MSC_UTIL.SYS_YES) THEN
4186: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4187: NULL;
4188: Else
4189:
4190: IF (lv_where_clause IS NULL) THEN
4196:
4197: END IF; -- Added for 5935273 SRP Additions
4198:
4199:
4200: IF (MSC_CL_COLLECTION.v_coll_prec.user_supply_demand_flag = MSC_UTIL.SYS_YES) THEN
4201: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4202: if (MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_TGT) then
4203: IF (lv_where_clause IS NULL) THEN
4204: lv_where_clause := '41';
4197: END IF; -- Added for 5935273 SRP Additions
4198:
4199:
4200: IF (MSC_CL_COLLECTION.v_coll_prec.user_supply_demand_flag = MSC_UTIL.SYS_YES) THEN
4201: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4202: if (MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_TGT) then
4203: IF (lv_where_clause IS NULL) THEN
4204: lv_where_clause := '41';
4205: ELSE
4198:
4199:
4200: IF (MSC_CL_COLLECTION.v_coll_prec.user_supply_demand_flag = MSC_UTIL.SYS_YES) THEN
4201: if (MSC_CL_COLLECTION.v_is_cont_refresh) then
4202: if (MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_TGT) then
4203: IF (lv_where_clause IS NULL) THEN
4204: lv_where_clause := '41';
4205: ELSE
4206: lv_where_clause := lv_where_clause||', 41';
4216: END IF;
4217:
4218: -- CP-ACK starts
4219:
4220: IF (MSC_CL_COLLECTION.v_coll_prec.supplier_response_flag = MSC_UTIL.SYS_YES) THEN
4221:
4222: -- CP-AUTO
4223: IF (MSC_CL_COLLECTION.v_is_cont_refresh) then
4224:
4219:
4220: IF (MSC_CL_COLLECTION.v_coll_prec.supplier_response_flag = MSC_UTIL.SYS_YES) THEN
4221:
4222: -- CP-AUTO
4223: IF (MSC_CL_COLLECTION.v_is_cont_refresh) then
4224:
4225: IF (MSC_CL_COLLECTION.v_coll_prec.suprep_sn_flag = MSC_UTIL.SYS_TGT) THEN
4226:
4227: IF (lv_where_clause IS NULL) THEN
4221:
4222: -- CP-AUTO
4223: IF (MSC_CL_COLLECTION.v_is_cont_refresh) then
4224:
4225: IF (MSC_CL_COLLECTION.v_coll_prec.suprep_sn_flag = MSC_UTIL.SYS_TGT) THEN
4226:
4227: IF (lv_where_clause IS NULL) THEN
4228: lv_where_clause := MSC_CL_COLLECTION.G_MRP_PO_ACK;
4229: ELSE
4224:
4225: IF (MSC_CL_COLLECTION.v_coll_prec.suprep_sn_flag = MSC_UTIL.SYS_TGT) THEN
4226:
4227: IF (lv_where_clause IS NULL) THEN
4228: lv_where_clause := MSC_CL_COLLECTION.G_MRP_PO_ACK;
4229: ELSE
4230: lv_where_clause := lv_where_clause||', '||MSC_CL_COLLECTION.G_MRP_PO_ACK;
4231: END IF;
4232:
4226:
4227: IF (lv_where_clause IS NULL) THEN
4228: lv_where_clause := MSC_CL_COLLECTION.G_MRP_PO_ACK;
4229: ELSE
4230: lv_where_clause := lv_where_clause||', '||MSC_CL_COLLECTION.G_MRP_PO_ACK;
4231: END IF;
4232:
4233: END IF;
4234:
4234:
4235: ELSE
4236:
4237: IF (lv_where_clause IS NULL) THEN
4238: lv_where_clause := MSC_CL_COLLECTION.G_MRP_PO_ACK;
4239: ELSE
4240: lv_where_clause := lv_where_clause||', '||MSC_CL_COLLECTION.G_MRP_PO_ACK;
4241: END IF;
4242:
4236:
4237: IF (lv_where_clause IS NULL) THEN
4238: lv_where_clause := MSC_CL_COLLECTION.G_MRP_PO_ACK;
4239: ELSE
4240: lv_where_clause := lv_where_clause||', '||MSC_CL_COLLECTION.G_MRP_PO_ACK;
4241: END IF;
4242:
4243: END IF;
4244:
4250: -- loaded during partial replacement since
4251: -- User Defined supply load is parameter independent.
4252: -- For that purpose complete refresh needs to be run.
4253:
4254: IF (MSC_CL_COLLECTION.v_coll_prec.osp_supply = MSC_UTIL.SYS_YES) THEN
4255: IF (lv_where_clause IS NULL) THEN
4256: lv_where_clause := '974';
4257: ELSE
4258: lv_where_clause := lv_where_clause||', 974';
4258: lv_where_clause := lv_where_clause||', 974';
4259: END IF;
4260: END IF;
4261:
4262: IF (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag = MSC_UTIL.SYS_YES) THEN
4263: IF (lv_where_clause IS NULL) THEN
4264: lv_where_clause := '992';
4265: ELSE
4266: lv_where_clause := lv_where_clause||', 992';
4266: lv_where_clause := lv_where_clause||', 992';
4267: END IF;
4268: END IF;
4269:
4270: IF (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag = MSC_UTIL.SYS_YES) THEN
4271: IF (lv_where_clause IS NULL) THEN
4272: lv_where_clause := '92';
4273: ELSE
4274: lv_where_clause := lv_where_clause||', 92';
4275: END IF;
4276: END IF;
4277:
4278:
4279: IF NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
4280: lv_sql_stmt := lv_sql_stmt||' organization_id NOT '||MSC_UTIL.v_in_org_str;
4281: END IF;
4282:
4283: IF NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS
4279: IF NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS THEN
4280: lv_sql_stmt := lv_sql_stmt||' organization_id NOT '||MSC_UTIL.v_in_org_str;
4281: END IF;
4282:
4283: IF NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS
4284: AND NOT (MSC_CL_COLLECTION.v_is_complete_refresh) THEN
4285: lv_sql_stmt := lv_sql_stmt||' OR ';
4286: END IF;
4287:
4280: lv_sql_stmt := lv_sql_stmt||' organization_id NOT '||MSC_UTIL.v_in_org_str;
4281: END IF;
4282:
4283: IF NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag = MSC_UTIL.G_ALL_ORGANIZATIONS
4284: AND NOT (MSC_CL_COLLECTION.v_is_complete_refresh) THEN
4285: lv_sql_stmt := lv_sql_stmt||' OR ';
4286: END IF;
4287:
4288: IF NOT (MSC_CL_COLLECTION.v_is_complete_refresh) then
4284: AND NOT (MSC_CL_COLLECTION.v_is_complete_refresh) THEN
4285: lv_sql_stmt := lv_sql_stmt||' OR ';
4286: END IF;
4287:
4288: IF NOT (MSC_CL_COLLECTION.v_is_complete_refresh) then
4289: lv_where_clause:= ' nvl(coll_order_type, order_type) NOT IN ('||lv_where_clause||' )';
4290: lv_sql_stmt := lv_sql_stmt|| lv_where_clause;
4291: END IF;
4292:
4300:
4301: EXCEPTION
4302: WHEN OTHERS THEN
4303: update msc_apps_instances
4304: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
4305: where instance_id = MSC_CL_COLLECTION.v_instance_id;
4306: commit;
4307:
4308: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
4301: EXCEPTION
4302: WHEN OTHERS THEN
4303: update msc_apps_instances
4304: set SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
4305: where instance_id = MSC_CL_COLLECTION.v_instance_id;
4306: commit;
4307:
4308: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
4309: RAISE;
4324: lv_copySQL_fixedpart VARCHAR2 (5000);
4325: lv_copySQL_variablepart VARCHAR2 (5000);
4326: firstcondn BOOLEAN;
4327: BEGIN
4328: lv_temp_supply_tbl := 'SUPPLIES_' || MSC_CL_COLLECTION.v_instance_code;
4329:
4330: lv_copySQL_fixedpart :=
4331: 'INSERT INTO '
4332: || lv_temp_supply_tbl
4331: 'INSERT INTO '
4332: || lv_temp_supply_tbl
4333: || ' SELECT * from MSC_SUPPLIES '
4334: || ' WHERE sr_instance_id = '
4335: || MSC_CL_COLLECTION.v_instance_id
4336: || ' AND plan_id = -1 ';
4337:
4338: /* copy sql structure:
4339: lv_copySQL_fixedpart
4345:
4346:
4347: -- agmcont:
4348:
4349: IF MSC_CL_COLLECTION.v_coll_prec.mps_flag = MSC_UTIL.SYS_YES
4350: THEN
4351: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4352: THEN
4353: IF (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_TGT)
4347: -- agmcont:
4348:
4349: IF MSC_CL_COLLECTION.v_coll_prec.mps_flag = MSC_UTIL.SYS_YES
4350: THEN
4351: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4352: THEN
4353: IF (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_TGT)
4354: THEN
4355: lv_collected_ordertypes := '5';
4349: IF MSC_CL_COLLECTION.v_coll_prec.mps_flag = MSC_UTIL.SYS_YES
4350: THEN
4351: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4352: THEN
4353: IF (MSC_CL_COLLECTION.v_coll_prec.mps_sn_flag = MSC_UTIL.SYS_TGT)
4354: THEN
4355: lv_collected_ordertypes := '5';
4356: END IF;
4357: ELSE
4358: lv_collected_ordertypes := '5';
4359: END IF;
4360: END IF;
4361:
4362: IF (MSC_CL_COLLECTION.v_coll_prec.payback_demand_supply_flag =
4363: MSC_UTIL.SYS_YES)
4364: THEN
4365: IF (lv_collected_ordertypes IS NULL)
4366: THEN
4369: lv_collected_ordertypes := lv_collected_ordertypes || ', 29';
4370: END IF;
4371: END IF;
4372:
4373: IF (MSC_CL_COLLECTION.v_coll_prec.cmro_closed_wo = MSC_UTIL.SYS_YES)
4374: THEN
4375: IF (lv_collected_ordertypes IS NULL)
4376: THEN
4377: lv_collected_ordertypes := '90';
4379: lv_collected_ordertypes := lv_collected_ordertypes || ', 90';
4380: END IF;
4381: END IF;
4382:
4383: IF (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES)
4384: THEN
4385: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4386: THEN
4387: IF (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_TGT)
4381: END IF;
4382:
4383: IF (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES)
4384: THEN
4385: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4386: THEN
4387: IF (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_TGT)
4388: THEN
4389: IF (lv_collected_ordertypes IS NULL)
4383: IF (MSC_CL_COLLECTION.v_coll_prec.wip_flag = MSC_UTIL.SYS_YES)
4384: THEN
4385: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4386: THEN
4387: IF (MSC_CL_COLLECTION.v_coll_prec.wip_sn_flag = MSC_UTIL.SYS_TGT)
4388: THEN
4389: IF (lv_collected_ordertypes IS NULL)
4390: THEN
4391: lv_collected_ordertypes := '3,7,14,15,16,27,30,70';
4407:
4408: -- Question what does REPT item - 16 represent?
4409: -- It is assumed that it should be grouped with WIP flag.
4410:
4411: IF (MSC_CL_COLLECTION.v_coll_prec.po_flag = MSC_UTIL.SYS_YES)
4412: THEN
4413: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4414: THEN
4415: IF (MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_TGT)
4409: -- It is assumed that it should be grouped with WIP flag.
4410:
4411: IF (MSC_CL_COLLECTION.v_coll_prec.po_flag = MSC_UTIL.SYS_YES)
4412: THEN
4413: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4414: THEN
4415: IF (MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_TGT)
4416: THEN
4417: IF (lv_collected_ordertypes IS NULL)
4411: IF (MSC_CL_COLLECTION.v_coll_prec.po_flag = MSC_UTIL.SYS_YES)
4412: THEN
4413: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4414: THEN
4415: IF (MSC_CL_COLLECTION.v_coll_prec.po_sn_flag = MSC_UTIL.SYS_TGT)
4416: THEN
4417: IF (lv_collected_ordertypes IS NULL)
4418: THEN
4419: lv_collected_ordertypes := '1,2,8,11,12,73,74,87';
4432: END IF;
4433: END IF;
4434: END IF;
4435:
4436: IF (MSC_CL_COLLECTION.v_coll_prec.oh_flag = MSC_UTIL.SYS_YES)
4437: THEN
4438: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4439: THEN
4440: IF (MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_TGT)
4434: END IF;
4435:
4436: IF (MSC_CL_COLLECTION.v_coll_prec.oh_flag = MSC_UTIL.SYS_YES)
4437: THEN
4438: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4439: THEN
4440: IF (MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_TGT)
4441: THEN
4442: IF (lv_collected_ordertypes IS NULL)
4436: IF (MSC_CL_COLLECTION.v_coll_prec.oh_flag = MSC_UTIL.SYS_YES)
4437: THEN
4438: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4439: THEN
4440: IF (MSC_CL_COLLECTION.v_coll_prec.oh_sn_flag = MSC_UTIL.SYS_TGT)
4441: THEN
4442: IF (lv_collected_ordertypes IS NULL)
4443: THEN
4444: lv_collected_ordertypes := '18';
4455: END IF;
4456: END IF;
4457: END IF;
4458:
4459: IF (MSC_CL_COLLECTION.v_coll_prec.internal_repair_flag =
4460: MSC_UTIL.SYS_YES)
4461: THEN
4462: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4463: THEN
4458:
4459: IF (MSC_CL_COLLECTION.v_coll_prec.internal_repair_flag =
4460: MSC_UTIL.SYS_YES)
4461: THEN
4462: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4463: THEN
4464: NULL;
4465: ELSE
4466: IF (lv_collected_ordertypes IS NULL)
4471: END IF;
4472: END IF;
4473: END IF; -- Added for 5909379 SRP Additions
4474:
4475: IF (MSC_CL_COLLECTION.v_coll_prec.external_repair_flag =
4476: MSC_UTIL.SYS_YES)
4477: THEN
4478: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4479: THEN
4474:
4475: IF (MSC_CL_COLLECTION.v_coll_prec.external_repair_flag =
4476: MSC_UTIL.SYS_YES)
4477: THEN
4478: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4479: THEN
4480: NULL;
4481: ELSE
4482: IF (lv_collected_ordertypes IS NULL)
4488: END IF;
4489: END IF; -- Added for 5935273 SRP Additions
4490:
4491:
4492: IF (MSC_CL_COLLECTION.v_coll_prec.user_supply_demand_flag =
4493: MSC_UTIL.SYS_YES)
4494: THEN
4495: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4496: THEN
4491:
4492: IF (MSC_CL_COLLECTION.v_coll_prec.user_supply_demand_flag =
4493: MSC_UTIL.SYS_YES)
4494: THEN
4495: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4496: THEN
4497: IF (MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_TGT)
4498: THEN
4499: IF (lv_collected_ordertypes IS NULL)
4493: MSC_UTIL.SYS_YES)
4494: THEN
4495: IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4496: THEN
4497: IF (MSC_CL_COLLECTION.v_coll_prec.usup_sn_flag = MSC_UTIL.SYS_TGT)
4498: THEN
4499: IF (lv_collected_ordertypes IS NULL)
4500: THEN
4501: lv_collected_ordertypes := '41';
4514: END IF;
4515:
4516: /* CP-ACK starts */
4517:
4518: /* IF (MSC_CL_COLLECTION.v_coll_prec.supplier_response_flag =
4519: MSC_UTIL.SYS_YES)
4520: THEN
4521: /* CP-AUTO */
4522: /*IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4518: /* IF (MSC_CL_COLLECTION.v_coll_prec.supplier_response_flag =
4519: MSC_UTIL.SYS_YES)
4520: THEN
4521: /* CP-AUTO */
4522: /*IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4523: THEN
4524: IF (MSC_CL_COLLECTION.v_coll_prec.suprep_sn_flag =
4525: MSC_UTIL.SYS_TGT)
4526: THEN
4520: THEN
4521: /* CP-AUTO */
4522: /*IF (MSC_CL_COLLECTION.v_is_cont_refresh)
4523: THEN
4524: IF (MSC_CL_COLLECTION.v_coll_prec.suprep_sn_flag =
4525: MSC_UTIL.SYS_TGT)
4526: THEN
4527: IF (lv_collected_ordertypes IS NULL)
4528: THEN
4525: MSC_UTIL.SYS_TGT)
4526: THEN
4527: IF (lv_collected_ordertypes IS NULL)
4528: THEN
4529: lv_collected_ordertypes := MSC_CL_COLLECTION.G_MRP_PO_ACK;
4530: ELSE
4531: lv_collected_ordertypes :=
4532: lv_collected_ordertypes
4533: || ', '
4530: ELSE
4531: lv_collected_ordertypes :=
4532: lv_collected_ordertypes
4533: || ', '
4534: || MSC_CL_COLLECTION.G_MRP_PO_ACK;
4535: END IF;
4536: END IF;
4537: ELSE
4538: IF (lv_collected_ordertypes IS NULL)
4536: END IF;
4537: ELSE
4538: IF (lv_collected_ordertypes IS NULL)
4539: THEN
4540: lv_collected_ordertypes := MSC_CL_COLLECTION.G_MRP_PO_ACK;
4541: ELSE
4542: lv_collected_ordertypes :=
4543: lv_collected_ordertypes
4544: || ', '
4541: ELSE
4542: lv_collected_ordertypes :=
4543: lv_collected_ordertypes
4544: || ', '
4545: || MSC_CL_COLLECTION.G_MRP_PO_ACK;
4546: END IF;
4547: END IF;
4548: END IF;
4549:
4554: -- For that purpose complete refresh needs to be run.
4555:
4556: /* start of code to prepare lv_collected_entites_filter2*/
4557:
4558: /* IF ( (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4559: MSC_UTIL.SYS_YES)
4560: AND (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4561: MSC_UTIL.SYS_YES))
4562: THEN
4556: /* start of code to prepare lv_collected_entites_filter2*/
4557:
4558: /* IF ( (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4559: MSC_UTIL.SYS_YES)
4560: AND (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4561: MSC_UTIL.SYS_YES))
4562: THEN
4563: lv_collected_entites_filter2 := '(ORDER_TYPE =92)';
4564: ELSIF ( (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4560: AND (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4561: MSC_UTIL.SYS_YES))
4562: THEN
4563: lv_collected_entites_filter2 := '(ORDER_TYPE =92)';
4564: ELSIF ( (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4565: MSC_UTIL.SYS_NO)
4566: AND (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4567: MSC_UTIL.SYS_YES))
4568: THEN
4562: THEN
4563: lv_collected_entites_filter2 := '(ORDER_TYPE =92)';
4564: ELSIF ( (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4565: MSC_UTIL.SYS_NO)
4566: AND (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4567: MSC_UTIL.SYS_YES))
4568: THEN
4569: Lv_collected_entites_filter2 :=
4570: '( ORDER_TYPE =92 AND MAINTENANCE_OBJECT_SOURCE =2 ) ';
4567: MSC_UTIL.SYS_YES))
4568: THEN
4569: Lv_collected_entites_filter2 :=
4570: '( ORDER_TYPE =92 AND MAINTENANCE_OBJECT_SOURCE =2 ) ';
4571: ELSIF ( (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4572: MSC_UTIL.SYS_YES)
4573: AND (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4574: MSC_UTIL.SYS_NO))
4575: THEN
4569: Lv_collected_entites_filter2 :=
4570: '( ORDER_TYPE =92 AND MAINTENANCE_OBJECT_SOURCE =2 ) ';
4571: ELSIF ( (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4572: MSC_UTIL.SYS_YES)
4573: AND (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4574: MSC_UTIL.SYS_NO))
4575: THEN
4576: lv_collected_entites_filter2 :=
4577: '( ORDER_TYPE =92 AND MAINTENANCE_OBJECT_SOURCE =1 ) ';
4574: MSC_UTIL.SYS_NO))
4575: THEN
4576: lv_collected_entites_filter2 :=
4577: '( ORDER_TYPE =92 AND MAINTENANCE_OBJECT_SOURCE =1 ) ';
4578: ELSIF ( (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4579: MSC_UTIL.SYS_NO)
4580: AND (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4581: MSC_UTIL.SYS_NO))
4582: THEN
4576: lv_collected_entites_filter2 :=
4577: '( ORDER_TYPE =92 AND MAINTENANCE_OBJECT_SOURCE =1 ) ';
4578: ELSIF ( (MSC_CL_COLLECTION.v_coll_prec.eam_forecasts_flag =
4579: MSC_UTIL.SYS_NO)
4580: AND (MSC_CL_COLLECTION.v_coll_prec.cmro_forecasts_flag =
4581: MSC_UTIL.SYS_NO))
4582: THEN
4583: lv_collected_entites_filter2 := NULL;
4584: END IF;
4586:
4587: /* start of code to prepare lv_copySQL_variablepart*/
4588: /*firstcondn := TRUE;
4589:
4590: IF (NOT MSC_CL_COLLECTION.v_coll_prec.org_group_flag =
4591: MSC_UTIL.G_ALL_ORGANIZATIONS)
4592: THEN
4593: IF (NOT firstcondn)
4594: THEN
4599: '(ORGANIZATION_ID NOT ' || MSC_UTIL.v_in_org_str || ')';
4600: firstcondn := FALSE;
4601: END IF;
4602:
4603: IF NOT ( MSC_CL_COLLECTION.v_is_complete_refresh
4604: AND lv_collected_ordertypes IS NOT NULL)
4605: THEN
4606: IF (NOT firstcondn)
4607: THEN
4620:
4621: END IF;
4622:
4623:
4624: IF NOT ( MSC_CL_COLLECTION.v_is_complete_refresh )
4625: AND( lv_collected_entites_filter2 IS NOT NULL)
4626: THEN
4627: IF (NOT firstcondn)
4628: THEN
4656: EXCEPTION
4657: WHEN OTHERS
4658: THEN
4659: UPDATE msc_apps_instances
4660: SET SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
4661: WHERE instance_id = MSC_CL_COLLECTION.v_instance_id;
4662:
4663: COMMIT;
4664:
4657: WHEN OTHERS
4658: THEN
4659: UPDATE msc_apps_instances
4660: SET SUPPLIES_LOAD_FLAG = MSC_CL_COLLECTION.G_JOB_ERROR
4661: WHERE instance_id = MSC_CL_COLLECTION.v_instance_id;
4662:
4663: COMMIT;
4664:
4665: MSC_UTIL.LOG_MSG (MSC_UTIL.G_D_STATUS, SQLERRM);
4674: lv_sql_stmt VARCHAR2(32767);
4675:
4676: BEGIN
4677:
4678: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
4679: lv_supply_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
4680: ELSE
4681: lv_supply_tbl:= 'MSC_SUPPLIES';
4682: END IF;
4675:
4676: BEGIN
4677:
4678: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
4679: lv_supply_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
4680: ELSE
4681: lv_supply_tbl:= 'MSC_SUPPLIES';
4682: END IF;
4683:
4723: AND MOP.sr_instance_id = :v_instance_id';
4724:
4725:
4726: EXECUTE IMMEDIATE lv_sql_stmt
4727: USING MSC_CL_COLLECTION.v_current_date,
4728: MSC_CL_COLLECTION.v_current_user,
4729: MSC_CL_COLLECTION.v_current_date,
4730: MSC_CL_COLLECTION.v_current_user,
4731: MSC_CL_COLLECTION.v_instance_id;
4724:
4725:
4726: EXECUTE IMMEDIATE lv_sql_stmt
4727: USING MSC_CL_COLLECTION.v_current_date,
4728: MSC_CL_COLLECTION.v_current_user,
4729: MSC_CL_COLLECTION.v_current_date,
4730: MSC_CL_COLLECTION.v_current_user,
4731: MSC_CL_COLLECTION.v_instance_id;
4732:
4725:
4726: EXECUTE IMMEDIATE lv_sql_stmt
4727: USING MSC_CL_COLLECTION.v_current_date,
4728: MSC_CL_COLLECTION.v_current_user,
4729: MSC_CL_COLLECTION.v_current_date,
4730: MSC_CL_COLLECTION.v_current_user,
4731: MSC_CL_COLLECTION.v_instance_id;
4732:
4733: COMMIT;
4726: EXECUTE IMMEDIATE lv_sql_stmt
4727: USING MSC_CL_COLLECTION.v_current_date,
4728: MSC_CL_COLLECTION.v_current_user,
4729: MSC_CL_COLLECTION.v_current_date,
4730: MSC_CL_COLLECTION.v_current_user,
4731: MSC_CL_COLLECTION.v_instance_id;
4732:
4733: COMMIT;
4734: END LOAD_PAYBACK_SUPPLIES;
4727: USING MSC_CL_COLLECTION.v_current_date,
4728: MSC_CL_COLLECTION.v_current_user,
4729: MSC_CL_COLLECTION.v_current_date,
4730: MSC_CL_COLLECTION.v_current_user,
4731: MSC_CL_COLLECTION.v_instance_id;
4732:
4733: COMMIT;
4734: END LOAD_PAYBACK_SUPPLIES;
4735: