using Rhea.Common; using FluentScheduler; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks; using Tiger.IBusiness; using Tiger.Model; using Tiger.Model.Minsun; namespace Tiger.Business.MES { /// /// 从U9C获取客户条码信息 /// public class U9C_ME_GetCustSn : TigerJobBase, ITJob { public string Id { get; set; } = Guid.NewGuid().ToString("N"); public string Tag { get; set; } public string Name { get; set; } public U9C_ME_GetCustSn() { Id = Guid.NewGuid().ToString("N"); Tag = "U9C_ME_GetCustSn Interface Job"; GetJob(typeof(U9C_ME_GetCustSn).Name); Name = Job.JobName; } public void Execute() { Logger.Scheduler.Info($"进入计划调度(名称:{Name})...\r\n"); try { Schedule = JobManager.GetSchedule(Name); StartTime = DateTime.Now; string msg = ""; string status = "Successed"; GetJob(typeof(U9C_ME_GetCustSn).Name); TskJobInput tskJobInput = CheckIFCanGo(); if (tskJobInput.result) { var result = DI.Resolve().GetCustBarCode(tskJobInput.input); if (!result.IsSuccessed) { msg = $"获取客户条码信息异常:{result.Message}"; Logger.Scheduler.Error(msg); status = "Failed"; } else { msg = $"从U9C获取客户条码信息成功:{result.Message}"; Trig.LastRunTime = (tskJobInput.input.endTime.ToDateTime() - DateTime.Now).TotalMinutes > 0 ? Trig.LastRunTime : tskJobInput.input.endTime.ToDateTime(); } } SaveFluentSchedulerLog(status, $"{msg}"); Logger.Scheduler.Info($"计划调度(名称:{Name})完成,返回信息:{msg}\r\n"); } catch (System.Exception ex) { Logger.Scheduler.Fatal(ex, "获取客户条码信息异常"); SaveFluentSchedulerLog("Failed", ex.Message); } } } }