DBA Data[Home] [Help]

APPS.CN_PROC_BATCHES_PKG dependencies on CN_PROCESS_BATCHES

Line 18: cn_process_batches with all salesrep/periods that are

14: Fixed populate batch proc to prevent duplicate keys
15: 15-JUL-95 P Cook Modified calls to begin batch
16: 01-AUG-95 P Cook Added populate_calcsub_batches
17: 10-AUG-95 P Cook Modified populate_calcsub_batches to populate
18: cn_process_batches with all salesrep/periods that are
19: impacted by running calc on a salesrep.
20: 11-AUG-95 P Cook Revised calcsub to populate correct impacted salesreps
21: 14-AUG-95 P Cook Replace hardcoded trx batch size with system_batch_size
22: 18-AUG-95 P Cook Handle no_data_found in flood routine excep handlers

Line 174: FROM cn_process_batches_all a

170: -- no point joining to periods for the status because it may have
171: -- changed by the time we come to process the records
172: CURSOR physical_batches IS
173: SELECT a.physical_batch_id
174: FROM cn_process_batches_all a
175: , (SELECT MAX(physical_batch_id) physical_batch_id
176: , SUM(sales_lines_total) + 1 rec_total
177: FROM cn_process_batches_all
178: WHERE logical_batch_id = g_logical_batch_id) b

Line 177: FROM cn_process_batches_all

173: SELECT a.physical_batch_id
174: FROM cn_process_batches_all a
175: , (SELECT MAX(physical_batch_id) physical_batch_id
176: , SUM(sales_lines_total) + 1 rec_total
177: FROM cn_process_batches_all
178: WHERE logical_batch_id = g_logical_batch_id) b
179: WHERE a.logical_batch_id = g_logical_batch_id AND a.status_code = 'IN_USE'
180: GROUP BY a.physical_batch_id
181: ORDER BY SUM(DECODE(a.physical_batch_id, b.physical_batch_id, b.rec_total, a.sales_lines_total)) DESC;

Line 185: FROM cn_process_batches_all a

181: ORDER BY SUM(DECODE(a.physical_batch_id, b.physical_batch_id, b.rec_total, a.sales_lines_total)) DESC;
182:
183: CURSOR physical_batches2 IS
184: SELECT a.physical_batch_id
185: FROM cn_process_batches_all a
186: , (SELECT MAX(physical_batch_id) physical_batch_id
187: , SUM(commission_headers_count) + 1 rec_total
188: FROM cn_process_batches_all
189: WHERE logical_batch_id = g_logical_batch_id) b

Line 188: FROM cn_process_batches_all

