From 0f1a8431d6c8fbb4532818f95431a6b0f9b54a39 Mon Sep 17 00:00:00 2001
From: Ben Lin <maobin001@msn.com>
Date: 星期六, 26 十月 2024 18:54:24 +0800
Subject: [PATCH] 合并更新

---
 Tiger.Business.MES/Task/Jobs.U9C_ME_GetWo.cs |   76 ++++++++++++++++++++++++++++++++++---
 1 files changed, 69 insertions(+), 7 deletions(-)

diff --git a/Tiger.Business.MES/Task/Jobs.U9C_ME_GetWo.cs b/Tiger.Business.MES/Task/Jobs.U9C_ME_GetWo.cs
index fc9464d..0e538c0 100644
--- a/Tiger.Business.MES/Task/Jobs.U9C_ME_GetWo.cs
+++ b/Tiger.Business.MES/Task/Jobs.U9C_ME_GetWo.cs
@@ -1,5 +1,4 @@
 锘縰sing Rhea.Common;
-using Sundial;
 using System;
 using System.Collections.Generic;
 using System.Linq;
@@ -9,6 +8,8 @@
 using Tiger.IBusiness;
 using Tiger.Model;
 using Tiger.Model.Minsun;
+using FluentScheduler;
+using static Microsoft.CodeAnalysis.CSharp.SyntaxTokenParser;
 
 namespace Tiger.Business.MES
 {
@@ -17,13 +18,18 @@
     /// </summary>
     public class U9C_MES_GetWo : TigerJobBase, ITigerJob
     {
-        public U9C_MES_GetWo() {
+        public string Id { get; set; }
+        public string Tag { get; set; }
+        public string Name { get; set; }
+
+        public U9C_MES_GetWo()
+        {
             Id = Guid.NewGuid().ToString("N");
             Tag = "U9C_MES_GetWo Interface Job";
             Name = "U9C_MES_GetWo Interface Job";
         }
 
-        public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
+        public async Task ExecuteAsync(Sundial.JobExecutingContext context, CancellationToken stoppingToken)
         {
             Logger.Scheduler.Info(context.Trigger.ConvertToMonitor());
             try
@@ -56,13 +62,15 @@
     /// <summary>
     /// 浠嶶9C鑾峰彇宸ュ崟淇℃伅 FluentScheduler鐗�
     /// </summary>
-    public class fU9C_MES_GetWo : TigerJobBase, FluentScheduler.IJob
+    public class fU9C_MES_GetWo : TigerJobBase, ITJob
     {
+        public string Id { get; set; }
+        public string Tag { get; set; }
+        public string Name { get; set; } = typeof(fU9C_MES_GetWo).Name;
         public fU9C_MES_GetWo()
         {
             Id = Guid.NewGuid().ToString("N");
             Tag = "U9C_MES_GetWo Interface Job";
-            Name = "浠嶶9C鍚屾宸ュ崟淇℃伅";
         }
 
         public void Execute()
@@ -70,8 +78,62 @@
             Logger.Scheduler.Info($"杩涘叆璁″垝璋冨害(鍚嶇О:{Name})...\r\n");
             try
             {
+                string msg = "";
+                string status = "Successed";
                 var _lastRunTime = Biz.SysParam["GetWo_LastRun", "Interface_LastRun"].PARAM_VALUE;
                 var LastRunTime = string.IsNullOrEmpty(_lastRunTime) ? DateTime.Now.AddMinutes(-10) : Convert.ToDateTime(_lastRunTime);
+                StartTime = DateTime.Now;
+                if ((DateTime.Now - LastRunTime).TotalMinutes > 10)
+                {
+                    GetWoInput input = new GetWoInput
+                    {
+                        startTime = LastRunTime.ToString("yyyy-MM-dd HH:mm:ss"),
+                        endTime = LastRunTime.AddMinutes(10).ToString("yyyy-MM-dd HH:mm:ss")
+                    };
+                    //var result = DI.Resolve<IU9C_MES>().GetU9CBasWo(input);
+                    //if (!result.IsSuccessed)
+                    //{
+                    //    msg = $"鑾峰彇宸ュ崟淇℃伅寮傚父:{result.Message}";
+                    //    Logger.Scheduler.Error(msg);
+                    //    status = "Failed";
+                    //}
+                    //else
+                    //{
+                    //    msg = $"浠嶶9C鑾峰彇宸ュ崟淇℃伅鎴愬姛:{result.Message}";
+                    //}
+                }
+                SaveFluentSchedulerLog(Name, status, $"{msg}");
+                Logger.Scheduler.Info($"璁″垝璋冨害(鍚嶇О:{Name})瀹屾垚锛岃繑鍥炰俊鎭�:{msg}\r\n");
+            }
+            catch (System.Exception ex)
+            {
+                Logger.Scheduler.Fatal(ex, "鑾峰彇宸ュ崟淇℃伅寮傚父");
+                SaveFluentSchedulerLog(Name, "Failed", ex.Message);
+            }
+        }
+    }//endClass
+
+    public class fTest : TigerJobBase, ITJob
+    {
+        public string Id { get; set; }
+        public string Tag { get; set; }
+        public string Name { get; set; } = typeof(fTest).Name;
+        public fTest()
+        {
+            Id = Guid.NewGuid().ToString("N");
+            Tag = "U9C_MES_GetWo Interface Job";
+        }
+
+        public void Execute()
+        {
+            Logger.Scheduler.Info($"杩涘叆璁″垝璋冨害(鍚嶇О:{Name})...\r\n");
+            try
+            {
+                string msg = "";
+                string status = "Successed";
+                var _lastRunTime = Biz.SysParam["GetWo_LastRun", "Interface_LastRun"].PARAM_VALUE;
+                var LastRunTime = string.IsNullOrEmpty(_lastRunTime) ? DateTime.Now.AddMinutes(-10) : Convert.ToDateTime(_lastRunTime);
+                StartTime = DateTime.Now;
                 //if ((DateTime.Now - LastRunTime).TotalMinutes > 10)
                 //{
                 //    GetWoInput input = new GetWoInput
@@ -85,12 +147,12 @@
                 //        Logger.Scheduler.Error($"鑾峰彇宸ュ崟淇℃伅寮傚父:{result.Message}");
                 //    }
                 //}
-                //SaveLog(context, "浠嶶9C鑾峰彇宸ュ崟淇℃伅鎴愬姛");
+                SaveFluentSchedulerLog(Name, status, "娴嬭瘯浠诲姟鎴愬姛");
                 Logger.Scheduler.Info($"璁″垝璋冨害(鍚嶇О:{Name})瀹屾垚\r\n");
             }
             catch (System.Exception ex)
             {
-                Logger.Scheduler.Fatal(ex, "鑾峰彇宸ュ崟淇℃伅寮傚父");
+                Logger.Scheduler.Fatal(ex, "娴嬭瘯浠诲姟寮傚父\r\n");
             }
         }
     }

--
Gitblit v1.9.3