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

177 lines
6.1 KiB
Go
Raw Normal View History

2023-07-11 09:08:19 +00:00
package logic
import (
2023-09-06 04:21:58 +00:00
"encoding/json"
2023-07-11 09:08:19 +00:00
"errors"
2023-08-08 06:31:40 +00:00
"fusenapi/model/gmodel"
2023-07-11 09:08:19 +00:00
"fusenapi/utils/auth"
"fusenapi/utils/basic"
2023-07-20 07:27:17 +00:00
"fusenapi/utils/format"
2023-07-11 09:08:19 +00:00
"fusenapi/utils/image"
2023-09-06 06:35:42 +00:00
"fusenapi/utils/s3url_to_s3id"
2023-07-11 09:08:19 +00:00
"gorm.io/gorm"
2023-07-20 07:27:17 +00:00
"strings"
2023-07-11 09:08:19 +00:00
"context"
"fusenapi/server/product/internal/svc"
"fusenapi/server/product/internal/types"
"github.com/zeromicro/go-zero/core/logx"
)
type GetRecommandProductListLogic struct {
logx.Logger
ctx context.Context
svcCtx *svc.ServiceContext
}
func NewGetRecommandProductListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetRecommandProductListLogic {
return &GetRecommandProductListLogic{
Logger: logx.WithContext(ctx),
ctx: ctx,
svcCtx: svcCtx,
}
}
func (l *GetRecommandProductListLogic) GetRecommandProductList(req *types.GetRecommandProductListReq, userinfo *auth.UserInfo) (resp *basic.Response) {
2023-07-20 06:56:28 +00:00
req.Num = 4 //写死4个
2023-07-11 09:08:19 +00:00
if req.Size > 0 {
2023-08-15 11:43:50 +00:00
req.Size = int32(image.GetCurrentSize(uint32(req.Size)))
2023-07-11 09:08:19 +00:00
}
2023-07-20 06:56:28 +00:00
productInfo, err := l.svcCtx.AllModels.FsProduct.FindOneBySn(l.ctx, req.Sn)
if err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) {
return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "detail`s product is not found")
}
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeDbSqlErr, "failed to get detail product info")
}
2023-08-08 06:31:40 +00:00
var (
recommendProductList []gmodel.FsProduct
)
if productInfo.RecommendProduct != nil && *productInfo.RecommendProduct != "" {
recommendProductIds, err := format.StrSlicToInt64Slice(strings.Split(*productInfo.RecommendProduct, ","))
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "failed to split recommend product ids")
}
recommendProductList, err = l.svcCtx.AllModels.FsProduct.GetProductListByIds(l.ctx, recommendProductIds, "")
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeDbSqlErr, "failed to get recommend product list")
}
2023-07-11 09:08:19 +00:00
}
2023-09-06 04:21:58 +00:00
//资源id集合
resourceIds := make([]string, 0, 50)
2023-07-20 06:56:28 +00:00
//需要填充时需要忽略的id
2023-08-08 06:31:40 +00:00
ignoreProductIds := make([]int64, 0, len(recommendProductList))
2023-07-20 10:04:50 +00:00
productIds := make([]int64, 0, len(recommendProductList))
2023-07-20 06:56:28 +00:00
//在合并之前记住推荐的产品
mapRecommend := make(map[int64]struct{})
for _, v := range recommendProductList {
2023-07-20 10:06:48 +00:00
ignoreProductIds = append(ignoreProductIds, v.Id)
productIds = append(productIds, v.Id)
2023-07-20 06:56:28 +00:00
mapRecommend[v.Id] = struct{}{}
2023-09-06 06:35:42 +00:00
resourceIds = append(resourceIds, s3url_to_s3id.GetS3ResourceIdFormUrl(*v.Cover))
resourceIds = append(resourceIds, s3url_to_s3id.GetS3ResourceIdFormUrl(*v.CoverImg))
2023-07-20 06:56:28 +00:00
}
2023-07-20 10:06:48 +00:00
//小于请求的数量则需要从产品表中随机填补上(不包含上面的产品)
2023-07-20 06:56:28 +00:00
lenRecommendProduct := len(recommendProductList)
if lenRecommendProduct < int(req.Num) {
appendNum := int(req.Num) - lenRecommendProduct
productList, err := l.svcCtx.AllModels.FsProduct.GetIgnoreRandomProductList(l.ctx, appendNum, ignoreProductIds)
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeDbSqlErr, "failed to get product list")
}
//合并列表
2023-07-20 07:27:17 +00:00
for _, v := range productList {
productIds = append(productIds, v.Id)
recommendProductList = append(recommendProductList, v)
}
}
2023-09-27 06:05:26 +00:00
//获取产品最低价
mapProductMinPrice := make(map[int64]int64)
if err = l.svcCtx.AllModels.FsProductModel3d.GetProductMinPrice(l.ctx, productIds, 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.CodeDbSqlErr, "failed to get product min price")
2023-07-20 07:27:17 +00:00
}
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-06 04:21:58 +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-06 04:21:58 +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-06 04:21:58 +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-06 04:21:58 +00:00
Cover: *v.Cover,
CoverMetadata: mapResourceMetadata[*v.Cover],
2023-08-14 04:30:14 +00:00
})
2023-07-11 09:08:19 +00:00
}
2023-07-20 06:56:28 +00:00
list := make([]types.GetRecommandProductListRsp, 0, len(recommendProductList))
for _, v := range recommendProductList {
2023-08-14 04:30:14 +00:00
/*r := image.ThousandFaceImageFormatReq{
2023-07-11 09:08:19 +00:00
Size: int(req.Size),
IsThousandFace: 0,
Cover: *v.Cover,
CoverImg: *v.CoverImg,
CoverDefault: *v.Cover,
ProductId: v.Id,
UserId: userinfo.UserId,
}
if user.Id != 0 {
r.IsThousandFace = int(*user.IsThousandFace)
}
2023-07-20 06:56:28 +00:00
//千人前面处理
2023-08-14 04:30:14 +00:00
image.ThousandFaceImageFormat(&r)*/
2023-07-20 06:56:28 +00:00
isRecommend := int64(0)
if _, ok := mapRecommend[v.Id]; ok {
isRecommend = 1
}
2023-07-20 07:27:17 +00:00
minPrice := int64(0)
if minVal, ok := mapProductMinPrice[v.Id]; ok {
minPrice = minVal
}
2023-08-14 04:30:14 +00:00
item := types.GetRecommandProductListRsp{
2023-09-06 04:21:58 +00:00
Id: v.Id,
Sn: *v.Sn,
Title: *v.Title,
TitleCn: *v.TitleCn,
Cover: *v.Cover,
CoverMetadata: mapResourceMetadata[*v.Cover],
CoverImg: *v.CoverImg,
CoverImgMetadata: mapResourceMetadata[*v.CoverImg],
CoverDefault: []types.CoverDefaultItem{},
Intro: *v.Intro,
IsRecommend: isRecommend,
MinPrice: minPrice,
2023-09-08 09:54:57 +00:00
IsCustomization: *v.IsCustomization,
2023-08-14 04:30:14 +00:00
}
if _, ok := mapTagProp[productInfo.Id]; ok {
item.CoverDefault = mapTagProp[productInfo.Id]
}
list = append(list, item)
2023-07-11 09:08:19 +00:00
}
return resp.SetStatusWithMessage(basic.CodeOK, "success", list)
}