DBA Data[Home] [Help]

APPS.PJI_FM_EXTR dependencies on PJI_FM_SUM_MAIN

Line 16: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

12: l_to_project_id number := 0;
13:
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_EXTR.EXTRACT_BATCH_FND(p_worker_id);')) then
19: return;
20: end if;

Line 51: PJI_FM_SUM_MAIN.g_null) FUNDING_CATEGORY

47: ,pf.project_id PROJECT_ID
48: ,agr.customer_id CUSTOMER_ID
49: ,trunc(pf.date_allocated) DATE_ALLOCATED
50: ,nvl(pf.funding_category,
51: PJI_FM_SUM_MAIN.g_null) FUNDING_CATEGORY
52: ,pf.projfunc_allocated_amount POU_ALLOCATED_AMOUNT
53: ,pf.project_allocated_amount PRJ_ALLOCATED_AMOUNT
54: ,pf.pji_summarized_flag PJI_SUMMARIZED_FLAG
55: ,pf.rowid ROW_ID

Line 56: ,ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) BATCH_ID

52: ,pf.projfunc_allocated_amount POU_ALLOCATED_AMOUNT
53: ,pf.project_allocated_amount PRJ_ALLOCATED_AMOUNT
54: ,pf.pji_summarized_flag PJI_SUMMARIZED_FLAG
55: ,pf.rowid ROW_ID
56: ,ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) BATCH_ID
57: FROM pji_fm_proj_batch_map bat
58: ,pa_project_fundings pf
59: ,pa_agreements_all agr
60: ,pa_project_customers cust

Line 83: PJI_FM_SUM_MAIN.g_null) FUNDING_CATEGORY

79: ,pf.project_id PROJECT_ID
80: ,agr.customer_id CUSTOMER_ID
81: ,trunc(pf.date_allocated) DATE_ALLOCATED
82: ,nvl(pf.funding_category,
83: PJI_FM_SUM_MAIN.g_null) FUNDING_CATEGORY
84: ,pf.projfunc_allocated_amount POU_ALLOCATED_AMOUNT
85: ,pf.project_allocated_amount PRJ_ALLOCATED_AMOUNT
86: ,pf.pji_summarized_flag PJI_SUMMARIZED_FLAG
87: ,pf.rowid ROW_ID

Line 88: ,ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) BATCH_ID

84: ,pf.projfunc_allocated_amount POU_ALLOCATED_AMOUNT
85: ,pf.project_allocated_amount PRJ_ALLOCATED_AMOUNT
86: ,pf.pji_summarized_flag PJI_SUMMARIZED_FLAG
87: ,pf.rowid ROW_ID
88: ,ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) BATCH_ID
89: FROM pji_fm_proj_batch_map bat
90: ,pa_project_fundings pf
91: ,pa_agreements_all agr
92: ,pa_project_customers cust

Line 114: PJI_FM_SUM_MAIN.g_null) FUNDING_CATEGORY

110: ,pf.project_id PROJECT_ID
111: ,agr.customer_id CUSTOMER_ID
112: ,trunc(pf.date_allocated) DATE_ALLOCATED
113: ,nvl(pf.funding_category,
114: PJI_FM_SUM_MAIN.g_null) FUNDING_CATEGORY
115: ,pf.projfunc_allocated_amount POU_ALLOCATED_AMOUNT
116: ,pf.project_allocated_amount PRJ_ALLOCATED_AMOUNT
117: ,pf.pji_summarized_flag PJI_SUMMARIZED_FLAG
118: ,pf.rowid ROW_ID

Line 119: ,ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) BATCH_ID

115: ,pf.projfunc_allocated_amount POU_ALLOCATED_AMOUNT
116: ,pf.project_allocated_amount PRJ_ALLOCATED_AMOUNT
117: ,pf.pji_summarized_flag PJI_SUMMARIZED_FLAG
118: ,pf.rowid ROW_ID
119: ,ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) BATCH_ID
120: FROM pji_fm_proj_batch_map bat
121: ,pa_project_fundings pf
122: ,pa_agreements_all agr
123: ,pa_project_customers cust

Line 148: PJI_FM_SUM_MAIN.g_null) FUNDING_CATEGORY

