fix: Trial balance sheet adjusted balance (#273)

packages/server/src/services/Accounting/Ledger.ts

@@ -1,5 +1,5 @@
 import moment from 'moment';
-import { defaultTo, uniqBy } from 'lodash';
+import { defaultTo, sumBy, uniqBy } from 'lodash';
 import { IAccountTransaction, ILedger, ILedgerEntry } from '@/interfaces';
 
 export default class Ledger implements ILedger {
@@ -49,6 +49,15 @@ export default class Ledger implements ILedger {
     return this.filter((entry) => entry.accountId === accountId);
   }
 
+  /**
+   * Filters entries by the given accounts ids then returns a new ledger.
+   * @param {number[]} accountsIds - Accounts ids.
+   * @returns {ILedger}
+   */
+  public whereAccountsIds(accountsIds: number[]): ILedger {
+    return this.filter((entry) => accountsIds.indexOf(entry.accountId) !== -1);
+  }
+
   /**
    * Filters entries that before or same the given date and returns a new ledger.
    * @param   {Date|string} fromDate
@@ -130,6 +139,22 @@ export default class Ledger implements ILedger {
     return closingBalance;
   }
 
+  /**
+   * Retrieves the closing credit of the entries.
+   * @returns {number}
+   */
+  public getClosingCredit(): number {
+    return sumBy(this.entries, 'credit');
+  }
+
+  /**
+   * Retrieves the closing debit of the entries.
+   * @returns {number}
+   */
+  public getClosingDebit(): number {
+    return sumBy(this.entries, 'debit');
+  }
+
   /**
    * Retrieve the closing balance of the entries.
    * @returns {number}

packages/server/src/services/FinancialStatements/TrialBalanceSheet/TrialBalanceSheet.ts

@@ -10,13 +10,26 @@ import {
 } from '@/interfaces';
 import FinancialSheet from '../FinancialSheet';
 import { allPassedConditionsPass, flatToNestedArray } from 'utils';
+import { TrialBalanceSheetRepository } from './TrialBalanceSheetRepository';
 
 export default class TrialBalanceSheet extends FinancialSheet {
-  tenantId: number;
-  query: ITrialBalanceSheetQuery;
-  accounts: IAccount & { type: IAccountType }[];
-  journalFinancial: any;
-  baseCurrency: string;
+  /**
+   * Trial balance sheet query.
+   * @param {ITrialBalanceSheetQuery} query
+   */
+  private query: ITrialBalanceSheetQuery;
+
+  /**
+   * Trial balance sheet repository.
+   * @param {TrialBalanceSheetRepository}
+   */
+  private repository: TrialBalanceSheetRepository;
+
+  /**
+   * Organization base currency.
+   * @param {string}
+   */
+  private baseCurrency: string;
 
   /**
    * Constructor method.
@@ -28,20 +41,58 @@ export default class TrialBalanceSheet extends FinancialSheet {
   constructor(
     tenantId: number,
     query: ITrialBalanceSheetQuery,
-    accounts: IAccount & { type: IAccountType }[],
-    journalFinancial: any,
+    repository: TrialBalanceSheetRepository,
     baseCurrency: string
   ) {
     super();
 
     this.tenantId = tenantId;
     this.query = query;
-    this.accounts = accounts;
-    this.journalFinancial = journalFinancial;
+    this.repository = repository;
     this.numberFormat = this.query.numberFormat;
     this.baseCurrency = baseCurrency;
   }
 
+  /**
+   * Retrieves the closing credit of the given account.
+   * @param {number} accountId
+   * @returns {number}
+   */
+  public getClosingAccountCredit(accountId: number) {
+    const depsAccountsIds =
+      this.repository.accountsDepGraph.dependenciesOf(accountId);
+
+    return this.repository.totalAccountsLedger
+      .whereAccountsIds([accountId, ...depsAccountsIds])
+      .getClosingCredit();
+  }
+
+  /**
+   * Retrieves the closing debit of the given account.
+   * @param {number} accountId
+   * @returns {number}
+   */
+  public getClosingAccountDebit(accountId: number) {
+    const depsAccountsIds =
+      this.repository.accountsDepGraph.dependenciesOf(accountId);
+
+    return this.repository.totalAccountsLedger
+      .whereAccountsIds([accountId, ...depsAccountsIds])
+      .getClosingDebit();
+  }
+
+  /**
+   * Retrieves the closing total of the given account.
+   * @param {number} accountId
+   * @returns {number}
+   */
+  public getClosingAccountTotal(accountId: number) {
+    const credit = this.getClosingAccountCredit(accountId);
+    const debit = this.getClosingAccountDebit(accountId);
+
+    return debit - credit;
+  }
+
   /**
    * Account mapper.
    * @param {IAccount} account
@@ -50,23 +101,28 @@ export default class TrialBalanceSheet extends FinancialSheet {
   private accountTransformer = (
     account: IAccount & { type: IAccountType }
   ): ITrialBalanceAccount => {
-    const trial = this.journalFinancial.getTrialBalanceWithDepands(account.id);
+    const debit = this.getClosingAccountDebit(account.id);
+    const credit = this.getClosingAccountCredit(account.id);
+    const balance = this.getClosingAccountTotal(account.id);
 
     return {
       id: account.id,
       parentAccountId: account.parentAccountId,
       name: account.name,
+      formattedName: account.code
+        ? `${account.name} - ${account.code}`
+        : `${account.name}`,
       code: account.code,
       accountNormal: account.accountNormal,
 
-      credit: trial.credit,
-      debit: trial.debit,
-      balance: trial.balance,
+      credit,
+      debit,
+      balance,
       currencyCode: this.baseCurrency,
 
-      formattedCredit: this.formatNumber(trial.credit),
-      formattedDebit: this.formatNumber(trial.debit),
-      formattedBalance: this.formatNumber(trial.balance),
+      formattedCredit: this.formatNumber(credit),
+      formattedDebit: this.formatNumber(debit),
+      formattedBalance: this.formatNumber(balance),
     };
   };
 
@@ -117,10 +173,7 @@ export default class TrialBalanceSheet extends FinancialSheet {
   private filterNoneTransactions = (
     accountNode: ITrialBalanceAccount
   ): boolean => {
-    const entries = this.journalFinancial.getAccountEntriesWithDepents(
-      accountNode.id
-    );
-    return entries.length > 0;
+    return false === this.repository.totalAccountsLedger.isEmpty();
   };
 
   /**
@@ -200,11 +253,11 @@ export default class TrialBalanceSheet extends FinancialSheet {
    */
   public reportData(): ITrialBalanceSheetData {
     // Don't return noting if the journal has no transactions.
-    if (this.journalFinancial.isEmpty()) {
+    if (this.repository.totalAccountsLedger.isEmpty()) {
       return null;
     }
     // Retrieve accounts nodes.
-    const accounts = this.accountsSection(this.accounts);
+    const accounts = this.accountsSection(this.repository.accounts);
 
     // Retrieve account node.
     const total = this.tatalSection(accounts);

packages/server/src/services/FinancialStatements/TrialBalanceSheet/TrialBalanceSheetRepository.ts

@@ -0,0 +1,105 @@
+import { ITrialBalanceSheetQuery } from '@/interfaces';
+import Ledger from '@/services/Accounting/Ledger';
+import { Knex } from 'knex';
+import { isEmpty } from 'lodash';
+import { Service } from 'typedi';
+
+@Service()
+export class TrialBalanceSheetRepository {
+  private query: ITrialBalanceSheetQuery;
+  private models: any;
+  public accounts: any;
+  public accountsDepGraph;
+
+  /**
+   * Total closing accounts ledger.
+   * @param {Ledger}
+   */
+  public totalAccountsLedger: Ledger;
+
+  /**
+   * Constructor method.
+   * @param {number} tenantId
+   * @param {IBalanceSheetQuery} query
+   */
+  constructor(models: any, repos: any, query: ITrialBalanceSheetQuery) {
+    this.query = query;
+    this.repos = repos;
+    this.models = models;
+  }
+
+  /**
+   * Async initialize.
+   * @returns {Promise<void>}
+   */
+  public asyncInitialize = async () => {
+    await this.initAccounts();
+    await this.initAccountsClosingTotalLedger();
+  };
+
+  // ----------------------------
+  // # Accounts
+  // ----------------------------
+  /**
+   * Initialize accounts.
+   * @returns {Promise<void>}
+   */
+  public initAccounts = async () => {
+    const accounts = await this.getAccounts();
+    const accountsDepGraph =
+      await this.repos.accountRepository.getDependencyGraph();
+
+    this.accountsDepGraph = accountsDepGraph;
+    this.accounts = accounts;
+  };
+
+  /**
+   * Initialize all accounts closing total ledger.
+   * @return {Promise<void>}
+   */
+  public initAccountsClosingTotalLedger = async (): Promise<void> => {
+    const totalByAccounts = await this.closingAccountsTotal(this.query.toDate);
+
+    this.totalAccountsLedger = Ledger.fromTransactions(totalByAccounts);
+  };
+
+  /**
+   * Retrieve accounts of the report.
+   * @return {Promise<IAccount[]>}
+   */
+  private getAccounts = () => {
+    const { Account } = this.models;
+
+    return Account.query();
+  };
+
+  /**
+   * Retrieve the opening balance transactions of the report.
+   * @param {Date|string} openingDate -
+   */
+  public closingAccountsTotal = async (openingDate: Date | string) => {
+    const { AccountTransaction } = this.models;
+
+    return AccountTransaction.query().onBuild((query) => {
+      query.sum('credit as credit');
+      query.sum('debit as debit');
+      query.groupBy('accountId');
+      query.select(['accountId']);
+
+      query.modify('filterDateRange', null, openingDate);
+      query.withGraphFetched('account');
+
+      this.commonFilterBranchesQuery(query);
+    });
+  };
+
+  /**
+   * Common branches filter query.
+   * @param {Knex.QueryBuilder} query
+   */
+  private commonFilterBranchesQuery = (query: Knex.QueryBuilder) => {
+    if (!isEmpty(this.query.branchesIds)) {
+      query.modify('filterByBranches', this.query.branchesIds);
+    }
+  };
+}

packages/server/src/services/FinancialStatements/TrialBalanceSheet/TrialBalanceSheetService.ts

@@ -2,12 +2,18 @@ import { Service, Inject } from 'typedi';
 import moment from 'moment';
 import TenancyService from '@/services/Tenancy/TenancyService';
 import Journal from '@/services/Accounting/JournalPoster';
-import { ITrialBalanceSheetMeta, ITrialBalanceSheetQuery, ITrialBalanceStatement } from '@/interfaces';
+import {
+  ITrialBalanceSheetMeta,
+  ITrialBalanceSheetQuery,
+  ITrialBalanceStatement,
+} from '@/interfaces';
 import TrialBalanceSheet from './TrialBalanceSheet';
 import FinancialSheet from '../FinancialSheet';
 import InventoryService from '@/services/Inventory/Inventory';
 import { parseBoolean } from 'utils';
 import { Tenant } from '@/system/models';
+import { TrialBalanceSheetRepository } from './TrialBalanceSheetRepository';
+import { TrialBalanceSheetTable } from './TrialBalanceSheetTable';
 
 @Service()
 export default class TrialBalanceSheetService extends FinancialSheet {
@@ -51,9 +57,8 @@ export default class TrialBalanceSheetService extends FinancialSheet {
   reportMetadata(tenantId: number): ITrialBalanceSheetMeta {
     const settings = this.tenancy.settings(tenantId);
 
-    const isCostComputeRunning = this.inventoryService.isItemsCostComputeRunning(
-      tenantId
-    );
+    const isCostComputeRunning =
+      this.inventoryService.isItemsCostComputeRunning(tenantId);
     const organizationName = settings.get({
       group: 'organization',
       key: 'name',
@@ -72,10 +77,8 @@ export default class TrialBalanceSheetService extends FinancialSheet {
 
   /**
    * Retrieve trial balance sheet statement.
-   * -------------
    * @param {number} tenantId
    * @param {IBalanceSheetQuery} query
-   *
    * @return {IBalanceSheetStatement}
    */
   public async trialBalanceSheet(
@@ -86,43 +89,27 @@ export default class TrialBalanceSheetService extends FinancialSheet {
       ...this.defaultQuery,
       ...query,
     };
-    const {
-      accountRepository,
-      transactionsRepository,
-    } = this.tenancy.repositories(tenantId);
 
     const tenant = await Tenant.query()
       .findById(tenantId)
       .withGraphFetched('metadata');
 
-    this.logger.info('[trial_balance_sheet] trying to calcualte the report.', {
-      tenantId,
-      filter,
-    });
-    // Retrieve all accounts on the storage.
-    const accounts = await accountRepository.all();
-    const accountsGraph = await accountRepository.getDependencyGraph();
+    const models = this.tenancy.models(tenantId);
+    const repos = this.tenancy.repositories(tenantId);
 
-    // Retrieve all journal transactions based on the given query.
-    const transactions = await transactionsRepository.journal({
-      fromDate: query.fromDate,
-      toDate: query.toDate,
-      sumationCreditDebit: true,
-      branchesIds: query.branchesIds
-    });
-    // Transform transactions array to journal collection.
-    const transactionsJournal = Journal.fromTransactions(
-      transactions,
-      tenantId,
-      accountsGraph
+    const trialBalanceSheetRepos = new TrialBalanceSheetRepository(
+      models,
+      repos,
+      filter
     );
+    await trialBalanceSheetRepos.asyncInitialize();
+
     // Trial balance report instance.
     const trialBalanceInstance = new TrialBalanceSheet(
       tenantId,
       filter,
-      accounts,
-      transactionsJournal,
-      tenant.metadata.baseCurrency,
+      trialBalanceSheetRepos,
+      tenant.metadata.baseCurrency
     );
     // Trial balance sheet data.
     const trialBalanceSheetData = trialBalanceInstance.reportData();
@@ -133,4 +120,27 @@ export default class TrialBalanceSheetService extends FinancialSheet {
       meta: this.reportMetadata(tenantId),
     };
   }
+
+  /**
+   * Retrieves the trial balance sheet table.
+   * @param {number} tenantId
+   * @param {ITrialBalanceSheetQuery} query
+   * @returns {Promise<any>}
+   */
+  public async trialBalanceSheetTable(
+    tenantId: number,
+    query: ITrialBalanceSheetQuery
+  ) {
+    const trialBalance = await this.trialBalanceSheet(tenantId, query);
+    const table = new TrialBalanceSheetTable(trialBalance.data, query, {});
+
+    return {
+      table: {
+        columns: table.tableColumns(),
+        rows: table.tableRows(),
+      },
+      meta: trialBalance.meta,
+      query: trialBalance.query,
+    };
+  }
 }

packages/server/src/services/FinancialStatements/TrialBalanceSheet/TrialBalanceSheetTable.ts

@@ -0,0 +1,146 @@
+import * as R from 'ramda';
+import FinancialSheet from '../FinancialSheet';
+import { FinancialTable } from '../FinancialTable';
+import {
+  IBalanceSheetStatementData,
+  ITableColumn,
+  ITableColumnAccessor,
+  ITableRow,
+  ITrialBalanceAccount,
+  ITrialBalanceSheetData,
+  ITrialBalanceSheetQuery,
+  ITrialBalanceTotal,
+} from '@/interfaces';
+import { tableRowMapper } from '@/utils';
+import { IROW_TYPE } from '../BalanceSheet/constants';
+import { FinancialSheetStructure } from '../FinancialSheetStructure';
+
+export class TrialBalanceSheetTable extends R.compose(
+  FinancialTable,
+  FinancialSheetStructure
+)(FinancialSheet) {
+  /**
+   * @param {ITrialBalanceSheetData}
+   */
+  public data: ITrialBalanceSheetData;
+
+  /**
+   * Balance sheet query.
+   * @param {ITrialBalanceSheetQuery}
+   */
+  public query: ITrialBalanceSheetQuery;
+
+  /**
+   * Constructor method.
+   * @param {IBalanceSheetStatementData} reportData -
+   * @param {ITrialBalanceSheetQuery} query -
+   */
+  constructor(
+    data: ITrialBalanceSheetData,
+    query: ITrialBalanceSheetQuery,
+    i18n: any
+  ) {
+    super();
+
+    this.data = data;
+    this.query = query;
+    this.i18n = i18n;
+  }
+  
+  /**
+   * Retrieve the common columns for all report nodes.
+   * @param {ITableColumnAccessor[]}
+   */
+  private commonColumnsAccessors = (): ITableColumnAccessor[] => {
+    return [
+      { key: 'account', accessor: 'formattedName' },
+      { key: 'debit', accessor: 'formattedDebit' },
+      { key: 'credit', accessor: 'formattedCredit' },
+      { key: 'total', accessor: 'formattedBalance' },
+    ];
+  };
+
+  /**
+   * Maps the account node to table row.
+   * @param {ITrialBalanceAccount} node -
+   * @returns {ITableRow}
+   */
+  private accountNodeTableRowsMapper = (
+    node: ITrialBalanceAccount
+  ): ITableRow => {
+    const columns = this.commonColumnsAccessors();
+    const meta = {
+      rowTypes: [IROW_TYPE.ACCOUNT],
+      id: node.id,
+    };
+    return tableRowMapper(node, columns, meta);
+  };
+
+  /**
+   * Maps the total node to table row.
+   * @param {ITrialBalanceTotal} node -
+   * @returns {ITableRow}
+   */
+  private totalNodeTableRowsMapper = (node: ITrialBalanceTotal): ITableRow => {
+    const columns = this.commonColumnsAccessors();
+    const meta = {
+      rowTypes: [IROW_TYPE.TOTAL],
+      id: node.id,
+    };
+    return tableRowMapper(node, columns, meta);
+  };
+
+  /**
+   * Mappes the given report sections to table rows.
+   * @param  {IBalanceSheetDataNode[]} nodes -
+   * @return {ITableRow}
+   */
+  private accountsToTableRowsMap = (
+    nodes: ITrialBalanceAccount[]
+  ): ITableRow[] => {
+    return this.mapNodesDeep(nodes, this.accountNodeTableRowsMapper);
+  };
+
+  /**
+   * Retrieves the accounts table rows of the given report data.
+   * @returns {ITableRow[]}
+   */
+  private accountsTableRows = (): ITableRow[] => {
+    return this.accountsToTableRowsMap(this.data.accounts);
+  };
+
+  /**
+   * Maps the given total node to table row.
+   * @returns {ITableRow}
+   */
+  private totalTableRow = (): ITableRow => {
+    return this.totalNodeTableRowsMapper(this.data.total);
+  };
+
+  /**
+   * Retrieves the table rows.
+   * @returns {ITableRow[]}
+   */
+  public tableRows = (): ITableRow[] => {
+    return R.compose(
+      R.append(this.totalTableRow()),
+      R.concat(this.accountsTableRows())
+    )([]);
+  };
+
+  /**
+   * Retrrieves the table columns.
+   * @returns {ITableColumn[]}
+   */
+  public tableColumns = (): ITableColumn[] => {
+    return R.compose(
+      this.tableColumnsCellIndexing,
+      R.concat([
+        { key: 'account_name', label: 'Account' },
+        { key: 'debit', label: 'Debit' },
+        { key: 'credit', label: 'Credit' },
+        { key: 'total', label: 'Total' },
+      ])
+    )([]);
+  };
+}

packages/server/src/services/FinancialStatements/TrialBalanceSheet/_constants.ts

@@ -0,0 +1,5 @@
+
+export enum IROW_TYPE {
+  ACCOUNT = 'ACCOUNT',
+  TOTAL = 'TOTAL',
+}