fix: 批量修复功能问题 - 购物车结算/订单库存积分/搜索/抽奖/个人资料等

backend/internal/api/handlers/order.go

@@ -141,7 +141,11 @@ func (h *OrderHandler) Create(c *gin.Context) {
 	}
 
 	var carts []models.Cart
-	utils.DB.Where("user_id = ?", userID).Preload("Product").Find(&carts)
+	cartQuery := utils.DB.Where("user_id = ?", userID).Preload("Product")
+	if len(req.CartItemIDs) > 0 {
+		cartQuery = cartQuery.Where("id IN ?", req.CartItemIDs)
+	}
+	cartQuery.Find(&carts)
 
 	if len(carts) == 0 {
 		c.JSON(http.StatusBadRequest, gin.H{"error": "Cart is empty"})
@@ -154,6 +158,20 @@ func (h *OrderHandler) Create(c *gin.Context) {
 	supplierMap := make(map[uint]bool)
 
 	for _, cart := range carts {
+		if !cart.Product.IsActive {
+			c.JSON(http.StatusBadRequest, gin.H{"error": "Product " + cart.Product.Name + " is no longer available"})
+			return
+		}
+
+		if cart.Product.MinPurchase > 0 && cart.Quantity < cart.Product.MinPurchase {
+			c.JSON(http.StatusBadRequest, gin.H{"error": cart.Product.Name + " minimum purchase is " + strconv.Itoa(cart.Product.MinPurchase)})
+			return
+		}
+		if cart.Product.MaxPurchase != nil && *cart.Product.MaxPurchase > 0 && cart.Quantity > *cart.Product.MaxPurchase {
+			c.JSON(http.StatusBadRequest, gin.H{"error": cart.Product.Name + " maximum purchase is " + strconv.Itoa(*cart.Product.MaxPurchase)})
+			return
+		}
+
 		if cart.Product.RequireCredit {
 			var user models.User
 			utils.DB.First(&user, userID)
@@ -268,7 +286,11 @@ func (h *OrderHandler) Create(c *gin.Context) {
 		}
 	}
 
-	if err := tx.Where("user_id = ?", userID).Delete(&models.Cart{}).Error; err != nil {
+	cartIDs := make([]uint, len(carts))
+	for i, cart := range carts {
+		cartIDs[i] = cart.ID
+	}
+	if err := tx.Where("id IN ? AND user_id = ?", cartIDs, userID).Delete(&models.Cart{}).Error; err != nil {
 		tx.Rollback()
 		c.JSON(http.StatusInternalServerError, gin.H{"error": "Failed to clear cart"})
 		return
@@ -394,7 +416,7 @@ func (h *OrderHandler) ProcessRefund(c *gin.Context) {
 	id, _ := strconv.Atoi(c.Param("id"))
 
 	var order models.Order
-	if err := utils.DB.First(&order, id).Error; err != nil {
+	if err := utils.DB.Preload("OrderItems").First(&order, id).Error; err != nil {
 		c.JSON(http.StatusNotFound, gin.H{"error": "Order not found"})
 		return
 	}
@@ -413,11 +435,35 @@ func (h *OrderHandler) ProcessRefund(c *gin.Context) {
 		}
 
 		refundAmount := order.TotalAmount * (1 - feeRate/100)
-		utils.DB.Model(&order).Updates(map[string]interface{}{
+
+		tx := utils.DB.Begin()
+
+		tx.Model(&order).Updates(map[string]interface{}{
 			"refund_status": models.RefundStatusCompleted,
 			"refund_amount": refundAmount,
 			"status":        models.OrderStatusRefunded,
 		})
+
+		for _, item := range order.OrderItems {
+			var product models.Product
+			if err := tx.First(&product, item.ProductID).Error; err == nil {
+				if product.RequireCredit {
+					tx.Model(&models.User{}).Where("id = ?", order.UserID).
+						UpdateColumn("purchase_credits", utils.DB.Raw("purchase_credits + ?", product.CreditCost*item.Quantity))
+				}
+				if product.CreditReward > 0 {
+					tx.Model(&models.User{}).Where("id = ?", order.UserID).
+						UpdateColumn("purchase_credits", utils.DB.Raw("purchase_credits - ?", product.CreditReward*item.Quantity))
+				}
+			}
+
+			var inventory models.Inventory
+			if err := tx.Where("product_id = ?", item.ProductID).First(&inventory).Error; err == nil {
+				tx.Model(&inventory).UpdateColumn("quantity", inventory.Quantity+item.Quantity)
+			}
+		}
+
+		tx.Commit()
 	} else {
 		utils.DB.Model(&order).Updates(map[string]interface{}{
 			"refund_status": models.RefundStatusRejected,
@@ -441,7 +487,7 @@ func (h *OrderHandler) CancelOrder(c *gin.Context) {
 	id, _ := strconv.Atoi(c.Param("id"))
 
 	var order models.Order
-	if err := utils.DB.Where("id = ? AND user_id = ?", id, userID).First(&order).Error; err != nil {
+	if err := utils.DB.Preload("OrderItems").Where("id = ? AND user_id = ?", id, userID).First(&order).Error; err != nil {
 		c.JSON(http.StatusNotFound, gin.H{"error": "Order not found"})
 		return
 	}
@@ -451,7 +497,29 @@ func (h *OrderHandler) CancelOrder(c *gin.Context) {
 		return
 	}
 
-	utils.DB.Model(&order).Update("status", models.OrderStatusCancelled)
+	tx := utils.DB.Begin()
+	tx.Model(&order).Update("status", models.OrderStatusCancelled)
+
+	for _, item := range order.OrderItems {
+		var product models.Product
+		if err := tx.First(&product, item.ProductID).Error; err == nil {
+			if product.RequireCredit {
+				tx.Model(&models.User{}).Where("id = ?", order.UserID).
+					UpdateColumn("purchase_credits", utils.DB.Raw("purchase_credits + ?", product.CreditCost*item.Quantity))
+			}
+			if product.CreditReward > 0 {
+				tx.Model(&models.User{}).Where("id = ?", order.UserID).
+					UpdateColumn("purchase_credits", utils.DB.Raw("purchase_credits - ?", product.CreditReward*item.Quantity))
+			}
+		}
+
+		var inventory models.Inventory
+		if err := tx.Where("product_id = ?", item.ProductID).First(&inventory).Error; err == nil {
+			tx.Model(&inventory).UpdateColumn("quantity", inventory.Quantity+item.Quantity)
+		}
+	}
+
+	tx.Commit()
 	c.JSON(http.StatusOK, gin.H{"message": "Order cancelled successfully"})
 }