feat(SPG-425) REST API CUD Data Gate

pull/28/head
Aswin Ashar Abdullah 2024-07-15 14:28:25 +07:00
parent 688be5828d
commit 0d2e49f93a
31 changed files with 911 additions and 1 deletions

View File

@ -29,7 +29,7 @@ module.exports = function (plop) {
name: 'location', name: 'location',
message: 'Location: ', message: 'Location: ',
choices: function () { choices: function () {
return ['item related', 'user related', 'season related', 'transaction']; return ['item related', 'user related', 'season related', 'transaction', 'web information'];
}, },
}, },
], ],

View File

@ -58,6 +58,8 @@ import { MidtransModule } from './modules/configuration/midtrans/midtrans.module
import { RefundModule } from './modules/transaction/refund/refund.module'; import { RefundModule } from './modules/transaction/refund/refund.module';
import { RefundModel } from './modules/transaction/refund/data/models/refund.model'; import { RefundModel } from './modules/transaction/refund/data/models/refund.model';
import { RefundItemModel } from './modules/transaction/refund/data/models/refund-item.model'; import { RefundItemModel } from './modules/transaction/refund/data/models/refund-item.model';
import { GateModule } from './modules/web-information/gate/gate.module';
import { GateModel } from './modules/web-information/gate/data/models/gate.model';
@Module({ @Module({
imports: [ imports: [
@ -76,6 +78,7 @@ import { RefundItemModel } from './modules/transaction/refund/data/models/refund
entities: [ entities: [
...UserPrivilegeModels, ...UserPrivilegeModels,
ErrorLogModel, ErrorLogModel,
GateModel,
ItemModel, ItemModel,
ItemCategoryModel, ItemCategoryModel,
ItemRateModel, ItemRateModel,
@ -135,6 +138,9 @@ import { RefundItemModel } from './modules/transaction/refund/data/models/refund
SeasonTypeModule, SeasonTypeModule,
SeasonPeriodModule, SeasonPeriodModule,
// web information
GateModule,
// report // report
ReportModule, ReportModule,
ReportBookmarkModule, ReportBookmarkModule,

View File

@ -48,3 +48,5 @@ export const BLANK_USER = {
role: null, role: null,
user_privilege_id: null, user_privilege_id: null,
}; };
export const EMPTY_UUID = '00000000-0000-0000-0000-000000000000';

View File

@ -1,4 +1,5 @@
export enum MODULE_NAME { export enum MODULE_NAME {
GATE = 'gates',
ITEM = 'items', ITEM = 'items',
ITEM_CATEGORY = 'item-categories', ITEM_CATEGORY = 'item-categories',
ITEM_RATE = 'item-rates', ITEM_RATE = 'item-rates',

View File

@ -3,6 +3,7 @@ export enum TABLE_NAME {
ITEM = 'items', ITEM = 'items',
ITEM_CATEGORY = 'item_categories', ITEM_CATEGORY = 'item_categories',
ITEM_RATE = 'item_rates', ITEM_RATE = 'item_rates',
GATE = 'gates',
LOG = 'logs', LOG = 'logs',
PAYMENT_METHOD = 'payment_methods', PAYMENT_METHOD = 'payment_methods',
PRICE_FORMULA = 'price_formulas', PRICE_FORMULA = 'price_formulas',

View File

@ -0,0 +1,29 @@
import { MigrationInterface, QueryRunner } from 'typeorm';
export class Gate1721024987609 implements MigrationInterface {
name = 'Gate1721024987609';
public async up(queryRunner: QueryRunner): Promise<void> {
await queryRunner.query(
`CREATE TYPE "public"."gates_status_enum" AS ENUM('active', 'cancel', 'confirmed', 'draft', 'expired', 'inactive', 'partial refund', 'pending', 'proses refund', 'refunded', 'rejected', 'settled', 'waiting')`,
);
await queryRunner.query(
`CREATE TYPE "public"."gates_type_enum" AS ENUM('gate masuk', 'gate keluar')`,
);
await queryRunner.query(
`CREATE TABLE "gates" ("id" uuid NOT NULL DEFAULT uuid_generate_v4(), "creator_id" character varying(36), "creator_name" character varying(125), "editor_id" character varying(36), "editor_name" character varying(125), "created_at" bigint NOT NULL, "updated_at" bigint NOT NULL, "status" "public"."gates_status_enum" NOT NULL DEFAULT 'draft', "type" "public"."gates_type_enum" NOT NULL DEFAULT 'gate masuk', "code" character varying, "note" text, "item_id" uuid, CONSTRAINT "PK_2dd58a77462dd2c5695ec4a7975" PRIMARY KEY ("id"))`,
);
await queryRunner.query(
`ALTER TABLE "gates" ADD CONSTRAINT "FK_29f020cd153bb079722bcbee830" FOREIGN KEY ("item_id") REFERENCES "items"("id") ON DELETE CASCADE ON UPDATE CASCADE`,
);
}
public async down(queryRunner: QueryRunner): Promise<void> {
await queryRunner.query(
`ALTER TABLE "gates" DROP CONSTRAINT "FK_29f020cd153bb079722bcbee830"`,
);
await queryRunner.query(`DROP TABLE "gates"`);
await queryRunner.query(`DROP TYPE "public"."gates_type_enum"`);
await queryRunner.query(`DROP TYPE "public"."gates_status_enum"`);
}
}

View File

@ -15,6 +15,7 @@ import { LimitType } from '../../constants';
import { ItemCategoryModel } from 'src/modules/item-related/item-category/data/models/item-category.model'; import { ItemCategoryModel } from 'src/modules/item-related/item-category/data/models/item-category.model';
import { UserModel } from 'src/modules/user-related/user/data/models/user.model'; import { UserModel } from 'src/modules/user-related/user/data/models/user.model';
import { ItemRateModel } from 'src/modules/item-related/item-rate/data/models/item-rate.model'; import { ItemRateModel } from 'src/modules/item-related/item-rate/data/models/item-rate.model';
import { GateModel } from 'src/modules/web-information/gate/data/models/gate.model';
@Entity(TABLE_NAME.ITEM) @Entity(TABLE_NAME.ITEM)
export class ItemModel export class ItemModel
@ -108,4 +109,11 @@ export class ItemModel
onUpdate: 'CASCADE', onUpdate: 'CASCADE',
}) })
item_rates: ItemRateModel[]; item_rates: ItemRateModel[];
// relasi ke gate
@OneToMany(() => GateModel, (model) => model.item, {
onDelete: 'CASCADE',
onUpdate: 'CASCADE',
})
gates: GateModel[];
} }

View File

@ -0,0 +1,4 @@
export enum GateType {
GATE_IN = 'gate masuk',
GATE_OUT = 'gate keluar',
}

View File

@ -0,0 +1,34 @@
import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
import { GateEntity } from '../../domain/entities/gate.entity';
import { Column, Entity, JoinColumn, ManyToOne } from 'typeorm';
import { BaseStatusModel } from 'src/core/modules/data/model/base-status.model';
import { GateType } from '../../constants';
import { ItemModel } from 'src/modules/item-related/item/data/models/item.model';
@Entity(TABLE_NAME.GATE)
export class GateModel
extends BaseStatusModel<GateEntity>
implements GateEntity
{
@Column('enum', {
name: 'type',
enum: GateType,
default: GateType.GATE_IN,
})
type: GateType;
@Column('varchar', { name: 'code', nullable: true })
code: string;
@Column('text', { name: 'note', nullable: true })
note: string;
@Column('varchar', { name: 'item_id', nullable: true })
item_id: string;
@ManyToOne(() => ItemModel, (model) => model.gates, {
onDelete: 'CASCADE',
onUpdate: 'CASCADE',
})
@JoinColumn({ name: 'item_id' })
item: ItemModel;
}

View File

@ -0,0 +1,17 @@
import { Injectable } from '@nestjs/common';
import { BaseDataService } from 'src/core/modules/data/service/base-data.service';
import { GateEntity } from '../../domain/entities/gate.entity';
import { InjectRepository } from '@nestjs/typeorm';
import { GateModel } from '../models/gate.model';
import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
import { Repository } from 'typeorm';
@Injectable()
export class GateDataService extends BaseDataService<GateEntity> {
constructor(
@InjectRepository(GateModel, CONNECTION_NAME.DEFAULT)
private repo: Repository<GateModel>,
) {
super(repo);
}
}

View File

@ -0,0 +1,5 @@
import { IEvent } from 'src/core/strings/constants/interface.constants';
export class GateChangeStatusEvent {
constructor(public readonly data: IEvent) {}
}

View File

@ -0,0 +1,5 @@
import { IEvent } from 'src/core/strings/constants/interface.constants';
export class GateCreatedEvent {
constructor(public readonly data: IEvent) {}
}

View File

@ -0,0 +1,5 @@
import { IEvent } from 'src/core/strings/constants/interface.constants';
export class GateDeletedEvent {
constructor(public readonly data: IEvent) {}
}

View File

@ -0,0 +1,5 @@
import { IEvent } from 'src/core/strings/constants/interface.constants';
export class GateUpdatedEvent {
constructor(public readonly data: IEvent) {}
}

View File

@ -0,0 +1,10 @@
import { BaseStatusEntity } from 'src/core/modules/domain/entities/base-status.entity';
import { GateType } from '../../constants';
export interface GateEntity extends BaseStatusEntity {
type: GateType;
code: string;
note: string;
item_id: string;
}

View File

@ -0,0 +1,106 @@
import { Injectable } from '@nestjs/common';
import { CreateGateManager } from './managers/create-gate.manager';
import { GateDataService } from '../../data/services/gate-data.service';
import { GateEntity } from '../entities/gate.entity';
import { DeleteGateManager } from './managers/delete-gate.manager';
import { UpdateGateManager } from './managers/update-gate.manager';
import { BaseDataTransactionOrchestrator } from 'src/core/modules/domain/usecase/orchestrators/base-data-transaction.orchestrator';
import { ActiveGateManager } from './managers/active-gate.manager';
import { InactiveGateManager } from './managers/inactive-gate.manager';
import { ConfirmGateManager } from './managers/confirm-gate.manager';
import { STATUS } from 'src/core/strings/constants/base.constants';
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
import { BatchConfirmGateManager } from './managers/batch-confirm-gate.manager';
import { BatchInactiveGateManager } from './managers/batch-inactive-gate.manager';
import { BatchActiveGateManager } from './managers/batch-active-gate.manager';
import { BatchDeleteGateManager } from './managers/batch-delete-gate.manager';
import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
@Injectable()
export class GateDataOrchestrator extends BaseDataTransactionOrchestrator<GateEntity> {
constructor(
private createManager: CreateGateManager,
private updateManager: UpdateGateManager,
private deleteManager: DeleteGateManager,
private activeManager: ActiveGateManager,
private confirmManager: ConfirmGateManager,
private inactiveManager: InactiveGateManager,
private batchDeleteManager: BatchDeleteGateManager,
private batchActiveManager: BatchActiveGateManager,
private batchConfirmManager: BatchConfirmGateManager,
private batchInactiveManager: BatchInactiveGateManager,
private serviceData: GateDataService,
) {
super();
}
async create(data): Promise<GateEntity> {
this.createManager.setData(data);
this.createManager.setService(this.serviceData, TABLE_NAME.GATE);
await this.createManager.execute();
return this.createManager.getResult();
}
async update(dataId, data): Promise<GateEntity> {
this.updateManager.setData(dataId, data);
this.updateManager.setService(this.serviceData, TABLE_NAME.GATE);
await this.updateManager.execute();
return this.updateManager.getResult();
}
async delete(dataId): Promise<string> {
this.deleteManager.setData(dataId);
this.deleteManager.setService(this.serviceData, TABLE_NAME.GATE);
await this.deleteManager.execute();
return this.deleteManager.getResult();
}
async batchDelete(dataIds: string[]): Promise<BatchResult> {
this.batchDeleteManager.setData(dataIds);
this.batchDeleteManager.setService(this.serviceData, TABLE_NAME.GATE);
await this.batchDeleteManager.execute();
return this.batchDeleteManager.getResult();
}
async active(dataId): Promise<string> {
this.activeManager.setData(dataId, STATUS.ACTIVE);
this.activeManager.setService(this.serviceData, TABLE_NAME.GATE);
await this.activeManager.execute();
return this.activeManager.getResult();
}
async batchActive(dataIds: string[]): Promise<BatchResult> {
this.batchActiveManager.setData(dataIds, STATUS.ACTIVE);
this.batchActiveManager.setService(this.serviceData, TABLE_NAME.GATE);
await this.batchActiveManager.execute();
return this.batchActiveManager.getResult();
}
async confirm(dataId): Promise<string> {
this.confirmManager.setData(dataId, STATUS.ACTIVE);
this.confirmManager.setService(this.serviceData, TABLE_NAME.GATE);
await this.confirmManager.execute();
return this.confirmManager.getResult();
}
async batchConfirm(dataIds: string[]): Promise<BatchResult> {
this.batchConfirmManager.setData(dataIds, STATUS.ACTIVE);
this.batchConfirmManager.setService(this.serviceData, TABLE_NAME.GATE);
await this.batchConfirmManager.execute();
return this.batchConfirmManager.getResult();
}
async inactive(dataId): Promise<string> {
this.inactiveManager.setData(dataId, STATUS.INACTIVE);
this.inactiveManager.setService(this.serviceData, TABLE_NAME.GATE);
await this.inactiveManager.execute();
return this.inactiveManager.getResult();
}
async batchInactive(dataIds: string[]): Promise<BatchResult> {
this.batchInactiveManager.setData(dataIds, STATUS.INACTIVE);
this.batchInactiveManager.setService(this.serviceData, TABLE_NAME.GATE);
await this.batchInactiveManager.execute();
return this.batchInactiveManager.getResult();
}
}

View File

@ -0,0 +1,45 @@
import { Injectable } from '@nestjs/common';
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
import { GateEntity } from '../../entities/gate.entity';
import {
EventTopics,
validateRelations,
} from 'src/core/strings/constants/interface.constants';
import { GateModel } from '../../../data/models/gate.model';
import { GateChangeStatusEvent } from '../../entities/event/gate-change-status.event';
@Injectable()
export class ActiveGateManager extends BaseUpdateStatusManager<GateEntity> {
getResult(): string {
return `Success active data gate ${this.result.code}`;
}
async validateProcess(): Promise<void> {
return;
}
async beforeProcess(): Promise<void> {
return;
}
async afterProcess(): Promise<void> {
return;
}
get validateRelations(): validateRelations[] {
return [];
}
get entityTarget(): any {
return GateModel;
}
get eventTopics(): EventTopics[] {
return [
{
topic: GateChangeStatusEvent,
data: this.data,
},
];
}
}

View File

@ -0,0 +1,45 @@
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
import { GateEntity } from '../../entities/gate.entity';
import {
EventTopics,
validateRelations,
} from 'src/core/strings/constants/interface.constants';
import { GateModel } from '../../../data/models/gate.model';
import { GateChangeStatusEvent } from '../../entities/event/gate-change-status.event';
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
import { Injectable } from '@nestjs/common';
@Injectable()
export class BatchActiveGateManager extends BaseBatchUpdateStatusManager<GateEntity> {
validateData(data: GateEntity): Promise<void> {
return;
}
beforeProcess(): Promise<void> {
return;
}
afterProcess(): Promise<void> {
return;
}
get validateRelations(): validateRelations[] {
return [];
}
get entityTarget(): any {
return GateModel;
}
get eventTopics(): EventTopics[] {
return [
{
topic: GateChangeStatusEvent,
},
];
}
getResult(): BatchResult {
return this.result;
}
}

View File

@ -0,0 +1,45 @@
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
import { GateEntity } from '../../entities/gate.entity';
import {
EventTopics,
validateRelations,
} from 'src/core/strings/constants/interface.constants';
import { GateModel } from '../../../data/models/gate.model';
import { GateChangeStatusEvent } from '../../entities/event/gate-change-status.event';
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
import { Injectable } from '@nestjs/common';
@Injectable()
export class BatchConfirmGateManager extends BaseBatchUpdateStatusManager<GateEntity> {
validateData(data: GateEntity): Promise<void> {
return;
}
beforeProcess(): Promise<void> {
return;
}
afterProcess(): Promise<void> {
return;
}
get validateRelations(): validateRelations[] {
return [];
}
get entityTarget(): any {
return GateModel;
}
get eventTopics(): EventTopics[] {
return [
{
topic: GateChangeStatusEvent,
},
];
}
getResult(): BatchResult {
return this.result;
}
}

View File

@ -0,0 +1,45 @@
import { BaseBatchDeleteManager } from 'src/core/modules/domain/usecase/managers/base-batch-delete.manager';
import { GateEntity } from '../../entities/gate.entity';
import {
EventTopics,
validateRelations,
} from 'src/core/strings/constants/interface.constants';
import { GateModel } from '../../../data/models/gate.model';
import { GateDeletedEvent } from '../../entities/event/gate-deleted.event';
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
import { Injectable } from '@nestjs/common';
@Injectable()
export class BatchDeleteGateManager extends BaseBatchDeleteManager<GateEntity> {
async beforeProcess(): Promise<void> {
return;
}
async validateData(data: GateEntity): Promise<void> {
return;
}
async afterProcess(): Promise<void> {
return;
}
get validateRelations(): validateRelations[] {
return [];
}
get entityTarget(): any {
return GateModel;
}
get eventTopics(): EventTopics[] {
return [
{
topic: GateDeletedEvent,
},
];
}
getResult(): BatchResult {
return this.result;
}
}

View File

@ -0,0 +1,45 @@
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
import { GateEntity } from '../../entities/gate.entity';
import {
EventTopics,
validateRelations,
} from 'src/core/strings/constants/interface.constants';
import { GateModel } from '../../../data/models/gate.model';
import { GateChangeStatusEvent } from '../../entities/event/gate-change-status.event';
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
import { Injectable } from '@nestjs/common';
@Injectable()
export class BatchInactiveGateManager extends BaseBatchUpdateStatusManager<GateEntity> {
validateData(data: GateEntity): Promise<void> {
return;
}
beforeProcess(): Promise<void> {
return;
}
afterProcess(): Promise<void> {
return;
}
get validateRelations(): validateRelations[] {
return [];
}
get entityTarget(): any {
return GateModel;
}
get eventTopics(): EventTopics[] {
return [
{
topic: GateChangeStatusEvent,
},
];
}
getResult(): BatchResult {
return this.result;
}
}

View File

@ -0,0 +1,45 @@
import { Injectable } from '@nestjs/common';
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
import { GateEntity } from '../../entities/gate.entity';
import {
EventTopics,
validateRelations,
} from 'src/core/strings/constants/interface.constants';
import { GateModel } from '../../../data/models/gate.model';
import { GateChangeStatusEvent } from '../../entities/event/gate-change-status.event';
@Injectable()
export class ConfirmGateManager extends BaseUpdateStatusManager<GateEntity> {
getResult(): string {
return `Success active data gate ${this.result.code}`;
}
async validateProcess(): Promise<void> {
return;
}
async beforeProcess(): Promise<void> {
return;
}
async afterProcess(): Promise<void> {
return;
}
get validateRelations(): validateRelations[] {
return [];
}
get entityTarget(): any {
return GateModel;
}
get eventTopics(): EventTopics[] {
return [
{
topic: GateChangeStatusEvent,
data: this.data,
},
];
}
}

View File

@ -0,0 +1,48 @@
import {
HttpStatus,
Injectable,
UnprocessableEntityException,
} from '@nestjs/common';
import {
EventTopics,
columnUniques,
validateRelations,
} from 'src/core/strings/constants/interface.constants';
import { GateEntity } from '../../entities/gate.entity';
import { GateModel } from '../../../data/models/gate.model';
import { BaseCreateManager } from 'src/core/modules/domain/usecase/managers/base-create.manager';
import { GateCreatedEvent } from '../../entities/event/gate-created.event';
import { validateItemGate } from './helpers/validate-item-gate.helper';
@Injectable()
export class CreateGateManager extends BaseCreateManager<GateEntity> {
async beforeProcess(): Promise<void> {
await validateItemGate(this.dataService, this.data);
return;
}
async afterProcess(): Promise<void> {
return;
}
get validateRelations(): validateRelations[] {
return [];
}
get uniqueColumns(): columnUniques[] {
return [];
}
get eventTopics(): EventTopics[] {
return [
{
topic: GateCreatedEvent,
data: this.data,
},
];
}
get entityTarget(): any {
return GateModel;
}
}

View File

@ -0,0 +1,45 @@
import { Injectable } from '@nestjs/common';
import { BaseDeleteManager } from 'src/core/modules/domain/usecase/managers/base-delete.manager';
import { GateEntity } from '../../entities/gate.entity';
import {
EventTopics,
validateRelations,
} from 'src/core/strings/constants/interface.constants';
import { GateModel } from '../../../data/models/gate.model';
import { GateDeletedEvent } from '../../entities/event/gate-deleted.event';
@Injectable()
export class DeleteGateManager extends BaseDeleteManager<GateEntity> {
getResult(): string {
return `Success`;
}
async validateProcess(): Promise<void> {
return;
}
async beforeProcess(): Promise<void> {
return;
}
async afterProcess(): Promise<void> {
return;
}
get validateRelations(): validateRelations[] {
return [];
}
get entityTarget(): any {
return GateModel;
}
get eventTopics(): EventTopics[] {
return [
{
topic: GateDeletedEvent,
data: this.data,
},
];
}
}

View File

@ -0,0 +1,38 @@
import { HttpStatus, UnprocessableEntityException } from '@nestjs/common';
import { EMPTY_UUID } from 'src/core/strings/constants/base.constants';
import { In, Not } from 'typeorm';
export async function validateItemGate(dataService, data, id?) {
// validate same code
const existCode = await dataService.getOneByOptions({
where: {
code: data.code,
id: Not(In([id ?? EMPTY_UUID])),
},
});
if (existCode) {
throw new UnprocessableEntityException({
statusCode: HttpStatus.UNPROCESSABLE_ENTITY,
message: `Failed! Gate with code ${data.code} already exist`,
error: 'Unprocessable Entity',
});
}
// validate type item
const existType = await dataService.getOneByOptions({
where: {
item_id: data.item.id,
type: data.type,
id: Not(In([id ?? EMPTY_UUID])),
},
});
if (existType) {
throw new UnprocessableEntityException({
statusCode: HttpStatus.UNPROCESSABLE_ENTITY,
message: `Failed! Gate type ${data.type} with item ${data.item.name} already exist`,
error: 'Unprocessable Entity',
});
}
}

View File

@ -0,0 +1,45 @@
import { Injectable } from '@nestjs/common';
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
import { GateEntity } from '../../entities/gate.entity';
import {
EventTopics,
validateRelations,
} from 'src/core/strings/constants/interface.constants';
import { GateModel } from '../../../data/models/gate.model';
import { GateChangeStatusEvent } from '../../entities/event/gate-change-status.event';
@Injectable()
export class InactiveGateManager extends BaseUpdateStatusManager<GateEntity> {
getResult(): string {
return `Success inactive data gate ${this.result.code}`;
}
async validateProcess(): Promise<void> {
return;
}
async beforeProcess(): Promise<void> {
return;
}
async afterProcess(): Promise<void> {
return;
}
get validateRelations(): validateRelations[] {
return [];
}
get entityTarget(): any {
return GateModel;
}
get eventTopics(): EventTopics[] {
return [
{
topic: GateChangeStatusEvent,
data: this.data,
},
];
}
}

View File

@ -0,0 +1,48 @@
import { Injectable } from '@nestjs/common';
import { BaseUpdateManager } from 'src/core/modules/domain/usecase/managers/base-update.manager';
import { GateEntity } from '../../entities/gate.entity';
import { GateModel } from '../../../data/models/gate.model';
import { GateUpdatedEvent } from '../../entities/event/gate-updated.event';
import {
EventTopics,
columnUniques,
validateRelations,
} from 'src/core/strings/constants/interface.constants';
import { validateItemGate } from './helpers/validate-item-gate.helper';
@Injectable()
export class UpdateGateManager extends BaseUpdateManager<GateEntity> {
async validateProcess(): Promise<void> {
await validateItemGate(this.dataService, this.data, this.dataId);
return;
}
async beforeProcess(): Promise<void> {
return;
}
async afterProcess(): Promise<void> {
return;
}
get validateRelations(): validateRelations[] {
return [];
}
get uniqueColumns(): columnUniques[] {
return [];
}
get entityTarget(): any {
return GateModel;
}
get eventTopics(): EventTopics[] {
return [
{
topic: GateUpdatedEvent,
data: this.data,
},
];
}
}

View File

@ -0,0 +1,54 @@
import { Module } from '@nestjs/common';
import { ConfigModule } from '@nestjs/config';
import { TypeOrmModule } from '@nestjs/typeorm';
import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
import { GateDataService } from './data/services/gate-data.service';
import { GateReadService } from './data/services/gate-read.service';
import { GateReadController } from './infrastructure/gate-read.controller';
import { GateReadOrchestrator } from './domain/usecases/gate-read.orchestrator';
import { GateDataController } from './infrastructure/gate-data.controller';
import { GateDataOrchestrator } from './domain/usecases/gate-data.orchestrator';
import { CreateGateManager } from './domain/usecases/managers/create-gate.manager';
import { CqrsModule } from '@nestjs/cqrs';
import { IndexGateManager } from './domain/usecases/managers/index-gate.manager';
import { DeleteGateManager } from './domain/usecases/managers/delete-gate.manager';
import { UpdateGateManager } from './domain/usecases/managers/update-gate.manager';
import { ActiveGateManager } from './domain/usecases/managers/active-gate.manager';
import { ConfirmGateManager } from './domain/usecases/managers/confirm-gate.manager';
import { InactiveGateManager } from './domain/usecases/managers/inactive-gate.manager';
import { DetailGateManager } from './domain/usecases/managers/detail-gate.manager';
import { BatchDeleteGateManager } from './domain/usecases/managers/batch-delete-gate.manager';
import { BatchActiveGateManager } from './domain/usecases/managers/batch-active-gate.manager';
import { BatchConfirmGateManager } from './domain/usecases/managers/batch-confirm-gate.manager';
import { BatchInactiveGateManager } from './domain/usecases/managers/batch-inactive-gate.manager';
import { GateModel } from './data/models/gate.model';
@Module({
imports: [
ConfigModule.forRoot(),
TypeOrmModule.forFeature([GateModel], CONNECTION_NAME.DEFAULT),
CqrsModule,
],
controllers: [GateDataController, GateReadController],
providers: [
IndexGateManager,
DetailGateManager,
CreateGateManager,
DeleteGateManager,
UpdateGateManager,
ActiveGateManager,
ConfirmGateManager,
InactiveGateManager,
BatchDeleteGateManager,
BatchActiveGateManager,
BatchConfirmGateManager,
BatchInactiveGateManager,
GateDataService,
GateReadService,
GateDataOrchestrator,
GateReadOrchestrator,
],
})
export class GateModule {}

View File

@ -0,0 +1,46 @@
import { BaseStatusDto } from 'src/core/modules/infrastructure/dto/base-status.dto';
import { GateEntity } from '../../domain/entities/gate.entity';
import { GateType } from '../../constants';
import { ApiProperty } from '@nestjs/swagger';
import { string } from 'mathjs';
import { IsObject, IsString } from 'class-validator';
import { Exclude } from 'class-transformer';
import { ItemEntity } from 'src/modules/item-related/item/domain/entities/item.entity';
export class GateDto extends BaseStatusDto implements GateEntity {
@ApiProperty({
type: string,
required: true,
example: GateType.GATE_IN,
})
@IsString()
type: GateType;
@ApiProperty({
type: string,
required: true,
example: '41245',
})
code: string;
@ApiProperty({
type: string,
required: false,
example: '41245',
})
note: string;
@ApiProperty({
type: Object,
required: true,
example: {
id: 'uuid',
name: 'whana',
},
})
@IsObject()
item: ItemEntity;
@Exclude()
item_id: string;
}

View File

@ -0,0 +1,78 @@
import {
Body,
Controller,
Delete,
Param,
Patch,
Post,
Put,
} from '@nestjs/common';
import { GateDataOrchestrator } from '../domain/usecases/gate-data.orchestrator';
import { GateDto } from './dto/gate.dto';
import { MODULE_NAME } from 'src/core/strings/constants/module.constants';
import { ApiBearerAuth, ApiTags } from '@nestjs/swagger';
import { GateEntity } from '../domain/entities/gate.entity';
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
import { BatchIdsDto } from 'src/core/modules/infrastructure/dto/base-batch.dto';
import { Public } from 'src/core/guards';
@ApiTags(`${MODULE_NAME.GATE.split('-').join(' ')} - data`)
@Controller(`v1/${MODULE_NAME.GATE}`)
@Public(false)
@ApiBearerAuth('JWT')
export class GateDataController {
constructor(private orchestrator: GateDataOrchestrator) {}
@Post()
async create(@Body() data: GateDto): Promise<GateEntity> {
return await this.orchestrator.create(data);
}
@Put('/batch-delete')
async batchDeleted(@Body() body: BatchIdsDto): Promise<BatchResult> {
return await this.orchestrator.batchDelete(body.ids);
}
@Patch(':id/active')
async active(@Param('id') dataId: string): Promise<string> {
return await this.orchestrator.active(dataId);
}
@Put('/batch-active')
async batchActive(@Body() body: BatchIdsDto): Promise<BatchResult> {
return await this.orchestrator.batchActive(body.ids);
}
@Patch(':id/confirm')
async confirm(@Param('id') dataId: string): Promise<string> {
return await this.orchestrator.confirm(dataId);
}
@Put('/batch-confirm')
async batchConfirm(@Body() body: BatchIdsDto): Promise<BatchResult> {
return await this.orchestrator.batchConfirm(body.ids);
}
@Patch(':id/inactive')
async inactive(@Param('id') dataId: string): Promise<string> {
return await this.orchestrator.inactive(dataId);
}
@Put('/batch-inactive')
async batchInactive(@Body() body: BatchIdsDto): Promise<BatchResult> {
return await this.orchestrator.batchInactive(body.ids);
}
@Put(':id')
async update(
@Param('id') dataId: string,
@Body() data: GateDto,
): Promise<GateEntity> {
return await this.orchestrator.update(dataId, data);
}
@Delete(':id')
async delete(@Param('id') dataId: string): Promise<string> {
return await this.orchestrator.delete(dataId);
}
}