144: ,pf.project_id PROJECT_ID
145: ,agr.customer_id CUSTOMER_ID
146: ,trunc(pf.date_allocated) DATE_ALLOCATED
147: ,nvl(pf.funding_category,
148: PJI_FM_SUM_MAIN.g_null) FUNDING_CATEGORY
149: ,pf.projfunc_allocated_amount POU_ALLOCATED_AMOUNT
150: ,pf.project_allocated_amount PRJ_ALLOCATED_AMOUNT
151: ,pf.pji_summarized_flag PJI_SUMMARIZED_FLAG
152: ,pf.rowid ROW_ID

Line 153: ,ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) BATCH_ID

149: ,pf.projfunc_allocated_amount POU_ALLOCATED_AMOUNT
150: ,pf.project_allocated_amount PRJ_ALLOCATED_AMOUNT
151: ,pf.pji_summarized_flag PJI_SUMMARIZED_FLAG
152: ,pf.rowid ROW_ID
153: ,ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) BATCH_ID
154: FROM pji_fm_proj_batch_map bat
155: ,pa_project_fundings pf
156: ,pa_agreements_all agr
157: ,pa_project_customers cust

Line 185: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

181: l_process varchar2(30);
182:
183: begin
184:
185: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
186:
187: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
188: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);')) then
189: return;

Line 229: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

225: l_parallel_processes number;
226:
227: begin
228:
229: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
230:
231: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS(p_worker_id);')) then
232: return;
233: end if;

Line 236: (PJI_FM_SUM_MAIN.g_process, 'PARALLEL_PROCESSES');

232: return;
233: end if;
234:
235: l_parallel_processes := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
236: (PJI_FM_SUM_MAIN.g_process, 'PARALLEL_PROCESSES');
237:
238: select count(*)
239: into l_leftover_batches
240: from PJI_HELPER_BATCH_MAP

Line 303: where PROCESS_NAME like PJI_FM_SUM_MAIN.g_process || x and

299: for x in 2 .. l_parallel_processes loop
300:
301: update PJI_SYSTEM_PRC_STATUS
302: set STEP_STATUS = 'C'
303: where PROCESS_NAME like PJI_FM_SUM_MAIN.g_process || x and
304: STEP_NAME =
305: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS(p_worker_id);' and
306: START_DATE is null;
307:

Line 355: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

351: l_process varchar2(30);
352:
353: begin
354:
355: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
356:
357: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
358: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_POST(p_worker_id);')) then
359: return;

Line 388: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

384: l_transition_flag varchar2(1);
385:
386: begin
387:
388: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
389:
390: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_DREV(p_worker_id);')) then
391: return;
392: end if;

Line 397: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,

393:
394: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
395:
396: l_transition_flag :=
397: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
398: 'TRANSITION');
399:
400: INSERT /*+ APPEND */ INTO PJI_FM_EXTR_DREVN
401: (

Line 444: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) batch_id

440: , drv.gl_period_name gl_period_name
441: , -1 log_event_id
442: , drv.pji_summarized_flag PJI_SUMMARIZED_FLAG
443: , agr.customer_id customer_id
444: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) batch_id
445: FROM
446: pji_fm_proj_batch_map bat
447: , pa_draft_revenues_all drv
448: , pa_agreements_all agr

Line 485: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) batch_id

481: , drv.gl_period_name gl_period_name
482: , -1 log_event_id
483: , drv.pji_summarized_flag PJI_SUMMARIZED_FLAG
484: , agr.customer_id customer_id
485: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) batch_id
486: FROM
487: pji_fm_proj_batch_map bat
488: , pa_draft_revenues_all drv
489: , pa_agreements_all agr

Line 523: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) batch_id

519: , drv.gl_period_name gl_period_name
520: , -1 log_event_id
521: , drv.pji_summarized_flag PJI_SUMMARIZED_FLAG
522: , agr.customer_id customer_id
523: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) batch_id
524: FROM
525: pji_fm_proj_batch_map bat
526: , pa_draft_revenues_all drv
527: , pa_agreements_all agr

Line 562: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) batch_id

558: , drv.gl_period_name gl_period_name
559: , -1 log_event_id
560: , drv.pji_summarized_flag PJI_SUMMARIZED_FLAG
561: , agr.customer_id customer_id
562: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) batch_id
563: FROM
564: pji_fm_proj_batch_map bat
565: , pa_draft_revenues_all drv
566: , pa_agreements_all agr

