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 810: okl_streams_pub.update_streams(

806: END LOOP;
807: --Bug# 4212626: end
808:
809: IF (l_orig_strm_tbl.COUNT > 0) THEN
810: okl_streams_pub.update_streams(
811: p_api_version => 1.0,
812: p_init_msg_list => OKC_API.G_FALSE,
813: x_return_status => x_return_status,
814: x_msg_count => x_msg_count,

Line 948: okl_streams_pub.update_streams(

944: l_orig_strm_tbl(l_orig_strm_count).date_history := SYSDATE;
945: END LOOP;
946:
947: IF (l_orig_strm_tbl.COUNT > 0) THEN
948: okl_streams_pub.update_streams(
949: p_api_version => 1.0,
950: p_init_msg_list => OKC_API.G_FALSE,
951: x_return_status => x_return_status,
952: x_msg_count => x_msg_count,

Line 1041: okl_streams_pub.create_streams(

1037: RAISE copy_failed;
1038: END IF;
1039:
1040: -- call API to create new streams
1041: okl_streams_pub.create_streams(
1042: p_api_version => 1.0,
1043: p_init_msg_list => OKC_API.G_FALSE,
1044: x_return_status => x_return_status,
1045: x_msg_count => x_msg_count,

Line 1198: okl_streams_pub.update_streams(

1194: ELSIF p_status = 'HIST' THEN
1195: l_stmv_rec.date_history := SYSDATE;
1196: END IF;
1197:
1198: okl_streams_pub.update_streams(
1199: p_api_version => 1.0,
1200: p_init_msg_list => OKC_API.G_FALSE,
1201: x_return_status => x_return_status,
1202: x_msg_count => x_msg_count,

Line 3987: okl_streams_pub.update_streams(

3983: l_orig_fee_strm_tbl(i).active_yn := 'N';
3984: l_orig_fee_strm_tbl(i).date_history := SYSDATE;
3985: END LOOP;
3986: IF (l_orig_fee_strm_tbl.COUNT <> 0) THEN
3987: okl_streams_pub.update_streams(
3988: p_api_version => 1.0,
3989: p_init_msg_list => OKC_API.G_FALSE,
3990: x_return_status => x_return_status,
3991: x_msg_count => x_msg_count,

Line 5946: okl_streams_pub.update_streams(

5942: l_disb_strm_tbl(i).date_history := SYSDATE;
5943: END LOOP;
5944:
5945: IF (l_disb_strm_tbl.COUNT > 0) THEN
5946: okl_streams_pub.update_streams(
5947: p_api_version => 1.0,
5948: p_init_msg_list => OKC_API.G_FALSE,
5949: x_return_status => x_return_status,
5950: x_msg_count => x_msg_count,

Line 6003: okl_streams_pub.update_streams(

5999: l_accu_strm_tbl(i).active_yn := 'N';
6000: END LOOP;
6001:
6002: IF (l_accu_strm_tbl.COUNT > 0) THEN
6003: okl_streams_pub.update_streams(
6004: p_api_version => 1.0,
6005: p_init_msg_list => OKC_API.G_FALSE,
6006: x_return_status => x_return_status,
6007: x_msg_count => x_msg_count,

Line 6966: okl_streams_pub.update_streams(

6962:
6963: IF (l_new_strm_tbl.COUNT > 0) THEN
6964:
6965: -- Call Streams api to update Link_Hist_Stream_Id and Trx_Id
6966: okl_streams_pub.update_streams(
6967: p_api_version => 1.0,
6968: p_init_msg_list => OKL_API.G_FALSE,
6969: x_return_status => x_return_status,
6970: x_msg_count => x_msg_count,

Line 7240: okl_streams_pub.update_stream_elements(

7236:
7237: END IF;
7238:
7239: IF (l_selv_tbl.COUNT > 0) THEN
7240: okl_streams_pub.update_stream_elements(
7241: p_api_version => 1.0,
7242: p_init_msg_list => OKL_API.G_FALSE,
7243: x_return_status => x_return_status,
7244: x_msg_count => x_msg_count,

Line 7591: okl_streams_pub.update_stream_elements(

7587:
7588: END IF;
7589:
7590: IF (l_selv_tbl.COUNT > 0) THEN
7591: okl_streams_pub.update_stream_elements(
7592: p_api_version => 1.0,
7593: p_init_msg_list => OKL_API.G_FALSE,
7594: x_return_status => x_return_status,
7595: x_msg_count => x_msg_count,

Line 7975: okl_streams_pub.update_stream_elements(

7971: debug_message('l_stream_tbl(i).kle_id: '||l_stream_tbl(i).kle_id);
7972: END IF;
7973:
7974: IF (l_selv_tbl.COUNT > 0) THEN
7975: okl_streams_pub.update_stream_elements(
7976: p_api_version => 1.0,
7977: p_init_msg_list => OKL_API.G_FALSE,
7978: x_return_status => x_return_status,
7979: x_msg_count => x_msg_count,

Line 8382: okl_streams_pub.update_stream_elements(

8378: END IF;
8379: END IF;
8380:
8381: IF (l_selv_tbl.COUNT > 0) THEN
8382: okl_streams_pub.update_stream_elements(
8383: p_api_version => 1.0,
8384: p_init_msg_list => OKL_API.G_FALSE,
8385: x_return_status => x_return_status,
8386: x_msg_count => x_msg_count,

Line 8617: l_stmv_rec_init Okl_Streams_pub.stmv_rec_type;

8613: INDEX BY BINARY_INTEGER;
8614:
8615: l_disb_adj_tbl disb_adj_tbl_type;
8616:
8617: l_stmv_rec_init Okl_Streams_pub.stmv_rec_type;
8618:
8619: l_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
8620: l_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
8621: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;

Line 8619: l_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;

8615: l_disb_adj_tbl disb_adj_tbl_type;
8616:
8617: l_stmv_rec_init Okl_Streams_pub.stmv_rec_type;
8618:
8619: l_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
8620: l_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
8621: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
8622: lx_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
8623:

Line 8620: l_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;

8616:
8617: l_stmv_rec_init Okl_Streams_pub.stmv_rec_type;
8618:
8619: l_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
8620: l_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
8621: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
8622: lx_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
8623:
8624: l_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;

Line 8621: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;

8617: l_stmv_rec_init Okl_Streams_pub.stmv_rec_type;
8618:
8619: l_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
8620: l_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
8621: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
8622: lx_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
8623:
8624: l_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;
8625: lx_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;

Line 8622: lx_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;

8618:
8619: l_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
8620: l_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
8621: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
8622: lx_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
8623:
8624: l_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;
8625: lx_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;
8626:

Line 8624: l_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;

8620: l_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
8621: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
8622: lx_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
8623:
8624: l_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;
8625: lx_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;
8626:
8627: l_selv_tbl selv_tbl_type;
8628: x_selv_tbl selv_tbl_type;

Line 8625: lx_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;

8621: lx_stmv_rec_new_disb Okl_Streams_pub.stmv_rec_type;
8622: lx_selv_tbl_new_disb Okl_Streams_pub.selv_tbl_type;
8623:
8624: l_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;
8625: lx_stmv_rec_old_disb Okl_Streams_pub.stmv_rec_type;
8626:
8627: l_selv_tbl selv_tbl_type;
8628: x_selv_tbl selv_tbl_type;
8629:

Line 8768: okl_streams_pub.update_stream_elements(

8764: 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);
8765: END IF;
8766:
8767: IF (l_selv_tbl.COUNT > 0) THEN
8768: okl_streams_pub.update_stream_elements(
8769: p_api_version => p_api_version,
8770: p_init_msg_list => p_init_msg_list,
8771: x_return_status => x_return_status,
8772: x_msg_count => x_msg_count,

Line 8852: Okl_Streams_Pub.update_streams(

8848: l_stmv_rec_old_disb.say_code := 'HIST';
8849: l_stmv_rec_old_disb.active_yn := 'N';
8850: l_stmv_rec_old_disb.date_history := SYSDATE;
8851:
8852: Okl_Streams_Pub.update_streams(
8853: p_api_version => p_api_version,
8854: p_init_msg_list => p_init_msg_list,
8855: x_return_status => x_return_status,
8856: x_msg_count => x_msg_count,

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

8859: x_stmv_rec => lx_stmv_rec_old_disb);
8860:
8861: IF (G_IS_DEBUG_STATEMENT_ON = true) THEN
8862: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'Historizing Existing Investor Disbursement Adjustment Stream');
8863: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'After calling OKL_STREAMS_PUB.update_streams'||x_return_status);
8864: END IF;
8865:
8866: IF (x_return_status = OKL_API.G_RET_STS_UNEXP_ERROR) then
8867: raise OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;

Line 8900: Okl_Streams_Pub.create_streams(

8896: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'Total Disb Adjustment Amount: '||l_selv_tbl_new_disb(1).amount);
8897: END IF;
8898:
8899: IF l_selv_tbl_new_disb(1).amount <> 0 THEN
8900: Okl_Streams_Pub.create_streams(
8901: p_api_version => p_api_version,
8902: p_init_msg_list => p_init_msg_list,
8903: x_return_status => x_return_status,
8904: x_msg_count => x_msg_count,

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

8909: x_selv_tbl => lx_selv_tbl_new_disb);
8910:
8911: IF (G_IS_DEBUG_STATEMENT_ON = true) THEN
8912: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'Creating New Investor Disbursement Adjustment Stream');
8913: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'After calling OKL_STREAMS_PUB.create_streams'||x_return_status);
8914: END IF;
8915:
8916: IF (x_return_status = OKL_API.G_RET_STS_UNEXP_ERROR) then
8917: raise OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;

Line 8944: Okl_Streams_Pub.update_streams(

8940: l_stmv_rec_old_disb.say_code := 'HIST';
8941: l_stmv_rec_old_disb.active_yn := 'N';
8942: l_stmv_rec_old_disb.date_history := SYSDATE;
8943:
8944: Okl_Streams_Pub.update_streams(
8945: p_api_version => p_api_version,
8946: p_init_msg_list => p_init_msg_list,
8947: x_return_status => x_return_status,
8948: x_msg_count => x_msg_count,

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

8951: x_stmv_rec => lx_stmv_rec_old_disb);
8952:
8953: IF (G_IS_DEBUG_STATEMENT_ON = true) THEN
8954: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'Historizing Existing Investor Disbursement Adjustment Stream');
8955: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'After calling OKL_STREAMS_PUB.update_streams'||x_return_status);
8956: END IF;
8957:
8958: IF (x_return_status = OKL_API.G_RET_STS_UNEXP_ERROR) then
8959: raise OKL_API.G_EXCEPTION_UNEXPECTED_ERROR;

Line 9207: okl_streams_pub.update_streams(

9203:
9204: IF (l_new_strm_tbl.COUNT > 0) THEN
9205:
9206: -- Call Streams api to update Link_Hist_Stream_Id and Trx_Id
9207: okl_streams_pub.update_streams(
9208: p_api_version => 1.0,
9209: p_init_msg_list => OKL_API.G_FALSE,
9210: x_return_status => x_return_status,
9211: x_msg_count => x_msg_count,

Line 9465: okl_streams_pub.update_stream_elements(

9461: END IF;
9462: END IF;
9463:
9464: IF (l_selv_tbl.COUNT > 0) THEN
9465: okl_streams_pub.update_stream_elements(
9466: p_api_version => 1.0,
9467: p_init_msg_list => OKL_API.G_FALSE,
9468: x_return_status => x_return_status,
9469: x_msg_count => x_msg_count,