diff --git a/packages/server/src/loaders/jobs.ts b/packages/server/src/loaders/jobs.ts index c64a8fe72..d3a4dbc1a 100644 --- a/packages/server/src/loaders/jobs.ts +++ b/packages/server/src/loaders/jobs.ts @@ -13,7 +13,9 @@ import { PaymentReceiveMailNotificationJob } from '@/services/Sales/PaymentRecei import { PlaidFetchTransactionsJob } from '@/services/Banking/Plaid/PlaidFetchTransactionsJob'; import { ImportDeleteExpiredFilesJobs } from '@/services/Import/jobs/ImportDeleteExpiredFilesJob'; import { SendVerifyMailJob } from '@/services/Authentication/jobs/SendVerifyMailJob'; -import { RegonizeTransactionsJob } from '@/services/Banking/RegonizeTranasctions/RecognizeTransactionsJob'; +import { ReregonizeTransactionsJob } from '@/services/Banking/RegonizeTranasctions/jobs/RerecognizeTransactionsJob'; +import { RegonizeTransactionsJob } from '@/services/Banking/RegonizeTranasctions/jobs/RecognizeTransactionsJob'; +import { RevertRegonizeTransactionsJob } from '@/services/Banking/RegonizeTranasctions/jobs/RevertRecognizedTransactionsJob'; export default ({ agenda }: { agenda: Agenda }) => { new ResetPasswordMailJob(agenda); @@ -31,6 +33,8 @@ export default ({ agenda }: { agenda: Agenda }) => { new ImportDeleteExpiredFilesJobs(agenda); new SendVerifyMailJob(agenda); new RegonizeTransactionsJob(agenda); + new ReregonizeTransactionsJob(agenda); + new RevertRegonizeTransactionsJob(agenda); agenda.start().then(() => { agenda.every('1 hours', 'delete-expired-imported-files', {}); diff --git a/packages/server/src/services/Banking/RegonizeTranasctions/RevertRecognizedTransactions.ts b/packages/server/src/services/Banking/RegonizeTranasctions/RevertRecognizedTransactions.ts index 9191f1845..2d8247506 100644 --- a/packages/server/src/services/Banking/RegonizeTranasctions/RevertRecognizedTransactions.ts +++ b/packages/server/src/services/Banking/RegonizeTranasctions/RevertRecognizedTransactions.ts @@ -43,7 +43,7 @@ export class RevertRecognizedTransactions { q.whereNotNull('recognizedTransaction.id'); if (rulesIds.length > 0) { - q.where('recognizedTransaction.bankRuleId', rulesIds); + q.whereIn('recognizedTransaction.bankRuleId', rulesIds); } if (transactionsCriteria?.accountId) { q.where('accountId', transactionsCriteria.accountId);