【Go】十八、http 调用服务的编写

http接口框架的搭建

这个http接口框架的搭建参考之前的全量搭建，这里是快速搭建的模式：
直接对已有的http模块举行复制修改，主要修改点在于 proto部门与api、router 部门，剩余的要针对举行修改模块名称。
接口的详细编写

在 api/goods/goods.go 中编写详细的代码：
例如：goods的List接口的开辟：

1. func List(ctx *gin.Context) {
2.         request := &proto.GoodsFilterRequest{}
4.         priceMin := ctx.DefaultQuery("pmin", "0") // 取出设定的最小价格,默认为 0
5.         priceMinInt, _ := strconv.Atoi(priceMin)
6.         request.PriceMin = int32(priceMinInt)
8.         priceMax := ctx.DefaultQuery("pmax", "0")
9.         priceMaxInt, _ := strconv.Atoi(priceMax)
10.         request.PriceMax = int32(priceMaxInt)
12.         isHot := ctx.DefaultQuery("ih", "0")
13.         if isHot == "1" {
14.                 request.IsHot = true
15.         }
17.         isNew := ctx.DefaultQuery("in", "0")
18.         if isNew == "1" {
19.                 request.IsNew = true
20.         }
22.         isTab := ctx.DefaultQuery("it", "0")
23.         if isTab == "1" {
24.                 request.IsTab = true
25.         }
27.         categoryId := ctx.DefaultQuery("c", "0")
28.         categoryIdInt, _ := strconv.Atoi(categoryId)
29.         request.TopCategory = int32(categoryIdInt)
31.         pages := ctx.DefaultQuery("p", "0")
32.         pagesInt, _ := strconv.Atoi(pages)
33.         request.Pages = int32(pagesInt)
35.         perNums := ctx.DefaultQuery("pnum", "0")
36.         perNumsInt, _ := strconv.Atoi(perNums)
37.         request.PagePerNums = int32(perNumsInt)
39.         keywords := ctx.DefaultQuery("q", "")
40.         request.KeyWords = keywords
42.         brandId := ctx.DefaultQuery("b", "0")
43.         brandIdInt, _ := strconv.Atoi(brandId)
44.         request.Brand = int32(brandIdInt)
46.         r, err := global.GoodsSrvClient.GoodsList(context.Background(), request)
47.         if err != nil {
48.                 zap.S().Errorw("[List] 查询 【商品列表】 失败")
49.                 HandleGrpcErrorToHttp(err, ctx)
50.                 return
51.         }
52.         reMap := map[string]interface{}{
53.                 "total": r.Total,
54.                 "data":  r.Data,
55.         }
56.         ctx.JSON(http.StatusOK, reMap)
57. }

复制代码

但是呢，这种写法存在一定的问题，就是在http接口中未存在对于 后端数据的修正，如许子未便于前端与后端的数据对接，以是我们在 http 端一般可以做一个修改确定：

1.         reMap := map[string]interface{}{
2.                 "total": r.Total,
3.         }
5.         // 这里一般会进行数据处理
6.         goodsList := make([]interface{}, 0)
7.         for _, value := range r.Data {
8.                 goodsList = append(goodsList, map[string]interface{}{
9.                         "id":          value.Id,
10.                         "name":        value.Name,
11.                         "goods_brief": value.GoodsBrief,
12.                         "desc":        value.GoodsDesc,
13.                         "ship_free":   value.ShipFree,
14.                         "images":      value.Images,
15.                         "desc_images": value.DescImages,
16.                         "front_image": value.GoodsFrontImage,
17.                         "shop_price":  value.ShopPrice,
18.                         "category": map[string]interface{}{
19.                                 "id":   value.Category.Id,
20.                                 "name": value.Category.Name,
21.                         },
22.                         "brand": map[string]interface{}{
23.                                 "id":   value.Brand.Id,
24.                                 "name": value.Brand.Name,
25.                                 "logo": value.Brand.Logo,
26.                         },
27.                         "is_hot":  value.IsHot,
28.                         "is_new":  value.IsNew,
29.                         "on_sale": value.OnSale,
30.                 })
31.         }
32.         reMap["data"] = goodsList
34.         ctx.JSON(http.StatusOK, reMap)

复制代码

注册中央内容抽取

偶然候，我们的项目不是完全基于某一个注册中央，我们不希望将注册中央的逻辑集成在 main文件中，我们希望我们的项目具有快速替换性，这个时候就需要我们将注册中央的内容抽取出来
注册中央服务注册

我们在 util 包下创建一个 register 包，再在 register包下创建 consul包，再在 consul包下创建register.go：

1. package consul
3. import (
4.         "fmt"
5.         "github.com/hashicorp/consul/api"
6.         "mxshop-api/goods-web/global"
7. )
9. // 重新配置Register，令其单独拎出来
10. // 注册类，这是一个类
11. type Registry struct {
12.         Host string
13.         Port int
14. }
16. // 这个是类的能力，能干什么
17. type RegistryClient interface {
18.         Register(address string, port int, name string, tags []string, id string) error
19.         DeRegister(serviceId string) error
20. }
22. func NewRegistryClient(host string, port int) RegistryClient {
23.         return &Registry{
24.                 Host: host,
25.                 Port: port,
26.         }
27. }
29. func (r *Registry) Register(address string, port int, name string, tags []string, id string) error {
30.         cfg := api.DefaultConfig()
31.         cfg.Address = fmt.Sprintf("%s:%d", r.Host, r.Port) // consul 的地址
33.         client, err := api.NewClient(cfg)
34.         if err != nil {
35.                 panic(err)
36.         }
38.         // 生成 consul 的注册对象
39.         // 配置基础信息
40.         registration := new(api.AgentServiceRegistration)
41.         registration.Name = name
42.         registration.ID = id
43.         registration.Tags = tags
44.         registration.Port = port
45.         registration.Address = address
47.         // 配置检查对象，也就是健康检查机制
48.         check := &api.AgentServiceCheck{
49.                 HTTP:                           fmt.Sprintf("http://%s:%d/health", global.ServerConfig.Host, global.ServerConfig.Port), // 发送 GET 请求来进行健康检查，服务的地址
50.                 Timeout:                        "5s",                                                                                   // 每次健康检查中，多久没有回复视为健康检查失败
51.                 Interval:                       "5s",                                                                                   // 进行健康检查的频率
52.                 DeregisterCriticalServiceAfter: "10s",                                                                                  // 不健康服务允许存活的时间，当一个服务被检查为不健康时，若 10s 内其没有转为健康，则将其从服务中删除
53.         }
55.         // 将检查对象配置进 consul 的注册对象 registration 中
56.         registration.Check = check
58.         // 将配置的 consul 注册进去
59.         err = client.Agent().ServiceRegister(registration)
60.         client.Agent().ServiceDeregister(name)
61.         if err != nil {
62.                 panic(err)
63.         }
65.         return nil
67. }
69. func (r *Registry) DeRegister(serviceId string) error {
70.         return nil
71. }

复制代码

在这个程序中，我们要注意的是程序的注册与鸭子范例的实际应用，同时理解golang的计划思想
main.go

1.         // 动态配置 Consul 相关信息
2.         register_client := consul.NewRegistryClient(global.ServerConfig.ConsulInfo.Host, global.ServerConfig.ConsulInfo.Port)
3.         serviceId := fmt.Sprintf("%s", uuid.NewV4())
4.         err := register_client.Register(global.ServerConfig.Host, global.ServerConfig.Port, global.ServerConfig.Name, global.ServerConfig.Tags, serviceId)
5.         if err != nil {
6.                 zap.S().Panic("服务注册失败", err.Error())
7.         }

复制代码

注册中央服务注销

优雅的使用go 的队列机制注销服务

1.         quit := make(chan os.Signal)
2.         // 如果接收到了 kill 或 ctrl C，则进入quit
3.         signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)
4.         <-quit
5.         if err = register_client.DeRegister(serviceId); err != nil {
6.                 zap.S().Panic("注销失败：", err.Error())
7.         } else {
8.                 zap.S().Panic("注销成功")
9.         }

复制代码

新建商品接口

在router中添加路由，这个商品需要管理员权限才可以新建

1. func InitGoodsRouter(Router *gin.RouterGroup) {
2.         // 这样就需要 /user/list 才可以进行访问了
3.         GoodsRouter := Router.Group("goods")
4.         {
5.                 // 在这里添加拦截器的作用响应位置
6.                 GoodsRouter.GET("", goods.List)
7.                 GoodsRouter.POST("", middlewares.JWTAuth(), middlewares.IsAdminAuth(), goods.New)
8.         }
9. }

复制代码

同时我们在 api/goods.go 中添加新建商品的接口

1. func New(ctx *gin.Context) {
2.         // 由于这里使用了 类似于 Vo 的感觉，所以先构建一个用来绑定获取到的前端数据
3.         goodsForm := forms.GoodsForm{}
4.         // 绑定 ShouldBind可以同时绑定form和json，这里就写的明确一点，视为json形式
5.         if err := ctx.ShouldBindJSON(&goodsForm); err != nil {
6.                 HandleValidatorError(ctx, err)
7.                 return
8.         }
9.         // 利用proto 从 grpc服务中获取所需的信息
10.         goodsClient := global.GoodsSrvClient
11.         rsp, err := goodsClient.CreateGoods(context.Background(), &proto.CreateGoodsInfo{
12.                 Name:            goodsForm.Name,
13.                 GoodsSn:         goodsForm.GoodsSn,
14.                 Stocks:          goodsForm.Stocks,
15.                 MarketPrice:     goodsForm.MarketPrice,
16.                 ShopPrice:       goodsForm.ShopPrice,
17.                 GoodsBrief:      goodsForm.GoodsBrief,
18.                 GoodsDesc:       goodsForm.GoodsDesc,
19.                 ShipFree:        *goodsForm.ShipFree,
20.                 Images:          goodsForm.Images,
21.                 DescImages:      goodsForm.DescImages,
22.                 GoodsFrontImage: goodsForm.FrontImage,
23.                 CategoryId:      goodsForm.CategoryId,
24.                 BrandId:         goodsForm.Brand,
25.         })
26.         if err != nil {
27.                 HandleGrpcErrorToHttp(err, ctx)
28.                 return
29.         }
30.         // todo 如何设置库存
31.         ctx.JSON(http.StatusOK, rsp)
32. }

复制代码

商品详情接口

在 router 中创建 单独商品详情接口：

1. GoodsRouter.GET("/:id", goods.Detail) // 捕捉类似于/goods/123 的内容中的 123

复制代码

1. func Detail(ctx *gin.Context) {
2.         // 获取拼接在 链接之后的参数
3.         id := ctx.Param("id") // 获取 /goods/123
4.         i, err := strconv.ParseInt(id, 10, 32)
5.         if err != nil {
6.                 ctx.Status(http.StatusNotFound)
7.                 return
8.         }
9.         // 发送 grpc 请求查询相关内容
10.         r, err := global.GoodsSrvClient.GetGoodsDetail(context.Background(), &proto.GoodInfoRequest{
11.                 Id: int32(i),
12.         })
13.         if err != nil {
14.                 api.HandleGrpcErrorToHttp(err, ctx)
15.         }
16.         rsp := map[string]interface{}{
17.                 "id":          r.Id,
18.                 "name":        r.Name,
19.                 "goods_brief": r.GoodsBrief,
20.                 "desc":        r.GoodsDesc,
21.                 "ship_free":   r.ShipFree,
22.                 "images":      r.Images,
23.                 "desc_images": r.DescImages,
24.                 "front_image": r.GoodsFrontImage,
25.                 "shop_price":  r.ShopPrice,
26.                 "category": map[string]interface{}{
27.                         "id":   r.Category.Id,
28.                         "name": r.Category.Name,
29.                 },
30.                 "brand": map[string]interface{}{
31.                         "id":   r.Brand.Id,
32.                         "name": r.Brand.Name,
33.                         "logo": r.Brand.Logo,
34.                 },
35.                 "is_hot":  r.IsHot,
36.                 "is_new":  r.IsNew,
37.                 "on_sale": r.OnSale,
38.         }
39.         ctx.JSON(http.StatusOK, rsp)
40. }

复制代码

删除商品接口

在 router 中创建 删除商品的接口：

1. GoodsRouter.DELETE("/:id", middlewares.JWTAuth(), middlewares.IsAdminAuth(), goods.Delete)

复制代码

1. func Delete(ctx *gin.Context) {
2.         id := ctx.Param("id")
3.         i, err := strconv.ParseInt(id, 10, 32)
4.         if err != nil {
5.                 ctx.Status(http.StatusNotFound)
6.                 return
7.         }
8.         _, err = global.GoodsSrvClient.DeleteGoods(context.Background(), &proto.DeleteGoodsInfo{Id: int32(i)})
9.         if err != nil {
10.                 api.HandleGrpcErrorToHttp(err, ctx)
11.                 return
12.         }
13.         ctx.Status(http.StatusOK)
14.         return
15. }

复制代码

获取商品库存接口

库存接口正在开辟中
在router 中新增接口

1. GoodsRouter.GET("/:id/stocks", goods.Stocks) // 获取商品库存

复制代码

1. func Stocks(ctx *gin.Context) {
2.         id := ctx.Param("id")
3.         _, err := strconv.ParseInt(id, 10, 32)
4.         if err != nil {
5.                 ctx.Status(http.StatusNotFound)
6.                 return
7.         }
9.         // TODO 商品库存相关信息
10. }

复制代码

更新商品状态接口

1. GoodsRouter.PATCH("/:id", middlewares.JWTAuth(), middlewares.IsAdminAuth(), goods.UpdateStatus)

复制代码

1. func UpdateStatus(ctx *gin.Context) {
2.         id := ctx.Param("id")
3.         i, err := strconv.ParseInt(id, 10, 32)
4.         if err != nil {
5.                 ctx.Status(http.StatusNotFound)
6.                 return
7.         }
9.         goodsStatusForm := forms.GoodsStatusForm{}
10.         if err := ctx.ShouldBindJSON(&goodsStatusForm); err != nil {
11.                 api.HandleValidatorError(ctx, err)
12.                 return
13.         }
15.         if _, err = global.GoodsSrvClient.UpdateGoods(context.Background(), &proto.CreateGoodsInfo{
16.                 Id:     int32(i),
17.                 IsNew:  *goodsStatusForm.IsNew,
18.                 IsHot:  *goodsStatusForm.IsHot,
19.                 OnSale: *goodsStatusForm.OnSale,
20.         }); err != nil {
21.                 api.HandleGrpcErrorToHttp(err, ctx)
22.                 return
23.         }
25.         ctx.JSON(http.StatusOK, gin.H{
26.                 "msg": "修改成功",
27.         })
28. }

复制代码

更新商品接口

1. GoodsRouter.PUT("/:id", middlewares.JWTAuth(), middlewares.IsAdminAuth(), goods.Update)

复制代码

1. func Update(ctx *gin.Context) {
2.         id := ctx.Param("id")
3.         i, err := strconv.ParseInt(id, 10, 32)
4.         if err != nil {
5.                 ctx.Status(http.StatusNotFound)
6.                 return
7.         }
9.         goodsForm := forms.GoodsForm{}
10.         if err = ctx.ShouldBindJSON(&goodsForm); err != nil {
11.                 api.HandleValidatorError(ctx, err)
12.                 return
13.         }
15.         if _, err = global.GoodsSrvClient.UpdateGoods(context.Background(), &proto.CreateGoodsInfo{
16.                 Id:              int32(i),
17.                 Name:            goodsForm.Name,
18.                 GoodsSn:         goodsForm.GoodsSn,
19.                 Stocks:          goodsForm.Stocks,
20.                 MarketPrice:     goodsForm.MarketPrice,
21.                 ShopPrice:       goodsForm.ShopPrice,
22.                 GoodsBrief:      goodsForm.GoodsBrief,
23.                 GoodsDesc:       goodsForm.GoodsDesc,
24.                 ShipFree:        *goodsForm.ShipFree,
25.                 Images:          goodsForm.Images,
26.                 DescImages:      goodsForm.DescImages,
27.                 GoodsFrontImage: goodsForm.FrontImage,
28.                 CategoryId:      goodsForm.CategoryId,
29.                 BrandId:         goodsForm.Brand,
30.         }); err != nil {
31.                 api.HandleGrpcErrorToHttp(err, ctx)
32.                 return
33.         }
35.         ctx.JSON(http.StatusOK, gin.H{
36.                 "msg": "修改成功",
37.         })
39. }

复制代码

分类的相干接口

我们在做分类接口之前，意识到有三个接口是各人都共用的，分别是：removeTopStruct、HandleGrpcErrorToHttp、HandleValidatorError ，以是我们可以把这三个接口都抽到base.go 中：
base.go（在 api 包下创建的新接口）

1. package api
3. import (
4.         "github.com/gin-gonic/gin"
5.         "github.com/go-playground/validator/v10"
6.         "google.golang.org/grpc/codes"
7.         "google.golang.org/grpc/status"
8.         "mxshop-api/goods-web/global"
9.         "net/http"
10.         "strings"
11. )
13. func HandleGrpcErrorToHttp(err error, c *gin.Context) {
14.         // 将 grpc 的状态码转换为 http 的状态码
15.         if err != nil {
16.                 if e, ok := status.FromError(err); ok {
17.                         switch e.Code() {
18.                         case codes.NotFound:
19.                                 c.JSON(http.StatusNotFound, gin.H{
20.                                         "msg": e.Message(),
21.                                 })
22.                         case codes.Internal:
23.                                 c.JSON(http.StatusInternalServerError, gin.H{
24.                                         "msg": "内部错误",
25.                                 })
26.                         case codes.InvalidArgument:
27.                                 c.JSON(http.StatusBadRequest, gin.H{
28.                                         "msg": "参数错误",
29.                                 })
30.                         default:
31.                                 c.JSON(http.StatusInternalServerError, gin.H{
32.                                         "msg": "其他错误：" + e.Message(),
33.                                 })
34.                         }
36.                 }
37.         }
38. }
40. // 在最后返回错误时调用，用来将返回中的对象名去掉
41. func RemoveTopStruct(fields map[string]string) map[string]string {
42.         rsp := map[string]string{}
43.         for field, err := range fields {
44.                 rsp[field[strings.Index(field, ".")+1:]] = err // 将map中的 key 中的 . 前面的信息去掉
45.         }
46.         return rsp
47. }
49. func HandleValidatorError(c *gin.Context, err error) {
50.         errs, ok := err.(validator.ValidationErrors)
51.         if !ok {
52.                 c.JSON(http.StatusOK, gin.H{
53.                         "msg": err.Error(),
54.                 })
55.         }
56.         c.JSON(http.StatusBadRequest, gin.H{
57.                 "msg": RemoveTopStruct(errs.Translate(global.Trans)),
58.         })
59.         return
60. }

复制代码

创建所需表单

forms/category.go

1. package forms
3. type CategoryForm struct {
4.         Name           string `form:"name" json:"name" binding:"required,min=3,max=20"`
5.         ParentCategory int32  `form:"parent" json:"parent"`
6.         Level          int32  `form:"level" json:"level" binding:"required,oneof=1 2 3"`
7.         IsTab          *bool  `form:"is_tab" json:"is_tab" binding:"required"`
8. }
10. type UpdateCategoryForm struct {
11.         Name  string `form:"name" json:"name" binding:"required,min=3,max=20"`
12.         IsTab *bool  `form:"is_tab" json:"is_tab"`
13. }

复制代码

创建接口

全部接口：

1. package category
3. import (
4.         "context"
5.         "encoding/json"
6.         "github.com/gin-gonic/gin"
7.         "go.uber.org/zap"
8.         "google.golang.org/protobuf/types/known/emptypb"
9.         "mxshop-api/goods-web/api"
10.         "mxshop-api/goods-web/forms"
11.         "mxshop-api/goods-web/global"
12.         "mxshop-api/goods-web/proto"
13.         "net/http"
14.         "strconv"
15. )
17. func List(ctx *gin.Context) {
18.         r, err := global.GoodsSrvClient.GetAllCategorysList(context.Background(), &emptypb.Empty{})
19.         if err != nil {
20.                 api.HandleGrpcErrorToHttp(err, ctx)
21.                 return
22.         }
23.         // 创建一个数组
24.         data := make([]interface{}, 0)
25.         err = json.Unmarshal([]byte(r.JsonData), &data) // 这里是逻辑写成这样了，所有的分级分类会以JSON的形式存储在r.JsonData 中，这里是对应的反解
26.         if err != nil {
27.                 zap.S().Errorw("[List] 查询 【分类列表】 失败", err.Error())
28.         }
29.         ctx.JSON(http.StatusOK, data)
30. }
32. func Detail(ctx *gin.Context) {
33.         id := ctx.Param("id")
34.         i, err := strconv.ParseInt(id, 10, 32)
35.         if err != nil {
36.                 ctx.Status(http.StatusNotFound)
37.                 return
38.         }
39.         reMap := make(map[string]interface{})
40.         subCategorys := make([]interface{}, 0)
41.         if r, err := global.GoodsSrvClient.GetSubCategory(context.Background(), &proto.CategoryListRequest{
42.                 Id: int32(i),
43.         }); err != nil {
44.                 api.HandleGrpcErrorToHttp(err, ctx)
45.                 return
46.         } else {
47.                 for _, value := range r.SubCategorys {
48.                         subCategorys = append(subCategorys, map[string]interface{}{
49.                                 "id":              value.Id,
50.                                 "name":            value.Name,
51.                                 "level":           value.Level,
52.                                 "parent_category": value.ParentCategory,
53.                                 "is_tab":          value.IsTab,
54.                         })
55.                 }
56.                 reMap["id"] = r.Info.Id
57.                 reMap["name"] = r.Info.Name
58.                 reMap["level"] = r.Info.Level
59.                 reMap["parent_category"] = r.Info.ParentCategory
60.                 reMap["sub_category"] = subCategorys
62.                 ctx.JSON(http.StatusOK, reMap)
63.         }
64.         return
65. }
67. func New(ctx *gin.Context) {
68.         categoryForm := forms.CategoryForm{}
69.         if err := ctx.ShouldBindJSON(&categoryForm); err != nil {
70.                 api.HandleValidatorError(ctx, err)
71.                 return
72.         }
73.         rsp, err := global.GoodsSrvClient.CreateCategory(context.Background(), &proto.CategoryInfoRequest{
74.                 Name:           categoryForm.Name,
75.                 IsTab:          *categoryForm.IsTab,
76.                 Level:          categoryForm.Level,
77.                 ParentCategory: categoryForm.ParentCategory,
78.         })
79.         if err != nil {
80.                 api.HandleGrpcErrorToHttp(err, ctx)
81.         }
83.         request := make(map[string]interface{})
84.         request["id"] = rsp.Id
85.         request["name"] = rsp.Name
86.         request["parent"] = rsp.ParentCategory
87.         request["level"] = rsp.Level
88.         request["is_tab"] = rsp.IsTab
89.         ctx.JSON(http.StatusOK, request)
90. }
92. func Delete(ctx *gin.Context) {
93.         id := ctx.Param("id")
94.         i, err := strconv.ParseInt(id, 10, 32)
95.         if err != nil {
96.                 ctx.Status(http.StatusNotFound)
97.                 return
98.         }
100.         //1. 先查询出该分类写的所有子分类
101.         //2. 将所有的分类全部逻辑删除
102.         //3. 将该分类下的所有的商品逻辑删除
103.         _, err = global.GoodsSrvClient.DeleteCategory(context.Background(), &proto.DeleteCategoryRequest{Id: int32(i)})
104.         if err != nil {
105.                 api.HandleGrpcErrorToHttp(err, ctx)
106.                 return
107.         }
109.         ctx.Status(http.StatusOK)
110. }
112. func Update(ctx *gin.Context) {
113.         categoryForm := forms.UpdateCategoryForm{}
114.         if err := ctx.ShouldBindJSON(&categoryForm); err != nil {
115.                 api.HandleValidatorError(ctx, err)
116.                 return
117.         }
119.         id := ctx.Param("id")
120.         i, err := strconv.ParseInt(id, 10, 32)
121.         if err != nil {
122.                 ctx.Status(http.StatusNotFound)
123.                 return
124.         }
126.         request := &proto.CategoryInfoRequest{
127.                 Id:   int32(i),
128.                 Name: categoryForm.Name,
129.         }
130.         if categoryForm.IsTab != nil {
131.                 request.IsTab = *categoryForm.IsTab
132.         }
133.         _, err = global.GoodsSrvClient.UpdateCategory(context.Background(), request)
134.         if err != nil {
135.                 api.HandleGrpcErrorToHttp(err, ctx)
136.                 return
137.         }
139.         ctx.Status(http.StatusOK)
140. }

复制代码

添加 router

router/category.go

1. package router
3. import (
4.         "github.com/gin-gonic/gin"
5.         "mxshop-api/goods-web/api/category"
6. )
8. func InitCategoryRouter(Router *gin.RouterGroup) {
9.         CategoryRouter := Router.Group("category")
10.         {
11.                 CategoryRouter.GET("", category.List)
12.                 CategoryRouter.DELETE("/:id", category.Delete)
13.                 CategoryRouter.GET("/:id", category.Detail)
14.                 CategoryRouter.POST("", category.New)
15.                 CategoryRouter.PUT("/:id", category.Update)
16.         }
17. }

复制代码

在Init 中添加category

initialize/router.go：

1.         ApiGroup := Router.Group("/g/v1")
2.         router2.InitGoodsRouter(ApiGroup)
3.         router2.InitCategoryRouter(ApiGroup) // q添加
4.         router2.InitHealthCheckRouter(Router.Group(""))

复制代码

轮播图接口

添加轮播图Form

创建文件 forms/banner.go

1. package forms
3. type BannerForm struct {
4.         Image string `form:"image" json:"image" binding:"url"`
5.         Index int `form:"index" json:"index" binding:"required"`
6.         Url string `form:"url" json:"url" binding:"url"`
7. }

