修改队列任务逻辑

dengjunjie

2024-05-06 25698020def2aba0db3bc6807ceef325ed4ea8b1

修改队列任务逻辑

 ´úÂë¹ÜÀí/PCS/WCS_Server/WIDESEA_Comm/StateEnum/TrayEnum.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,38 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace WIDESEA_Comm
{
    /// <summary>
    /// æ‰˜ç›˜çŠ¶æ€
    /// </summary>
    public enum TrayStateEnum
    {
        /// <summary>
        /// ç©ºæ‰˜ç›˜
        /// </summary>
        EmptyTray,
        /// <summary>
        /// æ»¡æ‰˜ç›˜
        /// </summary>
        StrogeTray

    }
    /// <summary>
    /// æ‰˜ç›˜ç±»åž‹
    /// </summary>
    public enum TrayTypeEnum
    {
        /// <summary>
        /// å°æ‰˜ç›˜
        /// </summary>
        SmallTray,
        /// <summary>
        /// å¤§æ‰˜ç›˜
        /// </summary>
        LargeTray,
    }
}

 ´úÂë¹ÜÀí/PCS/WCS_Server/WIDESEA_Comm/TaskEnum/AGVJobEnum.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,34 @@
using System;
using System.Collections.Generic;
using System.Text;

namespace WIDESEA_Common
{
    public enum AGVJobEnum
    {
        /// <summary>
        /// æ–°ä»»åŠ¡
        /// </summary>
        newTaskEnum = 1,
        /// <summary>
        /// å–消任务
        /// </summary>
        cancelTaskEnum = 2,
        /// <summary>
        /// å˜æ›´ä»»åŠ¡
        /// </summary>
        changeTaskEnum = 3,
        /// <summary>
        /// ä¸‹å‘任务异常
        /// </summary>
        newTaskExp = 11,
        /// <summary>
        /// å–消任务异常
        /// </summary>
        cancelTaskExp = 12,
        /// <summary>
        /// å˜æ›´ä»»åŠ¡å¼‚常
        /// </summary>
        changeTaskExp = 13,
    }
}

 ´úÂë¹ÜÀí/PCS/WCS_Server/WIDESEA_Comm/TaskEnum/AGVTaskStateEnum.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,74 @@
using System;
using System.Collections.Generic;
using System.Text;

namespace WIDESEA_Common
{
    public enum AGVTaskStateEnum
    {
        /// <summary>
        /// å·²ä¸‹å‘待回复
        /// </summary>
        Wait,
        /// <summary>
        /// èµ·ç‚¹æ‰§è¡Œä¸­
        /// </summary>
        Executing = 1,
        /// <summary>
        /// èµ·ç‚¹å·²å®Œæˆ
        /// </summary>
        Complete = 2,
        /// <summary>
        /// ç»ˆç‚¹æ‰§è¡Œä¸­
        /// </summary>
        Executing1 = 3,
        /// <summary>
        /// ç»ˆç‚¹å·²å®Œæˆ
        /// </summary>
        Complete1 = 4,
        /// <summary>
        /// å·²ä¸‹å‘
        /// </summary>
        SendOut,
        /// <summary>
        /// å·²åˆ›å»ºæœªæ‰§è¡Œ
        /// </summary>
        Create,
        /// <summary>
        /// å¼‚常
        /// </summary>
        Abnormal,
        /// <summary>
        /// ç¼–辑中
        /// </summary>
        Editing,
        /// <summary>
        /// æ›´æ”¹ä»»åŠ¡ç­‰çº§å¼‚常（RCS收到的现有任务更改指令无法执行）
        /// </summary>
        EditAbnormal,
        /// <summary>
        /// æ‰§è¡Œå¼‚常（RCS已收到新下发的任务但无法执行）
        /// </summary>
        ExecutAbnormal,
        /// <summary>
        /// å–消
        /// </summary>
        Cancel,
        /// <summary>
        /// å¾…取消
        /// </summary>
        WaitCancel,
        /// <summary>
        /// å–消异常（RCS收到的现有任务取消指令无法执行）
        /// </summary>
        CancelAbnormal,
        /// <summary>
        /// å–消待回复
        /// </summary>
        WaitReply,
        /// <summary>
        /// é˜Ÿåˆ—中
        /// </summary>
        Queue,
    }
}

 ´úÂë¹ÜÀí/PCS/WCS_Server/WIDESEA_Comm/TaskEnum/AGVTaskTypeEnum.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,54 @@
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Text;

