feat:cp_cv

_const/enum/res_e/enum.go

@@ -5,55 +5,16 @@ import "git.hilo.cn/hilo-common/resource/mysql"
 type MsgIdType = uint
 
 const (
-	DEFAULT_LANG = "en"
+	DefaultLang = "en"
 )
 
 type ResMedalType = mysql.Type
-
-const (
-	Wealth        ResMedalType = 1
-	Charm         ResMedalType = 2
-	LoveForAll    ResMedalType = 3
-	StartForAll   ResMedalType = 4
-	MoonForAll    ResMedalType = 5
-	MarryMe       ResMedalType = 6
-	RoomRocket    ResMedalType = 7
-	Actity        ResMedalType = 8
-	FruitKing     ResMedalType = 9
-	BoxKing       ResMedalType = 10
-	Helicopter    ResMedalType = 11
-	Roadster      ResMedalType = 12
-	Watermelon    ResMedalType = 13
-	Kiss          ResMedalType = 14
-	Love          ResMedalType = 15
-	Chick         ResMedalType = 16
-	SportsCar     ResMedalType = 17
-	Rocket        ResMedalType = 18
-	Tower         ResMedalType = 19
-	Eagle         ResMedalType = 20
-	Lion          ResMedalType = 21
-	Vacation      ResMedalType = 22
-	RomanticNight ResMedalType = 23
-	SweetCouple   ResMedalType = 24
-	Castle        ResMedalType = 25
-	WeddingCar    ResMedalType = 26
-	VideoChat     ResMedalType = 27
-)
-
 type ResMedalScope = mysql.Type
-
-const (
-	//私有，只能时管理人发放
-	Private ResMedalScope = 1
-	//公有，自己获取
-	Public ResMedalScope = 2
-)
-
 type ResNameplateType = mysql.Type
 type ResNameplateObtainType = mysql.Type
 type ResNameplateScope = mysql.Type
-
 type ResUserBag = mysql.Type
