package cp_r import ( "fmt" "git.hilo.cn/hilo-common/domain" "git.hilo.cn/hilo-common/mycontext" "git.hilo.cn/hilo-common/resource/mysql" "github.com/gin-gonic/gin" "github.com/jinzhu/now" "hilo-user/_const/enum/cp_e" "hilo-user/cv/cp_cv" "hilo-user/cv/user_cv" "hilo-user/domain/model/cp_m" "hilo-user/domain/model/user_m" "hilo-user/myerr/bizerr" "hilo-user/req" "hilo-user/resp" "time" ) // @Tags CP v2 // @Summary 排行榜 // @Param token header string true "token" // @Param nonce header string true "随机数字" // @Param pageIndex query int true "偏移值 默认:1" default(1) // @Param pageSize query int true "请求数量 默认:10" default(10) // @Param queryType path string true "类型:day/week/month" // @Success 200 {object} []cp_cv.CvCp // @Router /v2/cp/rank/{queryType} [get] func CpRank(c *gin.Context) (*mycontext.MyContext, error) { myCtx := mycontext.CreateMyContext(c.Keys) userId, err := req.GetUserId(c) if err != nil { return myCtx, err } pageReq := new(req.PageReqBase) if err := c.ShouldBindQuery(pageReq); err != nil { return myCtx, err } if pageReq.PageIndex == 0 { pageReq.PageIndex = 1 } queryType := c.Param("queryType") if queryType != "day" && queryType != "week" && queryType != "month" { return myCtx, bizerr.InvalidParameter } var beginDate, endDate string switch queryType { case "day": beginDate, endDate = time.Now().Format("2006-01-02"), time.Now().Format("2006-01-02") case "week": beginDate = now.BeginningOfWeek().Format("2006-01-02") endDate = now.EndOfWeek().Format("2006-01-02") case "month": beginDate = now.BeginningOfMonth().Format("2006-01-02") endDate = now.EndOfMonth().Format("2006-01-02") } offset, limit := (pageReq.PageIndex-1)*pageReq.PageSize, pageReq.PageSize model := domain.CreateModelContext(myCtx) ranks := cp_m.PageCpDayRank(model, beginDate, endDate, offset, limit) var response []cp_cv.CvCp var userIds []mysql.ID var cpIds []mysql.ID for _, rank := range ranks { userIds = append(userIds, rank.UserId1) userIds = append(userIds, rank.UserId2) cpIds = append(cpIds, rank.CpId) } userBase, err := user_cv.GetUserBaseMap(userIds, userId) if err != nil { return myCtx, err } cpLevels := cp_m.MGetCpLevel(model, cpIds) for i, rank := range ranks { response = append(response, cp_cv.CvCp{ CpId: rank.CpId, User1: userBase[rank.UserId1], User2: userBase[rank.UserId2], Score: rank.Score, Ranking: fmt.Sprintf("%d", i+1+offset), CpLevel: cp_cv.CvCpLevel{ Level: cpLevels[rank.CpId].Level, //Points: cp_e.CpLevelPoints[cpLevel] + curPoints, //EndPoints: nextPoints, //RemainPoints: remainPoints, //ExpireAtUnix: expireAtUnix, }, }) } resp.ResponsePageBaseOk(c, response, pageReq.PageIndex+1, len(ranks) >= pageReq.PageSize) return myCtx, nil } // @Tags CP v2 // @Summary CP,Top3 // @Param token header string true "token" // @Param nonce header string true "随机数字" // @Success 200 {object} cp_cv.CpTops // @Router /v2/cp/top3 [get] func CpTop3(c *gin.Context) (*mycontext.MyContext, error) { myCtx := mycontext.CreateMyContext(c.Keys) userId, err := req.GetUserId(c) if err != nil { return myCtx, err } var response = cp_cv.CpTops{ Day: make([]cp_cv.CvCp, 0), Week: make([]cp_cv.CvCp, 0), } queryTypes := []string{"day", "week"} for _, queryType := range queryTypes { var beginDate, endDate string switch queryType { case "day": beginDate, endDate = time.Now().Format("2006-01-02"), time.Now().Format("2006-01-02") case "week": beginDate = now.BeginningOfWeek().Format("2006-01-02") endDate = now.EndOfWeek().Format("2006-01-02") } offset, limit := 0, 3 model := domain.CreateModelContext(myCtx) ranks := cp_m.PageCpDayRank(model, beginDate, endDate, offset, limit) var userIds []mysql.ID var cpIds []mysql.ID for _, rank := range ranks { userIds = append(userIds, rank.UserId1) userIds = append(userIds, rank.UserId2) cpIds = append(cpIds, rank.CpId) } userBase, err := user_cv.GetUserBaseMap(userIds, userId) if err != nil { return myCtx, err } cpLevels := cp_m.MGetCpLevel(model, cpIds) for i, rank := range ranks { if queryType == "day" { response.Day = append(response.Day, cp_cv.CvCp{ CpId: rank.CpId, User1: userBase[rank.UserId1], User2: userBase[rank.UserId2], Score: rank.Score, Ranking: fmt.Sprintf("%d", i+1+offset), CpLevel: cp_cv.CvCpLevel{ Level: cpLevels[rank.CpId].Level, }, }) } else { response.Week = append(response.Week, cp_cv.CvCp{ CpId: rank.CpId, User1: userBase[rank.UserId1], User2: userBase[rank.UserId2], Score: rank.Score, Ranking: fmt.Sprintf("%d", i+1+offset), CpLevel: cp_cv.CvCpLevel{ Level: cpLevels[rank.CpId].Level, }, }) } } } resp.ResponseOk(c, response) return myCtx, nil } // @Tags CP v2 // @Summary 我的cp // @Param token header string true "token" // @Param nonce header string true "随机数字" // @Param queryType path string true "类型:day/week/month" // @Success 200 {object} cp_cv.CvCp // @Router /v2/cp/my/{queryType} [get] func CpMy(c *gin.Context) (*mycontext.MyContext, error) { myCtx := mycontext.CreateMyContext(c.Keys) userId, err := req.GetUserId(c) if err != nil { return myCtx, err } queryType := c.Param("queryType") if queryType != "day" && queryType != "week" && queryType != "month" { return myCtx, bizerr.InvalidParameter } var beginDate, endDate string switch queryType { case "day": beginDate, endDate = time.Now().Format("2006-01-02"), time.Now().Format("2006-01-02") case "week": beginDate = now.BeginningOfWeek().Format("2006-01-02") endDate = now.EndOfWeek().Format("2006-01-02") case "month": beginDate = now.BeginningOfMonth().Format("2006-01-02") endDate = now.EndOfMonth().Format("2006-01-02") } model := domain.CreateModelContext(myCtx) relation, exits := cp_m.GetCpRelation(model, userId) var userIds []mysql.ID var scores uint32 if exits { // 保证一下自己是userId1 userIds = append(userIds, userId) if relation.UserId1 == userId { userIds = append(userIds, relation.UserId2) } else { userIds = append(userIds, relation.UserId1) } rank := cp_m.GetCpDayRank(model, beginDate, endDate, relation.ID) scores = rank.Score } else { userIds = append(userIds, userId) relation.UserId1 = userId } userBases, err := user_cv.GetUserBaseMap(userIds, userId) if err != nil { return myCtx, err } response := cp_cv.CvCp{ CpId: relation.ID, Score: scores, } if relation.UserId1 > 0 { response.User1 = userBases[relation.UserId1] } if relation.UserId2 > 0 { response.User2 = userBases[relation.UserId2] response.Ranking = "99+" } resp.ResponseOk(c, response) return myCtx, nil } // @Tags CP v2 // @Summary 成就页 // @Param token header string true "token" // @Param nonce header string true "随机数字" // @Success 200 {object} []cp_cv.CvCpAchievement // @Router /v2/cp/achievement [get] func CpAchievement(c *gin.Context) (*mycontext.MyContext, error) { myCtx := mycontext.CreateMyContext(c.Keys) userId, err := req.GetUserId(c) if err != nil { return myCtx, err } model := domain.CreateModelContext(myCtx) relation, exits := cp_m.GetCpRelation(model, userId) var response = make([]cp_cv.CvCpAchievement, 0) TypeDescMap := map[cp_e.CpAchievement]string{ // todo 翻译 cp_e.CpAchievementLevel: "等级分值最高", cp_e.CpAchievementVisitors: "空间访问量最高", cp_e.CpAchievementMonthRank: "月榜最高", cp_e.CpAchievementWeekRank: "周榜最高", cp_e.CpAchievementDayRank: "天榜最高", } if exits { users, err := user_m.GetUserMapByIds(model, []mysql.ID{relation.UserId1, relation.UserId2}) if err != nil { return myCtx, err } achievements := cp_m.GetCpAchievements(model, relation.ID) for _, a := range achievements { response = append(response, cp_cv.CvCpAchievement{ CpId: a.CpId, User1: user_cv.UserToTiny(users[a.UserId1]), User2: user_cv.UserToTiny(users[a.UserId2]), Type: a.Type, TypeDesc: TypeDescMap[a.Type], Score: a.Score, TimeUnix: a.UpdatedTime.Unix(), }) } } else { } resp.ResponsePageBaseOk(c, response, 0, false) return myCtx, nil }