fusenapi/server/product/internal/logic/homepagerecommendproductlistlogic.go

213 lines
8.4 KiB
Go
Raw Normal View History

2023-07-20 09:35:13 +00:00
package logic
import (
2023-09-05 08:35:02 +00:00
"encoding/json"
2023-07-20 09:35:13 +00:00
"errors"
2023-10-17 07:33:46 +00:00
"fusenapi/constants"
2023-07-20 09:35:13 +00:00
"fusenapi/model/gmodel"
"fusenapi/utils/auth"
"fusenapi/utils/basic"
"fusenapi/utils/format"
2023-09-06 06:35:42 +00:00
"fusenapi/utils/s3url_to_s3id"
2023-07-20 09:35:13 +00:00
"gorm.io/gorm"
"strings"
"context"
"fusenapi/server/product/internal/svc"
"fusenapi/server/product/internal/types"
"github.com/zeromicro/go-zero/core/logx"
)
2023-07-20 09:47:28 +00:00
type HomePageRecommendProductListLogic struct {
2023-07-20 09:35:13 +00:00
logx.Logger
ctx context.Context
svcCtx *svc.ServiceContext
}
2023-07-20 09:47:28 +00:00
func NewHomePageRecommendProductListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *HomePageRecommendProductListLogic {
return &HomePageRecommendProductListLogic{
2023-07-20 09:35:13 +00:00
Logger: logx.WithContext(ctx),
ctx: ctx,
svcCtx: svcCtx,
}
}
2023-07-20 09:47:28 +00:00
func (l *HomePageRecommendProductListLogic) HomePageRecommendProductList(req *types.HomePageRecommendProductListReq, userinfo *auth.UserInfo) (resp *basic.Response) {
2023-07-20 09:35:13 +00:00
//查询用户信息(不用判断存在)
2023-08-14 03:49:02 +00:00
_, err := l.svcCtx.AllModels.FsUser.FindUserById(l.ctx, userinfo.UserId)
2023-07-20 09:35:13 +00:00
if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "get user info err")
}
var (
2023-08-14 03:35:23 +00:00
merchantInfo *gmodel.FsMerchantCategory
2023-07-20 09:35:13 +00:00
recommendProductList []gmodel.FsProduct //产品列表select 字段需要看查询的地方)
productOptionalPartList []gmodel.GetGroupPartListByProductIdsRsp //产品配件列表
2023-08-14 03:53:16 +00:00
mapProductHaveOptionFitting = make(map[int64]struct{}) //是否有配件map
productTemplatesV2 []gmodel.FsProductTemplateV2 //产品模板列表select 字段需要看查询的地方)
productSizeCountList []gmodel.CountProductSizeByStatusRsp //产品尺寸数量列表select 字段需要看查询的地方)
mapProductSizeCount = make(map[int64]int64) //产品尺寸数量map
mapProductTemplate = make(map[int64]struct{}) //产品模板map
2023-07-20 09:35:13 +00:00
)
2023-08-14 03:35:23 +00:00
//选了商家类型
if req.MerchantType > 0 {
merchantInfo, err = l.svcCtx.AllModels.FsMerchantCategory.FindOne(l.ctx, req.MerchantType)
2023-08-28 06:56:01 +00:00
if err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) {
2023-08-28 07:40:56 +00:00
return resp.SetStatusWithMessage(basic.CodeOK, "the merchant category is not exists", []interface{}{})
2023-08-28 06:56:01 +00:00
}
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeDbSqlErr, "failed to get merchant category")
}
2023-08-14 03:35:23 +00:00
} else {
2023-08-28 06:56:01 +00:00
//获取默认的那个
merchantInfo, err = l.svcCtx.AllModels.FsMerchantCategory.FindDefualtOne(l.ctx)
if err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) {
2023-08-28 07:40:56 +00:00
return resp.SetStatusWithMessage(basic.CodeOK, "the default merchant category is not exists", []interface{}{})
2023-08-28 06:56:01 +00:00
}
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeDbSqlErr, "failed to get default merchant category")
2023-08-14 03:35:23 +00:00
}
}
if *merchantInfo.RecommendProduct == "" {
return resp.SetStatusWithMessage(basic.CodeOK, "success", []interface{}{})
}
recommendProductIds, err := format.StrSlicToInt64Slice(strings.Split(*merchantInfo.RecommendProduct, ","))
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "failed to parse recommend product")
}
2023-09-05 08:35:02 +00:00
//资源id集合
resourceIds := make([]string, 0, 100)
2023-07-20 09:35:13 +00:00
//获取列表推荐产品
2023-08-14 03:35:23 +00:00
recommendProductList, err = l.svcCtx.AllModels.FsProduct.GetProductListByIds(l.ctx, recommendProductIds, "sort-desc")
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeDbSqlErr, "failed to get product list")
}
2023-07-20 09:35:13 +00:00
if len(recommendProductList) == 0 {
return resp.SetStatusWithMessage(basic.CodeOK, "success", []interface{}{})
}
productIds := make([]int64, 0, len(recommendProductList))
for _, product := range recommendProductList {
productIds = append(productIds, product.Id)
2023-09-06 06:35:42 +00:00
resourceIds = append(resourceIds, s3url_to_s3id.GetS3ResourceIdFormUrl(*product.Cover))
resourceIds = append(resourceIds, s3url_to_s3id.GetS3ResourceIdFormUrl(*product.CoverImg))
2023-07-20 09:35:13 +00:00
}
//获取商品可选配件
productOptionalPartList, err = l.svcCtx.AllModels.FsProductModel3d.GetGroupPartListByProductIds(l.ctx, productIds)
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeDbSqlErr, "failed to get product part list")
}
//存储有配件的map
for _, partList := range productOptionalPartList {
partList.PartList = strings.Trim(partList.PartList, " ")
partList.PartList = strings.Trim(partList.PartList, ",")
if partList.PartList == "" {
continue
}
mapProductHaveOptionFitting[partList.ProductId] = struct{}{}
}
2023-09-27 03:48:15 +00:00
//获取产品最低价格
2023-09-27 06:05:26 +00:00
mapProductMinPrice := make(map[int64]int64)
2023-10-17 07:33:46 +00:00
modelList, err := l.svcCtx.AllModels.FsProductModel3d.GetAllByProductIdsTags(l.ctx, productIds, []int{constants.TAG_MODEL, constants.TAG_PARTS}, "id,size_id,product_id,price,tag,part_id,step_price")
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "get product model list err")
}
if err = l.svcCtx.AllModels.FsProductModel3d.GetProductMinPrice(modelList, mapProductMinPrice); err != nil {
2023-09-27 08:16:33 +00:00
logx.Error(err)
2023-09-27 03:48:15 +00:00
return resp.SetStatusWithMessage(basic.CodeServiceErr, "failed to get product min price")
2023-07-20 09:35:13 +00:00
}
//获取模板(只是获取产品product_id)
2023-08-17 10:19:15 +00:00
productTemplatesV2, err = l.svcCtx.AllModels.FsProductTemplateV2.FindAllByProductIds(l.ctx, productIds, "", "product_id")
2023-07-20 09:35:13 +00:00
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "get product template_v2 err")
}
for _, v := range productTemplatesV2 {
mapProductTemplate[*v.ProductId] = struct{}{}
}
//获取产品尺寸数量
productSizeCountList, err = l.svcCtx.AllModels.FsProductSize.GetGroupProductSizeByStatus(l.ctx, productIds, 1)
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "get product size count err")
}
for _, v := range productSizeCountList {
mapProductSizeCount[v.ProductId] = v.Num
}
2023-08-14 04:30:14 +00:00
//获取产品标签相关属性
productTagPropList, err := l.svcCtx.AllModels.FsProductTagProp.GetTagPropByProductIdsWithProductTag(l.ctx, productIds)
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeDbSqlErr, "failed to get product tag property")
}
2023-09-05 08:35:02 +00:00
for _, v := range productTagPropList {
2023-09-06 06:35:42 +00:00
resourceIds = append(resourceIds, s3url_to_s3id.GetS3ResourceIdFormUrl(*v.Cover))
2023-09-05 08:35:02 +00:00
}
//根据resourceUrls找到对应的元数据
resourceMetadataList, err := l.svcCtx.AllModels.FsResource.FindAllByResourceIds(l.ctx, resourceIds)
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeDbSqlErr, "failed to get resource list")
}
mapResourceMetadata := make(map[string]map[string]interface{})
for _, v := range resourceMetadataList {
var metadata map[string]interface{}
if v.Metadata != nil {
2023-09-07 03:16:01 +00:00
_ = json.Unmarshal(*v.Metadata, &metadata)
2023-09-05 08:35:02 +00:00
}
mapResourceMetadata[*v.ResourceUrl] = metadata
}
2023-08-14 04:30:14 +00:00
mapTagProp := make(map[int64][]types.CoverDefaultItem)
for _, v := range productTagPropList {
mapTagProp[*v.ProductId] = append(mapTagProp[*v.ProductId], types.CoverDefaultItem{
2023-09-06 07:04:51 +00:00
TemplateTag: v.TemplateTag,
2023-09-05 08:35:02 +00:00
Cover: *v.Cover,
CoverMetadata: mapResourceMetadata[*v.Cover],
2023-08-14 04:30:14 +00:00
})
}
2023-07-20 09:35:13 +00:00
//组装返回
2023-07-20 09:47:28 +00:00
listRsp := make([]types.HomePageRecommendProductListRsp, 0, len(recommendProductList))
2023-07-20 09:35:13 +00:00
for _, productInfo := range recommendProductList {
minPrice, ok := mapProductMinPrice[productInfo.Id]
_, tmpOk := mapProductTemplate[productInfo.Id]
//无最小价格则不显示 || 没有模板也不显示
if !ok || !tmpOk {
continue
}
sizeNum := int64(0)
if mapSizeNum, ok := mapProductSizeCount[productInfo.Id]; ok {
sizeNum = mapSizeNum
}
//有无可选配件
haveOptionalFitting := false
if _, ok = mapProductHaveOptionFitting[productInfo.Id]; ok {
haveOptionalFitting = true
}
2023-07-20 09:47:28 +00:00
item := types.HomePageRecommendProductListRsp{
2023-07-24 10:08:19 +00:00
Id: productInfo.Id,
2023-07-20 09:35:13 +00:00
Sn: *productInfo.Sn,
Title: *productInfo.Title,
2023-08-14 03:46:29 +00:00
Cover: *productInfo.Cover,
2023-09-05 08:35:02 +00:00
CoverMetadata: mapResourceMetadata[*productInfo.Cover],
2023-08-14 04:31:49 +00:00
CoverDefault: []types.CoverDefaultItem{},
2023-07-20 09:35:13 +00:00
SizeNum: uint32(sizeNum),
2023-07-24 02:30:08 +00:00
MinPrice: minPrice,
2023-07-20 09:35:13 +00:00
HaveOptionalFitting: haveOptionalFitting,
2023-09-07 10:28:19 +00:00
IsCustomization: *productInfo.IsCustomization,
2023-07-20 09:35:13 +00:00
}
2023-08-14 04:30:14 +00:00
if _, ok = mapTagProp[productInfo.Id]; ok {
item.CoverDefault = mapTagProp[productInfo.Id]
}
2023-07-20 09:35:13 +00:00
//加入分类产品切片
listRsp = append(listRsp, item)
}
return resp.SetStatusWithMessage(basic.CodeOK, "success", listRsp)
}