+type ResPropertyAvatarType = mysql.Type
 
 const (
 	ResUserBagGift ResUserBag = 1 // 背包道具-礼物

cv/cp_cv/rank.go

+package cp_cv
+
+import "hilo-user/cv/user_cv"
+
+type CvCp struct {
+	CpId    uint64              `json:"cpId"`    // cpId
+	User1   *user_cv.CvUserBase `json:"user1"`   // user1
+	User2   *user_cv.CvUserBase `json:"user2"`   // user2
+	Score   uint32              `json:"score"`   // 分值
+	Ranking int                 `json:"ranking"` // 排名
+}

cv/headwear_cv/headwear.go

+package headwear_cv
+
+import (
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"gorm.io/gorm"
+	"hilo-user/_const/enum/headwear_e"
+	"hilo-user/domain/model/res_m"
+	"hilo-user/domain/model/user_m"
+	"hilo-user/myerr"
+	"strconv"
+	"time"
+)
+
+type CvHeadwear struct {
+	Id        uint64    `json:"id"`
+	Using     bool      `json:"using"`
+	PicUrl    mysql.Str `json:"picUrl"`
+	EffectUrl mysql.Str `json:"effectUrl"`
+	TimeLeft  int64     `json:"timeLeft"`	// 离到期还有多少秒（过期则是负数）
+}
+
+type CvHeadwearDiamond struct {
+	Id         uint64 `json:"id"`
+	PicUrl     string `json:"picUrl"`
+	EffectUrl  string `json:"effectUrl"`
+	DiamondNum uint32 `json:"diamondNum"`
+	Second     uint32 `json:"second"`
+	Days       string `json:"days"`
+}
+
+func GetCvHeadwearDiamond(pageSize int, pageIndex int) ([]CvHeadwearDiamond, error) {
+	headwearDiamonds := []CvHeadwearDiamond{}
+	if err := mysql.Db.Raw("SELECT d.id, r.pic_url, r.effect_url, d.`second`, d.diamond_num from res_headwear r, res_headwear_diamond d where r.id = d.res_headwear_id and d.`status` = ? ORDER BY d.diamond_num asc LIMIT ?, ?", mysql.USER, (pageIndex-1)*pageSize, pageSize).Scan(&headwearDiamonds).Error; err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+	for i, _ := range headwearDiamonds {
+		headwearDiamonds[i].Days = strconv.FormatUint(uint64(headwearDiamonds[i].Second/(24*60*60)), 10)
+	}
+	return headwearDiamonds, nil
+}
+
+func GetHeadwearList(db *gorm.DB, userId uint64) ([]CvHeadwear, error) {
+	rows := make([]user_m.UserHeadwear, 0)
+	if err := db.Where(&user_m.UserHeadwear{
+		UserId: userId,
+	}).Where("end_time >= ?", time.Now()).Order("`using` DESC, updated_time DESC").Find(&rows).Error; err != nil {
+		return nil, err
+	}
+	resHwMap, err := res_m.GetResHeadwearMap(db)
+	if err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+
+	result := make([]CvHeadwear, 0)
+	now := time.Now()
+	hasUsing := false
+	for _, i := range rows {
+		//  TODO: 没过期并且有设置using的，才算是，因为写入方不维护using状态的更新
+		isUsing := i.Using == headwear_e.YesUsing && i.EndTime.After(now)
+		result = append(result, CvHeadwear{
+			Id:        i.HeadwearId,
+			PicUrl:    resHwMap[i.HeadwearId].PicUrl,
+			EffectUrl: resHwMap[i.HeadwearId].EffectUrl,
+			Using:     isUsing,
+			TimeLeft:  i.EndTime.Unix() - now.Unix(),
+		})
+		if isUsing {
+			hasUsing = true
+		}
+	}
+	// 如果没有一个using，则找第一个没过期的充当
+	if ! hasUsing {
+		for i, e := range result {
+			if e.TimeLeft > 0 {
+				result[i].Using = true
+				break
+			}
+		}
+	}
+
+	return result, nil
+}
+
+func GetCvHeadwear(userId uint64) (*CvHeadwear, error) {
+	userHeadwear := user_m.UserHeadwear{}
+	if err := mysql.Db.Model(&user_m.UserHeadwear{}).Where(&user_m.UserHeadwear{
+		UserId: userId,
+	}).Where("end_time >= ?", time.Now()).Order("`using` DESC, updated_time DESC").First(&userHeadwear).Error; err != nil {
+		if err == gorm.ErrRecordNotFound {
+			return nil, nil
+		} else {
+			return nil, myerr.WrapErr(err)
+		}
+	}
+	resHeadwear := res_m.ResHeadwear{}
+	if err := mysql.Db.Model(&res_m.ResHeadwear{}).First(&resHeadwear, userHeadwear.HeadwearId).Error; err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+	return &CvHeadwear{
+		Id:        userHeadwear.HeadwearId,
+		PicUrl:    resHeadwear.PicUrl,
+		EffectUrl: resHeadwear.EffectUrl,
+		Using:     userHeadwear.Using == headwear_e.YesUsing,
+	}, nil
+}
+
+func BatchGetCvHeadwears(userIds []uint64) (map[uint64]CvHeadwear, error) {
+	if len(userIds) == 0 {
+		return map[uint64]CvHeadwear{}, nil
+	}
+	rows := make([]user_m.UserHeadwear, 0)
+	//asc 进行覆盖，保证了updated_time 最大的是最后的输出
+	if err := mysql.Db.Where("user_id IN ?", userIds).Where("end_time >= ?", time.Now()).
+		Order("`using` ASC, updated_time ASC").Find(&rows).Error; err != nil {
+		return nil, err
+	}
+	//
+	resHeadwearIds := make([]uint64, 0, len(rows))
+	for i, _ := range rows {
+		resHeadwearIds = append(resHeadwearIds, rows[i].HeadwearId)
+	}
+	//获取头饰资源，然后转换成map结构
+	resHeadwearMap := map[uint64]res_m.ResHeadwear{}
+	resHeadwears := []res_m.ResHeadwear{}
+	if err := mysql.Db.Where("id IN ?", resHeadwearIds).Find(&resHeadwears).Error; err != nil {
+		return nil, err
+	}
+	for i, _ := range resHeadwears {
+		resHeadwearMap[resHeadwears[i].ID] = resHeadwears[i]
+	}
+
+	result := make(map[uint64]CvHeadwear, 0)
+	for _, r := range rows {
+		headwear, flag := resHeadwearMap[r.HeadwearId]
+		if flag {
+			result[r.UserId] = CvHeadwear{
+				Id:        headwear.ID,
+				PicUrl:    headwear.PicUrl,
+				EffectUrl: headwear.EffectUrl,
+				Using:     r.Using == headwear_e.YesUsing,
+			}
+		}
+
+	}
+	return result, nil
+
+}
+

cv/medal_cv/medal.go

+package medal_cv
+
+import (
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"gorm.io/gorm"
+	"hilo-user/domain/model/res_m"
+	"sort"
+)
+
+type CvMedal struct {
+	Id        uint32    `json:"id"`
+	PicUrl    mysql.Str `json:"picUrl"`
+	EffectUrl mysql.Str `json:"effectUrl"`
+}
+
+type ReturnGroupMedal struct {
+	PicUrl  string `json:"picUrl"`
+	SvgaUrl string `json:"svgaUrl"`
+}
+
+type PicElement struct {
+	PicUrl  string `json:"picUrl"`
+	SvgaUrl string `json:"svgaUrl"`
+}
+
+func GetMedalInfoMap(db *gorm.DB, medals map[uint64][]uint32) (map[uint64][]uint32, map[uint64][]CvMedal, error) {
+	resMedals, err := res_m.MedalGetAllMap(db)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	medalIds := make(map[uint64][]uint32)
+	medalMap := make(map[uint64][]CvMedal, 0)
+
+	// 只选择合法的勋章
+	for u, i := range medals {
+		medalIds[u] = make([]uint32, 0)
+		medalMap[u] = make([]CvMedal, 0)
+
+		for _, j := range i {
+			if e, ok := resMedals[j]; ok {
+				medalIds[u] = append(medalIds[u], j)
+				medalMap[u] = append(medalMap[u], CvMedal{
+					Id:        j,
+					PicUrl:    e.PicUrl,
+					EffectUrl: e.SvgaUrl,
+				})
+			}
+		}
+		// 按照勋章排序
+		sort.Slice(medalIds[u], func(i, j int) bool {
+			return resMedals[medalIds[u][i]].Sort < resMedals[medalIds[u][j]].Sort
+		})
+
+		sort.Slice(medalMap[u], func(i, j int) bool {
+			return resMedals[medalMap[u][i].Id].Sort < resMedals[medalMap[u][j].Id].Sort
+		})
+	}
+	return medalIds, medalMap, nil
+}

cv/noble_cv/noble.go

+package noble_cv
+
+import (
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"gorm.io/gorm"
+	"hilo-user/domain/model/noble_m"
+	"hilo-user/myerr"
+	"time"
+)
+
+type NobleConfig struct {
+	Level         uint16 `json:"level"`         // 贵族等级
+	PurchasePrice uint32 `json:"purchasePrice"` // 购买价格
+	RenewalPrice  uint32 `json:"renewalPrice"`  // 续费价格
+	Duration      uint16 `json:"duration"`      // 有效期（天）
+	PicUrl        string `json:"picUrl"`        // 大图url
+	DailyGold     uint   `json:"dailyGold"`     // 每日登录领取的金币
+	RideId        uint64 `json:"rideId"`        // 赠送的勋章ID
+	HeaddressId   uint64 `json:"headdressId"`   // 赠送的头饰ID
+	Privileges    []int  `json:"privileges"`    // 权益列表
+}
+
+type NobleInfo struct {
+	Level      uint16 `json:"level"`      // 等级
+	EndTime    int64  `json:"endTime"`    // 截止时间
+	RemainTime int64  `json:"remainTime"` // 还有多久（秒）过期，可以是负数
+	Price      uint32 `json:"price"`      // 购买或续费价格
+}
+
+type CvNoble struct {
+	Level   uint16 `json:"level"`
+	EndTime int64  `json:"endTime"`
+}
+
+func GetCvNoble(userId uint64) (CvNoble, error) {
+	userNoble := noble_m.UserNoble{}
+	if err := mysql.Db.Model(&noble_m.UserNoble{}).Where(&noble_m.UserNoble{
+		UserId: userId,
+	}).Where("end_time > ?", time.Now()).Order("level desc").First(&userNoble).Error; err != nil {
+		if err == gorm.ErrRecordNotFound {
+			return CvNoble{
+				Level:   0,
+				EndTime: 0,
+			}, nil
+		} else {
+			return CvNoble{
+				Level:   0,
+				EndTime: 0,
+			}, myerr.WrapErr(err)
+		}
+	} else {
+		return CvNoble{
+			Level:   userNoble.Level,
+			EndTime: userNoble.EndTime.Unix(),
+		}, nil
+	}
+}
+
+func GetCvNobles(userIds []uint64) (map[uint64]CvNoble, error) {
+	if len(userIds) == 0 {
+		return map[uint64]CvNoble{}, nil
+	}
+	var userNobles []noble_m.UserNoble
+	if err := mysql.Db.Model(&noble_m.UserNoble{}).Where("user_id in (?)", userIds).Where("end_time > ?", time.Now()).Order("level asc").Find(&userNobles).Error; err != nil {
+		return nil, err
+	}
+
+	userNobleMap := map[uint64]noble_m.UserNoble{}
+	for i, _ := range userNobles {
+		userNobleMap[userNobles[i].UserId] = userNobles[i]
+	}
+
+	result := map[uint64]CvNoble{}
+	for _, r := range userIds {
+		userNoble, flag := userNobleMap[r]
+		if flag {
+			result[r] = CvNoble{
+				Level:   userNoble.Level,
+				EndTime: userNoble.EndTime.Unix(),
+			}
+		} else {
+			result[r] = CvNoble{
+				Level:   0,
+				EndTime: 0,
+			}
+		}
+	}
+	return result, nil
+}

cv/property_cv/property.go

+package property_cv
+
+import (
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"gorm.io/gorm"
+	"hilo-user/_const/enum/headwear_e"
+	"hilo-user/domain/model/res_m"
+	"hilo-user/domain/model/user_m"
+	"hilo-user/myerr"
+	"strconv"
+	"time"
+)
+
+type CvProperty struct {
+	Id             uint64    `json:"id"`
+	PicUrl         mysql.Str `json:"picUrl"`
+	EffectUrl      mysql.Str `json:"effectUrl"`
+	Using          bool      `json:"using"`
+	TimeLeft       int64     `json:"timeLeft"` // 离到期还有多少秒（过期则是负数）
+	SenderAvatar   string    `json:"senderAvatar"`
+	ReceiverAvatar string    `json:"receiverAvatar"`
+}
+
+type CvPropertyDiamond struct {
+	Id         uint64 `json:"id"`
+	PicUrl     string `json:"picUrl"`
+	EffectUrl  string `json:"effectUrl"`
+	DiamondNum uint32 `json:"diamondNum"`
+	Second     uint32 `json:"second"`
+	Days       string `json:"days"`
+}
+
+func GetCvPropertyDiamond(pageSize int, pageIndex int) ([]CvPropertyDiamond, error) {
+	propertyDiamonds := []CvPropertyDiamond{}
+	if err := mysql.Db.Raw("select d.id, r.pic_url, r.effect_url, d.`second`, d.diamond_num from res_property r, res_property_diamond d where r.id = d.res_property_id and d.`status` = ? ORDER BY d.diamond_num ASC LIMIT ?, ?", mysql.USER, (pageIndex-1)*pageSize, pageSize).Scan(&propertyDiamonds).Error; err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+	for i, _ := range propertyDiamonds {
+		propertyDiamonds[i].Days = strconv.FormatUint(uint64(propertyDiamonds[i].Second/(24*60*60)), 10)
+	}
+	return propertyDiamonds, nil
+}
+
+func GetPropertyById(resPropertyId mysql.ID) (CvProperty, error) {
+	resProperty := res_m.ResProperty{}
+	if err := mysql.Db.Model(&res_m.ResProperty{}).First(&resProperty, resPropertyId).Error; err != nil {
+		return CvProperty{}, err
+	}
+
+	//获取座驾头像
+	propertieAvatarMap, err := (&res_m.ResPropertyAvatar{}).GetAll(mysql.Db)
+	if err != nil {
+		return CvProperty{}, err
+	}
+
+	userIds := []uint64{}
+	for _, value := range propertieAvatarMap {
+		if value.SendUserId > 0 {
+			userIds = append(userIds, value.SendUserId)
+		}
+		if value.ReceiverUserId > 0 {
+			userIds = append(userIds, value.ReceiverUserId)
+		}
+	}
+	//获取用户信息
+	users := []user_m.User{}
+	if err := mysql.Db.Model(&user_m.User{}).Where("id in (?)", userIds).Find(&users).Error; err != nil {
+		return CvProperty{}, myerr.WrapErr(err)
+	}
+	userAvatarMap := map[mysql.ID]string{}
+	for _, r := range users {
+		userAvatarMap[r.ID] = r.Avatar
+	}
+	var senderAvatar string = ""
+	var receiverAvatar string = ""
+
+	if propertieAvatar, flag := propertieAvatarMap[resProperty.ID]; flag {
+		if propertieAvatar.SendUserId > 0 {
+			if avatar, flag := userAvatarMap[propertieAvatar.SendUserId]; flag {
+				senderAvatar = avatar
+			}
+		}
+		if propertieAvatar.ReceiverUserId > 0 {
+			if avatar, flag := userAvatarMap[propertieAvatar.ReceiverUserId]; flag {
+				receiverAvatar = avatar
+			}
+		}
+	}
+	return CvProperty{
+		Id:             resProperty.ID,
+		PicUrl:         resProperty.PicUrl,
+		EffectUrl:      resProperty.EffectUrl,
+		SenderAvatar:   senderAvatar,
+		ReceiverAvatar: receiverAvatar,
+	}, nil
+}
+
+func GetPropertyAll(db *gorm.DB) (map[uint64]CvProperty, error) {
+	rp := res_m.ResProperty{}
+	properties, err := rp.GetAll(mysql.Db)
+	if err != nil {
+		return nil, err
+	}
+
+	//获取座驾头像
+	propertieAvatarMap, err := (&res_m.ResPropertyAvatar{}).GetAll(mysql.Db)
+
+	userIds := []uint64{}
+	for _, value := range propertieAvatarMap {
+		if value.SendUserId > 0 {
+			userIds = append(userIds, value.SendUserId)
+		}
+		if value.ReceiverUserId > 0 {
+			userIds = append(userIds, value.ReceiverUserId)
+		}
+	}
+	//获取用户信息
+	users := []user_m.User{}
+	if err := db.Model(&user_m.User{}).Where("id in (?)", userIds).Find(&users).Error; err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+	userAvatarMap := map[mysql.ID]string{}
+	for _, r := range users {
+		userAvatarMap[r.ID] = r.Avatar
+	}
+
+	result := map[uint64]CvProperty{}
+	for _, r := range properties {
+
+		var senderAvatar string = ""
+		var receiverAvatar string = ""
+		if propertieAvatar, flag := propertieAvatarMap[r.ID]; flag {
+			if propertieAvatar.SendUserId > 0 {
+				if avatar, flag := userAvatarMap[propertieAvatar.SendUserId]; flag {
+					senderAvatar = avatar
+				}
+			}
+			if propertieAvatar.ReceiverUserId > 0 {
+				if avatar, flag := userAvatarMap[propertieAvatar.ReceiverUserId]; flag {
+					receiverAvatar = avatar
+				}
+			}
+		}
+
+		result[r.ID] = CvProperty{
+			Id:             r.ID,
+			PicUrl:         r.PicUrl,
+			EffectUrl:      r.EffectUrl,
+			SenderAvatar:   senderAvatar,
+			ReceiverAvatar: receiverAvatar,
+		}
+	}
+	return result, nil
+}
+
+func GetPropertyList(db *gorm.DB, userId uint64) ([]CvProperty, error) {
+	rows := make([]user_m.UserProperty, 0)
+	if err := db.Where(&user_m.UserProperty{
+		UserId: userId,
+	}).Order("`using` DESC, updated_time DESC").Find(&rows).Error; err != nil {
+		return nil, err
+	}
+	rp := res_m.ResProperty{}
+	properties, err := rp.GetAll(mysql.Db)
+	if err != nil {
+		return nil, err
+	}
+
+	//获取座驾头像
+	propertieAvatarMap, err := (&res_m.ResPropertyAvatar{}).GetAll(mysql.Db)
+
+	userIds := []uint64{}
+	for _, value := range propertieAvatarMap {
+		if value.SendUserId > 0 {
+			userIds = append(userIds, value.SendUserId)
+		}
+		if value.ReceiverUserId > 0 {
+			userIds = append(userIds, value.ReceiverUserId)
+		}
+	}
+	//获取用户信息
+	users := []user_m.User{}
+	if err := db.Model(&user_m.User{}).Where("id in (?)", userIds).Find(&users).Error; err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+	userAvatarMap := map[mysql.ID]string{}
+	for _, r := range users {
+		userAvatarMap[r.ID] = r.Avatar
+	}
+
+	result := make([]CvProperty, 0)
+	now := time.Now()
+	hasUsing := false
+	for _, i := range rows {
+		//  TODO: 没过期并且有设置using的，才算是，因为写入方不维护using状态的更新
+		isUsing := i.Using == headwear_e.YesUsing && i.EndTime.After(now)
+		var senderAvatar string = ""
+		var receiverAvatar string = ""
+		if propertieAvatar, flag := propertieAvatarMap[i.PropertyId]; flag {
+			if propertieAvatar.SendUserId > 0 {
+				if avatar, flag := userAvatarMap[propertieAvatar.SendUserId]; flag {
+					senderAvatar = avatar
+				}
+			}
+			if propertieAvatar.ReceiverUserId > 0 {
+				if avatar, flag := userAvatarMap[propertieAvatar.ReceiverUserId]; flag {
+					receiverAvatar = avatar
+				}
+			}
+		}
+		result = append(result, CvProperty{
+			Id:             i.PropertyId,
+			PicUrl:         properties[i.PropertyId].PicUrl,
+			EffectUrl:      properties[i.PropertyId].EffectUrl,
+			Using:          isUsing,
+			TimeLeft:       i.EndTime.Unix() - now.Unix(),
+			SenderAvatar:   senderAvatar,
+			ReceiverAvatar: receiverAvatar,
+		})
+		if isUsing {
+			hasUsing = true
+		}
+	}
+	// 如果没有一个using，则找第一个没过期的充当
+	if !hasUsing {
+		for i, e := range result {
+			if e.TimeLeft > 0 {
+				result[i].Using = true
+				break
+			}
+		}
+	}
+	return result, nil
+}
+
+type PropertyExt struct {
+	Id             uint64
+	PicUrl         mysql.Str
+	EffectUrl      mysql.Str
+	Using          bool
+	TimeLeft       int64 // 离到期还有多少秒（过期则是负数）
+	SenderAvatar   string
+	ReceiverAvatar string
+}
+
+func GetExtendedProperty(db *gorm.DB) (map[uint64]PropertyExt, error) {
+	rp := res_m.ResProperty{}
+	properties, err := rp.GetAll(mysql.Db)
+	if err != nil {
+		return nil, err
+	}
+
+	//获取座驾头像
+	propertieAvatarMap, err := (&res_m.ResPropertyAvatar{}).GetAll(mysql.Db)
+
+	userIds := []uint64{}
+	for _, value := range propertieAvatarMap {
+		if value.SendUserId > 0 {
+			userIds = append(userIds, value.SendUserId)
+		}
+		if value.ReceiverUserId > 0 {
+			userIds = append(userIds, value.ReceiverUserId)
+		}
+	}
+	//获取用户信息
+	users := []user_m.User{}
+	if err := db.Model(&user_m.User{}).Where("id in (?)", userIds).Find(&users).Error; err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+	userAvatarMap := map[mysql.ID]string{}
+	for _, r := range users {
+		userAvatarMap[r.ID] = r.Avatar
+	}
+
+	result := map[uint64]PropertyExt{}
+	for _, r := range properties {
+
+		var senderAvatar string = ""
+		var receiverAvatar string = ""
+		if propertieAvatar, flag := propertieAvatarMap[r.ID]; flag {
+			if propertieAvatar.SendUserId > 0 {
+				if avatar, flag := userAvatarMap[propertieAvatar.SendUserId]; flag {
+					senderAvatar = avatar
+				}
+			}
+			if propertieAvatar.ReceiverUserId > 0 {
+				if avatar, flag := userAvatarMap[propertieAvatar.ReceiverUserId]; flag {
+					receiverAvatar = avatar
+				}
+			}
+		}
+
+		result[r.ID] = PropertyExt{
+			Id:             r.ID,
+			PicUrl:         r.PicUrl,
+			EffectUrl:      r.EffectUrl,
+			SenderAvatar:   senderAvatar,
+			ReceiverAvatar: receiverAvatar,
+		}
+	}
+	return result, nil
+}

cv/user_cv/user.go

 package user_cv
 
-import "hilo-user/domain/model/user_m"
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"git.hilo.cn/hilo-common/mylogrus"
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"git.hilo.cn/hilo-common/rpc"
+	"gorm.io/gorm"
+	"hilo-user/cv/headwear_cv"
+	"hilo-user/cv/medal_cv"
+	"hilo-user/cv/noble_cv"
+	"hilo-user/cv/property_cv"
+	"hilo-user/domain/model/noble_m"
+	"hilo-user/domain/model/res_m"
+	"hilo-user/domain/model/user_m"
+	"hilo-user/myerr"
+)
 
 type UserTiny struct {
 	Id           uint64 `json:"id,omitempty"`
@@ -27,3 +41,287 @@ func UserToTiny(user user_m.User) UserTiny {
 		IsPrettyCode: user.IsPrettyCode(),
 	}
 }
