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 145: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

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

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

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

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

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

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

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

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

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

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

198: END IF;
199: asg_base.set_upload_tranid(p_tranid);
200: --set hwm_tranid to tranid-1 and make synch_errors null
201: -- Moved to download_init Because we shouldn't process uploads when it is in auto sync
202: -- asg_helper.set_synch_errmsg(p_clientid,(p_tranid-1),null,null);
203:
204: asg_apply.process_sequences(p_clientid, p_tranid, l_return_status);
205:
206: asg_apply.process_mobile_queries(p_clientid, p_tranid, l_return_status);

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

221: END IF;
222:
223: EXCEPTION
224: WHEN synch_disabled THEN
225: IF(asg_helper.check_is_log_enabled(g_err_level))
226: THEN
227: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||
228: to_char(sysdate, 'yyyy-mm-dd') ||
229: ' Synch is not enabled.',

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

223: EXCEPTION
224: WHEN synch_disabled THEN
225: IF(asg_helper.check_is_log_enabled(g_err_level))
226: THEN
227: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||
228: to_char(sysdate, 'yyyy-mm-dd') ||
229: ' Synch is not enabled.',
230: 'asg_cons_qpkg',g_err_level);
231: END IF;

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

231: END IF;
232: IF l_disabled_synch_message IS NULL THEN
233: l_disabled_synch_message := 'Synch is not enabled.';
234: END IF;
235: asg_helper.set_synch_errmsg(p_clientid,null,g_device_type,
236: 'User Synch Error: '||l_disabled_synch_message);
237: RAISE_APPLICATION_ERROR(-20994, l_disabled_synch_message);
238: WHEN OTHERS THEN
239: l_sqlerror_message := SQLERRM;

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

