任务奖励

tasks/tasks.controller.js

@@ -1,4 +1,5 @@
 const TasksModel = require("./tasks.model.js");
+const TasksTool = require("./tasks.tool.js");
 
 // Get all task configurations
 exports.getAllTasks = async (req, res) => {
@@ -40,13 +41,35 @@ exports.savePlayerTasks = async (req, res) => {
     const tasksData = req.body;
     tasksData.userId = userId;
 
+    const historyTasks = await TasksModel.getPlayerTasks(userId);
+
     const updatedTasks = await TasksModel.savePlayerTasks(tasksData);
     if (!updatedTasks) {
       return res.status(500).send({ error: "Failed to save player tasks" });
     }
 
+    // Give reward for completing a task
+    for (let i = 0; i < req.body.tasks.length; i++) {
+      const task = req.body.tasks[i];
+      const historyTask = historyTasks.tasks.find(
+        (t) => t.taskId === task.taskId
+      );
+      if (historyTask) {
+        if (historyTask.status != task.status) {
+          if (
+            task.status === TasksTool.TASK_STATUS.CLAIMED &&
+            historyTask.status === TasksTool.TASK_STATUS.COMPLETED
+          ) {
+            // 任务可以领取奖励 且 历史任务状态为完成
+            const taskConfig = await TasksModel.getTaskConfigById(task.taskId);
+            await TasksTool.giveTaskReward(userId, taskConfig);
+          }
+        }
+      }
+    }
+
     res.status(200).send({ success: true });
   } catch (error) {
     res.status(500).send({ error: "Internal server error" });
   }
-};
+};