DBA Data[Home] [Help]

APPS.WSMPLOAD dependencies on WIP_CONSTANTS

Line 137: decode(wlbj.on_rec_path, 'Y', WIP_CONSTANTS.MIDPOINT_FORWARDS, WIP_CONSTANTS.CURRENT_OP) inf_sch_mode

133:
134: CURSOR C_INF_SCH_PAR_REP_JOBS IS
135: SELECT distinct(wdj.wip_entity_id) wip_entity_id,
136: wdj.organization_id,
137: decode(wlbj.on_rec_path, 'Y', WIP_CONSTANTS.MIDPOINT_FORWARDS, WIP_CONSTANTS.CURRENT_OP) inf_sch_mode
138: FROM wsm_lot_based_jobs wlbj,
139: wip_discrete_jobs wdj,
140: wsm_sm_resulting_jobs wsrj
141: WHERE wsrj.internal_group_id = WSMPLOAD.G_GROUP_ID

Line 635: and wsmti.process_status = WIP_CONSTANTS.PENDING

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;
637:
638: BEGIN
639: l_stmt_num := 5;

Line 721: set process_status = WIP_CONSTANTS.RUNNING,

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,
725: PROGRAM_UPDATE_DATE = sysdate,

Line 742: and wsmti.process_status = WIP_CONSTANTS.RUNNING

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
745: and wsmti.transaction_date <= sysdate
746: order by wsmti.transaction_date,wsmti.header_id;

Line 743: and wsji.process_status = WIP_CONSTANTS.PENDING

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
745: and wsmti.transaction_date <= sysdate
746: order by wsmti.transaction_date,wsmti.header_id;
747:

Line 765: and wsmti.process_status = WIP_CONSTANTS.RUNNING

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
768: and wsmti.transaction_date <= sysdate
769: order by wsmti.transaction_date,wsmti.header_id;

Line 766: and wrji.process_status = WIP_CONSTANTS.PENDING

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
768: and wsmti.transaction_date <= sysdate
769: order by wsmti.transaction_date,wsmti.header_id;
770:

Line 784: set process_status = WIP_CONSTANTS.RUNNING,

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,
788: PROGRAM_UPDATE_DATE = sysdate,

Line 796: where wsmti.process_status = WIP_CONSTANTS.RUNNING

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: )
800: and wsji.process_status = WIP_CONSTANTS.PENDING;

Line 800: and wsji.process_status = WIP_CONSTANTS.PENDING;

796: where wsmti.process_status = WIP_CONSTANTS.RUNNING
797: and wsmti.transaction_date <= sysdate
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),

Line 803: set process_status = WIP_CONSTANTS.RUNNING,

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,
807: PROGRAM_UPDATE_DATE = sysdate,

Line 815: where wsmti.process_status = WIP_CONSTANTS.RUNNING

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: )
819: and wrji.process_status = WIP_CONSTANTS.PENDING;

Line 819: and wrji.process_status = WIP_CONSTANTS.PENDING;

815: where wsmti.process_status = WIP_CONSTANTS.RUNNING
816: and wsmti.transaction_date <= sysdate
817: and internal_group_id = l_internal_group_id
818: )
819: and wrji.process_status = WIP_CONSTANTS.PENDING;
820:
821: -- issue update statements for all the transactions...
822: COMMIT;
823:

Line 1047: Where wsmti.process_status IN (WIP_CONSTANTS.PENDING,WIP_CONSTANTS.ERROR)

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
1051: ( wsji.wip_entity_name = l_starting_jobs_tbl(l_index).wip_entity_name

Line 1065: Where wsmti.process_status IN (WIP_CONSTANTS.PENDING,WIP_CONSTANTS.ERROR)

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)
1069: and wsmti.transaction_date < l_txn_header_rec.transaction_date;

Line 1166: l_txn_status_tbl(l_txn_counter) := wip_constants.error;

1162: END LOOP;
1163: END IF;
1164: -- ST : Fix for bug 5226648 end --
1165:
1166: l_txn_status_tbl(l_txn_counter) := wip_constants.error;
1167: l_txn_header_tbl(l_txn_counter) := l_wsm_wtxn_hdr_tbl(l_txn_counter).header_id;
1168:
1169: l_stmt_num := 62;
1170: -- also add the job name and the job wip entity id also... to the errored list....