236: 'User Synch Error: '||l_disabled_synch_message);
237: RAISE_APPLICATION_ERROR(-20994, l_disabled_synch_message);
238: WHEN OTHERS THEN
239: l_sqlerror_message := SQLERRM;
240: IF(asg_helper.check_is_log_enabled(g_err_level))
241: THEN
242: asg_helper.log(
243: 'User Synch Error: ' || p_clientid || ' ' ||
244: to_char(sysdate, 'yyyy-mm-dd') ||

Line 242: asg_helper.log(

238: WHEN OTHERS THEN
239: l_sqlerror_message := SQLERRM;
240: IF(asg_helper.check_is_log_enabled(g_err_level))
241: THEN
242: asg_helper.log(
243: 'User Synch Error: ' || p_clientid || ' ' ||
244: to_char(sysdate, 'yyyy-mm-dd') ||
245: ' Exception in upload_complete. ' || l_sqlerror_message,
246: 'asg_cons_qpkg', g_err_level);

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

244: to_char(sysdate, 'yyyy-mm-dd') ||
245: ' Exception in upload_complete. ' || l_sqlerror_message,
246: 'asg_cons_qpkg', g_err_level);
247: END IF;
248: asg_helper.set_synch_errmsg(p_clientid,null,g_device_type,
249: 'User Synch Error: ' ||
250: ' Exception in upload_complete. ' ||
251: l_sqlerror_message);
252: RAISE_APPLICATION_ERROR(-20995, 'Exception during upload ' ||

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

275: l_is_auto_sync VARCHAR2(1);
276: l_is_download_only_sync VARCHAR2(1);
277: l_sync_id NUMBER;
278: BEGIN
279: IF(asg_helper.check_is_log_enabled(g_stmt_level))
280: THEN
281: asg_helper.log('Start Download ' || p_clientid ||
282: ' last tranid: ' || p_last_tranid ||
283: ' current tranid: ' || p_curr_tranid,

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

277: l_sync_id NUMBER;
278: BEGIN
279: IF(asg_helper.check_is_log_enabled(g_stmt_level))
280: THEN
281: asg_helper.log('Start Download ' || p_clientid ||
282: ' last tranid: ' || p_last_tranid ||
283: ' current tranid: ' || p_curr_tranid,
284: 'asg_cons_qpkg',g_stmt_level);
285: END IF;

Line 294: asg_helper.log('Auto Sync: ' || l_is_auto_sync || ' and Download only sync: ' || l_is_download_only_sync

290: -- or not a download only sync
291: l_is_auto_sync := asg_base.is_auto_sync();
292: l_is_download_only_sync := asg_base.is_download_only_sync(p_clientid, p_curr_tranid);
293:
294: asg_helper.log('Auto Sync: ' || l_is_auto_sync || ' and Download only sync: ' || l_is_download_only_sync
295: ,'asg_cons_qpkg',g_stmt_level);
296:
297: IF (l_is_auto_sync = 'N'
298: OR l_is_download_only_sync = 'N') THEN

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

308: IF l_pwd_expired = 'Y' THEN
309: raise password_expired;
310: END IF;
311: -- Check if user's synch is disabled
312: IF asg_helper.is_user_synch_enabled(p_clientid,l_disabled_synch_message)
313: = FND_API.G_FALSE THEN
314: raise synch_disabled;
315: END IF;
316: -- Initialize all the session information except the list of pubitems

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

324: l_last_synch_date, asg_base.g_empty_pub_item_tbl);
325:
326: -- check out if this user needs complete
327: -- refresh since he's been a dormant user.
328: asg_helper.log('Checking if user: '
329: || p_clientid || ' needs complete refresh.',
330: 'asg_cons_qpkg',g_stmt_level);
331: process_purge_Sdq(p_clientid, p_last_tranid, p_curr_tranid);
332:

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

332:
333: IF(g_first_synch) THEN
334: set_synch_completed(p_clientid);
335: delete_row(p_clientid);
336: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
337: asg_helper.log('First synch..deleted all rows from asg_complete_refresh'
338: ,'asg_cons_qpkg',g_stmt_level);
339: END IF;
340: ELSE

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

333: IF(g_first_synch) THEN
334: set_synch_completed(p_clientid);
335: delete_row(p_clientid);
336: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
337: asg_helper.log('First synch..deleted all rows from asg_complete_refresh'
338: ,'asg_cons_qpkg',g_stmt_level);
339: END IF;
340: ELSE
341: process_compref_table(p_clientid,p_last_tranid);

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

354: l_sqlerror_message := SQLERRM;
355: else
356: l_sqlerror_message := l_ret_msg;
357: end if;
358: IF(asg_helper.check_is_log_enabled(g_err_level))
359: THEN
360: asg_helper.log('processsdq returned FALSE', 'asg_cons_qpkg',
361: g_err_level);
362: END IF;

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

356: l_sqlerror_message := l_ret_msg;
357: end if;
358: IF(asg_helper.check_is_log_enabled(g_err_level))
359: THEN
360: asg_helper.log('processsdq returned FALSE', 'asg_cons_qpkg',
361: g_err_level);
362: END IF;
363: asg_helper.set_synch_errmsg(p_clientid, null, g_device_type,'Error during download in asg_download.processsdq: '||
364: l_sqlerror_message);

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

359: THEN
360: asg_helper.log('processsdq returned FALSE', 'asg_cons_qpkg',
361: g_err_level);
362: END IF;
363: asg_helper.set_synch_errmsg(p_clientid, null, g_device_type,'Error during download in asg_download.processsdq: '||
364: l_sqlerror_message);
365:
366: RAISE_APPLICATION_ERROR(-20999, 'Error during download in ' ||
367: 'asg_download.processsdq ' ||

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

373:
374: --12.1
375: -- Start processing uploads when synchronized manually(i.e,not auto sync)
376: -- and when download is successful
377: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
378: 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);
379: END IF;
380: asg_helper.set_synch_errmsg(p_clientid,l_sync_id,g_device_type, null);
381: EXCEPTION

Line 378: 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);

374: --12.1
375: -- Start processing uploads when synchronized manually(i.e,not auto sync)
376: -- and when download is successful
377: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
378: 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);
379: END IF;
380: asg_helper.set_synch_errmsg(p_clientid,l_sync_id,g_device_type, null);
381: EXCEPTION
382:

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

376: -- and when download is successful
377: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
378: 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);
379: END IF;
380: asg_helper.set_synch_errmsg(p_clientid,l_sync_id,g_device_type, null);
381: EXCEPTION
382:
383: WHEN synch_disabled THEN
384: asg_helper.set_synch_errmsg(

Line 384: asg_helper.set_synch_errmsg(

380: asg_helper.set_synch_errmsg(p_clientid,l_sync_id,g_device_type, null);
381: EXCEPTION
382:
383: WHEN synch_disabled THEN
384: asg_helper.set_synch_errmsg(
385: p_clientid,null,g_device_type,
386: 'User Synch Error: '||
387: nvl(l_disabled_synch_message,'Synch is not enabled.'));
388:

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

385: p_clientid,null,g_device_type,
386: 'User Synch Error: '||
387: nvl(l_disabled_synch_message,'Synch is not enabled.'));
388:
389: IF(asg_helper.check_is_log_enabled(g_err_level)) THEN
390: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||
391: to_char(sysdate, 'yyyy-mm-dd') ||
392: ' Synch is not enabled.',
393: 'asg_cons_qpkg',g_err_level);

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

386: 'User Synch Error: '||
387: nvl(l_disabled_synch_message,'Synch is not enabled.'));
388:
389: IF(asg_helper.check_is_log_enabled(g_err_level)) THEN
390: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||
391: to_char(sysdate, 'yyyy-mm-dd') ||
392: ' Synch is not enabled.',
393: 'asg_cons_qpkg',g_err_level);
394: END IF;

Line 400: asg_helper.set_synch_errmsg(

396: l_disabled_synch_message := 'Synch is not enabled.';
397: END IF;
398: RAISE_APPLICATION_ERROR(-20994, l_disabled_synch_message);
399: WHEN password_expired THEN
400: asg_helper.set_synch_errmsg(
401: p_clientid,null,g_device_type,
402: 'User Synch Error: User Password Expired.');
403: IF(asg_helper.check_is_log_enabled(g_err_level)) THEN
404: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||

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

399: WHEN password_expired THEN
400: asg_helper.set_synch_errmsg(
401: p_clientid,null,g_device_type,
402: 'User Synch Error: User Password Expired.');
403: IF(asg_helper.check_is_log_enabled(g_err_level)) THEN
404: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||
405: to_char(sysdate, 'yyyy-mm-dd') ||
406: ' User Password Expired.',
407: 'asg_cons_qpkg',g_err_level);

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

