98: resultout := wf_engine.eng_null;
99:
100: exception
101: when others then
102: Wf_Core.Context('Wf_Standard', 'AbortProcess', itemtype,
103: itemkey, to_char(actid), funcmode);
104: raise;
105: end AbortProcess;
106:
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);
125: raise;
126: end OrJoin;
127:
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:
156: -- The And fails if there is at least one in-transition which is either
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:
156: -- The And fails if there is at least one in-transition which is either
157: -- incomplete or complete with the wrong result.
192: end if;
193: return;
194: exception
195: when others then
196: Wf_Core.Context('Wf_Standard', 'AndJoin', itemtype,
197: itemkey, to_char(actid), funcmode);
198: raise;
199: end AndJoin;
200:
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);
253: raise;
254: end Assign;
255:
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:
285: -- Get item attribute name
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:
285: -- Get item attribute name
286: aname := wf_engine.GetActivityAttrText(itemtype,itemkey,actid, 'ATTR');
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;
297: exception
298: when others then
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);
301: raise;
302: end GetURL;
303:
398: end if;
399:
400: exception
401: when others then
402: Wf_Core.Context('Wf_Standard', 'Compare', itemtype,
403: itemkey, to_char(actid), funcmode);
404: raise;
405: end Compare;
406:
476: end if;
477:
478: exception
479: when others then
480: Wf_Core.Context('Wf_Standard', 'CompareExecutionTime', itemtype,
481: itemkey, to_char(actid), funcmode);
482: raise;
483: end CompareExecutionTime;
484:
690: end if;
691:
692: exception
693: when others then
694: Wf_Core.Context('Wf_Standard', 'CompareEventProperty', itemtype,
695: itemkey, to_char(actid), funcmode);
696: raise;
697: end CompareEventProperty;
698:
869: end if; -- RUN
870:
871: exception
872: when others then
873: Wf_Core.Context('Wf_Standard', 'SetEventProperty', itemtype,
874: itemkey, to_char(actid), funcmode);
875: raise;
876: end SetEventProperty;
877:
1008: end if; -- RUN
1009:
1010: exception
1011: when others then
1012: Wf_Core.Context('Wf_Standard', 'GetEventProperty', itemtype,
1013: itemkey, to_char(actid), funcmode);
1014: raise;
1015: end GetEventProperty;
1016:
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');
1060: end if;
1061:
1062: if deferit = 'Y' then
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');
1060: end if;
1061:
1062: if deferit = 'Y' then
1063: -- Check if this is the first or second execution of this activity.
1093: when others then
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;
1115: when others then
1116: --
1117: -- Dont raise error if its a dup name: instead we will loop
1118: -- around and increment the counter.
1119: if ( wf_core.error_name <> 'WFENG_ITEM_UNIQUE' ) then
1120: raise;
1121: end if;
1122: end;
1123: end loop;
1131: resultout := wf_engine.eng_completed;
1132:
1133: exception
1134: when others then
1135: Wf_Core.Context('Wf_Standard', 'LaunchProcess', itemtype,
1136: itemkey, to_char(actid), Sitemtype||':'||Sitemkey||SProcess);
1137: raise;
1138: end LaunchProcess;
1139:
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:
1179:
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:
1179:
1180:
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);
1187: wf_core.token('SAME_VERSION',SameVersionFlag);
1188: wf_core.raise('WFSQL_ARGS');
1189: end if;
1190:
1183:
1184: if SItemkey is null
1185: or SameVersionFlag is null then
1186: wf_core.token('ITEMKEY',Sitemkey);
1187: wf_core.token('SAME_VERSION',SameVersionFlag);
1188: wf_core.raise('WFSQL_ARGS');
1189: end if;
1190:
1191: if SameVersionFlag = 'T' then
1184: if SItemkey is null
1185: or SameVersionFlag is null then
1186: wf_core.token('ITEMKEY',Sitemkey);
1187: wf_core.token('SAME_VERSION',SameVersionFlag);
1188: wf_core.raise('WFSQL_ARGS');
1189: end if;
1190:
1191: if SameVersionFlag = 'T' then
1192: sameversion := TRUE;
1203: resultout := wf_engine.eng_completed;
1204:
1205: exception
1206: when others then
1207: Wf_Core.Context('Wf_Standard', 'ForkItem', itemtype,
1208: itemkey, to_char(actid), Sitemkey);
1209: raise;
1210: end ForkItem;
1211:
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);
1228: raise;
1229: end Noop;
1230:
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);
1272: Wf_Core.Token('ACTID', to_char(actid));
1273: Wf_Core.Raise('WFENG_NOTIFICATION_PERFORMER');
1274: end if;
1275:
1268: end if;
1269:
1270: if prole is null then
1271: Wf_Core.Token('TYPE', itemtype);
1272: Wf_Core.Token('ACTID', to_char(actid));
1273: Wf_Core.Raise('WFENG_NOTIFICATION_PERFORMER');
1274: end if;
1275:
1276: -- message name and expand roles will be null. Get these from attributes
1269:
1270: if prole is null then
1271: Wf_Core.Token('TYPE', itemtype);
1272: Wf_Core.Token('ACTID', to_char(actid));
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,
1304:
1305:
1306: exception
1307: when others then
1308: Wf_Core.Context('Wf_Standard', 'Notify', itemtype,
1309: itemkey, to_char(actid), funcmode);
1310: raise;
1311: end Notify;
1312:
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);
1337: raise;
1338: end Block;
1339:
1374: end if;
1375:
1376: exception
1377: when others then
1378: Wf_Core.Context('Wf_Standard', 'Defer', itemtype, itemkey,
1379: to_char(actid), funcmode);
1380: raise;
1381: end Defer;
1382:
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:
1450: -- Check if this is the first or second execution of this activity.
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:
1450: -- Check if this is the first or second execution of this activity.
1451: -- First -> result_code will be null (really null).
1525: end if;
1526:
1527: exception
1528: when wf_invalid_mode then
1529: Wf_Core.Context('Wf_Standard', 'Wait', itemtype, itemkey,
1530: to_char(actid), funcmode);
1531: Wf_Core.Token('COMMAND', wait_mode);
1532: Wf_Core.Raise('WFSQL_COMMAND');
1533: when others then
1527: exception
1528: when wf_invalid_mode then
1529: Wf_Core.Context('Wf_Standard', 'Wait', itemtype, itemkey,
1530: to_char(actid), funcmode);
1531: Wf_Core.Token('COMMAND', wait_mode);
1532: Wf_Core.Raise('WFSQL_COMMAND');
1533: when others then
1534: Wf_Core.Context('Wf_Standard', 'Wait', itemtype, itemkey,
1535: to_char(actid), funcmode);
1528: when wf_invalid_mode then
1529: Wf_Core.Context('Wf_Standard', 'Wait', itemtype, itemkey,
1530: to_char(actid), funcmode);
1531: Wf_Core.Token('COMMAND', wait_mode);
1532: Wf_Core.Raise('WFSQL_COMMAND');
1533: when others then
1534: Wf_Core.Context('Wf_Standard', 'Wait', itemtype, itemkey,
1535: to_char(actid), funcmode);
1536: raise;
1530: to_char(actid), funcmode);
1531: Wf_Core.Token('COMMAND', wait_mode);
1532: Wf_Core.Raise('WFSQL_COMMAND');
1533: when others then
1534: Wf_Core.Context('Wf_Standard', 'Wait', itemtype, itemkey,
1535: to_char(actid), funcmode);
1536: raise;
1537: end Wait;
1538:
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:
1574: -- Get RETRY or SKIP command
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:
1574: -- Get RETRY or SKIP command
1575: cmd := Wf_Engine.GetActivityAttrText(itemtype, itemkey, actid, 'COMMAND');
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);
1609: Wf_Core.Token('COMMAND', cmd);
1610: Wf_Core.Raise('WFSQL_COMMAND');
1611: when others then
1605: exception
1606: when wf_invalid_command then
1607: Wf_Core.Context('Wf_Standard', 'ResetError', itemtype,
1608: itemkey, to_char(actid), funcmode);
1609: Wf_Core.Token('COMMAND', cmd);
1610: Wf_Core.Raise('WFSQL_COMMAND');
1611: when others then
1612: Wf_Core.Context('Wf_Standard', 'ResetError', itemtype,
1613: itemkey, to_char(actid), funcmode);
1606: when wf_invalid_command then
1607: Wf_Core.Context('Wf_Standard', 'ResetError', itemtype,
1608: itemkey, to_char(actid), funcmode);
1609: Wf_Core.Token('COMMAND', cmd);
1610: Wf_Core.Raise('WFSQL_COMMAND');
1611: when others then
1612: Wf_Core.Context('Wf_Standard', 'ResetError', itemtype,
1613: itemkey, to_char(actid), funcmode);
1614: raise;
1608: itemkey, to_char(actid), funcmode);
1609: Wf_Core.Token('COMMAND', cmd);
1610: Wf_Core.Raise('WFSQL_COMMAND');
1611: when others then
1612: Wf_Core.Context('Wf_Standard', 'ResetError', itemtype,
1613: itemkey, to_char(actid), funcmode);
1614: raise;
1615: end ResetError;
1616:
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:
1688: actdate := wf_item.active_date(itemtype, itemkey);
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:
1688: actdate := wf_item.active_date(itemtype, itemkey);
1689: cmd := Wf_Engine.GetActivityAttrText(itemtype,itemkey,actid,'METHOD');
1782: end;
1783: end loop;
1784: exception
1785: when wf_invalid_command then
1786: wf_core.context('Wf_Standard', 'RoleResoluion',
1787: itemtype, itemkey, to_char(actid), funcmode);
1788: wf_core.token('COMMAND', cmd);
1789: wf_core.raise('WFSQL_COMMAND');
1790: when others then
1784: exception
1785: when wf_invalid_command then
1786: wf_core.context('Wf_Standard', 'RoleResoluion',
1787: itemtype, itemkey, to_char(actid), funcmode);
1788: wf_core.token('COMMAND', cmd);
1789: wf_core.raise('WFSQL_COMMAND');
1790: when others then
1791: wf_core.Context('Wf_Standard', 'RoleResolution',
1792: itemtype, itemkey, to_char(actid), funcmode);
1785: when wf_invalid_command then
1786: wf_core.context('Wf_Standard', 'RoleResoluion',
1787: itemtype, itemkey, to_char(actid), funcmode);
1788: wf_core.token('COMMAND', cmd);
1789: wf_core.raise('WFSQL_COMMAND');
1790: when others then
1791: wf_core.Context('Wf_Standard', 'RoleResolution',
1792: itemtype, itemkey, to_char(actid), funcmode);
1793: raise;
1787: itemtype, itemkey, to_char(actid), funcmode);
1788: wf_core.token('COMMAND', cmd);
1789: wf_core.raise('WFSQL_COMMAND');
1790: when others then
1791: wf_core.Context('Wf_Standard', 'RoleResolution',
1792: itemtype, itemkey, to_char(actid), funcmode);
1793: raise;
1794: end RoleResolution;
1795:
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:
1824: l_waiting_activity := upper(Wf_Engine.GetActivityAttrText(
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:
1824: l_waiting_activity := upper(Wf_Engine.GetActivityAttrText(
1825: itemtype, itemkey, actid,'WAITING_ACTIVITY'));
1835: end if;
1836:
1837: exception
1838: when wf_invalid_command then
1839: Wf_Core.Context('Wf_Standard', 'ContinueFlow',
1840: itemtype,itemkey, to_char(actid), funcmode);
1841: Wf_Core.Token('COMMAND', l_waiting_flow );
1842: Wf_Core.Raise('WFSQL_COMMAND');
1843: when others then
1837: exception
1838: when wf_invalid_command then
1839: Wf_Core.Context('Wf_Standard', 'ContinueFlow',
1840: itemtype,itemkey, to_char(actid), funcmode);
1841: Wf_Core.Token('COMMAND', l_waiting_flow );
1842: Wf_Core.Raise('WFSQL_COMMAND');
1843: when others then
1844: Wf_Core.Context('Wf_Standard', 'ContinueFlow',
1845: itemtype,itemkey, to_char(actid), funcmode);
1838: when wf_invalid_command then
1839: Wf_Core.Context('Wf_Standard', 'ContinueFlow',
1840: itemtype,itemkey, to_char(actid), funcmode);
1841: Wf_Core.Token('COMMAND', l_waiting_flow );
1842: Wf_Core.Raise('WFSQL_COMMAND');
1843: when others then
1844: Wf_Core.Context('Wf_Standard', 'ContinueFlow',
1845: itemtype,itemkey, to_char(actid), funcmode);
1846: raise;
1840: itemtype,itemkey, to_char(actid), funcmode);
1841: Wf_Core.Token('COMMAND', l_waiting_flow );
1842: Wf_Core.Raise('WFSQL_COMMAND');
1843: when others then
1844: Wf_Core.Context('Wf_Standard', 'ContinueFlow',
1845: itemtype,itemkey, to_char(actid), funcmode);
1846: raise;
1847: end continueflow;
1848:
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:
1877: l_continuation_activity := upper(Wf_Engine.GetActivityAttrText(
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:
1877: l_continuation_activity := upper(Wf_Engine.GetActivityAttrText(
1878: itemtype, itemkey, actid,
1891: end if;
1892:
1893: exception
1894: when wf_invalid_command then
1895: Wf_Core.Context('Wf_Standard', 'WaitForFlow',
1896: itemtype,itemkey, to_char(actid), funcmode);
1897: Wf_Core.Token('COMMAND', l_continuation_flow );
1898: Wf_Core.Raise('WFSQL_COMMAND');
1899: when others then
1893: exception
1894: when wf_invalid_command then
1895: Wf_Core.Context('Wf_Standard', 'WaitForFlow',
1896: itemtype,itemkey, to_char(actid), funcmode);
1897: Wf_Core.Token('COMMAND', l_continuation_flow );
1898: Wf_Core.Raise('WFSQL_COMMAND');
1899: when others then
1900: Wf_Core.Context('Wf_Standard', 'WaitForFlow',
1901: itemtype,itemkey, to_char(actid), funcmode);
1894: when wf_invalid_command then
1895: Wf_Core.Context('Wf_Standard', 'WaitForFlow',
1896: itemtype,itemkey, to_char(actid), funcmode);
1897: Wf_Core.Token('COMMAND', l_continuation_flow );
1898: Wf_Core.Raise('WFSQL_COMMAND');
1899: when others then
1900: Wf_Core.Context('Wf_Standard', 'WaitForFlow',
1901: itemtype,itemkey, to_char(actid), funcmode);
1902: raise;
1896: itemtype,itemkey, to_char(actid), funcmode);
1897: Wf_Core.Token('COMMAND', l_continuation_flow );
1898: Wf_Core.Raise('WFSQL_COMMAND');
1899: when others then
1900: Wf_Core.Context('Wf_Standard', 'WaitForFlow',
1901: itemtype,itemkey, to_char(actid), funcmode);
1902: raise;
1903: end WaitForFlow;
1904:
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');
1934: end if;
1935:
1936: begin
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');
1934: end if;
1935:
1936: begin
1937: loop_count := wf_engine.GetItemAttrNumber(
1940: when others then
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
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',
1966: itemtype, itemkey, to_char(actid), funcmode);
1967: raise;
1968: end loopcounter;
1969:
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:
2064: -- Get Notifications group_id for activity
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:
2064: -- Get Notifications group_id for activity
2065: Wf_Item_Activity_Status.Notification_Status(itemtype,itemkey,actid,
2166: end if;
2167: return;
2168: exception
2169: when wf_invalid_command then
2170: Wf_Core.Context('Wf_Standard', 'VoteForResultType', itemtype,
2171: itemkey, to_char(actid), funcmode);
2172: Wf_Core.Token('COMMAND', l_voting_option);
2173: Wf_Core.Raise('WFSQL_COMMAND');
2174: when others then
2168: exception
2169: when wf_invalid_command then
2170: Wf_Core.Context('Wf_Standard', 'VoteForResultType', itemtype,
2171: itemkey, to_char(actid), funcmode);
2172: Wf_Core.Token('COMMAND', l_voting_option);
2173: Wf_Core.Raise('WFSQL_COMMAND');
2174: when others then
2175: Wf_Core.Context('Wf_Standard', 'VoteForResultType',itemtype,
2176: itemkey, to_char(actid), funcmode);
2169: when wf_invalid_command then
2170: Wf_Core.Context('Wf_Standard', 'VoteForResultType', itemtype,
2171: itemkey, to_char(actid), funcmode);
2172: Wf_Core.Token('COMMAND', l_voting_option);
2173: Wf_Core.Raise('WFSQL_COMMAND');
2174: when others then
2175: Wf_Core.Context('Wf_Standard', 'VoteForResultType',itemtype,
2176: itemkey, to_char(actid), funcmode);
2177: raise;
2171: itemkey, to_char(actid), funcmode);
2172: Wf_Core.Token('COMMAND', l_voting_option);
2173: Wf_Core.Raise('WFSQL_COMMAND');
2174: when others then
2175: Wf_Core.Context('Wf_Standard', 'VoteForResultType',itemtype,
2176: itemkey, to_char(actid), funcmode);
2177: raise;
2178: end VoteForResultType;
2179:
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);
2247: raise;
2248: end WaitForMasterFlow;
2249:
2361:
2362:
2363: exception
2364: when others then
2365: wf_core.context('Wf_Standard', 'WaitForDetailFlow',
2366: itemtype,itemkey,to_char(actid),continuation_activity);
2367: raise;
2368: end WaitForDetailFlow;
2369:
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
2409: -- the detail flow has not reach the waiting activity
2410: if ( wf_core.error_name = 'WFENG_NOT_NOTIFIED' ) then
2411: wf_core.clear;
2412: else
2413: raise;
2414: end if;
2407: -- If call to CompleteActivity cannot find activity, return null
2408: -- As either the detail flows does not have a waiting activity OR
2409: -- the detail flow has not reach the waiting activity
2410: if ( wf_core.error_name = 'WFENG_NOT_NOTIFIED' ) then
2411: wf_core.clear;
2412: else
2413: raise;
2414: end if;
2415: end;
2418: ContinueDetailFlow.resultout := wf_engine.eng_null;
2419:
2420: exception
2421: when others then
2422: wf_core.context('Wf_Standard','ContinueDetailFlow',
2423: itemtype, itemkey, to_char(actid),waiting_activity);
2424: raise;
2425: end ContinueDetailFlow;
2426:
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;
2570: ContinueMasterFlow.resultout := wf_engine.eng_null;
2571: else
2572: raise;
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;
2570: ContinueMasterFlow.resultout := wf_engine.eng_null;
2571: else
2572: raise;
2573: end if;
2589: --
2590: -- If call to CompleteActivity cannot find activity, return
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;
2590: -- If call to CompleteActivity cannot find activity, return
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;
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;
2626: ContinueMasterFlow.resultout := wf_engine.eng_null;
2627: else
2628: raise;
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;
2626: ContinueMasterFlow.resultout := wf_engine.eng_null;
2627: else
2628: raise;
2629: end if;
2644: end if; --First execution
2645:
2646: exception
2647: when others then
2648: wf_core.context('Wf_Standard', 'ContinueMasterFlow',
2649: itemtype, itemkey, to_char(actid), waiting_activity);
2650: raise;
2651: end ContinueMasterFlow;
2652:
2746: result := wf_engine.eng_completed;
2747: END IF;
2748: EXCEPTION
2749: WHEN OTHERS THEN
2750: WF_CORE.Context('WF_STANDARD', 'InitializeErrors',
2751: itemtype, itemkey, actid, funcmode);
2752: RAISE;
2753: END InitializeErrors;
2754:
2812: END IF;
2813:
2814: EXCEPTION
2815: WHEN OTHERS THEN
2816: WF_CORE.Context('WF_STANDARD', 'CheckErrorActive',
2817: itemtype, itemkey, actid, funcmode);
2818: RAISE;
2819: END CheckErrorActive;
2820: -- -------------------------------------------------------------------
2888: -- Since no subscription found, look at from agent details
2889: begin
2890: select 'LOCAL' into l_source
2891: from wf_systems ws
2892: where ws.guid = hextoraw(wf_core.translate('WF_SYSTEM_GUID'))
2893: and ws.name = nvl(l_event_t.GetFromAgent().GetSystem(),ws.name);
2894: exception
2895: when no_data_found then
2896: l_source := 'EXTERNAL';
2901: -- Get the Error Message, or set it if UNEXPECTED
2902: --
2903: l_error_message := substr(l_event_t.GetErrorMessage(),1,2000);
2904: IF (l_error_message is null) THEN
2905: l_error_message := wf_core.translate('NO_MATCHING_SUBSCRIPTIONS');
2906: END IF;
2907:
2908: -- Get the Error Stack
2909: l_error_stack := substr(l_event_t.GetErrorStack(),1,2000);
2970: resultout := wf_engine.eng_completed;
2971: END IF;
2972: EXCEPTION
2973: WHEN OTHERS THEN
2974: WF_CORE.Context('WF_STANDARD', 'InitializeEventError',
2975: itemtype, itemkey, actid, funcmode);
2976: RAISE;
2977: END InitializeEventError;
2978: -- --------------------------------------------------------------------
3063: --
3064: -- Build the Table
3065: if (display_type = wf_notification.doc_html) then
3066: i := 1;
3067: l_cells(i) := wf_core.translate('WF_EVENT_HEADING');
3068: l_cells(i) := 'S30%:'||l_cells(i);
3069:
3070: i := i + 1;
3071: l_cells(i) := wf_core.translate('WF_VALUE');
3067: l_cells(i) := wf_core.translate('WF_EVENT_HEADING');
3068: l_cells(i) := 'S30%:'||l_cells(i);
3069:
3070: i := i + 1;
3071: l_cells(i) := wf_core.translate('WF_VALUE');
3072: l_cells(i) := 'S70%:'||l_cells(i);
3073:
3074: i := i + 1;
3075: l_cells(i) := 'S:'||wf_core.translate('WF_EVENT_NAME');
3071: l_cells(i) := wf_core.translate('WF_VALUE');
3072: l_cells(i) := 'S70%:'||l_cells(i);
3073:
3074: i := i + 1;
3075: l_cells(i) := 'S:'||wf_core.translate('WF_EVENT_NAME');
3076: i := i + 1;
3077: l_cells(i) := 'S:'||nvl(l_event_t.GetEventName(),'&'||'nbsp');
3078:
3079: i := i + 1;
3076: i := i + 1;
3077: l_cells(i) := 'S:'||nvl(l_event_t.GetEventName(),'&'||'nbsp');
3078:
3079: i := i + 1;
3080: l_cells(i) := 'S:'||wf_core.translate('WF_EVENT_KEY');
3081: i := i + 1;
3082: l_cells(i) := 'S:'||nvl(l_event_t.GetEventKey(),'&'||'nbsp');
3083:
3084: i := i + 1;
3081: i := i + 1;
3082: l_cells(i) := 'S:'||nvl(l_event_t.GetEventKey(),'&'||'nbsp');
3083:
3084: i := i + 1;
3085: l_cells(i) := 'S:'||wf_core.translate('WF_TO_AGENT_NAME');
3086: i := i + 1;
3087: l_cells(i) := 'S:'||l_to_agent;
3088: i := i + 1;
3089: l_cells(i) := 'S:'||wf_core.translate('WF_TO_AGENT_SYSTEM');
3085: l_cells(i) := 'S:'||wf_core.translate('WF_TO_AGENT_NAME');
3086: i := i + 1;
3087: l_cells(i) := 'S:'||l_to_agent;
3088: i := i + 1;
3089: l_cells(i) := 'S:'||wf_core.translate('WF_TO_AGENT_SYSTEM');
3090: i := i + 1;
3091: l_cells(i) := 'S:'||l_to_system;
3092:
3093: i := i + 1;
3090: i := i + 1;
3091: l_cells(i) := 'S:'||l_to_system;
3092:
3093: i := i + 1;
3094: l_cells(i) := 'S:'||wf_core.translate('WF_FROM_AGENT_NAME');
3095: i := i + 1;
3096: l_cells(i) := 'S:'||l_from_agent;
3097: i := i + 1;
3098: l_cells(i) := 'S:'||wf_core.translate('WF_FROM_AGENT_SYSTEM');
3094: l_cells(i) := 'S:'||wf_core.translate('WF_FROM_AGENT_NAME');
3095: i := i + 1;
3096: l_cells(i) := 'S:'||l_from_agent;
3097: i := i + 1;
3098: l_cells(i) := 'S:'||wf_core.translate('WF_FROM_AGENT_SYSTEM');
3099: i := i + 1;
3100: l_cells(i) := 'S:'||l_from_system;
3101:
3102: i := i + 1;
3099: i := i + 1;
3100: l_cells(i) := 'S:'||l_from_system;
3101:
3102: i := i + 1;
3103: l_cells(i) := 'S:'||wf_core.translate('WF_SEND_DATE');
3104: i := i + 1;
3105: l_cells(i) := 'S:'||l_send_date_text||'';
3106:
3107: i := i + 1;
3104: i := i + 1;
3105: l_cells(i) := 'S:'||l_send_date_text||'';
3106:
3107: i := i + 1;
3108: l_cells(i) := 'S:'||wf_core.translate('WF_RECEIVE_DATE');
3109: i := i + 1;
3110: l_cells(i) := 'S:'||l_receive_date_text||'';
3111:
3112: i := i + 1;
3109: i := i + 1;
3110: l_cells(i) := 'S:'||l_receive_date_text||'';
3111:
3112: i := i + 1;
3113: l_cells(i) := 'S:'||wf_core.translate('WF_PRIORITY');
3114: i := i + 1;
3115: l_cells(i) := 'S:'||l_priority;
3116:
3117: i := i + 1;
3114: i := i + 1;
3115: l_cells(i) := 'S:'||l_priority;
3116:
3117: i := i + 1;
3118: l_cells(i) := 'S:'||wf_core.translate('WF_CORRELATION');
3119: i := i + 1;
3120: l_cells(i) := 'S:'||nvl(l_event_t.GetCorrelationId(),'&'||'nbsp');
3121:
3122: else
3119: i := i + 1;
3120: l_cells(i) := 'S:'||nvl(l_event_t.GetCorrelationId(),'&'||'nbsp');
3121:
3122: else
3123: l_result := Wf_Core.Newline||rpad(wf_core.translate('WF_EVENT_HEADING'),40)
3124: ||wf_core.translate('WF_VALUE')||Wf_Core.Newline;
3125:
3126: l_result := l_result||rpad(wf_core.translate('WF_EVENT_NAME'),40)||
3127: l_event_t.GetEventName()||Wf_Core.Newline||
3120: l_cells(i) := 'S:'||nvl(l_event_t.GetCorrelationId(),'&'||'nbsp');
3121:
3122: else
3123: l_result := Wf_Core.Newline||rpad(wf_core.translate('WF_EVENT_HEADING'),40)
3124: ||wf_core.translate('WF_VALUE')||Wf_Core.Newline;
3125:
3126: l_result := l_result||rpad(wf_core.translate('WF_EVENT_NAME'),40)||
3127: l_event_t.GetEventName()||Wf_Core.Newline||
3128: rpad(wf_core.translate('WF_EVENT_KEY'),40)||
3122: else
3123: l_result := Wf_Core.Newline||rpad(wf_core.translate('WF_EVENT_HEADING'),40)
3124: ||wf_core.translate('WF_VALUE')||Wf_Core.Newline;
3125:
3126: l_result := l_result||rpad(wf_core.translate('WF_EVENT_NAME'),40)||
3127: l_event_t.GetEventName()||Wf_Core.Newline||
3128: rpad(wf_core.translate('WF_EVENT_KEY'),40)||
3129: l_event_t.GetEventKey()||Wf_Core.Newline||
3130: rpad(wf_core.translate('WF_FROM_AGENT_NAME'),40)||
3123: l_result := Wf_Core.Newline||rpad(wf_core.translate('WF_EVENT_HEADING'),40)
3124: ||wf_core.translate('WF_VALUE')||Wf_Core.Newline;
3125:
3126: l_result := l_result||rpad(wf_core.translate('WF_EVENT_NAME'),40)||
3127: l_event_t.GetEventName()||Wf_Core.Newline||
3128: rpad(wf_core.translate('WF_EVENT_KEY'),40)||
3129: l_event_t.GetEventKey()||Wf_Core.Newline||
3130: rpad(wf_core.translate('WF_FROM_AGENT_NAME'),40)||
3131: l_From_Agent||Wf_Core.Newline||
3124: ||wf_core.translate('WF_VALUE')||Wf_Core.Newline;
3125:
3126: l_result := l_result||rpad(wf_core.translate('WF_EVENT_NAME'),40)||
3127: l_event_t.GetEventName()||Wf_Core.Newline||
3128: rpad(wf_core.translate('WF_EVENT_KEY'),40)||
3129: l_event_t.GetEventKey()||Wf_Core.Newline||
3130: rpad(wf_core.translate('WF_FROM_AGENT_NAME'),40)||
3131: l_From_Agent||Wf_Core.Newline||
3132: rpad(wf_core.translate('WF_FROM_AGENT_SYSTEM'),40)||
3125:
3126: l_result := l_result||rpad(wf_core.translate('WF_EVENT_NAME'),40)||
3127: l_event_t.GetEventName()||Wf_Core.Newline||
3128: rpad(wf_core.translate('WF_EVENT_KEY'),40)||
3129: l_event_t.GetEventKey()||Wf_Core.Newline||
3130: rpad(wf_core.translate('WF_FROM_AGENT_NAME'),40)||
3131: l_From_Agent||Wf_Core.Newline||
3132: rpad(wf_core.translate('WF_FROM_AGENT_SYSTEM'),40)||
3133: l_From_System||Wf_Core.Newline||
3126: l_result := l_result||rpad(wf_core.translate('WF_EVENT_NAME'),40)||
3127: l_event_t.GetEventName()||Wf_Core.Newline||
3128: rpad(wf_core.translate('WF_EVENT_KEY'),40)||
3129: l_event_t.GetEventKey()||Wf_Core.Newline||
3130: rpad(wf_core.translate('WF_FROM_AGENT_NAME'),40)||
3131: l_From_Agent||Wf_Core.Newline||
3132: rpad(wf_core.translate('WF_FROM_AGENT_SYSTEM'),40)||
3133: l_From_System||Wf_Core.Newline||
3134: rpad(wf_core.translate('WF_TO_AGENT_NAME'),40)||
3127: l_event_t.GetEventName()||Wf_Core.Newline||
3128: rpad(wf_core.translate('WF_EVENT_KEY'),40)||
3129: l_event_t.GetEventKey()||Wf_Core.Newline||
3130: rpad(wf_core.translate('WF_FROM_AGENT_NAME'),40)||
3131: l_From_Agent||Wf_Core.Newline||
3132: rpad(wf_core.translate('WF_FROM_AGENT_SYSTEM'),40)||
3133: l_From_System||Wf_Core.Newline||
3134: rpad(wf_core.translate('WF_TO_AGENT_NAME'),40)||
3135: l_To_Agent||Wf_Core.Newline||
3128: rpad(wf_core.translate('WF_EVENT_KEY'),40)||
3129: l_event_t.GetEventKey()||Wf_Core.Newline||
3130: rpad(wf_core.translate('WF_FROM_AGENT_NAME'),40)||
3131: l_From_Agent||Wf_Core.Newline||
3132: rpad(wf_core.translate('WF_FROM_AGENT_SYSTEM'),40)||
3133: l_From_System||Wf_Core.Newline||
3134: rpad(wf_core.translate('WF_TO_AGENT_NAME'),40)||
3135: l_To_Agent||Wf_Core.Newline||
3136: rpad(wf_core.translate('WF_TO_AGENT_SYSTEM'),40)||
3129: l_event_t.GetEventKey()||Wf_Core.Newline||
3130: rpad(wf_core.translate('WF_FROM_AGENT_NAME'),40)||
3131: l_From_Agent||Wf_Core.Newline||
3132: rpad(wf_core.translate('WF_FROM_AGENT_SYSTEM'),40)||
3133: l_From_System||Wf_Core.Newline||
3134: rpad(wf_core.translate('WF_TO_AGENT_NAME'),40)||
3135: l_To_Agent||Wf_Core.Newline||
3136: rpad(wf_core.translate('WF_TO_AGENT_SYSTEM'),40)||
3137: l_To_System||Wf_Core.Newline||
3130: rpad(wf_core.translate('WF_FROM_AGENT_NAME'),40)||
3131: l_From_Agent||Wf_Core.Newline||
3132: rpad(wf_core.translate('WF_FROM_AGENT_SYSTEM'),40)||
3133: l_From_System||Wf_Core.Newline||
3134: rpad(wf_core.translate('WF_TO_AGENT_NAME'),40)||
3135: l_To_Agent||Wf_Core.Newline||
3136: rpad(wf_core.translate('WF_TO_AGENT_SYSTEM'),40)||
3137: l_To_System||Wf_Core.Newline||
3138: rpad(wf_core.translate('WF_PRIORITY'),40)||
3131: l_From_Agent||Wf_Core.Newline||
3132: rpad(wf_core.translate('WF_FROM_AGENT_SYSTEM'),40)||
3133: l_From_System||Wf_Core.Newline||
3134: rpad(wf_core.translate('WF_TO_AGENT_NAME'),40)||
3135: l_To_Agent||Wf_Core.Newline||
3136: rpad(wf_core.translate('WF_TO_AGENT_SYSTEM'),40)||
3137: l_To_System||Wf_Core.Newline||
3138: rpad(wf_core.translate('WF_PRIORITY'),40)||
3139: l_Priority||Wf_Core.Newline||
3132: rpad(wf_core.translate('WF_FROM_AGENT_SYSTEM'),40)||
3133: l_From_System||Wf_Core.Newline||
3134: rpad(wf_core.translate('WF_TO_AGENT_NAME'),40)||
3135: l_To_Agent||Wf_Core.Newline||
3136: rpad(wf_core.translate('WF_TO_AGENT_SYSTEM'),40)||
3137: l_To_System||Wf_Core.Newline||
3138: rpad(wf_core.translate('WF_PRIORITY'),40)||
3139: l_Priority||Wf_Core.Newline||
3140: rpad(wf_core.translate('WF_SEND_DATE'),40)||
3133: l_From_System||Wf_Core.Newline||
3134: rpad(wf_core.translate('WF_TO_AGENT_NAME'),40)||
3135: l_To_Agent||Wf_Core.Newline||
3136: rpad(wf_core.translate('WF_TO_AGENT_SYSTEM'),40)||
3137: l_To_System||Wf_Core.Newline||
3138: rpad(wf_core.translate('WF_PRIORITY'),40)||
3139: l_Priority||Wf_Core.Newline||
3140: rpad(wf_core.translate('WF_SEND_DATE'),40)||
3141: l_send_date_text||Wf_Core.Newline||
3134: rpad(wf_core.translate('WF_TO_AGENT_NAME'),40)||
3135: l_To_Agent||Wf_Core.Newline||
3136: rpad(wf_core.translate('WF_TO_AGENT_SYSTEM'),40)||
3137: l_To_System||Wf_Core.Newline||
3138: rpad(wf_core.translate('WF_PRIORITY'),40)||
3139: l_Priority||Wf_Core.Newline||
3140: rpad(wf_core.translate('WF_SEND_DATE'),40)||
3141: l_send_date_text||Wf_Core.Newline||
3142: rpad(wf_core.translate('WF_RECEIVE_DATE'),40)||
3135: l_To_Agent||Wf_Core.Newline||
3136: rpad(wf_core.translate('WF_TO_AGENT_SYSTEM'),40)||
3137: l_To_System||Wf_Core.Newline||
3138: rpad(wf_core.translate('WF_PRIORITY'),40)||
3139: l_Priority||Wf_Core.Newline||
3140: rpad(wf_core.translate('WF_SEND_DATE'),40)||
3141: l_send_date_text||Wf_Core.Newline||
3142: rpad(wf_core.translate('WF_RECEIVE_DATE'),40)||
3143: l_receive_date_text||Wf_Core.Newline||
3136: rpad(wf_core.translate('WF_TO_AGENT_SYSTEM'),40)||
3137: l_To_System||Wf_Core.Newline||
3138: rpad(wf_core.translate('WF_PRIORITY'),40)||
3139: l_Priority||Wf_Core.Newline||
3140: rpad(wf_core.translate('WF_SEND_DATE'),40)||
3141: l_send_date_text||Wf_Core.Newline||
3142: rpad(wf_core.translate('WF_RECEIVE_DATE'),40)||
3143: l_receive_date_text||Wf_Core.Newline||
3144: rpad(wf_core.translate('WF_CORRELATION'),40)||
3137: l_To_System||Wf_Core.Newline||
3138: rpad(wf_core.translate('WF_PRIORITY'),40)||
3139: l_Priority||Wf_Core.Newline||
3140: rpad(wf_core.translate('WF_SEND_DATE'),40)||
3141: l_send_date_text||Wf_Core.Newline||
3142: rpad(wf_core.translate('WF_RECEIVE_DATE'),40)||
3143: l_receive_date_text||Wf_Core.Newline||
3144: rpad(wf_core.translate('WF_CORRELATION'),40)||
3145: l_event_t.GetCorrelationId()||Wf_Core.Newline;
3138: rpad(wf_core.translate('WF_PRIORITY'),40)||
3139: l_Priority||Wf_Core.Newline||
3140: rpad(wf_core.translate('WF_SEND_DATE'),40)||
3141: l_send_date_text||Wf_Core.Newline||
3142: rpad(wf_core.translate('WF_RECEIVE_DATE'),40)||
3143: l_receive_date_text||Wf_Core.Newline||
3144: rpad(wf_core.translate('WF_CORRELATION'),40)||
3145: l_event_t.GetCorrelationId()||Wf_Core.Newline;
3146:
3139: l_Priority||Wf_Core.Newline||
3140: rpad(wf_core.translate('WF_SEND_DATE'),40)||
3141: l_send_date_text||Wf_Core.Newline||
3142: rpad(wf_core.translate('WF_RECEIVE_DATE'),40)||
3143: l_receive_date_text||Wf_Core.Newline||
3144: rpad(wf_core.translate('WF_CORRELATION'),40)||
3145: l_event_t.GetCorrelationId()||Wf_Core.Newline;
3146:
3147: end if;
3140: rpad(wf_core.translate('WF_SEND_DATE'),40)||
3141: l_send_date_text||Wf_Core.Newline||
3142: rpad(wf_core.translate('WF_RECEIVE_DATE'),40)||
3143: l_receive_date_text||Wf_Core.Newline||
3144: rpad(wf_core.translate('WF_CORRELATION'),40)||
3145: l_event_t.GetCorrelationId()||Wf_Core.Newline;
3146:
3147: end if;
3148:
3141: l_send_date_text||Wf_Core.Newline||
3142: rpad(wf_core.translate('WF_RECEIVE_DATE'),40)||
3143: l_receive_date_text||Wf_Core.Newline||
3144: rpad(wf_core.translate('WF_CORRELATION'),40)||
3145: l_event_t.GetCorrelationId()||Wf_Core.Newline;
3146:
3147: end if;
3148:
3149: -- Display the Parameter List
3152: j := l_parmlist_t.FIRST;
3153: while (j <= l_parmlist_t.LAST) loop
3154: if (display_type = wf_notification.doc_html) then
3155: i := i + 1;
3156: l_cells(i) := 'S:'||wf_core.translate('WF_PARAMETER')||' : '||l_parmlist_t(j).getName();
3157:
3158: i := i + 1;
3159: l_cells(i) :=
3160: 'S:'||substr(nvl(l_parmlist_t(j).getValue(),'&'||'nbsp'),1,20);
3158: i := i + 1;
3159: l_cells(i) :=
3160: 'S:'||substr(nvl(l_parmlist_t(j).getValue(),'&'||'nbsp'),1,20);
3161: else
3162: l_result := l_result||rpad(wf_core.translate('WF_PARAMETER')
3163: ||l_parmlist_t(j).getName(),40)
3164: ||substr(l_parmlist_t(j).getValue(),1,20)||Wf_Core.Newline;
3165: end if;
3166: j := l_parmlist_t.NEXT(j);
3160: 'S:'||substr(nvl(l_parmlist_t(j).getValue(),'&'||'nbsp'),1,20);
3161: else
3162: l_result := l_result||rpad(wf_core.translate('WF_PARAMETER')
3163: ||l_parmlist_t(j).getName(),40)
3164: ||substr(l_parmlist_t(j).getValue(),1,20)||Wf_Core.Newline;
3165: end if;
3166: j := l_parmlist_t.NEXT(j);
3167: end loop;
3168: end if;
3174: type => 'H',
3175: rs => l_result);
3176: -- Display title
3177: l_result := '
'||wf_core.Translate('WFITD_EVENT_DETAILS')|| 3179: ' |
'||l_result||' |
3184: document := l_result;
3185:
3186: exception
3187: when others then
3188: wf_core.context('WF_STANDARD','EventDetails',document_id, display_type);
3189: raise;
3190: end EventDetails;
3191: -- --------------------------------------------------------------------
3192: -- Retry Raise
3247: l_toagent := l_event_t.GetToAgent();
3248: l_event_t.SetPriority(-1); -- want this dequeued ASAP
3249: wf_event.enqueue(l_event_t, l_toagent);
3250: ELSE
3251: wf_core.raise('WFSQL_ARGS');
3252:
3253: END IF;
3254:
3255: resultout := wf_engine.eng_completed;
3259: END IF;
3260:
3261: EXCEPTION
3262: WHEN OTHERS THEN
3263: WF_CORE.Context('WF_STANDARD', 'RetryRaise',
3264: itemtype, itemkey, actid, funcmode);
3265: RAISE;
3266: end RetryRaise;
3267: -- --------------------------------------------------------------------
3349: END IF;
3350:
3351: EXCEPTION
3352: WHEN OTHERS THEN
3353: WF_CORE.Context('WF_STANDARD', 'GetAgents',
3354: itemtype, itemkey, actid, funcmode);
3355: RAISE;
3356: end GetAgents;
3357: -- --------------------------------------------------------------------
3414: END IF;
3415:
3416: EXCEPTION
3417: WHEN OTHERS THEN
3418: WF_CORE.Context('WF_STANDARD', 'GetAckAgent',
3419: itemtype, itemkey, actid, funcmode);
3420: RAISE;
3421: end GetAckAgent;
3422:
3469: l_sub_param_list := wf_event.GetParamListFromString(l_params);
3470:
3471: if (display_type = wf_notification.doc_html) then
3472: i := 1;
3473: l_cells(i) := 'S30%:'||wf_core.Translate('WF_PARAMETER');
3474:
3475: i := i + 1;
3476: l_cells(i) := 'S70%:'||wf_core.Translate('WF_VALUE');
3477: else
3472: i := 1;
3473: l_cells(i) := 'S30%:'||wf_core.Translate('WF_PARAMETER');
3474:
3475: i := i + 1;
3476: l_cells(i) := 'S70%:'||wf_core.Translate('WF_VALUE');
3477: else
3478: l_result := Wf_Core.Newline||rpad(wf_core.Translate('WF_PARAMETER'), 40)
3479: ||wf_core.translate('WF_VALUE')||Wf_Core.Newline;
3480: end if;
3474:
3475: i := i + 1;
3476: l_cells(i) := 'S70%:'||wf_core.Translate('WF_VALUE');
3477: else
3478: l_result := Wf_Core.Newline||rpad(wf_core.Translate('WF_PARAMETER'), 40)
3479: ||wf_core.translate('WF_VALUE')||Wf_Core.Newline;
3480: end if;
3481:
3482: -- Show all Subscription Parameters that are currently used as
3475: i := i + 1;
3476: l_cells(i) := 'S70%:'||wf_core.Translate('WF_VALUE');
3477: else
3478: l_result := Wf_Core.Newline||rpad(wf_core.Translate('WF_PARAMETER'), 40)
3479: ||wf_core.translate('WF_VALUE')||Wf_Core.Newline;
3480: end if;
3481:
3482: -- Show all Subscription Parameters that are currently used as
3483: -- meta-data store for WS definition
3491: i := i + 1;
3492: l_cells(i) := 'S:'||l_sub_param_list(j).getValue();
3493: else
3494: l_result := l_result||rpad(l_sub_param_list(j).getName(),40)||
3495: rpad(l_sub_param_list(j).getValue(),40)||wf_core.newline;
3496: end if;
3497: j := l_sub_param_list.NEXT(j);
3498: end loop;
3499: end if;
3508: aname => 'EVENT_SUBSCRIPTION');
3509:
3510: if (display_type = wf_notification.doc_html) then
3511: i := i + 1;
3512: l_cells(i) := 'S:'||wf_core.Translate('WF_INOKER_RULE_FUNC');
3513: i := i + 1;
3514: l_cells(i) := 'S:'||l_rule_func;
3515:
3516: i := i + 1;
3513: i := i + 1;
3514: l_cells(i) := 'S:'||l_rule_func;
3515:
3516: i := i + 1;
3517: l_cells(i) := 'S:'||wf_core.Translate('WF_WS_INPUT_MESG');
3518: i := i + 1;
3519: l_url := ''||wf_core.Translate('WF_CLICK_HERE')||'';
3520: l_cells(i) := 'S:'||l_url;
3521:
3515:
3516: i := i + 1;
3517: l_cells(i) := 'S:'||wf_core.Translate('WF_WS_INPUT_MESG');
3518: i := i + 1;
3519: l_url := ''||wf_core.Translate('WF_CLICK_HERE')||'';
3520: l_cells(i) := 'S:'||l_url;
3521:
3522: i := i + 1;
3523: l_cells(i) := 'S:'||wf_core.Translate('WF_SUBSCRIPTION_PAGE');
3519: l_url := ''||wf_core.Translate('WF_CLICK_HERE')||'';
3520: l_cells(i) := 'S:'||l_url;
3521:
3522: i := i + 1;
3523: l_cells(i) := 'S:'||wf_core.Translate('WF_SUBSCRIPTION_PAGE');
3524: i := i + 1;
3525: l_url := ''||wf_core.Translate('WF_CLICK_HERE')||'';
3526: l_cells(i) := 'S:'||l_url;
3527:
3521:
3522: i := i + 1;
3523: l_cells(i) := 'S:'||wf_core.Translate('WF_SUBSCRIPTION_PAGE');
3524: i := i + 1;
3525: l_url := ''||wf_core.Translate('WF_CLICK_HERE')||'';
3526: l_cells(i) := 'S:'||l_url;
3527:
3528: wf_notification.Ntf_Table(l_cells, 2, 'H', l_result);
3529:
3528: wf_notification.Ntf_Table(l_cells, 2, 'H', l_result);
3529:
3530: -- Display title "Web Service Details"
3531: l_result := '
'||wf_core.Translate('WF_WEBSERVICE_DETAILS')||' |
'||l_result||' |
3532: '
3533: '
3534:
3535: else
3536: l_result := l_result||rpad(wf_core.Translate('WF_INOKER_RULE_FUNC'),40)||
3537: rpad(l_rule_func,40)||wf_core.newline||
3538: rpad(wf_core.Translate('WF_WS_INPUT_MESG'),40)||
3539: rpad(l_evt_url,40)||wf_core.newline||
3540: rpad(wf_core.Translate('WF_SUBSCRIPTION_PAGE'),40)||
3541: rpad(l_sub_url,40)||wf_core.newline;
3542:
3535: else
3536: l_result := l_result||rpad(wf_core.Translate('WF_INOKER_RULE_FUNC'),40)||
3537: rpad(l_rule_func,40)||wf_core.newline||
3538: rpad(wf_core.Translate('WF_WS_INPUT_MESG'),40)||
3539: rpad(l_evt_url,40)||wf_core.newline||
3540: rpad(wf_core.Translate('WF_SUBSCRIPTION_PAGE'),40)||
3541: rpad(l_sub_url,40)||wf_core.newline;
3542:
3543: end if;
3536: l_result := l_result||rpad(wf_core.Translate('WF_INOKER_RULE_FUNC'),40)||
3537: rpad(l_rule_func,40)||wf_core.newline||
3538: rpad(wf_core.Translate('WF_WS_INPUT_MESG'),40)||
3539: rpad(l_evt_url,40)||wf_core.newline||
3540: rpad(wf_core.Translate('WF_SUBSCRIPTION_PAGE'),40)||
3541: rpad(l_sub_url,40)||wf_core.newline;
3542:
3543: end if;
3544: end if;
3537: rpad(l_rule_func,40)||wf_core.newline||
3538: rpad(wf_core.Translate('WF_WS_INPUT_MESG'),40)||
3539: rpad(l_evt_url,40)||wf_core.newline||
3540: rpad(wf_core.Translate('WF_SUBSCRIPTION_PAGE'),40)||
3541: rpad(l_sub_url,40)||wf_core.newline;
3542:
3543: end if;
3544: end if;
3545: document := l_result;
3544: end if;
3545: document := l_result;
3546: exception
3547: when others then
3548: wf_core.context('WF_STANDARD', 'SubscriptionDetails', document_id);
3549: raise;
3550: end SubscriptionDetails;
3551:
3552: -- ErrorDetails
3588: document_type := wf_notification.doc_html;
3589:
3590: i := 1;
3591: if (l_error_name is not null) then
3592: l_cells(i) := 'E20%:'||wf_core.Translate('WFMON_ERROR_NAME');
3593: i := i + 1;
3594: l_cells(i) := 'S:'||l_error_name;
3595: i := i + 1;
3596: end if;
3594: l_cells(i) := 'S:'||l_error_name;
3595: i := i + 1;
3596: end if;
3597:
3598: l_cells(i) := 'E20%:'||wf_core.Translate('WFMON_ERROR_MESSAGE');
3599: i := i + 1;
3600: l_cells(i) := 'S:'||l_error_message;
3601:
3602: i := i + 1;
3599: i := i + 1;
3600: l_cells(i) := 'S:'||l_error_message;
3601:
3602: i := i + 1;
3603: l_cells(i) := 'E20%:'||wf_core.Translate('WFMON_ERROR_STACK');
3604: i := i + 1;
3605: l_cells(i) := 'S:'||l_error_stack;
3606:
3607: wf_notification.NTF_Table(cells => l_cells,
3610: rs => l_result);
3611:
3612: -- Display title
3613: l_result := '
'||wf_core.Translate('WF_ERROR_DETAILS') || 3615: ' |
'||l_result||' |
3614: '
3615: ''||'
3616: else
3617: document_type := wf_notification.doc_text;
3618: l_result := rpad(wf_core.Translate('WFMON_ERROR_NAME'),40)||' : '||l_error_name||wf_core.newline||
3619: rpad(wf_core.Translate('WFMON_ERROR_MESSAGE'),40)||' : '||l_error_message||wf_core.newline||
3620: rpad(wf_core.Translate('WFMON_ERROR_STACK'),40)||' : '||l_error_stack||wf_core.newline;
3621: end if;
3622: document := l_result;
3623: exception
3624: when others then
3621: end if;
3622: document := l_result;
3623: exception
3624: when others then
3625: wf_core.context('WF_STANDARD', 'ErrorDetails', document_id);
3626: raise;
3627: end ErrorDetails;
3628:
3629: -- SubscriptionAction