DBA Data[Home] [Help]

APPS.ASG_APPLY dependencies on ASG_USERS_INQINFO

Line 189: ' FROM asg_users_inqinfo ' ||

185: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ' ||
186: 'WHERE clid$$cs = :1 AND ' ||
187: 'tranid$$ NOT IN ' ||
188: '(SELECT tranid ' ||
189: ' FROM asg_users_inqinfo ' ||
190: ' WHERE device_user_name = :2)';
191: EXECUTE IMMEDIATE l_select_sync_sqlstring
192: INTO p_sync_tables
193: USING p_user_name, p_user_name;

Line 263: DELETE FROM asg_users_inqinfo

259: ' End TranID: ' || p_end_tranid ||
260: ' Compact TranID: ' || p_compact_tranid);
261:
262: -- Remove all records except compact tranID
263: DELETE FROM asg_users_inqinfo
264: WHERE device_user_name = p_user_name AND
265: tranid >= p_start_tranid AND
266: tranid <= p_end_tranid AND
267: tranid <> p_compact_tranid;

Line 533: /* to asg_users_inqinfo table */

529:
530: END compact_inqtables;
531:
532: /* Procedure to retrieve transactions that are not yet added */
533: /* to asg_users_inqinfo table */
534: PROCEDURE get_new_tranids(p_user_name IN VARCHAR2,
535: l_tranids_tbl OUT NOCOPY num_tbl_type)
536: IS
537: counter PLS_INTEGER;

Line 549: ' FROM asg_users_inqinfo ' ||

545: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ' ||
546: 'WHERE clid$$cs = :user_name AND '||
547: 'tranid$$ NOT IN ' ||
548: '(SELECT tranid ' ||
549: ' FROM asg_users_inqinfo ' ||
550: ' WHERE device_user_name = :user_name)';
551: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
552: DBMS_SQL.PARSE (l_cursor_id, l_select_tranid_sqlstring, DBMS_SQL.v7);
553: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );

Line 580: FROM asg_user a, asg_users_inqinfo b

576: IS
577: counter PLS_INTEGER;
578: CURSOR c_clients_yy IS
579: SELECT DISTINCT a.user_name user_name
580: FROM asg_user a, asg_users_inqinfo b
581: WHERE a.user_name = b.device_user_name AND
582: b.processed in ('I', 'N') AND
583: a.enabled = 'Y'
584: ORDER BY a.user_name;

Line 587: FROM asg_user a, asg_users_inqinfo b

583: a.enabled = 'Y'
584: ORDER BY a.user_name;
585: CURSOR c_clients_yn IS
586: SELECT DISTINCT a.user_name user_name
587: FROM asg_user a, asg_users_inqinfo b
588: WHERE a.user_name = b.device_user_name AND
589: b.deferred = 'N' AND b.processed <> 'Y' AND
590: a.enabled = 'Y'
591: ORDER BY a.user_name;

Line 594: FROM asg_user a, asg_users_inqinfo b

590: a.enabled = 'Y'
591: ORDER BY a.user_name;
592: CURSOR c_clients_ny IS
593: SELECT DISTINCT a.user_name user_name
594: FROM asg_user a, asg_users_inqinfo b
595: WHERE a.user_name = b.device_user_name AND
596: b.deferred <> 'N' and b.processed <> 'Y'
597: ORDER BY a.user_name;
598: BEGIN

Line 645: FROM asg_users_inqinfo a

641: IS
642: counter PLS_INTEGER;
643: CURSOR c_all_tran (p_user_name VARCHAR2) IS
644: SELECT tranid
645: FROM asg_users_inqinfo a
646: WHERE a.device_user_name = p_user_name
647: ORDER BY tranid;
648: BEGIN
649: IF ((p_user_name = FND_API.G_MISS_CHAR) OR (p_user_name IS NULL))THEN

Line 912: FROM asg_users_inqinfo a

908: x_return_status OUT NOCOPY VARCHAR2)
909: IS
910: CURSOR c_first_tran (p_user_name VARCHAR2) IS
911: SELECT min(tranid) tran_id
912: FROM asg_users_inqinfo a
913: WHERE a.device_user_name = p_user_name AND
914: a.deferred='N'
915: AND a.tranid <=
916: (SELECT nvl(hwm_tranid,1000000000000)

Line 954: FROM asg_users_inqinfo a

950: x_return_status OUT NOCOPY VARCHAR2)
951: IS
952: CURSOR c_next_tran (p_user_name VARCHAR2, p_tranid VARCHAR2) IS
953: SELECT min(tranid) tran_id
954: FROM asg_users_inqinfo a
955: WHERE tranid > p_tranid AND
956: a.device_user_name = p_user_name AND
957: a.deferred='N'
958: AND a.tranid <=

Line 1088: -- Process asg_users_inqinfo/asg_users_inqarchive

