import {
  ConflictException,
  Injectable,
  InternalServerErrorException,
  NotFoundException,
} from '@nestjs/common';
import { GroupRepositoryImplement } from '../repository/group.repository.imple';
import { Group } from '../entities/group.entity';
import { CreateGroup, UpdateGroup } from '../dtos/group.dto';
import { Response } from '../../response/response';
import { ImportarService } from '../../common/importar/importar.service';
import { ProductsService } from './products.service';

@Injectable()
export class GroupService {
  constructor(
    private groupRepository: GroupRepositoryImplement,
    private productoService: ProductsService,
    private importarService: ImportarService,
  ) {}
  findAll(
    limit: number,
    offset: number,
    page: number,
    fech_ini: string,
    fech_fin: string,
    familia: number,
    linea: number,
    grupo: number
  ): Promise<Group[]> {
    return this.groupRepository.findAll(
      limit,
      offset,
      page,
      fech_ini,
      fech_fin,
      familia,
      linea,
      grupo
    );
  }
  findAllFilters(): Promise<Group[]> {
    return this.groupRepository.findAllFilters();
  }
  
  async findById(id: number): Promise<Group> {
    const grupo = await this.groupRepository.findById(id);
    if (!grupo) {
      throw new NotFoundException('Error', 'El grupo no existe');
    }
    return grupo;
  }

  async create(group: CreateGroup[]): Promise<Response> {
    let res = new Response();
    try {
      await this.groupRepository.create(group);
      res.cod = 200;
      res.message = `!Grupo creado exitosamente!`;
      res.status = true;
      return res;
    } catch (err) {
      if (err && err.length > 0) {
        throw new ConflictException(err);
      } else {
        throw new InternalServerErrorException(err.message);
      }
    }
  }
  async update(id: number, group: UpdateGroup): Promise<Response> {
    let res = new Response();
    const lsProduct =  await this.productoService.countProductoXIdGrupo(id)
    if (lsProduct.length > 0) throw new ConflictException(
      'Error',
      `El Grupo a actualizar ya cuenta con productos vinculados, no se puede actualizar`,
    );
    const exist = await this.findById(id);
    if (exist) {
      try {
        await this.groupRepository.update(id, group);
        res.cod = 200;
        res.message = `!Grupo actualizado exitosamente!`;
        res.status = true;
        return res;
      } catch (err) {
        throw new InternalServerErrorException(err.message);
      }
    } else {
      throw new NotFoundException('Error', 'El grupo no existe');
    }
  }

  async delete(id: number) {
    try {
      let res = new Response();
      await this.groupRepository.delete(id);
      res.cod = 200;
      res.message = `!Grupo Eliminado exitosamente!`;
      res.status = true;
      return res;
    } catch (err) {
      if (err.message.includes('foreign key constraint fails')) {
        throw new ConflictException(
          'Error',
          `Imposible eliminar el grupo. Hay Familias, lineas y productos vinculados a él. Desvincula o elimina antes de intentar nuevamente`,
        );
      } else {
        throw new InternalServerErrorException(err.message);
      }
    }
  }
  async findByIdLinea(id: number): Promise<Group[]> {
    const linea = await this.groupRepository.findByIdLinea(id);
    if (!linea) {
      throw new NotFoundException(
        'Error',
        'No existe grupos por esa linea no existe',
      );
    }
    return linea;
  }
  async exportarExcel_v1(
    fech_ini: string,
    fech_fin: string,
    familia: number,
    linea: number
  ) {
    const sheetName = 'Grupo';
    const columnHeaders = [
      'Codigo Familia',
      'Descripción Familia',
      'Codigo Linea',
      'Descripción Linea',
      'Codigo Grupo',
      'Descripción Grupo',
      'Codigo en Conjunto',
      'Total Productos',
      'Fecha Registro'
    ];
    const data = await this.groupRepository.findAll(
      100000,
      0,
      1,
      fech_ini,
      fech_fin,
      familia,
      linea,
      0
    );
    const listGrupo = [];
    data.registros.forEach((row) => {
      const ro = [
        row.cod_fam,
        row.des_fam,
        row.cod_line,
        row.des_line,
        row.cod_gru,
        row.des_gru,
        // `${row.cod_fam}-${row.des_fam}`,
        // `${row.cod_line}-${row.des_line}`,
        row.cod_gru_final,
        row.total_product,
        row.fec_regis
      ];
      listGrupo.push(ro);
    });
    return await this.importarService.exportarExcel(
      sheetName,
      columnHeaders,
      listGrupo
    );
  }
  async exportarExcel(
    fech_ini: string,
    fech_fin: string,
    familia: number,
    linea: number
  ) {
    const sheetName = 'Grupo';
    const columnHeaders = [
      'Codigo Familia',
      'Descripción Familia',
      'Codigo Linea',
      'Descripción Linea',
      'Codigo Grupo',
      'Descripción Grupo',
      'Fecha Registro'
    ];
    const data = await this.groupRepository.findAll(
      100000,
      0,
      1,
      fech_ini,
      fech_fin,
      familia,
      linea, 
      0
    );
    const listGrupo = [];
    data.registros.forEach((row) => {
      const ro = [
        row.cod_fam,
        row.des_fam,
        row.cod_line,
        row.des_line,
        row.cod_gru,
        row.des_gru,
        row.fec_regis
      ];
      listGrupo.push(ro);
    });
    return await this.importarService.exportarExcel(
      sheetName,
      columnHeaders,
      listGrupo
    );
  }
  async exportarPdf(
    fech_ini: string,
    fech_fin: string,
    familia: number,
    linea: number
  ): Promise<ArrayBuffer> {
    const columnHeaders = [
      'Codigo Grupo',
      'Descripción Grupo',
      'Familia',
      'Linea',
      'Codigo en Conjunto',
      'Total Productos',
      'Fecha Registro'
    ];
    const data = await this.groupRepository.findAll(
      100000,
      0,
      1,
      fech_ini,
      fech_fin,
      familia,
      linea,
      0
    );
    const listGrupo = [];
    data.registros.forEach((row) => {
      const fecRegis = new Date(row.fec_regis).toISOString().slice(0, 10);
      const ro = [
        row.cod_gru,
        row.des_gru,
        `${row.cod_fam}-${row.des_fam}`,
        `${row.cod_line}-${row.des_line}`,
        row.cod_gru_final,
        row.total_product,
        fecRegis
      ];
      listGrupo.push(ro);
    });
    return this.importarService.exportarPdf(
      listGrupo,
      columnHeaders,
      'Reporte de Grupos de Productos'
    );
  }
}