[Home] [Help]
44:
45: BEGIN
46:
47: IF (l_debug <> -1) THEN
48: rlm_core_sv.dpush(C_SDEBUG,'StartDSPProcess');
49: rlm_core_sv.dlog(C_DEBUG,'p_Header_Id ', p_Header_Id);
50: END IF;
51: --
52: -- fnd_profile.get('ORG_ID', v_org_id);
45: BEGIN
46:
47: IF (l_debug <> -1) THEN
48: rlm_core_sv.dpush(C_SDEBUG,'StartDSPProcess');
49: rlm_core_sv.dlog(C_DEBUG,'p_Header_Id ', p_Header_Id);
50: END IF;
51: --
52: -- fnd_profile.get('ORG_ID', v_org_id);
53: --
54: g_num_child := v_num_child;
55: v_org_id := v_Sch_rec.org_id;
56: --
57: IF (l_debug <> -1) THEN
58: rlm_core_sv.dlog(C_DEBUG,'Org Id ', v_Sch_rec.org_id);
59: END IF;
60: --
61: -- Bug#: 3053299 - Added Schedule Generation Date as argument
62: --
62: --
63: GetScheduleDetails(p_Header_Id, v_ScheduleNum, v_Customer, v_ScheduleGenDate);
64: --
65: IF (l_debug <> -1) THEN
66: rlm_core_sv.dlog(C_DEBUG,'v_ScheduleNum ', v_ScheduleNum);
67: rlm_core_sv.dlog(C_DEBUG,'v_Customer ', v_Customer);
68: END IF;
69:
70: -- Abort the process if it has hung
63: GetScheduleDetails(p_Header_Id, v_ScheduleNum, v_Customer, v_ScheduleGenDate);
64: --
65: IF (l_debug <> -1) THEN
66: rlm_core_sv.dlog(C_DEBUG,'v_ScheduleNum ', v_ScheduleNum);
67: rlm_core_sv.dlog(C_DEBUG,'v_Customer ', v_Customer);
68: END IF;
69:
70: -- Abort the process if it has hung
71: --
71: --
72: BEGIN
73: --
74: IF (l_debug <> -1) THEN
75: rlm_core_sv.dlog(C_DEBUG,'Aborting old processes');
76: END IF;
77: --
78: wf_engine.AbortProcess(itemtype => v_ItemType,
79: itemkey => v_ItemKey);
78: wf_engine.AbortProcess(itemtype => v_ItemType,
79: itemkey => v_ItemKey);
80: --
81: IF (l_debug <> -1) THEN
82: rlm_core_sv.dlog(C_DEBUG,'After abort bad process');
83: END IF;
84: --
85: EXCEPTION
86: WHEN OTHERS THEN
85: EXCEPTION
86: WHEN OTHERS THEN
87: --
88: IF (l_debug <> -1) THEN
89: rlm_core_sv.dlog(C_DEBUG,'Did not abort any process');
90: END IF;
91: --
92: END;
93: --
100: docommit => FALSE,
101: force => TRUE);
102: --
103: IF (l_debug <> -1) THEN
104: rlm_core_sv.dlog(C_DEBUG,'After Purge for Item key ',p_Header_Id);
105: END IF;
106: --
107: wf_engine.CreateProcess(v_ItemType, v_ItemKey, v_ProcessName);
108:
170: v_ScheduleGenDate);
171:
172: --
173: IF (l_debug <> -1) THEN
174: rlm_core_sv.dlog(C_DEBUG,'Before Start Process ');
175: END IF;
176: --
177: SELECT hsecs INTO v_start_time from v$timer;
178:
178:
179: wf_engine.StartProcess(v_ItemType, v_ItemKey);
180: --
181: IF (l_debug <> -1) THEN
182: rlm_core_sv.dlog(C_DEBUG,'After Start Process ');
183: END IF;
184: --
185: v_retcode := wf_engine.GetItemAttrNumber(v_ItemType,v_ItemKey,'ERRORS_EXIST');
186: --
184: --
185: v_retcode := wf_engine.GetItemAttrNumber(v_ItemType,v_ItemKey,'ERRORS_EXIST');
186: --
187: IF (l_debug <> -1) THEN
188: rlm_core_sv.dlog(C_DEBUG,' Errors Status: ', v_retcode);
189: END IF;
190: --
191: retcode := g_PROC_SUCCESS;
192: --
190: --
191: retcode := g_PROC_SUCCESS;
192: --
193: IF (l_debug <> -1) THEN
194: rlm_core_sv.dlog(C_DEBUG,'Before End Process ');
195: END IF;
196: --
197: BEGIN
198: --
196: --
197: BEGIN
198: --
199: IF (l_debug <> -1) THEN
200: rlm_core_sv.dlog(C_DEBUG,'Aborting old processes');
201: END IF;
202: --
203: wf_engine.AbortProcess(itemtype => v_ItemType,
204: itemkey => v_ItemKeyNew);
203: wf_engine.AbortProcess(itemtype => v_ItemType,
204: itemkey => v_ItemKeyNew);
205: --
206: IF (l_debug <> -1) THEN
207: rlm_core_sv.dlog(C_DEBUG,'after abort bad process');
208: END IF;
209: --
210: EXCEPTION
211: WHEN OTHERS THEN
210: EXCEPTION
211: WHEN OTHERS THEN
212: --
213: IF (l_debug <> -1) THEN
214: rlm_core_sv.dlog(C_DEBUG,'Did not abort any process');
215: END IF;
216: --
217: END;
218: --
225: force => TRUE);
226: --
227:
228: IF (l_debug <> -1) THEN
229: rlm_core_sv.dlog(C_DEBUG,'Creating End Process ');
230: END IF;
231: --
232: wf_engine.CreateProcess(v_ItemType, v_ItemKeyNew, 'RLMEND');
233: --
236: --
237: wf_engine.SetItemUserKey(v_ItemType, v_ItemKeyNew,v_ScheduleNum);
238: --
239: IF (l_debug <> -1) THEN
240: rlm_core_sv.dlog(C_DEBUG,'Setting attributes End Process ');
241: END IF;
242: --
243: wf_engine.SetItemAttrNumber( v_ItemType,
244: v_ItemKeyNew,
302: v_ScheduleGenDate);
303:
304: --
305: IF (l_debug <> -1) THEN
306: rlm_core_sv.dlog(C_DEBUG,'Start EndProcess ');
307: END IF;
308: --
309: wf_engine.StartProcess(v_ItemType, v_ItemKeyNew);
310:
315: retcode := v_retcode;
316: */
317:
318: IF (l_debug <> -1) THEN
319: rlm_core_sv.dpop(C_SDEBUG);
320: END IF;
321:
322: SELECT hsecs INTO v_end_time FROM v$timer;
323: v_wf_msg_text:= 'Time spent in Work Flow call - '||(v_end_time-v_start_time)/100 ;
328: --
329: retcode := g_PROC_ERROR;
330: --
331: IF (l_debug <> -1) THEN
332: rlm_core_sv.dlog(C_DEBUG,'Errors found ');
333: rlm_core_sv.dlog(C_DEBUG,'Error: ',SUBSTR(SQLERRM,1,1500));
334: rlm_core_sv.dpop(C_SDEBUG);
335: END IF;
336: --
329: retcode := g_PROC_ERROR;
330: --
331: IF (l_debug <> -1) THEN
332: rlm_core_sv.dlog(C_DEBUG,'Errors found ');
333: rlm_core_sv.dlog(C_DEBUG,'Error: ',SUBSTR(SQLERRM,1,1500));
334: rlm_core_sv.dpop(C_SDEBUG);
335: END IF;
336: --
337: -- rlm_core_sv.stop_debug;
330: --
331: IF (l_debug <> -1) THEN
332: rlm_core_sv.dlog(C_DEBUG,'Errors found ');
333: rlm_core_sv.dlog(C_DEBUG,'Error: ',SUBSTR(SQLERRM,1,1500));
334: rlm_core_sv.dpop(C_SDEBUG);
335: END IF;
336: --
337: -- rlm_core_sv.stop_debug;
338: --
333: rlm_core_sv.dlog(C_DEBUG,'Error: ',SUBSTR(SQLERRM,1,1500));
334: rlm_core_sv.dpop(C_SDEBUG);
335: END IF;
336: --
337: -- rlm_core_sv.stop_debug;
338: --
339: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
340:
341: END StartDSPProcess;
359:
360: BEGIN
361: --
362: IF (l_debug <> -1) THEN
363: rlm_core_sv.dpush(C_SDEBUG,'ValidateDemand');
364: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
365: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
366: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
367: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
360: BEGIN
361: --
362: IF (l_debug <> -1) THEN
363: rlm_core_sv.dpush(C_SDEBUG,'ValidateDemand');
364: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
365: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
366: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
367: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
368: END IF;
361: --
362: IF (l_debug <> -1) THEN
363: rlm_core_sv.dpush(C_SDEBUG,'ValidateDemand');
364: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
365: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
366: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
367: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
368: END IF;
369:
362: IF (l_debug <> -1) THEN
363: rlm_core_sv.dpush(C_SDEBUG,'ValidateDemand');
364: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
365: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
366: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
367: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
368: END IF;
369:
370: IF (FUNCMODE = 'RUN') THEN
363: rlm_core_sv.dpush(C_SDEBUG,'ValidateDemand');
364: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
365: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
366: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
367: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
368: END IF;
369:
370: IF (FUNCMODE = 'RUN') THEN
371: -- Executable Statements
371: -- Executable Statements
372: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
373: --
374: IF (l_debug <> -1) THEN
375: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
376: rlm_core_sv.dlog(C_DEBUG,' Before Validate');
377: END IF;
378: --
379: -- Bug 2868593
372: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
373: --
374: IF (l_debug <> -1) THEN
375: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
376: rlm_core_sv.dlog(C_DEBUG,' Before Validate');
377: END IF;
378: --
379: -- Bug 2868593
380: SAVEPOINT s_ValidateDemand;
383: --
384: rlm_validatedemand_sv.GroupValidateDemand(v_header_id, v_status);
385: --
386: IF (l_debug <> -1) THEN
387: rlm_core_sv.dlog(C_DEBUG,' After Validate v_status: ', v_status);
388: rlm_core_sv.dlog(C_DEBUG,'g_schedule_PS', RLM_VALIDATEDEMAND_SV.g_schedule_PS);
389: END IF;
390:
391: SELECT hsecs INTO l_val_end_time FROM v$timer;
384: rlm_validatedemand_sv.GroupValidateDemand(v_header_id, v_status);
385: --
386: IF (l_debug <> -1) THEN
387: rlm_core_sv.dlog(C_DEBUG,' After Validate v_status: ', v_status);
388: rlm_core_sv.dlog(C_DEBUG,'g_schedule_PS', RLM_VALIDATEDEMAND_SV.g_schedule_PS);
389: END IF;
390:
391: SELECT hsecs INTO l_val_end_time FROM v$timer;
392: --
389: END IF;
390:
391: SELECT hsecs INTO l_val_end_time FROM v$timer;
392: --
393: IF v_status <> rlm_core_sv.k_PROC_ERROR THEN
394: --
395: IF RLM_VALIDATEDEMAND_SV.g_schedule_PS <> rlm_core_sv.k_PS_ERROR
396: THEN
397: --
391: SELECT hsecs INTO l_val_end_time FROM v$timer;
392: --
393: IF v_status <> rlm_core_sv.k_PROC_ERROR THEN
394: --
395: IF RLM_VALIDATEDEMAND_SV.g_schedule_PS <> rlm_core_sv.k_PS_ERROR
396: THEN
397: --
398: -- Archive Demand
399: --
397: --
398: -- Archive Demand
399: --
400: IF (l_debug <> -1) THEN
401: rlm_core_sv.dlog(C_DEBUG,'Archiving');
402: END IF;
403: --
404: resultout := 'COMPLETE:CONT';
405: --
406: ELSE
407: -- No Archiving
408: --
409: IF (l_debug <> -1) THEN
410: rlm_core_sv.dlog(C_DEBUG,'Not Archiving');
411: END IF;
412: --
413: resultout := 'COMPLETE:ABT';
414: --
416: --
417: ELSE
418: --
419: IF (l_debug <> -1) THEN
420: rlm_core_sv.dlog(C_DEBUG,'Not Archiving');
421: END IF;
422: --
423: resultout := 'COMPLETE:ABT';
424: --
424: --
425: END IF;
426: --
427:
428: IF (v_status = rlm_core_sv.k_PROC_ERROR) OR (rlm_validatedemand_sv.g_schedule_PS = rlm_core_sv.k_PS_ERROR) THEN
429: --
430: RAISE e_DPFailed;
431: --
432: END IF;
432: END IF;
433: --
434:
435: IF (l_debug <> -1) THEN
436: rlm_core_sv.dpop(C_SDEBUG);
437: END IF;
438: ---
439: RETURN;
440: --
479: EXCEPTION
480: WHEN NO_DATA_FOUND THEN
481: --
482: IF (l_debug <> -1) THEN
483: rlm_core_sv.dlog(C_DEBUG,'NO data found ');
484: END IF;
485: --
486: wf_core.context('RLM_WF_SV','ValidateDemand',
487: itemtype, itemkey,TO_CHAR(actid),funcmode);
487: itemtype, itemkey,TO_CHAR(actid),funcmode);
488: resultout := 'COMPLETE:ABT';
489: --
490: IF (l_debug <> -1) THEN
491: rlm_core_sv.dpop(C_SDEBUG);
492: END IF;
493: --
494: WHEN e_DPFailed THEN
495: --
493: --
494: WHEN e_DPFailed THEN
495: --
496: IF (l_debug <> -1) THEN
497: rlm_core_sv.dlog(C_DEBUG,'Validate Demand failed');
498: END IF;
499: --
500: ROLLBACK TO s_ValidateDemand; /* Bug 2868593 */
501: --
501: --
502: rlm_dp_sv.UpdateGroupPS(v_header_id,
503: g_Sch_rec.schedule_header_id,
504: g_Grp_rec,
505: rlm_core_sv.k_PS_ERROR,
506: 'ALL');
507: --
508: rlm_dp_sv.UpdateHeaderPS(v_header_id,
509: g_Sch_rec.schedule_header_id);
517: itemtype, itemkey,TO_CHAR(actid),funcmode);
518: resultout := 'COMPLETE:ABT';
519: --
520: IF (l_debug <> -1) THEN
521: rlm_core_sv.dpop(C_SDEBUG);
522: END IF;
523: --
524: WHEN OTHERS THEN
525: --
529: --
530: rlm_dp_sv.UpdateGroupPS(v_header_id,
531: g_Sch_rec.schedule_header_id,
532: g_Grp_rec,
533: rlm_core_sv.k_PS_ERROR,
534: 'ALL');
535: --
536: rlm_dp_sv.UpdateHeaderPS(v_header_id,
537: g_Sch_rec.schedule_header_id);
543: --
544: COMMIT;
545: --
546: IF (l_debug <> -1) THEN
547: rlm_core_sv.dpop(C_SDEBUG);
548: END IF;
549: --
550: --RAISE;
551:
569: v_md_msg_text VARCHAR2(32000);
570: BEGIN
571: --
572: IF (l_debug <> -1) THEN
573: rlm_core_sv.dpush(C_SDEBUG,'ManageDemand');
574: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
575: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
576: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
577: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
570: BEGIN
571: --
572: IF (l_debug <> -1) THEN
573: rlm_core_sv.dpush(C_SDEBUG,'ManageDemand');
574: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
575: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
576: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
577: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
578: END IF;
571: --
572: IF (l_debug <> -1) THEN
573: rlm_core_sv.dpush(C_SDEBUG,'ManageDemand');
574: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
575: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
576: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
577: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
578: END IF;
579: --
572: IF (l_debug <> -1) THEN
573: rlm_core_sv.dpush(C_SDEBUG,'ManageDemand');
574: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
575: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
576: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
577: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
578: END IF;
579: --
580: IF (FUNCMODE = 'RUN') THEN
573: rlm_core_sv.dpush(C_SDEBUG,'ManageDemand');
574: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
575: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
576: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
577: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
578: END IF;
579: --
580: IF (FUNCMODE = 'RUN') THEN
581: -- Executable Statements
581: -- Executable Statements
582: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
583: --
584: IF (l_debug <> -1) THEN
585: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
586: END IF;
587: --
588: SAVEPOINT s_child_process;
589:
594: g_Grp_rec,
595: v_status);
596: --
597: IF (l_debug <> -1) THEN
598: rlm_core_sv.dlog(C_DEBUG,' After ManageDemand v_status: ', v_status);
599: END IF;
600: --
601: SELECT hsecs INTO v_md_end_time FROM v$timer;
602: v_md_total:=v_md_total+(v_md_end_time-v_md_start_time)/100;
600: --
601: SELECT hsecs INTO v_md_end_time FROM v$timer;
602: v_md_total:=v_md_total+(v_md_end_time-v_md_start_time)/100;
603:
604: IF v_status = rlm_core_sv.k_PROC_ERROR THEN
605: --
606: RAISE e_DPFailed;
607: --
608: END IF;
609: --
610: resultout := 'COMPLETE:SUCCESS';
611: --
612: IF (l_debug <> -1) THEN
613: rlm_core_sv.dpop(C_SDEBUG);
614: END IF;
615: --
616: v_md_msg_text :='Total Time spent in Managedemand call - '|| v_md_total;
617: fnd_file.put_line(fnd_file.log,v_md_msg_text);
659: EXCEPTION
660: WHEN NO_DATA_FOUND THEN
661: --
662: IF (l_debug <> -1) THEN
663: rlm_core_sv.dlog(C_DEBUG,'NO data found ');
664: END IF;
665: --
666: wf_core.context('RLM_WF_SV','ManageDemand',
667: itemtype, itemkey,TO_CHAR(actid),funcmode);
667: itemtype, itemkey,TO_CHAR(actid),funcmode);
668: resultout := 'COMPLETE:FAILURE';
669: --
670: IF (l_debug <> -1) THEN
671: rlm_core_sv.dpop(C_SDEBUG);
672: END IF;
673: --
674: WHEN e_DPFailed THEN
675: --
673: --
674: WHEN e_DPFailed THEN
675: --
676: IF (l_debug <> -1) THEN
677: rlm_core_sv.dlog(C_DEBUG,'Manage Demand failed');
678: END IF;
679: --
680: ROLLBACK TO s_child_process;
681: --
681: --
682: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
683: g_Sch_rec.schedule_header_id,
684: g_Grp_rec,
685: rlm_core_sv.k_PS_ERROR);
686: COMMIT;
687: wf_core.context('RLM_WF_SV','ManageDemand',
688: itemtype, itemkey,TO_CHAR(actid),funcmode);
689: resultout := 'COMPLETE:FAILURE';
690: --
691: IF NOT rlm_dp_sv.LockHeader(v_header_id, g_Sch_rec) THEN
692: --
693: IF (l_debug <> -1) THEN
694: rlm_core_sv.dlog(C_DEBUG, 'Cannot lock header in MD.e_DPFailed');
695: END IF;
696: --
697: RAISE e_LockH;
698: END IF;
697: RAISE e_LockH;
698: END IF;
699: --
700: IF (l_debug <> -1) THEN
701: rlm_core_sv.dpop(C_SDEBUG);
702: END IF;
703: --
704: WHEN OTHERS THEN
705: wf_core.context('RLM_WF_SV','ManageDemand',
706: itemtype, itemkey,TO_CHAR(actid),funcmode);
707: resultout := 'COMPLETE:FAILURE';
708: --
709: IF (l_debug <> -1) THEN
710: rlm_core_sv.dpop(C_SDEBUG);
711: END IF;
712: --RAISE;
713:
714: END ManageDemand;
732:
733: BEGIN
734: --
735: IF (l_debug <> -1) THEN
736: rlm_core_sv.dpush(C_SDEBUG,'ManageForecast');
737: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
738: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
739: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
740: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
733: BEGIN
734: --
735: IF (l_debug <> -1) THEN
736: rlm_core_sv.dpush(C_SDEBUG,'ManageForecast');
737: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
738: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
739: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
740: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
741: END IF;
734: --
735: IF (l_debug <> -1) THEN
736: rlm_core_sv.dpush(C_SDEBUG,'ManageForecast');
737: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
738: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
739: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
740: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
741: END IF;
742:
735: IF (l_debug <> -1) THEN
736: rlm_core_sv.dpush(C_SDEBUG,'ManageForecast');
737: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
738: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
739: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
740: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
741: END IF;
742:
743: IF (FUNCMODE = 'RUN') THEN
736: rlm_core_sv.dpush(C_SDEBUG,'ManageForecast');
737: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
738: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
739: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
740: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
741: END IF;
742:
743: IF (FUNCMODE = 'RUN') THEN
744: -- Executable Statements
744: -- Executable Statements
745: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
746: --
747: IF (l_debug <> -1) THEN
748: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
749: rlm_core_sv.dlog(C_DEBUG,' ManageForecast');
750: END IF;
751: --
752: SELECT hsecs INTO v_mf_start_time FROM v$timer;
745: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
746: --
747: IF (l_debug <> -1) THEN
748: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
749: rlm_core_sv.dlog(C_DEBUG,' ManageForecast');
750: END IF;
751: --
752: SELECT hsecs INTO v_mf_start_time FROM v$timer;
753:
756: g_Grp_rec,
757: v_status);
758: --
759: IF (l_debug <> -1) THEN
760: rlm_core_sv.dlog(C_DEBUG,' After ManageForecast v_status: ', v_status);
761: END IF;
762: --
763: SELECT hsecs INTO v_mf_end_time FROM v$timer;
764: v_mf_total:=v_mf_total+(v_mf_end_time-v_mf_start_time)/100;
762: --
763: SELECT hsecs INTO v_mf_end_time FROM v$timer;
764: v_mf_total:=v_mf_total+(v_mf_end_time-v_mf_start_time)/100;
765:
766: IF v_status = rlm_core_sv.k_PROC_ERROR THEN
767: --
768: RAISE e_DPFailed;
769: --
770: END IF;
771: --
772: resultout := 'COMPLETE:SUCCESS';
773: --
774: IF (l_debug <> -1) THEN
775: rlm_core_sv.dpop(C_SDEBUG);
776: END IF;
777: --
778: v_mf_msg_text:='Total Time spent in Manageforecast call - '|| v_mf_total ;
779: fnd_file.put_line(fnd_file.log, v_mf_msg_text);
819: EXCEPTION
820: WHEN NO_DATA_FOUND THEN
821: --
822: IF (l_debug <> -1) THEN
823: rlm_core_sv.dlog(C_DEBUG,'NO data found ');
824: END IF;
825: --
826: wf_core.context('RLM_WF_SV','ManageForecast',
827: itemtype, itemkey,TO_CHAR(actid),funcmode);
827: itemtype, itemkey,TO_CHAR(actid),funcmode);
828: resultout := 'COMPLETE:FAILURE';
829: --
830: IF (l_debug <> -1) THEN
831: rlm_core_sv.dpop(C_SDEBUG);
832: END IF;
833: --
834: WHEN e_DPFailed THEN
835: --
833: --
834: WHEN e_DPFailed THEN
835: --
836: IF (l_debug <> -1) THEN
837: rlm_core_sv.dlog(C_DEBUG,'Manage Forecast failed');
838: END IF;
839: --
840: ROLLBACK TO s_child_process;
841: --
841: --
842: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
843: g_Sch_rec.schedule_header_id,
844: g_Grp_rec,
845: rlm_core_sv.k_PS_ERROR);
846: COMMIT;
847:
848: wf_core.context('RLM_WF_SV','ManageForecast',
849: itemtype, itemkey,TO_CHAR(actid),funcmode);
851: --
852: IF NOT rlm_dp_sv.LockHeader(v_header_id, g_Sch_rec) THEN
853: --
854: IF (l_debug <> -1) THEN
855: rlm_core_sv.dlog(C_DEBUG, 'Cannot lock header in FD.e_DPFailed');
856: END IF;
857: --
858: RAISE e_LockH;
859: END IF;
858: RAISE e_LockH;
859: END IF;
860: --
861: IF (l_debug <> -1) THEN
862: rlm_core_sv.dpop(C_SDEBUG);
863: END IF;
864: --
865: WHEN OTHERS THEN
866: wf_core.context('RLM_WF_SV','ManageForecast',
867: itemtype, itemkey,TO_CHAR(actid),funcmode);
868: resultout := 'COMPLETE:FAILURE';
869: --
870: IF (l_debug <> -1) THEN
871: rlm_core_sv.dpop(C_SDEBUG);
872: END IF;
873: --RAISE;
874:
875: END ManageForecast;
892: v_rd_msg_text VARCHAR2(32000);
893: BEGIN
894: --
895: IF (l_debug <> -1) THEN
896: rlm_core_sv.dpush(C_SDEBUG,'ReconcileDemand');
897: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
898: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
899: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
900: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
893: BEGIN
894: --
895: IF (l_debug <> -1) THEN
896: rlm_core_sv.dpush(C_SDEBUG,'ReconcileDemand');
897: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
898: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
899: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
900: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
901: END IF;
894: --
895: IF (l_debug <> -1) THEN
896: rlm_core_sv.dpush(C_SDEBUG,'ReconcileDemand');
897: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
898: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
899: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
900: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
901: END IF;
902: --
895: IF (l_debug <> -1) THEN
896: rlm_core_sv.dpush(C_SDEBUG,'ReconcileDemand');
897: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
898: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
899: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
900: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
901: END IF;
902: --
903: IF (FUNCMODE = 'RUN') THEN
896: rlm_core_sv.dpush(C_SDEBUG,'ReconcileDemand');
897: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
898: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
899: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
900: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
901: END IF;
902: --
903: IF (FUNCMODE = 'RUN') THEN
904: -- Executable Statements
904: -- Executable Statements
905: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
906: --
907: IF (l_debug <> -1) THEN
908: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
909: END IF;
910: --
911: SELECT hsecs INTO v_rd_start_time from v$timer;
912: --
915: g_Grp_rec,
916: v_status);
917: --
918: IF (l_debug <> -1) THEN
919: rlm_core_sv.dlog(C_DEBUG,' After ReconcileDemand v_status: ', v_status);
920: END IF;
921: --
922: SELECT hsecs INTO v_rd_end_time FROM v$timer;
923: v_rd_total :=v_rd_total+(v_rd_end_time-v_rd_start_time)/100;
921: --
922: SELECT hsecs INTO v_rd_end_time FROM v$timer;
923: v_rd_total :=v_rd_total+(v_rd_end_time-v_rd_start_time)/100;
924: --
925: IF v_status = rlm_core_sv.k_PROC_ERROR THEN
926: --
927: RAISE e_DPFailed;
928: --
929: END IF;
930: --
931: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
932: g_Sch_rec.schedule_header_id,
933: g_Grp_rec,
934: rlm_core_sv.k_PS_PROCESSED);
935: --
936: COMMIT;
937: --
938: IF NOT rlm_dp_sv.LockHeader(v_header_id, g_Sch_rec) THEN
937: --
938: IF NOT rlm_dp_sv.LockHeader(v_header_id, g_Sch_rec) THEN
939: --
940: IF (l_debug <> -1) THEN
941: rlm_core_sv.dlog(C_DEBUG,'Unable to lock header after processing grp');
942: END IF;
943: --
944: RAISE e_LockH;
945: --
947: --
948: resultout := 'COMPLETE:SUCCESS';
949: --
950: IF (l_debug <> -1) THEN
951: rlm_core_sv.dpop(C_SDEBUG);
952: END IF;
953: --
954: v_rd_msg_text:='Total Time spent in RecDemand call - '|| v_rd_total ;
955: fnd_file.put_line(fnd_file.log, v_rd_msg_text);
997: EXCEPTION
998: WHEN NO_DATA_FOUND THEN
999: --
1000: IF (l_debug <> -1) THEN
1001: rlm_core_sv.dlog(C_DEBUG,'NO data found ');
1002: END IF;
1003: --
1004: wf_core.context('RLM_WF_SV','ReconcileDemand',
1005: itemtype, itemkey,TO_CHAR(actid),funcmode);
1005: itemtype, itemkey,TO_CHAR(actid),funcmode);
1006: resultout := 'COMPLETE:FAILURE';
1007: --
1008: IF (l_debug <> -1) THEN
1009: rlm_core_sv.dpop(C_SDEBUG);
1010: END IF;
1011: --
1012: WHEN e_DPFailed THEN
1013: --
1011: --
1012: WHEN e_DPFailed THEN
1013: --
1014: IF (l_debug <> -1) THEN
1015: rlm_core_sv.dlog(C_DEBUG,'Reconcile Demand failed');
1016: END IF;
1017: --
1018: IF g_Sch_rec.schedule_type <> RLM_DP_SV.k_SEQUENCED THEN
1019: --
1021: --
1022: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
1023: g_Sch_rec.schedule_header_id,
1024: g_Grp_rec,
1025: rlm_core_sv.k_PS_ERROR);
1026: END IF;
1027: --
1028: COMMIT;
1029: wf_core.context('RLM_WF_SV','ReconcileDemand',
1033: --
1034: IF NOT rlm_dp_sv.LockHeader(v_header_id, g_Sch_rec) THEN
1035: --
1036: IF (l_debug <> -1) THEN
1037: rlm_core_sv.dlog(C_DEBUG, 'Cannot lock header in RD.e_DPFailed');
1038: END IF;
1039: --
1040: RAISE e_LockH;
1041: END IF;
1040: RAISE e_LockH;
1041: END IF;
1042: --
1043: IF (l_debug <> -1) THEN
1044: rlm_core_sv.dpop(C_SDEBUG);
1045: END IF;
1046: --
1047: WHEN OTHERS THEN
1048: wf_core.context('RLM_WF_SV','ReconcileDemand',
1049: itemtype, itemkey,TO_CHAR(actid),funcmode);
1050: resultout := 'COMPLETE:FAILURE';
1051: --
1052: IF (l_debug <> -1) THEN
1053: rlm_core_sv.dpop(C_SDEBUG);
1054: END IF;
1055: --RAISE;
1056:
1057: END ReconcileDemand;
1070: --
1071: BEGIN
1072: --
1073: IF (l_debug <> -1) THEN
1074: rlm_core_sv.dpush(C_SDEBUG,'PurgeInterface');
1075: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1076: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1077: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1078: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1071: BEGIN
1072: --
1073: IF (l_debug <> -1) THEN
1074: rlm_core_sv.dpush(C_SDEBUG,'PurgeInterface');
1075: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1076: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1077: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1078: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1079: END IF;
1072: --
1073: IF (l_debug <> -1) THEN
1074: rlm_core_sv.dpush(C_SDEBUG,'PurgeInterface');
1075: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1076: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1077: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1078: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1079: END IF;
1080: --
1073: IF (l_debug <> -1) THEN
1074: rlm_core_sv.dpush(C_SDEBUG,'PurgeInterface');
1075: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1076: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1077: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1078: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1079: END IF;
1080: --
1081: IF (FUNCMODE = 'RUN') THEN
1074: rlm_core_sv.dpush(C_SDEBUG,'PurgeInterface');
1075: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1076: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1077: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1078: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1079: END IF;
1080: --
1081: IF (FUNCMODE = 'RUN') THEN
1082: -- Executable Statements
1082: -- Executable Statements
1083: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
1084: --
1085: IF (l_debug <> -1) THEN
1086: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
1087: END IF;
1088: --
1089: rlm_message_sv.dump_messages(v_header_id);
1090: rlm_dp_sv.PurgeInterfaceLines(v_header_id);
1093: --
1094: resultout := 'COMPLETE:SUCCESS';
1095: --
1096: IF (l_debug <> -1) THEN
1097: rlm_core_sv.dpop(C_SDEBUG);
1098: END IF;
1099: --
1100: RETURN;
1101: --
1140: EXCEPTION
1141: WHEN NO_DATA_FOUND THEN
1142: --
1143: IF (l_debug <> -1) THEN
1144: rlm_core_sv.dlog(C_DEBUG,'NO data found ');
1145: END IF;
1146: --
1147: wf_core.context('RLM_WF_SV','PurgeInterface',
1148: itemtype, itemkey,TO_CHAR(actid),funcmode);
1148: itemtype, itemkey,TO_CHAR(actid),funcmode);
1149: resultout := 'COMPLETE:FAILURE';
1150: --
1151: IF (l_debug <> -1) THEN
1152: rlm_core_sv.dpop(C_SDEBUG);
1153: END IF;
1154: --
1155: WHEN OTHERS THEN
1156: wf_core.context('RLM_WF_SV','PurgeInterface',
1157: itemtype, itemkey,TO_CHAR(actid),funcmode);
1158: resultout := 'COMPLETE:FAILURE';
1159: --
1160: IF (l_debug <> -1) THEN
1161: rlm_core_sv.dpop(C_SDEBUG);
1162: END IF;
1163: --
1164: RAISE;
1165:
1196:
1197: BEGIN
1198: --
1199: IF (l_debug <> -1) THEN
1200: rlm_core_sv.dpush(C_SDEBUG,'CheckErrors');
1201: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1202: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1203: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1204: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1197: BEGIN
1198: --
1199: IF (l_debug <> -1) THEN
1200: rlm_core_sv.dpush(C_SDEBUG,'CheckErrors');
1201: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1202: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1203: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1204: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1205: END IF;
1198: --
1199: IF (l_debug <> -1) THEN
1200: rlm_core_sv.dpush(C_SDEBUG,'CheckErrors');
1201: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1202: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1203: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1204: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1205: END IF;
1206: --
1199: IF (l_debug <> -1) THEN
1200: rlm_core_sv.dpush(C_SDEBUG,'CheckErrors');
1201: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1202: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1203: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1204: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1205: END IF;
1206: --
1207: IF (FUNCMODE = 'RUN') THEN
1200: rlm_core_sv.dpush(C_SDEBUG,'CheckErrors');
1201: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1202: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1203: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1204: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1205: END IF;
1206: --
1207: IF (FUNCMODE = 'RUN') THEN
1208: -- Executable Statements
1207: IF (FUNCMODE = 'RUN') THEN
1208: -- Executable Statements
1209: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID'); --
1210: IF (l_debug <> -1) THEN
1211: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
1212: END IF;
1213: --
1214: v_request_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'REQUEST_ID');
1215: --
1213: --
1214: v_request_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'REQUEST_ID');
1215: --
1216: IF (l_debug <> -1) THEN
1217: rlm_core_sv.dlog(C_DEBUG,' Request Id :', v_request_id);
1218: END IF;
1219: --
1220: v_schedule_num := wf_engine.GetItemAttrText(itemtype,itemkey,'SCHEDULE_NUMBER');
1221: --
1219: --
1220: v_schedule_num := wf_engine.GetItemAttrText(itemtype,itemkey,'SCHEDULE_NUMBER');
1221: --
1222: IF (l_debug <> -1) THEN
1223: rlm_core_sv.dlog(C_DEBUG,' Schedule Number :', v_schedule_num);
1224: END IF;
1225: --
1226: rlm_message_sv.dump_messages(v_header_id);
1227: rlm_message_sv.initialize_messages;
1235: FROM rlm_interface_headers
1236: WHERE header_id = v_header_id;
1237: --
1238: IF (l_debug <> -1) THEN
1239: rlm_core_sv.dlog(C_DEBUG,' No of Errors :', x_errors);
1240: END IF;
1241: --
1242: IF (x_errors = 0) then
1243: --
1257: resultout := 'COMPLETE:ABT';
1258: END IF;
1259: --
1260: IF (v_process_status IS NOT NULL AND
1261: (v_process_status = rlm_core_sv.k_PS_PARTIAL_PROCESSED OR
1262: v_process_status = RLM_CORE_SV.k_PS_ERROR) ) THEN
1263: --
1264: -- Setting the x_errors to be more than one
1265: -- so that correct return value can be set
1258: END IF;
1259: --
1260: IF (v_process_status IS NOT NULL AND
1261: (v_process_status = rlm_core_sv.k_PS_PARTIAL_PROCESSED OR
1262: v_process_status = RLM_CORE_SV.k_PS_ERROR) ) THEN
1263: --
1264: -- Setting the x_errors to be more than one
1265: -- so that correct return value can be set
1266: x_errors := 1;
1268: --
1269: CLOSE c_process_status_interface;
1270: --
1271: ELSIF (v_process_status IS NOT NULL AND
1272: (v_process_status = rlm_core_sv.k_PS_PARTIAL_PROCESSED OR
1273: v_process_status = RLM_CORE_SV.k_PS_ERROR) ) THEN
1274: -- Setting the x_errors to be more than one
1275: -- so that correct return value can be set
1276: x_errors := 1;
1269: CLOSE c_process_status_interface;
1270: --
1271: ELSIF (v_process_status IS NOT NULL AND
1272: (v_process_status = rlm_core_sv.k_PS_PARTIAL_PROCESSED OR
1273: v_process_status = RLM_CORE_SV.k_PS_ERROR) ) THEN
1274: -- Setting the x_errors to be more than one
1275: -- so that correct return value can be set
1276: x_errors := 1;
1277: END IF;
1297: IF (x_errors > 0 ) THEN
1298: resultout := 'COMPLETE:ERRORS';
1299: --
1300: IF (l_debug <> -1) THEN
1301: rlm_core_sv.dlog(C_DEBUG,' resultout :', resultout);
1302: rlm_core_sv.dpop(C_SDEBUG);
1303: END IF;
1304: --
1305: RETURN;
1298: resultout := 'COMPLETE:ERRORS';
1299: --
1300: IF (l_debug <> -1) THEN
1301: rlm_core_sv.dlog(C_DEBUG,' resultout :', resultout);
1302: rlm_core_sv.dpop(C_SDEBUG);
1303: END IF;
1304: --
1305: RETURN;
1306: ELSE
1306: ELSE
1307: resultout := 'COMPLETE:N';
1308: --
1309: IF (l_debug <> -1) THEN
1310: rlm_core_sv.dlog(C_DEBUG,' resultout :', resultout);
1311: rlm_core_sv.dpop(C_SDEBUG);
1312: END IF;
1313: --
1314: RETURN;
1307: resultout := 'COMPLETE:N';
1308: --
1309: IF (l_debug <> -1) THEN
1310: rlm_core_sv.dlog(C_DEBUG,' resultout :', resultout);
1311: rlm_core_sv.dpop(C_SDEBUG);
1312: END IF;
1313: --
1314: RETURN;
1315: END IF;
1355: EXCEPTION
1356: WHEN NO_DATA_FOUND THEN
1357: --
1358: IF (l_debug <> -1) THEN
1359: rlm_core_sv.dlog(C_DEBUG,'NO data found ');
1360: END IF;
1361: --
1362: wf_core.context('RLM_WF_SV','CheckErrors',
1363: itemtype, itemkey,TO_CHAR(actid),funcmode);
1363: itemtype, itemkey,TO_CHAR(actid),funcmode);
1364: resultout := 'COMPLETE:ABT';
1365: --
1366: IF (l_debug <> -1) THEN
1367: rlm_core_sv.dpop(C_SDEBUG);
1368: END IF;
1369: --
1370: WHEN OTHERS THEN
1371: wf_core.context('RLM_WF_SV','CheckErrors',
1372: itemtype, itemkey,TO_CHAR(actid),funcmode);
1373: resultout := 'COMPLETE:ABT';
1374: --
1375: IF (l_debug <> -1) THEN
1376: rlm_core_sv.dpop(C_SDEBUG);
1377: END IF;
1378: --
1379: RAISE;
1380:
1404: --
1405: BEGIN
1406: --
1407: IF (l_debug <> -1) THEN
1408: rlm_core_sv.dpush(C_SDEBUG,'RunReport');
1409: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1410: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1411: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1412: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1405: BEGIN
1406: --
1407: IF (l_debug <> -1) THEN
1408: rlm_core_sv.dpush(C_SDEBUG,'RunReport');
1409: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1410: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1411: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1412: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1413: END IF;
1406: --
1407: IF (l_debug <> -1) THEN
1408: rlm_core_sv.dpush(C_SDEBUG,'RunReport');
1409: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1410: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1411: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1412: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1413: END IF;
1414: --
1407: IF (l_debug <> -1) THEN
1408: rlm_core_sv.dpush(C_SDEBUG,'RunReport');
1409: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1410: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1411: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1412: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1413: END IF;
1414: --
1415: IF (FUNCMODE = 'RUN') THEN
1408: rlm_core_sv.dpush(C_SDEBUG,'RunReport');
1409: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1410: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1411: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1412: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1413: END IF;
1414: --
1415: IF (FUNCMODE = 'RUN') THEN
1416: -- Executable Statements
1416: -- Executable Statements
1417: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
1418: --
1419: IF (l_debug <> -1) THEN
1420: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
1421: END IF;
1422: --
1423: v_org_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'ORG_ID');
1424: --
1422: --
1423: v_org_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'ORG_ID');
1424: --
1425: IF (l_debug <> -1) THEN
1426: rlm_core_sv.dlog(C_DEBUG,' Org Id :', v_org_id);
1427: END IF;
1428: --
1429: v_request_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'REQUEST_ID');
1430: --
1428: --
1429: v_request_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'REQUEST_ID');
1430: --
1431: IF (l_debug <> -1) THEN
1432: rlm_core_sv.dlog(C_DEBUG,' Request Id :', v_request_id);
1433: END IF;
1434: --
1435: v_sched_num := wf_engine.GetItemAttrText(itemtype,itemkey,'SCHEDULE_NUMBER');
1436: --
1434: --
1435: v_sched_num := wf_engine.GetItemAttrText(itemtype,itemkey,'SCHEDULE_NUMBER');
1436: --
1437: IF (l_debug <> -1) THEN
1438: rlm_core_sv.dlog(C_DEBUG,' Schedule Number :', v_sched_num);
1439: END IF;
1440:
1441: /*
1442: -- Needs to be used once DSP concurrent program sets print options parameters
1492:
1493: resultout := 'COMPLETE:SUCCESS';
1494: --
1495: IF (l_debug <> -1) THEN
1496: rlm_core_sv.dpop(C_SDEBUG);
1497: END IF;
1498: --
1499: RETURN;
1500: END IF;
1538: EXCEPTION
1539: WHEN NO_DATA_FOUND THEN
1540: --
1541: IF (l_debug <> -1) THEN
1542: rlm_core_sv.dlog(C_DEBUG,'NO data found ');
1543: END IF;
1544: --
1545: wf_core.context('RLM_WF_SV','RunReport',
1546: itemtype, itemkey,TO_CHAR(actid),funcmode);
1546: itemtype, itemkey,TO_CHAR(actid),funcmode);
1547: resultout := 'COMPLETE:FAILURE';
1548: --
1549: IF (l_debug <> -1) THEN
1550: rlm_core_sv.dpop(C_SDEBUG);
1551: END IF;
1552: --
1553: WHEN OTHERS THEN
1554: wf_core.context('RLM_WF_SV','RunReport',
1555: itemtype, itemkey,TO_CHAR(actid),funcmode);
1556: resultout := 'COMPLETE:FAILURE';
1557: --
1558: IF (l_debug <> -1) THEN
1559: rlm_core_sv.dpop(C_SDEBUG);
1560: END IF;
1561: --
1562: RAISE;
1563:
1571: IS
1572: BEGIN
1573: --
1574: IF (l_debug <> -1) THEN
1575: rlm_core_sv.dpush(C_SDEBUG,'GetScheduleDetails');
1576: rlm_core_sv.dlog(C_DEBUG,'x_Header_Id ', x_Header_Id);
1577: END IF;
1578: --
1579: select schedule_reference_num, cust_name_ext, sched_generation_date
1572: BEGIN
1573: --
1574: IF (l_debug <> -1) THEN
1575: rlm_core_sv.dpush(C_SDEBUG,'GetScheduleDetails');
1576: rlm_core_sv.dlog(C_DEBUG,'x_Header_Id ', x_Header_Id);
1577: END IF;
1578: --
1579: select schedule_reference_num, cust_name_ext, sched_generation_date
1580: into x_Schedule_Num, x_Customer_Name , x_Schedule_Gen_Date
1581: from rlm_interface_headers
1582: where header_id = x_Header_Id ;
1583: --
1584: IF (l_debug <> -1) THEN
1585: rlm_core_sv.dlog(C_DEBUG,' Schedule Generation Date :',
1586: TO_CHAR(x_Schedule_Gen_Date));
1587: rlm_core_sv.dlog(C_DEBUG,' Successful select');
1588: rlm_core_sv.dpop(C_SDEBUG);
1589: END IF;
1583: --
1584: IF (l_debug <> -1) THEN
1585: rlm_core_sv.dlog(C_DEBUG,' Schedule Generation Date :',
1586: TO_CHAR(x_Schedule_Gen_Date));
1587: rlm_core_sv.dlog(C_DEBUG,' Successful select');
1588: rlm_core_sv.dpop(C_SDEBUG);
1589: END IF;
1590: --
1591: EXCEPTION
1584: IF (l_debug <> -1) THEN
1585: rlm_core_sv.dlog(C_DEBUG,' Schedule Generation Date :',
1586: TO_CHAR(x_Schedule_Gen_Date));
1587: rlm_core_sv.dlog(C_DEBUG,' Successful select');
1588: rlm_core_sv.dpop(C_SDEBUG);
1589: END IF;
1590: --
1591: EXCEPTION
1592: WHEN NO_DATA_FOUND THEN
1591: EXCEPTION
1592: WHEN NO_DATA_FOUND THEN
1593: --
1594: IF (l_debug <> -1) THEN
1595: rlm_core_sv.dpop(C_SDEBUG, 'No Data Found');
1596: END IF;
1597: --
1598: WHEN OTHERS THEN
1599: --
1597: --
1598: WHEN OTHERS THEN
1599: --
1600: IF (l_debug <> -1) THEN
1601: rlm_core_sv.dpop(C_SDEBUG, 'Other Errors');
1602: END IF;
1603:
1604: END GetScheduleDetails;
1605:
1626: e_DSPFailed EXCEPTION;
1627: BEGIN
1628: --
1629: IF (l_debug <> -1) THEN
1630: rlm_core_sv.dpush(C_SDEBUG,'StartDSPLoop');
1631: rlm_core_sv.dlog(C_DEBUG,'p_Header_Id ', p_Header_Id);
1632: rlm_core_sv.dlog(C_DEBUG,'Starting process:',v_ItemKey);
1633: rlm_core_sv.dlog(C_DEBUG,'Org ID', v_org_id);
1634: END IF;
1627: BEGIN
1628: --
1629: IF (l_debug <> -1) THEN
1630: rlm_core_sv.dpush(C_SDEBUG,'StartDSPLoop');
1631: rlm_core_sv.dlog(C_DEBUG,'p_Header_Id ', p_Header_Id);
1632: rlm_core_sv.dlog(C_DEBUG,'Starting process:',v_ItemKey);
1633: rlm_core_sv.dlog(C_DEBUG,'Org ID', v_org_id);
1634: END IF;
1635: --
1628: --
1629: IF (l_debug <> -1) THEN
1630: rlm_core_sv.dpush(C_SDEBUG,'StartDSPLoop');
1631: rlm_core_sv.dlog(C_DEBUG,'p_Header_Id ', p_Header_Id);
1632: rlm_core_sv.dlog(C_DEBUG,'Starting process:',v_ItemKey);
1633: rlm_core_sv.dlog(C_DEBUG,'Org ID', v_org_id);
1634: END IF;
1635: --
1636: -- fnd_profile.get('ORG_ID', v_org_id);
1629: IF (l_debug <> -1) THEN
1630: rlm_core_sv.dpush(C_SDEBUG,'StartDSPLoop');
1631: rlm_core_sv.dlog(C_DEBUG,'p_Header_Id ', p_Header_Id);
1632: rlm_core_sv.dlog(C_DEBUG,'Starting process:',v_ItemKey);
1633: rlm_core_sv.dlog(C_DEBUG,'Org ID', v_org_id);
1634: END IF;
1635: --
1636: -- fnd_profile.get('ORG_ID', v_org_id);
1637: --
1637: --
1638: v_org_id := v_Sch_rec.org_id;
1639: --
1640: IF (l_debug <> -1) THEN
1641: rlm_core_sv.dlog(C_DEBUG,'Org Id ', v_org_id);
1642: END IF;
1643: --
1644: -- Bug#: 3053299 - Added Schedule Generation Date as argument
1645: GetScheduleDetails(p_Header_Id, v_ScheduleNum, v_Customer, v_ScheduleGenDate);
1644: -- Bug#: 3053299 - Added Schedule Generation Date as argument
1645: GetScheduleDetails(p_Header_Id, v_ScheduleNum, v_Customer, v_ScheduleGenDate);
1646: --
1647: IF (l_debug <> -1) THEN
1648: rlm_core_sv.dlog(C_DEBUG,'v_ScheduleNum ', v_ScheduleNum);
1649: rlm_core_sv.dlog(C_DEBUG,'v_Customer ', v_Customer);
1650: END IF;
1651: --
1652: -- Set various Header Attributes
1645: GetScheduleDetails(p_Header_Id, v_ScheduleNum, v_Customer, v_ScheduleGenDate);
1646: --
1647: IF (l_debug <> -1) THEN
1648: rlm_core_sv.dlog(C_DEBUG,'v_ScheduleNum ', v_ScheduleNum);
1649: rlm_core_sv.dlog(C_DEBUG,'v_Customer ', v_Customer);
1650: END IF;
1651: --
1652: -- Set various Header Attributes
1653:
1717: v_ScheduleGenDate);
1718:
1719: --
1720: IF (l_debug <> -1) THEN
1721: rlm_core_sv.dlog(C_DEBUG,'Before Start Process DSP Loop');
1722: END IF;
1723: --
1724: wf_engine.StartProcess(v_ItemType, v_ItemKey);
1725: --
1723: --
1724: wf_engine.StartProcess(v_ItemType, v_ItemKey);
1725: --
1726: IF (l_debug <> -1) THEN
1727: rlm_core_sv.dlog(C_DEBUG,'After Start Process DSP Loop ');
1728: END IF;
1729: --
1730: v_retcode := wf_engine.GetItemAttrNumber(v_ItemType,v_ItemKey,'ERRORS_EXIST');
1731: --
1729: --
1730: v_retcode := wf_engine.GetItemAttrNumber(v_ItemType,v_ItemKey,'ERRORS_EXIST');
1731: --
1732: IF (l_debug <> -1) THEN
1733: rlm_core_sv.dlog(C_DEBUG,' Errors Status: ', v_retcode);
1734: END IF;
1735: --
1736: retcode := g_PROC_SUCCESS;
1737: --
1735: --
1736: retcode := g_PROC_SUCCESS;
1737: --
1738: IF (l_debug <> -1) THEN
1739: rlm_core_sv.dpop(C_SDEBUG);
1740: END IF;
1741: --
1742: EXCEPTION
1743: --
1743: --
1744: WHEN OTHERS THEN
1745: --
1746: IF (l_debug <> -1) THEN
1747: rlm_core_sv.dlog(C_DEBUG,'Errors found ');
1748: rlm_core_sv.dlog(C_DEBUG,'Error: ',SUBSTR(SQLERRM,1,1500));
1749: END IF;
1750: --
1751: retcode := g_PROC_ERROR;
1744: WHEN OTHERS THEN
1745: --
1746: IF (l_debug <> -1) THEN
1747: rlm_core_sv.dlog(C_DEBUG,'Errors found ');
1748: rlm_core_sv.dlog(C_DEBUG,'Error: ',SUBSTR(SQLERRM,1,1500));
1749: END IF;
1750: --
1751: retcode := g_PROC_ERROR;
1752: --
1750: --
1751: retcode := g_PROC_ERROR;
1752: --
1753: IF (l_debug <> -1) THEN
1754: rlm_core_sv.dpop(C_SDEBUG);
1755: END IF;
1756: --
1757: -- rlm_core_sv.stop_debug;
1758: --
1753: IF (l_debug <> -1) THEN
1754: rlm_core_sv.dpop(C_SDEBUG);
1755: END IF;
1756: --
1757: -- rlm_core_sv.stop_debug;
1758: --
1759: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1760:
1761: END StartDSPLoop;
1781: --
1782: BEGIN
1783: --
1784: IF (l_debug <> -1) THEN
1785: rlm_core_sv.dpush(C_SDEBUG,'CreateDSPLoop');
1786: rlm_core_sv.dlog(C_DEBUG,'p_Header_Id ', p_Header_Id);
1787: rlm_core_sv.dlog(C_DEBUG,'Creating Loop:',v_ItemKey);
1788: rlm_core_Sv.dlog(C_DEBUG, 'v_ItemType', v_ItemType);
1789: END IF;
1782: BEGIN
1783: --
1784: IF (l_debug <> -1) THEN
1785: rlm_core_sv.dpush(C_SDEBUG,'CreateDSPLoop');
1786: rlm_core_sv.dlog(C_DEBUG,'p_Header_Id ', p_Header_Id);
1787: rlm_core_sv.dlog(C_DEBUG,'Creating Loop:',v_ItemKey);
1788: rlm_core_Sv.dlog(C_DEBUG, 'v_ItemType', v_ItemType);
1789: END IF;
1790: --
1783: --
1784: IF (l_debug <> -1) THEN
1785: rlm_core_sv.dpush(C_SDEBUG,'CreateDSPLoop');
1786: rlm_core_sv.dlog(C_DEBUG,'p_Header_Id ', p_Header_Id);
1787: rlm_core_sv.dlog(C_DEBUG,'Creating Loop:',v_ItemKey);
1788: rlm_core_Sv.dlog(C_DEBUG, 'v_ItemType', v_ItemType);
1789: END IF;
1790: --
1791: -- fnd_profile.get('ORG_ID', v_org_id);
1784: IF (l_debug <> -1) THEN
1785: rlm_core_sv.dpush(C_SDEBUG,'CreateDSPLoop');
1786: rlm_core_sv.dlog(C_DEBUG,'p_Header_Id ', p_Header_Id);
1787: rlm_core_sv.dlog(C_DEBUG,'Creating Loop:',v_ItemKey);
1788: rlm_core_Sv.dlog(C_DEBUG, 'v_ItemType', v_ItemType);
1789: END IF;
1790: --
1791: -- fnd_profile.get('ORG_ID', v_org_id);
1792: --
1790: --
1791: -- fnd_profile.get('ORG_ID', v_org_id);
1792: --
1793: IF (l_debug <> -1) THEN
1794: rlm_core_sv.dlog(C_DEBUG, 'Org Id ', MO_GLOBAL.get_current_org_id);
1795: END IF;
1796: --
1797: -- Abort the process if it has hung
1798: BEGIN
1797: -- Abort the process if it has hung
1798: BEGIN
1799: --
1800: IF (l_debug <> -1) THEN
1801: rlm_core_sv.dlog(C_DEBUG,'Aborting old processes');
1802: END IF;
1803: --
1804: wf_engine.AbortProcess(itemtype => v_ItemType,
1805: itemkey => v_ItemKey);
1804: wf_engine.AbortProcess(itemtype => v_ItemType,
1805: itemkey => v_ItemKey);
1806: --
1807: IF (l_debug <> -1) THEN
1808: rlm_core_sv.dlog(C_DEBUG,'after abort bad process');
1809: END IF;
1810: --
1811: EXCEPTION
1812: WHEN OTHERS THEN
1811: EXCEPTION
1812: WHEN OTHERS THEN
1813: --
1814: IF (l_debug <> -1) THEN
1815: rlm_core_sv.dlog(C_DEBUG,'Did not abort any process');
1816: END IF;
1817: --
1818: END;
1819: --
1826: docommit => FALSE,
1827: force => TRUE);
1828: --
1829: IF (l_debug <> -1) THEN
1830: rlm_core_sv.dlog(C_DEBUG,'After Purge for Item key ',v_ItemKey);
1831: END IF;
1832: --
1833: wf_engine.CreateProcess(v_ItemType, v_ItemKey, v_ProcessName);
1834: wf_engine.SetItemParent(v_ItemType,v_ItemKey,v_ItemType,to_char(p_Header_Id),
1840: --
1841: retcode := g_PROC_SUCCESS;
1842: --
1843: IF (l_debug <> -1) THEN
1844: rlm_core_sv.dlog(C_DEBUG,'After Create Process DSP Loop ');
1845: rlm_core_sv.dpop(C_SDEBUG);
1846: END IF;
1847:
1848: EXCEPTION
1841: retcode := g_PROC_SUCCESS;
1842: --
1843: IF (l_debug <> -1) THEN
1844: rlm_core_sv.dlog(C_DEBUG,'After Create Process DSP Loop ');
1845: rlm_core_sv.dpop(C_SDEBUG);
1846: END IF;
1847:
1848: EXCEPTION
1849: WHEN OTHERS THEN
1848: EXCEPTION
1849: WHEN OTHERS THEN
1850: --
1851: IF (l_debug <> -1) THEN
1852: rlm_core_sv.dlog(C_DEBUG,'Errors found ');
1853: rlm_core_sv.dlog(C_DEBUG,'Error: ',SUBSTR(SQLERRM,1,1500));
1854: END IF;
1855: --
1856: retcode := g_PROC_ERROR;
1849: WHEN OTHERS THEN
1850: --
1851: IF (l_debug <> -1) THEN
1852: rlm_core_sv.dlog(C_DEBUG,'Errors found ');
1853: rlm_core_sv.dlog(C_DEBUG,'Error: ',SUBSTR(SQLERRM,1,1500));
1854: END IF;
1855: --
1856: retcode := g_PROC_ERROR;
1857: --
1855: --
1856: retcode := g_PROC_ERROR;
1857: --
1858: IF (l_debug <> -1) THEN
1859: rlm_core_sv.dpop(C_SDEBUG);
1860: END IF;
1861: --
1862: -- rlm_core_sv.stop_debug;
1863: --
1858: IF (l_debug <> -1) THEN
1859: rlm_core_sv.dpop(C_SDEBUG);
1860: END IF;
1861: --
1862: -- rlm_core_sv.stop_debug;
1863: --
1864: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1865:
1866:
1879: --
1880: BEGIN
1881: --
1882: IF (l_debug <> -1) THEN
1883: rlm_core_sv.dpush(C_SDEBUG,'UpdateHeaderPS');
1884: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1885: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1886: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1887: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1880: BEGIN
1881: --
1882: IF (l_debug <> -1) THEN
1883: rlm_core_sv.dpush(C_SDEBUG,'UpdateHeaderPS');
1884: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1885: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1886: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1887: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1888: END IF;
1881: --
1882: IF (l_debug <> -1) THEN
1883: rlm_core_sv.dpush(C_SDEBUG,'UpdateHeaderPS');
1884: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1885: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1886: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1887: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1888: END IF;
1889: --
1882: IF (l_debug <> -1) THEN
1883: rlm_core_sv.dpush(C_SDEBUG,'UpdateHeaderPS');
1884: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1885: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1886: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1887: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1888: END IF;
1889: --
1890: IF (FUNCMODE = 'RUN') THEN
1883: rlm_core_sv.dpush(C_SDEBUG,'UpdateHeaderPS');
1884: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
1885: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
1886: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
1887: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
1888: END IF;
1889: --
1890: IF (FUNCMODE = 'RUN') THEN
1891: -- Executable Statements
1892: --
1893: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
1894: --
1895: IF (l_debug <> -1) THEN
1896: rlm_core_sv.dlog(C_DEBUG,'WF Header_id :',v_header_id);
1897: rlm_core_sv.dlog(C_DEBUG,' Header_id :', g_Sch_rec.header_id);
1898: rlm_core_sv.dlog(C_DEBUG,'schedule_header_id',
1899: g_Sch_rec.schedule_header_id);
1900:
1893: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
1894: --
1895: IF (l_debug <> -1) THEN
1896: rlm_core_sv.dlog(C_DEBUG,'WF Header_id :',v_header_id);
1897: rlm_core_sv.dlog(C_DEBUG,' Header_id :', g_Sch_rec.header_id);
1898: rlm_core_sv.dlog(C_DEBUG,'schedule_header_id',
1899: g_Sch_rec.schedule_header_id);
1900:
1901: END IF;
1894: --
1895: IF (l_debug <> -1) THEN
1896: rlm_core_sv.dlog(C_DEBUG,'WF Header_id :',v_header_id);
1897: rlm_core_sv.dlog(C_DEBUG,' Header_id :', g_Sch_rec.header_id);
1898: rlm_core_sv.dlog(C_DEBUG,'schedule_header_id',
1899: g_Sch_rec.schedule_header_id);
1900:
1901: END IF;
1902: --
1902: --
1903: IF g_Sch_rec.header_id IS NULL THEN
1904: --
1905: IF (l_debug <> -1) THEN
1906: rlm_core_sv.dlog(C_DEBUG,'Assigning the global variable.');
1907: END IF;
1908: --
1909: SELECT * INTO g_Sch_rec
1910: FROM rlm_interface_headers
1917: --
1918: resultout := 'COMPLETE:SUCCESS';
1919: --
1920: IF (l_debug <> -1) THEN
1921: rlm_core_sv.dpop(C_SDEBUG);
1922: END IF;
1923: --
1924: RETURN;
1925: --
1964: EXCEPTION
1965: WHEN NO_DATA_FOUND THEN
1966: --
1967: IF (l_debug <> -1) THEN
1968: rlm_core_sv.dlog(C_DEBUG,'NO data found ');
1969: END IF;
1970: --
1971: wf_core.context('RLM_WF_SV','UpdateHeaderPS',
1972: itemtype, itemkey,TO_CHAR(actid),funcmode);
1972: itemtype, itemkey,TO_CHAR(actid),funcmode);
1973: resultout := 'COMPLETE:FAILURE';
1974: --
1975: IF (l_debug <> -1) THEN
1976: rlm_core_sv.dpop(C_SDEBUG);
1977: END IF;
1978: --
1979: WHEN OTHERS THEN
1980: --
1978: --
1979: WHEN OTHERS THEN
1980: --
1981: IF (l_debug <> -1) THEN
1982: rlm_core_sv.dlog(C_DEBUG,'When Others');
1983: END IF;
1984: --
1985: wf_core.context('RLM_WF_SV','UpdateHeaderPS',
1986: itemtype, itemkey,TO_CHAR(actid),funcmode);
1986: itemtype, itemkey,TO_CHAR(actid),funcmode);
1987: resultout := 'COMPLETE:FAILURE';
1988: --
1989: IF (l_debug <> -1) THEN
1990: rlm_core_sv.dpop(C_SDEBUG);
1991: END IF;
1992: --RAISE;
1993: END UpdateHeaderPS;
1994:
2021: --
2022: BEGIN
2023: --
2024: IF (l_debug <> -1) THEN
2025: rlm_core_sv.dpush(C_SDEBUG,'ProcessGroupDemand');
2026: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2027: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2028: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2029: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2022: BEGIN
2023: --
2024: IF (l_debug <> -1) THEN
2025: rlm_core_sv.dpush(C_SDEBUG,'ProcessGroupDemand');
2026: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2027: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2028: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2029: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2030: END IF;
2023: --
2024: IF (l_debug <> -1) THEN
2025: rlm_core_sv.dpush(C_SDEBUG,'ProcessGroupDemand');
2026: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2027: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2028: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2029: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2030: END IF;
2031: --
2024: IF (l_debug <> -1) THEN
2025: rlm_core_sv.dpush(C_SDEBUG,'ProcessGroupDemand');
2026: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2027: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2028: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2029: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2030: END IF;
2031: --
2032: IF (FUNCMODE = 'RUN') THEN
2025: rlm_core_sv.dpush(C_SDEBUG,'ProcessGroupDemand');
2026: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2027: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2028: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2029: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2030: END IF;
2031: --
2032: IF (FUNCMODE = 'RUN') THEN
2033: -- Executable Statements
2033: -- Executable Statements
2034: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
2035: --
2036: IF (l_debug <> -1) THEN
2037: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
2038: END IF;
2039: --
2040: SAVEPOINT s_child_process;
2041: SELECT hsecs INTO v_md_start_time FROM v$timer;
2044: g_Grp_rec,
2045: v_status);
2046: --
2047: IF (l_debug <> -1) THEN
2048: rlm_core_sv.dlog(C_DEBUG,' After ManageDemand v_status: ', v_status);
2049: END IF;
2050: --
2051: SELECT hsecs INTO v_md_end_time FROM v$timer;
2052: v_md_total:=v_md_total+(v_md_end_time-v_md_start_time)/100;
2050: --
2051: SELECT hsecs INTO v_md_end_time FROM v$timer;
2052: v_md_total:=v_md_total+(v_md_end_time-v_md_start_time)/100;
2053:
2054: IF v_status = rlm_core_sv.k_PROC_ERROR THEN
2055: --
2056: RAISE e_MDFailed;
2057: --
2058: END IF;
2057: --
2058: END IF;
2059: --
2060: IF (l_debug <> -1) THEN
2061: rlm_core_sv.dlog(C_DEBUG,'Before Manage Forecast');
2062: END IF;
2063: --
2064: SELECT hsecs INTO v_mf_start_time FROM v$timer;
2065:
2068: g_Grp_rec,
2069: v_status);
2070: --
2071: IF (l_debug <> -1) THEN
2072: rlm_core_sv.dlog(C_DEBUG,' After ManageForecast v_status: ', v_status);
2073: END IF;
2074: --
2075: SELECT hsecs INTO v_mf_end_time FROM v$timer;
2076: v_mf_total:=v_mf_total+(v_mf_end_time-v_mf_start_time)/100;
2074: --
2075: SELECT hsecs INTO v_mf_end_time FROM v$timer;
2076: v_mf_total:=v_mf_total+(v_mf_end_time-v_mf_start_time)/100;
2077:
2078: IF v_status = rlm_core_sv.k_PROC_ERROR THEN
2079: --
2080: RAISE e_MFFailed;
2081: --
2082: END IF;
2081: --
2082: END IF;
2083: --
2084: IF (l_debug <> -1) THEN
2085: rlm_core_sv.dlog(C_DEBUG,'Before Reconcile Demand');
2086: END IF;
2087: --
2088: SELECT hsecs INTO v_rd_start_time FROM v$timer;
2089:
2093: v_status);
2094:
2095: --
2096: IF (l_debug <> -1) THEN
2097: rlm_core_sv.dlog(C_DEBUG, 'After ReconcileDemand v_status', v_status);
2098: END IF;
2099: --
2100: SELECT hsecs INTO v_rd_end_time FROM v$timer;
2101: v_rd_total :=v_rd_total+(v_rd_end_time-v_rd_start_time)/100;
2099: --
2100: SELECT hsecs INTO v_rd_end_time FROM v$timer;
2101: v_rd_total :=v_rd_total+(v_rd_end_time-v_rd_start_time)/100;
2102: --
2103: IF v_status = rlm_core_sv.k_PROC_ERROR THEN
2104: --
2105: RAISE e_RDFailed;
2106: --
2107: END IF;
2108: --
2109: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
2110: g_Sch_rec.schedule_header_id,
2111: g_Grp_rec,
2112: rlm_core_sv.k_PS_PROCESSED);
2113:
2114: COMMIT;
2115: --
2116: resultout := 'COMPLETE:SUCCESS';
2115: --
2116: resultout := 'COMPLETE:SUCCESS';
2117: --
2118: IF (l_debug <> -1) THEN
2119: rlm_core_sv.dpop(C_SDEBUG);
2120: END IF;
2121: --
2122: l_msg_text:='Total Time spent in Validatedemand call - '||
2123: (l_val_end_time-l_val_start_time)/100;
2179: EXCEPTION
2180: WHEN NO_DATA_FOUND THEN
2181: --
2182: IF (l_debug <> -1) THEN
2183: rlm_core_sv.dlog(C_DEBUG,'NO data found ');
2184: END IF;
2185: --
2186: wf_core.context('RLM_WF_SV','ProcessGroupDemand',
2187: itemtype, itemkey,TO_CHAR(actid),funcmode);
2187: itemtype, itemkey,TO_CHAR(actid),funcmode);
2188: resultout := 'COMPLETE:FAILURE';
2189: --
2190: IF (l_debug <> -1) THEN
2191: rlm_core_sv.dpop(C_SDEBUG);
2192: END IF;
2193: --
2194: WHEN e_MDFailed THEN
2195: --
2193: --
2194: WHEN e_MDFailed THEN
2195: --
2196: IF (l_debug <> -1) THEN
2197: rlm_core_sv.dlog(C_DEBUG,'Manage Demand failed');
2198: END IF;
2199: --
2200: ROLLBACK TO s_child_process;
2201: --
2201: --
2202: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
2203: g_Sch_rec.schedule_header_id,
2204: g_Grp_rec,
2205: rlm_core_sv.k_PS_ERROR);
2206:
2207: -- Bug#: 2771756 - Start
2208: -- Bug: 4198330 added grouping info
2209: rlm_message_sv.removeMessages(
2224: --
2225: IF NOT rlm_dp_sv.LockHeader(v_header_id, g_Sch_rec) THEN
2226: --
2227: IF (l_debug <> -1) THEN
2228: rlm_core_sv.dlog(C_DEBUG, 'Unable to lock header in e_MDFailed');
2229: END IF;
2230: --
2231: RAISE e_LockH;
2232: --
2232: --
2233: END IF;
2234: --
2235: IF (l_debug <> -1) THEN
2236: rlm_core_sv.dpop(C_SDEBUG);
2237: END IF;
2238: --
2239: WHEN e_MFFailed THEN
2240: --
2238: --
2239: WHEN e_MFFailed THEN
2240: --
2241: IF (l_debug <> -1) THEN
2242: rlm_core_sv.dlog(C_DEBUG,'Manage Forecast failed');
2243: END IF;
2244: --
2245: ROLLBACK TO s_child_process;
2246: --
2246: --
2247: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
2248: g_Sch_rec.schedule_header_id,
2249: g_Grp_rec,
2250: rlm_core_sv.k_PS_ERROR);
2251:
2252: -- Bug#: 2771756 - Start
2253: -- Bug: 4198330 added grouping info
2254: rlm_message_sv.removeMessages(
2268: --
2269: IF NOT rlm_dp_sv.LockHeader(v_header_id, g_Sch_rec) THEN
2270: --
2271: IF (l_debug <> -1) THEN
2272: rlm_core_sv.dlog(C_DEBUG, 'Unable to lock header in e_FDFailed');
2273: END IF;
2274: --
2275: RAISE e_LockH;
2276: --
2276: --
2277: END IF;
2278: --
2279: IF (l_debug <> -1) THEN
2280: rlm_core_sv.dpop(C_SDEBUG);
2281: END IF;
2282: --
2283: WHEN e_RDFailed THEN
2284: --
2282: --
2283: WHEN e_RDFailed THEN
2284: --
2285: IF (l_debug <> -1) THEN
2286: rlm_core_sv.dlog(C_DEBUG,'Reconcile Demand failed');
2287: END IF;
2288: --
2289: ROLLBACK TO s_child_process;
2290: --
2290: --
2291: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
2292: g_Sch_rec.schedule_header_id,
2293: g_Grp_rec,
2294: rlm_core_sv.k_PS_ERROR);
2295: -- Bug#: 2771756 - Start
2296: -- Bug: 4198330 added grouping info
2297: rlm_message_sv.removeMessages(
2298: p_header_id => v_header_id,
2312: --
2313: IF NOT rlm_dp_sv.LockHeader(v_header_id, g_Sch_rec) THEN
2314: --
2315: IF (l_debug <> -1) THEN
2316: rlm_core_sv.dlog(C_DEBUG, 'Unable to lock header in e_RDFailed');
2317: END IF;
2318: --
2319: RAISE e_LockH;
2320: --
2320: --
2321: END IF;
2322: --
2323: IF (l_debug <> -1) THEN
2324: rlm_core_sv.dpop(C_SDEBUG);
2325: END IF;
2326: --
2327: WHEN e_LockH THEN
2328: --
2326: --
2327: WHEN e_LockH THEN
2328: --
2329: IF (l_debug <> -1) THEN
2330: rlm_core_sv.dlog(C_DEBUG, 'e_LockH exception in ProcessGroupdemand');
2331: rlm_core_sv.dpop(C_SDEBUG);
2332: END IF;
2333: --
2334: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
2327: WHEN e_LockH THEN
2328: --
2329: IF (l_debug <> -1) THEN
2330: rlm_core_sv.dlog(C_DEBUG, 'e_LockH exception in ProcessGroupdemand');
2331: rlm_core_sv.dpop(C_SDEBUG);
2332: END IF;
2333: --
2334: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
2335: g_Sch_rec.schedule_header_id,
2333: --
2334: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
2335: g_Sch_rec.schedule_header_id,
2336: g_Grp_rec,
2337: rlm_core_sv.k_PS_ERROR,
2338: 'ALL');
2339: --
2340: rlm_message_sv.app_error(
2341: x_ExceptionLevel => rlm_message_sv.k_error_level,
2343: x_InterfaceHeaderId => v_header_id,
2344: x_InterfaceLineId => NULL,
2345: x_OrderLineId => NULL,
2346: x_Token1 => 'SCHED_REF',
2347: x_Value1 => rlm_core_sv.get_schedule_reference_num(v_header_id));
2348: --
2349: COMMIT;
2350: resultout := 'COMPLETE:FAILURE';
2351: --
2352: WHEN OTHERS THEN
2353:
2354: -- Bug 2771756 : Added the rollback statement.
2355: IF (l_debug <> -1) THEN
2356: rlm_core_sv.dlog(C_DEBUG,'ProcessGroupDemand when others',
2357: SUBSTR(SQLERRM,1,1500));
2358: END IF;
2359: --
2360: ROLLBACK TO s_child_process;
2361: --
2362: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
2363: g_Sch_rec.schedule_header_id,
2364: g_Grp_rec,
2365: rlm_core_sv.k_PS_ERROR);
2366:
2367: -- Bug#: 2771756 - Start
2368: -- Bug: 4198330 added grouping info
2369: rlm_message_sv.removeMessages(
2383: --
2384: IF NOT rlm_dp_sv.LockHeader(v_header_id, g_Sch_rec) THEN
2385: --
2386: IF (l_debug <> -1) THEN
2387: rlm_core_sv.dlog(C_DEBUG, 'Unable to lock header in when others');
2388: rlm_core_sv.dpop(C_SDEBUG);
2389: END IF;
2390: --
2391: RAISE e_LockH;
2384: IF NOT rlm_dp_sv.LockHeader(v_header_id, g_Sch_rec) THEN
2385: --
2386: IF (l_debug <> -1) THEN
2387: rlm_core_sv.dlog(C_DEBUG, 'Unable to lock header in when others');
2388: rlm_core_sv.dpop(C_SDEBUG);
2389: END IF;
2390: --
2391: RAISE e_LockH;
2392: --
2392: --
2393: END IF;
2394: --
2395: IF (l_debug <> -1) THEN
2396: rlm_core_sv.dpop(C_SDEBUG);
2397: END IF;
2398: --
2399: --RAISE;
2400:
2421:
2422: BEGIN
2423: --
2424: IF (l_debug <> -1) THEN
2425: rlm_core_sv.dpush(C_SDEBUG,'ArchiveDemand');
2426: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2427: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2428: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2429: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2422: BEGIN
2423: --
2424: IF (l_debug <> -1) THEN
2425: rlm_core_sv.dpush(C_SDEBUG,'ArchiveDemand');
2426: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2427: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2428: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2429: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2430: END IF;
2423: --
2424: IF (l_debug <> -1) THEN
2425: rlm_core_sv.dpush(C_SDEBUG,'ArchiveDemand');
2426: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2427: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2428: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2429: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2430: END IF;
2431: --
2424: IF (l_debug <> -1) THEN
2425: rlm_core_sv.dpush(C_SDEBUG,'ArchiveDemand');
2426: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2427: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2428: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2429: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2430: END IF;
2431: --
2432: IF (FUNCMODE = 'RUN') THEN
2425: rlm_core_sv.dpush(C_SDEBUG,'ArchiveDemand');
2426: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2427: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2428: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2429: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2430: END IF;
2431: --
2432: IF (FUNCMODE = 'RUN') THEN
2433: -- Executable Statements
2434: --
2435: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
2436: --
2437: IF (l_debug <> -1) THEN
2438: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
2439: rlm_core_sv.dlog(C_DEBUG,'Before Archive_Demand');
2440: END IF;
2441: --
2442: RLM_TPA_SV.PostValidation;
2435: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
2436: --
2437: IF (l_debug <> -1) THEN
2438: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
2439: rlm_core_sv.dlog(C_DEBUG,'Before Archive_Demand');
2440: END IF;
2441: --
2442: RLM_TPA_SV.PostValidation;
2443: --
2441: --
2442: RLM_TPA_SV.PostValidation;
2443: --
2444: IF RLM_VALIDATEDEMAND_SV.g_header_rec.process_status =
2445: rlm_core_sv.k_PS_ERROR THEN
2446: --
2447: resultout := 'COMPLETE:ABT';
2448: --
2449: IF (l_debug <> -1) THEN
2446: --
2447: resultout := 'COMPLETE:ABT';
2448: --
2449: IF (l_debug <> -1) THEN
2450: rlm_core_sv.dlog(C_DEBUG,'resultout',resultout);
2451: END IF;
2452: --
2453: ELSE
2454: --
2454: --
2455: resultout := 'COMPLETE:CONT';
2456: --
2457: IF (l_debug <> -1) THEN
2458: rlm_core_sv.dlog(C_DEBUG,'resultout',resultout);
2459: END IF;
2460: --
2461: END IF;
2462: --
2460: --
2461: END IF;
2462: --
2463: IF (l_debug <> -1) THEN
2464: rlm_core_sv.dpop(C_SDEBUG);
2465: END IF;
2466: --
2467: RETURN;
2468: END IF;
2506: EXCEPTION
2507: WHEN NO_DATA_FOUND THEN
2508: --
2509: IF (l_debug <> -1) THEN
2510: rlm_core_sv.dlog(C_DEBUG,'NO data found ');
2511: END IF;
2512: --
2513: wf_core.context('RLM_WF_SV','ArchiveDemand',
2514: itemtype, itemkey,TO_CHAR(actid),funcmode);
2514: itemtype, itemkey,TO_CHAR(actid),funcmode);
2515: resultout := 'COMPLETE:ABT';
2516: --
2517: IF (l_debug <> -1) THEN
2518: rlm_core_sv.dpop(C_SDEBUG);
2519: END IF;
2520: --
2521: WHEN OTHERS THEN
2522: --
2520: --
2521: WHEN OTHERS THEN
2522: --
2523: IF (l_debug <> -1) THEN
2524: rlm_core_sv.dlog(C_DEBUG,'ArchiveDemand when others',
2525: SUBSTR(SQLERRM,1,1500));
2526: END IF;
2527: --
2528: rlm_dp_sv.UpdateGroupPS(v_header_id,
2527: --
2528: rlm_dp_sv.UpdateGroupPS(v_header_id,
2529: g_Sch_rec.schedule_header_id,
2530: g_Grp_rec,
2531: rlm_core_sv.k_PS_ERROR,
2532: 'ALL');
2533: --
2534: rlm_dp_sv.UpdateHeaderPS(v_header_id,
2535: g_Sch_rec.schedule_header_id);
2541: --
2542: COMMIT;
2543: --
2544: IF (l_debug <> -1) THEN
2545: rlm_core_sv.dpop(C_SDEBUG);
2546: END IF;
2547: --
2548: wf_core.context('RLM_WF_SV','ArchiveDemand',
2549: itemtype, itemkey,TO_CHAR(actid),funcmode);
2571: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
2572:
2573: IF RLM_DP_SV.edi_test_indicator = 'T' then
2574: --
2575: rlm_core_sv.dlog(C_DEBUG,'Test schedule found');
2576: raise e_wftestschedule;
2577: --
2578: ELSE
2579: --
2590: x_InterfaceHeaderId => v_header_id,
2591: x_InterfaceLineId => NULL,
2592: x_OrderLineId => NULL,
2593: x_Token1 => 'SCHED_REF',
2594: x_Value1 =>rlm_core_sv.get_schedule_reference_num(v_header_id));
2595:
2596: resultout := 'T';
2597: COMMIT;
2598: --
2637: rlm_interface_lines_all ril
2638: WHERE ril.header_id = v_hdr_id
2639: AND ril.org_id = rih.org_id
2640: AND ril.header_id = rih.header_id
2641: AND ril.process_status in ( rlm_core_sv.k_PS_AVAILABLE,
2642: rlm_core_sv.k_PS_PARTIAL_PROCESSED)
2643: GROUP BY rih.customer_id,
2644: ril.ship_from_org_id,
2645: ril.ship_to_address_id,
2638: WHERE ril.header_id = v_hdr_id
2639: AND ril.org_id = rih.org_id
2640: AND ril.header_id = rih.header_id
2641: AND ril.process_status in ( rlm_core_sv.k_PS_AVAILABLE,
2642: rlm_core_sv.k_PS_PARTIAL_PROCESSED)
2643: GROUP BY rih.customer_id,
2644: ril.ship_from_org_id,
2645: ril.ship_to_address_id,
2646: ril.ship_to_site_use_id,
2660:
2661: BEGIN
2662: --
2663: IF (l_debug <> -1) THEN
2664: rlm_core_sv.dpush(C_SDEBUG,'CallProcessGroup');
2665: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2666: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2667: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2668: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2661: BEGIN
2662: --
2663: IF (l_debug <> -1) THEN
2664: rlm_core_sv.dpush(C_SDEBUG,'CallProcessGroup');
2665: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2666: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2667: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2668: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2669: END IF;
2662: --
2663: IF (l_debug <> -1) THEN
2664: rlm_core_sv.dpush(C_SDEBUG,'CallProcessGroup');
2665: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2666: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2667: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2668: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2669: END IF;
2670: --
2663: IF (l_debug <> -1) THEN
2664: rlm_core_sv.dpush(C_SDEBUG,'CallProcessGroup');
2665: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2666: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2667: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2668: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2669: END IF;
2670: --
2671: IF (FUNCMODE = 'RUN') THEN
2664: rlm_core_sv.dpush(C_SDEBUG,'CallProcessGroup');
2665: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2666: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2667: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2668: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2669: END IF;
2670: --
2671: IF (FUNCMODE = 'RUN') THEN
2672: -- Executable Statements
2672: -- Executable Statements
2673: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
2674: --
2675: IF (l_debug <> -1) THEN
2676: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
2677: END IF;
2678: --
2679: SELECT process_status
2680: INTO v_tmp_status
2681: FROM rlm_interface_headers
2682: WHERE header_id = v_Header_Id;
2683: --
2684: IF (l_debug <> -1) THEN
2685: rlm_core_sv.dlog(C_DEBUG,'process status =', v_tmp_status);
2686: END IF;
2687: --
2688:
2689: --
2686: END IF;
2687: --
2688:
2689: --
2690: IF v_tmp_status <> rlm_core_sv.k_PROC_ERROR THEN
2691: --
2692: v_num_child := g_num_child;
2693: --
2694: IF v_num_child > 1 THEN /* Parallel DSP */
2700: --
2701: IF NOT RLM_DP_SV.LockHeader(v_header_id, g_Sch_rec) THEN
2702: --
2703: IF (l_debug <> -1) THEN
2704: rlm_core_sv.dlog(C_DEBUG, 'Cannot lock header after CreateChildGroups');
2705: END IF;
2706: --
2707: RAISE e_LockH;
2708: --
2763: EXIT WHEN c_group_cur%NOTFOUND;
2764: --
2765: -- Setting the global vars
2766: IF (l_debug <> -1) THEN
2767: rlm_core_sv.dlog(C_DEBUG,'Create loop',v_count);
2768: END IF;
2769: --
2770: IF v_count > 1 THEN
2771: --
2771: --
2772: IF NOT rlm_dp_sv.LockHeader(v_header_id, g_Sch_rec) THEN
2773: --
2774: IF (l_debug <> -1) THEN
2775: rlm_core_sv.dlog(C_DEBUG, 'Cannot lock header');
2776: END IF;
2777: --
2778: resultout := 'COMPLETE:FAILURE';
2779: RAISE e_LockH;
2786: v_header_id,
2787: v_count);
2788: --
2789: IF (l_debug <> -1) THEN
2790: rlm_core_sv.dlog(C_DEBUG,'start loop',v_count);
2791: rlm_core_sv.dlog(C_DEBUG, '***** Processing new group *****');
2792: rlm_core_sv.dlog(C_DEBUG, 'Blanket Number', g_Grp_rec.blanket_number);
2793: END IF;
2794: --
2787: v_count);
2788: --
2789: IF (l_debug <> -1) THEN
2790: rlm_core_sv.dlog(C_DEBUG,'start loop',v_count);
2791: rlm_core_sv.dlog(C_DEBUG, '***** Processing new group *****');
2792: rlm_core_sv.dlog(C_DEBUG, 'Blanket Number', g_Grp_rec.blanket_number);
2793: END IF;
2794: --
2795: rlm_wf_sv.StartDSPLoop(errbuf,
2788: --
2789: IF (l_debug <> -1) THEN
2790: rlm_core_sv.dlog(C_DEBUG,'start loop',v_count);
2791: rlm_core_sv.dlog(C_DEBUG, '***** Processing new group *****');
2792: rlm_core_sv.dlog(C_DEBUG, 'Blanket Number', g_Grp_rec.blanket_number);
2793: END IF;
2794: --
2795: rlm_wf_sv.StartDSPLoop(errbuf,
2796: retcode,
2817: --
2818: END IF;
2819: --
2820: IF (l_debug <> -1) THEN
2821: rlm_core_sv.dpop(C_SDEBUG);
2822: END IF;
2823: RETURN;
2824: END IF;
2825:
2862: EXCEPTION
2863: WHEN NO_DATA_FOUND THEN
2864: --
2865: IF (l_debug <> -1) THEN
2866: rlm_core_sv.dlog(C_DEBUG,'NO data found ');
2867: END IF;
2868: --
2869: wf_core.context('RLM_WF_SV','CallProcessGroup',
2870: itemtype, itemkey,TO_CHAR(actid),funcmode);
2870: itemtype, itemkey,TO_CHAR(actid),funcmode);
2871: resultout := 'COMPLETE:FAILURE';
2872: --
2873: IF (l_debug <> -1) THEN
2874: rlm_core_sv.dpop(C_SDEBUG);
2875: END IF;
2876: --
2877: WHEN e_LockH THEN
2878: --
2876: --
2877: WHEN e_LockH THEN
2878: --
2879: IF (l_debug <> -1) THEN
2880: rlm_core_sv.dlog(C_DEBUG, 'e_LockH exception in CallProcessGroup');
2881: rlm_core_sv.dpop(C_SDEBUG);
2882: END IF;
2883: --
2884: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
2877: WHEN e_LockH THEN
2878: --
2879: IF (l_debug <> -1) THEN
2880: rlm_core_sv.dlog(C_DEBUG, 'e_LockH exception in CallProcessGroup');
2881: rlm_core_sv.dpop(C_SDEBUG);
2882: END IF;
2883: --
2884: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
2885: g_Sch_rec.schedule_header_id,
2883: --
2884: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
2885: g_Sch_rec.schedule_header_id,
2886: g_Grp_rec,
2887: rlm_core_sv.k_PS_ERROR,
2888: 'ALL');
2889: --
2890: rlm_message_sv.app_error(
2891: x_ExceptionLevel => rlm_message_sv.k_error_level,
2893: x_InterfaceHeaderId => v_header_id,
2894: x_InterfaceLineId => NULL,
2895: x_OrderLineId => NULL,
2896: x_Token1 => 'SCHED_REF',
2897: x_Value1 => rlm_core_sv.get_schedule_reference_num(v_header_id));
2898: --
2899: COMMIT;
2900: resultout := 'COMPLETE:FAILURE';
2901: --
2904: itemtype, itemkey,TO_CHAR(actid),funcmode);
2905: resultout := 'COMPLETE:FAILURE';
2906: --
2907: IF (l_debug <> -1) THEN
2908: rlm_core_sv.dpop(C_SDEBUG);
2909: END IF;
2910: --
2911: --RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
2912:
2933:
2934: BEGIN
2935: --
2936: IF (l_debug <> -1) THEN
2937: rlm_core_sv.dpush(C_SDEBUG,'PostValidate');
2938: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2939: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2940: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2941: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2934: BEGIN
2935: --
2936: IF (l_debug <> -1) THEN
2937: rlm_core_sv.dpush(C_SDEBUG,'PostValidate');
2938: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2939: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2940: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2941: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2942: END IF;
2935: --
2936: IF (l_debug <> -1) THEN
2937: rlm_core_sv.dpush(C_SDEBUG,'PostValidate');
2938: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2939: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2940: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2941: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2942: END IF;
2943: --
2936: IF (l_debug <> -1) THEN
2937: rlm_core_sv.dpush(C_SDEBUG,'PostValidate');
2938: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2939: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2940: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2941: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2942: END IF;
2943: --
2944: IF (FUNCMODE = 'RUN') THEN
2937: rlm_core_sv.dpush(C_SDEBUG,'PostValidate');
2938: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
2939: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
2940: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
2941: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
2942: END IF;
2943: --
2944: IF (FUNCMODE = 'RUN') THEN
2945: -- Executable Statements
2945: -- Executable Statements
2946: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
2947: --
2948: IF (l_debug <> -1) THEN
2949: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
2950: END IF;
2951: --
2952: -- Lock the headers and Populate g_Sch_rec
2953: IF NOT rlm_dp_sv.LockHeader(v_header_Id, g_Sch_rec) THEN
2952: -- Lock the headers and Populate g_Sch_rec
2953: IF NOT rlm_dp_sv.LockHeader(v_header_Id, g_Sch_rec) THEN
2954: --
2955: IF (l_debug <> -1) THEN
2956: rlm_core_sv.dlog(C_DEBUG,'header not locked');
2957: END IF;
2958: --
2959: raise e_LockH;
2960: --
2962: --
2963: IF g_Sch_rec.schedule_purpose = rlm_dp_sv.k_CONFIRMATION THEN
2964: --
2965: IF (l_debug <> -1) THEN
2966: rlm_core_sv.dlog(C_DEBUG,'RLM_CONF_SCH_RCD');
2967: END IF;
2968: --
2969: raise e_ConfirmationSchedule;
2970: --
2993: --
2994: resultout := 'COMPLETE:SUCCESS';
2995: --
2996: IF (l_debug <> -1) THEN
2997: rlm_core_sv.dpop(C_SDEBUG);
2998: END IF;
2999: --
3000: RETURN;
3001: END IF;
3039: EXCEPTION
3040: WHEN NO_DATA_FOUND THEN
3041: --
3042: IF (l_debug <> -1) THEN
3043: rlm_core_sv.dlog(C_DEBUG,'NO data found ');
3044: END IF;
3045: --
3046: wf_core.context('RLM_WF_SV','PostValidate',
3047: itemtype, itemkey,TO_CHAR(actid),funcmode);
3047: itemtype, itemkey,TO_CHAR(actid),funcmode);
3048: resultout := 'COMPLETE:FAILURE';
3049: --
3050: IF (l_debug <> -1) THEN
3051: rlm_core_sv.dpop(C_SDEBUG);
3052: END IF;
3053: --
3054: WHEN e_LockH THEN
3055: --
3053: --
3054: WHEN e_LockH THEN
3055: --
3056: IF (l_debug <> -1) THEN
3057: rlm_core_sv.dlog(C_DEBUG,'PostValidate failed Lock header');
3058: END IF;
3059: --
3060: rlm_dp_sv.UpdateGroupPS(v_header_id,
3061: g_Sch_rec.schedule_header_id,
3059: --
3060: rlm_dp_sv.UpdateGroupPS(v_header_id,
3061: g_Sch_rec.schedule_header_id,
3062: g_Grp_rec,
3063: rlm_core_sv.k_PS_ERROR,
3064: 'ALL');
3065: --
3066: rlm_dp_sv.UpdateHeaderPS(v_header_id,
3067: g_Sch_rec.schedule_header_id);
3074: itemtype, itemkey,TO_CHAR(actid),funcmode);
3075: resultout := 'COMPLETE:FAILURE';
3076: --
3077: IF (l_debug <> -1) THEN
3078: rlm_core_sv.dpop(C_SDEBUG);
3079: END IF;
3080: --
3081: WHEN e_ConfirmationSchedule THEN
3082: --
3080: --
3081: WHEN e_ConfirmationSchedule THEN
3082: --
3083: IF (l_debug <> -1) THEN
3084: rlm_core_sv.dlog(C_DEBUG,'RLM_CONF_SCH_RCD');
3085: END IF;
3086: --
3087: rlm_message_sv.app_error(
3088: x_ExceptionLevel => rlm_message_sv.k_warn_level,
3098: --
3099: rlm_dp_sv.UpdateGroupPS(g_Sch_rec.header_id,
3100: g_Sch_rec.Schedule_header_id,
3101: g_Grp_rec,
3102: rlm_core_sv.K_PS_PROCESSED,
3103: 'ALL');
3104: --
3105: rlm_dp_sv.UpdateHeaderPS(g_Sch_rec.header_id,
3106: g_Sch_rec.Schedule_header_id);
3112: -- Bug#: 3053299 -- Setting the output
3113: resultout := 'COMPLETE:SUCCESS';
3114: --
3115: IF (l_debug <> -1) THEN
3116: rlm_core_sv.dpop(C_SDEBUG);
3117: END IF;
3118:
3119: WHEN e_ReplaceSchedule THEN
3120: --
3124: --
3125: rlm_dp_sv.UpdateGroupPS(v_header_id,
3126: g_Sch_rec.schedule_header_id,
3127: g_Grp_rec,
3128: rlm_core_sv.k_PS_ERROR,
3129: 'ALL');
3130: --
3131: rlm_dp_sv.UpdateHeaderPS(v_header_id,
3132: g_Sch_rec.schedule_header_id);
3139: --
3140: COMMIT;
3141: --
3142: IF (l_debug <> -1) THEN
3143: rlm_core_sv.dpop(C_SDEBUG);
3144: END IF;
3145:
3146: WHEN OTHERS THEN
3147: wf_core.context('RLM_WF_SV','PostValidate',
3150: --
3151: rlm_dp_sv.UpdateGroupPS(v_header_id,
3152: g_Sch_rec.schedule_header_id,
3153: g_Grp_rec,
3154: rlm_core_sv.k_PS_ERROR,
3155: 'ALL');
3156: --
3157: rlm_dp_sv.UpdateHeaderPS(v_header_id,
3158: g_Sch_rec.schedule_header_id);
3164: --
3165: COMMIT;
3166: --
3167: IF (l_debug <> -1) THEN
3168: rlm_core_sv.dpop(C_SDEBUG);
3169: END IF;
3170: --RAISE ;
3171:
3172: END PostValidate;
3189: e_DPFailed EXCEPTION;
3190: BEGIN
3191: --
3192: IF (l_debug <> -1) THEN
3193: rlm_core_sv.dpush(C_SDEBUG,'CHeckStatus');
3194: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
3195: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
3196: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
3197: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
3190: BEGIN
3191: --
3192: IF (l_debug <> -1) THEN
3193: rlm_core_sv.dpush(C_SDEBUG,'CHeckStatus');
3194: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
3195: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
3196: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
3197: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
3198: END IF;
3191: --
3192: IF (l_debug <> -1) THEN
3193: rlm_core_sv.dpush(C_SDEBUG,'CHeckStatus');
3194: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
3195: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
3196: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
3197: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
3198: END IF;
3199: --
3192: IF (l_debug <> -1) THEN
3193: rlm_core_sv.dpush(C_SDEBUG,'CHeckStatus');
3194: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
3195: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
3196: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
3197: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
3198: END IF;
3199: --
3200: IF (FUNCMODE = 'RUN') THEN
3193: rlm_core_sv.dpush(C_SDEBUG,'CHeckStatus');
3194: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
3195: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
3196: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
3197: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
3198: END IF;
3199: --
3200: IF (FUNCMODE = 'RUN') THEN
3201: -- Executable Statements
3201: -- Executable Statements
3202: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
3203: --
3204: IF (l_debug <> -1) THEN
3205: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
3206: END IF;
3207: --
3208: v_request_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'REQUEST_ID');
3209: --
3207: --
3208: v_request_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'REQUEST_ID');
3209: --
3210: IF (l_debug <> -1) THEN
3211: rlm_core_sv.dlog(C_DEBUG,' Request Id :', v_request_id);
3212: END IF;
3213: --
3214: v_schedule_num := wf_engine.GetItemAttrText(itemtype,itemkey,'SCHEDULE_NUMBER');
3215: --
3213: --
3214: v_schedule_num := wf_engine.GetItemAttrText(itemtype,itemkey,'SCHEDULE_NUMBER');
3215: --
3216: IF (l_debug <> -1) THEN
3217: rlm_core_sv.dlog(C_DEBUG,' Schedule Number :', v_schedule_num);
3218: END IF;
3219: --
3220: rlm_message_sv.dump_messages(v_header_id);
3221: rlm_message_sv.initialize_messages;
3229:
3230: resultout := 'COMPLETE:ERR';
3231: --
3232: IF (l_debug <> -1) THEN
3233: rlm_core_sv.dpop(C_SDEBUG);
3234: END IF;
3235: --
3236: RETURN;
3237:
3276: EXCEPTION
3277: WHEN NO_DATA_FOUND THEN
3278: --
3279: IF (l_debug <> -1) THEN
3280: rlm_core_sv.dlog(C_DEBUG,'NO data found ');
3281: END IF;
3282: --
3283: wf_core.context('RLM_WF_SV','CHeckStatus',
3284: itemtype, itemkey,TO_CHAR(actid),funcmode);
3284: itemtype, itemkey,TO_CHAR(actid),funcmode);
3285: resultout := 'COMPLETE:N';
3286: --
3287: IF (l_debug <> -1) THEN
3288: rlm_core_sv.dpop(C_SDEBUG);
3289: END IF;
3290: --
3291: WHEN OTHERS THEN
3292: wf_core.context('RLM_WF_SV','CHeckStatus',
3293: itemtype, itemkey,TO_CHAR(actid),funcmode);
3294: resultout := 'COMPLETE:N';
3295: --
3296: IF (l_debug <> -1) THEN
3297: rlm_core_sv.dpop(C_SDEBUG);
3298: END IF;
3299: --
3300: RAISE;
3301:
3329: --
3330: BEGIN
3331: --
3332: IF (l_debug <> -1) THEN
3333: rlm_core_sv.dpush(C_SDEBUG, 'Notification_ToUser');
3334: rlm_core_sv.dlog(C_DEBUG, 'User Id :', user_id);
3335: END IF;
3336: --
3337: OPEN c_user(user_id);
3330: BEGIN
3331: --
3332: IF (l_debug <> -1) THEN
3333: rlm_core_sv.dpush(C_SDEBUG, 'Notification_ToUser');
3334: rlm_core_sv.dlog(C_DEBUG, 'User Id :', user_id);
3335: END IF;
3336: --
3337: OPEN c_user(user_id);
3338: FETCH c_user INTO v_ToUserName;
3339: --
3340: IF (c_user%NOTFOUND) THEN
3341: --
3342: IF (l_debug <> -1) THEN
3343: rlm_core_sv.dlog(C_DEBUG,'Notification_ToUser :: No Data Found');
3344: END IF;
3345: --
3346: RAISE e_UserNotFound;
3347: --
3349: --
3350: CLOSE c_user;
3351: --
3352: IF (l_debug <> -1) THEN
3353: rlm_core_sv.dlog(C_DEBUG, 'To User', v_ToUserName);
3354: rlm_core_sv.dpop(C_SDEBUG);
3355: END IF;
3356: --
3357: RETURN v_ToUserName;
3350: CLOSE c_user;
3351: --
3352: IF (l_debug <> -1) THEN
3353: rlm_core_sv.dlog(C_DEBUG, 'To User', v_ToUserName);
3354: rlm_core_sv.dpop(C_SDEBUG);
3355: END IF;
3356: --
3357: RETURN v_ToUserName;
3358: --
3362: --
3363: rlm_message_sv.sql_error('RLM_WF_SV.Notification_ToUser',user_id);
3364: --
3365: IF (l_debug <> -1) THEN
3366: rlm_core_sv.dlog(C_DEBUG, 'Exception : e_UserNotFound');
3367: rlm_core_sv.dpop(C_SDEBUG);
3368: END IF;
3369: --
3370: RAISE;
3363: rlm_message_sv.sql_error('RLM_WF_SV.Notification_ToUser',user_id);
3364: --
3365: IF (l_debug <> -1) THEN
3366: rlm_core_sv.dlog(C_DEBUG, 'Exception : e_UserNotFound');
3367: rlm_core_sv.dpop(C_SDEBUG);
3368: END IF;
3369: --
3370: RAISE;
3371: --
3411: --
3412: BEGIN
3413: --
3414: IF (l_debug <> -1) THEN
3415: rlm_core_sv.dpush(C_SDEBUG, 'Notification_FromUser');
3416: rlm_core_sv.dlog(C_DEBUG, 'Responsibility Id :', responsibility_id);
3417: rlm_core_sv.dlog(C_DEBUG, 'Application Id :', resp_appl_id);
3418: END IF;
3419: --
3412: BEGIN
3413: --
3414: IF (l_debug <> -1) THEN
3415: rlm_core_sv.dpush(C_SDEBUG, 'Notification_FromUser');
3416: rlm_core_sv.dlog(C_DEBUG, 'Responsibility Id :', responsibility_id);
3417: rlm_core_sv.dlog(C_DEBUG, 'Application Id :', resp_appl_id);
3418: END IF;
3419: --
3420: v_FromUserName := FND_USER_RESP_GROUPS_API. upgrade_resp_role
3413: --
3414: IF (l_debug <> -1) THEN
3415: rlm_core_sv.dpush(C_SDEBUG, 'Notification_FromUser');
3416: rlm_core_sv.dlog(C_DEBUG, 'Responsibility Id :', responsibility_id);
3417: rlm_core_sv.dlog(C_DEBUG, 'Application Id :', resp_appl_id);
3418: END IF;
3419: --
3420: v_FromUserName := FND_USER_RESP_GROUPS_API. upgrade_resp_role
3421: (respid => responsibility_id,
3421: (respid => responsibility_id,
3422: appid => resp_appl_id);
3423: --
3424: IF (l_debug <> -1) THEN
3425: rlm_core_sv.dlog(C_DEBUG, 'Internal Role Name', v_FromUserName);
3426: rlm_core_sv.dpop(C_SDEBUG);
3427: END IF;
3428: --
3429: RETURN v_FromUserName;
3422: appid => resp_appl_id);
3423: --
3424: IF (l_debug <> -1) THEN
3425: rlm_core_sv.dlog(C_DEBUG, 'Internal Role Name', v_FromUserName);
3426: rlm_core_sv.dpop(C_SDEBUG);
3427: END IF;
3428: --
3429: RETURN v_FromUserName;
3430: --
3435: rlm_message_sv.sql_error('RLM_WF_SV.Notification_FromUser',
3436: SUBSTRB(SQLERRM, 1, 200));
3437: --
3438: IF (l_debug <> -1) THEN
3439: rlm_core_sv.dlog(C_DEBUG, 'When Others - ' || SUBSTRB(SQLERRM, 1, 200));
3440: rlm_core_sv.dpop(C_SDEBUG);
3441: END IF;
3442: --
3443: RAISE;
3436: SUBSTRB(SQLERRM, 1, 200));
3437: --
3438: IF (l_debug <> -1) THEN
3439: rlm_core_sv.dlog(C_DEBUG, 'When Others - ' || SUBSTRB(SQLERRM, 1, 200));
3440: rlm_core_sv.dpop(C_SDEBUG);
3441: END IF;
3442: --
3443: RAISE;
3444: --
3485: v_process_status NUMBER;
3486: BEGIN
3487: --
3488: IF (l_debug <> -1) THEN
3489: rlm_core_sv.dpush(C_SDEBUG,'GetScheduleStatus');
3490: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
3491: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
3492: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
3493: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
3486: BEGIN
3487: --
3488: IF (l_debug <> -1) THEN
3489: rlm_core_sv.dpush(C_SDEBUG,'GetScheduleStatus');
3490: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
3491: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
3492: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
3493: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
3494: END IF;
3487: --
3488: IF (l_debug <> -1) THEN
3489: rlm_core_sv.dpush(C_SDEBUG,'GetScheduleStatus');
3490: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
3491: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
3492: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
3493: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
3494: END IF;
3495: --
3488: IF (l_debug <> -1) THEN
3489: rlm_core_sv.dpush(C_SDEBUG,'GetScheduleStatus');
3490: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
3491: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
3492: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
3493: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
3494: END IF;
3495: --
3496: IF (FUNCMODE = 'RUN') THEN
3489: rlm_core_sv.dpush(C_SDEBUG,'GetScheduleStatus');
3490: rlm_core_sv.dlog(C_DEBUG,'itemtype ', itemtype);
3491: rlm_core_sv.dlog(C_DEBUG,'itemkey ', itemkey);
3492: rlm_core_sv.dlog(C_DEBUG,'actid ', actid);
3493: rlm_core_sv.dlog(C_DEBUG,'funcmode ', funcmode);
3494: END IF;
3495: --
3496: IF (FUNCMODE = 'RUN') THEN
3497: -- Executable Statements
3497: -- Executable Statements
3498: v_header_id := wf_engine.GetItemAttrNumber(itemtype,itemkey,'HEADER_ID');
3499: --
3500: IF (l_debug <> -1) THEN
3501: rlm_core_sv.dlog(C_DEBUG,' Header_id :', v_header_id);
3502: END IF;
3503: --
3504:
3505: OPEN c_process_status_schedule(g_Sch_rec.schedule_header_id); --Bug# 3567538
3515: IF (c_process_status_interface%NOTFOUND) THEN
3516: resultout := 'COMPLETE:ERROR';
3517: END IF;
3518:
3519: IF (v_process_status IS NOT NULL AND v_process_status = RLM_CORE_SV.k_PS_PARTIAL_PROCESSED) THEN
3520: resultout := 'COMPLETE:PARTIAL_PROCESS';
3521: ELSE
3522: resultout := 'COMPLETE:ERROR';
3523: END IF ;
3524:
3525: CLOSE c_process_status_interface;
3526: END IF;
3527:
3528: IF (v_process_status IS NOT NULL AND v_process_status = RLM_CORE_SV.k_PS_PARTIAL_PROCESSED) THEN
3529: resultout := 'COMPLETE:PARTIAL_PROCESS';
3530: ELSE
3531: resultout := 'COMPLETE:ERROR';
3532: END IF;
3535: CLOSE c_process_status_schedule;
3536:
3537: --
3538: IF (l_debug <> -1) THEN
3539: rlm_core_sv.dpop(C_SDEBUG);
3540: END IF;
3541: --
3542: RETURN;
3543:
3585: itemtype, itemkey,TO_CHAR(actid),funcmode);
3586: resultout := 'COMPLETE:ERROR';
3587: --
3588: IF (l_debug <> -1) THEN
3589: rlm_core_sv.dpop(C_SDEBUG);
3590: END IF;
3591: --
3592: RAISE;
3593: