| | |
|---|
| | | |
|---|
| | | public void Execute() |
|---|
| | | { |
|---|
| | | Logger.Scheduler.Info($"进入计划调度(名称:{Name})...\r\n"); |
|---|
| | | #region 固定写法 |
|---|
| | | Logger.Scheduler.Info($"/**\r\n *进入计划调度(名称: {Name} )....\r\n */\r\n"); //固定写法 |
|---|
| | | Schedule = JobManager.GetSchedule(Name); //固定写法 |
|---|
| | | StartTime = DateTime.Now; //固定写法 |
|---|
| | | #endregion |
|---|
| | | try |
|---|
| | | { |
|---|
| | | Schedule = JobManager.GetSchedule(Name); |
|---|
| | | StartTime = DateTime.Now; |
|---|
| | | string msg = ""; |
|---|
| | | string status = "Successed"; |
|---|
| | | GetJob(typeof(U9C_MES_GetCustomer).Name); |
|---|
| | | TskJobInput tskJobInput = CheckIFCanGo(); |
|---|
| | | TskJobInput tskJobInput = CheckHowToDo(); |
|---|
| | | if (tskJobInput.result) |
|---|
| | | { |
|---|
| | | var result = DI.Resolve<IU9C_MES>().GetCustomer(tskJobInput.input); |
|---|
| | |
|---|
| | | else |
|---|
| | | { |
|---|
| | | msg = $"从U9C获取客户信息成功:{result.Message}"; |
|---|
| | | Trig.LastRunTime = (tskJobInput.input.endTime.ToDateTime() - DateTime.Now).TotalMinutes > 0 ? Trig.LastRunTime : tskJobInput.input.endTime.ToDateTime(); |
|---|
| | | //固定写法 |
|---|
| | | Trig.LastRunTime = Args.ByInterval == "Y" ? tskJobInput.input.endTime.ToDateTime().AddHours(Args.Interval) : tskJobInput.input.endTime.ToDateTime(); |
|---|
| | | Trig.NextRunTime = Schedule.NextRun; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | SaveFluentSchedulerLog(status, $"{msg}"); |
|---|
| | | Logger.Scheduler.Info($"计划调度(名称:{Name})完成，返回信息:{msg}\r\n"); |
|---|
| | | Logger.Scheduler.Info($"计划调度(名称:{Name})完成，返回信息:{msg}\r\n"); |
|---|
| | | } |
|---|
| | | catch (System.Exception ex) |
|---|
| | | { |
|---|
| | | Logger.Scheduler.Fatal(ex, "获取客户信息异常"); |
|---|
| | | SaveFluentSchedulerLog("Failed", ex.Message); |
|---|
| | | } |
|---|
| | | Logger.Scheduler.Info($"/* 计划调度(名称:{Name})结束 */\r\n"); //固定写法 |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
