video_course/service/user.go

/**
 * @ File:
 * @ Date: 2021/1/25 10:07
 * @ Author: JYQ
 * @ Description:
 */
package service

import (
	"video_course/errors"
	"video_course/lib/session"
	"video_course/model"
	h "video_course/repository/http"
)

type User struct {
	base
}

//查询用户身体数据
func (u User) UserSelfQuery(
	token string) (userBodyInfo *model.UserBodyInfo, err error) {
	sm := session.GetSessionManager()
	sess, err_ := sm.FindByToken(token)
	if err_ != nil {
		err = err_
		return
	}
	userMd5 := sess.UserId
	var rtnCode int
	//首先查询心率系统，如果查询失败查询小飞龙系统
	rtnCode, userBodyInfo = h.HeartRateServer{}.VipUserQueryByUserMd5(userMd5)
	if rtnCode != 0 {
		rtnCode, userBodyInfo = h.LoalloutServer{}.VipUserQueryByUserMd5("73c845ca89d952074b36a5b18d961cac", userMd5)
		if rtnCode != 0 {
			err = errors.ErrUserNotExists
		}
	}

	return
}

//查询用户是否正在上课接口
func (u User) GetDuInfoAndUserInfoByUserMd5(
	token string) (inClass int, duInfo *model.DuInfo, userBodyInfo *model.UserBodyInfo, err error) {
	sm := session.GetSessionManager()
	sess, err_ := sm.FindByToken(token)
	if err_ != nil {
		err = err_
		return
	}
	userMd5 := sess.UserId

	//查询心率系统
	inClass, duInfo, userBodyInfo, err = h.HeartRateServer{}.GetDuInfoAndUserInfoByUserMd5(userMd5)

	return
}