blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-05-24 13:59:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

getui

Browse Source
This commit is contained in:
wangchuxiao 2022-04-11 14:41:09 +08:00
parent 81a6e4b46c
commit edcc215774
2 changed files with 24 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
internal/push/getui/push.go
View File

@ -68,6 +68,7 @@ type Notification struct {
} }
type PushResp struct { type PushResp struct {
GetuiCommonResp
} }
func newGetuiClient() *Getui { func newGetuiClient() *Getui {
@ -81,14 +82,10 @@ func (g *Getui) Push(userIDList []string, alert, detailContent, platform, operat
log.NewError(operationID, utils.OperationIDGenerator(), "GetGetuiToken failed", err.Error()) log.NewError(operationID, utils.OperationIDGenerator(), "GetGetuiToken failed", err.Error())
} }
if token == "" || err != nil { if token == "" || err != nil {
token, expireTime, err := g.Auth(operationID, time.Now().UnixNano()/1e6) token, err = g.getTokenAndSave2Redis(operationID)
if err != nil { if err != nil {
return "", utils.Wrap(err, "Auth failed") log.NewError(operationID, utils.GetSelfFuncName(), "getTokenAndSave2Redis failed", err.Error())
} return "", utils.Wrap(err, "")
log.NewDebug(operationID, "getui", utils.GetSelfFuncName(), token, expireTime, err)
err = db.DB.SetGetuiToken(token, 60*60*23)
if err != nil {
return "", utils.Wrap(err, "Auth failed")
} }
} }
pushReq := PushReq{ pushReq := PushReq{
@ -107,8 +104,12 @@ func (g *Getui) Push(userIDList []string, alert, detailContent, platform, operat
if err != nil { if err != nil {
return "", utils.Wrap(err, "push failed") return "", utils.Wrap(err, "push failed")
} }
log.NewDebug(operationID, utils.GetSelfFuncName(), "resp: ", pushResp)
if pushResp.Code == 10001 {
_, _ = g.getTokenAndSave2Redis(operationID)
}
respBytes, err := json.Marshal(pushResp) respBytes, err := json.Marshal(pushResp)
return string(respBytes), err return string(respBytes), utils.Wrap(err, "")
} }
func (g *Getui) Auth(operationID string, timeStamp int64) (token string, expireTime int64, err error) { func (g *Getui) Auth(operationID string, timeStamp int64) (token string, expireTime int64, err error) {
@ -124,7 +125,6 @@ func (g *Getui) Auth(operationID string, timeStamp int64) (token string, expireT
Appkey: config.Config.Push.Getui.AppKey, Appkey: config.Config.Push.Getui.AppKey,
} }
respAuth := AuthResp{} respAuth := AuthResp{}
err = g.request(AuthURL, reqAuth, "", &respAuth, operationID) err = g.request(AuthURL, reqAuth, "", &respAuth, operationID)
if err != nil { if err != nil {
return "", 0, err return "", 0, err
@ -166,3 +166,16 @@ func (g *Getui) request(url string, content interface{}, token string, returnStr
} }
return nil return nil
} }
func (g *Getui) getTokenAndSave2Redis(operationID string) (token string, err error) {
token, expireTime, err := g.Auth(operationID, time.Now().UnixNano()/1e6)
if err != nil {
return "", utils.Wrap(err, "Auth failed")
}
log.NewDebug(operationID, "getui", utils.GetSelfFuncName(), token, expireTime, err)
err = db.DB.SetGetuiToken(token, 60*60*23)
if err != nil {
return "", utils.Wrap(err, "Auth failed")
}
return token, nil
}

4
pkg/common/http/http_resp.go
View File

@ -38,6 +38,6 @@ func RespHttp200(ctx *gin.Context, err error, data interface{}) {
} }
// warp error // warp error
func WrapError(err constant.ErrInfo, msg ...string) error { func WrapError(err constant.ErrInfo) error {
return status.Error(codes.Code(err.ErrCode), err.ErrMsg+msg[0]) return status.Error(codes.Code(err.ErrCode), err.ErrMsg)
} }