|
|
|
@ -41,104 +41,244 @@ public class TyrpOutgoingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase |
|
|
|
} |
|
|
|
var scontrolWriter = workerContext.ServiceProvider.GetRequiredService<ScontrolWriter>();//scontrol中间表服务
|
|
|
|
var wmsoutmWriter = workerContext.ServiceProvider.GetRequiredService<WmsoutmWriter>();//wmsoutm中间表的服务
|
|
|
|
var countadjustWriter = workerContext.ServiceProvider.GetRequiredService<CountAdjustNoteWriter>();//mesout_asd中间表的服务
|
|
|
|
int scontrol_count = 0;//scontrol插入条数
|
|
|
|
int wmsoutm_count = 0; //wmsoutm插入条数
|
|
|
|
int mesout_asd_count = 0; //mesout_asd插入条数
|
|
|
|
|
|
|
|
#region 采购单 PurchaseOrder scontrol
|
|
|
|
Logger.LogInformation($"Write PurchaseOrder");//采购单
|
|
|
|
var purchaseOrderConvert = workerContext.ServiceProvider.GetRequiredService<PurchaseOrderConverter>(); |
|
|
|
var purchaseOrderList = await purchaseOrderConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await scontrolWriter.WriteAsync(purchaseOrderList).ConfigureAwait(false); |
|
|
|
if (purchaseOrderList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"采购单-PurchaseOrder处理{purchaseOrderList.Count}条"); |
|
|
|
scontrol_count += purchaseOrderList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
Logger.LogInformation($"Write PurchaseReturn");//采购退货单
|
|
|
|
#region 采购退货单 PurchaseReturn scontrol
|
|
|
|
Logger.LogInformation($"Write PurchaseReturn");//采购退货单(汇总)
|
|
|
|
var purchaseReturnConvert = workerContext.ServiceProvider.GetRequiredService<PurchaseReturnConverter>(); |
|
|
|
var purchaseReturnList = await purchaseReturnConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await scontrolWriter.WriteAsync(purchaseReturnList).ConfigureAwait(false); |
|
|
|
if (purchaseReturnList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"采购退货单-PurchaseReturn处理{purchaseReturnList.Count}条"); |
|
|
|
scontrol_count += purchaseReturnList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
Logger.LogInformation($"Write PutawayNote");//验收单
|
|
|
|
#region 验收单 Putaway scontrol
|
|
|
|
Logger.LogInformation($"Write PutawayNote");//验收单(汇总)
|
|
|
|
var putawayNoteConvert = workerContext.ServiceProvider.GetRequiredService<PutawayNoteConverter>(); |
|
|
|
var putawayNoteList = await putawayNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await scontrolWriter.WriteAsync(putawayNoteList).ConfigureAwait(false); |
|
|
|
if (putawayNoteList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"验收单-Putaway处理{putawayNoteList.Count}条"); |
|
|
|
scontrol_count += putawayNoteList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
Logger.LogInformation($"Write IssueNote");//线边仓领料单
|
|
|
|
#region 线边仓领料单 Issue scontrol
|
|
|
|
Logger.LogInformation($"Write IssueNote");//线边仓领料单(汇总)
|
|
|
|
var issueNoteConvert = workerContext.ServiceProvider.GetRequiredService<IssueNoteConverter>(); |
|
|
|
var issueNoteList = await issueNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await scontrolWriter.WriteAsync(issueNoteList).ConfigureAwait(false); |
|
|
|
if (issueNoteList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"线边仓领料单-Issue处理{issueNoteList.Count}条"); |
|
|
|
scontrol_count += issueNoteList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
#region 线边仓退料单 ProductionReturn scontrol
|
|
|
|
Logger.LogInformation($"Write ProductionReturnNote");//线边仓退料单
|
|
|
|
var productionReturnNoteConvert = workerContext.ServiceProvider.GetRequiredService<ProductionReturnNoteConverter>(); |
|
|
|
var productionReturnNoteList = await productionReturnNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await scontrolWriter.WriteAsync(productionReturnNoteList).ConfigureAwait(false); |
|
|
|
if (productionReturnNoteList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"线边仓退料单-ProductionReturn处理{productionReturnNoteList.Count}条"); |
|
|
|
scontrol_count += productionReturnNoteList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
#region 半成品上架 SemiPutaway scontrol
|
|
|
|
Logger.LogInformation($"Write SemiPutawayNote");//半成品上架
|
|
|
|
var semiPutawayNoteConvert = workerContext.ServiceProvider.GetRequiredService<SemiPutawayNoteConverter>(); |
|
|
|
var semiPutawayNoteList = await semiPutawayNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await scontrolWriter.WriteAsync(semiPutawayNoteList).ConfigureAwait(false); |
|
|
|
if (semiPutawayNoteList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"半成品上架-SemiPutaway处理{semiPutawayNoteList.Count}条"); |
|
|
|
scontrol_count += semiPutawayNoteList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
Logger.LogInformation($"Write TransferNote");//储位、线边仓调拨单 和 客户储位调拨单
|
|
|
|
#region 储位、线边仓调拨单 和 客户储位调拨单 Transfer scontrol
|
|
|
|
Logger.LogInformation($"Write TransferNote");//储位、线边仓调拨单 和 客户储位调拨单(汇总)
|
|
|
|
var transferNoteConvert = workerContext.ServiceProvider.GetRequiredService<TransferNoteConverter>(); |
|
|
|
var transferNoteList = await transferNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
var transferNoteForErpList = transferNoteList.Where(r => r.DataType == EnumOutgoingDataType.TransferForErp.ToString()).ToList();//储位、线边仓调拨单
|
|
|
|
var transferNoteForCustomList = transferNoteList.Where(r => r.DataType == EnumOutgoingDataType.TransferForCustom.ToString()).ToList();//客户储位调拨单
|
|
|
|
await scontrolWriter.WriteAsync(transferNoteForErpList).ConfigureAwait(false); |
|
|
|
await wmsoutmWriter.WriteAsync(transferNoteForCustomList).ConfigureAwait(false); |
|
|
|
if (transferNoteForErpList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"储位、线边仓调拨单-Transfer处理{transferNoteForErpList.Count}条"); |
|
|
|
scontrol_count += transferNoteForErpList.Count; |
|
|
|
} |
|
|
|
if (transferNoteForCustomList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"客户储位调拨单-Transfer处理{transferNoteForCustomList.Count}条"); |
|
|
|
wmsoutm_count += transferNoteForCustomList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
Logger.LogInformation($"Write SemiPutawayNote");//半成品上架
|
|
|
|
var semiPutawayNoteConvert = workerContext.ServiceProvider.GetRequiredService<SemiPutawayNoteConverter>(); |
|
|
|
var semiPutawayNoteList = await semiPutawayNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await scontrolWriter.WriteAsync(semiPutawayNoteList).ConfigureAwait(false); |
|
|
|
|
|
|
|
Logger.LogInformation($"Write ProductReceiptNote");//缴库单
|
|
|
|
var productReceiptNoteConvert = workerContext.ServiceProvider.GetRequiredService<ProductReceiptNoteConverter>(); |
|
|
|
var productReceiptNoteList = await productReceiptNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
var productReceiptNoteWriter = workerContext.ServiceProvider.GetRequiredService<ProductReceiptNoteWriter>(); |
|
|
|
await productReceiptNoteWriter.WriteAsync(productReceiptNoteList).ConfigureAwait(false); |
|
|
|
if (scontrol_count > 0)//如果scontrol中有插入数据下边接口不执行
|
|
|
|
{ |
|
|
|
Logger.LogInformation($"scontrol处理{scontrol_count}条"); |
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
|
Logger.LogInformation($"Write DeliverNote");//出货单
|
|
|
|
#region 出货单 Deliver wmsoutm
|
|
|
|
Logger.LogInformation($"Write DeliverNote");//出货单(汇总)
|
|
|
|
var deliverNoteConvert = workerContext.ServiceProvider.GetRequiredService<DeliverNoteConverter>(); |
|
|
|
var deliverNoteList = await deliverNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await wmsoutmWriter.WriteAsync(deliverNoteList).ConfigureAwait(false); |
|
|
|
if (deliverNoteList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"出货单-Deliver处理{deliverNoteList.Count}条"); |
|
|
|
wmsoutm_count += deliverNoteList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
#region --接口以关闭-- 退货单 UnplannedReceipt wmsoutm
|
|
|
|
//暂无此接口
|
|
|
|
//Logger.LogInformation($"Write CustomerReturnNote");//退货单
|
|
|
|
//var customerReturnNoteConvert = workerContext.ServiceProvider.GetRequiredService<CustomerReturnNoteConverter>();
|
|
|
|
//var customerReturnNoteList = await customerReturnNoteConvert.ConvertAsync().ConfigureAwait(false);
|
|
|
|
//await wmsoutmWriter.WriteAsync(customerReturnNoteList).ConfigureAwait(false);
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
Logger.LogInformation($"Write UnplannedIssueNote");//非生产领料单
|
|
|
|
#region 非生产领料单 UnplannedIssue wmsoutm
|
|
|
|
Logger.LogInformation($"Write UnplannedIssueNote");//非生产领料单(汇总)
|
|
|
|
var unplannedIssueNoteConvert = workerContext.ServiceProvider.GetRequiredService<UnplannedIssueNoteConverter>(); |
|
|
|
var unplannedIssueNoteNoteList = await unplannedIssueNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await wmsoutmWriter.WriteAsync(unplannedIssueNoteNoteList).ConfigureAwait(false); |
|
|
|
if (unplannedIssueNoteNoteList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"非生产领料单-UnplannedIssue处理{unplannedIssueNoteNoteList.Count}条"); |
|
|
|
wmsoutm_count += unplannedIssueNoteNoteList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
Logger.LogInformation($"Write UnplannedReceiptNote");//非生产退料
|
|
|
|
#region 非生产退料 UnplannedReceipt wmsoutm
|
|
|
|
Logger.LogInformation($"Write UnplannedReceiptNote");//非生产退料(汇总)
|
|
|
|
var unplannedReceiptNoteConvert = workerContext.ServiceProvider.GetRequiredService<UnplannedReceiptNoteConverter>(); |
|
|
|
var unplannedReceiptNoteList = await unplannedReceiptNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await wmsoutmWriter.WriteAsync(unplannedReceiptNoteList).ConfigureAwait(false); |
|
|
|
if (unplannedReceiptNoteList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"非生产退料-UnplannedReceipt处理{unplannedReceiptNoteList.Count}条"); |
|
|
|
wmsoutm_count += unplannedReceiptNoteList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
#region 回收料入库单 RecycledMaterialReceipt wmsoutm
|
|
|
|
Logger.LogInformation($"Write RecycledMaterialReceiptNote");//回收料入库单
|
|
|
|
var recycledMaterialReceiptNoteConvert = workerContext.ServiceProvider.GetRequiredService<RecycledMaterialReceiptNoteConverter>(); |
|
|
|
var recycledMaterialReceiptNoteList = await recycledMaterialReceiptNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await wmsoutmWriter.WriteAsync(recycledMaterialReceiptNoteList).ConfigureAwait(false); |
|
|
|
if (recycledMaterialReceiptNoteList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"回收料入库单-RecycledMaterialReceipt处理{recycledMaterialReceiptNoteList.Count}条"); |
|
|
|
wmsoutm_count += recycledMaterialReceiptNoteList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
#region 退拆单 ProductRecycle wmsoutm
|
|
|
|
Logger.LogInformation($"Write BackFlushNote");//退拆单
|
|
|
|
var productRecycleNoteConvert = workerContext.ServiceProvider.GetRequiredService<ProductRecycleNoteConverter>(); |
|
|
|
var productRecycleNoteList = await productRecycleNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await wmsoutmWriter.WriteAsync(productRecycleNoteList).ConfigureAwait(false); |
|
|
|
if (productRecycleNoteList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"退拆单-ProductRecycle处理{productRecycleNoteList.Count}条"); |
|
|
|
wmsoutm_count += productRecycleNoteList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
if (wmsoutm_count > 0)//如果wmsoutm中有插入数据下边接口不执行
|
|
|
|
{ |
|
|
|
Logger.LogInformation($"wmsoutm处理{wmsoutm_count}条"); |
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
|
#region --接口以关闭-- 盘点调整单 CountAdjust mesout_asd
|
|
|
|
//东阳上海和安徽暂时关闭此接口
|
|
|
|
//Logger.LogInformation($"Write CountAdjusNote");//盘点调整单
|
|
|
|
//var countadjustNoteConvert = workerContext.ServiceProvider.GetRequiredService<CountAdjustNoteConverter>();
|
|
|
|
//var countadjustNoteList = await countadjustNoteConvert.ConvertAsync().ConfigureAwait(false);
|
|
|
|
var countadjustWriter = workerContext.ServiceProvider.GetRequiredService<CountAdjustNoteWriter>(); |
|
|
|
//await countadjustWriter.WriteAsync(countadjustNoteList).ConfigureAwait(false);
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
#region 线边仓调整单 WIPAdjust mesout_asd
|
|
|
|
Logger.LogInformation($"Write WIPAdjusNote");//线边仓调整单
|
|
|
|
var wipAdjustNoteConvert = workerContext.ServiceProvider.GetRequiredService<WIPAdjusNoteConverter>(); |
|
|
|
var wipAdjustNoteList = await wipAdjustNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await countadjustWriter.WriteAsync(wipAdjustNoteList).ConfigureAwait(false); |
|
|
|
if (wipAdjustNoteList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"线边仓调整单-WIPAdjust处理{wipAdjustNoteList.Count}条"); |
|
|
|
mesout_asd_count += wipAdjustNoteList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
#region 回收料调整单 Item_Transform mesout_asd
|
|
|
|
Logger.LogInformation($"Write ItemTransformNote");//回收料调整单
|
|
|
|
var ItemTransformNoteConvert = workerContext.ServiceProvider.GetRequiredService<ItemTransformNoteConverter>(); |
|
|
|
var ItemTransformNoteList = await ItemTransformNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await countadjustWriter.WriteAsync(ItemTransformNoteList).ConfigureAwait(false); |
|
|
|
if (ItemTransformNoteList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"回收料调整单-Item_Transform处理{ItemTransformNoteList.Count}条"); |
|
|
|
mesout_asd_count += ItemTransformNoteList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
|
|
#region 报废单、线边仓报废单 Scrap mesout_asd
|
|
|
|
Logger.LogInformation($"Write ScrapNote");//报废单、线边仓报废单
|
|
|
|
var scrapNoteConvert = workerContext.ServiceProvider.GetRequiredService<ScrapNoteConverter>(); |
|
|
|
var scrapNoteList = await scrapNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
await countadjustWriter.WriteAsync(scrapNoteList).ConfigureAwait(false); |
|
|
|
if (scrapNoteList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"报废单、线边仓报废单-Scrap处理{scrapNoteList.Count}条"); |
|
|
|
mesout_asd_count += scrapNoteList.Count; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
if (mesout_asd_count > 0)//如果mesout_asd中有插入数据下边接口不执行
|
|
|
|
{ |
|
|
|
Logger.LogInformation($"mesout_asd处理{mesout_asd_count}条"); |
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
|
#region 缴库单 ProductReceipt mesout
|
|
|
|
Logger.LogInformation($"Write ProductReceiptNote");//缴库单
|
|
|
|
var productReceiptNoteConvert = workerContext.ServiceProvider.GetRequiredService<ProductReceiptNoteConverter>(); |
|
|
|
var productReceiptNoteList = await productReceiptNoteConvert.ConvertAsync().ConfigureAwait(false); |
|
|
|
var productReceiptNoteWriter = workerContext.ServiceProvider.GetRequiredService<ProductReceiptNoteWriter>();//mesout中间表的服务
|
|
|
|
await productReceiptNoteWriter.WriteAsync(productReceiptNoteList).ConfigureAwait(false); |
|
|
|
if (productReceiptNoteList.Count > 0) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"缴库单-ProductReceipt处理{productReceiptNoteList.Count}条"); |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
Logger.LogInformation($"Completed: Handling {Outgoing}"); |
|
|
|
} |
|
|
|
|
lvzb
2 years ago