[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))
1877: END delete_duplicate_records;
1878:
1879: /*
1880: takes a user name and inserts records for each publication subscribed
1881: by the user into asg_purge_sdq
1882: */
1883: PROCEDURE set_user_first_synch(l_user_name varchar2)
1884: is
1885: PRAGMA autonomous_transaction;
1887: log_concprogram('Setting user '||l_user_name ||' to first synch '||
1888: l_user_name,'asg_download',
1889: FND_LOG.LEVEL_STATEMENT);
1890:
1891: INSERT INTO asg_purge_sdq(user_name,pub_name,creation_date,created_by,
1892: last_update_date,last_updated_by )
1893: ( SELECT user_name,pub_name ,sysdate,1,sysdate,1
1894: FROM asg_user_pub_resps
1895: WHERE user_name = l_user_name
1910: END set_user_first_synch;
1911:
1912: /*
1913: takes a user name and inserts records for each publication subscribed
1914: by the user into asg_purge_sdq
1915: */
1916: PROCEDURE set_user_first_synch_pub(l_user_name varchar2,l_pub_name varchar2)
1917: is
1918: PRAGMA autonomous_transaction;
1921: /*log_concprogram('Setting user '||l_user_name ||' to first synch '||
1922: l_user_name,'asg_download',
1923: FND_LOG.LEVEL_STATEMENT);*/
1924: SELECT COUNT(*) INTO l_count
1925: FROM asg_purge_sdq
1926: WHERE user_name = l_user_name
1927: AND pub_name = l_pub_name;
1928:
1929: IF l_count =0 THEN
1926: WHERE user_name = l_user_name
1927: AND pub_name = l_pub_name;
1928:
1929: IF l_count =0 THEN
1930: INSERT INTO asg_purge_sdq(user_name,pub_name,creation_date,created_by,
1931: last_update_date,last_updated_by)
1932: VALUES (l_user_name,l_pub_name,sysdate,1,sysdate,1);
1933: commit;
1934: END IF;
1990: SELECT user_name FROM asg_user
1991: WHERE user_name > l_last_processed
1992: and user_name not in
1993: ( select distinct user_name
1994: from asg_purge_sdq where TRANSACTION_ID IS NULL )
1995: ORDER BY user_name
1996: ) WHERE ROWNUM <= l_max_num;
1997:
1998: CURSOR c_get_last_user(l_dormancy_period NUMBER,
2230: AND publication_item IN
2231: (SELECT item_id FROM asg_pub_item
2232: WHERE pub_name = l_dormant_rec.pub_name);
2233:
2234: DELETE FROM asg_purge_sdq
2235: WHERE user_name = l_dormant_rec.user_name
2236: AND pub_name = l_dormant_rec.pub_name;
2237: commit;
2238: /* change this .. has to insert for current publicatino..*/
2238: /* change this .. has to insert for current publicatino..*/
2239: set_user_first_synch_pub(l_dormant_rec.user_name,
2240: l_dormant_rec.pub_name);
2241: END;
2242: -- delete SDQ and DQ , asg_complete_refresh , asg_purge_sdq and commit.
2243: -- set to complete ref in asg_purge_sdq..
2244: END LOOP;
2245: CLOSE c_dormant_users;
2246:
2239: set_user_first_synch_pub(l_dormant_rec.user_name,
2240: l_dormant_rec.pub_name);
2241: END;
2242: -- delete SDQ and DQ , asg_complete_refresh , asg_purge_sdq and commit.
2243: -- set to complete ref in asg_purge_sdq..
2244: END LOOP;
2245: CLOSE c_dormant_users;
2246:
2247: log_concprogram('Last user to be processed in this run : '||l_last_user,
2276: return values :
2277: If it returns "false" then the record need not be inserted into SDQ ..
2278: it may be that:
2279: 1. records for the pub item or the corresponding publication
2280: exists in asg_complete_refresh or asg_purge_sdq
2281: If the return value is "true" then record is inserted.
2282: --
2283: */
2284:
2293: WHERE user_name = l_un AND publication_item = l_pi
2294: AND synch_completed = 'N';
2295: CURSOR c_exists_purge(l_pub varchar2,l_un varchar2)
2296: IS
2297: SELECT user_name FROM asg_purge_Sdq
2298: WHERE user_name = l_un
2299: AND pub_name = l_pub
2300: AND transaction_id IS null;
2301: l_pub_name varchar2(30);