import { Injectable, NotFoundException } from '@nestjs/common';
import { InjectRepository } from '@nestjs/typeorm';
import { Repository } from 'typeorm';
import { Contact } from './entities/contact.entity.js';
import { Company } from '../companies/entities/company.entity.js';
import { CreateContactDto } from './dto/create-contact.dto.js';
import { UpdateContactDto } from './dto/update-contact.dto.js';
import { QueryContactDto } from './dto/query-contact.dto.js';
import { PaginatedResponseDto } from '../common/dto/pagination.dto.js';

@Injectable()
export class ContactsService {
  constructor(
    @InjectRepository(Contact)
    private contactsRepository: Repository<Contact>,
    @InjectRepository(Company)
    private companiesRepository: Repository<Company>,
  ) {}

  async create(companyId: string, createContactDto: CreateContactDto): Promise<Contact> {
    const contact = this.contactsRepository.create({
      ...createContactDto,
      companyId,
    });
    return this.contactsRepository.save(contact);
  }

  async findAllByCompany(companyId: string, query: QueryContactDto): Promise<PaginatedResponseDto<any>> {
    const { page = 1, limit = 20, search } = query;
    const skip = (page - 1) * limit;

    const qb = this.contactsRepository
      .createQueryBuilder('contact')
      .leftJoin(Company, 'company', 'company.id = contact.companyId')
      .select([
        'contact.id',
        'contact.companyId',
        'contact.name',
        'contact.designation',
        'contact.mobile',
        'contact.email',
        'contact.createdAt',
        'contact.updatedAt',
      ])
      .addSelect('company.companyName', 'companyName')
      .where('contact.companyId = :companyId', { companyId });

    if (search) {
      qb.andWhere(
        '(contact.name ILIKE :search OR contact.designation ILIKE :search OR contact.mobile ILIKE :search OR contact.email ILIKE :search OR company.companyName ILIKE :search)',
        { search: `%${search}%` },
      );
    }

    qb.orderBy('contact.createdAt', 'DESC');

    const rawResults = await qb.offset(skip).limit(limit).getRawMany();
    const totalQb = this.contactsRepository
      .createQueryBuilder('contact')
      .leftJoin(Company, 'company', 'company.id = contact.companyId')
      .where('contact.companyId = :companyId', { companyId });

    if (search) {
      totalQb.andWhere(
        '(contact.name ILIKE :search OR contact.designation ILIKE :search OR contact.mobile ILIKE :search OR contact.email ILIKE :search OR company.companyName ILIKE :search)',
        { search: `%${search}%` },
      );
    }

    const total = await totalQb.getCount();

    const data = rawResults.map((raw) => ({
      id: raw.contact_id,
      companyId: raw.contact_companyId,
      name: raw.contact_name,
      designation: raw.contact_designation,
      mobile: raw.contact_mobile,
      email: raw.contact_email,
      createdAt: raw.contact_createdAt,
      updatedAt: raw.contact_updatedAt,
      companyName: raw.companyName || null,
    }));

    return new PaginatedResponseDto(data, total, page, limit);
  }

  async findAll(query: QueryContactDto): Promise<PaginatedResponseDto<any>> {
    const { page = 1, limit = 20, search, companyId, designation } = query;
    const skip = (page - 1) * limit;

    const qb = this.contactsRepository
      .createQueryBuilder('contact')
      .leftJoin(Company, 'company', 'company.id = contact.companyId')
      .select([
        'contact.id',
        'contact.companyId',
        'contact.name',
        'contact.designation',
        'contact.mobile',
        'contact.email',
        'contact.createdAt',
        'contact.updatedAt',
      ])
      .addSelect('company.companyName', 'companyName');

    if (companyId) {
      qb.where('contact.companyId = :companyId', { companyId });
    }

    if (designation) {
      if (companyId) {
        qb.andWhere('contact.designation = :designation', { designation });
      } else {
        qb.where('contact.designation = :designation', { designation });
      }
    }

    if (search) {
      const whereClause = companyId || designation ? 'AND' : 'WHERE';
      qb.andWhere(
        `${whereClause} (contact.name ILIKE :search OR contact.designation ILIKE :search OR contact.mobile ILIKE :search OR contact.email ILIKE :search OR company.companyName ILIKE :search)`,
        { search: `%${search}%` },
      );
    }

    qb.orderBy('contact.createdAt', 'DESC');

    const rawResults = await qb.offset(skip).limit(limit).getRawMany();
    const totalQb = this.contactsRepository
      .createQueryBuilder('contact')
      .leftJoin(Company, 'company', 'company.id = contact.companyId');

    if (companyId) {
      totalQb.where('contact.companyId = :companyId', { companyId });
    }

    if (designation) {
      if (companyId) {
        totalQb.andWhere('contact.designation = :designation', { designation });
      } else {
        totalQb.where('contact.designation = :designation', { designation });
      }
    }

    if (search) {
      const whereClause = companyId || designation ? 'AND' : 'WHERE';
      totalQb.andWhere(
        `${whereClause} (contact.name ILIKE :search OR contact.designation ILIKE :search OR contact.mobile ILIKE :search OR contact.email ILIKE :search OR company.companyName ILIKE :search)`,
        { search: `%${search}%` },
      );
    }

    const total = await totalQb.getCount();

    const data = rawResults.map((raw) => ({
      id: raw.contact_id,
      companyId: raw.contact_companyId,
      name: raw.contact_name,
      designation: raw.contact_designation,
      mobile: raw.contact_mobile,
      email: raw.contact_email,
      createdAt: raw.contact_createdAt,
      updatedAt: raw.contact_updatedAt,
      companyName: raw.companyName || null,
    }));

    return new PaginatedResponseDto(data, total, page, limit);
  }

  async findOne(id: string): Promise<Contact> {
    const contact = await this.contactsRepository.findOne({ where: { id } });
    if (!contact) {
      throw new NotFoundException('Contact not found');
    }
    return contact;
  }

  async update(id: string, updateContactDto: UpdateContactDto): Promise<Contact> {
    const contact = await this.findOne(id);
    Object.assign(contact, updateContactDto);
    return this.contactsRepository.save(contact);
  }

  async remove(id: string): Promise<void> {
    const contact = await this.findOne(id);
    await this.contactsRepository.remove(contact);
  }
}