using PlcSiemens.Core.Extension; using ServiceCenter.Extensions; using ServiceCenter.Logs; using ServiceCenter.SqlSugars; using System.ComponentModel; using WCS.Core; using WCS.Entity; using WCS.Entity.Protocol.BCR; using WCS.Entity.Protocol.Station; using WCS.WorkEngineering.Extensions; using WCS.WorkEngineering.WebApi.Controllers; using WCS.WorkEngineering.WebApi.Models.WMS.Request; using WCS.WorkEngineering.Worlds; using DeviceFlags = WCS.WorkEngineering.Extensions.DeviceFlags; namespace WCS.WorkEngineering.Systems { /// /// 一楼入库工位处理系统 /// [BelongTo(typeof(MainWorld))] [Description("一楼扫码入库")] public class 一楼扫码入库 : DeviceSystem> { protected override bool ParallelDo => true; protected override bool SaveLogsToFile => true; public override void Do(Device obj) { obj.入库站点是否被禁止(); obj.入库站点是否满足执行条件(); WCS_TaskInfo task = null;//处理完成的任务 try { //获取托盘条码 var barcode = obj.Data5.GetBCRCode(); if (barcode.IsNullOrWhiteSpace()) { World.Log("扫码失败,内容为空", LogLevelEnum.Mid); return; } SqlSugarHelper.Do(_db => { var db = _db.Default; //var barcode = "TAP00001"; //验证是否有对应的任务 if (!db.Queryable().Any(v => v.BarCode == barcode && v.Type == TaskType.EnterDepot)) { var palletType = PalletType.Pallet09; if (barcode.Contains("TPB")) palletType = PalletType.PalletNo09; var res = WmsApi.OneFloorWorkerBuildEmptyPalletsStock(new OneFloorWorkerBuildEmptyPalletsStockRequest() { PalletCode = barcode, StartLoc = obj.Entity.Code, PalletType = palletType, Height = 2 }); if (res.ResCode == WebApi.Models.WMS.Response.ResponseStatusCodeEnum.Sucess) return; } //找到对应的任务 var taskInfo = db.Queryable().First(v => v.BarCode == barcode && v.Type == TaskType.EnterDepot); if (taskInfo.Status == Entity.TaskStatus.WaitingToExecute) { var tunnel = obj.Entity.Targets.FirstOrDefault(v => v.HasFlag(DeviceFlags.巷道)); //开始对任务进行处理 taskInfo.Status = Entity.TaskStatus.ConveyorExecution; taskInfo.StartTime = DateTime.Now; taskInfo.SrmStation = taskInfo.AddrFrom; taskInfo.LastInteractionPoint = obj.Entity.Code; taskInfo.Tunnel = tunnel.Code; taskInfo.Height = 2; taskInfo.Device = obj.Entity.Code switch { "2532" => "SRM1", "2732" => "SRM2", "2932" => "SRM3", "3132" => "SRM4", "3332" => "SRM5", "3532" => "SRM6", _ => taskInfo.Device }; db.UpdateableRowLock(taskInfo).ExecuteCommand(); taskInfo.AddWCS_TASK_DTL(db, obj.Entity.Code, "开始执行入库任务"); task = taskInfo; } 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.Data2.Request}]"); 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.Code == "2532"; return dev.HasFlag(Extensions.DeviceFlags.一楼扫码); } } }