[Home] [Help]
71: CREATED_BY,
72: LAST_UPDATE_LOGIN,
73: PLAN_TYPE_CODE
74: from PJI_PJP_WBS_HEADER a
75: where a.project_id in ( select b.project_id from PJI_PJP_PROJ_BATCH_MAP b
76: where b.worker_id = p_worker_id );
77:
78: insert into PJI_PA_XBS_DENORM_T
79: (STRUCT_TYPE,
118: STRUCT_EMT_ID,
119: RELATIONSHIP_TYPE
120: from PA_XBS_DENORM a
121: -- Bug 12763391 - a.struct_type join should be outside the bracket
122: -- join to PJI_PJP_PROJ_BATCH_MAP is not needed since PJI_PJP_WBS_HEADER_T has
123: -- the rows filtered based on join to PJI_PJP_PROJ_BATCH_MAP and the worker_id
124: where a.STRUCT_VERSION_ID in ( select b.wbs_VERSION_ID
125: from PJI_PJP_WBS_HEADER_T b
126: )
119: RELATIONSHIP_TYPE
120: from PA_XBS_DENORM a
121: -- Bug 12763391 - a.struct_type join should be outside the bracket
122: -- join to PJI_PJP_PROJ_BATCH_MAP is not needed since PJI_PJP_WBS_HEADER_T has
123: -- the rows filtered based on join to PJI_PJP_PROJ_BATCH_MAP and the worker_id
124: where a.STRUCT_VERSION_ID in ( select b.wbs_VERSION_ID
125: from PJI_PJP_WBS_HEADER_T b
126: )
127: and a.struct_type||'' = 'WBS'||'';
170: STRUCT_EMT_ID,
171: RELATIONSHIP_TYPE
172: from PJI_XBS_DENORM a
173: where a.SUP_PROJECT_ID in ( select distinct b.SUP_PROJECT_ID
174: from PJI_PA_XBS_DENORM_T b, PJI_PJP_PROJ_BATCH_MAP c
175: where c.worker_id = p_worker_id
176: and b.sup_project_id = c.project_id);
177:
178: insert into PJI_XBS_DENORM_T
218: STRUCT_EMT_ID,
219: RELATIONSHIP_TYPE
220: from PJI_XBS_DENORM a
221: where a.SUP_PROJECT_ID in ( select b.PROJECT_ID
222: from PJI_PJP_PROJ_BATCH_MAP b
223: where b.worker_id = p_worker_id )
224: and not exists ( select 'x' from PJI_PJP_PROJ_BATCH_MAP c
225: where c.worker_id = p_worker_id and c.project_id = a.sup_project_id );
226:
220: from PJI_XBS_DENORM a
221: where a.SUP_PROJECT_ID in ( select b.PROJECT_ID
222: from PJI_PJP_PROJ_BATCH_MAP b
223: where b.worker_id = p_worker_id )
224: and not exists ( select 'x' from PJI_PJP_PROJ_BATCH_MAP c
225: where c.worker_id = p_worker_id and c.project_id = a.sup_project_id );
226:
227: while (lv_level > 0) loop
228:
1426: 'LW', 'Y',
1427: 'LF', 'N') WP_FLAG,
1428: 'Y' PUSHUP_FLAG
1429: from
1430: PJI_PJP_PROJ_BATCH_MAP map,
1431: -- Commenting and adding code for testing 0802
1432: PJI_XBS_DENORM_T prg,
1433: --PJI_XBS_DENORM prg,
1434: -- End of Commenting and adding code for testing 0802
2806: 'LW', 'Y',
2807: 'LF', 'N') WP_FLAG,
2808: 'Y' PUSHUP_FLAG
2809: from
2810: PJI_PJP_PROJ_BATCH_MAP map,
2811: PJI_XBS_DENORM prg,
2812: (
2813: select 'LF' INVERT_ID, 'LF' INVERT_VALUE from dual union all
2814: select 'LW' INVERT_ID, 'LW' INVERT_VALUE from dual union all
3056: log.ATTRIBUTE18,
3057: log.ATTRIBUTE19,
3058: log.ATTRIBUTE20
3059: from
3060: PJI_PJP_PROJ_BATCH_MAP map,
3061: PA_PJI_PROJ_EVENTS_LOG log,
3062: PA_RBS_VERSIONS_B ver
3063: where
3064: map.WORKER_ID = p_worker_id and
3098: log.ATTRIBUTE18,
3099: log.ATTRIBUTE19,
3100: log.ATTRIBUTE20
3101: from
3102: PJI_PJP_PROJ_BATCH_MAP map,
3103: PA_PJI_PROJ_EVENTS_LOG log
3104: where
3105: map.WORKER_ID = p_worker_id and
3106: log.EVENT_TYPE = 'PRG_CHANGE' and
3142: select /*+ ordered index(ver PA_PROJ_ELEMENT_VERSIONS_N3) */
3143: distinct
3144: ver.PRG_GROUP
3145: from
3146: PJI_PJP_PROJ_BATCH_MAP map,
3147: PA_PROJ_ELEMENT_VERSIONS ver
3148: where
3149: map.WORKER_ID = p_worker_id and
3150: map.PROJECT_ID = ver.PROJECT_ID and
3194: distinct
3195: asg.RBS_HEADER_ID,
3196: asg.RBS_VERSION_ID
3197: from
3198: PJI_PJP_PROJ_BATCH_MAP map,
3199: PA_RBS_PRJ_ASSIGNMENTS asg
3200: where
3201: map.WORKER_ID = p_worker_id and
3202: asg.PROJECT_ID = map.PROJECT_ID and
3207: distinct
3208: rbs.RBS_HEADER_ID,
3209: rbs.RBS_VERSION_ID
3210: from
3211: PJI_PJP_PROJ_BATCH_MAP map,
3212: PA_PROJECTS_ALL prj,
3213: PA_RBS_VERSIONS_B rbs,
3214: PA_PJI_PROJ_EVENTS_LOG log
3215: where
3254: log.ATTRIBUTE18,
3255: log.ATTRIBUTE19,
3256: log.ATTRIBUTE20
3257: from
3258: PJI_PJP_PROJ_BATCH_MAP map,
3259: PA_RBS_PRJ_ASSIGNMENTS asg,
3260: PA_PJI_PROJ_EVENTS_LOG log
3261: where
3262: map.WORKER_ID = p_worker_id and
3366: log.ATTRIBUTE19,
3367: log.ATTRIBUTE20
3368: from
3369: PA_PJI_PROJ_EVENTS_LOG log,
3370: PJI_PJP_PROJ_BATCH_MAP map
3371: where
3372: map.WORKER_ID = p_worker_id and
3373: log.EVENT_TYPE = 'PRG_CHANGE' and
3374: log.EVENT_OBJECT = -1 and
4338: cursor required_rbs (p_worker_id in number) is
4339: select
4340: distinct asg.RBS_VERSION_ID -- bug 6892644
4341: from
4342: PJI_PJP_PROJ_BATCH_MAP map,
4343: PA_RBS_PRJ_ASSIGNMENTS asg
4344: where
4345: map.WORKER_ID = p_worker_id and
4346: asg.PROJECT_ID = map.PROJECT_ID and
4514: l_creation_date,
4515: l_created_by,
4516: l_last_update_login
4517: from
4518: PJI_PJP_PROJ_BATCH_MAP map,
4519: PA_XBS_DENORM pa
4520: where
4521: map.WORKER_ID = p_worker_id and
4522: pa.SUP_PROJECT_ID = map.PROJECT_ID and
4573: l_creation_date,
4574: l_created_by,
4575: l_last_update_login
4576: from
4577: PJI_PJP_PROJ_BATCH_MAP map,
4578: PA_XBS_DENORM pa
4579: where
4580: map.WORKER_ID = p_worker_id and
4581: pa.SUP_PROJECT_ID = map.PROJECT_ID and
4594:
4595: delete
4596: from PJI_REP_XBS_DENORM;
4597: -- where PROJECT_ID in (select map.PROJECT_ID
4598: -- from PJI_PJP_PROJ_BATCH_MAP map
4599: -- where map.WORKER_ID = p_worker_id);
4600:
4601: end if;
4602:
4738: select
4739: distinct
4740: prj_emt.PROJECT_ID
4741: from
4742: PJI_PJP_PROJ_BATCH_MAP map,
4743: PA_PROJ_ELEMENTS prj_emt
4744: where
4745: map.WORKER_ID = p_worker_id and
4746: prj_emt.OBJECT_TYPE = 'PA_STRUCTURES' and
4762: wbs_hdr.LAST_UPDATED_BY = l_last_updated_by,
4763: wbs_hdr.LAST_UPDATE_LOGIN = l_last_update_login
4764: where wbs_hdr.PROJECT_ID in
4765: (select map.PROJECT_ID
4766: from PJI_PJP_PROJ_BATCH_MAP map
4767: where map.WORKER_ID = p_worker_id) and
4768: wbs_hdr.PLAN_VERSION_ID = -1 and
4769: wbs_hdr.WBS_VERSION_ID in
4770: (select log.EVENT_OBJECT
5042: 'N') PROG_REP_USAGE_FLAG,
5043: 'Y' REPORTING_USAGE_FLAG,
5044: 'N' FP_USAGE_FLAG
5045: from
5046: PJI_PJP_PROJ_BATCH_MAP map,
5047: PA_RBS_PRJ_ASSIGNMENTS asg,
5048: PA_XBS_DENORM den1,
5049: PA_XBS_DENORM den2
5050: where
5277: l_created_by,
5278: l_last_update_login,
5279: 'A'
5280: from
5281: PJI_PJP_PROJ_BATCH_MAP map,
5282: PA_RBS_PRJ_ASSIGNMENTS asg,
5283: PJI_PJP_RBS_HEADER rbs_hdr
5284: where
5285: map.WORKER_ID = p_worker_id and
5318: l_created_by,
5319: l_last_update_login,
5320: 'A'
5321: from
5322: PJI_PJP_PROJ_BATCH_MAP map
5323: where
5324: map.WORKER_ID = p_worker_id;
5325:
5326: elsif (l_extraction_type = 'INCREMENTAL' or
7005: to_number(null) G2_OTH_COMMITTED_COST,
7006: bal.QUANTITY,
7007: bal.BILL_QUANTITY
7008: from
7009: PJI_PJP_PROJ_BATCH_MAP map,
7010: PJI_FP_TXN_ACCUM bal,
7011: PJI_PJP_RBS_HEADER rbs_hdr
7012: where
7013: l_extraction_type in ('FULL', 'PARTIAL') and
7086: bal.G2_OTH_COMMITTED_COST,
7087: to_number(null) QUANTITY,
7088: to_number(null) BILL_QUANTITY
7089: from
7090: PJI_PJP_PROJ_BATCH_MAP map,
7091: PJI_FP_TXN_ACCUM1 bal,
7092: PJI_PJP_RBS_HEADER rbs_hdr
7093: where
7094: l_extraction_type in ('FULL', 'PARTIAL') and
7520: src1.TXN_CURRENCY_CODE
7521: ) src2
7522: ) src,
7523: PA_RBS_TXN_ACCUM_MAP rbs,
7524: PJI_PJP_PROJ_BATCH_MAP map,
7525: PJI_ORG_EXTR_INFO info,
7526: PJI_PJP_WBS_HEADER wbs_hdr,
7527: PA_PROJ_ELEMENT_VERSIONS ver,
7528: (
8221: prj.PROJECT_CURRENCY_CODE,
8222: src.TXN_CURRENCY_CODE
8223: )
8224: ) src,
8225: PJI_PJP_PROJ_BATCH_MAP map,
8226: PJI_PJP_WBS_HEADER wbs_hdr,
8227: PA_PROJ_ELEMENT_VERSIONS ver,
8228: (
8229: select 1 INVERT_ID from dual
8329:
8330: if (l_extraction_type = 'PARTIAL' or
8331: l_extraction_type = 'RBS') then
8332:
8333: update PJI_PJP_PROJ_BATCH_MAP
8334: set PJI_PROJECT_STATUS = 'Y'
8335: where WORKER_ID = p_worker_id and
8336: PJI_PROJECT_STATUS is null;
8337:
8338: elsif (l_extraction_type = 'FULL' or
8339: l_extraction_type = 'INCREMENTAL') then
8340:
8341: /*bug#5349102 added the check for FIN8 */
8342: update PJI_PJP_PROJ_BATCH_MAP
8343: set PJI_PROJECT_STATUS = 'Y'
8344: where WORKER_ID = p_worker_id and
8345: PJI_PROJECT_STATUS is null and
8346: PROJECT_ID in (select distinct
8364: end if;
8365:
8366: if (l_extraction_type = 'INCREMENTAL') then
8367:
8368: update PJI_PJP_PROJ_BATCH_MAP map
8369: set map.EXTRACTION_TYPE = 'M'
8370: where map.WORKER_ID = p_worker_id and
8371: map.PROJECT_ID in (select fin7.PROJECT_ID
8372: from PJI_PJP_RMAP_FPR fin7_r,
8374: where fin7_r.WORKER_ID = p_worker_id and
8375: fin7_r.RECORD_TYPE = 'M' and
8376: fin7.ROWID = fin7_r.STG_ROWID);
8377:
8378: update PJI_PJP_PROJ_BATCH_MAP map
8379: set map.EXTRACTION_TYPE = 'M'
8380: where map.WORKER_ID = p_worker_id and
8381: map.PROJECT_ID not in (select cmt.PROJECT_ID
8382: from PA_COMMITMENT_TXNS cmt);
8482: select
8483: map.worker_id,bv.project_id,bv.budget_version_id,
8484: nvl(fpo.all_time_phased_code,nvl(fpo.cost_time_phased_code,fpo.revenue_time_phased_code)) time_phased_code
8485: from
8486: PJI_PJP_PROJ_BATCH_MAP map,
8487: PA_PROJ_FP_OPTIONS fpo,
8488: PA_BUDGET_VERSIONS bv
8489: where
8490: map.WORKER_ID = p_worker_id and
8530: UNION ALL --Pull Reversals for Actuals , CB,CO when l_refresh_code=-1,-3,-4
8531: select
8532: map.worker_id,map.project_id, plan_version_id, 'G' time_phased_code
8533: from
8534: PJI_PJP_PROJ_BATCH_MAP map,
8535: (
8536: select decode (bitand (l_refresh_code,1),1,-1,-999) plan_version_id from dual where l_plan_type_id is null
8537: union all
8538: select decode (bitand (l_refresh_code,g_cb_plans),g_cb_plans,-3,-999) plan_version_id from dual
8933: - fpr.custom13 CUSTOM13,
8934: - fpr.custom14 CUSTOM14,
8935: - fpr.custom15 CUSTOM15 /* Modified for Bug 8271578 End */
8936: from
8937: PJI_PJP_PROJ_BATCH_MAP map,
8938: PJI_FP_XBS_ACCUM_F fpr
8939: where
8940: l_extraction_type = 'INCREMENTAL' and
8941: map.WORKER_ID = p_worker_id and
9163: fnd_stats.gather_table_stats('PJI','PJI_AC_AGGR_PJP0',PERCENT=>40);
9164: fnd_stats.gather_table_stats('PJI','PJI_AC_CUST_PJP0',PERCENT=>40);
9165: fnd_stats.gather_table_stats('PJI','PJI_AC_XBS_ACCUM_F',PERCENT=>40);
9166: fnd_stats.gather_table_stats('PJI','PJI_ORG_EXTR_INFO',PERCENT=>40);
9167: fnd_stats.gather_table_stats('PJI','PJI_PJP_PROJ_BATCH_MAP',PERCENT=>40);
9168: fnd_stats.gather_table_stats('PJI','PJI_TIME_CAL_PERIOD',PERCENT=>40);
9169: fnd_stats.gather_table_stats('PJI','PJI_TIME_CAL_RPT_STRUCT',PERCENT=>40);
9170: fnd_stats.gather_table_stats('PJI','PJI_TIME_ENT_PERIOD',PERCENT=>40);
9171: fnd_stats.gather_table_stats('PJI','PJI_TIME_RPT_STRUCT',PERCENT=>40);
9471: - acr.CUSTOM13 CUSTOM13,
9472: - acr.CUSTOM14 CUSTOM14,
9473: - acr.CUSTOM15 CUSTOM15
9474: from
9475: PJI_PJP_PROJ_BATCH_MAP map,
9476: PJI_AC_XBS_ACCUM_F acr
9477: where
9478: l_extraction_type = 'PARTIAL' and
9479: map.WORKER_ID = p_worker_id and
9781: WORKER_ID = p_worker_id
9782: union all -- activity and snapshot reversals - PART 1 - ENT dates
9783: -- Select old ITD amounts for snapshots with
9784: -- reverse sign from base level fact
9785: select /*+ ordered use_nl(acr map) index(cal PJI_TIME_RPT_STRUCT_N1) index(acr PJI_AC_XBS_ACCUM_F_N1) index(map PJI_PJP_PROJ_BATCH_MAP_N1) */ -- Modified for bug 15996434
9786: distinct -- Bug 6689297
9787: p_worker_id WORKER_ID,
9788: acr.PROJECT_ID,
9789: acr.PROJECT_ORG_ID,
9893: PJI_AC_AGGR_PJP0 pjp0, -- Re-orderdered the tables for bug 15996434
9894: PJI_TIME_ENT_PERIOD_V ent,
9895: PJI_TIME_RPT_STRUCT cal,
9896: PJI_AC_XBS_ACCUM_F acr,
9897: PJI_PJP_PROJ_BATCH_MAP map,
9898: (
9899: select 'ACTIVITY' INVERT_ID from DUAL union all
9900: select 'SNAPSHOT' INVERT_ID from DUAL
9901: ) invert
9924: abs(nvl(acr.AR_COUNT_OVERDUE,0)) > 0
9925: union all -- activity and snapshot reversals - PART 2 - GL dates
9926: -- Select old ITD amounts for snapshots with
9927: -- reverse sign from base level fact
9928: select /*+ ordered use_nl(acr map) full(info) index(cal PJI_TIME_CAL_RPT_STRUCT_N1) index(acr PJI_AC_XBS_ACCUM_F_N1) index(map PJI_PJP_PROJ_BATCH_MAP_N1) */ -- Modified for bug 15996434
9929: distinct -- Bug 6689297
9930: p_worker_id WORKER_ID,
9931: acr.PROJECT_ID,
9932: acr.PROJECT_ORG_ID,
10037: PJI_AC_XBS_ACCUM_F acr,
10038: PJI_ORG_EXTR_INFO info,
10039: PJI_TIME_CAL_PERIOD_V gl_cal,
10040: PJI_TIME_CAL_RPT_STRUCT cal,
10041: PJI_PJP_PROJ_BATCH_MAP map,
10042: (
10043: select 'ACTIVITY' INVERT_ID from DUAL union all
10044: select 'SNAPSHOT' INVERT_ID from DUAL
10045: ) invert
10071: abs(nvl(acr.AR_COUNT_OVERDUE,0)) > 0
10072: union all -- activity and snapshot reversals - PART 3 - PA dates
10073: -- Select old ITD amounts for snapshots with
10074: -- reverse sign from base level fact
10075: select /*+ ordered use_nl(acr map) full(info) index(cal PJI_TIME_CAL_RPT_STRUCT_N1) index(acr PJI_AC_XBS_ACCUM_F_N1) index(map PJI_PJP_PROJ_BATCH_MAP_N1) */ -- Modified for bug 15996434
10076: distinct -- Bug 6689297
10077: p_worker_id WORKER_ID,
10078: acr.PROJECT_ID,
10079: acr.PROJECT_ORG_ID,
10184: PJI_AC_XBS_ACCUM_F acr,
10185: PJI_ORG_EXTR_INFO info,
10186: PJI_TIME_CAL_PERIOD_V pa_cal,
10187: PJI_TIME_CAL_RPT_STRUCT cal,
10188: PJI_PJP_PROJ_BATCH_MAP map,
10189: (
10190: select 'ACTIVITY' INVERT_ID from DUAL union all
10191: select 'SNAPSHOT' INVERT_ID from DUAL
10192: ) invert
11041: nvl(max(den.SUP_LEVEL), 0)
11042: into
11043: l_level
11044: from
11045: PJI_PJP_PROJ_BATCH_MAP map,
11046: PJI_XBS_DENORM den
11047: where
11048: map.WORKER_ID = p_worker_id and
11049: den.STRUCT_TYPE = 'PRG' and
14199: nvl(max(den.SUP_LEVEL), 0)
14200: into
14201: l_level
14202: from
14203: PJI_PJP_PROJ_BATCH_MAP map,
14204: PJI_XBS_DENORM den
14205: where
14206: map.WORKER_ID = p_worker_id and
14207: den.STRUCT_TYPE = 'PRG' and
14778: prg.SUB_ROLLUP_ID,
14779: prg.RELATIONSHIP_TYPE RELATIONSHIP_TYPE,
14780: 'Y' PUSHUP_FLAG
14781: from
14782: PJI_PJP_PROJ_BATCH_MAP map,
14783: PJI_XBS_DENORM prg,
14784: PJI_XBS_DENORM_DELTA prg_delta
14785: where
14786: prg.STRUCT_TYPE = 'PRG' and
15588: select
15589: SUP_LEVEL
15590: from
15591: PA_XBS_DENORM den,
15592: PJI_PJP_PROJ_BATCH_MAP map
15593: where
15594: map.WORKER_ID = p_worker_id and
15595: den.STRUCT_TYPE = 'PRG' and
15596: den.SUP_PROJECT_ID = map.PROJECT_ID
16628: 'STRUCTURE_PUBLISHED' = sup_ver.STATUS_CODE (+) and
16629: wbs_hdr.CB_FLAG = fin_plan.CB (+) and
16630: wbs_hdr.CO_FLAG = fin_plan.CO (+)
16631: ) pjp,
16632: PJI_PJP_PROJ_BATCH_MAP map,
16633: PA_PROJ_WORKPLAN_ATTR sup_wpa,
16634: PA_PROJ_ELEM_VER_STRUCTURE sup_fin_ver,
16635: PA_XBS_DENORM wbs,
16636: (
16830: select
16831: SUP_LEVEL
16832: from
16833: PA_XBS_DENORM den,
16834: PJI_PJP_PROJ_BATCH_MAP map
16835: where
16836: map.WORKER_ID = p_worker_id and
16837: den.STRUCT_TYPE = 'PRG' and
16838: den.SUP_PROJECT_ID = map.PROJECT_ID
17182: wbs_hdr.WBS_VERSION_ID = prg.SUB_ID and
17183: wbs_hdr.PROJECT_ID = pjp1.PROJECT_ID and
17184: wbs_hdr.PLAN_VERSION_ID = -1
17185: ) pjp,
17186: PJI_PJP_PROJ_BATCH_MAP map,
17187: PA_PROJ_WORKPLAN_ATTR sup_wpa,
17188: PA_PROJ_ELEM_VER_STRUCTURE sup_fin_ver,
17189: PA_XBS_DENORM wbs,
17190: (
18752:
18753: BEGIN
18754: select distinct ver.wbs_version_id bulk collect
18755: into l_wbs_version_id_tbl
18756: from PJI_PJP_PROJ_BATCH_MAP map,Pji_pjp_wbs_header ver
18757: where map.PROJECT_ID=ver.project_id
18758: and map.WORKER_ID = p_worker_id;
18759: EXCEPTION
18760: WHEN NO_DATA_FOUND then null;
18762:
18763: delete
18764: from PJI_XBS_DENORM
18765: where SUP_PROJECT_ID in (select map.PROJECT_ID
18766: from PJI_PJP_PROJ_BATCH_MAP map
18767: where WORKER_ID = p_worker_id);
18768:
18769: l_count := l_count + sql%rowcount;
18770:
18810: l_creation_date,
18811: l_created_by,
18812: l_last_update_login
18813: from
18814: PJI_PJP_PROJ_BATCH_MAP map,
18815: PA_XBS_DENORM den
18816: where
18817: map.WORKER_ID = p_worker_id and
18818: den.SUP_PROJECT_ID = map.PROJECT_ID;
18826:
18827: -- delete from PJI_REP_XBS_DENORM;
18828: pji_rep_util.Log_Struct_Change_Event(l_wbs_version_id_tbl); --Uncommented for bug 14571067
18829: -- where PROJECT_ID in (select map.PROJECT_ID
18830: -- from PJI_PJP_PROJ_BATCH_MAP map
18831: -- where map.WORKER_ID = p_worker_id);
18832:
18833: end if; -- Uncommented for bug 14571067
18834:
19426: select
19427: ROWNUM,
19428: PROJECT_ID
19429: from
19430: PJI_PJP_PROJ_BATCH_MAP
19431: where
19432: WORKER_ID = p_worker_id and
19433: PJI_PROJECT_STATUS = 'Y' and
19434: rownum <= G_PROGRESS_COMMIT_SIZE;
19503: -- condition. It is to be commented at all times in checked
19504: -- in code.
19505:
19506: forall j in 1..l_project_id_tbl.COUNT
19507: update PJI_PJP_PROJ_BATCH_MAP
19508: set pji_project_status =
19509: decode(l_return_status
19510: , FND_API.G_RET_STS_SUCCESS
19511: , 'S' -- Success
19526: END LOOP;
19527:
19528: if l_success <> 'Y' then
19529:
19530: update pji_pjp_proj_batch_map -- Process the pending projects in the next sumz run.
19531: set pji_project_status = 'Y'
19532: where
19533: WORKER_ID = p_worker_id and
19534: pji_project_status = 'P';
19539: end if;
19540:
19541: -- Reset flags. 'N' means actuals don't exist for this project.
19542: -- Reset flags for only those projects for which actuals exist.
19543: update pji_pjp_proj_batch_map
19544: set pji_project_status = 'Y'
19545: where
19546: WORKER_ID = p_worker_id and
19547: pji_project_status <> 'N';
19579: cursor project_list (p_worker_id in number) is
19580: SELECT nvl(ver.PRG_LEVEL,1) PRG_LEVEL,
19581: ver.PROJECT_ID
19582: FROM
19583: pji_pjp_proj_batch_map map,
19584: pa_proj_element_versions ver,
19585: pa_proj_structure_types typ,
19586: pa_proj_elem_ver_structure str
19587: WHERE
19620:
19621: if (l_extraction_type = 'FULL' or
19622: l_extraction_type = 'INCREMENTAL') then
19623:
19624: update PJI_PJP_PROJ_BATCH_MAP
19625: set PJI_PROJECT_STATUS = 'Y'
19626: where WORKER_ID = p_worker_id and
19627: PJI_PROJECT_STATUS is null and
19628: PROJECT_ID in (select distinct
19706: set LOCK_FLAG = null
19707: where LOCK_FLAG is not null
19708: and project_id IN
19709: ( SELECT project_id
19710: FROM pji_pjp_proj_batch_map
19711: WHERE worker_id = p_worker_id );
19712:
19713: -- SELECT DECODE(l_extraction_type, 'PARTIAL', 'PLANTYPE', l_extraction_type)
19714: -- INTO l_extraction_type