From 4a91e38c8839978e10e0ddf0c447f983227f21f7 Mon Sep 17 00:00:00 2001
From: Ben Lin <maobin001@msn.com>
Date: 星期六, 26 十月 2024 11:14:10 +0800
Subject: [PATCH] 计划任务更新

---
 Tiger.Business.MES/Task/TskJob.cs |   20 ++++++++++++++------
 1 files changed, 14 insertions(+), 6 deletions(-)

diff --git a/Tiger.Business.MES/Task/TskJob.cs b/Tiger.Business.MES/Task/TskJob.cs
index 5215a8e..6c5d1f9 100644
--- a/Tiger.Business.MES/Task/TskJob.cs
+++ b/Tiger.Business.MES/Task/TskJob.cs
@@ -11,6 +11,7 @@
 using FluentScheduler;
 using Newtonsoft.Json;
 using static Tiger.Model.TrigArgs;
+using System.Reflection;
 
 namespace Tiger.Business.MES
 {
@@ -29,12 +30,13 @@
             var result = new ApiAction();
             try
             {
-                var _job = Biz.Db.Queryable<TSK_JOB>().Where(x => x.JobName == input.JobName).First()??new() { 
-                    JobName = input.JobName,
+                var _job = Biz.Db.Queryable<TSK_JOB>().Where(x => x.JobName == input.JobType).First()??new() { 
+                    JobName = input.JobType,
                     JobType = input.JobType,
                     AssemblyName = input.AssemblyName,
-                    Remark = input.Remark,
                 };
+                _job.Remark = input.Remark;
+
                 //璁″垝浠诲姟鍙傛暟
                 var Args = new TrigArgs()
                 {
@@ -49,23 +51,29 @@
                     Hours = input.Hours,
                     Days = input.Days,
                 };
-                TSK_TRIG tskTrig = new TSK_TRIG()
+                TSK_TRIG tskTrig = Biz.Db.Queryable<TSK_TRIG>().Where(x => x.JobId == _job.ID).First() ?? new()
                 {
                     JobId = _job.ID,
-                    Args = JsonConvert.SerializeObject(Args),
                     Status = TSK_TRIG.Statuss.Ready.GetValue(),
                     StartTime = DateTime.Now,
                     NumberOfRuns = 1,
                 };
+                tskTrig.Args = JsonConvert.SerializeObject(Args);
 
                 var db = Biz.Db;
                 var dbTran = db.UseTran(() =>
                 {
                     var y = db.Storageable(_job)
-                       .WhereColumns(t => new { t.JobName, t.GHOST_ROW })
+                       .WhereColumns(t => new { t.JobName,t.GHOST_ROW })
                        .ToStorage();
                     y.AsInsertable.ExecuteCommand();
                     y.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
+
+                    var z = db.Storageable(tskTrig)
+                       .WhereColumns(t => new { t.JobId, t.GHOST_ROW })
+                       .ToStorage();
+                    z.AsInsertable.ExecuteCommand();
+                    z.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
                 });
                 if (!dbTran.IsSuccess)
                 {

--
Gitblit v1.9.3