38 lines
1.0 KiB
Go
38 lines
1.0 KiB
Go
package handler
|
|
|
|
import (
|
|
"ecs/proto"
|
|
"ecs/proto/old"
|
|
"ecs/servers/center/logic"
|
|
"github.com/oylshe1314/framework/http"
|
|
"github.com/oylshe1314/framework/server"
|
|
)
|
|
|
|
type InnerHandler struct {
|
|
*Handler
|
|
|
|
centerManager *logic.CenterManager
|
|
}
|
|
|
|
func NewInnerHandler(srv server.Server, centerManager *logic.CenterManager) *InnerHandler {
|
|
return &InnerHandler{Handler: newHandler(srv), centerManager: centerManager}
|
|
}
|
|
|
|
func (this *InnerHandler) GetWechatAccessToken(msg *http.Message) {
|
|
var accessToken = this.centerManager.GetWechatAccessToken()
|
|
_ = msg.Reply(&old.MsgGetWechatAccessTokenAck{AccessToken: accessToken})
|
|
}
|
|
|
|
func (this *InnerHandler) RefreshWechatAccessToken(msg *http.Message) {
|
|
var req = new(old.MsgRefreshWechatAccessTokenReq)
|
|
var err = msg.Read(req)
|
|
if err != nil {
|
|
this.logger.Error("Read message error, ", err)
|
|
_ = msg.Reply(proto.RawErrMessageError)
|
|
return
|
|
}
|
|
|
|
var accessToken = this.centerManager.RefreshWechatAccessToken(req.AppletId)
|
|
_ = msg.Reply(&old.MsgRefreshWechatAccessTokenAck{AccessToken: accessToken})
|
|
}
|