namespace WIDESEA_Common
{
    public enum AGVTaskTypeEnum
    {
        /// <summary>
        /// é€æ»¡æ–™æž¶
        /// </summary>
        //SendFull = 1,
        /// <summary>
        /// å–空料架
        /// </summary>
        //TakeEmpty = 2,
        /// <summary>
        /// å¾…检库入库
        /// </summary>
        [Description("待检库入库")]
        TaskType_Inbound = 1,
        /// <summary>
        /// å¾…检库出库
        /// </summary>
        [Description("待检库出库")]
        TaskType_Outbound = 2,
        /// <summary>
        /// å¤–协库入库
        /// </summary>
        [Description("外协库入库")]
        TaskType_OutsourceInbound = 3,
        /// <summary>
        /// å¤–协库出库
        /// </summary>
        [Description("外协库出库")]
        TaskType_OutsourceOutbound = 4,
        /// <summary>
        /// å¾…检库内移库
        /// </summary>
        [Description("待检库内移库")]
        TaskType_Carry,
        /// <summary>
        /// å¾…检移库外协
        /// </summary>
        [Description("待检移库外协")]
        TaskType_OutsourceCarry,
        /// <summary>
        /// è¡¥ç©ºæ‰˜ä»»åŠ¡
        /// </summary>
        [Description("补空托任务")]
        TaskType_EmptyPallet,
    }
}

 ´úÂë¹ÜÀí/PCS/WCS_Server/WIDESEA_WCS/Common/Gantry.cs

