|
|
|
@ -3,23 +3,15 @@ using System.Collections.Generic; |
|
|
|
using System.ComponentModel.DataAnnotations; |
|
|
|
using System.Linq; |
|
|
|
using System.Threading.Tasks; |
|
|
|
using DocumentFormat.OpenXml.Office2010.ExcelAc; |
|
|
|
using DocumentFormat.OpenXml.Spreadsheet; |
|
|
|
using Microsoft.AspNetCore.Authorization; |
|
|
|
using Microsoft.AspNetCore.Http; |
|
|
|
using Microsoft.AspNetCore.Mvc; |
|
|
|
using Microsoft.EntityFrameworkCore; |
|
|
|
using Volo.Abp; |
|
|
|
using Volo.Abp.Uow; |
|
|
|
using Volo.Abp.Users; |
|
|
|
using Win_in.Sfs.Basedata.Application.Contracts; |
|
|
|
using Win_in.Sfs.Shared.Application.Contracts; |
|
|
|
using Win_in.Sfs.Shared.Domain.Shared; |
|
|
|
using Win_in.Sfs.Shared.Event; |
|
|
|
using Win_in.Sfs.Wms.Store.Application.Contracts; |
|
|
|
using Win_in.Sfs.Wms.Store.Domain; |
|
|
|
using Win_in.Sfs.Wms.Store.Domain.Shared; |
|
|
|
using PurchaseOrderDetail = Win_in.Sfs.Wms.Store.Domain.PurchaseOrderDetail; |
|
|
|
|
|
|
|
namespace Win_in.Sfs.Wms.Store.Application; |
|
|
|
|
|
|
|
@ -34,7 +26,8 @@ public class PurchaseOrderAppService : |
|
|
|
private readonly IPurchaseOrderManager _purchaseOrderManager; |
|
|
|
private readonly ISupplierAppService _supplierAppService; |
|
|
|
private readonly IItemBasicAppService _itemBasicAppService; |
|
|
|
|
|
|
|
private readonly IPurchaseReceiptJobAppService _purchaseReceiptJobAppService; |
|
|
|
|
|
|
|
public PurchaseOrderAppService( |
|
|
|
IPurchaseOrderRepository repository, |
|
|
|
IPurchaseOrderManager purchaseOrderManager, |
|
|
|
@ -53,30 +46,31 @@ public class PurchaseOrderAppService : |
|
|
|
#region 东阳使用
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
/// 用来重写 导入数据时可以加工数据
|
|
|
|
/// 用来重写 导入数据时可以加工数据
|
|
|
|
/// </summary>
|
|
|
|
/// <param name="dictionary"></param>
|
|
|
|
/// <returns></returns>
|
|
|
|
protected override async Task<Dictionary<PurchaseOrder, EntityState>> ImportProcessingEntityAsync( |
|
|
|
Dictionary<PurchaseOrder, EntityState> dictionary) |
|
|
|
{ |
|
|
|
var addList= dictionary.Where(p => p.Value == EntityState.Added).Select(p => p.Key); |
|
|
|
var addList = dictionary.Where(p => p.Value == EntityState.Added).Select(p => p.Key); |
|
|
|
|
|
|
|
foreach (var purchaseOrder in addList) |
|
|
|
{ |
|
|
|
purchaseOrder.CreatorId = CurrentUser.Id; |
|
|
|
purchaseOrder.Worker = CurrentUser.Name; |
|
|
|
|
|
|
|
var supplierDto=await _supplierAppService.GetByCodeAsync(purchaseOrder.SupplierCode).ConfigureAwait(false); |
|
|
|
var supplierDto = |
|
|
|
await _supplierAppService.GetByCodeAsync(purchaseOrder.SupplierCode).ConfigureAwait(false); |
|
|
|
purchaseOrder.SupplierCode = supplierDto.Code; |
|
|
|
purchaseOrder.SupplierAddress = supplierDto.Address; |
|
|
|
purchaseOrder.SupplierName= supplierDto.Name; |
|
|
|
purchaseOrder.SupplierName = supplierDto.Name; |
|
|
|
|
|
|
|
foreach (var detail in purchaseOrder.Details) |
|
|
|
{ |
|
|
|
var itemBasicDto= await _itemBasicAppService.GetByCodeAsync(detail.ItemCode).ConfigureAwait(false); |
|
|
|
var itemBasicDto = await _itemBasicAppService.GetByCodeAsync(detail.ItemCode).ConfigureAwait(false); |
|
|
|
|
|
|
|
detail.ItemName= itemBasicDto.Name; |
|
|
|
detail.ItemName = itemBasicDto.Name; |
|
|
|
detail.ItemDesc1 = itemBasicDto.Desc1; |
|
|
|
detail.ItemDesc2 = itemBasicDto.Desc2; |
|
|
|
} |
|
|
|
@ -87,10 +81,8 @@ public class PurchaseOrderAppService : |
|
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
/// 【创建】采购订单
|
|
|
|
/// 【创建】采购订单
|
|
|
|
/// </summary>
|
|
|
|
/// <param name="input"></param>
|
|
|
|
/// <returns></returns>
|
|
|
|
@ -111,7 +103,7 @@ public class PurchaseOrderAppService : |
|
|
|
} |
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
/// 【批量创建】采购订单
|
|
|
|
/// 【批量创建】采购订单
|
|
|
|
/// </summary>
|
|
|
|
/// <param name="inputs"></param>
|
|
|
|
/// <returns></returns>
|
|
|
|
@ -163,8 +155,6 @@ public class PurchaseOrderAppService : |
|
|
|
await _repository.UpdateAsync(entity).ConfigureAwait(false); |
|
|
|
} |
|
|
|
|
|
|
|
#region Function
|
|
|
|
|
|
|
|
[HttpPost("complete/{number}")] |
|
|
|
public async Task<PurchaseOrderDTO> CompleteAsync(string number) |
|
|
|
{ |
|
|
|
@ -173,9 +163,6 @@ public class PurchaseOrderAppService : |
|
|
|
} |
|
|
|
|
|
|
|
[HttpPost("cancel/{id}")] |
|
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
[HttpPost("{id}/detail/open/{detailId}")] |
|
|
|
public virtual async Task OpenDetailAsync(Guid id, Guid detailId) |
|
|
|
{ |
|
|
|
@ -188,13 +175,6 @@ public class PurchaseOrderAppService : |
|
|
|
await _purchaseOrderManager.CloseDetailAsync(id, detailId).ConfigureAwait(false); |
|
|
|
} |
|
|
|
|
|
|
|
[HttpPost("check-status")] |
|
|
|
public virtual async Task CheckStatusAsync(string number) |
|
|
|
{ |
|
|
|
await Task.CompletedTask.ConfigureAwait(false); |
|
|
|
throw new NotImplementedException(); |
|
|
|
} |
|
|
|
|
|
|
|
[HttpPost("upsert")] |
|
|
|
public virtual async Task UpsertAsync(PurchaseOrderEditInput input) |
|
|
|
{ |
|
|
|
@ -202,6 +182,27 @@ public class PurchaseOrderAppService : |
|
|
|
await _repository.UpsertAsync(entity).ConfigureAwait(false); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
[HttpGet("get-list-by-item-code")] |
|
|
|
public virtual async Task<List<PurchaseOrderDTO>> GetListByItemCodeAsync(string itemCode) |
|
|
|
{ |
|
|
|
var entitys = await _repository.GetListAsync(p => p.Details.Any(y => y.ItemCode == itemCode)) |
|
|
|
.ConfigureAwait(false); |
|
|
|
|
|
|
|
var dtos = ObjectMapper.Map<List<PurchaseOrder>, List<PurchaseOrderDTO>>(entitys); |
|
|
|
|
|
|
|
return dtos; |
|
|
|
} |
|
|
|
|
|
|
|
#region 校验
|
|
|
|
|
|
|
|
[HttpPost("check-status")] |
|
|
|
public virtual async Task CheckStatusAsync(string number) |
|
|
|
{ |
|
|
|
await Task.CompletedTask.ConfigureAwait(false); |
|
|
|
throw new NotImplementedException(); |
|
|
|
} |
|
|
|
|
|
|
|
protected virtual async Task CheckImportInputBusinessAsync(PurchaseOrderImportInput importInput, |
|
|
|
EnumImportMethod importMethod, List<ValidationResult> validationRresult) |
|
|
|
{ |
|
|
|
@ -231,47 +232,17 @@ public class PurchaseOrderAppService : |
|
|
|
Check.NotNull(item, "供应商代码", "供应商不存在"); |
|
|
|
} |
|
|
|
|
|
|
|
protected override async Task<PurchaseOrder> GetEntityAsync(PurchaseOrderImportInput importInput) |
|
|
|
{ |
|
|
|
return await _repository.FindAsync(t => t.Number == importInput.Number).ConfigureAwait(false); |
|
|
|
} |
|
|
|
|
|
|
|
protected virtual async Task ImportDataAsync(List<PurchaseOrder> entites, List<PurchaseOrder> deleteEntities) |
|
|
|
{ |
|
|
|
await _purchaseOrderManager.ImportDataAsync(entites, deleteEntities).ConfigureAwait(false); |
|
|
|
} |
|
|
|
|
|
|
|
protected override Func<PurchaseOrderImportInput, object> GetEntityExpression() |
|
|
|
{ |
|
|
|
return t => t.Number; |
|
|
|
} |
|
|
|
|
|
|
|
[HttpGet("get-list-by-item-code")] |
|
|
|
public virtual async Task<List<PurchaseOrderDTO>> GetListByItemCodeAsync(string itemCode) |
|
|
|
{ |
|
|
|
var entitys = await _repository.GetListAsync(p => p.Details.Any(y => y.ItemCode == itemCode)) |
|
|
|
.ConfigureAwait(false); |
|
|
|
|
|
|
|
var dtos = ObjectMapper.Map<List<PurchaseOrder>, List<PurchaseOrderDTO>>(entitys); |
|
|
|
|
|
|
|
return dtos; |
|
|
|
} |
|
|
|
#endregion
|
|
|
|
|
|
|
|
[HttpGet("get-list-by-supplier-code-and-item-code")] |
|
|
|
public virtual async Task<List<PurchaseOrderDTO>> GetListBySupplierCodeAsync(string supplierCode, string itemCode) |
|
|
|
{ |
|
|
|
var entitys = await _repository.GetListAsync(p => p.Details.Any(y => y.ItemCode == itemCode) && p.SupplierCode == supplierCode); |
|
|
|
|
|
|
|
List<PurchaseOrder> list = new List<PurchaseOrder>(); |
|
|
|
var entitys = await _repository.GetListAsync(p => p.Details.Any(y => y.ItemCode == itemCode) && p.SupplierCode == supplierCode).ConfigureAwait(false); |
|
|
|
|
|
|
|
foreach (var entity in entitys) |
|
|
|
{ |
|
|
|
var purchaseOrder = await _repository.GetAsync(entity.Id); |
|
|
|
list.Add(purchaseOrder); |
|
|
|
} |
|
|
|
|
|
|
|
var dtos = ObjectMapper.Map<List<PurchaseOrder>, List<PurchaseOrderDTO>>(list); |
|
|
|
var dtos = ObjectMapper.Map<List<PurchaseOrder>, List<PurchaseOrderDTO>>(entitys); |
|
|
|
|
|
|
|
return dtos; |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
