DBA Data[Home] [Help]

APPS.WSMPLOAD dependencies on WSM_SPLIT_MERGE_TXN_INTERFACE

Line 6: type t_wsm_wtxn_hdr_tbl is table of wsm_split_merge_txn_interface%rowtype index by binary_integer;

2: /* $Header: WSMLOADB.pls 120.10.12010000.2 2008/09/02 06:11:44 sisankar ship $ */
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;

Line 10: type t_wtxn_hdr_id_tbl is table of wsm_split_merge_txn_interface.header_id%type index by binary_integer;

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;
13:
14: g_user_id number;

Line 632: from wsm_split_merge_txn_interface wsmti

628: -- ST : Added for bug 5297923
629: e_invalid_job_data exception;
630: cursor c_pending_txn_header is
631: select *
632: from wsm_split_merge_txn_interface wsmti
633: where nvl(wsmti.group_id,-99999) = nvl(nvl(p_group_id,wsmti.group_id),-99999)
634: and wsmti.transaction_date <= sysdate
635: and wsmti.process_status = WIP_CONSTANTS.PENDING
636: order by transaction_date,header_id;

Line 720: update wsm_split_merge_txn_interface wsmti

716: end loop;
717:
718: -- Update..
719: forall l_cntr in l_header_id_tbl.first..l_header_id_tbl.last
720: update wsm_split_merge_txn_interface wsmti
721: set process_status = WIP_CONSTANTS.RUNNING,
722: group_id = decode(group_id, NULL, l_internal_group_id, p_group_id),
723: internal_group_id = l_internal_group_id,
724: REQUEST_ID = g_request_id,

Line 740: wsm_split_merge_txn_interface wsmti

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
744: and wsmti.internal_group_id = l_internal_group_id

Line 763: wsm_split_merge_txn_interface wsmti

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
767: and wsmti.internal_group_id = l_internal_group_id

Line 795: wsm_split_merge_txn_interface wsmti

791: LAST_UPDATE_DATE = sysdate,
792: LAST_UPDATED_BY = g_user_id,
793: LAST_UPDATE_LOGIN = g_user_login_id
794: where wsji.header_id in ( select header_id from
795: wsm_split_merge_txn_interface wsmti
796: where wsmti.process_status = WIP_CONSTANTS.RUNNING
797: and wsmti.transaction_date <= sysdate
798: and internal_group_id = l_internal_group_id
799: )

Line 814: wsm_split_merge_txn_interface wsmti

810: LAST_UPDATE_DATE = sysdate,
811: LAST_UPDATED_BY = g_user_id,
812: LAST_UPDATE_LOGIN = g_user_login_id
813: where wrji.header_id in ( select header_id from
814: wsm_split_merge_txn_interface wsmti
815: where wsmti.process_status = WIP_CONSTANTS.RUNNING
816: and wsmti.transaction_date <= sysdate
817: and internal_group_id = l_internal_group_id
818: )

Line 1046: WSM_SPLIT_MERGE_TXN_INTERFACE WSMTI

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
1050: OR

Line 1064: WSM_SPLIT_MERGE_TXN_INTERFACE WSMTI

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)
1068: and wrji.organization_id = nvl(l_starting_jobs_tbl(l_index).organization_id,l_txn_header_rec.organization_id)

Line 1622: update wsm_split_merge_txn_interface wsmti

1618: and wsji.process_status = WIP_CONSTANTS.RUNNING;
1619:
1620: forall l_counter in l_txn_status_tbl.first..l_txn_status_tbl.last
1621:
1622: update wsm_split_merge_txn_interface wsmti
1623: set group_id = decode(group_id, NULL, l_internal_group_id, p_group_id),
1624: internal_group_id = l_internal_group_id,
1625: REQUEST_ID = g_request_id,
1626: PROGRAM_UPDATE_DATE = sysdate,

Line 1676: FROM wsm_split_merge_txn_interface

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,
1679: SYSDATE - l_del_int_prof_value));
1680:

Line 1696: FROM wsm_split_merge_txn_interface

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,
1699: SYSDATE - l_del_int_prof_value));
1700:

Line 1714: DELETE wsm_split_merge_txn_interface

1710: );
1711: End if;
1712:
1713: l_stmt_num := 180;
1714: DELETE wsm_split_merge_txn_interface
1715: WHERE process_status = WIP_CONSTANTS.COMPLETED
1716: AND transaction_date <= decode(l_del_int_prof_value, NULL, transaction_date-1,
1717: SYSDATE - l_del_int_prof_value);
1718:

Line 1719: -- delete from wsm_split_merge_txn_interface

1715: WHERE process_status = WIP_CONSTANTS.COMPLETED
1716: AND transaction_date <= decode(l_del_int_prof_value, NULL, transaction_date-1,
1717: SYSDATE - l_del_int_prof_value);
1718:
1719: -- delete from wsm_split_merge_txn_interface
1720: if( g_log_level_statement >= l_log_level ) then
1721: l_msg_tokens.delete;
1722: WSM_log_PVT.logMessage(p_module_name => l_module ,
1723: p_msg_text => 'Deleted : ' || SQL%ROWCOUNT || ' rows from wsm_split_merge_txn_interface',

Line 1723: p_msg_text => 'Deleted : ' || SQL%ROWCOUNT || ' rows from wsm_split_merge_txn_interface',

1719: -- delete from wsm_split_merge_txn_interface
1720: if( g_log_level_statement >= l_log_level ) then
1721: l_msg_tokens.delete;
1722: WSM_log_PVT.logMessage(p_module_name => l_module ,
1723: p_msg_text => 'Deleted : ' || SQL%ROWCOUNT || ' rows from wsm_split_merge_txn_interface',
1724: p_stmt_num => l_stmt_num ,
1725: p_msg_tokens => l_msg_tokens,
1726: p_fnd_log_level => g_log_level_statement,
1727: p_run_log_level => l_log_level