1084: -- Process c$inq first
1085: log('process_auto_sync: Processing c$inq');
1086: compact_cinq(p_user_name, p_tranid, l_end_tranid, l_compact_tranid);
1087:
1088: -- Process asg_users_inqinfo/asg_users_inqarchive
1089: log('process_auto_sync: Processing asg inq info tables');
1090: compact_asginq(p_user_name, p_tranid, l_end_tranid, l_compact_tranid);
1091:
1092: -- Process inq tables

Line 1333: UPDATE asg_users_inqinfo

1329:
1330: END LOOP;
1331:
1332: IF (l_deferred_trans = TRUE) THEN
1333: UPDATE asg_users_inqinfo
1334: SET deferred = 'Y', processed = 'I',
1335: last_update_date = SYSDATE, last_updated_by = 1
1336: WHERE device_user_name = p_user_name AND
1337: tranid = p_tranid;

Line 1393: UPDATE asg_users_inqinfo

1389: purge_pubitems(p_user_name, p_tranid, l_pubitems_tbl, x_return_status);
1390: END IF;
1391:
1392: -- If no deferred rows, set processed = 'Y'
1393: UPDATE asg_users_inqinfo
1394: SET processed = 'Y', last_update_date=SYSDATE, last_updated_by=1
1395: WHERE device_user_name = p_user_name AND
1396: tranid = p_tranid AND
1397: tranid not IN

Line 1416: FROM asg_users_inqinfo

1412: curr_tranid NUMBER;
1413: l_tranid_tbl num_tbl_type;
1414: cursor c_tranids (p_user_name VARCHAR2, p_max_tranid NUMBER) IS
1415: SELECT tranid
1416: FROM asg_users_inqinfo
1417: WHERE device_user_name = p_user_name AND
1418: tranid <= p_max_tranid;
1419: BEGIN
1420: IF ((p_user_name = FND_API.G_MISS_CHAR) OR (p_user_name IS NULL)) THEN

Line 1457: -- Check if the c$inq and asg_users_inqinfo are in sync.

1453: BEGIN
1454: x_return_status := FND_API.G_RET_STS_SUCCESS;
1455: x_begin_client_apply := FND_API.G_TRUE;
1456:
1457: -- Check if the c$inq and asg_users_inqinfo are in sync.
1458: get_sync_state(p_user_name, l_sync_tables);
1459: log('begin_client_apply: l_sync_tables: ' || l_sync_tables,g_stmt_level);
1460:
1461: IF l_sync_tables = 1 THEN

Line 1462: -- Get all the tranids in c$inq that are not in asg_users_inqinfo

1458: get_sync_state(p_user_name, l_sync_tables);
1459: log('begin_client_apply: l_sync_tables: ' || l_sync_tables,g_stmt_level);
1460:
1461: IF l_sync_tables = 1 THEN
1462: -- Get all the tranids in c$inq that are not in asg_users_inqinfo
1463: get_new_tranids(p_user_name, l_tranids_tbl);
1464:
1465: FOR curr_index in 1..l_tranids_tbl.count LOOP
1466: curr_tranid := l_tranids_tbl(curr_index);

Line 1486: FROM asg_users_inqinfo

1482: curr_tran_deferred VARCHAR2(1);
1483: curr_tran_archive VARCHAR2(1);
1484: CURSOR c_archive_asg_users(p_user_name VARCHAR2) IS
1485: SELECT tranid, processed, deferred, archive
1486: FROM asg_users_inqinfo
1487: WHERE device_user_name = p_user_name;
1488: BEGIN
1489:
1490: IF ((p_user_name = FND_API.G_MISS_CHAR) OR (p_user_name IS NULL)) THEN

Line 1511: DELETE FROM asg_users_inqinfo

1507: tranid = curr_tranid;
1508: END IF;
1509: END LOOP;
1510:
1511: DELETE FROM asg_users_inqinfo
1512: WHERE device_user_name = p_user_name AND processed = 'Y';
1513: COMMIT;
1514:
1515: END end_client_apply;

Line 1762: INSERT INTO asg_users_inqinfo (device_user_name,

1758: x_return_status := FND_API.G_RET_STS_ERROR;
1759: return;
1760: END IF;
1761:
1762: INSERT INTO asg_users_inqinfo (device_user_name,
1763: resource_id,
1764: tranid,
1765: sync_date,
1766: processed,

Line 1925: UPDATE asg_users_inqinfo

1921: log('process_user: Unknown exception. No inq records found for user: '
1922: || p_user_name || ' for tranid: ' || p_tranid, FND_LOG.LEVEL_ERROR);
1923: log('process_user: Possible cause: Olite was reinstalled while ' ||
1924: 'there were unprocessed inq transactions',g_stmt_level);
1925: UPDATE asg_users_inqinfo
1926: SET processed = 'U', deferred = 'Y'
1927: WHERE device_user_name = p_user_name AND
1928: tranid = p_tranid;
1929: return ;