|
@@ -1,5 +1,6 @@
|
|
|
using DBHelper;
|
|
|
using Microsoft.EntityFrameworkCore;
|
|
|
+using Newtonsoft.Json;
|
|
|
using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.Linq;
|
|
@@ -127,11 +128,13 @@ namespace WCS.Service.Works.Station
|
|
|
|
|
|
var res = WMS.GetTunnelList(taskList.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();
|
|
|
|
|
|
var tunnelInfos = new List<TunnelInfo>();
|
|
|
+
|
|
|
foreach (var item in tunnels)
|
|
|
{
|
|
|
//当前巷道的取货点
|
|
@@ -155,9 +158,11 @@ namespace WCS.Service.Works.Station
|
|
|
var taskInStation = Device.Where(p => p.CODE.StartsWith("G") && p.DEVICEGROUP.Any(d => d.MEMBER == rgvDeliveryPoint.Entity)).MinBy(p => p.CODE);
|
|
|
//RGV是否有正在前往这个地址的任务
|
|
|
var rgvList = Device.Where(v => v.Is(DF.BOPPRGV)).Select(v => v.Create<RGVDevice>());
|
|
|
- if (rgvList.Any(v => (!v.Data2.SystemStatus.HasFlag(WCS.Entity.Protocol.RGV.RGVRunStatus.空闲) || !v.Data2.WorkMode.HasFlag(WCS.Entity.Protocol.RGV.RGVMode.自动))
|
|
|
+
|
|
|
+ var rgvTaskCount = ProtocolProxy.YGWMS150Redis.Get("BoppRgvTaskCount").ToInt();
|
|
|
+ if (rgvList.Count(v => (!v.Data2.SystemStatus.HasFlag(WCS.Entity.Protocol.RGV.RGVRunStatus.空闲) || !v.Data2.WorkMode.HasFlag(WCS.Entity.Protocol.RGV.RGVMode.自动))
|
|
|
&& v.Data2.TaskType_1 == WCS.Entity.Protocol.RGV.RGVTaskType.放货
|
|
|
- && v.Data2.DestPosition_1 == taskInStation?.CODE.Replace("G", "").ToShort())) continue;
|
|
|
+ && v.Data2.DestPosition_1 == taskInStation?.CODE.Replace("G", "").ToShort())>rgvTaskCount) continue;
|
|
|
tunnelInfos.Add(new TunnelInfo
|
|
|
{
|
|
|
Tunnel = item,
|
|
@@ -182,8 +187,8 @@ namespace WCS.Service.Works.Station
|
|
|
task.ADDRNEXT = tunnelInfo.taskIN.CODE;
|
|
|
task.TaskGroupKey = res.WMSTaskGroupKey;
|
|
|
task.ADDRTO = task.DEVICE;
|
|
|
- var msg = $"下达从G1030移动至{dev.Data.Goodsend}的PLC指令。同时将任务分配至[{task.TUNNEL}]-[{task.DEVICE}]";
|
|
|
- msg += $"[{dev.Data.Tasknum}][G1030][{dev.Data.Goodsend}][{tunnelInfo.SRM.Entity.CODE}][{dev.Data.VoucherNo}[{dev.Data2.VoucherNo}]";
|
|
|
+ var msg = $"下达从G23移动至{dev.Data.Goodsend}的PLC指令。同时将任务分配至[{task.TUNNEL}]-[{task.DEVICE}]";
|
|
|
+ msg += $"[{dev.Data.Tasknum}][G23][{dev.Data.Goodsend}][{tunnelInfo.SRM.Entity.CODE}][{dev.Data.VoucherNo}[{dev.Data2.VoucherNo}]";
|
|
|
task.CreateStatusLog(db, msg, this.GetType());
|
|
|
finishTaskList.Add(new FinishTaskList<int>(task.ID, item.Station));
|
|
|
}
|
|
@@ -241,26 +246,33 @@ namespace WCS.Service.Works.Station
|
|
|
|
|
|
var res = WMS.GetTunnelList(taskList.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();
|
|
|
|
|
|
var tunnelInfos = new List<TunnelInfo>();
|
|
|
+ var setting = new JsonSerializerSettings();
|
|
|
+ setting.ReferenceLoopHandling = ReferenceLoopHandling.Ignore;
|
|
|
+ setting.PreserveReferencesHandling = PreserveReferencesHandling.Objects;
|
|
|
+ code.infolog($"{res.WMSTaskGroupKey}第二次分配:WMS返回{JsonConvert.SerializeObject(tunnelNo, setting)}。");
|
|
|
foreach (var item in tunnels)
|
|
|
{
|
|
|
//当前巷道的取货点
|
|
|
var allIn = Device.Where(v => v.Is(DF.SRMBOPP取货))
|
|
|
- .Where(v => v.ROUTES.Any(p => p.NEXT == item)) //下一个点为当前巷道的取货点
|
|
|
+ .Where(v => v.ROUTES.Any(p => p.NEXT.CODE == item.CODE)) //下一个点为当前巷道的取货点
|
|
|
.Select(v => v.CODE)
|
|
|
.ToList();
|
|
|
+ code.infolog($"allIn:{JsonConvert.SerializeObject(allIn, setting)};item:{item.CODE}");
|
|
|
//下一个目标地址包含取货点的设备,此时获得的数据是旋转台
|
|
|
var turntable = Device.Where(v => v.IsConv() && v.ROUTES.Any(p => p.NEXT != null && allIn.Contains(p.NEXT.CODE)))
|
|
|
.Where(v => stationDeviceGroup.Items.Any(p => p.Entity == v))// 筛选出包含在当前设备组的设备
|
|
|
.Distinct()
|
|
|
.FirstOrDefault();//去一次重
|
|
|
if (turntable == null) continue;
|
|
|
+ code.infolog($"turntable:{turntable.CODE};item:{item.CODE}");
|
|
|
var dev = Device.Where(p => p.CODE.StartsWith("G") && p.DEVICEGROUP.Any(d => allIn.Contains(d.MEMBER.CODE))).MinBy(p => p.CODE);
|
|
|
-
|
|
|
+ code.infolog($"dev:{dev.CODE};item:{item.CODE}");
|
|
|
tunnelInfos.Add(new TunnelInfo
|
|
|
{
|
|
|
Tunnel = item,
|
|
@@ -268,9 +280,21 @@ namespace WCS.Service.Works.Station
|
|
|
SRM = Device.Where(p => p.IsSC()).FirstOrDefault(p => item.ROUTES.Any(d => d.NEXT.CODE == p.CODE)).Create<SRMDevice>()
|
|
|
});
|
|
|
}
|
|
|
+ code.infolog($"tunnelInfo:{JsonConvert.SerializeObject(tunnelInfos.Select(v => new { taskIN = v.taskIN.CODE, Tunnel = v.Tunnel.CODE, SRM = v.SRM.Entity.CODE }), setting)};");
|
|
|
//筛选出优先级最高的可用巷道
|
|
|
- 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; } }).MinBy(v => tunnelNo.IndexOf(v.Tunnel.CODE));
|
|
|
+ var tunnelInfo = tunnelInfos.Where(v =>
|
|
|
+ {
|
|
|
+ try
|
|
|
+ {
|
|
|
+ code.infolog($"SCAlarm:{v.SRM.Data3.SCAlarm};SRMMode:{v.SRM.Data2.SRMMode};SRMStatus:{v.SRM.Data2.SRMStatus};CODE:{v.SRM.Entity.CODE}");
|
|
|
+ return (v.SRM.Data3.SCAlarm == 0 && v.SRM.Data2.SRMMode == SCMode.远程 && v.SRM.Data2.SRMStatus == SCRunStatus.空闲)||v.SRM.Entity.CODE=="SRM1" || v.SRM.Entity.CODE == "SRM2";
|
|
|
+ }
|
|
|
+ catch { return false; }
|
|
|
+ }).MinBy(v => tunnelNo.IndexOf(v.Tunnel.CODE));
|
|
|
if (tunnelInfo == null) throw new WarnException("无可用巷道");
|
|
|
+ code.infolog($"tunnelNo:{JsonConvert.SerializeObject(tunnelNo, setting)}。");
|
|
|
+ code.infolog($"tunnelInfo:{JsonConvert.SerializeObject(new { taskIN = tunnelInfo.taskIN.CODE, Tunnel = tunnelInfo.Tunnel.CODE, SRM = tunnelInfo.SRM.Entity.CODE }, setting)};");
|
|
|
+ code.infolog($"{res.WMSTaskGroupKey}第二次分配:WCS选择{tunnelInfo.Tunnel.CODE}。");
|
|
|
|
|
|
//开始变更任务信息
|
|
|
foreach (var item in devise)
|
|
@@ -306,6 +330,7 @@ namespace WCS.Service.Works.Station
|
|
|
finishTask.Station.Data.Goodsnum = finishTaskList.Count.ToShort();
|
|
|
finishTask.Station.Data.CmdType = IstationCmdType.分配目标地址;
|
|
|
finishTask.Station.Data.VoucherNo++;
|
|
|
+ code.infolog($"{task.TaskGroupKey}第二次分配:WCS目标地址{finishTask.Station.Data.Goodsend}。");
|
|
|
}
|
|
|
});
|
|
|
});
|