APPS.WSMPLOAD dependencies on WSM_STARTING_JOBS_INTERFACE

Line 7: type t_wsm_wtxn_sj_tbl is table of wsm_starting_jobs_interface%rowtype index by binary_integer;

3:
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;

Line 739: from wsm_starting_jobs_interface wsji,

735: -- Completed setting the status...
736:
737: select wsji.*
738: bulk collect into l_wsm_wtxn_sj_tbl
739: from wsm_starting_jobs_interface wsji,
740: wsm_split_merge_txn_interface wsmti
741: where wsji.header_id = wsmti.header_id
742: and wsmti.process_status = WIP_CONSTANTS.RUNNING
743: and wsji.process_status = WIP_CONSTANTS.PENDING

Line 783: update wsm_starting_jobs_interface wsji

779: p_run_log_level => l_log_level
780: );
781: End if;
782:
783: update wsm_starting_jobs_interface wsji
784: set process_status = WIP_CONSTANTS.RUNNING,
785: group_id = decode(group_id, NULL, l_internal_group_id, p_group_id),
786: internal_group_id = l_internal_group_id,
787: REQUEST_ID = g_request_id,

Line 1045: from WSM_STARTING_JOBS_INTERFACE WSJI,

1041: begin
1042: l_stmt_num := 52;
1043: select 1
1044: into l_dummy -- 'Earlier Errored Txn Exists in WSJI'
1045: from WSM_STARTING_JOBS_INTERFACE WSJI,
1046: WSM_SPLIT_MERGE_TXN_INTERFACE WSMTI
1047: Where wsmti.process_status IN (WIP_CONSTANTS.PENDING,WIP_CONSTANTS.ERROR)
1048: and wsji.header_id = wsmti.header_id
1049: and (wsji.wip_entity_id = l_starting_jobs_tbl(l_index).wip_entity_id

Line 1484: l_msg_tokens(1).TokenValue := 'WSM_STARTING_JOBS_INTERFACE (header_id = ' || l_wsm_wtxn_hdr_tbl(l_txn_counter).header_id

1480: IF G_LOG_LEVEL_ERROR >= l_log_level OR FND_MSG_PUB.check_msg_level(g_msg_lvl_error) THEN
1481:
1482: l_msg_tokens.delete;
1483: l_msg_tokens(1).TokenName := 'TABLE';
1484: l_msg_tokens(1).TokenValue := 'WSM_STARTING_JOBS_INTERFACE (header_id = ' || l_wsm_wtxn_hdr_tbl(l_txn_counter).header_id
1485: || ' )';
1486: WSM_log_PVT.logMessage(p_module_name => l_module ,
1487: p_msg_name => 'WSM_PENDING_TXN' ,
1488: p_msg_appl_name => 'WSM' ,

Line 1606: update wsm_starting_jobs_interface wsji

1602: where wrji.header_id = l_txn_header_tbl(l_counter)
1603: and wrji.process_status = WIP_CONSTANTS.RUNNING;
1604:
1605: forall l_counter in l_txn_status_tbl.first..l_txn_status_tbl.last
1606: update wsm_starting_jobs_interface wsji
1607: set group_id = decode(group_id, NULL, l_internal_group_id, p_group_id),
1608: internal_group_id = l_internal_group_id,
1609: REQUEST_ID = g_request_id,
1610: PROGRAM_UPDATE_DATE = sysdate,

Line 1673: -- delete from wsm_starting_jobs_interface

1669: -- ok here we go and delete the completed the txns ..... based on the profile
1670: l_stmt_num := 160;
1671: l_del_int_prof_value := fnd_profile.value('WSM_INTERFACE_HISTORY_DAYS');
1672:
1673: -- delete from wsm_starting_jobs_interface
1674: DELETE wsm_starting_jobs_interface
1675: WHERE header_id IN ( SELECT header_id
1676: FROM wsm_split_merge_txn_interface
1677: WHERE process_status = WIP_CONSTANTS.COMPLETED

Line 1674: DELETE wsm_starting_jobs_interface

1670: l_stmt_num := 160;
1671: l_del_int_prof_value := fnd_profile.value('WSM_INTERFACE_HISTORY_DAYS');
1672:
1673: -- delete from wsm_starting_jobs_interface
1674: DELETE wsm_starting_jobs_interface
1675: WHERE header_id IN ( SELECT header_id
1676: FROM wsm_split_merge_txn_interface
1677: WHERE process_status = WIP_CONSTANTS.COMPLETED
1678: AND transaction_date <= decode(l_del_int_prof_value, NULL, transaction_date-1,

Line 1684: p_msg_text => 'Deleted : ' || SQL%ROWCOUNT || ' rows from wsm_starting_jobs_interface',

1680:
1681: if( g_log_level_statement >= l_log_level ) then
1682: l_msg_tokens.delete;
1683: WSM_log_PVT.logMessage(p_module_name => l_module ,
1684: p_msg_text => 'Deleted : ' || SQL%ROWCOUNT || ' rows from wsm_starting_jobs_interface',
1685: p_stmt_num => l_stmt_num ,
1686: p_msg_tokens => l_msg_tokens,
1687: p_fnd_log_level => g_log_level_statement,
1688: p_run_log_level => l_log_level