16 changed files with 499 additions and 336 deletions
@ -0,0 +1,104 @@ |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.Linq; |
|||
using System.Text; |
|||
using System.Threading.Tasks; |
|||
using EFCore.BulkExtensions; |
|||
using Microsoft.AspNetCore.Authorization; |
|||
using Microsoft.AspNetCore.Http; |
|||
using Microsoft.AspNetCore.Mvc; |
|||
using SettleAccount.Bases; |
|||
using SettleAccount.Domain.BQ; |
|||
using Volo.Abp; |
|||
using Volo.Abp.Application.Dtos; |
|||
using Win.Abp.Snowflakes; |
|||
using Win.Sfs.BaseData.ImportExcelCommon; |
|||
using Win.Sfs.SettleAccount.Bases.DomainServices; |
|||
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.Shared.RepositoryBase; |
|||
|
|||
namespace Win.Sfs.SettleAccount.Bases; |
|||
/// <summary>
|
|||
/// 发票明细调整表
|
|||
/// </summary>
|
|||
[AllowAnonymous] |
|||
[Route("api/settleaccount/[controller]/[action]")]
|
|||
public class ADJ_SERVICE : BASE_SERVICE |
|||
{ |
|||
protected readonly INormalEfCoreRepository<PUB_ADJ_DETAIL, Guid> _repository; |
|||
protected readonly BaseDomainService _baseDomainService; |
|||
public ADJ_SERVICE( |
|||
INormalEfCoreRepository<PUB_ADJ_DETAIL, Guid> repository, |
|||
BaseDomainService baseDomainService, |
|||
IExcelImportAppService excelImportService, |
|||
ISnowflakeIdGenerator snowflakeIdGenerator, |
|||
ICommonManager commonManager |
|||
) |
|||
: base(excelImportService, snowflakeIdGenerator, commonManager) |
|||
{ |
|||
_repository = repository; |
|||
_baseDomainService = baseDomainService; |
|||
} |
|||
/// <summary>
|
|||
///查询明细
|
|||
/// </summary>
|
|||
/// <param name="input">明细查询条件</param>
|
|||
/// <returns></returns>
|
|||
[HttpPost] |
|||
|
|||
public virtual async Task<PagedResultDto<PUB_ADJ_DETAIL_DTO>> DetailQueryAsync(PUB_ADJ_DETAIL_REQ_DTO input) |
|||
{ |
|||
var entitys = await _repository.GetListByFilterAsync(input.Filters, input.Sorting, input.MaxResultCount, input.SkipCount); |
|||
var totalCount = await _repository.GetCountByFilterAsync(input.Filters); |
|||
var dtos = ObjectMapper.Map<List<PUB_ADJ_DETAIL>, List<PUB_ADJ_DETAIL_DTO>>(entitys); |
|||
return new PagedResultDto<PUB_ADJ_DETAIL_DTO>(totalCount, dtos); |
|||
} |
|||
/// <summary>
|
|||
/// 导入文件
|
|||
/// </summary>
|
|||
/// <param name="files"></param>
|
|||
/// <returns></returns>
|
|||
/// <exception cref="BusinessException"></exception>
|
|||
[HttpPost] |
|||
[DisableRequestSizeLimit] |
|||
public async Task<string> ExcelImport([FromForm] IFormFileCollection files) |
|||
{ |
|||
List<ErrorExportDto> errorList = new List<ErrorExportDto>(); |
|||
ExportImporter _exportImporter = new ExportImporter(); |
|||
var result = await _exportImporter.UploadExcelImport<PUB_ADJ_DETAIL_IMP_DTO>(files, _excelImportService); |
|||
if (result.Count == 0) |
|||
{ |
|||
throw new BusinessException("8989", "导入数据记录为0条"); |
|||
} |
|||
var deletels = _repository.Where(p => p.OldInvBillNum == result.FirstOrDefault().OldInvBillNum).ToList(); |
|||
var first = deletels.FirstOrDefault(); |
|||
if (!string.IsNullOrEmpty(first.InvBillNum)) |
|||
{ |
|||
throw new BusinessException("8989", $"调整记录已经新发票号:{first.InvBillNum}"); |
|||
} |
|||
var entityList = ObjectMapper.Map<List<PUB_ADJ_DETAIL_IMP_DTO>, List<PUB_ADJ_DETAIL>>(result); |
|||
var codelist = entityList.Select(p => p.LU).ToList(); |
|||
var errors = await _baseDomainService.CheckBase(codelist, new BASE_CONF() { IsRelationShip = true }); |
|||
foreach (var itm in errors) |
|||
{ |
|||
errorList.Add( |
|||
new ErrorExportDto() { ItemCode = $"{itm}", Message = $"[客户零件关系表]不存在客户零件号{itm}" }); |
|||
} |
|||
var errorEntitylist = await _baseDomainService.CheckPriceList(entityList); |
|||
if (errorEntitylist.Count > 0) |
|||
{ |
|||
foreach (var itm in errorEntitylist) |
|||
{ |
|||
errorList.Add(new ErrorExportDto() { ItemCode = $"{itm.LU}", Message = $"客户零件号{itm.LU}标识号{itm.PN}下线日期{itm.SettleDate}不存在价格单记录" }); |
|||
} |
|||
} |
|||
await _repository.DbContext.BulkDeleteAsync(deletels);//删除发票下所有调整明细
|
|||
await _repository.DbContext.BulkInsertAsync(entityList); |
|||
return ApplicationConsts.SuccessStr; |
|||
} |
|||
|
|||
} |
|||
Loading…
Reference in new issue