💻 Transactions service

[B-Dmitriy]

Разработать сервис транзакции

[!CAUTION] Не возможно начинать, пока не будет готова таблица контрагентов

• https://github.com/B-Dmitriy/cashflow/issues/2

На данный момент нужны следующие колонки: 1) id 2) comment 3) amount - сумма, кол-во денег 4) currency - валюта 5) in/out - входящий/исходящий (для фильрации) 5) counterpartyId - ссылка на контрагента 6) createdAt

Необходимо реализовать в прототипе (v0)

• [x] Список всех транзакций
• [x] CRUD
• [x] Пагинация
• [x] Сортировка по дате (по-умолчанию), и по сумме рамеру платежа.
• [x] Фильтр по входящим и исходящим
• [x] Фильтр по месяцу (вернее по интервалу даты)

[B-Dmitriy]

import { Repository } from 'typeorm';
import { InjectRepository } from '@nestjs/typeorm';
import { Injectable, NotFoundException } from '@nestjs/common';

import { TransactionDto } from './dto/transaction.dto';
import { Transaction } from './entities/transaction.entity';
import { CreateTransactionDto } from './dto/create-transaction.dto';
import { UpdateTransactionDto } from './dto/update-transaction.dto';
import { GetTransactionsQueryDto } from './dto/get-transaction-query.dto';
import { Counterparty } from '../counterparties/entities/counterparty.entity';

@Injectable()
export class TransactionsService {
  constructor(
    @InjectRepository(Counterparty)
    private counterpartyRepository: Repository<Counterparty>,
    @InjectRepository(Transaction)
    private transactionsRepository: Repository<Transaction>,
  ) {}

  async create(
    createTransactionDto: CreateTransactionDto,
  ): Promise<TransactionDto> {
    const counterpartyId = createTransactionDto.counterpartyId;

    const counterparty = await this.counterpartyRepository.findOneBy({
      id: counterpartyId,
    });

    if (!counterparty) {
      throw new NotFoundException({
        statusCode: 404,
        message: `counterparty with id ${counterpartyId} not found`,
      });
    }

    return await this.transactionsRepository.save(createTransactionDto);
  }

  // TODO: Common return type for tables get-counterparties-response.dto.ts
  async findAll(queryParams: GetTransactionsQueryDto) {
    const transactions = await this.transactionsRepository.query(`
        select t.id,t.amount,t.currency,
               c.name as counterparty,
               c.description as counterpartyDescription,
               t.createdAt,t.comment
        from "transaction" AS t
        LEFT JOIN counterparty AS c
        ON t.counterpartyId = c.id
        LIMIT ${queryParams.limit}
        OFFSET ${(+queryParams.page - 1) * +queryParams.limit};
    `);

    const total = await this.transactionsRepository.count();

    return {
      items: transactions,
      page: +queryParams.page,
      limit: +queryParams.limit,
      total,
    };
  }

  async findOne(id: number) {
    const transaction = await this.transactionsRepository.findOneBy({ id });

    if (!transaction) throw new NotFoundException();

    return transaction;
  }

  async update(id: number, updateTransactionDto: UpdateTransactionDto) {
    const counterpartyId = updateTransactionDto.counterpartyId;

    const counterparty = await this.counterpartyRepository.findOneBy({
      id: counterpartyId,
    });

    if (!counterparty) {
      throw new NotFoundException({
        statusCode: 404,
        message: `counterparty with id ${counterpartyId} not found`,
      });
    }

    const updateResult = await this.transactionsRepository.update(
      id,
      updateTransactionDto,
    );

    if (updateResult.affected === 0) throw new NotFoundException();

    return await this.transactionsRepository.findOneBy({ id });
  }

  async remove(id: number) {
    const deletedResult = await this.transactionsRepository.delete(id);

    if (deletedResult.affected === 0) throw new NotFoundException();

    return;
  }
}

[B-Dmitriy]

Closed in pr #6