package cp_r import ( "git.hilo.cn/hilo-common/domain" "git.hilo.cn/hilo-common/mycontext" "git.hilo.cn/hilo-common/resource/mysql" "github.com/gin-gonic/gin" "hilo-user/_const/enum/cp_e" "hilo-user/cv/cp_cv" "hilo-user/cv/user_cv" "hilo-user/domain/event/cp_ev" "hilo-user/domain/model/cp_m" "hilo-user/domain/model/user_m" "hilo-user/myerr/bizerr" "hilo-user/req" "hilo-user/resp" ) // @Tags CP v2 // @Summary cp空间 // @Param token header string true "token" // @Param nonce header string true "随机数字" // @Param externalId query string true "查看用户的externalId" // @Success 200 {object} cp_cv.CvSpace // @Router /v2/cp/space [get] func CpSpace(c *gin.Context) (*mycontext.MyContext, error) { myContext := mycontext.CreateMyContext(c.Keys) userId, lang, err := req.GetUserIdLang(c, myContext) if err != nil { return myContext, err } externalId := c.Query("externalId") if len(externalId) <= 0 { return myContext, bizerr.InvalidParameter } var model = domain.CreateModelContext(myContext) userInfo, err := user_m.GetUser(model, userId) if err != nil { return myContext, err } cpUserInfo, err := user_m.GetUserByExtId(model, externalId) if err != nil { return myContext, err } expireAtUnix, cpLevel := int64(0), cp_e.CpLevel0 nextPoints, remainPoints, curPoints := cp_e.CpLevelPoints[cp_e.CpLevel1], mysql.Num(0), mysql.Num(0) cpRelation, exists := cp_m.GetCpRelation(model, cpUserInfo.ID) if exists { level := cp_m.GetCpLevel(model, cpRelation.ID) cpLevel, curPoints = level.Level, level.Points expireAtUnix = level.ExpireAt.Unix() // cp 存在的时候,发布访问cp空间事件 if err := cp_ev.PublishCpSpaceVisit(model, &cp_ev.SpaceVisitEvent{ UserId: userId, CpId: cpRelation.ID, UserId1: cpRelation.UserId1, UserId2: cpRelation.UserId2, }); err != nil { return myContext, err } } if cpLevel != cp_e.CpLevelMax { nextPoints = cp_e.CpLevelPoints[cpLevel+1] remainPoints = nextPoints - cp_e.CpLevelPoints[cpLevel] - curPoints } privilegeList := cp_cv.CopyCpLevelPrivilegeList(cpLevel, lang) userPrivileges, err := cp_m.MGetUserSvipPrivilege(model, []uint64{userId}) if err != nil { return myContext, err } for i, v := range privilegeList { if v.CanSwitch { privilegeList[i].UserSwitch = userPrivileges[userId][v.Type] } } response := cp_cv.CvSpace{ CpInfo: cp_cv.CvCpInfo{ UserInfo: user_cv.UserToTiny(*userInfo), CpUserInfo: user_cv.UserToTiny(*cpUserInfo), }, CpLevel: cp_cv.CvCpLevel{ Level: cpLevel, Points: cp_e.CpLevelPoints[cpLevel] + curPoints, NextPoints: nextPoints, RemainPoints: remainPoints, ExpireAtUnix: expireAtUnix, }, ResLevelList: cp_cv.CvResLevelList, PrivilegeList: privilegeList, } resp.ResponseOk(c, response) return myContext, nil } type CpPrivilegeOpenCloseReq struct { Type cp_e.CpPrivilege `form:"type" binding:"required"` OpenClose mysql.OpenClose `form:"openClose" binding:"required"` } // @Tags CP v2 // @Summary cp特权开关 // @Param token header string true "token" // @Param nonce header string true "随机数字" // @Param type formData int true "1.空间 2.横幅 3.等级勋章 4.证书 5.进场特效 6.头像头饰 7.动态资料卡 8.麦位特效" // @Param openClose formData int true "1:open 2:close" // @Success 200 // @Router /v2/cp/privilege/openClose [put] func CpPrivilegeOpenClose(c *gin.Context) (*mycontext.MyContext, error) { myCtx := mycontext.CreateMyContext(c.Keys) var request CpPrivilegeOpenCloseReq if err := c.ShouldBind(&request); err != nil { return myCtx, err } userId, err := req.GetUserId(c) if err != nil { return myCtx, err } var model = domain.CreateModelContext(myCtx) if err := cp_m.OpenCLoseUserSvipPrivilege(model, userId, request.Type, request.OpenClose); err != nil { return myCtx, err } resp.ResponseOk(c, "") return myCtx, nil }