400: asg_helper.set_synch_errmsg(
401: p_clientid,null,g_device_type,
402: 'User Synch Error: User Password Expired.');
403: IF(asg_helper.check_is_log_enabled(g_err_level)) THEN
404: asg_helper.log('User Synch Error: ' || p_clientid || ' ' ||
405: to_char(sysdate, 'yyyy-mm-dd') ||
406: ' User Password Expired.',
407: 'asg_cons_qpkg',g_err_level);
408: END IF;

Line 413: asg_helper.set_synch_errmsg(

409: RAISE_APPLICATION_ERROR(-20993, 'Your password has expired. ' ||
410: 'Please contact your System Administrator to reset the password.');
411: WHEN OTHERS THEN
412: l_sqlerror_message := SQLERRM;
413: asg_helper.set_synch_errmsg(
414: p_clientid,null,g_device_type,
415: 'User Synch Error: Exception in processsdq '||
416: l_sqlerror_message);
417: IF(asg_helper.check_is_log_enabled(g_err_level))

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

413: asg_helper.set_synch_errmsg(
414: p_clientid,null,g_device_type,
415: 'User Synch Error: Exception in processsdq '||
416: l_sqlerror_message);
417: IF(asg_helper.check_is_log_enabled(g_err_level))
418: THEN
419: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||
420: to_char(sysdate, 'yyyy-mm-dd') ||
421: ' transaction-id: ' || p_curr_tranid ||

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

415: 'User Synch Error: Exception in processsdq '||
416: l_sqlerror_message);
417: IF(asg_helper.check_is_log_enabled(g_err_level))
418: THEN
419: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||
420: to_char(sysdate, 'yyyy-mm-dd') ||
421: ' transaction-id: ' || p_curr_tranid ||
422: ' Exception in processsdq ' || l_sqlerror_message,
423: 'asg_cons_qpkg',g_err_level);

Line 437: asg_helper.log('download_init', 'asg_consq_pkg',g_err_level);

433: asg_base.set_pub_items(l_pub_item_tbl);
434:
435: -- Write to log all the session information for this user
436: asg_base.print_all_globals();
437: asg_helper.log('download_init', 'asg_consq_pkg',g_err_level);
438: END download_init;
439:
440: -- Notifies when all the client's data is sent
441: PROCEDURE download_complete(p_clientid IN VARCHAR2)

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

443: l_bool_ret BOOLEAN;
444: l_last_tranid NUMBER;
445: l_sqlerror_message VARCHAR2(512);
446: BEGIN
447: IF(asg_helper.check_is_log_enabled(g_stmt_level))
448: THEN
449: asg_helper.log('Download complete called for client: ' || p_clientid,
450: 'asg_cons_qpkg',g_stmt_level);
451: END IF;

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

445: l_sqlerror_message VARCHAR2(512);
446: BEGIN
447: IF(asg_helper.check_is_log_enabled(g_stmt_level))
448: THEN
449: asg_helper.log('Download complete called for client: ' || p_clientid,
450: 'asg_cons_qpkg',g_stmt_level);
451: END IF;
452: --new code
453: set_synch_completed(p_clientid);

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

455: BEGIN
456: l_bool_ret := asg_download.purgesdq();
457: IF l_bool_ret = FALSE THEN
458: l_sqlerror_message := SQLERRM;
459: IF(asg_helper.check_is_log_enabled(g_err_level))
460: THEN
461: asg_helper.log('purgesdq returned FALSE',
462: 'asg_cons_qpkg',g_err_level);
463: END IF;

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

457: IF l_bool_ret = FALSE THEN
458: l_sqlerror_message := SQLERRM;
459: IF(asg_helper.check_is_log_enabled(g_err_level))
460: THEN
461: asg_helper.log('purgesdq returned FALSE',
462: 'asg_cons_qpkg',g_err_level);
463: END IF;
464: RAISE_APPLICATION_ERROR(-20997, 'Error during download in ' ||
465: 'asg_download.purgesdq ' || l_sqlerror_message);

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

490: END IF;
491: -- Reset all session information
492: asg_base.reset_all_globals();
493:
494: IF(asg_helper.check_is_log_enabled(g_stmt_level))
495: THEN
496: asg_helper.log('Download complete DONE for client: ' || p_clientid,
497: 'asg_cons_qpkg',g_stmt_level);
498: END IF;

Line 496: asg_helper.log('Download complete DONE for client: ' || p_clientid,

492: asg_base.reset_all_globals();
493:
494: IF(asg_helper.check_is_log_enabled(g_stmt_level))
495: THEN
496: asg_helper.log('Download complete DONE for client: ' || p_clientid,
497: 'asg_cons_qpkg',g_stmt_level);
498: END IF;
499: EXCEPTION
500: WHEN OTHERS THEN

Line 502: asg_helper.set_synch_errmsg(

498: END IF;
499: EXCEPTION
500: WHEN OTHERS THEN
501: l_sqlerror_message := SQLERRM;
502: asg_helper.set_synch_errmsg(
503: p_clientid,null,g_device_type,
504: 'User Synch Error: Exception in purgesdq '||
505: l_sqlerror_message);
506:

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

503: p_clientid,null,g_device_type,
504: 'User Synch Error: Exception in purgesdq '||
505: l_sqlerror_message);
506:
507: IF(asg_helper.check_is_log_enabled(g_err_level))
508: THEN
509: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||
510: to_char(sysdate, 'yyyy-mm-dd') ||
511: ' transaction-id: ' || asg_base.get_current_tranid ||

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

505: l_sqlerror_message);
506:
507: IF(asg_helper.check_is_log_enabled(g_err_level))
508: THEN
509: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||
510: to_char(sysdate, 'yyyy-mm-dd') ||
511: ' transaction-id: ' || asg_base.get_current_tranid ||
512: ' Exception in purgesdq ' || l_sqlerror_message,
513: 'asg_cons_qpkg',g_err_level);

