WcsFramework/YWGC/FJK/WCS.WorkEngineering/Systems/环形库码垛结束.cs

using NetTaste;
using ServiceCenter.Extensions;
using ServiceCenter.Logs;
using ServiceCenter.SqlSugars;
using SqlSugar;
using System.ComponentModel;
using WCS.Core;
using WCS.Entity;
using WCS.Entity.Protocol.Protocol.Robot;
using WCS.Entity.Protocol.Robot;
using WCS.Entity.Protocol.Station;
using WCS.WorkEngineering.Extensions;
using WCS.WorkEngineering.Model.WMS;
using WCS.WorkEngineering.WebApi.Controllers;
using WCS.WorkEngineering.Worlds;
using DeviceFlags = WCS.WorkEngineering.Extensions.DeviceFlags;
using TaskStatus = WCS.Entity.TaskStatus;

namespace WCS.WorkEngineering.Systems
{
    /// <summary>
    ///  环形库码垛结束
    /// </summary>
    [BelongTo(typeof(MainWorld))]
    [Description("环形库码垛结束")]
    public class 环形库码垛结束 : DeviceSystem<Device<IStation520, IStation521, IStation523, IRobot530, IRobot531>>
    {
        protected override bool ParallelDo => true;

        public override void Do(Device<IStation520, IStation521, IStation523, IRobot530, IRobot531> obj)
        {
            var isForcedEnding = false;
            SqlSugarHelper.Do(_db =>
            {
                var db = _db.Default;             
                var code = $"ForcedEndStation{obj.Entity.Code}";
                var isForcedEnd = db.Queryable<fjSysConfig>().NoLock().First(x => x.Code == code);
                if (isForcedEnd != null && isForcedEnd.SContent.ToShort() == 1)
                {
                    isForcedEnding = true;
                }
            });
            //强制结束不再判断机械臂是否给结束信号
            if ((!obj.Data5.CmdType.HasFlag(RobotCmdType.End)) && obj.Data4.CmdType != 0) obj.Data4.CmdType = 0;
            if (!obj.Data3.Status.HasFlag(StationStatus.PH_Status)) return;
            if (!obj.Data5.CmdType.HasFlag(RobotCmdType.End) && !isForcedEnding) return;
            if ((obj.Data5.MaxQuantity != obj.Data5.Quantity || obj.Data5.Quantity == 0 || obj.Data5.MaxQuantity == 0)&& !isForcedEnding) throw new KnownException($"码垛数量异常:最大码垛数量[{obj.Data5.MaxQuantity}]已码数量{obj.Data5.Quantity}", LogLevelEnum.High);
            WCS_TaskInfo task = null;

            
            //找到对应的码垛数据
            SqlSugarHelper.Do(_db =>
            {
                var db = _db.Default;
                var taskNoList = obj.Data5.GetTaskNoList().ToList();
                var tasks = db.Queryable<WCS_TaskInfo>().RowLock().Where(x => taskNoList.Contains(x.ID) && x.Status == TaskStatus.ConveyorExecution).ToList();
              
                if (tasks.Count() > 0 && tasks.Count() != obj.Data5.MaxQuantity && !isForcedEnding)
                {
                    World.Log($"任务数量{tasks.Count()}-最大码垛数量{obj.Data5.MaxQuantity}");
                    return;
                }

                //获取id值用于直接码垛判断
                var taskGroup = tasks.First().Type == TaskType.SetPlate ? tasks.First().TaskGroupKey : "";                
                var deliveryTask = db.Queryable<WCS_TaskInfo>().RowLock().Single(x => x.Type == TaskType.Delivery && x.AddrTo == obj.Entity.Code && x.Status >= TaskStatus.RgvExecution && x.Status < TaskStatus.Finish) ?? throw new KnownException($"未找到当前站台对应的托盘搬运任务", LogLevelEnum.High);
                var taskInfo = db.Queryable<WCS_TaskInfo>().RowLock().Single(x => x.Status == TaskStatus.WaitingToExecute && x.AddrFrom == obj.Entity.Code && x.Type == TaskType.EnterDepot);
                if (deliveryTask.Status != TaskStatus.RgvCompleted) throw new KnownException($"搬运任务状态异常:{deliveryTask.ID}", LogLevelEnum.High);
                if (taskInfo == null)
                {
                    var task = db.Queryable<WCS_TaskInfo>().NoLock().Single(x => x.Status <= TaskStatus.RgvExecution && x.AddrFrom == obj.Entity.Code && x.Type == TaskType.EnterDepot);
                    
                    if (task != null)
                    {
                        World.Log($"环线库码垛工位[{obj.Entity.Code}]存在状态为[{task.Status.GetDescription()}]的任务，任务号是[{task.ID}].请找到此任务确认并进行处理");
                        return;
                    }
                    //开始获取当前位置的空托盘搬运任务信息
                    var cbrCode = db.Queryable<WCS_TaskInfo>().First(x => x.Status == TaskStatus.RgvCompleted && x.AddrTo == obj.Entity.Code);
                    try
                    {
                        //开始绑盘
                        var res = WmsApi.FinishBingPallet(cbrCode.BarCode, tasks.Select(x => x.BarCode).ToList(), obj.Entity.Code.GetWareCode(), obj.Entity.Code, obj.Entity.Parent.Code);
                        if (!string.IsNullOrEmpty(taskGroup) && res.ResCode == WebApi.Models.WMS.Response.ResponseStatusCodeEnum.Sucess)
                        {
                            var ringPallet = db.Queryable<BillRingPalletizingInfo>().First(x => x.Id.ToString() == taskGroup && x.Out == false);
                            if (ringPallet != null)
                            { 
                                ringPallet.Out = true;
                                db.UpdateableRowLock(ringPallet).UpdateColumns(x => new { x.Out }).ExecuteCommand();
                            }
                            //UpdateScontent(db, obj.Entity.Code);

                            //foreach (var item in tasks)
                            //{
                            //    item.Status = TaskStatus.Finish;
                            //    item.EndTime = DateTime.Now;
                            //    db.UpdateableRowLock(item).UpdateColumns(x => new { x.Status, x.EndTime }).ExecuteCommand();
                            //    item.AddWCS_TASK_DTL(db, obj.Entity.Code, "任务结束");
                            //}
                            //deliveryTask.Status = TaskStatus.Finish;
                            //deliveryTask.EndTime = DateTime.Now;
                            //db.UpdateableRowLock(deliveryTask).UpdateColumns(x => new { x.Status, x.EndTime }).ExecuteCommand();
                            //deliveryTask.AddWCS_TASK_DTL(db, obj.Entity.Code, $"任务结束");
                            //var dev1 = DevicePath.GetPath(obj.Entity.Code, "SRM").Points.Last();
                            //taskInfo.Status = TaskStatus.ConveyorExecution;
                            //taskInfo.WarehouseCode = dev1.Code.GetWareCode();
                            //db.UpdateableRowLock(taskInfo).UpdateColumns(x => new { x.Status, x.WarehouseCode }).ExecuteCommand();
                            //taskInfo.AddWCS_TASK_DTL(db, obj.Entity.Code, $"更新任务对应仓库信息{taskInfo.WarehouseCode}");

                            //task = taskInfo;
                            //if (task == null) return;
                            //obj.Data.TaskNumber = task.ID;
                            //obj.Data.GoodsStart = obj.Entity.Code.ToShort();
                            //obj.Data.GoodsEnd = task.AddrNext.ToShort();
                            //obj.Data4.CmdType = RobotCmdType.End;
                        }                                               
                    }
                    catch (Exception e)
                    {
                        World.Log($"{e.Message}");
                        try
                        {
                            var res = WmsApi.BingPallet(cbrCode.BarCode, tasks.Select(x => x.BarCode).ToList(), obj.Entity.Code.GetWareCode(), obj.Entity.Code, obj.Entity.Parent.Code);
                            if (!string.IsNullOrEmpty(taskGroup) && res.ResCode == WebApi.Models.WMS.Response.ResponseStatusCodeEnum.Sucess)
                            {
                                var ringPallet = db.Queryable<BillRingPalletizingInfo>().First(x => x.Id.ToString() == taskGroup && x.Out == false);
                                if (ringPallet != null)
                                {
                                    ringPallet.Out = true;
                                    db.UpdateableRowLock(ringPallet).UpdateColumns(x => new { x.Out }).ExecuteCommand();
                                }
                                //UpdateScontent(db, obj.Entity.Code);

                                //foreach (var item in tasks)
                                //{
                                //    item.Status = TaskStatus.Finish;
                                //    item.EndTime = DateTime.Now;
                                //    db.UpdateableRowLock(item).UpdateColumns(x => new { x.Status, x.EndTime }).ExecuteCommand();
                                //    item.AddWCS_TASK_DTL(db, obj.Entity.Code, "任务结束");
                                //}
                                //deliveryTask.Status = TaskStatus.Finish;
                                //deliveryTask.EndTime = DateTime.Now;
                                //db.UpdateableRowLock(deliveryTask).UpdateColumns(x => new { x.Status, x.EndTime }).ExecuteCommand();
                                //deliveryTask.AddWCS_TASK_DTL(db, obj.Entity.Code, $"任务结束");
                                //var dev2 = DevicePath.GetPath(obj.Entity.Code, "SRM").Points.Last();
                                //taskInfo.Status = TaskStatus.ConveyorExecution;
                                //taskInfo.WarehouseCode = dev2.Code.GetWareCode();
                                //db.UpdateableRowLock(taskInfo).UpdateColumns(x => new { x.Status, x.WarehouseCode }).ExecuteCommand();
                                //taskInfo.AddWCS_TASK_DTL(db, obj.Entity.Code, $"更新任务对应仓库信息{taskInfo.WarehouseCode}");

                                //task = taskInfo;
                                //if (task == null) return;
                                //obj.Data.TaskNumber = task.ID;
                                //obj.Data.GoodsStart = obj.Entity.Code.ToShort();
                                //obj.Data.GoodsEnd = task.AddrNext.ToShort();
                                //obj.Data4.CmdType = RobotCmdType.End;
                            }                            
                        }
                        catch (Exception exception)
                        {
                            World.Log($"{exception.Message}");
                        }
                    }
                    return;
                }

                foreach (var item in tasks)
                {
                    item.Status = TaskStatus.Finish;
                    item.EndTime = DateTime.Now;
                    db.UpdateableRowLock(item).UpdateColumns(x => new { x.Status, x.EndTime }).ExecuteCommand();
                    item.AddWCS_TASK_DTL(db, obj.Entity.Code, "任务结束");
                }

                deliveryTask.Status = TaskStatus.Finish;
                deliveryTask.EndTime = DateTime.Now;
                db.UpdateableRowLock(deliveryTask).UpdateColumns(x => new { x.Status, x.EndTime }).ExecuteCommand();
                deliveryTask.AddWCS_TASK_DTL(db, obj.Entity.Code, $"任务结束");
                var dev = DevicePath.GetPath(obj.Entity.Code, "SRM").Points.Last();
                taskInfo.Status = TaskStatus.ConveyorExecution;
                taskInfo.WarehouseCode = dev.Code.GetWareCode();
                db.UpdateableRowLock(taskInfo).UpdateColumns(x => new { x.Status, x.WarehouseCode }).ExecuteCommand();
                taskInfo.AddWCS_TASK_DTL(db, obj.Entity.Code, $"更新任务对应仓库信息{taskInfo.WarehouseCode}");

                task = taskInfo;
            });
            if (task == null) return;
            obj.Data.TaskNumber = task.ID;
            obj.Data.GoodsStart = obj.Entity.Code.ToShort();
            obj.Data.GoodsEnd = task.AddrNext.ToShort();
            obj.Data4.CmdType = RobotCmdType.End;
        }

        public void UpdateScontent(SqlSugarScopeProvider db,string device)
        {
            var code = $"ForcedEndStation{device}";
            var isForcedEnd = db.Queryable<fjSysConfig>().NoLock().First(x => x.Code == code);
            if (isForcedEnd != null && isForcedEnd.SContent.ToShort() == 1)
            {
                isForcedEnd.SContent = "0";
                db.UpdateableRowLock(isForcedEnd).UpdateColumns(x => new { x.SContent }).ExecuteCommand();
            }
        }

        public override bool Select(Device dev)
        {
            return dev.HasFlag(DeviceFlags.环形库码垛工位);
        }
    }
}