Merge branch 'feature/family' into feature/3.5

_const/enum/country_e/enum.go

@@ -3,7 +3,7 @@ package country_e
 import "git.hilo.cn/hilo-common/resource/mysql"
 
 // 国家角色
-type CountryMgrRole mysql.Type
+type CountryMgrRole uint8
 
 const (
 	// 国家管理员

_const/enum/groupPower_e/grade.go

+package groupPower_e
+
+import "git.hilo.cn/hilo-common/resource/mysql"
+
+type GroupPowerGrade int
+
+const (
+	GroupPowerGrade0 GroupPowerGrade = 0 // 青铜
+	GroupPowerGrade1 GroupPowerGrade = 1 // 白银
+	GroupPowerGrade2 GroupPowerGrade = 2 // 黄金
+	GroupPowerGrade3 GroupPowerGrade = 3 // 黑金
+
+	GroupPowerGradeMax = GroupPowerGrade3
+)
+
+var (
+	GroupPowerGradeExp = map[GroupPowerGrade]mysql.Num{
+		GroupPowerGrade0: 0,
+		GroupPowerGrade1: 2500000,
+		GroupPowerGrade2: 15000000,
+		GroupPowerGrade3: 60000000,
+	}
+)
+
+type GroupPowerPrivilege int
+
+const (
+	GroupPowerPrivilegeMemberNum         GroupPowerPrivilege = 1 // 成员数
+	GroupPowerPrivilegeMgrNum            GroupPowerPrivilege = 2 // 管理员数
+	GroupPowerPrivilegeNameplate         GroupPowerPrivilege = 3 // 家族铭牌
+	GroupPowerPrivilegeMedal             GroupPowerPrivilege = 4 // 家族徽章装饰
+	GroupPowerPrivilegeNameplateEdit     GroupPowerPrivilege = 5 // 编辑铭牌
+	GroupPowerPrivilegeNameplateHeadwear GroupPowerPrivilege = 6 // 家族头饰
+)

_const/enum/groupPower_e/star.go

+package groupPower_e
+
+type GroupPowerStarType int
+
+const (
+	GroupPowerStarTypeFamous GroupPowerStarType = 1 // 送礼
+	GroupPowerStarTypeActive GroupPowerStarType = 2 // 活跃
+	GroupPowerStarTypeCharm  GroupPowerStarType = 3 // 收礼
+)
+
+func IsGroupPowerStarType(t GroupPowerStarType) bool {
+	if t != GroupPowerStarTypeFamous && t != GroupPowerStarTypeActive && t != GroupPowerStarTypeCharm {
+		return false
+	}
+	return true
+}

_const/enum/msg_e/msg.go

@@ -131,6 +131,8 @@ const (
 	NewUserRegisterPush2     = 45 // 邀请朋友来Hilo，最高获得100,000钻石奖励！
 	NewUserRegisterPush3     = 46 // 举办首个活动，领取10,000钻石和35%奖杯奖励！
 	ActFruitPutRankAward     = 47 // 水果机投入排行榜提醒领奖
+	GroupPowerUpgrade        = 48 // 家族升级
+	GroupPowerExpireNotice   = 49 // 家族等级即将过期（每月20日）
 )
 
 type MsgSysUserType = mysql.Type

cron/cron.go

@@ -3,12 +3,16 @@ package cron
 import (
 	"git.hilo.cn/hilo-common/resource/config"
 	"hilo-group/cron/gift_cron"
+	"hilo-group/cron/group_cron"
+	"hilo-group/cron/mic_cron"
 )
 
 func Init() {
 	if !config.IsMaster() {
 		return
 	}
-	gift_cron.SendGiftEventInit() // 礼物消息
-	gift_cron.GiftRemark()        // 礼物消息补偿
+	gift_cron.SendGiftEventInit()   // 礼物消息
+	gift_cron.GiftRemark()          // 礼物消息补偿
+	mic_cron.OnMicCheck()           // 检查上麦
+	group_cron.GroupPowerExpClear() // 清理家族经验/等级
 }

cron/group_cron/group_power_exp.go

+package group_cron
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"github.com/robfig/cron"
+	"hilo-group/domain/event/group_power_ev"
+	"hilo-group/domain/model/groupPower_m"
+)
+
+// 清理家族经验和等级
+func GroupPowerExpClear() {
+	c := cron.New()
+	// 每月1号0:00经验值清零
+	spec := "0 0 0 1 * ?"
+	_ = c.AddFunc(spec, func() {
+		var model = domain.CreateModelNil()
+		if err := groupPower_m.ClearGroupPowerExp(model); err != nil {
+			model.Log.Errorf("ClearGroupPowerExp fail:%v", err)
+		}
+	})
+
+	// 每分钟清理过期家族等级
+	spec = "0 * * * * ?"
+	_ = c.AddFunc(spec, func() {
+		var model = domain.CreateModelNil()
+		if err := groupPower_m.ClearGroupPowerGrade(model); err != nil {
+			model.Log.Errorf("ClearGroupPowerGrade fail:%v", err)
+		}
+	})
+	// 每月20号发家族即将过期通知
+	spec = "0 0 0 20 * ?"
+	_ = c.AddFunc(spec, func() {
+		var model = domain.CreateModelNil()
+		_ = group_power_ev.PublishGroupPowerExpireNotice(model, &group_power_ev.GroupPowerExpireNoticeEvent{})
+	})
+	c.Start()
+}

cron/mic_cron/on_mic.go

+package mic_cron
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"github.com/robfig/cron"
+	"hilo-group/domain/event/mic_ev"
+	"hilo-group/domain/model/group_m"
+)
+
+func OnMicCheck() {
+	c := cron.New()
+	//一分钟执行一次
+	spec := "0 */1 * * * ?"
+	_ = c.AddFunc(spec, func() {
+		//获取麦上的所有人
+		var model = domain.CreateModelNil()
+		groupIds, err := group_m.GetMicHasInGroups()
+		if err != nil {
+			model.Log.Errorf("cron micIn GetMicHasInGroups err:%v", err)
+			return
+		}
+		for _, groupId := range groupIds {
+			//遍历每个麦位
+			for i := 1; i <= 30; i++ {
+				micUser, err := group_m.GetMicUser(model, groupId, i)
+				if err != nil {
+					model.Log.Errorf("cron micIn group_m.GetMicUser err:%v", err)
+				}
+				if micUser != nil {
+					if err := mic_ev.PublishOnMicEvent(model, &mic_ev.OnMicEvent{
+						GroupUuid:  micUser.GroupUuid,
+						I:          micUser.I,
+						ExternalId: micUser.ExternalId,
+						UserId:     micUser.UserId,
+						Forbid:     micUser.Forbid,
+						Timestamp:  micUser.Timestamp,
+					}); err != nil {
+						model.Log.Errorf("PublishOnMicEvent fail:%v", err)
+					}
+					//if err := group_mic_s.NewGroupPowerService(model.MyContext).GroupPowerOnMicExp(groupId, micUser.UserId, micUser.Timestamp); err != nil {
+					//	model.Log.Errorf("cron micIn GroupPowerOnMicExp err:%v", err)
+					//} else {
+					//	model.Log.Infof("cron micIn GroupPowerOnMicExp success, groupId:%v, userId:%v", groupId, micUser.UserId)
+					//}
+				}
+			}
+		}
+	})
+	c.Start()
+}

cv/group_cv/group.go

@@ -64,10 +64,11 @@ type GroupInfo struct {
 	GroupBasicInfo
 
 	// hilo业务
-	EntryLevel     uint32 `json:"entryLevel"`     // obsolete
-	HasOnMic       bool   `json:"hasOnMic"`       // 房间麦上是否有人
-	GroupPowerId   uint64 `json:"groupPowerId"`   // 群主所在的势力ID
-	GroupPowerName string `json:"groupPowerName"` // 群主所在的势力的名称
+	EntryLevel          uint32 `json:"entryLevel"`          // obsolete
+	HasOnMic            bool   `json:"hasOnMic"`            // 房间麦上是否有人
+	GroupPowerId        uint64 `json:"groupPowerId"`        // 群主所在的势力ID
+	GroupPowerName      string `json:"groupPowerName"`      // 群主所在的势力的名称
+	GroupPowerNameplate string `json:"groupPowerNameplate"` // 势力铭牌
 
 	// "AppDefinedData": 群组维度的自定义字段 【暂时不用】
 	MemberList []MemberListInfo
@@ -312,7 +313,7 @@ func BuildJoinedGroupInfo(myService *domain.Service, myUserId uint64, groupIds [
 		for _, i := range groupIds {
 			owners = append(owners, groupInfo[i].Owner)
 		}
-		powerIds, powerNames, err := group_power_cv.BatchGetGroupPower(model.Db, owners)
+		powerIds, powerNames, powerNameplates, err := group_power_cv.BatchGetGroupPower(model.Db, owners)
 		if err != nil {
 			return nil, 0, err
 		}
@@ -388,9 +389,10 @@ func BuildJoinedGroupInfo(myService *domain.Service, myUserId uint64, groupIds [
 							MicNumType:          int(g.MicNumType),
 							GroupMedals:         medals,
 						},
-						HasOnMic:       len(micUsers) > 0,
-						GroupPowerId:   powerIds[g.Owner],
-						GroupPowerName: powerNames[g.Owner],
+						HasOnMic:            len(micUsers) > 0,
+						GroupPowerId:        powerIds[g.Owner],
+						GroupPowerName:      powerNames[g.Owner],
+						GroupPowerNameplate: powerNameplates[g.Owner],
 					},
 					MicUsers:      micUsers,
 					RoomUserCount: uint(roomCount[i]),

cv/group_power_cv/groupPower.go

@@ -233,28 +233,31 @@ func GetCvGroupPowerUsers(groupPowerId uint64) ([]mysql.ID, error) {
 	return usreIds, nil
 }
 
-func BatchGetGroupPower(db *gorm.DB, userIds []uint64) (map[uint64]uint64, map[uint64]string, error) {
+// return userId->powerId userId->powerName userId->powerNameplate
+func BatchGetGroupPower(db *gorm.DB, userIds []uint64) (map[uint64]uint64, map[uint64]string, map[uint64]string, error) {
 	if len(userIds) <= 0 {
-		return nil, nil, nil
+		return nil, nil, nil, nil
 	}
 	groupPowers, err := groupPower_m.GetGroupPowerMap(db, userIds)
 	if err != nil {
-		return nil, nil, err
+		return nil, nil, nil, err
 	}
 
 	gpIds := make([]uint64, 0)
 	for _, i := range groupPowers {
 		gpIds = append(gpIds, i)
 	}
-	powerNames, err := groupPower_m.GetGroupPowerNames(db, gpIds)
+	powerNames, powerNameplates, err := groupPower_m.GetGroupPowerNames(db, gpIds)
 	if err != nil {
-		return nil, nil, err
+		return nil, nil, nil, err
 	}
 	groupPowerNames := make(map[mysql.ID]string, 0)
+	groupPowerNameplates := make(map[mysql.ID]string, 0)
 	for i, g := range groupPowers {
 		groupPowerNames[i] = powerNames[g]
+		groupPowerNameplates[i] = powerNameplates[g]
 	}
-	return groupPowers, groupPowerNames, nil
+	return groupPowers, groupPowerNames, groupPowerNameplates, nil
 }
 
 //获取国家势力的所有用户数量

cv/group_power_cv/group_rank.go

+package group_power_cv
+
+import (
+	"hilo-group/_const/enum/groupPower_e"
+	"hilo-group/cv/user_cv"
+)
+
+// 家族信息
+type CvGroupPowerInfo struct {
+	CvGroupPowerBase   `json:",inline"`
+	CvGroupPowerMember `json:",inline"`
+}
+
+// 家族基本信息
+type CvGroupPowerBase struct {
+	GroupPowerId uint64 `json:"groupPowerId"` // 家族id
+	Icon         string `json:"icon"`         // 家族图片
+	Name         string `json:"name"`         // 家族名
+	Nameplate    string `json:"nameplate"`    // 铭牌
+}
+
+// 家族成员
+type CvGroupPowerMember struct {
+	MemberNum   uint32 `json:"memberNum"`                         // 当前成员数
+	MemberLimit uint32 `json:"memberLimit" swaggertype:"integer"` // 成员上限
+}
+
+// 家族等级
+type CvGroupPowerGrade struct {
+	Grade    groupPower_e.GroupPowerGrade `json:"grade"`              // 等级 0:无 1:青铜 2:白银 3:黄金 4:黑金
+	Exp      uint32                       `json:"exp"`                // 经验值
+	NextExp  uint32                       `json:"nextExp,omitempty"`  // 升级所需经验值
+	ExpireAt string                       `json:"expireAt,omitempty"` // 有效期
+	ShowExp  bool                         `json:"showExp"`            // 是否展示经验值
+}
+
+// 家族榜单
+type CvGroupPowerRank struct {
+	MyGroupPower *CvGroupPowerRankData  `json:"myGroupPower,omitempty"` // 我的家族排名
+	Items        []CvGroupPowerRankData `json:"items"`                  // 列表
+}
+
+type CvGroupPowerRankData struct {
+	CvGroupPowerBase  `json:",inline"`
+	CvGroupPowerGrade `json:",inline"`
+	Rank              int `json:"rank"` // 排名
+}
+
+// 家族之星
+type CvGroupPowerStarData struct {
+	User  user_cv.CvUserTiny `json:"user"`
+	Score uint32             `json:"score"` // 对应分值
+}
+
+// 资源等级
+type CvResGrade struct {
+	Grade   groupPower_e.GroupPowerGrade `json:"grade"`   // 等级
+	Icon    string                       `json:"icon"`    // 等级icon
+	BigIcon string                       `json:"bigIcon"` // 等级大图标
+}
+
+// 特权信息
+type CvPrivilege struct {
+	Type groupPower_e.GroupPowerPrivilege `json:"type"` // 特权id 1:成员数 2:管理员数 3:家族铭牌 4:家族徽章装饰 5:编辑铭牌 6:家族头饰
+	Num  int                              `json:"num"`  // 数目
+}
+
+// 家族等级页
+type CvGroupPowerGradeDetail struct {
+	GroupPowerBase  CvGroupPowerBase  `json:"groupPowerBase"`  // 家族基本信息
+	GroupPowerGrade CvGroupPowerGrade `json:"groupPowerGrade"` // 家族等级信息
+	ResGradeList    []CvResGrade      `json:"resGradeList"`    // 资源等级列表,青铜、白银、黄金、黑金
+	PrivilegeList   []CvPrivilege     `json:"privilegeList"`   // 等级特权
+}
+
+var CvResGradeList = []CvResGrade{
+	{groupPower_e.GroupPowerGrade0, "青铜icon", "青铜bigIcon"}, // todo
+	{groupPower_e.GroupPowerGrade1, "白银icon", "白银bigIcon"}, // todo
+	{groupPower_e.GroupPowerGrade2, "黄金icon", "黄金bigIcon"}, // todo
+	{groupPower_e.GroupPowerGrade3, "黑金icon", "黑金bigIcon"}, // todo
+}
+
+var GroupPowerGradePrivilegeNum = map[groupPower_e.GroupPowerGrade][]CvPrivilege{
+	groupPower_e.GroupPowerGrade0: {
+		{groupPower_e.GroupPowerPrivilegeMemberNum, 300},
+		{groupPower_e.GroupPowerPrivilegeMgrNum, 10},
+		{groupPower_e.GroupPowerPrivilegeNameplate, 1},
+		{groupPower_e.GroupPowerPrivilegeMedal, 1},
+	},
+	groupPower_e.GroupPowerGrade1: {
+		{groupPower_e.GroupPowerPrivilegeMemberNum, 500},
+		{groupPower_e.GroupPowerPrivilegeMgrNum, 15},
+		{groupPower_e.GroupPowerPrivilegeNameplate, 1},
+		{groupPower_e.GroupPowerPrivilegeMedal, 1},
+		{groupPower_e.GroupPowerPrivilegeNameplateEdit, 1},
+	},
+	groupPower_e.GroupPowerGrade2: {
+		{groupPower_e.GroupPowerPrivilegeMemberNum, 800},
+		{groupPower_e.GroupPowerPrivilegeMgrNum, 20},
+		{groupPower_e.GroupPowerPrivilegeNameplate, 1},
+		{groupPower_e.GroupPowerPrivilegeMedal, 1},
+		{groupPower_e.GroupPowerPrivilegeNameplateEdit, 1},
+		{groupPower_e.GroupPowerPrivilegeNameplateHeadwear, 1},
+	},
+	groupPower_e.GroupPowerGrade3: {
+		{groupPower_e.GroupPowerPrivilegeMemberNum, 1200},
+		{groupPower_e.GroupPowerPrivilegeMgrNum, 25},
+		{groupPower_e.GroupPowerPrivilegeNameplate, 1},
+		{groupPower_e.GroupPowerPrivilegeMedal, 1},
+		{groupPower_e.GroupPowerPrivilegeNameplateEdit, 1},
+		{groupPower_e.GroupPowerPrivilegeNameplateHeadwear, 1},
+	},
+}

cv/user_cv/user.go

@@ -299,7 +299,7 @@ func getUserDetails(model *domain.Model, users []*user_m.User, myUserId mysql.ID
 	for _, i := range groupPowers {
 		gpIds = append(gpIds, i)
 	}
-	powerNames, err := groupPower_m.GetGroupPowerNames(mysql.Db, gpIds)
+	powerNames, _, err := groupPower_m.GetGroupPowerNames(mysql.Db, gpIds)
 	if err != nil {
 		return nil, err
 	}

domain/event/group_power_ev/groupPowerExpireNotice.go

+package group_power_ev
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+)
+
+//注册监听
+var groupPowerExpireNoticeListen = new(domain.EventBase)
+
+type GroupPowerExpireNoticeEvent struct {
+}
+
+//添加领域事件，在每个领域模型中init中添加，因为这是静态业务，非动态的。
+func AddGroupPowerExpireNoticeSync(callback func(model *domain.Model, event interface{}) error) {
+	domain.AddEventSync(groupPowerExpireNoticeListen, callback)
+}
+
+//加入到异步操作中
+func AddGroupPowerExpireNoticeAsync(callback func(model *domain.Model, event interface{}) error) {
+	domain.AddEventAsync(groupPowerExpireNoticeListen, callback)
+}
+
+//领域事件发布
+func PublishGroupPowerExpireNotice(model *domain.Model, event interface{}) error {
+	return domain.PublishEvent(groupPowerExpireNoticeListen, model, event)
+}

domain/event/group_power_ev/groupPowerUpgrade.go

+package group_power_ev
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"git.hilo.cn/hilo-common/resource/mysql"
+)
+
+//注册监听
+var groupPowerUpgradeListen = new(domain.EventBase)
+
+type GroupPowerUpgradeEvent struct {
+	GroupPowerId mysql.ID
+}
+
+//添加领域事件，在每个领域模型中init中添加，因为这是静态业务，非动态的。
+func AddGroupPowerUpgradeSync(callback func(model *domain.Model, event interface{}) error) {
+	domain.AddEventSync(groupPowerUpgradeListen, callback)
+}
+
+//加入到异步操作中
+func AddGroupPowerUpgradeAsync(callback func(model *domain.Model, event interface{}) error) {
+	domain.AddEventAsync(groupPowerUpgradeListen, callback)
+}
+
+//领域事件发布
+func PublishGroupPowerUpgrade(model *domain.Model, event interface{}) error {
+	return domain.PublishEvent(groupPowerUpgradeListen, model, event)
+}

domain/event/mic_ev/on_mic.go

+package mic_ev
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+)
+
+var onMicListen = new(domain.EventBase)
+
+// 在麦上事件
+type OnMicEvent struct {
+	GroupUuid  string // 群组uuid
+	I          int    // 麦位
+	ExternalId string // 麦中的人
+	UserId     uint64 // 麦中的人
+	Forbid     bool   // 静音 true:静音，false:没有静音
+	Timestamp  int64  // 上麦的的时间戳
+}
+
+func AddOnMicEventSync(callback func(model *domain.Model, event interface{}) error) {
+	domain.AddEventSync(onMicListen, callback)
+}
+
+func AddOnMicEventAsync(callback func(model *domain.Model, event interface{}) error) {
+	domain.AddEventAsync(onMicListen, callback)
+}
+
+func PublishOnMicEvent(model *domain.Model, event interface{}) error {
+	return domain.PublishEvent(onMicListen, model, event)
+}

domain/model/groupPower_m/groupPower.go

@@ -384,47 +384,28 @@ func GetGroupPowerMap(db *gorm.DB, userIds []mysql.ID) (map[mysql.ID]uint64, err
 	return result, nil
 }
 
-func GetGroupPowerNames(db *gorm.DB, ids []mysql.ID) (map[mysql.ID]string, error) {
+// return
+func GetGroupPowerNames(db *gorm.DB, ids []mysql.ID) (map[mysql.ID]string, map[mysql.ID]string, error) {
 	type record struct {
-		Id   mysql.ID
-		Name string
+		Id        mysql.ID
+		Name      string
+		Nameplate string
 	}
 	rows := make([]record, 0)
+	result := make(map[mysql.ID]string, 0)
+	result2 := make(map[mysql.ID]string, 0)
 	if len(ids) > 0 {
-		if err := db.Model(&GroupPower{}).Select("p.id, i.name").
+		if err := db.Model(&GroupPower{}).Select("p.id, i.name,p.nameplate").
 			Joins("AS p INNER JOIN group_info AS i ON p.group_uid = i.im_group_id").
 			Where("p.id IN ?", ids).Find(&rows).Error; err != nil {
-			return nil, err
+			return result, result2, err
 		}
 	}
-	result := make(map[mysql.ID]string, 0)
 	for _, i := range rows {
 		result[i.Id] = i.Name
+		result2[i.Id] = i.Nameplate
 	}
-	return result, nil
-}
-
-type GroupPowerInfo struct {
-	PowerId mysql.ID
-	Owner   mysql.ID
-	Name    string
-}
-
-func BatchGetGroupPower(db *gorm.DB, ids []mysql.ID) (map[mysql.ID]GroupPowerInfo, error) {
-	rows := make([]GroupPowerInfo, 0)
-	if len(ids) > 0 {
-		if err := db.Model(&GroupPower{}).Select("p.id AS power_id, u.user_id AS owner, p.name").
-			Joins("AS p INNER JOIN group_power_user AS u ON p.id = u.group_power_id").
-			Where("p.id IN ? AND p.status = ? AND role = ?", ids, groupPower_e.GroupPowerUserHas, groupPower_e.GroupPowerUserRoleMgr).
-			Find(&rows).Error; err != nil {
-			return nil, err
-		}
-	}
-	result := make(map[mysql.ID]GroupPowerInfo, 0)
-	for _, i := range rows {
-		result[i.PowerId] = i
-	}
-	return result, nil
+	return result, result2, nil
 }
 
 func GetGroupPower(model *domain.Model, id mysql.ID) (*GroupPower, error) {
@@ -684,3 +665,36 @@ func GetUserGroupPower(model *domain.Model, userId uint64) (uint64, string, erro
 	}
 	return gpu.GroupPowerId, powerName, nil
 }
+
+// 获取势力下的所有群组
+func GetGroupPowerGroups(model *domain.Model, groupPowerId mysql.ID) ([]*group_m.GroupInfo, error) {
+	var res []*group_m.GroupInfo
+	var ownerIds []mysql.ID
+	if err := model.DB().Model(GroupPowerUser{}).Select("user_id").Where("group_power_id = ?", groupPowerId).Scan(&ownerIds).Error; err != nil {
+		model.Log.Errorf("GetGroupPowerGroups fail:%v", err)
+		return nil, err
+	}
+	if len(ownerIds) <= 0 {
+		return res, nil
+	}
+	if err := model.DB().Model(group_m.GroupInfo{}).Where("owner in ?", ownerIds).Find(&res).Error; err != nil {
+		model.Log.Errorf("GetGroupPowerGroups fail:%v", err)
+		return nil, err
+	}
+	return res, nil
+}
+
+// 批量获取势力用户
+// return userId->GroupPowerUser
+func BatchGetGroupPowerUser(model *domain.Model, userIds []mysql.ID) (map[mysql.ID]GroupPowerUser, error) {
+	var rows []GroupPowerUser
+	res := make(map[mysql.ID]GroupPowerUser)
+	if err := model.Db.Model(GroupPowerUser{}).Where("user_id in ?", userIds).Find(&rows).Error; err != nil {
+		model.Log.Errorf("BatchGetGroupPowerUser fail:%v", err)
+		return res, err
+	}
+	for i, v := range rows {
+		res[v.UserId] = rows[i]
+	}
+	return res, nil
+}

domain/model/groupPower_m/group_grade.go

+package groupPower_m
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"git.hilo.cn/hilo-common/utils"
+	"github.com/jinzhu/now"
+	"gorm.io/gorm"
+	"gorm.io/gorm/clause"
+	"hilo-group/_const/enum/groupPower_e"
+	"hilo-group/domain/event/group_power_ev"
+	"time"
+)
+
+type GroupPowerDayExp struct {
+	Date         string
+	GroupPowerId mysql.ID
+	Exp          mysql.Num
+	CreatedTime  time.Time `gorm:"->"`
+	UpdatedTime  time.Time `gorm:"->"`
+}
+
+type GroupPowerGrade struct {
+	GroupPowerId mysql.ID
+	Exp          mysql.Num
+	Grade        groupPower_e.GroupPowerGrade
+	ExpireAt     time.Time
+	CreatedTime  time.Time `gorm:"->"`
+	UpdatedTime  time.Time `gorm:"->"`
+}
+
+type GroupPowerExpDetail struct {
+	mysql.Entity
+	GroupPowerId mysql.ID
+	UserId       mysql.ID
+	Exp          mysql.Num
+	AddReduce    mysql.AddReduce
+	BefNum       mysql.Num
+	AftNum       mysql.Num
+	Remark       string
+}
+
+type GroupPowerOnMic struct {
+	Date         string
+	GroupPowerId mysql.ID
+	UserId       mysql.ID
+	Seconds      int64
+	LastCalTs    int64
+	CreatedTime  time.Time `gorm:"->"`
+	UpdatedTime  time.Time `gorm:"->"`
+}
+
+type GroupPowerOnMicDetail struct {
+	Date         string
+	GroupPowerId mysql.ID
+	UserId       mysql.ID
+	Minute       int
+	CreatedTime  time.Time `gorm:"->"`
+	UpdatedTime  time.Time `gorm:"->"`
+}
+
+// 增加家族经验
+// 达到经验值之后升级
+// 单进程同步执行,不考虑并发
+func IncrGroupPowerExp(txModel *domain.Model, groupPowerId mysql.ID, exp mysql.Num, userId mysql.ID, remark string) error {
+	var err error
+	defer func() {
+		if err != nil {
+			txModel.Log.Errorf("IncrGroupPowerExp fail,id:%v,exp:%v,err:%v", groupPowerId, exp, err)
+		}
+	}()
+	// 增加家族经验-天
+	date := time.Now().Format("2006-01-02")
+	gpe := &GroupPowerDayExp{
+		Date:         date,
+		GroupPowerId: groupPowerId,
+		Exp:          exp,
+	}
+	if err = txModel.DB().Model(GroupPowerDayExp{}).Clauses(clause.OnConflict{Columns: []clause.Column{{Name: "date"}, {Name: "group_power_id"}},
+		DoUpdates: clause.Assignments(map[string]interface{}{
+			"exp": gorm.Expr("exp + ?", gpe.Exp)})}).Create(gpe).Error; err != nil {
+		return err
+	}
+	// 增加家族经验-总
+	gpg := &GroupPowerGrade{
+		GroupPowerId: groupPowerId,
+		Exp:          exp,
+		Grade:        0,
+		ExpireAt:     time.Time{},
+	}
+	if err = txModel.DB().Model(GroupPowerGrade{}).Clauses(clause.OnConflict{Columns: []clause.Column{{Name: "group_power_id"}},
+		DoUpdates: clause.Assignments(map[string]interface{}{
+			"exp": gorm.Expr("exp + ?", gpg.Exp)})}).Create(gpg).Error; err != nil {
+		return err
+	}
+	// 当前写后读
+	latestGrade := new(GroupPowerGrade)
+	if err = txModel.DB().Model(GroupPowerGrade{}).Where("group_power_id = ?", groupPowerId).First(latestGrade).Error; err != nil {
+		return err
+	}
+	// 记录明细
+	detail := &GroupPowerExpDetail{
+		GroupPowerId: groupPowerId,
+		UserId:       userId,
+		Exp:          exp,
+		AddReduce:    mysql.ADD,
+		BefNum:       latestGrade.Exp - exp,
+		AftNum:       latestGrade.Exp,
+		Remark:       remark,
+	}
+	if err = txModel.DB().Model(GroupPowerExpDetail{}).Create(detail).Error; err != nil {
+		return err
+	}
+	// 达到经验值之后升级
+	for grade := groupPower_e.GroupPowerGradeMax; grade >= groupPower_e.GroupPowerGrade0; grade-- {
+		if latestGrade.Exp > groupPower_e.GroupPowerGradeExp[grade] {
+			if latestGrade.Grade < grade { // 升级
+				expireAt := now.EndOfMonth()
+				expireAt = utils.AddDate(expireAt, 0, 1) // 等级有效期到下个月月底
+				updateAttrs := map[string]interface{}{
+					"grade":     grade,
+					"expire_at": expireAt,
+				}
+				if err = txModel.DB().Model(GroupPowerGrade{}).Where("group_power_id = ?", latestGrade.GroupPowerId).UpdateColumns(updateAttrs).Error; err != nil {
+					return err
+				}
+				// 升级发事件
+				_ = group_power_ev.PublishGroupPowerUpgrade(txModel, &group_power_ev.GroupPowerUpgradeEvent{
+					GroupPowerId: groupPowerId,
+				})
+			}
+			break
+		}
+	}
+	return nil
+}
+
+// 获取势力用户上麦加经验记录
+func GetGroupPowerUserOnMicDetails(model *domain.Model, groupPowerId, userId mysql.ID) ([]*GroupPowerOnMicDetail, error) {
+	var res []*GroupPowerOnMicDetail
+	date := time.Now().Format("2006-01-02")
+	if err := model.DB().Model(GroupPowerOnMicDetail{}).Where("date = ? AND group_power_id = ? AND user_id = ?", date, groupPowerId, userId).Find(&res).Error; err != nil {
+		return res, err
+	}
+	return res, nil
+}
+
+// 获取势力用户上麦记录
+func GetGroupPowerOnMic(model *domain.Model, groupPowerId, userId mysql.ID) (*GroupPowerOnMic, error) {
+	gpom := new(GroupPowerOnMic)
+	date := time.Now().Format("2006-01-02")
+	if err := model.DB().Model(GroupPowerOnMic{}).Where("date = ? AND group_power_id = ? AND user_id = ?", date, groupPowerId, userId).First(gpom).Error; err != nil {
+		if err == gorm.ErrRecordNotFound {
+			return &GroupPowerOnMic{Date: date, GroupPowerId: groupPowerId, UserId: userId}, nil
+		}
+		return nil, err
+	}
+	return gpom, nil
+}
+
+const MaxMinuteTimes = 18
+
+// 增加势力上麦经验
+// 事务操作
+func IncrGroupPowerExpOnMic(model *domain.Model, groupPowerId, userId mysql.ID, joinMicTimestamp int64) error {
+	return model.Transaction(func(model *domain.Model) error {
+		// 获取用户上麦奖励历史
+		onMicDetails, err := GetGroupPowerUserOnMicDetails(model, groupPowerId, userId)
+		if err != nil {
+			return err
+		}
+		numDetails := len(onMicDetails)
+		if numDetails >= MaxMinuteTimes {
+			// 上麦经验贡献值最多1800,1分钟100
+			return nil
+		}
+		onMic, err := GetGroupPowerOnMic(model, groupPowerId, userId)
+		if err != nil {
+			return err
+		}
+		onMicSeconds := time.Now().Unix() - joinMicTimestamp
+		if onMic.LastCalTs == joinMicTimestamp {
+			onMicSeconds = onMicSeconds - int64(numDetails*600) // 扣除之前加过的时间
+		}
+		var moreDetails []*GroupPowerOnMicDetail
+		totalMinuteTimes := int((onMic.Seconds + onMicSeconds) / 600) // 今天实际能加经验次数
+		if totalMinuteTimes >= MaxMinuteTimes {
+			totalMinuteTimes = MaxMinuteTimes
+		}
+		if totalMinuteTimes > numDetails {
+			// 续上上一次的时间,从numDetails开始
+			for mt := numDetails + 1; mt <= totalMinuteTimes; mt++ {
+				moreDetails = append(moreDetails, &GroupPowerOnMicDetail{
+					Date:         time.Now().Format("2006-01-02"),
+					GroupPowerId: groupPowerId,
+					UserId:       userId,
+					Minute:       mt * 10, // 转换分钟
+				})
+			}
+		}
+		// 有更多麦上10分钟,可以加经验
+		if len(moreDetails) > 0 {
+			for _, detail := range moreDetails {
+				// 添加明细,避免重复计算
+				if err := model.DB().Model(GroupPowerOnMicDetail{}).Create(detail).Error; err != nil {
+					return err
+				}
+				// 每10分钟增加100点经验
+				if err := IncrGroupPowerExp(model, groupPowerId, 100, userId, "上麦10分钟"); err != nil {
+					return err
+				}
+			}
+			// 更新micExp信息
+			onMic.Seconds = onMic.Seconds + onMicSeconds
+			onMic.LastCalTs = joinMicTimestamp
+			if err := model.DB().Model(GroupPowerOnMic{}).Clauses(clause.OnConflict{Columns: []clause.Column{{Name: "date"}, {Name: "group_power_id"}},
+				DoUpdates: clause.Assignments(
+					map[string]interface{}{
+						"seconds":     onMic.Seconds,
+						"last_cal_ts": joinMicTimestamp,
+					},
+				)}).
+				Create(onMic).Error; err != nil {
+				return err
+			}
+		}
+		return nil
+	})
+}
+
+// 增加势力上麦时长-家族之星
+// 事务操作
+func IncrGroupPowerStarOnMic(model *domain.Model, groupPowerId, userId mysql.ID, joinMicTimestamp int64) error {
+	return model.Transaction(func(model *domain.Model) error {
+		star, err := GetGroupPowerMonthStar(model, groupPowerId, userId, groupPower_e.GroupPowerStarTypeActive)
+		curTs := joinMicTimestamp
+		nowTs := time.Now().Unix()
+		if err != nil && err != gorm.ErrRecordNotFound {
+			return err
+		}
+		if star != nil && joinMicTimestamp < star.LastCalTs { // 加入的时间比上次计算时间小
+			curTs = star.LastCalTs
+		}
+		score := nowTs - curTs
+		return IncrGroupPowerMonthStarScore(model, groupPowerId, userId, groupPower_e.GroupPowerStarTypeActive, mysql.Num(score), nowTs)
+	})
+}
+
+// 清理所有家族的经验
+func ClearGroupPowerExp(model *domain.Model) error {
+	var groupPowerGrades []*GroupPowerGrade
+	if err := model.DB().Model(GroupPowerGrade{}).Where("exp > 0").Find(&groupPowerGrades).Error; err != nil {
+		return err
+	}
+	return model.Transaction(func(model *domain.Model) error {
+		for _, grade := range groupPowerGrades {
+			if err := model.DB().Model(GroupPowerGrade{}).Where("group_power_id = ?", grade.GroupPowerId).UpdateColumn("exp", 0).Error; err != nil {
+				return err
+			}
+			// 记录明细
+			detail := &GroupPowerExpDetail{
+				GroupPowerId: grade.GroupPowerId,
+				UserId:       0,
+				Exp:          0,
+				AddReduce:    mysql.SET,
+				BefNum:       grade.Exp,
+				AftNum:       0,
+				Remark:       "每月清零",
+			}
+			if err := model.DB().Model(GroupPowerExpDetail{}).Create(detail).Error; err != nil {
+				return err
+			}
+		}
+		return nil
+	})
+}
+
+// 清理过期家族等级
+func ClearGroupPowerGrade(model *domain.Model) error {
+	var groupPowerGrades []*GroupPowerGrade
+	if err := model.DB().Model(GroupPowerGrade{}).Where("expire_at < ?", time.Now()).Find(&groupPowerGrades).Error; err != nil {
+		return err
+	}
+	return model.Transaction(func(model *domain.Model) error {
+		for _, grade := range groupPowerGrades {
+			updateAttrs := map[string]interface{}{
+				"grade":     0,
+				"expire_at": time.Time{},
+			}
+			if err := model.DB().Model(GroupPowerGrade{}).Where("group_power_id = ?", grade.GroupPowerId).Updates(updateAttrs).Error; err != nil {
+				return err
+			}
+		}
+		return nil
+	})
+}
+
+// 批量获取家族等级
+func MGetGroupPowerGrade(model *domain.Model, groupPowerIds []mysql.ID) (map[mysql.ID]GroupPowerGrade, error) {
+	var rows []GroupPowerGrade
+	res := make(map[mysql.ID]GroupPowerGrade)
+	if err := model.DB().Model(GroupPowerGrade{}).Where("group_power_id in ?", groupPowerIds).Find(&rows).Error; err != nil {
+		model.Log.Errorf("MGetGroupPowerGrade fail:%v", err)
+		return res, err
+	}
+	for i, v := range rows {
+		res[v.GroupPowerId] = rows[i]
+	}
+	return res, nil
+}

domain/model/groupPower_m/group_info.go

+package groupPower_m
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"hilo-group/_const/enum/groupPower_e"
+)
+
+type GroupPowerInfo struct {
+	mysql.Entity
+	GroupUid    string
+	Name        string
+	Nameplate   string
+	Declaration string
+	Icon        string
+	Status      int
+}
+
+func (GroupPowerInfo) TableName() string {
+	return "group_power"
+}
+
+// 批量获取家族信息
+func MGetGroupPowerInfoMap(model *domain.Model, groupPowerIds []mysql.ID) (map[mysql.ID]GroupPowerInfo, error) {
+	var rows []GroupPowerInfo
+	res := make(map[mysql.ID]GroupPowerInfo)
+	if err := model.DB().Model(GroupPowerInfo{}).Where("id in ?", groupPowerIds).Find(&rows).Error; err != nil {
+		model.Log.Errorf("MGetGroupPowerInfo fail:%v", err)
+		return res, err
+	}
+	for i, v := range rows {
+		res[v.ID] = rows[i]
+	}
+	return res, nil
+}
+
+// 批量获取家族成员
+func MGetGroupPowerUsers(model *domain.Model, groupPowerIds []mysql.ID) (map[mysql.ID][]*GroupPowerUser, error) {
+	var users []*GroupPowerUser
+	res := make(map[mysql.ID][]*GroupPowerUser)
+	if err := model.DB().Model(GroupPowerUser{}).Where("group_power_id in ?", groupPowerIds).Find(&users).Error; err != nil {
+		model.Log.Errorf("MGetGroupPowerUsers fail:%v", err)
+		return res, err
+	}
+	for i, v := range users {
+		res[v.GroupPowerId] = append(res[v.GroupPowerId], users[i])
+	}
+	return res, nil
+}
+
+// 获取家族成员
+func GetGroupPowerUser(model *domain.Model, groupPowerId mysql.ID) ([]*GroupPowerUser, error) {
+	m, err := MGetGroupPowerUsers(model, []mysql.ID{groupPowerId})
+	if err != nil {
+		return nil, err
+	}
+	return m[groupPowerId], nil
+}
+
+// 获取所有家族的主
+func GetAllGroupPowerOwners(model *domain.Model) ([]mysql.ID, error) {
+	var userIds []mysql.ID
+	if err := model.DB().Model(GroupPowerUser{}).Select("user_id").
+		Where("role = ?", groupPower_e.GroupPowerUserRoleMgr).Find(&userIds).Error; err != nil {
+		model.Log.Errorf("GetAllGroupPowerOwners fail:%v", err)
+		return userIds, err
+	}
+	return userIds, nil
+}

domain/model/groupPower_m/group_rank.go

+package groupPower_m
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"git.hilo.cn/hilo-common/resource/mysql"
+)
+
+type GroupPowerExpRank struct {
+	GroupPowerId mysql.ID
+	Exp          mysql.Num
+	Rank         int
+}
+
+// 获取家族经验排行榜
+// param limit: 排行榜人数
+func GetGroupPowerExpRank(model *domain.Model, beginDate, endDate string, limit int) ([]GroupPowerExpRank, error) {
+	var res []GroupPowerExpRank
+	if err := model.DB().Table("group_power_day_exp").Select("group_power_id,SUM(exp) as exp").
+		Where("date BETWEEN ? AND ?", beginDate, endDate).Group("group_power_id").Order("exp DESC").Limit(limit).Find(&res).Error; err != nil {
+		model.Log.Errorf("GetGroupPowerExpRank fail:%v", err)
+		return res, err
+	}
+	for i := range res {
+		res[i].Rank = i + 1
+	}
+	return res, nil
+}

