fix: 重复生成向量

src/pages/api/model/data/pushModelDataInput.ts

@@ -58,7 +58,7 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse<
       })
       })
     );
     );
 
 
-    generateVector(true);
+    generateVector();
 
 
     jsonRes(res, {
     jsonRes(res, {
       data: insertRes.filter((item) => item.status === 'rejected').length
       data: insertRes.filter((item) => item.status === 'rejected').length

src/pages/api/model/data/pushModelDataJson.ts

@@ -66,7 +66,7 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse<
       })
       })
     );
     );
 
 
-    generateVector(true);
+    generateVector();
 
 
     jsonRes(res, {
     jsonRes(res, {
       data: insertRedisRes.filter((item) => item.status === 'rejected').length
       data: insertRedisRes.filter((item) => item.status === 'rejected').length

src/service/events/generateQA.ts

@@ -17,11 +17,7 @@ export async function generateQA(): Promise<any> {
     console.log('QA 最多5个进程');
     console.log('QA 最多5个进程');
     return;
     return;
   }
   }
-  global.generatingQA += 1;
-
-  setTimeout(() => {
-    generateQA();
-  }, 3000);
+  global.generatingQA++;
 
 
   try {
   try {
     const redis = await connectRedis();
     const redis = await connectRedis();
@@ -136,17 +132,19 @@ export async function generateQA(): Promise<any> {
       text: systemPrompt.content + text + response.rawContent
       text: systemPrompt.content + text + response.rawContent
     });
     });
 
 
+    global.generatingQA--;
+
     generateQA();
     generateQA();
-    generateVector(true);
+    generateVector();
   } catch (error: any) {
   } catch (error: any) {
     console.log(error);
     console.log(error);
     console.log('生成QA错误:', error?.response);
     console.log('生成QA错误:', error?.response);
 
 
     setTimeout(() => {
     setTimeout(() => {
+      global.generatingQA--;
       generateQA();
       generateQA();
     }, 5000);
     }, 5000);
   }
   }
-  global.generatingQA--;
 }
 }
 
 
 /**
 /**

src/service/events/generateVector.ts

-import { getOpenAIApi } from '@/service/utils/chat';
-import { httpsAgent } from '@/service/utils/tools';
 import { connectRedis } from '../redis';
 import { connectRedis } from '../redis';
 import { VecModelDataIdx } from '@/constants/redis';
 import { VecModelDataIdx } from '@/constants/redis';
 import { vectorToBuffer } from '@/utils/tools';
 import { vectorToBuffer } from '@/utils/tools';
@@ -88,6 +86,7 @@ export async function generateVector(next = false): Promise<any> {
       setTimeout(() => {
       setTimeout(() => {
         generateVector(true);
         generateVector(true);
       }, 60000);
       }, 60000);
+      return;
     }
     }
 
 
     setTimeout(() => {
     setTimeout(() => {

src/service/mongo.ts

@@ -30,7 +30,7 @@ export async function connectToDatabase(): Promise<void> {
   global.generatingQA = 0;
   global.generatingQA = 0;
   generateQA();
   generateQA();
   // generateAbstract();
   // generateAbstract();
-  generateVector();
+  generateVector(true);
 }
 }
 
 
 export * from './models/authCode';
 export * from './models/authCode';

src/utils/tools.ts

@@ -75,7 +75,7 @@ export const readPdfContent = (file: File) =>
     const readPDFPage = async (doc: any, pageNo: number) => {
     const readPDFPage = async (doc: any, pageNo: number) => {
       const page = await doc.getPage(pageNo);
       const page = await doc.getPage(pageNo);
       const tokenizedText = await page.getTextContent();
       const tokenizedText = await page.getTextContent();
-      const pageText = tokenizedText.items.map((token: any) => token.str).join('');
+      const pageText = tokenizedText.items.map((token: any) => token.str).join(' ');
       return pageText;
       return pageText;
     };
     };