29: p_process_table_name => 'HRI_CS_SUPH');
30: ELSE
31: l_start_date := fnd_date.date_to_canonical
32: (fnd_date.displaydt_to_date
33: (hri_bpl_conc_log.get_last_collect_to_date
34: ('HRI_CS_SUPH','HRI_CS_SUPH')));
35: END IF;
36:
37: hri_bpl_conc_log.dbg('Full refresh: ' || l_full_refresh);
33: (hri_bpl_conc_log.get_last_collect_to_date
34: ('HRI_CS_SUPH','HRI_CS_SUPH')));
35: END IF;
36:
37: hri_bpl_conc_log.dbg('Full refresh: ' || l_full_refresh);
38: hri_bpl_conc_log.dbg('Collect from: ' || l_start_date);
39:
40: load_supervisor_history
41: (errbuf => errbuf,
34: ('HRI_CS_SUPH','HRI_CS_SUPH')));
35: END IF;
36:
37: hri_bpl_conc_log.dbg('Full refresh: ' || l_full_refresh);
38: hri_bpl_conc_log.dbg('Collect from: ' || l_start_date);
39:
40: load_supervisor_history
41: (errbuf => errbuf,
42: retcode => retcode,
89: ) IS
90: --
91: BEGIN
92: --
93: hri_bpl_conc_log.record_process_start('HRI_CS_POSH');
94: --
95: hri_opl_posh.load_all_positions
96: (errbuf => errbuf
97: ,retcode => retcode
97: ,retcode => retcode
98: ,p_chunk_size => p_chunk_size
99: );
100: --
101: hri_bpl_conc_log.log_process_end
102: (p_status => TRUE
103: ,p_attribute1 => p_chunk_size
104: );
105: --
108: EXCEPTION
109: --
110: WHEN OTHERS THEN
111: --
112: hri_bpl_conc_log.log_process_end
113: (p_status => FALSE
114: ,p_attribute1 => p_chunk_size
115: );
116: --
127: ) IS
128: --
129: BEGIN
130: --
131: hri_bpl_conc_log.record_process_start('HRI_ORG_HRCHY_SUMMARY');
132: --
133: hri_opl_orgh.load
134: (errbuf => errbuf
135: ,retcode => retcode
135: ,retcode => retcode
136: ,p_chunk_size => p_chunk_size
137: );
138: --
139: hri_bpl_conc_log.log_process_end
140: (p_status => TRUE
141: ,p_attribute1 => p_chunk_size
142: );
143: --
146: EXCEPTION
147: --
148: WHEN OTHERS THEN
149: --
150: hri_bpl_conc_log.log_process_end
151: (p_status => FALSE
152: ,p_attribute1 => p_chunk_size
153: );
154: --
166:
167: BEGIN
168:
169: -- Log process start
170: hri_bpl_conc_log.record_process_start('HRI_CS_JOBH_CT');
171:
172: -- If the full refresh parameter is not provided, default it
173: IF (p_full_refresh IS NULL) THEN
174: l_full_refresh := hri_oltp_conc_param.get_parameter_value
177: ELSE
178: l_full_refresh := p_full_refresh;
179: END IF;
180:
181: hri_bpl_conc_log.dbg('Full refresh: ' || l_full_refresh);
182: hri_bpl_conc_log.dbg('Collect from: N/A');
183:
184: IF (l_full_refresh = 'Y') THEN
185: hri_opl_jobh.full_refresh;
178: l_full_refresh := p_full_refresh;
179: END IF;
180:
181: hri_bpl_conc_log.dbg('Full refresh: ' || l_full_refresh);
182: hri_bpl_conc_log.dbg('Collect from: N/A');
183:
184: IF (l_full_refresh = 'Y') THEN
185: hri_opl_jobh.full_refresh;
186: ELSE
186: ELSE
187: hri_opl_jobh.incr_refresh(p_refresh_flex => 'N');
188: END IF;
189:
190: hri_bpl_conc_log.log_process_end
191: (p_status => TRUE
192: ,p_period_from => hr_general.start_of_time
193: ,p_period_to => hr_general.end_of_time
194: ,p_attribute1 => p_full_refresh
195: );
196:
197: EXCEPTION WHEN OTHERS THEN
198:
199: hri_bpl_conc_log.log_process_end
200: (p_status => FALSE
201: ,p_period_from => hr_general.start_of_time
202: ,p_period_to => hr_general.end_of_time
203: ,p_attribute1 => p_full_refresh);
215:
216: BEGIN
217:
218: -- As the process is being run from CM, enable output logging
219: hri_bpl_conc_log.record_process_start('HRI_CS_PRSNTYP_CT');
220:
221: -- If the full refresh parameter is not provided, default it
222: IF (p_full_refresh IS NULL) THEN
223: l_full_refresh := hri_oltp_conc_param.get_parameter_value
226: ELSE
227: l_full_refresh := p_full_refresh;
228: END IF;
229:
230: hri_bpl_conc_log.dbg('Full refresh: ' || l_full_refresh);
231: hri_bpl_conc_log.dbg('Collect from: N/A');
232:
233: -- Set warning off (in case this session is re-used)
234: hri_bpl_person_type.g_warning_flag := 'N';
227: l_full_refresh := p_full_refresh;
228: END IF;
229:
230: hri_bpl_conc_log.dbg('Full refresh: ' || l_full_refresh);
231: hri_bpl_conc_log.dbg('Collect from: N/A');
232:
233: -- Set warning off (in case this session is re-used)
234: hri_bpl_person_type.g_warning_flag := 'N';
235:
247: retcode := 1;
248: END IF;
249:
250: -- Log process end
251: hri_bpl_conc_log.log_process_end
252: (p_status => TRUE
253: ,p_period_from => hr_general.start_of_time
254: ,p_period_to => hr_general.end_of_time
255: ,p_attribute1 => 'N');
258: EXCEPTION WHEN OTHERS THEN
259:
260: g_msg_sub_group := NVL(g_msg_sub_group, 'INCR_REFRESH');
261:
262: hri_bpl_conc_log.log_process_info
263: (p_package_name => 'HRI_OPL_PERSON_TYPE_CTGRY'
264: ,p_msg_type => 'ERROR'
265: ,p_msg_group => 'PRSN_TYP_CNGS'
266: ,p_msg_sub_group => g_msg_sub_group
266: ,p_msg_sub_group => g_msg_sub_group
267: ,p_sql_err_code => SQLCODE
268: ,p_note => SQLERRM);
269:
270: hri_bpl_conc_log.log_process_end
271: (p_status => FALSE
272: ,p_period_from => hr_general.start_of_time
273: ,p_period_to => hr_general.end_of_time
274: ,p_attribute1 => 'N');
288:
289: BEGIN
290:
291: -- As the process is being run from CM, enable output logging
292: hri_bpl_conc_log.record_process_start('HRI_CS_PER_PERSON_CT');
293:
294: -- If the full refresh parameter is not provided, default it
295: IF (p_full_refresh IS NULL) THEN
296: l_full_refresh := hri_oltp_conc_param.get_parameter_value
299: ELSE
300: l_full_refresh := p_full_refresh;
301: END IF;
302:
303: hri_bpl_conc_log.dbg('Full refresh: ' || l_full_refresh);
304: hri_bpl_conc_log.dbg('Collect from: N/A');
305:
306: -- Call the appropriate function depending on full refresh parameter
307: IF (l_full_refresh = 'Y') THEN
300: l_full_refresh := p_full_refresh;
301: END IF;
302:
303: hri_bpl_conc_log.dbg('Full refresh: ' || l_full_refresh);
304: hri_bpl_conc_log.dbg('Collect from: N/A');
305:
306: -- Call the appropriate function depending on full refresh parameter
307: IF (l_full_refresh = 'Y') THEN
308: hri_opl_per_person.load(1500,
317:
318: END IF;
319:
320: -- Log process end
321: hri_bpl_conc_log.log_process_end
322: (p_status => TRUE
323: ,p_period_from => hr_general.start_of_time
324: ,p_period_to => hr_general.end_of_time
325: ,p_attribute1 => 'N');
327: EXCEPTION WHEN OTHERS THEN
328:
329: g_msg_sub_group := NVL(g_msg_sub_group, 'INCR_REFRESH');
330:
331: hri_bpl_conc_log.log_process_info
332: (p_package_name => 'HRI_CS_PER_PERSON_CT'
333: ,p_msg_type => 'ERROR'
334: ,p_msg_group => 'PRSN_CNGS'
335: ,p_msg_sub_group => g_msg_sub_group
335: ,p_msg_sub_group => g_msg_sub_group
336: ,p_sql_err_code => SQLCODE
337: ,p_note => SQLERRM);
338:
339: hri_bpl_conc_log.log_process_end
340: (p_status => FALSE
341: ,p_period_from => hr_general.start_of_time
342: ,p_period_to => hr_general.end_of_time
343: ,p_attribute1 => 'N');
359:
360: BEGIN
361:
362: -- Log process start
363: hri_bpl_conc_log.record_process_start('HRI_CS_POW_BAND_CT');
364:
365: -- If the full refresh parameter is not provided, default it
366: IF (p_full_refresh IS NULL) THEN
367: l_full_refresh := hri_oltp_conc_param.get_parameter_value
370: ELSE
371: l_full_refresh := p_full_refresh;
372: END IF;
373:
374: hri_bpl_conc_log.dbg('Full refresh: ' || l_full_refresh);
375: hri_bpl_conc_log.dbg('Collect from: N/A');
376:
377: -- Set warning off - in case the session is reused
378: hri_opl_period_of_work.g_warning_flag := 'N';
371: l_full_refresh := p_full_refresh;
372: END IF;
373:
374: hri_bpl_conc_log.dbg('Full refresh: ' || l_full_refresh);
375: hri_bpl_conc_log.dbg('Collect from: N/A');
376:
377: -- Set warning off - in case the session is reused
378: hri_opl_period_of_work.g_warning_flag := 'N';
379:
386: ELSE
387:
388: -- Period of work bands are not refreshed in incremental mode
389: -- Log this into the concurrent program log
390: hri_bpl_conc_log.output('Period of work bands are not ' ||
391: 'refreshed in incremental mode');
392:
393: END IF;
394:
398: retcode:= 1;
399: END IF;
400:
401: -- Log process end
402: hri_bpl_conc_log.log_process_end
403: (p_status => TRUE
404: ,p_period_from => hr_general.start_of_time
405: ,p_period_to => hr_general.end_of_time
406: ,p_attribute1 => 'N');
406: ,p_attribute1 => 'N');
407:
408: EXCEPTION WHEN OTHERS THEN
409:
410: hri_bpl_conc_log.log_process_end
411: (p_status => FALSE
412: ,p_period_from => hr_general.start_of_time
413: ,p_period_to => hr_general.end_of_time
414: ,p_attribute1 => 'N');
431:
432: BEGIN
433:
434: -- Log process start
435: hri_bpl_conc_log.record_process_start('HRI_CS_JOB_JOB_ROLE_CT');
436:
437: -- If the full refresh parameter is not provided, default it
438: IF (p_full_refresh IS NULL) THEN
439: l_full_refresh := hri_oltp_conc_param.get_parameter_value
442: ELSE
443: l_full_refresh := p_full_refresh;
444: END IF;
445:
446: hri_bpl_conc_log.dbg('Full refresh: ' || l_full_refresh);
447: hri_bpl_conc_log.dbg('Collect from: N/A');
448:
449: -- Set warning off - in case the session is reused
450: hri_bpl_job.g_warning_flag := 'N';
443: l_full_refresh := p_full_refresh;
444: END IF;
445:
446: hri_bpl_conc_log.dbg('Full refresh: ' || l_full_refresh);
447: hri_bpl_conc_log.dbg('Collect from: N/A');
448:
449: -- Set warning off - in case the session is reused
450: hri_bpl_job.g_warning_flag := 'N';
451:
461: retcode:= 1;
462: END IF;
463:
464: -- Log process end
465: hri_bpl_conc_log.log_process_end
466: (p_status => TRUE
467: ,p_period_from => hr_general.start_of_time
468: ,p_period_to => SYSDATE
469: ,p_attribute1 => 'N');
469: ,p_attribute1 => 'N');
470:
471: EXCEPTION WHEN OTHERS THEN
472:
473: hri_bpl_conc_log.log_process_end
474: (p_status => FALSE
475: ,p_period_from => hr_general.start_of_time
476: ,p_period_to => SYSDATE
477: ,p_attribute1 => 'N');