src/ApplicationBundle/Modules/Aspire/Controller/AspireController.php line 39

Open in your IDE?
  1. <?php
  3. namespace ApplicationBundle\Modules\Aspire\Controller;
  5. use ApplicationBundle\Controller\GenericController;
  6. use ApplicationBundle\Entity\AccTransactionDetails;
  7. use ApplicationBundle\Entity\AccTransactions;
  8. use ApplicationBundle\Entity\AspireAccount;
  9. use ApplicationBundle\Entity\AspireConnection;
  10. use ApplicationBundle\Entity\AspirePayout;
  11. use ApplicationBundle\Entity\AspirePayoutItem;
  12. use ApplicationBundle\Entity\AspirePostRule;
  13. use ApplicationBundle\Entity\AspireTransaction;
  14. use ApplicationBundle\Helper\Crypt;
  15. use ApplicationBundle\Interfaces\SessionCheckInterface;
  16. use ApplicationBundle\Modules\Aspire\Aspire;
  17. use ApplicationBundle\Modules\Authentication\Constants\UserConstants;
  18. use Symfony\Component\HttpFoundation\JsonResponse;
  19. use Symfony\Component\HttpFoundation\Request;
  20. use Symfony\Component\HttpFoundation\Response;
  22. class AspireController extends GenericController implements SessionCheckInterface
  23. {
  24.     private function boot(): void
  25.     {
  26.         $key = '';
  27.         try {
  28.             $key = $this->getParameter('app_encryption_key');
  29.         } catch (\Exception $e) {}
  30.         if ($key) {
  31.             Crypt::setKey($key);
  32.         }
  33.     }
  35.     // =========================================================================
  36.     // CONNECTIONS
  37.     // =========================================================================
  39.     public function connectionListAction(Request $request): Response
  40.     {
  41.         $this->boot();
  42.         $em      = $this->getDoctrine()->getManager();
  43.         $session = $request->getSession();
  44.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  46.         $connections = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')
  47.             ->findBy(['companyId' => $companyId], ['id' => 'DESC']);
  49.         return $this->render('@Aspire/pages/list/list_aspire_connections.html.twig', [
  50.             'connections' => $connections,
  51.             'page_title'  => 'Aspire Connect — Connections',
  52.         ]);
  53.     }
  55.     /**
  56.      * Aspire Accounts ⇄ ERP bank-account (GL head) mapping. Each Aspire account
  57.      * (multi-currency) maps to a local bank_accounts row whose accounts_head_id is
  58.      * the GL head used when posting that account's transactions. A tenant default
  59.      * (acc_setting aspire_default_bank_account_id) is the fallback.
  60.      */
  61.     public function accountListAction(Request $request): Response
  62.     {
  63.         $this->boot();
  64.         $em        = $this->getDoctrine()->getManager();
  65.         $conn      = $em->getConnection();
  66.         $companyId  = $request->getSession()->get(UserConstants::USER_COMPANY_ID);
  68.         $accounts = $conn->fetchAllAssociative(
  69.             "SELECT aa.id, aa.aspire_account_id, aa.account_type, aa.currency_code, aa.available_balance, aa.bank_account_id,
  70.                     ba.account_holder_name AS bank_name, ba.account_number, ba.accounts_head_id,
  71.                     ah.name AS gl_head_name
  72.              FROM aspire_account aa
  73.              LEFT JOIN bank_accounts ba ON ba.id = aa.bank_account_id
  74.              LEFT JOIN acc_accounts_head ah ON ah.accounts_head_id = ba.accounts_head_id
  75.              WHERE aa.company_id = ? ORDER BY aa.currency_code, aa.aspire_account_id",
  76.             [$companyId]
  77.         );
  78.         $bankAccounts = $conn->fetchAllAssociative(
  79.             "SELECT ba.id, ba.account_holder_name, ba.account_number, ba.currency_code, ba.accounts_head_id, ah.name AS gl_head_name
  80.              FROM bank_accounts ba LEFT JOIN acc_accounts_head ah ON ah.accounts_head_id = ba.accounts_head_id
  81.              ORDER BY ba.account_holder_name"
  82.         );
  83.         $defaultBankId = (int) $conn->fetchOne("SELECT data FROM acc_setting WHERE name = 'aspire_default_bank_account_id' LIMIT 1");
  85.         return $this->render('@Aspire/pages/list/aspire_accounts.html.twig', [
  86.             'accounts'      => $accounts,
  87.             'bankAccounts'  => $bankAccounts,
  88.             'defaultBankId' => $defaultBankId,
  89.             'page_title'    => 'Aspire Connect — Accounts',
  90.         ]);
  91.     }
  93.     /** POST /aspire/accounts/map — set an account's bank mapping, or the default. */
  94.     public function accountMapAction(Request $request): JsonResponse
  95.     {
  96.         $this->boot();
  97.         $em        = $this->getDoctrine()->getManager();
  98.         $conn      = $em->getConnection();
  99.         $companyId  = (int) $request->getSession()->get(UserConstants::USER_COMPANY_ID);
  101.         // set tenant default fallback
  102.         if ($request->request->get('set_default') !== null) {
  103.             $bankId = (int) $request->request->get('bankAccountId', 0);
  104.             $conn->executeStatement("DELETE FROM acc_setting WHERE name = 'aspire_default_bank_account_id'");
  105.             if ($bankId > 0) {
  106.                 $conn->executeStatement(
  107.                     "INSERT INTO acc_setting (name, data, company_id, created_at) VALUES ('aspire_default_bank_account_id', ?, ?, NOW())",
  108.                     [(string) $bankId, $companyId]
  109.                 );
  110.             }
  111.             return new JsonResponse(['success' => true]);
  112.         }
  114.         // map a specific Aspire account → bank account (+ backfill its txns)
  115.         $accId  = (int) $request->request->get('id', 0);
  116.         $bankId = (int) $request->request->get('bankAccountId', 0);
  117.         $acct = $accId ? $em->getRepository('ApplicationBundle\\Entity\\AspireAccount')->find($accId) : null;
  118.         if (!$acct || $acct->getCompanyId() != $companyId) {
  119.             return new JsonResponse(['success' => false, 'message' => 'Account not found.']);
  120.         }
  121.         $acct->setBankAccountId($bankId ?: null);
  122.         $em->flush();
  123.         // backfill un-posted transactions of this Aspire account with the mapped wallet
  124.         $backfilled = $conn->executeStatement(
  125.             "UPDATE aspire_transaction SET local_bank_account_id = ?
  126.              WHERE company_id = ? AND aspire_account_id = ? AND status NOT IN ('posted','auto_posted','matched')",
  127.             [$bankId ?: 0, $companyId, $acct->getAspireAccountId()]
  128.         );
  129.         return new JsonResponse(['success' => true, 'backfilled' => $backfilled]);
  130.     }
  132.     public function connectionFormAction(Request $request, int $id = 0): Response
  133.     {
  134.         $this->boot();
  135.         $em      = $this->getDoctrine()->getManager();
  136.         $session = $request->getSession();
  137.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  139.         $conn = $id ? $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')->find($id) : null;
  140.         if ($conn && $conn->getCompanyId() != $companyId) {
  141.             return $this->redirectToRoute('aspire_connection_list');
  142.         }
  144.         $bankAccounts = $em->getRepository('ApplicationBundle\\Entity\\BankAccounts')
  145.             ->createQueryBuilder('b')
  146.             ->where('b.docBookedFlag != 1 OR b.docBookedFlag IS NULL')
  147.             ->getQuery()->getResult();
  149.         return $this->render('@Aspire/pages/input_forms/aspire_connection.html.twig', [
  150.             'conn'         => $conn,
  151.             'bankAccounts' => $bankAccounts,
  152.             'page_title'   => $conn ? 'Edit Connection' : 'New Aspire Connection',
  153.         ]);
  154.     }
  156.     public function connectionSaveAction(Request $request): JsonResponse
  157.     {
  158.         $this->boot();
  159.         $em      = $this->getDoctrine()->getManager();
  160.         $session = $request->getSession();
  161.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  162.         $loginId   = $session->get(UserConstants::USER_LOGIN_ID);
  164.         $id    = (int)$request->request->get('id', 0);
  165.         $label = trim($request->request->get('label', ''));
  166.         $clientId     = trim($request->request->get('client_id', ''));
  167.         $clientSecret = trim($request->request->get('client_secret', ''));
  168.         $defaultBankAccountId = (int)$request->request->get('default_bank_account_id', 0) ?: null;
  169.         $payoutClientId     = trim($request->request->get('payout_client_id', '')) ?: null;
  170.         $payoutClientSecret = trim($request->request->get('payout_client_secret', '')) ?: null;
  172.         $initialSyncDateStr = trim($request->request->get('initial_sync_date', ''));
  173.         $initialSyncDate = $initialSyncDateStr ? new \DateTime($initialSyncDateStr) : null;
  175.         if (!$label || !$clientId) {
  176.             return new JsonResponse(['success' => false, 'message' => 'Label and Client ID are required.']);
  177.         }
  179.         if ($id) {
  180.             $conn = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')->find($id);
  181.             if (!$conn || $conn->getCompanyId() != $companyId) {
  182.                 return new JsonResponse(['success' => false, 'message' => 'Not found.']);
  183.             }
  184.             $conn->setEditLoginId($loginId);
  185.         } else {
  186.             $conn = new AspireConnection();
  187.             $conn->setCompanyId($companyId);
  188.             $conn->setCreateLoginId($loginId);
  189.             $conn->setStatus('active');
  190.         }
  192.         $conn->setLabel($label);
  193.         $conn->setClientId($clientId);
  194.         if ($clientSecret) {
  195.             $conn->setClientSecret(Crypt::encrypt($clientSecret));
  196.         }
  197.         $conn->setDefaultBankAccountId($defaultBankAccountId);
  198.         $conn->setInitialSyncDate($initialSyncDate);
  200.         // Payout credentials (optional, separate Aspire API key for transfers)
  201.         if ($payoutClientId !== null) {
  202.             $conn->setPayoutClientId($payoutClientId ?: null);
  203.         }
  204.         if ($payoutClientSecret) {
  205.             $conn->setPayoutClientSecret(Crypt::encrypt($payoutClientSecret));
  206.         } elseif ($payoutClientId === '') {
  207.             // Clearing payout client id also clears the secret
  208.             $conn->setPayoutClientSecret(null);
  209.         }
  211.         $em->persist($conn);
  212.         $em->flush();
  214.         return new JsonResponse(['success' => true, 'id' => $conn->getId()]);
  215.     }
  217.     public function connectionTestAction(Request $request, int $id): JsonResponse
  218.     {
  219.         $this->boot();
  220.         $em      = $this->getDoctrine()->getManager();
  221.         $session = $request->getSession();
  222.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  224.         $conn = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')->find($id);
  225.         if (!$conn || $conn->getCompanyId() != $companyId) {
  226.             return new JsonResponse(['success' => false, 'message' => 'Not found.']);
  227.         }
  229.         // Force token refresh
  230.         $conn->setTokenExpiresAt(0);
  231.         $token = Aspire::getValidAccessToken($conn, $em);
  232.         if (!$token) {
  233.             $detail = $conn->getLastSyncError() ?: 'No error detail stored.';
  234.             return new JsonResponse(['success' => false, 'message' => 'Invalid credentials — could not obtain token. Detail: ' . $detail]);
  235.         }
  237.         $resp = Aspire::makeRequest(Aspire::BASE_URL . '/accounts', $token);
  238.         if (!empty($resp['error']) || ($resp['http_code'] ?? 200) >= 400) {
  239.             return new JsonResponse(['success' => false, 'message' => 'Credentials valid but /accounts returned an error.', 'detail' => $resp]);
  240.         }
  242.         $count = count($resp['data'] ?? []);
  243.         return new JsonResponse(['success' => true, 'message' => "Connected. Found {$count} Aspire account(s)."]);
  244.     }
  246.     public function connectionDisableAction(Request $request, int $id): JsonResponse
  247.     {
  248.         $this->boot();
  249.         $em      = $this->getDoctrine()->getManager();
  250.         $session = $request->getSession();
  251.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  253.         $conn = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')->find($id);
  254.         if (!$conn || $conn->getCompanyId() != $companyId) {
  255.             return new JsonResponse(['success' => false]);
  256.         }
  258.         $conn->setStatus($conn->getStatus() === 'disabled' ? 'active' : 'disabled');
  259.         $em->flush();
  260.         return new JsonResponse(['success' => true, 'status' => $conn->getStatus()]);
  261.     }
  263.     public function connectionDeleteAction(Request $request, int $id): JsonResponse
  264.     {
  265.         $this->boot();
  266.         $em      = $this->getDoctrine()->getManager();
  267.         $session = $request->getSession();
  268.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  270.         $conn = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')->find($id);
  271.         if (!$conn || $conn->getCompanyId() != $companyId) {
  272.             return new JsonResponse(['success' => false]);
  273.         }
  275.         $conn->setStatus('deleted');
  276.         $em->flush();
  277.         return new JsonResponse(['success' => true]);
  278.     }
  280.     // =========================================================================
  281.     // ACCOUNT MAPPING
  282.     // =========================================================================
  284.     public function accountMapSaveAction(Request $request): JsonResponse
  285.     {
  286.         $this->boot();
  287.         $em        = $this->getDoctrine()->getManager();
  288.         $session   = $request->getSession();
  289.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  291.         $aspireAccountEntityId = (int)$request->request->get('aspire_account_entity_id');
  292.         $bankAccountId         = (int)$request->request->get('bank_account_id') ?: null;
  294.         $acct = $em->getRepository('ApplicationBundle\\Entity\\AspireAccount')->find($aspireAccountEntityId);
  295.         if (!$acct || $acct->getCompanyId() != $companyId) {
  296.             return new JsonResponse(['success' => false]);
  297.         }
  299.         $acct->setBankAccountId($bankAccountId);
  300.         $em->flush();
  301.         return new JsonResponse(['success' => true]);
  302.     }
  304.     // =========================================================================
  305.     // TRANSACTIONS (staging inbox)
  306.     // =========================================================================
  308.     public function transactionListAction(Request $request): Response
  309.     {
  310.         $em        = $this->getDoctrine()->getManager();
  311.         $session   = $request->getSession();
  312.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  314.         $status       = $request->query->get('status', '');
  315.         $connectionId = (int)$request->query->get('connection_id', 0);
  317.         $qb = $em->getRepository('ApplicationBundle\\Entity\\AspireTransaction')
  318.             ->createQueryBuilder('t')
  319.             ->where('t.companyId = :cid')
  320.             ->setParameter('cid', $companyId)
  321.             ->orderBy('t.postedAt', 'DESC')
  322.             ->setMaxResults(500);
  324.         if ($status) {
  325.             $qb->andWhere('t.status = :st')->setParameter('st', $status);
  326.         }
  327.         if ($connectionId) {
  328.             $qb->andWhere('t.connectionId = :conn')->setParameter('conn', $connectionId);
  329.         }
  331.         $transactions = $qb->getQuery()->getResult();
  333.         $connections = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')
  334.             ->findBy(['companyId' => $companyId]);
  336.         return $this->render('@Aspire/pages/list/list_aspire_transactions.html.twig', [
  337.             'transactions' => $transactions,
  338.             'connections'  => $connections,
  339.             'status'       => $status,
  340.             'connectionId' => $connectionId,
  341.             'page_title'   => 'Aspire Connect — Transactions',
  342.         ]);
  343.     }
  345.     public function transactionViewAction(Request $request, int $id): Response
  346.     {
  347.         $em        = $this->getDoctrine()->getManager();
  348.         $session   = $request->getSession();
  349.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  351.         $txn = $em->getRepository('ApplicationBundle\\Entity\\AspireTransaction')->find($id);
  352.         if (!$txn || $txn->getCompanyId() != $companyId) {
  353.             return $this->redirectToRoute('aspire_txn_list');
  354.         }
  356.         // Functional currency + the live engine rate, so the view can show the
  357.         // FX-rate override only for foreign txns and pre-fill the auto rate.
  358.         $fqp      = '\ApplicationBundle\Modules\Accounts\Service\FxRateProvider';
  359.         $baseCode = strtoupper((string) ($fqp::resolveBaseCurrency($em, (int) $companyId) ?: ''));
  360.         $currCode = strtoupper((string) $txn->getCurrencyCode());
  361.         $autoRate = null;
  362.         if ($currCode && $baseCode && $currCode !== $baseCode) {
  363.             $d = $txn->getPostedAt() ?: new \DateTime();
  364.             // getRate() throws if no rate row exists — that's fine, just show no auto rate.
  365.             try { $r = (float) $fqp::getRate($em, $currCode, $baseCode, $d, 'MID'); if ($r > 0) { $autoRate = $r; } }
  366.             catch (\Throwable $e) {}
  367.         }
  369.         return $this->render('@Aspire/pages/view/view_aspire_transaction.html.twig', [
  370.             'txn'                => $txn,
  371.             'page_title'         => 'Transaction #' . $txn->getId(),
  372.             'base_currency_code' => $baseCode,
  373.             'auto_rate'          => $autoRate,
  374.         ]);
  375.     }
  377.     public function transactionPostNowAction(Request $request, int $id): JsonResponse
  378.     {
  379.         $this->boot();
  380.         $em        = $this->getDoctrine()->getManager();
  381.         $session   = $request->getSession();
  382.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  383.         $loginId   = $session->get(UserConstants::USER_LOGIN_ID);
  385.         $txn = $em->getRepository('ApplicationBundle\\Entity\\AspireTransaction')->find($id);
  386.         if (!$txn || $txn->getCompanyId() != $companyId) {
  387.             return new JsonResponse(['success' => false, 'message' => 'Not found.']);
  388.         }
  389.         if (in_array($txn->getStatus(), ['posted', 'auto_posted'])) {
  390.             return new JsonResponse(['success' => false, 'message' => 'Already posted.']);
  391.         }
  393.         $debitHead  = (int)$request->request->get('debit_account_head_id');
  394.         $creditHead = (int)$request->request->get('credit_account_head_id');
  395.         $notes      = $request->request->get('notes', '');
  397.         if (!$debitHead || !$creditHead) {
  398.             return new JsonResponse(['success' => false, 'message' => 'Select both debit and credit accounts.']);
  399.         }
  401.         $rule = new AspirePostRule();
  402.         $rule->setDebitAccountHeadId($debitHead);
  403.         $rule->setCreditAccountHeadId($creditHead);
  404.         $rule->setAutoPost(true);
  405.         $rule->setEnabled(true);
  407.         $txn->setNotes($notes);
  409.         // Optional per-leg FX rate overrides from the inbox (blank => engine default).
  410.         $opts   = [];
  411.         $drRate = $request->request->get('dr_rate', '');
  412.         $crRate = $request->request->get('cr_rate', '');
  413.         if ($drRate !== '' && (float) $drRate > 0) { $opts['drRate'] = (float) $drRate; }
  414.         if ($crRate !== '' && (float) $crRate > 0) { $opts['crRate'] = (float) $crRate; }
  416.         $ok = Aspire::postTransactionToGL($txn, $rule, $em, $loginId, $opts);
  417.         if ($ok) {
  418.             $txn->setStatus('posted');
  419.             $em->flush();
  421.             // Audit-Ready: the moment cash posts, check whether this party head is already documented
  422.             // (tagged to an invoice) or needs a source document → open/close the case automatically.
  423.             // Advisory only — never allowed to affect the GL post.
  424.             try {
  425.                 (new \ApplicationBundle\Modules\Accounts\Service\AuditReadyReconciliationService($em))
  426.                     ->evaluateAfterPosting([$debitHead, $creditHead], null, (int) $loginId);
  427.             } catch (\Throwable $e) { /* audit-ready is advisory — never break a GL post */ }
  429.             // Build pre-filled suggest_rule payload for the "save as rule?" modal
  430.             $matchVal = '';
  431.             if ($txn->getDescription()) {
  432.                 $words = array_slice(preg_split('/\s+/', trim($txn->getDescription())), 0, 4);
  433.                 $matchVal = implode(' ', $words);
  434.             }
  435.             $suggestRule = [
  436.                 'name'                  => substr($txn->getDescription() ?: $txn->getReference() ?: '', 0, 80),
  437.                 'match_type'            => $txn->getCounterparty() ? 'counterparty_equals' : 'description_contains',
  438.                 'match_value'           => $txn->getCounterparty() ?: $matchVal,
  439.                 'currency_code'         => $txn->getCurrencyCode(),
  440.                 'direction_filter'      => $txn->getDirection() ?: 'both',
  441.                 'debit_account_head_id' => $debitHead,
  442.                 'credit_account_head_id'=> $creditHead,
  443.             ];
  445.             return new JsonResponse(['success' => true, 'suggest_rule' => $suggestRule]);
  446.         }
  447.         return new JsonResponse(['success' => false, 'message' => 'GL posting failed — check account head configuration.']);
  448.     }
  450.     /**
  451.      * Undo a post / match so the bank transaction can be re-linked.
  452.      *  - posted / auto_posted: Aspire CREATED a standalone GL voucher → reverse + delete
  453.      *    it (DeleteDocument::AccTransactions un-hits the ledger), drop the feed overlay.
  454.      *  - matched: linked to a PRE-EXISTING voucher → only UNLINK + drop our feed overlay;
  455.      *    never delete that voucher (it wasn't ours).
  456.      * The transaction returns to 'new' so it re-appears in the inbox for re-posting/re-linking.
  457.      * POST /aspire/transaction/undo/{id}
  458.      */
  459.     public function transactionUndoAction(Request $request, int $id): JsonResponse
  460.     {
  461.         $this->boot();
  462.         $em        = $this->getDoctrine()->getManager();
  463.         $session   = $request->getSession();
  464.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  466.         $txn = $em->getRepository('ApplicationBundle\\Entity\\AspireTransaction')->find($id);
  467.         if (!$txn || $txn->getCompanyId() != $companyId) {
  468.             return new JsonResponse(['success' => false, 'message' => 'Not found.']);
  469.         }
  471.         $status    = $txn->getStatus();
  472.         $voucherId = (int) $txn->getAccTransactionsId();
  473.         if (!in_array($status, ['posted', 'auto_posted', 'matched'])) {
  474.             return new JsonResponse(['success' => false, 'message' => 'Nothing to undo — this transaction is not posted or matched.']);
  475.         }
  477.         // An FX conversion posts BOTH legs onto ONE voucher — collect every Aspire leg
  478.         // linked to the same voucher so they all reset together (otherwise the paired leg
  479.         // is left orphaned, pointing at a voucher that's been deleted → "can't undo").
  480.         $repo     = $em->getRepository('ApplicationBundle\\Entity\\AspireTransaction');
  481.         $siblings = $voucherId
  482.             ? $repo->findBy(['accTransactionsId' => $voucherId, 'companyId' => $companyId])
  483.             : [];
  484.         if (empty($siblings)) { $siblings = [$txn]; }
  486.         try {
  487.             if ($status === 'matched') {
  488.                 // Linked to an existing voucher — unlink only, never delete it.
  489.                 if ($voucherId) { \ApplicationBundle\Modules\Aspire\Aspire::unmarkReconciledFromFeed($em, $voucherId); }
  490.                 $message = $voucherId
  491.                     ? ('Unlinked from voucher #' . $voucherId . ' — it can now be re-linked or posted.')
  492.                     : 'Unlinked — it can now be re-linked or posted.';
  493.             } else {
  494.                 // We created this voucher — reverse the GL hit by deleting it (once). Tolerate
  495.                 // an already-deleted voucher (e.g. undoing the orphaned second leg).
  496.                 if ($voucherId) {
  497.                     \ApplicationBundle\Modules\Aspire\Aspire::unmarkReconciledFromFeed($em, $voucherId);
  498.                     $stillExists = $em->getConnection()->fetchOne(
  499.                         'SELECT transaction_id FROM acc_transactions WHERE transaction_id = ?', [$voucherId]
  500.                     );
  501.                     if ($stillExists) {
  502.                         \ApplicationBundle\Modules\System\DeleteDocument::AccTransactions($em, $voucherId, 1);
  503.                     }
  504.                 }
  505.                 $legNote = (count($siblings) > 1) ? (' (' . count($siblings) . ' legs reset)') : '';
  506.                 $message = $voucherId
  507.                     ? ('GL post reversed (voucher #' . $voucherId . ' deleted)' . $legNote . ' — it can now be re-posted or linked.')
  508.                     : 'Post reversed — it can now be re-posted or linked.';
  509.             }
  511.             $stamp = (new \DateTime())->format('Y-m-d H:i');
  512.             foreach ($siblings as $leg) {
  513.                 $leg->setAccTransactionsId(null);
  514.                 $leg->setMatchedRuleId(null);
  515.                 $leg->setPostedAtErp(null);
  516.                 $leg->setPostedLoginId(null);
  517.                 $leg->setStatus('new');
  518.                 $note = trim((string) $leg->getNotes());
  519.                 $leg->setNotes(trim($note . ' [post/link undone ' . $stamp . ']'));
  520.             }
  521.             $em->flush();
  522.         } catch (\Throwable $e) {
  523.             return new JsonResponse(['success' => false, 'message' => 'Undo failed: ' . $e->getMessage()]);
  524.         }
  526.         return new JsonResponse(['success' => true, 'message' => $message]);
  527.     }
  529.     public function transactionIgnoreAction(Request $request, int $id): JsonResponse
  530.     {
  531.         $em        = $this->getDoctrine()->getManager();
  532.         $session   = $request->getSession();
  533.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  535.         $txn = $em->getRepository('ApplicationBundle\\Entity\\AspireTransaction')->find($id);
  536.         if (!$txn || $txn->getCompanyId() != $companyId) {
  537.             return new JsonResponse(['success' => false]);
  538.         }
  539.         $txn->setStatus('ignored');
  540.         $em->flush();
  541.         return new JsonResponse(['success' => true]);
  542.     }
  544.     /**
  545.      * Candidate existing vouchers to match this bank transaction against — by amount
  546.      * (±tolerance) within a date window, excluding vouchers already linked to another
  547.      * Aspire transaction. GET /aspire/transaction/match-candidates/{id}
  548.      */
  549.     public function transactionMatchCandidatesAction(Request $request, int $id): JsonResponse
  550.     {
  551.         $em        = $this->getDoctrine()->getManager();
  552.         $companyId = $request->getSession()->get(UserConstants::USER_COMPANY_ID);
  553.         $conn      = $em->getConnection();
  555.         $txn = $em->getRepository('ApplicationBundle\\Entity\\AspireTransaction')->find($id);
  556.         if (!$txn || $txn->getCompanyId() != $companyId) {
  557.             return new JsonResponse(['success' => false, 'message' => 'Not found.']);
  558.         }
  560.         // The bank amount is signed (negative for outgoing) but voucher leg amounts
  561.         // are stored positive — match on the ABSOLUTE value.
  562.         $amount = abs((float) $txn->getAmount());
  563.         $tol    = max(0.5, $amount * 0.01);                 // 1% or 50c, whichever larger
  564.         $date   = $txn->getPostedAt() ?: new \DateTime();
  565.         $from   = (clone $date)->modify('-31 days');        // bank value-date vs posting-date drift
  566.         $to     = (clone $date)->modify('+31 days');
  568.         // Match against a transaction LINE (the leg that hit the bank), not the header
  569.         // sum — a multi-leg voucher's header total rarely equals a single bank line.
  570.         $rows = $conn->fetchAllAssociative(
  571.             "SELECT t.transaction_id AS id, t.document_hash AS hash,
  572.                     t.transaction_amount AS amount, t.transaction_date AS date,
  573.                     MIN(ABS(d.amount - ?)) AS leg_diff
  574.                FROM acc_transactions t
  575.                JOIN acc_transaction_details d ON d.transaction_id = t.transaction_id
  576.               WHERE ABS(d.amount - ?) <= ?
  577.                 AND t.transaction_date BETWEEN ? AND ?
  578.                 AND (t.delete_flag = 0 OR t.delete_flag IS NULL)
  579.                 AND t.transaction_id NOT IN (
  580.                       SELECT acc_transactions_id FROM aspire_transaction WHERE acc_transactions_id IS NOT NULL
  581.                 )
  582.               GROUP BY t.transaction_id, t.document_hash, t.transaction_amount, t.transaction_date
  583.               ORDER BY leg_diff ASC, ABS(DATEDIFF(t.transaction_date, ?)) ASC, t.transaction_id DESC
  584.               LIMIT 20",
  585.             [$amount, $amount, $tol, $from->format('Y-m-d 00:00:00'), $to->format('Y-m-d 23:59:59'), $date->format('Y-m-d')]
  586.         );
  588.         return new JsonResponse(['success' => true, 'txn_amount' => $amount, 'candidates' => $rows]);
  589.     }
  591.     /**
  592.      * Link this bank transaction to an EXISTING voucher instead of posting a new one
  593.      * (dedupe). No GL entry is created — we just mark the bank txn matched & linked, so
  594.      * the reconciliation overlay ties them together. POST /aspire/transaction/match/{id}
  595.      */
  596.     public function transactionMatchAction(Request $request, int $id): JsonResponse
  597.     {
  598.         $em        = $this->getDoctrine()->getManager();
  599.         $companyId = $request->getSession()->get(UserConstants::USER_COMPANY_ID);
  600.         $conn      = $em->getConnection();
  602.         $txn = $em->getRepository('ApplicationBundle\\Entity\\AspireTransaction')->find($id);
  603.         if (!$txn || $txn->getCompanyId() != $companyId) {
  604.             return new JsonResponse(['success' => false, 'message' => 'Not found.']);
  605.         }
  606.         if (in_array($txn->getStatus(), ['posted', 'auto_posted', 'matched'])) {
  607.             return new JsonResponse(['success' => false, 'message' => 'Already posted or matched.']);
  608.         }
  610.         $voucherId = (int) $request->request->get('transaction_id');
  611.         if (!$voucherId) {
  612.             return new JsonResponse(['success' => false, 'message' => 'Select a voucher to match.']);
  613.         }
  614.         $exists = $conn->fetchOne('SELECT transaction_id FROM acc_transactions WHERE transaction_id = ?', [$voucherId]);
  615.         if (!$exists) {
  616.             return new JsonResponse(['success' => false, 'message' => 'Voucher not found.']);
  617.         }
  618.         // Guard: that voucher must not already be linked to another bank txn.
  619.         $taken = $conn->fetchOne('SELECT id FROM aspire_transaction WHERE acc_transactions_id = ? AND id <> ?', [$voucherId, $id]);
  620.         if ($taken) {
  621.             return new JsonResponse(['success' => false, 'message' => 'That voucher is already matched to another transaction.']);
  622.         }
  624.         $txn->setAccTransactionsId($voucherId);
  625.         $txn->setStatus('matched');
  626.         $txn->setPostedAtErp(new \DateTime());
  627.         $txn->setNotes(trim((string) $txn->getNotes() . ' [matched to existing voucher #' . $voucherId . ']'));
  628.         $em->flush();
  630.         // The bank feed now confirms this existing voucher — mark it reconciled.
  631.         \ApplicationBundle\Modules\Aspire\Aspire::markReconciledFromFeed($em, $voucherId, $txn, (int) $request->getSession()->get(UserConstants::USER_LOGIN_ID));
  633.         return new JsonResponse(['success' => true, 'message' => 'Linked to voucher #' . $voucherId . ' — no new entry posted.']);
  634.     }
  636.     /**
  637.      * Counterpart candidates for a wallet-to-wallet FX conversion — other un-posted
  638.      * Aspire txns in the OPPOSITE direction (the other leg of the exchange).
  639.      * GET /aspire/transaction/conversion-candidates/{id}
  640.      */
  641.     public function transactionConversionCandidatesAction(Request $request, int $id): JsonResponse
  642.     {
  643.         $em        = $this->getDoctrine()->getManager();
  644.         $companyId = $request->getSession()->get(UserConstants::USER_COMPANY_ID);
  646.         $txn = $em->getRepository('ApplicationBundle\\Entity\\AspireTransaction')->find($id);
  647.         if (!$txn || $txn->getCompanyId() != $companyId) {
  648.             return new JsonResponse(['success' => false, 'message' => 'Not found.']);
  649.         }
  650.         $oppositeDir = ($txn->getDirection() === 'debit') ? 'credit' : 'debit';
  652.         // Counterpart legs within ±7 days of this txn (a conversion's two legs settle close
  653.         // together) — much shorter than listing every un-posted transaction.
  654.         $anchorDate = ($txn->getPostedAt() ?: new \DateTime())->format('Y-m-d');
  655.         $rows = $em->getConnection()->fetchAllAssociative(
  656.             "SELECT id, aspire_txn_id, amount, currency_code, direction, description, posted_at
  657.                FROM aspire_transaction
  658.               WHERE company_id = ? AND id <> ? AND status = 'new' AND direction = ?
  659.                 AND posted_at IS NOT NULL
  660.                 AND ABS(DATEDIFF(posted_at, ?)) <= 7
  661.               ORDER BY ABS(DATEDIFF(posted_at, ?)) ASC, id DESC
  662.               LIMIT 25",
  663.             [$companyId, $id, $oppositeDir, $anchorDate, $anchorDate]
  664.         );
  665.         return new JsonResponse(['success' => true, 'candidates' => $rows]);
  666.     }
  668.     /**
  669.      * Post a wallet-to-wallet FX conversion: pair THIS txn with a counterpart leg,
  670.      * post one balanced conversion journal (both wallets + realized FX) via
  671.      * FxConversionService, and mark BOTH Aspire txns posted & cross-linked.
  672.      * POST /aspire/transaction/post-conversion/{id} { counterpart_id, applied_rate }
  673.      */
  674.     public function transactionPostConversionAction(Request $request, int $id): JsonResponse
  675.     {
  676.         $this->boot();
  677.         $em        = $this->getDoctrine()->getManager();
  678.         $companyId = $request->getSession()->get(UserConstants::USER_COMPANY_ID);
  679.         $loginId   = $request->getSession()->get(UserConstants::USER_LOGIN_ID);
  681.         $repo = $em->getRepository('ApplicationBundle\\Entity\\AspireTransaction');
  682.         $txn  = $repo->find($id);
  683.         $cpId = (int) $request->request->get('counterpart_id');
  684.         $cp   = $cpId ? $repo->find($cpId) : null;
  686.         if (!$txn || $txn->getCompanyId() != $companyId) { return new JsonResponse(['success' => false, 'message' => 'Transaction not found.']); }
  687.         if (!$cp   || $cp->getCompanyId()  != $companyId) { return new JsonResponse(['success' => false, 'message' => 'Select the counterpart transaction.']); }
  688.         if ($cp->getId() == $txn->getId())                { return new JsonResponse(['success' => false, 'message' => 'Counterpart must be a different transaction.']); }
  689.         foreach ([$txn, $cp] as $t) {
  690.             if (in_array($t->getStatus(), ['posted', 'auto_posted', 'matched'])) {
  691.                 return new JsonResponse(['success' => false, 'message' => 'One of the legs is already posted/matched.']);
  692.             }
  693.         }
  695.         // Source = outgoing (debit) leg; destination = incoming (credit) leg.
  696.         $debit  = ($txn->getDirection() === 'debit') ? $txn : $cp;
  697.         $credit = ($txn->getDirection() === 'debit') ? $cp  : $txn;
  698.         if ($debit->getDirection() !== 'debit' || $credit->getDirection() !== 'credit') {
  699.             return new JsonResponse(['success' => false, 'message' => 'A conversion needs one outgoing and one incoming leg.']);
  700.         }
  702.         $srcBank = \ApplicationBundle\Modules\Aspire\Aspire::resolveTxnBankAccount($em, $debit);
  703.         $dstBank = \ApplicationBundle\Modules\Aspire\Aspire::resolveTxnBankAccount($em, $credit);
  704.         if (!$srcBank || !$dstBank) {
  705.             return new JsonResponse(['success' => false, 'message' => 'Could not resolve the wallet for one of the legs — map the Aspire account to a bank account under Aspire → Accounts (or set a default).']);
  706.         }
  708.         $srcAmount   = abs((float) $debit->getAmount());
  709.         $dstAmount   = abs((float) $credit->getAmount());
  710.         $appliedRate = (float) $request->request->get('applied_rate', 0);
  711.         if ($appliedRate <= 0 && $srcAmount > 0) { $appliedRate = $dstAmount / $srcAmount; }   // derive src→dst
  712.         // Optional manual rate of 1 source-currency unit to the book/functional currency.
  713.         // Blank → the service auto-resolves (exact-date → nearest → cross-derive from the legs).
  714.         $bookRate = trim((string) $request->request->get('book_rate', ''));
  716.         try {
  717.             $res = \ApplicationBundle\Modules\Accounts\Service\FxConversionService::post(
  718.                 $em, (int) $companyId, (int) $loginId,
  719.                 $srcBank, $dstBank,
  720.                 $srcAmount, strtoupper((string) $debit->getCurrencyCode()),
  721.                 $dstAmount, strtoupper((string) $credit->getCurrencyCode()),
  722.                 $appliedRate, null, '0', null,
  723.                 $debit->getAspireTxnId(),
  724.                 ($debit->getPostedAt() ?: new \DateTime()),
  725.                 'aspire', $debit->getAspireTxnId(),
  726.                 'FX conversion ' . $debit->getCurrencyCode() . '→' . $credit->getCurrencyCode(),
  727.                 $bookRate !== '' ? $bookRate : null
  728.             );
  729.         } catch (\Throwable $e) {
  730.             return new JsonResponse(['success' => false, 'message' => 'Conversion post failed: ' . $e->getMessage()]);
  731.         }
  733.         $txnId = (int) ($res['transactionId'] ?? 0);
  734.         foreach ([$debit, $credit] as $t) {
  735.             $other = ($t === $debit) ? $credit : $debit;
  736.             $t->setStatus('posted');
  737.             $t->setAccTransactionsId($txnId);
  738.             $t->setPostedAtErp(new \DateTime());
  739.             $t->setPostedLoginId($loginId ?: null);
  740.             $t->setNotes(trim((string) $t->getNotes() . ' [FX conversion, paired #' . $other->getId() . ', GL #' . $txnId . ']'));
  741.         }
  742.         $em->flush();
  744.         // Both legs came off the bank feed — mark the posted conversion voucher reconciled.
  745.         \ApplicationBundle\Modules\Aspire\Aspire::markReconciledFromFeed($em, $txnId, $debit, (int) $loginId);
  747.         return new JsonResponse(['success' => true, 'message' => 'Conversion posted (GL #' . $txnId . '); both legs linked.']);
  748.     }
  750.     /**
  751.      * Suggest an FX rate for the rate fields: internal /tax/fx-rates first, then the
  752.      * external provider as a fallback. GET /aspire/fx-rate-lookup?from=USD&to=SGD&date=YYYY-MM-DD
  753.      */
  754.     public function fxRateLookupAction(Request $request): JsonResponse
  755.     {
  756.         $em   = $this->getDoctrine()->getManager();
  757.         $from = strtoupper(trim((string) $request->query->get('from', '')));
  758.         $to   = strtoupper(trim((string) $request->query->get('to', '')));
  759.         $dStr = (string) $request->query->get('date', '');
  760.         if ($from === '' || $to === '') { return new JsonResponse(['success' => false]); }
  761.         if ($from === $to)              { return new JsonResponse(['success' => true, 'rate' => 1, 'source' => 'same']); }
  763.         try { $date = $dStr ? new \DateTime($dStr) : new \DateTime(); } catch (\Throwable $e) { $date = new \DateTime(); }
  765.         // Internal rate table wins.
  766.         $fqp = '\ApplicationBundle\Modules\Accounts\Service\FxRateProvider';
  767.         try {
  768.             $r = (float) $fqp::getRate($em, $from, $to, $date, 'MID');
  769.             if ($r > 0) { return new JsonResponse(['success' => true, 'rate' => $r, 'source' => 'internal']); }
  770.         } catch (\Throwable $e) { /* none — fall through */ }
  772.         // External provider fallback — OPT-IN only (it makes an outbound call to a
  773.         // third-party rate API). Enable per tenant: acc_setting 'external_fx_rate_enabled' = '1'.
  774.         $extEnabled = $em->getConnection()->fetchOne("SELECT data FROM acc_setting WHERE name = 'external_fx_rate_enabled' LIMIT 1");
  775.         if ($extEnabled === '1') {
  776.             $r = \ApplicationBundle\Modules\Accounts\Service\ExternalFxRateService::fetchRate($from, $to, $date);
  777.             if ($r) { return new JsonResponse(['success' => true, 'rate' => $r, 'source' => 'external']); }
  778.         }
  780.         return new JsonResponse(['success' => false, 'message' => 'No internal rate — enter manually.']);
  781.     }
  783.     public function transactionBulkPostAction(Request $request): JsonResponse
  784.     {
  785.         $this->boot();
  786.         $em        = $this->getDoctrine()->getManager();
  787.         $session   = $request->getSession();
  788.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  789.         $loginId   = $session->get(UserConstants::USER_LOGIN_ID);
  791.         $ids        = $request->request->get('ids', []);
  792.         $debitHead  = (int)$request->request->get('debit_account_head_id');
  793.         $creditHead = (int)$request->request->get('credit_account_head_id');
  795.         if (!$debitHead || !$creditHead || empty($ids)) {
  796.             return new JsonResponse(['success' => false, 'message' => 'Missing parameters.']);
  797.         }
  799.         $rule = new AspirePostRule();
  800.         $rule->setDebitAccountHeadId($debitHead);
  801.         $rule->setCreditAccountHeadId($creditHead);
  802.         $rule->setAutoPost(true);
  803.         $rule->setEnabled(true);
  805.         $posted = $failed = 0;
  806.         foreach ((array)$ids as $txnId) {
  807.             $txn = $em->getRepository('ApplicationBundle\\Entity\\AspireTransaction')->find((int)$txnId);
  808.             if (!$txn || $txn->getCompanyId() != $companyId) {
  809.                 continue;
  810.             }
  811.             if (in_array($txn->getStatus(), ['posted', 'auto_posted'])) {
  812.                 continue;
  813.             }
  814.             $ok = Aspire::postTransactionToGL($txn, $rule, $em, $loginId);
  815.             $ok ? $posted++ : $failed++;
  816.         }
  817.         $em->flush();
  818.         return new JsonResponse(['success' => true, 'posted' => $posted, 'failed' => $failed]);
  819.     }
  821.     // =========================================================================
  822.     // AUTO-POST RULES
  823.     // =========================================================================
  825.     public function ruleListAction(Request $request): Response
  826.     {
  827.         $em        = $this->getDoctrine()->getManager();
  828.         $session   = $request->getSession();
  829.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  831.         $rules = $em->getRepository('ApplicationBundle\\Entity\\AspirePostRule')
  832.             ->createQueryBuilder('r')
  833.             ->where('r.companyId = :cid AND (r.docBookedFlag != 1 OR r.docBookedFlag IS NULL)')
  834.             ->setParameter('cid', $companyId)
  835.             ->orderBy('r.priority', 'ASC')
  836.             ->getQuery()->getResult();
  838.         return $this->render('@Aspire/pages/list/list_aspire_post_rules.html.twig', [
  839.             'rules'      => $rules,
  840.             'page_title' => 'Aspire Connect — Auto-Post Rules',
  841.         ]);
  842.     }
  844.     public function ruleFormAction(Request $request, int $id = 0): Response
  845.     {
  846.         $em        = $this->getDoctrine()->getManager();
  847.         $session   = $request->getSession();
  848.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  850.         $rule = $id ? $em->getRepository('ApplicationBundle\\Entity\\AspirePostRule')->find($id) : null;
  851.         if ($rule && $rule->getCompanyId() != $companyId) {
  852.             return $this->redirectToRoute('aspire_rule_list');
  853.         }
  855.         $connections = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')
  856.             ->findBy(['companyId' => $companyId, 'status' => 'active']);
  858.         return $this->render('@Aspire/pages/input_forms/aspire_post_rule.html.twig', [
  859.             'rule'        => $rule,
  860.             'connections' => $connections,
  861.             'page_title'  => $rule ? 'Edit Auto-Post Rule' : 'New Auto-Post Rule',
  862.         ]);
  863.     }
  865.     public function ruleSaveAction(Request $request): JsonResponse
  866.     {
  867.         $em        = $this->getDoctrine()->getManager();
  868.         $session   = $request->getSession();
  869.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  870.         $loginId   = $session->get(UserConstants::USER_LOGIN_ID);
  872.         $id = (int)$request->request->get('id', 0);
  873.         if ($id) {
  874.             $rule = $em->getRepository('ApplicationBundle\\Entity\\AspirePostRule')->find($id);
  875.             if (!$rule || $rule->getCompanyId() != $companyId) {
  876.                 return new JsonResponse(['success' => false]);
  877.             }
  878.             $rule->setEditLoginId($loginId);
  879.         } else {
  880.             $rule = new AspirePostRule();
  881.             $rule->setCompanyId($companyId);
  882.             $rule->setCreateLoginId($loginId);
  883.         }
  885.         $rule->setName($request->request->get('name', ''));
  886.         $rule->setPriority((int)$request->request->get('priority', 100));
  887.         $rule->setConnectionId((int)$request->request->get('connection_id', 0) ?: null);
  888.         $rule->setMatchType($request->request->get('match_type', 'description_contains'));
  889.         $rule->setMatchValue($request->request->get('match_value', '') ?: null);
  890.         $rule->setMinAmount($request->request->get('min_amount', '') !== '' ? (float)$request->request->get('min_amount') : null);
  891.         $rule->setMaxAmount($request->request->get('max_amount', '') !== '' ? (float)$request->request->get('max_amount') : null);
  892.         $rule->setDirectionFilter($request->request->get('direction_filter', 'both'));
  893.         $rule->setCurrencyCode(strtoupper(trim($request->request->get('currency_code', ''))) ?: null);
  894.         $rule->setDebitAccountHeadId((int)$request->request->get('debit_account_head_id') ?: null);
  895.         $rule->setCreditAccountHeadId((int)$request->request->get('credit_account_head_id') ?: null);
  896.         $rule->setTaxRate($request->request->get('tax_rate', '') !== '' ? (float)$request->request->get('tax_rate') : null);
  897.         $rule->setAutoPost((bool)(int)$request->request->get('auto_post', 1));
  898.         $rule->setEnabled((bool)(int)$request->request->get('enabled', 1));
  900.         $em->persist($rule);
  901.         $em->flush();
  902.         return new JsonResponse(['success' => true, 'id' => $rule->getId()]);
  903.     }
  905.     public function ruleDeleteAction(Request $request, int $id): JsonResponse
  906.     {
  907.         $em        = $this->getDoctrine()->getManager();
  908.         $session   = $request->getSession();
  909.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  911.         $rule = $em->getRepository('ApplicationBundle\\Entity\\AspirePostRule')->find($id);
  912.         if (!$rule || $rule->getCompanyId() != $companyId) {
  913.             return new JsonResponse(['success' => false]);
  914.         }
  915.         $rule->setDocBookedFlag(1);
  916.         $em->flush();
  917.         return new JsonResponse(['success' => true]);
  918.     }
  920.     public function ruleTestAction(Request $request): JsonResponse
  921.     {
  922.         $em        = $this->getDoctrine()->getManager();
  923.         $session   = $request->getSession();
  924.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  926.         $ruleId = (int)$request->request->get('rule_id');
  927.         $rule   = $em->getRepository('ApplicationBundle\\Entity\\AspirePostRule')->find($ruleId);
  928.         if (!$rule || $rule->getCompanyId() != $companyId) {
  929.             return new JsonResponse(['success' => false]);
  930.         }
  932.         $stagingRows = $em->getRepository('ApplicationBundle\\Entity\\AspireTransaction')
  933.             ->createQueryBuilder('t')
  934.             ->where('t.companyId = :cid AND t.status = :st')
  935.             ->setParameter('cid', $companyId)
  936.             ->setParameter('st', 'new')
  937.             ->setMaxResults(200)
  938.             ->getQuery()->getResult();
  940.         $matches = [];
  941.         foreach ($stagingRows as $txn) {
  942.             if (Aspire::evaluateRules($txn, [$rule])) {
  943.                 $matches[] = [
  944.                     'id'          => $txn->getId(),
  945.                     'aspire_txn'  => $txn->getAspireTxnId(),
  946.                     'date'        => $txn->getPostedAt() ? $txn->getPostedAt()->format('Y-m-d') : '',
  947.                     'amount'      => $txn->getAmount(),
  948.                     'direction'   => $txn->getDirection(),
  949.                     'description' => $txn->getDescription(),
  950.                     'counterparty'=> $txn->getCounterparty(),
  951.                 ];
  952.             }
  953.         }
  955.         return new JsonResponse(['success' => true, 'matches' => $matches]);
  956.     }
  958.     public function suggestHeadsAction(Request $request, int $id): JsonResponse
  959.     {
  960.         $this->boot();
  961.         $em        = $this->getDoctrine()->getManager();
  962.         $session   = $request->getSession();
  963.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  965.         $txn = $em->getRepository('ApplicationBundle\\Entity\\AspireTransaction')->find($id);
  966.         if (!$txn || $txn->getCompanyId() != $companyId) {
  967.             return new JsonResponse(['success' => false]);
  968.         }
  970.         $suggestion = Aspire::suggestHeads($txn, $em);
  971.         return new JsonResponse(['success' => true, 'suggestion' => $suggestion]);
  972.     }
  975.     // =========================================================================
  976.     // PAYOUTS
  977.     // =========================================================================
  979.     public function payoutListAction(Request $request): Response
  980.     {
  981.         $em        = $this->getDoctrine()->getManager();
  982.         $session   = $request->getSession();
  983.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  985.         $payouts = $em->getRepository('ApplicationBundle\\Entity\\AspirePayout')
  986.             ->createQueryBuilder('p')
  987.             ->where('p.companyId = :cid AND (p.docBookedFlag != 1 OR p.docBookedFlag IS NULL)')
  988.             ->setParameter('cid', $companyId)
  989.             ->orderBy('p.id', 'DESC')
  990.             ->setMaxResults(300)
  991.             ->getQuery()->getResult();
  993.         $connections = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')
  994.             ->findBy(['companyId' => $companyId, 'status' => 'active']);
  996.         return $this->render('@Aspire/pages/list/list_aspire_payouts.html.twig', [
  997.             'payouts'     => $payouts,
  998.             'connections' => $connections,
  999.             'page_title'  => 'Aspire Connect — Payouts',
  1000.         ]);
  1001.     }
  1003.     public function payoutFormAction(Request $request, int $id = 0): Response
  1004.     {
  1005.         $this->boot();
  1006.         $em        = $this->getDoctrine()->getManager();
  1007.         $session   = $request->getSession();
  1008.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  1010.         $payout = $id ? $em->getRepository('ApplicationBundle\\Entity\\AspirePayout')->find($id) : null;
  1011.         if ($payout && $payout->getCompanyId() != $companyId) {
  1012.             return $this->redirectToRoute('aspire_payout_list');
  1013.         }
  1015.         $connections = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')
  1016.             ->findBy(['companyId' => $companyId, 'status' => 'active']);
  1018.         $aspireAccounts = $em->getRepository('ApplicationBundle\\Entity\\AspireAccount')
  1019.             ->findBy(['companyId' => $companyId]);
  1021.         $items = $payout ? $em->getRepository('ApplicationBundle\\Entity\\AspirePayoutItem')
  1022.             ->findBy(['payoutId' => $payout->getId()]) : [];
  1024.         return $this->render('@Aspire/pages/input_forms/aspire_payout.html.twig', [
  1025.             'payout'         => $payout,
  1026.             'connections'    => $connections,
  1027.             'aspireAccounts' => $aspireAccounts,
  1028.             'items'          => $items,
  1029.             'page_title'     => $payout ? 'Edit Payout Draft' : 'New Payout',
  1030.         ]);
  1031.     }
  1033.     public function payoutViewAction(Request $request, int $id): Response
  1034.     {
  1035.         $em        = $this->getDoctrine()->getManager();
  1036.         $session   = $request->getSession();
  1037.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  1039.         $payout = $em->getRepository('ApplicationBundle\\Entity\\AspirePayout')->find($id);
  1040.         if (!$payout || $payout->getCompanyId() != $companyId) {
  1041.             return $this->redirectToRoute('aspire_payout_list');
  1042.         }
  1044.         $items = $em->getRepository('ApplicationBundle\\Entity\\AspirePayoutItem')
  1045.             ->findBy(['payoutId' => $id]);
  1047.         return $this->render('@Aspire/pages/view/view_aspire_payout.html.twig', [
  1048.             'payout'     => $payout,
  1049.             'items'      => $items,
  1050.             'page_title' => 'Payout #' . $payout->getId(),
  1051.         ]);
  1052.     }
  1054.     public function payoutSaveDraftAction(Request $request): JsonResponse
  1055.     {
  1056.         $this->boot();
  1057.         $em        = $this->getDoctrine()->getManager();
  1058.         $session   = $request->getSession();
  1059.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  1060.         $loginId   = $session->get(UserConstants::USER_LOGIN_ID);
  1062.         $id         = (int)$request->request->get('id', 0);
  1063.         $type       = $request->request->get('payout_type', 'single');
  1064.         $connId     = (int)$request->request->get('connection_id');
  1065.         $sourceAcct = $request->request->get('source_aspire_account_id', '');
  1066.         $srcCur     = $request->request->get('source_currency', 'SGD');
  1067.         $dstCur     = $request->request->get('destination_currency', 'SGD');
  1068.         $method     = $request->request->get('payment_method', 'LOCAL');
  1069.         $clearing   = $request->request->get('clearing_system', 'FAST');
  1070.         $reference  = $request->request->get('reference', '');
  1072.         $conn = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')->find($connId);
  1073.         if (!$conn || $conn->getCompanyId() != $companyId) {
  1074.             return new JsonResponse(['success' => false, 'message' => 'Connection not found.']);
  1075.         }
  1077.         if ($id) {
  1078.             $payout = $em->getRepository('ApplicationBundle\\Entity\\AspirePayout')->find($id);
  1079.             if (!$payout || $payout->getCompanyId() != $companyId) {
  1080.                 return new JsonResponse(['success' => false]);
  1081.             }
  1082.             if (!in_array($payout->getStatus(), ['draft'])) {
  1083.                 return new JsonResponse(['success' => false, 'message' => 'Cannot edit a payout that is already submitted.']);
  1084.             }
  1085.             $payout->setEditLoginId($loginId);
  1086.             // Remove old items
  1087.             $oldItems = $em->getRepository('ApplicationBundle\\Entity\\AspirePayoutItem')
  1088.                 ->findBy(['payoutId' => $id]);
  1089.             foreach ($oldItems as $oi) {
  1090.                 $em->remove($oi);
  1091.             }
  1092.         } else {
  1093.             $payout = new AspirePayout();
  1094.             $payout->setCompanyId($companyId);
  1095.             $payout->setConnectionId($connId);
  1096.             $payout->setStatus('draft');
  1097.             $payout->setCreateLoginId($loginId);
  1098.         }
  1100.         $payout->setPayoutType($type);
  1101.         $payout->setSourceAspireAccountId($sourceAcct);
  1102.         $payout->setSourceCurrency($srcCur);
  1103.         $payout->setDestinationCurrency($dstCur);
  1104.         $payout->setPaymentMethod($method);
  1105.         $payout->setClearingSystem($clearing);
  1106.         $payout->setReference($reference);
  1107.         $em->persist($payout);
  1108.         $em->flush();
  1110.         // Save line items
  1111.         $itemsData = $request->request->get('items', []);
  1112.         $total = 0;
  1113.         foreach ((array)$itemsData as $itemRow) {
  1114.             $item = new AspirePayoutItem();
  1115.             $item->setPayoutId($payout->getId());
  1116.             $item->setBankCountryCode($itemRow['bank_country_code'] ?? 'SG');
  1117.             $item->setBankCode($itemRow['bank_code'] ?? null);
  1118.             $item->setBankAccountNumber($itemRow['bank_account_number'] ?? null);
  1119.             $item->setAccountHolderName($itemRow['account_holder_name'] ?? null);
  1120.             $item->setEntityType($itemRow['entity_type'] ?? 'INDIVIDUAL');
  1121.             $item->setAmount(isset($itemRow['amount']) ? (float)$itemRow['amount'] : null);
  1122.             $item->setReference($itemRow['reference'] ?? null);
  1123.             $item->setBeneficiaryEmployeeId(!empty($itemRow['employee_id']) ? (int)$itemRow['employee_id'] : null);
  1124.             $item->setBeneficiarySupplierId(!empty($itemRow['supplier_id']) ? (int)$itemRow['supplier_id'] : null);
  1125.             $item->setItemStatus('pending');
  1126.             $em->persist($item);
  1127.             $total += (float)($itemRow['amount'] ?? 0);
  1128.         }
  1130.         $payout->setTotalAmount($total);
  1131.         $em->flush();
  1133.         return new JsonResponse(['success' => true, 'id' => $payout->getId()]);
  1134.     }
  1136.     public function payoutRequestOtpAction(Request $request, int $id): JsonResponse
  1137.     {
  1138.         $this->boot();
  1139.         $em        = $this->getDoctrine()->getManager();
  1140.         $session   = $request->getSession();
  1141.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  1143.         $payout = $em->getRepository('ApplicationBundle\\Entity\\AspirePayout')->find($id);
  1144.         if (!$payout || $payout->getCompanyId() != $companyId) {
  1145.             return new JsonResponse(['success' => false, 'message' => 'Not found.']);
  1146.         }
  1147.         if ($payout->getStatus() !== 'draft') {
  1148.             return new JsonResponse(['success' => false, 'message' => 'Payout is not in draft state.']);
  1149.         }
  1151.         $conn  = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')->find($payout->getConnectionId());
  1152.         $items = $em->getRepository('ApplicationBundle\\Entity\\AspirePayoutItem')->findBy(['payoutId' => $id]);
  1154.         if ($payout->getPayoutType() === 'single') {
  1155.             $item = $items[0] ?? null;
  1156.             if (!$item) {
  1157.                 return new JsonResponse(['success' => false, 'message' => 'No beneficiary found.']);
  1158.             }
  1159.             $payload = [
  1160.                 'source_currency'      => $payout->getSourceCurrency(),
  1161.                 'source_account_id'    => $payout->getSourceAspireAccountId(),
  1162.                 'destination_currency' => $payout->getDestinationCurrency(),
  1163.                 'bank_country_code'    => $item->getBankCountryCode(),
  1164.                 'payment_method'       => $payout->getPaymentMethod(),
  1165.                 'clearing_system'      => $payout->getClearingSystem(),
  1166.                 'entity_type'          => $item->getEntityType(),
  1167.                 'bank_code'            => $item->getBankCode(),
  1168.                 'bank_account_number'  => $item->getBankAccountNumber(),
  1169.                 'account_holder_name'  => $item->getAccountHolderName(),
  1170.                 'amount'               => (float)$item->getAmount(),
  1171.                 'reference'            => $item->getReference() ?: $payout->getReference(),
  1172.             ];
  1173.             $resp = Aspire::createSingleTransfer($conn, $payload, $em);
  1174.         } else {
  1175.             $beneficiaries = [];
  1176.             foreach ($items as $item) {
  1177.                 $beneficiaries[] = [
  1178.                     'bank_code'            => $item->getBankCode(),
  1179.                     'bank_account_number'  => $item->getBankAccountNumber(),
  1180.                     'account_holder_name'  => $item->getAccountHolderName(),
  1181.                     'entity_type'          => $item->getEntityType(),
  1182.                     'bank_country_code'    => $item->getBankCountryCode(),
  1183.                     'amount'               => (float)$item->getAmount(),
  1184.                     'reference'            => $item->getReference() ?: $payout->getReference(),
  1185.                 ];
  1186.             }
  1187.             $payload = [
  1188.                 'source_account_id'    => $payout->getSourceAspireAccountId(),
  1189.                 'source_currency'      => $payout->getSourceCurrency(),
  1190.                 'destination_currency' => $payout->getDestinationCurrency(),
  1191.                 'bank_country_code'    => $items[0]->getBankCountryCode() ?? 'SG',
  1192.                 'payment_method'       => $payout->getPaymentMethod(),
  1193.                 'clearing_system'      => $payout->getClearingSystem(),
  1194.                 'beneficiaries'        => $beneficiaries,
  1195.                 'total_transfer_amount'=> (float)$payout->getTotalAmount(),
  1196.                 'reference'            => $payout->getReference(),
  1197.             ];
  1198.             $resp = Aspire::createBulkTransfer($conn, $payload, $em);
  1199.         }
  1201.         $payout->setRawRequest(json_encode($payload));
  1202.         $payout->setRawResponse(json_encode($resp));
  1204.         if (!empty($resp['error']) || ($resp['http_code'] ?? 200) >= 400) {
  1205.             $payout->setStatus('error');
  1206.             $payout->setErrorMessage(json_encode($resp));
  1207.             $em->flush();
  1208.             return new JsonResponse(['success' => false, 'message' => 'Aspire API error.', 'detail' => $resp]);
  1209.         }
  1211.         $transferId = $resp['transfer_id'] ?? ($resp['bulk_transfer_id'] ?? ($resp['id'] ?? null));
  1212.         if ($transferId) {
  1213.             $payout->setAspireTransferId($transferId);
  1214.         }
  1215.         $payout->setStatus('pending_otp');
  1216.         $em->flush();
  1218.         return new JsonResponse(['success' => true, 'message' => 'OTP sent to your registered mobile number. Enter it below to confirm.', 'transfer_id' => $transferId]);
  1219.     }
  1221.     public function payoutSubmitAction(Request $request, int $id): JsonResponse
  1222.     {
  1223.         $this->boot();
  1224.         $em        = $this->getDoctrine()->getManager();
  1225.         $session   = $request->getSession();
  1226.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  1227.         $loginId   = $session->get(UserConstants::USER_LOGIN_ID);
  1229.         $payout = $em->getRepository('ApplicationBundle\\Entity\\AspirePayout')->find($id);
  1230.         if (!$payout || $payout->getCompanyId() != $companyId) {
  1231.             return new JsonResponse(['success' => false]);
  1232.         }
  1233.         if ($payout->getStatus() !== 'pending_otp') {
  1234.             return new JsonResponse(['success' => false, 'message' => 'Payout is not awaiting OTP.']);
  1235.         }
  1237.         // OTP confirmation: Aspire's exact endpoint for OTP confirm is TBD (sandbox testing needed).
  1238.         // For now we mark as submitted — the /transfer/{id}/status poll will confirm completion.
  1239.         $payout->setStatus('submitted');
  1240.         $payout->setSubmittedLoginId($loginId);
  1241.         $payout->setSubmittedAt(new \DateTime());
  1242.         $em->flush();
  1244.         return new JsonResponse(['success' => true, 'message' => 'Payout submitted. Refreshing status…']);
  1245.     }
  1247.     public function payoutRefreshStatusAction(Request $request, int $id): JsonResponse
  1248.     {
  1249.         $this->boot();
  1250.         $em        = $this->getDoctrine()->getManager();
  1251.         $session   = $request->getSession();
  1252.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  1254.         $payout = $em->getRepository('ApplicationBundle\\Entity\\AspirePayout')->find($id);
  1255.         if (!$payout || $payout->getCompanyId() != $companyId) {
  1256.             return new JsonResponse(['success' => false]);
  1257.         }
  1259.         if (!$payout->getAspireTransferId()) {
  1260.             return new JsonResponse(['success' => false, 'message' => 'No Aspire transfer ID recorded.']);
  1261.         }
  1263.         $conn = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')->find($payout->getConnectionId());
  1264.         $resp = $payout->getPayoutType() === 'bulk'
  1265.             ? Aspire::getBulkTransferStatus($conn, $payout->getAspireTransferId(), $em)
  1266.             : Aspire::getTransferStatus($conn, $payout->getAspireTransferId(), $em);
  1268.         $aspireStatus = $resp['status'] ?? ($resp['transfer_status'] ?? null);
  1269.         $payout->setRawResponse(json_encode($resp));
  1270.         $payout->setLastStatusCheckAt(new \DateTime());
  1272.         if ($aspireStatus) {
  1273.             $map = [
  1274.                 'Completed'  => 'completed',
  1275.                 'Rejected'   => 'rejected',
  1276.                 'In Progress'=> 'submitted',
  1277.             ];
  1278.             $mapped = $map[$aspireStatus] ?? null;
  1279.             if ($mapped) {
  1280.                 $payout->setStatus($mapped);
  1281.             }
  1282.         }
  1283.         $em->flush();
  1285.         return new JsonResponse(['success' => true, 'aspire_status' => $aspireStatus, 'status' => $payout->getStatus()]);
  1286.     }
  1288.     public function payoutFxQuoteAction(Request $request): JsonResponse
  1289.     {
  1290.         $this->boot();
  1291.         $em        = $this->getDoctrine()->getManager();
  1292.         $session   = $request->getSession();
  1293.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  1295.         $connId = (int)$request->request->get('connection_id');
  1296.         $conn = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')->find($connId);
  1297.         if (!$conn || $conn->getCompanyId() != $companyId) {
  1298.             return new JsonResponse(['success' => false]);
  1299.         }
  1301.         $params = [
  1302.             'source_currency'      => $request->request->get('source_currency'),
  1303.             'destination_currency' => $request->request->get('destination_currency'),
  1304.             'amount'               => (float)$request->request->get('amount'),
  1305.         ];
  1306.         $resp = Aspire::getFxQuote($conn, $params, $em);
  1307.         return new JsonResponse($resp);
  1308.     }
  1310.     // =========================================================================
  1311.     // SYNC
  1312.     // =========================================================================
  1314.     public function syncNowAction(Request $request, int $connectionId): JsonResponse
  1315.     {
  1316.         $this->boot();
  1317.         $em        = $this->getDoctrine()->getManager();
  1318.         $session   = $request->getSession();
  1319.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  1320.         $loginId   = $session->get(UserConstants::USER_LOGIN_ID);
  1322.         $conn = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')->find($connectionId);
  1323.         if (!$conn || $conn->getCompanyId() != $companyId) {
  1324.             return new JsonResponse(['success' => false, 'error' => 'Connection not found.']);
  1325.         }
  1327.         try {
  1328.             $result = Aspire::syncConnection($conn, $em, $loginId, 'manual');
  1329.         } catch (\Exception $e) {
  1330.             return new JsonResponse(['success' => false, 'error' => $e->getMessage()]);
  1331.         }
  1333.         // Attach lastSyncError detail if sync failed on token
  1334.         if (!($result['success'] ?? true) && $conn->getLastSyncError()) {
  1335.             $result['detail'] = $conn->getLastSyncError();
  1336.         }
  1338.         return new JsonResponse($result);
  1339.     }
  1341.     public function syncLogListAction(Request $request): Response
  1342.     {
  1343.         $em        = $this->getDoctrine()->getManager();
  1344.         $session   = $request->getSession();
  1345.         $companyId = $session->get(UserConstants::USER_COMPANY_ID);
  1347.         $logs = $em->getRepository('ApplicationBundle\\Entity\\AspireSyncLog')
  1348.             ->createQueryBuilder('l')
  1349.             ->where('l.companyId = :cid')
  1350.             ->setParameter('cid', $companyId)
  1351.             ->orderBy('l.startedAt', 'DESC')
  1352.             ->setMaxResults(200)
  1353.             ->getQuery()->getResult();
  1355.         return $this->render('@Aspire/pages/list/list_aspire_connections.html.twig', [
  1356.             'connections' => [],
  1357.             'syncLogs'    => $logs,
  1358.             'showLogs'    => true,
  1359.             'page_title'  => 'Aspire Connect — Sync Log',
  1360.         ]);
  1361.     }
  1362. }