The following lines contain the word 'select', 'insert', 'update' or 'delete':
FUNCTION Event_data_delete
-- Rule function for event data deletions used as the last subscription to AS events
(p_subscription_guid IN RAW,
p_event IN OUT NOCOPY WF_EVENT_T)
RETURN VARCHAR2
IS
l_key VARCHAR2(240);
SAVEPOINT Event_data_delete;
DELETE FROM as_event_data
WHERE event_key = l_key;
WF_CORE.CONTEXT('AS_BUSINESS_EVENT_PVT', 'EVENT_DATA_DELETE', p_event.getEventName(), p_subscription_guid);
ROLLBACK TO Event_data_delete;
WF_CORE.CONTEXT('AS_BUSINESS_EVENT_PVT', 'EVENT_DATA_DELETE', p_event.getEventName(), p_subscription_guid);
SELECT name INTO RetEvent
FROM wf_events
WHERE name = p_event_name;
SELECT 'Y'
FROM wf_events eve,
wf_event_subscriptions sub
WHERE eve.name = p_event_name
AND eve.status = 'ENABLED'
AND eve.guid = sub.event_filter_guid
AND UPPER(sub.rule_function) = 'AS_BUSINESS_EVENT_PVT.EVENT_DATA_DELETE'
AND sub.status = 'ENABLED'
AND sub.source_type = 'LOCAL'
AND EXISTS (
SELECT 'X'
FROM wf_event_subscriptions sub1
WHERE sub1.event_filter_guid = eve.guid
AND UPPER(sub1.rule_function) <> 'AS_BUSINESS_EVENT_PVT.EVENT_DATA_DELETE'
AND sub1.status = 'ENABLED'
AND sub1.source_type = 'LOCAL')
;
SELECT p_event_name || AS_BUSINESS_EVENT_S.nextval INTO RetKey FROM DUAL;
insert into AS_EVENT_DATA (
EVENT_DATA_ID,
EVENT_KEY, OBJECT_STATE,
LAST_UPDATE_DATE, CREATION_DATE, CREATED_BY, LAST_UPDATED_BY,
LAST_UPDATE_LOGIN,
CHAR01, CHAR02, CHAR03, CHAR04, CHAR05, CHAR06, CHAR07, CHAR08,
CHAR09, CHAR10, CHAR11, CHAR12, CHAR13, CHAR14, CHAR15, CHAR16,
CHAR17, CHAR18, CHAR19, CHAR20, CHAR21, CHAR22, CHAR23, CHAR24,
CHAR25, CHAR26, CHAR27, CHAR28, CHAR29, CHAR30, CHAR31, CHAR32,
CHAR33, CHAR34, CHAR35, CHAR36, CHAR37, CHAR38, CHAR39, CHAR40,
CHAR41, CHAR42, CHAR43, CHAR44, CHAR45, CHAR46, CHAR47, CHAR48,
CHAR49, CHAR50, CHAR51, CHAR52, CHAR53, CHAR54, CHAR55, CHAR56,
CHAR57, CHAR58, CHAR59, CHAR60, CHAR61, CHAR62, CHAR63, CHAR64,
CHAR65, CHAR66, CHAR67, CHAR68, CHAR69, CHAR70, CHAR71, CHAR72,
CHAR73, CHAR74, CHAR75, CHAR76, CHAR77, CHAR78, CHAR79, CHAR80,
NUM01, NUM02, NUM03, NUM04, NUM05, NUM06, NUM07, NUM08, NUM09,
NUM10, NUM11, NUM12, NUM13, NUM14, NUM15, NUM16, NUM17, NUM18,
NUM19, NUM20, NUM21, NUM22, NUM23, NUM24, NUM25, NUM26, NUM27,
NUM28, NUM29, NUM30,
DATE01, DATE02, DATE03, DATE04, DATE05, DATE06, DATE07, DATE08,
DATE09, DATE10, DATE11, DATE12, DATE13, DATE14, DATE15
)
select
AS_EVENT_DATA_S.nextval,
p_new_event_key, OBJECT_STATE,
SYSDATE, SYSDATE, CREATED_BY, LAST_UPDATED_BY,
LAST_UPDATE_LOGIN,
CHAR01, CHAR02, CHAR03, CHAR04, CHAR05, CHAR06, CHAR07, CHAR08,
CHAR09, CHAR10, CHAR11, CHAR12, CHAR13, CHAR14, CHAR15, CHAR16,
CHAR17, CHAR18, CHAR19, CHAR20, CHAR21, CHAR22, CHAR23, CHAR24,
CHAR25, CHAR26, CHAR27, CHAR28, CHAR29, CHAR30, CHAR31, CHAR32,
CHAR33, CHAR34, CHAR35, CHAR36, CHAR37, CHAR38, CHAR39, CHAR40,
CHAR41, CHAR42, CHAR43, CHAR44, CHAR45, CHAR46, CHAR47, CHAR48,
CHAR49, CHAR50, CHAR51, CHAR52, CHAR53, CHAR54, CHAR55, CHAR56,
CHAR57, CHAR58, CHAR59, CHAR60, CHAR61, CHAR62, CHAR63, CHAR64,
CHAR65, CHAR66, CHAR67, CHAR68, CHAR69, CHAR70, CHAR71, CHAR72,
CHAR73, CHAR74, CHAR75, CHAR76, CHAR77, CHAR78, CHAR79, CHAR80,
NUM01, NUM02, NUM03, NUM04, NUM05, NUM06, NUM07, NUM08, NUM09,
NUM10, NUM11, NUM12, NUM13, NUM14, NUM15, NUM16, NUM17, NUM18,
NUM19, NUM20, NUM21, NUM22, NUM23, NUM24, NUM25, NUM26, NUM27,
NUM28, NUM29, NUM30,
DATE01, DATE02, DATE03, DATE04, DATE05, DATE06, DATE07, DATE08,
DATE09, DATE10, DATE11, DATE12, DATE13, DATE14, DATE15
from AS_EVENT_DATA where event_key = p_old_event_key;
insert into AS_EVENT_DATA (
EVENT_DATA_ID,
EVENT_KEY, OBJECT_STATE, CHAR01, CHAR02,
LAST_UPDATE_DATE, CREATION_DATE, CREATED_BY, LAST_UPDATED_BY,
LAST_UPDATE_LOGIN
)
values (
AS_EVENT_DATA_S.nextval,
l_new_key, 'AAA', l_param.GetName(), l_param.GetValue(),
SYSDATE, SYSDATE, FND_GLOBAL.USER_ID, FND_GLOBAL.USER_ID,
FND_GLOBAL.CONC_LOGIN_ID
);
insert into AS_EVENT_DATA (
EVENT_DATA_ID,
EVENT_KEY, OBJECT_STATE, CHAR01, CHAR02,
LAST_UPDATE_DATE, CREATION_DATE, CREATED_BY, LAST_UPDATED_BY,
LAST_UPDATE_LOGIN
)
values (
AS_EVENT_DATA_S.nextval,
l_new_key, 'AAA', 'EVENT_NAME', l_event_name,
SYSDATE, SYSDATE, FND_GLOBAL.USER_ID, FND_GLOBAL.USER_ID,
FND_GLOBAL.CONC_LOGIN_ID
);
insert into AS_EVENT_DATA (
EVENT_DATA_ID,
EVENT_KEY, OBJECT_STATE, CHAR01, CHAR02,
LAST_UPDATE_DATE, CREATION_DATE, CREATED_BY, LAST_UPDATED_BY,
LAST_UPDATE_LOGIN
)
values (
AS_EVENT_DATA_S.nextval,
l_new_key, 'AAA', 'EVENT_KEY', l_key,
SYSDATE, SYSDATE, FND_GLOBAL.USER_ID, FND_GLOBAL.USER_ID,
FND_GLOBAL.CONC_LOGIN_ID
);
select enabled_flag, opp_flag, opp_open_status_flag, win_loss_indicator
from as_statuses_b
where status_code = p_status;
insert into AS_EVENT_DATA (
EVENT_DATA_ID,
EVENT_KEY, OBJECT_STATE,
LAST_UPDATE_DATE, CREATION_DATE, CREATED_BY, LAST_UPDATED_BY,
LAST_UPDATE_LOGIN,
NUM01, NUM02,
NUM03, NUM04,
NUM05,
NUM06, NUM07,
NUM08,
NUM09, NUM10,
NUM11, NUM12,
NUM13,
NUM14,
NUM15,
NUM16, NUM17,
NUM18,
NUM19,
NUM20,
NUM21,
DATE01, DATE02, DATE03,
CHAR01, CHAR02,
CHAR03, CHAR04,
CHAR05, CHAR06,
CHAR07,
CHAR08, CHAR09,
CHAR10, CHAR11,
CHAR12,
CHAR13,
CHAR14,
CHAR15, CHAR16,
CHAR17, CHAR18,
CHAR19, CHAR20,
CHAR21, CHAR22,
CHAR23, CHAR24,
CHAR25, CHAR26,
CHAR27, CHAR28,
CHAR29, CHAR30,
CHAR31,
CHAR32,
CHAR33,
CHAR34,
CHAR35,
CHAR36, CHAR37)
select
AS_EVENT_DATA_S.nextval,
p_item_key, p_indicator,
SYSDATE, SYSDATE, FND_GLOBAL.USER_ID, FND_GLOBAL.USER_ID,
FND_GLOBAL.CONC_LOGIN_ID,
-- NUM01 - NUM21
lead_id, customer_id,
address_id, owner_salesforce_id,
owner_sales_group_id,
sales_stage_id, win_probability,
customer_budget,
sales_methodology_id, total_amount,
last_updated_by, created_by,
close_competitor_id,
source_promotion_id,
end_user_customer_id,
end_user_address_id, org_id,
price_list_id,
incumbent_partner_resource_id,
incumbent_partner_party_id,
offer_id,
-- DATE01 - DATE03
last_update_date, creation_date,
decision_date,
-- CHAR01 - CHAR37
lead_number, status,
orig_system_reference, channel_code,
currency_code, close_reason,
close_competitor_code,
close_competitor, close_comment,
description, parent_project,
auto_assignment_type,
prm_assignment_type,
decision_timeframe_code,
attribute_category, attribute1,
attribute2, attribute3,
attribute4, attribute5,
attribute6, attribute7,
attribute8, attribute9,
attribute10, attribute11,
attribute12, attribute13,
attribute14, attribute15,
vehicle_response_code,
budget_status_code,
prm_exec_sponsor_flag,
prm_prj_lead_in_place_flag,
prm_ind_classification_code,
prm_lead_type, freeze_flag
from as_leads_all where lead_id = p_lead_id;
insert into AS_EVENT_DATA (
EVENT_DATA_ID,
EVENT_KEY, OBJECT_STATE,
LAST_UPDATE_DATE, CREATION_DATE, CREATED_BY, LAST_UPDATED_BY,
LAST_UPDATE_LOGIN,
NUM01, NUM02,
NUM03, NUM05,
NUM12,
NUM13, NUM14,
NUM15, NUM19,
NUM22, NUM23,
NUM24,
DATE01, DATE02,
DATE04, DATE05,
DATE06,
CHAR01, CHAR03,
CHAR06, CHAR07,
CHAR08, CHAR09,
CHAR10, CHAR11,
CHAR12, CHAR13,
CHAR14, CHAR15,
CHAR16, CHAR17,
CHAR18, CHAR19,
CHAR20, CHAR21,
CHAR22)
select
AS_EVENT_DATA_S.nextval,
p_item_key, p_indicator,
SYSDATE, SYSDATE, FND_GLOBAL.USER_ID, FND_GLOBAL.USER_ID,
FND_GLOBAL.CONC_LOGIN_ID,
-- NUM01-03, 05, 12-15, 19, 22-24
lead_line_id, lead_id,
last_updated_by, created_by,
inventory_item_id,
organization_id, quantity,
total_amount, org_id,
offer_id, source_promotion_id,
price_volume_margin,
-- DATE01-02, 04-06
last_update_date, creation_date,
ship_date, decision_date,
forecast_date,
-- CHAR01, 03, 06-22
status_code, uom_code,
attribute_category, attribute1,
attribute2, attribute3,
attribute4, attribute5,
attribute6, attribute7,
attribute8, attribute9,
attribute10, attribute11,
attribute12, attribute13,
attribute14, attribute15,
rolling_forecast_flag
from as_lead_lines where lead_id = p_lead_id;
insert into AS_EVENT_DATA (
EVENT_DATA_ID,
EVENT_KEY, OBJECT_STATE,
LAST_UPDATE_DATE, CREATION_DATE, CREATED_BY, LAST_UPDATED_BY,
LAST_UPDATE_LOGIN,
NUM01, NUM02, NUM03, NUM04)
select
AS_EVENT_DATA_S.nextval,
p_item_key, p_indicator,
SYSDATE, SYSDATE, FND_GLOBAL.USER_ID, FND_GLOBAL.USER_ID,
FND_GLOBAL.CONC_LOGIN_ID,
-- NUM01-09
salesforce_id, sales_group_id, access_id, lead_id
from AS_SALES_TEAM_EMP_V where lead_id = p_lead_id;
insert into AS_EVENT_DATA (
EVENT_DATA_ID,
EVENT_KEY, OBJECT_STATE,
LAST_UPDATE_DATE, CREATION_DATE, CREATED_BY, LAST_UPDATED_BY,
LAST_UPDATE_LOGIN,
NUM01, NUM02, NUM03, NUM04, NUM05)
select
AS_EVENT_DATA_S.nextval,
p_item_key, p_indicator,
SYSDATE, SYSDATE, FND_GLOBAL.USER_ID, FND_GLOBAL.USER_ID,
FND_GLOBAL.CONC_LOGIN_ID,
-- NUM01-09
salesforce_id, sales_group_id, access_id, customer_id, address_id
from AS_SALES_TEAM_EMP_V where customer_id = p_cust_id and lead_id IS NULL and
sales_lead_id IS NULL;
select
NUM01, NUM02,
NUM03, NUM04,
NUM05,
NUM06, NUM07,
NUM08,
NUM09, NUM10,
NUM11, NUM12,
NUM13,
NUM14,
NUM15,
NUM16, NUM17,
NUM18,
NUM19,
NUM20,
NUM21,
DATE01, DATE02, DATE03,
CHAR01, CHAR02,
CHAR03, CHAR04,
CHAR05, CHAR06,
CHAR07,
CHAR08, CHAR09,
CHAR10, CHAR11,
CHAR12,
CHAR13,
CHAR14,
CHAR15, CHAR16,
CHAR17, CHAR18,
CHAR19, CHAR20,
CHAR21, CHAR22,
CHAR23, CHAR24,
CHAR25, CHAR26,
CHAR27, CHAR28,
CHAR29, CHAR30,
CHAR31,
CHAR32,
CHAR33,
CHAR34,
CHAR35,
CHAR36, CHAR37
from as_event_data
where event_key = p_item_key AND object_state = p_indicator;
p_delete_flag IN BOOLEAN) RETURN VARCHAR2
IS
l_RetVal VARCHAR(1) := 'N';
select
NUM01, NUM02,
NUM03, NUM05,
NUM12,
NUM13, NUM14,
NUM15, NUM19,
NUM22, NUM23,
NUM24,
DATE01, DATE02,
DATE04, DATE05,
DATE06,
CHAR01, CHAR03,
CHAR06, CHAR07,
CHAR08, CHAR09,
CHAR10, CHAR11,
CHAR12, CHAR13,
CHAR14, CHAR15,
CHAR16, CHAR17,
CHAR18, CHAR19,
CHAR20, CHAR21,
CHAR22, rowid
from as_event_data
where event_key = p_item_key AND object_state = p_indicator ORDER BY NUM01;
select
NUM01, NUM02,
NUM03, NUM05,
NUM12,
NUM13, NUM14,
NUM15, NUM19,
NUM22, NUM23,
NUM24,
DATE01, DATE02,
DATE04, DATE05,
DATE06,
CHAR01, CHAR03,
CHAR06, CHAR07,
CHAR08, CHAR09,
CHAR10, CHAR11,
CHAR12, CHAR13,
CHAR14, CHAR15,
CHAR16, CHAR17,
CHAR18, CHAR19,
CHAR20, CHAR21,
CHAR22, rowid
from as_event_data
where event_key = p_item_key AND object_state = p_indicator ORDER BY NUM01;
IF NOT p_delete_flag THEN
EXIT;
IF p_delete_flag THEN
delete from AS_EVENT_DATA where rowid = l_old_rec.rowid;
delete from AS_EVENT_DATA where rowid = l_new_rec.rowid;
p_delete_flag IN BOOLEAN) RETURN VARCHAR2
IS
l_RetVal VARCHAR(1) := 'N';
select
NUM01, NUM02, NUM03, NUM04, NUM05, rowid
from as_event_data
where event_key = p_item_key AND object_state = p_indicator
ORDER BY NUM01, NUM02, NUM05;
select
NUM01, NUM02, NUM03, NUM04, NUM05, rowid
from as_event_data
where event_key = p_item_key AND object_state = p_indicator
ORDER BY NUM01, NUM02, NUM05;
IF NOT p_delete_flag THEN
EXIT;
IF p_delete_flag THEN
delete from AS_EVENT_DATA where rowid = l_old_rec.rowid;
delete from AS_EVENT_DATA where rowid = l_new_rec.rowid;
FUNCTION Raise_update_oppty_event (
p_subscription_guid IN RAW,
p_event IN OUT NOCOPY WF_EVENT_T
)
RETURN VARCHAR2
IS
l_api_name CONSTANT VARCHAR2(30) := 'Raise_update_oppty_event';
l_module CONSTANT VARCHAR2(255) := 'as.plsql.bevpv.Raise_update_oppty_event';
SAVEPOINT Raise_update_oppty_event;
l_event_name := OPPTY_UPDATE_EVENT;
delete from AS_EVENT_DATA where event_key = l_event_key;
ROLLBACK TO Raise_update_oppty_event;
WF_CORE.CONTEXT('AS_BUSINESS_EVENT_PVT', 'RAISE_UPDATE_OPPTY_EVENT', p_event.getEventName(), p_subscription_guid);
END Raise_update_oppty_event;
PROCEDURE Before_Oppty_Update(
p_lead_id IN NUMBER,
x_event_key OUT NOCOPY VARCHAR2
) IS
l_api_name CONSTANT VARCHAR2(30) := 'Before_Oppty_Update';
l_module CONSTANT VARCHAR2(255) := 'as.plsql.bevpv.Before_Oppty_Update';
SAVEPOINT Before_Oppty_Update;
l_raise_event := exist_subscription( OPPTY_UPDATE_EVENT );
x_event_key := item_key( OPPTY_UPDATE_EVENT );
END Before_Oppty_Update;
PROCEDURE Update_oppty_post_event(
p_lead_id IN NUMBER,
p_event_key IN VARCHAR2
) IS
l_api_name CONSTANT VARCHAR2(30) := 'Update_oppty_post_event';
l_module CONSTANT VARCHAR2(255) := 'as.plsql.bevpv.Update_oppty_post_event';
SAVEPOINT Update_oppty_post_event;
IF INSTR(p_event_key, OPPTY_UPDATE_EVENT) <> 1 THEN
FND_MESSAGE.SET_NAME('AS', 'AS_INVALID_EVENT_KEY');
p_event_name => INT_OPPTY_UPDATE_EVENT,
p_event_key => p_event_key,
p_parameters => l_list );
l_event := WF_EVENT_T(NULL, NULL, NULL, NULL, l_list, INT_OPPTY_UPDATE_EVENT,
p_event_key, NULL, NULL, NULL, NULL, NULL, NULL);
l_status := Raise_update_oppty_event(NULL, l_event);
l_list.DELETE;
END Update_oppty_post_event;
l_raise_event := exist_subscription( OPP_LINES_UPDATE_EVENT );
p_event_name => OPP_LINES_UPDATE_EVENT,
p_event_key => l_event_key,
p_parameters => l_list );
delete from AS_EVENT_DATA where event_key = l_event_key;
PROCEDURE Before_Opp_Lines_Update(
p_lead_id IN NUMBER,
x_event_key OUT NOCOPY VARCHAR2
) IS
l_api_name CONSTANT VARCHAR2(30) := 'Before_Opp_Lines_Update';
l_module CONSTANT VARCHAR2(255) := 'as.plsql.bevpv.Before_Opp_Lines_Update';
SAVEPOINT Before_Opp_Lines_Update;
l_raise_event := exist_subscription( OPP_LINES_UPDATE_EVENT );
x_event_key := item_key( OPP_LINES_UPDATE_EVENT );
END Before_Opp_Lines_Update;
IF INSTR(p_event_key, OPP_LINES_UPDATE_EVENT) <> 1 THEN
FND_MESSAGE.SET_NAME('AS', 'AS_INVALID_EVENT_KEY');
p_event_name => INT_OPP_LINES_UPDATE_EVENT,
p_event_key => p_event_key,
p_parameters => l_list );
l_event := WF_EVENT_T(NULL, NULL, NULL, NULL, l_list, INT_OPP_LINES_UPDATE_EVENT,
p_event_key, NULL, NULL, NULL, NULL, NULL, NULL);
IF INSTR(l_event_key, OPP_STEAM_UPDATE_EVENT) = 1 THEN
l_event_name := OPP_STEAM_UPDATE_EVENT;
l_event_name := CUST_STEAM_UPDATE_EVENT;
delete from AS_EVENT_DATA where event_key = l_event_key;
PROCEDURE Before_Opp_STeam_Update(
p_lead_id IN NUMBER,
x_event_key OUT NOCOPY VARCHAR2
) IS
l_api_name CONSTANT VARCHAR2(30) := 'Before_Opp_STeam_Update';
l_module CONSTANT VARCHAR2(255) := 'as.plsql.bevpv.Before_Opp_STeam_Update';
SAVEPOINT Before_Opp_STeam_Update;
l_raise_event := exist_subscription( OPP_STEAM_UPDATE_EVENT );
x_event_key := item_key( OPP_STEAM_UPDATE_EVENT );
END Before_Opp_STeam_Update;
IF INSTR(p_event_key, OPP_STEAM_UPDATE_EVENT) <> 1 THEN
FND_MESSAGE.SET_NAME('AS', 'AS_INVALID_EVENT_KEY');
p_event_name => INT_STEAM_UPDATE_EVENT,
p_event_key => p_event_key,
p_parameters => l_list );
l_event := WF_EVENT_T(NULL, NULL, NULL, NULL, l_list, INT_STEAM_UPDATE_EVENT,
p_event_key, NULL, NULL, NULL, NULL, NULL, NULL);
PROCEDURE Before_Cust_STeam_Update(
p_cust_id IN NUMBER,
x_event_key OUT NOCOPY VARCHAR2
) IS
l_api_name CONSTANT VARCHAR2(30) := 'Before_Cust_STeam_Update';
l_module CONSTANT VARCHAR2(255) := 'as.plsql.bevpv.Before_Cust_STeam_Update';
SAVEPOINT Before_Cust_STeam_Update;
l_raise_event := exist_subscription( CUST_STEAM_UPDATE_EVENT );
x_event_key := item_key( CUST_STEAM_UPDATE_EVENT );
END Before_Cust_STeam_Update;
IF INSTR(p_event_key, CUST_STEAM_UPDATE_EVENT) <> 1 THEN
FND_MESSAGE.SET_NAME('AS', 'AS_INVALID_EVENT_KEY');
p_event_name => INT_STEAM_UPDATE_EVENT,
p_event_key => p_event_key,
p_parameters => l_list );
l_event := WF_EVENT_T(NULL, NULL, NULL, NULL, l_list, INT_STEAM_UPDATE_EVENT,
p_event_key, NULL, NULL, NULL, NULL, NULL, NULL);