first

api/api.go

@@ -0,0 +1,34 @@
+package api
+
+// BindComponentByPC 构建PC端授权链接
+const BindComponentByPC = "https://mp.weixin.qq.com/cgi-bin/componentloginpage"
+
+// BindComponentByH5 构建移动端授权链接
+const BindComponentByH5 = "https://mp.weixin.qq.com/safe/bindcomponent"
+
+// StartPushTicket 启动票据推送服务
+const StartPushTicket = "https://api.weixin.qq.com/cgi-bin/component/api_start_push_ticket"
+
+// ComponentToken 获取令牌
+const ComponentToken = "https://api.weixin.qq.com/cgi-bin/component/api_component_token"
+
+// CreatePreAuthCode 获取预授权码
+const CreatePreAuthCode = "https://api.weixin.qq.com/cgi-bin/component/api_create_preauthcode"
+
+// QueryAuth 获取授权信息
+const QueryAuth = "https://api.weixin.qq.com/cgi-bin/component/api_query_auth"
+
+// AuthorizerToken 获取/刷新接口调用令牌
+const AuthorizerToken = "https://api.weixin.qq.com/cgi-bin/component/api_authorizer_token"
+
+// GetAuthorizerInfo 获取授权帐号信息
+const GetAuthorizerInfo = "https://api.weixin.qq.com/cgi-bin/component/api_get_authorizer_info"
+
+// GetAuthorizerList 拉取所有已授权的帐号信息
+const GetAuthorizerList = "https://api.weixin.qq.com/cgi-bin/component/api_get_authorizer_list"
+
+// GetAuthorizerOption 获取授权方选项信息
+const GetAuthorizerOption = "https://api.weixin.qq.com/cgi-bin/component/api_get_authorizer_option"
+
+// SetAuthorizerOption 设置授权方选项信息
+const SetAuthorizerOption = "https://api.weixin.qq.com/cgi-bin/component/api_set_authorizer_option"

entity/authorization_change_notice.go

@@ -0,0 +1,12 @@
+package entity
+
+// AuthorizationChangeNotice 授权变更通知
+type AuthorizationChangeNotice struct {
+	AppId                        string  `json:"AppId"`
+	CreateTime                   float64 `json:"CreateTime"`
+	InfoType                     string  `json:"InfoType"`
+	AuthorizerAppid              string  `json:"AuthorizerAppid"`
+	AuthorizationCode            string  `json:"AuthorizationCode"`
+	AuthorizationCodeExpiredTime float64 `json:"AuthorizationCodeExpiredTime"`
+	PreAuthCode                  string  `json:"PreAuthCode"`
+}

entity/authorization_info.go

@@ -0,0 +1,10 @@
+package entity
+
+// AuthorizationInfo 授权信息
+type AuthorizationInfo struct {
+	AuthorizerAppId        string     `json:"authorizer_appid"`
+	AuthorizerAccessToken  string     `json:"authorizer_access_token"`
+	ExpiresIn              float64    `json:"expires_in"`
+	AuthorizerRefreshToken string     `json:"authorizer_refresh_token"`
+	FuncInfo               []FuncInfo `json:"func_info"`
+}

entity/authorizer_info.go

@@ -0,0 +1,23 @@
+package entity
+
+// AuthorizerBasicInfo 公众号/小程序帐号基本信息
+type AuthorizerBasicInfo struct {
+	AuthorizerAppid string  `json:"authorizer_appid"`
+	RefreshToken    string  `json:"refresh_token"`
+	AuthTime        float64 `json:"auth_time"`
+}
+
+// AuthorizerInfo 公众号/小程序帐号信息
+type AuthorizerInfo struct {
+	NickName        string          `json:"nick_name"`
+	HeadImg         string          `json:"head_img"`
+	ServiceTypeInfo Enum            `json:"service_type_info"`
+	VerifyTypeInfo  Enum            `json:"verify_type_info"`
+	UserName        string          `json:"user_name"`
+	PrincipalName   string          `json:"principal_name"`
+	Signature       string          `json:"signature"`
+	Alias           string          `json:"alias"`
+	BusinessInfo    BusinessInfo    `json:"business_info"`
+	QrcodeUrl       string          `json:"qrcode_url"`
+	MiniProgramInfo MiniProgramInfo `json:"MiniProgramInfo"`
+}

