APPS.CSI_TRANSACTION_IMPORT_PVT dependencies on CSI_BATCH_TXN_LINES

Line 37: TYPE header_id_array_type is TABLE OF CSI_BATCH_TXN_LINES.ORDER_HEADER_ID%TYPE ;

33: l_schema varchar2(30);
34: l_status varchar2(1);
35: l_industry varchar2(1);
36:
37: TYPE header_id_array_type is TABLE OF CSI_BATCH_TXN_LINES.ORDER_HEADER_ID%TYPE ;
38: l_header_id header_id_array_type;
39: l_limit number;
40:
41: CURSOR l_header_cur IS

Line 43: FROM csi_batch_txn_lines cbtl

39: l_limit number;
40:
41: CURSOR l_header_cur IS
42: SELECT DISTINCT cbtl.order_header_id
43: FROM csi_batch_txn_lines cbtl
44: WHERE batch_id = -1
45: AND NOT EXISTS (SELECT 'x' --do not assign a batch_id to an order that is
46: -- being processed
47: FROM csi_batch_txn_lines cbtl2

Line 47: FROM csi_batch_txn_lines cbtl2

43: FROM csi_batch_txn_lines cbtl
44: WHERE batch_id = -1
45: AND NOT EXISTS (SELECT 'x' --do not assign a batch_id to an order that is
46: -- being processed
47: FROM csi_batch_txn_lines cbtl2
48: WHERE cbtl2.order_header_id = cbtl.order_header_id
49: AND cbtl2.processed_flag IN (1,2)
50: AND cbtl2.batch_id <> -1)
51: ORDER BY order_header_id;

Line 55: SELECT csi_batch_txn_lines_s.nextval

51: ORDER BY order_header_id;
52:
53: BEGIN
54:
55: SELECT csi_batch_txn_lines_s.nextval
56: INTO l_seq
57: FROM dual;
58:
59: OPEN l_header_cur;

Line 67: UPDATE csi_batch_txn_lines cbtl

63: debug('Order Headers that will be batched: ' || l_header_id.count);
64: if (l_header_id.count > 0) then
65:
66: FORALL i in l_header_id.first..l_header_id.last
67: UPDATE csi_batch_txn_lines cbtl
68: SET batch_id = l_seq + MOD(l_header_id(i), p_num_workers)
69: WHERE order_header_id = l_header_id(i);
70:
71: debug('Assigned batch_id to ' || SQL%ROWCOUNT || ' order lines');

Line 83: EXECUTE IMMEDIATE 'ALTER SEQUENCE '||l_schema||'.CSI_BATCH_TXN_LINES_S INCREMENT BY '||TO_CHAR(l_seq_incr);

79: END IF;
80:
81: --Adjust sequence
82: l_seq_incr := p_num_workers;
83: EXECUTE IMMEDIATE 'ALTER SEQUENCE '||l_schema||'.CSI_BATCH_TXN_LINES_S INCREMENT BY '||TO_CHAR(l_seq_incr);
84: SELECT csi_batch_txn_lines_s.nextval
85: INTO l_seq
86: FROM dual;
87: EXECUTE IMMEDIATE 'ALTER SEQUENCE '||l_schema||'.CSI_BATCH_TXN_LINES_S INCREMENT BY 1';

Line 84: SELECT csi_batch_txn_lines_s.nextval

80:
81: --Adjust sequence
82: l_seq_incr := p_num_workers;
83: EXECUTE IMMEDIATE 'ALTER SEQUENCE '||l_schema||'.CSI_BATCH_TXN_LINES_S INCREMENT BY '||TO_CHAR(l_seq_incr);
84: SELECT csi_batch_txn_lines_s.nextval
85: INTO l_seq
86: FROM dual;
87: EXECUTE IMMEDIATE 'ALTER SEQUENCE '||l_schema||'.CSI_BATCH_TXN_LINES_S INCREMENT BY 1';
88:

Line 87: EXECUTE IMMEDIATE 'ALTER SEQUENCE '||l_schema||'.CSI_BATCH_TXN_LINES_S INCREMENT BY 1';

83: EXECUTE IMMEDIATE 'ALTER SEQUENCE '||l_schema||'.CSI_BATCH_TXN_LINES_S INCREMENT BY '||TO_CHAR(l_seq_incr);
84: SELECT csi_batch_txn_lines_s.nextval
85: INTO l_seq
86: FROM dual;
87: EXECUTE IMMEDIATE 'ALTER SEQUENCE '||l_schema||'.CSI_BATCH_TXN_LINES_S INCREMENT BY 1';
88:
89: debug(' New Sequence Value '||l_seq);
90: end if;
91:

Line 122: FROM csi_batch_txn_lines CTL

118:
119: CURSOR worker_batch_cur(cp_workers_available in number,p_batch_lower_limit in number) IS
120: select * from (
121: SELECT DISTINCT ctl.batch_id
122: FROM csi_batch_txn_lines CTL
123: WHERE ctl.processed_flag = 0
124: AND batch_id >= p_batch_lower_limit
125: )
126: where ROWNUM <= cp_workers_available

Line 200: -- unmark rows in csi_batch_txn_lines

196: debug('Error: Submit Request failed by returning Request Id '||l_request_id);
197: RETCODE := 'Error';
198: CONC_STATUS := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',Current_Error_Code);
199:
200: -- unmark rows in csi_batch_txn_lines
201: update csi_batch_txn_lines
202: set batch_id = -1,last_update_date = sysdate,last_updated_by = fnd_global.user_id
203: where batch_id = cur_batch.batch_id;
204:

Line 201: update csi_batch_txn_lines

197: RETCODE := 'Error';
198: CONC_STATUS := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',Current_Error_Code);
199:
200: -- unmark rows in csi_batch_txn_lines
201: update csi_batch_txn_lines
202: set batch_id = -1,last_update_date = sysdate,last_updated_by = fnd_global.user_id
203: where batch_id = cur_batch.batch_id;
204:
205: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;

Line 210: update CSI_BATCH_TXN_LINES

206: end if;
207:
208: -- set the processed flag to 1 so that the next run of this program
209: -- will not process the rows
210: update CSI_BATCH_TXN_LINES
211: set processed_flag = 1,last_update_date = sysdate,last_updated_by = fnd_global.user_id
212: where batch_id = cur_batch.batch_id
213: and processed_flag = 0;
214:

Line 229: update csi_batch_txn_lines

225: IF fnd_log.level_unexpected >= fnd_log.g_current_runtime_level THEN
226: fnd_log.string(fnd_log.level_unexpected,'csi.plsql.csi_transaction_import_pvt.process_transaction_rows', 'WHEN OTHERS: ' ||SQLERRM);
227: END IF;
228:
229: update csi_batch_txn_lines
230: set batch_id = -1,last_update_date = sysdate,last_updated_by = fnd_global.user_id
231: where processed_flag = 0;
232:
233: commit;