Merge branch 'development' of ssh://git.eigen.co.id:2222/eigen/pos-be into development

Reviewed-on: #162

src/core/helpers/validation/validate-relation.helper.ts

@@ -52,10 +52,12 @@ export class ValidateRelationHelper<Entity> {
         `Failed! this data already connected to ${relation.relation}`;
 
       if (relation.singleQuery) {
+        const relationObject = data[relation.relation] ?? {};
+        const isRelationExist = `${relation.singleQuery[0]}` in relationObject;
         const relationColumn =
           data[relation.relation]?.[`${relation.singleQuery[0]}`];
         if (
-          !!relationColumn &&
+          isRelationExist &&
           this.mappingValidator(
             relationColumn,
             relation.singleQuery[1],
@@ -69,6 +71,7 @@ export class ValidateRelationHelper<Entity> {
   }
 
   mappingValidator(column, operator, value) {
+    const candidates = Array.isArray(value) ? value : [value];
     switch (operator) {
       case '!=':
         return column != value;
@@ -76,6 +79,12 @@ export class ValidateRelationHelper<Entity> {
       case '==':
         return column == value;
 
+      case 'in':
+        return candidates.includes(column);
+
+      case 'not in':
+        return !candidates.includes(column);
+
       default:
         return column == value;
     }

src/database/migrations/1750834308368-remove-item-name-unique.ts

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

src/modules/booking-online/order/domain/usecases/managers/booking-item.manager.ts

@@ -54,4 +54,14 @@ export class BookingItemManager extends IndexItemManager {
     });
     return { total, data: items };
   }
+
+  setQueryFilter(
+    queryBuilder: SelectQueryBuilder<ItemEntity>,
+  ): SelectQueryBuilder<ItemEntity> {
+    const query = super.setQueryFilter(queryBuilder);
+
+    query.andWhere(`${this.tableName}.status = 'active'`);
+
+    return query;
+  }
 }

src/modules/booking-online/order/domain/usecases/managers/create-booking.manager.ts

@@ -57,6 +57,7 @@ export class CreateBookingManager extends CreateTransactionManager {
         time: this.data.booking_date,
         id: this.data.id,
       },
+      this.data.payment_total,
       `snap/v4/redirection/${this.data.payment_midtrans_token}`,
     );
   }

src/modules/booking-online/order/infrastructure/item.controller.ts

@@ -23,6 +23,7 @@ export class ItemController {
   ): Promise<PaginationResponse<ItemEntity>> {
     params.limit = 1000;
     params.show_to_booking = true;
+    params.all_item = true;
     this.indexManager.setFilterParam(params);
     this.indexManager.setService(this.serviceData, TABLE_NAME.ITEM);
     await this.indexManager.execute();

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

@@ -21,6 +21,19 @@ export class MidtransService {
     return diffInHours > 24;
   }
 
+  isCreatedMoreThan24HoursAgo(unixTimestamp) {
+    const date = moment.unix(unixTimestamp);
+    const now = moment();
+    const diffInHours = now.diff(date, 'hours');
+    return diffInHours > 24;
+  }
+
+  isBookingDateExpired(bookingDate) {
+    const bookingDateMoment = moment(bookingDate);
+    const today = moment().startOf('day');
+    return bookingDateMoment.isBefore(today);
+  }
+
   get midtransInstance() {
     return new Snap({
       isProduction: false,
@@ -38,15 +51,17 @@ export class MidtransService {
     const responses = [];
 
     for (const transaction of pendingIds) {
-      const { id, invoice_date } = transaction;
+      const { id, booking_date, created_at } = transaction;
       let status;
       try {
         status = await this.getStatus(id);
       } catch (error) {
         status = {
           order_id: id,
-          transaction_status: this.isMoreThan24HoursAgo(invoice_date)
+          transaction_status:
-            ? 'cancel'
+            this.isCreatedMoreThan24HoursAgo(created_at) ||
+            this.isBookingDateExpired(booking_date)
+              ? 'expired'
               : 'pending',
         };
       }

src/modules/configuration/otp-verification/infrastructure/guards/otp-auth.guard.ts

@@ -54,10 +54,12 @@ export class OtpAuthGuard implements CanActivate {
           request.user = userLogin;
           return true;
         } else {
-          throw new UnprocessableEntityException('Invalid OTP credentials');
+          throw new UnprocessableEntityException(
+            'Invalid username or password.',
+          );
         }
       } catch (err) {
-        throw new UnprocessableEntityException('Invalid OTP encoding');
+        throw new UnprocessableEntityException('Invalid username or password.');
       }
     }
 

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

@@ -25,7 +25,7 @@ export class ItemModel
   extends BaseStatusModel<ItemEntity>
   implements ItemEntity
 {
-  @Column('varchar', { name: 'name', unique: true })
+  @Column('varchar', { name: 'name' })
   name: string;
 
   @Column('text', { name: 'booking_description', nullable: true })

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

@@ -32,7 +32,13 @@ export class ActiveItemManager extends BaseUpdateStatusManager<ItemEntity> {
   }
 
   get validateRelations(): validateRelations[] {
-    return [
+    const timeGroupId = this.data.time_group_id ?? this.data.time_group?.id;
+    const relation =
+      this.data.bundling_items?.length > 0
+        ? 'bundling_items'
+        : 'bundling_parents';
+
+    const validateRelations: validateRelations[] = [
       {
         relation: 'tenant',
         singleQuery: ['status', '!=', STATUS.ACTIVE],
@@ -44,6 +50,16 @@ export class ActiveItemManager extends BaseUpdateStatusManager<ItemEntity> {
         message: `Gagal! Terdapat item yang belum aktif`,
       },
     ];
+
+    if (timeGroupId != null) {
+      validateRelations.push({
+        relation: relation,
+        singleQuery: ['time_group_id', 'not in', [timeGroupId, null]],
+        message: `Gagal Update! Time group item dan bundling item tidak sama`,
+      });
+    }
+
+    return validateRelations;
   }
 
   get entityTarget(): any {

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

@@ -8,6 +8,7 @@ import { ItemEntity } from '../../entities/item.entity';
 import { ItemModel } from '../../../data/models/item.model';
 import { BaseCreateManager } from 'src/core/modules/domain/usecase/managers/base-create.manager';
 import { ItemCreatedEvent } from '../../entities/event/item-created.event';
+import { STATUS } from 'src/core/strings/constants/base.constants';
 
 @Injectable()
 export class CreateItemManager extends BaseCreateManager<ItemEntity> {
@@ -29,11 +30,36 @@ export class CreateItemManager extends BaseCreateManager<ItemEntity> {
   }
 
   get validateRelations(): validateRelations[] {
-    return [];
+    const timeGroupId = this.data.time_group_id ?? this.data.time_group?.id;
+    const relation =
+      this.data.bundling_items?.length > 0
+        ? 'bundling_items'
+        : 'bundling_parents';
+    return timeGroupId != null
+      ? [
+          {
+            relation: relation,
+            singleQuery: ['time_group_id', 'in', [timeGroupId, null]],
+            message: `Gagal Update! Time group item dan bundling item tidak sama`,
+          },
+        ]
+      : [];
   }
 
   get uniqueColumns(): columnUniques[] {
-    return [{ column: 'name' }];
+    const timeGroupId = this.data.time_group_id ?? this.data.time_group?.id;
+    return timeGroupId != null
+      ? [
+          {
+            column: 'name',
+            query: `((${this.tableName}.time_group_id Is Null OR ${this.tableName}.time_group_id = '${timeGroupId}'))`,
+          },
+        ]
+      : [
+          {
+            column: 'name',
+          },
+        ];
   }
 
   get eventTopics(): EventTopics[] {

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

@@ -8,6 +8,7 @@ import {
   columnUniques,
   validateRelations,
 } from 'src/core/strings/constants/interface.constants';
+import { STATUS } from 'src/core/strings/constants/base.constants';
 
 @Injectable()
 export class UpdateItemManager extends BaseUpdateManager<ItemEntity> {
@@ -39,11 +40,37 @@ export class UpdateItemManager extends BaseUpdateManager<ItemEntity> {
   }
 
   get validateRelations(): validateRelations[] {
-    return [];
+    const timeGroupId = this.data.time_group_id ?? this.data.time_group?.id;
+    const relation =
+      this.data.bundling_items?.length > 0
+        ? 'bundling_items'
+        : 'bundling_parents';
+
+    return timeGroupId != null
+      ? [
+          {
+            relation: relation,
+            singleQuery: ['time_group_id', 'not in', [timeGroupId, null]],
+            message: `Gagal Update! Time group item dan bundling item tidak sama`,
+          },
+        ]
+      : [];
   }
 
   get uniqueColumns(): columnUniques[] {
-    return [];
+    const timeGroupId = this.data.time_group_id ?? this.data.time_group?.id;
+    return timeGroupId != null
+      ? [
+          {
+            column: 'name',
+            query: `((${this.tableName}.time_group_id Is Null OR ${this.tableName}.time_group_id = '${timeGroupId}'))`,
+          },
+        ]
+      : [
+          {
+            column: 'name',
+          },
+        ];
   }
 
   get entityTarget(): any {

src/modules/item-related/time-group/domain/usecases/managers/index-public-time-group.manager.ts

@@ -6,6 +6,8 @@ import {
   Param,
   RelationParam,
 } from 'src/core/modules/domain/entities/base-filter.entity';
+import * as moment from 'moment';
+import { ORDER_TYPE } from 'src/core/strings/constants/base.constants';
 
 // TODO:
 // Implementasikan filter by start_time, end_timen, dan max_usage_time
@@ -13,6 +15,10 @@ import {
 @Injectable()
 export class IndexPublicTimeGroupManager extends BaseIndexManager<TimeGroupEntity> {
   async prepareData(): Promise<void> {
+    Object.assign(this.filterParam, {
+      order_by: `${this.tableName}.start_time`,
+      order_type: ORDER_TYPE.ASC,
+    });
     return;
   }
 
@@ -60,6 +66,15 @@ export class IndexPublicTimeGroupManager extends BaseIndexManager<TimeGroupEntit
     queryBuilder: SelectQueryBuilder<TimeGroupEntity>,
   ): SelectQueryBuilder<TimeGroupEntity> {
     queryBuilder.andWhere(`items.id is not null`);
+
+    if (!this.filterParam.date) {
+      const currentTime = moment().utcOffset('+07:00').format('HH:mm:ss');
+
+      queryBuilder.andWhere(`${this.tableName}.end_time >= :current_time`, {
+        current_time: currentTime,
+      });
+    }
+
     return queryBuilder;
   }
 }

src/modules/item-related/time-group/infrastructure/dto/filter-time-group.dto.ts

@@ -30,4 +30,12 @@ export class FilterTimeGroupDto
   @ApiProperty({ type: 'string', required: false })
   @ValidateIf((body) => body.max_usage_time_to)
   max_usage_time_to: string;
+
+  @ApiProperty({
+    type: Date,
+    required: false,
+    example: '2024-01-01',
+  })
+  @ValidateIf((body) => body.date)
+  date: Date;
 }

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

@@ -52,11 +52,15 @@ export class TicketDataService extends BaseDataService<QueueTicket> {
     });
 
     if (!order) {
+      // Check if id is a valid UUID format
+      const uuidRegex =
+        /^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i;
+      const whereCondition = !uuidRegex.test(id)
+        ? { invoice_code: id, booking_date: new Date() }
+        : { id, booking_date: new Date() };
       const { customer_name, customer_phone } =
         await this.transaction.findOneOrFail({
-          where: {
+          where: whereCondition,
-            id,
-          },
         });
 
       const start = moment().startOf('day').valueOf();

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

@@ -56,7 +56,7 @@ export class QueueOrchestrator {
       return order;
     } catch (error) {
       throw new UnauthorizedException({
-        message: 'Invoice tidak ditemukan',
+        message: 'Invoice tidak ditemukan untuk tanggal hari ini',
         error: 'INVOICE_NOT_FOUND',
       });
     }

src/modules/queue/domain/usecases/generate-queue.manager.ts

@@ -27,6 +27,7 @@ export class GenerateQueueManager {
   async generate(transaction: TransactionModel) {
     const date = transaction.booking_date ?? transaction.invoice_date;
     const queue_date = moment(date, 'YYYY-MM-DD').unix();
+    const isToday = moment(date, 'YYYY-MM-DD').isSame(moment(), 'day');
 
     const { id, customer_name, customer_phone, invoice_code } = transaction;
 
@@ -40,10 +41,9 @@ export class GenerateQueueManager {
 
     const items = this.generateItems(transaction.items);
 
-    const existTicket = await this.ticketService.ticketByUser(
+    const existTicket = isToday
-      customer_name,
+      ? await this.ticketService.ticketByUser(customer_name, customer_phone)
-      customer_phone,
+      : null;
-    );
 
     const insertTickets: QueueTicket[] = [];
     if (customer_name && customer_phone && existTicket) {

src/modules/transaction/transaction/data/services/transaction-read.service.ts

@@ -8,7 +8,7 @@ import {
 } from 'src/core/strings/constants/base.constants';
 import { Repository } from 'typeorm';
 import { BaseReadService } from 'src/core/modules/data/service/base-read.service';
-import { TransactionPaymentType } from '../../constants';
+import { TransactionPaymentType, TransactionType } from '../../constants';
 
 @Injectable()
 export class TransactionReadService extends BaseReadService<TransactionEntity> {
@@ -24,8 +24,9 @@ export class TransactionReadService extends BaseReadService<TransactionEntity> {
       where: {
         status: STATUS.PENDING,
         payment_type: TransactionPaymentType.MIDTRANS,
+        type: TransactionType.ONLINE,
       },
-      select: ['id', 'invoice_date'],
+      select: ['id', 'invoice_date', 'created_at', 'booking_date'],
     });
 
     return transactions;

src/services/whatsapp/whatsapp.service.ts

@@ -324,10 +324,25 @@ export class WhatsappService {
       );
   }
 
-  async bookingRegister(data: WhatsappBookingCreate, paymentUrl: string) {
+  async bookingRegister(
+    data: WhatsappBookingCreate,
+    total: number,
+    paymentUrl: string,
+  ) {
     const momentDate = moment(data.time);
     const fallbackValue = momentDate.locale('id').format('dddd, DD MMMM YYYY');
 
+    const currentDate = moment().locale('id').format('DD MMMM YYYY');
+
+    const formattedTotal = new Intl.NumberFormat('id-ID', {
+      style: 'currency',
+      currency: 'IDR',
+      minimumFractionDigits: 0,
+      maximumFractionDigits: 0,
+    })
+      .format(total)
+      .replace('IDR', 'Rp');
+
     const payload = {
       messaging_product: 'whatsapp',
       to: phoneNumberOnly(data.phone), // recipient's phone number
@@ -351,6 +366,21 @@ export class WhatsappService {
                 parameter_name: 'booking_date',
                 text: fallbackValue,
               },
+              {
+                type: 'text',
+                parameter_name: 'created_date',
+                text: currentDate,
+              },
+              {
+                type: 'text',
+                parameter_name: 'booking_code',
+                text: data.code,
+              },
+              {
+                type: 'text',
+                parameter_name: 'total',
+                text: formattedTotal,
+              },
             ],
           },
           {