11 changed files with 252 additions and 7 deletions
@ -0,0 +1,139 @@ |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.Linq; |
|||
using System.Text.Json; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.ObjectMapping; |
|||
using Win_in.Sfs.Auth.Application.Contracts; |
|||
using Win_in.Sfs.Shared.Domain.Shared; |
|||
using Win_in.Sfs.Wms.DataExchange.Domain; |
|||
using Win_in.Sfs.Wms.DataExchange.Domain.Fawtyg.Tyrp; |
|||
using Win_in.Sfs.Wms.DataExchange.Domain.Shared; |
|||
using Win_in.Sfs.Wms.DataExchange.WMS.ItemTransformNote; |
|||
using Win_in.Sfs.Wms.Store.Application.Contracts; |
|||
|
|||
namespace Win_in.Sfs.Wms.DataExchange.Fawtyg.TyrpAgent.Outgoing; |
|||
|
|||
public class ItemTransformNoteConverter : IOutgoingConverter |
|||
{ |
|||
private readonly IOutgoingFromWmsManager _outgoingFromWmsManager; |
|||
private readonly IOutgoingToExternalManager _outgoingToExternalManager; |
|||
private readonly ISupplierAsnAppService _supplierAsnAppService; |
|||
private readonly IDepartmentAppService _departmentAppService; |
|||
private readonly IObjectMapper _objectMapper; |
|||
|
|||
public ItemTransformNoteConverter( |
|||
IOutgoingFromWmsManager outgoingFromWmsManager |
|||
, IOutgoingToExternalManager outgoingToExternalManager |
|||
, ISupplierAsnAppService supplierAsnAppService |
|||
, IDepartmentAppService departmentAppService |
|||
, IObjectMapper objectMapper |
|||
) |
|||
{ |
|||
_outgoingFromWmsManager = outgoingFromWmsManager; |
|||
_outgoingToExternalManager = outgoingToExternalManager; |
|||
_supplierAsnAppService = supplierAsnAppService; |
|||
_departmentAppService = departmentAppService; |
|||
_objectMapper = objectMapper; |
|||
} |
|||
|
|||
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 wmsCountAdjust = JsonSerializer.Deserialize<ItemTransformNoteDTO>(outgoingFromWms.DataContent); |
|||
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) |
|||
{ |
|||
List<ItemTransformNoteDetailExchangeDto> ItemTransform = new List<ItemTransformNoteDetailExchangeDto>(); |
|||
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, |
|||
SourceSystem = EnumSystemType.WMS.ToString(), |
|||
SourceDataId = wmsCountAdjust.Number, |
|||
SourceDataGroupCode = wmsCountAdjust.Number, |
|||
SourceDataDetailCode = Item.ItemCode, |
|||
Writer = nameof(TyrpOutgoingBackgroundWorker), |
|||
DestinationSystem = EnumSystemType.ERP.ToString(), |
|||
DestinationDataId = "", |
|||
}; |
|||
outgoingToExternal.SetEffectiveDate(outgoingFromWms.EffectiveDate); |
|||
var exchangeIssue = await BuildPurchaseReceiptExchangeDtoAsync(wmsCountAdjust, Item).ConfigureAwait(false); |
|||
outgoingToExternal.SourceDataContent = JsonSerializer.Serialize(exchangeIssue); |
|||
var arrive = BuildIssue(exchangeIssue, departmentCode); |
|||
outgoingToExternal.DestinationDataContent = JsonSerializer.Serialize(arrive); |
|||
|
|||
outgoingToExternalList.Add(outgoingToExternal); |
|||
} |
|||
|
|||
} |
|||
} |
|||
} |
|||
await _outgoingToExternalManager.CreateManyAsync(outgoingToExternalList).ConfigureAwait(false); ; |
|||
//将outgoingFromWms数据归档
|
|||
await _outgoingFromWmsManager.ArchiveManyAsync(outgoingFromWmsList).ConfigureAwait(false); ; |
|||
return outgoingToExternalList; |
|||
//插入到中间表OutgoingToExternal
|
|||
} |
|||
|
|||
private CountAdjust BuildIssue(ItemTransformNoteExchangeDto exchangeCountAdjust, string departmentCode) |
|||
{ |
|||
var detail = exchangeCountAdjust.Detail; |
|||
string asdtype = ""; |
|||
if (Enum.Parse<EnumTransSubType>(exchangeCountAdjust.Type) == EnumTransSubType.Item_Transform) |
|||
{ |
|||
asdtype = "4003"; |
|||
} |
|||
var counta = new CountAdjust() |
|||
{ |
|||
mesout_asd_refc = departmentCode, |
|||
mesout_asd_dt_w = DateTime.Now.ToString("yyyyMMdd HH:mm:ss"), |
|||
mesout_asd_type = asdtype, |
|||
mesout_asd_part = detail.ItemCode, |
|||
mesout_asd_date = exchangeCountAdjust.ActiveDate.ToString("yyyyMMdd"), |
|||
mesout_asd_loc = detail.LocationErpCode, |
|||
mesout_asd_code = detail.ReasonCode, |
|||
mesout_asd_qty = detail.FromQty, |
|||
mesout_asd_user = exchangeCountAdjust.Worker, |
|||
mesout_asd_k = string.Empty, |
|||
mesout_asd_stat = "Y" |
|||
|
|||
}; |
|||
|
|||
|
|||
return counta; |
|||
|
|||
} |
|||
|
|||
private async Task<ItemTransformNoteExchangeDto> BuildPurchaseReceiptExchangeDtoAsync( |
|||
ItemTransformNoteDTO wmsCountAdjust, ItemTransformNoteDetailExchangeDto wmsCountAdjustDetail) |
|||
{ |
|||
|
|||
var exchangeCountAdjust = _objectMapper.Map<ItemTransformNoteDTO, ItemTransformNoteExchangeDto>(wmsCountAdjust); |
|||
|
|||
exchangeCountAdjust.Detail = wmsCountAdjustDetail; |
|||
return exchangeCountAdjust; |
|||
} |
|||
} |
|||
|
|||
@ -0,0 +1,45 @@ |
|||
|
|||
using System.ComponentModel.DataAnnotations; |
|||
|
|||
namespace Win_in.Sfs.Wms.DataExchange.WMS.ItemTransformNote; |
|||
|
|||
public class ItemTransformNoteDetailExchangeDto |
|||
{ |
|||
/// <summary>
|
|||
/// 物品代码
|
|||
/// </summary>
|
|||
[Display(Name = "物品代码")] |
|||
public string ItemCode { get; set; } |
|||
/// <summary>
|
|||
/// ERP库位
|
|||
/// </summary>
|
|||
[Display(Name = "ERP库位")] |
|||
public string LocationErpCode { get; set; } |
|||
/// <summary>
|
|||
/// 原因代码
|
|||
/// </summary>
|
|||
[Display(Name = "原因代码")] |
|||
public string ReasonCode { get; set; } |
|||
/// <summary>
|
|||
/// 调整数量
|
|||
/// </summary>
|
|||
[Display(Name = "来源数量")] |
|||
public decimal FromQty { get; set; } |
|||
/// <summary>
|
|||
/// 目标数量
|
|||
/// </summary>
|
|||
[Display(Name = "目标数量")] |
|||
public decimal ToQty { get; set; } |
|||
/// <summary>
|
|||
/// 目标库位
|
|||
/// </summary>
|
|||
[Display(Name = "目标库位")] |
|||
[Required(ErrorMessage = "{0}是必填项")] |
|||
public string ToLocationCode { get; set; } |
|||
/// <summary>
|
|||
/// 目标物品代码
|
|||
/// </summary>
|
|||
[Display(Name = "目标物品代码")] |
|||
public string ToItemCode { get; set; } |
|||
|
|||
} |
|||
@ -0,0 +1,30 @@ |
|||
using System; |
|||
using System.ComponentModel.DataAnnotations; |
|||
namespace Win_in.Sfs.Wms.DataExchange.WMS.ItemTransformNote; |
|||
|
|||
public class ItemTransformNoteExchangeDto |
|||
{ |
|||
/// <summary>
|
|||
/// 单据号
|
|||
/// </summary>
|
|||
public string Number { get; set; } |
|||
/// <summary>
|
|||
/// 生效日期
|
|||
/// </summary>
|
|||
public DateTime ActiveDate { get; set; } = DateTime.Now.Date; |
|||
/// <summary>
|
|||
/// 操作员
|
|||
/// </summary>
|
|||
public string Worker { get; set; } |
|||
|
|||
/// <summary>
|
|||
/// 类型
|
|||
/// </summary>
|
|||
public string Type { get; set; } |
|||
|
|||
/// <summary>
|
|||
/// 明细
|
|||
/// </summary>
|
|||
[Display(Name = "明细")] |
|||
public ItemTransformNoteDetailExchangeDto Detail { get; set; } = new(); |
|||
} |
|||
Loading…
Reference in new issue