+ ![avatar]()
+
+
+
+ 上传头像
+ {{ animal.description || '暂无描述' }}
+管理平台上的所有动物信息
+您的验证码是：${verificationCode}
+验证码将在10分钟后过期，请及时使用。
+如果这不是您的操作，请忽略此邮件。
+ ` + }); + + res.json(success({ + message: '验证码已发送到您的邮箱' + })); + } catch (error) { + next(error); + } +}; + +// 忘记密码 +const forgotPassword = async (req, res, next) => { + try { + const { email } = req.body; + + if (!email) { + throw new AppError('邮箱不能为空', 400); + } + + // 查找用户 + const user = await UserMySQL.findByEmail(email); + if (!user) { + // 为了安全，不暴露用户是否存在 + res.json(success({ + message: '如果该邮箱已注册，重置密码链接已发送到您的邮箱' + })); + return; + } + + // 生成重置token + const resetToken = generateVerificationCode(); + const expiresAt = new Date(Date.now() + 30 * 60 * 1000); // 30分钟后过期 + + // 保存重置token + await UserMySQL.savePasswordResetToken(user.id, resetToken, expiresAt); + + // 发送重置邮件 + await sendEmail({ + to: email, + subject: '结伴客 - 密码重置', + html: ` +您请求重置密码，请点击下面的链接重置您的密码：
+ 重置密码 +此链接将在30分钟后过期。
+如果这不是您的操作，请忽略此邮件。
+ ` + }); + + res.json(success({ + message: '如果该邮箱已注册，重置密码链接已发送到您的邮箱' + })); + } catch (error) { + next(error); + } +}; + +// 重置密码 +const resetPassword = async (req, res, next) => { + try { + const { token, newPassword } = req.body; + + if (!token || !newPassword) { + throw new AppError('重置token和新密码不能为空', 400); + } + + if (newPassword.length < 6) { + throw new AppError('密码长度不能少于6位', 400); + } + + // 验证重置token + const resetData = await UserMySQL.findPasswordResetToken(token); + if (!resetData || new Date() > resetData.expires_at) { + throw new AppError('重置token无效或已过期', 400); + } + + // 加密新密码 + const hashedPassword = await bcrypt.hash(newPassword, 12); + + // 更新密码 + await UserMySQL.updatePassword(resetData.user_id, hashedPassword); + + // 删除重置token + await UserMySQL.deletePasswordResetToken(token); + + res.json(success({ + message: '密码重置成功' + })); + } catch (error) { + next(error); + } +}; + module.exports = { register, login, @@ -314,5 +506,9 @@ module.exports = { updateProfile, changePassword, wechatLogin, - adminLogin + adminLogin, + refreshToken, + sendEmailVerification, + forgotPassword, + resetPassword }; \ No newline at end of file diff --git a/backend/src/controllers/order/index.js b/backend/src/controllers/order/index.js index 1ef08ed..3e2486a 100644 --- a/backend/src/controllers/order/index.js +++ b/backend/src/controllers/order/index.js @@ -191,44 +191,43 @@ async function cancelOrder(req, res, next) { async function payOrder(req, res, next) { try { const { orderId } = req.params; - const userId = req.user.id; const paymentData = req.body; + const userId = req.user.id; // 验证必要字段 - if (!paymentData.payment_method) { + if (!paymentData.payment_method || !paymentData.amount) { return res.status(400).json({ success: false, - message: '缺少必要字段: payment_method' + message: '缺少必要字段: payment_method, amount' }); } - const order = await OrderService.payOrder(orderId, userId, paymentData); - - res.json({ - success: true, - message: '订单支付成功', - data: order - }); - } catch (error) { - console.error('支付订单控制器错误:', error); - if (error.message === '订单不存在') { + // 获取订单并验证权限 + const order = await OrderService.getOrderById(orderId); + if (!order) { return res.status(404).json({ success: false, message: '订单不存在' }); } - if (error.message === '无权操作此订单') { + + // 检查权限：用户只能支付自己的订单 + if (req.user.role === 'user' && order.user_id !== userId) { return res.status(403).json({ success: false, message: '无权操作此订单' }); } - if (error.message === '订单状态不允许支付') { - return res.status(400).json({ - success: false, - message: '订单状态不允许支付' - }); - } + + const result = await OrderService.payOrder(orderId, paymentData); + + res.json({ + success: true, + message: '支付订单创建成功', + data: result + }); + } catch (error) { + console.error('支付订单控制器错误:', error); res.status(500).json({ success: false, message: error.message || '支付订单失败' diff --git a/backend/src/controllers/payment.js b/backend/src/controllers/payment.js new file mode 100644 index 0000000..867a195 --- /dev/null +++ b/backend/src/controllers/payment.js @@ -0,0 +1,371 @@ +const PaymentService = require('../services/payment'); +const { validationResult } = require('express-validator'); + +class PaymentController { + /** + * 创建支付订单 + * @param {Object} req - 请求对象 + * @param {Object} res - 响应对象 + */ + async createPayment(req, res) { + try { + // 验证请求参数 + const errors = validationResult(req); + if (!errors.isEmpty()) { + return res.status(400).json({ + success: false, + message: '参数验证失败', + errors: errors.array() + }); + } + + const paymentData = req.body; + const userId = req.user.id; + + // 验证必要字段 + if (!paymentData.order_id || !paymentData.amount || !paymentData.payment_method) { + return res.status(400).json({ + success: false, + message: '缺少必要字段: order_id, amount, payment_method' + }); + } + + // 添加用户ID + paymentData.user_id = userId; + + const payment = await PaymentService.createPayment(paymentData); + + res.status(201).json({ + success: true, + message: '支付订单创建成功', + data: payment + }); + } catch (error) { + console.error('创建支付订单控制器错误:', error); + res.status(500).json({ + success: false, + message: error.message || '创建支付订单失败' + }); + } + } + + /** + * 获取支付订单详情 + * @param {Object} req - 请求对象 + * @param {Object} res - 响应对象 + */ + async getPayment(req, res) { + try { + const { paymentId } = req.params; + const userId = req.user.id; + + const payment = await PaymentService.getPaymentById(paymentId); + + // 检查权限：用户只能查看自己的支付订单 + if (req.user.role === 'user' && payment.user_id !== userId) { + return res.status(403).json({ + success: false, + message: '无权访问此支付订单' + }); + } + + res.json({ + success: true, + data: payment + }); + } catch (error) { + console.error('获取支付订单控制器错误:', error); + if (error.message === '支付订单不存在') { + return res.status(404).json({ + success: false, + message: '支付订单不存在' + }); + } + res.status(500).json({ + success: false, + message: error.message || '获取支付订单失败' + }); + } + } + + /** + * 查询支付状态 + * @param {Object} req - 请求对象 + * @param {Object} res - 响应对象 + */ + async queryPaymentStatus(req, res) { + try { + const { paymentNo } = req.params; + const userId = req.user.id; + + const payment = await PaymentService.getPaymentByNo(paymentNo); + + // 检查权限 + if (req.user.role === 'user' && payment.user_id !== userId) { + return res.status(403).json({ + success: false, + message: '无权访问此支付订单' + }); + } + + res.json({ + success: true, + data: { + payment_no: payment.payment_no, + status: payment.status, + amount: payment.amount, + paid_at: payment.paid_at, + transaction_id: payment.transaction_id + } + }); + } catch (error) { + console.error('查询支付状态控制器错误:', error); + if (error.message === '支付订单不存在') { + return res.status(404).json({ + success: false, + message: '支付订单不存在' + }); + } + res.status(500).json({ + success: false, + message: error.message || '查询支付状态失败' + }); + } + } + + /** + * 处理支付回调（微信支付） + * @param {Object} req - 请求对象 + * @param {Object} res - 响应对象 + */ + async handleWechatCallback(req, res) { + try { + const callbackData = req.body; + + // 验证回调数据 + if (!callbackData.out_trade_no || !callbackData.transaction_id) { + return res.status(400).json({ + success: false, + message: '回调数据不完整' + }); + } + + // 处理支付回调 + const payment = await PaymentService.handlePaymentCallback({ + payment_no: callbackData.out_trade_no, + transaction_id: callbackData.transaction_id, + status: callbackData.result_code === 'SUCCESS' ? 'paid' : 'failed', + paid_amount: callbackData.total_fee / 100, // 微信金额单位为分 + paid_at: new Date() + }); + + // 返回微信要求的格式 + res.set('Content-Type', 'application/xml'); + res.send(` +