WcsFramework/WCS.WorkEngineering/Systems/一楼叠盘机入库.cs

using ServiceCenter.Logs;
using ServiceCenter.SqlSugars;
using System.ComponentModel;
using WCS.Core;
using WCS.Entity;
using WCS.WorkEngineering.Extensions;
using WCS.WorkEngineering.Protocol.BCR;
using WCS.WorkEngineering.Protocol.Station;
using WCS.WorkEngineering.WebApi.Controllers;
using WCS.WorkEngineering.WebApi.Models.WMS.Request;
using WCS.WorkEngineering.Worlds;

namespace WCS.WorkEngineering.Systems
{
    /// <summary>
    ///  一楼叠盘机入库
    /// </summary>
    [BelongTo(typeof(MainWorld))]
    [Description("一楼叠盘机入库")]
    public class 一楼叠盘机入库 : DeviceSystem<Device<IStation520, IStation521, IStation523, IStation91, IBCR81>>
    {
        protected override bool ParallelDo => true;

        protected override bool SaveLogsToFile => true;

        public override void Do(Device<IStation520, IStation521, IStation523, IStation91, IBCR81> obj)
        {
            obj.入库站点是否被禁止();
            obj.入库站点是否满足执行条件();

            WCS_TaskInfo task = null;//处理完成的任务
            try
            {
                var device = "";
                var barcode = "";

                switch (obj.Entity.Code)
                {
                    case "2527":
                        device = "SRM1";
                        barcode = "TPA";
                        break;

                    case "2528":
                        device = "SRM1";
                        barcode = "TPA";
                        break;

                    case "2727":
                        device = "SRM2";
                        barcode = "TPA";
                        break;

                    case "2728":
                        device = "SRM2";
                        barcode = "TPA";
                        break;
                };

                SqlSugarHelper.Do(_db =>
                {
                    var db = _db.Default;

                    //验证是否有对应的任务
                    if (!db.Queryable<WCS_TaskInfo>().Any(v => v.BarCode == barcode))
                    {
                        var res = WmsApi.OneFloorWorkerBuildEmptyPalletsStock(new OneFloorWorkerBuildEmptyPalletsStockRequest()
                        {
                            PalletCode = barcode,
                            StartLoc = obj.Entity.Code,
                            Height = 2
                        });
                        if (res.ResCode == WebApi.Models.WMS.Response.ResponseStatusCodeEnum.Sucess) return;
                    }
                    //找到对应的任务
                    task = db.Queryable<WCS_TaskInfo>().First(v => v.BarCode == barcode);
                    if (task.Status == Entity.TaskStatus.WaitingToExecute)
                    {
                        var tunnel = obj.Entity.Targets.Where(v => v.HasFlag(Extensions.DeviceFlags.巷道)).FirstOrDefault();
                        //开始对任务进行处理
                        task.Status = Entity.TaskStatus.ConveyorExecution;
                        task.StartTime = DateTime.Now;
                        task.SrmStation = task.AddrFrom;
                        task.LastInteractionPoint = obj.Entity.Code;
                        task.Tunnel = tunnel.Code;
                        task.Height = 2;

                        task.AddWCS_TASK_DTL(_db, obj.Entity.Code, "开始执行入库任务");
                        db.Updateable(task).ExecuteCommand();
                        task.updateRedisHash();
                    }
                    else return;
                });
            }
            catch (Exception ex)
            {
                throw new KnownException(ex.Message, LogLevelEnum.High);
            }
            if (task == null) return;

            World.Log($"任务处理:开始-DB520[{obj.Data.TaskNumber}]-[{obj.Data.VoucherNo}]-DB521[{obj.Data2.TaskNumber}]-[{obj.Data2.VoucherNo}]");
            obj.Data.TaskNumber = task.ID;
            obj.Data.VoucherNo++;
            World.Log($"任务处理:结束-DB520[{obj.Data.TaskNumber}]-[{obj.Data.VoucherNo}]-DB521[{obj.Data2.TaskNumber}]-[{obj.Data2.VoucherNo}]");
        }

        public override bool Select(Device dev)
        {
            return dev.HasFlag(Extensions.DeviceFlags.一楼叠盘机);
        }
    }
}