From 83109bffe17f4cf877bb9546065723835a3c6b7d Mon Sep 17 00:00:00 2001
From: lss <Lss@HanInfo>
Date: 星期三, 18 六月 2025 17:30:38 +0800
Subject: [PATCH] 货位禁用添加，国自安全交互流程变更
---
HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/process/DeviceProcess.cs | 114 ++++++++++++++++++++++++++++++++++++++++++--------------
1 files changed, 85 insertions(+), 29 deletions(-)
diff --git a/HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/process/DeviceProcess.cs b/HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/process/DeviceProcess.cs
index 8a26bb6..380aec4 100644
--- a/HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/process/DeviceProcess.cs
+++ b/HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/process/DeviceProcess.cs
@@ -7,6 +7,7 @@
using S7.Net;
using System;
using System.Collections.Generic;
+using System.IO;
using System.Linq;
using System.Threading;
using static HH.WCS.JiaTong.LISTA.process.HttpModel;
@@ -91,7 +92,7 @@
internal static void Traffic()
{
var db = new SqlHelper<object>().GetInstance();
- List<string> locs = new List<string>() { "LCDP-001" };
+ List<string> locs = new List<string>() { "LCDP-001", "BADPW-01" };
var location = db.Queryable<Location>().Where(a => locs.Contains(a.S_CODE)).ToList();
if (location.Count > 0)
{
@@ -104,8 +105,8 @@
var cntr = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == item.S_CODE).ToList();
if (cntr.Count > 0)
{
- var cntrcodes = cntr.Select(a => a.S_CNTR_CODE).ToArray();
- cntrcode = string.Join(",", cntrcodes);
+ cntrcode = cntr.OrderBy(a=>a.T_CREATE).First().S_CNTR_CODE;
+ // cntrcode = string.Join(",", cntrcodes);
}
//鍒涘缓杩囨湭瀹屾垚鐨勪换鍔′笉鍙戣捣璇锋眰
@@ -155,46 +156,93 @@
}
}
+
+ public static Dictionary<string, DpjErrorInfo> DpjInfoDirectory = new Dictionary<string, DpjErrorInfo>();
/// <summary>
/// 浜曟澗鍙犵洏鏈哄彔鐩樺洖搴� /// </summary>
internal static void DpjTraffic()
{
- string startBti = "CMB17-DP-001";
+ var devices = Settings.deviceInfos.Where(a => a.deviceType == 1).ToList();
+ //var db = new SqlHelper<object>().GetInstance();
+ //var list = db.Queryable<Location>().Where(a => a.N_CURRENT_NUM > 0 && a.N_LOCK_STATE == 0).OrderByDescending(a => a.N_COL).Take(1).PartitionBy(a => a.N_ROW).ToList();
try
{
- var IsDp = S7Helper.ReadDpj(2001, S7.Net.VarType.Byte);
- var value = S7Helper.ReadDpj(2014, S7.Net.VarType.Int);
-
- if (value >= 1 && IsDp == 1)
+ if (devices.Count > 0)
{
- //var cntr = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == item.S_CODE).ToList();
- //if (cntr.Count > 0)
- //{
- // var cntrcodes = cntr.Select(a => a.S_CNTR_CODE).ToArray();
- // cntrcode = string.Join(",", cntrcodes);
- //}
-
- //鍒涘缓杩囨湭瀹屾垚鐨勪换鍔′笉鍙戣捣璇锋眰
- var mst = WCSHelper.GetTaskByStartloc(startBti);
- if (mst == null)
+ foreach (var device in devices)
{
- Traystacker(startBti, value, 2);
- }
- else
- {
- LogHelper.Info($"鏈夋墽琛屼腑鐨勫彔鐩樺洖搴撲换鍔mst.S_CODE}锛屼笉瑙﹀彂鍙犵洏浠诲姟");
- }
+ var IsDp = S7Helper.ReadDpj(device.address, 2001, S7.Net.VarType.Byte);
+ var value = S7Helper.ReadDpj(device.address, 2014, S7.Net.VarType.Int);
+ var ErrorCode = S7Helper.ReadDpj(device.address, 2016, S7.Net.VarType.Int);
+ //璁板綍鍙犵洏鏈烘姤閿欎俊鎭�+ if (DpjInfoDirectory.ContainsKey(device.address))
+ {
+ DpjInfoDirectory[device.address].Address = device.address;
+ DpjInfoDirectory[device.address].DeviceName = device.deviceName;
+ var ErrorInfo = Settings.dpjErrorInfos.Where(a => a.ErrorCode == ErrorCode).First();
+ if (ErrorInfo != null)
+ {
+ DpjInfoDirectory[device.address].ErrorInfo = ErrorInfo.ErrorInfo;
+ }
+ }
+ else
+ {
+ string errorinfo = "";
+ var ErrorInfo = Settings.dpjErrorInfos.Where(a => a.ErrorCode == ErrorCode).First();
+ if (ErrorInfo != null)
+ {
+ errorinfo = ErrorInfo.ErrorInfo;
+ }
+ DpjInfoDirectory.Add(device.address, new DpjErrorInfo() { Address = device.address, DeviceName = device.deviceName, ErrorInfo = errorinfo });
+ }
+ if (value >= 1 && IsDp == 1)
+ {
+ //var cntr = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == item.S_CODE).ToList();
+ //if (cntr.Count > 0)
+ //{
+ // var cntrcodes = cntr.Select(a => a.S_CNTR_CODE).ToArray();
+ // cntrcode = string.Join(",", cntrcodes);
+ //}
+ //鍒涘缓杩囨湭瀹屾垚鐨勪换鍔′笉鍙戣捣璇锋眰
+ var mst = WCSHelper.GetTaskByStartloc(device.TN_Location);
+ if (mst == null)
+ {
+ Traystacker(device.TN_Location, value, 2);
+ }
+ else
+ {
+ LogHelper.Info($"鏈夋墽琛屼腑鐨勫彔鐩樺洖搴撲换鍔mst.S_CODE}锛屼笉瑙﹀彂鍙犵洏浠诲姟");
+ }
+ //var loc = LocationHelper.GetLocByLoc(device.TN_Location);
+ //if (loc != null)
+ //{
+ // if (loc.N_LOCK_STATE == 0) {
+ // Traystacker(device.TN_Location, value, 2);
+ // }
+ // else
+ // {
+ // LogHelper.Info($"璁惧璧风偣锛歿device.TN_Location}鏈夐攣锛屼笉鐢熸垚浠诲姟");
+ // }
+ //}
+ //else
+ //{
+ // LogHelper.Info($"鏍规嵁璁惧锛歿device.deviceName}锛岃捣鐐癸細{device.TN_Location},鏈壘鍒拌揣浣�);
+ //}
+ }
+ else
+ {
+ LogHelper.Info($"鍙犵洏鏈烘暟閲忥細{value},鍙犵洏淇″彿锛歿IsDp}锛屼笉瑙﹀彂鍙犵洏浠诲姟");
+ }
+ Thread.Sleep(8000);
+ }
}
- else
- {
- LogHelper.Info($"鍙犵洏鏈烘暟閲忥細{value},鍙犵洏淇″彿锛歿IsDp}锛屼笉瑙﹀彂鍙犵洏浠诲姟");
- }
- Thread.Sleep(8000);
+
}
catch (Exception ex)
{
+
LogHelper.Error($"ReadDpj DpjTraffic:{ex}", ex);
}
@@ -236,5 +284,13 @@
LogHelper.Info($"绌烘墭杩斿洖 Error=>{ex.ToString()}");
}
}
+
+ public class DpjErrorInfo
+ {
+
+ public string Address { get; set; }
+ public string DeviceName { get; set; }
+ public string ErrorInfo { get; set; }
+ }
}
}
--
Gitblit v1.9.1