123: --
124: -- initialise
125: --
126: l_query_id := fnd_profile.value('CSF_DEFAULT_AUTO_COMMIT_QUERY');
127: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_STARTED');
128: print(fnd_message.get);
129: --
130: x_errbuf := g_errbuf_success;
131: x_retcode := g_retcode_success;
124: -- initialise
125: --
126: l_query_id := fnd_profile.value('CSF_DEFAULT_AUTO_COMMIT_QUERY');
127: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_STARTED');
128: print(fnd_message.get);
129: --
130: x_errbuf := g_errbuf_success;
131: x_retcode := g_retcode_success;
132: fnd_msg_pub.Initialize;
188: ELSE
189: l_start_date :=sysdate;
190: END IF;
191:
192: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PARAMS');
193: fnd_message.set_token('SOURCE_FLAG', p_task_source);
194: fnd_message.set_token('QUERY', p_query_id);
195: fnd_message.set_token('COMMIT_HORIZON', p_commit_horizon||' '||p_commit_horizon_uom);
196: fnd_message.set_token('FROMDATE', to_char(l_start_date,'dd-mon-rrrr hh24:mi:ss'));
189: l_start_date :=sysdate;
190: END IF;
191:
192: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PARAMS');
193: fnd_message.set_token('SOURCE_FLAG', p_task_source);
194: fnd_message.set_token('QUERY', p_query_id);
195: fnd_message.set_token('COMMIT_HORIZON', p_commit_horizon||' '||p_commit_horizon_uom);
196: fnd_message.set_token('FROMDATE', to_char(l_start_date,'dd-mon-rrrr hh24:mi:ss'));
197: fnd_message.set_token('TODATE', to_char(l_end_date,'dd-mon-rrrr hh24:mi:ss'));
190: END IF;
191:
192: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PARAMS');
193: fnd_message.set_token('SOURCE_FLAG', p_task_source);
194: fnd_message.set_token('QUERY', p_query_id);
195: fnd_message.set_token('COMMIT_HORIZON', p_commit_horizon||' '||p_commit_horizon_uom);
196: fnd_message.set_token('FROMDATE', to_char(l_start_date,'dd-mon-rrrr hh24:mi:ss'));
197: fnd_message.set_token('TODATE', to_char(l_end_date,'dd-mon-rrrr hh24:mi:ss'));
198: printlog(fnd_message.get);
191:
192: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PARAMS');
193: fnd_message.set_token('SOURCE_FLAG', p_task_source);
194: fnd_message.set_token('QUERY', p_query_id);
195: fnd_message.set_token('COMMIT_HORIZON', p_commit_horizon||' '||p_commit_horizon_uom);
196: fnd_message.set_token('FROMDATE', to_char(l_start_date,'dd-mon-rrrr hh24:mi:ss'));
197: fnd_message.set_token('TODATE', to_char(l_end_date,'dd-mon-rrrr hh24:mi:ss'));
198: printlog(fnd_message.get);
199:
192: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PARAMS');
193: fnd_message.set_token('SOURCE_FLAG', p_task_source);
194: fnd_message.set_token('QUERY', p_query_id);
195: fnd_message.set_token('COMMIT_HORIZON', p_commit_horizon||' '||p_commit_horizon_uom);
196: fnd_message.set_token('FROMDATE', to_char(l_start_date,'dd-mon-rrrr hh24:mi:ss'));
197: fnd_message.set_token('TODATE', to_char(l_end_date,'dd-mon-rrrr hh24:mi:ss'));
198: printlog(fnd_message.get);
199:
200:
193: fnd_message.set_token('SOURCE_FLAG', p_task_source);
194: fnd_message.set_token('QUERY', p_query_id);
195: fnd_message.set_token('COMMIT_HORIZON', p_commit_horizon||' '||p_commit_horizon_uom);
196: fnd_message.set_token('FROMDATE', to_char(l_start_date,'dd-mon-rrrr hh24:mi:ss'));
197: fnd_message.set_token('TODATE', to_char(l_end_date,'dd-mon-rrrr hh24:mi:ss'));
198: printlog(fnd_message.get);
199:
200:
201: OPEN c_terr_resource;
194: fnd_message.set_token('QUERY', p_query_id);
195: fnd_message.set_token('COMMIT_HORIZON', p_commit_horizon||' '||p_commit_horizon_uom);
196: fnd_message.set_token('FROMDATE', to_char(l_start_date,'dd-mon-rrrr hh24:mi:ss'));
197: fnd_message.set_token('TODATE', to_char(l_end_date,'dd-mon-rrrr hh24:mi:ss'));
198: printlog(fnd_message.get);
199:
200:
201: OPEN c_terr_resource;
202: FETCH c_terr_resource
313: );
314: commit;
315: g_batch_total := g_batch_total+1;
316: l_primary_request_stack(g_batch_total) := x_request_id;
317: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PARALLEL');
318: fnd_message.set_token('REQUEST_ID', x_request_id);
319: fnd_message.set_token('FROMTASKID', l_first_task_id);
320: fnd_message.set_token('TOTASKID', l_last_task_id);
321: printlog(fnd_message.get);
314: commit;
315: g_batch_total := g_batch_total+1;
316: l_primary_request_stack(g_batch_total) := x_request_id;
317: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PARALLEL');
318: fnd_message.set_token('REQUEST_ID', x_request_id);
319: fnd_message.set_token('FROMTASKID', l_first_task_id);
320: fnd_message.set_token('TOTASKID', l_last_task_id);
321: printlog(fnd_message.get);
322: end if;
315: g_batch_total := g_batch_total+1;
316: l_primary_request_stack(g_batch_total) := x_request_id;
317: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PARALLEL');
318: fnd_message.set_token('REQUEST_ID', x_request_id);
319: fnd_message.set_token('FROMTASKID', l_first_task_id);
320: fnd_message.set_token('TOTASKID', l_last_task_id);
321: printlog(fnd_message.get);
322: end if;
323:
316: l_primary_request_stack(g_batch_total) := x_request_id;
317: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PARALLEL');
318: fnd_message.set_token('REQUEST_ID', x_request_id);
319: fnd_message.set_token('FROMTASKID', l_first_task_id);
320: fnd_message.set_token('TOTASKID', l_last_task_id);
321: printlog(fnd_message.get);
322: end if;
323:
324:
317: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PARALLEL');
318: fnd_message.set_token('REQUEST_ID', x_request_id);
319: fnd_message.set_token('FROMTASKID', l_first_task_id);
320: fnd_message.set_token('TOTASKID', l_last_task_id);
321: printlog(fnd_message.get);
322: end if;
323:
324:
325: EXIT WHEN c_task_list%NOTFOUND;
325: EXIT WHEN c_task_list%NOTFOUND;
326: END LOOP;
327:
328:
329: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_RESOURCES');
330: fnd_message.set_token('NOOFTASKS', l_tot_tasks_queried);
331: fnd_message.set_token('COUNT', p_res_key.count);
332: print(fnd_message.get);
333:
326: END LOOP;
327:
328:
329: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_RESOURCES');
330: fnd_message.set_token('NOOFTASKS', l_tot_tasks_queried);
331: fnd_message.set_token('COUNT', p_res_key.count);
332: print(fnd_message.get);
333:
334: IF g_batch_total >0
327:
328:
329: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_RESOURCES');
330: fnd_message.set_token('NOOFTASKS', l_tot_tasks_queried);
331: fnd_message.set_token('COUNT', p_res_key.count);
332: print(fnd_message.get);
333:
334: IF g_batch_total >0
335: THEN
328:
329: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_RESOURCES');
330: fnd_message.set_token('NOOFTASKS', l_tot_tasks_queried);
331: fnd_message.set_token('COUNT', p_res_key.count);
332: print(fnd_message.get);
333:
334: IF g_batch_total >0
335: THEN
336:
335: THEN
336:
337: l_return_status := fnd_api.g_ret_sts_success;
338: primary_ptr := 1;
339: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_TOTAL');
340: fnd_message.set_token('TOTAL', g_batch_total);
341: printlog(fnd_message.get);
342: END IF;
343: printlog(' ===================================================================================================');
336:
337: l_return_status := fnd_api.g_ret_sts_success;
338: primary_ptr := 1;
339: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_TOTAL');
340: fnd_message.set_token('TOTAL', g_batch_total);
341: printlog(fnd_message.get);
342: END IF;
343: printlog(' ===================================================================================================');
344:
337: l_return_status := fnd_api.g_ret_sts_success;
338: primary_ptr := 1;
339: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_TOTAL');
340: fnd_message.set_token('TOTAL', g_batch_total);
341: printlog(fnd_message.get);
342: END IF;
343: printlog(' ===================================================================================================');
344:
345: dbms_lock.sleep(l_sleep_time);
359: dev_status => l_dev_status,
360: message => l_dummy3);
361: IF (NOT l_call_status) THEN
362:
363: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_ERR');
364: fnd_message.set_token('ERROR', l_failed_request_id);
365: print(fnd_message.get);
366: l_failed_request_id := l_primary_request_stack(primary_ptr);
367: raise fnd_api.g_exc_unexpected_error;
360: message => l_dummy3);
361: IF (NOT l_call_status) THEN
362:
363: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_ERR');
364: fnd_message.set_token('ERROR', l_failed_request_id);
365: print(fnd_message.get);
366: l_failed_request_id := l_primary_request_stack(primary_ptr);
367: raise fnd_api.g_exc_unexpected_error;
368: END IF;
361: IF (NOT l_call_status) THEN
362:
363: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_ERR');
364: fnd_message.set_token('ERROR', l_failed_request_id);
365: print(fnd_message.get);
366: l_failed_request_id := l_primary_request_stack(primary_ptr);
367: raise fnd_api.g_exc_unexpected_error;
368: END IF;
369: IF l_dev_phase = 'COMPLETE'
373: l_completed_batch_count := l_completed_batch_count +1;
374: IF l_dev_status = 'ERROR'
375: THEN
376:
377: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_ERR');
378: fnd_message.set_token('ERROR', l_failed_request_id);
379: print(fnd_message.get);
380: raise fnd_api.g_exc_unexpected_error;
381: ELSIF l_dev_status = 'WARNING'
374: IF l_dev_status = 'ERROR'
375: THEN
376:
377: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_ERR');
378: fnd_message.set_token('ERROR', l_failed_request_id);
379: print(fnd_message.get);
380: raise fnd_api.g_exc_unexpected_error;
381: ELSIF l_dev_status = 'WARNING'
382: THEN
375: THEN
376:
377: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_ERR');
378: fnd_message.set_token('ERROR', l_failed_request_id);
379: print(fnd_message.get);
380: raise fnd_api.g_exc_unexpected_error;
381: ELSIF l_dev_status = 'WARNING'
382: THEN
383: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_WAR');
379: print(fnd_message.get);
380: raise fnd_api.g_exc_unexpected_error;
381: ELSIF l_dev_status = 'WARNING'
382: THEN
383: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_WAR');
384: fnd_message.set_token('WARNING', l_failed_request_id);
385: print(fnd_message.get);
386: l_return_status := 'W'; --WARNING;
387: ELSE
380: raise fnd_api.g_exc_unexpected_error;
381: ELSIF l_dev_status = 'WARNING'
382: THEN
383: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_WAR');
384: fnd_message.set_token('WARNING', l_failed_request_id);
385: print(fnd_message.get);
386: l_return_status := 'W'; --WARNING;
387: ELSE
388: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_COMP');
381: ELSIF l_dev_status = 'WARNING'
382: THEN
383: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_WAR');
384: fnd_message.set_token('WARNING', l_failed_request_id);
385: print(fnd_message.get);
386: l_return_status := 'W'; --WARNING;
387: ELSE
388: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_COMP');
389: fnd_message.set_token('COMPLETED', l_failed_request_id);
384: fnd_message.set_token('WARNING', l_failed_request_id);
385: print(fnd_message.get);
386: l_return_status := 'W'; --WARNING;
387: ELSE
388: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_COMP');
389: fnd_message.set_token('COMPLETED', l_failed_request_id);
390: print(fnd_message.get);
391: END IF;
392:
385: print(fnd_message.get);
386: l_return_status := 'W'; --WARNING;
387: ELSE
388: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_COMP');
389: fnd_message.set_token('COMPLETED', l_failed_request_id);
390: print(fnd_message.get);
391: END IF;
392:
393: END IF;
386: l_return_status := 'W'; --WARNING;
387: ELSE
388: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_PRG_COMP');
389: fnd_message.set_token('COMPLETED', l_failed_request_id);
390: print(fnd_message.get);
391: END IF;
392:
393: END IF;
394: END IF;
405: END IF;
406: END IF;
407: END LOOP;
408: ELSE
409: fnd_message.set_name('CSF','CSF_NO_TASK_FOR_RESOURCE');
410: print(fnd_message.get);
411: l_return_status := 'W'; --WARNING;
412: END IF;
413: printlog(' =================================================================================================================');
406: END IF;
407: END LOOP;
408: ELSE
409: fnd_message.set_name('CSF','CSF_NO_TASK_FOR_RESOURCE');
410: print(fnd_message.get);
411: l_return_status := 'W'; --WARNING;
412: END IF;
413: printlog(' =================================================================================================================');
414: END IF;
427: fnd_msg_pub.get(counter,FND_API.G_FALSE,l_msg_data,l1);
428: print(l_msg_data);
429: end loop;
430: end if;
431: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_DONE');
432: print(fnd_message.get);
433:
434: exception
435: when fnd_api.g_exc_unexpected_error then
428: print(l_msg_data);
429: end loop;
430: end if;
431: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_DONE');
432: print(fnd_message.get);
433:
434: exception
435: when fnd_api.g_exc_unexpected_error then
436:
454: fnd_msg_pub.get(counter,FND_API.G_FALSE,l_msg_data,l1);
455: print(l_msg_data);
456: end loop;
457: end if;
458: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_EXCEPTION');
459: fnd_message.set_token('P_MESSAGE', sqlerrm);
460: print(fnd_message.get);
461: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_ABORT');
462: print(fnd_message.get);
455: print(l_msg_data);
456: end loop;
457: end if;
458: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_EXCEPTION');
459: fnd_message.set_token('P_MESSAGE', sqlerrm);
460: print(fnd_message.get);
461: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_ABORT');
462: print(fnd_message.get);
463: end update_planned_task_status;
456: end loop;
457: end if;
458: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_EXCEPTION');
459: fnd_message.set_token('P_MESSAGE', sqlerrm);
460: print(fnd_message.get);
461: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_ABORT');
462: print(fnd_message.get);
463: end update_planned_task_status;
464:
457: end if;
458: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_EXCEPTION');
459: fnd_message.set_token('P_MESSAGE', sqlerrm);
460: print(fnd_message.get);
461: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_ABORT');
462: print(fnd_message.get);
463: end update_planned_task_status;
464:
465: --============================================--
458: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_EXCEPTION');
459: fnd_message.set_token('P_MESSAGE', sqlerrm);
460: print(fnd_message.get);
461: fnd_message.set_name('CSF', 'CSF_AUTO_COMMIT_ABORT');
462: print(fnd_message.get);
463: end update_planned_task_status;
464:
465: --============================================--
466: -- private procedure and function definitions --