DBA Data[Home] [Help]

APPS.OKL_CONTRACT_REBOOK_PVT dependencies on OKL_STREAMS_PUB

Line 18: SUBTYPE stmv_rec_type IS OKL_STREAMS_PUB.stmv_rec_type;

14: --Bug# 4212626
15: G_INSURANCE_LSE_ID CONSTANT NUMBER := 47;
16:
17: -- subtype tcnv_rec_type IS OKL_TRX_CONTRACTS_PVT.tcnv_rec_type;
18: SUBTYPE stmv_rec_type IS OKL_STREAMS_PUB.stmv_rec_type;
19: SUBTYPE stmv_tbl_type IS OKL_STREAMS_PUB.stmv_tbl_type;
20: SUBTYPE selv_rec_type IS OKL_STREAMS_PUB.selv_rec_type;
21: SUBTYPE selv_tbl_type IS OKL_STREAMS_PUB.selv_tbl_type;
22: SUBTYPE khrv_rec_type IS OKL_CONTRACT_PUB.khrv_rec_type;

Line 19: SUBTYPE stmv_tbl_type IS OKL_STREAMS_PUB.stmv_tbl_type;

15: G_INSURANCE_LSE_ID CONSTANT NUMBER := 47;
16:
17: -- subtype tcnv_rec_type IS OKL_TRX_CONTRACTS_PVT.tcnv_rec_type;
18: SUBTYPE stmv_rec_type IS OKL_STREAMS_PUB.stmv_rec_type;
19: SUBTYPE stmv_tbl_type IS OKL_STREAMS_PUB.stmv_tbl_type;
20: SUBTYPE selv_rec_type IS OKL_STREAMS_PUB.selv_rec_type;
21: SUBTYPE selv_tbl_type IS OKL_STREAMS_PUB.selv_tbl_type;
22: SUBTYPE khrv_rec_type IS OKL_CONTRACT_PUB.khrv_rec_type;
23: SUBTYPE chrv_rec_type IS OKL_OKC_MIGRATION_PVT.chrv_rec_type;

Line 20: SUBTYPE selv_rec_type IS OKL_STREAMS_PUB.selv_rec_type;

16:
17: -- subtype tcnv_rec_type IS OKL_TRX_CONTRACTS_PVT.tcnv_rec_type;
18: SUBTYPE stmv_rec_type IS OKL_STREAMS_PUB.stmv_rec_type;
19: SUBTYPE stmv_tbl_type IS OKL_STREAMS_PUB.stmv_tbl_type;
20: SUBTYPE selv_rec_type IS OKL_STREAMS_PUB.selv_rec_type;
21: SUBTYPE selv_tbl_type IS OKL_STREAMS_PUB.selv_tbl_type;
22: SUBTYPE khrv_rec_type IS OKL_CONTRACT_PUB.khrv_rec_type;
23: SUBTYPE chrv_rec_type IS OKL_OKC_MIGRATION_PVT.chrv_rec_type;
24: SUBTYPE clev_tbl_type IS OKL_OKC_MIGRATION_PVT.clev_tbl_type;

Line 21: SUBTYPE selv_tbl_type IS OKL_STREAMS_PUB.selv_tbl_type;

17: -- subtype tcnv_rec_type IS OKL_TRX_CONTRACTS_PVT.tcnv_rec_type;
18: SUBTYPE stmv_rec_type IS OKL_STREAMS_PUB.stmv_rec_type;
19: SUBTYPE stmv_tbl_type IS OKL_STREAMS_PUB.stmv_tbl_type;
20: SUBTYPE selv_rec_type IS OKL_STREAMS_PUB.selv_rec_type;
21: SUBTYPE selv_tbl_type IS OKL_STREAMS_PUB.selv_tbl_type;
22: SUBTYPE khrv_rec_type IS OKL_CONTRACT_PUB.khrv_rec_type;
23: SUBTYPE chrv_rec_type IS OKL_OKC_MIGRATION_PVT.chrv_rec_type;
24: SUBTYPE clev_tbl_type IS OKL_OKC_MIGRATION_PVT.clev_tbl_type;
25: SUBTYPE klev_tbl_type IS OKL_CONTRACT_PUB.klev_tbl_type;

