eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.OKL_LA_STREAM_PVT dependencies on OKL_STREAMS

Line 1712: okl_streams str

1708: -- cursor to fetch the stream element amount
1709: CURSOR get_strmele_csr(p_khr_id NUMBER, p_strm_id NUMBER, p_sty_id NUMBER) IS
1710: SELECT ele.amount
1711: FROM okl_strm_elements ele,
1712: okl_streams str
1713: WHERE ele.stm_id = p_strm_id
1714: AND str.khr_id = p_khr_id
1715: AND str.sty_id = p_sty_id
1716: AND upper(str.say_code) = 'CURR'

Line 1724: l_stmv_rec okl_streams_pub.stmv_rec_type;

1720: lx_fee_types_rec okl_maintain_fee_pvt.fee_types_rec_type;
1721: l_fee_types_rec okl_maintain_fee_pvt.fee_types_rec_type;
1722: l_rvi_amount NUMBER;
1723: l_strm_id NUMBER;
1724: l_stmv_rec okl_streams_pub.stmv_rec_type;
1725: l_api_name VARCHAR2(255) := 'update_rvi_amount';
1726: BEGIN
1727: x_return_status := OKL_API.G_RET_STS_SUCCESS;
1728: -- Call start_activity to create savepoint, check compatibility

Line 1797: okl_streams_pub.delete_streams(p_api_version => p_api_version,

1793: END IF;
1794: END IF; -- end of stream element check
1795: END IF; -- end of main product check
1796: -- delete the primary stream for all products
1797: okl_streams_pub.delete_streams(p_api_version => p_api_version,
1798: p_init_msg_list => OKL_API.G_FALSE,
1799: x_return_status => x_return_status,
1800: x_msg_count => x_msg_count,
1801: x_msg_data => x_msg_data,

Line 2483: l_stmv_tbl okl_streams_pub.stmv_tbl_type;

2479: l_api_name CONSTANT VARCHAR2(30) := 'DELETE_WKG_STRMS';
2480: l_return_status VARCHAR2(1) := OKL_API.G_RET_STS_SUCCESS;
2481: l_api_version NUMBER := 1.0;
2482:
2483: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
2484: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
2485: l_strms_orig_rec strms_csr%ROWTYPE;
2486: l_strms_rep_rec strms_csr%ROWTYPE;
2487:

Line 2484: x_stmv_tbl okl_streams_pub.stmv_tbl_type;

2480: l_return_status VARCHAR2(1) := OKL_API.G_RET_STS_SUCCESS;
2481: l_api_version NUMBER := 1.0;
2482:
2483: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
2484: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
2485: l_strms_orig_rec strms_csr%ROWTYPE;
2486: l_strms_rep_rec strms_csr%ROWTYPE;
2487:
2488: i NUMBER;

Line 2537: Okl_Streams_pub.delete_streams(

2533: END LOOP;
2534:
2535: If ( i > 0 ) Then
2536:
2537: Okl_Streams_pub.delete_streams(
2538: p_api_version => p_api_version,
2539: p_init_msg_list => p_init_msg_list,
2540: x_return_status => x_return_status,
2541: x_msg_count => x_msg_count,

Line 2616: l_stmv_tbl okl_streams_pub.stmv_tbl_type;

2612: lx_failStatus VARCHAR2(30);
2613: c_kle_id NUMBER;
2614: c_sty_id NUMBER;
2615: v_adj_amt NUMBER;
2616: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
2617: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
2618: l_selv_tbl okl_streams_pvt.selv_tbl_type;
2619: l_pt_tbl okl_streams_pub.selv_tbl_type;
2620: --srsreeni Bug 5917582 start

Line 2617: x_stmv_tbl okl_streams_pub.stmv_tbl_type;

2613: c_kle_id NUMBER;
2614: c_sty_id NUMBER;
2615: v_adj_amt NUMBER;
2616: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
2617: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
2618: l_selv_tbl okl_streams_pvt.selv_tbl_type;
2619: l_pt_tbl okl_streams_pub.selv_tbl_type;
2620: --srsreeni Bug 5917582 start
2621: l_pt_tbl_tmp okl_streams_pub.selv_tbl_type;

Line 2618: l_selv_tbl okl_streams_pvt.selv_tbl_type;

2614: c_sty_id NUMBER;
2615: v_adj_amt NUMBER;
2616: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
2617: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
2618: l_selv_tbl okl_streams_pvt.selv_tbl_type;
2619: l_pt_tbl okl_streams_pub.selv_tbl_type;
2620: --srsreeni Bug 5917582 start
2621: l_pt_tbl_tmp okl_streams_pub.selv_tbl_type;
2622: --srsreeni Bug 5917582 end

Line 2619: l_pt_tbl okl_streams_pub.selv_tbl_type;

2615: v_adj_amt NUMBER;
2616: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
2617: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
2618: l_selv_tbl okl_streams_pvt.selv_tbl_type;
2619: l_pt_tbl okl_streams_pub.selv_tbl_type;
2620: --srsreeni Bug 5917582 start
2621: l_pt_tbl_tmp okl_streams_pub.selv_tbl_type;
2622: --srsreeni Bug 5917582 end
2623: lx_selv_tbl okl_streams_pvt.selv_tbl_type;

Line 2621: l_pt_tbl_tmp okl_streams_pub.selv_tbl_type;

2617: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
2618: l_selv_tbl okl_streams_pvt.selv_tbl_type;
2619: l_pt_tbl okl_streams_pub.selv_tbl_type;
2620: --srsreeni Bug 5917582 start
2621: l_pt_tbl_tmp okl_streams_pub.selv_tbl_type;
2622: --srsreeni Bug 5917582 end
2623: lx_selv_tbl okl_streams_pvt.selv_tbl_type;
2624: l_stmv_rec okl_streams_pub.stmv_rec_type;
2625: lx_stmv_rec okl_streams_pub.stmv_rec_type;

Line 2623: lx_selv_tbl okl_streams_pvt.selv_tbl_type;

2619: l_pt_tbl okl_streams_pub.selv_tbl_type;
2620: --srsreeni Bug 5917582 start
2621: l_pt_tbl_tmp okl_streams_pub.selv_tbl_type;
2622: --srsreeni Bug 5917582 end
2623: lx_selv_tbl okl_streams_pvt.selv_tbl_type;
2624: l_stmv_rec okl_streams_pub.stmv_rec_type;
2625: lx_stmv_rec okl_streams_pub.stmv_rec_type;
2626: --srsreeni bug 5869271 start add
2627: l_old_cle_id okc_k_lines_b.ID%TYPE;

Line 2624: l_stmv_rec okl_streams_pub.stmv_rec_type;

2620: --srsreeni Bug 5917582 start
2621: l_pt_tbl_tmp okl_streams_pub.selv_tbl_type;
2622: --srsreeni Bug 5917582 end
2623: lx_selv_tbl okl_streams_pvt.selv_tbl_type;
2624: l_stmv_rec okl_streams_pub.stmv_rec_type;
2625: lx_stmv_rec okl_streams_pub.stmv_rec_type;
2626: --srsreeni bug 5869271 start add
2627: l_old_cle_id okc_k_lines_b.ID%TYPE;
2628: l_old_sty_id okl_strm_type_b.ID%TYPE;

Line 2625: lx_stmv_rec okl_streams_pub.stmv_rec_type;

2621: l_pt_tbl_tmp okl_streams_pub.selv_tbl_type;
2622: --srsreeni Bug 5917582 end
2623: lx_selv_tbl okl_streams_pvt.selv_tbl_type;
2624: l_stmv_rec okl_streams_pub.stmv_rec_type;
2625: lx_stmv_rec okl_streams_pub.stmv_rec_type;
2626: --srsreeni bug 5869271 start add
2627: l_old_cle_id okc_k_lines_b.ID%TYPE;
2628: l_old_sty_id okl_strm_type_b.ID%TYPE;
2629: l_old_str_stmv_rec okl_streams_pub.stmv_rec_type;

Line 2629: l_old_str_stmv_rec okl_streams_pub.stmv_rec_type;

2625: lx_stmv_rec okl_streams_pub.stmv_rec_type;
2626: --srsreeni bug 5869271 start add
2627: l_old_cle_id okc_k_lines_b.ID%TYPE;
2628: l_old_sty_id okl_strm_type_b.ID%TYPE;
2629: l_old_str_stmv_rec okl_streams_pub.stmv_rec_type;
2630: l_old_acr_stmv_rec okl_streams_pub.stmv_rec_type;
2631: l_last_se_line_number OKL_STRM_ELEMENTS_V.SE_LINE_NUMBER%TYPE;
2632: l_last_acr_se_line_number OKL_STRM_ELEMENTS_V.SE_LINE_NUMBER%TYPE;
2633: --srsreeni bug 5869271 end add

Line 2630: l_old_acr_stmv_rec okl_streams_pub.stmv_rec_type;

2626: --srsreeni bug 5869271 start add
2627: l_old_cle_id okc_k_lines_b.ID%TYPE;
2628: l_old_sty_id okl_strm_type_b.ID%TYPE;
2629: l_old_str_stmv_rec okl_streams_pub.stmv_rec_type;
2630: l_old_acr_stmv_rec okl_streams_pub.stmv_rec_type;
2631: l_last_se_line_number OKL_STRM_ELEMENTS_V.SE_LINE_NUMBER%TYPE;
2632: l_last_acr_se_line_number OKL_STRM_ELEMENTS_V.SE_LINE_NUMBER%TYPE;
2633: --srsreeni bug 5869271 end add
2634: l_purpose_code VARCHAR2(30) := p_purpose;

Line 2693: FROM okl_streams stm

2689: CURSOR l_stmp_yn_csr(khrid NUMBER, p VARCHAR2) IS
2690: SELECT 'Y' What
2691: FROM dual
2692: WHERE EXISTS(SELECT stm.id stmid
2693: FROM okl_streams stm
2694: WHERE stm.khr_id = khrid
2695: --AND stm.say_code = 'CURR'
2696: AND stm.say_code = 'WORK'
2697: AND stm.sgn_code = 'STMP'

Line 2703: FROM okl_streams stm

2699: AND stm.active_yn = 'N');
2700: -- To get the stream information
2701: CURSOR l_stm_csr(khrid NUMBER, kleid NUMBER, styid NUMBER, p VARCHAR2) IS
2702: SELECT stm.id stmid
2703: FROM okl_streams stm
2704: WHERE stm.khr_id = khrid
2705: AND stm.kle_id = kleid
2706: AND stm.sty_id = styid
2707: AND stm.say_code = 'CURR'

Line 2732: l_pt_pro_fee_tbl okl_streams_pub.selv_tbl_type;

2728: l_pdt_id NUMBER;
2729: l_primary_sty_id NUMBER;
2730:
2731: -- gboomina Bug 4746368 - Added - Start
2732: l_pt_pro_fee_tbl okl_streams_pub.selv_tbl_type;
2733: l_fee_strm_type_rec fee_strm_type_csr%ROWTYPE;
2734: -- gboomina Bug 4746368 - Added - End
2735: --srsreeni Bug 5917582 start
2736: l_pt_pro_fee_tbl_tmp okl_streams_pub.selv_tbl_type;

Line 2736: l_pt_pro_fee_tbl_tmp okl_streams_pub.selv_tbl_type;

2732: l_pt_pro_fee_tbl okl_streams_pub.selv_tbl_type;
2733: l_fee_strm_type_rec fee_strm_type_csr%ROWTYPE;
2734: -- gboomina Bug 4746368 - Added - End
2735: --srsreeni Bug 5917582 start
2736: l_pt_pro_fee_tbl_tmp okl_streams_pub.selv_tbl_type;
2737: --srsreeni Bug 5917582 end
2738:
2739: --Added by djanaswa for bug 6007644
2740: l_recurrence_date DATE := NULL;

Line 2782: okl_streams_pub.delete_streams(p_api_version => p_api_version,

2778: i := i + 1;
2779: l_stmv_tbl(i).id := l_stm_rec.stmid;
2780: END LOOP;
2781: IF ( i > 0 ) THEN
2782: okl_streams_pub.delete_streams(p_api_version => p_api_version,
2783: x_return_status => x_return_status,
2784: p_init_msg_list => p_init_msg_list,
2785: x_msg_count => x_msg_count,
2786: x_msg_data => x_msg_data,

Line 2902: okl_streams_pub.create_streams(p_api_version => p_api_version,

2898: l_stmv_rec.date_working := SYSDATE;
2899: --Added by kthiruva on 09-Feb-2006
2900: --Bug 5029161 - Start of Changes
2901: IF l_selv_tbl.COUNT > 0 THEN
2902: okl_streams_pub.create_streams(p_api_version => p_api_version,
2903: p_init_msg_list => p_init_msg_list,
2904: x_return_status => x_return_status,
2905: x_msg_count => x_msg_count,
2906: x_msg_data => x_msg_data,

Line 2933: okl_streams_pub.create_stream_elements(

2929: EXIT WHEN(i = l_selv_tbl.LAST);
2930: i := l_selv_tbl.NEXT(i);
2931: END LOOP;
2932: -- populate the detail
2933: okl_streams_pub.create_stream_elements(
2934: p_api_version => p_api_version
2935: ,p_init_msg_list => p_init_msg_list
2936: ,x_return_status => x_return_status
2937: ,x_msg_count => x_msg_count

Line 3043: okl_streams_pub.create_streams(p_api_version => p_api_version,

3039: l_stmv_rec.date_working := SYSDATE;
3040: --Added by kthiruva on 09-Feb-2006
3041: --Bug 5029161 - Start of Changes
3042: IF l_selv_tbl.COUNT > 0 THEN
3043: okl_streams_pub.create_streams(p_api_version => p_api_version,
3044: p_init_msg_list => p_init_msg_list,
3045: x_return_status => x_return_status,
3046: x_msg_count => x_msg_count,
3047: x_msg_data => x_msg_data,

Line 3075: okl_streams_pub.create_stream_elements(

3071: EXIT WHEN(i = l_selv_tbl.LAST);
3072: i := l_selv_tbl.NEXT(i);
3073: END LOOP;
3074: -- populate the detail
3075: okl_streams_pub.create_stream_elements(
3076: p_api_version => p_api_version
3077: ,p_init_msg_list => p_init_msg_list
3078: ,x_return_status => x_return_status
3079: ,x_msg_count => x_msg_count

Line 3174: okl_streams_pub.create_streams(p_api_version => p_api_version,

3170:
3171: --Added by kthiruva on 09-Feb-2006
3172: --Bug 5029161 - Start of Changes
3173: IF l_pt_tbl.COUNT > 0 THEN
3174: okl_streams_pub.create_streams(p_api_version => p_api_version,
3175: p_init_msg_list => p_init_msg_list,
3176: x_return_status => x_return_status,
3177: x_msg_count => x_msg_count,
3178: x_msg_data => x_msg_data,

Line 3255: okl_streams_pub.create_streams(p_api_version => p_api_version,

3251: l_stmv_rec.date_working := SYSDATE;
3252: --Added by kthiruva on 09-Feb-2006
3253: --Bug 5029161 - Start of Changes
3254: IF l_pt_pro_fee_tbl.COUNT > 0 THEN
3255: okl_streams_pub.create_streams(p_api_version => p_api_version,
3256: p_init_msg_list => p_init_msg_list,
3257: x_return_status => x_return_status,
3258: x_msg_count => x_msg_count,
3259: x_msg_data => x_msg_data,

Line 3364: l_stmv_rec Okl_Streams_pub.stmv_rec_type;

3360:
3361:
3362: l_ctrt_cap_amnt NUMBER := p_ctrt_cap_amnt;
3363:
3364: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
3365: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3366: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3367: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3368:

Line 3365: l_selv_tbl Okl_Streams_pub.selv_tbl_type;

3361:
3362: l_ctrt_cap_amnt NUMBER := p_ctrt_cap_amnt;
3363:
3364: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
3365: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3366: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3367: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3368:
3369: i NUMBER;

Line 3366: x_stmv_rec Okl_Streams_pub.stmv_rec_type;

3362: l_ctrt_cap_amnt NUMBER := p_ctrt_cap_amnt;
3363:
3364: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
3365: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3366: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3367: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3368:
3369: i NUMBER;
3370: j NUMBER;

Line 3367: x_selv_tbl Okl_Streams_pub.selv_tbl_type;

3363:
3364: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
3365: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3366: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3367: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3368:
3369: i NUMBER;
3370: j NUMBER;
3371: k NUMBER;

Line 3438: Okl_Streams_Pub.create_streams(

3434: END LOOP;
3435:
3436:
3437:
3438: Okl_Streams_Pub.create_streams(
3439: p_api_version => l_api_version
3440: ,p_init_msg_list => p_init_msg_list
3441: ,x_return_status => l_return_status
3442: ,x_msg_count => x_msg_count

Line 3534: l_stmv_rec Okl_Streams_pub.stmv_rec_type;

3530: l_superTval NUMBER;
3531: l_alloc_value NUMBER;
3532: l_ctrt_cap_amnt NUMBER := p_ctrt_cap_amnt;
3533:
3534: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
3535: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3536: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3537: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3538:

Line 3535: l_selv_tbl Okl_Streams_pub.selv_tbl_type;

3531: l_alloc_value NUMBER;
3532: l_ctrt_cap_amnt NUMBER := p_ctrt_cap_amnt;
3533:
3534: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
3535: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3536: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3537: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3538:
3539: BEGIN

Line 3536: x_stmv_rec Okl_Streams_pub.stmv_rec_type;

3532: l_ctrt_cap_amnt NUMBER := p_ctrt_cap_amnt;
3533:
3534: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
3535: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3536: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3537: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3538:
3539: BEGIN
3540:

Line 3537: x_selv_tbl Okl_Streams_pub.selv_tbl_type;

3533:
3534: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
3535: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3536: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3537: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3538:
3539: BEGIN
3540:
3541: l_return_status := OKL_API.START_ACTIVITY(

Line 3602: Okl_Streams_Pub.update_streams(

3598:
3599: END LOOP;
3600:
3601:
3602: Okl_Streams_Pub.update_streams(
3603: p_api_version => l_api_version
3604: ,p_init_msg_list => p_init_msg_list
3605: ,x_return_status => l_return_status
3606: ,x_msg_count => x_msg_count

Line 3626: Okl_Streams_Pub.create_stream_elements(

3622: LOOP
3623: l_selv_tbl(i).stm_id := x_stmv_rec.id;
3624: END LOOP;
3625:
3626: Okl_Streams_Pub.create_stream_elements(
3627: p_api_version => l_api_version
3628: ,p_init_msg_list => p_init_msg_list
3629: ,x_return_status => l_return_status
3630: ,x_msg_count => x_msg_count

Line 3708: From okl_streams str,

3704:
3705: Cursor l_strms_csr ( chrId NUMBER, st VARCHAR2 ) IS
3706: Select sty.id sty_id,
3707: sty.name
3708: From okl_streams str,
3709: okl_strm_type_tl sty
3710: Where sty.id = str.sty_id
3711: and str.khr_id = chrId
3712: and sty.name = st

Line 3875: FROM okl_streams str

3871: -- get the transaction number
3872: CURSOR l_strm_csr (chrId NUMBER, pp VARCHAR2 )
3873: IS
3874: SELECT DISTINCT str.transaction_number transaction_number
3875: FROM okl_streams str
3876: WHERE str.khr_id = chrId
3877: AND str.say_code = 'CURR'
3878: AND nvl(str.purpose_code, 'ORIGIN') = pp;
3879: -- Billable rents

Line 3887: okl_streams str,

3883: CURSOR l_billedrents_csr(chrId NUMBER, kleid NUMBER, p VARCHAR2)
3884: IS
3885: SELECT nvl(sum(ele.AMOUNT),0)
3886: FROM okl_strm_elements ele,
3887: okl_streams str,
3888: okl_strm_type_b sty
3889: WHERE str.khr_id = chrId
3890: AND nvl(str.kle_id, -1) = kleid
3891: AND str.sty_id = sty.id

Line 3974: l_stmv_rec Okl_Streams_pub.stmv_rec_type;

3970: l_rl_rec1 l_rl_csr1%ROWTYPE;
3971: l_line_rec l_line_csr%ROWTYPE;
3972: l_strm_rec l_strm_csr%ROWTYPE;
3973: l_styid_rec get_styid_csr%ROWTYPE;
3974: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
3975: l_stmv_rec_intm_rentals Okl_Streams_pub.stmv_rec_type;
3976: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3977: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
3978: x_stmv_rec Okl_Streams_pub.stmv_rec_type;

Line 3975: l_stmv_rec_intm_rentals Okl_Streams_pub.stmv_rec_type;

3971: l_line_rec l_line_csr%ROWTYPE;
3972: l_strm_rec l_strm_csr%ROWTYPE;
3973: l_styid_rec get_styid_csr%ROWTYPE;
3974: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
3975: l_stmv_rec_intm_rentals Okl_Streams_pub.stmv_rec_type;
3976: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3977: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
3978: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3979: x_selv_tbl Okl_Streams_pub.selv_tbl_type;

Line 3976: l_selv_tbl Okl_Streams_pub.selv_tbl_type;

3972: l_strm_rec l_strm_csr%ROWTYPE;
3973: l_styid_rec get_styid_csr%ROWTYPE;
3974: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
3975: l_stmv_rec_intm_rentals Okl_Streams_pub.stmv_rec_type;
3976: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3977: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
3978: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3979: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3980: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;

Line 3977: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;

3973: l_styid_rec get_styid_csr%ROWTYPE;
3974: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
3975: l_stmv_rec_intm_rentals Okl_Streams_pub.stmv_rec_type;
3976: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3977: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
3978: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3979: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3980: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
3981: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;

Line 3978: x_stmv_rec Okl_Streams_pub.stmv_rec_type;

3974: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
3975: l_stmv_rec_intm_rentals Okl_Streams_pub.stmv_rec_type;
3976: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3977: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
3978: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3979: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3980: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
3981: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
3982: lx_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;

Line 3979: x_selv_tbl Okl_Streams_pub.selv_tbl_type;

3975: l_stmv_rec_intm_rentals Okl_Streams_pub.stmv_rec_type;
3976: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3977: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
3978: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3979: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3980: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
3981: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
3982: lx_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
3983: lx_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;

Line 3980: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;

3976: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
3977: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
3978: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3979: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3980: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
3981: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
3982: lx_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
3983: lx_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
3984: lx_inv_agmt_chr_id_tbl okl_securitization_pvt.inv_agmt_chr_id_tbl_type;

Line 3981: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;

3977: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
3978: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3979: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3980: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
3981: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
3982: lx_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
3983: lx_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
3984: lx_inv_agmt_chr_id_tbl okl_securitization_pvt.inv_agmt_chr_id_tbl_type;
3985: BEGIN

Line 3982: lx_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;

3978: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
3979: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3980: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
3981: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
3982: lx_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
3983: lx_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
3984: lx_inv_agmt_chr_id_tbl okl_securitization_pvt.inv_agmt_chr_id_tbl_type;
3985: BEGIN
3986: x_return_status := OKL_API.G_RET_STS_SUCCESS;

Line 3983: lx_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;

3979: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
3980: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
3981: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
3982: lx_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
3983: lx_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
3984: lx_inv_agmt_chr_id_tbl okl_securitization_pvt.inv_agmt_chr_id_tbl_type;
3985: BEGIN
3986: x_return_status := OKL_API.G_RET_STS_SUCCESS;
3987: -- Call start_activity to create savepoint, check compatibility

Line 4149: Okl_Streams_Pub.create_streams(

4145: --l_selv_tbl_intm_rentals(1).date_billed := sysdate;
4146: --l_stmv_rec_intm_rentals.sty_id := l_styid_rec.id;
4147: l_stmv_rec_intm_rentals.sty_id := styid.id;
4148: IF l_selv_tbl_intm_rentals(1).amount <> 0 THEN
4149: Okl_Streams_Pub.create_streams(
4150: p_api_version => p_api_version,
4151: p_init_msg_list => p_init_msg_list,
4152: x_return_status => x_return_status,
4153: x_msg_count => x_msg_count,

Line 4277: okl_streams_pub.create_streams(

4273: l_selv_tbl_secure(1).amount := ln_secure_amt * -1;
4274:
4275: IF l_selv_tbl_secure(1).amount <> 0 THEN
4276:
4277: okl_streams_pub.create_streams(
4278: p_api_version => p_api_version,
4279: p_init_msg_list => p_init_msg_list,
4280: x_return_status => x_return_status,
4281: x_msg_count => x_msg_count,

Line 4358: Okl_Streams_Pub.create_streams(

4354: --l_selv_tbl_intm_rentals(1).date_billed := sysdate;
4355: --l_stmv_rec_intm_rentals.sty_id := l_styid_rec.id;
4356: l_stmv_rec_intm_rentals.sty_id := styid.id;
4357: IF l_selv_tbl_intm_rentals(1).amount <> 0 THEN
4358: Okl_Streams_Pub.create_streams(
4359: p_api_version => p_api_version,
4360: p_init_msg_list => p_init_msg_list,
4361: x_return_status => x_return_status,
4362: x_msg_count => x_msg_count,

Line 4487: okl_streams str,

4483: p_purpose VARCHAR2)
4484: IS
4485: SELECT NVL(SUM(ele.AMOUNT),0) amount
4486: FROM okl_strm_elements ele,
4487: okl_streams str,
4488: okl_strm_type_b sty
4489: WHERE str.khr_id = p_chr_id
4490: AND NVL(str.kle_id, -1) = p_kle_id
4491: AND str.sty_id = sty.id

Line 4505: okl_streams str,

4501: p_purpose VARCHAR2)
4502: IS
4503: SELECT NVL(SUM(ele.AMOUNT),0) amount
4504: FROM okl_strm_elements ele,
4505: okl_streams str,
4506: okl_strm_type_b sty
4507: WHERE str.khr_id = p_chr_id
4508: AND NVL(str.kle_id, -1) = p_kle_id
4509: AND str.sty_id = sty.id

Line 4551: -- FROM okl_streams str

4547: -- get the transaction number
4548: CURSOR l_trx_num_csr
4549: IS
4550: -- SELECT DISTINCT str.transaction_number transaction_number
4551: -- FROM okl_streams str
4552: -- WHERE str.khr_id = p_chr_id
4553: -- AND str.say_code = 'CURR'
4554: -- AND nvl(str.purpose_code, 'ORIGIN') = p_purpose;
4555: SELECT OKL_SIF_SEQ.NEXTVAL

Line 4571: l_stmv_rec Okl_Streams_pub.stmv_rec_type;

4567: l_pdt_id_rec l_hdr_pdt_csr%ROWTYPE;
4568: r_line_rec l_line_csr%ROWTYPE;
4569: l_strm_rec l_trx_num_csr%ROWTYPE;
4570: l_styid_rec get_styid_csr%ROWTYPE;
4571: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
4572: l_stmv_rec_intm_rentals Okl_Streams_pub.stmv_rec_type;
4573: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
4574: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
4575: x_stmv_rec Okl_Streams_pub.stmv_rec_type;

Line 4572: l_stmv_rec_intm_rentals Okl_Streams_pub.stmv_rec_type;

4568: r_line_rec l_line_csr%ROWTYPE;
4569: l_strm_rec l_trx_num_csr%ROWTYPE;
4570: l_styid_rec get_styid_csr%ROWTYPE;
4571: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
4572: l_stmv_rec_intm_rentals Okl_Streams_pub.stmv_rec_type;
4573: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
4574: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
4575: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
4576: x_selv_tbl Okl_Streams_pub.selv_tbl_type;

Line 4573: l_selv_tbl Okl_Streams_pub.selv_tbl_type;

4569: l_strm_rec l_trx_num_csr%ROWTYPE;
4570: l_styid_rec get_styid_csr%ROWTYPE;
4571: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
4572: l_stmv_rec_intm_rentals Okl_Streams_pub.stmv_rec_type;
4573: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
4574: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
4575: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
4576: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
4577: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;

Line 4574: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;

4570: l_styid_rec get_styid_csr%ROWTYPE;
4571: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
4572: l_stmv_rec_intm_rentals Okl_Streams_pub.stmv_rec_type;
4573: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
4574: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
4575: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
4576: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
4577: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
4578: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;

Line 4575: x_stmv_rec Okl_Streams_pub.stmv_rec_type;

4571: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
4572: l_stmv_rec_intm_rentals Okl_Streams_pub.stmv_rec_type;
4573: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
4574: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
4575: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
4576: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
4577: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
4578: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
4579: lx_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;

Line 4576: x_selv_tbl Okl_Streams_pub.selv_tbl_type;

4572: l_stmv_rec_intm_rentals Okl_Streams_pub.stmv_rec_type;
4573: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
4574: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
4575: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
4576: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
4577: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
4578: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
4579: lx_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
4580: lx_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;

Line 4577: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;

4573: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
4574: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
4575: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
4576: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
4577: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
4578: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
4579: lx_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
4580: lx_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
4581: lx_inv_agmt_chr_id_tbl okl_securitization_pvt.inv_agmt_chr_id_tbl_type;

Line 4578: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;

4574: l_selv_tbl_intm_rentals Okl_Streams_pub.selv_tbl_type;
4575: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
4576: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
4577: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
4578: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
4579: lx_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
4580: lx_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
4581: lx_inv_agmt_chr_id_tbl okl_securitization_pvt.inv_agmt_chr_id_tbl_type;
4582: Begin

Line 4579: lx_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;

4575: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
4576: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
4577: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
4578: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
4579: lx_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
4580: lx_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
4581: lx_inv_agmt_chr_id_tbl okl_securitization_pvt.inv_agmt_chr_id_tbl_type;
4582: Begin
4583: x_return_status := OKL_API.G_RET_STS_SUCCESS;

Line 4580: lx_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;

4576: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
4577: l_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
4578: l_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
4579: lx_stmv_rec_secure Okl_Streams_pub.stmv_rec_type;
4580: lx_selv_tbl_secure Okl_Streams_pub.selv_tbl_type;
4581: lx_inv_agmt_chr_id_tbl okl_securitization_pvt.inv_agmt_chr_id_tbl_type;
4582: Begin
4583: x_return_status := OKL_API.G_RET_STS_SUCCESS;
4584: -- Call start_activity to create savepoint, check compatibility

Line 4716: Okl_Streams_Pub.create_streams(

4712: l_selv_tbl_intm_rentals(1).stream_element_date := sysdate;
4713: l_selv_tbl_intm_rentals(1).se_line_number := 1;
4714: l_selv_tbl_intm_rentals(1).comments := 'Interim Rentals for a Mass Rebooked Rentals';
4715: IF l_selv_tbl_intm_rentals(1).amount <> 0 THEN
4716: Okl_Streams_Pub.create_streams(
4717: p_api_version => p_api_version,
4718: p_init_msg_list => p_init_msg_list,
4719: x_return_status => x_return_status,
4720: x_msg_count => x_msg_count,

Line 4833: okl_streams_pub.create_streams(

4829: l_stmv_rec_secure.source_id := lx_inv_agmt_chr_id_tbl(i).khr_id;
4830: l_stmv_rec_secure.source_table := 'OKL_K_HEADERS';
4831: l_selv_tbl_secure(1).amount := ln_secure_amt * -1;
4832: IF l_selv_tbl_secure(1).amount <> 0 THEN
4833: okl_streams_pub.create_streams(
4834: p_api_version => p_api_version,
4835: p_init_msg_list => p_init_msg_list,
4836: x_return_status => x_return_status,
4837: x_msg_count => x_msg_count,

Line 4914: Okl_Streams_Pub.create_streams(

4910: l_selv_tbl_intm_rentals(1).stream_element_date := sysdate;
4911: l_selv_tbl_intm_rentals(1).se_line_number := 1;
4912: l_selv_tbl_intm_rentals(1).comments := 'Interim Rentals for a Mass Rebooked Rentals';
4913: IF l_selv_tbl_intm_rentals(1).amount <> 0 THEN
4914: Okl_Streams_Pub.create_streams(
4915: p_api_version => p_api_version,
4916: p_init_msg_list => p_init_msg_list,
4917: x_return_status => x_return_status,
4918: x_msg_count => x_msg_count,

Line 5043: l_stmv_rec okl_streams_pub.stmv_rec_type;

5039: error VARCHAR2(256);
5040: --styid NUMBER;
5041: styid strm_rec_type;
5042: stream_name VARCHAR2(256);
5043: l_stmv_rec okl_streams_pub.stmv_rec_type;
5044: l_stmv_rec_adv_rentals okl_streams_pub.stmv_rec_type;
5045: l_selv_tbl okl_streams_pub.selv_tbl_type;
5046: l_selv_tbl_adv_rentals okl_streams_pub.selv_tbl_type;
5047: x_stmv_rec okl_streams_pub.stmv_rec_type;

Line 5044: l_stmv_rec_adv_rentals okl_streams_pub.stmv_rec_type;

5040: --styid NUMBER;
5041: styid strm_rec_type;
5042: stream_name VARCHAR2(256);
5043: l_stmv_rec okl_streams_pub.stmv_rec_type;
5044: l_stmv_rec_adv_rentals okl_streams_pub.stmv_rec_type;
5045: l_selv_tbl okl_streams_pub.selv_tbl_type;
5046: l_selv_tbl_adv_rentals okl_streams_pub.selv_tbl_type;
5047: x_stmv_rec okl_streams_pub.stmv_rec_type;
5048: x_selv_tbl okl_streams_pub.selv_tbl_type;

Line 5045: l_selv_tbl okl_streams_pub.selv_tbl_type;

5041: styid strm_rec_type;
5042: stream_name VARCHAR2(256);
5043: l_stmv_rec okl_streams_pub.stmv_rec_type;
5044: l_stmv_rec_adv_rentals okl_streams_pub.stmv_rec_type;
5045: l_selv_tbl okl_streams_pub.selv_tbl_type;
5046: l_selv_tbl_adv_rentals okl_streams_pub.selv_tbl_type;
5047: x_stmv_rec okl_streams_pub.stmv_rec_type;
5048: x_selv_tbl okl_streams_pub.selv_tbl_type;
5049:

Line 5046: l_selv_tbl_adv_rentals okl_streams_pub.selv_tbl_type;

5042: stream_name VARCHAR2(256);
5043: l_stmv_rec okl_streams_pub.stmv_rec_type;
5044: l_stmv_rec_adv_rentals okl_streams_pub.stmv_rec_type;
5045: l_selv_tbl okl_streams_pub.selv_tbl_type;
5046: l_selv_tbl_adv_rentals okl_streams_pub.selv_tbl_type;
5047: x_stmv_rec okl_streams_pub.stmv_rec_type;
5048: x_selv_tbl okl_streams_pub.selv_tbl_type;
5049:
5050: --Modified for streams performance

Line 5047: x_stmv_rec okl_streams_pub.stmv_rec_type;

5043: l_stmv_rec okl_streams_pub.stmv_rec_type;
5044: l_stmv_rec_adv_rentals okl_streams_pub.stmv_rec_type;
5045: l_selv_tbl okl_streams_pub.selv_tbl_type;
5046: l_selv_tbl_adv_rentals okl_streams_pub.selv_tbl_type;
5047: x_stmv_rec okl_streams_pub.stmv_rec_type;
5048: x_selv_tbl okl_streams_pub.selv_tbl_type;
5049:
5050: --Modified for streams performance
5051: -- This cursors fetches all the line id's for the contract whose Rent streams

Line 5048: x_selv_tbl okl_streams_pub.selv_tbl_type;

5044: l_stmv_rec_adv_rentals okl_streams_pub.stmv_rec_type;
5045: l_selv_tbl okl_streams_pub.selv_tbl_type;
5046: l_selv_tbl_adv_rentals okl_streams_pub.selv_tbl_type;
5047: x_stmv_rec okl_streams_pub.stmv_rec_type;
5048: x_selv_tbl okl_streams_pub.selv_tbl_type;
5049:
5050: --Modified for streams performance
5051: -- This cursors fetches all the line id's for the contract whose Rent streams
5052: -- have a structure that is not -1 or 0

Line 5117: FROM okl_streams str

5113: str.sty_id,
5114: str.say_code,
5115: str.active_yn,
5116: str.kle_id
5117: FROM okl_streams str
5118: WHERE str.khr_id = chrId
5119: AND str.kle_id = kleId
5120: AND str.say_code = 'WORK'
5121: --Added by kthiruva for Streams Performance Patch

Line 5143: FROM okl_streams stm

5139: ORDER BY ele.stream_element_date;
5140:
5141: CURSOR l_stmp_yn_csr(khrid NUMBER, p VARCHAR2) IS
5142: SELECT count(stm.id) cnt
5143: FROM okl_streams stm
5144: WHERE stm.khr_id = khrid
5145: AND stm.say_code = 'WORK'
5146: AND stm.sgn_code = 'STMP'
5147: AND nvl(stm.purpose_code, 'ORIGIN') = p;

Line 5167: l_rent_amt_tbl Okl_Streams_Util.NumberTabTyp;

5163: --Bug 4414441 - Start of Changes
5164: l_payment_rec l_payment_csr%ROWTYPE;
5165: TYPE l_payment_tbl_type IS TABLE OF l_payment_csr%ROWTYPE INDEX BY BINARY_INTEGER;
5166: l_payment_tbl l_payment_tbl_type;
5167: l_rent_amt_tbl Okl_Streams_Util.NumberTabTyp;
5168: k NUMBER;
5169: l_next_position NUMBER;
5170: --Bug 4414441 - End of Changes
5171: BEGIN

Line 5377: okl_streams_pub.update_streams(

5373: --Assigning the value of the sum of the last n element amounts to the first advance rent stream
5374: l_selv_tbl_adv_rentals(1).amount := l_pay_amount;
5375: --Bug 4414441 - End of Changes
5376: -- update the rent streams for ESG to reflect uniform rental payment
5377: okl_streams_pub.update_streams(
5378: p_api_version => l_api_version
5379: ,p_init_msg_list => p_init_msg_list
5380: ,x_return_status => x_return_status
5381: ,x_msg_count => x_msg_count

Line 5433: okl_streams_pub.create_streams(

5429: END IF;
5430: END IF;
5431:
5432: l_stmv_rec_adv_rentals.sty_id := styid.id;
5433: okl_streams_pub.create_streams(
5434: p_api_version => l_api_version
5435: ,p_init_msg_list => p_init_msg_list
5436: ,x_return_status => x_return_status
5437: ,x_msg_count => x_msg_count

Line 5535: FROM okl_streams

5531: IS
5532: SELECT 1
5533: FROM dual
5534: WHERE EXISTS (SELECT 1
5535: FROM okl_streams
5536: WHERE khr_id= p_dnz_chr_id
5537: AND say_code = 'WORK'
5538: AND sgn_code = 'STMP');
5539: -- Validate the contract has Subsidy line

Line 5751: l_stmv_tbl okl_streams_pub.stmv_tbl_type;

5747: l_pdt_id_rec l_hdr_pdt_csr%ROWTYPE;
5748: l_strm_rec strm_csr%ROWTYPE;
5749: l_strms_rec strms_csr%ROWTYPE;
5750:
5751: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
5752: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
5753: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
5754: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
5755:

Line 5752: x_stmv_tbl okl_streams_pub.stmv_tbl_type;

5748: l_strm_rec strm_csr%ROWTYPE;
5749: l_strms_rec strms_csr%ROWTYPE;
5750:
5751: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
5752: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
5753: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
5754: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
5755:
5756: -- Code for bulk update -02/28/2004 - HKPATEL

Line 5753: l_selv_tbl Okl_Streams_pub.selv_tbl_type;

5749: l_strms_rec strms_csr%ROWTYPE;
5750:
5751: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
5752: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
5753: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
5754: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
5755:
5756: -- Code for bulk update -02/28/2004 - HKPATEL
5757: l_id_tbl okl_streams_util.NumberTabTyp;

Line 5754: x_selv_tbl Okl_Streams_pub.selv_tbl_type;

5750:
5751: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
5752: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
5753: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
5754: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
5755:
5756: -- Code for bulk update -02/28/2004 - HKPATEL
5757: l_id_tbl okl_streams_util.NumberTabTyp;
5758: l_say_code_tbl okl_streams_util.Var10TabTyp;

Line 5757: l_id_tbl okl_streams_util.NumberTabTyp;

5753: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
5754: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
5755:
5756: -- Code for bulk update -02/28/2004 - HKPATEL
5757: l_id_tbl okl_streams_util.NumberTabTyp;
5758: l_say_code_tbl okl_streams_util.Var10TabTyp;
5759: l_active_yn_tbl okl_streams_util.Var10TabTyp;
5760: l_date_history_tbl okl_streams_util.DateTabTyp;
5761: l_date_curr_tbl okl_streams_util.DateTabTyp;

Line 5758: l_say_code_tbl okl_streams_util.Var10TabTyp;

5754: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
5755:
5756: -- Code for bulk update -02/28/2004 - HKPATEL
5757: l_id_tbl okl_streams_util.NumberTabTyp;
5758: l_say_code_tbl okl_streams_util.Var10TabTyp;
5759: l_active_yn_tbl okl_streams_util.Var10TabTyp;
5760: l_date_history_tbl okl_streams_util.DateTabTyp;
5761: l_date_curr_tbl okl_streams_util.DateTabTyp;
5762:

Line 5759: l_active_yn_tbl okl_streams_util.Var10TabTyp;

5755:
5756: -- Code for bulk update -02/28/2004 - HKPATEL
5757: l_id_tbl okl_streams_util.NumberTabTyp;
5758: l_say_code_tbl okl_streams_util.Var10TabTyp;
5759: l_active_yn_tbl okl_streams_util.Var10TabTyp;
5760: l_date_history_tbl okl_streams_util.DateTabTyp;
5761: l_date_curr_tbl okl_streams_util.DateTabTyp;
5762:
5763: -- Code for bulk update ends here -02/28/2004 - HKPATEL

Line 5760: l_date_history_tbl okl_streams_util.DateTabTyp;

5756: -- Code for bulk update -02/28/2004 - HKPATEL
5757: l_id_tbl okl_streams_util.NumberTabTyp;
5758: l_say_code_tbl okl_streams_util.Var10TabTyp;
5759: l_active_yn_tbl okl_streams_util.Var10TabTyp;
5760: l_date_history_tbl okl_streams_util.DateTabTyp;
5761: l_date_curr_tbl okl_streams_util.DateTabTyp;
5762:
5763: -- Code for bulk update ends here -02/28/2004 - HKPATEL
5764:

Line 5761: l_date_curr_tbl okl_streams_util.DateTabTyp;

5757: l_id_tbl okl_streams_util.NumberTabTyp;
5758: l_say_code_tbl okl_streams_util.Var10TabTyp;
5759: l_active_yn_tbl okl_streams_util.Var10TabTyp;
5760: l_date_history_tbl okl_streams_util.DateTabTyp;
5761: l_date_curr_tbl okl_streams_util.DateTabTyp;
5762:
5763: -- Code for bulk update ends here -02/28/2004 - HKPATEL
5764:
5765:

Line 5784: okl_streams str,

5780: -- Changed this cursor for user defined streams
5781: Cursor l_secdep_csr( chrId NUMBER,pdtId NUMBER, pp VARCHAR2 ) is
5782: Select ele.id
5783: From okl_strm_elements ele,
5784: okl_streams str,
5785: --okl_strm_type_v sty,
5786: OKL_STRM_TMPT_LINES_UV sty,
5787: okl_k_lines_full_v kle,
5788: okc_line_styles_b lse,

Line 5815: FROM okl_streams stm

5811: l_secdep_rec l_secdep_csr%ROWTYPE;
5812:
5813: CURSOR l_stmp_yn_csr(khrid NUMBER, p VARCHAR2) IS
5814: SELECT count(stm.id) cnt
5815: FROM okl_streams stm
5816: WHERE stm.khr_id = khrid
5817: AND stm.say_code = 'WORK'
5818: AND stm.sgn_code = 'STMP'
5819: AND nvl(stm.purpose_code, 'ORIGIN') = p;

Line 5840: FROM OKL_STREAMS str

5836: pp VARCHAR2 )
5837: IS
5838:
5839: SELECT 'N'
5840: FROM OKL_STREAMS str
5841: WHERE EXISTS (SELECT ID FROM OKL_STRM_ELEMENTS ele WHERE ele.STM_ID = str.ID AND ele.DATE_BILLED IS NULL )
5842: AND str.KHR_ID = chrId
5843: AND str.STY_ID = styId
5844: AND str.SAY_CODE = status

Line 6140: Okl_Streams_pub.update_streams(

6136: END LOOP;
6137: If ( l_id_tbl.COUNT > 0 ) Then
6138: /* Commented for Bulk update by HKPATEL -02/18/2005
6139: If ( l_stmv_tbl.COUNT > 0 ) Then
6140: Okl_Streams_pub.update_streams(
6141: p_api_version => p_api_version,
6142: p_init_msg_list => p_init_msg_list,
6143: x_return_status => x_return_status,
6144: x_msg_count => x_msg_count,

Line 6161: UPDATE OKL_STREAMS

6157: --Added by kthiruva for Debugging
6158: write_to_log('Prior to the Historing of Current streams and updation of Work streams to current');
6159:
6160: FORALL i IN l_id_tbl.FIRST..l_id_tbl.LAST
6161: UPDATE OKL_STREAMS
6162: SET say_code = l_say_code_tbl(i),
6163: active_yn = l_active_yn_tbl(i),
6164: date_history = l_date_history_tbl(i),
6165: date_current = l_date_curr_tbl(i)

Line 6264: Okl_Streams_pub.delete_stream_elements(

6260:
6261:
6262: If ( i > 0 ) Then
6263:
6264: Okl_Streams_pub.delete_stream_elements(
6265: p_api_version => p_api_version,
6266: p_init_msg_list => p_init_msg_list,
6267: x_return_status => x_return_status,
6268: x_msg_count => x_msg_count,

Line 6402: l_prev_stm_id OKL_STREAMS.ID%TYPE;

6398: -- Declare Variables
6399: l_api_name CONSTANT VARCHAR2(30) := 'RECREATE_TMT_LN_STRMS';
6400: l_strm_index NUMBER;
6401: l_sel_index NUMBER;
6402: l_prev_stm_id OKL_STREAMS.ID%TYPE;
6403:
6404: -- vdamerla Forward Ported Bug6149951 starts
6405:
6406: l_orig_chr_id OKC_K_HEADERS_B.ID%TYPE; -- smadhava - Bug# 6149951

Line 6412: l_stmv_tbl okl_streams_pub.stmv_tbl_type;

6408:
6409: -- vdamerla Forward Ported Bug6149951 ends
6410:
6411: -- Declare records/table types
6412: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
6413: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
6414: l_selv_tbl okl_streams_pub.selv_tbl_type;
6415: lx_selv_tbl okl_streams_pub.selv_tbl_type;
6416: -- vdamerla Forward Port

Line 6413: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;

6409: -- vdamerla Forward Ported Bug6149951 ends
6410:
6411: -- Declare records/table types
6412: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
6413: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
6414: l_selv_tbl okl_streams_pub.selv_tbl_type;
6415: lx_selv_tbl okl_streams_pub.selv_tbl_type;
6416: -- vdamerla Forward Port
6417: -- Cursor to get fees linked to a terminated Asset

Line 6414: l_selv_tbl okl_streams_pub.selv_tbl_type;

6410:
6411: -- Declare records/table types
6412: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
6413: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
6414: l_selv_tbl okl_streams_pub.selv_tbl_type;
6415: lx_selv_tbl okl_streams_pub.selv_tbl_type;
6416: -- vdamerla Forward Port
6417: -- Cursor to get fees linked to a terminated Asset
6418: CURSOR c_lnk_fin_rol_trm_fee (cp_chr_id OKC_K_HEADERS_B.ID%TYPE) IS

Line 6415: lx_selv_tbl okl_streams_pub.selv_tbl_type;

6411: -- Declare records/table types
6412: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
6413: lx_stmv_tbl okl_streams_pub.stmv_tbl_type;
6414: l_selv_tbl okl_streams_pub.selv_tbl_type;
6415: lx_selv_tbl okl_streams_pub.selv_tbl_type;
6416: -- vdamerla Forward Port
6417: -- Cursor to get fees linked to a terminated Asset
6418: CURSOR c_lnk_fin_rol_trm_fee (cp_chr_id OKC_K_HEADERS_B.ID%TYPE) IS
6419: SELECT LNK_CLE.ID LNK_ID

Line 6470: , cp_trx_number okl_streams.transaction_number%TYPE) IS

6466:
6467: CURSOR c_streams (cp_chr_id OKC_K_HEADERS_B.ID%TYPE
6468: , cp_cle_id OKC_K_LINES_B.ID%TYPE
6469: , cp_date_terminated DATE
6470: , cp_trx_number okl_streams.transaction_number%TYPE) IS
6471: SELECT STM.ID STREAM_ID
6472: , STM.STY_ID
6473: , STM.SGN_CODE
6474: , STM.PURPOSE_CODE

Line 6480: FROM OKL_STREAMS STM

6476: , SEL.STREAM_ELEMENT_DATE
6477: , SEL.AMOUNT
6478: , SEL.SE_LINE_NUMBER
6479: , SEL.COMMENTS -- vdamerla Forward Ported Bug 6344223
6480: FROM OKL_STREAMS STM
6481: , OKL_STRM_ELEMENTS SEL
6482: , OKL_STRM_TYPE_B STY -- vdamerla Forward Ported Bug 6082209
6483: WHERE SEL.STM_ID = STM.ID
6484: AND STM.KHR_ID = cp_chr_id

Line 6545: FROM okl_streams stm,

6541: --This cursor will get the terminated lines of current streams
6542: CURSOR l_get_curr_streams_lines
6543: IS
6544: SELECT distinct stm.kle_id
6545: FROM okl_streams stm,
6546: okc_k_lines_b ln
6547: WHERE stm.khr_id = p_chr_id
6548: AND stm.say_code = 'CURR'
6549: AND stm.kle_id = ln.id

Line 6569: ,cp_trx_number okl_streams.transaction_number%TYPE) IS

6565: --Modified the cursor by vdamerla for bug 6344223
6566: --Added ISG generated stream type purposes so that these streams will not be
6567: --copied over during mass/online rebook. Streams will be regenerated by ISG
6568: CURSOR c_streams1 (cp_chr_id OKC_K_HEADERS_B.ID%TYPE
6569: ,cp_trx_number okl_streams.transaction_number%TYPE) IS
6570: SELECT STM.ID STREAM_ID
6571: , STM.STY_ID
6572: , STM.SGN_CODE
6573: , STM.PURPOSE_CODE

Line 6579: FROM OKL_STREAMS STM

6575: , SEL.STREAM_ELEMENT_DATE
6576: , SEL.AMOUNT
6577: , SEL.SE_LINE_NUMBER
6578: , SEL.COMMENTS
6579: FROM OKL_STREAMS STM
6580: , OKL_STRM_ELEMENTS SEL
6581: , OKL_STRM_TYPE_B STY
6582: WHERE SEL.STM_ID = STM.ID
6583: AND STM.KHR_ID = cp_chr_id

Line 7029: OKL_STREAMS_PUB.CREATE_STREAMS_PERF(p_api_version

7025:
7026: -- STEP 3
7027: IF l_stmv_tbl.COUNT > 0 THEN
7028: -- Call the API to bulk insert data into streams and stream elements
7029: OKL_STREAMS_PUB.CREATE_STREAMS_PERF(p_api_version
7030: , p_init_msg_list
7031: , x_return_status
7032: , x_msg_count
7033: , x_msg_data

Line 7103: l_id_tbl okl_streams_util.NumberTabTyp;

7099:
7100: l_trxH_in_rec Okl_Trx_Contracts_Pvt.tcnv_rec_type;
7101: l_trxH_out_rec Okl_Trx_Contracts_Pvt.tcnv_rec_type;
7102: -- Code for bulk update -02/18/2004 - HKPATEL
7103: l_id_tbl okl_streams_util.NumberTabTyp;
7104: -- Code for bulk update ends here -02/18/2004 - HKPATEL
7105:
7106:
7107: Cursor ylds_csr( chrId NUMBER ) IS

Line 7192: FROM okl_streams str

7188: str.transaction_number trn_num,
7189: str.purpose_code,
7190: str.say_code,
7191: str.active_yn
7192: FROM okl_streams str
7193: WHERE str.khr_id = p_chr_id
7194: AND str.purpose_code = 'REPORT'
7195: AND str.say_code = 'CURR'
7196: AND str.sgn_code NOT IN ('INTC','LATE_CALC') -- bug 6472228

Line 7210: m_stmv_tbl okl_streams_pub.stmv_tbl_type;

7206: -- Bug 4737555 - End of Changes
7207:
7208: lv_pdt_no_rep VARCHAR2(3) := 'N';
7209: j NUMBER := 0;
7210: m_stmv_tbl okl_streams_pub.stmv_tbl_type;
7211: mx_stmv_tbl okl_streams_pub.stmv_tbl_type;
7212: ylds_rec ylds_csr%ROWTYPE;
7213:
7214: l_strm_rec strm_csr%ROWTYPE;

Line 7211: mx_stmv_tbl okl_streams_pub.stmv_tbl_type;

7207:
7208: lv_pdt_no_rep VARCHAR2(3) := 'N';
7209: j NUMBER := 0;
7210: m_stmv_tbl okl_streams_pub.stmv_tbl_type;
7211: mx_stmv_tbl okl_streams_pub.stmv_tbl_type;
7212: ylds_rec ylds_csr%ROWTYPE;
7213:
7214: l_strm_rec strm_csr%ROWTYPE;
7215: l_stmv_tbl okl_streams_pub.stmv_tbl_type;

Line 7215: l_stmv_tbl okl_streams_pub.stmv_tbl_type;

7211: mx_stmv_tbl okl_streams_pub.stmv_tbl_type;
7212: ylds_rec ylds_csr%ROWTYPE;
7213:
7214: l_strm_rec strm_csr%ROWTYPE;
7215: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
7216: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
7217:
7218: i NUMBER;
7219: l_tcnCode VARCHAR2(256);

Line 7216: x_stmv_tbl okl_streams_pub.stmv_tbl_type;

7212: ylds_rec ylds_csr%ROWTYPE;
7213:
7214: l_strm_rec strm_csr%ROWTYPE;
7215: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
7216: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
7217:
7218: i NUMBER;
7219: l_tcnCode VARCHAR2(256);
7220: l_transaction_type VARCHAR2(256) := 'Miscellaneous';--'Generate Yields';

Line 7443: Okl_Streams_pub.delete_streams(

7439: l_stmv_tbl(i).sgn_code := l_strms_rep_rec.SGN_CODE;
7440: l_stmv_tbl(i).transaction_number := l_strms_rep_rec.TRN_NUM;
7441: END LOOP;
7442: IF i > 0 THEN
7443: Okl_Streams_pub.delete_streams(
7444: p_api_version => p_api_version,
7445: p_init_msg_list => p_init_msg_list,
7446: x_return_status => x_return_status,
7447: x_msg_count => x_msg_count,

Line 7535: Okl_Streams_pub.delete_streams(

7531: l_stmv_tbl(i).sgn_code := l_strms_rep_rec.SGN_CODE;
7532: l_stmv_tbl(i).transaction_number := l_strms_rep_rec.TRN_NUM;
7533: END LOOP;
7534: IF i > 0 THEN
7535: Okl_Streams_pub.delete_streams(
7536: p_api_version => p_api_version,
7537: p_init_msg_list => p_init_msg_list,
7538: x_return_status => x_return_status,
7539: x_msg_count => x_msg_count,

Line 7632: UPDATE OKL_STREAMS

7628: BEGIN
7629: --Added by kthiruva for Debugging
7630: write_to_log('Prior to the call to historing current streams');
7631: FORALL i IN l_id_tbl.FIRST..l_id_tbl.LAST
7632: UPDATE OKL_STREAMS
7633: SET say_code = 'HIST',
7634: active_yn = 'N',
7635: date_history = sysdate
7636: WHERE ID = l_id_tbl(i);

Line 7654: okl_streams_pub.update_streams(

7650: raise OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
7651: END;
7652: /* Commented for Bulk Update - HKPATEL - 02/18/2004
7653: IF (m_stmv_tbl.COUNT > 0) THEN
7654: okl_streams_pub.update_streams(
7655: p_api_version => p_api_version,
7656: p_init_msg_list => p_init_msg_list,
7657: x_return_status => x_return_status,
7658: x_msg_count => x_msg_count,

Line 7750: l_timeout := FND_PROFILE.value('OKL_STREAMS_TIME_OUT');

7746: IF(l_report_req_status NOT IN('PROCESS_COMPLETE', 'PROCESS_COMPLETE_ERRORS','PROCESSING_FAILED'
7747: ,'PROCESS_ABORTED','SERVER_NA','TIME_OUT')) THEN
7748:
7749: --Fetching the value of the time out variable
7750: l_timeout := FND_PROFILE.value('OKL_STREAMS_TIME_OUT');
7751: l_timeout := l_timeout * 60;
7752:
7753: OPEN get_rep_trans_num(p_chr_id);
7754: FETCH get_rep_trans_num INTO l_alert_name;

Line 9122: OKL_STREAMS_UTIL.get_dependent_stream_type

9118: END IF;
9119: CLOSE get_sub_income_strm_csr;
9120:
9121: -- New code for bug 4044089 by HKPATEL 12/02/2004
9122: OKL_STREAMS_UTIL.get_dependent_stream_type
9123: (
9124: p_khr_id =>p_chr_id,
9125: p_primary_sty_id =>l_sty_id,
9126: p_dependent_sty_purpose=>'SUBSIDY_INCOME',

Line 9264: OKL_STREAMS_UTIL.get_dependent_stream_type

9260: EXIT WHEN (x_return_status = OKL_API.G_RET_STS_ERROR);
9261: END IF;
9262: CLOSE get_sub_income_strm_csr;
9263: -- New code for bug 4044089 by HKPATEL 12/02/2004
9264: OKL_STREAMS_UTIL.get_dependent_stream_type
9265: (
9266: p_khr_id =>p_chr_id,
9267: p_primary_sty_id =>l_sty_id,
9268: p_dependent_sty_purpose=>'SUBSIDY_INCOME',

Line 19619: l_stmv_tbl okl_streams_pub.stmv_tbl_type;

19615:
19616: l_trxH_in_rec Okl_Trx_Contracts_Pvt.tcnv_rec_type;
19617: l_trxH_out_rec Okl_Trx_Contracts_Pvt.tcnv_rec_type;
19618:
19619: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
19620: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
19621:
19622: i NUMBER;
19623: l_lines_rec l_line_rec_csr%ROWTYPE;

Line 19620: x_stmv_tbl okl_streams_pub.stmv_tbl_type;

19616: l_trxH_in_rec Okl_Trx_Contracts_Pvt.tcnv_rec_type;
19617: l_trxH_out_rec Okl_Trx_Contracts_Pvt.tcnv_rec_type;
19618:
19619: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
19620: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
19621:
19622: i NUMBER;
19623: l_lines_rec l_line_rec_csr%ROWTYPE;
19624: l_transaction_type VARCHAR2(256):= 'Miscellaneous';--'Generate Yields';

Line 20029: l_stmv_rec Okl_Streams_pub.stmv_rec_type;

20025: l_api_name CONSTANT VARCHAR2(30) := 'GEN_STREAMS';
20026: l_api_version CONSTANT NUMBER := 1.0;
20027: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
20028:
20029: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
20030: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
20031: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
20032: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
20033:

Line 20030: l_selv_tbl Okl_Streams_pub.selv_tbl_type;

20026: l_api_version CONSTANT NUMBER := 1.0;
20027: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
20028:
20029: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
20030: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
20031: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
20032: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
20033:
20034: cursor l_rl_csr( rgcode OKC_RULE_GROUPS_B.RGD_CODE%TYPE,

Line 20031: x_stmv_rec Okl_Streams_pub.stmv_rec_type;

20027: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
20028:
20029: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
20030: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
20031: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
20032: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
20033:
20034: cursor l_rl_csr( rgcode OKC_RULE_GROUPS_B.RGD_CODE%TYPE,
20035: rlcat OKC_RULES_B.RULE_INFORMATION_CATEGORY%TYPE,

Line 20032: x_selv_tbl Okl_Streams_pub.selv_tbl_type;

20028:
20029: l_stmv_rec Okl_Streams_pub.stmv_rec_type;
20030: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
20031: x_stmv_rec Okl_Streams_pub.stmv_rec_type;
20032: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
20033:
20034: cursor l_rl_csr( rgcode OKC_RULE_GROUPS_B.RGD_CODE%TYPE,
20035: rlcat OKC_RULES_B.RULE_INFORMATION_CATEGORY%TYPE,
20036: chrId NUMBER,

Line 20165: From okl_streams;

20161: l_stmv_rec.active_yn := 'Y';
20162: l_stmv_rec.date_current := sysdate;
20163:
20164: Select max(transaction_number)+1 into temp
20165: From okl_streams;
20166:
20167: l_stmv_rec.transaction_number := temp;
20168: l_stmv_rec.sgn_code := 'MANL';
20169:

Line 20193: Okl_Streams_Pub.create_streams(

20189: j := j + k;
20190:
20191: END LOOP;
20192:
20193: Okl_Streams_Pub.create_streams(
20194: p_api_version => l_api_version
20195: ,p_init_msg_list => p_init_msg_list
20196: ,x_return_status => l_return_status
20197: ,x_msg_count => x_msg_count

Line 20375: l_stmv_tbl okl_streams_pub.stmv_tbl_type;

20371: p_pdtv_rec pdtv_rec_type;
20372: x_pdt_parameter_rec pdt_param_rec_type;
20373: x_no_data_found BOOLEAN;
20374:
20375: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
20376: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
20377: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
20378: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
20379: l_strms_orig_rec strms_csr%ROWTYPE;

Line 20376: x_stmv_tbl okl_streams_pub.stmv_tbl_type;

20372: x_pdt_parameter_rec pdt_param_rec_type;
20373: x_no_data_found BOOLEAN;
20374:
20375: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
20376: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
20377: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
20378: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
20379: l_strms_orig_rec strms_csr%ROWTYPE;
20380: l_strms_rep_rec strms_csr%ROWTYPE;

Line 20377: l_selv_tbl Okl_Streams_pub.selv_tbl_type;

20373: x_no_data_found BOOLEAN;
20374:
20375: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
20376: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
20377: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
20378: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
20379: l_strms_orig_rec strms_csr%ROWTYPE;
20380: l_strms_rep_rec strms_csr%ROWTYPE;
20381: -- Code for bulk update -02/28/2004 - HKPATEL

Line 20378: x_selv_tbl Okl_Streams_pub.selv_tbl_type;

20374:
20375: l_stmv_tbl okl_streams_pub.stmv_tbl_type;
20376: x_stmv_tbl okl_streams_pub.stmv_tbl_type;
20377: l_selv_tbl Okl_Streams_pub.selv_tbl_type;
20378: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
20379: l_strms_orig_rec strms_csr%ROWTYPE;
20380: l_strms_rep_rec strms_csr%ROWTYPE;
20381: -- Code for bulk update -02/28/2004 - HKPATEL
20382: l_id_tbl okl_streams_util.NumberTabTyp;

Line 20382: l_id_tbl okl_streams_util.NumberTabTyp;

20378: x_selv_tbl Okl_Streams_pub.selv_tbl_type;
20379: l_strms_orig_rec strms_csr%ROWTYPE;
20380: l_strms_rep_rec strms_csr%ROWTYPE;
20381: -- Code for bulk update -02/28/2004 - HKPATEL
20382: l_id_tbl okl_streams_util.NumberTabTyp;
20383: -- Code for bulk update ends here -02/28/2004 - HKPATEL
20384:
20385:
20386: i NUMBER;

Line 20482: UPDATE OKL_STREAMS

20478: --Added by kthiruva for Debugging
20479: write_to_log('Updating the Work streams to CURR');
20480:
20481: FORALL i IN l_id_tbl.FIRST..l_id_tbl.LAST
20482: UPDATE OKL_STREAMS
20483: SET say_code = 'CURR',
20484: active_yn = 'Y',
20485: date_current = sysdate
20486: WHERE ID = l_id_tbl(i);

Line 20512: Okl_Streams_pub.update_streams(

20508: raise OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
20509: END;
20510: /* Commented for Bulk update by HKPATEL -02/28/2004
20511: If ( l_stmv_tbl.COUNT > 0 ) Then
20512: Okl_Streams_pub.update_streams(
20513: p_api_version => p_api_version,
20514: p_init_msg_list => p_init_msg_list,
20515: x_return_status => x_return_status,
20516: x_msg_count => x_msg_count,

Line 20584: OKL_STREAMS_UTIL.get_pricing_engine(

20580: return;
20581:
20582: End If;
20583:
20584: OKL_STREAMS_UTIL.get_pricing_engine(
20585: p_khr_id => p_khr_id,
20586: x_pricing_engine => l_pricing_engine,
20587: x_return_status => x_return_status);
20588: --Added by kthiruva for Debugging

Line 20597: --IF ( fnd_profile.value('OKL_STREAMS_GEN_PATH') = 'EXTERNAL') THEN

20593: raise OKL_API.G_EXCEPTION_ERROR;
20594: END IF;
20595:
20596:
20597: --IF ( fnd_profile.value('OKL_STREAMS_GEN_PATH') = 'EXTERNAL') THEN
20598: IF ( l_pricing_engine = 'EXTERNAL') THEN
20599:
20600: --
20601: -- Call EXTERNAL Stream genration process