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" "time" ) // @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 } targetUserInfo, err := user_m.GetUserByExtId(model, externalId) if err != nil { return myContext, err } var cpUserInfo *user_m.User expireAtUnix, cpLevel := int64(0), cp_e.CpLevel0 visitTimes := int64(0) settlementDate, cpDays, applyToUnbind := "", 0, false nextPoints, curPoints := cp_e.CpLevelPoints[cp_e.CpLevel1], mysql.Num(0) cpRelation, exists := cp_m.GetCpRelation(model, targetUserInfo.ID) if exists { level := cp_m.GetCpLevel(model, cpRelation.ID) cpLevel, curPoints = level.Level, level.Points expireAtUnix, settlementDate = level.ExpireAt.Unix(), level.ExpireAt.Format("2006-01-02") cpDays = int(time.Now().Sub(cpRelation.CreatedTime).Hours()/24) + 1 // 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 } visitTimes = cp_m.CountCpSpaceVisitors(model, cpRelation.ID) cpUserId := cpRelation.UserId2 if cpUserId == userId { cpUserId = cpRelation.UserId1 } applyToUnbind = cp_m.GetApplyToUnbind(model, userId, cpUserId) cpUserInfo, err = user_m.GetUser(model, cpUserId) if err != nil { return myContext, err } } if cpLevel != cp_e.CpLevelMax { nextPoints = cp_e.CpLevelPoints[cpLevel+1] } else { nextPoints = cp_e.CpLevelPoints[cp_e.CpLevelMax] } userPrivileges, err := cp_m.MGetUserSvipPrivilege(model, []uint64{userId}) if err != nil { return myContext, err } allPrivilegeList := make([][]cp_cv.CvPrivilege, cp_e.CpLevelMax+1) for level := cp_e.CpLevel0; level <= cp_e.CpLevelMax; level++ { privilegeList := cp_cv.CopyCpLevelPrivilegeList(level, lang) for i, v := range privilegeList { if v.CanSwitch { privilegeList[i].UserSwitch = userPrivileges[userId][v.Type] } } allPrivilegeList[level] = privilegeList } // 返回值 response := cp_cv.CvSpace{ CpLevel: cp_cv.CvCpLevel{ Level: cpLevel, Points: cp_e.CpLevelPoints[cpLevel] + curPoints, StartPoints: cp_e.CpLevelPoints[cpLevel], EndPoints: nextPoints, ExpireAtUnix: expireAtUnix, SettlementDate: settlementDate, }, ResLevelList: cp_cv.CvResLevelList, PrivilegeList: allPrivilegeList, } response.CpInfo = cp_cv.CvCpInfo{ UserInfo: user_cv.UserToTiny(*userInfo), CpDays: cpDays, VisitTimes: visitTimes, ApplyToUnbind: applyToUnbind, } if cpUserInfo != nil { response.CpInfo.CpUserInfo = user_cv.UserToTiny(*cpUserInfo) } 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 }