The following lines contain the word 'select', 'insert', 'update' or 'delete':
p_update_date_from IN DATE,
p_update_date_to IN DATE,
p_message_status_code IN VARCHAR2
)
IS
l_place_holder_table Elec_Msgs_Summary_Tbl;
l_update_date_from DATE;
l_update_date_to DATE;
select x.order_source_id,
x.orig_sys_document_ref,
x.sold_to_org_id,
decode(nvl(max(x.order_number), 0), 0, NULL, max(x.order_number)),
max(order_type_id),
count(*),
min(x.creation_date),
max(x.last_update_date),
'x',
x.org_id
from oe_em_information x
where x.order_source_id = p_order_source_id
and (x.orig_sys_document_ref = p_orig_sys_document_ref or p_orig_sys_document_ref IS NULL)
and x.sold_to_org_id = p_sold_to_org_id
and (x.em_transaction_type_code = p_transaction_type or p_transaction_type IS NULL)
group by x.order_source_id, x.orig_sys_document_ref, x.sold_to_org_id, x.org_id
having min(x.creation_date) between nvl(l_start_date_from, min(x.creation_date)) and nvl(l_start_date_to, min(x.creation_date))
and max(x.last_update_date) between nvl(l_update_date_from, max(x.last_update_date)) and nvl(l_update_date_to, max(x.last_update_date))
order by x.org_id, x.order_source_id, x.sold_to_org_id;
select x.order_source_id,
x.orig_sys_document_ref,
x.sold_to_org_id,
decode(nvl(max(x.order_number), 0), 0, NULL, max(x.order_number)),
max(order_type_id),
count(*),
min(x.creation_date),
max(x.last_update_date),
'x',
x.org_id
from oe_em_information x
where x.order_source_id = p_order_source_id
and (x.orig_sys_document_ref = p_orig_sys_document_ref or p_orig_sys_document_ref IS NULL)
and (x.sold_to_org_id = p_sold_to_org_id or p_sold_to_org_id IS NULL)
and (x.em_transaction_type_code = p_transaction_type or p_transaction_type IS NULL)
group by x.order_source_id, x.orig_sys_document_ref, x.sold_to_org_id, x.org_id
having min(x.creation_date) between nvl(l_start_date_from, min(x.creation_date)) and nvl(l_start_date_to, min(x.creation_date))
and max(x.last_update_date) between nvl(l_update_date_from, max(x.last_update_date)) and nvl(l_update_date_to, max(x.last_update_date))
order by x.org_id, x.order_source_id, x.sold_to_org_id;
select x.order_source_id,
x.orig_sys_document_ref,
x.sold_to_org_id,
decode(nvl(max(x.order_number), 0), 0, NULL, max(x.order_number)),
max(order_type_id),
count(*),
min(x.creation_date),
max(x.last_update_date),
'x',
x.org_id
from oe_em_information x
where x.order_source_id between l_min_order_source_id and l_max_order_source_id
and (x.orig_sys_document_ref = p_orig_sys_document_ref or p_orig_sys_document_ref IS NULL)
and x.sold_to_org_id = p_sold_to_org_id
and (x.em_transaction_type_code = p_transaction_type or p_transaction_type IS NULL)
group by x.order_source_id, x.orig_sys_document_ref, x.sold_to_org_id, x.org_id
having min(x.creation_date) between nvl(l_start_date_from, min(x.creation_date)) and nvl(l_start_date_to, min(x.creation_date))
and max(x.last_update_date) between nvl(l_update_date_from, max(x.last_update_date)) and nvl(l_update_date_to, max(x.last_update_date))
order by x.org_id, x.order_source_id, x.sold_to_org_id;
select x.order_source_id,
x.orig_sys_document_ref,
x.sold_to_org_id,
decode(nvl(max(x.order_number), 0), 0, NULL, max(x.order_number)),
max(order_type_id),
count(*),
min(x.creation_date),
max(x.last_update_date),
'x',
x.org_id
from oe_em_information x
where x.order_source_id between l_min_order_source_id and l_max_order_source_id
and (x.orig_sys_document_ref = p_orig_sys_document_ref or p_orig_sys_document_ref IS NULL)
and (x.sold_to_org_id = p_sold_to_org_id or p_sold_to_org_id IS NULL)
and (x.em_transaction_type_code = p_transaction_type or p_transaction_type IS NULL)
group by x.order_source_id, x.orig_sys_document_ref, x.sold_to_org_id, x.org_id
having min(x.creation_date) between nvl(l_start_date_from, min(x.creation_date)) and nvl(l_start_date_to, min(x.creation_date))
and max(x.last_update_date) between nvl(l_update_date_from, max(x.last_update_date)) and nvl(l_update_date_to, max(x.last_update_date))
order by x.org_id, x.order_source_id, x.sold_to_org_id;
select x.order_source_id,
x.orig_sys_document_ref,
x.sold_to_org_id,
decode(nvl(max(x.order_number), 0), 0, NULL, max(x.order_number)),
max(order_type_id),
count(*),
min(x.creation_date),
max(x.last_update_date),
'x',
x.org_id
from oe_em_information x
where x.order_source_id = p_order_source_id
and (x.orig_sys_document_ref = p_orig_sys_document_ref or p_orig_sys_document_ref IS NULL)
and x.sold_to_org_id = p_sold_to_org_id
and (x.em_transaction_type_code = p_transaction_type or p_transaction_type IS NULL)
and exists (select 1 from oe_processing_msgs msg
where msg.order_source_id = x.order_source_id
and msg.original_sys_document_ref = x.orig_sys_document_ref
and ((msg.entity_code like 'ELECMSG%' and msg.entity_id = to_number(x.item_key)) or x.em_conc_request_id = msg.request_id)
and msg.message_status_code = p_message_status_code)
group by x.order_source_id, x.orig_sys_document_ref, x.sold_to_org_id, x.org_id
having min(x.creation_date) between nvl(l_start_date_from, min(x.creation_date)) and nvl(l_start_date_to, min(x.creation_date))
and max(x.last_update_date) between nvl(l_update_date_from, max(x.last_update_date)) and nvl(l_update_date_to, max(x.last_update_date))
order by x.org_id, x.order_source_id, x.sold_to_org_id;
select x.order_source_id,
x.orig_sys_document_ref,
x.sold_to_org_id,
decode(nvl(max(x.order_number), 0), 0, NULL, max(x.order_number)),
max(order_type_id),
count(*),
min(x.creation_date),
max(x.last_update_date),
'x',
x.org_id
from oe_em_information x
where x.order_source_id = p_order_source_id
and (x.orig_sys_document_ref = p_orig_sys_document_ref or p_orig_sys_document_ref IS NULL)
and (x.sold_to_org_id = p_sold_to_org_id or p_sold_to_org_id IS NULL)
and (x.em_transaction_type_code = p_transaction_type or p_transaction_type IS NULL)
and exists (select 1 from oe_processing_msgs msg
where msg.order_source_id = x.order_source_id
and msg.original_sys_document_ref = x.orig_sys_document_ref
and ((msg.entity_code like 'ELECMSG%' and msg.entity_id = to_number(x.item_key)) or x.em_conc_request_id = msg.request_id)
and msg.message_status_code = p_message_status_code)
group by x.order_source_id, x.orig_sys_document_ref, x.sold_to_org_id, x.org_id
having min(x.creation_date) between nvl(l_start_date_from, min(x.creation_date)) and nvl(l_start_date_to, min(x.creation_date))
and max(x.last_update_date) between nvl(l_update_date_from, max(x.last_update_date)) and nvl(l_update_date_to, max(x.last_update_date))
order by x.org_id, x.order_source_id, x.sold_to_org_id;
select x.order_source_id,
x.orig_sys_document_ref,
x.sold_to_org_id,
decode(nvl(max(x.order_number), 0), 0, NULL, max(x.order_number)),
max(order_type_id),
count(*),
min(x.creation_date),
max(x.last_update_date),
'x',
x.org_id
from oe_em_information x
where x.order_source_id between l_min_order_source_id and l_max_order_source_id
and (x.orig_sys_document_ref = p_orig_sys_document_ref or p_orig_sys_document_ref IS NULL)
and x.sold_to_org_id = p_sold_to_org_id
and (x.em_transaction_type_code = p_transaction_type or p_transaction_type IS NULL)
and exists (select 1 from oe_processing_msgs msg
where msg.order_source_id = x.order_source_id
and msg.original_sys_document_ref = x.orig_sys_document_ref
and ((msg.entity_code like 'ELECMSG%' and msg.entity_id = to_number(x.item_key)) or x.em_conc_request_id = msg.request_id)
and msg.message_status_code = p_message_status_code)
group by x.order_source_id, x.orig_sys_document_ref, x.sold_to_org_id, x.org_id
having min(x.creation_date) between nvl(l_start_date_from, min(x.creation_date)) and nvl(l_start_date_to, min(x.creation_date))
and max(x.last_update_date) between nvl(l_update_date_from, max(x.last_update_date)) and nvl(l_update_date_to, max(x.last_update_date))
order by x.org_id, x.order_source_id, x.sold_to_org_id;
select x.order_source_id,
x.orig_sys_document_ref,
x.sold_to_org_id,
decode(nvl(max(x.order_number), 0), 0, NULL, max(x.order_number)),
max(order_type_id),
count(*),
min(x.creation_date),
max(x.last_update_date),
'x',
x.org_id
from oe_em_information x
where x.order_source_id between l_min_order_source_id and l_max_order_source_id
and (x.orig_sys_document_ref = p_orig_sys_document_ref or p_orig_sys_document_ref IS NULL)
and (x.sold_to_org_id = p_sold_to_org_id or p_sold_to_org_id IS NULL)
and (x.em_transaction_type_code = p_transaction_type or p_transaction_type IS NULL)
and exists (select 1 from oe_processing_msgs msg
where msg.order_source_id = x.order_source_id
and msg.original_sys_document_ref = x.orig_sys_document_ref
and ((msg.entity_code like 'ELECMSG%' and msg.entity_id = to_number(x.item_key)) or x.em_conc_request_id = msg.request_id)
and msg.message_status_code = p_message_status_code)
group by x.order_source_id, x.orig_sys_document_ref, x.sold_to_org_id, x.org_id
having min(x.creation_date) between nvl(l_start_date_from, min(x.creation_date)) and nvl(l_start_date_to, min(x.creation_date))
and max(x.last_update_date) between nvl(l_update_date_from, max(x.last_update_date)) and nvl(l_update_date_to, max(x.last_update_date))
order by x.org_id, x.order_source_id, x.sold_to_org_id;
SELECT em_transaction_type_code, message_text, document_status
FROM oe_em_information
WHERE order_source_id = p_elec_msgs_tbl(j).order_source_id
AND orig_sys_document_ref = p_elec_msgs_tbl(j).orig_sys_document_ref
AND sold_to_org_id = p_elec_msgs_tbl(j).sold_to_org_id
AND org_id = p_elec_msgs_tbl(j).org_id
ORDER BY creation_date desc;
l_update_date_from := to_date(to_char(trunc(p_update_date_from), DT_mask),DT_mask);
l_update_date_to := to_date(to_char(p_update_date_to+(1-1/(24*60*60)), DT_mask),DT_mask);
SELECT max(order_source_id), min(order_source_id)
INTO l_max_order_source_id, l_min_order_source_id
FROM OE_Order_Sources;
l_results_rec.last_update_date,
l_results_rec.last_transaction_type,
l_results_rec.org_id;
l_results_rec.last_update_date,
l_results_rec.last_transaction_type,
l_results_rec.org_id;
l_results_rec.last_update_date,
l_results_rec.last_transaction_type,
l_results_rec.org_id;
l_results_rec.last_update_date,
l_results_rec.last_transaction_type,
l_results_rec.org_id;
l_results_rec.last_update_date,
l_results_rec.last_transaction_type,
l_results_rec.org_id;
l_results_rec.last_update_date,
l_results_rec.last_transaction_type,
l_results_rec.org_id;
l_results_rec.last_update_date,
l_results_rec.last_transaction_type,
l_results_rec.org_id;
l_results_rec.last_update_date,
l_results_rec.last_transaction_type,
l_results_rec.org_id;
SELECT decode(nvl(max(order_number), 0), 0, NULL, max(order_number)),max (order_type_id), count(*), min(creation_Date), max(last_update_Date)
INTO p_elec_msgs_tbl(n).order_number,p_elec_msgs_tbl(n).order_type_id, p_elec_msgs_tbl(n).num_msgs, p_elec_msgs_tbl(n).creation_date, p_elec_msgs_tbl(n).last_update_date
FROM oe_em_information
WHERE order_source_id = p_elec_msgs_tbl(n).order_source_id
AND orig_sys_document_ref = p_elec_msgs_tbl(n).orig_sys_document_ref
AND sold_to_org_id = p_elec_msgs_tbl(n).sold_to_org_id
AND org_id = p_elec_msgs_tbl(n).org_id;
p_last_update_itemkey IN VARCHAR2,
x_return_status OUT NOCOPY VARCHAR2)
IS
l_debug_level CONSTANT NUMBER := oe_debug_pub.g_debug_level;
/* Insertion -- what should the behaviour be if org_id is null */
INSERT INTO Oe_Em_Information (
order_source_id,
orig_sys_document_ref,
sold_to_org_id,
em_transaction_type_code,
document_id,
parent_document_id,
org_id,
change_sequence,
item_type,
item_key,
order_number,
order_type_id,
document_status,
message_text,
em_conc_request_id,
created_by,
creation_date,
last_update_login,
last_updated_by,
last_update_date,
header_id,
document_disposition,
last_update_itemkey)
VALUES (
p_order_source_id,
p_orig_sys_document_ref,
p_sold_to_org_id,
p_transaction_type,
p_document_id,
p_parent_document_id,
p_org_id,
p_change_sequence,
p_itemtype,
p_itemkey,
p_order_number,
p_order_type_id,
p_status,
p_message_text,
p_request_id,
FND_GLOBAL.USER_ID,
SYSDATE,
FND_GLOBAL.LOGIN_ID,
FND_GLOBAL.USER_ID,
SYSDATE,
p_header_id,
p_document_disposition,
p_last_update_itemkey
);
oe_debug_pub.add('Insert succeeded'||SQL%ROWCOUNT||' de'||SQLERRM);
oe_debug_pub.add('DUPLICATE INDEX VALUE IN OEXVELMB.Create History Entry, update instead of insert'||SQLERRM);
PROCEDURE Update_History_Entry (
p_order_source_id IN NUMBER,
p_sold_to_org_id IN NUMBER,
p_orig_sys_document_ref IN VARCHAR2,
p_transaction_type IN VARCHAR2,
p_document_id IN NUMBER,
p_parent_document_id IN NUMBER,
p_org_id IN NUMBER,
p_change_sequence IN VARCHAR2,
p_itemtype IN VARCHAR2,
p_itemkey IN VARCHAR2,
p_order_number IN NUMBER,
p_order_type_id IN NUMBER,
p_status IN VARCHAR2,
p_message_text IN VARCHAR2,
p_request_id IN NUMBER,
p_header_id IN NUMBER,
p_document_disposition IN VARCHAR2,
p_last_update_itemkey IN VARCHAR2,
x_return_status OUT NOCOPY VARCHAR2)
IS
l_debug_level CONSTANT NUMBER := oe_debug_pub.g_debug_level;
/* Insertion -- what should the behaviour be if org_id is null */
UPDATE Oe_Em_Information Set
item_type = nvl(p_itemtype, item_type),
item_key = nvl(p_itemkey, item_key),
change_sequence = nvl(p_change_sequence, change_sequence),
order_number = nvl(p_order_number, order_number),
document_status = nvl(p_status, document_status),
message_text = nvl(p_message_text, message_text),
em_conc_request_id = nvl(p_request_id, em_conc_request_id),
order_type_id = nvl(p_order_type_id, order_type_id),
last_update_login = FND_GLOBAL.LOGIN_ID,
last_updated_by = FND_GLOBAL.USER_ID,
last_update_date = SYSDATE,
header_id = nvl(p_header_id, header_id),
document_disposition = nvl(p_document_disposition, document_disposition),
last_update_itemkey = nvl(p_last_update_itemkey, last_update_itemkey)
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref = p_orig_sys_document_ref
AND sold_to_org_id = p_sold_to_org_id
AND em_transaction_type_code = p_transaction_type
AND document_id = p_document_id;
oe_debug_pub.add('Number of rows updated: ' || SQL%ROWCOUNT);
oe_debug_pub.add('OTHERS IN OEXVELMB.Update History Entry');
END Update_History_Entry;
SELECT order_source_id, last_update_itemkey, em_conc_request_id
INTO l_dummy, l_last_itemkey, l_last_request_id
FROM oe_em_information
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref = p_orig_sys_document_ref
AND sold_to_org_id = p_sold_to_org_id
AND em_transaction_type_code = p_transaction_type
AND document_id = p_document_id
FOR UPDATE;
/* SELECT document_id
INTO l_document_id
FROM oe_em_information
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref = p_orig_sys_document_ref
AND sold_to_org_id = p_sold_to_org_id
AND em_transaction_type_code = 'CSO'
AND rownum = 1
ORDER BY 1 DESC;
SELECT max(document_id)
INTO l_document_id
FROM oe_em_information
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref = p_orig_sys_document_ref
AND sold_to_org_id = p_sold_to_org_id
AND em_transaction_type_code = 'CSO'
AND org_id = p_org_id;
PROCEDURE OEEM_SELECTOR
( p_itemtype in varchar2,
p_itemkey in varchar2,
p_actid in number,
p_funcmode in varchar2,
p_x_result in out NOCOPY /* file.sql.39 change */ varchar2
)
IS
l_user_id NUMBER;
oe_debug_pub.add( 'ENTERING OEEM_SELECTOR PROCEDURE' ) ;
WF_CORE.Context('OE_ELEC_MSGS_WF', 'OEEM_SELECTOR',
p_itemtype, p_itemkey, p_actid, p_funcmode);
END OEEM_SELECTOR;
PROCEDURE Create_Or_Update_Hist_WF (
p_itemtype IN VARCHAR2,
p_itemkey IN VARCHAR2,
p_actid IN NUMBER,
p_funcmode IN VARCHAR2,
p_x_result IN OUT NOCOPY /* file.sql.39 change */ VARCHAR2)
IS
l_order_source_id NUMBER;
p_last_update_itemkey => l_curr_itemkey,
x_return_status => l_result
);
OE_ELECMSGS_PVT.Update_History_Entry (
p_order_source_id => l_order_source_id,
p_sold_to_org_id => l_sold_to_org_id,
p_orig_sys_document_ref => l_orig_sys_document_ref,
p_transaction_type => l_transaction_type,
p_document_id => l_document_id,
-- p_parent_document_id => l_parent_document_id,
p_change_sequence => l_change_sequence,
p_order_number => l_order_number,
p_order_type_id => l_order_type_id,
p_itemtype => l_wf_itemtype,
p_itemkey => l_wf_itemkey,
p_org_id => l_org_id,
p_status => l_status,
p_message_text => l_message_text,
p_request_id => l_request_id,
p_header_id => l_header_id,
p_document_disposition => l_document_disposition,
p_last_update_itemkey => l_curr_itemkey,
x_return_status => l_result
);
wf_core.context('OE_Elecmsgs_Pvt', 'Create_Or_Update_Hist_WF',
p_itemtype, p_itemkey, to_char(p_actid), p_funcmode);
oe_debug_pub.add('OTHERS in Create_Or_Update_Hist_WF ' || SQLERRM );
OE_MSG_PUB.Add_Exc_Msg ( G_PKG_NAME, 'Create_Or_Update_Hist_Wf');
END Create_Or_Update_Hist_WF;
SELECT max(order_source_id), min(order_source_id)
INTO l_max_order_source_id, l_min_order_source_id
FROM OE_Order_Sources;
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.orig_sys_customer_ref
FROM OE_Headers_Interface h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.orig_sys_customer_ref IS NOT NULL)
AND c.customer_info_type_code = 'ACCOUNT';
oe_debug_pub.add('Deleted '|| l_cust_rows || ' records for customer ref with org_id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.orig_sys_customer_ref
FROM OE_Headers_Iface_All h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.orig_sys_customer_ref IS NOT NULL
AND h.org_id IS NULL)
AND c.customer_info_type_code = 'ACCOUNT';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.sold_to_contact_ref
FROM OE_Headers_Interface h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.sold_to_contact_ref IS NOT NULL)
AND c.customer_info_type_code = 'CONTACT';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records for sold to contact with org id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.sold_to_contact_ref
FROM OE_Headers_Iface_All h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.sold_to_contact_ref IS NOT NULL
AND h.org_id IS NULL)
AND c.customer_info_type_code = 'CONTACT';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.bill_to_contact_ref
FROM OE_Headers_Interface h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.bill_to_contact_ref IS NOT NULL)
AND c.customer_info_type_code = 'CONTACT';
oe_debug_pub.add('Deleted '|| l_cust_rows || ' records for bill to contact ref with org id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.bill_to_contact_ref
FROM OE_Headers_Iface_All h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.bill_to_contact_ref IS NOT NULL
AND h.org_id IS NULL)
AND c.customer_info_type_code = 'CONTACT';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.ship_to_contact_ref
FROM OE_Headers_Interface h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.ship_to_contact_ref IS NOT NULL)
AND c.customer_info_type_code = 'CONTACT';
oe_debug_pub.add('Deleted '|| l_cust_rows || ' records for ship to contact ref with org id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.ship_to_contact_ref
FROM OE_Headers_Iface_All h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.ship_to_contact_ref IS NOT NULL
AND h.org_id IS NULL)
AND c.customer_info_type_code = 'CONTACT';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.deliver_to_contact_ref
FROM OE_Headers_Interface h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.deliver_to_contact_ref IS NOT NULL)
AND c.customer_info_type_code = 'CONTACT';
oe_debug_pub.add('Deleted '|| l_cust_rows || ' records for deliver to contact ref with org id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.deliver_to_contact_ref
FROM OE_Headers_Iface_All h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.deliver_to_contact_ref IS NOT NULL
AND h.org_id IS NULL)
AND c.customer_info_type_code = 'CONTACT';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.orig_ship_address_ref
FROM OE_Headers_Interface h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.orig_ship_address_ref IS NOT NULL)
AND c.customer_info_type_code = 'ADDRESS';
oe_debug_pub.add('Deleted '|| l_cust_rows || ' records for ship address ref with org id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.orig_ship_address_ref
FROM OE_Headers_Iface_All h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.orig_ship_address_ref IS NOT NULL
AND h.org_id IS NULL)
AND c.customer_info_type_code = 'ADDRESS';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.orig_bill_address_ref
FROM OE_Headers_Interface h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.orig_bill_address_ref IS NOT NULL)
AND c.customer_info_type_code = 'ADDRESS';
oe_debug_pub.add('Deleted '|| l_cust_rows || ' records for bill address ref with org id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.orig_bill_address_ref
FROM OE_Headers_Iface_All h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.orig_bill_address_ref IS NOT NULL
AND h.org_id IS NULL)
AND c.customer_info_type_code = 'ADDRESS';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.orig_deliver_address_ref
FROM OE_Headers_Interface h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.orig_deliver_address_ref IS NOT NULL)
AND c.customer_info_type_code = 'ADDRESS';
oe_debug_pub.add('Deleted '|| l_cust_rows || ' records for deliver address ref with org id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.orig_deliver_address_ref
FROM OE_Headers_Iface_All h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.orig_deliver_address_ref IS NOT NULL
AND h.org_id IS NULL)
AND c.customer_info_type_code = 'ADDRESS';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_cust_rows || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Customer Info Interface (Header): '|| l_cust_rows);
DELETE
FROM OE_Headers_Interface
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Headers_Iface_All
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Headers_Interface
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Headers_Iface_All
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Headers Interface: '|| l_count);
DELETE
FROM OE_Actions_Interface
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Actions_Iface_All
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Actions_Interface
WHERE order_source_id BETWEEN l_min_order_source_id AND l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Actions_Iface_All
WHERE order_source_id BETWEEN l_min_order_source_id AND l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(SQL%ROWCOUNT || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Actions Interface (Header): '|| l_count);
DELETE
FROM OE_Credits_Interface
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Credits_Iface_All
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Credits_Interface
WHERE order_source_id BETWEEN l_min_order_source_id AND l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Credits_Iface_All
WHERE order_source_id BETWEEN l_min_order_source_id AND l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Credits Interface (Header): '|| l_count);
DELETE
FROM OE_Price_Adjs_Interface
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Price_Adjs_Iface_All
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Price_Adjs_Interface
WHERE order_source_id BETWEEN l_min_order_source_id AND l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Price_Adjs_Iface_All
WHERE order_source_id BETWEEN l_min_order_source_id AND l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Price Adjustments Interface (Header): '|| l_count);
DELETE
FROM OE_Price_Atts_Interface
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Price_Atts_Iface_All
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Price_Atts_Interface
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Price_Atts_Iface_All
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Pricing Attributes Interface (Header): '|| l_count);
DELETE
FROM OE_Payments_Interface
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Payments_Iface_All
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Payments_Interface
WHERE order_source_id BETWEEN l_min_order_source_id AND l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Payments_Iface_All
WHERE order_source_id BETWEEN l_min_order_source_id AND l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Payments Interface (Header): '|| l_count);
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.bill_to_contact_ref
FROM OE_Lines_Interface h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.bill_to_contact_ref IS NOT NULL)
AND c.customer_info_type_code = 'CONTACT';
oe_debug_pub.add('Deleted '|| l_cust_rows || ' records for bill to contact ref with org id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.bill_to_contact_ref
FROM OE_Lines_Iface_All h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.bill_to_contact_ref IS NOT NULL
AND h.org_id IS NULL)
AND c.customer_info_type_code = 'CONTACT';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.ship_to_contact_ref
FROM OE_Lines_Interface h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.ship_to_contact_ref IS NOT NULL)
AND c.customer_info_type_code = 'CONTACT';
oe_debug_pub.add('Deleted '|| l_cust_rows || ' records for ship to contact ref with org id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.ship_to_contact_ref
FROM OE_Lines_Iface_All h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.ship_to_contact_ref IS NOT NULL
AND h.org_id IS NULL)
AND c.customer_info_type_code = 'CONTACT';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.deliver_to_contact_ref
FROM OE_Lines_Interface h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.deliver_to_contact_ref IS NOT NULL)
AND c.customer_info_type_code = 'CONTACT';
oe_debug_pub.add('Deleted '|| l_cust_rows || ' records for deliver to contact ref with org id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.deliver_to_contact_ref
FROM OE_Lines_Iface_All h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.deliver_to_contact_ref IS NOT NULL
AND h.org_id IS NULL)
AND c.customer_info_type_code = 'CONTACT';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.orig_ship_address_ref
FROM OE_Lines_Interface h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.orig_ship_address_ref IS NOT NULL)
AND c.customer_info_type_code = 'ADDRESS';
oe_debug_pub.add('Deleted '|| l_cust_rows || ' records for ship to address ref with org id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.orig_ship_address_ref
FROM OE_Lines_Iface_All h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.orig_ship_address_ref IS NOT NULL
AND h.org_id IS NULL)
AND c.customer_info_type_code = 'ADDRESS';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.orig_bill_address_ref
FROM OE_Lines_Interface h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.orig_bill_address_ref IS NOT NULL)
AND c.customer_info_type_code = 'ADDRESS';
oe_debug_pub.add('Deleted '|| l_cust_rows || ' records for bill to address ref with org id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.orig_bill_address_ref
FROM OE_Lines_Iface_All h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.orig_bill_address_ref IS NOT NULL
AND h.org_id IS NULL)
AND c.customer_info_type_code = 'ADDRESS';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.orig_deliver_address_ref
FROM OE_Lines_Interface h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.orig_deliver_address_ref IS NOT NULL)
AND c.customer_info_type_code = 'ADDRESS';
oe_debug_pub.add('Deleted '|| l_cust_rows || ' records for deliver address ref with org id');
DELETE
FROM OE_Customer_Info_Iface_All c
WHERE c.customer_info_ref IN (SELECT h.orig_deliver_address_ref
FROM OE_Lines_Iface_All h
WHERE order_source_id between l_c_min_ord_src and l_c_max_ord_src
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND h.orig_deliver_address_ref IS NOT NULL
AND h.org_id IS NULL)
AND c.customer_info_type_code = 'ADDRESS';
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_cust_rows || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Customer Info Interface (Line): '|| l_cust_rows);
DELETE
FROM OE_Lines_Interface
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Lines_Iface_All
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Lines_Interface
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Lines_Iface_All
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Lines Interface: '|| l_count);
DELETE
FROM OE_Actions_Interface
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Actions_Iface_All
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Actions_Interface
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Actions_Iface_All
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Actions Interface (Line): '|| l_count);
DELETE
FROM OE_Credits_Interface
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Credits_Iface_All
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Credits_Interface
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Credits_Iface_All
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Credits Interface (Line): '|| l_count);
DELETE
FROM OE_LotSerials_Interface
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_LotSerials_Iface_All
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_LotSerials_Interface
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_LotSerials_Iface_All
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Lotserials Interface (Line): '|| l_count );
DELETE
FROM OE_Price_Adjs_Interface
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Price_Adjs_Iface_All
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Price_Adjs_Interface
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Price_Adjs_Iface_All
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Price Adjustments Interface (Line): '|| l_count );
DELETE
FROM OE_Price_Atts_Interface
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Price_Atts_Iface_All
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Price_Atts_Interface
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Price_Atts_Iface_All
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Pricing Attributes Interface (Line): '|| l_count );
DELETE
FROM OE_Reservtns_Interface
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Reservtns_Iface_All
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Reservtns_Interface
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Reservtns_Iface_All
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Reservations Interface (Line): '|| l_count );
DELETE
FROM OE_Payments_Interface
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Payments_Iface_All
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
DELETE
FROM OE_Payments_Interface
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org);
DELETE
FROM OE_Payments_Iface_All
WHERE order_source_id BETWEEN l_min_order_source_id and l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND orig_sys_line_ref IS NOT NULL
AND (l_sold_to_org_id IS NULL
OR l_sold_to_org_id = sold_to_org_id
OR l_sold_to_org = sold_to_org)
AND org_id IS NULL;
oe_debug_pub.add('Deleted '|| SQL%ROWCOUNT || ' records with NULL Org Id');
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Payments Interface (Line): '|| l_count );
DELETE
FROM OE_Header_Acks
WHERE order_source_id = nvl(p_order_source_id, order_source_id)
AND orig_sys_document_ref BETWEEN p_orig_sys_document_ref_from
AND p_orig_sys_document_ref_to
AND sold_to_org_id = nvl(l_sold_to_org_id, sold_to_org_id)
AND nvl(acknowledgment_flag, 'N') = 'Y'
AND ((p_operating_unit IS NULL AND MO_GLOBAL.Check_Access (org_id) = l_yes) OR org_id = p_operating_unit);
DELETE
FROM OE_Header_Acks
WHERE order_source_id = nvl(p_order_source_id, order_source_id)
AND orig_sys_document_ref >= p_orig_sys_document_ref_from
AND sold_to_org_id = nvl(l_sold_to_org_id, sold_to_org_id)
AND nvl(acknowledgment_flag, 'N') = 'Y'
AND ((p_operating_unit IS NULL AND MO_GLOBAL.Check_Access (org_id) = l_yes) OR org_id = p_operating_unit);
DELETE
FROM OE_Header_Acks
WHERE order_source_id = nvl(p_order_source_id, order_source_id)
AND orig_sys_document_ref <= p_orig_sys_document_ref_to
AND sold_to_org_id = nvl(l_sold_to_org_id, sold_to_org_id)
AND nvl(acknowledgment_flag, 'N') = 'Y'
AND ((p_operating_unit IS NULL AND MO_GLOBAL.Check_Access (org_id) = l_yes) OR org_id = p_operating_unit);
DELETE
FROM OE_Header_Acks
WHERE order_source_id = nvl(p_order_source_id, order_source_id)
AND orig_sys_document_ref >= ' '
AND sold_to_org_id = nvl(l_sold_to_org_id, sold_to_org_id)
AND nvl(acknowledgment_flag, 'N') = 'Y'
AND ((p_operating_unit IS NULL AND MO_GLOBAL.Check_Access (org_id) = l_yes) OR org_id = p_operating_unit);
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Header Acknowledgments: '|| l_count );
DELETE
FROM OE_Line_Acks
WHERE order_source_id = nvl(p_order_source_id, order_source_id)
AND orig_sys_document_ref BETWEEN p_orig_sys_document_ref_from
AND p_orig_sys_document_ref_to
AND sold_to_org_id = nvl(l_sold_to_org_id, sold_to_org_id)
AND nvl(acknowledgment_flag, 'N') = 'Y'
AND ((p_operating_unit IS NULL AND MO_GLOBAL.Check_Access (org_id) = l_yes) OR org_id = p_operating_unit);
DELETE
FROM OE_Line_Acks
WHERE order_source_id = nvl(p_order_source_id, order_source_id)
AND orig_sys_document_ref >= p_orig_sys_document_ref_from
AND sold_to_org_id = nvl(l_sold_to_org_id, sold_to_org_id)
AND nvl(acknowledgment_flag, 'N') = 'Y'
AND ((p_operating_unit IS NULL AND MO_GLOBAL.Check_Access (org_id) = l_yes) OR org_id = p_operating_unit);
DELETE
FROM OE_Line_Acks
WHERE order_source_id = nvl(p_order_source_id, order_source_id)
AND orig_sys_document_ref <= p_orig_sys_document_ref_to
AND sold_to_org_id = nvl(l_sold_to_org_id, sold_to_org_id)
AND nvl(acknowledgment_flag, 'N') = 'Y'
AND ((p_operating_unit IS NULL AND MO_GLOBAL.Check_Access (org_id) = l_yes) OR org_id = p_operating_unit);
DELETE
FROM OE_Line_Acks
WHERE order_source_id = nvl(p_order_source_id, order_source_id)
AND orig_sys_document_ref >= ' '
AND sold_to_org_id = nvl(l_sold_to_org_id, sold_to_org_id)
AND nvl(acknowledgment_flag, 'N') = 'Y'
AND ((p_operating_unit IS NULL AND MO_GLOBAL.Check_Access (org_id) = l_yes) OR org_id = p_operating_unit);
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Line Acknowledgments: '|| l_count);
DELETE
FROM OE_EM_Information
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND sold_to_org_id = l_sold_to_org_id;
DELETE
FROM OE_EM_Information
WHERE order_source_id = p_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND sold_to_org_id = nvl(l_sold_to_org_id,sold_to_org_id);
DELETE
FROM OE_EM_Information
WHERE order_source_id BETWEEN l_min_order_source_id AND l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND sold_to_org_id = l_sold_to_org_id;
DELETE
FROM OE_EM_Information
WHERE order_source_id BETWEEN l_min_order_source_id AND l_max_order_source_id
AND orig_sys_document_ref BETWEEN nvl(p_orig_sys_document_ref_from, orig_sys_document_ref)
AND nvl(p_orig_sys_document_ref_to, orig_sys_document_ref)
AND sold_to_org_id = nvl(l_sold_to_org_id,sold_to_org_id);
oe_debug_pub.add(l_count || ' rows deleted');
fnd_file.put_line(FND_FILE.OUTPUT, 'Rows Deleted from Open Interface Tracking table: '|| l_count);