[Home] [Help]
70: l_msg_data VARCHAR2(2000);
71: BEGIN
72: FND_MSG_PUB.Reset;
73: FOR I IN 1..FND_MSG_PUB.Count_Msg LOOP
74: l_msg_data := substr(l_msg_data || FND_MSG_PUB.Get(p_encoded => FND_API.G_FALSE ), 1, 2000) ;
75: END LOOP;
76: IF (SQLERRM IS NOT NULL) THEN
77: l_msg_data := substr(l_msg_data || SQLERRM, 1, 2000);
78: END IF;
142: log(' hz_imp_batch_summary.original_system has return null. This indicates an error during batch setup.');
143: END IF;
144: RETURN l_os;
145: EXCEPTION WHEN others THEN
146: RAISE FND_API.G_EXC_ERROR;
147: END get_os;
148:
149: PROCEDURE POP_INTERFACE_SEARCH_TAB (
150: p_batch_id IN NUMBER,
156: x_msg_data OUT NOCOPY VARCHAR2
157: ) IS
158: l_sql_stmt VARCHAR2(255) ;
159: BEGIN
160: x_return_status := fnd_api.g_ret_sts_success;
161: hz_trans_pkg.set_bulk_dup_id ;
162: -- execute immediate ' begin HZ_IMP_MATCH_RULE_'||p_match_rule_id||'.pop_parties_int('|| p_batch_id ||',' || p_from_osr ||','|| p_to_osr||'); end;';
163: l_sql_stmt := ' begin HZ_IMP_MATCH_RULE_'||p_match_rule_id||'.pop_parties_int(:1, :2, :3); end;';
164: execute immediate l_sql_stmt using p_batch_id, p_from_osr, p_to_osr;
172: l_sql_stmt := ' begin HZ_IMP_MATCH_RULE_'||p_match_rule_id||'.pop_contacts_int(:1, :2,:3); end;';
173: execute immediate l_sql_stmt using p_batch_id, p_from_osr, p_to_osr;
174:
175: EXCEPTION WHEN others THEN
176: x_return_status := fnd_api.g_ret_sts_unexp_error;
177: FND_MESSAGE.SET_NAME('AR', 'HZ_DQM_API_ERROR');
178: FND_MESSAGE.SET_TOKEN('PROC' ,'POP_INTERFACE_SEARCH_TAB');
179: FND_MESSAGE.SET_TOKEN('ERROR' , SQLERRM);
180: FND_MSG_PUB.ADD;
177: FND_MESSAGE.SET_NAME('AR', 'HZ_DQM_API_ERROR');
178: FND_MESSAGE.SET_TOKEN('PROC' ,'POP_INTERFACE_SEARCH_TAB');
179: FND_MESSAGE.SET_TOKEN('ERROR' , SQLERRM);
180: FND_MSG_PUB.ADD;
181: fnd_msg_pub.count_and_get(p_encoded => fnd_api.g_false,
182: p_count => x_msg_count,
183: p_data => x_msg_data);
184: END POP_INTERFACE_SEARCH_TAB;
185:
206: log(' p_from_osr = '|| p_from_osr);
207: log(' p_to_osr = ' || p_to_osr);
208: log(' p_batch_mode_flag = '|| p_batch_mode_flag);
209:
210: x_return_status := fnd_api.g_ret_sts_success;
211: hz_trans_pkg.set_bulk_dup_id ;
212: select batch_dedup_flag, batch_dedup_match_rule_id, registry_dedup_match_rule_id, addr_val_flag
213: into l_a, l_c, l_d, l_e
214: from hz_imp_batch_summary
311: execute immediate l_sql_stmt using p_batch_id, p_from_osr, p_to_osr, p_batch_mode_flag;
312: END IF;
313: log('End of staging for interface_tca POP_INT_TCA_SEARCH_TAB');
314: EXCEPTION WHEN others THEN
315: x_return_status := fnd_api.g_ret_sts_unexp_error;
316: FND_MESSAGE.SET_NAME('AR', 'HZ_DQM_API_ERROR');
317: FND_MESSAGE.SET_TOKEN('PROC' ,'POP_INT_TCA_SEARCH_TAB');
318: FND_MESSAGE.SET_TOKEN('ERROR' , SQLERRM);
319: FND_MSG_PUB.ADD;
316: FND_MESSAGE.SET_NAME('AR', 'HZ_DQM_API_ERROR');
317: FND_MESSAGE.SET_TOKEN('PROC' ,'POP_INT_TCA_SEARCH_TAB');
318: FND_MESSAGE.SET_TOKEN('ERROR' , SQLERRM);
319: FND_MSG_PUB.ADD;
320: fnd_msg_pub.count_and_get(p_encoded => fnd_api.g_false,
321: p_count => x_msg_count,
322: p_data => x_msg_data);
323: END POP_INT_TCA_SEARCH_TAB;
324:
398: execute immediate l_sql_stmt using p_batch_id;
399: END IF;
400: EXCEPTION WHEN OTHERS THEN
401: log(SQLERRM);
402: RAISE FND_API.G_EXC_ERROR;
403: END chk_table;
404:
405: PROCEDURE chk_srch_tab ( p_batch_id IN NUMBER
406: ) IS
412: chk_table('HZ_SRCH_PSITES', p_batch_id);
413: chk_table('HZ_SRCH_CONTACTS', p_batch_id);
414: chk_table('HZ_SRCH_CPTS', p_batch_id);
415: EXCEPTION WHEN OTHERS THEN
416: RAISE FND_API.G_EXC_ERROR;
417: END chk_srch_tab;
418:
419: PROCEDURE dqm_post_imp_cleanup (
420: p_batch_id IN NUMBER,
423: x_msg_data OUT NOCOPY VARCHAR2
424: ) IS
425: l_procedure_name VARCHAR2(30) := '.DQM_POST_IMP_CLEANUP' ;
426: BEGIN
427: x_return_status := fnd_api.g_ret_sts_success;
428: log(' HZ_DQM_DUP_ID_PKG.final_process_int_tca_dup_id(' || p_batch_id || '); +');
429: HZ_DQM_DUP_ID_PKG.final_process_int_tca_dup_id(p_batch_id);
430: log(' HZ_DQM_DUP_ID_PKG.final_process_int_tca_dup_id(' || p_batch_id || '); -');
431: chk_srch_tab(p_batch_id);
431: chk_srch_tab(p_batch_id);
432: delete from HZ_INT_DUP_RESULTS where batch_id = p_batch_id;
433: EXCEPTION WHEN OTHERS THEN
434: log(SQLERRM);
435: x_return_status := fnd_api.g_ret_sts_unexp_error;
436: FND_MESSAGE.SET_NAME('AR', 'HZ_DQM_API_ERROR');
437: FND_MESSAGE.SET_TOKEN('PROC' ,'DQM_POST_IMP_CLEANUP');
438: FND_MESSAGE.SET_TOKEN('ERROR' , SQLERRM);
439: FND_MSG_PUB.ADD;
436: FND_MESSAGE.SET_NAME('AR', 'HZ_DQM_API_ERROR');
437: FND_MESSAGE.SET_TOKEN('PROC' ,'DQM_POST_IMP_CLEANUP');
438: FND_MESSAGE.SET_TOKEN('ERROR' , SQLERRM);
439: FND_MSG_PUB.ADD;
440: fnd_msg_pub.count_and_get(p_encoded => fnd_api.g_false,
441: p_count => x_msg_count,
442: p_data => x_msg_data);
443: END dqm_post_imp_cleanup;
444:
452: l_sql_stmt := ' delete from ' ||l_owner || '.' || p_table_name || ' where batch_id = :1 ';
453: execute immediate l_sql_stmt using p_batch_id;
454: EXCEPTION WHEN OTHERS THEN
455: log(SQLERRM);
456: RAISE FND_API.G_EXC_ERROR;
457: END del_from_table;
458:
459:
460:
468: l_owner VARCHAR2(255);
469: l_table_name VARCHAR2(30);
470: l_sql_stmt VARCHAR2(255);
471: BEGIN
472: x_return_status := fnd_api.g_ret_sts_success;
473: chk_srch_tab(p_batch_id);
474: delete from HZ_IMP_INT_DEDUP_RESULTS where batch_id = p_batch_id;
475: delete from HZ_IMP_DUP_PARTIES where batch_id = p_batch_id;
476: delete from HZ_IMP_DUP_DETAILS where batch_id = p_batch_id;
475: delete from HZ_IMP_DUP_PARTIES where batch_id = p_batch_id;
476: delete from HZ_IMP_DUP_DETAILS where batch_id = p_batch_id;
477: EXCEPTION WHEN OTHERS THEN
478: log(SQLERRM);
479: x_return_status := fnd_api.g_ret_sts_unexp_error;
480: FND_MESSAGE.SET_NAME('AR', 'HZ_DQM_API_ERROR');
481: FND_MESSAGE.SET_TOKEN('PROC' ,'DQM_PRE_IMP_CLEANUP');
482: FND_MESSAGE.SET_TOKEN('ERROR' , SQLERRM);
483: FND_MSG_PUB.ADD;
480: FND_MESSAGE.SET_NAME('AR', 'HZ_DQM_API_ERROR');
481: FND_MESSAGE.SET_TOKEN('PROC' ,'DQM_PRE_IMP_CLEANUP');
482: FND_MESSAGE.SET_TOKEN('ERROR' , SQLERRM);
483: FND_MSG_PUB.ADD;
484: fnd_msg_pub.count_and_get(p_encoded => fnd_api.g_false,
485: p_count => x_msg_count,
486: p_data => x_msg_data);
487: END dqm_pre_imp_cleanup;
488:
501: END IF;
502: RETURN l_owner;
503: EXCEPTION WHEN OTHERS THEN
504: log(SQLERRM);
505: RAISE FND_API.G_EXC_ERROR;
506: END get_owner_name;
507:
508: /*
509: PROCEDURE del_existing_rec(p_et_name IN VARCHAR,
568: l_temp VARCHAR2(255);
569: l_sqlstr VARCHAR2(4000);
570:
571: BEGIN
572: x_return_status := fnd_api.g_ret_sts_success;
573: select batch_dedup_flag, registry_dedup_flag, batch_dedup_match_rule_id, registry_dedup_match_rule_id, addr_val_flag
574: into l_a, l_b, l_c, l_d, l_e
575: from hz_imp_batch_summary
576: where batch_id = p_batch_id;
599: END IF;
600: END IF;
601: EXCEPTION WHEN OTHERS THEN
602: log(SQLERRM); --
603: x_return_status := fnd_api.g_ret_sts_unexp_error;
604: FND_MESSAGE.SET_NAME('AR', 'HZ_DQM_API_ERROR');
605: FND_MESSAGE.SET_TOKEN('PROC' ,'DQM_INTER_IMP_CLEANUP');
606: FND_MESSAGE.SET_TOKEN('ERROR' , SQLERRM);
607: FND_MSG_PUB.ADD;
604: FND_MESSAGE.SET_NAME('AR', 'HZ_DQM_API_ERROR');
605: FND_MESSAGE.SET_TOKEN('PROC' ,'DQM_INTER_IMP_CLEANUP');
606: FND_MESSAGE.SET_TOKEN('ERROR' , SQLERRM);
607: FND_MSG_PUB.ADD;
608: fnd_msg_pub.count_and_get(p_encoded => fnd_api.g_false,
609: p_count => x_msg_count,
610: p_data => x_msg_data);
611: END dqm_inter_imp_cleanup;
612:
645: x_msg_data VARCHAR2(255);
646: l_row_id VARCHAR2(100);
647:
648: BEGIN
649: x_return_status := fnd_api.g_ret_sts_success;
650: LOOP
651: log(' Processing worker ' || p_worker_num );
652: l_row_id := NULL;
653: IF (p_phase = 'PHASE_1') THEN
666: HZ_IMP_DQM_STAGE.POP_INTERFACE_SEARCH_TAB(to_number(p_batch_id),
667: to_number(p_match_rule_id), l_from_osr, l_to_osr,
668: x_return_status, x_msg_count, x_msg_data);
669:
670: IF (x_return_status <> fnd_api.g_ret_sts_success) THEN
671: retcode := 2;
672: err := x_msg_data;
673: logerror;
674: UPDATE hz_imp_work_units SET BATCH_DEDUP_STATUS = 'E' where rowid = l_row_id;
671: retcode := 2;
672: err := x_msg_data;
673: logerror;
674: UPDATE hz_imp_work_units SET BATCH_DEDUP_STATUS = 'E' where rowid = l_row_id;
675: RAISE FND_API.G_EXC_ERROR;
676: ELSE
677: UPDATE hz_imp_work_units SET BATCH_DEDUP_STATUS = 'C' where rowid = l_row_id;
678: END IF;
679: COMMIT;
685: EXIT;
686: END IF;
687: COMMIT;
688: HZ_DQM_DUP_ID_PKG.interface_dup_id_worker(p_batch_id, p_match_rule_id, l_from_osr, l_to_osr, x_return_status, x_msg_count, x_msg_data);
689: IF (x_return_status <> fnd_api.g_ret_sts_success) THEN
690: retcode := 2;
691: err := x_msg_data;
692: logerror;
693: UPDATE hz_imp_work_units SET BATCH_DEDUP_STATUS = 'E' WHERE ROWID = l_row_id;
690: retcode := 2;
691: err := x_msg_data;
692: logerror;
693: UPDATE hz_imp_work_units SET BATCH_DEDUP_STATUS = 'E' WHERE ROWID = l_row_id;
694: RAISE FND_API.G_EXC_ERROR;
695: ELSE
696: UPDATE hz_imp_work_units SET BATCH_DEDUP_STATUS = 'C' WHERE ROWID = l_row_id;
697: END IF;
698: COMMIT;
701: EXCEPTION WHEN OTHERS THEN
702: retcode := 2;
703: err := SQLERRM;
704: log ('Error ::'|| err);
705: RAISE FND_API.G_EXC_ERROR;
706: END interface_dup_id_worker;
707:
708:
709: PROCEDURE interface_dup_id(
769: IF l_sub_requests(i) = 0 THEN
770: log('Error submitting worker ' || i);
771: log(fnd_message.get);
772: retcode := 2;
773: RAISE FND_API.G_EXC_ERROR;
774: ELSE
775: log('Submitted request for Worker ' || TO_CHAR(I) );
776: log('Request ID : ' || l_sub_requests(i));
777: END IF;
795: outandlog('Worker with request id ' || l_sub_requests(I) );
796: outandlog('Did not complete normally.');
797: retcode := 2;
798: log(' retcode = ' || retcode);
799: RAISE FND_API.G_EXC_ERROR;
800: END LOOP;
801: END IF;
802: log('p_rule_id '||p_match_rule_id);
803: IF l_workers_completed THEN
834: outandlog('Worker with request id ' || l_sub_requests(I) );
835: outandlog('Did not complete normally');
836: retcode := 2;
837: log(' retcode = ' || retcode);
838: RAISE FND_API.G_EXC_ERROR;
839: END LOOP;
840: END IF;
841: log('p_rule_id '||p_match_rule_id);
842: IF l_workers_completed THEN
853: retcode := 2;
854: log(' retcode . = ' || retcode);
855: UPDATE HZ_IMP_BATCH_SUMMARY set BATCH_DEDUP_STATUS = 'ERROR' where batch_id = p_batch_id;
856: COMMIT;
857: RAISE FND_API.G_EXC_ERROR;
858: END interface_dup_id;
859:
860: PROCEDURE gen_pkg_spec (
861: p_pkg_name IN VARCHAR2,
916: IF is_test THEN
917: l('END ' || p_pkg_name || ';'); -- this
918: END IF;
919: EXCEPTION WHEN OTHERS THEN
920: RAISE FND_API.G_EXC_ERROR;
921: END gen_pkg_spec;
922:
923:
924: PROCEDURE get_table_name (
1093: fnd_log.string(fnd_log.LEVEL_ERROR,G_PKG_NAME||l_procedure_name,'p_et_point = '||p_et_point);
1094: END IF;
1095: END IF;
1096: EXCEPTION WHEN OTHERS THEN
1097: RAISE FND_API.G_EXC_ERROR;
1098: END get_select_str;
1099:
1100: PROCEDURE get_trans_str (
1101: p_entity_name IN VARCHAR2,
1215: fnd_log.string(fnd_log.LEVEL_ERROR,G_PKG_NAME||l_procedure_name,'p_et_point = '|| p_et_point);
1216: END IF;
1217: END IF;
1218: EXCEPTION WHEN OTHERS THEN
1219: RAISE FND_API.G_EXC_ERROR;
1220:
1221: END get_trans_str;
1222:
1223: PROCEDURE get_cust_insert_str (
1411: fnd_log.string(fnd_log.LEVEL_ERROR,G_PKG_NAME||l_procedure_name,'p_et_point = '|| p_et_point);
1412: END IF;
1413: END IF;
1414: EXCEPTION WHEN OTHERS THEN
1415: RAISE FND_API.G_EXC_ERROR;
1416:
1417: END get_insert_str;
1418:
1419: PROCEDURE get_cust_insert_val_str (
1607: fnd_log.string(fnd_log.LEVEL_ERROR,G_PKG_NAME||l_procedure_name,'p_et_point = '|| p_et_point);
1608: END IF;
1609: END IF;
1610: EXCEPTION WHEN OTHERS THEN
1611: RAISE FND_API.G_EXC_ERROR;
1612:
1613: END get_insert_val_str;
1614:
1615: /*
1944: l_trans_list(i + 3) := ' H_P_PS_CUST_TX27(I) := HZ_TRANS_PKG.BASIC_CLEANSE_WRADDR(H_P_PS_ADD(I), NULL, ''ADDRESS'', ''PARTY_SITES'', ''SEARCH''); '; */
1945: END IF;
1946: END IF;
1947: EXCEPTION WHEN OTHERS THEN
1948: RAISE FND_API.G_EXC_ERROR;
1949: END get_trans_proc;
1950:
1951: PROCEDURE gen_pop_parties (
1952: p_rule_id IN NUMBER
2088: l(' null;');
2089: END IF;
2090: l(' END pop_parties; ');
2091: EXCEPTION WHEN OTHERS THEN
2092: RAISE FND_API.G_EXC_ERROR;
2093: END gen_pop_parties;
2094:
2095:
2096: PROCEDURE gen_pop_parties_int (
2229: l(' null; ');
2230: END IF;
2231: l(' END pop_parties_int; ');
2232: EXCEPTION WHEN OTHERS THEN
2233: RAISE FND_API.G_EXC_ERROR;
2234: END gen_pop_parties_int ;
2235:
2236:
2237: PROCEDURE gen_pop_party_sites (
2406: l(' null;');
2407: END IF;
2408: l(' END pop_party_sites; ');
2409: EXCEPTION WHEN OTHERS THEN
2410: RAISE FND_API.G_EXC_ERROR;
2411: END gen_pop_party_sites;
2412:
2413:
2414: PROCEDURE gen_pop_party_sites_int (
2552: l(' null;');
2553: END IF;
2554: l(' END pop_party_sites_int; ');
2555: EXCEPTION WHEN OTHERS THEN
2556: RAISE FND_API.G_EXC_ERROR;
2557:
2558: END gen_pop_party_sites_int;
2559:
2560: PROCEDURE gen_static_text(
2577: l(' ) IS');
2578: l(' ');
2579: l(' BEGIN');
2580: l(' ');
2581: l(' x_return_status := fnd_api.g_ret_sts_success; ');
2582: l(' pop_parties(p_batch_id, p_from_osr, p_to_osr);');
2583: l(' pop_party_sites(p_batch_id, p_from_osr, p_to_osr);');
2584: l(' pop_cp(p_batch_id, p_from_osr, p_to_osr);');
2585: l(' pop_contacts(p_batch_id, p_from_osr, p_to_osr);');
2584: l(' pop_cp(p_batch_id, p_from_osr, p_to_osr);');
2585: l(' pop_contacts(p_batch_id, p_from_osr, p_to_osr);');
2586: l(' -- build_srch_indexes(); ');
2587: l(' EXCEPTION WHEN others THEN ');
2588: l(' x_return_status := fnd_api.g_ret_sts_unexp_error; ');
2589: l(' fnd_msg_pub.count_and_get(p_encoded => fnd_api.g_false, ');
2590: l(' p_count => x_msg_count, ');
2591: l(' p_data => x_msg_data); ');
2592: l(' RAISE; ');
2585: l(' pop_contacts(p_batch_id, p_from_osr, p_to_osr);');
2586: l(' -- build_srch_indexes(); ');
2587: l(' EXCEPTION WHEN others THEN ');
2588: l(' x_return_status := fnd_api.g_ret_sts_unexp_error; ');
2589: l(' fnd_msg_pub.count_and_get(p_encoded => fnd_api.g_false, ');
2590: l(' p_count => x_msg_count, ');
2591: l(' p_data => x_msg_data); ');
2592: l(' RAISE; ');
2593: l(' END POP_INTERFACE_SEARCH_TAB;');
2609: l(' l_e VARCHAR2(1); ');
2610: l(' ');
2611:
2612: l(' BEGIN ');
2613: l(' x_return_status := fnd_api.g_ret_sts_success; ');
2614: l(' select batch_dedup_flag, registry_dedup_flag, batch_dedup_match_rule_id, registry_dedup_match_rule_id, addr_val_flag ');
2615: l(' into l_a, l_b, l_c, l_d, l_e ');
2616: l(' from hz_imp_batch_summary ');
2617: l(' where batch_id = p_batch_id; ');
2629: l(' END IF; ');
2630: l(' END IF; ');
2631:
2632: l(' EXCEPTION WHEN others THEN ');
2633: l(' x_return_status := fnd_api.g_ret_sts_unexp_error; ');
2634: l(' fnd_msg_pub.count_and_get(p_encoded => fnd_api.g_false, ');
2635: l(' p_count => x_msg_count, ');
2636: l(' p_data => x_msg_data); ');
2637: l(' RAISE; ');
2630: l(' END IF; ');
2631:
2632: l(' EXCEPTION WHEN others THEN ');
2633: l(' x_return_status := fnd_api.g_ret_sts_unexp_error; ');
2634: l(' fnd_msg_pub.count_and_get(p_encoded => fnd_api.g_false, ');
2635: l(' p_count => x_msg_count, ');
2636: l(' p_data => x_msg_data); ');
2637: l(' RAISE; ');
2638: l(' END POP_INT_TCA_SEARCH_TAB; ');
2638: l(' END POP_INT_TCA_SEARCH_TAB; ');
2639:
2640: l(' ');
2641: EXCEPTION WHEN OTHERS THEN
2642: RAISE FND_API.G_EXC_ERROR;
2643: END gen_static_text;
2644:
2645: PROCEDURE gen_get_contact_cur (
2646: p_rule_id IN NUMBER
2778: END IF;
2779: l(' END get_contact_cur; ');
2780: l(' ');
2781: EXCEPTION WHEN OTHERS THEN
2782: RAISE FND_API.G_EXC_ERROR;
2783: END gen_get_contact_cur;
2784:
2785:
2786: PROCEDURE gen_get_contact_cur_int (
2900: END IF;
2901: l(' END get_contact_cur_int; ');
2902: l(' ');
2903: EXCEPTION WHEN OTHERS THEN
2904: RAISE FND_API.G_EXC_ERROR;
2905: END gen_get_contact_cur_int;
2906:
2907: PROCEDURE gen_pop_contacts (
2908: p_rule_id IN NUMBER
3022: END IF;
3023: l(' END pop_contacts; ');
3024: l(' ');
3025: EXCEPTION WHEN OTHERS THEN
3026: RAISE FND_API.G_EXC_ERROR;
3027: END gen_pop_contacts;
3028:
3029:
3030: PROCEDURE gen_pop_contacts_int (
3142: l(' null; ');
3143: END IF;
3144: l(' END pop_contacts_int; ');
3145: EXCEPTION WHEN OTHERS THEN
3146: RAISE FND_API.G_EXC_ERROR;
3147: END gen_pop_contacts_int;
3148:
3149: PROCEDURE gen_pop_cp (
3150: p_rule_id IN NUMBER
3296: l(' null;');
3297: END IF;
3298: l(' END pop_cp; ');
3299: EXCEPTION WHEN OTHERS THEN
3300: RAISE FND_API.G_EXC_ERROR;
3301: END gen_pop_cp;
3302:
3303:
3304: PROCEDURE gen_pop_cp_int (
3439: l(' null; ');
3440: END IF;
3441: l(' END pop_cp_int; ');
3442: EXCEPTION WHEN OTHERS THEN
3443: RAISE FND_API.G_EXC_ERROR;
3444: END gen_pop_cp_int;
3445:
3446: PROCEDURE gen_declarations (
3447: p_rule_id IN NUMBER
3610: l(' H_P_PS_CUST_TX27 CharList240; ');
3611: */
3612: END IF;
3613: EXCEPTION WHEN OTHERS THEN
3614: RAISE FND_API.G_EXC_ERROR;
3615: END gen_declarations;
3616:
3617: FUNCTION chk_is_std(p_attribute_name IN VARCHAR2
3618: ) RETURN VARCHAR2
3757: IF is_test THEN
3758: l('END ' || p_pkg_name || ';'); -- this
3759: END IF;
3760: EXCEPTION WHEN OTHERS THEN
3761: RAISE FND_API.G_EXC_ERROR;
3762:
3763: END gen_pkg_body;
3764:
3765: FUNCTION EXIST_COL (attr_name IN VARCHAR2,
3835: fnd_log_repository.init;
3836: fnd_log.string(fnd_log.LEVEL_STATEMENT,G_PKG_NAME||l_procedure_name,'Enter, p_rule_id='||p_rule_id);
3837: END IF;
3838: --Initialize API return status to success.
3839: x_return_status := FND_API.G_RET_STS_SUCCESS;
3840: -- Initialize the compiled package name
3841: l_rule_id := TO_NUMBER(p_rule_id);
3842: l_package_name := 'HZ_IMP_MATCH_RULE_'||p_rule_id;
3843: -- Initialize message stack
3853: EXCEPTION
3854: WHEN NO_DATA_FOUND THEN
3855: FND_MESSAGE.SET_NAME('AR', 'HZ_STAGE_NO_RULE');
3856: FND_MSG_PUB.ADD;
3857: RAISE FND_API.G_EXC_ERROR;
3858: END;
3859: -- Check if match rule has any inactive transformations
3860: OPEN check_inactive;
3861: FETCH check_inactive INTO l_tmp;
3869: END;
3870:
3871: fnd_message.set_name('AR','HZ_MR_HAS_INACTIVE_TX');
3872: FND_MSG_PUB.ADD;
3873: RAISE FND_API.G_EXC_ERROR;
3874: END IF;
3875: CLOSE check_inactive;
3876: -- Generate and compile match rule package spec
3877: HZ_GEN_PLSQL.new(l_package_name, 'PACKAGE');
3883: HZ_GEN_PLSQL.compile_code;
3884:
3885: --Standard call to get message count and if count is 1, get message info.
3886: FND_MSG_PUB.Count_And_Get(
3887: p_encoded => FND_API.G_FALSE,
3888: p_count => x_msg_count,
3889: p_data => x_msg_data);
3890:
3891: UPDATE HZ_MATCH_RULES_B SET COMPILATION_FLAG = 'C' WHERE MATCH_RULE_ID = l_rule_id;
3890:
3891: UPDATE HZ_MATCH_RULES_B SET COMPILATION_FLAG = 'C' WHERE MATCH_RULE_ID = l_rule_id;
3892: COMMIT;
3893: EXCEPTION
3894: WHEN FND_API.G_EXC_ERROR THEN
3895: FND_MSG_PUB.Count_And_Get(
3896: p_encoded => FND_API.G_FALSE,
3897: p_count => x_msg_count,
3898: p_data => x_msg_data);
3892: COMMIT;
3893: EXCEPTION
3894: WHEN FND_API.G_EXC_ERROR THEN
3895: FND_MSG_PUB.Count_And_Get(
3896: p_encoded => FND_API.G_FALSE,
3897: p_count => x_msg_count,
3898: p_data => x_msg_data);
3899: x_return_status := FND_API.G_RET_STS_ERROR;
3900: UPDATE HZ_MATCH_RULES_B SET COMPILATION_FLAG = 'U' WHERE MATCH_RULE_ID = l_rule_id;
3895: FND_MSG_PUB.Count_And_Get(
3896: p_encoded => FND_API.G_FALSE,
3897: p_count => x_msg_count,
3898: p_data => x_msg_data);
3899: x_return_status := FND_API.G_RET_STS_ERROR;
3900: UPDATE HZ_MATCH_RULES_B SET COMPILATION_FLAG = 'U' WHERE MATCH_RULE_ID = l_rule_id;
3901: COMMIT;
3902: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
3903: FND_MSG_PUB.Count_And_Get(
3898: p_data => x_msg_data);
3899: x_return_status := FND_API.G_RET_STS_ERROR;
3900: UPDATE HZ_MATCH_RULES_B SET COMPILATION_FLAG = 'U' WHERE MATCH_RULE_ID = l_rule_id;
3901: COMMIT;
3902: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
3903: FND_MSG_PUB.Count_And_Get(
3904: p_encoded => FND_API.G_FALSE,
3905: p_count => x_msg_count,
3906: p_data => x_msg_data);
3900: UPDATE HZ_MATCH_RULES_B SET COMPILATION_FLAG = 'U' WHERE MATCH_RULE_ID = l_rule_id;
3901: COMMIT;
3902: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
3903: FND_MSG_PUB.Count_And_Get(
3904: p_encoded => FND_API.G_FALSE,
3905: p_count => x_msg_count,
3906: p_data => x_msg_data);
3907: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
3908: UPDATE HZ_MATCH_RULES_B SET COMPILATION_FLAG = 'U' WHERE MATCH_RULE_ID = l_rule_id;
3903: FND_MSG_PUB.Count_And_Get(
3904: p_encoded => FND_API.G_FALSE,
3905: p_count => x_msg_count,
3906: p_data => x_msg_data);
3907: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
3908: UPDATE HZ_MATCH_RULES_B SET COMPILATION_FLAG = 'U' WHERE MATCH_RULE_ID = l_rule_id;
3909: COMMIT;
3910: WHEN OTHERS THEN
3911:
3914: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
3915: FND_MSG_PUB.ADD;
3916:
3917: FND_MSG_PUB.Count_And_Get(
3918: p_encoded => FND_API.G_FALSE,
3919: p_count => x_msg_count,
3920: p_data => x_msg_data);
3921: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
3922: UPDATE HZ_MATCH_RULES_B SET COMPILATION_FLAG = 'U' WHERE MATCH_RULE_ID = l_rule_id;
3917: FND_MSG_PUB.Count_And_Get(
3918: p_encoded => FND_API.G_FALSE,
3919: p_count => x_msg_count,
3920: p_data => x_msg_data);
3921: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
3922: UPDATE HZ_MATCH_RULES_B SET COMPILATION_FLAG = 'U' WHERE MATCH_RULE_ID = l_rule_id;
3923: COMMIT;
3924:
3925: END gen_hz_dqm_imp_debug;