在go + gin中gorm實現指定搜索/區(qū)間搜索分頁列表功能接口實例

Go  /  管理員 發(fā)布于 6個月前   448

該需求是實現一個商品搜索分頁列表功能go + gin+ gorm實現實例

實例代碼:

控制器 

api/v1/spu.go

func GetStoreSearchSpu(c *gin.Context) {
    param := req.GetListParam{}
    err := c.ShouldBindJSON(&param)
    
    if err != nil {
        resp.ERRWithMsg(c, resp.SPU_PARAM_ERR, err.Error())
        return
    }
    param.IsHidden = api.Uint8(0)
    
    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)
}

service 

service/spu.go

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
    cond = fmt.Sprintf("spus.store_id = '%s'", p.StoreId)
    
    //顏色
    if p.Color != "" {
        cond = fmt.Sprintf("%s and EXISTS ( SELECT 1 FROM specs WHERE specs.spu_id = spus.id AND specs.title = 'Color' AND specs.spec_name = '%s')", cond, p.Color)
    }
    
    //size
    if p.Size != "" {
        cond = fmt.Sprintf("%s and EXISTS ( SELECT 1 FROM specs WHERE specs.spu_id = spus.id AND specs.title = 'Size' AND specs.spec_name = '%s')", cond, p.Size)
    }
    
    //price區(qū)間
    if p.MinPrice >= 0 && p.MaxPrice > 0 {
        cond = fmt.Sprintf("%s and spus.min_price BETWEEN %d AND %d", cond, p.MinPrice, p.MaxPrice)
    }
    
    if p.IsHidden != nil {
        if cond != "" {
            cond = fmt.Sprintf("%s and hidden = %d", cond, *p.IsHidden)
        } else {
            cond = fmt.Sprintf("hidden = %d", *p.IsHidden)
        }
    }
    
    //fmt.Println("cond:", cond)
    var SpuAlls = []string{"spus.id", "spus.currency", "spus.pv", "spus.created_at", "spus.updated_at", "spus.store_id", "spus.spu_name", "spus.img", "spus.video", "spus.gallery", "spus.detail_dawing", "spus.category_id1", "spus.category_id2", "spus.category_id3", "spus.brand_id", "spus.oringin", "spus.minimun", "spus.inc_minimun", "spus.volume", "spus.box_cbm", "spus.cbm", "spus.weight", "spus.packaging", "spus.graphic", "spus.logo", "spus.description", "spus.attributes", "spus.min_price", "spus.max_price", "spus.sales", "spus.comment_num", "spus.order_view", "spus.hidden"}
    
    err = s.DB.Model(model.Spu{}).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).Where(cond).Find(&list).Error
    if err != nil {
        return
    }
    
    err = getSpuListProp(list)
    return
}

ps:

getSpuListProp: 這是一分翻譯數據處理函數 , 這里不作分享

路由

g.POST("getStoreSearchSpu", v1.GetStoreSearchSpu)

效果圖: