[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;
77: l_params(1).paramName := 'p_groupID';
78: l_params(1).paramValue := p_groupID;
79: l_params(2).paramName := 'p_validationLevel';
80: l_params(2).paramValue := p_validationLevel;
81: wip_logger.entryPoint(p_procName => g_pkgName || '.' || l_procName,
82: p_params => l_params,
83: x_returnStatus => x_returnStatus);
84: if(x_returnStatus <> fnd_api.g_ret_sts_success) then
85: raise fnd_api.g_exc_unexpected_error;
95: and process_phase = wip_constants.ml_validation
96: and load_type <> wip_constants.create_sched;
97:
98: if (l_logLevel <= wip_constants.trace_logging) then
99: wip_logger.log(l_requestCount || ' pending request(s) found for group_id' || p_groupID || ' for discrete processing', l_retStatus);
100: end if;
101:
102: -- lock all the records
103: open c_allrows;
165: wip_constants.create_ns_job,
166: wip_constants.resched_job);
167:
168: if (l_logLevel <= wip_constants.trace_logging) then
169: wip_logger.log('There are ' || l_totalNum || ' detail records....', l_retStatus);
170: end if;
171:
172: if ( l_totalNum > 0 ) then
173: wip_job_details.load_all_details(p_group_id => p_groupID,
246: exception
247: when others then
248: x_errorMsg := fnd_message.get;
249: if (l_logLevel <= wip_constants.trace_logging) then
250: wip_logger.log('calling wip_osp.release_validation failed in wip_massload_pub.massLoadJobs', l_retStatus);
251: end if;
252: raise fnd_api.g_exc_unexpected_error;
253: end;
254: end if ;
270: wjsi_rec.interface_id,
271: x_errorMsg,
272: g_wipMLError);
273: if (l_logLevel <= wip_constants.trace_logging) then
274: wip_logger.log('interface ' || wjsi_rec.interface_id || ' failed: ' || x_errorMsg, l_retStatus);
275: end if;
276: /*Bug 16529960 Add exception handler to avoid massload terminated because of unexpected exception*/
277: when others then
278: rollback to wip_massload_start;
280: wjsi_rec.interface_id,
281: 'unexp error: ' || SQLERRM,
282: g_wipMLError);
283: if (l_logLevel <= wip_constants.trace_logging) then
284: wip_logger.log('unexp error: ' || SQLERRM||' for interface id: '||wjsi_rec.interface_id, l_retStatus);
285: end if;
286: end;
287: end loop;
288:
352: x_returnStatus := fnd_api.g_ret_sts_success;
353: end if;
354:
355: if (l_logLevel <= wip_constants.trace_logging) then
356: wip_logger.exitPoint(p_procName => g_pkgName || '.' || l_procName,
357: p_procReturnStatus => x_returnStatus,
358: p_msg => 'success',
359: x_returnStatus => l_retStatus);
360: end if;
361: exception
362: when wip_constants.records_locked then
363: x_returnStatus := fnd_api.g_ret_sts_unexp_error;
364: if (l_logLevel <= wip_constants.trace_logging) then
365: wip_logger.exitPoint(p_procName => g_pkgName || '.' || l_procName,
366: p_procReturnStatus => x_returnStatus,
367: p_msg => 'records locked',
368: x_returnStatus => l_retStatus);
369: end if;
371: x_errorMsg := fnd_message.get;
372: when fnd_api.g_exc_unexpected_error then
373: x_returnStatus := fnd_api.g_ret_sts_unexp_error;
374: if (l_logLevel <= wip_constants.trace_logging) then
375: wip_logger.exitPoint(p_procName => g_pkgName || '.' || l_procName,
376: p_procReturnStatus => x_returnStatus,
377: p_msg => x_errorMsg,
378: x_returnStatus => l_retStatus);
379: end if;
380: /*Bug 16529960: Add exception handler to log any unexpected exception*/
381: when others then
382: x_returnStatus := fnd_api.g_ret_sts_unexp_error;
383: if (l_logLevel <= wip_constants.trace_logging) then
384: wip_logger.exitPoint(p_procName => g_pkgName || '.' || l_procName,
385: p_procReturnStatus => x_returnStatus,
386: p_msg => 'unexp error: ' || SQLERRM,
387: x_returnStatus => l_retStatus);
388: end if;
396: p_validationLevel in number,
397: x_wipEntityID out nocopy number,
398: x_returnStatus out nocopy varchar2,
399: x_errorMsg out nocopy varchar2) is
400: l_params wip_logger.param_tbl_t;
401: l_procName varchar2(30) := 'createOneJob';
402: l_logLevel number := to_number(fnd_log.g_current_runtime_level);
403: l_retStatus varchar2(1);
404: l_totalNum number;
425: l_params(1).paramName := 'p_interfaceID';
426: l_params(1).paramValue := p_interfaceID;
427: l_params(2).paramName := 'p_validationLevel';
428: l_params(2).paramValue := p_validationLevel;
429: wip_logger.entryPoint(p_procName => g_pkgName || '.' || l_procName,
430: p_params => l_params,
431: x_returnStatus => x_returnStatus);
432: if(x_returnStatus <> fnd_api.g_ret_sts_success) then
433: raise fnd_api.g_exc_unexpected_error;
510: and wjdi.process_status = wip_constants.pending
511: and wjsi.rowid = l_rowid;
512:
513: if (l_logLevel <= wip_constants.trace_logging) then
514: wip_logger.log('There are ' || l_totalNum || ' detail records....', l_retStatus);
515: end if;
516:
517: if ( l_totalNum > 0 ) then
518: wip_job_details.load_all_details(p_group_id => l_groupID,
570: set process_status = wip_constants.completed
571: where rowid = l_rowid;
572:
573: if (l_logLevel <= wip_constants.trace_logging) then
574: wip_logger.exitPoint(p_procName => g_pkgName || '.' || l_procName,
575: p_procReturnStatus => x_returnStatus,
576: p_msg => 'success',
577: x_returnStatus => l_retStatus);
578: end if;
585: p_interfaceID,
586: x_errorMsg,
587: g_wipMLError);
588: if (l_logLevel <= wip_constants.trace_logging) then
589: wip_logger.exitPoint(p_procName => g_pkgName || '.' || l_procName,
590: p_procReturnStatus => x_returnStatus,
591: p_msg => 'records locked',
592: x_returnStatus => l_retStatus);
593: end if;
597: p_interfaceID,
598: x_errorMsg,
599: g_wipMLError);
600: if (l_logLevel <= wip_constants.trace_logging) then
601: wip_logger.exitPoint(p_procName => g_pkgName || '.' || l_procName,
602: p_procReturnStatus => x_returnStatus,
603: p_msg => x_errorMsg,
604: x_returnStatus => l_retStatus);
605: end if;