[Home] [Help]
49: ----------------------------------------------------------------------
50:
51: PROCEDURE Raise_Business_Event(
52: p_api_version IN NUMBER
53: ,p_init_msg_list IN VARCHAR2 := FND_API.G_FALSE
54: ,p_commit IN VARCHAR2 := FND_API.G_FALSE
55: ,p_validation_level IN NUMBER := FND_API.G_VALID_LEVEL_FULL
56: ,x_return_status OUT NOCOPY VARCHAR2
57: ,x_msg_count OUT NOCOPY NUMBER
50:
51: PROCEDURE Raise_Business_Event(
52: p_api_version IN NUMBER
53: ,p_init_msg_list IN VARCHAR2 := FND_API.G_FALSE
54: ,p_commit IN VARCHAR2 := FND_API.G_FALSE
55: ,p_validation_level IN NUMBER := FND_API.G_VALID_LEVEL_FULL
56: ,x_return_status OUT NOCOPY VARCHAR2
57: ,x_msg_count OUT NOCOPY NUMBER
58: ,x_msg_data OUT NOCOPY VARCHAR2
51: PROCEDURE Raise_Business_Event(
52: p_api_version IN NUMBER
53: ,p_init_msg_list IN VARCHAR2 := FND_API.G_FALSE
54: ,p_commit IN VARCHAR2 := FND_API.G_FALSE
55: ,p_validation_level IN NUMBER := FND_API.G_VALID_LEVEL_FULL
56: ,x_return_status OUT NOCOPY VARCHAR2
57: ,x_msg_count OUT NOCOPY NUMBER
58: ,x_msg_data OUT NOCOPY VARCHAR2
59:
88: BEGIN
89: --------------------- initialize -----------------------
90: SAVEPOINT Raise_Business_Event;
91:
92: IF NOT FND_API.Compatible_API_Call (
93: l_api_version,
94: p_api_version,
95: l_api_name,
96: G_PKG_NAME)
94: p_api_version,
95: l_api_name,
96: G_PKG_NAME)
97: THEN
98: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
99: END IF;
100: -- Initialize message list if p_init_msg_list is set to TRUE.
101: IF FND_API.to_Boolean( p_init_msg_list )
102: THEN
97: THEN
98: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
99: END IF;
100: -- Initialize message list if p_init_msg_list is set to TRUE.
101: IF FND_API.to_Boolean( p_init_msg_list )
102: THEN
103: FND_MSG_PUB.initialize;
104: END IF;
105:
108: DPP_UTILITY_PVT.debug_message('Public API: ' || l_api_name || 'start');
109: END IF;
110:
111: -- Initialize API return status to sucess
112: x_return_status := FND_API.g_ret_sts_success;
113:
114: --Get a unique value for the execution detail id
115: BEGIN
116: SELECT DPP_EXECUTION_DETAIL_ID_SEQ.nextval
126: FND_MSG_PUB.add;
127: IF FND_MSG_PUB.check_msg_level (FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
128: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
129: END IF;
130: RAISE FND_API.g_exc_error;
131: WHEN OTHERS THEN
132: fnd_message.set_name('FND', 'SQL_PLSQL_ERROR');
133: fnd_message.set_token('ROUTINE', 'DPP_BUSINESSEVENTS_PVT');
134: fnd_message.set_token('ERRNO', sqlcode);
138: fnd_message.set_token('SEQ_NAME', 'DPP_EXECUTION_DETAIL_ID_SEQ');
139: FND_MSG_PUB.add;
140: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
141: END IF;
142: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
143: END;
144: IF g_debug THEN
145: DPP_UTILITY_PVT.debug_message('Execution Detail ID : ' || l_exe_dtl_id ||' For Transaction ID :'||p_txn_hdr_rec.Transaction_Header_ID);
146: DPP_UTILITY_PVT.debug_message('Process Code : ' || p_txn_hdr_rec.process_code);
162: FND_MSG_PUB.add;
163: IF FND_MSG_PUB.check_msg_level (FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
164: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
165: END IF;
166: RAISE FND_API.g_exc_error;
167: WHEN OTHERS THEN
168: fnd_message.set_name('FND', 'SQL_PLSQL_ERROR');
169: fnd_message.set_token('ROUTINE', 'DPP_BUSINESSEVENTS_PVT');
170: fnd_message.set_token('ERRNO', sqlcode);
168: fnd_message.set_name('FND', 'SQL_PLSQL_ERROR');
169: fnd_message.set_token('ROUTINE', 'DPP_BUSINESSEVENTS_PVT');
170: fnd_message.set_token('ERRNO', sqlcode);
171: fnd_message.set_token('REASON', sqlerrm);
172: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
173: END;
174:
175: l_user_name := ''''||l_user_name||'''';
176:
182: --No claim type flag has been sent
183: FND_MESSAGE.set_name('DPP', 'DPP_BUSEVT_INVALID_CLAIM_TYPE');
184: FND_MSG_PUB.add;
185: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
186: RAISE FND_API.g_exc_error;
187: ELSE
188: --Concatinate the claim flag with necessary quotes to generate xml data
189: l_claim_type_flag := ''''||p_txn_hdr_rec.claim_type_flag||'''';
190: IF g_debug THEN
215: FND_MSG_PUB.add;
216: IF FND_MSG_PUB.check_msg_level (FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
217: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
218: END IF;
219: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
220: END;
221: END LOOP;
222: ELSE
223: fnd_message.set_name('FND', 'SQL_PLSQL_ERROR');
224: fnd_message.set_token('ROUTINE', 'DPP_BUSINESSEVENTS_PVT');
225: fnd_message.set_token('ERRNO', sqlcode);
226: fnd_message.set_token('REASON', 'Transaction Line Id is required for the API');
227: FND_MSG_PUB.add;
228: RAISE FND_API.G_EXC_ERROR;
229: END IF; --l_table_count
230: ELSE
231: IF p_txn_hdr_rec.claim_type_flag = 'SUPP_DSTR_CL' THEN
232: BEGIN
245: FND_MSG_PUB.add;
246: IF FND_MSG_PUB.check_msg_level (FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
247: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
248: END IF;
249: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
250: END;
251: ELSE
252: BEGIN
253: INSERT INTO DPP_TRANSACTION_LINES_GT(transaction_header_id,
265: FND_MSG_PUB.add;
266: IF FND_MSG_PUB.check_msg_level (FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
267: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
268: END IF;
269: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
270: END;
271: END IF;
272: END IF;
273:
319: WHERE transaction_header_id = p_txn_hdr_rec.Transaction_Header_ID
320: AND nvl(update_item_list_price, 'N') = 'N';
321:
322: IF SQL%ROWCOUNT = 0 THEN
323: l_return_status := FND_API.G_RET_STS_ERROR;
324: DPP_UTILITY_PVT.debug_message('Unable to Update the column update_item_list_price in DPP_TRANSACTION_LINES_ALL Table');
325: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
326: END IF;
327:
321:
322: IF SQL%ROWCOUNT = 0 THEN
323: l_return_status := FND_API.G_RET_STS_ERROR;
324: DPP_UTILITY_PVT.debug_message('Unable to Update the column update_item_list_price in DPP_TRANSACTION_LINES_ALL Table');
325: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
326: END IF;
327:
328: END IF;
329: ELSIF p_txn_hdr_rec.process_code = 'OUTPL' THEN
373: WHERE transaction_header_id = p_txn_hdr_rec.Transaction_Header_ID
374: AND nvl(NOTIFY_OUTBOUND_PRICELIST,'N') <> 'D';
375:
376: IF SQL%ROWCOUNT = 0 THEN
377: l_return_status := FND_API.G_RET_STS_ERROR;
378: DPP_UTILITY_PVT.debug_message('Unable to Update the column NOTIFY_OUTBOUND_PRICELIST in DPP_TRANSACTION_LINES_ALL Table');
379: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
380: END IF;
381: END IF;
375:
376: IF SQL%ROWCOUNT = 0 THEN
377: l_return_status := FND_API.G_RET_STS_ERROR;
378: DPP_UTILITY_PVT.debug_message('Unable to Update the column NOTIFY_OUTBOUND_PRICELIST in DPP_TRANSACTION_LINES_ALL Table');
379: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
380: END IF;
381: END IF;
382:
383: ELSIF p_txn_hdr_rec.process_code = 'UPDCLM' THEN
397: FND_MSG_PUB.add;
398: IF FND_MSG_PUB.check_msg_level (FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
399: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
400: END IF;
401: RAISE FND_API.G_EXC_ERROR;
402: WHEN OTHERS THEN
403: fnd_message.set_name('FND', 'SQL_PLSQL_ERROR');
404: fnd_message.set_token('ROUTINE', 'DPP_BUSINESSEVENTS_PVT');
405: fnd_message.set_token('ERRNO', sqlcode);
409: FND_MESSAGE.set_name('DPP', 'DPP_BUSEVT_INVALID_CLAIM_AMT');
410: FND_MSG_PUB.add;
411: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
412: END IF;
413: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
414: END;
415: --Generate the Input Xml required for the Business Event --Update Claim
416: l_queryCtx := dbms_xmlquery.newContext('SELECT Transaction_header_id,
417: Transaction_number,
496: WHERE transaction_header_id = p_txn_hdr_rec.Transaction_Header_ID
497: AND nvl(NOTIFY_INBOUND_PRICELIST,'N') <> 'D';
498:
499: IF SQL%ROWCOUNT = 0 THEN
500: l_return_status := FND_API.G_RET_STS_ERROR;
501: DPP_UTILITY_PVT.debug_message('Unable to Update the column NOTIFY_INBOUND_PRICELIST in DPP_TRANSACTION_LINES_ALL Table');
502: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
503: END IF;
504: END IF;
498:
499: IF SQL%ROWCOUNT = 0 THEN
500: l_return_status := FND_API.G_RET_STS_ERROR;
501: DPP_UTILITY_PVT.debug_message('Unable to Update the column NOTIFY_INBOUND_PRICELIST in DPP_TRANSACTION_LINES_ALL Table');
502: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
503: END IF;
504: END IF;
505:
506: ELSIF p_txn_hdr_rec.process_code = 'PROMO' THEN
550: WHERE transaction_header_id = p_txn_hdr_rec.Transaction_Header_ID
551: AND nvl(NOTIFY_PROMOTIONS_PRICELIST,'N') <> 'D';
552:
553: IF SQL%ROWCOUNT = 0 THEN
554: l_return_status := FND_API.G_RET_STS_ERROR;
555: DPP_UTILITY_PVT.debug_message('Unable to Update the column NOTIFY_PROMOTIONS_PRICELIST in DPP_TRANSACTION_LINES_ALL Table');
556: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
557: END IF;
558: END IF;
552:
553: IF SQL%ROWCOUNT = 0 THEN
554: l_return_status := FND_API.G_RET_STS_ERROR;
555: DPP_UTILITY_PVT.debug_message('Unable to Update the column NOTIFY_PROMOTIONS_PRICELIST in DPP_TRANSACTION_LINES_ALL Table');
556: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
557: END IF;
558: END IF;
559: ELSIF p_txn_hdr_rec.process_code = 'INVC' THEN
560: --Retrieve the gl_cost_adjustment_acct
580: FND_MESSAGE.set_name('DPP', 'DPP_BUSEVT_INVALID_COSTADJACC');
581: FND_MSG_PUB.add;
582: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
583: END IF;
584: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
585: END;
586: IF l_cost_adj_acct IS NULL THEN
587: BEGIN
588: SELECT osp.gl_cost_adjustment_acct
600: FND_MSG_PUB.add;
601: IF FND_MSG_PUB.check_msg_level (FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
602: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
603: END IF;
604: RAISE FND_API.G_EXC_ERROR;
605: WHEN OTHERS THEN
606: fnd_message.set_name('FND', 'SQL_PLSQL_ERROR');
607: fnd_message.set_token('ROUTINE', 'DPP_BUSINESSEVENTS_PVT');
608: fnd_message.set_token('ERRNO', sqlcode);
612: FND_MESSAGE.set_name('DPP', 'DPP_BUSEVT_INVALID_COSTADJACC');
613: FND_MSG_PUB.add;
614: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
615: END IF;
616: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
617: END;
618: END IF;
619:
620: IF l_cost_adj_acct IS NOT NULL THEN
667: WHERE transaction_header_id = p_txn_hdr_rec.Transaction_Header_ID
668: AND nvl(UPDATE_INVENTORY_COSTING,'N') = 'N';
669:
670: IF SQL%ROWCOUNT = 0 THEN
671: l_return_status := FND_API.G_RET_STS_ERROR;
672: DPP_UTILITY_PVT.debug_message('Unable to Update the column UPDATE_INVENTORY_COSTING in DPP_TRANSACTION_LINES_ALL Table');
673: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
674: END IF;
675: END IF;
669:
670: IF SQL%ROWCOUNT = 0 THEN
671: l_return_status := FND_API.G_RET_STS_ERROR;
672: DPP_UTILITY_PVT.debug_message('Unable to Update the column UPDATE_INVENTORY_COSTING in DPP_TRANSACTION_LINES_ALL Table');
673: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
674: END IF;
675: END IF;
676: ELSE
677: fnd_message.set_name('FND', 'SQL_PLSQL_ERROR');
681: FND_MSG_PUB.add;
682: IF FND_MSG_PUB.check_msg_level (FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
683: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
684: END IF;
685: RAISE FND_API.G_EXC_ERROR;
686: END IF;
687:
688: ELSIF p_txn_hdr_rec.process_code = 'NTFYPO' THEN
689: --Generate the Input Xml required for the Business-- Event Send Notifications for Purchase Orders
733: WHERE transaction_header_id = p_txn_hdr_rec.Transaction_Header_ID
734: AND nvl(notify_purchasing_docs ,'N') <> 'D';
735:
736: IF SQL%ROWCOUNT = 0 THEN
737: l_return_status := FND_API.G_RET_STS_ERROR;
738: DPP_UTILITY_PVT.debug_message('Unable to Update the column notify_purchasing_docs in DPP_TRANSACTION_LINES_ALL Table');
739: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
740: END IF;
741: END IF;
735:
736: IF SQL%ROWCOUNT = 0 THEN
737: l_return_status := FND_API.G_RET_STS_ERROR;
738: DPP_UTILITY_PVT.debug_message('Unable to Update the column notify_purchasing_docs in DPP_TRANSACTION_LINES_ALL Table');
739: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
740: END IF;
741: END IF;
742: ELSIF p_txn_hdr_rec.process_code = 'UPDTPO' THEN
743: --Generate the Input Xml required for the Business Event -- Update Purchasing - Purchase Orders
785: WHERE transaction_header_id = p_txn_hdr_rec.Transaction_Header_ID
786: AND nvl(UPDATE_PURCHASING_DOCS ,'N')= 'N';
787:
788: IF SQL%ROWCOUNT = 0 THEN
789: l_return_status := FND_API.G_RET_STS_ERROR;
790: DPP_UTILITY_PVT.debug_message('Unable to Update the column UPDATE_PURCHASING_DOCS in DPP_TRANSACTION_LINES_ALL Table');
791: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
792: END IF;
793: END IF;
787:
788: IF SQL%ROWCOUNT = 0 THEN
789: l_return_status := FND_API.G_RET_STS_ERROR;
790: DPP_UTILITY_PVT.debug_message('Unable to Update the column UPDATE_PURCHASING_DOCS in DPP_TRANSACTION_LINES_ALL Table');
791: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
792: END IF;
793: END IF;
794: ELSIF p_txn_hdr_rec.process_code = 'DSTRINVCL' THEN
795: --Added code for DPP Price Increase Enhancement
811: FND_MSG_PUB.add;
812: IF FND_MSG_PUB.check_msg_level (FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
813: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
814: END IF;
815: RAISE FND_API.g_exc_error;
816: WHEN OTHERS THEN
817: fnd_message.set_name('FND', 'SQL_PLSQL_ERROR');
818: fnd_message.set_token('ROUTINE', 'DPP_BUSINESSEVENTS_PVT');
819: fnd_message.set_token('ERRNO', sqlcode);
823: fnd_message.set_token('SEQ_NAME', 'DPP_EXECUTION_DETAIL_ID_SEQ'); --To be modified
824: FND_MSG_PUB.add;
825: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
826: END IF;
827: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
828: END;
829:
830: IF (l_price_change_flag = 'N') THEN
831: dtl_price_change := 'nvl(dtl.price_change,0) > 0';
897: AND nvl(approved_inventory,0) > 0
898: AND nvl(price_change,0) > 0;
899:
900: IF SQL%ROWCOUNT = 0 THEN
901: l_return_status := FND_API.G_RET_STS_ERROR;
902: DPP_UTILITY_PVT.debug_message('Unable to Update the column SUPP_DIST_CLAIM_STATUS in DPP_TRANSACTION_LINES_ALL Table');
903: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
904: END IF;
905: --Update those lines to Y who have the approved inventory as 0
899:
900: IF SQL%ROWCOUNT = 0 THEN
901: l_return_status := FND_API.G_RET_STS_ERROR;
902: DPP_UTILITY_PVT.debug_message('Unable to Update the column SUPP_DIST_CLAIM_STATUS in DPP_TRANSACTION_LINES_ALL Table');
903: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
904: END IF;
905: --Update those lines to Y who have the approved inventory as 0
906: UPDATE DPP_TRANSACTION_LINES_ALL
907: SET SUPP_DIST_CLAIM_STATUS = 'Y',
925: AND nvl(approved_inventory,0) > 0
926: AND nvl(price_change,0) <> 0;
927:
928: IF SQL%ROWCOUNT = 0 THEN
929: l_return_status := FND_API.G_RET_STS_ERROR;
930: DPP_UTILITY_PVT.debug_message('Unable to Update the column SUPP_DIST_CLAIM_STATUS in DPP_TRANSACTION_LINES_ALL Table');
931: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
932: END IF;
933: --Update those lines to Y who have the approved inventory as 0
927:
928: IF SQL%ROWCOUNT = 0 THEN
929: l_return_status := FND_API.G_RET_STS_ERROR;
930: DPP_UTILITY_PVT.debug_message('Unable to Update the column SUPP_DIST_CLAIM_STATUS in DPP_TRANSACTION_LINES_ALL Table');
931: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
932: END IF;
933: --Update those lines to Y who have the approved inventory as 0
934: UPDATE DPP_TRANSACTION_LINES_ALL
935: SET SUPP_DIST_CLAIM_STATUS = 'Y',
1005: AND nvl(reported_inventory,0) > 0
1006: AND nvl(supp_claim_amt,0) > 0;
1007:
1008: IF SQL%ROWCOUNT = 0 THEN
1009: l_return_status := FND_API.G_RET_STS_ERROR;
1010: DPP_UTILITY_PVT.debug_message('Unable to Update the column supplier_claim_created in DPP_customer_claims_all Table');
1011: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1012: END IF;
1013: --Update those lines to Y which have reported inventory as 0
1007:
1008: IF SQL%ROWCOUNT = 0 THEN
1009: l_return_status := FND_API.G_RET_STS_ERROR;
1010: DPP_UTILITY_PVT.debug_message('Unable to Update the column supplier_claim_created in DPP_customer_claims_all Table');
1011: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1012: END IF;
1013: --Update those lines to Y which have reported inventory as 0
1014: UPDATE DPP_customer_claims_all
1015: SET supplier_claim_created = 'Y',
1140: FND_MESSAGE.set_name('DPP', 'DPP_BUSEVT_INVALID_PRO_CODE');
1141: fnd_message.set_token('PROCESS_CODE', p_txn_hdr_rec.process_code);
1142: FND_MSG_PUB.add;
1143: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
1144: RAISE FND_API.g_exc_error;
1145: END IF;
1146:
1147: --Raise the Workflow Event Procedure for the given process
1148: Raise_Workflow_Event(
1159: dpp_utility_pvt.debug_message('return status for Raise_Workflow_Event =>'||l_return_status);
1160: --dpp_utility_pvt.debug_message (substr(('Message data =>'||l_msg_data),1,4000));
1161: END IF;
1162: -- Check return status from the above procedure call
1163: IF l_return_status = FND_API.G_RET_STS_ERROR THEN
1164: RAISE FND_API.g_exc_error;
1165: ELSIF l_return_status = FND_API.G_RET_STS_UNEXP_ERROR THEN
1166: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1167: END IF;
1160: --dpp_utility_pvt.debug_message (substr(('Message data =>'||l_msg_data),1,4000));
1161: END IF;
1162: -- Check return status from the above procedure call
1163: IF l_return_status = FND_API.G_RET_STS_ERROR THEN
1164: RAISE FND_API.g_exc_error;
1165: ELSIF l_return_status = FND_API.G_RET_STS_UNEXP_ERROR THEN
1166: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1167: END IF;
1168: x_return_status:= l_return_status;
1161: END IF;
1162: -- Check return status from the above procedure call
1163: IF l_return_status = FND_API.G_RET_STS_ERROR THEN
1164: RAISE FND_API.g_exc_error;
1165: ELSIF l_return_status = FND_API.G_RET_STS_UNEXP_ERROR THEN
1166: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1167: END IF;
1168: x_return_status:= l_return_status;
1169:
1162: -- Check return status from the above procedure call
1163: IF l_return_status = FND_API.G_RET_STS_ERROR THEN
1164: RAISE FND_API.g_exc_error;
1165: ELSIF l_return_status = FND_API.G_RET_STS_UNEXP_ERROR THEN
1166: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1167: END IF;
1168: x_return_status:= l_return_status;
1169:
1170: -- Standard check for p_commit
1167: END IF;
1168: x_return_status:= l_return_status;
1169:
1170: -- Standard check for p_commit
1171: IF FND_API.to_Boolean( p_commit )
1172: THEN
1173: COMMIT;
1174: END IF;
1175: FND_MSG_PUB.count_and_get(
1172: THEN
1173: COMMIT;
1174: END IF;
1175: FND_MSG_PUB.count_and_get(
1176: p_encoded => FND_API.g_false,
1177: p_count => x_msg_count,
1178: p_data => x_msg_data
1179: );
1180:
1179: );
1180:
1181: --Exception Handling
1182: EXCEPTION
1183: WHEN FND_API.g_exc_error THEN
1184: ROLLBACK TO Raise_Business_Event;
1185: x_return_status := FND_API.g_ret_sts_error;
1186: FND_MSG_PUB.count_and_get (
1187: p_encoded => FND_API.g_false,
1181: --Exception Handling
1182: EXCEPTION
1183: WHEN FND_API.g_exc_error THEN
1184: ROLLBACK TO Raise_Business_Event;
1185: x_return_status := FND_API.g_ret_sts_error;
1186: FND_MSG_PUB.count_and_get (
1187: p_encoded => FND_API.g_false,
1188: p_count => x_msg_count,
1189: p_data => x_msg_data
1183: WHEN FND_API.g_exc_error THEN
1184: ROLLBACK TO Raise_Business_Event;
1185: x_return_status := FND_API.g_ret_sts_error;
1186: FND_MSG_PUB.count_and_get (
1187: p_encoded => FND_API.g_false,
1188: p_count => x_msg_count,
1189: p_data => x_msg_data
1190: );
1191:
1194: x_msg_data := SUBSTR((x_msg_data||' '|| FND_MSG_PUB.GET(P_MSG_INDEX => I, P_ENCODED => 'F')), 1, 4000);
1195: END LOOP;
1196: END IF;
1197:
1198: WHEN FND_API.g_exc_unexpected_error THEN
1199: ROLLBACK TO Raise_Business_Event;
1200: x_return_status := FND_API.g_ret_sts_unexp_error ;
1201: FND_MSG_PUB.count_and_get (
1202: p_encoded => FND_API.g_false,
1196: END IF;
1197:
1198: WHEN FND_API.g_exc_unexpected_error THEN
1199: ROLLBACK TO Raise_Business_Event;
1200: x_return_status := FND_API.g_ret_sts_unexp_error ;
1201: FND_MSG_PUB.count_and_get (
1202: p_encoded => FND_API.g_false,
1203: p_count => x_msg_count,
1204: p_data => x_msg_data
1198: WHEN FND_API.g_exc_unexpected_error THEN
1199: ROLLBACK TO Raise_Business_Event;
1200: x_return_status := FND_API.g_ret_sts_unexp_error ;
1201: FND_MSG_PUB.count_and_get (
1202: p_encoded => FND_API.g_false,
1203: p_count => x_msg_count,
1204: p_data => x_msg_data
1205: );
1206:
1215: fnd_message.set_name('FND', 'SQL_PLSQL_ERROR');
1216: fnd_message.set_token('ROUTINE', 'DPP_BUSINESSEVENTS_PVT');
1217: fnd_message.set_token('ERRNO', sqlcode);
1218: fnd_message.set_token('REASON', sqlerrm);
1219: x_return_status := FND_API.g_ret_sts_unexp_error ;
1220: IF FND_MSG_PUB.check_msg_level (FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
1221: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
1222: END IF;
1223: FND_MSG_PUB.count_and_get (
1220: IF FND_MSG_PUB.check_msg_level (FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
1221: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
1222: END IF;
1223: FND_MSG_PUB.count_and_get (
1224: p_encoded => FND_API.g_false,
1225: p_count => x_msg_count,
1226: p_data => x_msg_data
1227: );
1228:
1269: l_event_test VARCHAR2(10);
1270:
1271: BEGIN
1272:
1273: x_return_status := FND_API.g_ret_sts_success;
1274: --------------------- initialize -----------------------
1275: SAVEPOINT Raise_Workflow_Event;
1276:
1277: --Get a unique value for the l_new_item_key key
1279: --Check if the event subscription can be raised or not before inserting into the DPP_EXECUTION_DETAILS table
1280: l_event_test := wf_event.test(l_event_name);
1281: IF l_event_test = 'NONE' THEN
1282: DPP_UTILITY_PVT.debug_message('No enabled local subscriptions reference the event, or the event does not exist.');
1283: RAISE FND_API.g_exc_error;
1284: ELSE
1285: IF g_debug THEN
1286: DPP_UTILITY_PVT.debug_message('Number of rows Processed : '||p_row_count);
1287: END IF;
1323: FND_MSG_PUB.add;
1324: IF FND_MSG_PUB.check_msg_level (FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
1325: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
1326: END IF;
1327: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1328: END;
1329: --Define in WF Attributes l_parameter_list := WF_PARAMETER_LIST_T();
1330: WF_EVENT.AddParameterToList( p_name => 'TARGETSYSTEM'
1331: , p_value => l_target_system
1353: DPP_UTILITY_PVT.debug_message('Work Flow Event is not Raised');
1354: END IF;
1355: FND_MESSAGE.set_name('DPP', 'DPP_CC_NO_ELIGIBLE_LINES_MSG');
1356: FND_MSG_PUB.add;
1357: RAISE FND_API.g_exc_error;
1358: END IF; --p_row_count > 0
1359: END IF;
1360:
1361: EXCEPTION
1358: END IF; --p_row_count > 0
1359: END IF;
1360:
1361: EXCEPTION
1362: WHEN FND_API.g_exc_error THEN
1363: ROLLBACK TO Raise_Workflow_Event;
1364: x_return_status := FND_API.g_ret_sts_error;
1365: FND_MSG_PUB.count_and_get (
1366: p_encoded => FND_API.g_false,
1360:
1361: EXCEPTION
1362: WHEN FND_API.g_exc_error THEN
1363: ROLLBACK TO Raise_Workflow_Event;
1364: x_return_status := FND_API.g_ret_sts_error;
1365: FND_MSG_PUB.count_and_get (
1366: p_encoded => FND_API.g_false,
1367: p_count => x_msg_count,
1368: p_data => x_msg_data
1362: WHEN FND_API.g_exc_error THEN
1363: ROLLBACK TO Raise_Workflow_Event;
1364: x_return_status := FND_API.g_ret_sts_error;
1365: FND_MSG_PUB.count_and_get (
1366: p_encoded => FND_API.g_false,
1367: p_count => x_msg_count,
1368: p_data => x_msg_data
1369: );
1370: IF x_msg_count > 1 THEN
1372: x_msg_data := SUBSTR((x_msg_data||' '|| FND_MSG_PUB.GET(P_MSG_INDEX => I, P_ENCODED => 'F')), 1, 4000);
1373: END LOOP;
1374: END IF;
1375:
1376: WHEN FND_API.g_exc_unexpected_error THEN
1377: ROLLBACK TO Raise_Workflow_Event;
1378: x_return_status := FND_API.g_ret_sts_unexp_error ;
1379: FND_MSG_PUB.count_and_get (
1380: p_encoded => FND_API.g_false,
1374: END IF;
1375:
1376: WHEN FND_API.g_exc_unexpected_error THEN
1377: ROLLBACK TO Raise_Workflow_Event;
1378: x_return_status := FND_API.g_ret_sts_unexp_error ;
1379: FND_MSG_PUB.count_and_get (
1380: p_encoded => FND_API.g_false,
1381: p_count => x_msg_count,
1382: p_data => x_msg_data
1376: WHEN FND_API.g_exc_unexpected_error THEN
1377: ROLLBACK TO Raise_Workflow_Event;
1378: x_return_status := FND_API.g_ret_sts_unexp_error ;
1379: FND_MSG_PUB.count_and_get (
1380: p_encoded => FND_API.g_false,
1381: p_count => x_msg_count,
1382: p_data => x_msg_data
1383: );
1384: IF x_msg_count > 1 THEN
1393: fnd_message.set_token('ROUTINE', 'DPP_BUSINESSEVENTS_PVT');
1394: fnd_message.set_token('ERRNO', sqlcode);
1395: fnd_message.set_token('REASON', sqlerrm);
1396: FND_MSG_PUB.add;
1397: x_return_status := FND_API.g_ret_sts_unexp_error ;
1398: IF FND_MSG_PUB.check_msg_level (FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
1399: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
1400: END IF;
1401: FND_MSG_PUB.count_and_get (
1398: IF FND_MSG_PUB.check_msg_level (FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
1399: FND_MSG_PUB.add_exc_msg (g_pkg_name, l_api_name);
1400: END IF;
1401: FND_MSG_PUB.count_and_get (
1402: p_encoded => FND_API.g_false,
1403: p_count => x_msg_count,
1404: p_data => x_msg_data
1405: );
1406: IF x_msg_count > 1 THEN