WcsFramework/WCS.WorkEngineering/Systems/NoInteractionSystems.cs

using PlcSiemens.Core.Extension;
using ServiceCenter.Logs;
using ServiceCenter.Redis;
using ServiceCenter.SqlSugars;
using System.ComponentModel;
using WCS.Core;
using WCS.Entity;
using WCS.WorkEngineering.Extensions;
using WCS.WorkEngineering.WebApi.Controllers;
using WCS.WorkEngineering.WebApi.Models.AGV.Response;
using WCS.WorkEngineering.Worlds;

namespace WCS.WorkEngineering.Systems
{
    /// <summary>
    ///  无交互系统
    /// </summary>
    [BelongTo(typeof(NoInteractionWorld))]
    [Description("无交互系统")]
    public class NoInteractionSystems : DeviceSystem<Station>
    {
        public NoInteractionSystems()
        {
        }

        protected override bool ParallelDo => true;

        protected override bool SaveLogsToFile => true;

        public override void Do(Station obj)
        {
            var key = $"WCS:Lock:无交互系统{obj.Entity.Code}";
            try
            {
                if (RedisHub.Default.Get(key) != null)
                {
                    throw new KnownException($"[{obj.Entity.Code}]--触发并发管控", LogLevelEnum.High);
                }
                RedisHub.Default.Set(key, obj.Entity.Code);

                #region 处理所有的新增任务

                try
                {
                    List<WCS_TaskInfo> taskInfos = new List<WCS_TaskInfo>();
                    SqlSugarHelper.Do(db =>
                    {
                        taskInfos = db.Default.Queryable<WCS_TaskInfo>().Where(t => t.Status == Entity.TaskStatus.NewBuild).ToList();
                    });
                    if (taskInfos.Any())
                    {
                        foreach (var item in taskInfos)
                        {
                            try
                            {
                                SqlSugarHelper.Do(db =>
                                {
                                    var task = db.Default.Queryable<WCS_TaskInfo>().Where(t => t.ID == item.ID).First() ?? throw new Exception($"未找到对应的WCS任务[{item.ID}]");
                                    if (task.Type == TaskType.EnterDepot)
                                    {
                                        //创建AGV任务
                                        var agvTask = new WCS_AgvTaskInfo()
                                        {
                                            ID = db.GetAGVTaskId(),
                                            TaskType = AGVTaskType.EnterDepot,
                                            Status = AGVTaskStatus.NewBuild,
                                            Station = task.WorkBench,
                                            AddWho = "WCS",
                                            //Position = task.SrmStation
                                        };
                                        if (task.Floor == 2)
                                        {
                                            //task.Tunnel = "3";
                                            task.Tunnel = "";
                                            task.Device = "SRM3";
                                            task.SrmStation = "1025";
                                        }
                                        db.Default.Insertable(agvTask).SplitTable().ExecuteCommand();
                                        //更新任务状态
                                        task.Status = Entity.TaskStatus.WaitingToExecute;
                                        task.AgvTaskID = agvTask.ID;
                                        db.Default.Updateable(task).ExecuteCommand();
                                        task.AddWCS_TASK_DTL(db, task.Device, $"初始化入库任务信息,并创建AGV任务中间表,AGV任务目标地址:{agvTask.Position}");
                                    }
                                    else if (task.Type == TaskType.OutDepot)
                                    {
                                        #region 二楼非半自动手动出库任务需要创建AGV任务

                                        if (task.Floor == 2 && task.OutType != OutTypeEnum.半自动手动出库任务)
                                        {
                                            //创建AGV任务
                                            var agvTask = new WCS_AgvTaskInfo()
                                            {
                                                ID = db.GetAGVTaskId(),
                                                TaskType = AGVTaskType.CallMaterial,
                                                Status = AGVTaskStatus.NewBuild,
                                                Station = task.WorkBench,
                                                AddWho = "WCS"
                                            };
                                            db.Default.Insertable(agvTask).SplitTable().ExecuteCommand();
                                            task.AgvTaskID = agvTask.ID;
                                        }
                                        else if (task.Floor == 1 && task.BusType == "一楼出满轮")
                                        {
                                            //创建AGV任务
                                            var agvTask = new WCS_AgvTaskInfo()
                                            {
                                                ID = db.GetAGVTaskId(),
                                                TaskType = AGVTaskType.CallMaterial,
                                                Status = AGVTaskStatus.NewBuild,
                                                Station = task.SrmStation,
                                                Position = task.AddrTo,
                                                WorkShop = 111,
                                                AddWho = "WCS"
                                            };
                                            db.Default.Insertable(agvTask).SplitTable().ExecuteCommand();
                                            task.AgvTaskID = agvTask.ID;
                                        }
                                        else if (task.BusType == "一楼立库出空轮")
                                        {
                                            //创建AGV任务
                                            var agvTask = new WCS_AgvTaskInfo()
                                            {
                                                ID = db.GetAGVTaskId(),
                                                TaskType = AGVTaskType.CallForMaterial,
                                                Status = AGVTaskStatus.NewBuild,
                                                Station = task.SrmStation,
                                                Position = task.AddrTo,
                                                AddWho = "WCS"
                                            };
                                            db.Default.Insertable(agvTask).SplitTable().ExecuteCommand();
                                            task.AgvTaskID = agvTask.ID;
                                        }

                                        #endregion 二楼非半自动手动出库任务需要创建AGV任务

                                        if (task.SrmStation.IsNullOrEmpty()) //如果没有指定放货站台
                                        {
                                            //获取堆垛机到目标地址的路径信息
                                            var path = DevicePath.GetPath(task.Device, task.AddrTo);
                                            task.SrmStation = path.Points[1].Code;
                                        }
                                        //更新任务状态
                                        task.Status = Entity.TaskStatus.WaitingToExecute;
                                        db.Default.Updateable(task).ExecuteCommand();
                                        task.AddWCS_TASK_DTL(db, task.Device, $"初始化出库任务信息,放货站台:{task.SrmStation}");
                                    }
                                    else if (task.Type == TaskType.Delivery) //一楼叉车搬运任务
                                    {
                                        var agv = new WCS_AgvTaskInfo()
                                        {
                                            ID = db.GetAGVTaskId(),
                                            TaskType = AGVTaskType.ForkliftFilling,
                                            Status = AGVTaskStatus.NewBuild,
                                            Station = task.WorkBench,
                                            AddWho = "WCS"
                                        };
                                        db.Default.Insertable(agv).SplitTable().ExecuteCommand();
                                        //更新WCS数据
                                        task.Status = Entity.TaskStatus.WaitingToExecute;
                                        task.AgvTaskID = agv.ID;
                                        db.Default.Updateable(task).ExecuteCommand();
                                        task.AddWCS_TASK_DTL(db, task.Device, $"初始化搬运任务信息,并创建AGV任务");
                                    }
                                    else if (task.Type == TaskType.EmptyInit)
                                    {
                                        //更新任务状态
                                        task.Status = Entity.TaskStatus.WaitingToExecute;
                                        db.Default.Updateable(task).ExecuteCommand();
                                        task.AddWCS_TASK_DTL(db, task.Device, $"初始化任务信息");
                                    }
                                });
                            }
                            catch (Exception ex)
                            {
                                World.Log(ex.Message, LogLevelEnum.Mid);
                                continue;
                            }
                        }
                    }
                }
                catch (Exception ex)
                {
                    World.Log(ex.Message, LogLevelEnum.Mid);
                }

                #endregion 处理所有的新增任务

                #region 下发入库AGV任务

                List<WCS_AgvTaskInfo> agvTaskInfos = new List<WCS_AgvTaskInfo>();

                SqlSugarHelper.Do(db =>
                {
                    agvTaskInfos = db.Default.Queryable<WCS_AgvTaskInfo>().Where(t => t.Status == AGVTaskStatus.NewBuild && t.TaskType == AGVTaskType.EnterDepot).SplitTable(v => v.Take(2)).ToList();
                });

                if (agvTaskInfos.Any())
                {
                    foreach (var item in agvTaskInfos)
                    {
                        try
                        {
                            SqlSugarHelper.Do(db =>
                            {
                                string barCode = "";
                                var agv = db.Default.Queryable<WCS_AgvTaskInfo>().Where(t => t.ID == item.ID).SplitTable(v => v.Take(2)).First() ?? throw new Exception($"未找到对应的AGV任务:{item.ID}");
                                //获取对应wcs任务
                                var wcs = db.Default.Queryable<WCS_TaskInfo>().Where(t => t.AgvTaskID == agv.ID && t.Status == Entity.TaskStatus.WaitingToExecute).First() ?? throw new Exception($"AGV任务[{item.ID}]未找到对应的WCS任务");
                                switch (wcs.Floor)
                                {
                                    case 1: //一楼下发AGV任务
                                        var res = AgvApi.满轮入库(wcs.BarCode, agv.Station, Guid.NewGuid().ToString().Replace("-", ""), "1");
                                        agv.Status = AGVTaskStatus.Confirm;
                                        agv.AgvID = res.data;
                                        if (agv.Station.StartsWith("HA") && !(agv.Station.Contains("HA01") || agv.Station.Contains("HA02") || agv.Station.Contains("HA03") || agv.Station.Contains("HA04") || agv.Station.Contains("HA05")))
                                        {
                                            agv.WorkShop = 1138;
                                        }
                                        db.Default.Updateable(agv).SplitTable(x => x.Take(2)).ExecuteCommand();
                                        break;

                                    case 2:
                                        barCode = wcs.BarCode;
                                        if (!string.IsNullOrEmpty(wcs.BarCode) && wcs.BarCode.Contains("-"))
                                        {
                                            barCode = wcs.BarCode.Substring(0, wcs.BarCode.IndexOf("-"));
                                        }
                                        var agvRes = IwmsApi.空轮回库(wcs.MatCode, wcs.SrmStation, wcs.IsSurplus, wcs.IsRework, agv.ID, barCode, wcs.AddWho);
                                        agv.Status = AGVTaskStatus.Confirm;
                                        agv.AgvID = agvRes.data;
                                        db.Default.Updateable(agv).SplitTable(x => x.Take(2)).ExecuteCommand();
                                        break;

                                    default:
                                        break;
                                }

                                //更新WCS数据
                                wcs.Status = Entity.TaskStatus.AGVExecution;
                                db.Default.Updateable(wcs).ExecuteCommand();
                                wcs.AddWCS_TASK_DTL(db, wcs.Device, $"任务下发至AGV-AGV任务ID{agv.AgvID}");
                            });
                        }
                        catch (Exception ex)
                        {
                            World.Log(ex.Message, LogLevelEnum.Mid);
                            continue;
                        }
                    }
                }

                #endregion 下发入库AGV任务

                #region 一楼叉车补空任务处理

                List<WCS_AgvTaskInfo> agvTaskInfos1 = new List<WCS_AgvTaskInfo>();

                SqlSugarHelper.Do(db =>
                {
                    agvTaskInfos1 = db.Default.Queryable<WCS_AgvTaskInfo>().Where(t => t.Status == AGVTaskStatus.NewBuild && t.TaskType == AGVTaskType.ForkliftFilling).SplitTable(v => v.Take(2)).ToList();
                });

                if (agvTaskInfos1.Any())
                {
                    agvTaskInfos1 = agvTaskInfos1.GroupBy(GetLineNo).Select(x => x.OrderBy(a => a.AddTime).First()).ToList();
                    foreach (var item in agvTaskInfos1)
                    {
                        try
                        {
                            GenAgvSchedulingTaskResponse res = new GenAgvSchedulingTaskResponse();
                            SqlSugarHelper.Do(db =>
                            {
                                var agv = db.Default.Queryable<WCS_AgvTaskInfo>().Where(t => t.ID == item.ID).SplitTable(v => v.Take(2)).First() ?? throw new Exception($"未找到对应的AGV任务:{item.ID}");
                                //获取对应wcs任务
                                var wcs = db.Default.Queryable<WCS_TaskInfo>().Where(t => t.AgvTaskID == agv.ID && t.Status == Entity.TaskStatus.WaitingToExecute).First() ?? throw new Exception($"AGV任务[{item.ID}]未找到对应的WCS任务");
                                //下发AGV任务
                                res = AgvApi.机台补空(agv.Station, Guid.NewGuid().ToString().Replace("-", ""), "1");
                                agv.Status = AGVTaskStatus.Confirm;
                                agv.AgvID = res.data;
                                db.Default.Updateable(agv).SplitTable(x => x.Take(2)).ExecuteCommand();

                                wcs.Status = Entity.TaskStatus.AGVExecution;
                                db.Default.Updateable(wcs).ExecuteCommand();
                                wcs.AddWCS_TASK_DTL(db, wcs.Device, $"任务下发至AGV,AGV任务号:{res.data}");
                            });
                        }
                        catch (Exception ex)
                        {
                            World.Log(ex.Message, LogLevelEnum.Mid);
                            continue;
                        }
                    }
                }

                #endregion 一楼叉车补空任务处理
            }
            finally
            {
                RedisHub.Default.Del(key);
            }
        }

