5 changed files with 229 additions and 0 deletions
@ -0,0 +1,67 @@ |
|||||
|
using Magicodes.ExporterAndImporter.Core; |
||||
|
using System.ComponentModel.DataAnnotations; |
||||
|
using Win.Sfs.Shared.DtoBase; |
||||
|
|
||||
|
namespace Win.Sfs.SettleAccount.Entities.BQ.Dtos |
||||
|
{ |
||||
|
/// <summary>
|
||||
|
/// 采购价格单
|
||||
|
/// </summary>
|
||||
|
public class PURCHASE_PRICE_DTO |
||||
|
{ |
||||
|
/// <summary>
|
||||
|
/// 零件号
|
||||
|
/// </summary>
|
||||
|
[Display(Name = "零件号")] |
||||
|
public string LU { get; set; } |
||||
|
|
||||
|
/// <summary>
|
||||
|
/// 价格
|
||||
|
/// </summary>
|
||||
|
[Display(Name = "价格")] |
||||
|
public decimal Price { get; set; } |
||||
|
} |
||||
|
|
||||
|
public class PURCHASE_PRICE_IMPORT_DTO |
||||
|
{ |
||||
|
/// <summary>
|
||||
|
/// 零件号
|
||||
|
/// </summary>
|
||||
|
[Display(Name = "零件号")] |
||||
|
[ImporterHeader(Name = "零件号")] |
||||
|
public string LU { get; set; } |
||||
|
|
||||
|
/// <summary>
|
||||
|
/// 价格
|
||||
|
/// </summary>
|
||||
|
[Display(Name = "价格")] |
||||
|
[ImporterHeader(Name = "价格")] |
||||
|
public decimal Price { get; set; } |
||||
|
} |
||||
|
|
||||
|
public class PURCHASE_PRICE_REQUEST_DTO : RequestDtoBase |
||||
|
{ |
||||
|
|
||||
|
} |
||||
|
|
||||
|
/// <summary>
|
||||
|
/// 导出
|
||||
|
/// </summary>
|
||||
|
public class PURCHASE_PRICE_EXPORT_DTO |
||||
|
{ |
||||
|
/// <summary>
|
||||
|
/// 零件号
|
||||
|
/// </summary>
|
||||
|
[Display(Name = "零件号")] |
||||
|
[ExporterHeader(DisplayName = "零件号")] |
||||
|
public string LU { get; set; } |
||||
|
|
||||
|
/// <summary>
|
||||
|
/// 价格
|
||||
|
/// </summary>
|
||||
|
[Display(Name = "价格")] |
||||
|
[ExporterHeader(DisplayName = "价格")] |
||||
|
public decimal Price { get; set; } |
||||
|
} |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,8 @@ |
|||||
|
using Win.Sfs.Shared.DtoBase; |
||||
|
|
||||
|
namespace Win.Sfs.SettleAccount.Entities.BQ.Dtos |
||||
|
{ |
||||
|
public class RequestDto : RequestDtoBase |
||||
|
{ |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,131 @@ |
|||||
|
using Microsoft.AspNetCore.Authorization; |
||||
|
using Microsoft.AspNetCore.Http; |
||||
|
using Microsoft.AspNetCore.Mvc; |
||||
|
using SettleAccount.Domain.BQ; |
||||
|
using Shouldly; |
||||
|
using System; |
||||
|
using System.Collections.Generic; |
||||
|
using System.Linq; |
||||
|
using System.Threading.Tasks; |
||||
|
using Volo.Abp.Application.Dtos; |
||||
|
using Volo.Abp.Caching; |
||||
|
using Win.Abp.Snowflakes; |
||||
|
using Win.Sfs.BaseData.ImportExcelCommon; |
||||
|
using Win.Sfs.SettleAccount.CommonManagers; |
||||
|
using Win.Sfs.SettleAccount.Constant; |
||||
|
using Win.Sfs.SettleAccount.Entities.BQ.Dtos; |
||||
|
using Win.Sfs.SettleAccount.ExcelImporter; |
||||
|
using Win.Sfs.SettleAccount.ExportReports; |
||||
|
using Win.Sfs.SettleAccount.MaterialRelationships; |
||||
|
using Win.Sfs.Shared.DtoBase; |
||||
|
using Win.Sfs.Shared.RepositoryBase; |
||||
|
|
||||
|
namespace Win.Sfs.SettleAccount.Entities.BQ |
||||
|
{ |
||||
|
/// <summary>
|
||||
|
/// 采购价格单
|
||||
|
/// </summary>
|
||||
|
[AllowAnonymous] |
||||
|
[Route("api/settleaccount/PURCHASE_PRICE_SERVICE")] |
||||
|
public class PURCHASE_PRICE_SERVICE : SettleAccountApplicationBase<PURCHASE_PRICE> |
||||
|
{ |
||||
|
/// <summary>
|
||||
|
/// 采购价格单仓储
|
||||
|
/// </summary>
|
||||
|
private readonly INormalEfCoreRepository<PURCHASE_PRICE, Guid> _repository; |
||||
|
|
||||
|
public PURCHASE_PRICE_SERVICE( |
||||
|
INormalEfCoreRepository<PURCHASE_PRICE, Guid> repository, |
||||
|
IDistributedCache<PURCHASE_PRICE> cache, |
||||
|
IExcelImportAppService excelImportService, |
||||
|
ISnowflakeIdGenerator snowflakeIdGenerator, |
||||
|
ICommonManager commonManager |
||||
|
) : base(cache, excelImportService, snowflakeIdGenerator, commonManager) |
||||
|
{ |
||||
|
_repository = repository; |
||||
|
} |
||||
|
|
||||
|
#region 导入、导出
|
||||
|
/// <summary>
|
||||
|
/// 导入
|
||||
|
/// </summary>
|
||||
|
[HttpPost] |
||||
|
[Route("Import")] |
||||
|
public async Task<string> ImportAsync([FromForm] IFormFileCollection files) |
||||
|
{ |
||||
|
ExportImporter _exportImporter = new ExportImporter(); |
||||
|
var result = await _exportImporter.UploadExcelImport<PURCHASE_PRICE_IMPORT_DTO>(files, _excelImportService); |
||||
|
var _ls = ObjectMapper.Map<List<PURCHASE_PRICE_IMPORT_DTO>, List<PURCHASE_PRICE>>(result); |
||||
|
List<string> _errorList = new List<string>(); |
||||
|
var checkList = new List<ErrorExportDto>(); |
||||
|
|
||||
|
if (_ls.Count > 0) |
||||
|
{ |
||||
|
var query = from arc in _ls |
||||
|
group arc by new { arc.LU } |
||||
|
into g |
||||
|
where g.Count() > 1 |
||||
|
|
||||
|
select g; |
||||
|
foreach (var itm in query) |
||||
|
{ |
||||
|
checkList.Add(new ErrorExportDto(string.Empty, string.Empty, string.Empty, string.Empty, string.Empty, string.Empty, string.Format("物料号{0}有重复", itm.Key.LU), string.Empty)); |
||||
|
} |
||||
|
} |
||||
|
foreach (var itm in _ls) |
||||
|
{ |
||||
|
var _first = _repository.FirstOrDefault(p => p.LU == itm.LU); |
||||
|
if (_first != null) |
||||
|
{ |
||||
|
_first.Update(itm.Price); |
||||
|
await _repository.UpdateAsync(_first); |
||||
|
} |
||||
|
else |
||||
|
{ |
||||
|
await _repository.InsertAsync(itm); |
||||
|
} |
||||
|
} |
||||
|
if (checkList.Count > 0) |
||||
|
{ |
||||
|
return await ExportErrorReportAsync(checkList); |
||||
|
} |
||||
|
return ApplicationConsts.SuccessStr; |
||||
|
} |
||||
|
|
||||
|
/// <summary>
|
||||
|
/// 导出
|
||||
|
/// </summary>
|
||||
|
[HttpPost] |
||||
|
[Route("Export")] |
||||
|
public async Task<string> ExportAsync(RequestDto input) |
||||
|
{ |
||||
|
string fileName = $"采购价格单_{Guid.NewGuid()}.xlsx"; |
||||
|
var entities = await _repository.GetListByFilterAsync(input.Filters, input.Sorting, int.MaxValue, 0, true); |
||||
|
var dtos = ObjectMapper.Map<List<PURCHASE_PRICE>, List<PURCHASE_PRICE_EXPORT_DTO>>(entities); |
||||
|
|
||||
|
ExportImporter _exportImporter = new ExportImporter(); |
||||
|
var result = await _exportImporter.ExcelExporter(dtos); |
||||
|
result.ShouldNotBeNull(); |
||||
|
|
||||
|
await _excelImportService.SaveBlobAsync(new SaveExcelImportInputDto { Name = fileName, Content = result }); |
||||
|
return fileName; |
||||
|
} |
||||
|
#endregion
|
||||
|
|
||||
|
#region CURD
|
||||
|
/// <summary>
|
||||
|
/// 获取列表
|
||||
|
/// </summary>
|
||||
|
[HttpPost] |
||||
|
[Route("list")] |
||||
|
public async Task<PagedResultDto<PURCHASE_PRICE_DTO>> GetListAsync(RequestDto input) |
||||
|
{ |
||||
|
var entities = await _repository.GetListByFilterAsync(input.Filters, input.Sorting, input.MaxResultCount, input.SkipCount, true); |
||||
|
var totalCount = await _repository.GetCountByFilterAsync(input.Filters); |
||||
|
var dtos = ObjectMapper.Map<List<PURCHASE_PRICE>, List<PURCHASE_PRICE_DTO>>(entities); |
||||
|
return new PagedResultDto<PURCHASE_PRICE_DTO>(totalCount, dtos); |
||||
|
} |
||||
|
#endregion
|
||||
|
|
||||
|
} |
||||
|
} |
||||
Loading…
Reference in new issue