| | |
| | | trig = Biz.Db.Queryable<TSK_TRIG>().Where(q => q.JobId == job.ID).First(); |
| | | trig.Status = TSK_TRIG.Statuss.Running.GetValue(); |
| | | trig.StartTime = DateTime.Now; |
| | | trig.NextRunTime = schedule.NextRun; |
| | | listTrig.Add(trig); |
| | | } |
| | | } |
| | |
| | | var jobs = Biz.Db.Queryable<TSK_JOB>().IncludesAllFirstLayer().ToList(); |
| | | foreach (var job in jobs) |
| | | { |
| | | //if (job.JobName == "fU9C_MES_GetWo" || job.JobName == "fTest") |
| | | { |
| | | Type type = Type.GetType($"{job.AssemblyName}.{job.JobType},{job.AssemblyName}", throwOnError: true); |
| | | dynamic _type = Activator.CreateInstance(type); |
| | | TrigArgs args = JsonConvert.DeserializeObject<TrigArgs>(job.Triggers[0].Args); |
| | | Schedule schedule = Schedule(_type, job.JobName, registry); |
| | | //生成计划 |
| | | GenerateSchedule(args, schedule); |
| | | } |
| | | Type type = Type.GetType($"{job.AssemblyName}.{job.JobType},{job.AssemblyName}", throwOnError: true); |
| | | dynamic _type = Activator.CreateInstance(type); |
| | | TrigArgs args = JsonConvert.DeserializeObject<TrigArgs>(job.Triggers[0].Args); |
| | | Schedule schedule = Schedule(_type, job.JobName, registry); |
| | | //生成计划 |
| | | GenerateSchedule(args, schedule); |
| | | } |
| | | } |
| | | catch (System.Exception ex) |