entity/business_info.go

@@ -0,0 +1,10 @@
+package entity
+
+// BusinessInfo 功能的开通状况（0代表未开通，1代表已开通）
+type BusinessInfo struct {
+	OpenStore float64 `json:"open_store"`
+	OpenScan  float64 `json:"open_scan"`
+	OpenPay   float64 `json:"open_pay"`
+	OpenCard  float64 `json:"open_card"`
+	OpenShake float64 `json:"open_shake"`
+}

entity/entity.go

@@ -0,0 +1,6 @@
+package entity
+
+// Enum 通用枚举类型
+type Enum struct {
+	ID float64 `json:"id"`
+}

entity/error.go

@@ -0,0 +1,13 @@
+package entity
+
+import "fmt"
+
+// Error 通用错误
+type Error struct {
+	Code    float64 `json:"errcode"`
+	Message string  `json:"errmsg"`
+}
+
+func (e Error) Error() string {
+	return fmt.Sprintf("[%d] - %s", int(e.Code), e.Message)
+}

entity/func_info.go

@@ -0,0 +1,6 @@
+package entity
+
+// FuncInfo 权限
+type FuncInfo struct {
+	FuncscopeCategory Enum `json:"funcscope_category"`
+}

entity/mini_program_info.go

@@ -0,0 +1,23 @@
+package entity
+
+// MiniProgramNetwork 小程序配置的合法域名信息
+type MiniProgramNetwork struct {
+	RequestDomain   []string `json:"RequestDomain"`
+	WsRequestDomain []string `json:"WsRequestDomain"`
+	UploadDomain    []string `json:"UploadDomain"`
+	DownloadDomain  []string `json:"DownloadDomain"`
+	BizDomain       []string `json:"BizDomain"`
+	UDPDomain       []string `json:"UDPDomain"`
+}
+
+// MiniProgramCategory 小程序配置的类目信息
+type MiniProgramCategory struct {
+	First  string `json:"first"`
+	Second string `json:"second"`
+}
+
+// MiniProgramInfo 小程序配置
+type MiniProgramInfo struct {
+	Network    MiniProgramNetwork    `json:"network"`
+	Categories []MiniProgramCategory `json:"categories"`
+}

go.mod

@@ -0,0 +1,3 @@
+module gitee.com/yansen_zh/wechat-oplatform-sdk
+
+go 1.17

service/authorizer_info.go

@@ -0,0 +1,65 @@
+package service
+
+import (
+	"encoding/json"
+	"errors"
+	"net/url"
+
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/api"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/entity"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils/request"
+)
+
+// AuthorizerInfoParam 获取授权帐号信息参数
+type AuthorizerInfoParam struct {
+	ComponentAppId  string `json:"component_appid"`
+	AuthorizerAppId string `json:"authorizer_appid"`
+}
+
+// AuthorizerInfoResult 获取授权帐号信息结果
+type AuthorizerInfoResult struct {
+	entity.Error
+	AuthorizationInfo entity.AuthorizationInfo `json:"authorization_info"`
+	AuthorizerInfo    entity.AuthorizerInfo    `json:"authorizer_info"`
+}
+
+// GetAuthorizerInfo 获取授权帐号信息
+func GetAuthorizerInfo(componentAccessToken string, param AuthorizerInfoParam) (*AuthorizerInfoResult, error) {
+	if componentAccessToken == "" {
+		return nil, errors.New("获取授权帐号信息 第三方平台的 component_access_token 不能为空")
+	}
+
+	if param.ComponentAppId == "" {
+		return nil, errors.New("获取授权帐号信息 第三方平台的 appid 不能为空")
+	}
+
+	if param.AuthorizerAppId == "" {
+		return nil, errors.New("获取授权帐号信息 授权方 appid 不能为空")
+	}
+
+	data, e1 := json.Marshal(param)
+	if e1 != nil {
+		return nil, e1
+	}
+
+	queryParam := url.Values{}
+	queryParam.Set("component_access_token", componentAccessToken)
+
+	apiUrl, _ := utils.ParseURL(api.GetAuthorizerInfo, &queryParam)
+	resp, e2 := request.PostJSON(apiUrl.String(), data)
+	if e2 != nil {
+		return nil, e2
+	}
+
+	result := AuthorizerInfoResult{}
+	if err := json.Unmarshal(resp, &result); err != nil {
+		return nil, err
+	}
+
+	if result.Code != 0 {
+		return &result, result.Error
+	}
+
+	return &result, nil
+}

service/authorizer_list.go

@@ -0,0 +1,74 @@
+package service
+
+import (
+	"encoding/json"
+	"errors"
+	"net/url"
+
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/api"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/entity"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils/request"
+)
+
+// AuthorizerListParam 拉取所有已授权的帐号信息参数
+type AuthorizerListParam struct {
+	ComponentAppId string `json:"component_appid"`
+	Offset         int    `json:"offset"`
+	Count          int    `json:"count"`
+}
+
+// AuthorizerListResult 拉取所有已授权的帐号信息结果
+type AuthorizerListResult struct {
+	entity.Error
+	TotalCount float64                      `json:"total_count"`
+	List       []entity.AuthorizerBasicInfo `json:"list"`
+}
+
+// AuthorizerList 拉取所有已授权的帐号信息
+func AuthorizerList(componentAccessToken string, param AuthorizerListParam) (*AuthorizerListResult, error) {
+	if componentAccessToken == "" {
+		return nil, errors.New("拉取所有已授权的帐号信息 第三方平台的 component_access_token 不能为空")
+	}
+
+	if param.ComponentAppId == "" {
+		return nil, errors.New("拉取所有已授权的帐号信息 第三方平台的 appid 不能为空")
+	}
+
+	if param.Offset < 0 {
+		param.Offset = 0
+	}
+
+	if param.Count < 0 {
+		param.Count = 100
+	}
+
+	if param.Count > 500 {
+		param.Count = 500
+	}
+
+	data, e1 := json.Marshal(param)
+	if e1 != nil {
+		return nil, e1
+	}
+
+	queryParam := url.Values{}
+	queryParam.Set("component_access_token", componentAccessToken)
+
+	apiUrl, _ := utils.ParseURL(api.GetAuthorizerList, &queryParam)
+	resp, e2 := request.PostJSON(apiUrl.String(), data)
+	if e2 != nil {
+		return nil, e2
+	}
+
+	result := AuthorizerListResult{}
+	if err := json.Unmarshal(resp, &result); err != nil {
+		return nil, err
+	}
+
+	if result.Code != 0 {
+		return &result, result.Error
+	}
+
+	return &result, nil
+}

service/authorizer_option.go

