Blame view

cmd/httpserver/AccountAction.go 2.12 KB
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
1
  package main
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
2
3
  
  import (
15864203   zhangqijia   feat: 增加短信接口
4
  	"fmt"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
5
  	"github.com/gin-gonic/gin"
765431a4   zhangqijia   增加schema接口, 抽象 mo...
6
  	"pro2d/common"
15864203   zhangqijia   feat: 增加短信接口
7
8
  	"pro2d/common/db/redisproxy"
  	"pro2d/common/sms"
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
9
  	"pro2d/models"
7f269318   zhangqijia   add pb.go; 添加关闭连接...
10
  	"pro2d/pb"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
11
12
  )
  
62d5d847   zhangqijia   http服务只用写actionSt...
13
  type AccountAction struct {
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
14
  	HttpServer *AccountServer
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
15
16
  }
  
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
17
  func (h *AccountAction) Register(c *gin.Context) (int, interface{}) {
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
18
19
  	var register pb.Register
  	if err := c.ShouldBindJSON(&register); err != nil {
436e0af4   zhangqijia   reactor: dir; Ac...
20
21
22
  		return 1, err.Error()
  	}
  
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
23
24
25
26
27
28
29
30
31
  	key := fmt.Sprintf(common.SMSCode, register.Phone)
  
  	relay, err := redisproxy.GET(key)
  	if err != nil {
  		return 2, err.Error()
  	}
  	code := relay.(string)
  
  	if register.Code != code {
436e0af4   zhangqijia   reactor: dir; Ac...
32
  		return 2, "code error"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
33
34
35
36
  	}
  
  	account := models.NewAccount(register.Phone)
  	if err := account.Load(); err == nil {
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
37
  		return 3, "account exists: " + register.Phone
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
38
39
  	}
  
765431a4   zhangqijia   增加schema接口, 抽象 mo...
40
  	account.Uid = common.SnowFlack.NextValStr()
29a163be   zhangqijia   fix: CreateReq ui...
41
  	account.Password = common.Md5V(register.Password)
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
42
  	if err := account.Create(); err != nil {
436e0af4   zhangqijia   reactor: dir; Ac...
43
  		return 4, "account register err: " + err.Error()
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
44
45
  	}
  	account.Password = register.Password
436e0af4   zhangqijia   reactor: dir; Ac...
46
  	return 0, "success"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
47
48
  }
  
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
49
  func (h *AccountAction) Login(c *gin.Context) (int, interface{}) {
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
50
51
  	var login pb.Account
  	if err := c.ShouldBindJSON(&login); err != nil {
436e0af4   zhangqijia   reactor: dir; Ac...
52
  		return 1, err.Error()
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
53
54
55
  	}
  	account := models.NewAccount(login.Phone)
  	if err := account.Load(); err != nil {
436e0af4   zhangqijia   reactor: dir; Ac...
56
  		return 2, err.Error()
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
57
58
  	}
  
29a163be   zhangqijia   fix: CreateReq ui...
59
  	if common.Md5V(login.Password) != account.Password {
436e0af4   zhangqijia   reactor: dir; Ac...
60
  		return 3, "password error"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
61
62
  	}
  
a0c46341   zhangqijia   fix: http login
63
  	var gs []*pb.ServiceInfo
765431a4   zhangqijia   增加schema接口, 抽象 mo...
64
  	for k, v := range h.HttpServer.EtcdClient.GetByPrefix(common.GlobalConf.GameConf.Name) {
a0c46341   zhangqijia   fix: http login
65
66
  		gs = append(gs, &pb.ServiceInfo{
  			Id:      k,
765431a4   zhangqijia   增加schema接口, 抽象 mo...
67
  			Name:    common.GlobalConf.GameConf.Name,
a0c46341   zhangqijia   fix: http login
68
69
70
71
  			Address: v,
  		})
  	}
  	rsp := &pb.LoginRsp{
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
72
  		Token:       account.Uid,
a0c46341   zhangqijia   fix: http login
73
74
  		GameService: gs,
  	}
62d5d847   zhangqijia   http服务只用写actionSt...
75
  	return 0, rsp
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
76
  }
15864203   zhangqijia   feat: 增加短信接口
77
  
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
78
  func (h *AccountAction) Sms(c *gin.Context) (int, interface{}) {
15864203   zhangqijia   feat: 增加短信接口
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
  	c.Request.ParseForm()
  	phone, ok := c.GetPostForm("phone")
  	if !ok {
  		return 1, "phone not exists"
  	}
  	code := common.RandomCode()
  	key := fmt.Sprintf(common.SMSCode, phone)
  
  	relay, err := redisproxy.SETNX(key, code)
  	if relay.(int64) == 0 {
  		return 2, "send frequently"
  	}
  	redisproxy.ExpireKey(key, 60)
  
  	err = sms.SendSms(phone, code)
  	if err != nil {
  		redisproxy.DEL(key)
  		return 3, err.Error()
  	}
  
  	return 0, nil
  }