[Home] [Help]
The following lines contain the word 'select', 'insert', 'update' or 'delete':
dbi_header_update_date_tab date_bin_table := date_bin_table();
dbi_line_update_date_tab date_bin_table := date_bin_table();
PROCEDURE Oe_Update_DBI_log;
select duplicate_id, customer_id, duplicate_site_id, customer_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
SELECT /*+ PARALLEL (H) PARALLEL (M1) PARALLEL(M2)
PARALLEL (M3) PARALLEL (M4) PARALLEL (M5)
PARALLEL (M6) PARALLEL (M7) */
H.HEADER_ID , H.LAST_UPDATE_DATE, H.HEADER_ID, H.SOLD_TO_ORG_ID,
H.INVOICE_TO_ORG_ID, H.SHIP_TO_ORG_ID, H.DELIVER_TO_ORG_ID,
H.SOLD_TO_SITE_USE_ID, H.END_CUSTOMER_SITE_USE_ID,
H.END_CUSTOMER_ID,
NVL(M1.CUSTOMER_MERGE_ID,NVL(M2.CUSTOMER_MERGE_ID,NVL(M3.CUSTOMER_MERGE_ID,
NVL(M4.CUSTOMER_MERGE_ID,nvl(M5.CUSTOMER_MERGE_ID,
NVL(M6.CUSTOMER_MERGE_ID,M7.CUSTOMER_MERGE_ID))))))
FROM RA_CUSTOMER_MERGES M1,
RA_CUSTOMER_MERGES M2,
RA_CUSTOMER_MERGES M3,
RA_CUSTOMER_MERGES M4,
RA_CUSTOMER_MERGES M5,
RA_CUSTOMER_MERGES M6,
RA_CUSTOMER_MERGES M7,
OE_ORDER_HEADERS H
WHERE ( H.SOLD_TO_ORG_ID = M1.DUPLICATE_ID(+)
AND H.INVOICE_TO_ORG_ID = M2.DUPLICATE_SITE_ID(+)
AND H.SHIP_TO_ORG_ID = M3.DUPLICATE_SITE_ID(+)
AND H.SOLD_TO_SITE_USE_ID = M4.DUPLICATE_SITE_ID(+)
AND H.DELIVER_TO_ORG_ID = M5.DUPLICATE_SITE_ID(+)
AND H.END_CUSTOMER_SITE_USE_ID = M6.DUPLICATE_SITE_ID(+)
AND H.END_CUSTOMER_ID = M7.DUPLICATE_ID(+) )
AND (M1.DUPLICATE_SITE_ID IS NOT NULL
OR M2.DUPLICATE_ID IS NOT NULL
OR M3.DUPLICATE_ID IS NOT NULL
OR M4.DUPLICATE_ID IS NOT NULL
OR M5.DUPLICATE_ID IS NOT NULL
OR M6.DUPLICATE_ID IS NOT NULL
OR M7.DUPLICATE_SITE_ID IS NOT NULL)
AND M1.PROCESS_FLAG(+) = 'N'
AND M2.PROCESS_FLAG(+) = 'N'
AND M3.PROCESS_FLAG(+) = 'N'
AND M4.PROCESS_FLAG(+) = 'N'
AND M5.PROCESS_FLAG(+) = 'N'
AND M6.PROCESS_FLAG(+) = 'N'
AND M7.PROCESS_FLAG(+) = 'N'
AND M1.REQUEST_ID(+) =req_id
AND M2.REQUEST_ID(+) =req_id
AND M3.REQUEST_ID(+) =req_id
AND M4.REQUEST_ID(+) =req_id
AND M5.REQUEST_ID(+) =req_id
AND M6.REQUEST_ID(+) =req_id
AND M7.REQUEST_ID(+) =req_id
AND M1.SET_NUMBER(+) =set_num
AND M2.SET_NUMBER(+) =set_num
AND M3.SET_NUMBER(+) =set_num
AND M4.SET_NUMBER(+) =set_num
AND M5.SET_NUMBER(+) =set_num
AND M6.SET_NUMBER(+) =set_num
AND M7.SET_NUMBER(+) =set_num
for update nowait;
SELECT /*+ PARALLEL (H) PARALLEL (M1) PARALLEL(M2)
PARALLEL (M3) PARALLEL (M4) PARALLEL (M5)
PARALLEL (M6) PARALLEL (M7) */
H.HEADER_ID , H.LAST_UPDATE_DATE, H.HEADER_ID, H.SOLD_TO_ORG_ID,
H.INVOICE_TO_ORG_ID, H.SHIP_TO_ORG_ID, H.DELIVER_TO_ORG_ID,
H.SOLD_TO_SITE_USE_ID, H.END_CUSTOMER_SITE_USE_ID,
H.END_CUSTOMER_ID,
NVL(M1.CUSTOMER_MERGE_ID,NVL(M2.CUSTOMER_MERGE_ID,NVL(M3.CUSTOMER_MERGE_ID,
NVL(M4.CUSTOMER_MERGE_ID,nvl(M5.CUSTOMER_MERGE_ID,
NVL(M6.CUSTOMER_MERGE_ID,M7.CUSTOMER_MERGE_ID))))))
FROM RA_CUSTOMER_MERGES M1,
RA_CUSTOMER_MERGES M2,
RA_CUSTOMER_MERGES M3,
RA_CUSTOMER_MERGES M4,
RA_CUSTOMER_MERGES M5,
RA_CUSTOMER_MERGES M6,
RA_CUSTOMER_MERGES M7,
OE_ORDER_HEADERS H
WHERE ( H.SOLD_TO_ORG_ID = M1.DUPLICATE_ID(+)
AND H.INVOICE_TO_ORG_ID = M2.DUPLICATE_SITE_ID(+)
AND H.SHIP_TO_ORG_ID = M3.DUPLICATE_SITE_ID(+)
AND H.SOLD_TO_SITE_USE_ID = M4.DUPLICATE_SITE_ID(+)
AND H.DELIVER_TO_ORG_ID = M5.DUPLICATE_SITE_ID(+)
AND H.END_CUSTOMER_SITE_USE_ID = M6.DUPLICATE_SITE_ID(+)
AND H.END_CUSTOMER_ID = M7.DUPLICATE_ID(+) )
AND (M1.DUPLICATE_SITE_ID IS NOT NULL
OR M2.DUPLICATE_ID IS NOT NULL
OR M3.DUPLICATE_ID IS NOT NULL
OR M4.DUPLICATE_ID IS NOT NULL
OR M5.DUPLICATE_ID IS NOT NULL
OR M6.DUPLICATE_ID IS NOT NULL
OR M7.DUPLICATE_SITE_ID IS NOT NULL)
AND M1.PROCESS_FLAG(+) = 'N'
AND M2.PROCESS_FLAG(+) = 'N'
AND M3.PROCESS_FLAG(+) = 'N'
AND M4.PROCESS_FLAG(+) = 'N'
AND M5.PROCESS_FLAG(+) = 'N'
AND M6.PROCESS_FLAG(+) = 'N'
AND M7.PROCESS_FLAG(+) = 'N'
AND M1.REQUEST_ID(+) =req_id
AND M2.REQUEST_ID(+) =req_id
AND M3.REQUEST_ID(+) =req_id
AND M4.REQUEST_ID(+) =req_id
AND M5.REQUEST_ID(+) =req_id
AND M6.REQUEST_ID(+) =req_id
AND M7.REQUEST_ID(+) =req_id
AND M1.SET_NUMBER(+) =set_num
AND M2.SET_NUMBER(+) =set_num
AND M3.SET_NUMBER(+) =set_num
AND M4.SET_NUMBER(+) =set_num
AND M5.SET_NUMBER(+) =set_num
AND M6.SET_NUMBER(+) =set_num
AND M7.SET_NUMBER(+) =set_num;
dbi_local_hdr_update_date_tab date_bin_table := date_bin_table();
dbi_local_hdr_update_date_tab,
dbi_local_hdr_header_id_tab,
hdr_sold_to_org_id_tab,
hdr_invoice_to_org_id_tab,
hdr_ship_to_org_id_tab,
hdr_deliver_to_org_id_tab,
hdr_sold_to_site_use_id_tab,
hdr_end_cust_site_use_id_tab,
hdr_end_cust_id_tab,
MERGE_HEADER_ID_LIST
LIMIT 20000;
arp_message.set_line(' update_date_tab_count for hdr='||dbi_local_hdr_update_date_tab.COUNT);
IF dbi_local_hdr_update_date_tab.COUNT > 0 then
IF dbi_header_update_date_tab.COUNT > 0 then
l_global_count := dbi_header_update_date_tab.COUNT;
dbi_header_update_date_tab.EXTEND(dbi_local_hdr_update_date_tab.COUNT);
dbi_header_header_id_tab.EXTEND(dbi_local_hdr_update_date_tab.COUNT);
dbi_header_update_date_tab(l_global_count + i) := dbi_local_hdr_update_date_tab(i);
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
NUM_COL1_ORIG,
NUM_COL1_NEW,
NUM_COL2_ORIG,
NUM_COL2_NEW,
NUM_COL3_ORIG,
NUM_COL3_NEW,
NUM_COL4_ORIG,
NUM_COL4_NEW,
NUM_COL5_ORIG,
NUM_COL5_NEW,
NUM_COL6_ORIG,
NUM_COL6_NEW,
NUM_COL7_ORIG,
NUM_COL7_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
) VALUES (
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_ORDER_HEADERS_ALL',
MERGE_HEADER_ID_LIST(I),
hdr_header_id_tab(I),
old_hdr_sold_to_org_id_tab(I),
decode(hdr_sold_to_org_id_tab(I),NULL,old_hdr_sold_to_org_id_tab(I),hdr_sold_to_org_id_tab(i)),
old_hdr_invoice_to_org_id_tab(I),
decode(hdr_invoice_to_org_id_tab(I),NULL,old_hdr_invoice_to_org_id_tab(I),hdr_invoice_to_org_id_tab(i)),
old_hdr_ship_to_org_id_tab(I),
decode(hdr_ship_to_org_id_tab(I),NULL,old_hdr_ship_to_org_id_tab(I),hdr_ship_to_org_id_tab(i)),
old_hdr_deliver_to_org_id_tab(I),
decode(hdr_deliver_to_org_id_tab(I),NULL,old_hdr_deliver_to_org_id_tab(I),hdr_deliver_to_org_id_tab(i)),
old_hdr_sold_to_site_id_tab(I),
decode(hdr_sold_to_site_use_id_tab(I),NULL,old_hdr_sold_to_site_id_tab(I),hdr_sold_to_site_use_id_tab(i)),
old_hdr_end_cust_site_tab(I),
decode(hdr_end_cust_site_use_id_tab(I),NULL,old_hdr_end_cust_site_tab(I),hdr_end_cust_site_use_id_tab(i)),
old_hdr_end_cust_id_tab(I),
decode(hdr_end_cust_id_tab(I),NULL,old_hdr_end_cust_id_tab(I),hdr_end_cust_id_tab(i)),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
);
UPDATE OE_ORDER_HEADERS_ALL H
SET sold_to_org_id = decode(hdr_sold_to_org_id_tab(i),null,sold_to_org_id,hdr_sold_to_org_id_tab(i)),
invoice_to_org_id = decode(hdr_invoice_to_org_id_tab(i),null,invoice_to_org_id,hdr_invoice_to_org_id_tab(i)),
ship_to_org_id = decode(hdr_ship_to_org_id_tab(i),null,ship_to_org_id,hdr_ship_to_org_id_tab(i)),
deliver_to_org_id = decode(hdr_deliver_to_org_id_tab(i),null,deliver_to_org_id,hdr_deliver_to_org_id_tab(i)),
sold_to_site_use_id = decode(hdr_sold_to_site_use_id_tab(i),null,sold_to_site_use_id,hdr_sold_to_site_use_id_tab(i)),
end_customer_site_use_id = decode(hdr_end_cust_site_use_id_tab(i),null,end_customer_site_use_id,hdr_end_cust_site_use_id_tab(i)),
end_customer_id = decode(hdr_end_cust_id_tab(i),null,end_customer_id,hdr_end_cust_id_tab(i)),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id = arp_standard.profile.program_application_id ,
program_id = arp_standard.profile.program_id,
program_update_date = SYSDATE,
lock_control = lock_control+1
WHERE header_id = hdr_header_id_tab(i)
RETURNING last_update_date bulk collect into dbi_header_update_date_tab;
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
hdr_header_id_tab.DELETE;
hdr_sold_to_org_id_tab.DELETE;
hdr_invoice_to_org_id_tab.DELETE;
hdr_ship_to_org_id_tab.DELETE;
hdr_deliver_to_org_id_tab.DELETE;
hdr_sold_to_site_use_id_tab.DELETE;
hdr_end_cust_site_use_id_tab.DELETE;
hdr_end_cust_id_tab.DELETE;
old_hdr_sold_to_org_id_tab.DELETE;
old_hdr_invoice_to_org_id_tab.DELETE;
old_hdr_ship_to_org_id_tab.DELETE;
old_hdr_deliver_to_org_id_tab.DELETE;
old_hdr_sold_to_site_id_tab.DELETE;
old_hdr_end_cust_site_tab.DELETE;
old_hdr_end_cust_id_tab.DELETE;
customer_id_tab.DELETE;
customer_site_id_tab.DELETE;
dbi_local_hdr_header_id_tab.DELETE;
dbi_local_hdr_update_date_tab.DELETE;
arp_message.set_line(' update_date_tab_count for hdr='||dbi_header_update_date_tab.COUNT);
select duplicate_id, customer_id, duplicate_site_id, customer_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
SELECT /*+ PARALLEL(L)
PARALLEL(M1)
PARALLEL(M2)
PARALLEL(M3)
PARALLEL(M4)
PARALLEL(M5)
PARALLEL(M6)
PARALLEL(M7) */
hist.header_id ,
hist.sold_to_org_id,
hist.invoice_to_org_id,
hist.ship_to_org_id,
hist.sold_to_site_use_id,
hist.deliver_to_org_id,
hist.end_customer_site_use_id,
hist.end_customer_id
FROM RA_CUSTOMER_MERGES M1,
RA_CUSTOMER_MERGES M2,
RA_CUSTOMER_MERGES M3,
RA_CUSTOMER_MERGES M4,
RA_CUSTOMER_MERGES M5,
RA_CUSTOMER_MERGES M6,
RA_CUSTOMER_MERGES M7,
OE_ORDER_HEADER_HISTORY HIST,
-- Changed by Srini for MOAC
-- This MOAC change has been reverted.
-- For more information please
-- see the bug #5050382
OE_ORDER_HEADERS H
WHERE
( hist.sold_to_org_id = m1.duplicate_id(+)
and hist.invoice_to_org_id = m2.duplicate_site_id(+)
and hist.ship_to_org_id = m3.duplicate_site_id(+)
and hist.sold_to_site_use_id = m4.duplicate_site_id(+)
and hist.deliver_to_org_id = m5.duplicate_site_id(+)
and hist.end_customer_site_use_id = m6.duplicate_site_id(+)
and hist.end_customer_id = m7.duplicate_id(+)
)
and
(m1.duplicate_site_id is not null or
m2.duplicate_id is not null or
m3.duplicate_id is not null or
m4.duplicate_id is not null or
m5.duplicate_id is not null or
m6.duplicate_id is not null or
m7.duplicate_site_id is not null)
and m1.process_flag(+) = 'N'
and m2.process_flag(+) = 'N'
and m3.process_flag(+) = 'N'
and m4.process_flag(+) = 'N'
and m5.process_flag(+) = 'N'
and m6.process_flag(+) = 'N'
and m7.process_flag(+) = 'N'
and m1.request_id(+) =req_id
and m2.request_id(+) =req_id
and m3.request_id(+) =req_id
and m4.request_id(+) =req_id
and m5.request_id(+) =req_id
and m6.request_id(+) =req_id
and m7.request_id(+) =req_id
and m1.set_number(+) =set_num
and m2.set_number(+) =set_num
and m3.set_number(+) =set_num
and m4.set_number(+) =set_num
and m5.set_number(+) =set_num
and m6.set_number(+) =set_num
and m7.set_number(+) =set_num
and hist.header_id=h.header_id
for update nowait;
SELECT /*+ PARALLEL(L)
PARALLEL(M1)
PARALLEL(M2)
PARALLEL(M3)
PARALLEL(M4)
PARALLEL(M5)
PARALLEL(M6)
PARALLEL(M7) */
hist.header_id ,
hist.sold_to_org_id,
hist.invoice_to_org_id,
hist.ship_to_org_id,
hist.sold_to_site_use_id,
hist.deliver_to_org_id,
hist.end_customer_site_use_id,
hist.end_customer_id
FROM RA_CUSTOMER_MERGES M1,
RA_CUSTOMER_MERGES M2,
RA_CUSTOMER_MERGES M3,
RA_CUSTOMER_MERGES M4,
RA_CUSTOMER_MERGES M5,
RA_CUSTOMER_MERGES M6,
RA_CUSTOMER_MERGES M7,
OE_ORDER_HEADER_HISTORY HIST,
--Changed for MOAC
OE_ORDER_HEADERS_ALL H
WHERE
( hist.sold_to_org_id = m1.duplicate_id(+)
and hist.invoice_to_org_id = m2.duplicate_site_id(+)
and hist.ship_to_org_id = m3.duplicate_site_id(+)
and hist.sold_to_site_use_id = m4.duplicate_site_id(+)
and hist.deliver_to_org_id = m5.duplicate_site_id(+)
and hist.end_customer_site_use_id = m6.duplicate_site_id(+)
and hist.end_customer_id = m7.duplicate_id(+)
)
and
(m1.duplicate_site_id is not null or
m2.duplicate_id is not null or
m3.duplicate_id is not null or
m4.duplicate_id is not null or
m5.duplicate_id is not null or
m6.duplicate_id is not null or
m7.duplicate_site_id is not null)
and m1.process_flag(+) = 'N'
and m2.process_flag(+) = 'N'
and m3.process_flag(+) = 'N'
and m4.process_flag(+) = 'N'
and m5.process_flag(+) = 'N'
and m6.process_flag(+) = 'N'
and m7.process_flag(+) = 'N'
and m1.request_id(+) =req_id
and m2.request_id(+) =req_id
and m3.request_id(+) =req_id
and m4.request_id(+) =req_id
and m5.request_id(+) =req_id
and m6.request_id(+) =req_id
and m7.request_id(+) =req_id
and m1.set_number(+) =set_num
and m2.set_number(+) =set_num
and m3.set_number(+) =set_num
and m4.set_number(+) =set_num
and m5.set_number(+) =set_num
and m6.set_number(+) =set_num
and m7.set_number(+) =set_num
and hist.header_id=h.header_id;
UPDATE OE_ORDER_HEADER_HISTORY HHIST
SET sold_to_org_id = decode(hhst_sold_to_org_id_tab(i),null,sold_to_org_id,hhst_sold_to_org_id_tab(i)),
invoice_to_org_id = decode(hhst_invoice_to_org_id_tab(i),null,invoice_to_org_id,hhst_invoice_to_org_id_tab(i)),
ship_to_org_id = decode(hhst_ship_to_org_id_tab(i),null,ship_to_org_id,hhst_ship_to_org_id_tab(i)),
sold_to_site_use_id = decode(hhst_sold_to_site_use_id_tab(i),null,sold_to_site_use_id,hhst_sold_to_site_use_id_tab(i)),
deliver_to_org_id = decode(hhst_deliver_to_org_id_tab(i),null,deliver_to_org_id,hhst_deliver_to_org_id_tab(i)),
end_customer_site_use_id = decode(hhst_end_cust_site_use_id_tab(i),null,end_customer_site_use_id,hhst_end_cust_site_use_id_tab(i)),
end_customer_id = decode(hhst_end_cust_id_tab(i),null,end_customer_id,hhst_end_cust_id_tab(i)),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id = arp_standard.profile.program_application_id ,
program_id = arp_standard.profile.program_id,
program_update_date = SYSDATE
WHERE header_id = hhst_header_id_tab(i);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
hhst_header_id_tab.DELETE;
hhst_sold_to_org_id_tab.DELETE;
hhst_invoice_to_org_id_tab.DELETE;
hhst_ship_to_org_id_tab.DELETE;
hhst_sold_to_site_use_id_tab.DELETE;
hhst_deliver_to_org_id_tab.DELETE;
hhst_end_cust_site_use_id_tab.DELETE;
hhst_end_cust_id_tab.DELETE;
customer_id_tab.DELETE;
customer_site_id_tab.DELETE;
select HEADER_ID
from oe_order_header_history
where ship_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
select HEADER_ID
from oe_order_header_history
where invoice_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
select HEADER_ID
from oe_order_header_history
where deliver_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
select HEADER_ID
from oe_order_header_history
where sold_to_org_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
select HEADER_ID
from oe_order_header_history
where sold_to_site_use_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
select HEADER_ID
from oe_order_header_history
where end_customer_site_use_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
select HEADER_ID
from oe_order_header_history
where end_customer_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
UPDATE oe_order_header_history a
set ship_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.ship_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where ship_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
UPDATE oe_order_header_history a
set invoice_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.invoice_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where invoice_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
UPDATE oe_order_header_history a
set deliver_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.deliver_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where deliver_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
UPDATE oe_order_header_history a
set sold_to_org_id = (select distinct m.customer_id
from ra_customer_merges m
where a.sold_to_org_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where sold_to_org_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
UPDATE oe_order_header_history a
set sold_to_site_use_id = (select distinct m.customer_id
from ra_customer_merges m
where a.sold_to_site_use_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where sold_to_site_use_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
UPDATE oe_order_header_history a
set end_customer_site_use_id = (select distinct m.customer_id
from ra_customer_merges m
where a.end_customer_site_use_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where end_customer_site_use_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
UPDATE oe_order_header_history a
set end_customer_id = (select distinct m.customer_id
from ra_customer_merges m
where a.end_customer_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where end_customer_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
/* -- Interface tables need not be updated
-- Not logging merge for Interface tables
Procedure OE_Merge_Headers_IFACE (Req_Id IN NUMBER,
Set_Num IN NUMBER,
Process_Mode IN VARCHAR2)
IS
CURSOR c1 is
select HEADER_ID
from oe_headers_iface_all
where ship_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
select HEADER_ID
from oe_headers_iface_all
where invoice_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
select HEADER_ID
from oe_headers_iface_all
where deliver_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
select HEADER_ID
from oe_headers_iface_all
where sold_to_org_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
UPDATE oe_headers_iface_all a
set ship_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.ship_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where ship_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
UPDATE oe_headers_iface_all a
set invoice_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.invoice_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where invoice_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
UPDATE oe_headers_iface_all a
set deliver_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.deliver_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where deliver_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
UPDATE oe_headers_iface_all a
set sold_to_org_id = (select distinct m.customer_id
from ra_customer_merges m
where a.sold_to_org_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where sold_to_org_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
Interface tables need not be updated */
/*------------------------------------------------*/
/*--- PRIVATE PROCEDURE OE_Merge_Header_ACKS ---*/
/*------------------------------------------------*/
Procedure OE_Merge_Header_ACKS (Req_Id IN NUMBER,
Set_Num IN NUMBER,
Process_Mode IN VARCHAR2)
IS
CURSOR c1 is
select HEADER_ID
from OE_HEADER_ACKS
where ship_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
for update nowait;
select HEADER_ID
from OE_HEADER_ACKS
where invoice_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
for update nowait;
select HEADER_ID
from OE_HEADER_ACKS
where deliver_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
for update nowait;
select /* MOAC_SQL_CHANGE */ a.HEADER_ID
from OE_HEADER_ACKS a, OE_ORDER_HEADERS_all h
where a.sold_to_org_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
--changed for bug 3196900
and a.header_id=h.header_id
for update nowait;
select HEADER_ID
from OE_HEADER_ACKS
where sold_to_site_use_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
for update nowait;
select HEADER_ID
from OE_HEADER_ACKS
where end_customer_site_use_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
for update nowait;
select a.HEADER_ID
from OE_HEADER_ACKS a,OE_ORDER_HEADERS h
where a.end_customer_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
-- changed for bug 3196900
and a.header_id=h.header_id
for update nowait;
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
NUM_COL3_ORIG,
NUM_COL3_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_HEADER_ACKS',
m.CUSTOMER_MERGE_HEADER_ID,
h.ORIG_SYS_DOCUMENT_REF,
h.ship_to_org_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_header_acks h,
ra_customer_merges m
where h.ship_to_org_id=m.duplicate_site_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_HEADER_ACKS a
set ship_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.ship_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where ship_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
NUM_COL2_ORIG,
NUM_COL2_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_HEADERS_ACKS',
m.CUSTOMER_MERGE_HEADER_ID,
h.ORIG_SYS_DOCUMENT_REF,
h.invoice_to_org_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_header_acks h,
ra_customer_merges m
where h.invoice_to_org_id=m.duplicate_site_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and NVL(h.ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
UPDATE OE_HEADER_ACKS a
set invoice_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.invoice_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where invoice_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
NUM_COL4_ORIG,
NUM_COL4_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_HEADER_ACKS',
m.CUSTOMER_MERGE_HEADER_ID,
h.ORIG_SYS_DOCUMENT_REF,
h.deliver_to_org_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_header_acks h,
ra_customer_merges m
where h.deliver_to_org_id=m.duplicate_site_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
UPDATE OE_HEADER_ACKS a
set deliver_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.deliver_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where deliver_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
/* customer level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
NUM_COL1_ORIG,
NUM_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_HEADER_ACKS',
m.CUSTOMER_MERGE_HEADER_ID,
h.ORIG_SYS_DOCUMENT_REF,
h.sold_to_org_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_header_acks h,
ra_customer_merges m
where h.sold_to_org_id=m.duplicate_site_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
UPDATE OE_HEADER_ACKS a
set sold_to_org_id = (select distinct m.customer_id
from ra_customer_merges m
where a.sold_to_org_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where sold_to_org_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
--changed for bug 3196900
and a.header_id in (select header_id from oe_order_headers);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
NUM_COL5_ORIG,
NUM_COL5_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_HEADER_ACKS',
m.CUSTOMER_MERGE_HEADER_ID,
h.ORIG_SYS_DOCUMENT_REF,
h.sold_to_site_use_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_header_acks h,
ra_customer_merges m
where
h.sold_to_site_use_id=m.duplicate_site_id
and
m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
UPDATE OE_HEADER_ACKS a
set sold_to_site_use_id = (select distinct m.customer_id
from ra_customer_merges m
where a.sold_to_site_use_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where sold_to_site_use_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
NUM_COL6_ORIG,
NUM_COL6_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_HEADER_ACKS',
m.CUSTOMER_MERGE_HEADER_ID,
h.ORIG_SYS_DOCUMENT_REF,
h.end_customer_site_use_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_header_acks h,
ra_customer_merges m
where
h.end_customer_site_use_id=m.duplicate_site_id
and
m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
UPDATE OE_HEADER_ACKS a
set end_customer_site_use_id = (select distinct m.customer_id
from ra_customer_merges m
where a.end_customer_site_use_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where
end_customer_site_use_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and
NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
/* customer level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
NUM_COL7_ORIG,
NUM_COL7_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_HEADER_ACKS',
m.CUSTOMER_MERGE_HEADER_ID,
h.ORIG_SYS_DOCUMENT_REF,
h.end_customer_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_header_acks h,
ra_customer_merges m
where
h.end_customer_id=m.duplicate_site_id
and
m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
UPDATE OE_HEADER_ACKS a
set end_customer_id = (select distinct m.customer_id
from ra_customer_merges m
where a.end_customer_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where end_customer_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
--changed for bug 3196900
and a.header_id in (select header_id from oe_order_headers);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
select duplicate_id, customer_id, duplicate_site_id, customer_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
SELECT / *+ LEADING (M) PARALLEL (L) PARALLEL (M) * /
l.line_id ,
l.header_id,
l.last_update_date,
l.line_id,
'Y',
sold_to_org_id,
invoice_to_org_id,
ship_to_org_id,
intmed_ship_to_org_id,
deliver_to_org_id,
end_customer_site_use_id,
end_customer_id,
m.customer_merge_id
FROM RA_CUSTOMER_MERGES M,
-- change for bug 3196900
-- OE_ORDER_LINES_ALL L
OE_ORDER_LINES L
WHERE
(l.sold_to_org_id = m.duplicate_id
or l.invoice_to_org_id = m.duplicate_site_id
or l.ship_to_org_id = m.duplicate_site_id
or l.intmed_ship_to_org_id = m.duplicate_site_id
or l.end_customer_site_use_id = m.duplicate_site_id
or l.end_customer_id = m.duplicate_id
or l.deliver_to_org_id = m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
for update nowait;
SELECT /*+ PARALLEL (L) PARALLEL (M1) PARALLEL(M2)
PARALLEL (M3) PARALLEL (M4) PARALLEL (M5)
PARALLEL (M6) PARALLEL (M7) */
L.LINE_ID , L.HEADER_ID, L.LAST_UPDATE_DATE, L.LINE_ID, 'Y',
SOLD_TO_ORG_ID, INVOICE_TO_ORG_ID, SHIP_TO_ORG_ID,
INTMED_SHIP_TO_ORG_ID, DELIVER_TO_ORG_ID,
END_CUSTOMER_SITE_USE_ID, END_CUSTOMER_ID,
NVL(M1.CUSTOMER_MERGE_ID,NVL(M2.CUSTOMER_MERGE_ID,NVL(M3.CUSTOMER_MERGE_ID,
NVL(M4.CUSTOMER_MERGE_ID,NVL(M5.CUSTOMER_MERGE_ID,
NVL(M6.CUSTOMER_MERGE_ID,M7.CUSTOMER_MERGE_ID))))))
FROM RA_CUSTOMER_MERGES M1,
RA_CUSTOMER_MERGES M2,
RA_CUSTOMER_MERGES M3,
RA_CUSTOMER_MERGES M4,
RA_CUSTOMER_MERGES M5,
RA_CUSTOMER_MERGES M6,
RA_CUSTOMER_MERGES M7,
OE_ORDER_LINES L
WHERE ( L.SOLD_TO_ORG_ID = M1.DUPLICATE_ID(+)
AND L.INVOICE_TO_ORG_ID = M2.DUPLICATE_SITE_ID(+)
AND L.SHIP_TO_ORG_ID = M3.DUPLICATE_SITE_ID(+)
AND L.INTMED_SHIP_TO_ORG_ID = M4.DUPLICATE_SITE_ID(+)
AND L.END_CUSTOMER_SITE_USE_ID = M5.DUPLICATE_SITE_ID(+)
AND L.END_CUSTOMER_ID = M6.DUPLICATE_SITE_ID(+)
AND L.DELIVER_TO_ORG_ID = M7.DUPLICATE_ID(+) )
AND (M1.DUPLICATE_SITE_ID IS NOT NULL
OR M2.DUPLICATE_ID IS NOT NULL
OR M3.DUPLICATE_ID IS NOT NULL
OR M4.DUPLICATE_ID IS NOT NULL
OR M5.DUPLICATE_ID IS NOT NULL
OR M6.DUPLICATE_ID IS NOT NULL
OR M7.DUPLICATE_SITE_ID IS NOT NULL)
AND M1.PROCESS_FLAG(+) = 'N'
AND M2.PROCESS_FLAG(+) = 'N'
AND M3.PROCESS_FLAG(+) = 'N'
AND M4.PROCESS_FLAG(+) = 'N'
AND M5.PROCESS_FLAG(+) = 'N'
AND M6.PROCESS_FLAG(+) = 'N'
AND M7.PROCESS_FLAG(+) = 'N'
AND M1.REQUEST_ID(+) = req_id
AND M2.REQUEST_ID(+) = req_id
AND M3.REQUEST_ID(+) = req_id
AND M4.REQUEST_ID(+) = req_id
AND M5.REQUEST_ID(+) = req_id
AND M6.REQUEST_ID(+) = req_id
AND M7.REQUEST_ID(+) = req_id
AND M1.SET_NUMBER(+) = set_num
AND M2.SET_NUMBER(+) = set_num
AND M3.SET_NUMBER(+) = set_num
AND M4.SET_NUMBER(+) = set_num
AND M5.SET_NUMBER(+) = set_num
AND M6.SET_NUMBER(+) = set_num
AND M7.SET_NUMBER(+) = set_num
FOR UPDATE NOWAIT;
SELECT / *+ LEADING (M) PARALLEL (L) PARALLEL (M) * /
l.line_id ,
l.header_id,
l.last_update_date,
l.line_id,
'Y',
sold_to_org_id,
invoice_to_org_id,
ship_to_org_id,
intmed_ship_to_org_id,
deliver_to_org_id,
end_customer_site_use_id,
end_customer_id,
m.customer_merge_id
FROM RA_CUSTOMER_MERGES M,
-- changed for bug 3196900
-- OE_ORDER_LINES_ALL L
OE_ORDER_LINES L
WHERE
(l.sold_to_org_id = m.duplicate_id
or l.invoice_to_org_id = m.duplicate_site_id
or l.ship_to_org_id = m.duplicate_site_id
or l.intmed_ship_to_org_id = m.duplicate_site_id
or l.end_customer_site_use_id = m.duplicate_site_id
or l.end_customer_id = m.duplicate_id
or l.deliver_to_org_id = m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
SELECT /*+ PARALLEL (L) PARALLEL (M1) PARALLEL(M2)
PARALLEL (M3) PARALLEL (M4) PARALLEL (M5)
PARALLEL (M6) PARALLEL (M7) */
L.LINE_ID , L.HEADER_ID, L.LAST_UPDATE_DATE, L.LINE_ID, 'Y',
SOLD_TO_ORG_ID, INVOICE_TO_ORG_ID, SHIP_TO_ORG_ID,
INTMED_SHIP_TO_ORG_ID, DELIVER_TO_ORG_ID,
END_CUSTOMER_SITE_USE_ID, END_CUSTOMER_ID,
NVL(M1.CUSTOMER_MERGE_ID,NVL(M2.CUSTOMER_MERGE_ID,NVL(M3.CUSTOMER_MERGE_ID,
NVL(M4.CUSTOMER_MERGE_ID,NVL(M5.CUSTOMER_MERGE_ID,
NVL(M6.CUSTOMER_MERGE_ID,M7.CUSTOMER_MERGE_ID))))))
FROM RA_CUSTOMER_MERGES M1,
RA_CUSTOMER_MERGES M2,
RA_CUSTOMER_MERGES M3,
RA_CUSTOMER_MERGES M4,
RA_CUSTOMER_MERGES M5,
RA_CUSTOMER_MERGES M6,
RA_CUSTOMER_MERGES M7,
OE_ORDER_LINES L
WHERE ( L.SOLD_TO_ORG_ID = M1.DUPLICATE_ID(+)
AND L.INVOICE_TO_ORG_ID = M2.DUPLICATE_SITE_ID(+)
AND L.SHIP_TO_ORG_ID = M3.DUPLICATE_SITE_ID(+)
AND L.INTMED_SHIP_TO_ORG_ID = M4.DUPLICATE_SITE_ID(+)
AND L.END_CUSTOMER_SITE_USE_ID = M5.DUPLICATE_SITE_ID(+)
AND L.END_CUSTOMER_ID = M6.DUPLICATE_SITE_ID(+)
AND L.DELIVER_TO_ORG_ID = M7.DUPLICATE_ID(+) )
AND (M1.DUPLICATE_SITE_ID IS NOT NULL
OR M2.DUPLICATE_ID IS NOT NULL
OR M3.DUPLICATE_ID IS NOT NULL
OR M4.DUPLICATE_ID IS NOT NULL
OR M5.DUPLICATE_ID IS NOT NULL
OR M6.DUPLICATE_ID IS NOT NULL
OR M7.DUPLICATE_SITE_ID IS NOT NULL)
AND M1.PROCESS_FLAG(+) = 'N'
AND M2.PROCESS_FLAG(+) = 'N'
AND M3.PROCESS_FLAG(+) = 'N'
AND M4.PROCESS_FLAG(+) = 'N'
AND M5.PROCESS_FLAG(+) = 'N'
AND M6.PROCESS_FLAG(+) = 'N'
AND M7.PROCESS_FLAG(+) = 'N'
AND M1.REQUEST_ID(+) = req_id
AND M2.REQUEST_ID(+) = req_id
AND M3.REQUEST_ID(+) = req_id
AND M4.REQUEST_ID(+) = req_id
AND M5.REQUEST_ID(+) = req_id
AND M6.REQUEST_ID(+) = req_id
AND M7.REQUEST_ID(+) = req_id
AND M1.SET_NUMBER(+) = set_num
AND M2.SET_NUMBER(+) = set_num
AND M3.SET_NUMBER(+) = set_num
AND M4.SET_NUMBER(+) = set_num
AND M5.SET_NUMBER(+) = set_num
AND M6.SET_NUMBER(+) = set_num
AND M7.SET_NUMBER(+) = set_num;
dbi_local_line_update_date_tab date_bin_table :=date_bin_table();
dbi_local_line_update_date_tab,
dbi_local_line_line_id_tab,
dbi_local_line_status_tab,
line_sold_to_org_id_tab,
line_invoice_to_org_id_tab,
line_ship_to_org_id_tab,
line_intmed_ship_to_org_id_tab,
line_deliver_to_org_id_tab,
line_end_cust_site_use_id,
line_end_cust_id_tab,
MERGE_HEADER_ID_LIST
LIMIT 20000;
arp_message.set_line('local line_date_count='||dbi_local_line_update_date_tab.COUNT);
IF dbi_local_line_update_date_tab.COUNT > 0 then
IF dbi_line_update_date_tab.COUNT > 0 then
l_global_count := dbi_line_update_date_tab.COUNT;
dbi_line_update_date_tab.EXTEND(dbi_local_line_update_date_tab.COUNT);
dbi_line_header_id_tab.EXTEND(dbi_local_line_update_date_tab.COUNT);
dbi_line_line_id_tab.EXTEND(dbi_local_line_update_date_tab.COUNT);
dbi_line_status_tab.EXTEND(dbi_local_line_update_date_tab.COUNT);
dbi_line_update_date_tab(l_global_count + i):=dbi_local_line_update_date_tab(i);
--insert audit information for customer merge
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
NUM_COL1_ORIG,
NUM_COL1_NEW,
NUM_COL2_ORIG,
NUM_COL2_NEW,
NUM_COL3_ORIG,
NUM_COL3_NEW,
NUM_COL4_ORIG,
NUM_COL4_NEW,
NUM_COL5_ORIG,
NUM_COL5_NEW,
NUM_COL6_ORIG,
NUM_COL6_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
) VALUES (
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_ORDER_LINES_ALL',
MERGE_HEADER_ID_LIST(I),
line_line_id_tab(I),
line_sold_to_org_id_tab(I),
decode(line_sold_to_org_id_tab(I),NULL,old_line_sold_to_org_id_tab(I),line_sold_to_org_id_tab(i)),
line_invoice_to_org_id_tab(I),
decode(line_invoice_to_org_id_tab(I),NULL,old_line_invoice_to_org_id_tab(I),line_invoice_to_org_id_tab(i)),
line_ship_to_org_id_tab(I),
decode(line_ship_to_org_id_tab(I),NULL,old_line_ship_to_org_id_tab(I),line_ship_to_org_id_tab(i)),
line_deliver_to_org_id_tab(I),
decode(line_deliver_to_org_id_tab(I),NULL,old_line_deliver_to_org_id_tab(I),line_deliver_to_org_id_tab(i)),
line_end_cust_site_use_id(I),
decode(line_end_cust_site_use_id(I),NULL,old_line_end_cust_site_use_id(I),line_end_cust_site_use_id(i)),
line_end_cust_id_tab(I),
decode(line_end_cust_id_tab(I),NULL,old_line_end_cust_id_tab(I),line_end_cust_id_tab(i)),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
);
UPDATE OE_ORDER_LINES_ALL L
SET sold_to_org_id = decode(line_sold_to_org_id_tab(i),null,sold_to_org_id,line_sold_to_org_id_tab(i)),
invoice_to_org_id = decode(line_invoice_to_org_id_tab(i),null,invoice_to_org_id,line_invoice_to_org_id_tab(i)),
ship_to_org_id = decode(line_ship_to_org_id_tab(i),null,ship_to_org_id,line_ship_to_org_id_tab(i)),
intmed_ship_to_org_id = decode(line_intmed_ship_to_org_id_tab(i),null,intmed_ship_to_org_id,line_intmed_ship_to_org_id_tab(i)),
deliver_to_org_id = decode(line_deliver_to_org_id_tab(i),null,deliver_to_org_id,line_deliver_to_org_id_tab(i)),
end_customer_site_use_id = decode(line_end_cust_site_use_id(i),null,end_customer_site_use_id,line_end_cust_site_use_id(i)),
end_customer_id = decode(line_end_cust_id_tab(i),null,end_customer_id,line_end_cust_id_tab(i)),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id = arp_standard.profile.program_application_id ,
program_id = arp_standard.profile.program_id,
program_update_date = SYSDATE,
lock_control = lock_control+1
WHERE line_id = line_line_id_tab(i)
RETURNING last_update_date bulk collect into dbi_line_update_date_tab;
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
line_line_id_tab.DELETE;
line_sold_to_org_id_tab.DELETE;
line_invoice_to_org_id_tab.DELETE;
line_ship_to_org_id_tab.DELETE;
line_intmed_ship_to_org_id_tab.DELETE;
line_deliver_to_org_id_tab.DELETE;
line_end_cust_site_use_id.DELETE;
line_end_cust_id_tab.DELETE;
old_line_sold_to_org_id_tab.DELETE;
old_line_invoice_to_org_id_tab.DELETE;
old_line_ship_to_org_id_tab.DELETE;
old_intmed_ship_to_org_id_tab.DELETE;
old_line_deliver_to_org_id_tab.DELETE;
old_line_end_cust_site_use_id.DELETE;
old_line_end_cust_id_tab.DELETE;
customer_id_tab.DELETE;
customer_site_id_tab.DELETE;
dbi_local_line_header_id_tab.DELETE;
dbi_local_line_update_date_tab.DELETE;
dbi_local_line_line_id_tab.DELETE;
dbi_local_line_status_tab.DELETE;
arp_message.set_line(' line_date_count='||dbi_line_update_date_tab.COUNT);
select duplicate_id, customer_id, duplicate_site_id, customer_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
SELECT /*+ ordered PARALLEL(L) PARALLEL (LN)
PARALLEL(M1) PARALLEL(M2) PARALLEL(M3) PARALLEL(M4)
PARALLEL (M5) PARALLEL(M6) PARALLEL(M7)
PARALLEL (LN) */
l.line_id ,
-- changed for bug 3196900 added l. for every attribute
l.sold_to_org_id,
l.invoice_to_org_id,
l.ship_to_org_id,
l.intmed_ship_to_org_id,
l.deliver_to_org_id,
l.end_customer_site_use_id,
l.end_customer_id
FROM OE_ORDER_LINES_HISTORY L,
RA_CUSTOMER_MERGES M1,
RA_CUSTOMER_MERGES M2,
RA_CUSTOMER_MERGES M3,
RA_CUSTOMER_MERGES M4,
RA_CUSTOMER_MERGES M5,
RA_CUSTOMER_MERGES M6,
RA_CUSTOMER_MERGES M7,
-- changed for bug 3196900
-- OE_ORDER_LINES_HISTORY L
OE_ORDER_LINES_ALL LN
-- Changed for MOAC
WHERE
( l.sold_to_org_id = m1.duplicate_id(+)
and l.invoice_to_org_id = m2.duplicate_site_id(+)
and l.ship_to_org_id = m3.duplicate_site_id(+)
and l.intmed_ship_to_org_id = m4.duplicate_site_id(+)
and l.deliver_to_org_id = m5.duplicate_site_id(+)
and l.end_customer_site_use_id = m6.duplicate_site_id(+)
and l.end_customer_id = m7.duplicate_id(+) )
and
(m1.duplicate_site_id is not null or
m2.duplicate_id is not null or
m3.duplicate_id is not null or
m4.duplicate_id is not null or
m5.duplicate_id is not null or
m6.duplicate_id is not null or
m7.duplicate_site_id is not null)
and m1.process_flag(+) = 'N'
and m2.process_flag(+) = 'N'
and m3.process_flag(+) = 'N'
and m4.process_flag(+) = 'N'
and m5.process_flag(+) = 'N'
and m6.process_flag(+) = 'N'
and m7.process_flag(+) = 'N'
and m1.request_id(+) =req_id
and m2.request_id(+) =req_id
and m3.request_id(+) =req_id
and m4.request_id(+) =req_id
and m5.request_id(+) =req_id
and m6.request_id(+) =req_id
and m7.request_id(+) =req_id
and m1.set_number(+) =set_num
and m2.set_number(+) =set_num
and m3.set_number(+) =set_num
and m4.set_number(+) =set_num
and m5.set_number(+) =set_num
and m6.set_number(+) =set_num
and m7.set_number(+) =set_num
-- added for bug 3196900
and l.line_id=ln.line_id
for update nowait;
SELECT /*+ ordered PARALLEL(L) PARALLEL (LN)
PARALLEL(M1) PARALLEL(M2) PARALLEL(M3) PARALLEL(M4)
PARALLEL (M5) PARALLEL(M6) PARALLEL(M7)
PARALLEL (LN) */
l.line_id ,
--changed for bug 3196900 , added l. for every attribute
l.sold_to_org_id,
l.invoice_to_org_id,
l.ship_to_org_id,
l.intmed_ship_to_org_id,
l.deliver_to_org_id,
l.end_customer_site_use_id,
l.end_customer_id
FROM OE_ORDER_LINES_HISTORY L ,
RA_CUSTOMER_MERGES M1,
RA_CUSTOMER_MERGES M2,
RA_CUSTOMER_MERGES M3,
RA_CUSTOMER_MERGES M4,
RA_CUSTOMER_MERGES M5,
RA_CUSTOMER_MERGES M6,
RA_CUSTOMER_MERGES M7,
--changed for bug 3196900
-- OE_ORDER_LINES_HISTORY L
OE_ORDER_LINES_ALL LN
--Changed for MOAC
WHERE
( l.sold_to_org_id = m1.duplicate_id(+)
and l.invoice_to_org_id = m2.duplicate_site_id(+)
and l.ship_to_org_id = m3.duplicate_site_id(+)
and l.intmed_ship_to_org_id = m4.duplicate_site_id(+)
and l.deliver_to_org_id = m5.duplicate_site_id(+)
and l.end_customer_site_use_id = m6.duplicate_site_id(+)
and l.end_customer_id = m7.duplicate_id(+) )
and
(m1.duplicate_site_id is not null or
m2.duplicate_id is not null or
m3.duplicate_id is not null or
m4.duplicate_id is not null or
m5.duplicate_id is not null or
m6.duplicate_id is not null or
m7.duplicate_site_id is not null)
and m1.process_flag(+) = 'N'
and m2.process_flag(+) = 'N'
and m3.process_flag(+) = 'N'
and m4.process_flag(+) = 'N'
and m5.process_flag(+) = 'N'
and m6.process_flag(+) = 'N'
and m7.process_flag(+) = 'N'
and m1.request_id(+) =req_id
and m2.request_id(+) =req_id
and m3.request_id(+) =req_id
and m4.request_id(+) =req_id
and m5.request_id(+) =req_id
and m6.request_id(+) =req_id
and m7.request_id(+) =req_id
and m1.set_number(+) =set_num
and m2.set_number(+) =set_num
and m3.set_number(+) =set_num
and m4.set_number(+) =set_num
and m5.set_number(+) =set_num
and m6.set_number(+) =set_num
and m7.set_number(+) =set_num
-- added for bug 3196900
and l.line_id=ln.line_id;
UPDATE OE_ORDER_LINES_HISTORY LHIST
SET sold_to_org_id = decode(lhst_sold_to_org_id_tab(i),null,sold_to_org_id,lhst_sold_to_org_id_tab(i)),
invoice_to_org_id = decode(lhst_invoice_to_org_id_tab(i),null,invoice_to_org_id,lhst_invoice_to_org_id_tab(i)),
ship_to_org_id = decode(lhst_ship_to_org_id_tab(i),null,ship_to_org_id,lhst_ship_to_org_id_tab(i)),
intmed_ship_to_org_id = decode(lhst_intmed_ship_to_org_id_tab(i),null,intmed_ship_to_org_id,lhst_intmed_ship_to_org_id_tab(i)),
deliver_to_org_id = decode(lhst_deliver_to_org_id_tab(i),null,deliver_to_org_id,lhst_deliver_to_org_id_tab(i)),
end_customer_site_use_id = decode(lhst_end_cust_site_use_id_tab(i),null,end_customer_site_use_id,lhst_end_cust_site_use_id_tab(i)),
end_customer_id = decode(lhst_end_cust_id_tab(i),null,end_customer_id,lhst_end_cust_id_tab(i)),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id = arp_standard.profile.program_application_id ,
program_id = arp_standard.profile.program_id,
program_update_date = SYSDATE
WHERE line_id = lhst_line_id_tab(i);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
lhst_line_id_tab.DELETE;
lhst_sold_to_org_id_tab.DELETE;
lhst_invoice_to_org_id_tab.DELETE;
lhst_ship_to_org_id_tab.DELETE;
lhst_intmed_ship_to_org_id_tab.DELETE;
lhst_deliver_to_org_id_tab.DELETE;
lhst_end_cust_site_use_id_tab.DELETE;
customer_id_tab.DELETE;
customer_site_id_tab.DELETE;
/* Interface tables need not be updated
Not logging merge for Interface tables
Procedure OE_Merge_Lines_IFACE (Req_Id IN NUMBER,
Set_Num IN NUMBER,
Process_Mode IN VARCHAR2)
IS
CURSOR c1 is
select line_id
from oe_lines_iface_all
where ship_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
select line_id
from oe_lines_iface_all
where invoice_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
select line_id
from oe_lines_iface_all
where deliver_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
select line_id
from oe_lines_iface_all
where sold_to_org_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
UPDATE oe_lines_iface_all a
set ship_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.ship_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where ship_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
UPDATE oe_lines_iface_all a
set invoice_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.invoice_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where invoice_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
UPDATE oe_lines_iface_all a
set deliver_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.deliver_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where deliver_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
UPDATE oe_lines_iface_all a
set sold_to_org_id = (select distinct m.customer_id
from ra_customer_merges m
where a.sold_to_org_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where sold_to_org_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
Interface tables need not be updated */
/*-------------------------------------------------*/
/*--- PRIVATE PROCEDURE OE_Merge_Line_ACKS ---*/
/*-------------------------------------------------*/
Procedure OE_Merge_Line_ACKS (Req_Id IN NUMBER,
Set_Num IN NUMBER,
Process_Mode IN VARCHAR2)
IS
CURSOR c1 is
select line_id
from oe_line_acks
where ship_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
for update nowait;
select line_id
from oe_line_acks
where invoice_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
for update nowait;
select line_id
from oe_line_acks
where deliver_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
for update nowait;
select line_id
from oe_line_acks
where intmed_ship_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
for update nowait;
select a.line_id
from oe_line_acks a, oe_order_lines l
where a.sold_to_org_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
--changed for bug 3196900
and a.line_id=l.line_id
for update nowait;
select line_id
from oe_line_acks
where end_customer_site_use_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
for update nowait;
select a.line_id
from oe_line_acks a,oe_order_lines l
where a.end_customer_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
--changed for bug 3196900
and a.line_id=l.line_id
for update nowait;
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
PRIMARY_KEY2,
NUM_COL3_ORIG,
NUM_COL3_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_LINE_ACKS',
m.CUSTOMER_MERGE_HEADER_ID,
a.ORIG_SYS_DOCUMENT_REF,
a.ORIG_SYS_LINE_REF,
a.ship_to_org_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_line_acks a,
ra_customer_merges m
where m.process_flag = 'N'
and a.ship_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.set_number = set_num
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE oe_line_acks a
set ship_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.ship_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where ship_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
PRIMARY_KEY2,
NUM_COL2_ORIG,
NUM_COL2_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_LINE_ACKS',
m.CUSTOMER_MERGE_HEADER_ID,
a.ORIG_SYS_DOCUMENT_REF,
a.ORIG_SYS_LINE_REF,
a.invoice_to_org_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_line_acks a,
ra_customer_merges m
where m.process_flag = 'N'
and a.invoice_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.set_number = set_num
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
UPDATE oe_line_acks a
set invoice_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.invoice_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where invoice_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
PRIMARY_KEY2,
NUM_COL4_ORIG,
NUM_COL4_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_LINE_ACKS',
m.CUSTOMER_MERGE_HEADER_ID,
a.ORIG_SYS_DOCUMENT_REF,
a.ORIG_SYS_LINE_REF,
a.deliver_to_org_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_line_acks a,
ra_customer_merges m
where m.process_flag = 'N'
and a.deliver_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.set_number = set_num
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
UPDATE oe_line_acks a
set deliver_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.deliver_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where deliver_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
PRIMARY_KEY2,
NUM_COL5_ORIG,
NUM_COL5_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_LINE_ACKS',
m.CUSTOMER_MERGE_HEADER_ID,
a.ORIG_SYS_DOCUMENT_REF,
a.ORIG_SYS_LINE_REF,
a.intmed_ship_to_org_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_line_acks a,
ra_customer_merges m
where m.process_flag = 'N'
and a.intmed_ship_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.set_number = set_num
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
UPDATE oe_line_acks a
set intmed_ship_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.intmed_ship_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where intmed_ship_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
PRIMARY_KEY2,
NUM_COL1_ORIG,
NUM_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_LINE_ACKS',
m.CUSTOMER_MERGE_HEADER_ID,
a.ORIG_SYS_DOCUMENT_REF,
a.ORIG_SYS_LINE_REF,
a.sold_to_org_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_line_acks a,
ra_customer_merges m
where m.process_flag = 'N'
and a.sold_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.set_number = set_num
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
/* customer level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE oe_line_acks a
set sold_to_org_id = (select distinct m.customer_id
from ra_customer_merges m
where a.sold_to_org_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where sold_to_org_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
--added for bug 3196900
and a.line_id in (select line_id from oe_order_lines);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
PRIMARY_KEY2,
NUM_COL6_ORIG,
NUM_COL6_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_LINE_ACKS',
m.CUSTOMER_MERGE_HEADER_ID,
a.ORIG_SYS_DOCUMENT_REF,
a.ORIG_SYS_LINE_REF,
a.end_customer_site_use_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_line_acks a,
ra_customer_merges m
where m.process_flag = 'N'
and a.sold_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.set_number = set_num
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
/* customer level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE oe_line_acks a
set end_customer_site_use_id = (select distinct m.customer_id
from ra_customer_merges m
where a.end_customer_site_use_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where end_customer_site_use_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
PRIMARY_KEY2,
NUM_COL7_ORIG,
NUM_COL7_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_LINE_ACKS',
m.CUSTOMER_MERGE_HEADER_ID,
a.ORIG_SYS_DOCUMENT_REF,
a.ORIG_SYS_LINE_REF,
a.end_customer_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_line_acks a,
ra_customer_merges m
where m.process_flag = 'N'
and a.end_customer_id = m.duplicate_site_id
and m.request_id = req_id
and m.set_number = set_num
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y';
/* customer level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE oe_line_acks a
set end_customer_id = (select distinct m.customer_id
from ra_customer_merges m
where a.end_customer_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where end_customer_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and NVL(ACKNOWLEDGMENT_FLAG,'N') <> 'Y'
--added for bug 3196900
and a.line_id in (select line_id from oe_order_lines);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
select RULE_ELEMENT_ID
from oe_attachment_rule_elements
where attribute_value in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'SHIP_TO_ORG_ID'
for update nowait;
select RULE_ELEMENT_ID
from oe_attachment_rule_elements
where attribute_value in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'INVOICE_TO_ORG_ID'
for update nowait;
select RULE_ELEMENT_ID
from oe_attachment_rule_elements
where attribute_value in (select to_char(m.duplicate_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'SOLD_TO_ORG_ID'
for update nowait;
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL3_ORIG,
VCHAR_COL3_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_ATTACHMENT_RULE_ELEMENTS',
m.customer_merge_header_id,
a.rule_element_id,
a.attribute_value,
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_ATTACHMENT_RULE_ELEMENTS a,
ra_customer_merges m
where a.attribute_value = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.attribute_code = 'SHIP_TO_ORG_ID';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_ATTACHMENT_RULE_ELEMENTS a
set (attribute_value) = (select distinct to_char(m.customer_site_id)
from ra_customer_merges m
where a.attribute_value =
to_char(m.duplicate_site_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where attribute_value in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'SHIP_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL2_ORIG,
VCHAR_COL2_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_ATTACHMENT_RULE_ELEMENTS',
m.customer_merge_header_id,
a.rule_element_id,
a.attribute_value,
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_ATTACHMENT_RULE_ELEMENTS a,
ra_customer_merges m
where a.attribute_value = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.attribute_code = 'INVOICE_TO_ORG_ID';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_ATTACHMENT_RULE_ELEMENTS a
set (attribute_value) = (select distinct to_char(m.customer_site_id)
from ra_customer_merges m
where a.attribute_value =
to_char(m.duplicate_site_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where attribute_value in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'INVOICE_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL1_ORIG,
VCHAR_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_ATTACHMENT_RULE_ELEMENTS',
m.customer_merge_header_id,
a.rule_element_id,
a.attribute_value,
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_ATTACHMENT_RULE_ELEMENTS a,
ra_customer_merges m
where a.attribute_value = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.attribute_code = 'SOLD_TO_ORG_ID';
/* customer level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_ATTACHMENT_RULE_ELEMENTS a
set (attribute_value) = (select distinct to_char(m.customer_id)
from ra_customer_merges m
where a.attribute_value =
to_char(m.duplicate_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where attribute_value in (select to_char(m.duplicate_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'SOLD_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
select CONDITION_ELEMENT_ID
from oe_def_condn_elems
where value_string in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'SHIP_TO_ORG_ID'
for update nowait;
select CONDITION_ELEMENT_ID
from oe_def_condn_elems
where value_string in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'INVOICE_TO_ORG_ID'
for update nowait;
select CONDITION_ELEMENT_ID
from oe_def_condn_elems
where value_string in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'INTMED_SHIP_TO_ORG_ID'
for update nowait;
select CONDITION_ELEMENT_ID
from oe_def_condn_elems
where value_string in (select to_char(m.duplicate_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'SOLD_TO_ORG_ID'
for update nowait;
select ATTR_DEF_RULE_ID
from oe_def_attr_def_rules
where src_constant_value in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'SHIP_TO_ORG_ID'
for update nowait;
select ATTR_DEF_RULE_ID
from oe_def_attr_def_rules
where src_constant_value in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'INVOICE_TO_ORG_ID'
for update nowait;
select ATTR_DEF_RULE_ID
from oe_def_attr_def_rules
where src_constant_value in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'INTMED_SHIP_TO_ORG_ID'
for update nowait;
select ATTR_DEF_RULE_ID
from oe_def_attr_def_rules
where src_constant_value in (select to_char(m.duplicate_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'SOLD_TO_ORG_ID'
for update nowait;
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL1_ORIG,
VCHAR_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_DEF_CONDN_ELEMS',
m.customer_merge_header_id,
a.condition_element_id,
a.value_string,
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_DEF_CONDN_ELEMS a,
ra_customer_merges m
where a.value_string = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.attribute_code = 'SHIP_TO_ORG_ID';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_DEF_CONDN_ELEMS a
set value_string = (select distinct to_char(m.customer_site_id)
from ra_customer_merges m
where a.value_string =
to_char(m.duplicate_site_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where value_string in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'SHIP_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL1_ORIG,
VCHAR_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_DEF_CONDN_ELEMS',
m.customer_merge_header_id,
a.condition_element_id,
a.value_string,
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_DEF_CONDN_ELEMS a,
ra_customer_merges m
where a.value_string = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.attribute_code = 'INVOICE_TO_ORG_ID';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_DEF_CONDN_ELEMS a
set value_string = (select distinct to_char(m.customer_site_id)
from ra_customer_merges m
where a.value_string =
to_char(m.duplicate_site_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where value_string in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'INVOICE_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL1_ORIG,
VCHAR_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_DEF_CONDN_ELEMS',
m.customer_merge_header_id,
a.condition_element_id,
a.value_string,
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_DEF_CONDN_ELEMS a,
ra_customer_merges m
where a.value_string = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.attribute_code = 'INTMED_SHIP_TO_ORG_ID';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_DEF_CONDN_ELEMS a
set value_string = (select distinct to_char(m.customer_site_id)
from ra_customer_merges m
where a.value_string =
to_char(m.duplicate_site_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where value_string in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'INTMED_SHIP_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL1_ORIG,
VCHAR_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_DEF_CONDN_ELEMS',
m.customer_merge_header_id,
a.condition_element_id,
a.value_string,
to_char(m.customer_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_DEF_CONDN_ELEMS a,
ra_customer_merges m
where a.value_string = to_char(m.duplicate_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.attribute_code = 'SOLD_TO_ORG_ID';
/* customer level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_DEF_CONDN_ELEMS a
set value_string = (select distinct to_char(m.customer_id)
from ra_customer_merges m
where a.value_string =
to_char(m.duplicate_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where value_string in (select to_char(m.duplicate_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'SOLD_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL2_ORIG,
VCHAR_COL2_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_DEF_ATTR_DEF_RULES',
m.customer_merge_header_id,
a.attr_def_rule_id,
a.src_constant_value,
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_DEF_ATTR_DEF_RULES a,
ra_customer_merges m
where a.src_constant_value = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.attribute_code = 'SHIP_TO_ORG_ID';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_DEF_ATTR_DEF_RULES a
set src_constant_value = (select distinct to_char(m.customer_site_id)
from ra_customer_merges m
where a.src_constant_value =
to_char(m.duplicate_site_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where src_constant_value in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'SHIP_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL2_ORIG,
VCHAR_COL2_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_DEF_ATTR_DEF_RULES',
m.customer_merge_header_id,
a.attr_def_rule_id,
a.src_constant_value,
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_DEF_ATTR_DEF_RULES a,
ra_customer_merges m
where a.src_constant_value = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.attribute_code = 'INVOICE_TO_ORG_ID';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_DEF_ATTR_DEF_RULES a
set src_constant_value = (select distinct to_char(m.customer_site_id)
from ra_customer_merges m
where a.src_constant_value =
to_char(m.duplicate_site_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where src_constant_value in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'INVOICE_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL2_ORIG,
VCHAR_COL2_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_DEF_ATTR_DEF_RULES',
m.customer_merge_header_id,
a.attr_def_rule_id,
a.src_constant_value,
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_DEF_ATTR_DEF_RULES a,
ra_customer_merges m
where a.src_constant_value = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.attribute_code = 'INTMED_SHIP_TO_ORG_ID';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_DEF_ATTR_DEF_RULES a
set src_constant_value = (select distinct to_char(m.customer_site_id)
from ra_customer_merges m
where a.src_constant_value =
to_char(m.duplicate_site_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where src_constant_value in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'INTMED_SHIP_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL2_ORIG,
VCHAR_COL2_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_DEF_ATTR_DEF_RULES',
m.customer_merge_header_id,
a.attr_def_rule_id,
a.src_constant_value,
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_DEF_ATTR_DEF_RULES a,
ra_customer_merges m
where a.src_constant_value = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.attribute_code = 'SOLD_TO_ORG_ID';
/* customer level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_DEF_ATTR_DEF_RULES a
set src_constant_value = (select distinct to_char(m.customer_id)
from ra_customer_merges m
where a.src_constant_value =
to_char(m.duplicate_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where src_constant_value in (select to_char(m.duplicate_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and attribute_code = 'SOLD_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
select VALIDATION_TMPLT_ID
from oe_pc_vtmplt_cols
where value_string in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and column_name = 'SHIP_TO_ORG_ID'
for update nowait;
select VALIDATION_TMPLT_ID
from oe_pc_vtmplt_cols
where value_string in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and column_name = 'INVOICE_TO_ORG_ID'
for update nowait;
select VALIDATION_TMPLT_ID
from oe_pc_vtmplt_cols
where value_string in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and column_name = 'INTMED_SHIP_TO_ORG_ID'
for update nowait;
select VALIDATION_TMPLT_ID
from oe_pc_vtmplt_cols
where value_string in (select to_char(m.duplicate_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and column_name = 'SOLD_TO_ORG_ID'
for update nowait;
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL1_ORIG,
VCHAR_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_PC_VTMPLT_COLS',
m.customer_merge_header_id,
a.validation_tmplt_id,
a.value_string,
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_PC_VTMPLT_COLS a,
ra_customer_merges m
where a.value_string = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.column_name = 'SHIP_TO_ORG_ID';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_PC_VTMPLT_COLS a
set value_string = (select distinct to_char(m.customer_site_id)
from ra_customer_merges m
where a.value_string =
to_char(m.duplicate_site_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where value_string in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and column_name = 'SHIP_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL1_ORIG,
VCHAR_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_PC_VTMPLT_COLS',
m.customer_merge_header_id,
a.validation_tmplt_id,
a.value_string,
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_PC_VTMPLT_COLS a,
ra_customer_merges m
where a.value_string = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.column_name = 'INVOICE_TO_ORG_ID';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_PC_VTMPLT_COLS a
set value_string = (select distinct to_char(m.customer_site_id)
from ra_customer_merges m
where a.value_string =
to_char(m.duplicate_site_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where value_string in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and column_name = 'INVOICE_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL1_ORIG,
VCHAR_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_PC_VTMPLT_COLS',
m.customer_merge_header_id,
a.validation_tmplt_id,
a.value_string,
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_PC_VTMPLT_COLS a,
ra_customer_merges m
where a.value_string = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.column_name = 'INTMED_SHIP_TO_ORG_ID';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_PC_VTMPLT_COLS a
set value_string = (select distinct to_char(m.customer_site_id)
from ra_customer_merges m
where a.value_string =
to_char(m.duplicate_site_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where value_string in (select to_char(m.duplicate_site_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and column_name = 'INTMED_SHIP_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL2_ORIG,
VCHAR_COL2_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_PC_VTMPLT_COLS',
m.customer_merge_header_id,
a.validation_tmplt_id,
a.value_string,
to_char(m.customer_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_PC_VTMPLT_COLS a,
ra_customer_merges m
where a.value_string = to_char(m.duplicate_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.column_name = 'SOLD_TO_ORG_ID';
/* customer level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_PC_VTMPLT_COLS a
set value_string = (select distinct to_char(m.customer_id)
from ra_customer_merges m
where a.value_string =
to_char(m.duplicate_id)
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where value_string in (select to_char(m.duplicate_id)
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and column_name = 'SOLD_TO_ORG_ID';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
select hold_source_id
from oe_hold_sources
where hold_entity_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and hold_entity_code = 'S'
for update nowait;
select hold_source_id
from oe_hold_sources
where hold_entity_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and hold_entity_code = 'B'
for update nowait;
select hold_source_id
from oe_hold_sources
where hold_entity_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and hold_entity_code = 'C'
for update nowait;
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL1_ORIG,
VCHAR_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_HOLD_SOURCES',
m.customer_merge_header_id,
a.hold_source_id,
to_char(a.hold_entity_id),
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_HOLD_SOURCES a,
ra_customer_merges m
where a.hold_entity_id = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.hold_entity_code = 'S';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_HOLD_SOURCES a
set (hold_entity_id) = (select distinct m.customer_site_id
from ra_customer_merges m
where a.hold_entity_id =
m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where hold_entity_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and hold_entity_code = 'S';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL1_ORIG,
VCHAR_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_HOLD_SOURCES',
m.customer_merge_header_id,
a.hold_source_id,
to_char(a.hold_entity_id),
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_HOLD_SOURCES a,
ra_customer_merges m
where a.hold_entity_id = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.hold_entity_code = 'B';
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_HOLD_SOURCES a
set (hold_entity_id) = (select distinct m.customer_site_id
from ra_customer_merges m
where a.hold_entity_id =
m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where hold_entity_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and hold_entity_code = 'B';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL1_ORIG,
VCHAR_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_HOLD_SOURCES',
m.customer_merge_header_id,
a.hold_source_id,
to_char(a.hold_entity_id),
to_char(m.customer_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_HOLD_SOURCES a,
ra_customer_merges m
where a.hold_entity_id = to_char(m.duplicate_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
and a.hold_entity_code = 'S';
/* customer level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_HOLD_SOURCES a
set hold_entity_id = (select distinct m.customer_id
from ra_customer_merges m
where a.hold_entity_id =
m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where hold_entity_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
and hold_entity_code = 'C';
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
select DROP_SHIP_SOURCE_ID
from oe_drop_ship_sources
where LINE_LOCATION_ID in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL1_ORIG,
VCHAR_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_DROP_SHIP_SOURCES',
m.customer_merge_header_id,
a.drop_ship_source_id,
to_char(a.line_location_id),
to_char(m.customer_site_id),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_DROP_SHIP_SOURCES a,
ra_customer_merges m
where a.line_location_id = to_char(m.duplicate_site_id)
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_DROP_SHIP_SOURCES a
set line_location_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.line_location_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where line_location_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
select CUST_ITEM_SETTING_ID
from oe_cust_item_settings
where site_use_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
select CUST_ITEM_SETTING_ID
from oe_cust_item_settings
where customer_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
NUM_COL1_ORIG,
NUM_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_CUST_ITEM_SETTINGS',
m.customer_merge_header_id,
a.cust_item_setting_id,
a.site_use_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_CUST_ITEM_SETTINGS a,
ra_customer_merges m
where a.site_use_id = m.duplicate_site_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
/* site level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_CUST_ITEM_SETTINGS a
set site_use_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.site_use_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where site_use_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
NUM_COL2_ORIG,
NUM_COL2_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_CUST_ITEM_SETTINGS',
m.customer_merge_header_id,
a.cust_item_setting_id,
a.customer_id,
m.customer_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from OE_CUST_ITEM_SETTINGS a,
ra_customer_merges m
where a.customer_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
/* customer level update */
arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
UPDATE OE_CUST_ITEM_SETTINGS a
set customer_id = (select distinct m.customer_id
from ra_customer_merges m
where a.customer_id = m.duplicate_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
where customer_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
SELECT /*+ FULL(M)
FULL(S)
PARALLEL(S,30)
PARALLEL(M,30)
USE_HASH(M,S) */
s.set_id , s.ship_to_org_id , m.customer_merge_id
FROM RA_CUSTOMER_MERGES M, OE_SETS S
WHERE
s.ship_to_org_id = m.duplicate_site_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
for update nowait;
SELECT /*+ FULL(M)
FULL(S)
PARALLEL(S,30)
PARALLEL(M,30)
USE_HASH(M,S) */
s.set_id , s.ship_to_org_id ,m.customer_merge_id
FROM RA_CUSTOMER_MERGES M, OE_SETS S
WHERE
s.ship_to_org_id = m.duplicate_site_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
NUM_COL1_ORIG,
NUM_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
) VALUES (
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_SETS',
MERGE_HEADER_ID_LIST(I),
sets_set_id_tab(I),
sets_ship_to_org_id_tab(I),
sets_ship_to_org_id_tab(I),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
);
UPDATE OE_SETS S
SET ship_to_org_id = sets_ship_to_org_id_tab(i),
update_date = sysdate,
updated_by = arp_standard.profile.user_id,
update_login = arp_standard.profile.last_update_login
WHERE set_id = sets_set_id_tab(i);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
sets_set_id_tab.DELETE;
sets_ship_to_org_id_tab.DELETE;
MERGE_HEADER_ID_LIST.DELETE;
SELECT /*+ USE_NL (M A)
INDEX (A,OE_PRICE_ADJ_ATTRIBS_N2) */
a.price_adj_attrib_id ,
decode(a.pricing_attribute, 'QUALIFIER_ATTRIBUTE2',
m.customer_id, m.customer_site_id) attrib_value_from, a.pricing_attr_value_from,
m.customer_merge_id
--changed for bug 3196900
-- FROM RA_CUSTOMER_MERGES M, OE_PRICE_ADJ_ATTRIBS A
FROM RA_CUSTOMER_MERGES M, OE_PRICE_ADJ_ATTRIBS A,OE_PRICE_ADJUSTMENTS P,OE_ORDER_HEADERS H
WHERE
a.pricing_context = 'CUSTOMER'
and ((a.pricing_attribute in ('QUALIFIER_ATTRIBUTE11',
'QUALIFIER_ATTRIBUTE5',
'QUALIFIER_ATTRIBUTE14')
and a.pricing_attr_value_from = to_char(m.duplicate_site_id))
OR (a.pricing_attribute = 'QUALIFIER_ATTRIBUTE2'
and a.pricing_attr_value_from = to_char(m.duplicate_id)))
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
--added for bug 3196900
and a.price_adjustment_id=p.price_adjustment_id
and p.header_id=h.header_id
for update nowait;
SELECT /*+ USE_NL (M A)
INDEX (A,OE_PRICE_ADJ_ATTRIBS_N2) */
a.price_adj_attrib_id ,
decode(a.pricing_attribute, 'QUALIFIER_ATTRIBUTE2',
m.customer_id, m.customer_site_id) attrib_value_from, a.pricing_attr_value_from,
m.customer_merge_id
--changed for bug 3196900
-- FROM RA_CUSTOMER_MERGES M, OE_PRICE_ADJ_ATTRIBS A
FROM RA_CUSTOMER_MERGES M, OE_PRICE_ADJ_ATTRIBS A , OE_PRICE_ADJUSTMENTS P,
OE_ORDER_HEADERS H
WHERE
a.pricing_context = 'CUSTOMER'
and ((a.pricing_attribute in ('QUALIFIER_ATTRIBUTE11',
'QUALIFIER_ATTRIBUTE5',
'QUALIFIER_ATTRIBUTE14')
and a.pricing_attr_value_from = to_char(m.duplicate_site_id))
OR (a.pricing_attribute = 'QUALIFIER_ATTRIBUTE2'
and a.pricing_attr_value_from = to_char(m.duplicate_id)))
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num
--added for bug 3196900
and a.price_adjustment_id=p.price_adjustment_id
and p.header_id=h.header_id;
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
VCHAR_COL1_ORIG,
VCHAR_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
) VALUES (
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_PRICE_ADJ_ATTRIBS',
MERGE_HEADER_ID_LIST(I),
attrib_id_tab(I),
pricing_attr_value_from_tab(I),
to_char(attrib_value_from_tab(I)),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
);
UPDATE OE_PRICE_ADJ_ATTRIBS S
SET pricing_attr_value_from = to_char(attrib_value_from_tab(i)),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login
WHERE price_adj_attrib_id = attrib_id_tab(i);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
attrib_id_tab.DELETE;
attrib_value_from_tab.DELETE;
pricing_attr_value_from_tab.DELETE;
merge_header_id_list.DELETE;
select duplicate_id, customer_id, duplicate_site_id, customer_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
SELECT /*+ PARALLEL(H)
PARALLEL(M1)
PARALLEL(M2)
PARALLEL(M3)
PARALLEL(M4)
PARALLEL(M5) */
h.header_id ,
h.sold_to_org_id,
h.invoice_to_org_id,
h.ship_to_org_id,
h.deliver_to_org_id,
h.sold_to_site_use_id,
nvl(m1.customer_merge_id,nvl(m2.customer_merge_id,nvl(m3.customer_merge_id,nvl(m4.customer_merge_id,m5.customer_merge_id))))
FROM RA_CUSTOMER_MERGES M1,
RA_CUSTOMER_MERGES M2,
RA_CUSTOMER_MERGES M3,
RA_CUSTOMER_MERGES M4,
RA_CUSTOMER_MERGES M5,
-- changed for bug 3196900
-- OE_BLANKET_HEADERS_ALL H
OE_BLANKET_HEADERS H
WHERE
( h.sold_to_org_id = m1.duplicate_id(+)
and h.invoice_to_org_id = m2.duplicate_site_id(+)
and h.ship_to_org_id = m3.duplicate_site_id(+)
and h.deliver_to_org_id = m4.duplicate_site_id(+)
and h.sold_to_site_use_id = m5.duplicate_site_id(+) )
and
(m1.duplicate_site_id is not null or
m2.duplicate_id is not null or
m3.duplicate_id is not null or
m4.duplicate_id is not null or
m5.duplicate_id is not null )
and m1.process_flag(+) = 'N'
and m2.process_flag(+) = 'N'
and m3.process_flag(+) = 'N'
and m4.process_flag(+) = 'N'
and m5.process_flag(+) = 'N'
and m1.request_id(+) =req_id
and m2.request_id(+) =req_id
and m3.request_id(+) =req_id
and m4.request_id(+) =req_id
and m5.request_id(+) =req_id
and m1.set_number(+) =set_num
and m2.set_number(+) =set_num
and m3.set_number(+) =set_num
and m4.set_number(+) =set_num
and m5.set_number(+) =set_num
for update nowait;
SELECT /*+ PARALLEL(H)
PARALLEL(M1)
PARALLEL(M2)
PARALLEL(M3)
PARALLEL(M4)
PARALLEL(M5) */
h.header_id ,
h.sold_to_org_id,
h.invoice_to_org_id,
h.ship_to_org_id,
h.deliver_to_org_id,
h.sold_to_site_use_id,
nvl(m1.customer_merge_id,nvl(m2.customer_merge_id,nvl(m3.customer_merge_id,nvl(m4.customer_merge_id,m5.customer_merge_id))))
FROM RA_CUSTOMER_MERGES M1,
RA_CUSTOMER_MERGES M2,
RA_CUSTOMER_MERGES M3,
RA_CUSTOMER_MERGES M4,
RA_CUSTOMER_MERGES M5,
-- changed for bug 3196900
-- OE_BLANKET_HEADERS_ALL H
OE_BLANKET_HEADERS H
WHERE
( h.sold_to_org_id = m1.duplicate_id(+)
and h.invoice_to_org_id = m2.duplicate_site_id(+)
and h.ship_to_org_id = m3.duplicate_site_id(+)
and h.deliver_to_org_id = m4.duplicate_site_id(+)
and h.sold_to_site_use_id = m5.duplicate_site_id(+) )
and
(m1.duplicate_site_id is not null or
m2.duplicate_id is not null or
m3.duplicate_id is not null or
m4.duplicate_id is not null or
m5.duplicate_id is not null )
and m1.process_flag(+) = 'N'
and m2.process_flag(+) = 'N'
and m3.process_flag(+) = 'N'
and m4.process_flag(+) = 'N'
and m5.process_flag(+) = 'N'
and m1.request_id(+) =req_id
and m2.request_id(+) =req_id
and m3.request_id(+) =req_id
and m4.request_id(+) =req_id
and m5.request_id(+) =req_id
and m1.set_number(+) =set_num
and m2.set_number(+) =set_num
and m3.set_number(+) =set_num
and m4.set_number(+) =set_num
and m5.set_number(+) =set_num;
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
NUM_COL1_ORIG,
NUM_COL1_NEW,
NUM_COL2_ORIG,
NUM_COL2_NEW,
NUM_COL3_ORIG,
NUM_COL3_NEW,
NUM_COL4_ORIG,
NUM_COL4_NEW,
NUM_COL5_ORIG,
NUM_COL5_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
) VALUES (
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_BLANKET_HEADERS_ALL',
MERGE_HEADER_ID_LIST(I),
hdr_header_id_tab(I),
old_hdr_sold_to_org_id_tab(I),
decode(hdr_sold_to_org_id_tab(I),NULL,old_hdr_sold_to_org_id_tab(I),hdr_sold_to_org_id_tab(i)),
old_hdr_invoice_to_org_id_tab(I),
decode(hdr_invoice_to_org_id_tab(I),NULL,old_hdr_invoice_to_org_id_tab(I),hdr_invoice_to_org_id_tab(i)),
old_hdr_ship_to_org_id_tab(I),
decode(hdr_ship_to_org_id_tab(I),NULL,old_hdr_ship_to_org_id_tab(I),hdr_ship_to_org_id_tab(i)),
old_hdr_deliver_to_org_id_tab(I),
decode(hdr_deliver_to_org_id_tab(I),NULL,old_hdr_deliver_to_org_id_tab(I),hdr_deliver_to_org_id_tab(i)),
old_hdr_sold_to_site_id_tab(I),
decode(hdr_sold_to_site_use_id_tab(I),NULL,old_hdr_sold_to_site_id_tab(I),hdr_sold_to_site_use_id_tab(i)),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
);
UPDATE OE_BLANKET_HEADERS_ALL H
SET sold_to_org_id = decode(hdr_sold_to_org_id_tab(i),null,sold_to_org_id,hdr_sold_to_org_id_tab(i)),
invoice_to_org_id = decode(hdr_invoice_to_org_id_tab(i),null,invoice_to_org_id,hdr_invoice_to_org_id_tab(i)),
ship_to_org_id = decode(hdr_ship_to_org_id_tab(i),null,ship_to_org_id,hdr_ship_to_org_id_tab(i)),
deliver_to_org_id = decode(hdr_deliver_to_org_id_tab(i),null,deliver_to_org_id,hdr_deliver_to_org_id_tab(i)),
sold_to_site_use_id = decode(hdr_sold_to_site_use_id_tab(i),null,sold_to_site_use_id,hdr_sold_to_site_use_id_tab(i)),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id = arp_standard.profile.program_application_id ,
program_id = arp_standard.profile.program_id,
program_update_date = SYSDATE,
lock_control = lock_control+1
WHERE header_id = hdr_header_id_tab(i);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
hdr_header_id_tab.DELETE;
hdr_sold_to_org_id_tab.DELETE;
hdr_invoice_to_org_id_tab.DELETE;
hdr_ship_to_org_id_tab.DELETE;
hdr_deliver_to_org_id_tab.DELETE;
hdr_sold_to_site_use_id_tab.DELETE;
old_hdr_sold_to_org_id_tab.DELETE;
old_hdr_invoice_to_org_id_tab.DELETE;
old_hdr_ship_to_org_id_tab.DELETE;
old_hdr_deliver_to_org_id_tab.DELETE;
old_hdr_sold_to_site_id_tab.DELETE;
customer_id_tab.DELETE;
customer_site_id_tab.DELETE;
select hist.HEADER_ID
from oe_blanket_headers_hist hist,oe_blanket_headers h
where hist.ship_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
--added for bug 3196900
and hist.header_id=h.header_id
for update nowait;
select hist.HEADER_ID
from oe_blanket_headers_hist hist,oe_blanket_headers h
where hist.invoice_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
--changed for bug 3196900
and hist.header_id=h.header_id
for update nowait;
select hist.HEADER_ID
from oe_blanket_headers_hist hist, oe_blanket_headers h
where hist.deliver_to_org_id in
(select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
--added for bug 3196900
and hist.header_id=h.header_id
for update nowait;
select hist.HEADER_ID
from oe_blanket_headers_hist hist, oe_blanket_headers h
where hist.sold_to_org_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
--added for bug 3196900
and hist.header_id=h.header_id
for update nowait;
select hist.HEADER_ID
from oe_blanket_headers_hist hist,oe_blanket_headers h
where hist.sold_to_site_use_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
--added for bug 3196900
and hist.header_id=h.header_id
for update nowait;
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
PRIMARY_KEY_ID2,
NUM_COL3_ORIG,
NUM_COL3_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_BLANKET_HEADERS_HIST',
m.customer_merge_header_id,
h.header_id,
h.version_number,
h.ship_to_org_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_blanket_headers_hist h,
ra_customer_merges m
where h.ship_to_org_id=m.duplicate_site_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
UPDATE oe_blanket_headers_hist a
set ship_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.ship_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where ship_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
PRIMARY_KEY_ID2,
NUM_COL2_ORIG,
NUM_COL2_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_BLANKET_HEADERS_HIST',
m.CUSTOMER_MERGE_HEADER_ID,
h.version_number,
h.header_id,
h.invoice_to_org_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_blanket_headers_hist h,
ra_customer_merges m
where h.invoice_to_org_id=m.duplicate_site_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
UPDATE oe_blanket_headers_hist a
set invoice_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.invoice_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where invoice_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
PRIMARY_KEY_ID2,
NUM_COL4_ORIG,
NUM_COL4_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_BLANKET_HEADERS_HIST',
m.CUSTOMER_MERGE_HEADER_ID,
h.header_id,
h.version_number,
h.deliver_to_org_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_blanket_headers_hist h,
ra_customer_merges m
where h.deliver_to_org_id=m.duplicate_site_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
UPDATE oe_blanket_headers_hist a
set deliver_to_org_id = (select distinct m.customer_site_id
from ra_customer_merges m
where a.deliver_to_org_id = m.duplicate_site_id
and m.request_id = req_id
and m.process_flag = 'N'
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where deliver_to_org_id in (select m.duplicate_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
PRIMARY_KEY_ID2,
NUM_COL1_ORIG,
NUM_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_BLANKET_HEADERS_HIST',
m.customer_merge_header_id,
h.header_id,
h.version_number,
h.sold_to_org_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_blanket_headers_hist h,
ra_customer_merges m
where h.sold_to_org_id=m.duplicate_site_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
UPDATE oe_blanket_headers_hist a
set sold_to_org_id = (select distinct m.customer_id
from ra_customer_merges m
where a.sold_to_org_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where sold_to_org_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
PRIMARY_KEY_ID2,
NUM_COL5_ORIG,
NUM_COL5_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
)
select
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_BLANKET_HEADERS_HIST',
m.customer_merge_header_id,
h.header_id,
h.version_number,
h.sold_to_site_use_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_blanket_headers_hist h,
ra_customer_merges m
where h.sold_to_org_id=m.duplicate_site_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
UPDATE oe_blanket_headers_hist a
set sold_to_site_use_id = (select distinct m.customer_id
from ra_customer_merges m
where a.sold_to_site_use_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where sold_to_site_use_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
select duplicate_id, customer_id, duplicate_site_id, customer_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
SELECT /*+ PARALLEL(L)
PARALLEL(M1)
PARALLEL(M2)
PARALLEL(M3)
PARALLEL(M4)
PARALLEL(M5) */
l.line_id ,
sold_to_org_id,
invoice_to_org_id,
ship_to_org_id,
intmed_ship_to_org_id,
deliver_to_org_id,
nvl(m1.customer_merge_id,nvl(m2.customer_merge_id,nvl(m3.customer_merge_id,nvl(m4.customer_merge_id,m5.customer_merge_id))))
FROM RA_CUSTOMER_MERGES M1,
RA_CUSTOMER_MERGES M2,
RA_CUSTOMER_MERGES M3,
RA_CUSTOMER_MERGES M4,
RA_CUSTOMER_MERGES M5,
-- changed for bug 3196900
-- OE_BLANKET_LINES_ALL L
OE_BLANKET_LINES L
WHERE
( l.sold_to_org_id = m1.duplicate_id(+)
and l.invoice_to_org_id = m2.duplicate_site_id(+)
and l.ship_to_org_id = m3.duplicate_site_id(+)
and l.intmed_ship_to_org_id = m4.duplicate_site_id(+)
and l.deliver_to_org_id = m5.duplicate_site_id(+) )
and
(m1.duplicate_site_id is not null or
m2.duplicate_id is not null or
m3.duplicate_id is not null or
m4.duplicate_id is not null or
m5.duplicate_id is not null )
and m1.process_flag(+) = 'N'
and m2.process_flag(+) = 'N'
and m3.process_flag(+) = 'N'
and m4.process_flag(+) = 'N'
and m5.process_flag(+) = 'N'
and m1.request_id(+) =req_id
and m2.request_id(+) =req_id
and m3.request_id(+) =req_id
and m4.request_id(+) =req_id
and m5.request_id(+) =req_id
and m1.set_number(+) =set_num
and m2.set_number(+) =set_num
and m3.set_number(+) =set_num
and m4.set_number(+) =set_num
and m5.set_number(+) =set_num
for update nowait;
SELECT /*+ PARALLEL(L)
PARALLEL(M1)
PARALLEL(M2)
PARALLEL(M3)
PARALLEL(M4)
PARALLEL(M5) */
l.line_id ,
sold_to_org_id,
invoice_to_org_id,
ship_to_org_id,
intmed_ship_to_org_id,
deliver_to_org_id,
nvl(m1.customer_merge_id,nvl(m2.customer_merge_id,nvl(m3.customer_merge_id,nvl(m4.customer_merge_id,m5.customer_merge_id))))
FROM RA_CUSTOMER_MERGES M1,
RA_CUSTOMER_MERGES M2,
RA_CUSTOMER_MERGES M3,
RA_CUSTOMER_MERGES M4,
RA_CUSTOMER_MERGES M5,
--changed for bug 3196900
-- OE_BLANKET_LINES_ALL L
OE_BLANKET_LINES L
WHERE
( l.sold_to_org_id = m1.duplicate_id(+)
and l.invoice_to_org_id = m2.duplicate_site_id(+)
and l.ship_to_org_id = m3.duplicate_site_id(+)
and l.intmed_ship_to_org_id = m4.duplicate_site_id(+)
and l.deliver_to_org_id = m5.duplicate_site_id(+) )
and
(m1.duplicate_site_id is not null or
m2.duplicate_id is not null or
m3.duplicate_id is not null or
m4.duplicate_id is not null or
m5.duplicate_id is not null )
and m1.process_flag(+) = 'N'
and m2.process_flag(+) = 'N'
and m3.process_flag(+) = 'N'
and m4.process_flag(+) = 'N'
and m5.process_flag(+) = 'N'
and m1.request_id(+) =req_id
and m2.request_id(+) =req_id
and m3.request_id(+) =req_id
and m4.request_id(+) =req_id
and m5.request_id(+) =req_id
and m1.set_number(+) =set_num
and m2.set_number(+) =set_num
and m3.set_number(+) =set_num
and m4.set_number(+) =set_num
and m5.set_number(+) =set_num;
--insert audit information for customer merge
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
NUM_COL1_ORIG,
NUM_COL1_NEW,
NUM_COL2_ORIG,
NUM_COL2_NEW,
NUM_COL3_ORIG,
NUM_COL3_NEW,
NUM_COL4_ORIG,
NUM_COL4_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
) VALUES (
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_BLANKET_LINES_ALL',
MERGE_HEADER_ID_LIST(I),
line_line_id_tab(I),
line_sold_to_org_id_tab(I),
decode(line_sold_to_org_id_tab(I),NULL,old_line_sold_to_org_id_tab(I),line_sold_to_org_id_tab(i)),
line_invoice_to_org_id_tab(I),
decode(line_invoice_to_org_id_tab(I),NULL,old_line_invoice_to_org_id_tab(I),line_invoice_to_org_id_tab(i)),
line_ship_to_org_id_tab(I),
decode(line_ship_to_org_id_tab(I),NULL,old_line_ship_to_org_id_tab(I),line_ship_to_org_id_tab(i)),
line_deliver_to_org_id_tab(I),
decode(line_deliver_to_org_id_tab(I),NULL,old_line_deliver_to_org_id_tab(I),line_deliver_to_org_id_tab(i)),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
);
UPDATE OE_BLANKET_LINES_ALL L
SET sold_to_org_id = decode(line_sold_to_org_id_tab(i),null,sold_to_org_id,line_sold_to_org_id_tab(i)),
invoice_to_org_id = decode(line_invoice_to_org_id_tab(i),null,invoice_to_org_id,line_invoice_to_org_id_tab(i)),
ship_to_org_id = decode(line_ship_to_org_id_tab(i),null,ship_to_org_id,line_ship_to_org_id_tab(i)),
intmed_ship_to_org_id = decode(line_intmed_ship_to_org_id_tab(i),null,intmed_ship_to_org_id,line_intmed_ship_to_org_id_tab(i)),
deliver_to_org_id = decode(line_deliver_to_org_id_tab(i),null,deliver_to_org_id,line_deliver_to_org_id_tab(i)),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id = arp_standard.profile.program_application_id ,
program_id = arp_standard.profile.program_id,
program_update_date = SYSDATE,
lock_control = lock_control+1
WHERE line_id = line_line_id_tab(i);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
line_line_id_tab.DELETE;
line_sold_to_org_id_tab.DELETE;
line_invoice_to_org_id_tab.DELETE;
line_ship_to_org_id_tab.DELETE;
line_intmed_ship_to_org_id_tab.DELETE;
line_deliver_to_org_id_tab.DELETE;
old_line_sold_to_org_id_tab.DELETE;
old_line_invoice_to_org_id_tab.DELETE;
old_line_ship_to_org_id_tab.DELETE;
old_intmed_ship_to_org_id_tab.DELETE;
old_line_deliver_to_org_id_tab.DELETE;
customer_id_tab.DELETE;
customer_site_id_tab.DELETE;
select duplicate_id, customer_id, duplicate_site_id, customer_site_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
SELECT /*+ PARALLEL(L)
PARALLEL(M1)
PARALLEL(M2)
PARALLEL(M3)
PARALLEL(M4)
PARALLEL(M5) */
l.line_id ,
--changed for bug 3196900 , added l. for all the attributes
l.sold_to_org_id,
l.invoice_to_org_id,
l.ship_to_org_id,
l.intmed_ship_to_org_id,
l.deliver_to_org_id,
l.version_number,
nvl(m1.customer_merge_id,nvl(m2.customer_merge_id,nvl(m3.customer_merge_id,nvl(m4.customer_merge_id,m5.customer_merge_id))))
FROM RA_CUSTOMER_MERGES M1,
RA_CUSTOMER_MERGES M2,
RA_CUSTOMER_MERGES M3,
RA_CUSTOMER_MERGES M4,
RA_CUSTOMER_MERGES M5,
--changed for bug 3196900
-- OE_BLANKET_LINES_HIST L
OE_BLANKET_LINES_HIST L , OE_BLANKET_LINES_ALL LN
-- Changed for MOAC
WHERE
( l.sold_to_org_id = m1.duplicate_id(+)
and l.invoice_to_org_id = m2.duplicate_site_id(+)
and l.ship_to_org_id = m3.duplicate_site_id(+)
and l.intmed_ship_to_org_id = m4.duplicate_site_id(+)
and l.deliver_to_org_id = m5.duplicate_site_id(+) )
and
(m1.duplicate_site_id is not null or
m2.duplicate_id is not null or
m3.duplicate_id is not null or
m4.duplicate_id is not null or
m5.duplicate_id is not null )
and m1.process_flag(+) = 'N'
and m2.process_flag(+) = 'N'
and m3.process_flag(+) = 'N'
and m4.process_flag(+) = 'N'
and m5.process_flag(+) = 'N'
and m1.request_id(+) =req_id
and m2.request_id(+) =req_id
and m3.request_id(+) =req_id
and m4.request_id(+) =req_id
and m5.request_id(+) =req_id
and m1.set_number(+) =set_num
and m2.set_number(+) =set_num
and m3.set_number(+) =set_num
and m4.set_number(+) =set_num
and m5.set_number(+) =set_num
--added for bug 3196900
and l.line_id=ln.line_id
for update nowait;
SELECT /*+ PARALLEL(L)
PARALLEL(M1)
PARALLEL(M2)
PARALLEL(M3)
PARALLEL(M4)
PARALLEL(M5) */
l.line_id ,
--changed for bug 3196900, added l. for all the attributes
l.sold_to_org_id,
l.invoice_to_org_id,
l.ship_to_org_id,
l.intmed_ship_to_org_id,
l.deliver_to_org_id,
l.version_number,
nvl(m1.customer_merge_id,nvl(m2.customer_merge_id,nvl(m3.customer_merge_id,nvl(m4.customer_merge_id,m5.customer_merge_id))))
FROM RA_CUSTOMER_MERGES M1,
RA_CUSTOMER_MERGES M2,
RA_CUSTOMER_MERGES M3,
RA_CUSTOMER_MERGES M4,
RA_CUSTOMER_MERGES M5,
--changed for bug 3196900
-- OE_BLANKET_LINES_HIST L
OE_BLANKET_LINES_HIST L , OE_BLANKET_LINES_all LN
-- Changed for MOAC
WHERE
( l.sold_to_org_id = m1.duplicate_id(+)
and l.invoice_to_org_id = m2.duplicate_site_id(+)
and l.ship_to_org_id = m3.duplicate_site_id(+)
and l.intmed_ship_to_org_id = m4.duplicate_site_id(+)
and l.deliver_to_org_id = m5.duplicate_site_id(+) )
and
(m1.duplicate_site_id is not null or
m2.duplicate_id is not null or
m3.duplicate_id is not null or
m4.duplicate_id is not null or
m5.duplicate_id is not null )
and m1.process_flag(+) = 'N'
and m2.process_flag(+) = 'N'
and m3.process_flag(+) = 'N'
and m4.process_flag(+) = 'N'
and m5.process_flag(+) = 'N'
and m1.request_id(+) =req_id
and m2.request_id(+) =req_id
and m3.request_id(+) =req_id
and m4.request_id(+) =req_id
and m5.request_id(+) =req_id
and m1.set_number(+) =set_num
and m2.set_number(+) =set_num
and m3.set_number(+) =set_num
and m4.set_number(+) =set_num
and m5.set_number(+) =set_num
--added for bug 3196900
and l.line_id=ln.line_id;
INSERT INTO HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID1,
PRIMARY_KEY_ID2,
NUM_COL1_ORIG,
NUM_COL1_NEW,
NUM_COL2_ORIG,
NUM_COL2_NEW,
NUM_COL3_ORIG,
NUM_COL3_NEW,
NUM_COL4_ORIG,
NUM_COL4_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
) VALUES (
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_BLANKET_LINES_HIST',
MERGE_HEADER_ID_LIST(I),
lhst_line_id_tab(I),
lhst_version_number_tab(I),
lhst_sold_to_org_id_tab(I),
decode(lhst_sold_to_org_id_tab(I),NULL,old_lhst_sold_to_org_id_tab(I),lhst_sold_to_org_id_tab(i)),
lhst_invoice_to_org_id_tab(I),
decode(lhst_invoice_to_org_id_tab(I),NULL,old_lhst_invoice_to_org_id_tab(I),lhst_invoice_to_org_id_tab(i)),
lhst_ship_to_org_id_tab(I),
decode(lhst_ship_to_org_id_tab(I),NULL,old_lhst_ship_to_org_id_tab(I),lhst_ship_to_org_id_tab(i)),
lhst_deliver_to_org_id_tab(I),
decode(lhst_deliver_to_org_id_tab(I),NULL,old_lhst_deliver_to_org_id_tab(I),lhst_deliver_to_org_id_tab(i)),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
);
UPDATE OE_BLANKET_LINES_HIST LHIST
SET sold_to_org_id = decode(lhst_sold_to_org_id_tab(i),null,sold_to_org_id,lhst_sold_to_org_id_tab(i)),
invoice_to_org_id = decode(lhst_invoice_to_org_id_tab(i),null,invoice_to_org_id,lhst_invoice_to_org_id_tab(i)),
ship_to_org_id = decode(lhst_ship_to_org_id_tab(i),null,ship_to_org_id,lhst_ship_to_org_id_tab(i)),
intmed_ship_to_org_id = decode(lhst_intmed_ship_to_org_id_tab(i),null,intmed_ship_to_org_id,lhst_intmed_ship_to_org_id_tab(i)),
deliver_to_org_id = decode(lhst_deliver_to_org_id_tab(i),null,deliver_to_org_id,lhst_deliver_to_org_id_tab(i)),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id = arp_standard.profile.program_application_id ,
program_id = arp_standard.profile.program_id,
program_update_date = SYSDATE
WHERE line_id = lhst_line_id_tab(i);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
lhst_line_id_tab.DELETE;
lhst_sold_to_org_id_tab.DELETE;
lhst_invoice_to_org_id_tab.DELETE;
lhst_ship_to_org_id_tab.DELETE;
lhst_intmed_ship_to_org_id_tab.DELETE;
lhst_deliver_to_org_id_tab.DELETE;
lhst_version_number_tab.DELETE;
old_lhst_sold_to_org_id_tab.DELETE;
old_lhst_invoice_to_org_id_tab.DELETE;
old_lhst_ship_to_org_id_tab.DELETE;
old_intmed_ship_to_org_id_tab.DELETE;
old_lhst_deliver_to_org_id_tab.DELETE;
customer_id_tab.DELETE;
customer_site_id_tab.DELETE;
select header_id
--changed for bug 3196900
-- from OE_EM_INFORMATION_ALL
from OE_EM_INFORMATION
where sold_to_org_id in
(select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
for update nowait;
insert into HZ_CUSTOMER_MERGE_LOG (
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY1,
NUM_COL1_ORIG,
NUM_COL1_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY)
SELECT
HZ_CUSTOMER_MERGE_LOG_s.nextval,
'OE_EM_INFORMATION_ALL',
m.CUSTOMER_MERGE_HEADER_ID,
h.ORIG_SYS_DOCUMENT_REF,
h.sold_to_org_id,
m.customer_site_id,
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
from oe_em_information_All h,
ra_customer_merges m
where h.sold_to_org_id=m.duplicate_site_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num;
UPDATE OE_EM_INFORMATION_ALL a
set sold_to_org_id = (select distinct m.customer_id
from ra_customer_merges m
where a.sold_to_org_id = m.duplicate_id
and m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num),
last_update_date = sysdate,
last_updated_by = arp_standard.profile.user_id,
last_update_login = arp_standard.profile.last_update_login,
request_id = req_id,
program_application_id =arp_standard.profile.program_application_id,
program_id = arp_standard.profile.program_id,
program_update_date = sysdate
where sold_to_org_id in (select m.duplicate_id
from ra_customer_merges m
where m.process_flag = 'N'
and m.request_id = req_id
and m.set_number = set_num)
--added for bug3196900
and (a.document_id,a.em_transaction_type_code) in
(select document_id,em_transaction_type_code from oe_em_information);
arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
oe_update_dbi_log();
PROCEDURE Oe_Update_DBI_log IS
CURSOR c_get_lines(p_header_id number) IS
SELECT l.line_id
FROM oe_order_lines_all l
WHERE l.header_id = p_header_id;
SELECT SYS.SET_OF_BOOKS_ID
FROM AR_SYSTEM_PARAMETERS SYS;
l_update_date date;
arp_message.set_line(' inside update_dbi count hder_id_tab='||dbi_header_header_id_tab.COUNT);
INSERT INTO ONT_DBI_CHANGE_LOG
(HEADER_ID
,LINE_ID
,SET_OF_BOOKS_ID
,CURRENCY_CODE
,LAST_UPDATE_DATE
)
SELECT
dbi_header_header_id_tab(i)
,l.line_id
,l_set_of_books_id
,'XXX'
,dbi_header_update_date_tab(i)
FROM OE_ORDER_LINES_ALL l, oe_order_headers_all h
WHERE l.header_id = dbi_header_header_id_tab(i)
AND h.header_id = l.header_id
AND h.booked_flag = 'Y';
arp_message.set_line(' Hdr insert count='||sql%rowcount);
INSERT INTO ONT_DBI_CHANGE_LOG
(HEADER_ID
,LINE_ID
,SET_OF_BOOKS_ID
,CURRENCY_CODE
,LAST_UPDATE_DATE
)
SELECT
dbi_line_header_id_tab(i)
,l.line_id
,l_set_of_books_id
,'XXX'
,dbi_line_update_date_tab(i)
FROM OE_ORDER_LINES_ALL l
WHERE l.line_id = dbi_line_line_id_tab(i)
AND l.booked_flag = 'Y'
AND dbi_line_status_tab(i) = 'Y';
arp_message.set_line(' line insert count='||sql%rowcount);
dbi_header_id_tab.DELETE;
dbi_header_header_id_tab.DELETE;
dbi_header_update_date_tab.DELETE;
dbi_line_header_id_tab.DELETE;
dbi_line_line_id_tab.DELETE;
dbi_line_update_date_tab.DELETE;
dbi_line_status_tab.DELETE;
dbi_header_id_tab.DELETE;
arp_message.set_line(' End Update DBI');
oe_debug_pub.add('when others oe_cust_merge.update_dbi_log'||SQLERRM||
SQLCODE);
END oe_update_dbi_log;