space.go

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
	visitTimes := int64(0)
	cpDays, applyToUnbind := 0, false // todo cp时长
	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
		}
		visitTimes = cp_m.CountCpSpaceVisitors(model, cpRelation.ID)
		cpUserId := cpRelation.UserId2
		if cpUserId == userId {
			cpUserId = cpRelation.UserId1
		}
		applyToUnbind = cp_m.GetApplyToUnbind(model, userId, cpUserId)
	}
	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),
			VisitTimes:    visitTimes,
			CpDays:        cpDays,
			ApplyToUnbind: applyToUnbind,
		},
		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
}