接口修哎，tryp接口设置事务超时时间wms接口修改获取数据方法（未启用）

be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/appsettings.json

@@ -1,7 +1,7 @@
 {
   "ConnectionStrings": {
     "Default": "Server=10.164.113.32,1818\\SHDB;Database=Wms_Dy_ShangHai;uid=ShWmsUser;pwd=Faty@Wms_20230413#SH;TrustServerCertificate=True",
-    "DataExchange": "Server=10.164.113.32,1818\\SHDB;Database=WMS_DongYang_DataExchange;uid=ShWmsUser;pwd=Faty@Wms_20230413#SH;TrustServerCertificate=True",
+    "DataExchange": "Server=10.164.113.32,1818\\SHDB;Database=Wms_DataExchange_Main_Dy_ShangHai;uid=ShWmsUser;pwd=Faty@Wms_20230413#SH;TrustServerCertificate=True",
     "EOS": "Server=61.139.155.47;Database=EOSSH;Uid=wms;Pwd=1;TrustServerCertificate=True"
   },
 

be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.TyrpAgent/Outgoing/TyrpOutgoingBackgroundWorker.cs

@@ -1,3 +1,4 @@
+using System.Data;
 using System.Linq;
 using System.Threading.Tasks;
 using Microsoft.Extensions.DependencyInjection;
@@ -28,7 +29,7 @@ public class TyrpOutgoingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase
 
     }
 
-    [UnitOfWork]
+    [UnitOfWork(true,isolationLevel:IsolationLevel.Serializable,50)]
     protected override async Task DoWorkAsync(PeriodicBackgroundWorkerContext workerContext)
   {
         Logger.LogInformation($"Starting: Handling {Outgoing}");

be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/OutgoingFromWmsWorker.cs

@@ -33,6 +33,17 @@ public class OutgoingFromWmsWorker : AsyncPeriodicBackgroundWorkerBase
 
         //Do the work
         var batchSize = _options.BatchSize;
+        //List<Filter> filters = new List<Filter>();
+        //filters.Add( new Filter("Status", EnumExchangeDataStatus.Unread.ToString()));
+        //var input = new SfsStoreRequestInputBase
+        //{
+        //    Condition = new Condition { Filters = filters },
+        //    MaxResultCount = batchSize,
+        //    SkipCount = 0,
+        //    Sorting = "WriteTime"
+        //};
+        
+        //var exchangeDataList = await exchangeDataAppService.GetAllListByFilterAsync(input).ConfigureAwait(false);
         var exchangeDataList = await exchangeDataAppService.GetToBeProcessedListAsync(batchSize).ConfigureAwait(false);
         var outgoingFromWmsList = objectMapper.Map<List<ExchangeDataDTO>, List<OutgoingFromWms>>(exchangeDataList);
         await outgoingFromWmsManager.CreateManyAsync(outgoingFromWmsList).ConfigureAwait(false);

be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/DataExchanges/IssueNoteEventHandler.cs

@@ -38,8 +38,9 @@ public class IssueNoteEventHandler
         {
             await detail.TrySetLocationAsync(LocationAclService).ConfigureAwait(false);
         }
-        var exchangeDatames = await BuildExchangeDataAsync(StoreEventConsts.WMS, StoreEventConsts.MES, ExchangeDataType, dtos).ConfigureAwait(false);
-        await AddManyAsync(exchangeDatames).ConfigureAwait(false);
+        //20230915mes无此接口
+        //var exchangeDatames = await BuildExchangeDataAsync(StoreEventConsts.WMS, StoreEventConsts.MES, ExchangeDataType, dtos).ConfigureAwait(false);
+       // await AddManyAsync(exchangeDatames).ConfigureAwait(false);
         //如果无明细不给tyrp传接口只给mes传接口
         var toErpDto = new List<IssueNoteDTO>();
         foreach (var item in dtos)

be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/DataExchanges/PurchaseReceiptNoteEventHandler.cs

@@ -37,7 +37,7 @@ public class PurchaseReceiptNoteEventHandler
         {
             await detail.TrySetLocationAsync(LocationAclService, detail.LocationCode).ConfigureAwait(false);
         }
-        //QAD
+        //20230915tyrp无此接口
         var exchangeData = await BuildExchangeDataAsync(StoreEventConsts.WMS, StoreEventConsts.ERP, ExchangeDataType, dtos).ConfigureAwait(false);
         await AddManyAsync(exchangeData).ConfigureAwait(false);
     }