domain/model/groupPower_m/group_star.go

+package groupPower_m
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"gorm.io/gorm"
+	"gorm.io/gorm/clause"
+	"hilo-group/_const/enum/groupPower_e"
+	"time"
+)
+
+// 家族之星
+type GroupPowerMonthStar struct {
+	Month        string
+	GroupPowerId mysql.ID
+	UserId       mysql.ID
+	Type         groupPower_e.GroupPowerStarType
+	Score        mysql.Num
+	LastCalTs    int64
+	CreatedTime  time.Time `gorm:"->"`
+	UpdatedTime  time.Time `gorm:"->"`
+}
+
+// 增加家族之星分数
+func IncrGroupPowerMonthStarScore(model *domain.Model, groupPowerId, userId mysql.ID, _type groupPower_e.GroupPowerStarType, score mysql.Num, lastCalTs int64) error {
+	month := time.Now().Format("200601")
+	star := &GroupPowerMonthStar{
+		Month:        month,
+		GroupPowerId: groupPowerId,
+		UserId:       userId,
+		Type:         _type,
+		Score:        score,
+	}
+	if err := model.DB().Model(GroupPowerMonthStar{}).Clauses(clause.OnConflict{
+		Columns: []clause.Column{{Name: "month"}, {Name: "group_power_id"}, {Name: "user_id"}, {Name: "type"}},
+		DoUpdates: clause.Assignments(map[string]interface{}{
+			"score":       gorm.Expr("score + ?", star.Score),
+			"last_cal_ts": lastCalTs,
+		}),
+	}).Create(star).Error; err != nil {
+		model.Log.Errorf("IncrGroupPowerMonthStarScore fail:%v", err)
+		return err
+	}
+	return nil
+}
+
+// 获取家族之星分数
+// 允许返回gorm.ErrRecordNotFound
+func GetGroupPowerMonthStar(model *domain.Model, groupPowerId, userId mysql.ID, _type groupPower_e.GroupPowerStarType) (*GroupPowerMonthStar, error) {
+	res := new(GroupPowerMonthStar)
+	month := time.Now().Format("200601")
+	if err := model.DB().Where("month = ? AND group_power_id = ? AND user_id = ? AND `type` = ?", month, groupPowerId, userId, _type).First(res).Error; err != nil {
+		return nil, err
+	}
+	return res, nil
+}
+
+// 获取家族之星排行
+func GetGroupPowerMonthStarRank(model *domain.Model, groupPowerId mysql.ID, _type groupPower_e.GroupPowerStarType, offset, limit int) ([]*GroupPowerMonthStar, error) {
+	var res []*GroupPowerMonthStar
+	month := time.Now().Format("200601")
+	if err := model.DB().Model(GroupPowerMonthStar{}).Where("month = ? AND group_power_id = ? AND `type` = ?", month, groupPowerId, _type).
+		Order("score desc").Offset(offset).Limit(limit).Find(&res).Error; err != nil {
+		model.Log.Errorf("GetGroupPowerMonthStarRank fail:%v", err)
+		return res, err
+	}
+	return res, nil
+}

