DBA Data[Home] [Help]

APPS.CN_TRANSACTION_LOAD_PKG dependencies on CN_PROCESS_BATCHES

Line 49: SELECT cn_process_batches_s3.NEXTVAL

45: RETURN NUMBER IS
46: x_physical_batch_id NUMBER;
47: BEGIN
48: -- sequence s3 is for physical batch id
49: SELECT cn_process_batches_s3.NEXTVAL
50: INTO x_physical_batch_id
51: FROM SYS.DUAL;
52:
53: RETURN x_physical_batch_id;

Line 83: UPDATE cn_process_batches

79: || p_logical_batch_id
80: );
81:
82: IF p_physical_batch_id IS NULL THEN
83: UPDATE cn_process_batches
84: SET status_code = 'VOID'
85: , last_update_date = SYSDATE
86: , last_update_login = l_login_id
87: , last_updated_by = l_user_id

Line 94: UPDATE cn_process_batches

90: , program_id = l_conc_prog_id
91: , program_update_date = SYSDATE
92: WHERE logical_batch_id = p_logical_batch_id;
93: ELSE
94: UPDATE cn_process_batches
95: SET status_code = 'VOID'
96: , last_update_date = SYSDATE
97: , last_update_login = l_login_id
98: , last_updated_by = l_user_id

Line 116: --+ populate the physical_batch_id in cn_process_batches

112:
113: --+ Procedure Name
114: --+ Assign
115: --+ Purpose : Split the logical batch into smaller physical batches
116: --+ populate the physical_batch_id in cn_process_batches
117: PROCEDURE assign(p_logical_batch_id NUMBER, p_org_id NUMBER) IS
118: x_physical_batch_id NUMBER;
119: l_srp_trx_count NUMBER := 0;
120: l_trx_count NUMBER := 0; -- number of trx in current physical batch

Line 132: FROM cn_process_batches

128:
129: CURSOR logical_batches IS
130: SELECT salesrep_id
131: , SUM(sales_lines_total) srp_trx_count
132: FROM cn_process_batches
133: WHERE logical_batch_id = p_logical_batch_id AND status_code = 'IN_USE'
134: GROUP BY salesrep_id
135: ORDER BY salesrep_id DESC;
136:

Line 201: UPDATE cn_process_batches

197: || ' and # of trx : '
198: || l_srp_trx_count
199: );
200:
201: UPDATE cn_process_batches
202: SET physical_batch_id = x_physical_batch_id
203: , last_update_date = SYSDATE
204: , last_update_login = l_login_id
205: , last_updated_by = l_user_id

Line 270: UPDATE cn_process_batches

266: l_prog_appl_id NUMBER(15) := fnd_global.prog_appl_id;
267: BEGIN
268: -- Giving the batch an 'ERROR' status prevents subsequent
269: -- physical processes picking it up.
270: UPDATE cn_process_batches
271: SET status_code = 'ERROR'
272: , last_update_date = SYSDATE
273: , last_update_login = l_login_id
274: , last_updated_by = l_user_id

Line 307: FROM cn_process_batches

303: debugmsg('Conc_Submit : x_cls_rol_flag = ' || x_cls_rol_flag);
304:
305: -- transaction load
306: SELECT org_id INTO l_org_id
307: FROM cn_process_batches
308: WHERE physical_batch_id = x_physical_batch_id AND ROWNUM = 1;
309:
310: fnd_request.set_org_id(l_org_id);
311: -- transaction load

Line 392: FROM cn_process_batches

388:
389: -- Get individual physical batch id's for the entire logical batch
390: CURSOR physical_batches IS
391: SELECT DISTINCT physical_batch_id
392: FROM cn_process_batches
393: WHERE logical_batch_id = x_logical_batch_id AND status_code = 'IN_USE';
394:
395: physical_rec physical_batches%ROWTYPE;
396: BEGIN

Line 1164: -- update cn_process_batches, and perform classification, and rollup phases

1160: -- Name:
1161: -- Load
1162: -- Purpose:
1163: -- This procedure loads trx from CN_COMM_LINES_API to CN_COMMISSION_HEADERS,
1164: -- update cn_process_batches, and perform classification, and rollup phases
1165: PROCEDURE load(
1166: errbuf OUT NOCOPY VARCHAR2
1167: , retcode OUT NOCOPY NUMBER
1168: , p_salesrep_id IN NUMBER

Line 1242: SELECT cn_process_batches_s2.NEXTVAL INTO l_logical_batch_id FROM dual;

1238: RAISE fail_validate_ruleset;
1239: END IF;
1240: END IF;
1241:
1242: SELECT cn_process_batches_s2.NEXTVAL INTO l_logical_batch_id FROM dual;
1243:
1244: INSERT INTO cn_process_batches(
1245: process_batch_id
1246: , logical_batch_id

Line 1244: INSERT INTO cn_process_batches(

1240: END IF;
1241:
1242: SELECT cn_process_batches_s2.NEXTVAL INTO l_logical_batch_id FROM dual;
1243:
1244: INSERT INTO cn_process_batches(
1245: process_batch_id
1246: , logical_batch_id
1247: , srp_period_id
1248: , period_id

Line 1267: ( SELECT cn_process_batches_s1.NEXTVAL

1263: , program_id
1264: , program_update_date
1265: , org_id
1266: )
1267: ( SELECT cn_process_batches_s1.NEXTVAL
1268: , l_logical_batch_id
1269: , 1 -- a dummy value for a not null column
1270: , batch.period_id -- Start Period Id
1271: , batch.period_id -- End Period Id

Line 1319: -- populate the physical_batch_id in cn_process_batches

1315: RAISE no_trx_lines;
1316: END IF;
1317:
1318: -- Split the logical batch into smaller physical batches
1319: -- populate the physical_batch_id in cn_process_batches
1320: assign(p_logical_batch_id => l_logical_batch_id, p_org_id => p_org_id);
1321:
1322: -- Submit independent concurrent programs for each physical batch
1323: -- These physical batches will be executed in parallel

Line 1398: FROM cn_process_batches

1394: , period_id
1395: , start_date
1396: , end_date
1397: , sales_lines_total trx_count
1398: FROM cn_process_batches
1399: WHERE physical_batch_id = p_physical_batch_id AND status_code = 'IN_USE';
1400:
1401: counter NUMBER;
1402: l_counter NUMBER;

Line 2183: FROM cn_process_batches

2179: , cch.reversal_flag
2180: , cch.reversal_header_id
2181: FROM cn_commission_headers cch
2182: , (SELECT DISTINCT salesrep_id
2183: FROM cn_process_batches
2184: WHERE physical_batch_id = p_physical_batch_id AND status_code = 'IN_USE') pb
2185: WHERE cch.direct_salesrep_id = pb.salesrep_id
2186: AND cch.commission_header_id > l_init_commission_header_id;
2187: BEGIN