diff --git a/rpc/user.go b/rpc/user.go index 5e0043c7216b6e80468294134805f3c0418f6b1c..bed7df43b90141e2205f53f810eb8dd6d77615de 100644 --- a/rpc/user.go +++ b/rpc/user.go @@ -274,6 +274,39 @@ func GetUserCpRelation(model *domain.Model, userId mysql.ID) (*CvCpRelation, err return nil, nil } +// 获取指定cp对 +func MGetUserCpPairs(model *domain.Model, userIds []mysql.ID) ([][2]mysql.ID, error) { + type Response struct { + Code int `json:"code"` + Message string `json:"message"` + Data [][2]mysql.ID `json:"data"` + } + var res [][2]mysql.ID + if len(userIds) <= 0 { + return res, nil + } + var userIdsStr []string + for _, userId := range userIds { + userIdsStr = append(userIdsStr, fmt.Sprintf("%d", userId)) + } + _url := fmt.Sprintf("%v://%v/inner/user/cp/pair", defaultUserServerScheme, getUserHost()) + resp, err := HttpGet(model, _url, nil, map[string][]string{ + "ids": userIdsStr, + }) + if err != nil { + model.Log.Errorf("MGetUserLevel fail:%v", err) + return res, err + } + response := new(Response) + if err = json.Unmarshal(resp, response); err != nil { + model.Log.Errorf("MGetUserLevel json fail:%v", err) + return res, err + } else { + res = response.Data + } + return res, nil +} + func getUserHost() string { l := len(UserServerHost) r := rand.Intn(l) // 随机一个