Line 524: asg_helper.set_synch_errmsg(

520: /**/
521: EXCEPTION
522: WHEN OTHERS THEN
523: l_sqlerror_message := SQLERRM;
524: asg_helper.set_synch_errmsg(
525: p_clientid,null,g_device_type,
526: 'User Synch Error: Exception in download_complete '||
527: l_sqlerror_message);
528:

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

525: p_clientid,null,g_device_type,
526: 'User Synch Error: Exception in download_complete '||
527: l_sqlerror_message);
528:
529: IF(asg_helper.check_is_log_enabled(g_err_level))
530: THEN
531: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||
532: to_char(sysdate, 'yyyy-mm-dd') ||
533: ' transaction-id: ' || asg_base.get_current_tranid ||

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

527: l_sqlerror_message);
528:
529: IF(asg_helper.check_is_log_enabled(g_err_level))
530: THEN
531: asg_helper.log('User Synch Error: ' ||p_clientid || ' ' ||
532: to_char(sysdate, 'yyyy-mm-dd') ||
533: ' transaction-id: ' || asg_base.get_current_tranid ||
534: ' Exception in download_complete ' || l_sqlerror_message,
535: 'asg_cons_qpkg',g_err_level);

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

569: IS
570: l_loopvar NUMBER;
571: l_qry_string VARCHAR2(1024);
572: BEGIN
573: IF(asg_helper.check_is_log_enabled(g_stmt_level))
574: THEN
575: asg_helper.log('Performing batch update for: '||p_clientid,
576: 'asg_cons_qpkg',g_stmt_level);
577: END IF;

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

571: l_qry_string VARCHAR2(1024);
572: BEGIN
573: IF(asg_helper.check_is_log_enabled(g_stmt_level))
574: THEN
575: asg_helper.log('Performing batch update for: '||p_clientid,
576: 'asg_cons_qpkg',g_stmt_level);
577: END IF;
578: FOR l_loopvar IN 1..p_pubitem_tbl.count
579: LOOP

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

584: ' set rec_count= :1 ' ||
585: ' where name = :2';
586: EXECUTE IMMEDIATE l_qry_string
587: USING p_pubitem_tbl(l_loopvar).rec_count, p_pubitem_tbl(l_loopvar).name;
588: /* asg_helper.log('Update: '||p_pubitem_tbl(l_loopvar).name||' count: '
589: ||p_pubitem_tbl(l_loopvar).rec_count,
590: 'asg.asg_cons_qpkg');
591: */
592: END IF;

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

611:
612: BEGIN
613: l_total:=0;
614: l_pubitem_tbl := p_pubitem_tbl;
615: IF(asg_helper.check_is_log_enabled(g_stmt_level))
616: THEN
617: asg_helper.log('Inside process_first_synch for :'||p_clientid,
618: 'asg_cons_qpkg',g_stmt_level);
619: END IF;

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

613: l_total:=0;
614: l_pubitem_tbl := p_pubitem_tbl;
615: IF(asg_helper.check_is_log_enabled(g_stmt_level))
616: THEN
617: asg_helper.log('Inside process_first_synch for :'||p_clientid,
618: 'asg_cons_qpkg',g_stmt_level);
619: END IF;
620: asg_base.init(p_clientid,-1,0,null,p_pubitem_tbl);
621:

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

623: LOOP
624: l_curr_pubitem:=l_pubitem_tbl(l_loopvar).name;
625: IF(l_curr_pubitem like 'C$%')
626: THEN
627: IF(asg_helper.check_is_log_enabled(g_stmt_level))
628: THEN
629: asg_helper.log('Ignoring : '||l_curr_pubitem,
630: 'asg_cons_qpkg',g_stmt_level);
631: END IF;

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

625: IF(l_curr_pubitem like 'C$%')
626: THEN
627: IF(asg_helper.check_is_log_enabled(g_stmt_level))
628: THEN
629: asg_helper.log('Ignoring : '||l_curr_pubitem,
630: 'asg_cons_qpkg',g_stmt_level);
631: END IF;
632: ELSE
633: select base_object_name,base_owner into l_view_name,l_owner_name

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

637: EXECUTE IMMEDIATE l_qry_string2 into l_rec_count1;
638: l_total:=l_total+l_rec_count1;
639: l_pubitem_tbl(l_loopvar).rec_count:=l_rec_count1;
640: END IF;
641: /* asg_helper.log('Pub Name '||l_curr_pubitem||' Count: '||l_rec_count1,
642: 'asg.asg_cons_qpkg');
643: */
644: END LOOP;
645: update_rec_count(l_pubitem_tbl,p_clientid);

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