复制代码

编写API

创建文件 api/banner/banner.go

1. package banners
3. import (
4.         "context"
5.         "github.com/gin-gonic/gin"
6.         "google.golang.org/protobuf/types/known/emptypb"
7.         "mxshop-api/goods-web/api"
8.         "mxshop-api/goods-web/forms"
9.         "mxshop-api/goods-web/global"
10.         "mxshop-api/goods-web/proto"
11.         "net/http"
12.         "strconv"
13. )
15. func List(ctx *gin.Context) {
16.         rsp, err := global.GoodsSrvClient.BannerList(context.Background(), &emptypb.Empty{})
17.         if err != nil {
18.                 api.HandleGrpcErrorToHttp(err, ctx)
19.                 return
20.         }
21.         result := make([]interface{}, 0)
22.         for _, value := range rsp.Data {
23.                 reMap := make(map[string]interface{})
24.                 reMap["id"] = value.Id
25.                 reMap["index"] = value.Index
26.                 reMap["image"] = value.Image
27.                 reMap["url"] = value.Url
29.                 result = append(result, reMap)
30.         }
31.         ctx.JSON(http.StatusOK, result)
32. }
34. func New(ctx *gin.Context) {
35.         // 接收新增的信息
36.         bannerForm := forms.BannerForm{}
37.         if err := ctx.ShouldBindJSON(&bannerForm); err != nil {
38.                 api.HandleValidatorError(ctx, err)
39.                 return
40.         }
41.         rsp, err := global.GoodsSrvClient.CreateBanner(context.Background(), &proto.BannerRequest{
42.                 Index: int32(bannerForm.Index),
43.                 Image: bannerForm.Image,
44.                 Url:   bannerForm.Url,
45.         })
46.         if err != nil {
47.                 api.HandleGrpcErrorToHttp(err, ctx)
48.                 return
49.         }
51.         response := make(map[string]interface{})
52.         response["id"] = rsp.Id
53.         response["index"] = rsp.Index
54.         response["url"] = rsp.Url
55.         response["image"] = rsp.Image
56.         ctx.JSON(http.StatusOK, response)
57. }
59. func Update(ctx *gin.Context) {
60.         bannerForm := forms.BannerForm{}
61.         if err := ctx.ShouldBindJSON(&bannerForm); err != nil {
62.                 api.HandleValidatorError(ctx, err)
63.                 return
64.         }
66.         id := ctx.Param("id")
67.         i, err := strconv.ParseInt(id, 10, 32)
68.         if err != nil {
69.                 ctx.Status(http.StatusNotFound)
70.                 return
71.         }
73.         _, err = global.GoodsSrvClient.UpdateBanner(context.Background(), &proto.BannerRequest{
74.                 Id:    int32(i),
75.                 Index: int32(bannerForm.Index),
76.                 Url:   bannerForm.Url,
77.         })
78.         if err != nil {
79.                 api.HandleGrpcErrorToHttp(err, ctx)
80.                 return
81.         }
83.         ctx.Status(http.StatusOK)
84. }
86. func Delete(ctx *gin.Context) {
87.         id := ctx.Param("id")
88.         i, err := strconv.ParseInt(id, 10, 32)
89.         if err != nil {
90.                 ctx.Status(http.StatusNotFound)
91.                 return
92.         }
93.         _, err = global.GoodsSrvClient.DeleteBanner(context.Background(), &proto.BannerRequest{Id: int32(i)})
94.         if err != nil {
95.                 api.HandleGrpcErrorToHttp(err, ctx)
96.                 return
97.         }
98.         ctx.JSON(http.StatusOK, "")
99. }

复制代码

编写Router

创建文件 router/banner.go

1. package router
3. import (
4.         "github.com/gin-gonic/gin"
5.         "mxshop-api/goods-web/api/banners"
6.         "mxshop-api/goods-web/middlewares"
7. )
9. func InitBannerRouter(Router *gin.RouterGroup) {
10.         BannerRouter := Router.Group("banner")
11.         {
12.                 BannerRouter.GET("", banners.List)
13.                 BannerRouter.DELETE("/:id", middlewares.JWTAuth(), middlewares.IsAdminAuth(), banners.Delete)
14.                 BannerRouter.POST("", middlewares.JWTAuth(), middlewares.IsAdminAuth(), banners.New)
15.                 BannerRouter.PUT("/:id", middlewares.JWTAuth(), middlewares.IsAdminAuth(), banners.Update)
16.         }
17. }

复制代码

将Router添加至InitRouter

1.         ApiGroup := Router.Group("/g/v1")
2.         router2.InitGoodsRouter(ApiGroup)
3.         router2.InitCategoryRouter(ApiGroup)
4.         router2.InitBannerRouter(ApiGroup)
5.         router2.InitHealthCheckRouter(Router.Group(""))
6.         return Router

复制代码

品牌接口

添加品牌表单

1. package forms
3. type BrandForm struct {
4.         Name string `form:"name" json:"name" binding:"required,min=3,max=10"`
5.         Logo string `form:"logo" json:"logo" binding:"url"`
6. }
8. type CategoryBrandForm struct {
9.         CategoryId int `form:"category_id" json:"category_id" binding:"required"`
10.         BrandId    int `form:"brand_id" json:"brand_id" binding:"required"`
11. }

复制代码

添加品牌API

注意这里的分页是不好的写法，正确的应该在service层中实现，以是这里不要参考，详细可以参考商品那里的接口

1. package brands
3. import (
4.         "context"
5.         "net/http"
6.         "strconv"
8.         "github.com/gin-gonic/gin"
10.         "mxshop-api/goods-web/api"
11.         "mxshop-api/goods-web/forms"
12.         "mxshop-api/goods-web/global"
13.         "mxshop-api/goods-web/proto"
14. )
16. func BrandList(ctx *gin.Context) {
17.         pn := ctx.DefaultQuery("pn", "0")
18.         pnInt, _ := strconv.Atoi(pn)
19.         pSize := ctx.DefaultQuery("psize", "10")
20.         pSizeInt, _ := strconv.Atoi(pSize)
22.         rsp, err := global.GoodsSrvClient.BrandList(context.Background(), &proto.BrandFilterRequest{
23.                 Pages:       int32(pnInt),
24.                 PagePerNums: int32(pSizeInt),
25.         })
27.         if err != nil {
28.                 api.HandleGrpcErrorToHttp(err, ctx)
29.                 return
30.         }
32.         result := make([]interface{}, 0)
33.         reMap := make(map[string]interface{})
34.         reMap["total"] = rsp.Total
35.         for _, value := range rsp.Data[pnInt : pnInt*pSizeInt+pSizeInt] {
36.                 reMap := make(map[string]interface{})
37.                 reMap["id"] = value.Id
38.                 reMap["name"] = value.Name
39.                 reMap["logo"] = value.Logo
41.                 result = append(result, reMap)
42.         }
44.         reMap["data"] = result
46.         ctx.JSON(http.StatusOK, reMap)
47. }
49. func NewBrand(ctx *gin.Context) {
50.         brandForm := forms.BrandForm{}
51.         if err := ctx.ShouldBindJSON(&brandForm); err != nil {
52.                 api.HandleValidatorError(ctx, err)
53.                 return
54.         }
56.         rsp, err := global.GoodsSrvClient.CreateBrand(context.Background(), &proto.BrandRequest{
57.                 Name: brandForm.Name,
58.                 Logo: brandForm.Logo,
59.         })
60.         if err != nil {
61.                 api.HandleGrpcErrorToHttp(err, ctx)
62.                 return
63.         }
65.         request := make(map[string]interface{})
66.         request["id"] = rsp.Id
67.         request["name"] = rsp.Name
68.         request["logo"] = rsp.Logo
70.         ctx.JSON(http.StatusOK, request)
71. }
73. func DeleteBrand(ctx *gin.Context) {
74.         id := ctx.Param("id")
75.         i, err := strconv.ParseInt(id, 10, 32)
76.         if err != nil {
77.                 ctx.Status(http.StatusNotFound)
78.                 return
79.         }
80.         _, err = global.GoodsSrvClient.DeleteBrand(context.Background(), &proto.BrandRequest{Id: int32(i)})
81.         if err != nil {
82.                 api.HandleGrpcErrorToHttp(err, ctx)
83.                 return
84.         }
86.         ctx.Status(http.StatusOK)
87. }
89. func UpdateBrand(ctx *gin.Context) {
90.         brandForm := forms.BrandForm{}
91.         if err := ctx.ShouldBindJSON(&brandForm); err != nil {
92.                 api.HandleValidatorError(ctx, err)
93.                 return
94.         }
96.         id := ctx.Param("id")
97.         i, err := strconv.ParseInt(id, 10, 32)
98.         if err != nil {
99.                 ctx.Status(http.StatusNotFound)
100.                 return
101.         }
103.         _, err = global.GoodsSrvClient.UpdateBrand(context.Background(), &proto.BrandRequest{
104.                 Id:   int32(i),
105.                 Name: brandForm.Name,
106.                 Logo: brandForm.Logo,
107.         })
108.         if err != nil {
109.                 api.HandleGrpcErrorToHttp(err, ctx)
110.                 return
111.         }
112.         ctx.Status(http.StatusOK)
113. }
115. func GetCategoryBrandList(ctx *gin.Context) {
116.         id := ctx.Param("id")
117.         i, err := strconv.ParseInt(id, 10, 32)
118.         if err != nil {
119.                 ctx.Status(http.StatusNotFound)
120.                 return
121.         }
123.         rsp, err := global.GoodsSrvClient.GetCategoryBrandList(context.Background(), &proto.CategoryInfoRequest{
124.                 Id: int32(i),
125.         })
126.         if err != nil {
127.                 api.HandleGrpcErrorToHttp(err, ctx)
128.                 return
129.         }
131.         result := make([]interface{}, 0)
132.         for _, value := range rsp.Data {
133.                 reMap := make(map[string]interface{})
134.                 reMap["id"] = value.Id
135.                 reMap["name"] = value.Name
136.                 reMap["logo"] = value.Logo
138.                 result = append(result, reMap)
139.         }
141.         ctx.JSON(http.StatusOK, result)
142. }
144. func CategoryBrandList(ctx *gin.Context) {
145.         //所有的list返回的数据结构
146.         /*
147.                 {
148.                         "total": 100,
149.                         "data":[{},{}]
150.                 }
151.         */
152.         rsp, err := global.GoodsSrvClient.CategoryBrandList(context.Background(), &proto.CategoryBrandFilterRequest{})
153.         if err != nil {
154.                 api.HandleGrpcErrorToHttp(err, ctx)
155.                 return
156.         }
157.         reMap := map[string]interface{}{
158.                 "total": rsp.Total,
159.         }
161.         result := make([]interface{}, 0)
162.         for _, value := range rsp.Data {
163.                 reMap := make(map[string]interface{})
164.                 reMap["id"] = value.Id
165.                 reMap["category"] = map[string]interface{}{
166.                         "id":   value.Category.Id,
167.                         "name": value.Category.Name,
168.                 }
169.                 reMap["brand"] = map[string]interface{}{
170.                         "id":   value.Brand.Id,
171.                         "name": value.Brand.Name,
172.                         "logo": value.Brand.Logo,
173.                 }
175.                 result = append(result, reMap)
176.         }
178.         reMap["data"] = result
179.         ctx.JSON(http.StatusOK, reMap)
180. }
182. func NewCategoryBrand(ctx *gin.Context) {
183.         categoryBrandForm := forms.CategoryBrandForm{}
184.         if err := ctx.ShouldBindJSON(&categoryBrandForm); err != nil {
185.                 api.HandleValidatorError(ctx, err)
186.                 return
187.         }
189.         rsp, err := global.GoodsSrvClient.CreateCategoryBrand(context.Background(), &proto.CategoryBrandRequest{
190.                 CategoryId: int32(categoryBrandForm.CategoryId),
191.                 BrandId:    int32(categoryBrandForm.BrandId),
192.         })
193.         if err != nil {
194.                 api.HandleGrpcErrorToHttp(err, ctx)
195.                 return
196.         }
198.         response := make(map[string]interface{})
199.         response["id"] = rsp.Id
201.         ctx.JSON(http.StatusOK, response)
202. }
204. func UpdateCategoryBrand(ctx *gin.Context) {
205.         categoryBrandForm := forms.CategoryBrandForm{}
206.         if err := ctx.ShouldBindJSON(&categoryBrandForm); err != nil {
207.                 api.HandleValidatorError(ctx, err)
208.                 return
209.         }
211.         id := ctx.Param("id")
212.         i, err := strconv.ParseInt(id, 10, 32)
213.         if err != nil {
214.                 ctx.Status(http.StatusNotFound)
215.                 return
216.         }
218.         _, err = global.GoodsSrvClient.UpdateCategoryBrand(context.Background(), &proto.CategoryBrandRequest{
219.                 Id:         int32(i),
220.                 CategoryId: int32(categoryBrandForm.CategoryId),
221.                 BrandId:    int32(categoryBrandForm.BrandId),
222.         })
223.         if err != nil {
224.                 api.HandleGrpcErrorToHttp(err, ctx)
225.                 return
226.         }
227.         ctx.Status(http.StatusOK)
228. }
230. func DeleteCategoryBrand(ctx *gin.Context) {
231.         id := ctx.Param("id")
232.         i, err := strconv.ParseInt(id, 10, 32)
233.         if err != nil {
234.                 ctx.Status(http.StatusNotFound)
235.                 return
236.         }
237.         _, err = global.GoodsSrvClient.DeleteCategoryBrand(context.Background(), &proto.CategoryBrandRequest{Id: int32(i)})
238.         if err != nil {
239.                 api.HandleGrpcErrorToHttp(err, ctx)
240.                 return
241.         }
243.         ctx.JSON(http.StatusOK, "")
244. }

