13获取短信验证码服务（注册相关）#

1
#Request:
2
method: GET
3
#111表示的是手机号
4
url:api/v1.0/smscode/:mobile
5
url:api/v1.0/smscode/111?  text=248484&id=9cd8faa9-5653-4f7c-b653-0a58a8a98c81
6
data:no input data
7
#Response
8
#返回成功：
9
{
10
    "errno": "0",   //状态码
11
    "errmsg":"ok"
12
}
13
#注册失败：
14
{
15
    "errno": "4001",   //状态码
16
    "errmsg":"状态错误信息"
17
}

1
//网站：https://www.mysubmail.com
2

3

4
//短信map
5
  messageconfig := make(map[string]string)
6
  //id
7
  messageconfig["appid"] = "29672"
8
  //key
9
  messageconfig["appkey"] = "89d90165cbea8cae80137d7584179bdb"
10
  //编码格式
11
  messageconfig["signtype"] = "md5"
12

13

14
  //短信操作对象
15
  messagexsend := submail.CreateMessageXSend()
16
  //短信发送到那个手机号
17
  submail.MessageXSendAddTo(messagexsend, “手机号”)
18
  //短信发送的模板
19
  submail.MessageXSendSetProject(messagexsend, "NQ1J94")
20
  //发送的验证码
21
  submail.MessageXSendAddVar(messagexsend, "code", "1111")
22
  //发送
23
  fmt.Println("MessageXSend ", submail.MessageXSendRun(submail.MessageXSendBuildRequest(messagexsend), messageconfig))

1
service Example {
2
  rpc GetSmscd(Request) returns (Response) {}
3
}
4

5
//客户端发送给服务器
6
message Request {
7
  //手机号
8
  string Mobile = 1;
9
  //uuid
10
    string Id = 2;
11
    //验证码
12
    string Text = 3;
13
}
14
//服务器回发给客户端
15
message Response {
16
  string Errno = 1;
17
    string Errmsg = 2;
18
}

1
//获取短信验证码
2
rou.GET("/api/v1.0/smscode/:mobile",handler.Getsmscd)

1
func Getsmscd(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
2
  beego.Info(" 获取短信验证   api/v1.0/smscode/:id ")
3

4
  //创建服务
5
  service := grpc.NewService()
6
  service.Init()
7

8
  //获取 前端发送过来的手机号
9
  mobile := ps.ByName("mobile")
10
  beego.Info(mobile)
11
  //后端进行正则匹配
12
  //创建正则句柄
13
  myreg := regexp.MustCompile(`0?(13|14|15|17|18|19)[0-9]{9}`)
14
  //进行正则匹配
15
  bo := myreg.MatchString(mobile)
16

17
  //如果手机号错误则
18
  if bo == false {
19
    // we want to augment the response
20
    resp := map[string]interface{}{
21
      "errno":  utils.RECODE_NODATA,
22
      "errmsg": "手机号错误",
23
    }
24
    //设置返回数据格式
25
    w.Header().Set("Content-Type", "application/json")
26

27
    //将错误发送给前端
28
    if err := json.NewEncoder(w).Encode(resp); err != nil {
29
      http.Error(w, err.Error(), 503)
30
      beego.Info(err)
31
      return
32
    }
33
    beego.Info("手机号错误返回")
34
    return
35
  }
36

37

38
  //获取url携带的验证码 和key（uuid）
39
  beego.Info(r.URL.Query())
40
  //获取url携带的参数
41
  text := r.URL.Query()["text"][0] //text=248484
42

43
  id := r.URL.Query()["id"][0]     //id=9cd8faa9-5653-4f7c-b653-0a58a8a98c81
44

45

46
  //调用服务
47
  exampleClient := GETSMSCD.NewExampleService("go.micro.srv.GetSmscd", service.Client())
48
  rsp, err := exampleClient.GetSmscd(context.TODO(), &GETSMSCD.Request{
49
    Mobile: mobile,
50
    Id:     id,
51
    Text:   text,
52
  })
53

54
  if err != nil {
55
    http.Error(w, err.Error(), 502)
56
    beego.Info(err)
57
    //beego.Debug(err)
58
    return
59
  }
60
  //创建返回map
61
  resp := map[string]interface{}{
62
    "errno":  rsp.Errno,
63
    "errmsg": rsp.Errmsg,
64
  }
65
  //设置返回格式
66
  w.Header().Set("Content-Type", "application/json")
67

68
  //将数据回发给前端
69
  if err := json.NewEncoder(w).Encode(resp); err != nil {
70
    http.Error(w, err.Error(), 503)
71
    beego.Info(err)
72
    return
73
  }
74
}

1
package handler
2

3
import (
4
  "context"
5

6
  "github.com/micro/go-log"
7

8
  example "go-1/GetSmscd/proto/example"
9
  "strconv"
10
  "fmt"
11
  "time"
12
  "github.com/astaxie/beego"
13
  "go-1/homeweb/utils"
14
  "encoding/json"
15
  "github.com/astaxie/beego/cache"
16
  _ "github.com/astaxie/beego/cache/redis"
17
  _ "github.com/gomodule/redigo/redis"
18
  "github.com/garyburd/redigo/redis"
19
  "reflect"
20
  "math/rand"
21
  "github.com/SubmailDem/submail"
22
  "github.com/astaxie/beego/orm"
23
  "go-1/homeweb/models"
24
)
25

26
//获取短信验证码
27
func (e *Example) GetSmscd(ctx context.Context, req *example.Request, rsp *example.Response) error {
28
  beego.Info(" GET smscd  api/v1.0/smscode/:id ")
29
  //初始化返回正确的返回值
30
  rsp.Errno = utils.RECODE_OK
31
  rsp.Errmsg = utils.RecodeText(rsp.Errno)
32
  /*验证uuid的缓存*/
33

34

35
  //验证手机号
36
  o:=orm.NewOrm()
37
  user := models.User{Mobile:req.Mobile}
38
  err := o.Read(&user)
39
  if err==nil{
40
    beego.Info("用户已经存在")
41
    rsp.Errno  =  utils.RECODE_DBERR
42
    rsp.Errmsg  = utils.RecodeText(rsp.Errno)
43
    return  nil
44
  }
45
  beego.Info(err)
46

47
  //连接redis数据库
48
  redis_config_map := map[string]string{
49
    "key":utils.G_server_name,
50
    "conn":utils.G_redis_addr+":"+utils.G_redis_port,
51
    "dbNum":utils.G_redis_dbnum,
52
  }
53
  beego.Info(redis_config_map)
54
  redis_config ,_:=json.Marshal(redis_config_map)
55
  beego.Info( string(redis_config) )
56

57

58
  //连接redis数据库 创建句柄
59
  bm, err := cache.NewCache("redis", string(redis_config) )
60
  //bm,err:=cache.NewCache("redis",`{"key":"ihome","conn":"127.0.0.1:6379","dbNum":"0"} `)//创建1个缓存句柄
61
  if err != nil {
62
    beego.Info("缓存创建失败",err)
63
    rsp.Errno = utils.RECODE_DBERR
64
    rsp.Errmsg = utils.RecodeText(rsp.Errno)
65
    return nil
66
  }
67

68
  beego.Info(req.Id,reflect.TypeOf(req.Id))
69
  //查询相关数据
70

71
  value:=bm.Get(req.Id)
72
  if value  ==nil{
73
    beego.Info("获取到缓存数据查询失败",value)
74

75
    rsp.Errno = utils.RECODE_DBERR
76
    rsp.Errmsg = utils.RecodeText(rsp.Errno)
77

78
    return nil
79
  }
80
  beego.Info(value,reflect.TypeOf(value))
81
  value_str ,_ :=redis.String(value,nil)
82

83

84
  beego.Info(value_str,reflect.TypeOf(value_str))
85
  //数据对比
86
  if req.Text != value_str{
87
    beego.Info("图片验证码 错误 ")
88
    rsp.Errno = utils.RECODE_DBERR
89
    rsp.Errmsg = utils.RecodeText(rsp.Errno)
90
    return nil
91
  }
92

93

94

95

96

97
  r := rand.New(rand.NewSource(time.Now().UnixNano()))
98
  size := r.Intn(8999)+1000  //1000-9999
99
  beego.Info(size)
100

101
  //短信map
102
  messageconfig := make(map[string]string)
103
  //id
104
  messageconfig["appid"] = "29672"
105
  //key
106
  messageconfig["appkey"] = "89d90165cbea8cae80137d7584179bdb"
107
  //编码格式
108
  messageconfig["signtype"] = "md5"
109

110

111
  //短信操作对象
112
  messagexsend := submail.CreateMessageXSend()
113
  //短信发送到那个手机号
114
  submail.MessageXSendAddTo(messagexsend, req.Mobile  )
115
  //短信发送的模板
116
  submail.MessageXSendSetProject(messagexsend, "NQ1J94")
117
  //发送的验证码
118
  submail.MessageXSendAddVar(messagexsend, "code", strconv.Itoa(size))
119
  //发送
120
  fmt.Println("MessageXSend ", submail.MessageXSendRun(submail.MessageXSendBuildRequest(messagexsend), messageconfig))
121

122

123
  /*通过手机号将验证短信进行缓存*/
124

125
  err = bm.Put(req.Mobile,size,time.Second*300)
126
  if err !=nil{
127
    beego.Info("缓存出现问题")
128
    rsp.Errno = utils.RECODE_DBERR
129
    rsp.Errmsg = utils.RecodeText(rsp.Errno)
130
    return nil
131
  }
132

133
  return  nil
134
}