feat: add clear couch transaction API

Reviewed-on: #113

.drone.yml

@@ -2,18 +2,42 @@ kind: pipeline
 type: docker
 name: server
 steps:
-  - name: build
+  # - name: build
-    image: appleboy/drone-ssh
+  #   image: appleboy/drone-ssh
+  #   settings:
+  #     host:
+  #       - 172.10.10.10
+  #     username: eigen
+  #     key:
+  #       from_secret: DEVOPS_SSH_PRIVATE_OPEN
+  #     port: 22
+  #     script:
+  #       - cd /home/eigen/PROJECT/POS/POS.DEV/BE
+  #       - sh build.sh
+  #   when:
+  #     ref:
+  #       - refs/tags/devel_*
+  #       - refs/tags/*-alpha.*
+  - name: build-testing
+    image: plugins/docker
     settings:
-      host:
+      registry: registry.eigen.co.id
-        - 172.10.10.10
+      repo: registry.eigen.co.id/eigen/${DRONE_REPO_NAME}
-      username: eigen
+      tags: ${DRONE_TAG}
-      key:
+      custom_dns: 172.10.10.16
-        from_secret: DEVOPS_SSH_PRIVATE_OPEN
+    when:
-      port: 22
+      ref:
-      script:
+        - refs/tags/*-alpha.*
-        - cd /home/eigen/PROJECT/POS/POS.DEV/BE
+  - name: build-production
-        - sh build.sh
+    image: plugins/docker
+    settings:
+      registry: registry.eigen.co.id
+      repo: registry.eigen.co.id/eigen/${DRONE_REPO_NAME}
+      tags: ${DRONE_TAG}
+      custom_dns: 172.10.10.16
+    when:
+      ref:
+        - refs/tags/*-production.*
   - name: send-message
     image: plugins/webhook
     settings:
@@ -27,9 +51,59 @@ steps:
           "message": "Build {{repo.name}} sudah selesai"
         }
 trigger:
-  ref:
-    - refs/tags/devel_*
-    - refs/tags/*-alpha.*
   event:
     exclude:
       - promote
+---
+kind: pipeline
+type: docker
+name: kustomize
+
+clone:
+  disable: true
+
+steps:
+  - name: kustomize-testing
+    image: registry.k8s.io/kustomize/kustomize:v5.0.0
+    environment:
+      DEVOPS_SSH_PRIVATE:
+        from_secret: DEVOPS_SSH_PRIVATE
+      DEVOPS_SSH_PUBLIC:
+        from_secret: DEVOPS_SSH_PUBLIC
+      INFRASTRUCTURE_REPO: "k8s-kustomize-external"
+      DIRECTORY_NAME: "weplay-pos-testing"
+    commands:
+      - mkdir -p ~/.ssh &&
+      - echo $DEVOPS_SSH_PRIVATE | base64 -d > ~/.ssh/id_rsa &&
+      - echo $DEVOPS_SSH_PUBLIC | base64 -d > ~/.ssh/id_rsa.pub &&
+      - ssh-keyscan -H -p 2222 git.eigen.co.id >> ~/.ssh/known_hosts &&
+      - chmod 700 ~/.ssh/ &&
+      - chmod 600 ~/.ssh/id_rsa &&
+      - git clone ssh://git@git.eigen.co.id:2222/eigen/$INFRASTRUCTURE_REPO.git &&
+      - cd $INFRASTRUCTURE_REPO/$DIRECTORY_NAME
+      - kustomize edit set image registry.eigen.co.id/eigen/$DRONE_REPO_NAME=registry.eigen.co.id/eigen/$DRONE_REPO_NAME:$DRONE_TAG &&
+      - git add . &&
+      - |-
+        git commit -m "feat: update $DRONE_REPO_NAME testing to $DRONE_TAG" &&
+      - git push origin master
+  - name: send-message
+    image: harbor.eigen.co.id/docker.com/plugins/webhook
+    settings:
+      urls: https://mattermost.eigen.co.id/api/v4/posts
+      content_type: application/json
+      headers:
+        - Authorization=Bearer 5zubexudb38uuradfa36qy98ca
+      template: |
+        {
+          "channel_id": "s1ekqde1c3du5p35g6budnuotc",
+          "message": "ALERT: {{ repo.name }} gagal update dengan tag ${DRONE_TAG}"
+        }
+    when:
+      status:
+        - failure
+trigger:
+  ref:
+    include:
+      - refs/tags/*-alpha.*
+depends_on:
+  - server

Dockerfile

@@ -5,11 +5,11 @@ COPY . .
 RUN yarn install
 RUN yarn build
 FROM node:18.17-alpine
-ARG env_target
+# ARG env_target
 WORKDIR /app
-RUN echo ${env_target}
+# RUN echo ${env_target}
-COPY env/$env_target /app/.env
+# COPY env/$env_target /app/.env
-COPY --from=builder /app/env/$env_target .env
+# COPY --from=builder /app/env/$env_target .env
 COPY --from=builder /app/node_modules ./node_modules
 COPY --from=builder /app/dist ./dist
 COPY --from=builder /app/assets ./assets

env/env.development

@@ -40,3 +40,10 @@ ASSETS="https://asset.sky.eigen.co.id/"
 
 GOOGLE_CALENDAR_KEY="AIzaSyCSg4P3uC9Z7kD1P4f3rf1BbBaz4Q-M55o"
 GOOGLE_CALENDAR_ID="326464ac296874c7121825f5ef2e2799baa90b51da240f0045aae22beec10bd5@group.calendar.google.com"
+
+SUPERSET_URL=https://dashboard.weplayground.eigen.co.id
+SUPERSET_ADMIN_USERNAME=admin
+SUPERSET_ADMIN_PASSWORD=admin
+
+WHATSAPP_BUSINESS_ACCOUNT_NUMBER_ID=604883366037548
+WHATSAPP_BUSINESS_ACCESS_TOKEN=EAAINOvRRiEEBO9yQsYDnYtjHZB7q1nZCwbBpRcxIGMDWajKZBtmWxNRKvPYkS95KQZBsZBOvSFyjiEg5CcCZBZBtaSZApxyV8fiA3cEyVwf7iVZBQP2YCTPRQZArMFeeXbO0uq5TGygmjsIz3M4YxcUHxPzKO4pKxIyxnzcoUZCqCSo1NqQSLVf3a0JyZAwgDXGL55dV

env/env.production

@@ -37,3 +37,10 @@ ASSETS="https://asset.sky.eigen.co.id/"
 
 GOOGLE_CALENDAR_KEY="AIzaSyCSg4P3uC9Z7kD1P4f3rf1BbBaz4Q-M55o"
 GOOGLE_CALENDAR_ID="326464ac296874c7121825f5ef2e2799baa90b51da240f0045aae22beec10bd5@group.calendar.google.com"
+
+SUPERSET_URL=https://dashboard.weplayground.eigen.co.id
+SUPERSET_ADMIN_USERNAME=admin
+SUPERSET_ADMIN_PASSWORD=admin
+
+WHATSAPP_BUSINESS_ACCOUNT_NUMBER_ID=604883366037548
+WHATSAPP_BUSINESS_ACCESS_TOKEN=EAAINOvRRiEEBO9yQsYDnYtjHZB7q1nZCwbBpRcxIGMDWajKZBtmWxNRKvPYkS95KQZBsZBOvSFyjiEg5CcCZBZBtaSZApxyV8fiA3cEyVwf7iVZBQP2YCTPRQZArMFeeXbO0uq5TGygmjsIz3M4YxcUHxPzKO4pKxIyxnzcoUZCqCSo1NqQSLVf3a0JyZAwgDXGL55dV

package.json

@@ -28,6 +28,7 @@
   },
   "dependencies": {
     "@faker-js/faker": "^8.4.1",
+    "@nestjs/axios": "^3.0.3",
     "@nestjs/common": "^10.0.0",
     "@nestjs/config": "^3.2.2",
     "@nestjs/core": "^10.0.0",
@@ -39,6 +40,7 @@
     "@nestjs/typeorm": "^10.0.2",
     "@types/multer": "^1.4.11",
     "algebra.js": "^0.2.6",
+    "axios": "^1.7.5",
     "bcrypt": "^5.1.1",
     "class-transformer": "^0.5.1",
     "class-validator": "^0.14.1",
@@ -47,6 +49,7 @@
     "exceljs": "^4.4.0",
     "fs-extra": "^11.2.0",
     "googleapis": "^140.0.0",
+    "gtts": "^0.2.1",
     "handlebars": "^4.7.8",
     "mathjs": "^13.0.2",
     "midtrans-client": "^1.3.1",

src/app.module.ts

@@ -45,8 +45,10 @@ import { GoogleCalendarModule } from './modules/configuration/google-calendar/go
 import { TransactionModule } from './modules/transaction/transaction/transaction.module';
 import { TransactionModel } from './modules/transaction/transaction/data/models/transaction.model';
 import {
+  TransactionBreakdownTaxModel,
   TransactionItemBreakdownModel,
   TransactionItemModel,
+  TransactionItemTaxModel,
 } from './modules/transaction/transaction/data/models/transaction-item.model';
 import { TransactionTaxModel } from './modules/transaction/transaction/data/models/transaction-tax.model';
 import { ReconciliationModule } from './modules/transaction/reconciliation/reconciliation.module';
@@ -75,6 +77,22 @@ import { MailModule } from './modules/configuration/mail/mail.module';
 import { PosLogModel } from './modules/configuration/log/data/models/pos-log.model';
 import { ExportModule } from './modules/configuration/export/export.module';
 import { TransactionDemographyModel } from './modules/transaction/transaction/data/models/transaction-demography.model';
+import { SupersetModule } from './modules/configuration/superset/superset.module';
+import { GateScanModule } from './modules/gates/gate.module';
+import { UserLoginModel } from './modules/user-related/user/data/models/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 { ReportSummaryModule } from './modules/reports/report-summary/report-summary.module';
+import { QueueModule } from './modules/queue/queue.module';
+import {
+  QueueOrderModel,
+  QueueTicketModel,
+  QueueItemModel,
+  QueueModel,
+} 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';
+import { QueueBucketModel } from './modules/queue/data/models/queue-bucket.model';
 
 @Module({
   imports: [
@@ -99,7 +117,9 @@ import { TransactionDemographyModel } from './modules/transaction/transaction/da
         ItemModel,
         ItemCategoryModel,
         ItemRateModel,
+        ItemQueueModel,
         LogModel,
+        LogUserLoginModel,
         NewsModel,
         PaymentMethodModel,
         PosLogModel,
@@ -115,13 +135,24 @@ import { TransactionDemographyModel } from './modules/transaction/transaction/da
         TransactionTaxModel,
         TransactionDemographyModel,
         TransactionItemBreakdownModel,
+        TransactionItemTaxModel,
+        TransactionBreakdownTaxModel,
         UserModel,
+        UserLoginModel,
+
         VipCategoryModel,
         VipCodeModel,
 
         // report
         ReportBookmarkModel,
         ExportReportHistoryModel,
+
+        // Queue
+        QueueOrderModel,
+        QueueTicketModel,
+        QueueItemModel,
+        QueueModel,
+        QueueBucketModel,
       ],
       synchronize: false,
     }),
@@ -147,6 +178,7 @@ import { TransactionDemographyModel } from './modules/transaction/transaction/da
     ItemCategoryModule,
     ItemModule,
     ItemRateModule,
+    ItemQueueModule,
 
     // transaction
     PaymentMethodModule,
@@ -174,9 +206,18 @@ import { TransactionDemographyModel } from './modules/transaction/transaction/da
     ReportModule,
     ReportBookmarkModule,
     ReportExportModule,
+    ReportSummaryModule,
+
+    // superset
+    SupersetModule,
+
+    GateScanModule,
+
+    QueueModule,
   ],
   controllers: [],
   providers: [
+    AuthService,
     PrivilegeService,
     /**
      * By default all request from client will protect by JWT

src/core/guards/domain/jwt.guard.ts

@@ -7,10 +7,10 @@ import {
   UnauthorizedException,
 } from '@nestjs/common';
 import { Reflector } from '@nestjs/core';
-import { Observable } from 'rxjs';
 import { SessionService, UsersSession } from 'src/core/sessions';
 import { UNPROTECTED_URL } from '../constants';
 import { PrivilegeService } from './services/privilege.service';
+import { AuthService } from './services/auth.service';
 
 @Injectable({ scope: Scope.REQUEST })
 export class JWTGuard implements CanActivate {
@@ -18,14 +18,13 @@ export class JWTGuard implements CanActivate {
     protected readonly session: SessionService,
     protected readonly reflector: Reflector,
     protected readonly privilege: PrivilegeService,
+    protected readonly authService: AuthService,
   ) {}
 
   protected isPublic = false;
   protected userSession: UsersSession;
 
-  canActivate(
+  async canActivate(context: ExecutionContext) {
-    context: ExecutionContext,
-  ): boolean | Promise<boolean> | Observable<boolean> {
     /**
      * Check if access url is protected or not
      * By default `isUnprotected` equals `false`
@@ -61,9 +60,29 @@ export class JWTGuard implements CanActivate {
      */
     try {
       this.userSession = this.session.verifyToken(token);
+      await this.authService.verifyRegisteredLoginToken(token);
+
       Logger.log(`Access from ${this.userSession.name}`, 'AuthGuard');
       return true;
     } catch (error) {
+      const expiredError = error.message;
+      if (expiredError === 'jwt expired') {
+        const [, body] = token.split('.');
+        const bodyToken = JSON.parse(atob(body));
+
+        const user = {
+          role: bodyToken.role,
+          user_id: bodyToken.id,
+          username: bodyToken.username,
+          user_privilege_id: bodyToken.user_privilege_id,
+          item_id: bodyToken.item_id,
+          item_name: bodyToken.item_name,
+          source: bodyToken.source,
+        };
+
+        this.authService.logoutUser(user, token);
+      }
+
       throw new UnauthorizedException({
         code: 10001,
         message:

src/core/guards/domain/roles.guard.ts

@@ -9,7 +9,7 @@ import { MAIN_MENU } from '../constants';
 @Injectable()
 export class RolesGuard extends JWTGuard {
   async canActivate(context: ExecutionContext): Promise<boolean> {
-    super.canActivate(context);
+    await super.canActivate(context);
 
     // jika endpoint tersebut bukan public, maka lakukan check lanjutan
     if (!this.isPublic) {

src/core/guards/domain/services/auth.service.ts

@@ -0,0 +1,78 @@
+import {
+  HttpStatus,
+  Injectable,
+  Scope,
+  UnauthorizedException,
+} from '@nestjs/common';
+import { InjectDataSource } from '@nestjs/typeorm';
+import {
+  CONNECTION_NAME,
+  OPERATION,
+} from 'src/core/strings/constants/base.constants';
+import { DataSource } from 'typeorm';
+import { UserRole } from 'src/modules/user-related/user/constants';
+import { UserModel } from 'src/modules/user-related/user/data/models/user.model';
+import { AppSource, LogUserType } from 'src/core/helpers/constant';
+import { EventBus } from '@nestjs/cqrs';
+import { LogUserLoginEvent } from 'src/modules/configuration/log/domain/entities/log-user-login.event';
+import { UserLoginModel } from 'src/modules/user-related/user/data/models/user-login.model';
+
+interface UserEntity {
+  user_id: string;
+  username: string;
+  role: UserRole;
+  user_privilege_id: string;
+  item_id: string;
+  item_name: string;
+  source: AppSource;
+}
+
+@Injectable({ scope: Scope.REQUEST })
+export class AuthService {
+  constructor(
+    @InjectDataSource(CONNECTION_NAME.DEFAULT)
+    protected readonly dataSource: DataSource,
+
+    private eventBus: EventBus,
+  ) {}
+
+  get repository() {
+    return this.dataSource.getRepository(UserLoginModel);
+  }
+
+  async logoutUser(user: UserEntity, token: string) {
+    await this.repository.delete({ login_token: token });
+
+    const userLogout = {
+      type: LogUserType.logout,
+      created_at: new Date().getTime(),
+      name: user.username,
+      user_privilege_id: user.user_privilege_id,
+      ...user,
+    };
+
+    this.eventBus.publish(
+      new LogUserLoginEvent({
+        id: user.user_id,
+        old: null,
+        data: userLogout,
+        user: userLogout as any,
+        description: 'Logout',
+        module: UserModel.name,
+        op: OPERATION.UPDATE,
+      }),
+    );
+  }
+
+  async verifyRegisteredLoginToken(token: string) {
+    const data = await this.repository.findOneBy({ login_token: token });
+
+    if (!data) {
+      throw new UnauthorizedException({
+        statusCode: HttpStatus.UNAUTHORIZED,
+        message: `Invalid token`,
+        error: 'Unauthorized',
+      });
+    }
+  }
+}

src/core/helpers/constant/index.ts

@@ -0,0 +1,11 @@
+export enum LogUserType {
+  login = 'login',
+  logout = 'logout',
+}
+
+export enum AppSource {
+  POS_ADMIN = 'POS_ADMIN',
+  POS_COUNTER = 'POS_COUNTER',
+  QUEUE_ADMIN = 'QUEUE_ADMIN',
+  QUEUE_CUSTOMER = 'QUEUE_CUSTOMER',
+}

src/core/helpers/path/upload-store-path.helper.ts

@@ -8,7 +8,9 @@ import { diskStorage } from 'multer';
 const MB = 1024 * 1024;
 
 const fileFilter = (req, file, callback) => {
-  if (file.mimetype.match(/\/(jpg|jpeg|png)$/)) {
+  if (
+    file.mimetype.match(/\/(jpg|jpeg|png|flv|mp4|m3u8|ts|3gp|mov|avi|wmv)$/)
+  ) {
     callback(null, true);
   } else {
     callback(

src/core/modules/domain/usecase/base.manager.ts

@@ -32,7 +32,7 @@ export abstract class BaseManager {
 
   setUser() {
     try {
-      this.user = this.userProvider?.user;
+      this.user = this.userProvider?.user ?? BLANK_USER;
     } catch (error) {
       this.user = BLANK_USER;
     }

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

@@ -71,7 +71,7 @@ export abstract class BaseCreateManager<Entity> extends BaseManager {
   }
 
   async publishEvents() {
-    this.eventBus.publish(
+    this.eventBus?.publish(
       new RecordLog({
         id: this.result['id'],
         old: null,

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/modules/domain/usecase/managers/base-update-status.manager.ts

@@ -1,6 +1,10 @@
 import { ValidateRelationHelper } from 'src/core/helpers/validation/validate-relation.helper';
 import { BaseManager } from '../base.manager';
-import { OPERATION, STATUS } from 'src/core/strings/constants/base.constants';
+import {
+  OPERATION,
+  QUEUE_STATUS,
+  STATUS,
+} from 'src/core/strings/constants/base.constants';
 import * as _ from 'lodash';
 import { RecordLog } from 'src/modules/configuration/log/domain/entities/log.event';
 
@@ -8,12 +12,12 @@ export abstract class BaseUpdateStatusManager<Entity> extends BaseManager {
   protected dataId: string;
   protected result: Entity;
   protected oldData: Entity;
-  protected dataStatus: STATUS;
+  protected dataStatus: STATUS | QUEUE_STATUS;
   protected relations = [];
   protected duplicateColumn: string[];
   abstract get entityTarget(): any;
 
-  setData(id: string, status: STATUS): void {
+  setData(id: string, status: STATUS | QUEUE_STATUS): void {
     /**
      * // TODO: Handle case confirm multiple tabs;
      * Pola id yang dikirim dirubah menjadi data_id___updated_at

src/core/modules/infrastructure/dto/base-filter.dto.ts

@@ -23,6 +23,7 @@ export class BaseFilterDto implements BaseFilterEntity {
   @IsNumber()
   limit = 10;
 
+  @ApiProperty({ type: String, required: false })
   q: string;
 
   @ApiProperty({ type: ['string'], required: false })

src/core/response/constants.ts

@@ -1 +1,2 @@
 export const PAGINATION_RESPONSE = 'PAGINATION_RESPONSE';
+export const GATE_RESPONSE = 'GATE_RESPONSE';

src/core/response/domain/decorators/pagination.response.ts

@@ -1,5 +1,5 @@
 import { SetMetadata } from '@nestjs/common';
-import { PAGINATION_RESPONSE } from '../../constants';
+import { GATE_RESPONSE, PAGINATION_RESPONSE } from '../../constants';
 
 /**
  * This decorator will tell the response,
@@ -7,3 +7,5 @@ import { PAGINATION_RESPONSE } from '../../constants';
  */
 export const Pagination = (isPagination = true) =>
   SetMetadata(PAGINATION_RESPONSE, isPagination);
+
+export const Gate = () => SetMetadata(GATE_RESPONSE, true);

src/core/response/domain/response.interceptor.ts

@@ -8,13 +8,20 @@ import { Observable } from 'rxjs';
 import { map } from 'rxjs/operators';
 import { Request } from 'express';
 import { Reflector } from '@nestjs/core';
-import { PAGINATION_RESPONSE } from '../constants';
+import { GATE_RESPONSE, PAGINATION_RESPONSE } from '../constants';
 import { createPaginationResponse } from './utils/pagination-meta.helper';
 
 @Injectable()
 export class TransformInterceptor implements NestInterceptor {
   constructor(protected readonly reflector: Reflector) {}
   intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
+    const isGate = this.reflector.getAllAndOverride<boolean>(GATE_RESPONSE, [
+      context.getHandler(),
+      context.getClass(),
+    ]);
+
+    if (isGate) return next.handle();
+
     const isPagination = this.reflector.getAllAndOverride<boolean>(
       PAGINATION_RESPONSE,
       [context.getHandler(), context.getClass()],

src/core/sessions/domain/entities/user-sessions.interface.ts

@@ -1,8 +1,11 @@
+import { AppSource } from 'src/core/helpers/constant';
 import { UserRole } from 'src/modules/user-related/user/constants';
 
 export interface UsersSession {
   id: number;
   name: string;
   role: UserRole;
+  source?: AppSource;
+  item_id?: string;
   user_privilege_id: string;
 }

src/core/sessions/domain/providers/user.ts

@@ -23,4 +23,9 @@ export class UserProvider {
     const [, token] = this.request.headers['authorization'].split(' ');
     return this.session.verifyToken(token);
   }
+
+  get token(): string {
+    const [, token] = this.request.headers['authorization'].split(' ');
+    return token;
+  }
 }

src/core/strings/constants/base.constants.ts

@@ -15,6 +15,11 @@ export enum STATUS {
   WAITING = 'waiting',
 }
 
+export enum QUEUE_STATUS {
+  DONE = 'done',
+  CALLED = 'called',
+}
+
 export enum ORDER_TYPE {
   ASC = 'ASC',
   DESC = 'DESC',

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',
@@ -24,4 +25,7 @@ export enum MODULE_NAME {
   REPORT = 'report',
   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',
@@ -22,8 +23,12 @@ export enum TABLE_NAME {
   TRANSACTION_ITEM = 'transaction_items',
   TRANSACTION_ITEM_BREAKDOWN = 'transaction_item_breakdowns',
   TRANSACTION_TAX = 'transaction_taxes',
+  TRANSACTION_ITEM_TAX = 'transaction_item_taxes',
+  TRANSACTION_ITEM_BREAKDOWN_TAX = 't_breakdown_item_taxes',
   TRANSACTION_DEMOGRAPHY = 'transaction_demographies',
   USER = 'users',
+  USER_LOGIN = 'users_login',
+  LOG_USER_LOGIN = 'log_users_login',
   USER_PRIVILEGE = 'user_privileges',
   USER_PRIVILEGE_CONFIGURATION = 'user_privilege_configurations',
   VIP_CATEGORY = 'vip_categories',
@@ -31,4 +36,10 @@ export enum TABLE_NAME {
 
   REPORT_BOOKMARK = 'report_bookmark',
   EXPORT_REPORT_HISTORY = 'export_report_history',
+
+  QUEUE = 'queues',
+  QUEUE_ORDER = 'queue_orders',
+  QUEUE_TICKET = 'queue_tickets',
+  QUEUE_ITEM = 'queue_items',
+  QUEUE_BUCKET = 'queue_bucket',
 }

src/database/migrations/1723716561482-fix-demography-nationality.ts

@@ -21,9 +21,6 @@ export class FixDemographyNationality1723716561482
     await queryRunner.query(
       `ALTER TABLE "transaction_demographies" DROP CONSTRAINT "FK_a2b705884bca06c148e3b35ab04"`,
     );
-    await queryRunner.query(
-      `ALTER TABLE "transaction_demographies" ADD CONSTRAINT "UQ_a2b705884bca06c148e3b35ab04" UNIQUE ("transaction_id")`,
-    );
     await queryRunner.query(
       `ALTER TABLE "transaction_demographies" ADD CONSTRAINT "FK_a2b705884bca06c148e3b35ab04" FOREIGN KEY ("transaction_id") REFERENCES "transactions"("id") ON DELETE CASCADE ON UPDATE CASCADE`,
     );
@@ -33,9 +30,6 @@ export class FixDemographyNationality1723716561482
     await queryRunner.query(
       `ALTER TABLE "transaction_demographies" DROP CONSTRAINT "FK_a2b705884bca06c148e3b35ab04"`,
     );
-    await queryRunner.query(
-      `ALTER TABLE "transaction_demographies" DROP CONSTRAINT "UQ_a2b705884bca06c148e3b35ab04"`,
-    );
     await queryRunner.query(
       `ALTER TABLE "transaction_demographies" ADD CONSTRAINT "FK_a2b705884bca06c148e3b35ab04" FOREIGN KEY ("transaction_id") REFERENCES "transactions"("id") ON DELETE CASCADE ON UPDATE CASCADE`,
     );

src/database/migrations/1723801180604-add-estimation-to-item.ts

@@ -5,7 +5,7 @@ export class AddEstimationToItem1723801180604 implements MigrationInterface {
 
   public async up(queryRunner: QueryRunner): Promise<void> {
     await queryRunner.query(
-      `ALTER TABLE "items" ADD "play_estimation" integer`,
+      `ALTER TABLE "items" ADD "play_estimation" numeric`,
     );
   }
 

src/database/migrations/1724233193743-add-breakdown-to-transaction-item.ts

@@ -0,0 +1,19 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddBreakdownToTransactionItem1724233193743
+  implements MigrationInterface
+{
+  name = 'AddBreakdownToTransactionItem1724233193743';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" ADD "breakdown_bundling" boolean NOT NULL DEFAULT false`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" DROP COLUMN "breakdown_bundling"`,
+    );
+  }
+}

src/database/migrations/1724240624025-add-value-to-demography.ts

@@ -0,0 +1,47 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddValueToDemography1724240624025 implements MigrationInterface {
+  name = 'AddValueToDemography1724240624025';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TYPE "public"."transaction_demographies_nationality_enum" RENAME TO "transaction_demographies_nationality_enum_old"`,
+    );
+    await queryRunner.query(
+      `CREATE TYPE "public"."transaction_demographies_nationality_enum" AS ENUM('local', 'foreign', 'mix', 'foreigner')`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_demographies" ALTER COLUMN "nationality" DROP DEFAULT`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_demographies" ALTER COLUMN "nationality" TYPE "public"."transaction_demographies_nationality_enum" USING "nationality"::"text"::"public"."transaction_demographies_nationality_enum"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_demographies" ALTER COLUMN "nationality" SET DEFAULT 'local'`,
+    );
+    await queryRunner.query(
+      `DROP TYPE "public"."transaction_demographies_nationality_enum_old"`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `CREATE TYPE "public"."transaction_demographies_nationality_enum_old" AS ENUM('local', 'foreign', 'mix')`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_demographies" ALTER COLUMN "nationality" DROP DEFAULT`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_demographies" ALTER COLUMN "nationality" TYPE "public"."transaction_demographies_nationality_enum_old" USING "nationality"::"text"::"public"."transaction_demographies_nationality_enum_old"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_demographies" ALTER COLUMN "nationality" SET DEFAULT 'local'`,
+    );
+    await queryRunner.query(
+      `DROP TYPE "public"."transaction_demographies_nationality_enum"`,
+    );
+    await queryRunner.query(
+      `ALTER TYPE "public"."transaction_demographies_nationality_enum_old" RENAME TO "transaction_demographies_nationality_enum"`,
+    );
+  }
+}

src/database/migrations/1724926316235-add-value-variable-formula.ts

@@ -0,0 +1,19 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddValueVariableFormula1724926316235
+  implements MigrationInterface
+{
+  name = 'AddValueVariableFormula1724926316235';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "price_formulas" ADD "value_for" character varying NOT NULL DEFAULT 'dpp'`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "price_formulas" DROP COLUMN "value_for"`,
+    );
+  }
+}

src/database/migrations/1725962197762-add-payment-date-bank-column-at-transaction.ts

@@ -0,0 +1,19 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddPaymentDateBankColumnAtTransaction1725962197762
+  implements MigrationInterface
+{
+  name = 'AddPaymentDateBankColumnAtTransaction1725962197762';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "transactions" ADD "payment_date_bank" date`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "transactions" DROP COLUMN "payment_date_bank"`,
+    );
+  }
+}

src/database/migrations/1726033041774-add-pos-name-column.ts

@@ -0,0 +1,21 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddPosNameColumn1726033041774 implements MigrationInterface {
+  name = 'AddPosNameColumn1726033041774';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "transactions" ADD "creator_counter_name" character varying`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "logs_pos" ADD "pos_name" character varying`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`ALTER TABLE "logs_pos" DROP COLUMN "pos_name"`);
+    await queryRunner.query(
+      `ALTER TABLE "transactions" DROP COLUMN "creator_counter_name"`,
+    );
+  }
+}

src/database/migrations/1726041175749-add-flag-role-queue.ts

@@ -0,0 +1,43 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddFlagRoleQueue1726041175749 implements MigrationInterface {
+  name = 'AddFlagRoleQueue1726041175749';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TYPE "public"."users_role_enum" RENAME TO "users_role_enum_old"`,
+    );
+    await queryRunner.query(
+      `CREATE TYPE "public"."users_role_enum" AS ENUM('superadmin', 'staff', 'tenant', 'queue_admin')`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users" ALTER COLUMN "role" DROP DEFAULT`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users" ALTER COLUMN "role" TYPE "public"."users_role_enum" USING "role"::"text"::"public"."users_role_enum"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users" ALTER COLUMN "role" SET DEFAULT 'staff'`,
+    );
+    await queryRunner.query(`DROP TYPE "public"."users_role_enum_old"`);
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `CREATE TYPE "public"."users_role_enum_old" AS ENUM('superadmin', 'staff', 'tenant')`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users" ALTER COLUMN "role" DROP DEFAULT`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users" ALTER COLUMN "role" TYPE "public"."users_role_enum_old" USING "role"::"text"::"public"."users_role_enum_old"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users" ALTER COLUMN "role" SET DEFAULT 'staff'`,
+    );
+    await queryRunner.query(`DROP TYPE "public"."users_role_enum"`);
+    await queryRunner.query(
+      `ALTER TYPE "public"."users_role_enum_old" RENAME TO "users_role_enum"`,
+    );
+  }
+}

src/database/migrations/1726045820711-add-tax-item-transaction.ts

@@ -0,0 +1,73 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddTaxItemTransaction1726045820711 implements MigrationInterface {
+  name = 'AddTaxItemTransaction1726045820711';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `CREATE TABLE "transaction_item_taxes" ("id" uuid NOT NULL DEFAULT uuid_generate_v4(), "tax_id" character varying, "tax_name" character varying, "taxt_value" numeric, "tax_total_value" numeric, "transaction_id" uuid, CONSTRAINT "PK_fc5f6da61b24eb5bfdd503b0a0d" PRIMARY KEY ("id"))`,
+    );
+    await queryRunner.query(
+      `CREATE TABLE "t_breakdown_item_taxes" ("id" uuid NOT NULL DEFAULT uuid_generate_v4(), "tax_id" character varying, "tax_name" character varying, "taxt_value" numeric, "tax_total_value" numeric, "transaction_id" uuid, CONSTRAINT "PK_a1ef08d2c68169a50102aa70eca" PRIMARY KEY ("id"))`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" ADD "total_profit_share" numeric`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" ADD "total_profit_share" numeric`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_taxes" ADD CONSTRAINT "FK_f5c4966a381d903899cafb4b5ba" FOREIGN KEY ("transaction_id") REFERENCES "transaction_items"("id") ON DELETE CASCADE ON UPDATE CASCADE`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "t_breakdown_item_taxes" ADD CONSTRAINT "FK_74bedce7e94f6707ddf26ef0c0f" FOREIGN KEY ("transaction_id") REFERENCES "transaction_item_breakdowns"("id") ON DELETE CASCADE ON UPDATE CASCADE`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" ADD "payment_total_dpp" numeric`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" ADD "payment_total_dpp" numeric`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" ADD "payment_total_tax" numeric`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" ADD "payment_total_tax" numeric`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" ADD "total_share_tenant" numeric`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "t_breakdown_item_taxes" DROP CONSTRAINT "FK_74bedce7e94f6707ddf26ef0c0f"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_taxes" DROP CONSTRAINT "FK_f5c4966a381d903899cafb4b5ba"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" DROP COLUMN "total_profit_share"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" DROP COLUMN "total_profit_share"`,
+    );
+    await queryRunner.query(`DROP TABLE "t_breakdown_item_taxes"`);
+    await queryRunner.query(`DROP TABLE "transaction_item_taxes"`);
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" DROP COLUMN "payment_total_dpp"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" DROP COLUMN "payment_total_dpp"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" DROP COLUMN "payment_total_tax"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" DROP COLUMN "payment_total_tax"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" DROP COLUMN "total_share_tenant"`,
+    );
+  }
+}

src/database/migrations/1726115025759-add-table-user-login.ts

@@ -0,0 +1,21 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddTableUserLogin1726115025759 implements MigrationInterface {
+  name = 'AddTableUserLogin1726115025759';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `CREATE TABLE "users_login" ("id" uuid NOT NULL DEFAULT uuid_generate_v4(), "login_date" bigint NOT NULL, "login_token" character varying, "user_id" uuid, CONSTRAINT "REL_2a80a213b51423ce5b8211f058" UNIQUE ("user_id"), CONSTRAINT "PK_e564194a9a22f8c623354284f75" PRIMARY KEY ("id"))`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users_login" ADD CONSTRAINT "FK_2a80a213b51423ce5b8211f0584" FOREIGN KEY ("user_id") REFERENCES "users"("id") ON DELETE NO ACTION ON UPDATE NO ACTION`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "users_login" DROP CONSTRAINT "FK_2a80a213b51423ce5b8211f0584"`,
+    );
+    await queryRunner.query(`DROP TABLE "users_login"`);
+  }
+}

src/database/migrations/1726122619596-update-table-user-login.ts

@@ -0,0 +1,23 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class UpdateTableUserLogin1726122619596 implements MigrationInterface {
+  name = 'UpdateTableUserLogin1726122619596';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "users_login" DROP CONSTRAINT "FK_2a80a213b51423ce5b8211f0584"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users_login" ADD CONSTRAINT "FK_2a80a213b51423ce5b8211f0584" FOREIGN KEY ("user_id") REFERENCES "users"("id") ON DELETE CASCADE ON UPDATE CASCADE`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "users_login" DROP CONSTRAINT "FK_2a80a213b51423ce5b8211f0584"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users_login" ADD CONSTRAINT "FK_2a80a213b51423ce5b8211f0584" FOREIGN KEY ("user_id") REFERENCES "users"("id") ON DELETE NO ACTION ON UPDATE NO ACTION`,
+    );
+  }
+}

src/database/migrations/1726123955427-add-table-log-user-login.ts

@@ -0,0 +1,23 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddTableLogUserLogin1726123955427 implements MigrationInterface {
+  name = 'AddTableLogUserLogin1726123955427';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `CREATE TYPE "public"."log_users_login_type_enum" AS ENUM('login', 'logout')`,
+    );
+    await queryRunner.query(
+      `CREATE TYPE "public"."log_users_login_role_enum" AS ENUM('superadmin', 'staff', 'tenant', 'queue_admin')`,
+    );
+    await queryRunner.query(
+      `CREATE TABLE "log_users_login" ("id" uuid NOT NULL DEFAULT uuid_generate_v4(), "type" "public"."log_users_login_type_enum", "role" "public"."log_users_login_role_enum", "user_id" uuid, "username" character varying, "created_at" bigint, CONSTRAINT "PK_75141588aa6ee560504f7d3adce" PRIMARY KEY ("id"))`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`DROP TABLE "log_users_login"`);
+    await queryRunner.query(`DROP TYPE "public"."log_users_login_role_enum"`);
+    await queryRunner.query(`DROP TYPE "public"."log_users_login_type_enum"`);
+  }
+}

src/database/migrations/1726139426994-add-column-item_id.ts

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

src/database/migrations/1726141393404-add-column-item_name.ts

@@ -0,0 +1,23 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddColumnItemName1726141393404 implements MigrationInterface {
+  name = 'AddColumnItemName1726141393404';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "users_login" ADD "item_name" character varying`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "log_users_login" ADD "item_name" character varying`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "log_users_login" DROP COLUMN "item_name"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users_login" DROP COLUMN "item_name"`,
+    );
+  }
+}

src/database/migrations/1726365023179-add-formula-to-tax.ts

@@ -0,0 +1,17 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddFormulaToTax1726365023179 implements MigrationInterface {
+  name = 'AddFormulaToTax1726365023179';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`ALTER TABLE "taxes" ADD "formula_render" json`);
+    await queryRunner.query(
+      `ALTER TABLE "taxes" ADD "formula_string" character varying`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`ALTER TABLE "taxes" DROP COLUMN "formula_string"`);
+    await queryRunner.query(`ALTER TABLE "taxes" DROP COLUMN "formula_render"`);
+  }
+}

src/database/migrations/1726642119207-change-user-login-relation.ts

@@ -0,0 +1,35 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class ChangeUserLoginRelation1726642119207
+  implements MigrationInterface
+{
+  name = 'ChangeUserLoginRelation1726642119207';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`ALTER TABLE "users" DROP COLUMN "refresh_token"`);
+    await queryRunner.query(
+      `ALTER TABLE "users_login" DROP CONSTRAINT "FK_2a80a213b51423ce5b8211f0584"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users_login" DROP CONSTRAINT "REL_2a80a213b51423ce5b8211f058"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users_login" ADD CONSTRAINT "FK_2a80a213b51423ce5b8211f0584" FOREIGN KEY ("user_id") REFERENCES "users"("id") ON DELETE CASCADE ON UPDATE CASCADE`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "users_login" DROP CONSTRAINT "FK_2a80a213b51423ce5b8211f0584"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users_login" ADD CONSTRAINT "REL_2a80a213b51423ce5b8211f058" UNIQUE ("user_id")`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users_login" ADD CONSTRAINT "FK_2a80a213b51423ce5b8211f0584" FOREIGN KEY ("user_id") REFERENCES "users"("id") ON DELETE CASCADE ON UPDATE CASCADE`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users" ADD "refresh_token" character varying`,
+    );
+  }
+}

src/database/migrations/1726642499135-add-column-source-at-user-login.ts

@@ -0,0 +1,29 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddColumnSourceAtUserLogin1726642499135
+  implements MigrationInterface
+{
+  name = 'AddColumnSourceAtUserLogin1726642499135';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `CREATE TYPE "public"."users_login_role_enum" AS ENUM('superadmin', 'staff', 'tenant', 'queue_admin')`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users_login" ADD "role" "public"."users_login_role_enum"`,
+    );
+    await queryRunner.query(
+      `CREATE TYPE "public"."users_login_source_enum" AS ENUM('POS_ADMIN', 'POS_COUNTER', 'QUEUE_ADMIN', 'QUEUE_CUSTOMER')`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "users_login" ADD "source" "public"."users_login_source_enum"`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`ALTER TABLE "users_login" DROP COLUMN "source"`);
+    await queryRunner.query(`DROP TYPE "public"."users_login_source_enum"`);
+    await queryRunner.query(`ALTER TABLE "users_login" DROP COLUMN "role"`);
+    await queryRunner.query(`DROP TYPE "public"."users_login_role_enum"`);
+  }
+}

src/database/migrations/1726647442006-add-source-on-log-login.ts

@@ -0,0 +1,21 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddSourceOnLogLogin1726647442006 implements MigrationInterface {
+  name = 'AddSourceOnLogLogin1726647442006';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `CREATE TYPE "public"."log_users_login_source_enum" AS ENUM('POS_ADMIN', 'POS_COUNTER', 'QUEUE_ADMIN', 'QUEUE_CUSTOMER')`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "log_users_login" ADD "source" "public"."log_users_login_source_enum"`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "log_users_login" DROP COLUMN "source"`,
+    );
+    await queryRunner.query(`DROP TYPE "public"."log_users_login_source_enum"`);
+  }
+}

src/database/migrations/1726824289989-add-discount-for-item-transaction.ts

@@ -0,0 +1,43 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddDiscountForItemTransaction1726824289989
+  implements MigrationInterface
+{
+  name = 'AddDiscountForItemTransaction1726824289989';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" ADD "subtotal" numeric`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" ADD "discount_value" numeric`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" ADD "subtotal" numeric`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" ADD "discount_value" numeric`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" ADD "total_price" numeric`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" DROP COLUMN "total_price"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" DROP COLUMN "discount_value"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" DROP COLUMN "subtotal"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" DROP COLUMN "discount_value"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" DROP COLUMN "subtotal"`,
+    );
+  }
+}

src/database/migrations/1726830293878-change-column-name.ts

@@ -0,0 +1,23 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class ChangeColumnName1726830293878 implements MigrationInterface {
+  name = 'ChangeColumnName1726830293878';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" RENAME COLUMN "subtotal" TO "total_net_price"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" RENAME COLUMN "subtotal" TO "total_net_price"`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "transaction_item_breakdowns" RENAME COLUMN "total_net_price" TO "subtotal"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" RENAME COLUMN "total_net_price" TO "subtotal"`,
+    );
+  }
+}

src/database/migrations/1728377112337-add-discount-value-to-voucher.ts

@@ -0,0 +1,25 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddDiscountValueToVoucher1728377112337
+  implements MigrationInterface
+{
+  name = 'AddDiscountValueToVoucher1728377112337';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "vip_codes" ADD "discount_value" numeric`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "vip_codes" ALTER COLUMN "discount" DROP NOT NULL`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "vip_codes" ALTER COLUMN "discount" SET NOT NULL`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "vip_codes" DROP COLUMN "discount_value"`,
+    );
+  }
+}

src/database/migrations/1729072422409-item-video-and-vip-pass.ts

@@ -0,0 +1,21 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class ItemVideoAndVipPass1729072422409 implements MigrationInterface {
+  name = 'ItemVideoAndVipPass1729072422409';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "items" ADD "video_url" character varying`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "vip_categories" ADD "has_vip_pass" boolean NOT NULL DEFAULT false`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "vip_categories" DROP COLUMN "has_vip_pass"`,
+    );
+    await queryRunner.query(`ALTER TABLE "items" DROP COLUMN "video_url"`);
+  }
+}

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 SET NULL 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/database/migrations/1729582398827-item-queue-on-delete.ts

@@ -0,0 +1,25 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class ItemQueueOnDelete1729582398827 implements MigrationInterface {
+  name = 'ItemQueueOnDelete1729582398827';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "items" DROP CONSTRAINT "FK_2cbbeb03e176addcf60d65f7c9c"`,
+    );
+
+    await queryRunner.query(
+      `ALTER TABLE "items" ADD CONSTRAINT "FK_2cbbeb03e176addcf60d65f7c9c" FOREIGN KEY ("item_queue_id") REFERENCES "item_queues"("id") ON DELETE SET NULL 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" ADD CONSTRAINT "FK_2cbbeb03e176addcf60d65f7c9c" FOREIGN KEY ("item_queue_id") REFERENCES "item_queues"("id") ON DELETE CASCADE ON UPDATE CASCADE`,
+    );
+  }
+}

src/database/migrations/1729653046392-add-transaction-id-to-queue-order.ts

@@ -0,0 +1,19 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddTransactionIdToQueueOrder1729653046392
+  implements MigrationInterface
+{
+  name = 'AddTransactionIdToQueueOrder1729653046392';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "queue_orders" ADD "transaction_id" character varying NOT NULL`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "queue_orders" DROP COLUMN "transaction_id"`,
+    );
+  }
+}

src/database/migrations/1729756969674-add-queue-table.ts

@@ -0,0 +1,22 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddQueueTable1729756969674 implements MigrationInterface {
+  name = 'AddQueueTable1729756969674';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `CREATE TABLE "queues" ("id" uuid NOT NULL DEFAULT uuid_generate_v4(), "code" character varying NOT NULL, "status" character varying NOT NULL, "time" bigint NOT NULL, "call_time" bigint NOT NULL, "vip" boolean NOT NULL, "item_id" uuid NOT NULL, "qty" integer NOT NULL, CONSTRAINT "PK_d966f9eb39a9396658387071bb3" PRIMARY KEY ("id"))`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "queues" ADD CONSTRAINT "FK_435954e9a0d9967f17e043d54b4" FOREIGN KEY ("item_id") REFERENCES "queue_items"("id") ON DELETE CASCADE ON UPDATE CASCADE`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "queues" DROP CONSTRAINT "FK_435954e9a0d9967f17e043d54b4"`,
+    );
+
+    await queryRunner.query(`DROP TABLE "queues"`);
+  }
+}

src/database/migrations/1729838994129-add-queue-base-model.ts

@@ -0,0 +1,39 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddQueueBaseModel1729838994129 implements MigrationInterface {
+  name = 'AddQueueBaseModel1729838994129';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "queues" ADD "creator_id" character varying(36)`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "queues" ADD "creator_name" character varying(125)`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "queues" ADD "editor_id" character varying(36)`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "queues" ADD "editor_name" character varying(125)`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "queues" ADD "created_at" bigint NOT NULL`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "queues" ADD "updated_at" bigint NOT NULL`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "queues" ALTER COLUMN "call_time" DROP NOT NULL`,
+    );
+
+    await queryRunner.query(`ALTER TABLE "queues" DROP COLUMN "updated_at"`);
+    await queryRunner.query(`ALTER TABLE "queues" DROP COLUMN "created_at"`);
+    await queryRunner.query(`ALTER TABLE "queues" DROP COLUMN "editor_name"`);
+    await queryRunner.query(`ALTER TABLE "queues" DROP COLUMN "editor_id"`);
+    await queryRunner.query(`ALTER TABLE "queues" DROP COLUMN "creator_name"`);
+    await queryRunner.query(`ALTER TABLE "queues" DROP COLUMN "creator_id"`);
+  }
+}

src/database/migrations/1730859187883-add-queue-bucket.ts

@@ -0,0 +1,15 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddQueueBucket1730859187883 implements MigrationInterface {
+  name = 'AddQueueBucket1730859187883';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `CREATE TABLE "queue_bucket" ("id" uuid NOT NULL DEFAULT uuid_generate_v4(), "queue_item_id" character varying NOT NULL, "date" bigint NOT NULL, "regular" integer NOT NULL, "vip" integer NOT NULL, CONSTRAINT "PK_cdd58b0d9e93e4be922da9d8bd6" PRIMARY KEY ("id"))`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`DROP TABLE "queue_bucket"`);
+  }
+}

src/database/migrations/1731383726542-add-transaction-and-item-relation.ts

@@ -0,0 +1,50 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddTransactionAndItemRelation1731383726542
+  implements MigrationInterface
+{
+  name = 'AddTransactionAndItemRelation1731383726542';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" DROP COLUMN "item_id"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" ADD "item_id" uuid`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transactions" DROP COLUMN "customer_category_id"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transactions" ADD "customer_category_id" uuid`,
+    );
+
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" ADD CONSTRAINT "FK_edb934ab033f847e3f7ed4fc0fc" FOREIGN KEY ("item_id") REFERENCES "items"("id") ON DELETE NO ACTION ON UPDATE NO ACTION`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transactions" ADD CONSTRAINT "FK_08dc8138714894a66e94820766d" FOREIGN KEY ("customer_category_id") REFERENCES "vip_categories"("id") ON DELETE NO ACTION ON UPDATE NO ACTION`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "transactions" DROP CONSTRAINT "FK_08dc8138714894a66e94820766d"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" DROP CONSTRAINT "FK_edb934ab033f847e3f7ed4fc0fc"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transactions" DROP COLUMN "customer_category_id"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transactions" ADD "customer_category_id" character varying`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" DROP COLUMN "item_id"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "transaction_items" ADD "item_id" character varying`,
+    );
+  }
+}

src/database/migrations/1731498661938-add-item-queue-to-queue.ts

@@ -0,0 +1,15 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddItemQueueToQueue1731498661938 implements MigrationInterface {
+  name = 'AddItemQueueToQueue1731498661938';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "queues" ADD "item_queue_id" character varying`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`ALTER TABLE "queues" DROP COLUMN "item_queue_id"`);
+  }
+}

src/database/migrations/1731570311609-add-information-to-item-queue.ts

@@ -0,0 +1,19 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddInformationToItemQueue1731570311609
+  implements MigrationInterface
+{
+  name = 'AddInformationToItemQueue1731570311609';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "item_queues" ADD "information" character varying`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "item_queues" DROP COLUMN "information"`,
+    );
+  }
+}

src/database/migrations/1733199330134-item-queue-add-time-and-peak-level.ts

@@ -0,0 +1,25 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class ItemQueueAddTimeAndPeakLevel1733199330134
+  implements MigrationInterface
+{
+  name = 'ItemQueueAddTimeAndPeakLevel1733199330134';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "item_queues" ADD "max_peak_level" integer NOT NULL DEFAULT '100'`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "item_queues" ADD "call_preparation" integer NOT NULL DEFAULT '5'`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "item_queues" DROP COLUMN "call_preparation"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "item_queues" DROP COLUMN "max_peak_level"`,
+    );
+  }
+}