+
+//用户基本信息
+type CvUserBase struct {
+	//不会有返回值
+	Id *mysql.ID `json:"id,omitempty"`
+	//头像,不存在为nil
+	Avatar *string `json:"avatar"`
+	//是否默认头像 true：是 false:不是
+	DefaultAvatar *bool `json:"defaultAvatar"`
+	//用户对外ID
+	ExternalId *string `json:"externalId"`
+	//昵称,不存在为nil
+	Nick *string `json:"nick"`
+	//签名,不存在为nil
+	Description *string `json:"description"`
+	//性别 1：男 2：女,不存在为nil
+	Sex *uint8 `json:"sex"`
+	//国家,不存在为nil
+	Country *string `json:"country"`
+	//国旗图标,不存在为nil
+	CountryIcon *string `json:"countryIcon"`
+	//邀请码
+	Code         *string `json:"code"`
+	IsPrettyCode bool    `json:"isPrettyCode"` // 是否靓号
+	IsLogout     bool    `json:"isLogout"`     //是否注销
+	//生日，如果是其它人用户信息，年龄则按照是否展示显示，如果是本人，年龄则按照是否存在展示
+	Birthday *uint64 `json:"birthday"`
+	//是否展示年龄, 是本人才有数据，看其他用户均为nil
+	IsShowAge *uint8 `json:"isShowAge"`
+	//是否工会成员, 只有是自己查自己，这个才有值，其它全为nil, 20220329 数据开放：原因：产品1对1视频聊天中，公会用户视频需要送礼物。改为: 全部人可以知道是否是公会用户。
+	IsTradeUnion *bool `json:"isTradeUnion"`
+	//是否代理管理员, 只有自己查自己的时候才有值，其他情况为nil
+	IsAgentMgr *bool `json:"isAgentMgr"`
+	//工会成员，是否开启了，匹配通知，只有 isTradeUnion值为true，这里才有值,
+	IsTradeUnionMatchNotification *bool `json:"isTradeUnionMatchNotification"`
+	//是否VIP用户
+	IsVip bool `json:"isVip"`
+	//是否是官方人员
+	IsOfficialStaff bool `json:"isOfficialStaff"`
+	//VIP用户过期时间(只有自己查询自己，才返回)
+	VipExpireTime *int64                  `json:"vipExpireTime"`
+	Svip          rpc.CvSvip              `json:"svip"`      // svip结构,等级+权限
+	MedalInfo     []medal_cv.CvMedal      `json:"medalInfo"` // 勋章列表
+	Headwear      *headwear_cv.CvHeadwear `json:"headwear"`  // 当前使用的头饰
+	Ride          property_cv.CvProperty  `json:"ride"`      // 当前使用的座驾
+	Noble         noble_cv.CvNoble        `json:"noble"`     // 当前的
+}
+
+//批量获取用户基本信息
+func GetUserBases(userIds []mysql.ID, myUserId mysql.ID) ([]*CvUserBase, error) {
+	if len(userIds) == 0 {
+		return []*CvUserBase{}, nil
+	}
+	var users []user_m.User
+	if err := mysql.Db.Model(&user_m.User{}).Where("id in (?)", userIds).Find(&users).Error; err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+	vips, err := user_m.BatchGetVips(userIds)
+	if err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+	svips, err := rpc.MGetUserSvip(domain.CreateModelNil(), userIds)
+	if err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+
+	headwearMap, err := headwear_cv.BatchGetCvHeadwears(userIds)
+	if err != nil {
+		return nil, err
+	}
+
+	logger := mylogrus.MyLog.WithField("func", "GetUserBases")
+	medals, err := user_m.BatchGetUserMedalMerge(logger, mysql.Db, userIds)
+	if err != nil {
+		return nil, err
+	}
+
+	medals, medalInfo, err := getMedalInfoMap(mysql.Db, medals)
+	if err != nil {
+		return nil, err
+	}
+
+	up := user_m.UserProperty{}
+	rides, err := up.BatchGet(mysql.Db, userIds)
+	if err != nil {
+		return nil, err
+	}
+
+	//rp := res_m.ResProperty{}
+	//properties, err := rp.GetAll(mysql.Db)
+	properties, err := GetPropertyAll(mysql.Db)
+	if err != nil {
+		return nil, err
+	}
+
+	nobles, err := noble_m.BatchGetActiveNoble(domain.CreateModelNil(), userIds)
+	if err != nil {
+		return nil, err
+	}
+
+	superManagerMap, err := GetSuperManagerMap(userIds)
+	if err != nil {
+		return nil, err
+	}
+
+	cvUserBases := []*CvUserBase{}
+	for i := 0; i < len(users); i++ {
+		user := users[i]
+		invisible := IfLogout(user.LogoutTime)
+		invisibleAvatar := ""
+		invisibleNick := user.Code
+		//for _, p := range svips[user.ID].Privileges {
+		//	if p.Type == 17 && p.UserSwitch { // 神秘人特权
+		//		invisible = true
+		//		invisibleAvatar, invisibleNick = rpc.ReplaceSvipAvatarNick(invisibleAvatar, invisibleNick, svips[user.ID].Privileges)
+		//	}
+		//}
+		cvUserBase := &CvUserBase{
+			Id:              &user.ID,
+			Avatar:          StrNil(IfLogoutStr(invisible, invisibleAvatar, user.Avatar)),
+			DefaultAvatar:   &user.DefaultAvatar,
+			ExternalId:      StrToString(&user.ExternalId),
+			Nick:            StrNil(IfLogoutNick(invisible, invisibleNick, user.Nick)),
+			Description:     StrNil(IfLogoutStr(invisible, "", user.Description)),
+			Sex:             TypeToUint8(&user.Sex),
+			Country:         StrNil(user.Country),
+			CountryIcon:     StrNil(user.CountryIcon),
+			Code:            StrToString(&user.Code),
+			IsPrettyCode:    user.IsPrettyCode(),
+			IsVip:           vips[user.ID] != nil,
+			IsOfficialStaff: superManagerMap[user.ID],
+			MedalInfo:       IfLogoutMedalInfo(invisible, []medal_cv.CvMedal{}, medalInfo[user.ID]),
+			Ride: IfLogoutRide(IfLogout(user.LogoutTime), property_cv.CvProperty{}, property_cv.CvProperty{
+				Id:             rides[user.ID],
+				PicUrl:         properties[rides[user.ID]].PicUrl,
+				EffectUrl:      properties[rides[user.ID]].EffectUrl,
+				Using:          true,
+				SenderAvatar:   properties[rides[user.ID]].SenderAvatar,
+				ReceiverAvatar: properties[rides[user.ID]].ReceiverAvatar,
+			}),
+			Noble: noble_cv.CvNoble{
+				Level:   nobles[user.ID].Level,
+				EndTime: nobles[user.ID].EndTime.Unix(),
+			},
+		}
+		if cvUserBase.Noble.Level <= 0 {
+			cvUserBase.Noble.EndTime = 0
+		}
+		//
+		if headwear, flag := headwearMap[user.ID]; flag {
+			cvUserBase.Headwear = IfLogoutHeadwear(IfLogout(user.LogoutTime), nil, &headwear)
+		}
+
+		if user.ID == myUserId {
+			cvUserBase.VipExpireTime = vips[user.ID]
+			cvUserBase.IsShowAge = TypeToUint8(&user.IsShowAge)
+			cvUserBase.Birthday = BirthdayToUint64(&user.Birthday)
+		} else if user.IsShowAge == mysql.OPEN {
+			cvUserBase.Birthday = BirthdayToUint64(&user.Birthday)
+		}
+		cvUserBase.Svip = svips[user.ID]
+
+		cvUserBases = append(cvUserBases, cvUserBase)
+	}
+	return cvUserBases, nil
+}
+
+func getMedalInfoMap(db *gorm.DB, medals map[uint64][]uint32) (map[uint64][]uint32, map[uint64][]medal_cv.CvMedal, error) {
+	resMedals, err := res_m.MedalGetAllMap(db)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	medalIds := make(map[uint64][]uint32)
+	medalMap := make(map[uint64][]medal_cv.CvMedal, 0)
+
+	// 只选择合法的勋章
+	for u, i := range medals {
+		medalIds[u] = make([]uint32, 0)
+		medalMap[u] = make([]medal_cv.CvMedal, 0)
+
+		for _, j := range i {
+			if e, ok := resMedals[j]; ok {
+				medalIds[u] = append(medalIds[u], j)
+				medalMap[u] = append(medalMap[u], medal_cv.CvMedal{
+					Id:        j,
+					PicUrl:    e.PicUrl,
+					EffectUrl: e.SvgaUrl,
+				})
+			}
+		}
+	}
+	return medalIds, medalMap, nil
+}
+
+func GetPropertyAll(db *gorm.DB) (map[uint64]property_cv.CvProperty, error) {
+	rp := res_m.ResProperty{}
+	properties, err := rp.GetAll(mysql.Db)
+	if err != nil {
+		return nil, err
+	}
+
+	//获取座驾头像
+	propertyAvatarMap, err := (&res_m.ResPropertyAvatar{}).GetAll(mysql.Db)
+
+	var userIds []uint64
+	for _, value := range propertyAvatarMap {
+		if value.SendUserId > 0 {
+			userIds = append(userIds, value.SendUserId)
+		}
+		if value.ReceiverUserId > 0 {
+			userIds = append(userIds, value.ReceiverUserId)
+		}
+	}
+	//获取用户信息
+	users := []user_m.User{}
+	if err := db.Model(&user_m.User{}).Where("id in (?)", userIds).Find(&users).Error; err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+	userAvatarMap := map[mysql.ID]string{}
+	for _, r := range users {
+		userAvatarMap[r.ID] = r.Avatar
+	}
+
+	result := map[uint64]property_cv.CvProperty{}
+	for _, r := range properties {
+
+		var senderAvatar string = ""
+		var receiverAvatar string = ""
+		if propertyAvatar, flag := propertyAvatarMap[r.ID]; flag {
+			if propertyAvatar.SendUserId > 0 {
+				if avatar, flag := userAvatarMap[propertyAvatar.SendUserId]; flag {
+					senderAvatar = avatar
+				}
+			}
+			if propertyAvatar.ReceiverUserId > 0 {
+				if avatar, flag := userAvatarMap[propertyAvatar.ReceiverUserId]; flag {
+					receiverAvatar = avatar
+				}
+			}
+		}
+
+		result[r.ID] = property_cv.CvProperty{
+			Id:             r.ID,
+			PicUrl:         r.PicUrl,
+			EffectUrl:      r.EffectUrl,
+			SenderAvatar:   senderAvatar,
+			ReceiverAvatar: receiverAvatar,
+		}
+	}
+	return result, nil
+}
+
+func GetSuperManagerMap(userIds []uint64) (map[uint64]bool, error) {
+	if len(userIds) == 0 {
+		return map[uint64]bool{}, nil
+	}
+	var superManagers []user_m.SuperManager
+	if err := mysql.Db.Model(&user_m.SuperManager{}).Where("user_id in (?)", userIds).Find(&superManagers).Error; err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+	//转换成map
+	rs := map[uint64]bool{}
+	for i, _ := range userIds {
+		rs[userIds[i]] = false
+	}
+	for i, _ := range superManagers {
+		rs[superManagers[i].UserId] = true
+	}
+	return rs, nil
+}
+
+func GetUserBaseMap(userIds []mysql.ID, myUserId mysql.ID) (map[mysql.ID]*CvUserBase, error) {
+	userBases, err := GetUserBases(userIds, myUserId)
+	if err != nil {
+		return nil, err
+	}
+	//转换成map
+	mapIdUser := map[mysql.ID]*CvUserBase{}
+	for i := 0; i < len(userBases); i++ {
+		mapIdUser[*userBases[i].Id] = userBases[i]
+	}
+	return mapIdUser, nil
+}

