[Home] [Help]
687: RAISE PARAMETER_COUNT_MISMATCH;
688: END IF;
689: l_ctr := 1;
690:
691: --compares each element in the list with asg_purge_sdq ,asg_complete_Refresh
692: -- and SDQ and constructs a new list.. which is used for further processing.
693: FOR i IN p_accessList.FIRST..p_accessList.LAST
694: LOOP
695: IF (insert_sdq(p_pub_item,p_username_list(i))
1879: END delete_duplicate_records;
1880:
1881: /*
1882: takes a user name and inserts records for each publication subscribed
1883: by the user into asg_purge_sdq
1884: */
1885: PROCEDURE set_user_first_synch(l_user_name varchar2)
1886: is
1887: PRAGMA autonomous_transaction;
1889: log_concprogram('Setting user '||l_user_name ||' to first synch '||
1890: l_user_name,'asg_download',
1891: FND_LOG.LEVEL_STATEMENT);
1892:
1893: INSERT INTO asg_purge_sdq(user_name,pub_name,creation_date,created_by,
1894: last_update_date,last_updated_by )
1895: ( SELECT user_name,pub_name ,sysdate,1,sysdate,1
1896: FROM asg_user_pub_resps
1897: WHERE user_name = l_user_name
1912: END set_user_first_synch;
1913:
1914: /*
1915: takes a user name and inserts records for each publication subscribed
1916: by the user into asg_purge_sdq
1917: */
1918: PROCEDURE set_user_first_synch_pub(l_user_name varchar2,l_pub_name varchar2)
1919: is
1920: PRAGMA autonomous_transaction;
1923: /*log_concprogram('Setting user '||l_user_name ||' to first synch '||
1924: l_user_name,'asg_download',
1925: FND_LOG.LEVEL_STATEMENT);*/
1926: SELECT COUNT(*) INTO l_count
1927: FROM asg_purge_sdq
1928: WHERE user_name = l_user_name
1929: AND pub_name = l_pub_name;
1930:
1931: IF l_count =0 THEN
1928: WHERE user_name = l_user_name
1929: AND pub_name = l_pub_name;
1930:
1931: IF l_count =0 THEN
1932: INSERT INTO asg_purge_sdq(user_name,pub_name,creation_date,created_by,
1933: last_update_date,last_updated_by)
1934: VALUES (l_user_name,l_pub_name,sysdate,1,sysdate,1);
1935: commit;
1936: END IF;
1992: SELECT user_name FROM asg_user
1993: WHERE user_name > l_last_processed
1994: and user_name not in
1995: ( select distinct user_name
1996: from asg_purge_sdq where TRANSACTION_ID IS NULL )
1997: ORDER BY user_name
1998: ) WHERE ROWNUM <= l_max_num;
1999:
2000: CURSOR c_get_last_user(l_dormancy_period NUMBER,
2232: AND publication_item IN
2233: (SELECT item_id FROM asg_pub_item
2234: WHERE pub_name = l_dormant_rec.pub_name);
2235:
2236: DELETE FROM asg_purge_sdq
2237: WHERE user_name = l_dormant_rec.user_name
2238: AND pub_name = l_dormant_rec.pub_name;
2239: commit;
2240: /* change this .. has to insert for current publicatino..*/
2240: /* change this .. has to insert for current publicatino..*/
2241: set_user_first_synch_pub(l_dormant_rec.user_name,
2242: l_dormant_rec.pub_name);
2243: END;
2244: -- delete SDQ and DQ , asg_complete_refresh , asg_purge_sdq and commit.
2245: -- set to complete ref in asg_purge_sdq..
2246: END LOOP;
2247: CLOSE c_dormant_users;
2248:
2241: set_user_first_synch_pub(l_dormant_rec.user_name,
2242: l_dormant_rec.pub_name);
2243: END;
2244: -- delete SDQ and DQ , asg_complete_refresh , asg_purge_sdq and commit.
2245: -- set to complete ref in asg_purge_sdq..
2246: END LOOP;
2247: CLOSE c_dormant_users;
2248:
2249: log_concprogram('Last user to be processed in this run : '||l_last_user,
2278: return values :
2279: If it returns "false" then the record need not be inserted into SDQ ..
2280: it may be that:
2281: 1. records for the pub item or the corresponding publication
2282: exists in asg_complete_refresh or asg_purge_sdq
2283: If the return value is "true" then record is inserted.
2284: --
2285: */
2286:
2295: WHERE user_name = l_un AND publication_item = l_pi
2296: AND synch_completed = 'N';
2297: CURSOR c_exists_purge(l_pub varchar2,l_un varchar2)
2298: IS
2299: SELECT user_name FROM asg_purge_Sdq
2300: WHERE user_name = l_un
2301: AND pub_name = l_pub
2302: AND transaction_id IS null;
2303: l_pub_name varchar2(30);