11 更新用户名#

1
#Request:
2
method: PUT
3
url:api/v1.0/user/name
4
#data:
5
{
6
 "name":"panda"
7
}
8
#Response
9
#返回成功：
10
{
11
  "errno": "0",
12
  "errmsg": "成功",
13
  "data": {
14
    "name": "Panda"
15
  }
16
}
17

18
#返回失败：
19
{
20
    "errno": "400x",   //状态码
21
    "errmsg":"状态错误信息"
22
}

1
service Example {
2
  rpc PutUserInfo(Request) returns (Response) {}
3
  rpc Stream(StreamingRequest) returns (stream StreamingResponse) {}
4
  rpc PingPong(stream Ping) returns (stream Pong) {}
5
}
6

7
message Message {
8
  string say = 1;
9
}
10

11
message Request {
12
  string Sessionid=1;
13
    string Username = 2 ;
14
}
15

16
message Response {
17
  string Errno = 1;
18
    string Errmsg = 2;
19
    string Username = 3;
20
}

1
//请求更新用户名 PUT
2
rou.PUT("/api/v1.0/user/name",handler.PutUserInfo)

1
//更新用户名//PutUserInfo
2
func PutUserInfo(w http.ResponseWriter, r *http.Request,_ httprouter.Params) {
3
  beego.Info(" 更新用户名 Putuserinfo /api/v1.0/user/name")
4
  //创建服务
5
  service := grpc.NewService()
6
  service.Init()
7
  // 接收前端发送内容
8
  var request map[string]interface{}
9
  if err := json.NewDecoder(r.Body).Decode(&request); err != nil {
10
    http.Error(w, err.Error(), 500)
11
    return
12
  }
13

14
  // 调用服务
15
  exampleClient := PUTUSERINFO.NewExampleService("go.micro.srv.PutUserInfo", service.Client())
16

17
  //获取用户登陆信息
18
  userlogin,err:=r.Cookie("userlogin")
19
  if err != nil{
20
    resp := map[string]interface{}{
21
      "errno": utils.RECODE_SESSIONERR,
22
      "errmsg": utils.RecodeText(utils.RECODE_SESSIONERR),
23
    }
24

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

35

36
  rsp, err := exampleClient.PutUserInfo(context.TODO(), &PUTUSERINFO.Request{
37
    Sessionid:userlogin.Value,
38
    Username:request["name"].(string),
39
  })
40
  if err != nil {
41
    http.Error(w, err.Error(), 500)
42
    return
43
  }
44

45
  //接收回发数据
46
  data := make(map[string]interface{})
47
  data["name"]=rsp.Username
48

49

50
  response := map[string]interface{}{
51
    "errno": rsp.Errno,
52
    "errmsg": rsp.Errmsg,
53
    "data":data,
54
  }
55
  w.Header().Set("Content-Type", "application/json")
56

57
  // 返回前端
58
  if err := json.NewEncoder(w).Encode(response); err != nil {
59
    http.Error(w, err.Error(), 501)
60
    return
61
  }
62
}

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

3
  //打印被调用的函数
4
  beego.Info("---------------- PUT  /api/v1.0/user/name PutUersinfo() ------------------")
5

6
  //创建返回空间
7
  rsp.Errno= utils.RECODE_OK
8
  rsp.Errmsg = utils.RecodeText(rsp.Errno)
9

10
  /*得到用户发送过来的name*/
11
  beego.Info(rsp.Username)
12

13
  /*从从sessionid获取当前的userid*/
14
  //连接redis
15
  redis_config_map := map[string]string{
16
    "key":utils.G_server_name,
17
    //"conn":"127.0.0.1:6379",
18
    "conn":utils.G_redis_addr+":"+utils.G_redis_port,
19
    "dbNum":utils.G_redis_dbnum,
20
  }
21
  beego.Info(redis_config_map)
22
  redis_config ,_:=json.Marshal(redis_config_map)
23
  beego.Info( string(redis_config) )
24

25
  //连接redis数据库 创建句柄
26
  bm, err := cache.NewCache("redis", string(redis_config) )
27
  if err != nil {
28
    beego.Info("缓存创建失败",err)
29
    rsp.Errno  =  utils.RECODE_DBERR
30
    rsp.Errmsg  = utils.RecodeText(rsp.Errno)
31
    return  nil
32
  }
33
  //拼接key
34
  sessioniduserid :=  req.Sessionid + "user_id"
35
  //获取userid
36
  value_id :=bm.Get(sessioniduserid)
37
  beego.Info(value_id,reflect.TypeOf(value_id))
38

39
  id :=  int(value_id.([]uint8)[0])
40
  beego.Info(id ,reflect.TypeOf(id))
41

42
  //创建表对象
43
  user:=models.User{Id:id,Name:req.Username}
44
  /*更新对应user_id的name字段的内容*/
45
  //创建数据库句柄
46
  o:= orm.NewOrm()
47
  //更新
48
  _ , err =o.Update(&user ,"name")
49
  if err !=nil{
50
    rsp.Errno= utils.RECODE_DBERR
51
    rsp.Errmsg = utils.RecodeText(rsp.Errno)
52

53
    return nil
54
  }
55

56
  /*更新session user_id*/
57
  sessionidname :=  req.Sessionid + "name"
58
  bm.Put(sessioniduserid,string(user.Id),time.Second*600)
59
  /*更新session name*/
60
  bm.Put(sessionidname,string(user.Name),time.Second*600)
61

62
  /*成功返回数据*/
63
  rsp.Username = user.Name
64
  return nil
65
}