82: -- set debug level
83: l_debug_level := to_number(nvl(fnd_profile.value('CLN_DEBUG_LEVEL'), '5'));
84:
85: if (l_debug_level <= 2) then
86: cln_debug_pub.Add('ENTERING CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event', 1);
87: end if;
88:
89: if (l_debug_level <= 1) then
90: cln_debug_pub.Add('With the following parameters:', 1);
86: cln_debug_pub.Add('ENTERING CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event', 1);
87: end if;
88:
89: if (l_debug_level <= 1) then
90: cln_debug_pub.Add('With the following parameters:', 1);
91: cln_debug_pub.Add('p_tp_header_id:' || p_tp_header_id, 1);
92: cln_debug_pub.Add('p_list_header_id:' || p_list_header_id, 1);
93: cln_debug_pub.Add('p_category_id:' || p_category_id, 1);
94: cln_debug_pub.Add('p_from_items:' || p_from_items, 1);
87: end if;
88:
89: if (l_debug_level <= 1) then
90: cln_debug_pub.Add('With the following parameters:', 1);
91: cln_debug_pub.Add('p_tp_header_id:' || p_tp_header_id, 1);
92: cln_debug_pub.Add('p_list_header_id:' || p_list_header_id, 1);
93: cln_debug_pub.Add('p_category_id:' || p_category_id, 1);
94: cln_debug_pub.Add('p_from_items:' || p_from_items, 1);
95: cln_debug_pub.Add('p_to_items:' || p_to_items, 1);
88:
89: if (l_debug_level <= 1) then
90: cln_debug_pub.Add('With the following parameters:', 1);
91: cln_debug_pub.Add('p_tp_header_id:' || p_tp_header_id, 1);
92: cln_debug_pub.Add('p_list_header_id:' || p_list_header_id, 1);
93: cln_debug_pub.Add('p_category_id:' || p_category_id, 1);
94: cln_debug_pub.Add('p_from_items:' || p_from_items, 1);
95: cln_debug_pub.Add('p_to_items:' || p_to_items, 1);
96: cln_debug_pub.Add('p_currency_detail_id:' || p_currency_detail_id, 1);
89: if (l_debug_level <= 1) then
90: cln_debug_pub.Add('With the following parameters:', 1);
91: cln_debug_pub.Add('p_tp_header_id:' || p_tp_header_id, 1);
92: cln_debug_pub.Add('p_list_header_id:' || p_list_header_id, 1);
93: cln_debug_pub.Add('p_category_id:' || p_category_id, 1);
94: cln_debug_pub.Add('p_from_items:' || p_from_items, 1);
95: cln_debug_pub.Add('p_to_items:' || p_to_items, 1);
96: cln_debug_pub.Add('p_currency_detail_id:' || p_currency_detail_id, 1);
97: cln_debug_pub.Add('p_numitems_per_oag:' || p_numitems_per_oag, 1);
90: cln_debug_pub.Add('With the following parameters:', 1);
91: cln_debug_pub.Add('p_tp_header_id:' || p_tp_header_id, 1);
92: cln_debug_pub.Add('p_list_header_id:' || p_list_header_id, 1);
93: cln_debug_pub.Add('p_category_id:' || p_category_id, 1);
94: cln_debug_pub.Add('p_from_items:' || p_from_items, 1);
95: cln_debug_pub.Add('p_to_items:' || p_to_items, 1);
96: cln_debug_pub.Add('p_currency_detail_id:' || p_currency_detail_id, 1);
97: cln_debug_pub.Add('p_numitems_per_oag:' || p_numitems_per_oag, 1);
98: end if;
91: cln_debug_pub.Add('p_tp_header_id:' || p_tp_header_id, 1);
92: cln_debug_pub.Add('p_list_header_id:' || p_list_header_id, 1);
93: cln_debug_pub.Add('p_category_id:' || p_category_id, 1);
94: cln_debug_pub.Add('p_from_items:' || p_from_items, 1);
95: cln_debug_pub.Add('p_to_items:' || p_to_items, 1);
96: cln_debug_pub.Add('p_currency_detail_id:' || p_currency_detail_id, 1);
97: cln_debug_pub.Add('p_numitems_per_oag:' || p_numitems_per_oag, 1);
98: end if;
99:
92: cln_debug_pub.Add('p_list_header_id:' || p_list_header_id, 1);
93: cln_debug_pub.Add('p_category_id:' || p_category_id, 1);
94: cln_debug_pub.Add('p_from_items:' || p_from_items, 1);
95: cln_debug_pub.Add('p_to_items:' || p_to_items, 1);
96: cln_debug_pub.Add('p_currency_detail_id:' || p_currency_detail_id, 1);
97: cln_debug_pub.Add('p_numitems_per_oag:' || p_numitems_per_oag, 1);
98: end if;
99:
100: -- initialize parameters
93: cln_debug_pub.Add('p_category_id:' || p_category_id, 1);
94: cln_debug_pub.Add('p_from_items:' || p_from_items, 1);
95: cln_debug_pub.Add('p_to_items:' || p_to_items, 1);
96: cln_debug_pub.Add('p_currency_detail_id:' || p_currency_detail_id, 1);
97: cln_debug_pub.Add('p_numitems_per_oag:' || p_numitems_per_oag, 1);
98: end if;
99:
100: -- initialize parameters
101: x_progress := '000';
123: items_exist := FALSE;
124: msgs_sent_flag := FALSE;
125:
126: if (l_debug_level <= 1) then
127: cln_debug_pub.Add('p_tp_header_id:' || p_tp_header_id, 1);
128: end if;
129:
130: select eth.party_id, eth.party_site_id
131: into party_id, party_site_id
132: from ecx_tp_headers eth
133: where eth.tp_header_id = p_tp_header_id;
134:
135: if (l_debug_level <= 1) then
136: cln_debug_pub.Add('party_id:' || party_id, 1);
137: cln_debug_pub.Add('party_site_id:' || party_site_id, 1);
138: end if;
139:
140: select FND_PROFILE.VALUE('ORG_ID')
133: where eth.tp_header_id = p_tp_header_id;
134:
135: if (l_debug_level <= 1) then
136: cln_debug_pub.Add('party_id:' || party_id, 1);
137: cln_debug_pub.Add('party_site_id:' || party_site_id, 1);
138: end if;
139:
140: select FND_PROFILE.VALUE('ORG_ID')
141: into l_operating_unit_id
141: into l_operating_unit_id
142: from dual;
143:
144: if (l_debug_level <= 1) then
145: cln_debug_pub.Add('l_operating_unit_id:' || l_operating_unit_id, 1);
146: end if;
147:
148: l_inv_org_id := qp_util.Get_Item_Validation_Org;
149: if (l_debug_level <= 1) then
146: end if;
147:
148: l_inv_org_id := qp_util.Get_Item_Validation_Org;
149: if (l_debug_level <= 1) then
150: cln_debug_pub.Add('l_inv_org_id:' || l_inv_org_id, 1);
151: end if;
152:
153: select haou.name, hla.ece_tp_location_code
154: into l_publisher_name, l_publisher_partnridx
156: where haou.location_id = hla.location_id
157: and haou.organization_id = l_operating_unit_id;
158:
159: if (l_debug_level <= 1) then
160: cln_debug_pub.Add('l_publisher_name:' || l_publisher_name, 1);
161: cln_debug_pub.Add('l_publisher_partnridx:' || l_publisher_partnridx, 1);
162: end if;
163:
164: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Parameters Initialized';
157: and haou.organization_id = l_operating_unit_id;
158:
159: if (l_debug_level <= 1) then
160: cln_debug_pub.Add('l_publisher_name:' || l_publisher_name, 1);
161: cln_debug_pub.Add('l_publisher_partnridx:' || l_publisher_partnridx, 1);
162: end if;
163:
164: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Parameters Initialized';
165: if (l_debug_level <= 1) then
162: end if;
163:
164: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Parameters Initialized';
165: if (l_debug_level <= 1) then
166: cln_debug_pub.Add('Failure point ' || x_progress, 1);
167: end if;
168:
169: -- XML Setup Check
170: if (l_debug_level <= 1) then
167: end if;
168:
169: -- XML Setup Check
170: if (l_debug_level <= 1) then
171: cln_debug_pub.Add('Parameters before ecx_document.isDeliveryRequired:', 1);
172: cln_debug_pub.Add('transaction_type:' || transaction_type, 1);
173: cln_debug_pub.Add('transaction_subtype:' || transaction_subtype, 1);
174: cln_debug_pub.Add('party_id:' || party_id, 1);
175: cln_debug_pub.Add('party_site_id:' || party_site_id, 1);
168:
169: -- XML Setup Check
170: if (l_debug_level <= 1) then
171: cln_debug_pub.Add('Parameters before ecx_document.isDeliveryRequired:', 1);
172: cln_debug_pub.Add('transaction_type:' || transaction_type, 1);
173: cln_debug_pub.Add('transaction_subtype:' || transaction_subtype, 1);
174: cln_debug_pub.Add('party_id:' || party_id, 1);
175: cln_debug_pub.Add('party_site_id:' || party_site_id, 1);
176: cln_debug_pub.Add('return_code:' || return_code, 1);
169: -- XML Setup Check
170: if (l_debug_level <= 1) then
171: cln_debug_pub.Add('Parameters before ecx_document.isDeliveryRequired:', 1);
172: cln_debug_pub.Add('transaction_type:' || transaction_type, 1);
173: cln_debug_pub.Add('transaction_subtype:' || transaction_subtype, 1);
174: cln_debug_pub.Add('party_id:' || party_id, 1);
175: cln_debug_pub.Add('party_site_id:' || party_site_id, 1);
176: cln_debug_pub.Add('return_code:' || return_code, 1);
177: cln_debug_pub.Add('errmsg:' || errmsg, 1);
170: if (l_debug_level <= 1) then
171: cln_debug_pub.Add('Parameters before ecx_document.isDeliveryRequired:', 1);
172: cln_debug_pub.Add('transaction_type:' || transaction_type, 1);
173: cln_debug_pub.Add('transaction_subtype:' || transaction_subtype, 1);
174: cln_debug_pub.Add('party_id:' || party_id, 1);
175: cln_debug_pub.Add('party_site_id:' || party_site_id, 1);
176: cln_debug_pub.Add('return_code:' || return_code, 1);
177: cln_debug_pub.Add('errmsg:' || errmsg, 1);
178: end if;
171: cln_debug_pub.Add('Parameters before ecx_document.isDeliveryRequired:', 1);
172: cln_debug_pub.Add('transaction_type:' || transaction_type, 1);
173: cln_debug_pub.Add('transaction_subtype:' || transaction_subtype, 1);
174: cln_debug_pub.Add('party_id:' || party_id, 1);
175: cln_debug_pub.Add('party_site_id:' || party_site_id, 1);
176: cln_debug_pub.Add('return_code:' || return_code, 1);
177: cln_debug_pub.Add('errmsg:' || errmsg, 1);
178: end if;
179:
172: cln_debug_pub.Add('transaction_type:' || transaction_type, 1);
173: cln_debug_pub.Add('transaction_subtype:' || transaction_subtype, 1);
174: cln_debug_pub.Add('party_id:' || party_id, 1);
175: cln_debug_pub.Add('party_site_id:' || party_site_id, 1);
176: cln_debug_pub.Add('return_code:' || return_code, 1);
177: cln_debug_pub.Add('errmsg:' || errmsg, 1);
178: end if;
179:
180: ecx_document.isDeliveryRequired(
173: cln_debug_pub.Add('transaction_subtype:' || transaction_subtype, 1);
174: cln_debug_pub.Add('party_id:' || party_id, 1);
175: cln_debug_pub.Add('party_site_id:' || party_site_id, 1);
176: cln_debug_pub.Add('return_code:' || return_code, 1);
177: cln_debug_pub.Add('errmsg:' || errmsg, 1);
178: end if;
179:
180: ecx_document.isDeliveryRequired(
181: transaction_type => transaction_type,
186: retcode => return_code,
187: errmsg => errmsg);
188:
189: if (l_debug_level <= 1) then
190: cln_debug_pub.Add('Values returned from ecx_document.isDeliveryRequired:', 1);
191: cln_debug_pub.Add('return_code:' || return_code, 1);
192: cln_debug_pub.Add('errmsg:' || errmsg, 1);
193: end if;
194:
187: errmsg => errmsg);
188:
189: if (l_debug_level <= 1) then
190: cln_debug_pub.Add('Values returned from ecx_document.isDeliveryRequired:', 1);
191: cln_debug_pub.Add('return_code:' || return_code, 1);
192: cln_debug_pub.Add('errmsg:' || errmsg, 1);
193: end if;
194:
195: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : XML Setup Check';
188:
189: if (l_debug_level <= 1) then
190: cln_debug_pub.Add('Values returned from ecx_document.isDeliveryRequired:', 1);
191: cln_debug_pub.Add('return_code:' || return_code, 1);
192: cln_debug_pub.Add('errmsg:' || errmsg, 1);
193: end if;
194:
195: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : XML Setup Check';
196: if (l_debug_level <= 1) then
193: end if;
194:
195: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : XML Setup Check';
196: if (l_debug_level <= 1) then
197: cln_debug_pub.Add('Failure point ' || x_progress, 1);
198: end if;
199:
200: -- Decision on action depending on XML Setup Check
201: if (l_debug_level <= 1) then
198: end if;
199:
200: -- Decision on action depending on XML Setup Check
201: if (l_debug_level <= 1) then
202: cln_debug_pub.Add('Parameters:', 1);
203: cln_debug_pub.Add('p_numitems_per_oag:' || p_numitems_per_oag, 1);
204: end if;
205:
206: IF NOT(result) then
199:
200: -- Decision on action depending on XML Setup Check
201: if (l_debug_level <= 1) then
202: cln_debug_pub.Add('Parameters:', 1);
203: cln_debug_pub.Add('p_numitems_per_oag:' || p_numitems_per_oag, 1);
204: end if;
205:
206: IF NOT(result) then
207: --Trading partner not found. Nothing to do... Return from here
206: IF NOT(result) then
207: --Trading partner not found. Nothing to do... Return from here
208: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : No Trading Partner found during XML Setup Check';
209: if (l_debug_level <= 1) then
210: cln_debug_pub.Add('Failure point ' || x_progress, 1);
211: end if;
212:
213: ELSIF p_numitems_per_oag IS NULL then -- no number specified, send in one message
214:
213: ELSIF p_numitems_per_oag IS NULL then -- no number specified, send in one message
214:
215: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : No Number Limit Specified';
216: if (l_debug_level <= 1) then
217: cln_debug_pub.Add('Failure point ' || x_progress, 1);
218: end if;
219:
220: -- create unique key
221: SELECT CLN_SYNCCTLG_S.nextval into l_syncctlg_seq from dual;
219:
220: -- create unique key
221: SELECT CLN_SYNCCTLG_S.nextval into l_syncctlg_seq from dual;
222: if (l_debug_level <= 1) then
223: cln_debug_pub.Add('l_syncctlg_seq:' || l_syncctlg_seq, 1);
224: end if;
225: l_event_key := to_char(p_list_header_id) || '.' || to_char(l_syncctlg_seq);
226:
227: SELECT sysdate into l_date from dual;
225: l_event_key := to_char(p_list_header_id) || '.' || to_char(l_syncctlg_seq);
226:
227: SELECT sysdate into l_date from dual;
228: if (l_debug_level <= 1) then
229: cln_debug_pub.Add('l_date:' || l_date, 1);
230: end if;
231: l_canonical_date := FND_DATE.DATE_TO_CANONICAL(l_date);
232:
233: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Created Unique Key';
231: l_canonical_date := FND_DATE.DATE_TO_CANONICAL(l_date);
232:
233: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Created Unique Key';
234: if (l_debug_level <= 1) then
235: cln_debug_pub.Add('Failure point ' || x_progress, 1);
236: end if;
237:
238: -- add parameters to list for create collaboration event
239: wf_event.AddParameterToList(p_name => 'XMLG_INTERNAL_TXN_TYPE',
268: p_parameterlist => l_create_cln_parameter_list);
269:
270: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Initialize Create Event Parameters';
271: if (l_debug_level <= 1) then
272: cln_debug_pub.Add('Failure point ' || x_progress, 1);
273: end if;
274:
275: -- raise create collaboration event
276: wf_event.raise(p_event_name => l_create_cln_event,
278: p_parameters => l_create_cln_parameter_list);
279:
280: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Create Event Raised';
281: if (l_debug_level <= 1) then
282: cln_debug_pub.Add('Failure point ' || x_progress, 1);
283: end if;
284:
285: -- test to see if message contains any items
286: OPEN c_ItemsToSend;
285: -- test to see if message contains any items
286: OPEN c_ItemsToSend;
287: FETCH c_ItemsToSend into l_subset_from;
288: if (l_debug_level <= 1) then
289: cln_debug_pub.Add('l_subset_from:' || l_subset_from, 1);
290: end if;
291: l_subset_from := NULL;
292:
293: if c_ItemsToSend%FOUND then
296: CLOSE c_ItemsToSend;
297:
298: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Items Existence Check';
299: if (l_debug_level <= 1) then
300: cln_debug_pub.Add('Failure point ' || x_progress, 1);
301: end if;
302:
303: -- Decision on action depending on XML Setup Check
304: if (items_exist) then
303: -- Decision on action depending on XML Setup Check
304: if (items_exist) then
305: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Items Exist in Price List';
306: if (l_debug_level <= 1) then
307: cln_debug_pub.Add('Failure point ' || x_progress, 1);
308: end if;
309:
310: -- add parameters to list for send show shipment document
311: wf_event.AddParameterToList(p_name => 'ECX_TRANSACTION_TYPE',
406: p_parameterlist => l_send_syct_parameter_list);
407:
408: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Send Document Event Parameters Initialized';
409: if (l_debug_level <= 1) then
410: cln_debug_pub.Add('Failure point ' || x_progress, 1);
411: end if;
412:
413: -- raise event for send show shipment document
414: wf_event.raise(p_event_name => l_send_syct_event,
417:
418: -- Reached Here. Successful execution.
419: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Send Document Event Raised';
420: if (l_debug_level <= 1) then
421: cln_debug_pub.Add('Failure point ' || x_progress, 1);
422: end if;
423:
424: else
425: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : No Items Exist in Price List';
423:
424: else
425: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : No Items Exist in Price List';
426: if (l_debug_level <= 1) then
427: cln_debug_pub.Add('Failure point ' || x_progress, 1);
428: end if;
429:
430: -- add parameters to list for update collaboration event
431: l_update_cln_parameter_list := wf_parameter_list_t();
467: p_parameterlist => l_update_cln_parameter_list);
468:
469: x_progress := 'CLN_SYNCITEM_PKG.Syncctlg_Raise_Event : Initialize update event parameters';
470: if (l_debug_level <= 1) then
471: cln_debug_pub.Add('Failure point ' || x_progress, 1);
472: end if;
473:
474: -- raise update collaboration event
475: wf_event.raise(p_event_name => l_update_cln_event,
477: p_parameters => l_update_cln_parameter_list);
478:
479: x_progress := 'CLN_SYNCITEM_PKG.Syncctlg_Raise_Event : Update Event Raised';
480: if (l_debug_level <= 1) then
481: cln_debug_pub.Add('Failure point ' || x_progress, 1);
482: end if;
483: end if;
484:
485: -- Reached Here. Successful execution.
484:
485: -- Reached Here. Successful execution.
486: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Exiting No Number Limit Specified Branch';
487: if (l_debug_level <= 1) then
488: cln_debug_pub.Add('Failure point ' || x_progress, 1);
489: end if;
490: else -- number of items specified
491: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Number Limit Specified';
492: if (l_debug_level <= 1) then
489: end if;
490: else -- number of items specified
491: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Number Limit Specified';
492: if (l_debug_level <= 1) then
493: cln_debug_pub.Add('Failure point ' || x_progress, 1);
494: end if;
495:
496: -- open cursor for all the documents that will be sent
497: OPEN c_ItemsToSend;
501: items_exist := FALSE; -- reset flag
502:
503: -- extract first item
504: if (l_debug_level <= 1) then
505: cln_debug_pub.Add('Parameters:', 1);
506: cln_debug_pub.Add('p_numitems_per_oag:' || p_numitems_per_oag, 1);
507: end if;
508:
509: if p_numitems_per_oag >= 1 then
502:
503: -- extract first item
504: if (l_debug_level <= 1) then
505: cln_debug_pub.Add('Parameters:', 1);
506: cln_debug_pub.Add('p_numitems_per_oag:' || p_numitems_per_oag, 1);
507: end if;
508:
509: if p_numitems_per_oag >= 1 then
510: FETCH c_ItemsToSend INTO l_subset_from;
508:
509: if p_numitems_per_oag >= 1 then
510: FETCH c_ItemsToSend INTO l_subset_from;
511: if (l_debug_level <= 1) then
512: cln_debug_pub.Add('l_subset_from:' || l_subset_from, 1);
513: end if;
514: l_subset_to := l_subset_from;
515:
516: -- check if there are items left in the cursor. set flag so that you will update with error message.
514: l_subset_to := l_subset_from;
515:
516: -- check if there are items left in the cursor. set flag so that you will update with error message.
517: if (l_debug_level <= 1) then
518: cln_debug_pub.Add('Parameters:', 1);
519: end if;
520:
521: if c_ItemsToSend%FOUND then
522: items_exist := TRUE;
524: end if;
525:
526: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : First Item Range' || l_subset_from;
527: if (l_debug_level <= 1) then
528: cln_debug_pub.Add('Failure point ' || x_progress, 1);
529: end if;
530:
531: if (l_debug_level <= 1) then
532: cln_debug_pub.Add('Parameters:', 1);
528: cln_debug_pub.Add('Failure point ' || x_progress, 1);
529: end if;
530:
531: if (l_debug_level <= 1) then
532: cln_debug_pub.Add('Parameters:', 1);
533: cln_debug_pub.Add('counter:' || counter, 1);
534: cln_debug_pub.Add('p_numitems_per_oag:' || p_numitems_per_oag, 1);
535: end if;
536:
529: end if;
530:
531: if (l_debug_level <= 1) then
532: cln_debug_pub.Add('Parameters:', 1);
533: cln_debug_pub.Add('counter:' || counter, 1);
534: cln_debug_pub.Add('p_numitems_per_oag:' || p_numitems_per_oag, 1);
535: end if;
536:
537: while counter < p_numitems_per_oag loop
530:
531: if (l_debug_level <= 1) then
532: cln_debug_pub.Add('Parameters:', 1);
533: cln_debug_pub.Add('counter:' || counter, 1);
534: cln_debug_pub.Add('p_numitems_per_oag:' || p_numitems_per_oag, 1);
535: end if;
536:
537: while counter < p_numitems_per_oag loop
538: FETCH c_ItemsToSend INTO l_subset_to; -- extract last item number
536:
537: while counter < p_numitems_per_oag loop
538: FETCH c_ItemsToSend INTO l_subset_to; -- extract last item number
539: if (l_debug_level <= 1) then
540: cln_debug_pub.Add('l_subset_to:' || l_subset_to, 1);
541: end if;
542: EXIT WHEN c_ItemsToSend%NOTFOUND; -- if we reached the end, then just send out what's left
543: counter := counter + 1;
544: end loop;
544: end loop;
545:
546: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Last Item Range' || l_subset_to;
547: if (l_debug_level <= 1) then
548: cln_debug_pub.Add('Failure point ' || x_progress, 1);
549: end if;
550:
551: -- create unique key
552: SELECT CLN_SYNCCTLG_S.nextval into l_syncctlg_seq from dual;
550:
551: -- create unique key
552: SELECT CLN_SYNCCTLG_S.nextval into l_syncctlg_seq from dual;
553: if (l_debug_level <= 1) then
554: cln_debug_pub.Add('l_syncctlg_seq:' || l_syncctlg_seq, 1);
555: end if;
556: l_event_key := to_char(p_list_header_id) || '.' || to_char(l_syncctlg_seq);
557:
558: SELECT sysdate into l_date from dual;
556: l_event_key := to_char(p_list_header_id) || '.' || to_char(l_syncctlg_seq);
557:
558: SELECT sysdate into l_date from dual;
559: if (l_debug_level <= 1) then
560: cln_debug_pub.Add('l_date:' || l_date, 1);
561: end if;
562: l_canonical_date := FND_DATE.DATE_TO_CANONICAL(l_date);
563:
564: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Unique key created';
562: l_canonical_date := FND_DATE.DATE_TO_CANONICAL(l_date);
563:
564: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Unique key created';
565: if (l_debug_level <= 1) then
566: cln_debug_pub.Add('Failure point ' || x_progress, 1);
567: end if;
568:
569: EXIT WHEN items_exist = FALSE; -- if we reached the end, then no items to send
570:
601: p_parameterlist => l_create_cln_parameter_list);
602:
603: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Create Event Parameters Setup';
604: if (l_debug_level <= 1) then
605: cln_debug_pub.Add('Failure point ' || x_progress, 1);
606: end if;
607:
608: -- raise create collaboration event
609: wf_event.raise(p_event_name => l_create_cln_event,
611: p_parameters => l_create_cln_parameter_list);
612:
613: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Create Event Raised';
614: if (l_debug_level <= 1) then
615: cln_debug_pub.Add('Failure point ' || x_progress, 1);
616: end if;
617:
618: -- add parameters to list for send show shipment document
619: wf_event.AddParameterToList(p_name => 'ECX_TRANSACTION_TYPE',
714: p_parameterlist => l_send_syct_parameter_list);
715:
716: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Initialize Send Document Parameters';
717: if (l_debug_level <= 1) then
718: cln_debug_pub.Add('Failure point ' || x_progress, 1);
719: end if;
720:
721: -- raise event for send show shipment document
722: wf_event.raise(p_event_name => l_send_syct_event,
727: msgs_sent_flag := TRUE;
728:
729: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Send Document Event Raised';
730: if (l_debug_level <= 1) then
731: cln_debug_pub.Add('Failure point ' || x_progress, 1);
732: end if;
733:
734: EXIT WHEN c_ItemsToSend%NOTFOUND; -- same test again to see if all items have been extracted
735:
741: if NOT(msgs_sent_flag) then
742:
743: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Price List contains no items';
744: if (l_debug_level <= 1) then
745: cln_debug_pub.Add('Failure point ' || x_progress, 1);
746: end if;
747:
748: -- add parameters to list for update collaboration event
749: l_update_cln_parameter_list := wf_parameter_list_t();
785: p_parameterlist => l_update_cln_parameter_list);
786:
787: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Initialized update event parameters';
788: if (l_debug_level <= 1) then
789: cln_debug_pub.Add('Failure point ' || x_progress, 1);
790: end if;
791:
792: -- raise update collaboration event
793: wf_event.raise(p_event_name => l_update_cln_event,
795: p_parameters => l_update_cln_parameter_list);
796:
797: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Update Event Raised';
798: if (l_debug_level <= 1) then
799: cln_debug_pub.Add('Failure point ' || x_progress, 1);
800: end if;
801: end if;
802:
803: -- Reached Here. Successful execution.
802:
803: -- Reached Here. Successful execution.
804: x_progress := 'CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event : Finished Number Limit loop';
805: if (l_debug_level <= 1) then
806: cln_debug_pub.Add('Failure point ' || x_progress, 1);
807: end if;
808: end if;
809:
810: -- Reached Here. Successful execution.
808: end if;
809:
810: -- Reached Here. Successful execution.
811: if (l_debug_level <= 2) then
812: cln_debug_pub.Add('EXITING CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event Successfully', 1);
813: end if;
814: EXCEPTION
815: WHEN OTHERS THEN
816: l_error_code := SQLCODE;
815: WHEN OTHERS THEN
816: l_error_code := SQLCODE;
817: l_error_msg := SQLERRM;
818: if (l_debug_level <= 5) then
819: cln_debug_pub.Add('Exception ' || ':' || l_error_code || ':' || l_error_msg, 1);
820: end if;
821:
822: x_progress := 'EXITING CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event in Error ';
823: if (l_debug_level <= 2) then
820: end if;
821:
822: x_progress := 'EXITING CLN_SYNCCTLG_PKG.Syncctlg_Raise_Event in Error ';
823: if (l_debug_level <= 2) then
824: cln_debug_pub.Add('Failure point ' || x_progress, 1);
825: end if;
826: END Syncctlg_Raise_Event;
827:
828: