From 5721f0619d302fa0d26772e02d1cce5c0d9af9c5 Mon Sep 17 00:00:00 2001 From: shenzhuan Date: Sat, 8 Oct 2022 19:43:48 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B4=AD=E7=89=A9=E8=BD=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- product-service/.idea/.gitignore | 8 + product-service/.idea/modules.xml | 8 + product-service/.idea/product-service.iml | 13 + product-service/.idea/vcs.xml | 6 + product-service/.idea/watcherTasks.xml | 8 + product-service/client/client.go | 124 ++ product-service/common/jaeger.go | 29 + .../domain/repository/product_repository.go | 86 ++ .../domain/service/product_data_service.go | 40 + product-service/handler/product_handler.go | 98 ++ product-service/proto/product.pb.go | 1037 +++++++++++++++++ product-service/proto/product.pb.micro.go | 211 ++++ product-service/proto/product.proto | 146 +++ user-service/.idea/.gitignore | 8 + user-service/.idea/modules.xml | 8 + user-service/.idea/user-service.iml | 9 + user-service/.idea/vcs.xml | 6 + 17 files changed, 1845 insertions(+) create mode 100644 product-service/.idea/.gitignore create mode 100644 product-service/.idea/modules.xml create mode 100644 product-service/.idea/product-service.iml create mode 100644 product-service/.idea/vcs.xml create mode 100644 product-service/.idea/watcherTasks.xml create mode 100644 product-service/client/client.go create mode 100644 product-service/common/jaeger.go create mode 100644 product-service/domain/repository/product_repository.go create mode 100644 product-service/domain/service/product_data_service.go create mode 100644 product-service/handler/product_handler.go create mode 100644 product-service/proto/product.pb.go create mode 100644 product-service/proto/product.pb.micro.go create mode 100644 product-service/proto/product.proto create mode 100644 user-service/.idea/.gitignore create mode 100644 user-service/.idea/modules.xml create mode 100644 user-service/.idea/user-service.iml create mode 100644 user-service/.idea/vcs.xml diff --git a/product-service/.idea/.gitignore b/product-service/.idea/.gitignore new file mode 100644 index 0000000..13566b8 --- /dev/null +++ b/product-service/.idea/.gitignore @@ -0,0 +1,8 @@ +# Default ignored files +/shelf/ +/workspace.xml +# Editor-based HTTP Client requests +/httpRequests/ +# Datasource local storage ignored files +/dataSources/ +/dataSources.local.xml diff --git a/product-service/.idea/modules.xml b/product-service/.idea/modules.xml new file mode 100644 index 0000000..1c81204 --- /dev/null +++ b/product-service/.idea/modules.xml @@ -0,0 +1,8 @@ + + + + + + + + \ No newline at end of file diff --git a/product-service/.idea/product-service.iml b/product-service/.idea/product-service.iml new file mode 100644 index 0000000..9267579 --- /dev/null +++ b/product-service/.idea/product-service.iml @@ -0,0 +1,13 @@ + + + + + + + + + + + + \ No newline at end of file diff --git a/product-service/.idea/vcs.xml b/product-service/.idea/vcs.xml new file mode 100644 index 0000000..94a25f7 --- /dev/null +++ b/product-service/.idea/vcs.xml @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file diff --git a/product-service/.idea/watcherTasks.xml b/product-service/.idea/watcherTasks.xml new file mode 100644 index 0000000..4aabca4 --- /dev/null +++ b/product-service/.idea/watcherTasks.xml @@ -0,0 +1,8 @@ + + + + + + + \ No newline at end of file diff --git a/product-service/client/client.go b/product-service/client/client.go new file mode 100644 index 0000000..ef6c67e --- /dev/null +++ b/product-service/client/client.go @@ -0,0 +1,124 @@ +package main + +import ( + "context" + consul "github.com/asim/go-micro/plugins/registry/consul/v4" + opentracing2 "github.com/go-micro/plugins/v4/wrapper/trace/opentracing" + "github.com/opentracing/opentracing-go" + "go-micro.dev/v4/web" + "goproduct/common" + "goproduct/proto" + "log" + "strconv" + + "github.com/gin-gonic/gin" + "go-micro.dev/v4" + "go-micro.dev/v4/registry" +) + +// 获取远程服务的客户端 +func main() { + router := gin.Default() + + router.Handle("GET", "toPage", func(context *gin.Context) { + context.String(200, "to toPage ....") + }) + + //注册到consul + consulReg := consul.NewRegistry(func(options *registry.Options) { + options.Addrs = []string{"192.168.100.131:8500"} + }) + //初始化链路追踪的jaeper + t, io, err := common.NewTracer("shop-product-client", "192.168.100.131:6831") + if err != nil { + log.Println(err) + } + defer io.Close() + opentracing.SetGlobalTracer(t) + + rpcServer := micro.NewService( + //micro.Name("shop-product-client"), + micro.Registry(consulReg), //服务发现 + micro.WrapClient(opentracing2.NewClientWrapper(opentracing.GlobalTracer())), + ) + client := proto.NewPageService("shop-product", rpcServer.Client()) + //分页查询商品列表 + router.GET("/page", func(c *gin.Context) { + //获取远程服务的客户端 client + //获取页面参数 + length, _ := strconv.Atoi(c.Request.FormValue("length")) + pageIndex, _ := strconv.Atoi(c.Request.FormValue("pageIndex")) + //拼接请求信息 + req := &proto.PageReq{ + Length: int32(length), + PageIndex: int32(pageIndex), + } + //远程调用服务 + resp, err := client.Page(context.TODO(), req) + log.Println(" /page :", resp) + //根据响应做输出 + if err != nil { + log.Println(err.Error()) + //c.String(http.StatusBadRequest, "search failed !") + common.RespFail(c.Writer, resp, "请求失败") + return + } + ////writer data message row total field + common.RespListOK(c.Writer, resp, "请求成功", resp.Rows, resp.Total, "请求成功") + }) + //查询商品详情 + clientA := proto.NewShowProductDetailService("shop-product", rpcServer.Client()) + router.GET("/showProductDetail", func(c *gin.Context) { + //获取远程服务的客户端 client + //获取页面参数 + id, _ := strconv.Atoi(c.Request.FormValue("id")) + //拼接请求信息 + req := &proto.ProductDetailReq{ + Id: int32(id), + } + //远程调用服务 + resp, err := clientA.ShowProductDetail(context.TODO(), req) + log.Println(" /showProductDetail :", resp) + //根据响应做输出 + if err != nil { + log.Println(err.Error()) + //c.String(http.StatusBadRequest, "search failed !") + common.RespFail(c.Writer, resp, "请求失败") + return + } + ////writer data message row total field + common.RespOK(c.Writer, resp, "请求成功") + }) + //查询商品SKU + clientSKU := proto.NewShowProductSkuService("shop-product", rpcServer.Client()) + router.GET("/sku", func(c *gin.Context) { + //获取远程服务的客户端 client + //获取页面参数 + id, _ := strconv.Atoi(c.Request.FormValue("productId")) + //拼接请求信息 + req := &proto.ProductSkuReq{ + ProductId: int32(id), + } + //远程调用服务 + resp, err := clientSKU.ShowProductSku(context.TODO(), req) + log.Println(" /sku :", resp) + //根据响应做输出 + if err != nil { + log.Println(err.Error()) + //c.String(http.StatusBadRequest, "search failed !") + common.RespFail(c.Writer, resp, "请求失败") + return + } + ////writer data message row total field + common.RespListOK(c.Writer, resp, "请求成功", 0, 0, "请求成功") + + }) + service := web.NewService( + web.Address(":6667"), + web.Name("shop-product-client"), + web.Registry(consulReg), + web.Handler(router), + ) + service.Run() + //router.Run(":6666") +} diff --git a/product-service/common/jaeger.go b/product-service/common/jaeger.go new file mode 100644 index 0000000..10e3509 --- /dev/null +++ b/product-service/common/jaeger.go @@ -0,0 +1,29 @@ +package common + +import ( + "github.com/opentracing/opentracing-go" + jaeger "github.com/uber/jaeger-client-go" + "github.com/uber/jaeger-client-go/config" + "io" + "time" +) + +/* +@Auth:ShenZ +@Description: Jaeger的实列化方法 +*/ +func NewTracer(serviceName string, addr string) (opentracing.Tracer, io.Closer, error) { + cfg := &config.Configuration{ + ServiceName: serviceName, + Sampler: &config.SamplerConfig{ + Type: jaeger.SamplerTypeConst, + Param: 1, + }, + Reporter: &config.ReporterConfig{ + BufferFlushInterval: 1 * time.Second, + LogSpans: true, + LocalAgentHostPort: addr, + }, + } + return cfg.NewTracer() +} diff --git a/product-service/domain/repository/product_repository.go b/product-service/domain/repository/product_repository.go new file mode 100644 index 0000000..13e6810 --- /dev/null +++ b/product-service/domain/repository/product_repository.go @@ -0,0 +1,86 @@ +package repository + +import ( + "errors" + "fmt" + "goproduct/domain/model" + + "gorm.io/gorm" +) + +/** + int32 clientId = 1; + string phone = 2; + int32 systemId = 3; + string verificationCode = 4; +**/ +//接口 +type IProductRepository interface { + Page(int32, int32) (int64, *[]model.Product, error) + ShowProductDetail(int32) (*model.ProductDetail, error) + ShowProductSku(int32) (*[]model.ProductSku, error) + CountNum() int64 +} + +// 创建实例 +func NewProductRepository(db *gorm.DB) IProductRepository { + return &ProductRepository{mysqlDB: db} +} + +// 数据DB +type ProductRepository struct { + mysqlDB *gorm.DB +} + +// 重写接口方法 +// product/app/product/page?length=15&pageIndex=1 +func (u *ProductRepository) Page(length int32, pageIndex int32) (coun int64, products *[]model.Product, err error) { + arr := make([]model.Product, length) + var count int64 + //u.mysqlDB.Model(&model.Product{}).Count(&count) + + if length > 0 && pageIndex > 0 { + u.mysqlDB = u.mysqlDB.Limit(int(length)).Offset((int(pageIndex) - 1) * int(length)) + if err := u.mysqlDB.Find(&arr).Error; err != nil { + fmt.Println("query product err :", err) + } + u.mysqlDB.Model(&model.Product{}).Offset(-1).Limit(-1).Count(&count) + return count, &arr, nil + } + return count, &arr, errors.New("参数不匹配") +} + +func (u *ProductRepository) ShowProductDetail(id int32) (product *model.ProductDetail, err error) { + sql := "select p.`id` , p.`name`, p.product_type,p.category_id ,p.starting_price,\n " + + " pd.detail as detail ,GROUP_CONCAT(pp.picture SEPARATOR ',') as picture_list\n" + + "FROM `product` p\n" + + " left join product_detail pd on p.id = pd.product_id\n " + + " left join product_picture pp on p.id = pp.product_id\n " + + " where p.`id` = ?" + var productDetails []model.ProductDetail + + u.mysqlDB.Raw(sql, id).Scan(&productDetails) + fmt.Println("repository ShowProductDetail >>>> ", productDetails) + return &productDetails[0], nil +} +func (u *ProductRepository) CountNum() int64 { + var count int64 + u.mysqlDB.Model(&model.Product{}).Offset(-1).Limit(-1).Count(&count) + return count +} + +/* +SkuId int32 `gorm:"column:id" json:"skuId"` +Name string +AttributeSymbolList string `gorm:"column:attribute_symbolList" json:"attributeSymbolList"` +SellPrice float32 `gorm:"column:sell_price" json:"sellPrice"` +Stock int32 `gorm:"default:1"` +*/ +func (u *ProductRepository) ShowProductSku(id int32) (product *[]model.ProductSku, err error) { + sql := "select id ,name ,attribute_symbol_list,sell_price,stock from product_sku where product_id= ?" + var productSku []model.ProductSku + + u.mysqlDB.Raw(sql, id).Scan(&productSku) + fmt.Println("repository ShowProductSku >>>> ", productSku) + return &productSku, nil +} diff --git a/product-service/domain/service/product_data_service.go b/product-service/domain/service/product_data_service.go new file mode 100644 index 0000000..02946f3 --- /dev/null +++ b/product-service/domain/service/product_data_service.go @@ -0,0 +1,40 @@ +package service + +import ( + "goproduct/domain/model" + "goproduct/domain/repository" +) + +type IProductDataService interface { + Page(int32, int32) (count int64, products *[]model.Product, err error) + ShowProductDetail(int32) (obj *model.ProductDetail, err error) + ShowProductSku(int32) (obj *[]model.ProductSku, err error) + CountNum() int64 +} +type ProductDataService struct { + productRepository repository.IProductRepository +} + +func NewProductDataService(productRepository repository.IProductRepository) IProductDataService { + return &ProductDataService{productRepository: productRepository} +} + +// 重写接口方法 +func (u *ProductDataService) Page(length int32, pageIndex int32) (count int64, products *[]model.Product, err error) { + + return u.productRepository.Page(length, pageIndex) +} + +func (u *ProductDataService) CountNum() int64 { + + return u.productRepository.CountNum() +} + +func (u *ProductDataService) ShowProductDetail(id int32) (product *model.ProductDetail, err error) { + + return u.productRepository.ShowProductDetail(id) +} +func (u *ProductDataService) ShowProductSku(id int32) (product *[]model.ProductSku, err error) { + + return u.productRepository.ShowProductSku(id) +} diff --git a/product-service/handler/product_handler.go b/product-service/handler/product_handler.go new file mode 100644 index 0000000..41a580e --- /dev/null +++ b/product-service/handler/product_handler.go @@ -0,0 +1,98 @@ +package handler + +import ( + "context" + "fmt" + "goproduct/common" + "goproduct/domain/model" + "goproduct/domain/service" + "goproduct/proto" +) + +type ProductHandler struct { + ProductDataService service.IProductDataService +} + +// 查询商品列表 +func (u *ProductHandler) Page(ctx context.Context, req *proto.PageReq, resp *proto.PageResp) error { + //count := u.ProductDataService.CountNum() + count, obj, err := u.ProductDataService.Page(req.GetLength(), req.GetPageIndex()) + if err != nil { + println("page product err :", err) + } + //count = u.ProductDataService.CountNum() + resp.Rows = int64(req.GetLength()) + resp.Total = count + //fmt.Println(">>>>>>>>>>>>> page product success :", obj) + ObjForResp(obj, resp) + return nil +} + +/* +* + + "id": 115, + "name": "马歇尔MARSHALL STANMOREⅡ无线蓝牙音响家用复古重低音小音箱", + "startingPrice": 3300, + "mainPicture": "https://msb-edu-prod.oss-cn-beijing.aliyuncs.com/mall-product/product/d4f1f19e-2e90-4ac5-bbe3-1eba02085a0f.jpg", + "labelList": [ ], + "singleBuyLimit": null, + "isEnable": null, + "productType": null + +* +*/ +func ObjForResp(obj *[]model.Product, resp *proto.PageResp) (err error) { + for _, v := range *obj { + product := &proto.Product{} + err := common.SwapToStruct(v, product) + if err != nil { + return err + } + fmt.Println(">>>>>>>>>>>>> ", product) + resp.Product = append(resp.Product, product) + } + return nil +} + +// 商品详情 +func (u *ProductHandler) ShowProductDetail(ctx context.Context, req *proto.ProductDetailReq, resp *proto.ProductDetailResp) error { + //count := u.ProductDataService.CountNum() + obj, err := u.ProductDataService.ShowProductDetail(req.GetId()) + if err != nil { + println("ShowProductDetail err :", err) + } + productDetail := &proto.ProductDetail{} + err1 := common.SwapToStruct(obj, productDetail) + if err1 != nil { + println("ShowProductDetail SwapToStruct err :", err1) + } + resp.ProductDetail = append(resp.ProductDetail, productDetail) + return nil +} + +// 商品SKU +func (u *ProductHandler) ShowProductSku(ctx context.Context, req *proto.ProductSkuReq, resp *proto.ProductSkuResp) error { + //count := u.ProductDataService.CountNum() + obj, err := u.ProductDataService.ShowProductSku(req.GetProductId()) + if err != nil { + println("ShowProductSku err :", err) + } + err1 := ObjSkuForResp(obj, resp) + if err1 != nil { + println("ShowProductSku SwapToStruct err :", err1) + } + return nil +} + +func ObjSkuForResp(obj *[]model.ProductSku, resp *proto.ProductSkuResp) (err error) { + for _, v := range *obj { + product := &proto.ProductSku{} + err := common.SwapToStruct(v, product) + if err != nil { + return err + } + resp.ProductSku = append(resp.ProductSku, product) + } + return nil +} diff --git a/product-service/proto/product.pb.go b/product-service/proto/product.pb.go new file mode 100644 index 0000000..673ab0b --- /dev/null +++ b/product-service/proto/product.pb.go @@ -0,0 +1,1037 @@ +//* +// @Auth:ShenZ +// @Description: + +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.26.0 +// protoc v3.18.1 +// source: product.proto + +package proto + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +// * +// "id": 115, +// "name": "马歇尔MARSHALL STANMOREⅡ无线蓝牙音响家用复古重低音小音箱", +// "startingPrice": 3300, +// "mainPicture": "https://msb-edu-prod.oss-cn-beijing.aliyuncs.com/mall-product/product/d4f1f19e-2e90-4ac5-bbe3-1eba02085a0f.jpg", +// "labelList": [ ], +// "singleBuyLimit": null, +// "isEnable": null, +// "productType": null +type Product struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` + Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` + StartingPrice int32 `protobuf:"varint,3,opt,name=startingPrice,proto3" json:"startingPrice,omitempty"` + MainPicture string `protobuf:"bytes,4,opt,name=mainPicture,proto3" json:"mainPicture,omitempty"` + LabelList map[string]string `protobuf:"bytes,5,rep,name=labelList,proto3" json:"labelList,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` + SingleBuyLimit int32 `protobuf:"varint,6,opt,name=singleBuyLimit,proto3" json:"singleBuyLimit,omitempty"` + Token string `protobuf:"bytes,7,opt,name=token,proto3" json:"token,omitempty"` + IsEnable bool `protobuf:"varint,8,opt,name=isEnable,proto3" json:"isEnable,omitempty"` + ProductType int32 `protobuf:"varint,9,opt,name=productType,proto3" json:"productType,omitempty"` +} + +func (x *Product) Reset() { + *x = Product{} + if protoimpl.UnsafeEnabled { + mi := &file_product_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *Product) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*Product) ProtoMessage() {} + +func (x *Product) ProtoReflect() protoreflect.Message { + mi := &file_product_proto_msgTypes[0] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use Product.ProtoReflect.Descriptor instead. +func (*Product) Descriptor() ([]byte, []int) { + return file_product_proto_rawDescGZIP(), []int{0} +} + +func (x *Product) GetId() int32 { + if x != nil { + return x.Id + } + return 0 +} + +func (x *Product) GetName() string { + if x != nil { + return x.Name + } + return "" +} + +func (x *Product) GetStartingPrice() int32 { + if x != nil { + return x.StartingPrice + } + return 0 +} + +func (x *Product) GetMainPicture() string { + if x != nil { + return x.MainPicture + } + return "" +} + +func (x *Product) GetLabelList() map[string]string { + if x != nil { + return x.LabelList + } + return nil +} + +func (x *Product) GetSingleBuyLimit() int32 { + if x != nil { + return x.SingleBuyLimit + } + return 0 +} + +func (x *Product) GetToken() string { + if x != nil { + return x.Token + } + return "" +} + +func (x *Product) GetIsEnable() bool { + if x != nil { + return x.IsEnable + } + return false +} + +func (x *Product) GetProductType() int32 { + if x != nil { + return x.ProductType + } + return 0 +} + +// 请求 request struct +type PageReq struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Length int32 `protobuf:"varint,1,opt,name=length,proto3" json:"length,omitempty"` + PageIndex int32 `protobuf:"varint,2,opt,name=pageIndex,proto3" json:"pageIndex,omitempty"` +} + +func (x *PageReq) Reset() { + *x = PageReq{} + if protoimpl.UnsafeEnabled { + mi := &file_product_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *PageReq) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PageReq) ProtoMessage() {} + +func (x *PageReq) ProtoReflect() protoreflect.Message { + mi := &file_product_proto_msgTypes[1] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use PageReq.ProtoReflect.Descriptor instead. +func (*PageReq) Descriptor() ([]byte, []int) { + return file_product_proto_rawDescGZIP(), []int{1} +} + +func (x *PageReq) GetLength() int32 { + if x != nil { + return x.Length + } + return 0 +} + +func (x *PageReq) GetPageIndex() int32 { + if x != nil { + return x.PageIndex + } + return 0 +} + +// * +type PageResp struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Product []*Product `protobuf:"bytes,1,rep,name=product,proto3" json:"product,omitempty"` + Total int64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` + Rows int64 `protobuf:"varint,3,opt,name=rows,proto3" json:"rows,omitempty"` +} + +func (x *PageResp) Reset() { + *x = PageResp{} + if protoimpl.UnsafeEnabled { + mi := &file_product_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *PageResp) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PageResp) ProtoMessage() {} + +func (x *PageResp) ProtoReflect() protoreflect.Message { + mi := &file_product_proto_msgTypes[2] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use PageResp.ProtoReflect.Descriptor instead. +func (*PageResp) Descriptor() ([]byte, []int) { + return file_product_proto_rawDescGZIP(), []int{2} +} + +func (x *PageResp) GetProduct() []*Product { + if x != nil { + return x.Product + } + return nil +} + +func (x *PageResp) GetTotal() int64 { + if x != nil { + return x.Total + } + return 0 +} + +func (x *PageResp) GetRows() int64 { + if x != nil { + return x.Rows + } + return 0 +} + +// * +// ID int32 `json:"id"` +// Name string `json:"name"` +// ProductType int32 `gorm:"default:1" json:"productType"` +// CategoryId int32 `json:"categoryId"` +// StartingPrice float32 `json:"startingPrice"` +// TotalStock int32 `gorm:"default:1234" json:"totalStock"` +// MainPicture string `gorm:"default:1" json:"mainPicture"` +// RemoteAreaPostage float32 `json:"remoteAreaPostage"` +// SingleBuyLimit int32 `json:"singleBuyLimit"` +// IsEnable bool `json:"isEnable"` +// Remark string `gorm:"default:1" json:"remark"` +// CreateUser int32 `gorm:"default:1" json:"createUser"` +// CreateTime time.Time `json:"createTime"` +// UpdateUser int32 `json:"updateUser"` +// UpdateTime time.Time `json:"updateTime"` +// IsDeleted bool `json:"isDeleted"` +// Detail string `gorm:"dtail" json:"detail"` //商品详情页面 +// PictureList []string `gorm:"pictureList" json:"pictureList"` //商品详情需要的图片 +type ProductDetail struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` + Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` + ProductType int32 `protobuf:"varint,3,opt,name=productType,proto3" json:"productType,omitempty"` + CategoryId int32 `protobuf:"varint,4,opt,name=categoryId,proto3" json:"categoryId,omitempty"` + StartingPrice float32 `protobuf:"fixed32,5,opt,name=startingPrice,proto3" json:"startingPrice,omitempty"` + TotalStock int32 `protobuf:"varint,6,opt,name=totalStock,proto3" json:"totalStock,omitempty"` + MainPicture string `protobuf:"bytes,7,opt,name=mainPicture,proto3" json:"mainPicture,omitempty"` + RemoteAreaPostage float32 `protobuf:"fixed32,8,opt,name=remoteAreaPostage,proto3" json:"remoteAreaPostage,omitempty"` + SingleBuyLimit int32 `protobuf:"varint,9,opt,name=singleBuyLimit,proto3" json:"singleBuyLimit,omitempty"` + IsEnable bool `protobuf:"varint,10,opt,name=isEnable,proto3" json:"isEnable,omitempty"` + Remark string `protobuf:"bytes,11,opt,name=remark,proto3" json:"remark,omitempty"` + CreateUser int32 `protobuf:"varint,12,opt,name=createUser,proto3" json:"createUser,omitempty"` + CreateTime string `protobuf:"bytes,13,opt,name=createTime,proto3" json:"createTime,omitempty"` //go get google.golang.org/protobuf/ptypes/timestamp + UpdateUser int32 `protobuf:"varint,14,opt,name=updateUser,proto3" json:"updateUser,omitempty"` + UpdateTime string `protobuf:"bytes,15,opt,name=updateTime,proto3" json:"updateTime,omitempty"` + IsDeleted bool `protobuf:"varint,16,opt,name=IsDeleted,proto3" json:"IsDeleted,omitempty"` + Detail string `protobuf:"bytes,17,opt,name=detail,proto3" json:"detail,omitempty"` + PictureList string `protobuf:"bytes,18,opt,name=pictureList,proto3" json:"pictureList,omitempty"` +} + +func (x *ProductDetail) Reset() { + *x = ProductDetail{} + if protoimpl.UnsafeEnabled { + mi := &file_product_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *ProductDetail) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ProductDetail) ProtoMessage() {} + +func (x *ProductDetail) ProtoReflect() protoreflect.Message { + mi := &file_product_proto_msgTypes[3] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use ProductDetail.ProtoReflect.Descriptor instead. +func (*ProductDetail) Descriptor() ([]byte, []int) { + return file_product_proto_rawDescGZIP(), []int{3} +} + +func (x *ProductDetail) GetId() int32 { + if x != nil { + return x.Id + } + return 0 +} + +func (x *ProductDetail) GetName() string { + if x != nil { + return x.Name + } + return "" +} + +func (x *ProductDetail) GetProductType() int32 { + if x != nil { + return x.ProductType + } + return 0 +} + +func (x *ProductDetail) GetCategoryId() int32 { + if x != nil { + return x.CategoryId + } + return 0 +} + +func (x *ProductDetail) GetStartingPrice() float32 { + if x != nil { + return x.StartingPrice + } + return 0 +} + +func (x *ProductDetail) GetTotalStock() int32 { + if x != nil { + return x.TotalStock + } + return 0 +} + +func (x *ProductDetail) GetMainPicture() string { + if x != nil { + return x.MainPicture + } + return "" +} + +func (x *ProductDetail) GetRemoteAreaPostage() float32 { + if x != nil { + return x.RemoteAreaPostage + } + return 0 +} + +func (x *ProductDetail) GetSingleBuyLimit() int32 { + if x != nil { + return x.SingleBuyLimit + } + return 0 +} + +func (x *ProductDetail) GetIsEnable() bool { + if x != nil { + return x.IsEnable + } + return false +} + +func (x *ProductDetail) GetRemark() string { + if x != nil { + return x.Remark + } + return "" +} + +func (x *ProductDetail) GetCreateUser() int32 { + if x != nil { + return x.CreateUser + } + return 0 +} + +func (x *ProductDetail) GetCreateTime() string { + if x != nil { + return x.CreateTime + } + return "" +} + +func (x *ProductDetail) GetUpdateUser() int32 { + if x != nil { + return x.UpdateUser + } + return 0 +} + +func (x *ProductDetail) GetUpdateTime() string { + if x != nil { + return x.UpdateTime + } + return "" +} + +func (x *ProductDetail) GetIsDeleted() bool { + if x != nil { + return x.IsDeleted + } + return false +} + +func (x *ProductDetail) GetDetail() string { + if x != nil { + return x.Detail + } + return "" +} + +func (x *ProductDetail) GetPictureList() string { + if x != nil { + return x.PictureList + } + return "" +} + +// 请求 request struct +type ProductDetailReq struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` +} + +func (x *ProductDetailReq) Reset() { + *x = ProductDetailReq{} + if protoimpl.UnsafeEnabled { + mi := &file_product_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *ProductDetailReq) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ProductDetailReq) ProtoMessage() {} + +func (x *ProductDetailReq) ProtoReflect() protoreflect.Message { + mi := &file_product_proto_msgTypes[4] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use ProductDetailReq.ProtoReflect.Descriptor instead. +func (*ProductDetailReq) Descriptor() ([]byte, []int) { + return file_product_proto_rawDescGZIP(), []int{4} +} + +func (x *ProductDetailReq) GetId() int32 { + if x != nil { + return x.Id + } + return 0 +} + +// * +type ProductDetailResp struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + ProductDetail []*ProductDetail `protobuf:"bytes,1,rep,name=productDetail,proto3" json:"productDetail,omitempty"` +} + +func (x *ProductDetailResp) Reset() { + *x = ProductDetailResp{} + if protoimpl.UnsafeEnabled { + mi := &file_product_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *ProductDetailResp) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ProductDetailResp) ProtoMessage() {} + +func (x *ProductDetailResp) ProtoReflect() protoreflect.Message { + mi := &file_product_proto_msgTypes[5] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use ProductDetailResp.ProtoReflect.Descriptor instead. +func (*ProductDetailResp) Descriptor() ([]byte, []int) { + return file_product_proto_rawDescGZIP(), []int{5} +} + +func (x *ProductDetailResp) GetProductDetail() []*ProductDetail { + if x != nil { + return x.ProductDetail + } + return nil +} + +// SkuId int32 `gorm:"column:id" json:"skuId"` +// Name string +// AttributeSymbolList string `gorm:"column:attribute_symbolList" json:"attributeSymbolList"` +// SellPrice float32 `gorm:"column:sell_price" json:"sellPrice"` +// Stock int32 `gorm:"default:1"` +type ProductSku struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + SkuId int32 `protobuf:"varint,1,opt,name=skuId,proto3" json:"skuId,omitempty"` + Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` + AttributeSymbolList string `protobuf:"bytes,3,opt,name=attributeSymbolList,proto3" json:"attributeSymbolList,omitempty"` + SellPrice float32 `protobuf:"fixed32,4,opt,name=sellPrice,proto3" json:"sellPrice,omitempty"` + Stock int32 `protobuf:"varint,5,opt,name=stock,proto3" json:"stock,omitempty"` +} + +func (x *ProductSku) Reset() { + *x = ProductSku{} + if protoimpl.UnsafeEnabled { + mi := &file_product_proto_msgTypes[6] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *ProductSku) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ProductSku) ProtoMessage() {} + +func (x *ProductSku) ProtoReflect() protoreflect.Message { + mi := &file_product_proto_msgTypes[6] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use ProductSku.ProtoReflect.Descriptor instead. +func (*ProductSku) Descriptor() ([]byte, []int) { + return file_product_proto_rawDescGZIP(), []int{6} +} + +func (x *ProductSku) GetSkuId() int32 { + if x != nil { + return x.SkuId + } + return 0 +} + +func (x *ProductSku) GetName() string { + if x != nil { + return x.Name + } + return "" +} + +func (x *ProductSku) GetAttributeSymbolList() string { + if x != nil { + return x.AttributeSymbolList + } + return "" +} + +func (x *ProductSku) GetSellPrice() float32 { + if x != nil { + return x.SellPrice + } + return 0 +} + +func (x *ProductSku) GetStock() int32 { + if x != nil { + return x.Stock + } + return 0 +} + +// 请求 request struct +type ProductSkuReq struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + ProductId int32 `protobuf:"varint,1,opt,name=productId,proto3" json:"productId,omitempty"` +} + +func (x *ProductSkuReq) Reset() { + *x = ProductSkuReq{} + if protoimpl.UnsafeEnabled { + mi := &file_product_proto_msgTypes[7] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *ProductSkuReq) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ProductSkuReq) ProtoMessage() {} + +func (x *ProductSkuReq) ProtoReflect() protoreflect.Message { + mi := &file_product_proto_msgTypes[7] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use ProductSkuReq.ProtoReflect.Descriptor instead. +func (*ProductSkuReq) Descriptor() ([]byte, []int) { + return file_product_proto_rawDescGZIP(), []int{7} +} + +func (x *ProductSkuReq) GetProductId() int32 { + if x != nil { + return x.ProductId + } + return 0 +} + +// * +type ProductSkuResp struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + ProductSku []*ProductSku `protobuf:"bytes,1,rep,name=productSku,proto3" json:"productSku,omitempty"` +} + +func (x *ProductSkuResp) Reset() { + *x = ProductSkuResp{} + if protoimpl.UnsafeEnabled { + mi := &file_product_proto_msgTypes[8] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *ProductSkuResp) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ProductSkuResp) ProtoMessage() {} + +func (x *ProductSkuResp) ProtoReflect() protoreflect.Message { + mi := &file_product_proto_msgTypes[8] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use ProductSkuResp.ProtoReflect.Descriptor instead. +func (*ProductSkuResp) Descriptor() ([]byte, []int) { + return file_product_proto_rawDescGZIP(), []int{8} +} + +func (x *ProductSkuResp) GetProductSku() []*ProductSku { + if x != nil { + return x.ProductSku + } + return nil +} + +var File_product_proto protoreflect.FileDescriptor + +var file_product_proto_rawDesc = []byte{ + 0x0a, 0x0d, 0x70, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, + 0x05, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xec, 0x02, 0x0a, 0x07, 0x50, 0x72, 0x6f, 0x64, 0x75, + 0x63, 0x74, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x02, + 0x69, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, + 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x24, 0x0a, 0x0d, 0x73, 0x74, 0x61, 0x72, 0x74, 0x69, + 0x6e, 0x67, 0x50, 0x72, 0x69, 0x63, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0d, 0x73, + 0x74, 0x61, 0x72, 0x74, 0x69, 0x6e, 0x67, 0x50, 0x72, 0x69, 0x63, 0x65, 0x12, 0x20, 0x0a, 0x0b, + 0x6d, 0x61, 0x69, 0x6e, 0x50, 0x69, 0x63, 0x74, 0x75, 0x72, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x0b, 0x6d, 0x61, 0x69, 0x6e, 0x50, 0x69, 0x63, 0x74, 0x75, 0x72, 0x65, 0x12, 0x3b, + 0x0a, 0x09, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x4c, 0x69, 0x73, 0x74, 0x18, 0x05, 0x20, 0x03, 0x28, + 0x0b, 0x32, 0x1d, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, + 0x74, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x4c, 0x69, 0x73, 0x74, 0x45, 0x6e, 0x74, 0x72, 0x79, + 0x52, 0x09, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x26, 0x0a, 0x0e, 0x73, + 0x69, 0x6e, 0x67, 0x6c, 0x65, 0x42, 0x75, 0x79, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x06, 0x20, + 0x01, 0x28, 0x05, 0x52, 0x0e, 0x73, 0x69, 0x6e, 0x67, 0x6c, 0x65, 0x42, 0x75, 0x79, 0x4c, 0x69, + 0x6d, 0x69, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x07, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x1a, 0x0a, 0x08, 0x69, 0x73, 0x45, + 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x08, 0x52, 0x08, 0x69, 0x73, 0x45, + 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x70, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, + 0x54, 0x79, 0x70, 0x65, 0x18, 0x09, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0b, 0x70, 0x72, 0x6f, 0x64, + 0x75, 0x63, 0x74, 0x54, 0x79, 0x70, 0x65, 0x1a, 0x3c, 0x0a, 0x0e, 0x4c, 0x61, 0x62, 0x65, 0x6c, + 0x4c, 0x69, 0x73, 0x74, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, + 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, + 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x3f, 0x0a, 0x07, 0x50, 0x61, 0x67, 0x65, 0x52, 0x65, 0x71, + 0x12, 0x16, 0x0a, 0x06, 0x6c, 0x65, 0x6e, 0x67, 0x74, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, + 0x52, 0x06, 0x6c, 0x65, 0x6e, 0x67, 0x74, 0x68, 0x12, 0x1c, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, + 0x49, 0x6e, 0x64, 0x65, 0x78, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x09, 0x70, 0x61, 0x67, + 0x65, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x22, 0x5e, 0x0a, 0x08, 0x50, 0x61, 0x67, 0x65, 0x52, 0x65, + 0x73, 0x70, 0x12, 0x28, 0x0a, 0x07, 0x70, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x18, 0x01, 0x20, + 0x03, 0x28, 0x0b, 0x32, 0x0e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x50, 0x72, 0x6f, 0x64, + 0x75, 0x63, 0x74, 0x52, 0x07, 0x70, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x12, 0x14, 0x0a, 0x05, + 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x05, 0x74, 0x6f, 0x74, + 0x61, 0x6c, 0x12, 0x12, 0x0a, 0x04, 0x72, 0x6f, 0x77, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, + 0x52, 0x04, 0x72, 0x6f, 0x77, 0x73, 0x22, 0xbf, 0x04, 0x0a, 0x0d, 0x50, 0x72, 0x6f, 0x64, 0x75, + 0x63, 0x74, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, + 0x20, 0x01, 0x28, 0x05, 0x52, 0x02, 0x69, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, + 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x20, 0x0a, 0x0b, + 0x70, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x54, 0x79, 0x70, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, + 0x05, 0x52, 0x0b, 0x70, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x1e, + 0x0a, 0x0a, 0x63, 0x61, 0x74, 0x65, 0x67, 0x6f, 0x72, 0x79, 0x49, 0x64, 0x18, 0x04, 0x20, 0x01, + 0x28, 0x05, 0x52, 0x0a, 0x63, 0x61, 0x74, 0x65, 0x67, 0x6f, 0x72, 0x79, 0x49, 0x64, 0x12, 0x24, + 0x0a, 0x0d, 0x73, 0x74, 0x61, 0x72, 0x74, 0x69, 0x6e, 0x67, 0x50, 0x72, 0x69, 0x63, 0x65, 0x18, + 0x05, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0d, 0x73, 0x74, 0x61, 0x72, 0x74, 0x69, 0x6e, 0x67, 0x50, + 0x72, 0x69, 0x63, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x53, 0x74, 0x6f, + 0x63, 0x6b, 0x18, 0x06, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x53, + 0x74, 0x6f, 0x63, 0x6b, 0x12, 0x20, 0x0a, 0x0b, 0x6d, 0x61, 0x69, 0x6e, 0x50, 0x69, 0x63, 0x74, + 0x75, 0x72, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x6d, 0x61, 0x69, 0x6e, 0x50, + 0x69, 0x63, 0x74, 0x75, 0x72, 0x65, 0x12, 0x2c, 0x0a, 0x11, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, + 0x41, 0x72, 0x65, 0x61, 0x50, 0x6f, 0x73, 0x74, 0x61, 0x67, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, + 0x02, 0x52, 0x11, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x41, 0x72, 0x65, 0x61, 0x50, 0x6f, 0x73, + 0x74, 0x61, 0x67, 0x65, 0x12, 0x26, 0x0a, 0x0e, 0x73, 0x69, 0x6e, 0x67, 0x6c, 0x65, 0x42, 0x75, + 0x79, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x09, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0e, 0x73, 0x69, + 0x6e, 0x67, 0x6c, 0x65, 0x42, 0x75, 0x79, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x12, 0x1a, 0x0a, 0x08, + 0x69, 0x73, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x08, 0x52, 0x08, + 0x69, 0x73, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x65, 0x6d, 0x61, + 0x72, 0x6b, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x72, 0x65, 0x6d, 0x61, 0x72, 0x6b, + 0x12, 0x1e, 0x0a, 0x0a, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x55, 0x73, 0x65, 0x72, 0x18, 0x0c, + 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x55, 0x73, 0x65, 0x72, + 0x12, 0x1e, 0x0a, 0x0a, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x0d, + 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, + 0x12, 0x1e, 0x0a, 0x0a, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x55, 0x73, 0x65, 0x72, 0x18, 0x0e, + 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x55, 0x73, 0x65, 0x72, + 0x12, 0x1e, 0x0a, 0x0a, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x0f, + 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, + 0x12, 0x1c, 0x0a, 0x09, 0x49, 0x73, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x64, 0x18, 0x10, 0x20, + 0x01, 0x28, 0x08, 0x52, 0x09, 0x49, 0x73, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x64, 0x12, 0x16, + 0x0a, 0x06, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x18, 0x11, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, + 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x20, 0x0a, 0x0b, 0x70, 0x69, 0x63, 0x74, 0x75, 0x72, + 0x65, 0x4c, 0x69, 0x73, 0x74, 0x18, 0x12, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x70, 0x69, 0x63, + 0x74, 0x75, 0x72, 0x65, 0x4c, 0x69, 0x73, 0x74, 0x22, 0x22, 0x0a, 0x10, 0x50, 0x72, 0x6f, 0x64, + 0x75, 0x63, 0x74, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x71, 0x12, 0x0e, 0x0a, 0x02, + 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x02, 0x69, 0x64, 0x22, 0x4f, 0x0a, 0x11, + 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x73, + 0x70, 0x12, 0x3a, 0x0a, 0x0d, 0x70, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x44, 0x65, 0x74, 0x61, + 0x69, 0x6c, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, + 0x2e, 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x0d, + 0x70, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x22, 0x9c, 0x01, + 0x0a, 0x0a, 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x53, 0x6b, 0x75, 0x12, 0x14, 0x0a, 0x05, + 0x73, 0x6b, 0x75, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x05, 0x73, 0x6b, 0x75, + 0x49, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, + 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x30, 0x0a, 0x13, 0x61, 0x74, 0x74, 0x72, 0x69, 0x62, + 0x75, 0x74, 0x65, 0x53, 0x79, 0x6d, 0x62, 0x6f, 0x6c, 0x4c, 0x69, 0x73, 0x74, 0x18, 0x03, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x13, 0x61, 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x53, 0x79, + 0x6d, 0x62, 0x6f, 0x6c, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x65, 0x6c, 0x6c, + 0x50, 0x72, 0x69, 0x63, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x02, 0x52, 0x09, 0x73, 0x65, 0x6c, + 0x6c, 0x50, 0x72, 0x69, 0x63, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x73, 0x74, 0x6f, 0x63, 0x6b, 0x18, + 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x05, 0x73, 0x74, 0x6f, 0x63, 0x6b, 0x22, 0x2d, 0x0a, 0x0d, + 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x53, 0x6b, 0x75, 0x52, 0x65, 0x71, 0x12, 0x1c, 0x0a, + 0x09, 0x70, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, + 0x52, 0x09, 0x70, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x49, 0x64, 0x22, 0x43, 0x0a, 0x0e, 0x50, + 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x53, 0x6b, 0x75, 0x52, 0x65, 0x73, 0x70, 0x12, 0x31, 0x0a, + 0x0a, 0x70, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x53, 0x6b, 0x75, 0x18, 0x01, 0x20, 0x03, 0x28, + 0x0b, 0x32, 0x11, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, + 0x74, 0x53, 0x6b, 0x75, 0x52, 0x0a, 0x70, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x53, 0x6b, 0x75, + 0x32, 0x31, 0x0a, 0x04, 0x50, 0x61, 0x67, 0x65, 0x12, 0x29, 0x0a, 0x04, 0x50, 0x61, 0x67, 0x65, + 0x12, 0x0e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x50, 0x61, 0x67, 0x65, 0x52, 0x65, 0x71, + 0x1a, 0x0f, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x50, 0x61, 0x67, 0x65, 0x52, 0x65, 0x73, + 0x70, 0x22, 0x00, 0x32, 0x5d, 0x0a, 0x11, 0x53, 0x68, 0x6f, 0x77, 0x50, 0x72, 0x6f, 0x64, 0x75, + 0x63, 0x74, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x48, 0x0a, 0x11, 0x53, 0x68, 0x6f, 0x77, + 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x17, 0x2e, + 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x44, 0x65, 0x74, + 0x61, 0x69, 0x6c, 0x52, 0x65, 0x71, 0x1a, 0x18, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x50, + 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x73, 0x70, + 0x22, 0x00, 0x32, 0x51, 0x0a, 0x0e, 0x53, 0x68, 0x6f, 0x77, 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, + 0x74, 0x53, 0x6b, 0x75, 0x12, 0x3f, 0x0a, 0x0e, 0x53, 0x68, 0x6f, 0x77, 0x50, 0x72, 0x6f, 0x64, + 0x75, 0x63, 0x74, 0x53, 0x6b, 0x75, 0x12, 0x14, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x50, + 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x53, 0x6b, 0x75, 0x52, 0x65, 0x71, 0x1a, 0x15, 0x2e, 0x70, + 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x53, 0x6b, 0x75, 0x52, + 0x65, 0x73, 0x70, 0x22, 0x00, 0x42, 0x0a, 0x5a, 0x08, 0x2e, 0x2f, 0x3b, 0x70, 0x72, 0x6f, 0x74, + 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_product_proto_rawDescOnce sync.Once + file_product_proto_rawDescData = file_product_proto_rawDesc +) + +func file_product_proto_rawDescGZIP() []byte { + file_product_proto_rawDescOnce.Do(func() { + file_product_proto_rawDescData = protoimpl.X.CompressGZIP(file_product_proto_rawDescData) + }) + return file_product_proto_rawDescData +} + +var file_product_proto_msgTypes = make([]protoimpl.MessageInfo, 10) +var file_product_proto_goTypes = []interface{}{ + (*Product)(nil), // 0: proto.Product + (*PageReq)(nil), // 1: proto.PageReq + (*PageResp)(nil), // 2: proto.PageResp + (*ProductDetail)(nil), // 3: proto.ProductDetail + (*ProductDetailReq)(nil), // 4: proto.ProductDetailReq + (*ProductDetailResp)(nil), // 5: proto.ProductDetailResp + (*ProductSku)(nil), // 6: proto.ProductSku + (*ProductSkuReq)(nil), // 7: proto.ProductSkuReq + (*ProductSkuResp)(nil), // 8: proto.ProductSkuResp + nil, // 9: proto.Product.LabelListEntry +} +var file_product_proto_depIdxs = []int32{ + 9, // 0: proto.Product.labelList:type_name -> proto.Product.LabelListEntry + 0, // 1: proto.PageResp.product:type_name -> proto.Product + 3, // 2: proto.ProductDetailResp.productDetail:type_name -> proto.ProductDetail + 6, // 3: proto.ProductSkuResp.productSku:type_name -> proto.ProductSku + 1, // 4: proto.Page.Page:input_type -> proto.PageReq + 4, // 5: proto.ShowProductDetail.ShowProductDetail:input_type -> proto.ProductDetailReq + 7, // 6: proto.ShowProductSku.ShowProductSku:input_type -> proto.ProductSkuReq + 2, // 7: proto.Page.Page:output_type -> proto.PageResp + 5, // 8: proto.ShowProductDetail.ShowProductDetail:output_type -> proto.ProductDetailResp + 8, // 9: proto.ShowProductSku.ShowProductSku:output_type -> proto.ProductSkuResp + 7, // [7:10] is the sub-list for method output_type + 4, // [4:7] is the sub-list for method input_type + 4, // [4:4] is the sub-list for extension type_name + 4, // [4:4] is the sub-list for extension extendee + 0, // [0:4] is the sub-list for field type_name +} + +func init() { file_product_proto_init() } +func file_product_proto_init() { + if File_product_proto != nil { + return + } + if !protoimpl.UnsafeEnabled { + file_product_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*Product); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_product_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PageReq); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_product_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PageResp); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_product_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*ProductDetail); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_product_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*ProductDetailReq); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_product_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*ProductDetailResp); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_product_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*ProductSku); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_product_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*ProductSkuReq); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_product_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*ProductSkuResp); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_product_proto_rawDesc, + NumEnums: 0, + NumMessages: 10, + NumExtensions: 0, + NumServices: 3, + }, + GoTypes: file_product_proto_goTypes, + DependencyIndexes: file_product_proto_depIdxs, + MessageInfos: file_product_proto_msgTypes, + }.Build() + File_product_proto = out.File + file_product_proto_rawDesc = nil + file_product_proto_goTypes = nil + file_product_proto_depIdxs = nil +} diff --git a/product-service/proto/product.pb.micro.go b/product-service/proto/product.pb.micro.go new file mode 100644 index 0000000..52852df --- /dev/null +++ b/product-service/proto/product.pb.micro.go @@ -0,0 +1,211 @@ +// Code generated by protoc-gen-micro. DO NOT EDIT. +// source: product.proto + +package proto + +import ( + fmt "fmt" + proto "google.golang.org/protobuf/proto" + math "math" +) + +import ( + context "context" + api "go-micro.dev/v4/api" + client "go-micro.dev/v4/client" + server "go-micro.dev/v4/server" +) + +// Reference imports to suppress errors if they are not otherwise used. +var _ = proto.Marshal +var _ = fmt.Errorf +var _ = math.Inf + +// Reference imports to suppress errors if they are not otherwise used. +var _ api.Endpoint +var _ context.Context +var _ client.Option +var _ server.Option + +// Api Endpoints for Page service + +func NewPageEndpoints() []*api.Endpoint { + return []*api.Endpoint{} +} + +// Client API for Page service + +type PageService interface { + //rpc 服务 + Page(ctx context.Context, in *PageReq, opts ...client.CallOption) (*PageResp, error) +} + +type pageService struct { + c client.Client + name string +} + +func NewPageService(name string, c client.Client) PageService { + return &pageService{ + c: c, + name: name, + } +} + +func (c *pageService) Page(ctx context.Context, in *PageReq, opts ...client.CallOption) (*PageResp, error) { + req := c.c.NewRequest(c.name, "Page.Page", in) + out := new(PageResp) + err := c.c.Call(ctx, req, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +// Server API for Page service + +type PageHandler interface { + //rpc 服务 + Page(context.Context, *PageReq, *PageResp) error +} + +func RegisterPageHandler(s server.Server, hdlr PageHandler, opts ...server.HandlerOption) error { + type page interface { + Page(ctx context.Context, in *PageReq, out *PageResp) error + } + type Page struct { + page + } + h := &pageHandler{hdlr} + return s.Handle(s.NewHandler(&Page{h}, opts...)) +} + +type pageHandler struct { + PageHandler +} + +func (h *pageHandler) Page(ctx context.Context, in *PageReq, out *PageResp) error { + return h.PageHandler.Page(ctx, in, out) +} + +// Api Endpoints for ShowProductDetail service + +func NewShowProductDetailEndpoints() []*api.Endpoint { + return []*api.Endpoint{} +} + +// Client API for ShowProductDetail service + +type ShowProductDetailService interface { + //rpc 服务 + ShowProductDetail(ctx context.Context, in *ProductDetailReq, opts ...client.CallOption) (*ProductDetailResp, error) +} + +type showProductDetailService struct { + c client.Client + name string +} + +func NewShowProductDetailService(name string, c client.Client) ShowProductDetailService { + return &showProductDetailService{ + c: c, + name: name, + } +} + +func (c *showProductDetailService) ShowProductDetail(ctx context.Context, in *ProductDetailReq, opts ...client.CallOption) (*ProductDetailResp, error) { + req := c.c.NewRequest(c.name, "ShowProductDetail.ShowProductDetail", in) + out := new(ProductDetailResp) + err := c.c.Call(ctx, req, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +// Server API for ShowProductDetail service + +type ShowProductDetailHandler interface { + //rpc 服务 + ShowProductDetail(context.Context, *ProductDetailReq, *ProductDetailResp) error +} + +func RegisterShowProductDetailHandler(s server.Server, hdlr ShowProductDetailHandler, opts ...server.HandlerOption) error { + type showProductDetail interface { + ShowProductDetail(ctx context.Context, in *ProductDetailReq, out *ProductDetailResp) error + } + type ShowProductDetail struct { + showProductDetail + } + h := &showProductDetailHandler{hdlr} + return s.Handle(s.NewHandler(&ShowProductDetail{h}, opts...)) +} + +type showProductDetailHandler struct { + ShowProductDetailHandler +} + +func (h *showProductDetailHandler) ShowProductDetail(ctx context.Context, in *ProductDetailReq, out *ProductDetailResp) error { + return h.ShowProductDetailHandler.ShowProductDetail(ctx, in, out) +} + +// Api Endpoints for ShowProductSku service + +func NewShowProductSkuEndpoints() []*api.Endpoint { + return []*api.Endpoint{} +} + +// Client API for ShowProductSku service + +type ShowProductSkuService interface { + //rpc 服务 + ShowProductSku(ctx context.Context, in *ProductSkuReq, opts ...client.CallOption) (*ProductSkuResp, error) +} + +type showProductSkuService struct { + c client.Client + name string +} + +func NewShowProductSkuService(name string, c client.Client) ShowProductSkuService { + return &showProductSkuService{ + c: c, + name: name, + } +} + +func (c *showProductSkuService) ShowProductSku(ctx context.Context, in *ProductSkuReq, opts ...client.CallOption) (*ProductSkuResp, error) { + req := c.c.NewRequest(c.name, "ShowProductSku.ShowProductSku", in) + out := new(ProductSkuResp) + err := c.c.Call(ctx, req, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +// Server API for ShowProductSku service + +type ShowProductSkuHandler interface { + //rpc 服务 + ShowProductSku(context.Context, *ProductSkuReq, *ProductSkuResp) error +} + +func RegisterShowProductSkuHandler(s server.Server, hdlr ShowProductSkuHandler, opts ...server.HandlerOption) error { + type showProductSku interface { + ShowProductSku(ctx context.Context, in *ProductSkuReq, out *ProductSkuResp) error + } + type ShowProductSku struct { + showProductSku + } + h := &showProductSkuHandler{hdlr} + return s.Handle(s.NewHandler(&ShowProductSku{h}, opts...)) +} + +type showProductSkuHandler struct { + ShowProductSkuHandler +} + +func (h *showProductSkuHandler) ShowProductSku(ctx context.Context, in *ProductSkuReq, out *ProductSkuResp) error { + return h.ShowProductSkuHandler.ShowProductSku(ctx, in, out) +} diff --git a/product-service/proto/product.proto b/product-service/proto/product.proto new file mode 100644 index 0000000..88913b4 --- /dev/null +++ b/product-service/proto/product.proto @@ -0,0 +1,146 @@ +/** +* @Auth:ShenZ +* @Description: +*/ +syntax = "proto3"; // 版本号 +option go_package="./;proto"; //参数1 表示生成到哪个目录 ，参数2 表示生成的文件的package +package proto ; //默认在哪个包 + + +//结构体 +/** + "id": 115, + "name": "马歇尔MARSHALL STANMOREⅡ无线蓝牙音响家用复古重低音小音箱", + "startingPrice": 3300, + "mainPicture": "https://msb-edu-prod.oss-cn-beijing.aliyuncs.com/mall-product/product/d4f1f19e-2e90-4ac5-bbe3-1eba02085a0f.jpg", + "labelList": [ ], + "singleBuyLimit": null, + "isEnable": null, + "productType": null +**/ +message Product { + int32 id = 1; + string name = 2; + int32 startingPrice =3; + string mainPicture = 4; + map labelList = 5; + int32 singleBuyLimit = 6; + string token = 7; + bool isEnable = 8; + int32 productType = 9; +} +/** +前端请求信息 +{ + "clientId": 0, + "phone": "", + "systemId": 0, + "verificationCode": "" + } + **/ +//请求 request struct +message PageReq { + int32 length = 1; + int32 pageIndex = 2; +} +//响应 resp struct +/** + +**/ +message PageResp{ + repeated Product product = 1; + int64 total =2; + int64 rows = 3; +} +//RPC 服务 接口 +service Page { + //rpc 服务 + rpc Page (PageReq) returns (PageResp){} +} + +/** + ID int32 `json:"id"` + Name string `json:"name"` + ProductType int32 `gorm:"default:1" json:"productType"` + CategoryId int32 `json:"categoryId"` + StartingPrice float32 `json:"startingPrice"` + TotalStock int32 `gorm:"default:1234" json:"totalStock"` + MainPicture string `gorm:"default:1" json:"mainPicture"` + RemoteAreaPostage float32 `json:"remoteAreaPostage"` + SingleBuyLimit int32 `json:"singleBuyLimit"` + IsEnable bool `json:"isEnable"` + Remark string `gorm:"default:1" json:"remark"` + CreateUser int32 `gorm:"default:1" json:"createUser"` + CreateTime time.Time `json:"createTime"` + UpdateUser int32 `json:"updateUser"` + UpdateTime time.Time `json:"updateTime"` + IsDeleted bool `json:"isDeleted"` + Detail string `gorm:"dtail" json:"detail"` //商品详情页面 + PictureList []string `gorm:"pictureList" json:"pictureList"` //商品详情需要的图片 + */ +message ProductDetail { + int32 id = 1; + string name = 2; + int32 productType =3; + int32 categoryId = 4; + float startingPrice =5; + int32 totalStock = 6; + string mainPicture =7; + float remoteAreaPostage = 8; + int32 singleBuyLimit =9; + bool isEnable =10; + string remark =11; + int32 createUser =12 ; + string createTime = 13; //go get google.golang.org/protobuf/ptypes/timestamp + int32 updateUser =14; + string updateTime =15; + bool IsDeleted =16; + string detail =17; + string pictureList =18; +} +//请求 request struct +message ProductDetailReq { + int32 id = 1; +} +//响应 resp struct +/** + +**/ +message ProductDetailResp{ + repeated ProductDetail productDetail = 1; +} +//RPC 服务 接口 +service ShowProductDetail { + //rpc 服务 + rpc ShowProductDetail (ProductDetailReq) returns (ProductDetailResp){} +} +/* +SkuId int32 `gorm:"column:id" json:"skuId"` + Name string + AttributeSymbolList string `gorm:"column:attribute_symbolList" json:"attributeSymbolList"` + SellPrice float32 `gorm:"column:sell_price" json:"sellPrice"` + Stock int32 `gorm:"default:1"` + */ +message ProductSku { + int32 skuId = 1; + string name = 2; + string attributeSymbolList =3; + float sellPrice = 4; + int32 stock =5; +} +//请求 request struct +message ProductSkuReq { + int32 productId = 1; +} +//响应 resp struct +/** + +**/ +message ProductSkuResp{ + repeated ProductSku productSku = 1; +} +//RPC 服务 接口 +service ShowProductSku { + //rpc 服务 + rpc ShowProductSku (ProductSkuReq) returns (ProductSkuResp){} +} diff --git a/user-service/.idea/.gitignore b/user-service/.idea/.gitignore new file mode 100644 index 0000000..13566b8 --- /dev/null +++ b/user-service/.idea/.gitignore @@ -0,0 +1,8 @@ +# Default ignored files +/shelf/ +/workspace.xml +# Editor-based HTTP Client requests +/httpRequests/ +# Datasource local storage ignored files +/dataSources/ +/dataSources.local.xml diff --git a/user-service/.idea/modules.xml b/user-service/.idea/modules.xml new file mode 100644 index 0000000..f5824cf --- /dev/null +++ b/user-service/.idea/modules.xml @@ -0,0 +1,8 @@ + + + + + + + + \ No newline at end of file diff --git a/user-service/.idea/user-service.iml b/user-service/.idea/user-service.iml new file mode 100644 index 0000000..5e764c4 --- /dev/null +++ b/user-service/.idea/user-service.iml @@ -0,0 +1,9 @@ + + + + + + + + + \ No newline at end of file diff --git a/user-service/.idea/vcs.xml b/user-service/.idea/vcs.xml new file mode 100644 index 0000000..6c0b863 --- /dev/null +++ b/user-service/.idea/vcs.xml @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file