[Home] [Help]
35: /**
36: Move the Values from Source to the Target
37: **/
38:
39: for i in ecx_utils.g_target_levels(i_target_level).file_start_pos..ecx_utils.g_target_levels(i_target_level).file_end_pos
40: loop
41: /** Do a Clean up for the Target **/
42: ecx_utils.g_target(i).value := null;
43:
38:
39: for i in ecx_utils.g_target_levels(i_target_level).file_start_pos..ecx_utils.g_target_levels(i_target_level).file_end_pos
40: loop
41: /** Do a Clean up for the Target **/
42: ecx_utils.g_target(i).value := null;
43:
44: /** Change required for Clob Support -- 2263729 ***/
45: ecx_utils.g_target(i).clob_value := null;
46: ecx_utils.g_target(i).clob_length := null;
41: /** Do a Clean up for the Target **/
42: ecx_utils.g_target(i).value := null;
43:
44: /** Change required for Clob Support -- 2263729 ***/
45: ecx_utils.g_target(i).clob_value := null;
46: ecx_utils.g_target(i).clob_length := null;
47: ecx_utils.g_target(i).is_clob := null;
48:
49: if ecx_utils.g_target(i).map_attribute_id is not null
42: ecx_utils.g_target(i).value := null;
43:
44: /** Change required for Clob Support -- 2263729 ***/
45: ecx_utils.g_target(i).clob_value := null;
46: ecx_utils.g_target(i).clob_length := null;
47: ecx_utils.g_target(i).is_clob := null;
48:
49: if ecx_utils.g_target(i).map_attribute_id is not null
50: then
43:
44: /** Change required for Clob Support -- 2263729 ***/
45: ecx_utils.g_target(i).clob_value := null;
46: ecx_utils.g_target(i).clob_length := null;
47: ecx_utils.g_target(i).is_clob := null;
48:
49: if ecx_utils.g_target(i).map_attribute_id is not null
50: then
51: /** Change required for Clob Support -- 2263729 **/
45: ecx_utils.g_target(i).clob_value := null;
46: ecx_utils.g_target(i).clob_length := null;
47: ecx_utils.g_target(i).is_clob := null;
48:
49: if ecx_utils.g_target(i).map_attribute_id is not null
50: then
51: /** Change required for Clob Support -- 2263729 **/
52: if (ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).data_type = 112) Then
53: ecx_utils.g_target(i).clob_length := ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).clob_length;
48:
49: if ecx_utils.g_target(i).map_attribute_id is not null
50: then
51: /** Change required for Clob Support -- 2263729 **/
52: if (ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).data_type = 112) Then
53: ecx_utils.g_target(i).clob_length := ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).clob_length;
54: ecx_utils.g_target(i).is_clob := ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).is_clob;
55:
56: if (ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).clob_length > ecx_utils.G_CLOB_VARCHAR_LEN)
49: if ecx_utils.g_target(i).map_attribute_id is not null
50: then
51: /** Change required for Clob Support -- 2263729 **/
52: if (ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).data_type = 112) Then
53: ecx_utils.g_target(i).clob_length := ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).clob_length;
54: ecx_utils.g_target(i).is_clob := ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).is_clob;
55:
56: if (ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).clob_length > ecx_utils.G_CLOB_VARCHAR_LEN)
57: Then
50: then
51: /** Change required for Clob Support -- 2263729 **/
52: if (ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).data_type = 112) Then
53: ecx_utils.g_target(i).clob_length := ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).clob_length;
54: ecx_utils.g_target(i).is_clob := ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).is_clob;
55:
56: if (ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).clob_length > ecx_utils.G_CLOB_VARCHAR_LEN)
57: Then
58:
52: if (ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).data_type = 112) Then
53: ecx_utils.g_target(i).clob_length := ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).clob_length;
54: ecx_utils.g_target(i).is_clob := ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).is_clob;
55:
56: if (ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).clob_length > ecx_utils.G_CLOB_VARCHAR_LEN)
57: Then
58:
59: ecx_utils.g_target(i).clob_value := ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).clob_value;
60: else
55:
56: if (ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).clob_length > ecx_utils.G_CLOB_VARCHAR_LEN)
57: Then
58:
59: ecx_utils.g_target(i).clob_value := ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).clob_value;
60: else
61: ecx_utils.g_target(i).value :=
62: ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).value;
63: end if;
57: Then
58:
59: ecx_utils.g_target(i).clob_value := ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).clob_value;
60: else
61: ecx_utils.g_target(i).value :=
62: ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).value;
63: end if;
64: else
65: ecx_utils.g_target(i).value :=
58:
59: ecx_utils.g_target(i).clob_value := ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).clob_value;
60: else
61: ecx_utils.g_target(i).value :=
62: ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).value;
63: end if;
64: else
65: ecx_utils.g_target(i).value :=
66: ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).value;
61: ecx_utils.g_target(i).value :=
62: ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).value;
63: end if;
64: else
65: ecx_utils.g_target(i).value :=
66: ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).value;
67: end if;
68: end if;
69:
62: ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).value;
63: end if;
64: else
65: ecx_utils.g_target(i).value :=
66: ecx_utils.g_source(ecx_utils.g_target(i).map_attribute_id).value;
67: end if;
68: end if;
69:
70: /** If the value is null then assign the target default value
67: end if;
68: end if;
69:
70: /** If the value is null then assign the target default value
71: If ecx_utils.g_target(i).value is null
72: then
73: ecx_utils.g_target(i).value := ecx_utils.g_target(i).default_value;
74: End if;
75: if(l_statementEnabled) then
69:
70: /** If the value is null then assign the target default value
71: If ecx_utils.g_target(i).value is null
72: then
73: ecx_utils.g_target(i).value := ecx_utils.g_target(i).default_value;
74: End if;
75: if(l_statementEnabled) then
76: ecx_debug.log(l_statement, ecx_utils.g_target(i).attribute_name,ecx_utils.g_target(i).value,
77: i_method_name);
72: then
73: ecx_utils.g_target(i).value := ecx_utils.g_target(i).default_value;
74: End if;
75: if(l_statementEnabled) then
76: ecx_debug.log(l_statement, ecx_utils.g_target(i).attribute_name,ecx_utils.g_target(i).value,
77: i_method_name);
78: end if;
79: End if;
80: **/
78: end if;
79: End if;
80: **/
81:
82: If ecx_utils.g_target(i).clob_value is not null Then
83: if(l_statementEnabled) then
84: ecx_debug.log(l_statement,i||'=>'||ecx_utils.g_target(i).parent_attribute_id||'=>'||
85: ecx_utils.g_target(i).attribute_type||'=>'||
86: ecx_utils.g_target(i).attribute_name,ecx_utils.g_target(i).clob_value,
80: **/
81:
82: If ecx_utils.g_target(i).clob_value is not null Then
83: if(l_statementEnabled) then
84: ecx_debug.log(l_statement,i||'=>'||ecx_utils.g_target(i).parent_attribute_id||'=>'||
85: ecx_utils.g_target(i).attribute_type||'=>'||
86: ecx_utils.g_target(i).attribute_name,ecx_utils.g_target(i).clob_value,
87: i_method_name);
88: end if;
81:
82: If ecx_utils.g_target(i).clob_value is not null Then
83: if(l_statementEnabled) then
84: ecx_debug.log(l_statement,i||'=>'||ecx_utils.g_target(i).parent_attribute_id||'=>'||
85: ecx_utils.g_target(i).attribute_type||'=>'||
86: ecx_utils.g_target(i).attribute_name,ecx_utils.g_target(i).clob_value,
87: i_method_name);
88: end if;
89: else
82: If ecx_utils.g_target(i).clob_value is not null Then
83: if(l_statementEnabled) then
84: ecx_debug.log(l_statement,i||'=>'||ecx_utils.g_target(i).parent_attribute_id||'=>'||
85: ecx_utils.g_target(i).attribute_type||'=>'||
86: ecx_utils.g_target(i).attribute_name,ecx_utils.g_target(i).clob_value,
87: i_method_name);
88: end if;
89: else
90: -- if clob_value is null this means that it is varchar2
88: end if;
89: else
90: -- if clob_value is null this means that it is varchar2
91: /** If the value is null then assign the target default value **/
92: If ecx_utils.g_target(i).value is null
93: then
94: ecx_utils.g_target(i).value := ecx_utils.g_target(i).default_value;
95: End if;
96: if(l_statementEnabled) then
90: -- if clob_value is null this means that it is varchar2
91: /** If the value is null then assign the target default value **/
92: If ecx_utils.g_target(i).value is null
93: then
94: ecx_utils.g_target(i).value := ecx_utils.g_target(i).default_value;
95: End if;
96: if(l_statementEnabled) then
97: ecx_debug.log(l_statement,i||'=>'||ecx_utils.g_target(i).parent_attribute_id||'=>'||
98: ecx_utils.g_target(i).attribute_type||'=>'||
93: then
94: ecx_utils.g_target(i).value := ecx_utils.g_target(i).default_value;
95: End if;
96: if(l_statementEnabled) then
97: ecx_debug.log(l_statement,i||'=>'||ecx_utils.g_target(i).parent_attribute_id||'=>'||
98: ecx_utils.g_target(i).attribute_type||'=>'||
99: ecx_utils.g_target(i).attribute_name,ecx_utils.g_target(i).value,
100: i_method_name);
101: end if;
94: ecx_utils.g_target(i).value := ecx_utils.g_target(i).default_value;
95: End if;
96: if(l_statementEnabled) then
97: ecx_debug.log(l_statement,i||'=>'||ecx_utils.g_target(i).parent_attribute_id||'=>'||
98: ecx_utils.g_target(i).attribute_type||'=>'||
99: ecx_utils.g_target(i).attribute_name,ecx_utils.g_target(i).value,
100: i_method_name);
101: end if;
102: End If;
95: End if;
96: if(l_statementEnabled) then
97: ecx_debug.log(l_statement,i||'=>'||ecx_utils.g_target(i).parent_attribute_id||'=>'||
98: ecx_utils.g_target(i).attribute_type||'=>'||
99: ecx_utils.g_target(i).attribute_name,ecx_utils.g_target(i).value,
100: i_method_name);
101: end if;
102: End If;
103: end loop;
118: end if;
119: if (l_procedureEnabled) then
120: ecx_debug.pop(i_method_name);
121: end if;
122: raise ecx_utils.PROGRAM_EXIT;
123: end move_from_source_to_target;
124:
125: procedure processTarget
126: (
161:
162: ecx_print_local.print_new_level
163: (
164: i_target,
165: ecx_utils.g_target_levels(i_target).dtd_node_index
166: );
167:
168: if (i_target <> 0)
169: then
174: ecx_debug.pop(i_method_name);
175: end if;
176:
177: exception
178: when ecx_utils.program_exit then
179: ecx_debug.pop('ECX_OUTBOUND.processTarget');
180: raise ecx_utils.program_exit;
181: when others then
182: if(l_unexpectedEnabled) then
176:
177: exception
178: when ecx_utils.program_exit then
179: ecx_debug.pop('ECX_OUTBOUND.processTarget');
180: raise ecx_utils.program_exit;
181: when others then
182: if(l_unexpectedEnabled) then
183: ecx_debug.log(l_unexpected,'ECX','ECX_PROGRAM_ERROR',i_method_name,'PROGRESS_LEVEL',
184: 'ECX_OUTBOUND.PROCESSTARGET');
191: end if;
192: if (l_procedureEnabled) then
193: ecx_debug.pop(i_method_name);
194: end if;
195: raise ecx_utils.PROGRAM_EXIT;
196: end processTarget;
197:
198: procedure process_data
199: (
233: if i_stage = 10
234: then
235:
236: /** Should clean up the Current Source and the down levels first**/
237: for k in i..ecx_utils.g_source_levels.last
238: loop
239: for j in ecx_utils.g_source_levels(k).file_start_pos..ecx_utils.g_source_levels(k).file_end_pos
240: loop
241: if ecx_utils.g_source(j).default_value is null
235:
236: /** Should clean up the Current Source and the down levels first**/
237: for k in i..ecx_utils.g_source_levels.last
238: loop
239: for j in ecx_utils.g_source_levels(k).file_start_pos..ecx_utils.g_source_levels(k).file_end_pos
240: loop
241: if ecx_utils.g_source(j).default_value is null
242: then
243: ecx_utils.g_source(j).value := null;
237: for k in i..ecx_utils.g_source_levels.last
238: loop
239: for j in ecx_utils.g_source_levels(k).file_start_pos..ecx_utils.g_source_levels(k).file_end_pos
240: loop
241: if ecx_utils.g_source(j).default_value is null
242: then
243: ecx_utils.g_source(j).value := null;
244: ecx_utils.g_source(j).clob_value := null;
245: ecx_utils.g_source(j).is_clob := null;
239: for j in ecx_utils.g_source_levels(k).file_start_pos..ecx_utils.g_source_levels(k).file_end_pos
240: loop
241: if ecx_utils.g_source(j).default_value is null
242: then
243: ecx_utils.g_source(j).value := null;
244: ecx_utils.g_source(j).clob_value := null;
245: ecx_utils.g_source(j).is_clob := null;
246: ecx_utils.g_source(j).clob_length := null;
247: else
240: loop
241: if ecx_utils.g_source(j).default_value is null
242: then
243: ecx_utils.g_source(j).value := null;
244: ecx_utils.g_source(j).clob_value := null;
245: ecx_utils.g_source(j).is_clob := null;
246: ecx_utils.g_source(j).clob_length := null;
247: else
248: ecx_utils.g_source(j).value := ecx_utils.g_source(j).default_value;
241: if ecx_utils.g_source(j).default_value is null
242: then
243: ecx_utils.g_source(j).value := null;
244: ecx_utils.g_source(j).clob_value := null;
245: ecx_utils.g_source(j).is_clob := null;
246: ecx_utils.g_source(j).clob_length := null;
247: else
248: ecx_utils.g_source(j).value := ecx_utils.g_source(j).default_value;
249: end if;
242: then
243: ecx_utils.g_source(j).value := null;
244: ecx_utils.g_source(j).clob_value := null;
245: ecx_utils.g_source(j).is_clob := null;
246: ecx_utils.g_source(j).clob_length := null;
247: else
248: ecx_utils.g_source(j).value := ecx_utils.g_source(j).default_value;
249: end if;
250: if(l_statementEnabled) then
244: ecx_utils.g_source(j).clob_value := null;
245: ecx_utils.g_source(j).is_clob := null;
246: ecx_utils.g_source(j).clob_length := null;
247: else
248: ecx_utils.g_source(j).value := ecx_utils.g_source(j).default_value;
249: end if;
250: if(l_statementEnabled) then
251: ecx_debug.log(l_statement,'Source '||ecx_utils.g_source(j).attribute_name,
252: ecx_utils.g_source(j).value,i_method_name);
247: else
248: ecx_utils.g_source(j).value := ecx_utils.g_source(j).default_value;
249: end if;
250: if(l_statementEnabled) then
251: ecx_debug.log(l_statement,'Source '||ecx_utils.g_source(j).attribute_name,
252: ecx_utils.g_source(j).value,i_method_name);
253: end if;
254: end loop;
255: end loop;
248: ecx_utils.g_source(j).value := ecx_utils.g_source(j).default_value;
249: end if;
250: if(l_statementEnabled) then
251: ecx_debug.log(l_statement,'Source '||ecx_utils.g_source(j).attribute_name,
252: ecx_utils.g_source(j).value,i_method_name);
253: end if;
254: end loop;
255: end loop;
256:
275: p_return_status => i_return_status,
276: p_msg_count => i_msg_count,
277: p_msg_data => i_msg_data,
278: p_level => i,
279: p_tbl => ecx_utils.g_source,
280: p_tp_id => ecx_utils.g_rec_tp_id,
281: p_standard_id => ecx_utils.g_standard_id
282: );
283:
276: p_msg_count => i_msg_count,
277: p_msg_data => i_msg_data,
278: p_level => i,
279: p_tbl => ecx_utils.g_source,
280: p_tp_id => ecx_utils.g_rec_tp_id,
281: p_standard_id => ecx_utils.g_standard_id
282: );
283:
284: --Check the Status of the Code Conversion API and take appropriate action.
277: p_msg_data => i_msg_data,
278: p_level => i,
279: p_tbl => ecx_utils.g_source,
280: p_tp_id => ecx_utils.g_rec_tp_id,
281: p_standard_id => ecx_utils.g_standard_id
282: );
283:
284: --Check the Status of the Code Conversion API and take appropriate action.
285: IF (
292: ecx_debug.log(l_statement,'ECX','ECX_PROGRAM_ERROR',i_method_name,'PROGRESS_LEVEL',
293: 'ECX_OUTBOUND.PROCESS_DATA');
294: ecx_debug.log(l_statement,'ECX','EC_CODE_CONVERSION_FAILED',i_method_name,'LEVEL',i);
295: end if;
296: ecx_utils.i_ret_code := 2;
297: RAISE ecx_utils.PROGRAM_EXIT;
298: END IF;
299:
300: /** Execute the In-processing for the Source **/
293: 'ECX_OUTBOUND.PROCESS_DATA');
294: ecx_debug.log(l_statement,'ECX','EC_CODE_CONVERSION_FAILED',i_method_name,'LEVEL',i);
295: end if;
296: ecx_utils.i_ret_code := 2;
297: RAISE ecx_utils.PROGRAM_EXIT;
298: END IF;
299:
300: /** Execute the In-processing for the Source **/
301: ecx_actions.execute_stage_data (i_stage, i, 'S');
299:
300: /** Execute the In-processing for the Source **/
301: ecx_actions.execute_stage_data (i_stage, i, 'S');
302:
303: for j in ecx_utils.g_source_levels(i).first_target_level .. ecx_utils.g_source_levels(i).last_target_level
304: loop
305: /** Initialize the Target **/
306: for k in ecx_utils.g_target_levels(j).file_start_pos..ecx_utils.g_target_levels(j).file_end_pos
307: loop
302:
303: for j in ecx_utils.g_source_levels(i).first_target_level .. ecx_utils.g_source_levels(i).last_target_level
304: loop
305: /** Initialize the Target **/
306: for k in ecx_utils.g_target_levels(j).file_start_pos..ecx_utils.g_target_levels(j).file_end_pos
307: loop
308: if ecx_utils.g_target(k).default_value is null
309: then
310: ecx_utils.g_target(k).value := null;
304: loop
305: /** Initialize the Target **/
306: for k in ecx_utils.g_target_levels(j).file_start_pos..ecx_utils.g_target_levels(j).file_end_pos
307: loop
308: if ecx_utils.g_target(k).default_value is null
309: then
310: ecx_utils.g_target(k).value := null;
311: /** Change required for Clob Support -- 2263729 ***/
312: ecx_utils.g_target(k).clob_value := null;
306: for k in ecx_utils.g_target_levels(j).file_start_pos..ecx_utils.g_target_levels(j).file_end_pos
307: loop
308: if ecx_utils.g_target(k).default_value is null
309: then
310: ecx_utils.g_target(k).value := null;
311: /** Change required for Clob Support -- 2263729 ***/
312: ecx_utils.g_target(k).clob_value := null;
313: ecx_utils.g_target(k).clob_length := null;
314: ecx_utils.g_target(k).is_clob := null;
308: if ecx_utils.g_target(k).default_value is null
309: then
310: ecx_utils.g_target(k).value := null;
311: /** Change required for Clob Support -- 2263729 ***/
312: ecx_utils.g_target(k).clob_value := null;
313: ecx_utils.g_target(k).clob_length := null;
314: ecx_utils.g_target(k).is_clob := null;
315: else
316: ecx_utils.g_target(k).value := ecx_utils.g_target(k).default_value;
309: then
310: ecx_utils.g_target(k).value := null;
311: /** Change required for Clob Support -- 2263729 ***/
312: ecx_utils.g_target(k).clob_value := null;
313: ecx_utils.g_target(k).clob_length := null;
314: ecx_utils.g_target(k).is_clob := null;
315: else
316: ecx_utils.g_target(k).value := ecx_utils.g_target(k).default_value;
317: end if;
310: ecx_utils.g_target(k).value := null;
311: /** Change required for Clob Support -- 2263729 ***/
312: ecx_utils.g_target(k).clob_value := null;
313: ecx_utils.g_target(k).clob_length := null;
314: ecx_utils.g_target(k).is_clob := null;
315: else
316: ecx_utils.g_target(k).value := ecx_utils.g_target(k).default_value;
317: end if;
318: if(l_statementEnabled) then
312: ecx_utils.g_target(k).clob_value := null;
313: ecx_utils.g_target(k).clob_length := null;
314: ecx_utils.g_target(k).is_clob := null;
315: else
316: ecx_utils.g_target(k).value := ecx_utils.g_target(k).default_value;
317: end if;
318: if(l_statementEnabled) then
319: ecx_debug.log(l_statement,'target '||ecx_utils.g_target(k).attribute_name,
320: ecx_utils.g_target(k).value,i_method_name);
315: else
316: ecx_utils.g_target(k).value := ecx_utils.g_target(k).default_value;
317: end if;
318: if(l_statementEnabled) then
319: ecx_debug.log(l_statement,'target '||ecx_utils.g_target(k).attribute_name,
320: ecx_utils.g_target(k).value,i_method_name);
321: end if;
322: end loop;
323: end loop;
316: ecx_utils.g_target(k).value := ecx_utils.g_target(k).default_value;
317: end if;
318: if(l_statementEnabled) then
319: ecx_debug.log(l_statement,'target '||ecx_utils.g_target(k).attribute_name,
320: ecx_utils.g_target(k).value,i_method_name);
321: end if;
322: end loop;
323: end loop;
324:
327: ecx_debug.log(l_statement,'Previous Level',i,i_method_name);
328: ecx_debug.log(l_statement,'Current Level',i_next,i_method_name);
329: end if;
330:
331: if ( ecx_utils.g_source_levels(i).last_source_level -
332: ecx_utils.g_source_levels(i).first_source_level > 0 )
333: then
334: if i_next > i
335: then
328: ecx_debug.log(l_statement,'Current Level',i_next,i_method_name);
329: end if;
330:
331: if ( ecx_utils.g_source_levels(i).last_source_level -
332: ecx_utils.g_source_levels(i).first_source_level > 0 )
333: then
334: if i_next > i
335: then
336: if ( i_next >= ecx_utils.g_source_levels(i).first_source_level )
332: ecx_utils.g_source_levels(i).first_source_level > 0 )
333: then
334: if i_next > i
335: then
336: if ( i_next >= ecx_utils.g_source_levels(i).first_source_level )
337: and
338: ( i_next <= ecx_utils.g_source_levels(i).last_source_level )
339: then
340: if(l_statementEnabled) then
334: if i_next > i
335: then
336: if ( i_next >= ecx_utils.g_source_levels(i).first_source_level )
337: and
338: ( i_next <= ecx_utils.g_source_levels(i).last_source_level )
339: then
340: if(l_statementEnabled) then
341: ecx_debug.log(l_statement,'Skipping Source',i,i_method_name);
342: end if;
340: if(l_statementEnabled) then
341: ecx_debug.log(l_statement,'Skipping Source',i,i_method_name);
342: end if;
343: else
344: processTarget(ecx_utils.g_source_levels(i).first_target_level);
345: end if;
346: end if;
347:
348: if i_next <= i
346: end if;
347:
348: if i_next <= i
349: then
350: processTarget(ecx_utils.g_source_levels(i).first_target_level);
351: end if;
352: else
353: /** Else Expansion or 1-1 mapping **/
354: for j in ecx_utils.g_source_levels(i).first_target_level .. ecx_utils.g_source_levels(i).last_target_level
350: processTarget(ecx_utils.g_source_levels(i).first_target_level);
351: end if;
352: else
353: /** Else Expansion or 1-1 mapping **/
354: for j in ecx_utils.g_source_levels(i).first_target_level .. ecx_utils.g_source_levels(i).last_target_level
355: loop
356: processTarget(j);
357: end loop;
358: end if;
373: discontinuous elements will be printed before it gets overwritten.
374: */
375:
376: -- for all the target levels mapped to this source level print the discont elements
377: j := ecx_utils.g_source_levels(i).last_target_level;
378: if (l_statementEnabled) then
379: ecx_debug.log(l_statement,'last target level', ecx_utils.g_source_levels(i).last_target_level,i_method_name);
380: ecx_debug.log(l_statement, 'first target level', ecx_utils.g_source_levels(i).first_target_level,
381: i_method_name);
375:
376: -- for all the target levels mapped to this source level print the discont elements
377: j := ecx_utils.g_source_levels(i).last_target_level;
378: if (l_statementEnabled) then
379: ecx_debug.log(l_statement,'last target level', ecx_utils.g_source_levels(i).last_target_level,i_method_name);
380: ecx_debug.log(l_statement, 'first target level', ecx_utils.g_source_levels(i).first_target_level,
381: i_method_name);
382: end if;
383: while (j >= ecx_utils.g_source_levels(i).first_target_level)
376: -- for all the target levels mapped to this source level print the discont elements
377: j := ecx_utils.g_source_levels(i).last_target_level;
378: if (l_statementEnabled) then
379: ecx_debug.log(l_statement,'last target level', ecx_utils.g_source_levels(i).last_target_level,i_method_name);
380: ecx_debug.log(l_statement, 'first target level', ecx_utils.g_source_levels(i).first_target_level,
381: i_method_name);
382: end if;
383: while (j >= ecx_utils.g_source_levels(i).first_target_level)
384: loop
379: ecx_debug.log(l_statement,'last target level', ecx_utils.g_source_levels(i).last_target_level,i_method_name);
380: ecx_debug.log(l_statement, 'first target level', ecx_utils.g_source_levels(i).first_target_level,
381: i_method_name);
382: end if;
383: while (j >= ecx_utils.g_source_levels(i).first_target_level)
384: loop
385: ecx_print_local.print_discont_elements(ecx_print_local.last_printed + 1,
386: ecx_utils.g_target_levels(j).file_end_pos,
387: ecx_utils.g_target(ecx_utils.g_target_levels(j).file_start_pos).attribute_id,
382: end if;
383: while (j >= ecx_utils.g_source_levels(i).first_target_level)
384: loop
385: ecx_print_local.print_discont_elements(ecx_print_local.last_printed + 1,
386: ecx_utils.g_target_levels(j).file_end_pos,
387: ecx_utils.g_target(ecx_utils.g_target_levels(j).file_start_pos).attribute_id,
388: j);
389: j := j - 1;
390: end loop;
383: while (j >= ecx_utils.g_source_levels(i).first_target_level)
384: loop
385: ecx_print_local.print_discont_elements(ecx_print_local.last_printed + 1,
386: ecx_utils.g_target_levels(j).file_end_pos,
387: ecx_utils.g_target(ecx_utils.g_target_levels(j).file_start_pos).attribute_id,
388: j);
389: j := j - 1;
390: end loop;
391: end if;
393: if (l_procedureEnabled) then
394: ecx_debug.pop(i_method_name);
395: end if;
396: exception
397: when ecx_utils.program_exit then
398: if (l_procedureEnabled) then
399: ecx_debug.pop(i_method_name);
400: end if;
401: raise ecx_utils.program_exit;
397: when ecx_utils.program_exit then
398: if (l_procedureEnabled) then
399: ecx_debug.pop(i_method_name);
400: end if;
401: raise ecx_utils.program_exit;
402: when others then
403: ecx_debug.setErrorInfo(2, 30, SQLERRM || ' - ECX_OUTBOUND.PROCESS_DATA');
404: if(l_unexpectedEnabled) then
405: ecx_debug.log(l_unexpected, 'ECX', SQLERRM || ' - ECX_OUTBOUND.PROCESS_DATA',i_method_name);
406: end if;
407: if (l_procedureEnabled) then
408: ecx_debug.pop(i_method_name);
409: end if;
410: raise ecx_utils.program_exit;
411: end process_data;
412:
413:
414: procedure print_stack
430: ecx_debug.setErrorInfo(2, 30, SQLERRM || ' - ECX_OUTBOUND.PRINT_STACK');
431: if(l_unexpectedEnabled) then
432: ecx_debug.log(l_unexpected,'ECX', SQLERRM || ' - ECX_OUTBOUND.PRINT_STACK',i_method_name);
433: end if;
434: raise ecx_utils.program_exit;
435: end print_stack;
436:
437: procedure pop
438: (
472: if (l_procedureEnabled) then
473: ecx_debug.pop(i_method_name );
474: end if;
475: exception
476: when ecx_utils.program_exit then
477: if (l_procedureEnabled) then
478: ecx_debug.pop(i_method_name);
479: end if;
480: raise ecx_utils.program_exit;
476: when ecx_utils.program_exit then
477: if (l_procedureEnabled) then
478: ecx_debug.pop(i_method_name);
479: end if;
480: raise ecx_utils.program_exit;
481: when others then
482: ecx_debug.setErrorInfo(2, 30, SQLERRM || ' - ECX_OUTBOUND.POP');
483: if(l_unexpectedEnabled) then
484: ecx_debug.log(l_unexpected, 'ECX', SQLERRM || ' - ECX_OUTBOUND.POP',i_method_name);
485: end if;
486: if (l_procedureEnabled) then
487: ecx_debug.pop(i_method_name);
488: end if;
489: raise ecx_utils.program_exit;
490: end pop;
491:
492: procedure push
493: (
584: if (l_procedureEnabled) then
585: ecx_debug.pop(i_method_name);
586: end if;
587: exception
588: when ecx_utils.program_exit then
589: if (l_procedureEnabled) then
590: ecx_debug.pop(i_method_name);
591: end if;
592: raise ecx_utils.program_exit;
588: when ecx_utils.program_exit then
589: if (l_procedureEnabled) then
590: ecx_debug.pop(i_method_name);
591: end if;
592: raise ecx_utils.program_exit;
593: when others then
594: ecx_debug.setErrorInfo(2, 30, SQLERRM || ' - ECX_OUTBOUND.PUSH');
595: if(l_unexpectedEnabled) then
596: ecx_debug.log(l_unexpected,'ECX', SQLERRM || ' - ECX_OUTBOUND.PUSH',i_method_name);
597: end if;
598: if (l_procedureEnabled) then
599: ecx_debug.pop(i_method_name);
600: end if;
601: raise ecx_utils.program_exit;
602: end push;
603:
604:
605: procedure popall
632: ecx_debug.pop(i_method_name );
633: end if;
634:
635: exception
636: when ecx_utils.program_exit then
637: if (l_procedureEnabled) then
638: ecx_debug.pop(i_method_name );
639: end if;
640: raise ecx_utils.program_exit;
636: when ecx_utils.program_exit then
637: if (l_procedureEnabled) then
638: ecx_debug.pop(i_method_name );
639: end if;
640: raise ecx_utils.program_exit;
641: when others then
642: ecx_debug.setErrorInfo(2, 30, SQLERRM || ' - ECX_OUTBOUND.POPALL');
643: if(l_unexpectedEnabled) then
644: ecx_debug.log(l_unexpected,'ECX', SQLERRM || ' - ECX_OUTBOUND.POPALL',i_method_name);
645: end if;
646: if (l_procedureEnabled) then
647: ecx_debug.pop(i_method_name );
648: end if;
649: raise ecx_utils.program_exit;
650: end popall;
651:
652: /**
653: Fetches data from the ec_views recurrsively for a given document.
670: ecx_debug.push(i_method_name );
671: end if;
672: if(l_statementEnabled) then
673: ecx_debug.log(l_statement,'i_level',i_level,i_method_name);
674: ecx_debug.log(l_statement,'Source level',ecx_utils.g_source_levels.COUNT,i_method_name);
675: ecx_debug.log(l_statement,'target_source_levels',ecx_utils.g_target_source_levels.COUNT,i_method_name);
676: end if;
677: -- push root element on stack
678: if (i_level = 0)
671: end if;
672: if(l_statementEnabled) then
673: ecx_debug.log(l_statement,'i_level',i_level,i_method_name);
674: ecx_debug.log(l_statement,'Source level',ecx_utils.g_source_levels.COUNT,i_method_name);
675: ecx_debug.log(l_statement,'target_source_levels',ecx_utils.g_target_source_levels.COUNT,i_method_name);
676: end if;
677: -- push root element on stack
678: if (i_level = 0)
679: then
679: then
680: push(i_level);
681: end if;
682:
683: for i in 1..ecx_utils.g_source_levels.last
684: loop
685: IF ecx_utils.g_source_levels(i).parent_level = i_level
686: THEN
687: if(l_statementEnabled) then
681: end if;
682:
683: for i in 1..ecx_utils.g_source_levels.last
684: loop
685: IF ecx_utils.g_source_levels(i).parent_level = i_level
686: THEN
687: if(l_statementEnabled) then
688: ecx_debug.log(l_statement,'SQL Statement',ecx_utils.g_source_levels(i).sql_stmt,i_method_name);
689: end if;
684: loop
685: IF ecx_utils.g_source_levels(i).parent_level = i_level
686: THEN
687: if(l_statementEnabled) then
688: ecx_debug.log(l_statement,'SQL Statement',ecx_utils.g_source_levels(i).sql_stmt,i_method_name);
689: end if;
690: -- Set the Global Variable for Current Level
691: ecx_utils.g_current_level := i;
692:
687: if(l_statementEnabled) then
688: ecx_debug.log(l_statement,'SQL Statement',ecx_utils.g_source_levels(i).sql_stmt,i_method_name);
689: end if;
690: -- Set the Global Variable for Current Level
691: ecx_utils.g_current_level := i;
692:
693: /* Bind the Variables for the Where Clause */
694: ecx_actions.bind_variables_for_view(10,i);
695: i_rows_processed := dbms_sql.execute (ecx_utils.g_source_levels(i).Cursor_Handle);
691: ecx_utils.g_current_level := i;
692:
693: /* Bind the Variables for the Where Clause */
694: ecx_actions.bind_variables_for_view(10,i);
695: i_rows_processed := dbms_sql.execute (ecx_utils.g_source_levels(i).Cursor_Handle);
696: if(l_statementEnabled) then
697: ecx_debug.log(l_statement,'Cursor Handle',ecx_utils.g_source_levels(i).Cursor_handle,
698: i_method_name);
699: end if;
693: /* Bind the Variables for the Where Clause */
694: ecx_actions.bind_variables_for_view(10,i);
695: i_rows_processed := dbms_sql.execute (ecx_utils.g_source_levels(i).Cursor_Handle);
696: if(l_statementEnabled) then
697: ecx_debug.log(l_statement,'Cursor Handle',ecx_utils.g_source_levels(i).Cursor_handle,
698: i_method_name);
699: end if;
700:
701:
698: i_method_name);
699: end if;
700:
701:
702: while (dbms_sql.fetch_rows( ecx_utils.g_source_levels(i).Cursor_handle) > 0)
703: LOOP
704: push(i);
705:
706: if(l_statementEnabled) then
709:
710: -- Get Values from the View
711: -- Initialize the Column Counter
712: i_column_counter :=0;
713: j := ecx_utils.g_source_levels(i).file_start_pos;
714: loop
715: if (ecx_utils.g_source(j).external_level = i)
716: then
717: i_column_counter := i_column_counter + 1;
711: -- Initialize the Column Counter
712: i_column_counter :=0;
713: j := ecx_utils.g_source_levels(i).file_start_pos;
714: loop
715: if (ecx_utils.g_source(j).external_level = i)
716: then
717: i_column_counter := i_column_counter + 1;
718:
719: if ecx_utils.g_source(j).data_type <> 112 Then
715: if (ecx_utils.g_source(j).external_level = i)
716: then
717: i_column_counter := i_column_counter + 1;
718:
719: if ecx_utils.g_source(j).data_type <> 112 Then
720: dbms_sql.column_value
721: (
722: ecx_utils.g_source_levels(i).Cursor_handle,
723: i_column_counter,
718:
719: if ecx_utils.g_source(j).data_type <> 112 Then
720: dbms_sql.column_value
721: (
722: ecx_utils.g_source_levels(i).Cursor_handle,
723: i_column_counter,
724: ecx_utils.g_source(j).value
725: );
726: else
720: dbms_sql.column_value
721: (
722: ecx_utils.g_source_levels(i).Cursor_handle,
723: i_column_counter,
724: ecx_utils.g_source(j).value
725: );
726: else
727: dbms_sql.column_value
728: (
725: );
726: else
727: dbms_sql.column_value
728: (
729: ecx_utils.g_source_levels(i).Cursor_handle,
730: i_column_counter,
731: ecx_utils.g_source(j).clob_value
732: );
733: /** Change required for Clob Support -- 2263729 ***/
727: dbms_sql.column_value
728: (
729: ecx_utils.g_source_levels(i).Cursor_handle,
730: i_column_counter,
731: ecx_utils.g_source(j).clob_value
732: );
733: /** Change required for Clob Support -- 2263729 ***/
734: ecx_utils.g_source(j).clob_length := dbms_lob.getlength( ecx_utils.g_source(j).clob_value);
735: i_len := ecx_utils.g_source(j).clob_length;
730: i_column_counter,
731: ecx_utils.g_source(j).clob_value
732: );
733: /** Change required for Clob Support -- 2263729 ***/
734: ecx_utils.g_source(j).clob_length := dbms_lob.getlength( ecx_utils.g_source(j).clob_value);
735: i_len := ecx_utils.g_source(j).clob_length;
736:
737: ecx_utils.g_source(j).is_clob := 'N';
738:
731: ecx_utils.g_source(j).clob_value
732: );
733: /** Change required for Clob Support -- 2263729 ***/
734: ecx_utils.g_source(j).clob_length := dbms_lob.getlength( ecx_utils.g_source(j).clob_value);
735: i_len := ecx_utils.g_source(j).clob_length;
736:
737: ecx_utils.g_source(j).is_clob := 'N';
738:
739: If i_len <= ecx_utils.G_CLOB_VARCHAR_LEN Then
733: /** Change required for Clob Support -- 2263729 ***/
734: ecx_utils.g_source(j).clob_length := dbms_lob.getlength( ecx_utils.g_source(j).clob_value);
735: i_len := ecx_utils.g_source(j).clob_length;
736:
737: ecx_utils.g_source(j).is_clob := 'N';
738:
739: If i_len <= ecx_utils.G_CLOB_VARCHAR_LEN Then
740: ecx_utils.g_source(j).is_clob := 'Y'; /** To indicate value has a shorter string of clob value ***/
741: ecx_utils.g_source(j).value :=
735: i_len := ecx_utils.g_source(j).clob_length;
736:
737: ecx_utils.g_source(j).is_clob := 'N';
738:
739: If i_len <= ecx_utils.G_CLOB_VARCHAR_LEN Then
740: ecx_utils.g_source(j).is_clob := 'Y'; /** To indicate value has a shorter string of clob value ***/
741: ecx_utils.g_source(j).value :=
742: dbms_lob.substr(ecx_utils.g_source(j).clob_value,i_len,1);
743: ecx_utils.g_source(j).clob_value := null ;
736:
737: ecx_utils.g_source(j).is_clob := 'N';
738:
739: If i_len <= ecx_utils.G_CLOB_VARCHAR_LEN Then
740: ecx_utils.g_source(j).is_clob := 'Y'; /** To indicate value has a shorter string of clob value ***/
741: ecx_utils.g_source(j).value :=
742: dbms_lob.substr(ecx_utils.g_source(j).clob_value,i_len,1);
743: ecx_utils.g_source(j).clob_value := null ;
744: ecx_utils.g_source(j).clob_length := null ;
737: ecx_utils.g_source(j).is_clob := 'N';
738:
739: If i_len <= ecx_utils.G_CLOB_VARCHAR_LEN Then
740: ecx_utils.g_source(j).is_clob := 'Y'; /** To indicate value has a shorter string of clob value ***/
741: ecx_utils.g_source(j).value :=
742: dbms_lob.substr(ecx_utils.g_source(j).clob_value,i_len,1);
743: ecx_utils.g_source(j).clob_value := null ;
744: ecx_utils.g_source(j).clob_length := null ;
745: End If;
738:
739: If i_len <= ecx_utils.G_CLOB_VARCHAR_LEN Then
740: ecx_utils.g_source(j).is_clob := 'Y'; /** To indicate value has a shorter string of clob value ***/
741: ecx_utils.g_source(j).value :=
742: dbms_lob.substr(ecx_utils.g_source(j).clob_value,i_len,1);
743: ecx_utils.g_source(j).clob_value := null ;
744: ecx_utils.g_source(j).clob_length := null ;
745: End If;
746: end if;
739: If i_len <= ecx_utils.G_CLOB_VARCHAR_LEN Then
740: ecx_utils.g_source(j).is_clob := 'Y'; /** To indicate value has a shorter string of clob value ***/
741: ecx_utils.g_source(j).value :=
742: dbms_lob.substr(ecx_utils.g_source(j).clob_value,i_len,1);
743: ecx_utils.g_source(j).clob_value := null ;
744: ecx_utils.g_source(j).clob_length := null ;
745: End If;
746: end if;
747:
740: ecx_utils.g_source(j).is_clob := 'Y'; /** To indicate value has a shorter string of clob value ***/
741: ecx_utils.g_source(j).value :=
742: dbms_lob.substr(ecx_utils.g_source(j).clob_value,i_len,1);
743: ecx_utils.g_source(j).clob_value := null ;
744: ecx_utils.g_source(j).clob_length := null ;
745: End If;
746: end if;
747:
748: /** If the value is null set the default value **/
745: End If;
746: end if;
747:
748: /** If the value is null set the default value **/
749: if ecx_utils.g_source(j).value is null
750: then
751: ecx_utils.g_source(j).value := ecx_utils.g_source(j).default_value;
752: end if;
753:
747:
748: /** If the value is null set the default value **/
749: if ecx_utils.g_source(j).value is null
750: then
751: ecx_utils.g_source(j).value := ecx_utils.g_source(j).default_value;
752: end if;
753:
754: if(l_statementEnabled) then
755: if ecx_utils.g_source(j).base_column_name is not null
751: ecx_utils.g_source(j).value := ecx_utils.g_source(j).default_value;
752: end if;
753:
754: if(l_statementEnabled) then
755: if ecx_utils.g_source(j).base_column_name is not null
756: then
757: /** Change required for Clob Support -- 2263729 ***/
758: if ecx_utils.g_source(j).data_type = 112 Then
759: if ecx_utils.g_source(j).clob_value is null Then
754: if(l_statementEnabled) then
755: if ecx_utils.g_source(j).base_column_name is not null
756: then
757: /** Change required for Clob Support -- 2263729 ***/
758: if ecx_utils.g_source(j).data_type = 112 Then
759: if ecx_utils.g_source(j).clob_value is null Then
760:
761: ecx_debug.log(l_statement,
762: ecx_utils.g_source(j).base_column_name,
755: if ecx_utils.g_source(j).base_column_name is not null
756: then
757: /** Change required for Clob Support -- 2263729 ***/
758: if ecx_utils.g_source(j).data_type = 112 Then
759: if ecx_utils.g_source(j).clob_value is null Then
760:
761: ecx_debug.log(l_statement,
762: ecx_utils.g_source(j).base_column_name,
763: ecx_utils.g_source(j).value,
758: if ecx_utils.g_source(j).data_type = 112 Then
759: if ecx_utils.g_source(j).clob_value is null Then
760:
761: ecx_debug.log(l_statement,
762: ecx_utils.g_source(j).base_column_name,
763: ecx_utils.g_source(j).value,
764: i_method_name
765: );
766:
759: if ecx_utils.g_source(j).clob_value is null Then
760:
761: ecx_debug.log(l_statement,
762: ecx_utils.g_source(j).base_column_name,
763: ecx_utils.g_source(j).value,
764: i_method_name
765: );
766:
767: else
766:
767: else
768:
769: ecx_debug.log(l_statement,
770: ecx_utils.g_source(j).base_column_name,
771: ecx_utils.g_source(j).clob_value,
772: i_method_name
773: );
774: end if;
767: else
768:
769: ecx_debug.log(l_statement,
770: ecx_utils.g_source(j).base_column_name,
771: ecx_utils.g_source(j).clob_value,
772: i_method_name
773: );
774: end if;
775: else
774: end if;
775: else
776:
777: ecx_debug.log(l_statement,
778: ecx_utils.g_source(j).base_column_name,
779: ecx_utils.g_source(j).value,
780: i_method_name
781: );
782: End If;
775: else
776:
777: ecx_debug.log(l_statement,
778: ecx_utils.g_source(j).base_column_name,
779: ecx_utils.g_source(j).value,
780: i_method_name
781: );
782: End If;
783: end if;
782: End If;
783: end if;
784: end if;
785: end if;
786: exit when j = ecx_utils.g_source_levels(i).file_end_pos;
787: j := ecx_utils.g_source.next(j);
788: end loop;
789: if(l_statementEnabled) then
790: ecx_debug.log(l_statement,'All Rows fetched',i_method_name);
783: end if;
784: end if;
785: end if;
786: exit when j = ecx_utils.g_source_levels(i).file_end_pos;
787: j := ecx_utils.g_source.next(j);
788: end loop;
789: if(l_statementEnabled) then
790: ecx_debug.log(l_statement,'All Rows fetched',i_method_name);
791: end if;
791: end if;
792:
793:
794: i_count :=0;
795: if (ecx_utils.g_source_levels.count <> 0)
796: then
797: for m in ecx_utils.g_source_levels.first..ecx_utils.g_source_levels.last
798: loop
799: if(l_statementEnabled) then
793:
794: i_count :=0;
795: if (ecx_utils.g_source_levels.count <> 0)
796: then
797: for m in ecx_utils.g_source_levels.first..ecx_utils.g_source_levels.last
798: loop
799: if(l_statementEnabled) then
800: ecx_debug.log(l_statement,'Source level '||m,'Parent level'||ecx_utils.g_source_levels(m).parent_level,
801: i_method_name);
796: then
797: for m in ecx_utils.g_source_levels.first..ecx_utils.g_source_levels.last
798: loop
799: if(l_statementEnabled) then
800: ecx_debug.log(l_statement,'Source level '||m,'Parent level'||ecx_utils.g_source_levels(m).parent_level,
801: i_method_name);
802: end if;
803: if ecx_utils.g_source_levels(m).parent_level=i
804: then
799: if(l_statementEnabled) then
800: ecx_debug.log(l_statement,'Source level '||m,'Parent level'||ecx_utils.g_source_levels(m).parent_level,
801: i_method_name);
802: end if;
803: if ecx_utils.g_source_levels(m).parent_level=i
804: then
805: i_count := i_count+1;
806: end if;
807: end loop;
817:
818: END LOOP;
819: if i = 1
820: then
821: ecx_utils.g_source_levels(i).rows_processed := dbms_sql.last_row_count;
822: else
823: ecx_utils.g_source_levels(i).rows_processed :=
824: ecx_utils.g_source_levels(i).rows_processed + dbms_sql.last_row_count;
825: end if;
819: if i = 1
820: then
821: ecx_utils.g_source_levels(i).rows_processed := dbms_sql.last_row_count;
822: else
823: ecx_utils.g_source_levels(i).rows_processed :=
824: ecx_utils.g_source_levels(i).rows_processed + dbms_sql.last_row_count;
825: end if;
826: END IF;
827: end loop;
820: then
821: ecx_utils.g_source_levels(i).rows_processed := dbms_sql.last_row_count;
822: else
823: ecx_utils.g_source_levels(i).rows_processed :=
824: ecx_utils.g_source_levels(i).rows_processed + dbms_sql.last_row_count;
825: end if;
826: END IF;
827: end loop;
828: if (l_procedureEnabled) then
839: ecx_debug.setErrorInfo(2,30,'ECX_INVALID_NUMBER - ECX_OUTBOUND.FETCH_DATA_FROM_VIEW' );
840: if (l_procedureEnabled) then
841: ecx_debug.pop(i_method_name);
842: end if;
843: raise ecx_utils.program_exit;
844: WHEN ecx_utils.PROGRAM_EXIT then
845: raise;
846: WHEN OTHERS THEN
847: if(l_unexpectedEnabled) then
840: if (l_procedureEnabled) then
841: ecx_debug.pop(i_method_name);
842: end if;
843: raise ecx_utils.program_exit;
844: WHEN ecx_utils.PROGRAM_EXIT then
845: raise;
846: WHEN OTHERS THEN
847: if(l_unexpectedEnabled) then
848: ecx_debug.log(l_unexpected,'ECX','ECX_PROGRAM_ERROR',i_method_name,'PROGRESS_LEVEL',
856: end if;
857: if (l_procedureEnabled) then
858: ecx_debug.pop(i_method_name );
859: end if;
860: raise ecx_utils.PROGRAM_EXIT;
861: END fetch_data_from_view;
862:
863: procedure log_summary(level pls_integer)
864: is
869: ecx_debug.push(i_method_name);
870: end if;
871:
872: ecx_debug.log(level,'Processing Summary','====',i_method_name);
873: if (ecx_utils.g_source_levels.count <> 0)
874: then
875: for i in ecx_utils.g_source_levels.first..ecx_utils.g_source_levels.last
876: loop
877: ecx_debug.log(level,ecx_utils.g_source_levels(i).rows_processed||
871:
872: ecx_debug.log(level,'Processing Summary','====',i_method_name);
873: if (ecx_utils.g_source_levels.count <> 0)
874: then
875: for i in ecx_utils.g_source_levels.first..ecx_utils.g_source_levels.last
876: loop
877: ecx_debug.log(level,ecx_utils.g_source_levels(i).rows_processed||
878: ' row(s) processed for Level : '|| ecx_utils.g_source_levels(i).start_element
879: || '('|| i || ') ',i_method_name);
873: if (ecx_utils.g_source_levels.count <> 0)
874: then
875: for i in ecx_utils.g_source_levels.first..ecx_utils.g_source_levels.last
876: loop
877: ecx_debug.log(level,ecx_utils.g_source_levels(i).rows_processed||
878: ' row(s) processed for Level : '|| ecx_utils.g_source_levels(i).start_element
879: || '('|| i || ') ',i_method_name);
880: end loop;
881: end if;
874: then
875: for i in ecx_utils.g_source_levels.first..ecx_utils.g_source_levels.last
876: loop
877: ecx_debug.log(level,ecx_utils.g_source_levels(i).rows_processed||
878: ' row(s) processed for Level : '|| ecx_utils.g_source_levels(i).start_element
879: || '('|| i || ') ',i_method_name);
880: end loop;
881: end if;
882: if (l_procedureEnabled) then
891: if (l_procedureEnabled) then
892: ecx_debug.pop(i_method_name);
893: end if;
894:
895: raise ecx_utils.program_exit;
896: end log_summary;
897:
898: /**
899: Main Call for Processing Outbound Documents
968: ecx_debug.log(l_statement,'i_map_code',i_map_code,i_method_name);
969: end if;
970:
971: /** check for the Event Object. If null , initialize it **/
972: if ecx_utils.g_event is null
973: then
974: wf_event_t.initialize(ecx_utils.g_event);
975: end if;
976: i_parameterlist := wf_event_t.getParameterList(ecx_utils.g_event);
970:
971: /** check for the Event Object. If null , initialize it **/
972: if ecx_utils.g_event is null
973: then
974: wf_event_t.initialize(ecx_utils.g_event);
975: end if;
976: i_parameterlist := wf_event_t.getParameterList(ecx_utils.g_event);
977: if(l_statementEnabled) then
978: if i_parameterList is not null
972: if ecx_utils.g_event is null
973: then
974: wf_event_t.initialize(ecx_utils.g_event);
975: end if;
976: i_parameterlist := wf_event_t.getParameterList(ecx_utils.g_event);
977: if(l_statementEnabled) then
978: if i_parameterList is not null
979: then
980: for i in i_parameterList.FIRST..i_parameterList.LAST
986: end if;
987:
988:
989: /** Set the GLobal variables **/
990: ecx_utils.g_transaction_type := i_transaction_type;
991: ecx_utils.g_transaction_subtype := i_transaction_subtype;
992: ecx_utils.g_document_id := i_document_id;
993:
994: /** Check for Message Standard Code **/
987:
988:
989: /** Set the GLobal variables **/
990: ecx_utils.g_transaction_type := i_transaction_type;
991: ecx_utils.g_transaction_subtype := i_transaction_subtype;
992: ecx_utils.g_document_id := i_document_id;
993:
994: /** Check for Message Standard Code **/
995: begin
988:
989: /** Set the GLobal variables **/
990: ecx_utils.g_transaction_type := i_transaction_type;
991: ecx_utils.g_transaction_subtype := i_transaction_subtype;
992: ecx_utils.g_document_id := i_document_id;
993:
994: /** Check for Message Standard Code **/
995: begin
996: select standard_id
998: from ecx_standards
999: where standard_code = i_message_standard
1000: and standard_type = nvl(i_message_type, 'XML');
1001:
1002: ecx_utils.g_standard_id := i_standard_id;
1003: exception
1004: when others then
1005: ecx_debug.setErrorInfo(1, 30, 'ECX_CODE_CONVERSION_DISABLED',
1006: 'MESSAGE_STANDARD', i_message_standard);
1021: ecx_debug.setErrorInfo(1, 30, 'ECX_MAP_NOT_FOUND', 'MAP_CODE', i_map_code);
1022: if(l_unexpectedEnabled) then
1023: ecx_debug.log(l_unexpected,'ECX', 'ECX_MAP_NOT_FOUND', i_method_name,'MAP_CODE', i_map_code);
1024: end if;
1025: raise ecx_utils.program_exit;
1026: end;
1027:
1028: /** Check for tp_header_id **/
1029: begin
1034: and party_site_id = i_tp_site_id
1035: and party_type = i_tp_type;
1036:
1037: /** Set the GLobal g_rcv_tp_id **/
1038: ecx_utils.g_rec_tp_id:= i_tp_header_id;
1039: exception
1040: when others then
1041: ecx_debug.setErrorInfo(1, 30, 'ECX_TP_NOT_FOUND', 'PARTY_ID', i_tp_id);
1042: if(l_statementEnabled) then
1058: ecx_debug.setErrorInfo(1, 30, 'ECX_ROOT_ELEMENT_NOT_FOUND', 'MAP_ID', i_map_id);
1059: if(l_unexpectedEnabled) then
1060: ecx_debug.log(l_unexpected,'ECX', 'ECX_ROOT_ELEMENT_NOT_FOUND',i_method_name, 'MAP_ID', i_map_id);
1061: end if;
1062: raise ecx_utils.program_exit;
1063: end;
1064:
1065: /**
1066: Initialize Memory Structures Set the direction for the Transaction **/
1063: end;
1064:
1065: /**
1066: Initialize Memory Structures Set the direction for the Transaction **/
1067: ecx_utils.g_direction :='OUT';
1068: ecx_utils.initialize(i_map_id,x_same_map);
1069:
1070:
1071: /**
1064:
1065: /**
1066: Initialize Memory Structures Set the direction for the Transaction **/
1067: ecx_utils.g_direction :='OUT';
1068: ecx_utils.initialize(i_map_id,x_same_map);
1069:
1070:
1071: /**
1072: Find the Stack Variable.If Found set the value.
1078: );
1079:
1080: if (i_variable_found AND i_transaction_type is not null)
1081: then
1082: ecx_utils.g_stack(i_stack_pos).variable_value := i_transaction_type;
1083: end if;
1084:
1085: i_variable_found := ecx_actions.find_stack_variable
1086: (
1089: );
1090:
1091: if (i_variable_found AND i_transaction_subtype is not null)
1092: then
1093: ecx_utils.g_stack(i_stack_pos).variable_value := i_transaction_subtype;
1094: end if;
1095:
1096:
1097: i_variable_found := ecx_actions.find_stack_variable
1101: );
1102:
1103: if (i_variable_found AND i_document_id is not null)
1104: then
1105: ecx_utils.g_stack(i_stack_pos).variable_value := i_document_id;
1106: end if;
1107:
1108: i_variable_found := ecx_actions.find_stack_variable
1109: (
1112: );
1113:
1114: if (i_variable_found AND i_tp_id is not null)
1115: then
1116: ecx_utils.g_stack(i_stack_pos).variable_value := i_tp_id;
1117: end if;
1118:
1119: i_variable_found := ecx_actions.find_stack_variable
1120: (
1123: );
1124:
1125: if (i_variable_found AND i_tp_site_id is not null)
1126: then
1127: ecx_utils.g_stack(i_stack_pos).variable_value := i_tp_site_id;
1128: end if;
1129:
1130: i_variable_found := ecx_actions.find_stack_variable
1131: (
1134: );
1135:
1136: if (i_variable_found AND i_tp_type is not null)
1137: then
1138: ecx_utils.g_stack(i_stack_pos).variable_value := i_tp_type;
1139: end if;
1140:
1141: /* If the input wf_event_t object passed is null , the following loop raises an exception.
1142: so initialize the i_event_obj
1190: i_stack_param_value := i_parameter.getValue();
1191: /** Only overwrite the Global variable value if not null **/
1192: if i_stack_param_value is not null
1193: then
1194: ecx_utils.g_stack(i_stack_pos).variable_value
1195: := i_stack_param_value;
1196: end if;
1197: end if;
1198: end if;
1205: Should Avoid Parsing and Loading the Next Map if it is same as the previous one.
1206: **/
1207: if NOT (x_same_map)
1208: then
1209: ecx_utils.load_objects(i_map_id);
1210: end if;
1211:
1212: if (ecx_utils.g_source_levels.count <> 0)
1213: then
1208: then
1209: ecx_utils.load_objects(i_map_id);
1210: end if;
1211:
1212: if (ecx_utils.g_source_levels.count <> 0)
1213: then
1214: for i in ecx_utils.g_source_levels.first..ecx_utils.g_source_levels.last
1215: loop
1216: ecx_utils.g_source_levels(i).rows_processed := 0;
1210: end if;
1211:
1212: if (ecx_utils.g_source_levels.count <> 0)
1213: then
1214: for i in ecx_utils.g_source_levels.first..ecx_utils.g_source_levels.last
1215: loop
1216: ecx_utils.g_source_levels(i).rows_processed := 0;
1217: end loop;
1218: end if;
1212: if (ecx_utils.g_source_levels.count <> 0)
1213: then
1214: for i in ecx_utils.g_source_levels.first..ecx_utils.g_source_levels.last
1215: loop
1216: ecx_utils.g_source_levels(i).rows_processed := 0;
1217: end loop;
1218: end if;
1219: /**
1220: Initialize the temporary XML Buffer
1233: ecx_print_local.comment_node('Oracle eXtensible Markup Language Gateway Server ');
1234:
1235:
1236: /** DOCUMENT NODE **/
1237: if (not ecx_utils.g_delete_doctype) then
1238: ecx_print_local.document_node(i_root_element,i_filename,null);
1239: if(l_statementEnabled) then
1240: ecx_debug.log(l_statement, 'Printed DOCTYPE', i_method_name);
1241: end if;
1244: fetch_data_from_view (0);
1245: popall;
1246: ecx_print_local.xmlPOPALL(i_xmldoc);
1247:
1248: ecx_util_api.parseXML(ecx_utils.g_parser, i_xmldoc, l_parseXML, ecx_utils.g_xmldoc);
1249: if(l_statementEnabled) then
1250: ecx_debug.log(l_statement, 'Parsed XML', l_parseXML,i_method_name);
1251: end if;
1252:
1268:
1269: -- set the out variable to have the latest document.
1270: if l_parseXML then
1271: dbms_lob.trim(i_xmldoc, 0);
1272: xmlDOM.writetoCLOB(ecx_utils.g_xmldoc,i_xmldoc);
1273:
1274: g_instlmode := wf_core.translate('WF_INSTALL');
1275:
1276: if (l_statementEnabled)
1287: End Loop;
1288: fnd_log_attachment.close(attachment_id);
1289: end if;
1290: ELSE
1291: xmlDOM.writetofile(ecx_utils.g_xmldoc,ecx_utils.g_logdir||'/'||
1292: substr(ecx_utils.g_logfile,1,length(ecx_utils.g_logfile)-4)
1293: ||'.xml');
1294: END IF;
1295: end if;
1288: fnd_log_attachment.close(attachment_id);
1289: end if;
1290: ELSE
1291: xmlDOM.writetofile(ecx_utils.g_xmldoc,ecx_utils.g_logdir||'/'||
1292: substr(ecx_utils.g_logfile,1,length(ecx_utils.g_logfile)-4)
1293: ||'.xml');
1294: END IF;
1295: end if;
1296: end if;
1298: if(l_statementEnabled) then
1299: ecx_outbound.log_summary(l_statement);
1300:
1301: ecx_debug.log(l_statement,'ECX','ECX_DOCUMENTS_PROCESSED',i_method_name,'NO_OF_DOCS',
1302: ecx_utils.g_source_levels(0).rows_processed);
1303: ecx_debug.log(l_statement,'ECX','ECX_FINISH_OUTBOUND',i_method_name,'MAP_ID',i_map_id);
1304: end if;
1305:
1306: if not XMLDom.isNull(ecx_utils.g_xmldoc) then
1302: ecx_utils.g_source_levels(0).rows_processed);
1303: ecx_debug.log(l_statement,'ECX','ECX_FINISH_OUTBOUND',i_method_name,'MAP_ID',i_map_id);
1304: end if;
1305:
1306: if not XMLDom.isNull(ecx_utils.g_xmldoc) then
1307: i_node_type := xmlDOM.getNodeType(ecx_utils.g_xmldoc);
1308: if (i_node_type = xmlDOM.DOCUMENT_NODE) then
1309: xmlDOM.freeDocument(xmlDOM.makeDocument(ecx_utils.g_xmldoc));
1310: else
1303: ecx_debug.log(l_statement,'ECX','ECX_FINISH_OUTBOUND',i_method_name,'MAP_ID',i_map_id);
1304: end if;
1305:
1306: if not XMLDom.isNull(ecx_utils.g_xmldoc) then
1307: i_node_type := xmlDOM.getNodeType(ecx_utils.g_xmldoc);
1308: if (i_node_type = xmlDOM.DOCUMENT_NODE) then
1309: xmlDOM.freeDocument(xmlDOM.makeDocument(ecx_utils.g_xmldoc));
1310: else
1311: xmlDOM.freeDocFrag(xmlDOM.makeDocumentFragment(ecx_utils.g_xmldoc));
1305:
1306: if not XMLDom.isNull(ecx_utils.g_xmldoc) then
1307: i_node_type := xmlDOM.getNodeType(ecx_utils.g_xmldoc);
1308: if (i_node_type = xmlDOM.DOCUMENT_NODE) then
1309: xmlDOM.freeDocument(xmlDOM.makeDocument(ecx_utils.g_xmldoc));
1310: else
1311: xmlDOM.freeDocFrag(xmlDOM.makeDocumentFragment(ecx_utils.g_xmldoc));
1312: end if;
1313: xmlparser.freeparser(ecx_utils.g_parser);
1307: i_node_type := xmlDOM.getNodeType(ecx_utils.g_xmldoc);
1308: if (i_node_type = xmlDOM.DOCUMENT_NODE) then
1309: xmlDOM.freeDocument(xmlDOM.makeDocument(ecx_utils.g_xmldoc));
1310: else
1311: xmlDOM.freeDocFrag(xmlDOM.makeDocumentFragment(ecx_utils.g_xmldoc));
1312: end if;
1313: xmlparser.freeparser(ecx_utils.g_parser);
1314: end if;
1315: if (l_procedureEnabled) then
1309: xmlDOM.freeDocument(xmlDOM.makeDocument(ecx_utils.g_xmldoc));
1310: else
1311: xmlDOM.freeDocFrag(xmlDOM.makeDocumentFragment(ecx_utils.g_xmldoc));
1312: end if;
1313: xmlparser.freeparser(ecx_utils.g_parser);
1314: end if;
1315: if (l_procedureEnabled) then
1316: ecx_debug.pop(i_method_name );
1317: end if;
1316: ecx_debug.pop(i_method_name );
1317: end if;
1318:
1319: EXCEPTION
1320: WHEN ecx_utils.PROGRAM_EXIT then
1321: if(l_unexpectedEnabled) then
1322: ecx_debug.log(l_unexpected, 'Clean-up i_stack, l_node_stack, i_tmpxml and last_printed',
1323: i_method_name);
1324: ecx_outbound.log_summary(l_unexpected);
1329: ecx_print_local.last_printed := -1;
1330: if (l_procedureEnabled) then
1331: ecx_debug.pop(i_method_name );
1332: end if;
1333: raise ecx_utils.program_exit;
1334: WHEN OTHERS THEN
1335: if(l_unexpectedEnabled) then
1336: ecx_debug.log(l_unexpected,'ECX','ECX_PROGRAM_ERROR',i_method_name,'PROGRESS_LEVEL',
1337: 'ECX_OUTBOUND.PROCESS_OUTBOUND_DOCUMENTS');
1349: ecx_print_local.last_printed := -1;
1350: if (l_procedureEnabled) then
1351: ecx_debug.pop(i_method_name );
1352: end if;
1353: raise ecx_utils.PROGRAM_EXIT;
1354: end process_outbound_documents;
1355:
1356:
1357: procedure putmsg
1405: p_aflog_module_name VARCHAR2(2000) ;
1406:
1407: begin
1408: --- Sets the Log Directory in both Standalone and the Embedded mode
1409: ecx_utils.getLogDirectory;
1410:
1411: if ecx_utils.g_logfile is null
1412: then
1413: i_direct := false;
1407: begin
1408: --- Sets the Log Directory in both Standalone and the Embedded mode
1409: ecx_utils.getLogDirectory;
1410:
1411: if ecx_utils.g_logfile is null
1412: then
1413: i_direct := false;
1414: -- Fetch the Run Id for the Transaction
1415: open get_run_s;
1413: i_direct := false;
1414: -- Fetch the Run Id for the Transaction
1415: open get_run_s;
1416: fetch get_run_s
1417: into ecx_utils.g_run_id;
1418: close get_run_s;
1419:
1420: ecx_utils.g_logfile :=i_message_standard||'OUT'||
1421: i_transaction_type||i_transaction_subtype||i_document_id||ecx_utils.g_run_id||'.log';
1416: fetch get_run_s
1417: into ecx_utils.g_run_id;
1418: close get_run_s;
1419:
1420: ecx_utils.g_logfile :=i_message_standard||'OUT'||
1421: i_transaction_type||i_transaction_subtype||i_document_id||ecx_utils.g_run_id||'.log';
1422:
1423: p_aflog_module_name := '';
1424: IF (i_message_standard is not null) THEN
1417: into ecx_utils.g_run_id;
1418: close get_run_s;
1419:
1420: ecx_utils.g_logfile :=i_message_standard||'OUT'||
1421: i_transaction_type||i_transaction_subtype||i_document_id||ecx_utils.g_run_id||'.log';
1422:
1423: p_aflog_module_name := '';
1424: IF (i_message_standard is not null) THEN
1425: p_aflog_module_name := p_aflog_module_name||i_message_standard||'.';
1433: END IF;
1434: IF (i_document_id is not null) THEN
1435: p_aflog_module_name := p_aflog_module_name||i_document_id||'.';
1436: END IF;
1437: IF (ecx_utils.g_run_id is not null) THEN
1438: p_aflog_module_name := p_aflog_module_name||ecx_utils.g_run_id;
1439: END IF;
1440: p_aflog_module_name := p_aflog_module_name||'.log';
1441:
1434: IF (i_document_id is not null) THEN
1435: p_aflog_module_name := p_aflog_module_name||i_document_id||'.';
1436: END IF;
1437: IF (ecx_utils.g_run_id is not null) THEN
1438: p_aflog_module_name := p_aflog_module_name||ecx_utils.g_run_id;
1439: END IF;
1440: p_aflog_module_name := p_aflog_module_name||'.log';
1441:
1442: ecx_debug.enable_debug_new(i_debug_level,ecx_utils.g_logdir,ecx_utils.g_logfile, p_aflog_module_name);
1438: p_aflog_module_name := p_aflog_module_name||ecx_utils.g_run_id;
1439: END IF;
1440: p_aflog_module_name := p_aflog_module_name||'.log';
1441:
1442: ecx_debug.enable_debug_new(i_debug_level,ecx_utils.g_logdir,ecx_utils.g_logfile, p_aflog_module_name);
1443: end if;
1444:
1445: -- Assign local variables with the ecx_debug global variables
1446: l_procedure := ecx_debug.g_procedure;
1502: i_message_type
1503: );
1504:
1505: -- call ecx_out_wf_qh.enqueue with the correct parameters
1506: ecx_utils.g_event.addParameterToList('PARTY_TYPE', i_party_type);
1507: ecx_utils.g_event.addParameterToList('PARTYID', i_destination_code);
1508: ecx_utils.g_event.addParameterToList('PARTY_SITE_ID', i_destination_code);
1509: ecx_utils.g_event.addParameterToList('DOCUMENT_NUMBER', ecx_utils.g_document_id);
1510: ecx_utils.g_event.addParameterToList('MESSAGE_TYPE', i_message_type);
1503: );
1504:
1505: -- call ecx_out_wf_qh.enqueue with the correct parameters
1506: ecx_utils.g_event.addParameterToList('PARTY_TYPE', i_party_type);
1507: ecx_utils.g_event.addParameterToList('PARTYID', i_destination_code);
1508: ecx_utils.g_event.addParameterToList('PARTY_SITE_ID', i_destination_code);
1509: ecx_utils.g_event.addParameterToList('DOCUMENT_NUMBER', ecx_utils.g_document_id);
1510: ecx_utils.g_event.addParameterToList('MESSAGE_TYPE', i_message_type);
1511: ecx_utils.g_event.addParameterToList('MESSAGE_STANDARD', i_message_standard);
1504:
1505: -- call ecx_out_wf_qh.enqueue with the correct parameters
1506: ecx_utils.g_event.addParameterToList('PARTY_TYPE', i_party_type);
1507: ecx_utils.g_event.addParameterToList('PARTYID', i_destination_code);
1508: ecx_utils.g_event.addParameterToList('PARTY_SITE_ID', i_destination_code);
1509: ecx_utils.g_event.addParameterToList('DOCUMENT_NUMBER', ecx_utils.g_document_id);
1510: ecx_utils.g_event.addParameterToList('MESSAGE_TYPE', i_message_type);
1511: ecx_utils.g_event.addParameterToList('MESSAGE_STANDARD', i_message_standard);
1512: ecx_utils.g_event.addParameterToList('TRANSACTION_TYPE', i_ext_type);
1505: -- call ecx_out_wf_qh.enqueue with the correct parameters
1506: ecx_utils.g_event.addParameterToList('PARTY_TYPE', i_party_type);
1507: ecx_utils.g_event.addParameterToList('PARTYID', i_destination_code);
1508: ecx_utils.g_event.addParameterToList('PARTY_SITE_ID', i_destination_code);
1509: ecx_utils.g_event.addParameterToList('DOCUMENT_NUMBER', ecx_utils.g_document_id);
1510: ecx_utils.g_event.addParameterToList('MESSAGE_TYPE', i_message_type);
1511: ecx_utils.g_event.addParameterToList('MESSAGE_STANDARD', i_message_standard);
1512: ecx_utils.g_event.addParameterToList('TRANSACTION_TYPE', i_ext_type);
1513: ecx_utils.g_event.addParameterToList('TRANSACTION_SUBTYPE', i_ext_subtype);
1506: ecx_utils.g_event.addParameterToList('PARTY_TYPE', i_party_type);
1507: ecx_utils.g_event.addParameterToList('PARTYID', i_destination_code);
1508: ecx_utils.g_event.addParameterToList('PARTY_SITE_ID', i_destination_code);
1509: ecx_utils.g_event.addParameterToList('DOCUMENT_NUMBER', ecx_utils.g_document_id);
1510: ecx_utils.g_event.addParameterToList('MESSAGE_TYPE', i_message_type);
1511: ecx_utils.g_event.addParameterToList('MESSAGE_STANDARD', i_message_standard);
1512: ecx_utils.g_event.addParameterToList('TRANSACTION_TYPE', i_ext_type);
1513: ecx_utils.g_event.addParameterToList('TRANSACTION_SUBTYPE', i_ext_subtype);
1514: ecx_utils.g_event.addParameterToList('PROTOCOL_TYPE', i_destination_type);
1507: ecx_utils.g_event.addParameterToList('PARTYID', i_destination_code);
1508: ecx_utils.g_event.addParameterToList('PARTY_SITE_ID', i_destination_code);
1509: ecx_utils.g_event.addParameterToList('DOCUMENT_NUMBER', ecx_utils.g_document_id);
1510: ecx_utils.g_event.addParameterToList('MESSAGE_TYPE', i_message_type);
1511: ecx_utils.g_event.addParameterToList('MESSAGE_STANDARD', i_message_standard);
1512: ecx_utils.g_event.addParameterToList('TRANSACTION_TYPE', i_ext_type);
1513: ecx_utils.g_event.addParameterToList('TRANSACTION_SUBTYPE', i_ext_subtype);
1514: ecx_utils.g_event.addParameterToList('PROTOCOL_TYPE', i_destination_type);
1515: ecx_utils.g_event.addParameterToList('PROTOCOL_ADDRESS', i_destination_address);
1508: ecx_utils.g_event.addParameterToList('PARTY_SITE_ID', i_destination_code);
1509: ecx_utils.g_event.addParameterToList('DOCUMENT_NUMBER', ecx_utils.g_document_id);
1510: ecx_utils.g_event.addParameterToList('MESSAGE_TYPE', i_message_type);
1511: ecx_utils.g_event.addParameterToList('MESSAGE_STANDARD', i_message_standard);
1512: ecx_utils.g_event.addParameterToList('TRANSACTION_TYPE', i_ext_type);
1513: ecx_utils.g_event.addParameterToList('TRANSACTION_SUBTYPE', i_ext_subtype);
1514: ecx_utils.g_event.addParameterToList('PROTOCOL_TYPE', i_destination_type);
1515: ecx_utils.g_event.addParameterToList('PROTOCOL_ADDRESS', i_destination_address);
1516: ecx_utils.g_event.addParameterToList('USERNAME', i_username);
1509: ecx_utils.g_event.addParameterToList('DOCUMENT_NUMBER', ecx_utils.g_document_id);
1510: ecx_utils.g_event.addParameterToList('MESSAGE_TYPE', i_message_type);
1511: ecx_utils.g_event.addParameterToList('MESSAGE_STANDARD', i_message_standard);
1512: ecx_utils.g_event.addParameterToList('TRANSACTION_TYPE', i_ext_type);
1513: ecx_utils.g_event.addParameterToList('TRANSACTION_SUBTYPE', i_ext_subtype);
1514: ecx_utils.g_event.addParameterToList('PROTOCOL_TYPE', i_destination_type);
1515: ecx_utils.g_event.addParameterToList('PROTOCOL_ADDRESS', i_destination_address);
1516: ecx_utils.g_event.addParameterToList('USERNAME', i_username);
1517: ecx_utils.g_event.addParameterToList('PASSWORD', i_password);
1510: ecx_utils.g_event.addParameterToList('MESSAGE_TYPE', i_message_type);
1511: ecx_utils.g_event.addParameterToList('MESSAGE_STANDARD', i_message_standard);
1512: ecx_utils.g_event.addParameterToList('TRANSACTION_TYPE', i_ext_type);
1513: ecx_utils.g_event.addParameterToList('TRANSACTION_SUBTYPE', i_ext_subtype);
1514: ecx_utils.g_event.addParameterToList('PROTOCOL_TYPE', i_destination_type);
1515: ecx_utils.g_event.addParameterToList('PROTOCOL_ADDRESS', i_destination_address);
1516: ecx_utils.g_event.addParameterToList('USERNAME', i_username);
1517: ecx_utils.g_event.addParameterToList('PASSWORD', i_password);
1518: ecx_utils.g_event.addParameterToList('ATTRIBUTE1', i_attribute1);
1511: ecx_utils.g_event.addParameterToList('MESSAGE_STANDARD', i_message_standard);
1512: ecx_utils.g_event.addParameterToList('TRANSACTION_TYPE', i_ext_type);
1513: ecx_utils.g_event.addParameterToList('TRANSACTION_SUBTYPE', i_ext_subtype);
1514: ecx_utils.g_event.addParameterToList('PROTOCOL_TYPE', i_destination_type);
1515: ecx_utils.g_event.addParameterToList('PROTOCOL_ADDRESS', i_destination_address);
1516: ecx_utils.g_event.addParameterToList('USERNAME', i_username);
1517: ecx_utils.g_event.addParameterToList('PASSWORD', i_password);
1518: ecx_utils.g_event.addParameterToList('ATTRIBUTE1', i_attribute1);
1519: ecx_utils.g_event.addParameterToList('ATTRIBUTE2', i_attribute2);
1512: ecx_utils.g_event.addParameterToList('TRANSACTION_TYPE', i_ext_type);
1513: ecx_utils.g_event.addParameterToList('TRANSACTION_SUBTYPE', i_ext_subtype);
1514: ecx_utils.g_event.addParameterToList('PROTOCOL_TYPE', i_destination_type);
1515: ecx_utils.g_event.addParameterToList('PROTOCOL_ADDRESS', i_destination_address);
1516: ecx_utils.g_event.addParameterToList('USERNAME', i_username);
1517: ecx_utils.g_event.addParameterToList('PASSWORD', i_password);
1518: ecx_utils.g_event.addParameterToList('ATTRIBUTE1', i_attribute1);
1519: ecx_utils.g_event.addParameterToList('ATTRIBUTE2', i_attribute2);
1520: ecx_utils.g_event.addParameterToList('ATTRIBUTE3', i_attribute3);
1513: ecx_utils.g_event.addParameterToList('TRANSACTION_SUBTYPE', i_ext_subtype);
1514: ecx_utils.g_event.addParameterToList('PROTOCOL_TYPE', i_destination_type);
1515: ecx_utils.g_event.addParameterToList('PROTOCOL_ADDRESS', i_destination_address);
1516: ecx_utils.g_event.addParameterToList('USERNAME', i_username);
1517: ecx_utils.g_event.addParameterToList('PASSWORD', i_password);
1518: ecx_utils.g_event.addParameterToList('ATTRIBUTE1', i_attribute1);
1519: ecx_utils.g_event.addParameterToList('ATTRIBUTE2', i_attribute2);
1520: ecx_utils.g_event.addParameterToList('ATTRIBUTE3', i_attribute3);
1521: ecx_utils.g_event.addParameterToList('ATTRIBUTE4', i_attribute4);
1514: ecx_utils.g_event.addParameterToList('PROTOCOL_TYPE', i_destination_type);
1515: ecx_utils.g_event.addParameterToList('PROTOCOL_ADDRESS', i_destination_address);
1516: ecx_utils.g_event.addParameterToList('USERNAME', i_username);
1517: ecx_utils.g_event.addParameterToList('PASSWORD', i_password);
1518: ecx_utils.g_event.addParameterToList('ATTRIBUTE1', i_attribute1);
1519: ecx_utils.g_event.addParameterToList('ATTRIBUTE2', i_attribute2);
1520: ecx_utils.g_event.addParameterToList('ATTRIBUTE3', i_attribute3);
1521: ecx_utils.g_event.addParameterToList('ATTRIBUTE4', i_attribute4);
1522: ecx_utils.g_event.addParameterToList('ATTRIBUTE5', i_attribute5);
1515: ecx_utils.g_event.addParameterToList('PROTOCOL_ADDRESS', i_destination_address);
1516: ecx_utils.g_event.addParameterToList('USERNAME', i_username);
1517: ecx_utils.g_event.addParameterToList('PASSWORD', i_password);
1518: ecx_utils.g_event.addParameterToList('ATTRIBUTE1', i_attribute1);
1519: ecx_utils.g_event.addParameterToList('ATTRIBUTE2', i_attribute2);
1520: ecx_utils.g_event.addParameterToList('ATTRIBUTE3', i_attribute3);
1521: ecx_utils.g_event.addParameterToList('ATTRIBUTE4', i_attribute4);
1522: ecx_utils.g_event.addParameterToList('ATTRIBUTE5', i_attribute5);
1523: ecx_utils.g_event.addParameterToList('TRIGGER_ID', i_trigger_id);
1516: ecx_utils.g_event.addParameterToList('USERNAME', i_username);
1517: ecx_utils.g_event.addParameterToList('PASSWORD', i_password);
1518: ecx_utils.g_event.addParameterToList('ATTRIBUTE1', i_attribute1);
1519: ecx_utils.g_event.addParameterToList('ATTRIBUTE2', i_attribute2);
1520: ecx_utils.g_event.addParameterToList('ATTRIBUTE3', i_attribute3);
1521: ecx_utils.g_event.addParameterToList('ATTRIBUTE4', i_attribute4);
1522: ecx_utils.g_event.addParameterToList('ATTRIBUTE5', i_attribute5);
1523: ecx_utils.g_event.addParameterToList('TRIGGER_ID', i_trigger_id);
1524: ecx_utils.g_event.addParameterToList('LOGFILE', ecx_utils.g_logfile);
1517: ecx_utils.g_event.addParameterToList('PASSWORD', i_password);
1518: ecx_utils.g_event.addParameterToList('ATTRIBUTE1', i_attribute1);
1519: ecx_utils.g_event.addParameterToList('ATTRIBUTE2', i_attribute2);
1520: ecx_utils.g_event.addParameterToList('ATTRIBUTE3', i_attribute3);
1521: ecx_utils.g_event.addParameterToList('ATTRIBUTE4', i_attribute4);
1522: ecx_utils.g_event.addParameterToList('ATTRIBUTE5', i_attribute5);
1523: ecx_utils.g_event.addParameterToList('TRIGGER_ID', i_trigger_id);
1524: ecx_utils.g_event.addParameterToList('LOGFILE', ecx_utils.g_logfile);
1525: ecx_utils.g_event.addParameterToList('ITEM_TYPE', ecx_utils.g_item_type);
1518: ecx_utils.g_event.addParameterToList('ATTRIBUTE1', i_attribute1);
1519: ecx_utils.g_event.addParameterToList('ATTRIBUTE2', i_attribute2);
1520: ecx_utils.g_event.addParameterToList('ATTRIBUTE3', i_attribute3);
1521: ecx_utils.g_event.addParameterToList('ATTRIBUTE4', i_attribute4);
1522: ecx_utils.g_event.addParameterToList('ATTRIBUTE5', i_attribute5);
1523: ecx_utils.g_event.addParameterToList('TRIGGER_ID', i_trigger_id);
1524: ecx_utils.g_event.addParameterToList('LOGFILE', ecx_utils.g_logfile);
1525: ecx_utils.g_event.addParameterToList('ITEM_TYPE', ecx_utils.g_item_type);
1526: ecx_utils.g_event.addParameterToList('ITEM_KEY', ecx_utils.g_item_key);
1519: ecx_utils.g_event.addParameterToList('ATTRIBUTE2', i_attribute2);
1520: ecx_utils.g_event.addParameterToList('ATTRIBUTE3', i_attribute3);
1521: ecx_utils.g_event.addParameterToList('ATTRIBUTE4', i_attribute4);
1522: ecx_utils.g_event.addParameterToList('ATTRIBUTE5', i_attribute5);
1523: ecx_utils.g_event.addParameterToList('TRIGGER_ID', i_trigger_id);
1524: ecx_utils.g_event.addParameterToList('LOGFILE', ecx_utils.g_logfile);
1525: ecx_utils.g_event.addParameterToList('ITEM_TYPE', ecx_utils.g_item_type);
1526: ecx_utils.g_event.addParameterToList('ITEM_KEY', ecx_utils.g_item_key);
1527: ecx_utils.g_event.addParameterToList('ACTIVITY_ID', ecx_utils.g_activity_id);
1520: ecx_utils.g_event.addParameterToList('ATTRIBUTE3', i_attribute3);
1521: ecx_utils.g_event.addParameterToList('ATTRIBUTE4', i_attribute4);
1522: ecx_utils.g_event.addParameterToList('ATTRIBUTE5', i_attribute5);
1523: ecx_utils.g_event.addParameterToList('TRIGGER_ID', i_trigger_id);
1524: ecx_utils.g_event.addParameterToList('LOGFILE', ecx_utils.g_logfile);
1525: ecx_utils.g_event.addParameterToList('ITEM_TYPE', ecx_utils.g_item_type);
1526: ecx_utils.g_event.addParameterToList('ITEM_KEY', ecx_utils.g_item_key);
1527: ecx_utils.g_event.addParameterToList('ACTIVITY_ID', ecx_utils.g_activity_id);
1528: ecx_utils.g_event.addParameterToList('EVENT_NAME', ecx_utils.g_event.event_name);
1521: ecx_utils.g_event.addParameterToList('ATTRIBUTE4', i_attribute4);
1522: ecx_utils.g_event.addParameterToList('ATTRIBUTE5', i_attribute5);
1523: ecx_utils.g_event.addParameterToList('TRIGGER_ID', i_trigger_id);
1524: ecx_utils.g_event.addParameterToList('LOGFILE', ecx_utils.g_logfile);
1525: ecx_utils.g_event.addParameterToList('ITEM_TYPE', ecx_utils.g_item_type);
1526: ecx_utils.g_event.addParameterToList('ITEM_KEY', ecx_utils.g_item_key);
1527: ecx_utils.g_event.addParameterToList('ACTIVITY_ID', ecx_utils.g_activity_id);
1528: ecx_utils.g_event.addParameterToList('EVENT_NAME', ecx_utils.g_event.event_name);
1529: ecx_utils.g_event.addParameterToList('EVENT_KEY', ecx_utils.g_event.event_key);
1522: ecx_utils.g_event.addParameterToList('ATTRIBUTE5', i_attribute5);
1523: ecx_utils.g_event.addParameterToList('TRIGGER_ID', i_trigger_id);
1524: ecx_utils.g_event.addParameterToList('LOGFILE', ecx_utils.g_logfile);
1525: ecx_utils.g_event.addParameterToList('ITEM_TYPE', ecx_utils.g_item_type);
1526: ecx_utils.g_event.addParameterToList('ITEM_KEY', ecx_utils.g_item_key);
1527: ecx_utils.g_event.addParameterToList('ACTIVITY_ID', ecx_utils.g_activity_id);
1528: ecx_utils.g_event.addParameterToList('EVENT_NAME', ecx_utils.g_event.event_name);
1529: ecx_utils.g_event.addParameterToList('EVENT_KEY', ecx_utils.g_event.event_key);
1530: ecx_utils.g_event.event_data := i_xmldoc;
1523: ecx_utils.g_event.addParameterToList('TRIGGER_ID', i_trigger_id);
1524: ecx_utils.g_event.addParameterToList('LOGFILE', ecx_utils.g_logfile);
1525: ecx_utils.g_event.addParameterToList('ITEM_TYPE', ecx_utils.g_item_type);
1526: ecx_utils.g_event.addParameterToList('ITEM_KEY', ecx_utils.g_item_key);
1527: ecx_utils.g_event.addParameterToList('ACTIVITY_ID', ecx_utils.g_activity_id);
1528: ecx_utils.g_event.addParameterToList('EVENT_NAME', ecx_utils.g_event.event_name);
1529: ecx_utils.g_event.addParameterToList('EVENT_KEY', ecx_utils.g_event.event_key);
1530: ecx_utils.g_event.event_data := i_xmldoc;
1531:
1524: ecx_utils.g_event.addParameterToList('LOGFILE', ecx_utils.g_logfile);
1525: ecx_utils.g_event.addParameterToList('ITEM_TYPE', ecx_utils.g_item_type);
1526: ecx_utils.g_event.addParameterToList('ITEM_KEY', ecx_utils.g_item_key);
1527: ecx_utils.g_event.addParameterToList('ACTIVITY_ID', ecx_utils.g_activity_id);
1528: ecx_utils.g_event.addParameterToList('EVENT_NAME', ecx_utils.g_event.event_name);
1529: ecx_utils.g_event.addParameterToList('EVENT_KEY', ecx_utils.g_event.event_key);
1530: ecx_utils.g_event.event_data := i_xmldoc;
1531:
1532: -- set the from agent
1525: ecx_utils.g_event.addParameterToList('ITEM_TYPE', ecx_utils.g_item_type);
1526: ecx_utils.g_event.addParameterToList('ITEM_KEY', ecx_utils.g_item_key);
1527: ecx_utils.g_event.addParameterToList('ACTIVITY_ID', ecx_utils.g_activity_id);
1528: ecx_utils.g_event.addParameterToList('EVENT_NAME', ecx_utils.g_event.event_name);
1529: ecx_utils.g_event.addParameterToList('EVENT_KEY', ecx_utils.g_event.event_key);
1530: ecx_utils.g_event.event_data := i_xmldoc;
1531:
1532: -- set the from agent
1533: select name
1526: ecx_utils.g_event.addParameterToList('ITEM_KEY', ecx_utils.g_item_key);
1527: ecx_utils.g_event.addParameterToList('ACTIVITY_ID', ecx_utils.g_activity_id);
1528: ecx_utils.g_event.addParameterToList('EVENT_NAME', ecx_utils.g_event.event_name);
1529: ecx_utils.g_event.addParameterToList('EVENT_KEY', ecx_utils.g_event.event_key);
1530: ecx_utils.g_event.event_data := i_xmldoc;
1531:
1532: -- set the from agent
1533: select name
1534: into i_system
1539: if (upper(i_destination_type) = 'SOAP') then
1540: i_from_agt.setname('WF_WS_JMS_OUT');
1541:
1542: -- set default Web Services related attributes
1543: ecx_utils.g_event.addParameterToList('WS_SERVICE_NAMESPACE',
1544: 'urn:defaultSoapMessaging');
1545: ecx_utils.g_event.addParameterToList('WS_PORT_OPERATION',
1546: 'ReceiveDocument');
1547: ecx_utils.g_event.addParameterToList('WS_HEADER_IMPL_CLASS',
1541:
1542: -- set default Web Services related attributes
1543: ecx_utils.g_event.addParameterToList('WS_SERVICE_NAMESPACE',
1544: 'urn:defaultSoapMessaging');
1545: ecx_utils.g_event.addParameterToList('WS_PORT_OPERATION',
1546: 'ReceiveDocument');
1547: ecx_utils.g_event.addParameterToList('WS_HEADER_IMPL_CLASS',
1548: 'oracle.apps.fnd.wf.ws.client.DefaultHeaderGenerator');
1549: ecx_utils.g_event.addParameterToList('WS_RESPONSE_IMPL_CLASS',
1543: ecx_utils.g_event.addParameterToList('WS_SERVICE_NAMESPACE',
1544: 'urn:defaultSoapMessaging');
1545: ecx_utils.g_event.addParameterToList('WS_PORT_OPERATION',
1546: 'ReceiveDocument');
1547: ecx_utils.g_event.addParameterToList('WS_HEADER_IMPL_CLASS',
1548: 'oracle.apps.fnd.wf.ws.client.DefaultHeaderGenerator');
1549: ecx_utils.g_event.addParameterToList('WS_RESPONSE_IMPL_CLASS',
1550: 'oracle.apps.fnd.wf.ws.client.WfWsResponse');
1551: ecx_utils.g_event.addParameterToList('WS_CONSUMER', 'ecx');
1545: ecx_utils.g_event.addParameterToList('WS_PORT_OPERATION',
1546: 'ReceiveDocument');
1547: ecx_utils.g_event.addParameterToList('WS_HEADER_IMPL_CLASS',
1548: 'oracle.apps.fnd.wf.ws.client.DefaultHeaderGenerator');
1549: ecx_utils.g_event.addParameterToList('WS_RESPONSE_IMPL_CLASS',
1550: 'oracle.apps.fnd.wf.ws.client.WfWsResponse');
1551: ecx_utils.g_event.addParameterToList('WS_CONSUMER', 'ecx');
1552:
1553: else
1547: ecx_utils.g_event.addParameterToList('WS_HEADER_IMPL_CLASS',
1548: 'oracle.apps.fnd.wf.ws.client.DefaultHeaderGenerator');
1549: ecx_utils.g_event.addParameterToList('WS_RESPONSE_IMPL_CLASS',
1550: 'oracle.apps.fnd.wf.ws.client.WfWsResponse');
1551: ecx_utils.g_event.addParameterToList('WS_CONSUMER', 'ecx');
1552:
1553: else
1554:
1555: if (upper(i_destination_type) = 'JMS') then
1563: end if;
1564:
1565: end if;
1566: i_from_agt.setsystem(i_system);
1567: ecx_utils.g_event.setFromAgent(i_from_agt);
1568:
1569: if(l_statementEnabled) then
1570: ecx_debug.log(l_statement, 'Calling WF_EVENT.Send for Enqueue', i_method_name);
1571: end if;
1568:
1569: if(l_statementEnabled) then
1570: ecx_debug.log(l_statement, 'Calling WF_EVENT.Send for Enqueue', i_method_name);
1571: end if;
1572: wf_event.send(ecx_utils.g_event);
1573: ecx_errorlog.outbound_log(ecx_utils.g_event);
1574:
1575: if (upper(i_destination_type) = 'SOAP') or
1576: (upper(i_destination_type) = 'JMS') then
1569: if(l_statementEnabled) then
1570: ecx_debug.log(l_statement, 'Calling WF_EVENT.Send for Enqueue', i_method_name);
1571: end if;
1572: wf_event.send(ecx_utils.g_event);
1573: ecx_errorlog.outbound_log(ecx_utils.g_event);
1574:
1575: if (upper(i_destination_type) = 'SOAP') or
1576: (upper(i_destination_type) = 'JMS') then
1577: i_msgid := wf_event.g_msgid; -- JMS QH store enqueue msgid in wf_event.g_msgid
1584: -- exception is raised in this case)
1585: if (ecx_out_wf_qh.retmsg is not null) then
1586: ecx_debug.setErrorInfo(ecx_out_wf_qh.retcode, 30, ecx_out_wf_qh.retmsg);
1587: if(l_unexpectedEnabled) then
1588: ecx_debug.log(l_unexpected, ecx_utils.i_errbuf,i_method_name);
1589: end if;
1590: end if;
1591:
1592: if dbms_lob.istemporary(i_xmldoc) = 1 then
1603: if NOT ( i_direct )
1604: then
1605: ecx_debug.print_log;
1606: ecx_debug.disable_debug;
1607: ecx_utils.g_logfile:=null;
1608: end if;
1609:
1610: EXCEPTION
1611: WHEN ecx_utils.PROGRAM_EXIT then
1607: ecx_utils.g_logfile:=null;
1608: end if;
1609:
1610: EXCEPTION
1611: WHEN ecx_utils.PROGRAM_EXIT then
1612: if dbms_lob.istemporary(i_xmldoc) = 1 then
1613: dbms_lob.freetemporary(i_xmldoc);
1614: end if;
1615: if (l_procedureEnabled) then
1618: if NOT ( i_direct )
1619: then
1620: ecx_debug.print_log;
1621: ecx_debug.disable_debug;
1622: ecx_utils.g_logfile:=null;
1623:
1624: ecx_errorlog.outbound_engine
1625: (
1626: i_trigger_id,
1623:
1624: ecx_errorlog.outbound_engine
1625: (
1626: i_trigger_id,
1627: ecx_utils.i_ret_code,
1628: ecx_utils.i_errbuf,
1629: i_msgid,
1630: null,
1631: i_party_type
1624: ecx_errorlog.outbound_engine
1625: (
1626: i_trigger_id,
1627: ecx_utils.i_ret_code,
1628: ecx_utils.i_errbuf,
1629: i_msgid,
1630: null,
1631: i_party_type
1632: );
1631: i_party_type
1632: );
1633:
1634: else
1635: raise ecx_utils.program_exit;
1636: end if;
1637:
1638: WHEN OTHERS THEN
1639: if (ecx_out_wf_qh.retmsg is null AND ecx_out_wf_qh.retcode = 0)
1645: else
1646: ecx_debug.setErrorInfo(ecx_out_wf_qh.retcode, 30, ecx_out_wf_qh.retmsg);
1647: if(l_unexpectedEnabled) then
1648: ecx_debug.log(l_unexpected, 'msg and code set in queue handler',i_method_name);
1649: ecx_debug.log(l_unexpected,ecx_utils.i_errbuf,i_method_name);
1650: end if;
1651: end if;
1652:
1653: if dbms_lob.istemporary(i_xmldoc) = 1 then
1661: then
1662: IF (ecx_logging_enabled ) THEN
1663: ecx_debug.print_log;
1664: ecx_debug.disable_debug;
1665: ecx_utils.g_logfile:=null;
1666: END IF;
1667: ecx_errorlog.outbound_engine
1668: (
1669: i_trigger_id,
1666: END IF;
1667: ecx_errorlog.outbound_engine
1668: (
1669: i_trigger_id,
1670: ecx_utils.i_ret_code,
1671: ecx_utils.i_errbuf,
1672: i_msgid,
1673: null,
1674: i_party_type
1667: ecx_errorlog.outbound_engine
1668: (
1669: i_trigger_id,
1670: ecx_utils.i_ret_code,
1671: ecx_utils.i_errbuf,
1672: i_msgid,
1673: null,
1674: i_party_type
1675: );
1673: null,
1674: i_party_type
1675: );
1676: else
1677: raise ecx_utils.program_exit;
1678: end if;
1679:
1680: end putmsg;
1681:
1739: Populate the Parameters in the global event Object .if it is null ,
1740: initialize and create a new Instance and populate the variables
1741: **/
1742:
1743: if ecx_utils.g_event is null
1744: then
1745: wf_event_t.initialize(ecx_utils.g_event);
1746:
1747: end if;
1741: **/
1742:
1743: if ecx_utils.g_event is null
1744: then
1745: wf_event_t.initialize(ecx_utils.g_event);
1746:
1747: end if;
1748:
1749: /* Add the above Parameters to the Global Event Message Object
1748:
1749: /* Add the above Parameters to the Global Event Message Object
1750: For backward compatability */
1751:
1752: ecx_utils.g_event.addparametertolist('PARAMETER1',i_parameter1);
1753: ecx_utils.g_event.addparametertolist('PARAMETER2',i_parameter2);
1754: ecx_utils.g_event.addparametertolist('PARAMETER3',i_parameter3);
1755: ecx_utils.g_event.addparametertolist('PARAMETER4',i_parameter4);
1756: ecx_utils.g_event.addparametertolist('PARAMETER5',i_parameter5);
1749: /* Add the above Parameters to the Global Event Message Object
1750: For backward compatability */
1751:
1752: ecx_utils.g_event.addparametertolist('PARAMETER1',i_parameter1);
1753: ecx_utils.g_event.addparametertolist('PARAMETER2',i_parameter2);
1754: ecx_utils.g_event.addparametertolist('PARAMETER3',i_parameter3);
1755: ecx_utils.g_event.addparametertolist('PARAMETER4',i_parameter4);
1756: ecx_utils.g_event.addparametertolist('PARAMETER5',i_parameter5);
1757:
1750: For backward compatability */
1751:
1752: ecx_utils.g_event.addparametertolist('PARAMETER1',i_parameter1);
1753: ecx_utils.g_event.addparametertolist('PARAMETER2',i_parameter2);
1754: ecx_utils.g_event.addparametertolist('PARAMETER3',i_parameter3);
1755: ecx_utils.g_event.addparametertolist('PARAMETER4',i_parameter4);
1756: ecx_utils.g_event.addparametertolist('PARAMETER5',i_parameter5);
1757:
1758: putmsg( i_transaction_type ,
1751:
1752: ecx_utils.g_event.addparametertolist('PARAMETER1',i_parameter1);
1753: ecx_utils.g_event.addparametertolist('PARAMETER2',i_parameter2);
1754: ecx_utils.g_event.addparametertolist('PARAMETER3',i_parameter3);
1755: ecx_utils.g_event.addparametertolist('PARAMETER4',i_parameter4);
1756: ecx_utils.g_event.addparametertolist('PARAMETER5',i_parameter5);
1757:
1758: putmsg( i_transaction_type ,
1759: i_transaction_subtype ,
1752: ecx_utils.g_event.addparametertolist('PARAMETER1',i_parameter1);
1753: ecx_utils.g_event.addparametertolist('PARAMETER2',i_parameter2);
1754: ecx_utils.g_event.addparametertolist('PARAMETER3',i_parameter3);
1755: ecx_utils.g_event.addparametertolist('PARAMETER4',i_parameter4);
1756: ecx_utils.g_event.addparametertolist('PARAMETER5',i_parameter5);
1757:
1758: putmsg( i_transaction_type ,
1759: i_transaction_subtype ,
1760: i_party_id ,
1785: if(l_unexpectedEnabled) then
1786: ecx_debug.log(l_unexpected,'ECX', SQLERRM || ' - ECX_OUTBOUND.putmsg ',
1787: i_method_name);
1788: end if;
1789: raise ecx_utils.PROGRAM_EXIT;
1790: end putmsg;
1791:
1792: procedure GETXML
1793: (
1850: end if;
1851:
1852: IF (ecx_logging_enabled ) THEN
1853: --- Sets the Log Directory in both Standalone and the Embedded mode
1854: ecx_utils.getLogDirectory;
1855:
1856: /** Fetch the Run Id for the Transaction **/
1857: open get_run_s;
1858: fetch get_run_s
1855:
1856: /** Fetch the Run Id for the Transaction **/
1857: open get_run_s;
1858: fetch get_run_s
1859: into ecx_utils.g_run_id;
1860: close get_run_s;
1861:
1862: ecx_utils.g_logfile :=i_message_standard||'OUT'||
1863: i_transaction_type||i_transaction_subtype||i_document_id||ecx_utils.g_run_id||'.log';
1858: fetch get_run_s
1859: into ecx_utils.g_run_id;
1860: close get_run_s;
1861:
1862: ecx_utils.g_logfile :=i_message_standard||'OUT'||
1863: i_transaction_type||i_transaction_subtype||i_document_id||ecx_utils.g_run_id||'.log';
1864:
1865: p_aflog_module_name := '';
1866: IF (i_message_standard is not null) THEN
1859: into ecx_utils.g_run_id;
1860: close get_run_s;
1861:
1862: ecx_utils.g_logfile :=i_message_standard||'OUT'||
1863: i_transaction_type||i_transaction_subtype||i_document_id||ecx_utils.g_run_id||'.log';
1864:
1865: p_aflog_module_name := '';
1866: IF (i_message_standard is not null) THEN
1867: p_aflog_module_name := p_aflog_module_name||i_message_standard||'.';
1875: END IF;
1876: IF (i_document_id is not null) THEN
1877: p_aflog_module_name := p_aflog_module_name||i_document_id||'.';
1878: END IF;
1879: IF (ecx_utils.g_run_id is not null) THEN
1880: p_aflog_module_name := p_aflog_module_name||ecx_utils.g_run_id;
1881: END IF;
1882: p_aflog_module_name := p_aflog_module_name||'.log';
1883: ecx_debug.enable_debug_new(i_debug_level,ecx_utils.g_logdir,ecx_utils.g_logfile, p_aflog_module_name);
1876: IF (i_document_id is not null) THEN
1877: p_aflog_module_name := p_aflog_module_name||i_document_id||'.';
1878: END IF;
1879: IF (ecx_utils.g_run_id is not null) THEN
1880: p_aflog_module_name := p_aflog_module_name||ecx_utils.g_run_id;
1881: END IF;
1882: p_aflog_module_name := p_aflog_module_name||'.log';
1883: ecx_debug.enable_debug_new(i_debug_level,ecx_utils.g_logdir,ecx_utils.g_logfile, p_aflog_module_name);
1884: END IF;
1879: IF (ecx_utils.g_run_id is not null) THEN
1880: p_aflog_module_name := p_aflog_module_name||ecx_utils.g_run_id;
1881: END IF;
1882: p_aflog_module_name := p_aflog_module_name||'.log';
1883: ecx_debug.enable_debug_new(i_debug_level,ecx_utils.g_logdir,ecx_utils.g_logfile, p_aflog_module_name);
1884: END IF;
1885:
1886: IF g_instlmode = 'EMBEDDED' THEN
1887: IF (ecx_logging_enabled ) THEN
1890: i_log_file := 'Please ensure that FND-Logging is enabled for module '||ecx_debug.g_sqlprefix||'%';
1891: END IF;
1892: ELSE
1893: if (ecx_logging_enabled) then
1894: i_log_file := ecx_utils.g_logdir||ecx_utils.getFileSeparator()||ecx_utils.g_logfile;
1895: else
1896: i_log_file := 'Please ensure that logging is enabled';
1897: end if;
1898: END IF;
1941: then
1942: dbms_lob.freetemporary (i_tmpxmldoc);
1943: end if;
1944: ecx_debug.setErrorInfo(0, 10, 'ECX_SUCCESSFUL_EXECUTION');
1945: i_ret_code := ecx_utils.i_ret_code;
1946: i_errbuf := ecx_utils.i_errbuf;
1947:
1948: if(ecx_utils.i_ret_code = 0 ) then
1949: if(l_statementEnabled) then
1942: dbms_lob.freetemporary (i_tmpxmldoc);
1943: end if;
1944: ecx_debug.setErrorInfo(0, 10, 'ECX_SUCCESSFUL_EXECUTION');
1945: i_ret_code := ecx_utils.i_ret_code;
1946: i_errbuf := ecx_utils.i_errbuf;
1947:
1948: if(ecx_utils.i_ret_code = 0 ) then
1949: if(l_statementEnabled) then
1950: ecx_debug.log(l_statement, 'Ret Code',ecx_utils.i_ret_code,i_method_name);
1944: ecx_debug.setErrorInfo(0, 10, 'ECX_SUCCESSFUL_EXECUTION');
1945: i_ret_code := ecx_utils.i_ret_code;
1946: i_errbuf := ecx_utils.i_errbuf;
1947:
1948: if(ecx_utils.i_ret_code = 0 ) then
1949: if(l_statementEnabled) then
1950: ecx_debug.log(l_statement, 'Ret Code',ecx_utils.i_ret_code,i_method_name);
1951: ecx_debug.log(l_statement, 'Ret Msg ',ecx_utils.i_errbuf,i_method_name);
1952: end if;
1946: i_errbuf := ecx_utils.i_errbuf;
1947:
1948: if(ecx_utils.i_ret_code = 0 ) then
1949: if(l_statementEnabled) then
1950: ecx_debug.log(l_statement, 'Ret Code',ecx_utils.i_ret_code,i_method_name);
1951: ecx_debug.log(l_statement, 'Ret Msg ',ecx_utils.i_errbuf,i_method_name);
1952: end if;
1953: else
1954: if(l_unexpectedEnabled) then
1947:
1948: if(ecx_utils.i_ret_code = 0 ) then
1949: if(l_statementEnabled) then
1950: ecx_debug.log(l_statement, 'Ret Code',ecx_utils.i_ret_code,i_method_name);
1951: ecx_debug.log(l_statement, 'Ret Msg ',ecx_utils.i_errbuf,i_method_name);
1952: end if;
1953: else
1954: if(l_unexpectedEnabled) then
1955: ecx_debug.log(l_unexpected, 'Ret Code',ecx_utils.i_ret_code,i_method_name);
1951: ecx_debug.log(l_statement, 'Ret Msg ',ecx_utils.i_errbuf,i_method_name);
1952: end if;
1953: else
1954: if(l_unexpectedEnabled) then
1955: ecx_debug.log(l_unexpected, 'Ret Code',ecx_utils.i_ret_code,i_method_name);
1956: ecx_debug.log(l_unexpected, 'Ret Msg ',ecx_utils.i_errbuf,i_method_name);
1957: end if;
1958: end if;
1959:
1952: end if;
1953: else
1954: if(l_unexpectedEnabled) then
1955: ecx_debug.log(l_unexpected, 'Ret Code',ecx_utils.i_ret_code,i_method_name);
1956: ecx_debug.log(l_unexpected, 'Ret Msg ',ecx_utils.i_errbuf,i_method_name);
1957: end if;
1958: end if;
1959:
1960: if(l_procedureEnabled) then
1964: ecx_debug.print_log;
1965: ecx_debug.disable_debug;
1966: END IF;
1967: EXCEPTION
1968: WHEN ecx_utils.program_exit THEN
1969: i_ret_code := ecx_utils.i_ret_code;
1970: i_errbuf := ecx_utils.i_errbuf;
1971: if(l_unexpectedEnabled) then
1972: ecx_debug.log(l_unexpected,ecx_utils.i_errbuf,i_method_name);
1965: ecx_debug.disable_debug;
1966: END IF;
1967: EXCEPTION
1968: WHEN ecx_utils.program_exit THEN
1969: i_ret_code := ecx_utils.i_ret_code;
1970: i_errbuf := ecx_utils.i_errbuf;
1971: if(l_unexpectedEnabled) then
1972: ecx_debug.log(l_unexpected,ecx_utils.i_errbuf,i_method_name);
1973: end if;
1966: END IF;
1967: EXCEPTION
1968: WHEN ecx_utils.program_exit THEN
1969: i_ret_code := ecx_utils.i_ret_code;
1970: i_errbuf := ecx_utils.i_errbuf;
1971: if(l_unexpectedEnabled) then
1972: ecx_debug.log(l_unexpected,ecx_utils.i_errbuf,i_method_name);
1973: end if;
1974: if(l_procedureEnabled) then
1968: WHEN ecx_utils.program_exit THEN
1969: i_ret_code := ecx_utils.i_ret_code;
1970: i_errbuf := ecx_utils.i_errbuf;
1971: if(l_unexpectedEnabled) then
1972: ecx_debug.log(l_unexpected,ecx_utils.i_errbuf,i_method_name);
1973: end if;
1974: if(l_procedureEnabled) then
1975: ecx_debug.pop(i_method_name);
1976: end if;
1987: ecx_debug.setErrorInfo(2, 30, SQLERRM || ' - ECX_OUTBOUND.PUTMSG');
1988: if(l_unexpectedEnabled) then
1989: ecx_debug.log(l_unexpected,'ECX', SQLERRM || ' - ECX_OUTBOUND.PUTMSG',i_method_name);
1990: end if;
1991: i_ret_code := ecx_utils.i_ret_code;
1992: i_errbuf := ecx_utils.i_errbuf;
1993: if(l_procedureEnabled) then
1994: ecx_debug.pop(i_method_name);
1995: end if;
1988: if(l_unexpectedEnabled) then
1989: ecx_debug.log(l_unexpected,'ECX', SQLERRM || ' - ECX_OUTBOUND.PUTMSG',i_method_name);
1990: end if;
1991: i_ret_code := ecx_utils.i_ret_code;
1992: i_errbuf := ecx_utils.i_errbuf;
1993: if(l_procedureEnabled) then
1994: ecx_debug.pop(i_method_name);
1995: end if;
1996: -- free i_tmpxmldoc