数据推送

src/Hotline.Application/Bigscreen/SeatStateDataRefreshService.cs

@@ -52,17 +52,22 @@ namespace Hotline.Application.Bigscreen
 
 				while (!stoppingToken.IsCancellationRequested)
 				{
-					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;
-					//}
+					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 Task.Delay(times, stoppingToken);
 				}
 			}