| | |
| | | "fmt" |
| | | "google.golang.org/grpc" |
| | | "google.golang.org/grpc/credentials/insecure" |
| | | "strings" |
| | | "time" |
| | | ) |
| | | |
| | |
| | | return rsp.Result |
| | | } |
| | | |
| | | func SyncUserInfo(uuid string) { |
| | | func SyncUserInfo(uuid []string) { |
| | | cli := user.NewUserServiceClient(userConn) |
| | | var users = []*user.User{ |
| | | {Uuid: uuid}, |
| | | var users []*user.User |
| | | for _, id := range uuid { |
| | | users = append(users, &user.User{ |
| | | Uuid: id, |
| | | }) |
| | | } |
| | | ctx, cancel := context.WithTimeout(context.Background(), time.Second) |
| | | defer cancel() |
| | |
| | | |
| | | for _, member := range r.List { |
| | | err = model.NewUserSearch(nil).Upsert(model.User{ |
| | | UUID: member.Uuid, |
| | | Username: member.Username, |
| | | UserType: constvar.UserType(member.Usertype), |
| | | NickName: member.Nickname, |
| | | UUID: member.Uuid, |
| | | Username: member.Username, |
| | | UserType: constvar.UserType(member.Usertype), |
| | | NickName: member.Nickname, |
| | | SubUserIds: strings.Join(member.SubUserIds, ","), |
| | | }) |
| | | if err != nil { |
| | | logx.Errorf("sync user error: %v", err.Error()) |