53: --
54: TYPE ref_demand_cur IS REF CURSOR;
55: c_demand ref_demand_cur;
56: --
57: v_Sched_rec RLM_INTERFACE_HEADERS%ROWTYPE;
58: v_Group_rec t_Group_rec;
59:
60: l_start_time NUMBER;
61: l_end_time NUMBER;
108: --
109: IF p_header_id IS NOT NULL THEN
110: --
111: v_from_clause := '
112: FROM rlm_interface_headers hdr';
113: --
114: -- bug 3756599
115: v_where_clause := '
116: WHERE hdr.process_status IN (:k_PS_AVAILABLE, :k_PS_PARTIAL_PROCESSED, :k_PS_ERROR) AND header_id = :p_header_id ';
122: --
123: ELSE
124: --
125: v_from_clause := '
126: FROM rlm_interface_headers hdr';
127: v_where_clause := '
128: WHERE hdr.process_status IN (:k_PS_AVAILABLE, :k_PS_PARTIAL_PROCESSED, :k_PS_ERROR) ';
129: g_BindVarTab(g_BindVarTab.COUNT+1) := rlm_core_sv.k_PS_AVAILABLE;
130: g_BindVarTab(g_BindVarTab.COUNT+1) := rlm_core_sv.k_PS_PARTIAL_PROCESSED;
289:
290: IF v_header_ps IN (rlm_core_sv.k_PS_ERROR,
291: rlm_core_sv.k_PS_PARTIAL_PROCESSED) THEN
292: --
293: update rlm_interface_headers_all
294: set process_status = rlm_core_sv.k_PS_AVAILABLE
295: where header_id = v_header_id;
296: --
297: IF (l_debug <> -1) THEN
796: rlm_core_sv.dlog(C_DEBUG, 'x_header_id',x_header_id);
797: END IF;
798: --
799: select process_status into v_process_status
800: from rlm_interface_headers
801: where header_id = x_header_id;
802: --
803: DELETE FROM RLM_INTERFACE_HEADERS
804: WHERE header_id = x_header_id
799: select process_status into v_process_status
800: from rlm_interface_headers
801: where header_id = x_header_id;
802: --
803: DELETE FROM RLM_INTERFACE_HEADERS
804: WHERE header_id = x_header_id
805: and process_Status = rlm_core_sv.k_PS_PROCESSED;
806: --
807: IF(v_process_status <> rlm_core_sv.k_PS_PARTIAL_PROCESSED) THEN
852: PROCEDURE NAME: LockHeader
853:
854: ===========================================================================*/
855:
856: FUNCTION LockHeader (x_HeaderId IN NUMBER, v_Sched_rec OUT NOCOPY RLM_INTERFACE_HEADERS%ROWTYPE)
857: RETURN BOOLEAN
858: IS
859: x_progress VARCHAR2(3) := '010';
860:
859: x_progress VARCHAR2(3) := '010';
860:
861: CURSOR c IS
862: SELECT *
863: FROM rlm_interface_headers
864: WHERE header_id = x_HeaderId
865: and process_status IN (rlm_core_sv.k_PS_AVAILABLE,
866: rlm_core_sv.k_PS_PARTIAL_PROCESSED)
867: FOR UPDATE NOWAIT;
869: BEGIN
870: --
871: IF (l_debug <> -1) THEN
872: rlm_core_sv.dpush(C_SDEBUG,'LockHeader');
873: rlm_core_sv.dlog(C_DEBUG,'Locking RLM_INTERFACE_HEADERS');
874: END IF;
875: --
876: OPEN c;
877: FETCH c INTO v_Sched_rec;
966: v_program_id := fnd_global.conc_program_id;
967: --
968: SELECT schedule_header_id
969: INTO v_SchedHeaderId
970: FROM rlm_interface_headers
971: WHERE header_id = x_header_id;
972: --
973: IF (l_debug <> -1) THEN
974: rlm_core_sv.dlog(C_DEBUG, 'v_SchedHeaderId', v_SchedHeaderId);
1110: END IF;
1111: --
1112: SELECT schedule_header_id
1113: INTO v_SchedHeaderId
1114: FROM rlm_interface_headers
1115: WHERE header_id = x_HeaderId;
1116: --
1117: IF (l_debug <> -1) THEN
1118: rlm_core_sv.dlog(C_DEBUG, 'v_SchedHeaderId', v_SchedHeaderId);
1187: IF (l_debug <> -1) THEN
1188: rlm_core_sv.dlog(C_DEBUG,'x_HeaderStatus', x_HeaderStatus);
1189: END IF;
1190: --
1191: UPDATE rlm_interface_headers
1192: SET process_status = x_HeaderStatus,
1193: LAST_UPDATE_LOGIN = fnd_global.login_id ,
1194: REQUEST_ID = RLM_MESSAGE_SV.g_conc_req_id ,
1195: PROGRAM_APPLICATION_ID = fnd_global.PROG_APPL_ID ,
1429: --
1430: CURSOR c_group_cur IS
1431: SELECT ril.order_header_id,
1432: ril.blanket_number
1433: FROM rlm_interface_headers rih,
1434: rlm_interface_lines_all ril
1435: WHERE ril.header_id = x_header_id
1436: AND ril.header_id = rih.header_id
1437: AND ril.process_status in ( rlm_core_sv.k_PS_AVAILABLE,
1705: p_org_id IN NUMBER)
1706: IS
1707: --
1708: v_group_rec t_group_rec;
1709: v_sched_rec rlm_interface_headers%ROWTYPE;
1710: e_linesLocked EXCEPTION;
1711: e_MDFailed EXCEPTION;
1712: e_FDFailed EXCEPTION;
1713: e_RDFailed EXCEPTION;
1743: -- populate v_sched_rec
1744: --
1745: SELECT *
1746: INTO v_sched_rec
1747: FROM rlm_interface_headers_all
1748: WHERE header_id = p_header_id
1749: AND process_status IN (rlm_core_sv.k_PS_AVAILABLE,
1750: rlm_core_sv.k_PS_PARTIAL_PROCESSED);
1751: --
1814: PROCEDURE NAME: ProcessGroups
1815:
1816: ===========================================================================*/
1817:
1818: PROCEDURE ProcessGroups (p_sched_rec IN RLM_INTERFACE_HEADERS%ROWTYPE,
1819: p_header_id IN NUMBER,
1820: p_index IN NUMBER DEFAULT NULL,
1821: p_dspMode IN VARCHAR2)
1822: IS
1820: p_index IN NUMBER DEFAULT NULL,
1821: p_dspMode IN VARCHAR2)
1822: IS
1823: --
1824: v_sched_rec RLM_INTERFACE_HEADERS%ROWTYPE;
1825: v_Group_rec t_Group_rec;
1826: e_linesLocked EXCEPTION;
1827: e_MDFailed EXCEPTION;
1828: e_FDFailed EXCEPTION;
1860: ril.order_header_id,
1861: ril.blanket_number,
1862: min(ril.start_date_time),
1863: ril.ship_to_customer_id
1864: FROM rlm_interface_headers rih,
1865: rlm_interface_lines_all ril
1866: WHERE ril.header_id = p_header_id
1867: AND ril.header_id = rih.header_id
1868: AND nvl(ril.dsp_child_process_index,-99) =nvl(p_index, -99)