fix basket

backend/gestion/db/db_commands.go

@@ -148,8 +148,26 @@ func (d *Database) CreateCommand(username string) (*models.Command, error) {
 		return nil, fmt.Errorf("erreur lors de l'insertion des items: %w", err)
 	}
 
-	if err := d.GDB.Exec(`DELETE FROM baskets WHERE username = ?`, username).Error; err != nil {
-		return nil, fmt.Errorf("erreur lors du vidage du panier: %w", err)
+	// Décrémenter le stock et vider le panier de manière atomique.
+	if err := d.GDB.Transaction(func(tx *gorm.DB) error {
+		for _, item := range basketItems {
+			if item.IsReward {
+				continue
+			}
+			var currentStock float64
+			if err := tx.Raw(`SELECT stock FROM products WHERE id = ? FOR UPDATE`, item.ProductID).Scan(&currentStock).Error; err != nil {
+				return fmt.Errorf("erreur lecture stock produit %d: %w", item.ProductID, err)
+			}
+			if currentStock < item.Quantity {
+				return fmt.Errorf("stock insuffisant pour le produit %d", item.ProductID)
+			}
+			if err := tx.Exec(`UPDATE products SET stock = stock - ?, updated_at = CURRENT_TIMESTAMP WHERE id = ?`, item.Quantity, item.ProductID).Error; err != nil {
+				return fmt.Errorf("erreur décrémentation stock produit %d: %w", item.ProductID, err)
+			}
+		}
+		return tx.Exec(`DELETE FROM baskets WHERE username = ?`, username).Error
+	}); err != nil {
+		return nil, err
 	}
 
 	command := &models.Command{
@@ -256,8 +274,27 @@ func (d *Database) CreateCommandWithAddress(username, deliveryAddress string) (*
 		return nil, fmt.Errorf("erreur insertion items: %w", err)
 	}
 
-	if err := d.GDB.Exec(`DELETE FROM baskets WHERE username = ?`, username).Error; err != nil {
-		log.Printf("⚠️ Erreur vidage panier: %v", err)
+	// Décrémenter le stock et vider le panier de manière atomique.
+	if err := d.GDB.Transaction(func(tx *gorm.DB) error {
+		for _, item := range basketItems {
+			if item.IsReward {
+				continue
+			}
+			var currentStock float64
+			if err := tx.Raw(`SELECT stock FROM products WHERE id = ? FOR UPDATE`, item.ProductID).Scan(&currentStock).Error; err != nil {
+				return fmt.Errorf("erreur lecture stock produit %d: %w", item.ProductID, err)
+			}
+			if currentStock < item.Quantity {
+				return fmt.Errorf("stock insuffisant pour le produit %d", item.ProductID)
+			}
+			if err := tx.Exec(`UPDATE products SET stock = stock - ?, updated_at = CURRENT_TIMESTAMP WHERE id = ?`, item.Quantity, item.ProductID).Error; err != nil {
+				return fmt.Errorf("erreur décrémentation stock produit %d: %w", item.ProductID, err)
+			}
+		}
+		return tx.Exec(`DELETE FROM baskets WHERE username = ?`, username).Error
+	}); err != nil {
+		log.Printf("❌ Erreur décrément stock / vidage panier: %v", err)
+		return nil, err
 	}
 
 	sanitizedAddress := sanitizeLogMessage(deliveryAddress)