From 4f57c3e602eef9ec929a2315183fa28b21cd0987 Mon Sep 17 00:00:00 2001
From: yl <ykxkd@outlook.com>
Date: 星期三, 29 三月 2023 10:51:33 +0800
Subject: [PATCH] 订单下达获取工单语句修改、生产工单手工创建获取单据号接口
---
VueWebApi/Hubs/ChatHub.cs | 39 ++++++++++++++++++++++++++++++++++++++-
1 files changed, 38 insertions(+), 1 deletions(-)
diff --git a/VueWebApi/Hubs/ChatHub.cs b/VueWebApi/Hubs/ChatHub.cs
index c271caa..77ab1dd 100644
--- a/VueWebApi/Hubs/ChatHub.cs
+++ b/VueWebApi/Hubs/ChatHub.cs
@@ -1,14 +1,20 @@
锘縰sing 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>
@@ -42,6 +48,36 @@
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>
/// 鐢ㄦ埛涓婄嚎鍑芥暟(鍗曠敤鎴�)
@@ -49,7 +85,7 @@
/// <param name="name">鐢ㄦ埛鍚�</param>
public void SendLogin(string name)
{
- LogHelper.WriteLogData("鐧诲綍浜哄憳:" + name);
+ //LogHelper.WriteLogData("鐧诲綍浜哄憳:" + name);
if (!userList.Contains(name))
{
userList.Add(name);
@@ -60,6 +96,7 @@
{
//姣忔鐧婚檰id浼氬彂鐢熷彉鍖�
_connections[name] = Context.ConnectionId;
+ LogHelper.WriteLogData("鎵ц鍏宠仈:-->" + _connections[name]);
}
//鏂扮敤鎴蜂笂绾匡紝鏈嶅姟鍣ㄥ箍鎾鐢ㄦ埛鍚�
Clients.All.loginUser(userList);
--
Gitblit v1.9.3