[Home] [Help]
44867: l_fpm_upgrade varchar2(30) := p_fpm_upgrade;
44868:
44869: cursor batch is
44870: select distinct batch_id,worker_id
44871: from pji_helper_420
44872: where worker_id = PJI_PJP_FP_CURR_WRAP.GET_WORKER_ID
44873: order by batch_id;
44874:
44875: BEGIN
44877: l_parallel_proc := nvl(fnd_profile.value('PJI_EXTRACTION_PARALLELISM'), 1);
44878:
44879: g_worker_id := PJI_PJP_FP_CURR_WRAP.GET_WORKER_ID;
44880:
44881: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema, 'PJI_HELPER_420','NORMAL',l_partition_name);
44882: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema, 'PJI_BATCH_STATUS_420','NORMAL',l_partition_name);
44883:
44884:
44885: insert into pji_helper_420 (worker_id, project_id, batch_id, level_420, partial_mode_420, fpm_upgrade_420)
44881: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema, 'PJI_HELPER_420','NORMAL',l_partition_name);
44882: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema, 'PJI_BATCH_STATUS_420','NORMAL',l_partition_name);
44883:
44884:
44885: insert into pji_helper_420 (worker_id, project_id, batch_id, level_420, partial_mode_420, fpm_upgrade_420)
44886: (select worker_id, project_id, ceil(ROWNUM / l_batch_size) batch_id, l_level, l_partial_mode, l_fpm_upgrade
44887: FROM pji_pjp_proj_batch_map
44888: WHERE worker_id = g_worker_id );
44889:
44890:
44891: SELECT /*+ parallel(pji_merge_helper) */
44892: COUNT(DISTINCT batch_id)
44893: INTO l_batch_count
44894: FROM pji_helper_420
44895: where worker_id = g_worker_id;
44896:
44897: if l_batch_count > 0 then
44898:
44903:
44904: l_request_id := FND_REQUEST.SUBMIT_REQUEST
44905: (
44906: application => 'PJI',
44907: program => 'PJI_HELPER_420',
44908: sub_request => false,
44909: argument1 => rec.batch_id
44910: );
44911: commit;
45004: FOR i IN l_Batch_t.first..l_Batch_t.last LOOP
45005:
45006: IF (l_Batch_t(i).request_id > 0 ) THEN
45007: IF (PJI_PROCESS_UTIL.REQUEST_STATUS('OKAY',
45008: l_Batch_t(i).request_id,'PJI_HELPER_420')) THEN
45009: IF (PJI_PROCESS_UTIL.REQUEST_STATUS('RUNNING',
45010: l_Batch_t(i).request_id,'PJI_HELPER_420')) THEN
45011: l_Batch_t(i).request_status := 'RUNNING';
45012: ELSE
45006: IF (l_Batch_t(i).request_id > 0 ) THEN
45007: IF (PJI_PROCESS_UTIL.REQUEST_STATUS('OKAY',
45008: l_Batch_t(i).request_id,'PJI_HELPER_420')) THEN
45009: IF (PJI_PROCESS_UTIL.REQUEST_STATUS('RUNNING',
45010: l_Batch_t(i).request_id,'PJI_HELPER_420')) THEN
45011: l_Batch_t(i).request_status := 'RUNNING';
45012: ELSE
45013: l_Batch_t(i).request_status := 'COMPLETED';
45014: END IF;
45055: worker_id,
45056: level_420,
45057: partial_mode_420,
45058: fpm_upgrade_420
45059: from pji_helper_420
45060: where batch_id = x_batch_id;
45061:
45062:
45063: BEGIN
46040: pjp1.CUSTOM14,
46041: pjp1.CUSTOM15
46042: from
46043: PJI_FP_AGGR_PJP1 pjp1,
46044: PJI_HELPER_420 helper,
46045: PJI_PJP_WBS_HEADER_T wbs_hdr,
46046: PA_XBS_DENORM wbs,
46047: PJI_XBS_DENORM_T prg,
46048: (
46197: pjp1.CUSTOM14,
46198: pjp1.CUSTOM15
46199: from
46200: PJI_FP_AGGR_PJP1 pjp1,
46201: PJI_HELPER_420 helper, -- order in the From clause should not be changed unless recommended by perf team
46202: PJI_PJP_WBS_HEADER_T wbs_hdr,
46203: PJI_XBS_DENORM_T prg,
46204: (
46205: select 'Y' CB_FLAG,
46351: wbs.SIGN * fpr.CUSTOM14 CUSTOM14,
46352: wbs.SIGN * fpr.CUSTOM15 CUSTOM15
46353: from
46354: PJI_PA_PROJ_EVENTS_LOG log,
46355: PJI_HELPER_420 helper,
46356: PJI_PJP_WBS_HEADER_T wbs_hdr,
46357: PJI_XBS_DENORM_DELTA wbs,
46358: PJI_XBS_DENORM_T prg,
46359: PJI_FP_XBS_ACCUM_F fpr,
46583:
46584: -- x_row_id.delete;
46585: -- xf_row_id.delete;
46586: delete
46587: from pji_helper_420
46588: where batch_id = p_batch_id;
46589:
46590: update pji_batch_status_420
46591: set request_status = 'COMPLETED'