mirror of
https://github.com/geekgeekrun/geekgeekrun.git
synced 2026-09-08 17:09:07 +08:00
fix: reduce argument getBossIdsByJobIds count to fix error: Error: SQLITE_ERROR: Expression tree is too large (maximum depth 1000)
This commit is contained in:
@@ -38,6 +38,7 @@ import { MarkAsNotSuitOp, MarkAsNotSuitReason } from "./enums";
|
|||||||
import { AddColumnForMarkAsNotSuitLog1746092370665 } from "./migrations/1746092370665-AddColumnForMarkAsNotSuitLog";
|
import { AddColumnForMarkAsNotSuitLog1746092370665 } from "./migrations/1746092370665-AddColumnForMarkAsNotSuitLog";
|
||||||
import { Init1000000000000 } from "./migrations/1000000000000-Init";
|
import { Init1000000000000 } from "./migrations/1000000000000-Init";
|
||||||
import { AddJobSourceColumnForChatStartupLogAndMarkAsNotSuitLog1752380078526 } from "./migrations/1752380078526-AddJobSourceColumnForChatStartupLogAndMarkAsNotSuitLog";
|
import { AddJobSourceColumnForChatStartupLogAndMarkAsNotSuitLog1752380078526 } from "./migrations/1752380078526-AddJobSourceColumnForChatStartupLogAndMarkAsNotSuitLog";
|
||||||
|
const lodashImportPromise = import('lodash-es')
|
||||||
|
|
||||||
export function initDb(dbFilePath) {
|
export function initDb(dbFilePath) {
|
||||||
const { DataSource } = requireTypeorm()
|
const { DataSource } = requireTypeorm()
|
||||||
@@ -178,7 +179,13 @@ export default class SqlitePlugin {
|
|||||||
if (chattedJobIds.length === 0) {
|
if (chattedJobIds.length === 0) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
const chattedBossIds = ((await getBossIdsByJobIds(ds, chattedJobIds)) ?? []).map(it => it.encryptBossId)
|
const { chunk } = await lodashImportPromise
|
||||||
|
const chattedJobIdChunks = chunk(chattedJobIds, 200)
|
||||||
|
const chattedBossIds = [];
|
||||||
|
for (const chattedJobIdChunk of chattedJobIdChunks) {
|
||||||
|
const chattedBossIdChunk = ((await getBossIdsByJobIds(ds, chattedJobIdChunk)) ?? []).map(it => it.encryptBossId)
|
||||||
|
chattedBossIds.push(...chattedBossIdChunk)
|
||||||
|
}
|
||||||
for (const id of chattedBossIds) {
|
for (const id of chattedBossIds) {
|
||||||
blockBossNotNewChat.add(id)
|
blockBossNotNewChat.add(id)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user