30: IS
31: p_key VARCHAR2(30);
32: v_Num_Workers NUMBER;
33: BEGIN
34: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
35: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS.begin', '<
36: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Consolidation Hierarchy : ' || p_consolidation_hierarchy);
37: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Consolidation Entity : ' || p_consolidation_entity);
38: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Calendar Period : ' || p_cal_period_id);
31: p_key VARCHAR2(30);
32: v_Num_Workers NUMBER;
33: BEGIN
34: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
35: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS.begin', '<
37: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Consolidation Entity : ' || p_consolidation_entity);
38: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Calendar Period : ' || p_cal_period_id);
39: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Balance Type : ' || p_balance_type_code);
32: v_Num_Workers NUMBER;
33: BEGIN
34: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
35: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS.begin', '<
36: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Consolidation Hierarchy : ' || p_consolidation_hierarchy);
37: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Consolidation Entity : ' || p_consolidation_entity);
38: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Calendar Period : ' || p_cal_period_id);
39: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Balance Type : ' || p_balance_type_code);
40: END IF;
33: BEGIN
34: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
35: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS.begin', '<
36: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Consolidation Hierarchy : ' || p_consolidation_hierarchy);
37: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Consolidation Entity : ' || p_consolidation_entity);
38: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Calendar Period : ' || p_cal_period_id);
39: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Balance Type : ' || p_balance_type_code);
40: END IF;
41:
34: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
35: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS.begin', '<
36: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Consolidation Hierarchy : ' || p_consolidation_hierarchy);
37: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Consolidation Entity : ' || p_consolidation_entity);
38: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Calendar Period : ' || p_cal_period_id);
39: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Balance Type : ' || p_balance_type_code);
40: END IF;
41:
42: fnd_file.put_line(fnd_file.log, 'Beginning Consolidation Purge Program');
35: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS.begin', '<
36: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Consolidation Hierarchy : ' || p_consolidation_hierarchy);
37: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Consolidation Entity : ' || p_consolidation_entity);
38: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Calendar Period : ' || p_cal_period_id);
39: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS', 'Balance Type : ' || p_balance_type_code);
40: END IF;
41:
42: fnd_file.put_line(fnd_file.log, 'Beginning Consolidation Purge Program');
43: fnd_file.put_line(fnd_file.log, '<
54: WHERE NAME = 'cpu_count';
55:
56: EXCEPTION
57: WHEN OTHERS THEN
58: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_STATEMENT) THEN
59: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, g_api || '.PURGE_CONS_RUNS_WORKER', SubStr('Getting number of workers-'||TO_CHAR(SQLCODE)||': '||SQLERRM, 1, 255));
60: END IF;
61: fnd_file.put_line(fnd_file.log, SubStr('Getting number of workers-'||TO_CHAR(SQLCODE)||': '||SQLERRM, 1, 255));
62: x_retcode :='2';
55:
56: EXCEPTION
57: WHEN OTHERS THEN
58: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_STATEMENT) THEN
59: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, g_api || '.PURGE_CONS_RUNS_WORKER', SubStr('Getting number of workers-'||TO_CHAR(SQLCODE)||': '||SQLERRM, 1, 255));
60: END IF;
61: fnd_file.put_line(fnd_file.log, SubStr('Getting number of workers-'||TO_CHAR(SQLCODE)||': '||SQLERRM, 1, 255));
62: x_retcode :='2';
63: END;
72: AND gcer.most_recent_flag = 'Y'
73: AND gcer.run_entity_id = p_consolidation_entity;
74: EXCEPTION
75: WHEN OTHERS THEN
76: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_STATEMENT) THEN
77: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, g_api || '.PURGE_CONS_RUNS_WORKER', SubStr('Getting the Unique Key(p_key)'||TO_CHAR(SQLCODE)||': '||SQLERRM, 1, 255));
78: END IF;
79: fnd_file.put_line(fnd_file.log, SubStr('Getting the Unique Key(p_key)'||TO_CHAR(SQLCODE)||': '||SQLERRM, 1, 255));
80: x_retcode :='2';
73: AND gcer.run_entity_id = p_consolidation_entity;
74: EXCEPTION
75: WHEN OTHERS THEN
76: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_STATEMENT) THEN
77: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, g_api || '.PURGE_CONS_RUNS_WORKER', SubStr('Getting the Unique Key(p_key)'||TO_CHAR(SQLCODE)||': '||SQLERRM, 1, 255));
78: END IF;
79: fnd_file.put_line(fnd_file.log, SubStr('Getting the Unique Key(p_key)'||TO_CHAR(SQLCODE)||': '||SQLERRM, 1, 255));
80: x_retcode :='2';
81: END;
105: X_Argument7 => p_balance_type_code);
106:
107: -- To commit the overall transaction
108: COMMIT;
109: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
110: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS.end', '<
111: END IF;
112: EXCEPTION
113: WHEN OTHERS THEN
106:
107: -- To commit the overall transaction
108: COMMIT;
109: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
110: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS.end', '<
112: EXCEPTION
113: WHEN OTHERS THEN
114: ROLLBACK;
284: v_module_name VARCHAR2(100);
285:
286:
287: BEGIN
288: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
289: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER.begin', '<
290: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Consolidation Hierarchy : ' || p_consolidation_hierarchy);
291: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Consolidation Entity : ' || p_consolidation_entity);
292: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Calendar Period : ' || p_cal_period_id);
285:
286:
287: BEGIN
288: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
289: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER.begin', '<
291: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Consolidation Entity : ' || p_consolidation_entity);
292: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Calendar Period : ' || p_cal_period_id);
293: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Balance Type : ' || p_balance_type_code);
286:
287: BEGIN
288: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
289: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER.begin', '<
290: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Consolidation Hierarchy : ' || p_consolidation_hierarchy);
291: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Consolidation Entity : ' || p_consolidation_entity);
292: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Calendar Period : ' || p_cal_period_id);
293: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Balance Type : ' || p_balance_type_code);
294: END IF;
287: BEGIN
288: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
289: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER.begin', '<
290: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Consolidation Hierarchy : ' || p_consolidation_hierarchy);
291: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Consolidation Entity : ' || p_consolidation_entity);
292: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Calendar Period : ' || p_cal_period_id);
293: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Balance Type : ' || p_balance_type_code);
294: END IF;
295:
288: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
289: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER.begin', '<
290: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Consolidation Hierarchy : ' || p_consolidation_hierarchy);
291: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Consolidation Entity : ' || p_consolidation_entity);
292: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Calendar Period : ' || p_cal_period_id);
293: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Balance Type : ' || p_balance_type_code);
294: END IF;
295:
296: fnd_file.put_line(fnd_file.log, 'Beginning Consolidation Purge Program');
289: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER.begin', '<
290: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Consolidation Hierarchy : ' || p_consolidation_hierarchy);
291: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Consolidation Entity : ' || p_consolidation_entity);
292: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Calendar Period : ' || p_cal_period_id);
293: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER', 'Balance Type : ' || p_balance_type_code);
294: END IF;
295:
296: fnd_file.put_line(fnd_file.log, 'Beginning Consolidation Purge Program');
297: fnd_file.put_line(fnd_file.log, '<
384: fnd_file.put_line(fnd_file.log, '| Child Entity | Entry Name | Description |');
385: fnd_file.put_line(fnd_file.log, '+------------------------------------+--------------------------+-------------------------------------------------------------------------------------------+');
386:
387: FOR j IN l_purge_entry_id_rec.FIRST .. l_purge_entry_id_rec.LAST LOOP
388: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_STATEMENT) THEN
389: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, g_api || '.PURGE_CONS_RUNS_WORKER', 'Run Name : ' ||l_purge_cons_entity_list(i).run_name ||
390: 'Run Entity ID : ' ||l_purge_cons_entity_list(i).run_entity_id||
391: 'Entry ID: : ' ||l_purge_entry_id_rec(j).entry_id||
392: 'Child Entity ID : ' ||l_purge_entry_id_rec(j).child_entity_id);
385: fnd_file.put_line(fnd_file.log, '+------------------------------------+--------------------------+-------------------------------------------------------------------------------------------+');
386:
387: FOR j IN l_purge_entry_id_rec.FIRST .. l_purge_entry_id_rec.LAST LOOP
388: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_STATEMENT) THEN
389: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, g_api || '.PURGE_CONS_RUNS_WORKER', 'Run Name : ' ||l_purge_cons_entity_list(i).run_name ||
390: 'Run Entity ID : ' ||l_purge_cons_entity_list(i).run_entity_id||
391: 'Entry ID: : ' ||l_purge_entry_id_rec(j).entry_id||
392: 'Child Entity ID : ' ||l_purge_entry_id_rec(j).child_entity_id);
393: END IF;
439: p_batch_size,
440: FALSE);
441: END LOOP; -- while loop for parallel processsing
442: X_retcode := AD_CONC_UTILS_PKG.CONC_SUCCESS;
443: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
444: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER.end', '<
445: END IF;
446: EXCEPTION
447: WHEN OTHERS THEN
440: FALSE);
441: END LOOP; -- while loop for parallel processsing
442: X_retcode := AD_CONC_UTILS_PKG.CONC_SUCCESS;
443: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
444: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PURGE_CONS_RUNS_WORKER.end', '<
446: EXCEPTION
447: WHEN OTHERS THEN
448: ROLLBACK;