97 lines
2.8 KiB
TypeScript
97 lines
2.8 KiB
TypeScript
import { Knex } from 'knex';
|
|
import { Service, Inject } from 'typedi';
|
|
import {
|
|
ICreditNoteCreatedPayload,
|
|
ICreditNoteCreatingPayload,
|
|
ICreditNoteNewDTO,
|
|
} from '@/interfaces';
|
|
import HasTenancyService from '@/services/Tenancy/TenancyService';
|
|
import ItemsEntriesService from '@/services/Items/ItemsEntriesService';
|
|
import UnitOfWork from '@/services/UnitOfWork';
|
|
import { EventPublisher } from '@/lib/EventPublisher/EventPublisher';
|
|
import events from '@/subscribers/events';
|
|
import BaseCreditNotes from './CreditNotes';
|
|
|
|
@Service()
|
|
export default class CreateCreditNote extends BaseCreditNotes {
|
|
@Inject()
|
|
private uow: UnitOfWork;
|
|
|
|
@Inject()
|
|
private itemsEntriesService: ItemsEntriesService;
|
|
|
|
@Inject()
|
|
private tenancy: HasTenancyService;
|
|
|
|
@Inject()
|
|
private eventPublisher: EventPublisher;
|
|
|
|
/**
|
|
* Creates a new credit note.
|
|
* @param creditNoteDTO
|
|
*/
|
|
public newCreditNote = async (
|
|
tenantId: number,
|
|
creditNoteDTO: ICreditNoteNewDTO,
|
|
trx?: Knex.Transaction
|
|
) => {
|
|
const { CreditNote, Contact } = this.tenancy.models(tenantId);
|
|
|
|
// Triggers `onCreditNoteCreate` event.
|
|
await this.eventPublisher.emitAsync(events.creditNote.onCreate, {
|
|
tenantId,
|
|
creditNoteDTO,
|
|
});
|
|
// Validate customer existance.
|
|
const customer = await Contact.query()
|
|
.modify('customer')
|
|
.findById(creditNoteDTO.customerId)
|
|
.throwIfNotFound();
|
|
|
|
// Validate items ids existance.
|
|
await this.itemsEntriesService.validateItemsIdsExistance(
|
|
tenantId,
|
|
creditNoteDTO.entries
|
|
);
|
|
// Validate items should be sellable items.
|
|
await this.itemsEntriesService.validateNonSellableEntriesItems(
|
|
tenantId,
|
|
creditNoteDTO.entries
|
|
);
|
|
// Transformes the given DTO to storage layer data.
|
|
const creditNoteModel = this.transformCreateEditDTOToModel(
|
|
tenantId,
|
|
creditNoteDTO,
|
|
customer.currencyCode
|
|
);
|
|
// Creates a new credit card transactions under unit-of-work envirement.
|
|
return this.uow.withTransaction(
|
|
tenantId,
|
|
async (trx: Knex.Transaction) => {
|
|
// Triggers `onCreditNoteCreating` event.
|
|
await this.eventPublisher.emitAsync(events.creditNote.onCreating, {
|
|
tenantId,
|
|
creditNoteDTO,
|
|
trx,
|
|
} as ICreditNoteCreatingPayload);
|
|
|
|
// Upsert the credit note graph.
|
|
const creditNote = await CreditNote.query(trx).upsertGraph({
|
|
...creditNoteModel,
|
|
});
|
|
// Triggers `onCreditNoteCreated` event.
|
|
await this.eventPublisher.emitAsync(events.creditNote.onCreated, {
|
|
tenantId,
|
|
creditNoteDTO,
|
|
creditNote,
|
|
creditNoteId: creditNote.id,
|
|
trx,
|
|
} as ICreditNoteCreatedPayload);
|
|
|
|
return creditNote;
|
|
},
|
|
trx
|
|
);
|
|
};
|
|
}
|