corn/cp_corn/cp.go → cron/cp_cron/cp_relation.go

-package cp_corn
+package cp_cron
 
 import (
 	"git.hilo.cn/hilo-common/_const/enum/diamond_e"
@@ -36,6 +36,7 @@ func CpInviteCancelInit() {
 			return
 		}
 		for _, v := range inviteList {
+			model := domain.CreateModelContext(model.MyContext)
 			model.Log.Infof("CpInviteCancelInit invite:%+v", v)
 			err = model.Transaction(func(model *domain.Model) error {
 				// 更新邀请记录
@@ -54,7 +55,7 @@ func CpInviteCancelInit() {
 			})
 			if err != nil {
 				model.Log.Errorf("CpInviteCancelInit invite:%+v, err:%v", v, err)
-				return
+				continue
 			}
 			time.Sleep(time.Millisecond * 10)
 		}
@@ -66,6 +67,7 @@ func CpInviteCancelInit() {
 			return
 		}
 		for _, v := range cancelList {
+			model := domain.CreateModelContext(model.MyContext)
 			model.Log.Infof("CpInviteCancelInit cancel:%+v", v)
 			err = model.Transaction(func(model *domain.Model) error {
 				// 更新解除记录
@@ -84,7 +86,7 @@ func CpInviteCancelInit() {
 			})
 			if err != nil {
 				model.Log.Errorf("CpInviteCancelInit cancel:%+v, err:%v", v, err)
-				return
+				continue
 			}
 			time.Sleep(time.Millisecond * 10)
 		}

cron/cron.go

@@ -2,18 +2,20 @@ package cron
 
 import (
 	"git.hilo.cn/hilo-common/resource/config"
-	"hilo-user/corn/cp_corn"
 	"hilo-user/cron/cp_cron"
 	"hilo-user/cron/gift_cron"
+	"hilo-user/cron/user_cron"
 )
 
 func Init() {
+	user_cron.SyncGiftRecommendUsers() // 同步送礼推荐用户,多进程都需要执行
 	if !config.IsMaster() {
 		return
 	}
-	gift_cron.SendGiftEventInit() // 礼物消息
-	gift_cron.GiftRemark()        // 礼物消息补偿
+	//gift_cron.SendGiftEventInit() // 礼物消息
+	//gift_cron.GiftRemark()        // 礼物消息补偿
+	gift_cron.SendGiftEvent() // 送礼事件
 	cp_cron.ClearCpExpire()       // 清理过期cp
 	cp_cron.CpAnniversaryNotice() // cp纪念日
-	cp_corn.CpInviteCancelInit()  // cp邀请、解除到期结算
+	cp_cron.CpInviteCancelInit()  // cp邀请、解除到期结算
 }

cron/gift_cron/send_gift_redis.go

+package gift_cron
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"github.com/jinzhu/now"
+	"hilo-user/_const/enum/cp_e"
+	"hilo-user/domain/cache/gift_c"
+	"hilo-user/domain/event/gift_ev"
+	"hilo-user/domain/model/cp_m"
+	"time"
+)
+
+// 送礼事件
+func SendGiftEvent() {
+	//if !config.IsMaster() {
+	//	return
+	//}
+	go func() {
+		for true {
+			model := domain.CreateModelNil()
+			if sendGiftEvent := gift_c.BLPopQueueSendGift(model); sendGiftEvent != nil {
+				cpGiftEvent(model, sendGiftEvent) // cp送礼
+			}
+		}
+	}()
+}
+
+// 送礼增加cp等级
+// 送礼增加cp排行榜
+func cpGiftEvent(model *domain.Model, sendGiftEvent *gift_ev.SendGiftEvent) {
+	// 只处理cp礼物
+	if !sendGiftEvent.ResGift.Cp {
+		return
+	}
+	for _, receiverUid := range sendGiftEvent.ReceiveUserIds {
+		diamonds := sendGiftEvent.GiftN * sendGiftEvent.ResGift.DiamondNum
+		// 有cp关系
+		if cpRelation, exits := cp_m.GetCpRelationPair(model, sendGiftEvent.SendUserId, receiverUid); exits {
+			if err := cp_m.AddCpLevelPoints(model, cpRelation, diamonds, sendGiftEvent.SceneType, sendGiftEvent.SceneUid); err != nil {
+				model.Log.Errorf("AddCpLevelPoints fail:%v", err)
+			}
+			if err := cp_m.AddCpDayRank(model, cpRelation, diamonds); err != nil {
+				model.Log.Errorf("AddCpDayRank fail:%v", err)
+			}
+			// 检查最新的等级
+			if cpLevel := cp_m.GetCpLevel(model, cpRelation.Id); cpLevel.CpId >= 0 {
+				points := cpLevel.Points + cp_e.CpLevelPoints[cpLevel.Level]
+				if err := cp_m.UpdateCpAchievement(model, cpLevel.CpId, cpRelation.UserId1, cpRelation.UserId2, cp_e.CpAchievementLevel, points); err != nil {
+					model.Log.Errorf("UpdateCpAchievement fail:%v", err)
+				}
+			}
+			// 检查最高的分数
+			for _, queryType := range []string{"day", "week", "month"} {
+				var beginDate, endDate string
+				var cpAchievementType cp_e.CpAchievement
+				switch queryType {
+				case "day":
+					beginDate, endDate = time.Now().Format("2006-01-02"), time.Now().Format("2006-01-02")
+					cpAchievementType = cp_e.CpAchievementDayRank
+				case "week":
+					beginDate = now.BeginningOfWeek().Format("2006-01-02")
+					endDate = now.EndOfWeek().Format("2006-01-02")
+					cpAchievementType = cp_e.CpAchievementWeekRank
+				case "month":
+					beginDate = now.BeginningOfMonth().Format("2006-01-02")
+					endDate = now.EndOfMonth().Format("2006-01-02")
+					cpAchievementType = cp_e.CpAchievementMonthRank
+				}
+				if data := cp_m.GetCpDayRank(model, beginDate, endDate, cpRelation.Id); data.Score > 0 {
+					if err := cp_m.UpdateCpAchievement(model, cpRelation.Id, cpRelation.UserId1, cpRelation.UserId2, cpAchievementType, data.Score); err != nil {
+						model.Log.Errorf("UpdateCpAchievement fail:%v", err)
+					}
+				}
+			}
+			// 检查最新日周月榜单
+			return // 业务场景允许提前break(cp是唯一的)
+		}
+	}
+}

cron/user_cron/gift_user.go

+package user_cron
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"github.com/robfig/cron"
+	"hilo-user/domain/model/recommend_m"
+)
+
+// 定期同步礼物推荐用户
+func SyncGiftRecommendUsers() {
+	go recommend_m.SyncPastTop50SendGiftUsers(domain.CreateModelNil()) // 启动先同步一次
+
+	c := cron.New()
+	spec := "0 */5 * * * ?"
+	_ = c.AddFunc(spec, func() {
+		var model = domain.CreateModelNil()
+		recommend_m.SyncPastTop50SendGiftUsers(model)
+	})
+	c.Start()
+}

cv/cp_cv/rank.go

@@ -6,12 +6,12 @@ import (
 )
 
 type CvCpRank struct {
-	CpId    uint64              `json:"cpId"`            // cpId
-	User1   *user_cv.CvUserBase `json:"user1"`           // user1
-	User2   *user_cv.CvUserBase `json:"user2,omitempty"` // user2
-	Score   uint32              `json:"score"`           // 分值
-	CpLevel CvCpLevel           `json:"cpLevel"`         // cp等级
-	Ranking string              `json:"ranking"`         // 排名
+	CpId    uint64                `json:"cpId"`            // cpId
+	User1   *user_cv.CvUserLittle `json:"user1"`           // user1
+	User2   *user_cv.CvUserLittle `json:"user2,omitempty"` // user2
+	Score   uint32                `json:"score"`           // 分值
+	CpLevel CvCpLevel             `json:"cpLevel"`         // cp等级
+	Ranking string                `json:"ranking"`         // 排名
 }
 
 type CvCpAchievement struct {

cv/invite_cv/invite_apply.go

+package invite_cv
+
+import "git.hilo.cn/hilo-common/resource/mysql"
+
+type CvUserLevel struct {
+	UserId          mysql.ID `json:"userId"`          // 用户id
+	WealthUserGrade uint32   `json:"wealthUserGrade"` // 财富等级
+	CharmUserGrade  uint32   `json:"charmUserGrade"`  // 魅力等级
+	ActiveUserGrade uint32   `json:"activeUserGrade"` // 活跃等级
+	NobleLevel      uint16   `json:"nobleLevel"`      // 贵族等级
+}
+
+type InviteApplyRes struct {
+	List    []*InviteApply       `json:"list"`
+	NumList []*InviteApplyNumRes `json:"numList"`
+	MyCode  string               `json:"myCode"`
+}
+
+type InviteApply struct {
+	NewUserCode string `json:"newUserCode"`
+	Platform    string `json:"platform"`
+	Recharge    string `json:"recharge"`
+	UserCode    string `json:"userCode"`
+	CreateUnix  int64  `json:"createUnix"`
+	Level       string `json:"level"`
+	Status      uint8  `json:"status"` // 状态0.未审核1.已通过2.已拒绝
+	Avatar      string `json:"avatar"`
+	ExternalId  string `json:"externalId"`
+	Reason      int    `json:"reason"` // 1.已申请2.待审核3.已通过4.已拒绝"
+	Country     string `json:"country"`
+	PlatformId  string `json:"platformId"`
+}
+
+type InviteApplyNumRes struct {
+	Type int `json:"type"` // 1.已申请2.待审核3.已通过4.已拒绝"
+	Num  int `json:"num"`
+}
+
+type AgentPeriod struct {
+	Week []AgentPeriodWeek `json:"week"`
+}
+
+type AgentPeriodWeek struct {
+	StartDate string `json:"startDate"`
+	EndDate   string `json:"endDate"`
+}

cv/user_cv/user.go

 package user_cv
 
 import (
+	"encoding/json"
 	"git.hilo.cn/hilo-common/_const/common"
 	"git.hilo.cn/hilo-common/domain"
 	"git.hilo.cn/hilo-common/mylogrus"
@@ -29,6 +30,7 @@ type UserTiny struct {
 	Country      string `json:"country"`
 	CountryIcon  string `json:"countryIcon"`
 	IsPrettyCode bool   `json:"isPrettyCode"` // 是否靓号
+	Birthday     uint64 `json:"birthday"`
 }
 
 func UserToTiny(user user_m.User) *UserTiny {
@@ -42,6 +44,7 @@ func UserToTiny(user user_m.User) *UserTiny {
 		Country:      user.Country,
 		CountryIcon:  user.CountryIcon,
 		IsPrettyCode: user.IsPrettyCode(),
+		Birthday:     user.Birthday,
 	}
 }
 
@@ -82,7 +85,8 @@ type CvUserBase struct {
 	//邀请码
 	Code         *string `json:"code"`
 	IsPrettyCode bool    `json:"isPrettyCode"` // 是否靓号
-	IsLogout     bool    `json:"isLogout"`     //是否注销
+	IsNew        bool    `json:"isNew"`        // 是否新用户
+	IsLogout     bool    `json:"isLogout"`     // 是否注销
 	//生日，如果是其它人用户信息，年龄则按照是否展示显示，如果是本人，年龄则按照是否存在展示
 	Birthday *uint64 `json:"birthday"`
 	//是否展示年龄, 是本人才有数据，看其他用户均为nil
@@ -108,6 +112,17 @@ type CvUserBase struct {
 	GroupRole     common.GroupRoleType    `json:"groupRole"` // 在群组的角色
 }
 
+type CvUserLittle struct {
+	//不会有返回值
+	Id *mysql.ID `json:"id,omitempty"`
+	//头像,不存在为nil
+	Avatar *string `json:"avatar"`
+	//用户对外ID
+	ExternalId *string `json:"externalId"`
+	//昵称,不存在为nil
+	Nick *string `json:"nick"`
+}
+
 //批量获取用户基本信息
 func GetUserBases(userIds []mysql.ID, myUserId mysql.ID) ([]*CvUserBase, error) {
 	if len(userIds) == 0 {
@@ -199,6 +214,7 @@ func GetUserBases(userIds []mysql.ID, myUserId mysql.ID) ([]*CvUserBase, error)
 			CountryIcon:     StrNil(user.CountryIcon),
 			Code:            StrToString(&user.Code),
 			IsPrettyCode:    user.IsPrettyCode(),
+			IsNew:           user.IsNew(),
 			IsVip:           vips[user.ID] != nil,
 			IsOfficialStaff: superManagerMap[user.ID],
 			Medals:          IfLogoutMedals(IfLogout(user.LogoutTime), []uint32{}, medals[user.ID]),
@@ -299,6 +315,7 @@ func GetUserBasesForCp(userIds []mysql.ID) ([]*CvUserBase, error) {
 			CountryIcon:   StrNil(user.CountryIcon),
 			Code:          StrToString(&user.Code),
 			IsPrettyCode:  user.IsPrettyCode(),
+			IsNew:         user.IsNew(),
 			IsVip:         vips[user.ID] != nil,
 			Noble: noble_cv.CvNoble{
 				Level:   nobles[user.ID].Level,
@@ -477,6 +494,50 @@ type CvUserDetail struct {
 	Cp                *CvCp                 `json:"cp,omitempty"`             // cp信息
 }
 
+//用户详细信息-在房间里面时需要的
+type CvUserDetailRoom 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"`
+	//性别 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"` // 是否靓号
+	//生日，如果是其它人用户信息，年龄则按照是否展示显示，如果是本人，年龄则按照是否存在展示
+	Birthday *uint64 `json:"birthday"`
+	//是否展示年龄, 是本人才有数据，看其他用户均为nil
+	IsShowAge *uint8 `json:"isShowAge"`
+	//是否VIP用户
+	IsVip             bool                    `json:"isVip"`
+	Svip              rpc.CvSvip              `json:"svip"`                     // svip结构,等级+权限
+	Medals            []uint32                `json:"medals"`                   // 勋章列表
+	Noble             noble_cv.CvNoble        `json:"noble"`                    // 当前的
+	CountryManager    *CVCountryManager       `json:"countryManager,omitempty"` // 国家管理员
+	Headwear          *headwear_cv.CvHeadwear `json:"headwear"`                 // 当前使用的头饰
+	WealthUserGrade   uint32                  `json:"wealthUserGrade"`          //财富等级
+	CharmUserGrade    uint32                  `json:"charmUserGrade"`           //魅力等级
+	ActivityUserGrade uint32                  `json:"activityUserGrade"`        //活跃等级
+	GroupPower        rpc.CvGroupPowerInfo    `json:"groupPower"`               // 家族
+	//是否喜欢(本人没有数据，//20210205 已废弃nil，产品说：可以自己喜欢自己)
+	IsLike *bool `json:"isLike"`
+	//别人是否喜欢我，自己本人没有数据 (20210205 已废弃nil，产品说：可以自己喜欢自己)
+	IsLikeMe  *bool                `json:"isLikeMe"`
+	Cp        *CvCpTiny            `json:"cp,omitempty"` // cp信息
+	GroupRole common.GroupRoleType `json:"groupRole"`    // 在群组的角色
+}
+
 // cv国家管理人员
 type CVCountryManager struct {
 	Country string                   `json:"country"`                    // 国家name
@@ -492,6 +553,33 @@ type CvCp struct {
 	CpDays          int           `json:"cpDays"`          // cp天数
 }
 
+// cp信息
+type CvCpTiny struct {
+	CpUserInfo      *CvCpUser     `json:"cpUserInfo"`      // cp用户信息
+	CpLevel         CvCpLevel     `json:"cpLevel"`         // cp等级
+	MyPrivilegeList []CvPrivilege `json:"myPrivilegeList"` // 等级特权
+	CreatedUnix     int64         `json:"createdUnix"`     // cp创建时间
+	CpDays          int           `json:"cpDays"`          // cp天数
+}
+
+type CvCpUser struct {
+	//不会有返回值
+	Id *mysql.ID `json:"id,omitempty"`
+	//头像,不存在为nil
+	Avatar *string `json:"avatar"`
+	//用户对外ID
+	ExternalId *string `json:"externalId"`
+	//昵称,不存在为nil
+	Nick *string `json:"nick"`
+	//性别 1：男 2：女,不存在为nil
+	Sex *uint8 `json:"sex"`
+	//邀请码
+	Code     *string                 `json:"code"`
+	Headwear *headwear_cv.CvHeadwear `json:"headwear"` // 当前使用的头饰
+	Svip     rpc.CvSvip              `json:"svip"`     // svip结构,等级+权限
+	Noble    noble_cv.CvNoble        `json:"noble"`    // 当前的
+}
+
 // cp关系
 type CvCpRelation struct {
 	CpId         uint64 `json:"cpId"`
@@ -511,3 +599,19 @@ type CvCpLevel struct {
 type CvPrivilege struct {
 	Type cp_e.CpPrivilege `json:"type"` // 特权id 1:空间 2:横幅 3:等级勋章 4:证书 5:进场特效 6:头像头饰 7:动态资料卡 8:麦位特效
 }
+
+func UserBaseToUserLittle(base *CvUserBase) *CvUserLittle {
+	return &CvUserLittle{
+		Id:         base.Id,
+		Avatar:     base.Avatar,
+		ExternalId: base.ExternalId,
+		Nick:       base.Nick,
+	}
+}
+
+func CvUserDetailToCvUserDetailRoom(info *CvUserDetail) *CvUserDetailRoom {
+	res := new(CvUserDetailRoom)
+	jData, _ := json.Marshal(info)
+	_ = json.Unmarshal(jData, &res)
+	return res
+}

debug.ini

@@ -11,6 +11,8 @@ MYSQL_DB=hilo_code
 [REDIS]
 REDIS_HOST=47.244.34.27:6379
 REDIS_PASSWORD=8QZ9JD1zLvPR3yHf
+REDIS_CLUSTER_HOST=47.244.34.27:6379
+REDIS_CLUSTER_PASSWORD=8QZ9JD1zLvPR3yHf
 [JWT]
 SECRET=hilo1632
 ISSUER_API=hiloApi

domain/cache/gift_c/gift_event.go

+package gift_c
+
+import (
+	"encoding/json"
+	"git.hilo.cn/hilo-common/domain"
+	"github.com/go-redis/redis/v8"
+	"hilo-user/domain/event/gift_ev"
+	"time"
+)
+
+const EventSendGiftHiloUserQueue = "send:gift:queue:hilo_user"
+
+// redis pop event sendGift
+func BLPopQueueSendGift(model *domain.Model) *gift_ev.SendGiftEvent {
+	var res *gift_ev.SendGiftEvent
+	queue := EventSendGiftHiloUserQueue
+	strs, err := model.RedisCluster.BLPop(model, time.Second, queue).Result()
+	if err != nil {
+		if err != redis.Nil {
+			model.Log.Errorf("BLPopQueueSendGift fail:%v", err)
+		}
+		return nil
+	}
+	if len(strs) >= 2 {
+		content := strs[1]
+		res = new(gift_ev.SendGiftEvent)
+		if err := json.Unmarshal([]byte(content), res); err != nil {
+			model.Log.Errorf("BLPopQueueSendGift json fail:%v", err)
+			return nil
+		}
+		return res
+	}
+	return nil
+}

domain/cache/modelRedis.go

@@ -27,7 +27,7 @@ func SetJSON(model *domain.Model, key string, obj interface{}) (err error) {
 	if err != nil {
 		return err
 	}
-	return model.Redis.Set(model.Context, key, value, DEFAULT_TTL).Err()
+	return model.RedisCluster.Set(model.Context, key, value, DEFAULT_TTL).Err()
 }
 
 // 获取redis中json结构体
@@ -37,7 +37,7 @@ func GetJSON(model *domain.Model, key string, obj interface{}) (err error) {
 	defer func() {
 		model.Log.Infof("GetJson key:%v,value:%s,obj:%v,err:%v", key, value, obj, err)
 	}()
-	value, err = model.Redis.Get(model.Context, key).Bytes()
+	value, err = model.RedisCluster.Get(model.Context, key).Bytes()
 	if err != nil {
 		// may redisV2.Nil
 		return
@@ -59,7 +59,7 @@ func TryLock(model *domain.Model, key string, acquireTimeout, expireTimeout time
 		if time.Now().After(deadline) {
 			return false
 		}
-		flag, err := model.Redis.SetNX(model, key, "1", expireTimeout).Result()
+		flag, err := model.RedisCluster.SetNX(model, key, "1", expireTimeout).Result()
 		if err != nil || !flag {
 			time.Sleep(time.Millisecond * 10)
 		} else {
@@ -70,5 +70,5 @@ func TryLock(model *domain.Model, key string, acquireTimeout, expireTimeout time
 
 // 解锁
 func UnLock(model *domain.Model, key string) {
-	model.Redis.Del(model, key)
+	model.RedisCluster.Del(model, key)
 }

domain/cache/user_c/user.go

@@ -53,7 +53,7 @@ func ToUserId(model *domain.Model, externalId mysql.Str) (mysql.ID, error) {
 	if externalId == "" {
 		return 0, myerr.NewSysError("externalId 不能为空")
 	}
-	userId, err := model.Redis.Get(model.Context, user_k.GetExternalIdToUidKey(externalId)).Int64()
+	userId, err := model.RedisCluster.Get(model.Context, user_k.GetExternalIdToUidKey(externalId)).Int64()
 	if err != nil && err != redisV8.Nil {
 		return 0, err
 	}
@@ -76,7 +76,7 @@ func ToUserIdByCode(model *domain.Model, code mysql.Str) (mysql.ID, error) {
 	if code == "" {
 		return 0, myerr.NewSysError("code 不能为空")
 	}
-	userId, err := model.Redis.Get(model.Context, user_k.GetCodeToUidKey(code)).Int64()
+	userId, err := model.RedisCluster.Get(model.Context, user_k.GetCodeToUidKey(code)).Int64()
 	if err != nil && err != redisV8.Nil {
 		return 0, err
 	}
@@ -105,11 +105,11 @@ func cacheUserTiny(model *domain.Model, user *user_m.User) error {
 	//	return err
 	//}
 	// cache externalId->userId
-	if err := model.Redis.SetEX(model.Context, user_k.GetExternalIdToUidKey(user.ExternalId), user.ID, cache.GetDefaultTTL()).Err(); err != nil {
+	if err := model.RedisCluster.SetEX(model.Context, user_k.GetExternalIdToUidKey(user.ExternalId), user.ID, cache.GetDefaultTTL()).Err(); err != nil {
 		return err
 	}
 	// cache code->userId
-	if err := model.Redis.SetEX(model.Context, user_k.GetCodeToUidKey(user.Code), user.ID, cache.GetDefaultTTL()).Err(); err != nil {
+	if err := model.RedisCluster.SetEX(model.Context, user_k.GetCodeToUidKey(user.Code), user.ID, cache.GetDefaultTTL()).Err(); err != nil {
 		return err
 	}
 	if err := cache.SetJSON(model, user_k.GetUserTinyKey(user.ID), userTiny); err != nil {

domain/model/common/cache_medal.go

 package common
 
 import (
-	"context"
-	"encoding/json"
-	"git.hilo.cn/hilo-common/mylogrus"
 	"git.hilo.cn/hilo-common/resource/mysql"
-	"git.hilo.cn/hilo-common/resource/redisCli"
-	"hilo-user/_const/redis_key"
-	"hilo-user/myerr"
+	"github.com/bluele/gcache"
 	"time"
 )
 
-func GetUserMedalMergeCache(userId mysql.ID) ([]uint32, error) {
-	bData, err := GetCache(redis_key.GetUserMedalMerge(userId))
-	if err != nil {
-		return nil, myerr.WrapErr(err)
-	}
-
-	res := make([]uint32, 0)
-	err = json.Unmarshal(bData, &res)
-	if err != nil {
-		return nil, myerr.WrapErr(err)
-	}
-	return res, nil
-}
+// 改成lru
+var userMedalMergeLru = gcache.New(10000).LRU().Build()
 
-func GetCache(key string) ([]byte, error) {
-	data, err := redisCli.GetRedis().Get(context.Background(), key).Bytes()
-	if err != nil {
-		return nil, err
-	}
-	return data, nil
-}
-
-func SetCache(key string, data interface{}, expire time.Duration) error {
-	jData, err := json.Marshal(data)
-	if err != nil {
-		return err
-	}
-	err = redisCli.GetRedis().Set(context.Background(), key, jData, expire).Err()
-	if err != nil {
-		mylogrus.MyLog.Errorf("SetCache key:%s, data:%v, err:%s", key, data, err)
-		return err
+func GetUserMedalMergeCache(userId mysql.ID) ([]uint32, error) {
+	if data, err := userMedalMergeLru.Get(userId); err == nil {
+		return data.([]uint32), nil
 	}
-	return nil
+	return nil, nil
 }
 
-func SetUserMedalMergeCache(userId mysql.ID, data []uint32) error {
-	err := SetCache(redis_key.GetUserMedalMerge(userId), data, time.Hour*2)
-	if err != nil {
-		mylogrus.MyLog.Errorf("SetUserMedalMerge err:%s", err)
-		return myerr.WrapErr(err)
-	}
-	return nil
+func SetUserMedalMergeCache(userId mysql.ID, data []uint32) {
+	_ = userMedalMergeLru.SetWithExpire(userId, data, time.Minute*15)
 }

domain/model/cp_m/cp_relation.go

@@ -130,7 +130,21 @@ func GetCp(model *domain.Model, userId uint64) (*CpRelation, error) {
 		if err == gorm.ErrRecordNotFound {
 			return res, nil
 		}
-		model.Log.Errorf("CreateCp userId:%d, err:%v", userId, err)
+		model.Log.Errorf("GetCp userId:%d, err:%v", userId, err)
+		return nil, err
+	}
+	return res, nil
+}
+
+func GetCpByIds(model *domain.Model, userId1, userId2 uint64) (*CpRelation, error) {
+	ids := []uint64{userId1, userId2}
+	res := new(CpRelation)
+	err := model.DB().Model(CpRelation{}).Where("user_id1 in (?) and user_id2 in (?)", ids, ids).First(&res).Error
+	if err != nil {
+		if err == gorm.ErrRecordNotFound {
+			return res, nil
+		}
+		model.Log.Errorf("GetCpByIds userId1:%d, userId2:%d, err:%v", userId1, userId2, err)
 		return nil, err
 	}
 	return res, nil

domain/model/cp_m/rank.go

@@ -41,7 +41,9 @@ func AddCpDayRank(model *domain.Model, cpRelation CpRelation, score mysql.Num) (
 func PageCpDayRank(model *domain.Model, beginDate, endDate string, offset, limit int) []CpDayRank {
 	var ranks []CpDayRank
 	if err := model.DB().Table("cp_day_rank r").Joins("INNER JOIN cp_relation c ON c.id = r.cp_id").
-		Where("r.date BETWEEN ? AND ?", beginDate, endDate).Group("cp_id").Select("cp_id,r.user_id1,r.user_id2,SUM(r.score) score").
+		Where("r.date BETWEEN ? AND ?", beginDate, endDate).
+		Where("cp_id not in (1581, 12651, 5171, 9191, 39131, 28801, 181, 35221)").
+		Group("cp_id").Select("cp_id,r.user_id1,r.user_id2,SUM(r.score) score").
 		Order("score DESC").Offset(offset).Limit(limit).Find(&ranks).Error; err != nil {
 		model.Log.Errorf("PageCpDayRank fail:%v", err)
 	}

domain/model/diamond_m/diamond.go

 package diamond_m
 
 import (
+	"fmt"
 	"git.hilo.cn/hilo-common/_const/enum/diamond_e"
 	"git.hilo.cn/hilo-common/domain"
 	"git.hilo.cn/hilo-common/resource/mysql"
@@ -37,6 +38,11 @@ type DiamondAccountDetail struct {
 	diamondAccount   *DiamondAccount `gorm:"-"`
 }
 
+func (DiamondAccountDetail) TableName() string {
+	month := time.Now().Format("200601")
+	return fmt.Sprintf("diamond_account_detail_%s", month)
+}
+
 // 粉钻详情
 type DiamondPinkAccountDetail struct {
 	mysql.Entity
@@ -107,7 +113,7 @@ func (diamondAccount *DiamondAccount) addDiamondAccountDetail(operateType diamon
 	var count int64
 	if diamondOperateSet.FrequencyDay == -1 {
 		if diamondOperateSet.FrequencyNum != -1 {
-			diamondAccount.Db.Model(&DiamondAccountDetail{}).Where(&DiamondAccountDetail{
+			diamondAccount.DB().Table(DiamondAccountDetail{}.TableName()).Where(&DiamondAccountDetail{
 				UserId:      diamondAccount.UserId,
 				OperateType: operateType,
 			}).Count(&count)
@@ -122,7 +128,7 @@ func (diamondAccount *DiamondAccount) addDiamondAccountDetail(operateType diamon
 			return nil, myerr.WrapErr(err)
 		}
 		//一天的次数
-		diamondAccount.Db.Model(&DiamondAccountDetail{}).Where(&DiamondAccountDetail{
+		diamondAccount.DB().Table(DiamondAccountDetail{}.TableName()).Where(&DiamondAccountDetail{
 			UserId:      diamondAccount.UserId,
 			OperateType: operateType,
 		}).Where("created_time >= ? ", beginTime).Count(&count)
@@ -130,7 +136,7 @@ func (diamondAccount *DiamondAccount) addDiamondAccountDetail(operateType diamon
 			return nil, bizerr.DiamondFrequency
 		}
 		//终极拦截，利用
-		diamondAccount.SetCheckUpdateCondition(" EXISTS (SELECT * from (SELECT COUNT(1)  as n from diamond_account_detail d where d.user_id = " + strconv.FormatUint(diamondAccount.UserId, 10) + " and d.operate_type = " + strconv.FormatUint(uint64(operateType), 10) + " and d.created_time >= from_unixtime(" + strconv.FormatInt(utils.GetZeroTime(time.Now()).Unix(), 10) + ")) t where t.n < " + strconv.Itoa(diamondOperateSet.FrequencyNum) + " )")
+		diamondAccount.SetCheckUpdateCondition(" EXISTS (SELECT * from (SELECT COUNT(1)  as n from " + DiamondAccountDetail{}.TableName() + " d where d.user_id = " + strconv.FormatUint(diamondAccount.UserId, 10) + " and d.operate_type = " + strconv.FormatUint(uint64(operateType), 10) + " and d.created_time >= from_unixtime(" + strconv.FormatInt(utils.GetZeroTime(time.Now()).Unix(), 10) + ")) t where t.n < " + strconv.Itoa(diamondOperateSet.FrequencyNum) + " )")
 	}
 
 	//-1,代表值无效，由参数给与

domain/model/diamond_m/repo.go

@@ -3,7 +3,6 @@ package diamond_m
 import (
 	"git.hilo.cn/hilo-common/resource/mysql"
 	"gorm.io/gorm"
-	"hilo-user/domain/model"
 	"hilo-user/myerr"
 	"strconv"
 )
@@ -32,7 +31,10 @@ func (diamondAccountDetail *DiamondAccountDetail) PersistentNoInTransactional()
 	}
 
 	//持久化diamondAccountDetail
-	if err := model.Persistent(diamondAccountDetail.Db, diamondAccountDetail); err != nil {
+	//if err := model.Persistent(diamondAccountDetail.Db, diamondAccountDetail); err != nil {
+	//	return myerr.WrapErr(err)
+	//}
+	if err := diamondAccountDetail.DB().Table(diamondAccountDetail.TableName()).Save(diamondAccountDetail).Error; err != nil {
 		return myerr.WrapErr(err)
 	}
 	//改变diamondAccount值

domain/model/group_m/groupInfo.go

@@ -76,6 +76,18 @@ func ToTxGroupId(model *domain.Model, imGroupId string) (string, error) {
 	return gi.TxGroupId, nil
 }
 
+func ToTxGroupIdMap(model *domain.Model, imGroupIds []string) (map[string]string, error) {
+	var res = make(map[string]string)
+	var rows []GroupInfo
+	if err := model.DB().Model(GroupInfo{}).Where("im_group_id in ?", imGroupIds).Find(&rows).Error; err != nil {
+		return res, err
+	}
+	for _, v := range rows {
+		res[v.ImGroupId] = v.TxGroupId
+	}
+	return res, nil
+}
+
 func ToImGroupId(model *domain.Model, txGroupId string) (string, error) {
 	if len(txGroupId) <= 0 {
 		return "", nil

domain/model/group_m/room.go

@@ -4,7 +4,6 @@ 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/resource/redisCli"
 	"hilo-user/_const/redis_key/group_k"
 	"hilo-user/myerr"
 	"strconv"
@@ -12,7 +11,8 @@ import (
 	"time"
 )
 
-const expireMinute = 60 * 60 * 12
+// 3天
+const expireMinute = 60 * 60 * 24 * 3
 
 //获取在房间的用户 返回值：map,key:userId, value:groupUuid
 func RoomLivingUserIdFilter(model *domain.Model, userIds []mysql.ID) (map[mysql.ID]string, error) {
@@ -25,7 +25,7 @@ func RoomLivingUserIdFilter(model *domain.Model, userIds []mysql.ID) (map[mysql.
 		return nil, myerr.WrapErr(err)
 	}
 
-	groupUserIdstrs, err := redisCli.GetRedis().ZRange(model, key, 0, -1).Result()
+	groupUserIdstrs, err := model.RedisCluster.ZRange(model, key, 0, -1).Result()
 	if err != nil {
 		return nil, myerr.WrapErr(err)
 	}
@@ -33,7 +33,6 @@ func RoomLivingUserIdFilter(model *domain.Model, userIds []mysql.ID) (map[mysql.
 	resultUserSet := map[mysql.ID]string{}
 	for i, _ := range groupUserIdstrs {
 		tempGroupUid, userId := analysisMemberStr(groupUserIdstrs[i])
-		mylogrus.MyLog.Debugf("RoomLivingUserIdFilter, analysisMemberStr %s, %d", tempGroupUid, userId)
 
 		if _, flag := userIdSet[userId]; flag {
 			resultUserSet[userId] = tempGroupUid
@@ -43,7 +42,7 @@ func RoomLivingUserIdFilter(model *domain.Model, userIds []mysql.ID) (map[mysql.
 }
 
 func ClearExpired(model *domain.Model, key string, expireSec int64) error {
-	return model.Redis.ZRemRangeByScore(model, key,
+	return model.RedisCluster.ZRemRangeByScore(model, key,
 		"0", strconv.FormatInt(time.Now().Unix()-expireSec, 10)).Err()
 }
 

domain/model/invite_m/invite_apply.go

+package invite_m
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"git.hilo.cn/hilo-common/utils"
+	"gorm.io/gorm"
+	"time"
+)
+
+type InviteApply struct {
+	Id           uint64    `json:"id"`
+	UserId       uint64    `json:"user_id"`
+	NewUserId    uint64    `json:"new_user_id"`
+	Platform     string    `json:"platform"`
+	PlatformId   string    `json:"platform_id"`
+	RechargeInfo string    `json:"recharge_info"`
+	Status       uint8     `json:"status"` // 状态0.未审核1.已通过2.已拒绝
+	VideoUrl     string    `json:"video_url"`
+	Level        string    `json:"level"`
+	CreatedTime  time.Time `json:"created_time"`
+	Reason       int       `json:"reason"`      // 1.已申请2.待审核3.已通过4.已拒绝"
+	SubUserId    uint64    `json:"sub_user_id"` // 提交人
+}
+
+func CreateInviteApply(model *domain.Model, userId, newUserId, subUserId uint64, platform, platformId, recharge, videoUrl string) error {
+	err := model.DB().Create(&InviteApply{
+		UserId: userId, NewUserId: newUserId, Platform: platform, PlatformId: platformId, RechargeInfo: recharge, VideoUrl: videoUrl,
+		CreatedTime: time.Now(), SubUserId: subUserId}).Error
+	if err != nil {
+		model.Log.Errorf("CreateInviteApply err:%v", err)
+		return err
+	}
+	return nil
+}
+
+func GetApplyList(model *domain.Model, subUserId uint64, userIds []uint64, pageIndex, pageSize, gType int, beginTime,
+	endTime time.Time) ([]*InviteApply, int64, error) {
+	db := model.DB().Model(InviteApply{}).Where("user_id in (?) or sub_user_id = ?", userIds, subUserId).Where("created_time >= ? and created_time <= ?", beginTime, endTime)
+	switch gType { // 1.已申请2.待审核3.已通过4.已拒绝
+	case 2:
+		db = db.Where("`status` = ?", 0)
+	case 3:
+		db = db.Where("`status` = ?", 1)
+	case 4:
+		db = db.Where("`status` = ?", 2)
+	}
+	res := make([]*InviteApply, 0)
+	var count int64
+	err := db.Order("id desc").Offset((pageIndex - 1) * pageSize).Find(&res).Limit(-1).Offset(-1).Count(&count).Error
+	if err != nil {
+		model.Log.Errorf("GetApplyList err:%v", err)
+		return nil, 0, err
+	}
+	return res, count, nil
+}
+
+// 检查被邀请人是否存在
+func IsInInviteApply(model *domain.Model, userId mysql.ID) (bool, error) {
+	var apply InviteApply
+	if err := model.Db.Model(InviteApply{}).Where("new_user_id = ?", userId).First(&apply).Error; err != nil {
+		if err != gorm.ErrRecordNotFound {
+			return false, err
+		}
+		return false, nil
+	}
+	// err == nil, record exists
+	return true, nil
+}
+
+// 检查被邀请人是否存在
+func GetInviteApplyNumByType(model *domain.Model, gType int, beginTime, endTime time.Time, userIds []uint64, subUserId uint64) (int, error) {
+	var count int64
+	db := model.Db.Model(InviteApply{}).Where("user_id in (?) or sub_user_id = ?", userIds, subUserId).Where("created_time >= ? and created_time <= ?", beginTime, endTime)
+	switch gType { // 1.已申请2.待审核3.已通过4.已拒绝
+	case 2:
+		db = db.Where("`status` = ?", 0)
+	case 3:
+		db = db.Where("`status` = ?", 1)
+	case 4:
+		db = db.Where("`status` = ?", 2)
+	}
+	if err := db.Count(&count).Error; err != nil {
+		return 0, err
+	}
+	return int(count), nil
+}
+
+// 今日已提交次数
+func TodayInviteApplyCount(model *domain.Model, userId mysql.ID) (int64, error) {
+	start, end := utils.DayStartEnd(time.Now())
+	var count int64
+	if err := model.Db.Model(InviteApply{}).
+		Where("user_id = ?", userId).
+		Where("created_time >= ? and created_time <= ?", start.Format(utils.DATETIME_FORMAT), end.Format(utils.DATETIME_FORMAT)).
+		Count(&count).Error; err != nil {
+		return 0, err
+	}
+	// err == nil, record exists
+	return count, nil
+}

domain/model/promotion_m/model.go

+package promotion_m
+
+import "git.hilo.cn/hilo-common/resource/mysql"
+
+// 推广员
+type PromotionAgent struct {
+	mysql.Entity
+	ManagerId mysql.ID
+	AgentId   mysql.ID
+}
+
+// 邀请关系
+type PromotionInvite struct {
+	mysql.Entity
+	ManagerId  mysql.ID
+	AgentId    mysql.ID
+	Invitee    mysql.ID
+	Platform   string
+	PlatformId string
+	Reason     string
+	InviteDate string
+}
+
+// 邀请关系日志
+type PromotionInviteLog struct {
+	mysql.Entity
+	AgentId   mysql.ID
+	Invitee   mysql.ID
+	AddReduce mysql.AddReduce
+}

domain/model/promotion_m/promotion_info.go

+package promotion_m
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"gorm.io/gorm"
+)
+
+// 获取推广员平台
+func GetPromotionPlatforms(model *domain.Model) []string {
+	return []string{"Falla", "Yalla", "Whisper", "Ahlan", "Mashi", "YoYo", "Yoho", "Echo", "Hawa", "Yalla Ludo", "Hafla",
+		"Imo", "Ola Party", "ShareChat", "Viya", "Hello Yo", "Bigo Live", "Hago", "Oye Talk", "Tiktok", "Bigo", "Mr7ba"}
+}
+
+// 检查是否推广员
+func IsPromotionAgent(model *domain.Model, userId mysql.ID) bool {
+	var promotionAgent PromotionAgent
+	if err := model.Db.Model(PromotionAgent{}).Where("agent_id = ?", userId).First(&promotionAgent).Error; err != nil {
+		if err != gorm.ErrRecordNotFound {
+			model.Log.Errorf("IsPromotionAgent fail:%v", err)
+		}
+	} else if promotionAgent.ID > 0 {
+		return true
+	}
+	return false
+}
+
+// 检查被邀请人是否存在
+func IsPromotionInvitee(model *domain.Model, userId mysql.ID) (bool, error) {
+	var promotionInvite PromotionInvite
+	if err := model.Db.Model(PromotionInvite{}).Where("invitee = ?", userId).First(&promotionInvite).Error; err != nil {
+		if err != gorm.ErrRecordNotFound {
+			return false, err
+		}
+		return false, nil
+	}
+	// err == nil, record exists
+	return true, nil
+}
+
+// 检查是否推广经理
+func IsPromotionManager(model *domain.Model, userId mysql.ID) bool {
+	var promotionAgent PromotionAgent
+	if err := model.Db.Model(PromotionAgent{}).Where("manager_id = ?", userId).First(&promotionAgent).Error; err != nil {
+		if err != gorm.ErrRecordNotFound {
+			model.Log.Errorf("IsPromotionManager fail:%v", err)
+		}
+	} else if promotionAgent.ID > 0 {
+		return true
+	}
+	return false
+}
+
+// 检查是否我的推广经理
+func IsMyPromotionManager(model *domain.Model, userId, myUserId mysql.ID) bool {
+	var promotionAgent PromotionAgent
+	if err := model.Db.Model(PromotionAgent{}).Where("manager_id = ? and agent_id = ?", userId, myUserId).First(&promotionAgent).Error; err != nil {
+		if err != gorm.ErrRecordNotFound {
+			model.Log.Errorf("IsMyPromotionManager fail:%v", err)
+		}
+	} else if promotionAgent.ID > 0 {
+		return true
+	}
+	return false
+}
+
+// 获取推广经理拥有的所有推广员，包含自己
+func GetPromotionManagerAgentList(model *domain.Model, userId mysql.ID) ([]uint64, error) {
+	uids := make([]uint64, 0)
+	if err := model.Db.Model(PromotionAgent{}).Where("manager_id = ?", userId).Select("agent_id").
+		Pluck("agent_id", &uids).Error; err != nil {
+		model.Log.Errorf("IsPromotionManager fail:%v", err)
+		return nil, err
+	}
+	return uids, nil
+}
+
+// 添加推广邀请关系
+func AddPromotionInvite(model *domain.Model, managerId, agentId, invitee mysql.ID, platform, platformId, reason, inviteDate string) error {
+	if err := model.Db.Create(&PromotionInvite{
+		ManagerId:  managerId,
+		AgentId:    agentId,
+		Invitee:    invitee,
+		Platform:   platform,
+		PlatformId: platformId,
+		Reason:     reason,
+		InviteDate: inviteDate,
+	}).Error; err != nil {
+		return err
+	}
+	return addPromotionInviteLog(model, agentId, invitee, mysql.ADD)
+}
+
+// 添加推广邀请关系-日志
+func addPromotionInviteLog(model *domain.Model, agentId, invitee mysql.ID, addReduce mysql.AddReduce) error {
+	return model.Db.Create(&PromotionInviteLog{
+		AgentId:   agentId,
+		Invitee:   invitee,
+		AddReduce: addReduce,
+	}).Error
+}

domain/model/recommend_m/gift.go

+package recommend_m
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"github.com/bluele/gcache"
+	"time"
+)
+
+// 推荐用户送礼
+type recommendUserGift struct {
+	SendUserId      mysql.ID
+	SendUserDiamond mysql.Num
+}
+
+var recommendUserGiftKey = "recommendUserGiftKey"
+var recommendUserGiftCache = gcache.New(1).LRU().Build()
+
+// 推荐最近送礼的50人，最近12小时赠送礼物大于100k的用户
+func SyncPastTop50SendGiftUsers(model *domain.Model) {
+	limitUserIds, _ := GetBillboardLimitUserList(model)
+	var res []recommendUserGift
+	if err := model.DB().Table("gift_operate g").Joins("INNER JOIN user u ON u.id = g.send_user_id").Select("send_user_id,SUM(send_user_diamond) send_user_diamond").
+		Where("u.avatar <> ''").
+		Where("g.created_time >= ?", time.Now().Add(-time.Hour*12)).
+		Where("send_user_id NOT in ?", limitUserIds).
+		Group("send_user_id").
+		Having("send_user_diamond > 100000").Order("send_user_diamond DESC").Limit(34).Find(&res).Error; err != nil {
+		model.Log.Errorf("GetPastTop50SendGiftUsers fail:%v", err)
+	}
+	_ = recommendUserGiftCache.Set(recommendUserGiftKey, res)
+}
+
+// 只从缓存中拿
+func GetPastTop50SendGiftUsers(model *domain.Model) []recommendUserGift {
+	if data, err := recommendUserGiftCache.Get(recommendUserGiftKey); err == nil {
+		return data.([]recommendUserGift)
+	}
+	return []recommendUserGift{}
+}
+
+// 榜单黑名单
+func GetBillboardLimitUserList(model *domain.Model) ([]uint64, error) {
+	var userIds []uint64
+	if err := model.Db.Table("billboard_limit_user").Select("user_id").Find(&userIds).Error; err != nil {
+		return nil, err
+	}
+	return userIds, nil
+}

domain/model/user_m/medal.go

@@ -61,8 +61,8 @@ func GetUserMedalMerge(logger *logrus.Entry, db *gorm.DB, userId mysql.ID) ([]ui
 			}
 		}
 	}
-	logger.Infof("maxGrade %+v", maxGrades)
-	logger.Infof("maxMedalIds %+v", maxMedalIds)
+	//logger.Infof("maxGrade %+v", maxGrades)
+	//logger.Infof("maxMedalIds %+v", maxMedalIds)
 
 	mIds := result
 	result = make([]uint32, 0)

domain/model/user_m/user.go

@@ -52,6 +52,11 @@ func (u User) IsPrettyCode() bool {
 	return u.Code != u.OriginCode
 }
 
+// 七天内注册
+func (u User) IsNew() bool {
+	return time.Now().Sub(u.CreatedTime).Hours() < 24*7
+}
+
 //获取用户
 func GetUser(model *domain.Model, id mysql.ID) (*User, error) {
 	var user User

domain/service/cp_s/cp_relation.go

@@ -130,22 +130,31 @@ func CancelCpRelation(myCtx *mycontext.MyContext, myUserId uint64, externalId, l
 		return err
 	}
 
-	// 自己没有cp了
-	myCp, err := cp_m.GetCp(model, myUserId)
-	if err != nil {
-		return err
-	}
-	if myCp.Id == 0 {
-		return myerr.WrapErr(bizerr.InvalidParameter)
-	}
-	// 对方没有cp了
-	inviCp, err := cp_m.GetCp(model, userRec.ID)
+	// 我和对方是否是cp，且cp关系存在
+	cpRelation, err := cp_m.GetCpByIds(model, myUserId, userRec.ID)
 	if err != nil {
 		return err
 	}
-	if inviCp.Id == 0 {
+	if cpRelation.Id == 0 {
+		model.Log.Errorf("CancelCpRelation cp关系不存在 id1:%v, id2:%v", myUserId, userRec.ID)
 		return myerr.WrapErr(bizerr.InvalidParameter)
 	}
+	//// 自己没有cp了
+	//myCp, err := cp_m.GetCp(model, myUserId)
+	//if err != nil {
+	//	return err
+	//}
+	//if myCp.Id == 0 {
+	//	return myerr.WrapErr(bizerr.InvalidParameter)
+	//}
+	//// 对方没有cp了
+	//inviCp, err := cp_m.GetCp(model, userRec.ID)
+	//if err != nil {
+	//	return err
+	//}
+	//if inviCp.Id == 0 {
+	//	return myerr.WrapErr(bizerr.InvalidParameter)
+	//}
 
 	// 是否有关于我的cp解除申请，且还未被处理
 	myCancel, err := cp_m.GetCpCancelWithMe(model, user.ID, cp_e.CpCancel)

domain/service/event_s/event_init.go

@@ -14,7 +14,7 @@ import (
 
 func EventInit() {
 	UserBagSendEvent()
-	CpGiftEvent()
+	//CpGiftEvent()
 	CpSpaceVisitEvent()
 }
 

domain/service/user_s/user.go

@@ -172,11 +172,11 @@ func (s *UserService) GetUserDetail(userId mysql.ID, myUserId mysql.ID, lang str
 
 	//rp := res_m.ResProperty{}
 	//properties, err := rp.GetAll(mysql.Db)
-	_, myArea, err := user_m.GetUserCountryArea(model, myUserId)
+	_, area, err := user_m.GetUserCountryArea(model, userId)
 	if err != nil {
 		return nil, err
 	}
-	properties, err := property_cv.GetPropertyAll(mysql.Db, myArea)
+	properties, err := property_cv.GetPropertyAll(mysql.Db, area)
 	if err != nil {
 		return nil, err
 	}
@@ -285,6 +285,7 @@ func userToDetailOne(model *domain.Model, user *user_m.User, myUserId mysql.ID,
 			CountryIcon:     StrNil(user.CountryIcon),
 			Code:            StrToString(&user.Code),
 			IsPrettyCode:    user.IsPrettyCode(),
+			IsNew:           user.IsNew(),
 			IsVip:           isVip,
 			IsOfficialStaff: isOfficialStaff,
 			VipExpireTime:   vipExpireTime,

local.ini

@@ -11,6 +11,8 @@ MYSQL_DB=hilo_code
 [REDIS]
 REDIS_HOST=47.244.34.27:6379
 REDIS_PASSWORD=8QZ9JD1zLvPR3yHf
+REDIS_CLUSTER_HOST=47.244.34.27:6379
+REDIS_CLUSTER_PASSWORD=8QZ9JD1zLvPR3yHf
 [JWT]
 SECRET=hilo1632
 ISSUER_API=hiloApi

main.go

@@ -3,6 +3,7 @@ package main
 import (
 	"fmt"
 	"git.hilo.cn/hilo-common/resource/consul"
+	"git.hilo.cn/hilo-common/resource/redisCli"
 	"hilo-user/cron"
 	"hilo-user/domain/service/event_s"
 	"hilo-user/route"
@@ -17,6 +18,7 @@ const (
 func main() {
 	cron.Init()                                              // 开启定时任务
 	event_s.EventInit()                                      // 注册事件(内部事件+mysql拟kafka)
+	redisCli.InitCluster()                                   // redis集群
 	r := route.InitRouter()                                  // 注册路由
 	consul.RegisterToConsul(PORT, RegisterName, RegisterTag) // 服务注册
 	r.Run(fmt.Sprintf(":%d", PORT))                          // 启动服务

myerr/bizerr/bizCode.go

@@ -6,6 +6,7 @@ import (
 
 var (
 	// 一般性错误
+	HttpSecret        = myerr.NewBusinessCode(1000, "http secret err", myerr.BusinessData{})
 	TokenInvalid      = myerr.NewBusinessCode(1001, "token invalid", myerr.BusinessData{})
 	ExternalIdNoExist = myerr.NewBusinessCode(1003, "externalId no exist", myerr.BusinessData{})
 	CodeNoExist       = myerr.NewBusinessCode(1005, "code no exist", myerr.BusinessData{})
@@ -26,6 +27,11 @@ var (
 	// 群组
 	GroupNotFound = myerr.NewBusinessCode(14001, "Group not found", myerr.BusinessData{}) // 找不到该群
 
-	CpAlreadyInvite    = myerr.NewBusinessCode(50120, "Already invited", myerr.BusinessData{})         // 已经发送过邀请了
-	CpHaveCancelNoDeal = myerr.NewBusinessCode(50121, "You have a cancel apply", myerr.BusinessData{}) // 有接触申请需要处理
+	CpAlreadyInvite           = myerr.NewBusinessCode(50120, "Already invited", myerr.BusinessData{})                                                                                          // 已经发送过邀请了
+	CpHaveCancelNoDeal        = myerr.NewBusinessCode(50121, "You have a cancel apply", myerr.BusinessData{})                                                                                  // 有接触申请需要处理
+	InviteApplyNoPermission   = myerr.NewBusinessCode(50122, "This user does not have invitation permission", myerr.BusinessData{})                                                            // 该用户没有邀请权限
+	InviteApplyAlreadyInvited = myerr.NewBusinessCode(50123, "Already invited by someone else", myerr.BusinessData{})                                                                          // 已经被别人邀请了
+	InviteApplyCodeInvalid    = myerr.NewBusinessCode(50124, "user id invalid", myerr.BusinessData{})                                                                                          // 邀请人用户id错误
+	InviteApplyNewCodeInvalid = myerr.NewBusinessCode(50125, "user id invalid", myerr.BusinessData{})                                                                                          // 被邀请人用户id错误
+	InviteApplyTimes          = myerr.NewBusinessCode(50126, "Your application today has reached the upper limit, please wait for tomorrow to continue the application", myerr.BusinessData{}) // 今日邀请次数太多
 )

mysql/新人派对申请.sql

+CREATE TABLE `invite_apply` (
+                             `id` bigint unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+                             `user_id` bigint NOT NULL COMMENT '发起申请者',
+                             `new_user_id` bigint NOT NULL COMMENT '被邀请的人',
+                             `platform` varchar(20) NOT NULL COMMENT '来自平台',
+                             `platform_id` varchar(150) NOT NULL COMMENT '平台id',
+                             `recharge_info` varchar(50) NOT NULL COMMENT '新用户在其它平台充值的标志',
+                             `status` tinyint unsigned NOT NULL COMMENT '状态0.未审核1.已通过2.已拒绝',
+                             `level` varchar(5) NOT NULL DEFAULT '' COMMENT '申请等级(S,A,B,C)',
+                             `video_url` varchar(400) NOT NULL COMMENT '上传的视频url',
+                             `reason` tinyint unsigned NOT NULL DEFAULT '0' COMMENT '拒绝原因',
+                             `sub_user_id` bigint NOT NULL COMMENT '提交人',
+                             `created_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
+                             `updated_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+                             PRIMARY KEY (`id`),
+                             KEY `user_id` (`user_id`) USING BTREE,
+                             KEY `new_user_id` (`new_user_id`) USING BTREE,
+                             KEY `platform` (`platform`) USING BTREE,
+                             KEY `platform_id` (`platform_id`) USING BTREE,
+                             KEY `status` (`status`) USING BTREE,
+                             KEY `created_time` (`created_time`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='新人邀请申请';
+
+INSERT INTO hilo.res_msg_translate (`language`, title, content, icon_url, msg_type, `type`, action_type, action_url)
+VALUES ('en', '', 'The welcome party application of user {nick} (ID: {diamondIncome}) has been approved, the welcome party level is: {dayNum} level, inviter {beanNum} (ID: {groupCode})', '', 1, 59, 0, ''),
+       ('tr', '', '{nick} kullanıcısının (ID: {diamondIncome}) karşılama partisi uygulaması onaylandı, karşılama partisi seviyesi: {dayNum} seviyesi, davet eden {beanNum} (ID: {groupCode})', '', 1, 59, 0, ''),
+       ('en', '', 'The welcome party application of user {nick} (ID: {diamondIncome}) has been rejected. The reason for the rejection is: {dayNum}, inviter {beanNum} (ID: {groupCode})', '', 1, 60, 0, ''),
+       ('tr', '', '{nick} kullanıcısının (ID: {diamondIncome}) karşılama partisi başvurusu reddedildi. Reddedilme nedeni: {dayNum}, davet eden {beanNum} (ID: {groupCode})', '', 1, 60, 0, ''),
+       ('en', '', 'Welcome party application, please click to enter', 'https://image.whoisamy.shop/hilo/manager/welcomeparty.png', 1, 61, 1, 'https://h5.whoisamy.shop/action/hiloHtml/2023Activity/2023_7_03WelcomeParty/index.html'),
+       ('tr', '', 'hoşgeldin partisi uygulaması, girmek için lütfen tıklayınız', 'https://image.whoisamy.shop/hilo/manager/welcomeparty.png', 1, 61, 1, 'https://h5.whoisamy.shop/action/hiloHtml/2023Activity/2023_7_03WelcomeParty/index.html');
+
+
+INSERT INTO mgr_permission_config (id, parent_id, name, method_url, `type`)
+VALUES(3224, 2663, '欢迎派对审核', 'POST:/v1/mgr/invite/apply?$', 0),
+      (3225, 2663, '欢迎派对审核-列表', 'GET:/v1/mgr/invite/apply?$', 0);

release.ini

 [DATABASE]
 MYSQL_HOST=ua4papc3hmgqf351pbej-rw4rm.rwlb.dubai.rds.aliyuncs.com
-MYSQL_USERNAME=nextvideo
+MYSQL_USERNAME=hilo_user
 MYSQL_PASSWORD=ihlUwI4nhi9W88MI
 MYSQL_DB=hilo
 [DATABASECODE]
@@ -11,6 +11,8 @@ MYSQL_DB=hilo_code
 [REDIS]
 REDIS_HOST=r-eb3btxn8vfdsuwdbuf.redis.dubai.rds.aliyuncs.com:6379
 REDIS_PASSWORD=
+REDIS_CLUSTER_HOST=r-eb3yt6k8zgxs62kjjs.redis.dubai.rds.aliyuncs.com:6379
+REDIS_CLUSTER_PASSWORD=
 [JWT]
 SECRET=hilo1504
 ISSUER_API=hiloApi

resp/response.go

@@ -76,6 +76,32 @@ func ResponsePageBaseOk(c *gin.Context, data interface{}, nextPageIndex int, has
 	c.JSON(http.StatusOK, response)
 }
 
+// 分页返回
+// 客户端入参 req.PageReqBase
+// 服务端返回 req.PageRespBase
+func ResponsePageOk(c *gin.Context, data interface{}, total int64, pageSize, pageIndex int) {
+	if data == nil {
+		data = make([]interface{}, 0)
+	}
+	nextPageIndex := 0
+	hasNextPage := false
+	if (pageIndex-1)*pageSize+pageSize-1 < int(total) {
+		nextPageIndex = pageIndex + 1
+		hasNextPage = true
+	}
+	response := Response{
+		Code:             myerr.GetSuccessCode(),
+		Message:          myerr.GetSuccessMsg(),
+		OperationMessage: myerr.GetSuccessMsg(),
+		Data: req.PageRespBase{
+			NextPageIndex: nextPageIndex,
+			HasNextPage:   hasNextPage,
+			Data:          data,
+		},
+	}
+	c.JSON(http.StatusOK, response)
+}
+
 func ResponseWaring(c *gin.Context, waringError *myerr.WaringError) {
 	response := Response{
 		Code:             waringError.GetCode(),

route/cp_r/rank.go

@@ -81,8 +81,8 @@ func CpRank(c *gin.Context) (*mycontext.MyContext, error) {
 	for i, rank := range ranks {
 		response = append(response, cp_cv.CvCpRank{
 			CpId:    rank.CpId,
-			User1:   userBase[rank.UserId1],
-			User2:   userBase[rank.UserId2],
+			User1:   user_cv.UserBaseToUserLittle(userBase[rank.UserId1]),
+			User2:   user_cv.UserBaseToUserLittle(userBase[rank.UserId2]),
 			Score:   rank.Score,
 			Ranking: fmt.Sprintf("%d", i+1+offset),
 			CpLevel: cp_cv.CvCpLevel{
@@ -143,8 +143,8 @@ func CpTop3(c *gin.Context) (*mycontext.MyContext, error) {
 			if queryType == "day" {
 				response.Day = append(response.Day, cp_cv.CvCpRank{
 					CpId:    rank.CpId,
-					User1:   userBase[rank.UserId1],
-					User2:   userBase[rank.UserId2],
+					User1:   user_cv.UserBaseToUserLittle(userBase[rank.UserId1]),
+					User2:   user_cv.UserBaseToUserLittle(userBase[rank.UserId2]),
 					Score:   rank.Score,
 					Ranking: fmt.Sprintf("%d", i+1+offset),
 					CpLevel: cp_cv.CvCpLevel{
@@ -154,8 +154,8 @@ func CpTop3(c *gin.Context) (*mycontext.MyContext, error) {
 			} else {
 				response.Week = append(response.Week, cp_cv.CvCpRank{
 					CpId:    rank.CpId,
-					User1:   userBase[rank.UserId1],
-					User2:   userBase[rank.UserId2],
+					User1:   user_cv.UserBaseToUserLittle(userBase[rank.UserId1]),
+					User2:   user_cv.UserBaseToUserLittle(userBase[rank.UserId2]),
 					Score:   rank.Score,
 					Ranking: fmt.Sprintf("%d", i+1+offset),
 					CpLevel: cp_cv.CvCpLevel{
@@ -224,10 +224,10 @@ func CpMy(c *gin.Context) (*mycontext.MyContext, error) {
 		Score: scores,
 	}
 	if relation.UserId1 > 0 {
-		response.User1 = userBases[relation.UserId1]
+		response.User1 = user_cv.UserBaseToUserLittle(userBases[relation.UserId1])
 	}
 	if relation.UserId2 > 0 {
-		response.User2 = userBases[relation.UserId2]
+		response.User2 = user_cv.UserBaseToUserLittle(userBases[relation.UserId2])
 		response.Ranking = "30+"
 		ranks := cp_m.PageCpDayRank(model, beginDate, endDate, 0, 30)
 		for i, rank := range ranks {

route/invite_r/party_invite.go

+package invite_r
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"git.hilo.cn/hilo-common/mycontext"
+	"git.hilo.cn/hilo-common/utils"
+	"github.com/gin-gonic/gin"
+	"github.com/jinzhu/now"
+	"hilo-user/cv/invite_cv"
+	"hilo-user/domain/cache/user_c"
+	"hilo-user/domain/model/invite_m"
+	"hilo-user/domain/model/promotion_m"
+	"hilo-user/domain/model/user_m"
+	"hilo-user/myerr/bizerr"
+	"hilo-user/req"
+	"hilo-user/resp"
+	"time"
+)
+
+// @Tags 新人邀请
+// @Summary 提交申请
+// @Param newUserCode formData string true "被邀请人id"
+// @Param platform formData string true "平台"
+// @Param platformId formData string true "平台Id"
+// @Param recharge formData string true "充值金额"
+// @Param userCode formData string true "邀请人id"
+// @Param videoUrl formData string true "充值金额"
+// @Success 200
+// @Router /v2/user/invite/apply [post]
+func InviteApply(c *gin.Context) (*mycontext.MyContext, error) {
+	myCtx := mycontext.CreateMyContext(c.Keys)
+
+	type paramStr struct {
+		NewUserCode string `form:"newUserCode" binding:"required"`
+		Platform    string `form:"platform" binding:"required"`
+		PlatformId  string `form:"platformId" binding:"required"`
+		Recharge    string `form:"recharge" binding:"required"`
+		UserCode    string `form:"userCode" binding:"required"`
+		VideoUrl    string `form:"videoUrl" binding:"required"`
+	}
+
+	myUserId, err := req.GetUserId(c)
+	if err != nil {
+		return myCtx, err
+	}
+	model := domain.CreateModelContext(myCtx)
+	// 每日最多提交10次
+	noLimitTimesMap := map[uint64]struct{}{1770691: {}, 2264431: {}, 7283111: {}}
+	if _, ok := noLimitTimesMap[myUserId]; !ok {
+		// 今日提交次数
+		times, err := invite_m.TodayInviteApplyCount(model, myUserId)
+		if err != nil {
+			model.Log.Errorf("InviteApply myUserId:%v, err:%v", myUserId, err)
+			return myCtx, err
+		}
+		if times >= 15 {
+			return myCtx, bizerr.InviteApplyTimes
+		}
+	}
+
+	var param paramStr
+	if err := c.ShouldBind(&param); err != nil {
+		return myCtx, err
+	}
+	// 平台是否填写正确
+	platforms := promotion_m.GetPromotionPlatforms(model)
+	var existsPlatform bool
+	for _, v := range platforms {
+		if v == param.Platform {
+			existsPlatform = true
+		}
+	}
+	if !existsPlatform {
+		model.Log.Errorf("InviteApply param:%v", param)
+		return myCtx, bizerr.InvalidParameter
+	}
+	// code 是否存在
+	newUser, err := user_m.GetUserByCode(model, param.NewUserCode)
+	if err != nil {
+		model.Log.Errorf("InviteApply param:%v", param)
+		return myCtx, bizerr.InviteApplyNewCodeInvalid
+	}
+	user, err := user_m.GetUserByCode(model, param.UserCode)
+	if err != nil {
+		model.Log.Errorf("InviteApply param:%v", param)
+		return myCtx, bizerr.InviteApplyCodeInvalid
+	}
+	//if user.ID != myUserId { //只能自己提交
+	//	return myCtx, bizerr.InvalidParameter
+	//}
+	if newUser.ID == 0 || user.ID == 0 {
+		model.Log.Errorf("InviteApply param:%v", param)
+		return myCtx, bizerr.InvalidParameter
+	}
+	// 邀请人是否有资格邀请
+	if !promotion_m.IsPromotionAgent(model, user.ID) {
+		model.Log.Errorf("InviteApply 没有邀请资格 param:%v", param)
+		return myCtx, bizerr.InviteApplyNoPermission
+	}
+	//if user.ID != myUserId && !promotion_m.IsMyPromotionManager(model, user.ID, myUserId) {
+	//	model.Log.Errorf("InviteApply 没有邀请资格 param:%v", param)
+	//	return myCtx, bizerr.InviteApplyNoPermission
+	//}
+	// 被邀请人是否已经被人提交过申请
+	isApply, err := invite_m.IsInInviteApply(model, newUser.ID)
+	if err != nil {
+		model.Log.Errorf("InviteApply param:%v, err:%v", param, err)
+		return myCtx, err
+	}
+	if isApply {
+		model.Log.Errorf("InviteApply 已经被别人邀请过了 param:%v", param)
+		return myCtx, bizerr.InviteApplyAlreadyInvited
+	}
+	// 被邀请人是否符合条件
+	isInvite, err := promotion_m.IsPromotionInvitee(model, newUser.ID)
+	if err != nil {
+		model.Log.Errorf("InviteApply param:%v", param)
+		return myCtx, err
+	}
+	if isInvite {
+		model.Log.Errorf("InviteApply 已经被别人邀请了 param:%v", param)
+		return myCtx, bizerr.InviteApplyAlreadyInvited
+	}
+	// 插入邀请表
+	err = invite_m.CreateInviteApply(model, user.ID, newUser.ID, myUserId, param.Platform, param.PlatformId, param.Recharge, param.VideoUrl)
+	if err != nil {
+		model.Log.Errorf("InviteApply param:%v", param)
+		return myCtx, err
+	}
+
+	resp.ResponseOk(c, nil)
+	return myCtx, nil
+}
+
+// @Tags 新人邀请
+// @Summary 查询历史申请
+// @Param pageIndex query int true "偏移值 默认：1" default(1)
+// @Param pageSize query int true "请求数量 默认：10" default(10)
+// @Param beginTime query string true "开始时间2006-01-02"
+// @Param endTime query string true "结束时间2006-01-02"
+// @Param type query int true "1.已申请2.待审核3.已通过4.已拒绝"
+// @Success 200 {object} invite_cv.InviteApplyRes
+// @Router /v2/user/invite/apply [get]
+func InviteApplyList(c *gin.Context) (*mycontext.MyContext, error) {
+	myCtx := mycontext.CreateMyContext(c.Keys)
+
+	type paramStr struct {
+		PageIndex int       `form:"pageIndex" binding:"required"`
+		PageSize  int       `form:"pageSize" binding:"required"`
+		BeginTime time.Time `form:"beginTime" binding:"required" time_format:"2006-01-02"`
+		EndTime   time.Time `form:"endTime" binding:"required" time_format:"2006-01-02"`
+		Type      int       `form:"type"`
+	}
+
+	var param paramStr
+	if err := c.ShouldBindQuery(&param); err != nil {
+		return myCtx, err
+	}
+	if param.Type < 0 || param.Type > 4 {
+		return myCtx, bizerr.InvalidParameter
+	}
+
+	//beginTime, err := time.ParseInLocation(utils.DATE_FORMAT, param.BeginTime, time.Local)
+	//if err != nil {
+	//	return nil, myerr.WrapErr(err)
+	//}
+	//endTime, err := time.ParseInLocation(utils.DATE_FORMAT, param.EndTime, time.Local)
+	//if err != nil {
+	//	return nil, myerr.WrapErr(err)
+	//}
+	param.EndTime = utils.GetDayEndTime(param.EndTime)
+	userId, err := req.GetUserId(c)
+	if err != nil {
+		return myCtx, err
+	}
+
+	var model = domain.CreateModelContext(myCtx)
+
+	agentIds := []uint64{userId}
+	if promotion_m.IsPromotionManager(model, userId) {
+		agentIds, err = promotion_m.GetPromotionManagerAgentList(model, userId)
+		if err != nil {
+			return myCtx, err
+		}
+	}
+
+	if param.Type == 0 { // 返回所有Type类型有多少条数
+		user, err := user_c.GetUserTinyById(model, userId)
+		if err != nil {
+			model.Log.Errorf("GetApplyList param:%v, err:%v", param, err)
+			return myCtx, bizerr.InvalidParameter
+		}
+		numList := make([]*invite_cv.InviteApplyNumRes, 0, 4)
+		for _, gType := range []int{1, 2, 3, 4} { // 1.已申请2.待审核3.已通过4.已拒绝
+			num, err := invite_m.GetInviteApplyNumByType(model, gType, param.BeginTime, param.EndTime, agentIds, userId)
+			if err != nil {
+				return myCtx, err
+			}
+			numList = append(numList, &invite_cv.InviteApplyNumRes{Type: gType, Num: num})
+		}
+		resp.ResponsePageOk(c, &invite_cv.InviteApplyRes{NumList: numList, MyCode: user.Code}, 0, 0, 0)
+		return myCtx, nil
+	}
+
+	list, total, err := invite_m.GetApplyList(model, userId, agentIds, param.PageIndex, param.PageSize, param.Type, param.BeginTime, param.EndTime)
+	if err != nil {
+		model.Log.Errorf("GetApplyList param:%v, err:%v", param, err)
+		return myCtx, err
+	}
+
+	uids := make([]uint64, 0, len(list)+1)
+	for _, v := range list {
+		uids = append(uids, v.UserId, v.NewUserId)
+	}
+	users, err := user_c.GetUserTinyMap(model, uids, true)
+	if err != nil {
+		model.Log.Errorf("GetApplyList param:%v, err:%v", param, err)
+		return myCtx, err
+	}
+	res := &invite_cv.InviteApplyRes{}
+	res.List = make([]*invite_cv.InviteApply, 0, len(list))
+	for _, v := range list {
+		res.List = append(res.List, &invite_cv.InviteApply{
+			NewUserCode: users[v.NewUserId].Code,
+			Platform:    v.Platform,
+			Recharge:    v.RechargeInfo,
+			UserCode:    users[v.UserId].Code,
+			CreateUnix:  v.CreatedTime.Unix(),
+			Level:       v.Level,
+			Status:      v.Status,
+			Avatar:      users[v.NewUserId].Avatar,
+			ExternalId:  users[v.NewUserId].ExternalId,
+			Reason:      v.Reason,
+			Country:     users[v.NewUserId].Country,
+			PlatformId:  v.PlatformId,
+		})
+	}
+
+	resp.ResponsePageOk(c, res, total, param.PageSize, param.PageIndex)
+	return myCtx, nil
+}
+
+// @tags 新人邀请
+// @Summary 平台列表
+// @Success 200 {object} []string
+// @Router /v2/user/invite/platform [get]
+func PromotionPlatform(c *gin.Context) (*mycontext.MyContext, error) {
+	myCtx := mycontext.CreateMyContext(c.Keys)
+	resp.ResponseOk(c, []string{"Falla", "Yalla", "Whisper", "Ahlan", "Mashi", "YoYo", "Yoho", "Echo", "Hawa",
+		"Yalla Ludo", "Hafla", "Imo", "Ola Party", "ShareChat", "Viya", "Hello Yo", "Bigo Live", "Hago", "Oye Talk", "Tiktok", "Bigo", "Mr7ba"})
+	return myCtx, nil
+}
+
+// @Tags 新人邀请
+// @Summary 查询周期
+// @Success 200 {object} invite_cv.AgentPeriod
+// @Router /v2/user/invite/period [get]
+func AgentPeriod(c *gin.Context) (*mycontext.MyContext, error) {
+	myCtx := mycontext.CreateMyContext(c.Keys)
+	var response invite_cv.AgentPeriod
+	week := now.BeginningOfWeek().AddDate(0, 0, 1) // 周一开始
+	for i := 0; i < 12; i++ {
+		response.Week = append(response.Week, invite_cv.AgentPeriodWeek{
+			StartDate: week.Format("2006-01-02"),
+			EndDate:   week.AddDate(0, 0, 6).Format("2006-01-02"),
+		})
+		week = week.AddDate(0, 0, -7)
+	}
+	resp.ResponseOk(c, response)
+	return myCtx, nil
+}

route/middleHandle.go

@@ -2,6 +2,8 @@ package route
 
 import (
 	"bytes"
+	"crypto/md5"
+	"fmt"
 	"git.hilo.cn/hilo-common/mycontext"
 	"git.hilo.cn/hilo-common/mylogrus"
 	"git.hilo.cn/hilo-common/resource/config"
@@ -13,6 +15,7 @@ import (
 	"hilo-user/resp"
 	"io/ioutil"
 	"runtime/debug"
+	"strconv"
 	"strings"
 	"time"
 )
@@ -146,3 +149,54 @@ func EncryptHandle(c *gin.Context) {
 	}
 	c.Next()
 }
+
+//http信息解密(web)
+func HttpWebSecretHandle(c *gin.Context) {
+	traceId, _ := c.Keys[mycontext.TRACEID]
+
+	timestamp := c.GetHeader("timestamp") //时间戳,单位秒
+	nonce := c.GetHeader("nonce")         //随机数字
+	signature := c.GetHeader("signature") //sha1加密结果
+	mylogrus.MyLog.Debugf("handle secret begin timestamp:%v, nonce:%v, signature:%v traceId:%v", timestamp, nonce, signature, traceId)
+
+	if nonce == "hilo" {
+		mylogrus.MyLog.Infof("no check http secret handle")
+	} else {
+		if timestamp == "" || nonce == "" || signature == "" {
+			resp.ResponseBusiness(c, bizerr.HttpSecret)
+			c.Abort()
+			return
+		}
+		timestampInt, err := strconv.ParseInt(timestamp, 10, 64)
+		if err != nil {
+			resp.ResponseBusiness(c, bizerr.HttpSecret)
+			c.Abort()
+			return
+		}
+		nowTimestamp := time.Now().Unix()
+		v := nowTimestamp - timestampInt
+		//10分钟内有效，改成60分钟，20210402产品让我改成60分钟，原因：依旧有用户时间戳不对，达到了30分钟
+		if v < -60*60 || v > 60*60 {
+			mylogrus.MyLog.Warnf("handle secret err, timestampInt:%v, nowTimestamp:%v, v:%v, traceId:%v", timestampInt, nowTimestamp, v, traceId)
+			//2021/11/05 产品让我关的，因为中东用户时间戳有问题
+			/*			ResponseBusiness(c, bizerr.HttpSecret)
+						c.Abort()
+						return*/
+		}
+		str := timestamp + config.GetConfigApp().WEB_SECRET + nonce
+		//避免web的暴露，让用户知道app的api加密方式。
+		h := md5.New()
+		//h := sha1.New()
+		h.Write([]byte(str))
+		newSignature := fmt.Sprintf("%x", h.Sum(nil))
+
+		//newSignature := string(sha1.New().Sum([]byte(str))[:])
+		if signature != newSignature {
+			mylogrus.MyLog.Errorf("handle secret err signature:%v, newSignature:%v, traceId:%v", signature, newSignature, traceId)
+			resp.ResponseBusiness(c, bizerr.HttpSecret)
+			c.Abort()
+			return
+		}
+	}
+	c.Next()
+}

route/recommend_r/gift.go

+package recommend_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"
+	"hilo-user/cv/user_cv"
+	"hilo-user/domain/model/group_m"
+	"hilo-user/domain/model/recommend_m"
+	"hilo-user/domain/model/user_m"
+	"hilo-user/resp"
+)
+
+type RecommendUser struct {
+	User        *user_cv.UserTiny `json:"user"`
+	CurrentRoom string            `json:"currentRoom"` // 当前用户所在房间（产品叫“群组”）
+}
+
+// @Tags 用户推荐
+// @Summary 推荐最近送礼的50人，最近12小时赠送礼物大于100k的用户
+// @Param token header string true "token"
+// @Success 200 {object} []RecommendUser
+// @Router /v1/recommend/user/gift [get]
+func UserRecommendGift(c *gin.Context) (*mycontext.MyContext, error) {
+	myContext := mycontext.CreateMyContext(c.Keys)
+	model := domain.CreateModelContext(myContext)
+	// 获取推荐
+	recommendUser := recommend_m.GetPastTop50SendGiftUsers(model)
+	var response = make([]RecommendUser, 0)
+	if len(recommendUser) <= 0 {
+		resp.ResponseOk(c, response)
+		return myContext, nil
+	}
+	var userIds []mysql.ID
+	for _, v := range recommendUser {
+		userIds = append(userIds, v.SendUserId)
+	}
+	users, err := user_m.GetUserMapByIds(model, userIds)
+	if err != nil {
+		return myContext, err
+	}
+	rooms, err := group_m.RoomLivingUserIdFilter(model, userIds)
+	if err != nil {
+		return nil, err
+	} else if len(rooms) > 0 {
+		// to txGroupIds
+		var imGroupIds []string
+		for _, imGroupId := range rooms {
+			imGroupIds = append(imGroupIds, imGroupId)
+		}
+		txGroupIdsMap, _ := group_m.ToTxGroupIdMap(model, imGroupIds)
+		for uid, room := range rooms {
+			rooms[uid] = txGroupIdsMap[room]
+		}
+	}
+	for _, v := range recommendUser {
+		response = append(response, RecommendUser{user_cv.UserToTiny(users[v.SendUserId]), rooms[v.SendUserId]})
+	}
+	resp.ResponseOk(c, response)
+	return myContext, nil
+}

route/router.go

@@ -12,6 +12,8 @@ import (
 	"hilo-user/domain/model/msg_m"
 	"hilo-user/resp"
 	"hilo-user/route/cp_r"
+	"hilo-user/route/invite_r"
+	"hilo-user/route/recommend_r"
 	"hilo-user/route/user_r"
 )
 
@@ -52,6 +54,19 @@ func InitRouter() *gin.Engine {
 		//cp.GET("/relation/detail", wrapper(cp_r.CpDetailPage))
 		cp.GET("/im/check", wrapper(cp_r.CheckCpImExpire))
 	}
+	recommend := v1.Group("recommend")
+	{
+		recommend.GET("/user/gift", wrapper(recommend_r.UserRecommendGift))
+	}
+
+	userV2 := v2.Group("/user")
+	{
+		userV2.POST("/invite/apply", wrapper(invite_r.InviteApply))
+		userV2.GET("/invite/apply", wrapper(invite_r.InviteApplyList))
+		userV2.GET("/invite/platform", wrapper(invite_r.PromotionPlatform))
+		userV2.GET("/invite/period", wrapper(invite_r.AgentPeriod))
+		userV2.GET("/detail/room", EncryptHandle, wrapper(user_r.GetUserDetailInRoom))
+	}
 	inner := r.Group("/inner")
 	inner.Use(ExceptionHandle, LoggerHandle)
 	innerUser := inner.Group("/user")
@@ -61,7 +76,8 @@ func InitRouter() *gin.Engine {
 		innerUser.GET("/cp", wrapper(user_r.GetUserCp))
 		innerUser.GET("/cpRelations", wrapper(user_r.MGetUserCpRelation))
 		innerUser.GET("/cp/pair", wrapper(user_r.GetUserCpPair))
-		innerUser.GET("/cp/entryEffect", wrapper(user_r.GetUserCpEntryEffect)) // 获取cp进场特效信息,高频接口,需要额外处理
+		innerUser.GET("/cp/entryEffect", wrapper(user_r.GetUserCpEntryEffect))   // 获取cp进场特效信息,高频接口,需要额外处理
+		innerUser.GET("/svipNobleLevel", wrapper(user_r.MGetUserSvipNobleLevel)) // 获取用户svip/noble/level等信息
 	}
 	// 道具相关
 	innerProp := inner.Group("/prop")

route/user_r/inner.go

@@ -4,9 +4,11 @@ import (
 	"git.hilo.cn/hilo-common/domain"
 	"git.hilo.cn/hilo-common/mycontext"
 	"git.hilo.cn/hilo-common/resource/mysql"
+	"git.hilo.cn/hilo-common/rpc"
 	"github.com/gin-gonic/gin"
 	"hilo-user/_const/enum/cp_e"
 	"hilo-user/cv/cp_cv"
+	"hilo-user/cv/noble_cv"
 	"hilo-user/cv/user_cv"
 	"hilo-user/domain/cache/user_c"
 	"hilo-user/domain/model/bag_m"
@@ -56,6 +58,62 @@ func MGetUserLevels(c *gin.Context) (*mycontext.MyContext, error) {
 	return myCtx, nil
 }
 
+type MGetUserSvipVipLevelReq struct {
+	Ids []mysql.ID `form:"ids" binding:"required"`
+}
+
+// @Tags 用户-内部
+// @Summary 批量获取用户等级
+// @Param ids query string true "用户id,如:ids=1&ids=2&ids=3"
+// @Success 200 {object} user_cv.CvUserDetail
+// @Router /inner/user/svipNobleLevel [get]
+func MGetUserSvipNobleLevel(c *gin.Context) (*mycontext.MyContext, error) {
+	myCtx := mycontext.CreateMyContext(c.Keys)
+	var model = domain.CreateModelContext(myCtx)
+	var req MGetUserLevelReq
+	if err := c.ShouldBindQuery(&req); err != nil {
+		return myCtx, err
+	}
+	wealthGrade, err := user_m.MGetWealthGrade(model, req.Ids)
+	if err != nil {
+		return myCtx, err
+	}
+	charmGrade, err := user_m.MGetCharmGrade(model, req.Ids)
+	activeGrade, err := user_m.MGetActiveGrade(model, req.Ids)
+	nobleLevel, err := noble_m.BatchGetNobleLevel(model, req.Ids)
+	svip, err := rpc.MGetUserSvip(model, req.Ids)
+	users, err := user_m.GetUserMapByIds(model, req.Ids)
+	response := make(map[uint64]user_cv.CvUserDetail)
+	for _, userId := range req.Ids {
+		user := users[userId]
+		response[userId] = user_cv.CvUserDetail{
+			CvUserBase: user_cv.CvUserBase{
+				Id:          &user.ID,
+				Avatar:      &user.Avatar,
+				ExternalId:  &user.ExternalId,
+				Nick:        &user.Nick,
+				Sex:         &user.Sex,
+				Country:     &user.Country,
+				CountryIcon: &user.CountryIcon,
+				Code:        &user.Code,
+				Birthday:    &user.Birthday,
+				Svip: rpc.CvSvip{
+					SvipLevel: svip[userId].SvipLevel,
+				},
+				Noble: noble_cv.CvNoble{
+					Level: nobleLevel[userId],
+				},
+			},
+			WealthUserGrade:   wealthGrade[userId],
+			CharmUserGrade:    charmGrade[userId],
+			ActivityUserGrade: activeGrade[userId],
+		}
+	}
+
+	resp.ResponseOk(c, response)
+	return myCtx, nil
+}
+
 type GetUserBagReq struct {
 	BagId mysql.ID `form:"bagId" binding:"required"`
 }

route/user_r/user.go

@@ -7,6 +7,7 @@ import (
 	"git.hilo.cn/hilo-common/resource/redisCli"
 	"github.com/gin-gonic/gin"
 	"hilo-user/_const/redis_key/user_k"
+	"hilo-user/cv/user_cv"
 	"hilo-user/domain/model/group_m"
 	"hilo-user/domain/model/tim_m"
 	"hilo-user/domain/service/user_s"
@@ -106,3 +107,64 @@ func UserDetailByExternalId(c *gin.Context) (*mycontext.MyContext, error) {
 	resp.ResponseOk(c, cvUserDetail)
 	return myContext, nil
 }
+
+// @Tags 用户
+// @Summary 房间内获取用户信息
+// @Param userExternalId query string true "userExternalId"
+// @Param groupId query string false "群组id，当传了该id，则返回该用户在该群组的身份"
+// @Success 200 {object} user_cv.CvUserDetailRoom
+// @Router /v2/user/detail/room [get]
+func GetUserDetailInRoom(c *gin.Context) (*mycontext.MyContext, error) {
+	myContext := mycontext.CreateMyContext(c.Keys)
+	userId, lang, err := req.GetUserIdLang(c, myContext)
+	if err != nil {
+		return myContext, err
+	}
+	otherUserId, err := req.ToUserId(myContext, c.Query("userExternalId"))
+	if err != nil {
+		return nil, err
+	}
+	model := domain.CreateModelContext(myContext)
+
+	imGroupId := c.Query("groupId")
+	if imGroupId != "" {
+		imGroupId, err = group_m.ToImGroupId(model, imGroupId)
+		if err != nil {
+			return myContext, err
+		}
+	}
+
+	cvUserDetail, err := user_s.NewUserService(myContext).GetUserDetail(otherUserId, userId, lang)
+	if err != nil {
+		return myContext, err
+	}
+	if imGroupId != "" {
+		cvUserDetail.GroupRole, err = group_m.GetGroupRoleById(model, imGroupId, otherUserId)
+		if err != nil {
+			return myContext, err
+		}
+	}
+
+	if cvUserDetail != nil {
+		// 检查是否需要同步
+		if n, err := redisCli.GetRedis().Exists(model, user_k.GetKeySyncTimHilo(userId)).Result(); err == nil {
+			if n == 0 {
+				// FIXME：转异步执行
+				err = tim_m.FlushHiloInfo(*cvUserDetail.ExternalId, cvUserDetail.IsVip, cvUserDetail.IsPrettyCode,
+					cvUserDetail.Medals, cvUserDetail.MyGroupPowerName, cvUserDetail.Noble.Level)
+				if err == nil {
+					redisCli.GetRedis().Set(model, user_k.GetKeySyncTimHilo(userId), "1", time.Minute)
+				} else {
+					model.Log.Info("UserBaseByExternalId, FlushHiloInfo failed: ", err)
+				}
+			} else {
+				model.Log.Info("UserDetailByExternalId, no need to sync yet: ", userId)
+			}
+		} else {
+			model.Log.Info("UserDetailByExternalId, check KeySyncTimHilo failed", err)
+		}
+	}
+
+	resp.ResponseOk(c, user_cv.CvUserDetailToCvUserDetailRoom(cvUserDetail))
+	return myContext, nil
+}