Merge branch 'develop' of https://gitee.com/fusenpack/fusenapi into develop

This commit is contained in:
eson 2023-06-06 17:31:45 +08:00
commit b8790b7f79
30 changed files with 899 additions and 669 deletions

View File

@ -0,0 +1,8 @@
package constants
// api接口code响应码
const (
CODE_UNAUTH = 401 //未授权
CODE_SERVICE_ERR = 510 //内部代码错误
CODE_OK = 200 //ok
)

View File

@ -0,0 +1,271 @@
package constants
// 产品列表demo
const PRODUCT_LIST_DEMO = `{
"ob": {
"items": [
{
"id": 25,
"sn": "P1ELZGHU",
"title": "Packing box",
"cover": "/icon/icon_25_800.png",
"intro": "打包盒卡纸",
"cover_img": "/uploads/ognhdc6q_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 5,
"miniPrice": 2
},
{
"id": 28,
"sn": "P9KVYAUS",
"title": "Pizza box",
"cover": "/icon/9dmom0g7_800.png",
"intro": "披萨盒 瓦楞纸",
"cover_img": "/uploads/9xf1olkl_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 1,
"miniPrice": 2
},
{
"id": 30,
"sn": "PZWDSROX",
"title": "Paper bag with handle",
"cover": "/icon/iz44vraw_800.png",
"intro": "有提手纸袋牛皮纸",
"cover_img": "/uploads/rpwntxcq_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 4,
"miniPrice": 2
},
{
"id": 20,
"sn": "PNACHNUK",
"title": "Four cups of milk tea cup",
"cover": "/icon/plz43wpo_800.png",
"intro": "卡纸",
"cover_img": "/uploads/9tqgsjqi_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 2,
"miniPrice": 2
},
{
"id": 19,
"sn": "PHHVEXRW",
"title": "Milk tea cup holder double cup",
"cover": "/icon/ipohmmcj_800.png",
"intro": "奶茶杯托奶茶杯托两杯袋",
"cover_img": "/uploads/57ogzeq5_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 5,
"miniPrice": 2
},
{
"id": 11,
"sn": "P7N4D0MK",
"title": "Cup double layer",
"cover": "/icon/nrmzz4du_800.png",
"intro": "牛皮纸双层",
"cover_img": "/uploads/oqjm5own_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 5,
"miniPrice": 2
},
{
"id": 33,
"sn": "P0NFP19Y",
"title": "High paper bowl",
"cover": "/icon/cla4k6om_800.png",
"intro": "牛皮纸",
"cover_img": "/uploads/dt1qjkzg_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 4,
"miniPrice": 2
},
{
"id": 32,
"sn": "PDZ3HIUL",
"title": "Flat paper bowl",
"cover": "/icon/jy14adqz_800.png",
"intro": "牛皮纸",
"cover_img": "/uploads/bzwbxduc_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 3,
"miniPrice": 2
},
{
"id": 31,
"sn": "PEVSMU7I",
"title": "Paper bag without handle",
"cover": "/icon/osdsegor_800.png",
"intro": "牛皮纸",
"cover_img": "/uploads/ouvayny7_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 2,
"miniPrice": 2
},
{
"id": 29,
"sn": "P58ZZOTI",
"title": "plastic bag",
"cover": "/icon/dvsvddks_800.png",
"intro": "塑料袋",
"cover_img": "/uploads/qvvuzkzx_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 1,
"miniPrice": 2
},
{
"id": 24,
"sn": "PG7XIXII",
"title": "Hamburger box",
"cover": "/icon/icon_24_800.png",
"intro": "汉堡盒 卡纸",
"cover_img": "/uploads/fm1itgge_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 4,
"miniPrice": 2
},
{
"id": 23,
"sn": "PIJ2OVUE",
"title": "Milk tea ring portable double cup",
"cover": "/icon/nxb6hjln_800.png",
"intro": "卡纸",
"cover_img": "/uploads/52fash1n_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 4,
"miniPrice": 2
},
{
"id": 21,
"sn": "PMHXGUL6",
"title": "Milk tea ring portable single cup",
"cover": "/icon/qoaf5mtp_800.png",
"intro": "卡纸",
"cover_img": "/uploads/epvkzvyf_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 5,
"miniPrice": 2
},
{
"id": 18,
"sn": "PFCM8KNF",
"title": "Tableware set chopsticks",
"cover": "/icon/tcspod4b_800.png",
"intro": "餐具套装筷子厚牛皮纸包装",
"cover_img": "/uploads/5jgrgzvh_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 3,
"miniPrice": 2
},
{
"id": 17,
"sn": "PQKIQMIK",
"title": "Tableware set four piece set",
"cover": "/icon/mdo0vu1u_800.png",
"intro": "牛皮纸包装",
"cover_img": "/uploads/szsekvbw_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 4,
"miniPrice": 2
},
{
"id": 16,
"sn": "PBFOIOFH",
"title": "Tableware set four piece set",
"cover": "/icon/dzrf59cp_800.png",
"intro": "餐具套装",
"cover_img": "/uploads/svfoebf1_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 1,
"miniPrice": 2
},
{
"id": 15,
"sn": "P02V10AB",
"title": " Hot drink cup holder",
"cover": "/icon/icon_15_800.png",
"intro": "杯托、瓦楞纸",
"cover_img": "/uploads/4qbdid7i_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 5,
"miniPrice": 2
},
{
"id": 13,
"sn": "PER6WLAV",
"title": " Cup pet",
"cover": "/icon/icon_13_800.png",
"intro": "pet",
"cover_img": "/uploads/kfxehwjd_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 1,
"miniPrice": 2
},
{
"id": 12,
"sn": "PGFWRMAU",
"title": " Cup PP",
"cover": "/icon/icon_12_800.png",
"intro": "pp",
"cover_img": "/uploads/azp8uwhz_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 2,
"miniPrice": 2
},
{
"id": 10,
"sn": "P4ZXDVHS",
"title": "Cup monolayer",
"cover": "/icon/icon_10_800.png",
"intro": "牛皮纸单层",
"cover_img": "/uploads/onuzax6l_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 1,
"miniPrice": 2
}
],
"_links": {
"self": {
"href": "https://fusenapi.kayue.cn:8010/product/list?cid=13&size=620&page=1&is_demo=1"
},
"first": {
"href": "https://fusenapi.kayue.cn:8010/product/list?cid=13&size=620&page=1&is_demo=1"
},
"last": {
"href": "https://fusenapi.kayue.cn:8010/product/list?cid=13&size=620&page=2&is_demo=1"
},
"next": {
"href": "https://fusenapi.kayue.cn:8010/product/list?cid=13&size=620&page=2&is_demo=1"
}
},
"_meta": {
"totalCount": 21,
"pageCount": 2,
"currentPage": 1,
"perPage": 20
}
},
"typeName": "Boxes",
"description": ""
}`

View File

@ -0,0 +1,5 @@
package constants
const TAG_MODEL = 1 //模型
const TAG_PARTS = 2 //配件
const TAG_SCENE = 3 //场景

View File

@ -0,0 +1,10 @@
-- fusentest.fs_product_model3d_light definition
CREATE TABLE `fs_product_model3d_light` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT,
`name` varchar(255) NOT NULL COMMENT '灯光名称',
`info` text NOT NULL COMMENT '灯光数据json格式',
`status` tinyint(1) NOT NULL DEFAULT '1' COMMENT '状态值1显示0删除',
`ctime` int(11) DEFAULT NULL COMMENT '创建时间',
PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=58 DEFAULT CHARSET=utf8mb4 ROW_FORMAT=COMPACT COMMENT='模型-灯光组表';

View File

@ -0,0 +1,9 @@
-- fusentest.fs_product_template_tags definition
CREATE TABLE `fs_product_template_tags` (
`id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT 'ID',
`title` varchar(25) NOT NULL COMMENT '标题',
`status` tinyint(1) unsigned NOT NULL COMMENT '状态 1可用',
`create_at` int(10) unsigned NOT NULL COMMENT '创建时间',
PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=17 DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT COMMENT=' 模板标签表';

View File

@ -42,7 +42,7 @@ func (resp *Response) SetStatus(sr *basic.StatusResponse, data ...interface{}) {
resp.Message = sr.Message
if len(data) == 1 {
resp.Data = data[0]
}
}
}
// SetStatusWithMessage 设置默认StatusResponse(内部自定义) 非默认msg, 可以带data, data只使用一个参数
@ -51,5 +51,5 @@ func (resp *Response) SetStatusWithMessage(sr *basic.StatusResponse, msg string,
resp.Message = msg
if len(data) == 1 {
resp.Data = data[0]
}
}
}

View File

@ -0,0 +1,24 @@
package model
import "github.com/zeromicro/go-zero/core/stores/sqlx"
var _ FsProductModel3dLightModel = (*customFsProductModel3dLightModel)(nil)
type (
// FsProductModel3dLightModel is an interface to be customized, add more methods here,
// and implement the added methods in customFsProductModel3dLightModel.
FsProductModel3dLightModel interface {
fsProductModel3dLightModel
}
customFsProductModel3dLightModel struct {
*defaultFsProductModel3dLightModel
}
)
// NewFsProductModel3dLightModel returns a model for the database table.
func NewFsProductModel3dLightModel(conn sqlx.SqlConn) FsProductModel3dLightModel {
return &customFsProductModel3dLightModel{
defaultFsProductModel3dLightModel: newFsProductModel3dLightModel(conn),
}
}

View File

@ -0,0 +1,88 @@
// Code generated by goctl. DO NOT EDIT.
package model
import (
"context"
"database/sql"
"fmt"
"strings"
"github.com/zeromicro/go-zero/core/stores/builder"
"github.com/zeromicro/go-zero/core/stores/sqlc"
"github.com/zeromicro/go-zero/core/stores/sqlx"
"github.com/zeromicro/go-zero/core/stringx"
)
var (
fsProductModel3dLightFieldNames = builder.RawFieldNames(&FsProductModel3dLight{})
fsProductModel3dLightRows = strings.Join(fsProductModel3dLightFieldNames, ",")
fsProductModel3dLightRowsExpectAutoSet = strings.Join(stringx.Remove(fsProductModel3dLightFieldNames, "`id`", "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), ",")
fsProductModel3dLightRowsWithPlaceHolder = strings.Join(stringx.Remove(fsProductModel3dLightFieldNames, "`id`", "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), "=?,") + "=?"
)
type (
fsProductModel3dLightModel interface {
Insert(ctx context.Context, data *FsProductModel3dLight) (sql.Result, error)
FindOne(ctx context.Context, id int64) (*FsProductModel3dLight, error)
Update(ctx context.Context, data *FsProductModel3dLight) error
Delete(ctx context.Context, id int64) error
ListByIds(ctx context.Context, ids []string) (resp []FsProductModel3dLight, err error)
}
defaultFsProductModel3dLightModel struct {
conn sqlx.SqlConn
table string
}
FsProductModel3dLight struct {
Id int64 `db:"id"`
Name string `db:"name"` // 灯光名称
Info string `db:"info"` // 灯光数据json格式
Status int64 `db:"status"` // 状态值1显示0删除
Ctime sql.NullInt64 `db:"ctime"` // 创建时间
}
)
func newFsProductModel3dLightModel(conn sqlx.SqlConn) *defaultFsProductModel3dLightModel {
return &defaultFsProductModel3dLightModel{
conn: conn,
table: "`fs_product_model3d_light`",
}
}
func (m *defaultFsProductModel3dLightModel) Delete(ctx context.Context, id int64) error {
query := fmt.Sprintf("delete from %s where `id` = ?", m.table)
_, err := m.conn.ExecCtx(ctx, query, id)
return err
}
func (m *defaultFsProductModel3dLightModel) FindOne(ctx context.Context, id int64) (*FsProductModel3dLight, error) {
query := fmt.Sprintf("select %s from %s where `id` = ? limit 1", fsProductModel3dLightRows, m.table)
var resp FsProductModel3dLight
err := m.conn.QueryRowCtx(ctx, &resp, query, id)
switch err {
case nil:
return &resp, nil
case sqlc.ErrNotFound:
return nil, ErrNotFound
default:
return nil, err
}
}
func (m *defaultFsProductModel3dLightModel) Insert(ctx context.Context, data *FsProductModel3dLight) (sql.Result, error) {
query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?)", m.table, fsProductModel3dLightRowsExpectAutoSet)
ret, err := m.conn.ExecCtx(ctx, query, data.Name, data.Info, data.Status, data.Ctime)
return ret, err
}
func (m *defaultFsProductModel3dLightModel) Update(ctx context.Context, data *FsProductModel3dLight) error {
query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, fsProductModel3dLightRowsWithPlaceHolder)
_, err := m.conn.ExecCtx(ctx, query, data.Name, data.Info, data.Status, data.Ctime, data.Id)
return err
}
func (m *defaultFsProductModel3dLightModel) tableName() string {
return m.table
}

View File

@ -95,14 +95,7 @@ func (m *defaultFsProductModel3dModel) Update(ctx context.Context, data *FsProdu
_, err := m.conn.ExecCtx(ctx, query, data.ProductId, data.Tag, data.Title, data.Name, data.ModelInfo, data.MaterialId, data.SizeId, data.Sort, data.Light, data.LightList, data.PartId, data.PartList, data.Status, data.Ctime, data.OptionTemplate, data.Price, data.Sku, data.Id)
return err
}
func (m *defaultFsProductModel3dModel) ListBySizeIdsTag(ctx context.Context, sizeIds []string, tag int) (resp []FsProductModel3d, err error) {
query := fmt.Sprintf("select %s from %s where `size_id` in (?) and `tag` = ?", fsProductModel3dRows, m.table)
err = m.conn.QueryRowsCtx(ctx, &resp, query, strings.Join(sizeIds, ","), tag)
if err != nil {
return nil, err
}
return
}
func (m *defaultFsProductModel3dModel) tableName() string {
return m.table
}

View File

@ -29,6 +29,7 @@ type (
Update(ctx context.Context, data *FsProduct) error
Delete(ctx context.Context, id int64) error
GetProductListByConditions(ctx context.Context, productType int, isDel int, isShelf int, sort string) ([]FsProduct, error)
GetAllProductList(ctx context.Context, isDel int, isShelf int, sort string) (resp []FsProduct, err error)
}
defaultFsProductModel struct {
@ -122,24 +123,6 @@ func (m *defaultFsProductModel) Update(ctx context.Context, newData *FsProduct)
return err
}
func (m *defaultFsProductModel) GetProductListByConditions(ctx context.Context, productType int, isDel int, isShelf int, sort string) (resp []FsProduct, err error) {
query := fmt.Sprintf("select %s from %s where `type` = ? and `is_del` =? and `is_shelf` = ?",
fsProductRows, m.table)
switch sort {
case "sort-asc":
query = fmt.Sprintf("%s order by sort ASC", query)
case "sort-desc":
query = fmt.Sprintf("%s order by sort DESC", query)
default:
query = fmt.Sprintf("%s order by sort DESC", query)
}
err = m.conn.QueryRowsCtx(ctx, &resp, query, productType, isDel, isShelf)
if err != nil {
return nil, err
}
return
}
func (m *defaultFsProductModel) tableName() string {
return m.table
}

View File

@ -106,18 +106,6 @@ func (m *defaultFsProductPriceModel) Update(ctx context.Context, newData *FsProd
return err
}
type GetPriceListRsp struct {
ProductId int64 `json:"product_id"`
Price string `json:"price"`
}
func (m *defaultFsProductPriceModel) GetPriceList(ctx context.Context, productIds []string) (resp []GetPriceListRsp, err error) {
query := fmt.Sprintf("select %s from %s where `product_id` in (?) and `status` = ? group by product_id", "product_id,group_concat(step_price) as price ", m.table)
if err = m.conn.QueryRowsCtx(ctx, &resp, query, strings.Join(productIds, ","), 1); err != nil {
return nil, err
}
return
}
func (m *defaultFsProductPriceModel) tableName() string {
return m.table
}

View File

@ -88,28 +88,7 @@ func (m *defaultFsProductSizeModel) Update(ctx context.Context, data *FsProductS
_, err := m.conn.ExecCtx(ctx, query, data.ProductId, data.Title, data.Cover, data.CoverImg, data.Capacity, data.Status, data.Sort, data.Remark, data.PartsCanDeleted, data.Id)
return err
}
func (m *defaultFsProductSizeModel) CountByStatus(ctx context.Context, status int) (total int, err error) {
query := fmt.Sprintf("select %s from %s where `status` = ? limit 1", "count(*) as num", m.table)
err = m.conn.QueryRowCtx(ctx, &total, query, status)
if err != nil {
return 0, err
}
return
}
func (m *defaultFsProductSizeModel) FindAllByStatus(ctx context.Context, status int, sort int) (resp []FsProductSize, err error) {
query := fmt.Sprintf("select %s from %s where `status` = ? ", fsProductSizeRows, m.table)
switch sort {
case 1:
query = fmt.Sprintf("%s order by `sort` ASC", query)
case 2:
query = fmt.Sprintf("%s order by `sort` DESC", query)
}
err = m.conn.QueryRowsCtx(ctx, &resp, query, status)
if err != nil {
return nil, err
}
return
}
func (m *defaultFsProductSizeModel) tableName() string {
return m.table
}

View File

@ -0,0 +1,24 @@
package model
import "github.com/zeromicro/go-zero/core/stores/sqlx"
var _ FsProductTemplateTagsModel = (*customFsProductTemplateTagsModel)(nil)
type (
// FsProductTemplateTagsModel is an interface to be customized, add more methods here,
// and implement the added methods in customFsProductTemplateTagsModel.
FsProductTemplateTagsModel interface {
fsProductTemplateTagsModel
}
customFsProductTemplateTagsModel struct {
*defaultFsProductTemplateTagsModel
}
)
// NewFsProductTemplateTagsModel returns a model for the database table.
func NewFsProductTemplateTagsModel(conn sqlx.SqlConn) FsProductTemplateTagsModel {
return &customFsProductTemplateTagsModel{
defaultFsProductTemplateTagsModel: newFsProductTemplateTagsModel(conn),
}
}

View File

@ -0,0 +1,87 @@
// Code generated by goctl. DO NOT EDIT.
package model
import (
"context"
"database/sql"
"fmt"
"strings"
"github.com/zeromicro/go-zero/core/stores/builder"
"github.com/zeromicro/go-zero/core/stores/sqlc"
"github.com/zeromicro/go-zero/core/stores/sqlx"
"github.com/zeromicro/go-zero/core/stringx"
)
var (
fsProductTemplateTagsFieldNames = builder.RawFieldNames(&FsProductTemplateTags{})
fsProductTemplateTagsRows = strings.Join(fsProductTemplateTagsFieldNames, ",")
fsProductTemplateTagsRowsExpectAutoSet = strings.Join(stringx.Remove(fsProductTemplateTagsFieldNames, "`id`", "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), ",")
fsProductTemplateTagsRowsWithPlaceHolder = strings.Join(stringx.Remove(fsProductTemplateTagsFieldNames, "`id`", "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), "=?,") + "=?"
)
type (
fsProductTemplateTagsModel interface {
Insert(ctx context.Context, data *FsProductTemplateTags) (sql.Result, error)
FindOne(ctx context.Context, id int64) (*FsProductTemplateTags, error)
Update(ctx context.Context, data *FsProductTemplateTags) error
Delete(ctx context.Context, id int64) error
ListByIds(ctx context.Context, ids []string) (resp []FsProductTemplateTags, err error)
}
defaultFsProductTemplateTagsModel struct {
conn sqlx.SqlConn
table string
}
FsProductTemplateTags struct {
Id int64 `db:"id"` // ID
Title string `db:"title"` // 标题
Status int64 `db:"status"` // 状态 1可用
CreateAt int64 `db:"create_at"` // 创建时间
}
)
func newFsProductTemplateTagsModel(conn sqlx.SqlConn) *defaultFsProductTemplateTagsModel {
return &defaultFsProductTemplateTagsModel{
conn: conn,
table: "`fs_product_template_tags`",
}
}
func (m *defaultFsProductTemplateTagsModel) Delete(ctx context.Context, id int64) error {
query := fmt.Sprintf("delete from %s where `id` = ?", m.table)
_, err := m.conn.ExecCtx(ctx, query, id)
return err
}
func (m *defaultFsProductTemplateTagsModel) FindOne(ctx context.Context, id int64) (*FsProductTemplateTags, error) {
query := fmt.Sprintf("select %s from %s where `id` = ? limit 1", fsProductTemplateTagsRows, m.table)
var resp FsProductTemplateTags
err := m.conn.QueryRowCtx(ctx, &resp, query, id)
switch err {
case nil:
return &resp, nil
case sqlc.ErrNotFound:
return nil, ErrNotFound
default:
return nil, err
}
}
func (m *defaultFsProductTemplateTagsModel) Insert(ctx context.Context, data *FsProductTemplateTags) (sql.Result, error) {
query := fmt.Sprintf("insert into %s (%s) values (?, ?)", m.table, fsProductTemplateTagsRowsExpectAutoSet)
ret, err := m.conn.ExecCtx(ctx, query, data.Title, data.Status)
return ret, err
}
func (m *defaultFsProductTemplateTagsModel) Update(ctx context.Context, data *FsProductTemplateTags) error {
query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, fsProductTemplateTagsRowsWithPlaceHolder)
_, err := m.conn.ExecCtx(ctx, query, data.Title, data.Status, data.Id)
return err
}
func (m *defaultFsProductTemplateTagsModel) tableName() string {
return m.table
}

View File

@ -29,6 +29,7 @@ type (
Delete(ctx context.Context, id int64) error
FindAllByCondition(ctx context.Context, productIds []string) (resp []FsProductTemplateV2, err error)
FindAllByModelIdsProduct(ctx context.Context, modelIds []string, productId int64, sort int) (resp []FsProductTemplateV2, err error)
FindAllByModelIds(ctx context.Context, modelIds []string, sort int) (resp []FsProductTemplateV2, err error)
}
defaultFsProductTemplateV2Model struct {
@ -94,26 +95,6 @@ func (m *defaultFsProductTemplateV2Model) Update(ctx context.Context, data *FsPr
_, err := m.conn.ExecCtx(ctx, query, data.ProductId, data.ModelId, data.Title, data.Name, data.CoverImg, data.TemplateInfo, data.MaterialImg, data.Sort, data.LogoWidth, data.LogoHeight, data.IsPublic, data.Status, data.Ctime, data.Tag, data.IsDel, data.Id)
return err
}
func (m *defaultFsProductTemplateV2Model) FindAllByCondition(ctx context.Context, productIds []string) (resp []FsProductTemplateV2, err error) {
query := fmt.Sprintf("select %s from %s where `id` in (?) and `is_del` = ? and `status` = ?", fsProductTemplateV2Rows, m.table)
if err = m.conn.QueryRowsCtx(ctx, &resp, query, strings.Join(productIds, ","), 0, 1); err != nil {
return nil, err
}
return
}
func (m *defaultFsProductTemplateV2Model) FindAllByModelIdsProduct(ctx context.Context, modelIds []string, productId int64, sort int) (resp []FsProductTemplateV2, err error) {
query := fmt.Sprintf("select %s from %s where `model_id` in (?) and `product_id` = ? and `is_del` = ? and `status` = ?", fsProductTemplateV2Rows, m.table)
switch sort {
case 1:
query = fmt.Sprintf("%s order by `sort` ASC")
case 2:
query = fmt.Sprintf("%s order by `sort` DESC")
}
if err = m.conn.QueryRowsCtx(ctx, &resp, query, strings.Join(modelIds, ","), productId, 0, 1); err != nil {
return nil, err
}
return
}
func (m *defaultFsProductTemplateV2Model) tableName() string {
return m.table
}

43
model/self_fsproductmodel.go Executable file
View File

@ -0,0 +1,43 @@
// Code generated by goctl. DO NOT EDIT.
package model
import (
"context"
"fmt"
)
func (m *defaultFsProductModel) GetProductListByConditions(ctx context.Context, productType int, isDel int, isShelf int, sort string) (resp []FsProduct, err error) {
query := fmt.Sprintf("select %s from %s where `type` = ? and `is_del` =? and `is_shelf` = ?",
fsProductRows, m.table)
switch sort {
case "sort-asc":
query = fmt.Sprintf("%s order by sort ASC", query)
case "sort-desc":
query = fmt.Sprintf("%s order by sort DESC", query)
default:
query = fmt.Sprintf("%s order by sort DESC", query)
}
err = m.conn.QueryRowsCtx(ctx, &resp, query, productType, isDel, isShelf)
if err != nil {
return nil, err
}
return
}
func (m *defaultFsProductModel) GetAllProductList(ctx context.Context, isDel int, isShelf int, sort string) (resp []FsProduct, err error) {
query := fmt.Sprintf("select %s from %s where `is_del` =? and `is_shelf` = ?",
fsProductRows, m.table)
switch sort {
case "sort-asc":
query = fmt.Sprintf("%s order by sort ASC", query)
case "sort-desc":
query = fmt.Sprintf("%s order by sort DESC", query)
default:
query = fmt.Sprintf("%s order by sort DESC", query)
}
err = m.conn.QueryRowsCtx(ctx, &resp, query, isDel, isShelf)
if err != nil {
return nil, err
}
return
}

View File

@ -0,0 +1,18 @@
// Code generated by goctl. DO NOT EDIT.
package model
import (
"context"
"fmt"
"strings"
)
func (m *defaultFsProductModel3dLightModel) ListByIds(ctx context.Context, ids []string) (resp []FsProductModel3dLight, err error) {
query := fmt.Sprintf("select %s from %s where `id` in (?)", fsProductModel3dLightRows, m.table)
err = m.conn.QueryRowsCtx(ctx, &resp, query, strings.Join(ids, ","))
if err != nil {
return nil, err
}
return
}

View File

@ -0,0 +1,21 @@
// Code generated by goctl. DO NOT EDIT.
package model
import (
"context"
"fmt"
"strings"
)
func (m *defaultFsProductModel3dModel) ListBySizeIdsTag(ctx context.Context, sizeIds []string, tag int) (resp []FsProductModel3d, err error) {
if len(sizeIds) == 0 {
return nil, nil
}
query := fmt.Sprintf("select %s from %s where `size_id` in (?) and `tag` = ?", fsProductModel3dRows, m.table)
err = m.conn.QueryRowsCtx(ctx, &resp, query, strings.Join(sizeIds, ","), tag)
if err != nil {
return nil, err
}
return
}

View File

@ -0,0 +1,26 @@
// Code generated by goctl. DO NOT EDIT.
package model
import (
"context"
"fmt"
"strings"
)
type GetPriceListRsp struct {
ProductId int64 `json:"product_id"`
Price string `json:"price"`
}
func (m *defaultFsProductPriceModel) GetPriceList(ctx context.Context, productIds []string) (resp []GetPriceListRsp, err error) {
if len(productIds) == 0 {
return nil, nil
}
query := fmt.Sprintf("select %s from %s where `product_id` in (?) and `status` = ? group by product_id", "product_id,group_concat(step_price) as price ", m.table)
if err = m.conn.QueryRowsCtx(ctx, &resp, query, strings.Join(productIds, ","), 1); err != nil {
return nil, err
}
return
}

View File

@ -0,0 +1,31 @@
// Code generated by goctl. DO NOT EDIT.
package model
import (
"context"
"fmt"
)
func (m *defaultFsProductSizeModel) CountByStatus(ctx context.Context, status int) (total int, err error) {
query := fmt.Sprintf("select %s from %s where `status` = ? limit 1", "count(*) as num", m.table)
err = m.conn.QueryRowCtx(ctx, &total, query, status)
if err != nil {
return 0, err
}
return
}
func (m *defaultFsProductSizeModel) FindAllByStatus(ctx context.Context, status int, sort int) (resp []FsProductSize, err error) {
query := fmt.Sprintf("select %s from %s where `status` = ? ", fsProductSizeRows, m.table)
switch sort {
case 1:
query = fmt.Sprintf("%s order by `sort` ASC", query)
case 2:
query = fmt.Sprintf("%s order by `sort` DESC", query)
}
err = m.conn.QueryRowsCtx(ctx, &resp, query, status)
if err != nil {
return nil, err
}
return
}

View File

@ -0,0 +1,20 @@
// Code generated by goctl. DO NOT EDIT.
package model
import (
"context"
"fmt"
)
func (m *defaultFsProductTemplateTagsModel) ListByIds(ctx context.Context, ids []string) (resp []FsProductTemplateTags, err error) {
if len(ids) == 0 {
return nil, nil
}
query := fmt.Sprintf("select %s from %s where `id` in (?) ", fsProductTemplateTagsRows, m.table)
err = m.conn.QueryRowsCtx(ctx, &resp, query, ids)
if err != nil {
return nil, err
}
return
}

View File

@ -0,0 +1,50 @@
// Code generated by goctl. DO NOT EDIT.
package model
import (
"context"
"fmt"
"strings"
)
func (m *defaultFsProductTemplateV2Model) FindAllByCondition(ctx context.Context, productIds []string) (resp []FsProductTemplateV2, err error) {
query := fmt.Sprintf("select %s from %s where `id` in (?) and `is_del` = ? and `status` = ?", fsProductTemplateV2Rows, m.table)
if err = m.conn.QueryRowsCtx(ctx, &resp, query, strings.Join(productIds, ","), 0, 1); err != nil {
return nil, err
}
return
}
func (m *defaultFsProductTemplateV2Model) FindAllByModelIdsProduct(ctx context.Context, modelIds []string, productId int64, sort int) (resp []FsProductTemplateV2, err error) {
if len(modelIds) == 0 {
return
}
query := fmt.Sprintf("select %s from %s where `model_id` in (?) and `product_id` = ? and `is_del` = ? and `status` = ?", fsProductTemplateV2Rows, m.table)
switch sort {
case 1:
query = fmt.Sprintf("%s order by `sort` ASC", query)
case 2:
query = fmt.Sprintf("%s order by `sort` DESC", query)
}
if err = m.conn.QueryRowsCtx(ctx, &resp, query, strings.Join(modelIds, ","), productId, 0, 1); err != nil {
return nil, err
}
return
}
func (m *defaultFsProductTemplateV2Model) FindAllByModelIds(ctx context.Context, modelIds []string, sort int) (resp []FsProductTemplateV2, err error) {
if len(modelIds) == 0 {
return
}
query := fmt.Sprintf("select %s from %s where `model_id` in (?) and `is_del` = ? and `status` = ?", fsProductTemplateV2Rows, m.table)
switch sort {
case 1:
query = fmt.Sprintf("%s order by `sort` ASC", query)
case 2:
query = fmt.Sprintf("%s order by `sort` DESC", query)
}
if err = m.conn.QueryRowsCtx(ctx, &resp, query, strings.Join(modelIds, ","), 0, 1); err != nil {
return nil, err
}
return
}

3
model/self_fstagsmodel.go Executable file
View File

@ -0,0 +1,3 @@
// Code generated by goctl. DO NOT EDIT.
package model

View File

@ -13,11 +13,11 @@ import (
"fusenapi/product/internal/types"
)
func GetProductInfoHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
func GetSuccessRecommandHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
return func(w http.ResponseWriter, r *http.Request) {
//用户登录信息
userInfo := auth.CheckAuth(r)
var req types.GetProductInfoReq
var req types.GetSuccessRecommandReq
if err := httpx.Parse(r, &req); err != nil {
httpx.OkJsonCtx(r.Context(), w, &types.Response{
Code: 510,
@ -26,8 +26,9 @@ func GetProductInfoHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
logx.Info(err)
return
}
l := logic.NewGetProductInfoLogic(r.Context(), svcCtx)
resp := l.GetProductInfo(&req, userInfo)
l := logic.NewGetSuccessRecommandLogic(r.Context(), svcCtx)
resp := l.GetSuccessRecommand(&req, userInfo)
if resp != nil {
httpx.OkJsonCtx(r.Context(), w, resp)
} else {

View File

@ -19,8 +19,8 @@ func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) {
},
{
Method: http.MethodGet,
Path: "/product/info",
Handler: GetProductInfoHandler(serverCtx),
Path: "/product/success-recommand",
Handler: GetSuccessRecommandHandler(serverCtx),
},
},
)

View File

@ -1,88 +0,0 @@
package logic
import (
"context"
"fusenapi/product/internal/svc"
"fusenapi/product/internal/types"
"fusenapi/utils/auth"
"github.com/zeromicro/go-zero/core/logx"
)
type GetProductInfoLogic struct {
logx.Logger
ctx context.Context
svcCtx *svc.ServiceContext
}
func NewGetProductInfoLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetProductInfoLogic {
return &GetProductInfoLogic{
Logger: logx.WithContext(ctx),
ctx: ctx,
svcCtx: svcCtx,
}
}
// 获取产品详情
func (l *GetProductInfoLogic) GetProductInfo(req *types.GetProductInfoReq, loginInfo auth.UserInfo) (resp *types.Response) {
//校验前台登录情况
/*if loginInfo.UserId == 0 {
return &types.Response{Code: 402, Message: "please sign in"}
}
req.Pid = strings.Trim(req.Pid, " ")
req.ClientNo = strings.Trim(req.ClientNo, " ")
if req.Size > 0 {
req.Size = image.GetCurrentSize(req.Size)
}
//获取产品详情
productModel := model.NewFsProductModel(l.svcCtx.MysqlConn)
productInfo, err := productModel.FindOneBySn(l.ctx, req.Pid)
if err != nil && !errors.Is(err, sqlc.ErrNotFound) {
logx.Error(err)
return &types.Response{Code: 510, Message: "failed to get product info"}
}
if productInfo == nil {
return &types.Response{Code: 510, Message: "product not found"}
}
//获取产品标签
tagModel := model.NewFsTagsModel(l.svcCtx.MysqlConn)
tagInfo, err := tagModel.FindOne(l.ctx, productInfo.Type)
if err != nil {
logx.Error(err)
return &types.Response{Code: 510, Message: "failed to get product tag"}
}
//获取产品尺寸列表
productSizeModel := model.NewFsProductSizeModel(l.svcCtx.MysqlConn)
productSizeList, err := productSizeModel.FindAllByStatus(l.ctx, 1, 1)
if err != nil {
logx.Error(err)
return &types.Response{Code: 510, Message: "failed to get product size list"}
}
sizeIds := make([]string, 0, len(productSizeList))
for _, v := range productSizeList {
sizeIds = append(sizeIds, fmt.Sprintf("%d", v.Id))
}
//获取这些尺寸下的模型数据
productModel3dModel := model.NewFsProductModel3dModel(l.svcCtx.MysqlConn)
models, err := productModel3dModel.ListBySizeIdsTag(l.ctx, sizeIds, 1)
if err != nil {
logx.Error(err)
return &types.Response{Code: 510, Message: "failed to get product models"}
}
modelIds := make([]string, 0, len(models))
for _, v := range models {
modelIds = append(modelIds, fmt.Sprintf("%d", v.Id))
}
//通过产品id和模型id获取模板信息
productTemplateV2Model := model.NewFsProductTemplateV2Model(l.svcCtx.MysqlConn)
templateV2List, err := productTemplateV2Model.FindAllByModelIdsProduct(l.ctx, modelIds, productInfo.Id, 2)
if err != nil {
logx.Error(err)
return &types.Response{Code: 510, Message: "failed to get templates"}
}
//获取模板包含的model_id
templateModelIds := make([]string, 0, len(templateV2List))
for _, v := range templateV2List {
templateModelIds = append(templateModelIds, fmt.Sprintf("%d", v.ModelId))
}*/
return
}

View File

@ -36,18 +36,21 @@ func NewGetProductListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *Ge
// 获取产品列表
func (l *GetProductListLogic) GetProductList(req *types.GetProductListReq, loginInfo auth.UserInfo) (resp *types.Response) {
resp = &types.Response{}
//校验前台登录情况
if loginInfo.UserId == 0 {
return &types.Response{Code: 402, Message: "please sign in"}
resp.Set(constants.CODE_UNAUTH, "please sign in")
return
}
//如果是demo
if req.IsDemo == 1 {
var demo types.GetProductListRsp
if err := json.Unmarshal([]byte(l.DemoProductList()), &demo); err != nil {
if err := json.Unmarshal([]byte(constants.PRODUCT_LIST_DEMO), &demo); err != nil {
logx.Error(err)
return &types.Response{Code: 510, Message: "demo data format err"}
resp.Set(constants.CODE_SERVICE_ERR, "demo data format err")
}
return &types.Response{Code: 200, Message: "success", Data: demo}
resp.SetWithData(constants.CODE_OK, "success", demo)
return
}
if req.Page <= 0 {
req.Page = 1
@ -61,22 +64,25 @@ func (l *GetProductListLogic) GetProductList(req *types.GetProductListReq, login
userInfo, err := userModel.FindOne(l.ctx, loginInfo.UserId)
if err != nil && !errors.Is(err, sqlc.ErrNotFound) {
logx.Error(err)
return &types.Response{Code: 510, Message: "get user info err"}
resp.Set(constants.CODE_SERVICE_ERR, "get user info err")
return
}
if userInfo == nil {
return &types.Response{Code: 402, Message: "user not exists"}
resp.Set(constants.CODE_UNAUTH, "user not exists")
return
}
//查询符合的产品列表
productModel := model.NewFsProductModel(l.svcCtx.MysqlConn)
productList, err := productModel.GetProductListByConditions(l.ctx, int(req.Cid), 0, 1, "sort-desc")
if err != nil {
logx.Error(err)
return &types.Response{Code: 510, Message: "failed to get product list"}
resp.Set(constants.CODE_SERVICE_ERR, "failed to get product list")
return
}
fmt.Println(len(productList))
productLen := len(productList)
if productLen == 0 {
return &types.Response{Code: 200, Message: "success"}
resp.Set(constants.CODE_OK, "success")
return
}
//提取产品ids
productIds := make([]string, 0, productLen)
@ -87,7 +93,8 @@ func (l *GetProductListLogic) GetProductList(req *types.GetProductListReq, login
productPriceList, err := productPriceModel.GetPriceList(l.ctx, productIds)
if err != nil {
logx.Error(err)
return &types.Response{Code: 510, Message: "failed to get product min price list"}
resp.Set(constants.CODE_SERVICE_ERR, "failed to get product min price list")
return
}
//存储产品最小价格
mapProductMinPrice := make(map[int64]int64)
@ -96,7 +103,8 @@ func (l *GetProductListLogic) GetProductList(req *types.GetProductListReq, login
priceSlice, err := format.StrSlicToIntSlice(priceStrSlic)
if err != nil {
logx.Error(err)
return &types.Response{Code: 510, Message: err.Error()}
resp.Set(constants.CODE_SERVICE_ERR, err.Error())
return
}
if len(priceSlice) == 0 {
continue
@ -109,7 +117,8 @@ func (l *GetProductListLogic) GetProductList(req *types.GetProductListReq, login
productTemplatesV2, err := productTemplateModel.FindAllByCondition(l.ctx, productIds)
if err != nil {
logx.Error(err)
return &types.Response{Code: 510, Message: "get product template_v2 err"}
resp.Set(constants.CODE_SERVICE_ERR, "get product template_v2 err")
return
}
mapProductTemplate := make(map[int64]struct{})
for _, v := range productTemplatesV2 {
@ -120,7 +129,8 @@ func (l *GetProductListLogic) GetProductList(req *types.GetProductListReq, login
tagInfo, err := tagsModel.FindOne(l.ctx, req.Cid)
if err != nil && !errors.Is(err, sqlc.ErrNotFound) {
logx.Error(err)
return &types.Response{Code: 510, Message: "get classification err "}
resp.Set(constants.CODE_SERVICE_ERR, "get tag err")
return
}
if tagInfo == nil {
return &types.Response{Code: 510, Message: "classification not exists "}
@ -130,7 +140,8 @@ func (l *GetProductListLogic) GetProductList(req *types.GetProductListReq, login
productSizeCount, err := productSizeModel.CountByStatus(l.ctx, 1)
if err != nil {
logx.Error(err)
return &types.Response{Code: 510, Message: "get product size count err "}
resp.Set(constants.CODE_SERVICE_ERR, "get product size count err")
return
}
//拼接返回
itemList := make([]types.Items, 0, productLen)
@ -176,287 +187,10 @@ func (l *GetProductListLogic) GetProductList(req *types.GetProductListReq, login
}
itemList = append(itemList, item)
}
return &types.Response{
Code: 200,
Message: "success",
Data: types.GetProductListRsp{
Ob: types.Ob{
Items: itemList,
},
TypeName: tagInfo.Title,
Description: tagInfo.Description,
}}
resp.SetWithData(constants.CODE_OK, "success", types.GetProductListRsp{
Ob: types.Ob{
Items: itemList,
}, TypeName: tagInfo.Title, Description: tagInfo.Description,
})
return
}
// 样本产品列表
func (l *GetProductListLogic) DemoProductList() string {
return `{
"ob": {
"items": [
{
"id": 25,
"sn": "P1ELZGHU",
"title": "Packing box",
"cover": "/icon/icon_25_800.png",
"intro": "打包盒卡纸",
"cover_img": "/uploads/ognhdc6q_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 5,
"miniPrice": 2
},
{
"id": 28,
"sn": "P9KVYAUS",
"title": "Pizza box",
"cover": "/icon/9dmom0g7_800.png",
"intro": "披萨盒 瓦楞纸",
"cover_img": "/uploads/9xf1olkl_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 1,
"miniPrice": 2
},
{
"id": 30,
"sn": "PZWDSROX",
"title": "Paper bag with handle",
"cover": "/icon/iz44vraw_800.png",
"intro": "有提手纸袋牛皮纸",
"cover_img": "/uploads/rpwntxcq_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 4,
"miniPrice": 2
},
{
"id": 20,
"sn": "PNACHNUK",
"title": "Four cups of milk tea cup",
"cover": "/icon/plz43wpo_800.png",
"intro": "卡纸",
"cover_img": "/uploads/9tqgsjqi_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 2,
"miniPrice": 2
},
{
"id": 19,
"sn": "PHHVEXRW",
"title": "Milk tea cup holder double cup",
"cover": "/icon/ipohmmcj_800.png",
"intro": "奶茶杯托奶茶杯托两杯袋",
"cover_img": "/uploads/57ogzeq5_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 5,
"miniPrice": 2
},
{
"id": 11,
"sn": "P7N4D0MK",
"title": "Cup double layer",
"cover": "/icon/nrmzz4du_800.png",
"intro": "牛皮纸双层",
"cover_img": "/uploads/oqjm5own_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 5,
"miniPrice": 2
},
{
"id": 33,
"sn": "P0NFP19Y",
"title": "High paper bowl",
"cover": "/icon/cla4k6om_800.png",
"intro": "牛皮纸",
"cover_img": "/uploads/dt1qjkzg_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 4,
"miniPrice": 2
},
{
"id": 32,
"sn": "PDZ3HIUL",
"title": "Flat paper bowl",
"cover": "/icon/jy14adqz_800.png",
"intro": "牛皮纸",
"cover_img": "/uploads/bzwbxduc_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 3,
"miniPrice": 2
},
{
"id": 31,
"sn": "PEVSMU7I",
"title": "Paper bag without handle",
"cover": "/icon/osdsegor_800.png",
"intro": "牛皮纸",
"cover_img": "/uploads/ouvayny7_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 2,
"miniPrice": 2
},
{
"id": 29,
"sn": "P58ZZOTI",
"title": "plastic bag",
"cover": "/icon/dvsvddks_800.png",
"intro": "塑料袋",
"cover_img": "/uploads/qvvuzkzx_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 1,
"miniPrice": 2
},
{
"id": 24,
"sn": "PG7XIXII",
"title": "Hamburger box",
"cover": "/icon/icon_24_800.png",
"intro": "汉堡盒 卡纸",
"cover_img": "/uploads/fm1itgge_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 4,
"miniPrice": 2
},
{
"id": 23,
"sn": "PIJ2OVUE",
"title": "Milk tea ring portable double cup",
"cover": "/icon/nxb6hjln_800.png",
"intro": "卡纸",
"cover_img": "/uploads/52fash1n_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 4,
"miniPrice": 2
},
{
"id": 21,
"sn": "PMHXGUL6",
"title": "Milk tea ring portable single cup",
"cover": "/icon/qoaf5mtp_800.png",
"intro": "卡纸",
"cover_img": "/uploads/epvkzvyf_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 5,
"miniPrice": 2
},
{
"id": 18,
"sn": "PFCM8KNF",
"title": "Tableware set chopsticks",
"cover": "/icon/tcspod4b_800.png",
"intro": "餐具套装筷子厚牛皮纸包装",
"cover_img": "/uploads/5jgrgzvh_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 3,
"miniPrice": 2
},
{
"id": 17,
"sn": "PQKIQMIK",
"title": "Tableware set four piece set",
"cover": "/icon/mdo0vu1u_800.png",
"intro": "牛皮纸包装",
"cover_img": "/uploads/szsekvbw_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 4,
"miniPrice": 2
},
{
"id": 16,
"sn": "PBFOIOFH",
"title": "Tableware set four piece set",
"cover": "/icon/dzrf59cp_800.png",
"intro": "餐具套装",
"cover_img": "/uploads/svfoebf1_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 1,
"miniPrice": 2
},
{
"id": 15,
"sn": "P02V10AB",
"title": " Hot drink cup holder",
"cover": "/icon/icon_15_800.png",
"intro": "杯托、瓦楞纸",
"cover_img": "/uploads/4qbdid7i_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 5,
"miniPrice": 2
},
{
"id": 13,
"sn": "PER6WLAV",
"title": " Cup pet",
"cover": "/icon/icon_13_800.png",
"intro": "pet",
"cover_img": "/uploads/kfxehwjd_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 1,
"miniPrice": 2
},
{
"id": 12,
"sn": "PGFWRMAU",
"title": " Cup PP",
"cover": "/icon/icon_12_800.png",
"intro": "pp",
"cover_img": "/uploads/azp8uwhz_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 2,
"miniPrice": 2
},
{
"id": 10,
"sn": "P4ZXDVHS",
"title": "Cup monolayer",
"cover": "/icon/icon_10_800.png",
"intro": "牛皮纸单层",
"cover_img": "/uploads/onuzax6l_800.png",
"isEnv": 1,
"isMicro": 1,
"sizeNum": 1,
"miniPrice": 2
}
],
"_links": {
"self": {
"href": "https://fusenapi.kayue.cn:8010/product/list?cid=13&size=620&page=1&is_demo=1"
},
"first": {
"href": "https://fusenapi.kayue.cn:8010/product/list?cid=13&size=620&page=1&is_demo=1"
},
"last": {
"href": "https://fusenapi.kayue.cn:8010/product/list?cid=13&size=620&page=2&is_demo=1"
},
"next": {
"href": "https://fusenapi.kayue.cn:8010/product/list?cid=13&size=620&page=2&is_demo=1"
}
},
"_meta": {
"totalCount": 21,
"pageCount": 2,
"currentPage": 1,
"perPage": 20
}
},
"typeName": "Boxes",
"description": ""
}`
}

View File

@ -0,0 +1,90 @@
package logic
import (
"context"
"errors"
"fmt"
"fusenapi/constants"
"fusenapi/model"
"fusenapi/product/internal/svc"
"fusenapi/product/internal/types"
"fusenapi/utils/auth"
"fusenapi/utils/image"
"github.com/zeromicro/go-zero/core/stores/sqlx"
"math/rand"
"github.com/zeromicro/go-zero/core/logx"
)
type GetSuccessRecommandLogic struct {
logx.Logger
ctx context.Context
svcCtx *svc.ServiceContext
}
func NewGetSuccessRecommandLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetSuccessRecommandLogic {
return &GetSuccessRecommandLogic{
Logger: logx.WithContext(ctx),
ctx: ctx,
svcCtx: svcCtx,
}
}
func (l *GetSuccessRecommandLogic) GetSuccessRecommand(req *types.GetSuccessRecommandReq, loginInfo auth.UserInfo) (resp *types.Response) {
resp = &types.Response{}
//校验前台登录情况
if loginInfo.UserId == 0 {
resp.Set(constants.CODE_UNAUTH, "please sign in")
return
}
//获取用户信息
userModel := model.NewFsUserModel(l.svcCtx.MysqlConn)
userInfo, err := userModel.FindOne(l.ctx, loginInfo.UserId)
if err != nil && errors.Is(err, sqlx.ErrNotFound) {
logx.Error(err)
resp.Set(constants.CODE_SERVICE_ERR, "failed to get user info")
return
}
if userInfo == nil {
resp.Set(constants.CODE_UNAUTH, "failed to get user info")
return
}
if req.Num == 0 {
req.Num = 8
}
if req.Size > 0 {
req.Size = image.GetCurrentSize(req.Size)
}
//获取所有产品的ids
productModel := model.NewFsProductModel(l.svcCtx.MysqlConn)
productList, err := productModel.GetAllProductList(l.ctx, 0, 1, "sort-asc")
if err != nil {
logx.Error(err)
resp.Set(constants.CODE_SERVICE_ERR, "failed to get product list")
return
}
//没有推荐产品就返回
if len(productList) == 0 {
resp.Set(constants.CODE_OK, "success")
return
}
productIds := make([]string, 0, len(productList))
for _, v := range productList {
productIds = append(productIds, fmt.Sprintf("%d", v.Id))
}
//随机取8个
if len(productIds) > int(req.Num) {
//打乱顺序
indexArr := rand.Perm(len(productIds))
tmpProductIds := make([]string, 0, int(req.Num))
for k, v := range indexArr {
if k == 8 {
break
}
tmpProductIds = append(tmpProductIds, productIds[v])
}
productIds = tmpProductIds
}
return resp
}

View File

@ -56,106 +56,20 @@ type Items struct {
CoverDefault string `json:"coverDefault"`
}
type GetProductInfoReq struct {
Pid string `json:"pid"` //sn
Size uint32 `json:"size"` //图片尺寸
ClientNo string `json:"clientNo"` //页面标识
HaveCloudRendering bool `json:"haveCloudRendering"` //是否显示云渲染开关
type GetSuccessRecommandReq struct {
Num uint32 `form:"num"`
Size uint32 `form:"size"`
Sn string `form:"sn"`
}
type GetProductInfoRsp struct {
Id int64 `json:"id"`
Type int32 `json:"type"`
Title string `json:"title"`
IsEnv uint32 `json:"isEnv"`
IsMicro uint32 `json:"isMicro"`
Materials []Materials `json:"materials"`
Sizes []Sizes `json:"sizes"`
TypeName string `json:"typeName"`
Templates Templates `json:"templates"`
}
type Materials struct {
Id int64 `json:"id"`
Title string `json:"title"`
}
type Sizes struct {
Id int64 `json:"id"`
Title SizeTitle `json:"title"`
Capacity string `json:"capacity"`
Cover string `json:"cover"`
}
type SizeTitle struct {
Cm string `json:"cm"`
Inth string `json:"inth"`
}
type Templates struct {
Ob484 []Ob484 `json:"4_84"`
}
type Ob484 struct {
Id int64 `json:"id"`
Title string `json:"title"`
TemplateData TemplateData `json:"templateData"`
}
type TemplateData struct {
Id int64 `json:"id"`
Cover string `json:"cover"`
Material string `json:"material"`
MaterialList []Material `json:"materialList"`
}
type Material struct {
Id int64 `json:"id"`
Tag string `json:"tag"`
Title string `json:"title"`
Type string `json:"type"`
Text string `json:"text"`
Fill string `json:"fill"`
FontSize int `json:"fontSize"`
FontFamily string `json:"fontFamily"`
IfBr bool `json:"ifBr"`
IfShow bool `json:"ifShow"`
IfGroup bool `json:"ifGroup"`
MaxNum int `json:"maxNum"`
Rotation int `json:"rotation"`
Align string `json:"align"`
VerticalAlign string `json:"verticalAlign"`
Material string `json:"material"`
QRcodeType string `json:"qRcodeType"`
Width int `json:"width"`
Height int `json:"height"`
X int `json:"x"`
Y int `json:"y"`
Opacity int `json:"opacity"`
OptionalColor []OptionalColor `json:"optionalColor"`
ZIndex int `json:"zIndex"`
SvgPath string `json:"svgPath"`
Follow Follow `json:"follow"`
Group []string `json:"group"`
CameraStand CameraStand `json:"cameraStand"`
}
type CameraStand struct {
X int `json:"x"`
Y int `json:"y"`
Z int `json:"z"`
}
type Follow struct {
Fill string `json:"fill"`
IfShow string `json:"ifShow"`
Content string `json:"content"`
}
type OptionalColor struct {
Color string `json:"color"`
Name string `json:"name"`
Default string `json:"default"`
type GetSuccessRecommandRsp struct {
Title string `json:"title"`
Cover string `json:"cover"`
CoverImg string `json:"coverImg"`
Sn string `json:"sn"`
Id int64 `json:"id"`
SkuId int64 `json:"skuId"`
CoverDefault string `json:"coverDefault"`
}
type Response struct {
@ -164,11 +78,6 @@ type Response struct {
Data interface{} `json:"data"`
}
type Auth struct {
AccessSecret string `json:"AccessSecret"`
AccessExpire int `json:"AccessExpire"`
}
// Set 设置Response的Code和Message值
func (resp *Response) Set(Code int, Message string) {
resp.Code = Code

View File

@ -12,14 +12,13 @@ service product {
//获取产品列表
@handler GetProductListHandler
get /product/list(GetProductListReq) returns (response);
//获取产品详情信息
@handler GetProductInfoHandler
get /product/info(GetProductInfoReq) returns (response);
//获取成功后的推荐产品
@handler GetSuccessRecommand
get /product/success-recommand (GetSuccessRecommandReq) returns (response);
}
//获取产品列表
type GetProductListReq {
// TODO: add members here and delete this comment
Cid int64 `form:"cid"`
Size uint32 `form:"size"`
Page uint32 `form:"page"`
@ -63,95 +62,18 @@ type Items {
MiniPrice float64 `json:"miniPrice"`
CoverDefault string `json:"coverDefault"`
}
//获取产品详情
type GetProductInfoReq {
Pid string `json:"pid"` //sn
Size uint32 `json:"size"` //图片尺寸
ClientNo string `json:"clientNo"` //页面标识
HaveCloudRendering bool `json:"haveCloudRendering"` //是否显示云渲染开关
//获取成功后的推荐产品
type GetSuccessRecommandReq {
Num uint32 `form:"num"`
Size uint32 `form:"size"`
Sn string `form:"sn"`
}
type GetProductInfoRsp {
Id int64 `json:"id"`
Type int32 `json:"type"`
Title string `json:"title"`
IsEnv uint32 `json:"isEnv"`
IsMicro uint32 `json:"isMicro"`
Materials []Materials `json:"materials"`
Sizes []Sizes `json:"sizes"`
TypeName string `json:"typeName"`
Templates Templates `json:"templates"`
}
type Materials {
Id int64 `json:"id"`
Title string `json:"title"`
}
type Sizes {
Id int64 `json:"id"`
Title SizeTitle `json:"title"`
Capacity string `json:"capacity"`
Cover string `json:"cover"`
}
type SizeTitle {
Cm string `json:"cm"`
Inth string `json:"inth"`
}
type Templates {
Ob484 []Ob484 `json:"4_84"`
}
type Ob484 {
Id int64 `json:"id"`
Title string `json:"title"`
TemplateData TemplateData `json:"templateData"`
}
type TemplateData {
Id int64 `json:"id"`
Cover string `json:"cover"`
Material string `json:"material"`
MaterialList []Material `json:"materialList"`
}
type Material {
Id int64 `json:"id"`
Tag string `json:"tag"`
Title string `json:"title"`
Type string `json:"type"`
Text string `json:"text"`
Fill string `json:"fill"`
FontSize int `json:"fontSize"`
FontFamily string `json:"fontFamily"`
IfBr bool `json:"ifBr"`
IfShow bool `json:"ifShow"`
IfGroup bool `json:"ifGroup"`
MaxNum int `json:"maxNum"`
Rotation int `json:"rotation"`
Align string `json:"align"`
VerticalAlign string `json:"verticalAlign"`
Material string `json:"material"`
QRcodeType string `json:"qRcodeType"`
Width int `json:"width"`
Height int `json:"height"`
X int `json:"x"`
Y int `json:"y"`
Opacity int `json:"opacity"`
OptionalColor []OptionalColor `json:"optionalColor"`
ZIndex int `json:"zIndex"`
SvgPath string `json:"svgPath"`
Follow Follow `json:"follow"`
Group []string `json:"group"`
CameraStand CameraStand `json:"cameraStand"`
}
type CameraStand {
X int `json:"x"`
Y int `json:"y"`
Z int `json:"z"`
}
type Follow {
Fill string `json:"fill"`
IfShow string `json:"ifShow"`
Content string `json:"content"`
}
type OptionalColor {
Color string `json:"color"`
Name string `json:"name"`
Default string `json:"default"`
type GetSuccessRecommandRsp {
Title string `json:"title"`
Cover string `json:"cover"`
CoverImg string `json:"coverImg"`
Sn string `json:"sn"`
Id int64 `json:"id"`
SkuId int64 `json:"skuId"`
CoverDefault string `json:"coverDefault"`
}