From 742664d994a4dff99d71bd7be2f4c3cf4753bf5c Mon Sep 17 00:00:00 2001 From: tanglong <842690096@qq.com> Date: Mon, 28 Jul 2025 14:56:35 +0800 Subject: [PATCH] d --- YD_AllHeartRates.Api/Mqtt/MqttBackgroundService.cs | 4 ++-- YD_AllHeartRates.Api/Utilities/AppSettings.cs | 3 +++ YD_AllHeartRates.Api/appsettings.json | 2 ++ 3 files changed, 7 insertions(+), 2 deletions(-) diff --git a/YD_AllHeartRates.Api/Mqtt/MqttBackgroundService.cs b/YD_AllHeartRates.Api/Mqtt/MqttBackgroundService.cs index cef03df..6ccbcc8 100644 --- a/YD_AllHeartRates.Api/Mqtt/MqttBackgroundService.cs +++ b/YD_AllHeartRates.Api/Mqtt/MqttBackgroundService.cs @@ -97,7 +97,7 @@ namespace YD_AllHeartRates.Api.Mqtt studentList = (from d in _smartSportsContext.Device join s in _smartSportsContext.Student on d.StudentNo equals s.StudentNo join c in _smartSportsContext.Class on s.ClassId equals c.Id - where s.StudentStatus == 1 + where s.SchoolCode == AppSettings.SchoolCode && s.StudentStatus == 1 select new StudentDto { SchoolCode = s.SchoolCode, @@ -114,7 +114,7 @@ namespace YD_AllHeartRates.Api.Mqtt DeviceType = d.DeviceType, }).ToList(); - devices = _smartSportsContext.Device.ToList(); + devices = _smartSportsContext.Device.Where(x => x.SchoolCode == AppSettings.SchoolCode).ToList(); _caching.AddObject(AppSettings.StudentListCacheKey, studentList, 28800); _caching.AddObject(AppSettings.DeviceListCacheKey, devices, 28800); diff --git a/YD_AllHeartRates.Api/Utilities/AppSettings.cs b/YD_AllHeartRates.Api/Utilities/AppSettings.cs index b4f1cdb..464b422 100644 --- a/YD_AllHeartRates.Api/Utilities/AppSettings.cs +++ b/YD_AllHeartRates.Api/Utilities/AppSettings.cs @@ -16,6 +16,8 @@ public static string StudentListCacheKey = "student_list"; public static string DeviceListCacheKey = "device_list"; + public static string SchoolCode { get; set; } + public static void Init(IConfiguration configuration) { Logging = configuration.GetSection("Logging").Get(); @@ -25,6 +27,7 @@ FlushTime = configuration["FlushTime"]; DbConnectionString = configuration["DbConnectionString"]; SmartSportsString = configuration["SmartSportsString"]; + SchoolCode = configuration["SchoolCode"]; RedisConnectionString = configuration["RedisConnectionString"]; CorsUrls = configuration["CorsUrls"].Split(','); Mqtt = configuration.GetSection("Mqtt").Get(); diff --git a/YD_AllHeartRates.Api/appsettings.json b/YD_AllHeartRates.Api/appsettings.json index 5948be5..cbe105f 100644 --- a/YD_AllHeartRates.Api/appsettings.json +++ b/YD_AllHeartRates.Api/appsettings.json @@ -25,6 +25,8 @@ "FlushTime": "2000", //大屏刷新周期 + "SchoolCode": "202507280052", + "AppUrls": { },