<?php

class Installments
{
  private $db;


  public $id = null;
  public $name = null;
  public $description = null;
  public $type = null;
  public $initial_payment = null;
  public $payment_period = null;
  public $allow_change_on_close = null;
  public $interest_rate = null;
  public $comment = null;
  public $agency_id = null;
  public $is_archive = null;
  public $created_at = null;
  public $updated_at = null;

  public $user_agency_id;
  public $user_id;
  public $user;

  public function __construct($id = null, $customDb)
  {
    $pdo = $customDb ? $customDb : new MysqlPdo(hst, ndb, user, pass);
    $sql = "SET NAMES 'utf8'";
    $pdo->query($sql);
    $this->db = $pdo;

    $this->user_agency_id = isset($_SESSION['agency_id']) ? $_SESSION['agency_id'] : 0;
    $this->user_id = isset($_SESSION['id']) ? $_SESSION['id'] : 0;
    $this->user = new User;

    if ($id && is_int($id))
    {
      $sql = $this->db->query("SELECT * FROM installments WHERE `installments.id` = {$id}");
      $installment = $this->db->fetch_assoc($sql);

      if ($installment)
      {
        $this->id = $installment['id'];
        $this->name = $installment['name'];
        $this->description = $installment['description'];
        $this->type = $installment['type'];
        $this->initial_payment = $installment['initial_payment'];
        $this->payment_period = $installment['payment_period'];
        $this->allow_change_on_close = $installment['allow_change_on_close'];
        $this->interest_rate = $installment['interest_rate'];
        $this->comment = $installment['comment'];
        $this->agency_id = $installment['agency_id'];
        $this->is_archive = $installment['is_archive'];
        $this->created_at = $installment['created_at'];
        $this->updated_at = $installment['updated_at'];
      }
    }
  }

  private function installments($is_archive = 0)
  {
    $agency_id = $this->user_agency_id;
    $sql = "SELECT * FROM installments WHERE `agency_id` = $agency_id AND `is_archive` = $is_archive";

    if ($res = $this->db->query($sql))
    {
      $installments = array();

      while ($cs = $this->db->fetch_assoc($res))
      {
        // Декодируем payment_period из JSON в массив
        if (!empty($cs['payment_period'])) {
          $decoded = json_decode($cs['payment_period'], true);
          $cs['payment_period'] = ($decoded !== null && is_array($decoded)) ? $decoded : [];
        } else {
          $cs['payment_period'] = [];
        }
        $installments[] = $cs;
      }

      return $installments;
    }

    return [];
  }

  public function getInstallments()
  {
    return $this->installments(0);
  }

  public function getArchiveInstallments()
  {
    return $this->installments(1);
  }

  public function getById($id)
  {
    $id = (int) $id;
    $sql = "SELECT * FROM installments WHERE id = $id LIMIT 1";

    $result = $this->db->query($sql);
    $row = $this->db->fetch_assoc($result);

    if ($row && !empty($row['payment_period'])) {
      $decoded = json_decode($row['payment_period'], true);
      $valid_periods = ['monthly', 'quarterly', 'yearly'];
      $row['payment_period'] = ($decoded !== null && is_array($decoded))
        ? array_intersect($decoded, $valid_periods)
        : [];
    } else {
      $row['payment_period'] = [];
    }

    return $row;
  }

