[Home] [Help]
1: PACKAGE BODY cn_proc_batches_pkg AS
2: /* $Header: cnsybatb.pls 120.20.12010000.2 2008/09/26 10:07:47 venjayar ship $ */
3:
4: /*
5: Date Name Description
693: WHEN OTHERS THEN
694: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
695: fnd_log.STRING(
696: fnd_log.level_unexpected
697: , 'cn.plsql.cn_proc_batches_pkg.populate_calcsub_batches.loop'
698: , SQLERRM
699: );
700: END IF;
701:
777: END IF;
778:
779: cn_message_pkg.FLUSH;
780: WHEN OTHERS THEN
781: fnd_file.put_line(fnd_file.LOG, 'In cn_proc_batches_pkg.populate_calcsub_batch: ' || SQLERRM);
782: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.populate_calcsub_batch:');
783: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
784:
785: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
778:
779: cn_message_pkg.FLUSH;
780: WHEN OTHERS THEN
781: fnd_file.put_line(fnd_file.LOG, 'In cn_proc_batches_pkg.populate_calcsub_batch: ' || SQLERRM);
782: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.populate_calcsub_batch:');
783: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
784:
785: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
786: fnd_log.STRING(
784:
785: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
786: fnd_log.STRING(
787: fnd_log.level_unexpected
788: , 'cn.plsql.cn_proc_batches_pkg.populate_calcsub_batches.exception'
789: , SQLERRM
790: );
791: END IF;
792:
1109: WHEN OTHERS THEN
1110: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
1111: fnd_log.STRING(
1112: fnd_log.level_unexpected
1113: , 'cn.plsql.cn_proc_batches_pkg.find_srp_incomplete_plan.exception'
1114: , SQLERRM
1115: );
1116: END IF;
1117:
1247:
1248: IF (fnd_log.level_exception >= fnd_log.g_current_runtime_level) THEN
1249: fnd_log.MESSAGE(
1250: fnd_log.level_exception
1251: , 'cn.plsql.cn_proc_batches_pkg.populate_process_batches.all_reps'
1252: , FALSE
1253: );
1254: END IF;
1255:
1343:
1344: IF (fnd_log.level_exception >= fnd_log.g_current_runtime_level) THEN
1345: fnd_log.MESSAGE(
1346: fnd_log.level_exception
1347: , 'cn.plsql.cn_proc_batches_pkg.populate_process_batches.user_specify'
1348: , FALSE
1349: );
1350: END IF;
1351:
1536: IF (fnd_log.level_exception >= fnd_log.g_current_runtime_level) THEN
1537: fnd_log.STRING
1538: (
1539: fnd_log.level_exception
1540: , 'cn.plsql.cn_proc_batches_pkg.populate_process_batches.reps_in_notify_log'
1541: , 'No salesreps to calculate ...'
1542: );
1543: END IF;
1544:
1550: WHEN no_one_with_complete_plan THEN
1551: fnd_file.put_line
1552: (
1553: fnd_file.LOG
1554: , 'Exception occurs in cn_proc_batches_pkg.populate_process_batch: No one with complete compensation plan to calculate.'
1555: );
1556: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.populate_process_batch:');
1557: cn_message_pkg.rollback_errormsg_commit
1558: ('No one with complete compensation plan to calculate.');
1552: (
1553: fnd_file.LOG
1554: , 'Exception occurs in cn_proc_batches_pkg.populate_process_batch: No one with complete compensation plan to calculate.'
1555: );
1556: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.populate_process_batch:');
1557: cn_message_pkg.rollback_errormsg_commit
1558: ('No one with complete compensation plan to calculate.');
1559: RAISE;
1560: WHEN OTHERS THEN
1557: cn_message_pkg.rollback_errormsg_commit
1558: ('No one with complete compensation plan to calculate.');
1559: RAISE;
1560: WHEN OTHERS THEN
1561: fnd_file.put_line(fnd_file.LOG, 'In cn_proc_batches_pkg.populate_process_batch:' || SQLERRM);
1562:
1563: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
1564: fnd_log.STRING(
1565: fnd_log.level_unexpected
1562:
1563: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
1564: fnd_log.STRING(
1565: fnd_log.level_unexpected
1566: , 'cn.plsql.cn_proc_batches_pkg.populate_process_batch.exception'
1567: , SQLERRM
1568: );
1569: END IF;
1570:
1567: , SQLERRM
1568: );
1569: END IF;
1570:
1571: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.populate_process_batch: ');
1572: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
1573: RAISE;
1574: END populate_process_batch;
1575:
1600: BEGIN
1601: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
1602: fnd_log.STRING(
1603: fnd_log.level_procedure
1604: , 'cn.plsql.cn_proc_batches_pkg.calculation_submission.begin'
1605: , 'Beginning of calculation submission procedure ...'
1606: );
1607: END IF;
1608:
1662: WHERE logical_batch_id = g_logical_batch_id;
1663:
1664: IF l_status <> 'COMPLETE' THEN
1665: cn_global_var.initialize_instance_info(l_batch_rec.org_id);
1666: cn_proc_batches_pkg.main(
1667: p_concurrent_flag => l_batch_rec.concurrent_flag
1668: , p_process_name => 'CALCULATION'
1669: , p_logical_batch_id => g_logical_batch_id
1670: , p_start_date => l_batch_rec.start_date
1683:
1684: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
1685: fnd_log.STRING(
1686: fnd_log.level_procedure
1687: , 'cn.plsql.cn_proc_batches_pkg.calculation_submission.end'
1688: , 'End of calculation submission procedure.'
1689: );
1690: END IF;
1691: EXCEPTION
1692: WHEN no_one_with_complete_plan THEN
1693: fnd_file.put_line
1694: (
1695: fnd_file.LOG
1696: , 'no_one_with_complete_plan EXCEPTION in cn_proc_batches_pkg.calculation_submission'
1697: );
1698: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.calculation_submission');
1699: cn_message_pkg.rollback_errormsg_commit
1700: ('No resource with complete compensation plan to calculate.');
1694: (
1695: fnd_file.LOG
1696: , 'no_one_with_complete_plan EXCEPTION in cn_proc_batches_pkg.calculation_submission'
1697: );
1698: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.calculation_submission');
1699: cn_message_pkg.rollback_errormsg_commit
1700: ('No resource with complete compensation plan to calculate.');
1701: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'FAILED');
1702: COMMIT;
1702: COMMIT;
1703: app_exception.raise_exception;
1704: WHEN OTHERS THEN
1705: x_process_status_code := 'FAIL';
1706: fnd_file.put_line(fnd_file.LOG, 'Error in cn_proc_batches_pkg.calculation_submission.');
1707: fnd_file.put_line(fnd_file.LOG, SQLERRM);
1708: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.calculation_submission:');
1709: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
1710: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'FAILED');
1704: WHEN OTHERS THEN
1705: x_process_status_code := 'FAIL';
1706: fnd_file.put_line(fnd_file.LOG, 'Error in cn_proc_batches_pkg.calculation_submission.');
1707: fnd_file.put_line(fnd_file.LOG, SQLERRM);
1708: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.calculation_submission:');
1709: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
1710: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'FAILED');
1711: COMMIT;
1712:
1712:
1713: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
1714: fnd_log.STRING(
1715: fnd_log.level_unexpected
1716: , 'cn.plsql.cn_proc_batches_pkg.calculation_submission.exception'
1717: , SQLERRM
1718: );
1719: END IF;
1720: END calculation_submission;
1735: WHEN OTHERS THEN
1736: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
1737: fnd_log.STRING(
1738: fnd_log.level_unexpected
1739: , 'cn.plsql.cn_proc_batches_pkg.get_physical_batch_id.exception'
1740: , SQLERRM
1741: );
1742: END IF;
1743:
1876: BEGIN
1877: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
1878: fnd_log.STRING(
1879: fnd_log.level_procedure
1880: , 'cn.plsql.cn_proc_batches_pkg.assign.begin'
1881: , 'Beginning of assigning resources to physical batches ...'
1882: );
1883: END IF;
1884:
1959:
1960: IF (fnd_log.level_exception >= fnd_log.g_current_runtime_level) THEN
1961: fnd_log.STRING(
1962: fnd_log.level_exception
1963: , 'cn.plsql.cn_proc_batches_pkg.assign.reps_count'
1964: , 'No salesreps to process.'
1965: );
1966: END IF;
1967:
2043:
2044: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
2045: fnd_log.STRING(
2046: fnd_log.level_procedure
2047: , 'cn.plsql.cn_proc_batches_pkg.assign.end'
2048: , 'Finish assigning resources to physical batches.'
2049: );
2050: END IF;
2051:
2053: cn_message_pkg.FLUSH;
2054: COMMIT;
2055: EXCEPTION
2056: WHEN no_comm_lines THEN
2057: fnd_file.put_line(fnd_file.LOG, 'no_comm_lines exception in cn_proc_batches_pkg.assign');
2058: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.assign:');
2059: cn_message_pkg.DEBUG('No transactions to process.');
2060: RAISE;
2061: WHEN OTHERS THEN
2054: COMMIT;
2055: EXCEPTION
2056: WHEN no_comm_lines THEN
2057: fnd_file.put_line(fnd_file.LOG, 'no_comm_lines exception in cn_proc_batches_pkg.assign');
2058: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.assign:');
2059: cn_message_pkg.DEBUG('No transactions to process.');
2060: RAISE;
2061: WHEN OTHERS THEN
2062: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
2059: cn_message_pkg.DEBUG('No transactions to process.');
2060: RAISE;
2061: WHEN OTHERS THEN
2062: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
2063: fnd_log.STRING(fnd_log.level_unexpected, 'cn.plsql.cn_proc_batches_pkg.assign.exception'
2064: , SQLERRM);
2065: END IF;
2066:
2067: fnd_file.put_line(fnd_file.LOG, 'In cn_proc_batches.assign: ' || SQLERRM);
2064: , SQLERRM);
2065: END IF;
2066:
2067: fnd_file.put_line(fnd_file.LOG, 'In cn_proc_batches.assign: ' || SQLERRM);
2068: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.assign:');
2069: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
2070: RAISE;
2071: END assign;
2072:
2118: IF (x_request_id = 0 OR x_request_id IS NULL) THEN
2119: IF (fnd_log.level_error >= fnd_log.g_current_runtime_level) THEN
2120: fnd_log.STRING(
2121: fnd_log.level_error
2122: , 'cn.plsql.cn_proc_batches_pkg.conc_submit.submission_status'
2123: , 'Submission failure for batch: ' || x_physical_batch_id
2124: );
2125: END IF;
2126:
2196: BEGIN
2197: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
2198: fnd_log.STRING(
2199: fnd_log.level_procedure
2200: , 'cn.plsql.cn_proc_batches_pkg.conc_dispatch.begin'
2201: , 'Beginning of conc_dispatch...'
2202: );
2203: END IF;
2204:
2338:
2339: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
2340: fnd_log.STRING(
2341: fnd_log.level_unexpected
2342: , 'cn.plsql.cn_proc_batches_pkg.conc_dispatch.request_status'
2343: , 'Request ' || l_failed_request_id || ' failed (batch_id = ' || l_temp_phys_batch_id
2344: );
2345: END IF;
2346:
2380:
2381: IF (fnd_log.level_error >= fnd_log.g_current_runtime_level) THEN
2382: fnd_log.STRING(
2383: fnd_log.level_error
2384: , 'cn.plsql.cn_proc_batches_pkg.conc_dispatch.request_status'
2385: , 'Request ' || l_failed_request_id || ' failed (batch_id = '
2386: || l_temp_phys_batch_id
2387: );
2388: END IF;
2482:
2483: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
2484: fnd_log.STRING(
2485: fnd_log.level_procedure
2486: , 'cn.plsql.cn_proc_batches_pkg.conc_dispatch.end'
2487: , 'End of conc_dispatch.'
2488: );
2489: END IF;
2490: EXCEPTION
2488: );
2489: END IF;
2490: EXCEPTION
2491: WHEN conc_fail THEN
2492: fnd_file.put_line(fnd_file.LOG, 'conc_fail exception in cn_proc_batches_pkg.conc_dispatch');
2493: update_error(l_temp_phys_batch_id);
2494:
2495: -- canceling running/pending requests
2496: IF (l_primary_request_stack.COUNT > 0) THEN
2498: IF (l_primary_request_stack(i) > 0) THEN
2499: IF (fnd_log.level_exception >= fnd_log.g_current_runtime_level) THEN
2500: fnd_log.STRING(
2501: fnd_log.level_exception
2502: , 'cn.plsql.cn_proc_batches_pkg.conc_dispatch.exception'
2503: , 'Cancelling request: ' || l_primary_request_stack(i)
2504: );
2505: END IF;
2506:
2514: cn_message_pkg.end_batch(x_parent_proc_audit_id);
2515: WHEN OTHERS THEN
2516: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
2517: fnd_log.STRING(fnd_log.level_unexpected
2518: , 'cn.plsql.cn_proc_batches_pkg.conc_dispatch.exception', SQLERRM);
2519: END IF;
2520:
2521: fnd_file.put_line(fnd_file.LOG, 'unexpected exception in cn_proc_batches_pkg.conc_dispatch');
2522: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.conc_dispatch:');
2517: fnd_log.STRING(fnd_log.level_unexpected
2518: , 'cn.plsql.cn_proc_batches_pkg.conc_dispatch.exception', SQLERRM);
2519: END IF;
2520:
2521: fnd_file.put_line(fnd_file.LOG, 'unexpected exception in cn_proc_batches_pkg.conc_dispatch');
2522: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.conc_dispatch:');
2523: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
2524: RAISE;
2525: END conc_dispatch;
2518: , 'cn.plsql.cn_proc_batches_pkg.conc_dispatch.exception', SQLERRM);
2519: END IF;
2520:
2521: fnd_file.put_line(fnd_file.LOG, 'unexpected exception in cn_proc_batches_pkg.conc_dispatch');
2522: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.conc_dispatch:');
2523: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
2524: RAISE;
2525: END conc_dispatch;
2526:
2611: BEGIN
2612: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
2613: fnd_log.STRING(
2614: fnd_log.level_procedure
2615: , 'cn.plsql.cn_proc_batches_pkg.conc_dispatch2.begin'
2616: , 'Beginning of conc_dispatch2...'
2617: );
2618: END IF;
2619:
2726:
2727: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
2728: fnd_log.STRING(
2729: fnd_log.level_unexpected
2730: , 'cn.plsql.cn_proc_batches_pkg.conc_dispatch2.request_status'
2731: , 'Request ' || l_failed_request_id || ' failed (batch_id = ' || l_temp_phys_batch_id
2732: );
2733: END IF;
2734:
2776:
2777: IF (fnd_log.level_error >= fnd_log.g_current_runtime_level) THEN
2778: fnd_log.STRING(
2779: fnd_log.level_error
2780: , 'cn.plsql.cn_proc_batches_pkg.conc_dispatch2.request_status'
2781: , 'Request ' || l_failed_request_id || ' failed (batch_id = '
2782: || l_temp_phys_batch_id
2783: );
2784: END IF;
2923:
2924: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
2925: fnd_log.STRING(
2926: fnd_log.level_procedure
2927: , 'cn.plsql.cn_proc_batches_pkg.conc_dispatch2.end'
2928: , 'End of conc_dispatch.'
2929: );
2930: END IF;
2931: EXCEPTION
2929: );
2930: END IF;
2931: EXCEPTION
2932: WHEN conc_fail THEN
2933: fnd_file.put_line(fnd_file.LOG, 'conc_fail exception in cn_proc_batches_pkg.conc_dispatch');
2934: update_error(l_temp_phys_batch_id);
2935:
2936: -- canceling running/pending requests
2937: IF (l_primary_request_stack.COUNT > 0) THEN
2939: IF (l_primary_request_stack(i) > 0) THEN
2940: IF (fnd_log.level_exception >= fnd_log.g_current_runtime_level) THEN
2941: fnd_log.STRING(
2942: fnd_log.level_exception
2943: , 'cn.plsql.cn_proc_batches_pkg.conc_dispatch2.exception'
2944: , 'Cancelling request: ' || l_primary_request_stack(i)
2945: );
2946: END IF;
2947:
2960: WHEN OTHERS THEN
2961: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
2962: fnd_log.STRING(
2963: fnd_log.level_unexpected
2964: , 'cn.plsql.cn_proc_batches_pkg.conc_dispatch2.exception'
2965: , SQLERRM
2966: );
2967: END IF;
2968:
2965: , SQLERRM
2966: );
2967: END IF;
2968:
2969: fnd_file.put_line(fnd_file.LOG, 'unexpected exception in cn_proc_batches_pkg.conc_dispatch');
2970: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.conc_dispatch2:');
2971: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
2972: RAISE;
2973: END conc_dispatch2;
2966: );
2967: END IF;
2968:
2969: fnd_file.put_line(fnd_file.LOG, 'unexpected exception in cn_proc_batches_pkg.conc_dispatch');
2970: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.conc_dispatch2:');
2971: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
2972: RAISE;
2973: END conc_dispatch2;
2974:
2998: BEGIN
2999: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
3000: fnd_log.STRING(
3001: fnd_log.level_procedure
3002: , 'cn.plsql.cn_proc_batches_pkg.seq_dispatch.begin'
3003: , 'Beginning of seq_dispatch...'
3004: );
3005: END IF;
3006:
3054:
3055: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
3056: fnd_log.STRING(
3057: fnd_log.level_procedure
3058: , 'cn.plsql.cn_proc_batches_pkg.seq_dispatch.end'
3059: , 'End of seq_dispatch.'
3060: );
3061: END IF;
3062: EXCEPTION
3062: EXCEPTION
3063: WHEN OTHERS THEN
3064: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
3065: fnd_log.STRING(fnd_log.level_unexpected
3066: , 'cn.plsql.cn_proc_batches_pkg.seq_dispatch.exception', SQLERRM);
3067: END IF;
3068:
3069: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches.seq_dispatch:');
3070: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
3089:
3090: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
3091: fnd_log.STRING(
3092: fnd_log.level_procedure
3093: , 'cn.plsql.cn_proc_batches_pkg.calculate_batch.begin'
3094: , 'Beginning of calculate_batch...'
3095: );
3096: END IF;
3097:
3138:
3139: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
3140: fnd_log.STRING(
3141: fnd_log.level_procedure
3142: , 'cn.plsql.cn_proc_batches_pkg.calculate_batch.end'
3143: , 'End of calculate_batch.'
3144: );
3145: END IF;
3146:
3154:
3155: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
3156: fnd_log.STRING(
3157: fnd_log.level_unexpected
3158: , 'cn.plsql.cn_proc_batches_pkg.calculate_batch.exception'
3159: , SQLERRM
3160: );
3161: END IF;
3162:
3210: BEGIN
3211: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
3212: fnd_log.STRING(
3213: fnd_log.level_procedure
3214: , 'cn.plsql.cn_proc_batches_pkg.calc.begin'
3215: , 'Beginning of concurrent program calc ...'
3216: );
3217: END IF;
3218:
3232: , cn_api.get_lkup_meaning('NAME', 'CALC_SUBMISSION_OBJECT_TYPE'));
3233: fnd_file.put_line(fnd_file.LOG, fnd_message.get);
3234:
3235: IF (fnd_log.level_error >= fnd_log.g_current_runtime_level) THEN
3236: fnd_log.MESSAGE(fnd_log.level_error, 'cn.plsql.cn_proc_batches_pkg.calc.validation', TRUE);
3237: END IF;
3238:
3239: RAISE ABORT;
3240: END IF;
3246: fnd_message.set_name('CN', 'CN_INVALID_DATE_RANGE');
3247: fnd_file.put_line(fnd_file.LOG, fnd_message.get);
3248:
3249: IF (fnd_log.level_error >= fnd_log.g_current_runtime_level) THEN
3250: fnd_log.MESSAGE(fnd_log.level_error, 'cn.plsql.cn_proc_batches_pkg.calc.validation', TRUE);
3251: END IF;
3252:
3253: RAISE ABORT;
3254: ELSE
3260: fnd_message.set_token('DATE', p_start_date);
3261: fnd_file.put_line(fnd_file.LOG, fnd_message.get);
3262:
3263: IF (fnd_log.level_error >= fnd_log.g_current_runtime_level) THEN
3264: fnd_log.MESSAGE(fnd_log.level_error, 'cn.plsql.cn_proc_batches_pkg.calc.validation', TRUE);
3265: END IF;
3266:
3267: RAISE ABORT;
3268: END IF;
3277: fnd_message.set_token('DATE', p_end_date);
3278: fnd_file.put_line(fnd_file.LOG, fnd_message.get);
3279:
3280: IF (fnd_log.level_error >= fnd_log.g_current_runtime_level) THEN
3281: fnd_log.MESSAGE(fnd_log.level_error, 'cn.plsql.cn_proc_batches_pkg.calc.validation'
3282: , TRUE);
3283: END IF;
3284:
3285: RAISE ABORT;
3292: fnd_message.set_name('CN', 'CN_CALC_NO_SALESREP');
3293: fnd_file.put_line(fnd_file.LOG, fnd_message.get);
3294:
3295: IF (fnd_log.level_error >= fnd_log.g_current_runtime_level) THEN
3296: fnd_log.MESSAGE(fnd_log.level_error, 'cn.plsql.cn_proc_batches_pkg.calc.validation', TRUE);
3297: END IF;
3298:
3299: RAISE ABORT;
3300: END IF;
3335:
3336: IF (fnd_log.level_event >= fnd_log.g_current_runtime_level) THEN
3337: fnd_log.STRING(
3338: fnd_log.level_event
3339: , 'cn.plsql.cn_proc_batches_pkg.calc.submission'
3340: , 'Successfully created submission records.'
3341: );
3342: END IF;
3343:
3360:
3361: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
3362: fnd_log.STRING(
3363: fnd_log.level_procedure
3364: , 'cn.plsql.cn_proc_batches_pkg.calc.end'
3365: , 'End of concurrent program calc.'
3366: );
3367: END IF;
3368: EXCEPTION
3429: ) IS
3430: dummy NUMBER;
3431: dummy_char VARCHAR2(30);
3432: BEGIN
3433: cn_proc_batches_pkg.main(
3434: p_concurrent_flag => 'Y'
3435: , p_process_name => 'COLLECTION'
3436: , p_logical_batch_id => NULL
3437: , p_start_date => p_start_date
3484: BEGIN
3485: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
3486: fnd_log.STRING(
3487: fnd_log.level_procedure
3488: , 'cn.plsql.cn_proc_batches_pkg.runner.begin'
3489: , 'Beginning of batch runner '
3490: || p_physical_batch_id
3491: || ' in the phase of '
3492: || p_physical_process
3518: cn_message_pkg.DEBUG(
3519: 'Start batch runner (phase=' || p_physical_process || ', batch ID=' || p_physical_batch_id
3520: || ')'
3521: );
3522: cn_proc_batches_pkg.process_status(
3523: x_physical_process => p_physical_process
3524: , x_curr_status => l_curr_status
3525: , x_new_status => l_new_status
3526: );
3680:
3681: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
3682: fnd_log.STRING(
3683: fnd_log.level_procedure
3684: , 'cn.plsql.cn_proc_batches_pkg.runner.end'
3685: , 'End of batch runner '
3686: || p_physical_batch_id
3687: || 'at '
3688: || TO_CHAR(SYSDATE, 'DD-MON-YY HH24:MI:SS')
3732: COMMIT;
3733: END IF;
3734:
3735: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
3736: fnd_log.STRING(fnd_log.level_unexpected, 'cn.plsql.cn_proc_batches_pkg.runner.exception'
3737: , SQLERRM);
3738: END IF;
3739: END runner;
3740:
3851:
3852: IF (fnd_log.level_error >= fnd_log.g_current_runtime_level) THEN
3853: fnd_log.MESSAGE(
3854: fnd_log.level_error
3855: , 'cn.plsql.cn_proc_batches_pkg.validate_ruleset_status.validation'
3856: , TRUE
3857: );
3858: END IF;
3859:
3975: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'COMPLETE');
3976: fnd_message.set_name('CN', 'ALL_PROCESS_DONE_OK');
3977:
3978: IF (fnd_log.level_event >= fnd_log.g_current_runtime_level) THEN
3979: fnd_log.MESSAGE(fnd_log.level_event, 'cn.plsql.cn_proc_batches_pkg.processor.event'
3980: , TRUE);
3981: END IF;
3982: EXCEPTION
3983: WHEN NO_DATA_FOUND THEN
3987: fnd_message.set_name('CN', 'ALL_PROCESS_DONE_FAIL');
3988:
3989: IF (fnd_log.level_error >= fnd_log.g_current_runtime_level) THEN
3990: fnd_log.MESSAGE(fnd_log.level_error
3991: , 'cn.plsql.cn_proc_batches_pkg.processor.exception', TRUE);
3992: END IF;
3993: END;
3994:
3995: -- Mark the processed batches for deletion
4001: EXCEPTION
4002: WHEN OTHERS THEN
4003: retcode := 2;
4004: errbuf := SQLERRM;
4005: fnd_file.put_line(fnd_file.LOG, 'Unexpected exception in cn_proc_batches_pkg.processor');
4006: fnd_file.put_line(fnd_file.LOG, SQLERRM);
4007: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.processor:');
4008: cn_message_pkg.rollback_errormsg_commit(errbuf);
4009: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'FAILED');
4003: retcode := 2;
4004: errbuf := SQLERRM;
4005: fnd_file.put_line(fnd_file.LOG, 'Unexpected exception in cn_proc_batches_pkg.processor');
4006: fnd_file.put_line(fnd_file.LOG, SQLERRM);
4007: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.processor:');
4008: cn_message_pkg.rollback_errormsg_commit(errbuf);
4009: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'FAILED');
4010: cn_message_pkg.end_batch(l_paid);
4011:
4010: cn_message_pkg.end_batch(l_paid);
4011:
4012: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
4013: fnd_log.STRING(fnd_log.level_unexpected
4014: , 'cn.plsql.cn_proc_batches_pkg.processor.exception', SQLERRM);
4015: END IF;
4016:
4017: RAISE;
4018: END processor;
4064: BEGIN
4065: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
4066: fnd_log.STRING(
4067: fnd_log.level_procedure
4068: , 'cn.plsql.cn_proc_batches_pkg.main.begin'
4069: , 'Beginning of cn_proc_batches_pkg.main...'
4070: );
4071: END IF;
4072:
4065: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
4066: fnd_log.STRING(
4067: fnd_log.level_procedure
4068: , 'cn.plsql.cn_proc_batches_pkg.main.begin'
4069: , 'Beginning of cn_proc_batches_pkg.main...'
4070: );
4071: END IF;
4072:
4073: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'PROCESSING');
4099: RAISE ABORT;
4100: END IF;
4101: ELSE
4102: fnd_file.put_line(fnd_file.LOG
4103: , 'cn_proc_batches_pkg.main: bad process name: ' || p_process_name);
4104: cn_message_pkg.DEBUG('Invalid process code (' || p_process_name || ')');
4105: RAISE ABORT;
4106: END IF;
4107:
4113:
4114: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
4115: fnd_log.STRING(
4116: fnd_log.level_procedure
4117: , 'cn.plsql.cn_proc_batches_pkg.main.run_processor'
4118: , 'Before calling procedure processor.'
4119: );
4120: END IF;
4121:
4120: END IF;
4121:
4122: IF (p_concurrent_flag = 'N' OR(p_concurrent_flag = 'Y' AND fnd_global.conc_program_id <> -1)) THEN
4123: cn_message_pkg.DEBUG('Start processing transactions (non concurrent calculation)');
4124: cn_proc_batches_pkg.processor(
4125: l_dummy
4126: , l_temp
4127: , x_process_audit_id
4128: , p_concurrent_flag
4183: );
4184:
4185: IF l_request_id = 0 THEN
4186: fnd_file.put_line(fnd_file.LOG
4187: , 'cn_proc_batches_pkg.main: unable to submit batch_processor');
4188: cn_message_pkg.DEBUG('Failed to submit concurrent request (Batch Processor)');
4189: cn_message_pkg.DEBUG(fnd_message.get);
4190: x_process_status_code := 'FAIL';
4191:
4191:
4192: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
4193: fnd_log.STRING(
4194: fnd_log.level_unexpected
4195: , 'cn.plsql.cn_proc_batches_pkg.main.exception'
4196: , 'Failed to submit request for BATCH_PROCESSOR.'
4197: );
4198: END IF;
4199:
4213:
4214: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
4215: fnd_log.STRING(
4216: fnd_log.level_procedure
4217: , 'cn.plsql.cn_proc_batches_pkg.main.run_processor'
4218: , 'After calling procedure processor.'
4219: );
4220: END IF;
4221:
4221:
4222: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
4223: fnd_log.STRING(
4224: fnd_log.level_procedure
4225: , 'cn.plsql.cn_proc_batches_pkg.main.end'
4226: , 'End of cn_proc_batches_pkg.main...'
4227: );
4228: END IF;
4229: EXCEPTION
4222: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
4223: fnd_log.STRING(
4224: fnd_log.level_procedure
4225: , 'cn.plsql.cn_proc_batches_pkg.main.end'
4226: , 'End of cn_proc_batches_pkg.main...'
4227: );
4228: END IF;
4229: EXCEPTION
4230: WHEN ABORT THEN
4227: );
4228: END IF;
4229: EXCEPTION
4230: WHEN ABORT THEN
4231: cn_message_pkg.rollback_errormsg_commit('Exception occurs in cn_proc_batches_pkg.main.');
4232: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'FAILED');
4233: COMMIT;
4234: x_process_status_code := 'FAIL';
4235: fnd_file.put_line(fnd_file.LOG, fnd_message.get);
4234: x_process_status_code := 'FAIL';
4235: fnd_file.put_line(fnd_file.LOG, fnd_message.get);
4236: cn_message_pkg.end_batch(x_process_audit_id);
4237: WHEN OTHERS THEN
4238: fnd_file.put_line(fnd_file.LOG, 'unexpected exception in cn_proc_batches_pkg.main');
4239: fnd_file.put_line(fnd_file.LOG, SQLERRM);
4240: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.main: ');
4241: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
4242: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'FAILED');
4236: cn_message_pkg.end_batch(x_process_audit_id);
4237: WHEN OTHERS THEN
4238: fnd_file.put_line(fnd_file.LOG, 'unexpected exception in cn_proc_batches_pkg.main');
4239: fnd_file.put_line(fnd_file.LOG, SQLERRM);
4240: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.main: ');
4241: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
4242: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'FAILED');
4243: COMMIT;
4244: x_process_status_code := 'FAIL';
4245: --cn_message_pkg.set_name('CN','ALL_PROCESS_DONE_FAIL');
4246: cn_message_pkg.end_batch(x_process_audit_id);
4247:
4248: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
4249: fnd_log.STRING(fnd_log.level_unexpected, 'cn.plsql.cn_proc_batches_pkg.main.exception'
4250: , SQLERRM);
4251: END IF;
4252: END main;
4253:
4628: BEGIN
4629: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
4630: fnd_log.STRING(
4631: fnd_log.level_procedure
4632: , 'cn.plsql.cn_proc_batches_pkg.populate_bonus_process_batch.begin'
4633: , 'Beginning of poulate_bonus_process_batch ...'
4634: );
4635: END IF;
4636:
4865:
4866: IF (fnd_log.level_exception >= fnd_log.g_current_runtime_level) THEN
4867: fnd_log.MESSAGE(
4868: fnd_log.level_exception
4869: , 'cn.plsql.cn_proc_batches_pkg.populate_bonus_process_batch.error'
4870: , TRUE
4871: );
4872: END IF;
4873:
4876:
4877: IF (fnd_log.level_procedure >= fnd_log.g_current_runtime_level) THEN
4878: fnd_log.STRING(
4879: fnd_log.level_procedure
4880: , 'cn.plsql.cn_proc_batches_pkg.populate_bonus_process_batch.end'
4881: , 'Beginning of poulate_bonus_process_batch ...'
4882: );
4883: END IF;
4884: EXCEPTION
4882: );
4883: END IF;
4884: EXCEPTION
4885: WHEN no_comm_lines THEN
4886: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.populate_bonus_process_batch:');
4887: cn_message_pkg.rollback_errormsg_commit
4888: (
4889: 'No one with complete compensation plan to calculate or the period specified is not at the end of the plan element interval'
4890: );
4890: );
4891: fnd_file.put_line
4892: (
4893: fnd_file.LOG
4894: , 'Exception in cn_proc_batches_pkg.populate_bonus_process_batch: no one with complete '
4895: || 'compensation plan or the period specified is not at the end of the interval'
4896: );
4897: RAISE;
4898: WHEN OTHERS THEN
4898: WHEN OTHERS THEN
4899: IF (fnd_log.level_unexpected >= fnd_log.g_current_runtime_level) THEN
4900: fnd_log.STRING(
4901: fnd_log.level_unexpected
4902: , 'cn.plsql.cn_proc_batches_pkg.populate_bonus_process_batch.exception'
4903: , SQLERRM
4904: );
4905: END IF;
4906:
4903: , SQLERRM
4904: );
4905: END IF;
4906:
4907: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.populate_bonus_process_batch: ');
4908: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
4909: fnd_file.put_line(fnd_file.LOG
4910: , 'Exception in cn_proc_batches_pkg.populate_bonus_process_batch: ' || SQLERRM);
4911: RAISE;
4906:
4907: cn_message_pkg.DEBUG('Exception occurs in cn_proc_batches_pkg.populate_bonus_process_batch: ');
4908: cn_message_pkg.rollback_errormsg_commit(SQLERRM);
4909: fnd_file.put_line(fnd_file.LOG
4910: , 'Exception in cn_proc_batches_pkg.populate_bonus_process_batch: ' || SQLERRM);
4911: RAISE;
4912: END populate_bonus_process_batch;
4913: END cn_proc_batches_pkg;
4909: fnd_file.put_line(fnd_file.LOG
4910: , 'Exception in cn_proc_batches_pkg.populate_bonus_process_batch: ' || SQLERRM);
4911: RAISE;
4912: END populate_bonus_process_batch;
4913: END cn_proc_batches_pkg;