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 1081: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE

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

Line 1082: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION

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

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

1356: l_min_date date;
1357:
1358: begin
1359:
1360: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
1361:
1362: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ERDL_FULL(p_worker_id);')) then
1363: return;
1364: end if;

Line 1367: PJI_FM_SUM_MAIN.g_date_mask);

1363: return;
1364: end if;
1365:
1366: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
1367: PJI_FM_SUM_MAIN.g_date_mask);
1368:
1369: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
1370:
1371: -- insert for erdl

Line 1455: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_TYPE

1451: , -1 AS JOB_ID
1452: , -1 AS VENDOR_ID
1453: , -1 AS WORK_TYPE_ID
1454: , evt.event_type_id AS EXP_EVT_TYPE_ID
1455: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_TYPE
1456: , evt.event_type AS EVENT_TYPE
1457: , evt.event_type_classification AS EVENT_TYPE_CLASSIFICATION
1458: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_CATEGORY
1459: , evt.revenue_category_code AS REVENUE_CATEGORY

Line 1458: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_CATEGORY

1454: , evt.event_type_id AS EXP_EVT_TYPE_ID
1455: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_TYPE
1456: , evt.event_type AS EVENT_TYPE
1457: , evt.event_type_classification AS EVENT_TYPE_CLASSIFICATION
1458: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_CATEGORY
1459: , evt.revenue_category_code AS REVENUE_CATEGORY
1460: , 'PJI$NULL' AS NON_LABOR_RESOURCE
1461: , -1 AS BOM_LABOR_RESOURCE_ID
1462: , -1 AS BOM_EQUIPMENT_RESOURCE_ID

Line 1464: , PJI_FM_SUM_MAIN.g_null AS SYSTEM_LINKAGE_FUNCTION

1460: , 'PJI$NULL' AS NON_LABOR_RESOURCE
1461: , -1 AS BOM_LABOR_RESOURCE_ID
1462: , -1 AS BOM_EQUIPMENT_RESOURCE_ID
1463: , -1 AS INVENTORY_ITEM_ID
1464: , PJI_FM_SUM_MAIN.g_null AS SYSTEM_LINKAGE_FUNCTION
1465: , 'Y' AS PJI_PROJECT_RECORD_FLAG
1466: , 'N' AS PJI_RESOURCE_RECORD_FLAG
1467: , -1 AS CODE_COMBINATION_ID
1468: , Greatest(drev.GL_Date,l_min_date) AS PRVDR_GL_DATE

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

1560: l_to_project_id number;
1561:
1562: begin
1563:
1564: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
1565:
1566: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CDL_ROWIDS(p_worker_id);')) then
1567: return;
1568: end if;

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

1590: , null
1591: , null
1592: , null
1593: , cdl.PJI_SUMMARIZED_FLAG
1594: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold)
1595: FROM
1596: PA_COST_DISTRIBUTION_LINES_ALL cdl
1597: WHERE
1598: cdl.LINE_TYPE in ('R', 'I') and

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

