From 711aa91580d92c4facf42c57c07a5c3ef3032225 Mon Sep 17 00:00:00 2001 From: chenweijian <820961417@qq.com> Date: Mon, 24 Apr 2023 15:55:06 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=B6=E6=97=8F=E6=9C=88=E5=BA=A6=E6=B4=BB?= =?UTF-8?q?=E5=8A=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cron/cron.go | 1 + cron/group_cron/group_power_month_act.go | 22 ++ cv/group_power_cv/group_rank.go | 14 +- domain/model/groupPower_m/groupPower.go | 30 ++ domain/model/groupPower_m/group_rank.go | 11 +- domain/model/groupPower_m/group_star.go | 4 +- domain/service/group_power_s/group_power.go | 287 ++++++++++++++++++++ mysql/group_power_month_act.sql | 15 + route/group_power_r/group_rank.go | 132 ++++----- route/router.go | 1 + test/group_power_test.go | 12 + 11 files changed, 442 insertions(+), 87 deletions(-) create mode 100644 cron/group_cron/group_power_month_act.go create mode 100644 mysql/group_power_month_act.sql diff --git a/cron/cron.go b/cron/cron.go index 9fd7f65..181ba0b 100644 --- a/cron/cron.go +++ b/cron/cron.go @@ -15,4 +15,5 @@ func Init() { gift_cron.GiftRemark() // 礼物消息补偿 mic_cron.OnMicCheck() // 检查上麦 group_cron.GroupPowerExpClear() // 清理家族经验/等级 + group_cron.GroupPowerMonthRankAct() } diff --git a/cron/group_cron/group_power_month_act.go b/cron/group_cron/group_power_month_act.go new file mode 100644 index 0000000..82edee6 --- /dev/null +++ b/cron/group_cron/group_power_month_act.go @@ -0,0 +1,22 @@ +package group_cron + +import ( + "git.hilo.cn/hilo-common/domain" + "github.com/robfig/cron" + "hilo-group/domain/service/group_power_s" +) + +// 家族贡献月度排行榜发奖 +func GroupPowerMonthRankAct() { + c := cron.New() + // 每月1号0:01结算发奖 + spec := "0 1 0 1 * ?" + _ = c.AddFunc(spec, func() { + var model = domain.CreateModelNil() + if err := group_power_s.CalcGroupPowerMonthRankAct(model); err != nil { + model.Log.Errorf("GroupPowerMonthRankAct fail:%v", err) + } + }) + + c.Start() +} diff --git a/cv/group_power_cv/group_rank.go b/cv/group_power_cv/group_rank.go index 746aeef..eed7351 100644 --- a/cv/group_power_cv/group_rank.go +++ b/cv/group_power_cv/group_rank.go @@ -40,10 +40,20 @@ type CvGroupPowerRank struct { Items []CvGroupPowerRankData `json:"items"` // 列表 } +// 家族月度排行活动榜单 +type CvGroupPowerRankMontAct struct { + MyGroupPower *CvGroupPowerRankData `json:"myGroupPower"` // 我的家族排名 + Items []CvGroupPowerRankData `json:"items"` // 列表 + MyGroupPowerLast *CvGroupPowerRankData `json:"myGroupPowerLast"` // 我的家族排名(上月) + ItemsLast []CvGroupPowerRankData `json:"itemsLast"` // 列表(上月) + LeftSecond int64 `json:"leftSecond"` // 活动倒计时 +} + type CvGroupPowerRankData struct { CvGroupPowerBase `json:",inline"` CvGroupPowerGrade `json:",inline"` - Rank int `json:"rank"` // 排名 + Rank int `json:"rank"` // 排名 + StarList []*CvGroupPowerStarData `json:"starList"` // 家族贡献top10 } // 家族之星 @@ -108,6 +118,6 @@ var GroupPowerGradePrivilegeNum = map[groupPower_e.GroupPowerGrade][]CvPrivilege {groupPower_e.GroupPowerPrivilegeNameplate, 1, "https://image.whoisamy.shop/hilo/resource/family/nameplate_yellow.png"}, {groupPower_e.GroupPowerPrivilegeMedal, 1, "https://image.whoisamy.shop/hilo/resource/family/privilege_yellow.png"}, {groupPower_e.GroupPowerPrivilegeNameplateEdit, 1, "https://image.whoisamy.shop/hilo/resource/family/edit_yellow.png"}, - {groupPower_e.GroupPowerPrivilegeNameplateHeadwear, 1,"https://image.whoisamy.shop/hilo/resource/family/headwear_yellow.png"}, + {groupPower_e.GroupPowerPrivilegeNameplateHeadwear, 1, "https://image.whoisamy.shop/hilo/resource/family/headwear_yellow.png"}, }, } diff --git a/domain/model/groupPower_m/groupPower.go b/domain/model/groupPower_m/groupPower.go index 644c089..d78decb 100644 --- a/domain/model/groupPower_m/groupPower.go +++ b/domain/model/groupPower_m/groupPower.go @@ -43,6 +43,16 @@ type GroupPowerUser struct { Role groupPower_e.GroupPowerUserRole } +type ActFamilyMonthRankLog struct { + Id uint64 `json:"id"` + Period string `json:"period"` + FamilyId uint64 `json:"family_id"` + RankFamily int `json:"rank_family"` + RankUser int `json:"rank_user"` + UserId uint64 `json:"user_id"` + Award string `json:"award"` +} + func (gpu *GroupPowerUser) Get(db *gorm.DB) ([]GroupPowerUser, error) { rows := make([]GroupPowerUser, 0) err := db.Where(gpu).Find(&rows).Error @@ -64,6 +74,22 @@ func GetPowerOwner(db *gorm.DB, powerId uint64) (uint64, error) { return records[0].UserId, nil } +func GetPowerOwnerMap(model *domain.Model, powerIds []uint64) (map[uint64]uint64, error) { + rows := make([]GroupPowerUser, 0) + if len(powerIds) > 0 { + if err := model.DB().Model(&GroupPowerUser{}). + Where("group_power_id IN ? and role = ?", powerIds, groupPower_e.GroupPowerUserRoleMgr). + Find(&rows).Error; err != nil { + return nil, err + } + } + result := make(map[uint64]uint64, 0) + for _, i := range rows { + result[i.GroupPowerId] = i.UserId + } + return result, nil +} + func GetMyPowerId(db *gorm.DB, userId uint64) (uint64, error) { gpu := GroupPowerUser{UserId: userId, Role: groupPower_e.GroupPowerUserRoleMgr} records, err := gpu.Get(db) @@ -707,3 +733,7 @@ func BatchGetGroupPowerUser(model *domain.Model, userIds []mysql.ID) (map[mysql. } return res, nil } + +func CreateActFamilyMonthRankLog(model *domain.Model, list []*ActFamilyMonthRankLog) error { + return model.DB().CreateInBatches(&list, 50).Error +} diff --git a/domain/model/groupPower_m/group_rank.go b/domain/model/groupPower_m/group_rank.go index 1d18512..2185357 100644 --- a/domain/model/groupPower_m/group_rank.go +++ b/domain/model/groupPower_m/group_rank.go @@ -4,6 +4,7 @@ import ( "git.hilo.cn/hilo-common/domain" "git.hilo.cn/hilo-common/resource/mysql" "gorm.io/gorm" + "hilo-group/_const/enum/groupPower_e" ) type GroupPowerExpRank struct { @@ -14,10 +15,14 @@ type GroupPowerExpRank struct { // 获取家族经验排行榜 // param limit: 排行榜人数 -func GetGroupPowerExpRank(model *domain.Model, beginDate, endDate string, limit int) ([]GroupPowerExpRank, error) { +func GetGroupPowerExpRank(model *domain.Model, beginDate, endDate string, limit int, gpStatus groupPower_e.GroupPowerStatus) ([]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 { + db := model.DB().Table("group_power_day_exp gpd").Select("gpd.group_power_id,SUM(gpd.exp) as exp"). + Where("gpd.date BETWEEN ? AND ?", beginDate, endDate) + if gpStatus > 0 { + db = db.Joins("left join group_power gp on gpd.group_power_id = gp.id").Where("status = ?", gpStatus) + } + if err := db.Group("gpd.group_power_id").Order("exp DESC").Limit(limit).Find(&res).Error; err != nil { model.Log.Errorf("GetGroupPowerExpRank fail:%v", err) return res, err } diff --git a/domain/model/groupPower_m/group_star.go b/domain/model/groupPower_m/group_star.go index 1929399..ee52a2b 100644 --- a/domain/model/groupPower_m/group_star.go +++ b/domain/model/groupPower_m/group_star.go @@ -104,9 +104,9 @@ func GetGroupPowerMonthStar(model *domain.Model, groupPowerId, userId mysql.ID, } // 获取家族之星排行 -func GetGroupPowerMonthStarRank(model *domain.Model, groupPowerId mysql.ID, _type groupPower_e.GroupPowerStarType, offset, limit int) ([]*GroupPowerMonthStar, error) { +func GetGroupPowerMonthStarRank(model *domain.Model, groupPowerId mysql.ID, _type groupPower_e.GroupPowerStarType, offset, limit int, month string) ([]*GroupPowerMonthStar, error) { var res []*GroupPowerMonthStar - month := time.Now().Format("200601") + //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) diff --git a/domain/service/group_power_s/group_power.go b/domain/service/group_power_s/group_power.go index cef2684..fc8f7f3 100644 --- a/domain/service/group_power_s/group_power.go +++ b/domain/service/group_power_s/group_power.go @@ -1,11 +1,23 @@ package group_power_s import ( + "encoding/json" + "git.hilo.cn/hilo-common/_const/enum/diamond_e" "git.hilo.cn/hilo-common/domain" "git.hilo.cn/hilo-common/mycontext" "git.hilo.cn/hilo-common/resource/mysql" + "git.hilo.cn/hilo-common/txop/award_tx" + "git.hilo.cn/hilo-common/utils" + "github.com/jinzhu/now" + "hilo-group/_const/enum/groupPower_e" + "hilo-group/_const/enum/msg_e" + "hilo-group/cv/group_power_cv" + "hilo-group/cv/user_cv" "hilo-group/domain/event/group_power_ev" "hilo-group/domain/model/groupPower_m" + "hilo-group/domain/model/user_m" + "hilo-group/myerr/bizerr" + "time" ) type GroupPowerService struct { @@ -66,3 +78,278 @@ func (s *GroupPowerService) GroupPowerUserLeave(groupPowerId mysql.ID, userId my }) return remainSeconds, err } + +func GetGroupPowerRankResp(model *domain.Model, beginDate, endDate string, userId uint64, gpStatus groupPower_e.GroupPowerStatus) (response group_power_cv.CvGroupPowerRank, err error) { + rank, err := groupPower_m.GetGroupPowerExpRank(model, beginDate, endDate, 30, gpStatus) + if err != nil { + return + } + var ids []mysql.ID + for _, g := range rank { + ids = append(ids, g.GroupPowerId) + } + var myGroupPower *groupPower_m.GroupPowerUser + if userId > 0 { + myGroupPower, err = groupPower_m.GetGroupPowerUserOrNil(model, userId) + if err != nil { + return + } + } + if myGroupPower != nil { + ids = append(ids, myGroupPower.GroupPowerId) + } + grades, err := groupPower_m.MGetGroupPowerGrade(model, ids) + if err != nil { + return + } + groupPowers, err := groupPower_m.MGetGroupPowerInfoMap(model, ids) + if err != nil { + return + } + if myGroupPower != nil { + myGroupPowerRank, err := groupPower_m.GetMyGroupPowerExpRank(model, beginDate, endDate, myGroupPower.GroupPowerId) + if err != nil { + return response, err + } + response.MyGroupPower = &group_power_cv.CvGroupPowerRankData{ + CvGroupPowerBase: group_power_cv.CvGroupPowerBase{ + Id: 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: myGroupPowerRank.Exp, + }, + Rank: 0, + } + } + for _, v := range rank { + if response.MyGroupPower != nil && v.GroupPowerId == response.MyGroupPower.Id { + response.MyGroupPower.Rank = v.Rank + } + response.Items = append(response.Items, group_power_cv.CvGroupPowerRankData{ + CvGroupPowerBase: group_power_cv.CvGroupPowerBase{ + Id: 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+ + } + return response, nil +} + +func GetGroupPowerStar(model *domain.Model, groupPowerId mysql.ID, _type groupPower_e.GroupPowerStarType, offset, limit int, month string) ([]*group_power_cv.CvGroupPowerStarData, error) { + rank, err := groupPower_m.GetGroupPowerMonthStarRank(model, groupPowerId, _type, offset, limit, month) + if err != nil { + return nil, err + } + //var response []group_power_cv.CvGroupPowerStarData + response := make([]*group_power_cv.CvGroupPowerStarData, 0) + 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] + score := row.Score + if _type == groupPower_e.GroupPowerStarTypeActive { + score = score / 60 + } + if score <= 0 { + continue + } + 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: score, + }) + } + return response, nil +} + +func CalcGroupPowerMonthRankAct(model *domain.Model) error { + lastDayTime := time.Now().AddDate(0, 0, -1) + _now := now.New(lastDayTime) + calcMonth := _now.BeginningOfMonth().Format(utils.MONTH_FORMAT) + beginDate, endDate := _now.BeginningOfMonth().Format("2006-01-02"), _now.EndOfMonth().Format("2006-01-02") + return DoCalcGroupPowerMonthRankAct(model, calcMonth, beginDate, endDate) +} + +func DoCalcGroupPowerMonthRankAct(model *domain.Model, calcMonth, beginDate, endDate string) error { + // 计算获奖 + response, err := GetGroupPowerRankResp(model, beginDate, endDate, 0, groupPower_e.GroupPowerUserHas) + if err != nil { + return err + } + powerIds := make([]uint64, 0, len(response.Items)) + for i, v := range response.Items { + powerIds = append(powerIds, v.Id) + response.Items[i].StarList, err = GetGroupPowerStar(model, v.Id, groupPower_e.GroupPowerStarTypeFamous, 0, 10, time.Now().Format(utils.COMPACT_MONTH_FORMAT)) + if err != nil { + return err + } + } + // 奖励、日志 + awardList, logList, err := getAwardAndLogList(model, powerIds, response.Items, calcMonth) + if err != nil { + return err + } + + return model.Transaction(func(model *domain.Model) error { + // log + err = groupPower_m.CreateActFamilyMonthRankLog(model, logList) + if err != nil { + model.Log.Errorf("CalcGroupPowerMonthRankAct err:%+v", err) + return err + } + // award + for _, v := range awardList { + err = award_tx.SendUserAward(model, v, diamond_e.GeneralActivity, msg_e.MgrSendDiamondProperty) + if err != nil { + model.Log.Errorf("CalcGroupPowerMonthRankAct award:%+v, err:%+v", v, err) + return err + } + } + return nil + }) +} + +func getAwardAndLogList(model *domain.Model, powerIds []uint64, items []group_power_cv.CvGroupPowerRankData, calcMonth string) ([]*award_tx.UserAward, []*groupPower_m.ActFamilyMonthRankLog, error) { + // 读奖励配置 + confMap := CalcGroupPowerMonthRankActConf() + awardList := make([]*award_tx.UserAward, 0, 50) // 奖励 + ownerMap, err := groupPower_m.GetPowerOwnerMap(model, powerIds) + if err != nil { + return nil, nil, err + } + // log list + logList := make([]*groupPower_m.ActFamilyMonthRankLog, 0, 50) + for _, v := range items { + teamRank := 0 + if v.Rank >= 1 && v.Rank <= 3 { + teamRank = v.Rank + } else if v.Rank >= 4 && v.Rank <= 10 { + teamRank = 4 + } else { + break + } + ownerId, ok := ownerMap[v.Id] + if !ok || ownerId <= 0 { + model.Log.Errorf("CalcGroupPowerMonthRankAct 获取势力主错误 familyId:%d", v.Id) + return nil, nil, bizerr.InvalidParameter + } + uRankConfMap, tCOk := confMap[teamRank] + if !tCOk { + break + } + // 家族长奖励 + oAward, aOk := uRankConfMap[0] + if !aOk { + model.Log.Errorf("CalcGroupPowerMonthRankAct 配置错误:%v", confMap) + return nil, nil, bizerr.InvalidParameter + } + oAwardJ, _ := json.Marshal(oAward) + logList = append(logList, &groupPower_m.ActFamilyMonthRankLog{ + Period: calcMonth, + FamilyId: v.Id, + RankFamily: v.Rank, + RankUser: 0, + UserId: ownerId, + Award: string(oAwardJ), + }) + awardList = append(awardList, &award_tx.UserAward{ + UserId: ownerId, + MedalId: oAward.MedalId, + MedalDuration: oAward.MedalDay, + Diamond: oAward.Diamond, + NobleLevel: oAward.Noble, + NobleDuration: oAward.NobleDay, + HeaddressId: oAward.HeaddressId, + HeaddressDuration: oAward.HeaddressDay}) + // 家族成员奖励 + for i, m := range v.StarList { + uRank := i + 1 + confIdx := 9 + if uRank >= 1 && uRank <= 3 { + confIdx = 1 + } else if uRank >= 4 && uRank <= 10 { + confIdx = 4 + } + mAward, aOk := uRankConfMap[confIdx] + if !aOk { + break + } + mAwardJ, _ := json.Marshal(mAward) + logList = append(logList, &groupPower_m.ActFamilyMonthRankLog{ + Period: calcMonth, + FamilyId: v.Id, + RankFamily: v.Rank, + RankUser: uRank, + UserId: m.User.Id, + Award: string(mAwardJ), + }) + awardList = append(awardList, &award_tx.UserAward{ + UserId: m.User.Id, + MedalId: mAward.MedalId, + MedalDuration: mAward.MedalDay, + Diamond: mAward.Diamond, + NobleLevel: mAward.Noble, + NobleDuration: mAward.NobleDay, + HeaddressId: mAward.HeaddressId, + HeaddressDuration: mAward.HeaddressDay}) + } + } + return awardList, logList, nil +} + +// 奖励配置 +type awardConf struct { + MedalId uint64 + MedalDay uint32 + Diamond uint32 + Noble uint32 + NobleDay uint32 + HeaddressId uint64 + HeaddressDay int +} + +func CalcGroupPowerMonthRankActConf() map[int]map[int]*awardConf { + return map[int]map[int]*awardConf{ + 1: { + 0: {MedalId: 5211, MedalDay: 30, Diamond: 320000, Noble: 5, NobleDay: 15}, + 1: {MedalId: 5251, MedalDay: 30, Diamond: 120000, Noble: 5, NobleDay: 7, HeaddressId: 2121, HeaddressDay: 30}, + 4: {HeaddressId: 2121, HeaddressDay: 30}, + }, + 2: { + 0: {MedalId: 5221, MedalDay: 30, Diamond: 220000, Noble: 4, NobleDay: 15}, + 1: {MedalId: 5261, MedalDay: 30, Diamond: 100000, Noble: 4, NobleDay: 7, HeaddressId: 2131, HeaddressDay: 30}, + 4: {HeaddressId: 2131, HeaddressDay: 30}, + }, + 3: { + 0: {MedalId: 5231, MedalDay: 30, Diamond: 120000, Noble: 5, NobleDay: 5}, + 1: {MedalId: 5271, MedalDay: 30, Diamond: 70000, HeaddressId: 2141, HeaddressDay: 30}, + 4: {HeaddressId: 2141, HeaddressDay: 30}, + }, + 4: { + 0: {MedalId: 5241, MedalDay: 30}, + 1: {MedalId: 5281, MedalDay: 30, HeaddressId: 2151, HeaddressDay: 30}, + }, + } +} diff --git a/mysql/group_power_month_act.sql b/mysql/group_power_month_act.sql new file mode 100644 index 0000000..3722131 --- /dev/null +++ b/mysql/group_power_month_act.sql @@ -0,0 +1,15 @@ +CREATE TABLE `act_family_month_rank_log` ( + `id` bigint unsigned NOT NULL AUTO_INCREMENT COMMENT 'id', + `period` varchar(20) NOT NULL DEFAULT '' COMMENT '月份', + `family_id` bigint unsigned NOT NULL COMMENT '家族id', + `rank_family` int unsigned NOT NULL DEFAULT '0' COMMENT '家族排名', + `rank_user` int unsigned NOT NULL DEFAULT '0' COMMENT '用户在家族中的家族排名', + `user_id` bigint unsigned NOT NULL COMMENT 'id', + `award` varchar(500) NOT NULL DEFAULT '' COMMENT '获得的奖励', + `created_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP, + `updated_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + PRIMARY KEY (`id`), + UNIQUE KEY `period` (`period`,`family_id`,`rank_user`), + KEY `user_idx` (`user_id`) USING BTREE, + KEY `created_time` (`created_time`) USING BTREE +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='家族月度排行发奖日志'; \ No newline at end of file diff --git a/route/group_power_r/group_rank.go b/route/group_power_r/group_rank.go index 4705a24..555b98e 100644 --- a/route/group_power_r/group_rank.go +++ b/route/group_power_r/group_rank.go @@ -12,6 +12,7 @@ import ( "hilo-group/cv/user_cv" "hilo-group/domain/model/groupPower_m" "hilo-group/domain/model/user_m" + "hilo-group/domain/service/group_power_s" "hilo-group/myerr/bizerr" "hilo-group/req" "hilo-group/resp" @@ -46,72 +47,69 @@ func GroupPowerRank(c *gin.Context) (*mycontext.MyContext, error) { 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) + response, err := group_power_s.GetGroupPowerRankResp(model, beginDate, endDate, userId, 0) 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) + resp.ResponseOk(c, response) + return myContext, nil +} + +// @Tags 国家势力 +// @Summary 家族榜单-活动 +// @Success 200 {object} group_power_cv.CvGroupPowerRankMontAct +// @Router /v1/h5/groupPower/rank/month [get] +func GroupPowerMonthRankAct(c *gin.Context) (*mycontext.MyContext, error) { + myContext := mycontext.CreateMyContext(c.Keys) + userId, err := req.GetUserId(c) if err != nil { return myContext, err } - if myGroupPower != nil { - ids = append(ids, myGroupPower.GroupPowerId) - } - grades, err := groupPower_m.MGetGroupPowerGrade(model, ids) + var model = domain.CreateModelContext(myContext) + // 这个月 + beginDate, endDate := now.BeginningOfMonth().Format(utils.DATE_FORMAT), now.EndOfMonth().Format(utils.DATE_FORMAT) + response, err := GroupPowerMonthRankActByMonth(model, userId, beginDate, endDate, time.Now().Format(utils.COMPACT_MONTH_FORMAT)) if err != nil { return myContext, err } - groupPowers, err := groupPower_m.MGetGroupPowerInfoMap(model, ids) + // 上月 + lastMonthStart := utils.GetLastMonthStart(time.Now()) + lastTime := now.New(lastMonthStart) + beginDateLast, endDateLast := lastTime.BeginningOfMonth().Format(utils.DATE_FORMAT), lastTime.EndOfMonth().Format(utils.DATE_FORMAT) + responseLast, err := GroupPowerMonthRankActByMonth(model, userId, beginDateLast, endDateLast, lastMonthStart.Format(utils.COMPACT_MONTH_FORMAT)) if err != nil { return myContext, err } - if myGroupPower != nil { - myGroupPowerRank, err := groupPower_m.GetMyGroupPowerExpRank(model, beginDate, endDate, myGroupPower.GroupPowerId) - if err != nil { - return myContext, err - } - response.MyGroupPower = &group_power_cv.CvGroupPowerRankData{ - CvGroupPowerBase: group_power_cv.CvGroupPowerBase{ - Id: 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: myGroupPowerRank.Exp, - }, - Rank: 0, - } + + res := &group_power_cv.CvGroupPowerRankMontAct{ + MyGroupPower: response.MyGroupPower, + Items: response.Items, + MyGroupPowerLast: responseLast.MyGroupPower, + ItemsLast: responseLast.Items, + LeftSecond: now.EndOfMonth().Unix() - time.Now().Unix(), + } + resp.ResponseOk(c, res) + return myContext, nil +} + +func GroupPowerMonthRankActByMonth(model *domain.Model, userId uint64, beginDate, endDate, month string) (response group_power_cv.CvGroupPowerRank, err error) { + response, err = group_power_s.GetGroupPowerRankResp(model, beginDate, endDate, userId, groupPower_e.GroupPowerUserHas) + if err != nil { + return response, err } - for _, v := range rank { - if response.MyGroupPower != nil && v.GroupPowerId == response.MyGroupPower.Id { - response.MyGroupPower.Rank = v.Rank - } - response.Items = append(response.Items, group_power_cv.CvGroupPowerRankData{ - CvGroupPowerBase: group_power_cv.CvGroupPowerBase{ - Id: 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.StarList, err = group_power_s.GetGroupPowerStar(model, response.MyGroupPower.Id, groupPower_e.GroupPowerStarTypeFamous, 0, 10, month) } - if response.MyGroupPower != nil && response.MyGroupPower.Rank == 0 { - response.MyGroupPower.Rank = 31 // 客户端统一显示30+ + if err != nil { + return response, err } - resp.ResponseOk(c, response) - return myContext, nil + for i, v := range response.Items { + response.Items[i].StarList, err = group_power_s.GetGroupPowerStar(model, v.Id, groupPower_e.GroupPowerStarTypeFamous, 0, 10, month) + if err != nil { + return response, err + } + } + return response, nil } // @Tags 国家势力 @@ -135,7 +133,7 @@ func GroupPowerRankTop(c *gin.Context) (*mycontext.MyContext, error) { 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, 3) + rank, err := groupPower_m.GetGroupPowerExpRank(model, beginDate, endDate, 3, 0) if err != nil { return myContext, err } @@ -201,38 +199,12 @@ func GroupPowerStar(c *gin.Context) (*mycontext.MyContext, error) { 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) + var model = domain.CreateModelContext(myContext) + response, err := group_power_s.GetGroupPowerStar(model, param.GroupPowerId, param.Type, offset, limit, time.Now().Format(utils.COMPACT_MONTH_FORMAT)) 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] - score := row.Score - if param.Type == groupPower_e.GroupPowerStarTypeActive { - score = score / 60 - } - if score <= 0 { - continue - } - 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: score, - }) - } resp.ResponsePageBaseOk(c, response, 0, false) return myContext, nil } diff --git a/route/router.go b/route/router.go index f0910f9..5d58317 100644 --- a/route/router.go +++ b/route/router.go @@ -146,6 +146,7 @@ func InitRouter() *gin.Engine { h5GroupPower := v1.Group("/h5/groupPower") { h5GroupPower.GET("/grade/detail", wrapper(group_power_r.GroupPowerGradeDetail)) + h5GroupPower.GET("/rank/month", wrapper(group_power_r.GroupPowerMonthRankAct)) } charge := v1.Group("/charge") diff --git a/test/group_power_test.go b/test/group_power_test.go index c830099..d522d84 100644 --- a/test/group_power_test.go +++ b/test/group_power_test.go @@ -3,9 +3,13 @@ package test import ( "fmt" "git.hilo.cn/hilo-common/domain" + "git.hilo.cn/hilo-common/utils" + "github.com/jinzhu/now" "hilo-group/domain/model/groupPower_m" "hilo-group/domain/model/group_m" + "hilo-group/domain/service/group_power_s" "testing" + "time" ) func TestGetAllGroupPowerOwner(t *testing.T) { @@ -23,3 +27,11 @@ func TestIsUseTRTC(t *testing.T) { fmt.Println("true--------------") } } + +func TestDoCalcGroupPowerMonthRankAct(t *testing.T) { + lastDayTime := time.Now().AddDate(0, 0, -1) + _now := now.New(lastDayTime) + calcMonth := _now.BeginningOfMonth().Format(utils.MONTH_FORMAT) + beginDate, endDate := _now.BeginningOfMonth().Format("2006-01-02"), _now.EndOfMonth().Format("2006-01-02") + _ = group_power_s.DoCalcGroupPowerMonthRankAct(domain.CreateModelNil(), calcMonth, beginDate, endDate) +} -- 2.22.0