577 lines
19 KiB
PHP
577 lines
19 KiB
PHP
<?php
|
|
/**
|
|
* Classe FinancialEntries.class.php
|
|
* @filesource
|
|
* @autor Kenio de Souza
|
|
* @copyright Copyright 2021 - Souza Consultoria Tecnológica
|
|
* @package vendor
|
|
* @subpackage model
|
|
* @version 1.0
|
|
* @date 12/11/2021
|
|
*/
|
|
|
|
|
|
/** Defino o local onde esta a classe */
|
|
namespace vendor\model;
|
|
|
|
class FinancialEntries
|
|
{
|
|
/** 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 $financialEntriesId = null;
|
|
private $companyId = null;
|
|
private $companyId = null;
|
|
private $usersId = null;
|
|
private $description = null; private $fixed = null;
|
|
private $duration = null;
|
|
private $startDate = null;
|
|
private $entrieValue = null;
|
|
private $endDate = null;
|
|
private $financialAccountsId = null;
|
|
private $active = null;
|
|
private $lastid = null;
|
|
private $movementDateScheduled = null;
|
|
private $financialCategoriesId = null;
|
|
private $field = null;
|
|
private $next = null;
|
|
private $companiesBudgetsId = null;
|
|
private $reference = null;
|
|
private $clientBudgetsResult = null;
|
|
private $lastEntriesId = null;
|
|
|
|
/** 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 financial_entries";
|
|
|
|
/** 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 $financialEntriesId)
|
|
{
|
|
|
|
/** Parametros de entrada */
|
|
$this->financialEntriesId = $financialEntriesId;
|
|
|
|
/** Consulta SQL */
|
|
$this->sql = 'select * from financial_entries
|
|
where financial_entries_id = :financial_entries_id';
|
|
|
|
/** Preparo o SQL para execução */
|
|
$this->stmt = $this->connection->connect()->prepare($this->sql);
|
|
|
|
/** Preencho os parâmetros do SQL */
|
|
$this->stmt->bindParam(':financial_entries_id', $this->financialEntriesId);
|
|
|
|
/** 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 $start, int $max)
|
|
{
|
|
/** Parametros de entrada */
|
|
$this->start = $start;
|
|
$this->max = $max;
|
|
|
|
/** Verifico se há paginação */
|
|
if($this->max){
|
|
$this->limit = "limit $this->start, $this->max";
|
|
}
|
|
|
|
/** Consulta SQL */
|
|
$this->sql = 'select financial_entries_id,
|
|
company_id,
|
|
company_id,
|
|
user_id,
|
|
financial_accounts_id,
|
|
description,
|
|
fixed,
|
|
duration,
|
|
start_date,
|
|
end_date,
|
|
entrie_value,
|
|
active
|
|
from financial_entries '. $this->limit;
|
|
|
|
/** Preparo o SQL para execução */
|
|
$this->stmt = $this->connection->connect()->prepare($this->sql);
|
|
|
|
/** Executo o SQL */
|
|
$this->stmt->execute();
|
|
|
|
/** Retorno o resultado */
|
|
return $this->stmt->fetchAll(\PDO::FETCH_OBJ);
|
|
|
|
}
|
|
|
|
/** Localiza a entrada de um respectivo orçamento */
|
|
public function GetBudgets(int $companiesBudgetsId)
|
|
{
|
|
/** Parametros de entrada */
|
|
$this->companiesBudgetsId = $companiesBudgetsId;
|
|
|
|
/** Consulta SQL */
|
|
$this->sql = 'select fm.financial_movements_id,
|
|
fm.financial_accounts_id,
|
|
fm.financial_entries_id,
|
|
fm.financial_outputs_id,
|
|
fm.user_id,
|
|
fm.company_id,
|
|
fm.company_id,
|
|
fm.description,
|
|
fm.movement_value,
|
|
fm.movement_value_paid,
|
|
fm.movement_value_fees,
|
|
fm.movement_date,
|
|
fm.movement_date_scheduled,
|
|
fm.movement_date_paid,
|
|
fm.status,
|
|
fm.note,
|
|
fm.movement_user_confirmed,
|
|
c.reference as reference_client,
|
|
fc.reference
|
|
from financial_movements fm
|
|
left join clients c on fm.company_id = c.company_id
|
|
left join client_budgets cb on fm.companies_budgets_id = cb.companies_budgets_id
|
|
left join financial_categories fc on cb.financial_categories_id = fc.financial_categories_id
|
|
where fm.companies_budgets_id = :companies_budgets_id';
|
|
|
|
/** Preparo o SQL para execução */
|
|
$this->stmt = $this->connection->connect()->prepare($this->sql);
|
|
|
|
/** Preencho os parâmetros do SQL */
|
|
$this->stmt->bindParam(':companies_budgets_id', $this->companiesBudgetsId);
|
|
|
|
/** Executo o SQL */
|
|
$this->stmt->execute();
|
|
|
|
/** Retorno o resultado */
|
|
return $this->stmt->fetchObject();
|
|
|
|
}
|
|
|
|
/** Conta a quantidades de registros */
|
|
public function Count()
|
|
{
|
|
/** Consulta SQL */
|
|
$this->sql = 'select count(financial_entries_id) as qtde
|
|
from financial_entries
|
|
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', $_SESSION['USERSCOMPANYID']);
|
|
|
|
/** Executo o SQL */
|
|
$this->stmt->execute();
|
|
|
|
/** Retorno o resultado */
|
|
return $this->stmt->fetchObject();
|
|
|
|
}
|
|
|
|
/** Insere um novo registro no banco */
|
|
public function Create(int $financialEntriesId, int $companyId, int $companiesBudgetsId, string $description, int $fixed, int $duration, string $startDate, float $entrieValue, string $endDate, int $financialAccountsId, string $active, int $financialCategoriesId)
|
|
{
|
|
|
|
/** Parametros */
|
|
$this->financialEntriesId = $financialEntriesId;
|
|
$this->companyId = $companyId > 0 ? $companyId : null;
|
|
$this->companiesBudgetsId = $companiesBudgetsId;
|
|
$this->description = $description;
|
|
$this->fixed = $fixed;
|
|
$this->duration = $duration;
|
|
$this->startDate = $startDate;
|
|
$this->entrieValue = $entrieValue;
|
|
$this->endDate = $endDate;
|
|
$this->financialAccountsId = $financialAccountsId;
|
|
$this->active = $active;
|
|
$this->financialCategoriesId = $financialCategoriesId;
|
|
|
|
/** Consulta SQL */
|
|
$this->sql = 'insert into financial_entries(company_id,
|
|
companies_budgets_id,
|
|
user_id,
|
|
description,
|
|
fixed,
|
|
duration,
|
|
start_date,
|
|
entrie_value,
|
|
end_date,
|
|
financial_accounts_id,
|
|
financial_categories_id,
|
|
active
|
|
) values (:company_id,
|
|
:companies_budgets_id,
|
|
:user_id,
|
|
:description,
|
|
:fixed,
|
|
:duration,
|
|
:start_date,
|
|
:entrie_value,
|
|
:end_date,
|
|
:financial_accounts_id,
|
|
:financial_categories_id,
|
|
:active)';
|
|
|
|
/** Preparo o sql para receber os valores */
|
|
$this->stmt = $this->connection->connect()->prepare($this->sql);
|
|
|
|
/** Preencho os parâmetros do SQL */
|
|
$this->stmt->bindParam('user_id', $_SESSION['USERSID']);/** Informa o usuário responsável pelo novo cliente cadastrado */
|
|
$this->stmt->bindParam('company_id', $_SESSION['USERSCOMPANYID']);/** Informa a qual empresa pertence o cliente */
|
|
$this->stmt->bindParam('companies_budgets_id', $this->companiesBudgetsId);
|
|
$this->stmt->bindParam('financial_accounts_id', $this->financialAccountsId);
|
|
$this->stmt->bindParam('financial_categories_id', $this->financialCategoriesId);
|
|
$this->stmt->bindParam('description', $this->description);
|
|
$this->stmt->bindParam('fixed', $this->fixed);
|
|
$this->stmt->bindParam('duration', $this->duration);
|
|
$this->stmt->bindParam('start_date', $this->startDate);
|
|
$this->stmt->bindParam('entrie_value', $this->entrieValue);
|
|
$this->stmt->bindParam('end_date', $this->endDate);
|
|
$this->stmt->bindParam('active', $this->active);
|
|
|
|
/** Executo o SQL */
|
|
|
|
/** Caso a transação tenha sido bem sucedida, gravo a movimentação */
|
|
if($this->stmt->execute()){
|
|
|
|
/** Recupera o ID da última transação */
|
|
$this->lastid = $this->connection->connect()->lastInsertId();
|
|
|
|
/** Retorna o ID da transação */
|
|
return (int)$this->lastid;
|
|
}
|
|
}
|
|
|
|
/** Insere um novo registro no banco */
|
|
public function Save(int $financialEntriesId, int $companyId, int $companiesBudgetsId, string $description, int $fixed, int $duration, string $startDate, float $entrieValue, string $endDate, int $financialAccountsId, string $active, int $financialCategoriesId, ? string $reference)
|
|
{
|
|
|
|
/** Parametros */
|
|
$this->financialEntriesId = $financialEntriesId;
|
|
$this->companyId = $companyId > 0 ? $companyId : null;
|
|
$this->companiesBudgetsId = $companiesBudgetsId;
|
|
$this->description = $description;
|
|
$this->fixed = $fixed;
|
|
$this->duration = $duration;
|
|
$this->startDate = $startDate;
|
|
$this->entrieValue = $entrieValue;
|
|
$this->endDate = $endDate;
|
|
$this->financialAccountsId = $financialAccountsId;
|
|
$this->active = $active;
|
|
$this->financialCategoriesId = $financialCategoriesId;
|
|
$this->reference = $reference;
|
|
|
|
|
|
/** Verifica se o ID do registro foi informado */
|
|
if($this->financialEntriesId > 0){
|
|
|
|
/** Consulta SQL */
|
|
$this->sql = 'update financial_entries set company_id = :company_id,
|
|
description = :description,
|
|
fixed = :fixed,
|
|
duration = :duration,
|
|
start_date = :start_date,
|
|
entrie_value = :entrie_value,
|
|
end_date = :end_date,
|
|
financial_accounts_id = :financial_accounts_id,
|
|
financial_categories_id = :financial_categories_id,
|
|
active = :active,
|
|
date_update = CURRENT_TIMESTAMP,
|
|
users_id_update = :users_id_update,
|
|
reference = :reference
|
|
where financial_entries_id = :financial_entries_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('financial_entries_id', $this->financialEntriesId);
|
|
$this->stmt->bindParam('company_id', $this->companyId);
|
|
$this->stmt->bindParam('financial_accounts_id', $this->financialAccountsId);
|
|
$this->stmt->bindParam('financial_categories_id', $this->financialCategoriesId);
|
|
$this->stmt->bindParam('description', $this->description);
|
|
$this->stmt->bindParam('fixed', $this->fixed);
|
|
$this->stmt->bindParam('duration', $this->duration);
|
|
$this->stmt->bindParam('start_date', $this->startDate);
|
|
$this->stmt->bindParam('entrie_value', $this->entrieValue);
|
|
$this->stmt->bindParam('end_date', $this->endDate);
|
|
$this->stmt->bindParam('active', $this->active);
|
|
$this->stmt->bindParam('reference', $this->reference);
|
|
$this->stmt->bindParam('users_id_update', $_SESSION['USERSID']);/** Informa o usuário responsável */
|
|
|
|
/** Executo o SQL */
|
|
$this->stmt->execute();
|
|
return true;
|
|
|
|
}else{//Se o ID não foi informado, grava-se um novo registro
|
|
|
|
/** Consulta SQL */
|
|
$this->sql = 'insert into financial_entries(company_id,
|
|
companies_budgets_id,
|
|
user_id,
|
|
description,
|
|
fixed,
|
|
duration,
|
|
start_date,
|
|
entrie_value,
|
|
end_date,
|
|
financial_accounts_id,
|
|
financial_categories_id,
|
|
active,
|
|
reference
|
|
) values (:company_id,
|
|
:company_id,
|
|
:companies_budgets_id,
|
|
:user_id,
|
|
:description,
|
|
:fixed,
|
|
:duration,
|
|
:start_date,
|
|
:entrie_value,
|
|
:end_date,
|
|
:financial_accounts_id,
|
|
:financial_categories_id,
|
|
:active,
|
|
:reference)';
|
|
|
|
/** Preparo o sql para receber os valores */
|
|
$this->stmt = $this->connection->connect()->prepare($this->sql);
|
|
|
|
/** Preencho os parâmetros do SQL */
|
|
$this->stmt->bindParam('user_id', $_SESSION['USERSID']);/** Informa o usuário responsável pelo novo cliente cadastrado */
|
|
$this->stmt->bindParam('company_id', $this->companyId);
|
|
$this->stmt->bindParam('companies_budgets_id', $this->companiesBudgetsId);
|
|
$this->stmt->bindParam('financial_accounts_id', $this->financialAccountsId);
|
|
$this->stmt->bindParam('financial_categories_id', $this->financialCategoriesId);
|
|
$this->stmt->bindParam('description', $this->description);
|
|
$this->stmt->bindParam('fixed', $this->fixed);
|
|
$this->stmt->bindParam('duration', $this->duration);
|
|
$this->stmt->bindParam('start_date', $this->startDate);
|
|
$this->stmt->bindParam('entrie_value', $this->entrieValue);
|
|
$this->stmt->bindParam('end_date', $this->endDate);
|
|
$this->stmt->bindParam('active', $this->active);
|
|
$this->stmt->bindParam('reference', $this->reference);
|
|
|
|
/** Executo o SQL */
|
|
|
|
/** Caso a transação tenha sido bem sucedida, gravo a movimentação */
|
|
if($this->stmt->execute()){
|
|
|
|
/** Recupera o ID da última transação */
|
|
$this->lastEntriesId = $this->connection->connect()->lastInsertId();
|
|
|
|
/** Verifica se o último ID foi retornado */
|
|
if($this->lastEntriesId > 0){
|
|
|
|
/** Trata a data do agendamento do movimento de entrada */
|
|
$this->movementDateScheduled = strtotime($this->startDate);
|
|
|
|
/** Inicio do loop para cadastro de movimentação */
|
|
/** Efetuo o cadastro de movimentação de acordo com a entrada informada */
|
|
for($i=0; $i<$this->duration; $i++){
|
|
|
|
$this->movementDateScheduled = ( $i > 0 ? date("Y-m-d", mktime(0,0,0, (date('m', strtotime($this->startDate))+$i), date('d', strtotime($this->startDate)), date('Y', strtotime($this->startDate)))) : $this->startDate );
|
|
$this->next = $this->description . ' - '.($i+1).'/'.$this->duration;
|
|
|
|
/** Consulta SQL */
|
|
$this->sql = 'insert into financial_movements(financial_accounts_id,
|
|
financial_entries_id,
|
|
user_id,
|
|
company_id,
|
|
company_id,
|
|
companies_budgets_id,
|
|
description,
|
|
movement_value,
|
|
movement_date_scheduled,
|
|
reference
|
|
) values (:financial_accounts_id,
|
|
:financial_entries_id,
|
|
:user_id,
|
|
:company_id,
|
|
:company_id,
|
|
:companies_budgets_id,
|
|
:description,
|
|
:movement_value,
|
|
:movement_date_scheduled,
|
|
:reference)';
|
|
|
|
|
|
/** Preparo o sql para receber os valores */
|
|
$this->stmt = $this->connection->connect()->prepare($this->sql);
|
|
|
|
/** Preencho os parâmetros do SQL */
|
|
$this->stmt->bindParam('user_id', $_SESSION['USERSID']);/** Informa o usuário responsável pelo novo cliente cadastrado */
|
|
$this->stmt->bindParam('company_id', $this->companyId);/** Informa a qual empresa pertence o cliente */
|
|
$this->stmt->bindParam('financial_accounts_id', $this->financialAccountsId);
|
|
$this->stmt->bindParam('financial_entries_id', $this->lastEntriesId);
|
|
$this->stmt->bindParam('company_id', $this->companyId);
|
|
$this->stmt->bindParam('companies_budgets_id', $this->companiesBudgetsId);
|
|
$this->stmt->bindParam('description', $this->next);
|
|
$this->stmt->bindParam('movement_value', $this->entrieValue);
|
|
$this->stmt->bindParam('movement_date_scheduled', $this->movementDateScheduled);
|
|
$this->stmt->bindParam('reference', $this->reference);
|
|
|
|
/** Executo o SQL */
|
|
|
|
/** Caso ocorra algum erro na transação,excluo a entrada e seus respectivos agendamentos */
|
|
if(!$this->stmt->execute()){
|
|
|
|
|
|
/** Exclui a entrada */
|
|
$this->Delete($this->lastid);
|
|
|
|
/** Exclui possiveis agendamentos efetuados */
|
|
$this->DeleteMovements($this->lastid);
|
|
|
|
return false;
|
|
break;
|
|
|
|
/** Se não houver erros atualiza a referência */
|
|
} else {
|
|
|
|
|
|
/** Carrega o ID do novo registro gerado */
|
|
$this->lastid = $this->connection->connect()->lastInsertId();
|
|
|
|
/** carrega os dados do orçamento */
|
|
$this->clientBudgetsResult = $this->GetBudgets($this->companiesBudgetsId);
|
|
|
|
/** Gera a referência da movimentação para gravar no boleto */
|
|
$this->reference = $this->lastid.$this->clientBudgetsResult->reference.'/'.$this->clientBudgetsResult->reference_client.'-'.($i+1);
|
|
|
|
|
|
/** Consulta SQL */
|
|
$this->sql = 'update financial_movements set reference = :reference
|
|
where financial_movements_id = :financial_movements_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('reference', $this->reference);
|
|
$this->stmt->bindParam('financial_movements_id', $this->lastid);
|
|
|
|
/** Executo o SQL */
|
|
$this->stmt->execute();
|
|
|
|
}
|
|
|
|
|
|
}/** Fim do loop para cadastro de movimentação */
|
|
|
|
/** Caso não ocorra erros, informo como bem sucedido */
|
|
return true;
|
|
|
|
}else{/** Caso falhe o cadastro da transação, informo */
|
|
|
|
return false;
|
|
}
|
|
|
|
}else{/** Caso falhe o cadastro da transação, informo */
|
|
|
|
return false;
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
/** Deleta um determinado registro no banco de dados */
|
|
function Delete(int $financialEntriesId)
|
|
{
|
|
/** Parametros de entrada */
|
|
$this->financialEntriesId = $financialEntriesId;
|
|
|
|
/** Consulta SQL */
|
|
$this->sql = 'delete from financial_entries
|
|
where financial_entries_id = :financial_entries_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('financial_entries_id', $this->financialEntriesId);
|
|
|
|
/** Executo o SQL */
|
|
return $this->stmt->execute();
|
|
|
|
}
|
|
|
|
/** Deleta um determinado registro no banco de dados */
|
|
function DeleteMovements(int $financialEntriesId)
|
|
{
|
|
/** Parametros de entrada */
|
|
$this->financialEntriesId = $financialEntriesId;
|
|
|
|
/** Consulta SQL */
|
|
$this->sql = 'delete from financial_movements
|
|
where financial_entries_id = :financial_entries_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('financial_entries_id', $this->financialEntriesId);
|
|
|
|
/** Executo o SQL */
|
|
return $this->stmt->execute();
|
|
|
|
}
|
|
|
|
/** Fecha uma conexão aberta anteriormente com o banco de dados */
|
|
function __destruct()
|
|
{
|
|
$this->connection = null;
|
|
}
|
|
}
|