2289: l_module_name CONSTANT VARCHAR2(30) := 'TAX_MIGRATION';
2290:
2291: BEGIN
2292: RETCODE := 0; --0 for success, 1 for warning, 2 for error
2293: FND_FILE.PUT_LINE(FND_FILE.LOG,'Starting Concurrent Program: '|| G_PKG_NAME || '.' || l_module_name);
2294: FND_FILE.PUT_LINE(FND_FILE.LOG,'time: '|| to_char(SYSDATE, 'DD-MON-YYYY HH24:MI:SS'));
2295:
2296: --migrate the header level tax_exemption_id to exempt_certificate_number and exempt_reason_code
2297: --npalepu updating tax_code and tax_exemption_id to null for bug # 4908543
2290:
2291: BEGIN
2292: RETCODE := 0; --0 for success, 1 for warning, 2 for error
2293: FND_FILE.PUT_LINE(FND_FILE.LOG,'Starting Concurrent Program: '|| G_PKG_NAME || '.' || l_module_name);
2294: FND_FILE.PUT_LINE(FND_FILE.LOG,'time: '|| to_char(SYSDATE, 'DD-MON-YYYY HH24:MI:SS'));
2295:
2296: --migrate the header level tax_exemption_id to exempt_certificate_number and exempt_reason_code
2297: --npalepu updating tax_code and tax_exemption_id to null for bug # 4908543
2298: UPDATE /*+ parallel(oks) */ OKS_K_HEADERS_B oks
2305: WHERE oks.tax_exemption_id IS NOT NULL
2306: AND (oks.EXEMPT_CERTIFICATE_NUMBER IS NULL OR oks.EXEMPT_REASON_CODE IS NULL);
2307: --end npalepu
2308:
2309: FND_FILE.PUT_LINE(FND_FILE.LOG,'Finished migrating tax_exemption_id in OKS_K_HEADERS_B');
2310: FND_FILE.PUT_LINE(FND_FILE.LOG,'time: '|| to_char(SYSDATE, 'DD-MON-YYYY HH24:MI:SS'));
2311:
2312: /*npalepu added migration of tax_exemption_id to exempt_certificate_number and exempt_reason_code in oks_k_headers_bh table.
2313: updating tax_code and tax_exemption_id to null for bug # 4908543 */
2306: AND (oks.EXEMPT_CERTIFICATE_NUMBER IS NULL OR oks.EXEMPT_REASON_CODE IS NULL);
2307: --end npalepu
2308:
2309: FND_FILE.PUT_LINE(FND_FILE.LOG,'Finished migrating tax_exemption_id in OKS_K_HEADERS_B');
2310: FND_FILE.PUT_LINE(FND_FILE.LOG,'time: '|| to_char(SYSDATE, 'DD-MON-YYYY HH24:MI:SS'));
2311:
2312: /*npalepu added migration of tax_exemption_id to exempt_certificate_number and exempt_reason_code in oks_k_headers_bh table.
2313: updating tax_code and tax_exemption_id to null for bug # 4908543 */
2314: UPDATE /*+ parallel(oks) */ OKS_K_HEADERS_BH oks
2321: WHERE oks.tax_exemption_id IS NOT NULL
2322: AND (oks.EXEMPT_CERTIFICATE_NUMBER IS NULL OR oks.EXEMPT_REASON_CODE IS NULL);
2323: --end npalepu
2324:
2325: FND_FILE.PUT_LINE(FND_FILE.LOG,'Finished migrating tax_exemption_id in OKS_K_HEADERS_BH');
2326: FND_FILE.PUT_LINE(FND_FILE.LOG,'time: '|| to_char(SYSDATE, 'DD-MON-YYYY HH24:MI:SS'));
2327: --end npalepu
2328:
2329: COMMIT;
2322: AND (oks.EXEMPT_CERTIFICATE_NUMBER IS NULL OR oks.EXEMPT_REASON_CODE IS NULL);
2323: --end npalepu
2324:
2325: FND_FILE.PUT_LINE(FND_FILE.LOG,'Finished migrating tax_exemption_id in OKS_K_HEADERS_BH');
2326: FND_FILE.PUT_LINE(FND_FILE.LOG,'time: '|| to_char(SYSDATE, 'DD-MON-YYYY HH24:MI:SS'));
2327: --end npalepu
2328:
2329: COMMIT;
2330:
2327: --end npalepu
2328:
2329: COMMIT;
2330:
2331: FND_FILE.PUT_LINE(FND_FILE.LOG,'End Concurrent Program - Success, time: '|| to_char(SYSDATE, 'DD-MON-YYYY HH24:MI:SS') ||' ,retcode='|| retcode);
2332:
2333: EXCEPTION
2334: WHEN OTHERS THEN
2335: retcode := 2;
2333: EXCEPTION
2334: WHEN OTHERS THEN
2335: retcode := 2;
2336: errbuf := SQLCODE || SQLERRM;
2337: FND_FILE.PUT_LINE(FND_FILE.LOG,'End Concurrent Program - Error, time: '|| to_char(SYSDATE, 'DD-MON-YYYY HH24:MI:SS') ||' ,retcode='|| retcode);
2338:
2339: END TAX_MIGRATION;
2340:
2341:
2348: BEGIN
2349: --
2350: -- Manager processing for OKS_K_LINES_B table
2351: --
2352: fnd_file.put_line(FND_FILE.LOG, 'Start of Update_Tax_BMGR ');
2353: fnd_file.put_line(FND_FILE.LOG, ' P_batch_size : '||P_batch_size);
2354: fnd_file.put_line(FND_FILE.LOG, 'P_Num_Workers : '||P_Num_Workers);
2355:
2356: fnd_file.put_line(FND_FILE.LOG, 'starting oks_k_lines_b update worker ');
2349: --
2350: -- Manager processing for OKS_K_LINES_B table
2351: --
2352: fnd_file.put_line(FND_FILE.LOG, 'Start of Update_Tax_BMGR ');
2353: fnd_file.put_line(FND_FILE.LOG, ' P_batch_size : '||P_batch_size);
2354: fnd_file.put_line(FND_FILE.LOG, 'P_Num_Workers : '||P_Num_Workers);
2355:
2356: fnd_file.put_line(FND_FILE.LOG, 'starting oks_k_lines_b update worker ');
2357:
2350: -- Manager processing for OKS_K_LINES_B table
2351: --
2352: fnd_file.put_line(FND_FILE.LOG, 'Start of Update_Tax_BMGR ');
2353: fnd_file.put_line(FND_FILE.LOG, ' P_batch_size : '||P_batch_size);
2354: fnd_file.put_line(FND_FILE.LOG, 'P_Num_Workers : '||P_Num_Workers);
2355:
2356: fnd_file.put_line(FND_FILE.LOG, 'starting oks_k_lines_b update worker ');
2357:
2358: AD_CONC_UTILS_PKG.submit_subrequests(X_errbuf,
2352: fnd_file.put_line(FND_FILE.LOG, 'Start of Update_Tax_BMGR ');
2353: fnd_file.put_line(FND_FILE.LOG, ' P_batch_size : '||P_batch_size);
2354: fnd_file.put_line(FND_FILE.LOG, 'P_Num_Workers : '||P_Num_Workers);
2355:
2356: fnd_file.put_line(FND_FILE.LOG, 'starting oks_k_lines_b update worker ');
2357:
2358: AD_CONC_UTILS_PKG.submit_subrequests(X_errbuf,
2359: X_retcode,
2360: 'OKS',
2361: 'OKSTAXBWKR',
2362: P_batch_size,
2363: P_Num_Workers);
2364:
2365: fnd_file.put_line(FND_FILE.LOG, 'X_errbuf : '||X_errbuf);
2366: fnd_file.put_line(FND_FILE.LOG, 'X_retcode : '||X_retcode);
2367:
2368: END Update_Tax_BMGR;
2369:
2362: P_batch_size,
2363: P_Num_Workers);
2364:
2365: fnd_file.put_line(FND_FILE.LOG, 'X_errbuf : '||X_errbuf);
2366: fnd_file.put_line(FND_FILE.LOG, 'X_retcode : '||X_retcode);
2367:
2368: END Update_Tax_BMGR;
2369:
2370: PROCEDURE Update_Tax_HMGR(X_errbuf out NOCOPY varchar2,
2375: BEGIN
2376: --
2377: -- Manager processing for OKS_K_LINES_BH table
2378: --
2379: fnd_file.put_line(FND_FILE.LOG, 'Start of Update_Tax_HMGR ');
2380: fnd_file.put_line(FND_FILE.LOG, ' P_batch_size : '||P_batch_size);
2381: fnd_file.put_line(FND_FILE.LOG, 'P_Num_Workers : '||P_Num_Workers);
2382:
2383: fnd_file.put_line(FND_FILE.LOG, 'starting oks_k_lines_bh update worker ');
2376: --
2377: -- Manager processing for OKS_K_LINES_BH table
2378: --
2379: fnd_file.put_line(FND_FILE.LOG, 'Start of Update_Tax_HMGR ');
2380: fnd_file.put_line(FND_FILE.LOG, ' P_batch_size : '||P_batch_size);
2381: fnd_file.put_line(FND_FILE.LOG, 'P_Num_Workers : '||P_Num_Workers);
2382:
2383: fnd_file.put_line(FND_FILE.LOG, 'starting oks_k_lines_bh update worker ');
2384:
2377: -- Manager processing for OKS_K_LINES_BH table
2378: --
2379: fnd_file.put_line(FND_FILE.LOG, 'Start of Update_Tax_HMGR ');
2380: fnd_file.put_line(FND_FILE.LOG, ' P_batch_size : '||P_batch_size);
2381: fnd_file.put_line(FND_FILE.LOG, 'P_Num_Workers : '||P_Num_Workers);
2382:
2383: fnd_file.put_line(FND_FILE.LOG, 'starting oks_k_lines_bh update worker ');
2384:
2385: AD_CONC_UTILS_PKG.submit_subrequests(X_errbuf,
2379: fnd_file.put_line(FND_FILE.LOG, 'Start of Update_Tax_HMGR ');
2380: fnd_file.put_line(FND_FILE.LOG, ' P_batch_size : '||P_batch_size);
2381: fnd_file.put_line(FND_FILE.LOG, 'P_Num_Workers : '||P_Num_Workers);
2382:
2383: fnd_file.put_line(FND_FILE.LOG, 'starting oks_k_lines_bh update worker ');
2384:
2385: AD_CONC_UTILS_PKG.submit_subrequests(X_errbuf,
2386: X_retcode,
2387: 'OKS',
2388: 'OKSTAXHWKR',
2389: P_batch_size,
2390: P_Num_Workers);
2391:
2392: fnd_file.put_line(FND_FILE.LOG, 'X_errbuf : '||X_errbuf);
2393: fnd_file.put_line(FND_FILE.LOG, 'X_retcode : '||X_retcode);
2394:
2395: END Update_Tax_HMGR;
2396:
2389: P_batch_size,
2390: P_Num_Workers);
2391:
2392: fnd_file.put_line(FND_FILE.LOG, 'X_errbuf : '||X_errbuf);
2393: fnd_file.put_line(FND_FILE.LOG, 'X_retcode : '||X_retcode);
2394:
2395: END Update_Tax_HMGR;
2396:
2397: /*
2431: then
2432: raise_application_error(-20001,'Cannot get schema name for product : '||l_product);
2433: end if;
2434:
2435: fnd_file.put_line(FND_FILE.LOG, 'Start of upgrade script for OKS_K_LINES_B table ');
2436: fnd_file.put_line(FND_FILE.LOG, ' P_Worker_Id : '||P_Worker_Id);
2437: fnd_file.put_line(FND_FILE.LOG, 'P_Num_Workers : '||P_Num_Workers);
2438:
2439: --
2432: raise_application_error(-20001,'Cannot get schema name for product : '||l_product);
2433: end if;
2434:
2435: fnd_file.put_line(FND_FILE.LOG, 'Start of upgrade script for OKS_K_LINES_B table ');
2436: fnd_file.put_line(FND_FILE.LOG, ' P_Worker_Id : '||P_Worker_Id);
2437: fnd_file.put_line(FND_FILE.LOG, 'P_Num_Workers : '||P_Num_Workers);
2438:
2439: --
2440: -- Worker processing
2433: end if;
2434:
2435: fnd_file.put_line(FND_FILE.LOG, 'Start of upgrade script for OKS_K_LINES_B table ');
2436: fnd_file.put_line(FND_FILE.LOG, ' P_Worker_Id : '||P_Worker_Id);
2437: fnd_file.put_line(FND_FILE.LOG, 'P_Num_Workers : '||P_Num_Workers);
2438:
2439: --
2440: -- Worker processing
2441: --
2521: l_any_rows_to_process,
2522: P_batch_size,
2523: FALSE);
2524: end loop;
2525: fnd_file.put_line(FND_FILE.LOG,'Upgrade for tax columns in OKS_K_LINES_B table completed successfully');
2526: X_retcode := AD_CONC_UTILS_PKG.CONC_SUCCESS;
2527: X_errbuf := ' ';
2528: EXCEPTION
2529: WHEN OTHERS THEN
2528: EXCEPTION
2529: WHEN OTHERS THEN
2530: X_retcode := AD_CONC_UTILS_PKG.CONC_FAIL;
2531: X_errbuf := SQLERRM;
2532: fnd_file.put_line(FND_FILE.LOG,'X_errbuf : '||X_errbuf);
2533: fnd_file.put_line(FND_FILE.LOG,' ');
2534: raise;
2535: END;
2536: END Update_Tax_BWKR;
2529: WHEN OTHERS THEN
2530: X_retcode := AD_CONC_UTILS_PKG.CONC_FAIL;
2531: X_errbuf := SQLERRM;
2532: fnd_file.put_line(FND_FILE.LOG,'X_errbuf : '||X_errbuf);
2533: fnd_file.put_line(FND_FILE.LOG,' ');
2534: raise;
2535: END;
2536: END Update_Tax_BWKR;
2537:
2572: then
2573: raise_application_error(-20001,'Cannot get schema name for product : '||l_product);
2574: end if;
2575:
2576: fnd_file.put_line(FND_FILE.LOG, 'Start of upgrade script for OKS_K_LINES_BH table ');
2577: fnd_file.put_line(FND_FILE.LOG, ' P_Worker_Id : '||P_Worker_Id);
2578: fnd_file.put_line(FND_FILE.LOG, 'P_Num_Workers : '||P_Num_Workers);
2579:
2580: --
2573: raise_application_error(-20001,'Cannot get schema name for product : '||l_product);
2574: end if;
2575:
2576: fnd_file.put_line(FND_FILE.LOG, 'Start of upgrade script for OKS_K_LINES_BH table ');
2577: fnd_file.put_line(FND_FILE.LOG, ' P_Worker_Id : '||P_Worker_Id);
2578: fnd_file.put_line(FND_FILE.LOG, 'P_Num_Workers : '||P_Num_Workers);
2579:
2580: --
2581: -- Worker processing
2574: end if;
2575:
2576: fnd_file.put_line(FND_FILE.LOG, 'Start of upgrade script for OKS_K_LINES_BH table ');
2577: fnd_file.put_line(FND_FILE.LOG, ' P_Worker_Id : '||P_Worker_Id);
2578: fnd_file.put_line(FND_FILE.LOG, 'P_Num_Workers : '||P_Num_Workers);
2579:
2580: --
2581: -- Worker processing
2582: --
2661: l_any_rows_to_process,
2662: P_batch_size,
2663: FALSE);
2664: end loop;
2665: fnd_file.put_line(FND_FILE.LOG,'Upgrade for tax columns in OKS_K_LINES_BH table completed successfully');
2666: X_retcode := AD_CONC_UTILS_PKG.CONC_SUCCESS;
2667: X_errbuf := ' ';
2668: EXCEPTION
2669: WHEN OTHERS THEN
2668: EXCEPTION
2669: WHEN OTHERS THEN
2670: X_retcode := AD_CONC_UTILS_PKG.CONC_FAIL;
2671: X_errbuf := SQLERRM;
2672: fnd_file.put_line(FND_FILE.LOG,'X_errbuf : '||X_errbuf);
2673: fnd_file.put_line(FND_FILE.LOG,' ');
2674: raise;
2675: END;
2676: END Update_Tax_HWKR;
2669: WHEN OTHERS THEN
2670: X_retcode := AD_CONC_UTILS_PKG.CONC_FAIL;
2671: X_errbuf := SQLERRM;
2672: fnd_file.put_line(FND_FILE.LOG,'X_errbuf : '||X_errbuf);
2673: fnd_file.put_line(FND_FILE.LOG,' ');
2674: raise;
2675: END;
2676: END Update_Tax_HWKR;
2677: --end npalepu