src/database/migrations/1734717058658-add-notification-config-to-item-queue.ts

@@ -0,0 +1,25 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddNotificationConfigToItemQueue1734717058658
+  implements MigrationInterface
+{
+  name = 'AddNotificationConfigToItemQueue1734717058658';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "item_queues" ADD "use_notification" boolean NOT NULL DEFAULT true`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "item_queues" ADD "requiring_notification" boolean NOT NULL DEFAULT false`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "item_queues" DROP COLUMN "requiring_notification"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "item_queues" DROP COLUMN "use_notification"`,
+    );
+  }
+}

src/database/migrations/1734718462106-add-last-notification-to-queue.ts

@@ -0,0 +1,19 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddLastNotificationToQueue1734718462106
+  implements MigrationInterface
+{
+  name = 'AddLastNotificationToQueue1734718462106';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "queues" ADD "last_notification" bigint NULL`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "queues" DROP COLUMN "last_notification"`,
+    );
+  }
+}

src/modules/configuration/auth/auth.module.ts

@@ -9,14 +9,32 @@ import { CqrsModule } from '@nestjs/cqrs';
 import { UserModel } from 'src/modules/user-related/user/data/models/user.model';
 import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
 import { UserDataService } from 'src/modules/user-related/user/data/services/user-data.service';
+import { AuthAdminQueueController } from './infrastructure/auth-admin-queue.controller';
+import { AuthAdminQueueOrchestrator } from './domain/auth-admin-queue.orchestrator';
+import { LoginAdminQueueManager } from './domain/managers/admin-queue/login-admin-queue.manager';
+import { LogoutAdminQueueManager } from './domain/managers/admin-queue/logout-admin-queue.manager';
+import { UserLoginModel } from 'src/modules/user-related/user/data/models/user-login.model';
 
 @Module({
   imports: [
     ConfigModule.forRoot(),
-    TypeOrmModule.forFeature([UserModel], CONNECTION_NAME.DEFAULT),
+    TypeOrmModule.forFeature(
+      [UserModel, UserLoginModel],
+      CONNECTION_NAME.DEFAULT,
+    ),
     CqrsModule,
   ],
-  controllers: [AuthController],
+  controllers: [AuthController, AuthAdminQueueController],
-  providers: [LoginManager, LogoutManager, UserDataService, AuthOrchestrator],
+  providers: [
+    LoginManager,
+    LogoutManager,
+    UserDataService,
+    AuthOrchestrator,
+
+    // ADMIN QUEUE
+    AuthAdminQueueOrchestrator,
+    LoginAdminQueueManager,
+    LogoutAdminQueueManager,
+  ],
 })
 export class AuthModule {}

src/modules/configuration/auth/domain/auth-admin-queue.orchestrator.ts

@@ -0,0 +1,32 @@
+import { Injectable } from '@nestjs/common';
+import { LoginAdminQueueManager } from './managers/admin-queue/login-admin-queue.manager';
+import { LogoutAdminQueueManager } from './managers/admin-queue/logout-admin-queue.manager';
+import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
+import { UserDataService } from 'src/modules/user-related/user/data/services/user-data.service';
+
+@Injectable()
+export class AuthAdminQueueOrchestrator {
+  constructor(
+    private loginManager: LoginAdminQueueManager,
+    private logoutManager: LogoutAdminQueueManager,
+    private serviceData: UserDataService,
+  ) {}
+
+  async login(data): Promise<any> {
+    this.loginManager.setData(data);
+    this.loginManager.setService(this.serviceData, TABLE_NAME.USER);
+    await this.loginManager.execute();
+    return this.loginManager.getResult();
+  }
+
+  async logout(userId?: string): Promise<any> {
+    if (userId) this.logoutManager.setData({ user_id: userId });
+    this.logoutManager.setService(this.serviceData, TABLE_NAME.USER);
+    await this.logoutManager.execute();
+    return this.logoutManager.getResult();
+  }
+
+  async forceLogout(token): Promise<any> {
+    return this.serviceData.forceLogout(token);
+  }
+}

src/modules/configuration/auth/domain/auth.orchestrator.ts

@@ -24,4 +24,8 @@ export class AuthOrchestrator {
     await this.logoutManager.execute();
     return this.logoutManager.getResult();
   }
+
+  async forceLogout(token): Promise<any> {
+    return this.serviceData.forceLogout(token);
+  }
 }

src/modules/configuration/auth/domain/managers/admin-queue/login-admin-queue.manager.ts

@@ -0,0 +1,168 @@
+import {
+  HttpStatus,
+  Inject,
+  Injectable,
+  Logger,
+  UnauthorizedException,
+} from '@nestjs/common';
+import { validatePassword } from 'src/core/helpers/password/bcrypt.helpers';
+import { BaseCustomManager } from 'src/core/modules/domain/usecase/managers/base-custom.manager';
+import { SessionService } from 'src/core/sessions';
+import { STATUS } from 'src/core/strings/constants/base.constants';
+import { EventTopics } from 'src/core/strings/constants/interface.constants';
+import { UserModel } from 'src/modules/user-related/user/data/models/user.model';
+import { UserEntity } from 'src/modules/user-related/user/domain/entities/user.entity';
+import { In } from 'typeorm';
+import { UserRole } from 'src/modules/user-related/user/constants';
+import { AppSource, LogUserType } from 'src/core/helpers/constant';
+import { LogUserLoginEvent } from 'src/modules/configuration/log/domain/entities/log-user-login.event';
+import { UserLoginEntity } from 'src/modules/user-related/user/domain/entities/user-login.entity';
+
+@Injectable()
+export class LoginAdminQueueManager extends BaseCustomManager<UserEntity> {
+  @Inject()
+  protected session: SessionService;
+  protected token;
+  protected userLogin;
+
+  async validateProcess(): Promise<void> {
+    return;
+  }
+
+  async beforeProcess(): Promise<void> {
+    return;
+  }
+
+  async process(): Promise<void> {
+    const itemLogin = await this.dataService.getLoginUserByItem(
+      this.data.item_id,
+    );
+
+    // get user active by username
+    this.userLogin = await this.dataService.getOneByOptions({
+      where: {
+        username: this.data.username,
+        status: STATUS.ACTIVE,
+        role: In([UserRole.QUEUE_ADMIN, UserRole.SUPERADMIN]),
+      },
+      relations: ['user_login'],
+    });
+
+    if (!this.userLogin) this.throwError();
+
+    // validasi password
+    const valid = await validatePassword(
+      this.data.password,
+      this.userLogin?.password,
+    );
+    if (!valid) this.throwError();
+
+    const userLoginItem = await this.dataService.getOneByOptions({
+      where: {
+        id: itemLogin?.user_id,
+      },
+    });
+
+    const hasLoginAsQueue = this.userLogin?.user_login?.find(
+      (item) => item.source === AppSource.QUEUE_ADMIN,
+    );
+
+    if (hasLoginAsQueue && hasLoginAsQueue?.item_id !== this.data.item_id) {
+      throw new UnauthorizedException({
+        statusCode: HttpStatus.UNAUTHORIZED,
+        message: `Akun anda sudah login di item "${hasLoginAsQueue?.item_name}"`,
+        error: 'Unauthorized',
+      });
+    }
+    // else if (itemLogin && itemLogin.user_id !== this.userLogin.id) {
+    //   throw new UnauthorizedException({
+    //     statusCode: HttpStatus.UNAUTHORIZED,
+    //     message: `"${userLoginItem.name}" masih login sebagai admin antrian `,
+    //     error: 'Unauthorized',
+    //   });
+    // }
+
+    // * Disini untuk isi token
+    const tokenData = {
+      id: this.userLogin.id,
+      name: this.userLogin.name,
+      username: this.userLogin.username,
+      role: this.userLogin.role,
+      user_privilege_id: this.userLogin.user_privilege_id,
+      item_id: this.data.item_id,
+      item_name: this.data.item_name,
+      source: AppSource.QUEUE_ADMIN,
+    };
+
+    Logger.debug('Sign Token Admin Queue', 'LoginAdminQueueManager');
+    this.token = this.session.createAccessToken(tokenData);
+
+    Logger.debug('Save Login Token', 'LoginManager');
+    const userLoginData: UserLoginEntity = {
+      user_id: this.userLogin.id,
+      login_token: this.token,
+      login_date: new Date().getTime(),
+      source: AppSource.QUEUE_ADMIN,
+      role: this.userLogin.role,
+      item_id: this.data.item_id,
+      item_name: this.data.item_name,
+    };
+    if (hasLoginAsQueue?.item_id === this.data.item_id) {
+      Object.assign(userLoginData, { id: hasLoginAsQueue.id });
+    }
+    // Update refresh token
+    await this.dataService.saveUserLogin(userLoginData);
+
+    await this.publishEvents();
+
+    Logger.debug('Process Login Admin Queue Done', 'LoginAdminQueueManager');
+    return;
+  }
+
+  async afterProcess(): Promise<void> {
+    return;
+  }
+
+  getResult() {
+    return {
+      id: this.userLogin.id,
+      name: this.userLogin.name,
+      username: this.userLogin.username,
+      role: this.userLogin.role,
+      token: this.token,
+      item_id: this.data.item_id,
+      item_name: this.data.item_name,
+    };
+  }
+
+  get entityTarget(): any {
+    return UserModel;
+  }
+
+  get eventTopics(): EventTopics[] {
+    return [
+      {
+        topic: LogUserLoginEvent,
+        data: {
+          type: LogUserType.login,
+          role: this.userLogin.role,
+          user_id: this.userLogin.id,
+          username: this.userLogin.username,
+          created_at: new Date().getTime(),
+          item_id: this.data.item_id,
+          item_name: this.data.item_name,
+          source: AppSource.QUEUE_ADMIN,
+        },
+      },
+    ];
+  }
+
+  // !throw errornya akan sama, untuk security
+  throwError() {
+    throw new UnauthorizedException({
+      statusCode: HttpStatus.UNAUTHORIZED,
+      message: `Gagal! username atau password tidak sesuai`,
+      error: 'Unauthorized',
+    });
+  }
+}

src/modules/configuration/auth/domain/managers/admin-queue/logout-admin-queue.manager.ts

@@ -0,0 +1,62 @@
+import { AppSource, LogUserType } from 'src/core/helpers/constant';
+import { BaseCustomManager } from 'src/core/modules/domain/usecase/managers/base-custom.manager';
+import { EventTopics } from 'src/core/strings/constants/interface.constants';
+import { LogUserLoginEvent } from 'src/modules/configuration/log/domain/entities/log-user-login.event';
+import { UserModel } from 'src/modules/user-related/user/data/models/user.model';
+import { UserEntity } from 'src/modules/user-related/user/domain/entities/user.entity';
+
+export class LogoutAdminQueueManager extends BaseCustomManager<UserEntity> {
+  protected userLogin;
+
+  async validateProcess(): Promise<void> {
+    return;
+  }
+
+  async beforeProcess(): Promise<void> {
+    return;
+  }
+
+  async process(): Promise<void> {
+    const id = this.data?.user_id ?? this.user.id;
+
+    this.userLogin = await this.dataService.getOneByOptions({
+      where: { id },
+    });
+
+    await this.dataService.removeUserLogin({
+      user_id: id,
+      source: AppSource.QUEUE_ADMIN,
+    });
+
+    await this.publishEvents();
+    return;
+  }
+
+  async afterProcess(): Promise<void> {
+    return;
+  }
+
+  getResult() {
+    return `Success Logout User`;
+  }
+
+  get entityTarget(): any {
+    return UserModel;
+  }
+
+  get eventTopics(): EventTopics[] {
+    return [
+      {
+        topic: LogUserLoginEvent,
+        data: {
+          type: LogUserType.logout,
+          role: this.userLogin.role,
+          user_id: this.userLogin.id,
+          username: this.userLogin.name,
+          created_at: new Date().getTime(),
+          source: AppSource.QUEUE_ADMIN,
+        },
+      },
+    ];
+  }
+}

src/modules/configuration/auth/domain/managers/login.manager.ts

@@ -12,7 +12,11 @@ import { STATUS } from 'src/core/strings/constants/base.constants';
 import { EventTopics } from 'src/core/strings/constants/interface.constants';
 import { UserModel } from 'src/modules/user-related/user/data/models/user.model';
 import { UserEntity } from 'src/modules/user-related/user/domain/entities/user.entity';
-import { UserLoginEvent } from '../entities/login.event';
+import { Not } from 'typeorm';
+import { UserRole } from 'src/modules/user-related/user/constants';
+import { AppSource, LogUserType } from 'src/core/helpers/constant';
+import { LogUserLoginEvent } from 'src/modules/configuration/log/domain/entities/log-user-login.event';
+import { UserLoginEntity } from 'src/modules/user-related/user/domain/entities/user-login.entity';
 
 @Injectable()
 export class LoginManager extends BaseCustomManager<UserEntity> {
@@ -36,6 +40,7 @@ export class LoginManager extends BaseCustomManager<UserEntity> {
       where: {
         username: this.data.username,
         status: STATUS.ACTIVE,
+        role: Not(UserRole.QUEUE_ADMIN),
       },
       relations: [
         'user_privilege',
@@ -58,25 +63,27 @@ export class LoginManager extends BaseCustomManager<UserEntity> {
       username: this.userLogin.username,
       role: this.userLogin.role,
       user_privilege_id: this.userLogin.user_privilege_id,
+      source: AppSource.POS_ADMIN,
     };
 
     Logger.debug('Sign Token', 'LoginManager');
     this.token = this.session.createAccessToken(tokenData);
 
-    Logger.debug('refreshToken', 'LoginManager');
+    Logger.debug('Save Login Token', 'LoginManager');
-    const refreshToken = this.session.createAccessToken(tokenData);
+    const userLoginData: UserLoginEntity = {
+      user_id: this.userLogin.id,
+      login_token: this.token,
+      login_date: new Date().getTime(),
+      source: AppSource.POS_ADMIN,
+      role: this.userLogin.role,
+      item_id: null,
+      item_name: null,
+    };
 
-    Logger.debug('Update Refresh Token', 'LoginManager');
     // Update refresh token
-    await this.dataService.update(
+    await this.dataService.saveUserLogin(userLoginData);
-      this.queryRunner,
-      this.entityTarget,
-      { id: this.userLogin.id },
-      {
-        refresh_token: refreshToken,
-      },
-    );
 
+    await this.publishEvents();
     Logger.debug('Process Login Done', 'LoginManager');
     return;
   }
@@ -119,11 +126,14 @@ export class LoginManager extends BaseCustomManager<UserEntity> {
   get eventTopics(): EventTopics[] {
     return [
       {
-        topic: UserLoginEvent,
+        topic: LogUserLoginEvent,
         data: {
-          id: this.userLogin.id,
+          type: LogUserType.login,
-          type: 'login',
+          role: this.userLogin.role,
-          timestamp: new Date().getTime(),
+          user_id: this.userLogin.id,
+          username: this.userLogin.username,
+          created_at: new Date().getTime(),
+          source: AppSource.POS_ADMIN,
         },
       },
     ];

src/modules/configuration/auth/domain/managers/logout.manager.ts

@@ -2,7 +2,8 @@ import { BaseCustomManager } from 'src/core/modules/domain/usecase/managers/base
 import { EventTopics } from 'src/core/strings/constants/interface.constants';
 import { UserModel } from 'src/modules/user-related/user/data/models/user.model';
 import { UserEntity } from 'src/modules/user-related/user/domain/entities/user.entity';
-import { UserLogoutEvent } from '../entities/logout.event';
+import { AppSource, LogUserType } from 'src/core/helpers/constant';
+import { LogUserLoginEvent } from 'src/modules/configuration/log/domain/entities/log-user-login.event';
 
 export class LogoutManager extends BaseCustomManager<UserEntity> {
   async validateProcess(): Promise<void> {
@@ -14,15 +15,12 @@ export class LogoutManager extends BaseCustomManager<UserEntity> {
   }
 
   async process(): Promise<void> {
-    await this.dataService.update(
+    await this.dataService.removeUserLogin({
-      this.queryRunner,
+      user_id: this.user.id,
-      this.entityTarget,
+      login_token: this.userProvider.token,
-      { id: this.user.id },
+      source: AppSource.POS_ADMIN,
-      {
+    });
-        refresh_token: null,
+    await this.publishEvents();
-      },
-    );
-
     return;
   }
 
@@ -41,11 +39,14 @@ export class LogoutManager extends BaseCustomManager<UserEntity> {
   get eventTopics(): EventTopics[] {
     return [
       {
-        topic: UserLogoutEvent,
+        topic: LogUserLoginEvent,
         data: {
-          id: this.user.id,
+          type: LogUserType.logout,
-          type: 'logout',
+          role: this.user.role,
-          timestamp: new Date().getTime(),
+          user_id: this.user.id,
+          username: this.user.name,
+          created_at: new Date().getTime(),
+          source: AppSource.POS_ADMIN,
         },
       },
     ];

src/modules/configuration/auth/infrastructure/auth-admin-queue.controller.ts

@@ -0,0 +1,35 @@
+import { Body, Controller, Delete, Param, Post, Put } from '@nestjs/common';
+import { ExcludePrivilege, Public } from 'src/core/guards';
+import { ApiBearerAuth } from '@nestjs/swagger';
+import { ForceLogoutDto, LoginQueueDto } from './dto/login.dto';
+import { AuthAdminQueueOrchestrator } from '../domain/auth-admin-queue.orchestrator';
+
+@Controller('v1/auth/queue')
+export class AuthAdminQueueController {
+  constructor(private orchestrator: AuthAdminQueueOrchestrator) {}
+
+  @Post()
+  @Public(true)
+  async login(@Body() body: LoginQueueDto) {
+    return await this.orchestrator.login(body);
+  }
+
+  @ApiBearerAuth('JWT')
+  @Public(false)
+  @ExcludePrivilege()
+  @Delete('logout')
+  async logout() {
+    return await this.orchestrator.logout();
+  }
+
+  @Put(':user_id/logout')
+  async logoutQueueAdmin(@Param('user_id') userId: string) {
+    return await this.orchestrator.logout(userId);
+  }
+
+  @Post('force-logout')
+  @Public(true)
+  async forceLogout(@Body() body: ForceLogoutDto) {
+    return await this.orchestrator.forceLogout(body.token);
+  }
+}

src/modules/configuration/auth/infrastructure/auth.controller.ts

@@ -1,8 +1,8 @@
 import { Body, Controller, Delete, Post } from '@nestjs/common';
-import { Public } from 'src/core/guards';
+import { ExcludePrivilege, Public } from 'src/core/guards';
 import { AuthOrchestrator } from '../domain/auth.orchestrator';
 import { ApiBearerAuth } from '@nestjs/swagger';
-import { LoginDto } from './dto/login.dto';
+import { ForceLogoutDto, LoginDto } from './dto/login.dto';
 
 @Controller('v1/auth')
 export class AuthController {
@@ -16,8 +16,15 @@ export class AuthController {
 
   @ApiBearerAuth('JWT')
   @Public(false)
+  @ExcludePrivilege()
   @Delete('logout')
-  async logoout() {
+  async logout() {
     return await this.orchestrator.logout();
   }
+
+  @Post('force-logout')
+  @Public(true)
+  async forceLogout(@Body() body: ForceLogoutDto) {
+    return await this.orchestrator.forceLogout(body.token);
+  }
 }

src/modules/configuration/auth/infrastructure/dto/login.dto.ts

@@ -11,3 +11,27 @@ export class LoginDto implements LoginRequest {
   @IsString()
   password: string;
 }
+
+export class LoginQueueDto implements LoginRequest {
+  @ApiProperty({ name: 'username', required: true, default: 'superadmin' })
+  @IsString()
+  username: string;
+
+  @ApiProperty({ name: 'password', required: true, default: 'Eigen123!' })
+  @IsString()
+  password: string;
+
+  @ApiProperty({ name: 'item_id', required: true, default: 'string' })
+  @IsString()
+  item_id: string;
+
+  @ApiProperty({ name: 'item_name', required: true, default: 'string' })
+  @IsString()
+  item_name: string;
+}
+
+export class ForceLogoutDto {
+  @ApiProperty({ required: true })
+  @IsString()
+  token: string;
+}

src/modules/configuration/couch/couch.module.ts

@@ -51,6 +51,7 @@ import {
 import { SeasonPeriodDataService } from 'src/modules/season-related/season-period/data/services/season-period-data.service';
 import { SeasonPeriodModel } from 'src/modules/season-related/season-period/data/models/season-period.model';
 import { TransactionDemographyModel } from 'src/modules/transaction/transaction/data/models/transaction-demography.model';
+import { UserLoginModel } from 'src/modules/user-related/user/data/models/user-login.model';
 
 @Module({
   imports: [
@@ -61,6 +62,7 @@ import { TransactionDemographyModel } from 'src/modules/transaction/transaction/
         ItemRateModel,
         SeasonPeriodModel,
         UserModel,
+        UserLoginModel,
         TransactionModel,
         TransactionTaxModel,
         TransactionItemModel,
@@ -100,5 +102,6 @@ import { TransactionDemographyModel } from 'src/modules/transaction/transaction/
     ItemDataService,
     CouchService,
   ],
+  exports: [CouchService],
 })
 export class CouchModule {}

src/modules/configuration/couch/data/services/couch.service.ts

@@ -19,17 +19,19 @@ export class CouchService {
   }
 
   async onModuleInit() {
+    // return;
     const nano = this.nanoInstance;
     for (const database of DatabaseListen) {
       const db = nano.db.use(database);
       db.changesReader.start({ includeDocs: true }).on('change', (change) => {
-        Logger.log(
+        Logger.verbose(
           `Receive Data from ${database}: ${change?.id}`,
           'CouchService',
         );
         this.changeDoc(change, database);
       });
 
+      // transaction
       Logger.log(`start listen database ${database}`, 'CouchService');
     }
   }
@@ -94,4 +96,41 @@ export class CouchService {
       return null;
     }
   }
+
+  getUnixTimestampLast7Days() {
+    const date = new Date();
+    date.setDate(date.getDate() - 4);
+    date.setHours(0, 0, 0, 0);
+    return date.getTime();
+  }
+
+  public async clearTransactions() {
+    const nano = this.nanoInstance;
+    const transaction = nano.use('transaction');
+
+    const expiredDate = this.getUnixTimestampLast7Days();
+
+    const selectorPayment = {
+      created_at: {
+        $lt: expiredDate,
+      },
+    };
+
+    const transactions = await transaction.find({
+      selector: selectorPayment,
+      fields: ['_id', '_rev'],
+      limit: 100000,
+    });
+
+    const { docs } = transactions;
+    console.log(docs.length);
+    const deletedDocs = {
+      docs: docs.map((doc) => ({
+        _id: doc._id,
+        _rev: doc._rev,
+        _deleted: true,
+      })),
+    };
+    await transaction.bulk(deletedDocs);
+  }
 }

src/modules/configuration/couch/domain/managers/booking.handler.ts

@@ -95,11 +95,12 @@ export class ChangeStatusBookingHandler
       where: {
         id: dataID,
       },
-      relations: ['items'],
+      relations: ['items', 'items.bundling_items'],
     });
     mappingTransaction(booking);
 
     if (!couchData) {
+      console.log('save data to couch');
       await this.couchService.createDoc(
         {
           _id: booking.id,
@@ -108,6 +109,7 @@ export class ChangeStatusBookingHandler
         'booking',
       );
     } else {
+      console.log('update data to couch');
       await this.couchService.updateDoc(
         {
           _id: booking.id,
@@ -133,6 +135,7 @@ export class BookingUpdateHandler
     const dataID = data?.id ?? data?.order_id;
 
     const couchData = await this.couchService.getDoc(dataID, 'booking');
+    console.log('update', { dataID, couchData });
     if (couchData) {
       const booking = await this.bookingService.getOneByOptions({
         where: {
@@ -140,6 +143,7 @@ export class BookingUpdateHandler
         },
         relations: ['items'],
       });
+      console.log({ booking });
       mappingTransaction(booking);
       await this.couchService.updateDoc(
         {

src/modules/configuration/couch/infrastructure/couch.controller.ts

@@ -5,13 +5,17 @@ import { Public } from 'src/core/guards';
 import * as Nano from 'nano';
 import { CreateUserPrivilegeDto } from 'src/modules/user-related/user-privilege/infrastructure/dto/create-user-privilege.dto';
 import { ConfigService } from '@nestjs/config';
+import { CouchService } from '../data/services/couch.service';
 
 @ApiTags(`couch`)
 @Controller('v1/couch')
 @Public()
 @Injectable()
 export class CouchDataController {
-  constructor(private configService: ConfigService) {}
+  constructor(
+    private configService: ConfigService,
+    private couchService: CouchService,
+  ) {}
 
   get nanoInstance() {
     const couchConfiguration = this.configService.get<string>('COUCHDB_CONFIG');
@@ -64,4 +68,11 @@ export class CouchDataController {
       // return people.get();
     } catch (error) {}
   }
+
+  @Public(true)
+  @Get('clear-transactions')
+  async clearTransactions(): Promise<string> {
+    await this.couchService.clearTransactions();
+    return 'OK';
+  }
 }

src/modules/configuration/log/data/models/log-user-login.model.ts

@@ -0,0 +1,37 @@
+import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
+import { UserEntity } from '../../../../user-related/user/domain/entities/user.entity';
+import { Column, Entity } from 'typeorm';
+import { BaseCoreModel } from 'src/core/modules/data/model/base-core.model';
+import { LogUserLoginEntity } from '../../domain/entities/log-user-login.entity';
+import { UserRole } from '../../../../user-related/user/constants';
+import { AppSource, LogUserType } from 'src/core/helpers/constant';
+
+@Entity(TABLE_NAME.LOG_USER_LOGIN)
+export class LogUserLoginModel
+  extends BaseCoreModel<UserEntity>
+  implements LogUserLoginEntity
+{
+  @Column({ type: 'enum', enum: LogUserType, nullable: true })
+  type: LogUserType;
+
+  @Column({ type: 'enum', enum: UserRole, nullable: true })
+  role: UserRole;
+
+  @Column({ type: 'uuid', nullable: true })
+  user_id: string;
+
+  @Column({ type: 'uuid', nullable: true })
+  item_id: string;
+
+  @Column({ type: 'varchar', nullable: true })
+  item_name: string;
+
+  @Column({ type: 'varchar', nullable: true })
+  username: string;
+
+  @Column({ type: 'bigint', nullable: true })
+  created_at: number;
+
+  @Column({ type: 'enum', enum: AppSource, nullable: true })
+  source: AppSource;
+}

src/modules/configuration/log/data/models/pos-log.model.ts

@@ -14,6 +14,9 @@ export class PosLogModel
   @Column('bigint', { name: 'pos_number', nullable: true })
   pos_number: number;
 
+  @Column('varchar', { name: 'pos_name', nullable: true })
+  pos_name: string;
+
   @Column('decimal', { name: 'total_balance', nullable: true })
   total_balance: number;
 

src/modules/configuration/log/data/services/log-user-login.service.ts

@@ -0,0 +1,21 @@
+import { BaseDataService } from 'src/core/modules/data/service/base-data.service';
+import { Injectable } from '@nestjs/common';
+import { InjectRepository } from '@nestjs/typeorm';
+import { Repository } from 'typeorm';
+import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
+import { LogUserLoginEntity } from '../../domain/entities/log-user-login.entity';
+import { LogUserLoginModel } from '../models/log-user-login.model';
+
+@Injectable()
+export class LogUserLoginService extends BaseDataService<LogUserLoginEntity> {
+  constructor(
+    @InjectRepository(LogUserLoginModel, CONNECTION_NAME.DEFAULT)
+    private repo: Repository<LogUserLoginModel>,
+  ) {
+    super(repo);
+  }
+
+  async saveData(data) {
+    this.repo.save(data);
+  }
+}

src/modules/configuration/log/domain/entities/log-user-login.entity.ts

@@ -0,0 +1,13 @@
+import { LogUserType } from 'src/core/helpers/constant';
+import { UserRole } from '../../../../user-related/user/constants';
+import { BaseCoreEntity } from 'src/core/modules/domain/entities/base-core.entity';
+
+export interface LogUserLoginEntity extends BaseCoreEntity {
+  type: LogUserType;
+  role: UserRole;
+  user_id: string;
+  item_id: string;
+  item_name: string;
+  username: string;
+  created_at: number;
+}

src/modules/configuration/log/domain/entities/log-user-login.event.ts

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

src/modules/configuration/log/domain/entities/pos-log.entity.ts

@@ -3,6 +3,7 @@ import { BaseCoreEntity } from 'src/core/modules/domain/entities/base-core.entit
 export interface PosLogEntity extends BaseCoreEntity {
   type: PosLogType;
   pos_number: number;
+  pos_name: string;
   total_balance: number;
   created_at: number;
   creator_name: string;

src/modules/configuration/log/domain/handlers/log-user-login.handler.ts

@@ -0,0 +1,14 @@
+import { EventsHandler, IEventHandler } from '@nestjs/cqrs';
+
+import { LogUserLoginEvent } from '../entities/log-user-login.event';
+import { LogUserLoginService } from '../../data/services/log-user-login.service';
+
+@EventsHandler(LogUserLoginEvent)
+export class LogUserLoginHandler implements IEventHandler<LogUserLoginEvent> {
+  constructor(private service: LogUserLoginService) {}
+
+  async handle(event: LogUserLoginEvent) {
+    const data = event.data.data;
+    await this.service.saveData(data);
+  }
+}

src/modules/configuration/log/domain/handlers/pos-log.handler.ts

@@ -26,6 +26,7 @@ export class RecordPosLogHandler implements IEventHandler<ChangeDocEvent> {
         type: PosLogType[data.type],
         total_balance: data.withdrawal_cash ?? data.opening_cash_balance,
         pos_number: data.pos_number,
+        pos_name: data.pos_name,
         creator_id: data.pos_admin?.id,
         creator_name: data.pos_admin?.name ?? data.pos_admin?.username,
         drawn_by_id: data.withdraw_user?.id,

src/modules/configuration/log/log.module.ts

@@ -12,12 +12,15 @@ import { LogService } from './data/services/log.service';
 import { PosLogModel } from './data/models/pos-log.model';
 import { PosLogService } from './data/services/pos-log.service';
 import { RecordPosLogHandler } from './domain/handlers/pos-log.handler';
+import { LogUserLoginModel } from './data/models/log-user-login.model';
+import { LogUserLoginService } from './data/services/log-user-login.service';
+import { LogUserLoginHandler } from './domain/handlers/log-user-login.handler';
 
 @Module({
   imports: [
     ConfigModule.forRoot(),
     TypeOrmModule.forFeature(
-      [LogModel, ErrorLogModel, PosLogModel],
+      [LogModel, ErrorLogModel, PosLogModel, LogUserLoginModel],
       CONNECTION_NAME.DEFAULT,
     ),
     CqrsModule,
@@ -27,10 +30,12 @@ import { RecordPosLogHandler } from './domain/handlers/pos-log.handler';
     RecordLogHandler,
     RecordPosLogHandler,
     RecordErrorLogHandler,
+    LogUserLoginHandler,
 
     LogService,
     PosLogService,
     ErrorLogService,
+    LogUserLoginService,
   ],
 })
 export class LogModule {}

src/modules/configuration/mail/domain/handlers/payment-transaction.handler.ts

@@ -32,7 +32,6 @@ export class PaymentTransactionHandler
       const current_data = event.data.data;
       const data_id = current_data.transaction_id ?? event.data.id;
       const from_refund = event.data.module == TABLE_NAME.REFUND;
-      console.log('payment handlet', { data_id });
 
       const payments = await this.paymentService.getManyByOptions({
         where: {
@@ -106,6 +105,15 @@ export class PaymentTransactionHandler
               `;
               })}
             </ul>`,
+
+          refund_items_data: transaction?.['refund']?.refund_items
+            ?.filter((item) => Number(item.qty_refund) > 0)
+            .map((item) => {
+              return {
+                qty_refund: item.qty_refund,
+                item_name: item.transaction_item.item_name,
+              };
+            }),
         });
       }
 

src/modules/configuration/mail/domain/helpers/send-email.helper.ts

@@ -17,7 +17,7 @@ export async function sendEmail(receivers, invoiceType, attachment?) {
   for (const receiver of receivers) {
     try {
       const templateName = getTemplate(receiver.payment_type, invoiceType);
-      const templatePath = `./assets/email-template/${templateName}.html`;
+      const templatePath = `./assets/email-template/redesign/${templateName}.html`;
       const templateSource = fs.readFileSync(templatePath, 'utf8');
 
       const template = handlebars.compile(templateSource);

src/modules/configuration/superset/superset.controller.ts

@@ -0,0 +1,17 @@
+import { Controller, Get, Param } from '@nestjs/common';
+import { ApiBearerAuth, ApiTags } from '@nestjs/swagger';
+import { ExcludePrivilege, Public } from 'src/core/guards';
+import { SupersetService } from './superset.service';
+
+@ApiTags(`Superset`)
+@Controller(`v1/superset`)
+@Public(false)
+@ApiBearerAuth('JWT')
+export class SupersetController {
+  constructor(private service: SupersetService) {}
+  @Get('token/:id')
+  @ExcludePrivilege()
+  async getGuestToken(@Param('id') id: string) {
+    return this.service.getGuestToken(id);
+  }
+}

src/modules/configuration/superset/superset.module.ts

@@ -0,0 +1,11 @@
+import { Module } from '@nestjs/common';
+import { SupersetController } from './superset.controller';
+import { SupersetService } from './superset.service';
+import { HttpModule } from '@nestjs/axios';
+
+@Module({
+  imports: [HttpModule],
+  controllers: [SupersetController],
+  providers: [SupersetService],
+})
+export class SupersetModule {}

src/modules/configuration/superset/superset.service.ts

@@ -0,0 +1,82 @@
+import { HttpService } from '@nestjs/axios';
+import { Injectable, Logger } from '@nestjs/common';
+import { firstValueFrom } from 'rxjs';
+
+@Injectable()
+export class SupersetService {
+  private readonly logger = new Logger(SupersetService.name);
+  private supersetURL = process.env.SUPERSET_URL + '/api';
+  private adminUsername = process.env.SUPERSET_ADMIN_USERNAME;
+  private adminPassword = process.env.SUPERSET_ADMIN_PASSWORD;
+
+  constructor(private readonly httpService: HttpService) {}
+
+  async getLoginToken() {
+    const data = {
+      username: this.adminUsername,
+      password: this.adminPassword,
+      provider: 'db',
+      refresh: true,
+    };
+
+    const response = await firstValueFrom(
+      this.httpService.request({
+        method: 'POST',
+        url: `${this.supersetURL}/v1/security/login`,
+        data: data,
+      }),
+    );
+
+    return response.data.access_token;
+  }
+
+  async getCSRFToken() {
+    const loginToken = await this.getLoginToken();
+    const response = await firstValueFrom(
+      this.httpService.request({
+        method: 'GET',
+        url: `${this.supersetURL}/v1/security/csrf_token/`,
+        headers: { Authorization: `Bearer ${loginToken}` },
+      }),
+    );
+
+    const cookie = response.headers['set-cookie'];
+
+    return { loginToken, csrfToken: response.data.result, cookie };
+  }
+
+  async getGuestToken(uuid: string) {
+    const { loginToken, csrfToken, cookie } = await this.getCSRFToken();
+
+    const data = {
+      resources: [{ type: 'dashboard', id: uuid }],
+      rls: [],
+      user: { username: 'pos_embed', first_name: 'pos', last_name: 'embed' },
+    };
+
+    const [requestCookie] = cookie[0].split(';');
+
+    const headers = {
+      Authorization: `Bearer ${loginToken}`,
+      Cookie: requestCookie,
+      'Content-Type': 'application/json',
+      'X-CSRFToken': `${csrfToken}`,
+      'Access-Control-Allow-Credentials': true,
+    };
+
+    const response = await firstValueFrom(
+      this.httpService.request({
+        method: 'POST',
+        url: `${this.supersetURL}/v1/security/guest_token/`,
+        data: data,
+        headers: headers,
+      }),
+    ).catch((err) => {
+      this.logger.verbose({ loginToken, csrfToken });
+      this.logger.error(err.response.data);
+      throw err;
+    });
+
+    return response.data.token;
+  }
+}

src/modules/gates/domain/entity/gate-request.entity.ts

@@ -0,0 +1,11 @@
+export interface GateScanEntity {
+  gate_id: string;
+  type: string;
+  uuid: string;
+}
+
+export interface GateLogEntity {
+  gate_id: string;
+  code: string;
+  error: any;
+}

src/modules/gates/domain/entity/gate-response.entity.ts

@@ -0,0 +1,8 @@
+export interface GateResponseEntity {
+  code: number;
+  message: string;
+}
+
+export interface GateMasterEntity {
+  codes: string[];
+}

src/modules/gates/gate.module.ts

@@ -0,0 +1,17 @@
+import { Global, Module } from '@nestjs/common';
+import { ConfigModule } from '@nestjs/config';
+import { GateController } from './infrastructure/gate.controller';
+
+@Global()
+@Module({
+  imports: [
+    ConfigModule.forRoot(),
+    // TypeOrmModule.forFeature(
+    //   [],
+    //   CONNECTION_NAME.DEFAULT,
+    // ),
+  ],
+  controllers: [GateController],
+  providers: [],
+})
+export class GateScanModule {}

src/modules/gates/infrastructure/dto/logs.dto.ts

@@ -0,0 +1,26 @@
+import { IsNotEmpty, IsString } from 'class-validator';
+import { GateLogEntity } from '../../domain/entity/gate-request.entity';
+import { ApiProperty } from '@nestjs/swagger';
+
+export class GateLogDto implements GateLogEntity {
+  @ApiProperty({
+    type: String,
+    required: true,
+  })
+  @IsNotEmpty()
+  @IsString()
+  gate_id: string;
+
+  @ApiProperty({
+    type: String,
+    required: true,
+  })
+  @IsNotEmpty()
+  @IsString()
+  code: string;
+
+  @ApiProperty({
+    required: false,
+  })
+  error: any;
+}