642: 'asg.asg_cons_qpkg');
643: */
644: END LOOP;
645: update_rec_count(l_pubitem_tbl,p_clientid);
646: IF(asg_helper.check_is_log_enabled(g_stmt_level))
647: THEN
648: asg_helper.log('Total num of rows(First time synch): '||l_total,
649: 'asg_cons_qpkg',g_stmt_level);
650: END IF;

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

644: END LOOP;
645: update_rec_count(l_pubitem_tbl,p_clientid);
646: IF(asg_helper.check_is_log_enabled(g_stmt_level))
647: THEN
648: asg_helper.log('Total num of rows(First time synch): '||l_total,
649: 'asg_cons_qpkg',g_stmt_level);
650: END IF;
651: END process_first_synch;
652:

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

747: BEGIN
748: l_ret := is_previous_synch_successful(p_user_name,p_last_tranid);
749: IF( l_ret = FND_API.G_TRUE ) THEN
750: --previous synch was successful
751: IF(asg_helper.check_is_log_enabled(g_stmt_level))
752: THEN
753: asg_helper.log('Prev synch successful ',
754: 'asg_cons_qpkg',g_stmt_level);
755: END IF;

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

749: IF( l_ret = FND_API.G_TRUE ) THEN
750: --previous synch was successful
751: IF(asg_helper.check_is_log_enabled(g_stmt_level))
752: THEN
753: asg_helper.log('Prev synch successful ',
754: 'asg_cons_qpkg',g_stmt_level);
755: END IF;
756: delete_row(p_user_name);
757: ELSE

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

785: responsibility_id => null,
786: application_id => 689);
787:
788: IF (l_customProfValue = 'Y') THEN
789: IF(asg_helper.check_is_log_enabled(g_stmt_level))
790: THEN
791: asg_helper.log('Disabling download of custom pub items ',
792: 'asg_cons_qpkg', g_stmt_level);
793: END IF;

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

787:
788: IF (l_customProfValue = 'Y') THEN
789: IF(asg_helper.check_is_log_enabled(g_stmt_level))
790: THEN
791: asg_helper.log('Disabling download of custom pub items ',
792: 'asg_cons_qpkg', g_stmt_level);
793: END IF;
794: l_dml := 'DELETE FROM '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q ' ||
795: ' WHERE name IN ' ||

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

813:
814: l_upload_tranid := asg_base.get_upload_tranid();
815:
816: -- Check if conflict detection is needed other wise return
817: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
818: asg_helper.log('Checking if conflicts should be detected.',
819: 'asg_cons_qpkg',g_stmt_level);
820: END IF;
821: is_conflict_detection_needed (p_user_name,

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

814: l_upload_tranid := asg_base.get_upload_tranid();
815:
816: -- Check if conflict detection is needed other wise return
817: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
818: asg_helper.log('Checking if conflicts should be detected.',
819: 'asg_cons_qpkg',g_stmt_level);
820: END IF;
821: is_conflict_detection_needed (p_user_name,
822: l_upload_tranid,

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

823: l_detect_conflict,
824: l_pubitem_tbl);
825:
826: IF (l_detect_conflict = FND_API.G_FALSE) THEN
827: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
828: asg_helper.log('No need to check for conflicts.',
829: 'asg_cons_qpkg',g_stmt_level);
830: END IF;
831: return;

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

824: l_pubitem_tbl);
825:
826: IF (l_detect_conflict = FND_API.G_FALSE) THEN
827: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
828: asg_helper.log('No need to check for conflicts.',
829: 'asg_cons_qpkg',g_stmt_level);
830: END IF;
831: return;
832: END IF;

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

833:
834: -- Ok, conflicts need to be detected, process one pubitem at a time
835: FOR curr_index in 1..l_pubitem_tbl.count LOOP
836: l_pubitem := l_pubitem_tbl(curr_index).name;
837: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
838: asg_helper.log('Processing ' ||l_pubitem || ' for conflicts.',
839: 'asg_cons_qpkg',g_stmt_level);
840: END IF;
841: process_pubitem_conflicts(p_user_name, l_upload_tranid, l_pubitem);

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

834: -- Ok, conflicts need to be detected, process one pubitem at a time
835: FOR curr_index in 1..l_pubitem_tbl.count LOOP
836: l_pubitem := l_pubitem_tbl(curr_index).name;
837: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
838: asg_helper.log('Processing ' ||l_pubitem || ' for conflicts.',
839: 'asg_cons_qpkg',g_stmt_level);
840: END IF;
841: process_pubitem_conflicts(p_user_name, l_upload_tranid, l_pubitem);
842: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

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

838: asg_helper.log('Processing ' ||l_pubitem || ' for conflicts.',
839: 'asg_cons_qpkg',g_stmt_level);
840: END IF;
841: process_pubitem_conflicts(p_user_name, l_upload_tranid, l_pubitem);
842: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
843: asg_helper.log('Done processing ' ||l_pubitem || ' for conflicts.',
844: 'asg_cons_qpkg',g_stmt_level);
845: END IF;
846: END LOOP;

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

