[Home] [Help]
89: fpw.transaction_type_code,
90: fpw.corp_transaction_header_id,
91: fpw.tax_transaction_header_id,
92: af.asset_id same_asset_id_fail
93: from fa_parallel_workers fpw,
94: fa_asset_failures_gt af
95: where fpw.request_id = p_parent_request_id
96: and fpw.process_status = 'UNASSIGNED'
97: and fpw.worker_number = p_request_number
604: end loop; -- array loop
605:
606: -- now flags the rows process status accordingly
607: forall i in 1..l_rowid.count
608: update fa_parallel_workers mct
609: set process_status = l_process_status(i)
610: where rowid = l_rowid(i);
611:
612: if (g_log_level_rec.statement_level) then
609: set process_status = l_process_status(i)
610: where rowid = l_rowid(i);
611:
612: if (g_log_level_rec.statement_level) then
613: fa_debug_pkg.add(l_calling_fn, 'rows updated in fa_parallel_workersfor status', sql%rowcount);
614: end if;
615:
616: FND_CONCURRENT.AF_COMMIT;
617:
2685: select /*+ parallel(fpw_p) parallel(fpw_c) */
2686: distinct
2687: fpw_p.asset_id,
2688: fpw_p.worker_number
2689: from fa_parallel_workers fpw_p,
2690: fa_parallel_workers fpw_c
2691: where fpw_p.request_id = p_parent_request_id
2692: and fpw_p.transaction_type_code = 'ADDITION'
2693: and (fpw_p.parent_asset_id is null or
2686: distinct
2687: fpw_p.asset_id,
2688: fpw_p.worker_number
2689: from fa_parallel_workers fpw_p,
2690: fa_parallel_workers fpw_c
2691: where fpw_p.request_id = p_parent_request_id
2692: and fpw_p.transaction_type_code = 'ADDITION'
2693: and (fpw_p.parent_asset_id is null or
2694: not exists
2692: and fpw_p.transaction_type_code = 'ADDITION'
2693: and (fpw_p.parent_asset_id is null or
2694: not exists
2695: (select 1
2696: from fa_parallel_workers fpw_p1
2697: where fpw_p1.request_id = p_parent_request_id
2698: and fpw_p1.asset_id = fpw_p.parent_asset_id
2699: and fpw_p1.transaction_type_code = 'ADDITION'))
2700: and fpw_c.request_id = fpw_p.request_id
2720: p_parent_request_id number) is
2721: select
2722: fpw1.asset_id,
2723: level
2724: from fa_parallel_workers fpw1
2725: start with fpw1.asset_id = p_parent_asset_id
2726: and fpw1.request_id = p_parent_request_id
2727: and fpw1.transaction_type_code = 'ADDITION'
2728: connect by prior fpw1.asset_id = fpw1.parent_asset_id
2874: -- bug fix 5900321 (Initial Mass Copy copies capitalized assets to wrong fiscal year and period in TAX book)
2875: l_date_effective := nvl(l_corp_period_rec.period_close_date, sysdate);
2876: -- End bug fix 5900321
2877:
2878: insert into fa_parallel_workers
2879: (request_id ,
2880: asset_id ,
2881: asset_number ,
2882: asset_type ,
2972: if (g_log_level_rec.statement_level) then
2973: fa_debug_pkg.add(l_calling_fn, 'opening c_per_trx_child cursor at', sysdate, p_log_level_rec => g_log_level_rec);
2974: end if;
2975:
2976: insert into fa_parallel_workers
2977: (request_id ,
2978: asset_id ,
2979: asset_number ,
2980: asset_type ,
3080:
3081: end if;
3082:
3083: if (g_log_level_rec.statement_level) then
3084: fa_debug_pkg.add(l_calling_fn, 'rows inserted into fa_parallel_workers', sql%rowcount);
3085: end if;
3086:
3087: FND_CONCURRENT.AF_COMMIT;
3088: /* Bug 9020567 */
3085: end if;
3086:
3087: FND_CONCURRENT.AF_COMMIT;
3088: /* Bug 9020567 */
3089: /* When Data volumes are hign in fa_parallel_workers table we need to */
3090: /* analze this table to compute statistics for performance reason*/
3091:
3092: if (g_log_level_rec.statement_level) then
3093: fa_debug_pkg.add(l_calling_fn, 'Getting schema name', 'OFA', p_log_level_rec => g_log_level_rec);
3107: end if;
3108:
3109: EXECUTE IMMEDIATE 'begin sys.dbms_stats.gather_table_stats(
3110: :1, '
3111: ||'''fa_parallel_workers'''
3112: ||',estimate_percent=>100, cascade=>TRUE); end;' using l_schema;
3113:
3114: if (g_log_level_rec.statement_level) then
3115: fa_debug_pkg.add(l_calling_fn, 'After gather statistics', l_schema, p_log_level_rec => g_log_level_rec);
3171:
3172: -- note update by asset id instead of rowid is intentional
3173: -- we need all lines for the asset to go to the same worker
3174: forall i in 1..l_child_asset_id.count
3175: update fa_parallel_workers
3176: set worker_number = l_child_worker_number(i),
3177: process_order = l_child_process_order(i) + l_group_increment
3178: where request_id = p_parent_request_id
3179: and asset_id = l_child_asset_id(i);