cv/user_cv/utils.go

+package user_cv
+
+import (
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"hilo-user/cv/headwear_cv"
+	"hilo-user/cv/medal_cv"
+	"hilo-user/cv/property_cv"
+	"time"
+)
+
+//空字符串转成nil
+func StrNil(msg string) *string {
+	if msg == "" {
+		return nil
+	}
+	return &msg
+}
+
+func TypeToUint8(t *mysql.Type) *uint8 {
+	if *t == 0 {
+		return nil
+	} else {
+		return (*uint8)(t)
+	}
+}
+
+func BirthdayToUint64(birthday *mysql.Timestamp) *uint64 {
+	if *birthday == 0 {
+		return nil
+	}
+	return (*uint64)(birthday)
+}
+
+func NumToUint32(num *mysql.Num) *uint32 {
+	return (*uint32)(num)
+}
+
+func TimeToUint64(t *time.Time) *uint64 {
+	a := uint64(t.Unix())
+	return &a
+}
+
+func StrToString(str *mysql.Str) *string {
+	return (*string)(str)
+}
+
+func IndexToUint16(i *mysql.Index) *uint16 {
+	return (*uint16)(i)
+}
+
+func IdToUint64(id *mysql.ID) *uint64 {
+	return (*uint64)(id)
+}
+
+func IsInStringList(str string, list []string) bool {
+	for _, v := range list {
+		if str == v {
+			return true
+		}
+	}
+	return false
+}
+
+func IfLogoutStr(condition bool, trueVal, falseVal string) string {
+	if condition {
+		return trueVal
+	}
+	return falseVal
+}
+
+func IfLogoutNick(condition bool, code string, nick string) string {
+	if condition {
+		return "Hilo No." + code
+	}
+	return nick
+}
+func IfLogout(logoutTime int64) bool {
+	return logoutTime > 0 && time.Now().Unix() > logoutTime
+}
+
+func IfLogoutMedalInfo(condition bool, trueVal, falseVal []medal_cv.CvMedal) []medal_cv.CvMedal {
+	if condition {
+		return trueVal
+	}
+	return falseVal
+}
+
+func IfLogoutRide(condition bool, trueVal, falseVal property_cv.CvProperty) property_cv.CvProperty {
+	if condition {
+		return trueVal
+	}
+	return falseVal
+}
+
+func IfLogoutHeadwear(condition bool, trueVal, falseVal *headwear_cv.CvHeadwear) *headwear_cv.CvHeadwear {
+	if condition {
+		return trueVal
+	}
+	return falseVal
+}

