14: begin
15:
16: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
17:
18: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_ACT.BASE_SUMMARY(p_worker_id);')) then
19: return;
20: end if;
21:
22: l_batch_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
18: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_ACT.BASE_SUMMARY(p_worker_id);')) then
19: return;
20: end if;
21:
22: l_batch_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
23: (
24: l_process,
25: 'CURRENT_BATCH'
26: );
814: PA_TIME_ID,
815: PA_PERIOD_NAME,
816: TXN_CURRENCY_CODE;
817:
818: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_ACT.BASE_SUMMARY(p_worker_id);');
819:
820: -- truncate intermediate tables no longer required
821: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
822: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_FUNDG' , 'NORMAL',null);
818: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_ACT.BASE_SUMMARY(p_worker_id);');
819:
820: -- truncate intermediate tables no longer required
821: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
822: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_FUNDG' , 'NORMAL',null);
823: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DREVN' , 'NORMAL',null);
824: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DINVC' , 'NORMAL',null);
825: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DINVCITM' , 'NORMAL',null);
826: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_ARINV' , 'NORMAL',null);
819:
820: -- truncate intermediate tables no longer required
821: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
822: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_FUNDG' , 'NORMAL',null);
823: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DREVN' , 'NORMAL',null);
824: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DINVC' , 'NORMAL',null);
825: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DINVCITM' , 'NORMAL',null);
826: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_ARINV' , 'NORMAL',null);
827:
820: -- truncate intermediate tables no longer required
821: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
822: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_FUNDG' , 'NORMAL',null);
823: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DREVN' , 'NORMAL',null);
824: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DINVC' , 'NORMAL',null);
825: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DINVCITM' , 'NORMAL',null);
826: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_ARINV' , 'NORMAL',null);
827:
828: commit;
821: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
822: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_FUNDG' , 'NORMAL',null);
823: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DREVN' , 'NORMAL',null);
824: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DINVC' , 'NORMAL',null);
825: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DINVCITM' , 'NORMAL',null);
826: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_ARINV' , 'NORMAL',null);
827:
828: commit;
829:
822: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_FUNDG' , 'NORMAL',null);
823: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DREVN' , 'NORMAL',null);
824: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DINVC' , 'NORMAL',null);
825: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DINVCITM' , 'NORMAL',null);
826: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_ARINV' , 'NORMAL',null);
827:
828: commit;
829:
830: end BASE_SUMMARY;
840: begin
841:
842: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
843:
844: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT1', 'NORMAL',null);
845:
846: end CLEANUP;
847:
848: end PJI_FM_SUM_ACT;