1. router相关代码

1. message

  1. package router
  3. import (
  4.     "github.com/gin-gonic/gin"
  5.     "mxshop-api/userop-web/api/message"
  6.     "mxshop-api/userop-web/middlewares"
  7. )
  9. func InitMessageRouter(Router *gin.RouterGroup) {
  10.     MessageRouter := Router.Group("message")
  11.     {
  12.         MessageRouter.GET("", middlewares.JWTAuth(), message.List)          // 轮播图列表页
  13.         MessageRouter.POST("", middlewares.JWTAuth(), message.New)       //新建轮播图
  14.     }
  15. }

2. address

  1. package router
  3. import (
  4.     "github.com/gin-gonic/gin"
  5.     "mxshop-api/userop-web/api/address"
  6.     "mxshop-api/userop-web/middlewares"
  7. )
  9. func InitAddressRouter(Router *gin.RouterGroup) {
  10.     AddressRouter := Router.Group("address")
  11.     {
  12.         AddressRouter.GET("", middlewares.JWTAuth(), address.List)          // 轮播图列表页
  13.         AddressRouter.DELETE("/:id", middlewares.JWTAuth(), address.Delete) // 删除轮播图
  14.         AddressRouter.POST("", middlewares.JWTAuth(), address.New)       //新建轮播图
  15.         AddressRouter.PUT("/:id",middlewares.JWTAuth(), address.Update) //修改轮播图信息
  16.     }
  17. }

3. user_fav

  1. package router
  3. import (
  4.     "github.com/gin-gonic/gin"
  5.     "mxshop-api/userop-web/api/user_fav"
  6.     "mxshop-api/userop-web/middlewares"
  7. )
  9. func InitUserFavRouter(Router *gin.RouterGroup) {
  10.     UserFavRouter := Router.Group("userfavs")
  11.     {
  12.         UserFavRouter.DELETE("/:id", middlewares.JWTAuth(), user_fav.Delete) // 删除收藏记录
  13.         UserFavRouter.GET("/:id", middlewares.JWTAuth(), user_fav.Detail) // 获取收藏记录
  14.         UserFavRouter.POST("", middlewares.JWTAuth(), user_fav.New)       //新建收藏记录
  15.         UserFavRouter.GET("", middlewares.JWTAuth(), user_fav.List)       //获取当前用户的收藏
  17.     }
  18. }

2. handler相关代码

1. message

  1. package message
  3. import (
  4.     "context"
  5.     "github.com/gin-gonic/gin"
  6.     "go.uber.org/zap"
  7.     "mxshop-api/userop-web/api"
  8.     "mxshop-api/userop-web/forms"
  9.     "mxshop-api/userop-web/global"
  10.     "mxshop-api/userop-web/proto"
  11.     "net/http"
  12. )
  14. func List(ctx *gin.Context) {
  15.     rsp, err := global.MessageClient.MessageList(context.Background(), &proto.MessageRequest{})
  16.     if err != nil {
  17.         zap.S().Errorw("获取留言失败")
  18.         api.HandleGrpcErrorToHttp(err, ctx)
  19.         return
  20.     }
  22.     reMap := map[string]interface{}{
  23.         "total": rsp.Total,
  24.     }
  25.     result := make([]interface{}, 0)
  26.     for _, value := range rsp.Data {
  27.         reMap := make(map[string]interface{})
  28.         reMap["id"] = value.Id
  29.         reMap["user_id"] = value.UserId
  30.         reMap["type"] = value.MessageType
  31.         reMap["subject"] = value.Subject
  32.         reMap["message"] = value.Message
  33.         reMap["file"] = value.File
  35.         result = append(result, reMap)
  36.     }
  37.     reMap["data"] = result
  39.     ctx.JSON(http.StatusOK, reMap)
  40. }
  42. func New(ctx *gin.Context) {
  43.     messageForm := forms.MessageForm{}
  44.     if err := ctx.ShouldBindJSON(&messageForm); err != nil {
  45.         api.HandleValidatorError(ctx, err)
  46.         return
  47.     }
  49.     rsp, err := global.MessageClient.CreateMessage(context.Background(), &proto.MessageRequest{
  50.         MessageType: messageForm.MessageType,
  51.         Subject: messageForm.Subject,
  52.         Message: messageForm.Message,
  53.         File: messageForm.File,
  54.     })
  56.     if err != nil {
  57.         zap.S().Errorw("添加留言失败")
  58.         api.HandleGrpcErrorToHttp(err, ctx)
  59.         return
  60.     }
  62.     request := make(map[string]interface{})
  63.     request["id"] = rsp.Id
  65.     ctx.JSON(http.StatusOK, request)
  66. }

2. address

  1. package address
  3. import (
  4.     "context"
  5.     "github.com/gin-gonic/gin"
  6.     "go.uber.org/zap"
  7.     "mxshop-api/userop-web/api"
  8.     "mxshop-api/userop-web/forms"
  9.     "mxshop-api/userop-web/global"
  10.     "mxshop-api/userop-web/models"
  11.     "mxshop-api/userop-web/proto"
  12.     "net/http"
  13.     "strconv"
  14. )
  16. func List(ctx *gin.Context) {
  17.     request := &proto.AddressRequest{}
  19.     claims, _ := ctx.Get("claims")
  20.     currentUser := claims.(*models.CustomClaims)
  22.     if currentUser.AuthorityId != 2 {
  23.         userId, _ := ctx.Get("userId")
  24.         request.UserId = int32(userId.(uint))
  25.     }
  27.     rsp, err := global.AddressClient.GetAddressList(context.Background(), request)
  28.     if err != nil {
  29.         zap.S().Errorw("获取地址列表失败")
  30.         api.HandleGrpcErrorToHttp(err, ctx)
  31.         return
  32.     }
  34.     reMap := map[string]interface{}{
  35.         "total": rsp.Total,
  36.     }
  38.     result := make([]interface{}, 0)
  39.     for _, value := range rsp.Data {
  40.         reMap := make(map[string]interface{})
  41.         reMap["id"] = value.Id
  42.         reMap["user_id"] = value.UserId
  43.         reMap["province"] = value.Province
  44.         reMap["city"] = value.City
  45.         reMap["district"] = value.District
  46.         reMap["address"] = value.Address
  47.         reMap["signer_name"] = value.SignerName
  48.         reMap["signer_mobile"] = value.SignerMobile
  50.         result = append(result, reMap)
  51.     }
  53.     reMap["data"] = result
  55.     ctx.JSON(http.StatusOK, reMap)
  56. }
  58. func New(ctx *gin.Context) {
  59.     addressForm := forms.AddressForm{}
  60.     if err := ctx.ShouldBindJSON(&addressForm); err != nil {
  61.         api.HandleValidatorError(ctx, err)
  62.         return
  63.     }
  65.     rsp, err := global.AddressClient.CreateAddress(context.Background(), &proto.AddressRequest{
  66.         Province: addressForm.Province,
  67.         City: addressForm.City,
  68.         District: addressForm.District,
  69.         Address: addressForm.Address,
  70.         SignerName: addressForm.SignerName,
  71.         SignerMobile: addressForm.SignerMobile,
  72.     })
  74.     if err != nil {
  75.         zap.S().Errorw("新建地址失败")
  76.         api.HandleGrpcErrorToHttp(err, ctx)
  77.         return
  78.     }
  80.     request := make(map[string]interface{})
  81.     request["id"] = rsp.Id
  83.     ctx.JSON(http.StatusOK, request)
  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.AddressClient.DeleteAddress(context.Background(), &proto.AddressRequest{Id: int32(i)})
  94.     if err != nil {
  95.         zap.S().Errorw("删除地址失败")
  96.         api.HandleGrpcErrorToHttp(err, ctx)
  97.         return
  98.     }
  100.     ctx.JSON(http.StatusOK, "")
  101. }
  103. func Update(ctx *gin.Context) {
  104.     addressForm := forms.AddressForm{}
  105.     if err := ctx.ShouldBindJSON(&addressForm); err != nil {
  106.         api.HandleValidatorError(ctx, err)
  107.         return
  108.     }
  110.     id := ctx.Param("id")
  111.     i, err := strconv.ParseInt(id, 10, 32)
  112.     if err != nil {
  113.         ctx.Status(http.StatusNotFound)
  114.         return
  115.     }
  117.     _, err = global.AddressClient.UpdateAddress(context.Background(), &proto.AddressRequest{
  118.         Id:   int32(i),
  119.         Province: addressForm.Province,
  120.         City: addressForm.City,
  121.         District: addressForm.District,
  122.         Address: addressForm.Address,
  123.         SignerName: addressForm.SignerName,
  124.         SignerMobile: addressForm.SignerMobile,
  125.     })
  126.     if err != nil {
  127.         zap.S().Errorw("更新地址失败")
  128.         api.HandleGrpcErrorToHttp(err, ctx)
  129.         return
  130.     }
  131.     request := make(map[string]interface{})
  132.     ctx.JSON(http.StatusOK, request)
  133. }

3. userfav

  1. package user_fav
  3. import (
  4.     "context"
  5.     "github.com/gin-gonic/gin"
  6.     "go.uber.org/zap"
  7.     "mxshop-api/userop-web/api"
  8.     "mxshop-api/userop-web/forms"
  9.     "mxshop-api/userop-web/global"
  10.     "mxshop-api/userop-web/proto"
  11.     "net/http"
  12.     "strconv"
  13. )
  15. func List(ctx *gin.Context) {
  16.     userId, _ := ctx.Get("userId")
  17.     userFavRsp, err := global.UserFavClient.GetFavList(context.Background(), &proto.UserFavRequest{
  18.         UserId:  int32(userId.(uint)),
  19.     })
  20.     if err != nil {
  21.         zap.S().Errorw("获取收藏列表失败")
  22.         api.HandleGrpcErrorToHttp(err, ctx)
  23.         return
  24.     }
  26.     ids := make([]int32, 0)
  27.     for _, item := range userFavRsp.Data{
  28.         ids = append(ids, item.GoodsId)
  29.     }
  31.     if len(ids) == 0 {
  32.         ctx.JSON(http.StatusOK, gin.H{
  33.             "total":0,
  34.         })
  35.         return
  36.     }
  38.     //请求商品服务
  39.     goods, err := global.GoodsSrvClient.BatchGetGoods(context.Background(), &proto.BatchGoodsIdInfo{
  40.         Id: ids,
  41.     })
  42.     if err != nil {
  43.         zap.S().Errorw("[List] 批量查询【商品列表】失败")
  44.         api.HandleGrpcErrorToHttp(err, ctx)
  45.         return
  46.     }
  48.     reMap := map[string]interface{}{
  49.         "total": userFavRsp.Total,
  50.     }
  52.     goodsList := make([]interface{}, 0)
  53.     for _, item := range userFavRsp.Data{
  54.         data := gin.H{
  55.             "id":item.GoodsId,
  56.         }
  58.         for _, good := range goods.Data {
  59.             if item.GoodsId == good.Id {
  60.                 data["name"] = good.Name
  61.                 data["shop_price"] = good.ShopPrice
  62.             }
  63.         }
  65.         goodsList = append(goodsList, data)
  66.     }
  67.     reMap["data"] = goodsList
  68.     ctx.JSON(http.StatusOK, reMap)
  69. }
  71. func New(ctx *gin.Context) {
  72.     userFavForm := forms.UserFavForm{}
  73.     if err := ctx.ShouldBindJSON(&userFavForm); err != nil {
  74.         api.HandleValidatorError(ctx, err)
  75.         return
  76.     }
  78.     //缺少一步， 这个时候应该去商品服务查询一下这个是否存在
  79.     userId, _ := ctx.Get("userId")
  80.     _, err := global.UserFavClient.AddUserFav(context.Background(), &proto.UserFavRequest{
  81.         UserId:  int32(userId.(uint)),
  82.         GoodsId: userFavForm.GoodsId,
  83.     })
  85.     if err != nil {
  86.         zap.S().Errorw("添加收藏记录失败")
  87.         api.HandleGrpcErrorToHttp(err, ctx)
  88.         return
  89.     }
  91.     ctx.JSON(http.StatusOK, gin.H{})
  92. }
  94. func Delete(ctx *gin.Context) {
  95.     id := ctx.Param("id")
  96.     i, err := strconv.ParseInt(id, 10, 32)
  97.     if err != nil {
  98.         ctx.Status(http.StatusNotFound)
  99.         return
  100.     }
  102.     userId, _ := ctx.Get("userId")
  103.     _, err = global.UserFavClient.DeleteUserFav(context.Background(), &proto.UserFavRequest{
  104.         UserId:  int32(userId.(uint)),
  105.         GoodsId: int32(i),
  106.     })
  107.     if err != nil {
  108.         zap.S().Errorw("删除收藏记录失败")
  109.         api.HandleGrpcErrorToHttp(err, ctx)
  110.         return
  111.     }
  113.     ctx.JSON(http.StatusOK, gin.H{
  114.         "msg":"删除成功",
  115.     })
  116. }
  118. func Detail(ctx *gin.Context) {
  119.     goodsId := ctx.Param("id")
  120.     goodsIdInt, err := strconv.ParseInt(goodsId, 10, 32)
  121.     if err != nil {
  122.         ctx.Status(http.StatusNotFound)
  123.         return
  124.     }
  125.     userId, _ := ctx.Get("userId")
  126.     _, err = global.UserFavClient.GetUserFavDetail(context.Background(), &proto.UserFavRequest{
  127.         UserId:  int32(userId.(uint)),
  128.         GoodsId: int32(goodsIdInt),
  129.     })
  130.     if err != nil {
  131.         zap.S().Errorw("查询收藏状态失败")
  132.         api.HandleGrpcErrorToHttp(err, ctx)
  133.         return
  134.     }
  136.     ctx.Status(http.StatusOK)
  137. }

3. form表单

1. message

  1. package forms
  3. type MessageForm struct {
  4.     MessageType    int32 `form:"type" json:"type" binding:"required,oneof=1 2 3 4 5"`
  5.     Subject string `form:"subject" json:"subject" binding:"required"`
  6.     Message string `form:"message" json:"message" binding:"required"`
  7.     File string `form:"file" json:"file" binding:"required"`
  8. }

2. address

  1. package forms
  3. type AddressForm struct {
  4.     Province    string `form:"province" json:"province" binding:"required"`
  5.     City string `form:"city" json:"city" binding:"required"`
  6.     District string `form:"district" json:"district" binding:"required"`
  7.     Address string `form:"address" json:"address" binding:"required"`
  8.     SignerName string `form:"signer_name" json:"signer_name" binding:"required"`
  9.     SignerMobile string `form:"signer_mobile" json:"signer_mobile" binding:"required"`
  10. }

2. userfav

  1. package forms
  3. type UserFavForm struct {
  4.     GoodsId    int32 `form:"goods" json:"goods" binding:"required"`
  5. }