mirror of
https://github.com/silenceper/wechat.git
synced 2026-02-05 21:22:27 +08:00
Compare commits
1 Commits
v2.1.6-rc.
...
revert-685
| Author | SHA1 | Date | |
|---|---|---|---|
|
42b0966049 |
24
.github/workflows/go.yml
vendored
24
.github/workflows/go.yml
vendored
@@ -10,21 +10,17 @@ jobs:
|
||||
golangci:
|
||||
strategy:
|
||||
matrix:
|
||||
go-version: [ '1.16','1.17','1.18','1.19','1.20' ]
|
||||
go-version: [1.16.x,1.17.x,1.18.x]
|
||||
name: golangci-lint
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
- name: Setup Golang ${{ matrix.go-version }}
|
||||
uses: actions/setup-go@v4
|
||||
with:
|
||||
go-version: ${{ matrix.go-version }}
|
||||
- name: Checkout
|
||||
uses: actions/checkout@v3
|
||||
- uses: actions/setup-go@v3
|
||||
- uses: actions/checkout@v3
|
||||
- name: golangci-lint
|
||||
uses: golangci/golangci-lint-action@v3
|
||||
uses: golangci/golangci-lint-action@v3.2.0
|
||||
with:
|
||||
# Required: the version of golangci-lint is required and must be specified without patch version: we always use the latest patch version.
|
||||
version: v1.52.2
|
||||
version: latest
|
||||
build:
|
||||
name: Test
|
||||
runs-on: ubuntu-latest
|
||||
@@ -32,7 +28,7 @@ jobs:
|
||||
redis:
|
||||
image: redis
|
||||
ports:
|
||||
- 6379:6379
|
||||
- 6379:6379
|
||||
options: --entrypoint redis-server
|
||||
memcached:
|
||||
image: memcached
|
||||
@@ -42,14 +38,14 @@ jobs:
|
||||
# strategy set
|
||||
strategy:
|
||||
matrix:
|
||||
go: [ '1.16','1.17','1.18','1.19','1.20' ]
|
||||
go: ["1.16", "1.17", "1.18"]
|
||||
|
||||
steps:
|
||||
- uses: actions/checkout@v3
|
||||
- uses: actions/checkout@v2
|
||||
- name: Set up Go 1.x
|
||||
uses: actions/setup-go@v4
|
||||
uses: actions/setup-go@v2
|
||||
with:
|
||||
go-version: ${{ matrix.go }}
|
||||
id: go
|
||||
- name: Test
|
||||
run: go test -v -race ./...
|
||||
run: go test -v -race ./...
|
||||
|
||||
8
.github/workflows/release.yml
vendored
8
.github/workflows/release.yml
vendored
@@ -11,17 +11,17 @@ jobs:
|
||||
steps:
|
||||
-
|
||||
name: Checkout
|
||||
uses: actions/checkout@v3
|
||||
uses: actions/checkout@v2
|
||||
with:
|
||||
fetch-depth: 0
|
||||
-
|
||||
name: Set up Go
|
||||
uses: actions/setup-go@v4
|
||||
uses: actions/setup-go@v2
|
||||
with:
|
||||
go-version: 1.16
|
||||
go-version: 1.15
|
||||
-
|
||||
name: Run GoReleaser
|
||||
uses: goreleaser/goreleaser-action@v4
|
||||
uses: goreleaser/goreleaser-action@v2
|
||||
with:
|
||||
version: latest
|
||||
args: release --rm-dist
|
||||
|
||||
@@ -1,36 +0,0 @@
|
||||
package openapi
|
||||
|
||||
import "github.com/silenceper/wechat/v2/util"
|
||||
|
||||
// GetAPIQuotaParams 查询API调用额度参数
|
||||
type GetAPIQuotaParams struct {
|
||||
CgiPath string `json:"cgi_path"` // api的请求地址，例如"/cgi-bin/message/custom/send";不要前缀“https://api.weixin.qq.com” ，也不要漏了"/",否则都会76003的报错
|
||||
}
|
||||
|
||||
// APIQuota API调用额度
|
||||
type APIQuota struct {
|
||||
util.CommonError
|
||||
Quota struct {
|
||||
DailyLimit int64 `json:"daily_limit"` // 当天该账号可调用该接口的次数
|
||||
Used int64 `json:"used"` // 当天已经调用的次数
|
||||
Remain int64 `json:"remain"` // 当天剩余调用次数
|
||||
} `json:"quota"` // 详情
|
||||
}
|
||||
|
||||
// GetRidInfoParams 查询rid信息参数
|
||||
type GetRidInfoParams struct {
|
||||
Rid string `json:"rid"` // 调用接口报错返回的rid
|
||||
}
|
||||
|
||||
// RidInfo rid信息
|
||||
type RidInfo struct {
|
||||
util.CommonError
|
||||
Request struct {
|
||||
InvokeTime int64 `json:"invoke_time"` // 发起请求的时间戳
|
||||
CostInMs int64 `json:"cost_in_ms"` // 请求毫秒级耗时
|
||||
RequestURL string `json:"request_url"` // 请求的URL参数
|
||||
RequestBody string `json:"request_body"` // post请求的请求参数
|
||||
ResponseBody string `json:"response_body"` // 接口请求返回参数
|
||||
ClientIP string `json:"client_ip"` // 接口请求的客户端ip
|
||||
} `json:"request"` // 该rid对应的请求详情
|
||||
}
|
||||
@@ -1,127 +0,0 @@
|
||||
package openapi
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"fmt"
|
||||
|
||||
"github.com/silenceper/wechat/v2/domain/openapi"
|
||||
mpContext "github.com/silenceper/wechat/v2/miniprogram/context"
|
||||
ocContext "github.com/silenceper/wechat/v2/officialaccount/context"
|
||||
"github.com/silenceper/wechat/v2/util"
|
||||
)
|
||||
|
||||
const (
|
||||
clearQuotaURL = "https://api.weixin.qq.com/cgi-bin/clear_quota" // 重置API调用次数
|
||||
getAPIQuotaURL = "https://api.weixin.qq.com/cgi-bin/openapi/quota/get" // 查询API调用额度
|
||||
getRidInfoURL = "https://api.weixin.qq.com/cgi-bin/openapi/rid/get" // 查询rid信息
|
||||
clearQuotaByAppSecretURL = "https://api.weixin.qq.com/cgi-bin/clear_quota/v2" // 使用AppSecret重置 API 调用次数
|
||||
)
|
||||
|
||||
// OpenAPI openApi管理
|
||||
type OpenAPI struct {
|
||||
ctx interface{}
|
||||
}
|
||||
|
||||
// NewOpenAPI 实例化
|
||||
func NewOpenAPI(ctx interface{}) *OpenAPI {
|
||||
return &OpenAPI{ctx: ctx}
|
||||
}
|
||||
|
||||
// ClearQuota 重置API调用次数
|
||||
// https://developers.weixin.qq.com/miniprogram/dev/OpenApiDoc/openApi-mgnt/clearQuota.html
|
||||
func (o *OpenAPI) ClearQuota() error {
|
||||
appID, _, err := o.getAppIDAndSecret()
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
var payload = struct {
|
||||
AppID string `json:"appid"`
|
||||
}{
|
||||
AppID: appID,
|
||||
}
|
||||
res, err := o.doPostRequest(clearQuotaURL, payload)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return util.DecodeWithCommonError(res, "ClearQuota")
|
||||
}
|
||||
|
||||
// GetAPIQuota 查询API调用额度
|
||||
// https://developers.weixin.qq.com/miniprogram/dev/OpenApiDoc/openApi-mgnt/getApiQuota.html
|
||||
func (o *OpenAPI) GetAPIQuota(params openapi.GetAPIQuotaParams) (quota openapi.APIQuota, err error) {
|
||||
res, err := o.doPostRequest(getAPIQuotaURL, params)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
err = util.DecodeWithError(res, "a, "GetAPIQuota")
|
||||
return
|
||||
}
|
||||
|
||||
// GetRidInfo 查询rid信息
|
||||
// https://developers.weixin.qq.com/miniprogram/dev/OpenApiDoc/openApi-mgnt/getRidInfo.html
|
||||
func (o *OpenAPI) GetRidInfo(params openapi.GetRidInfoParams) (r openapi.RidInfo, err error) {
|
||||
res, err := o.doPostRequest(getRidInfoURL, params)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
err = util.DecodeWithError(res, &r, "GetRidInfo")
|
||||
return
|
||||
}
|
||||
|
||||
// ClearQuotaByAppSecret 使用AppSecret重置 API 调用次数
|
||||
// https://developers.weixin.qq.com/miniprogram/dev/OpenApiDoc/openApi-mgnt/clearQuotaByAppSecret.html
|
||||
func (o *OpenAPI) ClearQuotaByAppSecret() error {
|
||||
id, secret, err := o.getAppIDAndSecret()
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
uri := fmt.Sprintf("%s?appid=%s&appsecret=%s", clearQuotaByAppSecretURL, id, secret)
|
||||
res, err := util.HTTPPost(uri, "")
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return util.DecodeWithCommonError(res, "ClearQuotaByAppSecret")
|
||||
}
|
||||
|
||||
// 获取 AppID 和 AppSecret
|
||||
func (o *OpenAPI) getAppIDAndSecret() (string, string, error) {
|
||||
switch o.ctx.(type) {
|
||||
case *mpContext.Context:
|
||||
c := o.ctx.(*mpContext.Context)
|
||||
return c.AppID, c.AppSecret, nil
|
||||
case *ocContext.Context:
|
||||
c := o.ctx.(*ocContext.Context)
|
||||
return c.AppID, c.AppSecret, nil
|
||||
default:
|
||||
return "", "", errors.New("invalid context type")
|
||||
}
|
||||
}
|
||||
|
||||
// 获取 AccessToken
|
||||
func (o *OpenAPI) getAccessToken() (string, error) {
|
||||
switch o.ctx.(type) {
|
||||
case *mpContext.Context:
|
||||
return o.ctx.(*mpContext.Context).GetAccessToken()
|
||||
case *ocContext.Context:
|
||||
return o.ctx.(*ocContext.Context).GetAccessToken()
|
||||
default:
|
||||
return "", errors.New("invalid context type")
|
||||
}
|
||||
}
|
||||
|
||||
// 创建 POST 请求
|
||||
func (o *OpenAPI) doPostRequest(uri string, payload interface{}) ([]byte, error) {
|
||||
ak, err := o.getAccessToken()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
uri = fmt.Sprintf("%s?access_token=%s", uri, ak)
|
||||
return util.PostJSON(uri, payload)
|
||||
}
|
||||
@@ -40,8 +40,8 @@ type ResCode2Session struct {
|
||||
type RspCheckEncryptedData struct {
|
||||
util.CommonError
|
||||
|
||||
Vaild bool `json:"vaild"` // 是否是合法的数据
|
||||
CreateTime uint64 `json:"create_time"` // 加密数据生成的时间戳
|
||||
Vaild bool `json:"vaild"` // 是否是合法的数据
|
||||
CreateTime uint `json:"create_time"` // 加密数据生成的时间戳
|
||||
}
|
||||
|
||||
// Code2Session 登录凭证校验。
|
||||
|
||||
@@ -2,7 +2,6 @@ package miniprogram
|
||||
|
||||
import (
|
||||
"github.com/silenceper/wechat/v2/credential"
|
||||
"github.com/silenceper/wechat/v2/internal/openapi"
|
||||
"github.com/silenceper/wechat/v2/miniprogram/analysis"
|
||||
"github.com/silenceper/wechat/v2/miniprogram/auth"
|
||||
"github.com/silenceper/wechat/v2/miniprogram/business"
|
||||
@@ -127,8 +126,3 @@ func (miniProgram *MiniProgram) GetShortLink() *shortlink.ShortLink {
|
||||
func (miniProgram *MiniProgram) GetSURLScheme() *urlscheme.URLScheme {
|
||||
return urlscheme.NewURLScheme(miniProgram.ctx)
|
||||
}
|
||||
|
||||
// GetOpenAPI openApi管理接口
|
||||
func (miniProgram *MiniProgram) GetOpenAPI() *openapi.OpenAPI {
|
||||
return openapi.NewOpenAPI(miniProgram.ctx)
|
||||
}
|
||||
|
||||
@@ -123,7 +123,6 @@ type MixMessage struct {
|
||||
Title string `xml:"Title"`
|
||||
Description string `xml:"Description"`
|
||||
URL string `xml:"Url"`
|
||||
BizMsgMenuID int64 `xml:"bizmsgmenuid"`
|
||||
|
||||
// 事件相关
|
||||
Event EventType `xml:"Event" json:"Event"`
|
||||
@@ -196,14 +195,6 @@ type MixMessage struct {
|
||||
LegalPersonaName string `xml:"legal_persona_name"`
|
||||
ComponentPhone string `xml:"component_phone"`
|
||||
} `xml:"info"`
|
||||
ResultInfo struct {
|
||||
APIName string `xml:"api_name"`
|
||||
ApplyTime string `xml:"apply_time"`
|
||||
AuditID string `xml:"audit_id"`
|
||||
AuditTime string `xml:"audit_time"`
|
||||
Reason string `xml:"reason"`
|
||||
Status string `xml:"status"`
|
||||
} `xml:"result_info"`
|
||||
|
||||
// 卡券相关
|
||||
CardID string `xml:"CardId"`
|
||||
@@ -222,10 +213,6 @@ type MixMessage struct {
|
||||
TraceID string `xml:"trace_id"`
|
||||
StatusCode int `xml:"status_code"`
|
||||
|
||||
//小程序名称审核结果事件推送
|
||||
Ret int32 `xml:"ret"` //审核结果 2：失败，3：成功
|
||||
NickName string `xml:"nickname"` //小程序昵称
|
||||
|
||||
// 设备相关
|
||||
device.MsgDevice
|
||||
|
||||
|
||||
@@ -4,7 +4,6 @@ import (
|
||||
stdcontext "context"
|
||||
"net/http"
|
||||
|
||||
"github.com/silenceper/wechat/v2/internal/openapi"
|
||||
"github.com/silenceper/wechat/v2/officialaccount/draft"
|
||||
"github.com/silenceper/wechat/v2/officialaccount/freepublish"
|
||||
"github.com/silenceper/wechat/v2/officialaccount/ocr"
|
||||
@@ -213,8 +212,3 @@ func (officialAccount *OfficialAccount) GetSubscribe() *message.Subscribe {
|
||||
func (officialAccount *OfficialAccount) GetCustomerServiceManager() *customerservice.Manager {
|
||||
return customerservice.NewCustomerServiceManager(officialAccount.ctx)
|
||||
}
|
||||
|
||||
// GetOpenAPI openApi管理接口
|
||||
func (officialAccount *OfficialAccount) GetOpenAPI() *openapi.OpenAPI {
|
||||
return openapi.NewOpenAPI(officialAccount.ctx)
|
||||
}
|
||||
|
||||
@@ -1,230 +0,0 @@
|
||||
package addresslist
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
|
||||
"github.com/silenceper/wechat/v2/util"
|
||||
)
|
||||
|
||||
const (
|
||||
// getPermListURL 获取应用的可见范围
|
||||
getPermListURL = "https://qyapi.weixin.qq.com/cgi-bin/linkedcorp/agent/get_perm_list?access_token=%s"
|
||||
// getLinkedCorpUserURL 获取互联企业成员详细信息
|
||||
getLinkedCorpUserURL = "https://qyapi.weixin.qq.com/cgi-bin/linkedcorp/user/get?access_token=%s"
|
||||
// linkedCorpSimpleListURL 获取互联企业部门成员
|
||||
linkedCorpSimpleListURL = "https://qyapi.weixin.qq.com/cgi-bin/linkedcorp/user/simplelist?access_token=%s"
|
||||
// linkedCorpUserListURL 获取互联企业部门成员详情
|
||||
linkedCorpUserListURL = "https://qyapi.weixin.qq.com/cgi-bin/linkedcorp/user/list?access_token=%s"
|
||||
// linkedCorpDepartmentListURL 获取互联企业部门列表
|
||||
linkedCorpDepartmentListURL = "https://qyapi.weixin.qq.com/cgi-bin/linkedcorp/department/list?access_token=%s"
|
||||
)
|
||||
|
||||
// GetPermListResponse 获取应用的可见范围响应
|
||||
type GetPermListResponse struct {
|
||||
util.CommonError
|
||||
UserIDs []string `json:"userids"`
|
||||
DepartmentIDs []string `json:"department_ids"`
|
||||
}
|
||||
|
||||
// GetPermList 获取应用的可见范围
|
||||
// see https://developer.work.weixin.qq.com/document/path/93172
|
||||
func (r *Client) GetPermList() (*GetPermListResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.HTTPPost(fmt.Sprintf(getPermListURL, accessToken), ""); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &GetPermListResponse{}
|
||||
if err = util.DecodeWithError(response, result, "GetPermList"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
|
||||
// GetLinkedCorpUserRequest 获取互联企业成员详细信息请求
|
||||
type GetLinkedCorpUserRequest struct {
|
||||
UserID string `json:"userid"`
|
||||
}
|
||||
|
||||
// GetLinkedCorpUserResponse 获取互联企业成员详细信息响应
|
||||
type GetLinkedCorpUserResponse struct {
|
||||
util.CommonError
|
||||
UserInfo LinkedCorpUserInfo `json:"user_info"`
|
||||
}
|
||||
|
||||
// LinkedCorpUserInfo 互联企业成员详细信息
|
||||
type LinkedCorpUserInfo struct {
|
||||
UserID string `json:"userid"`
|
||||
Name string `json:"name"`
|
||||
Department []string `json:"department"`
|
||||
Mobile string `json:"mobile"`
|
||||
Telephone string `json:"telephone"`
|
||||
Email string `json:"email"`
|
||||
Position string `json:"position"`
|
||||
CorpID string `json:"corpid"`
|
||||
Extattr Extattr `json:"extattr"`
|
||||
}
|
||||
|
||||
// Extattr 互联企业成员详细信息扩展属性
|
||||
type Extattr struct {
|
||||
Attrs []ExtattrItem `json:"attrs"`
|
||||
}
|
||||
|
||||
// ExtattrItem 互联企业成员详细信息扩展属性条目
|
||||
type ExtattrItem struct {
|
||||
Name string `json:"name"`
|
||||
Value string `json:"value,omitempty"`
|
||||
Type int `json:"type"`
|
||||
Text ExtattrItemText `json:"text,omitempty"`
|
||||
Web ExtattrItemWeb `json:"web,omitempty"`
|
||||
}
|
||||
|
||||
// ExtattrItemText 互联企业成员详细信息自定义属性(文本)
|
||||
type ExtattrItemText struct {
|
||||
Value string `json:"value"`
|
||||
}
|
||||
|
||||
// ExtattrItemWeb 互联企业成员详细信息自定义属性(网页)
|
||||
type ExtattrItemWeb struct {
|
||||
URL string `json:"url"`
|
||||
Title string `json:"title"`
|
||||
}
|
||||
|
||||
// GetLinkedCorpUser 获取互联企业成员详细信息
|
||||
// see https://developer.work.weixin.qq.com/document/path/93171
|
||||
func (r *Client) GetLinkedCorpUser(req *GetLinkedCorpUserRequest) (*GetLinkedCorpUserResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(getLinkedCorpUserURL, accessToken), req); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &GetLinkedCorpUserResponse{}
|
||||
if err = util.DecodeWithError(response, result, "GetLinkedCorpUser"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
|
||||
// LinkedCorpSimpleListRequest 获取互联企业部门成员请求
|
||||
type LinkedCorpSimpleListRequest struct {
|
||||
DepartmentID string `json:"department_id"`
|
||||
}
|
||||
|
||||
// LinkedCorpSimpleListResponse 获取互联企业部门成员响应
|
||||
type LinkedCorpSimpleListResponse struct {
|
||||
util.CommonError
|
||||
Userlist []LinkedCorpUser `json:"userlist"`
|
||||
}
|
||||
|
||||
// LinkedCorpUser 企业部门成员
|
||||
type LinkedCorpUser struct {
|
||||
UserID string `json:"userid"`
|
||||
Name string `json:"name"`
|
||||
Department []string `json:"department"`
|
||||
CorpID string `json:"corpid"`
|
||||
}
|
||||
|
||||
// LinkedCorpSimpleList 获取互联企业部门成员
|
||||
// see https://developer.work.weixin.qq.com/document/path/93168
|
||||
func (r *Client) LinkedCorpSimpleList(req *LinkedCorpSimpleListRequest) (*LinkedCorpSimpleListResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(linkedCorpSimpleListURL, accessToken), req); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &LinkedCorpSimpleListResponse{}
|
||||
if err = util.DecodeWithError(response, result, "LinkedCorpSimpleList"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
|
||||
// LinkedCorpUserListRequest 获取互联企业部门成员详情请求
|
||||
type LinkedCorpUserListRequest struct {
|
||||
DepartmentID string `json:"department_id"`
|
||||
}
|
||||
|
||||
// LinkedCorpUserListResponse 获取互联企业部门成员详情响应
|
||||
type LinkedCorpUserListResponse struct {
|
||||
util.CommonError
|
||||
UserList []LinkedCorpUserInfo `json:"userlist"`
|
||||
}
|
||||
|
||||
// LinkedCorpUserList 获取互联企业部门成员详情
|
||||
// see https://developer.work.weixin.qq.com/document/path/93169
|
||||
func (r *Client) LinkedCorpUserList(req *LinkedCorpUserListRequest) (*LinkedCorpUserListResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(linkedCorpUserListURL, accessToken), req); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &LinkedCorpUserListResponse{}
|
||||
if err = util.DecodeWithError(response, result, "LinkedCorpUserList"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
|
||||
// LinkedCorpDepartmentListRequest 获取互联企业部门列表请求
|
||||
type LinkedCorpDepartmentListRequest struct {
|
||||
DepartmentID string `json:"department_id"`
|
||||
}
|
||||
|
||||
// LinkedCorpDepartmentListResponse 获取互联企业部门列表响应
|
||||
type LinkedCorpDepartmentListResponse struct {
|
||||
util.CommonError
|
||||
DepartmentList []LinkedCorpDepartment `json:"department_list"`
|
||||
}
|
||||
|
||||
// LinkedCorpDepartment 互联企业部门
|
||||
type LinkedCorpDepartment struct {
|
||||
DepartmentID string `json:"department_id"`
|
||||
DepartmentName string `json:"department_name"`
|
||||
ParentID string `json:"parentid"`
|
||||
Order int `json:"order"`
|
||||
}
|
||||
|
||||
// LinkedCorpDepartmentList 获取互联企业部门列表
|
||||
// see https://developer.work.weixin.qq.com/document/path/93170
|
||||
func (r *Client) LinkedCorpDepartmentList(req *LinkedCorpDepartmentListRequest) (*LinkedCorpDepartmentListResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(linkedCorpDepartmentListURL, accessToken), req); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &LinkedCorpDepartmentListResponse{}
|
||||
if err = util.DecodeWithError(response, result, "LinkedCorpDepartmentList"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
@@ -16,18 +16,6 @@ const (
|
||||
fetchBatchExternalContactUserDetailURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/batch/get_by_user"
|
||||
// updateUserRemarkURL 更新客户备注信息
|
||||
updateUserRemarkURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/remark"
|
||||
// listCustomerStrategyURL 获取规则组列表
|
||||
listCustomerStrategyURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/customer_strategy/list?access_token=%s"
|
||||
// getCustomerStrategyURL 获取规则组详情
|
||||
getCustomerStrategyURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/customer_strategy/get?access_token=%s"
|
||||
// getRangeCustomerStrategyURL 获取规则组管理范围
|
||||
getRangeCustomerStrategyURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/customer_strategy/get_range?access_token=%s"
|
||||
// createCustomerStrategyURL 创建新的规则组
|
||||
createCustomerStrategyURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/customer_strategy/create?access_token=%s"
|
||||
// editCustomerStrategyURL 编辑规则组及其管理范围
|
||||
editCustomerStrategyURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/customer_strategy/edit?access_token=%s"
|
||||
// delCustomerStrategyURL 删除规则组
|
||||
delCustomerStrategyURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/customer_strategy/del?access_token=%s"
|
||||
)
|
||||
|
||||
// ExternalUserListResponse 外部联系人列表响应
|
||||
@@ -83,7 +71,7 @@ type FollowUser struct {
|
||||
UserID string `json:"userid"`
|
||||
Remark string `json:"remark"`
|
||||
Description string `json:"description"`
|
||||
CreateTime int64 `json:"createtime"`
|
||||
CreateTime string `json:"create_time"`
|
||||
Tags []Tag `json:"tags"`
|
||||
RemarkCorpName string `json:"remark_corp_name"`
|
||||
RemarkMobiles []string `json:"remark_mobiles"`
|
||||
@@ -169,7 +157,7 @@ type FollowInfo struct {
|
||||
UserID string `json:"userid"`
|
||||
Remark string `json:"remark"`
|
||||
Description string `json:"description"`
|
||||
CreateTime int64 `json:"createtime"`
|
||||
CreateTime int `json:"create_time"`
|
||||
TagID []string `json:"tag_id"`
|
||||
RemarkCorpName string `json:"remark_corp_name"`
|
||||
RemarkMobiles []string `json:"remark_mobiles"`
|
||||
@@ -231,236 +219,3 @@ func (r *Client) UpdateUserRemark(request UpdateUserRemarkRequest) error {
|
||||
}
|
||||
return util.DecodeWithCommonError(response, "UpdateUserRemark")
|
||||
}
|
||||
|
||||
// ListCustomerStrategyRequest 获取规则组列表请求
|
||||
type ListCustomerStrategyRequest struct {
|
||||
Cursor string `json:"cursor"`
|
||||
Limit int `json:"limit"`
|
||||
}
|
||||
|
||||
// ListCustomerStrategyResponse 获取规则组列表响应
|
||||
type ListCustomerStrategyResponse struct {
|
||||
util.CommonError
|
||||
Strategy []StrategyID `json:"strategy"`
|
||||
NextCursor string `json:"next_cursor"`
|
||||
}
|
||||
|
||||
// StrategyID 规则组ID
|
||||
type StrategyID struct {
|
||||
StrategyID int `json:"strategy_id"`
|
||||
}
|
||||
|
||||
// ListCustomerStrategy 获取规则组列表
|
||||
// @see https://developer.work.weixin.qq.com/document/path/94883#%E8%8E%B7%E5%8F%96%E8%A7%84%E5%88%99%E7%BB%84%E5%88%97%E8%A1%A8
|
||||
func (r *Client) ListCustomerStrategy(req *ListCustomerStrategyRequest) (*ListCustomerStrategyResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(listCustomerStrategyURL, accessToken), req); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &ListCustomerStrategyResponse{}
|
||||
if err = util.DecodeWithError(response, result, "ListCustomerStrategy"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
|
||||
// GetCustomerStrategyRequest 获取规则组详情请求
|
||||
type GetCustomerStrategyRequest struct {
|
||||
StrategyID int `json:"strategy_id"`
|
||||
}
|
||||
|
||||
// GetCustomerStrategyResponse 获取规则组详情响应
|
||||
type GetCustomerStrategyResponse struct {
|
||||
util.CommonError
|
||||
Strategy Strategy `json:"strategy"`
|
||||
}
|
||||
|
||||
// Strategy 规则组
|
||||
type Strategy struct {
|
||||
StrategyID int `json:"strategy_id"`
|
||||
ParentID int `json:"parent_id"`
|
||||
StrategyName string `json:"strategy_name"`
|
||||
CreateTime int64 `json:"create_time"`
|
||||
AdminList []string `json:"admin_list"`
|
||||
Privilege Privilege `json:"privilege"`
|
||||
}
|
||||
|
||||
// Privilege 权限
|
||||
type Privilege struct {
|
||||
ViewCustomerList bool `json:"view_customer_list"`
|
||||
ViewCustomerData bool `json:"view_customer_data"`
|
||||
ViewRoomList bool `json:"view_room_list"`
|
||||
ContactMe bool `json:"contact_me"`
|
||||
JoinRoom bool `json:"join_room"`
|
||||
ShareCustomer bool `json:"share_customer"`
|
||||
OperResignCustomer bool `json:"oper_resign_customer"`
|
||||
OperResignGroup bool `json:"oper_resign_group"`
|
||||
SendCustomerMsg bool `json:"send_customer_msg"`
|
||||
EditWelcomeMsg bool `json:"edit_welcome_msg"`
|
||||
ViewBehaviorData bool `json:"view_behavior_data"`
|
||||
ViewRoomData bool `json:"view_room_data"`
|
||||
SendGroupMsg bool `json:"send_group_msg"`
|
||||
RoomDeduplication bool `json:"room_deduplication"`
|
||||
RapidReply bool `json:"rapid_reply"`
|
||||
OnjobCustomerTransfer bool `json:"onjob_customer_transfer"`
|
||||
EditAntiSpamRule bool `json:"edit_anti_spam_rule"`
|
||||
ExportCustomerList bool `json:"export_customer_list"`
|
||||
ExportCustomerData bool `json:"export_customer_data"`
|
||||
ExportCustomerGroupList bool `json:"export_customer_group_list"`
|
||||
ManageCustomerTag bool `json:"manage_customer_tag"`
|
||||
}
|
||||
|
||||
// GetCustomerStrategy 获取规则组详情
|
||||
// @see https://developer.work.weixin.qq.com/document/path/94883#%E8%8E%B7%E5%8F%96%E8%A7%84%E5%88%99%E7%BB%84%E8%AF%A6%E6%83%85
|
||||
func (r *Client) GetCustomerStrategy(req *GetCustomerStrategyRequest) (*GetCustomerStrategyResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(getCustomerStrategyURL, accessToken), req); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &GetCustomerStrategyResponse{}
|
||||
if err = util.DecodeWithError(response, result, "GetCustomerStrategy"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
|
||||
// GetRangeCustomerStrategyRequest 获取规则组管理范围请求
|
||||
type GetRangeCustomerStrategyRequest struct {
|
||||
StrategyID int `json:"strategy_id"`
|
||||
Cursor string `json:"cursor"`
|
||||
Limit int `json:"limit"`
|
||||
}
|
||||
|
||||
// GetRangeCustomerStrategyResponse 获取规则组管理范围响应
|
||||
type GetRangeCustomerStrategyResponse struct {
|
||||
util.CommonError
|
||||
Range []Range `json:"range"`
|
||||
NextCursor string `json:"next_cursor"`
|
||||
}
|
||||
|
||||
// Range 管理范围节点
|
||||
type Range struct {
|
||||
Type int `json:"type"`
|
||||
UserID string `json:"userid,omitempty"`
|
||||
PartyID int `json:"partyid,omitempty"`
|
||||
}
|
||||
|
||||
// GetRangeCustomerStrategy 获取规则组管理范围
|
||||
// @see https://developer.work.weixin.qq.com/document/path/94883#%E8%8E%B7%E5%8F%96%E8%A7%84%E5%88%99%E7%BB%84%E7%AE%A1%E7%90%86%E8%8C%83%E5%9B%B4
|
||||
func (r *Client) GetRangeCustomerStrategy(req *GetRangeCustomerStrategyRequest) (*GetRangeCustomerStrategyResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(getRangeCustomerStrategyURL, accessToken), req); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &GetRangeCustomerStrategyResponse{}
|
||||
if err = util.DecodeWithError(response, result, "GetRangeCustomerStrategy"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
|
||||
// CreateCustomerStrategyRequest 创建新的规则组请求
|
||||
type CreateCustomerStrategyRequest struct {
|
||||
ParentID int `json:"parent_id"`
|
||||
StrategyName string `json:"strategy_name"`
|
||||
AdminList []string `json:"admin_list"`
|
||||
Privilege Privilege `json:"privilege"`
|
||||
Range []Range `json:"range"`
|
||||
}
|
||||
|
||||
// CreateCustomerStrategyResponse 创建新的规则组响应
|
||||
type CreateCustomerStrategyResponse struct {
|
||||
util.CommonError
|
||||
StrategyID int `json:"strategy_id"`
|
||||
}
|
||||
|
||||
// CreateCustomerStrategy 创建新的规则组
|
||||
// @see https://developer.work.weixin.qq.com/document/path/94883#%E5%88%9B%E5%BB%BA%E6%96%B0%E7%9A%84%E8%A7%84%E5%88%99%E7%BB%84
|
||||
func (r *Client) CreateCustomerStrategy(req *CreateCustomerStrategyRequest) (*CreateCustomerStrategyResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(createCustomerStrategyURL, accessToken), req); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &CreateCustomerStrategyResponse{}
|
||||
if err = util.DecodeWithError(response, result, "CreateCustomerStrategy"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
|
||||
// EditCustomerStrategyRequest 编辑规则组及其管理范围请求
|
||||
type EditCustomerStrategyRequest struct {
|
||||
StrategyID int `json:"strategy_id"`
|
||||
StrategyName string `json:"strategy_name"`
|
||||
AdminList []string `json:"admin_list"`
|
||||
Privilege Privilege `json:"privilege"`
|
||||
RangeAdd []Range `json:"range_add"`
|
||||
RangeDel []Range `json:"range_del"`
|
||||
}
|
||||
|
||||
// EditCustomerStrategy 编辑规则组及其管理范围
|
||||
// see https://developer.work.weixin.qq.com/document/path/94883#%E7%BC%96%E8%BE%91%E8%A7%84%E5%88%99%E7%BB%84%E5%8F%8A%E5%85%B6%E7%AE%A1%E7%90%86%E8%8C%83%E5%9B%B4
|
||||
func (r *Client) EditCustomerStrategy(req *EditCustomerStrategyRequest) error {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(editCustomerStrategyURL, accessToken), req); err != nil {
|
||||
return err
|
||||
}
|
||||
return util.DecodeWithCommonError(response, "EditCustomerStrategy")
|
||||
}
|
||||
|
||||
// DelCustomerStrategyRequest 删除规则组请求
|
||||
type DelCustomerStrategyRequest struct {
|
||||
StrategyID int `json:"strategy_id"`
|
||||
}
|
||||
|
||||
// DelCustomerStrategy 删除规则组
|
||||
// see https://developer.work.weixin.qq.com/document/path/94883#%E5%88%A0%E9%99%A4%E8%A7%84%E5%88%99%E7%BB%84
|
||||
func (r *Client) DelCustomerStrategy(req *DelCustomerStrategyRequest) error {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(delCustomerStrategyURL, accessToken), req); err != nil {
|
||||
return err
|
||||
}
|
||||
return util.DecodeWithCommonError(response, "DelCustomerStrategy")
|
||||
}
|
||||
|
||||
@@ -80,7 +80,7 @@ type (
|
||||
ChatID string `json:"chat_id"` //客户群ID
|
||||
Name string `json:"name"` //群名
|
||||
Owner string `json:"owner"` //群主ID
|
||||
CreateTime int64 `json:"create_time"` //群的创建时间
|
||||
CreateTime int `json:"create_time"` //群的创建时间
|
||||
Notice string `json:"notice"` //群公告
|
||||
MemberList []GroupChatMember `json:"member_list"` //群成员列表
|
||||
AdminList []GroupChatAdmin `json:"admin_list"` //群管理员列表
|
||||
|
||||
@@ -111,8 +111,8 @@ func (r *Client) AddMsgTemplate(req *AddMsgTemplateRequest) (*AddMsgTemplateResp
|
||||
// GetGroupMsgListV2Request 获取群发记录列表请求
|
||||
type GetGroupMsgListV2Request struct {
|
||||
ChatType string `json:"chat_type"`
|
||||
StartTime int64 `json:"start_time"`
|
||||
EndTime int64 `json:"end_time"`
|
||||
StartTime int `json:"start_time"`
|
||||
EndTime int `json:"end_time"`
|
||||
Creator string `json:"creator,omitempty"`
|
||||
FilterType int `json:"filter_type"`
|
||||
Limit int `json:"limit"`
|
||||
@@ -130,7 +130,7 @@ type GetGroupMsgListV2Response struct {
|
||||
type GroupMsg struct {
|
||||
MsgID string `json:"msgid"`
|
||||
Creator string `json:"creator"`
|
||||
CreateTime int64 `json:"create_time"`
|
||||
CreateTime int `json:"create_time"`
|
||||
CreateType int `json:"create_type"`
|
||||
Text MsgText `json:"text"`
|
||||
Attachments []*Attachment `json:"attachments"`
|
||||
|
||||
@@ -18,14 +18,6 @@ const (
|
||||
delCropTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/del_corp_tag"
|
||||
// markCropTagURL 为客户打上、删除标签
|
||||
markCropTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/mark_tag"
|
||||
// getStrategyTagListURL 获取指定规则组下的企业客户标签
|
||||
getStrategyTagListURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get_strategy_tag_list?access_token=%s"
|
||||
// addStrategyTagURL 为指定规则组创建企业客户标签
|
||||
addStrategyTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/add_strategy_tag?access_token=%s"
|
||||
// editStrategyTagURL 编辑指定规则组下的企业客户标签
|
||||
editStrategyTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/edit_strategy_tag?access_token=%s"
|
||||
// delStrategyTagURL 删除指定规则组下的企业客户标签
|
||||
delStrategyTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/del_strategy_tag?access_token=%s"
|
||||
)
|
||||
|
||||
// GetCropTagRequest 获取企业标签请求
|
||||
@@ -44,7 +36,7 @@ type GetCropTagListResponse struct {
|
||||
type TagGroup struct {
|
||||
GroupID string `json:"group_id"`
|
||||
GroupName string `json:"group_name"`
|
||||
CreateTime int64 `json:"create_time"`
|
||||
CreateTime int `json:"create_time"`
|
||||
GroupOrder int `json:"group_order"`
|
||||
Deleted bool `json:"deleted"`
|
||||
Tag []TagGroupTagItem `json:"tag"`
|
||||
@@ -54,7 +46,7 @@ type TagGroup struct {
|
||||
type TagGroupTagItem struct {
|
||||
ID string `json:"id"`
|
||||
Name string `json:"name"`
|
||||
CreateTime int64 `json:"create_time"`
|
||||
CreateTime int `json:"create_time"`
|
||||
Order int `json:"order"`
|
||||
Deleted bool `json:"deleted"`
|
||||
}
|
||||
@@ -209,161 +201,3 @@ func (r *Client) MarkTag(request MarkTagRequest) error {
|
||||
}
|
||||
return util.DecodeWithCommonError(response, "MarkTag")
|
||||
}
|
||||
|
||||
// GetStrategyTagListRequest 获取指定规则组下的企业客户标签请求
|
||||
type GetStrategyTagListRequest struct {
|
||||
StrategyID int `json:"strategy_id"`
|
||||
TagID []string `json:"tag_id"`
|
||||
GroupID []string `json:"group_id"`
|
||||
}
|
||||
|
||||
// GetStrategyTagListResponse 获取指定规则组下的企业客户标签响应
|
||||
type GetStrategyTagListResponse struct {
|
||||
util.CommonError
|
||||
TagGroup []StrategyTagGroup `json:"tag_group"`
|
||||
}
|
||||
|
||||
// StrategyTagGroup 规则组下的企业标签组
|
||||
type StrategyTagGroup struct {
|
||||
GroupID string `json:"group_id"`
|
||||
GroupName string `json:"group_name"`
|
||||
CreateTime int64 `json:"create_time"`
|
||||
Order int `json:"order"`
|
||||
StrategyID int `json:"strategy_id"`
|
||||
Tag []StrategyTag `json:"tag"`
|
||||
}
|
||||
|
||||
// StrategyTag 规则组下的企业标签
|
||||
type StrategyTag struct {
|
||||
ID string `json:"id"`
|
||||
Name string `json:"name"`
|
||||
CreateTime int64 `json:"create_time"`
|
||||
Order int `json:"order"`
|
||||
}
|
||||
|
||||
// GetStrategyTagList 获取指定规则组下的企业客户标签
|
||||
// @see https://developer.work.weixin.qq.com/document/path/94882#%E8%8E%B7%E5%8F%96%E6%8C%87%E5%AE%9A%E8%A7%84%E5%88%99%E7%BB%84%E4%B8%8B%E7%9A%84%E4%BC%81%E4%B8%9A%E5%AE%A2%E6%88%B7%E6%A0%87%E7%AD%BE
|
||||
func (r *Client) GetStrategyTagList(req *GetStrategyTagListRequest) (*GetStrategyTagListResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(getStrategyTagListURL, accessToken), req); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &GetStrategyTagListResponse{}
|
||||
if err = util.DecodeWithError(response, result, "GetStrategyTagList"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
|
||||
// AddStrategyTagRequest 为指定规则组创建企业客户标签请求
|
||||
type AddStrategyTagRequest struct {
|
||||
StrategyID int `json:"strategy_id"`
|
||||
GroupID string `json:"group_id"`
|
||||
GroupName string `json:"group_name"`
|
||||
Order int `json:"order"`
|
||||
Tag []AddStrategyTagRequestItem `json:"tag"`
|
||||
}
|
||||
|
||||
// AddStrategyTagRequestItem 为指定规则组创建企业客户标签请求条目
|
||||
type AddStrategyTagRequestItem struct {
|
||||
Name string `json:"name"`
|
||||
Order int `json:"order"`
|
||||
}
|
||||
|
||||
// AddStrategyTagResponse 为指定规则组创建企业客户标签响应
|
||||
type AddStrategyTagResponse struct {
|
||||
util.CommonError
|
||||
TagGroup AddStrategyTagResponseTagGroup `json:"tag_group"`
|
||||
}
|
||||
|
||||
// AddStrategyTagResponseTagGroup 为指定规则组创建企业客户标签响应标签组
|
||||
type AddStrategyTagResponseTagGroup struct {
|
||||
GroupID string `json:"group_id"`
|
||||
GroupName string `json:"group_name"`
|
||||
CreateTime int64 `json:"create_time"`
|
||||
Order int `json:"order"`
|
||||
Tag []AddStrategyTagResponseItem `json:"tag"`
|
||||
}
|
||||
|
||||
// AddStrategyTagResponseItem 标签组内的标签列表
|
||||
type AddStrategyTagResponseItem struct {
|
||||
ID string `json:"id"`
|
||||
Name string `json:"name"`
|
||||
CreateTime int64 `json:"create_time"`
|
||||
Order int `json:"order"`
|
||||
}
|
||||
|
||||
// AddStrategyTag 为指定规则组创建企业客户标签
|
||||
// @see https://developer.work.weixin.qq.com/document/path/94882#%E4%B8%BA%E6%8C%87%E5%AE%9A%E8%A7%84%E5%88%99%E7%BB%84%E5%88%9B%E5%BB%BA%E4%BC%81%E4%B8%9A%E5%AE%A2%E6%88%B7%E6%A0%87%E7%AD%BE
|
||||
func (r *Client) AddStrategyTag(req *AddStrategyTagRequest) (*AddStrategyTagResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(addStrategyTagURL, accessToken), req); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &AddStrategyTagResponse{}
|
||||
if err = util.DecodeWithError(response, result, "AddStrategyTag"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
|
||||
// EditStrategyTagRequest 编辑指定规则组下的企业客户标签请求
|
||||
type EditStrategyTagRequest struct {
|
||||
ID string `json:"id"`
|
||||
Name string `json:"name"`
|
||||
Order int `json:"order"`
|
||||
}
|
||||
|
||||
// EditStrategyTag 编辑指定规则组下的企业客户标签
|
||||
// see https://developer.work.weixin.qq.com/document/path/94882#%E7%BC%96%E8%BE%91%E6%8C%87%E5%AE%9A%E8%A7%84%E5%88%99%E7%BB%84%E4%B8%8B%E7%9A%84%E4%BC%81%E4%B8%9A%E5%AE%A2%E6%88%B7%E6%A0%87%E7%AD%BE
|
||||
func (r *Client) EditStrategyTag(req *EditStrategyTagRequest) error {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(editStrategyTagURL, accessToken), req); err != nil {
|
||||
return err
|
||||
}
|
||||
return util.DecodeWithCommonError(response, "EditStrategyTag")
|
||||
}
|
||||
|
||||
// DelStrategyTagRequest 删除指定规则组下的企业客户标签请求
|
||||
type DelStrategyTagRequest struct {
|
||||
TagID []string `json:"tag_id"`
|
||||
GroupID []string `json:"group_id"`
|
||||
}
|
||||
|
||||
// DelStrategyTag 删除指定规则组下的企业客户标签
|
||||
// see https://developer.work.weixin.qq.com/document/path/94882#%E5%88%A0%E9%99%A4%E6%8C%87%E5%AE%9A%E8%A7%84%E5%88%99%E7%BB%84%E4%B8%8B%E7%9A%84%E4%BC%81%E4%B8%9A%E5%AE%A2%E6%88%B7%E6%A0%87%E7%AD%BE
|
||||
func (r *Client) DelStrategyTag(req *DelStrategyTagRequest) error {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(delStrategyTagURL, accessToken), req); err != nil {
|
||||
return err
|
||||
}
|
||||
return util.DecodeWithCommonError(response, "DelStrategyTag")
|
||||
}
|
||||
|
||||
@@ -1,17 +0,0 @@
|
||||
package invoice
|
||||
|
||||
import (
|
||||
"github.com/silenceper/wechat/v2/work/context"
|
||||
)
|
||||
|
||||
// Client 电子发票接口实例
|
||||
type Client struct {
|
||||
*context.Context
|
||||
}
|
||||
|
||||
// NewClient 初始化实例
|
||||
func NewClient(ctx *context.Context) *Client {
|
||||
return &Client{
|
||||
ctx,
|
||||
}
|
||||
}
|
||||
@@ -1,191 +0,0 @@
|
||||
package invoice
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
|
||||
"github.com/silenceper/wechat/v2/util"
|
||||
)
|
||||
|
||||
const (
|
||||
// getInvoiceInfoURL 查询电子发票
|
||||
getInvoiceInfoURL = "https://qyapi.weixin.qq.com/cgi-bin/card/invoice/reimburse/getinvoiceinfo?access_token=%s"
|
||||
// updateInvoiceStatusURL 更新发票状态
|
||||
updateInvoiceStatusURL = "https://qyapi.weixin.qq.com/cgi-bin/card/invoice/reimburse/updateinvoicestatus?access_token=%s"
|
||||
// updateStatusBatchURL 批量更新发票状态
|
||||
updateStatusBatchURL = "https://qyapi.weixin.qq.com/cgi-bin/card/invoice/reimburse/updatestatusbatch?access_token=%s"
|
||||
// getInvoiceInfoBatchURL 批量查询电子发票
|
||||
getInvoiceInfoBatchURL = "https://qyapi.weixin.qq.com/cgi-bin/card/invoice/reimburse/getinvoiceinfobatch?access_token=%s"
|
||||
)
|
||||
|
||||
// GetInvoiceInfoRequest 查询电子发票请求
|
||||
type GetInvoiceInfoRequest struct {
|
||||
CardID string `json:"card_id"`
|
||||
EncryptCode string `json:"encrypt_code"`
|
||||
}
|
||||
|
||||
// GetInvoiceInfoResponse 查询电子发票响应
|
||||
type GetInvoiceInfoResponse struct {
|
||||
util.CommonError
|
||||
CardID string `json:"card_id"`
|
||||
BeginTime int64 `json:"begin_time"`
|
||||
EndTime int64 `json:"end_time"`
|
||||
OpenID string `json:"openid"`
|
||||
Type string `json:"type"`
|
||||
Payee string `json:"payee"`
|
||||
Detail string `json:"detail"`
|
||||
UserInfo UserInfo `json:"user_info"`
|
||||
}
|
||||
|
||||
// UserInfo 发票的用户信息
|
||||
type UserInfo struct {
|
||||
Fee int64 `json:"fee"`
|
||||
Title string `json:"title"`
|
||||
BillingTime int64 `json:"billing_time"`
|
||||
BillingNo string `json:"billing_no"`
|
||||
BillingCode string `json:"billing_code"`
|
||||
Info []Info `json:"info"`
|
||||
FeeWithoutTax int64 `json:"fee_without_tax"`
|
||||
Tax int64 `json:"tax"`
|
||||
Detail string `json:"detail"`
|
||||
PdfURL string `json:"pdf_url"`
|
||||
TripPdfURL string `json:"trip_pdf_url"`
|
||||
ReimburseStatus string `json:"reimburse_status"`
|
||||
CheckCode string `json:"check_code"`
|
||||
BuyerNumber string `json:"buyer_number"`
|
||||
BuyerAddressAndPhone string `json:"buyer_address_and_phone"`
|
||||
BuyerBankAccount string `json:"buyer_bank_account"`
|
||||
SellerNumber string `json:"seller_number"`
|
||||
SellerAddressAndPhone string `json:"seller_address_and_phone"`
|
||||
SellerBankAccount string `json:"seller_bank_account"`
|
||||
Remarks string `json:"remarks"`
|
||||
Cashier string `json:"cashier"`
|
||||
Maker string `json:"maker"`
|
||||
}
|
||||
|
||||
// Info 商品信息结构
|
||||
type Info struct {
|
||||
Name string `json:"name"`
|
||||
Num int64 `json:"num"`
|
||||
Unit string `json:"unit"`
|
||||
Fee int64 `json:"fee"`
|
||||
Price int64 `json:"price"`
|
||||
}
|
||||
|
||||
// GetInvoiceInfo 查询电子发票
|
||||
// see https://developer.work.weixin.qq.com/document/path/90284
|
||||
func (r *Client) GetInvoiceInfo(req *GetInvoiceInfoRequest) (*GetInvoiceInfoResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(getInvoiceInfoURL, accessToken), req); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &GetInvoiceInfoResponse{}
|
||||
if err = util.DecodeWithError(response, result, "GetInvoiceInfo"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
|
||||
// UpdateInvoiceStatusRequest 更新发票状态请求
|
||||
type UpdateInvoiceStatusRequest struct {
|
||||
CardID string `json:"card_id"`
|
||||
EncryptCode string `json:"encrypt_code"`
|
||||
ReimburseStatus string `json:"reimburse_status"`
|
||||
}
|
||||
|
||||
// UpdateInvoiceStatus 更新发票状态
|
||||
// see https://developer.work.weixin.qq.com/document/path/90285
|
||||
func (r *Client) UpdateInvoiceStatus(req *UpdateInvoiceStatusRequest) error {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(updateInvoiceStatusURL, accessToken), req); err != nil {
|
||||
return err
|
||||
}
|
||||
return util.DecodeWithCommonError(response, "UpdateInvoiceStatus")
|
||||
}
|
||||
|
||||
// UpdateStatusBatchRequest 批量更新发票状态
|
||||
type UpdateStatusBatchRequest struct {
|
||||
OpenID string `json:"openid"`
|
||||
ReimburseStatus string `json:"reimburse_status"`
|
||||
InvoiceList []Invoice `json:"invoice_list"`
|
||||
}
|
||||
|
||||
// Invoice 发票卡券
|
||||
type Invoice struct {
|
||||
CardID string `json:"card_id"`
|
||||
EncryptCode string `json:"encrypt_code"`
|
||||
}
|
||||
|
||||
// UpdateStatusBatch 批量更新发票状态
|
||||
// see https://developer.work.weixin.qq.com/document/path/90286
|
||||
func (r *Client) UpdateStatusBatch(req *UpdateStatusBatchRequest) error {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(updateStatusBatchURL, accessToken), req); err != nil {
|
||||
return err
|
||||
}
|
||||
return util.DecodeWithCommonError(response, "UpdateStatusBatch")
|
||||
}
|
||||
|
||||
// GetInvoiceInfoBatchRequest 批量查询电子发票请求
|
||||
type GetInvoiceInfoBatchRequest struct {
|
||||
ItemList []Invoice `json:"item_list"`
|
||||
}
|
||||
|
||||
// GetInvoiceInfoBatchResponse 批量查询电子发票响应
|
||||
type GetInvoiceInfoBatchResponse struct {
|
||||
util.CommonError
|
||||
ItemList []Item `json:"item_list"`
|
||||
}
|
||||
|
||||
// Item 电子发票的结构化信息
|
||||
type Item struct {
|
||||
CardID string `json:"card_id"`
|
||||
BeginTime int64 `json:"begin_time"`
|
||||
EndTime int64 `json:"end_time"`
|
||||
OpenID string `json:"openid"`
|
||||
Type string `json:"type"`
|
||||
Payee string `json:"payee"`
|
||||
Detail string `json:"detail"`
|
||||
UserInfo UserInfo `json:"user_info"`
|
||||
}
|
||||
|
||||
// GetInvoiceInfoBatch 批量查询电子发票
|
||||
// see https://developer.work.weixin.qq.com/document/path/90287
|
||||
func (r *Client) GetInvoiceInfoBatch(req *GetInvoiceInfoBatchRequest) (*GetInvoiceInfoBatchResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = r.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(getInvoiceInfoBatchURL, accessToken), req); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &GetInvoiceInfoBatchResponse{}
|
||||
if err = util.DecodeWithError(response, result, "GetInvoiceInfoBatch"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
@@ -53,7 +53,7 @@ type callbackOriginMessage struct {
|
||||
// CallbackMessage 微信客服回调消息
|
||||
type CallbackMessage struct {
|
||||
ToUserName string `json:"to_user_name" xml:"ToUserName"` // 微信客服组件ID
|
||||
CreateTime int64 `json:"create_time" xml:"CreateTime"` // 消息创建时间，unix时间戳
|
||||
CreateTime int `json:"create_time" xml:"CreateTime"` // 消息创建时间，unix时间戳
|
||||
MsgType string `json:"msgtype" xml:"MsgType"` // 消息的类型，此时固定为 event
|
||||
Event string `json:"event" xml:"Event"` // 事件的类型，此时固定为 kf_msg_or_event
|
||||
Token string `json:"token" xml:"Token"` // 调用拉取消息接口时，需要传此token，用于校验请求的合法性
|
||||
|
||||
@@ -169,7 +169,7 @@ type CollectMessage struct {
|
||||
Collect struct {
|
||||
RoomName string `json:"room_name,omitempty"` // 填表消息所在的群名称。
|
||||
Creator string `json:"creator,omitempty"` // 创建者在群中的名字
|
||||
CreateTime int64 `json:"create_time,omitempty"` // 创建的时间
|
||||
CreateTime string `json:"create_time,omitempty"` // 创建的时间
|
||||
Details []CollectDetails `json:"details,omitempty"` // 表内容
|
||||
} `json:"collect,omitempty"`
|
||||
}
|
||||
|
||||
@@ -23,10 +23,6 @@ var (
|
||||
oauthUserInfoURL = "https://qyapi.weixin.qq.com/cgi-bin/user/getuserinfo?access_token=%s&code=%s"
|
||||
// oauthQrContentTargetURL 构造独立窗口登录二维码
|
||||
oauthQrContentTargetURL = "https://open.work.weixin.qq.com/wwopen/sso/qrConnect?appid=%s&agentid=%s&redirect_uri=%s&state=%s"
|
||||
// getUserInfoURL 获取访问用户身份&获取用户登录身份
|
||||
getUserInfoURL = "https://qyapi.weixin.qq.com/cgi-bin/auth/getuserinfo?access_token=%s&code=%s"
|
||||
// getUserDetailURL 获取访问用户敏感信息
|
||||
getUserDetailURL = "https://qyapi.weixin.qq.com/cgi-bin/auth/getuserdetail?access_token=%s"
|
||||
)
|
||||
|
||||
// NewOauth new init oauth
|
||||
@@ -97,73 +93,3 @@ func (ctr *Oauth) UserFromCode(code string) (result ResUserInfo, err error) {
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// GetUserInfoResponse 获取访问用户身份&获取用户登录身份响应
|
||||
type GetUserInfoResponse struct {
|
||||
util.CommonError
|
||||
UserID string `json:"userid"`
|
||||
UserTicket string `json:"user_ticket"`
|
||||
OpenID string `json:"openid"`
|
||||
ExternalUserID string `json:"external_userid"`
|
||||
}
|
||||
|
||||
// GetUserInfo 获取访问用户身份&获取用户登录身份
|
||||
// @see https://developer.work.weixin.qq.com/document/path/90213 获取访问用户身份
|
||||
// @see https://developer.work.weixin.qq.com/document/path/98176 获取用户登录身份
|
||||
func (ctr *Oauth) GetUserInfo(code string) (*GetUserInfoResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = ctr.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.HTTPGet(fmt.Sprintf(getUserInfoURL, accessToken, code)); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &GetUserInfoResponse{}
|
||||
if err = util.DecodeWithError(response, result, "GetUserInfo"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
|
||||
// GetUserDetailRequest 获取访问用户敏感信息请求
|
||||
type GetUserDetailRequest struct {
|
||||
UserTicket string `json:"user_ticket"`
|
||||
}
|
||||
|
||||
// GetUserDetailResponse 获取访问用户敏感信息响应
|
||||
type GetUserDetailResponse struct {
|
||||
util.CommonError
|
||||
UserID string `json:"userid"`
|
||||
Gender string `json:"gender"`
|
||||
Avatar string `json:"avatar"`
|
||||
QrCode string `json:"qr_code"`
|
||||
Mobile string `json:"mobile"`
|
||||
Email string `json:"email"`
|
||||
BizMail string `json:"biz_mail"`
|
||||
Address string `json:"address"`
|
||||
}
|
||||
|
||||
// GetUserDetail 获取访问用户敏感信息
|
||||
// @see https://developer.work.weixin.qq.com/document/path/95833
|
||||
func (ctr *Oauth) GetUserDetail(req *GetUserDetailRequest) (*GetUserDetailResponse, error) {
|
||||
var (
|
||||
accessToken string
|
||||
err error
|
||||
)
|
||||
if accessToken, err = ctr.GetAccessToken(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var response []byte
|
||||
if response, err = util.PostJSON(fmt.Sprintf(getUserDetailURL, accessToken), req); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
result := &GetUserDetailResponse{}
|
||||
if err = util.DecodeWithError(response, result, "GetUserDetail"); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
|
||||
@@ -7,7 +7,6 @@ import (
|
||||
"github.com/silenceper/wechat/v2/work/config"
|
||||
"github.com/silenceper/wechat/v2/work/context"
|
||||
"github.com/silenceper/wechat/v2/work/externalcontact"
|
||||
"github.com/silenceper/wechat/v2/work/invoice"
|
||||
"github.com/silenceper/wechat/v2/work/kf"
|
||||
"github.com/silenceper/wechat/v2/work/material"
|
||||
"github.com/silenceper/wechat/v2/work/message"
|
||||
@@ -80,8 +79,3 @@ func (wk *Work) GetMessage() *message.Client {
|
||||
func (wk *Work) GetAppChat() *appchat.Client {
|
||||
return appchat.NewClient(wk.ctx)
|
||||
}
|
||||
|
||||
// GetInvoice get invoice
|
||||
func (wk *Work) GetInvoice() *invoice.Client {
|
||||
return invoice.NewClient(wk.ctx)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user