本文主要向大家介绍了基于SQLServer数据库实现微信推送消息，通过具体的内容向大家展现，希望对大家学习SQLServer数据库有所帮助。
最近新上了一个项目，需要监控设备数据，增加一个报警功能。
短信要收费，邮件不方便，需要查看，微信是一个非常好的消息报警推送的手段。
微信目前不提供单独的用户推送消息接口，面向应用的话，就只有从订阅号、服务号、企业号当中选择一个。这里不在解释这三个号的区别，请自行查看微信公众平台说明。
显然，企业号是一个比较好的选择。企业号的通讯录可以把公司所有人加入进来，并且划分部门。同时企业号还支持创建独立应用，应用相当于一个独立的群，可以对通讯录设定用户可见，实现群聊功能，同时也支持各种二次开发。
这里我的思路是首先把技术部的人员加入到企业号，然后创建一个项目应用，将预警信息推送到这个项目中，同时设置技术部可见。
1. 那么首先需要注册微信企业号。这里不在说明，请按照提示注册。实际使用发现，不认证(交300)也可以正常使用，用户上限受限制。
2. 然后在通讯录中创建技术部，加入技术人员信息(关联微信号)，同时让他们关注企业号。
3. 在应用中心创建应用，设置可见范围技术部，启用回调模式，并获取Token，和EncodingAESKey。这里由于不需要处理交互消息，所以部在说明接口页面实现，我是直接把Senparc.Weixin.QY的Sample网站挂上去用了。当然想着把其中的Token，CorpID,EncodingAESKey这些换成自己企业号的。
4. 在设置-》权限管理->普通管理组中新建一个组。用来执行应用使用。(需要管理组的 Secret)
5. 使用VS2015新建项目，其他语言-Sqlserver-数据库项目。
6. 项目中右键，新建项，SQL CLR C# 存储过程。
7. 实现代码如下，测试代码，比较乱，见谅。
[csharp] view plain copy
1. using System;
2. using System.Data;
3. using System.Data.SqlClient;
4. using System.Data.SqlTypes;
5. using Microsoft.SqlServer.Server;
6. using System.Net;
7. using System.Text;
8. using System.Net.Security;
9. using System.Security.Cryptography.X509Certificates;
10. using System.IO;
11.
12.
13. public partial class StoredProcedures
14. {
15. public static readonly string Token = “0Eh7xxxxxxxxxfPm”;//与微信企业账号后台的Token设置保持一致，区分大小写。
16. public static readonly string EncodingAESKey = “pA4xxxxxxxxxxxwKzoP”;//与微信企业账号后台的EncodingAESKey设置保持一致，区分大小写。
17. public static readonly string CorpId = “wx8exxxx7300”;//与微信企业账号后台的EncodingAESKey设置保持一致，区分大小写。
18. public static readonly string CorpSecret = “N__IpQrxxxxxxxxxQxYGuaFw6DpGpM7dF0-K”;
19.
20.
21. private static readonly string DefaultUserAgent = “Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.2; SV1; .NET CLR 1.1.4322; .NET CLR 2.0.50727)”;
22.
23.
24. private static bool CheckValidationResult(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors errors)
25. {
26. return true; //总是接受
27. }
28.
29.
30. public static HttpWebResponse CreatePostHttpResponse(string url, string postData, Encoding charset)
31. {
32. HttpWebRequest request = null;
33. //HTTPSQ请求
34. ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult);
35. request = WebRequest.Create(url) as HttpWebRequest;
36. request.ProtocolVersion = HttpVersion.Version10;
37. request.Method = “POST”;
38. request.ContentType = “application/x-www-form-urlencoded”;
39. request.UserAgent = DefaultUserAgent;
40.
41.
42. byte[] data = charset.GetBytes(postData);
43. using (Stream stream = request.GetRequestStream())
44. {
45. stream.Write(data, 0, data.Length);
46. }
47. return request.GetResponse() as HttpWebResponse;
48. }
49.
50.
51. [Microsoft.SqlServer.Server.SqlProcedure]
52. public static void SendWxMessage2Part (SqlString partid, SqlString message)
53. {
54. // 在此处放置代码
55. string access_token = GetAccess_Token();
56. string url = “https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=” + access_token;
57. string postData = “{\”touser\”:\”\”,\”toparty\”: \””+ partid.ToString() + “\”,\”totag\”: \”\”,\”msgtype\”: \”text\”,\”agentid\”: 1,\”text\”: {\”content\”: \””+ message .ToString()+ “\”},\”safe\”:0}”;
58. Encoding encoding = Encoding.GetEncoding(“utf-8”);
59.
60.
61. HttpWebResponse response = CreatePostHttpResponse(url, postData, encoding);
62. }
63. [Microsoft.SqlServer.Server.SqlProcedure]
64. public static void SendWxMessage2User(SqlString userid, SqlString message)
65. {
66. // 在此处放置代码
67. string access_token = GetAccess_Token();
68. string url = “https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=” + access_token;
69. string postData = “{\”touser\”:\””+ userid .ToString()+ “\”,\”toparty\”: \”\”,\”totag\”: \”\”,\”msgtype\”: \”text\”,\”agentid\”: 1,\”text\”: {\”content\”: \””+ message .ToString()+ “\”},\”safe\”:0}”;
70. Encoding encoding = Encoding.GetEncoding(“utf-8”);
71.
72.
73. HttpWebResponse response = CreatePostHttpResponse(url, postData, encoding);
74. }
75. [Microsoft.SqlServer.Server.SqlProcedure]
76. public static void SendWxMessage2Tag(SqlString tagid, SqlString message)
77. {
78. // 在此处放置代码
79. string access_token = GetAccess_Token();
80. string url = “https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=” + access_token;
81. string postData = “{\”touser\”:\”\”,\”toparty\”: \”\”,\”totag\”: \””+ tagid .ToString()+ “\”,\”msgtype\”: \”text\”,\”agentid\”: 1,\”text\”: {\”content\”: \”” + message.ToString() + “\”},\”safe\”:0}”;
82. Encoding encoding = Encoding.GetEncoding(“utf-8”);
83.
84.
85. HttpWebResponse response = CreatePostHttpResponse(url, postData, encoding);
86. }
87.
88.
89. public static string GetAccess_Token()
90. {
91. var url1 = string.Format(“https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={0}&corpsecret={1}”, CorpId, CorpSecret);
92. Encoding encoding = Encoding.GetEncoding(“utf-8”);
93. HttpWebResponse response1 = CreatePostHttpResponse(url1, “”, encoding);
94. Stream stream1 = response1.GetResponseStream(); //获取响应的字符串流
95. StreamReader sr1 = new StreamReader(stream1); //创建一个stream读取流
96. string jsonText = sr1.ReadToEnd(); //从头读到尾，放到字符串html
97. sr1.Close();
98. stream1.Close();
99.
100.
101. string access_token = jsonText.Substring(17, 64);
102. return access_token;
103.
104.
105. }
106.
107. }
8. 生成项目，到Debug下将dll文件复制到服务器上去。
9. 执行如下脚本，启用clr，然后配置一下权限，导入dll到程序集，然后定义对应的存储过程。
[sql] view plain copy
1. —开启所有服务器配置选项
2. EXEC sp_configure N’show advanced options’, N’1′
3. RECONFIGURE WITH OVERRIDE
4. –开启clr enabled 选项
5. EXEC sp_configure N’clr enabled’, N’1′
6. RECONFIGURE WITH OVERRIDE
7. –关闭所有服务器配置选项
8. EXEC sp_configure N’show advanced options’, N’0′
9. RECONFIGURE WITH OVERRIDE
10. –如果存在权限问题，执行下面一段脚本
11. alter database CloudPF set TRUSTWORTHY on
12. EXEC sp_changedbowner ‘sa’
13.
14.
15. ALTER DATABASE CloudPF SET TRUSTWORTHY ON
16. GO
17. CREATE ASSEMBLY [Wx]
18. AUTHORIZATION [dbo]
19. FROM
20. ‘E:\DATA\Microsoft SQL Server\CLR\Wx.Common.dll’
21. WITH PERMISSION_SET = UNSAFE
22. GO
23.
24.
25. create proc dbo.SendWxMessage2Part
26. (@partid nvarchar(200),
27. @message nvarchar(2000))
28. AS
29. —sql c# clr 程序集文件名.类名.方法名
30. EXTERNAL NAME Wx.StoredProcedures.SendWxMessage2Part
31. go
32.
33.
34. create proc dbo.SendWxMessage2User
35. (@userid nvarchar(200),
36. @message nvarchar(2000))
37. AS
38. —sql c# clr 程序集文件名.类名.方法名
39. EXTERNAL NAME Wx.StoredProcedures.SendWxMessage2User
40. go
41.
42.
43. create proc dbo.SendWxMessage2Tag
44. (@tagid nvarchar(200),
45. @message nvarchar(2000))
46. AS
47. —sql c# clr 程序集文件名.类名.方法名
48. EXTERNAL NAME Wx.StoredProcedures.SendWxMessage2Tag
49. go
10. 在数据库可编程性下面，程序集和存储过程中，就能看到我们新加的C#的接口了。
11. 自行测试一下就好了 exec dbo.SendWxMessage2Part ‘2’,’ttttttt’ 这样，partID在公众平台企业号管理里面修改那可以看到，具体自行查说明。
PS：这里说一下遇到的一些问题。
1. 微信的权限，需要确认管理组，应用两部分的通讯录的可见性，如果出现交叉，可能会存在权限问题，报82001的错误。
2. SqlClr在编译的时候平台选择要根据数据库来选择，如果是2012需要选3.5，2016才可以选4.0，具体可以自行尝试。
3. 数据库项目属性中的sqlserver平台要与实际平台一致。
4. vs2015自带的发布，除非是safe，不然无法发布成功，建议使用脚本自行将程序集导入数据库。
5. 里面没用其他的类库，之前试过使用Newtonsoft的类库，发现要自己导入一堆的dll，包括.net自带的dll,很麻烦，于是直接用字符串截取方法获取的access_token。这样任何三方dll都没用，只导入自己就好了。
6. 注意C#存储过程定义的时候，参数类型要用SQLString这样的专用类型，不然无法部署。
这样就可以直接在触发器或者存储过程，计划任务中直接发微信消息了，省去好多事。
本文最新首发于微信公众号：高效工具导航，您可以关注获取最新的文章。
