|
|
const pool = require('../db');
|
|
|
|
|
|
async function updateScore(req, res) {
|
|
|
const { student_id, points } = req.body; //假设前端发送的数据是这两部分
|
|
|
const pool = require('../db');
|
|
|
|
|
|
async function updateScore(req, res) {
|
|
|
const { student_id, points } = req.body;
|
|
|
let connection; // 在try块外部声明connection
|
|
|
|
|
|
try {
|
|
|
connection = await pool.getConnection();
|
|
|
|
|
|
// 更新学生的积分并增加点名次数
|
|
|
const [result] = await connection.query(
|
|
|
'UPDATE students SET score = score + ?, call_count = call_count + 1 WHERE student_id = ?',
|
|
|
[points, student_id]
|
|
|
);
|
|
|
|
|
|
if (result.affectedRows > 0) {
|
|
|
// 查询更新后的分数
|
|
|
const [rows] = await connection.query(
|
|
|
'SELECT score FROM students WHERE student_id = ?',
|
|
|
[student_id]
|
|
|
);
|
|
|
|
|
|
if (rows.length > 0) {
|
|
|
const updatedScore = rows[0].score;
|
|
|
return res.send(String(updatedScore));
|
|
|
} else {
|
|
|
return res.status(404).send('学生不存在');
|
|
|
}
|
|
|
} else {
|
|
|
return res.status(404).send('学生不存在');
|
|
|
}
|
|
|
} catch (error) {
|
|
|
console.error('数据库操作失败:', error);
|
|
|
return res.status(500).send('更新积分失败');
|
|
|
} finally {
|
|
|
if (connection) {
|
|
|
connection.release(); // 只有在connection已被赋值时才调用release
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
async function getStudentScore(req, res) {
|
|
|
const { student_id } = req.body;
|
|
|
let connection;
|
|
|
|
|
|
try {
|
|
|
connection = await pool.getConnection();
|
|
|
|
|
|
// 查询指定学生的分数
|
|
|
const [rows] = await connection.query(
|
|
|
'SELECT score FROM students WHERE student_id =?',
|
|
|
[student_id]
|
|
|
);
|
|
|
|
|
|
if (rows.length > 0) {
|
|
|
const score = rows[0].score;
|
|
|
// 修改这里，构建包含student_id和score的对象并返回
|
|
|
return res.json({ student_id, score });
|
|
|
} else {
|
|
|
return res.status(404).json({ message: '学生不存在' });
|
|
|
}
|
|
|
} catch (error) {
|
|
|
console.error('数据库操作失败:', error);
|
|
|
return res.status(500).json({ error: '获取分数失败' });
|
|
|
} finally {
|
|
|
if (connection) {
|
|
|
connection.release();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
module.exports = { updateScore, getStudentScore };
|
|
|
try {
|
|
|
const connection = await pool.getConnection();
|
|
|
const [result] = await connection.query('UPDATE students SET score = score + ?, call_count = call_count + 1 WHERE student_id = ?', [points, student_id]);
|
|
|
|
|
|
if (result.affectedRows > 0) {
|
|
|
res.send({ message: '积分已更新' });
|
|
|
} else {
|
|
|
res.status(404).send({ message: '学生不存在' });
|
|
|
}
|
|
|
|
|
|
connection.release();
|
|
|
} catch (error) {
|
|
|
res.status(500).send({ error: '更新积分失败' });
|
|
|
}
|
|
|
}
|
|
|
|
|
|
module.exports = { updateScore };
|
