oauth.go 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182
  1. package oauth
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "net/url"
  6. "github.com/silenceper/wechat/v2/util"
  7. "github.com/silenceper/wechat/v2/work/context"
  8. )
  9. // Oauth auth
  10. type Oauth struct {
  11. *context.Context
  12. }
  13. var (
  14. // oauthTargetURL 企业微信内跳转地址
  15. oauthTargetURL = "https://open.weixin.qq.com/connect/oauth2/authorize?appid=%s&redirect_uri=%s&response_type=code&scope=snsapi_base&state=STATE#wechat_redirect"
  16. // oauthUserInfoURL 获取用户信息地址
  17. oauthUserInfoURL = "https://qyapi.weixin.qq.com/cgi-bin/user/getuserinfo?access_token=%s&code=%s"
  18. // oauthQrContentTargetURL 构造独立窗口登录二维码
  19. oauthQrContentTargetURL = "https://open.work.weixin.qq.com/wwopen/sso/qrConnect?appid=%s&agentid=%s&redirect_uri=%s&state=%s"
  20. )
  21. // NewOauth new init oauth
  22. func NewOauth(ctx *context.Context) *Oauth {
  23. return &Oauth{
  24. ctx,
  25. }
  26. }
  27. // GetTargetURL 获取授权地址
  28. func (ctr *Oauth) GetTargetURL(callbackURL string) string {
  29. // url encode
  30. return fmt.Sprintf(
  31. oauthTargetURL,
  32. ctr.CorpID,
  33. url.QueryEscape(callbackURL),
  34. )
  35. }
  36. // GetQrContentTargetURL 构造独立窗口登录二维码
  37. func (ctr *Oauth) GetQrContentTargetURL(callbackURL string) string {
  38. // url encode
  39. return fmt.Sprintf(
  40. oauthQrContentTargetURL,
  41. ctr.CorpID,
  42. ctr.AgentID,
  43. url.QueryEscape(callbackURL),
  44. util.RandomStr(16),
  45. )
  46. }
  47. // ResUserInfo 返回得用户信息
  48. type ResUserInfo struct {
  49. util.CommonError
  50. // 当用户为企业成员时返回
  51. UserID string `json:"UserId"`
  52. DeviceID string `json:"DeviceId"`
  53. // 非企业成员授权时返回
  54. OpenID string `json:"OpenId"`
  55. ExternalUserID string `json:"external_userid"`
  56. }
  57. // UserFromCode 根据code获取用户信息
  58. func (ctr *Oauth) UserFromCode(code string) (result ResUserInfo, err error) {
  59. var accessToken string
  60. if accessToken, err = ctr.GetAccessToken(); err != nil {
  61. return
  62. }
  63. var response []byte
  64. if response, err = util.HTTPGet(fmt.Sprintf(oauthUserInfoURL, accessToken, code)); err != nil {
  65. return
  66. }
  67. err = json.Unmarshal(response, &result)
  68. if result.ErrCode != 0 {
  69. err = fmt.Errorf("GetUserAccessToken error : errcode=%v , errmsg=%v", result.ErrCode, result.ErrMsg)
  70. return
  71. }
  72. return
  73. }