|
|
@@ -131,9 +131,6 @@ namespace WCS.Service.Works.Station
|
|
|
const string key1 = $"WCS:Lock:FirstOut";
|
|
|
DB.Do(db =>
|
|
|
{
|
|
|
- //验证总数
|
|
|
- if (db.Default.Set<WCS_TASK>().Count(v => v.STATUS < TaskStatus.已完成 && v.ADDRNEXT == "G1") >= 3) throw new WarnException("总数已达3，流量管控");
|
|
|
-
|
|
|
#region 开始进行优先判断
|
|
|
|
|
|
string value = ProtocolProxy.YG150Redis.Get(key1);
|
|
|
@@ -142,6 +139,10 @@ namespace WCS.Service.Works.Station
|
|
|
ProtocolProxy.YG150Redis.Set(key1, obj.Entity.CODE); //锁定当前设备，输送线是不是并行执行，所以不用增加redis事务锁
|
|
|
|
|
|
#endregion 开始进行优先判断
|
|
|
+ //验证总数
|
|
|
+ if (db.Default.Set<WCS_TASK>().Count(v => v.STATUS < TaskStatus.已完成 && v.ADDRNEXT == "G1") >= 3) throw new WarnException("总数已达3，流量管控");
|
|
|
+
|
|
|
+
|
|
|
|
|
|
foreach (var dev in devise)
|
|
|
{
|
