89: END IF;
90: --
91: SELECT hsecs INTO l_start_time from v$timer;
92: --
93: rlm_message_sv.populate_req_id;
94: --
95: MO_GLOBAL.set_policy_context(p_access_mode => 'S',
96: p_org_id => p_org_id);
97: --
273: END IF;
274: --
275: EXIT WHEN c_demand%NOTFOUND;
276: --
277: rlm_message_sv.initialize_messages;
278: --
279: -- bug 2721219
280: --
281: RLM_FORECAST_SV.k_REPLACE_FLAG := TRUE;
316: END IF;
317: --
318: --Bugfix 6453415 Start
319: update rlm_demand_exceptions
320: set request_id = rlm_message_sv.g_conc_req_id
321: where interface_header_id = v_header_id;
322: --Bugfix 6453415 End
323: --
324: END IF;
477: --
478: UpdateHeaderPS(v_Sched_rec.header_id,
479: v_Sched_rec.schedule_header_id);
480: --
481: rlm_message_sv.dump_messages(v_header_id);
482: --
483: PurgeInterfaceLines(v_header_id);
484: --
485: COMMIT;
516: IF (l_debug <> -1) THEN
517: rlm_core_sv.dlog(C_DEBUG,'RLM_CONF_SCH_RCD');
518: END IF;
519: --
520: rlm_message_sv.app_error(
521: x_ExceptionLevel => rlm_message_sv.k_warn_level,
522: x_MessageName => 'RLM_CONF_SCH_RCD',
523: x_InterfaceHeaderId => v_sched_rec.header_id,
524: x_InterfaceLineId => null,
517: rlm_core_sv.dlog(C_DEBUG,'RLM_CONF_SCH_RCD');
518: END IF;
519: --
520: rlm_message_sv.app_error(
521: x_ExceptionLevel => rlm_message_sv.k_warn_level,
522: x_MessageName => 'RLM_CONF_SCH_RCD',
523: x_InterfaceHeaderId => v_sched_rec.header_id,
524: x_InterfaceLineId => null,
525: x_ScheduleHeaderId => v_sched_rec.schedule_header_id,
537: --
538: UpdateHeaderPS(v_Sched_rec.header_id,
539: v_Sched_rec.Schedule_header_id);
540: --
541: rlm_message_sv.dump_messages(v_header_id);
542: PurgeInterfaceLines(v_header_id); /*2699981*/
543: --
544: COMMIT;
545: --
548: IF (l_debug <> -1) THEN
549: rlm_core_sv.dlog(C_DEBUG,'No data found ');
550: END IF;
551: --
552: rlm_message_sv.dump_messages(v_header_id);
553: --
554: WHEN e_VDFailed THEN
555: --
556: IF (l_debug <> -1) THEN
567: --
568: UpdateHeaderPS(v_header_id,
569: v_schedule_header_id);
570: --
571: rlm_message_sv.dump_messages(v_header_id);
572: --
573: COMMIT;
574: --
575: WHEN e_ReplaceSchedule THEN
582: rlm_core_sv.k_PS_ERROR);
583:
584: --
585: UpdateHeaderPS(v_header_id, v_schedule_header_id);
586: rlm_message_sv.dump_messages(v_header_id);
587: --
588: COMMIT;
589: --
590: /* Bug 2554058 */
591: --
592: WHEN e_testschedule THEN
593: --
594: IF (l_debug <> -1) THEN
595: rlm_core_sv.dlog(C_DEBUG, 'request ID', RLM_MESSAGE_SV.g_conc_req_id);
596: END IF;
597: --
598: rlm_message_sv.app_error(
599: x_ExceptionLevel => rlm_message_sv.k_warn_level,
594: IF (l_debug <> -1) THEN
595: rlm_core_sv.dlog(C_DEBUG, 'request ID', RLM_MESSAGE_SV.g_conc_req_id);
596: END IF;
597: --
598: rlm_message_sv.app_error(
599: x_ExceptionLevel => rlm_message_sv.k_warn_level,
600: x_MessageName => 'RLM_TEST_SCHEDULE_DETECTED',
601: x_InterfaceHeaderId => v_header_id,
602: x_InterfaceLineId => NULL,
595: rlm_core_sv.dlog(C_DEBUG, 'request ID', RLM_MESSAGE_SV.g_conc_req_id);
596: END IF;
597: --
598: rlm_message_sv.app_error(
599: x_ExceptionLevel => rlm_message_sv.k_warn_level,
600: x_MessageName => 'RLM_TEST_SCHEDULE_DETECTED',
601: x_InterfaceHeaderId => v_header_id,
602: x_InterfaceLineId => NULL,
603: x_OrderLineId => NULL,
603: x_OrderLineId => NULL,
604: x_Token1 => 'SCHED_REF',
605: x_Value1 =>rlm_core_sv.get_schedule_reference_num(v_header_id));
606: --
607: rlm_message_sv.dump_messages(v_header_id);
608: PurgeInterfaceLines(v_header_id); /*2699981*/
609: --
610: COMMIT;
611: --
621: --
622: /* UpdateHeaderPS(v_header_id,
623: v_schedule_header_id); */
624: --
625: rlm_message_sv.app_error(
626: x_ExceptionLevel => rlm_message_sv.k_error_level,
627: x_MessageName => 'RLM_HEADER_LOCK_NOT_OBTAINED',
628: x_InterfaceHeaderId => v_header_id,
629: x_InterfaceLineId => NULL,
622: /* UpdateHeaderPS(v_header_id,
623: v_schedule_header_id); */
624: --
625: rlm_message_sv.app_error(
626: x_ExceptionLevel => rlm_message_sv.k_error_level,
627: x_MessageName => 'RLM_HEADER_LOCK_NOT_OBTAINED',
628: x_InterfaceHeaderId => v_header_id,
629: x_InterfaceLineId => NULL,
630: x_OrderLineId => NULL,
635: rlm_core_sv.dlog(C_DEBUG,'Header could not be locked');
636: rlm_core_sv.dpop(C_SDEBUG, 'RLM_LOCK_NOT_OBTAINED');
637: END IF;
638: --
639: rlm_message_sv.dump_messages(v_header_id);
640: --
641: COMMIT;
642: --
643: WHEN OTHERS THEN
649: IF (l_debug <> -1) THEN
650: rlm_core_sv.dlog(C_DEBUG,'when others');
651: rlm_core_sv.dlog(C_DEBUG, 'Return Code', retcode);
652: rlm_core_sv.dlog(C_DEBUG, 'ERROR:', SUBSTR(SQLERRM,1,200));
653: rlm_core_sv.dlog(C_DEBUG, 'request ID', RLM_MESSAGE_SV.g_conc_req_id);
654: END IF;
655: --
656: UpdateGroupPS(v_header_id,
657: v_schedule_header_id,
661: --
662: UpdateHeaderPS(v_header_id,
663: v_schedule_header_id);
664: --
665: rlm_message_sv.sql_error('rlm_dp_sv.DemandProcessor', v_Progress);
666: --
667: rlm_message_sv.dump_messages(v_header_id);
668: --
669: COMMIT;
663: v_schedule_header_id);
664: --
665: rlm_message_sv.sql_error('rlm_dp_sv.DemandProcessor', v_Progress);
666: --
667: rlm_message_sv.dump_messages(v_header_id);
668: --
669: COMMIT;
670: --
671: END;
677: END IF;
678: --
679: IF c_demand%ROWCOUNT = 0 THEN
680: --
681: rlm_message_sv.initialize_messages;
682: --
683: rlm_message_sv.app_error(
684: x_ExceptionLevel => rlm_message_sv.k_error_level,
685: x_MessageName => 'RLM_NO_DATA_FOR_CRITERIA',
679: IF c_demand%ROWCOUNT = 0 THEN
680: --
681: rlm_message_sv.initialize_messages;
682: --
683: rlm_message_sv.app_error(
684: x_ExceptionLevel => rlm_message_sv.k_error_level,
685: x_MessageName => 'RLM_NO_DATA_FOR_CRITERIA',
686: x_InterfaceHeaderId => null,
687: x_InterfaceLineId => NULL,
680: --
681: rlm_message_sv.initialize_messages;
682: --
683: rlm_message_sv.app_error(
684: x_ExceptionLevel => rlm_message_sv.k_error_level,
685: x_MessageName => 'RLM_NO_DATA_FOR_CRITERIA',
686: x_InterfaceHeaderId => null,
687: x_InterfaceLineId => NULL,
688: x_ScheduleHeaderId => null,
700: IF (l_debug <> -1) THEN
701: rlm_core_sv.dlog(C_DEBUG,'RLM_NO_DATA_FOR_CRITERIA' );
702: END IF;
703: --
704: rlm_message_sv.dump_messages;
705: --
706: END IF;
707: --
708: CLOSE c_demand;
706: END IF;
707: --
708: CLOSE c_demand;
709: --
710: RunExceptionReport(x_requestId => rlm_message_sv.g_conc_req_id,
711: x_OrgId => p_org_id);
712:
713: SELECT hsecs INTO l_end_time from v$timer;
714:
757: --
758: WHEN OTHERS THEN
759: --
760: retcode := 2;
761: rlm_message_sv.sql_error('rlm_dp_sv.DemandProcessor', v_Progress);
762: rlm_message_sv.dump_messages(v_header_id);
763: --
764: IF (l_debug <> -1) THEN
765: rlm_core_sv.dlog(C_DEBUG, 'Return Code', retcode);
758: WHEN OTHERS THEN
759: --
760: retcode := 2;
761: rlm_message_sv.sql_error('rlm_dp_sv.DemandProcessor', v_Progress);
762: rlm_message_sv.dump_messages(v_header_id);
763: --
764: IF (l_debug <> -1) THEN
765: rlm_core_sv.dlog(C_DEBUG, 'Return Code', retcode);
766: rlm_core_sv.dpop(C_SDEBUG,'EXCEPTION: '|| SUBSTR(SQLERRM,1,200));
820: EXCEPTION
821: --
822: WHEN NO_DATA_FOUND THEN
823: --
824: rlm_message_sv.sql_error('rlm_dp_sv.PurgeInterfaceLines', v_Progress);
825: --
826: IF (l_debug <> -1) THEN
827: rlm_core_sv.dlog(C_DEBUG, 'No records to delete' );
828: rlm_core_sv.dpop(C_SDEBUG);
829: END IF;
830: --
831: WHEN OTHERS THEN
832: --
833: rlm_message_sv.sql_error('rlm_dp_sv.PurgeInterfaceLines', v_Progress);
834: --
835: IF (l_debug <> -1) THEN
836: rlm_core_sv.dpop(C_SDEBUG,'EXCEPTION: '|| SUBSTR(SQLERRM,1,200));
837: END IF;
902: --
903: RETURN(FALSE);
904: --
905: WHEN OTHERS THEN
906: rlm_message_sv.sql_error('rlm_managedemand_sv.lockHeader', x_progress);
907: --
908: IF (l_debug <> -1) THEN
909: rlm_core_sv.dlog(C_DEBUG,'progress',x_Progress);
910: rlm_core_sv.dpop(C_SDEBUG,'EXCEPTION: OTHER - sql error');
949: x_Group_rec.ship_to_org_id);
950: rlm_core_sv.dlog(C_DEBUG,'x_Group_rec.customer_item_id ',
951: x_Group_rec.customer_item_id);
952: rlm_core_sv.dlog(C_DEBUG,'x_UpdateLevel to ', x_UpdateLevel);
953: rlm_core_sv.dlog(C_DEBUG, 'request ID', RLM_MESSAGE_SV.g_conc_req_id);
954: END IF;
955: --
956: v_login_id := fnd_global.login_id ;
957: v_request_id := RLM_MESSAGE_SV.g_conc_req_id ;
953: rlm_core_sv.dlog(C_DEBUG, 'request ID', RLM_MESSAGE_SV.g_conc_req_id);
954: END IF;
955: --
956: v_login_id := fnd_global.login_id ;
957: v_request_id := RLM_MESSAGE_SV.g_conc_req_id ;
958: v_program_app_id := fnd_global.PROG_APPL_ID ;
959: v_program_id := fnd_global.conc_program_id;
960: --
961: SELECT schedule_header_id
1063: EXCEPTION
1064: --
1065: WHEN OTHERS THEN
1066: --
1067: rlm_message_sv.sql_error('rlm_dp_sv.UpdateGroupPS', v_Progress);
1068: --
1069: IF (l_debug <> -1) THEN
1070: rlm_core_sv.dpop(C_SDEBUG,'EXCEPTION: '|| SUBSTR(SQLERRM,1,200));
1071: END IF;
1098: --
1099: IF (l_debug <> -1) THEN
1100: rlm_core_sv.dpush(C_SDEBUG,'UpdateHeaderPS');
1101: rlm_core_sv.dlog(C_DEBUG,'x_HeaderId',x_HeaderId);
1102: rlm_core_sv.dlog(C_DEBUG, 'request ID', RLM_MESSAGE_SV.g_conc_req_id);
1103: END IF;
1104: --
1105: SELECT schedule_header_id
1106: INTO v_SchedHeaderId
1183: --
1184: UPDATE rlm_interface_headers
1185: SET process_status = x_HeaderStatus,
1186: LAST_UPDATE_LOGIN = fnd_global.login_id ,
1187: REQUEST_ID = RLM_MESSAGE_SV.g_conc_req_id ,
1188: PROGRAM_APPLICATION_ID = fnd_global.PROG_APPL_ID ,
1189: PROGRAM_ID = fnd_global.conc_program_id,
1190: PROGRAM_UPDATE_DATE = sysdate
1191: WHERE header_id = x_HeaderId;
1197: --
1198: UPDATE rlm_schedule_headers
1199: SET process_status = x_HeaderStatus,
1200: LAST_UPDATE_LOGIN = fnd_global.login_id ,
1201: REQUEST_ID = RLM_MESSAGE_SV.g_conc_req_id ,
1202: PROGRAM_APPLICATION_ID = fnd_global.PROG_APPL_ID ,
1203: PROGRAM_ID = fnd_global.conc_program_id,
1204: PROGRAM_UPDATE_DATE = sysdate
1205: WHERE header_id = v_SchedHeaderId ;
1219: END IF;
1220: --
1221: WHEN OTHERS THEN
1222: --
1223: rlm_message_sv.sql_error('rlm_dp_sv.UpdateHeaderStatus', x_progress);
1224: --
1225: IF (l_debug <> -1) THEN
1226: rlm_core_sv.dpop(C_SDEBUG,'EXCEPTION: OTHER - sql error');
1227: END IF;
1339: END IF;
1340: --
1341: WHEN OTHERS THEN
1342: --
1343: rlm_message_sv.sql_error('rlm_dp_sv.RunExceptionReport', x_progress);
1344: --
1345: IF (l_debug <> -1) THEN
1346: rlm_core_sv.dpop(C_SDEBUG,'EXCEPTION: OTHER - sql error');
1347: END IF;
1394: EXCEPTION
1395: --
1396: WHEN OTHERS THEN
1397: --
1398: rlm_message_sv.sql_error('rlm_dp_sv.CheckForecast', v_Progress);
1399: --
1400: IF (l_debug <> -1) THEN
1401: rlm_core_sv.dpop(C_SDEBUG,'EXCEPTION: '|| SUBSTR(SQLERRM,1,200));
1402: END IF;
1622: v_devstatus,
1623: v_reqmessage);
1624: --
1625: update rlm_demand_exceptions
1626: set request_id = RLM_MESSAGE_SV.g_conc_req_id
1627: where request_id = x_child_req_id(i);
1628: --
1629: /* update group status for all lines with child req id*/
1630: --
1708: v_temp NUMBER;
1709: --
1710: BEGIN
1711: --
1712: rlm_message_sv.populate_req_id;
1713: --
1714: IF (l_debug <> -1) THEN
1715: rlm_core_sv.start_debug;
1716: rlm_core_sv.dpush(C_SDEBUG, 'ChildProcess');
2021: rlm_core_sv.k_PS_ERROR);
2022: -- Bug#: 2771756 - Start
2023: -- Bug 4198330 added group information
2024: rlm_core_sv.dlog(C_DEBUG,'Manage Demand remove messages');
2025: rlm_message_sv.removeMessages(
2026: p_header_id => p_header_id,
2027: p_message => 'RLM_RSO_CREATION_INFO',
2028: p_message_type => 'I',
2029: p_ship_from_org_id => v_group_rec.ship_from_org_id,
2030: p_ship_to_address_id => v_group_rec.ship_to_address_id,
2031: p_customer_item_id => v_group_rec.customer_item_id,
2032: p_inventory_item_id => v_group_rec.inventory_item_id);
2033: -- Bug#: 2771756 - End
2034: rlm_message_sv.dump_messages(p_header_id);
2035: --
2036: COMMIT;
2037: --
2038: IF (p_dspMode = k_SEQ_DSP) THEN
2062: v_Group_rec,
2063: rlm_core_sv.k_PS_ERROR);
2064: -- Bug#: 2771756 - Start
2065: -- Start bug 4198330 added grouping information
2066: rlm_message_sv.removeMessages(
2067: p_header_id => p_header_id,
2068: p_message => 'RLM_RSO_CREATION_INFO',
2069: p_message_type => 'I',
2070: p_ship_from_org_id => v_group_rec.ship_from_org_id,
2071: p_ship_to_address_id => v_group_rec.ship_to_address_id,
2072: p_customer_item_id => v_group_rec.customer_item_id,
2073: p_inventory_item_id => v_group_rec.inventory_item_id);
2074: -- Bug#: 2771756 - End
2075: rlm_message_sv.dump_messages(p_header_id);
2076: --
2077: COMMIT;
2078: --
2079: IF (p_dspMode = k_SEQ_DSP) THEN
2104: rlm_core_sv.k_PS_ERROR);
2105: -- Bug#: 2771756 - Start
2106: -- Start bug 4198330 added grouping information
2107: rlm_core_sv.dlog(C_DEBUG,' before remove messages');
2108: rlm_message_sv.removeMessages(
2109: p_header_id => p_header_id,
2110: p_message => 'RLM_RSO_CREATION_INFO',
2111: p_message_type => 'I',
2112: p_ship_from_org_id => v_group_rec.ship_from_org_id,
2113: p_ship_to_address_id => v_group_rec.ship_to_address_id,
2114: p_customer_item_id => v_group_rec.customer_item_id,
2115: p_inventory_item_id => v_group_rec.inventory_item_id);
2116: -- Bug#: 2771756 - End
2117: rlm_message_sv.dump_messages(p_header_id);
2118: --
2119: COMMIT;
2120: --
2121: IF (p_dspMode = k_SEQ_DSP) THEN
2153: v_Group_rec,
2154: rlm_core_sv.k_PS_ERROR);
2155: -- Bug#: 2771756 - Start
2156: -- Start bug 4198330 added grouping information
2157: rlm_message_sv.removeMessages(
2158: p_header_id => p_header_id,
2159: p_message => 'RLM_RSO_CREATION_INFO',
2160: p_message_type => 'I',
2161: p_ship_from_org_id => v_group_rec.ship_from_org_id,
2162: p_ship_to_address_id => v_group_rec.ship_to_address_id,
2163: p_customer_item_id => v_group_rec.customer_item_id,
2164: p_inventory_item_id => v_group_rec.inventory_item_id);
2165: -- Bug#: 2771756 - End
2166: rlm_message_sv.dump_messages(p_header_id);
2167: --
2168: COMMIT;
2169: --
2170: IF (p_dspMode = k_SEQ_DSP) THEN
2224: --
2225: WHEN OTHERS THEN
2226: --
2227: IF (l_debug <> -1) THEN
2228: rlm_message_sv.dump_messages(p_header_id);
2229: rlm_core_sv.dpop(C_SDEBUG, 'Error: '||SUBSTR(SQLERRM,1,200));
2230: END IF;
2231: --
2232: raise;