DBA Data[Home] [Help]

APPS.FEM_MULTI_PROC_PKG dependencies on FEM_MP_PROCESS_CTL_T

Line 12: c_ctl_table CONSTANT VARCHAR2(30) := 'FEM_MP_PROCESS_CTL_T';

8: c_mp_app_id CONSTANT NUMBER := 274; -- App ID for FEM
9:
10: c_max_procs CONSTANT NUMBER := 8;
11:
12: c_ctl_table CONSTANT VARCHAR2(30) := 'FEM_MP_PROCESS_CTL_T';
13: c_arg_table CONSTANT VARCHAR2(30) := 'FEM_MP_PROCESS_ARGS_T';
14:
15: c_log_level_1 CONSTANT NUMBER := fnd_log.level_statement;
16: c_log_level_2 CONSTANT NUMBER := fnd_log.level_procedure;

Line 153: 'INSERT INTO fem_mp_process_ctl_t' ||

149: v_part_clause := '';
150: END if;
151:
152: v_sql_cmd :=
153: 'INSERT INTO fem_mp_process_ctl_t' ||
154: '(req_id, rule_id, slice_id, partition, data_slice, process_num, '||
155: 'rows_processed, rows_loaded, rows_rejected, status, message)'||
156: ' SELECT '||
157: p_req_id || ',' || p_rule_id || ',rownum +' || p_rownum ||

Line 174: FROM FEM_MP_PROCESS_CTL_T

