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 应用程序中,需要将配置文件放在 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.api
或Wechat.api(:default)
则表示默认账号的 wechat api。 -
在 wechat 命令行中,通过增加可选参数
-a, [--account=ACCOUNT]
来表示使用其他账号,例如wechat users -a wx2
表示列举wx2
这个账号的粉丝列表
进一步的多账号支持参见 PR 150。
启用数据库微信配置之后,会生成如下数据表:
属性 | 类型 | 备注 |
---|---|---|
environment | 字串 | 必填。配置对应的运行环境,一般有:production 、development 、test 。比如 production 配置仅在生产环境有效。默认为 development 。 |
account | 字串 | 必填。自定义的微信账户名称。同一 environment 下,账户名称不允许重复。 |
enabled | 布尔 | 必填。配置是否生效。默认 true 。 |
appid | 字串 | 公众号 id ,此字段和 corpid 两者必填其一。 |
secret | 字串 | 公众号相关配置。当公众号 appid 存在时必填。 |
corpid | 字串 | 企业号 id。此字段和 appid 两者必填其一。 |
corpsecret | 字串 | 企业号相关配置。当企业号 corpid 存在时必填。 |
agentid | 整数 | 企业号相关配置。当企业号 corpid 存在时必填。 |
encrypt_mode | 布尔 | |
encoding_aes_key | 字串 | 当 encrypt_mode 为 true 时必填。 |
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 秒,可视情况配置。
Wechat 服务器有报道曾出现 RestClient::SSLCertificateNotVerified 错误,此时可以选择关闭 SSL 验证。skip_verify_ssl: true
有些情况下,单个 Rails 应用可能需要处理来自多个微信公众号的消息,您可以通过在 wechat_responder
和 wechat_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 可以在 HTML 网页中控制微信客户端的行为,但必须先注入配置信息. Wechat gem 提供了帮助方法 wechat_config_js
使这个过程更简单:
注意 wechat_config_js 指令依赖于 wechat_api
或 wechat_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 的权限签名。
公众号可使用如下代码取得关注用户的相关信息。
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 里定义show
和create
方法,否则会报错。 - 如果遇到 “ 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 全量覆盖部门只支持单个根节点作为部门,不支持平行多根节点。
以下是几种典型场景的使用方法
$ 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
在任意代码中访问 Wechat 的 API 功能,但是更推荐的做法是仅在 Controller 中,通过引入 wechat_api
,使用 wechat
调用 API 功能,不仅因为这样是支持多个微信公众平台账号的必然要求,而且也避免了在模型层内过多引入微信相关代码。
class WechatReportsController < ApplicationController
wechat_api
layout 'wechat'
def index
@lots = Lot.with_preloading.wip_lot
end
end
可以通过 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'
为了在 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
- 企业微信接受菜单消息时,Wechat 腾讯服务器无法解析部分域名,请使用 iP 绑定回调 URL,用户的普通消息目前不受影响。
- 企业微信全量覆盖成员使用的 CSV 通讯录格式,直接将下载的模板导入是不工作的,必须使用 Excel 打开,然后另存为 CSV 格式才会变成合法格式。
- 如果使用 Nginx + Unicron 部署方案,并且使用了 Https,必须设置
trusted_domain_fullname
为 Https,否则会导致 JS-SDK 签名失效。