1: package body WF_EVENT_FUNCTIONS_PKG as
2: /* $Header: WFEVFNCB.pls 120.6 2005/11/28 00:53:49 nravindr ship $ */
3:
4: ------------------------------------------------------------------------------
5: /*
38: dtd := wf_agents_pkg.generate(p_event_key);
39: elsif p_event_name = 'oracle.apps.wf.event.agent.update' then
40: dtd := wf_agents_pkg.generate(p_event_key);
41: elsif p_event_name = 'oracle.apps.wf.event.agentgroup.create' then
42: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
43: 2,'/');
44: dtd := wf_agent_groups_pkg.generate(l_parameters(1), l_parameters(2));
45: elsif p_event_name = 'oracle.apps.wf.event.agentgroup.delete' then
46: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
42: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
43: 2,'/');
44: dtd := wf_agent_groups_pkg.generate(l_parameters(1), l_parameters(2));
45: elsif p_event_name = 'oracle.apps.wf.event.agentgroup.delete' then
46: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
47: 2,'/');
48: dtd := wf_agent_groups_pkg.generate(l_parameters(1), l_parameters(2));
49: elsif p_event_name = 'oracle.apps.wf.event.agentgroup.update' then
50: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
46: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
47: 2,'/');
48: dtd := wf_agent_groups_pkg.generate(l_parameters(1), l_parameters(2));
49: elsif p_event_name = 'oracle.apps.wf.event.agentgroup.update' then
50: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
51: 2,'/');
52: dtd := wf_agent_groups_pkg.generate1(l_parameters(1), l_parameters(2));
53: elsif p_event_name = 'oracle.apps.wf.event.event.create' then
54: dtd := wf_events_pkg.generate(p_event_key);
56: dtd := wf_events_pkg.generate(p_event_key);
57: elsif p_event_name = 'oracle.apps.wf.event.event.update' then
58: dtd := wf_events_pkg.generate(p_event_key);
59: elsif p_event_name = 'oracle.apps.wf.event.group.create' then
60: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
61: 2,'/');
62: dtd := wf_event_groups_pkg.generate(l_parameters(1), l_parameters(2));
63: elsif p_event_name = 'oracle.apps.wf.event.group.delete' then
64: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
60: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
61: 2,'/');
62: dtd := wf_event_groups_pkg.generate(l_parameters(1), l_parameters(2));
63: elsif p_event_name = 'oracle.apps.wf.event.group.delete' then
64: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
65: 2,'/');
66: dtd := wf_event_groups_pkg.generate(l_parameters(1), l_parameters(2));
67: elsif p_event_name = 'oracle.apps.wf.event.group.update' then
68: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
64: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
65: 2,'/');
66: dtd := wf_event_groups_pkg.generate(l_parameters(1), l_parameters(2));
67: elsif p_event_name = 'oracle.apps.wf.event.group.update' then
68: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
69: 2,'/');
70: dtd := wf_event_groups_pkg.generate2(l_parameters(1), l_parameters(2));
71: elsif p_event_name = 'oracle.apps.wf.event.subscription.create' then
72: dtd := wf_event_subscriptions_pkg.generate(p_event_key);
75: elsif p_event_name = 'oracle.apps.wf.event.subscription.update' then
76: dtd := wf_event_subscriptions_pkg.generate(p_event_key);
77: /** Start of Bug 2398759 to support Agent Groups **/
78: elsif p_event_name = 'oracle.apps.wf.agent.group.create' then
79: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
80: 2,'/');
81: dtd := wf_agent_groups_pkg.generate(l_parameters(1), l_parameters(2));
82: elsif p_event_name = 'oracle.apps.wf.agent.group.delete' then
83: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
79: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
80: 2,'/');
81: dtd := wf_agent_groups_pkg.generate(l_parameters(1), l_parameters(2));
82: elsif p_event_name = 'oracle.apps.wf.agent.group.delete' then
83: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
84: 2,'/');
85: dtd := wf_agent_groups_pkg.generate(l_parameters(1), l_parameters(2));
86: elsif p_event_name = 'oracle.apps.wf.agent.group.update' then
87: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
83: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
84: 2,'/');
85: dtd := wf_agent_groups_pkg.generate(l_parameters(1), l_parameters(2));
86: elsif p_event_name = 'oracle.apps.wf.agent.group.update' then
87: l_parameters := wf_event_functions_pkg.parameters(p_event_key,
88: 2,'/');
89: dtd := wf_agent_groups_pkg.generate(l_parameters(1), l_parameters(2));
90: /** End of Bug 2398759 **/
91: elsif p_event_name = 'oracle.apps.wf.event.all.sync' then
102: return (msg);
103:
104: exception
105: when others then
106: wf_core.context('WF_EVENT_FUNCTIONS_PKG', 'GENERATE', p_event_name,
107: p_event_key,
108: substr(dtd,1,100));
109: raise;
110: end;
166: wf_agents_pkg.receive(x_message);
167: elsif l_eventname = 'oracle.apps.wf.agent.group.create' then
168: wf_agent_groups_pkg.receive(x_message);
169: elsif l_eventname = 'oracle.apps.wf.agent.group.delete' then
170: l_parameters := wf_event_functions_pkg.parameters(l_eventkey,
171: 2,'/');
172: wf_agent_groups_pkg.delete_row(l_parameters(1), l_parameters(2));
173: elsif l_eventname = 'oracle.apps.wf.agent.group.update' then
174: wf_agent_groups_pkg.receive(x_message);
180: wf_events_pkg.receive(x_message);
181: elsif l_eventname = 'oracle.apps.wf.event.group.create' then
182: wf_event_groups_pkg.receive(x_message);
183: elsif l_eventname = 'oracle.apps.wf.event.group.delete' then
184: l_parameters := wf_event_functions_pkg.parameters(l_eventkey,
185: 2,'/');
186: wf_event_groups_pkg.delete_row(l_parameters(1), l_parameters(2));
187: elsif l_eventname = 'oracle.apps.wf.event.group.update' then
188: wf_event_groups_pkg.receive(x_message);
206: return(l_result);
207:
208: exception
209: when others then
210: wf_core.context('WF_EVENT_FUNCTIONS_PKG', 'RECEIVE', p_event.event_name,
211: p_subscription_guid);
212: wf_event.setErrorInfo(p_event,'ERROR');
213: return('ERROR');
214: end;
235: wf_event_t.initialize(l_event_t);
236:
237: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
238: WF_LOG_PKG.STRING(wf_log_pkg.level_procedure,
239: 'wf.plsql.WF_EVENT_FUNCTIONS_PKG.SEND.Begin',
240: 'Parameters:'||p_EventName||'*'|| p_EventKey||'*'||p_ToAgent||'*'||p_ToSystem);
241: end if;
242:
243: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
241: end if;
242:
243: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
244: WF_LOG_PKG.STRING(wf_log_pkg.level_statement,
245: 'wf.plsql.WF_EVENT_FUNCTIONS_PKG.SEND.Agent',
246: 'Populating Agent...');
247: end if;
248:
249: -- Populate the Agent
250: l_agent_t := wf_agent_t (p_ToAgent, p_ToSystem);
251:
252: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
253: WF_LOG_PKG.STRING(wf_log_pkg.level_statement,
254: 'wf.plsql.WF_EVENT_FUNCTIONS_PKG.SEND.Address',
255: 'Populating Address...');
256: end if;
257:
258: -- Populate the Address
262: pSendDate => sysdate);
263:
264: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
265: WF_LOG_PKG.STRING(wf_log_pkg.level_statement,
266: 'wf.plsql.WF_EVENT_FUNCTIONS_PKG.SEND.Content',
267: 'Populating Content');
268: end if;
269:
270: -- Populate the Content
272: pKey => p_EventKey,
273: pData => p_EventData);
274: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
275: WF_LOG_PKG.STRING(wf_log_pkg.level_statement,
276: 'wf.plsql.WF_EVENT_FUNCTIONS_PKG.SEND.Hardwire',
277: 'Hardwired Send');
278: end if;
279:
280: -- Release the hounds, hardwired send
281: wf_event.send(l_event_t);
282:
283: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
284: WF_LOG_PKG.STRING(wf_log_pkg.level_procedure,
285: 'wf.plsql.WF_EVENT_FUNCTIONS_PKG.SEND.End',
286: 'Completed Send');
287: end if;
288:
289: exception
287: end if;
288:
289: exception
290: when others then
291: wf_core.context('WF_EVENT_FUNCTIONS_PKG', 'SEND', p_EventName,
292: p_EventKey,
293: 'ERROR'); raise;
294: end;
295: ------------------------------------------------------------------------------
333: l_parameters(l_counter) := substr(p_string, l_startposition, l_amounttoread);
334:
335: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
336: wf_log_pkg.string(wf_log_pkg.level_statement,
337: 'wf.plsql.WF_EVENT_FUNCTIONS_PKG.PARAMETERS.get_pos',
338: 'String:'||p_string||' Start:'||l_startposition||
339: ' End:'||l_endposition);
340: end if;
341:
340: end if;
341:
342: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
343: wf_log_pkg.string(wf_log_pkg.level_statement,
344: 'wf.plsql.WF_EVENT_FUNCTIONS_PKG.PARAMETERS.get_param',
345: 'Parameter('||l_counter||') is '||l_parameters(l_counter));
346: end if;
347:
348: END LOOP;
350: return(l_parameters);
351:
352: exception
353: when others then
354: wf_core.context('WF_EVENT_FUNCTIONS_PKG', 'Parameters', substr(p_string,1,100),
355: p_numvalues,p_separator,
356: 'ERROR'); raise;
357: end;
358: ------------------------------------------------------------------------------
383: --
384: -- This is where we will do some logic to determine if there is a parameter
385: -- set which tells us which sequence to nextval to get the itemkey
386: --
387: l_function := wf_event_functions_pkg.SubscriptionParameters(l_parameters,
388: 'ITEMKEY');
389:
390: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
391: wf_log_pkg.string(wf_log_pkg.level_procedure,
388: 'ITEMKEY');
389:
390: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
391: wf_log_pkg.string(wf_log_pkg.level_procedure,
392: 'wf.plsql.WF_EVENT_FUNCTIONS_PKG.ADDCORRELATION.Begin',
393: 'Item Key function is '||l_function);
394: end if;
395:
396: IF l_function IS NOT NULL THEN
407: END IF;
408:
409: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
410: wf_log_pkg.string(wf_log_pkg.level_statement,
411: 'wf.plsql.WF_EVENT_FUNCTIONS_PKG.ADDCORRELATION.Set',
412: 'Item Key is '||l_itemkey);
413: end if;
414:
415: p_event.SetCorrelationId(l_itemkey);
417: return ('SUCCESS');
418:
419: exception
420: when others then
421: wf_core.context('WF_EVENT_FUNCTIONS_PKG', 'ADDCORRELATION', p_event.event_name,
422: p_event.event_key,
423: 'ERROR'); raise;
424: return('ERROR');
425: end;
478: return (l_value);
479:
480: exception
481: when others then
482: wf_core.context('WF_EVENT_FUNCTIONS_PKG', 'SUBSCRIPTIONPARAMETERS',
483: 'ERROR'); raise;
484:
485: end;
486:
665: end if;
666:
667: exception
668: when others then
669: wf_core.context('WF_EVENT_FUNCTIONS_PKG', 'SubParamInEvent',
670: p_event.event_name);
671: raise;
672:
673: end;
696:
697: end UpdateLicenseStatus;
698:
699:
700: end WF_EVENT_FUNCTIONS_PKG;