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 ;
768: l_party_id := 0;
769: L_REALTIME_SYNC_VALUE := nvl(FND_PROFILE.VALUE('HZ_DQM_ENABLE_REALTIME_SYNC'), 'Y');
770: IF (L_REALTIME_SYNC_VALUE = 'Y') THEN
771: -- REPURI. SYNC Perf Improvements. Insert directly into staging tables
772: HZ_STAGE_MAP_TRANSFORM.sync_single_cpt_online(p_contact_point_id, p_create_upd);
773: --Check if sync went through successfully
774: IF (is_sync_success('CONTACT_POINTS',p_contact_point_id,null)) THEN
775: -- Call sync index serial concurrent program
776: call_sync_index_serial ;
1667: BEGIN
1668: IF (l_entity(i) = 'PARTY') THEN
1669: select party_type into l_party_type from hz_parties where party_id = l_party_id(i);
1670: hz_trans_pkg.set_party_type(l_party_type);
1671: HZ_STAGE_MAP_TRANSFORM.sync_single_party(l_party_id(i), l_party_type, l_operation(i));
1672: i_party := true;
1673: ELSIF (l_entity(i) = 'PARTY_SITES') THEN
1674: HZ_STAGE_MAP_TRANSFORM.sync_single_party_site(l_record_id(i), l_operation(i));
1675: i_party := true;
1670: hz_trans_pkg.set_party_type(l_party_type);
1671: HZ_STAGE_MAP_TRANSFORM.sync_single_party(l_party_id(i), l_party_type, l_operation(i));
1672: i_party := true;
1673: ELSIF (l_entity(i) = 'PARTY_SITES') THEN
1674: HZ_STAGE_MAP_TRANSFORM.sync_single_party_site(l_record_id(i), l_operation(i));
1675: i_party := true;
1676: i_party_sites := true;
1677: ELSIF (l_entity(i) = 'CONTACTS') THEN
1678: HZ_STAGE_MAP_TRANSFORM.sync_single_contact(l_record_id(i), l_operation(i));
1674: HZ_STAGE_MAP_TRANSFORM.sync_single_party_site(l_record_id(i), l_operation(i));
1675: i_party := true;
1676: i_party_sites := true;
1677: ELSIF (l_entity(i) = 'CONTACTS') THEN
1678: HZ_STAGE_MAP_TRANSFORM.sync_single_contact(l_record_id(i), l_operation(i));
1679: i_party := true;
1680: i_contacts := true;
1681: ELSIF (l_entity(i) = 'CONTACT_POINTS') THEN
1682: HZ_STAGE_MAP_TRANSFORM.sync_single_contact_point(l_record_id(i), l_operation(i));
1678: HZ_STAGE_MAP_TRANSFORM.sync_single_contact(l_record_id(i), l_operation(i));
1679: i_party := true;
1680: i_contacts := true;
1681: ELSIF (l_entity(i) = 'CONTACT_POINTS') THEN
1682: HZ_STAGE_MAP_TRANSFORM.sync_single_contact_point(l_record_id(i), l_operation(i));
1683: i_party := true;
1684: i_contact_points := true;
1685: END IF;
1686:
1849: -- For Create
1850: log ('-----------------------------');
1851: log ('For Create Organization Party');
1852: log ('-----------------------------');
1853: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1854: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1855: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1856: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC' ,l_sync_party_cur);
1857: -- For Update
1850: log ('-----------------------------');
1851: log ('For Create Organization Party');
1852: log ('-----------------------------');
1853: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1854: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1855: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1856: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC' ,l_sync_party_cur);
1857: -- For Update
1858: log ('-----------------------------');
1851: log ('For Create Organization Party');
1852: log ('-----------------------------');
1853: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1854: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1855: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1856: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC' ,l_sync_party_cur);
1857: -- For Update
1858: log ('-----------------------------');
1859: log ('For Update Organization Party');
1852: log ('-----------------------------');
1853: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1854: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1855: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1856: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC' ,l_sync_party_cur);
1857: -- For Update
1858: log ('-----------------------------');
1859: log ('For Update Organization Party');
1860: log ('-----------------------------');
1857: -- For Update
1858: log ('-----------------------------');
1859: log ('For Update Organization Party');
1860: log ('-----------------------------');
1861: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1862: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1863: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1864: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC' , l_sync_party_cur);
1865:
1858: log ('-----------------------------');
1859: log ('For Update Organization Party');
1860: log ('-----------------------------');
1861: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1862: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1863: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1864: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC' , l_sync_party_cur);
1865:
1866: -- Sync all person parties
1859: log ('For Update Organization Party');
1860: log ('-----------------------------');
1861: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1862: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1863: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1864: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC' , l_sync_party_cur);
1865:
1866: -- Sync all person parties
1867: -- For Create
1860: log ('-----------------------------');
1861: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1862: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','ORGANIZATION', p_from_rec, p_to_rec, l_sync_party_cur);
1863: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1864: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC' , l_sync_party_cur);
1865:
1866: -- Sync all person parties
1867: -- For Create
1868: log ('-----------------------');
1867: -- For Create
1868: log ('-----------------------');
1869: log ('For Create Person Party');
1870: log ('-----------------------');
1871: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1872: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
1873: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1874: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC', l_sync_party_cur);
1875: -- For Update
1868: log ('-----------------------');
1869: log ('For Create Person Party');
1870: log ('-----------------------');
1871: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1872: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
1873: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1874: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC', l_sync_party_cur);
1875: -- For Update
1876: log ('-----------------------');
1869: log ('For Create Person Party');
1870: log ('-----------------------');
1871: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1872: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
1873: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1874: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC', l_sync_party_cur);
1875: -- For Update
1876: log ('-----------------------');
1877: log ('For Update Person Party');
1870: log ('-----------------------');
1871: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1872: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('C','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
1873: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1874: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'DQM_SYNC', l_sync_party_cur);
1875: -- For Update
1876: log ('-----------------------');
1877: log ('For Update Person Party');
1878: log ('-----------------------');
1875: -- For Update
1876: log ('-----------------------');
1877: log ('For Update Person Party');
1878: log ('-----------------------');
1879: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1880: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
1881: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1882: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC', l_sync_party_cur);
1883:
1876: log ('-----------------------');
1877: log ('For Update Person Party');
1878: log ('-----------------------');
1879: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1880: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
1881: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1882: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC', l_sync_party_cur);
1883:
1884: -- Sync all party_sites
1877: log ('For Update Person Party');
1878: log ('-----------------------');
1879: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1880: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
1881: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1882: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC', l_sync_party_cur);
1883:
1884: -- Sync all party_sites
1885: -- For Create
1878: log ('-----------------------');
1879: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor');
1880: HZ_STAGE_MAP_TRANSFORM.open_sync_party_cursor ('U','PERSON', p_from_rec, p_to_rec, l_sync_party_cur);
1881: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
1882: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'DQM_SYNC', l_sync_party_cur);
1883:
1884: -- Sync all party_sites
1885: -- For Create
1886: log ('----------------------');
1885: -- For Create
1886: log ('----------------------');
1887: log ('For Create Party Sites');
1888: log ('----------------------');
1889: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
1890: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('C', p_from_rec, p_to_rec, l_sync_party_site_cur);
1891: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
1892: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('C', 'DQM_SYNC', l_sync_party_site_cur);
1893: -- For Update
1886: log ('----------------------');
1887: log ('For Create Party Sites');
1888: log ('----------------------');
1889: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
1890: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('C', p_from_rec, p_to_rec, l_sync_party_site_cur);
1891: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
1892: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('C', 'DQM_SYNC', l_sync_party_site_cur);
1893: -- For Update
1894: log ('----------------------');
1887: log ('For Create Party Sites');
1888: log ('----------------------');
1889: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
1890: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('C', p_from_rec, p_to_rec, l_sync_party_site_cur);
1891: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
1892: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('C', 'DQM_SYNC', l_sync_party_site_cur);
1893: -- For Update
1894: log ('----------------------');
1895: log ('For Update Party Sites');
1888: log ('----------------------');
1889: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
1890: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('C', p_from_rec, p_to_rec, l_sync_party_site_cur);
1891: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
1892: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('C', 'DQM_SYNC', l_sync_party_site_cur);
1893: -- For Update
1894: log ('----------------------');
1895: log ('For Update Party Sites');
1896: log ('----------------------');
1893: -- For Update
1894: log ('----------------------');
1895: log ('For Update Party Sites');
1896: log ('----------------------');
1897: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
1898: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('U', p_from_rec, p_to_rec, l_sync_party_site_cur);
1899: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
1900: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('U', 'DQM_SYNC', l_sync_party_site_cur);
1901:
1894: log ('----------------------');
1895: log ('For Update Party Sites');
1896: log ('----------------------');
1897: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
1898: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('U', p_from_rec, p_to_rec, l_sync_party_site_cur);
1899: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
1900: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('U', 'DQM_SYNC', l_sync_party_site_cur);
1901:
1902: -- Sync all contacts
1895: log ('For Update Party Sites');
1896: log ('----------------------');
1897: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
1898: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('U', p_from_rec, p_to_rec, l_sync_party_site_cur);
1899: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
1900: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('U', 'DQM_SYNC', l_sync_party_site_cur);
1901:
1902: -- Sync all contacts
1903: -- For Create
1896: log ('----------------------');
1897: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor');
1898: HZ_STAGE_MAP_TRANSFORM.open_sync_party_site_cursor ('U', p_from_rec, p_to_rec, l_sync_party_site_cur);
1899: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
1900: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('U', 'DQM_SYNC', l_sync_party_site_cur);
1901:
1902: -- Sync all contacts
1903: -- For Create
1904: log ('-------------------');
1903: -- For Create
1904: log ('-------------------');
1905: log ('For Create Contacts');
1906: log ('-------------------');
1907: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
1908: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('C', p_from_rec, p_to_rec, l_sync_contact_cur);
1909: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
1910: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('C', 'DQM_SYNC', l_sync_contact_cur);
1911: -- For Update
1904: log ('-------------------');
1905: log ('For Create Contacts');
1906: log ('-------------------');
1907: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
1908: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('C', p_from_rec, p_to_rec, l_sync_contact_cur);
1909: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
1910: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('C', 'DQM_SYNC', l_sync_contact_cur);
1911: -- For Update
1912: log ('-------------------');
1905: log ('For Create Contacts');
1906: log ('-------------------');
1907: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
1908: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('C', p_from_rec, p_to_rec, l_sync_contact_cur);
1909: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
1910: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('C', 'DQM_SYNC', l_sync_contact_cur);
1911: -- For Update
1912: log ('-------------------');
1913: log ('For Update Contacts');
1906: log ('-------------------');
1907: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
1908: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('C', p_from_rec, p_to_rec, l_sync_contact_cur);
1909: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
1910: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('C', 'DQM_SYNC', l_sync_contact_cur);
1911: -- For Update
1912: log ('-------------------');
1913: log ('For Update Contacts');
1914: log ('-------------------');
1911: -- For Update
1912: log ('-------------------');
1913: log ('For Update Contacts');
1914: log ('-------------------');
1915: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
1916: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('U', p_from_rec, p_to_rec, l_sync_contact_cur);
1917: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
1918: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('U', 'DQM_SYNC', l_sync_contact_cur);
1919:
1912: log ('-------------------');
1913: log ('For Update Contacts');
1914: log ('-------------------');
1915: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
1916: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('U', p_from_rec, p_to_rec, l_sync_contact_cur);
1917: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
1918: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('U', 'DQM_SYNC', l_sync_contact_cur);
1919:
1920: -- Sync all contact_points
1913: log ('For Update Contacts');
1914: log ('-------------------');
1915: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
1916: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('U', p_from_rec, p_to_rec, l_sync_contact_cur);
1917: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
1918: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('U', 'DQM_SYNC', l_sync_contact_cur);
1919:
1920: -- Sync all contact_points
1921: -- For Create
1914: log ('-------------------');
1915: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor');
1916: HZ_STAGE_MAP_TRANSFORM.open_sync_contact_cursor ('U', p_from_rec, p_to_rec, l_sync_contact_cur);
1917: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
1918: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('U', 'DQM_SYNC', l_sync_contact_cur);
1919:
1920: -- Sync all contact_points
1921: -- For Create
1922: log ('-------------------------');
1921: -- For Create
1922: log ('-------------------------');
1923: log ('For Create Contact Points');
1924: log ('-------------------------');
1925: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
1926: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('C', p_from_rec, p_to_rec, l_sync_cpt_cur);
1927: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
1928: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('C', 'DQM_SYNC', l_sync_cpt_cur);
1929: -- For Update
1922: log ('-------------------------');
1923: log ('For Create Contact Points');
1924: log ('-------------------------');
1925: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
1926: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('C', p_from_rec, p_to_rec, l_sync_cpt_cur);
1927: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
1928: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('C', 'DQM_SYNC', l_sync_cpt_cur);
1929: -- For Update
1930: log ('-------------------------');
1923: log ('For Create Contact Points');
1924: log ('-------------------------');
1925: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
1926: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('C', p_from_rec, p_to_rec, l_sync_cpt_cur);
1927: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
1928: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('C', 'DQM_SYNC', l_sync_cpt_cur);
1929: -- For Update
1930: log ('-------------------------');
1931: log ('For Update Contact Points');
1924: log ('-------------------------');
1925: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
1926: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('C', p_from_rec, p_to_rec, l_sync_cpt_cur);
1927: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
1928: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('C', 'DQM_SYNC', l_sync_cpt_cur);
1929: -- For Update
1930: log ('-------------------------');
1931: log ('For Update Contact Points');
1932: log ('-------------------------');
1929: -- For Update
1930: log ('-------------------------');
1931: log ('For Update Contact Points');
1932: log ('-------------------------');
1933: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
1934: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('U', p_from_rec, p_to_rec, l_sync_cpt_cur);
1935: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
1936: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'DQM_SYNC', l_sync_cpt_cur);
1937:
1930: log ('-------------------------');
1931: log ('For Update Contact Points');
1932: log ('-------------------------');
1933: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
1934: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('U', p_from_rec, p_to_rec, l_sync_cpt_cur);
1935: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
1936: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'DQM_SYNC', l_sync_cpt_cur);
1937:
1938: -- Delete from from hz_dqm_sync_interface table, all the range
1931: log ('For Update Contact Points');
1932: log ('-------------------------');
1933: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
1934: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('U', p_from_rec, p_to_rec, l_sync_cpt_cur);
1935: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
1936: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'DQM_SYNC', l_sync_cpt_cur);
1937:
1938: -- Delete from from hz_dqm_sync_interface table, all the range
1939: -- of records that are already processed
1932: log ('-------------------------');
1933: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor');
1934: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('U', p_from_rec, p_to_rec, l_sync_cpt_cur);
1935: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
1936: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'DQM_SYNC', l_sync_cpt_cur);
1937:
1938: -- Delete from from hz_dqm_sync_interface table, all the range
1939: -- of records that are already processed
1940: DELETE FROM hz_dqm_sync_interface
2271: log ('-----------------------------');
2272: log ('For Create Organization Party');
2273: log ('-----------------------------');
2274:
2275: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2276: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2277: p_batch_id => p_batch_id
2278: ,p_batch_mode_flag => p_batch_mode_flag
2279: ,p_from_osr => p_from_osr
2272: log ('For Create Organization Party');
2273: log ('-----------------------------');
2274:
2275: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2276: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2277: p_batch_id => p_batch_id
2278: ,p_batch_mode_flag => p_batch_mode_flag
2279: ,p_from_osr => p_from_osr
2280: ,p_to_osr => p_to_osr
2283: ,p_operation => 'I'
2284: ,x_sync_party_cur => l_sync_party_cur
2285: );
2286:
2287: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2288: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'IMPORT_SYNC', l_sync_party_cur);
2289:
2290: -- For Update
2291: log ('-----------------------------');
2284: ,x_sync_party_cur => l_sync_party_cur
2285: );
2286:
2287: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2288: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'IMPORT_SYNC', l_sync_party_cur);
2289:
2290: -- For Update
2291: log ('-----------------------------');
2292: log ('For Update Organization Party');
2291: log ('-----------------------------');
2292: log ('For Update Organization Party');
2293: log ('-----------------------------');
2294:
2295: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2296: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2297: p_batch_id => p_batch_id
2298: ,p_batch_mode_flag => p_batch_mode_flag
2299: ,p_from_osr => p_from_osr
2292: log ('For Update Organization Party');
2293: log ('-----------------------------');
2294:
2295: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2296: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2297: p_batch_id => p_batch_id
2298: ,p_batch_mode_flag => p_batch_mode_flag
2299: ,p_from_osr => p_from_osr
2300: ,p_to_osr => p_to_osr
2303: ,p_operation => 'U'
2304: ,x_sync_party_cur => l_sync_party_cur
2305: );
2306:
2307: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2308: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'IMPORT_SYNC', l_sync_party_cur);
2309:
2310: -- Sync all person parties
2311: -- For Create
2304: ,x_sync_party_cur => l_sync_party_cur
2305: );
2306:
2307: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2308: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'IMPORT_SYNC', l_sync_party_cur);
2309:
2310: -- Sync all person parties
2311: -- For Create
2312:
2313: log ('-----------------------');
2314: log ('For Create Person Party');
2315: log ('-----------------------');
2316:
2317: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2318: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2319: p_batch_id => p_batch_id
2320: ,p_batch_mode_flag => p_batch_mode_flag
2321: ,p_from_osr => p_from_osr
2314: log ('For Create Person Party');
2315: log ('-----------------------');
2316:
2317: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2318: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2319: p_batch_id => p_batch_id
2320: ,p_batch_mode_flag => p_batch_mode_flag
2321: ,p_from_osr => p_from_osr
2322: ,p_to_osr => p_to_osr
2325: ,p_operation => 'I'
2326: ,x_sync_party_cur => l_sync_party_cur
2327: );
2328:
2329: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2330: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'IMPORT_SYNC', l_sync_party_cur);
2331:
2332: -- For Update
2333:
2326: ,x_sync_party_cur => l_sync_party_cur
2327: );
2328:
2329: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2330: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('C', 'IMPORT_SYNC', l_sync_party_cur);
2331:
2332: -- For Update
2333:
2334: log ('-----------------------');
2334: log ('-----------------------');
2335: log ('For Update Person Party');
2336: log ('-----------------------');
2337:
2338: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2339: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2340: p_batch_id => p_batch_id
2341: ,p_batch_mode_flag => p_batch_mode_flag
2342: ,p_from_osr => p_from_osr
2335: log ('For Update Person Party');
2336: log ('-----------------------');
2337:
2338: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur');
2339: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_party_cur (
2340: p_batch_id => p_batch_id
2341: ,p_batch_mode_flag => p_batch_mode_flag
2342: ,p_from_osr => p_from_osr
2343: ,p_to_osr => p_to_osr
2346: ,p_operation => 'U'
2347: ,x_sync_party_cur => l_sync_party_cur
2348: );
2349:
2350: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2351: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'IMPORT_SYNC', l_sync_party_cur);
2352:
2353: -- Sync all party_sites
2354: -- For Create
2347: ,x_sync_party_cur => l_sync_party_cur
2348: );
2349:
2350: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_parties');
2351: HZ_STAGE_MAP_TRANSFORM.sync_all_parties ('U', 'IMPORT_SYNC', l_sync_party_cur);
2352:
2353: -- Sync all party_sites
2354: -- For Create
2355:
2356: log ('----------------------');
2357: log ('For Create Party Sites');
2358: log ('----------------------');
2359:
2360: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur');
2361: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur (
2362: p_batch_id => p_batch_id
2363: ,p_batch_mode_flag => p_batch_mode_flag
2364: ,p_from_osr => p_from_osr
2357: log ('For Create Party Sites');
2358: log ('----------------------');
2359:
2360: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur');
2361: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur (
2362: p_batch_id => p_batch_id
2363: ,p_batch_mode_flag => p_batch_mode_flag
2364: ,p_from_osr => p_from_osr
2365: ,p_to_osr => p_to_osr
2367: ,p_operation => 'I'
2368: ,x_sync_party_site_cur => l_sync_party_site_cur
2369: );
2370:
2371: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2372: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('C', 'IMPORT_SYNC', l_sync_party_site_cur);
2373:
2374: -- For Update
2375: log ('----------------------');
2368: ,x_sync_party_site_cur => l_sync_party_site_cur
2369: );
2370:
2371: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2372: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('C', 'IMPORT_SYNC', l_sync_party_site_cur);
2373:
2374: -- For Update
2375: log ('----------------------');
2376: log ('For Update Party Sites');
2375: log ('----------------------');
2376: log ('For Update Party Sites');
2377: log ('----------------------');
2378:
2379: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur');
2380: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur (
2381: p_batch_id => p_batch_id
2382: ,p_batch_mode_flag => p_batch_mode_flag
2383: ,p_from_osr => p_from_osr
2376: log ('For Update Party Sites');
2377: log ('----------------------');
2378:
2379: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur');
2380: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_psite_cur (
2381: p_batch_id => p_batch_id
2382: ,p_batch_mode_flag => p_batch_mode_flag
2383: ,p_from_osr => p_from_osr
2384: ,p_to_osr => p_to_osr
2386: ,p_operation => 'U'
2387: ,x_sync_party_site_cur => l_sync_party_site_cur
2388: );
2389:
2390: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2391: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('U', 'IMPORT_SYNC', l_sync_party_site_cur);
2392:
2393: -- Sync all contacts
2394: -- For Create
2387: ,x_sync_party_site_cur => l_sync_party_site_cur
2388: );
2389:
2390: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites');
2391: HZ_STAGE_MAP_TRANSFORM.sync_all_party_sites ('U', 'IMPORT_SYNC', l_sync_party_site_cur);
2392:
2393: -- Sync all contacts
2394: -- For Create
2395: log ('-------------------');
2395: log ('-------------------');
2396: log ('For Create Contacts');
2397: log ('-------------------');
2398:
2399: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur');
2400: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur (
2401: p_batch_id => p_batch_id
2402: ,p_batch_mode_flag => p_batch_mode_flag
2403: ,p_from_osr => p_from_osr
2396: log ('For Create Contacts');
2397: log ('-------------------');
2398:
2399: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur');
2400: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur (
2401: p_batch_id => p_batch_id
2402: ,p_batch_mode_flag => p_batch_mode_flag
2403: ,p_from_osr => p_from_osr
2404: ,p_to_osr => p_to_osr
2406: ,p_operation => 'I'
2407: ,x_sync_contact_cur => l_sync_contact_cur
2408: );
2409:
2410: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2411: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('C', 'IMPORT_SYNC', l_sync_contact_cur);
2412: -- For Update
2413: log ('-------------------');
2414: log ('For Update Contacts');
2407: ,x_sync_contact_cur => l_sync_contact_cur
2408: );
2409:
2410: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2411: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('C', 'IMPORT_SYNC', l_sync_contact_cur);
2412: -- For Update
2413: log ('-------------------');
2414: log ('For Update Contacts');
2415: log ('-------------------');
2413: log ('-------------------');
2414: log ('For Update Contacts');
2415: log ('-------------------');
2416:
2417: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur');
2418: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur (
2419: p_batch_id => p_batch_id
2420: ,p_batch_mode_flag => p_batch_mode_flag
2421: ,p_from_osr => p_from_osr
2414: log ('For Update Contacts');
2415: log ('-------------------');
2416:
2417: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur');
2418: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_ct_cur (
2419: p_batch_id => p_batch_id
2420: ,p_batch_mode_flag => p_batch_mode_flag
2421: ,p_from_osr => p_from_osr
2422: ,p_to_osr => p_to_osr
2424: ,p_operation => 'U'
2425: ,x_sync_contact_cur => l_sync_contact_cur
2426: );
2427:
2428: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2429: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('U', 'IMPORT_SYNC', l_sync_contact_cur);
2430:
2431: -- Sync all contact_points
2432: -- For Create
2425: ,x_sync_contact_cur => l_sync_contact_cur
2426: );
2427:
2428: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contacts');
2429: HZ_STAGE_MAP_TRANSFORM.sync_all_contacts ('U', 'IMPORT_SYNC', l_sync_contact_cur);
2430:
2431: -- Sync all contact_points
2432: -- For Create
2433:
2434: log ('-------------------------');
2435: log ('For Create Contact Points');
2436: log ('-------------------------');
2437:
2438: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur');
2439: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur (
2440: p_batch_id => p_batch_id
2441: ,p_batch_mode_flag => p_batch_mode_flag
2442: ,p_from_osr => p_from_osr
2435: log ('For Create Contact Points');
2436: log ('-------------------------');
2437:
2438: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur');
2439: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur (
2440: p_batch_id => p_batch_id
2441: ,p_batch_mode_flag => p_batch_mode_flag
2442: ,p_from_osr => p_from_osr
2443: ,p_to_osr => p_to_osr
2445: ,p_operation => 'I'
2446: ,x_sync_cpt_cur => l_sync_cpt_cur
2447: );
2448:
2449: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2450: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('C', 'IMPORT_SYNC', l_sync_cpt_cur);
2451:
2452: -- For Update
2453:
2446: ,x_sync_cpt_cur => l_sync_cpt_cur
2447: );
2448:
2449: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2450: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('C', 'IMPORT_SYNC', l_sync_cpt_cur);
2451:
2452: -- For Update
2453:
2454: log ('-------------------------');
2454: log ('-------------------------');
2455: log ('For Update Contact Points');
2456: log ('-------------------------');
2457:
2458: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur');
2459: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur (
2460: p_batch_id => p_batch_id
2461: ,p_batch_mode_flag => p_batch_mode_flag
2462: ,p_from_osr => p_from_osr
2455: log ('For Update Contact Points');
2456: log ('-------------------------');
2457:
2458: log ('Calling HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur');
2459: HZ_STAGE_MAP_TRANSFORM.open_bulk_imp_sync_cpt_cur (
2460: p_batch_id => p_batch_id
2461: ,p_batch_mode_flag => p_batch_mode_flag
2462: ,p_from_osr => p_from_osr
2463: ,p_to_osr => p_to_osr
2465: ,p_operation => 'U'
2466: ,x_sync_cpt_cur => l_sync_cpt_cur
2467: );
2468:
2469: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2470: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'IMPORT_SYNC', l_sync_cpt_cur);
2471:
2472: END ;
2473:
2466: ,x_sync_cpt_cur => l_sync_cpt_cur
2467: );
2468:
2469: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2470: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'IMPORT_SYNC', l_sync_cpt_cur);
2471:
2472: END ;
2473:
2474: -- This would take a request_id , see if the corresponding conc program is complete