Line 1331: l_txn_status_tbl(l_txn_counter) := wip_constants.completed;

1327: );
1328: End if;
1329:
1330: l_stmt_num := 70;
1331: l_txn_status_tbl(l_txn_counter) := wip_constants.completed;
1332: l_txn_header_tbl(l_txn_counter) := l_wsm_wtxn_hdr_tbl(l_txn_counter).header_id;
1333:
1334: -- ST : Commenting out the below code for bug 5233265
1335: -- IF l_txn_header_rec.transaction_type_id = WSMPCNST.BONUS THEN

Line 1405: l_txn_status_tbl(l_txn_counter) := wip_constants.error;

1401: fnd_file.put_line(fnd_file.log,l_error_msg);
1402: END IF;
1403:
1404: l_stmt_num := 90;
1405: l_txn_status_tbl(l_txn_counter) := wip_constants.error;
1406: l_txn_header_tbl(l_txn_counter) := l_wsm_wtxn_hdr_tbl(l_txn_counter).header_id;
1407:
1408: l_index := l_starting_jobs_tbl.first;
1409:

Line 1447: l_txn_status_tbl(l_txn_counter) := wip_constants.error;

1443: l_stmt_num := 105;
1444:
1445: ROLLBACK TO s_process_one_wlt;
1446:
1447: l_txn_status_tbl(l_txn_counter) := wip_constants.error;
1448: l_txn_header_tbl(l_txn_counter) := l_wsm_wtxn_hdr_tbl(l_txn_counter).header_id;
1449:
1450: l_stmt_num := 106;
1451: -- also add the job name and the job wip entity id also... to the errored list....

Line 1476: l_txn_status_tbl(l_txn_counter) := wip_constants.error;

1472: -- error
1473: l_stmt_num := 110;
1474: l_program_status := nvl(l_program_status,-1);
1475: -- add the header id to the errored list....
1476: l_txn_status_tbl(l_txn_counter) := wip_constants.error;
1477: l_txn_header_tbl(l_txn_counter) := l_wsm_wtxn_hdr_tbl(l_txn_counter).header_id;
1478:
1479: -- Add the error message : ST : Fix for bug 4859986
1480: IF G_LOG_LEVEL_ERROR >= l_log_level OR FND_MSG_PUB.check_msg_level(g_msg_lvl_error) THEN

Line 1603: and wrji.process_status = WIP_CONSTANTS.RUNNING;

1599: LAST_UPDATE_DATE = sysdate,
1600: LAST_UPDATED_BY = g_user_id,
1601: LAST_UPDATE_LOGIN = g_user_login_id
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),

Line 1618: and wsji.process_status = WIP_CONSTANTS.RUNNING;

1614: LAST_UPDATE_DATE = sysdate,
1615: LAST_UPDATED_BY = g_user_id,
1616: LAST_UPDATE_LOGIN = g_user_login_id
1617: where wsji.header_id = l_txn_header_tbl(l_counter)
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

Line 1633: WHERE wsmti.process_status = WIP_CONSTANTS.RUNNING

1629: process_status = l_txn_status_tbl(l_counter),
1630: LAST_UPDATE_DATE = sysdate,
1631: LAST_UPDATED_BY = g_user_id,
1632: LAST_UPDATE_LOGIN = g_user_login_id
1633: WHERE wsmti.process_status = WIP_CONSTANTS.RUNNING
1634: and wsmti.header_id = l_txn_header_tbl(l_counter)
1635: and nvl(wsmti.group_id,l_internal_group_id) = nvl(p_group_id,l_internal_group_id) -- Modified for bug 7145473.
1636: and wsmti.transaction_date <= sysdate;
1637:

Line 1677: WHERE process_status = WIP_CONSTANTS.COMPLETED

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:
1681: if( g_log_level_statement >= l_log_level ) then

Line 1697: WHERE process_status = WIP_CONSTANTS.COMPLETED

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:
1701:

Line 1715: WHERE process_status = WIP_CONSTANTS.COMPLETED

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:
1719: -- delete from wsm_split_merge_txn_interface