eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.OKL_CONTRACT_REBOOK_PVT dependencies on OKL_STREAMS

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 552: FROM okl_streams str,

548: --Bug# 4212626
549: trx_id,
550: link_hist_stream_id
551: -- sty_code -- dropped after inclusion
552: FROM okl_streams str,
553: okl_strm_type_v sty
554: WHERE str.khr_id = p_rebook_chr_id
555: AND str.sty_id = sty.id
556: AND str.say_code = 'CURR';

Line 562: p_sty_id OKL_STREAMS.sty_id%TYPE,

558:
559: -- Bug# 2857333
560: CURSOR orig_strm_csr (p_khr_id OKC_K_HEADERS_V.ID%TYPE,
561: p_kle_id OKC_K_LINES_V.ID%TYPE,
562: p_sty_id OKL_STREAMS.sty_id%TYPE,
563: p_purpose_code OKL_STREAMS.PURPOSE_CODE%TYPE) IS
564: SELECT id
565: FROM okl_streams
566: WHERE khr_id = p_khr_id

Line 563: p_purpose_code OKL_STREAMS.PURPOSE_CODE%TYPE) IS

559: -- Bug# 2857333
560: CURSOR orig_strm_csr (p_khr_id OKC_K_HEADERS_V.ID%TYPE,
561: p_kle_id OKC_K_LINES_V.ID%TYPE,
562: p_sty_id OKL_STREAMS.sty_id%TYPE,
563: p_purpose_code OKL_STREAMS.PURPOSE_CODE%TYPE) IS
564: SELECT id
565: FROM okl_streams
566: WHERE khr_id = p_khr_id
567: AND sty_id = p_sty_id

Line 565: FROM okl_streams

561: p_kle_id OKC_K_LINES_V.ID%TYPE,
562: p_sty_id OKL_STREAMS.sty_id%TYPE,
563: p_purpose_code OKL_STREAMS.PURPOSE_CODE%TYPE) IS
564: SELECT id
565: FROM okl_streams
566: WHERE khr_id = p_khr_id
567: AND sty_id = p_sty_id
568: AND NVL(kle_id,-1) = NVL(p_kle_id, -1)
569: AND say_code <> 'HIST'

Line 593: okl_streams str,

589: CURSOR unbill_adj_csr( khrId NUMBER,
590: kleid NUMBER ) IS
591: SELECT NVL(ele.amount,0) amount
592: FROM okl_strm_elements ele,
593: okl_streams str,
594: --okl_strm_type_tl sty
595: okl_strm_type_v sty
596: WHERE NVL(str.kle_id,-1) = kleid
597: AND str.khr_id = khrId

Line 611: okl_streams str,

607: CURSOR undesb_adj_csr( khrId NUMBER,
608: kleid NUMBER ) IS
609: SELECT NVL(ele.amount,0) amount
610: FROM okl_strm_elements ele,
611: okl_streams str,
612: --okl_strm_type_tl sty
613: okl_strm_type_v sty
614: WHERE NVL(str.kle_id,-1) = kleid
615: AND str.khr_id = khrId

Line 652: FROM okl_streams orig_stm,

648: p_rebook_chr_id IN NUMBER) IS
649: SELECT orig_stm.id orig_stm_id,
650: sty.stream_type_purpose,
651: cle.lse_id
652: FROM okl_streams orig_stm,
653: okc_k_lines_b cle,
654: okl_strm_type_v sty
655: WHERE orig_stm.khr_id = p_orig_chr_id
656: AND orig_stm.say_code = 'CURR'

Line 663: FROM okl_streams new_stm

659: AND cle.id(+) = orig_stm.kle_id
660: AND cle.dnz_chr_id(+) = orig_stm.khr_id
661: AND sty.id = orig_stm.sty_id
662: AND NOT EXISTS (SELECT 1
663: FROM okl_streams new_stm
664: WHERE new_stm.khr_id = p_rebook_chr_id
665: AND new_stm.say_code = 'CURR'
666: AND new_stm.link_hist_stream_id = orig_stm.id);
667:

