[Home] [Help]
627: x_return_status OUT NOCOPY VARCHAR2,
628: x_se_id OUT NOCOPY NUMBER) Is
629:
630: l_prog_name CONSTANT VARCHAR2(100) := G_PKG_NAME||'.'||'generate_stub_element';
631: p_selv_tbl OKL_STREAMS_PUB.selv_tbl_type;
632: x_selv_tbl OKL_STREAMS_PUB.selv_tbl_type;
633: p_stmv_rec OKL_STREAMS_PUB.stmv_rec_type;
634: x_stmv_rec OKL_STREAMS_PUB.stmv_rec_type;
635: l_sty_id NUMBER;
628: x_se_id OUT NOCOPY NUMBER) Is
629:
630: l_prog_name CONSTANT VARCHAR2(100) := G_PKG_NAME||'.'||'generate_stub_element';
631: p_selv_tbl OKL_STREAMS_PUB.selv_tbl_type;
632: x_selv_tbl OKL_STREAMS_PUB.selv_tbl_type;
633: p_stmv_rec OKL_STREAMS_PUB.stmv_rec_type;
634: x_stmv_rec OKL_STREAMS_PUB.stmv_rec_type;
635: l_sty_id NUMBER;
636:
629:
630: l_prog_name CONSTANT VARCHAR2(100) := G_PKG_NAME||'.'||'generate_stub_element';
631: p_selv_tbl OKL_STREAMS_PUB.selv_tbl_type;
632: x_selv_tbl OKL_STREAMS_PUB.selv_tbl_type;
633: p_stmv_rec OKL_STREAMS_PUB.stmv_rec_type;
634: x_stmv_rec OKL_STREAMS_PUB.stmv_rec_type;
635: l_sty_id NUMBER;
636:
637: --prasjain:start for bug 5474827
630: l_prog_name CONSTANT VARCHAR2(100) := G_PKG_NAME||'.'||'generate_stub_element';
631: p_selv_tbl OKL_STREAMS_PUB.selv_tbl_type;
632: x_selv_tbl OKL_STREAMS_PUB.selv_tbl_type;
633: p_stmv_rec OKL_STREAMS_PUB.stmv_rec_type;
634: x_stmv_rec OKL_STREAMS_PUB.stmv_rec_type;
635: l_sty_id NUMBER;
636:
637: --prasjain:start for bug 5474827
638: /*
637: --prasjain:start for bug 5474827
638: /*
639: Cursor c_sty IS
640: SELECT sel.id
641: FROM okl_streams stm,
642: okl_strm_elements sel
643: where stm.khr_id = p_khr_id
644: and stm.say_code = 'HIST'
645: and stm.SGN_CODE = 'MANL'
701: p_selv_tbl(0).parent_index := 1 ;
702:
703: -- Create the Stream Header along with one stream element.
704: --print( l_prog_name, ' b4 create_stub ' || to_char(l_sty_id) );
705: okl_streams_pub.create_streams(
706: p_api_version,
707: p_init_msg_list,
708: x_return_status,
709: x_msg_count,
815: AND kle.fee_type <> 'CAPITALIZED';
816:
817: r_rollover_fee c_rollover_fee%ROWTYPE;
818:
819: l_selv_tbl okl_streams_pub.selv_tbl_type;
820: l_tmp_selv_tbl okl_streams_pub.selv_tbl_type;
821: l_pt_tbl okl_streams_pub.selv_tbl_type;
822: lx_selv_tbl okl_streams_pub.selv_tbl_type;
823:
816:
817: r_rollover_fee c_rollover_fee%ROWTYPE;
818:
819: l_selv_tbl okl_streams_pub.selv_tbl_type;
820: l_tmp_selv_tbl okl_streams_pub.selv_tbl_type;
821: l_pt_tbl okl_streams_pub.selv_tbl_type;
822: lx_selv_tbl okl_streams_pub.selv_tbl_type;
823:
824: l_stmv_rec okl_streams_pub.stmv_rec_type;
817: r_rollover_fee c_rollover_fee%ROWTYPE;
818:
819: l_selv_tbl okl_streams_pub.selv_tbl_type;
820: l_tmp_selv_tbl okl_streams_pub.selv_tbl_type;
821: l_pt_tbl okl_streams_pub.selv_tbl_type;
822: lx_selv_tbl okl_streams_pub.selv_tbl_type;
823:
824: l_stmv_rec okl_streams_pub.stmv_rec_type;
825: l_pt_rec okl_streams_pub.stmv_rec_type;
818:
819: l_selv_tbl okl_streams_pub.selv_tbl_type;
820: l_tmp_selv_tbl okl_streams_pub.selv_tbl_type;
821: l_pt_tbl okl_streams_pub.selv_tbl_type;
822: lx_selv_tbl okl_streams_pub.selv_tbl_type;
823:
824: l_stmv_rec okl_streams_pub.stmv_rec_type;
825: l_pt_rec okl_streams_pub.stmv_rec_type;
826: lx_stmv_rec okl_streams_pub.stmv_rec_type;
820: l_tmp_selv_tbl okl_streams_pub.selv_tbl_type;
821: l_pt_tbl okl_streams_pub.selv_tbl_type;
822: lx_selv_tbl okl_streams_pub.selv_tbl_type;
823:
824: l_stmv_rec okl_streams_pub.stmv_rec_type;
825: l_pt_rec okl_streams_pub.stmv_rec_type;
826: lx_stmv_rec okl_streams_pub.stmv_rec_type;
827:
828: l_capital_cost NUMBER;
821: l_pt_tbl okl_streams_pub.selv_tbl_type;
822: lx_selv_tbl okl_streams_pub.selv_tbl_type;
823:
824: l_stmv_rec okl_streams_pub.stmv_rec_type;
825: l_pt_rec okl_streams_pub.stmv_rec_type;
826: lx_stmv_rec okl_streams_pub.stmv_rec_type;
827:
828: l_capital_cost NUMBER;
829:
822: lx_selv_tbl okl_streams_pub.selv_tbl_type;
823:
824: l_stmv_rec okl_streams_pub.stmv_rec_type;
825: l_pt_rec okl_streams_pub.stmv_rec_type;
826: lx_stmv_rec okl_streams_pub.stmv_rec_type;
827:
828: l_capital_cost NUMBER;
829:
830: i BINARY_INTEGER := 0;
851:
852: l_se_id NUMBER;
853: l_fee_start_date DATE;
854:
855: l_principal_tbl okl_streams_pub.selv_tbl_type;
856: l_interest_tbl okl_streams_pub.selv_tbl_type;
857: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
858: l_termination_tbl okl_streams_pub.selv_tbl_type;
859: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
852: l_se_id NUMBER;
853: l_fee_start_date DATE;
854:
855: l_principal_tbl okl_streams_pub.selv_tbl_type;
856: l_interest_tbl okl_streams_pub.selv_tbl_type;
857: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
858: l_termination_tbl okl_streams_pub.selv_tbl_type;
859: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
860:
853: l_fee_start_date DATE;
854:
855: l_principal_tbl okl_streams_pub.selv_tbl_type;
856: l_interest_tbl okl_streams_pub.selv_tbl_type;
857: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
858: l_termination_tbl okl_streams_pub.selv_tbl_type;
859: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
860:
861: l_interim_interest NUMBER;
854:
855: l_principal_tbl okl_streams_pub.selv_tbl_type;
856: l_interest_tbl okl_streams_pub.selv_tbl_type;
857: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
858: l_termination_tbl okl_streams_pub.selv_tbl_type;
859: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
860:
861: l_interim_interest NUMBER;
862: l_interim_days NUMBER;
855: l_principal_tbl okl_streams_pub.selv_tbl_type;
856: l_interest_tbl okl_streams_pub.selv_tbl_type;
857: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
858: l_termination_tbl okl_streams_pub.selv_tbl_type;
859: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
860:
861: l_interim_interest NUMBER;
862: l_interim_days NUMBER;
863: l_interim_dpp NUMBER;
913: LOOP
914:
915: print( l_prog_name, ' found a roll fee ', to_char(r_rollover_fee.kleId) );
916:
917: update okl_streams
918: set say_code = 'HIST'
919: ,date_history = SYSDATE
920: where khr_id = p_khr_id
921: and kle_id = r_rollover_fee.kleId;
919: ,date_history = SYSDATE
920: where khr_id = p_khr_id
921: and kle_id = r_rollover_fee.kleId;
922:
923: update okl_streams
924: set active_yn = 'N'
925: where khr_id = p_khr_id
926: and kle_id = r_rollover_fee.kleId;
927:
1006: RAISE OKL_API.G_EXCEPTION_ERROR;
1007: END IF;
1008:
1009:
1010: lx_return_status := Okl_Streams_Util.round_streams_amount(
1011: p_api_version => g_api_version,
1012: p_init_msg_list => p_init_msg_list,
1013: x_msg_count => x_msg_count,
1014: x_msg_data => x_msg_data,
1028: l_stmv_rec.say_code := 'CURR';
1029: l_stmv_rec.active_yn := 'Y';
1030: l_stmv_rec.date_current := SYSDATE;
1031:
1032: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
1033: p_init_msg_list => G_FALSE,
1034: x_return_status => lx_return_status,
1035: x_msg_count => x_msg_count,
1036: x_msg_data => x_msg_data,
1165: l_stmv_rec.say_code := 'CURR';
1166: l_stmv_rec.active_yn := 'Y';
1167: l_stmv_rec.date_current := SYSDATE;
1168:
1169: lx_return_status := Okl_Streams_Util.round_streams_amount(
1170: p_api_version => g_api_version,
1171: p_init_msg_list => p_init_msg_list,
1172: x_msg_count => x_msg_count,
1173: x_msg_data => x_msg_data,
1183:
1184: l_principal_tbl.DELETE;
1185: l_principal_tbl := lx_selv_tbl;
1186:
1187: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
1188: p_init_msg_list => G_FALSE,
1189: x_return_status => lx_return_status,
1190: x_msg_count => x_msg_count,
1191: x_msg_data => x_msg_data,
1221: l_stmv_rec.say_code := 'CURR';
1222: l_stmv_rec.active_yn := 'Y';
1223: l_stmv_rec.date_current := SYSDATE;
1224:
1225: lx_return_status := Okl_Streams_Util.round_streams_amount(
1226: p_api_version => g_api_version,
1227: p_init_msg_list => p_init_msg_list,
1228: x_msg_count => x_msg_count,
1229: x_msg_data => x_msg_data,
1239:
1240: l_interest_tbl.DELETE;
1241: l_interest_tbl := lx_selv_tbl;
1242:
1243: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
1244: p_init_msg_list => G_FALSE,
1245: x_return_status => lx_return_status,
1246: x_msg_count => x_msg_count,
1247: x_msg_data => x_msg_data,
1277: l_stmv_rec.say_code := 'CURR';
1278: l_stmv_rec.active_yn := 'Y';
1279: l_stmv_rec.date_current := SYSDATE;
1280:
1281: lx_return_status := Okl_Streams_Util.round_streams_amount(
1282: p_api_version => g_api_version,
1283: p_init_msg_list => p_init_msg_list,
1284: x_msg_count => x_msg_count,
1285: x_msg_data => x_msg_data,
1295:
1296: l_prin_bal_tbl.DELETE;
1297: l_prin_bal_tbl := lx_selv_tbl;
1298:
1299: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
1300: p_init_msg_list => G_FALSE,
1301: x_return_status => lx_return_status,
1302: x_msg_count => x_msg_count,
1303: x_msg_data => x_msg_data,
1333: l_stmv_rec.say_code := 'CURR';
1334: l_stmv_rec.active_yn := 'Y';
1335: l_stmv_rec.date_current := SYSDATE;
1336:
1337: lx_return_status := Okl_Streams_Util.round_streams_amount(
1338: p_api_version => g_api_version,
1339: p_init_msg_list => p_init_msg_list,
1340: x_msg_count => x_msg_count,
1341: x_msg_data => x_msg_data,
1351:
1352: l_termination_tbl.DELETE;
1353: l_termination_tbl := lx_selv_tbl;
1354:
1355: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
1356: p_init_msg_list => G_FALSE,
1357: x_return_status => lx_return_status,
1358: x_msg_count => x_msg_count,
1359: x_msg_data => x_msg_data,
1389: l_stmv_rec.active_yn := 'Y';
1390: l_stmv_rec.date_current := SYSDATE;
1391:
1392:
1393: lx_return_status := Okl_Streams_Util.round_streams_amount(
1394: p_api_version => g_api_version,
1395: p_init_msg_list => p_init_msg_list,
1396: x_msg_count => x_msg_count,
1397: x_msg_data => x_msg_data,
1407:
1408: l_pre_tax_inc_tbl.DELETE;
1409: l_pre_tax_inc_tbl := lx_selv_tbl;
1410:
1411: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
1412: p_init_msg_list => G_FALSE,
1413: x_return_status => lx_return_status,
1414: x_msg_count => x_msg_count,
1415: x_msg_data => x_msg_data,
1618: CURSOR c_k_income (p_sty_name VARCHAR2) IS
1619: SELECT sel.amount income_amount,
1620: sel.stream_element_date income_date
1621: FROM okl_strm_elements sel,
1622: okl_streams stm,
1623: okl_strm_type_b sty,
1624: okl_strm_type_tl styt
1625: WHERE stm.khr_id = p_khr_id
1626: AND stm.say_code = 'WORK'
1633: AND sel.stream_element_date >= p_start_date
1634: AND sel.stream_element_date <= LAST_DAY(p_end_date) --bug# 3379436
1635: ORDER BY sel.stream_element_date;
1636:
1637: l_selv_tbl okl_streams_pub.selv_tbl_type;
1638: lx_selv_tbl okl_streams_pub.selv_tbl_type;
1639:
1640: l_stmv_rec okl_streams_pub.stmv_rec_type;
1641: lx_stmv_rec okl_streams_pub.stmv_rec_type;
1634: AND sel.stream_element_date <= LAST_DAY(p_end_date) --bug# 3379436
1635: ORDER BY sel.stream_element_date;
1636:
1637: l_selv_tbl okl_streams_pub.selv_tbl_type;
1638: lx_selv_tbl okl_streams_pub.selv_tbl_type;
1639:
1640: l_stmv_rec okl_streams_pub.stmv_rec_type;
1641: lx_stmv_rec okl_streams_pub.stmv_rec_type;
1642:
1636:
1637: l_selv_tbl okl_streams_pub.selv_tbl_type;
1638: lx_selv_tbl okl_streams_pub.selv_tbl_type;
1639:
1640: l_stmv_rec okl_streams_pub.stmv_rec_type;
1641: lx_stmv_rec okl_streams_pub.stmv_rec_type;
1642:
1643: l_amortized_exp_id NUMBER;
1644: l_sty_name VARCHAR2(150);
1637: l_selv_tbl okl_streams_pub.selv_tbl_type;
1638: lx_selv_tbl okl_streams_pub.selv_tbl_type;
1639:
1640: l_stmv_rec okl_streams_pub.stmv_rec_type;
1641: lx_stmv_rec okl_streams_pub.stmv_rec_type;
1642:
1643: l_amortized_exp_id NUMBER;
1644: l_sty_name VARCHAR2(150);
1645: l_sty_id NUMBER;
3204: p_stub_amount IN NUMBER,
3205: p_currency_code IN VARCHAR2,
3206: p_day_convention_month IN VARCHAR2 DEFAULT '30',
3207: p_day_convention_year IN VARCHAR2 DEFAULT '360',
3208: x_selv_tbl OUT NOCOPY okl_streams_pub.selv_tbl_type,
3209: x_return_status OUT NOCOPY VARCHAR2) IS
3210:
3211: lx_return_status VARCHAR2(1);
3212:
3534:
3535: CURSOR c_stm_count IS
3536: SELECT COUNT(stm.id),
3537: stm.sty_id
3538: FROM okl_streams stm
3539: WHERE stm.khr_id = p_khr_id
3540: AND stm.say_code = 'WORK'
3541: AND NVL(stm.purpose_code, '-99') = p_purpose_code
3542: AND stm.kle_id IS NULL
3544: GROUP BY stm.kle_id, stm.sty_id;
3545:
3546: CURSOR c_stm_first (p_sty_id NUMBER) IS
3547: SELECT id
3548: FROM okl_streams
3549: WHERE khr_id = p_khr_id
3550: AND kle_id IS NULL
3551: AND say_code = 'WORK'
3552: AND sty_id = p_sty_id
3553: AND NVL(purpose_code, '-99') = p_purpose_code;
3554:
3555: CURSOR c_stm (p_sty_id NUMBER, p_stm_id NUMBER) IS
3556: SELECT id
3557: FROM okl_streams
3558: WHERE khr_id = p_khr_id
3559: AND kle_id IS NULL
3560: AND sty_id = p_sty_id
3561: AND say_code = 'WORK'
3592: CLOSE c_last_sel;
3593:
3594: FOR l_stm IN c_stm (l_stm_count.sty_id, l_stm_first) LOOP
3595:
3596: DELETE FROM okl_streams WHERE id = l_stm.id
3597: and khr_id = p_khr_id;
3598:
3599: FOR l_sel IN c_sel (l_stm.id) LOOP
3600:
3610:
3611: END LOOP;
3612:
3613:
3614: DELETE FROM OKL_STREAMS WHERE purpose_code = 'STUBS'
3615: and khr_id = p_khr_id;
3616: x_return_status := G_RET_STS_SUCCESS;
3617: print( l_prog_name, 'end' );
3618:
3654: CURSOR c_stm_count IS
3655: SELECT COUNT(stm.id),
3656: stm.kle_id,
3657: stm.sty_id
3658: FROM okl_streams stm,
3659: okc_k_lines_b cle,
3660: okc_line_styles_b lse
3661: WHERE stm.khr_id = p_khr_id
3662: AND stm.say_code = 'WORK'
3669: GROUP BY stm.kle_id, stm.sty_id;
3670:
3671: CURSOR c_stm_first (p_kle_id NUMBER, p_sty_id NUMBER) IS
3672: SELECT id
3673: FROM okl_streams
3674: WHERE khr_id = p_khr_id
3675: AND kle_id = p_kle_id
3676: AND sty_id = p_sty_id
3677: AND say_code = 'WORK'
3678: AND NVL(purpose_code, '-99') = p_purpose_code;
3679:
3680: CURSOR c_stm (p_kle_id NUMBER, p_sty_id NUMBER, p_stm_id NUMBER) IS
3681: SELECT id
3682: FROM okl_streams
3683: WHERE khr_id = p_khr_id
3684: AND kle_id = p_kle_id
3685: AND sty_id = p_sty_id
3686: AND say_code = 'WORK'
3718: CLOSE c_last_sel;
3719:
3720: FOR l_stm IN c_stm (l_stm_count.kle_id, l_stm_count.sty_id, l_stm_first) LOOP
3721:
3722: DELETE FROM okl_streams WHERE id = l_stm.id
3723: and khr_id = p_khr_id;
3724:
3725: FOR l_sel IN c_sel (l_stm.id) LOOP
3726:
3734:
3735: END LOOP;
3736:
3737:
3738: DELETE FROM OKL_STREAMS WHERE purpose_code = 'STUBS'
3739: and khr_id = p_khr_id;
3740:
3741: x_return_status := G_RET_STS_SUCCESS;
3742: print( l_prog_name, 'end' );
3792: stm.kle_id kle_id,
3793: stm.sty_id,
3794: sty.stream_type_purpose stm_purpose,
3795: ele.amount amount
3796: FROM okl_streams stm,
3797: okl_strm_elements ele,
3798: okl_strm_type_b sty
3799: WHERE stm.khr_id = p_khr_id
3800: AND ele.stm_id = stm.id
3820: l_line_num NUMBER;
3821: n NUMBER := 0;
3822:
3823: -- Added by RGOOTY
3824: eleid_tbl Okl_Streams_Util.NumberTabTyp;
3825: streamid_tbl Okl_Streams_Util.NumberTabTyp;
3826: sel_date Okl_Streams_Util.DateTabTyp;
3827:
3828: lom_date DATE;
3821: n NUMBER := 0;
3822:
3823: -- Added by RGOOTY
3824: eleid_tbl Okl_Streams_Util.NumberTabTyp;
3825: streamid_tbl Okl_Streams_Util.NumberTabTyp;
3826: sel_date Okl_Streams_Util.DateTabTyp;
3827:
3828: lom_date DATE;
3829: i NUMBER;
3822:
3823: -- Added by RGOOTY
3824: eleid_tbl Okl_Streams_Util.NumberTabTyp;
3825: streamid_tbl Okl_Streams_Util.NumberTabTyp;
3826: sel_date Okl_Streams_Util.DateTabTyp;
3827:
3828: lom_date DATE;
3829: i NUMBER;
3830: -- Added by RGOOTY: 4403311
3833: j NUMBER;
3834: r NUMBER;
3835:
3836:
3837: l_ele_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3838: l_streamid_all_tbl Okl_Streams_Util.NumberTabTyp;
3839: l_sel_date_all_tbl Okl_Streams_Util.DateTabTyp;
3840: l_kle_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3841: l_amt_all_tbl Okl_Streams_Util.NumberTabTyp;
3834: r NUMBER;
3835:
3836:
3837: l_ele_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3838: l_streamid_all_tbl Okl_Streams_Util.NumberTabTyp;
3839: l_sel_date_all_tbl Okl_Streams_Util.DateTabTyp;
3840: l_kle_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3841: l_amt_all_tbl Okl_Streams_Util.NumberTabTyp;
3842: l_stm_purpose_all_tbl Okl_Streams_Util.Var150TabTyp;
3835:
3836:
3837: l_ele_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3838: l_streamid_all_tbl Okl_Streams_Util.NumberTabTyp;
3839: l_sel_date_all_tbl Okl_Streams_Util.DateTabTyp;
3840: l_kle_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3841: l_amt_all_tbl Okl_Streams_Util.NumberTabTyp;
3842: l_stm_purpose_all_tbl Okl_Streams_Util.Var150TabTyp;
3843:
3836:
3837: l_ele_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3838: l_streamid_all_tbl Okl_Streams_Util.NumberTabTyp;
3839: l_sel_date_all_tbl Okl_Streams_Util.DateTabTyp;
3840: l_kle_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3841: l_amt_all_tbl Okl_Streams_Util.NumberTabTyp;
3842: l_stm_purpose_all_tbl Okl_Streams_Util.Var150TabTyp;
3843:
3844: --Added by dpsingh for bug 5503678
3837: l_ele_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3838: l_streamid_all_tbl Okl_Streams_Util.NumberTabTyp;
3839: l_sel_date_all_tbl Okl_Streams_Util.DateTabTyp;
3840: l_kle_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3841: l_amt_all_tbl Okl_Streams_Util.NumberTabTyp;
3842: l_stm_purpose_all_tbl Okl_Streams_Util.Var150TabTyp;
3843:
3844: --Added by dpsingh for bug 5503678
3845: l_sty_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3838: l_streamid_all_tbl Okl_Streams_Util.NumberTabTyp;
3839: l_sel_date_all_tbl Okl_Streams_Util.DateTabTyp;
3840: l_kle_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3841: l_amt_all_tbl Okl_Streams_Util.NumberTabTyp;
3842: l_stm_purpose_all_tbl Okl_Streams_Util.Var150TabTyp;
3843:
3844: --Added by dpsingh for bug 5503678
3845: l_sty_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3846:
3841: l_amt_all_tbl Okl_Streams_Util.NumberTabTyp;
3842: l_stm_purpose_all_tbl Okl_Streams_Util.Var150TabTyp;
3843:
3844: --Added by dpsingh for bug 5503678
3845: l_sty_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3846:
3847: l_ele_id_mod_tbl Okl_Streams_Util.NumberTabTyp;
3848: l_streamid_mod_tbl Okl_Streams_Util.NumberTabTyp;
3849: l_sel_date_mod_tbl Okl_Streams_Util.DateTabTyp;
3843:
3844: --Added by dpsingh for bug 5503678
3845: l_sty_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3846:
3847: l_ele_id_mod_tbl Okl_Streams_Util.NumberTabTyp;
3848: l_streamid_mod_tbl Okl_Streams_Util.NumberTabTyp;
3849: l_sel_date_mod_tbl Okl_Streams_Util.DateTabTyp;
3850: l_kle_id_mod_tbl Okl_Streams_Util.NumberTabTyp;
3851: l_amt_mod_tbl Okl_Streams_Util.NumberTabTyp;
3844: --Added by dpsingh for bug 5503678
3845: l_sty_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3846:
3847: l_ele_id_mod_tbl Okl_Streams_Util.NumberTabTyp;
3848: l_streamid_mod_tbl Okl_Streams_Util.NumberTabTyp;
3849: l_sel_date_mod_tbl Okl_Streams_Util.DateTabTyp;
3850: l_kle_id_mod_tbl Okl_Streams_Util.NumberTabTyp;
3851: l_amt_mod_tbl Okl_Streams_Util.NumberTabTyp;
3852: l_stm_purpose_mod_tbl Okl_Streams_Util.Var150TabTyp;
3845: l_sty_id_all_tbl Okl_Streams_Util.NumberTabTyp;
3846:
3847: l_ele_id_mod_tbl Okl_Streams_Util.NumberTabTyp;
3848: l_streamid_mod_tbl Okl_Streams_Util.NumberTabTyp;
3849: l_sel_date_mod_tbl Okl_Streams_Util.DateTabTyp;
3850: l_kle_id_mod_tbl Okl_Streams_Util.NumberTabTyp;
3851: l_amt_mod_tbl Okl_Streams_Util.NumberTabTyp;
3852: l_stm_purpose_mod_tbl Okl_Streams_Util.Var150TabTyp;
3853:
3846:
3847: l_ele_id_mod_tbl Okl_Streams_Util.NumberTabTyp;
3848: l_streamid_mod_tbl Okl_Streams_Util.NumberTabTyp;
3849: l_sel_date_mod_tbl Okl_Streams_Util.DateTabTyp;
3850: l_kle_id_mod_tbl Okl_Streams_Util.NumberTabTyp;
3851: l_amt_mod_tbl Okl_Streams_Util.NumberTabTyp;
3852: l_stm_purpose_mod_tbl Okl_Streams_Util.Var150TabTyp;
3853:
3854: l_ele_id_del_tbl Okl_Streams_Util.NumberTabTyp;
3847: l_ele_id_mod_tbl Okl_Streams_Util.NumberTabTyp;
3848: l_streamid_mod_tbl Okl_Streams_Util.NumberTabTyp;
3849: l_sel_date_mod_tbl Okl_Streams_Util.DateTabTyp;
3850: l_kle_id_mod_tbl Okl_Streams_Util.NumberTabTyp;
3851: l_amt_mod_tbl Okl_Streams_Util.NumberTabTyp;
3852: l_stm_purpose_mod_tbl Okl_Streams_Util.Var150TabTyp;
3853:
3854: l_ele_id_del_tbl Okl_Streams_Util.NumberTabTyp;
3855: l_streamid_del_tbl Okl_Streams_Util.NumberTabTyp;
3848: l_streamid_mod_tbl Okl_Streams_Util.NumberTabTyp;
3849: l_sel_date_mod_tbl Okl_Streams_Util.DateTabTyp;
3850: l_kle_id_mod_tbl Okl_Streams_Util.NumberTabTyp;
3851: l_amt_mod_tbl Okl_Streams_Util.NumberTabTyp;
3852: l_stm_purpose_mod_tbl Okl_Streams_Util.Var150TabTyp;
3853:
3854: l_ele_id_del_tbl Okl_Streams_Util.NumberTabTyp;
3855: l_streamid_del_tbl Okl_Streams_Util.NumberTabTyp;
3856: l_sel_date_del_tbl Okl_Streams_Util.DateTabTyp;
3850: l_kle_id_mod_tbl Okl_Streams_Util.NumberTabTyp;
3851: l_amt_mod_tbl Okl_Streams_Util.NumberTabTyp;
3852: l_stm_purpose_mod_tbl Okl_Streams_Util.Var150TabTyp;
3853:
3854: l_ele_id_del_tbl Okl_Streams_Util.NumberTabTyp;
3855: l_streamid_del_tbl Okl_Streams_Util.NumberTabTyp;
3856: l_sel_date_del_tbl Okl_Streams_Util.DateTabTyp;
3857: l_kle_id_del_tbl Okl_Streams_Util.NumberTabTyp;
3858: l_amt_del_tbl Okl_Streams_Util.NumberTabTyp;
3851: l_amt_mod_tbl Okl_Streams_Util.NumberTabTyp;
3852: l_stm_purpose_mod_tbl Okl_Streams_Util.Var150TabTyp;
3853:
3854: l_ele_id_del_tbl Okl_Streams_Util.NumberTabTyp;
3855: l_streamid_del_tbl Okl_Streams_Util.NumberTabTyp;
3856: l_sel_date_del_tbl Okl_Streams_Util.DateTabTyp;
3857: l_kle_id_del_tbl Okl_Streams_Util.NumberTabTyp;
3858: l_amt_del_tbl Okl_Streams_Util.NumberTabTyp;
3859: l_stm_purpose_del_tbl Okl_Streams_Util.Var150TabTyp;
3852: l_stm_purpose_mod_tbl Okl_Streams_Util.Var150TabTyp;
3853:
3854: l_ele_id_del_tbl Okl_Streams_Util.NumberTabTyp;
3855: l_streamid_del_tbl Okl_Streams_Util.NumberTabTyp;
3856: l_sel_date_del_tbl Okl_Streams_Util.DateTabTyp;
3857: l_kle_id_del_tbl Okl_Streams_Util.NumberTabTyp;
3858: l_amt_del_tbl Okl_Streams_Util.NumberTabTyp;
3859: l_stm_purpose_del_tbl Okl_Streams_Util.Var150TabTyp;
3860:
3853:
3854: l_ele_id_del_tbl Okl_Streams_Util.NumberTabTyp;
3855: l_streamid_del_tbl Okl_Streams_Util.NumberTabTyp;
3856: l_sel_date_del_tbl Okl_Streams_Util.DateTabTyp;
3857: l_kle_id_del_tbl Okl_Streams_Util.NumberTabTyp;
3858: l_amt_del_tbl Okl_Streams_Util.NumberTabTyp;
3859: l_stm_purpose_del_tbl Okl_Streams_Util.Var150TabTyp;
3860:
3861: l_sum_amount NUMBER;
3854: l_ele_id_del_tbl Okl_Streams_Util.NumberTabTyp;
3855: l_streamid_del_tbl Okl_Streams_Util.NumberTabTyp;
3856: l_sel_date_del_tbl Okl_Streams_Util.DateTabTyp;
3857: l_kle_id_del_tbl Okl_Streams_Util.NumberTabTyp;
3858: l_amt_del_tbl Okl_Streams_Util.NumberTabTyp;
3859: l_stm_purpose_del_tbl Okl_Streams_Util.Var150TabTyp;
3860:
3861: l_sum_amount NUMBER;
3862: BEGIN
3855: l_streamid_del_tbl Okl_Streams_Util.NumberTabTyp;
3856: l_sel_date_del_tbl Okl_Streams_Util.DateTabTyp;
3857: l_kle_id_del_tbl Okl_Streams_Util.NumberTabTyp;
3858: l_amt_del_tbl Okl_Streams_Util.NumberTabTyp;
3859: l_stm_purpose_del_tbl Okl_Streams_Util.Var150TabTyp;
3860:
3861: l_sum_amount NUMBER;
3862: BEGIN
3863:
4092: l_sty_id NUMBER;
4093: l_sty_name VARCHAR2(150);
4094: l_mapped_sty_name VARCHAR2(150);
4095:
4096: l_selv_tbl okl_streams_pub.selv_tbl_type;
4097: l_tmp_selv_tbl okl_streams_pub.selv_tbl_type;
4098: l_pt_tbl okl_streams_pub.selv_tbl_type;
4099: lx_selv_tbl okl_streams_pub.selv_tbl_type;
4100:
4093: l_sty_name VARCHAR2(150);
4094: l_mapped_sty_name VARCHAR2(150);
4095:
4096: l_selv_tbl okl_streams_pub.selv_tbl_type;
4097: l_tmp_selv_tbl okl_streams_pub.selv_tbl_type;
4098: l_pt_tbl okl_streams_pub.selv_tbl_type;
4099: lx_selv_tbl okl_streams_pub.selv_tbl_type;
4100:
4101: l_stmv_rec okl_streams_pub.stmv_rec_type;
4094: l_mapped_sty_name VARCHAR2(150);
4095:
4096: l_selv_tbl okl_streams_pub.selv_tbl_type;
4097: l_tmp_selv_tbl okl_streams_pub.selv_tbl_type;
4098: l_pt_tbl okl_streams_pub.selv_tbl_type;
4099: lx_selv_tbl okl_streams_pub.selv_tbl_type;
4100:
4101: l_stmv_rec okl_streams_pub.stmv_rec_type;
4102: l_pt_rec okl_streams_pub.stmv_rec_type;
4095:
4096: l_selv_tbl okl_streams_pub.selv_tbl_type;
4097: l_tmp_selv_tbl okl_streams_pub.selv_tbl_type;
4098: l_pt_tbl okl_streams_pub.selv_tbl_type;
4099: lx_selv_tbl okl_streams_pub.selv_tbl_type;
4100:
4101: l_stmv_rec okl_streams_pub.stmv_rec_type;
4102: l_pt_rec okl_streams_pub.stmv_rec_type;
4103: lx_stmv_rec okl_streams_pub.stmv_rec_type;
4097: l_tmp_selv_tbl okl_streams_pub.selv_tbl_type;
4098: l_pt_tbl okl_streams_pub.selv_tbl_type;
4099: lx_selv_tbl okl_streams_pub.selv_tbl_type;
4100:
4101: l_stmv_rec okl_streams_pub.stmv_rec_type;
4102: l_pt_rec okl_streams_pub.stmv_rec_type;
4103: lx_stmv_rec okl_streams_pub.stmv_rec_type;
4104:
4105: l_capital_cost NUMBER;
4098: l_pt_tbl okl_streams_pub.selv_tbl_type;
4099: lx_selv_tbl okl_streams_pub.selv_tbl_type;
4100:
4101: l_stmv_rec okl_streams_pub.stmv_rec_type;
4102: l_pt_rec okl_streams_pub.stmv_rec_type;
4103: lx_stmv_rec okl_streams_pub.stmv_rec_type;
4104:
4105: l_capital_cost NUMBER;
4106:
4099: lx_selv_tbl okl_streams_pub.selv_tbl_type;
4100:
4101: l_stmv_rec okl_streams_pub.stmv_rec_type;
4102: l_pt_rec okl_streams_pub.stmv_rec_type;
4103: lx_stmv_rec okl_streams_pub.stmv_rec_type;
4104:
4105: l_capital_cost NUMBER;
4106:
4107: i BINARY_INTEGER := 0;
4188: sty.stream_type_purpose cf_purpose,
4189: sll.object1_id1 cf_frequency,
4190: DECODE(sll.object1_id1, 'M', 30, 'Q', 90, 'S', 180, 'A', 360) days_per_period,
4191: DECODE(sll.object1_id1, 'M', 12, 'Q', 4, 'S', 2, 'A', 1) periods_per_year
4192: FROM okl_streams stm,
4193: okl_strm_type_b sty,
4194: okl_strm_elements sel,
4195: okc_k_lines_b cle,
4196: okc_line_styles_b lse,
4242: l_capred_sty_name VARCHAR2(150);
4243:
4244: -- Added by RGOOTY : End
4245: -- Added by RGOOTY for perf.: Bug Number 4346646 Start
4246: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
4247: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
4248:
4249: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
4250: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
4243:
4244: -- Added by RGOOTY : End
4245: -- Added by RGOOTY for perf.: Bug Number 4346646 Start
4246: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
4247: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
4248:
4249: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
4250: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
4251: -- Added by RGOOTY for perf.: End
4245: -- Added by RGOOTY for perf.: Bug Number 4346646 Start
4246: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
4247: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
4248:
4249: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
4250: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
4251: -- Added by RGOOTY for perf.: End
4252:
4253: -- djanaswa ER6274342 start
4246: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
4247: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
4248:
4249: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
4250: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
4251: -- Added by RGOOTY for perf.: End
4252:
4253: -- djanaswa ER6274342 start
4254: l_arrears_pay_dates_option okl_st_gen_tmpt_sets_all.isg_arrears_pay_dates_option%type;
4330: l_selv_tbl(1).stream_element_date := l_hdr.end_date;
4331: l_selv_tbl(1).se_line_number := 1;
4332: l_selv_tbl(1).accrued_yn := NULL;
4333:
4334: lx_return_status := Okl_Streams_Util.round_streams_amount_esg(
4335: p_api_version => g_api_version,
4336: p_init_msg_list => p_init_msg_list,
4337: x_msg_count => x_msg_count,
4338: x_msg_data => x_msg_data,
4352: END IF;
4353: l_selv_tbl.DELETE;
4354: l_selv_tbl := lx_selv_tbl;
4355: --Accumulate Stream Header: 4346646
4356: OKL_STREAMS_UTIL.accumulate_strm_headers(
4357: p_stmv_rec => l_stmv_rec,
4358: x_full_stmv_tbl => l_stmv_tbl,
4359: x_return_status => lx_return_status );
4360: IF (lx_return_status = G_RET_STS_UNEXP_ERROR) THEN
4362: ELSIF (lx_return_status = G_RET_STS_ERROR) THEN
4363: RAISE OKL_API.G_EXCEPTION_ERROR;
4364: END IF;
4365: --Accumulate Stream Elements
4366: OKL_STREAMS_UTIL.accumulate_strm_elements(
4367: p_stm_index_no => l_stmv_tbl.LAST,
4368: p_selv_tbl => l_selv_tbl,
4369: x_full_selv_tbl => l_full_selv_tbl,
4370: x_return_status => lx_return_status );
4423: l_selv_tbl(1).stream_element_date := l_hdr.start_date;
4424: l_selv_tbl(1).se_line_number := 1;
4425: l_selv_tbl(1).accrued_yn := NULL;
4426:
4427: lx_return_status := Okl_Streams_Util.round_streams_amount_esg(
4428: p_api_version => g_api_version,
4429: p_init_msg_list => p_init_msg_list,
4430: x_msg_count => x_msg_count,
4431: x_msg_data => x_msg_data,
4447: l_selv_tbl.DELETE;
4448: l_selv_tbl := lx_selv_tbl;
4449:
4450: --Accumulate Stream Header: 4346646
4451: OKL_STREAMS_UTIL.accumulate_strm_headers(
4452: p_stmv_rec => l_stmv_rec,
4453: x_full_stmv_tbl => l_stmv_tbl,
4454: x_return_status => lx_return_status );
4455: IF (lx_return_status = G_RET_STS_UNEXP_ERROR) THEN
4458: RAISE OKL_API.G_EXCEPTION_ERROR;
4459: END IF;
4460:
4461: --Accumulate Stream Elements
4462: OKL_STREAMS_UTIL.accumulate_strm_elements(
4463: p_stm_index_no => l_stmv_tbl.LAST,
4464: p_selv_tbl => l_selv_tbl,
4465: x_full_selv_tbl => l_full_selv_tbl,
4466: x_return_status => lx_return_status );
4636: RAISE OKL_API.G_EXCEPTION_ERROR;
4637: END IF;
4638:
4639:
4640: lx_return_status := Okl_Streams_Util.round_streams_amount_esg(
4641: p_api_version => g_api_version,
4642: p_init_msg_list => p_init_msg_list,
4643: x_msg_count => x_msg_count,
4644: x_msg_data => x_msg_data,
4659:
4660: l_selv_tbl.DELETE;
4661: l_selv_tbl := lx_selv_tbl;
4662:
4663: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
4664: p_init_msg_list => G_FALSE,
4665: x_return_status => lx_return_status,
4666: x_msg_count => x_msg_count,
4667: x_msg_data => x_msg_data,
4781: l_selv_tbl(i).comments := r_inflow_line_tbl(i).cf_arrear;
4782: END LOOP;
4783:
4784:
4785: lx_return_status := Okl_Streams_Util.round_streams_amount_esg(
4786: p_api_version => p_api_version,
4787: p_init_msg_list => p_init_msg_list,
4788: x_msg_count => x_msg_count,
4789: x_msg_data => x_msg_data,
4804:
4805: l_selv_tbl.DELETE;
4806: l_selv_tbl := lx_selv_tbl;
4807:
4808: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
4809: p_init_msg_list => G_FALSE,
4810: x_return_status => lx_return_status,
4811: x_msg_count => x_msg_count,
4812: x_msg_data => x_msg_data,
4827: --Create all the accumulated Streams at one shot ..
4828: IF l_stmv_tbl.COUNT > 0 AND
4829: l_full_selv_tbl.COUNT > 0
4830: THEN
4831: Okl_Streams_Pub.create_streams_perf(
4832: p_api_version,
4833: p_init_msg_list,
4834: lx_return_status,
4835: x_msg_count,
4929: l_interest_id NUMBER;
4930: l_prin_bal_id NUMBER;
4931: l_termination_id NUMBER;
4932:
4933: l_selv_tbl okl_streams_pub.selv_tbl_type;
4934: l_pt_tbl okl_streams_pub.selv_tbl_type;
4935: lx_selv_tbl okl_streams_pub.selv_tbl_type;
4936:
4937: l_stmv_rec okl_streams_pub.stmv_rec_type;
4930: l_prin_bal_id NUMBER;
4931: l_termination_id NUMBER;
4932:
4933: l_selv_tbl okl_streams_pub.selv_tbl_type;
4934: l_pt_tbl okl_streams_pub.selv_tbl_type;
4935: lx_selv_tbl okl_streams_pub.selv_tbl_type;
4936:
4937: l_stmv_rec okl_streams_pub.stmv_rec_type;
4938: l_pt_rec okl_streams_pub.stmv_rec_type;
4931: l_termination_id NUMBER;
4932:
4933: l_selv_tbl okl_streams_pub.selv_tbl_type;
4934: l_pt_tbl okl_streams_pub.selv_tbl_type;
4935: lx_selv_tbl okl_streams_pub.selv_tbl_type;
4936:
4937: l_stmv_rec okl_streams_pub.stmv_rec_type;
4938: l_pt_rec okl_streams_pub.stmv_rec_type;
4939: lx_stmv_rec okl_streams_pub.stmv_rec_type;
4933: l_selv_tbl okl_streams_pub.selv_tbl_type;
4934: l_pt_tbl okl_streams_pub.selv_tbl_type;
4935: lx_selv_tbl okl_streams_pub.selv_tbl_type;
4936:
4937: l_stmv_rec okl_streams_pub.stmv_rec_type;
4938: l_pt_rec okl_streams_pub.stmv_rec_type;
4939: lx_stmv_rec okl_streams_pub.stmv_rec_type;
4940:
4941: i BINARY_INTEGER := 0;
4934: l_pt_tbl okl_streams_pub.selv_tbl_type;
4935: lx_selv_tbl okl_streams_pub.selv_tbl_type;
4936:
4937: l_stmv_rec okl_streams_pub.stmv_rec_type;
4938: l_pt_rec okl_streams_pub.stmv_rec_type;
4939: lx_stmv_rec okl_streams_pub.stmv_rec_type;
4940:
4941: i BINARY_INTEGER := 0;
4942: j BINARY_INTEGER := 0;
4935: lx_selv_tbl okl_streams_pub.selv_tbl_type;
4936:
4937: l_stmv_rec okl_streams_pub.stmv_rec_type;
4938: l_pt_rec okl_streams_pub.stmv_rec_type;
4939: lx_stmv_rec okl_streams_pub.stmv_rec_type;
4940:
4941: i BINARY_INTEGER := 0;
4942: j BINARY_INTEGER := 0;
4943: l_ele_count BINARY_INTEGER := 0;
4997: END IF;
4998:
4999: l_stmv_rec.purpose_code := 'FLOW';
5000: -- Proceed with Creating the RENT Stream Header
5001: okl_streams_pub.create_streams(
5002: p_api_version => G_API_VERSION,
5003: p_init_msg_list => G_FALSE,
5004: x_return_status => lx_return_status,
5005: x_msg_count => x_msg_count,
5103: --print( l_prog_name, 'start date ' || l_selv_tbl(1).stream_element_date );
5104: -- Create the Stream Elements in the OKL_STRM_ELEMENTS table
5105: -- feels like the join between stream header and stream elements here is
5106: -- sel_id, we are populating it in the above for loop.
5107: okl_streams_pub.create_stream_elements(
5108: p_api_version => G_API_VERSION,
5109: p_init_msg_list => G_FALSE,
5110: x_return_status => lx_return_status,
5111: x_msg_count => x_msg_count,
5142: END IF;
5143: END LOOP;
5144: lx_selv_tbl.DELETE;
5145: -- Create/Update Stream Elements with the above modification.
5146: okl_streams_pub.create_stream_elements(
5147: p_api_version => G_API_VERSION,
5148: p_init_msg_list => G_FALSE,
5149: x_return_status => lx_return_status,
5150: x_msg_count => x_msg_count,
5192: RAISE OKL_API.G_EXCEPTION_ERROR;
5193: END IF;
5194:
5195: l_pt_rec.purpose_code := 'PLOW';
5196: lx_return_status := Okl_Streams_Util.round_streams_amount(
5197: p_api_version => g_api_version,
5198: p_init_msg_list => p_init_msg_list,
5199: x_msg_count => x_msg_count,
5200: x_msg_data => x_msg_data,
5209: END IF;
5210: l_pt_tbl.DELETE;
5211: l_pt_tbl := lx_selv_tbl;
5212: -- Create additional Pass Through Streams
5213: okl_streams_pub.create_streams(
5214: p_api_version => G_API_VERSION,
5215: p_init_msg_list => G_FALSE,
5216: x_return_status => lx_return_status,
5217: x_msg_count => x_msg_count,
5403: l_interest_id NUMBER;
5404: l_prin_bal_id NUMBER;
5405: l_termination_id NUMBER;
5406:
5407: l_selv_tbl okl_streams_pub.selv_tbl_type;
5408: l_pt_tbl okl_streams_pub.selv_tbl_type;
5409: l_pt_pro_fee_tbl okl_streams_pub.selv_tbl_type;
5410: lx_selv_tbl okl_streams_pub.selv_tbl_type;
5411:
5404: l_prin_bal_id NUMBER;
5405: l_termination_id NUMBER;
5406:
5407: l_selv_tbl okl_streams_pub.selv_tbl_type;
5408: l_pt_tbl okl_streams_pub.selv_tbl_type;
5409: l_pt_pro_fee_tbl okl_streams_pub.selv_tbl_type;
5410: lx_selv_tbl okl_streams_pub.selv_tbl_type;
5411:
5412: l_stmv_rec okl_streams_pub.stmv_rec_type;
5405: l_termination_id NUMBER;
5406:
5407: l_selv_tbl okl_streams_pub.selv_tbl_type;
5408: l_pt_tbl okl_streams_pub.selv_tbl_type;
5409: l_pt_pro_fee_tbl okl_streams_pub.selv_tbl_type;
5410: lx_selv_tbl okl_streams_pub.selv_tbl_type;
5411:
5412: l_stmv_rec okl_streams_pub.stmv_rec_type;
5413: l_pt_rec okl_streams_pub.stmv_rec_type;
5406:
5407: l_selv_tbl okl_streams_pub.selv_tbl_type;
5408: l_pt_tbl okl_streams_pub.selv_tbl_type;
5409: l_pt_pro_fee_tbl okl_streams_pub.selv_tbl_type;
5410: lx_selv_tbl okl_streams_pub.selv_tbl_type;
5411:
5412: l_stmv_rec okl_streams_pub.stmv_rec_type;
5413: l_pt_rec okl_streams_pub.stmv_rec_type;
5414: l_pt_pro_fee_rec okl_streams_pub.stmv_rec_type;
5408: l_pt_tbl okl_streams_pub.selv_tbl_type;
5409: l_pt_pro_fee_tbl okl_streams_pub.selv_tbl_type;
5410: lx_selv_tbl okl_streams_pub.selv_tbl_type;
5411:
5412: l_stmv_rec okl_streams_pub.stmv_rec_type;
5413: l_pt_rec okl_streams_pub.stmv_rec_type;
5414: l_pt_pro_fee_rec okl_streams_pub.stmv_rec_type;
5415: lx_stmv_rec okl_streams_pub.stmv_rec_type;
5416:
5409: l_pt_pro_fee_tbl okl_streams_pub.selv_tbl_type;
5410: lx_selv_tbl okl_streams_pub.selv_tbl_type;
5411:
5412: l_stmv_rec okl_streams_pub.stmv_rec_type;
5413: l_pt_rec okl_streams_pub.stmv_rec_type;
5414: l_pt_pro_fee_rec okl_streams_pub.stmv_rec_type;
5415: lx_stmv_rec okl_streams_pub.stmv_rec_type;
5416:
5417: -- Loan Amortization
5410: lx_selv_tbl okl_streams_pub.selv_tbl_type;
5411:
5412: l_stmv_rec okl_streams_pub.stmv_rec_type;
5413: l_pt_rec okl_streams_pub.stmv_rec_type;
5414: l_pt_pro_fee_rec okl_streams_pub.stmv_rec_type;
5415: lx_stmv_rec okl_streams_pub.stmv_rec_type;
5416:
5417: -- Loan Amortization
5418: l_principal_tbl okl_streams_pub.selv_tbl_type;
5411:
5412: l_stmv_rec okl_streams_pub.stmv_rec_type;
5413: l_pt_rec okl_streams_pub.stmv_rec_type;
5414: l_pt_pro_fee_rec okl_streams_pub.stmv_rec_type;
5415: lx_stmv_rec okl_streams_pub.stmv_rec_type;
5416:
5417: -- Loan Amortization
5418: l_principal_tbl okl_streams_pub.selv_tbl_type;
5419: l_interest_tbl okl_streams_pub.selv_tbl_type;
5414: l_pt_pro_fee_rec okl_streams_pub.stmv_rec_type;
5415: lx_stmv_rec okl_streams_pub.stmv_rec_type;
5416:
5417: -- Loan Amortization
5418: l_principal_tbl okl_streams_pub.selv_tbl_type;
5419: l_interest_tbl okl_streams_pub.selv_tbl_type;
5420: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
5421: l_termination_tbl okl_streams_pub.selv_tbl_type;
5422: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
5415: lx_stmv_rec okl_streams_pub.stmv_rec_type;
5416:
5417: -- Loan Amortization
5418: l_principal_tbl okl_streams_pub.selv_tbl_type;
5419: l_interest_tbl okl_streams_pub.selv_tbl_type;
5420: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
5421: l_termination_tbl okl_streams_pub.selv_tbl_type;
5422: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
5423:
5416:
5417: -- Loan Amortization
5418: l_principal_tbl okl_streams_pub.selv_tbl_type;
5419: l_interest_tbl okl_streams_pub.selv_tbl_type;
5420: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
5421: l_termination_tbl okl_streams_pub.selv_tbl_type;
5422: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
5423:
5424: l_capital_cost NUMBER;
5417: -- Loan Amortization
5418: l_principal_tbl okl_streams_pub.selv_tbl_type;
5419: l_interest_tbl okl_streams_pub.selv_tbl_type;
5420: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
5421: l_termination_tbl okl_streams_pub.selv_tbl_type;
5422: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
5423:
5424: l_capital_cost NUMBER;
5425: l_interim_interest NUMBER;
5418: l_principal_tbl okl_streams_pub.selv_tbl_type;
5419: l_interest_tbl okl_streams_pub.selv_tbl_type;
5420: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
5421: l_termination_tbl okl_streams_pub.selv_tbl_type;
5422: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
5423:
5424: l_capital_cost NUMBER;
5425: l_interim_interest NUMBER;
5426: l_interim_days NUMBER;
5438:
5439: l_passthrough_pro_fee_id NUMBER;
5440:
5441: -- Added by RGOOTY for perf.: Bug Number 4346646 Start
5442: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
5443: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
5444:
5445: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
5446: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
5439: l_passthrough_pro_fee_id NUMBER;
5440:
5441: -- Added by RGOOTY for perf.: Bug Number 4346646 Start
5442: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
5443: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
5444:
5445: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
5446: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
5447: -- Added by RGOOTY for perf.: End
5441: -- Added by RGOOTY for perf.: Bug Number 4346646 Start
5442: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
5443: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
5444:
5445: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
5446: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
5447: -- Added by RGOOTY for perf.: End
5448:
5449: cursor fee_strm_type_csr ( kleid NUMBER,
5442: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
5443: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
5444:
5445: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
5446: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
5447: -- Added by RGOOTY for perf.: End
5448:
5449: cursor fee_strm_type_csr ( kleid NUMBER,
5450: linestyle VARCHAR2 ) is
5607: ELSIF lx_return_status = OKL_API.G_RET_STS_ERROR THEN
5608: RAISE OKL_API.G_EXCEPTION_ERROR;
5609: END IF;
5610:
5611: lx_return_status := Okl_Streams_Util.round_streams_amount_esg(
5612: p_api_version => g_api_version,
5613: p_init_msg_list => p_init_msg_list,
5614: x_msg_count => x_msg_count,
5615: x_msg_data => x_msg_data,
5631: l_selv_tbl.DELETE;
5632: l_selv_tbl := lx_selv_tbl;
5633:
5634: --Accumulate Stream Header
5635: OKL_STREAMS_UTIL.accumulate_strm_headers(
5636: p_stmv_rec => l_stmv_rec,
5637: x_full_stmv_tbl => l_stmv_tbl,
5638: x_return_status => lx_return_status );
5639: IF (lx_return_status = G_RET_STS_UNEXP_ERROR) THEN
5642: RAISE OKL_API.G_EXCEPTION_ERROR;
5643: END IF;
5644:
5645: --Accumulate Stream Elements
5646: OKL_STREAMS_UTIL.accumulate_strm_elements(
5647: p_stm_index_no => l_stmv_tbl.LAST,
5648: p_selv_tbl => l_selv_tbl,
5649: x_full_selv_tbl => l_full_selv_tbl,
5650: x_return_status => lx_return_status );
5653: ELSIF (lx_return_status = G_RET_STS_ERROR) THEN
5654: RAISE OKL_API.G_EXCEPTION_ERROR;
5655: END IF;
5656: /*
5657: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
5658: p_init_msg_list => G_FALSE,
5659: x_return_status => lx_return_status,
5660: x_msg_count => x_msg_count,
5661: x_msg_data => x_msg_data,
5720: RAISE OKL_API.G_EXCEPTION_ERROR;
5721: END IF;
5722:
5723:
5724: lx_return_status := Okl_Streams_Util.round_streams_amount_esg(
5725: p_api_version => g_api_version,
5726: p_init_msg_list => p_init_msg_list,
5727: x_msg_count => x_msg_count,
5728: x_msg_data => x_msg_data,
5743:
5744: l_pt_tbl.DELETE;
5745: l_pt_tbl := lx_selv_tbl;
5746: --Accumulate Stream Header: 4346646
5747: OKL_STREAMS_UTIL.accumulate_strm_headers(
5748: p_stmv_rec => l_pt_rec,
5749: x_full_stmv_tbl => l_stmv_tbl,
5750: x_return_status => lx_return_status );
5751: IF (lx_return_status = G_RET_STS_UNEXP_ERROR) THEN
5754: RAISE OKL_API.G_EXCEPTION_ERROR;
5755: END IF;
5756:
5757: --Accumulate Stream Elements
5758: OKL_STREAMS_UTIL.accumulate_strm_elements(
5759: p_stm_index_no => l_stmv_tbl.LAST,
5760: p_selv_tbl => l_pt_tbl,
5761: x_full_selv_tbl => l_full_selv_tbl,
5762: x_return_status => lx_return_status );
5765: ELSIF (lx_return_status = G_RET_STS_ERROR) THEN
5766: RAISE OKL_API.G_EXCEPTION_ERROR;
5767: END IF;
5768: /*
5769: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
5770: p_init_msg_list => G_FALSE,
5771: x_return_status => lx_return_status,
5772: x_msg_count => x_msg_count,
5773: x_msg_data => x_msg_data,
5839: RAISE OKL_API.G_EXCEPTION_ERROR;
5840: END IF;
5841:
5842:
5843: lx_return_status := Okl_Streams_Util.round_streams_amount_esg(
5844: p_api_version => g_api_version,
5845: p_init_msg_list => p_init_msg_list,
5846: x_msg_count => x_msg_count,
5847: x_msg_data => x_msg_data,
5862:
5863: l_pt_pro_fee_tbl.DELETE;
5864: l_pt_pro_fee_tbl := lx_selv_tbl;
5865:
5866: OKL_STREAMS_UTIL.accumulate_strm_headers(
5867: p_stmv_rec => l_pt_pro_fee_rec,
5868: x_full_stmv_tbl => l_stmv_tbl,
5869: x_return_status => lx_return_status );
5870:
5874: RAISE OKL_API.G_EXCEPTION_ERROR;
5875: END IF;
5876:
5877: --Accumulate Stream Elements
5878: OKL_STREAMS_UTIL.accumulate_strm_elements(
5879: p_stm_index_no => l_stmv_tbl.LAST,
5880: p_selv_tbl => l_pt_pro_fee_tbl,
5881: x_full_selv_tbl => l_full_selv_tbl,
5882: x_return_status => lx_return_status );
5912: x_payment_count := x_payment_count + 1;
5913: END IF;
5914: END LOOP;
5915: --Create all the accumulated Streams at one shot ..
5916: Okl_Streams_Pub.create_streams_perf(
5917: p_api_version,
5918: p_init_msg_list,
5919: lx_return_status,
5920: x_msg_count,
6207: l_interest_id NUMBER;
6208: l_prin_bal_id NUMBER;
6209: l_termination_id NUMBER;
6210:
6211: l_selv_tbl okl_streams_pub.selv_tbl_type;
6212: l_pt_tbl okl_streams_pub.selv_tbl_type;
6213: lx_selv_tbl okl_streams_pub.selv_tbl_type;
6214:
6215: l_stmv_rec okl_streams_pub.stmv_rec_type;
6208: l_prin_bal_id NUMBER;
6209: l_termination_id NUMBER;
6210:
6211: l_selv_tbl okl_streams_pub.selv_tbl_type;
6212: l_pt_tbl okl_streams_pub.selv_tbl_type;
6213: lx_selv_tbl okl_streams_pub.selv_tbl_type;
6214:
6215: l_stmv_rec okl_streams_pub.stmv_rec_type;
6216: l_pt_rec okl_streams_pub.stmv_rec_type;
6209: l_termination_id NUMBER;
6210:
6211: l_selv_tbl okl_streams_pub.selv_tbl_type;
6212: l_pt_tbl okl_streams_pub.selv_tbl_type;
6213: lx_selv_tbl okl_streams_pub.selv_tbl_type;
6214:
6215: l_stmv_rec okl_streams_pub.stmv_rec_type;
6216: l_pt_rec okl_streams_pub.stmv_rec_type;
6217: lx_stmv_rec okl_streams_pub.stmv_rec_type;
6211: l_selv_tbl okl_streams_pub.selv_tbl_type;
6212: l_pt_tbl okl_streams_pub.selv_tbl_type;
6213: lx_selv_tbl okl_streams_pub.selv_tbl_type;
6214:
6215: l_stmv_rec okl_streams_pub.stmv_rec_type;
6216: l_pt_rec okl_streams_pub.stmv_rec_type;
6217: lx_stmv_rec okl_streams_pub.stmv_rec_type;
6218:
6219: -- Loan Amortization
6212: l_pt_tbl okl_streams_pub.selv_tbl_type;
6213: lx_selv_tbl okl_streams_pub.selv_tbl_type;
6214:
6215: l_stmv_rec okl_streams_pub.stmv_rec_type;
6216: l_pt_rec okl_streams_pub.stmv_rec_type;
6217: lx_stmv_rec okl_streams_pub.stmv_rec_type;
6218:
6219: -- Loan Amortization
6220: l_principal_tbl okl_streams_pub.selv_tbl_type;
6213: lx_selv_tbl okl_streams_pub.selv_tbl_type;
6214:
6215: l_stmv_rec okl_streams_pub.stmv_rec_type;
6216: l_pt_rec okl_streams_pub.stmv_rec_type;
6217: lx_stmv_rec okl_streams_pub.stmv_rec_type;
6218:
6219: -- Loan Amortization
6220: l_principal_tbl okl_streams_pub.selv_tbl_type;
6221: l_interest_tbl okl_streams_pub.selv_tbl_type;
6216: l_pt_rec okl_streams_pub.stmv_rec_type;
6217: lx_stmv_rec okl_streams_pub.stmv_rec_type;
6218:
6219: -- Loan Amortization
6220: l_principal_tbl okl_streams_pub.selv_tbl_type;
6221: l_interest_tbl okl_streams_pub.selv_tbl_type;
6222: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
6223: l_termination_tbl okl_streams_pub.selv_tbl_type;
6224: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
6217: lx_stmv_rec okl_streams_pub.stmv_rec_type;
6218:
6219: -- Loan Amortization
6220: l_principal_tbl okl_streams_pub.selv_tbl_type;
6221: l_interest_tbl okl_streams_pub.selv_tbl_type;
6222: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
6223: l_termination_tbl okl_streams_pub.selv_tbl_type;
6224: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
6225:
6218:
6219: -- Loan Amortization
6220: l_principal_tbl okl_streams_pub.selv_tbl_type;
6221: l_interest_tbl okl_streams_pub.selv_tbl_type;
6222: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
6223: l_termination_tbl okl_streams_pub.selv_tbl_type;
6224: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
6225:
6226: l_capital_cost NUMBER;
6219: -- Loan Amortization
6220: l_principal_tbl okl_streams_pub.selv_tbl_type;
6221: l_interest_tbl okl_streams_pub.selv_tbl_type;
6222: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
6223: l_termination_tbl okl_streams_pub.selv_tbl_type;
6224: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
6225:
6226: l_capital_cost NUMBER;
6227: l_interim_interest NUMBER;
6220: l_principal_tbl okl_streams_pub.selv_tbl_type;
6221: l_interest_tbl okl_streams_pub.selv_tbl_type;
6222: l_prin_bal_tbl okl_streams_pub.selv_tbl_type;
6223: l_termination_tbl okl_streams_pub.selv_tbl_type;
6224: l_pre_tax_inc_tbl okl_streams_pub.selv_tbl_type;
6225:
6226: l_capital_cost NUMBER;
6227: l_interim_interest NUMBER;
6228: l_interim_days NUMBER;
6302: l_initial_irr NUMBER := 0;
6303: l_asset_count NUMBER := 0;
6304:
6305: -- Added by RGOOTY for perf.: Bug Number 4346646 Start
6306: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
6307: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
6308:
6309: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
6310: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
6303: l_asset_count NUMBER := 0;
6304:
6305: -- Added by RGOOTY for perf.: Bug Number 4346646 Start
6306: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
6307: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
6308:
6309: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
6310: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
6311: -- Added by RGOOTY for perf.: End
6305: -- Added by RGOOTY for perf.: Bug Number 4346646 Start
6306: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
6307: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
6308:
6309: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
6310: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
6311: -- Added by RGOOTY for perf.: End
6312:
6313: --Added by prasjain for bug 5474827
6306: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
6307: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
6308:
6309: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
6310: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
6311: -- Added by RGOOTY for perf.: End
6312:
6313: --Added by prasjain for bug 5474827
6314: l_se_id NUMBER;
6317: BEGIN
6318:
6319: -- print( l_prog_name, 'begin' );
6320: -- Added by RGOOTY: Start
6321: OKL_STREAMS_UTIL.get_acc_options(
6322: p_khr_id => p_khr_id,
6323: x_org_id => G_ORG_ID,
6324: x_precision => G_PRECISION,
6325: x_currency_code => G_CURRENCY_CODE,
6791: ELSIF lx_return_status = OKL_API.G_RET_STS_ERROR THEN
6792: RAISE OKL_API.G_EXCEPTION_ERROR;
6793: END IF;
6794:
6795: lx_return_status := Okl_Streams_Util.round_streams_amount_esg(
6796: p_api_version => g_api_version,
6797: p_init_msg_list => p_init_msg_list,
6798: x_msg_count => x_msg_count,
6799: x_msg_data => x_msg_data,
6814:
6815: l_principal_tbl.DELETE;
6816: l_principal_tbl := lx_selv_tbl;
6817:
6818: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
6819: p_init_msg_list => G_FALSE,
6820: x_return_status => lx_return_status,
6821: x_msg_count => x_msg_count,
6822: x_msg_data => x_msg_data,
6852: ELSIF lx_return_status = OKL_API.G_RET_STS_ERROR THEN
6853: RAISE OKL_API.G_EXCEPTION_ERROR;
6854: END IF;
6855:
6856: lx_return_status := Okl_Streams_Util.round_streams_amount_esg(
6857: p_api_version => g_api_version,
6858: p_init_msg_list => p_init_msg_list,
6859: x_msg_count => x_msg_count,
6860: x_msg_data => x_msg_data,
6875:
6876: l_interest_tbl.DELETE;
6877: l_interest_tbl := lx_selv_tbl;
6878:
6879: okl_streams_pub.create_streams(
6880: p_api_version => G_API_VERSION,
6881: p_init_msg_list => G_FALSE,
6882: x_return_status => lx_return_status,
6883: x_msg_count => x_msg_count,
6913: ELSIF lx_return_status = OKL_API.G_RET_STS_ERROR THEN
6914: RAISE OKL_API.G_EXCEPTION_ERROR;
6915: END IF;
6916:
6917: lx_return_status := Okl_Streams_Util.round_streams_amount_esg(
6918: p_api_version => g_api_version,
6919: p_init_msg_list => p_init_msg_list,
6920: x_msg_count => x_msg_count,
6921: x_msg_data => x_msg_data,
6936:
6937: l_prin_bal_tbl.DELETE;
6938: l_prin_bal_tbl := lx_selv_tbl;
6939:
6940: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
6941: p_init_msg_list => G_FALSE,
6942: x_return_status => lx_return_status,
6943: x_msg_count => x_msg_count,
6944: x_msg_data => x_msg_data,
6968: ELSIF lx_return_status = OKL_API.G_RET_STS_ERROR THEN
6969: RAISE OKL_API.G_EXCEPTION_ERROR;
6970: END IF;
6971:
6972: lx_return_status := Okl_Streams_Util.round_streams_amount_esg(
6973: p_api_version => g_api_version,
6974: p_init_msg_list => p_init_msg_list,
6975: x_msg_count => x_msg_count,
6976: x_msg_data => x_msg_data,
6991:
6992: l_termination_tbl.DELETE;
6993: l_termination_tbl := lx_selv_tbl;
6994:
6995: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
6996: p_init_msg_list => G_FALSE,
6997: x_return_status => lx_return_status,
6998: x_msg_count => x_msg_count,
6999: x_msg_data => x_msg_data,
7021: ELSIF lx_return_status = OKL_API.G_RET_STS_ERROR THEN
7022: RAISE OKL_API.G_EXCEPTION_ERROR;
7023: END IF;
7024:
7025: lx_return_status := Okl_Streams_Util.round_streams_amount_esg(
7026: p_api_version => g_api_version,
7027: p_init_msg_list => p_init_msg_list,
7028: x_msg_count => x_msg_count,
7029: x_msg_data => x_msg_data,
7044:
7045: l_pre_tax_inc_tbl.DELETE;
7046: l_pre_tax_inc_tbl := lx_selv_tbl;
7047:
7048: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
7049: p_init_msg_list => G_FALSE,
7050: x_return_status => lx_return_status,
7051: x_msg_count => x_msg_count,
7052: x_msg_data => x_msg_data,
7536: --
7537: -- call process API to create parent Stream Header and its child Stream Elements
7538: --
7539:
7540: lx_return_status := Okl_Streams_Util.round_streams_amount_esg(
7541: p_api_version => g_api_version,
7542: p_init_msg_list => p_init_msg_list,
7543: x_msg_count => x_msg_count,
7544: x_msg_data => x_msg_data,
7559:
7560: l_selv_tbl.DELETE;
7561: l_selv_tbl := lx_selv_tbl;
7562: --Accumulate Stream Header
7563: OKL_STREAMS_UTIL.accumulate_strm_headers(
7564: p_stmv_rec => l_stmv_rec,
7565: x_full_stmv_tbl => l_stmv_tbl,
7566: x_return_status => lx_return_status );
7567: IF (lx_return_status = G_RET_STS_UNEXP_ERROR) THEN
7569: ELSIF (lx_return_status = G_RET_STS_ERROR) THEN
7570: RAISE OKL_API.G_EXCEPTION_ERROR;
7571: END IF;
7572: --Accumulate Stream Elements
7573: OKL_STREAMS_UTIL.accumulate_strm_elements(
7574: p_stm_index_no => l_stmv_tbl.LAST,
7575: p_selv_tbl => l_selv_tbl,
7576: x_full_selv_tbl => l_full_selv_tbl,
7577: x_return_status => lx_return_status );
7605: --Create all the accumulated Streams at one shot ..
7606: IF l_stmv_tbl.COUNT > 0 AND
7607: l_full_selv_tbl.COUNT > 0
7608: THEN
7609: Okl_Streams_Pub.create_streams_perf(
7610: p_api_version,
7611: p_init_msg_list,
7612: lx_return_status,
7613: x_msg_count,
7690: END IF;
7691:
7692: If ( l_sty_id IS NOT NULL ) Then
7693:
7694: UPDATE okl_streams
7695: SET sty_id = l_sty_id
7696: WHERE khr_id = p_khr_id
7697: AND say_code = 'WORK'
7698: AND NVL(purpose_code, '-99') = l_purpose_code
7735: If ( l_sty_id IS NOT NULL ) Then
7736:
7737: -- print( l_prog_name, ' updating financed fees ' || to_char( r_financed_fees.id ));
7738:
7739: UPDATE okl_streams
7740: SET sty_id = l_sty_id
7741: WHERE khr_id = p_khr_id
7742: AND kle_id = r_financed_fees.id
7743: AND say_code = 'WORK'
7759:
7760: UPDATE okl_strm_elements
7761: SET comments=NULL
7762: WHERE stm_id IN
7763: (SELECT id from okl_streams WHERE khr_id = p_khr_id and say_code = 'WORK');
7764: -- print( l_prog_name, ' done ' );
7765:
7766: /*
7767: * delete the duplicates from the okl_streams header table.
7763: (SELECT id from okl_streams WHERE khr_id = p_khr_id and say_code = 'WORK');
7764: -- print( l_prog_name, ' done ' );
7765:
7766: /*
7767: * delete the duplicates from the okl_streams header table.
7768: */
7769: -- Modified by RGOOTY: Start
7770: IF (p_generation_type <> 'RESIDUAL VALUE' AND p_generation_type <> 'CAPITAL REDUCTION')
7771: THEN
7920: l_advance_or_arrears VARCHAR2(10) := 'ARREARS';
7921:
7922: Cursor l_strms_csr ( chrId NUMBER, styId NUMBER ) IS
7923: Select str.id strm_id
7924: From okl_streams str
7925: Where str.sty_id = styId
7926: and str.khr_id = chrId
7927: and str.say_code = 'WORK';
7928:
7947: l_sty_id NUMBER;
7948: l_sty_name VARCHAR2(150);
7949: l_mapped_sty_name VARCHAR2(150);
7950:
7951: l_selv_tbl okl_streams_pub.selv_tbl_type;
7952: l_pt_tbl okl_streams_pub.selv_tbl_type;
7953: lx_selv_tbl okl_streams_pub.selv_tbl_type;
7954:
7955: l_stmv_rec okl_streams_pub.stmv_rec_type;
7948: l_sty_name VARCHAR2(150);
7949: l_mapped_sty_name VARCHAR2(150);
7950:
7951: l_selv_tbl okl_streams_pub.selv_tbl_type;
7952: l_pt_tbl okl_streams_pub.selv_tbl_type;
7953: lx_selv_tbl okl_streams_pub.selv_tbl_type;
7954:
7955: l_stmv_rec okl_streams_pub.stmv_rec_type;
7956: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
7949: l_mapped_sty_name VARCHAR2(150);
7950:
7951: l_selv_tbl okl_streams_pub.selv_tbl_type;
7952: l_pt_tbl okl_streams_pub.selv_tbl_type;
7953: lx_selv_tbl okl_streams_pub.selv_tbl_type;
7954:
7955: l_stmv_rec okl_streams_pub.stmv_rec_type;
7956: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
7957: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
7951: l_selv_tbl okl_streams_pub.selv_tbl_type;
7952: l_pt_tbl okl_streams_pub.selv_tbl_type;
7953: lx_selv_tbl okl_streams_pub.selv_tbl_type;
7954:
7955: l_stmv_rec okl_streams_pub.stmv_rec_type;
7956: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
7957: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
7958: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
7959: l_pt_rec okl_streams_pub.stmv_rec_type;
7952: l_pt_tbl okl_streams_pub.selv_tbl_type;
7953: lx_selv_tbl okl_streams_pub.selv_tbl_type;
7954:
7955: l_stmv_rec okl_streams_pub.stmv_rec_type;
7956: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
7957: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
7958: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
7959: l_pt_rec okl_streams_pub.stmv_rec_type;
7960: lx_stmv_rec okl_streams_pub.stmv_rec_type;
7953: lx_selv_tbl okl_streams_pub.selv_tbl_type;
7954:
7955: l_stmv_rec okl_streams_pub.stmv_rec_type;
7956: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
7957: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
7958: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
7959: l_pt_rec okl_streams_pub.stmv_rec_type;
7960: lx_stmv_rec okl_streams_pub.stmv_rec_type;
7961:
7954:
7955: l_stmv_rec okl_streams_pub.stmv_rec_type;
7956: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
7957: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
7958: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
7959: l_pt_rec okl_streams_pub.stmv_rec_type;
7960: lx_stmv_rec okl_streams_pub.stmv_rec_type;
7961:
7962: i BINARY_INTEGER := 0;
7955: l_stmv_rec okl_streams_pub.stmv_rec_type;
7956: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
7957: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
7958: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
7959: l_pt_rec okl_streams_pub.stmv_rec_type;
7960: lx_stmv_rec okl_streams_pub.stmv_rec_type;
7961:
7962: i BINARY_INTEGER := 0;
7963:
7956: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
7957: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
7958: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
7959: l_pt_rec okl_streams_pub.stmv_rec_type;
7960: lx_stmv_rec okl_streams_pub.stmv_rec_type;
7961:
7962: i BINARY_INTEGER := 0;
7963:
7964: l_api_name CONSTANT VARCHAR2(61) := 'GEN_VAR_INT_SCHEDULE';
8016: END LOOP;
8017:
8018: If ( l_stmv_tbl.COUNT > 0 ) Then
8019:
8020: Okl_Streams_pub.update_streams(
8021: p_api_version => p_api_version,
8022: p_init_msg_list => p_init_msg_list,
8023: x_return_status => x_return_status,
8024: x_msg_count => x_msg_count,
8091: RAISE OKL_API.G_EXCEPTION_ERROR;
8092: END IF;
8093:
8094:
8095: x_return_status := Okl_Streams_Util.round_streams_amount(
8096: p_api_version => p_api_version,
8097: p_init_msg_list => p_init_msg_list,
8098: x_msg_count => x_msg_count,
8099: x_msg_data => x_msg_data,
8109:
8110: l_selv_tbl.DELETE;
8111: l_selv_tbl := lx_selv_tbl;
8112:
8113: okl_streams_pub.create_streams(p_api_version => p_api_version,
8114: p_init_msg_list => p_init_msg_list,
8115: x_return_status => x_return_status,
8116: x_msg_count => x_msg_count,
8117: x_msg_data => x_msg_data,
8167: p_contract_id IN NUMBER,
8168: p_kle_id IN NUMBER,
8169: p_sty_id IN NUMBER,
8170: p_mode IN VARCHAR2,
8171: x_stmv_rec OUT NOCOPY okl_streams_pub.stmv_rec_type,
8172: x_selv_tbl OUT NOCOPY okl_streams_pub.selv_tbl_type,
8173: x_return_status OUT NOCOPY VARCHAR2,
8174: x_msg_count OUT NOCOPY NUMBER,
8175: x_msg_data OUT NOCOPY VARCHAR2) IS
8168: p_kle_id IN NUMBER,
8169: p_sty_id IN NUMBER,
8170: p_mode IN VARCHAR2,
8171: x_stmv_rec OUT NOCOPY okl_streams_pub.stmv_rec_type,
8172: x_selv_tbl OUT NOCOPY okl_streams_pub.selv_tbl_type,
8173: x_return_status OUT NOCOPY VARCHAR2,
8174: x_msg_count OUT NOCOPY NUMBER,
8175: x_msg_data OUT NOCOPY VARCHAR2) IS
8176:
8192: stm.id stm_id
8193: from okl_pools pol,
8194: okl_pool_contents pcn,
8195: okl_strm_type_v sty,
8196: okl_streams stm,
8197: okl_strm_elements ele
8198: where pcn.sty_id = sty.id
8199: and pcn.pol_id = pol.id
8200: and stm.kle_id = pcn.kle_id
8251: stm.id stm_id
8252: from okl_pools pol,
8253: okl_pool_contents pcn,
8254: okl_strm_type_v sty,
8255: okl_streams stm,
8256: okl_strm_elements ele
8257: where pcn.sty_id = sty.id
8258: and pcn.pol_id = pol.id
8259: and stm.kle_id = pcn.kle_id
8304: l_sty_id NUMBER;
8305: l_sty_name VARCHAR2(150);
8306: l_mapped_sty_name VARCHAR2(150);
8307:
8308: l_selv_tbl okl_streams_pub.selv_tbl_type;
8309: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
8310: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
8311: lx_selv_tbl okl_streams_pub.selv_tbl_type;
8312:
8305: l_sty_name VARCHAR2(150);
8306: l_mapped_sty_name VARCHAR2(150);
8307:
8308: l_selv_tbl okl_streams_pub.selv_tbl_type;
8309: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
8310: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
8311: lx_selv_tbl okl_streams_pub.selv_tbl_type;
8312:
8313: l_stmv_rec okl_streams_pub.stmv_rec_type;
8306: l_mapped_sty_name VARCHAR2(150);
8307:
8308: l_selv_tbl okl_streams_pub.selv_tbl_type;
8309: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
8310: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
8311: lx_selv_tbl okl_streams_pub.selv_tbl_type;
8312:
8313: l_stmv_rec okl_streams_pub.stmv_rec_type;
8314: lx_stmv_rec okl_streams_pub.stmv_rec_type;
8307:
8308: l_selv_tbl okl_streams_pub.selv_tbl_type;
8309: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
8310: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
8311: lx_selv_tbl okl_streams_pub.selv_tbl_type;
8312:
8313: l_stmv_rec okl_streams_pub.stmv_rec_type;
8314: lx_stmv_rec okl_streams_pub.stmv_rec_type;
8315:
8309: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
8310: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
8311: lx_selv_tbl okl_streams_pub.selv_tbl_type;
8312:
8313: l_stmv_rec okl_streams_pub.stmv_rec_type;
8314: lx_stmv_rec okl_streams_pub.stmv_rec_type;
8315:
8316: cursor l_hdrrl_csr IS
8317: select crl.RULE_INFORMATION1 method
8310: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
8311: lx_selv_tbl okl_streams_pub.selv_tbl_type;
8312:
8313: l_stmv_rec okl_streams_pub.stmv_rec_type;
8314: lx_stmv_rec okl_streams_pub.stmv_rec_type;
8315:
8316: cursor l_hdrrl_csr IS
8317: select crl.RULE_INFORMATION1 method
8318: from OKC_RULE_GROUPS_B crg,
8837: p_kle_id IN NUMBER,
8838: p_sty_id IN NUMBER,
8839: --sosharma added, bug 6691554
8840: p_mode IN VARCHAR2,
8841: x_stmv_rec OUT NOCOPY okl_streams_pub.stmv_rec_type,
8842: x_selv_tbl OUT NOCOPY okl_streams_pub.selv_tbl_type,
8843: x_return_status OUT NOCOPY VARCHAR2,
8844: x_msg_count OUT NOCOPY NUMBER,
8845: x_msg_data OUT NOCOPY VARCHAR2) IS
8838: p_sty_id IN NUMBER,
8839: --sosharma added, bug 6691554
8840: p_mode IN VARCHAR2,
8841: x_stmv_rec OUT NOCOPY okl_streams_pub.stmv_rec_type,
8842: x_selv_tbl OUT NOCOPY okl_streams_pub.selv_tbl_type,
8843: x_return_status OUT NOCOPY VARCHAR2,
8844: x_msg_count OUT NOCOPY NUMBER,
8845: x_msg_data OUT NOCOPY VARCHAR2) IS
8846:
8862: stm.id stm_id
8863: from okl_pools pol,
8864: okl_pool_contents pcn,
8865: okl_strm_type_v sty,
8866: okl_streams stm,
8867: okl_strm_elements ele
8868: where pcn.sty_id = sty.id
8869: and pcn.pol_id = pol.id
8870: and stm.kle_id = pcn.kle_id
8924: stm.id stm_id
8925: from okl_pools pol,
8926: okl_pool_contents pcn,
8927: okl_strm_type_v sty,
8928: okl_streams stm,
8929: okl_strm_elements ele
8930: where pcn.sty_id = sty.id
8931: and pcn.pol_id = pol.id
8932: and stm.kle_id = pcn.kle_id
8971: l_sty_id NUMBER;
8972: l_sty_name VARCHAR2(150);
8973: l_mapped_sty_name VARCHAR2(150);
8974:
8975: l_selv_tbl okl_streams_pub.selv_tbl_type;
8976: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
8977: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
8978: lx_selv_tbl okl_streams_pub.selv_tbl_type;
8979:
8972: l_sty_name VARCHAR2(150);
8973: l_mapped_sty_name VARCHAR2(150);
8974:
8975: l_selv_tbl okl_streams_pub.selv_tbl_type;
8976: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
8977: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
8978: lx_selv_tbl okl_streams_pub.selv_tbl_type;
8979:
8980: l_stmv_rec okl_streams_pub.stmv_rec_type;
8973: l_mapped_sty_name VARCHAR2(150);
8974:
8975: l_selv_tbl okl_streams_pub.selv_tbl_type;
8976: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
8977: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
8978: lx_selv_tbl okl_streams_pub.selv_tbl_type;
8979:
8980: l_stmv_rec okl_streams_pub.stmv_rec_type;
8981: lx_stmv_rec okl_streams_pub.stmv_rec_type;
8974:
8975: l_selv_tbl okl_streams_pub.selv_tbl_type;
8976: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
8977: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
8978: lx_selv_tbl okl_streams_pub.selv_tbl_type;
8979:
8980: l_stmv_rec okl_streams_pub.stmv_rec_type;
8981: lx_stmv_rec okl_streams_pub.stmv_rec_type;
8982:
8976: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
8977: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
8978: lx_selv_tbl okl_streams_pub.selv_tbl_type;
8979:
8980: l_stmv_rec okl_streams_pub.stmv_rec_type;
8981: lx_stmv_rec okl_streams_pub.stmv_rec_type;
8982:
8983: cursor l_hdrrl_csr IS
8984: select crl.RULE_INFORMATION1 method
8977: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
8978: lx_selv_tbl okl_streams_pub.selv_tbl_type;
8979:
8980: l_stmv_rec okl_streams_pub.stmv_rec_type;
8981: lx_stmv_rec okl_streams_pub.stmv_rec_type;
8982:
8983: cursor l_hdrrl_csr IS
8984: select crl.RULE_INFORMATION1 method
8985: from OKC_RULE_GROUPS_B crg,
9437: Cursor l_strms_csr ( khrId NUMBER, kleId NUMBER, strmname VARCHAR2) IS
9438: select stm.id strm_id
9439: from okl_strm_type_v sty,
9440: okl_strm_type_tl stl,
9441: okl_streams stm
9442: where stl.language = 'US'
9443: and stl.name = strmname
9444: and sty.id = stl.id
9445: and stm.sty_id = sty.id
9458: sty.stream_type_purpose stream_type_purpose
9459: from okl_pools pol,
9460: okl_pool_contents pcn,
9461: okl_strm_type_v sty,
9462: okl_streams stm
9463: where pcn.sty_id = sty.id
9464: and pcn.pol_id = pol.id
9465: and stm.kle_id = pcn.kle_id
9466: and stm.khr_id = pcn.khr_id
9479: sty.stream_type_purpose stream_type_purpose
9480: from okl_pools pol,
9481: okl_pool_contents pcn,
9482: okl_strm_type_v sty,
9483: okl_streams stm
9484: where pcn.sty_id = sty.id
9485: and pcn.pol_id = pol.id
9486: and stm.kle_id = pcn.kle_id
9487: and stm.khr_id = pcn.khr_id
9506: sty.stream_type_purpose stream_type_purpose
9507: from okl_pools pol,
9508: okl_pool_contents pcn,
9509: okl_strm_type_v sty,
9510: okl_streams stm
9511: where pcn.sty_id = sty.id
9512: and pcn.pol_id = pol.id
9513: and stm.kle_id = pcn.kle_id
9514: and stm.khr_id = pcn.khr_id
9527: sty.stream_type_purpose stream_type_purpose
9528: from okl_pools pol,
9529: okl_pool_contents pcn,
9530: okl_strm_type_v sty,
9531: okl_streams stm
9532: where pcn.sty_id = sty.id
9533: and pcn.pol_id = pol.id
9534: and stm.kle_id = pcn.kle_id
9535: and stm.khr_id = pcn.khr_id
9545: sec_strms_rec sec_strms_csr%ROWTYPE;
9546:
9547: l_sty_id NUMBER;
9548:
9549: l_selv_tbl okl_streams_pub.selv_tbl_type;
9550: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
9551: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
9552: lx_selv_tbl okl_streams_pub.selv_tbl_type;
9553:
9546:
9547: l_sty_id NUMBER;
9548:
9549: l_selv_tbl okl_streams_pub.selv_tbl_type;
9550: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
9551: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
9552: lx_selv_tbl okl_streams_pub.selv_tbl_type;
9553:
9554: l_stmv_rec okl_streams_pub.stmv_rec_type;
9547: l_sty_id NUMBER;
9548:
9549: l_selv_tbl okl_streams_pub.selv_tbl_type;
9550: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
9551: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
9552: lx_selv_tbl okl_streams_pub.selv_tbl_type;
9553:
9554: l_stmv_rec okl_streams_pub.stmv_rec_type;
9555: lx_stmv_rec okl_streams_pub.stmv_rec_type;
9548:
9549: l_selv_tbl okl_streams_pub.selv_tbl_type;
9550: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
9551: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
9552: lx_selv_tbl okl_streams_pub.selv_tbl_type;
9553:
9554: l_stmv_rec okl_streams_pub.stmv_rec_type;
9555: lx_stmv_rec okl_streams_pub.stmv_rec_type;
9556:
9550: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
9551: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
9552: lx_selv_tbl okl_streams_pub.selv_tbl_type;
9553:
9554: l_stmv_rec okl_streams_pub.stmv_rec_type;
9555: lx_stmv_rec okl_streams_pub.stmv_rec_type;
9556:
9557: i NUMBER;
9558: n NUMBER;
9551: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
9552: lx_selv_tbl okl_streams_pub.selv_tbl_type;
9553:
9554: l_stmv_rec okl_streams_pub.stmv_rec_type;
9555: lx_stmv_rec okl_streams_pub.stmv_rec_type;
9556:
9557: i NUMBER;
9558: n NUMBER;
9559:
9634: END LOOP;
9635:
9636: If ( l_stmv_tbl.COUNT > 0 ) Then
9637:
9638: Okl_Streams_pub.update_streams(
9639: p_api_version => p_api_version,
9640: p_init_msg_list => p_init_msg_list,
9641: x_return_status => x_return_status,
9642: x_msg_count => x_msg_count,
9688: END LOOP;
9689:
9690: If ( l_stmv_tbl.COUNT > 0 ) Then
9691:
9692: Okl_Streams_pub.update_streams(
9693: p_api_version => p_api_version,
9694: p_init_msg_list => p_init_msg_list,
9695: x_return_status => x_return_status,
9696: x_msg_count => x_msg_count,
9746: If( l_selv_tbl.COUNT > 0 AND (l_stmv_rec.sty_id IS NOT NULL) ) Then
9747:
9748: print( l_api_name, ' creating pv disb streams ' );
9749:
9750: x_return_status := Okl_Streams_Util.round_streams_amount(
9751: p_api_version => g_api_version,
9752: p_init_msg_list => p_init_msg_list,
9753: x_msg_count => x_msg_count,
9754: x_msg_data => x_msg_data,
9764:
9765: l_selv_tbl.DELETE;
9766: l_selv_tbl := lx_selv_tbl;
9767:
9768: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
9769: p_init_msg_list => G_FALSE,
9770: x_return_status => x_return_status,
9771: x_msg_count => x_msg_count,
9772: x_msg_data => x_msg_data,
9824: END LOOP;
9825:
9826: If ( l_stmv_tbl.COUNT > 0 ) Then
9827:
9828: Okl_Streams_pub.update_streams(
9829: p_api_version => p_api_version,
9830: p_init_msg_list => p_init_msg_list,
9831: x_return_status => x_return_status,
9832: x_msg_count => x_msg_count,
9877: END LOOP;
9878:
9879: If ( l_stmv_tbl.COUNT > 0 ) Then
9880:
9881: Okl_Streams_pub.update_streams(
9882: p_api_version => p_api_version,
9883: p_init_msg_list => p_init_msg_list,
9884: x_return_status => x_return_status,
9885: x_msg_count => x_msg_count,
9935: If( l_selv_tbl.COUNT > 0 AND (l_stmv_rec.sty_id IS NOT NULL) ) Then
9936:
9937: print( l_api_name, ' creating pv disb streams ' );
9938:
9939: x_return_status := Okl_Streams_Util.round_streams_amount(
9940: p_api_version => g_api_version,
9941: p_init_msg_list => p_init_msg_list,
9942: x_msg_count => x_msg_count,
9943: x_msg_data => x_msg_data,
9953:
9954: l_selv_tbl.DELETE;
9955: l_selv_tbl := lx_selv_tbl;
9956:
9957: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
9958: p_init_msg_list => G_FALSE,
9959: x_return_status => x_return_status,
9960: x_msg_count => x_msg_count,
9961: x_msg_data => x_msg_data,
10031: Cursor l_strms_csr ( khrId NUMBER, kleId NUMBER, strmname VARCHAR2) IS
10032: select stm.id strm_id
10033: from okl_strm_type_v sty,
10034: okl_strm_type_tl stl,
10035: okl_streams stm
10036: where stl.language = 'US'
10037: and stl.name = strmname
10038: and sty.id = stl.id
10039: and stm.sty_id = sty.id
10052: sty.stream_type_purpose stream_type_purpose
10053: from okl_pools pol,
10054: okl_pool_contents pcn,
10055: okl_strm_type_v sty,
10056: okl_streams stm
10057: where pcn.sty_id = sty.id
10058: and pcn.pol_id = pol.id
10059: and stm.kle_id = pcn.kle_id
10060: and stm.khr_id = pcn.khr_id
10073: sty.stream_type_purpose stream_type_purpose
10074: from okl_pools pol,
10075: okl_pool_contents pcn,
10076: okl_strm_type_v sty,
10077: okl_streams stm
10078: where pcn.sty_id = sty.id
10079: and pcn.pol_id = pol.id
10080: and stm.kle_id = pcn.kle_id
10081: and stm.khr_id = pcn.khr_id
10101: sty.stream_type_purpose stream_type_purpose
10102: from okl_pools pol,
10103: okl_pool_contents pcn,
10104: okl_strm_type_v sty,
10105: okl_streams stm
10106: where pcn.sty_id = sty.id
10107: and pcn.pol_id = pol.id
10108: and stm.kle_id = pcn.kle_id
10109: and stm.khr_id = pcn.khr_id
10122: sty.stream_type_purpose stream_type_purpose
10123: from okl_pools pol,
10124: okl_pool_contents pcn,
10125: okl_strm_type_v sty,
10126: okl_streams stm
10127: where pcn.sty_id = sty.id
10128: and pcn.pol_id = pol.id
10129: and stm.kle_id = pcn.kle_id
10130: and stm.khr_id = pcn.khr_id
10142: sec_strms_rec sec_strms_csr%ROWTYPE;
10143:
10144: l_sty_id NUMBER;
10145:
10146: l_selv_tbl okl_streams_pub.selv_tbl_type;
10147: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
10148: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
10149: lx_selv_tbl okl_streams_pub.selv_tbl_type;
10150:
10143:
10144: l_sty_id NUMBER;
10145:
10146: l_selv_tbl okl_streams_pub.selv_tbl_type;
10147: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
10148: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
10149: lx_selv_tbl okl_streams_pub.selv_tbl_type;
10150:
10151: l_stmv_rec okl_streams_pub.stmv_rec_type;
10144: l_sty_id NUMBER;
10145:
10146: l_selv_tbl okl_streams_pub.selv_tbl_type;
10147: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
10148: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
10149: lx_selv_tbl okl_streams_pub.selv_tbl_type;
10150:
10151: l_stmv_rec okl_streams_pub.stmv_rec_type;
10152: lx_stmv_rec okl_streams_pub.stmv_rec_type;
10145:
10146: l_selv_tbl okl_streams_pub.selv_tbl_type;
10147: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
10148: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
10149: lx_selv_tbl okl_streams_pub.selv_tbl_type;
10150:
10151: l_stmv_rec okl_streams_pub.stmv_rec_type;
10152: lx_stmv_rec okl_streams_pub.stmv_rec_type;
10153:
10147: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
10148: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
10149: lx_selv_tbl okl_streams_pub.selv_tbl_type;
10150:
10151: l_stmv_rec okl_streams_pub.stmv_rec_type;
10152: lx_stmv_rec okl_streams_pub.stmv_rec_type;
10153:
10154: i NUMBER;
10155: n NUMBER;
10148: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
10149: lx_selv_tbl okl_streams_pub.selv_tbl_type;
10150:
10151: l_stmv_rec okl_streams_pub.stmv_rec_type;
10152: lx_stmv_rec okl_streams_pub.stmv_rec_type;
10153:
10154: i NUMBER;
10155: n NUMBER;
10156:
10236: END LOOP;
10237:
10238: If ( l_stmv_tbl.COUNT > 0 ) Then
10239:
10240: Okl_Streams_pub.update_streams(
10241: p_api_version => p_api_version,
10242: p_init_msg_list => p_init_msg_list,
10243: x_return_status => x_return_status,
10244: x_msg_count => x_msg_count,
10290: END LOOP;
10291:
10292: If ( l_stmv_tbl.COUNT > 0 ) Then
10293:
10294: Okl_Streams_pub.update_streams(
10295: p_api_version => p_api_version,
10296: p_init_msg_list => p_init_msg_list,
10297: x_return_status => x_return_status,
10298: x_msg_count => x_msg_count,
10349: If( l_selv_tbl.COUNT > 0 AND l_stmv_rec.sty_id IS NOT NULL) Then
10350:
10351: print( l_api_name, ' creating disb streams ' );
10352:
10353: x_return_status := Okl_Streams_Util.round_streams_amount(
10354: p_api_version => g_api_version,
10355: p_init_msg_list => p_init_msg_list,
10356: x_msg_count => x_msg_count,
10357: x_msg_data => x_msg_data,
10367:
10368: l_selv_tbl.DELETE;
10369: l_selv_tbl := lx_selv_tbl;
10370:
10371: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
10372: p_init_msg_list => G_FALSE,
10373: x_return_status => x_return_status,
10374: x_msg_count => x_msg_count,
10375: x_msg_data => x_msg_data,
10427: END LOOP;
10428:
10429: If ( l_stmv_tbl.COUNT > 0 ) Then
10430:
10431: Okl_Streams_pub.update_streams(
10432: p_api_version => p_api_version,
10433: p_init_msg_list => p_init_msg_list,
10434: x_return_status => x_return_status,
10435: x_msg_count => x_msg_count,
10481: END LOOP;
10482:
10483: If ( l_stmv_tbl.COUNT > 0 ) Then
10484:
10485: Okl_Streams_pub.update_streams(
10486: p_api_version => p_api_version,
10487: p_init_msg_list => p_init_msg_list,
10488: x_return_status => x_return_status,
10489: x_msg_count => x_msg_count,
10542: If( l_selv_tbl.COUNT > 0 AND l_stmv_rec.sty_id IS NOT NULL) Then
10543:
10544: print( l_api_name, ' creating disb streams ' );
10545:
10546: x_return_status := Okl_Streams_Util.round_streams_amount(
10547: p_api_version => g_api_version,
10548: p_init_msg_list => p_init_msg_list,
10549: x_msg_count => x_msg_count,
10550: x_msg_data => x_msg_data,
10560:
10561: l_selv_tbl.DELETE;
10562: l_selv_tbl := lx_selv_tbl;
10563:
10564: okl_streams_pub.create_streams(p_api_version => G_API_VERSION,
10565: p_init_msg_list => G_FALSE,
10566: x_return_status => x_return_status,
10567: x_msg_count => x_msg_count,
10568: x_msg_data => x_msg_data,
10977:
10978: CURSOR c_pbal IS
10979: SELECT ele.amount,
10980: ele.stream_element_date
10981: FROM okl_streams stm,
10982: okl_strm_elements ele,
10983: okl_strm_type_b sty
10984: WHERE sty.stream_type_purpose = 'PRINCIPAL_BALANCE'
10985: AND stm.sty_id = sty.id
10989: AND stm.active_yn = 'Y'
10990: AND ele.stm_id = stm.id
10991: AND ele.stream_element_date =
10992: ( SELECT max( ele.stream_element_date)
10993: FROM okl_streams stm,
10994: okl_strm_elements ele,
10995: okl_strm_type_b sty
10996: WHERE sty.stream_type_purpose = 'PRINCIPAL_BALANCE'
10997: AND stm.sty_id = sty.id
11350: l_advance_or_arrears VARCHAR2(10) := 'ARREARS';
11351:
11352: Cursor l_strms_csr ( chrId NUMBER, styId NUMBER ) IS
11353: Select str.id strm_id
11354: From okl_streams str
11355: Where str.sty_id = styId
11356: and str.khr_id = chrId
11357: and str.say_code = 'WORK';
11358:
11378: l_sty_id NUMBER;
11379: l_sty_name VARCHAR2(150);
11380: l_mapped_sty_name VARCHAR2(150);
11381:
11382: l_selv_tbl okl_streams_pub.selv_tbl_type;
11383: l_pt_tbl okl_streams_pub.selv_tbl_type;
11384: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11385:
11386: l_stmv_rec okl_streams_pub.stmv_rec_type;
11379: l_sty_name VARCHAR2(150);
11380: l_mapped_sty_name VARCHAR2(150);
11381:
11382: l_selv_tbl okl_streams_pub.selv_tbl_type;
11383: l_pt_tbl okl_streams_pub.selv_tbl_type;
11384: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11385:
11386: l_stmv_rec okl_streams_pub.stmv_rec_type;
11387: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
11380: l_mapped_sty_name VARCHAR2(150);
11381:
11382: l_selv_tbl okl_streams_pub.selv_tbl_type;
11383: l_pt_tbl okl_streams_pub.selv_tbl_type;
11384: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11385:
11386: l_stmv_rec okl_streams_pub.stmv_rec_type;
11387: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
11388: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
11382: l_selv_tbl okl_streams_pub.selv_tbl_type;
11383: l_pt_tbl okl_streams_pub.selv_tbl_type;
11384: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11385:
11386: l_stmv_rec okl_streams_pub.stmv_rec_type;
11387: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
11388: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
11389: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
11390: l_pt_rec okl_streams_pub.stmv_rec_type;
11383: l_pt_tbl okl_streams_pub.selv_tbl_type;
11384: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11385:
11386: l_stmv_rec okl_streams_pub.stmv_rec_type;
11387: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
11388: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
11389: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
11390: l_pt_rec okl_streams_pub.stmv_rec_type;
11391: lx_stmv_rec okl_streams_pub.stmv_rec_type;
11384: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11385:
11386: l_stmv_rec okl_streams_pub.stmv_rec_type;
11387: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
11388: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
11389: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
11390: l_pt_rec okl_streams_pub.stmv_rec_type;
11391: lx_stmv_rec okl_streams_pub.stmv_rec_type;
11392:
11385:
11386: l_stmv_rec okl_streams_pub.stmv_rec_type;
11387: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
11388: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
11389: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
11390: l_pt_rec okl_streams_pub.stmv_rec_type;
11391: lx_stmv_rec okl_streams_pub.stmv_rec_type;
11392:
11393: i BINARY_INTEGER := 0;
11386: l_stmv_rec okl_streams_pub.stmv_rec_type;
11387: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
11388: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
11389: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
11390: l_pt_rec okl_streams_pub.stmv_rec_type;
11391: lx_stmv_rec okl_streams_pub.stmv_rec_type;
11392:
11393: i BINARY_INTEGER := 0;
11394:
11387: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
11388: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
11389: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
11390: l_pt_rec okl_streams_pub.stmv_rec_type;
11391: lx_stmv_rec okl_streams_pub.stmv_rec_type;
11392:
11393: i BINARY_INTEGER := 0;
11394:
11395: l_api_name CONSTANT VARCHAR2(61) := 'GET_NEXT_BILL_DATE';
11637: l_old_cle_id NUMBER;
11638: l_old_sty_id NUMBER;
11639: l_purpose_code VARCHAR2(30);
11640:
11641: l_pt_tbl okl_streams_pub.selv_tbl_type;
11642: l_pt_pro_fee_tbl okl_streams_pub.selv_tbl_type;
11643:
11644: l_selv_tbl okl_streams_pub.selv_tbl_type;
11645: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11638: l_old_sty_id NUMBER;
11639: l_purpose_code VARCHAR2(30);
11640:
11641: l_pt_tbl okl_streams_pub.selv_tbl_type;
11642: l_pt_pro_fee_tbl okl_streams_pub.selv_tbl_type;
11643:
11644: l_selv_tbl okl_streams_pub.selv_tbl_type;
11645: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11646:
11640:
11641: l_pt_tbl okl_streams_pub.selv_tbl_type;
11642: l_pt_pro_fee_tbl okl_streams_pub.selv_tbl_type;
11643:
11644: l_selv_tbl okl_streams_pub.selv_tbl_type;
11645: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11646:
11647: l_stmv_rec okl_streams_pub.stmv_rec_type;
11648: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
11641: l_pt_tbl okl_streams_pub.selv_tbl_type;
11642: l_pt_pro_fee_tbl okl_streams_pub.selv_tbl_type;
11643:
11644: l_selv_tbl okl_streams_pub.selv_tbl_type;
11645: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11646:
11647: l_stmv_rec okl_streams_pub.stmv_rec_type;
11648: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
11649: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
11643:
11644: l_selv_tbl okl_streams_pub.selv_tbl_type;
11645: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11646:
11647: l_stmv_rec okl_streams_pub.stmv_rec_type;
11648: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
11649: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
11650:
11651: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
11644: l_selv_tbl okl_streams_pub.selv_tbl_type;
11645: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11646:
11647: l_stmv_rec okl_streams_pub.stmv_rec_type;
11648: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
11649: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
11650:
11651: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
11652: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
11645: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11646:
11647: l_stmv_rec okl_streams_pub.stmv_rec_type;
11648: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
11649: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
11650:
11651: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
11652: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
11653:
11647: l_stmv_rec okl_streams_pub.stmv_rec_type;
11648: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
11649: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
11650:
11651: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
11652: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
11653:
11654: l_prog_name CONSTANT VARCHAR2(61) := G_PKG_NAME||'.'||'gen_cash_flows_for_IA';
11655:
11648: l_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
11649: lx_stmv_tbl Okl_Streams_Pub.stmv_tbl_type;
11650:
11651: l_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
11652: lx_full_selv_tbl Okl_Streams_Pub.selv_tbl_type;
11653:
11654: l_prog_name CONSTANT VARCHAR2(61) := G_PKG_NAME||'.'||'gen_cash_flows_for_IA';
11655:
11656: BEGIN
11717: ELSIF x_return_status = OKL_API.G_RET_STS_ERROR THEN
11718: RAISE OKL_API.G_EXCEPTION_ERROR;
11719: END IF;
11720:
11721: x_return_status := Okl_Streams_Util.round_streams_amount_esg(
11722: p_api_version => g_api_version,
11723: p_init_msg_list => p_init_msg_list,
11724: x_msg_count => x_msg_count,
11725: x_msg_data => x_msg_data,
11741: l_selv_tbl.DELETE;
11742: l_selv_tbl := lx_selv_tbl;
11743:
11744: --Accumulate Stream Header
11745: OKL_STREAMS_UTIL.accumulate_strm_headers( p_stmv_rec => l_stmv_rec,
11746: x_full_stmv_tbl => l_stmv_tbl,
11747: x_return_status => x_return_status );
11748: IF (x_return_status = G_RET_STS_UNEXP_ERROR) THEN
11749: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
11751: RAISE OKL_API.G_EXCEPTION_ERROR;
11752: END IF;
11753:
11754: --Accumulate Stream Elements
11755: OKL_STREAMS_UTIL.accumulate_strm_elements( p_stm_index_no => l_stmv_tbl.LAST,
11756: p_selv_tbl => l_selv_tbl,
11757: x_full_selv_tbl => l_full_selv_tbl,
11758: x_return_status => x_return_status );
11759: IF (x_return_status = G_RET_STS_UNEXP_ERROR) THEN
11768:
11769: END LOOP;
11770:
11771: --Create all the accumulated Streams at one shot ..
11772: Okl_Streams_Pub.create_streams_perf( p_api_version,
11773: p_init_msg_list,
11774: x_return_status,
11775: x_msg_count,
11776: x_msg_data,
11872: l_pdt_id okl_products.id%type;
11873: l_currency_code okc_k_headers_all_b.currency_code%type;
11874: l_purpose_code VARCHAR2(30) := '-99';
11875:
11876: l_selv_tbl okl_streams_pub.selv_tbl_type;
11877: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11878: l_full_selv_tbl okl_streams_pub.selv_tbl_type;
11879: lx_full_selv_tbl okl_streams_pub.selv_tbl_type;
11880:
11873: l_currency_code okc_k_headers_all_b.currency_code%type;
11874: l_purpose_code VARCHAR2(30) := '-99';
11875:
11876: l_selv_tbl okl_streams_pub.selv_tbl_type;
11877: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11878: l_full_selv_tbl okl_streams_pub.selv_tbl_type;
11879: lx_full_selv_tbl okl_streams_pub.selv_tbl_type;
11880:
11881: l_stmv_rec okl_streams_pub.stmv_rec_type;
11874: l_purpose_code VARCHAR2(30) := '-99';
11875:
11876: l_selv_tbl okl_streams_pub.selv_tbl_type;
11877: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11878: l_full_selv_tbl okl_streams_pub.selv_tbl_type;
11879: lx_full_selv_tbl okl_streams_pub.selv_tbl_type;
11880:
11881: l_stmv_rec okl_streams_pub.stmv_rec_type;
11882: l_stmv_tbl okl_Streams_Pub.stmv_tbl_type;
11875:
11876: l_selv_tbl okl_streams_pub.selv_tbl_type;
11877: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11878: l_full_selv_tbl okl_streams_pub.selv_tbl_type;
11879: lx_full_selv_tbl okl_streams_pub.selv_tbl_type;
11880:
11881: l_stmv_rec okl_streams_pub.stmv_rec_type;
11882: l_stmv_tbl okl_Streams_Pub.stmv_tbl_type;
11883: lx_stmv_tbl okl_Streams_Pub.stmv_tbl_type;
11877: lx_selv_tbl okl_streams_pub.selv_tbl_type;
11878: l_full_selv_tbl okl_streams_pub.selv_tbl_type;
11879: lx_full_selv_tbl okl_streams_pub.selv_tbl_type;
11880:
11881: l_stmv_rec okl_streams_pub.stmv_rec_type;
11882: l_stmv_tbl okl_Streams_Pub.stmv_tbl_type;
11883: lx_stmv_tbl okl_Streams_Pub.stmv_tbl_type;
11884:
11885: l_prog_name CONSTANT VARCHAR2(61) := G_PKG_NAME||'.'||'gen_income_accruals_for_IA';
11878: l_full_selv_tbl okl_streams_pub.selv_tbl_type;
11879: lx_full_selv_tbl okl_streams_pub.selv_tbl_type;
11880:
11881: l_stmv_rec okl_streams_pub.stmv_rec_type;
11882: l_stmv_tbl okl_Streams_Pub.stmv_tbl_type;
11883: lx_stmv_tbl okl_Streams_Pub.stmv_tbl_type;
11884:
11885: l_prog_name CONSTANT VARCHAR2(61) := G_PKG_NAME||'.'||'gen_income_accruals_for_IA';
11886:
11879: lx_full_selv_tbl okl_streams_pub.selv_tbl_type;
11880:
11881: l_stmv_rec okl_streams_pub.stmv_rec_type;
11882: l_stmv_tbl okl_Streams_Pub.stmv_tbl_type;
11883: lx_stmv_tbl okl_Streams_Pub.stmv_tbl_type;
11884:
11885: l_prog_name CONSTANT VARCHAR2(61) := G_PKG_NAME||'.'||'gen_income_accruals_for_IA';
11886:
11887: BEGIN
11964: ELSIF x_return_status = OKL_API.G_RET_STS_ERROR THEN
11965: RAISE OKL_API.G_EXCEPTION_ERROR;
11966: END IF;
11967:
11968: x_return_status := Okl_Streams_Util.round_streams_amount_esg(
11969: p_api_version => g_api_version,
11970: p_init_msg_list => p_init_msg_list,
11971: x_msg_count => x_msg_count,
11972: x_msg_data => x_msg_data,
11988: l_selv_tbl.DELETE;
11989: l_selv_tbl := lx_selv_tbl;
11990:
11991: --Accumulate Stream Header
11992: OKL_STREAMS_UTIL.accumulate_strm_headers(
11993: p_stmv_rec => l_stmv_rec,
11994: x_full_stmv_tbl => l_stmv_tbl,
11995: x_return_status => x_return_status );
11996: IF (x_return_status = G_RET_STS_UNEXP_ERROR) THEN
11999: RAISE OKL_API.G_EXCEPTION_ERROR;
12000: END IF;
12001:
12002: --Accumulate Stream Elements
12003: OKL_STREAMS_UTIL.accumulate_strm_elements(
12004: p_stm_index_no => l_stmv_tbl.LAST,
12005: p_selv_tbl => l_selv_tbl,
12006: x_full_selv_tbl => l_full_selv_tbl,
12007: x_return_status => x_return_status );
12027: --Create all the accumulated Streams at one shot ..
12028: IF l_stmv_tbl.COUNT > 0 AND
12029: l_full_selv_tbl.COUNT > 0
12030: THEN
12031: Okl_Streams_Pub.create_streams_perf(
12032: p_api_version,
12033: p_init_msg_list,
12034: x_return_status,
12035: x_msg_count,
12081: , x_msg_data OUT NOCOPY VARCHAR2
12082: )
12083: IS
12084:
12085: l_strm_id_tbl okl_streams_util.NumberTabTyp;
12086: l_say_code_tbl okl_streams_util.Var10TabTyp;
12087: l_active_yn_tbl okl_streams_util.Var10TabTyp;
12088: l_date_history_tbl okl_streams_util.DateTabTyp;
12089: l_date_curr_tbl okl_streams_util.DateTabTyp;
12082: )
12083: IS
12084:
12085: l_strm_id_tbl okl_streams_util.NumberTabTyp;
12086: l_say_code_tbl okl_streams_util.Var10TabTyp;
12087: l_active_yn_tbl okl_streams_util.Var10TabTyp;
12088: l_date_history_tbl okl_streams_util.DateTabTyp;
12089: l_date_curr_tbl okl_streams_util.DateTabTyp;
12090:
12083: IS
12084:
12085: l_strm_id_tbl okl_streams_util.NumberTabTyp;
12086: l_say_code_tbl okl_streams_util.Var10TabTyp;
12087: l_active_yn_tbl okl_streams_util.Var10TabTyp;
12088: l_date_history_tbl okl_streams_util.DateTabTyp;
12089: l_date_curr_tbl okl_streams_util.DateTabTyp;
12090:
12091: CURSOR strms_csr IS
12084:
12085: l_strm_id_tbl okl_streams_util.NumberTabTyp;
12086: l_say_code_tbl okl_streams_util.Var10TabTyp;
12087: l_active_yn_tbl okl_streams_util.Var10TabTyp;
12088: l_date_history_tbl okl_streams_util.DateTabTyp;
12089: l_date_curr_tbl okl_streams_util.DateTabTyp;
12090:
12091: CURSOR strms_csr IS
12092: SELECT strm.id
12085: l_strm_id_tbl okl_streams_util.NumberTabTyp;
12086: l_say_code_tbl okl_streams_util.Var10TabTyp;
12087: l_active_yn_tbl okl_streams_util.Var10TabTyp;
12088: l_date_history_tbl okl_streams_util.DateTabTyp;
12089: l_date_curr_tbl okl_streams_util.DateTabTyp;
12090:
12091: CURSOR strms_csr IS
12092: SELECT strm.id
12093: , strm.say_code
12090:
12091: CURSOR strms_csr IS
12092: SELECT strm.id
12093: , strm.say_code
12094: FROM okl_streams strm
12095: WHERE khr_id = p_khr_id;
12096: l_strms_rec strms_csr%rowtype;
12097:
12098: i NUMBER;
12121: END LOOP;
12122:
12123: -- Update all streams at once...
12124: FORALL i IN l_strm_id_tbl.FIRST..l_strm_id_tbl.LAST
12125: UPDATE OKL_STREAMS
12126: SET say_code = l_say_code_tbl(i),
12127: active_yn = l_active_yn_tbl(i),
12128: date_history = l_date_history_tbl(i),
12129: date_current = l_date_curr_tbl(i)