1

yanjinhui

7 天以前 4d2b6fea8d08c95bd6bb2b8c2b1228383110457e

 代码管理/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/Task/ScheduledTaskJob.cs

@@ -18,6 +18,7 @@

namespace WIDESEAWCS_Tasks
{
    [DisallowConcurrentExecution]
    public partial class ScheduledTaskJob : JobBase, IJob
    {
        private readonly ITaskService _taskService;
@@ -36,253 +37,255 @@

        public Task Execute(IJobExecutionContext context)
        {
            try
            {
                #region 涓夋ゼ鑷姩浠诲姟
                List<string> StationCodes = new() { "0348840CC0315655", "0349350CC0315655" };
                var stations = _StationInfoService.Repository.QueryData(x => StationCodes.Contains(x.StationCode));
                #region 鍏ユ彁鍗囨満浠诲姟
                var station = stations.FirstOrDefault(x => x.StationStatus == (int)LocationStatusEnum.InStock && x.IsOccupied == 0);
                if (station != null)
                {
                    var tasknum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum));
                    Dt_Task dt_Task = new Dt_Task()
                    {
                        TaskNum = tasknum,
                        WMSTaskNum = "GP" + tasknum,
                        Grade = 60,
                        PalletCode = station.PalletCode,
                        Roadway = "",
                        TaskState = (int)TaskStatusEnum.New,
                        TaskType = TaskTypeEnum.RK3F.ObjToInt(),
                        SourceAddress = station.StationCode,
                        CurrentAddress = station.StationCode,
                        NextAddress = "TSJR3F",
                        TargetAddress = "TSJR3F",
                        Creater = "WCS",
                    };
                    var content = _taskService.SendHIKROBOTTask(dt_Task);
                    if (content.Status)
                    {
                        dt_Task.TaskState = (int)TaskStatusEnum.Execut;
                        dt_Task.Dispatchertime = DateTime.Now;
                        station.StationStatus = (int)LocationStatusEnum.OutLock;
                        _taskService.AddData(dt_Task);
                        _StationInfoService.UpdateData(station);
                    }
                }
                #endregion
            //try
            //{
            //    #region 涓夋ゼ鑷姩浠诲姟
            //    List<string> StationCodes = new() { "0348840CC0315690", "0349350CC0315686" };
            //    var stations = _StationInfoService.Repository.QueryData(x => StationCodes.Contains(x.StationCode));
            //    #region 鍏ユ彁鍗囨満浠诲姟
            //    var station = stations.FirstOrDefault(x => x.StationStatus == (int)LocationStatusEnum.InStock && x.IsOccupied == 0);
            //    if (station != null)
            //    {
            //        var tasknum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum));
            //        Dt_Task dt_Task = new Dt_Task()
            //        {

