|
@@ -52,6 +52,12 @@ class ApproveSendCountRequest extends API {
|
|
|
return res.json({ ...BaseStdResponse.ERR, msg: "该申请已审核,请刷新后重试!" })
|
|
return res.json({ ...BaseStdResponse.ERR, msg: "该申请已审核,请刷新后重试!" })
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ const [senderRows] = await conn.execute(
|
|
|
|
|
+ "SELECT username FROM users WHERE uuid = ?",
|
|
|
|
|
+ [request.sender_uuid]
|
|
|
|
|
+ )
|
|
|
|
|
+ const senderUsername = senderRows && senderRows[0] ? senderRows[0].username : "未知用户"
|
|
|
|
|
+
|
|
|
const [receiverRows] = await conn.execute(
|
|
const [receiverRows] = await conn.execute(
|
|
|
"SELECT uuid, lepao_count FROM users WHERE id = ? FOR UPDATE",
|
|
"SELECT uuid, lepao_count FROM users WHERE id = ? FOR UPDATE",
|
|
|
[request.receiver_user_id]
|
|
[request.receiver_user_id]
|
|
@@ -91,7 +97,8 @@ class ApproveSendCountRequest extends API {
|
|
|
balanceAfter: beforeCount + Number(request.count || 0),
|
|
balanceAfter: beforeCount + Number(request.count || 0),
|
|
|
bizType: 'gift_receive',
|
|
bizType: 'gift_receive',
|
|
|
bizId: `send_request:${id}`,
|
|
bizId: `send_request:${id}`,
|
|
|
- operatorUuid: uuid
|
|
|
|
|
|
|
+ operatorUuid: uuid,
|
|
|
|
|
+ remark: `用户${senderUsername}赠送${request.count}次`
|
|
|
})
|
|
})
|
|
|
|
|
|
|
|
await conn.commit()
|
|
await conn.commit()
|
|
@@ -133,7 +140,9 @@ class ApproveSendCountRequest extends API {
|
|
|
this.logger.error(`审核通过赠送申请失败!${err.message || "未知错误"}`)
|
|
this.logger.error(`审核通过赠送申请失败!${err.message || "未知错误"}`)
|
|
|
return res.json({ ...BaseStdResponse.ERR, msg: "审核通过失败,请稍后再试!" })
|
|
return res.json({ ...BaseStdResponse.ERR, msg: "审核通过失败,请稍后再试!" })
|
|
|
} finally {
|
|
} finally {
|
|
|
- conn.release()
|
|
|
|
|
|
|
+ if (conn?.connection && typeof conn.connection.release === 'function' && typeof conn?.release === 'function') {
|
|
|
|
|
+ conn.release()
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|