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

577: --Bug# 4212626
578: trx_id,
579: link_hist_stream_id
580: -- sty_code -- dropped after inclusion
581: FROM okl_streams str,
582: okl_strm_type_v sty
583: WHERE str.khr_id = p_rebook_chr_id
584: AND str.sty_id = sty.id
585: AND str.say_code = 'CURR';

Line 591: p_sty_id OKL_STREAMS.sty_id%TYPE,

587:
588: -- Bug# 2857333
589: CURSOR orig_strm_csr (p_khr_id OKC_K_HEADERS_V.ID%TYPE,
590: p_kle_id OKC_K_LINES_V.ID%TYPE,
591: p_sty_id OKL_STREAMS.sty_id%TYPE,
592: p_purpose_code OKL_STREAMS.PURPOSE_CODE%TYPE) IS
593: SELECT id
594: FROM okl_streams
595: WHERE khr_id = p_khr_id

Line 592: p_purpose_code OKL_STREAMS.PURPOSE_CODE%TYPE) IS

588: -- Bug# 2857333
589: CURSOR orig_strm_csr (p_khr_id OKC_K_HEADERS_V.ID%TYPE,
590: p_kle_id OKC_K_LINES_V.ID%TYPE,
591: p_sty_id OKL_STREAMS.sty_id%TYPE,
592: p_purpose_code OKL_STREAMS.PURPOSE_CODE%TYPE) IS
593: SELECT id
594: FROM okl_streams
595: WHERE khr_id = p_khr_id
596: AND sty_id = p_sty_id

Line 594: FROM okl_streams

590: p_kle_id OKC_K_LINES_V.ID%TYPE,
591: p_sty_id OKL_STREAMS.sty_id%TYPE,
592: p_purpose_code OKL_STREAMS.PURPOSE_CODE%TYPE) IS
593: SELECT id
594: FROM okl_streams
595: WHERE khr_id = p_khr_id
596: AND sty_id = p_sty_id
597: AND NVL(kle_id,-1) = NVL(p_kle_id, -1)
598: AND say_code <> 'HIST'

Line 622: okl_streams str,

618: CURSOR unbill_adj_csr( khrId NUMBER,
619: kleid NUMBER ) IS
620: SELECT NVL(ele.amount,0) amount
621: FROM okl_strm_elements ele,
622: okl_streams str,
623: --okl_strm_type_tl sty
624: okl_strm_type_v sty
625: WHERE NVL(str.kle_id,-1) = kleid
626: AND str.khr_id = khrId

Line 640: okl_streams str,

636: CURSOR undesb_adj_csr( khrId NUMBER,
637: kleid NUMBER ) IS
638: SELECT NVL(ele.amount,0) amount
639: FROM okl_strm_elements ele,
640: okl_streams str,
641: --okl_strm_type_tl sty
642: okl_strm_type_v sty
643: WHERE NVL(str.kle_id,-1) = kleid
644: AND str.khr_id = khrId

Line 681: FROM okl_streams orig_stm,

677: p_rebook_chr_id IN NUMBER) IS
678: SELECT orig_stm.id orig_stm_id,
679: sty.stream_type_purpose,
680: cle.lse_id
681: FROM okl_streams orig_stm,
682: okc_k_lines_b cle,
683: okl_strm_type_v sty
684: WHERE orig_stm.khr_id = p_orig_chr_id
685: AND orig_stm.say_code = 'CURR'

Line 692: FROM okl_streams new_stm

688: AND cle.id(+) = orig_stm.kle_id
689: AND cle.dnz_chr_id(+) = orig_stm.khr_id
690: AND sty.id = orig_stm.sty_id
691: AND NOT EXISTS (SELECT 1
692: FROM okl_streams new_stm
693: WHERE new_stm.khr_id = p_rebook_chr_id
694: AND new_stm.say_code = 'CURR'
695: AND new_stm.link_hist_stream_id = orig_stm.id);
696:

