From e691f2ecede6a962dfa76bb4a494ac1c80c9a389 Mon Sep 17 00:00:00 2001
From: yl <ykxkd@outlook.com>
Date: 星期六, 10 九月 2022 00:05:58 +0800
Subject: [PATCH] 设备点检记录导出接口去掉分页参数，设备保养记录查询、明细查询、导出(接口开发)
---
VueWebApi/Hubs/ChatHub.cs | 43 +++++++++++++++++++++++++++++++++++++------
1 files changed, 37 insertions(+), 6 deletions(-)
diff --git a/VueWebApi/Hubs/ChatHub.cs b/VueWebApi/Hubs/ChatHub.cs
index e7f51fb..c271caa 100644
--- a/VueWebApi/Hubs/ChatHub.cs
+++ b/VueWebApi/Hubs/ChatHub.cs
@@ -1,10 +1,11 @@
-锘縰sing Microsoft.AspNet.SignalR;
+锘縰sing Dapper;
+using Microsoft.AspNet.SignalR;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Web;
-using VueWebApi.Models;
+using VueWebApi.Tools;
namespace VueWebApi.Hubs
{
@@ -29,6 +30,7 @@
/// <param name="cont">娑堟伅鍐呭</param>
public void SendByGroup(string name1, string name2, string cont)
{
+ LogHelper.WriteLogData("鐧诲綍浜哄憳:" + name1 + "鍙戦�佷汉:" + name2 + "鍙戦�佸唴瀹�:" + 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") + "鐨勬秷鎭帹閫侊紒");
@@ -36,17 +38,18 @@
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();
+ 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="name">鐢ㄦ埛鍚�</param>
public void SendLogin(string name)
{
+ LogHelper.WriteLogData("鐧诲綍浜哄憳:" + name);
if (!userList.Contains(name))
{
userList.Add(name);
@@ -61,9 +64,37 @@
//鏂扮敤鎴蜂笂绾匡紝鏈嶅姟鍣ㄥ箍鎾鐢ㄦ埛鍚�
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鍒嗗壊杞瑂tring[]
+ //鏌ユ壘绯荤粺鐢ㄦ埛
+ 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());
+ //杩欓噷渚挎槸灏嗙敤鎴穒d鍜屽鍚嶈仈绯昏捣鏉�
+ _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>();
--
Gitblit v1.9.3