Workweixin Save

企业微信 Go SDK

官方接口文档->

Go语言实现企业微信sdk，a sensible Work Weixin SDK for Go。

以第三方服务商维度整理的sdk，集成了第三方应用sdk和自建应用代开发的sdk，支持一键生成新sdk代码，使用简单，扩展灵活。

• 支持一键生成sdk代码，包括api和回调事件
• 用缓存方案实现分布式 access_token/jsapi_ticket，保证在多个服务中只有一个服务能成功调用企微API请求 access_token/jsapi_ticket，减少API调用次数和服务重启需要重新获取的情况
  • 缓存方案支持自定义存储，默认内存存储
  • 默认缓存2小时，主动式触发获取，企业取消授权后支持缓存清理
• 用缓存方案实现读取/更新suite_ticket，保证多个服务能读取到最新的suite_ticket（suite_ticket每十分钟更新一次）
  • 缓存方案支持自定义存储，默认内存存储
• 支持自定义日志存储，提供Logger interface：用于自行实现日志记录器，便于收集日志
  • 默认 log.Printf 输出
• 获取授权企业ApiClient时，支持自定义闭包从数据库等读取企业数据，eg: Sdk.GetThirdAuthCorpApiClient

点击查看企业微信第三方应用开发博文

安装命令

go get github.com/zsmhub/workweixin

一键生成sdk代码命令(需手动格式化代码)

• 生成企微回调事件代码

  make callback doc=企微文档链接 [prefix=生成文件名前缀]
  
  # example
  make callback doc=https://developer.work.weixin.qq.com/document/path/92277 prefix=客户联系
  

  tip：如果发现callbacks/callback_constant.go没有这个回调事件的常量定义，则需手动补上

• 生成企微api代码

  make api doc=企微文档链接 [prefix=生成文件名前缀]
  
  # example
  make api doc=https://developer.work.weixin.qq.com/document/path/90600 prefix=应用授权
  

  tip：

  1. 生成GET方式的接口，请求参数的数据类型需要手动调整下
  2. 部分接口文档的请求/响应 json 示例，如果缺少部分字段，需手动补上
  3. 部分复杂的页面需要手动整理下sdk，如消息推送>发送应用消息接口。

sdk调用示例

强烈建议去 ./demo 文件夹查看完整示例！

点击查看完整demo

企微回调事件sdk调用示例

// 企微回调设置初始化
func InitCallbackHandler() error {
    // 服务商回调解析
    if err := workweixin.Sdk.NewProviderCallbackHandler(config.CorpCallbackToken, config.CorpCallbackEncodingAESKey); err != nil {
        return err
    }

    // 第三方应用回调解析【可选】
    if err := workweixin.Sdk.NewThirdAppCallbackHandler(config.AppSuiteCallbackToken, config.AppSuiteCallbackEncodingAESKey); err != nil {
        return err
    }

    // 第三方小程序回调解析【可选】
    if err := workweixin.Sdk.NewMiniSuiteCaNewThirdMiniCallbackHandlerllbackHandler(config.MiniSuiteCallbackToken, config.MiniSuiteCallbackEncodingAESKey); err != nil {
        return err
    }

    // 自建应用代开发回调解析【可选】
    if err := workweixin.Sdk.NewCustomizedTemplateCallbackHandler(config.CustomizedCallbackToken, config.CustomizedCallbackEncodingAESKey); err != nil {
        return err
    }

    return nil
}

// 服务商-解析并获取回调信息
workweixin.Sdk.ProviderCallback.GetCallBackMsg(r *http.Request)

// 第三方应用-解析并获取回调信息
workweixin.Sdk.ThirdAppCallback.GetCallBackMsg(r *http.Request)

// 第三方小程序-解析并获取回调信息
workweixin.Sdk.ThirdMiniCallback.GetCallBackMsg(r *http.Request)

// 自建应用代开发--解析并获取回调信息
workweixin.Sdk.CustomizedTemplateCallback.GetCallBackMsg(r *http.Request)

// 第三方应用回调完整示例
func HandleAppPostRequest(c echo.Context) error {
    msg, err := workweixin.Sdk.ThirdAppCallback.GetCallBackMsg(c.Request())
    if err != nil {
        return err
    }

    switch msg.MsgType {
    case callbacks.MessageTypeThird: // 第三方应用回调
        switch msg.EventType {
            // 推送suite_ticket，每十分钟推送一次suite_ticket
            case callbacks.InfoTypeSuiteTicket:
                extras, ok := msg.Extras.(callbacks.ThirdSuiteTicket)
                if !ok {
                    return errors.New("suite_ticket get failed")
                }

                ticket := extras.SuiteTicket.Text
                workweixin.Sdk.ThirdAppClient.RefreshSuiteTicket(ticket, time.Hour)

                // todo: 此处可将 suite_ticket 保存进数据库

            // 企业取消授权通知
            case callbacks.InfoTypeCancelAuth:
                  workweixin.Sdk.RemoveThirdAuthCorp(corpId)
        }
    }

    return nil
}

企微 api sdk 调用示例

import "xxx/workweixin/demo"

// 企微API客户端初始化
func InitApiHandler() error {
    // 初始化企微sdk参数
    workweixin.Sdk.InitOptions(apis.Options{
        DcsToken:                     demo.DcsTokenByRedis{},
        DcsAppSuiteTicket:            demo.DcsAppSuiteTicketByRedis{},
        GetThirdAppAuthCorpFunc:      demo.GetThirdAppAuthCorpToSdk,
        GetCustomizedAppAuthCorpFunc: demo.GetCustomizedAppAuthCorpToSdk,
        Logger:                       demo.Logger{},
    })

    // 服务商API客户端初始化
    workweixin.Sdk.NewProviderApiClient(config.CorpId, config.CorpProviderSecret)

    // 第三方应用API客户端初始化【可选】
    suiteTicket := dao.ConfigDao.GetByUniqueIndex(global.ConfigKeySuiteTicket)
    workweixin.Sdk.NewThirdAppApiClient(config.CorpId, config.AppSuiteId, config.AppSuiteSecret, suiteTicket.V)

    // 自建应用代开发API客户端初始化【可选】
    customizedTicket := dao.ConfigDao.GetByUniqueIndex(global.ConfigKeyCustomizedTicket)
    workweixin.Sdk.NewCustomizedApiClient(config.CorpId, config.CustomizedAppSuiteId, config.CustomizedAppSuiteSecret, customizedTicket.V)

    // 由于本地开发环境和预发布无法接收企微回调事件，故需定时刷新suite_ticket
    if config.IsLocal() || config.IsUat() {
        go func(suiteTicket, customizedTicket model.Config) {
            defer recover()
            ticker := time.NewTicker(10 * time.Minute)
            defer ticker.Stop()
            for {
                // 更新第三方应用ticket
                _ = suiteTicket.DelCache() // 清除本地缓存
                suiteTicket = dao.ConfigDao.GetByUniqueIndex(global.ConfigKeySuiteTicket)
                workweixin.Sdk.ThirdAppClient.RefreshSuiteTicket(suiteTicket.V, 30*time.Minute)

                // 更新自建应用代开发ticket
                _ = customizedTicket.DelCache() // 清除本地缓存
                customizedTicket = dao.ConfigDao.GetByUniqueIndex(global.ConfigKeyCustomizedTicket)
                workweixin.Sdk.CustomizedAppClient.RefreshSuiteTicket(customizedTicket.V, 30*time.Minute)

                <-ticker.C
            }
        }(suiteTicket, customizedTicket)
    }

    return nil
}

// 服务商级别API调用接口示例：获取接口调用许可订单详情
orderDetail, err := workweixin.Sdk.ProviderClient.ExecGetOrderLicense(apis.ReqGetOrderLicense{OrderID: orderId})

// 应用级别API调用接口示例：获取企业永久授权码
resp, err := workweixin.Sdk.ThirdAppClient.ExecGetPermanentCodeService(apis.ReqGetPermanentCodeService{AuthCode: authCode})

