From fc4894cace1eb65732b5f75767ce5657bc4d586e Mon Sep 17 00:00:00 2001
From: yl <ykxkd@outlook.com>
Date: 星期二, 06 九月 2022 19:11:15 +0800
Subject: [PATCH] 看板滚动公告查询接口开发
---
VueWebApi/Hubs/ChatHub.cs | 18 ++++++++++--------
1 files changed, 10 insertions(+), 8 deletions(-)
diff --git a/VueWebApi/Hubs/ChatHub.cs b/VueWebApi/Hubs/ChatHub.cs
index f095823..e7f51fb 100644
--- a/VueWebApi/Hubs/ChatHub.cs
+++ b/VueWebApi/Hubs/ChatHub.cs
@@ -1,8 +1,10 @@
锘縰sing Microsoft.AspNet.SignalR;
using System;
using System.Collections.Generic;
+using System.Data;
using System.Linq;
using System.Web;
+using VueWebApi.Models;
namespace VueWebApi.Hubs
{
@@ -13,14 +15,10 @@
/// </summary>
private IList<string> userList = UserInfo.userList;
-
-
/// <summary>
/// 鐢ㄦ埛鐨刢onnectionID涓庣敤鎴峰悕瀵圭収琛�
/// </summary>
private readonly static Dictionary<string, string> _connections = new Dictionary<string, string>();
-
-
/// <summary>
/// 鍙戦�佸嚱鏁帮紝鍓嶇瑙﹀彂璇ュ嚱鏁扮粰鏈嶅姟鍣紝鏈嶅姟鍣ㄥ湪灏嗘秷鎭彂閫佺粰鍓嶇锛岋紙Clients.All.(鍑芥暟鍚�)鏄叏浣撳箍鎾紝鍙﹀Clients鎻愪緵浜嗙粍鎾紝骞挎挱鎺掗櫎锛岀粍鎾帓闄わ紝鎸囧畾鐢ㄦ埛鎾彂绛夌瓑锛�
@@ -32,14 +30,16 @@
public void SendByGroup(string name1, string name2, string cont)
{
//Client鍐呬负鐢ㄦ埛鐨刬d锛屾槸鍞竴鐨勶紝SendMessage鍑芥暟鏄墠绔嚱鏁帮紝鎰忔�濇槸鏈嶅姟鍣ㄥ皢璇ユ秷鎭帹閫佽嚦鍓嶇
+ //Clients.Client(_connections[name2]).SendMessage("鏉ヨ嚜鐢ㄦ埛:" + name1 + " 鍐呭锛�" + cont + "" + DateTime.Now.ToString("yyyy/MM/ddhh:mm:ss") + "鐨勬秷鎭帹閫侊紒");
Clients.Client(_connections[name2]).SendMessage("鏉ヨ嚜鐢ㄦ埛:" + name1 + " 鍐呭锛�" + cont + "" + DateTime.Now.ToString("yyyy/MM/ddhh:mm:ss") + "鐨勬秷鎭帹閫侊紒");
}
-
- public void SendByGroups(string name1, IList<string>name2, string cont)
+ public void SendByGroups(string name1, DataTable name2, string cont)
{
- //Client鍐呬负鐢ㄦ埛鐨刬d锛屾槸鍞竴鐨勶紝SendMessage鍑芥暟鏄墠绔嚱鏁帮紝鎰忔�濇槸鏈嶅姟鍣ㄥ皢璇ユ秷鎭帹閫佽嚦鍓嶇
- Clients.Clients(name2).SendMessage("鏉ヨ嚜鐢ㄦ埛:" + name1 + " 鍐呭锛�" + cont + "" + DateTime.Now.ToString("yyyy/MM/ddhh:mm:ss") + "鐨勬秷鎭帹閫侊紒");
+ var departmentIDs = name2.AsEnumerable().ToList().Select(x => x.Field<string>("name")).ToList();
+ var FindPublicBaseDic = _connections.Where(d => departmentIDs.Contains(d.Key)).Select(x=>x.Value).ToList();
+ Clients.Clients(FindPublicBaseDic).SendMessage("鏉ヨ嚜鐢ㄦ埛:" + name1 + " 鍐呭锛�" + cont + "" + DateTime.Now.ToString("yyyy/MM/ddhh:mm:ss") + "鐨勬秷鎭帹閫侊紒");
}
+
/// <summary>
/// 鐢ㄦ埛涓婄嚎鍑芥暟
@@ -62,6 +62,8 @@
Clients.All.loginUser(userList);
}
}
+
+
public class UserInfo
{
public static IList<string> userList = new List<string>();
--
Gitblit v1.9.3