18:
19: IF (WIP_JOB_DETAILS.STD_ALONE = 1) THEN
20: Update WIP_JOB_DTLS_INTERFACE
21: SET interface_id = WIP_INTERFACE_S.NEXTVAL,
22: process_status = WIP_CONSTANTS.RUNNING
23: WHERE group_id = p_group_id
24: AND process_status = WIP_CONSTANTS.PENDING
25: AND process_phase = WIP_CONSTANTS.ML_VALIDATION;
26: ELSE
20: Update WIP_JOB_DTLS_INTERFACE
21: SET interface_id = WIP_INTERFACE_S.NEXTVAL,
22: process_status = WIP_CONSTANTS.RUNNING
23: WHERE group_id = p_group_id
24: AND process_status = WIP_CONSTANTS.PENDING
25: AND process_phase = WIP_CONSTANTS.ML_VALIDATION;
26: ELSE
27: Update WIP_JOB_DTLS_INTERFACE
28: SET interface_id = WIP_INTERFACE_S.NEXTVAL,
21: SET interface_id = WIP_INTERFACE_S.NEXTVAL,
22: process_status = WIP_CONSTANTS.RUNNING
23: WHERE group_id = p_group_id
24: AND process_status = WIP_CONSTANTS.PENDING
25: AND process_phase = WIP_CONSTANTS.ML_VALIDATION;
26: ELSE
27: Update WIP_JOB_DTLS_INTERFACE
28: SET interface_id = WIP_INTERFACE_S.NEXTVAL,
29: process_status = WIP_CONSTANTS.RUNNING
25: AND process_phase = WIP_CONSTANTS.ML_VALIDATION;
26: ELSE
27: Update WIP_JOB_DTLS_INTERFACE
28: SET interface_id = WIP_INTERFACE_S.NEXTVAL,
29: process_status = WIP_CONSTANTS.RUNNING
30: WHERE group_id = p_group_id
31: AND parent_header_id = p_parent_header_id
32: AND process_status = WIP_CONSTANTS.PENDING
33: AND process_phase = WIP_CONSTANTS.ML_VALIDATION;
28: SET interface_id = WIP_INTERFACE_S.NEXTVAL,
29: process_status = WIP_CONSTANTS.RUNNING
30: WHERE group_id = p_group_id
31: AND parent_header_id = p_parent_header_id
32: AND process_status = WIP_CONSTANTS.PENDING
33: AND process_phase = WIP_CONSTANTS.ML_VALIDATION;
34: END IF;
35:
36: exception
29: process_status = WIP_CONSTANTS.RUNNING
30: WHERE group_id = p_group_id
31: AND parent_header_id = p_parent_header_id
32: AND process_status = WIP_CONSTANTS.PENDING
33: AND process_phase = WIP_CONSTANTS.ML_VALIDATION;
34: END IF;
35:
36: exception
37: when no_data_found then
52: x_statement varchar2(2000) :=
53: ' select interface_id
54: from wip_job_dtls_interface WJDI' ||
55: ' where WJDI.group_id = :x_group_id'||
56: ' and WJDI.process_phase = '|| WIP_CONSTANTS.ML_VALIDATION ||
57: ' and WJDI.process_status in ('|| WIP_CONSTANTS.RUNNING||
58: ','||WIP_CONSTANTS.PENDING||
59: ','||WIP_CONSTANTS.WARNING ||') and '||
60: replace(p_where_clause, ' ',' ');
53: ' select interface_id
54: from wip_job_dtls_interface WJDI' ||
55: ' where WJDI.group_id = :x_group_id'||
56: ' and WJDI.process_phase = '|| WIP_CONSTANTS.ML_VALIDATION ||
57: ' and WJDI.process_status in ('|| WIP_CONSTANTS.RUNNING||
58: ','||WIP_CONSTANTS.PENDING||
59: ','||WIP_CONSTANTS.WARNING ||') and '||
60: replace(p_where_clause, ' ',' ');
61:
54: from wip_job_dtls_interface WJDI' ||
55: ' where WJDI.group_id = :x_group_id'||
56: ' and WJDI.process_phase = '|| WIP_CONSTANTS.ML_VALIDATION ||
57: ' and WJDI.process_status in ('|| WIP_CONSTANTS.RUNNING||
58: ','||WIP_CONSTANTS.PENDING||
59: ','||WIP_CONSTANTS.WARNING ||') and '||
60: replace(p_where_clause, ' ',' ');
61:
62: x_cursor_id integer;
55: ' where WJDI.group_id = :x_group_id'||
56: ' and WJDI.process_phase = '|| WIP_CONSTANTS.ML_VALIDATION ||
57: ' and WJDI.process_status in ('|| WIP_CONSTANTS.RUNNING||
58: ','||WIP_CONSTANTS.PENDING||
59: ','||WIP_CONSTANTS.WARNING ||') and '||
60: replace(p_where_clause, ' ',' ');
61:
62: x_cursor_id integer;
63: n_rows_fetched integer;
134: x_statement :=
135: ' UPDATE WIP_JOB_DTLS_INTERFACE WJDI'||
136: ' SET PROCESS_STATUS = :x_New_Process_Status ' ||
137: ' WHERE GROUP_ID = :x_Group_Id ' ||
138: ' AND PROCESS_PHASE = ' || WIP_CONSTANTS.ML_VALIDATION || '
139: AND PROCESS_STATUS IN ('|| WIP_CONSTANTS.RUNNING||
140: ','||WIP_CONSTANTS.PENDING||
141: ','||WIP_CONSTANTS.WARNING ||')'||
142: ' AND ' || replace(p_where_clause, ' ',' ');
135: ' UPDATE WIP_JOB_DTLS_INTERFACE WJDI'||
136: ' SET PROCESS_STATUS = :x_New_Process_Status ' ||
137: ' WHERE GROUP_ID = :x_Group_Id ' ||
138: ' AND PROCESS_PHASE = ' || WIP_CONSTANTS.ML_VALIDATION || '
139: AND PROCESS_STATUS IN ('|| WIP_CONSTANTS.RUNNING||
140: ','||WIP_CONSTANTS.PENDING||
141: ','||WIP_CONSTANTS.WARNING ||')'||
142: ' AND ' || replace(p_where_clause, ' ',' ');
143:
136: ' SET PROCESS_STATUS = :x_New_Process_Status ' ||
137: ' WHERE GROUP_ID = :x_Group_Id ' ||
138: ' AND PROCESS_PHASE = ' || WIP_CONSTANTS.ML_VALIDATION || '
139: AND PROCESS_STATUS IN ('|| WIP_CONSTANTS.RUNNING||
140: ','||WIP_CONSTANTS.PENDING||
141: ','||WIP_CONSTANTS.WARNING ||')'||
142: ' AND ' || replace(p_where_clause, ' ',' ');
143:
144: begin
137: ' WHERE GROUP_ID = :x_Group_Id ' ||
138: ' AND PROCESS_PHASE = ' || WIP_CONSTANTS.ML_VALIDATION || '
139: AND PROCESS_STATUS IN ('|| WIP_CONSTANTS.RUNNING||
140: ','||WIP_CONSTANTS.PENDING||
141: ','||WIP_CONSTANTS.WARNING ||')'||
142: ' AND ' || replace(p_where_clause, ' ',' ');
143:
144: begin
145: x_cursor_id := dbms_sql.open_cursor;
165: select count(*) into x_count
166: from wip_job_dtls_interface
167: where wip_entity_id = p_wip_entity_id
168: and organization_id = p_organization_id
169: and process_phase = WIP_CONSTANTS.ML_VALIDATION
170: and process_status = WIP_CONSTANTS.ERROR ;
171:
172: if x_count > 0 then
173: rollback;
166: from wip_job_dtls_interface
167: where wip_entity_id = p_wip_entity_id
168: and organization_id = p_organization_id
169: and process_phase = WIP_CONSTANTS.ML_VALIDATION
170: and process_status = WIP_CONSTANTS.ERROR ;
171:
172: if x_count > 0 then
173: rollback;
174:
201: begin
202: IF WIP_JOB_DETAILS.std_alone = 1 THEN
203:
204: Update WIP_JOB_DTLS_INTERFACE
205: SET process_status = WIP_CONSTANTS.ERROR
206: WHERE wip_entity_id = p_wip_entity_id
207: AND organization_id = p_organization_id;
208:
209: ELSIF WIP_JOB_DETAILS.std_alone = 0 THEN
208:
209: ELSIF WIP_JOB_DETAILS.std_alone = 0 THEN
210:
211: Update WIP_JOB_DTLS_INTERFACE
212: SET process_status = WIP_CONSTANTS.ERROR
213: WHERE group_id = p_group_id
214: AND parent_header_id = p_parent_header_id;
215:
216: END IF;
237: select group_id, header_id
238: into x_group_id, x_header_id
239: from wip_job_schedule_interface
240: where rowid = p_row_id
241: and load_type in (WIP_CONSTANTS.CREATE_JOB,WIP_CONSTANTS.RESCHED_JOB,
242: WIP_CONSTANTS.CREATE_NS_JOB);
243:
244: Update WIP_JOB_DTLS_INTERFACE
245: SET process_status = WIP_CONSTANTS.PENDING,
238: into x_group_id, x_header_id
239: from wip_job_schedule_interface
240: where rowid = p_row_id
241: and load_type in (WIP_CONSTANTS.CREATE_JOB,WIP_CONSTANTS.RESCHED_JOB,
242: WIP_CONSTANTS.CREATE_NS_JOB);
243:
244: Update WIP_JOB_DTLS_INTERFACE
245: SET process_status = WIP_CONSTANTS.PENDING,
246: group_id = p_group_id
241: and load_type in (WIP_CONSTANTS.CREATE_JOB,WIP_CONSTANTS.RESCHED_JOB,
242: WIP_CONSTANTS.CREATE_NS_JOB);
243:
244: Update WIP_JOB_DTLS_INTERFACE
245: SET process_status = WIP_CONSTANTS.PENDING,
246: group_id = p_group_id
247: WHERE group_id = x_group_id
248: AND parent_header_id = x_header_id;
249: