DBA Data[Home] [Help]

APPS.PJI_FM_SUM_BKLG dependencies on PJI_PROCESS_UTIL

Line 19: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_BKLG.ROWID_ACTIVITY_DATES_FIN(p_worker_id);')) then

15: begin
16:
17: l_process := PJI_RM_SUM_MAIN.g_process || p_worker_id;
18:
19: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_BKLG.ROWID_ACTIVITY_DATES_FIN(p_worker_id);')) then
20: return;
21: end if;
22:
23: -- Get the minimum activity dates for each project in the current batch

Line 60: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_BKLG.ROWID_ACTIVITY_DATES_FIN(p_worker_id);');

56: map.rowid
57: , map.project_id
58: ;
59:
60: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_BKLG.ROWID_ACTIVITY_DATES_FIN(p_worker_id);');
61:
62: commit;
63:
64: end ROWID_ACTIVITY_DATES_FIN;

Line 79: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_BKLG.UPDATE_ACTIVITY_DATES_FIN(p_worker_id);')) then

75: begin
76:
77: l_process := PJI_RM_SUM_MAIN.g_process || p_worker_id;
78:
79: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_BKLG.UPDATE_ACTIVITY_DATES_FIN(p_worker_id);')) then
80: return;
81: end if;
82:
83: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 83: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

79: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_BKLG.UPDATE_ACTIVITY_DATES_FIN(p_worker_id);')) then
80: return;
81: end if;
82:
83: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
84: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');
85:
86: -- Update the table pji_pji_proj_batch_map with the
87: -- minimum activity dates for each project in the current batch

Line 110: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_BKLG.UPDATE_ACTIVITY_DATES_FIN(p_worker_id);');

106: )
107: )
108: ;
109:
110: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_BKLG.UPDATE_ACTIVITY_DATES_FIN(p_worker_id);');
111:
112: commit;
113:
114: end UPDATE_ACTIVITY_DATES_FIN;

Line 128: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_BKLG.ROWID_ACTIVITY_DATES_ACT(p_worker_id);')) then

124: begin
125:
126: l_process := PJI_RM_SUM_MAIN.g_process || p_worker_id;
127:
128: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_BKLG.ROWID_ACTIVITY_DATES_ACT(p_worker_id);')) then
129: return;
130: end if;
131:
132: -- Get minimum funding dates for each project in the current batch

Line 163: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_BKLG.ROWID_ACTIVITY_DATES_ACT(p_worker_id);');

159: map.rowid
160: , map.project_id
161: ;
162:
163: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_BKLG.ROWID_ACTIVITY_DATES_ACT(p_worker_id);');
164:
165: commit;
166:
167: end ROWID_ACTIVITY_DATES_ACT;

Line 182: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_BKLG.UPDATE_ACTIVITY_DATES_ACT(p_worker_id);')) then

178: begin
179:
180: l_process := PJI_RM_SUM_MAIN.g_process || p_worker_id;
181:
182: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_BKLG.UPDATE_ACTIVITY_DATES_ACT(p_worker_id);')) then
183: return;
184: end if;
185:
186: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 186: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

182: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_BKLG.UPDATE_ACTIVITY_DATES_ACT(p_worker_id);')) then
183: return;
184: end if;
185:
186: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
187: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');
188:
189: -- Update the table pji_pji_proj_batch_map with the
190: -- minimum funding dates for each project in the current batch

Line 211: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_BKLG.UPDATE_ACTIVITY_DATES_ACT(p_worker_id);');

207: )
208: )
209: ;
210:
211: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_BKLG.UPDATE_ACTIVITY_DATES_ACT(p_worker_id);');
212:
213: commit;
214:
215: end UPDATE_ACTIVITY_DATES_ACT;

Line 231: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP

227: begin
228:
229: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
230:
231: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
232: ( l_process, 'PJI_FM_SUM_BKLG.SCOPE_PROJECTS_BKLG(p_worker_id);'
233: )) then
234: return;
235: end if;

Line 237: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

233: )) then
234: return;
235: end if;
236:
237: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
238: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');
239:
240: UPDATE PJI_PJI_PROJ_BATCH_MAP upd
241: set upd.BACKLOG_EXTRACTION_STATUS=null

Line 271: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION

267: )
268: )
269: ;
270:
271: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
272: (l_process, 'PJI_FM_SUM_BKLG.SCOPE_PROJECTS_BKLG(p_worker_id);');
273:
274: commit;
275:

Line 293: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP

289: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
290:
291: PJI_FM_DEBUG.CLEANUP_HOOK(l_process);
292:
293: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
294: (
295: l_process,
296: 'PJI_FM_SUM_BKLG.CLEANUP_INT_TABLE(p_worker_id);'
297: )) then

Line 303: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema ,

299: end if;
300:
301: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
302:
303: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema ,
304: 'PJI_FM_AGGR_ACT3',
305: 'NORMAL',
306: null);
307:

Line 308: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION

304: 'PJI_FM_AGGR_ACT3',
305: 'NORMAL',
306: null);
307:
308: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
309: (
310: l_process,
311: 'PJI_FM_SUM_BKLG.CLEANUP_INT_TABLE(p_worker_id);'
312: );

Line 1204: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP

1200: BEGIN
1201:
1202: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
1203:
1204: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
1205: ( l_process, 'PJI_FM_SUM_BKLG.PROCESS_DRMT_BKLG(p_worker_id);')) then
1206: return;
1207: end if;
1208:

Line 1258: IF (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

1254:
1255: LOOP
1256:
1257: -- Exit if the main process is not running
1258: IF (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1259: (PJI_RM_SUM_MAIN.g_process, 'PROCESS_RUNNING') <> 'Y' ) THEN
1260: exit;
1261: END IF;
1262:

Line 1319: PJI_PROCESS_UTIL.sleep(PJI_RM_SUM_MAIN.g_process_delay);

1315:
1316:
1317: IF ( l_try_upd_again = 'Y' ) Then
1318: -- wait for some time and try again
1319: PJI_PROCESS_UTIL.sleep(PJI_RM_SUM_MAIN.g_process_delay);
1320: ELSE -- go ahead with the processing for the record updated
1321:
1322: Select project_id
1323: Into l_curr_project_id

Line 1434: l_parallel_processes := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_RM_SUM_MAIN.g_process, 'PARALLEL_PROCESSES');

1430: ;
1431:
1432: IF ( l_count_for_upd = 0 ) THEN
1433:
1434: l_parallel_processes := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_RM_SUM_MAIN.g_process, 'PARALLEL_PROCESSES');
1435:
1436: for x in 2 .. l_parallel_processes loop
1437:
1438: update PJI_SYSTEM_PRC_STATUS

Line 1449: IF (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

1445: end loop;
1446:
1447: END IF;
1448:
1449: IF (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1450: (PJI_RM_SUM_MAIN.g_process, 'PROCESS_RUNNING') <> 'Y' ) THEN
1451: -- no need to raise any error here
1452: null;
1453:

Line 1455: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION

1451: -- no need to raise any error here
1452: null;
1453:
1454: ELSE
1455: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
1456: ( l_process, 'PJI_FM_SUM_BKLG.PROCESS_DRMT_BKLG(p_worker_id);');
1457:
1458: commit;
1459: