add shopCart

3dshow/api/collect.go

@@ -54,7 +54,6 @@ func Collect(r *GinRouter) {
 			query["userId"] = userId
 			return query
 		},
-		SearchProject: []string{""},
 		SearchPostProcess: func(page *repo.PageResult, _ *gin.Context, apictx *ApiSession, _ map[string]interface{}) (interface{}, error) {
 			// 查询组装数据
 			if len(page.List) > 0 {
@@ -73,7 +72,7 @@ func Collect(r *GinRouter) {
 					repo.RepoSeachDoc(apictx.CreateRepoCtx(), &repo.DocSearchOptions{
 						CollectName: repo.CollectionSupply,
 						Query:       repo.Map{"_id": supplyId},
-						Project:     []string{"name"},
+						Project:     []string{"name", "avatar", "contact"},
 					}, &supply)
 					v["productName"] = product.Name
 					v["productUnit"] = product.Unit

3dshow/api/router.go

@@ -22,6 +22,9 @@ func RegRouters(svc *Service) {
 	// 地址管理
 	Address(_3dshow)
 
+	// 购物车
+	ShopCart(_3dshow)
+
 	// 订单管理
 	Order(_3dshow)
 

3dshow/api/service.go

@@ -86,6 +86,8 @@ func CreateCRUD(router *GinRouter, prefix string, option *CRUDOption) {
 			}
 
 			out, err := repo.RepoUpdateSetDoc(apictx.CreateRepoCtx(), option.Collection, objId, m)
+			fmt.Println(objId)
+			fmt.Println(m)
 			if err != nil {
 				return nil, err
 			}

3dshow/api/shopCart.go

@@ -0,0 +1,72 @@
+package api
+
+import (
+	"3dshow/db/model"
+	"3dshow/db/repo"
+	"errors"
+	"time"
+
+	"github.com/gin-gonic/gin"
+	"go.mongodb.org/mongo-driver/bson/primitive"
+)
+
+func ShopCart(r *GinRouter) {
+
+	CreateCRUD(r, "/shopCart", &CRUDOption{
+		Collection: repo.CollectionShopCart,
+		NewModel: func(c *gin.Context, apictx *ApiSession) (interface{}, error) {
+			entity := &model.ShopCart{}
+			err := c.ShouldBindJSON(entity)
+			if err != nil {
+				return nil, errors.New("参数错误")
+			}
+			if len(entity.SupplyId) < 12 {
+				return nil, errors.New("供应链id错误")
+			}
+			if len(entity.ProductId) < 12 {
+				return nil, errors.New("商品id错误")
+			}
+			entity.CreateTime = time.Now()
+			_userId := apictx.User.ID
+			userId, _ := primitive.ObjectIDFromHex(_userId)
+			entity.UserId = userId
+
+			return entity, nil
+		},
+		EmtyModel: func(c *gin.Context, apictx *ApiSession) interface{} {
+			return &model.ShopCart{}
+		},
+		JWT: true,
+		SearchFilter: func(_ *gin.Context, apictx *ApiSession, query map[string]interface{}) map[string]interface{} {
+			_userId := apictx.User.ID
+			userId, _ := primitive.ObjectIDFromHex(_userId)
+			query["userId"] = userId
+			return query
+		},
+		OnUpdate: func(_ *gin.Context, _ *ApiSession, entity interface{}) {
+			ety := entity.(*model.ShopCart)
+			ety.UpdateTime = time.Now()
+		},
+		SearchPostProcess: func(page *repo.PageResult, _ *gin.Context, apictx *ApiSession, _ map[string]interface{}) (interface{}, error) {
+			// 查询组装数据
+			if len(page.List) > 0 {
+				for _, v := range page.List {
+					// 查询产品信息
+					supplyId := v["supplyId"].(primitive.ObjectID)
+					supply := model.Supply{}
+					// 供应商信息
+					repo.RepoSeachDoc(apictx.CreateRepoCtx(), &repo.DocSearchOptions{
+						CollectName: repo.CollectionSupply,
+						Query:       repo.Map{"_id": supplyId},
+						Project:     []string{"name", "avatar", "contact"},
+					}, &supply)
+					v["supplyName"] = supply.Name
+					v["supplyAvatar"] = supply.Avatar
+					v["supplyContact"] = supply.Contact
+
+				}
+			}
+			return page, nil
+		},
+	})
+}

3dshow/db/model/json/shopCart.json

@@ -0,0 +1,9 @@
+{
+    "supplyId": "636b1269cd5efc036be2b782",
+    "productId": "636def104fa01c203c478bad",
+    "name": "女士双G裸靴13",
+    "size": 36,
+    "color": "#ff0000",
+    "unit": "SL-H-1989",
+    "cover": "https://sku3d-test.obs.cn-east-3.myhuaweicloud.com/QueenTree/jpg/1667982563590ZJrpiI_1667982548060.jpg"
+}

3dshow/db/model/shopCart.go

@@ -0,0 +1,22 @@
+package model
+
+import (
+	"time"
+
+	"go.mongodb.org/mongo-driver/bson/primitive"
+)
+
+// 购物车
+type ShopCart struct {
+	Id         primitive.ObjectID `bson:"_id,omitempty" json:"_id"` // id
+	UserId     primitive.ObjectID `bson:"userId,omitempty" json:"userId"`
+	SupplyId   primitive.ObjectID `bson:"supplyId,omitempty" json:"supplyId"`   // 供应链id
+	ProductId  primitive.ObjectID `bson:"productId,omitempty" json:"productId"` // 购物车商品id
+	Name       string             `bson:"name,omitempty" json:"name"`
+	Size       int                `bson:"size,omitempty" json:"size"`   // 选定的尺寸
+	Color      string             `bson:"color,omitempty" json:"color"` // 选定的颜色
+	Unit       string             `bson:"unit,omitempty" json:"unit"`   // 型号
+	Cover      string             `bson:"cover,omitempty" json:"cover"` // 封面图
+	CreateTime time.Time          `bson:"createTime,omitempty" json:"createTime"`
+	UpdateTime time.Time          `bson:"updateTime,omitempty" json:"updateTime"`
+}

3dshow/db/repo/repo.go

@@ -18,11 +18,12 @@ type RepoSession struct {
 }
 
 const (
-	CollectionSupply  = "supply"
-	CollectionCollect = "collect"
-	CollectionProduct = "product"
-	CollectionAddress = "address"
-	CollectionOrder   = "order"
+	CollectionSupply   = "supply"
+	CollectionCollect  = "collect"
+	CollectionProduct  = "product"
+	CollectionAddress  = "address"
+	CollectionOrder    = "order"
+	CollectionShopCart = "shopCart"
 )
 
 type Map map[string]interface{}