create ticket

src/modules/ticket/providers/tickets.service.ts

@@ -1,57 +1,71 @@
+import { TicketRepository } from "../repositories/tickets.repository";
 import { InjectQueue } from "@nestjs/bullmq";
 import { BadRequestException, HttpException, Injectable, InternalServerErrorException, Logger, OnModuleInit } from "@nestjs/common";
 import { Queue } from "bullmq";
 import dayjs from "dayjs";
-// import { DataSource, MoreThanOrEqual, Not, QueryRunner } from "typeorm";
+import { CreateTicketDto } from "../DTO/create-ticket.dto";
+import { OrderRepository } from "src/modules/order/repositories/order.repository";
+import { User } from "src/modules/user/entities/user.entity";
+import { UserRepository } from "src/modules/user/repositories/user.repository";
+import { AdminRepository } from "src/modules/admin/repositories/admin.repository";
+import { Admin } from "src/modules/admin/entities/admin.entity";
 
-// import { TICKET } from "../constant";
-// import { ReferralService } from "./referral.service";
-// import { IUserIpAndHeaders } from "../../../common/decorators/user.decorator";
-// import { ParamDto } from "../../../common/DTO/param.dto";
-// import { CommonMessage, TicketMessageEnum, UserMessage } from "../../../common/enums/message.enum";
-// import { UserType } from "../../access-logs/enums/user-type.enum";
-// import { AccessLogService } from "../../access-logs/providers/access-log.service";
-// import { DanakService } from "../../danak-services/entities/danak-service.entity";
-// import { NotificationQueue } from "../../notifications/queue/notification.queue";
-// import { SupportPlanFeatureKey } from "../../support-plans/enums/support-plan-feature-key.enum";
-// import { SupportPlansService } from "../../support-plans/providers/support-plans.service";
-// import { User } from "../../users/entities/user.entity";
-// import { AdminsService } from "../../users/providers/admins.service";
-// import { UsersService } from "../../users/providers/users.service";
-// import { CreateTicketCategoryDto } from "../DTO/create-ticket-category.dto";
-// import { CreateTicketMessageDto } from "../DTO/create-ticket-message.dto";
-// import { CreateTicketByAdminDto, CreateTicketDto } from "../DTO/create-ticket.dto";
-// import { ReferTicketDto } from "../DTO/refer-ticket.dto";
-// import { SearchTicketCategoryDto } from "../DTO/search-ticket-category.dto";
-// import { SearchTicketQueryDto } from "../DTO/search-ticket-query.dto";
-// import { UpdateTicketCategoryDto } from "../DTO/update-ticket-category.dto";
-// import { TicketCategory } from "../entities/ticket-category.entity";
-// import { TicketMessageAttachment } from "../entities/ticket-message-attachment";
-// import { TicketMessage } from "../entities/ticket-message.entity";
-// import { Ticket } from "../entities/ticket.entity";
-// import { TicketStatus } from "../enums/ticket-status.enum";
-// import { TicketCategoryRepository } from "../repositories/tickets-category.repository";
-// import { TicketMessagesRepository } from "../repositories/tickets-message.repository";
-// import { TicketsRepository } from "../repositories/tickets.repository";
 
 @Injectable()
 export class TicketService {
   private readonly logger = new Logger(TicketService.name);
 
-  // constructor(
-  //   @InjectQueue(TICKET.QUEUE_NAME) private readonly ticketQueue: Queue,
-  //   private readonly ticketsRepository: TicketsRepository,
-  //   private readonly ticketsCategoryRepository: TicketCategoryRepository,
-  //   private readonly ticketMessagesRepository: TicketMessagesRepository,
-  //   private readonly usersService: UsersService,
-  //   private readonly adminsService: AdminsService,
-  //   private readonly notificationQueue: NotificationQueue,
-  //   private readonly referralService: ReferralService,
-  //   private readonly dataSource: DataSource,
-  //   private readonly supportPlansService: SupportPlansService,
-  //   private readonly accessLogService: AccessLogService,
-  // ) {}
+  constructor(
+    private readonly ticketsRepository: TicketRepository,
+    private readonly orderRepository: OrderRepository,
+    private readonly userRepository: UserRepository,
+    private readonly adminRepository: AdminRepository,
+    // private readonly adminsService: AdminsService,
+  ) { }
 
+  async createTicket(orderId: string, dto: CreateTicketDto, userId?: string, adminId?: string) {
+    const { content, attachments } = dto
+    if (!userId && !adminId) {
+      throw new BadRequestException("One of userId ord adminId is required")
+    }
+    const order = await this.orderRepository.findOne({ id: orderId })
+    if (!order) {
+      throw new BadRequestException("Order not found")
+    }
+
+    let user: null | User = null
+    let admin: null | Admin = null
+    
+    if (userId) {
+      user = await this.userRepository.findOne({ id: userId })
+      if (!user) {
+        throw new BadRequestException("User not found")
+      }
+    }
+    if (adminId) {
+      admin = await this.adminRepository.findOne({ id: adminId })
+      if (!admin) {
+        throw new BadRequestException("Admin not found")
+      }
+    }
+
+    if (!user && !admin) {
+      throw new BadRequestException("One of user or admin is required")
+    }
+
+    const ticket = this.ticketsRepository.create({
+      content,
+      attachments,
+      admin,
+      user,
+      order,
+    })
+
+    await this.ticketsRepository.em.persistAndFlush(ticket)
+
+    return ticket
+
+  }
   // async onModuleInit() {
   //   await this.scheduleAutoCloseJob();
   // }