成品库：库前出入库

成品库/WCS.WorkEngineering/Systems/堆垛机.cs

@@ -104,8 +104,15 @@ namespace WCS.WorkEngineering.Systems
                                 case OutTypeEnum.自动出库任务:
                                     task.Status = Entity.TaskStatus.Finish;
                                     var dev = new Station(Device.All.FirstOrDefault(v => v.Code == task.SrmStation), this.World);
-                                    dev.Data.TaskNumber = task.ID;
-                                    dev.Data.GoodsEnd = 8278;
+                                    if (task.AddrTo == "8271" || task.AddrTo == "8272" || task.AddrTo == "8273" || task.AddrTo == "8274" || task.AddrTo == "8275")
+                                    {
+                                        dev.Data.GoodsEnd = 8278;
+                                    }
+                                    else
+                                    {
+                                        dev.Data.GoodsEnd = task.AddrTo.ToShort();
+                                    }
+                                    dev.Data.TaskNumber = task.ID;                                   
                                     dev.Data.VoucherNo++;
                                     db.Default.Updateable(task).ExecuteCommand();
                                     task.AddWCS_TASK_DTL(db, task.SrmStation, "出库任务到达放货站台");
@@ -115,8 +122,15 @@ namespace WCS.WorkEngineering.Systems
                                 case OutTypeEnum.全自动手动出库任务:
                                     task.Status = Entity.TaskStatus.Finish;
                                     var dev1 = new Station(Device.All.FirstOrDefault(v => v.Code == task.SrmStation), this.World);
-                                    dev1.Data.TaskNumber = task.ID;
-                                    dev1.Data.GoodsEnd = 8278;
+                                    if (task.AddrTo == "8271" || task.AddrTo == "8272" || task.AddrTo == "8273" || task.AddrTo == "8274" || task.AddrTo == "8275")
+                                    {
+                                        dev1.Data.GoodsEnd = 8278;
+                                    }
+                                    else
+                                    {
+                                        dev1.Data.GoodsEnd = task.AddrTo.ToShort();
+                                    }
+                                    dev1.Data.TaskNumber = task.ID;                                    
                                     dev1.Data.VoucherNo++;
                                     db.Default.Updateable(task).ExecuteCommand();
                                     task.AddWCS_TASK_DTL(db, task.SrmStation, "手动出库任务到达放货站台");

成品库/WCS.WorkEngineering/Systems/成品入库.cs

