|
|
@ -14,122 +14,124 @@ using Win_in.Sfs.Wms.Store.Application.Contracts; |
|
|
|
|
|
|
|
|
namespace Win_in.Sfs.Wms.DataExchange.Fawtyg.TyrpAgent.Outgoing; |
|
|
namespace Win_in.Sfs.Wms.DataExchange.Fawtyg.TyrpAgent.Outgoing; |
|
|
|
|
|
|
|
|
public class ItemTransformNoteConverter : IOutgoingConverter |
|
|
public class ItemTransformNoteConverter : IOutgoingConverter |
|
|
{ |
|
|
{ |
|
|
private readonly IOutgoingFromWmsManager _outgoingFromWmsManager; |
|
|
private readonly IOutgoingFromWmsManager _outgoingFromWmsManager; |
|
|
private readonly IOutgoingToExternalManager _outgoingToExternalManager; |
|
|
private readonly IOutgoingToExternalManager _outgoingToExternalManager; |
|
|
private readonly ISupplierAsnAppService _supplierAsnAppService; |
|
|
private readonly ISupplierAsnAppService _supplierAsnAppService; |
|
|
private readonly IDepartmentAppService _departmentAppService; |
|
|
private readonly IDepartmentAppService _departmentAppService; |
|
|
private readonly IObjectMapper _objectMapper; |
|
|
private readonly IObjectMapper _objectMapper; |
|
|
|
|
|
|
|
|
public ItemTransformNoteConverter( |
|
|
public ItemTransformNoteConverter( |
|
|
IOutgoingFromWmsManager outgoingFromWmsManager |
|
|
IOutgoingFromWmsManager outgoingFromWmsManager |
|
|
, IOutgoingToExternalManager outgoingToExternalManager |
|
|
, IOutgoingToExternalManager outgoingToExternalManager |
|
|
, ISupplierAsnAppService supplierAsnAppService |
|
|
, ISupplierAsnAppService supplierAsnAppService |
|
|
, IDepartmentAppService departmentAppService |
|
|
, IDepartmentAppService departmentAppService |
|
|
, IObjectMapper objectMapper |
|
|
, IObjectMapper objectMapper |
|
|
) |
|
|
) |
|
|
{ |
|
|
{ |
|
|
_outgoingFromWmsManager = outgoingFromWmsManager; |
|
|
_outgoingFromWmsManager = outgoingFromWmsManager; |
|
|
_outgoingToExternalManager = outgoingToExternalManager; |
|
|
_outgoingToExternalManager = outgoingToExternalManager; |
|
|
_supplierAsnAppService = supplierAsnAppService; |
|
|
_supplierAsnAppService = supplierAsnAppService; |
|
|
_departmentAppService = departmentAppService; |
|
|
_departmentAppService = departmentAppService; |
|
|
_objectMapper = objectMapper; |
|
|
_objectMapper = objectMapper; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
public virtual async Task<List<OutgoingToExternal>> ConvertAsync() |
|
|
public virtual async Task<List<OutgoingToExternal>> ConvertAsync() |
|
|
|
|
|
{ |
|
|
|
|
|
var outgoingToExternalList = new List<OutgoingToExternal>(); |
|
|
|
|
|
var outgoingFromWmsList = await _outgoingFromWmsManager.GetToBeProcessedListAsync(EnumOutgoingDataType.Item_Transform, EnumSystemType.ERP).ConfigureAwait(false); |
|
|
|
|
|
foreach (var outgoingFromWms in outgoingFromWmsList) |
|
|
{ |
|
|
{ |
|
|
var outgoingToExternalList = new List<OutgoingToExternal>(); |
|
|
var wmsCountAdjust = JsonSerializer.Deserialize<ItemTransformNoteDTO>(outgoingFromWms.DataContent); |
|
|
var outgoingFromWmsList = await _outgoingFromWmsManager.GetToBeProcessedListAsync(EnumOutgoingDataType.Item_Transform, EnumSystemType.ERP).ConfigureAwait(false); |
|
|
if (Enum.Parse<EnumTransSubType>(wmsCountAdjust.Type) == EnumTransSubType.Item_Transform) |
|
|
foreach (var outgoingFromWms in outgoingFromWmsList) |
|
|
|
|
|
{ |
|
|
{ |
|
|
var wmsCountAdjust = JsonSerializer.Deserialize<ItemTransformNoteDTO>(outgoingFromWms.DataContent); |
|
|
string tyrpNumber = outgoingFromWms.TyrpNumber; |
|
|
if (Enum.Parse<EnumTransSubType>(wmsCountAdjust.Type) == EnumTransSubType.Item_Transform) |
|
|
var department = await _departmentAppService.GetByUsernameAsync(wmsCountAdjust.Worker).ConfigureAwait(false); |
|
|
|
|
|
var departmentCode = department == null ? "" : department.Code; |
|
|
|
|
|
var details = wmsCountAdjust.Details.GroupBy(r => new { r.ItemCode, r.ToItemCode, r.LocationErpCode, r.ToLocationCode }).Select(p => new ItemTransformNoteDetailExchangeDto { ToQty = p.Sum(itm => itm.ToQty), FromQty = p.Sum(itm => itm.FromQty), ItemCode = p.Key.ItemCode, ToItemCode = p.Key.ToItemCode, LocationErpCode = p.Key.LocationErpCode, ReasonCode = String.Join("、", p.Select(x => x.ReasonCode).ToArray()) }); |
|
|
|
|
|
foreach (var detail in details) |
|
|
{ |
|
|
{ |
|
|
var department =await _departmentAppService.GetByUsernameAsync(wmsCountAdjust.Worker).ConfigureAwait(false); |
|
|
List<ItemTransformNoteDetailExchangeDto> ItemTransform = new List<ItemTransformNoteDetailExchangeDto>(); |
|
|
var departmentCode = department == null ? "" : department.Code; |
|
|
ItemTransformNoteDetailExchangeDto ItemTrans = new ItemTransformNoteDetailExchangeDto(); |
|
|
var details = wmsCountAdjust.Details.GroupBy(r => new { r.ItemCode, r.ToItemCode, r.LocationErpCode, r.ToLocationCode }).Select(p => new ItemTransformNoteDetailExchangeDto { ToQty = p.Sum(itm => itm.ToQty), FromQty = p.Sum(itm => itm.FromQty), ItemCode = p.Key.ItemCode, ToItemCode = p.Key.ToItemCode, LocationErpCode = p.Key.LocationErpCode, ReasonCode = String.Join("、", p.Select(x => x.ReasonCode).ToArray()) }); |
|
|
ItemTrans.ItemCode = detail.ItemCode; |
|
|
foreach (var detail in details) |
|
|
ItemTrans.LocationErpCode = detail.LocationErpCode; |
|
|
|
|
|
ItemTrans.FromQty = detail.FromQty - detail.FromQty - detail.FromQty; |
|
|
|
|
|
ItemTrans.ReasonCode = detail.ReasonCode; |
|
|
|
|
|
ItemTransform.Add(ItemTrans); |
|
|
|
|
|
ItemTransformNoteDetailExchangeDto ItemTranss = new ItemTransformNoteDetailExchangeDto(); |
|
|
|
|
|
ItemTranss.ItemCode = detail.ToItemCode; |
|
|
|
|
|
ItemTranss.LocationErpCode = detail.LocationErpCode; |
|
|
|
|
|
ItemTranss.FromQty = detail.ToQty; |
|
|
|
|
|
ItemTranss.ReasonCode = detail.ReasonCode; |
|
|
|
|
|
ItemTransform.Add(ItemTranss); |
|
|
|
|
|
foreach (var Item in ItemTransform) |
|
|
{ |
|
|
{ |
|
|
List<ItemTransformNoteDetailExchangeDto> ItemTransform = new List<ItemTransformNoteDetailExchangeDto>(); |
|
|
var outgoingToExternal = new OutgoingToExternal() |
|
|
ItemTransformNoteDetailExchangeDto ItemTrans = new ItemTransformNoteDetailExchangeDto(); |
|
|
|
|
|
ItemTrans.ItemCode = detail.ItemCode; |
|
|
|
|
|
ItemTrans.LocationErpCode = detail.LocationErpCode; |
|
|
|
|
|
ItemTrans.FromQty = detail.FromQty - detail.FromQty - detail.FromQty; |
|
|
|
|
|
ItemTrans.ReasonCode = detail.ReasonCode; |
|
|
|
|
|
ItemTransform.Add(ItemTrans); |
|
|
|
|
|
ItemTransformNoteDetailExchangeDto ItemTranss = new ItemTransformNoteDetailExchangeDto(); |
|
|
|
|
|
ItemTranss.ItemCode = detail.ToItemCode; |
|
|
|
|
|
ItemTranss.LocationErpCode = detail.LocationErpCode; |
|
|
|
|
|
ItemTranss.FromQty = detail.ToQty; |
|
|
|
|
|
ItemTranss.ReasonCode = detail.ReasonCode; |
|
|
|
|
|
ItemTransform.Add(ItemTranss); |
|
|
|
|
|
foreach (var Item in ItemTransform) |
|
|
|
|
|
{ |
|
|
{ |
|
|
var outgoingToExternal = new OutgoingToExternal() |
|
|
DataType = outgoingFromWms.DataType, |
|
|
{ |
|
|
DataAction = outgoingFromWms.DataAction, |
|
|
DataType = outgoingFromWms.DataType, |
|
|
SerialNumber= tyrpNumber, |
|
|
DataAction = outgoingFromWms.DataAction, |
|
|
SourceSystem = EnumSystemType.WMS.ToString(), |
|
|
SourceSystem = EnumSystemType.WMS.ToString(), |
|
|
SourceDataId = wmsCountAdjust.Number, |
|
|
SourceDataId = wmsCountAdjust.Number, |
|
|
SourceDataGroupCode = wmsCountAdjust.Number, |
|
|
SourceDataGroupCode = wmsCountAdjust.Number, |
|
|
SourceDataDetailCode = Item.ItemCode, |
|
|
SourceDataDetailCode = Item.ItemCode, |
|
|
Writer = nameof(TyrpOutgoingBackgroundWorker), |
|
|
Writer = nameof(TyrpOutgoingBackgroundWorker), |
|
|
DestinationSystem = EnumSystemType.ERP.ToString(), |
|
|
DestinationSystem = EnumSystemType.ERP.ToString(), |
|
|
DestinationDataId = "", |
|
|
DestinationDataId = "", |
|
|
}; |
|
|
}; |
|
|
outgoingToExternal.SetEffectiveDate(outgoingFromWms.EffectiveDate); |
|
|
outgoingToExternal.SetEffectiveDate(outgoingFromWms.EffectiveDate); |
|
|
var exchangeIssue = await BuildPurchaseReceiptExchangeDtoAsync(wmsCountAdjust, Item).ConfigureAwait(false); |
|
|
var exchangeIssue = await BuildPurchaseReceiptExchangeDtoAsync(wmsCountAdjust, Item).ConfigureAwait(false); |
|
|
outgoingToExternal.SourceDataContent = JsonSerializer.Serialize(exchangeIssue); |
|
|
outgoingToExternal.SourceDataContent = JsonSerializer.Serialize(exchangeIssue); |
|
|
var arrive = BuildIssue(exchangeIssue, departmentCode); |
|
|
var arrive = BuildIssue(exchangeIssue, departmentCode); |
|
|
outgoingToExternal.DestinationDataContent = JsonSerializer.Serialize(arrive); |
|
|
outgoingToExternal.DestinationDataContent = JsonSerializer.Serialize(arrive); |
|
|
|
|
|
|
|
|
|
|
|
outgoingToExternalList.Add(outgoingToExternal); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
outgoingToExternalList.Add(outgoingToExternal); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
await _outgoingToExternalManager.CreateManyAsync(outgoingToExternalList).ConfigureAwait(false); ; |
|
|
|
|
|
//将outgoingFromWms数据归档
|
|
|
|
|
|
await _outgoingFromWmsManager.ArchiveManyAsync(outgoingFromWmsList).ConfigureAwait(false); ; |
|
|
|
|
|
return outgoingToExternalList; |
|
|
|
|
|
//插入到中间表OutgoingToExternal
|
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
await _outgoingToExternalManager.CreateManyAsync(outgoingToExternalList).ConfigureAwait(false); ; |
|
|
|
|
|
//将outgoingFromWms数据归档
|
|
|
|
|
|
await _outgoingFromWmsManager.ArchiveManyAsync(outgoingFromWmsList).ConfigureAwait(false); ; |
|
|
|
|
|
return outgoingToExternalList; |
|
|
|
|
|
//插入到中间表OutgoingToExternal
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
private CountAdjust BuildIssue(ItemTransformNoteExchangeDto exchangeCountAdjust, string departmentCode) |
|
|
private CountAdjust BuildIssue(ItemTransformNoteExchangeDto exchangeCountAdjust, string departmentCode) |
|
|
|
|
|
{ |
|
|
|
|
|
var detail = exchangeCountAdjust.Detail; |
|
|
|
|
|
var counta = new CountAdjust() |
|
|
{ |
|
|
{ |
|
|
var detail = exchangeCountAdjust.Detail; |
|
|
mesout_asd_refc = "MES", |
|
|
var counta = new CountAdjust() |
|
|
mesout_asd_dt_w = DateTime.Now.ToString("yyyyMMdd HH:mm:ss"), |
|
|
{ |
|
|
mesout_asd_type = "4003", |
|
|
mesout_asd_refc = "MES", |
|
|
mesout_asd_part = detail.ItemCode, |
|
|
mesout_asd_dt_w = DateTime.Now.ToString("yyyyMMdd HH:mm:ss"), |
|
|
//mesout_asd_date = exchangeCountAdjust.ActiveDate.ToString("yyyyMMdd"),
|
|
|
mesout_asd_type = "4003", |
|
|
mesout_asd_date = DateTime.Now.ToString("yyyyMMdd"), |
|
|
mesout_asd_part = detail.ItemCode, |
|
|
mesout_asd_loc = detail.LocationErpCode, |
|
|
//mesout_asd_date = exchangeCountAdjust.ActiveDate.ToString("yyyyMMdd"),
|
|
|
mesout_asd_code = detail.ReasonCode, |
|
|
mesout_asd_date = DateTime.Now.ToString("yyyyMMdd"), |
|
|
mesout_asd_qty = detail.FromQty, |
|
|
mesout_asd_loc = detail.LocationErpCode, |
|
|
mesout_asd_user = "WMS", |
|
|
mesout_asd_code = detail.ReasonCode, |
|
|
mesout_asd_k = string.Empty, |
|
|
mesout_asd_qty = detail.FromQty, |
|
|
mesout_asd_stat = "Y" |
|
|
mesout_asd_user = "WMS", |
|
|
|
|
|
mesout_asd_k = string.Empty, |
|
|
|
|
|
mesout_asd_stat = "Y" |
|
|
|
|
|
|
|
|
|
|
|
}; |
|
|
}; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return counta; |
|
|
return counta; |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
private async Task<ItemTransformNoteExchangeDto> BuildPurchaseReceiptExchangeDtoAsync( |
|
|
private async Task<ItemTransformNoteExchangeDto> BuildPurchaseReceiptExchangeDtoAsync( |
|
|
ItemTransformNoteDTO wmsCountAdjust, ItemTransformNoteDetailExchangeDto wmsCountAdjustDetail) |
|
|
ItemTransformNoteDTO wmsCountAdjust, ItemTransformNoteDetailExchangeDto wmsCountAdjustDetail) |
|
|
{ |
|
|
{ |
|
|
|
|
|
|
|
|
var exchangeCountAdjust = _objectMapper.Map<ItemTransformNoteDTO, ItemTransformNoteExchangeDto>(wmsCountAdjust); |
|
|
var exchangeCountAdjust = _objectMapper.Map<ItemTransformNoteDTO, ItemTransformNoteExchangeDto>(wmsCountAdjust); |
|
|
|
|
|
|
|
|
exchangeCountAdjust.Detail = wmsCountAdjustDetail; |
|
|
exchangeCountAdjust.Detail = wmsCountAdjustDetail; |
|
|
return exchangeCountAdjust; |
|
|
return exchangeCountAdjust; |
|
|
} |
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
lvzb
2 years ago