|
|
@@ -2,15 +2,14 @@ package service
|
|
|
|
|
|
import (
|
|
|
"fmt"
|
|
|
- "strconv"
|
|
|
+ "github.com/mojocn/base64Captcha"
|
|
|
"time"
|
|
|
"video_course/errors"
|
|
|
"video_course/global"
|
|
|
"video_course/lib/session"
|
|
|
"video_course/model"
|
|
|
+ h "video_course/repository/http"
|
|
|
rdb "video_course/repository/redis"
|
|
|
-
|
|
|
- "github.com/mojocn/base64Captcha"
|
|
|
)
|
|
|
|
|
|
var store = base64Captcha.DefaultMemStore
|
|
|
@@ -83,16 +82,16 @@ func (a Auth) GenVFCode(codeTypeInt int, phone string, ip string,
|
|
|
picId string,
|
|
|
picCode string) (err error) {
|
|
|
//图形验证码验证
|
|
|
- if !store.Verify(picId, picCode, true) {
|
|
|
- return errors.ErrPicVerifyCode
|
|
|
- }
|
|
|
+ //if !store.Verify(picId, picCode, true) {
|
|
|
+ // return errors.ErrPicVerifyCode
|
|
|
+ //}
|
|
|
//生成短信验证码
|
|
|
- smsCode := "123456"
|
|
|
+ smsCode := "12345678"
|
|
|
//发送短信
|
|
|
fmt.Println(smsCode)
|
|
|
//存储短信验证码
|
|
|
redisdb := rdb.GetRedis()
|
|
|
- redisdb.Set(global.AppName+":"+"smsCode:"+phone, []byte(smsCode), 3*time.Minute)
|
|
|
+ redisdb.Set(global.ProjectName+":"+global.AppName+":"+"smsCode:"+phone, []byte(smsCode), 3*time.Minute)
|
|
|
|
|
|
return
|
|
|
//dao := a.getUserDao()
|
|
|
@@ -126,18 +125,31 @@ func (a Auth) GenVFCode(codeTypeInt int, phone string, ip string,
|
|
|
|
|
|
func (a Auth) PhoneSignIn(phone string, smsCode string, ip string) (
|
|
|
s *model.Session, err error) {
|
|
|
+ //验证短信手机号和验证码
|
|
|
+ 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()
|
|
|
- s_, err := sm.CreateSession(strconv.Itoa(userId), src, time.Now().Add(time.Hour*24*5))
|
|
|
- s = model.NewSession(s_)
|
|
|
- //sess = NewSession
|
|
|
- //
|
|
|
- //gorm.VFCodeDAO{}.CheckVFCode(model.VFCodeCodeTypeLogin, phone, code)
|
|
|
- //
|
|
|
- //user := gorm.UserDAO{}.GetUserByPhone(phone)
|
|
|
- //user.CheckStatus()
|
|
|
- //
|
|
|
- //sess = function.Auth{}.WxLoginUser(user, channel, "", ip, phone, user.Phone)
|
|
|
- //logInfo = fmt.Sprintf("用户[%s]通过手机验证码登录", user.Name)
|
|
|
+
|
|
|
+ sess2, err_ := sm.CreateSession(userMd5, "src", time.Now().Add(time.Hour*24*5))
|
|
|
+ if err_ != nil {
|
|
|
+ err = err_
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ s = model.NewSession(sess2)
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|