DBA Data[Home] [Help]

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.4 2008/05/21 06:53:48 saradhak ship $*/
3:
4: -- DESCRIPTION
5: -- This package contains callbacks registered with Oracle Lite

Line 145: 'asg_cons_qpkg',g_stmt_level);

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

Line 186: 'asg_cons_qpkg',g_stmt_level);

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

Line 211: 'asg_cons_qpkg',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;
213: IF l_disabled_synch_message IS NULL THEN
214: l_disabled_synch_message := 'Synch is not enabled.';
215: END IF;

Line 227: 'asg_cons_qpkg', g_err_level);

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);
228: END IF;
229: asg_helper.set_synch_errmsg(p_clientid,null,g_device_type,
230: 'User Synch Error: ' ||
231: ' Exception in upload_complete. ' ||

Line 263: 'asg_cons_qpkg',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;
265: BEGIN
266: l_upload_tranid := asg_base.get_upload_tranid();
267: l_sync_id:=set_sync_id(p_clientid, l_upload_tranid); --12.1

Line 295: 'asg_cons_qpkg',g_stmt_level);

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

Line 303: ,'asg_cons_qpkg',g_stmt_level);

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

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

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;
360: IF l_disabled_synch_message IS NULL THEN
361: l_disabled_synch_message := 'Synch is not enabled.';
362: END IF;

Line 372: 'asg_cons_qpkg',g_err_level);

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

Line 388: 'asg_cons_qpkg',g_err_level);

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);
389: END IF;
390: RAISE_APPLICATION_ERROR(-20998, 'Exception during download ' ||
391: l_sqlerror_message);
392: END;

Line 414: 'asg_cons_qpkg',g_stmt_level);

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

Line 426: 'asg_cons_qpkg',g_err_level);

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

Line 472: 'asg_cons_qpkg',g_err_level);

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);
473: END IF;
474: -- Reset all session information
475: asg_base.reset_all_globals();
476: RAISE_APPLICATION_ERROR(-20996, 'Exception during download ' ||

Line 494: 'asg_cons_qpkg',g_err_level);

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);
495: END IF;
496: -- Reset all session information
497: asg_base.reset_all_globals();
498: RAISE_APPLICATION_ERROR(-20996, 'Exception during download ' ||

Line 535: 'asg_cons_qpkg',g_stmt_level);

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

Line 549: 'asg.asg_cons_qpkg');

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;
552: END LOOP;
553: END update_rec_count;

Line 577: 'asg_cons_qpkg',g_stmt_level);

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

Line 589: 'asg_cons_qpkg',g_stmt_level);

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

Line 601: 'asg.asg_cons_qpkg');

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

Line 608: 'asg_cons_qpkg',g_stmt_level);

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

Line 713: 'asg_cons_qpkg',g_stmt_level);

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

Line 751: 'asg_cons_qpkg', g_stmt_level);

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

Line 778: 'asg_cons_qpkg',g_stmt_level);

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

Line 788: 'asg_cons_qpkg',g_stmt_level);

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

Line 798: 'asg_cons_qpkg',g_stmt_level);

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

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

Line 809: 'asg_cons_qpkg',g_stmt_level);

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

Line 815: 'asg_cons_qpkg',g_stmt_level);

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

Line 892: 'asg_cons_qpkg',g_stmt_level);

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

Line 910: 'asg_cons_qpkg',g_stmt_level);

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

Line 926: 'asg_cons_qpkg',g_stmt_level);

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

Line 937: 'asg_cons_qpkg',g_stmt_level);

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

Line 970: 'asg_cons_qpkg',g_stmt_level);

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

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

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

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

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

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

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

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

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

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

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

Line 1213: 'asg_cons_qpkg',g_stmt_level);

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

Line 1223: 'asg_cons_qpkg',g_stmt_level);

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

Line 1258: 'asg_cons_qpkg',g_stmt_level);

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

Line 1266: 'asg_cons_qpkg',g_stmt_level);

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

Line 1294: 'asg_cons_qpkg',g_stmt_level);

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

Line 1313: 'asg_cons_qpkg',g_stmt_level);

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

Line 1324: 'asg_cons_qpkg',g_stmt_level);

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

Line 1438: 'asg_cons_qpkg',g_stmt_level);

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

Line 1446: 'asg_cons_qpkg',g_stmt_level);

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

Line 1475: END asg_cons_qpkg;

1471: return l_device_type;
1472: END find_device_type;
1473:
1474:
1475: END asg_cons_qpkg;