feat: item queue module

src/app.module.ts

@@ -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 { AuthService } from './core/guards/domain/services/auth.service';
 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({
   imports: [
@@ -107,6 +115,7 @@ import { ReportSummaryModule } from './modules/reports/report-summary/report-sum
         ItemModel,
         ItemCategoryModel,
         ItemRateModel,
+        ItemQueueModel,
         LogModel,
         LogUserLoginModel,
         NewsModel,
@@ -135,6 +144,11 @@ import { ReportSummaryModule } from './modules/reports/report-summary/report-sum
         // report
         ReportBookmarkModel,
         ExportReportHistoryModel,
+
+        // Queue
+        QueueOrderModel,
+        QueueTicketModel,
+        QueueItemModel,
       ],
       synchronize: false,
     }),
@@ -160,6 +174,7 @@ import { ReportSummaryModule } from './modules/reports/report-summary/report-sum
     ItemCategoryModule,
     ItemModule,
     ItemRateModule,
+    ItemQueueModule,
 
     // transaction
     PaymentMethodModule,
@@ -193,6 +208,8 @@ import { ReportSummaryModule } from './modules/reports/report-summary/report-sum
     SupersetModule,
 
     GateScanModule,
+
+    QueueModule,
   ],
   controllers: [],
   providers: [

src/core/modules/domain/usecase/managers/base-index.manager.ts

@@ -50,7 +50,7 @@ export abstract class BaseIndexManager<Entity> extends BaseReadManager {
 
         // jika searching status terdapat dalam enum, maka dia mencari specific data
         // ? 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);

src/core/strings/constants/module.constants.ts

@@ -4,6 +4,7 @@ export enum MODULE_NAME {
   GATE = 'gates',
   ITEM = 'items',
   ITEM_CATEGORY = 'item-categories',
+  ITEM_QUEUE = 'item-queues',
   ITEM_RATE = 'item-rates',
   NEWS = 'news',
   PAYMENT_METHOD = 'payment-methods',
@@ -25,4 +26,6 @@ export enum MODULE_NAME {
   REPORT_BOOKMARK = 'report-bookmark',
   REPORT_EXPORT = 'report-export',
   REPORT_SUMMARY = 'report-summary',
+
+  QUEUE = 'queue',
 }

src/core/strings/constants/table.constants.ts

@@ -4,6 +4,7 @@ export enum TABLE_NAME {
   FAQ = 'faqs',
   ITEM = 'items',
   ITEM_CATEGORY = 'item_categories',
+  ITEM_QUEUE = 'item_queues',
   ITEM_RATE = 'item_rates',
   GATE = 'gates',
   LOG = 'logs',
@@ -35,4 +36,8 @@ export enum TABLE_NAME {
 
   REPORT_BOOKMARK = 'report_bookmark',
   EXPORT_REPORT_HISTORY = 'export_report_history',
+
+  QUEUE_ORDER = 'queue_orders',
+  QUEUE_TICKET = 'queue_tickets',
+  QUEUE_ITEM = 'queue_items',
 }

src/database/migrations/1729151429165-queue-table.ts

@@ -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"`);
+  }
+}

src/database/migrations/1729248576381-video-url-to-json.ts

@@ -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"`);
+  }
+}

src/database/migrations/1729570177597-item-queues.ts

@@ -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"`);
+  }
+}

src/modules/item-related/item-queue/constants.ts

@@ -0,0 +1,7 @@
+export enum ItemType {
+  TIKET_MASUK = 'tiket masuk',
+  WAHANA = 'wahana',
+  BUNDLING = 'bundling',
+  FREE_GIFT = 'free gift',
+  OTHER = 'other',
+}

src/modules/item-related/item-queue/data/models/item-queue.model.ts

@@ -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[];
+}

src/modules/item-related/item-queue/data/services/item-queue-data.service.ts

@@ -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);
+  }
+}

src/modules/item-related/item-queue/data/services/item-queue-read.service.ts

@@ -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);
+  }
+}