Line 596: , to_date(log.attribute5, PJI_FM_SUM_MAIN.g_date_mask) pa_date

592: , to_number(log.event_object) project_id
593: , bat.project_type_class project_type_class
594: , to_number(log.attribute1) draft_revenue_num
595: , to_number(log.attribute4) agreement_id
596: , to_date(log.attribute5, PJI_FM_SUM_MAIN.g_date_mask) pa_date
597: , paprd.period_name pa_period_name
598: , to_date(log.attribute6, PJI_FM_SUM_MAIN.g_date_mask) gl_date
599: , glprd.period_name gl_period_name
600: , log.event_id log_event_id

Line 598: , to_date(log.attribute6, PJI_FM_SUM_MAIN.g_date_mask) gl_date

594: , to_number(log.attribute1) draft_revenue_num
595: , to_number(log.attribute4) agreement_id
596: , to_date(log.attribute5, PJI_FM_SUM_MAIN.g_date_mask) pa_date
597: , paprd.period_name pa_period_name
598: , to_date(log.attribute6, PJI_FM_SUM_MAIN.g_date_mask) gl_date
599: , glprd.period_name gl_period_name
600: , log.event_id log_event_id
601: , null pji_summarized_flag
602: , agr.customer_id customer_id

Line 603: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) batch_id

599: , glprd.period_name gl_period_name
600: , log.event_id log_event_id
601: , null pji_summarized_flag
602: , agr.customer_id customer_id
603: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold) batch_id
604: FROM
605: pa_pji_proj_events_log log
606: , pji_fm_proj_batch_map bat
607: , pa_agreements_all agr

Line 629: and to_date(log.attribute5, PJI_FM_SUM_MAIN.g_date_mask)

625: and bat.extraction_type = 'I'
626: and nvl(bat.PROJECT_ORG_ID,-1) = nvl(imp.org_id ,-1)
627: and imp.period_set_name = paprd.period_set_name
628: and imp.pa_period_type = paprd.period_type
629: and to_date(log.attribute5, PJI_FM_SUM_MAIN.g_date_mask)
630: between paprd.START_DATE and paprd.END_DATE
631: and imp.period_set_name = glprd.period_set_name
632: and imp.set_of_books_id = sob.set_of_books_id
633: and sob.accounted_period_type = glprd.period_type

Line 634: and to_date(log.attribute6, PJI_FM_SUM_MAIN.g_date_mask)

630: between paprd.START_DATE and paprd.END_DATE
631: and imp.period_set_name = glprd.period_set_name
632: and imp.set_of_books_id = sob.set_of_books_id
633: and sob.accounted_period_type = glprd.period_type
634: and to_date(log.attribute6, PJI_FM_SUM_MAIN.g_date_mask)
635: between glprd.START_DATE and glprd.END_DATE
636: ;
637:
638: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_DREV(p_worker_id);');

Line 654: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

650: l_process varchar2(30);
651:
652: begin
653:
654: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
655:
656: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
657: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);')) then
658: return;

Line 700: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

696: l_parallel_processes number;
697:
698: begin
699:
700: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
701:
702: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.MARK_EXTRACTED_DREV(p_worker_id);')) then
703: return;
704: end if;

Line 707: (PJI_FM_SUM_MAIN.g_process, 'PARALLEL_PROCESSES');

703: return;
704: end if;
705:
706: l_parallel_processes := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
707: (PJI_FM_SUM_MAIN.g_process, 'PARALLEL_PROCESSES');
708:
709: select count(*)
710: into l_leftover_batches
711: from PJI_HELPER_BATCH_MAP

Line 783: where PROCESS_NAME like PJI_FM_SUM_MAIN.g_process || x and

779: for x in 2 .. l_parallel_processes loop
780:
781: update PJI_SYSTEM_PRC_STATUS
782: set STEP_STATUS = 'C'
783: where PROCESS_NAME like PJI_FM_SUM_MAIN.g_process || x and
784: STEP_NAME =
785: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV(p_worker_id);' and
786: START_DATE is null;
787:

Line 835: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

831: l_process varchar2(30);
832:
833: begin
834:
835: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
836:
837: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
838: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV_POST(p_worker_id);')) then
839: return;

Line 867: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

863: l_min_date date;
864:
865: begin
866:
867: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
868:
869: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CDL_CRDL_FULL(p_worker_id);')) then
870: return;
871: end if;

Line 874: PJI_FM_SUM_MAIN.g_date_mask);

870: return;
871: end if;
872:
873: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
874: PJI_FM_SUM_MAIN.g_date_mask);
875:
876: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
877:
878: -- This cleanup is intentionally before the implicit commit so as not

Line 881: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROJ_PERF_FLAG'),

877:
878: -- This cleanup is intentionally before the implicit commit so as not
879: -- to interfere with the CDL extraction.
880: if (nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
881: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROJ_PERF_FLAG'),
882: 'N') = 'N' and
883: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
884: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_COST_FLAG'),
885: 'N') = 'N' and

Line 884: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_COST_FLAG'),

880: if (nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
881: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROJ_PERF_FLAG'),
882: 'N') = 'N' and
883: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
884: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_COST_FLAG'),
885: 'N') = 'N' and
886: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
887: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROFIT_FLAG'),
888: 'N') = 'N') then

Line 887: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROFIT_FLAG'),

883: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
884: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_COST_FLAG'),
885: 'N') = 'N' and
886: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
887: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROFIT_FLAG'),
888: 'N') = 'N') then
889: delete /*+ index (log, PA_PJI_PROJ_EVENTS_LOG_N1) */
890: from PA_PJI_PROJ_EVENTS_LOG log
891: where EVENT_TYPE = 'DRAFT_REVENUES';

Line 1079: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE

1075: 'COST', nvl(CnR.Work_Type_Id,-1),
1076: nvl(ei.Work_Type_Id, -1)) AS WORK_TYPE_ID
1077: , et.Expenditure_Type_ID AS EXP_EVT_TYPE_ID
1078: , et.Expenditure_Type AS EXPENDITURE_TYPE
1079: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE
1080: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION
1081: , et.Expenditure_Category AS EXPENDITURE_CATEGORY
1082: , et.Revenue_Category_Code AS REVENUE_CATEGORY
1083: , ei.Non_Labor_Resource AS NON_LABOR_RESOURCE

Line 1080: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION

1076: nvl(ei.Work_Type_Id, -1)) AS WORK_TYPE_ID
1077: , et.Expenditure_Type_ID AS EXP_EVT_TYPE_ID
1078: , et.Expenditure_Type AS EXPENDITURE_TYPE
1079: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE
1080: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION
1081: , et.Expenditure_Category AS EXPENDITURE_CATEGORY
1082: , et.Revenue_Category_Code AS REVENUE_CATEGORY
1083: , ei.Non_Labor_Resource AS NON_LABOR_RESOURCE
1084: , ei.Wip_Resource_ID AS BOM_LABOR_RESOURCE_ID

Line 1353: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

1349: l_min_date date;
1350:
1351: begin
1352:
1353: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
1354:
1355: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ERDL_FULL(p_worker_id);')) then
1356: return;
1357: end if;

Line 1360: PJI_FM_SUM_MAIN.g_date_mask);

1356: return;
1357: end if;
1358:
1359: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
1360: PJI_FM_SUM_MAIN.g_date_mask);
1361:
1362: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
1363:
1364: -- insert for erdl

Line 1448: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_TYPE

1444: , -1 AS JOB_ID
1445: , -1 AS VENDOR_ID
1446: , -1 AS WORK_TYPE_ID
1447: , evt.event_type_id AS EXP_EVT_TYPE_ID
1448: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_TYPE
1449: , evt.event_type AS EVENT_TYPE
1450: , evt.event_type_classification AS EVENT_TYPE_CLASSIFICATION
1451: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_CATEGORY
1452: , evt.revenue_category_code AS REVENUE_CATEGORY

Line 1451: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_CATEGORY

1447: , evt.event_type_id AS EXP_EVT_TYPE_ID
1448: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_TYPE
1449: , evt.event_type AS EVENT_TYPE
1450: , evt.event_type_classification AS EVENT_TYPE_CLASSIFICATION
1451: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_CATEGORY
1452: , evt.revenue_category_code AS REVENUE_CATEGORY
1453: , 'PJI$NULL' AS NON_LABOR_RESOURCE
1454: , -1 AS BOM_LABOR_RESOURCE_ID
1455: , -1 AS BOM_EQUIPMENT_RESOURCE_ID

