using Rhea.Common; using Sundial; 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_MES_GetCustomer : TigerJobBase, ITigerJob { public string Id { get; set; } = Guid.NewGuid().ToString("N"); public string Tag { get; set; } = "U9C_MES_GetCustomer Interface Job"; public string Name { get; set; } = "U9C_MES_GetCustomer Interface Job"; public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken) { Logger.Scheduler.Info(context.Trigger.ConvertToMonitor()); try { var _lastRunTime = Biz.SysParam["GetCust_LastRun", "Interface_LastRun"].PARAM_VALUE; var LastRunTime = string.IsNullOrEmpty(_lastRunTime) ? DateTime.Now.AddDays(-1) : Convert.ToDateTime(_lastRunTime); if ((DateTime.Now - LastRunTime).TotalDays > 1) { GetCustomerInput input = new GetCustomerInput { startTime = LastRunTime.ToString("yyyy-MM-dd HH:mm:ss"), endTime = LastRunTime.AddDays(1).ToString("yyyy-MM-dd HH:mm:ss") }; var result = await DI.Resolve().GetCustomer(input); if (!result.IsSuccessed) { Logger.Scheduler.Error($"获取客户信息异常:{result.Message}"); } } //SaveLog(context, "从U9C获取客户信息成功"); } catch (System.Exception ex) { Logger.Scheduler.Fatal(ex, "获取客户信息异常"); } await Task.CompletedTask; } } }