domain/model/res_m/country.go

@@ -191,7 +191,7 @@ func GetLangeByCountry(db *gorm.DB, country mysql.Str) (string, error) {
 	if err == nil {
 		return r.Lang, nil
 	} else if err == gorm.ErrRecordNotFound {
-		return res_e.DEFAULT_LANG, nil
+		return res_e.DefaultLang, nil
 	} else {
 		return "", myerr.WrapErr(err)
 	}

domain/model/res_m/headwear.go

@@ -123,3 +123,15 @@ func CheckHeadwearValidById(model *domain.Model, id mysql.ID) (bool, error) {
 		return true, nil
 	}
 }
+
+func GetResHeadwearMap(db *gorm.DB) (map[uint64]ResHeadwear, error) {
+	rows := make([]ResHeadwear, 0)
+	if err := db.Model(&ResHeadwear{}).Find(&rows).Error; err != nil {
+		return nil, err
+	}
+	result := make(map[uint64]ResHeadwear, 0)
+	for _, i := range rows {
+		result[i.ID] = i
+	}
+	return result, nil
+}
\ No newline at end of file

domain/model/res_m/medal.go

@@ -2,8 +2,10 @@ package res_m
 
 import (
 	"git.hilo.cn/hilo-common/resource/mysql"
+	"github.com/bluele/gcache"
 	"gorm.io/gorm"
 	"hilo-user/_const/enum/res_e"
+	"time"
 )
 
 type ResMedal struct {
@@ -41,3 +43,39 @@ func GetUserMedalLevelMap(db *gorm.DB) (map[uint64]uint8, map[uint8][]uint64, er
 	}
 	return medalTypes, result, nil
 }
