[Home] [Help]
153: from PJI_FM_PROJ_BATCH_MAP map
154: where map.WORKER_ID = p_worker_id);
155:
156: delete
157: from PJI_FP_TXN_ACCUM bal
158: where bal.PROJECT_ID in (select map.PROJECT_ID
159: from PJI_FM_PROJ_BATCH_MAP map
160: where map.WORKER_ID = p_worker_id);
161:
206: from PJI_FM_PROJ_BATCH_MAP map
207: where map.WORKER_ID = p_worker_id);
208:
209: delete
210: from PJI_FP_TXN_ACCUM1 bal
211: where bal.PROJECT_ID in (select map.PROJECT_ID
212: from PJI_FM_PROJ_BATCH_MAP map
213: where map.WORKER_ID = p_worker_id);
214:
2341: l_creation_date := sysdate;
2342: l_created_by := FND_GLOBAL.USER_ID;
2343: l_last_update_login := FND_GLOBAL.LOGIN_ID;
2344:
2345: insert /*+ append parallel(hdr_i) */ into PJI_FP_TXN_ACCUM_HEADER hdr_i
2346: (
2347: TXN_ACCUM_HEADER_ID,
2348: PERSON_ID,
2349: EXPENDITURE_ORG_ID,
2375: CREATED_BY,
2376: LAST_UPDATE_LOGIN
2377: )
2378: select
2379: PJI_FP_TXN_ACCUM_HEADER_S.NEXTVAL TXN_ACCUM_HEADER_ID,
2380: PERSON_ID,
2381: EXPENDITURE_ORG_ID,
2382: EXPENDITURE_ORGANIZATION_ID,
2383: RESOURCE_CLASS_ID,
2443: not exists
2444: (select
2445: 1
2446: from
2447: PJI_FP_TXN_ACCUM_HEADER hdr
2448: where
2449: tmp6.PERSON_ID = hdr.PERSON_ID and
2450: tmp6.EXPENDITURE_ORG_ID = hdr.EXPENDITURE_ORG_ID and
2451: tmp6.EXPENDITURE_ORGANIZATION_ID = hdr.EXPENDITURE_ORGANIZATION_ID and
2515:
2516: if (l_extraction_type = 'FULL' or
2517: l_extraction_type = 'PARTIAL') then
2518:
2519: insert /*+ append parallel(bal) */ into PJI_FP_TXN_ACCUM bal
2520: (
2521: TXN_ACCUM_HEADER_ID,
2522: RESOURCE_CLASS_ID,
2523: PROJECT_ID,
2620: l_created_by CREATED_BY,
2621: l_last_update_login LAST_UPDATE_LOGIN
2622: from
2623: PJI_FM_AGGR_FIN6 tmp6,
2624: PJI_FP_TXN_ACCUM_HEADER hdr
2625: where
2626: tmp6.WORKER_ID = p_worker_id and
2627: tmp6.RECORD_TYPE = 'A' and
2628: tmp6.PERSON_ID = hdr.PERSON_ID and
2823: tmp6.G2_PR_COMMITTED_COST,
2824: tmp6.G2_OTH_COMMITTED_COST
2825: from
2826: PJI_FM_AGGR_FIN6 tmp6,
2827: PJI_FP_TXN_ACCUM_HEADER hdr
2828: where
2829: tmp6.WORKER_ID = p_worker_id and
2830: tmp6.PERSON_ID = hdr.PERSON_ID and
2831: tmp6.EXPENDITURE_ORG_ID = hdr.EXPENDITURE_ORG_ID and
2899: l_last_update_login := FND_GLOBAL.LOGIN_ID;
2900:
2901: if (l_extraction_type = 'INCREMENTAL') then
2902:
2903: insert /*+ append parallel(bal) */ into PJI_FP_TXN_ACCUM bal
2904: (
2905: TXN_ACCUM_HEADER_ID,
2906: RESOURCE_CLASS_ID,
2907: PROJECT_ID,
3004: l_created_by CREATED_BY,
3005: l_last_update_login LAST_UPDATE_LOGIN
3006: from
3007: PJI_FM_AGGR_FIN6 tmp6,
3008: PJI_FP_TXN_ACCUM_HEADER hdr
3009: where
3010: tmp6.WORKER_ID = p_worker_id and
3011: tmp6.RECORD_TYPE = 'A' and
3012: tmp6.PERSON_ID = hdr.PERSON_ID and
3104:
3105: -- Only insert commitments during FULL run since INCREMENTAL commitments
3106: -- data is handled at the same time as INCREMETNAL actuals data above.
3107:
3108: insert /*+ append parallel(bal) */ into PJI_FP_TXN_ACCUM1 bal
3109: (
3110: TXN_ACCUM_HEADER_ID,
3111: PROJECT_ID,
3112: PROJECT_ORG_ID,
3187: l_created_by CREATED_BY,
3188: l_last_update_login LAST_UPDATE_LOGIN
3189: from
3190: PJI_FM_AGGR_FIN6 tmp6,
3191: PJI_FP_TXN_ACCUM_HEADER hdr
3192: where
3193: tmp6.WORKER_ID = p_worker_id and
3194: tmp6.RECORD_TYPE = 'M' and
3195: tmp6.PERSON_ID = hdr.PERSON_ID and
3277: l_last_update_login := FND_GLOBAL.LOGIN_ID;
3278:
3279: if (l_extraction_type = 'INCREMENTAL' and l_extract_commitments = 'Y') then
3280:
3281: insert /*+ append parallel(bal) */ into PJI_FP_TXN_ACCUM1 bal
3282: (
3283: TXN_ACCUM_HEADER_ID,
3284: PROJECT_ID,
3285: PROJECT_ORG_ID,
3360: l_created_by CREATED_BY,
3361: l_last_update_login LAST_UPDATE_LOGIN
3362: from
3363: PJI_FM_AGGR_FIN6 tmp6,
3364: PJI_FP_TXN_ACCUM_HEADER hdr
3365: where
3366: tmp6.WORKER_ID = p_worker_id and
3367: tmp6.RECORD_TYPE = 'M' and
3368: tmp6.PERSON_ID = hdr.PERSON_ID and
3687: tmp7.RECORD_TYPE
3688: from
3689: PJI_PJP_PROJ_BATCH_MAP map,
3690: PJI_FM_AGGR_FIN7 tmp7,
3691: PJI_FP_TXN_ACCUM psi
3692: where
3693: map.WORKER_ID = p_worker_id and
3694: tmp7.PROJECT_ID = map.PROJECT_ID and
3695: tmp7.RECORD_TYPE = 'A' and
3772: l_last_update_login := FND_GLOBAL.LOGIN_ID;
3773:
3774: if (l_extraction_type = 'INCREMENTAL') then
3775:
3776: update PJI_FP_TXN_ACCUM psi
3777: set (TXN_RAW_COST,
3778: TXN_BILL_RAW_COST,
3779: TXN_BRDN_COST,
3780: TXN_BILL_BRDN_COST,
3973: l_last_update_login := FND_GLOBAL.LOGIN_ID;
3974:
3975: if (l_extraction_type = 'INCREMENTAL') then
3976:
3977: insert /*+ append parallel(bal_i) */ into PJI_FP_TXN_ACCUM bal_i
3978: (
3979: TXN_ACCUM_HEADER_ID,
3980: RESOURCE_CLASS_ID,
3981: PROJECT_ID,
4181:
4182: if (l_extraction_type = 'INCREMENTAL') then
4183:
4184: delete
4185: from PJI_FP_TXN_ACCUM1 bal
4186: where bal.PROJECT_ID in (select distinct
4187: fin7.PROJECT_ID
4188: from PJI_PJP_RMAP_FPR tmp7_r,
4189: PJI_FM_AGGR_FIN7 fin7
4241: l_last_update_login := FND_GLOBAL.LOGIN_ID;
4242:
4243: if (l_extraction_type = 'INCREMENTAL') then
4244:
4245: insert /*+ append parallel(bal_i) */ into PJI_FP_TXN_ACCUM1 bal_i
4246: (
4247: TXN_ACCUM_HEADER_ID,
4248: PROJECT_ID,
4249: PROJECT_ORG_ID,