wechat.go 2.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091
  1. package wechat
  2. import (
  3. "net/http"
  4. "sync"
  5. "github.com/silenceper/wechat/cache"
  6. "github.com/silenceper/wechat/context"
  7. "github.com/silenceper/wechat/js"
  8. "github.com/silenceper/wechat/material"
  9. "github.com/silenceper/wechat/menu"
  10. "github.com/silenceper/wechat/oauth"
  11. "github.com/silenceper/wechat/server"
  12. "github.com/silenceper/wechat/user"
  13. )
  14. // Wechat struct
  15. type Wechat struct {
  16. Context *context.Context
  17. }
  18. // Config for user
  19. type Config struct {
  20. AppID string
  21. AppSecret string
  22. Token string
  23. EncodingAESKey string
  24. Cache cache.Cache
  25. }
  26. // NewWechat init
  27. func NewWechat(cfg *Config) *Wechat {
  28. context := new(context.Context)
  29. copyConfigToContext(cfg, context)
  30. return &Wechat{context}
  31. }
  32. func copyConfigToContext(cfg *Config, context *context.Context) {
  33. context.AppID = cfg.AppID
  34. context.AppSecret = cfg.AppSecret
  35. context.Token = cfg.Token
  36. context.EncodingAESKey = cfg.EncodingAESKey
  37. context.Cache = cfg.Cache
  38. context.SetAccessTokenLock(new(sync.RWMutex))
  39. context.SetJsAPITicketLock(new(sync.RWMutex))
  40. }
  41. //GetAccessToken 获取access_token
  42. func (wc *Wechat) GetAccessToken() (string, error) {
  43. return wc.Context.GetAccessToken()
  44. }
  45. // GetServer 消息管理
  46. func (wc *Wechat) GetServer(req *http.Request, writer http.ResponseWriter) *server.Server {
  47. wc.Context.Request = req
  48. wc.Context.Writer = writer
  49. return server.NewServer(wc.Context)
  50. }
  51. // GetMaterial 素材管理
  52. func (wc *Wechat) GetMaterial() *material.Material {
  53. return material.NewMaterial(wc.Context)
  54. }
  55. // GetOauth oauth2网页授权
  56. func (wc *Wechat) GetOauth(req *http.Request, writer http.ResponseWriter) *oauth.Oauth {
  57. wc.Context.Request = req
  58. wc.Context.Writer = writer
  59. return oauth.NewOauth(wc.Context)
  60. }
  61. // GetJs js-sdk配置
  62. func (wc *Wechat) GetJs(req *http.Request, writer http.ResponseWriter) *js.Js {
  63. wc.Context.Request = req
  64. wc.Context.Writer = writer
  65. return js.NewJs(wc.Context)
  66. }
  67. // GetMenu 菜单管理接口
  68. func (wc *Wechat) GetMenu(req *http.Request, writer http.ResponseWriter) *menu.Menu {
  69. wc.Context.Request = req
  70. wc.Context.Writer = writer
  71. return menu.NewMenu(wc.Context)
  72. }
  73. // GetUser 菜单管理接口
  74. func (wc *Wechat) GetUser(req *http.Request, writer http.ResponseWriter) *user.User {
  75. wc.Context.Request = req
  76. wc.Context.Writer = writer
  77. return user.NewUser(wc.Context)
  78. }