2023-10-12

SGGL/BLL/TaskScheduling/TimerTask/TaskJob.cs

@@ -22,6 +22,27 @@ namespace BLL
               InterFaceTaskService.ExecuteTasks(InterFaceTaskId);
  
 
+                //Console.WriteLine($"{DateTime.Now}【{Thread.CurrentThread.ManagedThreadId}】：自定义的工作正在执行... ...");
+            });
+        }
+    }
+    public class CLJob : IJob
+    {
+        public async Task Execute(IJobExecutionContext context)
+        {
+            JobKey key = context.JobDetail.Key;
+
+            // note: use context.MergedJobDataMap in production code
+            JobDataMap dataMap = context.JobDetail.JobDataMap;
+            string InterFaceTaskId = dataMap.GetString("InterFaceTaskId");
+
+            //使用异步任务来实现
+            await Task.Run(() =>
+            {
+                MonitorService.PipelineWeldingQuantities();
+
+
+
                 //Console.WriteLine($"{DateTime.Now}【{Thread.CurrentThread.ManagedThreadId}】：自定义的工作正在执行... ...");
             });
         }

SGGL/BLL/TaskScheduling/TimerTask/TimerTaskBase.cs

@@ -40,6 +40,8 @@ using System.Threading.Tasks;
                 //keyValuePairs.Add(item.InterFaceTaskId, scheduler);
                 //Funs.ScheduledTasks = keyValuePairs;
             }
+
+           //// jobAndTriggerMapping[GetClJobDetail()] = GetClTrigger();//增加材料定时
             var readOnlyjobAndTriggerMapping = new ReadOnlyDictionary<IJobDetail, IReadOnlyCollection<ITrigger>>(jobAndTriggerMapping);
             await scheduler.ScheduleJobs(readOnlyjobAndTriggerMapping, true);
             await scheduler.Start(); //只有启动了，里面的任务才会定时触发
@@ -159,6 +161,37 @@ using System.Threading.Tasks;
             return trigger1;
 
         }
+
+        #region 材料到货
+
+        public static IJobDetail GetClJobDetail()
+        { //创建Job
+            IJobDetail jobDetail1 = JobBuilder.Create<CLJob>()
+                .WithIdentity("CL", "group1")//给Job身份
+                .WithDescription("任务的描述，方便查找")
+                .Build();
+            return jobDetail1;
+        }
+        public static ReadOnlyCollection<ITrigger> GetClTrigger()
+        {
+            string cron = "0 0/1 * * * ? ";
+              cron = "0 0/1 * * * ? ";
+            //创建触发器
+            var trigger1 = new ReadOnlyCollection<ITrigger>(
+                new List<ITrigger>()
+                {
+                    TriggerBuilder.Create()
+                        .WithIdentity("CL", "group1") //给触发器身份
+                        .WithDescription("触发器的描述，方便查找")
+                        .StartAt(new DateTimeOffset(DateTime.Now.AddSeconds(10))) //.StartNow()都是启动触发器方式
+                        .WithCronSchedule(cron) //定时策略，Cron表达式
+                        .Build()
+                });
+            return trigger1;
+
+        }
+
+        #endregion
     }
  }