Line 692: OKL_STREAMS_UTIL.get_primary_stream_type(

688: /*
689: * Not required, got purpose from driving cursor strm_hdr_csr
690: *
691: -- Get Stream id for purpose = BILLING ADJUSTMENT
692: OKL_STREAMS_UTIL.get_primary_stream_type(
693: p_khr_id => p_orig_chr_id,
694: p_primary_sty_purpose => 'REBOOK_BILLING_ADJUSTMENT',
695: x_return_status => x_return_status,
696: x_primary_sty_id => x_billing_adj_sty_id

Line 709: OKL_STREAMS_UTIL.get_primary_stream_type(

705: OPEN inv_adj_csr;
706: FETCH inv_adj_csr INTO x_inv_disb_adj_sty_id;
707: CLOSE inv_adj_csr;
708:
709: OKL_STREAMS_UTIL.get_primary_stream_type(
710: p_khr_id => p_orig_chr_id,
711: p_primary_sty_purpose => 'INVESTOR_DISB_ADJUSTMENT',
712: x_return_status => x_return_status,
713: x_primary_sty_id => x_inv_disb_adj_sty_id

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 1150: FROM okl_streams

1146: l_id NUMBER;
1147:
1148: CURSOR strm_csr (p_chr_id OKC_K_HEADERS_V.ID%TYPE) IS
1149: SELECT id
1150: FROM okl_streams
1151: WHERE khr_id = p_chr_id
1152: -- BUg 4737555
1153: -- AND SGN_CODE <> 'INTC';
1154: AND SGN_CODE NOT IN ('INTC','LATE_CALC'); -- Bug 6472228

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 3561: FROM okl_streams

3557: AND line.orig_system_id1 IS NULL;
3558:
3559: CURSOR orig_fee_strm_csr (p_kle_id OKC_K_LINES_V.ID%TYPE) IS
3560: SELECT id
3561: FROM okl_streams
3562: WHERE kle_id = p_kle_id
3563: AND say_code <> 'HIST';
3564:
3565: CURSOR txn_csr (p_chr_id OKC_K_HEADERS_V.ID%TYPE) IS

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 5848: FROM okl_streams strm,

5844: AND representation_type = 'PRIMARY'; -- MGAAP 7263041
5845:
5846: CURSOR disb_strm_csr (p_chr_id OKC_K_HEADERS_V.ID%TYPE) IS
5847: SELECT strm.id
5848: FROM okl_streams strm,
5849: okl_strm_type_v TYPE
5850: WHERE TYPE.id = strm.sty_id
5851: AND TYPE.stream_type_subclass = 'INVESTOR_DISBURSEMENT'
5852: AND strm.khr_id = p_chr_id

Line 5857: FROM okl_streams strm,

5853: AND strm.say_code = 'CURR';
5854:
5855: CURSOR accu_strm_csr (p_chr_id OKC_K_HEADERS_V.ID%TYPE) IS
5856: SELECT strm.id
5857: FROM okl_streams strm,
5858: okl_strm_type_v TYPE
5859: WHERE TYPE.id = strm.sty_id
5860: /*
5861: AND TYPE.name IN (

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 6113: p_stream_status IN OKL_STREAMS.SAY_CODE%TYPE

6109: x_return_status OUT NOCOPY VARCHAR2,
6110: x_msg_count OUT NOCOPY NUMBER,
6111: x_msg_data OUT NOCOPY VARCHAR2,
6112: p_chr_id IN OKC_K_HEADERS_V.ID%TYPE,
6113: p_stream_status IN OKL_STREAMS.SAY_CODE%TYPE
6114: ) IS
6115:
6116: l_api_name VARCHAR2(35) := 'sync_rebook_stream';
6117: l_proc_name VARCHAR2(35) := 'SYNC_REBOOK_STREAM';

Line 6292: OKL_STREAMS_SEC_PVT.RESET_REPO_STREAMS; -- MGAAP 7263041

6288:
6289: --
6290: -- Create Investor Accrual Adjustment
6291: --
6292: OKL_STREAMS_SEC_PVT.RESET_REPO_STREAMS; -- MGAAP 7263041
6293: IF (G_IS_DEBUG_STATEMENT_ON = true) THEN
6294: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'Before call calc_inv_acc_adjustment');
6295: END IF;
6296: calc_inv_acc_adjustment(

Line 6347: OKL_STREAMS_SEC_PVT.SET_REPO_STREAMS;

6343: -- MGAAP start 7263041
6344:
6345: IF (l_rbk_trx_rec.multi_gaap_yn = 'Y') THEN
6346:
6347: OKL_STREAMS_SEC_PVT.SET_REPO_STREAMS;
6348:
6349: IF (G_IS_DEBUG_STATEMENT_ON = true) THEN
6350: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'Before call calc_inv_acc_adjustment for SECONDARY');
6351: END IF;

Line 6365: OKL_STREAMS_SEC_PVT.RESET_REPO_STREAMS;

6361: x_inv_accrual_rec => l_inv_accrual_rec,
6362: x_inv_stream_tbl => l_inv_stream_tbl,
6363: p_product_id => l_rbk_trx_rec.reporting_pdt_id
6364: );
6365: OKL_STREAMS_SEC_PVT.RESET_REPO_STREAMS;
6366: IF (G_IS_DEBUG_STATEMENT_ON = true) THEN
6367: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'After call calc_inv_acc_adjustment'||x_return_status);
6368: END IF;
6369:

Line 6765: FROM okl_streams new_stm

6761:
6762: CURSOR curr_streams_csr(p_khr_id IN NUMBER) IS
6763: SELECT new_stm.id new_stm_id,
6764: new_stm.kle_id
6765: FROM okl_streams new_stm
6766: WHERE new_stm.khr_id = p_khr_id
6767: AND new_stm.say_code = 'WORK';
6768:
6769: CURSOR ol_rbk_kle_hist_strms_csr(p_new_stm_id IN NUMBER,

Line 6773: FROM okl_streams new_stm,

6769: CURSOR ol_rbk_kle_hist_strms_csr(p_new_stm_id IN NUMBER,
6770: p_rbk_khr_id IN NUMBER,
6771: p_orig_khr_id IN NUMBER) IS
6772: SELECT orig_stm.id orig_stm_id
6773: FROM okl_streams new_stm,
6774: okc_k_lines_b cle,
6775: okl_streams orig_stm
6776: WHERE new_stm.id = p_new_stm_id
6777: AND cle.id = new_stm.kle_id

Line 6775: okl_streams orig_stm

6771: p_orig_khr_id IN NUMBER) IS
6772: SELECT orig_stm.id orig_stm_id
6773: FROM okl_streams new_stm,
6774: okc_k_lines_b cle,
6775: okl_streams orig_stm
6776: WHERE new_stm.id = p_new_stm_id
6777: AND cle.id = new_stm.kle_id
6778: AND cle.dnz_chr_id = p_rbk_khr_id
6779: AND orig_stm.khr_id = p_orig_khr_id

Line 6788: FROM okl_streams new_stm,

6784:
6785: CURSOR ol_rbk_khr_hist_strms_csr(p_new_stm_id IN NUMBER,
6786: p_orig_khr_id IN NUMBER) IS
6787: SELECT orig_stm.id orig_stm_id
6788: FROM okl_streams new_stm,
6789: okl_streams orig_stm
6790: WHERE new_stm.id = p_new_stm_id
6791: AND orig_stm.khr_id = p_orig_khr_id
6792: AND orig_stm.kle_id IS NULL

Line 6789: okl_streams orig_stm

6785: CURSOR ol_rbk_khr_hist_strms_csr(p_new_stm_id IN NUMBER,
6786: p_orig_khr_id IN NUMBER) IS
6787: SELECT orig_stm.id orig_stm_id
6788: FROM okl_streams new_stm,
6789: okl_streams orig_stm
6790: WHERE new_stm.id = p_new_stm_id
6791: AND orig_stm.khr_id = p_orig_khr_id
6792: AND orig_stm.kle_id IS NULL
6793: AND orig_stm.sty_id = new_stm.sty_id

Line 6797: l_orig_stm_id OKL_STREAMS.ID%TYPE;

6793: AND orig_stm.sty_id = new_stm.sty_id
6794: AND NVL(orig_stm.purpose_code,'ORIG') = NVL(new_stm.purpose_code,'ORIG')
6795: AND orig_stm.say_code = 'CURR';
6796:
6797: l_orig_stm_id OKL_STREAMS.ID%TYPE;
6798:
6799: CURSOR mass_rbk_hist_strms_csr(p_new_stm_id IN NUMBER,
6800: p_khr_id IN NUMBER) IS
6801: SELECT orig_stm.id orig_stm_id

Line 6802: FROM okl_streams new_stm,

6798:
6799: CURSOR mass_rbk_hist_strms_csr(p_new_stm_id IN NUMBER,
6800: p_khr_id IN NUMBER) IS
6801: SELECT orig_stm.id orig_stm_id
6802: FROM okl_streams new_stm,
6803: okl_streams orig_stm
6804: WHERE new_stm.id = p_new_stm_id
6805: AND orig_stm.khr_id = new_stm.khr_id
6806: AND NVL(orig_stm.kle_id,-1) = NVL(new_stm.kle_id,-1)

Line 6803: okl_streams orig_stm

6799: CURSOR mass_rbk_hist_strms_csr(p_new_stm_id IN NUMBER,
6800: p_khr_id IN NUMBER) IS
6801: SELECT orig_stm.id orig_stm_id
6802: FROM okl_streams new_stm,
6803: okl_streams orig_stm
6804: WHERE new_stm.id = p_new_stm_id
6805: AND orig_stm.khr_id = new_stm.khr_id
6806: AND NVL(orig_stm.kle_id,-1) = NVL(new_stm.kle_id,-1)
6807: AND orig_stm.sty_id = new_stm.sty_id

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 7056: FROM okl_streams new_stm,

7052: SELECT new_stm.id new_stm_id,
7053: orig_stm.id orig_stm_id,
7054: orig_stm.sty_id,
7055: orig_stm.kle_id
7056: FROM okl_streams new_stm,
7057: okl_strm_type_b sty,
7058: okl_streams orig_stm,
7059: okl_party_payment_hdr pph
7060: WHERE new_stm.khr_id = p_khr_id

Line 7058: okl_streams orig_stm,

7054: orig_stm.sty_id,
7055: orig_stm.kle_id
7056: FROM okl_streams new_stm,
7057: okl_strm_type_b sty,
7058: okl_streams orig_stm,
7059: okl_party_payment_hdr pph
7060: WHERE new_stm.khr_id = p_khr_id
7061: AND new_stm.say_code = 'CURR'
7062: AND new_stm.sty_id = sty.id

Line 7097: FROM okl_streams orig_stm,

7093: SELECT orig_stm.id orig_stm_id,
7094: orig_stm.sty_id,
7095: orig_stm.kle_id,
7096: cle.lse_id
7097: FROM okl_streams orig_stm,
7098: okl_strm_type_b sty,
7099: okc_k_lines_b cle,
7100: okl_party_payment_hdr pph
7101: WHERE orig_stm.khr_id = p_orig_khr_id

Line 7113: FROM okl_streams new_stm

7109: AND pph.cle_id = orig_stm.kle_id
7110: AND pph.payout_basis = 'DUE_DATE'
7111: AND pph.passthru_term = 'BASE'
7112: AND NOT EXISTS (SELECT 1
7113: FROM okl_streams new_stm
7114: WHERE new_stm.khr_id = p_rbk_khr_id
7115: AND new_stm.say_code = 'CURR'
7116: AND new_stm.link_hist_stream_id = orig_stm.id);
7117:

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 7413: FROM okl_streams new_stm,

7409: SELECT new_stm.id new_stm_id,
7410: orig_stm.id orig_stm_id,
7411: orig_stm.sty_id,
7412: orig_stm.kle_id
7413: FROM okl_streams new_stm,
7414: okl_strm_type_b sty,
7415: okl_streams orig_stm
7416: WHERE new_stm.khr_id = p_khr_id
7417: AND new_stm.say_code = 'CURR'

Line 7415: okl_streams orig_stm

7411: orig_stm.sty_id,
7412: orig_stm.kle_id
7413: FROM okl_streams new_stm,
7414: okl_strm_type_b sty,
7415: okl_streams orig_stm
7416: WHERE new_stm.khr_id = p_khr_id
7417: AND new_stm.say_code = 'CURR'
7418: AND new_stm.sty_id = sty.id
7419: AND sty.billable_yn = 'Y'

Line 7449: FROM okl_streams orig_stm,

7445: SELECT orig_stm.id orig_stm_id,
7446: orig_stm.sty_id,
7447: orig_stm.kle_id,
7448: cle.lse_id
7449: FROM okl_streams orig_stm,
7450: okl_strm_type_b sty,
7451: okc_k_lines_b cle
7452: WHERE orig_stm.khr_id = p_orig_khr_id
7453: AND orig_stm.say_code = 'CURR'

Line 7463: FROM okl_streams new_stm

7459: AND sty.billable_yn = 'Y'
7460: AND cle.id(+) = orig_stm.kle_id
7461: AND cle.dnz_chr_id(+) = orig_stm.khr_id
7462: AND NOT EXISTS (SELECT 1
7463: FROM okl_streams new_stm
7464: WHERE new_stm.khr_id = p_rbk_khr_id
7465: AND new_stm.say_code = 'CURR'
7466: AND new_stm.link_hist_stream_id = orig_stm.id);
7467:

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 7805: FROM okl_streams new_stm,

7801: orig_stm.id orig_stm_id,
7802: orig_stm.sty_id,
7803: orig_stm.kle_id,
7804: styt.name
7805: FROM okl_streams new_stm,
7806: okl_prod_strm_types psty,
7807: okl_k_headers khr,
7808: okl_streams orig_stm,
7809: okl_strm_type_tl styt

Line 7808: okl_streams orig_stm,

7804: styt.name
7805: FROM okl_streams new_stm,
7806: okl_prod_strm_types psty,
7807: okl_k_headers khr,
7808: okl_streams orig_stm,
7809: okl_strm_type_tl styt
7810: WHERE khr.id = p_khr_id
7811: AND psty.pdt_id = khr.pdt_id
7812: AND psty.accrual_yn = 'Y'

Line 7848: FROM okl_streams orig_stm,

7844: orig_stm.sty_id,
7845: orig_stm.kle_id,
7846: styt.name,
7847: cle.lse_id
7848: FROM okl_streams orig_stm,
7849: okl_prod_strm_types psty,
7850: okl_k_headers khr,
7851: okc_k_lines_b cle,
7852: okl_strm_type_tl styt

Line 7862: FROM okl_streams new_stm

7858: AND orig_stm.say_code = 'CURR'
7859: AND cle.id(+) = orig_stm.kle_id
7860: AND cle.dnz_chr_id(+) = orig_stm.khr_id
7861: AND NOT EXISTS (SELECT 1
7862: FROM okl_streams new_stm
7863: WHERE new_stm.khr_id = p_rbk_khr_id
7864: AND new_stm.say_code = 'CURR'
7865: AND new_stm.link_hist_stream_id = orig_stm.id)
7866: AND styt.id = orig_stm.sty_id

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 8155: --FROM okl_streams new_stm,

8151: orig_stm.id orig_stm_id,
8152: orig_stm.sty_id,
8153: orig_stm.kle_id,
8154: sty.name
8155: --FROM okl_streams new_stm,
8156: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
8157: okl_prod_strm_types psty,
8158: okl_k_headers khr,
8159: --okl_streams orig_stm,

Line 8156: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041

8152: orig_stm.sty_id,
8153: orig_stm.kle_id,
8154: sty.name
8155: --FROM okl_streams new_stm,
8156: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
8157: okl_prod_strm_types psty,
8158: okl_k_headers khr,
8159: --okl_streams orig_stm,
8160: okl_streams_rep_v orig_stm, -- MGAAP 7263041

Line 8159: --okl_streams orig_stm,

8155: --FROM okl_streams new_stm,
8156: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
8157: okl_prod_strm_types psty,
8158: okl_k_headers khr,
8159: --okl_streams orig_stm,
8160: okl_streams_rep_v orig_stm, -- MGAAP 7263041
8161: okl_strm_type_v sty
8162: WHERE khr.id = p_khr_id
8163: --AND psty.pdt_id = khr.pdt_id

Line 8160: okl_streams_rep_v orig_stm, -- MGAAP 7263041

8156: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
8157: okl_prod_strm_types psty,
8158: okl_k_headers khr,
8159: --okl_streams orig_stm,
8160: okl_streams_rep_v orig_stm, -- MGAAP 7263041
8161: okl_strm_type_v sty
8162: WHERE khr.id = p_khr_id
8163: --AND psty.pdt_id = khr.pdt_id
8164: AND psty.pdt_id = DECODE(OKL_STREAMS_SEC_PVT.GET_STREAMS_POLICY,

Line 8164: AND psty.pdt_id = DECODE(OKL_STREAMS_SEC_PVT.GET_STREAMS_POLICY,

8160: okl_streams_rep_v orig_stm, -- MGAAP 7263041
8161: okl_strm_type_v sty
8162: WHERE khr.id = p_khr_id
8163: --AND psty.pdt_id = khr.pdt_id
8164: AND psty.pdt_id = DECODE(OKL_STREAMS_SEC_PVT.GET_STREAMS_POLICY,
8165: 'PRIMARY', khr.pdt_id, p_reporting_pdt_id) -- MGAAP 7263041
8166: AND psty.accrual_yn = 'Y'
8167: AND psty.sty_id = new_stm.sty_id
8168: AND new_stm.khr_id = khr.id

Line 8208: --FROM okl_streams orig_stm,

8204: orig_stm.sty_id,
8205: orig_stm.kle_id,
8206: sty.name,
8207: cle.lse_id
8208: --FROM okl_streams orig_stm,
8209: FROM okl_streams_rep_v orig_stm, -- MGAAP 7263041
8210: okl_prod_strm_types psty,
8211: okl_k_headers khr,
8212: okc_k_lines_b cle,

Line 8209: FROM okl_streams_rep_v orig_stm, -- MGAAP 7263041

8205: orig_stm.kle_id,
8206: sty.name,
8207: cle.lse_id
8208: --FROM okl_streams orig_stm,
8209: FROM okl_streams_rep_v orig_stm, -- MGAAP 7263041
8210: okl_prod_strm_types psty,
8211: okl_k_headers khr,
8212: okc_k_lines_b cle,
8213: okl_strm_type_v sty

Line 8216: AND psty.pdt_id = DECODE(OKL_STREAMS_SEC_PVT.GET_STREAMS_POLICY,

8212: okc_k_lines_b cle,
8213: okl_strm_type_v sty
8214: WHERE khr.id = p_orig_khr_id
8215: --AND psty.pdt_id = khr.pdt_id
8216: AND psty.pdt_id = DECODE(OKL_STREAMS_SEC_PVT.GET_STREAMS_POLICY,
8217: 'PRIMARY', khr.pdt_id, p_reporting_pdt_id) -- MGAAP 7263041
8218: AND psty.accrual_yn = 'Y'
8219: AND psty.sty_id = orig_stm.sty_id
8220: AND orig_stm.khr_id = khr.id

Line 8226: --FROM okl_streams new_stm

8222: AND orig_stm.sgn_code NOT IN ('INTC','LATE_CALC') -- Bug6472228
8223: AND cle.id(+) = orig_stm.kle_id
8224: AND cle.dnz_chr_id(+) = orig_stm.khr_id
8225: AND NOT EXISTS (SELECT 1
8226: --FROM okl_streams new_stm
8227: FROM okl_streams_rep_v new_stm -- MGAAP 7263041
8228: WHERE new_stm.khr_id = p_rbk_khr_id
8229: AND new_stm.say_code = 'CURR'
8230: AND new_stm.link_hist_stream_id = orig_stm.id)

Line 8227: FROM okl_streams_rep_v new_stm -- MGAAP 7263041

8223: AND cle.id(+) = orig_stm.kle_id
8224: AND cle.dnz_chr_id(+) = orig_stm.khr_id
8225: AND NOT EXISTS (SELECT 1
8226: --FROM okl_streams new_stm
8227: FROM okl_streams_rep_v new_stm -- MGAAP 7263041
8228: WHERE new_stm.khr_id = p_rbk_khr_id
8229: AND new_stm.say_code = 'CURR'
8230: AND new_stm.link_hist_stream_id = orig_stm.id)
8231: AND sty.id = orig_stm.sty_id

Line 8300: l_current_mgaap_context := OKL_STREAMS_SEC_PVT.GET_STREAMS_POLICY;

8296: -- for all Current Accrual Streams for which Accruals were generated
8297: -- in the Original contract
8298:
8299: -- MGAAP start 7263041
8300: l_current_mgaap_context := OKL_STREAMS_SEC_PVT.GET_STREAMS_POLICY;
8301: IF (l_current_mgaap_context = 'REPORT') THEN
8302: OPEN c_get_reporting_pdt_id(p_rbk_khr_id);
8303: FETCH c_get_reporting_pdt_id INTO l_reporting_pdt_id, l_multi_gaap_yn;
8304: CLOSE c_get_reporting_pdt_id;

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 8571: okl_streams new_stm,

8567: orig_stm.id orig_stm_id
8568: FROM okl_pools pol,
8569: okl_pool_contents pcn,
8570: okl_strm_type_b sty,
8571: okl_streams new_stm,
8572: okl_streams orig_stm
8573: WHERE pcn.sty_id = sty.id
8574: AND pcn.pol_id = pol.id
8575: AND new_stm.kle_id = pcn.kle_id

Line 8572: okl_streams orig_stm

8568: FROM okl_pools pol,
8569: okl_pool_contents pcn,
8570: okl_strm_type_b sty,
8571: okl_streams new_stm,
8572: okl_streams orig_stm
8573: WHERE pcn.sty_id = sty.id
8574: AND pcn.pol_id = pol.id
8575: AND new_stm.kle_id = pcn.kle_id
8576: AND new_stm.khr_id = pcn.khr_id

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 8643: FROM okl_streams stm,

8639: CURSOR old_disb_adj_stm_csr(p_chr_id NUMBER,
8640: p_kle_id NUMBER)
8641: IS
8642: SELECT stm.id stm_id
8643: FROM okl_streams stm,
8644: okl_strm_type_b sty
8645: WHERE stm.khr_id = p_chr_id
8646: AND stm.kle_id = p_kle_id
8647: AND stm.sty_id = sty.id

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 8793: OKL_STREAMS_UTIL.get_primary_stream_type(

8789: END LOOP;
8790:
8791: IF (l_disb_adj_tbl.COUNT > 0) THEN
8792:
8793: OKL_STREAMS_UTIL.get_primary_stream_type(
8794: p_khr_id => l_inv_agreement_id,
8795: p_primary_sty_purpose => 'INVESTOR_DISB_ADJUSTMENT',
8796: x_return_status => x_return_status,
8797: x_primary_sty_id => l_disb_adj_sty_id

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 9062: FROM okl_streams new_stm,

9058:
9059: CURSOR curr_streams_csr(p_khr_id IN NUMBER) IS
9060: SELECT new_stm.id new_stm_id,
9061: new_stm.kle_id
9062: FROM okl_streams new_stm,
9063: okl_strm_type_b sty
9064: WHERE new_stm.khr_id = p_khr_id
9065: AND new_stm.say_code = 'WORK'
9066: AND new_stm.sty_id = sty.id

Line 9076: FROM okl_streams new_stm,

9072:
9073: CURSOR hist_strms_csr(p_new_stm_id IN NUMBER,
9074: p_khr_id IN NUMBER) IS
9075: SELECT orig_stm.id orig_stm_id
9076: FROM okl_streams new_stm,
9077: okl_streams orig_stm
9078: WHERE new_stm.id = p_new_stm_id
9079: AND orig_stm.khr_id = new_stm.khr_id
9080: AND NVL(orig_stm.kle_id,-1) = NVL(new_stm.kle_id,-1)

Line 9077: okl_streams orig_stm

9073: CURSOR hist_strms_csr(p_new_stm_id IN NUMBER,
9074: p_khr_id IN NUMBER) IS
9075: SELECT orig_stm.id orig_stm_id
9076: FROM okl_streams new_stm,
9077: okl_streams orig_stm
9078: WHERE new_stm.id = p_new_stm_id
9079: AND orig_stm.khr_id = new_stm.khr_id
9080: AND NVL(orig_stm.kle_id,-1) = NVL(new_stm.kle_id,-1)
9081: AND orig_stm.sty_id = new_stm.sty_id

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 9302: --FROM okl_streams new_stm,

9298: orig_stm.id orig_stm_id,
9299: orig_stm.sty_id,
9300: orig_stm.kle_id,
9301: sty.name
9302: --FROM okl_streams new_stm,
9303: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
9304: okl_prod_strm_types psty,
9305: okl_k_headers khr,
9306: --okl_streams orig_stm,

Line 9303: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041

9299: orig_stm.sty_id,
9300: orig_stm.kle_id,
9301: sty.name
9302: --FROM okl_streams new_stm,
9303: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
9304: okl_prod_strm_types psty,
9305: okl_k_headers khr,
9306: --okl_streams orig_stm,
9307: okl_streams_rep_v orig_stm, -- MGAAP 7263041

Line 9306: --okl_streams orig_stm,

9302: --FROM okl_streams new_stm,
9303: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
9304: okl_prod_strm_types psty,
9305: okl_k_headers khr,
9306: --okl_streams orig_stm,
9307: okl_streams_rep_v orig_stm, -- MGAAP 7263041
9308: okl_strm_type_v sty
9309: WHERE khr.id = p_khr_id
9310: --AND psty.pdt_id = khr.pdt_id

Line 9307: okl_streams_rep_v orig_stm, -- MGAAP 7263041

9303: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
9304: okl_prod_strm_types psty,
9305: okl_k_headers khr,
9306: --okl_streams orig_stm,
9307: okl_streams_rep_v orig_stm, -- MGAAP 7263041
9308: okl_strm_type_v sty
9309: WHERE khr.id = p_khr_id
9310: --AND psty.pdt_id = khr.pdt_id
9311: AND psty.pdt_id = NVL(p_product_id, khr.pdt_id) -- MGAAP 7263041

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,