                #region 鍑烘彁鍗囨満浠诲姟
                var device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "TSJ") as OtherDevice;
                if (device != null && device.IsConnected)
                {
                    if (device.GetValue<HoistEnum, short>(HoistEnum.SOutboundmaterialbox, "TSJC3F") == 1)
                    {
                        Dt_Task dt_Task = _taskService.Repository.QueryFirst(x => x.SourceAddress == "TSJC3F" /*&& x.TaskState < TaskStatusEnum.TakeFinish.ObjToInt()*/);
                        if (dt_Task == null)
                        {
                            station = stations.FirstOrDefault(x => x.StationStatus == (int)LocationStatusEnum.Free && x.IsOccupied == 0);
                            if (station != null)
                            {
                                var tasknum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum));
                                dt_Task = new Dt_Task()
                                {
                                    TaskNum = tasknum,
                                    WMSTaskNum = "GP" + tasknum,
                                    Grade = 60,
                                    PalletCode = "LXM" + tasknum,
                                    Roadway = "",
                                    TaskState = (int)TaskStatusEnum.New,
                                    TaskType = TaskTypeEnum.CK3F.ObjToInt(),
                                    SourceAddress = "TSJC3F",
                                    CurrentAddress = "TSJC3F",
                                    NextAddress = station.StationCode,
                                    TargetAddress = station.StationCode,
                                    Creater = "WCS",
                                };
                                var content = _taskService.SendHIKROBOTTask(dt_Task);
                                if (content.Status)
                                {
                                    dt_Task.TaskState = (int)TaskStatusEnum.Execut;
                                    dt_Task.Dispatchertime = DateTime.Now;
                                    station.StationStatus = (int)LocationStatusEnum.InLock;
                                    _taskService.AddData(dt_Task);
                                    _StationInfoService.UpdateData(station);
                                }
                            }
                        }
                    }
                }
                #endregion
            //            TaskNum = tasknum,
            //            WMSTaskNum = "GP" + tasknum,
            //            Grade = 60,
            //            PalletCode = station.PalletCode,
            //            Roadway = "",
            //            TaskState = (int)TaskStatusEnum.New,
            //            TaskType = TaskTypeEnum.RK3F.ObjToInt(),
            //            SourceAddress = station.StationCode,
            //            CurrentAddress = station.StationCode,
            //            NextAddress = "TSJR3F",
            //            TargetAddress = "TSJR3F",
            //            Creater = "WCS",
            //        };
            //        var content = _taskService.SendHIKROBOTTask(dt_Task);
            //        if (content.Status)
            //        {
            //            dt_Task.TaskState = (int)TaskStatusEnum.Execut;
            //            dt_Task.Dispatchertime = DateTime.Now;
            //            station.StationStatus = (int)LocationStatusEnum.OutLock;
            //            _taskService.AddData(dt_Task);
            //            _StationInfoService.UpdateData(station);
            //        }
            //    }
            //    #endregion

                #endregion
            //    #region 鍑烘彁鍗囨満浠诲姟
            //    var device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "TSJ") as OtherDevice;
            //    if (device != null && device.IsConnected)
            //    {
            //        if (device.GetValue<HoistEnum, short>(HoistEnum.SOutboundmaterialbox, "TSJC3F") == 1)
            //        {
            //            Dt_Task dt_Task = _taskService.Repository.QueryFirst(x => x.SourceAddress == "TSJC3F" /*&& x.TaskState < TaskStatusEnum.TakeFinish.ObjToInt()*/);
            //            if (dt_Task == null)
            //            {
            //                station = stations.FirstOrDefault(x => x.StationStatus == (int)LocationStatusEnum.Free && x.IsOccupied == 0);
            //                if (station != null)
            //                {
            //                    var tasknum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum));
            //                    dt_Task = new Dt_Task()
            //                    {
            //                        TaskNum = tasknum,
            //                        WMSTaskNum = "GP" + tasknum,
            //                        Grade = 60,
            //                        PalletCode = "LXM" + tasknum,
            //                        Roadway = "",
            //                        TaskState = (int)TaskStatusEnum.New,
            //                        TaskType = TaskTypeEnum.CK3F.ObjToInt(),
            //                        SourceAddress = "TSJC3F",
            //                        CurrentAddress = "TSJC3F",
            //                        NextAddress = station.StationCode,
            //                        TargetAddress = station.StationCode,
            //                        Creater = "WCS",
            //                    };
            //                    var content = _taskService.SendHIKROBOTTask(dt_Task);
            //                    if (content.Status)
            //                    {
            //                        dt_Task.TaskState = (int)TaskStatusEnum.Execut;
            //                        dt_Task.Dispatchertime = DateTime.Now;
            //                        station.StationStatus = (int)LocationStatusEnum.InLock;
            //                        _taskService.AddData(dt_Task);
            //                        _StationInfoService.UpdateData(station);
            //                    }
            //                }
            //            }
            //        }
            //    }
            //    #endregion

                #region 4F
                List<string> stationCodes = new() { "0319882DD0312730", "0319882DD0313240" };
                var Stations = _StationInfoService.Repository.QueryData(x => stationCodes.Contains(x.StationCode));
                #region 鍏ユ彁鍗囨満浠诲姟
                var Station = Stations.FirstOrDefault(x => x.StationStatus == (int)LocationStatusEnum.InStock && x.IsOccupied == 0);
                if (Station != null)
                {
                    var tasknum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum));
                    Dt_Task dt_Task = new Dt_Task()
                    {
                        TaskNum = tasknum,
                        WMSTaskNum = "GP" + tasknum,
                        Grade = 60,
                        PalletCode = Station.PalletCode,
                        Roadway = "",
                        TaskState = (int)TaskStatusEnum.New,
                        TaskType = TaskTypeEnum.F04.ObjToInt(),
                        SourceAddress = Station.StationCode,
                        CurrentAddress = Station.StationCode,
                        NextAddress = "TSJR4F",
                        TargetAddress = "TSJR4F",
                        Creater = "WCS",
                    };
                    var content = _taskService.SendHIKROBOTTask(dt_Task);
                    if (content.Status)
                    {
                        dt_Task.TaskState = (int)TaskStatusEnum.Execut;
                        dt_Task.Dispatchertime = DateTime.Now;
                        Station.StationStatus = (int)LocationStatusEnum.OutLock;
                        _taskService.AddData(dt_Task);
                        _StationInfoService.UpdateData(Station);
                    }
                }
                #endregion
            //    #endregion

                #region 鍑烘彁鍗囨満浠诲姟
                device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "TSJ") as OtherDevice;
                if (device != null && device.IsConnected)
                {
                    if (device.GetValue<HoistEnum, short>(HoistEnum.FOutboundmaterialbox, "TSJC4F") == 1)
                    {
                        Dt_Task dt_Task = _taskService.Repository.QueryFirst(x => x.SourceAddress == "TSJC4F" /*&& x.TaskState < TaskStatusEnum.TakeFinish.ObjToInt()*/);
                        if (dt_Task == null)
                        {
                            Station = Stations.FirstOrDefault(x => x.StationStatus == (int)LocationStatusEnum.Free && x.IsOccupied == 0);
                            if (Station != null)
                            {
                                var tasknum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum));
                                dt_Task = new Dt_Task()
                                {
                                    TaskNum = tasknum,
                                    WMSTaskNum = "GP" + tasknum,
                                    Grade = 60,
                                    PalletCode = "LXM" + tasknum,
                                    Roadway = "",
                                    TaskState = (int)TaskStatusEnum.New,
                                    TaskType = TaskTypeEnum.F03.ObjToInt(),
                                    SourceAddress = "TSJC4F",
                                    CurrentAddress = "TSJC4F",
                                    NextAddress = Station.StationCode,
                                    TargetAddress = Station.StationCode,
                                    Creater = "WCS",
                                };
                                var content = _taskService.SendHIKROBOTTask(dt_Task);
                                if (content.Status)
                                {
                                    dt_Task.TaskState = (int)TaskStatusEnum.Execut;
                                    dt_Task.Dispatchertime = DateTime.Now;
                                    Station.StationStatus = (int)LocationStatusEnum.InLock;
                                    _taskService.AddData(dt_Task);
                                    _StationInfoService.UpdateData(Station);
                                }
                            }
                        }
                    }
                }
                #endregion
            //    #region 4F
            //    List<string> stationCodes = new() { "0319882DD0313240", "0319882DD0313750"};
            //    var Stations = _StationInfoService.Repository.QueryData(x => stationCodes.Contains(x.StationCode));
            //    #region 鍏ユ彁鍗囨満浠诲姟
            //    var Station = Stations.FirstOrDefault(x => x.StationStatus == (int)LocationStatusEnum.InStock && x.IsOccupied == 0);
            //    if (Station != null)
            //    {
            //        var tasknum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum));
            //        Dt_Task dt_Task = new Dt_Task()
            //        {
            //            TaskNum = tasknum,
            //            WMSTaskNum = "GP" + tasknum,
            //            Grade = 60,
            //            PalletCode = Station.PalletCode,
            //            Roadway = "",
            //            TaskState = (int)TaskStatusEnum.New,
                        //TaskType = TaskTypeEnum.F04.ObjToInt(),
            //            SourceAddress = Station.StationCode,
            //            CurrentAddress = Station.StationCode,
            //            NextAddress = "TSJR4F",
            //            TargetAddress = "TSJR4F",
            //            Creater = "WCS",
            //        };
            //        var content = _taskService.SendHIKROBOTTask(dt_Task);
            //        if (content.Status)
            //        {
            //            dt_Task.TaskState = (int)TaskStatusEnum.Execut;
            //            dt_Task.Dispatchertime = DateTime.Now;
            //            Station.StationStatus = (int)LocationStatusEnum.OutLock;
            //            _taskService.AddData(dt_Task);
            //            _StationInfoService.UpdateData(Station);
            //        }
            //    }
            //    #endregion

                #endregion
            //    #region 鍑烘彁鍗囨満浠诲姟
            //    device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "TSJ") as OtherDevice;
            //    if (device != null && device.IsConnected)
            //    {
            //        var reslur = device.GetValue<HoistEnum, short>(HoistEnum.FOutboundmaterialbox, "TSJC4F");
            //        if (device.GetValue<HoistEnum, short>(HoistEnum.FOutboundmaterialbox, "TSJC4F") == 1)
            //        {
            //            Dt_Task dt_Task = _taskService.Repository.QueryFirst(x => x.SourceAddress == "TSJC4F" /*&& x.TaskState < TaskStatusEnum.TakeFinish.ObjToInt()*/);
            //            if (dt_Task == null)
            //            {
            //                Station = Stations.FirstOrDefault(x => x.StationStatus == (int)LocationStatusEnum.Free && x.IsOccupied == 0);
            //                if (Station != null)
            //                {
            //                    var tasknum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum));
            //                    dt_Task = new Dt_Task()
            //                    {
            //                        TaskNum = tasknum,
            //                        WMSTaskNum = "GP" + tasknum,
            //                        Grade = 60,
            //                        PalletCode = "LXM" + tasknum,
            //                        Roadway = "",
            //                        TaskState = (int)TaskStatusEnum.New,
            //                        TaskType = TaskTypeEnum.F03.ObjToInt(),
            //                        SourceAddress = "TSJC4F",
            //                        CurrentAddress = "TSJC4F",
            //                        NextAddress = Station.StationCode,
            //                        TargetAddress = Station.StationCode,
            //                        Creater = "WCS",
            //                    };
            //                    var content = _taskService.SendHIKROBOTTask(dt_Task);
            //                    if (content.Status)
            //                    {
            //                        dt_Task.TaskState = (int)TaskStatusEnum.Execut;
            //                        dt_Task.Dispatchertime = DateTime.Now;
            //                        Station.StationStatus = (int)LocationStatusEnum.InLock;
            //                        _taskService.AddData(dt_Task);
            //                        _StationInfoService.UpdateData(Station);
            //                    }
            //                }
            //            }
            //        }
            //    }
            //    #endregion

                #region 鍥涙ゼ鑷姩浠诲姟
                //List<string> LocationCodes = new() { "RGD0303A04041", "RG0302A05041", "RG0304A05041", "RG0205A05031" };
                List<string> LocationCodes = new() { "RGD0302A05041", "RGD0304A05041", "R3CG0106A04031", "RGD0307A05012" };
                var hKLocationInfos = _HKLocationInfoService.Repository.QueryData(x => LocationCodes.Contains(x.LocationCode));
                #region 鍏ユ彁鍗囨満浠诲姟
                var hKLocation = hKLocationInfos.FirstOrDefault(x => x.LocationStatus == (int)LocationStatusEnum.InStock);
                if (hKLocation != null)
                {
                    var tasknum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum));
                    Dt_Task dt_Task = new Dt_Task()
                    {
                        TaskNum = tasknum,
                        WMSTaskNum = "GP" + tasknum,
                        Grade = 60,
                        PalletCode = hKLocation.PalletCode,
                        Roadway = "",
                        TaskState = (int)TaskStatusEnum.New,
                        TaskType = TaskTypeEnum.CHUKU1.ObjToInt(),
                        SourceAddress = hKLocation.LocationCode,
                        CurrentAddress = hKLocation.LocationCode,
                        NextAddress = "TSJR4F",
                        TargetAddress = "TSJR4F",
                        Creater = "WCS",
                    };
                    var content = _taskService.SendHIKROBOTTask(dt_Task);
                    if (content.Status)
                    {
                        dt_Task.TaskState = (int)TaskStatusEnum.Execut;
                        dt_Task.Dispatchertime = DateTime.Now;
                        hKLocation.LocationStatus = (int)LocationStatusEnum.OutLock;
                        _taskService.AddData(dt_Task);
                        _HKLocationInfoService.UpdateData(hKLocation);
                    }
                }
                #endregion
            //    #endregion

                #region 鍑烘彁鍗囨満浠诲姟
                //if (device != null && device.IsConnected)
                //{
                //    if (device.GetValue<HoistEnum, short>(HoistEnum.FOutboundmaterialbox, "TSJC4F") == 1)
                //    {
                //        Dt_Task dt_Task = _taskService.Repository.QueryFirst(x => x.SourceAddress == "TSJC4F");
                //        if (dt_Task == null)
                //        {
                //            hKLocation = hKLocationInfos.FirstOrDefault(x => x.LocationStatus == (int)LocationStatusEnum.Free);
                //            if (hKLocation != null)
                //            {
                //                var tasknum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum));
                //                dt_Task = new Dt_Task()
                //                {
                //                    TaskNum = tasknum,
                //                    WMSTaskNum = "GP" + tasknum,
                //                    Grade = 60,
                //                    PalletCode = "LXM" + tasknum,
                //                    Roadway = "",
                //                    TaskState = (int)TaskStatusEnum.New,
                //                    TaskType = TaskTypeEnum.Q1TSJ4.ObjToInt(),
                //                    SourceAddress = "TSJC4F",
                //                    CurrentAddress = "TSJC4F",
                //                    NextAddress = hKLocation.LocationCode,
                //                    TargetAddress = hKLocation.LocationCode,
                //                    Creater = "WCS",
                //                };
                //                var content = _taskService.SendHIKROBOTTask(dt_Task);
                //                if (content.Status)
                //                {
                //                    dt_Task.TaskState = (int)TaskStatusEnum.Execut;
                //                    dt_Task.Dispatchertime = DateTime.Now;
                //                    hKLocation.LocationStatus = (int)LocationStatusEnum.InLock;
                //                    _taskService.AddData(dt_Task);
                //                    _HKLocationInfoService.UpdateData(hKLocation);
                //                }
                //            }
                //        }
            //    #region 鍥涙ゼ鑷姩浠诲姟
            //    //List<string> LocationCodes = new() { "RGD0303A04041", "RG0302A05041", "RG0304A05041", "RG0205A05031" };
            //    List<string> LocationCodes = new() { "RGD0302A05041", "RGD0304A05041", "R3CG0106A04031", "RGD0307A05012" };
            //    var hKLocationInfos = _HKLocationInfoService.Repository.QueryData(x => LocationCodes.Contains(x.LocationCode));
            //    #region 鍏ユ彁鍗囨満浠诲姟
            //    var hKLocation = hKLocationInfos.FirstOrDefault(x => x.LocationStatus == (int)LocationStatusEnum.InStock);
            //    if (hKLocation != null)
            //    {
            //        var tasknum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum));
            //        Dt_Task dt_Task = new Dt_Task()
            //        {
            //            TaskNum = tasknum,
            //            WMSTaskNum = "GP" + tasknum,
            //            Grade = 60,
            //            PalletCode = hKLocation.PalletCode,
            //            Roadway = "",
            //            TaskState = (int)TaskStatusEnum.New,
                        //TaskType = TaskTypeEnum.CHUKU1.ObjToInt(),
            //            SourceAddress = hKLocation.LocationCode,
            //            CurrentAddress = hKLocation.LocationCode,
            //            NextAddress = "TSJR4F",
            //            TargetAddress = "TSJR4F",
            //            Creater = "WCS",
            //        };
            //        var content = _taskService.SendHIKROBOTTask(dt_Task);
            //        if (content.Status)
            //        {
            //            dt_Task.TaskState = (int)TaskStatusEnum.Execut;
            //            dt_Task.Dispatchertime = DateTime.Now;
            //            hKLocation.LocationStatus = (int)LocationStatusEnum.OutLock;
            //            _taskService.AddData(dt_Task);
            //            _HKLocationInfoService.UpdateData(hKLocation);
            //        }
            //    }
            //    #endregion

                //    }
                //}
                #endregion
            //    #region 鍑烘彁鍗囨満浠诲姟
            //    //if (device != null && device.IsConnected)
            //    //{
            //    //    if (device.GetValue<HoistEnum, short>(HoistEnum.FOutboundmaterialbox, "TSJC4F") == 1)
            //    //    {
            //    //        Dt_Task dt_Task = _taskService.Repository.QueryFirst(x => x.SourceAddress == "TSJC4F");
            //    //        if (dt_Task == null)
            //    //        {
            //    //            hKLocation = hKLocationInfos.FirstOrDefault(x => x.LocationStatus == (int)LocationStatusEnum.Free);
            //    //            if (hKLocation != null)
            //    //            {
            //    //                var tasknum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum));
            //    //                dt_Task = new Dt_Task()
            //    //                {
            //    //                    TaskNum = tasknum,
            //    //                    WMSTaskNum = "GP" + tasknum,
            //    //                    Grade = 60,
            //    //                    PalletCode = "LXM" + tasknum,
            //    //                    Roadway = "",
            //    //                    TaskState = (int)TaskStatusEnum.New,
            //    //                    TaskType = TaskTypeEnum.Q1TSJ4.ObjToInt(),
            //    //                    SourceAddress = "TSJC4F",
            //    //                    CurrentAddress = "TSJC4F",
            //    //                    NextAddress = hKLocation.LocationCode,
            //    //                    TargetAddress = hKLocation.LocationCode,
            //    //                    Creater = "WCS",
            //    //                };
            //    //                var content = _taskService.SendHIKROBOTTask(dt_Task);
            //    //                if (content.Status)
            //    //                {
            //    //                    dt_Task.TaskState = (int)TaskStatusEnum.Execut;
            //    //                    dt_Task.Dispatchertime = DateTime.Now;
            //    //                    hKLocation.LocationStatus = (int)LocationStatusEnum.InLock;
            //    //                    _taskService.AddData(dt_Task);
            //    //                    _HKLocationInfoService.UpdateData(hKLocation);
            //    //                }
            //    //            }
            //    //        }

                #endregion
            }
            catch (Exception ex)
            {
                Console.Out.WriteLine(nameof(TaskJob) + ":" + ex.Message);
            }
            //    //    }
            //    //}
            //    #endregion

            //    #endregion
            //}
            //catch (Exception ex)
            //{
            //    Console.Out.WriteLine(nameof(TaskJob) + ":" + ex.Message);
            //}
            return Task.CompletedTask;
        }
    }