[Home] [Help]
62: -------------------------------------------------------------------------------
63:
64:
65: -- AbortProcess
66: -- cover to wf_engine abort process used in error process.
67: procedure AbortProcess(itemtype in varchar2,
68: itemkey in varchar2,
69: actid in number,
70: funcmode in varchar2,
74: l_error_itemkey varchar2(240);
75:
76: begin
77: -- Do nothing in cancel or timeout mode
78: if (funcmode <> wf_engine.eng_run) then
79: resultout := wf_engine.eng_null;
80: return;
81: end if;
82:
75:
76: begin
77: -- Do nothing in cancel or timeout mode
78: if (funcmode <> wf_engine.eng_run) then
79: resultout := wf_engine.eng_null;
80: return;
81: end if;
82:
83: --
83: --
84: -- Get the type and the key of the process that errored out
85: -- these were set in the erroring out process by Execute_Error_Process
86: --
87: l_error_itemkey := WF_ENGINE.GetItemAttrText(
88: itemtype => itemtype,
89: itemkey => itemkey,
90: aname => 'ERROR_ITEM_KEY' );
91: l_error_itemtype := WF_ENGINE.GetItemAttrText(
87: l_error_itemkey := WF_ENGINE.GetItemAttrText(
88: itemtype => itemtype,
89: itemkey => itemkey,
90: aname => 'ERROR_ITEM_KEY' );
91: l_error_itemtype := WF_ENGINE.GetItemAttrText(
92: itemtype => itemtype,
93: itemkey => itemkey,
94: aname => 'ERROR_ITEM_TYPE' );
95:
93: itemkey => itemkey,
94: aname => 'ERROR_ITEM_TYPE' );
95:
96: -- now abort the process: dont specify the process so it defaults to the root
97: Wf_Engine.AbortProcess(itemtype => l_error_itemtype, itemkey=>l_error_itemkey);
98: resultout := wf_engine.eng_null;
99:
100: exception
101: when others then
94: aname => 'ERROR_ITEM_TYPE' );
95:
96: -- now abort the process: dont specify the process so it defaults to the root
97: Wf_Engine.AbortProcess(itemtype => l_error_itemtype, itemkey=>l_error_itemkey);
98: resultout := wf_engine.eng_null;
99:
100: exception
101: when others then
102: Wf_Core.Context('Wf_Standard', 'AbortProcess', itemtype,
116: funcmode in varchar2,
117: resultout in out nocopy varchar2)
118: is
119: begin
120: resultout := wf_engine.eng_null;
121: exception
122: when others then
123: Wf_Core.Context('Wf_Standard', 'OrJoin', itemtype, itemkey,
124: to_char(actid), funcmode);
141: is
142: cnt pls_integer;
143: begin
144: -- Do nothing in cancel or timeout mode
145: if (funcmode <> wf_engine.eng_run) then
146: resultout := wf_engine.eng_null;
147: return;
148: end if;
149:
142: cnt pls_integer;
143: begin
144: -- Do nothing in cancel or timeout mode
145: if (funcmode <> wf_engine.eng_run) then
146: resultout := wf_engine.eng_null;
147: return;
148: end if;
149:
150: -- SYNCHMODE: Not allowed
147: return;
148: end if;
149:
150: -- SYNCHMODE: Not allowed
151: if (itemkey = wf_engine.eng_synch) then
152: Wf_Core.Token('OPERATION', 'Wf_Standard.AndJoin');
153: Wf_Core.Raise('WFENG_SYNCH_DISABLED');
154: end if;
155:
166: AND WIAS.ITEM_TYPE = itemtype
167: AND WIAS.ITEM_KEY = itemkey
168: AND WIAS.ACTIVITY_STATUS = 'COMPLETE'
169: AND (WAT.RESULT_CODE in (WIAS.ACTIVITY_RESULT_CODE,
170: wf_engine.eng_trans_any)
171: OR (WAT.RESULT_CODE = wf_engine.eng_trans_default
172: AND NOT EXISTS
173: (SELECT NULL
174: FROM WF_ACTIVITY_TRANSITIONS WAT2
167: AND WIAS.ITEM_KEY = itemkey
168: AND WIAS.ACTIVITY_STATUS = 'COMPLETE'
169: AND (WAT.RESULT_CODE in (WIAS.ACTIVITY_RESULT_CODE,
170: wf_engine.eng_trans_any)
171: OR (WAT.RESULT_CODE = wf_engine.eng_trans_default
172: AND NOT EXISTS
173: (SELECT NULL
174: FROM WF_ACTIVITY_TRANSITIONS WAT2
175: WHERE WAT2.FROM_PROCESS_ACTIVITY =
182: if (cnt > 0) then
183: -- This means there is at least one in-transition either incomplete
184: -- or complete with the wrong result.
185: -- The LogicalAnd fails, return a result of 'WAITING'.
186: resultout := wf_engine.eng_waiting;
187: else
188: -- This means there are no in-transition activities that are either
189: -- incomplete or complete with the wrong result.
190: -- The LogicalAnd succeeds, return a result of 'NULL' to continue.
187: else
188: -- This means there are no in-transition activities that are either
189: -- incomplete or complete with the wrong result.
190: -- The LogicalAnd succeeds, return a result of 'NULL' to continue.
191: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
192: end if;
193: return;
194: exception
195: when others then
219: aformat varchar2(240);
220: aname varchar2(30);
221: begin
222: -- Do nothing in cancel or timeout mode
223: if (funcmode <> wf_engine.eng_run) then
224: resultout := wf_engine.eng_null;
225: return;
226: end if;
227:
220: aname varchar2(30);
221: begin
222: -- Do nothing in cancel or timeout mode
223: if (funcmode <> wf_engine.eng_run) then
224: resultout := wf_engine.eng_null;
225: return;
226: end if;
227:
228: -- Get attribute info
225: return;
226: end if;
227:
228: -- Get attribute info
229: aname := wf_engine.GetActivityAttrText(itemtype, itemkey, actid, 'ATTR');
230: wf_engine.GetItemAttrInfo(itemtype, aname, atype, asubtype, aformat);
231:
232: -- NUMBER value
233: if (atype = 'NUMBER') then
226: end if;
227:
228: -- Get attribute info
229: aname := wf_engine.GetActivityAttrText(itemtype, itemkey, actid, 'ATTR');
230: wf_engine.GetItemAttrInfo(itemtype, aname, atype, asubtype, aformat);
231:
232: -- NUMBER value
233: if (atype = 'NUMBER') then
234: wf_engine.SetItemAttrNumber(itemtype,itemkey,aname,
230: wf_engine.GetItemAttrInfo(itemtype, aname, atype, asubtype, aformat);
231:
232: -- NUMBER value
233: if (atype = 'NUMBER') then
234: wf_engine.SetItemAttrNumber(itemtype,itemkey,aname,
235: wf_engine.GetActivityAttrNumber(itemtype,itemkey,actid, 'NUMBER_VALUE'));
236:
237: -- DATE value
238: elsif (atype = 'DATE') then
231:
232: -- NUMBER value
233: if (atype = 'NUMBER') then
234: wf_engine.SetItemAttrNumber(itemtype,itemkey,aname,
235: wf_engine.GetActivityAttrNumber(itemtype,itemkey,actid, 'NUMBER_VALUE'));
236:
237: -- DATE value
238: elsif (atype = 'DATE') then
239: wf_engine.SetItemAttrDate(itemtype,itemkey,aname,
235: wf_engine.GetActivityAttrNumber(itemtype,itemkey,actid, 'NUMBER_VALUE'));
236:
237: -- DATE value
238: elsif (atype = 'DATE') then
239: wf_engine.SetItemAttrDate(itemtype,itemkey,aname,
240: wf_engine.GetActivityAttrDate(itemtype,itemkey,actid, 'DATE_VALUE'));
241:
242: -- TEXT value (VARCHAR2, LOOKUP, FORM, URL, DOCUMENT, etc)
243: else
236:
237: -- DATE value
238: elsif (atype = 'DATE') then
239: wf_engine.SetItemAttrDate(itemtype,itemkey,aname,
240: wf_engine.GetActivityAttrDate(itemtype,itemkey,actid, 'DATE_VALUE'));
241:
242: -- TEXT value (VARCHAR2, LOOKUP, FORM, URL, DOCUMENT, etc)
243: else
244: wf_engine.SetItemAttrText(itemtype,itemkey,aname,
240: wf_engine.GetActivityAttrDate(itemtype,itemkey,actid, 'DATE_VALUE'));
241:
242: -- TEXT value (VARCHAR2, LOOKUP, FORM, URL, DOCUMENT, etc)
243: else
244: wf_engine.SetItemAttrText(itemtype,itemkey,aname,
245: wf_engine.GetActivityAttrText(itemtype,itemkey,actid, 'TEXT_VALUE'));
246: end if;
247:
248: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
241:
242: -- TEXT value (VARCHAR2, LOOKUP, FORM, URL, DOCUMENT, etc)
243: else
244: wf_engine.SetItemAttrText(itemtype,itemkey,aname,
245: wf_engine.GetActivityAttrText(itemtype,itemkey,actid, 'TEXT_VALUE'));
246: end if;
247:
248: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
249: exception
244: wf_engine.SetItemAttrText(itemtype,itemkey,aname,
245: wf_engine.GetActivityAttrText(itemtype,itemkey,actid, 'TEXT_VALUE'));
246: end if;
247:
248: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
249: exception
250: when others then
251: Wf_Core.Context('Wf_Standard', 'Assign', itemtype,
252: itemkey, to_char(actid), funcmode);
270: aname varchar2(30);
271: admin varchar2(8);
272: begin
273: -- Do nothing in cancel or timeout mode
274: if (funcmode <> wf_engine.eng_run) then
275: resultout := wf_engine.eng_null;
276: return;
277: end if;
278:
271: admin varchar2(8);
272: begin
273: -- Do nothing in cancel or timeout mode
274: if (funcmode <> wf_engine.eng_run) then
275: resultout := wf_engine.eng_null;
276: return;
277: end if;
278:
279: -- SYNCHMODE: Not allowed
276: return;
277: end if;
278:
279: -- SYNCHMODE: Not allowed
280: if (itemkey = wf_engine.eng_synch) then
281: Wf_Core.Token('OPERATION', 'Wf_Standard.GetUrl');
282: Wf_Core.Raise('WFENG_SYNCH_DISABLED');
283: end if;
284:
282: Wf_Core.Raise('WFENG_SYNCH_DISABLED');
283: end if;
284:
285: -- Get item attribute name
286: aname := wf_engine.GetActivityAttrText(itemtype,itemkey,actid, 'ATTR');
287:
288: -- Get admin mode
289: admin := wf_engine.GetActivityAttrText(itemtype,itemkey,actid, 'ADMIN_MODE');
290:
285: -- Get item attribute name
286: aname := wf_engine.GetActivityAttrText(itemtype,itemkey,actid, 'ATTR');
287:
288: -- Get admin mode
289: admin := wf_engine.GetActivityAttrText(itemtype,itemkey,actid, 'ADMIN_MODE');
290:
291: -- Set item attribute
292: wf_engine.SetItemAttrText(itemtype, itemkey, aname,
293: wf_monitor.geturl(
288: -- Get admin mode
289: admin := wf_engine.GetActivityAttrText(itemtype,itemkey,actid, 'ADMIN_MODE');
290:
291: -- Set item attribute
292: wf_engine.SetItemAttrText(itemtype, itemkey, aname,
293: wf_monitor.geturl(
294: wf_core.translate('WF_WEB_AGENT'), itemtype, itemkey, admin));
295:
296: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
292: wf_engine.SetItemAttrText(itemtype, itemkey, aname,
293: wf_monitor.geturl(
294: wf_core.translate('WF_WEB_AGENT'), itemtype, itemkey, admin));
295:
296: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
297: exception
298: when others then
299: Wf_Core.Context('Wf_Standard', 'GetUrl', itemtype,
300: itemkey, to_char(actid), funcmode);
326: tval1 varchar2(4000);
327: tval2 varchar2(4000);
328: begin
329: -- Do nothing in cancel or timeout mode
330: if (funcmode <> wf_engine.eng_run) then
331: resultout := wf_engine.eng_null;
332: return;
333: end if;
334:
327: tval2 varchar2(4000);
328: begin
329: -- Do nothing in cancel or timeout mode
330: if (funcmode <> wf_engine.eng_run) then
331: resultout := wf_engine.eng_null;
332: return;
333: end if;
334:
335: -- Get comparison data type
332: return;
333: end if;
334:
335: -- Get comparison data type
336: Wf_Engine.GetActivityAttrInfo(itemtype, itemkey, actid, 'VALUE1',
337: atype, asubtype, aformat);
338:
339: tval1 := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'VALUE1');
340:
335: -- Get comparison data type
336: Wf_Engine.GetActivityAttrInfo(itemtype, itemkey, actid, 'VALUE1',
337: atype, asubtype, aformat);
338:
339: tval1 := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'VALUE1');
340:
341:
342: --
343: -- NUMBER value
343: -- NUMBER value
344: --
345: if (atype = 'NUMBER') then
346: -- Get the two number values
347: nval1 := Wf_Engine.GetActivityAttrNumber(itemtype,itemkey,actid, 'VALUE1');
348: nval2 := Wf_Engine.GetActivityAttrNumber(itemtype,itemkey,actid, 'VALUE2');
349:
350: -- Compare
351: if (nval1 is null or nval2 is null) then
344: --
345: if (atype = 'NUMBER') then
346: -- Get the two number values
347: nval1 := Wf_Engine.GetActivityAttrNumber(itemtype,itemkey,actid, 'VALUE1');
348: nval2 := Wf_Engine.GetActivityAttrNumber(itemtype,itemkey,actid, 'VALUE2');
349:
350: -- Compare
351: if (nval1 is null or nval2 is null) then
352: resultout := wf_engine.eng_completed||':NULL';
348: nval2 := Wf_Engine.GetActivityAttrNumber(itemtype,itemkey,actid, 'VALUE2');
349:
350: -- Compare
351: if (nval1 is null or nval2 is null) then
352: resultout := wf_engine.eng_completed||':NULL';
353: elsif (nval1 < nval2) then
354: resultout := wf_engine.eng_completed||':LT';
355: elsif (nval1 > nval2) then
356: resultout := wf_engine.eng_completed||':GT';
350: -- Compare
351: if (nval1 is null or nval2 is null) then
352: resultout := wf_engine.eng_completed||':NULL';
353: elsif (nval1 < nval2) then
354: resultout := wf_engine.eng_completed||':LT';
355: elsif (nval1 > nval2) then
356: resultout := wf_engine.eng_completed||':GT';
357: elsif (nval1 = nval2) then
358: resultout := wf_engine.eng_completed||':EQ';
352: resultout := wf_engine.eng_completed||':NULL';
353: elsif (nval1 < nval2) then
354: resultout := wf_engine.eng_completed||':LT';
355: elsif (nval1 > nval2) then
356: resultout := wf_engine.eng_completed||':GT';
357: elsif (nval1 = nval2) then
358: resultout := wf_engine.eng_completed||':EQ';
359: end if;
360:
354: resultout := wf_engine.eng_completed||':LT';
355: elsif (nval1 > nval2) then
356: resultout := wf_engine.eng_completed||':GT';
357: elsif (nval1 = nval2) then
358: resultout := wf_engine.eng_completed||':EQ';
359: end if;
360:
361: --
362: -- DATE value
362: -- DATE value
363: --
364: elsif (atype = 'DATE') then
365: -- Get the two date values
366: dval1 := Wf_Engine.GetActivityAttrDate(itemtype,itemkey,actid, 'VALUE1');
367: dval2 := Wf_Engine.GetActivityAttrDate(itemtype,itemkey,actid, 'VALUE2');
368:
369: -- Compare
370: if (dval1 is null or dval2 is null) then
363: --
364: elsif (atype = 'DATE') then
365: -- Get the two date values
366: dval1 := Wf_Engine.GetActivityAttrDate(itemtype,itemkey,actid, 'VALUE1');
367: dval2 := Wf_Engine.GetActivityAttrDate(itemtype,itemkey,actid, 'VALUE2');
368:
369: -- Compare
370: if (dval1 is null or dval2 is null) then
371: resultout := wf_engine.eng_completed||':NULL';
367: dval2 := Wf_Engine.GetActivityAttrDate(itemtype,itemkey,actid, 'VALUE2');
368:
369: -- Compare
370: if (dval1 is null or dval2 is null) then
371: resultout := wf_engine.eng_completed||':NULL';
372: elsif (dval1 < dval2) then
373: resultout := wf_engine.eng_completed||':LT';
374: elsif (dval1 > dval2) then
375: resultout := wf_engine.eng_completed||':GT';
369: -- Compare
370: if (dval1 is null or dval2 is null) then
371: resultout := wf_engine.eng_completed||':NULL';
372: elsif (dval1 < dval2) then
373: resultout := wf_engine.eng_completed||':LT';
374: elsif (dval1 > dval2) then
375: resultout := wf_engine.eng_completed||':GT';
376: elsif (dval1 = dval2) then
377: resultout := wf_engine.eng_completed||':EQ';
371: resultout := wf_engine.eng_completed||':NULL';
372: elsif (dval1 < dval2) then
373: resultout := wf_engine.eng_completed||':LT';
374: elsif (dval1 > dval2) then
375: resultout := wf_engine.eng_completed||':GT';
376: elsif (dval1 = dval2) then
377: resultout := wf_engine.eng_completed||':EQ';
378: end if;
379:
373: resultout := wf_engine.eng_completed||':LT';
374: elsif (dval1 > dval2) then
375: resultout := wf_engine.eng_completed||':GT';
376: elsif (dval1 = dval2) then
377: resultout := wf_engine.eng_completed||':EQ';
378: end if;
379:
380: --
381: -- TEXT value (VARCHAR2, LOOKUP, FORM, URL, DOCUMENT, etc)
381: -- TEXT value (VARCHAR2, LOOKUP, FORM, URL, DOCUMENT, etc)
382: --
383: else
384: -- Get the two text values
385: tval1 := Wf_Engine.GetActivityAttrText(itemtype,itemkey,actid, 'VALUE1');
386: tval2 := Wf_Engine.GetActivityAttrText(itemtype,itemkey,actid, 'VALUE2');
387:
388: -- Compare
389: if (tval1 is null or tval2 is null) then
382: --
383: else
384: -- Get the two text values
385: tval1 := Wf_Engine.GetActivityAttrText(itemtype,itemkey,actid, 'VALUE1');
386: tval2 := Wf_Engine.GetActivityAttrText(itemtype,itemkey,actid, 'VALUE2');
387:
388: -- Compare
389: if (tval1 is null or tval2 is null) then
390: resultout := wf_engine.eng_completed||':NULL';
386: tval2 := Wf_Engine.GetActivityAttrText(itemtype,itemkey,actid, 'VALUE2');
387:
388: -- Compare
389: if (tval1 is null or tval2 is null) then
390: resultout := wf_engine.eng_completed||':NULL';
391: elsif (tval1 < tval2) then
392: resultout := wf_engine.eng_completed||':LT';
393: elsif (tval1 > tval2) then
394: resultout := wf_engine.eng_completed||':GT';
388: -- Compare
389: if (tval1 is null or tval2 is null) then
390: resultout := wf_engine.eng_completed||':NULL';
391: elsif (tval1 < tval2) then
392: resultout := wf_engine.eng_completed||':LT';
393: elsif (tval1 > tval2) then
394: resultout := wf_engine.eng_completed||':GT';
395: elsif (tval1 = tval2) then
396: resultout := wf_engine.eng_completed||':EQ';
390: resultout := wf_engine.eng_completed||':NULL';
391: elsif (tval1 < tval2) then
392: resultout := wf_engine.eng_completed||':LT';
393: elsif (tval1 > tval2) then
394: resultout := wf_engine.eng_completed||':GT';
395: elsif (tval1 = tval2) then
396: resultout := wf_engine.eng_completed||':EQ';
397: end if;
398: end if;
392: resultout := wf_engine.eng_completed||':LT';
393: elsif (tval1 > tval2) then
394: resultout := wf_engine.eng_completed||':GT';
395: elsif (tval1 = tval2) then
396: resultout := wf_engine.eng_completed||':EQ';
397: end if;
398: end if;
399:
400: exception
439: and item_key = itemkey;
440:
441: begin
442: -- Do nothing in cancel or timeout mode
443: if (funcmode <> wf_engine.eng_run) then
444: resultout := wf_engine.eng_null;
445: return;
446: end if;
447:
440:
441: begin
442: -- Do nothing in cancel or timeout mode
443: if (funcmode <> wf_engine.eng_run) then
444: resultout := wf_engine.eng_null;
445: return;
446: end if;
447:
448: Ptype := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'PARENTTYPE');
444: resultout := wf_engine.eng_null;
445: return;
446: end if;
447:
448: Ptype := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'PARENTTYPE');
449:
450: if Ptype = 'ROOT' then
451: -- calculate the execution time
452: open GetExecutionTime(itemtype, itemkey);
452: open GetExecutionTime(itemtype, itemkey);
453: fetch GetExecutionTime into delta;
454: close GetExecutionTime;
455: else
456: processid := WF_ENGINE_UTIL.activity_parent_process(itemtype, itemkey, actid);
457:
458: -- calculate the execution time
459: open GetRunningTime(itemtype, itemkey, processid);
460: fetch GetRunningTime into delta;
461: close GetRunningTime;
462: end if;
463:
464: -- look up the test value for execution time
465: Etime := Wf_Engine.GetActivityAttrNumber(itemtype, itemkey, actid, 'EXECUTIONTIME');
466:
467: -- execute comparison
468: if (delta is null or etime is null) then
469: resultout := wf_engine.eng_completed||':NULL';
465: Etime := Wf_Engine.GetActivityAttrNumber(itemtype, itemkey, actid, 'EXECUTIONTIME');
466:
467: -- execute comparison
468: if (delta is null or etime is null) then
469: resultout := wf_engine.eng_completed||':NULL';
470: elsif (delta < etime) then
471: resultout := wf_engine.eng_completed||':LT';
472: elsif (delta > etime) then
473: resultout := wf_engine.eng_completed||':GT';
467: -- execute comparison
468: if (delta is null or etime is null) then
469: resultout := wf_engine.eng_completed||':NULL';
470: elsif (delta < etime) then
471: resultout := wf_engine.eng_completed||':LT';
472: elsif (delta > etime) then
473: resultout := wf_engine.eng_completed||':GT';
474: elsif (delta = etime) then
475: resultout := wf_engine.eng_completed||':EQ';
469: resultout := wf_engine.eng_completed||':NULL';
470: elsif (delta < etime) then
471: resultout := wf_engine.eng_completed||':LT';
472: elsif (delta > etime) then
473: resultout := wf_engine.eng_completed||':GT';
474: elsif (delta = etime) then
475: resultout := wf_engine.eng_completed||':EQ';
476: end if;
477:
471: resultout := wf_engine.eng_completed||':LT';
472: elsif (delta > etime) then
473: resultout := wf_engine.eng_completed||':GT';
474: elsif (delta = etime) then
475: resultout := wf_engine.eng_completed||':EQ';
476: end if;
477:
478: exception
479: when others then
515: lSubType VARCHAR2 (20);
516: lFormat VARCHAR2 (20);
517:
518: begin
519: lEvent := wf_engine.getActivityAttrEvent(itemtype, itemkey,
520: actid, 'EVENT');
521: lProperty := wf_engine.getActivityAttrText(itemtype, itemkey,
522: actid, 'PROPERTY');
523:
517:
518: begin
519: lEvent := wf_engine.getActivityAttrEvent(itemtype, itemkey,
520: actid, 'EVENT');
521: lProperty := wf_engine.getActivityAttrText(itemtype, itemkey,
522: actid, 'PROPERTY');
523:
524: if (lProperty = 'PRIORITY') then
525: lNVal := wf_engine.getActivityAttrNumber(itemtype, itemkey,
521: lProperty := wf_engine.getActivityAttrText(itemtype, itemkey,
522: actid, 'PROPERTY');
523:
524: if (lProperty = 'PRIORITY') then
525: lNVal := wf_engine.getActivityAttrNumber(itemtype, itemkey,
526: actid, 'NUMBER_VALUE');
527: if (lEvent.priority is NULL or lNVal is NULL) then
528: resultout := wf_engine.eng_completed||':NULL';
529: elsif (lEvent.priority < lNVal) then
524: if (lProperty = 'PRIORITY') then
525: lNVal := wf_engine.getActivityAttrNumber(itemtype, itemkey,
526: actid, 'NUMBER_VALUE');
527: if (lEvent.priority is NULL or lNVal is NULL) then
528: resultout := wf_engine.eng_completed||':NULL';
529: elsif (lEvent.priority < lNVal) then
530: resultout := wf_engine.eng_completed||':LT';
531: elsif (lEvent.priority > lNVal) then
532: resultout := wf_engine.eng_completed||':GT';
526: actid, 'NUMBER_VALUE');
527: if (lEvent.priority is NULL or lNVal is NULL) then
528: resultout := wf_engine.eng_completed||':NULL';
529: elsif (lEvent.priority < lNVal) then
530: resultout := wf_engine.eng_completed||':LT';
531: elsif (lEvent.priority > lNVal) then
532: resultout := wf_engine.eng_completed||':GT';
533: elsif (lEvent.priority = lNVal) then
534: resultout := wf_engine.eng_completed||':EQ';
528: resultout := wf_engine.eng_completed||':NULL';
529: elsif (lEvent.priority < lNVal) then
530: resultout := wf_engine.eng_completed||':LT';
531: elsif (lEvent.priority > lNVal) then
532: resultout := wf_engine.eng_completed||':GT';
533: elsif (lEvent.priority = lNVal) then
534: resultout := wf_engine.eng_completed||':EQ';
535: end if;
536:
530: resultout := wf_engine.eng_completed||':LT';
531: elsif (lEvent.priority > lNVal) then
532: resultout := wf_engine.eng_completed||':GT';
533: elsif (lEvent.priority = lNVal) then
534: resultout := wf_engine.eng_completed||':EQ';
535: end if;
536:
537: elsif (lProperty = 'SEND_DATE') then
538: lDVal := wf_engine.getActivityAttrDate(itemtype, itemkey,
534: resultout := wf_engine.eng_completed||':EQ';
535: end if;
536:
537: elsif (lProperty = 'SEND_DATE') then
538: lDVal := wf_engine.getActivityAttrDate(itemtype, itemkey,
539: actid, 'DATE_VALUE');
540: if (lEvent.send_date is NULL or lDVal is null) then
541: resultout := wf_engine.eng_completed||':NULL';
542: elsif (lEvent.send_date < lDVal) then
537: elsif (lProperty = 'SEND_DATE') then
538: lDVal := wf_engine.getActivityAttrDate(itemtype, itemkey,
539: actid, 'DATE_VALUE');
540: if (lEvent.send_date is NULL or lDVal is null) then
541: resultout := wf_engine.eng_completed||':NULL';
542: elsif (lEvent.send_date < lDVal) then
543: resultout := wf_engine.eng_completed||':LT';
544: elsif (lEvent.send_date > lDVal) then
545: resultout := wf_engine.eng_completed||':GT';
539: actid, 'DATE_VALUE');
540: if (lEvent.send_date is NULL or lDVal is null) then
541: resultout := wf_engine.eng_completed||':NULL';
542: elsif (lEvent.send_date < lDVal) then
543: resultout := wf_engine.eng_completed||':LT';
544: elsif (lEvent.send_date > lDVal) then
545: resultout := wf_engine.eng_completed||':GT';
546: elsif (lEvent.send_date = lDVal) then
547: resultout := wf_engine.eng_completed||':EQ';
541: resultout := wf_engine.eng_completed||':NULL';
542: elsif (lEvent.send_date < lDVal) then
543: resultout := wf_engine.eng_completed||':LT';
544: elsif (lEvent.send_date > lDVal) then
545: resultout := wf_engine.eng_completed||':GT';
546: elsif (lEvent.send_date = lDVal) then
547: resultout := wf_engine.eng_completed||':EQ';
548: end if;
549: elsif (lProperty = 'RECEIVE_DATE') then
543: resultout := wf_engine.eng_completed||':LT';
544: elsif (lEvent.send_date > lDVal) then
545: resultout := wf_engine.eng_completed||':GT';
546: elsif (lEvent.send_date = lDVal) then
547: resultout := wf_engine.eng_completed||':EQ';
548: end if;
549: elsif (lProperty = 'RECEIVE_DATE') then
550: lDVal := wf_engine.getActivityAttrDate(itemtype, itemkey,
551: actid, 'DATE_VALUE');
546: elsif (lEvent.send_date = lDVal) then
547: resultout := wf_engine.eng_completed||':EQ';
548: end if;
549: elsif (lProperty = 'RECEIVE_DATE') then
550: lDVal := wf_engine.getActivityAttrDate(itemtype, itemkey,
551: actid, 'DATE_VALUE');
552: if (lEvent.receive_date is NULL or lDVal is null) then
553: resultout := wf_engine.eng_completed||':NULL';
554: elsif (lEvent.receive_date < lDVal) then
549: elsif (lProperty = 'RECEIVE_DATE') then
550: lDVal := wf_engine.getActivityAttrDate(itemtype, itemkey,
551: actid, 'DATE_VALUE');
552: if (lEvent.receive_date is NULL or lDVal is null) then
553: resultout := wf_engine.eng_completed||':NULL';
554: elsif (lEvent.receive_date < lDVal) then
555: resultout := wf_engine.eng_completed||':LT';
556: elsif (lEvent.receive_date > lDVal) then
557: resultout := wf_engine.eng_completed||':GT';
551: actid, 'DATE_VALUE');
552: if (lEvent.receive_date is NULL or lDVal is null) then
553: resultout := wf_engine.eng_completed||':NULL';
554: elsif (lEvent.receive_date < lDVal) then
555: resultout := wf_engine.eng_completed||':LT';
556: elsif (lEvent.receive_date > lDVal) then
557: resultout := wf_engine.eng_completed||':GT';
558: elsif (lEvent.receive_date = lDVal) then
559: resultout := wf_engine.eng_completed||':EQ';
553: resultout := wf_engine.eng_completed||':NULL';
554: elsif (lEvent.receive_date < lDVal) then
555: resultout := wf_engine.eng_completed||':LT';
556: elsif (lEvent.receive_date > lDVal) then
557: resultout := wf_engine.eng_completed||':GT';
558: elsif (lEvent.receive_date = lDVal) then
559: resultout := wf_engine.eng_completed||':EQ';
560: end if;
561: elsif (lProperty = 'CORRELATION_ID') then
555: resultout := wf_engine.eng_completed||':LT';
556: elsif (lEvent.receive_date > lDVal) then
557: resultout := wf_engine.eng_completed||':GT';
558: elsif (lEvent.receive_date = lDVal) then
559: resultout := wf_engine.eng_completed||':EQ';
560: end if;
561: elsif (lProperty = 'CORRELATION_ID') then
562: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
563: actid, 'TEXT_VALUE');
558: elsif (lEvent.receive_date = lDVal) then
559: resultout := wf_engine.eng_completed||':EQ';
560: end if;
561: elsif (lProperty = 'CORRELATION_ID') then
562: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
563: actid, 'TEXT_VALUE');
564: if (LEvent.correlation_id is NULL or lTVal is NULL) then
565: resultout := wf_engine.eng_completed||':NULL';
566: elsif (LEvent.correlation_id < lTVal) then
561: elsif (lProperty = 'CORRELATION_ID') then
562: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
563: actid, 'TEXT_VALUE');
564: if (LEvent.correlation_id is NULL or lTVal is NULL) then
565: resultout := wf_engine.eng_completed||':NULL';
566: elsif (LEvent.correlation_id < lTVal) then
567: resultout := wf_engine.eng_completed||':LT';
568: elsif (LEvent.correlation_id > lTVal) then
569: resultout := wf_engine.eng_completed||':GT';
563: actid, 'TEXT_VALUE');
564: if (LEvent.correlation_id is NULL or lTVal is NULL) then
565: resultout := wf_engine.eng_completed||':NULL';
566: elsif (LEvent.correlation_id < lTVal) then
567: resultout := wf_engine.eng_completed||':LT';
568: elsif (LEvent.correlation_id > lTVal) then
569: resultout := wf_engine.eng_completed||':GT';
570: elsif (LEvent.correlation_id = lTVal) then
571: resultout := wf_engine.eng_completed||':EQ';
565: resultout := wf_engine.eng_completed||':NULL';
566: elsif (LEvent.correlation_id < lTVal) then
567: resultout := wf_engine.eng_completed||':LT';
568: elsif (LEvent.correlation_id > lTVal) then
569: resultout := wf_engine.eng_completed||':GT';
570: elsif (LEvent.correlation_id = lTVal) then
571: resultout := wf_engine.eng_completed||':EQ';
572: end if;
573: elsif (lProperty = 'EVENT_NAME') then
567: resultout := wf_engine.eng_completed||':LT';
568: elsif (LEvent.correlation_id > lTVal) then
569: resultout := wf_engine.eng_completed||':GT';
570: elsif (LEvent.correlation_id = lTVal) then
571: resultout := wf_engine.eng_completed||':EQ';
572: end if;
573: elsif (lProperty = 'EVENT_NAME') then
574: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
575: actid, 'TEXT_VALUE');
570: elsif (LEvent.correlation_id = lTVal) then
571: resultout := wf_engine.eng_completed||':EQ';
572: end if;
573: elsif (lProperty = 'EVENT_NAME') then
574: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
575: actid, 'TEXT_VALUE');
576: if (LEvent.event_name is NULL or lTVal is NULL) then
577: resultout := wf_engine.eng_completed||':NULL';
578: elsif (LEvent.event_name < lTVal) then
573: elsif (lProperty = 'EVENT_NAME') then
574: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
575: actid, 'TEXT_VALUE');
576: if (LEvent.event_name is NULL or lTVal is NULL) then
577: resultout := wf_engine.eng_completed||':NULL';
578: elsif (LEvent.event_name < lTVal) then
579: resultout := wf_engine.eng_completed||':LT';
580: elsif (LEvent.event_name > lTVal) then
581: resultout := wf_engine.eng_completed||':GT';
575: actid, 'TEXT_VALUE');
576: if (LEvent.event_name is NULL or lTVal is NULL) then
577: resultout := wf_engine.eng_completed||':NULL';
578: elsif (LEvent.event_name < lTVal) then
579: resultout := wf_engine.eng_completed||':LT';
580: elsif (LEvent.event_name > lTVal) then
581: resultout := wf_engine.eng_completed||':GT';
582: elsif (LEvent.event_name = lTVal) then
583: resultout := wf_engine.eng_completed||':EQ';
577: resultout := wf_engine.eng_completed||':NULL';
578: elsif (LEvent.event_name < lTVal) then
579: resultout := wf_engine.eng_completed||':LT';
580: elsif (LEvent.event_name > lTVal) then
581: resultout := wf_engine.eng_completed||':GT';
582: elsif (LEvent.event_name = lTVal) then
583: resultout := wf_engine.eng_completed||':EQ';
584: end if;
585: elsif (lProperty = 'EVENT_KEY') then
579: resultout := wf_engine.eng_completed||':LT';
580: elsif (LEvent.event_name > lTVal) then
581: resultout := wf_engine.eng_completed||':GT';
582: elsif (LEvent.event_name = lTVal) then
583: resultout := wf_engine.eng_completed||':EQ';
584: end if;
585: elsif (lProperty = 'EVENT_KEY') then
586: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
587: actid, 'TEXT_VALUE');
582: elsif (LEvent.event_name = lTVal) then
583: resultout := wf_engine.eng_completed||':EQ';
584: end if;
585: elsif (lProperty = 'EVENT_KEY') then
586: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
587: actid, 'TEXT_VALUE');
588: if (LEvent.event_key is NULL or lTVal is NULL) then
589: resultout := wf_engine.eng_completed||':NULL';
590: elsif (LEvent.event_key < lTVal) then
585: elsif (lProperty = 'EVENT_KEY') then
586: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
587: actid, 'TEXT_VALUE');
588: if (LEvent.event_key is NULL or lTVal is NULL) then
589: resultout := wf_engine.eng_completed||':NULL';
590: elsif (LEvent.event_key < lTVal) then
591: resultout := wf_engine.eng_completed||':LT';
592: elsif (LEvent.event_key > lTVal) then
593: resultout := wf_engine.eng_completed||':GT';
587: actid, 'TEXT_VALUE');
588: if (LEvent.event_key is NULL or lTVal is NULL) then
589: resultout := wf_engine.eng_completed||':NULL';
590: elsif (LEvent.event_key < lTVal) then
591: resultout := wf_engine.eng_completed||':LT';
592: elsif (LEvent.event_key > lTVal) then
593: resultout := wf_engine.eng_completed||':GT';
594: elsif (LEvent.event_key = lTVal) then
595: resultout := wf_engine.eng_completed||':EQ';
589: resultout := wf_engine.eng_completed||':NULL';
590: elsif (LEvent.event_key < lTVal) then
591: resultout := wf_engine.eng_completed||':LT';
592: elsif (LEvent.event_key > lTVal) then
593: resultout := wf_engine.eng_completed||':GT';
594: elsif (LEvent.event_key = lTVal) then
595: resultout := wf_engine.eng_completed||':EQ';
596: end if;
597: elsif (lProperty = 'FROM_AGENT_NAME') then
591: resultout := wf_engine.eng_completed||':LT';
592: elsif (LEvent.event_key > lTVal) then
593: resultout := wf_engine.eng_completed||':GT';
594: elsif (LEvent.event_key = lTVal) then
595: resultout := wf_engine.eng_completed||':EQ';
596: end if;
597: elsif (lProperty = 'FROM_AGENT_NAME') then
598: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
599: actid, 'TEXT_VALUE');
594: elsif (LEvent.event_key = lTVal) then
595: resultout := wf_engine.eng_completed||':EQ';
596: end if;
597: elsif (lProperty = 'FROM_AGENT_NAME') then
598: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
599: actid, 'TEXT_VALUE');
600: if (LEvent.From_Agent.Name is NULL or lTVal is NULL) then
601: resultout := wf_engine.eng_completed||':NULL';
602: elsif (LEvent.From_Agent.Name < lTVal) then
597: elsif (lProperty = 'FROM_AGENT_NAME') then
598: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
599: actid, 'TEXT_VALUE');
600: if (LEvent.From_Agent.Name is NULL or lTVal is NULL) then
601: resultout := wf_engine.eng_completed||':NULL';
602: elsif (LEvent.From_Agent.Name < lTVal) then
603: resultout := wf_engine.eng_completed||':LT';
604: elsif (LEvent.From_Agent.Name > lTVal) then
605: resultout := wf_engine.eng_completed||':GT';
599: actid, 'TEXT_VALUE');
600: if (LEvent.From_Agent.Name is NULL or lTVal is NULL) then
601: resultout := wf_engine.eng_completed||':NULL';
602: elsif (LEvent.From_Agent.Name < lTVal) then
603: resultout := wf_engine.eng_completed||':LT';
604: elsif (LEvent.From_Agent.Name > lTVal) then
605: resultout := wf_engine.eng_completed||':GT';
606: elsif (LEvent.From_Agent.Name = lTVal) then
607: resultout := wf_engine.eng_completed||':EQ';
601: resultout := wf_engine.eng_completed||':NULL';
602: elsif (LEvent.From_Agent.Name < lTVal) then
603: resultout := wf_engine.eng_completed||':LT';
604: elsif (LEvent.From_Agent.Name > lTVal) then
605: resultout := wf_engine.eng_completed||':GT';
606: elsif (LEvent.From_Agent.Name = lTVal) then
607: resultout := wf_engine.eng_completed||':EQ';
608: end if;
609: elsif (lProperty = 'FROM_AGENT_SYSTEM') then
603: resultout := wf_engine.eng_completed||':LT';
604: elsif (LEvent.From_Agent.Name > lTVal) then
605: resultout := wf_engine.eng_completed||':GT';
606: elsif (LEvent.From_Agent.Name = lTVal) then
607: resultout := wf_engine.eng_completed||':EQ';
608: end if;
609: elsif (lProperty = 'FROM_AGENT_SYSTEM') then
610: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
611: actid, 'TEXT_VALUE');
606: elsif (LEvent.From_Agent.Name = lTVal) then
607: resultout := wf_engine.eng_completed||':EQ';
608: end if;
609: elsif (lProperty = 'FROM_AGENT_SYSTEM') then
610: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
611: actid, 'TEXT_VALUE');
612: if (LEvent.From_Agent.System is NULL or lTVal is NULL) then
613: resultout := wf_engine.eng_completed||':NULL';
614: elsif (LEvent.From_Agent.System < lTVal) then
609: elsif (lProperty = 'FROM_AGENT_SYSTEM') then
610: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
611: actid, 'TEXT_VALUE');
612: if (LEvent.From_Agent.System is NULL or lTVal is NULL) then
613: resultout := wf_engine.eng_completed||':NULL';
614: elsif (LEvent.From_Agent.System < lTVal) then
615: resultout := wf_engine.eng_completed||':LT';
616: elsif (LEvent.From_Agent.System > lTVal) then
617: resultout := wf_engine.eng_completed||':GT';
611: actid, 'TEXT_VALUE');
612: if (LEvent.From_Agent.System is NULL or lTVal is NULL) then
613: resultout := wf_engine.eng_completed||':NULL';
614: elsif (LEvent.From_Agent.System < lTVal) then
615: resultout := wf_engine.eng_completed||':LT';
616: elsif (LEvent.From_Agent.System > lTVal) then
617: resultout := wf_engine.eng_completed||':GT';
618: elsif (LEvent.From_Agent.System = lTVal) then
619: resultout := wf_engine.eng_completed||':EQ';
613: resultout := wf_engine.eng_completed||':NULL';
614: elsif (LEvent.From_Agent.System < lTVal) then
615: resultout := wf_engine.eng_completed||':LT';
616: elsif (LEvent.From_Agent.System > lTVal) then
617: resultout := wf_engine.eng_completed||':GT';
618: elsif (LEvent.From_Agent.System = lTVal) then
619: resultout := wf_engine.eng_completed||':EQ';
620: end if;
621: elsif (lProperty = 'TO_AGENT_NAME') then
615: resultout := wf_engine.eng_completed||':LT';
616: elsif (LEvent.From_Agent.System > lTVal) then
617: resultout := wf_engine.eng_completed||':GT';
618: elsif (LEvent.From_Agent.System = lTVal) then
619: resultout := wf_engine.eng_completed||':EQ';
620: end if;
621: elsif (lProperty = 'TO_AGENT_NAME') then
622: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
623: actid, 'TEXT_VALUE');
618: elsif (LEvent.From_Agent.System = lTVal) then
619: resultout := wf_engine.eng_completed||':EQ';
620: end if;
621: elsif (lProperty = 'TO_AGENT_NAME') then
622: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
623: actid, 'TEXT_VALUE');
624: if (LEvent.To_Agent.Name is NULL or lTVal is NULL) then
625: resultout := wf_engine.eng_completed||':NULL';
626: elsif (LEvent.To_Agent.Name < lTVal) then
621: elsif (lProperty = 'TO_AGENT_NAME') then
622: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
623: actid, 'TEXT_VALUE');
624: if (LEvent.To_Agent.Name is NULL or lTVal is NULL) then
625: resultout := wf_engine.eng_completed||':NULL';
626: elsif (LEvent.To_Agent.Name < lTVal) then
627: resultout := wf_engine.eng_completed||':LT';
628: elsif (LEvent.To_Agent.Name > lTVal) then
629: resultout := wf_engine.eng_completed||':GT';
623: actid, 'TEXT_VALUE');
624: if (LEvent.To_Agent.Name is NULL or lTVal is NULL) then
625: resultout := wf_engine.eng_completed||':NULL';
626: elsif (LEvent.To_Agent.Name < lTVal) then
627: resultout := wf_engine.eng_completed||':LT';
628: elsif (LEvent.To_Agent.Name > lTVal) then
629: resultout := wf_engine.eng_completed||':GT';
630: elsif (LEvent.To_Agent.Name = lTVal) then
631: resultout := wf_engine.eng_completed||':EQ';
625: resultout := wf_engine.eng_completed||':NULL';
626: elsif (LEvent.To_Agent.Name < lTVal) then
627: resultout := wf_engine.eng_completed||':LT';
628: elsif (LEvent.To_Agent.Name > lTVal) then
629: resultout := wf_engine.eng_completed||':GT';
630: elsif (LEvent.To_Agent.Name = lTVal) then
631: resultout := wf_engine.eng_completed||':EQ';
632: end if;
633: elsif (lProperty = 'TO_AGENT_SYSTEM') then
627: resultout := wf_engine.eng_completed||':LT';
628: elsif (LEvent.To_Agent.Name > lTVal) then
629: resultout := wf_engine.eng_completed||':GT';
630: elsif (LEvent.To_Agent.Name = lTVal) then
631: resultout := wf_engine.eng_completed||':EQ';
632: end if;
633: elsif (lProperty = 'TO_AGENT_SYSTEM') then
634: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
635: actid, 'TEXT_VALUE');
630: elsif (LEvent.To_Agent.Name = lTVal) then
631: resultout := wf_engine.eng_completed||':EQ';
632: end if;
633: elsif (lProperty = 'TO_AGENT_SYSTEM') then
634: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
635: actid, 'TEXT_VALUE');
636: if (LEvent.To_Agent.System is NULL or lTVal is NULL) then
637: resultout := wf_engine.eng_completed||':NULL';
638: elsif (LEvent.To_Agent.System < lTVal) then
633: elsif (lProperty = 'TO_AGENT_SYSTEM') then
634: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
635: actid, 'TEXT_VALUE');
636: if (LEvent.To_Agent.System is NULL or lTVal is NULL) then
637: resultout := wf_engine.eng_completed||':NULL';
638: elsif (LEvent.To_Agent.System < lTVal) then
639: resultout := wf_engine.eng_completed||':LT';
640: elsif (LEvent.To_Agent.System > lTVal) then
641: resultout := wf_engine.eng_completed||':GT';
635: actid, 'TEXT_VALUE');
636: if (LEvent.To_Agent.System is NULL or lTVal is NULL) then
637: resultout := wf_engine.eng_completed||':NULL';
638: elsif (LEvent.To_Agent.System < lTVal) then
639: resultout := wf_engine.eng_completed||':LT';
640: elsif (LEvent.To_Agent.System > lTVal) then
641: resultout := wf_engine.eng_completed||':GT';
642: elsif (LEvent.To_Agent.System = lTVal) then
643: resultout := wf_engine.eng_completed||':EQ';
637: resultout := wf_engine.eng_completed||':NULL';
638: elsif (LEvent.To_Agent.System < lTVal) then
639: resultout := wf_engine.eng_completed||':LT';
640: elsif (LEvent.To_Agent.System > lTVal) then
641: resultout := wf_engine.eng_completed||':GT';
642: elsif (LEvent.To_Agent.System = lTVal) then
643: resultout := wf_engine.eng_completed||':EQ';
644: end if;
645: elsif (lProperty = 'FROM_AGENT') then
639: resultout := wf_engine.eng_completed||':LT';
640: elsif (LEvent.To_Agent.System > lTVal) then
641: resultout := wf_engine.eng_completed||':GT';
642: elsif (LEvent.To_Agent.System = lTVal) then
643: resultout := wf_engine.eng_completed||':EQ';
644: end if;
645: elsif (lProperty = 'FROM_AGENT') then
646: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
647: actid, 'TEXT_VALUE');
642: elsif (LEvent.To_Agent.System = lTVal) then
643: resultout := wf_engine.eng_completed||':EQ';
644: end if;
645: elsif (lProperty = 'FROM_AGENT') then
646: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
647: actid, 'TEXT_VALUE');
648: if (LEvent.From_Agent.Name is NULL
649: or LEvent.From_Agent.System is NULL or lTVal is NULL) then
650: resultout := wf_engine.eng_completed||':NULL';
646: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
647: actid, 'TEXT_VALUE');
648: if (LEvent.From_Agent.Name is NULL
649: or LEvent.From_Agent.System is NULL or lTVal is NULL) then
650: resultout := wf_engine.eng_completed||':NULL';
651: elsif (LEvent.From_Agent.Name||'@'||LEvent.From_Agent.System < lTVal) then
652: resultout := wf_engine.eng_completed||':LT';
653: elsif (LEvent.From_Agent.Name||'@'||LEvent.From_Agent.System > lTVal) then
654: resultout := wf_engine.eng_completed||':GT';
648: if (LEvent.From_Agent.Name is NULL
649: or LEvent.From_Agent.System is NULL or lTVal is NULL) then
650: resultout := wf_engine.eng_completed||':NULL';
651: elsif (LEvent.From_Agent.Name||'@'||LEvent.From_Agent.System < lTVal) then
652: resultout := wf_engine.eng_completed||':LT';
653: elsif (LEvent.From_Agent.Name||'@'||LEvent.From_Agent.System > lTVal) then
654: resultout := wf_engine.eng_completed||':GT';
655: elsif (LEvent.From_Agent.Name||'@'||LEvent.From_Agent.System = lTVal) then
656: resultout := wf_engine.eng_completed||':EQ';
650: resultout := wf_engine.eng_completed||':NULL';
651: elsif (LEvent.From_Agent.Name||'@'||LEvent.From_Agent.System < lTVal) then
652: resultout := wf_engine.eng_completed||':LT';
653: elsif (LEvent.From_Agent.Name||'@'||LEvent.From_Agent.System > lTVal) then
654: resultout := wf_engine.eng_completed||':GT';
655: elsif (LEvent.From_Agent.Name||'@'||LEvent.From_Agent.System = lTVal) then
656: resultout := wf_engine.eng_completed||':EQ';
657: end if;
658: elsif (lProperty = 'TO_AGENT') then
652: resultout := wf_engine.eng_completed||':LT';
653: elsif (LEvent.From_Agent.Name||'@'||LEvent.From_Agent.System > lTVal) then
654: resultout := wf_engine.eng_completed||':GT';
655: elsif (LEvent.From_Agent.Name||'@'||LEvent.From_Agent.System = lTVal) then
656: resultout := wf_engine.eng_completed||':EQ';
657: end if;
658: elsif (lProperty = 'TO_AGENT') then
659: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
660: actid, 'TEXT_VALUE');
655: elsif (LEvent.From_Agent.Name||'@'||LEvent.From_Agent.System = lTVal) then
656: resultout := wf_engine.eng_completed||':EQ';
657: end if;
658: elsif (lProperty = 'TO_AGENT') then
659: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
660: actid, 'TEXT_VALUE');
661: if (LEvent.To_Agent.Name is NULL
662: or LEvent.To_Agent.System is NULL or lTVal is NULL) then
663: resultout := wf_engine.eng_completed||':NULL';
659: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
660: actid, 'TEXT_VALUE');
661: if (LEvent.To_Agent.Name is NULL
662: or LEvent.To_Agent.System is NULL or lTVal is NULL) then
663: resultout := wf_engine.eng_completed||':NULL';
664: elsif (LEvent.To_Agent.Name||'@'||LEvent.To_Agent.System < lTVal) then
665: resultout := wf_engine.eng_completed||':LT';
666: elsif (LEvent.To_Agent.Name||'@'||LEvent.To_Agent.System > lTVal) then
667: resultout := wf_engine.eng_completed||':GT';
661: if (LEvent.To_Agent.Name is NULL
662: or LEvent.To_Agent.System is NULL or lTVal is NULL) then
663: resultout := wf_engine.eng_completed||':NULL';
664: elsif (LEvent.To_Agent.Name||'@'||LEvent.To_Agent.System < lTVal) then
665: resultout := wf_engine.eng_completed||':LT';
666: elsif (LEvent.To_Agent.Name||'@'||LEvent.To_Agent.System > lTVal) then
667: resultout := wf_engine.eng_completed||':GT';
668: elsif (LEvent.To_Agent.Name||'@'||LEvent.To_Agent.System = lTVal) then
669: resultout := wf_engine.eng_completed||':EQ';
663: resultout := wf_engine.eng_completed||':NULL';
664: elsif (LEvent.To_Agent.Name||'@'||LEvent.To_Agent.System < lTVal) then
665: resultout := wf_engine.eng_completed||':LT';
666: elsif (LEvent.To_Agent.Name||'@'||LEvent.To_Agent.System > lTVal) then
667: resultout := wf_engine.eng_completed||':GT';
668: elsif (LEvent.To_Agent.Name||'@'||LEvent.To_Agent.System = lTVal) then
669: resultout := wf_engine.eng_completed||':EQ';
670: end if;
671: elsif (lProperty = 'PARAMETER') then
665: resultout := wf_engine.eng_completed||':LT';
666: elsif (LEvent.To_Agent.Name||'@'||LEvent.To_Agent.System > lTVal) then
667: resultout := wf_engine.eng_completed||':GT';
668: elsif (LEvent.To_Agent.Name||'@'||LEvent.To_Agent.System = lTVal) then
669: resultout := wf_engine.eng_completed||':EQ';
670: end if;
671: elsif (lProperty = 'PARAMETER') then
672: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
673: actid, 'TEXT_VALUE');
668: elsif (LEvent.To_Agent.Name||'@'||LEvent.To_Agent.System = lTVal) then
669: resultout := wf_engine.eng_completed||':EQ';
670: end if;
671: elsif (lProperty = 'PARAMETER') then
672: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
673: actid, 'TEXT_VALUE');
674: lParameter := wf_engine.getActivityAttrText(itemtype => itemtype,
675: itemkey => itemkey,
676: actid => actid,
670: end if;
671: elsif (lProperty = 'PARAMETER') then
672: lTVal := wf_engine.getActivityAttrText(itemtype, itemkey,
673: actid, 'TEXT_VALUE');
674: lParameter := wf_engine.getActivityAttrText(itemtype => itemtype,
675: itemkey => itemkey,
676: actid => actid,
677: aname => 'PARAMETER');
678: if (LEvent.GetValueForParameter(lParameter)) is NULL then
675: itemkey => itemkey,
676: actid => actid,
677: aname => 'PARAMETER');
678: if (LEvent.GetValueForParameter(lParameter)) is NULL then
679: resultout := wf_engine.eng_completed||':NULL';
680: elsif (LEvent.GetValueForParameter(lParameter) < lTVal) then
681: resultout := wf_engine.eng_completed||':LT';
682: elsif (LEvent.GetValueForParameter(lParameter) > lTVal) then
683: resultout := wf_engine.eng_completed||':GT';
677: aname => 'PARAMETER');
678: if (LEvent.GetValueForParameter(lParameter)) is NULL then
679: resultout := wf_engine.eng_completed||':NULL';
680: elsif (LEvent.GetValueForParameter(lParameter) < lTVal) then
681: resultout := wf_engine.eng_completed||':LT';
682: elsif (LEvent.GetValueForParameter(lParameter) > lTVal) then
683: resultout := wf_engine.eng_completed||':GT';
684: elsif (LEvent.GetValueForParameter(lParameter) = lTVal) then
685: resultout := wf_engine.eng_completed||':EQ';
679: resultout := wf_engine.eng_completed||':NULL';
680: elsif (LEvent.GetValueForParameter(lParameter) < lTVal) then
681: resultout := wf_engine.eng_completed||':LT';
682: elsif (LEvent.GetValueForParameter(lParameter) > lTVal) then
683: resultout := wf_engine.eng_completed||':GT';
684: elsif (LEvent.GetValueForParameter(lParameter) = lTVal) then
685: resultout := wf_engine.eng_completed||':EQ';
686: end if;
687: else
681: resultout := wf_engine.eng_completed||':LT';
682: elsif (LEvent.GetValueForParameter(lParameter) > lTVal) then
683: resultout := wf_engine.eng_completed||':GT';
684: elsif (LEvent.GetValueForParameter(lParameter) = lTVal) then
685: resultout := wf_engine.eng_completed||':EQ';
686: end if;
687: else
688: -- Unhandled property. Return NULL
689: resultout := wf_engine.eng_completed||':NULL';
685: resultout := wf_engine.eng_completed||':EQ';
686: end if;
687: else
688: -- Unhandled property. Return NULL
689: resultout := wf_engine.eng_completed||':NULL';
690: end if;
691:
692: exception
693: when others then
741: where WAAV.PROCESS_ACTIVITY_ID = actid
742: and WAAV.NAME = 'EVENT';
743:
744: /* Should be able to use the GetActivityAttrEvent to do this
745: lEvent := wf_engine.getItemAttrEvent(itemtype => itemtype,
746: itemkey => itemkey,
747: name => LAName);
748: */
749:
747: name => LAName);
748: */
749:
750:
751: lEvent := wf_engine.getActivityAttrEvent(itemtype, itemkey,
752: actid, 'EVENT');
753:
754: lProperty := wf_engine.getActivityAttrText(itemtype => itemtype,
755: itemkey => itemkey,
750:
751: lEvent := wf_engine.getActivityAttrEvent(itemtype, itemkey,
752: actid, 'EVENT');
753:
754: lProperty := wf_engine.getActivityAttrText(itemtype => itemtype,
755: itemkey => itemkey,
756: actid => actid,
757: aname => 'PROPERTY');
758: if (lProperty = 'PRIORITY') then
755: itemkey => itemkey,
756: actid => actid,
757: aname => 'PROPERTY');
758: if (lProperty = 'PRIORITY') then
759: lNVal := wf_engine.getActivityAttrNumber(itemtype => itemtype,
760: itemkey => itemkey,
761: actid => actid,
762: aname => 'NUMBER_VALUE');
763: lEvent.setPriority(lNVal);
761: actid => actid,
762: aname => 'NUMBER_VALUE');
763: lEvent.setPriority(lNVal);
764: elsif (lProperty = 'SEND_DATE') then
765: lDVal := wf_engine.getActivityAttrDate(itemtype => itemtype,
766: itemkey => itemkey,
767: actid => actid,
768: aname => 'DATE_VALUE');
769: lEvent.setSendDate(lDVal);
767: actid => actid,
768: aname => 'DATE_VALUE');
769: lEvent.setSendDate(lDVal);
770: elsif (lProperty = 'RECEIVE_DATE') then
771: lDVal := wf_engine.getActivityAttrDate(itemtype => itemtype,
772: itemkey => itemkey,
773: actid => actid,
774: aname => 'DATE_VALUE');
775: lEvent.setReceiveDate(lDVal);
773: actid => actid,
774: aname => 'DATE_VALUE');
775: lEvent.setReceiveDate(lDVal);
776: elsif (lProperty = 'CORRELATION_ID') then
777: lTVal := wf_engine.getActivityAttrText(itemtype => itemtype,
778: itemkey => itemkey,
779: actid => actid,
780: aname => 'TEXT_VALUE');
781: lEvent.setCorrelationID(lTVal);
779: actid => actid,
780: aname => 'TEXT_VALUE');
781: lEvent.setCorrelationID(lTVal);
782: elsif (lProperty = 'EVENT_NAME') then
783: lTVal := wf_engine.getActivityAttrText(itemtype => itemtype,
784: itemkey => itemkey,
785: actid => actid,
786: aname => 'TEXT_VALUE');
787: lEvent.setEventName(lTVal);
785: actid => actid,
786: aname => 'TEXT_VALUE');
787: lEvent.setEventName(lTVal);
788: elsif (lProperty = 'EVENT_KEY') then
789: lTVal := wf_engine.getActivityAttrText(itemtype => itemtype,
790: itemkey => itemkey,
791: actid => actid,
792: aname => 'TEXT_VALUE');
793: lEvent.setEventKey(lTVal);
791: actid => actid,
792: aname => 'TEXT_VALUE');
793: lEvent.setEventKey(lTVal);
794: elsif (lProperty = 'FROM_AGENT_NAME') then
795: lTVal := wf_engine.getActivityAttrText(itemtype => itemtype,
796: itemkey => itemkey,
797: actid => actid,
798: aname => 'TEXT_VALUE');
799: if lEvent.GetFromAgent() is not null then
801: end if;
802: lFromAgent.SetName(lTVal);
803: lEvent.SetFromAgent(lFromAgent);
804: elsif (lProperty = 'FROM_AGENT_SYSTEM') then
805: lTVal := wf_engine.getActivityAttrText(itemtype => itemtype,
806: itemkey => itemkey,
807: actid => actid,
808: aname => 'TEXT_VALUE');
809: if lEvent.GetFromAgent() is not null then
811: end if;
812: lFromAgent.SetSystem(lTVal);
813: lEvent.SetFromAgent(lFromAgent);
814: elsif (lProperty = 'TO_AGENT_NAME') then
815: lTVal := wf_engine.getActivityAttrText(itemtype => itemtype,
816: itemkey => itemkey,
817: actid => actid,
818: aname => 'TEXT_VALUE');
819: if lEvent.GetToAgent() is not null then
821: end if;
822: lToAgent.SetName(lTVal);
823: lEvent.SetToAgent(lToAgent);
824: elsif (lProperty = 'TO_AGENT_SYSTEM') then
825: lTVal := wf_engine.getActivityAttrText(itemtype => itemtype,
826: itemkey => itemkey,
827: actid => actid,
828: aname => 'TEXT_VALUE');
829: if lEvent.GetToAgent() is not null then
831: end if;
832: lToAgent.SetSystem(lTVal);
833: lEvent.SetToAgent(lToAgent);
834: elsif (lProperty = 'FROM_AGENT') then
835: lTVal := wf_engine.getActivityAttrText(itemtype => itemtype,
836: itemkey => itemkey,
837: actid => actid,
838: aname => 'TEXT_VALUE');
839: lAtSign := instr(lTVal, '@');
840: lFromAgent.SetName(substr(lTVal, 1, lAtSign-1));
841: lFromAgent.SetSystem(substr(lTVal, lAtSign+1));
842: lEvent.SetFromAgent(lFromAgent);
843: elsif (lProperty = 'TO_AGENT') then
844: lTVal := wf_engine.getActivityAttrText(itemtype => itemtype,
845: itemkey => itemkey,
846: actid => actid,
847: aname => 'TEXT_VALUE');
848: lAtSign := instr(lTVal, '@');
849: lToAgent.SetName(substr(lTVal, 1, lAtSign-1));
850: lToAgent.SetSystem(substr(lTVal, lAtSign+1));
851: lEvent.SetToAgent(lToAgent);
852: elsif (lProperty = 'PARAMETER') then
853: lTVal := wf_engine.getActivityAttrText(itemtype => itemtype,
854: itemkey => itemkey,
855: actid => actid,
856: aname => 'TEXT_VALUE');
857: lParameter := wf_engine.getActivityAttrText(itemtype => itemtype,
853: lTVal := wf_engine.getActivityAttrText(itemtype => itemtype,
854: itemkey => itemkey,
855: actid => actid,
856: aname => 'TEXT_VALUE');
857: lParameter := wf_engine.getActivityAttrText(itemtype => itemtype,
858: itemkey => itemkey,
859: actid => actid,
860: aname => 'PARAMETER');
861: lEvent.AddParameterToList(lParameter, lTVal);
860: aname => 'PARAMETER');
861: lEvent.AddParameterToList(lParameter, lTVal);
862: end if;
863:
864: wf_engine.setItemAttrEvent(itemtype => itemtype,
865: itemkey => itemkey,
866: name => lAName,
867: event => lEvent);
868: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
864: wf_engine.setItemAttrEvent(itemtype => itemtype,
865: itemkey => itemkey,
866: name => lAName,
867: event => lEvent);
868: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
869: end if; -- RUN
870:
871: exception
872: when others then
911: begin
912: if (funcmode = 'RUN') then
913:
914:
915: lEvent := wf_engine.getActivityAttrEvent(itemtype => itemtype,
916: itemkey => itemkey,
917: actid => actid,
918: name => 'EVENT');
919:
916: itemkey => itemkey,
917: actid => actid,
918: name => 'EVENT');
919:
920: lProperty := wf_engine.getActivityAttrText(itemtype => itemtype,
921: itemkey => itemkey,
922: actid => actid,
923: aname => 'PROPERTY');
924:
922: actid => actid,
923: aname => 'PROPERTY');
924:
925:
926: lAName := wf_engine.getActivityAttrText(itemtype => itemtype,
927: itemkey => itemkey,
928: actid => actid,
929: aname => 'ATTR');
930: if (lProperty = 'PRIORITY') then
927: itemkey => itemkey,
928: actid => actid,
929: aname => 'ATTR');
930: if (lProperty = 'PRIORITY') then
931: wf_engine.SetItemAttrNumber(itemtype => itemtype,
932: itemkey => itemkey,
933: aname => LAName,
934: avalue => lEvent.getPriority());
935: lEvent.setPriority(lNVal);
933: aname => LAName,
934: avalue => lEvent.getPriority());
935: lEvent.setPriority(lNVal);
936: elsif (lProperty = 'SEND_DATE') then
937: wf_engine.SetItemAttrDate(itemtype => itemtype,
938: itemkey => itemkey,
939: aname => LAName,
940: avalue => lEvent.getSendDate());
941: elsif (lProperty = 'RECEIVE_DATE') then
938: itemkey => itemkey,
939: aname => LAName,
940: avalue => lEvent.getSendDate());
941: elsif (lProperty = 'RECEIVE_DATE') then
942: wf_engine.SetItemAttrDate(itemtype => itemtype,
943: itemkey => itemkey,
944: aname => LAName,
945: avalue => lEvent.getReceiveDate());
946: elsif (lProperty = 'CORRELATION_ID') then
943: itemkey => itemkey,
944: aname => LAName,
945: avalue => lEvent.getReceiveDate());
946: elsif (lProperty = 'CORRELATION_ID') then
947: wf_engine.SetItemAttrText(itemtype => itemtype,
948: itemkey => itemkey,
949: aname => LAName,
950: avalue => lEvent.getCorrelationID());
951: elsif (lProperty = 'EVENT_NAME') then
948: itemkey => itemkey,
949: aname => LAName,
950: avalue => lEvent.getCorrelationID());
951: elsif (lProperty = 'EVENT_NAME') then
952: wf_engine.SetItemAttrText(itemtype => itemtype,
953: itemkey => itemkey,
954: aname => LAName,
955: avalue => lEvent.getEventName());
956: elsif (lProperty = 'EVENT_KEY') then
953: itemkey => itemkey,
954: aname => LAName,
955: avalue => lEvent.getEventName());
956: elsif (lProperty = 'EVENT_KEY') then
957: wf_engine.SetItemAttrText(itemtype => itemtype,
958: itemkey => itemkey,
959: aname => LAName,
960: avalue => lEvent.getEventKey());
961: elsif (lProperty = 'FROM_AGENT_NAME') then
958: itemkey => itemkey,
959: aname => LAName,
960: avalue => lEvent.getEventKey());
961: elsif (lProperty = 'FROM_AGENT_NAME') then
962: wf_engine.SetItemAttrText(itemtype => itemtype,
963: itemkey => itemkey,
964: aname => LAName,
965: avalue => lEvent.getFromAgent().getName());
966: elsif (lProperty = 'FROM_AGENT_SYSTEM') then
963: itemkey => itemkey,
964: aname => LAName,
965: avalue => lEvent.getFromAgent().getName());
966: elsif (lProperty = 'FROM_AGENT_SYSTEM') then
967: wf_engine.SetItemAttrText(itemtype => itemtype,
968: itemkey => itemkey,
969: aname => LAName,
970: avalue => lEvent.getFromAgent().getSystem());
971: elsif (lProperty = 'TO_AGENT_NAME') then
968: itemkey => itemkey,
969: aname => LAName,
970: avalue => lEvent.getFromAgent().getSystem());
971: elsif (lProperty = 'TO_AGENT_NAME') then
972: wf_engine.SetItemAttrText(itemtype => itemtype,
973: itemkey => itemkey,
974: aname => LAName,
975: avalue => lEvent.getToAgent().getName());
976: elsif (lProperty = 'TO_AGENT_SYSTEM') then
973: itemkey => itemkey,
974: aname => LAName,
975: avalue => lEvent.getToAgent().getName());
976: elsif (lProperty = 'TO_AGENT_SYSTEM') then
977: wf_engine.SetItemAttrText(itemtype => itemtype,
978: itemkey => itemkey,
979: aname => LAName,
980: avalue => lEvent.getToAgent().getSystem());
981: elsif (lProperty = 'FROM_AGENT') then
978: itemkey => itemkey,
979: aname => LAName,
980: avalue => lEvent.getToAgent().getSystem());
981: elsif (lProperty = 'FROM_AGENT') then
982: wf_engine.SetItemAttrText(itemtype => itemtype,
983: itemkey => itemkey,
984: aname => LAName,
985: avalue =>
986: lEvent.getFromAgent().getName()||
985: avalue =>
986: lEvent.getFromAgent().getName()||
987: '@'||lEvent.getFromAgent().getSystem());
988: elsif (lProperty = 'TO_AGENT') then
989: wf_engine.SetItemAttrText(itemtype => itemtype,
990: itemkey => itemkey,
991: aname => LAName,
992: avalue =>
993: lEvent.getToAgent().getName()||
992: avalue =>
993: lEvent.getToAgent().getName()||
994: '@'||lEvent.getToAgent().getSystem());
995: elsif (lProperty = 'PARAMETER') then
996: lParameter := wf_engine.getActivityAttrText(itemtype => itemtype,
997: itemkey => itemkey,
998: actid => actid,
999: aname => 'PARAMETER');
1000:
997: itemkey => itemkey,
998: actid => actid,
999: aname => 'PARAMETER');
1000:
1001: wf_engine.SetItemAttrText(itemtype => itemtype,
1002: itemkey => itemkey,
1003: aname => LAName,
1004: avalue =>
1005: lEvent.GetValueForParameter(lParameter));
1003: aname => LAName,
1004: avalue =>
1005: lEvent.GetValueForParameter(lParameter));
1006: end if;
1007: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
1008: end if; -- RUN
1009:
1010: exception
1011: when others then
1044:
1045: loop_flag BOOLEAN;
1046: begin
1047: -- Do nothing in cancel or timeout mode
1048: if (funcmode <> wf_engine.eng_run) then
1049: resultout := wf_engine.eng_null;
1050: return;
1051: end if;
1052:
1045: loop_flag BOOLEAN;
1046: begin
1047: -- Do nothing in cancel or timeout mode
1048: if (funcmode <> wf_engine.eng_run) then
1049: resultout := wf_engine.eng_null;
1050: return;
1051: end if;
1052:
1053:
1050: return;
1051: end if;
1052:
1053:
1054: SItemtype := upper(Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'ITEMTYPE'));
1055: Deferit := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'DEFER');
1056:
1057: if SItemtype is null then
1058: wf_core.token('ITEMTYPE','NULL');
1051: end if;
1052:
1053:
1054: SItemtype := upper(Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'ITEMTYPE'));
1055: Deferit := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'DEFER');
1056:
1057: if SItemtype is null then
1058: wf_core.token('ITEMTYPE','NULL');
1059: wf_core.raise('WFSQL_ARGS');
1064: -- First -> result_code will be null (really null).
1065: -- Second -> result_code will be '#NULL' (set that way by execution 1).
1066: Wf_Item_Activity_Status.Result(itemtype, itemkey, actid, status, result);
1067:
1068: if (result = wf_engine.eng_null) then
1069: -- Second execution.
1070: -- Defer must have been picked up by the background engine,
1071: -- so return complete result.
1072: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
1068: if (result = wf_engine.eng_null) then
1069: -- Second execution.
1070: -- Defer must have been picked up by the background engine,
1071: -- so return complete result.
1072: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
1073: else
1074: -- Return deferred result
1075: resultout := wf_engine.eng_deferred;
1076: return;
1071: -- so return complete result.
1072: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
1073: else
1074: -- Return deferred result
1075: resultout := wf_engine.eng_deferred;
1076: return;
1077: end if;
1078: end if;
1079:
1077: end if;
1078: end if;
1079:
1080: -- if we have got this far, go ahead and launch the process.
1081: SItemkey := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'ITEMKEY');
1082: SProcess := upper(Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'PROCESS_NAME'));
1083: SUserkey := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'USER_KEY');
1084: SOwner := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'OWNER');
1085: if sItemkey is not null then
1078: end if;
1079:
1080: -- if we have got this far, go ahead and launch the process.
1081: SItemkey := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'ITEMKEY');
1082: SProcess := upper(Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'PROCESS_NAME'));
1083: SUserkey := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'USER_KEY');
1084: SOwner := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'OWNER');
1085: if sItemkey is not null then
1086: wf_engine.LaunchProcess(SItemtype, SItemkey, SProcess, SUserkey, SOwner);
1079:
1080: -- if we have got this far, go ahead and launch the process.
1081: SItemkey := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'ITEMKEY');
1082: SProcess := upper(Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'PROCESS_NAME'));
1083: SUserkey := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'USER_KEY');
1084: SOwner := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'OWNER');
1085: if sItemkey is not null then
1086: wf_engine.LaunchProcess(SItemtype, SItemkey, SProcess, SUserkey, SOwner);
1087:
1080: -- if we have got this far, go ahead and launch the process.
1081: SItemkey := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'ITEMKEY');
1082: SProcess := upper(Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'PROCESS_NAME'));
1083: SUserkey := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'USER_KEY');
1084: SOwner := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'OWNER');
1085: if sItemkey is not null then
1086: wf_engine.LaunchProcess(SItemtype, SItemkey, SProcess, SUserkey, SOwner);
1087:
1088: else
1082: SProcess := upper(Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'PROCESS_NAME'));
1083: SUserkey := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'USER_KEY');
1084: SOwner := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'OWNER');
1085: if sItemkey is not null then
1086: wf_engine.LaunchProcess(SItemtype, SItemkey, SProcess, SUserkey, SOwner);
1087:
1088: else
1089: begin
1090: launch_count := wf_engine.GetItemAttrNumber(
1086: wf_engine.LaunchProcess(SItemtype, SItemkey, SProcess, SUserkey, SOwner);
1087:
1088: else
1089: begin
1090: launch_count := wf_engine.GetItemAttrNumber(
1091: itemtype, itemkey, 'LAUNCH_COUNT');
1092: exception
1093: when others then
1094: --
1094: --
1095: -- If item attribute does not exist then create it;
1096: --
1097: if ( wf_core.error_name = 'WFENG_ITEM_ATTR' ) then
1098: wf_engine.AddItemAttr(itemtype,itemkey, 'LAUNCH_COUNT');
1099: launch_count := 0;
1100: else
1101: raise;
1102: end if;
1107: begin
1108: launch_count:=launch_count+1;
1109: -- imtetype:itemkey is unique so the new itemkey should be unique
1110: sItemkey := itemtype||':'||itemkey||'-'||to_char(launch_count);
1111: wf_engine.LaunchProcess(SItemtype, SItemkey, SProcess,
1112: SUserkey, SOwner);
1113: loop_flag:=FALSE;
1114: exception
1115: when others then
1121: end if;
1122: end;
1123: end loop;
1124:
1125: wf_engine.SetItemAttrNumber(
1126: itemtype, itemkey, 'LAUNCH_COUNT',launch_count);
1127:
1128: end if;
1129:
1127:
1128: end if;
1129:
1130:
1131: resultout := wf_engine.eng_completed;
1132:
1133: exception
1134: when others then
1135: Wf_Core.Context('Wf_Standard', 'LaunchProcess', itemtype,
1165:
1166: begin
1167:
1168: -- Do nothing in cancel or timeout mode
1169: if (funcmode <> wf_engine.eng_run) then
1170: resultout := wf_engine.eng_null;
1171: return;
1172: end if;
1173:
1166: begin
1167:
1168: -- Do nothing in cancel or timeout mode
1169: if (funcmode <> wf_engine.eng_run) then
1170: resultout := wf_engine.eng_null;
1171: return;
1172: end if;
1173:
1174: if (itemkey = wf_engine.eng_synch) then
1170: resultout := wf_engine.eng_null;
1171: return;
1172: end if;
1173:
1174: if (itemkey = wf_engine.eng_synch) then
1175: Wf_Core.Token('OPERATION', 'Wf_Standard.ForkItem');
1176: Wf_Core.Raise('WFENG_SYNCH_DISABLED');
1177: end if;
1178:
1177: end if;
1178:
1179:
1180:
1181: SItemkey := upper(Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'NEW_ITEMKEY'));
1182: SameVersionFlag := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'SAME_VERSION');
1183:
1184: if SItemkey is null
1185: or SameVersionFlag is null then
1178:
1179:
1180:
1181: SItemkey := upper(Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'NEW_ITEMKEY'));
1182: SameVersionFlag := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'SAME_VERSION');
1183:
1184: if SItemkey is null
1185: or SameVersionFlag is null then
1186: wf_core.token('ITEMKEY',Sitemkey);
1194: sameversion := FALSE;
1195: end if;
1196:
1197: -- go ahead and create the new process.
1198: wf_engine.CreateForkProcess(Itemtype, Itemkey, SItemkey, SameVersion);
1199:
1200: -- start the new process
1201: wf_engine.StartForkProcess(Itemtype, SItemkey);
1202:
1197: -- go ahead and create the new process.
1198: wf_engine.CreateForkProcess(Itemtype, Itemkey, SItemkey, SameVersion);
1199:
1200: -- start the new process
1201: wf_engine.StartForkProcess(Itemtype, SItemkey);
1202:
1203: resultout := wf_engine.eng_completed;
1204:
1205: exception
1199:
1200: -- start the new process
1201: wf_engine.StartForkProcess(Itemtype, SItemkey);
1202:
1203: resultout := wf_engine.eng_completed;
1204:
1205: exception
1206: when others then
1207: Wf_Core.Context('Wf_Standard', 'ForkItem', itemtype,
1219: funcmode in varchar2,
1220: resultout in out nocopy varchar2)
1221: is
1222: begin
1223: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
1224: exception
1225: when others then
1226: Wf_Core.Context('Wf_Standard', 'Noop', itemtype,
1227: itemkey, to_char(actid), funcmode);
1248: avalue varchar2(240);
1249:
1250: begin
1251: -- Do nothing in cancel or timeout mode
1252: if (funcmode <> wf_engine.eng_run) then
1253: resultout := wf_engine.eng_null;
1254: return;
1255: end if;
1256:
1249:
1250: begin
1251: -- Do nothing in cancel or timeout mode
1252: if (funcmode <> wf_engine.eng_run) then
1253: resultout := wf_engine.eng_null;
1254: return;
1255: end if;
1256:
1257:
1263: prole := Wf_Activity.Perform_Role(itemtype, itemkey, actid);
1264:
1265: -- if it isnt then use the value from activity attribute
1266: if prole is null then
1267: prole := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'PERFORMER');
1268: end if;
1269:
1270: if prole is null then
1271: Wf_Core.Token('TYPE', itemtype);
1273: Wf_Core.Raise('WFENG_NOTIFICATION_PERFORMER');
1274: end if;
1275:
1276: -- message name and expand roles will be null. Get these from attributes
1277: avalue := upper(Wf_Engine.GetActivityAttrText(itemtype, itemkey,
1278: actid, 'MESSAGE'));
1279:
1280: -- let notification_send catch a missing message name.
1281: expand_role := nvl(Wf_Engine.GetActivityAttrText(itemtype, itemkey,
1277: avalue := upper(Wf_Engine.GetActivityAttrText(itemtype, itemkey,
1278: actid, 'MESSAGE'));
1279:
1280: -- let notification_send catch a missing message name.
1281: expand_role := nvl(Wf_Engine.GetActivityAttrText(itemtype, itemkey,
1282: actid, 'EXPANDROLES'),'N');
1283:
1284: -- parse out the message type if given
1285: colon := instr(avalue, ':');
1292: end if;
1293:
1294:
1295: -- Actually send the notification
1296: Wf_Engine_Util.Notification_Send(itemtype, itemkey, actid,
1297: msg, msgtype, prole, expand_role,
1298: resultout);
1299:
1300:
1322: resultout in out nocopy varchar2)
1323: is
1324: begin
1325: -- Do nothing in cancel or timeout mode
1326: if (funcmode <> wf_engine.eng_run) then
1327: resultout := wf_engine.eng_null;
1328: return;
1329: end if;
1330:
1323: is
1324: begin
1325: -- Do nothing in cancel or timeout mode
1326: if (funcmode <> wf_engine.eng_run) then
1327: resultout := wf_engine.eng_null;
1328: return;
1329: end if;
1330:
1331: resultout := wf_engine.eng_notified||':'||wf_engine.eng_null||
1327: resultout := wf_engine.eng_null;
1328: return;
1329: end if;
1330:
1331: resultout := wf_engine.eng_notified||':'||wf_engine.eng_null||
1332: ':'||wf_engine.eng_null;
1333: exception
1334: when others then
1335: Wf_Core.Context('Wf_Standard', 'Block', itemtype,
1328: return;
1329: end if;
1330:
1331: resultout := wf_engine.eng_notified||':'||wf_engine.eng_null||
1332: ':'||wf_engine.eng_null;
1333: exception
1334: when others then
1335: Wf_Core.Context('Wf_Standard', 'Block', itemtype,
1336: itemkey, to_char(actid), funcmode);
1352: status varchar2(8);
1353: result varchar2(30);
1354: begin
1355: -- Do nothing in cancel or timeout mode
1356: if (funcmode <> wf_engine.eng_run) then
1357: resultout := wf_engine.eng_null;
1358: return;
1359: end if;
1360:
1353: result varchar2(30);
1354: begin
1355: -- Do nothing in cancel or timeout mode
1356: if (funcmode <> wf_engine.eng_run) then
1357: resultout := wf_engine.eng_null;
1358: return;
1359: end if;
1360:
1361: -- Check if this is the first or second execution of this activity.
1362: -- First -> result_code will be null (really null).
1363: -- Second -> result_code will be '#NULL' (set that way by execution 1).
1364: Wf_Item_Activity_Status.Result(itemtype, itemkey, actid, status, result);
1365:
1366: if (result = wf_engine.eng_null) then
1367: -- Second execution.
1368: -- Defer must have been picked up by the background engine,
1369: -- so return complete result.
1370: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
1366: if (result = wf_engine.eng_null) then
1367: -- Second execution.
1368: -- Defer must have been picked up by the background engine,
1369: -- so return complete result.
1370: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
1371: else
1372: -- Return deferred result
1373: resultout := wf_engine.eng_deferred;
1374: end if;
1369: -- so return complete result.
1370: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
1371: else
1372: -- Return deferred result
1373: resultout := wf_engine.eng_deferred;
1374: end if;
1375:
1376: exception
1377: when others then
1435: time date;
1436: wf_invalid_mode exception;
1437: begin
1438: -- Do nothing in cancel or timeout mode
1439: if (funcmode <> wf_engine.eng_run) then
1440: resultout := wf_engine.eng_null;
1441: return;
1442: end if;
1443:
1436: wf_invalid_mode exception;
1437: begin
1438: -- Do nothing in cancel or timeout mode
1439: if (funcmode <> wf_engine.eng_run) then
1440: resultout := wf_engine.eng_null;
1441: return;
1442: end if;
1443:
1444: -- SYNCHMODE: Not allowed
1441: return;
1442: end if;
1443:
1444: -- SYNCHMODE: Not allowed
1445: if (itemkey = wf_engine.eng_synch) then
1446: Wf_Core.Token('OPERATION', 'Wf_Standard.Wait');
1447: Wf_Core.Raise('WFENG_SYNCH_DISABLED');
1448: end if;
1449:
1451: -- First -> result_code will be null (really null).
1452: -- Second -> result_code will be '#NULL' (set that way by execution 1).
1453: Wf_Item_Activity_Status.Result(itemtype, itemkey, actid, status, result);
1454:
1455: if (result = wf_engine.eng_null) then
1456: -- Second execution.
1457: -- Wait is completed, return complete result.
1458: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
1459: else
1454:
1455: if (result = wf_engine.eng_null) then
1456: -- Second execution.
1457: -- Wait is completed, return complete result.
1458: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
1459: else
1460: -- First execution.
1461: wait_mode := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid,
1462: 'WAIT_MODE');
1457: -- Wait is completed, return complete result.
1458: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
1459: else
1460: -- First execution.
1461: wait_mode := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid,
1462: 'WAIT_MODE');
1463:
1464: if (wait_mode = 'ABSOLUTE') then
1465: -- Absolute date
1462: 'WAIT_MODE');
1463:
1464: if (wait_mode = 'ABSOLUTE') then
1465: -- Absolute date
1466: wakeup := Wf_Engine.GetActivityAttrDate(itemtype, itemkey, actid,
1467: 'WAIT_ABSOLUTE_DATE');
1468:
1469: elsif (wait_mode = 'RELATIVE') then
1470: -- Relative date. Figure offset from sysdate.
1467: 'WAIT_ABSOLUTE_DATE');
1468:
1469: elsif (wait_mode = 'RELATIVE') then
1470: -- Relative date. Figure offset from sysdate.
1471: wakeup := Wf_Engine.GetActivityAttrNumber(itemtype, itemkey, actid,
1472: 'WAIT_RELATIVE_TIME') + sysdate;
1473:
1474: elsif (wait_mode = 'DAY_OF_WEEK') then
1475: -- Day of week.
1472: 'WAIT_RELATIVE_TIME') + sysdate;
1473:
1474: elsif (wait_mode = 'DAY_OF_WEEK') then
1475: -- Day of week.
1476: daybuf := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid,
1477: 'WAIT_DAY_OF_WEEK');
1478: wakeup := next_day(trunc(sysdate), daybuf);
1479:
1480: elsif (wait_mode = 'DAY_OF_MONTH') then
1477: 'WAIT_DAY_OF_WEEK');
1478: wakeup := next_day(trunc(sysdate), daybuf);
1479:
1480: elsif (wait_mode = 'DAY_OF_MONTH') then
1481: daybuf := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid,
1482: 'WAIT_DAY_OF_MONTH');
1483:
1484: -- Figure wakeup time as offset from beginning of current month
1485: if (daybuf = 'LAST') then
1511: raise wf_invalid_mode;
1512: end if;
1513:
1514: -- Add the WAIT_TIME to the wakeup if specified
1515: time := Wf_Engine.GetActivityAttrDate(itemtype, itemkey, actid,
1516: 'WAIT_TIME');
1517: if (time is not null) then
1518: wakeup := to_date(to_char(wakeup, 'DD/MM/YYYY')||
1519: to_char(time, ' HH24:MI'), 'DD/MM/YYYY HH24:MI');
1519: to_char(time, ' HH24:MI'), 'DD/MM/YYYY HH24:MI');
1520: end if;
1521:
1522: -- Return deferred result with wakeup time appended
1523: resultout := wf_engine.eng_deferred||':'||
1524: to_char(wakeup, wf_engine.date_format);
1525: end if;
1526:
1527: exception
1520: end if;
1521:
1522: -- Return deferred result with wakeup time appended
1523: resultout := wf_engine.eng_deferred||':'||
1524: to_char(wakeup, wf_engine.date_format);
1525: end if;
1526:
1527: exception
1528: when wf_invalid_mode then
1559: err_actlabel varchar2(62);
1560: wf_invalid_command exception;
1561: begin
1562: -- Do nothing in cancel or timeout mode
1563: if (funcmode <> wf_engine.eng_run) then
1564: resultout := wf_engine.eng_null;
1565: return;
1566: end if;
1567:
1560: wf_invalid_command exception;
1561: begin
1562: -- Do nothing in cancel or timeout mode
1563: if (funcmode <> wf_engine.eng_run) then
1564: resultout := wf_engine.eng_null;
1565: return;
1566: end if;
1567:
1568: -- SYNCHMODE: Not allowed
1565: return;
1566: end if;
1567:
1568: -- SYNCHMODE: Not allowed
1569: if (itemkey = wf_engine.eng_synch) then
1570: Wf_Core.Token('OPERATION', 'Wf_Standard.ResetError');
1571: Wf_Core.Raise('WFENG_SYNCH_DISABLED');
1572: end if;
1573:
1571: Wf_Core.Raise('WFENG_SYNCH_DISABLED');
1572: end if;
1573:
1574: -- Get RETRY or SKIP command
1575: cmd := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'COMMAND');
1576:
1577: -- Get original errored activity info
1578: err_itemtype := Wf_Engine.GetItemAttrText(itemtype, itemkey,
1579: 'ERROR_ITEM_TYPE');
1574: -- Get RETRY or SKIP command
1575: cmd := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'COMMAND');
1576:
1577: -- Get original errored activity info
1578: err_itemtype := Wf_Engine.GetItemAttrText(itemtype, itemkey,
1579: 'ERROR_ITEM_TYPE');
1580: err_itemkey := Wf_Engine.GetItemAttrText(itemtype, itemkey,
1581: 'ERROR_ITEM_KEY');
1582: err_actlabel := Wf_Engine.GetItemAttrText(itemtype, itemkey,
1576:
1577: -- Get original errored activity info
1578: err_itemtype := Wf_Engine.GetItemAttrText(itemtype, itemkey,
1579: 'ERROR_ITEM_TYPE');
1580: err_itemkey := Wf_Engine.GetItemAttrText(itemtype, itemkey,
1581: 'ERROR_ITEM_KEY');
1582: err_actlabel := Wf_Engine.GetItemAttrText(itemtype, itemkey,
1583: 'ERROR_ACTIVITY_LABEL');
1584:
1578: err_itemtype := Wf_Engine.GetItemAttrText(itemtype, itemkey,
1579: 'ERROR_ITEM_TYPE');
1580: err_itemkey := Wf_Engine.GetItemAttrText(itemtype, itemkey,
1581: 'ERROR_ITEM_KEY');
1582: err_actlabel := Wf_Engine.GetItemAttrText(itemtype, itemkey,
1583: 'ERROR_ACTIVITY_LABEL');
1584:
1585: if (cmd = wf_engine.eng_retry) then
1586: -- Rerun activity
1581: 'ERROR_ITEM_KEY');
1582: err_actlabel := Wf_Engine.GetItemAttrText(itemtype, itemkey,
1583: 'ERROR_ACTIVITY_LABEL');
1584:
1585: if (cmd = wf_engine.eng_retry) then
1586: -- Rerun activity
1587: Wf_Engine.HandleError(err_itemtype, err_itemkey, err_actlabel,
1588: cmd, '');
1589:
1583: 'ERROR_ACTIVITY_LABEL');
1584:
1585: if (cmd = wf_engine.eng_retry) then
1586: -- Rerun activity
1587: Wf_Engine.HandleError(err_itemtype, err_itemkey, err_actlabel,
1588: cmd, '');
1589:
1590: /* Disallow skip mode because it is too difficult to
1591: assign and validate the RESULT value
1588: cmd, '');
1589:
1590: /* Disallow skip mode because it is too difficult to
1591: assign and validate the RESULT value
1592: elsif (cmd = wf_engine.eng_skip) then
1593: -- Get result code
1594: result := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid,
1595: 'RESULT');
1596: -- Mark activity complete and continue processing
1590: /* Disallow skip mode because it is too difficult to
1591: assign and validate the RESULT value
1592: elsif (cmd = wf_engine.eng_skip) then
1593: -- Get result code
1594: result := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid,
1595: 'RESULT');
1596: -- Mark activity complete and continue processing
1597: Wf_Engine.HandleError(err_itemtype, err_itemkey, err_actlabel,
1598: cmd, result);
1593: -- Get result code
1594: result := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid,
1595: 'RESULT');
1596: -- Mark activity complete and continue processing
1597: Wf_Engine.HandleError(err_itemtype, err_itemkey, err_actlabel,
1598: cmd, result);
1599: */
1600: else
1601: raise wf_invalid_command;
1600: else
1601: raise wf_invalid_command;
1602: end if;
1603:
1604: resultout := wf_engine.eng_null;
1605: exception
1606: when wf_invalid_command then
1607: Wf_Core.Context('Wf_Standard', 'ResetError', itemtype,
1608: itemkey, to_char(actid), funcmode);
1643: wpa.perform_role_type
1644: FROM wf_activity_transitions wat,
1645: wf_process_activities wpa
1646: WHERE wat.from_process_activity = actid
1647: AND wat.result_code = wf_engine.eng_trans_default
1648: AND wat.to_process_activity = wpa.instance_id;
1649: --
1650: -- select number of activities the user currently has in worklist
1651: --
1673: begin
1674: --
1675: -- Do nothing in cancel mode
1676: --
1677: if (funcmode <> wf_engine.eng_run ) then
1678: resultout := wf_engine.eng_null;
1679: return;
1680: end if;
1681:
1674: --
1675: -- Do nothing in cancel mode
1676: --
1677: if (funcmode <> wf_engine.eng_run ) then
1678: resultout := wf_engine.eng_null;
1679: return;
1680: end if;
1681:
1682: -- SYNCHMODE: Not allowed
1679: return;
1680: end if;
1681:
1682: -- SYNCHMODE: Not allowed
1683: if (itemkey = wf_engine.eng_synch) then
1684: Wf_Core.Token('OPERATION', 'Wf_Standard.AndJoin');
1685: Wf_Core.Raise('WFENG_SYNCH_DISABLED');
1686: end if;
1687:
1685: Wf_Core.Raise('WFENG_SYNCH_DISABLED');
1686: end if;
1687:
1688: actdate := wf_item.active_date(itemtype, itemkey);
1689: cmd := Wf_Engine.GetActivityAttrText(itemtype,itemkey,actid,'METHOD');
1690:
1691: -- loop thru all out-transiations of role resolution activity
1692: for trans_rec in out_transitions loop
1693: declare
1697: assigned_performer varchar2(320);
1698: begin
1699: --
1700: if (Wf_Activity.Type(itemtype, trans_rec.activity_name, actdate) =
1701: wf_engine.eng_notification) then
1702: -- Get perform_role from constant or itemattr value
1703: if (trans_rec.perform_role_type = 'CONSTANT') then
1704: prole := trans_rec.perform_role;
1705: else
1702: -- Get perform_role from constant or itemattr value
1703: if (trans_rec.perform_role_type = 'CONSTANT') then
1704: prole := trans_rec.perform_role;
1705: else
1706: prole := Wf_Engine.GetItemAttrText(itemtype, itemkey,
1707: trans_rec.perform_role);
1708: end if;
1709: wf_directory.GetRoleUsers(prole,usertab);
1710: if ( cmd = 'LOAD_BALANCE' ) then
1771: into label
1772: from wf_process_activities wpa
1773: where wpa.instance_id = trans_rec.to_process_activity;
1774:
1775: wf_engine.AssignActivity(itemtype,itemkey,label,
1776: assigned_performer);
1777:
1778: end if;
1779:
1776: assigned_performer);
1777:
1778: end if;
1779:
1780: resultout := wf_engine.eng_null;
1781: end if;
1782: end;
1783: end loop;
1784: exception
1809: l_waiting_activity varchar2(30);
1810: l_waiting_flow varchar2(30);
1811: wf_invalid_command exception;
1812: begin
1813: if (funcmode <> wf_engine.eng_run) then
1814: resultout := wf_engine.eng_null;
1815: return;
1816: end if;
1817:
1810: l_waiting_flow varchar2(30);
1811: wf_invalid_command exception;
1812: begin
1813: if (funcmode <> wf_engine.eng_run) then
1814: resultout := wf_engine.eng_null;
1815: return;
1816: end if;
1817:
1818: -- SYNCHMODE: Not allowed
1815: return;
1816: end if;
1817:
1818: -- SYNCHMODE: Not allowed
1819: if (itemkey = wf_engine.eng_synch) then
1820: Wf_Core.Token('OPERATION', 'Wf_Standard.AndJoin');
1821: Wf_Core.Raise('WFENG_SYNCH_DISABLED');
1822: end if;
1823:
1820: Wf_Core.Token('OPERATION', 'Wf_Standard.AndJoin');
1821: Wf_Core.Raise('WFENG_SYNCH_DISABLED');
1822: end if;
1823:
1824: l_waiting_activity := upper(Wf_Engine.GetActivityAttrText(
1825: itemtype, itemkey, actid,'WAITING_ACTIVITY'));
1826: l_waiting_flow := Wf_Engine.GetActivityAttrText(
1827: itemtype, itemkey, actid,'WAITING_FLOW');
1828:
1822: end if;
1823:
1824: l_waiting_activity := upper(Wf_Engine.GetActivityAttrText(
1825: itemtype, itemkey, actid,'WAITING_ACTIVITY'));
1826: l_waiting_flow := Wf_Engine.GetActivityAttrText(
1827: itemtype, itemkey, actid,'WAITING_FLOW');
1828:
1829: if ( l_waiting_flow = 'MASTER' ) then
1830: ContinueMasterFlow(itemtype,itemkey,actid,l_waiting_activity,resultout);
1862: l_continuation_activity varchar2(30);
1863: l_continuation_flow varchar2(30);
1864: wf_invalid_command exception;
1865: begin
1866: if (funcmode <> wf_engine.eng_run) then
1867: resultout := wf_engine.eng_null;
1868: return;
1869: end if;
1870:
1863: l_continuation_flow varchar2(30);
1864: wf_invalid_command exception;
1865: begin
1866: if (funcmode <> wf_engine.eng_run) then
1867: resultout := wf_engine.eng_null;
1868: return;
1869: end if;
1870:
1871: -- SYNCHMODE: Not allowed
1868: return;
1869: end if;
1870:
1871: -- SYNCHMODE: Not allowed
1872: if (itemkey = wf_engine.eng_synch) then
1873: Wf_Core.Token('OPERATION', 'Wf_Standard.WaitForFlow');
1874: Wf_Core.Raise('WFENG_SYNCH_DISABLED');
1875: end if;
1876:
1873: Wf_Core.Token('OPERATION', 'Wf_Standard.WaitForFlow');
1874: Wf_Core.Raise('WFENG_SYNCH_DISABLED');
1875: end if;
1876:
1877: l_continuation_activity := upper(Wf_Engine.GetActivityAttrText(
1878: itemtype, itemkey, actid,
1879: 'CONTINUATION_ACTIVITY'));
1880: l_continuation_flow := Wf_Engine.GetActivityAttrText(
1881: itemtype,itemkey,actid,'CONTINUATION_FLOW');
1876:
1877: l_continuation_activity := upper(Wf_Engine.GetActivityAttrText(
1878: itemtype, itemkey, actid,
1879: 'CONTINUATION_ACTIVITY'));
1880: l_continuation_flow := Wf_Engine.GetActivityAttrText(
1881: itemtype,itemkey,actid,'CONTINUATION_FLOW');
1882:
1883: if ( l_continuation_flow = 'MASTER' ) then
1884: WaitForMasterFlow(itemtype,itemkey,actid,
1919: begin
1920: --
1921: -- Do nothing in cancel mode
1922: --
1923: if (funcmode <> wf_engine.eng_run) then
1924: resultout := wf_engine.eng_null;
1925: return;
1926: end if;
1927:
1920: --
1921: -- Do nothing in cancel mode
1922: --
1923: if (funcmode <> wf_engine.eng_run) then
1924: resultout := wf_engine.eng_null;
1925: return;
1926: end if;
1927:
1928: -- Get maximum times activity can be executed.
1925: return;
1926: end if;
1927:
1928: -- Get maximum times activity can be executed.
1929: max_times := wf_engine.GetActivityAttrNumber(
1930: itemtype, itemkey, actid, 'MAX_TIMES');
1931: if ( max_times is null ) then
1932: wf_core.token('MAX_TIMES',max_times);
1933: wf_core.raise('WFSQL_ARGS');
1933: wf_core.raise('WFSQL_ARGS');
1934: end if;
1935:
1936: begin
1937: loop_count := wf_engine.GetItemAttrNumber(
1938: itemtype, itemkey, 'LOOP_COUNT'||':'||actid);
1939: exception
1940: when others then
1941: --
1941: --
1942: -- If item attribute does not exist then create it;
1943: --
1944: if ( wf_core.error_name = 'WFENG_ITEM_ATTR' ) then
1945: wf_engine.AddItemAttr(
1946: itemtype,itemkey, 'LOOP_COUNT'||':'||actid);
1947: loop_count := 0;
1948: else
1949: raise;
1957: loop_count := loop_count +1;
1958: resultout := 'LOOP';
1959: end if;
1960:
1961: wf_engine.SetItemAttrNumber(
1962: itemtype, itemkey, 'LOOP_COUNT'||':'||actid,loop_count);
1963: exception
1964: when others then
1965: wf_core.context('Wf_Standard','LoopCount',
2048: result varchar2(30) := '';
2049: wf_invalid_command exception;
2050: begin
2051: -- Do nothing unless in RUN or TIMEOUT modes
2052: if (funcmode <> wf_engine.eng_run)
2053: and (funcmode <> wf_engine.eng_timeout) then
2054: resultout := wf_engine.eng_null;
2055: return;
2056: end if;
2049: wf_invalid_command exception;
2050: begin
2051: -- Do nothing unless in RUN or TIMEOUT modes
2052: if (funcmode <> wf_engine.eng_run)
2053: and (funcmode <> wf_engine.eng_timeout) then
2054: resultout := wf_engine.eng_null;
2055: return;
2056: end if;
2057:
2050: begin
2051: -- Do nothing unless in RUN or TIMEOUT modes
2052: if (funcmode <> wf_engine.eng_run)
2053: and (funcmode <> wf_engine.eng_timeout) then
2054: resultout := wf_engine.eng_null;
2055: return;
2056: end if;
2057:
2058: -- SYNCHMODE: Not allowed
2055: return;
2056: end if;
2057:
2058: -- SYNCHMODE: Not allowed
2059: if (itemkey = wf_engine.eng_synch) then
2060: Wf_Core.Token('OPERATION', 'Wf_Standard.VotForResultType');
2061: Wf_Core.Raise('WFENG_SYNCH_DISABLED');
2062: end if;
2063:
2063:
2064: -- Get Notifications group_id for activity
2065: Wf_Item_Activity_Status.Notification_Status(itemtype,itemkey,actid,
2066: l_group_id,l_user);
2067: l_voting_option := Wf_Engine.GetActivityAttrText(itemtype,itemkey,
2068: actid,'VOTING_OPTION');
2069: if (l_voting_option not in ('REQUIRE_ALL_VOTES', 'WAIT_FOR_ALL_VOTES',
2070: 'TALLY_ON_EVERY_VOTE')) then
2071: raise wf_invalid_command;
2077: -- and there are still open notifications, then return WAITING to
2078: -- either continue voting (in run mode) or trigger timeout processing
2079: -- (in timeout mode).
2080: if ((l_voting_option = 'REQUIRE_ALL_VOTES') or
2081: ((funcmode = wf_engine.eng_run) and
2082: (l_voting_option = 'WAIT_FOR_ALL_VOTES'))) then
2083: if (wf_notification.OpenNotificationsExist(l_group_id)) then
2084: resultout := wf_engine.eng_waiting;
2085: return;
2080: if ((l_voting_option = 'REQUIRE_ALL_VOTES') or
2081: ((funcmode = wf_engine.eng_run) and
2082: (l_voting_option = 'WAIT_FOR_ALL_VOTES'))) then
2083: if (wf_notification.OpenNotificationsExist(l_group_id)) then
2084: resultout := wf_engine.eng_waiting;
2085: return;
2086: end if;
2087: end if;
2088:
2098: l_code_count,l_per_of_total,l_per_of_vote);
2099:
2100: -- If this is timeout mode, then use the percent of votes cast so far.
2101: -- If this is run mode, then use the percent of total votes possible.
2102: if (funcmode = wf_engine.eng_timeout) then
2103: l_per_code := l_per_of_vote;
2104: else
2105: l_per_code := l_per_of_total;
2106: end if;
2105: l_per_code := l_per_of_total;
2106: end if;
2107:
2108: -- Get percent vote needed for this result to succeed
2109: per_success := Wf_Engine.GetActivityAttrNumber(itemtype,itemkey,
2110: actid,result_rec.result_code);
2111:
2112: if (per_success is null) then
2113: -- Null value means this is a default result.
2116: max_default := l_code_count;
2117: default_result := result_rec.result_code;
2118: elsif (l_code_count = max_default) then
2119: -- Tie for default result.
2120: default_result := wf_engine.eng_tie;
2121: end if;
2122: else
2123: -- If:
2124: -- a. % vote for this result > % needed for success OR
2132: -- Save satisfied result.
2133: result := result_rec.result_code;
2134: else
2135: -- This is the second result to be satisfied. Return a tie.
2136: resultout := wf_engine.eng_completed||':'||wf_engine.eng_tie;
2137: return;
2138: end if;
2139: end if;
2140: end if;
2141: end loop;
2142:
2143: if (result is not null) then
2144: -- Return the satisfied result code.
2145: resultout := wf_engine.eng_completed||':'||result;
2146: else
2147: -- If we get here no non-default results were satisfied.
2148: if (funcmode = wf_engine.eng_run and
2149: wf_notification.OpenNotificationsExist(l_group_id)) then
2144: -- Return the satisfied result code.
2145: resultout := wf_engine.eng_completed||':'||result;
2146: else
2147: -- If we get here no non-default results were satisfied.
2148: if (funcmode = wf_engine.eng_run and
2149: wf_notification.OpenNotificationsExist(l_group_id)) then
2150: -- Not timed out and still open notifications.
2151: -- Return waiting to continue voting.
2152: resultout := wf_engine.eng_waiting;
2148: if (funcmode = wf_engine.eng_run and
2149: wf_notification.OpenNotificationsExist(l_group_id)) then
2150: -- Not timed out and still open notifications.
2151: -- Return waiting to continue voting.
2152: resultout := wf_engine.eng_waiting;
2153: elsif (default_result is not null) then
2154: -- Either timeout or all notifications closed
2155: -- Return default result if one found.
2156: resultout := wf_engine.eng_completed||':'||default_result;
2152: resultout := wf_engine.eng_waiting;
2153: elsif (default_result is not null) then
2154: -- Either timeout or all notifications closed
2155: -- Return default result if one found.
2156: resultout := wf_engine.eng_completed||':'||default_result;
2157: elsif (funcmode = wf_engine.eng_timeout) then
2158: -- If Timeout has occured then return result Timeout so the Timeout
2159: -- transition will occur - BUG2885157
2160: resultout := wf_engine.eng_completed||':'||wf_engine.eng_timedout;
2153: elsif (default_result is not null) then
2154: -- Either timeout or all notifications closed
2155: -- Return default result if one found.
2156: resultout := wf_engine.eng_completed||':'||default_result;
2157: elsif (funcmode = wf_engine.eng_timeout) then
2158: -- If Timeout has occured then return result Timeout so the Timeout
2159: -- transition will occur - BUG2885157
2160: resultout := wf_engine.eng_completed||':'||wf_engine.eng_timedout;
2161: else
2156: resultout := wf_engine.eng_completed||':'||default_result;
2157: elsif (funcmode = wf_engine.eng_timeout) then
2158: -- If Timeout has occured then return result Timeout so the Timeout
2159: -- transition will occur - BUG2885157
2160: resultout := wf_engine.eng_completed||':'||wf_engine.eng_timedout;
2161: else
2162: -- All notifications closed, and no default.
2163: -- Return nomatch
2164: resultout := wf_engine.eng_completed||':'||wf_engine.eng_nomatch;
2160: resultout := wf_engine.eng_completed||':'||wf_engine.eng_timedout;
2161: else
2162: -- All notifications closed, and no default.
2163: -- Return nomatch
2164: resultout := wf_engine.eng_completed||':'||wf_engine.eng_nomatch;
2165: end if;
2166: end if;
2167: return;
2168: exception
2231: and WIAS.ITEM_KEY = l_parent_itemkey
2232: and WIAS.PROCESS_ACTIVITY = WPA.INSTANCE_ID
2233: and WPA.INSTANCE_LABEL = label
2234: and WPA.PROCESS_NAME = nvl(process, WPA.PROCESS_NAME)
2235: and wias.activity_status in (wf_engine.eng_completed, wf_engine.eng_active);
2236: exception
2237: -- When not complete return NOTIFIED to cause engine to stall
2238: when NO_DATA_FOUND then
2239: resultout := wf_engine.eng_notified||':'||wf_engine.eng_null|| ':'||wf_engine.eng_null;
2235: and wias.activity_status in (wf_engine.eng_completed, wf_engine.eng_active);
2236: exception
2237: -- When not complete return NOTIFIED to cause engine to stall
2238: when NO_DATA_FOUND then
2239: resultout := wf_engine.eng_notified||':'||wf_engine.eng_null|| ':'||wf_engine.eng_null;
2240: return;
2241: end;
2242: resultout := wf_engine.eng_null;
2243: exception
2238: when NO_DATA_FOUND then
2239: resultout := wf_engine.eng_notified||':'||wf_engine.eng_null|| ':'||wf_engine.eng_null;
2240: return;
2241: end;
2242: resultout := wf_engine.eng_null;
2243: exception
2244: when others then
2245: wf_core.context('Wf_Standard', 'WaitForMasterFlow',
2246: itemtype,itemkey,to_char(actid),continuation_activity);
2276: and end_date is null)
2277: and WIAS.PROCESS_ACTIVITY = WPA.INSTANCE_ID
2278: and WPA.INSTANCE_LABEL = plabel
2279: and WPA.PROCESS_NAME = nvl(pname, WPA.PROCESS_NAME)
2280: and wias.activity_status in (wf_engine.eng_completed, wf_engine.eng_active);
2281:
2282: cursor current_process (p_actid number) is
2283: select instance_label
2284: from wf_process_activities
2311: open current_process(actid);
2312: fetch current_process into l_waitLabel;
2313: close current_process;
2314:
2315: l_labelCount := WF_ENGINE.GetItemAttrNumber(itemType, itemKey,
2316: '#CNT_'||l_waitLabel, TRUE);
2317: if (l_labelCount is NULL) then
2318: l_childCount := WF_ENGINE.GetItemAttrNumber(itemType, itemKey,
2319: '#WAITFORDETAIL', TRUE);
2314:
2315: l_labelCount := WF_ENGINE.GetItemAttrNumber(itemType, itemKey,
2316: '#CNT_'||l_waitLabel, TRUE);
2317: if (l_labelCount is NULL) then
2318: l_childCount := WF_ENGINE.GetItemAttrNumber(itemType, itemKey,
2319: '#WAITFORDETAIL', TRUE);
2320: if (l_childCount is NULL) then --Fall back to the old path.
2321: open child_flows;
2322: fetch child_flows into number_active;
2322: fetch child_flows into number_active;
2323: close child_flows;
2324:
2325: if (number_active < 1) then
2326: resultout := wf_engine.eng_null;
2327: else
2328: open child_activities(itemtype, itemkey, process, label);
2329: fetch child_activities into number_complete;
2330: close child_activities;
2329: fetch child_activities into number_complete;
2330: close child_activities;
2331:
2332: if number_active > number_complete then
2333: resultout := wf_engine.eng_notified||':'||
2334: wf_engine.eng_null||':'||wf_engine.eng_null;
2335: else
2336: resultout := wf_engine.eng_null;
2337: end if;
2330: close child_activities;
2331:
2332: if number_active > number_complete then
2333: resultout := wf_engine.eng_notified||':'||
2334: wf_engine.eng_null||':'||wf_engine.eng_null;
2335: else
2336: resultout := wf_engine.eng_null;
2337: end if;
2338:
2332: if number_active > number_complete then
2333: resultout := wf_engine.eng_notified||':'||
2334: wf_engine.eng_null||':'||wf_engine.eng_null;
2335: else
2336: resultout := wf_engine.eng_null;
2337: end if;
2338:
2339: end if; --There are no children
2340: else --#WAITFORDETAIL exists
2337: end if;
2338:
2339: end if; --There are no children
2340: else --#WAITFORDETAIL exists
2341: WF_ENGINE.AddItemAttr(itemtype=>WaitForDetailFlow.itemtype,
2342: itemkey=>WaitForDetailFlow.itemkey,
2343: aname=>'#CNT_'||l_waitLabel,
2344: number_value=>l_childCount);
2345: if (l_childCount > 0) then
2342: itemkey=>WaitForDetailFlow.itemkey,
2343: aname=>'#CNT_'||l_waitLabel,
2344: number_value=>l_childCount);
2345: if (l_childCount > 0) then
2346: resultout := wf_engine.eng_notified||':'||
2347: wf_engine.eng_null||':'||wf_engine.eng_null;
2348: else
2349: resultout := wf_engine.eng_null;
2350: end if; --l_childCount > 0
2343: aname=>'#CNT_'||l_waitLabel,
2344: number_value=>l_childCount);
2345: if (l_childCount > 0) then
2346: resultout := wf_engine.eng_notified||':'||
2347: wf_engine.eng_null||':'||wf_engine.eng_null;
2348: else
2349: resultout := wf_engine.eng_null;
2350: end if; --l_childCount > 0
2351: end if; -- #WAITFORDETAIL
2345: if (l_childCount > 0) then
2346: resultout := wf_engine.eng_notified||':'||
2347: wf_engine.eng_null||':'||wf_engine.eng_null;
2348: else
2349: resultout := wf_engine.eng_null;
2350: end if; --l_childCount > 0
2351: end if; -- #WAITFORDETAIL
2352: elsif (l_labelCount > 0) then
2353: --The #CNT_ attribute exists and is 1 or greater so this will remain
2351: end if; -- #WAITFORDETAIL
2352: elsif (l_labelCount > 0) then
2353: --The #CNT_ attribute exists and is 1 or greater so this will remain
2354: --notified.
2355: resultout := wf_engine.eng_notified||':'||wf_engine.eng_null||
2356: ':'||wf_engine.eng_null;
2357:
2358: else --The labelcount exists and is < 1 so we can continue.
2359: resultout := wf_engine.eng_null;
2352: elsif (l_labelCount > 0) then
2353: --The #CNT_ attribute exists and is 1 or greater so this will remain
2354: --notified.
2355: resultout := wf_engine.eng_notified||':'||wf_engine.eng_null||
2356: ':'||wf_engine.eng_null;
2357:
2358: else --The labelcount exists and is < 1 so we can continue.
2359: resultout := wf_engine.eng_null;
2360: end if;
2355: resultout := wf_engine.eng_notified||':'||wf_engine.eng_null||
2356: ':'||wf_engine.eng_null;
2357:
2358: else --The labelcount exists and is < 1 so we can continue.
2359: resultout := wf_engine.eng_null;
2360: end if;
2361:
2362:
2363: exception
2399: --
2400: -- Complete Waiting Activity in All Detail Flows
2401: --
2402: begin
2403: wf_engine.CompleteActivity(child_flows_rec.item_type,
2404: child_flows_rec.item_key, waiting_activity,wf_engine.eng_null);
2405: exception
2406: when others then
2407: -- If call to CompleteActivity cannot find activity, return null
2400: -- Complete Waiting Activity in All Detail Flows
2401: --
2402: begin
2403: wf_engine.CompleteActivity(child_flows_rec.item_type,
2404: child_flows_rec.item_key, waiting_activity,wf_engine.eng_null);
2405: exception
2406: when others then
2407: -- If call to CompleteActivity cannot find activity, return null
2408: -- As either the detail flows does not have a waiting activity OR
2414: end if;
2415: end;
2416: end loop;
2417:
2418: ContinueDetailFlow.resultout := wf_engine.eng_null;
2419:
2420: exception
2421: when others then
2422: wf_core.context('Wf_Standard','ContinueDetailFlow',
2481: and (WI.item_type <> itemtype OR WI.item_key <> itemkey )
2482: and WI.end_date is null
2483: and WIAS.PROCESS_ACTIVITY = WPA.INSTANCE_ID
2484: and WPA.INSTANCE_LABEL = label
2485: and wias.activity_status in (wf_engine.eng_completed,
2486: wf_engine.eng_active);
2487:
2488: dummy varchar2(240);
2489: status varchar2(8);
2482: and WI.end_date is null
2483: and WIAS.PROCESS_ACTIVITY = WPA.INSTANCE_ID
2484: and WPA.INSTANCE_LABEL = label
2485: and wias.activity_status in (wf_engine.eng_completed,
2486: wf_engine.eng_active);
2487:
2488: dummy varchar2(240);
2489: status varchar2(8);
2490: result varchar2(30);
2510: -- First -> result_code will be null (really null).
2511: -- Second -> result_code will be '#NULL' (set that way by execution 1).
2512: Wf_Item_Activity_Status.Result(itemtype, itemkey, actid, status, result);
2513:
2514: if (result = wf_engine.eng_null) then
2515: -- Second execution.
2516: -- ContinueFlow() completed and was deferred.
2517: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
2518: return;
2513:
2514: if (result = wf_engine.eng_null) then
2515: -- Second execution.
2516: -- ContinueFlow() completed and was deferred.
2517: resultout := wf_engine.eng_completed||':'||wf_engine.eng_null;
2518: return;
2519: else
2520: --First execution.
2521:
2529:
2530: --Nulling out the #LBL_ attribute, if it does not exist, we will check the
2531: --parent flow for #WAITFORDETAIL to see if we can create the #LBL_
2532: --attribute.
2533: if NOT (WF_ENGINE.SetItemAttrText2(ContinueMasterFlow.itemtype,
2534: ContinueMasterFlow.itemkey,
2535: '#LBL_'||waiting_activity,
2536: NULL)) then
2537: l_childwaiting := WF_ENGINE.GetItemAttrNumber(
2533: if NOT (WF_ENGINE.SetItemAttrText2(ContinueMasterFlow.itemtype,
2534: ContinueMasterFlow.itemkey,
2535: '#LBL_'||waiting_activity,
2536: NULL)) then
2537: l_childwaiting := WF_ENGINE.GetItemAttrNumber(
2538: l_parent_itemtype, l_parent_itemkey,
2539: '#WAITFORDETAIL', TRUE);
2540: if (l_childwaiting is NOT NULL) then
2541: --The parent has #WAITFORDETAIL, so we can create the #LBL_ attribute
2538: l_parent_itemtype, l_parent_itemkey,
2539: '#WAITFORDETAIL', TRUE);
2540: if (l_childwaiting is NOT NULL) then
2541: --The parent has #WAITFORDETAIL, so we can create the #LBL_ attribute
2542: WF_ENGINE.AddItemAttr(ContinueMasterFlow.itemtype,
2543: ContinueMasterFlow.itemkey,
2544: '#LBL_'||waiting_activity, NULL);
2545:
2546: else --#WAITFORDETAIL does not exist in the parent, so we will fall back
2559: end if;
2560:
2561: if (number_active < 1) then
2562: begin
2563: wf_engine.CompleteActivity(l_parent_itemtype,l_parent_itemkey,
2564: waiting_activity,wf_engine.eng_null);
2565: resultout := wf_engine.eng_null;
2566: exception
2567: when OTHERS then
2560:
2561: if (number_active < 1) then
2562: begin
2563: wf_engine.CompleteActivity(l_parent_itemtype,l_parent_itemkey,
2564: waiting_activity,wf_engine.eng_null);
2565: resultout := wf_engine.eng_null;
2566: exception
2567: when OTHERS then
2568: if ( wf_core.error_name = 'WFENG_NOT_NOTIFIED' ) then
2561: if (number_active < 1) then
2562: begin
2563: wf_engine.CompleteActivity(l_parent_itemtype,l_parent_itemkey,
2564: waiting_activity,wf_engine.eng_null);
2565: resultout := wf_engine.eng_null;
2566: exception
2567: when OTHERS then
2568: if ( wf_core.error_name = 'WFENG_NOT_NOTIFIED' ) then
2569: wf_core.clear;
2566: exception
2567: when OTHERS then
2568: if ( wf_core.error_name = 'WFENG_NOT_NOTIFIED' ) then
2569: wf_core.clear;
2570: ContinueMasterFlow.resultout := wf_engine.eng_null;
2571: else
2572: raise;
2573: end if;
2574: end;
2578: close child_activities2;
2579:
2580: begin
2581: if number_active = number_complete then
2582: wf_engine.CompleteActivity(l_parent_itemtype,l_parent_itemkey,
2583: waiting_activity,wf_engine.eng_null);
2584: end if;
2585: resultout := wf_engine.eng_null;
2586:
2579:
2580: begin
2581: if number_active = number_complete then
2582: wf_engine.CompleteActivity(l_parent_itemtype,l_parent_itemkey,
2583: waiting_activity,wf_engine.eng_null);
2584: end if;
2585: resultout := wf_engine.eng_null;
2586:
2587: exception
2581: if number_active = number_complete then
2582: wf_engine.CompleteActivity(l_parent_itemtype,l_parent_itemkey,
2583: waiting_activity,wf_engine.eng_null);
2584: end if;
2585: resultout := wf_engine.eng_null;
2586:
2587: exception
2588: when others then
2589: --
2591: -- null and wait for master flow
2592: --
2593: if ( wf_core.error_name = 'WFENG_NOT_NOTIFIED' ) then
2594: wf_core.clear;
2595: ContinueMasterFlow.resultout := wf_engine.eng_null;
2596: else
2597: raise;
2598: end if;
2599: end;
2605:
2606: -- If we come to here, we must be progressing in the new code path.
2607: --Now we will try to decrement the corresponding #CNT_ attribute if it
2608: --exists, and will create it with a value of 0 if it does not yet exist.
2609: l_count := WF_ENGINE.AddToItemAttrNumber(l_parent_itemtype,
2610: l_parent_itemkey,
2611: '#CNT_'||waiting_activity, -1);
2612:
2613: if (l_count is NULL) then
2610: l_parent_itemkey,
2611: '#CNT_'||waiting_activity, -1);
2612:
2613: if (l_count is NULL) then
2614: WF_ENGINE.AddItemAttr(itemtype=>l_parent_itemtype,
2615: itemkey=>l_parent_itemkey,
2616: aname=>'#CNT_'||waiting_activity,
2617: number_value=>l_childwaiting - 1);
2618: elsif (l_count < 1) then
2616: aname=>'#CNT_'||waiting_activity,
2617: number_value=>l_childwaiting - 1);
2618: elsif (l_count < 1) then
2619: begin
2620: wf_engine.CompleteActivity(l_parent_itemtype,l_parent_itemkey,
2621: waiting_activity,wf_engine.eng_null);
2622: exception
2623: when OTHERS then
2624: if ( wf_core.error_name = 'WFENG_NOT_NOTIFIED' ) then
2617: number_value=>l_childwaiting - 1);
2618: elsif (l_count < 1) then
2619: begin
2620: wf_engine.CompleteActivity(l_parent_itemtype,l_parent_itemkey,
2621: waiting_activity,wf_engine.eng_null);
2622: exception
2623: when OTHERS then
2624: if ( wf_core.error_name = 'WFENG_NOT_NOTIFIED' ) then
2625: wf_core.clear;
2622: exception
2623: when OTHERS then
2624: if ( wf_core.error_name = 'WFENG_NOT_NOTIFIED' ) then
2625: wf_core.clear;
2626: ContinueMasterFlow.resultout := wf_engine.eng_null;
2627: else
2628: raise;
2629: end if;
2630: end;
2629: end if;
2630: end;
2631: end if;
2632:
2633: l_defer := WF_ENGINE.GetActivityAttrText(itemtype, itemkey, actid,
2634: '#HINT', TRUE);
2635:
2636: --If #HINT is not set to 'NO_DEFER', or is null we will set the
2637: --threshold to cause the next activity to defer.
2635:
2636: --If #HINT is not set to 'NO_DEFER', or is null we will set the
2637: --threshold to cause the next activity to defer.
2638: if ((l_defer is null) or (l_defer <> 'NO_DEFER')) then
2639: resultout := wf_engine.eng_deferred;
2640: else
2641: resultout := wf_engine.eng_null;
2642: end if;
2643:
2637: --threshold to cause the next activity to defer.
2638: if ((l_defer is null) or (l_defer <> 'NO_DEFER')) then
2639: resultout := wf_engine.eng_deferred;
2640: else
2641: resultout := wf_engine.eng_null;
2642: end if;
2643:
2644: end if; --First execution
2645:
2684: --
2685: -- Get the type and the key of the process that errored out
2686: -- these were set in the erroring out process by Execute_Error_Process
2687: --
2688: l_error_itemkey := WF_ENGINE.GetItemAttrText(
2689: itemtype => itemtype,
2690: itemkey => itemkey,
2691: aname => 'ERROR_ITEM_KEY' );
2692: l_error_itemtype := WF_ENGINE.GetItemAttrText(
2688: l_error_itemkey := WF_ENGINE.GetItemAttrText(
2689: itemtype => itemtype,
2690: itemkey => itemkey,
2691: aname => 'ERROR_ITEM_KEY' );
2692: l_error_itemtype := WF_ENGINE.GetItemAttrText(
2693: itemtype => itemtype,
2694: itemkey => itemkey,
2695: aname => 'ERROR_ITEM_TYPE' );
2696:
2700: --
2701:
2702: begin
2703: --if this item type doesnt exist an exception is raised.
2704: l_administrator := WF_ENGINE.GetItemAttrText(
2705: itemtype => l_error_itemtype,
2706: itemkey => l_error_itemkey,
2707: aname => 'WF_ADMINISTRATOR' );
2708:
2708:
2709: --
2710: --in case DEFAULT_RESET_ERROR_NTF does not exist.
2711: begin
2712: wf_engine.AssignActivity(itemtype,itemkey,
2713: 'DEFAULT_RESET_ERROR_NTF',
2714: l_administrator);
2715: exception
2716: when OTHERS then
2717: null; --We only null this exception because the parent
2718: --block nulls the expeption.
2719: end;
2720:
2721: wf_engine.AssignActivity(itemtype,itemkey,'RETRY_ONLY_NTF',
2722: l_administrator);
2723:
2724: exception
2725: when others then null;
2731: --
2732:
2733: begin
2734: --if this item type doesnt exist an exception is raised.
2735: l_timeout := WF_ENGINE.GetItemAttrNumber(
2736: itemtype => l_error_itemtype,
2737: itemkey => l_error_itemkey,
2738: aname => 'ERROR_TIMEOUT' );
2739: wf_engine.SetItemAttrNumber(itemtype,itemkey,'TIMEOUT_VALUE',l_timeout);
2735: l_timeout := WF_ENGINE.GetItemAttrNumber(
2736: itemtype => l_error_itemtype,
2737: itemkey => l_error_itemkey,
2738: aname => 'ERROR_TIMEOUT' );
2739: wf_engine.SetItemAttrNumber(itemtype,itemkey,'TIMEOUT_VALUE',l_timeout);
2740: exception
2741: when others then null;
2742: end;
2743:
2740: exception
2741: when others then null;
2742: end;
2743:
2744: result := wf_engine.eng_completed;
2745: ELSIF (funcmode = 'CANCEL') THEN
2746: result := wf_engine.eng_completed;
2747: END IF;
2748: EXCEPTION
2742: end;
2743:
2744: result := wf_engine.eng_completed;
2745: ELSIF (funcmode = 'CANCEL') THEN
2746: result := wf_engine.eng_completed;
2747: END IF;
2748: EXCEPTION
2749: WHEN OTHERS THEN
2750: WF_CORE.Context('WF_STANDARD', 'InitializeErrors',
2784: --
2785: -- Get the type and the key of the process that errored out
2786: -- these were set in the erroring out process by Execute_Error_Process
2787: --
2788: l_error_itemkey := WF_ENGINE.GetItemAttrText(
2789: itemtype => itemtype,
2790: itemkey => itemkey,
2791: aname => 'ERROR_ITEM_KEY' );
2792: l_error_itemtype := WF_ENGINE.GetItemAttrText(
2788: l_error_itemkey := WF_ENGINE.GetItemAttrText(
2789: itemtype => itemtype,
2790: itemkey => itemkey,
2791: aname => 'ERROR_ITEM_KEY' );
2792: l_error_itemtype := WF_ENGINE.GetItemAttrText(
2793: itemtype => itemtype,
2794: itemkey => itemkey,
2795: aname => 'ERROR_ITEM_TYPE' );
2796:
2793: itemtype => itemtype,
2794: itemkey => itemkey,
2795: aname => 'ERROR_ITEM_TYPE' );
2796:
2797: l_error_actid := WF_ENGINE.GetItemAttrText(
2798: itemtype => itemtype,
2799: itemkey => itemkey,
2800: aname => 'ERROR_ACTIVITY_ID' );
2801:
2844: --
2845: -- Get the Event Item Attribute
2846: --
2847:
2848: l_event_t := WF_ENGINE.GetItemAttrEvent(
2849: itemtype => itemtype,
2850: itemkey => itemkey,
2851: name => 'EVENT_MESSAGE' );
2852: --
2856:
2857: --
2858: -- Get the Error Type from the Item Attribute - set by Engine
2859: --
2860: l_error_type := WF_ENGINE.GetItemAttrText(
2861: itemtype => itemtype,
2862: itemkey => itemkey,
2863: aname => 'ERROR_TYPE');
2864: --
2865: -- If the error type is null, this must be an UNEXPECTED event
2866: --
2867: IF l_error_type IS NULL THEN
2868: l_error_type := 'UNEXPECTED';
2869: wf_engine.SetItemAttrText(itemtype => itemtype,
2870: itemkey => itemkey,
2871: aname => 'ERROR_TYPE',
2872: avalue => l_error_type);
2873: END IF;
2918: p_itemkey => itemkey);
2919:
2920: -- Set the Item Attributes
2921:
2922: wf_engine.SetItemAttrText(itemtype => itemtype,
2923: itemkey => itemkey,
2924: aname => 'ERROR_MESSAGE',
2925: avalue => l_error_message);
2926:
2923: itemkey => itemkey,
2924: aname => 'ERROR_MESSAGE',
2925: avalue => l_error_message);
2926:
2927: wf_engine.SetItemAttrText(itemtype => itemtype,
2928: itemkey => itemkey,
2929: aname => 'ERROR_STACK',
2930: avalue => l_error_stack);
2931:
2929: aname => 'ERROR_STACK',
2930: avalue => l_error_stack);
2931:
2932: -- Set the PL/SQL Document for the Event Details
2933: wf_engine.SetItemAttrText(itemtype => itemtype,
2934: itemkey => itemkey,
2935: aname => 'EVENT_DETAILS',
2936: avalue => 'PLSQL:WF_STANDARD.EVENTDETAILS/'||ItemType||':'||ItemKey);
2937:
2934: itemkey => itemkey,
2935: aname => 'EVENT_DETAILS',
2936: avalue => 'PLSQL:WF_STANDARD.EVENTDETAILS/'||ItemType||':'||ItemKey);
2937:
2938: wf_engine.SetItemAttrText(itemtype => itemtype,
2939: itemkey => itemkey,
2940: aname => 'ERROR_DETAILS',
2941: avalue => 'PLSQL:WF_STANDARD.ErrorDetails/'||ItemType||':'||ItemKey);
2942:
2939: itemkey => itemkey,
2940: aname => 'ERROR_DETAILS',
2941: avalue => 'PLSQL:WF_STANDARD.ErrorDetails/'||ItemType||':'||ItemKey);
2942:
2943: wf_engine.SetItemAttrText(itemtype => itemtype,
2944: itemkey => itemkey,
2945: aname => 'SUBSCRIPTION_DETAILS',
2946: avalue => 'PLSQL:WF_STANDARD.SubscriptionDetails/'||ItemType||':'||ItemKey);
2947:
2945: aname => 'SUBSCRIPTION_DETAILS',
2946: avalue => 'PLSQL:WF_STANDARD.SubscriptionDetails/'||ItemType||':'||ItemKey);
2947:
2948: -- Set the Value for the Error Subscription URL
2949: wf_engine.SetItemAttrText(itemtype => itemtype,
2950: itemkey => itemkey,
2951: aname => 'EVENT_SUBSCRIPTION',
2952: avalue => l_url);
2953: -- Set the Value for the Event Data URL
2950: itemkey => itemkey,
2951: aname => 'EVENT_SUBSCRIPTION',
2952: avalue => l_url);
2953: -- Set the Value for the Event Data URL
2954: wf_engine.SetItemAttrText(itemtype => itemtype,
2955: itemkey => itemkey,
2956: aname => 'EVENT_DATA_URL',
2957: avalue => l_eventdataurl);
2958:
2966: resultout := 'EVENT_WARNING';
2967: END IF;
2968:
2969: ELSIF (funcmode = 'CANCEL') THEN
2970: resultout := wf_engine.eng_completed;
2971: END IF;
2972: EXCEPTION
2973: WHEN OTHERS THEN
2974: WF_CORE.Context('WF_STANDARD', 'InitializeEventError',
3015: , instr(document_id,':')+1);
3016:
3017:
3018:
3019: l_event_t := wf_engine.GetItemAttrEvent(
3020: itemtype => itemtype,
3021: itemkey => itemkey,
3022: name => 'EVENT_MESSAGE' );
3023:
3207: begin
3208:
3209: IF (funcmode = 'RUN') THEN
3210:
3211: l_event_t := wf_engine.GetItemAttrEvent(
3212: itemtype => itemtype,
3213: itemkey => itemkey,
3214: name => 'EVENT_MESSAGE' );
3215:
3212: itemtype => itemtype,
3213: itemkey => itemkey,
3214: name => 'EVENT_MESSAGE' );
3215:
3216: aname := wf_engine.GetActivityAttrText(itemtype,
3217: itemkey,
3218: actid,
3219: 'COMMAND');
3220:
3251: wf_core.raise('WFSQL_ARGS');
3252:
3253: END IF;
3254:
3255: resultout := wf_engine.eng_completed;
3256:
3257: ELSIF (funcmode = 'CANCEL') THEN
3258: resultout := wf_engine.eng_completed;
3259: END IF;
3254:
3255: resultout := wf_engine.eng_completed;
3256:
3257: ELSIF (funcmode = 'CANCEL') THEN
3258: resultout := wf_engine.eng_completed;
3259: END IF;
3260:
3261: EXCEPTION
3262: WHEN OTHERS THEN
3292: begin
3293:
3294: IF (funcmode = 'RUN') THEN
3295:
3296: l_subguid := wf_engine.GetActivityAttrText(itemtype,
3297: itemkey,
3298: actid,
3299: 'SUB_GUID');
3300:
3297: itemkey,
3298: actid,
3299: 'SUB_GUID');
3300:
3301: l_outagentattr := wf_engine.GetActivityAttrText(itemtype,
3302: itemkey,
3303: actid,
3304: 'FROMAGENT');
3305:
3302: itemkey,
3303: actid,
3304: 'FROMAGENT');
3305:
3306: l_toagentattr := wf_engine.GetActivityAttrText(itemtype,
3307: itemkey,
3308: actid,
3309: 'TOAGENT');
3310:
3330: where wfa.guid = l_toagentguid
3331: and wfa.system_guid = wfs.guid;
3332:
3333: -- Update the agent item attributes
3334: wf_engine.SetItemAttrText(itemtype => itemtype,
3335: itemkey => itemkey,
3336: aname => l_outagentattr,
3337: avalue => l_outagent);
3338:
3335: itemkey => itemkey,
3336: aname => l_outagentattr,
3337: avalue => l_outagent);
3338:
3339: wf_engine.SetItemAttrText(itemtype => itemtype,
3340: itemkey => itemkey,
3341: aname => l_toagentattr,
3342: avalue => l_toagent);
3343: resultout := 'T';
3344: else
3345: resultout := 'F';
3346: end if;
3347: ELSIF (funcmode = 'CANCEL') THEN
3348: resultout := wf_engine.eng_completed;
3349: END IF;
3350:
3351: EXCEPTION
3352: WHEN OTHERS THEN
3382: begin
3383:
3384: IF (funcmode = 'RUN') THEN
3385:
3386: l_event_t := wf_engine.GetActivityAttrEvent(
3387: itemtype => itemtype,
3388: itemkey => itemkey,
3389: actid => actid,
3390: name => 'EVENTMESSAGE');
3388: itemkey => itemkey,
3389: actid => actid,
3390: name => 'EVENTMESSAGE');
3391:
3392: l_toagentattr := wf_engine.GetActivityAttrText(itemtype,
3393: itemkey,
3394: actid,
3395: 'ACKTOAGENT');
3396:
3400: fetch c_return_agent into l_agent;
3401: close c_return_agent;
3402:
3403: if l_agent is not null then
3404: wf_engine.SetItemAttrText(itemtype => itemtype,
3405: itemkey => itemkey,
3406: aname => l_toagentattr,
3407: avalue => l_agent||'@'||l_system);
3408: end if;
3406: aname => l_toagentattr,
3407: avalue => l_agent||'@'||l_system);
3408: end if;
3409:
3410: resultout := wf_engine.eng_completed;
3411:
3412: ELSIF (funcmode = 'CANCEL') THEN
3413: resultout := wf_engine.eng_completed;
3414: END IF;
3409:
3410: resultout := wf_engine.eng_completed;
3411:
3412: ELSIF (funcmode = 'CANCEL') THEN
3413: resultout := wf_engine.eng_completed;
3414: END IF;
3415:
3416: EXCEPTION
3417: WHEN OTHERS THEN
3453: l_item_type := nvl(substr(document_id, 1,
3454: instr(document_id,':')-1),'WFERROR');
3455: l_item_key := substr(document_id, instr(document_id,':')+1);
3456:
3457: l_event_t := wf_engine.GetItemAttrEvent(itemtype => l_item_type,
3458: itemkey => l_item_key,
3459: name => 'EVENT_MESSAGE');
3460: l_subscription := l_event_t.GetErrorSubscription();
3461:
3499: end if;
3500:
3501: -- Show Invoker Rule Function since it may be a Custom one extended from
3502: -- seeded. Also the Event Payload is WS input message
3503: l_evt_url := wf_engine.GetItemAttrText(itemtype => l_item_type,
3504: itemkey => l_item_key,
3505: aname => 'EVENT_DATA_URL');
3506: l_sub_url := wf_engine.GetItemAttrText(itemtype => l_item_type,
3507: itemkey => l_item_key,
3502: -- seeded. Also the Event Payload is WS input message
3503: l_evt_url := wf_engine.GetItemAttrText(itemtype => l_item_type,
3504: itemkey => l_item_key,
3505: aname => 'EVENT_DATA_URL');
3506: l_sub_url := wf_engine.GetItemAttrText(itemtype => l_item_type,
3507: itemkey => l_item_key,
3508: aname => 'EVENT_SUBSCRIPTION');
3509:
3510: if (display_type = wf_notification.doc_html) then
3573:
3574: l_item_type := nvl(substr(document_id, 1, instr(document_id,':')-1),'WFERROR');
3575: l_item_key := substr(document_id, instr(document_id,':')+1);
3576:
3577: l_error_name := wf_engine.GetItemAttrText(itemtype => l_item_type,
3578: itemkey => l_item_key,
3579: aname => 'ERROR_NAME');
3580: l_error_message := wf_engine.GetItemAttrText(itemtype => l_item_type,
3581: itemkey => l_item_key,
3576:
3577: l_error_name := wf_engine.GetItemAttrText(itemtype => l_item_type,
3578: itemkey => l_item_key,
3579: aname => 'ERROR_NAME');
3580: l_error_message := wf_engine.GetItemAttrText(itemtype => l_item_type,
3581: itemkey => l_item_key,
3582: aname => 'ERROR_MESSAGE');
3583: l_error_stack := wf_engine.GetItemAttrText(itemtype => l_item_type,
3584: itemkey => l_item_key,
3579: aname => 'ERROR_NAME');
3580: l_error_message := wf_engine.GetItemAttrText(itemtype => l_item_type,
3581: itemkey => l_item_key,
3582: aname => 'ERROR_MESSAGE');
3583: l_error_stack := wf_engine.GetItemAttrText(itemtype => l_item_type,
3584: itemkey => l_item_key,
3585: aname => 'ERROR_STACK');
3586:
3587: if (display_type = wf_notification.doc_html) then
3640: l_action_code varchar2(30);
3641: begin
3642:
3643: if (funcmode = 'RUN') then
3644: l_event_t := wf_engine.GetItemAttrEvent(itemtype => itemtype,
3645: itemkey => itemkey,
3646: name => 'EVENT_MESSAGE');
3647: l_subscription := l_event_t.GetErrorSubscription();
3648:
3651: FROM wf_event_subscriptions
3652: WHERE guid = l_subscription;
3653:
3654: if (l_action_code is not null) then
3655: resultout := wf_engine.eng_completed||':'||l_action_code;
3656: else
3657: resultout := wf_engine.eng_completed||':CUSTOM_RG';
3658: end if;
3659: elsif (funcmode = 'CANCEL') then
3653:
3654: if (l_action_code is not null) then
3655: resultout := wf_engine.eng_completed||':'||l_action_code;
3656: else
3657: resultout := wf_engine.eng_completed||':CUSTOM_RG';
3658: end if;
3659: elsif (funcmode = 'CANCEL') then
3660: resultout := wf_engine.eng_completed;
3661: end if;
3656: else
3657: resultout := wf_engine.eng_completed||':CUSTOM_RG';
3658: end if;
3659: elsif (funcmode = 'CANCEL') then
3660: resultout := wf_engine.eng_completed;
3661: end if;
3662:
3663: end SubscriptionAction;
3664: