02 获取地区信息#

1
#Request:
2
method: GET
3
url:api/v1.0/areas
4
#data:
5
no input data
6
#Response
7
#返回成功：
8
{
9
    "errno": 0,
10
    "errmsg":"OK",
11
    "data": [
12
    {"aid": 1, "aname": "东城区"},
13
    {"aid": 2, "aname": "西城区"},
14
    {"aid": 3, "aname": "通州区"},
15
    {"aid": 4, "aname": "顺义区"}]
16
    //...
17
}
18
#注册失败：
19
{
20
    "errno": "400x",   //状态码
21
    "errmsg":"状态错误信息"
22
}

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

5
message Request {
6
}
7

8
message Response {
9
    //返回错误码
10
  string Errno = 1;
11
  //返回错误信息
12
    string Errmsg = 2;
13
    //返回数据类型
14
    message Address{
15
        int32 aid = 1;
16
        string aname = 2;
17
    }
18
    //用自定义类型返回的数组
19
    repeated Address Data = 3;
20
}

1
//获取地区信息
2
rou.GET("/api/v1.0/areas",handler.GetArea)
3
//下面两个目前并不实现服务
4
//获取session
5
rou.GET("/api/v1.0/session",handler.GetSession)
6
//获取index
7
rou.GET("/api/v1.0/house/index",handler.GetIndex)

1
//获取地区
2
func GetArea(w http.ResponseWriter, r *http.Request,_ httprouter.Params) {
3
  beego.Info("获取地区请求客户端 url：api/v1.0/areas")
4

5
  //创建新的grpc返回句柄
6
  server :=grpc.NewService()
7
  //服务出初始化
8
  server.Init()
9

10

11
  //创建获取地区的服务并且返回句柄
12
  exampleClient := GETAREA.NewExampleService("go.micro.srv.GetArea", server.Client())
13

14
  //调用函数并且获得返回数据
15
  rsp, err := exampleClient.GetArea(context.TODO(), &GETAREA.Request{})
16
  if err != nil {
17
    http.Error(w, err.Error(), 502)
18
    return
19
  }
20
  //创建返回类型的切片
21
  area_list := []models.Area{}
22
  //循环读取服务返回的数据
23
  for _,value := range rsp.Data{
24
    tmp :=models.Area{Id:int(value.Aid),Name:value.Aname,Houses:nil}
25
    area_list = append(area_list,tmp)
26
  }
27
  //创建返回数据map
28
  response := map[string]interface{}{
29
    "errno": rsp.Errno,
30
    "errmsg": rsp.Errmsg,
31
    "data" : area_list,
32
  }
33
    //注意的点
34
  w.Header().Set("Content-Type", "application/json")
35

36
  // 将返回数据map发送给前端
37
  if err := json.NewEncoder(w).Encode(response); err != nil {
38
    http.Error(w, err.Error(), 503)
39
    return
40
  }
41
}
42

43

44
//获取session
45
func GetSession(w http.ResponseWriter, r *http.Request,_ httprouter.Params) {
46
  beego.Info("获取Session url：api/v1.0/session")
47

48
  //创建返回数据map
49
  response := map[string]interface{}{
50
    "errno": utils.RECODE_SESSIONERR,
51
    "errmsg": utils.RecodeText(utils.RECODE_SESSIONERR),
52

53
  }
54
  w.Header().Set("Content-Type", "application/json")
55

56
  // 将返回数据map发送给前端
57
  if err := json.NewEncoder(w).Encode(response); err != nil {
58
    http.Error(w, err.Error(), 503)
59
    return
60
  }
61
}
62

63
//获取首页轮播
64
func GetIndex(w http.ResponseWriter, r *http.Request,_ httprouter.Params) {
65
  beego.Info("获取首页轮播 url：api/v1.0/houses/index")
66

67
  //创建返回数据map
68
  response := map[string]interface{}{
69
    "errno": utils.RECODE_OK,
70
    "errmsg": utils.RecodeText(utils.RECODE_OK),
71

72
  }
73
  w.Header().Set("Content-Type", "application/json")
74

75
  // 将返回数据map发送给前端
76
  if err := json.NewEncoder(w).Encode(response); err != nil {
77
    http.Error(w, err.Error(), 503)
78
    return
79
  }
80
}

1
package handler
2
import (
3
  "context"
4

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

7
  example "go-1/GetArea/proto/example"
8
  "github.com/astaxie/beego"
9
  "go-1/homeweb/utils"
10
  "encoding/json"
11
  "github.com/astaxie/beego/cache"
12
  _ "github.com/astaxie/beego/cache/redis"
13
  _ "github.com/gomodule/redigo/redis"
14
  "github.com/astaxie/beego/orm"
15
  "go-1/homeweb/models"
16
  "time"
17
)
18

19

20
func (e *Example) GetArea(ctx context.Context, req *example.Request, rsp *example.Response) error {
21
  beego.Info(" GetArea    api/v1.0/areas !!!")
22

23
  //初始化返回值
24
  rsp.Errno = utils.RECODE_OK
25
  rsp.Errmsg = utils.RecodeText(rsp.Errno)
26

27
  //连接redis创建句柄
28
  redis_config_map := map[string]string{
29
    "key":utils.G_server_name,
30

31
    "conn":utils.G_redis_addr+":"+utils.G_redis_port,
32
    "dbNum":utils.G_redis_dbnum,
33
  }
34
  //确定连接信息
35
  beego.Info(redis_config_map)
36
  //将map转化为json
37
  redis_config ,_:=json.Marshal(redis_config_map)
38
  //连接redis
39
  bm, err := cache.NewCache("redis", string(redis_config) )
40
  if err != nil {
41
    beego.Info("缓存创建失败",err)
42
    rsp.Errno  =  utils.RECODE_DBERR
43
    rsp.Errmsg  = utils.RecodeText(rsp.Errno)
44
    return  nil
45
  }
46
  /*1获取缓存数据*/
47
  areas_info_value:=bm.Get("areas_info")
48
  //如果不为空则说明成功
49
  if areas_info_value  !=nil{
50
    beego.Info("获取到缓存发送给前端")
51

52
    //用来存放解码的json
53
    ares_info := []map[string]interface{}{}
54
    //解码
55
    err = json.Unmarshal(areas_info_value.([]byte),&ares_info)
56

57
    //进行循环赋值
58
    for key, value := range ares_info {
59

60
      beego.Info(key,value)
61
      //创建对于数据类型并进行赋值
62
      area := example.Response_Address{Aid :int32(value["aid"].(float64)), Aname :value["aname"].(string)}
63

64
      //递增到切片
65
      rsp.Data = append(rsp.Data,&area)
66
    }
67

68
    return nil
69
  }
70
  beego.Info("没有拿到缓存")
71

72
  /*2如果没有缓存我们就从mysql 里进行查询*/
73

74
  //orm的操作创建orm句柄
75
  o:=orm.NewOrm()
76

77
  //接受地区信息的切片
78
  var areas []models.Area
79
  //创建查询条件
80
  qs:= o.QueryTable("area")
81
  //查询全部地区
82
  num ,err :=qs.All(&areas)
83
  if err != nil {
84
    rsp.Errno  =  utils.RECODE_DBERR
85
    rsp.Errmsg  = utils.RecodeText(rsp.Errno)
86
    return nil
87
  }
88
  if num == 0 {
89
    rsp.Errno  =  utils.RECODE_NODATA
90
    rsp.Errmsg  = utils.RecodeText(rsp.Errno)
91
    return nil
92
  }
93

94
  beego.Info("写入缓存")
95

96
  /*3获取数据写入缓存*/
97

98
  //将查询到的数据编码成json格式
99
  ares_info_str,_:=json.Marshal(areas)
100

101
  //Put(key string, val interface{}, timeout time.Duration) error
102
  //存入缓存中
103
  err =bm.Put("areas_info",ares_info_str,time.Second*3600)
104
  if err != nil {
105
    beego.Info("数据库中查出数据信息存入缓存中失误",err)
106
    rsp.Errno  =  utils.RECODE_NODATA
107
    rsp.Errmsg  = utils.RecodeText(rsp.Errno)
108
    return nil
109
  }
110

111
  //返回地区信息
112
  for key, value := range areas {
113
    beego.Info(key,value)
114

115
    area := example.Response_Address{Aid :int32(value.Id), Aname :string(value.Name)}
116
    //var area  example.ResponseArea_Address
117
    //area.Aid = value["aid"].(int32)
118
    //area.Aname = value["aname"].(string)
119
    rsp.Data = append(rsp.Data,&area)
120
  }
121

122
  return nil
123
}