Browse Source

修改 datachange 排序规则

集成Redis
郑勃旭 2 years ago
parent
commit
10136e2b97
  1. 4
      be/Modules/Store/src/Win_in.Sfs.Wms.Store.Application/ExchangeDatas/ExchangeDataAppService.cs
  2. 2
      be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/ExchangeDatas/ExchangeDataManager.cs

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

@ -86,7 +86,7 @@ public class ExchangeDataAppService
var entities = await var entities = await
(await _repository.GetDbSetAsync().ConfigureAwait(false)) (await _repository.GetDbSetAsync().ConfigureAwait(false))
.Where(p => p.Status == EnumExchangeDataStatus.Unread) .Where(p => p.Status == EnumExchangeDataStatus.Unread)
.OrderBy(p => p.WriteTime) .OrderBy(p => p.TyrpNumber)
.Take(batchSize) .Take(batchSize)
.ToListAsync().ConfigureAwait(false); .ToListAsync().ConfigureAwait(false);
@ -108,7 +108,7 @@ public class ExchangeDataAppService
var entities = await var entities = await
(await _repository.GetDbSetAsync().ConfigureAwait(false)) (await _repository.GetDbSetAsync().ConfigureAwait(false))
.Where(p => p.Status == EnumExchangeDataStatus.Unread) .Where(p => p.Status == EnumExchangeDataStatus.Unread)
.OrderBy(p => p.WriteTime) .OrderBy(p => p.TyrpNumber)
.Take(batchSize) .Take(batchSize)
.ToListAsync().ConfigureAwait(false); .ToListAsync().ConfigureAwait(false);

2
be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/ExchangeDatas/ExchangeDataManager.cs

@ -39,7 +39,7 @@ public class ExchangeDataManager : DomainService, IExchangeDataManager
var entities = await var entities = await
(await _repository.GetDbSetAsync().ConfigureAwait(false)) (await _repository.GetDbSetAsync().ConfigureAwait(false))
.Where(p => p.Status == EnumExchangeDataStatus.Unread) .Where(p => p.Status == EnumExchangeDataStatus.Unread)
.OrderBy(p => p.WriteTime) .OrderBy(p => p.TyrpNumber)
.Take(batchSize) .Take(batchSize)
.ToListAsync().ConfigureAwait(false); .ToListAsync().ConfigureAwait(false);

Loading…
Cancel
Save