Forráskód Böngészése

fix: 修复编译错误 - queue模块追踪、cancelAudioGeneration导入、BigInt类型

MyFramework User 3 hónapja
szülő
commit
7ccbab81ce

+ 1 - 1
server/src/modules/book-generator/book-generator.store.ts

@@ -22,7 +22,7 @@ import { consumeAudioMinutes } from '../subscription/subscription.service';
  */
  */
 export async function cancelAudioGeneration(bookId: string): Promise<{ cancelledCount: number; rolledBackChapters: number[] }> {
 export async function cancelAudioGeneration(bookId: string): Promise<{ cancelledCount: number; rolledBackChapters: number[] }> {
   const chapters = await prisma.bookChapter.findMany({
   const chapters = await prisma.bookChapter.findMany({
-    where: { bookId: BigInt(bookId) },
+    where: { bookId: Number(bookId) },
     select: { id: true, level: true },
     select: { id: true, level: true },
   });
   });
 
 

+ 2 - 2
server/src/modules/book-generator/langgraph-controller.ts

@@ -6,7 +6,7 @@
 import Router from '@koa/router';
 import Router from '@koa/router';
 import { Context } from 'koa';
 import { Context } from 'koa';
 import { langGraphGenerator, getScaleConfig, resolveGenLevel, mapBookTypeToGenLevel } from './index';
 import { langGraphGenerator, getScaleConfig, resolveGenLevel, mapBookTypeToGenLevel } from './index';
-import { bookStore } from './book-generator.store';
+import { bookStore, cancelAudioGeneration } from './book-generator.store';
 import { prisma } from '../../models';
 import { prisma } from '../../models';
 import { estimateBookWords, estimateAudioMinutesFromWords, checkBookGenerationQuota, checkAudioQuota } from '../subscription/subscription.service';
 import { estimateBookWords, estimateAudioMinutesFromWords, checkBookGenerationQuota, checkAudioQuota } from '../subscription/subscription.service';
 import { optionalAuth } from '../../middleware/auth';
 import { optionalAuth } from '../../middleware/auth';
@@ -1060,7 +1060,7 @@ router.post('/books/:id/audio/cancel', async (ctx: Context) => {
       return;
       return;
     }
     }
 
 
-    const result = await bookStore.cancelAudioGeneration(bookId);
+    const result = await cancelAudioGeneration(bookId);
 
 
     if (result.cancelledCount === 0) {
     if (result.cancelledCount === 0) {
       ctx.body = {
       ctx.body = {

+ 9 - 0
server/src/modules/queue/queue.controller.ts

@@ -0,0 +1,9 @@
+import Router from '@koa/router';
+
+const router = new Router();
+
+router.get('/status', (ctx) => {
+  ctx.body = { code: 0, message: 'ok', data: { status: 'active' } };
+});
+
+export default router;