<?php
/**
* Classe ProductsCompanies.class.php
* @filesource
* @autor		Kenio de Souza
* @copyright	Copyright 2023 - Souza Consultoria Tecnológica
* @package		vendor
* @subpackage	model
* @version		1.0
* @date			05/07/2023
*
*
*/


/** Defino o local onde esta a classe */
namespace vendor\model;

class ProductsCompanies
{
	/** Declaro as vaiavéis da classe */
	private $connection = null;
	private $sql = null;
	private $stmt = null;
	private $start = null;
	private $max = null;
	private $limit = null;
	private $companyProductId = null;
	private $companyId = null;
	private $productsId = null;
	private $dateContract = null;
	private $dateCreate = null;
	private $dateUpdate = null;
	private $dateDelete = null;
	private $usersIdCreate = null;
	private $usersIdUpdate = null;
	private $usersIdDelete = null;
	private $description = null;
	private $field = null;
	private $readjustment = null;
	private $productValue = null;
	private $maturity = null;
	private $month = null;
	private $dateStart = null;
	private $dateEnd = null;
	private $search;

	/** Construtor da classe */
	function __construct()
	{
		/** Cria o objeto de conexão com o banco de dados */
		$this->connection = new Mysql();
	}

	/** Carrega os campos de uma tabela */
	public function Describe()
	{

		/** Consulta SQL */
		$this->sql = "describe products_companies";

		/** Preparo o SQL para execução */
		$this->stmt = $this->connection->connect()->prepare($this->sql);

		/** Executo o SQL */
		$this->stmt->execute();

		/** Retorno o resultado */
		$this->field = $this->stmt->fetchAll(\PDO::FETCH_OBJ);

		/** Declara o objeto */
		$resultDescribe = new \stdClass();
		$Field = '';

		/** Lista os campos da tabela para objetos */
		foreach($this->field as $UsersKey => $Result){

			/** Pega o nome do Field/Campo */
			$Field = $Result->Field;

			/** Carrega os objetos como null */
			$resultDescribe->$Field = null;

		}

		/** Retorna os campos declarados como vazios */
		return $resultDescribe;

	}

	/** Lista os registros do banco de dados com limitação */
	public function Get(int $companyProductId)
	{

		/** Parametros de entrada */
		$this->companyProductId = $companyProductId;

		/** Consulta SQL */
		$this->sql = 'select * from products_companies  
					  where product_company_id = :product_company_id';

		/** Preparo o SQL para execução */
		$this->stmt = $this->connection->connect()->prepare($this->sql);

		/** Preencho os parâmetros do SQL */
		$this->stmt->bindParam(':product_company_id', $this->companyProductId);

		/** Executo o SQL */
		$this->stmt->execute();

		/** Retorno o resultado */
		return $this->stmt->fetchObject();

	}

