Compare commits

..

No commits in common. "b08325a53c6ea06a46fef2a69374317a60fb6caa" and "e401a1bf4cdcc2f0c21e99aaae2f4bb191861b0e" have entirely different histories.

34 changed files with 137 additions and 281 deletions

7
env/env.development vendored
View File

@ -24,11 +24,8 @@ CRON_EVERY_HOUR="0 * * * *"
EMAIL_HOST=smtp.gmail.com
EMAIL_POST=465
EMAIL_USER=weplayground.app@gmail.com
EMAIL_TOKEN=sonvvwiukhsevtmv
// nama email yang akan muncul ke user sebagai pengirim
EMAIL_SENDER=no-reply@eigen.co.id
EMAIL_USER=developer@eigen.co.id
EMAIL_TOKEN=bitqkbkzjzfywxqx
MIDTRANS_URL=https://app.sandbox.midtrans.com
MIDTRANS_PRODUCTION=false

View File

@ -145,6 +145,7 @@ export const PrivilegePOSConstant = [
actions: [
PrivilegeAction.VIEW,
PrivilegeAction.CREATE,
PrivilegeAction.DELETE,
PrivilegeAction.EDIT,
PrivilegeAction.CANCEL,
],

View File

@ -1,17 +0,0 @@
import { MigrationInterface, QueryRunner } from 'typeorm';
export class UpdateTypeColumnItemTable1722587128195
implements MigrationInterface
{
name = 'UpdateTypeColumnItemTable1722587128195';
public async up(queryRunner: QueryRunner): Promise<void> {
await queryRunner.query(`ALTER TABLE "items" DROP COLUMN "sales_margin"`);
await queryRunner.query(`ALTER TABLE "items" ADD "sales_margin" numeric`);
}
public async down(queryRunner: QueryRunner): Promise<void> {
await queryRunner.query(`ALTER TABLE "items" DROP COLUMN "sales_margin"`);
await queryRunner.query(`ALTER TABLE "items" ADD "sales_margin" integer`);
}
}

View File

@ -1,23 +0,0 @@
import { MigrationInterface, QueryRunner } from 'typeorm';
export class UpdateTableTransaction1722595038215 implements MigrationInterface {
name = 'UpdateTableTransaction1722595038215';
public async up(queryRunner: QueryRunner): Promise<void> {
await queryRunner.query(
`CREATE TYPE "public"."transactions_payment_type_counter_enum" AS ENUM('midtrans', 'bank transfer', 'qris', 'counter', 'cash', 'credit card', 'debit', 'e-money')`,
);
await queryRunner.query(
`ALTER TABLE "transactions" ADD "payment_type_counter" "public"."transactions_payment_type_counter_enum"`,
);
}
public async down(queryRunner: QueryRunner): Promise<void> {
await queryRunner.query(
`ALTER TABLE "transactions" DROP COLUMN "payment_type_counter"`,
);
await queryRunner.query(
`DROP TYPE "public"."transactions_payment_type_counter_enum"`,
);
}
}

View File

@ -38,11 +38,8 @@ export class BookingHandler
const old_data = event.data.old;
const data = event.data.data;
if (
data.payment_type == TransactionPaymentType.COUNTER ||
([STATUS.ACTIVE, STATUS.SETTLED].includes(data.status) &&
data.payment_type != TransactionPaymentType.COUNTER)
) {
if (data.payment_type != TransactionPaymentType.COUNTER) return;
const booking = await this.bookingService.getOneByOptions({
where: {
id: data.id,
@ -53,9 +50,8 @@ export class BookingHandler
mappingTransaction(booking);
if (
(old_data?.status != data.status ||
data.payment_type != TransactionPaymentType.COUNTER) &&
[STATUS.PENDING, STATUS.ACTIVE, STATUS.SETTLED].includes(data.status)
old_data?.status != data.status &&
[STATUS.PENDING, STATUS.ACTIVE].includes(data.status)
) {
await this.couchService.createDoc(
{
@ -75,4 +71,3 @@ export class BookingHandler
}
}
}
}

View File

@ -61,12 +61,8 @@ export async function CreateEventCalendarHelper(
function mappingData(transaction) {
return {
summary: transaction.customer_name ?? transaction.invoice_code,
description: `<b>Booking for invoice ${
transaction.invoice_code
}</b><p>List Items :</p><ul>${transaction.items.map(
(item) => `<li>${item.item_name}</li>`,
)}</ul>`,
summary: transaction.invoice_code,
description: `Booking for invoice ${transaction.invoice_code}`,
start: {
dateTime: new Date(transaction.booking_date).toISOString(),
timeZone: 'Asia/Jakarta',

View File

@ -20,7 +20,7 @@ export async function sendEmail(receivers, subject) {
if (receiver.payment_type == TransactionPaymentType.MIDTRANS)
templateName = 'payment-confirmation-midtrans';
let templatePath = path.join(
let templatePath = path.resolve(
__dirname,
`../email-template/${ templateName }.html`,
);
@ -31,7 +31,7 @@ export async function sendEmail(receivers, subject) {
const htmlToSend = template(receiver);
const emailContext = {
from: process.env.EMAIL_SENDER ?? 'no-reply@weplayground.app',
from: 'no-reply@eigen.co.id',
to: receiver.email,
subject: subject,
html: htmlToSend,
@ -48,7 +48,7 @@ export async function sendEmail(receivers, subject) {
}
});
} catch (error) {
console.log(error, `Error occurs on send to ${receiver.email}`);
console.log(error, `Error occurs on send to ${ receiver.email }`)
}
}
}

View File

@ -1,57 +0,0 @@
import { Controller, Get, Injectable } from '@nestjs/common';
import { ApiTags } from '@nestjs/swagger';
import { Public } from 'src/core/guards';
import * as path from 'path';
import * as fs from 'fs';
@ApiTags(`email templates`)
@Controller('v1/email-templates')
@Public()
@Injectable()
export class MailTemplateController {
constructor() {}
getTemplate(templateName) {
const templatePath = path.join(
__dirname,
'../../../../../',
`src/modules/configuration/mail/domain/email-template/${templateName}.html`,
);
return fs.readFileSync(templatePath, 'utf8');
}
@Get('date-change')
async getDateChange() {
return this.getTemplate('change-date');
}
@Get('invoice')
async getBookingInvoice() {
return this.getTemplate('invoice');
}
@Get('payment-confirmation-bank')
async getPaymentConfirmation() {
return this.getTemplate('payment-confirmation-bank');
}
@Get('payment-confirmation-midtrans')
async getPaymentConfirmationMidtrans() {
return this.getTemplate('payment-confirmation-midtrans');
}
@Get('invoice-expired')
async getInvoiceExpired() {
return this.getTemplate('invoice-expired');
}
@Get('refund-confirmation')
async getRefundConfirmation() {
return this.getTemplate('refund-confirmation');
}
@Get('refund-request')
async getRefundRequest() {
return this.getTemplate('refunr-request');
}
}

View File

@ -8,7 +8,6 @@ import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
import { TransactionModel } from 'src/modules/transaction/transaction/data/models/transaction.model';
import { TransactionDataService } from 'src/modules/transaction/transaction/data/services/transaction-data.service';
import { PaymentTransactionHandler } from './domain/handlers/payment-transaction.handler';
import { MailTemplateController } from './infrastructure/mail.controller';
@Module({
imports: [
@ -19,7 +18,7 @@ import { MailTemplateController } from './infrastructure/mail.controller';
),
CqrsModule,
],
controllers: [MailTemplateController],
controllers: [],
providers: [
PaymentTransactionHandler,
PaymentMethodDataService,

View File

@ -18,20 +18,7 @@ export class MidtransController {
@Get(':id/status')
async getStatus(@Param('id') id: string) {
try {
const data = await this.dataService.getStatus(id);
this.eventBus.publishAll([
new MidtransCallbackEvent({
id: id,
data: data,
}),
]);
return 'Berhasil update status transaksi';
} catch (error) {
console.log(error.message);
throw new Error('Gagal update status transaksi');
}
return await this.dataService.getStatus(id);
}
@Post('callback')

View File

@ -32,10 +32,7 @@ export class SeasonPeriodHolidayHandler
const rate = new ItemRateModel();
rate.item_id = event.data.id;
rate.season_period_id = season.id;
rate.price =
Number(event.data.data.total_price) != 0
? event.data.data.total_price
: event.data.data.base_price;
rate.price = event.data.data.total_price ?? event.data.data.base_price;
rates.push(rate);
}

View File

@ -38,7 +38,7 @@ export class ItemModel
@Column('bigint', { name: 'hpp', nullable: true })
hpp: number;
@Column('decimal', { name: 'sales_margin', nullable: true })
@Column('int', { name: 'sales_margin', nullable: true })
sales_margin: number;
@Column('bigint', { name: 'total_price', nullable: true })

View File

@ -36,12 +36,7 @@ export class ActiveItemManager extends BaseUpdateStatusManager<ItemEntity> {
{
relation: 'tenant',
singleQuery: ['status', '!=', STATUS.ACTIVE],
message: `Gagal! tenant tidak aktif`,
},
{
relation: 'bundling_items',
singleQuery: ['status', '!=', STATUS.ACTIVE],
message: `Gagal! Terdapat item yang belum aktif`,
message: `Gagal! Belum ada item yang aktif`,
},
];
}

View File

@ -7,7 +7,11 @@ import {
import { ItemModel } from '../../../data/models/item.model';
import { ItemChangeStatusEvent } from '../../entities/event/item-change-status.event';
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
import { Injectable } from '@nestjs/common';
import {
HttpStatus,
Injectable,
UnprocessableEntityException,
} from '@nestjs/common';
import { STATUS } from 'src/core/strings/constants/base.constants';
@Injectable()
@ -29,12 +33,7 @@ export class BatchActiveItemManager extends BaseBatchUpdateStatusManager<ItemEnt
{
relation: 'tenant',
singleQuery: ['status', '!=', STATUS.ACTIVE],
message: `Gagal! tenant tidak aktif`,
},
{
relation: 'bundling_items',
singleQuery: ['status', '!=', STATUS.ACTIVE],
message: `Gagal! Terdapat item yang belum aktif`,
message: `Gagal! Belum ada item yang aktif`,
},
];
}

View File

@ -29,12 +29,7 @@ export class BatchConfirmItemManager extends BaseBatchUpdateStatusManager<ItemEn
{
relation: 'tenant',
singleQuery: ['status', '!=', STATUS.ACTIVE],
message: `Gagal! tenant tidak aktif`,
},
{
relation: 'bundling_items',
singleQuery: ['status', '!=', STATUS.ACTIVE],
message: `Gagal! Terdapat item yang belum aktif`,
message: `Gagal! Belum ada item yang aktif`,
},
];
}

View File

@ -32,12 +32,7 @@ export class ConfirmItemManager extends BaseUpdateStatusManager<ItemEntity> {
{
relation: 'tenant',
singleQuery: ['status', '!=', STATUS.ACTIVE],
message: `Gagal! tenant tidak aktif`,
},
{
relation: 'bundling_items',
singleQuery: ['status', '!=', STATUS.ACTIVE],
message: `Gagal! Terdapat item yang belum aktif`,
message: `Gagal! Belum ada item yang aktif`,
},
];
}

View File

@ -1,11 +1,8 @@
import { HttpStatus, UnprocessableEntityException } from '@nestjs/common';
import { STATUS } from 'src/core/strings/constants/base.constants';
import { In } from 'typeorm';
export async function validateRelation(dataService, id) {
const haveRelation = await dataService.getOneByOptions({
where: {
status: In([STATUS.ACTIVE]),
bundling_items: {
id: id,
},

View File

@ -36,7 +36,6 @@ export class DetailReconciliationManager extends BaseDetailManager<TransactionEn
`${this.tableName}.reconciliation_mdr`,
`${this.tableName}.payment_type`,
`${this.tableName}.payment_type_counter`,
`${this.tableName}.payment_type_method_id`,
`${this.tableName}.payment_type_method_name`,
`${this.tableName}.payment_type_method_number`,

View File

@ -51,7 +51,6 @@ export class IndexReconciliationManager extends BaseIndexManager<TransactionEnti
`${this.tableName}.invoice_code`,
`${this.tableName}.booking_date`,
`${this.tableName}.payment_type`,
`${this.tableName}.payment_type_counter`,
`${this.tableName}.payment_type_method_id`,
`${this.tableName}.payment_type_method_name`,
`${this.tableName}.payment_type_method_number`,

View File

@ -35,24 +35,27 @@ export class RecapReconciliationManager extends BaseCustomManager<TransactionEnt
const transactions = await this.dataService.getManyByOptions({
where: {
is_recap_transaction: false,
paymnet_type: TransactionType.COUNTER,
type: TransactionType.COUNTER,
status: STATUS.SETTLED,
created_at: Between(this.startOfDay, this.endOfDay),
},
});
const payCounserTransactions = await this.dataService.getManyByOptions({
where: {
is_recap_transaction: false,
payment_code: ILike('%SLS%'),
status: STATUS.SETTLED,
created_at: Between(this.startOfDay, this.endOfDay),
},
});
transactions.push(...payCounserTransactions);
for (const transaction of transactions) {
const {
creator_counter_no,
payment_type_counter,
payment_type_method_id,
} = transaction;
const { creator_counter_no, payment_type, payment_type_method_id } =
transaction;
const group_by =
creator_counter_no +
'-' +
payment_type_counter +
'-' +
payment_type_method_id;
creator_counter_no + '-' + payment_type + '-' + payment_type_method_id;
if (!this.recapTransactions[group_by]) {
this.recapTransactions[group_by] = [];
}
@ -66,20 +69,17 @@ export class RecapReconciliationManager extends BaseCustomManager<TransactionEnt
const total_recap = Object.keys(this.recapTransactions);
for (const recap of total_recap) {
const first_transaction = this.recapTransactions[recap][0];
const {
creator_counter_no,
payment_type_counter,
payment_type_method_id,
} = first_transaction;
const { creator_counter_no, payment_type, payment_type_method_id } =
first_transaction;
let query = {
is_recap_transaction: true,
created_at: Between(this.startOfDay, this.endOfDay),
creator_counter_no: creator_counter_no,
payment_type: payment_type_counter,
payment_type: payment_type,
};
if (payment_type_counter != 'cash')
if (payment_type != 'cash')
query['payment_type_method_id'] = payment_type_method_id ?? EMPTY_UUID;
const exist = await this.dataService.getOneByOptions({
@ -110,8 +110,7 @@ export class RecapReconciliationManager extends BaseCustomManager<TransactionEnt
booking_date: new Date(),
payment_date: new Date(),
creator_counter_no: first_transaction.creator_counter_no,
payment_type: first_transaction.payment_type_counter,
payment_type_counter: first_transaction.payment_type_counter,
payment_type: first_transaction.payment_type,
payment_type_method_id: first_transaction.payment_type_method_id,
payment_type_method_number:
first_transaction.payment_type_method_number,

View File

@ -12,10 +12,25 @@ import {
columnUniques,
validateRelations,
} from 'src/core/strings/constants/interface.constants';
import { STATUS } from 'src/core/strings/constants/base.constants';
@Injectable()
export class UpdateRefundManager extends BaseUpdateManager<RefundEntity> {
async validateProcess(): Promise<void> {
const transaction = await this.dataServiceFirstOpt.getOneByOptions({
where: {
id: this.data.transaction.id,
status: STATUS.SETTLED,
},
});
if (!transaction) {
throw new UnprocessableEntityException({
statusCode: HttpStatus.UNPROCESSABLE_ENTITY,
message: `Gagal! hanya pemesanan dengan status ${STATUS.SETTLED} yang dapat dikembalikan`,
error: 'Unprocessable Entity',
});
}
return;
}

View File

@ -107,13 +107,6 @@ export class TransactionModel
})
payment_type: TransactionPaymentType;
@Column('enum', {
name: 'payment_type_counter',
enum: TransactionPaymentType,
nullable: true,
})
payment_type_counter: TransactionPaymentType;
@Column('varchar', { name: 'payment_code', nullable: true })
payment_code: string;

View File

@ -41,7 +41,6 @@ export interface TransactionEntity extends BaseStatusEntity {
// payment data
payment_type: TransactionPaymentType;
payment_type_counter: TransactionPaymentType;
payment_type_method_id: string;
payment_type_method_name: string;
payment_type_method_number: string;

View File

@ -37,7 +37,8 @@ export class SettledTransactionHandler
relations: ['items'],
});
if (settled || oldSettled) {
if (!settled || !oldSettled) return;
const queryRunner = this.dataService
.getRepository()
.manager.connection.createQueryRunner();
@ -68,7 +69,6 @@ export class SettledTransactionHandler
data.payment_total_net_profit ?? 0,
);
console.log(data, 'dsa');
const google_calendar = await CreateEventCalendarHelper(data);
Object.assign(data, {
@ -80,7 +80,6 @@ export class SettledTransactionHandler
calendar_link: google_calendar?.htmlLink,
});
} else if (oldSettled) {
console.log(data, 'data oldSettled');
const google_calendar = await CreateEventCalendarHelper(data);
Object.assign(data, {
@ -92,4 +91,3 @@ export class SettledTransactionHandler
await this.dataService.create(queryRunner, TransactionModel, data);
}
}
}

View File

@ -11,7 +11,7 @@ import { TransactionChangeStatusEvent } from '../../entities/event/transaction-c
@Injectable()
export class ActiveTransactionManager extends BaseUpdateStatusManager<TransactionEntity> {
getResult(): string {
return `Success ${this.dataStatus} data ${this.result.invoice_code}`;
return `Success active data ${this.result.invoice_code}`;
}
async validateProcess(): Promise<void> {

View File

@ -16,11 +16,11 @@ import { STATUS } from 'src/core/strings/constants/base.constants';
@Injectable()
export class CancelTransactionManager extends BaseUpdateStatusManager<TransactionEntity> {
getResult(): string {
return `Success ${this.dataStatus} data ${this.result.invoice_code}`;
return `Success active data ${this.result.invoice_code}`;
}
async validateProcess(): Promise<void> {
if (![STATUS.EXPIRED, STATUS.PENDING].includes(this.oldData.status)) {
if (![STATUS.EXPIRED, STATUS.PENDING].includes(this.data.status)) {
throw new UnprocessableEntityException({
statusCode: HttpStatus.UNPROCESSABLE_ENTITY,
message: `Gagal! hanya tranksaksi dengan status ${STATUS.PENDING} dan ${STATUS.EXPIRED} yang dapat di${this.dataStatus}`,

View File

@ -67,7 +67,6 @@ export class DetailTransactionManager extends BaseDetailManager<TransactionEntit
`${this.tableName}.discount_value`,
`${this.tableName}.payment_type`,
`${this.tableName}.payment_type_counter`,
`${this.tableName}.payment_date`,
`${this.tableName}.payment_total_pay`,
`${this.tableName}.payment_type_method_id`,

View File

@ -98,7 +98,6 @@ export function mappingRevertTransaction(data, type) {
});
} else {
Object.assign(data, {
type: type,
creator_id: data.pos_admin?.id,
creator_name: data.pos_admin?.name,
invoice_code: data.code,
@ -108,11 +107,11 @@ export function mappingRevertTransaction(data, type) {
Object.assign(data, {
id: data.booking_id ?? data._id,
creator_counter_no: Number(data.pos_number),
status: STATUS.SETTLED,
settlement_date: new Date(data.created_at),
payment_date: new Date(data.created_at),
invoice_date: new Date(data.created_at),
payment_type: TransactionPaymentType.COUNTER,
payment_type_counter:
payment_type:
data.payment_type == 'cc'
? TransactionPaymentType.CC
: data.payment_type,
@ -123,12 +122,13 @@ export function mappingRevertTransaction(data, type) {
discount_percentage: data.discount_code?.discount,
});
} else {
Object.assign(data, {
type: type,
});
// Object.assign(data, {
// payment_type:
// })
}
Object.assign(data, {
type: type,
payment_total_net_profit: data.payment_total,
customer_category_id: data.customer_category?.id ?? null,
customer_category_name: data.customer_category?.name ?? null,

View File

@ -75,7 +75,6 @@ export class IndexTransactionManager extends BaseIndexManager<TransactionEntity>
`${this.tableName}.payment_code`,
`${this.tableName}.payment_card_information`,
`${this.tableName}.payment_type`,
`${this.tableName}.payment_type_counter`,
`${this.tableName}.payment_date`,
`${this.tableName}.payment_total_pay`,
`${this.tableName}.payment_type_method_id`,