在go語言中g(shù)in + gorm多表關(guān)聯(lián)實(shí)現(xiàn)一個(gè)店鋪商品搜索功能示例

Go  /  管理員 發(fā)布于 10個(gè)月前   489

跟上一篇一樣為了學(xué)習(xí)快速了解及跑通業(yè)務(wù)流程，快速開發(fā)實(shí)現(xiàn)功能。

有些拆分就不搞了，學(xué)習(xí)gorm多表關(guān)聯(lián)實(shí)現(xiàn)列表接口

環(huán)境啥的就不介紹了，跟之前一樣

go 1.18 + gin
接口測(cè)試apifox

進(jìn)入步驟：

加路由

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
    //新增詳情頁搜索 搜索關(guān)鍵詞及店鋪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
}

// 獲取列表下的數(shù)據(jù)處理
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

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

		// 獲取翻譯
		GetTranslationListBySpu(list[i])
	}

	return
}

效果