|
@@ -30,7 +30,7 @@ func GetUsersByIDs(ids []string) ([]*User, error) {
|
|
}
|
|
}
|
|
|
|
|
|
// 构建IN查询参数
|
|
// 构建IN查询参数
|
|
- query, args := buildInQuery("SELECT id, user_id, friend_ids, name, head, coin, create_time FROM users WHERE user_id IN", ids)
|
|
|
|
|
|
+ query, args := buildInQuery("SELECT id, user_id, friend_ids, name, head, coin, create_time,online_status FROM users WHERE user_id IN", ids)
|
|
|
|
|
|
// 执行查询
|
|
// 执行查询
|
|
rows, err := mysqlmgr.Query(query, args...)
|
|
rows, err := mysqlmgr.Query(query, args...)
|
|
@@ -54,6 +54,7 @@ func GetUsersByIDs(ids []string) ([]*User, error) {
|
|
&user.Head,
|
|
&user.Head,
|
|
&user.Coin,
|
|
&user.Coin,
|
|
&createTime,
|
|
&createTime,
|
|
|
|
+ &user.OnlineStatus,
|
|
)
|
|
)
|
|
if err != nil {
|
|
if err != nil {
|
|
return nil, fmt.Errorf("解析用户数据失败: %v", err)
|
|
return nil, fmt.Errorf("解析用户数据失败: %v", err)
|
|
@@ -334,7 +335,7 @@ func (u *User) GetAllFriend() ([]*User, error) {
|
|
|
|
|
|
// 3. 执行查询
|
|
// 3. 执行查询
|
|
query := fmt.Sprintf(`
|
|
query := fmt.Sprintf(`
|
|
- SELECT id, create_time, user_id, friend_ids, head, coin, name, account
|
|
|
|
|
|
+ SELECT id, create_time, user_id, friend_ids, head, coin, name, account ,online_status
|
|
FROM users
|
|
FROM users
|
|
WHERE user_id IN (%s)`, placeholders)
|
|
WHERE user_id IN (%s)`, placeholders)
|
|
|
|
|
|
@@ -359,6 +360,7 @@ func (u *User) GetAllFriend() ([]*User, error) {
|
|
&friend.Coin,
|
|
&friend.Coin,
|
|
&friend.Name,
|
|
&friend.Name,
|
|
&friend.Account,
|
|
&friend.Account,
|
|
|
|
+ &friend.OnlineStatus,
|
|
)
|
|
)
|
|
if err != nil {
|
|
if err != nil {
|
|
return nil, fmt.Errorf("解析好友数据失败: %v", err)
|
|
return nil, fmt.Errorf("解析好友数据失败: %v", err)
|