Blame view

cmd/httpserver/AccountAction.go 2.35 KB
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
1
  package main
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
2
3
  
  import (
15864203   zhangqijia   feat: 增加短信接口
4
  	"fmt"
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
5
  	"github.com/garyburd/redigo/redis"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
6
  	"github.com/gin-gonic/gin"
765431a4   zhangqijia   增加schema接口, 抽象 mo...
7
  	"pro2d/common"
15864203   zhangqijia   feat: 增加短信接口
8
  	"pro2d/common/db/redisproxy"
f415f471   zhangqijia   fix: roleID自增加上限制...
9
  	"pro2d/common/etcd"
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
10
  	"pro2d/common/logger"
15864203   zhangqijia   feat: 增加短信接口
11
  	"pro2d/common/sms"
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
12
  	"pro2d/models"
7f269318   zhangqijia   add pb.go; 添加关闭连接...
13
  	"pro2d/pb"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
14
15
  )
  
62d5d847   zhangqijia   http服务只用写actionSt...
16
  type AccountAction struct {
0e5d52de   zhangqijia   reactor: 重构底层框架1.0
17
  	HttpServer *AccountServer
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
18
19
  }
  
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
20
  func (h *AccountAction) Register(c *gin.Context) (int, interface{}) {
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
21
22
  	var register pb.Register
  	if err := c.ShouldBindJSON(&register); err != nil {
436e0af4   zhangqijia   reactor: dir; Ac...
23
24
25
  		return 1, err.Error()
  	}
  
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
26
27
28
  	key := fmt.Sprintf(common.SMSCode, register.Phone)
  
  	relay, err := redisproxy.GET(key)
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
29
  	code, err := redis.String(relay, err)
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
30
31
32
  	if err != nil {
  		return 2, err.Error()
  	}
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
33
  
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
34
35
36
37
  	logger.Debug("register: phone %s, code: %s", register.Phone, code)
  
  	if register.Code != code && register.Code != "0000" {
  		return 3, "code error"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
38
39
40
41
  	}
  
  	account := models.NewAccount(register.Phone)
  	if err := account.Load(); err == nil {
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
42
  		return 4, "account exists: " + register.Phone
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
43
44
  	}
  
101d1cc1   zhangqijia   feat: 一个基于redis的自...
45
46
  	uid, err := common.GetNextUId()
  	if err != nil {
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
47
  		return 5, "uid get error: " + err.Error()
101d1cc1   zhangqijia   feat: 一个基于redis的自...
48
49
  	}
  	account.Uid = uid
29a163be   zhangqijia   fix: CreateReq ui...
50
  	account.Password = common.Md5V(register.Password)
101d1cc1   zhangqijia   feat: 一个基于redis的自...
51
  	if err = account.Create(); err != nil {
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
52
  		return 6, "account register err: " + err.Error()
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
53
54
  	}
  	account.Password = register.Password
436e0af4   zhangqijia   reactor: dir; Ac...
55
  	return 0, "success"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
56
57
  }
  
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
58
  func (h *AccountAction) Login(c *gin.Context) (int, interface{}) {
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
59
60
  	var login pb.Account
  	if err := c.ShouldBindJSON(&login); err != nil {
436e0af4   zhangqijia   reactor: dir; Ac...
61
  		return 1, err.Error()
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
62
63
64
  	}
  	account := models.NewAccount(login.Phone)
  	if err := account.Load(); err != nil {
436e0af4   zhangqijia   reactor: dir; Ac...
65
  		return 2, err.Error()
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
66
67
  	}
  
29a163be   zhangqijia   fix: CreateReq ui...
68
  	if common.Md5V(login.Password) != account.Password {
436e0af4   zhangqijia   reactor: dir; Ac...
69
  		return 3, "password error"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
70
71
  	}
  
a0c46341   zhangqijia   fix: http login
72
  	var gs []*pb.ServiceInfo
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
73
  	for k, v := range etcd.GEtcdClient().GetByPrefix(common.GlobalConf.GameConf.Name) {
a0c46341   zhangqijia   fix: http login
74
75
  		gs = append(gs, &pb.ServiceInfo{
  			Id:      k,
765431a4   zhangqijia   增加schema接口, 抽象 mo...
76
  			Name:    common.GlobalConf.GameConf.Name,
a0c46341   zhangqijia   fix: http login
77
78
79
80
  			Address: v,
  		})
  	}
  	rsp := &pb.LoginRsp{
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
81
  		Token:       account.Uid,
a0c46341   zhangqijia   fix: http login
82
83
  		GameService: gs,
  	}
62d5d847   zhangqijia   http服务只用写actionSt...
84
  	return 0, rsp
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
85
  }
15864203   zhangqijia   feat: 增加短信接口
86
  
944a2ef6   zhangqijia   fix: 注册增加验证码,暂时使用...
87
  func (h *AccountAction) Sms(c *gin.Context) (int, interface{}) {
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
88
  	phone, ok := c.GetQuery("phone")
15864203   zhangqijia   feat: 增加短信接口
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
  	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
  }