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_BASE

Line 56: PROCEDURE get_pubitem_list(p_pubitem_tbl IN OUT NOCOPY asg_base.pub_item_tbl_type)

52: g_first_synch BOOLEAN := FALSE;
53: g_last_synch_successful VARCHAR2(1) := FND_API.G_TRUE;
54: g_device_type VARCHAR2(30):= NULL;
55:
56: PROCEDURE get_pubitem_list(p_pubitem_tbl IN OUT NOCOPY asg_base.pub_item_tbl_type)
57: IS
58: counter PLS_INTEGER;
59: l_cursor_id NUMBER;
60: l_cursor_ret NUMBER;

Line 66: p_pubitem_tbl:=asg_base.g_empty_pub_item_tbl;

62: l_pubitem_name VARCHAR2(30);
63: l_comp_ref VARCHAR2(1);
64: BEGIN
65: --set the pub item table to empty
66: p_pubitem_tbl:=asg_base.g_empty_pub_item_tbl;
67: l_select_pi_sqlstring :=
68: 'SELECT name, comp_ref ' ||
69: 'FROM ' || asg_base.G_OLITE_SCHEMA ||'.' ||'c$pub_list_q';
70:

Line 69: 'FROM ' || asg_base.G_OLITE_SCHEMA ||'.' ||'c$pub_list_q';

65: --set the pub item table to empty
66: p_pubitem_tbl:=asg_base.g_empty_pub_item_tbl;
67: l_select_pi_sqlstring :=
68: 'SELECT name, comp_ref ' ||
69: 'FROM ' || asg_base.G_OLITE_SCHEMA ||'.' ||'c$pub_list_q';
70:
71: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
72: DBMS_SQL.PARSE (l_cursor_id, l_select_pi_sqlstring, DBMS_SQL.v7);
73: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pubitem_name, 30);

Line 195: asg_base.set_upload_tranid(p_tranid);

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

Line 252: l_pub_item_tbl asg_base.pub_item_tbl_type;

248: l_disabled_synch_message VARCHAR2(2000);
249: l_sqlerror_message VARCHAR2(512);
250: synch_disabled EXCEPTION;
251: password_expired EXCEPTION;
252: l_pub_item_tbl asg_base.pub_item_tbl_type;
253: l_bool_ret BOOLEAN;
254: l_ret_msg varchar2(512);
255: l_pwd_expired VARCHAR2(1);
256: l_sync_id NUMBER;

Line 266: l_upload_tranid := asg_base.get_upload_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
268: -- This is relevant only for first synch
269: -- Raise error if password has expired.
270: -- Subsequent synchs raise error during authentication itself.

