2531: log('');
2532: log('Stage Parties begin');
2533:
2534: FND_MSG_PUB.initialize;
2535: HZ_TRANS_PKG.set_staging_context('Y');
2536: IF p_command='STAGE_ALL_DATA' THEN
2537:
2538: SELECT SYSDATE INTO l_startdate FROM DUAL;
2539:
2555: WHERE OPERATION = p_command
2556: AND WORKER_NUMBER = l_worker_number AND step = l_log_step;
2557: COMMIT;
2558:
2559: HZ_TRANS_PKG.set_party_type('ORGANIZATION');
2560: HZ_STAGE_MAP_TRANSFORM.open_party_cursor(
2561: 'ALL_PARTIES', 'ORGANIZATION',l_worker_number, l_num_workers, NULL,'N', l_party_cur);
2562: HZ_STAGE_MAP_TRANSFORM.insert_stage_parties('N',l_party_cur);
2563: ELSE
2560: HZ_STAGE_MAP_TRANSFORM.open_party_cursor(
2561: 'ALL_PARTIES', 'ORGANIZATION',l_worker_number, l_num_workers, NULL,'N', l_party_cur);
2562: HZ_STAGE_MAP_TRANSFORM.insert_stage_parties('N',l_party_cur);
2563: ELSE
2564: HZ_TRANS_PKG.set_party_type('ORGANIZATION');
2565: log(' Continue for Org cursor');
2566: HZ_STAGE_MAP_TRANSFORM.open_party_cursor(
2567: 'ALL_PARTIES', 'ORGANIZATION',l_worker_number, l_num_workers, NULL,'Y', l_party_cur);
2568: HZ_STAGE_MAP_TRANSFORM.insert_stage_parties('Y',l_party_cur);
2593: WHERE OPERATION = p_command
2594: AND WORKER_NUMBER = l_worker_number AND step = l_log_step;
2595: COMMIT;
2596:
2597: HZ_TRANS_PKG.set_party_type('PERSON');
2598: HZ_STAGE_MAP_TRANSFORM.open_party_cursor(
2599: 'ALL_PARTIES', 'PERSON',l_worker_number, l_num_workers, NULL,'N', l_party_cur);
2600: HZ_STAGE_MAP_TRANSFORM.insert_stage_parties('N',l_party_cur);
2601: ELSE
2599: 'ALL_PARTIES', 'PERSON',l_worker_number, l_num_workers, NULL,'N', l_party_cur);
2600: HZ_STAGE_MAP_TRANSFORM.insert_stage_parties('N',l_party_cur);
2601: ELSE
2602: log(' Continue for Per cursor');
2603: HZ_TRANS_PKG.set_party_type('PERSON');
2604: HZ_STAGE_MAP_TRANSFORM.open_party_cursor(
2605: 'ALL_PARTIES', 'PERSON',l_worker_number, l_num_workers, NULL,'Y', l_party_cur);
2606: HZ_STAGE_MAP_TRANSFORM.insert_stage_parties('Y',l_party_cur);
2607: END IF;
2631: WHERE OPERATION = p_command
2632: AND WORKER_NUMBER = l_worker_number AND step = l_log_step;
2633: COMMIT;
2634:
2635: HZ_TRANS_PKG.set_party_type('OTHER');
2636: HZ_STAGE_MAP_TRANSFORM.open_party_cursor(
2637: 'ALL_PARTIES', 'OTHER',l_worker_number, l_num_workers, NULL,'N', l_party_cur);
2638: HZ_STAGE_MAP_TRANSFORM.insert_stage_parties('N',l_party_cur);
2639: ELSE
2638: HZ_STAGE_MAP_TRANSFORM.insert_stage_parties('N',l_party_cur);
2639: ELSE
2640: log(' Continue for Oth cursor');
2641:
2642: HZ_TRANS_PKG.set_party_type('OTHER');
2643: HZ_STAGE_MAP_TRANSFORM.open_party_cursor(
2644: 'ALL_PARTIES', 'OTHER',l_worker_number, l_num_workers, NULL,'Y', l_party_cur);
2645: HZ_STAGE_MAP_TRANSFORM.insert_stage_parties('Y',l_party_cur);
2646: END IF;
2677: COMMIT;
2678:
2679: END IF;
2680:
2681: HZ_TRANS_PKG.set_party_type('ORGANIZATION');
2682: HZ_STAGE_MAP_TRANSFORM_UPD.open_party_cursor(
2683: 'ORGANIZATION',l_worker_number, l_num_workers, l_party_cur);
2684: IF l_party_cur IS NOT NULL THEN
2685: HZ_STAGE_MAP_TRANSFORM_UPD.update_stage_parties(l_party_cur);
2711: AND WORKER_NUMBER = l_worker_number AND step = l_log_step;
2712:
2713: END IF;
2714:
2715: HZ_TRANS_PKG.set_party_type('PERSON');
2716: HZ_STAGE_MAP_TRANSFORM_UPD.open_party_cursor(
2717: 'PERSON',l_worker_number, l_num_workers, l_party_cur);
2718:
2719: IF l_party_cur IS NOT NULL THEN
2745: WHERE OPERATION = p_command
2746: AND WORKER_NUMBER = l_worker_number AND step = l_log_step;
2747: END IF;
2748:
2749: HZ_TRANS_PKG.set_party_type('OTHER');
2750: HZ_STAGE_MAP_TRANSFORM_UPD.open_party_cursor(
2751: 'OTHER',l_worker_number, l_num_workers, l_party_cur);
2752:
2753: IF l_party_cur IS NOT NULL THEN
4888: l(' AND p.party_type <> ''PARTY_RELATIONSHIP'' ');
4889: l(' AND ps.party_orig_system_reference between p_from_osr and p_to_osr; ');
4890: l(' END IF;');
4891: l('');
4892: l(' hz_trans_pkg.set_party_type(p_party_type); ');
4893: l('');
4894: l(' END open_bulk_imp_sync_party_cur;');
4895: l('');
4896: END gen_bulk_imp_sync_party_query;
5104: l(' AND p.party_type <> ''PERSON'' ');
5105: l(' AND p.party_type <> ''ORGANIZATION'' ');
5106: l(' AND p.party_type <> ''PARTY_RELATIONSHIP''; ');
5107: l(' END IF;');
5108: l(' hz_trans_pkg.set_party_type(p_party_type); ');
5109: l(' END;');
5110:
5111: l('');
5112: l(' PROCEDURE sync_all_parties ( ');
5983: l(' SELECT party_type INTO l_party_type ');
5984: l(' FROM hz_parties WHERE party_id = p_party_id; ');
5985: l('');
5986: l(' -- Set global G_PARTY_TYPE variable value');
5987: l(' hz_trans_pkg.set_party_type(l_party_type); ');
5988: l('');
5989: l(' IF l_party_type = ''PERSON'' THEN ');
5990: l(' ---------------------------------- ');
5991: l(' -- Take care of CONTACT INFORMATION ');