DBA Data[Home] [Help]

APPS.HR_DELTA_SYNC_MESSAGES dependencies on HR_STATE_DELTA_SYNC

Line 288: PROCEDURE hr_state_delta_sync (errbuf OUT NOCOPY VARCHAR2

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*/
287:
288: PROCEDURE hr_state_delta_sync (errbuf OUT NOCOPY VARCHAR2
289: ,retcode OUT NOCOPY VARCHAR2
290: ,p_party_site_id in NUMBER)
291: is
292:

Line 328: from hr_state_delta_sync state

324: from fnd_common_lookups fcl,fnd_territories_vl ft
325: where fcl.lookup_type = (ft.territory_code ||'_STATE')
326: and fcl.last_update_date > p_max_run_date
327: and (ft.territory_code ,fcl.lookup_code) not in (select state.country_code,state.state_code
328: from hr_state_delta_sync state
329: where ft.territory_code = state.country_code
330: and fcl.lookup_code = state.state_code
331: and ft.last_update_date <= state.last_update_date
332: and state.status in ('QUEUED','SENT'));

Line 337: hr_state_delta_sync

333:
334: cursor fet_delta_status
335: is
336: select country_code,state_code,event_key from
337: hr_state_delta_sync
338: where status = 'QUEUED';
339:
340: p_country_code varchar2(5);
341: p_stt_code varchar2(30);

Line 394: update hr_state_delta_sync

390: fetch fet_delta_status into p_country_code,p_stt_code,p_event_key_gen;
391:
392: if fet_delta_status%found then
393:
394: update hr_state_delta_sync
395: set status = 'SENT'
396: where event_key = p_event_key_gen;
397: commit;
398:

Line 404: insert into hr_state_delta_sync(COUNTRY_CODE,STATE_CODE,

400: fetch fet_state_qsync into p_cntry_code,p_state_code,p_state_desc,p_enable_flag,p_last_update_date;
401: if fet_state_qsync%found then
402:
403: select hrhd_delta_sync_seq.nextval into p_unique_key from dual;
404: insert into hr_state_delta_sync(COUNTRY_CODE,STATE_CODE,
405: STATE_DESCRIPTION,ENABLE_FLAG,STATUS,EFFECTIVE_STATUS_DATE,
406: LAST_UPDATE_DATE,EVENT_KEY )
407: values(p_cntry_code,p_state_code,p_state_desc,p_enable_flag,'QUEUED',p_effective_date,p_last_update_date,p_state_code||'-'||to_char(p_unique_key));
408: commit;

Line 443: insert into hr_state_delta_sync(COUNTRY_CODE,STATE_CODE,

439: loop
440: fetch fet_state_sync into p_cntry_code,p_state_code,p_state_desc,p_enable_flag,p_last_update_date;
441: if fet_state_sync%found then
442: select hrhd_delta_sync_seq.nextval into p_unique_key from dual;
443: insert into hr_state_delta_sync(COUNTRY_CODE,STATE_CODE,
444: STATE_DESCRIPTION,ENABLE_FLAG,STATUS,EFFECTIVE_STATUS_DATE,
445: LAST_UPDATE_DATE,EVENT_KEY ) values(p_cntry_code,p_state_code,p_state_desc,p_enable_flag,'QUEUED',p_effective_date,p_last_update_date,p_state_code||'-'||to_char(p_unique_key));
446: commit;
447:

Line 492: end hr_state_delta_sync;

488: FND_FILE.put_line(fnd_file.log, 'Error in State Delta Synch Extraction: '||SQLCODE);
489: FND_FILE.NEW_LINE(FND_FILE.log, 1);
490: FND_FILE.put_line(fnd_file.log, 'Error Msg: '||substr(SQLERRM,1,700));
491:
492: end hr_state_delta_sync;
493:
494: /*Procedure to extract the delta synch data for state ends here*/
495:
496: /*Procedure to extract the delta synch data for location begins here*/

Line 2874: hr_delta_sync_messages.hr_state_delta_sync(ERRBUF,RETCODE,p_party_site_id);

2870: FND_FILE.NEW_LINE(FND_FILE.log, 1);
2871: FND_FILE.put_line(fnd_file.log,'Delta synch Data Extraction Begins:'||to_char(p_effective_date, 'DD/MM/RRRR HH:MI:SS'));
2872: if p_process_name = 'STATE_DELTA_SYNCH'
2873: then
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);

Line 2909: update hr_state_delta_sync

2905: is
2906: begin
2907: if p_process_name = 'STATE_DELTA_SYNCH'
2908: then
2909: update hr_state_delta_sync
2910: set status = 'SENT'
2911: where event_key = p_event_key;
2912:
2913: elsif p_process_name = 'COUNTRY_DELTA_SYNCH'