src/modules/item-related/item-queue/domain/entities/filter-item-queue.entity.ts

@@ -0,0 +1,5 @@
+import { BaseFilterEntity } from 'src/core/modules/domain/entities/base-filter.entity';
+
+export interface FilterItemQueueEntity extends BaseFilterEntity {
+  item_types: string[];
+}

src/modules/item-related/item-queue/domain/entities/item-queue.entity.ts

@@ -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[];
+}

src/modules/item-related/item-queue/domain/usecases/item-queue-data.orchestrator.ts

@@ -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();
+  }
+}

src/modules/item-related/item-queue/domain/usecases/item-queue-read.orchestrator.ts

@@ -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();
+  }
+}

src/modules/item-related/item-queue/domain/usecases/managers/active-item-queue.manager.ts

@@ -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 [];
+  }
+}

src/modules/item-related/item-queue/domain/usecases/managers/batch-active-item-queue.manager.ts

@@ -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;
+  }
+}

src/modules/item-related/item-queue/domain/usecases/managers/batch-confirm-item-queue.manager.ts

@@ -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;
+  }
+}

src/modules/item-related/item-queue/domain/usecases/managers/batch-delete-item-queue.manager.ts

@@ -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;
+  }
+}

src/modules/item-related/item-queue/domain/usecases/managers/batch-inactive-item-queue.manager.ts

@@ -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;
+  }
+}

src/modules/item-related/item-queue/domain/usecases/managers/confirm-item-queue.manager.ts

@@ -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 [];
+  }
+}

src/modules/item-related/item-queue/domain/usecases/managers/create-item-queue.manager.ts

@@ -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;
+  }
+}

src/modules/item-related/item-queue/domain/usecases/managers/delete-item-queue.manager.ts

@@ -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 [];
+  }
+}

src/modules/item-related/item-queue/domain/usecases/managers/detail-item-queue.manager.ts

@@ -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,
+    };
+  }
+}

src/modules/item-related/item-queue/domain/usecases/managers/inactive-item-queue.manager.ts

@@ -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 [];
+  }
+}

src/modules/item-related/item-queue/domain/usecases/managers/index-item-queue.manager.ts

@@ -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;
+  }
+}

src/modules/item-related/item-queue/domain/usecases/managers/update-item-queue.manager.ts

@@ -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 [];
+  }
+}

src/modules/item-related/item-queue/infrastructure/dto/filter-item-queue.dto.ts

@@ -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[];
+}

src/modules/item-related/item-queue/infrastructure/dto/item-queue.dto.ts

@@ -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[];
+}

src/modules/item-related/item-queue/infrastructure/item-queue-data.controller.ts

@@ -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);
+  }
+}

src/modules/item-related/item-queue/infrastructure/item-queue-read.controller.ts

@@ -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);
+  }
+}

src/modules/item-related/item-queue/item-queue.module.ts

@@ -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 {}

src/modules/item-related/item/data/models/item.model.ts

