1 class SignalRHepler
 2 {
 3 
 4     /// <summary>
 5     /// 获取通讯类上下文
 6     /// </summary>
 7     static  IHubContext _hubContext;
 8     // 定义一个静态变量来保存类的实例
 9     private static SignalRHepler uniqueInstance;
10 
11     // 定义一个标识确保线程同步
12     private static readonly object locker = new object();
13 
14     // 定义私有构造函数，使外界不能创建该类实例
15     public static SignalRHepler Instance
16     {
17         get
18         {
19             // 如果类的实例不存在则创建，否则直接返回
20             if (uniqueInstance == null)
21             {
22                 lock (locker)
23                 {
24                     uniqueInstance = new SignalRHepler();
25                     _hubContext = GlobalHost.ConnectionManager.GetHubContext<ChatHub>();
26                 }
27             }
28             return uniqueInstance;
29         }
30     }
31     /// <summary>
32     /// 推送消息
33     /// </summary>
34     public void BroadcastMessage(List<B2cmesremind> model)
35     {
36         if (model != null && model.Count > 0)
37         {
38             HubContext.Clients.All.sendMessage(model);
39         }
40     }
41     /// <summary>
42     /// 发送消息
43     /// </summary>
44     /// <param name="companyId">用户CompanyId</param>
45     public void BatchSend(string companyId)
46     {
47         var list = NetWork.WcfHelper.TravelHelper.GetList_B2cmesremind(new Dictionary<string, object> {
48                 { nameof(B2cmesremind.IsDeleted),0},
49                 { nameof(B2cmesremind.IsRead),0},
50                 { nameof(B2cmesremind.CompanyId),companyId}
51             });
52         BroadcastMessage(list);
53     }
54 }