Line 1457: , PJI_FM_SUM_MAIN.g_null AS SYSTEM_LINKAGE_FUNCTION

1453: , 'PJI$NULL' AS NON_LABOR_RESOURCE
1454: , -1 AS BOM_LABOR_RESOURCE_ID
1455: , -1 AS BOM_EQUIPMENT_RESOURCE_ID
1456: , -1 AS INVENTORY_ITEM_ID
1457: , PJI_FM_SUM_MAIN.g_null AS SYSTEM_LINKAGE_FUNCTION
1458: , 'Y' AS PJI_PROJECT_RECORD_FLAG
1459: , 'N' AS PJI_RESOURCE_RECORD_FLAG
1460: , -1 AS CODE_COMBINATION_ID
1461: , Greatest(drev.GL_Date,l_min_date) AS PRVDR_GL_DATE

Line 1557: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

1553: l_to_project_id number;
1554:
1555: begin
1556:
1557: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
1558:
1559: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CDL_ROWIDS(p_worker_id);')) then
1560: return;
1561: end if;

Line 1587: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold)

1583: , null
1584: , null
1585: , null
1586: , cdl.PJI_SUMMARIZED_FLAG
1587: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold)
1588: FROM
1589: PA_COST_DISTRIBUTION_LINES_ALL cdl
1590: WHERE
1591: cdl.LINE_TYPE in ('R', 'I') and

Line 1617: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold)

1613: , project_org_id
1614: , project_organization_id
1615: , project_type_class
1616: , pji_summarized_flag
1617: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold)
1618: FROM
1619: (
1620: SELECT /*+ ORDERED
1621: USE_NL(cdl)

Line 1681: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

1677: l_schema varchar2(30);
1678:
1679: begin
1680:
1681: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
1682:
1683: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CRDL_ROWIDS(p_worker_id);')) then
1684: return;
1685: end if;

Line 1767: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

1763: l_schema varchar2(30);
1764:
1765: begin
1766:
1767: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
1768:
1769: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ERDL_ROWIDS(p_worker_id);')) then
1770: return;
1771: end if;

Line 1871: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

1867: l_row_count number;
1868:
1869: begin
1870:
1871: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
1872:
1873: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CDL_AND_CRDL(p_worker_id);')) then
1874: return;
1875: end if;

Line 1878: PJI_FM_SUM_MAIN.g_date_mask);

1874: return;
1875: end if;
1876:
1877: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
1878: PJI_FM_SUM_MAIN.g_date_mask);
1879:
1880: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
1881:
1882: -- This cleanup is intentionally before the implicit commit so as not

Line 1885: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROJ_PERF_FLAG'),

1881:
1882: -- This cleanup is intentionally before the implicit commit so as not
1883: -- to interfere with the CDL extraction.
1884: if (nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1885: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROJ_PERF_FLAG'),
1886: 'N') = 'N' and
1887: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1888: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_COST_FLAG'),
1889: 'N') = 'N' and

Line 1888: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_COST_FLAG'),

1884: if (nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1885: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROJ_PERF_FLAG'),
1886: 'N') = 'N' and
1887: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1888: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_COST_FLAG'),
1889: 'N') = 'N' and
1890: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1891: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROFIT_FLAG'),
1892: 'N') = 'N') then

Line 1891: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROFIT_FLAG'),

1887: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1888: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_COST_FLAG'),
1889: 'N') = 'N' and
1890: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1891: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROFIT_FLAG'),
1892: 'N') = 'N') then
1893: delete /*+ index (log, PA_PJI_PROJ_EVENTS_LOG_N1) */
1894: from PA_PJI_PROJ_EVENTS_LOG log
1895: where EVENT_TYPE = 'DRAFT_REVENUES';

Line 2086: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE

2082: , nvl(exp.vendor_id, -1) AS VENDOR_ID
2083: , nvl(cdl.work_type_id, -1) AS WORK_TYPE_ID
2084: , et.expenditure_type_id AS EXP_EVT_TYPE_ID
2085: , et.expenditure_type AS EXPENDITURE_TYPE
2086: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE
2087: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION
2088: , et.expenditure_category AS EXPENDITURE_CATEGORY
2089: , et.revenue_category_code AS REVENUE_CATEGORY
2090: , ei.Non_Labor_Resource AS NON_LABOR_RESOURCE

Line 2087: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION

2083: , nvl(cdl.work_type_id, -1) AS WORK_TYPE_ID
2084: , et.expenditure_type_id AS EXP_EVT_TYPE_ID
2085: , et.expenditure_type AS EXPENDITURE_TYPE
2086: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE
2087: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION
2088: , et.expenditure_category AS EXPENDITURE_CATEGORY
2089: , et.revenue_category_code AS REVENUE_CATEGORY
2090: , ei.Non_Labor_Resource AS NON_LABOR_RESOURCE
2091: , ei.Wip_Resource_ID AS BOM_LABOR_RESOURCE_ID

Line 2210: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE

2206: , nvl(exp.vendor_id,-1) AS VENDOR_ID
2207: , nvl(ei.Work_type_ID, -1) AS WORK_TYPE_ID
2208: , et.Expenditure_Type_ID AS EXP_EVT_TYPE_ID
2209: , et.Expenditure_Type AS EXPENDITURE_TYPE
2210: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE
2211: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION
2212: , et.Expenditure_Category AS EXPENDITURE_CATEGORY
2213: , et.Revenue_Category_Code AS REVENUE_CATEGORY
2214: , ei.Non_Labor_Resource AS NON_LABOR_RESOURCE

Line 2211: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION

2207: , nvl(ei.Work_type_ID, -1) AS WORK_TYPE_ID
2208: , et.Expenditure_Type_ID AS EXP_EVT_TYPE_ID
2209: , et.Expenditure_Type AS EXPENDITURE_TYPE
2210: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE
2211: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION
2212: , et.Expenditure_Category AS EXPENDITURE_CATEGORY
2213: , et.Revenue_Category_Code AS REVENUE_CATEGORY
2214: , ei.Non_Labor_Resource AS NON_LABOR_RESOURCE
2215: , ei.Wip_Resource_ID AS BOM_LABOR_RESOURCE_ID

Line 2353: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

2349: l_process varchar2(30);
2350:
2351: begin
2352:
2353: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
2354:
2355: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
2356: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);')) then
2357: return;

