From 4456f43c6c73185a9f7ce46cdcdf94ab2053f02e Mon Sep 17 00:00:00 2001
From: zs <zhousong@weben-smart.com>
Date: 周三, 07 5月 2025 14:19:43 +0800
Subject: [PATCH] 修改生成器及出入库记录页面

---
 HIAWms/server/src/CMS.Plugin.HIAWms.Application/Implements/WmsInOutStockRecordAppService.cs |  537 ++++++++++++++++++++++++++++++++++++-----------------------
 1 files changed, 327 insertions(+), 210 deletions(-)

diff --git a/HIAWms/server/src/CMS.Plugin.HIAWms.Application/Implements/WmsInOutStockRecordAppService.cs b/HIAWms/server/src/CMS.Plugin.HIAWms.Application/Implements/WmsInOutStockRecordAppService.cs
index de2d3f8..cb54fa7 100644
--- a/HIAWms/server/src/CMS.Plugin.HIAWms.Application/Implements/WmsInOutStockRecordAppService.cs
+++ b/HIAWms/server/src/CMS.Plugin.HIAWms.Application/Implements/WmsInOutStockRecordAppService.cs
@@ -1,141 +1,149 @@
-using CMS.Plugin.HIAWms.Application.Contracts.Dtos.WmsInOutStockRecord;
-using CMS.Plugin.HIAWms.Application.Contracts.Services;
-using CMS.Plugin.HIAWms.Domain.Shared;
-using CMS.Plugin.HIAWms.Domain.WmsInOutStockRecord;
-using CmsQueryExtensions;
-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.WmsInOutStockRecord; 
+using CMS.Plugin.HIAWms.Application.Contracts.Services; 
+using CMS.Plugin.HIAWms.Domain.Shared; 
+using CmsQueryExtensions; 
+using CMS.Plugin.HIAWms.Domain.WmsInOutStockRecord; 
+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; 
+ 
 /// <summary> 
-/// 鍑哄叆搴撹褰曡〃搴旂敤鏈嶅姟 
+/// 鍑哄叆搴撹褰曞簲鐢ㄦ湇鍔� 
 /// </summary> 