// 授权企业级别API调用接口示例：获取部门列表
apiClient, err := workweixin.Sdk.GetThirdAuthCorpApiClient(v.CorpId)
if err != nil {
    fmt.Println(err)
}
department, err := apiClient.ExecListDepartment(apis.ReqListDepartment{})

// 获取provider_access_token
accessToken, err := workweixin.Sdk.ProviderClient.GetToken()

// 获取suite_access_token
accessToken, err := workweixin.Sdk.ThirdAppClient.GetToken()

// 获取授权企业access_token
accessToken, err := apiClient.GetToken()

// 构造oauth2链接
oauthUrl := workweixin.Sdk.ThirdAppClient.GetThirdOauthUrl(apis.GetThirdOauthUrlReq{
    RedirectUri: "xxx",
    Scope:       "xx",
    State:       "xx",
})

// 企微 error code 类型强制转换
if err != nil {
    if apiError, ok := err.(*apis.ClientError); ok && apiError.Code == apis.ErrCode60011 {
        return errors.New("无权限访问")
    }
    return nil, err
}

// 推送消息到第三方应用
reqSentMessageCard := apis.ReqSentMessageCard{
    ToUser:  v.InstallUserId,
    MsgType: "news",
    AgentId: v.AgentId,
    News: apis.ReqSentMessageCardNewsBody{
        Articles: []apis.ReqSentMessageCardNewsArticleBody{
            {
                Title:       "新模块【xxx】已上线",
                Description: "快进入【管理后台】把它配置到你的【侧边栏】中！",
                Url:         "https://xxx",
                UrlImg:      "https://xxx/workbench-config.jpg",
            },
        },
    },
}
if _, err = apiClient.ExecSentMessageCard(reqSentMessageCard); err != nil {
    fmt.Println(err)
}

// 帮前端获取 wx.config/wx.agentConfig 的签名配置
// 步骤1：获取授权企业的jsapi_ticket，wx.config注入的是企业的身份与权限，而wx.agentConfig注入的是应用的身份与权限
// 步骤2：JS-SDK使用权限签名算法
type QyapiGetJssdkConfigResp struct {
    CorpJsapiTicket apis.GetJsSdkSignResp `json:"corp_jsapi_ticket"`
    AppJsapiTicket  apis.GetJsSdkSignResp `json:"app_jsapi_ticket"`
}
func (qyapiRepo) GetJssdkConfig(req form.QyapiGetJssdkConfigReq) (*QyapiGetJssdkConfigResp, error) {
    apiClient, err := workweixin.Sdk.GetThirdAuthCorpApiClient(req.CorpId)
    if err != nil {
        return nil, err
    }

    corpTicket, err := apiClient.GetJSAPITicket()
    if err != nil {
        return nil, err
    }

    appTicket, err := apiClient.GetJSAPITicketAgentConfig()
    if err != nil {
        return nil, err
    }

    agentId := apiClient.AgentId
    return &QyapiGetJssdkConfigResp{
        CorpJsapiTicket: apiClient.GetJsSdkSign(req.CorpId, req.Url, corpTicket, 0),
        AppJsapiTicket:  apiClient.GetJsSdkSign(req.CorpId, req.Url, appTicket, agentId),
    }, nil
}

目录结构

.
├── api_generate             一键生成企微API代码
├── apis                     企业微信API整合
│   └── api.error.go         全局错误码
├── callback_generate        一键生成企微回调事件代码
├── callbacks                企业微信回调事件整合
│   └── callback_constant.go 回调事件常量定义
├── demo                     sdk调用示例
├── docs                     企业微信相关文档
├── internal                 消息加解密库
└── main.go                  入口文件

注意点

• 如果你发现了sdk中，没有某个回调事件或某个api，可以使用一键生成sdk代码命令生成，然后提交下pr

推荐开源项目

• 企业微信 GO SDK
• 抖店开放平台 GO SDK
• 微信视频号 GO SDK
• 小红书开放平台 GO SDK

参考开源项目

• OpenSCRM

Support