feat(analytics): account commission and investment transfers

Handle cashback commission imports, include commissions in analytics with separate investment metrics, and expose commission/version details in the UI.

Made-with: Cursor

backend/src/services/analytics.ts

@@ -47,26 +47,91 @@ export async function getSummary(params: BaseParams): Promise<AnalyticsSummaryRe
   const where = 'WHERE ' + conditions.join(' AND ');
 
   const totalsResult = await pool.query(
-    `SELECT
-       COALESCE(SUM(CASE WHEN t.direction = 'expense' THEN ABS(t.amount_signed) ELSE 0 END), 0)::bigint AS total_expense,
-       COALESCE(SUM(CASE WHEN t.direction = 'income' THEN t.amount_signed ELSE 0 END), 0)::bigint AS total_income
+    `WITH investment_ref AS (
+       SELECT (
+         SELECT id
+         FROM categories
+         WHERE name = 'Инвестиции' AND type = 'transfer'
+         ORDER BY id ASC
+         LIMIT 1
+       ) AS investment_category_id
+     )
+     SELECT
+       COALESCE(SUM(
+         CASE
+           WHEN (t.direction = 'expense' OR (t.direction = 'transfer' AND t.amount_signed < 0))
+             AND (
+               ir.investment_category_id IS NULL
+               OR t.category_id IS DISTINCT FROM ir.investment_category_id
+             )
+             THEN ABS(t.amount_signed) + t.commission
+           ELSE 0
+         END
+       ), 0)::bigint AS total_expense,
+       COALESCE(SUM(
+         CASE
+           WHEN t.direction = 'income'
+             AND (
+               ir.investment_category_id IS NULL
+               OR t.category_id IS DISTINCT FROM ir.investment_category_id
+             )
+             THEN t.amount_signed + t.commission
+           ELSE 0
+         END
+       ), 0)::bigint AS total_income,
+       COALESCE(SUM(
+         CASE
+           WHEN t.amount_signed < 0
+             AND ir.investment_category_id IS NOT NULL
+             AND t.category_id = ir.investment_category_id
+             THEN ABS(t.amount_signed) + t.commission
+           ELSE 0
+         END
+       ), 0)::bigint AS investment_outflow,
+       COALESCE(SUM(
+         CASE
+           WHEN t.amount_signed > 0
+             AND ir.investment_category_id IS NOT NULL
+             AND t.category_id = ir.investment_category_id
+             THEN t.amount_signed + t.commission
+           ELSE 0
+         END
+       ), 0)::bigint AS investment_income_excluded
      FROM transactions t
+     CROSS JOIN investment_ref ir
      ${where}`,
     values,
   );
 
   const totalExpense = Number(totalsResult.rows[0].total_expense);
   const totalIncome = Number(totalsResult.rows[0].total_income);
+  const investmentOutflow = Number(totalsResult.rows[0].investment_outflow);
+  const investmentIncomeExcluded = Number(totalsResult.rows[0].investment_income_excluded);
 
   const topResult = await pool.query(
-    `SELECT
-       t.category_id,
-       c.name AS category_name,
-       SUM(ABS(t.amount_signed))::bigint AS amount
+    `WITH investment_ref AS (
+       SELECT (
+         SELECT id
+         FROM categories
+         WHERE name = 'Инвестиции' AND type = 'transfer'
+         ORDER BY id ASC
+         LIMIT 1
+       ) AS investment_category_id
+     )
+     SELECT
+       COALESCE(t.category_id, 0)::bigint AS category_id,
+       COALESCE(c.name, 'Без категории') AS category_name,
+       SUM(ABS(t.amount_signed) + t.commission)::bigint AS amount
      FROM transactions t
+     CROSS JOIN investment_ref ir
      LEFT JOIN categories c ON c.id = t.category_id
-     ${where} AND t.direction = 'expense' AND t.category_id IS NOT NULL
-     GROUP BY t.category_id, c.name
+     ${where}
+       AND (t.direction = 'expense' OR (t.direction = 'transfer' AND t.amount_signed < 0))
+       AND (
+         ir.investment_category_id IS NULL
+         OR t.category_id IS DISTINCT FROM ir.investment_category_id
+       )
+     GROUP BY COALESCE(t.category_id, 0), COALESCE(c.name, 'Без категории')
      ORDER BY amount DESC
      LIMIT 5`,
     values,
@@ -83,6 +148,8 @@ export async function getSummary(params: BaseParams): Promise<AnalyticsSummaryRe
     totalExpense,
     totalIncome,
     net: totalIncome - totalExpense,
+    investmentOutflow,
+    investmentIncomeExcluded,
     topCategories,
   };
 }