@@ -0,0 +1,141 @@
+using ServiceCenter.Extensions;
+using ServiceCenter.Logs;
+using ServiceCenter.SqlSugars;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using WCS.Core;
+using WCS.Entity;
+using WCS.WorkEngineering.Extensions;
+using WCS.WorkEngineering.Protocol.BCR;
+using WCS.WorkEngineering.Protocol.SRM;
+using WCS.WorkEngineering.Protocol.Station;
+using WCS.WorkEngineering.WebApi.Controllers;
+using WCS.WorkEngineering.Worlds;
+using DeviceFlags = WCS.WorkEngineering.Extensions.DeviceFlags;
+
+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;
+        private List<Station> devs = new List<Station>();
+        private List<SRM> srms = new List<SRM>();
+        public 成品入库()
+        {
+            devs = Device.All.Where(v => v.HasFlag(DeviceFlags.入库)).Select(v => new Station(v, this.World)).ToList();
+            srms = Device.All.Where(v => v.HasProtocol(typeof(ISRM520))).Select(v => new SRM(v, this.World)).ToList();
+        }
+        public override void Do(Device<IStation520, IStation521, IStation523, IStation91, IBCR81> obj)
+        {
+            obj.入库站点是否被禁止();
+            obj.入库站点是否满足执行条件();
+            if (obj.Data2.Request != 1.ToShort()) throw new KnownException("无请求", LogLevelEnum.Mid);
+            if (!obj.Data3.Status.HasFlag(StationStatus.OT_Status) || !obj.Data3.Status.HasFlag(StationStatus.PH_Status)) throw new KnownException("无光电", LogLevelEnum.Mid);
+            string bcr = "";
+            //叠盘机托盘组入库
+            if (obj.Entity.Code == "")
+            {
+                if (obj.Data2.Request == 1)
+                {
+                    bcr = "TPC" + DateTime.Now.ToString("yyMMddHHmmss"); 
+                }               
+            }
+            else
+            {
+                //开始读取条码
+                bcr = obj.Data5.GetBCRCode();
+            }            
+            WCS_TaskInfo task = null;
+            SqlSugarHelper.Do(_db =>
+            {
+                var db = _db.Default;
+                //找到对应任务
+                var taskInfo = db.Queryable<WCS_TaskInfo>().First(x => x.BarCode == bcr);
+                //未找到对应任务
+                if (taskInfo == null)
+                {
+                    //向WMS申请入库任务
+                    var res = WmsApi.I_WCS_GetInTask(bcr, obj.Entity.Code);
+                    return;
+                }
+                //任务生成
+                if (taskInfo.Status == Entity.TaskStatus.WaitingToExecute)
+                {
+                    //开始获取堆垛机与可用站台信息
+                    var res = WmsApi.GetTunnelPriorityList(taskInfo.ID);
+                    if (res == null) throw new Exception($"未返回巷道");
+
+                    var tunnelNo = res.ResData.Split(",").Select(v => "SRM" + v).ToList();
+                    SRM srm = null;
+                    List<Station> stations = new List<Station>();
+                    //成品库库前堆垛机取货点
+                    stations = devs.Where(v => v.Entity.Code is "8001" or "8002" or "8003" or "8004" or "8005").ToList();
+                    //筛选出可用站台c
+                    stations = stations.Where(v => v.Data.VoucherNo == v.Data2.VoucherNo && v.Data3.Status.HasFlag(StationStatus.Auto))
+                                       .Where(v => !v.Data3.Status.HasFlag(StationStatus.PH_Status) && !v.Data3.Status.HasFlag(StationStatus.OT_Status))
+                                       .Where(v => !v.Data3.Status.HasFlag(StationStatus.Run)).ToList(); // 筛选出可用站台                             
+                    if (stations == null)
+                    {
+                        throw new KnownException($"{obj.Entity.Code}无可用放货站台", LogLevelEnum.High);
+                    }
+                    //可用堆垛机
+                    srm = stations.Select(v => v.Entity.Sources).SelectMany(v => v).Where(v => v.IsTunnel()) //上一个地址是巷道的
+                                  .Select(v => v.Sources).SelectMany(v => v).Where(v => v.HasProtocol(typeof(ISRM520))) //筛选出堆垛机
+                                  .Select(v => new SRM(v, this.World)) //转换为SRM
+                                  .Where(v => v != null && !v.Data2.Status.HasFlag(SrmStatus.Alarm) && v.Data2.AutoStatus == SrmAutoStatus.Automatic) //筛选出可用堆垛机
+                                  .Where(v => tunnelNo.Contains(v.Entity.Code)) //筛选出巷道优先级最高的堆垛机
+                                  .MinBy(v => tunnelNo.IndexOf(v.Entity.Code)); //按照巷道优先级排序
+                    if (srm == null)
+                    {
+                        throw new Exception($"任务{taskInfo.ID}无可用堆垛机");
+                    }
+                    //筛选出堆垛机的取货站台
+                    var nextPos = stations.FirstOrDefault(v => v.Entity.Sources.Where(t => t.IsTunnel()).Select(t => t.Sources).SelectMany(v => v) //获取所有巷道
+                                                                               .Where(t => t.HasProtocol(typeof(ISRM520)))//筛选出堆垛机
+                                                                               .SelectMany(v => v.Sources).Any(t => t.Code == srm.Entity.Parent.Code));
+                    if (nextPos == null)
+                    {
+                        throw new KnownException($"{obj.Entity.Code}没有可用的放货站台", LogLevelEnum.High);
+                    }
+
+                    var dev = devs.Find(v => v.Entity.Code == nextPos.Entity.Code);
+                    var nextCode = nextPos.Entity.Code;
+                    if (dev == null) throw new Exception($"找不到放货点");                    
+
+                    //堆垛机的可用取货站台
+                    taskInfo.SrmStation = nextPos.Entity.Code;
+                    taskInfo.AddrNext = nextPos.Entity.Sources.First().Code;
+                    taskInfo.Device = srm.Entity.Code;
+                    taskInfo.Tunnel = taskInfo.Device.GetLastDigit().ToString();
+                    taskInfo.Status = Entity.TaskStatus.ConveyorExecution;
+                    taskInfo.EditWho = "WCS";
+                    taskInfo.EditTime = DateTime.Now;
+                    db.Updateable(taskInfo).ExecuteCommand();
+                    taskInfo.AddWCS_TASK_DTL(_db, obj.Entity.Code, taskInfo.AddrNext, $"完成巷道分配，分配至{taskInfo.Device}");
+                    taskInfo.updateRedisHash();
+                    task = taskInfo;
+                    if (task == null) return;
+                }
+            });
+            obj.Data.TaskNumber = task.ID;
+            obj.Data.GoodsStart = obj.Entity.Code.ToShort();
+            obj.Data.GoodsEnd = task.SrmStation.ToShort();
+            obj.Data.VoucherNo++;
+
+        }
+        public override bool Select(Device dev)
+        {
+            return dev.Code == "";
+        }
+    }
+}

成品库/WCS.WorkEngineering/Systems/扫码入库.cs

@@ -55,8 +55,6 @@ namespace WCS.WorkEngineering.Systems
                 var db = _db.Default;
                 //找到对应任务
                 var taskInfo = db.Queryable<WCS_TaskInfo>().First(x => x.BarCode == bcr);                          
-                //var taskInfo = db.Queryable<WCS_TaskInfo>().First(x => x.AddrFrom == "8277");
-                
                 //未找到对应任务
                 if (taskInfo == null)
                 {
@@ -105,12 +103,9 @@ namespace WCS.WorkEngineering.Systems
                                   .Where(v => tunnelNo.Contains(v.Entity.Code)) //筛选出巷道优先级最高的堆垛机
                                   .MinBy(v => tunnelNo.IndexOf(v.Entity.Code)); //按照巷道优先级排序
                     if (srm == null)
-                    {
-                        
+                    {                        
                         throw new Exception($"任务{taskInfo.ID}无可用堆垛机{count}{count1[0].Entity.Code}");
-                    }
-                        
-
+                    }                        
                     //筛选出堆垛机的取货站台
                     var nextPos = stations.FirstOrDefault(v => v.Entity.Sources.Where(t => t.IsTunnel()).Select(t => t.Sources).SelectMany(v => v) //获取所有巷道
                                                                                .Where(t => t.HasProtocol(typeof(ISRM520)))//筛选出堆垛机