Blame view

cmd/httpserver/AccountAction.go 2.19 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
  	}
  
101d1cc1   zhangqijia   feat: 一个基于redis的自...
40
41
42
43
44
  	uid, err := common.GetNextUId()
  	if err != nil {
  		return 4, "uid get error: " + err.Error()
  	}
  	account.Uid = uid
29a163be   zhangqijia   fix: CreateReq ui...
45
  	account.Password = common.Md5V(register.Password)
101d1cc1   zhangqijia   feat: 一个基于redis的自...
46
  	if err = account.Create(); err != nil {
436e0af4   zhangqijia   reactor: dir; Ac...
47
  		return 4, "account register err: " + err.Error()
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
48
49
  	}
  	account.Password = register.Password
436e0af4   zhangqijia   reactor: dir; Ac...
50
  	return 0, "success"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
51
52
  }
  
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
53
  func (h *AccountAction) Login(c *gin.Context) (int, interface{}) {
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
54
55
  	var login pb.Account
  	if err := c.ShouldBindJSON(&login); err != nil {
436e0af4   zhangqijia   reactor: dir; Ac...
56
  		return 1, err.Error()
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
57
58
59
  	}
  	account := models.NewAccount(login.Phone)
  	if err := account.Load(); err != nil {
436e0af4   zhangqijia   reactor: dir; Ac...
60
  		return 2, err.Error()
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
61
62
  	}
  
29a163be   zhangqijia   fix: CreateReq ui...
63
  	if common.Md5V(login.Password) != account.Password {
436e0af4   zhangqijia   reactor: dir; Ac...
64
  		return 3, "password error"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
65
66
  	}
  
a0c46341   zhangqijia   fix: http login
67
  	var gs []*pb.ServiceInfo
765431a4   zhangqijia   增加schema接口, 抽象 mo...
68
  	for k, v := range h.HttpServer.EtcdClient.GetByPrefix(common.GlobalConf.GameConf.Name) {
a0c46341   zhangqijia   fix: http login
69
70
  		gs = append(gs, &pb.ServiceInfo{
  			Id:      k,
765431a4   zhangqijia   增加schema接口, 抽象 mo...
71
  			Name:    common.GlobalConf.GameConf.Name,
a0c46341   zhangqijia   fix: http login
72
73
74
75
  			Address: v,
  		})
  	}
  	rsp := &pb.LoginRsp{
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
76
  		Token:       account.Uid,
a0c46341   zhangqijia   fix: http login
77
78
  		GameService: gs,
  	}
62d5d847   zhangqijia   http服务只用写actionSt...
79
  	return 0, rsp
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
80
  }
15864203   zhangqijia   feat: 增加短信接口
81
  
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
82
  func (h *AccountAction) Sms(c *gin.Context) (int, interface{}) {
15864203   zhangqijia   feat: 增加短信接口
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
  	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
  }