|
@@ -45,8 +45,8 @@ namespace Hotline.Application.Jobs
|
|
public async Task Execute(IJobExecutionContext context)
|
|
public async Task Execute(IJobExecutionContext context)
|
|
{
|
|
{
|
|
var calls = await _db.Queryable<XingtangCall>()
|
|
var calls = await _db.Queryable<XingtangCall>()
|
|
- .Where(d => !d.IsSync && d.Tries <= 50)
|
|
|
|
- .Take(10)
|
|
|
|
|
|
+ .Where(d => (d.IsSync == null || !d.IsSync) && (d.Tries == null || d.Tries <= 50))
|
|
|
|
+ .Take(100)
|
|
.ToListAsync(context.CancellationToken);
|
|
.ToListAsync(context.CancellationToken);
|
|
|
|
|
|
var occupyCalls = new List<XingtangCall>();
|
|
var occupyCalls = new List<XingtangCall>();
|