fix:合并

2023-09-15 17:58:45 +08:00
parent e4343eb2d6
commit ca7cf4c81e
14 changed files with 732 additions and 418 deletions
--- a/service/repositories/order.go
+++ b/service/repositories/order.go
@@ -0,0 +1,151 @@
+package repositories
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+	"fusenapi/model/gmodel"
+	"fusenapi/utils/basic"
+	"fusenapi/utils/shopping_cart"
+	"math"
+
+	"github.com/aws/aws-sdk-go/aws/session"
+	"gorm.io/gorm"
+)
+
+func NewOrder(gormDB *gorm.DB, bLMServiceUrl *string, awsSession *session.Session) Order {
+	return &defaultOrder{
+		MysqlConn: gormDB,
+	}
+}
+
+type (
+	defaultOrder struct {
+		MysqlConn *gorm.DB
+	}
+	Order interface {
+		// 下单
+		// 预支付
+		// 列表
+		// 详情
+	}
+
+	/* 下单 */
+	CreateReq struct {
+		CurrentCurrency  string  `json:"current_currency"`  // 当前货币
+		ExchangeRate     string  `json:"exchange_rate"`     // 换算汇率
+		OriginalCurrency string  `json:"original_currency"` // 原始货币
+		UserId           int64   `json:"user_id"`
+		CartIds          []int64 `json:"cart_ids"`
+		DeliveryMethod   string  `json:"delivery_method"`
+	}
+	CreateRes struct {
+		ErrorCode basic.StatusResponse
+		OrderSn   string
+	}
+	/* 下单 */
+)
+
+// 下单
+func (d *defaultOrder) Create(ctx context.Context, in *CreateReq) (res *CreateRes, err error) {
+	var errorCode basic.StatusResponse
+	err = d.MysqlConn.WithContext(ctx).Transaction(func(tx *gorm.DB) error {
+		// 查询购物车
+		var shoppingCartList []*gmodel.RelaFsShoppingCart
+		resShoppingCartFind := tx.Preload("ShoppingCartProduct").Preload("ShoppingCartProductPriceList").Preload("ShoppingCartProductModel3dList").
+			Where("id IN ?", in.CartIds).
+			Where("user_id = ?", in.UserId).
+			Find(&shoppingCartList)
+		err = resShoppingCartFind.Error
+		if err != nil {
+			return err
+		}
+		shoppingCartListLen := len(shoppingCartList)
+		if shoppingCartListLen == 0 {
+			errorCode = *basic.CodeErrOrderCreatShoppingCartEmpty
+			return errors.New(errorCode.Message)
+		}
+		if shoppingCartListLen != len(in.CartIds) {
+			errorCode = *basic.CodeErrOrderCreatShoppingCartNotMatched
+			return errors.New(errorCode.Message)
+		}
+
+		var orderProductList []*gmodel.OrderProduct
+
+		for _, shoppingCart := range shoppingCartList {
+			// 购物车快照
+			var shoppingCartSnapshot shopping_cart.CartSnapshot
+			// 购物车商品价格
+			var shoppingCartProductPrice *gmodel.FsProductPrice
+			// 购物车商品模型
+			var shoppingCartProductModel3d *gmodel.FsProductModel3d
+			if shoppingCart.Snapshot != nil {
+				json.Unmarshal([]byte(*shoppingCart.Snapshot), &shoppingCartSnapshot)
+			}
+			// 商品异常
+			if shoppingCart.ShoppingCartProduct == nil || (shoppingCart.ShoppingCartProduct != nil && *shoppingCart.ShoppingCartProduct.IsShelf == 0) {
+				errorCode = *basic.CodeErrOrderCreatProductAbsent
+				errorCode.Message = "create order failed, product '" + shoppingCartSnapshot.ProductInfo.ProductName + "'is absent。"
+				return errors.New(errorCode.Message)
+			}
+			// 商品价格异常
+			if len(shoppingCart.ShoppingCartProductPriceList) == 0 {
+				errorCode = *basic.CodeErrOrderCreatProductPriceAbsent
+				errorCode.Message = "create order failed, price of product '" + shoppingCartSnapshot.ProductInfo.ProductName + "'is absent。"
+				return errors.New(errorCode.Message)
+			} else {
+				var isProductPrice bool
+				for _, shoppingCartProductPriceInfo := range shoppingCart.ShoppingCartProductPriceList {
+					if shoppingCart.SizeId == shoppingCartProductPriceInfo.SizeId {
+						shoppingCartProductPrice = shoppingCartProductPriceInfo
+						isProductPrice = true
+						break
+					}
+				}
+				if !isProductPrice {
+					errorCode = *basic.CodeErrOrderCreatProductPriceAbsent
+					errorCode.Message = "create order failed, price of product '" + shoppingCartSnapshot.ProductInfo.ProductName + "'is absent。"
+					return errors.New(errorCode.Message)
+				}
+				shoppingCart.ShoppingCartProductPriceList = []*gmodel.FsProductPrice{shoppingCartProductPrice}
+			}
+
+			// 商品模型异常
+			if len(shoppingCart.ShoppingCartProductModel3dList) == 0 {
+				errorCode = *basic.CodeErrOrderCreatProductAccessoryAbsent
+				errorCode.Message = "create order failed, accessoryof product '" + shoppingCartSnapshot.ProductInfo.ProductName + "'is absent。"
+				return errors.New(errorCode.Message)
+			} else {
+				var isProductModel bool
+				for _, shoppingCartProductModel3dInfo := range shoppingCart.ShoppingCartProductModel3dList {
+					if shoppingCart.SizeId == shoppingCartProductModel3dInfo.SizeId {
+						shoppingCartProductModel3d = shoppingCartProductModel3dInfo
+						isProductModel = true
+						break
+					}
+				}
+				if !isProductModel {
+					errorCode = *basic.CodeErrOrderCreatProductAccessoryAbsent
+					errorCode.Message = "create order failed, accessoryof product '" + shoppingCartSnapshot.ProductInfo.ProductName + "'is absent。"
+					return errors.New(errorCode.Message)
+				}
+				shoppingCart.ShoppingCartProductModel3dList = []*gmodel.FsProductModel3d{shoppingCartProductModel3d}
+			}
+
+			var purchaseQuantity float64 = float64(*shoppingCart.PurchaseQuantity)
+			var eachBoxNum float64 = float64(*shoppingCartProductPrice.EachBoxNum)
+			var boxNum int64 = math.Ceil(purchaseQuantity / eachBoxNum)
+
+			// 存储订单商品
+			orderProductList = append(orderProductList, &gmodel.OrderProduct{})
+		}
+
+		return nil
+	})
+	if err != nil {
+
+	}
+	return &CreateRes{
+		ErrorCode: errorCode,
+	}, nil
+}