eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.ASG_CONS_QPKG dependencies on ASG_HELPER

Line 142: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

138: l_sync_id NUMBER;
139:
140: BEGIN
141:
142: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
143: asg_helper.log('Entering set_sync_id: Clientid: ' ||
144: p_user_name || ' tranid: ' || p_upload_tranid,
145: 'asg_cons_qpkg',g_stmt_level);
146: END IF;

Line 143: asg_helper.log('Entering set_sync_id: Clientid: ' ||

139:
140: BEGIN
141:
142: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
143: asg_helper.log('Entering set_sync_id: Clientid: ' ||
144: p_user_name || ' tranid: ' || p_upload_tranid,
145: 'asg_cons_qpkg',g_stmt_level);
146: END IF;
147:

Line 182: IF(asg_helper.check_is_log_enabled(g_stmt_level))

178: -- This call will be made after all the uploaded data is committed.
179: -- Since during apply processing we account for the case when sync
180: -- fails after commit and before this call completed, we do not need
181: -- to do any processing.
182: IF(asg_helper.check_is_log_enabled(g_stmt_level))
183: THEN
184: asg_helper.log('Upload complete called for client: ' ||
185: p_clientid || ' tranid: ' || p_tranid,
186: 'asg_cons_qpkg',g_stmt_level);

Line 184: asg_helper.log('Upload complete called for client: ' ||

180: -- fails after commit and before this call completed, we do not need
181: -- to do any processing.
182: IF(asg_helper.check_is_log_enabled(g_stmt_level))
183: THEN
184: asg_helper.log('Upload complete called for client: ' ||
185: p_clientid || ' tranid: ' || p_tranid,
186: 'asg_cons_qpkg',g_stmt_level);
187: END IF;
188:

Line 191: IF asg_helper.is_user_synch_enabled(p_clientid,l_disabled_synch_message)

187: END IF;
188:
189: BEGIN
190: -- Check if user's synch is disabled
191: IF asg_helper.is_user_synch_enabled(p_clientid,l_disabled_synch_message)
192: = FND_API.G_FALSE THEN
193: raise synch_disabled;
194: END IF;
195: asg_base.set_upload_tranid(p_tranid);

Line 198: -- asg_helper.set_synch_errmsg(p_clientid,(p_tranid-1),null,null);

194: END IF;
195: asg_base.set_upload_tranid(p_tranid);
196: --set hwm_tranid to tranid-1 and make synch_errors null
197: -- Moved to download_init Because we shouldn't process uploads when it is in auto sync
198: -- asg_helper.set_synch_errmsg(p_clientid,(p_tranid-1),null,null);
199: asg_apply.process_sequences(p_clientid, p_tranid, l_return_status);
200: asg_apply.setup_inq_info(p_clientid, p_tranid, l_return_status);
201: --12.1
202: insert_auto_sync_tranids(p_clientid, p_tranid);

Line 206: IF(asg_helper.check_is_log_enabled(g_err_level))

202: insert_auto_sync_tranids(p_clientid, p_tranid);
203: COMMIT;
204: EXCEPTION
205: WHEN synch_disabled THEN
206: IF(asg_helper.check_is_log_enabled(g_err_level))
207: THEN
208: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||
209: to_char(sysdate, 'yyyy-mm-dd') ||
210: ' Synch is not enabled.',

Line 208: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||

204: EXCEPTION
205: WHEN synch_disabled THEN
206: IF(asg_helper.check_is_log_enabled(g_err_level))
207: THEN
208: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||
209: to_char(sysdate, 'yyyy-mm-dd') ||
210: ' Synch is not enabled.',
211: 'asg_cons_qpkg',g_err_level);
212: END IF;

Line 216: asg_helper.set_synch_errmsg(p_clientid,null,g_device_type,

212: END IF;
213: IF l_disabled_synch_message IS NULL THEN
214: l_disabled_synch_message := 'Synch is not enabled.';
215: END IF;
216: asg_helper.set_synch_errmsg(p_clientid,null,g_device_type,
217: 'User Synch Error: '||l_disabled_synch_message);
218: RAISE_APPLICATION_ERROR(-20994, l_disabled_synch_message);
219: WHEN OTHERS THEN
220: l_sqlerror_message := SQLERRM;

Line 221: IF(asg_helper.check_is_log_enabled(g_err_level))

217: 'User Synch Error: '||l_disabled_synch_message);
218: RAISE_APPLICATION_ERROR(-20994, l_disabled_synch_message);
219: WHEN OTHERS THEN
220: l_sqlerror_message := SQLERRM;
221: IF(asg_helper.check_is_log_enabled(g_err_level))
222: THEN
223: asg_helper.log(
224: 'User Synch Error: ' || p_clientid || ' ' ||
225: to_char(sysdate, 'yyyy-mm-dd') ||

Line 223: asg_helper.log(

219: WHEN OTHERS THEN
220: l_sqlerror_message := SQLERRM;
221: IF(asg_helper.check_is_log_enabled(g_err_level))
222: THEN
223: asg_helper.log(
224: 'User Synch Error: ' || p_clientid || ' ' ||
225: to_char(sysdate, 'yyyy-mm-dd') ||
226: ' Exception in upload_complete. ' || l_sqlerror_message,
227: 'asg_cons_qpkg', g_err_level);

Line 229: asg_helper.set_synch_errmsg(p_clientid,null,g_device_type,

225: to_char(sysdate, 'yyyy-mm-dd') ||
226: ' Exception in upload_complete. ' || l_sqlerror_message,
227: 'asg_cons_qpkg', g_err_level);
228: END IF;
229: asg_helper.set_synch_errmsg(p_clientid,null,g_device_type,
230: 'User Synch Error: ' ||
231: ' Exception in upload_complete. ' ||
232: l_sqlerror_message);
233: RAISE_APPLICATION_ERROR(-20995, 'Exception during upload ' ||

Line 258: IF(asg_helper.check_is_log_enabled(g_stmt_level))

254: l_ret_msg varchar2(512);
255: l_pwd_expired VARCHAR2(1);
256: l_sync_id NUMBER;
257: BEGIN
258: IF(asg_helper.check_is_log_enabled(g_stmt_level))
259: THEN
260: asg_helper.log('Start Download ' || p_clientid ||
261: ' last tranid: ' || p_last_tranid ||
262: ' current tranid: ' || p_curr_tranid,

Line 260: asg_helper.log('Start Download ' || p_clientid ||

256: l_sync_id NUMBER;
257: BEGIN
258: IF(asg_helper.check_is_log_enabled(g_stmt_level))
259: THEN
260: asg_helper.log('Start Download ' || p_clientid ||
261: ' last tranid: ' || p_last_tranid ||
262: ' current tranid: ' || p_curr_tranid,
263: 'asg_cons_qpkg',g_stmt_level);
264: END IF;

Line 278: IF asg_helper.is_user_synch_enabled(p_clientid,l_disabled_synch_message)

274: IF l_pwd_expired = 'Y' THEN
275: raise password_expired;
276: END IF;
277: -- Check if user's synch is disabled
278: IF asg_helper.is_user_synch_enabled(p_clientid,l_disabled_synch_message)
279: = FND_API.G_FALSE THEN
280: raise synch_disabled;
281: END IF;
282: -- Initialize all the session information except the list of pubitems

Line 293: asg_helper.log('Checking if user: '

289: l_last_synch_date, asg_base.g_empty_pub_item_tbl);
290:
291: -- check out if this user needs complete
292: -- refresh since he's been a dormant user.
293: asg_helper.log('Checking if user: '
294: || p_clientid || ' needs complete refresh.',
295: 'asg_cons_qpkg',g_stmt_level);
296: process_purge_Sdq(p_clientid, p_last_tranid, p_curr_tranid);
297:

Line 301: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

297:
298: IF(g_first_synch) THEN
299: set_synch_completed(p_clientid);
300: delete_row(p_clientid);
301: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
302: asg_helper.log('First synch..deleted all rows from asg_complete_refresh'
303: ,'asg_cons_qpkg',g_stmt_level);
304: END IF;
305: ELSE

Line 302: asg_helper.log('First synch..deleted all rows from asg_complete_refresh'

298: IF(g_first_synch) THEN
299: set_synch_completed(p_clientid);
300: delete_row(p_clientid);
301: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
302: asg_helper.log('First synch..deleted all rows from asg_complete_refresh'
303: ,'asg_cons_qpkg',g_stmt_level);
304: END IF;
305: ELSE
306: process_compref_table(p_clientid,p_last_tranid);

Line 323: IF(asg_helper.check_is_log_enabled(g_err_level))

319: l_sqlerror_message := SQLERRM;
320: else
321: l_sqlerror_message := l_ret_msg;
322: end if;
323: IF(asg_helper.check_is_log_enabled(g_err_level))
324: THEN
325: asg_helper.log('processsdq returned FALSE', 'asg_cons_qpkg',
326: g_err_level);
327: END IF;

Line 325: asg_helper.log('processsdq returned FALSE', 'asg_cons_qpkg',

321: l_sqlerror_message := l_ret_msg;
322: end if;
323: IF(asg_helper.check_is_log_enabled(g_err_level))
324: THEN
325: asg_helper.log('processsdq returned FALSE', 'asg_cons_qpkg',
326: g_err_level);
327: END IF;
328: asg_helper.set_synch_errmsg(p_clientid, null, g_device_type,'Error during download in asg_download.processsdq: '||
329: l_sqlerror_message);

Line 328: asg_helper.set_synch_errmsg(p_clientid, null, g_device_type,'Error during download in asg_download.processsdq: '||

324: THEN
325: asg_helper.log('processsdq returned FALSE', 'asg_cons_qpkg',
326: g_err_level);
327: END IF;
328: asg_helper.set_synch_errmsg(p_clientid, null, g_device_type,'Error during download in asg_download.processsdq: '||
329: l_sqlerror_message);
330:
331: RAISE_APPLICATION_ERROR(-20999, 'Error during download in ' ||
332: 'asg_download.processsdq ' ||

Line 342: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

338:
339: --12.1
340: -- Start processing uploads when synchronized manually(i.e,not auto sync)
341: -- and when download is successful
342: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
343: asg_helper.log('Set ASG_USER hwm_tranid to '||l_sync_id||' for Process Upload to pick it up.','asg_cons_qpkg',g_stmt_level);
344: END IF;
345: asg_helper.set_synch_errmsg(p_clientid,l_sync_id,g_device_type, null);
346: EXCEPTION

Line 343: asg_helper.log('Set ASG_USER hwm_tranid to '||l_sync_id||' for Process Upload to pick it up.','asg_cons_qpkg',g_stmt_level);

339: --12.1
340: -- Start processing uploads when synchronized manually(i.e,not auto sync)
341: -- and when download is successful
342: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
343: asg_helper.log('Set ASG_USER hwm_tranid to '||l_sync_id||' for Process Upload to pick it up.','asg_cons_qpkg',g_stmt_level);
344: END IF;
345: asg_helper.set_synch_errmsg(p_clientid,l_sync_id,g_device_type, null);
346: EXCEPTION
347:

Line 345: asg_helper.set_synch_errmsg(p_clientid,l_sync_id,g_device_type, null);

341: -- and when download is successful
342: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
343: asg_helper.log('Set ASG_USER hwm_tranid to '||l_sync_id||' for Process Upload to pick it up.','asg_cons_qpkg',g_stmt_level);
344: END IF;
345: asg_helper.set_synch_errmsg(p_clientid,l_sync_id,g_device_type, null);
346: EXCEPTION
347:
348: WHEN synch_disabled THEN
349: asg_helper.set_synch_errmsg(

Line 349: asg_helper.set_synch_errmsg(

345: asg_helper.set_synch_errmsg(p_clientid,l_sync_id,g_device_type, null);
346: EXCEPTION
347:
348: WHEN synch_disabled THEN
349: asg_helper.set_synch_errmsg(
350: p_clientid,null,g_device_type,
351: 'User Synch Error: '||
352: nvl(l_disabled_synch_message,'Synch is not enabled.'));
353:

Line 354: IF(asg_helper.check_is_log_enabled(g_err_level)) THEN

350: p_clientid,null,g_device_type,
351: 'User Synch Error: '||
352: nvl(l_disabled_synch_message,'Synch is not enabled.'));
353:
354: IF(asg_helper.check_is_log_enabled(g_err_level)) THEN
355: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||
356: to_char(sysdate, 'yyyy-mm-dd') ||
357: ' Synch is not enabled.',
358: 'asg_cons_qpkg',g_err_level);

Line 355: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||

351: 'User Synch Error: '||
352: nvl(l_disabled_synch_message,'Synch is not enabled.'));
353:
354: IF(asg_helper.check_is_log_enabled(g_err_level)) THEN
355: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||
356: to_char(sysdate, 'yyyy-mm-dd') ||
357: ' Synch is not enabled.',
358: 'asg_cons_qpkg',g_err_level);
359: END IF;

Line 365: asg_helper.set_synch_errmsg(

361: l_disabled_synch_message := 'Synch is not enabled.';
362: END IF;
363: RAISE_APPLICATION_ERROR(-20994, l_disabled_synch_message);
364: WHEN password_expired THEN
365: asg_helper.set_synch_errmsg(
366: p_clientid,null,g_device_type,
367: 'User Synch Error: User Password Expired.');
368: IF(asg_helper.check_is_log_enabled(g_err_level)) THEN
369: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||

Line 368: IF(asg_helper.check_is_log_enabled(g_err_level)) THEN

364: WHEN password_expired THEN
365: asg_helper.set_synch_errmsg(
366: p_clientid,null,g_device_type,
367: 'User Synch Error: User Password Expired.');
368: IF(asg_helper.check_is_log_enabled(g_err_level)) THEN
369: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||
370: to_char(sysdate, 'yyyy-mm-dd') ||
371: ' User Password Expired.',
372: 'asg_cons_qpkg',g_err_level);

Line 369: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||

365: asg_helper.set_synch_errmsg(
366: p_clientid,null,g_device_type,
367: 'User Synch Error: User Password Expired.');
368: IF(asg_helper.check_is_log_enabled(g_err_level)) THEN
369: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||
370: to_char(sysdate, 'yyyy-mm-dd') ||
371: ' User Password Expired.',
372: 'asg_cons_qpkg',g_err_level);
373: END IF;

Line 378: asg_helper.set_synch_errmsg(

374: RAISE_APPLICATION_ERROR(-20993, 'Your password has expired. ' ||
375: 'Please contact your System Administrator to reset the password.');
376: WHEN OTHERS THEN
377: l_sqlerror_message := SQLERRM;
378: asg_helper.set_synch_errmsg(
379: p_clientid,null,g_device_type,
380: 'User Synch Error: Exception in processsdq '||
381: l_sqlerror_message);
382: IF(asg_helper.check_is_log_enabled(g_err_level))

Line 382: IF(asg_helper.check_is_log_enabled(g_err_level))

378: asg_helper.set_synch_errmsg(
379: p_clientid,null,g_device_type,
380: 'User Synch Error: Exception in processsdq '||
381: l_sqlerror_message);
382: IF(asg_helper.check_is_log_enabled(g_err_level))
383: THEN
384: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||
385: to_char(sysdate, 'yyyy-mm-dd') ||
386: ' transaction-id: ' || p_curr_tranid ||

Line 384: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||

380: 'User Synch Error: Exception in processsdq '||
381: l_sqlerror_message);
382: IF(asg_helper.check_is_log_enabled(g_err_level))
383: THEN
384: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||
385: to_char(sysdate, 'yyyy-mm-dd') ||
386: ' transaction-id: ' || p_curr_tranid ||
387: ' Exception in processsdq ' || l_sqlerror_message,
388: 'asg_cons_qpkg',g_err_level);

Line 411: IF(asg_helper.check_is_log_enabled(g_stmt_level))

407: l_bool_ret BOOLEAN;
408: l_last_tranid NUMBER;
409: l_sqlerror_message VARCHAR2(512);
410: BEGIN
411: IF(asg_helper.check_is_log_enabled(g_stmt_level))
412: THEN
413: asg_helper.log('Download complete called for client: ' || p_clientid,
414: 'asg_cons_qpkg',g_stmt_level);
415: END IF;

Line 413: asg_helper.log('Download complete called for client: ' || p_clientid,

409: l_sqlerror_message VARCHAR2(512);
410: BEGIN
411: IF(asg_helper.check_is_log_enabled(g_stmt_level))
412: THEN
413: asg_helper.log('Download complete called for client: ' || p_clientid,
414: 'asg_cons_qpkg',g_stmt_level);
415: END IF;
416: --new code
417: set_synch_completed(p_clientid);

Line 423: IF(asg_helper.check_is_log_enabled(g_err_level))

419: BEGIN
420: l_bool_ret := asg_download.purgesdq();
421: IF l_bool_ret = FALSE THEN
422: l_sqlerror_message := SQLERRM;
423: IF(asg_helper.check_is_log_enabled(g_err_level))
424: THEN
425: asg_helper.log('purgesdq returned FALSE',
426: 'asg_cons_qpkg',g_err_level);
427: END IF;

Line 425: asg_helper.log('purgesdq returned FALSE',

421: IF l_bool_ret = FALSE THEN
422: l_sqlerror_message := SQLERRM;
423: IF(asg_helper.check_is_log_enabled(g_err_level))
424: THEN
425: asg_helper.log('purgesdq returned FALSE',
426: 'asg_cons_qpkg',g_err_level);
427: END IF;
428: RAISE_APPLICATION_ERROR(-20997, 'Error during download in ' ||
429: 'asg_download.purgesdq ' || l_sqlerror_message);

Line 461: asg_helper.set_synch_errmsg(

457:
458: EXCEPTION
459: WHEN OTHERS THEN
460: l_sqlerror_message := SQLERRM;
461: asg_helper.set_synch_errmsg(
462: p_clientid,null,g_device_type,
463: 'User Synch Error: Exception in purgesdq '||
464: l_sqlerror_message);
465:

Line 466: IF(asg_helper.check_is_log_enabled(g_err_level))

462: p_clientid,null,g_device_type,
463: 'User Synch Error: Exception in purgesdq '||
464: l_sqlerror_message);
465:
466: IF(asg_helper.check_is_log_enabled(g_err_level))
467: THEN
468: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||
469: to_char(sysdate, 'yyyy-mm-dd') ||
470: ' transaction-id: ' || asg_base.get_current_tranid ||

Line 468: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||

464: l_sqlerror_message);
465:
466: IF(asg_helper.check_is_log_enabled(g_err_level))
467: THEN
468: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||
469: to_char(sysdate, 'yyyy-mm-dd') ||
470: ' transaction-id: ' || asg_base.get_current_tranid ||
471: ' Exception in purgesdq ' || l_sqlerror_message,
472: 'asg_cons_qpkg',g_err_level);

Line 483: asg_helper.set_synch_errmsg(

479: /**/
480: EXCEPTION
481: WHEN OTHERS THEN
482: l_sqlerror_message := SQLERRM;
483: asg_helper.set_synch_errmsg(
484: p_clientid,null,g_device_type,
485: 'User Synch Error: Exception in download_complete '||
486: l_sqlerror_message);
487:

Line 488: IF(asg_helper.check_is_log_enabled(g_err_level))

484: p_clientid,null,g_device_type,
485: 'User Synch Error: Exception in download_complete '||
486: l_sqlerror_message);
487:
488: IF(asg_helper.check_is_log_enabled(g_err_level))
489: THEN
490: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||
491: to_char(sysdate, 'yyyy-mm-dd') ||
492: ' transaction-id: ' || asg_base.get_current_tranid ||

Line 490: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||

486: l_sqlerror_message);
487:
488: IF(asg_helper.check_is_log_enabled(g_err_level))
489: THEN
490: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||
491: to_char(sysdate, 'yyyy-mm-dd') ||
492: ' transaction-id: ' || asg_base.get_current_tranid ||
493: ' Exception in download_complete ' || l_sqlerror_message,
494: 'asg_cons_qpkg',g_err_level);

Line 532: IF(asg_helper.check_is_log_enabled(g_stmt_level))

528: IS
529: l_loopvar NUMBER;
530: l_qry_string VARCHAR2(1024);
531: BEGIN
532: IF(asg_helper.check_is_log_enabled(g_stmt_level))
533: THEN
534: asg_helper.log('Performing batch update for: '||p_clientid,
535: 'asg_cons_qpkg',g_stmt_level);
536: END IF;

Line 534: asg_helper.log('Performing batch update for: '||p_clientid,

530: l_qry_string VARCHAR2(1024);
531: BEGIN
532: IF(asg_helper.check_is_log_enabled(g_stmt_level))
533: THEN
534: asg_helper.log('Performing batch update for: '||p_clientid,
535: 'asg_cons_qpkg',g_stmt_level);
536: END IF;
537: FOR l_loopvar IN 1..p_pubitem_tbl.count
538: LOOP

Line 547: /* asg_helper.log('Update: '||p_pubitem_tbl(l_loopvar).name||' count: '

543: ' set rec_count= :1 ' ||
544: ' where name = :2';
545: EXECUTE IMMEDIATE l_qry_string
546: USING p_pubitem_tbl(l_loopvar).rec_count, p_pubitem_tbl(l_loopvar).name;
547: /* asg_helper.log('Update: '||p_pubitem_tbl(l_loopvar).name||' count: '
548: ||p_pubitem_tbl(l_loopvar).rec_count,
549: 'asg.asg_cons_qpkg');
550: */
551: END IF;

Line 574: IF(asg_helper.check_is_log_enabled(g_stmt_level))

570:
571: BEGIN
572: l_total:=0;
573: l_pubitem_tbl := p_pubitem_tbl;
574: IF(asg_helper.check_is_log_enabled(g_stmt_level))
575: THEN
576: asg_helper.log('Inside process_first_synch for :'||p_clientid,
577: 'asg_cons_qpkg',g_stmt_level);
578: END IF;

Line 576: asg_helper.log('Inside process_first_synch for :'||p_clientid,

572: l_total:=0;
573: l_pubitem_tbl := p_pubitem_tbl;
574: IF(asg_helper.check_is_log_enabled(g_stmt_level))
575: THEN
576: asg_helper.log('Inside process_first_synch for :'||p_clientid,
577: 'asg_cons_qpkg',g_stmt_level);
578: END IF;
579: asg_base.init(p_clientid,-1,0,null,p_pubitem_tbl);
580:

Line 586: IF(asg_helper.check_is_log_enabled(g_stmt_level))

582: LOOP
583: l_curr_pubitem:=l_pubitem_tbl(l_loopvar).name;
584: IF(l_curr_pubitem like 'C$%')
585: THEN
586: IF(asg_helper.check_is_log_enabled(g_stmt_level))
587: THEN
588: asg_helper.log('Ignoring : '||l_curr_pubitem,
589: 'asg_cons_qpkg',g_stmt_level);
590: END IF;

Line 588: asg_helper.log('Ignoring : '||l_curr_pubitem,

584: IF(l_curr_pubitem like 'C$%')
585: THEN
586: IF(asg_helper.check_is_log_enabled(g_stmt_level))
587: THEN
588: asg_helper.log('Ignoring : '||l_curr_pubitem,
589: 'asg_cons_qpkg',g_stmt_level);
590: END IF;
591: ELSE
592: select base_object_name,base_owner into l_view_name,l_owner_name

Line 600: /* asg_helper.log('Pub Name '||l_curr_pubitem||' Count: '||l_rec_count1,

596: EXECUTE IMMEDIATE l_qry_string2 into l_rec_count1;
597: l_total:=l_total+l_rec_count1;
598: l_pubitem_tbl(l_loopvar).rec_count:=l_rec_count1;
599: END IF;
600: /* asg_helper.log('Pub Name '||l_curr_pubitem||' Count: '||l_rec_count1,
601: 'asg.asg_cons_qpkg');
602: */
603: END LOOP;
604: update_rec_count(l_pubitem_tbl,p_clientid);

Line 605: IF(asg_helper.check_is_log_enabled(g_stmt_level))

601: 'asg.asg_cons_qpkg');
602: */
603: END LOOP;
604: update_rec_count(l_pubitem_tbl,p_clientid);
605: IF(asg_helper.check_is_log_enabled(g_stmt_level))
606: THEN
607: asg_helper.log('Total num of rows(First time synch): '||l_total,
608: 'asg_cons_qpkg',g_stmt_level);
609: END IF;

Line 607: asg_helper.log('Total num of rows(First time synch): '||l_total,

603: END LOOP;
604: update_rec_count(l_pubitem_tbl,p_clientid);
605: IF(asg_helper.check_is_log_enabled(g_stmt_level))
606: THEN
607: asg_helper.log('Total num of rows(First time synch): '||l_total,
608: 'asg_cons_qpkg',g_stmt_level);
609: END IF;
610: END process_first_synch;
611:

Line 710: IF(asg_helper.check_is_log_enabled(g_stmt_level))

706: BEGIN
707: l_ret := is_previous_synch_successful(p_user_name,p_last_tranid);
708: IF( l_ret = FND_API.G_TRUE ) THEN
709: --previous synch was successful
710: IF(asg_helper.check_is_log_enabled(g_stmt_level))
711: THEN
712: asg_helper.log('Prev synch successful ',
713: 'asg_cons_qpkg',g_stmt_level);
714: END IF;

Line 712: asg_helper.log('Prev synch successful ',

708: IF( l_ret = FND_API.G_TRUE ) THEN
709: --previous synch was successful
710: IF(asg_helper.check_is_log_enabled(g_stmt_level))
711: THEN
712: asg_helper.log('Prev synch successful ',
713: 'asg_cons_qpkg',g_stmt_level);
714: END IF;
715: delete_row(p_user_name);
716: ELSE

Line 748: IF(asg_helper.check_is_log_enabled(g_stmt_level))

744: responsibility_id => null,
745: application_id => 689);
746:
747: IF (l_customProfValue = 'Y') THEN
748: IF(asg_helper.check_is_log_enabled(g_stmt_level))
749: THEN
750: asg_helper.log('Disabling download of custom pub items ',
751: 'asg_cons_qpkg', g_stmt_level);
752: END IF;

Line 750: asg_helper.log('Disabling download of custom pub items ',

746:
747: IF (l_customProfValue = 'Y') THEN
748: IF(asg_helper.check_is_log_enabled(g_stmt_level))
749: THEN
750: asg_helper.log('Disabling download of custom pub items ',
751: 'asg_cons_qpkg', g_stmt_level);
752: END IF;
753: l_dml := 'DELETE FROM '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q ' ||
754: ' WHERE name IN ' ||

Line 776: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

772:
773: l_upload_tranid := asg_base.get_upload_tranid();
774:
775: -- Check if conflict detection is needed other wise return
776: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
777: asg_helper.log('Checking if conflicts should be detected.',
778: 'asg_cons_qpkg',g_stmt_level);
779: END IF;
780: is_conflict_detection_needed (p_user_name,

Line 777: asg_helper.log('Checking if conflicts should be detected.',

773: l_upload_tranid := asg_base.get_upload_tranid();
774:
775: -- Check if conflict detection is needed other wise return
776: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
777: asg_helper.log('Checking if conflicts should be detected.',
778: 'asg_cons_qpkg',g_stmt_level);
779: END IF;
780: is_conflict_detection_needed (p_user_name,
781: l_upload_tranid,

Line 786: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

782: l_detect_conflict,
783: l_pubitem_tbl);
784:
785: IF (l_detect_conflict = FND_API.G_FALSE) THEN
786: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
787: asg_helper.log('No need to check for conflicts.',
788: 'asg_cons_qpkg',g_stmt_level);
789: END IF;
790: return;

Line 787: asg_helper.log('No need to check for conflicts.',

783: l_pubitem_tbl);
784:
785: IF (l_detect_conflict = FND_API.G_FALSE) THEN
786: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
787: asg_helper.log('No need to check for conflicts.',
788: 'asg_cons_qpkg',g_stmt_level);
789: END IF;
790: return;
791: END IF;

Line 796: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

792:
793: -- Ok, conflicts need to be detected, process one pubitem at a time
794: FOR curr_index in 1..l_pubitem_tbl.count LOOP
795: l_pubitem := l_pubitem_tbl(curr_index).name;
796: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
797: asg_helper.log('Processing ' ||l_pubitem || ' for conflicts.',
798: 'asg_cons_qpkg',g_stmt_level);
799: END IF;
800: process_pubitem_conflicts(p_user_name, l_upload_tranid, l_pubitem);

Line 797: asg_helper.log('Processing ' ||l_pubitem || ' for conflicts.',

793: -- Ok, conflicts need to be detected, process one pubitem at a time
794: FOR curr_index in 1..l_pubitem_tbl.count LOOP
795: l_pubitem := l_pubitem_tbl(curr_index).name;
796: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
797: asg_helper.log('Processing ' ||l_pubitem || ' for conflicts.',
798: 'asg_cons_qpkg',g_stmt_level);
799: END IF;
800: process_pubitem_conflicts(p_user_name, l_upload_tranid, l_pubitem);
801: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

Line 801: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

797: asg_helper.log('Processing ' ||l_pubitem || ' for conflicts.',
798: 'asg_cons_qpkg',g_stmt_level);
799: END IF;
800: process_pubitem_conflicts(p_user_name, l_upload_tranid, l_pubitem);
801: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
802: asg_helper.log('Done processing ' ||l_pubitem || ' for conflicts.',
803: 'asg_cons_qpkg',g_stmt_level);
804: END IF;
805: END LOOP;

Line 802: asg_helper.log('Done processing ' ||l_pubitem || ' for conflicts.',

798: 'asg_cons_qpkg',g_stmt_level);
799: END IF;
800: process_pubitem_conflicts(p_user_name, l_upload_tranid, l_pubitem);
801: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
802: asg_helper.log('Done processing ' ||l_pubitem || ' for conflicts.',
803: 'asg_cons_qpkg',g_stmt_level);
804: END IF;
805: END LOOP;
806:

Line 807: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

803: 'asg_cons_qpkg',g_stmt_level);
804: END IF;
805: END LOOP;
806:
807: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
808: asg_helper.log('Done processing all conflicts.',
809: 'asg_cons_qpkg',g_stmt_level);
810: END IF;
811: EXCEPTION

Line 808: asg_helper.log('Done processing all conflicts.',

804: END IF;
805: END LOOP;
806:
807: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
808: asg_helper.log('Done processing all conflicts.',
809: 'asg_cons_qpkg',g_stmt_level);
810: END IF;
811: EXCEPTION
812: WHEN OTHERS THEN

Line 813: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

809: 'asg_cons_qpkg',g_stmt_level);
810: END IF;
811: EXCEPTION
812: WHEN OTHERS THEN
813: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
814: asg_helper.log('Exception when processing for conflicts. ' || sqlerrm,
815: 'asg_cons_qpkg',g_stmt_level);
816: END IF;
817: END process_conflicts;

Line 814: asg_helper.log('Exception when processing for conflicts. ' || sqlerrm,

810: END IF;
811: EXCEPTION
812: WHEN OTHERS THEN
813: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
814: asg_helper.log('Exception when processing for conflicts. ' || sqlerrm,
815: 'asg_cons_qpkg',g_stmt_level);
816: END IF;
817: END process_conflicts;
818:

Line 890: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

886: */
887: l_query_string2 := 'SELECT ' || l_pub_callback ||
888: '.detect_conflict( :1 ) from dual';
889:
890: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
891: asg_helper.log('SQL Command: ' || replace(l_query_string2,'''',''''''),
892: 'asg_cons_qpkg',g_stmt_level);
893: END IF;
894: BEGIN

Line 891: asg_helper.log('SQL Command: ' || replace(l_query_string2,'''',''''''),

887: l_query_string2 := 'SELECT ' || l_pub_callback ||
888: '.detect_conflict( :1 ) from dual';
889:
890: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
891: asg_helper.log('SQL Command: ' || replace(l_query_string2,'''',''''''),
892: 'asg_cons_qpkg',g_stmt_level);
893: END IF;
894: BEGIN
895: /*

Line 907: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

903: EXECUTE IMMEDIATE l_query_string2
904: INTO l_pub_detect_conflict
905: USING p_user_name;
906:
907: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
908: asg_helper.log('Publication callback returned: ' ||
909: l_pub_detect_conflict,
910: 'asg_cons_qpkg',g_stmt_level);
911: END IF;

Line 908: asg_helper.log('Publication callback returned: ' ||

904: INTO l_pub_detect_conflict
905: USING p_user_name;
906:
907: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
908: asg_helper.log('Publication callback returned: ' ||
909: l_pub_detect_conflict,
910: 'asg_cons_qpkg',g_stmt_level);
911: END IF;
912: IF (l_pub_detect_conflict = asg_base.G_YES) THEN

Line 924: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

920: l_counter := l_counter +1;
921: END IF;
922: EXCEPTION
923: WHEN OTHERS THEN
924: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
925: asg_helper.log('Exception in wrapper callback ' ||SQLERRM,
926: 'asg_cons_qpkg',g_stmt_level);
927: END IF;
928: END;

Line 925: asg_helper.log('Exception in wrapper callback ' ||SQLERRM,

921: END IF;
922: EXCEPTION
923: WHEN OTHERS THEN
924: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
925: asg_helper.log('Exception in wrapper callback ' ||SQLERRM,
926: 'asg_cons_qpkg',g_stmt_level);
927: END IF;
928: END;
929: END LOOP;

Line 935: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

931:
932: -- Some pubs need conflict detection
933: IF (l_counter > 1) THEN
934: p_detect_conflict := FND_API.G_TRUE;
935: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
936: asg_helper.log('Need to detect conflicts.',
937: 'asg_cons_qpkg',g_stmt_level);
938: END IF;
939: get_conf_pub_items_list(p_user_name, p_upload_tranid,

Line 936: asg_helper.log('Need to detect conflicts.',

932: -- Some pubs need conflict detection
933: IF (l_counter > 1) THEN
934: p_detect_conflict := FND_API.G_TRUE;
935: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
936: asg_helper.log('Need to detect conflicts.',
937: 'asg_cons_qpkg',g_stmt_level);
938: END IF;
939: get_conf_pub_items_list(p_user_name, p_upload_tranid,
940: l_conf_pubs, p_pubitem_tbl);

Line 967: IF(asg_helper.check_is_log_enabled(g_stmt_level))

963: ' ci.store = cpq.name AND ' ||
964: ' cpq.comp_ref <> ''Y'' AND ' ||
965: ' api.detect_conflict = ''Y''';
966:
967: IF(asg_helper.check_is_log_enabled(g_stmt_level))
968: THEN
969: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),
970: 'asg_cons_qpkg',g_stmt_level);
971: END IF;

Line 969: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),

965: ' api.detect_conflict = ''Y''';
966:
967: IF(asg_helper.check_is_log_enabled(g_stmt_level))
968: THEN
969: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),
970: 'asg_cons_qpkg',g_stmt_level);
971: END IF;
972:
973: EXECUTE IMMEDIATE l_query_string

Line 1032: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

1028: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1029: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pubitem);
1030: p_pubitem_tbl(l_counter).name := l_pubitem;
1031: l_counter := l_counter +1;
1032: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1033: asg_helper.log('Pub item that will be checked for conflicts: ' ||
1034: l_pubitem, 'asg_cons_qpkg',g_stmt_level);
1035: END IF;
1036: END LOOP;

Line 1033: asg_helper.log('Pub item that will be checked for conflicts: ' ||

1029: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pubitem);
1030: p_pubitem_tbl(l_counter).name := l_pubitem;
1031: l_counter := l_counter +1;
1032: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1033: asg_helper.log('Pub item that will be checked for conflicts: ' ||
1034: l_pubitem, 'asg_cons_qpkg',g_stmt_level);
1035: END IF;
1036: END LOOP;
1037:

Line 1058: asg_helper.log('Processing Purge SDQ','asg_cons_qpkg',g_stmt_level);

1054: l_cursor_id NUMBER;
1055: l_pub_name varchar2(30);
1056: l_ret_val NUMBER;
1057: BEGIN
1058: asg_helper.log('Processing Purge SDQ','asg_cons_qpkg',g_stmt_level);
1059:
1060: l_qry_string := 'select distinct pub_name from asg_pub_item where item_id in '||
1061: ' ( select name from '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q )';
1062: l_cursor_id := dbms_sql.open_cursor();

Line 1081: asg_helper.log('Setting user '||p_clientid||' to complete refresh for '||

1077: THEN
1078: IF(l_tran_id = -100 )
1079: THEN
1080: -- process first time .set publication to complete refresh
1081: asg_helper.log('Setting user '||p_clientid||' to complete refresh for '||
1082: ' publication '||l_pub_name,'asg_cons_qpkg',g_stmt_level);
1083: l_qry_string1 := 'update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '||
1084: ' set comp_ref = ''Y'' where name in '||
1085: ' ( select item_id from asg_pub_item where '||

Line 1095: asg_helper.log('Re-setting user '||p_clientid||' to complete refresh for '||

1091: WHERE user_name=p_clientid AND pub_name = l_pub_name;
1092: ELSIF ( p_last_tranid < l_tran_id )
1093: THEN
1094: -- last synch failed. ..so again set to complete refresh .
1095: asg_helper.log('Re-setting user '||p_clientid||' to complete refresh for '||
1096: ' publication '||l_pub_name,'asg_cons_qpkg',g_stmt_level);
1097: l_qry_string1 := 'update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '||
1098: ' set comp_ref = ''Y'' where name in '||
1099: ' ( select item_id from asg_pub_item where '||

Line 1108: asg_helper.log('Deleting asg_purge_sdq for user '||p_clientid||' and '||

1104: SET transaction_id=p_curr_tranid,last_update_date=sysdate
1105: WHERE user_name=p_clientid AND pub_name = l_pub_name;
1106: ELSE
1107: --previous synch succeded ..so delete from purge_sdq
1108: asg_helper.log('Deleting asg_purge_sdq for user '||p_clientid||' and '||
1109: ' publication '||l_pub_name,'asg_cons_qpkg',g_stmt_level);
1110: DELETE FROM asg_purge_sdq
1111: WHERE user_name = p_clientid AND pub_name = l_pub_name;
1112: END IF;

Line 1120: asg_helper.log('End processing purgeSDQ','asg_cons_qpkg',g_stmt_level);

1116: CLOSE c_purgeSdq;
1117: END LOOP;
1118:
1119: dbms_sql.close_cursor(l_cursor_id);
1120: asg_helper.log('End processing purgeSDQ','asg_cons_qpkg',g_stmt_level);
1121: EXCEPTION
1122: WHEN OTHERS THEN
1123: asg_helper.log('Exception in process_purge_sdq: ' || sqlerrm,
1124: 'asg_cons_qpkg',g_err_level);

Line 1123: asg_helper.log('Exception in process_purge_sdq: ' || sqlerrm,

1119: dbms_sql.close_cursor(l_cursor_id);
1120: asg_helper.log('End processing purgeSDQ','asg_cons_qpkg',g_stmt_level);
1121: EXCEPTION
1122: WHEN OTHERS THEN
1123: asg_helper.log('Exception in process_purge_sdq: ' || sqlerrm,
1124: 'asg_cons_qpkg',g_err_level);
1125: RAISE;
1126: END process_purge_Sdq;
1127:

Line 1211: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

1207: 'FROM ' || l_inqtable_name ||
1208: 'WHERE clid$$cs = :1 AND ' ||
1209: ' tranid$$ = :2 AND ' ||
1210: ' dmltype$$ = ''U''';
1211: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1212: asg_helper.log('SQL Command: ' || replace(l_query_string, '''', ''''''),
1213: 'asg_cons_qpkg',g_stmt_level);
1214: END IF;
1215:

Line 1212: asg_helper.log('SQL Command: ' || replace(l_query_string, '''', ''''''),

1208: 'WHERE clid$$cs = :1 AND ' ||
1209: ' tranid$$ = :2 AND ' ||
1210: ' dmltype$$ = ''U''';
1211: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1212: asg_helper.log('SQL Command: ' || replace(l_query_string, '''', ''''''),
1213: 'asg_cons_qpkg',g_stmt_level);
1214: END IF;
1215:
1216: EXECUTE IMMEDIATE l_query_string

Line 1221: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

1217: INTO l_client_update_count
1218: USING p_user_name, p_upload_tranid;
1219:
1220: IF (l_client_update_count =0) THEN
1221: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1222: asg_helper.log('No conflicts exist.',
1223: 'asg_cons_qpkg',g_stmt_level);
1224: END IF;
1225: return;

Line 1222: asg_helper.log('No conflicts exist.',

1218: USING p_user_name, p_upload_tranid;
1219:
1220: IF (l_client_update_count =0) THEN
1221: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1222: asg_helper.log('No conflicts exist.',
1223: 'asg_cons_qpkg',g_stmt_level);
1224: END IF;
1225: return;
1226: END IF;

Line 1256: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

1252: download_flag = 'Y' AND
1253: dml_type = 2;
1254: l_server_update_count := SQL%ROWCOUNT;
1255:
1256: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1257: asg_helper.log('Number of updates in server: ' || l_server_update_count,
1258: 'asg_cons_qpkg',g_stmt_level);
1259: END IF;
1260:

Line 1257: asg_helper.log('Number of updates in server: ' || l_server_update_count,

1253: dml_type = 2;
1254: l_server_update_count := SQL%ROWCOUNT;
1255:
1256: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1257: asg_helper.log('Number of updates in server: ' || l_server_update_count,
1258: 'asg_cons_qpkg',g_stmt_level);
1259: END IF;
1260:
1261: -- No updates from server. Return. Only conflicts between updates from

Line 1264: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

1260:
1261: -- No updates from server. Return. Only conflicts between updates from
1262: -- client and updates from server are detected.
1263: IF (l_server_update_count = 0) THEN
1264: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1265: asg_helper.log('No conflicts exist.',
1266: 'asg_cons_qpkg',g_stmt_level);
1267: END IF;
1268: return;

Line 1265: asg_helper.log('No conflicts exist.',

1261: -- No updates from server. Return. Only conflicts between updates from
1262: -- client and updates from server are detected.
1263: IF (l_server_update_count = 0) THEN
1264: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1265: asg_helper.log('No conflicts exist.',
1266: 'asg_cons_qpkg',g_stmt_level);
1267: END IF;
1268: return;
1269: END IF;

Line 1292: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

1288: ' WHERE user_name = :6 AND ' ||
1289: ' transaction_id = :7 AND ' ||
1290: ' pub_item = :8';
1291:
1292: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1293: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),
1294: 'asg_cons_qpkg',g_stmt_level);
1295: END IF;
1296: EXECUTE IMMEDIATE l_query_string

Line 1293: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),

1289: ' transaction_id = :7 AND ' ||
1290: ' pub_item = :8';
1291:
1292: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1293: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),
1294: 'asg_cons_qpkg',g_stmt_level);
1295: END IF;
1296: EXECUTE IMMEDIATE l_query_string
1297: USING p_user_name, p_upload_tranid,

Line 1311: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

1307: '(''' || p_user_name || ''', ' || p_upload_tranid ||
1308: ', ' || l_sequence || ') from dual';*/
1309: l_query_string := 'SELECT ' || l_conflict_callout ||
1310: '(:1,:2,:3) from dual';
1311: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1312: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),
1313: 'asg_cons_qpkg',g_stmt_level);
1314: END IF;
1315: BEGIN

Line 1312: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),

1308: ', ' || l_sequence || ') from dual';*/
1309: l_query_string := 'SELECT ' || l_conflict_callout ||
1310: '(:1,:2,:3) from dual';
1311: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1312: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),
1313: 'asg_cons_qpkg',g_stmt_level);
1314: END IF;
1315: BEGIN
1316: l_conf_resolution := l_client_wins;

Line 1322: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

1318: INTO l_conf_resolution
1319: USING p_user_name,p_upload_tranid,l_sequence ;
1320: EXCEPTION
1321: WHEN OTHERS THEN
1322: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1323: asg_helper.log('Exception in pub item level callback. ' || sqlerrm,
1324: 'asg_cons_qpkg',g_stmt_level);
1325: END IF;
1326: END;

Line 1323: asg_helper.log('Exception in pub item level callback. ' || sqlerrm,

1319: USING p_user_name,p_upload_tranid,l_sequence ;
1320: EXCEPTION
1321: WHEN OTHERS THEN
1322: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1323: asg_helper.log('Exception in pub item level callback. ' || sqlerrm,
1324: 'asg_cons_qpkg',g_stmt_level);
1325: END IF;
1326: END;
1327: IF (l_conf_resolution = l_server_wins) THEN

Line 1362: asg_helper.update_hwm_tranid(p_user_name, p_upload_tranid);

1358: p_upload_tranid IN NUMBER)
1359: IS
1360: PRAGMA AUTONOMOUS_TRANSACTION;
1361: BEGIN
1362: asg_helper.update_hwm_tranid(p_user_name, p_upload_tranid);
1363: commit;
1364: EXCEPTION
1365: WHEN OTHERS THEN
1366: rollback;

Line 1436: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

1432: l_last_synch_date DATE;
1433: BEGIN
1434: IF ((p_last_tranid <= -1) OR
1435: (g_first_synch = TRUE)) THEN
1436: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1437: asg_helper.log('First Synch detected.',
1438: 'asg_cons_qpkg',g_stmt_level);
1439: END IF;
1440: return NULL;

Line 1437: asg_helper.log('First Synch detected.',

1433: BEGIN
1434: IF ((p_last_tranid <= -1) OR
1435: (g_first_synch = TRUE)) THEN
1436: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1437: asg_helper.log('First Synch detected.',
1438: 'asg_cons_qpkg',g_stmt_level);
1439: END IF;
1440: return NULL;
1441: ELSE

Line 1444: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

1440: return NULL;
1441: ELSE
1442: g_last_synch_successful := is_previous_synch_successful(p_user_name,
1443: p_last_tranid);
1444: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1445: asg_helper.log('Last Synch Successful: ' || g_last_synch_successful,
1446: 'asg_cons_qpkg',g_stmt_level);
1447: END IF;
1448: IF (g_last_synch_successful = FND_API.G_TRUE) THEN

Line 1445: asg_helper.log('Last Synch Successful: ' || g_last_synch_successful,

1441: ELSE
1442: g_last_synch_successful := is_previous_synch_successful(p_user_name,
1443: p_last_tranid);
1444: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1445: asg_helper.log('Last Synch Successful: ' || g_last_synch_successful,
1446: 'asg_cons_qpkg',g_stmt_level);
1447: END IF;
1448: IF (g_last_synch_successful = FND_API.G_TRUE) THEN
1449: SELECT last_synch_date_end into l_last_synch_date