新增 批量重发

be/Modules/Store/src/Win_in.Sfs.Wms.Store.Application.Contracts/ExchangeDatas/IExchangeDataAppService.cs

@@ -14,4 +14,5 @@ public interface IExchangeDataAppService
     Task<List<ExchangeDataDTO>> GetToBeProcessedListPostAsync(int batchSize);
     Task<List<ExchangeDataDTO>> GetToBeProcessedListOnlyReadAsync(int batchSize);
     Task<List<ExchangeDataDTO>> UpdateStatusByIdListAsync(List<Guid> list);
+    Task<List<string>> ReSendByListAsync(List<string> list);
 }

be/Modules/Store/src/Win_in.Sfs.Wms.Store.Application/ExchangeDatas/ExchangeDataAppService.cs

@@ -3,6 +3,7 @@ using System.Collections.Generic;
 using System.Linq;
 using System.Threading.Tasks;
 using Castle.Components.DictionaryAdapter;
+using DocumentFormat.OpenXml.Office2010.ExcelAc;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.EntityFrameworkCore;
@@ -78,6 +79,44 @@ public class ExchangeDataAppService
         return new ExchangeDataDTO() { Id = entityNew.Id };
     }
 
+    [HttpPost("re-send-by-list")]
+    public virtual async Task<List<string>> ReSendByListAsync(List<string> list)
+    {
+        var exchangeDataOldList =
+            await _repository.GetListAsync(p => list.Contains(p.TyrpNumber)).ConfigureAwait(false);
+
+        var listnew = new List<string>();
+
+        foreach (var exchangeDataOld in exchangeDataOldList)
+        {
+            exchangeDataOld.Status = EnumExchangeDataStatus.Error;
+
+            var exchangeDataNew = new ExchangeData
+            {
+                DataAction = exchangeDataOld.DataAction,
+                DataContent = exchangeDataOld.DataContent,
+                DataIdentityCode = exchangeDataOld.DataIdentityCode,
+                DataType = exchangeDataOld.DataType,
+                DestinationSystem = exchangeDataOld.DestinationSystem,
+                EffectiveDate = exchangeDataOld.EffectiveDate,
+                Remark = exchangeDataOld.Remark,
+                SourceSystem = exchangeDataOld.SourceSystem,
+                WriteTime = DateTime.Now,
+                Writer = null
+            };
+
+            var entityNew = await _repository.InsertAsync(exchangeDataNew).ConfigureAwait(false);
+
+            exchangeDataOld.Remark = $"在【{DateTime.Now}】时，重新生成了新的接口数据:ID为【{entityNew.Id}】";
+
+            await _repository.UpdateAsync(exchangeDataOld).ConfigureAwait(false);
+
+            listnew.Add(entityNew.Id.ToString());
+        }
+
+        return listnew;
+    }
+
     [HttpPost("by-batchsize-post")]
     public virtual async Task<List<ExchangeDataDTO>> GetToBeProcessedListPostAsync(int batchSize)
     {