Blame view

cmd/httpserver/AccountAction.go 1.97 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
  }
  
62d5d847   zhangqijia   http服务只用写actionSt...
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
23
24
  		return 1, err.Error()
  	}
  
  	if register.Code != "0000" {
  		return 2, "code error"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
25
26
27
28
  	}
  
  	account := models.NewAccount(register.Phone)
  	if err := account.Load(); err == nil {
436e0af4   zhangqijia   reactor: dir; Ac...
29
  		return 3 , "account exists: " + register.Phone
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
30
31
  	}
  
765431a4   zhangqijia   增加schema接口, 抽象 mo...
32
  	account.Uid = common.SnowFlack.NextValStr()
29a163be   zhangqijia   fix: CreateReq ui...
33
  	account.Password = common.Md5V(register.Password)
33ea26ab   zhangqijia   使用schema封装mongo
34
  	if  err := account.Create(); err != nil{
436e0af4   zhangqijia   reactor: dir; Ac...
35
  		return 4, "account register err: " + err.Error()
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
36
37
  	}
  	account.Password = register.Password
436e0af4   zhangqijia   reactor: dir; Ac...
38
  	return 0, "success"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
39
40
  }
  
62d5d847   zhangqijia   http服务只用写actionSt...
41
  func (h *AccountAction) Login(c *gin.Context) (int,interface{}) {
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
42
43
  	var login pb.Account
  	if err := c.ShouldBindJSON(&login); err != nil {
436e0af4   zhangqijia   reactor: dir; Ac...
44
  		return 1, err.Error()
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
45
46
47
  	}
  	account := models.NewAccount(login.Phone)
  	if err := account.Load(); err != nil {
436e0af4   zhangqijia   reactor: dir; Ac...
48
  		return 2, err.Error()
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
49
50
  	}
  
29a163be   zhangqijia   fix: CreateReq ui...
51
  	if common.Md5V(login.Password) != account.Password {
436e0af4   zhangqijia   reactor: dir; Ac...
52
  		return 3, "password error"
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
53
54
  	}
  
a0c46341   zhangqijia   fix: http login
55
  	var gs []*pb.ServiceInfo
765431a4   zhangqijia   增加schema接口, 抽象 mo...
56
  	for k, v := range h.HttpServer.EtcdClient.GetByPrefix(common.GlobalConf.GameConf.Name) {
a0c46341   zhangqijia   fix: http login
57
58
  		gs = append(gs, &pb.ServiceInfo{
  			Id:      k,
765431a4   zhangqijia   增加schema接口, 抽象 mo...
59
  			Name:    common.GlobalConf.GameConf.Name,
a0c46341   zhangqijia   fix: http login
60
61
62
63
  			Address: v,
  		})
  	}
  	rsp := &pb.LoginRsp{
436e0af4   zhangqijia   reactor: dir; Ac...
64
  		Token:         account.Uid,
a0c46341   zhangqijia   fix: http login
65
66
  		GameService: gs,
  	}
62d5d847   zhangqijia   http服务只用写actionSt...
67
  	return 0, rsp
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
68
  }
15864203   zhangqijia   feat: 增加短信接口
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
  
  func (h *AccountAction) Sms(c *gin.Context) (int,interface{}) {
  	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
  }