| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970 |
- const API = require('../../lib/API')
- const db = require('../../plugin/DataBase/db')
- const AccessControl = require('../../lib/AccessControl')
- const { BaseStdResponse } = require('../../BaseStdResponse')
- const { executeOrderRefund } = require('../../lib/OrderRefundService')
- class RefundOrder extends API {
- constructor() {
- super()
- this.setPath('/Order/RefundOrder')
- this.setMethod('POST')
- }
- async onRequest(req, res) {
- const { uuid, session, orderId } = req.body
- if ([uuid, session, orderId].some(v => v === '' || v === null || v === undefined)) {
- return res.json({
- ...BaseStdResponse.MISSING_PARAMETER
- })
- }
- if (!await AccessControl.checkSession(uuid, session)) {
- return res.status(401).json({
- ...BaseStdResponse.ACCESS_DENIED
- })
- }
- try {
- const rows = await db.query(
- 'SELECT orderId FROM orders WHERE orderId = ? AND create_user = ? LIMIT 1',
- [orderId, uuid]
- )
- if (!rows || rows.length !== 1) {
- return res.json({
- ...BaseStdResponse.ERR,
- msg: '订单不存在'
- })
- }
- const result = await executeOrderRefund({
- orderId,
- operatorUuid: uuid,
- skipTimeLimit: false,
- logger: this.logger
- })
- if (!result.ok) {
- return res.json({
- ...BaseStdResponse.ERR,
- msg: result.msg
- })
- }
- this.logger.info(`用户申请退款成功,订单号:${orderId}`)
- return res.json({
- ...BaseStdResponse.OK,
- msg: result.msg
- })
- } catch (error) {
- this.logger.error(`用户退款接口异常 ${orderId}: ${error.stack || error}`)
- return res.json({
- ...BaseStdResponse.ERR,
- msg: '退款失败,请稍后再试'
- })
- }
- }
- }
- module.exports.RefundOrder = RefundOrder
|