1620: , project_org_id
1621: , project_organization_id
1622: , project_type_class
1623: , pji_summarized_flag
1624: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold)
1625: FROM
1626: (
1627: SELECT /*+ ORDERED
1628: USE_NL(cdl)

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

1684: l_schema varchar2(30);
1685:
1686: begin
1687:
1688: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
1689:
1690: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CRDL_ROWIDS(p_worker_id);')) then
1691: return;
1692: end if;

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

1770: l_schema varchar2(30);
1771:
1772: begin
1773:
1774: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
1775:
1776: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ERDL_ROWIDS(p_worker_id);')) then
1777: return;
1778: end if;

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

1874: l_row_count number;
1875:
1876: begin
1877:
1878: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
1879:
1880: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CDL_AND_CRDL(p_worker_id);')) then
1881: return;
1882: end if;

Line 1885: PJI_FM_SUM_MAIN.g_date_mask);

1881: return;
1882: end if;
1883:
1884: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
1885: PJI_FM_SUM_MAIN.g_date_mask);
1886:
1887: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
1888:
1889: -- This cleanup is intentionally before the implicit commit so as not

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

1888:
1889: -- This cleanup is intentionally before the implicit commit so as not
1890: -- to interfere with the CDL extraction.
1891: if (nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1892: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROJ_PERF_FLAG'),
1893: 'N') = 'N' and
1894: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1895: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_COST_FLAG'),
1896: 'N') = 'N' and

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

1891: if (nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1892: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROJ_PERF_FLAG'),
1893: 'N') = 'N' and
1894: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1895: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_COST_FLAG'),
1896: 'N') = 'N' and
1897: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1898: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROFIT_FLAG'),
1899: 'N') = 'N') then

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

1894: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1895: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_COST_FLAG'),
1896: 'N') = 'N' and
1897: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1898: (PJI_FM_SUM_MAIN.g_process, 'CONFIG_PROFIT_FLAG'),
1899: 'N') = 'N') then
1900: delete /*+ index (log, PA_PJI_PROJ_EVENTS_LOG_N1) */
1901: from PA_PJI_PROJ_EVENTS_LOG log
1902: where EVENT_TYPE = 'DRAFT_REVENUES';

Line 2095: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE

2091: , nvl(exp.vendor_id, -1) AS VENDOR_ID
2092: , nvl(cdl.work_type_id, -1) AS WORK_TYPE_ID
2093: , et.expenditure_type_id AS EXP_EVT_TYPE_ID
2094: , et.expenditure_type AS EXPENDITURE_TYPE
2095: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE
2096: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION
2097: , et.expenditure_category AS EXPENDITURE_CATEGORY
2098: , et.revenue_category_code AS REVENUE_CATEGORY
2099: , ei.Non_Labor_Resource AS NON_LABOR_RESOURCE

Line 2096: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION

2092: , nvl(cdl.work_type_id, -1) AS WORK_TYPE_ID
2093: , et.expenditure_type_id AS EXP_EVT_TYPE_ID
2094: , et.expenditure_type AS EXPENDITURE_TYPE
2095: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE
2096: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION
2097: , et.expenditure_category AS EXPENDITURE_CATEGORY
2098: , et.revenue_category_code AS REVENUE_CATEGORY
2099: , ei.Non_Labor_Resource AS NON_LABOR_RESOURCE
2100: , ei.Wip_Resource_ID AS BOM_LABOR_RESOURCE_ID

Line 2221: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE

2217: , nvl(exp.vendor_id,-1) AS VENDOR_ID
2218: , nvl(ei.Work_type_ID, -1) AS WORK_TYPE_ID
2219: , et.Expenditure_Type_ID AS EXP_EVT_TYPE_ID
2220: , et.Expenditure_Type AS EXPENDITURE_TYPE
2221: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE
2222: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION
2223: , et.Expenditure_Category AS EXPENDITURE_CATEGORY
2224: , et.Revenue_Category_Code AS REVENUE_CATEGORY
2225: , ei.Non_Labor_Resource AS NON_LABOR_RESOURCE

Line 2222: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION

2218: , nvl(ei.Work_type_ID, -1) AS WORK_TYPE_ID
2219: , et.Expenditure_Type_ID AS EXP_EVT_TYPE_ID
2220: , et.Expenditure_Type AS EXPENDITURE_TYPE
2221: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE
2222: , PJI_FM_SUM_MAIN.g_null AS EVENT_TYPE_CLASSIFICATION
2223: , et.Expenditure_Category AS EXPENDITURE_CATEGORY
2224: , et.Revenue_Category_Code AS REVENUE_CATEGORY
2225: , ei.Non_Labor_Resource AS NON_LABOR_RESOURCE
2226: , ei.Wip_Resource_ID AS BOM_LABOR_RESOURCE_ID

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

2362: l_process varchar2(30);
2363:
2364: begin
2365:
2366: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
2367:
2368: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
2369: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);')) then
2370: return;

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

2406: l_parallel_processes number;
2407:
2408: begin
2409:
2410: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
2411:
2412: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS(p_worker_id);')) then
2413: return;
2414: end if;

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

2413: return;
2414: end if;
2415:
2416: l_parallel_processes := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2417: (PJI_FM_SUM_MAIN.g_process, 'PARALLEL_PROCESSES');
2418:
2419: select count(*)
2420: into l_leftover_batches
2421: from PJI_HELPER_BATCH_MAP

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

2480: for x in 2 .. l_parallel_processes loop
2481:
2482: update PJI_SYSTEM_PRC_STATUS
2483: set STEP_STATUS = 'C'
2484: where PROCESS_NAME like PJI_FM_SUM_MAIN.g_process || x and
2485: STEP_NAME =
2486: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS(p_worker_id);' and
2487: START_DATE is null;
2488:

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

2532: l_process varchar2(30);
2533:
2534: begin
2535:
2536: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
2537:
2538: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
2539: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_POST(p_worker_id);')) then
2540: return;

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

2568: l_schema varchar2(30);
2569:
2570: begin
2571:
2572: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
2573:
2574: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ERDL(p_worker_id);')) then
2575: return;
2576: end if;

Line 2579: PJI_FM_SUM_MAIN.g_date_mask);