+
+var medalCache = gcache.New(1000).LRU().Build()
+var medalMapCache = gcache.New(1).LRU().Build()
+
+const medalKey = "MEDAL"
+
+// pprof看到内存分配很多
+// 加上15min lru
+func MedalGetAll(db *gorm.DB) ([]ResMedal, error) {
+	if data, err := medalCache.Get(medalKey); err == nil {
+		return data.([]ResMedal), nil
+	}
+	rows := make([]ResMedal, 0)
+	err := db.Find(&rows).Error
+	if err != nil {
+		return nil, err
+	}
+	_ = medalCache.SetWithExpire(medalKey, rows, time.Minute*15)
+	return rows, nil
+}
+
+func MedalGetAllMap(db *gorm.DB) (map[uint32]ResMedal, error) {
+	if data, err := medalMapCache.Get(medalKey); err == nil {
+		return data.(map[uint32]ResMedal), nil
+	}
+	rows, err := MedalGetAll(db)
+	if err != nil {
+		return nil, err
+	}
+	result := make(map[uint32]ResMedal, 0)
+	for _, i := range rows {
+		result[uint32(i.ID)] = i
+	}
+	_ = medalMapCache.SetWithExpire(medalKey, result, time.Minute*15)
+	return result, nil
+}

domain/model/res_m/property.go

