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