APPS.ASG_APPLY dependencies on ASG_USERS_INQARCHIVE

Line 273: -- Update asg_users_inqarchive also

269: tranid >= p_start_tranid AND
270: tranid <= p_end_tranid AND
271: tranid <> p_compact_tranid;
272:
273: -- Update asg_users_inqarchive also
274:
275: -- Get the list of pub-items for this tranid
276: -- This is the list of all publication items uploaded for that tranid
277: l_pubitems_1 := null;

Line 332: UPDATE asg_users_inqarchive

328: END LOOP;
329:
330: log('compact_asginq: Pub-Items to be processed during this auto sync: ' ||
331: l_pubitems_1 || l_pubitems_2);
332: UPDATE asg_users_inqarchive
333: SET pub_items1 = l_pubitems_1, pub_items2 = l_pubitems_2
334: WHERE device_user_name = p_user_name AND
335: tranid = p_compact_tranid;
336:

Line 338: DELETE FROM asg_users_inqarchive

334: WHERE device_user_name = p_user_name AND
335: tranid = p_compact_tranid;
336:
337: -- Remove all records except compact tranID
338: DELETE FROM asg_users_inqarchive
339: WHERE device_user_name = p_user_name AND
340: tranid >= p_start_tranid AND
341: tranid <= p_end_tranid AND
342: tranid <> p_compact_tranid;

Line 439: l_sql:='UPDATE ASG_USERS_INQARCHIVE '||

435: log('compact_curr_inqtable: No of Records Deleted IN C$INQ : ' || l_sql_count);
436:
437: IF l_sql_count>0 THEN
438: BEGIN
439: l_sql:='UPDATE ASG_USERS_INQARCHIVE '||
440: 'SET PUB_ITEMS1=replace(PUB_ITEMS1,'''||p_curr_pubitem||''',''*'||p_curr_pubitem||'''),
441: PUB_ITEMS2=replace(PUB_ITEMS2,'''||p_curr_pubitem||''',''*'||p_curr_pubitem||''') '||
442: 'WHERE DEVICE_USER_NAME=:2 AND TRANID=:3';
443: log('compact_curr_inqtable: SQL Command: ' || l_sql);

Line 1094: -- Process asg_users_inqinfo/asg_users_inqarchive

1090: -- Process c$inq first
1091: log('process_auto_sync: Processing c$inq');
1092: compact_cinq(p_user_name, p_tranid, l_end_tranid, l_compact_tranid);
1093:
1094: -- Process asg_users_inqinfo/asg_users_inqarchive
1095: log('process_auto_sync: Processing asg inq info tables');
1096: compact_asginq(p_user_name, p_tranid, l_end_tranid, l_compact_tranid);
1097:
1098: -- Process inq tables

Line 1516: UPDATE asg_users_inqarchive

1512: curr_tran_processed := caau.processed;
1513: curr_tran_deferred := caau.deferred;
1514: curr_tran_archive := caau.archive;
1515: IF (curr_tran_processed = 'Y') AND (curr_tran_archive = 'Y') THEN
1516: UPDATE asg_users_inqarchive
1517: SET processed = 'Y', deferred = curr_tran_deferred,
1518: last_update_date = SYSDATE, last_updated_by = 1
1519: WHERE device_user_name = p_user_name AND
1520: tranid = curr_tranid;

Line 1984: ' AND NOT EXISTS (SELECT 1 FROM asg_users_inqarchive ' ||

1980: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci '||
1981: 'WHERE clid$$cs = :1 AND ' ||
1982: ' tranid$$ = :2 AND ' ||
1983: ' store in (select item_id from asg_pub_item) '||
1984: ' AND NOT EXISTS (SELECT 1 FROM asg_users_inqarchive ' ||
1985: ' WHERE device_user_name = ci.clid$$cs AND TRANID =ci.tranid$$) '||
1986: ' ORDER BY store';
1987:
1988: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;

Line 2029: -- Replace with call to table-handler for asg_users_inqarchive

2025: counter2 := counter2 +1;
2026: END IF;
2027: END LOOP;
2028:
2029: -- Replace with call to table-handler for asg_users_inqarchive
2030: INSERT INTO asg_users_inqarchive (device_user_name,
2031: resource_id,
2032: tranid,
2033: sync_date,

Line 2030: INSERT INTO asg_users_inqarchive (device_user_name,

2026: END IF;
2027: END LOOP;
2028:
2029: -- Replace with call to table-handler for asg_users_inqarchive
2030: INSERT INTO asg_users_inqarchive (device_user_name,
2031: resource_id,
2032: tranid,
2033: sync_date,
2034: processed,