@@ -0,0 +1,132 @@
+package service
+
+import (
+	"encoding/json"
+	"errors"
+	"net/url"
+
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/api"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/entity"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils/request"
+)
+
+// GetAuthorizerOptionParam 获取授权方选项信息参数
+type GetAuthorizerOptionParam struct {
+	ComponentAppId  string `json:"component_appid"`
+	AuthorizerAppId string `json:"authorizer_appid"`
+	OptionName      string `json:"option_name"`
+}
+
+// GetAuthorizerOptionResult 获取授权方选项信息结果
+type GetAuthorizerOptionResult struct {
+	entity.Error
+	AuthorizerAppId string `json:"authorizer_appid"`
+	OptionName      string `json:"option_name"`
+	OptionValue     string `json:"option_value"`
+}
+
+// GetAuthorizerOption 获取授权方选项信息
+func GetAuthorizerOption(componentAccessToken string, param GetAuthorizerOptionParam) (*GetAuthorizerOptionResult, error) {
+	if componentAccessToken == "" {
+		return nil, errors.New("获取授权方选项信息 第三方平台的 component_access_token 不能为空")
+	}
+
+	if param.ComponentAppId == "" {
+		return nil, errors.New("获取授权方选项信息 授权公众号或小程序的 appid 不能为空")
+	}
+
+	if param.AuthorizerAppId == "" {
+		return nil, errors.New("获取授权方选项信息 第三方平台的 appid 不能为空")
+	}
+
+	if param.OptionName == "" {
+		return nil, errors.New("获取授权方选项信息 选项名称 不能为空")
+	}
+
+	data, e1 := json.Marshal(param)
+	if e1 != nil {
+		return nil, e1
+	}
+
+	queryParam := url.Values{}
+	queryParam.Set("component_access_token", componentAccessToken)
+
+	apiUrl, _ := utils.ParseURL(api.GetAuthorizerOption, &queryParam)
+	resp, e2 := request.PostJSON(apiUrl.String(), data)
+	if e2 != nil {
+		return nil, e2
+	}
+
+	result := GetAuthorizerOptionResult{}
+	if err := json.Unmarshal(resp, &result); err != nil {
+		return nil, err
+	}
+
+	if result.Code != 0 {
+		return &result, result.Error
+	}
+
+	return &result, nil
+}
+
+// SetAuthorizerOptionParam 设置授权方选项信息参数
+type SetAuthorizerOptionParam struct {
+	ComponentAppId  string `json:"component_appid"`
+	AuthorizerAppId string `json:"authorizer_appid"`
+	OptionName      string `json:"option_name"`
+	OptionValue     string `json:"option_value"`
+}
+
+// SetAuthorizerOptionResult 设置授权方选项信息结果
+type SetAuthorizerOptionResult struct {
+	entity.Error
+}
+
+// SetAuthorizerOption 设置授权方选项信息
+func SetAuthorizerOption(componentAccessToken string, param SetAuthorizerOptionParam) (*SetAuthorizerOptionResult, error) {
+	if componentAccessToken == "" {
+		return nil, errors.New("设置授权方选项信息 第三方平台的 component_access_token 不能为空")
+	}
+
+	if param.ComponentAppId == "" {
+		return nil, errors.New("设置授权方选项信息 授权公众号或小程序的 appid 不能为空")
+	}
+
+	if param.AuthorizerAppId == "" {
+		return nil, errors.New("设置授权方选项信息 第三方平台的 appid 不能为空")
+	}
+
+	if param.OptionName == "" {
+		return nil, errors.New("设置授权方选项信息 选项名称 不能为空")
+	}
+
+	if param.OptionValue == "" {
+		return nil, errors.New("设置授权方选项信息 设置的选项值 不能为空")
+	}
+
+	data, e1 := json.Marshal(param)
+	if e1 != nil {
+		return nil, e1
+	}
+
+	queryParam := url.Values{}
+	queryParam.Set("component_access_token", componentAccessToken)
+
+	apiUrl, _ := utils.ParseURL(api.SetAuthorizerOption, &queryParam)
+	resp, e2 := request.PostJSON(apiUrl.String(), data)
+	if e2 != nil {
+		return nil, e2
+	}
+
+	result := SetAuthorizerOptionResult{}
+	if err := json.Unmarshal(resp, &result); err != nil {
+		return nil, err
+	}
+
+	if result.Code != 0 {
+		return &result, result.Error
+	}
+
+	return &result, nil
+}

service/authorizer_token.go

@@ -0,0 +1,71 @@
+package service
+
+import (
+	"encoding/json"
+	"errors"
+	"net/url"
+
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/api"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/entity"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils/request"
+)
+
+// AuthorizerTokenParam 获取/刷新接口调用令牌参数
+type AuthorizerTokenParam struct {
+	ComponentAppId         string `json:"component_appid"`
+	AuthorizerAppId        string `json:"authorizer_appid"`
+	AuthorizerRefreshToken string `json:"authorizer_refresh_token"`
+}
+
+// AuthorizerTokenResult 获取/刷新接口调用令牌结果
+type AuthorizerTokenResult struct {
+	entity.Error
+	AuthorizerAccessToken  string  `json:"authorizer_access_token"`
+	ExpiresIn              float64 `json:"expires_in"`
+	AuthorizerRefreshToken string  `json:"authorizer_refresh_token"`
+}
+
+// AuthorizerToken 获取/刷新接口调用令牌
+func AuthorizerToken(componentAccessToken string, param AuthorizerTokenParam) (*AuthorizerTokenResult, error) {
+	if componentAccessToken == "" {
+		return nil, errors.New("获取/刷新接口调用令牌 第三方平台的 component_access_token 不能为空")
+	}
+
+	if param.ComponentAppId == "" {
+		return nil, errors.New("获取/刷新接口调用令牌 第三方平台的 appid 不能为空")
+	}
+
+	if param.AuthorizerAppId == "" {
+		return nil, errors.New("获取/刷新接口调用令牌 授权方 appid 不能为空")
+	}
+
+	if param.AuthorizerRefreshToken == "" {
+		return nil, errors.New("获取/刷新接口调用令牌 刷新令牌 不能为空")
+	}
+
+	data, e1 := json.Marshal(param)
+	if e1 != nil {
+		return nil, e1
+	}
+
+	queryParam := url.Values{}
+	queryParam.Set("component_access_token", componentAccessToken)
+
+	apiUrl, _ := utils.ParseURL(api.AuthorizerToken, &queryParam)
+	resp, e2 := request.PostJSON(apiUrl.String(), data)
+	if e2 != nil {
+		return nil, e2
+	}
+
+	result := AuthorizerTokenResult{}
+	if err := json.Unmarshal(resp, &result); err != nil {
+		return nil, err
+	}
+
+	if result.Code != 0 {
+		return &result, result.Error
+	}
+
+	return &result, nil
+}

service/bind_component.go

@@ -0,0 +1,82 @@
+package service
+
+import (
+	"errors"
+	"net/url"
+	"strconv"
+
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/api"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils"
+)
+
+// BindComponentParam 构建授权链接入参
+type BindComponentParam struct {
+	ComponentAppId string
+	PreAuthCode    string
+
+	// RedirectUri 不需要转码
+	RedirectUri string
+	AuthType    int
+	BizAppId    string
+}
+
+// BindComponentByPC 构建PC端授权链接
+func BindComponentByPC(param BindComponentParam) (*url.URL, error) {
+	return BindComponent("PC", param)
+}
+
+// BindComponentByH5 构建H5端授权链接
+func BindComponentByH5(param BindComponentParam) (*url.URL, error) {
+	return BindComponent("H5", param)
+}
+
+// BindComponent 构建授权链接
+func BindComponent(client string, param BindComponentParam) (*url.URL, error) {
+	isH5 := client == "H5"
+
+	if param.ComponentAppId == "" {
+		return nil, errors.New("构建授权链接 第三方平台的 appid 不能为空")
+	}
+
+	if param.PreAuthCode == "" {
+		return nil, errors.New("构建授权链接 预授权码 不能为空")
+	}
+
+	if param.RedirectUri == "" {
+		return nil, errors.New("构建授权链接 回调 URI 不能为空")
+	}
+
+	if param.AuthType < 1 || param.AuthType > 3 {
+		param.AuthType = 3
+	}
+
+	queryParams := url.Values{}
+	if isH5 {
+		queryParams.Set("action", "bindcomponent")
+		queryParams.Set("no_scan", "1")
+	}
+	queryParams.Set("component_appid", param.ComponentAppId)
+	queryParams.Set("pre_auth_code", param.PreAuthCode)
+	queryParams.Set("redirect_uri", param.RedirectUri)
+	// auth_type、biz_appid 两个字段互斥
+	if param.BizAppId != "" {
+		queryParams.Set("biz_appid", param.BizAppId)
+	} else {
+		queryParams.Set("auth_type", strconv.Itoa(param.AuthType))
+	}
+
+	apiUrl := api.BindComponentByPC
+	if isH5 {
+		apiUrl = api.BindComponentByH5
+	}
+	u, err := utils.ParseURL(apiUrl, &queryParams)
+	if err != nil {
+		return nil, err
+	}
+
+	if isH5 {
+		u.Fragment = "wechat_redirect"
+	}
+
+	return u, nil
+}

service/component_token.go

