using FluentScheduler; using Rhea.Common; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using Tiger.IBusiness; using Tiger.Model; namespace Tiger.Business.WMS { /// /// 从U9获取调拨单 /// public class U9C_WMS_GetTransfer: TigerJobBase, ITJob { public string Id { get; set; } = Guid.NewGuid().ToString("N"); public string Tag { get; set; } public string Name { get; set; } public U9C_WMS_GetTransfer() { Id = Guid.NewGuid().ToString("N"); Tag = "U9C_WMS_GetTransfer Interface Job"; GetJob(typeof(U9C_WMS_GetTransfer).Name); Name = Job.JobName; } public void Execute() { #region 固定写法 Logger.Scheduler.Info($"/**\r\n *进入计划调度(名称: {Name} )....\r\n */\r\n"); //固定写法 Schedule = JobManager.GetSchedule(Name); //固定写法 StartTime = DateTime.Now; //固定写法 #endregion try { string msg = ""; string status = "Successed"; GetJob(typeof(U9C_WMS_GetTransfer).Name); TskJobInput tskJobInput = CheckHowToDo(); if (tskJobInput.result) { var result = DI.Resolve().In_GetTransfer(tskJobInput.input); if (!result.IsSuccessed) { msg = $"获取调拨单据信息异常:{result.Message}"; Logger.Scheduler.Error(msg); status = "Failed"; } else { msg = $"从U9C获取调拨单据信息成功:{result.Message}"; //固定写法 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"); } catch (System.Exception ex) { Logger.Scheduler.Fatal(ex, "获取调拨单据信息异常"); SaveFluentSchedulerLog("Failed", ex.Message); } Logger.Scheduler.Info($"/* 计划调度(名称:{Name})结束 */\r\n"); //固定写法 } } }