[Home] [Help]
111: WHERE interface_run_id = p_interface_run_id
112: AND status = cst_s_val_1
113: AND interface_test_id between cp_lower_bound and cp_higher_bound
114: AND NVL(match_ind,cst_mi_val_15) in ( cst_mi_val_15,cst_mi_val_23)
115: AND EXISTS (SELECT 1 FROM IGS_AD_TEST_SEGS_INT testsegsint
116: WHERE testsegsint.status = cst_s_val_2
117: AND in_rec.INTERFACE_TEST_ID = testsegsint.interface_test_id
118: );
119:
118: );
119:
120:
121:
122: CURSOR c_igs_ad_test_segs_int(cp_interface_test_id igs_ad_test_segs_int.interface_test_id%TYPE) IS
123: SELECT cst_insert dmlmode, rowid, in_rec.*
124: FROM igs_ad_test_segs_int in_rec
125: WHERE status = cst_s_val_2
126: AND interface_test_id = cp_interface_test_id
120:
121:
122: CURSOR c_igs_ad_test_segs_int(cp_interface_test_id igs_ad_test_segs_int.interface_test_id%TYPE) IS
123: SELECT cst_insert dmlmode, rowid, in_rec.*
124: FROM igs_ad_test_segs_int in_rec
125: WHERE status = cst_s_val_2
126: AND interface_test_id = cp_interface_test_id
127: AND (( NVL(match_ind,'15') = '15'
128: AND NOT EXISTS (SELECT 1
132: OR ( p_rule = cst_rule_val_R
133: AND match_ind IN (cst_mi_val_16, cst_mi_val_25)))
134: UNION ALL
135: SELECT cst_update dmlmode, rowid, in_rec.*
136: FROM igs_ad_test_segs_int in_rec
137: WHERE status = cst_s_val_2
138: AND interface_test_id = cp_interface_test_id
139: AND ( (p_rule = cst_rule_val_I)
140: OR (p_rule = cst_rule_val_R AND match_ind = cst_mi_val_21))
151: AND TRUNC(ar.test_date) = TRUNC(cp_tst_rsl_cur.test_date);
152:
153: c_null_hdlg_test_rec c_null_hdlg_tst_rsl_cur%ROWTYPE;
154:
155: CURSOR c_null_hdlg_tst_dtls_cur(cp_test_segment_id igs_ad_test_segs_int.test_segment_id%TYPE,
156: cp_test_results_id igs_ad_tst_rslt_dtls.test_results_id%TYPE) IS
157: SELECT ROWID, ar.*
158: FROM igs_ad_tst_rslt_dtls ar
159: WHERE test_results_id = cp_test_results_id
197: l_total_records_prcessed NUMBER;
198:
199: test_seg_failed EXCEPTION;
200:
201: PROCEDURE upd_tst_dtls_atm_bef ( p_interface_test_id igs_ad_test_segs_int.interface_test_id%TYPE,
202: p_test_results_id igs_ad_tst_rslt_dtls.test_results_id%TYPE,
203: p_success IN OUT NOCOPY BOOLEAN) AS
204: PRAGMA AUTONOMOUS_TRANSACTION;
205: BEGIN
203: p_success IN OUT NOCOPY BOOLEAN) AS
204: PRAGMA AUTONOMOUS_TRANSACTION;
205: BEGIN
206: IF p_rule IN ('E','I') AND p_success THEN
207: UPDATE igs_ad_test_segs_int
208: SET
209: status = cst_s_val_3
210: , error_code = cst_ec_val_E700
211: , error_text = cst_et_val_E700
220:
221: -- Set STATUS to 1 for interface records with RULE = R and
222: -- MATCH IND = 17,18,19,22,23,24,27
223: IF p_rule IN ('R') AND p_success THEN
224: UPDATE igs_ad_test_segs_int
225: SET
226: status = cst_s_val_1
227: WHERE status = '2'
228: AND match_ind IN (cst_mi_val_17, cst_mi_val_18, cst_mi_val_19,
233:
234: -- Set STATUS to 1 and MATCH IND to 19 for interface records with RULE =
235: -- E matching OSS record(s)
236: IF p_rule IN ('E') AND p_success THEN
237: UPDATE igs_ad_test_segs_int in_rec
238: SET
239: status = cst_s_val_1
240: , match_ind = cst_mi_val_19
241: WHERE status = '2'
248: END IF;
249:
250: END upd_tst_dtls_atm_bef;
251:
252: PROCEDURE upd_tst_dtls_atm_s3 ( p_interface_test_id igs_ad_test_segs_int.interface_test_id%TYPE,
253: p_success IN OUT NOCOPY BOOLEAN) AS
254: PRAGMA AUTONOMOUS_TRANSACTION;
255: BEGIN
256: IF p_rule IN ('E','I') AND p_success THEN
253: p_success IN OUT NOCOPY BOOLEAN) AS
254: PRAGMA AUTONOMOUS_TRANSACTION;
255: BEGIN
256: IF p_rule IN ('E','I') AND p_success THEN
257: UPDATE igs_ad_test_segs_int
258: SET
259: status = cst_s_val_3
260: , error_code = cst_ec_val_E700
261: , error_text = cst_et_val_E700
268: COMMIT;
269: END IF;
270:
271: IF p_rule IN ('R') AND p_success THEN
272: UPDATE igs_ad_test_segs_int
273: SET
274: status = cst_s_val_3
275: , error_code = cst_ec_val_E700
276: , error_text = cst_et_val_E700
288: PROCEDURE upd_tst_dtls_atm_s1 ( p_rowid VARCHAR2,
289: p_mode VARCHAR2) AS
290: PRAGMA AUTONOMOUS_TRANSACTION;
291: BEGIN
292: UPDATE igs_ad_test_segs_int
293: SET
294: status = cst_s_val_1
295: , match_ind = DECODE(match_ind,
296: NULL, DECODE (p_mode,
301: COMMIT;
302: END upd_tst_dtls_atm_s1;
303:
304:
305: PROCEDURE upd_tst_dtls_atm_aft ( p_interface_test_id igs_ad_test_segs_int.interface_test_id%TYPE,
306: p_mode VARCHAR2,
307: p_success IN OUT NOCOPY BOOLEAN) AS
308: PRAGMA AUTONOMOUS_TRANSACTION;
309: BEGIN
308: PRAGMA AUTONOMOUS_TRANSACTION;
309: BEGIN
310: IF (p_mode = cst_update OR p_mode = cst_dsp ) AND p_success THEN
311: IF p_rule IN ('R') THEN
312: UPDATE igs_ad_test_segs_int in_rec
313: SET
314: status = cst_s_val_1
315: , match_ind = cst_mi_val_23
316: WHERE status = cst_s_val_2
356:
357: -- Set STATUS to 3 and MATCH IND = 20 for interface records with RULE = R and MATCH IND
358: -- <> 21, 25, ones failed discrepancy check
359: IF p_rule IN ('R') AND p_success THEN
360: UPDATE igs_ad_test_segs_int in_rec
361: SET
362: status = cst_s_val_3
363: , match_ind = cst_mi_val_20
364: WHERE status = cst_s_val_2
376: END IF;
377:
378: -- Set STATUS to 3 for interface records with RULE = R and invalid MATCH IND
379: IF p_rule IN ('R') AND p_success THEN
380: UPDATE igs_ad_test_segs_int
381: SET
382: status = cst_s_val_3
383: , error_code = cst_ec_val_E700
384: , error_text = cst_et_val_E700
392: END IF;
393: END upd_tst_dtls_atm_aft;
394:
395:
396: PROCEDURE upd_tst_dtls_atm_exp ( p_interface_test_id igs_ad_test_segs_int.interface_test_id%TYPE,
397: p_rowid VARCHAR2,
398: p_mode VARCHAR2,
399: p_error_code VARCHAR2,
400: p_error_text VARCHAR2) AS
400: p_error_text VARCHAR2) AS
401: PRAGMA AUTONOMOUS_TRANSACTION;
402: BEGIN
403:
404: UPDATE igs_ad_test_segs_int
405: SET
406: status = cst_s_val_3
407: , match_ind = DECODE(match_ind,
408: NULL, DECODE (p_mode,
414: WHERE status IN ('1','2')
415: AND interface_test_id = p_interface_test_id
416: AND rowid = p_rowid;
417:
418: UPDATE igs_ad_test_segs_int
419: SET
420: status = cst_s_val_3
421: , match_ind = DECODE(match_ind,
422: NULL, DECODE (p_mode,
433:
434: COMMIT;
435: END upd_tst_dtls_atm_exp;
436:
437: PROCEDURE upd_tst_dtls_atm_s2 ( p_interface_test_id igs_ad_test_segs_int.interface_test_id%TYPE,
438: p_test_results_id igs_ad_test_segs_int.test_results_id%TYPE) AS
439: PRAGMA AUTONOMOUS_TRANSACTION;
440: BEGIN
441:
434: COMMIT;
435: END upd_tst_dtls_atm_exp;
436:
437: PROCEDURE upd_tst_dtls_atm_s2 ( p_interface_test_id igs_ad_test_segs_int.interface_test_id%TYPE,
438: p_test_results_id igs_ad_test_segs_int.test_results_id%TYPE) AS
439: PRAGMA AUTONOMOUS_TRANSACTION;
440: BEGIN
441:
442: UPDATE igs_ad_test_segs_int
438: p_test_results_id igs_ad_test_segs_int.test_results_id%TYPE) AS
439: PRAGMA AUTONOMOUS_TRANSACTION;
440: BEGIN
441:
442: UPDATE igs_ad_test_segs_int
443: SET test_results_id = p_test_results_id
444: WHERE status = '2'
445: AND interface_test_id = p_interface_test_id;
446:
475: WHERE tst_int.interface_run_id = p_interface_run_id
476: AND tst_int.status IN (cst_s_val_2,cst_s_val_1)
477: AND TRUNC(tst_int.test_date) <= TRUNC(SYSDATE)
478: AND NOT EXISTS (SELECT 1
479: FROM igs_ad_test_segs_int tst_seg_int
480: WHERE tst_seg_int.interface_test_id = tst_int.interface_test_id
481: AND status = '2'
482: UNION
483: SELECT 1
497: FROM IGS_AD_TEST_INT testint
498: WHERE interface_run_id = p_interface_run_id
499: AND (status = cst_s_val_2 OR
500: (status = cst_s_val_1 AND NVL(match_ind,cst_mi_val_15) in ( cst_mi_val_15,cst_mi_val_23)
501: AND EXISTS (SELECT 1 FROM IGS_AD_TEST_SEGS_INT testsegsint
502: WHERE testsegsint.status = cst_s_val_2
503: AND testint.INTERFACE_TEST_ID = testsegsint.interface_test_id
504: )
505: )
515: FROM IGS_AD_TEST_INT testint
516: WHERE interface_run_id = p_interface_run_id
517: AND (status = cst_s_val_2 OR
518: (status = cst_s_val_1 AND NVL(match_ind,cst_mi_val_15) in ( cst_mi_val_15,cst_mi_val_23)
519: AND EXISTS (SELECT 1 FROM IGS_AD_TEST_SEGS_INT testsegsint
520: WHERE testsegsint.status = cst_s_val_2
521: AND testint.INTERFACE_TEST_ID = testsegsint.interface_test_id
522: )
523: )
542: ,error_text = cst_et_val_E577
543: WHERE interface_test_id = test_rec.interface_test_id
544: AND TRUNC(test_date) > TRUNC(SYSDATE)
545: AND EXISTS (SELECT 1
546: FROM igs_ad_test_segs_int
547: WHERE interface_test_id = test_rec.interface_test_id
548: AND status = '2');
549: IF SQL%ROWCOUNT > 0 THEN
550: COMMIT;
671: END IF;
672:
673:
674: IF l_success THEN
675: FOR test_dtls_rec IN c_igs_ad_test_segs_int(test_rec.interface_test_id)
676: LOOP
677: BEGIN
678: l_msg_at_index := igs_ge_msg_stack.count_msg;
679:
781: l_error_text := NVL(l_msg_data,igs_ad_gen_016.get_lkup_meaning ('IMPORT_ERROR_CODE', l_error_code, 8405));
782:
783: IF l_hash_msg_name_text_type_tab(l_msg_count-1).name <> 'ORA' THEN
784: IF p_enable_log = 'Y' THEN
785: igs_ad_imp_001.logerrormessage(test_dtls_rec.interface_testsegs_id,l_msg_data,'IGS_AD_TEST_SEGS_INT');
786: END IF;
787: ELSE
788: IF fnd_log.test(fnd_log.level_exception,l_prog_label) THEN
789: