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
|
{
|
/// <summary>
|
/// XCXJ据点到货单推T100
|
/// </summary>
|
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<SYS_ORGANIZATION>().ToList();
|
foreach (var company in companys)
|
{
|
var result = DI.Resolve<IErpT100>().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;
|
}
|
}
|
}
|