170: COMMIT;
171:
172: SELECT NVL(MAX(slice_id), 0)
173: INTO p_rownum
174: FROM FEM_MP_PROCESS_CTL_T
175: WHERE req_id = p_req_id;
176:
177: FEM_ENGINES_PKG.TECH_MESSAGE
178: (p_severity => c_log_level_2,

Line 248: 'INSERT INTO fem_mp_process_ctl_t ' ||

244: v_part_clause := '';
245: END if;
246:
247: v_sql_cmd :=
248: 'INSERT INTO fem_mp_process_ctl_t ' ||
249: '(req_id,rule_id,' ||
250: 'slice_id,partition,' ||
251: 'data_slice,' ||
252: 'process_num,rows_processed,rows_loaded,' ||

Line 283: FROM FEM_MP_PROCESS_CTL_T

279: COMMIT;
280:
281: SELECT NVL(MAX(slice_id), 0)
282: INTO p_rownum
283: FROM FEM_MP_PROCESS_CTL_T
284: WHERE req_id = p_req_id;
285:
286: FEM_ENGINES_PKG.TECH_MESSAGE
287: (p_severity => c_log_level_2,

Line 324: INSERT INTO fem_mp_process_ctl_t

320: p_msg_text => TO_CHAR(p_rownum));
321:
322: p_rownum := p_rownum + 1;
323:
324: INSERT INTO fem_mp_process_ctl_t
325: (req_id, rule_id, slice_id, partition, data_slice, process_num,
326: rows_processed, rows_loaded, rows_rejected, status, message)
327: VALUES
328: (p_req_id, p_rule_id, p_rownum, p_part_name, p_data_slc, 0,

Line 686: DELETE FROM FEM_MP_PROCESS_CTL_T

682:
683: ----------------------------------------------------
684: -- Remove data slices in case Job has multiple steps
685: ----------------------------------------------------
686: DELETE FROM FEM_MP_PROCESS_CTL_T
687: WHERE req_id = p_req_id;
688:
689: COMMIT;
690:

Line 1497: DELETE FROM fem_mp_process_ctl_t T

1493: THEN
1494: ----------------------------------
1495: -- Housekeep the MP process tables
1496: ----------------------------------
1497: DELETE FROM fem_mp_process_ctl_t T
1498: WHERE rule_id = p_rule_id
1499: AND (req_id IN (SELECT request_id
1500: FROM fnd_concurrent_requests
1501: WHERE phase_code = 'C')

Line 1521: DELETE FROM fem_mp_process_ctl_t

1517:
1518: Build Data Slices
1519:
1520: ***********************************************************************/
1521: DELETE FROM fem_mp_process_ctl_t
1522: WHERE req_id = v_req_id;
1523:
1524: COMMIT;
1525:

Line 1562: FROM fem_mp_process_ctl_t

1558:
1559: ***********************************************************************/
1560: SELECT MAX(REPLACE(data_slice,'{#}',''))
1561: INTO v_max_slice
1562: FROM fem_mp_process_ctl_t
1563: WHERE req_id = v_req_id;
1564:
1565:
1566: IF (v_max_slice IS NOT NULL)

Line 1570: FROM fem_mp_process_ctl_t

1566: IF (v_max_slice IS NOT NULL)
1567: THEN
1568: SELECT COUNT(*)
1569: INTO v_num_slices
1570: FROM fem_mp_process_ctl_t
1571: WHERE req_id = v_req_id;
1572: ELSE
1573: RAISE e_no_data_slices;
1574: END IF;

Line 1613: UPDATE fem_mp_process_ctl_t

1609:
1610: Process Error Rerun
1611:
1612: ***********************************************************************/
1613: UPDATE fem_mp_process_ctl_t
1614: SET req_id = v_req_id,
1615: process_num = 0
1616: WHERE req_id = p_failed_req_id
1617: AND status IS NULL;

Line 1628: UPDATE fem_mp_process_ctl_t

1624:
1625: Reset Data Slices to Initial State
1626:
1627: ***********************************************************************/
1628: UPDATE fem_mp_process_ctl_t
1629: SET process_num = 0,
1630: rows_processed = null,
1631: rows_loaded = null,
1632: rows_rejected = null,

Line 3501: ' UPDATE fem_mp_process_ctl_t'||

3497: ' :b_eng_sql,'''||v_data_slc||''','||
3498: ' :b_proc_num,:b_slc_id1,:b_fetch_limit';
3499:
3500: v_upd_stmt :=
3501: ' UPDATE fem_mp_process_ctl_t'||
3502: ' SET rows_processed = x_rows_processed,'||
3503: ' rows_loaded = x_rows_loaded,'||
3504: ' rows_rejected = x_rows_rejected,'||
3505: ' status = x_slc_stat,'||

Line 4534: FROM fem_mp_process_ctl_t

4530: END IF;
4531:
4532: SELECT status,message
4533: INTO v_slc_stat,v_slc_msg
4534: FROM fem_mp_process_ctl_t
4535: WHERE req_id = p_req_id
4536: AND slice_id = v_slc_id;
4537:
4538: END IF; -- Push Processing

Line 4595: UPDATE fem_mp_process_ctl_t

4591: v_slc_stat := 2;
4592: v_slc_msg := sqlerrm;
4593: END;
4594:
4595: UPDATE fem_mp_process_ctl_t
4596: SET status = v_slc_stat,
4597: message = v_slc_msg,
4598: rows_processed = v_rows_processed
4599: WHERE req_id = p_req_id

Line 4628: FROM fem_mp_process_ctl_t

4624: -- Post messages and set Concurrent status
4625: ------------------------------------------
4626: SELECT MAX(status)
4627: INTO v_sub_stat
4628: FROM fem_mp_process_ctl_t
4629: WHERE req_id = p_req_id
4630: AND process_num = p_proc_num;
4631:
4632: FEM_ENGINES_PKG.TECH_MESSAGE

Line 4820: FROM fem_mp_process_ctl_t

4816: -------------------------------------------------------------------------*/
4817:
4818: SELECT COUNT(DISTINCT partition)
4819: INTO v_part_count
4820: FROM fem_mp_process_ctl_t
4821: WHERE req_id = p_req_id;
4822:
4823: FEM_ENGINES_PKG.TECH_MESSAGE
4824: (p_severity => c_log_level_2,

Line 4899: FROM fem_mp_process_ctl_t

4895: LOOP
4896:
4897: SELECT slice_id, process_num
4898: INTO v_slc_id, v_proc_num0
4899: FROM fem_mp_process_ctl_t
4900: WHERE req_id = p_req_id
4901: AND slice_id =
4902: (SELECT MIN(slice_id)
4903: FROM fem_mp_process_ctl_t

Line 4903: FROM fem_mp_process_ctl_t

4899: FROM fem_mp_process_ctl_t
4900: WHERE req_id = p_req_id
4901: AND slice_id =
4902: (SELECT MIN(slice_id)
4903: FROM fem_mp_process_ctl_t
4904: WHERE req_id = p_req_id
4905: AND process_num = 0)
4906: FOR UPDATE;
4907:

Line 4916: UPDATE fem_mp_process_ctl_t

4912: END IF;
4913:
4914: END LOOP;
4915:
4916: UPDATE fem_mp_process_ctl_t
4917: SET process_num = p_proc_num
4918: WHERE req_id = p_req_id
4919: AND slice_id = v_slc_id;
4920:

Line 4961: FROM fem_mp_process_ctl_t

4957: p_msg_text => 'Searching previously used partition');
4958: BEGIN
4959: SELECT MIN(partition)
4960: INTO v_part_next
4961: FROM fem_mp_process_ctl_t
4962: WHERE req_id = p_req_id
4963: AND process_num = p_proc_num
4964: AND partition IN
4965: (SELECT partition

Line 4966: FROM fem_mp_process_ctl_t

4962: WHERE req_id = p_req_id
4963: AND process_num = p_proc_num
4964: AND partition IN
4965: (SELECT partition
4966: FROM fem_mp_process_ctl_t
4967: WHERE req_id = p_req_id
4968: AND process_num = 0);
4969: END;
4970: ELSE

Line 4987: FROM fem_mp_process_ctl_t

4983: p_msg_text => 'Searching next unprocessed partition');
4984: BEGIN
4985: SELECT MIN(partition)
4986: INTO v_part_next
4987: FROM fem_mp_process_ctl_t
4988: WHERE req_id = p_req_id
4989: AND partition NOT IN
4990: (SELECT partition
4991: FROM fem_mp_process_ctl_t

Line 4991: FROM fem_mp_process_ctl_t

4987: FROM fem_mp_process_ctl_t
4988: WHERE req_id = p_req_id
4989: AND partition NOT IN
4990: (SELECT partition
4991: FROM fem_mp_process_ctl_t
4992: WHERE req_id = p_req_id
4993: AND process_num > 0);
4994: END;
4995: END IF;

Line 5012: FROM fem_mp_process_ctl_t

5008: SELECT MIN(partition)
5009: INTO v_part_next
5010: FROM
5011: (SELECT partition, count(*) stat_0
5012: FROM fem_mp_process_ctl_t
5013: WHERE req_id = p_req_id
5014: AND process_num = 0
5015: GROUP BY partition)
5016: WHERE stat_0 =

Line 5019: FROM fem_mp_process_ctl_t

5015: GROUP BY partition)
5016: WHERE stat_0 =
5017: (SELECT max(stat_0) FROM
5018: (SELECT count(*) stat_0
5019: FROM fem_mp_process_ctl_t
5020: WHERE req_id = p_req_id
5021: AND process_num = 0
5022: GROUP BY partition));
5023: END;

Line 5039: FROM fem_mp_process_ctl_t

5035: LOOP
5036:
5037: SELECT slice_id, process_num
5038: INTO v_slc_id, v_proc_num0
5039: FROM fem_mp_process_ctl_t
5040: WHERE req_id = p_req_id
5041: AND slice_id =
5042: (SELECT MIN(slice_id)
5043: FROM fem_mp_process_ctl_t

Line 5043: FROM fem_mp_process_ctl_t

5039: FROM fem_mp_process_ctl_t
5040: WHERE req_id = p_req_id
5041: AND slice_id =
5042: (SELECT MIN(slice_id)
5043: FROM fem_mp_process_ctl_t
5044: WHERE req_id = p_req_id
5045: AND process_num = 0
5046: AND partition = v_part_next)
5047: FOR UPDATE;

Line 5057: UPDATE fem_mp_process_ctl_t

5053: END IF;
5054:
5055: END LOOP;
5056:
5057: UPDATE fem_mp_process_ctl_t
5058: SET process_num = p_proc_num
5059: WHERE req_id = p_req_id
5060: AND slice_id = v_slc_id;
5061:

Line 5118: FROM fem_mp_process_ctl_t

5114:
5115: BEGIN
5116: SELECT data_slice
5117: INTO v_data_slc
5118: FROM fem_mp_process_ctl_t
5119: WHERE req_id = p_req_id
5120: AND slice_id = v_slc_id
5121: AND process_num = p_proc_num;
5122: EXCEPTION

Line 5254: p_msg_text => 'Updating FEM_MP_PROCESS_CTL_T.');

5250:
5251: FEM_ENGINES_PKG.TECH_MESSAGE
5252: (p_severity => c_log_level_2,
5253: p_module => v_block||'.v_sql_cmd{707}',
5254: p_msg_text => 'Updating FEM_MP_PROCESS_CTL_T.');
5255:
5256: UPDATE fem_mp_process_ctl_t
5257: SET rows_processed = p_rows_processed,
5258: rows_loaded = p_rows_loaded,

Line 5256: UPDATE fem_mp_process_ctl_t

5252: (p_severity => c_log_level_2,
5253: p_module => v_block||'.v_sql_cmd{707}',
5254: p_msg_text => 'Updating FEM_MP_PROCESS_CTL_T.');
5255:
5256: UPDATE fem_mp_process_ctl_t
5257: SET rows_processed = p_rows_processed,
5258: rows_loaded = p_rows_loaded,
5259: rows_rejected = p_rows_rejected,
5260: status = p_status,

Line 5283: fem_mp_process_ctl_t.message%TYPE INDEX BY BINARY_INTEGER;

5279: PROCEDURE Post_Subreq_Messages(
5280: p_req_id IN NUMBER)
5281: IS
5282: TYPE mp_message_type IS TABLE OF
5283: fem_mp_process_ctl_t.message%TYPE INDEX BY BINARY_INTEGER;
5284: v_msg_list mp_message_type;
5285: BEGIN
5286: SELECT DISTINCT(message)
5287: BULK COLLECT INTO v_msg_list

Line 5288: FROM fem_mp_process_ctl_t

5284: v_msg_list mp_message_type;
5285: BEGIN
5286: SELECT DISTINCT(message)
5287: BULK COLLECT INTO v_msg_list
5288: FROM fem_mp_process_ctl_t
5289: WHERE req_id = p_req_id
5290: AND status IN (1,2);
5291:
5292: FEM_ENGINES_PKG.User_Message (

Line 5325: DELETE FROM fem_mp_process_ctl_t

5321: PROCEDURE Delete_Data_Slices(
5322: p_req_id IN NUMBER)
5323: IS
5324: BEGIN
5325: DELETE FROM fem_mp_process_ctl_t
5326: WHERE req_id = p_req_id;
5327:
5328: COMMIT;
5329: