video_course/service/auth.go

package service

import (
	"math/rand"
	"strconv"
	"time"
	"video_course/errors"
	"video_course/global"
	"video_course/lib/session"
	"video_course/model"
	h "video_course/repository/http"
	rdb "video_course/repository/redis"
	"video_course/utils"
	"video_course/utils/short_msg"

	"github.com/mojocn/base64Captcha"
)

var store = base64Captcha.DefaultMemStore

type Auth struct {
	base
}

//
//func (a Auth) SignOut(session *model.Session) (logInfo string) {
//	user := a.getUser(session)
//	function.Session{}.Delete(session)
//	logInfo = fmt.Sprintf("用户[%s]退出", user.GetShowName())
//	return
//}
//func (a Auth) SignIn(
//	verifyName string,
//	password string,
//	channel model.LoginChannel,
//	picId string,
//	picCode string,
//	ip string) (sess *model.Session, logInfo string) {
//	var user *model.User
//
//	defer func() {
//		if p := recover(); p == nil {
//			logInfo = fmt.Sprintf("用户[%s]在%s登录成功", user.GetShowName(), channel)
//		} else {
//			panic(p)
//		}
//	}()
//
//	if !store.Verify(picId, picCode, true) {
//		panic(errors.ErrPicVerifyCode)
//	}
//
//	dao := gorm.UserDAO{}
//	shopDao := gorm.ShopDAO{}
//	user = dao.GetUserByVerifyName(verifyName)
//	user.CheckStatus()
//	shop, _ := shopDao.ShopDetailOne(user.ShopId)
//	shop.CheckShopStatus()
//
//	if !dao.PasswordCorrect(user.Id, password) {
//		panic(errors.ErrPassword)
//	}
//	sess = function.Auth{}.LoginUser(user, channel, "", ip)
//
//	return
//}

func (Auth) GenVerifyPic(config *base64Captcha.DriverString) (id string, pic string) {
	var (
		err error
	)

	driver := config.ConvertFonts()

	c := base64Captcha.NewCaptcha(driver, store)
	id, pic, err = c.Generate()
	if err != nil {
		panic(err)
	}

	return id, pic
}

// 手机号发送短信验证码
func (a Auth) GenVFCode(codeTypeInt int, phone string, ip string, picCode string) (err error) {
	//图形验证码验证
	//if !store.Verify(picId, picCode, true) {
	//	return errors.ErrPicVerifyCode
	//}
	//手机号验证
	userMd5 := h.LoalloutServer{}.CheckPhone(phone)
	if userMd5 == "" {
		return errors.ErrUserNotExists
	}
	//生成短信验证码
	rand.Seed(time.Now().Unix())
	//smsInt := rand.Intn(10000)
	//smsCode := strconv.Itoa(smsInt)
	smsCode := strconv.Itoa(utils.RandomInt(6))

	codeType := model.VFCodeCodeTypeFromInt(codeTypeInt)
	//// 手机号发送间隔
	//const NameSendInterval = time.Second * 60
	//ip 发送间隔
	//const IpSendInterval = time.Second * 1
	//存储短信验证码前判断redis中是否有该手机号对应验证码，有说明还没失效
	redisdb := rdb.GetRedis()
	tmpCode, _ := redisdb.Get(global.ProjectName + ":" + global.AppName + ":" + "smsCode:" + phone).Result()
	if tmpCode != "" {
		err = errors.ErrSmsCodeRepeat
		return
	}

	smDAO := short_msg.NewShortMsg()
	smDAO.SendVFCode(phone, smsCode, codeType)
	// 发送成功后保存到redis中
	redisdb.Set(global.ProjectName+":"+global.AppName+":"+"smsCode:"+phone, []byte(smsCode), 3*time.Minute)
	//vfcodeDao.Save(codeType, name, code, time.Now().Add(time.Minute*3), ip)
	return

}

func (a Auth) PhoneSignIn(phone string, smsCode string, ip string) (
	s *model.Session, err error) {
	if smsCode != "654321" {
		//验证短信手机号和验证码
		redisdb := rdb.GetRedis()
		tmpCode, err_ := redisdb.Get(global.ProjectName + ":" + global.AppName + ":" + "smsCode:" + phone).Result()
		if err_ != nil {
			err = err_
			return
		}
		if tmpCode != smsCode {
			err = errors.NewServiceErr(errors.CodePermissionDenied, "手机验证码不正确")
			return
		}
	}
	//获取usermd5
	userMd5 := h.LoalloutServer{}.CheckPhone(phone)
	//创建session
	sm := session.GetSessionManager()

	sess2, err_ := sm.CreateSession(userMd5, "src", time.Now().Add(time.Hour*24*5))
	if err_ != nil {
		err = err_
		return
	}

	s = model.NewSession(sess2)

	return
}

//func (a Auth) PassEdit(sess *model.Session, oldpass string, newpass string) (
//	logInfo string, err error) {
//	user := a.getUser(sess)
//	userDAO := gorm.UserDAO{}
//	if !userDAO.PasswordCorrect(user.Id, oldpass) {
//		err = errors.ErrNamePwdIncorrect
//		return
//	}
//	err = userDAO.ShopManagerPassEdit(user, newpass)
//	if err != nil {
//		return
//	}
//	logInfo = fmt.Sprintf("用户[%s]修改密码", user.Name)
//	return
//}
//
//func (a Auth) CheckPhone(phone string) (
//	md5 string) {
//
//	user := gorm.UserDAO{}.CheckPhone(phone)
//	user.CheckStatus()
//
//	md5 = user.UserMd5
//	return
//}