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.WMS { /// /// XCXJ据点到货单推T100 /// public class VenderFromErpXCSJJob : TigerJobBase, ITigerJob { public string Id { get; set; } = Guid.NewGuid().ToString("N"); public string Tag { get; set; } = "Vender info From Erp Interface Job"; public string Name { get; set; } = "Vender info From Erp Interface Job"; public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken) { Logger.Scheduler.Info(context.Trigger.ConvertToMonitor()); try { var _lastRunTime = Biz.SysParam["Vender_LastTime"].PARAM_VALUE; var LastRunTime = string.IsNullOrEmpty(_lastRunTime) ? DateTime.Now.AddDays(-1) : Convert.ToDateTime(_lastRunTime); if ((DateTime.Now - LastRunTime).TotalDays >= 1) { var companys = Biz.Db.Queryable().ToList(); foreach (var company in companys) { var result = DI.Resolve().GetVenderInfoToDDL(new iVenderParams { company = company.ORG_CODE, startDate = LastRunTime.ToString("yyyy-MM-dd"), endDate = LastRunTime.AddDays(1).ToString("yyyy-MM-dd") }); if (!result.IsSuccessed) { Logger.Scheduler.Error($"据点:{company.ORG_CODE}拉取供应商资料异常:{result.Message}"); } SaveLog(context, $"{company.ORG_CODE}据点供应商资料获取成功"); } } } catch (System.Exception ex) { Logger.Scheduler.Fatal(ex, "拉取供应商信息异常"); } await Task.CompletedTask; } } }