@@ -0,0 +1,60 @@
+package service
+
+import (
+	"encoding/json"
+	"errors"
+
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/api"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/entity"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils/request"
+)
+
+// ComponentTokenParam 获取令牌参数
+type ComponentTokenParam struct {
+	ComponentAppId        string `json:"component_appid"`
+	ComponentAppSecret    string `json:"component_appsecret"`
+	ComponentVerifyTicket string `json:"component_verify_ticket"`
+}
+
+// ComponentTokenResult 获取令牌结果
+type ComponentTokenResult struct {
+	entity.Error
+	ComponentAccessToken string  `json:"component_access_token"`
+	ExpiresIn            float64 `json:"expires_in"`
+}
+
+// ComponentVerifyTicket 获取令牌
+func ComponentToken(param ComponentTokenParam) (*ComponentTokenResult, error) {
+	if param.ComponentAppId == "" {
+		return nil, errors.New("获取令牌 第三方平台的 appid 不能为空")
+	}
+
+	if param.ComponentAppSecret == "" {
+		return nil, errors.New("获取令牌 第三方平台的 appsecret 不能为空")
+	}
+
+	if param.ComponentVerifyTicket == "" {
+		return nil, errors.New("获取令牌 推送 ticket 不能为空")
+	}
+
+	data, e1 := json.Marshal(param)
+	if e1 != nil {
+		return nil, e1
+	}
+
+	resp, e2 := request.PostJSON(api.ComponentToken, data)
+	if e2 != nil {
+		return nil, e2
+	}
+
+	result := ComponentTokenResult{}
+	if err := json.Unmarshal(resp, &result); err != nil {
+		return nil, err
+	}
+
+	if result.Code != 0 {
+		return &result, result.Error
+	}
+
+	return &result, nil
+}

service/pre_auth_code.go

@@ -0,0 +1,60 @@
+package service
+
+import (
+	"encoding/json"
+	"errors"
+	"net/url"
+
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/api"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/entity"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils/request"
+)
+
+// PreAuthCodeParam 获取预授权码参数
+type PreAuthCodeParam struct {
+	ComponentAppId string `json:"component_appid"`
+}
+
+// PreAuthCodeResult 获取预授权码结果
+type PreAuthCodeResult struct {
+	entity.Error
+	PreAuthCode string  `json:"pre_auth_code"`
+	ExpiresIn   float64 `json:"expires_in"`
+}
+
+// CreatePreAuthCode 获取预授权码
+func CreatePreAuthCode(componentAccessToken string, param PreAuthCodeParam) (*PreAuthCodeResult, error) {
+	if componentAccessToken == "" {
+		return nil, errors.New("获取预授权码 第三方平台的 component_access_token 不能为空")
+	}
+
+	if param.ComponentAppId == "" {
+		return nil, errors.New("获取预授权码 第三方平台的 appid 不能为空")
+	}
+
+	data, e1 := json.Marshal(param)
+	if e1 != nil {
+		return nil, e1
+	}
+
+	queryParam := url.Values{}
+	queryParam.Set("component_access_token", componentAccessToken)
+
+	apiUrl, _ := utils.ParseURL(api.CreatePreAuthCode, &queryParam)
+	resp, e2 := request.PostJSON(apiUrl.String(), data)
+	if e2 != nil {
+		return nil, e2
+	}
+
+	result := PreAuthCodeResult{}
+	if err := json.Unmarshal(resp, &result); err != nil {
+		return nil, err
+	}
+
+	if result.Code != 0 {
+		return &result, result.Error
+	}
+
+	return &result, nil
+}

service/push_ticket.go

@@ -0,0 +1,53 @@
+package service
+
+import (
+	"encoding/json"
+	"errors"
+
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/api"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/entity"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils/request"
+)
+
+// PushTicketParam 启动票据推送服务参数
+type PushTicketParam struct {
+	ComponentAppId  string `json:"component_appid"`
+	ComponentSecret string `json:"component_secret"`
+}
+
+// PushTicketResult 启动票据推送服务参数
+type PushTicketResult struct {
+	entity.Error
+}
+
+// StartPushTicket 启动 ticket 推送服务
+func StartPushTicket(param PushTicketParam) (*PushTicketResult, error) {
+	if param.ComponentAppId == "" {
+		return nil, errors.New("启动 ticket 推送服务 第三方平台的 appid 不能为空")
+	}
+
+	if param.ComponentSecret == "" {
+		return nil, errors.New("启动 ticket 推送服务 第三方平台的 appsecret 不能为空")
+	}
+
+	data, e1 := json.Marshal(param)
+	if e1 != nil {
+		return nil, e1
+	}
+
+	resp, e2 := request.PostJSON(api.StartPushTicket, data)
+	if e2 != nil {
+		return nil, e2
+	}
+
+	result := PushTicketResult{}
+	if err := json.Unmarshal(resp, &result); err != nil {
+		return nil, err
+	}
+
+	if result.Code != 0 {
+		return &result, result.Error
+	}
+
+	return &result, nil
+}