184: SELECT a.physical_batch_id
185: FROM cn_process_batches_all a
186: , (SELECT MAX(physical_batch_id) physical_batch_id
187: , SUM(commission_headers_count) + 1 rec_total
188: FROM cn_process_batches_all
189: WHERE logical_batch_id = g_logical_batch_id) b
190: WHERE a.logical_batch_id = g_logical_batch_id AND a.status_code = 'IN_USE'
191: GROUP BY a.physical_batch_id
192: ORDER BY SUM(

Line 571: -- insert entry into cn_process_batches for this srp/period and entries of

567:
568: -- Procedure Name
569: -- Populate_calcsub_batches
570: -- Purpose
571: -- insert entry into cn_process_batches for this srp/period and entries of
572: -- all srps below this srp depending on the value of x_entire_hierarchy
573: -- Notes
574: -- 12-Jul-1998, Richard Jin Created
575: -- 05-Jun-1999, Richard Jin Modified 11.5

Line 639: INSERT INTO cn_process_batches_all

635:
636: IF l_descendant_tbl.COUNT > 0 THEN
637: FOR l_counter IN l_descendant_tbl.FIRST .. l_descendant_tbl.LAST LOOP
638: BEGIN
639: INSERT INTO cn_process_batches_all
640: (
641: process_batch_id
642: , logical_batch_id
643: , srp_period_id

Line 662: SELECT cn_process_batches_s1.NEXTVAL

658: , program_id
659: , program_update_date
660: , org_id
661: )
662: SELECT cn_process_batches_s1.NEXTVAL
663: , g_logical_batch_id
664: , 1 /* use a dummy value since this is a not null column */
665: , p_start_period_id
666: , p_end_period_id

Line 685: FROM cn_process_batches_all

681: , g_org_id
682: FROM DUAL
683: WHERE NOT EXISTS(
684: SELECT 1
685: FROM cn_process_batches_all
686: WHERE logical_batch_id = g_logical_batch_id
687: AND salesrep_id = l_descendant_tbl(l_counter).salesrep_id
688: AND period_id = p_start_period_id
689: AND end_period_id = p_end_period_id

Line 715: INSERT INTO cn_process_batches_all

711: -- case1: not entire hierarchy
712: -- only insert the base reps
713: -- case2: entire hierarchy. since get_descendants does not return the base salesrep
714: -- in the list, need to do the insert here.
715: INSERT INTO cn_process_batches_all
716: (
717: process_batch_id
718: , logical_batch_id
719: , srp_period_id

Line 738: SELECT cn_process_batches_s1.NEXTVAL

734: , program_id
735: , program_update_date
736: , org_id
737: )
738: SELECT cn_process_batches_s1.NEXTVAL
739: , g_logical_batch_id
740: , 1 /* use a dummy value since this is a not null column */
741: , p_start_period_id
742: , p_end_period_id

Line 761: FROM cn_process_batches_all

757: , g_org_id
758: FROM DUAL
759: WHERE NOT EXISTS(
760: SELECT 1
761: FROM cn_process_batches_all
762: WHERE logical_batch_id = g_logical_batch_id
763: AND salesrep_id = p_salesrep_id
764: AND period_id = p_start_period_id
765: AND end_period_id = p_end_period_id

Line 826: SELECT cn_process_batches_s2.NEXTVAL

822: END get_calc_sub_periods;
823:
824: PROCEDURE initialize_logical_batch(p_calc_sub_batch_id NUMBER) IS
825: BEGIN
826: SELECT cn_process_batches_s2.NEXTVAL
827: INTO g_logical_batch_id
828: FROM DUAL;
829:
830: UPDATE cn_calc_submission_batches_all

Line 1124: -- populate the cn_process_batches for an entry in cn_calc_submission_batches

1120:
1121: -- Procedure Name
1122: -- Populate_process_batches
1123: -- Purpose
1124: -- populate the cn_process_batches for an entry in cn_calc_submission_batches
1125: -- Notes
1126: -- 12-Jul-1998, Richard Jin Created
1127: -- 19-Sep-2002, Arvind Krishnan BUG:2509788 - Improved the performance of query in l_all_reps_csr
1128: PROCEDURE populate_process_batch(p_calc_sub_batch_id NUMBER) IS

Line 1636: DELETE cn_process_batches_all

1632: (l_batch_rec.status = 'FAILED' AND l_batch_rec.concurrent_flag = 'N')
1633: OR g_calc_type = 'BONUS'
1634: ) THEN
1635: -- purge the previous run from cn_process_batch before restart as a new logical batch
1636: DELETE cn_process_batches_all
1637: WHERE logical_batch_id = l_batch_rec.logical_batch_id;
1638: END IF;
1639:
1640: IF (

Line 1729: SELECT cn_process_batches_s3.NEXTVAL

1725: FUNCTION get_physical_batch_id
1726: RETURN NUMBER IS
1727: x_physical_batch_id NUMBER;
1728: BEGIN
1729: SELECT cn_process_batches_s3.NEXTVAL
1730: INTO x_physical_batch_id
1731: FROM SYS.DUAL;
1732:
1733: RETURN x_physical_batch_id;

Line 1765: UPDATE cn_process_batches_all

1761: l_conc_request_id NUMBER(15) := fnd_global.conc_request_id;
1762: l_prog_appl_id NUMBER(15) := fnd_global.prog_appl_id;
1763: BEGIN
1764: IF x_physical_batch_id IS NULL THEN
1765: UPDATE cn_process_batches_all
1766: SET status_code = 'VOID'
1767: , last_update_date = SYSDATE
1768: , last_update_login = l_login_id
1769: , last_updated_by = l_user_id

Line 1776: UPDATE cn_process_batches_all

1772: , program_id = l_conc_prog_id
1773: , program_update_date = SYSDATE
1774: WHERE logical_batch_id = g_logical_batch_id;
1775: ELSE
1776: UPDATE cn_process_batches_all
1777: SET status_code = 'VOID'
1778: , last_update_date = SYSDATE
1779: , last_update_login = l_login_id
1780: , last_updated_by = l_user_id

Line 1851: FROM cn_process_batches

1847:
1848: CURSOR reps IS
1849: SELECT salesrep_id
1850: , DECODE(sales_lines_total, 0, commission_headers_count, sales_lines_total)
1851: FROM cn_process_batches
1852: WHERE logical_batch_id = g_logical_batch_id AND status_code = 'IN_USE'
1853: ORDER BY salesrep_id DESC;
1854:
1855: CURSOR rep_lines_info(p_salesrep_id NUMBER) IS

Line 1857: FROM cn_commission_lines_all line, cn_process_batches_all batch

1853: ORDER BY salesrep_id DESC;
1854:
1855: CURSOR rep_lines_info(p_salesrep_id NUMBER) IS
1856: SELECT COUNT(1)
1857: FROM cn_commission_lines_all line, cn_process_batches_all batch
1858: WHERE batch.logical_batch_id = g_logical_batch_id
1859: AND batch.salesrep_id = p_salesrep_id
1860: AND batch.status_code = 'IN_USE'
1861: AND line.credited_salesrep_id = p_salesrep_id

Line 1868: FROM cn_process_batches_all batch, cn_notify_log_all LOG

1864: AND line.org_id = batch.org_id;
1865:
1866: CURSOR action_links IS
1867: SELECT DISTINCT action_link_id
1868: FROM cn_process_batches_all batch, cn_notify_log_all LOG
1869: WHERE batch.logical_batch_id = g_logical_batch_id
1870: AND batch.status_code = 'IN_USE'
1871: AND LOG.salesrep_id = batch.salesrep_id
1872: AND LOG.period_id BETWEEN batch.period_id AND batch.end_period_id

Line 1902: UPDATE cn_process_batches_all a

1898: CLOSE pre_batch_info;
1899: END IF;
1900:
1901: IF ((l_pre_logical_batch_id IS NOT NULL) AND(l_srp_batch_size_flag <> 'Y')) THEN
1902: UPDATE cn_process_batches_all a
1903: SET (a.sales_lines_total, a.commission_headers_count) =
1904: (SELECT sales_lines_total
1905: , commission_headers_count
1906: FROM cn_process_batches_all

Line 1906: FROM cn_process_batches_all

1902: UPDATE cn_process_batches_all a
1903: SET (a.sales_lines_total, a.commission_headers_count) =
1904: (SELECT sales_lines_total
1905: , commission_headers_count
1906: FROM cn_process_batches_all
1907: WHERE logical_batch_id = l_pre_logical_batch_id AND salesrep_id = a.salesrep_id)
1908: WHERE logical_batch_id = g_logical_batch_id;
1909:
1910: UPDATE cn_process_batches_all a

Line 1910: UPDATE cn_process_batches_all a

1906: FROM cn_process_batches_all
1907: WHERE logical_batch_id = l_pre_logical_batch_id AND salesrep_id = a.salesrep_id)
1908: WHERE logical_batch_id = g_logical_batch_id;
1909:
1910: UPDATE cn_process_batches_all a
1911: SET a.sales_lines_total =
1912: (SELECT COUNT(1)
1913: FROM cn_commission_lines_all
1914: WHERE credited_salesrep_id = a.salesrep_id

Line 1931: UPDATE cn_process_batches_all a

1927: OPEN reps;
1928: FETCH reps BULK COLLECT INTO reps_tbl, nums_tbl;
1929: CLOSE reps;
1930: ELSIF((l_batch_info.calc_type = 'COMMISSION') AND(l_srp_batch_size_flag <> 'Y')) THEN
1931: UPDATE cn_process_batches_all a
1932: SET a.sales_lines_total =
1933: (SELECT COUNT(1)
1934: FROM cn_commission_lines_all
1935: WHERE credited_salesrep_id = a.salesrep_id

Line 2017: UPDATE cn_process_batches_all

2013: END LOOP;
2014: END IF;
2015:
2016: FORALL i IN reps_tbl.FIRST .. reps_tbl.LAST
2017: UPDATE cn_process_batches_all
2018: SET physical_batch_id = bids_tbl(i)
2019: ,
2020: --sales_lines_total = nums_tbl(i),
2021: last_update_date = SYSDATE

Line 2083: UPDATE cn_process_batches_all

2079: l_prog_appl_id NUMBER(15) := fnd_global.prog_appl_id;
2080: BEGIN
2081: -- Giving the batch an 'ERROR' status prevents subsequent
2082: -- physical processes picking it up.
2083: UPDATE cn_process_batches_all
2084: SET status_code = 'ERROR'
2085: , last_update_date = SYSDATE
2086: , last_update_login = l_login_id
2087: , last_updated_by = l_user_id

Line 2260: UPDATE cn_process_batches_all

2256: END IF;
2257: END LOOP;
2258: l_new_request_submitted := TRUE;
2259:
2260: UPDATE cn_process_batches_all
2261: SET trx_batch_id = l_primary_batch_stack(x_batch_total)
2262: WHERE physical_batch_id = l_primary_batch_stack(x_batch_total);
2263:
2264: COMMIT;

Line 2593: FROM cn_process_batches

2589: AND fcr.phase_code = 'C'
2590: AND fcr.status_code <> 'C'
2591: AND EXISTS(
2592: SELECT 1
2593: FROM cn_process_batches
2594: WHERE logical_batch_id = g_logical_batch_id
2595: AND physical_batch_id = fcr.argument4);
2596:
2597: CURSOR success_phase(p_physical_batch_id NUMBER) IS

Line 2608: FROM cn_process_batches_all

2604: ORDER BY request_id DESC;
2605:
2606: CURSOR physical_batches IS
2607: SELECT DISTINCT physical_batch_id
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

Line 2675: UPDATE cn_process_batches_all

2671: l_completed_calculate_count := l_completed_calculate_count + 1;
2672: END IF;
2673: END LOOP;
2674:
2675: UPDATE cn_process_batches_all
2676: SET trx_batch_id = l_primary_batch_stack(g_batch_total)
2677: WHERE physical_batch_id = l_primary_batch_stack(g_batch_total);
2678:
2679: COMMIT;

Line 2996: FROM cn_process_batches_all

2992: g_batch_total NUMBER;
2993:
2994: CURSOR bc IS
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(

Line 3032: UPDATE cn_process_batches_all

3028: IF (l_curr_process = g_calculation) THEN
3029: l_count := l_count + 1;
3030:
3031: IF (l_count = g_batch_total) THEN
3032: UPDATE cn_process_batches_all
3033: SET trx_batch_id = physical_rec.physical_batch_id
3034: WHERE physical_batch_id = physical_rec.physical_batch_id;
3035:
3036: COMMIT;

Line 3504: FROM cn_process_batches_all

3500: , 'Inside batch runner: ' || TO_CHAR(SYSDATE, 'DD-MON-YY HH24:MI:SS'));
3501:
3502: SELECT org_id
3503: INTO l_org_id
3504: FROM cn_process_batches_all
3505: WHERE physical_batch_id = p_physical_batch_id AND ROWNUM = 1;
3506:
3507: l_request_id := fnd_global.conc_request_id;
3508:

Line 3644: FROM cn_process_batches_all

3640: SELECT MAX(period_id)
3641: , MAX(end_period_id)
3642: INTO l_calc_from_period_id
3643: , l_calc_to_period_id
3644: FROM cn_process_batches_all
3645: WHERE physical_batch_id = p_physical_batch_id;
3646:
3647: UPDATE cn_srp_intel_periods_all
3648: SET processing_status_code =

Line 3661: FROM cn_process_batches_all batch, cn_period_statuses_all per

3657: )
3658: WHERE (salesrep_id, period_id) IN(
3659: SELECT batch.salesrep_id
3660: , per.period_id
3661: FROM cn_process_batches_all batch, cn_period_statuses_all per
3662: WHERE batch.physical_batch_id = p_physical_batch_id
3663: AND per.period_id BETWEEN batch.period_id AND batch.end_period_id
3664: AND per.org_id = batch.org_id
3665: AND per.period_id BETWEEN l_calc_from_period_id AND l_calc_to_period_id

Line 3938: FROM cn_process_batches_all

3934: -- Group the srp periods into physical batches
3935: BEGIN
3936: SELECT physical_batch_id
3937: INTO l_temp
3938: FROM cn_process_batches_all
3939: WHERE logical_batch_id = g_logical_batch_id AND ROWNUM = 1;
3940: EXCEPTION
3941: WHEN OTHERS THEN
3942: l_temp := -1;

Line 3973: FROM cn_process_batches_all

3969: SELECT 1
3970: INTO l_temp
3971: FROM SYS.DUAL
3972: WHERE NOT EXISTS(SELECT 1
3973: FROM cn_process_batches_all
3974: WHERE logical_batch_id = p_logical_batch_id AND status_code = 'ERROR');
3975:
3976: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'COMPLETE');
3977: fnd_message.set_name('CN', 'ALL_PROCESS_DONE_OK');

Line 4147: FROM cn_process_batches_all

4143: SELECT 1
4144: INTO l_temp
4145: FROM SYS.DUAL
4146: WHERE NOT EXISTS(SELECT 1
4147: FROM cn_process_batches_all
4148: WHERE logical_batch_id = p_logical_batch_id AND status_code = 'ERROR');
4149:
4150: cn_calc_sub_batches_pkg.update_calc_sub_batch(g_logical_batch_id, 'COMPLETE');
4151: x_process_status_code := 'SUCCESS';