24: BEGIN
25: -- Set API savepoint
26: SAVEPOINT trx_create_pool;
27:
28: x_return_status := OKL_API.G_RET_STS_SUCCESS;
29:
30: l_api_version := p_api_version ;
31: l_init_msg_list := p_init_msg_list ;
32: l_return_status := x_return_status ;
42: x_msg_data => l_msg_data,
43: p_polv_rec => l_polv_rec,
44: x_polv_rec => lx_polv_rec);
45:
46: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
47: RAISE OKL_API.G_EXCEPTION_ERROR;
48: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
49: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
50: END IF;
43: p_polv_rec => l_polv_rec,
44: x_polv_rec => lx_polv_rec);
45:
46: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
47: RAISE OKL_API.G_EXCEPTION_ERROR;
48: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
49: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
50: END IF;
51:
44: x_polv_rec => lx_polv_rec);
45:
46: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
47: RAISE OKL_API.G_EXCEPTION_ERROR;
48: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
49: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
50: END IF;
51:
52: x_return_status := l_return_status ;
45:
46: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
47: RAISE OKL_API.G_EXCEPTION_ERROR;
48: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
49: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
50: END IF;
51:
52: x_return_status := l_return_status ;
53: x_msg_count := l_msg_count ;
55: x_polv_rec := lx_polv_rec;
56:
57:
58: EXCEPTION
59: WHEN OKL_API.G_EXCEPTION_ERROR THEN
60: ROLLBACK TO trx_create_pool;
61: x_return_status := OKL_API.G_RET_STS_ERROR;
62: x_msg_count := l_msg_count ;
63: x_msg_data := l_msg_data ;
57:
58: EXCEPTION
59: WHEN OKL_API.G_EXCEPTION_ERROR THEN
60: ROLLBACK TO trx_create_pool;
61: x_return_status := OKL_API.G_RET_STS_ERROR;
62: x_msg_count := l_msg_count ;
63: x_msg_data := l_msg_data ;
64: FND_MSG_PUB.count_and_get(
65: p_count => x_msg_count
63: x_msg_data := l_msg_data ;
64: FND_MSG_PUB.count_and_get(
65: p_count => x_msg_count
66: ,p_data => x_msg_data);
67: WHEN OKL_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
68: ROLLBACK TO trx_create_pool;
69: x_return_status := OKL_API.G_RET_STS_UNEXP_ERROR;
70: x_msg_count := l_msg_count ;
71: x_msg_data := l_msg_data ;
65: p_count => x_msg_count
66: ,p_data => x_msg_data);
67: WHEN OKL_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
68: ROLLBACK TO trx_create_pool;
69: x_return_status := OKL_API.G_RET_STS_UNEXP_ERROR;
70: x_msg_count := l_msg_count ;
71: x_msg_data := l_msg_data ;
72: FND_MSG_PUB.count_and_get(
73: p_count => x_msg_count
73: p_count => x_msg_count
74: ,p_data => x_msg_data);
75: WHEN OTHERS THEN
76: ROLLBACK TO trx_create_pool;
77: x_return_status := OKL_API.G_RET_STS_UNEXP_ERROR;
78: x_msg_count := l_msg_count ;
79: x_msg_data := l_msg_data ;
80: FND_MSG_PUB.ADD_EXC_MSG('OKL_POOL_PUB','create_pool');
81: FND_MSG_PUB.count_and_get(
131: x_msg_count => l_msg_count,
132: x_msg_data => l_msg_data
133: );
134:
135: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
136: RAISE OKL_API.G_EXCEPTION_ERROR;
137: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
138: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
139: END IF;
132: x_msg_data => l_msg_data
133: );
134:
135: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
136: RAISE OKL_API.G_EXCEPTION_ERROR;
137: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
138: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
139: END IF;
140:
133: );
134:
135: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
136: RAISE OKL_API.G_EXCEPTION_ERROR;
137: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
138: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
139: END IF;
140:
141: Okl_Pool_Pvt.update_pool(
134:
135: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
136: RAISE OKL_API.G_EXCEPTION_ERROR;
137: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
138: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
139: END IF;
140:
141: Okl_Pool_Pvt.update_pool(
142: p_api_version => l_api_version,
146: x_msg_data => l_msg_data,
147: p_polv_rec => l_polv_rec,
148: x_polv_rec => lx_polv_rec);
149:
150: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
151: RAISE OKL_API.G_EXCEPTION_ERROR;
152: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
153: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
154: END IF;
147: p_polv_rec => l_polv_rec,
148: x_polv_rec => lx_polv_rec);
149:
150: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
151: RAISE OKL_API.G_EXCEPTION_ERROR;
152: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
153: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
154: END IF;
155:
148: x_polv_rec => lx_polv_rec);
149:
150: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
151: RAISE OKL_API.G_EXCEPTION_ERROR;
152: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
153: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
154: END IF;
155:
156: --Assign value to OUT variables
149:
150: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
151: RAISE OKL_API.G_EXCEPTION_ERROR;
152: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
153: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
154: END IF;
155:
156: --Assign value to OUT variables
157: x_return_status := l_return_status ;
160: x_polv_rec := lx_polv_rec;
161:
162:
163: EXCEPTION
164: WHEN OKL_API.G_EXCEPTION_ERROR THEN
165: ROLLBACK TO trx_update_pool;
166: x_return_status := OKL_API.G_RET_STS_ERROR;
167: x_msg_count := l_msg_count ;
168: x_msg_data := l_msg_data ;
162:
163: EXCEPTION
164: WHEN OKL_API.G_EXCEPTION_ERROR THEN
165: ROLLBACK TO trx_update_pool;
166: x_return_status := OKL_API.G_RET_STS_ERROR;
167: x_msg_count := l_msg_count ;
168: x_msg_data := l_msg_data ;
169: FND_MSG_PUB.count_and_get(
170: p_count => x_msg_count
168: x_msg_data := l_msg_data ;
169: FND_MSG_PUB.count_and_get(
170: p_count => x_msg_count
171: ,p_data => x_msg_data);
172: WHEN OKL_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
173: ROLLBACK TO trx_update_pool;
174: x_return_status := OKL_API.G_RET_STS_UNEXP_ERROR;
175: x_msg_count := l_msg_count ;
176: x_msg_data := l_msg_data ;
170: p_count => x_msg_count
171: ,p_data => x_msg_data);
172: WHEN OKL_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
173: ROLLBACK TO trx_update_pool;
174: x_return_status := OKL_API.G_RET_STS_UNEXP_ERROR;
175: x_msg_count := l_msg_count ;
176: x_msg_data := l_msg_data ;
177: FND_MSG_PUB.count_and_get(
178: p_count => x_msg_count
178: p_count => x_msg_count
179: ,p_data => x_msg_data);
180: WHEN OTHERS THEN
181: ROLLBACK TO trx_update_pool;
182: x_return_status := OKL_API.G_RET_STS_UNEXP_ERROR;
183: x_msg_count := l_msg_count ;
184: x_msg_data := l_msg_data ;
185: FND_MSG_PUB.ADD_EXC_MSG('OKL_POOL_PUB','update_pool');
186: FND_MSG_PUB.count_and_get(
191:
192:
193: PROCEDURE cleanup_pool_contents(
194: p_api_version IN NUMBER
195: ,p_init_msg_list IN VARCHAR2 DEFAULT OKL_API.G_FALSE
196: ,x_return_status OUT NOCOPY VARCHAR2
197: ,x_msg_count OUT NOCOPY NUMBER
198: ,x_msg_data OUT NOCOPY VARCHAR2
199: ,p_pol_id IN NUMBER
249: x_msg_count => l_msg_count,
250: x_msg_data => l_msg_data
251: );
252:
253: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
254: RAISE OKL_API.G_EXCEPTION_ERROR;
255: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
256: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
257: END IF;
250: x_msg_data => l_msg_data
251: );
252:
253: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
254: RAISE OKL_API.G_EXCEPTION_ERROR;
255: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
256: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
257: END IF;
258:
251: );
252:
253: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
254: RAISE OKL_API.G_EXCEPTION_ERROR;
255: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
256: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
257: END IF;
258:
259:
252:
253: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
254: RAISE OKL_API.G_EXCEPTION_ERROR;
255: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
256: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
257: END IF;
258:
259:
260: Okl_Pool_Pvt.cleanup_pool_contents( p_api_version => l_api_version
291: ,p_streams_to_date => p_streams_to_date
292: ,p_action_code => Okl_Pool_Pvt.G_ACTION_REMOVE
293: ,x_poc_uv_tbl => lx_poc_uv_tbl);
294:
295: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
296: RAISE OKL_API.G_EXCEPTION_ERROR;
297: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
298: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
299: END IF;
292: ,p_action_code => Okl_Pool_Pvt.G_ACTION_REMOVE
293: ,x_poc_uv_tbl => lx_poc_uv_tbl);
294:
295: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
296: RAISE OKL_API.G_EXCEPTION_ERROR;
297: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
298: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
299: END IF;
300:
293: ,x_poc_uv_tbl => lx_poc_uv_tbl);
294:
295: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
296: RAISE OKL_API.G_EXCEPTION_ERROR;
297: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
298: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
299: END IF;
300:
301:
294:
295: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
296: RAISE OKL_API.G_EXCEPTION_ERROR;
297: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
298: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
299: END IF;
300:
301:
302: --Assign value to OUT variables
306: x_poc_uv_tbl := lx_poc_uv_tbl;
307:
308:
309: EXCEPTION
310: WHEN OKL_API.G_EXCEPTION_ERROR THEN
311: ROLLBACK TO trx_cleanup_pool_contents;
312: x_return_status := OKL_API.G_RET_STS_ERROR;
313: x_msg_count := l_msg_count ;
314: x_msg_data := l_msg_data ;
308:
309: EXCEPTION
310: WHEN OKL_API.G_EXCEPTION_ERROR THEN
311: ROLLBACK TO trx_cleanup_pool_contents;
312: x_return_status := OKL_API.G_RET_STS_ERROR;
313: x_msg_count := l_msg_count ;
314: x_msg_data := l_msg_data ;
315: FND_MSG_PUB.count_and_get(
316: p_count => x_msg_count
314: x_msg_data := l_msg_data ;
315: FND_MSG_PUB.count_and_get(
316: p_count => x_msg_count
317: ,p_data => x_msg_data);
318: WHEN OKL_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
319: ROLLBACK TO trx_cleanup_pool_contents;
320: x_return_status := OKL_API.G_RET_STS_UNEXP_ERROR;
321: x_msg_count := l_msg_count ;
322: x_msg_data := l_msg_data ;
316: p_count => x_msg_count
317: ,p_data => x_msg_data);
318: WHEN OKL_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
319: ROLLBACK TO trx_cleanup_pool_contents;
320: x_return_status := OKL_API.G_RET_STS_UNEXP_ERROR;
321: x_msg_count := l_msg_count ;
322: x_msg_data := l_msg_data ;
323: FND_MSG_PUB.count_and_get(
324: p_count => x_msg_count
324: p_count => x_msg_count
325: ,p_data => x_msg_data);
326: WHEN OTHERS THEN
327: ROLLBACK TO trx_cleanup_pool_contents;
328: x_return_status := OKL_API.G_RET_STS_UNEXP_ERROR;
329: x_msg_count := l_msg_count ;
330: x_msg_data := l_msg_data ;
331: FND_MSG_PUB.ADD_EXC_MSG('OKL_POOL_PUB','cleanup_pool_contents');
332: FND_MSG_PUB.count_and_get(
400: x_msg_count => l_msg_count,
401: x_msg_data => l_msg_data
402: );
403:
404: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
405: RAISE OKL_API.G_EXCEPTION_ERROR;
406: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
407: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
408: END IF;
401: x_msg_data => l_msg_data
402: );
403:
404: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
405: RAISE OKL_API.G_EXCEPTION_ERROR;
406: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
407: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
408: END IF;
409:
402: );
403:
404: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
405: RAISE OKL_API.G_EXCEPTION_ERROR;
406: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
407: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
408: END IF;
409:
410: OKL_POOL_PVT.add_pool_contents(
403:
404: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
405: RAISE OKL_API.G_EXCEPTION_ERROR;
406: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
407: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
408: END IF;
409:
410: OKL_POOL_PVT.add_pool_contents(
411: p_api_version =>l_api_version
445: ,p_stream_element_payment_freq =>NULL
446: ,p_log_message =>p_log_message
447: );
448:
449: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
450: RAISE OKL_API.G_EXCEPTION_ERROR;
451: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
452: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
453: END IF;
446: ,p_log_message =>p_log_message
447: );
448:
449: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
450: RAISE OKL_API.G_EXCEPTION_ERROR;
451: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
452: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
453: END IF;
454:
447: );
448:
449: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
450: RAISE OKL_API.G_EXCEPTION_ERROR;
451: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
452: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
453: END IF;
454:
455:
448:
449: IF ( l_return_status = OKL_API.G_RET_STS_ERROR ) THEN
450: RAISE OKL_API.G_EXCEPTION_ERROR;
451: ELSIF (l_return_status = OKL_API.G_RET_STS_UNEXP_ERROR ) THEN
452: RAISE OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;
453: END IF;
454:
455:
456: --Assign value to OUT variables
460: x_row_count:=l_row_count;
461:
462:
463: EXCEPTION
464: WHEN OKL_API.G_EXCEPTION_ERROR THEN
465: ROLLBACK TO trx_add_pool_contents;
466: x_return_status := OKL_API.G_RET_STS_ERROR;
467: x_msg_count := l_msg_count ;
468: x_msg_data := l_msg_data ;
462:
463: EXCEPTION
464: WHEN OKL_API.G_EXCEPTION_ERROR THEN
465: ROLLBACK TO trx_add_pool_contents;
466: x_return_status := OKL_API.G_RET_STS_ERROR;
467: x_msg_count := l_msg_count ;
468: x_msg_data := l_msg_data ;
469: FND_MSG_PUB.count_and_get(
470: p_count => x_msg_count
468: x_msg_data := l_msg_data ;
469: FND_MSG_PUB.count_and_get(
470: p_count => x_msg_count
471: ,p_data => x_msg_data);
472: WHEN OKL_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
473: ROLLBACK TO trx_add_pool_contents;
474: x_return_status := OKL_API.G_RET_STS_UNEXP_ERROR;
475: x_msg_count := l_msg_count ;
476: x_msg_data := l_msg_data ;
470: p_count => x_msg_count
471: ,p_data => x_msg_data);
472: WHEN OKL_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
473: ROLLBACK TO trx_add_pool_contents;
474: x_return_status := OKL_API.G_RET_STS_UNEXP_ERROR;
475: x_msg_count := l_msg_count ;
476: x_msg_data := l_msg_data ;
477: FND_MSG_PUB.count_and_get(
478: p_count => x_msg_count
478: p_count => x_msg_count
479: ,p_data => x_msg_data);
480: WHEN OTHERS THEN
481: ROLLBACK TO trx_add_pool_contents;
482: x_return_status := OKL_API.G_RET_STS_UNEXP_ERROR;
483: x_msg_count := l_msg_count ;
484: x_msg_data := l_msg_data ;
485: FND_MSG_PUB.ADD_EXC_MSG('OKL_POOL_PUB','add_pool_contents');
486: FND_MSG_PUB.count_and_get(