service/query_auth.go

@@ -0,0 +1,64 @@
+package service
+
+import (
+	"encoding/json"
+	"errors"
+	"net/url"
+
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/api"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/entity"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils"
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils/request"
+)
+
+// QueryAuthParam 获取授权信息参数
+type QueryAuthParam struct {
+	ComponentAppId    string `json:"component_appid"`
+	AuthorizationCode string `json:"authorization_code"`
+}
+
+// QueryAuthResult 获取授权信息结果
+type QueryAuthResult struct {
+	entity.Error
+	AuthorizationInfo entity.AuthorizationInfo `json:"authorization_info"`
+}
+
+// QueryAuth 获取授权信息
+func QueryAuth(componentAccessToken string, param QueryAuthParam) (*QueryAuthResult, error) {
+	if componentAccessToken == "" {
+		return nil, errors.New("获取授权信息 第三方平台的 component_access_token 不能为空")
+	}
+
+	if param.ComponentAppId == "" {
+		return nil, errors.New("获取授权信息 第三方平台的 appid 不能为空")
+	}
+
+	if param.AuthorizationCode == "" {
+		return nil, errors.New("获取授权信息 授权码 不能为空")
+	}
+
+	data, e1 := json.Marshal(param)
+	if e1 != nil {
+		return nil, e1
+	}
+
+	queryParam := url.Values{}
+	queryParam.Set("component_access_token", componentAccessToken)
+
+	apiUrl, _ := utils.ParseURL(api.QueryAuth, &queryParam)
+	resp, e2 := request.PostJSON(apiUrl.String(), data)
+	if e2 != nil {
+		return nil, e2
+	}
+
+	result := QueryAuthResult{}
+	if err := json.Unmarshal(resp, &result); err != nil {
+		return nil, err
+	}
+
+	if result.Code != 0 {
+		return &result, result.Error
+	}
+
+	return &result, nil
+}

service/verify_ticket.go

@@ -0,0 +1,31 @@
+package service
+
+import (
+	"encoding/xml"
+
+	"gitee.com/yansen_zh/wechat-oplatform-sdk/utils/encrypt"
+)
+
+// ComponentVerifyTicketResult 获取验证票据结果
+type ComponentVerifyTicketResult struct {
+	AppId                 string  `xml:"AppId"`
+	CreateTime            float64 `xml:"CreateTime"`
+	InfoType              string  `xml:"InfoType"`
+	ComponentVerifyTicket string  `xml:"ComponentVerifyTicket"`
+}
+
+// ComponentVerifyTicket 获取验证票据
+func VerifyTicket(data []byte, encodingAESKey, iv string) (*ComponentVerifyTicketResult, error) {
+	bt, err := encrypt.MsgDecode(data, encodingAESKey, iv)
+	if nil != err {
+		return nil, err
+	}
+
+	res := ComponentVerifyTicketResult{}
+
+	if e := xml.Unmarshal(bt, &res); e != nil {
+		return nil, e
+	}
+
+	return &res, nil
+}

utils/encrypt/encrypt.go

@@ -0,0 +1 @@
+package encrypt

utils/encrypt/msg_encrypt.go

