发送用户实名认证信息服务（认证相关）#

1
#Request:
2
method: POST
3
url:api/v1.0/user/auth
4
#data:
5
{
6
    real_name: "熊猫",
7
    id_card: "21011223344556677"
8
}
9
#Response
10
#返回成功：
11
{
12
  "errno": "0",
13
  "errmsg": "成功"
14
}
15
#返回失败：
16
{
17
    "errno": "400x",   //状态码
18
    "errmsg":"状态错误信息"
19
}

1
syntax = "proto3";
2

3
package go.micro.srv.PostUserAuth;
4

5
service Example {
6
  rpc PostUserAuth(Request) returns (Response) {}
7

8
}
9

10

11

12
message Request {
13
  string real_name = 1;
14
  string id_card = 2;
15
  string sessionid = 3;
16
}
17

18
message Response {
19
  string errno = 1;
20
  string errmsg = 2;
21
}

1
func PostUserAuth(w http.ResponseWriter, r *http.Request , _ httprouter.Params ) {
2
  fmt.Println("更新实名认证检测  URL: /api/v1.0/user/auth PostUserAuth ")
3
  // decode the incoming request as json
4
  var request map[string]interface{}
5
  if err := json.NewDecoder(r.Body).Decode(&request); err != nil {
6
    http.Error(w, err.Error(), 500)
7
    return
8
  }
9

10
  fmt.Println(request["real_name"])
11
  fmt.Println(request["id_card"])
12

13

14
  //获取session
15
  //从cookie获取sessionid
16
  cookie , err:=r.Cookie("userlogin")
17
  if err!=nil{
18
    response := map[string]interface{}{
19
      "errno": utils.RECODE_SESSIONERR,
20
      "errmsg": utils.RecodeText(utils.RECODE_SESSIONERR),
21
    }
22
    w.Header().Set("Content-Type","application/json")
23
    // encode and write the response as json
24
    if err := json.NewEncoder(w).Encode(response); err != nil {
25
      http.Error(w, err.Error(), 500)
26
      return
27
    }
28

29
    return
30
  }
31

32
  client :=grpc.NewService()
33
  client.Init()
34

35
  // call the backend service
36
  exampleClient := POSTUSERAUTH.NewExampleService("go.micro.srv.PostUserAuth", client.Client())
37
  rsp, err := exampleClient.PostUserAuth(context.TODO(), &POSTUSERAUTH.Request{
38
    Sessionid:cookie.Value,
39
    RealName:request["real_name"].(string),
40
    IdCard: request["id_card"].(string),
41
  })
42
  if err != nil {
43
    http.Error(w, err.Error(), 500)
44
    return
45
  }
46

47
  //将sessionid设置给cookie
48

49
  cookie , err = r.Cookie("userlogin")
50
  if err!=nil ||""==cookie.Value{
51
    cookie := http.Cookie{
52
      Name:"userlogin",
53
      Value:cookie.Value,
54
      Path:"/",
55
      MaxAge:600,
56
    }
57

58
    http.SetCookie(w,&cookie)
59
  }
60

61

62
  // we want to augment the response
63
  response := map[string]interface{}{
64
    "errno": rsp.Errno,
65
    "errmsg": rsp.Errmsg,
66
  }
67
  w.Header().Set("Content-Type","application/json")
68
  // encode and write the response as json
69
  if err := json.NewEncoder(w).Encode(response); err != nil {
70
    http.Error(w, err.Error(), 500)
71
    return
72
  }
73
}

1
func (e *Example) PostUserAuth(ctx context.Context, req *example.Request, rsp *example.Response) error {
2

3
  fmt.Println("更新实名认证检测  URL: /api/v1.0/user/auth PostUserAuth ")
4

5
  /*初始化返回*/
6
  rsp.Errno = utils.RECODE_OK
7
  rsp.Errmsg = utils.RecodeText(rsp.Errno)
8
  /*通过sessionid拼接key*/
9

10
  sessionuserid := req.Sessionid+"user_id"
11

12
  /*链接redis*/
13
  bm ,err:=utils.OpenRedis(utils.G_server_name,utils.G_redis_addr,utils.G_redis_port,utils.G_redis_dbnum)
14
  if err!=nil{
15
    fmt.Println("redis链接失败",err)
16
    rsp.Errno = utils.RECODE_DBERR
17
    rsp.Errmsg = utils.RecodeText(rsp.Errno)
18
    return nil
19
  }
20
  /*通过redis 以sessionid拼接的key来查询userid*/
21
  value :=bm.Get(sessionuserid)
22

23
  valueid :=int(value.([]uint8)[0])
24

25

26
  /*通过userid 更新user数据*/
27
  o:=orm.NewOrm()
28
  //创建数据对象
29
  user:=models.User{Id:valueid,Real_name:req.RealName,Id_card:req.IdCard}
30

31
  _,err=o.Update(&user,"real_name","id_card")
32
  if err!=nil{
33
    fmt.Println("数据更新失败",err)
34
    rsp.Errno = utils.RECODE_DBERR
35
    rsp.Errmsg = utils.RecodeText(rsp.Errno)
36
    return nil
37
  }
38

39

40
  /*更新登录时间*/
41

42
  //先删除
43
  /*拼接key*/
44
  sname:= req.Sessionid +"name"
45
  suserid:= req.Sessionid +"user_id"
46
  smobile:= req.Sessionid +"mobile"
47

48
  /*删除登录数据*/
49
  bm.Delete(sname)
50
  bm.Delete(suserid)
51
  bm.Delete(smobile)
52
  //后添加
53
  /*将登录信息存入 redis*/
54
  bm.Put(sname,string(user.Name),time.Second*600)
55
  bm.Put(suserid,string(user.Id),time.Second*600)
56
  bm.Put(smobile,string(user.Mobile),time.Second*600)
57

58

59

60
  return nil
61
}