[Home] [Help]
17: p_validationLevel in number,
18: p_commitFlag in number,
19: x_returnStatus out nocopy varchar2,
20: x_errorMsg out nocopy varchar2) is
21: l_params wip_logger.param_tbl_t;
22: l_procName varchar2(30) := 'massLoadJobs';
23: l_logLevel number := to_number(fnd_log.g_current_runtime_level);
24: l_retStatus varchar2(1);
25: l_totalNum number;
55: l_params(1).paramName := 'p_groupID';
56: l_params(1).paramValue := p_groupID;
57: l_params(2).paramName := 'p_validationLevel';
58: l_params(2).paramValue := p_validationLevel;
59: wip_logger.entryPoint(p_procName => g_pkgName || '.' || l_procName,
60: p_params => l_params,
61: x_returnStatus => x_returnStatus);
62: if(x_returnStatus <> fnd_api.g_ret_sts_success) then
63: raise fnd_api.g_exc_unexpected_error;
73: and process_phase = wip_constants.ml_validation
74: and load_type <> wip_constants.create_sched;
75:
76: if (l_logLevel <= wip_constants.trace_logging) then
77: wip_logger.log(l_requestCount || ' pending request(s) found for group_id' || p_groupID || ' for discrete processing', l_retStatus);
78: end if;
79:
80: -- lock all the records
81: open c_allrows;
132: wip_constants.create_ns_job,
133: wip_constants.resched_job);
134:
135: if (l_logLevel <= wip_constants.trace_logging) then
136: wip_logger.log('There are ' || l_totalNum || ' detail records....', l_retStatus);
137: end if;
138:
139: if ( l_totalNum > 0 ) then
140: wip_job_details.load_all_details(p_group_id => p_groupID,
196: wjsi_rec.interface_id,
197: x_errorMsg,
198: g_wipMLError);
199: if (l_logLevel <= wip_constants.trace_logging) then
200: wip_logger.log('interface ' || wjsi_rec.interface_id || ' failed: ' || x_errorMsg, l_retStatus);
201: end if;
202: end;
203: end loop;
204:
225: x_returnStatus := fnd_api.g_ret_sts_success;
226: end if;
227:
228: if (l_logLevel <= wip_constants.trace_logging) then
229: wip_logger.exitPoint(p_procName => g_pkgName || '.' || l_procName,
230: p_procReturnStatus => x_returnStatus,
231: p_msg => 'success',
232: x_returnStatus => l_retStatus);
233: end if;
234: exception
235: when wip_constants.records_locked then
236: x_returnStatus := fnd_api.g_ret_sts_unexp_error;
237: if (l_logLevel <= wip_constants.trace_logging) then
238: wip_logger.exitPoint(p_procName => g_pkgName || '.' || l_procName,
239: p_procReturnStatus => x_returnStatus,
240: p_msg => 'records locked',
241: x_returnStatus => l_retStatus);
242: end if;
244: x_errorMsg := fnd_message.get;
245: when fnd_api.g_exc_unexpected_error then
246: x_returnStatus := fnd_api.g_ret_sts_unexp_error;
247: if (l_logLevel <= wip_constants.trace_logging) then
248: wip_logger.exitPoint(p_procName => g_pkgName || '.' || l_procName,
249: p_procReturnStatus => x_returnStatus,
250: p_msg => x_errorMsg,
251: x_returnStatus => l_retStatus);
252: end if;
260: p_validationLevel in number,
261: x_wipEntityID out nocopy number,
262: x_returnStatus out nocopy varchar2,
263: x_errorMsg out nocopy varchar2) is
264: l_params wip_logger.param_tbl_t;
265: l_procName varchar2(30) := 'createOneJob';
266: l_logLevel number := to_number(fnd_log.g_current_runtime_level);
267: l_retStatus varchar2(1);
268: l_totalNum number;
282: l_params(1).paramName := 'p_interfaceID';
283: l_params(1).paramValue := p_interfaceID;
284: l_params(2).paramName := 'p_validationLevel';
285: l_params(2).paramValue := p_validationLevel;
286: wip_logger.entryPoint(p_procName => g_pkgName || '.' || l_procName,
287: p_params => l_params,
288: x_returnStatus => x_returnStatus);
289: if(x_returnStatus <> fnd_api.g_ret_sts_success) then
290: raise fnd_api.g_exc_unexpected_error;
367: and wjdi.process_status = wip_constants.pending
368: and wjsi.rowid = l_rowid;
369:
370: if (l_logLevel <= wip_constants.trace_logging) then
371: wip_logger.log('There are ' || l_totalNum || ' detail records....', l_retStatus);
372: end if;
373:
374: if ( l_totalNum > 0 ) then
375: wip_job_details.load_all_details(p_group_id => l_groupID,
402: set process_status = wip_constants.completed
403: where rowid = l_rowid;
404:
405: if (l_logLevel <= wip_constants.trace_logging) then
406: wip_logger.exitPoint(p_procName => g_pkgName || '.' || l_procName,
407: p_procReturnStatus => x_returnStatus,
408: p_msg => 'success',
409: x_returnStatus => l_retStatus);
410: end if;
417: p_interfaceID,
418: x_errorMsg,
419: g_wipMLError);
420: if (l_logLevel <= wip_constants.trace_logging) then
421: wip_logger.exitPoint(p_procName => g_pkgName || '.' || l_procName,
422: p_procReturnStatus => x_returnStatus,
423: p_msg => 'records locked',
424: x_returnStatus => l_retStatus);
425: end if;
429: p_interfaceID,
430: x_errorMsg,
431: g_wipMLError);
432: if (l_logLevel <= wip_constants.trace_logging) then
433: wip_logger.exitPoint(p_procName => g_pkgName || '.' || l_procName,
434: p_procReturnStatus => x_returnStatus,
435: p_msg => x_errorMsg,
436: x_returnStatus => l_retStatus);
437: end if;