Skip to content

Latest commit

 

History

History
813 lines (640 loc) · 34.1 KB

README-CN.md

File metadata and controls

813 lines (640 loc) · 34.1 KB

WeChat Gem Version Build Status Maintainability Test Coverage

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"

或者添加下面这行到 Gemfile:

gem 'wechat'

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

bundle install

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

rails generate wechat:install

运行rails g wechat:install后会自动生成wechat.yml配置,还有wechat 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的配置请阅读下一节

命令行程序的配置

要使用命令行程序,需要在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"

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

数据库微信账户配置

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

属性 类型 备注
environment 字串 必填。配置对应的运行环境,一般有:productiondevelopmenttest。比如 production 配置仅在生产环境有效。默认为 development
account 字串 必填。自定义的微信账户名称。同一 environment 下,账户名称不允许重复。
enabled 布尔 必填。配置是否生效。默认 true
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 gems提供了帮助方法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验证接口和cookie处理逻辑,用户仅需提供业务代码块即可。userid指的是微信企业成员UserID,openid是关注该公众号的用户openid。

注意:

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

关于接口权限

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

使用命令行

根据企业号和公众号配置不同,wechat提供了的命令行命令。

公众号命令行

$ wechat
Wechat Public Account commands:
  wechat callbackip                                             # 获取微信服务器IP地址
  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 [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_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 short_url [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 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 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 convert_to_openid [USER_ID]                            # userid转换成openid
  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 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_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]                   # 设置备注名

使用场景

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

#####获取所有用户的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: "click"
    name: "预订晚餐"
    key:  "BOOK_DINNER"
 -
  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的功能。

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]) #直接语音音返回给用户
  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

  # 当无任何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,否则文字消息将得不到转发。

通知

现支持以下通知:

  • wechat.responder.after_create data 包含 requestWechat::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签名失效。