102: exception
103: when no_data_found then
104: null;
105: end;
106: Wf_Core.Token('EVENT', l_event_name);
107: Wf_Core.Token('SOURCE', x_source_type);
108: Wf_Core.Token('PHASE', x_phase);
109: Wf_Core.Token('OWNERNAME', x_owner_name);
110: Wf_Core.Token('OWNERTAG', x_owner_tag);
103: when no_data_found then
104: null;
105: end;
106: Wf_Core.Token('EVENT', l_event_name);
107: Wf_Core.Token('SOURCE', x_source_type);
108: Wf_Core.Token('PHASE', x_phase);
109: Wf_Core.Token('OWNERNAME', x_owner_name);
110: Wf_Core.Token('OWNERTAG', x_owner_tag);
111: Wf_Core.Raise('WFE_DUPLICATE_SUB');
104: null;
105: end;
106: Wf_Core.Token('EVENT', l_event_name);
107: Wf_Core.Token('SOURCE', x_source_type);
108: Wf_Core.Token('PHASE', x_phase);
109: Wf_Core.Token('OWNERNAME', x_owner_name);
110: Wf_Core.Token('OWNERTAG', x_owner_tag);
111: Wf_Core.Raise('WFE_DUPLICATE_SUB');
112: else
105: end;
106: Wf_Core.Token('EVENT', l_event_name);
107: Wf_Core.Token('SOURCE', x_source_type);
108: Wf_Core.Token('PHASE', x_phase);
109: Wf_Core.Token('OWNERNAME', x_owner_name);
110: Wf_Core.Token('OWNERTAG', x_owner_tag);
111: Wf_Core.Raise('WFE_DUPLICATE_SUB');
112: else
113: insert into wf_event_subscriptions (
106: Wf_Core.Token('EVENT', l_event_name);
107: Wf_Core.Token('SOURCE', x_source_type);
108: Wf_Core.Token('PHASE', x_phase);
109: Wf_Core.Token('OWNERNAME', x_owner_name);
110: Wf_Core.Token('OWNERTAG', x_owner_tag);
111: Wf_Core.Raise('WFE_DUPLICATE_SUB');
112: else
113: insert into wf_event_subscriptions (
114: guid,
107: Wf_Core.Token('SOURCE', x_source_type);
108: Wf_Core.Token('PHASE', x_phase);
109: Wf_Core.Token('OWNERNAME', x_owner_name);
110: Wf_Core.Token('OWNERTAG', x_owner_tag);
111: Wf_Core.Raise('WFE_DUPLICATE_SUB');
112: else
113: insert into wf_event_subscriptions (
114: guid,
115: system_guid,
182: close c;
183:
184: exception
185: when others then
186: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Insert_Row', x_guid,
187: x_system_guid, X_SOURCE_TYPE, X_SOURCE_AGENT_GUID);
188: raise;
189:
190: end INSERT_ROW;
264: exception
265: when no_data_found then
266: null;
267: end;
268: Wf_Core.Context('Wf_Event_Subscriptions_Pkg', 'Update_Row');
269: Wf_Core.Token('EVENT', l_event_name);
270: Wf_Core.Token('SOURCE', x_source_type);
271: Wf_Core.Token('PHASE', x_phase);
272: Wf_Core.Token('OWNERNAME', x_owner_name);
265: when no_data_found then
266: null;
267: end;
268: Wf_Core.Context('Wf_Event_Subscriptions_Pkg', 'Update_Row');
269: Wf_Core.Token('EVENT', l_event_name);
270: Wf_Core.Token('SOURCE', x_source_type);
271: Wf_Core.Token('PHASE', x_phase);
272: Wf_Core.Token('OWNERNAME', x_owner_name);
273: Wf_Core.Token('OWNERTAG', x_owner_tag);
266: null;
267: end;
268: Wf_Core.Context('Wf_Event_Subscriptions_Pkg', 'Update_Row');
269: Wf_Core.Token('EVENT', l_event_name);
270: Wf_Core.Token('SOURCE', x_source_type);
271: Wf_Core.Token('PHASE', x_phase);
272: Wf_Core.Token('OWNERNAME', x_owner_name);
273: Wf_Core.Token('OWNERTAG', x_owner_tag);
274: Wf_Core.Raise('WFE_DUPLICATE_SUB');
267: end;
268: Wf_Core.Context('Wf_Event_Subscriptions_Pkg', 'Update_Row');
269: Wf_Core.Token('EVENT', l_event_name);
270: Wf_Core.Token('SOURCE', x_source_type);
271: Wf_Core.Token('PHASE', x_phase);
272: Wf_Core.Token('OWNERNAME', x_owner_name);
273: Wf_Core.Token('OWNERTAG', x_owner_tag);
274: Wf_Core.Raise('WFE_DUPLICATE_SUB');
275: end if;
268: Wf_Core.Context('Wf_Event_Subscriptions_Pkg', 'Update_Row');
269: Wf_Core.Token('EVENT', l_event_name);
270: Wf_Core.Token('SOURCE', x_source_type);
271: Wf_Core.Token('PHASE', x_phase);
272: Wf_Core.Token('OWNERNAME', x_owner_name);
273: Wf_Core.Token('OWNERTAG', x_owner_tag);
274: Wf_Core.Raise('WFE_DUPLICATE_SUB');
275: end if;
276:
269: Wf_Core.Token('EVENT', l_event_name);
270: Wf_Core.Token('SOURCE', x_source_type);
271: Wf_Core.Token('PHASE', x_phase);
272: Wf_Core.Token('OWNERNAME', x_owner_name);
273: Wf_Core.Token('OWNERTAG', x_owner_tag);
274: Wf_Core.Raise('WFE_DUPLICATE_SUB');
275: end if;
276:
277: if WF_EVENTS_PKG.g_Mode = 'FORCE' then
270: Wf_Core.Token('SOURCE', x_source_type);
271: Wf_Core.Token('PHASE', x_phase);
272: Wf_Core.Token('OWNERNAME', x_owner_name);
273: Wf_Core.Token('OWNERTAG', x_owner_tag);
274: Wf_Core.Raise('WFE_DUPLICATE_SUB');
275: end if;
276:
277: if WF_EVENTS_PKG.g_Mode = 'FORCE' then
278: update wf_event_subscriptions set
316: l_update_allowed := WF_EVENTS_PKG.is_update_allowed(X_CUSTOMIZATION_LEVEL, l_custom_level);
317:
318: if l_update_allowed = 'N' then
319: -- Set up the Error Stack
320: wf_core.context('WF_EVENT_SUBSCRIPTIONS_PKG','UPDATE_ROW',
321: X_EVENT_FILTER_GUID,
322: l_custom_level,
323: X_CUSTOMIZATION_LEVEL);
324: return;
463: null;
464: end if;
465: else
466: -- Raise error..
467: Wf_Core.Token('REASON','Invalid Customization Level:' ||
468: l_custom_level);
469: Wf_Core.Raise('WFSQL_INTERNAL');
470: end if;
471:
465: else
466: -- Raise error..
467: Wf_Core.Token('REASON','Invalid Customization Level:' ||
468: l_custom_level);
469: Wf_Core.Raise('WFSQL_INTERNAL');
470: end if;
471:
472: -- Only raise if all if no raise_event_flag is set to 'Y'
473: -- fetch_custom_level will raise no_data_found if the subscription is not found
579: -- Invalidate cache
580: wf_bes_cache.SetMetaDataUploaded();
581: exception
582: when others then
583: wf_core.context('Wf_Event_Subscriptions_Pkg', 'Load_Row', x_guid,
584: x_source_type, X_SOURCE_AGENT_GUID);
585: raise;
586: end LOAD_ROW;
587: -----------------------------------------------------------------------------
599: -- Invalidate cache
600: wf_bes_cache.SetMetaDataUploaded();
601: exception
602: when others then
603: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Delete_Row', x_guid);
604: raise;
605: end DELETE_ROW;
606: ----------------------------------------------------------------------------
607: procedure DELETE_SET (
684: -- Invalidate cache
685: wf_bes_cache.SetMetaDataUploaded();
686: exception
687: when others then
688: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Delete_Set',
689: x_system_guid, X_source_type, X_Event_Filter_GUID);
690: raise;
691: end DELETE_SET;
692: ----------------------------------------------------------------------------
816:
817: return buf;
818: exception
819: when others then
820: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Generate', x_guid);
821: raise;
822: end GENERATE;
823: -----------------------------------------------------------------------------
824: procedure RECEIVE (
958: l_onerror := l_value;
959: elsif(l_node_name = 'ACTION_CODE') then
960: l_actioncode := l_value;
961: else
962: Wf_Core.Token('REASON', 'Invalid column name found:' ||
963: l_node_name || ' with value:'||l_value);
964: Wf_Core.Raise('WFSQL_INTERNAL');
965: end if;
966: end loop;
960: l_actioncode := l_value;
961: else
962: Wf_Core.Token('REASON', 'Invalid column name found:' ||
963: l_node_name || ' with value:'||l_value);
964: Wf_Core.Raise('WFSQL_INTERNAL');
965: end if;
966: end loop;
967:
968: -- Validate Subscription
970: if L_PHASE is null then
971: -- For backward compatibility of the WFXLoad do not raise any errors when
972: -- the caller is the Loader. Throw a warning only
973: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then
974: Wf_Core.Token('REASON','Subscription Phase cannot be null');
975: Wf_Core.Raise('WFSQL_INTERNAL');
976: else
977: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',
978: 'WARNING! WARNING! Subscription Phase CANNOT be null for Event GUID '
971: -- For backward compatibility of the WFXLoad do not raise any errors when
972: -- the caller is the Loader. Throw a warning only
973: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then
974: Wf_Core.Token('REASON','Subscription Phase cannot be null');
975: Wf_Core.Raise('WFSQL_INTERNAL');
976: else
977: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',
978: 'WARNING! WARNING! Subscription Phase CANNOT be null for Event GUID '
979: || l_event_filter_guid || ' defaulting to 50');
973: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then
974: Wf_Core.Token('REASON','Subscription Phase cannot be null');
975: Wf_Core.Raise('WFSQL_INTERNAL');
976: else
977: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',
978: 'WARNING! WARNING! Subscription Phase CANNOT be null for Event GUID '
979: || l_event_filter_guid || ' defaulting to 50');
980: l_Phase := 50;
981: end if;
988:
989: -- For backward compatibility of the WFXLoad do not raise any errors when
990: -- the caller is the Loader. Throw a warning only
991: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then
992: Wf_Core.Token('REASON','Subscription Owner Name and Owner Tag cannot be null');
993: Wf_Core.Raise('WFSQL_INTERNAL');
994: else
995: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',
996: 'WARNING! WARNING! Subscription OWNER_NAME/OWNER_TAG CANNOT be null for Event GUID '
989: -- For backward compatibility of the WFXLoad do not raise any errors when
990: -- the caller is the Loader. Throw a warning only
991: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then
992: Wf_Core.Token('REASON','Subscription Owner Name and Owner Tag cannot be null');
993: Wf_Core.Raise('WFSQL_INTERNAL');
994: else
995: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',
996: 'WARNING! WARNING! Subscription OWNER_NAME/OWNER_TAG CANNOT be null for Event GUID '
997: || l_event_filter_guid);
991: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then
992: Wf_Core.Token('REASON','Subscription Owner Name and Owner Tag cannot be null');
993: Wf_Core.Raise('WFSQL_INTERNAL');
994: else
995: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',
996: 'WARNING! WARNING! Subscription OWNER_NAME/OWNER_TAG CANNOT be null for Event GUID '
997: || l_event_filter_guid);
998: end if;
999: end if;
1045: );
1046:
1047: exception
1048: when others then
1049: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive', x_message);
1050: raise;
1051: end RECEIVE;
1052: -----------------------------------------------------------------------------
1053: procedure validate_subscription (X_EVENT_FILTER_GUID in raw,
1087: end if;
1088: end if;
1089: exception
1090: when e_invalid_sub then
1091: l_trns1 := wf_core.translate('WFE_CUSTOM_LEVEL_' || X_CUSTOMIZATION_LEVEL);
1092: l_trns2 := wf_core.translate('WFE_CUSTOM_LEVEL_' || l_custom_level);
1093: wf_core.token('SUB_CUSTOM_LEVEL', l_trns1);
1094: wf_core.token('EVT_CUSTOM_LEVEL', l_trns2);
1095: wf_core.raise('WFE_INVALID_SUBSCRIPTION');
1088: end if;
1089: exception
1090: when e_invalid_sub then
1091: l_trns1 := wf_core.translate('WFE_CUSTOM_LEVEL_' || X_CUSTOMIZATION_LEVEL);
1092: l_trns2 := wf_core.translate('WFE_CUSTOM_LEVEL_' || l_custom_level);
1093: wf_core.token('SUB_CUSTOM_LEVEL', l_trns1);
1094: wf_core.token('EVT_CUSTOM_LEVEL', l_trns2);
1095: wf_core.raise('WFE_INVALID_SUBSCRIPTION');
1096: end validate_subscription;
1089: exception
1090: when e_invalid_sub then
1091: l_trns1 := wf_core.translate('WFE_CUSTOM_LEVEL_' || X_CUSTOMIZATION_LEVEL);
1092: l_trns2 := wf_core.translate('WFE_CUSTOM_LEVEL_' || l_custom_level);
1093: wf_core.token('SUB_CUSTOM_LEVEL', l_trns1);
1094: wf_core.token('EVT_CUSTOM_LEVEL', l_trns2);
1095: wf_core.raise('WFE_INVALID_SUBSCRIPTION');
1096: end validate_subscription;
1097:
1090: when e_invalid_sub then
1091: l_trns1 := wf_core.translate('WFE_CUSTOM_LEVEL_' || X_CUSTOMIZATION_LEVEL);
1092: l_trns2 := wf_core.translate('WFE_CUSTOM_LEVEL_' || l_custom_level);
1093: wf_core.token('SUB_CUSTOM_LEVEL', l_trns1);
1094: wf_core.token('EVT_CUSTOM_LEVEL', l_trns2);
1095: wf_core.raise('WFE_INVALID_SUBSCRIPTION');
1096: end validate_subscription;
1097:
1098: procedure fetch_custom_level(X_GUID in raw,
1091: l_trns1 := wf_core.translate('WFE_CUSTOM_LEVEL_' || X_CUSTOMIZATION_LEVEL);
1092: l_trns2 := wf_core.translate('WFE_CUSTOM_LEVEL_' || l_custom_level);
1093: wf_core.token('SUB_CUSTOM_LEVEL', l_trns1);
1094: wf_core.token('EVT_CUSTOM_LEVEL', l_trns2);
1095: wf_core.raise('WFE_INVALID_SUBSCRIPTION');
1096: end validate_subscription;
1097:
1098: procedure fetch_custom_level(X_GUID in raw,
1099: X_CUSTOMIZATION_LEVEL out nocopy varchar2)