1: package body WF_EVENT_SYNCHRONIZE_PKG as
2: /* $Header: WFEVSYNB.pls 120.6 2006/08/21 13:37:06 nravindr ship $ */
3: ------------------------------------------------------------------------------
4: /*
5: ** PRIVATE global variable
33: l_result varchar2(100);
34: begin
35:
36: dbms_lob.createtemporary(l_clob, FALSE, DBMS_LOB.CALL);
37: wf_event_synchronize_pkg.CreateSyncClob(p_eventdata => l_clob);
38:
39: p_event.SetEventData(l_clob);
40:
41: l_result := wf_rule.default_rule(p_subscription_guid, p_event);
43: return (l_result);
44:
45: exception
46: when others then
47: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'SYNCHRONIZE', p_event.event_name,
48: p_event.event_key,
49: 'ERROR'); raise;
50: return('ERROR');
51: end;
63:
64: l_result varchar2(100);
65: begin
66:
67: wf_event_synchronize_pkg.uploadsyncclob(p_event.event_data);
68:
69: l_result := wf_rule.default_rule(p_subscription_guid, p_event);
70:
71: return (l_result);
71: return (l_result);
72:
73: exception
74: when others then
75: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'SYNCHRONIZEUPLOAD', p_event.event_name,
76: p_event.event_key,
77: 'ERROR'); raise;
78: return('ERROR');
79: end;
99: g_objecttype := upper(p_objecttype);
100:
101: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
102: wf_log_pkg.string(wf_log_pkg.level_procedure,
103: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.CREATESYNCCLOB.Begin',
104: 'Entered Create Sync Clob');
105: end if;
106:
107: IF (p_isexactnum = 1) THEN
125: -- Files.
126: IF g_objecttype in ('SYSTEMS', 'AGENTS', 'AGENTGROUPS') THEN
127: -- Systems, Agents, Agent Groups in one file
128: dbms_lob.append(p_eventdata,
129: wf_event_synchronize_pkg.GetSystems(l_ObjectKey));
130: dbms_lob.append(p_eventdata,
131: wf_event_synchronize_pkg.GetAgents(l_ObjectKey,p_isexact));
132: dbms_lob.append(p_eventdata,
133: wf_event_synchronize_pkg.GetAgentGroups(l_ObjectKey));
127: -- Systems, Agents, Agent Groups in one file
128: dbms_lob.append(p_eventdata,
129: wf_event_synchronize_pkg.GetSystems(l_ObjectKey));
130: dbms_lob.append(p_eventdata,
131: wf_event_synchronize_pkg.GetAgents(l_ObjectKey,p_isexact));
132: dbms_lob.append(p_eventdata,
133: wf_event_synchronize_pkg.GetAgentGroups(l_ObjectKey));
134: ELSIF g_objecttype = 'EVENTS' THEN
135: -- Download event and event groups
129: wf_event_synchronize_pkg.GetSystems(l_ObjectKey));
130: dbms_lob.append(p_eventdata,
131: wf_event_synchronize_pkg.GetAgents(l_ObjectKey,p_isexact));
132: dbms_lob.append(p_eventdata,
133: wf_event_synchronize_pkg.GetAgentGroups(l_ObjectKey));
134: ELSIF g_objecttype = 'EVENTS' THEN
135: -- Download event and event groups
136: dbms_lob.append(p_eventdata,
137: wf_event_synchronize_pkg.GetEvents(l_ObjectKey, p_ownertag));
133: wf_event_synchronize_pkg.GetAgentGroups(l_ObjectKey));
134: ELSIF g_objecttype = 'EVENTS' THEN
135: -- Download event and event groups
136: dbms_lob.append(p_eventdata,
137: wf_event_synchronize_pkg.GetEvents(l_ObjectKey, p_ownertag));
138:
139: dbms_lob.append(p_eventdata,
140: wf_event_synchronize_pkg.GetEventGroups(
141: l_ObjectKey,p_ownertag));
136: dbms_lob.append(p_eventdata,
137: wf_event_synchronize_pkg.GetEvents(l_ObjectKey, p_ownertag));
138:
139: dbms_lob.append(p_eventdata,
140: wf_event_synchronize_pkg.GetEventGroups(
141: l_ObjectKey,p_ownertag));
142: ELSIF g_objecttype = 'EVENT_GROUPS' THEN
143: -- Download event groups
144: dbms_lob.append(p_eventdata,
141: l_ObjectKey,p_ownertag));
142: ELSIF g_objecttype = 'EVENT_GROUPS' THEN
143: -- Download event groups
144: dbms_lob.append(p_eventdata,
145: wf_event_synchronize_pkg.GetGroups(l_ObjectKey, p_ownertag));
146:
147: -- EVENT_GROUPS option now downloads only GROUP type objects. Not members
148: -- dbms_lob.append(p_eventdata,
149: -- wf_event_synchronize_pkg.GetEventGroupByGroup(l_ObjectKey,p_ownertag));
145: wf_event_synchronize_pkg.GetGroups(l_ObjectKey, p_ownertag));
146:
147: -- EVENT_GROUPS option now downloads only GROUP type objects. Not members
148: -- dbms_lob.append(p_eventdata,
149: -- wf_event_synchronize_pkg.GetEventGroupByGroup(l_ObjectKey,p_ownertag));
150: ELSIF g_objecttype = 'SUBSCRIPTIONS' THEN
151: -- Download subscriptions in one file
152: dbms_lob.append(p_eventdata,
153: wf_event_synchronize_pkg.GetSubscriptions(l_ObjectKey,
149: -- wf_event_synchronize_pkg.GetEventGroupByGroup(l_ObjectKey,p_ownertag));
150: ELSIF g_objecttype = 'SUBSCRIPTIONS' THEN
151: -- Download subscriptions in one file
152: dbms_lob.append(p_eventdata,
153: wf_event_synchronize_pkg.GetSubscriptions(l_ObjectKey,
154: p_isexact, p_ownertag));
155:
156: ELSE -- including ALL
157:
155:
156: ELSE -- including ALL
157:
158: dbms_lob.append(p_eventdata,
159: wf_event_synchronize_pkg.GetSystems(l_ObjectKey));
160: dbms_lob.append(p_eventdata,
161: wf_event_synchronize_pkg.GetAgents(l_ObjectKey,p_isexact));
162: dbms_lob.append(p_eventdata,
163: wf_event_synchronize_pkg.GetAgentGroups(l_ObjectKey));
157:
158: dbms_lob.append(p_eventdata,
159: wf_event_synchronize_pkg.GetSystems(l_ObjectKey));
160: dbms_lob.append(p_eventdata,
161: wf_event_synchronize_pkg.GetAgents(l_ObjectKey,p_isexact));
162: dbms_lob.append(p_eventdata,
163: wf_event_synchronize_pkg.GetAgentGroups(l_ObjectKey));
164: dbms_lob.append(p_eventdata,
165: wf_event_synchronize_pkg.GetEvents(l_ObjectKey, p_ownertag));
159: wf_event_synchronize_pkg.GetSystems(l_ObjectKey));
160: dbms_lob.append(p_eventdata,
161: wf_event_synchronize_pkg.GetAgents(l_ObjectKey,p_isexact));
162: dbms_lob.append(p_eventdata,
163: wf_event_synchronize_pkg.GetAgentGroups(l_ObjectKey));
164: dbms_lob.append(p_eventdata,
165: wf_event_synchronize_pkg.GetEvents(l_ObjectKey, p_ownertag));
166: dbms_lob.append(p_eventdata,
167: wf_event_synchronize_pkg.GetSubscriptions(l_ObjectKey,p_isexact, p_ownertag));
161: wf_event_synchronize_pkg.GetAgents(l_ObjectKey,p_isexact));
162: dbms_lob.append(p_eventdata,
163: wf_event_synchronize_pkg.GetAgentGroups(l_ObjectKey));
164: dbms_lob.append(p_eventdata,
165: wf_event_synchronize_pkg.GetEvents(l_ObjectKey, p_ownertag));
166: dbms_lob.append(p_eventdata,
167: wf_event_synchronize_pkg.GetSubscriptions(l_ObjectKey,p_isexact, p_ownertag));
168: dbms_lob.append(p_eventdata,
169: wf_event_synchronize_pkg.GetEventGroups(l_ObjectKey, p_ownertag));
163: wf_event_synchronize_pkg.GetAgentGroups(l_ObjectKey));
164: dbms_lob.append(p_eventdata,
165: wf_event_synchronize_pkg.GetEvents(l_ObjectKey, p_ownertag));
166: dbms_lob.append(p_eventdata,
167: wf_event_synchronize_pkg.GetSubscriptions(l_ObjectKey,p_isexact, p_ownertag));
168: dbms_lob.append(p_eventdata,
169: wf_event_synchronize_pkg.GetEventGroups(l_ObjectKey, p_ownertag));
170:
171: END IF;
165: wf_event_synchronize_pkg.GetEvents(l_ObjectKey, p_ownertag));
166: dbms_lob.append(p_eventdata,
167: wf_event_synchronize_pkg.GetSubscriptions(l_ObjectKey,p_isexact, p_ownertag));
168: dbms_lob.append(p_eventdata,
169: wf_event_synchronize_pkg.GetEventGroups(l_ObjectKey, p_ownertag));
170:
171: END IF;
172:
173: dbms_lob.writeappend(p_eventdata, length(g_end_clob), g_end_clob);
175: --return (syncclob);
176:
177: exception
178: when others then
179: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'CREATESYNCCLOB', g_objecttype,
180: p_ObjectKey ,null);
181: raise;
182: end;
183: ------------------------------------------------------------------------------
203:
204: begin
205: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
206: wf_log_pkg.string(wf_log_pkg.level_procedure,
207: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.CREATEFILE.Begin',
208: 'Entered Create File');
209: end if;
210:
211: if (p_isexact) then
215: end if;
216:
217: dbms_lob.createtemporary( l_clob, FALSE, DBMS_LOB.CALL);
218:
219: wf_event_synchronize_pkg.CreateSyncClob(p_ObjectType, p_ObjectKey, l_isExactNum, null, l_clob);
220:
221: if (dbms_lob.getlength(l_clob) = 0) then
222: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
223: wf_log_pkg.string(wf_log_pkg.level_statement,
220:
221: if (dbms_lob.getlength(l_clob) = 0) then
222: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
223: wf_log_pkg.string(wf_log_pkg.level_statement,
224: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.CREATEFILE.Clob_Size',
225: 'l_clob null');
226: end if;
227: end if;
228:
227: end if;
228:
229: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
230: wf_log_pkg.string(wf_log_pkg.level_statement,
231: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.CREATEFILE.Create',
232: 'Calling to CreateClob File');
233: end if;
234:
235: wf_event_synchronize_pkg.CreateClobFile(p_Directory, p_Filename, l_clob);
231: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.CREATEFILE.Create',
232: 'Calling to CreateClob File');
233: end if;
234:
235: wf_event_synchronize_pkg.CreateClobFile(p_Directory, p_Filename, l_clob);
236:
237: exception
238: when others then
239: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'CREATEFILE', p_Directory||
235: wf_event_synchronize_pkg.CreateClobFile(p_Directory, p_Filename, l_clob);
236:
237: exception
238: when others then
239: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'CREATEFILE', p_Directory||
240: '*'||p_Filename,p_ObjectType||'*'||p_ObjectKey ,null);
241: raise;
242: end;
243: ------------------------------------------------------------------------------
266:
267: begin
268: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
269: wf_log_pkg.string(wf_log_pkg.level_procedure,
270: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.CREATECLOBFILE.Begin',
271: 'Entered Create Clob File: '||p_Directory||'-'||p_Filename);
272: end if;
273:
274: l_filehandle := UTL_FILE.FOPEN(p_Directory, p_Filename,'w');
274: l_filehandle := UTL_FILE.FOPEN(p_Directory, p_Filename,'w');
275:
276: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
277: wf_log_pkg.string(wf_log_pkg.level_statement,
278: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.CREATECLOBFILE.file_handle',
279: 'Got file handle');
280: end if;
281:
282: --
324: l_current_position);
325:
326: utl_file.putf(l_filehandle, l_messagedata);
327:
328: wf_log_pkg.string(6, 'WF_EVENT_SYNCHRONIZE_PKG.CREATEFILE',
329: substr(l_messagedata,1,l_splice_size));
330:
331: l_current_position := l_current_position + l_splice_size;
332:
348: utl_file.fclose(l_filehandle);
349:
350: exception
351: when others then
352: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'CREATECLOBFILE', p_Directory||
353: '*'||p_Filename,null);
354: raise;
355: end;
356: ------------------------------------------------------------------------------
405: -- We have the Clob
406: --
407: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
408: wf_log_pkg.string(wf_log_pkg.level_statement,
409: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.UPLOADFILE.file_size',
410: 'Clob Size is:'||l_clobsize);
411: wf_log_pkg.string(wf_log_pkg.level_statement,
412: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.UPLOADFILE.upload',
413: 'About to Upload Clob');
408: wf_log_pkg.string(wf_log_pkg.level_statement,
409: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.UPLOADFILE.file_size',
410: 'Clob Size is:'||l_clobsize);
411: wf_log_pkg.string(wf_log_pkg.level_statement,
412: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.UPLOADFILE.upload',
413: 'About to Upload Clob');
414: end if;
415:
416: wf_event_synchronize_pkg.uploadsyncclob( l_clob);
412: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.UPLOADFILE.upload',
413: 'About to Upload Clob');
414: end if;
415:
416: wf_event_synchronize_pkg.uploadsyncclob( l_clob);
417:
418: exception
419: when utl_file.invalid_path then
420: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
416: wf_event_synchronize_pkg.uploadsyncclob( l_clob);
417:
418: exception
419: when utl_file.invalid_path then
420: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
421: p_Filename,null);
422: wf_core.raise('WFE_INVALID_PATH');
423: when utl_file.invalid_mode then
424: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
420: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
421: p_Filename,null);
422: wf_core.raise('WFE_INVALID_PATH');
423: when utl_file.invalid_mode then
424: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
425: p_Filename,null);
426: wf_core.raise('WFE_INVALID_MODE');
427: when utl_file.invalid_operation then
428: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
424: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
425: p_Filename,null);
426: wf_core.raise('WFE_INVALID_MODE');
427: when utl_file.invalid_operation then
428: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
429: p_Filename,null);
430: wf_core.raise('WFE_INVALID_OPERATION');
431: when utl_file.read_error then
432: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
428: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
429: p_Filename,null);
430: wf_core.raise('WFE_INVALID_OPERATION');
431: when utl_file.read_error then
432: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
433: p_Filename,null);
434: wf_core.raise('WFE_READ_ERROR');
435: when utl_file.internal_error then
436: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
432: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
433: p_Filename,null);
434: wf_core.raise('WFE_READ_ERROR');
435: when utl_file.internal_error then
436: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
437: p_Filename,null);
438: wf_core.raise('WFE_INTERNAL_ERROR');
439: when utl_file.invalid_filehandle then
440: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
436: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
437: p_Filename,null);
438: wf_core.raise('WFE_INTERNAL_ERROR');
439: when utl_file.invalid_filehandle then
440: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
441: p_Filename,null);
442: wf_core.raise('WFE_INVALID_FILEHANDLE');
443: when others then
444: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
440: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
441: p_Filename,null);
442: wf_core.raise('WFE_INVALID_FILEHANDLE');
443: when others then
444: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADFILE', p_Directory,
445: p_Filename,null);
446: raise;
447: end;
448: ------------------------------------------------------------------------------
483: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
484: -- This is for logging only
485: -- BINDVAR_SCAN_IGNORE[3]
486: wf_log_pkg.string(wf_log_pkg.level_statement,
487: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.UPLOADSYNCCLOB.pos',
488: 'Begin Pos '||l_begin_position);
489: end if;
490:
491: EXIT when l_begin_position = 0; -- No More Event Objects left
504: l_begin_position);
505:
506: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
507: wf_log_pkg.string(wf_log_pkg.level_statement,
508: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.UPLOADSYNCCLOB.data',
509: 'Message Data: '||substr(l_messagedata,1,100));
510: end if;
511:
512: --
511:
512: --
513: -- Get Object Type, and then call to UploadObject
514: --
515: l_objecttype := wf_event_synchronize_pkg.GetObjectType(l_messagedata);
516:
517: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
518: wf_log_pkg.string(wf_log_pkg.level_statement,
519: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.UPLOADSYNCCLOB.object',
515: l_objecttype := wf_event_synchronize_pkg.GetObjectType(l_messagedata);
516:
517: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
518: wf_log_pkg.string(wf_log_pkg.level_statement,
519: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.UPLOADSYNCCLOB.object',
520: 'Object Type: '||l_objecttype);
521: end if;
522:
523: wf_event_synchronize_pkg.UploadObject(l_objecttype, l_messagedata,l_error);
519: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.UPLOADSYNCCLOB.object',
520: 'Object Type: '||l_objecttype);
521: end if;
522:
523: wf_event_synchronize_pkg.UploadObject(l_objecttype, l_messagedata,l_error);
524:
525: END LOOP;
526:
527: exception
525: END LOOP;
526:
527: exception
528: when others then
529: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UPLOADSYNCCLOB', l_counter,
530: substr(l_messagedata,1,100)
531: ,null);
532: raise;
533: end;
569: return (returnclob);
570:
571: exception
572: when others then
573: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'GetSystems', p_key,null,
574: 'ERROR'); raise;
575: end;
576: ------------------------------------------------------------------------------
577: /*
611: END IF;
612:
613: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
614: wf_log_pkg.string(wf_log_pkg.level_procedure,
615: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.GETAGENTS.Begin',
616: 'Entered GetAgents');
617: end if;
618:
619: dbms_lob.createtemporary(returnclob, FALSE, DBMS_LOB.CALL);
627:
628: if (p_isexact = false) then
629: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
630: wf_log_pkg.string(wf_log_pkg.level_statement,
631: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.GETAGENTS.set_pound',
632: 'Substitute with pounds.');
633: end if;
634:
635: l_clob_len := dbms_lob.getlength(l_clob);
660:
661:
662: exception
663: when others then
664: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'GetAgents', p_key,null,
665: 'ERROR'); raise;
666: end;
667: ------------------------------------------------------------------------------
668: /*
713: return (returnclob);
714:
715: exception
716: when others then
717: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'GetAgentGroups', p_key,null,
718: 'ERROR'); raise;
719: end;
720:
721: ------------------------------------------------------------------------------
778: return (returnclob);
779:
780: exception
781: when others then
782: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'GetEvents', p_key,null,
783: 'ERROR'); raise;
784: end;
785: ------------------------------------------------------------------------------
786: /*
847: return (returnclob);
848:
849: exception
850: when others then
851: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'GetEventGroups', p_key,null,
852: 'ERROR'); raise;
853: end;
854: ------------------------------------------------------------------------------
855: /*
910: return (returnclob);
911:
912: exception
913: when others then
914: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'GetGroups', p_key,null,
915: 'ERROR'); raise;
916: end;
917: ------------------------------------------------------------------------------
918: function GETEVENTGROUPBYGROUP (
955: return (returnclob);
956:
957: exception
958: when others then
959: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'GetEventGroupByGroup', p_key,null,
960: 'ERROR'); raise;
961: end;
962:
963: ------------------------------------------------------------------------------
1008: END IF;
1009:
1010: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
1011: wf_log_pkg.string(wf_log_pkg.level_procedure,
1012: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.GETSUBSCRIPTIONS.Begin',
1013: 'Entered GetSubscriptions');
1014: end if;
1015:
1016: dbms_lob.createtemporary(returnclob, FALSE, DBMS_LOB.CALL);
1024:
1025: if (p_isexact = false) then
1026: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1027: wf_log_pkg.string(wf_log_pkg.level_statement,
1028: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.GETSUBSCRIPTIONS.set_pound',
1029: 'Substitute with pounds.');
1030: end if;
1031:
1032: l_clob_len := dbms_lob.getlength(l_clob);
1129: return (returnclob);
1130:
1131: exception
1132: when others then
1133: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'GetSubscriptions', p_key,null,
1134: 'ERROR'); raise;
1135: end;
1136: ------------------------------------------------------------------------------
1137: /*
1164: return (l_return);
1165:
1166: exception
1167: when others then
1168: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'GetObjectType',
1169: substr(p_messagedata,1,100),null,
1170: 'ERROR'); raise;
1171: end;
1172: ------------------------------------------------------------------------------
1198: END IF;
1199:
1200: /*exception
1201: when others then
1202: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UploadObject',
1203: substr(p_messagedata,1,100),
1204: p_objecttype,
1205: 'ERROR'); raise;*/
1206: end;
1228: end if;
1229: end if;
1230: exception
1231: when others then
1232: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'UpdateGUID');
1233: raise;
1234: end;
1235: ------------------------------------------------------------------------------
1236: /*
1272: end if;
1273: return (retStr);
1274: exception
1275: when others then
1276: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'ReplaceContent');
1277: raise;
1278: end;
1279: ------------------------------------------------------------------------------
1280: /*
1308: end if;
1309: return (retStr);
1310: exception
1311: when others then
1312: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'SetGUID');
1313: raise;
1314: end;
1315: ------------------------------------------------------------------------------
1316: /*
1337: end if;
1338: return (retStr);
1339: exception
1340: when others then
1341: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'SetSYSTEMGUID');
1342: raise;
1343: end;
1344: ------------------------------------------------------------------------------
1345: /*
1368: return upper(substr(l_sid,1,30));
1369:
1370: exception
1371: when others then
1372: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'GetSID');
1373: raise;
1374: end;
1375: ------------------------------------------------------------------------------
1376: /*
1407:
1408: return (g_qowner);
1409: exception
1410: when others then
1411: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'GetQOwner');
1412: raise;
1413: end;
1414: ------------------------------------------------------------------------------
1415: /*
1455: return (retStr);
1456:
1457: exception
1458: when others then
1459: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'SetSID');
1460: raise;
1461: end;
1462: ------------------------------------------------------------------------------
1463: /*
1545: return (retStr);
1546:
1547: exception
1548: when others then
1549: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'SetAgent');
1550: raise;
1551: end;
1552:
1553: ------------------------------------------------------------------------------
1581:
1582: begin
1583: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
1584: wf_log_pkg.string(wf_log_pkg.level_procedure,
1585: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.SETPOUND.Begin',
1586: 'Entered SetPound.');
1587: end if;
1588:
1589: if dataStr is not null then
1618: end if;
1619: return (retStr);
1620: exception
1621: when others then
1622: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'SetPound');
1623: raise;
1624: end;
1625:
1626: ------------------------------------------------------------------------------
1647:
1648: begin
1649: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
1650: wf_log_pkg.string(wf_log_pkg.level_procedure,
1651: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.SETNULL.Begin',
1652: 'Entered SetNull.');
1653: end if;
1654:
1655: if dataStr is not null then
1673: end if;
1674: return (retStr);
1675: exception
1676: when others then
1677: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'SetNull');
1678: raise;
1679: end;
1680:
1681: ------------------------------------------------------------------------------
1688: begin
1689:
1690: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
1691: wf_log_pkg.string(wf_log_pkg.level_procedure,
1692: 'wf.plsql.WF_EVENT_SYNCHRONIZE_PKG.CREATEEMPTYCLOB.Begin',
1693: 'Entered Create Empty Clob');
1694: end if;
1695:
1696: dbms_lob.createtemporary(p_outclob, FALSE, DBMS_LOB.CALL);
1695:
1696: dbms_lob.createtemporary(p_outclob, FALSE, DBMS_LOB.CALL);
1697: exception
1698: when others then
1699: wf_core.context('WF_EVENT_SYNCHRONIZE_PKG', 'CREATEEMPTYCLOB');
1700: raise;
1701: end;
1702: ------------------------------------------------------------------------------
1703: /*
1756: end if;
1757: return (retStr);
1758: exception
1759: when others then
1760: wf_core.context('Wf_Event_Synchronize_Pkg', 'GetAgent');
1761: raise;
1762: end;
1763: --------------------------------------------------------------------------------------------
1764: /*
1833: P_ERROR_MSG out nocopy varchar2
1834: )
1835: is
1836: begin
1837: Wf_Event_Synchronize_Pkg.CreateSyncClob(P_OBJECTTYPE, P_OBJECTKEY, P_ISEXACTNUM,
1838: P_OWNERTAG, P_EVENTDATA);
1839: p_error_code := null;
1840: p_error_msg := null;
1841: exception
1848: end if;
1849: end CREATESYNCCLOB2;
1850: --------------------------------------------------------------------------------------------
1851:
1852: end WF_EVENT_SYNCHRONIZE_PKG;