You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
40 lines
1.4 KiB
40 lines
1.4 KiB
package live_user |
|
|
|
import ( |
|
"context" |
|
"fmt" |
|
"github.com/pkg/errors" |
|
"go-common/app/interface/live/app-interface/conf" |
|
cDao "go-common/app/interface/live/app-interface/dao" |
|
liveUserV1 "go-common/app/service/live/live_user/api/liverpc/v1" |
|
"go-common/library/ecode" |
|
"go-common/library/log" |
|
rpcCtx "go-common/library/net/rpc/liverpc/context" |
|
"time" |
|
) |
|
|
|
func (d *Dao) GetDaHangHai(ctx context.Context, req *liveUserV1.NoteGetReq) (rep *liveUserV1.NoteGetResp_Data, err error) { |
|
// TODO 添加DaHangHai超时配置 |
|
getTagTimeout := time.Duration(conf.GetTimeout("DaHangHai", 50)) * time.Millisecond |
|
dahanghai, err := cDao.LiveUserApi.V1Note.Get(rpcCtx.WithTimeout(ctx, getTagTimeout), req) |
|
rep = &liveUserV1.NoteGetResp_Data{} |
|
if err != nil { |
|
log.Error("[GetDaHangHai]live_user.v1.note.get rpc error:%+v", err) |
|
err = errors.WithMessage(ecode.UserDHHRPCError, fmt.Sprintf("live_user.v1.note.get rpc error:%+v", err)) |
|
return |
|
} |
|
if dahanghai.Code != 0 { |
|
log.Error("[GetDaHangHai]live_user.v1.note response error:%+v,code:%d,msg:%s", err, dahanghai.Code, dahanghai.Msg) |
|
err = errors.WithMessage(ecode.UserDHHReturnError, fmt.Sprintf("live_user.v1.note response error,code:%d,msg:%s", dahanghai.Code, dahanghai.Msg)) |
|
return |
|
} |
|
|
|
if dahanghai.Data == nil { |
|
log.Error("[GetUserTagList]live_user.v1.note empty error") |
|
err = errors.WithMessage(ecode.UserDHHDataNil, "live_user.v1.note empty error") |
|
return |
|
} |
|
rep = dahanghai.Data |
|
|
|
return |
|
}
|
|
|