发送登陆信息服务（登陆相关）#

1
#Request:
2
method: POST
3
url:api/v1.0/sessions
4
#data:
5
{
6
    mobile: "133", //手机号
7
    password: "itcast"//密码
8
}
9
#Response
10
#返回成功：
11
{
12
    "errno": "0",
13
    "errmsg":"OK",
14
}
15
#返回失败：
16
{
17
    "errno": "400x",   //状态码
18
    "errmsg":"状态错误信息"
19
}

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

5
message Request {
6
  string Mobile =1 ;
7
  string Password =2 ;
8
}
9

10
message Response {
11
    string Errno = 1 ;
12
    string Errmsg =2 ;
13
    string SessionID = 3 ;
14
}

1
//登陆
2
rou.POST("/api/v1.0/sessions",handler.PostLogin)

1
//登陆
2
func PostLogin(w http.ResponseWriter, r *http.Request, _ httprouter.Params) {
3
  beego.Info("登陆 api/v1.0/sessions")
4
  //获取前端post请求发送的内容
5
  var request map[string]interface{}
6
  if err := json.NewDecoder(r.Body).Decode(&request); err != nil {
7
    http.Error(w, err.Error(), 500)
8
    return
9
  }
10

11
  for key, value := range request {
12
    beego.Info(key,value,reflect.TypeOf(value))
13
  }
14
  //判断账号密码是否为空
15
  if request["mobile"] == "" || request["password"] =="" {
16
    resp := map[string]interface{}{
17
      "errno": utils.RECODE_NODATA,
18
      "errmsg": "信息有误请从新输入",
19
    }
20
    w.Header().Set("Content-Type", "application/json")
21

22
    // encode and write the response as json
23
    if err := json.NewEncoder(w).Encode(resp); err != nil {
24
      http.Error(w, err.Error(), 503)
25
      beego.Info(err)
26
      return
27
    }
28
    beego.Info("有数据为空")
29
    return
30
  }
31

32
  //创建连接
33

34
  service := grpc.NewService()
35
  service.Init()
36
  exampleClient :=POSTLOGIN.NewExampleService("go.micro.srv.PostLogin",service.Client())
37

38
  rsp, err := exampleClient.PostLogin(context.TODO(),&POSTLOGIN.Request{
39
    Password:request["password"].(string),
40
    Mobile:request["mobile"].(string),
41
  })
42

43

44
  if err != nil {
45
    http.Error(w, err.Error(), 502)
46

47
    beego.Info(err)
48
    //beego.Debug(err)
49
    return
50
  }
51

52
  cookie,err :=r.Cookie("userlogin")
53
  if err !=nil || ""==cookie.Value{
54
    cookie  := http.Cookie{Name: "userlogin", Value: rsp.SessionID, Path: "/", MaxAge: 600}
55
    http.SetCookie(w, &cookie)
56
  }
57
  beego.Info(rsp.SessionID)
58
  resp := map[string]interface{}{
59
    "errno": rsp.Errno,
60
    "errmsg": rsp.Errmsg,
61

62
  }
63
  w.Header().Set("Content-Type", "application/json")
64

65
  // encode and write the response as json
66
  if err := json.NewEncoder(w).Encode(resp); err != nil {
67
    http.Error(w, err.Error(), 503)
68
    beego.Info(err)
69
    return
70
  }
71
}

1
func (e *Example) PostLogin(ctx context.Context, req *example.Request, rsp *example.Response) error {
2
  beego.Info("登陆 api/v1.0/sessions")
3

4
  //返回给前端的map结构体
5
  rsp.Errno =  utils.RECODE_OK
6
  rsp.Errmsg = utils.RecodeText(rsp.Errno)
7

8

9
  //查询数据库
10
  var user models.User
11
  o:=orm.NewOrm()
12

13
  //select * from user
14
  //创建查询句柄
15
  qs:=o.QueryTable("user")
16
  //qs.Filter("profile__age", 18)
17
  //查询符合的数据
18
  err:=qs.Filter("mobile",req.Mobile).One(&user)
19
  if err != nil {
20

21
    rsp.Errno =  utils.RECODE_NODATA
22
    rsp.Errmsg = utils.RecodeText(rsp.Errno)
23

24
    return nil
25
  }
26

27
  //判断密码是否正确
28
  if req.Password != user.Password_hash{
29
    rsp.Errno =  utils.RECODE_PWDERR
30
    rsp.Errmsg = utils.RecodeText(rsp.Errno)
31

32
    return nil
33
  }
34

35
  //编写redis缓存数据库信息
36
  redis_config_map := map[string]string{
37
    "key":utils.G_server_name,
38
    //"conn":"127.0.0.1:6379",
39
    "conn":utils.G_redis_addr+":"+utils.G_redis_port,
40
    "dbNum":utils.G_redis_dbnum,
41
  }
42
  beego.Info(redis_config_map)
43
  redis_config ,_:=json.Marshal(redis_config_map)
44

45

46
  //连接redis数据库 创建句柄
47
  bm, err := cache.NewCache("redis", string(redis_config) )
48

49
  if err != nil {
50
    beego.Info("缓存创建失败",err)
51
    rsp.Errno = utils.RECODE_DBERR
52
    rsp.Errmsg = utils.RecodeText(rsp.Errno)
53

54
    return nil
55
  }
56

57
  //生成sessionID
58
  h := GetMd5String(req.Mobile+req.Password)
59
  rsp.SessionID = h
60

61
  beego.Info(h)
62

63
  //拼接key sessionid + name
64
  bm.Put(h+"name",string(user.Name),time.Second*3600)
65
  //拼接key sessionid + user_id
66
  bm.Put(h+"user_id", string(user.Id) ,time.Second*3600)
67
  //拼接key sessionid + mobile
68
  bm.Put(h+"mobile",string(user.Mobile) ,time.Second*3600)
69

70
  //成功返回数据
71
  return nil
72

73
}