[Home] [Help]
136: ) RETURN VARCHAR2
137: IS
138: l_os VARCHAR2(30) ;
139: BEGIN
140: select original_system into l_os from hz_imp_batch_summary where batch_id = p_batch_id;
141: IF (l_os IS NULL) THEN
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;
138: l_os VARCHAR2(30) ;
139: BEGIN
140: select original_system into l_os from hz_imp_batch_summary where batch_id = p_batch_id;
141: IF (l_os IS NULL) THEN
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;
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
215: where batch_id = p_batch_id;
216: log ('l_a = '|| l_a);
217: log ('l_c = '|| l_c);
218: log ('l_d = '|| l_d);
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;
577:
578:
579: IF (l_b = 'Y') THEN
731: l_message VARCHAR2(240);
732: l_workers_completed boolean ;
733: BEGIN
734: /* DQM - Batch De-duplication Program
735: Writes to - HZ_IMP_BATCH_SUMMARY.BATCH_DEDUP_STATUS
736: Values -
737: PROCESSING - When program starts the process
738: COMPLETED - When program ends successfully. Also write all the DQM Count columns in this case.
739: ERROR - When program encounters some error
756: END IF;
757: */
758:
759: chk_table('HZ_INT_DUP_RESULTS', p_batch_id);
760: UPDATE HZ_IMP_BATCH_SUMMARY set BATCH_DEDUP_STATUS = 'PROCESSING' where batch_id = p_batch_id;
761: COMMIT;
762: -- HZ_IMP_DQM_STAGE.dqm_pre_imp_cleanup(p_batch_id, x_return_status, x_msg_count, x_msg_data);
763: FOR I in 1..to_number(p_num_of_workers) LOOP
764: log('I = ' || I);
842: IF l_workers_completed THEN
843: HZ_DQM_DUP_ID_PKG.interface_sanitize_report(p_batch_id,
844: p_match_rule_id, x_return_status, x_msg_count, x_msg_data);
845:
846: -- update hz_imp_batch_summary set est_no_matches = $no where batch_id = p_batch_id;
847: UPDATE HZ_IMP_BATCH_SUMMARY set BATCH_DEDUP_STATUS = 'COMPLETED' where batch_id = p_batch_id;
848: COMMIT;
849: chk_table('HZ_INT_DUP_RESULTS', p_batch_id);
850: END IF;
843: HZ_DQM_DUP_ID_PKG.interface_sanitize_report(p_batch_id,
844: p_match_rule_id, x_return_status, x_msg_count, x_msg_data);
845:
846: -- update hz_imp_batch_summary set est_no_matches = $no where batch_id = p_batch_id;
847: UPDATE HZ_IMP_BATCH_SUMMARY set BATCH_DEDUP_STATUS = 'COMPLETED' where batch_id = p_batch_id;
848: COMMIT;
849: chk_table('HZ_INT_DUP_RESULTS', p_batch_id);
850: END IF;
851: END IF;
851: END IF;
852: EXCEPTION WHEN OTHERS 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:
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; ');
2618: l(' ');
2619: l(' IF (l_b = ''Y'') THEN ');
2620: l(' IF ((l_a = ''Y'') AND (l_c = l_d) ) THEN ');