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:
136: logical_rec logical_batches%ROWTYPE;

Line 198: UPDATE cn_process_batches

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

Line 267: UPDATE cn_process_batches

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

Line 304: FROM cn_process_batches

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

Line 389: FROM cn_process_batches

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

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

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

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

1234: RAISE fail_validate_ruleset;
1235: END IF;
1236: END IF;
1237:
1238: SELECT cn_process_batches_s2.NEXTVAL INTO l_logical_batch_id FROM dual;
1239:
1240: INSERT INTO cn_process_batches(
1241: process_batch_id
1242: , logical_batch_id

Line 1240: INSERT INTO cn_process_batches(

1236: END IF;
1237:
1238: SELECT cn_process_batches_s2.NEXTVAL INTO l_logical_batch_id FROM dual;
1239:
1240: INSERT INTO cn_process_batches(
1241: process_batch_id
1242: , logical_batch_id
1243: , srp_period_id
1244: , period_id

Line 1263: ( SELECT cn_process_batches_s1.NEXTVAL

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

Line 1314: -- populate the physical_batch_id in cn_process_batches

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

Line 1386: FROM cn_process_batches

1382: , period_id
1383: , start_date
1384: , end_date
1385: , sales_lines_total trx_count
1386: FROM cn_process_batches
1387: WHERE physical_batch_id = p_physical_batch_id AND status_code = 'IN_USE';
1388:
1389: counter NUMBER;
1390: l_counter NUMBER;

Line 2171: FROM cn_process_batches

2167: , cch.reversal_flag
2168: , cch.reversal_header_id
2169: FROM cn_commission_headers cch
2170: , (SELECT DISTINCT salesrep_id
2171: FROM cn_process_batches
2172: WHERE physical_batch_id = p_physical_batch_id AND status_code = 'IN_USE') pb
2173: WHERE cch.direct_salesrep_id = pb.salesrep_id
2174: AND cch.commission_header_id > l_init_commission_header_id;
2175: BEGIN