The following lines contain the word 'select', 'insert', 'update' or 'delete':
l_updated_docref VARCHAR2(50);
SELECT order_source_id
FROM oe_order_sources s
WHERE (
(nvl(l_order_source,' ') = ' ') OR
(
(nvl(l_order_source,' ') <> ' ') AND
(enabled_flag = 'Y') AND
(nvl(to_char(order_source_id),' ')=nvl(rtrim(l_order_source),' '))
)
)
ORDER BY order_source_id
;
SELECT order_source_id
, orig_sys_document_ref
, sold_to_org_id
, sold_to_org
, change_sequence
, nvl(closed_flag, 'N')
,org_id
FROM oe_headers_iface_all
WHERE request_id = l_request_id
AND decode(p_perf_param, 'Y',
nvl(error_flag,'N'), ' ')
= decode(p_perf_param, 'Y',
'N', ' ')
AND decode(l_looped_flag, 'Y',
l_rowid, ' ')
= decode(l_looped_flag, 'Y',
rowidtochar(rowid), ' ')
ORDER BY org_id,order_source_id, orig_sys_document_ref, change_sequence
;
SELECT order_source_id
, original_sys_document_ref
, change_sequence
, original_sys_document_line_ref
, message_text
FROM oe_processing_msgs_vl
WHERE request_id = l_request_id
ORDER BY order_source_id, original_sys_document_ref, change_sequence
;
SELECT /*+ INDEX (a,OE_PROCESSING_MSGS_N2)
USE_NL (a b) */
a.order_source_id
, a.original_sys_document_ref
, a.change_sequence
, a.original_sys_document_line_ref
, a.org_id
, b.message_text
FROM oe_processing_msgs a, oe_processing_msgs_tl b
WHERE a.request_id = l_request_id
AND a.transaction_id = b.transaction_id
AND b.language = oe_globals.g_lang
ORDER BY a.order_source_id, a.original_sys_document_ref, a.change_sequence
;
Update Concurrent Request Ids
-----------------------------------------------------------
*/
/* oe_debug_pub.add('No of orders in inf table');
SELECT COUNT(*) INTO l_ord_count
FROM oe_headers_iface_all
WHERE order_source_id = 1084
AND ( nvl(NULL,' ') = ' ' OR
(nvl(NULL,' ') <> ' ' AND
nvl(NULL,' ') = nvl(orig_sys_document_ref,' ')))
AND ( nvl(NULL,' ') = ' ' OR
(nvl(NULL,' ') <> ' ' AND
nvl(NULL,' ') = nvl(operation_code,' ')))
AND request_id IS NULL
AND nvl(error_flag,'N') = 'N';
UPDATE oe_headers_interface
SET request_id = l_request_id
WHERE order_source_id = l_order_source_id
AND ( nvl(l_orig_sys_document_ref,' ') = ' ' OR
(nvl(l_orig_sys_document_ref,' ') <> ' ' AND
nvl(l_orig_sys_document_ref,' ') = nvl(orig_sys_document_ref,' ')))
AND ( nvl(l_operation_code,' ') = ' ' OR
(nvl(l_operation_code,' ') <> ' ' AND
nvl(l_operation_code,' ') = nvl(operation_code,' ')))
AND ( l_sold_to_org_id IS NULL OR
(l_sold_to_org_id IS NOT NULL AND
nvl(l_sold_to_org_id, FND_API.G_MISS_NUM) = nvl(sold_to_org_id, FND_API.G_MISS_NUM)))
AND
( l_sold_to_org IS NULL OR
(l_sold_to_org IS NOT NULL AND
nvl(l_sold_to_org, FND_API.G_MISS_CHAR) = nvl(sold_to_org, FND_API.G_MISS_CHAR)))
AND ( l_change_sequence IS NULL OR
(l_change_sequence IS NOT NULL AND
nvl(l_change_sequence, FND_API.G_MISS_CHAR) = nvl(change_sequence, FND_API.G_MISS_CHAR)))
AND request_id IS NULL
AND nvl(error_flag,'N') = 'N';
UPDATE oe_headers_iface_all
SET request_id = l_request_id,
org_id = p_default_org_id
WHERE order_source_id = l_order_source_id
AND ( nvl(l_orig_sys_document_ref,' ') = ' ' OR
(nvl(l_orig_sys_document_ref,' ') <> ' ' AND
nvl(l_orig_sys_document_ref,' ') = nvl(orig_sys_document_ref,' ')))
AND ( nvl(l_operation_code,' ') = ' ' OR
(nvl(l_operation_code,' ') <> ' ' AND
nvl(l_operation_code,' ') = nvl(operation_code,' ')))
AND ( l_sold_to_org_id IS NULL OR
(l_sold_to_org_id IS NOT NULL AND
nvl(l_sold_to_org_id, FND_API.G_MISS_NUM) = nvl(sold_to_org_id, FND_API.G_MISS_NUM)))
AND
( l_sold_to_org IS NULL OR
(l_sold_to_org IS NOT NULL AND
nvl(l_sold_to_org, FND_API.G_MISS_CHAR) = nvl(sold_to_org, FND_API.G_MISS_CHAR)))
AND ( l_change_sequence IS NULL OR
(l_change_sequence IS NOT NULL AND
nvl(l_change_sequence, FND_API.G_MISS_CHAR) = nvl(change_sequence, FND_API.G_MISS_CHAR)))
AND request_id IS NULL
AND nvl(error_flag,'N') = 'N'
AND org_id IS NULL;
SELECT COUNT(*)
INTO l_row_count
FROM oe_headers_iface_all -- MOAC
WHERE request_id = l_request_id;
UPDATE oe_headers_iface_all
SET request_id = new_request_id
WHERE request_id = l_request_id
AND ROWNUM =1;
UPDATE oe_headers_iface_all
SET request_id = new_request_id
WHERE request_id = l_request_id
AND ROWNUM <= batch_size;
UPDATE oe_lines_iface_all
SET request_id = l_request_id
WHERE (order_source_id, orig_sys_document_ref, nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR),nvl(org_id,nvl(p_default_org_id,FND_API.G_MISS_NUM))) IN
( SELECT order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR), nvl(org_id,FND_API.G_MISS_NUM)
FROM oe_headers_iface_all
WHERE request_id = l_request_id);
oe_debug_pub.add('rows updated: ' || sql%rowcount);
UPDATE oe_price_adjs_iface_all
SET request_id = l_request_id
WHERE (order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR),nvl(org_id,nvl(p_default_org_id,FND_API.G_MISS_NUM))) IN
( SELECT order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR), nvl(org_id,FND_API.G_MISS_NUM)
FROM oe_headers_iface_all
WHERE request_id = l_request_id) ;
UPDATE oe_payments_iface_all
SET request_id = l_request_id
WHERE (order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR),nvl(org_id,nvl(p_default_org_id,FND_API.G_MISS_NUM))) IN
( SELECT order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR), nvl(org_id,FND_API.G_MISS_NUM)
FROM oe_headers_iface_all
WHERE request_id = l_request_id) ;
oe_debug_pub.add('oe payments rows updated: ' || sql%rowcount);
UPDATE oe_price_atts_iface_all
SET request_id = l_request_id
WHERE (order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR),nvl(org_id,nvl(p_default_org_id,FND_API.G_MISS_NUM))) IN
( SELECT order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR), nvl(org_id,FND_API.G_MISS_NUM)
FROM oe_headers_iface_all
WHERE request_id = l_request_id) ;
UPDATE oe_credits_iface_all
SET request_id = l_request_id
WHERE (order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR),nvl(org_id,nvl(p_default_org_id,FND_API.G_MISS_NUM))) IN
( SELECT order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR), nvl(org_id,FND_API.G_MISS_NUM)
FROM oe_headers_iface_all
WHERE request_id = l_request_id) ;
UPDATE oe_lotserials_iface_all
SET request_id = l_request_id
WHERE (order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR),nvl(org_id,nvl(p_default_org_id,FND_API.G_MISS_NUM))) IN
( SELECT order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR), nvl(org_id,FND_API.G_MISS_NUM)
FROM oe_headers_iface_all
WHERE request_id = l_request_id) ;
UPDATE oe_reservtns_iface_all
SET request_id = l_request_id
WHERE (order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR),nvl(org_id,nvl(p_default_org_id,FND_API.G_MISS_NUM))) IN
( SELECT order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR), nvl(org_id,FND_API.G_MISS_NUM)
FROM oe_headers_iface_all
WHERE request_id = l_request_id) ;
UPDATE oe_actions_iface_all
SET request_id = l_request_id
WHERE (order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR),nvl(org_id,nvl(p_default_org_id,FND_API.G_MISS_NUM))) IN
( SELECT order_source_id, orig_sys_document_ref,
nvl(sold_to_org_id, FND_API.G_MISS_NUM), nvl(sold_to_org, FND_API.G_MISS_CHAR), nvl(change_sequence, FND_API.G_MISS_CHAR), nvl(org_id,FND_API.G_MISS_NUM)
FROM oe_headers_iface_all
WHERE request_id = l_request_id) ;
select parent_request_id
into l_pnt_request_id
from fnd_concurrent_requests
where request_id=l_request_id;
UPDATE oe_lines_iface_all
SET request_id = l_request_id,
sold_to_org_id = nvl(sold_to_org_id, l_sold_to_org_id),
sold_to_org = nvl(sold_to_org, l_sold_to_org),
org_id = l_org_id
WHERE order_source_id = l_order_source_id
AND orig_sys_document_ref = l_orig_sys_document_ref
AND nvl(change_sequence, ' ') = nvl(l_change_sequence, ' ')
AND nvl(org_id,l_org_id) = l_org_id ;
UPDATE oe_price_adjs_iface_all
SET request_id = l_request_id,
sold_to_org_id = nvl(sold_to_org_id, l_sold_to_org_id),
sold_to_org = nvl(sold_to_org, l_sold_to_org),
org_id = l_org_id
WHERE order_source_id = l_order_source_id
AND orig_sys_document_ref = l_orig_sys_document_ref
AND nvl(change_sequence, ' ') = nvl(l_change_sequence, ' ')
AND nvl(org_id,l_org_id) = l_org_id ;
UPDATE oe_payments_iface_all /* Bug #3419970 */
SET request_id = l_request_id,
sold_to_org_id = nvl(sold_to_org_id, l_sold_to_org_id),
sold_to_org = nvl(sold_to_org, l_sold_to_org),
org_id = l_org_id
WHERE order_source_id = l_order_source_id
AND orig_sys_document_ref = l_orig_sys_document_ref
AND nvl(change_sequence, ' ') = nvl(l_change_sequence, ' ')
AND nvl(org_id,l_org_id) = l_org_id ;
UPDATE oe_price_atts_iface_all
SET request_id = l_request_id,
sold_to_org_id = nvl(sold_to_org_id, l_sold_to_org_id),
sold_to_org = nvl(sold_to_org, l_sold_to_org),
org_id = l_org_id
WHERE order_source_id = l_order_source_id
AND orig_sys_document_ref = l_orig_sys_document_ref
AND nvl(change_sequence, ' ') = nvl(l_change_sequence, ' ')
AND nvl(org_id,l_org_id) = l_org_id ;
UPDATE oe_credits_iface_all
SET request_id = l_request_id,
sold_to_org_id = nvl(sold_to_org_id, l_sold_to_org_id),
sold_to_org = nvl(sold_to_org, l_sold_to_org),
org_id = l_org_id
WHERE order_source_id = l_order_source_id
AND orig_sys_document_ref = l_orig_sys_document_ref
AND nvl(change_sequence, ' ') = nvl(l_change_sequence, ' ')
AND nvl(org_id,l_org_id) = l_org_id ;
UPDATE oe_reservtns_iface_all
SET request_id = l_request_id,
sold_to_org_id = nvl(sold_to_org_id, l_sold_to_org_id),
sold_to_org = nvl(sold_to_org, l_sold_to_org),
org_id = l_org_id
WHERE order_source_id = l_order_source_id
AND orig_sys_document_ref = l_orig_sys_document_ref
AND nvl(change_sequence, ' ') = nvl(l_change_sequence, ' ')
AND nvl(org_id,l_org_id) = l_org_id ;
UPDATE oe_lotserials_iface_all
SET request_id = l_request_id,
sold_to_org_id = nvl(sold_to_org_id, l_sold_to_org_id),
sold_to_org = nvl(sold_to_org, l_sold_to_org),
org_id = l_org_id
WHERE order_source_id = l_order_source_id
AND orig_sys_document_ref = l_orig_sys_document_ref
AND nvl(change_sequence, ' ') = nvl(l_change_sequence, ' ')
AND nvl(org_id,l_org_id) = l_org_id ;
UPDATE oe_actions_iface_all
SET request_id = l_request_id,
sold_to_org_id = nvl(sold_to_org_id, l_sold_to_org_id),
sold_to_org = nvl(sold_to_org, l_sold_to_org),
org_id = l_org_id
WHERE order_source_id = l_order_source_id
AND orig_sys_document_ref = l_orig_sys_document_ref
AND nvl(change_sequence, ' ') = nvl(l_change_sequence, ' ')
AND nvl(org_id,l_org_id) = l_org_id ;
select rowidtochar(rowid)
into l_rowid
from oe_headers_iface_all --MOAC
where request_id = l_pnt_request_id
and rownum = 1;
UPDATE oe_headers_iface_all --MOAC
SET request_id = l_request_id
WHERE request_id = l_pnt_request_id
AND nvl(error_flag,'N') = 'N'
AND rowidtochar(rowid) = l_rowid
AND rownum = 1
RETURNING orig_sys_document_ref
INTO l_updated_docref;
oe_debug_pub.add('rowcount:' || sql%rowcount || ' updated docref:' || l_updated_docref);
oe_debug_pub.add('others exception when attempting update' ||sqlerrm);
/* SELECT count(*) INTO l_count_msgs
FROM oe_processing_msgs_vl
WHERE request_id = l_request_id;
SELECT closed_flag
INTO l_closed_flag
FROM oe_headers_iface_all
WHERE orig_sys_document_ref = p_orig_sys_document_ref
AND order_source_id = p_order_source_id
AND nvl(sold_to_org_id, -999) = nvl(p_sold_to_org_id, -999)
AND nvl(sold_to_org, ' ') = nvl(p_sold_to_org, ' ')
AND nvl(change_sequence, ' ') = nvl(p_change_sequence, ' ')
AND nvl(org_id,-99) = nvl(p_org_id,-99)
AND nvl(request_id, -999) = nvl(p_request_id, -999);