fix: add recognize jobs

bigcapitalhq · Aug 7, 2024 · 0025dcf · 0025dcf
1 parent 81995dc
commit 0025dcf
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git 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
@@ -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);