获取用户基本信息服务（用户相关）#

1
#Request:
2
method: GET
3
url:api/v1.0/user
4
#data:
5
no input data
6
#Response
7
#返回成功：
8
{
9
  "errno": "0",
10
  "errmsg": "成功",
11
  "data": {
12
    "user_id": 1,
13
    "name": "Panda",
14
    "mobile": "110",
15
    "real_name": "熊猫",
16
    "id_card": "210112244556677",
17
    "avatar_url": "http://101.200.170.171:9998/group1/M00/00/00/Zciqq1n7It2ANn1dAADexS5wJKs808.png"
18
  }
19
}
20
#返回失败：
21
{
22
    "errno": "400x",   //状态码
23
    "errmsg":"状态错误信息"
24
}

1
service Example {
2
  rpc GetUserInfo(Request) returns (Response) {}
3
}
4
message Request {
5
    string Sessionid = 1 ;
6
}
7
message Response {
8
    //错误码
9
  string Errno =1 ;
10
  //错误信息
11
    string Errmsg = 2;
12
    //用户id
13
    int64  User_id = 3 ;
14
    //用户名
15
    string Name =4;
16
    //手机号
17
    string Mobile =5 ;
18
    //真实姓名
19
    string Real_name =6 ;
20
    //身份证号
21
    string Id_card =7;
22
    //头衔地址
23
    string Avatar_url =8 ;
24
}

1
//请求用户基本信息 GET /api/v1.0/user
2
rou.GET("/api/v1.0/user", handler.GetUserInfo)

1
func GetUserInfo(w http.ResponseWriter, r *http.Request,_ httprouter.Params) {
2
  beego.Info("GetUserInfo  获取用户信息   /api/v1.0/user")
3
  //初始化服务
4
  service := grpc.NewService()
5
  service.Init()
6

7
  //创建句柄
8
  exampleClient := GETUSERINFO.NewExampleService("go.micro.srv.GetUserInfo", service.Client())
9

10
  //获取用户的登陆信息
11
  userlogin,err:=r.Cookie("userlogin")
12

13
  //判断是否成功不成功就直接返回
14
  if err != nil{
15
    resp := map[string]interface{}{
16
      "errno": utils.RECODE_SESSIONERR,
17
      "errmsg": utils.RecodeText(utils.RECODE_SESSIONERR),
18
    }
19

20
    w.Header().Set("Content-Type", "application/json")
21
    // encode and write the response as json
22
    if err := json.NewEncoder(w).Encode(resp); err != nil {
23
      http.Error(w, err.Error(), 503)
24
      beego.Info(err)
25
      return
26
    }
27
    return
28
  }
29

30
  //成功就将信息发送给前端
31
  rsp, err := exampleClient.GetUserInfo(context.TODO(),&GETUSERINFO.Request{
32
    Sessionid:userlogin.Value,
33
  })
34

35
  if err != nil {
36
    http.Error(w, err.Error(), 502)
37

38
    beego.Info(err)
39
    //beego.Debug(err)
40
    return
41
  }
42
  //
43

44

45
  // 准备1个数据的map
46
  data := make(map[string]interface{})
47
  //将信息发送给前端
48
  data["user_id"] = int(rsp.UserId)
49
  data["name"] = rsp.Name
50
  data["mobile"] = rsp.Mobile
51
  data["real_name"] = rsp.RealName
52
  data["id_card"] = rsp.IdCard
53
  data["avatar_url"] = utils.AddDomain2Url(rsp.AvatarUrl)
54

55
  resp := map[string]interface{}{
56
    "errno": rsp.Errno,
57
    "errmsg": rsp.Errmsg,
58
    "data" : data,
59
  }
60
  //设置格式
61
  w.Header().Set("Content-Type", "application/json")
62

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

70
  return
71
}

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

3
  beego.Info("---------------- GET  /api/v1.0/user Getuserinfo() ------------------")
4
  //打印sessionid
5
  beego.Info(req.Sessionid,reflect.TypeOf(req.Sessionid))
6
  //错误码
7
  rsp.Errno  =  utils.RECODE_OK
8
  rsp.Errmsg  = utils.RecodeText(rsp.Errno)
9

10

11
  //构建连接缓存的数据
12
  redis_config_map := map[string]string{
13
    "key":utils.G_server_name,
14
    //"conn":"127.0.0.1:6379",
15
    "conn":utils.G_redis_addr+":"+utils.G_redis_port,
16
    "dbNum":utils.G_redis_dbnum,
17
  }
18
  beego.Info(redis_config_map)
19
  redis_config ,_:=json.Marshal(redis_config_map)
20

21
  //连接redis数据库 创建句柄
22
  bm, err := cache.NewCache("redis", string(redis_config) )
23
  if err != nil {
24
    beego.Info("缓存创建失败",err)
25
    rsp.Errno  =  utils.RECODE_DBERR
26
    rsp.Errmsg  = utils.RecodeText(rsp.Errno)
27
    return  nil
28
  }
29

30
  //拼接用户信息缓存字段
31
  sessioniduserid :=  req.Sessionid + "user_id"
32

33
  //获取到当前登陆用户的user_id
34
  value_id :=bm.Get(sessioniduserid)
35
  //打印
36
  beego.Info(value_id,reflect.TypeOf(value_id))
37

38
  //数据格式转换
39
  id :=  int(value_id.([]uint8)[0])
40
  beego.Info(id ,reflect.TypeOf(id))
41
  //创建user表
42
  user := models.User{Id:id}
43
  //创建数据库orm句柄
44
  o := orm.NewOrm()
45
  //查询表
46
  err =o.Read(&user)
47
  if err !=nil{
48
    rsp.Errno  =  utils.RECODE_DBERR
49
    rsp.Errmsg  = utils.RecodeText(rsp.Errno)
50
    return  nil
51
  }
52
  //将查询到的数据依次赋值
53
  rsp.UserId= int64(user.Id)
54
  rsp.Name= user.Name
55
  rsp.Mobile = user.Mobile
56
  rsp.RealName = user.Real_name
57
  rsp.IdCard = user.Id_card
58
  rsp.AvatarUrl = user.Avatar_url
59

60

61
  return nil
62
}