PACKAGE BODY: APPS.OKL_LPO_STRM_PVT

Source

1 PACKAGE BODY OKL_LPO_STRM_PVT AS
2 /* $Header: OKLRLSXB.pls 120.2 2005/10/30 04:34:58 appldev noship $ */
3 
4   PROCEDURE create_lpo_streams(
5      p_api_version                  IN  NUMBER
6     ,p_init_msg_list                IN  VARCHAR2 DEFAULT Okc_Api.G_FALSE
7     ,x_return_status                OUT NOCOPY VARCHAR2
8     ,x_msg_count                    OUT NOCOPY NUMBER
9     ,x_msg_data                     OUT NOCOPY VARCHAR2
10     ,p_lpo_id						IN  NUMBER
11      ) IS
12 
13     l_slx_rec            			SLX_REC_TYPE;
14     x_slx_rec            			SLX_REC_TYPE;
15     p_slx_rec            			SLX_REC_TYPE;
16 
17     l_return_status                 VARCHAR2(1)   := Okc_Api.G_RET_STS_SUCCESS;
18     l_found							BOOLEAN;
19 
20 
21     CURSOR l_slx_csr IS
22 		   /*SELECT distinct id
23 		   FROM okl_strm_type_b
24 		   WHERE BILLABLE_YN = 'Y';*/
25 		   SELECT sty_id
26 		   FROM okl_strm_tmpt_all_types_uv sty
27 		   WHERE sty.BILLABLE_YN = 'Y'
28            and not exists (select 1 from OKL_STRM_TYPE_EXEMPT_V sem
29                            where sem.lpo_id = p_lpo_id
30                            and   sem.sty_id = sty.sty_id);
31 
32     BEGIN
33   		FOR l_sty_rec IN l_slx_csr
34         LOOP
35 
36 		l_slx_rec.lpo_id 					:= p_lpo_id;
37 		l_slx_rec.sty_id 					:= l_sty_rec.sty_id;
38 		l_slx_rec.late_policy_exempt_yn		:= 'N';
39 
40 
41         okl_strm_type_exempt_pub.insert_strm_type_exempt(
42                            p_api_version   => p_api_version
43                           ,p_init_msg_list => p_init_msg_list
44                           ,x_return_status => x_return_status
45                           ,x_msg_count     => x_msg_count
46                           ,x_msg_data      => x_msg_data
47                           ,p_slxv_rec	   => l_slx_rec
48                           ,x_slxv_rec	   => p_slx_rec
49                           );
50 
51 --        IF (x_return_Status <> Okl_Api.G_RET_STS_SUCCESS) THEN
52 --			   Okl_Accounting_Util.get_error_message(x_msg_count, l_msg_data);
53 --        END IF;
54 
55 
56       IF x_return_status = Okc_Api.G_RET_STS_UNEXP_ERROR THEN
57        RAISE G_EXCEPTION_HALT_VALIDATION;
58       ELSE
59         IF x_return_status <> Okc_Api.G_RET_STS_SUCCESS THEN
60           l_return_status := x_return_status;
61            END IF;
62       END IF;
63   END LOOP;
64 
65 	    EXCEPTION
66     WHEN G_EXCEPTION_HALT_VALIDATION THEN
67       NULL;
68     WHEN OTHERS THEN
69       Okc_Api.SET_MESSAGE(p_app_name          => g_app_name
70                          ,p_msg_name          => g_unexpected_error
71                          ,p_token1            => g_sqlcode_token
72                          ,p_token1_value      => SQLCODE
73                          ,p_token2            => g_sqlerrm_token
74                          ,p_token2_value      => SQLERRM);
75         x_return_status := Okc_Api.G_RET_STS_UNEXP_ERROR;
76 
77 
78 END create_lpo_streams;
79 END OKL_LPO_STRM_PVT;