        public override bool Select(Device dev)
        {
            return dev.Code == "1011";
        }

        public static List<LineNo> LineNoS = new List<LineNo>();

        /// <summary>
        ///  获取线体号
        /// </summary>
        /// <param name="agv"></param>
        /// <returns></returns>
        public int GetLineNo(WCS_AgvTaskInfo agv)
        {
            //TODO:需确定Station是否在叉车补空任务中对应产线站点
            if (LineNoS.Count==0)
            {
                LineNoS.Add(new LineNo { Line = 1, Max = 156, Min = 129, Station = new List<string> { "HA0129_1", "HA0129_2", "HA0129_3", "HA0156_1" } });
                LineNoS.Add(new LineNo { Line = 2, Max = 128, Min = 101, Station = new List<string> { "HA0128_1", "HA0128_2", "HA0128_3", "HA0101_1" } });
                LineNoS.Add(new LineNo { Line = 2, Max = 228, Min = 201, Station = new List<string> { "HA0228_1", "HA0228_2", "HA0228_3", "HA0201_1" } });
                LineNoS.Add(new LineNo { Line = 3, Max = 256, Min = 229, Station = new List<string> { "HA0229_1", "HA0229_2", "HA0229_3", "HA0256_1" } });
                LineNoS.Add(new LineNo { Line = 4, Max = 356, Min = 329, Station = new List<string> { "HA0329_1", "HA0329_2", "HA0329_3", "HA0356_1" } });
                LineNoS.Add(new LineNo { Line = 5, Max = 328, Min = 301, Station = new List<string> { "HA0301_1", "HA0328_1", "HA0328_2", "HA0328_3" } });
                LineNoS.Add(new LineNo { Line = 5, Max = 428, Min = 401, Station = new List<string> { "HA0401_1", "HA0428_1", "HA0428_2", "HA0428_3" } });
                LineNoS.Add(new LineNo { Line = 6, Max = 456, Min = 429, Station = new List<string> { "HA0429_1", "HA0429_2", "HA0429_3", "HA0456_1" } });
                LineNoS.Add(new LineNo { Line = 7, Max = 564, Min = 533, Station = new List<string> { "HA0533_1", "HA0533_2", "HA0533_3", "HA0564_1" } });
                LineNoS.Add(new LineNo { Line = 8, Max = 532, Min = 501, Station = new List<string> { "HA0501_1", "HA0532_1", "HA0532_2", "HA0532_3" } });
                LineNoS.Add(new LineNo { Line = 8, Max = 632, Min = 601, Station = new List<string> { "HA0632_1", "HA0632_2", "HA0632_3", "HA0601_1" } });
                LineNoS.Add(new LineNo { Line = 9, Max = 664, Min = 633, Station = new List<string> { "HA0633_1", "HA0633_1", "HA0633_2", "HA0664_1" } });
                LineNoS.Add(new LineNo { Line = 10, Max = 764, Min = 733, Station = new List<string> { "HA0733_1", "HA0733_2", "HA0733_3", "HA0764_1" } });
                LineNoS.Add(new LineNo { Line = 11, Max = 732, Min = 701, Station = new List<string> { "HA0701_1", "HA0732_1", "HA0732_2", "HA0732_3" } });
                LineNoS.Add(new LineNo { Line = 11, Max = 832, Min = 801, Station = new List<string> { "HA0801_1", "HA0832_1", "HA0832_2", "HA0832_3" } });
                LineNoS.Add(new LineNo { Line = 12, Max = 864, Min = 833, Station = new List<string> { "HA0833_1", "HA0833_2", "HA0833_3", "HA0864_1" } });
                LineNoS.Add(new LineNo { Line = 13, Max = 964, Min = 933, Station = new List<string> { "HA0933_1", "HA0933_2", "HA1332_3", "HA0964_1" } });
                LineNoS.Add(new LineNo { Line = 14, Max = 932, Min = 901, Station = new List<string> { "HA0932_1", "HA0932_2", "HA0932_3", "HA0901_1" } });
                LineNoS.Add(new LineNo { Line = 14, Max = 1032, Min = 1011, Station = new List<string> { "HA1001_1", "HA1032_1", "HA1032_2", "HA1032_3" } });
                LineNoS.Add(new LineNo { Line = 15, Max = 1064, Min = 1033, Station = new List<string> { "HA1033_1", "HA1033_2", "HA1033_3", "HA1064_1" } });
                LineNoS.Add(new LineNo { Line = 16, Max = 1164, Min = 1633, Station = new List<string> { "HA1133_1", "HA1133_2", "HA1133_3", "HA1164_1" } });
                LineNoS.Add(new LineNo { Line = 17, Max = 1132, Min = 1101, Station = new List<string> { "HA1132_1", "HA1132_2", "HA1132_3", "HA1101_1" } });
            }

            return (from item in LineNoS let no = agv.Station.Substring(2, 4).ToInt() where item.Station.Contains(agv.Station) || (no <= item.Max && no >= item.Min) select item.Line).FirstOrDefault();
        }
    }

    public class LineNo
    {
        public int Line { get; set; }

        public List<string> Station { get; set; }

        public int Max { get; set; }

        public int Min { get; set; }
    }
}