2575: return;
2576: end if;
2577:
2578: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
2579: PJI_FM_SUM_MAIN.g_date_mask);
2580:
2581: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
2582:
2583: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,

Line 2741: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_TYPE

2737: , -1 AS JOB_ID
2738: , -1 AS VENDOR_ID
2739: , -1 AS WORK_TYPE_ID
2740: , scope.Exp_Evt_Type_ID AS EXP_EVT_TYPE_ID
2741: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_TYPE
2742: , scope.Event_Type AS EVENT_TYPE
2743: , scope.Event_Type_Classification AS EVENT_TYPE_CLASSIFICATION
2744: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_CATEGORY
2745: , scope.Revenue_Category AS REVENUE_CATEGORY

Line 2744: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_CATEGORY

2740: , scope.Exp_Evt_Type_ID AS EXP_EVT_TYPE_ID
2741: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_TYPE
2742: , scope.Event_Type AS EVENT_TYPE
2743: , scope.Event_Type_Classification AS EVENT_TYPE_CLASSIFICATION
2744: , PJI_FM_SUM_MAIN.g_null AS EXPENDITURE_CATEGORY
2745: , scope.Revenue_Category AS REVENUE_CATEGORY
2746: , 'PJI$NULL' AS NON_LABOR_RESOURCE
2747: , -1 AS BOM_LABOR_RESOURCE_ID
2748: , -1 AS BOM_EQUIPMENT_RESOURCE_ID

Line 2750: , PJI_FM_SUM_MAIN.g_null AS SYSTEM_LINKAGE_FUNCTION

2746: , 'PJI$NULL' AS NON_LABOR_RESOURCE
2747: , -1 AS BOM_LABOR_RESOURCE_ID
2748: , -1 AS BOM_EQUIPMENT_RESOURCE_ID
2749: , -1 AS INVENTORY_ITEM_ID
2750: , PJI_FM_SUM_MAIN.g_null AS SYSTEM_LINKAGE_FUNCTION
2751: , 'Y' AS PJI_PROJECT_RECORD_FLAG
2752: , 'N' AS PJI_RESOURCE_RECORD_FLAG
2753: , -1 AS CODE_COMBINATION_ID
2754: , Greatest(scope.GL_Date,l_min_date) AS PRVDR_GL_DATE

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

2867: l_to_project_id number := 0;
2868:
2869: begin
2870:
2871: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
2872:
2873: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_DINV(p_worker_id);')) then
2874: return;
2875: end if;

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

3169: l_extraction_type varchar2(15);
3170:
3171: begin
3172:
3173: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3174: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
3175:
3176: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.MARK_EXTRACTED_DINV_ROWS(p_worker_id);')) then
3177: return;

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

3210: l_to_project_id number := 0;
3211:
3212: begin
3213:
3214: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3215:
3216: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_DINVITEM(p_worker_id);')) then
3217: return;
3218: end if;

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

3485: l_extraction_type varchar2(30);
3486:
3487: begin
3488:
3489: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3490:
3491: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ARINV(p_worker_id);')) then
3492: return;
3493: end if;

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

3521: , amount_overdue_remaining
3522: , actual_date_closed
3523: , customer_id
3524: , pji_summarized_flag
3525: , ceil(ROWNUM / PJI_FM_SUM_MAIN.g_commit_threshold)
3526: from
3527: (SELECT /*+ ordered
3528: parallel(part)
3529: full(bat) use_hash(bat) */

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

3580: l_process varchar2(30);
3581:
3582: begin
3583:
3584: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3585:
3586: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
3587: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);')) then
3588: return;

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

3624: l_parallel_processes number;
3625:
3626: begin
3627:
3628: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3629:
3630: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES(p_worker_id);')) then
3631: return;
3632: end if;

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

3631: return;
3632: end if;
3633:
3634: l_parallel_processes := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
3635: (PJI_FM_SUM_MAIN.g_process, 'PARALLEL_PROCESSES');
3636:
3637: select count(*)
3638: into l_leftover_batches
3639: from PJI_HELPER_BATCH_MAP

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

3700: for x in 2 .. l_parallel_processes loop
3701:
3702: update PJI_SYSTEM_PRC_STATUS
3703: set STEP_STATUS = 'C'
3704: where PROCESS_NAME like PJI_FM_SUM_MAIN.g_process || x and
3705: STEP_NAME =
3706: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES(p_worker_id);' and
3707: START_DATE is null;
3708:

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

3752: l_process varchar2(30);
3753:
3754: begin
3755:
3756: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3757:
3758: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
3759: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_POST(p_worker_id);')) then
3760: return;