@@ -92,23 +159,53 @@ export async function getByCategory(params: BaseParams): Promise<ByCategoryItem[
   const where = 'WHERE ' + conditions.join(' AND ');
 
   const totalResult = await pool.query(
-    `SELECT COALESCE(SUM(ABS(t.amount_signed)), 0)::bigint AS total
+    `WITH investment_ref AS (
+       SELECT (
+         SELECT id
+         FROM categories
+         WHERE name = 'Инвестиции' AND type = 'transfer'
+         ORDER BY id ASC
+         LIMIT 1
+       ) AS investment_category_id
+     )
+     SELECT COALESCE(SUM(ABS(t.amount_signed) + t.commission), 0)::bigint AS total
      FROM transactions t
-     ${where} AND t.direction = 'expense'`,
+     CROSS JOIN investment_ref ir
+     ${where}
+       AND (t.direction = 'expense' OR (t.direction = 'transfer' AND t.amount_signed < 0))
+       AND (
+         ir.investment_category_id IS NULL
+         OR t.category_id IS DISTINCT FROM ir.investment_category_id
+       )`,
     values,
   );
   const total = Number(totalResult.rows[0].total);
 
   const { rows } = await pool.query(
-    `SELECT
-       t.category_id,
-       c.name AS category_name,
-       SUM(ABS(t.amount_signed))::bigint AS amount,
+    `WITH investment_ref AS (
+       SELECT (
+         SELECT id
+         FROM categories
+         WHERE name = 'Инвестиции' AND type = 'transfer'
+         ORDER BY id ASC
+         LIMIT 1
+       ) AS investment_category_id
+     )
+     SELECT
+       COALESCE(t.category_id, 0)::bigint AS category_id,
+       COALESCE(c.name, 'Без категории') AS category_name,
+       SUM(ABS(t.amount_signed) + t.commission)::bigint AS amount,
        COUNT(*)::int AS tx_count
      FROM transactions t
+     CROSS JOIN investment_ref ir
      LEFT JOIN categories c ON c.id = t.category_id
-     ${where} AND t.direction = 'expense'
-     GROUP BY t.category_id, c.name
+     ${where}
+       AND (t.direction = 'expense' OR (t.direction = 'transfer' AND t.amount_signed < 0))
+       AND (
+         ir.investment_category_id IS NULL
+         OR t.category_id IS DISTINCT FROM ir.investment_category_id
+       )
+     GROUP BY COALESCE(t.category_id, 0), COALESCE(c.name, 'Без категории')
      ORDER BY amount DESC`,
     values,
   );
@@ -174,13 +271,52 @@ export async function getTimeseries(
          gs::date AS period_start,
          ${periodEndExpr} AS period_end
        FROM generate_series(${truncExpr}, $2::date, '${intervalStr}'::interval) gs
+     ),
+     investment_ref AS (
+       SELECT (
+         SELECT id
+         FROM categories
+         WHERE name = 'Инвестиции' AND type = 'transfer'
+         ORDER BY id ASC
+         LIMIT 1
+       ) AS investment_category_id
      )
      SELECT
        p.period_start,
        p.period_end,
-       COALESCE(SUM(CASE WHEN t.direction = 'expense' THEN ABS(t.amount_signed) ELSE 0 END), 0)::bigint AS expense_amount,
-       COALESCE(SUM(CASE WHEN t.direction = 'income' THEN t.amount_signed ELSE 0 END), 0)::bigint AS income_amount
+       COALESCE(SUM(
+         CASE
+           WHEN (t.direction = 'expense' OR (t.direction = 'transfer' AND t.amount_signed < 0))
+             AND (
+               ir.investment_category_id IS NULL
+               OR t.category_id IS DISTINCT FROM ir.investment_category_id
+             )
+             THEN ABS(t.amount_signed) + t.commission
+           ELSE 0
+         END
+       ), 0)::bigint AS expense_amount,
+       COALESCE(SUM(
+         CASE
+           WHEN t.direction = 'income'
+             AND (
+               ir.investment_category_id IS NULL
+               OR t.category_id IS DISTINCT FROM ir.investment_category_id
+             )
+             THEN t.amount_signed + t.commission
+           ELSE 0
+         END
+       ), 0)::bigint AS income_amount,
+       COALESCE(SUM(
+         CASE
+           WHEN t.amount_signed < 0
+             AND ir.investment_category_id IS NOT NULL
+             AND t.category_id = ir.investment_category_id
+             THEN ABS(t.amount_signed) + t.commission
+           ELSE 0
+         END
+       ), 0)::bigint AS investment_outflow
      FROM periods p
+     CROSS JOIN investment_ref ir
      LEFT JOIN transactions t ON ${txWhere}
      GROUP BY p.period_start, p.period_end
      ORDER BY p.period_start`,
@@ -192,5 +328,6 @@ export async function getTimeseries(
     periodEnd: r.period_end.toISOString().slice(0, 10),
     expenseAmount: Number(r.expense_amount),
     incomeAmount: Number(r.income_amount),
+    investmentOutflow: Number(r.investment_outflow),
   }));
 }