1: PACKAGE BODY ZX_ON_DEMAND_TRX_UPGRADE_PKG AS
2: /* $Header: zxmigtrxdemdpkgb.pls 120.34.12010000.2 2008/11/12 12:33:28 spasala ship $ */
3:
4: g_current_runtime_level NUMBER;
5: g_level_statement CONSTANT NUMBER := FND_LOG.LEVEL_STATEMENT;
6: g_level_procedure CONSTANT NUMBER := FND_LOG.LEVEL_PROCEDURE;
7: g_level_unexpected CONSTANT NUMBER := FND_LOG.LEVEL_UNEXPECTED;
8:
9: CONC_SUCCESS CONSTANT NUMBER := 0;
2: /* $Header: zxmigtrxdemdpkgb.pls 120.34.12010000.2 2008/11/12 12:33:28 spasala ship $ */
3:
4: g_current_runtime_level NUMBER;
5: g_level_statement CONSTANT NUMBER := FND_LOG.LEVEL_STATEMENT;
6: g_level_procedure CONSTANT NUMBER := FND_LOG.LEVEL_PROCEDURE;
7: g_level_unexpected CONSTANT NUMBER := FND_LOG.LEVEL_UNEXPECTED;
8:
9: CONC_SUCCESS CONSTANT NUMBER := 0;
10: CONC_WARNING CONSTANT NUMBER := 1;
3:
4: g_current_runtime_level NUMBER;
5: g_level_statement CONSTANT NUMBER := FND_LOG.LEVEL_STATEMENT;
6: g_level_procedure CONSTANT NUMBER := FND_LOG.LEVEL_PROCEDURE;
7: g_level_unexpected CONSTANT NUMBER := FND_LOG.LEVEL_UNEXPECTED;
8:
9: CONC_SUCCESS CONSTANT NUMBER := 0;
10: CONC_WARNING CONSTANT NUMBER := 1;
11: CONC_FAIL CONSTANT NUMBER := 2;
78: l_res BOOLEAN;
79: -- bug fix 5483850 end
80:
81: BEGIN
82: g_current_runtime_level := FND_LOG.G_CURRENT_RUNTIME_LEVEL;
83:
84: --
85: -- Manager processing
86: --
85: -- Manager processing
86: --
87:
88: IF g_level_procedure >= g_current_runtime_level THEN
89: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR','ZX_TRX_UPDATE_MGR(+)');
90: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',' p_application_id: '||p_application_id);
91: END IF;
92:
93: X_retcode := CONC_SUCCESS;
86: --
87:
88: IF g_level_procedure >= g_current_runtime_level THEN
89: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR','ZX_TRX_UPDATE_MGR(+)');
90: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',' p_application_id: '||p_application_id);
91: END IF;
92:
93: X_retcode := CONC_SUCCESS;
94:
113: X_ARGUMENT4=>p_application_id,
114: X_argument5=>l_update_name);
115:
116: IF g_level_statement >= g_current_runtime_level THEN
117: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR','ZX_TRX_UPDATE_MGR(-)');
118: END IF;
119: */
120:
121: -- rewrote the process to submit worker request for bug fix 5483850
126: FOR i in 1..X_Num_Workers
127: LOOP
128:
129: IF g_level_statement >= g_current_runtime_level THEN
130: FND_LOG.STRING(g_level_statement,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',
131: 'Submitting concurrent request for worker '||i);
132: END IF;
133:
134: l_worker(i) := fnd_request.submit_request(
144: ARGUMENT5=>l_update_name );
145:
146: IF l_worker(i) = 0 THEN
147: IF g_level_statement >= g_current_runtime_level THEN
148: FND_LOG.STRING(g_level_statement,
149: 'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',
150: 'Error submitting request #'||i);
151: FND_LOG.STRING(g_level_statement,
152: 'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',
147: IF g_level_statement >= g_current_runtime_level THEN
148: FND_LOG.STRING(g_level_statement,
149: 'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',
150: 'Error submitting request #'||i);
151: FND_LOG.STRING(g_level_statement,
152: 'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',
153: fnd_message.get);
154: END IF;
155: COMMIT;
154: END IF;
155: COMMIT;
156: ELSE
157: IF g_level_statement >= g_current_runtime_level THEN
158: FND_LOG.STRING(g_level_statement,
159: 'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',
160: 'Submitted request #'||i);
161: FND_LOG.STRING(g_level_statement,
162: 'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',
157: IF g_level_statement >= g_current_runtime_level THEN
158: FND_LOG.STRING(g_level_statement,
159: 'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',
160: 'Submitted request #'||i);
161: FND_LOG.STRING(g_level_statement,
162: 'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',
163: 'Request ID: ' ||l_worker(i));
164: END IF;
165: COMMIT;
173: l_worker_not_complete := TRUE;
174: WHILE l_worker_not_complete LOOP
175: --dbms_lock.sleep(10);
176: IF g_level_statement >= g_current_runtime_level THEN
177: FND_LOG.STRING(g_level_statement,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',
178: 'Inside Loop for checking the child request status');
179: END IF;
180:
181: l_worker_not_complete := FALSE;
190: l_dev_status,
191: l_message);
192:
193: IF g_level_statement >= g_current_runtime_level THEN
194: FND_LOG.STRING(g_level_statement,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',
195: 'l_dev_phase: '||l_dev_phase);
196: END IF;
197:
198: IF l_dev_phase = 'COMPLETE' Then
198: IF l_dev_phase = 'COMPLETE' Then
199: NULL;
200: ELSE
201: IF g_level_statement >= g_current_runtime_level THEN
202: FND_LOG.STRING(g_level_statement,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',
203: 'Loop once again');
204: END IF;
205: l_worker_not_complete := TRUE;
206: END IF;
218:
219: COMMIT;
220:
221: IF g_level_procedure >= g_current_runtime_level THEN
222: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR','ZX_TRX_UPDATE_MGR(-)');
223: END IF;
224: EXCEPTION
225: WHEN OTHERS THEN
226: X_retcode := CONC_FAIL;
224: EXCEPTION
225: WHEN OTHERS THEN
226: X_retcode := CONC_FAIL;
227: IF g_level_unexpected >= g_current_runtime_level THEN
228: FND_LOG.STRING(g_level_unexpected,
229: 'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_MGR',
230: sqlcode || ': ' || SUBSTR(SQLERRM, 1, 80) );
231: END IF;
232: raise;
267: l_temp BOOLEAN;
268:
269: BEGIN
270:
271: g_current_runtime_level := FND_LOG.G_CURRENT_RUNTIME_LEVEL;
272:
273: --
274: -- get schema name of the table for ROWID range processing
275: --
273: --
274: -- get schema name of the table for ROWID range processing
275: --
276: IF g_level_procedure >= g_current_runtime_level then
277: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_WKR','ZX_TRX_UPDATE_WKR(+)');
278: END IF;
279:
280: X_retcode := CONC_SUCCESS;
281:
292: END IF;
293:
294:
295: IF g_level_statement >= g_current_runtime_level THEN
296: FND_LOG.STRING(g_level_statement,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_WKR','Worker: '||X_Worker_Id||' l_multi_org_flag is ' || l_multi_org_flag);
297: FND_LOG.STRING(g_level_statement,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_WKR','Worker: '||X_Worker_Id||' l_org_id is ' || l_org_id );
298:
299: END IF;
300:
293:
294:
295: IF g_level_statement >= g_current_runtime_level THEN
296: FND_LOG.STRING(g_level_statement,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_WKR','Worker: '||X_Worker_Id||' l_multi_org_flag is ' || l_multi_org_flag);
297: FND_LOG.STRING(g_level_statement,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_WKR','Worker: '||X_Worker_Id||' l_org_id is ' || l_org_id );
298:
299: END IF;
300:
301: l_fnd_return := FND_INSTALLATION.GET(401,401, l_inv_flag, l_industry);
323: END IF;
324:
325:
326: IF g_level_statement >= g_current_runtime_level then
327: FND_LOG.STRING(g_level_statement,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_WKR','Worker: '||X_Worker_Id||' X_Worker_Id is ' || X_Worker_Id);
328: FND_LOG.STRING(g_level_statement,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_WKR','Worker: '||X_Worker_Id||' X_Num_Workers is ' || X_Num_Workers );
329: END IF;
330:
331: BEGIN
324:
325:
326: IF g_level_statement >= g_current_runtime_level then
327: FND_LOG.STRING(g_level_statement,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_WKR','Worker: '||X_Worker_Id||' X_Worker_Id is ' || X_Worker_Id);
328: FND_LOG.STRING(g_level_statement,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_WKR','Worker: '||X_Worker_Id||' X_Num_Workers is ' || X_Num_Workers );
329: END IF;
330:
331: BEGIN
332:
424: raise;
425: END;
426:
427: IF g_level_procedure >= g_current_runtime_level then
428: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_WKR','ZX_TRX_UPDATE_WKR(-)');
429: END IF;
430:
431: EXCEPTION
432: WHEN OTHERS THEN
431: EXCEPTION
432: WHEN OTHERS THEN
433: X_retcode := CONC_FAIL;
434: IF g_level_unexpected >= g_current_runtime_level THEN
435: FND_LOG.STRING(g_level_unexpected,
436: 'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_TRX_UPDATE_WKR',
437: sqlcode || ': ' || SUBSTR(SQLERRM, 1, 80) );
438: END IF;
439: raise;
462: l_inv_installed := p_inv_installed;
463:
464:
465: IF g_level_procedure >= g_current_runtime_level then
466: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' zx_ar_trx_mig (+)' );
467: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_start_rowid is ' || p_start_rowid );
468: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_end_rowid is ' || p_end_rowid );
469: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_org_id is ' || p_org_id );
470: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_multi_org_flag is ' || p_multi_org_flag );
463:
464:
465: IF g_level_procedure >= g_current_runtime_level then
466: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' zx_ar_trx_mig (+)' );
467: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_start_rowid is ' || p_start_rowid );
468: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_end_rowid is ' || p_end_rowid );
469: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_org_id is ' || p_org_id );
470: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_multi_org_flag is ' || p_multi_org_flag );
471: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_inv_installed is ' || p_inv_installed );
464:
465: IF g_level_procedure >= g_current_runtime_level then
466: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' zx_ar_trx_mig (+)' );
467: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_start_rowid is ' || p_start_rowid );
468: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_end_rowid is ' || p_end_rowid );
469: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_org_id is ' || p_org_id );
470: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_multi_org_flag is ' || p_multi_org_flag );
471: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_inv_installed is ' || p_inv_installed );
472: END IF;
465: IF g_level_procedure >= g_current_runtime_level then
466: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' zx_ar_trx_mig (+)' );
467: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_start_rowid is ' || p_start_rowid );
468: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_end_rowid is ' || p_end_rowid );
469: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_org_id is ' || p_org_id );
470: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_multi_org_flag is ' || p_multi_org_flag );
471: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_inv_installed is ' || p_inv_installed );
472: END IF;
473:
466: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' zx_ar_trx_mig (+)' );
467: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_start_rowid is ' || p_start_rowid );
468: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_end_rowid is ' || p_end_rowid );
469: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_org_id is ' || p_org_id );
470: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_multi_org_flag is ' || p_multi_org_flag );
471: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_inv_installed is ' || p_inv_installed );
472: END IF;
473:
474: x_retcode := CONC_SUCCESS;
467: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_start_rowid is ' || p_start_rowid );
468: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_end_rowid is ' || p_end_rowid );
469: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_org_id is ' || p_org_id );
470: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_multi_org_flag is ' || p_multi_org_flag );
471: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' p_inv_installed is ' || p_inv_installed );
472: END IF;
473:
474: x_retcode := CONC_SUCCESS;
475:
2197:
2198: x_rows_processed := SQL%ROWCOUNT;
2199:
2200: IF g_level_procedure >= g_current_runtime_level THEN
2201: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' x_rows_processed is ' || x_rows_processed );
2202: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' zx_ar_trx_mig (-)' );
2203: END IF;
2204:
2205: EXCEPTION
2198: x_rows_processed := SQL%ROWCOUNT;
2199:
2200: IF g_level_procedure >= g_current_runtime_level THEN
2201: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' x_rows_processed is ' || x_rows_processed );
2202: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG','Worker: '||p_worker_id||' zx_ar_trx_mig (-)' );
2203: END IF;
2204:
2205: EXCEPTION
2206: WHEN OTHERS THEN
2205: EXCEPTION
2206: WHEN OTHERS THEN
2207: X_retcode := CONC_FAIL;
2208: IF g_level_unexpected >= g_current_runtime_level THEN
2209: FND_LOG.STRING(g_level_unexpected,
2210: 'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AR_TRX_MIG',
2211: 'Worker: '||p_worker_id||'Raised exceptions: '||
2212: sqlcode || ': ' || SUBSTR(SQLERRM, 1, 80) );
2213: END IF;
2233: l_org_id := p_org_id;
2234:
2235:
2236: IF g_level_procedure >= g_current_runtime_level THEN
2237: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||' zx_ap_trx_mig (+)' );
2238: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||' p_start_rowid is ' || p_start_rowid );
2239: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_end_rowid is ' || p_end_rowid );
2240: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_org_id is ' || p_org_id );
2241: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_multi_org_flag is ' || p_multi_org_flag );
2234:
2235:
2236: IF g_level_procedure >= g_current_runtime_level THEN
2237: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||' zx_ap_trx_mig (+)' );
2238: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||' p_start_rowid is ' || p_start_rowid );
2239: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_end_rowid is ' || p_end_rowid );
2240: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_org_id is ' || p_org_id );
2241: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_multi_org_flag is ' || p_multi_org_flag );
2242: END IF;
2235:
2236: IF g_level_procedure >= g_current_runtime_level THEN
2237: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||' zx_ap_trx_mig (+)' );
2238: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||' p_start_rowid is ' || p_start_rowid );
2239: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_end_rowid is ' || p_end_rowid );
2240: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_org_id is ' || p_org_id );
2241: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_multi_org_flag is ' || p_multi_org_flag );
2242: END IF;
2243:
2236: IF g_level_procedure >= g_current_runtime_level THEN
2237: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||' zx_ap_trx_mig (+)' );
2238: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||' p_start_rowid is ' || p_start_rowid );
2239: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_end_rowid is ' || p_end_rowid );
2240: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_org_id is ' || p_org_id );
2241: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_multi_org_flag is ' || p_multi_org_flag );
2242: END IF;
2243:
2244: x_retcode := CONC_SUCCESS;
2237: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||' zx_ap_trx_mig (+)' );
2238: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||' p_start_rowid is ' || p_start_rowid );
2239: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_end_rowid is ' || p_end_rowid );
2240: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_org_id is ' || p_org_id );
2241: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||'p_multi_org_flag is ' || p_multi_org_flag );
2242: END IF;
2243:
2244: x_retcode := CONC_SUCCESS;
2245:
3866:
3867: x_rows_processed := SQL%ROWCOUNT;
3868:
3869: IF g_level_procedure >= g_current_runtime_level THEN
3870: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||' x_rows_processed is ' || x_rows_processed );
3871: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||' zx_ap_trx_mig (-)' );
3872: END IF;
3873:
3874: EXCEPTION
3867: x_rows_processed := SQL%ROWCOUNT;
3868:
3869: IF g_level_procedure >= g_current_runtime_level THEN
3870: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||' x_rows_processed is ' || x_rows_processed );
3871: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG','Worker: '||p_worker_id||' zx_ap_trx_mig (-)' );
3872: END IF;
3873:
3874: EXCEPTION
3875: WHEN OTHERS THEN
3874: EXCEPTION
3875: WHEN OTHERS THEN
3876: X_retcode := CONC_FAIL;
3877: IF g_level_unexpected >= g_current_runtime_level THEN
3878: FND_LOG.STRING(g_level_unexpected,
3879: 'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_AP_TRX_MIG',
3880: 'Worker: '||p_worker_id||'Raised exceptions: '||
3881: sqlcode || ': ' || SUBSTR(SQLERRM, 1, 80) );
3882: END IF;
3902: l_org_id := p_org_id;
3903:
3904:
3905: IF g_level_procedure >= g_current_runtime_level THEN
3906: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||' zx_po_trx_mig (+)' );
3907: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_start_rowid is ' || p_start_rowid );
3908: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_end_rowid is ' || p_end_rowid );
3909: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_org_id is ' || p_org_id );
3910: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_multi_org_flag is ' || p_multi_org_flag );
3903:
3904:
3905: IF g_level_procedure >= g_current_runtime_level THEN
3906: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||' zx_po_trx_mig (+)' );
3907: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_start_rowid is ' || p_start_rowid );
3908: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_end_rowid is ' || p_end_rowid );
3909: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_org_id is ' || p_org_id );
3910: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_multi_org_flag is ' || p_multi_org_flag );
3911: END IF;
3904:
3905: IF g_level_procedure >= g_current_runtime_level THEN
3906: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||' zx_po_trx_mig (+)' );
3907: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_start_rowid is ' || p_start_rowid );
3908: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_end_rowid is ' || p_end_rowid );
3909: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_org_id is ' || p_org_id );
3910: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_multi_org_flag is ' || p_multi_org_flag );
3911: END IF;
3912:
3905: IF g_level_procedure >= g_current_runtime_level THEN
3906: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||' zx_po_trx_mig (+)' );
3907: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_start_rowid is ' || p_start_rowid );
3908: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_end_rowid is ' || p_end_rowid );
3909: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_org_id is ' || p_org_id );
3910: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_multi_org_flag is ' || p_multi_org_flag );
3911: END IF;
3912:
3913: x_retcode := CONC_SUCCESS;
3906: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||' zx_po_trx_mig (+)' );
3907: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_start_rowid is ' || p_start_rowid );
3908: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_end_rowid is ' || p_end_rowid );
3909: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_org_id is ' || p_org_id );
3910: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||'p_multi_org_flag is ' || p_multi_org_flag );
3911: END IF;
3912:
3913: x_retcode := CONC_SUCCESS;
3914:
5462:
5463: x_rows_processed := SQL%ROWCOUNT;
5464:
5465: IF g_level_procedure >= g_current_runtime_level THEN
5466: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||' x_rows_processed is ' || x_rows_processed );
5467: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||' zx_po_trx_mig (-)' );
5468: END IF;
5469:
5470: EXCEPTION
5463: x_rows_processed := SQL%ROWCOUNT;
5464:
5465: IF g_level_procedure >= g_current_runtime_level THEN
5466: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||' x_rows_processed is ' || x_rows_processed );
5467: FND_LOG.STRING(g_level_procedure,'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG','Worker: '||p_worker_id||' zx_po_trx_mig (-)' );
5468: END IF;
5469:
5470: EXCEPTION
5471: WHEN OTHERS THEN
5470: EXCEPTION
5471: WHEN OTHERS THEN
5472: X_retcode := CONC_FAIL;
5473: IF g_level_unexpected >= g_current_runtime_level THEN
5474: FND_LOG.STRING(g_level_unexpected,
5475: 'ZX_ON_DEMAND_TRX_UPGRADE_PKG.ZX_PO_TRX_MIG',
5476: 'Worker: '||p_worker_id||'Raised exceptions: '||
5477: sqlcode || ': ' || SUBSTR(SQLERRM, 1, 80) );
5478: END IF;