| | |
| | | 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) |
| | |
| | | { |
| | | JobManager.RemoveJob(jobname); |
| | | string guid = Guid.NewGuid().ToString("N"); |
| | | TSK_JOB job = Biz.Db.Queryable<TSK_JOB>().Where(x => x.JobName == jobname).First(); |
| | | var trigger = Biz.Db.Queryable<TSK_TRIG>().Where(x => x.JobId == job.ID).First(); |
| | | TSK_JOB job = Biz.Db.Queryable<TSK_JOB>().Where(x => x.JobName == jobname).IncludesAllFirstLayer().First(); |
| | | var trigger = job.Triggers[0]; |
| | | TrigArgs args = JsonConvert.DeserializeObject<TrigArgs>(job.Triggers[0].Args); |
| | | args.runType = RunType.ToRunNow; |
| | | JobManager.AddJob<TJob>((s) => GenerateSchedule(args, s.WithName(jobname))); |