src/Hotline.Api/Realtimes/RealtimeMethods.cs

@@ -46,7 +46,14 @@
 
         #region 大屏-数据展示
 
-        public static string BsDataShow = "BsDataShow";
+        public static string BsDataShowArea1 = "BsDataShowArea1";
+        public static string BsDataShowArea2 = "BsDataShowArea2";
+        public static string BsDataShowArea3 = "BsDataShowArea3";
+        public static string BsDataShowArea4 = "BsDataShowArea4";
+        public static string BsDataShowArea5 = "BsDataShowArea5";
+        public static string BsDataShowArea6 = "BsDataShowArea6";
+        public static string BsDataShowArea7 = "BsDataShowArea7";
+        public static string BsDataShowArea8 = "BsDataShowArea8";
 
         #endregion
     }

src/Hotline.Api/Realtimes/RealtimeService.cs

@@ -166,8 +166,14 @@ public class RealtimeService : IRealtimeService, IScopeDependency
 
     #region 大屏.数据展示
 
-    public Task BsDataShowChangedAsync(object obj, CancellationToken cancellationToken) =>
-        SendToGroupAsync(RealtimeGroupNames.BigScreenDataShow, RealtimeMethods.BsDataShow, obj, cancellationToken);
+    public Task BsDataShowChanged1Async(object obj, CancellationToken cancellationToken) => SendToGroupAsync(RealtimeGroupNames.BigScreenDataShow, RealtimeMethods.BsDataShowArea1, obj, cancellationToken);
+    public Task BsDataShowChanged2Async(object obj, CancellationToken cancellationToken) => SendToGroupAsync(RealtimeGroupNames.BigScreenDataShow, RealtimeMethods.BsDataShowArea2, obj, cancellationToken);
+    public Task BsDataShowChanged3Async(object obj, CancellationToken cancellationToken) => SendToGroupAsync(RealtimeGroupNames.BigScreenDataShow, RealtimeMethods.BsDataShowArea3, obj, cancellationToken);
+    public Task BsDataShowChanged4Async(object obj, CancellationToken cancellationToken) => SendToGroupAsync(RealtimeGroupNames.BigScreenDataShow, RealtimeMethods.BsDataShowArea4, obj, cancellationToken);
+    public Task BsDataShowChanged5Async(object obj, CancellationToken cancellationToken) => SendToGroupAsync(RealtimeGroupNames.BigScreenDataShow, RealtimeMethods.BsDataShowArea5, obj, cancellationToken);
+    public Task BsDataShowChanged6Async(object obj, CancellationToken cancellationToken) => SendToGroupAsync(RealtimeGroupNames.BigScreenDataShow, RealtimeMethods.BsDataShowArea6, obj, cancellationToken);
+    public Task BsDataShowChanged7Async(object obj, CancellationToken cancellationToken) => SendToGroupAsync(RealtimeGroupNames.BigScreenDataShow, RealtimeMethods.BsDataShowArea7, obj, cancellationToken);
+    public Task BsDataShowChanged8Async(object obj, CancellationToken cancellationToken) => SendToGroupAsync(RealtimeGroupNames.BigScreenDataShow, RealtimeMethods.BsDataShowArea8, obj, cancellationToken);
 
     #endregion
 

src/Hotline.Application/Bigscreen/BigscreenDataShowRefreshService.cs

@@ -13,10 +13,12 @@ namespace Hotline.Application.Bigscreen
     public class BigscreenDataShowRefreshService : BackgroundService
     {
         private readonly IServiceScopeFactory _serviceScopeFactory;
+        private readonly DateTime _lastModifyTime;
 
         public BigscreenDataShowRefreshService(IServiceScopeFactory serviceScopeFactory)
         {
             _serviceScopeFactory = serviceScopeFactory;
+            _lastModifyTime = DateTime.Now;
         }
 
         /// <summary>
@@ -39,7 +41,7 @@ namespace Hotline.Application.Bigscreen
                     Age = 20,
                 };
 
-                await realtimeService.BsDataShowChangedAsync(data, stoppingToken);
+                //await realtimeService.BsDataShowChangedAsync(data, stoppingToken);
 
                 await Task.Delay(30000, stoppingToken);
             }

src/Hotline.Repository.SqlSugar/Quality/QualityRepository.cs

@@ -1,4 +1,5 @@
-using Hotline.Quality;
+using Hotline.Ai.Quality;
+using Hotline.Quality;
 using Hotline.Repository.SqlSugar.DataPermissions;
 using Hotline.Share.Dtos.File;
 using Hotline.Share.Dtos.Quality;
@@ -18,19 +19,22 @@ namespace Hotline.Repository.SqlSugar.Quality
 		private readonly ISessionContext _sessionContext;
 		private readonly IMapper _mapper;
 		private readonly IRepository<QualityDetail> _qualiteyDetail;
+        private readonly IAiQualityService _aiQualityService;
 
-		public QualityRepository(
+        public QualityRepository(
 			ISugarUnitOfWork<HotlineDbContext> uow,
 			IDataPermissionFilterBuilder dataPermissionFilterBuilder,
 			ISessionContext sessionContext,
 			IMapper mapper,
-			IRepository<QualityDetail> qualiteyDetail
-			) : base(uow, dataPermissionFilterBuilder)
+			IRepository<QualityDetail> qualiteyDetail,
+			IAiQualityService aiQualityService
+        ) : base(uow, dataPermissionFilterBuilder)
 		{
 			_sessionContext = sessionContext;
 			_mapper = mapper;
 			_qualiteyDetail = qualiteyDetail;
-		}
+            _aiQualityService = aiQualityService;
+        }
 
 		public async Task AddQualityAsync(EQualitySource Source, string OrderId, string VisitId , CancellationToken cancellationToken)
 		{
@@ -55,7 +59,9 @@ namespace Hotline.Repository.SqlSugar.Quality
 			var count = await CountAsync(x => x.OrderId == OrderId && x.Source == Source, cancellationToken);
 			if (count <= 0)
 				await AddQualityAsync(quality, cancellationToken);
-		}
+
+            await _aiQualityService.CreateAiOrderQualityTask(new());
+        }
 
 		public async Task AddQualityAsync(QualityAddDto model, CancellationToken cancellationToken)
 		{

src/Hotline/Ai/Quality/IAiQualityService.cs

@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Hotline.Ai.Quality
+{
+    public interface IAiQualityService
+    {
+        Task CreateAiOrderQualityTask(object obj);
+    }
+}

src/Hotline/Realtimes/IRealtimeService.cs

@@ -30,8 +30,16 @@ namespace Hotline.Realtimes
 
         #region 大屏.数据展示
 
-        Task BsDataShowChangedAsync(object obj, CancellationToken cancellationToken);
+        Task BsDataShowChanged1Async(object obj, CancellationToken cancellationToken);
+        Task BsDataShowChanged2Async(object obj, CancellationToken cancellationToken);
+        Task BsDataShowChanged3Async(object obj, CancellationToken cancellationToken);
+        Task BsDataShowChanged4Async(object obj, CancellationToken cancellationToken);
+        Task BsDataShowChanged5Async(object obj, CancellationToken cancellationToken);
+        Task BsDataShowChanged6Async(object obj, CancellationToken cancellationToken);
+        Task BsDataShowChanged7Async(object obj, CancellationToken cancellationToken);
+        Task BsDataShowChanged8Async(object obj, CancellationToken cancellationToken);
 
         #endregion
+
     }
-}
+}