From 7bf91c71dca50d1e67bf203822ed0d36054509fb Mon Sep 17 00:00:00 2001 From: schangxiang@126.com <schangxiang@126.com> Date: 周二, 13 5月 2025 16:37:20 +0800 Subject: [PATCH] 使用 脚本 --- Weben_CMS专用代码生成器/Weben_CMS_TemplateDemo/server/src/CMS.Plugin.HIAWms.Application/Implements/WmsMaterialAppService.cs | 674 +++++++++++++++++++++++++++++-------------------------- 1 files changed, 352 insertions(+), 322 deletions(-) diff --git "a/Weben_CMS\344\270\223\347\224\250\344\273\243\347\240\201\347\224\237\346\210\220\345\231\250/Weben_CMS_TemplateDemo/server/src/CMS.Plugin.HIAWms.Application/Implements/WmsMaterialAppService.cs" "b/Weben_CMS\344\270\223\347\224\250\344\273\243\347\240\201\347\224\237\346\210\220\345\231\250/Weben_CMS_TemplateDemo/server/src/CMS.Plugin.HIAWms.Application/Implements/WmsMaterialAppService.cs" index 90560f4..3d9ab58 100644 --- "a/Weben_CMS\344\270\223\347\224\250\344\273\243\347\240\201\347\224\237\346\210\220\345\231\250/Weben_CMS_TemplateDemo/server/src/CMS.Plugin.HIAWms.Application/Implements/WmsMaterialAppService.cs" +++ "b/Weben_CMS\344\270\223\347\224\250\344\273\243\347\240\201\347\224\237\346\210\220\345\231\250/Weben_CMS_TemplateDemo/server/src/CMS.Plugin.HIAWms.Application/Implements/WmsMaterialAppService.cs" @@ -1,127 +1,132 @@ -using CMS.Plugin.HIAWms.Application.Contracts.Dtos.WmsMaterial; -using CMS.Plugin.HIAWms.Application.Contracts.Services; -using CMS.Plugin.HIAWms.Domain.Shared; -using CmsQueryExtensions; -using CMS.Plugin.HIAWms.Domain.WmsMaterial; -using CmsQueryExtensions.Extension; -using System.Linq.Expressions; -using Volo.Abp; -using Volo.Abp.Application.Dtos; -using Volo.Abp.Data; -using Volo.Abp.ObjectExtending; -using Volo.Abp.ObjectMapping; - -namespace CMS.Plugin.HIAWms.Application.Implements; - +using CMS.Plugin.HIAWms.Application.Contracts.Dtos.WmsMaterial; +using CMS.Plugin.HIAWms.Application.Contracts.Services; +using CMS.Plugin.HIAWms.Domain.Shared; +using CmsQueryExtensions; +using CMS.Plugin.HIAWms.Domain.WmsMaterial; +using CmsQueryExtensions.Extension; +using System.Linq.Expressions; +using Volo.Abp; +using Volo.Abp.Application.Dtos; +using Volo.Abp.Data; +using Volo.Abp.ObjectExtending; +using Volo.Abp.ObjectMapping; +using CmsQueryExtensions.Entitys; + + +namespace CMS.Plugin.HIAWms.Application.Implements; + /// <summary> /// 鐗╂枡鍩虹淇℃伅琛ㄥ簲鐢ㄦ湇鍔� /// </summary> -public class WmsMaterialAppService : CMSPluginAppService, IWmsMaterialAppService -{ - private readonly IWmsMaterialRepository wmsMaterialRepository; - +public class WmsMaterialAppService : CMSPluginAppService, IWmsMaterialAppService +{ + private readonly IWmsMaterialRepository wmsMaterialRepository; + /// <summary> /// Initializes a new instance of the <see cref="WmsMaterialAppService"/> class. /// </summary> /// <param name="WmsMaterialRepository">The task job repository.</param> - public WmsMaterialAppService(IWmsMaterialRepository _WmsMaterialRepository) - { - wmsMaterialRepository = _WmsMaterialRepository; - } - + public WmsMaterialAppService(IWmsMaterialRepository _WmsMaterialRepository) + { + wmsMaterialRepository = _WmsMaterialRepository; + } + /// <summary> /// 鑾峰彇鎸囧畾鐗╂枡鍩虹淇℃伅琛� /// </summary> /// <param name="id"></param> /// <returns></returns> - public virtual async Task<WmsMaterialDto> GetAsync(Guid id) - { - return ObjectMapper.Map<WmsMaterial, WmsMaterialDto>(await wmsMaterialRepository.GetAsync(id)); - } - + public virtual async Task<WmsMaterialDto> GetAsync(Guid id) + { + return ObjectMapper.Map<WmsMaterial, WmsMaterialDto>(await wmsMaterialRepository.GetAsync(id)); + } + /// <summary> /// 鍒嗛〉鑾峰彇鐗╂枡鍩虹淇℃伅琛� /// </summary> /// <param name="input"></param> /// <returns></returns> - public virtual async Task<PagedResultDto<WmsMaterialDto>> GetListAsync(GetWmsMaterialInput input) - { - Check.NotNull(input, nameof(input)); - - if (input.Sorting.IsNullOrWhiteSpace()) - { - input.Sorting = nameof(WmsMaterial.Sort); - } - + public virtual async Task<PagedResultDto<WmsMaterialDto>> GetListAsync(GetWmsMaterialInput input) + { + Check.NotNull(input, nameof(input)); + + if (input.Sorting.IsNullOrWhiteSpace()) + { + input.Sorting = nameof(WmsMaterial.Sort); + } + #region 鍔ㄦ�佹瀯閫犳煡璇㈡潯浠� - + //鍔ㄦ�佹瀯閫犳煡璇㈡潯浠� - var whereConditions = DynamicGetQueryParams(input); - - #endregion - - var count = await wmsMaterialRepository.GetCountAsync(whereConditions); - var list = await wmsMaterialRepository.GetListAsync(whereConditions, input.Sorting, input.MaxResultCount, input.SkipCount); - - return new PagedResultDto<WmsMaterialDto>(count, ObjectMapper.Map<List<WmsMaterial>, List<WmsMaterialDto>>(list)); - } - + var whereConditions = DynamicGetQueryParams(input); + + #endregion + + var count = await wmsMaterialRepository.GetCountAsync(whereConditions); + var list = await wmsMaterialRepository.GetListAsync(whereConditions, input.Sorting, input.MaxResultCount, input.SkipCount); + + return new PagedResultDto<WmsMaterialDto>(count, ObjectMapper.Map<List<WmsMaterial>, List<WmsMaterialDto>>(list)); + } + /// <summary> /// 鍔ㄦ�佹瀯閫犳煡璇㈡潯浠� /// </summary> /// <param name="input">杈撳叆鍙傛暟</param> /// <returns></returns> - private FunReturnResultModel<Expression<Func<WmsMaterial, bool>>> DynamicGetQueryParams(GetWmsMaterialInput input) - { + private FunReturnResultModel<Expression<Func<WmsMaterial, bool>>> DynamicGetQueryParams(GetWmsMaterialInput input) + { //鍔ㄦ�佹瀯閫犳煡璇㈡潯浠� - var whereConditions = WhereConditionsExtensions.GetWhereConditions<WmsMaterial, GetWmsMaterialInput>(input); - if (!whereConditions.IsSuccess) - { - throw new Exception("鍔ㄦ�佹瀯閫犳煡璇㈡潯浠跺け璐�:" + whereConditions.ErrMsg); - } - + var whereConditions = WhereConditionsExtensions.GetWhereConditions<WmsMaterial, GetWmsMaterialInput>(input); + if (!whereConditions.IsSuccess) + { + throw new Exception("鍔ㄦ�佹瀯閫犳煡璇㈡潯浠跺け璐�:" + whereConditions.ErrMsg); + } + //涔熷彲鍐嶆鑷畾涔夋瀯寤烘煡璇㈡潯浠� - Expression<Func<WmsMaterial, bool>> extendExpression = a => a.IsDeleted == false; + Expression<Func<WmsMaterial, bool>> extendExpression = a => a.IsDeleted == false; // 浣跨敤 System.Linq.PredicateBuilder 鐨� And - var pres = (System.Linq.Expressions.Expression<Func<WmsMaterial, bool>>)(whereConditions.data); - whereConditions.data = System.Linq.PredicateBuilder.And(pres, extendExpression); - - return whereConditions; - } - + var pres = (System.Linq.Expressions.Expression<Func<WmsMaterial, bool>>)(whereConditions.data); + whereConditions.data = System.Linq.PredicateBuilder.And(pres, extendExpression); + + return whereConditions; + } + + + /// <summary> /// 鏂板缓鐗╂枡鍩虹淇℃伅琛� /// </summary> /// <param name="input"></param> /// <returns></returns> /// <exception cref="UserFriendlyException"></exception> - public virtual async Task<WmsMaterialDto> CreateAsync(WmsMaterialCreateDto input) - { - await CheckCreateOrUpdateDtoAsync(input); - - var exist = await wmsMaterialRepository.NameExistAsync(input.MaterialCode); - if (exist) - { - throw new UserFriendlyException(L[CMSPluginDomainErrorCodes.NameAlreadyExists, input.MaterialCode]); - } - - var maxSort = await wmsMaterialRepository.GetMaxSortAsync(); - var sort = input.Sort ?? maxSort; - - var insertObj = ObjectMapper.Map<WmsMaterialCreateDto, WmsMaterial>(input); - insertObj.Sort = sort; - input.MapExtraPropertiesTo(insertObj, MappingPropertyDefinitionChecks.None); - - await wmsMaterialRepository.InsertAsync(insertObj); - + public virtual async Task<WmsMaterialDto> CreateAsync(WmsMaterialCreateDto input) + { + await CheckCreateOrUpdateDtoAsync(input); + + var exist = await wmsMaterialRepository.NameExistAsync(input.MaterialCode); + if (exist) + { + throw new UserFriendlyException(L[CMSPluginDomainErrorCodes.NameAlreadyExists, input.MaterialCode]); + } + + var maxSort = await wmsMaterialRepository.GetMaxSortAsync(); + var sort = input.Sort ?? maxSort; + + var insertObj = ObjectMapper.Map<WmsMaterialCreateDto, WmsMaterial>(input); + insertObj.Sort = sort; + input.MapExtraPropertiesTo(insertObj, MappingPropertyDefinitionChecks.None); + + insertObj.CreatorName = input.CreatorName;//鍒涘缓浜� + await wmsMaterialRepository.InsertAsync(insertObj); + //if (input.Sort.HasValue && insertObj.Sort != maxSort) //{ // await AdjustSortAsync(insertObj.Id, insertObj.Sort); //} - - return ObjectMapper.Map<WmsMaterial, WmsMaterialDto>(insertObj); - } - + + return ObjectMapper.Map<WmsMaterial, WmsMaterialDto>(insertObj); + } + /// <summary> /// 鏇存柊鐗╂枡鍩虹淇℃伅琛� /// </summary> @@ -129,21 +134,21 @@ /// <param name="input"></param> /// <returns></returns> /// <exception cref="UserFriendlyException"></exception> - public virtual async Task<WmsMaterialDto> UpdateAsync(Guid id, WmsMaterialUpdateDto input) - { - await CheckCreateOrUpdateDtoAsync(input); - - var updateObj = await wmsMaterialRepository.GetAsync(id); - var exist = await wmsMaterialRepository.NameExistAsync(input.MaterialCode, updateObj.Id); - if (exist) - { - throw new UserFriendlyException(L[CMSPluginDomainErrorCodes.NameAlreadyExists, input.MaterialCode]); - } - - updateObj.SetConcurrencyStampIfNotNull(input.ConcurrencyStamp); - input.MapExtraPropertiesTo(updateObj, MappingPropertyDefinitionChecks.None); - - updateObj.MaterialCode = input.MaterialCode; + public virtual async Task<WmsMaterialDto> UpdateAsync(Guid id, WmsMaterialUpdateDto input) + { + await CheckCreateOrUpdateDtoAsync(input); + + var updateObj = await wmsMaterialRepository.GetAsync(id); + var exist = await wmsMaterialRepository.NameExistAsync(input.MaterialCode, updateObj.Id); + if (exist) + { + throw new UserFriendlyException(L[CMSPluginDomainErrorCodes.NameAlreadyExists, input.MaterialCode]); + } + + updateObj.SetConcurrencyStampIfNotNull(input.ConcurrencyStamp); + input.MapExtraPropertiesTo(updateObj, MappingPropertyDefinitionChecks.None); + + updateObj.MaterialCode = input.MaterialCode; updateObj.IsValid = input.IsValid; updateObj.IsSelfMade = input.IsSelfMade; updateObj.Num = input.Num; @@ -165,20 +170,21 @@ updateObj.RedundantField2 = input.RedundantField2; updateObj.RedundantField3 = input.RedundantField3; updateObj.Remark = input.Remark; - - - await wmsMaterialRepository.UpdateAsync(updateObj); - - return ObjectMapper.Map<WmsMaterial, WmsMaterialDto>(updateObj); - } - + + updateObj.LastModifierName = input.LastModifierName;//淇敼浜� + + await wmsMaterialRepository.UpdateAsync(updateObj); + + return ObjectMapper.Map<WmsMaterial, WmsMaterialDto>(updateObj); + } + /// <summary> /// 鍏嬮殕鐗╂枡鍩虹淇℃伅琛� /// </summary> /// <param name="ids"></param> /// <returns></returns> - public async Task<List<WmsMaterialDto>> CloneAsync(IEnumerable<Guid> ids) - { + public async Task<List<WmsMaterialDto>> CloneAsync(IEnumerable<Guid> ids) + { //var wmsMaterials = new List<WmsMaterial>(); //if (ids != null) //{ @@ -198,261 +204,285 @@ // name += WmsMaterialConsts.CloneTag; // continue; // } - + // notExist = true; // } - + // //WmsMaterial = await wmsMaterialRepository.InsertAsync(WmsMaterial.Clone(GuidGenerator.Create(), name, sort++)); // wmsMaterials.Add(WmsMaterial); // } // } //} - + //return ObjectMapper.Map<List<WmsMaterial>, List<WmsMaterialDto>>(wmsMaterials); - return new List<WmsMaterialDto>(); - } - + return new List<WmsMaterialDto>(); + } + /// <summary> /// 鍒犻櫎鍗曚釜鐗╂枡鍩虹淇℃伅琛� /// </summary> /// <param name="id"></param> /// <returns></returns> - public virtual Task DeleteAsync(Guid id) - { - return wmsMaterialRepository.DeleteAsync(id); - } - + public virtual Task DeleteAsync(Guid id) + { + return wmsMaterialRepository.DeleteAsync(id); + } + /// <summary> /// 鍒犻櫎澶氫釜鐗╂枡鍩虹淇℃伅琛� /// </summary> /// <param name="ids"></param> /// <returns></returns> - public async Task DeleteManyAsync(IEnumerable<Guid> ids) - { - foreach (var id in ids) - { - await DeleteAsync(id); - } - } - + public async Task DeleteManyAsync(IEnumerable<Guid> ids) + { + foreach (var id in ids) + { + await DeleteAsync(id); + } + } + + /// <summary> + /// 鐗╃悊鍒犻櫎鐗╂枡鍩虹淇℃伅琛� + /// </summary> + /// <param name="id">鐗╂枡ID</param> + /// <param name="cancellationToken"></param> + /// <returns></returns> + public virtual async Task DeletePermanentlyAsync(Guid id, CancellationToken cancellationToken = default) + { + wmsMaterialRepository.DeletePermanentlyAsync(id); + } + + /// <summary> + /// 鎵归噺鐗╃悊鍒犻櫎鐗╂枡鍩虹淇℃伅琛紙鐩存帴鍒犻櫎锛屼笉杞垹闄わ級 + /// </summary> + /// <param name="ids">瑕佸垹闄ょ殑鐗╂枡ID鍒楄〃</param> + /// <param name="cancellationToken"></param> + /// <returns></returns> + public virtual async Task BatchDeletePermanentlyAsync(IEnumerable<Guid> ids, CancellationToken cancellationToken = default) + { + wmsMaterialRepository.BatchDeletePermanentlyAsync(ids); + } + /// <summary> /// 璋冩暣鎺掑簭鐗╂枡鍩虹淇℃伅琛� /// </summary> /// <param name="id"></param> /// <param name="sort"></param> /// <returns></returns> - public virtual async Task AdjustSortAsync(Guid id, int sort) - { - var list = await wmsMaterialRepository.GetListAsync(null, nameof(WmsMaterial.Sort)); - if (list != null && list.Any()) - { - var initSort = 1; - list.ForEach(x => x.AdjustSort(initSort++)); - var entity = list.FirstOrDefault(x => x.Id == id); - if (entity != null) - { - if (sort == 1) - { - list.Where(x => x.Id != id).ToList()?.ForEach(x => x.AdjustSort(x.Sort + 1)); - } - else if (entity.Sort > sort) - { - list.Where(x => x.Id != id && x.Sort >= sort).ToList()?.ForEach(x => x.AdjustSort(x.Sort + 1)); - list.Where(x => x.Id != id && x.Sort < sort).ToList()?.ForEach(x => x.AdjustSort(x.Sort - 1)); - } - else if (entity.Sort < sort) - { - list.Where(x => x.Id != id && x.Sort > sort).ToList()?.ForEach(x => x.AdjustSort(x.Sort + 1)); - list.Where(x => x.Id != id && x.Sort <= sort).ToList()?.ForEach(x => x.AdjustSort(x.Sort - 1)); - } - - entity.AdjustSort(sort); - } - } - - await wmsMaterialRepository.UpdateManyAsync(list); - } - + public virtual async Task AdjustSortAsync(Guid id, int sort) + { + var list = await wmsMaterialRepository.GetListAsync(null, nameof(WmsMaterial.Sort)); + if (list != null && list.Any()) + { + var initSort = 1; + list.ForEach(x => x.AdjustSort(initSort++)); + var entity = list.FirstOrDefault(x => x.Id == id); + if (entity != null) + { + if (sort == 1) + { + list.Where(x => x.Id != id).ToList()?.ForEach(x => x.AdjustSort(x.Sort + 1)); + } + else if (entity.Sort > sort) + { + list.Where(x => x.Id != id && x.Sort >= sort).ToList()?.ForEach(x => x.AdjustSort(x.Sort + 1)); + list.Where(x => x.Id != id && x.Sort < sort).ToList()?.ForEach(x => x.AdjustSort(x.Sort - 1)); + } + else if (entity.Sort < sort) + { + list.Where(x => x.Id != id && x.Sort > sort).ToList()?.ForEach(x => x.AdjustSort(x.Sort + 1)); + list.Where(x => x.Id != id && x.Sort <= sort).ToList()?.ForEach(x => x.AdjustSort(x.Sort - 1)); + } + + entity.AdjustSort(sort); + } + } + + await wmsMaterialRepository.UpdateManyAsync(list); + } + /// <summary> /// 瀵煎叆鐗╂枡鍩虹淇℃伅琛� /// </summary> /// <param name="input"></param> /// <returns></returns> /// <exception cref="UserFriendlyException"></exception> - public async Task ImportAsync(WmsMaterialsImportModel input) - { - Check.NotNull(input, nameof(input)); - - var wmsMaterialCreateDtos = new List<(int RowIndex, WmsMaterialCreateDto Item)>(); - var wmsMaterialUpdateDtos = new List<(int RowIndex, Guid Id, WmsMaterialUpdateDto Item)>(); - var importItems = input.WmsMaterials; - - if (importItems != null && importItems.Any()) - { + public async Task ImportAsync(WmsMaterialsImportModel input, MyCurrentUser myCurrentUser) + { + Check.NotNull(input, nameof(input)); + + var wmsMaterialCreateDtos = new List<(int RowIndex, WmsMaterialCreateDto Item)>(); + var wmsMaterialUpdateDtos = new List<(int RowIndex, Guid Id, WmsMaterialUpdateDto Item)>(); + var importItems = input.WmsMaterials; + + if (importItems != null && importItems.Any()) + { #region 瀵煎叆鏍¢獙 - + // 鍒ゆ柇鍚嶇О鏄惁閲嶅锛屽苟杈撳嚭绗嚑琛岄噸澶� - var duplicateWmsMaterials = importItems.GroupBy(x => x.MaterialCode).Where(x => x.Count() > 1).ToList(); - if (duplicateWmsMaterials?.Any() == true) - { - var duplicateWmsMaterialMsgs = duplicateWmsMaterials.Select(x => $"绗� {string.Join(",", x.Select(x => x.RowIndex))} 琛岋細{x.Key} 鍚嶇О閲嶅"); - var errorMsg = $"瀵煎叆澶辫触锛侀厤缃紝 {string.Join(",", duplicateWmsMaterialMsgs)}锛岀粓姝㈠鍏�"; - throw new UserFriendlyException(errorMsg); - } - - #endregion - - foreach (var impItem in importItems) - { - if (impItem.MaterialCode.IsNullOrWhiteSpace()) - { - continue; - } - - if (impItem.MaterialCode.IsNullOrWhiteSpace()) - { - var errorMsg = $"瀵煎叆澶辫触锛侀厤缃紝绗瑊impItem.RowIndex}琛岋細WmsMaterial鍚嶇О涓嶈兘涓虹┖"; - throw new UserFriendlyException(errorMsg); - } - - var oldWmsMaterial = await wmsMaterialRepository.FindByNameAsync(impItem.MaterialCode); - if (oldWmsMaterial != null) - { - var wmsMaterialUpdateDto = new WmsMaterialUpdateDto - { + var duplicateWmsMaterials = importItems.GroupBy(x => x.MaterialCode).Where(x => x.Count() > 1).ToList(); + if (duplicateWmsMaterials?.Any() == true) + { + var duplicateWmsMaterialMsgs = duplicateWmsMaterials.Select(x => $"绗� {string.Join(",", x.Select(x => x.RowIndex))} 琛岋細{x.Key} 鍚嶇О閲嶅"); + var errorMsg = $"瀵煎叆澶辫触锛侀厤缃紝 {string.Join(",", duplicateWmsMaterialMsgs)}锛岀粓姝㈠鍏�"; + throw new UserFriendlyException(errorMsg); + } + + #endregion + + foreach (var impItem in importItems) + { + if (impItem.MaterialCode.IsNullOrWhiteSpace()) + { + continue; + } + + if (impItem.MaterialCode.IsNullOrWhiteSpace()) + { + var errorMsg = $"瀵煎叆澶辫触锛侀厤缃紝绗瑊impItem.RowIndex}琛岋細WmsMaterial鍚嶇О涓嶈兘涓虹┖"; + throw new UserFriendlyException(errorMsg); + } + + var oldWmsMaterial = await wmsMaterialRepository.FindByNameAsync(impItem.MaterialCode); + if (oldWmsMaterial != null) + { + var wmsMaterialUpdateDto = new WmsMaterialUpdateDto + { MaterialCode = impItem.MaterialCode, -IsValid = impItem.IsValid, -IsSelfMade = impItem.IsSelfMade, -Num = impItem.Num, -SelfNum = impItem.SelfNum, -MaterialName = impItem.MaterialName, -NullLength = impItem.NullLength, -PurchaseType = impItem.PurchaseType, -MaterialType = impItem.MaterialType, -PrimaryUnit = impItem.PrimaryUnit, -Standard = impItem.Standard, -OuterDiameter = impItem.OuterDiameter, -WallThickness = impItem.WallThickness, -MaterialQuality = impItem.MaterialQuality, -Length = impItem.Length, -IsMainBranch = impItem.IsMainBranch, -Factory = impItem.Factory, -Certification = impItem.Certification, -RedundantField1 = impItem.RedundantField1, -RedundantField2 = impItem.RedundantField2, -RedundantField3 = impItem.RedundantField3, -Remark = impItem.Remark, - - }; - - wmsMaterialUpdateDtos.Add((impItem.RowIndex, oldWmsMaterial.Id, wmsMaterialUpdateDto)); - } - else - { - var wmsMaterialCreateDto = new WmsMaterialCreateDto - { + IsValid = impItem.IsValid, + IsSelfMade = impItem.IsSelfMade, + Num = impItem.Num, + SelfNum = impItem.SelfNum, + MaterialName = impItem.MaterialName, + NullLength = impItem.NullLength, + PurchaseType = impItem.PurchaseType, + MaterialType = impItem.MaterialType, + PrimaryUnit = impItem.PrimaryUnit, + Standard = impItem.Standard, + OuterDiameter = impItem.OuterDiameter, + WallThickness = impItem.WallThickness, + MaterialQuality = impItem.MaterialQuality, + Length = impItem.Length, + IsMainBranch = impItem.IsMainBranch, + Factory = impItem.Factory, + Certification = impItem.Certification, + RedundantField1 = impItem.RedundantField1, + RedundantField2 = impItem.RedundantField2, + RedundantField3 = impItem.RedundantField3, + Remark = impItem.Remark, + + }; + + wmsMaterialUpdateDtos.Add((impItem.RowIndex, oldWmsMaterial.Id, wmsMaterialUpdateDto)); + } + else + { + var wmsMaterialCreateDto = new WmsMaterialCreateDto + { MaterialCode = impItem.MaterialCode, -IsValid = impItem.IsValid, -IsSelfMade = impItem.IsSelfMade, -Num = impItem.Num, -SelfNum = impItem.SelfNum, -MaterialName = impItem.MaterialName, -NullLength = impItem.NullLength, -PurchaseType = impItem.PurchaseType, -MaterialType = impItem.MaterialType, -PrimaryUnit = impItem.PrimaryUnit, -Standard = impItem.Standard, -OuterDiameter = impItem.OuterDiameter, -WallThickness = impItem.WallThickness, -MaterialQuality = impItem.MaterialQuality, -Length = impItem.Length, -IsMainBranch = impItem.IsMainBranch, -Factory = impItem.Factory, -Certification = impItem.Certification, -RedundantField1 = impItem.RedundantField1, -RedundantField2 = impItem.RedundantField2, -RedundantField3 = impItem.RedundantField3, -Remark = impItem.Remark, - - }; - - wmsMaterialCreateDtos.Add((impItem.RowIndex, wmsMaterialCreateDto)); - } - } - } - + IsValid = impItem.IsValid, + IsSelfMade = impItem.IsSelfMade, + Num = impItem.Num, + SelfNum = impItem.SelfNum, + MaterialName = impItem.MaterialName, + NullLength = impItem.NullLength, + PurchaseType = impItem.PurchaseType, + MaterialType = impItem.MaterialType, + PrimaryUnit = impItem.PrimaryUnit, + Standard = impItem.Standard, + OuterDiameter = impItem.OuterDiameter, + WallThickness = impItem.WallThickness, + MaterialQuality = impItem.MaterialQuality, + Length = impItem.Length, + IsMainBranch = impItem.IsMainBranch, + Factory = impItem.Factory, + Certification = impItem.Certification, + RedundantField1 = impItem.RedundantField1, + RedundantField2 = impItem.RedundantField2, + RedundantField3 = impItem.RedundantField3, + Remark = impItem.Remark, + + }; + + wmsMaterialCreateDtos.Add((impItem.RowIndex, wmsMaterialCreateDto)); + } + } + } + // 鏂板 - foreach (var wmsMaterialDto in wmsMaterialCreateDtos) - { - try - { - await CreateAsync(wmsMaterialDto.Item); - } - catch (Exception e) - { - var errorMsg = $"瀵煎叆澶辫触锛侀厤缃紝绗瑊wmsMaterialDto.RowIndex}琛岋細{e.Message}锛岀粓姝㈠鍏�"; - throw new UserFriendlyException(errorMsg); - } - } - + foreach (var wmsMaterialDto in wmsMaterialCreateDtos) + { + try + { + wmsMaterialDto.Item.CreatorName = myCurrentUser.UserAccount;//鍒涘缓浜� + await CreateAsync(wmsMaterialDto.Item); + } + catch (Exception e) + { + var errorMsg = $"瀵煎叆澶辫触锛侀厤缃紝绗瑊wmsMaterialDto.RowIndex}琛岋細{e.Message}锛岀粓姝㈠鍏�"; + throw new UserFriendlyException(errorMsg); + } + } + // 鏇存柊 - foreach (var wmsMaterialDto in wmsMaterialUpdateDtos) - { - try - { - await UpdateAsync(wmsMaterialDto.Id, wmsMaterialDto.Item); - } - catch (Exception e) - { - var errorMsg = $"瀵煎叆澶辫触锛侀厤缃紝绗瑊wmsMaterialDto.RowIndex}琛岋細{e.Message}锛岀粓姝㈠鍏�"; - throw new UserFriendlyException(errorMsg); - } - } - } - + foreach (var wmsMaterialDto in wmsMaterialUpdateDtos) + { + try + { + wmsMaterialDto.Item.LastModifierName = myCurrentUser.UserAccount;//淇敼浜� + await UpdateAsync(wmsMaterialDto.Id, wmsMaterialDto.Item); + } + catch (Exception e) + { + var errorMsg = $"瀵煎叆澶辫触锛侀厤缃紝绗瑊wmsMaterialDto.RowIndex}琛岋細{e.Message}锛岀粓姝㈠鍏�"; + throw new UserFriendlyException(errorMsg); + } + } + } + /// <summary> /// 瀵煎嚭鐗╂枡鍩虹淇℃伅琛� /// </summary> /// <param name="input"></param> /// <returns></returns> - public async Task<(Dictionary<string, object> Sheets, string FileName)> ExportAsync(GetWmsMaterialInput input) - { - Check.NotNull(input, nameof(input)); - - if (input.Sorting.IsNullOrWhiteSpace()) - { - input.Sorting = nameof(WmsMaterial.Sort); - } - + public async Task<(Dictionary<string, object> Sheets, string FileName)> ExportAsync(GetWmsMaterialInput input) + { + Check.NotNull(input, nameof(input)); + + if (input.Sorting.IsNullOrWhiteSpace()) + { + input.Sorting = nameof(WmsMaterial.Sort); + } + #region 鍔ㄦ�佹瀯閫犳煡璇㈡潯浠� - + //鍔ㄦ�佹瀯閫犳煡璇㈡潯浠� - var whereConditions = DynamicGetQueryParams(input); - - #endregion - - - var list = await wmsMaterialRepository.GetListAsync(whereConditions, input.Sorting, input.MaxResultCount, input.SkipCount, includeDetails: true); - var result = ObjectMapper.Map<List<WmsMaterial>, List<WmsMaterialDto>>(list); - - var sheets = new Dictionary<string, object> - { - ["閰嶇疆"] = ExportHelper.ConvertListToExportData(result), - }; - - var fileName = "鐗╂枡淇℃伅"; - return (sheets, fileName); - } - + var whereConditions = DynamicGetQueryParams(input); + + #endregion + + + var list = await wmsMaterialRepository.GetListAsync(whereConditions, input.Sorting, input.MaxResultCount, input.SkipCount, includeDetails: true); + var result = ObjectMapper.Map<List<WmsMaterial>, List<WmsMaterialDto>>(list); + + var sheets = new Dictionary<string, object> + { + ["閰嶇疆"] = ExportHelper.ConvertListToExportData(result), + }; + + var fileName = "鐗╂枡淇℃伅"; + return (sheets, fileName); + } + /// <summary> /// 鏍¢獙鐗╂枡鍩虹淇℃伅琛紝褰撴柊寤烘垨鏇存柊鏃� /// </summary> /// <param name="input"></param> /// <returns></returns> - protected Task CheckCreateOrUpdateDtoAsync(WmsMaterialCreateOrUpdateDtoBase input) - { - Check.NotNull(input, nameof(input)); - Check.NotNullOrWhiteSpace(input.MaterialCode, "鐗╂枡缂栫爜锛堝敮涓�鏍囪瘑锛�", 64); + protected Task CheckCreateOrUpdateDtoAsync(WmsMaterialCreateOrUpdateDtoBase input) + { + Check.NotNull(input, nameof(input)); + Check.NotNullOrWhiteSpace(input.MaterialCode, "鐗╂枡缂栫爜锛堝敮涓�鏍囪瘑锛�", 64); Check.NotNull(input.IsValid, "鏄惁鏈夋晥鐗╂枡"); Check.NotNull(input.Num, "鏁伴噺"); Check.NotNullOrWhiteSpace(input.MaterialName, "鐗╂枡鍚嶇О", 128); @@ -462,7 +492,7 @@ Check.NotNull(input.WallThickness, "澹佸帤锛堝崟浣嶏細mm锛�"); Check.NotNull(input.Length, "闀垮害锛堝崟浣嶏細m锛�"); Check.NotNull(input.IsMainBranch, "鏄惁涓轰富鏀"); - - return Task.CompletedTask; - } -} + + return Task.CompletedTask; + } +} -- Gitblit v1.9.3