chore: add some
This commit is contained in:
@@ -1,13 +1,14 @@
|
||||
import { Injectable } from "@nestjs/common";
|
||||
import { BadRequestException, Injectable } from "@nestjs/common";
|
||||
// eslint-disable-next-line import/no-named-as-default
|
||||
import Decimal from "decimal.js";
|
||||
import { QueryRunner } from "typeorm";
|
||||
|
||||
import { InvoiceMessage } from "../../../common/enums/message.enum";
|
||||
import { SubscriptionPlan } from "../../subscriptions/entities/subscription.entity";
|
||||
import { RoleEnum } from "../../users/enums/role.enum";
|
||||
import { PaginationUtils } from "../../utils/providers/pagination.utils";
|
||||
import { CreateInvoiceDto } from "../DTO/create-invoice.dto";
|
||||
import { InvoicesSearchQueryDto } from "../DTO/invoices-search-query.dto";
|
||||
import { InvoicesSearchQueryDto, UserInvoicesSearchQueryDto } from "../DTO/invoices-search-query.dto";
|
||||
import { Invoice } from "../entities/invoice.entity";
|
||||
import { InvoiceStatus } from "../enums/invoice-status.enum";
|
||||
// import { InvoiceItemsRepository } from "../repositories/invoice-items.repository";
|
||||
@@ -31,7 +32,7 @@ export class InvoicesService {
|
||||
totalPrice: item.unitPrice * item.count - (item.unitPrice * item.count * item.discount) / 100,
|
||||
};
|
||||
});
|
||||
|
||||
//
|
||||
const totalPrice = invoiceItems.reduce((sum, item) => new Decimal(item.totalPrice).add(sum), new Decimal(0));
|
||||
const tax = totalPrice.mul(0.1);
|
||||
//
|
||||
@@ -40,7 +41,7 @@ export class InvoicesService {
|
||||
//
|
||||
const invoice = this.invoiceRepository.create({
|
||||
user: { id: createDto.userId },
|
||||
totalPrice,
|
||||
totalPrice: totalPrice.toNumber(),
|
||||
items: invoiceItems,
|
||||
tax: tax.toNumber(),
|
||||
dueDate,
|
||||
@@ -56,8 +57,9 @@ export class InvoicesService {
|
||||
}
|
||||
///********************************** */
|
||||
async createInvoiceForSubscription(userId: string, plan: SubscriptionPlan, dueDate: Date, queryRunner: QueryRunner) {
|
||||
const invoiceItems = [{ name: plan.name, count: 1, unitPrice: plan.price, discount: 0, subscriptionPlan: plan }];
|
||||
|
||||
const invoiceItems = [
|
||||
{ name: plan.service.name, count: 1, unitPrice: plan.price, discount: 0, subscriptionPlan: plan, totalPrice: plan.price },
|
||||
];
|
||||
const invoice = queryRunner.manager.create(Invoice, {
|
||||
totalPrice: plan.price,
|
||||
user: { id: userId },
|
||||
@@ -66,7 +68,7 @@ export class InvoicesService {
|
||||
dueDate,
|
||||
items: invoiceItems,
|
||||
});
|
||||
|
||||
//
|
||||
await queryRunner.manager.save(Invoice, invoice);
|
||||
return invoice;
|
||||
}
|
||||
@@ -81,7 +83,8 @@ export class InvoicesService {
|
||||
queryBuilder
|
||||
.leftJoinAndSelect("invoice.user", "user")
|
||||
.leftJoinAndSelect("invoice.items", "items")
|
||||
.leftJoinAndSelect("items.subscriptionPlan", "subscriptionPlan");
|
||||
.leftJoinAndSelect("items.subscriptionPlan", "subscriptionPlan", "subscriptionPlan.id IS NOT NULL")
|
||||
.leftJoinAndSelect("subscriptionPlan.service", "service", "subscriptionPlan.id IS NOT NULL");
|
||||
|
||||
if (queryDto.q) {
|
||||
queryBuilder
|
||||
@@ -102,12 +105,60 @@ export class InvoicesService {
|
||||
queryBuilder.andWhere("subscriptionPlan.serviceId = :serviceId", { serviceId: queryDto.serviceId });
|
||||
}
|
||||
|
||||
queryBuilder.orderBy("createdAt", "DESC");
|
||||
queryBuilder.orderBy("invoice.createdAt", "DESC");
|
||||
queryBuilder.skip(skip);
|
||||
queryBuilder.take(limit);
|
||||
|
||||
const [invoices, count] = await queryBuilder.getManyAndCount();
|
||||
|
||||
return {
|
||||
invoices,
|
||||
count,
|
||||
paginate: true,
|
||||
};
|
||||
}
|
||||
//*********************************** */
|
||||
async getInvoiceById(invoiceId: string, role: RoleEnum, userId: string) {
|
||||
let invoice: Invoice | null;
|
||||
|
||||
if (role === RoleEnum.ADMIN) {
|
||||
invoice = await this.invoiceRepository.findOne({
|
||||
where: { id: invoiceId },
|
||||
relations: { items: { subscriptionPlan: true }, user: true },
|
||||
});
|
||||
} else {
|
||||
invoice = await this.invoiceRepository.findOne({
|
||||
where: { id: invoiceId, user: { id: userId } },
|
||||
relations: { items: { subscriptionPlan: true } },
|
||||
});
|
||||
}
|
||||
|
||||
if (!invoice) throw new BadRequestException(InvoiceMessage.NOT_FOUND_BY_ID);
|
||||
|
||||
return {
|
||||
invoice,
|
||||
};
|
||||
}
|
||||
//*********************************** */
|
||||
async getUserInvoices(queryDto: UserInvoicesSearchQueryDto, userId: string) {
|
||||
const { limit, skip } = PaginationUtils(queryDto);
|
||||
|
||||
const queryBuilder = this.invoiceRepository.createQueryBuilder("invoice");
|
||||
|
||||
queryBuilder
|
||||
.andWhere("invoice.user.id = :userId", { userId: userId })
|
||||
.leftJoinAndSelect("invoice.items", "items")
|
||||
.leftJoinAndSelect("items.subscriptionPlan", "subscriptionPlan", "subscriptionPlan.id IS NOT NULL")
|
||||
.leftJoinAndSelect("subscriptionPlan.service", "service", "subscriptionPlan.id IS NOT NULL");
|
||||
|
||||
if (queryDto.status) {
|
||||
queryBuilder.andWhere("invoice.status = :status", { status: queryDto.status });
|
||||
}
|
||||
|
||||
queryBuilder.orderBy("invoice.createdAt", "DESC").skip(skip).take(limit);
|
||||
|
||||
const [invoices, count] = await queryBuilder.getManyAndCount();
|
||||
|
||||
return {
|
||||
invoices,
|
||||
count,
|
||||
|
||||
Reference in New Issue
Block a user