-public class WmsInOutStockRecordAppService : CMSPluginAppService, IWmsInOutStockRecordAppService
-{
-    private readonly IWmsInOutStockRecordRepository _wmsInOutStockRecordRepository;
-
+public class WmsInOutStockRecordAppService : CMSPluginAppService, IWmsInOutStockRecordAppService 
+{ 
+    private readonly IWmsInOutStockRecordRepository wmsInOutStockRecordRepository; 
+ 
     /// <summary> 
     /// Initializes a new instance of the <see cref="WmsInOutStockRecordAppService"/> class. 
     /// </summary> 
     /// <param name="WmsInOutStockRecordRepository">The task job repository.</param> 
-    public WmsInOutStockRecordAppService(IWmsInOutStockRecordRepository wmsInOutStockRecordRepository)
-    {
-        _wmsInOutStockRecordRepository = wmsInOutStockRecordRepository;
-    }
-
+    public WmsInOutStockRecordAppService(IWmsInOutStockRecordRepository _WmsInOutStockRecordRepository) 
+    { 
+        wmsInOutStockRecordRepository = _WmsInOutStockRecordRepository; 
+    } 
+ 
     /// <summary> 
-    /// 鑾峰彇鎸囧畾鍑哄叆搴撹褰曡〃 
+    /// 鑾峰彇鎸囧畾鍑哄叆搴撹褰� 
     /// </summary> 
     /// <param name="id"></param> 
     /// <returns></returns> 
-    public virtual async Task<WmsInOutStockRecordDto> GetAsync(Guid id)
-    {
-        return ObjectMapper.Map<WmsInOutStockRecord, WmsInOutStockRecordDto>(await _wmsInOutStockRecordRepository.GetAsync(id));
-    }
-
+    public virtual async Task<WmsInOutStockRecordDto> GetAsync(Guid id) 
+    { 
+        return ObjectMapper.Map<WmsInOutStockRecord, WmsInOutStockRecordDto>(await wmsInOutStockRecordRepository.GetAsync(id)); 
+    } 
+ 
     /// <summary> 
-    /// 鍒嗛〉鑾峰彇鍑哄叆搴撹褰曡〃 
+    /// 鍒嗛〉鑾峰彇鍑哄叆搴撹褰� 
     /// </summary> 
     /// <param name="input"></param> 
     /// <returns></returns> 
-    public virtual async Task<PagedResultDto<WmsInOutStockRecordDto>> GetListAsync(GetWmsInOutStockRecordInput input)
-    {
-        Check.NotNull(input, nameof(input));
-
-        if (input.Sorting.IsNullOrWhiteSpace())
-        {
-            input.Sorting = nameof(WmsInOutStockRecord.Sort);
-        }
-
+    public virtual async Task<PagedResultDto<WmsInOutStockRecordDto>> GetListAsync(GetWmsInOutStockRecordInput input) 
+    { 
+        Check.NotNull(input, nameof(input)); 
+ 
+        if (input.Sorting.IsNullOrWhiteSpace()) 
+        { 
+            input.Sorting = nameof(WmsInOutStockRecord.Sort); 
+        } 
+ 
         #region 鍔ㄦ�佹瀯閫犳煡璇㈡潯浠�  
-
+ 
         //鍔ㄦ�佹瀯閫犳煡璇㈡潯浠�  
-        var whereConditions = DynamicGetQueryParams(input);
-
-        #endregion
-
-        var count = await _wmsInOutStockRecordRepository.GetCountAsync(whereConditions);
-        var list = await _wmsInOutStockRecordRepository.GetListAsync(whereConditions, input.Sorting, input.MaxResultCount, input.SkipCount);
-
-        return new PagedResultDto<WmsInOutStockRecordDto>(count, ObjectMapper.Map<List<WmsInOutStockRecord>, List<WmsInOutStockRecordDto>>(list));
-    }
-
+        var whereConditions = DynamicGetQueryParams(input); 
+ 
+        #endregion 
+ 
+        var count = await wmsInOutStockRecordRepository.GetCountAsync(whereConditions); 
+        var list = await wmsInOutStockRecordRepository.GetListAsync(whereConditions, input.Sorting, input.MaxResultCount, input.SkipCount); 
+ 
+        return new PagedResultDto<WmsInOutStockRecordDto>(count, ObjectMapper.Map<List<WmsInOutStockRecord>, List<WmsInOutStockRecordDto>>(list)); 
+    } 
+ 
     /// <summary>  
     /// 鍔ㄦ�佹瀯閫犳煡璇㈡潯浠�  
     /// </summary>  
     /// <param name="input">杈撳叆鍙傛暟</param>  
     /// <returns></returns>  
-    private FunReturnResultModel<Expression<Func<WmsInOutStockRecord, bool>>> DynamicGetQueryParams(GetWmsInOutStockRecordInput input)
-    {
+    private FunReturnResultModel<Expression<Func<WmsInOutStockRecord, bool>>> DynamicGetQueryParams(GetWmsInOutStockRecordInput input) 
+    { 
         //鍔ㄦ�佹瀯閫犳煡璇㈡潯浠�  
-        var whereConditions = WhereConditionsExtensions.GetWhereConditions<WmsInOutStockRecord, GetWmsInOutStockRecordInput>(input);
-        if (!whereConditions.IsSuccess)
-        {
-            throw new Exception("鍔ㄦ�佹瀯閫犳煡璇㈡潯浠跺け璐�:" + whereConditions.ErrMsg);
-        }
-
+        var whereConditions = WhereConditionsExtensions.GetWhereConditions<WmsInOutStockRecord, GetWmsInOutStockRecordInput>(input); 
+        if (!whereConditions.IsSuccess) 
+        { 
+            throw new Exception("鍔ㄦ�佹瀯閫犳煡璇㈡潯浠跺け璐�:" + whereConditions.ErrMsg); 
+        } 
+ 
         //涔熷彲鍐嶆鑷畾涔夋瀯寤烘煡璇㈡潯浠�  
-        Expression<Func<WmsInOutStockRecord, bool>> extendExpression = a => a.IsDeleted == false;
+        Expression<Func<WmsInOutStockRecord, bool>> extendExpression = a => a.IsDeleted == false; 
         // 浣跨敤 System.Linq.PredicateBuilder 鐨� And 
-        var pres = (System.Linq.Expressions.Expression<Func<WmsInOutStockRecord, bool>>)(whereConditions.data);
-        whereConditions.data = System.Linq.PredicateBuilder.And(pres, extendExpression);
-
-        return whereConditions;
-    }
-
+        var pres = (System.Linq.Expressions.Expression<Func<WmsInOutStockRecord, 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<WmsInOutStockRecordDto> CreateAsync(WmsInOutStockRecordCreateDto input)
-    {
-        await CheckCreateOrUpdateDtoAsync(input);
-
-
-
-        var maxSort = await _wmsInOutStockRecordRepository.GetMaxSortAsync();
-        var sort = input.Sort ?? maxSort;
-
-        var insertObj = ObjectMapper.Map<WmsInOutStockRecordCreateDto, WmsInOutStockRecord>(input);
-        insertObj.Sort = sort;
-        input.MapExtraPropertiesTo(insertObj, MappingPropertyDefinitionChecks.None);
-
-        await _wmsInOutStockRecordRepository.InsertAsync(insertObj);
-
-        if (input.Sort.HasValue && insertObj.Sort != maxSort)
-        {
-            await AdjustSortAsync(insertObj.Id, insertObj.Sort);
-        }
-
-        return ObjectMapper.Map<WmsInOutStockRecord, WmsInOutStockRecordDto>(insertObj);
-    }
-
+    public virtual async Task<WmsInOutStockRecordDto> CreateAsync(WmsInOutStockRecordCreateDto input) 
+    { 
+        await CheckCreateOrUpdateDtoAsync(input); 
+ 
+        var exist = await wmsInOutStockRecordRepository.NameExistAsync(input.Id); 
+        if (exist) 
+        { 
+            throw new UserFriendlyException(L[CMSPluginDomainErrorCodes.NameAlreadyExists, input.Id]); 
+        } 
+ 
+        var maxSort = await wmsInOutStockRecordRepository.GetMaxSortAsync(); 
+        var sort = input.Sort ?? maxSort; 
+ 
+        var insertObj = ObjectMapper.Map<WmsInOutStockRecordCreateDto, WmsInOutStockRecord>(input); 
+        insertObj.Sort = sort; 
+        input.MapExtraPropertiesTo(insertObj, MappingPropertyDefinitionChecks.None); 
+ 
+        await wmsInOutStockRecordRepository.InsertAsync(insertObj); 
+ 
+        if (input.Sort.HasValue && insertObj.Sort != maxSort) 
+        { 
+            await AdjustSortAsync(insertObj.Id, insertObj.Sort); 
+        } 
+ 
+        return ObjectMapper.Map<WmsInOutStockRecord, WmsInOutStockRecordDto>(insertObj); 
+    } 
+ 
     /// <summary> 
-    /// 鏇存柊鍑哄叆搴撹褰曡〃 
+    /// 鏇存柊鍑哄叆搴撹褰� 
     /// </summary> 
     /// <param name="id"></param> 
     /// <param name="input"></param> 
     /// <returns></returns> 
     /// <exception cref="UserFriendlyException"></exception> 
-    public virtual async Task<WmsInOutStockRecordDto> UpdateAsync(Guid id, WmsInOutStockRecordUpdateDto input)
-    {
-        await CheckCreateOrUpdateDtoAsync(input);
-
-        var updateObj = await _wmsInOutStockRecordRepository.GetAsync(id);
-
-
-        updateObj.SetConcurrencyStampIfNotNull(input.ConcurrencyStamp);
-        input.MapExtraPropertiesTo(updateObj, MappingPropertyDefinitionChecks.None);
-
-        updateObj.OrderNo = input.OrderNo;
+    public virtual async Task<WmsInOutStockRecordDto> UpdateAsync(Guid id, WmsInOutStockRecordUpdateDto input) 
+    { 
+        await CheckCreateOrUpdateDtoAsync(input); 
+ 
+        var updateObj = await wmsInOutStockRecordRepository.GetAsync(id); 
+        var exist = await wmsInOutStockRecordRepository.NameExistAsync(input.Id, updateObj.Id); 
+        if (exist) 
+        { 
+            throw new UserFriendlyException(L[CMSPluginDomainErrorCodes.NameAlreadyExists, input.Id]); 
+        } 
+ 
+        updateObj.SetConcurrencyStampIfNotNull(input.ConcurrencyStamp); 
+        input.MapExtraPropertiesTo(updateObj, MappingPropertyDefinitionChecks.None); 
+ 
+                updateObj.OrderNo = input.OrderNo;
         updateObj.MaterialName = input.MaterialName;
         updateObj.MaterialNo = input.MaterialNo;
         updateObj.StockType = input.StockType;
@@ -147,20 +155,21 @@
         updateObj.TaskNo = input.TaskNo;
         updateObj.SourcePlace = input.SourcePlace;
         updateObj.ToPlace = input.ToPlace;
-
-
-        await _wmsInOutStockRecordRepository.UpdateAsync(updateObj);
-
-        return ObjectMapper.Map<WmsInOutStockRecord, WmsInOutStockRecordDto>(updateObj);
-    }
-
+        updateObj.IsDisabled = input.IsDisabled;
+ 
+ 
+        await wmsInOutStockRecordRepository.UpdateAsync(updateObj); 
+ 
+        return ObjectMapper.Map<WmsInOutStockRecord, WmsInOutStockRecordDto>(updateObj); 
+    } 
+ 
     /// <summary> 
-    /// 鍏嬮殕鍑哄叆搴撹褰曡〃 
+    /// 鍏嬮殕鍑哄叆搴撹褰� 
     /// </summary> 
     /// <param name="ids"></param> 
     /// <returns></returns> 
-    public async Task<List<WmsInOutStockRecordDto>> CloneAsync(IEnumerable<Guid> ids)
-    {
+    public async Task<List<WmsInOutStockRecordDto>> CloneAsync(IEnumerable<Guid> ids) 
+    { 
         //var wmsInOutStockRecords = new List<WmsInOutStockRecord>(); 
         //if (ids != null) 
         //{ 
@@ -180,140 +189,248 @@
         //                    name += WmsInOutStockRecordConsts.CloneTag; 
         //                    continue; 
         //                } 
-
+ 
         //                notExist = true; 
         //            } 
-
+ 
         //            //WmsInOutStockRecord = await wmsInOutStockRecordRepository.InsertAsync(WmsInOutStockRecord.Clone(GuidGenerator.Create(), name, sort++)); 
         //            wmsInOutStockRecords.Add(WmsInOutStockRecord); 
         //        } 
         //    } 
         //} 
-
+ 
         //return ObjectMapper.Map<List<WmsInOutStockRecord>, List<WmsInOutStockRecordDto>>(wmsInOutStockRecords); 
-        return new List<WmsInOutStockRecordDto>();
-    }
-
+        return new List<WmsInOutStockRecordDto>(); 
+    } 
+ 
     /// <summary> 
-    /// 鍒犻櫎鍗曚釜鍑哄叆搴撹褰曡〃 
+    /// 鍒犻櫎鍗曚釜鍑哄叆搴撹褰� 
     /// </summary> 
     /// <param name="id"></param> 
     /// <returns></returns> 
-    public virtual Task DeleteAsync(Guid id)
-    {
-        return _wmsInOutStockRecordRepository.DeleteAsync(id);
-    }
-
+    public virtual Task DeleteAsync(Guid id) 
+    { 
+        return wmsInOutStockRecordRepository.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"></param> 
     /// <param name="sort"></param> 
     /// <returns></returns> 
-    public virtual async Task AdjustSortAsync(Guid id, int sort)
-    {
-        var list = await _wmsInOutStockRecordRepository.GetListAsync(null, nameof(WmsInOutStockRecord.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 _wmsInOutStockRecordRepository.UpdateManyAsync(list);
-    }
-
+    public virtual async Task AdjustSortAsync(Guid id, int sort) 
+    { 
+        var list = await wmsInOutStockRecordRepository.GetListAsync(null, nameof(WmsInOutStockRecord.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 wmsInOutStockRecordRepository.UpdateManyAsync(list); 
+    } 
+ 
     /// <summary> 
-    /// 瀵煎叆鍑哄叆搴撹褰曡〃 
+    /// 瀵煎叆鍑哄叆搴撹褰� 
     /// </summary> 
     /// <param name="input"></param> 
     /// <returns></returns> 
     /// <exception cref="UserFriendlyException"></exception> 
-    public async Task ImportAsync(WmsInOutStockRecordsImportModel input)
-    {
-
-    }
-
+    public async Task ImportAsync(WmsInOutStockRecordsImportModel input) 
+    { 
+        Check.NotNull(input, nameof(input)); 
+ 
+        var wmsInOutStockRecordCreateDtos = new List<(int RowIndex, WmsInOutStockRecordCreateDto Item)>(); 
+        var wmsInOutStockRecordUpdateDtos = new List<(int RowIndex, Guid Id, WmsInOutStockRecordUpdateDto Item)>(); 
+        var importItems = input.WmsInOutStockRecords; 
+ 
+        if (importItems != null && importItems.Any()) 
+        { 
+            #region 瀵煎叆鏍¢獙 
+ 
+            // 鍒ゆ柇鍚嶇О鏄惁閲嶅锛屽苟杈撳嚭绗嚑琛岄噸澶� 
+            var duplicateWmsInOutStockRecords = importItems.GroupBy(x => x.Id).Where(x => x.Count() > 1).ToList(); 
+            if (duplicateWmsInOutStockRecords?.Any() == true) 
+            { 
+                var duplicateWmsInOutStockRecordMsgs = duplicateWmsInOutStockRecords.Select(x => $"绗� {string.Join(",", x.Select(x => x.RowIndex))} 琛岋細{x.Key}  鍚嶇О閲嶅"); 
+                var errorMsg = $"瀵煎叆澶辫触锛侀厤缃紝 {string.Join(",", duplicateWmsInOutStockRecordMsgs)}锛岀粓姝㈠鍏�"; 
+                throw new UserFriendlyException(errorMsg); 
+            } 
+ 
+            #endregion 
+ 
+            foreach (var impItem in importItems) 
+            { 
+                if (impItem.Id.IsNullOrWhiteSpace()) 
+                { 
+                    continue; 
+                } 
+ 
+                if (impItem.Id.IsNullOrWhiteSpace()) 
+                { 
+                    var errorMsg = $"瀵煎叆澶辫触锛侀厤缃紝绗瑊impItem.RowIndex}琛岋細WmsInOutStockRecord鍚嶇О涓嶈兘涓虹┖"; 
+                    throw new UserFriendlyException(errorMsg); 
+                } 
+ 
+                var oldWmsInOutStockRecord = await wmsInOutStockRecordRepository.FindByNameAsync(impItem.Id); 
+                if (oldWmsInOutStockRecord != null) 
+                { 
+                    var wmsInOutStockRecordUpdateDto = new WmsInOutStockRecordUpdateDto 
+                    { 
+                        OrderNo = impItem.OrderNo,
+MaterialName = impItem.MaterialName,
+MaterialNo = impItem.MaterialNo,
+StockType = impItem.StockType,
+ContainerNo = impItem.ContainerNo,
+MaterialModel = impItem.MaterialModel,
+OperateTime = impItem.OperateTime,
+Remark = impItem.Remark,
+MaterialId = impItem.MaterialId,
+TaskNo = impItem.TaskNo,
+SourcePlace = impItem.SourcePlace,
+ToPlace = impItem.ToPlace,
+IsDisabled = impItem.IsDisabled,
+ 
+                    }; 
+ 
+                    wmsInOutStockRecordUpdateDtos.Add((impItem.RowIndex, oldWmsInOutStockRecord.Id, wmsInOutStockRecordUpdateDto)); 
+                } 
+                else 
+                { 
+                    var wmsInOutStockRecordCreateDto = new WmsInOutStockRecordCreateDto 
+                    { 
+                        OrderNo = impItem.OrderNo,
+MaterialName = impItem.MaterialName,
+MaterialNo = impItem.MaterialNo,
+StockType = impItem.StockType,
+ContainerNo = impItem.ContainerNo,
+MaterialModel = impItem.MaterialModel,
+OperateTime = impItem.OperateTime,
+Remark = impItem.Remark,
+MaterialId = impItem.MaterialId,
+TaskNo = impItem.TaskNo,
+SourcePlace = impItem.SourcePlace,
+ToPlace = impItem.ToPlace,
+IsDisabled = impItem.IsDisabled,
+ 
+                    }; 
+ 
+                    wmsInOutStockRecordCreateDtos.Add((impItem.RowIndex, wmsInOutStockRecordCreateDto)); 
+                } 
+            } 
+        } 
+ 
+        // 鏂板 
+        foreach (var wmsInOutStockRecordDto in wmsInOutStockRecordCreateDtos) 
+        { 
+            try 
+            { 
+                await CreateAsync(wmsInOutStockRecordDto.Item); 
+            } 
+            catch (Exception e) 
+            { 
+                var errorMsg = $"瀵煎叆澶辫触锛侀厤缃紝绗瑊wmsInOutStockRecordDto.RowIndex}琛岋細{e.Message}锛岀粓姝㈠鍏�"; 
+                throw new UserFriendlyException(errorMsg); 
+            } 
+        } 
+ 
+        // 鏇存柊 
+        foreach (var wmsInOutStockRecordDto in wmsInOutStockRecordUpdateDtos) 
+        { 
+            try 
+            { 
+                await UpdateAsync(wmsInOutStockRecordDto.Id, wmsInOutStockRecordDto.Item); 
+            } 
+            catch (Exception e) 
+            { 
+                var errorMsg = $"瀵煎叆澶辫触锛侀厤缃紝绗瑊wmsInOutStockRecordDto.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(GetWmsInOutStockRecordInput input)
-    {
-        Check.NotNull(input, nameof(input));
-
-        if (input.Sorting.IsNullOrWhiteSpace())
-        {
-            input.Sorting = nameof(WmsInOutStockRecord.Sort);
-        }
-
+    public async Task<(Dictionary<string, object> Sheets, string FileName)> ExportAsync(GetWmsInOutStockRecordInput input) 
+    { 
+        Check.NotNull(input, nameof(input)); 
+ 
+        if (input.Sorting.IsNullOrWhiteSpace()) 
+        { 
+            input.Sorting = nameof(WmsInOutStockRecord.Sort); 
+        } 
+ 
         #region 鍔ㄦ�佹瀯閫犳煡璇㈡潯浠�  
-
+ 
         //鍔ㄦ�佹瀯閫犳煡璇㈡潯浠�  
-        var whereConditions = DynamicGetQueryParams(input);
-
-        #endregion
-
-
-        var list = await _wmsInOutStockRecordRepository.GetListAsync(whereConditions, input.Sorting, input.MaxResultCount, input.SkipCount, includeDetails: true);
-        var result = ObjectMapper.Map<List<WmsInOutStockRecord>, List<WmsInOutStockRecordDto>>(list);
-
-        var sheets = new Dictionary<string, object>
-        {
-            ["閰嶇疆"] = ExportHelper.ConvertListToExportData(result),
-        };
-
-        var fileName = result.Count > 1 ? "WmsInOutStockRecord鍒楄〃" : result.Count == 1 ? result[0]?.MaterialName : "WmsInOutStockRecord妯$増";
-        return (sheets, fileName);
-    }
-
+        var whereConditions = DynamicGetQueryParams(input); 
+ 
+        #endregion 
+ 
+ 
+        var list = await wmsInOutStockRecordRepository.GetListAsync(whereConditions, input.Sorting, input.MaxResultCount, input.SkipCount, includeDetails: true); 
+        var result = ObjectMapper.Map<List<WmsInOutStockRecord>, List<WmsInOutStockRecordDto>>(list); 
+ 
+        var sheets = new Dictionary<string, object> 
+        { 
+            ["閰嶇疆"] = ExportHelper.ConvertListToExportData(result), 
+        }; 
+ 
+        var fileName = result.Count > 1 ? "鍑哄叆搴撹褰曞垪琛�" : result.Count == 1 ? result[0]?.Id : "WmsInOutStockRecord妯$増"; 
+        return (sheets, fileName); 
+    } 
+ 
     /// <summary> 
-    /// 鏍¢獙鍑哄叆搴撹褰曡〃锛屽綋鏂板缓鎴栨洿鏂版椂 
+    /// 鏍¢獙鍑哄叆搴撹褰曪紝褰撴柊寤烘垨鏇存柊鏃� 
     /// </summary> 
     /// <param name="input"></param> 
     /// <returns></returns> 
-    protected Task CheckCreateOrUpdateDtoAsync(WmsInOutStockRecordCreateOrUpdateDtoBase input)
-    {
-        Check.NotNull(input, nameof(input));
-        Check.NotNullOrWhiteSpace(input.OrderNo, "鍗曟嵁缂栧彿", 50);
+    protected Task CheckCreateOrUpdateDtoAsync(WmsInOutStockRecordCreateOrUpdateDtoBase input) 
+    { 
+        Check.NotNull(input, nameof(input)); 
+                Check.NotNullOrWhiteSpace(input.OrderNo, "鍗曟嵁缂栧彿", 50);
         Check.NotNullOrWhiteSpace(input.MaterialNo, "鐗╂枡浠跺彿", 50);
         Check.NotNull(input.StockType, "鎿嶄綔绫诲瀷");
         Check.NotNullOrWhiteSpace(input.MaterialId, "鐗╂枡ID", 50);
         Check.NotNullOrWhiteSpace(input.TaskNo, "浠诲姟鍙�", 50);
-
-        return Task.CompletedTask;
-    }
-}
+ 
+        return Task.CompletedTask; 
+    } 
+} 

--
Gitblit v1.9.3