domain/service/event_s/event_init.go

@@ -3,20 +3,24 @@ package event_s
 import (
 	"encoding/json"
 	"git.hilo.cn/hilo-common/domain"
+	"git.hilo.cn/hilo-common/resource/mysql"
 	"git.hilo.cn/hilo-common/rpc"
 	"git.hilo.cn/hilo-common/sdk/tencentyun"
+	"hilo-group/_const/enum/groupPower_e"
 	"hilo-group/_const/enum/group_e"
 	"hilo-group/_const/enum/msg_e"
 	"hilo-group/_const/enum/task_e"
 	"hilo-group/domain/event/gift_ev"
 	"hilo-group/domain/event/group_ev"
 	"hilo-group/domain/event/group_power_ev"
+	"hilo-group/domain/event/mic_ev"
 	"hilo-group/domain/model/diamond_m"
 	"hilo-group/domain/model/groupPower_m"
 	"hilo-group/domain/model/group_m"
 	"hilo-group/domain/model/msg_m"
 	"hilo-group/domain/model/task_m"
 	"hilo-group/domain/model/user_m"
+	"hilo-group/domain/service/group_mic_s"
 	"hilo-group/myerr"
 	"strconv"
 	"time"
@@ -28,7 +32,8 @@ func EventInit() {
 	GroupEvents()
 	GroupImMass()
 	GroupTheme()
-	SendGift()
+	SendGift() // 送礼事件
+	OnMic()    // 在麦上事件
 }
 
 func GroupSupportEvents() {
@@ -101,7 +106,7 @@ func GroupSupportEvents() {
 }
 
 func GroupPowerEvents() {
-	//加入势力
+	// 加入势力
 	group_power_ev.AddGroupPowerJoinAsync(func(model *domain.Model, e interface{}) error {
 		event, ok := e.(*group_power_ev.GroupPowerJoinEvent)
 		if !ok {
@@ -129,7 +134,7 @@ func GroupPowerEvents() {
 		msg_m.SendEmasMsgAssistant(model, mgrUser.ExternalId, mgrUser.DeviceType)
 		return nil
 	})
-	//离开势力
+	// 离开势力
 	group_power_ev.AddGroupPowerLeaveAsync(func(model *domain.Model, e interface{}) error {
 		event, ok := e.(*group_power_ev.GroupPowerLeaveEvent)
 		if !ok {
@@ -157,6 +162,57 @@ func GroupPowerEvents() {
 		msg_m.SendEmasMsgAssistant(model, mgrUser.ExternalId, mgrUser.DeviceType)
 		return nil
 	})
+	// 势力升级
+	group_power_ev.AddGroupPowerUpgradeAsync(func(model *domain.Model, e interface{}) error {
+		event, ok := e.(*group_power_ev.GroupPowerUpgradeEvent)
+		if !ok {
+			model.Log.Errorf("AddGroupPowerUpgradeAsync event type err")
+			return nil
+		}
+		model.Log.Infof("msg AddGroupPowerUpgradeAsync GroupPowerId:%v", event.GroupPowerId)
+		users, err := groupPower_m.GetGroupPowerUser(model, event.GroupPowerId)
+		if err != nil {
+			return err
+		}
+		var userIds []mysql.ID
+		for _, u := range users {
+			userIds = append(userIds, u.UserId)
+		}
+		userMaps, err := user_m.GetUserMapByIds(model, userIds)
+		if err != nil {
+			return err
+		}
+		for uid, u := range userMaps {
+			if err := msg_m.NewUserRecord(model, uid, msg_e.GroupPowerUpgrade, "", 0, "", "", "", "", "").Persistent(); err != nil {
+				model.Log.Errorf("msg AddGroupPowerLeaveAsync NewUserRecord err:%v", err)
+				return nil
+			}
+			msg_m.SendEmasMsgAssistant(model, u.ExternalId, u.DeviceType)
+		}
+		return nil
+	})
+
+	// 势力等级即将过期
+	group_power_ev.AddGroupPowerExpireNoticeAsync(func(model *domain.Model, e interface{}) error {
+		model.Log.Infof("msg AddGroupPowerExpireNoticeAsync")
+		powerOwners, err := groupPower_m.GetAllGroupPowerOwners(model)
+		if err != nil {
+			model.Log.Errorf("AddGroupPowerExpireNoticeAsync fail:%v", err)
+			return err
+		}
+		userMaps, err := user_m.GetUserMapByIds(model, powerOwners)
+		if err != nil {
+			return err
+		}
+		for uid, u := range userMaps {
+			if err := msg_m.NewUserRecord(model, uid, msg_e.GroupPowerExpireNotice, "", 0, "", "", "", "", "").Persistent(); err != nil {
+				model.Log.Errorf("msg AddGroupPowerExpireNoticeAsync NewUserRecord err:%v", err)
+				return nil
+			}
+			msg_m.SendEmasMsgAssistant(model, u.ExternalId, u.DeviceType)
+		}
+		return nil
+	})
 }
 
 func GroupEvents() {
@@ -397,14 +453,73 @@ func FlushHiloInfo(extId string, isVip bool, isPrettyCode bool, medals []uint32,
 }
 
 func SendGift() {
-	// 送礼事件-火箭
-	gift_ev.AddSendGiftEventAsync(func(model *domain.Model, event interface{}) error {
+	// 送礼事件-势力经验
+	gift_ev.AddSendGiftEventSync(func(model *domain.Model, event interface{}) error {
 		sendGiftEvent, ok := event.(*gift_ev.SendGiftEvent)
 		if !ok {
 			model.Log.Errorf("AddSendGiftEventAsync event type err")
 			return nil
 		}
 		model.Log.Infof("AddSendGiftEventAsync %+v", sendGiftEvent)
+		exist, groupPowerId, err := groupPower_m.CheckGroupPowerUser(model, sendGiftEvent.SendUserId)
+		if err != nil {
+			model.Log.Infof("CheckGroupPowerUser fail %+v", err)
+			return err
+		}
+		if exist {
+			exp := sendGiftEvent.GiftN * mysql.Num(len(sendGiftEvent.ReceiveUserIds)) * sendGiftEvent.ResGift.DiamondNum
+			return groupPower_m.IncrGroupPowerExp(model, groupPowerId, exp, sendGiftEvent.SendUserId, "送礼")
+		}
 		return nil
 	})
+	// 家族之星-送礼/收礼
+	gift_ev.AddSendGiftEventAsync(func(model *domain.Model, event interface{}) error {
+		sendGiftEvent, ok := event.(*gift_ev.SendGiftEvent)
+		if !ok {
+			model.Log.Errorf("AddSendGiftEventAsync event type err")
+			return nil
+		}
+		var userIds = []mysql.ID{sendGiftEvent.SendUserId}
+		userIds = append(userIds, sendGiftEvent.ReceiveUserIds...)
+		groupPowers, err := groupPower_m.BatchGetGroupPowerUser(model, userIds)
+		if err != nil {
+			model.Log.Errorf("AddSendGiftEventAsync fail:%v", err)
+			return err
+		}
+		// 送礼加分
+		if data, ok := groupPowers[sendGiftEvent.SendUserId]; ok {
+			diamonds := sendGiftEvent.GiftN * sendGiftEvent.ResGift.DiamondNum * mysql.Num(len(sendGiftEvent.ReceiveUserIds))
+			if err := groupPower_m.IncrGroupPowerMonthStarScore(model, data.GroupPowerId, data.UserId, groupPower_e.GroupPowerStarTypeFamous, diamonds, 0); err != nil {
+				model.Log.Errorf("IncrGroupPowerMonthStarScore famous fail:%v", err)
+			}
+		}
+		// 收礼加分
+		for _, userId := range sendGiftEvent.ReceiveUserIds {
+			if data, ok := groupPowers[userId]; ok {
+				diamonds := sendGiftEvent.GiftN * sendGiftEvent.ResGift.DiamondNum
+				if err := groupPower_m.IncrGroupPowerMonthStarScore(model, data.GroupPowerId, data.UserId, groupPower_e.GroupPowerStarTypeCharm, diamonds, 0); err != nil {
+					model.Log.Errorf("IncrGroupPowerMonthStarScore charm fail:%v", err)
+				}
+			}
+		}
+		return nil
+	})
+}
+
+func OnMic() {
+	// 上麦经验/上麦时长
+	mic_ev.AddOnMicEventAsync(func(model *domain.Model, e interface{}) error {
+		event, ok := e.(*mic_ev.OnMicEvent)
+		if !ok {
+			model.Log.Errorf("AddOnMicEventSync event type err")
+			return nil
+		}
+		if err := group_mic_s.NewGroupPowerService(model.MyContext).IncrGroupPowerOnMicExpAndTime(event.GroupUuid, event.UserId, event.Timestamp); err != nil {
+			model.Log.Errorf("cron micIn GroupPowerOnMicExp err:%v", err)
+		} else {
+			model.Log.Infof("cron micIn GroupPowerOnMicExp success, groupId:%v, userId:%v", event.GroupUuid, event.UserId)
+		}
+		return nil
+	})
+
 }

domain/service/event_s/send_gift.go

@@ -57,7 +57,7 @@ func (s *GiftSendEventService) Consume() error {
 				return nil
 			}
 			if err := gift_ev.PublishSendGiftEvent(model, sendGiftEvent); err != nil {
-				model.Log.Errorf("PublishSendGiftEvent fail,event:%v,err:%v", cpEvent, err)
+				model.Log.Errorf("PublishSendGiftEvent fail,event:%v,err:%v", string(cpEvent.Payload), err)
 				return err
 			}
 			// 标记已经处理

domain/service/group_mic_s/group_mic.go

@@ -10,6 +10,7 @@ import (
 	"hilo-group/_const/enum/group_e"
 	"hilo-group/_const/redis_key"
 	"hilo-group/domain/event/group_ev"
+	"hilo-group/domain/model/groupPower_m"
 	"hilo-group/domain/model/group_m"
 	"hilo-group/domain/service/signal_s"
 	"hilo-group/myerr"
@@ -287,3 +288,39 @@ func (s *GroupMicService) GroupIMMassByMgr(groupId string, userId uint64, extern
 		})
 	})
 }
+
+// 增加势力上麦经验/时长
+func (s *GroupMicService) IncrGroupPowerOnMicExpAndTime(groupId string, userId uint64, joinMicTimestamp int64) error {
+	var model = domain.CreateModelContext(s.svc.MyContext)
+	exists, groupPowerId, err := groupPower_m.CheckGroupPowerUser(model, userId)
+	if err != nil {
+		return err
+	}
+	if !exists {
+		return nil
+	}
+	// 获取势力下所有群组
+	groups, err := groupPower_m.GetGroupPowerGroups(model, groupPowerId)
+	if err != nil {
+		return err
+	}
+	inGroup := false
+	for _, group := range groups {
+		if group.ImGroupId == groupId {
+			inGroup = true
+			break
+		}
+	}
+	if !inGroup {
+		return nil
+	}
+	// 增加势力上麦经验
+	if err := groupPower_m.IncrGroupPowerExpOnMic(model, groupPowerId, userId, joinMicTimestamp); err != nil {
+		model.Log.Errorf("IncrGroupPowerExpOnMic fail:%v", err)
+	}
+	// 增加势力上麦时长
+	if err := groupPower_m.IncrGroupPowerStarOnMic(model, groupPowerId, userId, joinMicTimestamp); err != nil {
+		model.Log.Errorf("IncrGroupPowerOnMicTime fail:%v", err)
+	}
+	return nil
+}

local.ini

@@ -59,12 +59,12 @@ TX_OVERSEA_APP_ID=40000066
 TX_OVERSEA_KEY=3ab68ea5bddc8774d90b8c764ae71188914bd5fd06f30b28790c51e44ca7885c
 [EMAS]
 REGION_ID=cn-hangzhou
-ACCESS_KEY_ID=LTAI4FhNPzxdzD4w6bHirL9Z
-ACCESS_KEY_SECRET=OQvUJpXDrjGi3g1F2aHiAIFWIvLdbP
+ACCESS_KEY_ID=LTAIdQZv5H1kNZp5
+ACCESS_KEY_SECRET=UnwY0ClDkqBMLwPx3OJJiLYyk9xYLO
 ANDROID_APP_KEY=30250713
 ANDROID_APP_SECRET=cae7b9a9d3e54577d2c3b60bf6d23047
-IOS_APP_KEY=30240346
-IOS_APP_SECRET=57f33ab9ca6a957a8c659f2b0b6d1205
+IOS_APP_KEY=30790728
+IOS_APP_SECRET=4fd69ca084c67d4b5a8d15452f0af26a
 APNS=DEV
 [AGORA]
 APP_ID=fc3e087f701b4f788099e1924c3cc7b0

route/group_power_r/group_power.go

@@ -377,7 +377,7 @@ func GetGroupPowerGroups(c *gin.Context) (*mycontext.MyContext, error) {
 			groupIds = append(groupIds, i.ImGroupId)
 			owners = append(owners, i.Owner)
 		}
-		powerIds, powerNames, err := group_power_cv.BatchGetGroupPower(model.Db, owners)
+		powerIds, powerNames, powerNameplates, err := group_power_cv.BatchGetGroupPower(model.Db, owners)
 		if err != nil {
 			return myContext, err
 		}
@@ -489,9 +489,10 @@ func GetGroupPowerGroups(c *gin.Context) (*mycontext.MyContext, error) {
 						MicNumType:          int(i.MicNumType),
 						GroupMedals:         medals,
 					},
-					HasOnMic:       len(roomMicUserMap[i.ImGroupId]) > 0,
-					GroupPowerId:   powerIds[i.Owner],
-					GroupPowerName: powerNames[i.Owner],
+					HasOnMic:            len(roomMicUserMap[i.ImGroupId]) > 0,
+					GroupPowerId:        powerIds[i.Owner],
+					GroupPowerName:      powerNames[i.Owner],
+					GroupPowerNameplate: powerNameplates[i.Owner],
 				},
 				MicUsers:      micUsers,
 				RoomUserCount: uint(roomCount[i.ImGroupId]),

route/group_power_r/group_rank.go

+package group_power_r
+
+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/utils"
+	"github.com/gin-gonic/gin"
+	"github.com/jinzhu/now"
+	"hilo-group/_const/enum/groupPower_e"
+	"hilo-group/cv/group_power_cv"
+	"hilo-group/cv/user_cv"
+	"hilo-group/domain/model/groupPower_m"
+	"hilo-group/domain/model/user_m"
+	"hilo-group/myerr/bizerr"
+	"hilo-group/req"
+	"hilo-group/resp"
+	"strconv"
+	"time"
+)
+
+// @Tags 国家势力
+// @Summary 家族榜单
+// @Param token header string true "token"
+// @Param nonce header string true "随机数字"
+// @Param period path string true "榜单周期 day:日 week:周 month:月"
+// @Success 200 {object} group_power_cv.CvGroupPowerRank
+// @Router /v1/groupPower/rank/{period} [get]
+func GroupPowerRank(c *gin.Context) (*mycontext.MyContext, error) {
+	myContext := mycontext.CreateMyContext(c.Keys)
+	userId, err := req.GetUserId(c)
+	if err != nil {
+		return myContext, err
+	}
+	period := c.Param("period")
+	if period != "day" && period != "week" && period != "month" {
+		return myContext, bizerr.InvalidParameter
+	}
+	var beginDate, endDate string
+	switch period {
+	case "day":
+		beginDate, endDate = time.Now().Format("2006-01-02"), time.Now().Format("2006-01-02")
+	case "week":
+		beginDate, endDate = utils.GetMonday(time.Now()).Format("2006-01-02"), utils.GetMonday(time.Now()).AddDate(0, 0, 6).Format("2006-01-02")
+	case "month":
+		beginDate, endDate = now.BeginningOfMonth().Format("2006-01-02"), now.EndOfMonth().Format("2006-01-02")
+	}
+	var model = domain.CreateModelContext(myContext)
+	rank, err := groupPower_m.GetGroupPowerExpRank(model, beginDate, endDate, 30)
+	if err != nil {
+		return myContext, err
+	}
+	var ids []mysql.ID
+	for _, g := range rank {
+		ids = append(ids, g.GroupPowerId)
+	}
+	response := group_power_cv.CvGroupPowerRank{}
+	myGroupPower, err := groupPower_m.GetGroupPowerUserOrNil(model, userId)
+	if err != nil {
+		return myContext, err
+	}
+	if myGroupPower != nil {
+		ids = append(ids, myGroupPower.GroupPowerId)
+	}
+	grades, err := groupPower_m.MGetGroupPowerGrade(model, ids)
+	if err != nil {
+		return myContext, err
+	}
+	groupPowers, err := groupPower_m.MGetGroupPowerInfoMap(model, ids)
+	if err != nil {
+		return myContext, err
+	}
+	for _, v := range rank {
+		if myGroupPower != nil && v.GroupPowerId == myGroupPower.GroupPowerId && myGroupPower.Role == groupPower_e.GroupPowerUserRoleMgr {
+			response.MyGroupPower = &group_power_cv.CvGroupPowerRankData{
+				CvGroupPowerBase: group_power_cv.CvGroupPowerBase{
+					GroupPowerId: myGroupPower.GroupPowerId,
+					Icon:         groupPowers[myGroupPower.GroupPowerId].Icon,
+					Name:         groupPowers[myGroupPower.GroupPowerId].Name,
+					Nameplate:    groupPowers[myGroupPower.GroupPowerId].Nameplate,
+				},
+				CvGroupPowerGrade: group_power_cv.CvGroupPowerGrade{
+					Grade: grades[myGroupPower.GroupPowerId].Grade,
+					Exp:   v.Exp,
+				},
+				Rank: v.Rank,
+			}
+		}
+		response.Items = append(response.Items, group_power_cv.CvGroupPowerRankData{
+			CvGroupPowerBase: group_power_cv.CvGroupPowerBase{
+				GroupPowerId: v.GroupPowerId,
+				Icon:         groupPowers[v.GroupPowerId].Icon,
+				Name:         groupPowers[v.GroupPowerId].Name,
+				Nameplate:    groupPowers[v.GroupPowerId].Nameplate,
+			},
+			CvGroupPowerGrade: group_power_cv.CvGroupPowerGrade{
+				Grade: grades[v.GroupPowerId].Grade,
+				Exp:   v.Exp,
+			},
+			Rank: v.Rank,
+		})
+	}
+	if response.MyGroupPower != nil && response.MyGroupPower.Rank == 0 {
+		response.MyGroupPower.Rank = 31 // 客户端统一显示30+
+	}
+	resp.ResponseOk(c, response)
+	return myContext, nil
+}
+
+type GroupPowerStarReq struct {
+	GroupPowerId mysql.ID                        `form:"groupPowerId" binding:"required"`
+	Type         groupPower_e.GroupPowerStarType `form:"type" binding:"required"`
+	PageSize     int                             `form:"pageSize"`
+	PageIndex    int                             `form:"pageIndex"`
+}
+
+// @Tags 国家势力
+// @Summary 家族之星
+// @Param token header string true "token"
+// @Param nonce header string true "随机数字"
+// @Param groupPowerId query int true "家族id"
+// @Param type query integer true "类型 1:送礼 2:活跃 3:收礼物"
+// @Param pageSize query int false "分页大小 默认：30" default(30)
+// @Param pageIndex query int false "第几个分页，从1开始 默认：1" default(1)
+// @Success 200 {object} []group_power_cv.CvGroupPowerStarData
+// @Router /v1/groupPower/star [get]
+func GroupPowerStar(c *gin.Context) (*mycontext.MyContext, error) {
+	myContext := mycontext.CreateMyContext(c.Keys)
+	param := new(GroupPowerStarReq)
+	if err := c.ShouldBindQuery(param); err != nil {
+		return myContext, err
+	}
+	if param.PageIndex <= 0 {
+		param.PageIndex = 1
+	}
+	if param.PageSize <= 0 {
+		param.PageSize = 30
+	}
+	var model = domain.CreateModelContext(myContext)
+	offset, limit := (param.PageIndex-1)*param.PageSize, param.PageSize
+	rank, err := groupPower_m.GetGroupPowerMonthStarRank(model, param.GroupPowerId, param.Type, offset, limit)
+	if err != nil {
+		return myContext, err
+	}
+	var response []group_power_cv.CvGroupPowerStarData
+	var userIds []mysql.ID
+	for _, row := range rank {
+		userIds = append(userIds, row.UserId)
+	}
+	users, err := user_m.GetUserMapByIds(model, userIds)
+	for _, row := range rank {
+		user := users[row.UserId]
+		response = append(response, group_power_cv.CvGroupPowerStarData{
+			User: user_cv.CvUserTiny{
+				Id:         user.ID,
+				ExternalId: user.ExternalId,
+				Code:       user.Code,
+				Nick:       user.Nick,
+				Avatar:     user.Avatar,
+			},
+			Score: row.Score,
+		})
+	}
+	resp.ResponsePageBaseOk(c, response, 0, false)
+	return myContext, nil
+}
+
+// @Tags 国家势力
+// @Summary 家族等级页
+// @Param token header string true "token"
+// @Param nonce header string true "随机数字"
+// @Param groupPowerId query int true "家族id"
+// @Success 200 {object} group_power_cv.CvGroupPowerGradeDetail
+// @Router /v1/groupPower/grade/detail [get]
+func GroupPowerGradeDetail(c *gin.Context) (*mycontext.MyContext, error) {
+	myContext := mycontext.CreateMyContext(c.Keys)
+	userId, err := req.GetUserId(c)
+	if err != nil {
+		return myContext, err
+	}
+	groupPowerId, err := strconv.ParseUint(c.Query("groupPowerId"), 10, 16)
+	if err != nil || groupPowerId <= 0 {
+		return myContext, bizerr.InvalidParameter
+	}
+	var model = domain.CreateModelContext(myContext)
+	groupPowerInfo, err := groupPower_m.MGetGroupPowerInfoMap(model, []mysql.ID{groupPowerId})
+	if err != nil {
+		return myContext, err
+	}
+	gradeM, err := groupPower_m.MGetGroupPowerGrade(model, []mysql.ID{groupPowerId})
+	if err != nil {
+		return myContext, err
+	}
+	groupPower, ok := groupPowerInfo[groupPowerId]
+	if !ok {
+		return myContext, bizerr.GroupNotFound
+	}
+	grade := gradeM[groupPowerId]
+	nextExp := mysql.Num(0)
+	if grade.Grade != groupPower_e.GroupPowerGradeMax {
+		nextExp = groupPower_e.GroupPowerGradeExp[grade.Grade+1] - groupPower_e.GroupPowerGradeExp[grade.Grade]
+	}
+	expireAt := ""
+	if grade.ExpireAt.After(time.Now()) {
+		expireAt = grade.ExpireAt.Format("2006-01-02")
+	}
+	showExp := false
+	if exits, _, err := groupPower_m.CheckGroupPowerUser(model, userId); err != nil {
+		return myContext, err
+	} else if exits {
+		showExp = true
+	}
+	response := group_power_cv.CvGroupPowerGradeDetail{
+		GroupPowerBase: group_power_cv.CvGroupPowerBase{
+			GroupPowerId: groupPower.ID,
+			Icon:         groupPower.Icon,
+			Name:         groupPower.Name,
+			Nameplate:    groupPower.Nameplate,
+		},
+		GroupPowerGrade: group_power_cv.CvGroupPowerGrade{
+			Grade:    grade.Grade,
+			Exp:      grade.Exp,
+			NextExp:  nextExp,
+			ExpireAt: expireAt,
+			ShowExp:  showExp,
+		},
+		ResGradeList:  group_power_cv.CvResGradeList,
+		PrivilegeList: group_power_cv.GroupPowerGradePrivilegeNum[grade.Grade],
+	}
+	resp.ResponseOk(c, response)
+	return myContext, nil
+}

route/group_power_r/inner.go

+package group_power_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-group/_const/enum/groupPower_e"
+	"hilo-group/_const/enum/msg_e"
+	"hilo-group/cv/group_power_cv"
+	"hilo-group/domain/model/groupPower_m"
+	"hilo-group/domain/model/msg_m"
+	"hilo-group/domain/model/user_m"
+	"hilo-group/resp"
+)
+
+type MGetGroupPowerReq 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} map[mysql.ID]group_power_cv.CvGroupPowerInfo
+// @Router /inner/groupPower/infos [get]
+func MGetGroupPowers(c *gin.Context) (*mycontext.MyContext, error) {
+	myCtx := mycontext.CreateMyContext(c.Keys)
+	var model = domain.CreateModelContext(myCtx)
+	var req MGetGroupPowerReq
+	if err := c.ShouldBindQuery(&req); err != nil {
+		return myCtx, err
+	}
+	groupPowers, err := groupPower_m.MGetGroupPowerInfoMap(model, req.Ids)
+	if err != nil {
+		return myCtx, err
+	}
+	groupPowerUsers, err := groupPower_m.MGetGroupPowerUsers(model, req.Ids)
+	if err != nil {
+		return myCtx, err
+	}
+	groupPowerGrade, err := groupPower_m.MGetGroupPowerGrade(model, req.Ids)
+	if err != nil {
+		return myCtx, err
+	}
+	response := make(map[mysql.ID]group_power_cv.CvGroupPowerInfo)
+	for groupPowerId, info := range groupPowers {
+		// 成员上限
+		var memberLimit mysql.Num
+		grade := groupPowerGrade[groupPowerId].Grade
+		if grade >= groupPower_e.GroupPowerGrade0 && grade <= groupPower_e.GroupPowerGradeMax {
+			memberLimit = mysql.Num(group_power_cv.GroupPowerGradePrivilegeNum[groupPowerGrade[groupPowerId].Grade][0].Num)
+		}
+		memberNum := mysql.Num(len(groupPowerUsers[groupPowerId]))
+		if memberNum > memberLimit {
+			memberLimit = memberNum
+		}
+		response[groupPowerId] = group_power_cv.CvGroupPowerInfo{
+			CvGroupPowerBase: group_power_cv.CvGroupPowerBase{
+				GroupPowerId: groupPowerId,
+				Icon:         info.Icon,
+				Name:         info.Name,
+				Nameplate:    info.Nameplate,
+			},
+			CvGroupPowerMember: group_power_cv.CvGroupPowerMember{
+				MemberNum:   memberNum,
+				MemberLimit: memberLimit,
+			},
+		}
+	}
+	resp.ResponseOk(c, response)
+	return myCtx, nil
+}
+
+func Test(c *gin.Context) (*mycontext.MyContext, error) {
+	var model = domain.CreateModelNil()
+	if err := msg_m.NewUserRecord(model, 4522, msg_e.GroupPowerUserJoin, "frozen", 4522, "", "", "", "", "").Persistent(); err != nil {
+		return nil, err
+	}
+	mgrUser, _ := user_m.GetUser(model, 4522)
+	err := msg_m.SendEmasMsgAssistant(model, mgrUser.ExternalId, mgrUser.DeviceType)
+	if err != nil {
+		return nil, err
+	}
+	//err := emas.SendIosMsgAll("全部消息测试")
+	//if err != nil {
+	//	return nil, err
+	//}
+	return nil, nil
+}

route/group_r/group_info.go

@@ -133,7 +133,7 @@ func GetTheirGroups(c *gin.Context) (*mycontext.MyContext, error) {
 	}
 	model.Log.Info("GetTheirGroups: theirRoles - ", theirRoles)
 
-	powerIds, powerNames, err := group_power_cv.BatchGetGroupPower(model.Db, owners)
+	powerIds, powerNames, powerNameplates, err := group_power_cv.BatchGetGroupPower(model.Db, owners)
 	if err != nil {
 		return myContext, err
 	}
@@ -273,8 +273,9 @@ func GetTheirGroups(c *gin.Context) (*mycontext.MyContext, error) {
 							GroupMedals:         medals,
 						},
 						//HasOnMic:       onMicScore[i.GroupId] != 0,
-						GroupPowerId:   powerIds[gi.Owner],
-						GroupPowerName: powerNames[gi.Owner],
+						GroupPowerId:        powerIds[gi.Owner],
+						GroupPowerName:      powerNames[gi.Owner],
+						GroupPowerNameplate: powerNameplates[gi.Owner],
 					},
 					MicUsers:      micUsers,
 					RoomUserCount: uint(roomCount[i.GroupId]),
@@ -362,7 +363,7 @@ func PluginReady(c *gin.Context) (*mycontext.MyContext, error) {
 // @Param token header string true "token"
 // @Param nonce header string true "随机数字"
 // @Param groupId path string true "群ID"
-// @Success 200 {object} cv.RoomInfo
+// @Success 200 {object} group_cv.RoomInfo
 // @Router /v1/imGroup/roomInfo/{groupId} [get]
 func GetRoomInfo(c *gin.Context) (*mycontext.MyContext, error) {
 	myContext := mycontext.CreateMyContext(c.Keys)
@@ -1195,7 +1196,7 @@ func GroupMedalAll(c *gin.Context) (*mycontext.MyContext, error) {
 // @Param token header string true "token"
 // @Param nonce header string true "随机数字"
 // @Param groupId query string false "群ID"
-// @Success 200 {object} cv.RoomMedalInfo
+// @Success 200 {object} group_cv.RoomMedalInfo
 // @Router /v1/imGroup/medal/room [get]
 func GetRoomMedal(c *gin.Context) (*mycontext.MyContext, error) {
 	myContext := mycontext.CreateMyContext(c.Keys)

route/group_r/group_list.go

@@ -246,7 +246,7 @@ func GetPopularGroups(c *gin.Context) (*mycontext.MyContext, error) {
 			groupIds = append(groupIds, i.ImGroupId)
 			owners = append(owners, i.Owner)
 		}
-		powerIds, powerNames, err := group_power_cv.BatchGetGroupPower(model.Db, owners)
+		powerIds, powerNames, powerNameplates, err := group_power_cv.BatchGetGroupPower(model.Db, owners)
 		if err != nil {
 			return myContext, err
 		}
@@ -338,9 +338,10 @@ func GetPopularGroups(c *gin.Context) (*mycontext.MyContext, error) {
 						MicNumType:          int(i.MicNumType),
 						GroupMedals:         medals,
 					},
-					HasOnMic:       true,
-					GroupPowerId:   powerIds[i.Owner],
-					GroupPowerName: powerNames[i.Owner],
+					HasOnMic:            true,
+					GroupPowerId:        powerIds[i.Owner],
+					GroupPowerName:      powerNames[i.Owner],
+					GroupPowerNameplate: powerNameplates[i.Owner],
 				},
 				MicUsers:      micUsers,
 				RoomUserCount: uint(roomCount[i.ImGroupId]),
@@ -468,7 +469,7 @@ func GetLatestGroups(c *gin.Context) (*mycontext.MyContext, error) {
 	for _, group := range groupInfos {
 		owners = append(owners, group.Owner)
 	}
-	powerIds, powerNames, err := group_power_cv.BatchGetGroupPower(model.Db, owners)
+	powerIds, powerNames, powerNameplates, err := group_power_cv.BatchGetGroupPower(model.Db, owners)
 	if err != nil {
 		return myContext, err
 	}
@@ -555,9 +556,10 @@ func GetLatestGroups(c *gin.Context) (*mycontext.MyContext, error) {
 					MicNumType:          int(group.MicNumType),
 					GroupMedals:         medals,
 				},
-				HasOnMic:       true,
-				GroupPowerId:   powerIds[group.Owner],
-				GroupPowerName: powerNames[group.Owner],
+				HasOnMic:            true,
+				GroupPowerId:        powerIds[group.Owner],
+				GroupPowerName:      powerNames[group.Owner],
+				GroupPowerNameplate: powerNameplates[group.Owner],
 			},
 			MicUsers:      micUsers,
 			RoomUserCount: uint(roomCount[group.ImGroupId]),
@@ -1150,7 +1152,7 @@ func buildRoleMembers(model *domain.Model, groupId string, userId uint64) ([]gro
 // @Param countryShortName query string true "国家缩写"
 // @Param pageSize query int true "分页大小 默认：10" default(10)
 // @Param pageIndex query int true "第几个分页，从1开始 默认：1" default(1)
-// @Success 200 {object} cv.PopularGroupInfo
+// @Success 200 {object} group_cv.PopularGroupInfo
 // @Router /v1/imGroup/country [get]
 func GetGroupByCountry(c *gin.Context) (*mycontext.MyContext, error) {
 	myContext := mycontext.CreateMyContext(c.Keys)
@@ -1289,7 +1291,7 @@ func GetGroupByCountry(c *gin.Context) (*mycontext.MyContext, error) {
 			groupIds = append(groupIds, i.ImGroupId)
 			owners = append(owners, i.Owner)
 		}
-		powerIds, powerNames, err := group_power_cv.BatchGetGroupPower(model.Db, owners)
+		powerIds, powerNames, powerNameplates, err := group_power_cv.BatchGetGroupPower(model.Db, owners)
 		if err != nil {
 			return myContext, err
 		}
@@ -1369,9 +1371,10 @@ func GetGroupByCountry(c *gin.Context) (*mycontext.MyContext, error) {
 						MicNumType:          int(i.MicNumType),
 						GroupMedals:         medals,
 					},
-					HasOnMic:       micGroupNum[i.ImGroupId] > 0,
-					GroupPowerId:   powerIds[i.Owner],
-					GroupPowerName: powerNames[i.Owner],
+					HasOnMic:            micGroupNum[i.ImGroupId] > 0,
+					GroupPowerId:        powerIds[i.Owner],
+					GroupPowerName:      powerNames[i.Owner],
+					GroupPowerNameplate: powerNameplates[i.Owner],
 				},
 				MicUsers:      []user_cv.CvUserTiny{},
 				RoomUserCount: uint(roomCount[i.ImGroupId]),
@@ -1436,7 +1439,7 @@ func getCandidatesByCountry(model *domain.Model, bannedGroups map[string]uint64,
 // @Param signature header string true "sha1加密结果"
 // @Param deviceType header string true "系统类型 ios android"
 // @Param deviceVersion header string true "系统版本"
-// @Success 200 {object} cv.CvCountry
+// @Success 200 {object} group_cv.CvCountry
 // @Router /v1/imGroup/country/prior [get]
 func GroupountryPrior(c *gin.Context) (*mycontext.MyContext, error) {
 	myContext := mycontext.CreateMyContext(c.Keys)

route/group_r/group_mic.go

@@ -921,7 +921,7 @@ func GroupMicMute(c *gin.Context) (*mycontext.MyContext, error) {
 // @Param nonce header string true "随机数字"
 // @Param groupId formData string true "群ID"
 // @Param content formData string true "内容"
-// @Success 200 {object} cv.CvDiamond
+// @Success 200 {object} diamond_cv.CvDiamond
 // @Router /v1/imGroup/mic/mass [post]
 func GroupMicMass(c *gin.Context) (*mycontext.MyContext, error) {
 	myContext := mycontext.CreateMyContext(c.Keys)
@@ -960,7 +960,7 @@ func GroupMicMass(c *gin.Context) (*mycontext.MyContext, error) {
 // @Param nonce header string true "随机数字"
 // @Param groupId formData string true "群ID"
 // @Param content formData string true "内容"
-// @Success 200 {object} cv.CvDiamond
+// @Success 200 {object} diamond_cv.CvDiamond
 // @Router /v1/imGroup/mgr/mass [post]
 func GroupMgrMass(c *gin.Context) (*mycontext.MyContext, error) {
 	myContext := mycontext.CreateMyContext(c.Keys)

route/group_r/group_support.go

@@ -67,7 +67,7 @@ func GetSupportPage(c *gin.Context) (*mycontext.MyContext, error) {
 // @Param token header string true "token"
 // @Param nonce header string true "随机数字"
 // @Param groupId query string false "群ID"
-// @Success 200 {object} cv.SupportPageDetail
+// @Success 200 {object} group_cv.SupportPageDetail
 // @Router /v1/imGroup/support/detail [get]
 func GetSupportDetail(c *gin.Context) (*mycontext.MyContext, error) {
 	myContext := mycontext.CreateMyContext(c.Keys)
@@ -256,7 +256,7 @@ func TryAddSupporter(c *gin.Context) (*mycontext.MyContext, error) {
 // @Param nonce header string true "随机数字"
 // @Param groupId path string true "群ID"
 // @Param supporters formData string false "群支持者的externalId，用逗号分隔"
-// @Success 200 {object} cv.AwardResult
+// @Success 200 {object} group_cv.AwardResult
 // @Router /v1/imGroup/support/award/{groupId} [post]
 func TakeSupportAward(c *gin.Context) (*mycontext.MyContext, error) {
 	myContext := mycontext.CreateMyContext(c.Keys)

route/router.go

@@ -135,12 +135,23 @@ func InitRouter() *gin.Engine {
 		groupPower.POST("/quit", wrapper(group_power_r.GroupPowerQuit))
 		groupPower.GET("/quit/list", wrapper(group_power_r.GroupPowerQuitList))
 		groupPower.POST("/admin", wrapper(group_power_r.GroupPowerSetAdmin))
+		groupPower.GET("/rank/:period", wrapper(group_power_r.GroupPowerRank))
+		groupPower.GET("/star", wrapper(group_power_r.GroupPowerStar))
+		groupPower.GET("/grade/detail", wrapper(group_power_r.GroupPowerGradeDetail))
 	}
 
 	charge := v1.Group("/charge")
 	{
 		charge.GET("/share", wrapper(charge_r.CanShareChargeLink))
 	}
+
+	// 内部接口
+	inner := r.Group("/inner")
+	innerGroupPower := inner.Group("/groupPower")
+	{
+		innerGroupPower.GET("/infos", wrapper(group_power_r.MGetGroupPowers))
+	}
+	r.GET("/test", wrapper(group_power_r.Test))
 	return r
 }
 

test/.env

+MODE=local

test/group_power_test.go

+package test
+
+import (
+	"git.hilo.cn/hilo-common/domain"
+	"hilo-group/domain/model/groupPower_m"
+	"testing"
+)
+
+func TestGetAllGroupPowerOwner(t *testing.T) {
+	owners, err := groupPower_m.GetAllGroupPowerOwners(domain.CreateModelNil())
+	println(owners, err)
+}

test/local.ini

+[DATABASE]
+MYSQL_HOST=47.244.34.27:3306
+MYSQL_USERNAME=root
+MYSQL_PASSWORD=yX0jPAhO0I4s2zlA
+MYSQL_DB=hilo
+[DATABASECODE]
+MYSQL_HOST=47.244.34.27:3306
+MYSQL_USERNAME=root
+MYSQL_PASSWORD=yX0jPAhO0I4s2zlA
+MYSQL_DB=hilo_code
+[REDIS]
+REDIS_HOST=47.244.34.27:6379
+REDIS_PASSWORD=8QZ9JD1zLvPR3yHf
+[JWT]
+SECRET=hilo1632
+ISSUER_API=hiloApi
+ISSUER_Mgr=hiloMgr
+EXPIRE=240h
+[GAMEJWT]
+SECRET=hilo1632
+ISSUER_CLIENT=hiloClient
+ISSUER_SERVER=hiloServer
+EXPIRE=240h
+[APP]
+MASTER=false
+BIZ_SECRET=biz
+WEB_SECRET=webHilo1258
+OPERATION_SECRET=operation1258236
+SUPERUSER=2701,2831
+OFFICIAL_STAFF=2701,2831
+OFFICIAL_GROUP=@TGS#3NC2ATRHS,@TGS#33W3KNLHK
+MINIMAL_VERSION_ANDROID=212
+MINIMAL_VERSION_IOS=100
+MODERATE=AWS
+[OSS]
+OSS_ACCESS_KEY_ID=LTAIxdazV2pCuV3T
+OSS_ACCESS_KEY_SECRET=zuAnreAXQ6vlAKnvvmolFLfb1N5w5S
+OSS_ROLE_ARN=acs:ram::1509841556585969:role/aliyunosstokengeneratorrole
+OSS_END_POINT=http://oss-accelerate.aliyuncs.com
+OSS_BUCKET=starvoice
+OSS_CDN=https://oss.chathot.me/
+OSS_EXPIRED_TIME=3600
+OSS_STS_POINT=me-east-1
+OSS_STS=sts-faceline-demo
+OSS_STS_AES=484194d4d0f968a7
+[AWS]
+AWS_BUCKET=starchat
+AWS_CDN=https://image.whoisamy.shop/
+AWS_DIR=hilo/
+CONFIDENCE=80
+[RONGYUN]
+RONG_CLOUD_APP_KEY=pvxdm17jpe9tr
+RONG_CLOUD_APP_SECRET=rI4giiKWaBS4
+RONG_CLOUD_URL=https://api-sg01.ronghub.com
+[TENCENTYUN]
+TENCENTYUN_APP_ID=1400548270
+TENCENTYUN_KEY=321bd60f73096b059c7350f1cd97d51028850b34fa58c5c0d26bb4a19e783de8
+TX_OVERSEA_APP_ID=40000066
+TX_OVERSEA_KEY=3ab68ea5bddc8774d90b8c764ae71188914bd5fd06f30b28790c51e44ca7885c
+[EMAS]
+REGION_ID=cn-hangzhou
+ACCESS_KEY_ID=LTAI4FhNPzxdzD4w6bHirL9Z
+ACCESS_KEY_SECRET=OQvUJpXDrjGi3g1F2aHiAIFWIvLdbP
+ANDROID_APP_KEY=30250713
+ANDROID_APP_SECRET=cae7b9a9d3e54577d2c3b60bf6d23047
+IOS_APP_KEY=30240346
+IOS_APP_SECRET=57f33ab9ca6a957a8c659f2b0b6d1205
+APNS=DEV
+[AGORA]
+APP_ID=fc3e087f701b4f788099e1924c3cc7b0
+APP_CERTIFICATE=ff29c100a613433db82324e8411eabc8
+CUSTOMER_KEY=6b132c0ff7164560a2bc53fda06ea85a
+CUSTOMER_SECRET=eedad2cd16d24834990d5450ace9f1ce
+CALLBACK_SECRET=n_ZizS_N8
+[CHECKOUT]
+AUTHORIZATION=sk_test_9b5e771c-5a3f-4a8d-a4da-31b19bd43d83
+URL=https://api.sandbox.checkout.com/hosted-payments
+H5=http://test.chathot.me/action/hiloHtml/22_05_30_recharge/topup.html
+HILO_SECRET_KEY=sk_test_dfbaa3b6-135d-4376-9996-2089b7d8a086
+[MATCH]
+MATCH_FREE_TIME=60
+MATCH_FREE_TIME_VIP=300
+MATCH_ADD_TIME_FREE=90
+MATCH_AGORA_TIME=30
+MATCH_CYCLE=8
+MATCH_USER_EXPIRES=480
+MATCH_SUCCESS_WAIT_DURATION=10
+MATCH_SUCCESS_SINGLE_WAIT_TIME_IN_SEC=12
+MATCH_SUCCESS_DUAL_WAIT_TIME_IN_SEC=15
+[ONLINE]
+ONLINE_CYCLE=600
+ONLINE_USER_EXPIRES=259200
+[VIDEO]
+VIDEO_DAILY_FREE_NUM=20
+VIDEO_FREE_TIME=60
+VIDEO_FREE_TIME_VIP=300
+VIDEO_ADD_TIME_FREE=60
+VIDEO_AGORA_TIME=30
+VIDEO_MINUTE_NORMAL=1000
+VIDEO_MINUTE_UNION=2000
+[SESSION]
+SESSION_DAILY_FREE_NUM=50
+[BEAN]
+DIAMOND_BEAN_RATE=90
+[H5]
+USER_LEVEL=http://test.chathot.me/action/activityhtml/hiloUserLevel/index.html
+GROUP_SUPPORT=http://test.chathot.me/action/activityhtml/21_12_06/page.html
+LUCKY_WHEEL=https://h5.whoisamy.shop/action/activityhtml/21_12_30/page.html
+NOBLE_BUY_IOS=https://h5.whoisamy.shop/action/hiloHtml/lxt_h5/page.html
+[GROUPIM]
+MSG_SORT_EXPIRE=43200
+MSG_SORT_SNAP=300
+[GRADE]
+CHARM_SPEED_VIP=15
+ACTITY_SPEED_VIP=15
+WEALTH_SPEED_VIP=15
+[LIKE]
+I_LIKE_NUM=30
+I_LIKE_NUM_VIP=100
+I_LIKE_NUM_NOBLE=1000
+[APPLEPAY]
+PASSWORD=38702750a05c4cb09c9d6ca646835634
+[REGISTER]
+IMEI_TOTAL=3
+IMEI_OAUTH=2
+ACCOUNT_IP=100
+ACCOUNT_IP_DURATION=21600
+[BANNER]
+GIFT_BANNER_LEVEL1=100
+GIFT_BANNER_LEVEL2=2000
+GIFT_BANNER_LEVEL3=5000
+[DIAMOND]
+DAILY_LOGIN_IMEI_LIMIT=200
+DAILY_LOGIN_IP_LIMIT=5
+PRIVATE_GIFT_RETURN=1440
+NEW_USER_INVITE_AWARD=5000
+[LUCKY_WHEEL]
+MINIMAL_PARTICIPANT=2
+WAIT_TIMELONG=10
+WINNER_DIAMOND_BANNER=100
+[GROUP_CUSTOM_THEME]
+PIC_LIMIT=5
+DAY=10
+[GIFT]
+WALL_DIAMOND=10
+[DAILY]
+LOGIN_COMMON=5
+LOGIN_VIP=300
+[DAILY]
+LOGIN_COMMON=5
+LOGIN_VIP=300
+[FRUIT_TYCOON]
+POOL_RATIO=20
+WATERMELON_RATIO=70
+[ACTIVITY]
+COUNTRY_STAR_POOL_RATIO=20
+COUNTRY_STAR_ORDINARY_RATIO=20
+[PAYER_MAX]
+URL=https://pay-gate-uat.payermax.com/aggregate-pay-gate/api/gateway
+KEY=d50d149a883b8bb6
+MERCHANT_ID=SP11018326
+BIZ_TYPE=CUSTOMIZE
+VERSION=2.3
+FRONT_CALLBACK_URL=https://www.hiloconn.com
+SHOW_RESULT=1
+EXPIRE_TIME=1800
+LANGUAGE=en
+[SUD]
+API_LIST=https://sim-asc.sudden.ltd
+[URL]
+BIZ_HTTP=https://test.apiv1.faceline.live
\ No newline at end of file