C# 企业微信:开启消息接受&接收消息&推送消息

2023-11-07

前言:微信吧!接触的人都会100%各种踩坑,就算同样东西去年做过,今年来一样踩坑,因为太多你稍微不记得一点点的细节就能让你研究N久。为此,我要把这个过程详细的记录下来。

 

一、开启消息接受


 1.拿到企业corpId,应用的Token,EncodingAESKey

2.这界面先别关,拿到 Token,EncodingAESKey后,建个接口

鉴于公司系统的架构类型,我这里创建的是一个aspx文件,代码如下:

public partial class request_WxMsgApi : System.Web.UI.Page
{
    protected void Page_Load(object sender, EventArgs e)
    {
        //开启消息接受
        if (Request.HttpMethod.ToUpper() == "GET")
        {
            string signature = HttpContext.Current.Request.QueryString["msg_signature"];
            string timestamp = HttpContext.Current.Request.QueryString["timestamp"];
            string nonce = HttpContext.Current.Request.QueryString["nonce"];
            string echostr = HttpContext.Current.Request.QueryString["echostr"];
            string decryptEchoString = "";
            WXBizMsgCrypt wxcpt = new WXBizMsgCrypt("your token", "your EncodingAESKey", System.Configuration.ConfigurationManager.AppSettings["Corpid"]);
            int ret = wxcpt.VerifyURL(signature, timestamp, nonce, echostr, ref decryptEchoString);
            if (ret != 0)
            {
                //有错误的话记录日志
                //WriteLogFile("ERR: VerifyURL fail, ret: " + ret);
            }
            HttpContext.Current.Response.Write(decryptEchoString);
            HttpContext.Current.Response.End();
            return;
        }
}
}

注意:WXBizMsgCrypt类和Cryptography类,到微信官方下载即可链接

3.写完代码,将文件更新到服务器,让这个 aspx文件能外网访问。然后再在

把这个aspx文件的链接填上去,若能正常返回,这里就会保存成功,若不能那就得再去补坑了....

 

二、接收消息


上面已经与微信那边打通了接口,接下来就是要正真接受消息了。开启消息是get请求,而正式使用接受消息则微信是post数据过来,所以  接口打通之后上面那些代码就没用了,因为数据传输模式和处理模式都不一样了

我这里的接收消息,会把各种类型的文件存到数据库或者服务器,非文本的则存到服务器,放个路径到数据库

代码如下:

