From 52bd4af193199c19177f40dab06fa83b7a3dc59f Mon Sep 17 00:00:00 2001
From: czw <selecti@yeah.net>
Date: 星期二, 15 七月 2025 10:35:30 +0800
Subject: [PATCH] 1
---
2025年6月12日/AuxAllWCS/Build/Project/代码/VS自定义类/AutoThread.cs | 476 ++++++++++++++++++++++++++++++++++++++++------------------
1 files changed, 325 insertions(+), 151 deletions(-)
diff --git "a/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs" "b/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs"
index 10d44fc..ed756b0 100644
--- "a/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs"
+++ "b/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs"
@@ -137,24 +137,35 @@
{
try
{
- foreach (var ip in new List<string> {
- device1.p鍙戦偅绉�涓嬬嚎.Config.IP,
- device1.p鍙戦偅绉�涓嬬嚎.Config.IP,
- device1.D瀹氬瓙1鍙锋満姊版墜.Config.IP,
- device1.D瀹氬瓙2鍙锋満姊版墜.Config.IP,
- device1.Js鎹烽『1.Config.IP,
- device1.Js鎹烽『2.Config.IP,
- device1.缁村笇灏旀姄鑷�.Config.IP,
- device1.缁村笇灏旀姄鑷�.Config.IP,
- device1.RGV.Config.IP
- })
- {
- string pattern = @"\b(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\b";
+ // foreach (var ip in new List<string> {
+ // device1.p鍙戦偅绉�涓嬬嚎.Config.IP,
+ // device1.p鍙戦偅绉�涓嬬嚎.Config.IP,
+ // device1.D瀹氬瓙1鍙锋満姊版墜.Config.IP,
+ // device1.D瀹氬瓙2鍙锋満姊版墜.Config.IP,
+ // device1.Js鎹烽『1.Config.IP,
+ // device1.Js鎹烽『2.Config.IP,
+ // device1.缁村笇灏旀姄鑷�.Config.IP,
+ // device1.缁村笇灏旀姄鑷�.Config.IP,
+ // device1.RGV.Config.IP,
+ // device1.S1002Read.Config.IP,
+ // device1.S2001Read.Config.IP,
+ // device1.S3001Read.Config.IP
+ //})
+ // {
+ // string pattern = @"\b(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\b";
- var matches = Regex.Match(ip, pattern);
- if (matches.Success)
- IsMachineOnline(matches.Value);
- }
+ // var matches = Regex.Match(ip, pattern);
+ // if (matches.Success)
+ // {
+ // var b = IsMachineOnline(matches.Value);
+ // if (!Iponlines.ContainsKey(ip))
+ // {
+ // Iponlines.TryAdd(ip, b);
+ // }
+ // else
+ // Iponlines[ip] = b;
+ // }
+ // }
}
catch (Exception ex)
{
@@ -164,7 +175,7 @@
}, tag, device, 3000));
tasks.Add(GetTask(ThreadMXC3, tag, 3000));
tasks.Add(GetTask(ThreadMXC4, tag, 3000));
- tasks.Add(GetTask(ResetGats, tag, 3000));
+ //tasks.Add(GetTask(ResetGats, tag, 3000));
tasks.Add(GetTask(sa1022, tag, 3000));
tasks.Add(GetTask(sa1025, tag, 3000));
@@ -172,17 +183,15 @@
tasks.Add(GetTask(sa2001, tag, 3000));
tasks.Add(GetTask(sa2030, tag, 3000));
tasks.Add(GetTask(sa2008, tag, 3000));
- tasks.Add(GetTask(sa3001, tag, 3000));
- tasks.Add(GetTask(sa3005, tag, 3000));
- tasks.Add(GetTask(sa3006, tag, 3000));
- tasks.Add(GetTask(sa3010, tag, 3000));
-
-
-
+ //tasks.Add(GetTask(sa3001, tag, 3000));
+ //tasks.Add(GetTask(sa3005, tag, 3000));
+ //tasks.Add(GetTask(sa3006, tag, 3000));
+ //tasks.Add(GetTask(sa3010, tag, 3000));
Task.WaitAll(tasks.ToArray());
}
+ public static ConcurrentDictionary<string, bool> Iponlines = new ConcurrentDictionary<string, bool>();
public bool IsMachineOnline(string hostNameOrIp, int timeout = 1000)
{
//device.p鍙戦偅绉�涓嬬嚎.Config.IP
@@ -273,6 +282,7 @@
if (VERX != null)
{
+ LogHelper.Info($"{VERX.deviceName} D1212>{tag.Js1.D1212} 宸︽弧淇″彿:{TcpServer.GetBitdata(tag.Js1.D1212, 2)} D1212_LAST>{tag.Js1.D1212_LAST} 鍙虫弧淇″彿>{TcpServer.GetBitdata(tag.Js1.D1212, 3)} D1213_LAST>{tag.Js1.D1213_LAST}");
if (tag.Js1.D1212_LAST == 0 && TcpServer.GetBitdata(tag.Js1.D1212, 2) == 1)
{
var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new
@@ -291,8 +301,9 @@
if (tag.Js1.D1212_LAST == 1 && TcpServer.GetBitdata(tag.Js1.D1212, 2) == 0)
{
//tag.Js1.D1212_LAST = 0;
+ tag.Js1.D1224 = 0;
RedisHelper.Add($"Js鎹烽『1.D1202_LAST", "0", out string msg);
- //Conn.榛樿Redis.SetValue(VERX.deviceName + ".D1224", "0", VERX.deviceName + "Queue");
+ //Conn.榛樿Redis.SetValue("Js鎹烽『1.D1224", "0", VERX.deviceName + "Queue");
}
if (tag.Js1.D1213_LAST == 0 && TcpServer.GetBitdata(tag.Js1.D1212, 3) == 1)
@@ -313,8 +324,8 @@
if (tag.Js1.D1213_LAST == 1 && TcpServer.GetBitdata(tag.Js1.D1212, 3) == 0)
{
//tag.Js1.D1213_LAST = 0;
+ tag.Js1.D1225 = 0;
RedisHelper.Add($"Js鎹烽『1.D1203_LAST", "0", out string msg);
- //Conn.榛樿Redis.SetValue(VERX.deviceName + ".D1225", "0", VERX.deviceName + "Queue");
}
}
}
@@ -329,6 +340,8 @@
if (VERX != null)
{
+ LogHelper.Info($"{VERX.deviceName} D1212>{tag.Js2.D1212} 宸︽弧淇″彿:{TcpServer.GetBitdata(tag.Js2.D1212, 2)} D1212_LAST>{tag.Js2.D1212_LAST} 鍙虫弧淇″彿>{TcpServer.GetBitdata(tag.Js2.D1212, 2)} D1213_LAST>{tag.Js2.D1213_LAST}");
+
if (tag.Js2.D1212_LAST == 0 && TcpServer.GetBitdata(tag.Js2.D1212, 2) == 1)
{
var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new
@@ -346,7 +359,7 @@
if (tag.Js2.D1212_LAST == 1 && TcpServer.GetBitdata(tag.Js2.D1212, 2) == 0)
{
//tag.Js2.D1212_LAST = 0;
-
+ tag.Js2.D1224 = 0;
RedisHelper.Add($"Js鎹烽『2.D1202_LAST", "0", out string msg);
}
if (tag.Js2.D1213_LAST == 0 && TcpServer.GetBitdata(tag.Js2.D1212, 3) == 1)
@@ -367,7 +380,7 @@
if (tag.Js2.D1213_LAST == 1 && TcpServer.GetBitdata(tag.Js2.D1213, 2) == 0)
{
//tag.Js2.D1213_LAST = 0;
-
+ tag.Js2.D1225 = 0;
RedisHelper.Add($"Js鎹烽『2.D1203_LAST", "0", out string msg);
}
}
@@ -468,7 +481,7 @@
if (VERX != null)
{
if (tag.wxr1.R46)
- LogHelper.Info($"{VERX.deviceName} R44>{tag.wxr1.R46} R44LAST>{tag.wxr1.R46_LAST} R10>{tag.wxr1.R11}");
+ LogHelper.Info($"{VERX.deviceName} R46>{tag.wxr1.R46} R46LAST>{tag.wxr1.R46_LAST} R11>{tag.wxr1.R11}");
if (tag.wxr1.R46 && !tag.wxr1.R46_LAST && tag.wxr1.R11)
{
if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode) && !string.IsNullOrEmpty(traycode.Trim()))
@@ -633,7 +646,7 @@
if (VERX != null)
{
if (tag.wxr2.R46)
- LogHelper.Info($"{VERX.deviceName} R44>{tag.wxr2.R46} R44LAST>{tag.wxr2.R46_LAST} R10>{tag.wxr2.R11}");
+ LogHelper.Info($"{VERX.deviceName} R46>{tag.wxr2.R46} R46LAST>{tag.wxr2.R46_LAST} R11>{tag.wxr2.R11}");
if (tag.wxr2.R46 && !tag.wxr2.R46_LAST && tag.wxr2.R11)
{
if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode) && !string.IsNullOrEmpty(traycode.Trim()))
@@ -655,7 +668,7 @@
}
else
{
- TcpServer.TcpServerSend(VERX.deviceNo[2], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E"));
+ TcpServer.TcpServerSend(VERX.deviceNo[1], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E"));
}
}
else
@@ -768,15 +781,25 @@
LogHelper.Info($"鏌ョ湅RGV 鐢甸噺锛氥�{tag.RGV.R褰撳墠鐢甸噺}銆�鍏呯數鐘舵�锛氥�{tag.RGV.R鍏呯數鐘舵�}銆�鏁呴殰浠ｇ爜锛氥�{tag.RGV.RgvrunError}銆�鎵嬪姩1鑷姩2銆恵tag.RGV.R鎵嬪姩1鑷姩2}銆�);
+ if (tag.RGV.R鍏呯數鐘舵� == 1)
+ {
+ LogHelper.Info($"RGV 鍏呯數妯″紡锛屼笉鐢ㄧ銆�);
+ return;
+ }
if (tag.RGV.R鎵嬪姩1鑷姩2 == 1)
{
LogHelper.Info($"RGV 鎵嬪姩妯″紡锛屼笉鐢ㄧ銆�);
return;
}
+ if (tag.RGV.RgvrunError > 0)
+ {
+ LogHelper.Info($"RGV 鏁呴殰锛屼笉鐢ㄧ銆�);
+ return;
+ }
+ LogHelper.Info($"RGV125鍛戒护鏌ョ湅 Rgv浠诲姟鏁版嵁 鍐�workmode:{tag.RGV.workMod} taskmod{tag.RGV.taskmod} t1No:{tag.RGV.taskno1} t1do:{tag.RGV.task1do} t2No:{tag.RGV.taskno2} t2do:{tag.RGV.task2do} taskend:{tag.RGV.taskend} ");
if (tag.RGV.taskend == 125)
{
LogHelper.Info($"RGV 鏈�25鍛戒护鏈墽琛屻� ");
- LogHelper.Info($"RGV125鍛戒护鏈墽琛�浠诲姟鏁版嵁 workmode:{tag.RGV.workMod}\n taskmod{tag.RGV.taskmod} \n t1No:{tag.RGV.taskno1}\n t1do:{tag.RGV.task1do} \n t2No:{tag.RGV.taskno2}\n t2do:{tag.RGV.task2do}\n taskend:{tag.RGV.taskend} ");
if (tag.RGV.workMod == 0 && tag.RGV.taskmod == 0 && tag.RGV.taskno1 == tag.RGV.ReadTask1No && tag.RGV.taskno2 == tag.RGV.ReadTask2No)
{
@@ -786,28 +809,28 @@
System.Threading.Thread.Sleep(3000);
return;
}
- LogHelper.Info($"浠诲姟涓嬪彂 Rgv 浠诲姟 杩涘叆 Rgv淇℃伅 W1鐘舵�{tag.RGV.w1status} ReadTask1No>{tag.RGV.ReadTask1No} 1宸ヤ綅鏉＄爜:{tag.RGV.bit1Code} bit1taskOver>{tag.RGV.bit1taskOver} W2鐘舵�{tag.RGV.w2status} ReadTask2No>{tag.RGV.ReadTask2No} 2宸ヤ綅鏉＄爜:{tag.RGV.bit2Code} bit2taskOver>{tag.RGV.bit2taskOver}");
+ LogHelper.Info($"浠诲姟涓嬪彂 Rgv浠诲姟鏁版嵁 璇�W1鐘舵�{tag.RGV.w1status} ReadTask1No>{tag.RGV.ReadTask1No} 1宸ヤ綅鏉＄爜:{tag.RGV.bit1Code} bit1taskOver>{tag.RGV.bit1taskOver} W2鐘舵�{tag.RGV.w2status} ReadTask2No>{tag.RGV.ReadTask2No} 2宸ヤ綅鏉＄爜:{tag.RGV.bit2Code} bit2taskOver>{tag.RGV.bit2taskOver}");
TaskEntity task1 = null;
TaskEntity task2 = null;
var task1Isrun = false;
if (tag.RGV.ReadTask1No > 0 && tag.RGV.bit1taskOver != 1)
{
- var taskno = tag.RGV.ReadTask1No;
- string tno = "TN" + (DateTime.Now.ToString("yy")) + ((taskno.ToString()).PadLeft(8, '0'));
- task1 = taskservice.FindEntity(x => x.S_TASK_NO == tno);
- if (task1 != null && task1.S_B_STATE != "瀹屾垚")
- task1Isrun = true;
+ //var taskno = tag.RGV.ReadTask1No;
+ //string tno = "TN" + (DateTime.Now.ToString("yy")) + ((taskno.ToString()).PadLeft(8, '0'));
+ //task1 = taskservice.FindEntity(x => x.S_TASK_NO == tno);
+ //if (task1 != null && task1.S_B_STATE != "瀹屾垚")
+ task1Isrun = true;
//if (tag.RGV.bit1taskOver_LAST == 1)
// RedisHelper.Add($"RGV.bit1taskOver_LAST", "0", out string msg);
}
var task2Isrun = false;
if (tag.RGV.ReadTask2No > 0 && tag.RGV.bit2taskOver != 1)
{
- var taskno = tag.RGV.ReadTask2No;
- string tno = "TN" + (DateTime.Now.ToString("yy")) + ((taskno.ToString()).PadLeft(8, '0'));
- task2 = taskservice.FindEntity(x => x.S_TASK_NO == tno);
- if (task2 != null && task2.S_B_STATE != "瀹屾垚")
- task2Isrun = true;
+ //var taskno = tag.RGV.ReadTask2No;
+ //string tno = "TN" + (DateTime.Now.ToString("yy")) + ((taskno.ToString()).PadLeft(8, '0'));
+ //task2 = taskservice.FindEntity(x => x.S_TASK_NO == tno);
+ //if (task2 != null && task2.S_B_STATE != "瀹屾垚")
+ task2Isrun = true;
//if (tag.RGV.bit2taskOver_LAST == 1)
// RedisHelper.Add($"RGV.bit2taskOver_LAST", "0", out string msg);
}
@@ -916,9 +939,22 @@
// var b = RedisHelper.Remove("RGVQueue", out rev);
// }
//}
+ var tklistall = taskservice.FindList(x => x.S_B_STATE != "瀹屾垚" && x.S_B_STATE != "鍙栨秷" && x.S_WORK_MODE == "RGV").OrderBy(x => x.T_CREATE).ToList();
+ var tklist = tklistall.FindAll(x => x.S_B_STATE == "鏈墽琛�);
+ var tkunNormal = tklistall.Except(tklist);
+ if (tkunNormal.Any())
+ foreach (var tk in tkunNormal)
+ {
+ if (tk.S_TASK_NO != task1?.S_TASK_NO && tk.S_TASK_NO != task2?.S_TASK_NO)
+ {
+ tk.S_B_STATE = "鍙栨秷";
+ tk.S_NOTE = "涓嶅湪鎵ц闃熷垪涓�鍙栨秷";
+ taskservice.Update(tk);
+ }
+ }
///1 鏈夎揣 灏� 鍙栥� 1 娌¤揣 灏� 鍗歌揣锛�閮芥湁璐� 灏�鍗歌揣銆�閮芥病璐�灏�鍗�- var tklist = taskservice.FindList(x => x.S_B_STATE == "鏈墽琛� && x.S_WORK_MODE == "RGV").OrderBy(x => x.T_CREATE).ToList();
+ // taskservice.FindList(x => x.S_B_STATE == "鏈墽琛� && x.S_WORK_MODE == "RGV").OrderBy(x => x.T_CREATE).ToList();
if (task1 != null && task1.S_B_STATE != "瀹屾垚") //1鏈変换鍔� {
if (task2 != null && task2.S_B_STATE != "瀹屾垚")// 1 鏈変换鍔� 2 鏈変换鍔°�
@@ -1131,8 +1167,8 @@
var taskCOdes = new List<string> { "Sarrive", "Srelease", "Earrive", "Erelease" };
TaskActRepository taskActRepository = new TaskActRepository();
TaskRepository taskRepository = new TaskRepository();
- var requires = taskActRepository.FindList(x => taskCOdes.Contains(x.S_ACTION_CODE) && x.N_CREATEMETHOD == 0).OrderBy(x => x.T_CREATE).ToList();
- var timeMorhours = requires.FindAll(x => DateTime.Now.Subtract(x.T_CREATE).TotalHours > 1);
+ var requires1 = taskActRepository.FindList(x => taskCOdes.Contains(x.S_ACTION_CODE) && x.N_CREATEMETHOD == 0).OrderBy(x => x.T_CREATE).ToList();
+ var timeMorhours = requires1.FindAll(x => DateTime.Now.Subtract(x.T_CREATE).TotalHours > 1);
if (timeMorhours.Any())
{
foreach (var mor in timeMorhours)
@@ -1141,10 +1177,23 @@
mor.S_REVIEW_COMMENT = "瓒呮椂涓嶅鐞�;
taskActRepository.Update(mor);
}
- requires = requires.Except(timeMorhours).ToList();
+ requires1 = requires1.Except(timeMorhours).ToList();
}
- foreach (var item in requires)
+ foreach (var requires in requires1.GroupBy(x => x.S_TASK_NO))
+ //foreach (var item in requires)
{
+ var rsss = requires.ToList();
+ var item = rsss.OrderBy(x => x.S_ACTION_CODE.Contains("release") ? 0 : 1).LastOrDefault();
+ if (rsss.Count > 1)
+ {
+ rsss.Remove(item);
+ foreach (var mor in rsss)
+ {
+ mor.N_CREATEMETHOD = 3;
+ mor.S_REVIEW_COMMENT = "澶氫綑涓嶅鐞�;
+ taskActRepository.Update(mor);
+ }
+ }
LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE}鍏夋爡澶勭悊 =================> ");
var tin = taskCOdes.IndexOf(item.S_ACTION_CODE);
if (tin == -1)
@@ -1290,7 +1339,10 @@
continuuuuu = true;
}
else
+ {
SetRedistoPlc("A1019鍙栬揣浜や簰.Ssetreq", "true", "A1019鍙栬揣浜や簰Queue", "鍐橝GV鐢宠");
+ tag.SA1019.StaskMode = 1;
+ }
}
break;
case "1030":
@@ -1301,7 +1353,10 @@
continuuuuu = true;
}
else
+ {
SetRedistoPlc("A1030鍙栬揣浜や簰.Ssetreq", "true", "A1030鍙栬揣浜や簰Queue", "鍐橝GV鐢宠");
+ tag.SA1030.StaskMode = 1;
+ }
}
break;
case "2030":
@@ -1312,7 +1367,10 @@
continuuuuu = true;
}
else
+ {
SetRedistoPlc("A2030鍙栬揣浜や簰.Ssetreq", "true", "A2030鍙栬揣浜や簰Queue", "鍐橝GV鐢宠");
+ tag.SA2030.StaskMode = 1;
+ }
}
break;
case "3005":
@@ -1323,7 +1381,10 @@
continuuuuu = true;
}
else
+ {
SetRedistoPlc("A3005鍙栬揣浜や簰.Ssetreq", "true", "A3005鍙栬揣浜や簰Queue", "鍐橝GV鐢宠");
+ tag.ssx杈撻�绾�s3005.StaskMode = 1;
+ }
}
break;
case "3010":
@@ -1334,7 +1395,10 @@
continuuuuu = true;
}
else
+ {
SetRedistoPlc("A3010鍙栬揣浜や簰.Ssetreq", "true", "A3010鍙栬揣浜や簰Queue", "鍐橝GV鐢宠");
+ tag.ssx杈撻�绾�s3010.StaskMode = 1;
+ }
}
break;
//}
@@ -1348,7 +1412,10 @@
continuuuuu = true;
}
else
+ {
SetRedistoPlc("A1022鏀捐揣浜や簰.Ssetreq", "true", "A1022鏀捐揣浜や簰Queue", "鍐橝GV鐢宠");
+ tag.SA1022.StaskMode = 2;
+ }
}
break;
case "1025":
@@ -1359,7 +1426,10 @@
continuuuuu = true;
}
else
+ {
SetRedistoPlc("A1025鏀捐揣浜や簰.Ssetreq", "true", "A1025鏀捐揣浜や簰Queue", "鍐橝GV鐢宠");
+ tag.SA1025.StaskMode = 2;
+ }
}
break;
case "2001":
@@ -1370,7 +1440,10 @@
continuuuuu = true;
}
else
+ {
SetRedistoPlc("A2001鏀捐揣浜や簰.Ssetreq", "true", "A2001鏀捐揣浜や簰Queue", "鍐橝GV鐢宠");
+ tag.SA2001.StaskMode = 2;
+ }
}
break;
case "3001":
@@ -1381,7 +1454,10 @@
continuuuuu = true;
}
else
+ {
SetRedistoPlc("A3001鏀捐揣浜や簰.Ssetreq", "true", "A3001鏀捐揣浜や簰Queue", "鍐橝GV鐢宠");
+ tag.ssx杈撻�绾�s3001.StaskMode = 2;
+ }
}
break;
case "3006":
@@ -1392,7 +1468,10 @@
continuuuuu = true;
}
else
+ {
SetRedistoPlc("A3006鏀捐揣浜や簰.Ssetreq", "true", "A3006鏀捐揣浜や簰Queue", "鍐橝GV鐢宠");
+ tag.ssx杈撻�绾�s3006.StaskMode = 2;
+ }
}
break;
}
@@ -1440,7 +1519,7 @@
{
var close = (System.UInt16)System.Convert.ChangeType(Conn.榛樿Redis.GetValue(dev.deviceName + "." + (V ? "D2220" : "D2225")), typeof(System.UInt16));
- if (close == 1)
+ if (close == 0)
{
LogHelper.Info($"{dev.deviceName}{(V ? "宸� : "鍙�)} 鍏夋爡{(goin ? "鍏抽棴" : "寮�惎")} 鐢宠銆�宸茬粡鍏抽棴锛�);
continuuuuu = true;
@@ -1470,6 +1549,7 @@
}
}
System.Threading.Thread.Sleep(3000);
+ //ResetGats(tag);
}
public void ResetGats(Tag tag)
{
@@ -1482,18 +1562,20 @@
//int int0 = TcpServer.GetBitdata(numm, 0);
//int int1 = TcpServer.GetBitdata(numm, 1);
- if (TcpServer.GetBitdata(numm, 0) == 0)
- {
- Conn.榛樿Redis.SetValue(dev.deviceName + ".D1220", "0", dev.deviceName + "Queue", false);
- Conn.榛樿Redis.SetValue(dev.deviceName + ".D1222", "0", dev.deviceName + "Queue", false);
- }
- if (TcpServer.GetBitdata(numm, 1) == 0)
- {
- Conn.榛樿Redis.SetValue(dev.deviceName + ".D1221", "0", dev.deviceName + "Queue", false);
- Conn.榛樿Redis.SetValue(dev.deviceName + ".D1223", "0", dev.deviceName + "Queue", false);
- }
+ //if (TcpServer.GetBitdata(numm, 0) == 0)
+ //{
+ // Conn.榛樿Redis.SetValue(dev.deviceName + ".D1220", "0", dev.deviceName + "Queue", false);
+ // Conn.榛樿Redis.SetValue(dev.deviceName + ".D1222", "0", dev.deviceName + "Queue", false);
+ //}
+ //if (TcpServer.GetBitdata(numm, 1) == 0)
+ //{
+ // Conn.榛樿Redis.SetValue(dev.deviceName + ".D1221", "0", dev.deviceName + "Queue", false);
+ // Conn.榛樿Redis.SetValue(dev.deviceName + ".D1223", "0", dev.deviceName + "Queue", false);
+ //}
+
if (TcpServer.GetBitdata(numm, 2) == 0)
{
+ //Conn.榛樿Redis.GetValue(dev.deviceName + ".D1224");
Conn.榛樿Redis.SetValue(dev.deviceName + ".D1224", "0", dev.deviceName + "Queue", false);
}
if (TcpServer.GetBitdata(numm, 3) == 0)
@@ -1510,18 +1592,22 @@
//涓�嚎鍦板潃锛�0.221.55.181 绔彛锛�000
//if (IsMachineOnline("10.221.55.181"))
{
- //if (tag.DZ1.D2211 == 1 && tag.DZ1.D2220 == 1)
- // tag.DZ1.D2211 = 0;
- //if (tag.DZ1.D2216 == 1 && tag.DZ1.D2225 == 1)
- // tag.DZ1.D2216 = 0;
+ if (tag.DZ1.D2211 == 1 && tag.DZ1.D2220 == 1)
+ //tag.DZ1.D2211 = 0;
+ Conn.榛樿Redis.SetValue("D瀹氬瓙1鍙锋満姊版墜.D2211", "0", "D瀹氬瓙1鍙锋満姊版墜Queue", false);
+ if (tag.DZ1.D2216 == 1 && tag.DZ1.D2225 == 1)
+ //tag.DZ1.D2216 = 0;
+ Conn.榛樿Redis.SetValue("D瀹氬瓙1鍙锋満姊版墜.D2216", "0", "D瀹氬瓙1鍙锋満姊版墜Queue", false);
}
//浜岀嚎鍦板潃锛�0.221.55.179 绔彛锛�000
//if (IsMachineOnline("10.221.55.179"))
{
- //if (tag.DZ2.D2211 == 1 && tag.DZ2.D2220 == 1)
- // tag.DZ2.D2211 = 0;
- //if (tag.DZ2.D2216 == 1 && tag.DZ2.D2225 == 1)
- // tag.DZ2.D2216 = 0;
+ if (tag.DZ2.D2211 == 1 && tag.DZ2.D2220 == 1)
+ //tag.DZ2.D2211 = 0;
+ Conn.榛樿Redis.SetValue("D瀹氬瓙2鍙锋満姊版墜.D2211", "0", "D瀹氬瓙2鍙锋満姊版墜Queue", false);
+ if (tag.DZ2.D2216 == 1 && tag.DZ2.D2225 == 1)
+ //tag.DZ2.D2216 = 0;
+ Conn.榛樿Redis.SetValue("D瀹氬瓙2鍙锋満姊版墜.D2216", "0", "D瀹氬瓙2鍙锋満姊版墜Queue", false);
}
}
LogHelper.Info($"ThreadGrats deviceType5鍏夋爡鍐欏叆浣嶉噸缃畬鎴愩� =================> ");
@@ -1533,6 +1619,11 @@
public void ThreadEdown(Tag tag)
{
Console.WriteLine($"ThreadEdown 20 23 = 绌轰笅妫�祴 =================> ");
+ if (tag.RGV.R鍏呯數鐘舵� == 1 || tag.RGV.R鎵嬪姩1鑷姩2 == 1 || tag.RGV.RgvrunError > 0)
+ {
+ LogHelper.Info($"RGV 鎵嬪姩||鏁呴殰||鍏呯數锛岀┖涓嬫娴嬬粓姝€�");
+ return;
+ }
TaskRepository taskRepository = new TaskRepository();
foreach (var Bssx in new string[] { "1020", "1023" })
{
@@ -1639,7 +1730,12 @@
public void ThreadDdown(Tag tag)
{
- Console.WriteLine($"ThreadDdown 08 10 ==================> 1026");
+ Console.WriteLine($"ThreadDdown 08 16==================> 1026");
+ if (tag.RGV.R鍏呯數鐘舵� == 1 || tag.RGV.R鎵嬪姩1鑷姩2 == 1 || tag.RGV.RgvrunError > 0)
+ {
+ LogHelper.Info($"RGV 鎵嬪姩||鏁呴殰||鍏呯數锛�8 16 > 1026缁堟銆�);
+ return;
+ }
TaskRepository taskRepository = new TaskRepository();
foreach (var Bssx in new string[] { "1008", "1016" })
{
@@ -1676,6 +1772,19 @@
{
RedisHelper.Add($"S{Bssx}Read.RtaskState_LAST", "1", out msg);
RedisHelper.Add($"S{item}Read.R5绌洪棽_LAST", "1", out string msg2);
+
+ LogHelper.Info($"{R鎵樼洏鐮亇 瀹氬瓙鐢熶骇瀹屾垚杩涜椴嶅伐锛侊紒");
+ var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/223", JsonConvert.SerializeObject(new
+ {
+ cntrCode = R鎵樼洏鐮�
+ type = 1,
+ lineCode = "1002,1008".Contains(Bssx) ? "T01" : "T02"
+ }));
+ //var strr = JsonConvert.DeserializeObject<MES2234>(str);
+ //if (strr.success && strr.data != null)
+ //{
+
+ //}
//Conn.榛樿Redis.SetValue($"S{Bssx}Read.RtaskState_LAST", "1", $"S{Bssx}ReadQueue");
//Conn.榛樿Redis.SetValue($"S{item}Read.R5绌洪棽_LAST", "1", $"S{item}ReadQueue");
break;
@@ -1698,6 +1807,11 @@
public void Thread0210Down(Tag tag)
{
Console.WriteLine($"Thread0210Down ==================>");
+ if (tag.RGV.R鍏呯數鐘舵� == 1 || tag.RGV.R鎵嬪姩1鑷姩2 == 1 || tag.RGV.RgvrunError > 0)
+ {
+ LogHelper.Info($"RGV 鎵嬪姩||鏁呴殰||鍏呯數锛�2 10 > 1017缁堟銆�);
+ return;
+ }
TaskRepository taskRepository = new TaskRepository();
foreach (var Bssx in new string[] { "1002", "1010" })
{
@@ -1733,6 +1847,13 @@
{
RedisHelper.Add($"S{Bssx}Read.RtaskState_LAST", "1", out msg);
RedisHelper.Add($"S{item}Read.R5绌洪棽_LAST", "1", out string msg1);
+ LogHelper.Info($"{R鎵樼洏鐮亇 杞瓙鐢熶骇瀹屾垚杩涜椴嶅伐锛侊紒");
+ var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/223", JsonConvert.SerializeObject(new
+ {
+ cntrCode = R鎵樼洏鐮�
+ type = 2,
+ lineCode = "1002,1008".Contains(Bssx) ? "T01" : "T02"
+ }));
//Conn.榛樿Redis.SetValue($"S{Bssx}Read.RtaskState_LAST", "1", $"S{Bssx}ReadQueue");
//Conn.榛樿Redis.SetValue($"S{item}Read.R5绌洪棽_LAST", "1", $"S{item}ReadQueue");
break;
@@ -1775,6 +1896,7 @@
{
LogHelper.Info($"ssx == 1003 && tag.SF涓嬫枡浣�WRelease1003:{tag.SF涓嬫枡浣�WRelease1003} 鍐檉1 2210=1锛孉rrive{ssx}BarcodeLast={RtrayCode}");
tag.FNK1.D2210 = 1;
+ //Conn.榛樿Redis.SetValue($"p鍙戦偅绉�涓嬬嚎.D2210", "1", $"p鍙戦偅绉�涓嬬嚎Queue",false);
}
break;
case "1005":
@@ -1815,33 +1937,33 @@
if (WRelease == 1 && rReleaseOver == 1)
{
- switch (ssx)
- {
- case "1003":
- {
- LogHelper.Info($"璇粄ssx} WRelease=1&& rReleaseOver=1 璇籉NK1.D2213{tag.FNK1.D2213}=1? 骞跺啓0");
- tag.FNK1.D2213 = 0;
- }
- break;
- case "1005":
- {
- LogHelper.Info($"璇粄ssx} WRelease=1&& rReleaseOver=1 璇籉NK1.D2218{tag.FNK1.D2218}=1? 骞跺啓0");
- tag.FNK1.D2218 = 0;
- }
- break;
- case "1011":
- {
- LogHelper.Info($"璇粄ssx} WRelease=1&& rReleaseOver=1 璇籉NK2.D2213{tag.FNK1.D2213}=1? 骞跺啓0");
- tag.FNK2.D2213 = 0;
- }
- break;
- case "1013":
- {
- LogHelper.Info($"璇粄ssx} WRelease=1&& rReleaseOver=1 璇籉NK2.D2218{tag.FNK2.D2218}=1? 骞跺啓0");
- tag.FNK2.D2218 = 0;
- }
- break;
- }
+ //switch (ssx)
+ //{
+ // case "1003":
+ // {
+ // LogHelper.Info($"璇粄ssx} WRelease=1&& rReleaseOver=1 璇籉NK1.D2213{tag.FNK1.D2213}=1? 骞跺啓0");
+ // tag.FNK1.D2213 = 0;
+ // }
+ // break;
+ // case "1005":
+ // {
+ // LogHelper.Info($"璇粄ssx} WRelease=1&& rReleaseOver=1 璇籉NK1.D2218{tag.FNK1.D2218}=1? 骞跺啓0");
+ // tag.FNK1.D2218 = 0;
+ // }
+ // break;
+ // case "1011":
+ // {
+ // LogHelper.Info($"璇粄ssx} WRelease=1&& rReleaseOver=1 璇籉NK2.D2213{tag.FNK1.D2213}=1? 骞跺啓0");
+ // tag.FNK2.D2213 = 0;
+ // }
+ // break;
+ // case "1013":
+ // {
+ // LogHelper.Info($"璇粄ssx} WRelease=1&& rReleaseOver=1 璇籉NK2.D2218{tag.FNK2.D2218}=1? 骞跺啓0");
+ // tag.FNK2.D2218 = 0;
+ // }
+ // break;
+ //}
LogHelper.Info($"璇粄ssx} WRelease=1&& rReleaseOver=1 WRelease 鍐�");
Conn.榛樿Redis.SetValue($"FNK1003051113.WRelease{ssx}", "0", $"FNK1003051113Queue");
}
@@ -1857,7 +1979,7 @@
if (tag.FNK1.D2217 == 1 && tag.FNK1.D2217_LAST == 0)
{
//tag.FNK1.D2215 = 0;
- tag.FNK1.D2218 = 1;
+ //tag.FNK1.D2218 = 1;
//tag.FNK1.D2212_LAST = 1;
RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.D2217_LAST", "1", out string msg);
@@ -1884,7 +2006,7 @@
LogHelper.Info($" FN1 D2212>{tag.FNK1.D2212} D2212LAST>{tag.FNK1.D2212_LAST} D2210>{tag.FNK1.D2210} D2211>{tag.FNK1.D2211} D2213>{tag.FNK1.D2213}");
if (tag.FNK1.D2212 == 1 && tag.FNK1.D2212_LAST == 0)
{
- tag.FNK1.D2213 = 1;
+ //tag.FNK1.D2213 = 1;
//tag.FNK1.D2210 = 0;
//tag.FNK1.D2217_LAST = 1;
RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.D2212_LAST", "1", out string msg);
@@ -1919,7 +2041,7 @@
if (tag.FNK2.D2217 == 1 && tag.FNK2.D2217_LAST == 0)
{
//tag.FNK2.D2215 = 0;
- tag.FNK2.D2218 = 1;
+ //tag.FNK2.D2218 = 1;
//tag.FNK2.D2212_LAST = 1;
RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.D2217_LAST", "1", out string msg);
@@ -1948,7 +2070,7 @@
if (tag.FNK2.D2212 == 1 && tag.FNK2.D2212_LAST == 0)
{
//tag.FNK2.D2210 = 0;
- tag.FNK2.D2213 = 1;
+ //tag.FNK2.D2213 = 1;
//tag.FNK2.D2217_LAST = 1;
RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.D2212_LAST", "1", out string msg);
@@ -1978,8 +2100,8 @@
{
var taggg = tag.SA1019;
string vqu = "A1019鍙栬揣浜や簰";
- Console.WriteLine($"1019浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
- if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
+ LogHelper.Info($"1019浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
+ if (taggg.SOver && taggg.SreadAgvover)
{
SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "鍐橝GV鐢宠");
SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "鍐橝GV鐢宠");
@@ -1991,18 +2113,38 @@
private void sa2008(Tag tag)
{
var rdisTcode = RedisHelper.Get<string>($"Arrive{2008}BarcodeLast", out string msg);
- //if(tag.ssx杈撻�绾�s2008)
+ LogHelper.Info($"2008 鎵樼洏鍙穥tag.SA2030.R鎵樼洏鐮亇 redis Arrive{2008}BarcodeLast鎵樼洏鍙凤細{rdisTcode} 鍖归厤鏍￠獙銆�);
+ if (!string.IsNullOrEmpty(tag.ssx杈撻�绾�s2008.R鎵樼洏鐮� && rdisTcode != tag.ssx杈撻�绾�s2008.R鎵樼洏鐮�
+ {
+ var ntr = tag.ssx杈撻�绾�s2008.R鎵樼洏鐮�
+ var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/224", JsonConvert.SerializeObject(new
+ {
+ cntrCode = ntr,
+ type = 1
+ }));
+ var strr = JsonConvert.DeserializeObject<MES2234>(str);
+ if (strr.success && strr.data != null)
+ {
+ var end = (strr.data.lineNum == 1 ? 2027
+ : strr.data.lineNum == 2 ? 2020 : 2013);
+ tag.ssx杈撻�绾�s2008.wTaskNo = (uint)(20080000 + end);
+ tag.ssx杈撻�绾�s2008.wEbit = 2027;
+ tag.ssx杈撻�绾�s2008.R鎵樼洏鐮�= ntr;
+ RedisHelper.Add<string>($"Arrive{2008}BarcodeLast", ntr, out msg);
+ }
+ }
}
private void sa2030(Tag tag)
{
var taggg = tag.SA2030;
string vqu = "A2030鍙栬揣浜や簰";
- Console.WriteLine($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
- if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
+ LogHelper.Info($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
+ if (taggg.SOver && taggg.SreadAgvover)
{
- SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "鍐橝GV鐢宠");
- SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "鍐橝GV鐢宠");
+ SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "娓匒GV鐢宠");
}
}
@@ -2010,11 +2152,12 @@
{
var taggg = tag.SA2001;
string vqu = "A2001鏀捐揣浜や簰";
- Console.WriteLine($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
- if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
+ LogHelper.Info($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
+ if (taggg.SOver && taggg.SreadAgvover)
{
- SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "鍐橝GV鐢宠");
- SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "鍐橝GV鐢宠");
+ SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "娓匒GV鐢宠");
}
}
@@ -2022,11 +2165,12 @@
{
var taggg = tag.SA1030;
string vqu = "A1030鍙栬揣浜や簰";
- Console.WriteLine($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
- if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
+ LogHelper.Info($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
+ if (taggg.SOver && taggg.SreadAgvover)
{
SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "鍐橝GV鐢宠");
SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "鍐橝GV鐢宠");
+ SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "鍐橝GV鐢宠");
}
}
@@ -2034,11 +2178,12 @@
{
var taggg = tag.SA1025;
string vqu = "A1025鏀捐揣浜や簰";
- Console.WriteLine($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
- if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
+ LogHelper.Info($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
+ if (taggg.SOver && taggg.SreadAgvover)
{
- SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "鍐橝GV鐢宠");
- SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "鍐橝GV鐢宠");
+ SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "娓匒GV鐢宠");
}
}
@@ -2046,11 +2191,12 @@
{
var taggg = tag.SA1022;
string vqu = "A1022鏀捐揣浜や簰";
- Console.WriteLine($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
- if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
+ LogHelper.Info($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
+ if (taggg.SOver && taggg.SreadAgvover)
{
- SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "鍐橝GV鐢宠");
- SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "鍐橝GV鐢宠");
+ SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "娓匒GV鐢宠");
}
}
@@ -2058,11 +2204,12 @@
{
var taggg = tag.ssx杈撻�绾�s3010;
string vqu = "A3010鍙栬揣浜や簰";
- Console.WriteLine($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
- if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
+ LogHelper.Info($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
+ if (taggg.SOver && taggg.SreadAgvover)
{
- SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "鍐橝GV鐢宠");
- SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "鍐橝GV鐢宠");
+ SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "娓匒GV鐢宠");
}
}
@@ -2070,11 +2217,12 @@
{
var taggg = tag.ssx杈撻�绾�s3006;
string vqu = "A3006鏀捐揣浜や簰";
- Console.WriteLine($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
- if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
+ LogHelper.Info($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
+ if (taggg.SOver && taggg.SreadAgvover)
{
- SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "鍐橝GV鐢宠");
- SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "鍐橝GV鐢宠");
+ SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "娓匒GV鐢宠");
}
}
@@ -2082,11 +2230,12 @@
{
var taggg = tag.ssx杈撻�绾�s3005;
string vqu = "A3005鍙栬揣浜や簰";
- Console.WriteLine($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
- if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
+ LogHelper.Info($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
+ if (taggg.SOver && taggg.SreadAgvover)
{
- SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "鍐橝GV鐢宠");
- SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "鍐橝GV鐢宠");
+ SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "娓匒GV鐢宠");
}
}
@@ -2094,11 +2243,12 @@
{
var taggg = tag.ssx杈撻�绾�s3010;
string vqu = "A3001鏀捐揣浜や簰";
- Console.WriteLine($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
- if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
+ LogHelper.Info($"{vqu}浠诲姟鐘舵�锛� =====>浠诲姟鐢宠锛歿taggg.Ssetreq},杈撻�绾垮厑璁革細{taggg.SreadCan} 浠诲姟瀹屾垚锛歿taggg.SOver} 杈撻�绾挎敹鍒板畬鎴愶細{taggg.SreadAgvover}");
+ if (taggg.SOver && taggg.SreadAgvover)
{
- SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "鍐橝GV鐢宠");
- SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "鍐橝GV鐢宠");
+ SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "娓匒GV鐢宠");
+ SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "娓匒GV鐢宠");
}
}
@@ -2124,7 +2274,19 @@
}
public void Thread1030Down(Tag tag)
{
- //Console.WriteLine($"SA1030 浠诲姟鐘舵�锛� =====>agv瀹屾垚SOver{tag.SA1030.SOver}");
+ Console.WriteLine($"SA1030 浠诲姟鐘舵�锛� =====>");
+ if (tag.SA1030.RtaskState == 4 && tag.SA1030.RtaskState_LAST == 0 && tag.SA2001.R5绌洪棽 == 5)
+ {
+ var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new
+ {
+ requestType = 10,
+ startBit = "1030",
+ endBit = "2001",
+ }));
+ RedisHelper.Add($"S1030Read.RtaskState_LAST", "1", out string msg);
+ }
+ else if (tag.SA1030.RtaskState != 4 && tag.SA1030.RtaskState_LAST == 1)
+ RedisHelper.Add($"S1030Read.RtaskState_LAST", "0", out string msg);
//if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
//{
// SetRedistoPlc("A1022鏀捐揣浜や簰.Ssetreq", "false", "A1022鏀捐揣浜や簰Queue", "娓呯悊");
@@ -2132,8 +2294,16 @@
//}
//Console.WriteLine($"SA1030 浠诲姟鐘舵�锛歿tag.SA1030.RtaskState}- 绌洪棽{tag.SA1030.R5绌洪棽}-->瀵瑰簲缁堢偣2001>绌洪棽5锛歿tag.SA2001.R5绌洪棽}");
}
+ static int i = 0;
public void Thread2030Down(Tag tag)
{
+ i++;
+ if (i > 2 * 3600 / 3)
+ {
+ Console.Clear();
+ LogHelper.Info($"寰幆{i}娆�> 娓呯┖鎺у埗鍙般�");
+ i = 0;
+ }
//Console.WriteLine($"SA2030 浠诲姟鐘舵�锛� =====>");
//Console.WriteLine($"SA2030 浠诲姟鐘舵�锛歿tag.SA2030.RtaskState}- 绌洪棽{tag.SA2030.R5绌洪棽} - barcode:{tag.SA2030.R鎵樼洏鐮亇");
@@ -2459,9 +2629,9 @@
case "1022":
{
type = "A008";
- if (tag.SA1022.R5绌洪棽 != 1)
+ if (tag.SA1022.R5绌洪棽 != 5)
{
- LogHelper.Info($"瑙ｉ噴MES浠诲姟 ->{task.S_TASK_NO} 缁堢偣1022 闈炵┖闂诧紝涓嶆帹閫�);
+ LogHelper.Info($"瑙ｉ噴MES浠诲姟 ->{task.S_TASK_NO} 缁堢偣1022 >{tag.SA1022.R5绌洪棽} 闈炵┖闂诧紝涓嶆帹閫�);
continue;
}
}
@@ -2469,9 +2639,9 @@
case "1025":
{
type = "A007";
- if (tag.SA1025.R5绌洪棽 != 1)
+ if (tag.SA1025.R5绌洪棽 != 5)
{
- LogHelper.Info($"瑙ｉ噴MES浠诲姟 ->{task.S_TASK_NO} 缁堢偣 1025 闈炵┖闂诧紝涓嶆帹閫�);
+ LogHelper.Info($"瑙ｉ噴MES浠诲姟 ->{task.S_TASK_NO} 缁堢偣 1025 >{tag.SA1025.R5绌洪棽} 闈炵┖闂诧紝涓嶆帹閫�);
continue;
}
}
@@ -2479,9 +2649,9 @@
case "2001":
{
type = "A007";
- if (tag.SA2001.R5绌洪棽 != 1)
+ if (tag.SA2001.R5绌洪棽 != 5)
{
- LogHelper.Info($"瑙ｉ噴MES浠诲姟 ->{task.S_TASK_NO} 缁堢偣 2001 闈炵┖闂诧紝涓嶆帹閫�);
+ LogHelper.Info($"瑙ｉ噴MES浠诲姟 ->{task.S_TASK_NO} 缁堢偣 2001>{tag.SA2001.R5绌洪棽} 闈炵┖闂诧紝涓嶆帹閫�);
continue;
}
}
@@ -2489,9 +2659,9 @@
case "3001":
{
type = "A010";
- if (tag.ssx杈撻�绾�s3001.R5绌洪棽 != 1)
+ if (tag.ssx杈撻�绾�s3001.R5绌洪棽 != 5)
{
- LogHelper.Info($"瑙ｉ噴MES浠诲姟 ->{task.S_TASK_NO} 缁堢偣 3001 闈炵┖闂诧紝涓嶆帹閫�);
+ LogHelper.Info($"瑙ｉ噴MES浠诲姟 ->{task.S_TASK_NO} 缁堢偣 3001>{tag.ssx杈撻�绾�s3001.R5绌洪棽} 闈炵┖闂诧紝涓嶆帹閫�);
continue;
}
}
@@ -2499,9 +2669,9 @@
case "3006":
{
type = "A010";
- if (tag.ssx杈撻�绾�s3006.R5绌洪棽 != 1)
+ if (tag.ssx杈撻�绾�s3006.R5绌洪棽 != 5)
{
- LogHelper.Info($"瑙ｉ噴MES浠诲姟 ->{task.S_TASK_NO} 缁堢偣 3006 闈炵┖闂诧紝涓嶆帹閫�);
+ LogHelper.Info($"瑙ｉ噴MES浠诲姟 ->{task.S_TASK_NO} 缁堢偣 3006>{tag.ssx杈撻�绾�s3001.R5绌洪棽} 闈炵┖闂诧紝涓嶆帹閫�);
continue;
}
}
@@ -2510,7 +2680,7 @@
LogHelper.Info($"瑙ｉ噴MES浠诲姟 ->{task.S_TASK_NO} 鐩存帴鐢熸垚瀵瑰簲浠诲姟");
//鐩存帴鐢熸垚瀵瑰簲浠诲姟銆�- var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, task.S_END_LOC, task.S_TYPE, 6, task.S_CNTRS?.Split(',').ToList() ?? new List<string>(), type);
+ var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, task.S_END_LOC, task.S_TYPE, 6, task.S_CNTRS?.Split(',').ToList() ?? new List<string>(), "AGV", type);
LogHelper.Info($"瑙ｉ噴MES浠诲姟 ->{task.S_TASK_NO} 鐩存帴鐢熸垚瀵瑰簲浠诲姟 缁撴灉锛歿res}");
if (res)
@@ -2655,7 +2825,7 @@
public string procNo()
{
- return TaskProcess.GenerateTaskNo("鏃ュ織娴佹按鍙�);
+ return TaskProcess.GenerateTaskNo("鏃ュ織娴佹按鍙�, "LOG");
}
public bool SetRedistoPlc(string key, string value, string queue, string desc)
{
@@ -3002,6 +3172,7 @@
{
requestType = 7,
startBit = VERX.location[0],
+ endBit = "1025",
unLockStartBitOutbin = true
}));
LogHelper.Info($"{VERX.location[0]}鐢宠mes浠诲姟缁撴灉{str}");
@@ -3025,6 +3196,7 @@
{
requestType = 7,
startBit = VERX.location[1],
+ endBit = "1025",
unLockStartBitOutbin = true
}));
LogHelper.Info($"{VERX.location[0]}鐢宠mes浠诲姟缁撴灉{str}");
@@ -3054,13 +3226,14 @@
LogHelper.Info("瀹氬瓙2鍙风嚎 deviceType 5 娌℃湁閰嶇疆銆�);
return;
}
- LogHelper.Info($" {VERX.deviceName} D2221>{tag.DZ1.D2221} D2221_LAST>{tag.DZ1.D2221_LAST} D2226>{tag.DZ1.D2226} D2226_LAST>{tag.DZ1.D2226_LAST}");
+ LogHelper.Info($" {VERX.deviceName} D2221>{tag.DZ2.D2221} D2221_LAST>{tag.DZ2.D2221_LAST} D2226>{tag.DZ2.D2226} D2226_LAST>{tag.DZ2.D2226_LAST}");
if (tag.DZ2.D2221 == 1 && tag.DZ2.D2221_LAST == 0)
{
var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new
{
requestType = 7,
startBit = VERX.location[0],
+ endBit = "1025",
unLockStartBitOutbin = true
}));
LogHelper.Info($"{VERX.location[0]}鐢宠mes浠诲姟缁撴灉{str}");
@@ -3083,6 +3256,7 @@
{
requestType = 7,
startBit = VERX.location[1],
+ endBit = "1025",
unLockStartBitOutbin = true
}));
LogHelper.Info($"{VERX.location[0]}鐢宠mes浠诲姟缁撴灉{str}");
--
Gitblit v1.9.1