From 6d40f7c8b19efc612f824ee7e778d5be9f8382f5 Mon Sep 17 00:00:00 2001
From: Tjiny <Tjinyu23@163.com>
Date: 星期五, 11 七月 2025 17:04:03 +0800
Subject: [PATCH] 2025-07-11日提交

---
 HH.WCS.Mobox3.RiDong/Program.cs |   37 ++++++++++++++++++++++++++++++++-----
 1 files changed, 32 insertions(+), 5 deletions(-)

diff --git a/HH.WCS.Mobox3.RiDong/Program.cs b/HH.WCS.Mobox3.RiDong/Program.cs
index 936e939..c5a6b55 100644
--- a/HH.WCS.Mobox3.RiDong/Program.cs
+++ b/HH.WCS.Mobox3.RiDong/Program.cs
@@ -6,16 +6,22 @@
 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 +41,8 @@
                 x.SetDescription("hh123");
                 x.SetDisplayName("hh123.wms");
                 x.SetServiceName("hh123.wms");
-
             });
-
+            
             var exitCode = (int)Convert.ChangeType(rc, rc.GetTypeCode());
             Environment.ExitCode = exitCode;
         }
@@ -97,9 +102,9 @@
                     // Directory璇诲彇鏂囦欢锛屽苟澶勭悊
                     GetTask(DirectoryHelper.GainData),
                     // 鍑哄簱agv浠诲姟鎺ㄩ�
-                    GetTask(ThreadMenthod.DispatchFromAGV),
+                    GetTaskS(ThreadMenthod.DispatchFromAGV),
                     // 璇诲彇绾夸綋淇℃伅骞跺仛瀵瑰簲鐨勫鐞�-                    GetTask(ThreadMenthod.ReadConveyorlinesMessage)
+                    GetTask(ThreadMenthod.ReadConveyorlinesMessage),
                 };
                 Task.WaitAll(tasks.ToArray());
             }
@@ -130,6 +135,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