public partial class request_WxMsgApi : System.Web.UI.Page
{
    protected void Page_Load(object sender, EventArgs e)
    {
        byte[] btHtml = Request.BinaryRead(Request.ContentLength);
        string strHtml = System.Text.Encoding.Default.GetString(btHtml);

        //接受消息
        if (Request.HttpMethod.ToUpper() == "POST")
        {
            string token = "your token";//从配置文件获取Token
            string encodingAESKey = "your EncodingAESKey";//从配置文件获取EncodingAESKey
            string corpId = System.Configuration.ConfigurationManager.AppSettings["corpid"];//从配置文件获取corpId

            string signature = HttpContext.Current.Request.QueryString["msg_signature"];
            string timestamp = HttpContext.Current.Request.QueryString["timestamp"];
            string nonce = HttpContext.Current.Request.QueryString["nonce"];
            string decryptEchoString = "";

            WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(token, encodingAESKey, corpId);
            int ret = wxcpt.DecryptMsg(signature, timestamp, nonce, strHtml, ref decryptEchoString);
            if (ret == 0)
            {
                //WriteLogFile("ERR: VerifyURL fail, ret: " + ret);
                if (!string.IsNullOrEmpty(decryptEchoString))
                {
                    try
                    {
                        XmlDocument doc = new XmlDocument();
                        doc.LoadXml(decryptEchoString);
                        XmlNode root = doc.FirstChild;
                        var msgType = root["MsgType"].InnerText;//voice(MediaId),video(MediaId),text(Content),image(PicUrl),
                        if (msgType == "voice" || msgType == "video" || msgType == "text" || msgType == "image")
                        {
                            var msgId = root["MsgId"].InnerText;
                            var fromuser = root["FromUserName"].InnerText;
                            var timesend = root["CreateTime"].InnerText;//时间戳
                            DateTime dtStart = TimeZone.CurrentTimeZone.ToLocalTime(new DateTime(1970, 1, 1));
                            long lTime = long.Parse(timesend + "0000000");
                            TimeSpan toNow = new TimeSpan(lTime);
                            var cTime = dtStart.Add(toNow);
                            var content = "";

                            switch (msgType)
                            {
                                case "voice":
                                    content = root["MediaId"].InnerText;
                                    break;
                                case "video":
                                    content = root["MediaId"].InnerText;
                                    break;
                                case "text":
                                    content = root["Content"].InnerText;
                                    break;
                                case "image":
                                    content = root["PicUrl"].InnerText;
                                    break;
                                default:
                                    break;
                            }
                            string sql = "insert into T_CmpWxMsg([MsgId],[MsgType],[FromUser],[CreateTime],[Content]) values(@MsgId,@MsgType,@FromUser,@CreateTime,@Content)";
                            DataHelper.ExecuteNonQuery(sql, new System.Data.SqlClient.SqlParameter[]
                            {
                                new System.Data.SqlClient.SqlParameter("@MsgId", msgId),
                                new System.Data.SqlClient.SqlParameter("@MsgType", msgType),
                                new System.Data.SqlClient.SqlParameter("@FromUser", fromuser),
                                new System.Data.SqlClient.SqlParameter("@CreateTime", cTime),
                                new System.Data.SqlClient.SqlParameter("@Content", content)
                            }, conString);
                            //WriteLogFile("存入数据库成功" + cTime);

                            //异步任务-检索未下载的媒体文件
                            System.Threading.Tasks.Task.Factory.StartNew(() =>
                            {
                                //WriteLogFile("异步任务开始");
                                try
                                {
                                    //拉取媒体源文件
                                    string sql_ = "select ID,Content,MsgType from T_CmpWxMsg WHERE ISNULL(MediaSavePath,'')='' and MsgType in ('voice','video')";
                                    var mediaList = DataOperation.DataCenter.ExecuteReader(sql_, Base.ConString, new object[] { });
                                    foreach (var item in mediaList)
                                    {
                                        string corpsecret = System.Configuration.ConfigurationManager.AppSettings["corpsecret"];//你的应用对应的secrect
                                        string tocken = Base.GetCorpToken(corpsecret, corpId).Access_Token;//拿取tocken,注意有效时间,最好用缓存控制
                                        string url = string.Format("https://qyapi.weixin.qq.com/cgi-bin/media/get?access_token={0}&media_id={1}", tocken, item.Content);

                                        string upfile = Path.Combine(System.AppDomain.CurrentDomain.BaseDirectory, @"file\wxMaterial");
                                        if (!System.IO.Directory.Exists(upfile))
                                            System.IO.Directory.CreateDirectory(upfile);

                                        string filePath = upfile + "\\" + item.Content + (item.MsgType == "voice" ? ".amr" : ".mp4");
                                        WebClient client = new WebClient();
                                        client.DownloadFile(url, filePath);

                                        //更新存储的物理路径
                                        string updatesql = "update T_CmpWxMsg set MediaSavePath = '" + (@"\file\wxMaterial\" + item.Content + (item.MsgType == "voice" ? ".amr" : ".mp4")) + "' where ID='" + item.ID + "'";
                                        DataHelper.ExecuteNonQuery(updatesql, Base.ConString);
                                    }
                                }
                                catch (Exception ex) {
                                    //WriteLogFile("异步任务执行出错:" + ex.Message);
                                }
                            });
                        }
                    }
                    catch (Exception ex)
                    {
                       // WriteLogFile("程序异常:" + ex.Message);
                    }
                    finally
                    {
                        //WriteLogFile("解密消息内容:" + decryptEchoString);
                        HttpContext.Current.Response.Write(decryptEchoString);
                        HttpContext.Current.Response.End();
                    }
                }
            }
        }
    }
}

注意:这里用到的WXBizMsgCrypt类,在上面有提到可以到官方下载。

 

三、发送消息


string msg = "你好!<a href=\"https://blog.csdn.net/u012847695/article/details/102936505\">点这里查看</a>";
//按部门发送
//item = new { toparty = "438|439|471", msgtype = "text", agentid = "8", text = new { content = msg }, safe = "0" };
//按人发送
dynamic item = new { touser = "wanger|liuer", msgtype = "text", agentid = "你的应用对应的agentid", text = new { content = msg }, safe = "0" };
var body = Base.DataToJson(item);
var corpsecret = System.Configuration.ConfigurationManager.AppSettings["corpsecret"];
string tocken = Base.GetCorpToken(corpsecret).Access_Token;//获取token,注意有效时间,可用缓存控制
string url = string.Format("https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token={0}", tocken);
var result = Base.InfoPost(url, body);//post request 请求
JavaScriptSerializer js = new JavaScriptSerializer();
IDictionary obj = js.DeserializeObject(result) as IDictionary;

post请求代码