@@ -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 { 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 { ItemQueueModel } from 'src/modules/item-related/item-queue/data/models/item-queue.model';
 
 @Entity(TABLE_NAME.ITEM)
 export class ItemModel
@@ -28,8 +29,8 @@ export class ItemModel
   @Column('varchar', { name: 'image_url', nullable: true })
   image_url: string;
 
-  @Column('varchar', { nullable: true })
-  video_url: string;
+  @Column('json', { nullable: true })
+  video_url: string[];
 
   @Column('enum', {
     name: 'item_type',
@@ -85,6 +86,13 @@ export class ItemModel
   @JoinColumn({ name: 'item_category_id' })
   item_category: ItemCategoryModel;
 
+  @ManyToOne(() => ItemQueueModel, (model) => model.items, {
+    onUpdate: 'CASCADE',
+    onDelete: 'CASCADE',
+  })
+  @JoinColumn({ name: 'item_queue_id' })
+  item_queue: ItemQueueModel;
+
   // relation ke tenant
   // ? karena item bisajadi merupakan item dari tenant
   @Column('varchar', { name: 'tenant_id', nullable: true })

src/modules/item-related/item/domain/entities/item.entity.ts

@@ -6,7 +6,7 @@ export interface ItemEntity extends BaseStatusEntity {
   name: string;
   item_type: ItemType;
   image_url: string;
-  video_url?: string;
+  video_url?: string[];
 
   hpp: number;
   sales_margin: number;

src/modules/item-related/item/infrastructure/dto/item.dto.ts

@@ -12,6 +12,7 @@ import {
   ValidateIf,
 } from 'class-validator';
 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 {
   @ApiProperty({
@@ -32,13 +33,16 @@ export class ItemDto extends BaseStatusDto implements ItemEntity {
   image_url: string;
 
   @ApiProperty({
-    type: String,
+    isArray: true,
     required: false,
-    example: '...',
   })
-  @IsString()
+  // @IsString()
   @ValidateIf((body) => body.video_url)
-  video_url: string;
+  @Transform(({ value }) => {
+    if (!value) return [];
+    return Array.isArray(value) ? value : [value];
+  })
+  video_url: string[];
 
   @ApiProperty({
     type: 'string',

src/modules/item-related/item/infrastructure/item-read.controller.ts

@@ -41,18 +41,18 @@ export class ItemReadController {
   }
 }
 
-@ApiTags(`Item Queue - Read`)
-@Controller(`v1/item-queue`)
-@Public(true)
-export class ItemReadQueueController {
-  constructor(private orchestrator: ItemReadOrchestrator) {}
+// @ApiTags(`Item Queue - Read`)
+// @Controller(`v1/item-queue`)
+// @Public(true)
+// export class ItemReadQueueController {
+//   constructor(private orchestrator: ItemReadOrchestrator) {}
 
-  @Get()
-  @Pagination()
-  @ExcludePrivilege()
-  async indexQueue(
-    @Query() params: FilterItemDto,
-  ): Promise<PaginationResponse<ItemEntity>> {
-    return await this.orchestrator.indexQueue(params);
-  }
-}
+//   @Get()
+//   @Pagination()
+//   @ExcludePrivilege()
+//   async indexQueue(
+//     @Query() params: FilterItemDto,
+//   ): Promise<PaginationResponse<ItemEntity>> {
+//     return await this.orchestrator.indexQueue(params);
+//   }
+// }

src/modules/item-related/item/item.module.ts

@@ -6,7 +6,7 @@ import { ItemDataService } from './data/services/item-data.service';
 import { ItemReadService } from './data/services/item-read.service';
 import {
   ItemReadController,
-  ItemReadQueueController,
+  // ItemReadQueueController,
 } from './infrastructure/item-read.controller';
 import { ItemReadOrchestrator } from './domain/usecases/item-read.orchestrator';
 import { ItemDataController } from './infrastructure/item-data.controller';
@@ -44,7 +44,7 @@ import { IndexItemQueueManager } from './domain/usecases/managers/index-queue-it
   controllers: [
     ItemDataController,
     ItemReadController,
-    ItemReadQueueController,
+    // ItemReadQueueController,
   ],
   providers: [
     IndexItemManager,

src/modules/queue/data/models/queue.model.ts

@@ -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;
+}

src/modules/queue/data/services/ticket.service.ts

@@ -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);
+  }
+}

src/modules/queue/domain/entities/order.entity.ts

@@ -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[];
+}

src/modules/queue/domain/entities/queue-item.entity.ts

@@ -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;
+}

src/modules/queue/domain/entities/ticket.entity.ts

@@ -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[];
+}

src/modules/queue/domain/queue.orchestrator.ts

@@ -0,0 +1,6 @@
+import { Injectable } from '@nestjs/common';
+
+@Injectable()
+export class QueueOrchestrator {
+  //   constructor() {}
+}

src/modules/queue/infrastructure/controllers/queue.controller.ts

@@ -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) {}
+}

src/modules/queue/queue.module.ts

@@ -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 {}