APPS.WSMPLOAD dependencies on WSM_RESULTING_JOBS_INTERFACE

Line 8: type t_wsm_wtxn_rj_tbl is table of wsm_resulting_jobs_interface%rowtype index by binary_integer;

4: /* Forward declaration of this PRIVATE PROCEDURE */
5:
6: type t_wsm_wtxn_hdr_tbl is table of wsm_split_merge_txn_interface%rowtype index by binary_integer;
7: type t_wsm_wtxn_sj_tbl is table of wsm_starting_jobs_interface%rowtype index by binary_integer;
8: type t_wsm_wtxn_rj_tbl is table of wsm_resulting_jobs_interface%rowtype index by binary_integer;
9:
10: type t_wtxn_hdr_id_tbl is table of wsm_split_merge_txn_interface.header_id%type index by binary_integer;
11: type t_wtxn_job_id_tbl is table of number index by binary_integer;
12: type t_wtxn_job_name_tbl is table of number index by wip_entities.wip_entity_name%type;

Line 762: from wsm_resulting_jobs_interface wrji,

758: End if;
759:
760: select wrji.*
761: bulk collect into l_wsm_wtxn_rj_tbl
762: from wsm_resulting_jobs_interface wrji,
763: wsm_split_merge_txn_interface wsmti
764: where wrji.header_id = wsmti.header_id
765: and wsmti.process_status = WIP_CONSTANTS.RUNNING
766: and wrji.process_status = WIP_CONSTANTS.PENDING

Line 802: update wsm_resulting_jobs_interface wrji

798: and internal_group_id = l_internal_group_id
799: )
800: and wsji.process_status = WIP_CONSTANTS.PENDING;
801:
802: update wsm_resulting_jobs_interface wrji
803: set process_status = WIP_CONSTANTS.RUNNING,
804: group_id = decode(group_id, NULL, l_internal_group_id, p_group_id),
805: internal_group_id = l_internal_group_id,
806: REQUEST_ID = g_request_id,

Line 1063: from WSM_RESULTING_JOBS_INTERFACE WRJI,

1059: l_error_txn := 1;
1060:
1061: select 1
1062: into l_dummy -- 'Earlier Errored Txn Exists in WRJI'
1063: from WSM_RESULTING_JOBS_INTERFACE WRJI,
1064: WSM_SPLIT_MERGE_TXN_INTERFACE WSMTI
1065: Where wsmti.process_status IN (WIP_CONSTANTS.PENDING,WIP_CONSTANTS.ERROR)
1066: and wrji.header_id = wsmti.header_id
1067: and (wrji.wip_entity_name = l_starting_jobs_tbl(l_index).wip_entity_name)

Line 1591: update wsm_resulting_jobs_interface wrji

1587: -- OSP FP I end
1588: l_stmt_num := 140;
1589:
1590: forall l_counter in l_txn_status_tbl.first..l_txn_status_tbl.last
1591: update wsm_resulting_jobs_interface wrji
1592: set group_id = decode(group_id, NULL, l_internal_group_id, p_group_id),
1593: internal_group_id = l_internal_group_id,
1594: REQUEST_ID = g_request_id,
1595: PROGRAM_UPDATE_DATE = sysdate,

Line 1693: -- delete from wsm_resulting_jobs_interface

1689: );
1690: End if;
1691:
1692: l_stmt_num := 170;
1693: -- delete from wsm_resulting_jobs_interface
1694: DELETE wsm_resulting_jobs_interface
1695: WHERE header_id IN (SELECT header_id
1696: FROM wsm_split_merge_txn_interface
1697: WHERE process_status = WIP_CONSTANTS.COMPLETED

Line 1694: DELETE wsm_resulting_jobs_interface

1690: End if;
1691:
1692: l_stmt_num := 170;
1693: -- delete from wsm_resulting_jobs_interface
1694: DELETE wsm_resulting_jobs_interface
1695: WHERE header_id IN (SELECT header_id
1696: FROM wsm_split_merge_txn_interface
1697: WHERE process_status = WIP_CONSTANTS.COMPLETED
1698: AND transaction_date <= decode(l_del_int_prof_value, NULL, transaction_date-1,

Line 1705: p_msg_text => 'Deleted : ' || SQL%ROWCOUNT || ' rows from wsm_resulting_jobs_interface',

1701:
1702: if( g_log_level_statement >= l_log_level ) then
1703: l_msg_tokens.delete;
1704: WSM_log_PVT.logMessage(p_module_name => l_module ,
1705: p_msg_text => 'Deleted : ' || SQL%ROWCOUNT || ' rows from wsm_resulting_jobs_interface',
1706: p_stmt_num => l_stmt_num ,
1707: p_msg_tokens => l_msg_tokens,
1708: p_fnd_log_level => g_log_level_statement,
1709: p_run_log_level => l_log_level