复制代码

添加品牌Router

1. package router
3. import (
4.         "github.com/gin-gonic/gin"
5.         "mxshop-api/goods-web/api/brands"
6. )
8. // 1. 商品的api接口开发完成
9. // 2. 图片的坑
10. func InitBrandRouter(Router *gin.RouterGroup) {
11.         BrandRouter := Router.Group("brands")
12.         {
13.                 BrandRouter.GET("", brands.BrandList)          // 品牌列表页
14.                 BrandRouter.DELETE("/:id", brands.DeleteBrand) // 删除品牌
15.                 BrandRouter.POST("", brands.NewBrand)          //新建品牌
16.                 BrandRouter.PUT("/:id", brands.UpdateBrand)    //修改品牌信息
17.         }
19.         CategoryBrandRouter := Router.Group("categorybrands")
20.         {
21.                 CategoryBrandRouter.GET("", brands.CategoryBrandList)          // 类别品牌列表页
22.                 CategoryBrandRouter.DELETE("/:id", brands.DeleteCategoryBrand) // 删除类别品牌
23.                 CategoryBrandRouter.POST("", brands.NewCategoryBrand)          //新建类别品牌
24.                 CategoryBrandRouter.PUT("/:id", brands.UpdateCategoryBrand)    //修改类别品牌
25.                 CategoryBrandRouter.GET("/:id", brands.GetCategoryBrandList)   //获取分类的品牌
26.         }
27. }

复制代码

品牌路由导入路由表

1.         ApiGroup := Router.Group("/g/v1")
2.         router2.InitGoodsRouter(ApiGroup)
3.         router2.InitCategoryRouter(ApiGroup)
4.         router2.InitBannerRouter(ApiGroup)
5.         router2.InitBrandRouter(ApiGroup)
6.         router2.InitHealthCheckRouter(Router.Group(""))

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。