@@ -404,6 +404,15 @@
                        }
                        #endregion

                        var Stations = stationinfoRepository.Find(x => x.area == PipelineJob.area_code(name)).OrderBy(x => x.lastUpdateTime).ToList();

                        #region ä¸‹æ–™ä½æ˜¯å¦ä¸ºç©ºçŠ¶æ€åŒæ­¥ç»™æ¡æž¶
                        foreach (var station in Stations)
                        {
                            client.WriteByOrder(station.stationCode, station.location_state != LocationStateEnum.Stroge.ToString(), name);
                        }
                        #endregion

                        if (finished && !updatefinished)
                        {
                            client.WriteByOrder("W_Enabl_Load", false, name);//是否允许
@@ -551,14 +560,6 @@
                        #endregion


                        var Stations = stationinfoRepository.Find(x => x.area == PipelineJob.area_code(name)).OrderBy(x => x.lastUpdateTime).ToList();

                        #region ä¸‹æ–™ä½æ˜¯å¦ä¸ºç©ºçŠ¶æ€åŒæ­¥ç»™æ¡æž¶
                        foreach (var station in Stations)
                        {
                            client.WriteByOrder(station.stationCode, station.location_state != LocationStateEnum.Stroge.ToString(), name);
                        }
                        #endregion

                        #region MyRegion
                        //var currentAreaNr = (Int16)DBExtension.Read(details.Where(x => x.plcdetail_name == "W_Are00aNr").First(), client);

 ´úÂë¹ÜÀí/PCS/WCS_Server/WIDESEA_WCS/JobsPart/Common/GetStation/EmptyPalletStation.cs

@@ -60,9 +60,9 @@
                #region ä¼˜å…ˆå‡º3库区内空托盘
                if (area == "11")
                {
                    EmptyStation = stationinfoRepository.Find(x => x.quantity > 0 && x.stationCode == "C01004001" /*&& x.location_state == "Stroge"*/ && x.tray_status == "EmptyTray" && x.enable).FirstOrDefault();
                    EmptyStation = stationinfoRepository.Find(x => x.quantity > 0 && x.stationCode == "C01004002" /*&& x.location_state == "Stroge"*/ && x.tray_status == "EmptyTray" && x.enable).FirstOrDefault();
                    if (EmptyStation == null)
                        EmptyStation = stationinfoRepository.Find(x => x.quantity > 0 && x.stationCode == "C01005001"/* && x.location_state == "Stroge"*/ && x.tray_status == "EmptyTray" && x.enable).FirstOrDefault();
                        EmptyStation = stationinfoRepository.Find(x => x.quantity > 0 && x.stationCode == "C01005002"/* && x.location_state == "Stroge"*/ && x.tray_status == "EmptyTray" && x.enable).FirstOrDefault();
                    if (EmptyStation != null)
                        EmptyStation = stationinfoRepository.Find(x => x.quantity > 0 && x.area == EmptyStation.area && x.line == EmptyStation.line /*&& x.location_state == "Stroge"*/ && x.tray_status == "EmptyTray" && x.enable).OrderByDescending(x => x.column).FirstOrDefault();
                    if (EmptyStation != null)//空托货位不为空判断是否存在其他任务
@@ -143,15 +143,16 @@
                Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context);

                #region æŸ¥æ‰¾ç©ºæ‰˜ç›˜åº“区
                if (stationinfoRepository.Find(x => x.area == area && x.location_state == LocationStateEnum.Busy.ToString()).Any() && area != "10")
                //if (stationinfoRepository.Find(x => x.area == area && x.location_state == LocationStateEnum.Busy.ToString()).Any() && area != "10")
                if (stationinfoRepository.Find(x => x.stationCode == "A01001001" && x.quantity == 5 && x.location_state == LocationStateEnum.Stroge.ToString()).Any())
                {
                    var EmptyStation = stationinfoRepository.Find(x => x.stationCode == "C01005001" && x.location_state == LocationStateEnum.Empty.ToString()).FirstOrDefault();
                    var EmptyStation = stationinfoRepository.Find(x => x.stationCode == "C01005002" && x.location_state == LocationStateEnum.Empty.ToString()).FirstOrDefault();
                    if (EmptyStation != null)
                    {
                        if (!stationinfoRepository.Find(x => x.line == EmptyStation.line && x.area == EmptyStation.area && x.location_state != LocationStateEnum.Empty.ToString()).Any())
                            return EmptyStation;
                    }
                    EmptyStation = stationinfoRepository.Find(x => x.quantity > 0 && x.stationCode == "C01005001" && x.location_state == "Stroge" && x.tray_status == "EmptyTray" && x.enable).FirstOrDefault();
                    EmptyStation = stationinfoRepository.Find(x => x.quantity > 0 && x.stationCode == "C01005002" && x.location_state == "Stroge" && x.tray_status == "EmptyTray" && x.enable).FirstOrDefault();


                    if (EmptyStation != null) stationinfo = Station(EmptyStation, stationinfoRepository);
@@ -161,31 +162,25 @@

                    if (EmptyStation.quantity == 5)
                    {
                        EmptyStation = stationinfoRepository.Find(x => x.stationCode == "C01004001" && x.location_state == LocationStateEnum.Empty.ToString()).FirstOrDefault();
                        EmptyStation = stationinfoRepository.Find(x => x.stationCode == "C01004002" && x.location_state == LocationStateEnum.Empty.ToString()).FirstOrDefault();
                        if (EmptyStation != null)
                        {
                            if (!stationinfoRepository.Find(x => x.line == EmptyStation.line && x.area == EmptyStation.area && x.location_state != LocationStateEnum.Empty.ToString()).Any())
                                return EmptyStation;
                        }

                        EmptyStation = stationinfoRepository.Find(x => x.quantity > 0 && x.stationCode == "C01004001" && x.location_state == "Stroge" && x.tray_status == "EmptyTray" && x.enable).FirstOrDefault();
                        EmptyStation = stationinfoRepository.Find(x => x.quantity > 0 && x.stationCode == "C01004002" && x.location_state == "Stroge" && x.tray_status == "EmptyTray" && x.enable).FirstOrDefault();
                        if (EmptyStation != null) stationinfo = Station(EmptyStation, stationinfoRepository);
                    }

                }
                else
                {
                    if (stationinfoRepository.Find(x => x.area == area && x.location_state == LocationStateEnum.Busy.ToString()).Any()) return stationinfo;
                    stationinfo = stationinfoRepository.Find(x => x.area == area && x.quantity > 0 && x.enable).OrderBy(x => x.column).FirstOrDefault();
                    if (stationinfo != null)
                    {
                        if (stationinfo.quantity < 5) return stationinfo;
                        else
                            stationinfo = stationinfoRepository.Find(x => x.area == area && x.location_state == LocationStateEnum.Empty.ToString() && x.enable).OrderByDescending(x => x.column).FirstOrDefault();
                    }
                    else
                    {
                        stationinfo = stationinfoRepository.Find(x => x.area == area && x.location_state == LocationStateEnum.Empty.ToString() && x.enable).OrderByDescending(x => x.column).FirstOrDefault();
                    }
                    stationinfo = stationinfoRepository.Find(x => x.area == area && x.location_state == LocationStateEnum.Empty.ToString() && x.enable).OrderByDescending(x => x.column).FirstOrDefault();

                }
                #endregion

 ´úÂë¹ÜÀí/PCS/WCS_Server/WIDESEA_WCS/JobsPart/Common/RestockHCJ.cs

@@ -1,11 +1,14 @@
using System;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using System.Xml.Linq;
using WIDESEA_Comm;
using WIDESEA_Comm.LogInfo;
using WIDESEA_Common;
using WIDESEA_Core.BaseProvider;
using WIDESEA_Core.EFDbContext;
using WIDESEA_Entity.DomainModels;
@@ -31,104 +34,210 @@
            try
            {
                VOLContext Context = new VOLContext();
                Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context);
                IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(Context);
                Idt_agvtaskRepository agvtaskService = new dt_agvtaskRepository(Context);
                var tasks = agvtaskService.Find(x => x.agv_taskstate == "Queue").OrderByDescending(x => x.agv_grade).ThenBy(x => x.agv_createtime).ToList();
                foreach (var task in tasks)

                #region é˜Ÿåˆ—任务
                var agvtasks = agvtaskService.Find(x => x.agv_taskstate == AGVTaskStateEnum.Queue.ToString()).ToList();

                var AGVTaskTypes = Enum.GetNames(typeof(AGVTaskTypeEnum));
                foreach (var AGVTaskType in AGVTaskTypes)
                {
                    try
                    var agvtask = agvtasks.Where(x => x.agv_tasktype == AGVTaskType).OrderByDescending(x => x.agv_grade).ThenBy(x => x.agv_createtime).FirstOrDefault();
                    if (agvtask != null) UpdateQueue(agvtaskService, agvtask);
                }
                #endregion

                #region MyRegion
                //var tasks = agvtaskService.Find(x => x.agv_taskstate == "Queue").OrderByDescending(x => x.agv_grade).ThenBy(x => x.agv_createtime).ToList();
                //foreach (var task in tasks)
                //{
                //    try
                //    {
                //        if (task.agv_tasktype == "TaskType_EmptyPallet")//空托任务
                //        {
                //            if (task.agv_fromaddress == "" && DateTime.Now - task.agv_createtime >= TimeSpan.FromMinutes(2))
                //            {
                //                if (task.agv_tasknum.Contains("_"))
                //                {
                //                    string mainTaskNum = task.agv_tasknum.Split('_')[0];
                //                    if (agvtaskService.Find(x => x.agv_tasknum == mainTaskNum && task.agv_taskstate != "Executing" && task.agv_taskstate != "Create").Any() || !agvtaskService.Find(x => x.agv_tasknum == mainTaskNum).Any())
                //                        GetStation.EmptyPalletStation(task);
                //                }
                //                else
                //                    GetStation.EmptyPalletStation(task);

                //                WriteDBLog.Success("更新空托队列任务", $"任务编号：{task.agv_tasknum}", "PCS");
                //                continue;
                //            }
                //        }
                //        else if (task.agv_tasktype == "TaskType_OutsourceInbound" || task.agv_tasktype == "TaskType_Inbound")//外协库入库/AB库入库
                //        {
                //            if (task.agv_toaddress == "")
                //            {
                //                var stationinfo = stationinfoRepository.Find(x => x.stationCode == task.agv_fromaddress).FirstOrDefault();
                //                var work = workinfoRepository.Find(x => x.workOrder == stationinfo.Number && x.drawingNo == stationinfo.stationType && x.heatID == stationinfo.heatNumber && x.processCode == "17").FirstOrDefault();
                //                var TargetLocation = task.agv_tasktype == "TaskType_Inbound" ? GetLocation.GetEmptyLocation(stationinfoRepository, work, task) : StationTask.GetEmptyLocation(stationinfoRepository);
                //                if (TargetLocation != null)
                //                {
                //                    if (agvtaskService.Find(x => x.agv_toaddress == TargetLocation.stationCode).Any()) continue;
                //                    task.agv_taskstate = "Create";
                //                    task.agv_toaddress = TargetLocation.stationCode;
                //                    TargetLocation.location_state = LocationStateEnum.InBusy.ToString();
                //                    TargetLocation.billetID = stationinfo.billetID;
                //                    TargetLocation.stationType = task.agv_materielid;
                //                    TargetLocation.heatNumber = stationinfo.heatNumber;
                //                    TargetLocation.Number = task.jobID;
                //                    stationinfoRepository.Update(TargetLocation, true);
                //                    agvtaskService.Update(task, true);
                //                    WriteDBLog.Success("更新入库队列任务", $"任务编号：{task.agv_tasknum}", "PCS");
                //                    continue;
                //                }
                //            }
                //        }
                //        else if (task.agv_tasktype == "TaskType_OutsourceOutbound" || task.agv_tasktype == "TaskType_Outbound")//外协库出库/AB库出库
                //        {
                //            if (task.agv_toaddress == "")
                //            {
                //                var EmptyStations = stationinfoRepository.Find(x => x.stationCode.Contains("S01001") && (x.tray_status == "EmptyTray" || x.location_state == "Empty") && x.enable).ToList();
                //                foreach (var EmptyStation in EmptyStations)
                //                {
                //                    if (agvtaskService.Find(x => x.agv_toaddress == EmptyStation.stationCode).Any()) continue;
                //                    task.agv_taskstate = "Create";
                //                    task.agv_toaddress = EmptyStation.stationCode;
                //                    EmptyStation.location_state = LocationStateEnum.Busy.ToString();
                //                    stationinfoRepository.Update(EmptyStation, true);
                //                    agvtaskService.Update(task, true);
                //                    WriteDBLog.Success("更新出库队列任务", $"任务编号：{task.agv_tasknum}", "PCS");
                //                    return;
                //                }
                //            }
                //        }
                //        else if (task.agv_tasktype == "TaskType_OutsourceCarry")//移库外协
                //        {
                //            if (task.agv_toaddress == "")
                //            {
                //                var TargetLocation = StationTask.GetEmptyLocation(stationinfoRepository);
                //                if (TargetLocation != null)
                //                {
                //                    if (agvtaskService.Find(x => x.agv_toaddress == TargetLocation.stationCode).Any()) continue;

                //                    task.agv_taskstate = "Create";
                //                    task.agv_toaddress = TargetLocation.stationCode;
                //                    TargetLocation.location_state = LocationStateEnum.OutBusy.ToString();
                //                    TargetLocation.stationType = task.agv_materielid;
                //                    stationinfoRepository.Update(TargetLocation, true);
                //                    agvtaskService.Update(task, true);
                //                    WriteDBLog.Success("更新移库外协队列任务", $"任务编号：{task.agv_tasknum}", "PCS");
                //                    continue;
                //                }
                //            }
                //        }
                //    }
                //    catch (Exception ex)
                //    {
                //        //WriteDBLog.Error("更新队列任务", $"错误信息：{ex.Message}", "PCS");
                //        WriteLog.Write_Log("更新队列任务", "更新失败", "", $"错误信息：{ex.Message}");
                //    }
                //}
                #endregion

            }
            catch (Exception ex)
            {
                WriteDBLog.Error("更新队列任务", $"错误信息：{ex.Message}", "PCS");
            }
        }

        public static void UpdateQueue(Idt_agvtaskRepository agvtaskService, dt_agvtask agvtask)
        {
            VOLContext Context = new VOLContext();
            Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context);
            IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(Context);
            try
            {
                if (agvtask.agv_tasktype == AGVTaskTypeEnum.TaskType_EmptyPallet.ToString())//空托任务
                {
                    if (agvtask.agv_fromaddress == "" && DateTime.Now - agvtask.agv_createtime >= TimeSpan.FromMinutes(2))
                    {
                        if (task.agv_tasktype == "TaskType_EmptyPallet")//空托任务
                        if (agvtask.agv_tasknum.Contains("_"))
                        {
                            if (task.agv_fromaddress == "" && DateTime.Now - task.agv_createtime >= TimeSpan.FromMinutes(2))
                            {
                                if (task.agv_tasknum.Contains("_"))
                                {
                                    string mainTaskNum = task.agv_tasknum.Split('_')[0];
                                    if (agvtaskService.Find(x => x.agv_tasknum == mainTaskNum && task.agv_taskstate != "Executing" && task.agv_taskstate != "Create").Any() || !agvtaskService.Find(x => x.agv_tasknum == mainTaskNum).Any())
                                        GetStation.EmptyPalletStation(task);
                                }
                                else
                                    GetStation.EmptyPalletStation(task);
                            string mainTaskNum = agvtask.agv_tasknum.Split('_')[0];
                            if (agvtaskService.Find(x => x.agv_tasknum == mainTaskNum && agvtask.agv_taskstate != AGVTaskStateEnum.Executing.ToString() && agvtask.agv_taskstate != AGVTaskStateEnum.Create.ToString()).Any() || !agvtaskService.Find(x => x.agv_tasknum == mainTaskNum).Any())
                                GetStation.EmptyPalletStation(agvtask);
                        }
                        else
                            GetStation.EmptyPalletStation(agvtask);

                                WriteDBLog.Success("更新空托队列任务", $"任务编号：{task.agv_tasknum}", "PCS");
                                continue;
                            }
                        }
                        else if (task.agv_tasktype == "TaskType_OutsourceInbound" || task.agv_tasktype == "TaskType_Inbound")//外协库入库/AB库入库
                        WriteDBLog.Success("更新空托队列任务", $"任务编号：{agvtask.agv_tasknum}", "PCS");
                    }
                }
                else if (agvtask.agv_tasktype == AGVTaskTypeEnum.TaskType_OutsourceInbound.ToString() || agvtask.agv_tasktype == AGVTaskTypeEnum.TaskType_Inbound.ToString())//外协库入库/AB库入库
                {
                    if (agvtask.agv_toaddress == "")
                    {
                        var stationinfo = stationinfoRepository.Find(x => x.stationCode == agvtask.agv_fromaddress).FirstOrDefault();
                        var work = workinfoRepository.Find(x => x.workOrder == stationinfo.Number && x.drawingNo == stationinfo.stationType && x.heatID == stationinfo.heatNumber && x.processCode == "17").FirstOrDefault();
                        var TargetLocation = agvtask.agv_tasktype == AGVTaskTypeEnum.TaskType_Inbound.ToString() ? GetLocation.GetEmptyLocation(stationinfoRepository, work, agvtask) : StationTask.GetEmptyLocation(stationinfoRepository);
                        if (TargetLocation != null)
                        {
                            if (task.agv_toaddress == "")
                            if (!agvtaskService.Find(x => x.agv_toaddress == TargetLocation.stationCode).Any())
                            {
                                var stationinfo = stationinfoRepository.Find(x => x.stationCode == task.agv_fromaddress).FirstOrDefault();
                                var work = workinfoRepository.Find(x => x.workOrder == stationinfo.Number && x.drawingNo == stationinfo.stationType && x.heatID == stationinfo.heatNumber && x.processCode == "17").FirstOrDefault();
                                var TargetLocation = task.agv_tasktype == "TaskType_Inbound" ? GetLocation.GetEmptyLocation(stationinfoRepository, work, task) : StationTask.GetEmptyLocation(stationinfoRepository);
                                if (TargetLocation != null)
                                {
                                    if (agvtaskService.Find(x => x.agv_toaddress == TargetLocation.stationCode).Any()) continue;
                                    task.agv_taskstate = "Create";
                                    task.agv_toaddress = TargetLocation.stationCode;
                                    TargetLocation.location_state = LocationStateEnum.InBusy.ToString();
                                    TargetLocation.billetID = stationinfo.billetID;
                                    TargetLocation.stationType = task.agv_materielid;
                                    TargetLocation.heatNumber = stationinfo.heatNumber;
                                    TargetLocation.Number = task.jobID;
                                    stationinfoRepository.Update(TargetLocation, true);
                                    agvtaskService.Update(task, true);
                                    WriteDBLog.Success("更新入库队列任务", $"任务编号：{task.agv_tasknum}", "PCS");
                                    continue;
                                }
                            }
                        }
                        else if (task.agv_tasktype == "TaskType_OutsourceOutbound" || task.agv_tasktype == "TaskType_Outbound")//外协库出库/AB库出库
                        {
                            if (task.agv_toaddress == "")
                            {
                                var EmptyStations = stationinfoRepository.Find(x => x.stationCode.Contains("S01001") && (x.tray_status == "EmptyTray" || x.location_state == "Empty") && x.enable).ToList();
                                foreach (var EmptyStation in EmptyStations)
                                {
                                    if (agvtaskService.Find(x => x.agv_toaddress == EmptyStation.stationCode).Any()) continue;
                                    task.agv_taskstate = "Create";
                                    task.agv_toaddress = EmptyStation.stationCode;
                                    EmptyStation.location_state = LocationStateEnum.Busy.ToString();
                                    stationinfoRepository.Update(EmptyStation, true);
                                    agvtaskService.Update(task, true);
                                    WriteDBLog.Success("更新出库队列任务", $"任务编号：{task.agv_tasknum}", "PCS");
                                    return;
                                }
                            }
                        }
                        else if (task.agv_tasktype == "TaskType_OutsourceCarry")//移库外协
                        {
                            if (task.agv_toaddress == "")
                            {
                                var TargetLocation = StationTask.GetEmptyLocation(stationinfoRepository);
                                if (TargetLocation != null)
                                {
                                    if (agvtaskService.Find(x => x.agv_toaddress == TargetLocation.stationCode).Any()) continue;

                                    task.agv_taskstate = "Create";
                                    task.agv_toaddress = TargetLocation.stationCode;
                                    TargetLocation.location_state = LocationStateEnum.OutBusy.ToString();
                                    TargetLocation.stationType = task.agv_materielid;
                                    stationinfoRepository.Update(TargetLocation, true);
                                    agvtaskService.Update(task, true);
                                    WriteDBLog.Success("更新移库外协队列任务", $"任务编号：{task.agv_tasknum}", "PCS");
                                    continue;
                                }
                                agvtask.agv_taskstate = AGVTaskStateEnum.Create.ToString();
                                agvtask.agv_toaddress = TargetLocation.stationCode;
                                TargetLocation.location_state = LocationStateEnum.InBusy.ToString();
                                TargetLocation.billetID = stationinfo.billetID;
                                TargetLocation.stationType = agvtask.agv_materielid;
                                TargetLocation.heatNumber = stationinfo.heatNumber;
                                TargetLocation.Number = agvtask.jobID;
                                stationinfoRepository.Update(TargetLocation, true);
                                agvtaskService.Update(agvtask, true);
                                WriteDBLog.Success("更新入库队列任务", $"任务编号：{agvtask.agv_tasknum}", "PCS");
                            }
                        }
                    }
                    catch (Exception ex)
                }
                else if (agvtask.agv_tasktype == AGVTaskTypeEnum.TaskType_OutsourceOutbound.ToString() || agvtask.agv_tasktype == AGVTaskTypeEnum.TaskType_Outbound.ToString())//外协库出库/AB库出库
                {
                    if (agvtask.agv_toaddress == "")
                    {
                        //WriteDBLog.Error("更新队列任务", $"错误信息：{ex.Message}", "PCS");
                        WriteLog.Write_Log("更新队列任务","更新失败", "", $"错误信息：{ex.Message}");
                        var EmptyStations = stationinfoRepository.Find(x => x.stationCode.Contains("S01001") && (x.tray_status == TrayStateEnum.EmptyTray.ToString() || x.location_state == LocationStateEnum.Empty.ToString()) && x.enable).ToList();
                        foreach (var EmptyStation in EmptyStations)
                        {
                            if (agvtaskService.Find(x => x.agv_toaddress == EmptyStation.stationCode).Any()) continue;
                            agvtask.agv_taskstate = AGVTaskStateEnum.Create.ToString();
                            agvtask.agv_toaddress = EmptyStation.stationCode;
                            EmptyStation.location_state = LocationStateEnum.Busy.ToString();
                            stationinfoRepository.Update(EmptyStation, true);
                            agvtaskService.Update(agvtask, true);
                            WriteDBLog.Success("更新出库队列任务", $"任务编号：{agvtask.agv_tasknum}", "PCS");
                            return;
                        }
                    }
                }
                else if (agvtask.agv_tasktype == AGVTaskTypeEnum.TaskType_OutsourceCarry.ToString())//移库外协
                {
                    if (agvtask.agv_toaddress == "")
                    {
                        var TargetLocation = StationTask.GetEmptyLocation(stationinfoRepository);
                        if (TargetLocation != null)
                        {
                            if (!agvtaskService.Find(x => x.agv_toaddress == TargetLocation.stationCode).Any())
                            {
                                agvtask.agv_taskstate = AGVTaskStateEnum.Create.ToString();
                                agvtask.agv_toaddress = TargetLocation.stationCode;
                                TargetLocation.location_state = LocationStateEnum.OutBusy.ToString();
                                TargetLocation.stationType = agvtask.agv_materielid;
                                stationinfoRepository.Update(TargetLocation, true);
                                agvtaskService.Update(agvtask, true);
                                WriteDBLog.Success("更新移库外协队列任务", $"任务编号：{agvtask.agv_tasknum}", "PCS");
                            }
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                WriteDBLog.Error("更新队列任务", $"错误信息：{ex.Message}", "PCS");
                WriteLog.Write_Log("更新队列任务", "更新失败", "", $"错误信息：{ex.Message}");
            }
        }
    }