feat(saleReceipts): fix schedule compute inventory items cost.

This commit is contained in:
a.bouhuolia
2021-03-03 14:05:58 +02:00
parent 0c6bbba647
commit 9fef91b965
4 changed files with 76 additions and 77 deletions

View File

@@ -7,7 +7,7 @@ import SaleInvoiceService from 'services/Sales/SalesInvoices';
import ItemsService from 'services/Items/ItemsService'; import ItemsService from 'services/Items/ItemsService';
import DynamicListingService from 'services/DynamicListing/DynamicListService'; import DynamicListingService from 'services/DynamicListing/DynamicListService';
import { ServiceError } from 'exceptions'; import { ServiceError } from 'exceptions';
import { ISaleInvoiceDTO, ISalesInvoicesFilter } from 'interfaces'; import { ISaleInvoiceDTO, ISaleInvoiceCreateDTO } from 'interfaces';
@Service() @Service()
export default class SaleInvoicesController extends BaseController { export default class SaleInvoicesController extends BaseController {
@@ -153,7 +153,7 @@ export default class SaleInvoicesController extends BaseController {
*/ */
async newSaleInvoice(req: Request, res: Response, next: NextFunction) { async newSaleInvoice(req: Request, res: Response, next: NextFunction) {
const { tenantId, user } = req; const { tenantId, user } = req;
const saleInvoiceDTO: ISaleInvoiceDTO = this.matchedBodyData(req); const saleInvoiceDTO: ISaleInvoiceCreateDTO = this.matchedBodyData(req);
try { try {
// Creates a new sale invoice with associated entries. // Creates a new sale invoice with associated entries.

View File

@@ -9,7 +9,7 @@ import { ServiceError } from 'exceptions';
import DynamicListingService from 'services/DynamicListing/DynamicListService'; import DynamicListingService from 'services/DynamicListing/DynamicListService';
@Service() @Service()
export default class SalesReceiptsController extends BaseController{ export default class SalesReceiptsController extends BaseController {
@Inject() @Inject()
saleReceiptService: SaleReceiptService; saleReceiptService: SaleReceiptService;
@@ -24,36 +24,35 @@ export default class SalesReceiptsController extends BaseController{
router.post( router.post(
'/:id/close', '/:id/close',
[ [...this.specificReceiptValidationSchema],
...this.specificReceiptValidationSchema,
],
this.validationResult, this.validationResult,
asyncMiddleware(this.closeSaleReceipt.bind(this)), asyncMiddleware(this.closeSaleReceipt.bind(this)),
this.handleServiceErrors, this.handleServiceErrors
) );
router.post( router.post(
'/:id', [ '/:id',
[
...this.specificReceiptValidationSchema, ...this.specificReceiptValidationSchema,
...this.salesReceiptsValidationSchema, ...this.salesReceiptsValidationSchema,
], ],
this.validationResult, this.validationResult,
asyncMiddleware(this.editSaleReceipt.bind(this)), asyncMiddleware(this.editSaleReceipt.bind(this)),
this.handleServiceErrors, this.handleServiceErrors
); );
router.post( router.post(
'/', '/',
this.salesReceiptsValidationSchema, this.salesReceiptsValidationSchema,
this.validationResult, this.validationResult,
asyncMiddleware(this.newSaleReceipt.bind(this)), asyncMiddleware(this.newSaleReceipt.bind(this)),
this.handleServiceErrors, this.handleServiceErrors
); );
router.delete( router.delete(
'/:id', '/:id',
this.specificReceiptValidationSchema, this.specificReceiptValidationSchema,
this.validationResult, this.validationResult,
asyncMiddleware(this.deleteSaleReceipt.bind(this)), asyncMiddleware(this.deleteSaleReceipt.bind(this)),
this.handleServiceErrors, this.handleServiceErrors
); );
router.get( router.get(
'/', '/',
@@ -61,15 +60,14 @@ export default class SalesReceiptsController extends BaseController{
this.validationResult, this.validationResult,
asyncMiddleware(this.getSalesReceipts.bind(this)), asyncMiddleware(this.getSalesReceipts.bind(this)),
this.handleServiceErrors, this.handleServiceErrors,
this.dynamicListService.handlerErrorsToResponse, this.dynamicListService.handlerErrorsToResponse
); );
router.get( router.get(
'/:id', [ '/:id',
...this.specificReceiptValidationSchema, [...this.specificReceiptValidationSchema],
],
this.validationResult, this.validationResult,
asyncMiddleware(this.getSaleReceipt.bind(this)), asyncMiddleware(this.getSaleReceipt.bind(this)),
this.handleServiceErrors, this.handleServiceErrors
); );
return router; return router;
} }
@@ -94,8 +92,14 @@ export default class SalesReceiptsController extends BaseController{
check('entries.*.item_id').exists().isNumeric().toInt(), check('entries.*.item_id').exists().isNumeric().toInt(),
check('entries.*.quantity').exists().isNumeric().toInt(), check('entries.*.quantity').exists().isNumeric().toInt(),
check('entries.*.rate').exists().isNumeric().toInt(), check('entries.*.rate').exists().isNumeric().toInt(),
check('entries.*.discount').optional({ nullable: true }).isNumeric().toInt(), check('entries.*.discount')
check('entries.*.description').optional({ nullable: true }).trim().escape(), .optional({ nullable: true })
.isNumeric()
.toInt(),
check('entries.*.description')
.optional({ nullable: true })
.trim()
.escape(),
check('receipt_message').optional().trim().escape(), check('receipt_message').optional().trim().escape(),
check('statement').optional().trim().escape(), check('statement').optional().trim().escape(),
@@ -106,9 +110,7 @@ export default class SalesReceiptsController extends BaseController{
* Specific sale receipt validation schema. * Specific sale receipt validation schema.
*/ */
get specificReceiptValidationSchema() { get specificReceiptValidationSchema() {
return [ return [param('id').exists().isNumeric().toInt()];
param('id').exists().isNumeric().toInt()
];
} }
/** /**
@@ -121,14 +123,14 @@ export default class SalesReceiptsController extends BaseController{
query('column_sort_by').optional(), query('column_sort_by').optional(),
query('sort_order').optional().isIn(['desc', 'asc']), query('sort_order').optional().isIn(['desc', 'asc']),
query('page').optional().isNumeric().toInt(), query('page').optional().isNumeric().toInt(),
query('page_size').optional().isNumeric().toInt(), query('page_size').optional().isNumeric().toInt(),
]; ];
} }
/** /**
* Creates a new receipt. * Creates a new receipt.
* @param {Request} req * @param {Request} req
* @param {Response} res * @param {Response} res
*/ */
async newSaleReceipt(req: Request, res: Response, next: NextFunction) { async newSaleReceipt(req: Request, res: Response, next: NextFunction) {
const { tenantId } = req; const { tenantId } = req;
@@ -136,11 +138,10 @@ export default class SalesReceiptsController extends BaseController{
try { try {
// Store the given sale receipt details with associated entries. // Store the given sale receipt details with associated entries.
const storedSaleReceipt = await this.saleReceiptService const storedSaleReceipt = await this.saleReceiptService.createSaleReceipt(
.createSaleReceipt( tenantId,
tenantId, saleReceiptDTO
saleReceiptDTO, );
);
return res.status(200).send({ return res.status(200).send({
id: storedSaleReceipt.id, id: storedSaleReceipt.id,
message: 'Sale receipt has been created successfully.', message: 'Sale receipt has been created successfully.',
@@ -152,8 +153,8 @@ export default class SalesReceiptsController extends BaseController{
/** /**
* Deletes the sale receipt with associated entries and journal transactions. * Deletes the sale receipt with associated entries and journal transactions.
* @param {Request} req * @param {Request} req
* @param {Response} res * @param {Response} res
*/ */
async deleteSaleReceipt(req: Request, res: Response, next: NextFunction) { async deleteSaleReceipt(req: Request, res: Response, next: NextFunction) {
const { tenantId } = req; const { tenantId } = req;
@@ -162,7 +163,7 @@ export default class SalesReceiptsController extends BaseController{
try { try {
// Deletes the sale receipt. // Deletes the sale receipt.
await this.saleReceiptService.deleteSaleReceipt(tenantId, saleReceiptId); await this.saleReceiptService.deleteSaleReceipt(tenantId, saleReceiptId);
return res.status(200).send({ return res.status(200).send({
id: saleReceiptId, id: saleReceiptId,
message: 'Sale receipt has been deleted successfully.', message: 'Sale receipt has been deleted successfully.',
@@ -175,8 +176,8 @@ export default class SalesReceiptsController extends BaseController{
/** /**
* Edit the sale receipt details with associated entries and re-write * Edit the sale receipt details with associated entries and re-write
* journal transaction on the same date. * journal transaction on the same date.
* @param {Request} req - * @param {Request} req -
* @param {Response} res - * @param {Response} res -
*/ */
async editSaleReceipt(req: Request, res: Response, next: NextFunction) { async editSaleReceipt(req: Request, res: Response, next: NextFunction) {
const { tenantId } = req; const { tenantId } = req;
@@ -188,7 +189,7 @@ export default class SalesReceiptsController extends BaseController{
await this.saleReceiptService.editSaleReceipt( await this.saleReceiptService.editSaleReceipt(
tenantId, tenantId,
saleReceiptId, saleReceiptId,
saleReceipt, saleReceipt
); );
return res.status(200).send({ return res.status(200).send({
id: saleReceiptId, id: saleReceiptId,
@@ -201,9 +202,9 @@ export default class SalesReceiptsController extends BaseController{
/** /**
* Marks the given the sale receipt as closed. * Marks the given the sale receipt as closed.
* @param {Request} req * @param {Request} req
* @param {Response} res * @param {Response} res
* @param {NextFunction} next * @param {NextFunction} next
*/ */
async closeSaleReceipt(req: Request, res: Response, next: NextFunction) { async closeSaleReceipt(req: Request, res: Response, next: NextFunction) {
const { tenantId } = req; const { tenantId } = req;
@@ -211,10 +212,7 @@ export default class SalesReceiptsController extends BaseController{
try { try {
// Update the given sale receipt details. // Update the given sale receipt details.
await this.saleReceiptService.closeSaleReceipt( await this.saleReceiptService.closeSaleReceipt(tenantId, saleReceiptId);
tenantId,
saleReceiptId,
);
return res.status(200).send({ return res.status(200).send({
id: saleReceiptId, id: saleReceiptId,
message: 'Sale receipt has been closed successfully.', message: 'Sale receipt has been closed successfully.',
@@ -226,7 +224,7 @@ export default class SalesReceiptsController extends BaseController{
/** /**
* Listing sales receipts. * Listing sales receipts.
* @param {Request} req * @param {Request} req
* @param {Response} res * @param {Response} res
*/ */
async getSalesReceipts(req: Request, res: Response, next: NextFunction) { async getSalesReceipts(req: Request, res: Response, next: NextFunction) {
@@ -244,8 +242,11 @@ export default class SalesReceiptsController extends BaseController{
} }
try { try {
const { salesReceipts, pagination, filterMeta } = await this.saleReceiptService const {
.salesReceiptsList(tenantId, filter); salesReceipts,
pagination,
filterMeta,
} = await this.saleReceiptService.salesReceiptsList(tenantId, filter);
return res.status(200).send({ return res.status(200).send({
sale_receipts: salesReceipts, sale_receipts: salesReceipts,
@@ -259,20 +260,23 @@ export default class SalesReceiptsController extends BaseController{
/** /**
* Retrieve the sale receipt with associated entries. * Retrieve the sale receipt with associated entries.
* @param {Request} req * @param {Request} req
* @param {Response} res * @param {Response} res
* @param {NextFunction} next * @param {NextFunction} next
*/ */
async getSaleReceipt(req: Request, res: Response, next: NextFunction) { async getSaleReceipt(req: Request, res: Response, next: NextFunction) {
const { id: saleReceiptId } = req.params; const { id: saleReceiptId } = req.params;
const { tenantId } = req; const { tenantId } = req;
try { try {
const saleReceipt = await this.saleReceiptService.getSaleReceipt(tenantId, saleReceiptId); const saleReceipt = await this.saleReceiptService.getSaleReceipt(
tenantId,
saleReceiptId
);
return res.status(200).send({ return res.status(200).send({
sale_receipt: saleReceipt, sale_receipt: saleReceipt,
}) });
} catch (error) { } catch (error) {
next(error); next(error);
} }
@@ -280,41 +284,46 @@ export default class SalesReceiptsController extends BaseController{
/** /**
* Handles service errors. * Handles service errors.
* @param {Error} error * @param {Error} error
* @param {Request} req * @param {Request} req
* @param {Response} res * @param {Response} res
* @param {NextFunction} next * @param {NextFunction} next
*/ */
handleServiceErrors(error: Error, req: Request, res: Response, next: NextFunction) { handleServiceErrors(
error: Error,
req: Request,
res: Response,
next: NextFunction
) {
if (error instanceof ServiceError) { if (error instanceof ServiceError) {
if (error.errorType === 'SALE_RECEIPT_NOT_FOUND') { if (error.errorType === 'SALE_RECEIPT_NOT_FOUND') {
return res.boom.badRequest(null, { return res.boom.badRequest(null, {
errors: [{ type: 'SALE_RECEIPT_NOT_FOUND', code: 100 }], errors: [{ type: 'SALE_RECEIPT_NOT_FOUND', code: 100 }],
}) });
} }
if (error.errorType === 'DEPOSIT_ACCOUNT_NOT_FOUND') { if (error.errorType === 'DEPOSIT_ACCOUNT_NOT_FOUND') {
return res.boom.badRequest(null, { return res.boom.badRequest(null, {
errors: [{ type: 'DEPOSIT_ACCOUNT_NOT_FOUND', code: 200 }], errors: [{ type: 'DEPOSIT_ACCOUNT_NOT_FOUND', code: 200 }],
}) });
} }
if (error.errorType === 'DEPOSIT_ACCOUNT_NOT_CURRENT_ASSET') { if (error.errorType === 'DEPOSIT_ACCOUNT_NOT_CURRENT_ASSET') {
return res.boom.badRequest(null, { return res.boom.badRequest(null, {
errors: [{ type: 'DEPOSIT_ACCOUNT_NOT_CURRENT_ASSET', code: 300 }], errors: [{ type: 'DEPOSIT_ACCOUNT_NOT_CURRENT_ASSET', code: 300 }],
}) });
} }
if (error.errorType === 'ITEMS_NOT_FOUND') { if (error.errorType === 'ITEMS_NOT_FOUND') {
return res.boom.badRequest(null, { return res.boom.badRequest(null, {
errors: [{ type: 'ITEMS_NOT_FOUND', code: 400, }], errors: [{ type: 'ITEMS_NOT_FOUND', code: 400 }],
}); });
} }
if (error.errorType === 'ENTRIES_IDS_NOT_FOUND') { if (error.errorType === 'ENTRIES_IDS_NOT_FOUND') {
return res.boom.badRequest(null, { return res.boom.badRequest(null, {
errors: [{ type: 'ENTRIES_IDS_NOT_FOUND', code: 500, }], errors: [{ type: 'ENTRIES_IDS_NOT_FOUND', code: 500 }],
}); });
} }
if (error.errorType === 'NOT_SELL_ABLE_ITEMS') { if (error.errorType === 'NOT_SELL_ABLE_ITEMS') {
return res.boom.badRequest(null, { return res.boom.badRequest(null, {
errors: [{ type: 'NOT_SELL_ABLE_ITEMS', code: 600, }], errors: [{ type: 'NOT_SELL_ABLE_ITEMS', code: 600 }],
}); });
} }
if (error.errorType === 'SALE.RECEIPT.NOT.FOUND') { if (error.errorType === 'SALE.RECEIPT.NOT.FOUND') {
@@ -340,4 +349,4 @@ export default class SalesReceiptsController extends BaseController{
} }
next(error); next(error);
} }
}; }

View File

@@ -417,6 +417,8 @@ export default class JournalCommands {
referenceId: saleReceipt.id, referenceId: saleReceipt.id,
date: saleReceipt.receiptDate, date: saleReceipt.receiptDate,
userId: saleReceipt.userId, userId: saleReceipt.userId,
transactionNumber: saleReceipt.receiptNumber,
referenceNumber: saleReceipt.referenceNo,
}; };
// XXX Debit - Deposit account. // XXX Debit - Deposit account.
const depositEntry = new JournalEntry({ const depositEntry = new JournalEntry({

View File

@@ -181,19 +181,16 @@ export default class SalesReceiptService {
tenantId, tenantId,
saleReceiptDTO.depositAccountId saleReceiptDTO.depositAccountId
); );
// Validate items IDs existance on the storage. // Validate items IDs existance on the storage.
await this.itemsEntriesService.validateItemsIdsExistance( await this.itemsEntriesService.validateItemsIdsExistance(
tenantId, tenantId,
saleReceiptDTO.entries saleReceiptDTO.entries
); );
// Validate the sellable items. // Validate the sellable items.
await this.itemsEntriesService.validateNonSellableEntriesItems( await this.itemsEntriesService.validateNonSellableEntriesItems(
tenantId, tenantId,
saleReceiptDTO.entries saleReceiptDTO.entries
); );
// Validate sale receipt number uniuqiness. // Validate sale receipt number uniuqiness.
if (saleReceiptDTO.receiptNumber) { if (saleReceiptDTO.receiptNumber) {
await this.validateReceiptNumberUnique( await this.validateReceiptNumberUnique(
@@ -460,7 +457,7 @@ export default class SalesReceiptService {
saleReceipt: ISaleReceipt, saleReceipt: ISaleReceipt,
override?: boolean override?: boolean
): Promise<void> { ): Promise<void> {
await this.inventoryService.recordInventoryTransactionsFromItemsEntries( return this.inventoryService.recordInventoryTransactionsFromItemsEntries(
tenantId, tenantId,
saleReceipt.id, saleReceipt.id,
'SaleReceipt', 'SaleReceipt',
@@ -468,15 +465,6 @@ export default class SalesReceiptService {
'OUT', 'OUT',
override, override,
); );
// Triggers `onInventoryTransactionsCreated` event.
this.eventDispatcher.dispatch(
events.saleReceipt.onInventoryTransactionsCreated,
{
tenantId,
saleReceipt,
saleReceiptId: saleReceipt.id,
}
);
} }
/** /**