839: 'asg_cons_qpkg',g_stmt_level);
840: END IF;
841: process_pubitem_conflicts(p_user_name, l_upload_tranid, l_pubitem);
842: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
843: asg_helper.log('Done processing ' ||l_pubitem || ' for conflicts.',
844: 'asg_cons_qpkg',g_stmt_level);
845: END IF;
846: END LOOP;
847:

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

844: 'asg_cons_qpkg',g_stmt_level);
845: END IF;
846: END LOOP;
847:
848: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
849: asg_helper.log('Done processing all conflicts.',
850: 'asg_cons_qpkg',g_stmt_level);
851: END IF;
852: EXCEPTION

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

845: END IF;
846: END LOOP;
847:
848: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
849: asg_helper.log('Done processing all conflicts.',
850: 'asg_cons_qpkg',g_stmt_level);
851: END IF;
852: EXCEPTION
853: WHEN OTHERS THEN

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

850: 'asg_cons_qpkg',g_stmt_level);
851: END IF;
852: EXCEPTION
853: WHEN OTHERS THEN
854: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
855: asg_helper.log('Exception when processing for conflicts. ' || sqlerrm,
856: 'asg_cons_qpkg',g_stmt_level);
857: END IF;
858: END process_conflicts;

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

851: END IF;
852: EXCEPTION
853: WHEN OTHERS THEN
854: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
855: asg_helper.log('Exception when processing for conflicts. ' || sqlerrm,
856: 'asg_cons_qpkg',g_stmt_level);
857: END IF;
858: END process_conflicts;
859:

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

927: */
928: l_query_string2 := 'SELECT ' || l_pub_callback ||
929: '.detect_conflict( :1 ) from dual';
930:
931: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
932: asg_helper.log('SQL Command: ' || replace(l_query_string2,'''',''''''),
933: 'asg_cons_qpkg',g_stmt_level);
934: END IF;
935: BEGIN

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

928: l_query_string2 := 'SELECT ' || l_pub_callback ||
929: '.detect_conflict( :1 ) from dual';
930:
931: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
932: asg_helper.log('SQL Command: ' || replace(l_query_string2,'''',''''''),
933: 'asg_cons_qpkg',g_stmt_level);
934: END IF;
935: BEGIN
936: /*

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

944: EXECUTE IMMEDIATE l_query_string2
945: INTO l_pub_detect_conflict
946: USING p_user_name;
947:
948: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
949: asg_helper.log('Publication callback returned: ' ||
950: l_pub_detect_conflict,
951: 'asg_cons_qpkg',g_stmt_level);
952: END IF;

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

945: INTO l_pub_detect_conflict
946: USING p_user_name;
947:
948: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
949: asg_helper.log('Publication callback returned: ' ||
950: l_pub_detect_conflict,
951: 'asg_cons_qpkg',g_stmt_level);
952: END IF;
953: IF (l_pub_detect_conflict = asg_base.G_YES) THEN

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

961: l_counter := l_counter +1;
962: END IF;
963: EXCEPTION
964: WHEN OTHERS THEN
965: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
966: asg_helper.log('Exception in wrapper callback ' ||SQLERRM,
967: 'asg_cons_qpkg',g_stmt_level);
968: END IF;
969: END;

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

962: END IF;
963: EXCEPTION
964: WHEN OTHERS THEN
965: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
966: asg_helper.log('Exception in wrapper callback ' ||SQLERRM,
967: 'asg_cons_qpkg',g_stmt_level);
968: END IF;
969: END;
970: END LOOP;

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

972:
973: -- Some pubs need conflict detection
974: IF (l_counter > 1) THEN
975: p_detect_conflict := FND_API.G_TRUE;
976: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
977: asg_helper.log('Need to detect conflicts.',
978: 'asg_cons_qpkg',g_stmt_level);
979: END IF;
980: get_conf_pub_items_list(p_user_name, p_upload_tranid,

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

973: -- Some pubs need conflict detection
974: IF (l_counter > 1) THEN
975: p_detect_conflict := FND_API.G_TRUE;
976: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
977: asg_helper.log('Need to detect conflicts.',
978: 'asg_cons_qpkg',g_stmt_level);
979: END IF;
980: get_conf_pub_items_list(p_user_name, p_upload_tranid,
981: l_conf_pubs, p_pubitem_tbl);

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

1004: ' ci.store = cpq.name AND ' ||
1005: ' cpq.comp_ref <> ''Y'' AND ' ||
1006: ' api.detect_conflict = ''Y''';
1007:
1008: IF(asg_helper.check_is_log_enabled(g_stmt_level))
1009: THEN
1010: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),
1011: 'asg_cons_qpkg',g_stmt_level);
1012: END IF;

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

1006: ' api.detect_conflict = ''Y''';
1007:
1008: IF(asg_helper.check_is_log_enabled(g_stmt_level))
1009: THEN
1010: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),
1011: 'asg_cons_qpkg',g_stmt_level);
1012: END IF;
1013:
1014: EXECUTE IMMEDIATE l_query_string

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

1069: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1070: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pubitem);
1071: p_pubitem_tbl(l_counter).name := l_pubitem;
1072: l_counter := l_counter +1;
1073: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1074: asg_helper.log('Pub item that will be checked for conflicts: ' ||
1075: l_pubitem, 'asg_cons_qpkg',g_stmt_level);
1076: END IF;
1077: END LOOP;

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

