From 6b9e8c7ff2eef9b69e37ee383e243497e68d1f3c Mon Sep 17 00:00:00 2001 From: Tjiny <Tjinyu23@163.com> Date: 星期二, 24 六月 2025 13:40:34 +0800 Subject: [PATCH] 定时充电任务调度流程 --- HH.WCS.Mobox3.RiDong/Program.cs | 39 ++++++++++++++++++++++++++++++++++----- 1 files changed, 34 insertions(+), 5 deletions(-) diff --git a/HH.WCS.Mobox3.RiDong/Program.cs b/HH.WCS.Mobox3.RiDong/Program.cs index 936e939..c4e366d 100644 --- a/HH.WCS.Mobox3.RiDong/Program.cs +++ b/HH.WCS.Mobox3.RiDong/Program.cs @@ -6,16 +6,21 @@ using System.Threading.Tasks; using HH.WCS.Mobox3.RiDong.device; using HH.WCS.Mobox3.RiDong.generalMethod; +using HH.WCS.Mobox3.RiDong.Quartz; using HH.WCS.Mobox3.RiDong.util; using Microsoft.Owin.Hosting; +using Quartz; +using Quartz.Impl; using Topshelf; namespace HH.WCS.Mobox3.RiDong { internal class Program { - static void Main(string[] args) + static async Task Main(string[] args) { + // await QuartzJobCreate.CreateJob(); + Settings.Init(); //1.0 寮�惎api Startup(); @@ -35,9 +40,8 @@ x.SetDescription("hh123"); x.SetDisplayName("hh123.wms"); x.SetServiceName("hh123.wms"); - }); - + var exitCode = (int)Convert.ChangeType(rc, rc.GetTypeCode()); Environment.ExitCode = exitCode; } @@ -80,6 +84,7 @@ /// </summary> public class WorkThread { + public void Start() { List<Task> tasks = new List<Task> @@ -97,12 +102,14 @@ // Directory璇诲彇鏂囦欢锛屽苟澶勭悊 GetTask(DirectoryHelper.GainData), // 鍑哄簱agv浠诲姟鎺ㄩ� - GetTask(ThreadMenthod.DispatchFromAGV), + GetTaskS(ThreadMenthod.DispatchFromAGV), // 璇诲彇绾夸綋淇℃伅骞跺仛瀵瑰簲鐨勫鐞�- GetTask(ThreadMenthod.ReadConveyorlinesMessage) + GetTask(ThreadMenthod.ReadConveyorlinesMessage), }; Task.WaitAll(tasks.ToArray()); } + + public void Stop() { @@ -130,6 +137,28 @@ return task; } + + private Task GetTaskS(Action action) + { + var task = Task.Run(() => + { + while (true) + { + try + { + action(); + } + catch (Exception ex) + { + LogHelper.Error(ex.Message, ex); + } + + Thread.Sleep(600000); + } + }); + + return task; + } /// <summary> /// ftp涓婁紶涓庝笅杞� -- Gitblit v1.9.1