Browse Source

大屏数据

田爽 1 year ago
parent
commit
dee0c51b83
1 changed files with 7 additions and 16 deletions
  1. 7 16
      src/Hotline.Application/Bigscreen/SeatStateDataRefreshService.cs

+ 7 - 16
src/Hotline.Application/Bigscreen/SeatStateDataRefreshService.cs

@@ -52,22 +52,13 @@ namespace Hotline.Application.Bigscreen
 
 
 				while (!stoppingToken.IsCancellationRequested)
 				while (!stoppingToken.IsCancellationRequested)
 				{
 				{
-					var now = DateTime.Now;
-					var secRange = (now - _lastModifyTime).TotalSeconds;
-					if (secRange > 10)
-					{
-						var call24 = await seatStateDataService.GetCall24(stoppingToken);
-						await realtimeService.BsSeatStateDataShowChangedAsync1(call24, stoppingToken);
-						var callTop10 = await seatStateDataService.GetCallTop10(stoppingToken);
-						await realtimeService.BsSeatStateDataShowChangedAsync2(callTop10, stoppingToken);
-						var callList = await seatStateDataService.GetCallList(stoppingToken);
-						await realtimeService.BsSeatStateDataShowChangedAsync3(callList, stoppingToken);
-						//var callAverage = await seatStateDataService.GetCallAverage(stoppingToken);
-						//await realtimeService.BsSeatStateDataShowChangedAsync4(callAverage, stoppingToken);
-						//logger.LogInformation($"send msg: {orders.First().Address}");
-						_lastModifyTime = DateTime.Now;
-						//}
-					}
+					await realtimeService.BsSeatStateDataShowChangedAsync1(await seatStateDataService.GetCall24(stoppingToken), stoppingToken);
+					await realtimeService.BsSeatStateDataShowChangedAsync2(await seatStateDataService.GetCallTop10(stoppingToken), stoppingToken);
+					await realtimeService.BsSeatStateDataShowChangedAsync3(await seatStateDataService.GetCallList(stoppingToken), stoppingToken);
+					await realtimeService.BsSeatStateDataShowChangedAsync4(await seatStateDataService.GetCallAverage(stoppingToken), stoppingToken);
+					//logger.LogInformation($"send msg: {orders.First().Address}");
+					_lastModifyTime = DateTime.Now;
+					//}
 					await Task.Delay(times, stoppingToken);
 					await Task.Delay(times, stoppingToken);
 				}
 				}
 			}
 			}