简介企业微信会话内容存档C#调用接口源码是一套面向C#开发者的合规存档集成工具用于自动同步企业微信聊天记录并落库满足审计、质检与数据分析需求。包内共81个文件以49个C#源码文件为核心覆盖文本、图片、语音、视频、红包、会议等消息类型的解析同时附带DLL动态库、EXE运行组件、配置文件及调试缓存整体约57.1MB结构清晰便于接入。资源重点展示了企业微信API调用流程、身份与权限验证、定时增量同步策略、异常捕获与日志记录等关键环节并内置VC运行库一键安装包可降低环境搭建门槛。已有206人学习下载适合具备一定C#基础、正在对接会话存档接口的后端或桌面应用开发者。 做企业微信会话内容存档C#调用接口这套东西我从零到一完整做过一遍今天把源码思路和踩坑记录整理出来。这篇内容适合正在接企业微信会话存档接口的.NET开发者也适合团队准备做聊天记录留痕、客服质检、合规需求的架构师参考。读完你至少能把拉取、解密、落库这条主链路跑通。先别急着写代码。企业微信的会话内容存档和企业微信本身的消息推送、群机器人完全不是一个量级的东西它需要企业管理员在成员知情同意的前提下把内部员工和客户之间的聊天记录完整留存下来。这个功能一旦开启所有被纳入范围的成员产生的会话数据都会被加密存档在企业微信服务器上数据保留期一般是3天过期不取就没了。所以你的程序必须能稳定、及时地拉取数据并且要处理好增量游标官方叫seq不能丢数据、不能重复入库这是整个项目的核心难点。1. 会话存档项目的前置认知1.1 会话内容存档到底能做什么一句话概括企业微信把指定成员的所有会话消息单聊、群聊都算在服务器侧加密留存然后对外开放一套接口让企业自己拉取、解密和存储。典型场景有这么几类金融机构、上市公司做合规留痕监管要求聊天记录必须可追溯、可审计。客服团队做服务质量抽检把客服和客户的聊天记录拉下来按关键字、情绪、时长做分析。销售团队做客户沟通沉淀把所有跟客户聊过的东西统一归档防止销售飞单或者离职带走客户资源。从技术角度讲接口的能力边界比较清晰拉取加密消息、解密消息、拉取媒体文件图片、语音、视频等、获取成员同意状态。需要注意拉接口只能拿到“已同意存档的成员”的数据没有经过成员同意的会话内容不会进入存档范围这是产品层面就定死的规则做技术方案时不用纠结也没有绕过空间。1.2 调用接口的完整能力清单企业微信会话存档的接口链路官方文档里管它叫“会话内容存档”核心调用有两个阶段REST API 阶段用企业IDcorpid和应用密钥secret换取 access_token然后调用/cgi-bin/msgaudit/getchatdata拉取一批加密消息。解密阶段拉下来的消息体里有一个加密随机密钥字段encrypt_random_key和一个加密消息字段encrypt_chat_msg需要配合企业微信提供的SDK做解密。官方SDK目前提供的是C/C动态库Windows下是WeWorkFinanceSdk.dllLinux下是libWeWorkFinanceSdk.so所以C#要接入核心工作有两块一是写REST API调用层二是给SDK动态库写P/Invoke封装。这两块做完后面的存储、检索、展示就是普通业务开发了。另外要记住一个数字媒体文件的存档数据服务器保存期限同样有限拉取之后建议立刻转存到自己的对象存储或者NAS别指望企业微信帮你长久保存。2. C#接入方案设计与环境准备2.1 为什么选C#做这层封装C#做企业微信会话存档封装最大的优势是能复用.NET生态。REST API调用用HttpClientJSON解析用System.Text.Json或Newtonsoft.Json定时任务可以塞进BackgroundService或者Quartz.NET底层交付就是一个Windows服务或者Linux守护进程部署运维都很顺手。难点集中在SDK动态库调用上。企业微信官方SDK是C接口需要我们自己声明DllImport。这个封装本身不复杂但细节容易踩坑结构体内存布局要跟C头文件对齐字符串指针要正确处理x86/x64的位数必须跟部署环境匹配。过程中偶尔会遇到直接内存访问违例AccessViolationException多数时候就是结构体定义或者调用约定不对。2.2 开发环境与必备资源清单我这次项目用的环境Windows 10 Visual Studio 2022目标框架 .NET 8官方SDK企业微信会话内容存档SDKC/C动态库版本NuGet包Newtonsoft.Json方便反序列化、System.Security.CryptographySDK内部已封装一般不需要自己实现如果你部署到Linux需要把SDK换成.so文件同时注意DllImport的库名要改成libWeWorkFinanceSdk.so。纯 .NET 8 的DllImport在Linux上是可以直接用相对路径引用本地库的但要把动态库放到应用目录或者LD_LIBRARY_PATH能扫到的地方。注意官方SDK没有官方C# NuGet包。网上有几款社区封装包但质量参差不齐。我更推荐自己封装一层核心逻辑就几十行出了问题能快速定位不用依赖第三方维护。3. 管理后台配置与密钥处理3.1 开通存档与配置成员范围企业微信管理后台开通会话存档前提是企业已完成认证。流程一般是登录企业微信管理后台找到“安全与管理”或者“审计与存档”相关入口。打开“会话内容存档”开关按提示选择需要存档的成员范围。申请接口密钥secret这个secret对应的是“会话内容存档”应用不是普通的自建应用。配置RSA公钥把生成的公钥粘贴到后台指定位置。配置范围这一步很关键。存档成员的增删改不是实时的成员变化后可能要等几分钟才生效我们排查问题时就被这个延迟坑过一回改了成员范围之后立刻调接口结果返回错误码60001无权限还以为代码写错了。3.2 RSA密钥生成与安全存放RSA密钥对是解密的关键。推荐用OpenSSL生成openssl genrsa -out private_key.pem 2048 openssl rsa -in private_key.pem -pubout -out public_key.pem上传公钥到企业微信后台私钥保存在你自己的应用服务器上通过配置文件或者环境变量注入。私钥内容不要提交到Git仓库哪怕是私有仓库也尽量不要万一泄露就相当于把客户聊天记录拱手让人了。私钥格式在SDK初始化时直接传原始PEM字符串即可官方SDK的Init方法支持密钥文件内容作为参数。我见过有人试图先把PEM转成XML再传结果初始化一直失败其实没必要直接把PEM原样传进去就行。4. C#源码实现与关键细节4.1 获取access_token第一步是获取 access_token。这个接口比较简单注意两点一是要缓存token7200秒的有效期没必要每次都请求二是token在并发下要保证只有一个线程在刷新否则容易互相覆盖导致接口报40014。public class WeWorkTokenService { private readonly HttpClient _http; private readonly string _corpid; private readonly string _secret; private string _token string.Empty; private DateTime _expireTime DateTime.MinValue; private readonly SemaphoreSlim _semaphore new(1, 1); public WeWorkTokenService(string corpid, string secret, HttpClient http) { _corpid corpid; _secret secret; _http http; } public async Taskstring GetTokenAsync() { if (!string.IsNullOrEmpty(_token) DateTime.Now _expireTime) return _token; await _semaphore.WaitAsync(); try { if (!string.IsNullOrEmpty(_token) DateTime.Now _expireTime) return _token; var url $https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid{_corpid}corpsecret{_secret}; var json await _http.GetStringAsync(url); var result JsonConvert.DeserializeObjectTokenResult(json); if (result.errcode ! 0) throw new Exception($获取token失败: {result.errcode} {result.errmsg}); _token result.access_token; _expireTime DateTime.Now.AddSeconds(result.expires_in - 300); // 提前5分钟过期 return _token; } finally { _semaphore.Release(); } } } public class TokenResult { public int errcode { get; set; } public string errmsg { get; set; } public string access_token { get; set; } public int expires_in { get; set; } }这里的300秒提前量是实战经验。token过期边界上刚好有一批消息拉取请求可能带着旧token过去提前刷新能少踩很多随机报错。4.2 SDK封装层接下来是官方SDK的P/Invoke封装。先看C头文件里比较关键的结构体和方法签名C#这边要做一一对应[StructLayout(LayoutKind.Sequential)] public struct Slice_t { public int len; public IntPtr buf; } public class WeWorkFinanceSdk { private const string DllName WeWorkFinanceSdk.dll; [DllImport(DllName, CallingConvention CallingConvention.Cdecl)] private static extern IntPtr NewSdk(); [DllImport(DllName, CallingConvention CallingConvention.Cdecl)] private static extern int Init(IntPtr sdk, string corpId, string secret); [DllImport(DllName, CallingConvention CallingConvention.Cdecl)] private static extern int GetChatData(IntPtr sdk, ulong seq, uint limit, string proxy, string passwd, int timeout, out Slice_t chatDatas); [DllImport(DllName, CallingConvention CallingConvention.Cdecl)] private static extern int DecryptData(IntPtr sdk, string encryptRandomKey, string encryptChatMsg, out Slice_t msg); [DllImport(DllName, CallingConvention CallingConvention.Cdecl)] private static extern void FreeSlice(IntPtr slice); }这里有个小细节GetChatData的timeout参数单位是毫秒我一开始传了秒导致接口每次都在短时间内返回超时错误后来翻C头文件注释才发现单位是毫秒。再有就是FreeSlice必须调用否则内存会一直涨。消息量大时一次拉取几百条数据每条都申请了非托管内存不及时释放会直接内存溢出。4.3 拉取会话数据并解密核心流程是拿着access_token调用REST接口拿到密文消息然后丢给SDK解密。我在项目里用一个WeWorkArchiveService来管理整个流程public class WeWorkArchiveService { private readonly WeWorkFinanceSdk _sdk; private readonly IntPtr _sdkHandle; private readonly WeWorkTokenService _tokenService; private readonly HttpClient _http; public WeWorkArchiveService(WeWorkTokenService tokenService, HttpClient http) { _tokenService tokenService; _http http; _sdk new WeWorkFinanceSdk(); _sdkHandle WeWorkFinanceSdk.NewSdk(); var initRet WeWorkFinanceSdk.Init(_sdkHandle, _corpid, _privateKey); if (initRet ! 0) throw new Exception($SDK初始化失败: {initRet}); } public async Task(ulong nextSeq, ListChatMessage messages) FetchChatDataAsync(ulong seq) { var token await _tokenService.GetTokenAsync(); var url $https://qyapi.weixin.qq.com/cgi-bin/msgaudit/getchatdata?access_token{token}; var requestBody new { seq seq, limit 1000, timeout 5000, type 0 }; var content new StringContent(JsonConvert.SerializeObject(requestBody), Encoding.UTF8, application/json); var response await _http.PostAsync(url, content); var responseJson await response.Content.ReadAsStringAsync(); var result JsonConvert.DeserializeObjectChatDataResult(responseJson); if (result.errcode ! 0) throw new Exception($拉取会话数据失败: {result.errcode} {result.errmsg}); var messages new ListChatMessage(); foreach (var item in result.data) { var decryptRet WeWorkFinanceSdk.DecryptData(_sdkHandle, item.encryptRandomKey, item.encryptChatMsg, out var rawMsg); if (decryptRet ! 0) continue; var plainText Marshal.PtrToStringUTF8(rawMsg.buf, rawMsg.len); WeWorkFinanceSdk.FreeSlice(rawMsg.buf); var chatMessage JsonConvert.DeserializeObjectChatMessage(plainText); chatMessage.seq item.seq; messages.Add(chatMessage); } return (result.next_seq, messages); } }拉取到的数据里seq是增量游标下一轮拉取请求要把它传回去。next_seq是服务端返回的下一个位置正常情况下next_seq应该等于当前批次最后一条的seq1。如果next_seq一直不变说明没有新数据。解密后的消息是JSON格式字段大致长这样{ msgid: 123456, action: send, from: {id: zhangsan}, tolist: [{id: lisi}], roomid: wrA1B2C3, msgtime: 1700000000, msgtype: text, text: {content: 你好这条消息会被存档} }常见的msgtype有text、image、voice、video、file、emoji、link、miniprogram等。文本消息直接取text.content图片语音视频这类媒体消息解密后的JSON里会有media_id和md5值还需要再调用一次SDK的GetMediaData方法把真正的文件内容拉下来。媒体文件的处理逻辑相对独立建议放到单独的服务里做不要在拉取主链路里做同步下载。5. 常见问题与排障心得5.1 典型错误码对照调试过程中一定会遇到各种错误码这里把自己踩过的整理成一张表错误码含义产生原因解决办法40001access_token无效token过期、被刷新、缓存并发问题检查token刷新逻辑加锁40014不合法的access_token同40001常见于并发刷新用信号量保证单线程刷新60001无权限访问该接口成员未配置存档范围、secret不对核对后台成员配置和secret60020访问ip不在白名单服务器出口IP未加入白名单把部署服务器公网IP加进白名单30005媒体文件下载失败文件已过期或media_id错误拉取后立即转存失败重试60001这个错误码最有迷惑性。它不光出现在成员范围没配好时如果企业微信后台更新了存档范围接口这边会有几分钟到十几分钟的延迟所以遇到60001先别急着改代码耐心等一会儿再试。5.2 序列推进与消息一致性seq是增量拉取的生命线但它并不保证严格连续。企业微信的文档里说一次拉取可能返回空列表也可能返回非连续的一段seq。所以不能简单认为“下一个seq等于当前seq1”必须使用服务端返回的next_seq。我第一版代码就拿当前seq1去发下一次请求结果出现消息空洞后来才发现应该直接信任next_seq并且在本地记录“已处理的最大seq”用这个值作为下一次拉取的起点。另一个容易忽略的问题是拉取到解密后消息本身有msgtime但你的本地记录应该以seq为准去做顺序控制不能拿msgtime排序。同一时间点可能有多条消息msgtime相同的情况太常见了拿它做唯一性判断一定会出问题。5.3 性能与稳定性优化存档服务一般会挂在后台持续运行性能问题要提前考虑。我的经验是拉取频率不用太高每30秒拉一次足够。limit建议设500或者1000单次拉太多反而容易触发接口超时。拉取和解密要分开。REST接口拉取是慢网络操作解密是CPU操作解密放线程池里并行处理但要注意SDK线程安全问题。我测试下来同一个SDK句柄并发调用DecryptData在Windows下偶尔会崩溃稳妥的做法是给解密操作加一个锁或者维护一个SDK句柄池。消息落库用批量插入不要一条一条插。解密后的JSON塞进数据库的text字段再额外做几张宽表存常用的查询字段比如发送人、接收人、消息类型、时间。检索要求不高的话直接上Elasticsearch也可以但需要考虑运维成本。再说一个亲测有效的细节GetChatData拉数据时如果中间有代理服务器需要把代理地址传给SDK。我们公司测试环境有网络隔离所有外部请求都要走代理一开始没传代理参数接口一直超时后来看了SDK文档把proxy参数传进去才通。最后一点存档服务要加监控告警。最简单的方式就是记录每次拉取时间、拉取条数、解密成功失败数如果连续几轮都拉不到数据或者解密失败率升高立刻报警。这个项目上线跑了一段时间后我们就靠告警抓到了一回私钥被运维同学不小心轮换导致解密全部失败的问题。会话存档这东西量一大、时间一长最怕的就是静默失败一旦中间断了几天数据补数据会非常痛苦提前做好监控比什么都重要。本文还有配套的精品资源点击获取
C#调用企业微信会话存档接口：SDK封装与消息解密实战
简介企业微信会话内容存档C#调用接口源码是一套面向C#开发者的合规存档集成工具用于自动同步企业微信聊天记录并落库满足审计、质检与数据分析需求。包内共81个文件以49个C#源码文件为核心覆盖文本、图片、语音、视频、红包、会议等消息类型的解析同时附带DLL动态库、EXE运行组件、配置文件及调试缓存整体约57.1MB结构清晰便于接入。资源重点展示了企业微信API调用流程、身份与权限验证、定时增量同步策略、异常捕获与日志记录等关键环节并内置VC运行库一键安装包可降低环境搭建门槛。已有206人学习下载适合具备一定C#基础、正在对接会话存档接口的后端或桌面应用开发者。 做企业微信会话内容存档C#调用接口这套东西我从零到一完整做过一遍今天把源码思路和踩坑记录整理出来。这篇内容适合正在接企业微信会话存档接口的.NET开发者也适合团队准备做聊天记录留痕、客服质检、合规需求的架构师参考。读完你至少能把拉取、解密、落库这条主链路跑通。先别急着写代码。企业微信的会话内容存档和企业微信本身的消息推送、群机器人完全不是一个量级的东西它需要企业管理员在成员知情同意的前提下把内部员工和客户之间的聊天记录完整留存下来。这个功能一旦开启所有被纳入范围的成员产生的会话数据都会被加密存档在企业微信服务器上数据保留期一般是3天过期不取就没了。所以你的程序必须能稳定、及时地拉取数据并且要处理好增量游标官方叫seq不能丢数据、不能重复入库这是整个项目的核心难点。1. 会话存档项目的前置认知1.1 会话内容存档到底能做什么一句话概括企业微信把指定成员的所有会话消息单聊、群聊都算在服务器侧加密留存然后对外开放一套接口让企业自己拉取、解密和存储。典型场景有这么几类金融机构、上市公司做合规留痕监管要求聊天记录必须可追溯、可审计。客服团队做服务质量抽检把客服和客户的聊天记录拉下来按关键字、情绪、时长做分析。销售团队做客户沟通沉淀把所有跟客户聊过的东西统一归档防止销售飞单或者离职带走客户资源。从技术角度讲接口的能力边界比较清晰拉取加密消息、解密消息、拉取媒体文件图片、语音、视频等、获取成员同意状态。需要注意拉接口只能拿到“已同意存档的成员”的数据没有经过成员同意的会话内容不会进入存档范围这是产品层面就定死的规则做技术方案时不用纠结也没有绕过空间。1.2 调用接口的完整能力清单企业微信会话存档的接口链路官方文档里管它叫“会话内容存档”核心调用有两个阶段REST API 阶段用企业IDcorpid和应用密钥secret换取 access_token然后调用/cgi-bin/msgaudit/getchatdata拉取一批加密消息。解密阶段拉下来的消息体里有一个加密随机密钥字段encrypt_random_key和一个加密消息字段encrypt_chat_msg需要配合企业微信提供的SDK做解密。官方SDK目前提供的是C/C动态库Windows下是WeWorkFinanceSdk.dllLinux下是libWeWorkFinanceSdk.so所以C#要接入核心工作有两块一是写REST API调用层二是给SDK动态库写P/Invoke封装。这两块做完后面的存储、检索、展示就是普通业务开发了。另外要记住一个数字媒体文件的存档数据服务器保存期限同样有限拉取之后建议立刻转存到自己的对象存储或者NAS别指望企业微信帮你长久保存。2. C#接入方案设计与环境准备2.1 为什么选C#做这层封装C#做企业微信会话存档封装最大的优势是能复用.NET生态。REST API调用用HttpClientJSON解析用System.Text.Json或Newtonsoft.Json定时任务可以塞进BackgroundService或者Quartz.NET底层交付就是一个Windows服务或者Linux守护进程部署运维都很顺手。难点集中在SDK动态库调用上。企业微信官方SDK是C接口需要我们自己声明DllImport。这个封装本身不复杂但细节容易踩坑结构体内存布局要跟C头文件对齐字符串指针要正确处理x86/x64的位数必须跟部署环境匹配。过程中偶尔会遇到直接内存访问违例AccessViolationException多数时候就是结构体定义或者调用约定不对。2.2 开发环境与必备资源清单我这次项目用的环境Windows 10 Visual Studio 2022目标框架 .NET 8官方SDK企业微信会话内容存档SDKC/C动态库版本NuGet包Newtonsoft.Json方便反序列化、System.Security.CryptographySDK内部已封装一般不需要自己实现如果你部署到Linux需要把SDK换成.so文件同时注意DllImport的库名要改成libWeWorkFinanceSdk.so。纯 .NET 8 的DllImport在Linux上是可以直接用相对路径引用本地库的但要把动态库放到应用目录或者LD_LIBRARY_PATH能扫到的地方。注意官方SDK没有官方C# NuGet包。网上有几款社区封装包但质量参差不齐。我更推荐自己封装一层核心逻辑就几十行出了问题能快速定位不用依赖第三方维护。3. 管理后台配置与密钥处理3.1 开通存档与配置成员范围企业微信管理后台开通会话存档前提是企业已完成认证。流程一般是登录企业微信管理后台找到“安全与管理”或者“审计与存档”相关入口。打开“会话内容存档”开关按提示选择需要存档的成员范围。申请接口密钥secret这个secret对应的是“会话内容存档”应用不是普通的自建应用。配置RSA公钥把生成的公钥粘贴到后台指定位置。配置范围这一步很关键。存档成员的增删改不是实时的成员变化后可能要等几分钟才生效我们排查问题时就被这个延迟坑过一回改了成员范围之后立刻调接口结果返回错误码60001无权限还以为代码写错了。3.2 RSA密钥生成与安全存放RSA密钥对是解密的关键。推荐用OpenSSL生成openssl genrsa -out private_key.pem 2048 openssl rsa -in private_key.pem -pubout -out public_key.pem上传公钥到企业微信后台私钥保存在你自己的应用服务器上通过配置文件或者环境变量注入。私钥内容不要提交到Git仓库哪怕是私有仓库也尽量不要万一泄露就相当于把客户聊天记录拱手让人了。私钥格式在SDK初始化时直接传原始PEM字符串即可官方SDK的Init方法支持密钥文件内容作为参数。我见过有人试图先把PEM转成XML再传结果初始化一直失败其实没必要直接把PEM原样传进去就行。4. C#源码实现与关键细节4.1 获取access_token第一步是获取 access_token。这个接口比较简单注意两点一是要缓存token7200秒的有效期没必要每次都请求二是token在并发下要保证只有一个线程在刷新否则容易互相覆盖导致接口报40014。public class WeWorkTokenService { private readonly HttpClient _http; private readonly string _corpid; private readonly string _secret; private string _token string.Empty; private DateTime _expireTime DateTime.MinValue; private readonly SemaphoreSlim _semaphore new(1, 1); public WeWorkTokenService(string corpid, string secret, HttpClient http) { _corpid corpid; _secret secret; _http http; } public async Taskstring GetTokenAsync() { if (!string.IsNullOrEmpty(_token) DateTime.Now _expireTime) return _token; await _semaphore.WaitAsync(); try { if (!string.IsNullOrEmpty(_token) DateTime.Now _expireTime) return _token; var url $https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid{_corpid}corpsecret{_secret}; var json await _http.GetStringAsync(url); var result JsonConvert.DeserializeObjectTokenResult(json); if (result.errcode ! 0) throw new Exception($获取token失败: {result.errcode} {result.errmsg}); _token result.access_token; _expireTime DateTime.Now.AddSeconds(result.expires_in - 300); // 提前5分钟过期 return _token; } finally { _semaphore.Release(); } } } public class TokenResult { public int errcode { get; set; } public string errmsg { get; set; } public string access_token { get; set; } public int expires_in { get; set; } }这里的300秒提前量是实战经验。token过期边界上刚好有一批消息拉取请求可能带着旧token过去提前刷新能少踩很多随机报错。4.2 SDK封装层接下来是官方SDK的P/Invoke封装。先看C头文件里比较关键的结构体和方法签名C#这边要做一一对应[StructLayout(LayoutKind.Sequential)] public struct Slice_t { public int len; public IntPtr buf; } public class WeWorkFinanceSdk { private const string DllName WeWorkFinanceSdk.dll; [DllImport(DllName, CallingConvention CallingConvention.Cdecl)] private static extern IntPtr NewSdk(); [DllImport(DllName, CallingConvention CallingConvention.Cdecl)] private static extern int Init(IntPtr sdk, string corpId, string secret); [DllImport(DllName, CallingConvention CallingConvention.Cdecl)] private static extern int GetChatData(IntPtr sdk, ulong seq, uint limit, string proxy, string passwd, int timeout, out Slice_t chatDatas); [DllImport(DllName, CallingConvention CallingConvention.Cdecl)] private static extern int DecryptData(IntPtr sdk, string encryptRandomKey, string encryptChatMsg, out Slice_t msg); [DllImport(DllName, CallingConvention CallingConvention.Cdecl)] private static extern void FreeSlice(IntPtr slice); }这里有个小细节GetChatData的timeout参数单位是毫秒我一开始传了秒导致接口每次都在短时间内返回超时错误后来翻C头文件注释才发现单位是毫秒。再有就是FreeSlice必须调用否则内存会一直涨。消息量大时一次拉取几百条数据每条都申请了非托管内存不及时释放会直接内存溢出。4.3 拉取会话数据并解密核心流程是拿着access_token调用REST接口拿到密文消息然后丢给SDK解密。我在项目里用一个WeWorkArchiveService来管理整个流程public class WeWorkArchiveService { private readonly WeWorkFinanceSdk _sdk; private readonly IntPtr _sdkHandle; private readonly WeWorkTokenService _tokenService; private readonly HttpClient _http; public WeWorkArchiveService(WeWorkTokenService tokenService, HttpClient http) { _tokenService tokenService; _http http; _sdk new WeWorkFinanceSdk(); _sdkHandle WeWorkFinanceSdk.NewSdk(); var initRet WeWorkFinanceSdk.Init(_sdkHandle, _corpid, _privateKey); if (initRet ! 0) throw new Exception($SDK初始化失败: {initRet}); } public async Task(ulong nextSeq, ListChatMessage messages) FetchChatDataAsync(ulong seq) { var token await _tokenService.GetTokenAsync(); var url $https://qyapi.weixin.qq.com/cgi-bin/msgaudit/getchatdata?access_token{token}; var requestBody new { seq seq, limit 1000, timeout 5000, type 0 }; var content new StringContent(JsonConvert.SerializeObject(requestBody), Encoding.UTF8, application/json); var response await _http.PostAsync(url, content); var responseJson await response.Content.ReadAsStringAsync(); var result JsonConvert.DeserializeObjectChatDataResult(responseJson); if (result.errcode ! 0) throw new Exception($拉取会话数据失败: {result.errcode} {result.errmsg}); var messages new ListChatMessage(); foreach (var item in result.data) { var decryptRet WeWorkFinanceSdk.DecryptData(_sdkHandle, item.encryptRandomKey, item.encryptChatMsg, out var rawMsg); if (decryptRet ! 0) continue; var plainText Marshal.PtrToStringUTF8(rawMsg.buf, rawMsg.len); WeWorkFinanceSdk.FreeSlice(rawMsg.buf); var chatMessage JsonConvert.DeserializeObjectChatMessage(plainText); chatMessage.seq item.seq; messages.Add(chatMessage); } return (result.next_seq, messages); } }拉取到的数据里seq是增量游标下一轮拉取请求要把它传回去。next_seq是服务端返回的下一个位置正常情况下next_seq应该等于当前批次最后一条的seq1。如果next_seq一直不变说明没有新数据。解密后的消息是JSON格式字段大致长这样{ msgid: 123456, action: send, from: {id: zhangsan}, tolist: [{id: lisi}], roomid: wrA1B2C3, msgtime: 1700000000, msgtype: text, text: {content: 你好这条消息会被存档} }常见的msgtype有text、image、voice、video、file、emoji、link、miniprogram等。文本消息直接取text.content图片语音视频这类媒体消息解密后的JSON里会有media_id和md5值还需要再调用一次SDK的GetMediaData方法把真正的文件内容拉下来。媒体文件的处理逻辑相对独立建议放到单独的服务里做不要在拉取主链路里做同步下载。5. 常见问题与排障心得5.1 典型错误码对照调试过程中一定会遇到各种错误码这里把自己踩过的整理成一张表错误码含义产生原因解决办法40001access_token无效token过期、被刷新、缓存并发问题检查token刷新逻辑加锁40014不合法的access_token同40001常见于并发刷新用信号量保证单线程刷新60001无权限访问该接口成员未配置存档范围、secret不对核对后台成员配置和secret60020访问ip不在白名单服务器出口IP未加入白名单把部署服务器公网IP加进白名单30005媒体文件下载失败文件已过期或media_id错误拉取后立即转存失败重试60001这个错误码最有迷惑性。它不光出现在成员范围没配好时如果企业微信后台更新了存档范围接口这边会有几分钟到十几分钟的延迟所以遇到60001先别急着改代码耐心等一会儿再试。5.2 序列推进与消息一致性seq是增量拉取的生命线但它并不保证严格连续。企业微信的文档里说一次拉取可能返回空列表也可能返回非连续的一段seq。所以不能简单认为“下一个seq等于当前seq1”必须使用服务端返回的next_seq。我第一版代码就拿当前seq1去发下一次请求结果出现消息空洞后来才发现应该直接信任next_seq并且在本地记录“已处理的最大seq”用这个值作为下一次拉取的起点。另一个容易忽略的问题是拉取到解密后消息本身有msgtime但你的本地记录应该以seq为准去做顺序控制不能拿msgtime排序。同一时间点可能有多条消息msgtime相同的情况太常见了拿它做唯一性判断一定会出问题。5.3 性能与稳定性优化存档服务一般会挂在后台持续运行性能问题要提前考虑。我的经验是拉取频率不用太高每30秒拉一次足够。limit建议设500或者1000单次拉太多反而容易触发接口超时。拉取和解密要分开。REST接口拉取是慢网络操作解密是CPU操作解密放线程池里并行处理但要注意SDK线程安全问题。我测试下来同一个SDK句柄并发调用DecryptData在Windows下偶尔会崩溃稳妥的做法是给解密操作加一个锁或者维护一个SDK句柄池。消息落库用批量插入不要一条一条插。解密后的JSON塞进数据库的text字段再额外做几张宽表存常用的查询字段比如发送人、接收人、消息类型、时间。检索要求不高的话直接上Elasticsearch也可以但需要考虑运维成本。再说一个亲测有效的细节GetChatData拉数据时如果中间有代理服务器需要把代理地址传给SDK。我们公司测试环境有网络隔离所有外部请求都要走代理一开始没传代理参数接口一直超时后来看了SDK文档把proxy参数传进去才通。最后一点存档服务要加监控告警。最简单的方式就是记录每次拉取时间、拉取条数、解密成功失败数如果连续几轮都拉不到数据或者解密失败率升高立刻报警。这个项目上线跑了一段时间后我们就靠告警抓到了一回私钥被运维同学不小心轮换导致解密全部失败的问题。会话存档这东西量一大、时间一长最怕的就是静默失败一旦中间断了几天数据补数据会非常痛苦提前做好监控比什么都重要。本文还有配套的精品资源点击获取
