using Autofac;
|
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.Entitys.WMS.DTOS;
|
using Tiger.Model.Minsun;
|
|
namespace Tiger.Business.WMS
|
{
|
/// <summary>
|
/// XCXJ据点到货单推T100
|
/// </summary>
|
public class ReceiptHToErpXCSJJob : TigerJobBase, ITigerJob
|
{
|
public string Id { get; set; } = Guid.NewGuid().ToString("N");
|
public string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
public string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
try
|
{
|
var result = iWMS.ReceiptHToErp("XCSJ", context.Trigger.ConvertToMonitor());
|
if (!result.IsSuccessed)
|
{
|
Logger.Scheduler.Error($"生成到货异常:{result.Message}");
|
}
|
//SaveLog(context, "XCXJ据点到货单推T100");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "生成到货单异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
/// DGXC据点到货单推T100
|
/// </summary>
|
public class ReceiptHToErpDGXCJob : TigerJobBase, ITigerJob
|
{
|
public string Id { get; set; } = Guid.NewGuid().ToString("N");
|
public string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
public string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
try
|
{
|
var result = iWMS.ReceiptHToErp("DGXC", context.Trigger.ConvertToMonitor());
|
//Thread.Sleep(10*60*1000);
|
if (!result.IsSuccessed)
|
{
|
Logger.Scheduler.Error($"生成到货异常:{result.Message}");
|
}
|
//SaveLog(context, "DGXC据点到货单推T100");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "生成到货单异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
/// AHXC据点到货单推T100
|
/// </summary>
|
public class ReceiptHToErpAHXCJob : TigerJobBase, ITigerJob
|
{
|
public string Id { get; set; } = Guid.NewGuid().ToString("N");
|
public string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
public string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
try
|
{
|
var result = iWMS.ReceiptHToErp("AHXC", context.Trigger.ConvertToMonitor());
|
if (!result.IsSuccessed)
|
{
|
Logger.Scheduler.Error($"生成到货异常:{result.Message}");
|
}
|
//SaveLog(context, "AHXC据点到货单推T100");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "生成到货单异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
/// 从T100获取物料信息
|
/// </summary>
|
public class MaterialInfoToT100Job : TigerJobBase, ITigerJob
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public new string Id { get; set; } = Guid.NewGuid().ToString("N");
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
/// <summary>
|
///
|
/// </summary>
|
private readonly IMaterialInfoBusiness _materialInfoBusiness = BizContext.Container.Resolve<IMaterialInfoBusiness>();
|
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
/// <param name="materialInfoBusiness"></param>
|
//public MaterialInfoToT100Job(IMaterialInfoBusiness materialInfoBusiness)
|
//{
|
// _materialInfoBusiness = materialInfoBusiness;
|
//}
|
|
/// <summary>
|
/// 同步物料信息定时任务
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="stoppingToken"></param>
|
/// <returns></returns>
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
var starttime = DateTime.Now;
|
try
|
{
|
Logger.Scheduler.Info(context.Trigger.ConvertToMonitor()); //计划任务开始日志
|
foreach (var item in BIZ_WMS_TRANSFER.strongHoldList)
|
{
|
var model = new InputDTO()
|
{
|
site = item,
|
startdt = starttime.AddHours(-24),
|
enddt = starttime
|
};
|
var result = _materialInfoBusiness.GetMaterialFromT100(model);
|
}
|
|
SaveLog(context, "同步T100物料信息数据");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "同步T100物料信息数据异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
/// 从T100获取物料信息
|
/// </summary>
|
public class PurchaseInfoFromT100Job : TigerJobBase, ITigerJob
|
{
|
#region 常量
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Id { get; set; } = Guid.NewGuid().ToString("N");
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
#endregion 常量
|
|
#region DI
|
|
/// <summary>
|
///
|
/// </summary>
|
private readonly IMaterialInfoBusiness _materialInfoBusiness = BizContext.Container.Resolve<IMaterialInfoBusiness>();
|
|
///// <summary>
|
///// 构造函数
|
///// </summary>
|
///// <param name="materialInfoBusiness"></param>
|
//public PurchaseInfoFromT100Job(IMaterialInfoBusiness materialInfoBusiness)
|
//{
|
// _materialInfoBusiness = materialInfoBusiness;
|
//}
|
|
#endregion DI
|
|
/// <summary>
|
/// 同步物料信息定时任务
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="stoppingToken"></param>
|
/// <returns></returns>
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
var starttime = DateTime.Now;
|
try
|
{
|
Logger.Scheduler.Info(context.Trigger.ConvertToMonitor());
|
var orgList = WMS_ITEMExtension.GetOrgList();
|
foreach (var item in orgList)
|
{
|
var model = new InputDTO()
|
{
|
site = item,
|
startdt = starttime.AddHours(-24),
|
enddt = starttime
|
};
|
var result = _materialInfoBusiness.GetPurchaseInfoFromT100(model);
|
}
|
SaveLog(context, "同步T100采购单信息数据");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "同步T100采购单信息数据异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
///
|
/// </summary>
|
public class CustomerInfoFromT100 : TigerJobBase, ITigerJob
|
{
|
#region 常量
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Id { get; set; } = Guid.NewGuid().ToString("N");
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
#endregion 常量
|
|
#region DI
|
|
/// <summary>
|
///
|
/// </summary>
|
private readonly IMaterialInfoBusiness _materialInfoBusiness = BizContext.Container.Resolve<IMaterialInfoBusiness>();
|
|
///// <summary>
|
///// 构造函数
|
///// </summary>
|
///// <param name="materialInfoBusiness"></param>
|
//public CustomerInfoFromT100(IMaterialInfoBusiness materialInfoBusiness)
|
//{
|
// _materialInfoBusiness = materialInfoBusiness;
|
//}
|
|
#endregion DI
|
|
/// <summary>
|
/// 同步采购单信息定时任务
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="stoppingToken"></param>
|
/// <returns></returns>
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
var starttime = DateTime.Now;
|
try
|
{
|
Logger.Scheduler.Info(context.Trigger.ConvertToMonitor());
|
var orgList = WMS_ITEMExtension.GetOrgList();
|
foreach (var item in orgList)
|
{
|
var model = new InputDTO()
|
{
|
site = item,
|
startdt = starttime.AddHours(-24),
|
enddt = starttime
|
};
|
var result = _materialInfoBusiness.GetCustomerInfoFromT100(model);
|
}
|
|
SaveLog(context, "同步T10采购单信息数据");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "同步T100采购单信息数据异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
///
|
/// </summary>
|
public class InspectionNoInfoFromT100 : TigerJobBase, ITigerJob
|
{
|
#region 常量
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Id { get; set; } = Guid.NewGuid().ToString("N");
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
#endregion 常量
|
|
#region DI
|
|
/// <summary>
|
///
|
/// </summary>
|
private readonly IMaterialInfoBusiness _materialInfoBusiness = BizContext.Container.Resolve<IMaterialInfoBusiness>();
|
|
#endregion DI
|
|
/// <summary>
|
/// 同步送检单信息定时任务
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="stoppingToken"></param>
|
/// <returns></returns>
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
var starttime = DateTime.Now;
|
try
|
{
|
var result = _materialInfoBusiness.GetInspectionNoFromT100();
|
SaveLog(context, "同步T100送检单信息数据");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "同步T100采购单信息数据异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
/// 其他出库单定时推送给T100——过账
|
/// </summary>
|
public class OtherOutInfoToT100 : TigerJobBase, ITigerJob
|
{
|
#region 常量
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Id { get; set; } = Guid.NewGuid().ToString("N");
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
#endregion 常量
|
|
#region DI
|
|
/// <summary>
|
///
|
/// </summary>
|
private readonly IMaterialInfoBusiness _materialInfoBusiness = BizContext.Container.Resolve<IMaterialInfoBusiness>();
|
|
#endregion DI
|
|
/// <summary>
|
/// 同步其他出库单单信息定时任务
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="stoppingToken"></param>
|
/// <returns></returns>
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
var starttime = DateTime.Now;
|
try
|
{
|
var orgList = WMS_ITEMExtension.GetOrgList();
|
foreach (var item in orgList)
|
{
|
var model = new InputDTO()
|
{
|
site = item
|
};
|
var result = _materialInfoBusiness.GetOtherOutInfoToT100(model);
|
}
|
|
SaveLog(context, "同步T100调拨单信息数据");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "同步T100调拨单信息数据异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
/// 其他出库单定时推送给T100——过账
|
/// </summary>
|
public class SaaleOutInfoToT100 : TigerJobBase, ITigerJob
|
{
|
#region 常量
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Id { get; set; } = Guid.NewGuid().ToString("N");
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
#endregion 常量
|
|
#region DI
|
|
/// <summary>
|
///
|
/// </summary>
|
private readonly IMaterialInfoBusiness _materialInfoBusiness = BizContext.Container.Resolve<IMaterialInfoBusiness>();
|
|
#endregion DI
|
|
/// <summary>
|
/// 同步送检单信息定时任务
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="stoppingToken"></param>
|
/// <returns></returns>
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
var starttime = DateTime.Now;
|
try
|
{
|
var orgList = WMS_ITEMExtension.GetOrgList();
|
foreach (var item in orgList)
|
{
|
var model = new InputDTO()
|
{
|
site = item
|
};
|
var result = _materialInfoBusiness.PutSaleOutInfoToT100(model);
|
}
|
|
SaveLog(context, "同步T100调拨单信息数据");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "同步T100调拨单信息数据异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
/// 过账调拨单定时推送给T100——创单并过账
|
/// </summary>
|
public class TrasferInfoToT100 : TigerJobBase, ITigerJob
|
{
|
#region 常量
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Id { get; set; } = Guid.NewGuid().ToString("N");
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
#endregion 常量
|
|
#region DI
|
|
/// <summary>
|
///
|
/// </summary>
|
private readonly IMaterialInfoBusiness _materialInfoBusiness = BizContext.Container.Resolve<IMaterialInfoBusiness>();
|
|
#endregion DI
|
|
/// <summary>
|
/// 过账调拨单定时推送给T100——创单并过账
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="stoppingToken"></param>
|
/// <returns></returns>
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
var starttime = DateTime.Now;
|
try
|
{
|
var orgList = WMS_ITEMExtension.GetOrgList();
|
var DB = Biz.Db;
|
var jobData = DB.Queryable<TSK_JOB>().Where(i => i.JobName == "TrasferInfoToT100").First();// 获取定时任务内容
|
if (!jobData.IsNullOrEmpty() && jobData.ISRUNNING == 1)
|
{
|
Logger.Scheduler.Info("调拨定时任务正在执行中，本次任务已主动终止！");
|
//throw new Exception("调拨定时任务正在执行中，本次任务已主动终止！");
|
}
|
else
|
{
|
jobData.ISRUNNING = 1;
|
DB.Updateable(jobData).ExecuteCommand();// 如果当前定时任务不在执行中的状态，则在开始执行前，设定为执行中
|
}
|
foreach (var item in orgList)
|
{
|
var model = new InputDTO()
|
{
|
site = item
|
};
|
var result = _materialInfoBusiness.GetTrasferInfoToT100(model);
|
}
|
|
SaveLog(context, "同步T100调拨单信息数据");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "同步T100调拨单信息数据异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
/// 过账调拨单定时推送给T100——直接过账
|
/// </summary>
|
public class TrasferInfoToT100Plan2 : TigerJobBase, ITigerJob
|
{
|
#region 常量
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Id { get; set; } = Guid.NewGuid().ToString("N");
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
#endregion 常量
|
|
#region DI
|
|
/// <summary>
|
///
|
/// </summary>
|
private readonly IMaterialInfoBusiness _materialInfoBusiness = BizContext.Container.Resolve<IMaterialInfoBusiness>();
|
|
#endregion DI
|
|
/// <summary>
|
/// 过账调拨单定时推送给T100——直接过账
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="stoppingToken"></param>
|
/// <returns></returns>
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
var starttime = DateTime.Now;
|
try
|
{
|
var orgList = WMS_ITEMExtension.GetOrgList();
|
foreach (var item in orgList)
|
{
|
var model = new InputDTO()
|
{
|
site = item
|
};
|
var result = _materialInfoBusiness.GetTrasferInfoToT100Plan2(model);
|
}
|
|
SaveLog(context, "同步T100调拨单信息数据");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "同步T100调拨单信息数据异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
/// 过账调拨单定时推送给T100
|
/// </summary>
|
public class TrasferInfoFromT100 : TigerJobBase, ITigerJob
|
{
|
#region 常量
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Id { get; set; } = Guid.NewGuid().ToString("N");
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
#endregion 常量
|
|
#region DI
|
|
/// <summary>
|
///
|
/// </summary>
|
private readonly IMaterialInfoBusiness _materialInfoBusiness = BizContext.Container.Resolve<IMaterialInfoBusiness>();
|
|
#endregion DI
|
|
/// <summary>
|
/// 同步送检单信息定时任务
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="stoppingToken"></param>
|
/// <returns></returns>
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
var starttime = DateTime.Now;
|
try
|
{
|
var orgList = WMS_ITEMExtension.GetOrgList();
|
foreach (var item in orgList)
|
{
|
var model = new InputDTO()
|
{
|
site = item,
|
startdt = starttime.AddHours(-24),
|
enddt = starttime
|
};
|
var result = _materialInfoBusiness.GetTrasferInfoFromT100(model);
|
}
|
SaveLog(context, "同步T100调拨单信息数据");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "同步T100调拨单信息数据异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
/// 过账调拨单定时推送给T100
|
/// </summary>
|
public class OtheroUTInfoFromT100 : TigerJobBase, ITigerJob
|
{
|
#region 常量
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Id { get; set; } = Guid.NewGuid().ToString("N");
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
#endregion 常量
|
|
#region DI
|
|
/// <summary>
|
///
|
/// </summary>
|
private readonly IMaterialInfoBusiness _materialInfoBusiness = BizContext.Container.Resolve<IMaterialInfoBusiness>();
|
|
#endregion DI
|
|
/// <summary>
|
/// 同步送检单信息定时任务
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="stoppingToken"></param>
|
/// <returns></returns>
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
var starttime = DateTime.Now;
|
try
|
{
|
var orgList = WMS_ITEMExtension.GetOrgList();
|
foreach (var item in orgList)
|
{
|
var model = new InputDTO()
|
{
|
site = item,
|
startdt = starttime.AddHours(-24),
|
enddt = starttime
|
};
|
var result = _materialInfoBusiness.GetOtherOutInfoFromT100(model);
|
}
|
|
SaveLog(context, "同步T100调拨单信息数据");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "同步T100调拨单信息数据异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
///
|
/// </summary>
|
public class WarehouseCodeInfoFromT100 : TigerJobBase, ITigerJob
|
{
|
#region 常量
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Id { get; set; } = Guid.NewGuid().ToString("N");
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
#endregion 常量
|
|
#region DI
|
|
/// <summary>
|
///
|
/// </summary>
|
private readonly IMaterialInfoBusiness _materialInfoBusiness = BizContext.Container.Resolve<IMaterialInfoBusiness>();
|
|
#endregion DI
|
|
/// <summary>
|
/// 同步仓库信息定时任务
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="stoppingToken"></param>
|
/// <returns></returns>
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
var starttime = DateTime.Now;
|
try
|
{
|
Logger.Scheduler.Info(context.Trigger.ConvertToMonitor());
|
var orgList = WMS_ITEMExtension.GetOrgList();
|
foreach (var item in orgList)
|
{
|
var model = new InputDTO()
|
{
|
site = item,
|
startdt = starttime.AddHours(-24),
|
enddt = starttime
|
};
|
var result = _materialInfoBusiness.GetWarehouseCodeInfoFromT100(model);
|
}
|
SaveLog(context, "同步T100仓库代码信息数据");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "同步T100仓库代码信息数据异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
/// 从MES获取成品入库信息
|
/// </summary>
|
public class ProductInputInfoFromT100 : TigerJobBase, ITigerJob
|
{
|
#region 常量
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Id { get; set; } = Guid.NewGuid().ToString("N");
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
#endregion 常量
|
|
#region DI
|
|
/// <summary>
|
///
|
/// </summary>
|
private readonly IMaterialInfoBusiness _materialInfoBusiness = BizContext.Container.Resolve<IMaterialInfoBusiness>();
|
|
#endregion DI
|
|
/// <summary>
|
/// 同步MES成品入库信息定时任务
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="stoppingToken"></param>
|
/// <returns></returns>
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
var starttime = DateTime.Now;
|
try
|
{
|
var DB = Biz.Db;
|
var jobData = DB.Queryable<TSK_JOB>().Where(i => i.JobName == "ProductInputInfoFromT100").First();// 获取定时任务内容
|
if (!jobData.IsNullOrEmpty() && jobData.ISRUNNING == 1)
|
{
|
Logger.Scheduler.Info("成品入库定时任务正在执行中，本次任务已主动终止！");
|
return;
|
//throw new Exception("成品入库定时任务正在执行中，本次任务已主动终止！");
|
}
|
else
|
{
|
jobData.ISRUNNING = 1;
|
DB.Updateable(jobData).ExecuteCommand();// 如果当前定时任务不在执行中的状态，则在开始执行前，设定为执行中
|
}
|
var result = _materialInfoBusiness.ProductInputInfoFromT100();
|
|
SaveLog(context, "同步MES成品入库信息数据成功");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "同步MES成品入库信息数据异常");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
|
/// <summary>
|
/// 物料超期预警
|
/// </summary>
|
public class MaterialExtended : TigerJobBase, ITigerJob
|
{
|
#region 常量
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Id { get; set; } = Guid.NewGuid().ToString("N");
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Tag { get; set; } = "Receipt Header To Erp Interface Job";
|
|
/// <summary>
|
///
|
/// </summary>
|
public new string Name { get; set; } = "Receipt Header To Erp Interface Job";
|
|
#endregion 常量
|
|
#region DI
|
|
/// <summary>
|
///
|
/// </summary>
|
private readonly IMaterialInfoBusiness _materialInfoBusiness = BizContext.Container.Resolve<IMaterialInfoBusiness>();
|
|
#endregion DI
|
|
/// <summary>
|
/// 物料超期预警定时任务
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="stoppingToken"></param>
|
/// <returns></returns>
|
public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
|
{
|
var starttime = DateTime.Now;
|
try
|
{
|
var result = _materialInfoBusiness.MaterialExtended();
|
|
SaveLog(context, "物料超期预警定时任务执行成功");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Scheduler.Fatal(ex, "物料超期预警定时任务执行成功");
|
}
|
await Task.CompletedTask;
|
}
|
}
|
}
|
