积分兑换

src/app/api/exchange-history/route.js

@@ -100,6 +100,37 @@ export async function POST(request) {
       exchangeTime,
       exchangeCount,
     } = await request.json();
+
+    // 获取用户当前积分
+    const user = await User.findById(userId);
+    if (!user) {
+      return setCORSHeaders(
+        NextResponse.json(
+          { success: false, error: "未找到用户" },
+          { status: 404 }
+        )
+      );
+    }
+
+    const currentPoints = user.points;
+    const pointsToDeduct = item.points;
+
+    // 检查用户积分是否足够
+    if (currentPoints < pointsToDeduct) {
+      return setCORSHeaders(
+        NextResponse.json(
+          {
+            success: false,
+            error: "积分不足",
+            currentPoints: currentPoints,
+            requiredPoints: pointsToDeduct,
+          },
+          { status: 400 }
+        )
+      );
+    }
+
+    // 创建新的兑换历史记录
     const newExchangeHistory = new ExchangeHistory({
       userId,
       username,
@@ -110,6 +141,31 @@ export async function POST(request) {
       exchangeCount,
     });
     await newExchangeHistory.save();
+
+    // 更新用户积分
+    const updatedUser = await User.findByIdAndUpdate(
+      userId,
+      { $inc: { points: -pointsToDeduct } },
+      { new: true, runValidators: true }
+    );
+
+    if (!updatedUser) {
+      throw new Error("更新用户积分失败");
+    }
+
+    console.log(
+      `用户 ${updatedUser.username} 的积分已扣除 ${pointsToDeduct} 点`
+    );
+
+    // 创建积分加减历史记录
+    const reason = `兑换: ${item.title.replace(/<[^>]*>/g, "").trim()}`;
+    const pointHistory = new PointHistory({
+      user: updatedUser._id,
+      points: -pointsToDeduct,
+      reason: reason,
+    });
+    await pointHistory.save();
+
     const response = NextResponse.json(
       {
         success: true,
@@ -130,24 +186,6 @@ export async function PUT(request) {
   try {
     const { id, ...updateData } = await request.json();
     console.log(id, updateData);
-
-    // 获取原始的兑换历史记录
-    const originalExchangeHistory = await ExchangeHistory.findById(id).populate(
-      "item"
-    );
-    if (!originalExchangeHistory) {
-      return NextResponse.json(
-        { success: false, error: "未找到兑换历史" },
-        { status: 404 }
-      );
-    }
-
-    // 保存原始状态
-    const originalStatus = originalExchangeHistory.status;
-
-    console.log("originalExchangeHistory", originalExchangeHistory);
-
-    // 更新兑换历史
     const updatedExchangeHistory = await ExchangeHistory.findByIdAndUpdate(
       id,
       updateData,
@@ -155,37 +193,12 @@ export async function PUT(request) {
         new: true,
         runValidators: true,
       }
-    ).populate("item");
-
-    // 检查状态是否变更为"已兑换"
-    if (updateData.status === "已兑换" && originalStatus !== "已兑换") {
-      const pointsToDeduct = updatedExchangeHistory.item.points;
-
-      // 更新用户积分
-      const updatedUser = await User.findByIdAndUpdate(
-        updatedExchangeHistory.userId,
-        { $inc: { points: -pointsToDeduct } }, // 减少用户积分
-        { new: true, runValidators: true }
-      );
-
-      if (!updatedUser) {
-        throw new Error("更新用户积分失败");
-      }
-
-      console.log(
-        `用户 ${updatedUser.username} 的积分已扣除 ${pointsToDeduct} 点`
+    );
+    if (!updatedExchangeHistory) {
+      return NextResponse.json(
+        { success: false, error: "未找到兑换历史" },
+        { status: 404 }
       );
-
-      // 创建积分历史记录
-      const reason = `兑换: ${updatedExchangeHistory.item.title
-        .replace(/<[^>]*>/g, "")
-        .trim()}`;
-      const pointHistory = new PointHistory({
-        user: updatedUser._id,
-        points: -pointsToDeduct,
-        reason: reason,
-      });
-      await pointHistory.save();
     }
     const response = NextResponse.json(
       { success: true, data: updatedExchangeHistory },

src/app/exchange-points/ExchangeForm.jsx

@@ -3,9 +3,21 @@
 import { useState, useEffect } from "react";
 import { X } from "lucide-react";
 
-export default function ExchangeForm({ currentUser, item, onClose, setAlert }) {
+export default function ExchangeForm({
+  currentUser,
+  setCurrentUser,
+  item,
+  onClose,
+  setAlert,
+}) {
   const [formData, setFormData] = useState({});
   const [isSubmitting, setIsSubmitting] = useState(false);
+  // const [currentUser, setCurrentUser] = useState(null);
+
+  // useEffect(() => {
+  //   const user = JSON.parse(localStorage.getItem("currentUser") || "null");
+  //   setCurrentUser(user);
+  // }, []);
 
   const handleInputChange = (e) => {
     setFormData({ ...formData, [e.target.name]: e.target.value });
@@ -19,7 +31,7 @@ export default function ExchangeForm({ currentUser, item, onClose, setAlert }) {
       const params = {
         userId: currentUser.id,
         username: currentUser.username,
-        item: item._id,
+        item,
         status: "待兑换未审核",
         exchangeInfo: {
           account: formData.account || "",
@@ -50,6 +62,11 @@ export default function ExchangeForm({ currentUser, item, onClose, setAlert }) {
           message: "提交成功，正在审核中",
         });
         onClose();
+        const updatedUser = {
+          ...currentUser,
+          points: currentUser.points - item.points,
+        };
+        setCurrentUser(updatedUser);
       } else {
         setAlert({ type: "error", message: res.error });
       }

src/app/exchange-points/page.js

@@ -67,6 +67,10 @@ export default function ExchangePage() {
   };
 
   const handleExchange = (item) => {
+    if (currentUser.points < item.points) {
+      setAlert({ type: "error", message: "积分不足，无法兑换" });
+      return;
+    }
     setSelectedItem(item);
   };
 
@@ -181,6 +185,7 @@ export default function ExchangePage() {
         {selectedItem && (
           <ExchangeForm
             currentUser={currentUser}
+            setCurrentUser={setCurrentUser}
             item={selectedItem}
             setAlert={setAlert}
             onClose={() => setSelectedItem(null)}

src/app/personal-center/page.jsx

@@ -47,6 +47,7 @@ const PersonalCenter = () => {
               storedUser.id
             )}&current=1&pageSize=${PAGE_SIZE}`
           ),
+          // 获取最新积分信息
           fetch(`/api/user?id=${encodeURIComponent(storedUser.id)}`),
           fetch("/api/new-activities", {
             headers: {