在go语言中gin + gorm多表关联实现一个店铺商品搜索功能示例

Go  /  管理员 发布于 12个月前   558

跟上一篇一样为了学习快速了解及跑通业务流程，快速开发实现功能。

有些拆分就不搞了，学习gorm多表关联实现列表接口

环境啥的就不介绍了，跟之前一样

go 1.18 + gin
接口测试apifox

进入步骤：

加路由

g.POST("getXfSearchSpu", v1.GetXfSearchSpu)

添加分页传参

// 分页列表
type GetListParam struct {
    SortInfo
    PageInfo
    Type       uint    `json:"type"`
    StoreId    string  `json:"storeId"`
    UserId     string  `json:"userId"`
    IsHidden   *uint8  `json:"isHidden"`
    Status     *uint16 `json:"status"`
    Search     string  `json:"search"`
    CategoryId string  `json:"categoryId"`
    ColorId    uint    `json:"colorId"`
}

接口控制器

func GetXfSearchSpu(c *gin.Context) {
    param := req.GetListParam{}
    err := c.ShouldBindJSON(&param)
    if err != nil {
        resp.ERRWithMsg(c, resp.SPU_PARAM_ERR, err.Error())
        return
    }
    fmt.Println("param:", param)
    
    s := service.NewSpuService()
    list, count, err := s.GetListV3(&param)
    if err != nil {
        resp.ERRWithMsg(c, resp.SPU_FIND_ERR, err.Error())
        return
    }
    resp.OkWithData(resp.PageResult{Rows: list, Count: count}, c)
}

server

// 202405
func (s *SpuService) GetListV3(p *req.GetListParam) (list []*model.Spu, count int64, err error) {
    p.Search = quote(p.Search)
    list = make([]*model.Spu, 0)
    limit, offset := getPageInfo(&p.PageInfo)
    
    var cond string
    //新增详情页搜索 搜索关键词及店铺id
    if p.StoreId != "" && p.Search != "" {
        cond = fmt.Sprintf("spus.store_id = '%s' and spus.spu_name like '%s'", p.StoreId, "%"+p.Search+"%")
    } else {
        cond = fmt.Sprintf("spus.store_id = '%s'", p.StoreId)
    }
    
    //颜色
    if p.ColorId != 0 {
        cond = fmt.Sprintf("sss.color_id = %d", p.ColorId)
    }
    
    if p.IsHidden != nil {
        if cond != "" {
            cond = fmt.Sprintf("%s and hidden = %d", cond, *p.IsHidden)
        } else {
            cond = fmt.Sprintf("hidden = %d", *p.IsHidden)
        }
    }
    
    ／／字段
    var SpuAlls = []string{"spus.id","spus.created_at", "spus.updated_at","spus.hidden"}
    
    err = s.DB.Model(model.Spu{}).Joins("INNER JOIN skus ON spus.id = skus.spu_id").Joins("INNER JOIN spu_spec_skus AS sss ON spus.id = sss.spu_id ").Where(cond).Count(&count).Error
    if err != nil || count == 0 {
        return
    }
    
    err = s.DB.Order("spus.created_at desc").Limit(limit).Offset(offset).Select(SpuAlls).Joins("INNER JOIN skus ON spus.id = skus.spu_id").Joins("INNER JOIN spu_spec_skus AS sss ON spus.id = sss.spu_id ").Where(cond).Find(&list).Error
    if err != nil {
        return
    }
    
    err = getSpuListProp(list)
    return
}

// 获取列表下的数据处理
func getSpuListProp(list []*model.Spu) (err error) {
	categoryService := NewCategoryService()
	specService := NewSpecService()
	for i := range list {
		list[i].ToObj()
		// 获取分类
		var categoryList []model.Category
		var specParam *model.SpecParam
		list[i].ToCategoryIdList()
		categoryList, err = categoryService.GetJustListByIdList(list[i].CategoryIdList)
		if err != nil {
			return
		}
		list[i].CategoryList = categoryList

		// 获取规格
		specParam, err = specService.GetUseOfListBySpuId(list[i].ID)
		if err != nil {
			return
		}
		list[i].SpecParam = specParam

		// 获取翻译
		GetTranslationListBySpu(list[i])
	}

	return
}

效果