Line 721: OKL_STREAMS_UTIL.get_primary_stream_type(

717: /*
718: * Not required, got purpose from driving cursor strm_hdr_csr
719: *
720: -- Get Stream id for purpose = BILLING ADJUSTMENT
721: OKL_STREAMS_UTIL.get_primary_stream_type(
722: p_khr_id => p_orig_chr_id,
723: p_primary_sty_purpose => 'REBOOK_BILLING_ADJUSTMENT',
724: x_return_status => x_return_status,
725: x_primary_sty_id => x_billing_adj_sty_id

Line 738: OKL_STREAMS_UTIL.get_primary_stream_type(

734: OPEN inv_adj_csr;
735: FETCH inv_adj_csr INTO x_inv_disb_adj_sty_id;
736: CLOSE inv_adj_csr;
737:
738: OKL_STREAMS_UTIL.get_primary_stream_type(
739: p_khr_id => p_orig_chr_id,
740: p_primary_sty_purpose => 'INVESTOR_DISB_ADJUSTMENT',
741: x_return_status => x_return_status,
742: x_primary_sty_id => x_inv_disb_adj_sty_id

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

1175: l_id NUMBER;
1176:
1177: CURSOR strm_csr (p_chr_id OKC_K_HEADERS_V.ID%TYPE) IS
1178: SELECT id
1179: FROM okl_streams
1180: WHERE khr_id = p_chr_id
1181: -- BUg 4737555
1182: -- AND SGN_CODE <> 'INTC';
1183: AND SGN_CODE NOT IN ('INTC','LATE_CALC'); -- Bug 6472228

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

3312: AND line.sts_code <> 'ABANDONED';
3313:
3314: CURSOR orig_fee_strm_csr (p_kle_id OKC_K_LINES_V.ID%TYPE) IS
3315: SELECT id
3316: FROM okl_streams
3317: WHERE kle_id = p_kle_id
3318: AND say_code <> 'HIST';
3319:
3320: CURSOR txn_csr (p_chr_id OKC_K_HEADERS_V.ID%TYPE) IS

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

7505: AND representation_type = 'PRIMARY'; -- MGAAP 7263041
7506:
7507: CURSOR disb_strm_csr (p_chr_id OKC_K_HEADERS_V.ID%TYPE) IS
7508: SELECT strm.id
7509: FROM okl_streams strm,
7510: okl_strm_type_v TYPE
7511: WHERE TYPE.id = strm.sty_id
7512: AND TYPE.stream_type_subclass = 'INVESTOR_DISBURSEMENT'
7513: AND strm.khr_id = p_chr_id

Line 7518: FROM okl_streams strm,

7514: AND strm.say_code = 'CURR';
7515:
7516: CURSOR accu_strm_csr (p_chr_id OKC_K_HEADERS_V.ID%TYPE) IS
7517: SELECT strm.id
7518: FROM okl_streams strm,
7519: okl_strm_type_v TYPE
7520: WHERE TYPE.id = strm.sty_id
7521: /*
7522: AND TYPE.name IN (

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

7770: x_return_status OUT NOCOPY VARCHAR2,
7771: x_msg_count OUT NOCOPY NUMBER,
7772: x_msg_data OUT NOCOPY VARCHAR2,
7773: p_chr_id IN OKC_K_HEADERS_V.ID%TYPE,
7774: p_stream_status IN OKL_STREAMS.SAY_CODE%TYPE
7775: ) IS
7776:
7777: l_api_name VARCHAR2(35) := 'sync_rebook_stream';
7778: l_proc_name VARCHAR2(35) := 'SYNC_REBOOK_STREAM';

Line 7956: OKL_STREAMS_SEC_PVT.RESET_REPO_STREAMS; -- MGAAP 7263041

7952:
7953: --
7954: -- Create Investor Accrual Adjustment
7955: --
7956: OKL_STREAMS_SEC_PVT.RESET_REPO_STREAMS; -- MGAAP 7263041
7957: IF (G_IS_DEBUG_STATEMENT_ON = true) THEN
7958: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'Before call calc_inv_acc_adjustment');
7959: END IF;
7960: calc_inv_acc_adjustment(

Line 8013: OKL_STREAMS_SEC_PVT.SET_REPO_STREAMS;

8009: -- MGAAP start 7263041
8010:
8011: IF (l_rbk_trx_rec.multi_gaap_yn = 'Y') THEN
8012:
8013: OKL_STREAMS_SEC_PVT.SET_REPO_STREAMS;
8014:
8015: IF (G_IS_DEBUG_STATEMENT_ON = true) THEN
8016: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'Before call calc_inv_acc_adjustment for SECONDARY');
8017: END IF;

Line 8031: OKL_STREAMS_SEC_PVT.RESET_REPO_STREAMS;

8027: x_inv_accrual_rec => l_inv_accrual_rec,
8028: x_inv_stream_tbl => l_inv_stream_tbl,
8029: p_product_id => l_rbk_trx_rec.reporting_pdt_id
8030: );
8031: OKL_STREAMS_SEC_PVT.RESET_REPO_STREAMS;
8032: IF (G_IS_DEBUG_STATEMENT_ON = true) THEN
8033: OKL_DEBUG_PUB.LOG_DEBUG(FND_LOG.LEVEL_STATEMENT, G_MODULE,'After call calc_inv_acc_adjustment'||x_return_status);
8034: END IF;
8035:

Line 8434: FROM okl_streams new_stm

8430:
8431: CURSOR curr_streams_csr(p_khr_id IN NUMBER) IS
8432: SELECT new_stm.id new_stm_id,
8433: new_stm.kle_id
8434: FROM okl_streams new_stm
8435: WHERE new_stm.khr_id = p_khr_id
8436: AND new_stm.say_code = 'WORK';
8437:
8438: CURSOR ol_rbk_kle_hist_strms_csr(p_new_stm_id IN NUMBER,

Line 8442: FROM okl_streams new_stm,

8438: CURSOR ol_rbk_kle_hist_strms_csr(p_new_stm_id IN NUMBER,
8439: p_rbk_khr_id IN NUMBER,
8440: p_orig_khr_id IN NUMBER) IS
8441: SELECT orig_stm.id orig_stm_id
8442: FROM okl_streams new_stm,
8443: okc_k_lines_b cle,
8444: okl_streams orig_stm
8445: WHERE new_stm.id = p_new_stm_id
8446: AND cle.id = new_stm.kle_id

Line 8444: okl_streams orig_stm

8440: p_orig_khr_id IN NUMBER) IS
8441: SELECT orig_stm.id orig_stm_id
8442: FROM okl_streams new_stm,
8443: okc_k_lines_b cle,
8444: okl_streams orig_stm
8445: WHERE new_stm.id = p_new_stm_id
8446: AND cle.id = new_stm.kle_id
8447: AND cle.dnz_chr_id = p_rbk_khr_id
8448: AND orig_stm.khr_id = p_orig_khr_id

Line 8457: FROM okl_streams new_stm,

8453:
8454: CURSOR ol_rbk_khr_hist_strms_csr(p_new_stm_id IN NUMBER,
8455: p_orig_khr_id IN NUMBER) IS
8456: SELECT orig_stm.id orig_stm_id
8457: FROM okl_streams new_stm,
8458: okl_streams orig_stm
8459: WHERE new_stm.id = p_new_stm_id
8460: AND orig_stm.khr_id = p_orig_khr_id
8461: AND orig_stm.kle_id IS NULL

Line 8458: okl_streams orig_stm

8454: CURSOR ol_rbk_khr_hist_strms_csr(p_new_stm_id IN NUMBER,
8455: p_orig_khr_id IN NUMBER) IS
8456: SELECT orig_stm.id orig_stm_id
8457: FROM okl_streams new_stm,
8458: okl_streams orig_stm
8459: WHERE new_stm.id = p_new_stm_id
8460: AND orig_stm.khr_id = p_orig_khr_id
8461: AND orig_stm.kle_id IS NULL
8462: AND orig_stm.sty_id = new_stm.sty_id

Line 8466: l_orig_stm_id OKL_STREAMS.ID%TYPE;

8462: AND orig_stm.sty_id = new_stm.sty_id
8463: AND NVL(orig_stm.purpose_code,'ORIG') = NVL(new_stm.purpose_code,'ORIG')
8464: AND orig_stm.say_code = 'CURR';
8465:
8466: l_orig_stm_id OKL_STREAMS.ID%TYPE;
8467:
8468: CURSOR mass_rbk_hist_strms_csr(p_new_stm_id IN NUMBER,
8469: p_khr_id IN NUMBER) IS
8470: SELECT orig_stm.id orig_stm_id

Line 8471: FROM okl_streams new_stm,

8467:
8468: CURSOR mass_rbk_hist_strms_csr(p_new_stm_id IN NUMBER,
8469: p_khr_id IN NUMBER) IS
8470: SELECT orig_stm.id orig_stm_id
8471: FROM okl_streams new_stm,
8472: okl_streams orig_stm
8473: WHERE new_stm.id = p_new_stm_id
8474: AND orig_stm.khr_id = new_stm.khr_id
8475: AND NVL(orig_stm.kle_id,-1) = NVL(new_stm.kle_id,-1)

Line 8472: okl_streams orig_stm

8468: CURSOR mass_rbk_hist_strms_csr(p_new_stm_id IN NUMBER,
8469: p_khr_id IN NUMBER) IS
8470: SELECT orig_stm.id orig_stm_id
8471: FROM okl_streams new_stm,
8472: okl_streams orig_stm
8473: WHERE new_stm.id = p_new_stm_id
8474: AND orig_stm.khr_id = new_stm.khr_id
8475: AND NVL(orig_stm.kle_id,-1) = NVL(new_stm.kle_id,-1)
8476: AND orig_stm.sty_id = new_stm.sty_id

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

8721: SELECT new_stm.id new_stm_id,
8722: orig_stm.id orig_stm_id,
8723: orig_stm.sty_id,
8724: orig_stm.kle_id
8725: FROM okl_streams new_stm,
8726: okl_strm_type_b sty,
8727: okl_streams orig_stm,
8728: okl_party_payment_hdr pph
8729: WHERE new_stm.khr_id = p_khr_id

Line 8727: okl_streams orig_stm,

8723: orig_stm.sty_id,
8724: orig_stm.kle_id
8725: FROM okl_streams new_stm,
8726: okl_strm_type_b sty,
8727: okl_streams orig_stm,
8728: okl_party_payment_hdr pph
8729: WHERE new_stm.khr_id = p_khr_id
8730: AND new_stm.say_code = 'CURR'
8731: AND new_stm.sty_id = sty.id

Line 8766: FROM okl_streams orig_stm,

8762: SELECT orig_stm.id orig_stm_id,
8763: orig_stm.sty_id,
8764: orig_stm.kle_id,
8765: cle.lse_id
8766: FROM okl_streams orig_stm,
8767: okl_strm_type_b sty,
8768: okc_k_lines_b cle,
8769: okl_party_payment_hdr pph
8770: WHERE orig_stm.khr_id = p_orig_khr_id

Line 8782: FROM okl_streams new_stm

8778: AND pph.cle_id = orig_stm.kle_id
8779: AND pph.payout_basis = 'DUE_DATE'
8780: AND pph.passthru_term = 'BASE'
8781: AND NOT EXISTS (SELECT 1
8782: FROM okl_streams new_stm
8783: WHERE new_stm.khr_id = p_rbk_khr_id
8784: AND new_stm.say_code = 'CURR'
8785: AND new_stm.link_hist_stream_id = orig_stm.id);
8786:

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

9078: SELECT new_stm.id new_stm_id,
9079: orig_stm.id orig_stm_id,
9080: orig_stm.sty_id,
9081: orig_stm.kle_id
9082: FROM okl_streams new_stm,
9083: okl_strm_type_b sty,
9084: okl_streams orig_stm
9085: WHERE new_stm.khr_id = p_khr_id
9086: AND new_stm.say_code = 'CURR'

Line 9084: okl_streams orig_stm

9080: orig_stm.sty_id,
9081: orig_stm.kle_id
9082: FROM okl_streams new_stm,
9083: okl_strm_type_b sty,
9084: okl_streams orig_stm
9085: WHERE new_stm.khr_id = p_khr_id
9086: AND new_stm.say_code = 'CURR'
9087: AND new_stm.sty_id = sty.id
9088: AND sty.billable_yn = 'Y'

Line 9120: FROM okl_streams orig_stm,

9116: SELECT orig_stm.id orig_stm_id,
9117: orig_stm.sty_id,
9118: orig_stm.kle_id,
9119: cle.lse_id
9120: FROM okl_streams orig_stm,
9121: okl_strm_type_b sty,
9122: okc_k_lines_b cle
9123: WHERE orig_stm.khr_id = p_orig_khr_id
9124: AND orig_stm.say_code = 'CURR'

Line 9137: FROM okl_streams new_stm

9133: AND sty.billable_yn = 'Y'
9134: AND cle.id(+) = orig_stm.kle_id
9135: AND cle.dnz_chr_id(+) = orig_stm.khr_id
9136: AND NOT EXISTS (SELECT 1
9137: FROM okl_streams new_stm
9138: WHERE new_stm.khr_id = p_rbk_khr_id
9139: AND new_stm.say_code = 'CURR'
9140: AND new_stm.link_hist_stream_id = orig_stm.id);
9141:

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

9475: orig_stm.id orig_stm_id,
9476: orig_stm.sty_id,
9477: orig_stm.kle_id,
9478: styt.name
9479: FROM okl_streams new_stm,
9480: okl_prod_strm_types psty,
9481: okl_k_headers khr,
9482: okl_streams orig_stm,
9483: okl_strm_type_tl styt

Line 9482: okl_streams orig_stm,

9478: styt.name
9479: FROM okl_streams new_stm,
9480: okl_prod_strm_types psty,
9481: okl_k_headers khr,
9482: okl_streams orig_stm,
9483: okl_strm_type_tl styt
9484: WHERE khr.id = p_khr_id
9485: AND psty.pdt_id = khr.pdt_id
9486: AND psty.accrual_yn = 'Y'

Line 9522: FROM okl_streams orig_stm,

9518: orig_stm.sty_id,
9519: orig_stm.kle_id,
9520: styt.name,
9521: cle.lse_id
9522: FROM okl_streams orig_stm,
9523: okl_prod_strm_types psty,
9524: okl_k_headers khr,
9525: okc_k_lines_b cle,
9526: okl_strm_type_tl styt

Line 9536: FROM okl_streams new_stm

9532: AND orig_stm.say_code = 'CURR'
9533: AND cle.id(+) = orig_stm.kle_id
9534: AND cle.dnz_chr_id(+) = orig_stm.khr_id
9535: AND NOT EXISTS (SELECT 1
9536: FROM okl_streams new_stm
9537: WHERE new_stm.khr_id = p_rbk_khr_id
9538: AND new_stm.say_code = 'CURR'
9539: AND new_stm.link_hist_stream_id = orig_stm.id)
9540: AND styt.id = orig_stm.sty_id

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

9825: orig_stm.id orig_stm_id,
9826: orig_stm.sty_id,
9827: orig_stm.kle_id,
9828: sty.name
9829: --FROM okl_streams new_stm,
9830: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
9831: okl_prod_strm_types psty,
9832: okl_k_headers khr,
9833: --okl_streams orig_stm,

Line 9830: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041

9826: orig_stm.sty_id,
9827: orig_stm.kle_id,
9828: sty.name
9829: --FROM okl_streams new_stm,
9830: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
9831: okl_prod_strm_types psty,
9832: okl_k_headers khr,
9833: --okl_streams orig_stm,
9834: okl_streams_rep_v orig_stm, -- MGAAP 7263041

Line 9833: --okl_streams orig_stm,

9829: --FROM okl_streams new_stm,
9830: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
9831: okl_prod_strm_types psty,
9832: okl_k_headers khr,
9833: --okl_streams orig_stm,
9834: okl_streams_rep_v orig_stm, -- MGAAP 7263041
9835: okl_strm_type_v sty
9836: WHERE khr.id = p_khr_id
9837: --AND psty.pdt_id = khr.pdt_id

Line 9834: okl_streams_rep_v orig_stm, -- MGAAP 7263041

9830: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
9831: okl_prod_strm_types psty,
9832: okl_k_headers khr,
9833: --okl_streams orig_stm,
9834: okl_streams_rep_v orig_stm, -- MGAAP 7263041
9835: okl_strm_type_v sty
9836: WHERE khr.id = p_khr_id
9837: --AND psty.pdt_id = khr.pdt_id
9838: AND psty.pdt_id = DECODE(OKL_STREAMS_SEC_PVT.GET_STREAMS_POLICY,

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

9834: okl_streams_rep_v orig_stm, -- MGAAP 7263041
9835: okl_strm_type_v sty
9836: WHERE khr.id = p_khr_id
9837: --AND psty.pdt_id = khr.pdt_id
9838: AND psty.pdt_id = DECODE(OKL_STREAMS_SEC_PVT.GET_STREAMS_POLICY,
9839: 'PRIMARY', khr.pdt_id, p_reporting_pdt_id) -- MGAAP 7263041
9840: AND psty.accrual_yn = 'Y'
9841: AND psty.sty_id = new_stm.sty_id
9842: AND new_stm.khr_id = khr.id

Line 9882: --FROM okl_streams orig_stm,

9878: orig_stm.sty_id,
9879: orig_stm.kle_id,
9880: sty.name,
9881: cle.lse_id
9882: --FROM okl_streams orig_stm,
9883: FROM okl_streams_rep_v orig_stm, -- MGAAP 7263041
9884: okl_prod_strm_types psty,
9885: okl_k_headers khr,
9886: okc_k_lines_b cle,

Line 9883: FROM okl_streams_rep_v orig_stm, -- MGAAP 7263041

9879: orig_stm.kle_id,
9880: sty.name,
9881: cle.lse_id
9882: --FROM okl_streams orig_stm,
9883: FROM okl_streams_rep_v orig_stm, -- MGAAP 7263041
9884: okl_prod_strm_types psty,
9885: okl_k_headers khr,
9886: okc_k_lines_b cle,
9887: okl_strm_type_v sty

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

9886: okc_k_lines_b cle,
9887: okl_strm_type_v sty
9888: WHERE khr.id = p_orig_khr_id
9889: --AND psty.pdt_id = khr.pdt_id
9890: AND psty.pdt_id = DECODE(OKL_STREAMS_SEC_PVT.GET_STREAMS_POLICY,
9891: 'PRIMARY', khr.pdt_id, p_reporting_pdt_id) -- MGAAP 7263041
9892: AND psty.accrual_yn = 'Y'
9893: AND psty.sty_id = orig_stm.sty_id
9894: AND orig_stm.khr_id = khr.id

Line 9900: --FROM okl_streams new_stm

9896: AND orig_stm.sgn_code NOT IN ('INTC','LATE_CALC') -- Bug6472228
9897: AND cle.id(+) = orig_stm.kle_id
9898: AND cle.dnz_chr_id(+) = orig_stm.khr_id
9899: AND NOT EXISTS (SELECT 1
9900: --FROM okl_streams new_stm
9901: FROM okl_streams_rep_v new_stm -- MGAAP 7263041
9902: WHERE new_stm.khr_id = p_rbk_khr_id
9903: AND new_stm.say_code = 'CURR'
9904: AND new_stm.link_hist_stream_id = orig_stm.id)

Line 9901: FROM okl_streams_rep_v new_stm -- MGAAP 7263041

9897: AND cle.id(+) = orig_stm.kle_id
9898: AND cle.dnz_chr_id(+) = orig_stm.khr_id
9899: AND NOT EXISTS (SELECT 1
9900: --FROM okl_streams new_stm
9901: FROM okl_streams_rep_v new_stm -- MGAAP 7263041
9902: WHERE new_stm.khr_id = p_rbk_khr_id
9903: AND new_stm.say_code = 'CURR'
9904: AND new_stm.link_hist_stream_id = orig_stm.id)
9905: AND sty.id = orig_stm.sty_id

Line 9974: l_current_mgaap_context := OKL_STREAMS_SEC_PVT.GET_STREAMS_POLICY;

9970: -- for all Current Accrual Streams for which Accruals were generated
9971: -- in the Original contract
9972:
9973: -- MGAAP start 7263041
9974: l_current_mgaap_context := OKL_STREAMS_SEC_PVT.GET_STREAMS_POLICY;
9975: IF (l_current_mgaap_context = 'REPORT') THEN
9976: OPEN c_get_reporting_pdt_id(p_rbk_khr_id);
9977: FETCH c_get_reporting_pdt_id INTO l_reporting_pdt_id, l_multi_gaap_yn;
9978: CLOSE c_get_reporting_pdt_id;

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

10241: orig_stm.id orig_stm_id
10242: FROM okl_pools pol,
10243: okl_pool_contents pcn,
10244: okl_strm_type_b sty,
10245: okl_streams new_stm,
10246: okl_streams orig_stm
10247: WHERE pcn.sty_id = sty.id
10248: AND pcn.pol_id = pol.id
10249: AND new_stm.kle_id = pcn.kle_id

Line 10246: okl_streams orig_stm

10242: FROM okl_pools pol,
10243: okl_pool_contents pcn,
10244: okl_strm_type_b sty,
10245: okl_streams new_stm,
10246: okl_streams orig_stm
10247: WHERE pcn.sty_id = sty.id
10248: AND pcn.pol_id = pol.id
10249: AND new_stm.kle_id = pcn.kle_id
10250: AND new_stm.khr_id = pcn.khr_id

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

10313: CURSOR old_disb_adj_stm_csr(p_chr_id NUMBER,
10314: p_kle_id NUMBER)
10315: IS
10316: SELECT stm.id stm_id
10317: FROM okl_streams stm,
10318: okl_strm_type_b sty
10319: WHERE stm.khr_id = p_chr_id
10320: AND stm.kle_id = p_kle_id
10321: AND stm.sty_id = sty.id

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

10463: END LOOP;
10464:
10465: IF (l_disb_adj_tbl.COUNT > 0) THEN
10466:
10467: OKL_STREAMS_UTIL.get_primary_stream_type(
10468: p_khr_id => l_inv_agreement_id,
10469: p_primary_sty_purpose => 'INVESTOR_DISB_ADJUSTMENT',
10470: x_return_status => x_return_status,
10471: x_primary_sty_id => l_disb_adj_sty_id

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

10779: -- Modified to pick only primary streams
10780: CURSOR curr_streams_csr(p_khr_id IN NUMBER) IS
10781: SELECT new_stm.id new_stm_id,
10782: new_stm.kle_id
10783: FROM okl_streams new_stm,
10784: okl_strm_type_b sty
10785: WHERE new_stm.khr_id = p_khr_id
10786: AND new_stm.say_code = 'WORK'
10787: AND new_stm.sty_id = sty.id

Line 10800: FROM okl_streams new_stm,

10796: --get the new reporting streams created during rebook
10797: CURSOR curr_streams_secondary_csr(p_khr_id IN NUMBER) IS
10798: SELECT new_stm.id new_stm_id,
10799: new_stm.kle_id
10800: FROM okl_streams new_stm,
10801: okl_strm_type_b sty
10802: WHERE new_stm.khr_id = p_khr_id
10803: AND new_stm.say_code = 'WORK'
10804: AND new_stm.sty_id = sty.id

Line 10815: FROM okl_streams new_stm,

10811: -- Modified to pick only primary streams
10812: CURSOR hist_strms_csr(p_new_stm_id IN NUMBER,
10813: p_khr_id IN NUMBER) IS
10814: SELECT orig_stm.id orig_stm_id
10815: FROM okl_streams new_stm,
10816: okl_streams orig_stm
10817: WHERE new_stm.id = p_new_stm_id
10818: AND orig_stm.khr_id = new_stm.khr_id
10819: AND NVL(orig_stm.kle_id,-1) = NVL(new_stm.kle_id,-1)

Line 10816: okl_streams orig_stm

10812: CURSOR hist_strms_csr(p_new_stm_id IN NUMBER,
10813: p_khr_id IN NUMBER) IS
10814: SELECT orig_stm.id orig_stm_id
10815: FROM okl_streams new_stm,
10816: okl_streams orig_stm
10817: WHERE new_stm.id = p_new_stm_id
10818: AND orig_stm.khr_id = new_stm.khr_id
10819: AND NVL(orig_stm.kle_id,-1) = NVL(new_stm.kle_id,-1)
10820: AND orig_stm.sty_id = new_stm.sty_id

Line 10830: FROM okl_streams new_stm,

10826: --get the old reporting streams on the contract
10827: CURSOR hist_strms_secondary_csr(p_new_stm_id IN NUMBER,
10828: p_khr_id IN NUMBER) IS
10829: SELECT orig_stm.id orig_stm_id
10830: FROM okl_streams new_stm,
10831: okl_streams orig_stm
10832: WHERE new_stm.id = p_new_stm_id
10833: AND orig_stm.khr_id = new_stm.khr_id
10834: AND NVL(orig_stm.kle_id,-1) = NVL(new_stm.kle_id,-1)

Line 10831: okl_streams orig_stm

10827: CURSOR hist_strms_secondary_csr(p_new_stm_id IN NUMBER,
10828: p_khr_id IN NUMBER) IS
10829: SELECT orig_stm.id orig_stm_id
10830: FROM okl_streams new_stm,
10831: okl_streams orig_stm
10832: WHERE new_stm.id = p_new_stm_id
10833: AND orig_stm.khr_id = new_stm.khr_id
10834: AND NVL(orig_stm.kle_id,-1) = NVL(new_stm.kle_id,-1)
10835: AND orig_stm.sty_id = new_stm.sty_id

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

11169: orig_stm.id orig_stm_id,
11170: orig_stm.sty_id,
11171: orig_stm.kle_id,
11172: sty.name
11173: --FROM okl_streams new_stm,
11174: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
11175: okl_prod_strm_types psty,
11176: okl_k_headers khr,
11177: --okl_streams orig_stm,

Line 11174: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041

11170: orig_stm.sty_id,
11171: orig_stm.kle_id,
11172: sty.name
11173: --FROM okl_streams new_stm,
11174: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
11175: okl_prod_strm_types psty,
11176: okl_k_headers khr,
11177: --okl_streams orig_stm,
11178: okl_streams_rep_v orig_stm, -- MGAAP 7263041

Line 11177: --okl_streams orig_stm,

11173: --FROM okl_streams new_stm,
11174: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
11175: okl_prod_strm_types psty,
11176: okl_k_headers khr,
11177: --okl_streams orig_stm,
11178: okl_streams_rep_v orig_stm, -- MGAAP 7263041
11179: okl_strm_type_v sty
11180: WHERE khr.id = p_khr_id
11181: --AND psty.pdt_id = khr.pdt_id

Line 11178: okl_streams_rep_v orig_stm, -- MGAAP 7263041

11174: FROM okl_streams_rep_v new_stm, -- MGAAP 7263041
11175: okl_prod_strm_types psty,
11176: okl_k_headers khr,
11177: --okl_streams orig_stm,
11178: okl_streams_rep_v orig_stm, -- MGAAP 7263041
11179: okl_strm_type_v sty
11180: WHERE khr.id = p_khr_id
11181: --AND psty.pdt_id = khr.pdt_id
11182: AND psty.pdt_id = NVL(p_product_id, khr.pdt_id) -- MGAAP 7263041

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,