	/** Lista todos os egistros do banco com ou sem paginação*/
	public function All(int $companyId)
	{
		/** Parametros de entrada */
		$this->companyId = $companyId;

		/** Consulta SQL */
		$this->sql = 'SELECT cp.maturity,
							 cp.readjustment,
							 GROUP_CONCAT(cp.product_company_id ORDER BY cp.product_company_id SEPARATOR \',\') AS product_company_ids,
							 GROUP_CONCAT(cp.product_id ORDER BY cp.product_company_id SEPARATOR \',\') AS product_ids,
							 GROUP_CONCAT(cp.description ORDER BY cp.product_company_id SEPARATOR \',\') AS descriptions,
							 GROUP_CONCAT(p.description ORDER BY cp.product_company_id SEPARATOR \',\') AS products,
							 GROUP_CONCAT(p.reference ORDER BY cp.product_company_id SEPARATOR \',\') AS `references`,
							 GROUP_CONCAT(cp.product_value ORDER BY cp.product_company_id SEPARATOR \',\') AS product_values,
							 GROUP_CONCAT(p.type ORDER BY cp.product_company_id SEPARATOR \',\') AS product_types,
							 SUM(cp.product_value) AS total_product_value
					  FROM 
						products_companies cp
					 LEFT JOIN 
						products p ON cp.product_id = p.product_id
					  WHERE 
					 	cp.company_id = :company_id
							AND cp.status = \'A\'
						GROUP BY 
							cp.maturity, cp.readjustment, p.type;';

		/** Preparo o SQL para execução */
		$this->stmt = $this->connection->connect()->prepare($this->sql);

		/** Preencho os parâmetros do SQL */
		$this->stmt->bindParam(':company_id', $this->companyId);		

		/** Executo o SQL */
		$this->stmt->execute();

		/** Retorno o resultado */
		return $this->stmt->fetchAll(\PDO::FETCH_OBJ);

	}	

	/** Lista todos os egistros do banco com ou sem paginação*/
	public function Readjustment(string $readjustment)
	{
		/** Parametros de entrada */
		$this->readjustment = $readjustment;

		/** Lista de meses do ano */
		$this->month = ['janeiro'   => '01',
						'fevereiro' => '02',
						'março'     => '03',
						'abril'     => '04',
						'maio'      => '05',
						'junho'     => '06',
						'julho'     => '07',
						'agosto'    => '08',
						'setembro'  => '09',
						'outubro'   => '10',
						'novembro'  => '11',
						'dezembro'  => '12'
						];

		/** Prepara a data de consulta */
		$this->dateStart = date('Y').'-'.$this->month[$this->readjustment].'-01';
		$this->dateEnd = (date('Y')+1).'-'.$this->month[$this->readjustment].'-01';		

		/** Consulta SQL */
		$this->sql = 'select distinct(c.company_id),
							 c.user_id,
							 c.company_id,
							 c.reference,
							 c.name_business,
							 c.name_fantasy,
							 c.cnpj,
							 c.zip_code,
							 c.adress,
							 c.number,
							 c.complement,
							 c.district,
							 c.city,
							 c.state,
							 c.state_initials,
							 c.country,
							 c.date_register,
							 c.responsible,
							 c.active,
							 c.type,							 
							 c.email,
							 c.contract_type,
							 c.contract_date,
                             cp.maturity,
							 (select cp.maturity from products_companies cp where cp.company_id = c.company_id limit 0, 1) as due_date		
					  from companies c 
					  left join products_companies cp on c.company_id = cp.company_id
					  where cp.readjustment = :readjustment
					  and (select count(fm.financial_movements_id) 
					       from financial_movements fm
						   where fm.movement_date_scheduled between \''.$this->dateStart.'\' and \''.$this->dateEnd.'\'
						   and fm.company_id = c.company_id) = 0 
					  order by cp.maturity asc';					  

		/** Preparo o SQL para execução */
		$this->stmt = $this->connection->connect()->prepare($this->sql);

		/** Preencho os parâmetros do SQL */
		$this->stmt->bindParam(':readjustment', $this->readjustment);		

		/** Executo o SQL */
		$this->stmt->execute();

		/** Retorno o resultado */
		return $this->stmt->fetchAll(\PDO::FETCH_OBJ);

	}

	/** Conta a quantidades de registros */
	public function Count(int $companyId)
	{
		
		/** Parametros de entrada */
		$this->companyId = $companyId;		
		
		/** Consulta SQL */
		$this->sql = 'select count(product_company_id) as qtde
					  from products_companies where company_id = :company_id ';

		/** Preparo o SQL para execução */
		$this->stmt = $this->connection->connect()->prepare($this->sql);

		/** Preencho os parâmetros do SQL */
		$this->stmt->bindParam(':company_id', $this->companyId);		

		/** Executo o SQL */
		$this->stmt->execute();

		/** Retorno o resultado */
		return $this->stmt->fetchObject()->qtde;

	}

	/** Insere um novo registro no banco */
	public function Save(int $companyProductId, 
	                     int $companyId, 
						 int $productsId, 
						 ? string $dateContract, 
						 string $description, 
						 string $readjustment, 
						 ? float $productValue, 
						 int $maturity)
	{


		/** Parametros */
		$this->companyProductId = $companyProductId;
		$this->companyId = $companyId;
		$this->productsId = $productsId;
		$this->dateContract = $dateContract;
		$this->usersIdCreate = $_SESSION['USERSID'];//Carrega o ID do usuário logado
		$this->usersIdUpdate = $_SESSION['USERSID'];//Carrega o ID do usuário logado
		$this->description = $description;
		$this->readjustment = $readjustment;
		$this->productValue = $productValue;
		$this->maturity = $maturity;
	

		/** Verifica se o ID do registro foi informado */
		if($this->companyProductId > 0){

			/** Consulta SQL */
			$this->sql = 'update products_companies set product_id = :product_id,
													 date_contract = :date_contract,
													 date_update = CURRENT_TIMESTAMP,
													 user_id_update = :user_id_update,
													 description = :description,
													 readjustment = :readjustment,
													 product_value = :product_value,
													 maturity = :maturity
					  	  where product_company_id = :product_company_id';

		}else{//Se o ID não foi informado, grava-se um novo registro

			/** Consulta SQL */
			$this->sql = 'insert into products_companies(product_company_id, 
													  company_id, 
													  product_id, 
													  user_id_create,
													  date_contract, 			
													  description,
													  readjustment,
													  product_value,
													  maturity 
											) values (:product_company_id, 
													  :company_id,
													  :product_id,
													  :user_id_create,
													  :date_contract,			
													  :description,
													  :readjustment,
													  :product_value,
													  :maturity)';

		}

		/** Preparo o sql para receber os valores */
		$this->stmt = $this->connection->connect()->prepare($this->sql);

		/** Preencho os parâmetros do SQL */
		$this->stmt->bindParam('product_company_id', $this->companyProductId);		
		$this->stmt->bindParam('product_id', $this->productsId);
		$this->stmt->bindParam('date_contract', $this->dateContract);		
		$this->stmt->bindParam('description', $this->description);
		$this->stmt->bindParam('readjustment', $this->readjustment);
		$this->stmt->bindParam('product_value', $this->productValue);
		$this->stmt->bindParam('maturity', $this->maturity);

		if($this->companyProductId > 0){

			$this->stmt->bindParam('user_id_update', $this->usersIdUpdate);

		}else{

			$this->stmt->bindParam('user_id_create', $this->usersIdCreate);
			$this->stmt->bindParam('company_id', $this->companyId);
		}

		/** Executo o SQL */
		return $this->stmt->execute();

	}

	/** Deleta um determinado registro no banco de dados */
	function Delete(int $companyProductId)
	{
		/** Parametros de entrada */
		$this->companyProductId = $companyProductId;
		$this->usersIdDelete = $_SESSION['USERSID'];//Carrega o ID do usuário logado

		/** Consulta SQL */
		$this->sql = 'update products_companies set status = \'E\',
		                                         date_delete = CURRENT_TIMESTAMP,
												 user_id_delete = :user_id_delete
					  where  product_company_id = :product_company_id';

		/** Preparo o sql para receber os valores */
		$this->stmt = $this->connection->connect()->prepare($this->sql);

		/** Preencho os parâmetros do SQL */
		$this->stmt->bindParam('product_company_id', $this->companyProductId);
		$this->stmt->bindParam('user_id_delete', $this->usersIdDelete);

		/** Executo o SQL */
		return $this->stmt->execute();

	}

	/** Atualiza o valor do produto */
	public function UpdateValueProduct(int $companyId, int $productsId, float $productValue)
	{

		/** Parametros de entrada */
		$this->companyId  = $companyId;
		$this->productsId = $productsId;
		$this->productValue = $productValue;

		/** Consulta SQL */
		$this->sql = 'update products_companies set product_value = :product_value 
					  where  company_id = :company_id 
					  and product_id = :product_id';

		/** Preparo o sql para receber os valores */
		$this->stmt = $this->connection->connect()->prepare($this->sql);

		/** Preencho os parâmetros do SQL */
		$this->stmt->bindParam('company_id', $this->companyId);
		$this->stmt->bindParam('product_id', $this->productsId);
		$this->stmt->bindParam('product_value', $this->productValue);

		/** Executo o SQL */
		return $this->stmt->execute();					  

	}

	/** Fecha uma conexão aberta anteriormente com o banco de dados */
	function __destruct()
	{
		$this->connection = null;
    }
}