logo
0
0
Login
Eric-Guo<eric.guocz@gmail.com>
Add badge of DeepWiki

WeChat Gem Version Build StatusAsk DeepWiki

Join the chat

WeChat Gem 帮助开发者方便地在 Rails 环境中集成微信公众平台企业微信小程序,包括功能:

  • 微信公众平台/企业微信发送消息 API(命令行和 Web 环境都可以使用)
  • 接收消息(必须运行 Web 服务器)
  • 微信 JS-SDK config 接口注入权限验证
  • OAuth 2.0 认证机制
  • 接收消息会话 ( Session ) 记录机制(可选)

命令行工具 wechat 可以调用各种无需 Web 环境的 API,同时也提供了 Rails Controller 的 Responder DSL 。可以帮助开发者方便地在 Rails 应用中集成微信的消息处理,包括主动推送的和被动响应的消息。

如果您的 App 还需要集成微信 OAuth2.0 除了简便的 wechat_oauth2 指令,也可以考虑 omniauth-wechat-oauth2 以便和 devise 集成提供完整的用户认证。

如果您对如何制作微信网页 UI 没有灵感,可以参考官方的 weui 。针对 Rails 的 Gem 是 weui-rails

主页型应用请使用 wechat_api,传统消息型应用请使用 wechat_responder

如果您想从一个稍微完整一些的示例开始微信开发,可以参考 wechat-starter,这个示例甚至包括了微信支付的内容。

安装

使用 gem install

gem install "wechat" # 如果使用 Ruby 版本小于 2.6 # gem install wechat -v 0.12.4

或者添加下面这行到 Gemfile:

gem 'wechat' # 如果使用 Rails 版本小于 6 # gem 'wechat', '~> 0.12.4'

运行下面这行代码来安装:

bundle install

运行下面这行代码来生成必要文件:

rails generate wechat:install

运行 rails g wechat:install 后会自动生成 wechat.yml 配置,还有 wechats_controller 及相关路由配置到当前 Rails 项目。

启用 Session 会话记录:

rails g wechat:session rake db:migrate

运行后会自动启用回调消息会话 (Session) 记录,wechat Gem 会在 Rails 项目中生成两个文件,用户可以在 wechat_session 表中添加更多字段或者声明一些关联关系。使用已有的 hash_store 直接保存也是可以的,但对于 PostgreSQL 用户,使用 hstore 或者 json 格式可能更佳,当然最佳方案仍然是添加新字段记录数据。

启用 Redis 存贮 Token 和 Ticket:

rails g wechat:redis_store

Redis 存贮相比默认的文件存贮,可以允许 Rails 应用运行在多台服务器中。如果只有一台服务器,仍然推荐使用默认的文件存贮,另外命令行不会读取 Redis 存贮的 Token 或者 Ticket。

启用数据库配置微信账户:

rails g wechat:config rake db:migrate

运行后会在数据库中创建 wechat_configs 表用来记录不同微信账户的配置。

配置

微信的第一次配置

请先确保在服务器上配置成功,再到微信官网提交链接。否则微信会提示错误。

默认通过 rails g wechat:install 生成的 URL 是: http://your-server.com/wechat

appid/corpid 以及 secret 的配置请阅读下一节

数据配置模式

需要保证传入的 record 属性中包含 access_token, token_expires_in, got_token_at

def client @client ||= Wechat::Api.new(app_id, app_secret, token_file, network_setting, jsapi_ticket_file, record) end

命令行程序的配置

要使用命令行程序,需要在 home 目录中创建一个 ~/.wechat.yml,包含以下内容。其中 access_token 是存放 access_token 的文件位置。

appid: "my_appid" secret: "my_secret" access_token: "/var/tmp/wechat_access_token"

Windows 或者使用企业号需要存放在 C:/Users/[user_name]/ 下,其中 corpid 和 corpsecret 可以从企业号管理界面的设置 -> 权限管理,通过新建任意一个管理组后获取。

corpid: "my_appid" corpsecret: "my_secret" agentid: 1 # 企业应用的 id 整型可在应用的设置页面查看 access_token: "C:/Users/[user_name]/wechat_access_token"

Rails 全局配置

Rails 应用程序中,需要将配置文件放在 config/wechat.yml,可以为不同 environment 创建不同的配置。

微信公众平台配置示例:

default: &default appid: "app_id" secret: "app_secret" token: "app_token" access_token: "/var/tmp/wechat_access_token" jsapi_ticket: "/var/tmp/wechat_jsapi_ticket" production: appid: <%= ENV['WECHAT_APPID'] %> secret: <%= ENV['WECHAT_APP_SECRET'] %> token: <%= ENV['WECHAT_TOKEN'] %> access_token: <%= ENV['WECHAT_ACCESS_TOKEN'] %> jsapi_ticket: <%= ENV['WECHAT_JSAPI_TICKET'] %> oauth2_cookie_duration: <%= ENV['WECHAT_OAUTH2_COOKIE_DURATION'] %> # seconds development: <<: *default trusted_domain_fullname: "http://your_dev.proxy.qqbrowser.cc" test: <<: *default

微信公众平台可选安全模式(加密模式),通过添加如下配置可开启加密模式。

default: &default encrypt_mode: true encoding_aes_key: "my_encoding_aes_key"

企业微信配置下必须使用加密模式,其中 token 和 encoding_aes_key 可以从企业号管理界面的应用中心 -> 某个应用 -> 模式选择,选择回调模式后获得。

default: &default corpid: "corpid" corpsecret: "corpsecret" agentid: 1 access_token: "C:/Users/[user_name]/wechat_access_token" token: "" encoding_aes_key: "" jsapi_ticket: "C:/Users/[user_name]/wechat_jsapi_ticket" production: corpid: <%= ENV['WECHAT_CORPID'] %> corpsecret: <%= ENV['WECHAT_CORPSECRET'] %> agentid: <%= ENV['WECHAT_AGENTID'] %> access_token: <%= ENV['WECHAT_ACCESS_TOKEN'] %> token: <%= ENV['WECHAT_TOKEN'] %> timeout: 30, skip_verify_ssl: true encoding_aes_key: <%= ENV['WECHAT_ENCODING_AES_KEY'] %> jsapi_ticket: <%= ENV['WECHAT_JSAPI_TICKET'] %> oauth2_cookie_duration: <%= ENV['WECHAT_OAUTH2_COOKIE_DURATION'] %> development: <<: *default trusted_domain_fullname: "http://your_dev.proxy.qqbrowser.cc" test: <<: *default # Multiple Accounts # # wx2_development: # <<: *default # appid: "my_appid" # secret: "my_secret" # access_token: "tmp/wechat_access_token2" # jsapi_ticket: "tmp/wechat_jsapi_ticket2" # # wx2_test: # <<: *default # appid: "my_appid" # secret: "my_secret" # # wx2_production: # <<: *default # appid: "my_appid" # secret: "my_secret"

支持微信公众平台 / 企业微信多账号的注意点 ( 例如:增加账号 wx2 ):

  • 配置文件可增加多个微信公众平台 ( 企业微信 ) 配置,用法类似 Rails 中 config/database.yml 多数据库配置的处理。 development, test, production 是默认账号的配置段,要想增加账号 wx2,你需要增加配置段 wx2_development, wx2_test, wx2_production

  • 声明账号 wx2 wechat_responder:

    wechat_responder account: :wx2
  • Wechat.api(:wx2) 表示使用账号 wx2 的 Wechat api,而 Wechat.apiWechat.api(:default) 则表示默认账号的 wechat api。

  • 在 wechat 命令行中,通过增加可选参数 -a, [--account=ACCOUNT] 来表示使用其他账号,例如 wechat users -a wx2 表示列举 wx2 这个账号的粉丝列表

进一步的多账号支持参见 PR 150

数据库微信账户配置

启用数据库微信配置之后,会生成如下数据表:

属性类型备注
environment字串必填。配置对应的运行环境,一般有:productiondevelopmenttest。比如 production 配置仅在生产环境有效。默认为 development
account字串必填。自定义的微信账户名称。同一 environment 下,账户名称不允许重复。
enabled布尔必填。配置是否生效。默认 true
account_type字串非必填。当前只支持mp,表示小程序。
appid字串公众号 id ,此字段和 corpid 两者必填其一。
secret字串公众号相关配置。当公众号 appid 存在时必填。
corpid字串企业号 id。此字段和 appid 两者必填其一。
corpsecret字串企业号相关配置。当企业号 corpid 存在时必填。
agentid整数企业号相关配置。当企业号 corpid 存在时必填。
encrypt_mode布尔
encoding_aes_key字串encrypt_modetrue 时必填。
token字串必填。
access_token字串必填。存储 access token 文件的路径。
jsapi_ticket字串必填。存储 jsapi ticket 文件的路径。
skip_verify_ssl布尔
timeout整数默认值是 20。
trusted_domain_fullname字串

数据库配置更新后,需要重启服务器或者调用 Wechat.reload_config! 载入更新,否则更新不会生效。

配置优先级

注意在 Rails 项目根目录下运行 wechat 命令行工具会优先使用 config/wechat.yml 中的 default配置,如果失败则使用 ~\.wechat.yml 中的配置,以便于在生产环境下管理多个微信账号应用。

如果启用数据库账户配置,数据库中的账户信息在读入 wechat.yml 或环境变量之后被载入。当存在同名账户时,数据库中的配置会覆盖前两者。

配置微信服务器超时

微信服务器有时请求会花很长时间,如果不配置默认为 20 秒,可视情况配置。

配置跳过 SSL 认证

Wechat 服务器有报道曾出现 RestClient::SSLCertificateNotVerified 错误,此时可以选择关闭 SSL 验证。skip_verify_ssl: true

为每个 Responder 配置不同的 appid 和 secret

有些情况下,单个 Rails 应用可能需要处理来自多个微信公众号的消息,您可以通过在 wechat_responderwechat_api 后配置多个相关参数来支持多账号。

class WechatFirstController < ActionController::Base wechat_responder account: :new_account, account_from_request: Proc.new{ |request| request.params[:wechat] } on :text, with:"help", respond: "help content" end

或者直接完整配置

class WechatFirstController < ActionController::Base wechat_responder appid: "app1", secret: "secret1", token: "token1", access_token: Rails.root.join("tmp/access_token1"), account_from_request: Proc.new{ |request| request.params[:wechat] } on :text, with:"help", respond: "help content" end

其中 account_from_request 是一个 Proc,接受 request 作为唯一参数,返回相应的微信账户名称。以上示例中,controller 会根据 request 中传入的 wechat 参数选择微信账户。如果没有提供 account_from_request 或者 Proc 的结果是 nil,则使用 account 或者完整配置。

JS-SDK 支持

通过 JS-SDK 可以在 HTML 网页中控制微信客户端的行为,但必须先注入配置信息. Wechat gem 提供了帮助方法 wechat_config_js 使这个过程更简单:

注意 wechat_config_js 指令依赖于 wechat_apiwechat_responder ,需要先在 controller 里面添加。

<body> <%= wechat_config_js debug: false, api: %w(hideMenuItems closeWindow) -%> <script type="application/javascript"> wx.ready(function() { wx.hideOptionMenu(); }); </script> <a href="javascript:wx.closeWindow();">Close</a> </body>

在开发模式下,由于程序往往通过微信调试工具的服务器端调试工具反向代理被访问,此时需要配置 trusted_domain_fullname 以便 wechat gem 可以使用正确的域名做 JS-SDK 的权限签名。

OAuth2.0 验证接口支持

公众号可使用如下代码取得关注用户的相关信息。

class CartController < ActionController::Base wechat_api def index wechat_oauth2 do |openid| @current_user = User.find_by(wechat_openid: openid) @articles = @current_user.articles end # 指定 account_name 可以使用任意微信账户 # wechat_oauth2('snsapi_base', nil, account_name) do |openid| # ... # end end end

企业微信可使用如下代码取得企业用户的相关信息。

class WechatsController < ActionController::Base layout 'wechat' wechat_responder def apply_new wechat_oauth2 do |userid| @current_user = User.find_by(wechat_userid: userid) @apply = Apply.new @apply.user_id = @current_user.id end end end

wechat_oauth2 封装了 OAuth2.0 验证接口和 Cookies 处理逻辑,用户仅需提供业务代码块即可。userid 指的是微信企业成员 userid,openid 是关注该公众号的用户 openid。

注意:

  • 如果使用 wechat_responder,请不要在 Controller 里定义 showcreate 方法,否则会报错。
  • 如果遇到 “ redirect_uri 参数错误” 的错误信息,请登录服务号管理后台,查看 “开发者中心/网页服务/网页授权获取用户基本信息” 的授权回调页面域名已正确配置。

关于接口权限

Wechat Gem 内部不会检查权限,但因公众号类型不同和微信服务器端通讯时,可能会被拒绝详细权限控制可参考官方文档

使用命令行

根据企业微信和微信公众平台配置不同 Wechat 提供了的命令行命令。

微信公众平台命令行

$ wechat Wechat Public Account commands: wechat addvoicetorecofortext [VOICE_ID] # AI 开放接口 - 提交语音 wechat callbackip # 获取微信服务器 iP 地址 wechat clear_quota # 接口调用次数清零 wechat custom_image [OPENID, IMAGE_PATH] # 发送图片客服消息 wechat custom_music [OPENID, THUMBNAIL_PATH, MUSIC_URL] # 发送音乐客服消息 wechat custom_news [OPENID, NEWS_YAML_PATH] # 发送图文客服消息 wechat custom_text [OPENID, TEXT_MESSAGE] # 发送文字客服消息 wechat custom_video [OPENID, VIDEO_PATH] # 发送视频客服消息 wechat custom_voice [OPENID, VOICE_PATH] # 发送语音客服消息 wechat customservice_getonlinekflist # 获取在线客服接待信息 wechat group_create [GROUP_NAME] # 创建分组 wechat group_delete [GROUP_ID] # 删除分组 wechat group_update [GROUP_ID, NEW_GROUP_NAME] # 修改分组名 wechat groups # 查询所有分组 wechat material_get [MEDIA_ID, PATH] # 永久媒体下载 wechat material_add [MEDIA_TYPE, PATH] # 永久媒体上传 wechat material_add_news [MPNEWS_YAML_PATH] # 永久图文素材上传 wechat material_count # 获取永久素材总数 wechat material_delete [MEDIA_ID] # 删除永久素材 wechat material_list [TYPE, OFFSET, COUNT] # 获取永久素材列表 wechat media [MEDIA_ID, PATH] # 媒体下载 wechat media_hq [MEDIA_ID, PATH] # 高清音频下载 wechat media_create [MEDIA_TYPE, PATH] # 媒体上传 wechat media_uploadimg [IMAGE_PATH] # 上传图文消息内的图片 wechat media_uploadnews [MPNEWS_YAML_PATH] # 上传图文消息素材 wechat menu # 当前菜单 wechat menu_addconditional [CONDITIONAL_MENU_YAML_PATH] # 创建个性化菜单 wechat menu_create [MENU_YAML_PATH] # 创建菜单 wechat menu_delconditional [MENU_ID] # 删除个性化菜单 wechat menu_delete # 删除菜单 wechat menu_trymatch [USER_ID] # 测试个性化菜单匹配结果 wechat message_mass_delete [MSG_ID] # 删除群发消息 wechat message_mass_get [MSG_ID] # 查询群发消息发送状态 wechat message_mass_preview [WX_NAME, MPNEWS_MEDIA_ID] # 预览图文消息素材 wechat qrcode_create_limit_scene [SCENE_ID_OR_STR] # 请求永久二维码 wechat qrcode_create_scene [SCENE_ID_OR_STR, EXPIRE_SECONDS] # 请求临时二维码 wechat qrcode_download [TICKET, QR_CODE_PIC_PATH] # 通过 ticket 下载二维码 wechat queryrecoresultfortext [VOICE_ID] # AI 开放接口 - 获取语音识别结果 wechat shorturl [LONG_URL] # 长链接转短链接 wechat tag [TAGID] # 获取标签下粉丝列表 wechat tag_add_user [TAG_ID, OPEN_IDS] # 批量为用户打标签 wechat tag_create [TAGNAME, TAG_ID] # 创建标签 wechat tag_del_user [TAG_ID, OPEN_IDS] # 批量为用户取消标签 wechat tag_delete [TAG_ID] # 删除标签 wechat tag_update [TAG_ID, TAGNAME] # 更新标签名字 wechat tags # 获取所有标签 wechat template_message [OPENID, TEMPLATE_YAML_PATH] # 模板消息接口 wechat translatecontent [CONTENT] # AI 开放接口 - 微信翻译 wechat user [OPEN_ID] # 获取用户基本信息 wechat user_batchget [OPEN_ID_LIST] # 批量获取用户基本信息 wechat user_change_group [OPEN_ID, TO_GROUP_ID] # 移动用户分组 wechat user_group [OPEN_ID] # 查询用户所在分组 wechat user_update_remark [OPEN_ID, REMARK] # 设置备注名 wechat users # 关注者列表 wechat wxa_msg_sec_check [CONTENT] # 检查一段文本是否含有违法违规内容。 wechat wxacode_download [WXA_CODE_PIC_PATH, PATH, WIDTH] # 下载小程序码

企业微信命令行

$ wechat Wechat Enterprise Account commands: wechat agent [AGENT_ID] # 获取企业号应用详情 wechat agent_list # 获取应用概况列表 wechat batch_job_result [JOB_ID] # 获取异步任务结果 wechat batch_replaceparty [BATCH_PARTY_CSV_MEDIA_ID] # 全量覆盖部门 wechat batch_replaceuser [BATCH_USER_CSV_MEDIA_ID] # 全量覆盖成员 wechat batch_syncuser [SYNC_USER_CSV_MEDIA_ID] # 增量更新成员 wechat callbackip # 获取微信服务器 iP 地址 wechat clear_quota # 接口调用次数清零 wechat convert_to_openid [USER_ID] # userid 转换成 openid wechat convert_to_userid [OPENID] # openid 转换成 userid wechat custom_image [OPENID, IMAGE_PATH] # 发送图片客服消息 wechat custom_music [OPENID, THUMBNAIL_PATH, MUSIC_URL] # 发送音乐客服消息 wechat custom_news [OPENID, NEWS_YAML_PATH] # 发送图文客服消息 wechat custom_text [OPENID, TEXT_MESSAGE] # 发送文字客服消息 wechat custom_video [OPENID, VIDEO_PATH] # 发送视频客服消息 wechat custom_voice [OPENID, VOICE_PATH] # 发送语音客服消息 wechat department [DEPARTMENT_ID] # 获取部门列表 wechat department_create [NAME, PARENT_ID] # 创建部门 wechat department_delete [DEPARTMENT_ID] # 删除部门 wechat department_update [DEPARTMENT_ID, NAME] # 更新部门 wechat getusercumulate [BEGIN_DATE, END_DATE] # 获取累计用户数据 wechat getusersummary [BEGIN_DATE, END_DATE] # 获取用户增减数据 wechat invite_user [USER_ID] # 邀请成员关注 wechat material [MEDIA_ID, PATH] # 永久媒体下载 wechat material_add [MEDIA_TYPE, PATH] # 永久媒体上传 wechat material_count # 获取永久素材总数 wechat material_delete [MEDIA_ID] # 删除永久素材 wechat material_list [TYPE, OFFSET, COUNT] # 获取永久素材列表 wechat media [MEDIA_ID, PATH] # 媒体下载 wechat media_create [MEDIA_TYPE, PATH] # 媒体上传 wechat media_hq [MEDIA_ID, PATH] # 高清音频媒体下载 wechat media_uploadimg [IMAGE_PATH] # 上传图文消息内的图片 wechat menu # 当前菜单 wechat menu_addconditional [CONDITIONAL_MENU_YAML_PATH] # 创建个性化菜单 wechat menu_create [MENU_YAML_PATH] # 创建菜单 wechat menu_delconditional [MENU_ID] # 删除个性化菜单 wechat menu_delete # 删除菜单 wechat menu_trymatch [USER_ID] # 测试个性化菜单匹配结果 wechat message_send [OPENID, TEXT_MESSAGE] # 发送文字消息 wechat qrcode_download [TICKET, QR_CODE_PIC_PATH] # 通过 ticket 下载二维码 wechat tag [TAG_ID] # 获取标签成员 wechat tag_add_department [TAG_ID, PARTY_IDS] # 增加标签部门 wechat tag_add_user [TAG_ID, USER_IDS] # 增加标签成员 wechat tag_create [TAGNAME, TAG_ID] # 创建标签 wechat tag_del_department [TAG_ID, PARTY_IDS] # 删除标签部门 wechat tag_del_user [TAG_ID, USER_IDS] # 删除标签成员 wechat tag_delete [TAG_ID] # 删除标签 wechat tag_update [TAG_ID, TAGNAME] # 更新标签名字 wechat tags # 获取所有标签 wechat template_message [OPENID, TEMPLATE_YAML_PATH] # 模板消息接口 wechat upload_replaceparty [BATCH_PARTY_CSV_PATH] # 上传文件方式全量覆盖部门 wechat upload_replaceuser [BATCH_USER_CSV_PATH] # 上传文件方式全量覆盖成员 wechat user [OPEN_ID] # 获取用户基本信息 wechat user_batchdelete [USER_ID_LIST] # 批量删除成员 wechat user_create [USER_ID, NAME] # 创建成员 wechat user_delete [USER_ID] # 删除成员 wechat user_list [DEPARTMENT_ID] # 获取部门成员详情 wechat user_simplelist [DEPARTMENT_ID] # 获取部门成员 wechat user_update_remark [OPEN_ID, REMARK] # 设置备注名

注意:replaceparty 全量覆盖部门只支持单个根节点作为部门,不支持平行多根节点。

使用场景

以下是几种典型场景的使用方法

获取所有用户的 openid
$ wechat users {"total"=>4, "count"=>4, "data"=>{"openid"=>["oCfEht9***********", "oCfEhtwqa***********", "oCfEht9oMCqGo***********", "oCfEht_81H5o2***********"]}, "next_openid"=>"oCfEht_81H5o2***********"}
获取用户的信息
$ wechat user "oCfEht9***********" {"subscribe"=>1, "openid"=>"oCfEht9***********", "nickname"=>"Nickname", "sex"=>1, "language"=>"zh_CN", "city"=>"徐汇", "province"=>"上海", "country"=>"中国", "headimgurl"=>"http://wx.qlogo.cn/mmopen/ajNVdqHZLLBd0SG8NjV3UpXZuiaGGPDcaKHebTKiaTyof*********/0", "subscribe_time"=>1395715239}
获取当前菜单
$ wechat menu {"menu"=>{"button"=>[{"type"=>"view", "name"=>"保护的", "url"=>"http://***/protected", "sub_button"=>[]}, {"type"=>"view", "name"=>"公开的", "url"=>"http://***", "sub_button"=>[]}]}}
创建菜单

通过运行rails g wechat:menu可以生成一个定义菜单内容的 yaml 文件菜单可以包含下列内容:

button: - name: "我要" sub_button: - type: "scancode_waitmsg" name: "绑定用餐二维码" key: "BINDING_QR_CODE" - type: "click" name: "预订午餐" key: "BOOK_LUNCH" - type: "miniprogram" name: "小程序示例" url: "http://ericguo.com/" appid: "wx1234567890" pagepath: "pages/index" - name: "查询" sub_button: - type: "click" name: "进出记录" key: "BADGE_IN_OUT" - type: "click" name: "年假余额" key: "ANNUAL_LEAVE" - type: "view" name: "关于" url: "http://blog.cloud-mes.com/"

下列命令行将上传自定义菜单:

$ wechat menu_create menu.yaml

需确保设置,权限管理中有对此应用的管理权限,否则会报 60011 错。

发送客服图文消息

需定义一个图文消息内容的 yaml 文件,比如 articles.yaml

articles: - title: "习近平在布鲁日欧洲学院演讲" description: "新华网比利时布鲁日 4 月 1 日电 国家主席习近平 1 日在比利时布鲁日欧洲学院发表重要演讲" url: "http://news.sina.com.cn/c/2014-04-01/232629843387.shtml" pic_url: "http://i3.sinaimg.cn/dy/c/2014-04-01/1396366518_bYays1.jpg"

然后执行命令行

$ wechat custom_news oCfEht9oM*********** articles.yml
发送模板消息

需定义一个模板消息内容的 yaml 文件,比如 template.yml

template: template_id: "o64KQ62_xxxxxxxxxxxxxxx-Qz-MlNcRKteq8" url: "http://weixin.qq.com/download" topcolor: "#FF0000" data: first: value: "您好,您已报名成功" color: "#0A0A0A" keynote1: value: "XX 活动" color: "#CCCCCC" keynote2: value: "2014 年 9 月 16 日" color: "#CCCCCC" keynote3: value: "上海徐家汇 xxx 城" color: "#CCCCCC" remark: value: "欢迎再次使用。" color: "#173177"

然后执行命令行

$ wechat template_message oCfEht9oM*********** template.yml

在代码中可以这样使用:

template = YAML.load(File.read(template_yaml_path)) Wechat.api.template_message_send Wechat::Message.to(openid).template(template['template'])

若在 Controller 中使用 wechat_api 或者 wechat_responder,可以使用 wechat:

template = YAML.load(File.read(template_yaml_path)) wechat.template_message_send Wechat::Message.to(openid).template(template['template'])

wechat_api - Rails Controller Wechat API

虽然用户可以随时通过 Wechat.api 在任意代码中访问 Wechat 的 API 功能,但是更推荐的做法是仅在 Controller 中,通过引入 wechat_api,使用 wechat 调用 API 功能,不仅因为这样是支持多个微信公众平台账号的必然要求,而且也避免了在模型层内过多引入微信相关代码。

class WechatReportsController < ApplicationController wechat_api layout 'wechat' def index @lots = Lot.with_preloading.wip_lot end end

在 ActiveJob/Rake tasks 中调用有 wechat api

可以通过 Wechat.api 在任意地方使用 Wechat Api 的功能。

下面以通过 rails console 调用微信 Ai 开放接口的语音识别为例:

# Audio file with ID3 version 2.4.0, contains:MPEG ADTS, layer III, v2, 40 kbps, 16 kHz, Monaural test_voice_file='test_voice.mp3' Wechat.api.addvoicetorecofortext('test_voice_id', File.open(test_voice_file)) Wechat.api.queryrecoresultfortext 'test_voice_id'

wechat_responder - Rails Responder Controller DSL

为了在 Rails App 中响应用户的消息,开发者需要创建一个 wechat responder Controller 首先在 Router 中定义

resource :wechat, only:[:show, :create]

然后创建 Controller Class 例如

class WechatsController < ActionController::Base wechat_responder # 默认文字信息 responder on :text do |request, content| request.reply.text "echo: #{content}" #Just echo end # 当请求的文字信息内容为 'help' 时,使用这个 responder 处理 on :text, with: 'help' do |request| request.reply.text 'help content' #回复帮助信息 end # 当请求的文字信息内容为'<n>条新闻'时,使用这个 responder 处理,并将 n 作为第二个参数 on :text, with: /^(\d+) 条新闻$/ do |request, count| # 微信最多显示 8 条新闻,大于 8 条将只取前 8 条 news = (1..count.to_i).each_with_object([]) { |n, memo| memo << { title: '新闻标题', content: "第#{n}条新闻的内容#{n.hash}" } } request.reply.news(news) do |article, n, index| # 回复"articles" article.item title: "#{index} #{n[:title]}", description: n[:content], pic_url: 'http://www.baidu.com/img/bdlogo.gif', url: 'http://www.baidu.com/' end end # 当用户加关注 on :event, with: 'subscribe' do |request| request.reply.text "User #{request[:FromUserName]} subscribe now" end # 公众平台收到未关注用户扫描 qrscene_xxxxxx 二维码时。注意此次扫描事件将不再引发上条的用户加关注事件 on :scan, with: 'qrscene_xxxxxx' do |request, ticket| request.reply.text "Unsubscribe user #{request[:FromUserName]} Ticket #{ticket}" end # 公众平台收到已关注用户扫描创建二维码的 scene_id 事件时 on :scan, with: 'scene_id' do |request, ticket| request.reply.text "Subscribe user #{request[:FromUserName]} Ticket #{ticket}" end # 当没有任何 on :scan 事件处理已关注用户扫描的 scene_id 时 on :event, with: 'scan' do |request| if request[:EventKey].present? request.reply.text "event scan got EventKey #{request[:EventKey]} Ticket #{request[:Ticket]}" end end # 企业微信收到 EventKey 为二维码扫描结果事件时 on :scan, with: 'BINDING_QR_CODE' do |request, scan_result, scan_type| request.reply.text "User #{request[:FromUserName]} ScanResult #{scan_result} ScanType #{scan_type}" end # 企业微信收到 EventKey 为 CODE 39 码扫描结果事件时 on :scan, with: 'BINDING_BARCODE' do |message, scan_result| if scan_result.start_with? 'CODE_39,' message.reply.text "User: #{message[:FromUserName]} scan barcode, result is #{scan_result.split(',')[1]}" end end # 当用户点击菜单时 on :click, with: 'BOOK_LUNCH' do |request, key| request.reply.text "User: #{request[:FromUserName]} click #{key}" end # 当用户点击菜单时 on :view, with: 'http://wechat.somewhere.com/view_url' do |request, view| request.reply.text "#{request[:FromUserName]} view #{view}" end # 处理图片信息 on :image do |request| request.reply.image(request[:MediaId]) #直接将图片返回给用户 end # 处理语音信息 on :voice do |request| # 直接语音音返回给用户 # request.reply.voice(request[:MediaId]) voice_id = request[:MediaId] # 开通语音识别后,用户每次发送语音给服务号时,微信会在推送的语音消息 XML 数据包中,增加一个 Recognition 字段 recognition = request[:Recognition] request.reply.text "#{voice_id} #{recognition}" end # 处理视频信息 on :video do |request| nickname = wechat.user(request[:FromUserName])['nickname'] #调用 api 获得发送者的 nickname request.reply.video(request[:MediaId], title: '回声', description: "#{nickname}发来的视频请求") #直接视频返回给用户 end # 处理地理位置消息 on :label_location do |request| request.reply.text("Label: #{request[:Label]} Location_X: #{request[:Location_X]} Location_Y: #{request[:Location_Y]} Scale: #{request[:Scale]}") end # 处理上报地理位置事件 on :location do |request| request.reply.text("Latitude: #{request[:Latitude]} Longitude: #{request[:Longitude]} Precision: #{request[:Precision]}") end # 当用户取消关注订阅 on :event, with: 'unsubscribe' do |request| request.reply.success # user can not receive this message end # 成员进入应用的事件推送 on :event, with: 'enter_agent' do |request| request.reply.text "#{request[:FromUserName]} enter agent app now" end # 当异步任务增量更新成员完成时推送 on :batch_job, with: 'sync_user' do |request, batch_job| request.reply.text "job #{batch_job[:JobId]} finished, return code #{batch_job[:ErrCode]}, return message #{batch_job[:ErrMsg]}" end # 当异步任务全量覆盖成员完成时推送 on :batch_job, with: 'replace_user' do |request, batch_job| request.reply.text "job #{batch_job[:JobId]} finished, return code #{batch_job[:ErrCode]}, return message #{batch_job[:ErrMsg]}" end # 当异步任务邀请成员关注完成时推送 on :batch_job, with: 'invite_user' do |request, batch_job| request.reply.text "job #{batch_job[:JobId]} finished, return code #{batch_job[:ErrCode]}, return message #{batch_job[:ErrMsg]}" end # 当异步任务全量覆盖部门完成时推送 on :batch_job, with: 'replace_party' do |request, batch_job| request.reply.text "job #{batch_job[:JobId]} finished, return code #{batch_job[:ErrCode]}, return message #{batch_job[:ErrMsg]}" end # 事件推送群发结果 on :event, with: 'masssendjobfinish' do |request| # https://mp.weixin.qq.com/wiki?action=doc&id=mp1481187827_i0l21&t=0.03571905015619936#8 request.reply.success # request is XML result hash. end # 客户同意进行聊天内容存档事件回调 on :change_external_contact do |request| # https://open.work.weixin.qq.com/api/doc/90000/90135/92005 request.reply.success # request is XML result hash. end # 会话事件回调 on :msgaudit_notify do |request| # https://open.work.weixin.qq.com/api/doc/90000/90135/95039 request.reply.success # request is XML result hash. end # 当无任何 responder 处理用户信息时,使用这个 responder 处理 on :fallback, respond: 'fallback message' end

在 controller 中使用 wechat_responder 引入 Responder DSL,之后可以用

on <message_type> do |message| message.reply.text "some text" end

来响应用户信息。

目前支持的 message_type 有如下几种

  • :text 响应文字消息,可以用 :with 参数来匹配文本内容 on(:text, with:'help'){|message, content| ...}
  • :image 响应图片消息
  • :voice 响应语音消息
  • :shortvideo 响应短视频消息
  • :video 响应视频消息
  • :label_location 响应地理位置消息
  • :link 响应链接消息
  • :event 响应事件消息,可以用 :with 参数来匹配事件类型,同文字消息类似,支持正则表达式匹配
  • :click 虚拟响应事件消息,微信传入:event,但 gem 内部会单独处理
  • :view 虚拟响应事件消息,微信传入:event,但 gem 内部会单独处理
  • :scan 虚拟响应事件消息
  • :batch_job 虚拟响应事件消息
  • :location 虚拟响应上报地理位置事件消息
  • :fallback 默认响应,当收到的消息无法被其他 responder 响应时,会使用这个 responder.

多客服消息转发

class WechatsController < ActionController::Base # 当无任何 responder 处理用户信息时,转发至客服处理。 on :fallback do |message| message.reply.transfer_customer_service end end

注意设置了多客服消息转发后,不能再添加默认文字信息 responder,否则文字消息将得不到转发。

无法处理给一个默认回答,一周内不要重复

class WechatsController < ActionController::Base on :fallback do |message| Rails.logger.debug "YouApp_ToUserName: #{message.message_hash["FromUserName"]}" session = WechatSession.find_by openid: message.message_hash["FromUserName"] return message.reply.success if session.present? && session.greating_time.present? && session.greating_time >= 1.week.ago images_path = Rails.root.join("public", "images", "default_help.jpg") media_id = Wechat.api.media_create("image", images_path)["media_id"] if session.present? && session.reload # generate migration: add_column :wechat_sessions, :greating_time, :datetime session.update(greating_time: Time.current) end message.reply.image(media_id) end end

通知

现支持以下通知:

  • wechat.responder.after_create data 包含 request Wechat::Message 和 responseWechat::Message

使用示例:

ActiveSupport::Notifications.subscribe('wechat.responder.after_create') do |name, started, finished, unique_id, data| WechatLog.create request: data[:request], response: data[:response] end

已知问题

  • 企业微信全量覆盖成员使用的 CSV 通讯录格式,直接将下载的模板导入是不工作的,必须使用 Excel 打开,然后另存为 CSV 格式才会变成合法格式。
  • 在开发模式上使用外部反响代理 https 回调,可能需要设置 trusted_domain_fullname 为 https,否则会导致 JS-SDK 签名失效。