APPS.HR_DELTA_SYNC_MESSAGES dependencies on HR_COUNTRY_DELTA_SYNC

Line 79: PROCEDURE hr_country_delta_sync(errbuf OUT NOCOPY VARCHAR2

75: /*Procedure to insert the record into hr_psft_sync_run table ends*/
76:
77: /*Procedure to extract the delta synch data for country begins here*/
78:
79: PROCEDURE hr_country_delta_sync(errbuf OUT NOCOPY VARCHAR2
80: ,retcode OUT NOCOPY VARCHAR2
81: ,p_party_site_id in NUMBER)
82: is
83: p_cntry_code fnd_territories_vl.territory_code%type;

Line 102: from hr_country_delta_sync cntry

98: ft.territory_code,ft.obsolete_flag,ft.row_id,ft.last_update_date
99: from fnd_territories_vl ft
100: where ft.last_update_date > p_max_run_date
101: and (ft.territory_code,ft.row_id) not in (select cntry.country_code,cntry.row_id
102: from hr_country_delta_sync cntry
103: where ft.territory_code = cntry.country_code
104: and ft.row_id = cntry.row_id
105: and ft.last_update_date <= cntry.last_update_date
106: and cntry.status in ('QUEUED','SENT'));

Line 116: hr_country_delta_sync

112:
113: cursor fet_delta_status
114: is
115: select country_code,row_id,event_key from
116: hr_country_delta_sync
117: where status = 'QUEUED';
118:
119: p_country_code varchar2(5);
120: p_row1_id rowid;

Line 188: update hr_country_delta_sync

184: fetch fet_delta_status into p_country_code,p_row1_id,p_event_key_gen;
185:
186: if fet_delta_status%found then
187:
188: update hr_country_delta_sync
189: set status = 'SENT'
190: where event_key = p_event_key_gen;
191: commit;
192:

Line 198: insert into hr_country_delta_sync(COUNTRY_CODE,COUNTRY_DESCRIPTION,ROW_ID,

194: fetch fet_cntry_sync into p_cntry_code,p_cntry_desc,p_cntry_code,p_obs_flag,p_row_id,p_last_update_date;
195: if fet_cntry_sync%found then
196:
197: select hrhd_delta_sync_seq.nextval into p_unique_key from dual;
198: insert into hr_country_delta_sync(COUNTRY_CODE,COUNTRY_DESCRIPTION,ROW_ID,
199: COUNTRY_2CHAR,OBSOLETE_FLAG,LAST_UPDATE_DATE,STATUS,EFFECTIVE_STATUS_DATE,EVENT_KEY)
200: values(p_cntry_code,p_cntry_desc,p_row_id,p_cntry_code,p_obs_flag,p_last_update_date,'QUEUED',p_effective_date,
201: p_cntry_code||'-'||to_char(p_unique_key));
202: commit;

Line 238: insert into hr_country_delta_sync(COUNTRY_CODE,COUNTRY_DESCRIPTION,ROW_ID,

234: loop
235: fetch fet_cntry_fsync into p_cntry_code,p_cntry_desc,p_cntry_code,p_obs_flag,p_row_id,p_last_update_date;
236: if fet_cntry_fsync%found then
237: select hrhd_delta_sync_seq.nextval into p_unique_key from dual;
238: insert into hr_country_delta_sync(COUNTRY_CODE,COUNTRY_DESCRIPTION,ROW_ID,
239: COUNTRY_2CHAR,OBSOLETE_FLAG,LAST_UPDATE_DATE,STATUS,EFFECTIVE_STATUS_DATE,EVENT_KEY)
240: values(p_cntry_code,p_cntry_desc,p_row_id,p_cntry_code,p_obs_flag,p_last_update_date,'QUEUED',p_effective_date,
241: p_cntry_code||'-'||to_char(p_unique_key));
242: commit;

Line 282: end hr_country_delta_sync;

278: FND_FILE.put_line(fnd_file.log, 'Error in Country Delta Synch Extraction: '||SQLCODE);
279: FND_FILE.NEW_LINE(FND_FILE.log, 1);
280: FND_FILE.put_line(fnd_file.log, 'Error Msg: '||substr(SQLERRM,1,700));
281:
282: end hr_country_delta_sync;
283:
284: /*Procedure to extract the delta synch data for country ends here*/
285:
286: /*Procedure to extract the delta synch data for state begins here*/

Line 2878: hr_delta_sync_messages.hr_country_delta_sync(ERRBUF,RETCODE,p_party_site_id);

2874: hr_delta_sync_messages.hr_state_delta_sync(ERRBUF,RETCODE,p_party_site_id);
2875: elsif p_process_name = 'COUNTRY_DELTA_SYNCH'
2876: then
2877:
2878: hr_delta_sync_messages.hr_country_delta_sync(ERRBUF,RETCODE,p_party_site_id);
2879: elsif p_process_name = 'LOCATION_DELTA_SYNCH'
2880: then
2881: hr_delta_sync_messages.hr_location_delta_sync(ERRBUF,RETCODE,p_party_site_id);
2882: elsif p_process_name = 'PERSON_DELTA_SYNCH'

Line 2916: update hr_country_delta_sync

2912:
2913: elsif p_process_name = 'COUNTRY_DELTA_SYNCH'
2914: then
2915:
2916: update hr_country_delta_sync
2917: set status = 'SENT'
2918: where event_key = p_event_key;
2919:
2920: elsif p_process_name = 'LOCATION_DELTA_SYNCH'