554: BEGIN
555: L_REALTIME_SYNC_VALUE := nvl(FND_PROFILE.VALUE('HZ_DQM_ENABLE_REALTIME_SYNC'), 'Y');
556: IF ( L_REALTIME_SYNC_VALUE = 'Y') THEN
557: -- REPURI. SYNC Perf Improvements. Insert directly into staging tables
558: HZ_STAGE_MAP_TRANSFORM.sync_single_party_online(p_party_id, p_create_upd);
559: --Check if sync went through successfully
560: IF (is_sync_success('PARTY',null,p_party_id)) THEN
561: -- Call sync index serial concurrent program
562: call_sync_index_serial ;
598: BEGIN
599: L_REALTIME_SYNC_VALUE := nvl(FND_PROFILE.VALUE('HZ_DQM_ENABLE_REALTIME_SYNC'), 'Y');
600: IF (L_REALTIME_SYNC_VALUE = 'Y') THEN
601: -- REPURI. SYNC Perf Improvements. Insert directly into staging tables
602: HZ_STAGE_MAP_TRANSFORM.sync_single_party_online(p_party_id, p_create_upd);
603: --Check if sync went through successfully
604: IF (is_sync_success('PARTY',null,p_party_id)) THEN
605: -- Call sync index serial concurrent program
606: call_sync_index_serial ;
648: BEGIN
649: L_REALTIME_SYNC_VALUE := nvl(FND_PROFILE.VALUE('HZ_DQM_ENABLE_REALTIME_SYNC'), 'Y');
650: IF (L_REALTIME_SYNC_VALUE = 'Y') THEN
651: -- REPURI. SYNC Perf Improvements. Insert directly into staging tables
652: HZ_STAGE_MAP_TRANSFORM.sync_single_party_site_online(p_party_site_id, p_create_upd);
653: --Check if sync went through successfully
654: IF (is_sync_success('PARTY_SITES',p_party_site_id,null)) THEN
655: -- Call sync index serial concurrent program
656: call_sync_index_serial ;
711: BEGIN
712: L_REALTIME_SYNC_VALUE := nvl(FND_PROFILE.VALUE('HZ_DQM_ENABLE_REALTIME_SYNC'), 'Y');
713: IF (L_REALTIME_SYNC_VALUE = 'Y') THEN
714: -- REPURI. SYNC Perf Improvements. Insert directly into staging tables
715: HZ_STAGE_MAP_TRANSFORM.sync_single_contact_online(p_org_contact_id, p_create_upd);
716: --Check if sync went through successfully
717: IF (is_sync_success('CONTACTS',p_org_contact_id,null)) THEN
718: -- Call sync index serial concurrent program
719: call_sync_index_serial ;
779: l_party_id := 0;
780: L_REALTIME_SYNC_VALUE := nvl(FND_PROFILE.VALUE('HZ_DQM_ENABLE_REALTIME_SYNC'), 'Y');
781: IF (L_REALTIME_SYNC_VALUE = 'Y') THEN
782: -- REPURI. SYNC Perf Improvements. Insert directly into staging tables
783: HZ_STAGE_MAP_TRANSFORM.sync_single_cpt_online(p_contact_point_id, p_create_upd);
784: --Check if sync went through successfully
785: IF (is_sync_success('CONTACT_POINTS',p_contact_point_id,null)) THEN
786: -- Call sync index serial concurrent program
787: call_sync_index_serial ;
1786: BEGIN
1787: IF (l_entity(i) = 'PARTY') THEN
1788: select party_type into l_party_type from hz_parties where party_id = l_party_id(i);
1789: hz_trans_pkg.set_party_type(l_party_type);
1790: HZ_STAGE_MAP_TRANSFORM.sync_single_party(l_party_id(i), l_party_type, l_operation(i));
1791: i_party := true;
1792: ELSIF (l_entity(i) = 'PARTY_SITES') THEN
1793: HZ_STAGE_MAP_TRANSFORM.sync_single_party_site(l_record_id(i), l_operation(i));
1794: i_party := true;
1789: hz_trans_pkg.set_party_type(l_party_type);
1790: HZ_STAGE_MAP_TRANSFORM.sync_single_party(l_party_id(i), l_party_type, l_operation(i));
1791: i_party := true;
1792: ELSIF (l_entity(i) = 'PARTY_SITES') THEN
1793: HZ_STAGE_MAP_TRANSFORM.sync_single_party_site(l_record_id(i), l_operation(i));
1794: i_party := true;
1795: i_party_sites := true;
1796: ELSIF (l_entity(i) = 'CONTACTS') THEN
1797: HZ_STAGE_MAP_TRANSFORM.sync_single_contact(l_record_id(i), l_operation(i));
1793: HZ_STAGE_MAP_TRANSFORM.sync_single_party_site(l_record_id(i), l_operation(i));
1794: i_party := true;
1795: i_party_sites := true;
1796: ELSIF (l_entity(i) = 'CONTACTS') THEN
1797: HZ_STAGE_MAP_TRANSFORM.sync_single_contact(l_record_id(i), l_operation(i));
1798: i_party := true;
1799: i_contacts := true;
1800: ELSIF (l_entity(i) = 'CONTACT_POINTS') THEN
1801: HZ_STAGE_MAP_TRANSFORM.sync_single_contact_point(l_record_id(i), l_operation(i));
1797: HZ_STAGE_MAP_TRANSFORM.sync_single_contact(l_record_id(i), l_operation(i));
1798: i_party := true;
1799: i_contacts := true;
1800: ELSIF (l_entity(i) = 'CONTACT_POINTS') THEN
1801: HZ_STAGE_MAP_TRANSFORM.sync_single_contact_point(l_record_id(i), l_operation(i));
1802: i_party := true;
1803: i_contact_points := true;
1804: END IF;
1805:
1968: -- For Create
1969: log ('-----------------------------');
1970: log ('For Create Organization Party');
1971: log ('-----------------------------');
1972: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1973: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1974: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1975: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC' ,l_sync_party_cur);
1976: -- For Update
1969: log ('-----------------------------');
1970: log ('For Create Organization Party');
1971: log ('-----------------------------');
1972: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1973: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1974: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1975: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC' ,l_sync_party_cur);
1976: -- For Update
1977: log ('-----------------------------');
1970: log ('For Create Organization Party');
1971: log ('-----------------------------');
1972: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1973: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1974: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1975: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC' ,l_sync_party_cur);
1976: -- For Update
1977: log ('-----------------------------');
1978: log ('For Update Organization Party');
1971: log ('-----------------------------');
1972: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1973: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1974: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1975: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC' ,l_sync_party_cur);
1976: -- For Update
1977: log ('-----------------------------');
1978: log ('For Update Organization Party');
1979: log ('-----------------------------');
1976: -- For Update
1977: log ('-----------------------------');
1978: log ('For Update Organization Party');
1979: log ('-----------------------------');
1980: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1981: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1982: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1983: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC' , l_sync_party_cur);
1984:
1977: log ('-----------------------------');
1978: log ('For Update Organization Party');
1979: log ('-----------------------------');
1980: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1981: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1982: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1983: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC' , l_sync_party_cur);
1984:
1985: -- Sync all person parties
1978: log ('For Update Organization Party');
1979: log ('-----------------------------');
1980: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1981: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1982: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1983: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC' , l_sync_party_cur);
1984:
1985: -- Sync all person parties
1986: -- For Create
1979: log ('-----------------------------');
1980: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1981: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1982: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1983: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC' , l_sync_party_cur);
1984:
1985: -- Sync all person parties
1986: -- For Create
1987: log ('-----------------------');
1986: -- For Create
1987: log ('-----------------------');
1988: log ('For Create Person Party');
1989: log ('-----------------------');
1990: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1991: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
1992: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1993: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC', l_sync_party_cur);
1994: -- For Update
1987: log ('-----------------------');
1988: log ('For Create Person Party');
1989: log ('-----------------------');
1990: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1991: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
1992: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1993: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC', l_sync_party_cur);
1994: -- For Update
1995: log ('-----------------------');
1988: log ('For Create Person Party');
1989: log ('-----------------------');
1990: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1991: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
1992: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1993: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC', l_sync_party_cur);
1994: -- For Update
1995: log ('-----------------------');
1996: log ('For Update Person Party');
1989: log ('-----------------------');
1990: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1991: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
1992: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1993: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC', l_sync_party_cur);
1994: -- For Update
1995: log ('-----------------------');
1996: log ('For Update Person Party');
1997: log ('-----------------------');
1994: -- For Update
1995: log ('-----------------------');
1996: log ('For Update Person Party');
1997: log ('-----------------------');
1998: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1999: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
2000: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2001: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC', l_sync_party_cur);
2002:
1995: log ('-----------------------');
1996: log ('For Update Person Party');
1997: log ('-----------------------');
1998: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1999: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
2000: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2001: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC', l_sync_party_cur);
2002:
2003: -- Sync all party_sites
1996: log ('For Update Person Party');
1997: log ('-----------------------');
1998: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1999: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
2000: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2001: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC', l_sync_party_cur);
2002:
2003: -- Sync all party_sites
2004: -- For Create
1997: log ('-----------------------');
1998: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1999: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
2000: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2001: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC', l_sync_party_cur);
2002:
2003: -- Sync all party_sites
2004: -- For Create
2005: log ('----------------------');
2004: -- For Create
2005: log ('----------------------');
2006: log ('For Create Party Sites');
2007: log ('----------------------');
2008: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
2009: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('C', p_from_rec, p_to_rec, l_sync_party_site_cur);
2010: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2011: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('C', 'DQM_SYNC', l_sync_party_site_cur);
2012: -- For Update
2005: log ('----------------------');
2006: log ('For Create Party Sites');
2007: log ('----------------------');
2008: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
2009: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('C', p_from_rec, p_to_rec, l_sync_party_site_cur);
2010: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2011: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('C', 'DQM_SYNC', l_sync_party_site_cur);
2012: -- For Update
2013: log ('----------------------');
2006: log ('For Create Party Sites');
2007: log ('----------------------');
2008: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
2009: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('C', p_from_rec, p_to_rec, l_sync_party_site_cur);
2010: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2011: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('C', 'DQM_SYNC', l_sync_party_site_cur);
2012: -- For Update
2013: log ('----------------------');
2014: log ('For Update Party Sites');
2007: log ('----------------------');
2008: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
2009: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('C', p_from_rec, p_to_rec, l_sync_party_site_cur);
2010: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2011: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('C', 'DQM_SYNC', l_sync_party_site_cur);
2012: -- For Update
2013: log ('----------------------');
2014: log ('For Update Party Sites');
2015: log ('----------------------');
2012: -- For Update
2013: log ('----------------------');
2014: log ('For Update Party Sites');
2015: log ('----------------------');
2016: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
2017: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('U', p_from_rec, p_to_rec, l_sync_party_site_cur);
2018: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2019: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('U', 'DQM_SYNC', l_sync_party_site_cur);
2020:
2013: log ('----------------------');
2014: log ('For Update Party Sites');
2015: log ('----------------------');
2016: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
2017: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('U', p_from_rec, p_to_rec, l_sync_party_site_cur);
2018: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2019: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('U', 'DQM_SYNC', l_sync_party_site_cur);
2020:
2021: -- Sync all contacts
2014: log ('For Update Party Sites');
2015: log ('----------------------');
2016: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
2017: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('U', p_from_rec, p_to_rec, l_sync_party_site_cur);
2018: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2019: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('U', 'DQM_SYNC', l_sync_party_site_cur);
2020:
2021: -- Sync all contacts
2022: -- For Create
2015: log ('----------------------');
2016: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
2017: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('U', p_from_rec, p_to_rec, l_sync_party_site_cur);
2018: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2019: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('U', 'DQM_SYNC', l_sync_party_site_cur);
2020:
2021: -- Sync all contacts
2022: -- For Create
2023: log ('-------------------');
2022: -- For Create
2023: log ('-------------------');
2024: log ('For Create Contacts');
2025: log ('-------------------');
2026: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
2027: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('C', p_from_rec, p_to_rec, l_sync_contact_cur);
2028: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2029: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('C', 'DQM_SYNC', l_sync_contact_cur);
2030: -- For Update
2023: log ('-------------------');
2024: log ('For Create Contacts');
2025: log ('-------------------');
2026: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
2027: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('C', p_from_rec, p_to_rec, l_sync_contact_cur);
2028: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2029: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('C', 'DQM_SYNC', l_sync_contact_cur);
2030: -- For Update
2031: log ('-------------------');
2024: log ('For Create Contacts');
2025: log ('-------------------');
2026: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
2027: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('C', p_from_rec, p_to_rec, l_sync_contact_cur);
2028: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2029: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('C', 'DQM_SYNC', l_sync_contact_cur);
2030: -- For Update
2031: log ('-------------------');
2032: log ('For Update Contacts');
2025: log ('-------------------');
2026: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
2027: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('C', p_from_rec, p_to_rec, l_sync_contact_cur);
2028: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2029: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('C', 'DQM_SYNC', l_sync_contact_cur);
2030: -- For Update
2031: log ('-------------------');
2032: log ('For Update Contacts');
2033: log ('-------------------');
2030: -- For Update
2031: log ('-------------------');
2032: log ('For Update Contacts');
2033: log ('-------------------');
2034: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
2035: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('U', p_from_rec, p_to_rec, l_sync_contact_cur);
2036: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2037: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('U', 'DQM_SYNC', l_sync_contact_cur);
2038:
2031: log ('-------------------');
2032: log ('For Update Contacts');
2033: log ('-------------------');
2034: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
2035: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('U', p_from_rec, p_to_rec, l_sync_contact_cur);
2036: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2037: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('U', 'DQM_SYNC', l_sync_contact_cur);
2038:
2039: -- Sync all contact_points
2032: log ('For Update Contacts');
2033: log ('-------------------');
2034: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
2035: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('U', p_from_rec, p_to_rec, l_sync_contact_cur);
2036: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2037: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('U', 'DQM_SYNC', l_sync_contact_cur);
2038:
2039: -- Sync all contact_points
2040: -- For Create
2033: log ('-------------------');
2034: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
2035: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('U', p_from_rec, p_to_rec, l_sync_contact_cur);
2036: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2037: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('U', 'DQM_SYNC', l_sync_contact_cur);
2038:
2039: -- Sync all contact_points
2040: -- For Create
2041: log ('-------------------------');
2040: -- For Create
2041: log ('-------------------------');
2042: log ('For Create Contact Points');
2043: log ('-------------------------');
2044: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
2045: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('C', p_from_rec, p_to_rec, l_sync_cpt_cur);
2046: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2047: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('C', 'DQM_SYNC', l_sync_cpt_cur);
2048: -- For Update
2041: log ('-------------------------');
2042: log ('For Create Contact Points');
2043: log ('-------------------------');
2044: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
2045: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('C', p_from_rec, p_to_rec, l_sync_cpt_cur);
2046: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2047: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('C', 'DQM_SYNC', l_sync_cpt_cur);
2048: -- For Update
2049: log ('-------------------------');
2042: log ('For Create Contact Points');
2043: log ('-------------------------');
2044: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
2045: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('C', p_from_rec, p_to_rec, l_sync_cpt_cur);
2046: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2047: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('C', 'DQM_SYNC', l_sync_cpt_cur);
2048: -- For Update
2049: log ('-------------------------');
2050: log ('For Update Contact Points');
2043: log ('-------------------------');
2044: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
2045: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('C', p_from_rec, p_to_rec, l_sync_cpt_cur);
2046: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2047: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('C', 'DQM_SYNC', l_sync_cpt_cur);
2048: -- For Update
2049: log ('-------------------------');
2050: log ('For Update Contact Points');
2051: log ('-------------------------');
2048: -- For Update
2049: log ('-------------------------');
2050: log ('For Update Contact Points');
2051: log ('-------------------------');
2052: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
2053: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('U', p_from_rec, p_to_rec, l_sync_cpt_cur);
2054: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2055: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'DQM_SYNC', l_sync_cpt_cur);
2056:
2049: log ('-------------------------');
2050: log ('For Update Contact Points');
2051: log ('-------------------------');
2052: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
2053: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('U', p_from_rec, p_to_rec, l_sync_cpt_cur);
2054: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2055: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'DQM_SYNC', l_sync_cpt_cur);
2056:
2057: -- Delete from from hz_dqm_sync_interface table, all the range
2050: log ('For Update Contact Points');
2051: log ('-------------------------');
2052: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
2053: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('U', p_from_rec, p_to_rec, l_sync_cpt_cur);
2054: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2055: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'DQM_SYNC', l_sync_cpt_cur);
2056:
2057: -- Delete from from hz_dqm_sync_interface table, all the range
2058: -- of records that are already processed
2051: log ('-------------------------');
2052: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
2053: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('U', p_from_rec, p_to_rec, l_sync_cpt_cur);
2054: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2055: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'DQM_SYNC', l_sync_cpt_cur);
2056:
2057: -- Delete from from hz_dqm_sync_interface table, all the range
2058: -- of records that are already processed
2059: DELETE FROM hz_dqm_sync_interface
2450: log ('-----------------------------');
2451: log ('For Create Organization Party');
2452: log ('-----------------------------');
2453:
2454: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2455: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2456: p_batch_id => p_batch_id
2457: ,p_batch_mode_flag => p_batch_mode_flag
2458: ,p_from_osr => p_from_osr
2451: log ('For Create Organization Party');
2452: log ('-----------------------------');
2453:
2454: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2455: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2456: p_batch_id => p_batch_id
2457: ,p_batch_mode_flag => p_batch_mode_flag
2458: ,p_from_osr => p_from_osr
2459: ,p_to_osr => p_to_osr
2462: ,p_operation => 'I'
2463: ,x_sync_party_cur => l_sync_party_cur
2464: );
2465:
2466: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2467: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'IMPORT_SYNC', l_sync_party_cur);
2468:
2469: -- For Update
2470: log ('-----------------------------');
2463: ,x_sync_party_cur => l_sync_party_cur
2464: );
2465:
2466: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2467: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'IMPORT_SYNC', l_sync_party_cur);
2468:
2469: -- For Update
2470: log ('-----------------------------');
2471: log ('For Update Organization Party');
2470: log ('-----------------------------');
2471: log ('For Update Organization Party');
2472: log ('-----------------------------');
2473:
2474: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2475: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2476: p_batch_id => p_batch_id
2477: ,p_batch_mode_flag => p_batch_mode_flag
2478: ,p_from_osr => p_from_osr
2471: log ('For Update Organization Party');
2472: log ('-----------------------------');
2473:
2474: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2475: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2476: p_batch_id => p_batch_id
2477: ,p_batch_mode_flag => p_batch_mode_flag
2478: ,p_from_osr => p_from_osr
2479: ,p_to_osr => p_to_osr
2482: ,p_operation => 'U'
2483: ,x_sync_party_cur => l_sync_party_cur
2484: );
2485:
2486: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2487: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'IMPORT_SYNC', l_sync_party_cur);
2488:
2489: -- Sync all person parties
2490: -- For Create
2483: ,x_sync_party_cur => l_sync_party_cur
2484: );
2485:
2486: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2487: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'IMPORT_SYNC', l_sync_party_cur);
2488:
2489: -- Sync all person parties
2490: -- For Create
2491:
2492: log ('-----------------------');
2493: log ('For Create Person Party');
2494: log ('-----------------------');
2495:
2496: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2497: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2498: p_batch_id => p_batch_id
2499: ,p_batch_mode_flag => p_batch_mode_flag
2500: ,p_from_osr => p_from_osr
2493: log ('For Create Person Party');
2494: log ('-----------------------');
2495:
2496: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2497: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2498: p_batch_id => p_batch_id
2499: ,p_batch_mode_flag => p_batch_mode_flag
2500: ,p_from_osr => p_from_osr
2501: ,p_to_osr => p_to_osr
2504: ,p_operation => 'I'
2505: ,x_sync_party_cur => l_sync_party_cur
2506: );
2507:
2508: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2509: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'IMPORT_SYNC', l_sync_party_cur);
2510:
2511: -- For Update
2512:
2505: ,x_sync_party_cur => l_sync_party_cur
2506: );
2507:
2508: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2509: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'IMPORT_SYNC', l_sync_party_cur);
2510:
2511: -- For Update
2512:
2513: log ('-----------------------');
2513: log ('-----------------------');
2514: log ('For Update Person Party');
2515: log ('-----------------------');
2516:
2517: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2518: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2519: p_batch_id => p_batch_id
2520: ,p_batch_mode_flag => p_batch_mode_flag
2521: ,p_from_osr => p_from_osr
2514: log ('For Update Person Party');
2515: log ('-----------------------');
2516:
2517: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2518: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2519: p_batch_id => p_batch_id
2520: ,p_batch_mode_flag => p_batch_mode_flag
2521: ,p_from_osr => p_from_osr
2522: ,p_to_osr => p_to_osr
2525: ,p_operation => 'U'
2526: ,x_sync_party_cur => l_sync_party_cur
2527: );
2528:
2529: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2530: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'IMPORT_SYNC', l_sync_party_cur);
2531:
2532: -- Sync all party_sites
2533: -- For Create
2526: ,x_sync_party_cur => l_sync_party_cur
2527: );
2528:
2529: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2530: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'IMPORT_SYNC', l_sync_party_cur);
2531:
2532: -- Sync all party_sites
2533: -- For Create
2534:
2535: log ('----------------------');
2536: log ('For Create Party Sites');
2537: log ('----------------------');
2538:
2539: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur');
2540: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur (
2541: p_batch_id => p_batch_id
2542: ,p_batch_mode_flag => p_batch_mode_flag
2543: ,p_from_osr => p_from_osr
2536: log ('For Create Party Sites');
2537: log ('----------------------');
2538:
2539: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur');
2540: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur (
2541: p_batch_id => p_batch_id
2542: ,p_batch_mode_flag => p_batch_mode_flag
2543: ,p_from_osr => p_from_osr
2544: ,p_to_osr => p_to_osr
2546: ,p_operation => 'I'
2547: ,x_sync_party_site_cur => l_sync_party_site_cur
2548: );
2549:
2550: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2551: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('C', 'IMPORT_SYNC', l_sync_party_site_cur);
2552:
2553: -- For Update
2554: log ('----------------------');
2547: ,x_sync_party_site_cur => l_sync_party_site_cur
2548: );
2549:
2550: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2551: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('C', 'IMPORT_SYNC', l_sync_party_site_cur);
2552:
2553: -- For Update
2554: log ('----------------------');
2555: log ('For Update Party Sites');
2554: log ('----------------------');
2555: log ('For Update Party Sites');
2556: log ('----------------------');
2557:
2558: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur');
2559: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur (
2560: p_batch_id => p_batch_id
2561: ,p_batch_mode_flag => p_batch_mode_flag
2562: ,p_from_osr => p_from_osr
2555: log ('For Update Party Sites');
2556: log ('----------------------');
2557:
2558: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur');
2559: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur (
2560: p_batch_id => p_batch_id
2561: ,p_batch_mode_flag => p_batch_mode_flag
2562: ,p_from_osr => p_from_osr
2563: ,p_to_osr => p_to_osr
2565: ,p_operation => 'U'
2566: ,x_sync_party_site_cur => l_sync_party_site_cur
2567: );
2568:
2569: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2570: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('U', 'IMPORT_SYNC', l_sync_party_site_cur);
2571:
2572: -- Sync all contacts
2573: -- For Create
2566: ,x_sync_party_site_cur => l_sync_party_site_cur
2567: );
2568:
2569: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2570: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('U', 'IMPORT_SYNC', l_sync_party_site_cur);
2571:
2572: -- Sync all contacts
2573: -- For Create
2574: log ('-------------------');
2574: log ('-------------------');
2575: log ('For Create Contacts');
2576: log ('-------------------');
2577:
2578: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur');
2579: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur (
2580: p_batch_id => p_batch_id
2581: ,p_batch_mode_flag => p_batch_mode_flag
2582: ,p_from_osr => p_from_osr
2575: log ('For Create Contacts');
2576: log ('-------------------');
2577:
2578: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur');
2579: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur (
2580: p_batch_id => p_batch_id
2581: ,p_batch_mode_flag => p_batch_mode_flag
2582: ,p_from_osr => p_from_osr
2583: ,p_to_osr => p_to_osr
2585: ,p_operation => 'I'
2586: ,x_sync_contact_cur => l_sync_contact_cur
2587: );
2588:
2589: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2590: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('C', 'IMPORT_SYNC', l_sync_contact_cur);
2591: -- For Update
2592: log ('-------------------');
2593: log ('For Update Contacts');
2586: ,x_sync_contact_cur => l_sync_contact_cur
2587: );
2588:
2589: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2590: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('C', 'IMPORT_SYNC', l_sync_contact_cur);
2591: -- For Update
2592: log ('-------------------');
2593: log ('For Update Contacts');
2594: log ('-------------------');
2592: log ('-------------------');
2593: log ('For Update Contacts');
2594: log ('-------------------');
2595:
2596: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur');
2597: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur (
2598: p_batch_id => p_batch_id
2599: ,p_batch_mode_flag => p_batch_mode_flag
2600: ,p_from_osr => p_from_osr
2593: log ('For Update Contacts');
2594: log ('-------------------');
2595:
2596: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur');
2597: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur (
2598: p_batch_id => p_batch_id
2599: ,p_batch_mode_flag => p_batch_mode_flag
2600: ,p_from_osr => p_from_osr
2601: ,p_to_osr => p_to_osr
2603: ,p_operation => 'U'
2604: ,x_sync_contact_cur => l_sync_contact_cur
2605: );
2606:
2607: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2608: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('U', 'IMPORT_SYNC', l_sync_contact_cur);
2609:
2610: -- Sync all contact_points
2611: -- For Create
2604: ,x_sync_contact_cur => l_sync_contact_cur
2605: );
2606:
2607: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2608: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('U', 'IMPORT_SYNC', l_sync_contact_cur);
2609:
2610: -- Sync all contact_points
2611: -- For Create
2612:
2613: log ('-------------------------');
2614: log ('For Create Contact Points');
2615: log ('-------------------------');
2616:
2617: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur');
2618: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur (
2619: p_batch_id => p_batch_id
2620: ,p_batch_mode_flag => p_batch_mode_flag
2621: ,p_from_osr => p_from_osr
2614: log ('For Create Contact Points');
2615: log ('-------------------------');
2616:
2617: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur');
2618: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur (
2619: p_batch_id => p_batch_id
2620: ,p_batch_mode_flag => p_batch_mode_flag
2621: ,p_from_osr => p_from_osr
2622: ,p_to_osr => p_to_osr
2624: ,p_operation => 'I'
2625: ,x_sync_cpt_cur => l_sync_cpt_cur
2626: );
2627:
2628: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2629: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('C', 'IMPORT_SYNC', l_sync_cpt_cur);
2630:
2631: -- For Update
2632:
2625: ,x_sync_cpt_cur => l_sync_cpt_cur
2626: );
2627:
2628: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2629: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('C', 'IMPORT_SYNC', l_sync_cpt_cur);
2630:
2631: -- For Update
2632:
2633: log ('-------------------------');
2633: log ('-------------------------');
2634: log ('For Update Contact Points');
2635: log ('-------------------------');
2636:
2637: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur');
2638: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur (
2639: p_batch_id => p_batch_id
2640: ,p_batch_mode_flag => p_batch_mode_flag
2641: ,p_from_osr => p_from_osr
2634: log ('For Update Contact Points');
2635: log ('-------------------------');
2636:
2637: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur');
2638: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur (
2639: p_batch_id => p_batch_id
2640: ,p_batch_mode_flag => p_batch_mode_flag
2641: ,p_from_osr => p_from_osr
2642: ,p_to_osr => p_to_osr
2644: ,p_operation => 'U'
2645: ,x_sync_cpt_cur => l_sync_cpt_cur
2646: );
2647:
2648: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2649: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'IMPORT_SYNC', l_sync_cpt_cur);
2650:
2651: END ;
2652:
2645: ,x_sync_cpt_cur => l_sync_cpt_cur
2646: );
2647:
2648: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2649: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'IMPORT_SYNC', l_sync_cpt_cur);
2650:
2651: END ;
2652:
2653: -- This would take a request_id , see if the corresponding conc program is complete