Compare commits
3 Commits
77a6afbbbc
...
efa245048a
Author | SHA1 | Date |
---|---|---|
|
efa245048a | |
|
2d0ccf67f2 | |
|
77cf19c06e |
|
@ -83,6 +83,14 @@ import { UserLoginModel } from './modules/user-related/user/data/models/user-log
|
||||||
import { LogUserLoginModel } from './modules/configuration/log/data/models/log-user-login.model';
|
import { LogUserLoginModel } from './modules/configuration/log/data/models/log-user-login.model';
|
||||||
import { AuthService } from './core/guards/domain/services/auth.service';
|
import { AuthService } from './core/guards/domain/services/auth.service';
|
||||||
import { ReportSummaryModule } from './modules/reports/report-summary/report-summary.module';
|
import { ReportSummaryModule } from './modules/reports/report-summary/report-summary.module';
|
||||||
|
import { QueueModule } from './modules/queue/queue.module';
|
||||||
|
import {
|
||||||
|
QueueOrderModel,
|
||||||
|
QueueTicketModel,
|
||||||
|
QueueItemModel,
|
||||||
|
} from './modules/queue/data/models/queue.model';
|
||||||
|
import { ItemQueueModule } from './modules/item-related/item-queue/item-queue.module';
|
||||||
|
import { ItemQueueModel } from './modules/item-related/item-queue/data/models/item-queue.model';
|
||||||
|
|
||||||
@Module({
|
@Module({
|
||||||
imports: [
|
imports: [
|
||||||
|
@ -107,6 +115,7 @@ import { ReportSummaryModule } from './modules/reports/report-summary/report-sum
|
||||||
ItemModel,
|
ItemModel,
|
||||||
ItemCategoryModel,
|
ItemCategoryModel,
|
||||||
ItemRateModel,
|
ItemRateModel,
|
||||||
|
ItemQueueModel,
|
||||||
LogModel,
|
LogModel,
|
||||||
LogUserLoginModel,
|
LogUserLoginModel,
|
||||||
NewsModel,
|
NewsModel,
|
||||||
|
@ -135,6 +144,11 @@ import { ReportSummaryModule } from './modules/reports/report-summary/report-sum
|
||||||
// report
|
// report
|
||||||
ReportBookmarkModel,
|
ReportBookmarkModel,
|
||||||
ExportReportHistoryModel,
|
ExportReportHistoryModel,
|
||||||
|
|
||||||
|
// Queue
|
||||||
|
QueueOrderModel,
|
||||||
|
QueueTicketModel,
|
||||||
|
QueueItemModel,
|
||||||
],
|
],
|
||||||
synchronize: false,
|
synchronize: false,
|
||||||
}),
|
}),
|
||||||
|
@ -160,6 +174,7 @@ import { ReportSummaryModule } from './modules/reports/report-summary/report-sum
|
||||||
ItemCategoryModule,
|
ItemCategoryModule,
|
||||||
ItemModule,
|
ItemModule,
|
||||||
ItemRateModule,
|
ItemRateModule,
|
||||||
|
ItemQueueModule,
|
||||||
|
|
||||||
// transaction
|
// transaction
|
||||||
PaymentMethodModule,
|
PaymentMethodModule,
|
||||||
|
@ -193,6 +208,8 @@ import { ReportSummaryModule } from './modules/reports/report-summary/report-sum
|
||||||
SupersetModule,
|
SupersetModule,
|
||||||
|
|
||||||
GateScanModule,
|
GateScanModule,
|
||||||
|
|
||||||
|
QueueModule,
|
||||||
],
|
],
|
||||||
controllers: [],
|
controllers: [],
|
||||||
providers: [
|
providers: [
|
||||||
|
|
|
@ -50,7 +50,7 @@ export abstract class BaseIndexManager<Entity> extends BaseReadManager {
|
||||||
|
|
||||||
// jika searching status terdapat dalam enum, maka dia mencari specific data
|
// jika searching status terdapat dalam enum, maka dia mencari specific data
|
||||||
// ? karena jika tidak, ketika dia search "active" maka "inactive" juga ikut
|
// ? karena jika tidak, ketika dia search "active" maka "inactive" juga ikut
|
||||||
return `'${STATUS[statusData.toUpperCase()]}'` ?? `'%${statusData}%'`;
|
return `'${STATUS[statusData.toUpperCase()]}'`;
|
||||||
});
|
});
|
||||||
|
|
||||||
const exist = specificFilter.find((item) => item.isStatus);
|
const exist = specificFilter.find((item) => item.isStatus);
|
||||||
|
|
|
@ -4,6 +4,7 @@ export enum MODULE_NAME {
|
||||||
GATE = 'gates',
|
GATE = 'gates',
|
||||||
ITEM = 'items',
|
ITEM = 'items',
|
||||||
ITEM_CATEGORY = 'item-categories',
|
ITEM_CATEGORY = 'item-categories',
|
||||||
|
ITEM_QUEUE = 'item-queues',
|
||||||
ITEM_RATE = 'item-rates',
|
ITEM_RATE = 'item-rates',
|
||||||
NEWS = 'news',
|
NEWS = 'news',
|
||||||
PAYMENT_METHOD = 'payment-methods',
|
PAYMENT_METHOD = 'payment-methods',
|
||||||
|
@ -25,4 +26,6 @@ export enum MODULE_NAME {
|
||||||
REPORT_BOOKMARK = 'report-bookmark',
|
REPORT_BOOKMARK = 'report-bookmark',
|
||||||
REPORT_EXPORT = 'report-export',
|
REPORT_EXPORT = 'report-export',
|
||||||
REPORT_SUMMARY = 'report-summary',
|
REPORT_SUMMARY = 'report-summary',
|
||||||
|
|
||||||
|
QUEUE = 'queue',
|
||||||
}
|
}
|
||||||
|
|
|
@ -4,6 +4,7 @@ export enum TABLE_NAME {
|
||||||
FAQ = 'faqs',
|
FAQ = 'faqs',
|
||||||
ITEM = 'items',
|
ITEM = 'items',
|
||||||
ITEM_CATEGORY = 'item_categories',
|
ITEM_CATEGORY = 'item_categories',
|
||||||
|
ITEM_QUEUE = 'item_queues',
|
||||||
ITEM_RATE = 'item_rates',
|
ITEM_RATE = 'item_rates',
|
||||||
GATE = 'gates',
|
GATE = 'gates',
|
||||||
LOG = 'logs',
|
LOG = 'logs',
|
||||||
|
@ -35,4 +36,8 @@ export enum TABLE_NAME {
|
||||||
|
|
||||||
REPORT_BOOKMARK = 'report_bookmark',
|
REPORT_BOOKMARK = 'report_bookmark',
|
||||||
EXPORT_REPORT_HISTORY = 'export_report_history',
|
EXPORT_REPORT_HISTORY = 'export_report_history',
|
||||||
|
|
||||||
|
QUEUE_ORDER = 'queue_orders',
|
||||||
|
QUEUE_TICKET = 'queue_tickets',
|
||||||
|
QUEUE_ITEM = 'queue_items',
|
||||||
}
|
}
|
||||||
|
|
|
@ -0,0 +1,43 @@
|
||||||
|
import { MigrationInterface, QueryRunner } from 'typeorm';
|
||||||
|
|
||||||
|
export class QueueTable1729151429165 implements MigrationInterface {
|
||||||
|
name = 'QueueTable1729151429165';
|
||||||
|
|
||||||
|
public async up(queryRunner: QueryRunner): Promise<void> {
|
||||||
|
await queryRunner.query(
|
||||||
|
`CREATE TABLE "queue_orders" ("id" uuid NOT NULL DEFAULT uuid_generate_v4(), "code" character varying NOT NULL, "customer" character varying, "phone" character varying, "date" bigint NOT NULL, CONSTRAINT "PK_b139e4cc9ca3e709c152f820d2e" PRIMARY KEY ("id"))`,
|
||||||
|
);
|
||||||
|
await queryRunner.query(
|
||||||
|
`CREATE TABLE "queue_tickets" ("id" uuid NOT NULL DEFAULT uuid_generate_v4(), "code" character varying NOT NULL, "customer" character varying, "phone" character varying, "date" bigint NOT NULL, "order_id" uuid, CONSTRAINT "PK_1b903aa90bcc04136caa6540c55" PRIMARY KEY ("id"))`,
|
||||||
|
);
|
||||||
|
await queryRunner.query(
|
||||||
|
`CREATE TABLE "queue_items" ("id" uuid NOT NULL DEFAULT uuid_generate_v4(), "qty" integer NOT NULL, "ticket_id" uuid, "item_id" uuid, CONSTRAINT "PK_2245e11ac3517494bacfe932773" PRIMARY KEY ("id"))`,
|
||||||
|
);
|
||||||
|
|
||||||
|
await queryRunner.query(
|
||||||
|
`ALTER TABLE "queue_tickets" ADD CONSTRAINT "FK_0e9823b8b7ca9523b3be73878e5" FOREIGN KEY ("order_id") REFERENCES "queue_orders"("id") ON DELETE CASCADE ON UPDATE CASCADE`,
|
||||||
|
);
|
||||||
|
await queryRunner.query(
|
||||||
|
`ALTER TABLE "queue_items" ADD CONSTRAINT "FK_25352739034765f6917757df74b" FOREIGN KEY ("ticket_id") REFERENCES "queue_tickets"("id") ON DELETE CASCADE ON UPDATE CASCADE`,
|
||||||
|
);
|
||||||
|
await queryRunner.query(
|
||||||
|
`ALTER TABLE "queue_items" ADD CONSTRAINT "FK_ab15c053aeb4f739ebf533b61cd" FOREIGN KEY ("item_id") REFERENCES "items"("id") ON DELETE NO ACTION ON UPDATE NO ACTION`,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
public async down(queryRunner: QueryRunner): Promise<void> {
|
||||||
|
await queryRunner.query(
|
||||||
|
`ALTER TABLE "queue_items" DROP CONSTRAINT "FK_ab15c053aeb4f739ebf533b61cd"`,
|
||||||
|
);
|
||||||
|
await queryRunner.query(
|
||||||
|
`ALTER TABLE "queue_items" DROP CONSTRAINT "FK_25352739034765f6917757df74b"`,
|
||||||
|
);
|
||||||
|
await queryRunner.query(
|
||||||
|
`ALTER TABLE "queue_tickets" DROP CONSTRAINT "FK_0e9823b8b7ca9523b3be73878e5"`,
|
||||||
|
);
|
||||||
|
|
||||||
|
await queryRunner.query(`DROP TABLE "queue_items"`);
|
||||||
|
await queryRunner.query(`DROP TABLE "queue_tickets"`);
|
||||||
|
await queryRunner.query(`DROP TABLE "queue_orders"`);
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,18 @@
|
||||||
|
import { MigrationInterface, QueryRunner } from 'typeorm';
|
||||||
|
|
||||||
|
export class VideoUrlToJson1729248576381 implements MigrationInterface {
|
||||||
|
name = 'VideoUrlToJson1729248576381';
|
||||||
|
|
||||||
|
public async up(queryRunner: QueryRunner): Promise<void> {
|
||||||
|
await queryRunner.query(`ALTER TABLE "items" DROP COLUMN "video_url"`);
|
||||||
|
await queryRunner.query(`ALTER TABLE "items" ADD "video_url" json`);
|
||||||
|
}
|
||||||
|
|
||||||
|
public async down(queryRunner: QueryRunner): Promise<void> {
|
||||||
|
await queryRunner.query(`ALTER TABLE "items" DROP COLUMN "video_url"`);
|
||||||
|
await queryRunner.query(
|
||||||
|
`ALTER TABLE "items" ADD "video_url" character varying`,
|
||||||
|
);
|
||||||
|
await queryRunner.query(`DROP TABLE "item_queues"`);
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,33 @@
|
||||||
|
import { MigrationInterface, QueryRunner } from 'typeorm';
|
||||||
|
|
||||||
|
export class ItemQueues1729570177597 implements MigrationInterface {
|
||||||
|
name = 'ItemQueues1729570177597';
|
||||||
|
|
||||||
|
public async up(queryRunner: QueryRunner): Promise<void> {
|
||||||
|
await queryRunner.query(
|
||||||
|
`CREATE TYPE "public"."item_queues_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"."item_queues_item_type_enum" AS ENUM('tiket masuk', 'wahana', 'bundling', 'free gift', 'other')`,
|
||||||
|
);
|
||||||
|
await queryRunner.query(
|
||||||
|
`CREATE TABLE "item_queues" ("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"."item_queues_status_enum" NOT NULL DEFAULT 'draft', "name" character varying NOT NULL, "item_type" "public"."item_queues_item_type_enum" NOT NULL DEFAULT 'tiket masuk', CONSTRAINT "PK_e19adb0b99d995e8f10c189985f" PRIMARY KEY ("id"))`,
|
||||||
|
);
|
||||||
|
await queryRunner.query(`ALTER TABLE "items" ADD "item_queue_id" uuid`);
|
||||||
|
|
||||||
|
await queryRunner.query(
|
||||||
|
`ALTER TABLE "items" ADD CONSTRAINT "FK_2cbbeb03e176addcf60d65f7c9c" FOREIGN KEY ("item_queue_id") REFERENCES "item_queues"("id") ON DELETE CASCADE ON UPDATE CASCADE`,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
public async down(queryRunner: QueryRunner): Promise<void> {
|
||||||
|
await queryRunner.query(
|
||||||
|
`ALTER TABLE "items" DROP CONSTRAINT "FK_2cbbeb03e176addcf60d65f7c9c"`,
|
||||||
|
);
|
||||||
|
|
||||||
|
await queryRunner.query(`ALTER TABLE "items" DROP COLUMN "item_queue_id"`);
|
||||||
|
await queryRunner.query(`DROP TABLE "item_queues"`);
|
||||||
|
await queryRunner.query(`DROP TYPE "public"."item_queues_item_type_enum"`);
|
||||||
|
await queryRunner.query(`DROP TYPE "public"."item_queues_status_enum"`);
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,7 @@
|
||||||
|
export enum ItemType {
|
||||||
|
TIKET_MASUK = 'tiket masuk',
|
||||||
|
WAHANA = 'wahana',
|
||||||
|
BUNDLING = 'bundling',
|
||||||
|
FREE_GIFT = 'free gift',
|
||||||
|
OTHER = 'other',
|
||||||
|
}
|
|
@ -0,0 +1,28 @@
|
||||||
|
import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
|
||||||
|
import { ItemQueueEntity } from '../../domain/entities/item-queue.entity';
|
||||||
|
import { Column, Entity, OneToMany } from 'typeorm';
|
||||||
|
import { BaseStatusModel } from 'src/core/modules/data/model/base-status.model';
|
||||||
|
import { ItemType } from '../../constants';
|
||||||
|
import { ItemModel } from 'src/modules/item-related/item/data/models/item.model';
|
||||||
|
|
||||||
|
@Entity(TABLE_NAME.ITEM_QUEUE)
|
||||||
|
export class ItemQueueModel
|
||||||
|
extends BaseStatusModel<ItemQueueEntity>
|
||||||
|
implements ItemQueueEntity
|
||||||
|
{
|
||||||
|
@Column('varchar', { name: 'name' })
|
||||||
|
name: string;
|
||||||
|
|
||||||
|
@Column('enum', {
|
||||||
|
name: 'item_type',
|
||||||
|
enum: ItemType,
|
||||||
|
default: ItemType.TIKET_MASUK,
|
||||||
|
})
|
||||||
|
item_type: ItemType;
|
||||||
|
|
||||||
|
@OneToMany(() => ItemModel, (model) => model.item_queue, {
|
||||||
|
onDelete: 'CASCADE',
|
||||||
|
onUpdate: 'CASCADE',
|
||||||
|
})
|
||||||
|
items: ItemModel[];
|
||||||
|
}
|
|
@ -0,0 +1,17 @@
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
import { BaseDataService } from 'src/core/modules/data/service/base-data.service';
|
||||||
|
import { ItemQueueEntity } from '../../domain/entities/item-queue.entity';
|
||||||
|
import { InjectRepository } from '@nestjs/typeorm';
|
||||||
|
import { ItemQueueModel } from '../models/item-queue.model';
|
||||||
|
import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
|
||||||
|
import { Repository } from 'typeorm';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class ItemQueueDataService extends BaseDataService<ItemQueueEntity> {
|
||||||
|
constructor(
|
||||||
|
@InjectRepository(ItemQueueModel, CONNECTION_NAME.DEFAULT)
|
||||||
|
private repo: Repository<ItemQueueModel>,
|
||||||
|
) {
|
||||||
|
super(repo);
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,17 @@
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
import { ItemQueueEntity } from '../../domain/entities/item-queue.entity';
|
||||||
|
import { InjectRepository } from '@nestjs/typeorm';
|
||||||
|
import { ItemQueueModel } from '../models/item-queue.model';
|
||||||
|
import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
|
||||||
|
import { Repository } from 'typeorm';
|
||||||
|
import { BaseReadService } from 'src/core/modules/data/service/base-read.service';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class ItemQueueReadService extends BaseReadService<ItemQueueEntity> {
|
||||||
|
constructor(
|
||||||
|
@InjectRepository(ItemQueueModel, CONNECTION_NAME.DEFAULT)
|
||||||
|
private repo: Repository<ItemQueueModel>,
|
||||||
|
) {
|
||||||
|
super(repo);
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,5 @@
|
||||||
|
import { BaseFilterEntity } from 'src/core/modules/domain/entities/base-filter.entity';
|
||||||
|
|
||||||
|
export interface FilterItemQueueEntity extends BaseFilterEntity {
|
||||||
|
item_types: string[];
|
||||||
|
}
|
|
@ -0,0 +1,9 @@
|
||||||
|
import { BaseStatusEntity } from 'src/core/modules/domain/entities/base-status.entity';
|
||||||
|
import { ItemType } from '../../constants';
|
||||||
|
import { ItemEntity } from 'src/modules/item-related/item/domain/entities/item.entity';
|
||||||
|
|
||||||
|
export interface ItemQueueEntity extends BaseStatusEntity {
|
||||||
|
name: string;
|
||||||
|
item_type: ItemType;
|
||||||
|
items: ItemEntity[];
|
||||||
|
}
|
|
@ -0,0 +1,122 @@
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
import { CreateItemQueueManager } from './managers/create-item-queue.manager';
|
||||||
|
import { ItemQueueDataService } from '../../data/services/item-queue-data.service';
|
||||||
|
import { ItemQueueEntity } from '../entities/item-queue.entity';
|
||||||
|
import { DeleteItemQueueManager } from './managers/delete-item-queue.manager';
|
||||||
|
import { UpdateItemQueueManager } from './managers/update-item-queue.manager';
|
||||||
|
import { BaseDataTransactionOrchestrator } from 'src/core/modules/domain/usecase/orchestrators/base-data-transaction.orchestrator';
|
||||||
|
import { ActiveItemQueueManager } from './managers/active-item-queue.manager';
|
||||||
|
import { InactiveItemQueueManager } from './managers/inactive-item-queue.manager';
|
||||||
|
import { ConfirmItemQueueManager } from './managers/confirm-item-queue.manager';
|
||||||
|
import { STATUS } from 'src/core/strings/constants/base.constants';
|
||||||
|
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||||
|
import { BatchConfirmItemQueueManager } from './managers/batch-confirm-item-queue.manager';
|
||||||
|
import { BatchInactiveItemQueueManager } from './managers/batch-inactive-item-queue.manager';
|
||||||
|
import { BatchActiveItemQueueManager } from './managers/batch-active-item-queue.manager';
|
||||||
|
import { BatchDeleteItemQueueManager } from './managers/batch-delete-item-queue.manager';
|
||||||
|
import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class ItemQueueDataOrchestrator extends BaseDataTransactionOrchestrator<ItemQueueEntity> {
|
||||||
|
constructor(
|
||||||
|
private createManager: CreateItemQueueManager,
|
||||||
|
private updateManager: UpdateItemQueueManager,
|
||||||
|
private deleteManager: DeleteItemQueueManager,
|
||||||
|
private activeManager: ActiveItemQueueManager,
|
||||||
|
private confirmManager: ConfirmItemQueueManager,
|
||||||
|
private inactiveManager: InactiveItemQueueManager,
|
||||||
|
private batchDeleteManager: BatchDeleteItemQueueManager,
|
||||||
|
private batchActiveManager: BatchActiveItemQueueManager,
|
||||||
|
private batchConfirmManager: BatchConfirmItemQueueManager,
|
||||||
|
private batchInactiveManager: BatchInactiveItemQueueManager,
|
||||||
|
private serviceData: ItemQueueDataService,
|
||||||
|
) {
|
||||||
|
super();
|
||||||
|
}
|
||||||
|
|
||||||
|
async create(data): Promise<ItemQueueEntity> {
|
||||||
|
data.items = data.item_ids.map((id) => {
|
||||||
|
return { id };
|
||||||
|
});
|
||||||
|
this.createManager.setData(data);
|
||||||
|
this.createManager.setService(this.serviceData, TABLE_NAME.ITEM_CATEGORY);
|
||||||
|
await this.createManager.execute();
|
||||||
|
await this.createManager.generateConfig();
|
||||||
|
return this.createManager.getResult();
|
||||||
|
}
|
||||||
|
|
||||||
|
async update(dataId, data): Promise<ItemQueueEntity> {
|
||||||
|
this.updateManager.setData(dataId, data);
|
||||||
|
this.updateManager.setService(this.serviceData, TABLE_NAME.ITEM_CATEGORY);
|
||||||
|
await this.updateManager.execute();
|
||||||
|
return this.updateManager.getResult();
|
||||||
|
}
|
||||||
|
|
||||||
|
async delete(dataId): Promise<string> {
|
||||||
|
this.deleteManager.setData(dataId);
|
||||||
|
this.deleteManager.setService(this.serviceData, TABLE_NAME.ITEM_CATEGORY);
|
||||||
|
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.ITEM_CATEGORY,
|
||||||
|
);
|
||||||
|
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.ITEM_CATEGORY);
|
||||||
|
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.ITEM_CATEGORY,
|
||||||
|
);
|
||||||
|
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.ITEM_CATEGORY);
|
||||||
|
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.ITEM_CATEGORY,
|
||||||
|
);
|
||||||
|
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.ITEM_CATEGORY);
|
||||||
|
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.ITEM_CATEGORY,
|
||||||
|
);
|
||||||
|
await this.batchInactiveManager.execute();
|
||||||
|
return this.batchInactiveManager.getResult();
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,33 @@
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
import { IndexItemQueueManager } from './managers/index-item-queue.manager';
|
||||||
|
import { ItemQueueReadService } from '../../data/services/item-queue-read.service';
|
||||||
|
import { ItemQueueEntity } from '../entities/item-queue.entity';
|
||||||
|
import { PaginationResponse } from 'src/core/response/domain/ok-response.interface';
|
||||||
|
import { BaseReadOrchestrator } from 'src/core/modules/domain/usecase/orchestrators/base-read.orchestrator';
|
||||||
|
import { DetailItemQueueManager } from './managers/detail-item-queue.manager';
|
||||||
|
import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class ItemQueueReadOrchestrator extends BaseReadOrchestrator<ItemQueueEntity> {
|
||||||
|
constructor(
|
||||||
|
private indexManager: IndexItemQueueManager,
|
||||||
|
private detailManager: DetailItemQueueManager,
|
||||||
|
private serviceData: ItemQueueReadService,
|
||||||
|
) {
|
||||||
|
super();
|
||||||
|
}
|
||||||
|
|
||||||
|
async index(params): Promise<PaginationResponse<ItemQueueEntity>> {
|
||||||
|
this.indexManager.setFilterParam(params);
|
||||||
|
this.indexManager.setService(this.serviceData, TABLE_NAME.ITEM_QUEUE);
|
||||||
|
await this.indexManager.execute();
|
||||||
|
return this.indexManager.getResult();
|
||||||
|
}
|
||||||
|
|
||||||
|
async detail(dataId: string): Promise<ItemQueueEntity> {
|
||||||
|
this.detailManager.setData(dataId);
|
||||||
|
this.detailManager.setService(this.serviceData, TABLE_NAME.ITEM_QUEUE);
|
||||||
|
await this.detailManager.execute();
|
||||||
|
return this.detailManager.getResult();
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,39 @@
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
|
||||||
|
import { ItemQueueEntity } from '../../entities/item-queue.entity';
|
||||||
|
import {
|
||||||
|
EventTopics,
|
||||||
|
validateRelations,
|
||||||
|
} from 'src/core/strings/constants/interface.constants';
|
||||||
|
import { ItemQueueModel } from '../../../data/models/item-queue.model';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class ActiveItemQueueManager extends BaseUpdateStatusManager<ItemQueueEntity> {
|
||||||
|
getResult(): string {
|
||||||
|
return `Success active data ${this.result.name}`;
|
||||||
|
}
|
||||||
|
|
||||||
|
async validateProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async beforeProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async afterProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
get validateRelations(): validateRelations[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
|
||||||
|
get entityTarget(): any {
|
||||||
|
return ItemQueueModel;
|
||||||
|
}
|
||||||
|
|
||||||
|
get eventTopics(): EventTopics[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,40 @@
|
||||||
|
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
|
||||||
|
import { ItemQueueEntity } from '../../entities/item-queue.entity';
|
||||||
|
import {
|
||||||
|
EventTopics,
|
||||||
|
validateRelations,
|
||||||
|
} from 'src/core/strings/constants/interface.constants';
|
||||||
|
import { ItemQueueModel } from '../../../data/models/item-queue.model';
|
||||||
|
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class BatchActiveItemQueueManager extends BaseBatchUpdateStatusManager<ItemQueueEntity> {
|
||||||
|
validateData(data: ItemQueueEntity): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
beforeProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
afterProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
get validateRelations(): validateRelations[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
|
||||||
|
get entityTarget(): any {
|
||||||
|
return ItemQueueModel;
|
||||||
|
}
|
||||||
|
|
||||||
|
get eventTopics(): EventTopics[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
|
||||||
|
getResult(): BatchResult {
|
||||||
|
return this.result;
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,40 @@
|
||||||
|
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
|
||||||
|
import { ItemQueueEntity } from '../../entities/item-queue.entity';
|
||||||
|
import {
|
||||||
|
EventTopics,
|
||||||
|
validateRelations,
|
||||||
|
} from 'src/core/strings/constants/interface.constants';
|
||||||
|
import { ItemQueueModel } from '../../../data/models/item-queue.model';
|
||||||
|
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class BatchConfirmItemQueueManager extends BaseBatchUpdateStatusManager<ItemQueueEntity> {
|
||||||
|
validateData(data: ItemQueueEntity): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
beforeProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
afterProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
get validateRelations(): validateRelations[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
|
||||||
|
get entityTarget(): any {
|
||||||
|
return ItemQueueModel;
|
||||||
|
}
|
||||||
|
|
||||||
|
get eventTopics(): EventTopics[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
|
||||||
|
getResult(): BatchResult {
|
||||||
|
return this.result;
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,46 @@
|
||||||
|
import { BaseBatchDeleteManager } from 'src/core/modules/domain/usecase/managers/base-batch-delete.manager';
|
||||||
|
import { ItemQueueEntity } from '../../entities/item-queue.entity';
|
||||||
|
import {
|
||||||
|
EventTopics,
|
||||||
|
validateRelations,
|
||||||
|
} from 'src/core/strings/constants/interface.constants';
|
||||||
|
import { ItemQueueModel } from '../../../data/models/item-queue.model';
|
||||||
|
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class BatchDeleteItemQueueManager extends BaseBatchDeleteManager<ItemQueueEntity> {
|
||||||
|
async beforeProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async validateData(data: ItemQueueEntity): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async afterProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
get validateRelations(): validateRelations[] {
|
||||||
|
return [
|
||||||
|
{
|
||||||
|
relation: 'items',
|
||||||
|
message:
|
||||||
|
'Gagal! tidak dapat mengubah tipe item karena sudah berelasi dengan item',
|
||||||
|
},
|
||||||
|
];
|
||||||
|
}
|
||||||
|
|
||||||
|
get entityTarget(): any {
|
||||||
|
return ItemQueueModel;
|
||||||
|
}
|
||||||
|
|
||||||
|
get eventTopics(): EventTopics[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
|
||||||
|
getResult(): BatchResult {
|
||||||
|
return this.result;
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,46 @@
|
||||||
|
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
|
||||||
|
import { ItemQueueEntity } from '../../entities/item-queue.entity';
|
||||||
|
import {
|
||||||
|
EventTopics,
|
||||||
|
validateRelations,
|
||||||
|
} from 'src/core/strings/constants/interface.constants';
|
||||||
|
import { ItemQueueModel } from '../../../data/models/item-queue.model';
|
||||||
|
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class BatchInactiveItemQueueManager extends BaseBatchUpdateStatusManager<ItemQueueEntity> {
|
||||||
|
validateData(data: ItemQueueEntity): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
beforeProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
afterProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
get validateRelations(): validateRelations[] {
|
||||||
|
return [
|
||||||
|
{
|
||||||
|
relation: 'items',
|
||||||
|
message:
|
||||||
|
'Gagal! tidak dapat mengubah tipe item karena sudah berelasi dengan item',
|
||||||
|
},
|
||||||
|
];
|
||||||
|
}
|
||||||
|
|
||||||
|
get entityTarget(): any {
|
||||||
|
return ItemQueueModel;
|
||||||
|
}
|
||||||
|
|
||||||
|
get eventTopics(): EventTopics[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
|
||||||
|
getResult(): BatchResult {
|
||||||
|
return this.result;
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,39 @@
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
|
||||||
|
import { ItemQueueEntity } from '../../entities/item-queue.entity';
|
||||||
|
import {
|
||||||
|
EventTopics,
|
||||||
|
validateRelations,
|
||||||
|
} from 'src/core/strings/constants/interface.constants';
|
||||||
|
import { ItemQueueModel } from '../../../data/models/item-queue.model';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class ConfirmItemQueueManager extends BaseUpdateStatusManager<ItemQueueEntity> {
|
||||||
|
getResult(): string {
|
||||||
|
return `Success active data ${this.result.name}`;
|
||||||
|
}
|
||||||
|
|
||||||
|
async validateProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async beforeProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async afterProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
get validateRelations(): validateRelations[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
|
||||||
|
get entityTarget(): any {
|
||||||
|
return ItemQueueModel;
|
||||||
|
}
|
||||||
|
|
||||||
|
get eventTopics(): EventTopics[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,43 @@
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
import {
|
||||||
|
EventTopics,
|
||||||
|
columnUniques,
|
||||||
|
validateRelations,
|
||||||
|
} from 'src/core/strings/constants/interface.constants';
|
||||||
|
import { ItemQueueEntity } from '../../entities/item-queue.entity';
|
||||||
|
import { ItemQueueModel } from '../../../data/models/item-queue.model';
|
||||||
|
import { BaseCreateManager } from 'src/core/modules/domain/usecase/managers/base-create.manager';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class CreateItemQueueManager extends BaseCreateManager<ItemQueueEntity> {
|
||||||
|
async beforeProcess(): Promise<void> {
|
||||||
|
Object.assign(this.data, {
|
||||||
|
item_type: this.data.item_type.toLowerCase(),
|
||||||
|
});
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async afterProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async generateConfig(): Promise<void> {
|
||||||
|
// TODO: Implement logic here
|
||||||
|
}
|
||||||
|
|
||||||
|
get validateRelations(): validateRelations[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
|
||||||
|
get uniqueColumns(): columnUniques[] {
|
||||||
|
return [{ column: 'name' }];
|
||||||
|
}
|
||||||
|
|
||||||
|
get eventTopics(): EventTopics[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
|
||||||
|
get entityTarget(): any {
|
||||||
|
return ItemQueueModel;
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,45 @@
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
import { BaseDeleteManager } from 'src/core/modules/domain/usecase/managers/base-delete.manager';
|
||||||
|
import { ItemQueueEntity } from '../../entities/item-queue.entity';
|
||||||
|
import {
|
||||||
|
EventTopics,
|
||||||
|
validateRelations,
|
||||||
|
} from 'src/core/strings/constants/interface.constants';
|
||||||
|
import { ItemQueueModel } from '../../../data/models/item-queue.model';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class DeleteItemQueueManager extends BaseDeleteManager<ItemQueueEntity> {
|
||||||
|
getResult(): string {
|
||||||
|
return `Success`;
|
||||||
|
}
|
||||||
|
|
||||||
|
async validateProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async beforeProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async afterProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
get validateRelations(): validateRelations[] {
|
||||||
|
return [
|
||||||
|
{
|
||||||
|
relation: 'items',
|
||||||
|
message:
|
||||||
|
'Gagal! tidak dapat mengubah tipe item karena sudah berelasi dengan item',
|
||||||
|
},
|
||||||
|
];
|
||||||
|
}
|
||||||
|
|
||||||
|
get entityTarget(): any {
|
||||||
|
return ItemQueueModel;
|
||||||
|
}
|
||||||
|
|
||||||
|
get eventTopics(): EventTopics[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,58 @@
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
import { BaseDetailManager } from 'src/core/modules/domain/usecase/managers/base-detail.manager';
|
||||||
|
import { ItemQueueEntity } from '../../entities/item-queue.entity';
|
||||||
|
import { RelationParam } from 'src/core/modules/domain/entities/base-filter.entity';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class DetailItemQueueManager extends BaseDetailManager<ItemQueueEntity> {
|
||||||
|
async prepareData(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async beforeProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async afterProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
get relations(): RelationParam {
|
||||||
|
return {
|
||||||
|
joinRelations: [],
|
||||||
|
selectRelations: ['items'],
|
||||||
|
countRelations: [],
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
get selects(): string[] {
|
||||||
|
return [
|
||||||
|
`${this.tableName}.id`,
|
||||||
|
`${this.tableName}.status`,
|
||||||
|
`${this.tableName}.name`,
|
||||||
|
`${this.tableName}.item_type`,
|
||||||
|
`${this.tableName}.created_at`,
|
||||||
|
`${this.tableName}.creator_name`,
|
||||||
|
`${this.tableName}.updated_at`,
|
||||||
|
`${this.tableName}.editor_name`,
|
||||||
|
|
||||||
|
`items.id`,
|
||||||
|
`items.created_at`,
|
||||||
|
`items.status`,
|
||||||
|
`items.item_type`,
|
||||||
|
`items.name`,
|
||||||
|
`items.hpp`,
|
||||||
|
`items.limit_type`,
|
||||||
|
`items.limit_value`,
|
||||||
|
`items.base_price`,
|
||||||
|
`items.share_profit`,
|
||||||
|
`items.play_estimation`,
|
||||||
|
];
|
||||||
|
}
|
||||||
|
|
||||||
|
get setFindProperties(): any {
|
||||||
|
return {
|
||||||
|
id: this.dataId,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,45 @@
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
|
||||||
|
import { ItemQueueEntity } from '../../entities/item-queue.entity';
|
||||||
|
import {
|
||||||
|
EventTopics,
|
||||||
|
validateRelations,
|
||||||
|
} from 'src/core/strings/constants/interface.constants';
|
||||||
|
import { ItemQueueModel } from '../../../data/models/item-queue.model';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class InactiveItemQueueManager extends BaseUpdateStatusManager<ItemQueueEntity> {
|
||||||
|
getResult(): string {
|
||||||
|
return `Success inactive data ${this.result.name}`;
|
||||||
|
}
|
||||||
|
|
||||||
|
async validateProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async beforeProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async afterProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
get validateRelations(): validateRelations[] {
|
||||||
|
return [
|
||||||
|
{
|
||||||
|
relation: 'items',
|
||||||
|
message:
|
||||||
|
'Gagal! tidak dapat mengubah tipe item karena sudah berelasi dengan item',
|
||||||
|
},
|
||||||
|
];
|
||||||
|
}
|
||||||
|
|
||||||
|
get entityTarget(): any {
|
||||||
|
return ItemQueueModel;
|
||||||
|
}
|
||||||
|
|
||||||
|
get eventTopics(): EventTopics[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,75 @@
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
import { BaseIndexManager } from 'src/core/modules/domain/usecase/managers/base-index.manager';
|
||||||
|
import { ItemQueueEntity } from '../../entities/item-queue.entity';
|
||||||
|
import { SelectQueryBuilder } from 'typeorm';
|
||||||
|
import {
|
||||||
|
Param,
|
||||||
|
RelationParam,
|
||||||
|
} from 'src/core/modules/domain/entities/base-filter.entity';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class IndexItemQueueManager extends BaseIndexManager<ItemQueueEntity> {
|
||||||
|
async prepareData(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async beforeProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async afterProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
get relations(): RelationParam {
|
||||||
|
return {
|
||||||
|
joinRelations: [],
|
||||||
|
selectRelations: ['items'],
|
||||||
|
countRelations: [],
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
get selects(): string[] {
|
||||||
|
return [
|
||||||
|
`${this.tableName}.id`,
|
||||||
|
`${this.tableName}.status`,
|
||||||
|
`${this.tableName}.name`,
|
||||||
|
`${this.tableName}.item_type`,
|
||||||
|
`${this.tableName}.created_at`,
|
||||||
|
`${this.tableName}.creator_name`,
|
||||||
|
`${this.tableName}.updated_at`,
|
||||||
|
`${this.tableName}.editor_name`,
|
||||||
|
|
||||||
|
`items.id`,
|
||||||
|
`items.created_at`,
|
||||||
|
`items.status`,
|
||||||
|
`items.item_type`,
|
||||||
|
`items.name`,
|
||||||
|
`items.hpp`,
|
||||||
|
`items.limit_type`,
|
||||||
|
`items.limit_value`,
|
||||||
|
`items.base_price`,
|
||||||
|
`items.share_profit`,
|
||||||
|
`items.play_estimation`,
|
||||||
|
];
|
||||||
|
}
|
||||||
|
|
||||||
|
get specificFilter(): Param[] {
|
||||||
|
return [
|
||||||
|
{
|
||||||
|
cols: `${this.tableName}.name`,
|
||||||
|
data: this.filterParam.names,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
cols: `${this.tableName}.item_type::text`,
|
||||||
|
data: this.filterParam.item_types,
|
||||||
|
},
|
||||||
|
];
|
||||||
|
}
|
||||||
|
|
||||||
|
setQueryFilter(
|
||||||
|
queryBuilder: SelectQueryBuilder<ItemQueueEntity>,
|
||||||
|
): SelectQueryBuilder<ItemQueueEntity> {
|
||||||
|
return queryBuilder;
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,53 @@
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
import { BaseUpdateManager } from 'src/core/modules/domain/usecase/managers/base-update.manager';
|
||||||
|
import { ItemQueueEntity } from '../../entities/item-queue.entity';
|
||||||
|
import { ItemQueueModel } from '../../../data/models/item-queue.model';
|
||||||
|
import {
|
||||||
|
EventTopics,
|
||||||
|
columnUniques,
|
||||||
|
validateRelations,
|
||||||
|
} from 'src/core/strings/constants/interface.constants';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class UpdateItemQueueManager extends BaseUpdateManager<ItemQueueEntity> {
|
||||||
|
async validateProcess(): Promise<void> {
|
||||||
|
Object.assign(this.data, {
|
||||||
|
item_type: this.data.item_type.toLowerCase(),
|
||||||
|
});
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async beforeProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async afterProcess(): Promise<void> {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
get validateRelations(): validateRelations[] {
|
||||||
|
if (this.data.item_type != this.oldData.item_type) {
|
||||||
|
return [
|
||||||
|
{
|
||||||
|
relation: 'items',
|
||||||
|
message:
|
||||||
|
'Gagal! tidak dapat mengubah tipe item karena sudah berelasi dengan item',
|
||||||
|
},
|
||||||
|
];
|
||||||
|
} else {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
get uniqueColumns(): columnUniques[] {
|
||||||
|
return [{ column: 'name' }];
|
||||||
|
}
|
||||||
|
|
||||||
|
get entityTarget(): any {
|
||||||
|
return ItemQueueModel;
|
||||||
|
}
|
||||||
|
|
||||||
|
get eventTopics(): EventTopics[] {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,15 @@
|
||||||
|
import { BaseFilterDto } from 'src/core/modules/infrastructure/dto/base-filter.dto';
|
||||||
|
import { FilterItemQueueEntity } from '../../domain/entities/filter-item-queue.entity';
|
||||||
|
import { ApiProperty } from '@nestjs/swagger';
|
||||||
|
import { Transform } from 'class-transformer';
|
||||||
|
|
||||||
|
export class FilterItemQueueDto
|
||||||
|
extends BaseFilterDto
|
||||||
|
implements FilterItemQueueEntity
|
||||||
|
{
|
||||||
|
@ApiProperty({ type: ['string'], required: false })
|
||||||
|
@Transform((body) => {
|
||||||
|
return Array.isArray(body.value) ? body.value : [body.value];
|
||||||
|
})
|
||||||
|
item_types: string[];
|
||||||
|
}
|
|
@ -0,0 +1,32 @@
|
||||||
|
import { BaseStatusDto } from 'src/core/modules/infrastructure/dto/base-status.dto';
|
||||||
|
import { ItemQueueEntity } from '../../domain/entities/item-queue.entity';
|
||||||
|
import { IsArray, IsString } from 'class-validator';
|
||||||
|
import { ItemType } from '../../constants';
|
||||||
|
import { ApiProperty } from '@nestjs/swagger';
|
||||||
|
import { ItemEntity } from 'src/modules/item-related/item/domain/entities/item.entity';
|
||||||
|
import { Exclude, Transform } from 'class-transformer';
|
||||||
|
|
||||||
|
export class ItemQueueDto extends BaseStatusDto implements ItemQueueEntity {
|
||||||
|
@Exclude()
|
||||||
|
items: ItemEntity[];
|
||||||
|
|
||||||
|
@ApiProperty({ name: 'name', required: true, example: 'Bundling w Entrance' })
|
||||||
|
@IsString()
|
||||||
|
name: string;
|
||||||
|
|
||||||
|
@ApiProperty({
|
||||||
|
type: 'string',
|
||||||
|
required: true,
|
||||||
|
description: `Select (${JSON.stringify(Object.values(ItemType))})`,
|
||||||
|
example: ItemType.BUNDLING,
|
||||||
|
})
|
||||||
|
item_type: ItemType;
|
||||||
|
|
||||||
|
@ApiProperty({ type: [String], required: true })
|
||||||
|
@Transform((body) => {
|
||||||
|
return Array.isArray(body.value) ? body.value : [body.value];
|
||||||
|
})
|
||||||
|
@IsArray()
|
||||||
|
@IsString({ each: true })
|
||||||
|
item_ids: string[];
|
||||||
|
}
|
|
@ -0,0 +1,78 @@
|
||||||
|
import {
|
||||||
|
Body,
|
||||||
|
Controller,
|
||||||
|
Delete,
|
||||||
|
Param,
|
||||||
|
Patch,
|
||||||
|
Post,
|
||||||
|
Put,
|
||||||
|
} from '@nestjs/common';
|
||||||
|
import { ItemQueueDataOrchestrator } from '../domain/usecases/item-queue-data.orchestrator';
|
||||||
|
import { ItemQueueDto } from './dto/item-queue.dto';
|
||||||
|
import { MODULE_NAME } from 'src/core/strings/constants/module.constants';
|
||||||
|
import { ApiBearerAuth, ApiTags } from '@nestjs/swagger';
|
||||||
|
import { ItemQueueEntity } from '../domain/entities/item-queue.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.ITEM_QUEUE.split('-').join(' ')} - data`)
|
||||||
|
@Controller(`v1/${MODULE_NAME.ITEM_QUEUE}`)
|
||||||
|
@Public(false)
|
||||||
|
@ApiBearerAuth('JWT')
|
||||||
|
export class ItemQueueDataController {
|
||||||
|
constructor(private orchestrator: ItemQueueDataOrchestrator) {}
|
||||||
|
|
||||||
|
@Post()
|
||||||
|
async create(@Body() data: ItemQueueDto): Promise<ItemQueueEntity> {
|
||||||
|
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: ItemQueueDto,
|
||||||
|
): Promise<ItemQueueEntity> {
|
||||||
|
return await this.orchestrator.update(dataId, data);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Delete(':id')
|
||||||
|
async delete(@Param('id') dataId: string): Promise<string> {
|
||||||
|
return await this.orchestrator.delete(dataId);
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,30 @@
|
||||||
|
import { Controller, Get, Param, Query } from '@nestjs/common';
|
||||||
|
import { FilterItemQueueDto } from './dto/filter-item-queue.dto';
|
||||||
|
import { Pagination } from 'src/core/response';
|
||||||
|
import { PaginationResponse } from 'src/core/response/domain/ok-response.interface';
|
||||||
|
import { ItemQueueEntity } from '../domain/entities/item-queue.entity';
|
||||||
|
import { ItemQueueReadOrchestrator } from '../domain/usecases/item-queue-read.orchestrator';
|
||||||
|
import { ApiBearerAuth, ApiTags } from '@nestjs/swagger';
|
||||||
|
import { MODULE_NAME } from 'src/core/strings/constants/module.constants';
|
||||||
|
import { Public } from 'src/core/guards';
|
||||||
|
|
||||||
|
@ApiTags(`${MODULE_NAME.ITEM_QUEUE.split('-').join(' ')} - read`)
|
||||||
|
@Controller(`v1/${MODULE_NAME.ITEM_QUEUE}`)
|
||||||
|
@Public(false)
|
||||||
|
@ApiBearerAuth('JWT')
|
||||||
|
export class ItemQueueReadController {
|
||||||
|
constructor(private orchestrator: ItemQueueReadOrchestrator) {}
|
||||||
|
|
||||||
|
@Get()
|
||||||
|
@Pagination()
|
||||||
|
async index(
|
||||||
|
@Query() params: FilterItemQueueDto,
|
||||||
|
): Promise<PaginationResponse<ItemQueueEntity>> {
|
||||||
|
return await this.orchestrator.index(params);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Get(':id')
|
||||||
|
async detail(@Param('id') id: string): Promise<ItemQueueEntity> {
|
||||||
|
return await this.orchestrator.detail(id);
|
||||||
|
}
|
||||||
|
}
|
|
@ -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 { ItemQueueDataService } from './data/services/item-queue-data.service';
|
||||||
|
import { ItemQueueReadService } from './data/services/item-queue-read.service';
|
||||||
|
import { ItemQueueReadController } from './infrastructure/item-queue-read.controller';
|
||||||
|
import { ItemQueueReadOrchestrator } from './domain/usecases/item-queue-read.orchestrator';
|
||||||
|
import { ItemQueueDataController } from './infrastructure/item-queue-data.controller';
|
||||||
|
import { ItemQueueDataOrchestrator } from './domain/usecases/item-queue-data.orchestrator';
|
||||||
|
import { CreateItemQueueManager } from './domain/usecases/managers/create-item-queue.manager';
|
||||||
|
import { CqrsModule } from '@nestjs/cqrs';
|
||||||
|
import { IndexItemQueueManager } from './domain/usecases/managers/index-item-queue.manager';
|
||||||
|
import { DeleteItemQueueManager } from './domain/usecases/managers/delete-item-queue.manager';
|
||||||
|
import { UpdateItemQueueManager } from './domain/usecases/managers/update-item-queue.manager';
|
||||||
|
import { ActiveItemQueueManager } from './domain/usecases/managers/active-item-queue.manager';
|
||||||
|
import { ConfirmItemQueueManager } from './domain/usecases/managers/confirm-item-queue.manager';
|
||||||
|
import { InactiveItemQueueManager } from './domain/usecases/managers/inactive-item-queue.manager';
|
||||||
|
import { DetailItemQueueManager } from './domain/usecases/managers/detail-item-queue.manager';
|
||||||
|
import { BatchDeleteItemQueueManager } from './domain/usecases/managers/batch-delete-item-queue.manager';
|
||||||
|
import { BatchActiveItemQueueManager } from './domain/usecases/managers/batch-active-item-queue.manager';
|
||||||
|
import { BatchConfirmItemQueueManager } from './domain/usecases/managers/batch-confirm-item-queue.manager';
|
||||||
|
import { BatchInactiveItemQueueManager } from './domain/usecases/managers/batch-inactive-item-queue.manager';
|
||||||
|
import { ItemQueueModel } from './data/models/item-queue.model';
|
||||||
|
|
||||||
|
@Module({
|
||||||
|
imports: [
|
||||||
|
ConfigModule.forRoot(),
|
||||||
|
TypeOrmModule.forFeature([ItemQueueModel], CONNECTION_NAME.DEFAULT),
|
||||||
|
CqrsModule,
|
||||||
|
],
|
||||||
|
controllers: [ItemQueueDataController, ItemQueueReadController],
|
||||||
|
providers: [
|
||||||
|
IndexItemQueueManager,
|
||||||
|
DetailItemQueueManager,
|
||||||
|
CreateItemQueueManager,
|
||||||
|
DeleteItemQueueManager,
|
||||||
|
UpdateItemQueueManager,
|
||||||
|
ActiveItemQueueManager,
|
||||||
|
ConfirmItemQueueManager,
|
||||||
|
InactiveItemQueueManager,
|
||||||
|
BatchDeleteItemQueueManager,
|
||||||
|
BatchActiveItemQueueManager,
|
||||||
|
BatchConfirmItemQueueManager,
|
||||||
|
BatchInactiveItemQueueManager,
|
||||||
|
|
||||||
|
ItemQueueDataService,
|
||||||
|
ItemQueueReadService,
|
||||||
|
|
||||||
|
ItemQueueDataOrchestrator,
|
||||||
|
ItemQueueReadOrchestrator,
|
||||||
|
],
|
||||||
|
})
|
||||||
|
export class ItemQueueModule {}
|
|
@ -16,6 +16,7 @@ import { ItemCategoryModel } from 'src/modules/item-related/item-category/data/m
|
||||||
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';
|
import { GateModel } from 'src/modules/web-information/gate/data/models/gate.model';
|
||||||
|
import { ItemQueueModel } from 'src/modules/item-related/item-queue/data/models/item-queue.model';
|
||||||
|
|
||||||
@Entity(TABLE_NAME.ITEM)
|
@Entity(TABLE_NAME.ITEM)
|
||||||
export class ItemModel
|
export class ItemModel
|
||||||
|
@ -28,8 +29,8 @@ export class ItemModel
|
||||||
@Column('varchar', { name: 'image_url', nullable: true })
|
@Column('varchar', { name: 'image_url', nullable: true })
|
||||||
image_url: string;
|
image_url: string;
|
||||||
|
|
||||||
@Column('varchar', { nullable: true })
|
@Column('json', { nullable: true })
|
||||||
video_url: string;
|
video_url: string[];
|
||||||
|
|
||||||
@Column('enum', {
|
@Column('enum', {
|
||||||
name: 'item_type',
|
name: 'item_type',
|
||||||
|
@ -85,6 +86,13 @@ export class ItemModel
|
||||||
@JoinColumn({ name: 'item_category_id' })
|
@JoinColumn({ name: 'item_category_id' })
|
||||||
item_category: ItemCategoryModel;
|
item_category: ItemCategoryModel;
|
||||||
|
|
||||||
|
@ManyToOne(() => ItemQueueModel, (model) => model.items, {
|
||||||
|
onUpdate: 'CASCADE',
|
||||||
|
onDelete: 'CASCADE',
|
||||||
|
})
|
||||||
|
@JoinColumn({ name: 'item_queue_id' })
|
||||||
|
item_queue: ItemQueueModel;
|
||||||
|
|
||||||
// relation ke tenant
|
// relation ke tenant
|
||||||
// ? karena item bisajadi merupakan item dari tenant
|
// ? karena item bisajadi merupakan item dari tenant
|
||||||
@Column('varchar', { name: 'tenant_id', nullable: true })
|
@Column('varchar', { name: 'tenant_id', nullable: true })
|
||||||
|
|
|
@ -6,7 +6,7 @@ export interface ItemEntity extends BaseStatusEntity {
|
||||||
name: string;
|
name: string;
|
||||||
item_type: ItemType;
|
item_type: ItemType;
|
||||||
image_url: string;
|
image_url: string;
|
||||||
video_url?: string;
|
video_url?: string[];
|
||||||
|
|
||||||
hpp: number;
|
hpp: number;
|
||||||
sales_margin: number;
|
sales_margin: number;
|
||||||
|
|
|
@ -12,6 +12,7 @@ import {
|
||||||
ValidateIf,
|
ValidateIf,
|
||||||
} from 'class-validator';
|
} from 'class-validator';
|
||||||
import { ItemCategoryEntity } from 'src/modules/item-related/item-category/domain/entities/item-category.entity';
|
import { ItemCategoryEntity } from 'src/modules/item-related/item-category/domain/entities/item-category.entity';
|
||||||
|
import { Transform } from 'class-transformer';
|
||||||
|
|
||||||
export class ItemDto extends BaseStatusDto implements ItemEntity {
|
export class ItemDto extends BaseStatusDto implements ItemEntity {
|
||||||
@ApiProperty({
|
@ApiProperty({
|
||||||
|
@ -32,13 +33,16 @@ export class ItemDto extends BaseStatusDto implements ItemEntity {
|
||||||
image_url: string;
|
image_url: string;
|
||||||
|
|
||||||
@ApiProperty({
|
@ApiProperty({
|
||||||
type: String,
|
isArray: true,
|
||||||
required: false,
|
required: false,
|
||||||
example: '...',
|
|
||||||
})
|
})
|
||||||
@IsString()
|
// @IsString()
|
||||||
@ValidateIf((body) => body.video_url)
|
@ValidateIf((body) => body.video_url)
|
||||||
video_url: string;
|
@Transform(({ value }) => {
|
||||||
|
if (!value) return [];
|
||||||
|
return Array.isArray(value) ? value : [value];
|
||||||
|
})
|
||||||
|
video_url: string[];
|
||||||
|
|
||||||
@ApiProperty({
|
@ApiProperty({
|
||||||
type: 'string',
|
type: 'string',
|
||||||
|
|
|
@ -41,18 +41,18 @@ export class ItemReadController {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ApiTags(`Item Queue - Read`)
|
// @ApiTags(`Item Queue - Read`)
|
||||||
@Controller(`v1/item-queue`)
|
// @Controller(`v1/item-queue`)
|
||||||
@Public(true)
|
// @Public(true)
|
||||||
export class ItemReadQueueController {
|
// export class ItemReadQueueController {
|
||||||
constructor(private orchestrator: ItemReadOrchestrator) {}
|
// constructor(private orchestrator: ItemReadOrchestrator) {}
|
||||||
|
|
||||||
@Get()
|
// @Get()
|
||||||
@Pagination()
|
// @Pagination()
|
||||||
@ExcludePrivilege()
|
// @ExcludePrivilege()
|
||||||
async indexQueue(
|
// async indexQueue(
|
||||||
@Query() params: FilterItemDto,
|
// @Query() params: FilterItemDto,
|
||||||
): Promise<PaginationResponse<ItemEntity>> {
|
// ): Promise<PaginationResponse<ItemEntity>> {
|
||||||
return await this.orchestrator.indexQueue(params);
|
// return await this.orchestrator.indexQueue(params);
|
||||||
}
|
// }
|
||||||
}
|
// }
|
||||||
|
|
|
@ -6,7 +6,7 @@ import { ItemDataService } from './data/services/item-data.service';
|
||||||
import { ItemReadService } from './data/services/item-read.service';
|
import { ItemReadService } from './data/services/item-read.service';
|
||||||
import {
|
import {
|
||||||
ItemReadController,
|
ItemReadController,
|
||||||
ItemReadQueueController,
|
// ItemReadQueueController,
|
||||||
} from './infrastructure/item-read.controller';
|
} from './infrastructure/item-read.controller';
|
||||||
import { ItemReadOrchestrator } from './domain/usecases/item-read.orchestrator';
|
import { ItemReadOrchestrator } from './domain/usecases/item-read.orchestrator';
|
||||||
import { ItemDataController } from './infrastructure/item-data.controller';
|
import { ItemDataController } from './infrastructure/item-data.controller';
|
||||||
|
@ -44,7 +44,7 @@ import { IndexItemQueueManager } from './domain/usecases/managers/index-queue-it
|
||||||
controllers: [
|
controllers: [
|
||||||
ItemDataController,
|
ItemDataController,
|
||||||
ItemReadController,
|
ItemReadController,
|
||||||
ItemReadQueueController,
|
// ItemReadQueueController,
|
||||||
],
|
],
|
||||||
providers: [
|
providers: [
|
||||||
IndexItemManager,
|
IndexItemManager,
|
||||||
|
|
|
@ -0,0 +1,89 @@
|
||||||
|
import { BaseCoreModel } from 'src/core/modules/data/model/base-core.model';
|
||||||
|
import { QueueOrder } from '../../domain/entities/order.entity';
|
||||||
|
import { Column, Entity, JoinColumn, ManyToOne, OneToMany } from 'typeorm';
|
||||||
|
import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
|
||||||
|
import { QueueTicket } from '../../domain/entities/ticket.entity';
|
||||||
|
import { QueueItem } from '../../domain/entities/queue-item.entity';
|
||||||
|
import { ItemEntity } from 'src/modules/item-related/item/domain/entities/item.entity';
|
||||||
|
|
||||||
|
import { ItemModel } from 'src/modules/item-related/item/data/models/item.model';
|
||||||
|
|
||||||
|
@Entity(TABLE_NAME.QUEUE_ORDER)
|
||||||
|
export class QueueOrderModel
|
||||||
|
extends BaseCoreModel<QueueOrderModel>
|
||||||
|
implements QueueOrder
|
||||||
|
{
|
||||||
|
@Column('varchar')
|
||||||
|
code: string;
|
||||||
|
|
||||||
|
@Column('varchar', { nullable: true })
|
||||||
|
customer: string;
|
||||||
|
|
||||||
|
@Column('varchar', { nullable: true })
|
||||||
|
phone: string;
|
||||||
|
|
||||||
|
@OneToMany(() => QueueTicketModel, (model) => model.order, {
|
||||||
|
cascade: true,
|
||||||
|
onDelete: 'CASCADE',
|
||||||
|
onUpdate: 'CASCADE',
|
||||||
|
})
|
||||||
|
tickets: QueueTicket[];
|
||||||
|
|
||||||
|
@Column({ type: 'bigint' })
|
||||||
|
date: number;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Entity(TABLE_NAME.QUEUE_TICKET)
|
||||||
|
export class QueueTicketModel
|
||||||
|
extends BaseCoreModel<QueueTicketModel>
|
||||||
|
implements QueueTicket
|
||||||
|
{
|
||||||
|
@Column('varchar')
|
||||||
|
code: string;
|
||||||
|
|
||||||
|
@Column('varchar', { nullable: true })
|
||||||
|
customer: string;
|
||||||
|
|
||||||
|
@Column('varchar', { nullable: true })
|
||||||
|
phone: string;
|
||||||
|
|
||||||
|
@ManyToOne(() => QueueOrderModel, (model) => model.tickets, {
|
||||||
|
onDelete: 'CASCADE',
|
||||||
|
onUpdate: 'CASCADE',
|
||||||
|
})
|
||||||
|
@JoinColumn({ name: 'order_id' })
|
||||||
|
order: QueueOrder;
|
||||||
|
|
||||||
|
@Column({ type: 'bigint' })
|
||||||
|
date: number;
|
||||||
|
|
||||||
|
@OneToMany(() => QueueItemModel, (model) => model.ticket, {
|
||||||
|
cascade: true,
|
||||||
|
onDelete: 'CASCADE',
|
||||||
|
onUpdate: 'CASCADE',
|
||||||
|
})
|
||||||
|
items: QueueItem[];
|
||||||
|
}
|
||||||
|
|
||||||
|
@Entity(TABLE_NAME.QUEUE_ITEM)
|
||||||
|
export class QueueItemModel
|
||||||
|
extends BaseCoreModel<QueueItemModel>
|
||||||
|
implements QueueItem
|
||||||
|
{
|
||||||
|
@ManyToOne(() => QueueTicketModel, (model) => model.items, {
|
||||||
|
onDelete: 'CASCADE',
|
||||||
|
onUpdate: 'CASCADE',
|
||||||
|
})
|
||||||
|
@JoinColumn({ name: 'ticket_id' })
|
||||||
|
ticket: QueueTicket;
|
||||||
|
|
||||||
|
@Column('varchar')
|
||||||
|
item_id: string;
|
||||||
|
|
||||||
|
@ManyToOne(() => ItemModel)
|
||||||
|
@JoinColumn({ name: 'item_id' })
|
||||||
|
item: ItemEntity;
|
||||||
|
|
||||||
|
@Column('int')
|
||||||
|
qty: number;
|
||||||
|
}
|
|
@ -0,0 +1,25 @@
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
import { BaseDataService } from 'src/core/modules/data/service/base-data.service';
|
||||||
|
import { InjectRepository } from '@nestjs/typeorm';
|
||||||
|
import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
|
||||||
|
import { Repository } from 'typeorm';
|
||||||
|
import { QueueTicket } from '../../domain/entities/ticket.entity';
|
||||||
|
import { QueueOrderModel, QueueTicketModel } from '../models/queue.model';
|
||||||
|
import { QueueOrder } from '../../domain/entities/order.entity';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class TicketDataService extends BaseDataService<QueueTicket> {
|
||||||
|
constructor(
|
||||||
|
@InjectRepository(QueueTicketModel, CONNECTION_NAME.DEFAULT)
|
||||||
|
private repo: Repository<QueueTicketModel>,
|
||||||
|
|
||||||
|
@InjectRepository(QueueOrderModel, CONNECTION_NAME.DEFAULT)
|
||||||
|
private order: Repository<QueueOrderModel>,
|
||||||
|
) {
|
||||||
|
super(repo);
|
||||||
|
}
|
||||||
|
|
||||||
|
async createQueueOrder(order: QueueOrder): Promise<QueueOrderModel> {
|
||||||
|
return await this.order.save(order);
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,10 @@
|
||||||
|
import { BaseCoreEntity } from 'src/core/modules/domain/entities/base-core.entity';
|
||||||
|
import { QueueTicket } from './ticket.entity';
|
||||||
|
|
||||||
|
export interface QueueOrder extends BaseCoreEntity {
|
||||||
|
code: string;
|
||||||
|
customer: string;
|
||||||
|
phone: string;
|
||||||
|
date: number;
|
||||||
|
tickets: QueueTicket[];
|
||||||
|
}
|
|
@ -0,0 +1,10 @@
|
||||||
|
import { BaseCoreEntity } from 'src/core/modules/domain/entities/base-core.entity';
|
||||||
|
import { ItemEntity } from 'src/modules/item-related/item/domain/entities/item.entity';
|
||||||
|
import { QueueTicket } from './ticket.entity';
|
||||||
|
|
||||||
|
export interface QueueItem extends BaseCoreEntity {
|
||||||
|
ticket?: QueueTicket;
|
||||||
|
item?: ItemEntity;
|
||||||
|
item_id: string;
|
||||||
|
qty: number;
|
||||||
|
}
|
|
@ -0,0 +1,13 @@
|
||||||
|
import { BaseCoreEntity } from 'src/core/modules/domain/entities/base-core.entity';
|
||||||
|
import { QueueOrder } from './order.entity';
|
||||||
|
import { QueueItem } from './queue-item.entity';
|
||||||
|
|
||||||
|
// eslint-disable-next-line @typescript-eslint/no-empty-interface
|
||||||
|
export interface QueueTicket extends BaseCoreEntity {
|
||||||
|
code: string;
|
||||||
|
customer: string;
|
||||||
|
phone: string;
|
||||||
|
date: number;
|
||||||
|
order?: QueueOrder;
|
||||||
|
items: QueueItem[];
|
||||||
|
}
|
|
@ -0,0 +1,6 @@
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class QueueOrchestrator {
|
||||||
|
// constructor() {}
|
||||||
|
}
|
|
@ -0,0 +1,24 @@
|
||||||
|
import {
|
||||||
|
Body,
|
||||||
|
Controller,
|
||||||
|
Delete,
|
||||||
|
Param,
|
||||||
|
Patch,
|
||||||
|
Post,
|
||||||
|
Put,
|
||||||
|
Res,
|
||||||
|
} from '@nestjs/common';
|
||||||
|
|
||||||
|
import { MODULE_NAME } from 'src/core/strings/constants/module.constants';
|
||||||
|
import { ApiBearerAuth, ApiTags } from '@nestjs/swagger';
|
||||||
|
|
||||||
|
import { Public } from 'src/core/guards';
|
||||||
|
import { QueueOrchestrator } from '../../domain/queue.orchestrator';
|
||||||
|
|
||||||
|
@ApiTags(`Queue`)
|
||||||
|
@Controller(`v1/${MODULE_NAME.QUEUE}`)
|
||||||
|
@Public(false)
|
||||||
|
@ApiBearerAuth('JWT')
|
||||||
|
export class QueueController {
|
||||||
|
constructor(private orchestrator: QueueOrchestrator) {}
|
||||||
|
}
|
|
@ -0,0 +1,46 @@
|
||||||
|
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 { CqrsModule } from '@nestjs/cqrs';
|
||||||
|
|
||||||
|
import { ItemModel } from 'src/modules/item-related/item/data/models/item.model';
|
||||||
|
import {
|
||||||
|
QueueItemModel,
|
||||||
|
QueueOrderModel,
|
||||||
|
QueueTicketModel,
|
||||||
|
} from './data/models/queue.model';
|
||||||
|
import { QueueController } from './infrastructure/controllers/queue.controller';
|
||||||
|
import { QueueOrchestrator } from './domain/queue.orchestrator';
|
||||||
|
import { QueueTransactionHandler } from './infrastructure/handlers/transaction.handler';
|
||||||
|
import { TransactionDataService } from '../transaction/transaction/data/services/transaction-data.service';
|
||||||
|
import { TransactionModel } from '../transaction/transaction/data/models/transaction.model';
|
||||||
|
import { TicketDataService } from './data/services/ticket.service';
|
||||||
|
|
||||||
|
@Module({
|
||||||
|
imports: [
|
||||||
|
ConfigModule.forRoot(),
|
||||||
|
TypeOrmModule.forFeature(
|
||||||
|
[
|
||||||
|
QueueOrderModel,
|
||||||
|
QueueTicketModel,
|
||||||
|
QueueItemModel,
|
||||||
|
ItemModel,
|
||||||
|
TransactionModel,
|
||||||
|
],
|
||||||
|
CONNECTION_NAME.DEFAULT,
|
||||||
|
),
|
||||||
|
CqrsModule,
|
||||||
|
],
|
||||||
|
controllers: [QueueController],
|
||||||
|
providers: [
|
||||||
|
QueueTransactionHandler,
|
||||||
|
|
||||||
|
QueueOrchestrator,
|
||||||
|
|
||||||
|
TransactionDataService,
|
||||||
|
TicketDataService,
|
||||||
|
],
|
||||||
|
})
|
||||||
|
export class QueueModule {}
|
Loading…
Reference in New Issue