坐席数据

src/Hotline.Application/Bigscreen/SeatStateDataRefreshService.cs

@@ -64,7 +64,7 @@ namespace Hotline.Application.Bigscreen
 							In = SqlFunc.AggregateSum(SqlFunc.IIF(x.CallDirection == Share.Enums.CallCenter.ECallDirection.In, 1, 0)),
 							Out = SqlFunc.AggregateSum(SqlFunc.IIF(x.CallDirection == Share.Enums.CallCenter.ECallDirection.Out, 1, 0)),
 						}).MergeTable().ToListAsync(stoppingToken);
-					await realtimeService.BsSeatStateDataShowChangedAsync(call24, stoppingToken);
+					//await realtimeService.BsSeatStateDataShowChangedAsync(call24, stoppingToken);
 
 					var callTop10 = await callRepository.Queryable()
 						.Where(x => x.CreatedTime.ToString("yyyy-MM-dd") == DateTime.Now.ToString("yyyy-MM-dd") && x.CallOrderType == Share.Enums.CallCenter.ECallOrderType.Order)
@@ -74,7 +74,7 @@ namespace Hotline.Application.Bigscreen
 							UserName = x.UserName,
 							In = SqlFunc.AggregateSum(SqlFunc.IIF(x.CallDirection == Share.Enums.CallCenter.ECallDirection.In, 1, 0))
 						}).MergeTable().OrderByDescending(x => x.In).Take(10).ToListAsync(stoppingToken);
-					await realtimeService.BsSeatStateDataShowChangedAsync(callTop10, stoppingToken);
+					//await realtimeService.BsSeatStateDataShowChangedAsync(callTop10, stoppingToken);
 
 					var callList = await callRepository.Queryable()
 						.Where(x => x.CreatedTime.ToString("yyyy-MM-dd") == DateTime.Now.ToString("yyyy-MM-dd") && x.CallOrderType == Share.Enums.CallCenter.ECallOrderType.Order)
@@ -86,7 +86,7 @@ namespace Hotline.Application.Bigscreen
 							OutOn = SqlFunc.AggregateSum(SqlFunc.IIF(x.CallDirection == Share.Enums.CallCenter.ECallDirection.Out && x.OnState == Share.Enums.CallCenter.EOnState.On, 1, 0)),
 							InQueueNoOn = SqlFunc.AggregateSum(SqlFunc.IIF(x.CallDirection == Share.Enums.CallCenter.ECallDirection.In && x.OnState == Share.Enums.CallCenter.EOnState.NoOn && x.QueueTims > 0, 1, 0)),
 						}).MergeTable().ToListAsync(stoppingToken);
-					await realtimeService.BsSeatStateDataShowChangedAsync(callList, stoppingToken);
+					//await realtimeService.BsSeatStateDataShowChangedAsync(callList, stoppingToken);
 
 					var callAverage = await callRepository.Queryable()
 						.Where(x => x.CreatedTime.ToString("yyyy-MM-dd") == DateTime.Now.ToString("yyyy-MM-dd") && x.CallOrderType == Share.Enums.CallCenter.ECallOrderType.Order)
@@ -98,7 +98,7 @@ namespace Hotline.Application.Bigscreen
 							In = SqlFunc.AggregateSum(SqlFunc.IIF(x.CallDirection == Share.Enums.CallCenter.ECallDirection.In, 1, 0)) / 60,
 							Out = SqlFunc.AggregateSum(SqlFunc.IIF(x.CallDirection == Share.Enums.CallCenter.ECallDirection.Out, 1, 0)) / 60,
 						}).MergeTable().ToListAsync(stoppingToken);
-					await realtimeService.BsSeatStateDataShowChangedAsync(callAverage, stoppingToken);
+					await realtimeService.BsSeatStateDataShowChangedAsync(new { Call24 = call24, CallTop10 = callTop10, CallList= callList, CallAverage = callAverage }, stoppingToken);
 
 					//logger.LogInformation($"send msg: {orders.First().Address}");
 					_lastModifyTime = DateTime.Now;