40 lines
1.2 KiB
TypeScript
40 lines
1.2 KiB
TypeScript
import { and, db, eq, songReplayRequests } from '~/drizzle/db'
|
|
|
|
export default defineEventHandler(async (event) => {
|
|
// 1. 检查用户认证
|
|
const user = event.context.user
|
|
if (!user) {
|
|
throw createError({ statusCode: 401, message: '需要登录才能取消重播申请' })
|
|
}
|
|
|
|
// 2. 读取请求体
|
|
const body = await readBody(event)
|
|
const { songId } = body
|
|
|
|
if (!songId) {
|
|
throw createError({ statusCode: 400, message: '歌曲ID不能为空' })
|
|
}
|
|
|
|
// 3. 检查申请是否存在且属于该用户
|
|
const existing = await db
|
|
.select()
|
|
.from(songReplayRequests)
|
|
.where(and(eq(songReplayRequests.songId, songId), eq(songReplayRequests.userId, user.id)))
|
|
.limit(1)
|
|
|
|
if (existing.length === 0) {
|
|
throw createError({ statusCode: 404, message: '重播申请不存在或无权取消' })
|
|
}
|
|
|
|
// 4. 删除申请记录
|
|
try {
|
|
await db
|
|
.delete(songReplayRequests)
|
|
.where(and(eq(songReplayRequests.songId, songId), eq(songReplayRequests.userId, user.id)))
|
|
return { success: true, message: '已取消重播申请' }
|
|
} catch (error: any) {
|
|
console.error('取消重播申请失败:', error)
|
|
throw createError({ statusCode: 500, message: '取消重播申请失败，请稍后再试' })
|
|
}
|
|
})
|