[Home] [Help]
25: -- updated by multiple Project Intelligence data extraction processes running
26: -- in parallel.
27: -- In order to isolate the process from changes made to the table by
28: -- other extraction programs we create a snapshot of this table in
29: -- PJI_RM_ORG_BATCH_MAP. PJI_RM_ORG_BATCH_MAP is also used to partition
30: -- processing scope into batches.
31: --
32: -- Processing itself consists of two major stages. First, we process orgs
33: -- for which we never extracted fi information before. One of reasons to
483: fid.EXPENDITURE_ORGANIZATION_ID = org.ORGANIZATION_ID);
484:
485: if (l_extraction_type = 'INCREMENTAL' ) then
486:
487: insert into pji_rm_org_batch_map (
488: worker_id,
489: organization_id,
490: start_date,
491: end_date,
507: elsif (l_extraction_type = 'PARTIAL') then
508:
509: if (p_include_sub_org = 'Y') then
510:
511: insert into PJI_RM_ORG_BATCH_MAP
512: (
513: WORKER_ID,
514: ORGANIZATION_ID,
515: START_DATE,
534: sts.STATUS = 'X';
535:
536: else
537:
538: insert into PJI_RM_ORG_BATCH_MAP
539: (
540: WORKER_ID,
541: ORGANIZATION_ID,
542: START_DATE,
561: end if;
562:
563: elsif (l_extraction_type = 'FULL') then
564:
565: insert into PJI_RM_ORG_BATCH_MAP
566: (
567: WORKER_ID,
568: ORGANIZATION_ID,
569: EXTRACTION_TYPE,
588: update PJI_ORG_EXTR_STATUS
589: set STATUS = 'X'
590: where l_extraction_type in ('FULL', 'INCREMENTAL') and
591: ORGANIZATION_ID IN (select map.ORGANIZATION_ID
592: from PJI_RM_ORG_BATCH_MAP map
593: where map.WORKER_ID = 1) and
594: STATUS is null;
595:
596: l_global_start_date := PJI_UTILS.GET_EXTRACTION_START_DATE;
1415:
1416: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
1417:
1418: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1419: 'PJI_RM_ORG_BATCH_MAP','NORMAL',null);
1420:
1421: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1422: 'PJI_PJI_PROJ_BATCH_MAP','NORMAL',null);
1423: