using Dapper;
|
using Microsoft.AspNet.SignalR;
|
using Microsoft.AspNet.SignalR.Hubs;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Linq;
|
using System.Web;
|
using VueWebApi.Models;
|
using VueWebApi.Tools;
|
|
namespace VueWebApi.Hubs
|
{
|
/// <summary>
|
/// chatHub集线器类
|
/// </summary>
|
[HubName("chatHub")]
|
public class ChatHub : Hub
|
{
|
/// <summary>
|
/// 静态用户列表
|
/// </summary>
|
private IList<string> userList = UserInfo.userList;
|
|
/// <summary>
|
/// 用户的connectionID与用户名对照表
|
/// </summary>
|
private readonly static Dictionary<string, string> _connections = new Dictionary<string, string>();
|
|
/// <summary>
|
/// 发送函数，前端触发该函数给服务器，服务器在将消息发送给前端，（Clients.All.(函数名)是全体广播，另外Clients提供了组播，广播排除，组播排除，指定用户播发等等）
|
/// 该函数名在前端使用时一定要注意，前端调用该函数时，函数首字母一定要小写
|
/// </summary>
|
/// <param name="name1">发起者</param>
|
/// <param name="name2">消息接收者</param>
|
/// <param name="cont">消息内容</param>
|
public void SendByGroup(string name1, string name2, string cont)
|
{
|
LogHelper.WriteLogData("登录人员:" + name1 + "发送人:" + name2 + "发送内容:" + cont);
|
//Client内为用户的id，是唯一的，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, DataTable name2, string cont)
|
{
|
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>
|
/// 安灯呼叫提交时调用
|
/// </summary>
|
/// <param name="username">发起人</param>
|
/// <param name="wkshpcode">车间编码</param>
|
/// <param name="eqpcode">设备编码</param>
|
/// <param name="json"></param>
|
public void SendByGroupList(string username,string wkshpcode, string eqpcode, List<AnDnDate> json)
|
{
|
try
|
{
|
for (int i = 0; i < json.Count; i++)
|
{
|
string cont = wkshpcode + "对应设备" + eqpcode + json[i].name.ToString();
|
var departmentIDs = json[i].children.ToList().Select(x => x.username).ToList();//获取推送人员
|
var FindPublicBaseDic = _connections.Where(d => departmentIDs.Contains(d.Key)).Select(x => x.Value).ToList(); //匹配已经登录的推送人员唯一码
|
LogHelper.WriteLogData("在线人数："+FindPublicBaseDic.Count.ToString());
|
var FindPublicBaseDicName = _connections.Where(d => FindPublicBaseDic.Contains(d.Value)).Select(x => x.Key).ToList(); //根据唯一码匹配已经登录的推送人员名称
|
LogHelper.WriteLogData("在线人人员名称：" + FindPublicBaseDicName.ToString());
|
Clients.Clients(FindPublicBaseDic).SendMessage("来自用户:" + username + " 内容：" + cont + "时间" + DateTime.Now.ToString("yyyy/MM/ddhh:mm:ss") + "的消息通知！");
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.WriteLogData("报错:"+ex.Message);
|
throw;
|
}
|
|
}
|
|
|
/// <summary>
|
/// 用户上线函数(单用户)
|
/// </summary>
|
/// <param name="name">用户名</param>
|
public void SendLogin(string name)
|
{
|
//LogHelper.WriteLogData("登录人员:" + name);
|
if (!userList.Contains(name))
|
{
|
userList.Add(name);
|
//这里便是将用户id和姓名联系起来
|
_connections.Add(name, Context.ConnectionId);
|
}
|
else
|
{
|
//每次登陆id会发生变化
|
_connections[name] = Context.ConnectionId;
|
LogHelper.WriteLogData("执行关联:-->" + _connections[name]);
|
}
|
//新用户上线，服务器广播该用户名
|
Clients.All.loginUser(userList);
|
}
|
/// <summary>
|
/// 用户上线函数(多用户)
|
/// </summary>
|
/// <param name="code">用户名集合</param>
|
public void SendLogins(string code)
|
{
|
string[] selects = Array.ConvertAll<string, string>(code.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries), s => s.ToString()); //string分割转string[]
|
//查找系统用户
|
var sql = @"select usercode as code,username as name
|
from TUser
|
where is_delete='0' and enable='Y' and usercode in @usercode";
|
var data = DapperHelper.selectlist(sql, new { shopcode = selects.ToArray() });
|
for (int i = 0; i < data.Rows.Count; i++)
|
{
|
|
if (!userList.Contains(data.Rows[i]["name"].ToString()))
|
{
|
userList.Add(data.Rows[i]["name"].ToString());
|
//这里便是将用户id和姓名联系起来
|
_connections.Add(data.Rows[i]["name"].ToString(), Context.ConnectionId);
|
}
|
else
|
{
|
//每次登陆id会发生变化
|
_connections[data.Rows[i]["name"].ToString()] = Context.ConnectionId;
|
}
|
}
|
//新用户上线，服务器广播该用户名
|
Clients.All.loginUser(userList);
|
}
|
}
|
public class UserInfo
|
{
|
public static IList<string> userList = new List<string>();
|
}
|
}
|