Line 839: okl_streams_pub.update_streams(

835: END LOOP;
836: --Bug# 4212626: end
837:
838: IF (l_orig_strm_tbl.COUNT > 0) THEN
839: okl_streams_pub.update_streams(
840: p_api_version => 1.0,
841: p_init_msg_list => OKC_API.G_FALSE,
842: x_return_status => x_return_status,
843: x_msg_count => x_msg_count,

Line 977: okl_streams_pub.update_streams(

973: l_orig_strm_tbl(l_orig_strm_count).date_history := SYSDATE;
974: END LOOP;
975:
976: IF (l_orig_strm_tbl.COUNT > 0) THEN
977: okl_streams_pub.update_streams(
978: p_api_version => 1.0,
979: p_init_msg_list => OKC_API.G_FALSE,
980: x_return_status => x_return_status,
981: x_msg_count => x_msg_count,

Line 1070: okl_streams_pub.create_streams(

1066: RAISE copy_failed;
1067: END IF;
1068:
1069: -- call API to create new streams
1070: okl_streams_pub.create_streams(
1071: p_api_version => 1.0,
1072: p_init_msg_list => OKC_API.G_FALSE,
1073: x_return_status => x_return_status,
1074: x_msg_count => x_msg_count,

Line 1227: okl_streams_pub.update_streams(

1223: ELSIF p_status = 'HIST' THEN
1224: l_stmv_rec.date_history := SYSDATE;
1225: END IF;
1226:
1227: okl_streams_pub.update_streams(
1228: p_api_version => 1.0,
1229: p_init_msg_list => OKC_API.G_FALSE,
1230: x_return_status => x_return_status,
1231: x_msg_count => x_msg_count,

Line 3710: okl_streams_pub.update_streams(

3706: l_orig_fee_strm_tbl(i).active_yn := 'N';
3707: l_orig_fee_strm_tbl(i).date_history := SYSDATE;
3708: END LOOP;
3709: IF (l_orig_fee_strm_tbl.COUNT <> 0) THEN
3710: okl_streams_pub.update_streams(
3711: p_api_version => 1.0,
3712: p_init_msg_list => OKC_API.G_FALSE,
3713: x_return_status => x_return_status,
3714: x_msg_count => x_msg_count,

Line 7607: okl_streams_pub.update_streams(

7603: l_disb_strm_tbl(i).date_history := SYSDATE;
7604: END LOOP;
7605:
7606: IF (l_disb_strm_tbl.COUNT > 0) THEN
7607: okl_streams_pub.update_streams(
7608: p_api_version => 1.0,
7609: p_init_msg_list => OKC_API.G_FALSE,
7610: x_return_status => x_return_status,
7611: x_msg_count => x_msg_count,

Line 7664: okl_streams_pub.update_streams(

7660: l_accu_strm_tbl(i).active_yn := 'N';
7661: END LOOP;
7662:
7663: IF (l_accu_strm_tbl.COUNT > 0) THEN
7664: okl_streams_pub.update_streams(
7665: p_api_version => 1.0,
7666: p_init_msg_list => OKC_API.G_FALSE,
7667: x_return_status => x_return_status,
7668: x_msg_count => x_msg_count,

Line 8635: okl_streams_pub.update_streams(

8631:
8632: IF (l_new_strm_tbl.COUNT > 0) THEN
8633:
8634: -- Call Streams api to update Link_Hist_Stream_Id and Trx_Id
8635: okl_streams_pub.update_streams(
8636: p_api_version => 1.0,
8637: p_init_msg_list => OKL_API.G_FALSE,
8638: x_return_status => x_return_status,
8639: x_msg_count => x_msg_count,

Line 8909: okl_streams_pub.update_stream_elements(

8905:
8906: END IF;
8907:
8908: IF (l_selv_tbl.COUNT > 0) THEN
8909: okl_streams_pub.update_stream_elements(
8910: p_api_version => 1.0,
8911: p_init_msg_list => OKL_API.G_FALSE,
8912: x_return_status => x_return_status,
8913: x_msg_count => x_msg_count,

Line 9265: okl_streams_pub.update_stream_elements(

9261:
9262: END IF;
9263:
9264: IF (l_selv_tbl.COUNT > 0) THEN
9265: okl_streams_pub.update_stream_elements(
9266: p_api_version => 1.0,
9267: p_init_msg_list => OKL_API.G_FALSE,
9268: x_return_status => x_return_status,
9269: x_msg_count => x_msg_count,

Line 9649: okl_streams_pub.update_stream_elements(

9645: debug_message('l_stream_tbl(i).kle_id: '||l_stream_tbl(i).kle_id);
9646: END IF;
9647:
9648: IF (l_selv_tbl.COUNT > 0) THEN
9649: okl_streams_pub.update_stream_elements(
9650: p_api_version => 1.0,
9651: p_init_msg_list => OKL_API.G_FALSE,
9652: x_return_status => x_return_status,
9653: x_msg_count => x_msg_count,

Line 10056: okl_streams_pub.update_stream_elements(

10052: END IF;
10053: END IF;
10054:
10055: IF (l_selv_tbl.COUNT > 0) THEN
10056: okl_streams_pub.update_stream_elements(
10057: p_api_version => 1.0,
10058: p_init_msg_list => OKL_API.G_FALSE,
10059: x_return_status => x_return_status,
10060: x_msg_count => x_msg_count,

Line 10291: l_stmv_rec_init Okl_Streams_pub.stmv_rec_type;

10287: INDEX BY BINARY_INTEGER;
10288:
10289: l_disb_adj_tbl disb_adj_tbl_type;
10290:
10291: l_stmv_rec_init Okl_Streams_pub.stmv_rec_type;
10292:
10293: l_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
10294: l_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
10295: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;

Line 10293: l_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;

10289: l_disb_adj_tbl disb_adj_tbl_type;
10290:
10291: l_stmv_rec_init Okl_Streams_pub.stmv_rec_type;
10292:
10293: l_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
10294: l_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
10295: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
10296: lx_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
10297:

Line 10294: l_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;

10290:
10291: l_stmv_rec_init Okl_Streams_pub.stmv_rec_type;
10292:
10293: l_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
10294: l_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
10295: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
10296: lx_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
10297:
10298: l_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;

Line 10295: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;

10291: l_stmv_rec_init Okl_Streams_pub.stmv_rec_type;
10292:
10293: l_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
10294: l_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
10295: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
10296: lx_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
10297:
10298: l_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;
10299: lx_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;

Line 10296: lx_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;

10292:
10293: l_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
10294: l_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
10295: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
10296: lx_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
10297:
10298: l_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;
10299: lx_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;
10300:

Line 10298: l_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;

10294: l_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
10295: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
10296: lx_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
10297:
10298: l_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;
10299: lx_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;
10300:
10301: l_selv_tbl selv_tbl_type;
10302: x_selv_tbl selv_tbl_type;

Line 10299: lx_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;

10295: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
10296: lx_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
10297:
10298: l_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;
10299: lx_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;
10300:
10301: l_selv_tbl selv_tbl_type;
10302: x_selv_tbl selv_tbl_type;
10303:

Line 10442: okl_streams_pub.update_stream_elements(

10438: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'l_disb_adj_tbl(i).disb_adj_amt: '||l_disb_adj_tbl(i).disb_adj_amt);
10439: END IF;
10440:
10441: IF (l_selv_tbl.COUNT > 0) THEN
10442: okl_streams_pub.update_stream_elements(
10443: p_api_version => p_api_version,
10444: p_init_msg_list => p_init_msg_list,
10445: x_return_status => x_return_status,
10446: x_msg_count => x_msg_count,

Line 10526: Okl_Streams_Pub.update_streams(

10522: l_stmv_rec_old_disb.say_code := 'HIST';
10523: l_stmv_rec_old_disb.active_yn := 'N';
10524: l_stmv_rec_old_disb.date_history := SYSDATE;
10525:
10526: Okl_Streams_Pub.update_streams(
10527: p_api_version => p_api_version,
10528: p_init_msg_list => p_init_msg_list,
10529: x_return_status => x_return_status,
10530: x_msg_count => x_msg_count,

Line 10537: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'After calling OKL_STREAMS_PUB.update_streams'||x_return_status);

10533: x_stmv_rec => lx_stmv_rec_old_disb);
10534:
10535: IF (G_IS_DEBUG_STATEMENT_ON = true) THEN
10536: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'Historizing Existing Investor Disbursement Adjustment Stream');
10537: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'After calling OKL_STREAMS_PUB.update_streams'||x_return_status);
10538: END IF;
10539:
10540: IF (x_return_status = OKL_API.G_RET_STS_UNEXP_ERROR) then
10541: raise OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;

Line 10574: Okl_Streams_Pub.create_streams(

10570: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'Total Disb Adjustment Amount: '||l_selv_tbl_new_disb(1).amount);
10571: END IF;
10572:
10573: IF l_selv_tbl_new_disb(1).amount <> 0 THEN
10574: Okl_Streams_Pub.create_streams(
10575: p_api_version => p_api_version,
10576: p_init_msg_list => p_init_msg_list,
10577: x_return_status => x_return_status,
10578: x_msg_count => x_msg_count,

Line 10587: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'After calling OKL_STREAMS_PUB.create_streams'||x_return_status);

10583: x_selv_tbl => lx_selv_tbl_new_disb);
10584:
10585: IF (G_IS_DEBUG_STATEMENT_ON = true) THEN
10586: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'Creating New Investor Disbursement Adjustment Stream');
10587: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'After calling OKL_STREAMS_PUB.create_streams'||x_return_status);
10588: END IF;
10589:
10590: IF (x_return_status = OKL_API.G_RET_STS_UNEXP_ERROR) then
10591: raise OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;

Line 10618: Okl_Streams_Pub.update_streams(

10614: l_stmv_rec_old_disb.say_code := 'HIST';
10615: l_stmv_rec_old_disb.active_yn := 'N';
10616: l_stmv_rec_old_disb.date_history := SYSDATE;
10617:
10618: Okl_Streams_Pub.update_streams(
10619: p_api_version => p_api_version,
10620: p_init_msg_list => p_init_msg_list,
10621: x_return_status => x_return_status,
10622: x_msg_count => x_msg_count,

Line 10629: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'After calling OKL_STREAMS_PUB.update_streams'||x_return_status);

10625: x_stmv_rec => lx_stmv_rec_old_disb);
10626:
10627: IF (G_IS_DEBUG_STATEMENT_ON = true) THEN
10628: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'Historizing Existing Investor Disbursement Adjustment Stream');
10629: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'After calling OKL_STREAMS_PUB.update_streams'||x_return_status);
10630: END IF;
10631:
10632: IF (x_return_status = OKL_API.G_RET_STS_UNEXP_ERROR) then
10633: raise OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;

Line 11008: okl_streams_pub.update_streams(

11004:
11005: IF (l_new_strm_tbl.COUNT > 0) THEN
11006:
11007: -- Call Streams api to update Link_Hist_Stream_Id and Trx_Id
11008: okl_streams_pub.update_streams(
11009: p_api_version => 1.0,
11010: p_init_msg_list => OKL_API.G_FALSE,
11011: x_return_status => x_return_status,
11012: x_msg_count => x_msg_count,

Line 11075: okl_streams_pub.update_streams(

11071:
11072: IF (l_new_strm_sec_tbl.COUNT > 0) THEN
11073:
11074: -- Call Streams api to update Link_Hist_Stream_Id and Trx_Id
11075: okl_streams_pub.update_streams(
11076: p_api_version => 1.0,
11077: p_init_msg_list => OKL_API.G_FALSE,
11078: x_return_status => x_return_status,
11079: x_msg_count => x_msg_count,

Line 11336: okl_streams_pub.update_stream_elements(

11332: END IF;
11333: END IF;
11334:
11335: IF (l_selv_tbl.COUNT > 0) THEN
11336: okl_streams_pub.update_stream_elements(
11337: p_api_version => 1.0,
11338: p_init_msg_list => OKL_API.G_FALSE,
11339: x_return_status => x_return_status,
11340: x_msg_count => x_msg_count,