400: END;
401:
402: PROCEDURE generate_map_pkg_nolog IS
403: BEGIN
404: HZ_GEN_PLSQL.new('HZ_STAGE_MAP_TRANSFORM', 'PACKAGE BODY');
405: l('CREATE OR REPLACE PACKAGE BODY HZ_STAGE_MAP_TRANSFORM AS');
406:
407: generate_declarations;
408: generate_ds_proc;
401:
402: PROCEDURE generate_map_pkg_nolog IS
403: BEGIN
404: HZ_GEN_PLSQL.new('HZ_STAGE_MAP_TRANSFORM', 'PACKAGE BODY');
405: l('CREATE OR REPLACE PACKAGE BODY HZ_STAGE_MAP_TRANSFORM AS');
406:
407: generate_declarations;
408: generate_ds_proc;
409: generate_log;
623:
624:
625: PROCEDURE generate_map_pkg IS
626: BEGIN
627: log('Generating package body for HZ_STAGE_MAP_TRANSFORM');
628: HZ_GEN_PLSQL.new('HZ_STAGE_MAP_TRANSFORM', 'PACKAGE BODY');
629: l('CREATE OR REPLACE PACKAGE BODY HZ_STAGE_MAP_TRANSFORM AS');
630:
631: generate_declarations;
624:
625: PROCEDURE generate_map_pkg IS
626: BEGIN
627: log('Generating package body for HZ_STAGE_MAP_TRANSFORM');
628: HZ_GEN_PLSQL.new('HZ_STAGE_MAP_TRANSFORM', 'PACKAGE BODY');
629: l('CREATE OR REPLACE PACKAGE BODY HZ_STAGE_MAP_TRANSFORM AS');
630:
631: generate_declarations;
632: generate_ds_proc;
625: PROCEDURE generate_map_pkg IS
626: BEGIN
627: log('Generating package body for HZ_STAGE_MAP_TRANSFORM');
628: HZ_GEN_PLSQL.new('HZ_STAGE_MAP_TRANSFORM', 'PACKAGE BODY');
629: l('CREATE OR REPLACE PACKAGE BODY HZ_STAGE_MAP_TRANSFORM AS');
630:
631: generate_declarations;
632: generate_ds_proc;
633: generate_log;
721: x_rebuild_cpt_idx OUT NOCOPY BOOLEAN) IS
722:
723: BEGIN
724:
725: log('Generating package body for HZ_STAGE_MAP_TRANSFORM_UPD');
726: HZ_GEN_PLSQL.new('HZ_STAGE_MAP_TRANSFORM_UPD', 'PACKAGE BODY');
727: l('CREATE OR REPLACE PACKAGE BODY HZ_STAGE_MAP_TRANSFORM_UPD AS');
728:
729: generate_declarations;
722:
723: BEGIN
724:
725: log('Generating package body for HZ_STAGE_MAP_TRANSFORM_UPD');
726: HZ_GEN_PLSQL.new('HZ_STAGE_MAP_TRANSFORM_UPD', 'PACKAGE BODY');
727: l('CREATE OR REPLACE PACKAGE BODY HZ_STAGE_MAP_TRANSFORM_UPD AS');
728:
729: generate_declarations;
730: generate_party_query_upd(x_rebuild_party_idx);
723: BEGIN
724:
725: log('Generating package body for HZ_STAGE_MAP_TRANSFORM_UPD');
726: HZ_GEN_PLSQL.new('HZ_STAGE_MAP_TRANSFORM_UPD', 'PACKAGE BODY');
727: l('CREATE OR REPLACE PACKAGE BODY HZ_STAGE_MAP_TRANSFORM_UPD AS');
728:
729: generate_declarations;
730: generate_party_query_upd(x_rebuild_party_idx);
731: generate_contact_query_upd(x_rebuild_psite_idx);
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
2564: HZ_TRANS_PKG.set_party_type('ORGANIZATION');
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
2564: HZ_TRANS_PKG.set_party_type('ORGANIZATION');
2565: log(' Continue for Org cursor');
2566: HZ_STAGE_MAP_TRANSFORM.open_party_cursor(
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);
2569: END IF;
2570:
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);
2569: END IF;
2570:
2571: CLOSE l_party_cur;
2572: l_log_step := 'STEP1';
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
2602: log(' Continue for Per cursor');
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
2602: log(' Continue for Per cursor');
2603: HZ_TRANS_PKG.set_party_type('PERSON');
2604: HZ_STAGE_MAP_TRANSFORM.open_party_cursor(
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;
2608:
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;
2608:
2609: CLOSE l_party_cur;
2610: l_log_step := 'STEP2';
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
2640: log(' Continue for Oth cursor');
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
2640: log(' Continue for Oth cursor');
2641:
2642: HZ_TRANS_PKG.set_party_type('OTHER');
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;
2647:
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;
2647:
2648: CLOSE l_party_cur;
2649: l_log_step := 'STEP3';
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);
2686: CLOSE l_party_cur;
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);
2686: CLOSE l_party_cur;
2687: END IF;
2688:
2689: l_log_step := 'STEP1';
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
2720: HZ_STAGE_MAP_TRANSFORM_UPD.update_stage_parties(l_party_cur);
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
2720: HZ_STAGE_MAP_TRANSFORM_UPD.update_stage_parties(l_party_cur);
2721: CLOSE l_party_cur;
2722: END IF;
2723: l_log_step := 'STEP2';
2724: UPDATE HZ_DQM_STAGE_LOG set end_flag='Y', end_time = SYSDATE
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
2754: HZ_STAGE_MAP_TRANSFORM_UPD.update_stage_parties(l_party_cur);
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
2754: HZ_STAGE_MAP_TRANSFORM_UPD.update_stage_parties(l_party_cur);
2755: CLOSE l_party_cur;
2756: END IF;
2757:
2758: l_log_step := 'STEP3';
2781: AND WORKER_NUMBER = l_worker_number AND step = l_log_step;
2782:
2783: END IF;
2784:
2785: HZ_STAGE_MAP_TRANSFORM_UPD.open_contact_cursor(
2786: l_worker_number, l_num_workers, l_contact_cur);
2787: IF l_contact_cur IS NOT NULL THEN
2788: HZ_STAGE_MAP_TRANSFORM_UPD.update_stage_contacts(l_contact_cur);
2789: CLOSE l_contact_cur;
2784:
2785: HZ_STAGE_MAP_TRANSFORM_UPD.open_contact_cursor(
2786: l_worker_number, l_num_workers, l_contact_cur);
2787: IF l_contact_cur IS NOT NULL THEN
2788: HZ_STAGE_MAP_TRANSFORM_UPD.update_stage_contacts(l_contact_cur);
2789: CLOSE l_contact_cur;
2790: END IF;
2791: l_log_step := 'STEP4';
2792: UPDATE HZ_DQM_STAGE_LOG set end_flag='Y', end_time = SYSDATE
2814: AND WORKER_NUMBER = l_worker_number AND step = l_log_step;
2815:
2816: END IF;
2817:
2818: HZ_STAGE_MAP_TRANSFORM_UPD.open_party_site_cursor(
2819: l_worker_number, l_num_workers, l_party_site_cur);
2820: IF l_party_site_cur IS NOT NULL THEN
2821: HZ_STAGE_MAP_TRANSFORM_UPD.update_stage_party_sites(l_party_site_cur);
2822: CLOSE l_party_site_cur;
2817:
2818: HZ_STAGE_MAP_TRANSFORM_UPD.open_party_site_cursor(
2819: l_worker_number, l_num_workers, l_party_site_cur);
2820: IF l_party_site_cur IS NOT NULL THEN
2821: HZ_STAGE_MAP_TRANSFORM_UPD.update_stage_party_sites(l_party_site_cur);
2822: CLOSE l_party_site_cur;
2823: END IF;
2824:
2825: l_log_step := 'STEP5';
2847: AND WORKER_NUMBER = l_worker_number AND step = l_log_step;
2848:
2849: END IF;
2850:
2851: HZ_STAGE_MAP_TRANSFORM_UPD.open_contact_pt_cursor(
2852: l_worker_number, l_num_workers, l_cpt_cur);
2853: IF l_cpt_cur IS NOT NULL THEN
2854: HZ_STAGE_MAP_TRANSFORM_UPD.update_stage_contact_pts(l_cpt_cur);
2855: CLOSE l_cpt_cur;
2850:
2851: HZ_STAGE_MAP_TRANSFORM_UPD.open_contact_pt_cursor(
2852: l_worker_number, l_num_workers, l_cpt_cur);
2853: IF l_cpt_cur IS NOT NULL THEN
2854: HZ_STAGE_MAP_TRANSFORM_UPD.update_stage_contact_pts(l_cpt_cur);
2855: CLOSE l_cpt_cur;
2856: END IF;
2857: l_log_step := 'STEP6';
2858: UPDATE HZ_DQM_STAGE_LOG set end_flag='Y', end_time = SYSDATE
4667: l('');
4668:
4669: END;
4670:
4671: -- REPURI. Proccedure to generate the code (into HZ_STAGE_MAP_TRANSFORM)
4672: -- for OPEN_BULK_IMP_SYNC_PARTY_CUR procedure. Bug 4884735.
4673:
4674: PROCEDURE gen_bulk_imp_sync_party_query IS
4675:
4894: l(' END open_bulk_imp_sync_party_cur;');
4895: l('');
4896: END gen_bulk_imp_sync_party_query;
4897:
4898: -- REPURI. Proccedure to generate the code (into HZ_STAGE_MAP_TRANSFORM)
4899: -- for OPEN_SYNC_PARTY_CURSOR and SYNC_ALL_PARTIES Procedures.
4900:
4901: PROCEDURE generate_sync_party_query_proc IS
4902:
6191: l(' END;');
6192:
6193: END;
6194:
6195: -- REPURI. Proccedure to generate the code (into HZ_STAGE_MAP_TRANSFORM)
6196: -- for OPEN_BULK_IMP_SYNC_PSITE_CUR Procedure. Bug 4884735.
6197:
6198: PROCEDURE gen_bulk_imp_sync_psite_query IS
6199: cur_col_num NUMBER := 1;
6349: l('');
6350: END gen_bulk_imp_sync_psite_query;
6351:
6352:
6353: -- REPURI. Proccedure to generate the code (into HZ_STAGE_MAP_TRANSFORM)
6354: -- for OPEN_SYNC_PARTY_SITE_CURSOR and SYNC_ALL_PARTY_SITES Procedures.
6355:
6356: PROCEDURE generate_sync_psite_query_proc IS
6357: cur_col_num NUMBER := 1;
7447: l(' END;');
7448:
7449: END;
7450:
7451: -- REPURI. Proccedure to generate the code (into HZ_STAGE_MAP_TRANSFORM)
7452: -- for OPEN_BULK_IMP_SYNC_CT_CUR query procedure. Bug 4884735.
7453:
7454: PROCEDURE gen_bulk_imp_sync_ct_query IS
7455: cur_col_num NUMBER := 1;
7650: END gen_bulk_imp_sync_ct_query;
7651:
7652:
7653:
7654: -- REPURI. Proccedure to generate the code (into HZ_STAGE_MAP_TRANSFORM)
7655: -- for OPEN_SYNC_CONTACT_CURSOR and SYNC_ALL_CONTACTS Procedures.
7656:
7657: PROCEDURE generate_sync_ct_query_proc IS
7658: cur_col_num NUMBER := 1;
8740:
8741: END;
8742:
8743:
8744: -- REPURI. Proccedure to generate the code (into HZ_STAGE_MAP_TRANSFORM)
8745: -- for OPEN_BULK_IMP_SYNC_CPT_CUR query procedure. Bug 4884735.
8746:
8747:
8748: PROCEDURE gen_bulk_imp_sync_cpt_query IS
8913:
8914: END gen_bulk_imp_sync_cpt_query;
8915:
8916:
8917: -- REPURI. Proccedure to generate the code (into HZ_STAGE_MAP_TRANSFORM)
8918: -- for OPEN_SYNC_CPT_CURSOR and SYNC_ALL_CONTACT_POINTS Procedures.
8919:
8920: PROCEDURE generate_sync_cpt_query_proc IS
8921: