[Home] [Help]
556:
557:
558: EXCEPTION
559: WHEN OTHERS THEN
560: AP_Debug_Pkg.Print('Y', 'Invoices: p_start_rowid:' ||p_start_rowid ||
561: ' p_end_rowid:'||p_end_rowid);
562: AP_Debug_Pkg.Print('Y', 'Error: '||sqlcode||': '||sqlerrm);
563:
564: RAISE;
558: EXCEPTION
559: WHEN OTHERS THEN
560: AP_Debug_Pkg.Print('Y', 'Invoices: p_start_rowid:' ||p_start_rowid ||
561: ' p_end_rowid:'||p_end_rowid);
562: AP_Debug_Pkg.Print('Y', 'Error: '||sqlcode||': '||sqlerrm);
563:
564: RAISE;
565: END Create_Invoice_Dist_Links;
566:
954: END IF;
955:
956: EXCEPTION
957: WHEN OTHERS THEN
958: AP_Debug_Pkg.Print('Y', 'Prepay: p_start_rowid:' ||p_start_rowid ||
959: ' p_end_rowid:'||p_end_rowid);
960: AP_Debug_Pkg.Print('Y', 'Error: '||sqlcode||': '||sqlerrm);
961: RAISE;
962:
956: EXCEPTION
957: WHEN OTHERS THEN
958: AP_Debug_Pkg.Print('Y', 'Prepay: p_start_rowid:' ||p_start_rowid ||
959: ' p_end_rowid:'||p_end_rowid);
960: AP_Debug_Pkg.Print('Y', 'Error: '||sqlcode||': '||sqlerrm);
961: RAISE;
962:
963: END Create_Prepay_Dist_Links;
964:
1936:
1937:
1938: EXCEPTION
1939: WHEN OTHERS THEN
1940: AP_Debug_Pkg.Print('Y', 'Payment: p_start_rowid:' ||p_start_rowid ||
1941: ' p_end_rowid:'||p_end_rowid);
1942: AP_Debug_Pkg.Print('Y', 'Error: '||sqlcode||': '||sqlerrm);
1943: RAISE;
1944:
1938: EXCEPTION
1939: WHEN OTHERS THEN
1940: AP_Debug_Pkg.Print('Y', 'Payment: p_start_rowid:' ||p_start_rowid ||
1941: ' p_end_rowid:'||p_end_rowid);
1942: AP_Debug_Pkg.Print('Y', 'Error: '||sqlcode||': '||sqlerrm);
1943: RAISE;
1944:
1945: END Create_Payment_Dist_Links;
1946:
2151: EXCEPTION
2152: WHEN OTHERS THEN
2153: IF (SQLCODE <> -20001) THEN
2154: IF g_debug_flag = 'Y' THEN
2155: AP_Debug_Pkg.Print('Y','SQLAP','AP_DEBUG','ERROR',SQLERRM,
2156: 'CALLING_SEQUENCE', l_curr_calling_sequence);
2157: END IF;
2158: END IF;
2159: APP_EXCEPTION.RAISE_EXCEPTION;
2209: l_mode VARCHAR2(30) := 'UPDATE';
2210:
2211: BEGIN
2212:
2213: AP_Debug_Pkg.Print('Y','Inside SLA On Demand Upgrade Subworker');
2214:
2215: l_curr_calling_sequence := 'AP_XLA_UPGRADE_PKG.AP_XLA_Upgrade_Subworker';
2216:
2217: g_current_runtime_level := FND_LOG.G_CURRENT_RUNTIME_LEVEL;
2220: FND_LOG.STRING(g_level_procedure,'AP_XLA_UPGRADE_PKG.AP_XLA_UPGRADE_SUBWORKER',
2221: 'AP_XLA_UPGRADE_SUBWORKER(+)');
2222: END IF;
2223:
2224: AP_Debug_Pkg.Print('Y', 'AP_XLA_UPGRADE_SUBWORKER(+)');
2225: AP_Debug_Pkg.Print('Y', 'Starting at '||to_char(sysdate,'HH24:MI:SS'));
2226:
2227: IF (FND_INSTALLATION.GET_APP_INFO('SQLAP', l_status, l_industry, l_table_owner)) THEN
2228: NULL;
2221: 'AP_XLA_UPGRADE_SUBWORKER(+)');
2222: END IF;
2223:
2224: AP_Debug_Pkg.Print('Y', 'AP_XLA_UPGRADE_SUBWORKER(+)');
2225: AP_Debug_Pkg.Print('Y', 'Starting at '||to_char(sysdate,'HH24:MI:SS'));
2226:
2227: IF (FND_INSTALLATION.GET_APP_INFO('SQLAP', l_status, l_industry, l_table_owner)) THEN
2228: NULL;
2229: END IF;
2271:
2272:
2273: WHILE (l_any_rows_to_process = TRUE) LOOP
2274:
2275: --AP_Debug_Pkg.Print('Y', 'Start of Create_Invoice_Dist_Links');
2276: Create_Invoice_Dist_Links(
2277: l_start_rowid,
2278: l_end_rowid,
2279: l_curr_calling_sequence);
2277: l_start_rowid,
2278: l_end_rowid,
2279: l_curr_calling_sequence);
2280:
2281: --AP_Debug_Pkg.Print('Y', 'End of Create_Invoice_Dist_Links');
2282:
2283: l_rows_processed := SQL%ROWCOUNT;
2284:
2285: --AP_Debug_Pkg.Print('Y', 'Start of Create_Prepay_Dist_Links');
2281: --AP_Debug_Pkg.Print('Y', 'End of Create_Invoice_Dist_Links');
2282:
2283: l_rows_processed := SQL%ROWCOUNT;
2284:
2285: --AP_Debug_Pkg.Print('Y', 'Start of Create_Prepay_Dist_Links');
2286: Create_Prepay_Dist_Links(
2287: l_start_rowid,
2288: l_end_rowid,
2289: l_curr_calling_sequence);
2287: l_start_rowid,
2288: l_end_rowid,
2289: l_curr_calling_sequence);
2290:
2291: --AP_Debug_Pkg.Print('Y', 'End of Create_Prepay_Dist_Links');
2292:
2293: ad_parallel_updates_pkg.processed_rowid_range(
2294: l_rows_processed,
2295: l_end_rowid);
2350: END IF;
2351:
2352: WHILE (l_any_rows_to_process = TRUE) LOOP
2353:
2354: --AP_Debug_Pkg.Print('Y', 'Start of Create_Payment_Dist_Links');
2355: Create_Payment_Dist_Links(
2356: l_start_rowid,
2357: l_end_rowid,
2358: l_curr_calling_sequence);
2356: l_start_rowid,
2357: l_end_rowid,
2358: l_curr_calling_sequence);
2359:
2360: --AP_Debug_Pkg.Print('Y', 'End of Create_Payment_Dist_Links');
2361:
2362: l_rows_processed := SQL%ROWCOUNT;
2363:
2364: ad_parallel_updates_pkg.processed_rowid_range(
2395: FND_LOG.STRING(g_level_procedure,'AP_XLA_UPGRADE_PKG.AP_XLA_UPGRADE_SUBWORKER',
2396: 'AP_XLA_UPGRADE_SUBWORKER(-)');
2397: END IF;
2398:
2399: AP_Debug_Pkg.Print('Y', 'AP_XLA_UPGRADE_SUBWORKER(-)');
2400: AP_Debug_Pkg.Print('Y', 'End at ' || to_char(sysdate,'HH24:MI:SS'));
2401:
2402: EXCEPTION
2403: WHEN OTHERS THEN
2396: 'AP_XLA_UPGRADE_SUBWORKER(-)');
2397: END IF;
2398:
2399: AP_Debug_Pkg.Print('Y', 'AP_XLA_UPGRADE_SUBWORKER(-)');
2400: AP_Debug_Pkg.Print('Y', 'End at ' || to_char(sysdate,'HH24:MI:SS'));
2401:
2402: EXCEPTION
2403: WHEN OTHERS THEN
2404: retcode := 'Failed';
2463: FND_LOG.STRING(g_level_procedure,'AP_XLA_UPGRADE_PKG.AP_XLA_UPGRADE_ONDEMAND',
2464: ' Calling LAUNCH_WORKER');
2465: END IF;
2466:
2467: AP_Debug_Pkg.Print('Y', 'AP_XLA_UPGRADE_ONDEMAND(+) ');
2468: AP_Debug_Pkg.Print('Y', 'Starting at ' || to_char(sysdate, 'HH24:MI:SS'));
2469: AP_Debug_Pkg.Print('Y', 'Number of workers ' || p_num_workers);
2470:
2471: IF (FND_INSTALLATION.GET_APP_INFO('SQLAP', l_status, l_industry, l_table_owner)) THEN
2464: ' Calling LAUNCH_WORKER');
2465: END IF;
2466:
2467: AP_Debug_Pkg.Print('Y', 'AP_XLA_UPGRADE_ONDEMAND(+) ');
2468: AP_Debug_Pkg.Print('Y', 'Starting at ' || to_char(sysdate, 'HH24:MI:SS'));
2469: AP_Debug_Pkg.Print('Y', 'Number of workers ' || p_num_workers);
2470:
2471: IF (FND_INSTALLATION.GET_APP_INFO('SQLAP', l_status, l_industry, l_table_owner)) THEN
2472: NULL;
2465: END IF;
2466:
2467: AP_Debug_Pkg.Print('Y', 'AP_XLA_UPGRADE_ONDEMAND(+) ');
2468: AP_Debug_Pkg.Print('Y', 'Starting at ' || to_char(sysdate, 'HH24:MI:SS'));
2469: AP_Debug_Pkg.Print('Y', 'Number of workers ' || p_num_workers);
2470:
2471: IF (FND_INSTALLATION.GET_APP_INFO('SQLAP', l_status, l_industry, l_table_owner)) THEN
2472: NULL;
2473: END IF;
2482: FROM ap_invoices_upg_control
2483: WHERE module_name = 'SLA_ONDEMAND_INV_UPGRADE'
2484: AND end_date IS NULL;
2485:
2486: AP_Debug_Pkg.Print('Y', 'Existing script name for invoices '||l_inv_script_name);
2487: EXCEPTION
2488: WHEN no_data_found THEN
2489:
2490: l_inv_script_name := 'apidstln.sql'||l_batch_id;
2487: EXCEPTION
2488: WHEN no_data_found THEN
2489:
2490: l_inv_script_name := 'apidstln.sql'||l_batch_id;
2491: AP_Debug_Pkg.Print('Y', 'New script name for invoices '||l_inv_script_name);
2492:
2493: INSERT INTO ap_invoices_upg_control
2494: (Module_Name,
2495: Sub_Module,
2525: FROM ap_invoices_upg_control
2526: WHERE module_name = 'SLA_ONDEMAND_PAY_UPGRADE'
2527: AND end_date IS NULL;
2528:
2529: AP_Debug_Pkg.Print('Y', 'Existing script name for payments '||l_pay_script_name);
2530: EXCEPTION
2531: WHEN no_data_found THEN
2532:
2533: l_pay_script_name := 'appdstln.sql'||l_batch_id;
2530: EXCEPTION
2531: WHEN no_data_found THEN
2532:
2533: l_pay_script_name := 'appdstln.sql'||l_batch_id;
2534: AP_Debug_Pkg.Print('Y', 'New script name for payments '||l_pay_script_name);
2535:
2536: INSERT INTO ap_invoices_upg_control
2537: (Module_Name,
2538: Sub_Module,
2574: FND_LOG.STRING(g_level_procedure,'AP_XLA_UPGRADE_PKG.AP_XLA_UPGRADE_ONDEMAND',
2575: 'Submitting concurrent request for worker '||i);
2576: END IF;
2577:
2578: AP_Debug_Pkg.Print('Y', 'Submitting concurrent request for worker '||i);
2579:
2580: l_worker(i) := LAUNCH_WORKER(i,
2581: p_batch_size,
2582: p_num_workers,
2597: FND_LOG.STRING(g_level_procedure,'AP_XLA_UPGRADE_PKG.AP_XLA_UPGRADE_ONDEMAND',
2598: 'Inside Loop for checking the child request status');
2599: END IF;
2600:
2601: AP_Debug_Pkg.Print('Y', 'Inside Loop for checking the child request status');
2602:
2603: l_child_notcomplete := FALSE;
2604:
2605: FOR i in 1..p_num_workers
2623: FND_LOG.STRING(g_level_procedure,'AP_XLA_UPGRADE_PKG.AP_XLA_UPGRADE_ONDEMAND',
2624: 'Loop once again');
2625: END IF;
2626:
2627: AP_Debug_Pkg.Print('Y', 'Loop once again for worker '|| l_worker(i));
2628:
2629: l_child_notcomplete := TRUE;
2630: END IF;
2631:
2646: FND_LOG.STRING(g_level_procedure,'AP_XLA_UPGRADE_PKG.AP_XLA_UPGRADE_ONDEMAND',
2647: 'Setting XLA migration status to processed');
2648: END IF;
2649:
2650: AP_Debug_Pkg.Print('Y', 'Setting XLA migration status to processed');
2651:
2652: l_mig_status := XLA_Upgrade_Pub.Set_Migration_Status_Code
2653: (200, null, null, null);
2654:
2669: FND_LOG.STRING(g_level_procedure,'AP_XLA_UPGRADE_PKG.AP_XLA_UPGRADE_ONDEMAND',
2670: 'AP_XLA_UPGRADE_ONDEMAND(-)');
2671: END IF;
2672:
2673: AP_Debug_Pkg.Print('Y', 'AP_XLA_UPGRADE_ONDEMAND(-)');
2674: AP_Debug_Pkg.Print('Y', 'Ending at '|| to_char(sysdate,'HH24:MI:SS'));
2675:
2676: COMMIT;
2677:
2670: 'AP_XLA_UPGRADE_ONDEMAND(-)');
2671: END IF;
2672:
2673: AP_Debug_Pkg.Print('Y', 'AP_XLA_UPGRADE_ONDEMAND(-)');
2674: AP_Debug_Pkg.Print('Y', 'Ending at '|| to_char(sysdate,'HH24:MI:SS'));
2675:
2676: COMMIT;
2677:
2678: -- set the Return Code and the Error Buffer.
2686: IF g_level_procedure >= g_current_runtime_level THEN
2687: FND_LOG.STRING(g_level_procedure,'AP_XLA_UPGRADE_PKG.AP_XLA_UPGRADE_ONDEMAND',
2688: 'Error in procedure AP_XLA_UPGRADE_SUBWORKER');
2689: END IF;
2690: AP_Debug_Pkg.Print('Y', 'Error in procedure AP_XLA_UPGRADE_SUBWORKER');
2691:
2692: errbuf := 'Error in procedure AP_XLA_UPGRADE_SUBWORKER';
2693: retcode := 2;
2694:
2699: IF g_level_procedure >= g_current_runtime_level THEN
2700: FND_LOG.STRING(g_level_procedure,'AP_XLA_UPGRADE_PKG.AP_XLA_UPGRADE_ONDEMAND',
2701: 'Error while updating migration status code');
2702: END IF;
2703: AP_Debug_Pkg.Print('Y', 'Error while updating migration status code');
2704:
2705: --bug:8791198
2706: errbuf := 'Error while updating migration status code';
2707: retcode := 2;