+package res_m
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"gorm.io/gorm"
+	"hilo-user/_const/enum/res_e"
+	"hilo-user/myerr"
+	"hilo-user/myerr/bizerr"
+)
+
+type ResProperty struct {
+	mysql.Entity
+	*domain.Model `gorm:"-"`
+	Name          mysql.Str
+	PicUrl        mysql.Str
+	EffectUrl     mysql.Str
+}
+
+type ResPropertyDiamond struct {
+	mysql.Entity
+	*domain.Model `gorm:"-"`
+	ResPropertyId mysql.ID
+	DiamondNum    mysql.Num
+	Second        mysql.Num
+	Status        mysql.UserYesNo
+}
+
+type ResPropertyAvatar struct {
+	mysql.Entity
+	*domain.Model  `gorm:"-"`
+	ResPropertyId  mysql.ID
+	Type           res_e.ResPropertyAvatarType
+	SendUserId     mysql.ID
+	ReceiverUserId mysql.ID
+}
+
+func InitResPropertyDiamond(model *domain.Model, resPropertyId mysql.ID, diamondNum mysql.Num, second mysql.Num) *ResPropertyDiamond {
+	return &ResPropertyDiamond{
+		Model:         model,
+		ResPropertyId: resPropertyId,
+		DiamondNum:    diamondNum,
+		Second:        second,
+		Status:        mysql.NOUSER,
+	}
+}
+
+//id获取头饰，不存在则抛异常
+func GetPropertyById(model *domain.Model, id mysql.ID) (*ResProperty, error) {
+	resProperty := ResProperty{}
+	if err := model.Db.Model(&ResProperty{}).First(&resProperty, id).Error; err != nil {
+		return nil, myerr.WrapErr(err)
+	} else {
+		resProperty.Model = model
+		return &resProperty, nil
+	}
+}
+
+func GetResPropertyDiamond(model *domain.Model, resPropertyDiamondId mysql.ID) (*ResPropertyDiamond, error) {
+	resPropertyDiamond := ResPropertyDiamond{}
+	if err := model.Db.Model(&ResPropertyDiamond{}).First(&resPropertyDiamond, resPropertyDiamondId).Error; err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+	if resPropertyDiamond.Status == mysql.NOUSER {
+		return nil, bizerr.ResPropertyDiamondNoUse
+	}
+	return &resPropertyDiamond, nil
+}
+
+func GetResPropertyDiamondByPropertyIdOrNil(model *domain.Model, resPropertyId mysql.ID) (*ResPropertyDiamond, error) {
+	resPropertyDiamond := ResPropertyDiamond{}
+	if err := model.Db.Model(&ResPropertyDiamond{}).Where(&ResPropertyDiamond{
+		ResPropertyId: resPropertyId,
+	}).First(&resPropertyDiamond).Error; err != nil {
+		if err == gorm.ErrRecordNotFound {
+			return nil, nil
+		} else {
+			return nil, myerr.WrapErr(err)
+		}
+	}
+	resPropertyDiamond.Model = model
+	return &resPropertyDiamond, nil
+}
+
+//设置成未使用
+func (resPropertyDiamond *ResPropertyDiamond) SetUser() *ResPropertyDiamond {
+	resPropertyDiamond.Status = mysql.USER
+	return resPropertyDiamond
+}
+
+//设置成未使用
+func (resPropertyDiamond *ResPropertyDiamond) SetNoUser() *ResPropertyDiamond {
+	resPropertyDiamond.Status = mysql.NOUSER
+	return resPropertyDiamond
+}
+
+func (resPropertyDiamond *ResPropertyDiamond) SetDiamondNum(diamondNum uint32) *ResPropertyDiamond {
+	resPropertyDiamond.DiamondNum = diamondNum
+	return resPropertyDiamond
+}
+
+func (resPropertyDiamond *ResPropertyDiamond) SetSecond(second uint32) *ResPropertyDiamond {
+	resPropertyDiamond.Second = second
+	return resPropertyDiamond
+}
+
+func AddProperty(model *domain.Model, p *ResProperty) error {
+	return model.Db.Create(p).Error
+}
+
+func EditProperty(model *domain.Model, propertyId uint64, name, picUrl, effectUrl string) error {
+	activityConfig := ResProperty{Entity: mysql.Entity{ID: propertyId}}
+	err := model.Db.First(&activityConfig).Error
+	if err != nil {
+		return err
+	}
+	activityConfig.Name = name
+	activityConfig.PicUrl = picUrl
+	activityConfig.EffectUrl = effectUrl
+	return model.Db.Save(&activityConfig).Error
+}
+
+func (p *ResProperty) Get(db *gorm.DB) error {
+	return db.Where(p).First(p).Error
+}
+
+func (p *ResProperty) GetAll(db *gorm.DB) (map[uint64]ResProperty, error) {
+	rows := make([]ResProperty, 0)
+	if err := db.Where(p).Find(&rows).Error; err != nil {
+		return nil, err
+	}
+	result := make(map[uint64]ResProperty, 0)
+	for _, i := range rows {
+		result[i.ID] = i
+	}
+	return result, nil
+}
+
+func (p *ResPropertyAvatar) GetAll(db *gorm.DB) (map[uint64]ResPropertyAvatar, error) {
+	rows := make([]ResPropertyAvatar, 0)
+	if err := db.Where(p).Find(&rows).Error; err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+	result := make(map[uint64]ResPropertyAvatar, 0)
+	for _, i := range rows {
+		result[i.ResPropertyId] = i
+	}
+	return result, nil
+}

domain/model/res_m/resMultiText.go

@@ -27,7 +27,7 @@ func GetResMultiTextBy(db *gorm.DB, msgId uint, Language mysql.Str) (*ResMultiTe
 		if err == gorm.ErrRecordNotFound {
 			if err := db.Where(&ResMultiText{
 				MsgId:    msgId,
-				Language: res_e.DEFAULT_LANG,
+				Language: res_e.DefaultLang,
 			}).First(&r).Error; err != nil {
 				return nil, myerr.WrapErr(err)
 			}

domain/model/user_m/medal.go

@@ -89,3 +89,15 @@ func GetUserMedal(db *gorm.DB, userId mysql.ID) ([]uint32, error) {
 	}
 	return result, nil
 }
+
+func BatchGetUserMedalMerge(logger *logrus.Entry, db *gorm.DB, userIds []mysql.ID) (map[uint64][]uint32, error) {
+	result := make(map[uint64][]uint32, 0)
+	for _, u := range userIds {
+		a, err := GetUserMedalMerge(logger, db, u)
+		if err != nil {
+			return nil, err
+		}
+		result[u] = a
+	}
+	return result, nil
+}

domain/model/user_m/property.go

@@ -108,4 +108,32 @@ type UserPropertyLog struct {
 	Type          property_e.UserPropertyLogType
 	AddSecond     *mysql.Num
 	UpdateEndTime *time.Time
-}
\ No newline at end of file
+}
+
+func (userProperty *UserProperty) BatchGet(db *gorm.DB, userIds []uint64) (map[uint64]uint64, error) {
+	rows := make([]UserProperty, 0)
+	if err := db.Model(userProperty).
+		Where("end_time > NOW() AND user_id IN ?", userIds).Order("id DESC").Find(&rows).Error; err != nil {
+		return nil, err
+	}
+	result := make(map[uint64]uint64, 0)
+	tmp := make(map[uint64]uint64, 0)
+	for _, i := range rows {
+		if _, ok := result[i.UserId]; !ok {
+			if i.Using == property_e.YesUsing {
+				// using = true且id最大，就确定是当前使用的
+				result[i.UserId] = i.PropertyId
+			} else if _, ok := tmp[i.UserId]; !ok {
+				// using = false且id最大，先记下，因为不知道还有没有using=true的
+				tmp[i.UserId] = i.PropertyId
+			}
+		}
+	}
+	for k, v := range tmp {
+		// result中没有的，就采用tmp保存的
+		if _, ok := result[k]; !ok {
+			result[k] = v
+		}
+	}
+	return result, nil
+}