Line 2397: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

2393: l_parallel_processes number;
2394:
2395: begin
2396:
2397: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
2398:
2399: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS(p_worker_id);')) then
2400: return;
2401: end if;

Line 2404: (PJI_FM_SUM_MAIN.g_process, 'PARALLEL_PROCESSES');

2400: return;
2401: end if;
2402:
2403: l_parallel_processes := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2404: (PJI_FM_SUM_MAIN.g_process, 'PARALLEL_PROCESSES');
2405:
2406: select count(*)
2407: into l_leftover_batches
2408: from PJI_HELPER_BATCH_MAP

Line 2471: where PROCESS_NAME like PJI_FM_SUM_MAIN.g_process || x and

2467: for x in 2 .. l_parallel_processes loop
2468:
2469: update PJI_SYSTEM_PRC_STATUS
2470: set STEP_STATUS = 'C'
2471: where PROCESS_NAME like PJI_FM_SUM_MAIN.g_process || x and
2472: STEP_NAME =
2473: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS(p_worker_id);' and
2474: START_DATE is null;
2475:

Line 2523: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

2519: l_process varchar2(30);
2520:
2521: begin
2522:
2523: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
2524:
2525: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
2526: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_POST(p_worker_id);')) then
2527: return;

Line 2559: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

2555: l_schema varchar2(30);
2556:
2557: begin
2558:
2559: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
2560:
2561: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ERDL(p_worker_id);')) then
2562: return;
2563: end if;

Line 2566: PJI_FM_SUM_MAIN.g_date_mask);

2562: return;
2563: end if;
2564:
2565: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
2566: PJI_FM_SUM_MAIN.g_date_mask);
2567:
2568: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
2569:
2570: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,

Line 2728: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_TYPE

2724: , -1 AS JOB_ID
2725: , -1 AS VENDOR_ID
2726: , -1 AS WORK_TYPE_ID
2727: , scope.Exp_Evt_Type_ID AS EXP_EVT_TYPE_ID
2728: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_TYPE
2729: , scope.Event_Type AS EVENT_TYPE
2730: , scope.Event_Type_Classification AS EVENT_TYPE_CLASSIFICATION
2731: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_CATEGORY
2732: , scope.Revenue_Category AS REVENUE_CATEGORY

