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