690: AND start_date = p_start_date
691: AND end_date = p_end_date);
692: EXCEPTION
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
691: AND end_date = p_end_date);
692: EXCEPTION
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: );
692: EXCEPTION
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;
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(
787: fnd_log.level_unexpected
788: , 'cn.plsql.cn_proc_batches_pkg.populate_calcsub_batches.exception'
789: , 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(
787: fnd_log.level_unexpected
788: , 'cn.plsql.cn_proc_batches_pkg.populate_calcsub_batches.exception'
789: , SQLERRM
790: );
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(
787: fnd_log.level_unexpected
788: , 'cn.plsql.cn_proc_batches_pkg.populate_calcsub_batches.exception'
789: , SQLERRM
790: );
791: END IF;
1106: RETURN TRUE;
1107: END IF;
1108: EXCEPTION
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
1107: END IF;
1108: EXCEPTION
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: );
1108: EXCEPTION
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;
1244:
1245: IF l_counter = 0 THEN /* no one to be calculated */
1246: fnd_message.set_name('CN', 'CNSBCS_NO_ONE_TO_CALCULATE');
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
1245: IF l_counter = 0 THEN /* no one to be calculated */
1246: fnd_message.set_name('CN', 'CNSBCS_NO_ONE_TO_CALCULATE');
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: );
1246: fnd_message.set_name('CN', 'CNSBCS_NO_ONE_TO_CALCULATE');
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;
1340:
1341: IF l_counter = 0 THEN /* no one to be calculated */
1342: fnd_message.set_name('CN', 'CNSBCS_NO_ONE_TO_CALCULATE');
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
1341: IF l_counter = 0 THEN /* no one to be calculated */
1342: fnd_message.set_name('CN', 'CNSBCS_NO_ONE_TO_CALCULATE');
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: );
1342: fnd_message.set_name('CN', 'CNSBCS_NO_ONE_TO_CALCULATE');
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;
1532: --fnd_message.set_name('CN', 'CNSBCS_NO_ONE_IN_NOTIFY_LOG');
1533: --raise no_one_with_complete_plan;
1534: -- clku, bug 2783261, we won;t error out if we do not find any reps in
1535: -- notify log, we just set status to complete and return
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'
1533: --raise no_one_with_complete_plan;
1534: -- clku, bug 2783261, we won;t error out if we do not find any reps in
1535: -- notify log, we just set status to complete and return
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 ...'
1535: -- notify log, we just set status to complete and return
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;
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
1566: , 'cn.plsql.cn_proc_batches_pkg.populate_process_batch.exception'
1567: , SQLERRM
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
1566: , 'cn.plsql.cn_proc_batches_pkg.populate_process_batch.exception'
1567: , SQLERRM
1568: );
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
1566: , 'cn.plsql.cn_proc_batches_pkg.populate_process_batch.exception'
1567: , SQLERRM
1568: );
1569: END IF;
1597:
1598: l_batch_rec l_calc_batch_csr%ROWTYPE;
1599: l_status cn_calc_submission_batches.status%TYPE;
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 ...'
1598: l_batch_rec l_calc_batch_csr%ROWTYPE;
1599: l_status cn_calc_submission_batches.status%TYPE;
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: );
1599: l_status cn_calc_submission_batches.status%TYPE;
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;
1680: cn_message_pkg.end_batch(x_process_audit_id);
1681: END IF;
1682: END IF;
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.'
1681: END IF;
1682: END IF;
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: );
1682: END IF;
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;
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:
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
1710: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'FAILED');
1711: COMMIT;
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: );
1711: COMMIT;
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;
1732:
1733: RETURN x_physical_batch_id;
1734: EXCEPTION
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
1733: RETURN x_physical_batch_id;
1734: EXCEPTION
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: );
1734: EXCEPTION
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;
1873: AND LOG.status = 'INCOMPLETE'
1874: AND LOG.action_link_id IS NOT NULL
1875: AND LOG.org_id = batch.org_id;
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 ...'
1874: AND LOG.action_link_id IS NOT NULL
1875: AND LOG.org_id = batch.org_id;
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: );
1875: AND LOG.org_id = batch.org_id;
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;
1956:
1957: IF (reps_tbl.COUNT = 0) THEN
1958: cn_message_pkg.set_name('CN', 'PROC_NO_TRX_TO_PROCESS');
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.'
1957: IF (reps_tbl.COUNT = 0) THEN
1958: cn_message_pkg.set_name('CN', 'PROC_NO_TRX_TO_PROCESS');
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: );
1958: cn_message_pkg.set_name('CN', 'PROC_NO_TRX_TO_PROCESS');
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;
2040: WHERE action_link_id = action_link.action_link_id AND status = 'INCOMPLETE';
2041: END LOOP;
2042: END IF;
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.'
2041: END LOOP;
2042: END IF;
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: );
2042: END IF;
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;
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
2063: fnd_log.STRING(fnd_log.level_unexpected, 'cn.plsql.cn_proc_batches_pkg.assign.exception'
2064: , SQLERRM);
2065: END IF;
2066:
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);
2115: , argument4 => x_physical_batch_id
2116: );
2117:
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
2116: );
2117:
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: );
2117:
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;
2193: l_end_date DATE;
2194: l_payee_count NUMBER;
2195: l_new_request_submitted BOOLEAN;
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...'
2194: l_payee_count NUMBER;
2195: l_new_request_submitted BOOLEAN;
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: );
2195: l_new_request_submitted BOOLEAN;
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;
2335: IF (NOT l_call_status) THEN
2336: l_failed_request_id := l_primary_request_stack(primary_ptr);
2337: l_temp_phys_batch_id := l_primary_batch_stack(primary_ptr);
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
2336: l_failed_request_id := l_primary_request_stack(primary_ptr);
2337: l_temp_phys_batch_id := l_primary_batch_stack(primary_ptr);
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: );
2337: l_temp_phys_batch_id := l_primary_batch_stack(primary_ptr);
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;
2377:
2378: IF l_dev_status IN('ERROR', 'TERMINATING', 'TERMINATED', 'DELETED') THEN
2379: l_temp_phys_batch_id := l_primary_batch_stack(primary_ptr);
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 = '
2378: IF l_dev_status IN('ERROR', 'TERMINATING', 'TERMINATED', 'DELETED') THEN
2379: l_temp_phys_batch_id := l_primary_batch_stack(primary_ptr);
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
2379: l_temp_phys_batch_id := l_primary_batch_stack(primary_ptr);
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: );
2479: END IF; -- If request_id is null
2480: END LOOP; -- for primary_ptr in 1..x_batch_total
2481: END LOOP; -- while unfinished loop
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.'
2480: END LOOP; -- for primary_ptr in 1..x_batch_total
2481: END LOOP; -- while unfinished loop
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: );
2481: END LOOP; -- while unfinished loop
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;
2495: -- canceling running/pending requests
2496: IF (l_primary_request_stack.COUNT > 0) THEN
2497: FOR i IN l_primary_request_stack.FIRST .. l_primary_request_stack.LAST LOOP
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)
2496: IF (l_primary_request_stack.COUNT > 0) THEN
2497: FOR i IN l_primary_request_stack.FIRST .. l_primary_request_stack.LAST LOOP
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: );
2497: FOR i IN l_primary_request_stack.FIRST .. l_primary_request_stack.LAST LOOP
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;
2512: END IF;
2513:
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:
2513:
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');
2608: FROM cn_process_batches_all
2609: WHERE logical_batch_id = g_logical_batch_id
2610: ORDER BY physical_batch_id DESC;
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...'
2609: WHERE logical_batch_id = g_logical_batch_id
2610: ORDER BY physical_batch_id DESC;
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: );
2610: ORDER BY physical_batch_id DESC;
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;
2723: IF (NOT l_call_status) THEN
2724: l_failed_request_id := l_primary_request_stack(primary_ptr);
2725: l_temp_phys_batch_id := l_primary_batch_stack(primary_ptr);
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
2724: l_failed_request_id := l_primary_request_stack(primary_ptr);
2725: l_temp_phys_batch_id := l_primary_batch_stack(primary_ptr);
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: );
2725: l_temp_phys_batch_id := l_primary_batch_stack(primary_ptr);
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;
2773:
2774: IF l_dev_status IN('ERROR', 'TERMINATING', 'TERMINATED', 'DELETED') THEN
2775: l_temp_phys_batch_id := l_primary_batch_stack(primary_ptr);
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 = '
2774: IF l_dev_status IN('ERROR', 'TERMINATING', 'TERMINATED', 'DELETED') THEN
2775: l_temp_phys_batch_id := l_primary_batch_stack(primary_ptr);
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
2775: l_temp_phys_batch_id := l_primary_batch_stack(primary_ptr);
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: );
2920: END IF;
2921:
2922: END LOOP;
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.'
2921:
2922: END LOOP;
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: );
2922: END LOOP;
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;
2936: -- canceling running/pending requests
2937: IF (l_primary_request_stack.COUNT > 0) THEN
2938: FOR i IN l_primary_request_stack.FIRST .. l_primary_request_stack.LAST LOOP
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)
2937: IF (l_primary_request_stack.COUNT > 0) THEN
2938: FOR i IN l_primary_request_stack.FIRST .. l_primary_request_stack.LAST LOOP
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: );
2938: FOR i IN l_primary_request_stack.FIRST .. l_primary_request_stack.LAST LOOP
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;
2957: cn_message_pkg.DEBUG('Concurrent request failed (physical batch ID=' || l_temp_phys_batch_id
2958: || ')');
2959: cn_message_pkg.end_batch(x_parent_proc_audit_id);
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
2958: || ')');
2959: cn_message_pkg.end_batch(x_parent_proc_audit_id);
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: );
2959: cn_message_pkg.end_batch(x_parent_proc_audit_id);
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;
2995: SELECT COUNT(DISTINCT physical_batch_id)
2996: FROM cn_process_batches_all
2997: WHERE logical_batch_id = g_logical_batch_id AND status_code = 'IN_USE';
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...'
2996: FROM cn_process_batches_all
2997: WHERE logical_batch_id = g_logical_batch_id AND status_code = 'IN_USE';
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: );
2997: WHERE logical_batch_id = g_logical_batch_id AND status_code = 'IN_USE';
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;
3051: finished := TRUE;
3052: END IF;
3053: END LOOP;
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.'
3052: END IF;
3053: END LOOP;
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: );
3053: END LOOP;
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;
3060: );
3061: END IF;
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:
3061: END IF;
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:');
3086: l_org_id NUMBER;
3087: BEGIN
3088: retcode := 0; -- success = 0, warning = 1, fail = 2
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...'
3087: BEGIN
3088: retcode := 0; -- success = 0, warning = 1, fail = 2
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: );
3088: retcode := 0; -- success = 0, warning = 1, fail = 2
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;
3135: retcode := 2;
3136: errbuf := l_msg_data;
3137: END IF;
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.'
3136: errbuf := l_msg_data;
3137: END IF;
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: );
3137: END IF;
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;
3151: WHEN OTHERS THEN
3152: retcode := 2;
3153: errbuf := SQLERRM;
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
3152: retcode := 2;
3153: errbuf := SQLERRM;
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: );
3153: errbuf := SQLERRM;
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;
3207: WHERE NAME = p_batch_name AND org_id = l_org_id);
3208:
3209: l_incomplete_plan BOOLEAN := FALSE;
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 ...'
3208:
3209: l_incomplete_plan BOOLEAN := FALSE;
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: );
3209: l_incomplete_plan BOOLEAN := FALSE;
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;
3231: fnd_message.set_token('BATCH_NAME'
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;
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;
3245: IF p_start_date > p_end_date THEN
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;
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
3259: fnd_message.set_name('CN', 'CN_CALC_SUB_OPEN_DATE');
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;
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;
3276: fnd_message.set_name('CN', 'CN_CALC_SUB_OPEN_DATE');
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:
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;
3291: IF p_salesrep_option = 'USER_SPECIFY' AND p_salesrep_id IS NULL THEN
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;
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;
3332: END IF;
3333:
3334: COMMIT;
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.'
3333:
3334: COMMIT;
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: );
3334: COMMIT;
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;
3357: retcode := 2;
3358: errbuf := 'Calculation fails';
3359: END IF;
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.'
3358: errbuf := 'Calculation fails';
3359: END IF;
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: );
3359: END IF;
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;
3481: l_period_type_id NUMBER;
3482: l_calc_from_period_id NUMBER;
3483: l_calc_to_period_id NUMBER;
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 '
3482: l_calc_from_period_id NUMBER;
3483: l_calc_to_period_id NUMBER;
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
3483: l_calc_to_period_id NUMBER;
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 '
3677:
3678: retcode := 0;
3679: errbuf := 'Batch runner completes successfully.';
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 '
3678: retcode := 0;
3679: errbuf := 'Batch runner completes successfully.';
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
3679: errbuf := 'Batch runner completes successfully.';
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 '
3731: ELSE
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;
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:
3848:
3849: IF l_error_ctr = 1 THEN
3850: fnd_message.set_name('CN', 'PROC_CLS_PKG_MISSING');
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
3849: IF l_error_ctr = 1 THEN
3850: fnd_message.set_name('CN', 'PROC_CLS_PKG_MISSING');
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: );
3850: fnd_message.set_name('CN', 'PROC_CLS_PKG_MISSING');
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;
3974:
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
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
3985: errbuf := 'Completed with error. Please see the log file for details.';
3986: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'FAILED');
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;
3986: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'FAILED');
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:
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:
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:
4009: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'FAILED');
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;
4061: l_dummy VARCHAR2(80);
4062: l_request_id NUMBER;
4063: l_process_audit_id NUMBER(15);
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...'
4062: l_request_id NUMBER;
4063: l_process_audit_id NUMBER(15);
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: );
4063: l_process_audit_id NUMBER(15);
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;
4110: fnd_file.put_line(fnd_file.LOG, fnd_message.get);
4111: RAISE ABORT;
4112: END IF;
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.'
4111: RAISE ABORT;
4112: END IF;
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: );
4112: END IF;
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;
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:
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.'
4189: cn_message_pkg.DEBUG(fnd_message.get);
4190: x_process_status_code := 'FAIL';
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: );
4190: x_process_status_code := 'FAIL';
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;
4210: COMMIT;
4211: END IF;
4212: END IF;
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.'
4211: END IF;
4212: END IF;
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: );
4212: END IF;
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;
4218: , 'After calling procedure processor.'
4219: );
4220: END IF;
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...'
4219: );
4220: END IF;
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: );
4220: END IF;
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;
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;
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:
4625: , org_id
4626: FROM cn_calc_submission_batches_all
4627: WHERE calc_sub_batch_id = p_calc_sub_batch_id;
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 ...'
4626: FROM cn_calc_submission_batches_all
4627: WHERE calc_sub_batch_id = p_calc_sub_batch_id;
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: );
4627: WHERE calc_sub_batch_id = p_calc_sub_batch_id;
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;
4862:
4863: IF l_counter = 0 THEN /* no one to be calculated */
4864: fnd_message.set_name('CN', 'CNSBCS_NO_ONE_TO_BONUS');
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
4863: IF l_counter = 0 THEN /* no one to be calculated */
4864: fnd_message.set_name('CN', 'CNSBCS_NO_ONE_TO_BONUS');
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: );
4864: fnd_message.set_name('CN', 'CNSBCS_NO_ONE_TO_BONUS');
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:
4874: RAISE no_comm_lines;
4875: END IF;
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 ...'
4874: RAISE no_comm_lines;
4875: END IF;
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: );
4875: END IF;
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;
4895: || 'compensation plan or the period specified is not at the end of the interval'
4896: );
4897: RAISE;
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
4896: );
4897: RAISE;
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: );
4897: RAISE;
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;