Line 288: asg_base.init(p_clientid, p_last_tranid, p_curr_tranid,

284: g_first_synch := asg_download.isFirstSync();
285: l_last_synch_date := find_last_synch_date(p_clientid,
286: p_last_tranid);
287: g_device_type := find_device_type(p_clientid);
288: asg_base.init(p_clientid, p_last_tranid, p_curr_tranid,
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.

Line 289: l_last_synch_date, asg_base.g_empty_pub_item_tbl);

285: l_last_synch_date := find_last_synch_date(p_clientid,
286: p_last_tranid);
287: g_device_type := find_device_type(p_clientid);
288: asg_base.init(p_clientid, p_last_tranid, p_curr_tranid,
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: '

Line 398: asg_base.set_pub_items(l_pub_item_tbl);

394: -- The final pub items list should be in l_pub_item_tbl
395: get_pubitem_list(l_pub_item_tbl);
396:
397: -- Store the list of pubitems to be refreshed
398: asg_base.set_pub_items(l_pub_item_tbl);
399:
400: -- Write to log all the session information for this user
401: asg_base.print_all_globals();
402: END download_init;

Line 401: asg_base.print_all_globals();

397: -- Store the list of pubitems to be refreshed
398: asg_base.set_pub_items(l_pub_item_tbl);
399:
400: -- Write to log all the session information for this user
401: asg_base.print_all_globals();
402: END download_init;
403:
404: -- Notifies when all the client's data is sent
405: PROCEDURE download_complete(p_clientid IN VARCHAR2)

Line 433: l_last_tranid := asg_base.get_last_tranid();

429: 'asg_download.purgesdq ' || l_sqlerror_message);
430: END IF;
431:
432: -- Update the synctime end in asg_user table
433: l_last_tranid := asg_base.get_last_tranid();
434: IF ((l_last_tranid <= -1) OR
435: (g_first_synch = TRUE)) THEN
436: UPDATE asg_user
437: SET last_tranid = l_last_tranid,

Line 445: prior_synch_date_end = asg_base.get_last_synch_date(),

441: ELSE
442: IF(g_last_synch_successful = FND_API.G_TRUE) THEN
443: UPDATE asg_user
444: SET last_tranid = l_last_tranid,
445: prior_synch_date_end = asg_base.get_last_synch_date(),
446: last_synch_date_end = sysdate
447: WHERE user_name = p_clientid;
448: ELSE
449: UPDATE asg_user

Line 456: asg_base.reset_all_globals();

452: WHERE user_name = p_clientid;
453: END IF;
454: END IF;
455: -- Reset all session information
456: asg_base.reset_all_globals();
457:
458: EXCEPTION
459: WHEN OTHERS THEN
460: l_sqlerror_message := SQLERRM;

Line 470: ' transaction-id: ' || asg_base.get_current_tranid ||

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);
473: END IF;
474: -- Reset all session information

Line 475: asg_base.reset_all_globals();

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 ' ||
477: l_sqlerror_message);
478: END ;
479: /**/

Line 492: ' transaction-id: ' || asg_base.get_current_tranid ||

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);
495: END IF;
496: -- Reset all session information

Line 497: asg_base.reset_all_globals();

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 ' ||
499: l_sqlerror_message);
500: END download_complete;
501:

Line 510: l_qry_string1:='select count(*) from '||asg_base.G_OLITE_SCHEMA

506: l_rec_count1 NUMBER;
507: l_rec_count2 NUMBER;
508: l_qry_string1 VARCHAR2(512);
509: BEGIN
510: l_qry_string1:='select count(*) from '||asg_base.G_OLITE_SCHEMA
511: ||'.c$pub_list_q';
512: EXECUTE IMMEDIATE l_qry_string1 into l_rec_count1;
513: l_qry_string1:='select count(*) from '||asg_base.G_OLITE_SCHEMA
514: ||'.c$pub_list_q where comp_ref=''Y''';

Line 513: l_qry_string1:='select count(*) from '||asg_base.G_OLITE_SCHEMA

509: BEGIN
510: l_qry_string1:='select count(*) from '||asg_base.G_OLITE_SCHEMA
511: ||'.c$pub_list_q';
512: EXECUTE IMMEDIATE l_qry_string1 into l_rec_count1;
513: l_qry_string1:='select count(*) from '||asg_base.G_OLITE_SCHEMA
514: ||'.c$pub_list_q where comp_ref=''Y''';
515: EXECUTE IMMEDIATE l_qry_string1 into l_rec_count2;
516: IF(l_rec_count1 = l_rec_count2) THEN
517: p_is_first_synch:='Y';

