|
@@ -48,43 +48,51 @@ namespace Hotline.Application.Bigscreen
|
|
|
|
|
|
while (!stoppingToken.IsCancellationRequested)
|
|
|
{
|
|
|
- var now = DateTime.Now;
|
|
|
- var today = now.Date;
|
|
|
- var month = now.Month;
|
|
|
- var secRange = (now - _lastModifyTime).TotalSeconds;
|
|
|
-
|
|
|
-
|
|
|
- if (secRange >= 10)
|
|
|
+ try
|
|
|
{
|
|
|
- //area1
|
|
|
- var todayTotal = await orderRepository.CountAsync(d => d.CreationTime.Date == today, stoppingToken);
|
|
|
- var todayCompleted =
|
|
|
- await orderRepository.CountAsync(d => d.FiledTime.HasValue && d.FiledTime.Value.Date == today,
|
|
|
- stoppingToken);
|
|
|
- var monthTotal = await orderRepository.CountAsync(d => d.CreationTime.Month == month, stoppingToken);
|
|
|
- var monthCompleted = await orderRepository.CountAsync(d => d.FiledTime.HasValue && d.FiledTime.Value.Month == month, stoppingToken);
|
|
|
- await realtimeService.BsDataShowChanged1Async(new { todayTotal, todayCompleted, monthTotal, monthCompleted }, stoppingToken);
|
|
|
|
|
|
- //area3
|
|
|
- var calls = await callRepository.Queryable()
|
|
|
- .OrderByDescending(d => d.CreationTime)
|
|
|
- .Take(20)
|
|
|
- .Select(d => new { creationTime = d.CreatedTime, from = d.CPNName, to = d.CDPN, d.Duration })
|
|
|
- .ToListAsync(stoppingToken);
|
|
|
- await realtimeService.BsDataShowChanged3Async(calls, stoppingToken);
|
|
|
+ var now = DateTime.Now;
|
|
|
+ var today = now.Date;
|
|
|
+ var month = now.Month;
|
|
|
+ var secRange = (now - _lastModifyTime).TotalSeconds;
|
|
|
|
|
|
- //area8
|
|
|
- var orders = await orderRepository.Queryable(workflowFilter: false)
|
|
|
- .OrderByDescending(d => d.CreationTime)
|
|
|
- .Take(20)
|
|
|
- .Select(d => new { d.No, d.Title, d.Address, d.CreationTime, d.AcceptType })
|
|
|
- .ToListAsync(stoppingToken);
|
|
|
- await realtimeService.BsDataShowChanged8Async(orders, stoppingToken);
|
|
|
|
|
|
- logger.LogInformation($"send msg: {orders.First().Address}");
|
|
|
- _lastModifyTime = DateTime.Now;
|
|
|
- }
|
|
|
+ if (secRange >= 10)
|
|
|
+ {
|
|
|
+ //area1
|
|
|
+ var todayTotal = await orderRepository.CountAsync(d => d.CreationTime.Date == today, stoppingToken);
|
|
|
+ var todayCompleted =
|
|
|
+ await orderRepository.CountAsync(d => d.FiledTime.HasValue && d.FiledTime.Value.Date == today,
|
|
|
+ stoppingToken);
|
|
|
+ var monthTotal = await orderRepository.CountAsync(d => d.CreationTime.Month == month, stoppingToken);
|
|
|
+ var monthCompleted = await orderRepository.CountAsync(d => d.FiledTime.HasValue && d.FiledTime.Value.Month == month, stoppingToken);
|
|
|
+ await realtimeService.BsDataShowChanged1Async(new { todayTotal, todayCompleted, monthTotal, monthCompleted }, stoppingToken);
|
|
|
+
|
|
|
+ //area3
|
|
|
+ var calls = await callRepository.Queryable()
|
|
|
+ .OrderByDescending(d => d.CreationTime)
|
|
|
+ .Take(20)
|
|
|
+ .Select(d => new { creationTime = d.CreatedTime, from = d.CPNName, to = d.CDPN, d.Duration })
|
|
|
+ .ToListAsync(stoppingToken);
|
|
|
+ await realtimeService.BsDataShowChanged3Async(calls, stoppingToken);
|
|
|
+
|
|
|
+ //area8
|
|
|
+ var orders = await orderRepository.Queryable(workflowFilter: false)
|
|
|
+ .OrderByDescending(d => d.CreationTime)
|
|
|
+ .Take(20)
|
|
|
+ .Select(d => new { d.No, d.Title, d.Address, d.CreationTime, d.AcceptType })
|
|
|
+ .ToListAsync(stoppingToken);
|
|
|
+ await realtimeService.BsDataShowChanged8Async(orders, stoppingToken);
|
|
|
|
|
|
+ logger.LogInformation($"send msg: {orders.First().Address}");
|
|
|
+ _lastModifyTime = DateTime.Now;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ catch (Exception)
|
|
|
+ {
|
|
|
+
|
|
|
+ }
|
|
|
await Task.Delay(times, stoppingToken);
|
|
|
}
|
|
|
}
|