1070: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pubitem);
1071: p_pubitem_tbl(l_counter).name := l_pubitem;
1072: l_counter := l_counter +1;
1073: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1074: asg_helper.log('Pub item that will be checked for conflicts: ' ||
1075: l_pubitem, 'asg_cons_qpkg',g_stmt_level);
1076: END IF;
1077: END LOOP;
1078:

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

1095: l_cursor_id NUMBER;
1096: l_pub_name varchar2(30);
1097: l_ret_val NUMBER;
1098: BEGIN
1099: asg_helper.log('Processing Purge SDQ','asg_cons_qpkg',g_stmt_level);
1100:
1101: l_qry_string := 'select distinct pub_name from asg_pub_item where item_id in '||
1102: ' ( select name from '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q )';
1103: l_cursor_id := dbms_sql.open_cursor();

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

1118: THEN
1119: IF(l_tran_id = -100 )
1120: THEN
1121: -- process first time .set publication to complete refresh
1122: asg_helper.log('Setting user '||p_clientid||' to complete refresh for '||
1123: ' publication '||l_pub_name,'asg_cons_qpkg',g_stmt_level);
1124: l_qry_string1 := 'update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '||
1125: ' set comp_ref = ''Y'' where name in '||
1126: ' ( select item_id from asg_pub_item where '||

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

1132: WHERE user_name=p_clientid AND pub_name = l_pub_name;
1133: ELSIF ( p_last_tranid < l_tran_id )
1134: THEN
1135: -- last synch failed. ..so again set to complete refresh .
1136: asg_helper.log('Re-setting user '||p_clientid||' to complete refresh for '||
1137: ' publication '||l_pub_name,'asg_cons_qpkg',g_stmt_level);
1138: l_qry_string1 := 'update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '||
1139: ' set comp_ref = ''Y'' where name in '||
1140: ' ( select item_id from asg_pub_item where '||

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

1145: SET transaction_id=p_curr_tranid,last_update_date=sysdate
1146: WHERE user_name=p_clientid AND pub_name = l_pub_name;
1147: ELSE
1148: --previous synch succeded ..so delete from purge_sdq
1149: asg_helper.log('Deleting asg_purge_sdq for user '||p_clientid||' and '||
1150: ' publication '||l_pub_name,'asg_cons_qpkg',g_stmt_level);
1151: DELETE FROM asg_purge_sdq
1152: WHERE user_name = p_clientid AND pub_name = l_pub_name;
1153: END IF;

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

1157: CLOSE c_purgeSdq;
1158: END LOOP;
1159:
1160: dbms_sql.close_cursor(l_cursor_id);
1161: asg_helper.log('End processing purgeSDQ','asg_cons_qpkg',g_stmt_level);
1162: EXCEPTION
1163: WHEN OTHERS THEN
1164: asg_helper.log('Exception in process_purge_sdq: ' || sqlerrm,
1165: 'asg_cons_qpkg',g_err_level);

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

1160: dbms_sql.close_cursor(l_cursor_id);
1161: asg_helper.log('End processing purgeSDQ','asg_cons_qpkg',g_stmt_level);
1162: EXCEPTION
1163: WHEN OTHERS THEN
1164: asg_helper.log('Exception in process_purge_sdq: ' || sqlerrm,
1165: 'asg_cons_qpkg',g_err_level);
1166: RAISE;
1167: END process_purge_Sdq;
1168:

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

