DBA Data[Home] [Help]

PACKAGE BODY: APPS.OKL_GENERATE_STREAMS_PUB

Source


1 PACKAGE BODY OKL_GENERATE_STREAMS_PUB AS
2 /* $Header: OKLPGSMB.pls 115.11 2004/04/13 10:47:05 rnaik noship $ */
3 
4   ---------------------------------------------------------------------------
5   -- PROCEDURE GENERATE_STREAMS
6   ---------------------------------------------------------------------------
7   PROCEDURE GENERATE_STREAMS(p_api_version          IN         NUMBER
8                              ,p_init_msg_list       IN         VARCHAR2
9                              ,p_khr_id              IN         NUMBER
10                              ,p_generation_ctx_code IN         VARCHAR2
11                              ,x_trx_number          OUT NOCOPY NUMBER
12                              ,x_trx_status          OUT NOCOPY VARCHAR2
13                              ,x_return_status       OUT NOCOPY VARCHAR2
14                              ,x_msg_count           OUT NOCOPY NUMBER
15                              ,x_msg_data            OUT NOCOPY VARCHAR2)
16   IS
17     l_return_status VARCHAR2(1) := G_RET_STS_SUCCESS;
18     l_api_name VARCHAR2(31) := 'GENERATE_STREAMS';
19     l_api_version NUMBER := 1;
20   BEGIN
21     l_return_status := OKL_API.START_ACTIVITY(p_api_name       => l_api_name,
22                                               p_pkg_name       => G_PKG_NAME,
23                                               p_init_msg_list  => p_init_msg_list,
24                                               l_api_version    => l_api_version,
25                                               p_api_version    => p_api_version,
26                                               p_api_type       => G_API_TYPE,
27                                               x_return_status  => l_return_status);
28     IF (l_return_status = G_RET_STS_UNEXP_ERROR) THEN
29       RAISE G_EXCEPTION_UNEXPECTED_ERROR;
30     ELSIF (l_return_status = G_RET_STS_ERROR) THEN
31       RAISE G_EXCEPTION_ERROR;
32     END IF;
33 
34 
35 
36     Okl_Generate_Streams_Pvt.generate_streams(p_api_version          => p_api_version
37                                               ,p_init_msg_list       => p_init_msg_list
38 					      ,p_khr_id              => p_khr_id
39 					      ,p_generation_ctx_code => p_generation_ctx_code
40 					      ,x_trx_number          => x_trx_number
41 					      ,x_trx_status          => x_trx_status
42 					      ,x_return_status       => l_return_status
43 					      ,x_msg_count           => x_msg_count
44 					      ,x_msg_data            => x_msg_data);
45 
46      IF l_return_status = G_RET_STS_ERROR THEN
47         RAISE G_EXCEPTION_ERROR;
48      ELSIF l_return_status = G_RET_STS_UNEXP_ERROR THEN
49         RAISE G_EXCEPTION_UNEXPECTED_ERROR;
50      END IF;
51 
52 
53 
54     OKL_API.END_ACTIVITY(x_msg_count => x_msg_count,
55                          x_msg_data  => x_msg_data);
56     x_return_status := l_return_status;
57 
58    EXCEPTION
59     WHEN G_EXCEPTION_ERROR THEN
60       x_return_status := OKL_API.HANDLE_EXCEPTIONS(p_api_name  => l_api_name,
61                                                    p_pkg_name  => G_PKG_NAME,
62                                                    p_exc_name  => G_EXC_NAME_RET_STS_ERR,
63                                                    x_msg_count => x_msg_count,
64                                                    x_msg_data  => x_msg_data,
65                                                    p_api_type  => G_API_TYPE);
66     WHEN G_EXCEPTION_UNEXPECTED_ERROR THEN
67       x_return_status := OKL_API.HANDLE_EXCEPTIONS(p_api_name  => l_api_name,
68                                                    p_pkg_name  => G_PKG_NAME,
69                                                    p_exc_name  => G_EXC_NAME_RET_STS_UNEXP_ERR,
70                                                    x_msg_count => x_msg_count,
71                                                    x_msg_data  => x_msg_data,
72                                                    p_api_type  => G_API_TYPE);
73     WHEN OTHERS THEN
74       x_return_status := OKL_API.HANDLE_EXCEPTIONS(p_api_name  => l_api_name,
75                                                    p_pkg_name  => G_PKG_NAME,
76                                                    p_exc_name  => G_EXC_NAME_OTHERS,
77                                                    x_msg_count => x_msg_count,
78                                                    x_msg_data  => x_msg_data,
79                                                    p_api_type  => G_API_TYPE);
80 
81   END GENERATE_STREAMS;
82 
83 
84   ---------------------------------------------------------------------------
85   -- PROCEDURE POPULATE_HEADER_DATA
86   ---------------------------------------------------------------------------
87   PROCEDURE POPULATE_HEADER_DATA(p_api_version          IN         NUMBER
88                                  ,p_init_msg_list       IN         VARCHAR2
89                                  ,p_khr_id              IN         NUMBER
90                                  ,p_generation_ctx_code IN         VARCHAR2
91                                  ,x_trx_number          OUT NOCOPY NUMBER
92                                  ,x_return_status       OUT NOCOPY VARCHAR2
93                                  ,x_msg_count           OUT NOCOPY NUMBER
94                                  ,x_msg_data            OUT NOCOPY VARCHAR2)
95   IS
96     l_return_status VARCHAR2(1) := G_RET_STS_SUCCESS;
97     l_api_name VARCHAR2(31) := 'POPULATE_HEADER_DATA';
98     l_api_version NUMBER := 1;
99   BEGIN
100 --dbms_output.put_line('inside gen stream pub');
101     l_return_status := OKL_API.START_ACTIVITY(p_api_name       => l_api_name,
102                                               p_pkg_name       => G_PKG_NAME,
103                                               p_init_msg_list  => p_init_msg_list,
104                                               l_api_version    => l_api_version,
105                                               p_api_version    => p_api_version,
106                                               p_api_type       => G_API_TYPE,
107                                               x_return_status  => l_return_status);
108     IF (l_return_status = G_RET_STS_UNEXP_ERROR) THEN
109       RAISE G_EXCEPTION_UNEXPECTED_ERROR;
110     ELSIF (l_return_status = G_RET_STS_ERROR) THEN
111       RAISE G_EXCEPTION_ERROR;
112     END IF;
113 
114 
115 --dbms_output.put_line('calling gen stream pvt');
116     Okl_Generate_Streams_Pvt.populate_header_data(p_api_version          => p_api_version
117                                                   ,p_init_msg_list       => p_init_msg_list
118 					          ,p_khr_id              => p_khr_id
119 					          ,p_generation_ctx_code => p_generation_ctx_code
120 					          ,x_trx_number          => x_trx_number
121 					          ,x_return_status       => l_return_status
122 					          ,x_msg_count           => x_msg_count
123 					          ,x_msg_data            => x_msg_data);
124 
125      IF l_return_status = G_RET_STS_ERROR THEN
126         RAISE G_EXCEPTION_ERROR;
127      ELSIF l_return_status = G_RET_STS_UNEXP_ERROR THEN
128         RAISE G_EXCEPTION_UNEXPECTED_ERROR;
129      END IF;
130 --dbms_output.put_line('back from  gen stream pvt' || l_return_status);
131 
132 
133     OKL_API.END_ACTIVITY(x_msg_count => x_msg_count,
134                          x_msg_data  => x_msg_data);
135     x_return_status := l_return_status;
136 
137    EXCEPTION
138     WHEN G_EXCEPTION_ERROR THEN
139       x_return_status := OKL_API.HANDLE_EXCEPTIONS(p_api_name  => l_api_name,
140                                                    p_pkg_name  => G_PKG_NAME,
141                                                    p_exc_name  => G_EXC_NAME_RET_STS_ERR,
142                                                    x_msg_count => x_msg_count,
143                                                    x_msg_data  => x_msg_data,
144                                                    p_api_type  => G_API_TYPE);
145     WHEN G_EXCEPTION_UNEXPECTED_ERROR THEN
146       x_return_status := OKL_API.HANDLE_EXCEPTIONS(p_api_name  => l_api_name,
147                                                    p_pkg_name  => G_PKG_NAME,
148                                                    p_exc_name  => G_EXC_NAME_RET_STS_UNEXP_ERR,
149                                                    x_msg_count => x_msg_count,
150                                                    x_msg_data  => x_msg_data,
151                                                    p_api_type  => G_API_TYPE);
152     WHEN OTHERS THEN
153       x_return_status := OKL_API.HANDLE_EXCEPTIONS(p_api_name  => l_api_name,
154                                                    p_pkg_name  => G_PKG_NAME,
155                                                    p_exc_name  => G_EXC_NAME_OTHERS,
156                                                    x_msg_count => x_msg_count,
157                                                    x_msg_data  => x_msg_data,
158                                                    p_api_type  => G_API_TYPE);
159 
160   END POPULATE_HEADER_DATA;
161 
162 
163   ---------------------------------------------------------------------------
164   -- PROCEDURE INVOKE_PRICING_ENGINE
165   ---------------------------------------------------------------------------
166   PROCEDURE INVOKE_PRICING_ENGINE(p_api_version          IN         NUMBER
167                                   ,p_init_msg_list       IN         VARCHAR2
168                                   ,p_trx_number          in NUMBER
169                                   ,x_trx_number          OUT NOCOPY NUMBER
170                                   ,x_trx_status          OUT NOCOPY VARCHAR2
171                                   ,x_return_status       OUT NOCOPY VARCHAR2
172                                   ,x_msg_count           OUT NOCOPY NUMBER
173                                   ,x_msg_data            OUT NOCOPY VARCHAR2)
174   IS
175     l_return_status VARCHAR2(1) := G_RET_STS_SUCCESS;
176     l_api_name VARCHAR2(31) := 'INVOKE_PRICING_ENGINE';
177     l_api_version NUMBER := 1;
178   BEGIN
179     l_return_status := OKL_API.START_ACTIVITY(p_api_name       => l_api_name,
180                                               p_pkg_name       => G_PKG_NAME,
181                                               p_init_msg_list  => p_init_msg_list,
182                                               l_api_version    => l_api_version,
183                                               p_api_version    => p_api_version,
184                                               p_api_type       => G_API_TYPE,
185                                               x_return_status  => l_return_status);
186     IF (l_return_status = G_RET_STS_UNEXP_ERROR) THEN
187       RAISE G_EXCEPTION_UNEXPECTED_ERROR;
188     ELSIF (l_return_status = G_RET_STS_ERROR) THEN
189       RAISE G_EXCEPTION_ERROR;
190     END IF;
191 
192 
193 --DBMS_OUTPUT.PUT_LINE('pub to pvt');
194     Okl_Generate_Streams_Pvt.invoke_pricing_engine(p_api_version    => p_api_version
195                                                    ,p_init_msg_list => p_init_msg_list
196 					           ,p_trx_number    => p_trx_number
197 					           ,x_trx_number    => x_trx_number
198 					           ,x_trx_status    => x_trx_status
199 					           ,x_return_status => l_return_status
200 					           ,x_msg_count     => x_msg_count
201 					           ,x_msg_data      => x_msg_data);
202 --DBMS_OUTPUT.PUT_LINE('pvt ok?' || l_return_status);
203      IF l_return_status = G_RET_STS_ERROR THEN
204         RAISE G_EXCEPTION_ERROR;
205      ELSIF l_return_status = G_RET_STS_UNEXP_ERROR THEN
206         RAISE G_EXCEPTION_UNEXPECTED_ERROR;
207      END IF;
208 
209 
210 
211     OKL_API.END_ACTIVITY(x_msg_count => x_msg_count,
212                          x_msg_data  => x_msg_data);
213     x_return_status := l_return_status;
214 
215    EXCEPTION
216     WHEN G_EXCEPTION_ERROR THEN
217       x_return_status := OKL_API.HANDLE_EXCEPTIONS(p_api_name  => l_api_name,
218                                                    p_pkg_name  => G_PKG_NAME,
219                                                    p_exc_name  => G_EXC_NAME_RET_STS_ERR,
220                                                    x_msg_count => x_msg_count,
221                                                    x_msg_data  => x_msg_data,
222                                                    p_api_type  => G_API_TYPE);
223     WHEN G_EXCEPTION_UNEXPECTED_ERROR THEN
224       x_return_status := OKL_API.HANDLE_EXCEPTIONS(p_api_name  => l_api_name,
225                                                    p_pkg_name  => G_PKG_NAME,
226                                                    p_exc_name  => G_EXC_NAME_RET_STS_UNEXP_ERR,
227                                                    x_msg_count => x_msg_count,
228                                                    x_msg_data  => x_msg_data,
229                                                    p_api_type  => G_API_TYPE);
230     WHEN OTHERS THEN
231       x_return_status := OKL_API.HANDLE_EXCEPTIONS(p_api_name  => l_api_name,
232                                                    p_pkg_name  => G_PKG_NAME,
233                                                    p_exc_name  => G_EXC_NAME_OTHERS,
234                                                    x_msg_count => x_msg_count,
235                                                    x_msg_data  => x_msg_data,
236                                                    p_api_type  => G_API_TYPE);
237 
238   END INVOKE_PRICING_ENGINE;
239 END OKL_GENERATE_STREAMS_PUB;