Browse Source

修改 计划外出入库 的 单位

集成Redis
郑勃旭 2 years ago
parent
commit
2b890b9e04
  1. 1
      be/Modules/Store/src/Win_in.Sfs.Wms.Store.Application.Contracts/Requests/UnplannedIssueRequests/Inputs/UnplannedIssueRequestImportInput.cs
  2. 1
      be/Modules/Store/src/Win_in.Sfs.Wms.Store.Application.Contracts/Requests/UnplannedReceiptRequests/Inputs/UnplannedReceiptRequestImportInput.cs
  3. 34
      be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/UnplannedIssueRequests/UnplannedIssueRequestManager.cs
  4. 33
      be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/UnplannedReceiptRequests/UnplannedReceiptRequestManager.cs

1
be/Modules/Store/src/Win_in.Sfs.Wms.Store.Application.Contracts/Requests/UnplannedIssueRequests/Inputs/UnplannedIssueRequestImportInput.cs

@ -26,7 +26,6 @@ public class UnplannedIssueRequestImportInput : SfsStoreImportInputBase
/// 单位 /// 单位
/// </summary> /// </summary>
[Display(Name = "单位")] [Display(Name = "单位")]
[Required(ErrorMessage = "单位不能为空")]
public string Uom { get; set; } public string Uom { get; set; }
/// <summary> /// <summary>

1
be/Modules/Store/src/Win_in.Sfs.Wms.Store.Application.Contracts/Requests/UnplannedReceiptRequests/Inputs/UnplannedReceiptRequestImportInput.cs

@ -26,7 +26,6 @@ public class UnplannedReceiptRequestImportInput : SfsStoreImportInputBase
/// 单位 /// 单位
/// </summary> /// </summary>
[Display(Name = "单位")] [Display(Name = "单位")]
[Required(ErrorMessage = "单位不能为空")]
public string Uom { get; set; } public string Uom { get; set; }
/// <summary> /// <summary>

34
be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/UnplannedIssueRequests/UnplannedIssueRequestManager.cs

@ -1,20 +1,26 @@
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks; using System.Threading.Tasks;
using Volo.Abp;
using Win_in.Sfs.Basedata.Application.Contracts;
namespace Win_in.Sfs.Wms.Store.Domain; namespace Win_in.Sfs.Wms.Store.Domain;
public class UnplannedIssueRequestManager : SfsStoreRequestManagerBase<UnplannedIssueRequest, UnplannedIssueRequestDetail>, IUnplannedIssueRequestManager public class UnplannedIssueRequestManager : SfsStoreRequestManagerBase<UnplannedIssueRequest, UnplannedIssueRequestDetail>, IUnplannedIssueRequestManager
{ {
public readonly IUnplannedIssueRequestRepository _repository; private readonly IUnplannedIssueRequestRepository _repository;
private readonly IDictAppService _dictAppService;
private readonly IItemBasicAppService _itemBasicAppService;
//public readonly _repository; //public readonly _repository;
//public readonly IUnplannedIssueRequestRepository _repository; //public readonly IUnplannedIssueRequestRepository _repository;
public UnplannedIssueRequestManager( public UnplannedIssueRequestManager(
IUnplannedIssueRequestRepository repository IUnplannedIssueRequestRepository repository, IDictAppService dictAppService, IItemBasicAppService itemBasicAppService) : base(repository)
) : base(repository)
{ {
_repository = repository; _repository = repository;
_dictAppService = dictAppService;
_itemBasicAppService = itemBasicAppService;
} }
/// <summary> /// <summary>
@ -29,4 +35,26 @@ public class UnplannedIssueRequestManager : SfsStoreRequestManagerBase<Unplanned
await CreateManyAsync(mergeEntities).ConfigureAwait(false); await CreateManyAsync(mergeEntities).ConfigureAwait(false);
} }
public override async Task<List<UnplannedIssueRequest>> CreateManyAsync(List<UnplannedIssueRequest> entities)
{
var dictDto = await _dictAppService.GetByCodeAsync("CaseCode").ConfigureAwait(false);
foreach (var entity in entities)
{
foreach (var unplannedIssueRequestDetail in entity.Details)
{
var flag = dictDto.Items.ToList().FirstOrDefault(p => p.Value == unplannedIssueRequestDetail.CaseCode);
if (flag == null)
{
throw new UserFriendlyException($"【{unplannedIssueRequestDetail.CaseCode}】专案不存在");
}
var itemBasicDto= await _itemBasicAppService.GetByCodeAsync(unplannedIssueRequestDetail.ItemCode).ConfigureAwait(false);
unplannedIssueRequestDetail.Uom = itemBasicDto.BasicUom;
}
}
return await base.CreateManyAsync(entities).ConfigureAwait(false);
}
} }

33
be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/UnplannedReceiptRequests/UnplannedReceiptRequestManager.cs

@ -1,20 +1,26 @@
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks; using System.Threading.Tasks;
using Volo.Abp;
using Win_in.Sfs.Basedata.Application.Contracts;
namespace Win_in.Sfs.Wms.Store.Domain; namespace Win_in.Sfs.Wms.Store.Domain;
public class UnplannedReceiptRequestManager : SfsStoreRequestManagerBase<UnplannedReceiptRequest, UnplannedReceiptRequestDetail>, IUnplannedReceiptRequestManager public class UnplannedReceiptRequestManager : SfsStoreRequestManagerBase<UnplannedReceiptRequest, UnplannedReceiptRequestDetail>, IUnplannedReceiptRequestManager
{ {
public readonly IUnplannedReceiptRequestRepository _repository; private readonly IUnplannedReceiptRequestRepository _repository;
private readonly IDictAppService _dictAppService;
private readonly IItemBasicAppService _itemBasicAppService;
//public readonly _repository; //public readonly _repository;
//public readonly IUnplannedReceiptRequestRepository _repository; //public readonly IUnplannedReceiptRequestRepository _repository;
public UnplannedReceiptRequestManager( public UnplannedReceiptRequestManager(
IUnplannedReceiptRequestRepository repository IUnplannedReceiptRequestRepository repository, IDictAppService dictAppService, IItemBasicAppService itemBasicAppService) : base(repository)
) : base(repository)
{ {
_repository = repository; _repository = repository;
_dictAppService = dictAppService;
_itemBasicAppService = itemBasicAppService;
} }
/// <summary> /// <summary>
@ -30,4 +36,25 @@ public class UnplannedReceiptRequestManager : SfsStoreRequestManagerBase<Unplann
await CreateManyAsync(mergeEntities).ConfigureAwait(false); await CreateManyAsync(mergeEntities).ConfigureAwait(false);
} }
public override async Task<List<UnplannedReceiptRequest>> CreateManyAsync(List<UnplannedReceiptRequest> entities)
{
var dictDto= await _dictAppService.GetByCodeAsync("CaseCode").ConfigureAwait(false);
foreach (var entity in entities)
{
foreach (var unplannedReceiptRequestDetail in entity.Details)
{
var flag= dictDto.Items.ToList().FirstOrDefault(p => p.Value == unplannedReceiptRequestDetail.CaseCode);
if (flag == null)
{
throw new UserFriendlyException($"【{unplannedReceiptRequestDetail.CaseCode}】专案不存在");
}
var itemBasicDto = await _itemBasicAppService.GetByCodeAsync(unplannedReceiptRequestDetail.ItemCode).ConfigureAwait(false);
unplannedReceiptRequestDetail.Uom = itemBasicDto.BasicUom;
}
}
return await base.CreateManyAsync(entities).ConfigureAwait(false);
}
} }

Loading…
Cancel
Save