 public static string InfoPost(string url, string body)
    {
        HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(new Uri(url));
        request.Timeout = 30000;//30秒
        request.Method = "POST";
        byte[] payload = System.Text.Encoding.UTF8.GetBytes(body);
        Stream writer = request.GetRequestStream();
        writer.Write(payload, 0, payload.Length);
        writer.Close();
        HttpWebResponse response = (HttpWebResponse)request.GetResponse();
        StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.GetEncoding("utf-8"));
        var result = reader.ReadToEnd();
        return result;
    }

下次来写个支付的,自己写的看得懂点,不然每次才坑都要各种百度查资料

以上纯属个人独自研究成果,仅供参考,转载请注明出处

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

C# 企业微信:开启消息接受&接收消息&推送消息 的相关文章

  • Unix网络编程澄清

    我正在翻阅这本经典书籍Unix网络编程 https rads stackoverflow com amzn click com 0139498761 当我偶然发现这个程序时 第 6 8 节 第 179 180 页 include unp h
  • 如何检查QProcess是否正确执行?

    QProcess process sdcompare QString command sdcompare QStringList args sdcompare command sdcompare diff args sdcompare lt
  • 如何将隐藏字段从一个页面传递到另一页面?

    我有一个 Net 类库 我想从一次代码隐藏页面传递一个隐藏变量 并在另一个代码隐藏页面中获取它 请注意 我没有任何可以使用表单标签和 get post 方法的设计页面 aspx 页面 我们应该怎么做 注意 我想使用隐藏字段将值从一页传递到另
  • 如何修复此错误“GDI+ 中发生一般错误”?

    从默认名称打开图像并以默认名称保存 覆盖它 我需要从 Image Default jpg 制作图形 将其放在 picturebox1 image 上并在 picurebox1 上绘制一些图形 它有效 这不是我的问题 但我无法保存 pictu
  • 互斥体实现可以互换(独立于线程实现)

    所有互斥体实现最终都会调用相同的基本系统 硬件调用吗 这意味着它们可以互换吗 具体来说 如果我使用 gnu parallel算法 使用openmp 并且我想让他们称之为线程安全的类我可以使用boost mutex用于锁定 或者我必须编写自己
  • 如何从 .resx 文件条目获取注释

    资源文件中的字符串有名称 值和注释 The ResXResourceReader类让我可以访问名称和值 有办法看评论吗 你应该能够得到Comment via ResXDataNode class http msdn microsoft co
  • 如何访问另一个窗体上的ListView控件

    当单击与 ListView 所在表单不同的表单中的按钮时 我试图填充 ListView 我在 Form1 中创建了一个方法以在 Form2 中使用 并将参数传递给 Form1 中的方法 然后填充 ListView 当我调试时 我得到了传递的
  • 回发或回调参数无效。使用“”启用事件验证

    当我从客户端回发页面时 出现以下错误 我有修改客户端 asp ListBox 的 JavaScript 代码 我们该如何解决这个问题 错误详细信息如下 Server Error in XXX Application Invalid post
  • 验证插件在更新面板中不起作用

    我有一个更新面板 面板内有文本框和按钮可用 现在我正在使用 jQuery Validation 插件 但是在更新面板中使用时验证插件不起作用 例如 function GetAddressTargetList var objArray new
  • 如何在 Linq 中获得左外连接?

    我的数据库中有两个表 如下所示 顾客 C ID city 1 Dhaka 2 New york 3 London 个人信息 P ID C ID Field value 1 1 First Name Nasir 2 1 Last Name U
  • 未经许可更改内存值

    我有一个二维数组 当我第一次打印数组的数据时 日期打印正确 但其他时候 array last i 的数据从 i 0 到 last 1 显然是一个逻辑错误 但我不明白原因 因为我复制并粘贴了 for 语句 那么 C 更改数据吗 I use g
  • 无需安装即可部署 Expression Encoder SDK

    我试图在使用 Microsoft Expression Encoder 3 SDK 时证明一个概念 我正在尝试将 SDK 部署到我的托管 Web 服务器 以了解更多关于它是否有效以及还需要安装什么的信息 我无法在服务器上进行任何操作 以下是
  • 如何使用 Mongodb C# 驱动程序连接多个集合

    我需要将 3 个集合与多个集合合并在一起 lookup我在 C 驱动程序中尝试过 它允许我 lookup用户采集但无法执行秒 lookup用于设置集合 有人可以帮忙吗 db Transactions aggregate lookup fro
  • 如何编写一个同时需要请求和响应Dtos的ServiceStack插件

    我需要提供本地化数据服务 所有本地化的响应 Dto 都共享相同的属性 IE 我定义了一个接口 ILocalizedDto 来标记那些 Dto 在请求端 有一个ILocalizedRequest对于需要本地化的请求 Using IPlugin
  • std::async 与重载函数

    可能的重复 std bind 重载解析 https stackoverflow com questions 4159487 stdbind overload resolution 考虑以下 C 示例 class A public int f
  • HttpWebRequest 在第二次调用时超时

    为什么以下代码在第二次 及后续 运行时超时 代码挂在 using Stream objStream request GetResponse GetResponseStream 然后引发 WebException 表示请求已超时 我已经尝试过
  • 如何从main方法调用业务对象类?

    我已将代码分为业务对象 访问层 如下所示 void Main Business object public class ExpenseBO public void MakeExpense ExpensePayload payload var
  • 如何在按钮单击时模拟按键 - Unity

    我对 Unity 中的脚本编写非常陌生 我正在尝试创建一个按钮 一旦单击它就需要模拟按下 F 键 要拾取一个项目 这是我当前的代码 在编写此代码之前我浏览了所有统一论坛 但找不到任何有效的东西 Code using System Colle
  • 英特尔 Pin 与 C++14

    问题 我有一些关于在 C 14 或其他 C 版本中使用英特尔 Pin 的问题 使用较新版本从较旧的 C 编译代码很少会出现任何问题 但由于 Intel Pin 是操作指令级别的 如果我使用 C 11 或 C 14 编译它 是否会出现任何不良
  • 如何将 Roslyn 语义模型返回的类型符号名称与 Mono.Cecil 返回的类型符号名称相匹配?

    我有以下代码 var paramDeclType m semanticModel GetTypeInfo paramDecl Type Type Where paramDeclType ToString returns System Col