@@ -0,0 +1,101 @@
+package encrypt
+
+import (
+	"bytes"
+	"crypto/aes"
+	"crypto/cipher"
+	"encoding/base64"
+	"errors"
+)
+
+// MsgEncode 使用 AES CBC 模式加密数据
+// data 为待加密数据
+func MsgEncode(data []byte, encodingAESKey, iv string) ([]byte, error) {
+	if encodingAESKey == "" {
+		return nil, errors.New("加密 EncodingAESKey 为空")
+	}
+
+	if iv == "" {
+		return nil, errors.New("加密 IV 为空")
+	}
+
+	if nil == data || len(data) == 0 {
+		return nil, errors.New("待加密 消息 为空")
+	}
+
+	aesKey, e1 := base64.StdEncoding.DecodeString(encodingAESKey + "=")
+	if e1 != nil {
+		return nil, e1
+	}
+
+	block, e2 := aes.NewCipher(aesKey)
+	if e2 != nil {
+		return nil, e2
+	}
+
+	blockSize := block.BlockSize()
+	dist := pkcs7(data, blockSize)
+
+	// CBC
+	mode := cipher.NewCBCEncrypter(block, []byte(iv))
+	mode.CryptBlocks(dist, data)
+
+	// 如果需要拿到字符串, 请使用
+	// fmt.Sprintf("%x", xxx)
+	// 或者使用 base64 转码
+	return dist, nil
+}
+
+// MsgDecode 是 MsgEncode 的反操作, 用来解密数据
+// data 为待解密数据
+func MsgDecode(data []byte, encodingAESKey, iv string) ([]byte, error) {
+	if encodingAESKey == "" {
+		return nil, errors.New("解密 EncodingAESKey 为空")
+	}
+
+	if iv == "" {
+		return nil, errors.New("解密 IV 为空")
+	}
+
+	if nil == data || len(data) == 0 {
+		return nil, errors.New("待解密 消息 为空")
+	}
+
+	aesKey, e1 := base64.StdEncoding.DecodeString(encodingAESKey + "=")
+	if e1 != nil {
+		return nil, e1
+	}
+
+	block, err := aes.NewCipher(aesKey)
+	if err != nil {
+		return nil, err
+	}
+
+	dist := make([]byte, len(data))
+
+	mode := cipher.NewCBCDecrypter(block, []byte(iv))
+	mode.CryptBlocks(dist, data)
+
+	// 如果需要拿到字符串, 请使用
+	// fmt.Sprintf("%s", xxx)
+	return unpkcs7(dist), nil
+}
+
+// pkcs7 填充
+func pkcs7(data []byte, blockSize int) []byte {
+	paddingBlock := blockSize - len(data)%blockSize
+	if paddingBlock == 0 {
+		paddingBlock = blockSize
+	}
+
+	padding := bytes.Repeat([]byte{byte(paddingBlock)}, paddingBlock)
+	return append(data, padding...)
+}
+
+// unpkcs7 取消 pkcs7 填充
+func unpkcs7(data []byte) []byte {
+	length := len(data)
+
+	unpadding := int(data[length-1])
+	return data[:(length - unpadding)]
+}

utils/request/content_type.go

@@ -0,0 +1,3 @@
+package request
+
+const ContentTypeJSON = "application/json"

utils/request/request.go

@@ -0,0 +1,34 @@
+package request
+
+import (
+	"bytes"
+	"errors"
+	"io"
+	"net/http"
+)
+
+func post(url string, contentType string, body []byte) ([]byte, error) {
+	resp, e1 := http.Post(url, contentType, bytes.NewReader(body))
+	if e1 != nil {
+		return nil, e1
+	}
+
+	if resp.StatusCode > 299 {
+		return nil, errors.New(resp.Status)
+	}
+
+	body, e2 := io.ReadAll(resp.Body)
+	resp.Body.Close()
+	if e2 != nil {
+		return nil, e2
+	}
+
+	return body, nil
+}
+
+// PostJSON 使用 POST 方式发送 json 数据
+func PostJSON(url string, body []byte) ([]byte, error) {
+
+	return post(url, ContentTypeJSON, body)
+
+}

utils/url.go

@@ -0,0 +1,17 @@
+package utils
+
+import "net/url"
+
+// ParseURL 解析URL
+func ParseURL(rawURL string, param *url.Values) (*url.URL, error) {
+	u, err := url.Parse(rawURL)
+	if err != nil {
+		return nil, err
+	}
+
+	if nil != param {
+		u.RawQuery = param.Encode()
+	}
+
+	return u, nil
+}