domain/model/user_m/superManager.go

+package user_m
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"gorm.io/gorm"
+	"hilo-user/myerr"
+	"strings"
+)
+
+type SuperManager struct {
+	mysql.Entity
+	*domain.Model `gorm:"-"`
+	UserId        mysql.ID
+	IsAll         bool
+	Countries     string
+}
+
+func IsSuperManager(model *domain.Model, userId mysql.ID) (bool, error) {
+	var n int64
+	if err := model.Db.Model(&SuperManager{}).Where(&SuperManager{
+		UserId: userId,
+	}).Count(&n).Error; err != nil {
+		return false, myerr.WrapErr(err)
+	}
+	return n > 0, nil
+}
+
+// 对某人是否有超管权限
+func IsSuperManagerV2(model *domain.Model, userId, targetUserId mysql.ID) (bool, error) {
+	var man SuperManager
+	if err := model.Db.Model(&SuperManager{}).Where(&SuperManager{
+		UserId: userId,
+	}).First(&man).Error; err != nil {
+		if err != gorm.ErrRecordNotFound {
+			model.Log.Errorf("IsSuperManagerV2 fail:%v", err)
+		}
+		return false, nil
+	}
+	if man.IsAll {
+		return true, nil
+	}
+	targetUser, err := GetUser(model, targetUserId)
+	if err != nil {
+		return false, err
+	}
+	countries := strings.Split(man.Countries, ",")
+	for _, c := range countries {
+		if c == targetUser.Country {
+			return true, nil
+		}
+	}
+	return false, nil
+}
+
+func GetSuperManagerAll(model *domain.Model) ([]uint64, error) {
+	var superManagers []SuperManager
+	if err := model.Db.Model(&SuperManager{}).Find(&superManagers).Error; err != nil {
+		return nil, myerr.WrapErr(err)
+	}
+	userIds := make([]uint64, 0, len(superManagers))
+	for i, _ := range superManagers {
+		userIds = append(userIds, superManagers[i].UserId)
+	}
+	return userIds, nil
+}
+
+/*
+func GetSuperManagerMap(model *domain.Model) (map[uint64]struct{}, error) {
+	userIds, err := GetSuperManagerAll(model)
+	if err != nil {
+		return nil, err
+	}
+	userIdMap := map[uint64]struct{}{}
+	for i, _ := range userIds {
+		userIdMap[userIds[i]] = struct{}{}
+	}
+	return userIdMap, nil
+}*/

domain/model/user_m/vip.go

@@ -43,3 +43,24 @@ func GetVip(db *gorm.DB, userId uint64) (*UserVip, error) {
 	}
 	return nil, nil
 }
+
+func BatchGetVips(userIds []uint64) (map[uint64]*int64, error) {
+	rows := make([]UserVip, 0)
+	err := mysql.Db.Where("user_id IN ?", userIds).Find(&rows).Error
+	if err != nil {
+		return nil, err
+	}
+
+	result := make(map[uint64]*int64, 0)
+	for _, i := range userIds {
+		result[i] = nil
+	}
+	now := time.Now()
+	for _, i := range rows {
+		if i.ExpireAt.After(now) {
+			ts := i.ExpireAt.Unix()
+			result[i.UserId] = &ts
+		}
+	}
+	return result, nil
+}

go.mod

@@ -70,6 +70,8 @@ require (
 	golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8 // indirect
 	golang.org/x/text v0.3.6 // indirect
 	golang.org/x/tools v0.0.0-20190907020128-2ca718005c18 // indirect
+	google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 // indirect
+	google.golang.org/grpc v1.42.0 // indirect
 	google.golang.org/protobuf v1.28.1 // indirect
 	gopkg.in/ini.v1 v1.63.2 // indirect
 	gopkg.in/yaml.v2 v2.4.0 // indirect

myerr/bizerr/bizCode.go

@@ -19,4 +19,6 @@ var (
 	DiamondNoEnough      = myerr.NewBusinessCode(4000, "Insufficient diamonds", myerr.BusinessData{})
 	DiamondFrequency     = myerr.NewBusinessCode(4001, "Diamond operation frequency too high", myerr.BusinessData{})
 	DiamondAccountFrozen = myerr.NewBusinessCode(4004, "Diamond Account Frozen", myerr.BusinessData{})
+
+	ResPropertyDiamondNoUse = myerr.NewBusinessCode(5004, "Property can not buy", myerr.BusinessData{}) //头饰不能买
 )

route/cp_r/rank.go

@@ -3,8 +3,11 @@ package cp_r
 import (
 	"git.hilo.cn/hilo-common/domain"
 	"git.hilo.cn/hilo-common/mycontext"
+	"git.hilo.cn/hilo-common/resource/mysql"
 	"github.com/gin-gonic/gin"
 	"github.com/jinzhu/now"
+	"hilo-user/cv/cp_cv"
+	"hilo-user/cv/user_cv"
 	"hilo-user/domain/model/cp_m"
 	"hilo-user/myerr/bizerr"
 	"hilo-user/req"
@@ -19,10 +22,14 @@ import (
 // @Param pageIndex query int true "偏移值 默认：1" default(1)
 // @Param pageSize query int true "请求数量 默认：10" default(10)
 // @Param queryType path string true "类型：day/week/month"
-// @Success 200
+// @Success 200 {object} []cp_cv.CvCp
 // @Router /v2/cp/rank/{queryType} [get]
 func CpRank(c *gin.Context) (*mycontext.MyContext, error) {
 	myCtx := mycontext.CreateMyContext(c.Keys)
+	userId, err := req.GetUserId(c)
+	if err != nil {
+		return myCtx, err
+	}
 	pageReq := new(req.PageReqBase)
 	if err := c.ShouldBindQuery(pageReq); err != nil {
 		return myCtx, err
@@ -48,6 +55,25 @@ func CpRank(c *gin.Context) (*mycontext.MyContext, error) {
 	offset, limit := (pageReq.PageIndex-1)*pageReq.PageSize, pageReq.PageSize
 	model := domain.CreateModelContext(myCtx)
 	ranks := cp_m.PageCpDayRank(model, beginDate, endDate, offset, limit)
-	resp.ResponsePageBaseOk(c, ranks, pageReq.PageIndex+1, len(ranks) < pageReq.PageSize)
+	var response []cp_cv.CvCp
+	var userIds []mysql.ID
+	for _, rank := range ranks {
+		userIds = append(userIds, rank.UserId1)
+		userIds = append(userIds, rank.UserId2)
+	}
+	userBase, err := user_cv.GetUserBaseMap(userIds, userId)
+	if err != nil {
+		return myCtx, err
+	}
+	for i, rank := range ranks {
+		response = append(response, cp_cv.CvCp{
+			CpId:    rank.CpId,
+			User1:   userBase[rank.UserId1],
+			User2:   userBase[rank.UserId2],
+			Score:   rank.Score,
+			Ranking: i + 1 + offset,
+		})
+	}
+	resp.ResponsePageBaseOk(c, response, pageReq.PageIndex+1, len(ranks) < pageReq.PageSize)
 	return myCtx, nil
 }