|
@@ -12,73 +12,6 @@ using WCS.Service.Extensions;
|
|
|
|
|
|
namespace WCS.Service.Works.Station
|
|
|
{
|
|
|
- //[WorkTitle(typeof(ProductHandler), "一楼入库扫码")]
|
|
|
- //internal class 一楼入库 : DeviceWork<StationDevice>
|
|
|
- //{
|
|
|
- // private readonly string Conv_1028 = "1028";
|
|
|
- // private readonly string Conv_1029 = "1029";
|
|
|
-
|
|
|
- // protected override bool SelectDevice(WCS_DEVICE dev)
|
|
|
- // {
|
|
|
- // return dev.CODE == Conv_1028 || dev.CODE == Conv_1029;
|
|
|
- // }
|
|
|
-
|
|
|
- // protected override void Do(StationDevice dev)
|
|
|
- // {
|
|
|
- // dev.EX(dev =>
|
|
|
- // {
|
|
|
- // var code = dev.Entity.CODE;
|
|
|
- // if (dev.Data.VoucherNo != dev.Data2.VoucherNo)
|
|
|
- // throw new WarnException($"等待任务[{dev.Data2.Tasknum}]执行--凭证号不一致[{dev.Data.VoucherNo}][{dev.Data2.VoucherNo}]");
|
|
|
- // if (!dev.Data2.Status.HasFlag(IstationStatus.光电状态)) throw new DoException("无光电");
|
|
|
- // if (dev.Data3.Status.HasFlag(StationStatus.运行状态位)) throw new DoException("设备运行中");
|
|
|
- // if (dev.Data2.Request != IstationRequest.扫码入库) throw new WarnException("有光电无请求");
|
|
|
- // if (dev.Data2.Tasknum > 10000) throw new WarnException("有光电有请求,但已生产任务");
|
|
|
-
|
|
|
- // var bcr = dev.Entity.BCR();
|
|
|
- // var barcode = bcr.Content.Trim('\r');
|
|
|
- // if (barcode == "") throw new WarnException("扫码失败");
|
|
|
-
|
|
|
- // var info = WMS.I_WCS_GetInTask(barcode, dev.Entity.CODE);
|
|
|
- // var next = dev.Entity.CODE == Conv_1028 ? "1030" : "1031";
|
|
|
- // if (db.Default.Set<WCS_TASK>().Any(v => v.BARCODE == info.ContainerCode && v.STATUS<TaskStatus.已完成 && v.TYPE == TaskType.入库))
|
|
|
- // {
|
|
|
- // throw new WarnException($"WCS有正在执行的{info.ContainerCode},WMS任务号:{info.WMSTaskNum}");
|
|
|
- // }
|
|
|
-
|
|
|
- // var station = dev.Entity.CODE;
|
|
|
- // DB.Do(db =>
|
|
|
- // {
|
|
|
- // var task = new WCS_TASK();
|
|
|
- // task.BARCODE = info.ContainerCode;
|
|
|
- // task.TYPE = TaskType.入库;
|
|
|
- // task.STATUS = TaskStatus.执行中;
|
|
|
- // task.ADDRFROM = dev.Entity.CODE;
|
|
|
- // task.ADDRTO = info.EndPostion;
|
|
|
- // task.STARTTIME = DateTime.Now;
|
|
|
- // task.UPDATEUSER = "WCS";
|
|
|
- // task.UPDATETIME = DateTime.Now;
|
|
|
- // task.WMSTASK = int.Parse(info.WMSTaskNum);
|
|
|
- // task.TaskGroupKey = info.TaskGroupKey;
|
|
|
- // task.ADDRNEXT = next;
|
|
|
- // task.HEIGHT = dev.Data2.GoodsSize;
|
|
|
-
|
|
|
- // db.Default.Set<WCS_TASK>().Add(task);
|
|
|
- // db.Default.SaveChanges();
|
|
|
-
|
|
|
- // dev.Data.Tasknum = task.ID;
|
|
|
- // dev.Data.Goodsstart = task.ADDRFROM.ToShort();
|
|
|
- // dev.Data.Goodsend = task.ADDRNEXT.ToShort();
|
|
|
- // dev.Data.CmdType = IstationCmdType.扫码入库;
|
|
|
- // dev.Data.VoucherNo++;
|
|
|
- // var msg = $"下达从{dev.Entity.CODE}移动至{next}的PLC指令。";
|
|
|
- // msg += $"[{dev.Data.Tasknum}][{dev.Data.Goodsstart}][{dev.Data.Goodsend}][{dev.Data.VoucherNo}[{dev.Data2.VoucherNo}]";
|
|
|
- // task.CreateStatusLog(db, msg, this.GetType());
|
|
|
- // });
|
|
|
- // });
|
|
|
- // }
|
|
|
- //}
|
|
|
-
|
|
|
[WorkTitle(typeof(ProductHandler), "一楼入库扫码")]
|
|
|
internal class 一楼入库 : Work<StationDeviceGroup>
|
|
|
{
|
|
@@ -177,111 +110,6 @@ namespace WCS.Service.Works.Station
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- //[WorkTitle(typeof(ProductHandler), "一楼分配巷道")]
|
|
|
- //internal class 巷道分配 : Work<StationDeviceGroup>
|
|
|
- //{
|
|
|
- // private readonly string ConvGroup_1030 = "G1030";
|
|
|
- // private readonly string Conv_1030 = "1030";
|
|
|
- // private readonly string RGV8 = "RGV8";
|
|
|
-
|
|
|
- // protected override bool SelectDevice(WCS_DEVICE dev)
|
|
|
- // {
|
|
|
- // return dev.CODE == ConvGroup_1030;
|
|
|
- // }
|
|
|
-
|
|
|
- // protected override void Do(StationDeviceGroup obj)
|
|
|
- // {
|
|
|
- // obj.EX(obj =>
|
|
|
- // {
|
|
|
- // var code = obj.Entity.CODE;
|
|
|
- // //当前组有一个运行的设备就停止执行
|
|
|
- // foreach (var item in obj.Items)
|
|
|
- // {
|
|
|
- // var dev = Device.Find(item.Entity.CODE).Create<StationDevice>();
|
|
|
- // if (!dev.Data2.Status.HasFlag(IstationStatus.光电状态)) throw new DoException("无光电");
|
|
|
- // if (dev.Data.VoucherNo != dev.Data2.VoucherNo)
|
|
|
- // throw new WarnException($"等待任务[{dev.Data2.Tasknum}]执行--凭证号不一致[{dev.Data.VoucherNo}][{dev.Data2.VoucherNo}]");
|
|
|
- // if (dev.Data3.Status.HasFlag(StationStatus.运行状态位)) throw new WarnException("设备运行中");
|
|
|
- // if (dev.Data2.Tasknum > 10000 && dev.Data2.Request != IstationRequest.请求分配目标地址)
|
|
|
- // throw new WarnException("有任务无请求");
|
|
|
- // }
|
|
|
-
|
|
|
- // //获取需要进行巷道分配的设备
|
|
|
- // var devs = obj.TaskedDeviceGetNextAddress() ?? throw new WarnException("无可用任务");
|
|
|
-
|
|
|
- // DB.Do(db =>
|
|
|
- // {
|
|
|
- // var taskIds = devs.Select(p => p.Data2.Tasknum);
|
|
|
- // var tasks = db.Default.Set<WCS_TASK>().Where(p => taskIds.Any(v => v == p.ID)).ToList();
|
|
|
- // var res = WMS.GetTunnelList(tasks.Select(v => v.WMSTASK.ToString()).ToList(), code);
|
|
|
- // if (string.IsNullOrEmpty(res.TunnelNum)) throw new WarnException($"WMS未返回巷道");
|
|
|
- // var tunnelNo = res.TunnelNum.Split(',').Select(v => "TY" + v).ToList();
|
|
|
-
|
|
|
- // var tunnels = Device.Where(v => tunnelNo.Contains(v.CODE)).ToList();
|
|
|
-
|
|
|
- // List<TunnelInfo> tunnelInfos = new List<TunnelInfo>();
|
|
|
- // foreach (var item in tunnels)
|
|
|
- // {
|
|
|
- // //当前巷道的取货点
|
|
|
- // var allIn = Device.Where(v => v.Is(DF.SRM二级品取货)) //一楼所有取货点
|
|
|
- // .Where(v => v.ROUTES.Any(p => p.NEXT == item)) //下一个点为当前巷道的取货点
|
|
|
- // .Select(v => v.CODE)
|
|
|
- // .ToList();
|
|
|
- // var putStation = Device.Where(v => v.IsConv() && v.ROUTES.Any(p => p.NEXT != null && allIn.Contains(p.NEXT.CODE))) //下一个目标地址包含取货点的设备
|
|
|
- // .Select(v => v.Create<StationDevice>()) //取所有可以到达取货点设备的信息
|
|
|
- // .Where(v => !v.Data3.Status.HasFlag(StationStatus.运行状态位) && !v.Data2.Status.HasFlag(IstationStatus.光电状态) && v.Data2.Tasknum < 10000)//筛选出空闲的路径点,此处因输送机都是一个动力,因此可以先找路径点再找设备组
|
|
|
- // .Distinct()
|
|
|
- // .FirstOrDefault();//去一次重
|
|
|
- // if (putStation == null) continue;
|
|
|
- // var taskInStation = Device.Where(p => p.CODE.StartsWith("G") && p.DEVICEGROUP.Any(d => d.MEMBER == putStation.Entity)).OrderBy(p => p.CODE).FirstOrDefault();
|
|
|
- // //RGV是否有正在前往这个地址的任务
|
|
|
- // var rgv8 = Device.Find(RGV8).Create<RGVDevice>();
|
|
|
- // if (!rgv8.Data2.SystemStatus.HasFlag(WCS.Entity.Protocol.RGV.RGVRunStatus.空闲)
|
|
|
- // && !rgv8.Data2.WorkMode.HasFlag(WCS.Entity.Protocol.RGV.RGVMode.自动)
|
|
|
- // && rgv8.Data2.DestPosition_1 == taskInStation.CODE.Replace("G", "").ToShort()) continue;
|
|
|
- // tunnelInfos.Add(new TunnelInfo
|
|
|
- // {
|
|
|
- // Tunnel = item,
|
|
|
- // taskIN = taskInStation, //找到放货点设备所在组
|
|
|
- // SRM = Device.Where(p => p.IsSC()).FirstOrDefault(p => item.ROUTES.Any(d => d.NEXT.CODE == p.CODE)).Create<SRMDevice>()
|
|
|
- // });
|
|
|
- // }
|
|
|
- // //筛选出优先级最高的可用巷道
|
|
|
- // var tunnelInfo = tunnelInfos.Where(v => { try { return v.SRM.Data3.SCAlarm == 0 && v.SRM.Data2.SRMMode == SCMode.远程 && v.SRM.Data2.SRMStatus == SCRunStatus.空闲; } catch { return false; } })
|
|
|
- // .Where(v => !db.Default.Set<WCS_TASK>().Any(p => p.Priority > 0 && p.DEVICE == v.SRM.Entity.CODE && p.STATUS < TaskStatus.堆垛机完成))
|
|
|
- // .OrderBy(v => tunnelNo.IndexOf(v.Tunnel.CODE)).FirstOrDefault();
|
|
|
- // if (tunnelInfo == null) throw new WarnException("无可用巷道");
|
|
|
-
|
|
|
- // //开始向设备中写入任务信息
|
|
|
- // foreach (var item in devs)
|
|
|
- // {
|
|
|
- // var dev = Device.Find(item.Entity.CODE).Create<StationDevice>();
|
|
|
- // var task = tasks.FirstOrDefault(p => p.ID == dev.Data2.Tasknum);
|
|
|
- // if (task == null) throw new WarnException($"WCS无该任务{dev.Data2.Tasknum}--{dev.Entity.CODE}");
|
|
|
-
|
|
|
- // task.DEVICE = tunnelInfo.SRM.Entity.CODE;
|
|
|
- // task.TUNNEL = tunnelInfo.Tunnel.CODE;
|
|
|
- // task.ADDRNEXT = tunnelInfo.taskIN.CODE;
|
|
|
- // task.TaskGroupKey = res.WMSTaskGroupKey;
|
|
|
- // task.ADDRTO = task.DEVICE;
|
|
|
- // db.Default.SaveChanges();
|
|
|
-
|
|
|
- // var msg = $"下达从{Conv_1030}移动至{dev.Data.Goodsend}的PLC指令。同时将任务分配至[{ task.TUNNEL }]-[{task.DEVICE}]";
|
|
|
- // msg += $"[{dev.Data.Tasknum}][{Conv_1030}][{dev.Data.Goodsend}][{tunnelInfo.SRM.Entity.CODE}][{dev.Data.VoucherNo}[{dev.Data2.VoucherNo}]";
|
|
|
-
|
|
|
- // task.CreateStatusLog(db, msg, this.GetType());
|
|
|
-
|
|
|
- // dev.Data.Tasknum = task.ID;
|
|
|
- // dev.Data.Goodsstart = Conv_1030.ToShort();
|
|
|
- // dev.Data.Goodsend = tunnelInfo.taskIN.CODE.Replace("G", "").ToShort();
|
|
|
- // dev.Data.CmdType = IstationCmdType.分配目标地址;
|
|
|
- // dev.Data.VoucherNo++;
|
|
|
- // }
|
|
|
- // });
|
|
|
- // });
|
|
|
- // }
|
|
|
- //}
|
|
|
-
|
|
|
[WorkTitle(typeof(ProductHandler), "一楼分配巷道")]
|
|
|
internal class 巷道分配 : Work<StationDeviceGroup>
|
|
|
{
|