From b079910e5de15863c26e479ffab15cc45d706f1a Mon Sep 17 00:00:00 2001
From: kazelee <1847801760@qq.com>
Date: 星期一, 19 五月 2025 16:25:22 +0800
Subject: [PATCH] 测试修复轮询出库、抽检流程的问题
---
Program.cs | 22 +++++++++-------------
1 files changed, 9 insertions(+), 13 deletions(-)
diff --git a/Program.cs b/Program.cs
index 21fa639..d201d83 100644
--- a/Program.cs
+++ b/Program.cs
@@ -127,24 +127,20 @@
{
List<Task> tasks = new List<Task>();
- tasks.Add(GetTask(OutboundCore.CheckOutboundOrder));
+ // 杞锛氬嚭搴撳崟鐘舵�
+ tasks.Add(GetTask(OutboundCore.CheckOrderState));
- tasks.Add(GetTask(OutboundCore.CheckOutboundTask));
+ // 杞锛氭娊妫�崟鐘舵�
+ tasks.Add(GetTask(CheckCore.CheckOrderState));
-
- // 娣诲姞浠诲姟鎺ㄩ�绾跨▼
- //tasks.Add(GetTask(WCSCore.Dispatch));
-
- // 娣诲姞鑷畾涔夌嚎绋�- //tasks.Add(GetTask(Monitor.CheckEmptyCnt));//妫�祴绌烘墭鐩�-
- // 鏍规嵁S7/Modbus鍗忚鍒ゆ柇杈撻�绾跨殑淇″彿 鍘熸潗鏂欎骇绾垮簱鍖�>婊℃墭缂撳瓨搴撳尯锛岀┖鎵樼紦瀛樺簱鍖�>鍘熸潗鏂欎骇绾垮簱鍖�- //tasks.Add(GetTask(Monitor.CheckS7Devices));
+ // 杞锛氱Щ搴撳崟鐘舵�
+ tasks.Add(GetTask(ShiftCore.CheckOrderState));
Task.WaitAll(tasks.ToArray());
}
public void Stop() { Console.WriteLine("work stopped"); }
- private Task GetTask(Action action)
+
+ private Task GetTask(Action action, int intervalMs = 3000)
{
var task = Task.Run(() =>
{
@@ -158,7 +154,7 @@
{
LogHelper.Error(ex.Message, ex);
}
- Thread.Sleep(3000);
+ Thread.Sleep(intervalMs);
}
});
return task;
--
Gitblit v1.9.1