Line 526: PROCEDURE update_rec_count(p_pubitem_tbl IN asg_base.pub_item_tbl_type,

522:
523:
524: --PROCEDURE FOR PERFORMING BATCH UPDATES ON MOBILEADMIN.C$PUB_LIST_Q
525:
526: PROCEDURE update_rec_count(p_pubitem_tbl IN asg_base.pub_item_tbl_type,
527: p_clientid IN VARCHAR2)
528: IS
529: l_loopvar NUMBER;
530: l_qry_string VARCHAR2(1024);

Line 542: l_qry_string:='update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '||

538: LOOP
539: IF(p_pubitem_tbl(l_loopvar).rec_count is not null OR
540: p_pubitem_tbl(l_loopvar).name not like 'C$%')
541: THEN
542: l_qry_string:='update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '||
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;

Line 558: PROCEDURE process_first_synch(p_pubitem_tbl IN asg_base.pub_item_tbl_type,

554:
555:
556: --PROCEDURE FOR POPULATING rec_count MOBILEADMIN.C$PUB_LIST_Q FOR FIRST TIME SYNCH
557:
558: PROCEDURE process_first_synch(p_pubitem_tbl IN asg_base.pub_item_tbl_type,
559: p_clientid IN VARCHAR2)
560: IS
561: l_curr_pubitem VARCHAR2(128);
562: l_loopvar NUMBER;

Line 569: l_pubitem_tbl asg_base.pub_item_tbl_type;

565: l_total NUMBER;
566: l_rec_count1 NUMBER;
567: l_qry_string1 VARCHAR2(1024);
568: l_qry_string2 VARCHAR2(1024);
569: l_pubitem_tbl asg_base.pub_item_tbl_type;
570:
571: BEGIN
572: l_total:=0;
573: l_pubitem_tbl := p_pubitem_tbl;

Line 579: asg_base.init(p_clientid,-1,0,null,p_pubitem_tbl);

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
582: LOOP
583: l_curr_pubitem:=l_pubitem_tbl(l_loopvar).name;

Line 628: l_user_name := asg_base.get_user_name;

624: IS
625: l_user_name VARCHAR2(30);
626: l_qry_string VARCHAR2(1024);
627: BEGIN
628: l_user_name := asg_base.get_user_name;
629: l_qry_string := 'update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '
630: ||'set comp_ref = ''Y'' '||' where name IN ('
631: ||'SELECT publication_item FROM asg_complete_refresh '
632: ||' WHERE synch_completed=''N'' AND user_name = :1 '

Line 629: l_qry_string := 'update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '

625: l_user_name VARCHAR2(30);
626: l_qry_string VARCHAR2(1024);
627: BEGIN
628: l_user_name := asg_base.get_user_name;
629: l_qry_string := 'update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '
630: ||'set comp_ref = ''Y'' '||' where name IN ('
631: ||'SELECT publication_item FROM asg_complete_refresh '
632: ||' WHERE synch_completed=''N'' AND user_name = :1 '
633: ||' AND publication_item IN '

Line 634: ||' ( SELECT name FROM '||asg_base.G_OLITE_SCHEMA

630: ||'set comp_ref = ''Y'' '||' where name IN ('
631: ||'SELECT publication_item FROM asg_complete_refresh '
632: ||' WHERE synch_completed=''N'' AND user_name = :1 '
633: ||' AND publication_item IN '
634: ||' ( SELECT name FROM '||asg_base.G_OLITE_SCHEMA
635: ||'.c$pub_list_q ))' ;
636: EXECUTE IMMEDIATE l_qry_string
637: USING l_user_name;
638: END set_complete_refresh;

Line 664: ' (SELECT name FROM '||asg_base.G_OLITE_SCHEMA||

660: ' synch_completed=''Y'',last_update_date=sysdate ' ||
661: ' WHERE user_name= :1 ' ||
662: ' AND ' ||
663: ' publication_item IN ' ||
664: ' (SELECT name FROM '||asg_base.G_OLITE_SCHEMA||
665: '.c$pub_list_q)';
666: EXECUTE IMMEDIATE l_qry_string
667: USING p_user_name;
668:

Line 691: '(SELECT name FROM '||asg_base.G_OLITE_SCHEMA||

687: l_qry_string:= ' DELETE FROM asg_complete_refresh '||
688: ' WHERE user_name = :1 ' ||
689: ' AND synch_completed = ''Y'' AND '||
690: ' publication_item IN ' ||
691: '(SELECT name FROM '||asg_base.G_OLITE_SCHEMA||
692: '.c$pub_list_q)';
693: EXECUTE IMMEDIATE l_qry_string
694: USING p_user_name;
695: END delete_row;

Line 722: ||'(SELECT name FROM '||asg_base.G_OLITE_SCHEMA

718: --so set all PI's of the current user to complete_synch
719: l_str:= 'UPDATE asg_complete_refresh SET synch_completed=''N'' , '
720: ||' last_update_date = sysdate WHERE user_name = :1 '
721: ||' AND publication_item in '
722: ||'(SELECT name FROM '||asg_base.G_OLITE_SCHEMA
723: ||'.c$pub_list_q)';
724: EXECUTE IMMEDIATE l_str
725: USING p_user_name;
726: END IF;

Line 740: l_user_id := asg_base.get_user_id(p_user_name);

736: l_user_id NUMBER;
737: BEGIN
738: -- If custom publication item download is disabled
739: -- then remove all custom entries from c$pub_list_q
740: l_user_id := asg_base.get_user_id(p_user_name);
741: l_customProfValue := fnd_profile.VALUE_SPECIFIC(
742: name => 'ASG_DISABLE_CUSTOM_SYNCH',
743: user_id => l_user_id,
744: responsibility_id => null,

Line 753: l_dml := 'DELETE FROM '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q ' ||

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' ||
756: ' where a.pub_name=b.name and b.custom=''Y'')';
757: EXECUTE IMMEDIATE l_dml;

Line 769: l_pubitem_tbl asg_base.pub_item_tbl_type;

765: IS
766: l_upload_tranid NUMBER;
767: l_detect_conflict VARCHAR2(1);
768: l_pubitem VARCHAR2(30);
769: l_pubitem_tbl asg_base.pub_item_tbl_type;
770: l_counter NUMBER;
771: BEGIN
772:
773: l_upload_tranid := asg_base.get_upload_tranid();

Line 773: l_upload_tranid := asg_base.get_upload_tranid();

769: l_pubitem_tbl asg_base.pub_item_tbl_type;
770: l_counter NUMBER;
771: BEGIN
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.',

Line 824: p_pubitem_tbl IN OUT NOCOPY asg_base.pub_item_tbl_type)

820: PROCEDURE is_conflict_detection_needed(
821: p_user_name IN VARCHAR2,
822: p_upload_tranid IN NUMBER,
823: p_detect_conflict IN OUT NOCOPY VARCHAR2,
824: p_pubitem_tbl IN OUT NOCOPY asg_base.pub_item_tbl_type)
825: IS
826: l_conf_pis_exist VARCHAR2(1);
827: l_query_string VARCHAR2(512);
828: l_query_string2 VARCHAR2(512);

Line 843: IF (l_conf_pis_exist = asg_base.G_NO) THEN

839:
840: p_detect_conflict := FND_API.G_FALSE;
841: l_conf_pis_exist := conflict_pub_items_exist(p_user_name,
842: p_upload_tranid);
843: IF (l_conf_pis_exist = asg_base.G_NO) THEN
844: return;
845: END IF;
846:
847: -- Ok, some pub items are uploaded which need conflict detection

Line 850: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci, ' ||

846:
847: -- Ok, some pub items are uploaded which need conflict detection
848: -- Call the publication level wrapper.
849: /* l_query_string := 'SELECT distinct api.pub_name ' ||
850: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci, ' ||
851: ' asg_pub_item api ' ||
852: 'WHERE ci.clid$$cs = ''' || p_user_name || ''' AND ' ||
853: ' ci.tranid$$ = ' || p_upload_tranid || ' AND ' ||
854: ' ci.store = api.name';*/

Line 856: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci, ' ||

852: 'WHERE ci.clid$$cs = ''' || p_user_name || ''' AND ' ||
853: ' ci.tranid$$ = ' || p_upload_tranid || ' AND ' ||
854: ' ci.store = api.name';*/
855: l_query_string := 'SELECT distinct api.pub_name ' ||
856: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci, ' ||
857: ' asg_pub_item api ' ||
858: 'WHERE ci.clid$$cs = :1 AND ' ||
859: ' ci.tranid$$ = :2 AND ' ||
860: ' ci.store = api.name';

Line 912: IF (l_pub_detect_conflict = asg_base.G_YES) 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.
915: IF (l_conf_pubs IS NULL) THEN
916: l_conf_pubs := '''' || l_pub_name || '''';

Line 951: l_conf_pis_exist VARCHAR2(1) := asg_base.G_NO;

947: RETURN VARCHAR2
948: IS
949: l_query_string VARCHAR2(512);
950: l_conf_pi_count NUMBER;
951: l_conf_pis_exist VARCHAR2(1) := asg_base.G_NO;
952: BEGIN
953: -- As an optimization, first check the inq to see if there are
954: -- any pub items uploaded that have detect_conflict set to yes.
955: -- and will not be complete refreshed

Line 957: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci, ' ||

953: -- As an optimization, first check the inq to see if there are
954: -- any pub items uploaded that have detect_conflict set to yes.
955: -- and will not be complete refreshed
956: l_query_string := 'SELECT count(*) ' ||
957: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci, ' ||
958: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||
959: ' asg_pub_item api ' ||
960: 'WHERE ci.clid$$cs = :1 AND ' ||
961: ' ci.tranid$$ = :2 AND ' ||

Line 958: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||

954: -- any pub items uploaded that have detect_conflict set to yes.
955: -- and will not be complete refreshed
956: l_query_string := 'SELECT count(*) ' ||
957: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci, ' ||
958: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||
959: ' asg_pub_item api ' ||
960: 'WHERE ci.clid$$cs = :1 AND ' ||
961: ' ci.tranid$$ = :2 AND ' ||
962: ' ci.store = api.name AND ' ||

Line 977: l_conf_pis_exist := asg_base.G_YES;

973: EXECUTE IMMEDIATE l_query_string
974: INTO l_conf_pi_count
975: USING p_user_name, p_upload_tran_id;
976: IF (l_conf_pi_count > 0) THEN
977: l_conf_pis_exist := asg_base.G_YES;
978: END IF;
979: return l_conf_pis_exist;
980:
981: END conflict_pub_items_exist;

Line 987: p_pubitem_tbl IN OUT NOCOPY asg_base.pub_item_tbl_type)

983: PROCEDURE get_conf_pub_items_list(
984: p_user_name IN VARCHAR2,
985: p_upload_tranid IN NUMBER,
986: l_conf_pubs IN VARCHAR2,
987: p_pubitem_tbl IN OUT NOCOPY asg_base.pub_item_tbl_type)
988: IS
989: l_query_string VARCHAR2(4000);
990: l_pubitem VARCHAR2(30);
991: l_cursor_id NUMBER;

Line 996: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci , ' ||

992: l_cursor_ret NUMBER;
993: l_counter NUMBER;
994: BEGIN
995: /* l_query_string := 'SELECT ci.store ' ||
996: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci , ' ||
997: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||
998: ' asg_pub_item api ' ||
999: 'WHERE ci.clid$$cs = ''' || p_user_name || ''' AND ' ||
1000: ' ci.tranid$$ = ' || p_upload_tranid || ' AND ' ||

Line 997: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||

993: l_counter NUMBER;
994: BEGIN
995: /* l_query_string := 'SELECT ci.store ' ||
996: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci , ' ||
997: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||
998: ' asg_pub_item api ' ||
999: 'WHERE ci.clid$$cs = ''' || p_user_name || ''' AND ' ||
1000: ' ci.tranid$$ = ' || p_upload_tranid || ' AND ' ||
1001: ' ci.store = api.name AND ' ||

Line 1007: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci , ' ||

1003: ' cpq.comp_ref <> ''Y'' AND ' ||
1004: ' api.detect_conflict = ''Y'' AND ' ||
1005: ' api.pub_name in (' || l_conf_pubs || ')';*/
1006: l_query_string := 'SELECT ci.store ' ||
1007: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci , ' ||
1008: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||
1009: ' asg_pub_item api ' ||
1010: 'WHERE ci.clid$$cs = :1 AND ' ||
1011: ' ci.tranid$$ = :2 AND ' ||

Line 1008: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||

1004: ' api.detect_conflict = ''Y'' AND ' ||
1005: ' api.pub_name in (' || l_conf_pubs || ')';*/
1006: l_query_string := 'SELECT ci.store ' ||
1007: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci , ' ||
1008: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||
1009: ' asg_pub_item api ' ||
1010: 'WHERE ci.clid$$cs = :1 AND ' ||
1011: ' ci.tranid$$ = :2 AND ' ||
1012: ' ci.store = api.name AND ' ||

Line 1061: ' ( select name from '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q )';

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();
1063: DBMS_SQL.parse(l_cursor_id,l_qry_string,DBMS_SQL.v7);
1064: DBMS_SQL.define_column(l_cursor_id,1,l_pub_name,30);
1065: l_ret_val := DBMS_SQL.execute(l_cursor_id);

Line 1083: l_qry_string1 := 'update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '||

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 )';
1087: EXECUTE IMMEDIATE l_qry_string1

Line 1097: l_qry_string1 := 'update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '||

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 )';
1101: EXECUTE IMMEDIATE l_qry_string1

Line 1204: l_inqtable_name := asg_base.G_OLITE_SCHEMA ||

1200:
1201: -- One more optimization before checking for conflicts
1202: -- Check if there any UPD DML from client
1203: -- and then check if there is any UPD DML from server
1204: l_inqtable_name := asg_base.G_OLITE_SCHEMA ||
1205: '.' || 'cfm$' || p_pubitem || ' ';
1206: l_query_string := 'SELECT count(*) ' ||
1207: 'FROM ' || l_inqtable_name ||
1208: 'WHERE clid$$cs = :1 AND ' ||

Line 1233: l_client_wins := asg_base.G_CLIENT_WINS;

1229: INTO l_piv, l_primary_key_columns, l_conflict_callout
1230: FROM asg_pub_item
1231: WHERE name = p_pubitem;
1232:
1233: l_client_wins := asg_base.G_CLIENT_WINS;
1234: l_server_wins := asg_base.G_SERVER_WINS;
1235: l_download_tranid := asg_base.get_current_tranid();
1236: -- Get the access_id of updated DMLs
1237: insert into asg_conf_info (user_name,

Line 1234: l_server_wins := asg_base.G_SERVER_WINS;

1230: FROM asg_pub_item
1231: WHERE name = p_pubitem;
1232:
1233: l_client_wins := asg_base.G_CLIENT_WINS;
1234: l_server_wins := asg_base.G_SERVER_WINS;
1235: l_download_tranid := asg_base.get_current_tranid();
1236: -- Get the access_id of updated DMLs
1237: insert into asg_conf_info (user_name,
1238: pub_item,

Line 1235: l_download_tranid := asg_base.get_current_tranid();

1231: WHERE name = p_pubitem;
1232:
1233: l_client_wins := asg_base.G_CLIENT_WINS;
1234: l_server_wins := asg_base.G_SERVER_WINS;
1235: l_download_tranid := asg_base.get_current_tranid();
1236: -- Get the access_id of updated DMLs
1237: insert into asg_conf_info (user_name,
1238: pub_item,
1239: transaction_id,

Line 1467: asg_base.detect_device_switch(p_user_name, l_device_type);

1463: RETURN VARCHAR2 IS
1464: l_device_type VARCHAR2(30) := null;
1465: BEGIN
1466: -- Find the device type and detect device switch as well
1467: asg_base.detect_device_switch(p_user_name, l_device_type);
1468: RETURN l_device_type;
1469: EXCEPTION
1470: WHEN OTHERS THEN
1471: return l_device_type;