随机推荐

  • MATLAB怎么使用table格式读取csv文件并画图

    MATLAB中新增了一个table类型 可以很方便的读取文件中的数据 在使用这个格式的时候会默认把读取文件的第一行设置为标题 访问的时候需要通过索引值进行访问 具体怎么操作通过一个MATLAB例子进行说明 MATLAB代码 T readta
  • c 语言怎么释放链表节点,C:如何释放链表中的节点?

    我如何释放在另一个函数中分配的节点 struct node int data struct node next struct node buildList struct node head NULL struct node second N
  • 揭开数学智慧的神秘面纱:MathGPTPro使用指南带你领略数学的魅力!

    请查收一份MathGPTPro的使用指南 欢迎大家进入我们的MathGPTPro群 我们产品的链接在这 https mathgptpro com 欢迎大家踊跃提问 大家可以文字或者图片 也支持手写图片 输入问题 遇到回答中不解的问题 公式
  • MYSQL学习笔记(二)——数据库和数据表操作

    MYSQL数据库学习笔记 二 目录 MYSQL数据库学习笔记 二 一 MYSQL数据库操作 一 创建数据库 二 指定当前数据库 三 修改数据库 四 删除数据库 二 数据表操作 一 创建数据表 二 复制现成的表 三 修改数据表 1 add实例
  • 关于电脑丢失msvcr120.dll的几个修复方法

    MSVCR120 dll它是Windows系统运行某些程序所需的文件之一 如果你在运行某个程序时遇到了MSVCR120 dll丢失的错误 那么你不能简单地忽略它 因为这可能会导致程序无法正常运行 在本篇文章中 我们将为大家介绍一些解决MSV
  • MySQL高效编程学习笔记(五)--表的维护和改造

    修改表的列结构 若表中有数据最好先备份 注意转换前后的字符长度 以及是否可以互相转换等问题 改变列数据类型 ALTER TABLE visitor MODIFY nam VARCHAR 30 Eg alter table goods mod
  • 用Node.js实现一个HTTP服务器程序(文件服务器)

    http Node js开发的目的就是为了用JavaScript编写Web服务器程序 因为JavaScript实际上已经统治了浏览器端的脚本 其优势就是有世界上数量最多的前端开发人员 如果已经掌握了JavaScript前端开发 再学习一下如
  • 基于java的Mock利器-Mockito

    1 认识Mockito Mockito是java单元测试中使用率最高的Mock框架之一 特点 简明的语法和完整的文档 Mockito支持永Maven和Gradle来进行依赖引入和管理 2 Mockito Maven引入
  • 记一次Redis配置database不生效的问题

    1 先贴代码 乍一看 这个配置没问题 redis也在spring下 springboot 的 Configuration 也会默认加载redis的配置 但是一开始怎么调试都不能默认数据库为1的情况 后来我在Redis配置中发现了另一个好东东
  • Linux下重要文件不小心被删除?别着急,看这里!

    针对日常维护操作 难免会出现文件误删除的操作 大家熟知linux文件系统不同win有回收站 删除后的文件可以到垃圾箱寻回 要知道linux文件修复比较费劲 网络上面的文档也是五花八门 所以本次研究一种比较靠谱的文件和目录恢复方法 也给维护人
  • leedcode 1254. 统计封闭岛屿的数目

    题目 二维矩阵 grid 由 0 土地 和 1 水 组成 岛是由最大的4个方向连通的 0 组成的群 封闭岛是一个 完全 由1包围 左 上 右 下 的岛 思路 封闭岛屿是由1完全包围的岛 也就是说 该岛屿不能在二维矩阵的边界处 这种情况排出后
  • C语言编程中遇到Warning提示的解决方法:warning:implicit declaration of function ‘XXX‘,conflicting types for ‘XXX’

    目录 原因 解决办法 总结 在用codeblocks编写C语言代码时遇到了一个错误 implicit declaration of function XXX conflicting types for XXX 这里的 XXX 代表的是我自己
  • 案例实践:Shell定时上传文件至HDFS

    目录 一 项目需求 二 实现思路 三 具体实现流程 1 规划文件目录 2 开发shell脚本 3 给shell脚本授权 4 定时执行Shell脚本 5 查看HDFS历史访问日志 一 项目需求 公司在线服务器每天都会产生网站运行日志 为了避免
  • 机器学习_深度学习毕设题目汇总——目标检测B

    下面是该类的一些题目 题目 典型恶劣天气条件下高铁周界入侵目标检测 图模型融合时空特征的视觉显著性目标检测算法研究 基于SAR图像的舰船目标检测方法研究 基于三维点云分析的智能汽车目标检测方法研究 基于传播模型的显著目标检测方法研究 基于全
  • 如何在Ubuntu服务器上安装 QEMU/KVM 以创建虚拟机

    KVM是 Kernel based Virtual Machine 的缩写 是集成到 Linux 内核中的开源类型 1 虚拟机管理程序 裸机虚拟机管理程序 它允许您创建和管理运行 Windows Linux 或 UNIX 变体 如 Free
  • 微信小程序云开发操作全解

    云开发三大基础能力 云函数 运行在微信服务器上的函数 处理微信相关操作有天然优势 如获得用户信息异常方便 以前服务端解析很麻烦 数据库 一个小程序可以直接操作的JSON数据库 可以直接操作数据库 不在需要服务端了 存储 用来存储文件和图片
  • Vue中获取接口的方法

    在vue小黑框中输入 cnpm install axios 下载安装 可以设置成全局 引入import axios from axios 把axios放进Vue对象的原型中 Vue prototype axios axios 设置默认的地址
  • 思科模拟器基础实验完整流程-初级

    文章目录 实验拓扑 第一部分 企业总部内网 第一层 接入层 第二层 汇聚层 解决 VLAN 间通信 第三层 网络层 第二部分 企业分部内网 第三部分 外部网络路由 第四部分 NAT 地址转换 第五步 VPN 实验拓扑 由图我们可以看到这张拓
  • 【SpringCloud】用【Idea】构建Maven父子工程图文(1)

    1 概述 之前老是出现idea建springCloud的maven父子工程失败 特此写下经验和教训 springboot版本 2 2 1 2 不多逼逼 图文教程直接来 新建maven空工程 事先准备好一个空文件夹 选择刚才建好的空文件夹 不
  • C# 企业微信:开启消息接受&接收消息&推送消息

    前言 微信吧 接触的人都会100 各种踩坑 就算同样东西去年做过 今年来一样踩坑 因为太多你稍微不记得一点点的细节就能让你研究N久 为此 我要把这个过程详细的记录下来 一 开启消息接受 1 拿到企业corpId 应用的Token Encod