  public function addEdit($installment)
  {
    $agency_id = $this->user_agency_id;

    if (!$installment || !$agency_id) {
      return false;
    }

    // Обработка входных данных
    $name = isset($installment->name) ? trim($installment->name) : '';
    $type = isset($installment->type) ? trim($installment->type) : '';
    // Сериализация payment_period в JSON строку
    $payment_period = isset($installment->payment_period)
      ? (is_array($installment->payment_period)
        ? json_encode($installment->payment_period)
        : json_encode([$installment->payment_period])) // Если строка, преобразуем в массив
      : json_encode([]); // Пустой массив по умолчанию
    $description = isset($installment->description) ? trim($installment->description) : null;
    $initial_payment = isset($installment->initial_payment) ? (float) $installment->initial_payment : null;
    $allow_change_on_close = isset($installment->allow_change_on_close) ? (int) $installment->allow_change_on_close : 0;
    $interest_rate = isset($installment->interest_rate) ? (float) $installment->interest_rate : null;
    $comment = isset($installment->comment) ? trim($installment->comment) : null;

    // Проверка корректности JSON
    if ($payment_period === false) {
      error_log('JSON encoding failed for payment_period: ' . print_r($installment->payment_period, true));
      return false;
    }

    // Проверка на некорректное значение
    if (!is_array($installment->payment_period) && $installment->payment_period === 'Array') {
      error_log('Invalid payment_period value: ' . print_r($installment->payment_period, true));
      return false;
    }

    if (!empty($installment->id) && $this->getById($installment->id)) {
      $id = (int) $installment->id;
      $sql = "UPDATE installments
                SET agency_id = $agency_id,
                    name = '$name',
                    type = '$type',
                    payment_period = '$payment_period',
                    description = " . ($description !== null ? "'$description'" : "NULL") . ",
                    initial_payment = " . ($initial_payment !== null ? $initial_payment : "NULL") . ",
                    allow_change_on_close = $allow_change_on_close,
                    interest_rate = " . ($interest_rate !== null ? $interest_rate : "NULL") . ",
                    comment = " . ($comment !== null ? "'$comment'" : "NULL") . ",
                    is_archive = 0
                WHERE id = $id";

      $result = $this->db->query($sql);
      return $result ? $this->getById($id) : false;
    } else {
      $sql = "INSERT INTO installments (agency_id, name, type, payment_period, description, initial_payment, allow_change_on_close, interest_rate, comment, is_archive)
                VALUES ($agency_id, '$name', '$type', '$payment_period', " .
        ($description !== null ? "'$description'" : "NULL") . ", " .
        ($initial_payment !== null ? $initial_payment : "NULL") . ", " .
        "$allow_change_on_close, " .
        ($interest_rate !== null ? $interest_rate : "NULL") . ", " .
        ($comment !== null ? "'$comment'" : "NULL") . ", " .
        "0)";

      $result = $this->db->query($sql);
      if ($result) {
        $new_id = $this->db->insert_id;
        return $this->getById($new_id);
      } else {
        return false;
      }
    }
  }

  public function toArchiveOrRecover($installment_id, $status)
  {
    $installment_id = (int) $installment_id;
    $status = ($status == 1) ? 1 : 0;

    if (!$installment_id || !$this->user_agency_id || !$this->getById($installment_id)) {
      return false;
    }

    if ($status === 1) {
      $this->db->query("DELETE FROM complex_house_installments WHERE installment_id = {$installment_id}");
    }

    $sql = "UPDATE `installments` SET `is_archive` = $status WHERE `id` = {$installment_id}";

    $result = $this->db->query($sql);
    return $result ? true : false;
  }

  public function delete($installment_id)
  {
    $installment_id = (int) $installment_id;

    // Проверка наличия ID, агентства и существования рассрочки
    if (!$installment_id || !$this->user_agency_id || !$this->getById($installment_id)) {
      return false;
    }

    $this->db->query("DELETE FROM complex_house_installments WHERE installment_id = {$installment_id}");

    // Удаление записи
    $sql = "DELETE FROM installments WHERE id = $installment_id AND agency_id = {$this->user_agency_id}";
    $result = $this->db->query($sql);


    return $result ? true : false;
  }

  public function updateHouseInstallments($house_id, $installments)
  {
    // Удаляем старые связи
    $this->db->query("DELETE FROM complex_house_installments WHERE house_id = " . (int)$house_id);

    $hasInstallments = !empty($installments) && is_array($installments);

    if ($hasInstallments) {
      // Добавляем новые записи
      foreach ($installments as $i) {
        $installment_id = (int)$i['id'];
        $end_date = !empty($i['end_date']) ? "'" . date('Y-m-d', strtotime($i['end_date'])) . "'" : "NULL";

        $this->db->query("
                        INSERT INTO complex_house_installments (house_id, installment_id, end_date)
                        VALUES ($house_id, $installment_id, $end_date)
                    ");
      }

      // Обновляем payment_types и installment_price у помещений
      $rooms = $this->db->query("
                    SELECT complex_rooms.id, complex_rooms.payment_types, complex_rooms.total_amount
                    FROM complex_rooms
                    JOIN complex_floors ON complex_floors.id = complex_rooms.floor_id 
                    JOIN complex_entrances ON complex_floors.complex_entrance_id = complex_entrances.id
                    JOIN complex_houses ON complex_entrances.complex_house_id = complex_houses.id
                    WHERE complex_houses.id = " . (int)$house_id
      );

      while ($room = $this->db->fetch_assoc($rooms)) {
        $roomId = (int)$room['id'];
        $totalAmount = (float)$room['total_amount'];
        $paymentTypes = json_decode($room['payment_types'], true);

        if (!is_array($paymentTypes)) {
          $paymentTypes = [];
        }

        if (!in_array('INSTALLMENT', $paymentTypes)) {
          $paymentTypes[] = 'INSTALLMENT';
          $updatedJson = json_encode(array_values($paymentTypes));
          $escapedJson = "'" . addslashes($updatedJson) . "'";

          $this->db->query("
                        UPDATE complex_rooms
                        SET
                            payment_types = $escapedJson,
                            installment_price = $totalAmount
                        WHERE id = $roomId
                    ");
        }
      }
    } else {
      // Удаляем INSTALLMENT из payment_types
      $rooms = $this->db->query("
                    SELECT complex_rooms.id, complex_rooms.payment_types
                    FROM complex_rooms
                    JOIN complex_floors ON complex_floors.id = complex_rooms.floor_id 
                    JOIN complex_entrances ON complex_floors.complex_entrance_id = complex_entrances.id
                    JOIN complex_houses ON complex_entrances.complex_house_id = complex_houses.id
                    WHERE complex_houses.id = " . (int)$house_id
      );

      while ($room = $this->db->fetch_assoc($rooms)) {
        $roomId = (int)$room['id'];
        $paymentTypes = json_decode($room['payment_types'], true);

        if (!is_array($paymentTypes)) {
          $paymentTypes = [];
        }

        if (in_array('INSTALLMENT', $paymentTypes)) {
          $filteredTypes = [];
          foreach ($paymentTypes as $type) {
            if ($type !== 'INSTALLMENT') {
              $filteredTypes[] = $type;
            }
          }

          $updatedJson = json_encode($filteredTypes);
          $escapedJson = "'" . addslashes($updatedJson) . "'";

          $this->db->query("
                        UPDATE complex_rooms 
                        SET payment_types = $escapedJson
                        WHERE id = $roomId
                    ");
        }
      }
    }
  }

  public function getByHouseId($house_id)
  {
    $sql = "SELECT 
                  i.id,
                  i.name,
                  i.type,
                  i.description,
                  i.initial_payment,
                  i.payment_period,
                  i.interest_rate,
                  i.comment,
                  chi.end_date as house_installment_end_date
              FROM complex_house_installments chi
              LEFT JOIN installments i ON i.id = chi.installment_id
              WHERE chi.house_id = {$house_id}
              AND i.is_archive = 0
              AND (chi.end_date IS NULL OR chi.end_date >= CURDATE())";

    $result = $this->db->query($sql);
    $installmentsMap = [];

    while ($row = $this->db->fetch_assoc($result)) {
      $row['payment_period'] = explode(',', $row['payment_period']);

      // Исключаем дубликаты по i.id
      if (!isset($installmentsMap[$row['id']])) {
        $installmentsMap[$row['id']] = $row;
      }
    }

    return array_values($installmentsMap);
  }

  public function getByComplexId($complex_id)
  {
    $sql = "SELECT 
                  i.id,
                  i.name,
                  i.type,
                  i.description,
                  i.initial_payment,
                  i.payment_period,
                  i.interest_rate,
                  i.comment,
                  chi.end_date as house_installment_end_date,
                  chi.house_id
              FROM complex_house_installments chi
              LEFT JOIN installments i ON i.id = chi.installment_id
              LEFT JOIN complex_houses ch ON ch.id = chi.house_id
              WHERE ch.complex_id = {$complex_id}
              AND i.is_archive = 0
              AND (chi.end_date IS NULL OR chi.end_date >= CURDATE())";

    $result = $this->db->query($sql);
    $installmentsMap = [];

    while ($row = $this->db->fetch_assoc($result)) {
      $row['payment_period'] = explode(',', $row['payment_period']);

      // Используем ID в качестве ключа — исключаем дубликаты
      if (!isset($installmentsMap[$row['id']])) {
        $installmentsMap[$row['id']] = $row;
      }
    }

    return array_values($installmentsMap);
  }
}