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_CONS_QPKG

Line 1: PACKAGE BODY asg_cons_qpkg AS

1: PACKAGE BODY asg_cons_qpkg AS
2: /*$Header: asgconqb.pls 120.8.12020000.3 2013/04/09 11:55:31 saradhak ship $*/
3:
4: -- DESCRIPTION
5: -- This package contains callbacks registered with Oracle Lite

Line 148: 'asg_cons_qpkg',g_stmt_level);

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:
151: IF p_upload_tranid IS NULL THEN
152: OPEN c_sync_id(p_user_name);

Line 190: 'asg_cons_qpkg',g_stmt_level);

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:
193: BEGIN
194: -- Check if user's synch is disabled

Line 230: 'asg_cons_qpkg',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;
232: IF l_disabled_synch_message IS NULL THEN
233: l_disabled_synch_message := 'Synch is not enabled.';
234: END IF;

Line 246: 'asg_cons_qpkg', g_err_level);

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);
247: END IF;
248: asg_helper.set_synch_errmsg(p_clientid,null,g_device_type,
249: 'User Synch Error: ' ||
250: ' Exception in upload_complete. ' ||

Line 284: 'asg_cons_qpkg',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;
286: BEGIN
287: l_upload_tranid := asg_base.get_upload_tranid();
288:

Line 295: ,'asg_cons_qpkg',g_stmt_level);

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
299: l_sync_id:=set_sync_id(p_clientid, l_upload_tranid);

Line 330: 'asg_cons_qpkg',g_stmt_level);

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:
333: IF(g_first_synch) THEN
334: set_synch_completed(p_clientid);

Line 338: ,'asg_cons_qpkg',g_stmt_level);

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);
342: set_complete_refresh;

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 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 393: 'asg_cons_qpkg',g_err_level);

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;
395: IF l_disabled_synch_message IS NULL THEN
396: l_disabled_synch_message := 'Synch is not enabled.';
397: END IF;

Line 407: 'asg_cons_qpkg',g_err_level);

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;
409: RAISE_APPLICATION_ERROR(-20993, 'Your password has expired. ' ||
410: 'Please contact your System Administrator to reset the password.');
411: WHEN OTHERS THEN

Line 423: 'asg_cons_qpkg',g_err_level);

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);
424: END IF;
425: RAISE_APPLICATION_ERROR(-20998, 'Exception during download ' ||
426: l_sqlerror_message);
427: END;

Line 450: 'asg_cons_qpkg',g_stmt_level);

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);
454:

Line 462: 'asg_cons_qpkg',g_err_level);

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);
466: END IF;

Line 497: 'asg_cons_qpkg',g_stmt_level);

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
501: l_sqlerror_message := SQLERRM;

Line 513: 'asg_cons_qpkg',g_err_level);

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);
514: END IF;
515: -- Reset all session information
516: asg_base.reset_all_globals();
517: RAISE_APPLICATION_ERROR(-20996, 'Exception during download ' ||

Line 535: 'asg_cons_qpkg',g_err_level);

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);
536: END IF;
537: -- Reset all session information
538: asg_base.reset_all_globals();
539: RAISE_APPLICATION_ERROR(-20996, 'Exception during download ' ||

Line 576: 'asg_cons_qpkg',g_stmt_level);

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
580: IF(p_pubitem_tbl(l_loopvar).rec_count is not null OR

Line 590: 'asg.asg_cons_qpkg');

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;
593: END LOOP;
594: END update_rec_count;

Line 618: 'asg_cons_qpkg',g_stmt_level);

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:
622: FOR l_loopvar in 1..l_pubitem_tbl.count

Line 630: 'asg_cons_qpkg',g_stmt_level);

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
634: from asg_pub_item where item_id=l_curr_pubitem;

Line 642: 'asg.asg_cons_qpkg');

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

Line 649: 'asg_cons_qpkg',g_stmt_level);

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:
653: -- Populates the number of records for each publication item downloaded

Line 754: 'asg_cons_qpkg',g_stmt_level);

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
758: --previous synch was not successful

Line 792: 'asg_cons_qpkg', g_stmt_level);

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 ' ||
796: ' (select a.name from asg_pub_item a,asg_pub b' ||

Line 819: 'asg_cons_qpkg',g_stmt_level);

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,
823: l_detect_conflict,

Line 829: 'asg_cons_qpkg',g_stmt_level);

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;
833:

Line 839: 'asg_cons_qpkg',g_stmt_level);

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
843: asg_helper.log('Done processing ' ||l_pubitem || ' for conflicts.',

Line 844: '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:
848: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN

Line 850: 'asg_cons_qpkg',g_stmt_level);

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

Line 856: 'asg_cons_qpkg',g_stmt_level);

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:
860: -- Routine to determine if conflicts should be detected

Line 933: 'asg_cons_qpkg',g_stmt_level);

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: /*
937: l_cursor_id2 := DBMS_SQL.OPEN_CuRSOR();

Line 951: 'asg_cons_qpkg',g_stmt_level);

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
954: -- Conflicts should be detected for this publication
955: -- Build a comma separated list for use later.

Line 967: 'asg_cons_qpkg',g_stmt_level);

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;
971: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);

Line 978: 'asg_cons_qpkg',g_stmt_level);

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);
982: END IF;

Line 1011: 'asg_cons_qpkg',g_stmt_level);

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
1015: INTO l_conf_pi_count

Line 1075: l_pubitem, 'asg_cons_qpkg',g_stmt_level);

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:
1079: END get_conf_pub_items_list;

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 1123: ' publication '||l_pub_name,'asg_cons_qpkg',g_stmt_level);

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 '||
1127: ' pub_name = :1 )';

Line 1137: ' publication '||l_pub_name,'asg_cons_qpkg',g_stmt_level);

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 '||
1141: ' pub_name = :1 )';

Line 1150: ' publication '||l_pub_name,'asg_cons_qpkg',g_stmt_level);

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;
1154: ELSE

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 1165: 'asg_cons_qpkg',g_err_level);

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:
1169: FUNCTION get_pk_predicate(l_primary_key_columns IN VARCHAR2)

Line 1254: 'asg_cons_qpkg',g_stmt_level);

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
1258: INTO l_client_update_count

Line 1264: 'asg_cons_qpkg',g_stmt_level);

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;
1268:

Line 1299: 'asg_cons_qpkg',g_stmt_level);

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
1303: -- client and updates from server are detected.

Line 1307: 'asg_cons_qpkg',g_stmt_level);

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;
1311:

Line 1335: 'asg_cons_qpkg',g_stmt_level);

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,
1339: p_user_name, p_upload_tranid, p_pubitem,

Line 1354: 'asg_cons_qpkg',g_stmt_level);

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;
1358: EXECUTE IMMEDIATE l_query_string

Line 1365: 'asg_cons_qpkg',g_stmt_level);

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
1369: UPDATE asg_conf_info

Line 1479: 'asg_cons_qpkg',g_stmt_level);

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
1483: g_last_synch_successful := is_previous_synch_successful(p_user_name,

Line 1487: 'asg_cons_qpkg',g_stmt_level);

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
1491: FROM asg_user

Line 1516: END asg_cons_qpkg;

1512: return l_device_type;
1513: END find_device_type;
1514:
1515:
1516: END asg_cons_qpkg;