1248: 'FROM ' || l_inqtable_name ||
1249: 'WHERE clid$$cs = :1 AND ' ||
1250: ' tranid$$ = :2 AND ' ||
1251: ' dmltype$$ = ''U''';
1252: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1253: asg_helper.log('SQL Command: ' || replace(l_query_string, '''', ''''''),
1254: 'asg_cons_qpkg',g_stmt_level);
1255: END IF;
1256:

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

1249: 'WHERE clid$$cs = :1 AND ' ||
1250: ' tranid$$ = :2 AND ' ||
1251: ' dmltype$$ = ''U''';
1252: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1253: asg_helper.log('SQL Command: ' || replace(l_query_string, '''', ''''''),
1254: 'asg_cons_qpkg',g_stmt_level);
1255: END IF;
1256:
1257: EXECUTE IMMEDIATE l_query_string

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

1258: INTO l_client_update_count
1259: USING p_user_name, p_upload_tranid;
1260:
1261: IF (l_client_update_count =0) THEN
1262: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1263: asg_helper.log('No conflicts exist.',
1264: 'asg_cons_qpkg',g_stmt_level);
1265: END IF;
1266: return;

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

1259: USING p_user_name, p_upload_tranid;
1260:
1261: IF (l_client_update_count =0) THEN
1262: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1263: asg_helper.log('No conflicts exist.',
1264: 'asg_cons_qpkg',g_stmt_level);
1265: END IF;
1266: return;
1267: END IF;

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

1293: download_flag = 'Y' AND
1294: dml_type = 2;
1295: l_server_update_count := SQL%ROWCOUNT;
1296:
1297: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1298: asg_helper.log('Number of updates in server: ' || l_server_update_count,
1299: 'asg_cons_qpkg',g_stmt_level);
1300: END IF;
1301:

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

1294: dml_type = 2;
1295: l_server_update_count := SQL%ROWCOUNT;
1296:
1297: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1298: asg_helper.log('Number of updates in server: ' || l_server_update_count,
1299: 'asg_cons_qpkg',g_stmt_level);
1300: END IF;
1301:
1302: -- No updates from server. Return. Only conflicts between updates from

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

1301:
1302: -- No updates from server. Return. Only conflicts between updates from
1303: -- client and updates from server are detected.
1304: IF (l_server_update_count = 0) THEN
1305: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1306: asg_helper.log('No conflicts exist.',
1307: 'asg_cons_qpkg',g_stmt_level);
1308: END IF;
1309: return;

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

1302: -- No updates from server. Return. Only conflicts between updates from
1303: -- client and updates from server are detected.
1304: IF (l_server_update_count = 0) THEN
1305: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1306: asg_helper.log('No conflicts exist.',
1307: 'asg_cons_qpkg',g_stmt_level);
1308: END IF;
1309: return;
1310: END IF;

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

1329: ' WHERE user_name = :6 AND ' ||
1330: ' transaction_id = :7 AND ' ||
1331: ' pub_item = :8';
1332:
1333: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1334: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),
1335: 'asg_cons_qpkg',g_stmt_level);
1336: END IF;
1337: EXECUTE IMMEDIATE l_query_string

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

1330: ' transaction_id = :7 AND ' ||
1331: ' pub_item = :8';
1332:
1333: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1334: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),
1335: 'asg_cons_qpkg',g_stmt_level);
1336: END IF;
1337: EXECUTE IMMEDIATE l_query_string
1338: USING p_user_name, p_upload_tranid,

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

1348: '(''' || p_user_name || ''', ' || p_upload_tranid ||
1349: ', ' || l_sequence || ') from dual';*/
1350: l_query_string := 'SELECT ' || l_conflict_callout ||
1351: '(:1,:2,:3) from dual';
1352: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1353: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),
1354: 'asg_cons_qpkg',g_stmt_level);
1355: END IF;
1356: BEGIN

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

1349: ', ' || l_sequence || ') from dual';*/
1350: l_query_string := 'SELECT ' || l_conflict_callout ||
1351: '(:1,:2,:3) from dual';
1352: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1353: asg_helper.log('SQL Command: ' || replace(l_query_string,'''',''''''),
1354: 'asg_cons_qpkg',g_stmt_level);
1355: END IF;
1356: BEGIN
1357: l_conf_resolution := l_client_wins;

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

1359: INTO l_conf_resolution
1360: USING p_user_name,p_upload_tranid,l_sequence ;
1361: EXCEPTION
1362: WHEN OTHERS THEN
1363: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1364: asg_helper.log('Exception in pub item level callback. ' || sqlerrm,
1365: 'asg_cons_qpkg',g_stmt_level);
1366: END IF;
1367: END;

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

1360: USING p_user_name,p_upload_tranid,l_sequence ;
1361: EXCEPTION
1362: WHEN OTHERS THEN
1363: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1364: asg_helper.log('Exception in pub item level callback. ' || sqlerrm,
1365: 'asg_cons_qpkg',g_stmt_level);
1366: END IF;
1367: END;
1368: IF (l_conf_resolution = l_server_wins) THEN

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

1399: p_upload_tranid IN NUMBER)
1400: IS
1401: PRAGMA AUTONOMOUS_TRANSACTION;
1402: BEGIN
1403: asg_helper.update_hwm_tranid(p_user_name, p_upload_tranid);
1404: commit;
1405: EXCEPTION
1406: WHEN OTHERS THEN
1407: rollback;

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

1473: l_last_synch_date DATE;
1474: BEGIN
1475: IF ((p_last_tranid <= -1) OR
1476: (g_first_synch = TRUE)) THEN
1477: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1478: asg_helper.log('First Synch detected.',
1479: 'asg_cons_qpkg',g_stmt_level);
1480: END IF;
1481: return NULL;

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

1474: BEGIN
1475: IF ((p_last_tranid <= -1) OR
1476: (g_first_synch = TRUE)) THEN
1477: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1478: asg_helper.log('First Synch detected.',
1479: 'asg_cons_qpkg',g_stmt_level);
1480: END IF;
1481: return NULL;
1482: ELSE

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

1481: return NULL;
1482: ELSE
1483: g_last_synch_successful := is_previous_synch_successful(p_user_name,
1484: p_last_tranid);
1485: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1486: asg_helper.log('Last Synch Successful: ' || g_last_synch_successful,
1487: 'asg_cons_qpkg',g_stmt_level);
1488: END IF;
1489: IF (g_last_synch_successful = FND_API.G_TRUE) THEN

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

1482: ELSE
1483: g_last_synch_successful := is_previous_synch_successful(p_user_name,
1484: p_last_tranid);
1485: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1486: asg_helper.log('Last Synch Successful: ' || g_last_synch_successful,
1487: 'asg_cons_qpkg',g_stmt_level);
1488: END IF;
1489: IF (g_last_synch_successful = FND_API.G_TRUE) THEN
1490: SELECT last_synch_date_end into l_last_synch_date