|
|
@ -46,77 +46,77 @@ public class TyrpOutgoingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase |
|
|
int wmsoutm_count = 0; //wmsoutm插入条数
|
|
|
int wmsoutm_count = 0; //wmsoutm插入条数
|
|
|
int mesout_asd_count = 0; //mesout_asd插入条数
|
|
|
int mesout_asd_count = 0; //mesout_asd插入条数
|
|
|
|
|
|
|
|
|
#region 采购单 PurchaseOrder scontrol
|
|
|
//#region 采购单 PurchaseOrder scontrol
|
|
|
Logger.LogInformation($"Write PurchaseOrder");//采购单
|
|
|
//Logger.LogInformation($"Write PurchaseOrder");//采购单
|
|
|
var purchaseOrderConvert = workerContext.ServiceProvider.GetRequiredService<PurchaseOrderConverter>(); |
|
|
//var purchaseOrderConvert = workerContext.ServiceProvider.GetRequiredService<PurchaseOrderConverter>();
|
|
|
var purchaseOrderList = await purchaseOrderConvert.ConvertAsync().ConfigureAwait(false); |
|
|
//var purchaseOrderList = await purchaseOrderConvert.ConvertAsync().ConfigureAwait(false);
|
|
|
await scontrolWriter.WriteAsync(purchaseOrderList).ConfigureAwait(false); |
|
|
//await scontrolWriter.WriteAsync(purchaseOrderList).ConfigureAwait(false);
|
|
|
if (purchaseOrderList.Count > 0) |
|
|
//if (purchaseOrderList.Count > 0)
|
|
|
{ |
|
|
//{
|
|
|
Logger.LogInformation($"采购单-PurchaseOrder处理{purchaseOrderList.Count}条"); |
|
|
// Logger.LogInformation($"采购单-PurchaseOrder处理{purchaseOrderList.Count}条");
|
|
|
scontrol_count += purchaseOrderList.Count; |
|
|
// scontrol_count += purchaseOrderList.Count;
|
|
|
} |
|
|
//}
|
|
|
#endregion
|
|
|
//#endregion
|
|
|
|
|
|
|
|
|
#region 采购退货单 PurchaseReturn scontrol
|
|
|
//#region 采购退货单 PurchaseReturn scontrol
|
|
|
Logger.LogInformation($"Write PurchaseReturn");//采购退货单(汇总)
|
|
|
//Logger.LogInformation($"Write PurchaseReturn");//采购退货单(汇总)
|
|
|
var purchaseReturnConvert = workerContext.ServiceProvider.GetRequiredService<PurchaseReturnConverter>(); |
|
|
//var purchaseReturnConvert = workerContext.ServiceProvider.GetRequiredService<PurchaseReturnConverter>();
|
|
|
var purchaseReturnList = await purchaseReturnConvert.ConvertAsync().ConfigureAwait(false); |
|
|
//var purchaseReturnList = await purchaseReturnConvert.ConvertAsync().ConfigureAwait(false);
|
|
|
await scontrolWriter.WriteAsync(purchaseReturnList).ConfigureAwait(false); |
|
|
//await scontrolWriter.WriteAsync(purchaseReturnList).ConfigureAwait(false);
|
|
|
if (purchaseReturnList.Count > 0) |
|
|
//if (purchaseReturnList.Count > 0)
|
|
|
{ |
|
|
//{
|
|
|
Logger.LogInformation($"采购退货单-PurchaseReturn处理{purchaseReturnList.Count}条"); |
|
|
// Logger.LogInformation($"采购退货单-PurchaseReturn处理{purchaseReturnList.Count}条");
|
|
|
scontrol_count += purchaseReturnList.Count; |
|
|
// scontrol_count += purchaseReturnList.Count;
|
|
|
} |
|
|
//}
|
|
|
#endregion
|
|
|
//#endregion
|
|
|
|
|
|
|
|
|
#region 验收单 Putaway scontrol
|
|
|
//#region 验收单 Putaway scontrol
|
|
|
Logger.LogInformation($"Write PutawayNote");//验收单(汇总)
|
|
|
//Logger.LogInformation($"Write PutawayNote");//验收单(汇总)
|
|
|
var putawayNoteConvert = workerContext.ServiceProvider.GetRequiredService<PutawayNoteConverter>(); |
|
|
//var putawayNoteConvert = workerContext.ServiceProvider.GetRequiredService<PutawayNoteConverter>();
|
|
|
var putawayNoteList = await putawayNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
//var putawayNoteList = await putawayNoteConvert.ConvertAsync().ConfigureAwait(false);
|
|
|
await scontrolWriter.WriteAsync(putawayNoteList).ConfigureAwait(false); |
|
|
//await scontrolWriter.WriteAsync(putawayNoteList).ConfigureAwait(false);
|
|
|
if (putawayNoteList.Count > 0) |
|
|
//if (putawayNoteList.Count > 0)
|
|
|
{ |
|
|
//{
|
|
|
Logger.LogInformation($"验收单-Putaway处理{putawayNoteList.Count}条"); |
|
|
// Logger.LogInformation($"验收单-Putaway处理{putawayNoteList.Count}条");
|
|
|
scontrol_count += putawayNoteList.Count; |
|
|
// scontrol_count += putawayNoteList.Count;
|
|
|
} |
|
|
//}
|
|
|
#endregion
|
|
|
//#endregion
|
|
|
|
|
|
|
|
|
#region 线边仓领料单 Issue scontrol
|
|
|
//#region 线边仓领料单 Issue scontrol
|
|
|
Logger.LogInformation($"Write IssueNote");//线边仓领料单(汇总)
|
|
|
//Logger.LogInformation($"Write IssueNote");//线边仓领料单(汇总)
|
|
|
var issueNoteConvert = workerContext.ServiceProvider.GetRequiredService<IssueNoteConverter>(); |
|
|
//var issueNoteConvert = workerContext.ServiceProvider.GetRequiredService<IssueNoteConverter>();
|
|
|
var issueNoteList = await issueNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
//var issueNoteList = await issueNoteConvert.ConvertAsync().ConfigureAwait(false);
|
|
|
await scontrolWriter.WriteAsync(issueNoteList).ConfigureAwait(false); |
|
|
//await scontrolWriter.WriteAsync(issueNoteList).ConfigureAwait(false);
|
|
|
if (issueNoteList.Count > 0) |
|
|
//if (issueNoteList.Count > 0)
|
|
|
{ |
|
|
//{
|
|
|
Logger.LogInformation($"线边仓领料单-Issue处理{issueNoteList.Count}条"); |
|
|
// Logger.LogInformation($"线边仓领料单-Issue处理{issueNoteList.Count}条");
|
|
|
scontrol_count += issueNoteList.Count; |
|
|
// scontrol_count += issueNoteList.Count;
|
|
|
} |
|
|
//}
|
|
|
#endregion
|
|
|
//#endregion
|
|
|
|
|
|
|
|
|
#region 线边仓退料单 ProductionReturn scontrol
|
|
|
//#region 线边仓退料单 ProductionReturn scontrol
|
|
|
Logger.LogInformation($"Write ProductionReturnNote");//线边仓退料单(汇总)
|
|
|
//Logger.LogInformation($"Write ProductionReturnNote");//线边仓退料单(汇总)
|
|
|
var productionReturnNoteConvert = workerContext.ServiceProvider.GetRequiredService<ProductionReturnNoteConverter>(); |
|
|
//var productionReturnNoteConvert = workerContext.ServiceProvider.GetRequiredService<ProductionReturnNoteConverter>();
|
|
|
var productionReturnNoteList = await productionReturnNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
//var productionReturnNoteList = await productionReturnNoteConvert.ConvertAsync().ConfigureAwait(false);
|
|
|
await scontrolWriter.WriteAsync(productionReturnNoteList).ConfigureAwait(false); |
|
|
//await scontrolWriter.WriteAsync(productionReturnNoteList).ConfigureAwait(false);
|
|
|
if (productionReturnNoteList.Count > 0) |
|
|
//if (productionReturnNoteList.Count > 0)
|
|
|
{ |
|
|
//{
|
|
|
Logger.LogInformation($"线边仓退料单-ProductionReturn处理{productionReturnNoteList.Count}条"); |
|
|
// Logger.LogInformation($"线边仓退料单-ProductionReturn处理{productionReturnNoteList.Count}条");
|
|
|
scontrol_count += productionReturnNoteList.Count; |
|
|
// scontrol_count += productionReturnNoteList.Count;
|
|
|
} |
|
|
//}
|
|
|
#endregion
|
|
|
//#endregion
|
|
|
|
|
|
|
|
|
#region 半成品上架 SemiPutaway scontrol
|
|
|
//#region 半成品上架 SemiPutaway scontrol
|
|
|
Logger.LogInformation($"Write SemiPutawayNote");//半成品上架
|
|
|
//Logger.LogInformation($"Write SemiPutawayNote");//半成品上架
|
|
|
var semiPutawayNoteConvert = workerContext.ServiceProvider.GetRequiredService<SemiPutawayNoteConverter>(); |
|
|
//var semiPutawayNoteConvert = workerContext.ServiceProvider.GetRequiredService<SemiPutawayNoteConverter>();
|
|
|
var semiPutawayNoteList = await semiPutawayNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
//var semiPutawayNoteList = await semiPutawayNoteConvert.ConvertAsync().ConfigureAwait(false);
|
|
|
await scontrolWriter.WriteAsync(semiPutawayNoteList).ConfigureAwait(false); |
|
|
//await scontrolWriter.WriteAsync(semiPutawayNoteList).ConfigureAwait(false);
|
|
|
if (semiPutawayNoteList.Count > 0) |
|
|
//if (semiPutawayNoteList.Count > 0)
|
|
|
{ |
|
|
//{
|
|
|
Logger.LogInformation($"半成品上架-SemiPutaway处理{semiPutawayNoteList.Count}条"); |
|
|
// Logger.LogInformation($"半成品上架-SemiPutaway处理{semiPutawayNoteList.Count}条");
|
|
|
scontrol_count += semiPutawayNoteList.Count; |
|
|
// scontrol_count += semiPutawayNoteList.Count;
|
|
|
} |
|
|
//}
|
|
|
#endregion
|
|
|
//#endregion
|
|
|
|
|
|
|
|
|
#region 储位、线边仓调拨单 和 客户储位调拨单 Transfer scontrol
|
|
|
#region 储位、线边仓调拨单 和 客户储位调拨单 Transfer scontrol
|
|
|
Logger.LogInformation($"Write TransferNote");//储位、线边仓调拨单 和 客户储位调拨单(汇总)
|
|
|
Logger.LogInformation($"Write TransferNote");//储位、线边仓调拨单 和 客户储位调拨单(汇总)
|
|
|
|