Line 2731: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_CATEGORY

2727: , scope.Exp_Evt_Type_ID AS EXP_EVT_TYPE_ID
2728: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_TYPE
2729: , scope.Event_Type AS EVENT_TYPE
2730: , scope.Event_Type_Classification AS EVENT_TYPE_CLASSIFICATION
2731: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_CATEGORY
2732: , scope.Revenue_Category AS REVENUE_CATEGORY
2733: , 'PJI$NULL' AS NON_LABOR_RESOURCE
2734: , -1 AS BOM_LABOR_RESOURCE_ID
2735: , -1 AS BOM_EQUIPMENT_RESOURCE_ID

Line 2737: , PJI_FM_SUM_MAIN.g_null AS SYSTEM_LINKAGE_FUNCTION

2733: , 'PJI$NULL' AS NON_LABOR_RESOURCE
2734: , -1 AS BOM_LABOR_RESOURCE_ID
2735: , -1 AS BOM_EQUIPMENT_RESOURCE_ID
2736: , -1 AS INVENTORY_ITEM_ID
2737: , PJI_FM_SUM_MAIN.g_null AS SYSTEM_LINKAGE_FUNCTION
2738: , 'Y' AS PJI_PROJECT_RECORD_FLAG
2739: , 'N' AS PJI_RESOURCE_RECORD_FLAG
2740: , -1 AS CODE_COMBINATION_ID
2741: , Greatest(scope.GL_Date,l_min_date) AS PRVDR_GL_DATE

Line 2858: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

2854: l_to_project_id number := 0;
2855:
2856: begin
2857:
2858: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
2859:
2860: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_DINV(p_worker_id);')) then
2861: return;
2862: end if;

Line 3160: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

3156: l_extraction_type varchar2(15);
3157:
3158: begin
3159:
3160: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3161: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
3162:
3163: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.MARK_EXTRACTED_DINV_ROWS(p_worker_id);')) then
3164: return;

Line 3201: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

3197: l_to_project_id number := 0;
3198:
3199: begin
3200:
3201: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3202:
3203: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_DINVITEM(p_worker_id);')) then
3204: return;
3205: end if;

Line 3476: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

3472: l_extraction_type varchar2(30);
3473:
3474: begin
3475:
3476: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3477:
3478: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ARINV(p_worker_id);')) then
3479: return;
3480: end if;

Line 3512: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold)

3508: , amount_overdue_remaining
3509: , actual_date_closed
3510: , customer_id
3511: , pji_summarized_flag
3512: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold)
3513: from
3514: (SELECT /*+ ordered
3515: parallel(part)
3516: full(bat) use_hash(bat) */

Line 3571: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

3567: l_process varchar2(30);
3568:
3569: begin
3570:
3571: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3572:
3573: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
3574: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);')) then
3575: return;

Line 3615: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

3611: l_parallel_processes number;
3612:
3613: begin
3614:
3615: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3616:
3617: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES(p_worker_id);')) then
3618: return;
3619: end if;

Line 3622: (PJI_FM_SUM_MAIN.g_process, 'PARALLEL_PROCESSES');

3618: return;
3619: end if;
3620:
3621: l_parallel_processes := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
3622: (PJI_FM_SUM_MAIN.g_process, 'PARALLEL_PROCESSES');
3623:
3624: select count(*)
3625: into l_leftover_batches
3626: from PJI_HELPER_BATCH_MAP

Line 3691: where PROCESS_NAME like PJI_FM_SUM_MAIN.g_process || x and

3687: for x in 2 .. l_parallel_processes loop
3688:
3689: update PJI_SYSTEM_PRC_STATUS
3690: set STEP_STATUS = 'C'
3691: where PROCESS_NAME like PJI_FM_SUM_MAIN.g_process || x and
3692: STEP_NAME =
3693: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES(p_worker_id);' and
3694: START_DATE is null;
3695:

Line 3743: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

3739: l_process varchar2(30);
3740:
3741: begin
3742:
3743: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3744:
3745: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
3746: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_POST(p_worker_id);')) then
3747: return;