数据大屏增加110来源工单消息推送

src/Hotline.Api/Realtimes/RealtimeMethods.cs

@@ -75,6 +75,8 @@
         public static string OrderHandlingDetail = "OrderHandlingDetail";
 
         public static string OrderSecondaryHandlingDetail = "OrderSecondaryHandlingDetail";
+
+        public static string OrderSourePoliceDetail = "OrderSourePoliceDetail";
         #endregion
 
         #region 司法大屏

src/Hotline.Api/Realtimes/RealtimeService.cs

@@ -228,6 +228,15 @@ public class RealtimeService : IRealtimeService, IScopeDependency
     /// <returns></returns>
     public Task OrderSecondaryHandlingDetailAsync(object obj, CancellationToken cancellationToken) =>
         SendToGroupAsync(RealtimeGroupNames.BigDataScreen, RealtimeMethods.OrderSecondaryHandlingDetail, obj, cancellationToken);
+
+    /// <summary>
+    /// 推送110来源工单
+    /// </summary>
+    /// <param name="obj"></param>
+    /// <param name="cancellationToken"></param>
+    /// <returns></returns>
+    public Task OrderSourePoliceDetailAsync(object obj, CancellationToken cancellationToken) =>
+        SendToGroupAsync(RealtimeGroupNames.BigDataScreen, RealtimeMethods.OrderSourePoliceDetail, obj, cancellationToken);
     #endregion
 
     /// <summary>

src/Hotline.Application/Bigscreen/DataScreenRefreshService.cs

@@ -127,6 +127,21 @@ namespace Hotline.Application.Bigscreen
                 }
                 catch { }
 
+                try
+                {
+                    var list = await _orderRepository
+                       .Queryable(false, false, false)
+                       .Where(x => x.Source ==ESource.Police110&& x.StartTime.Value.Date == DateTime.Now.Date)
+                       .OrderByDescending(x => x.StartTime)
+                       .Take(50)
+                       .ToListAsync();
+                    var orderlist = _mapper.Map<List<OrderDto>>(list);
+
+                    await realtimeService.OrderSourePoliceDetailAsync(orderlist, stoppingToken);
+                }
+                catch { }
+
+
                 await Task.Delay(times);
             }
         }

src/Hotline/Realtimes/IRealtimeService.cs

@@ -24,7 +24,7 @@ namespace Hotline.Realtimes
 
         #region 系统消息通知
 
-        Task CircularRecoordAsync(string id,string title,string sendContent, CancellationToken cancellationToken);
+        Task CircularRecoordAsync(string id, string title, string sendContent, CancellationToken cancellationToken);
 
         #endregion
 
@@ -61,6 +61,14 @@ namespace Hotline.Realtimes
         Task OrderHandlingDetailAsync(object obj, CancellationToken cancellationToken);
 
         Task OrderSecondaryHandlingDetailAsync(object obj, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// 推送110来源工单
+        /// </summary>
+        /// <param name="obj"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task OrderSourePoliceDetailAsync(object obj, CancellationToken cancellationToken);
         #endregion
 
         #region 司法大屏