connection = new Mysql();
}
/** Carrega os campos de uma tabela */
public function Describe()
{
/** Consulta SQL */
$this->sql = "describe companies_budgets_commissions";
/** 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 $CompaniesBudgetsCommissionsId)
{
/** Parametros de entrada */
$this->CompaniesBudgetsCommissionsId = $CompaniesBudgetsCommissionsId;
/** Consulta SQL */
$this->sql = 'select cm.companies_budgets_commissions_id,
cm.financial_movements_id,
cm.companies_budgets_id,
cm.user_id,
cm.user_id_create,
cm.user_id_confirm,
cm.value,
cm.date_create,
cm.description,
cm.parcel,
cm.commission_value_paid,
cm.commission_date_paid,
cm.commission_date_confirm,
f.movement_value_paid
from companies_budgets_commissions cm
left join financial_movements f on cm.financial_movements_id = f.financial_movements_id
where cm.companies_budgets_commissions_id = :companies_budgets_commissions_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_commissions_id', $this->CompaniesBudgetsCommissionsId);
/** Executo o SQL */
$this->stmt->execute();
/** Retorno o resultado */
return $this->stmt->fetchObject();
}
/** Lista os registros do banco de dados com limitação */
public function Check(int $CompaniesBudgetsId, int $usersId)
{
/** Parametros de entrada */
$this->CompaniesBudgetsId = $CompaniesBudgetsId;
$this->usersId = $usersId;
/** Consulta SQL */
$this->sql = 'select count(cm.companies_budgets_commissions_id) as qtde
from companies_budgets_commissions cm
where cm.companies_budgets_id = :companies_budgets_id
and cm.user_id = :user_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);
$this->stmt->bindParam(':user_id', $this->usersId);
/** Executo o SQL */
$this->stmt->execute();
/** Retorno o resultado */
return $this->stmt->fetchObject()->qtde;
}
/** Lista todos os egistros do banco com ou sem paginação*/
public function All(int $start, int $max, int $CompanyBudgetsId, int $usersId, string $dateStart, string $dateEnd)
{
/** Parametros de entrada */
$this->CompanyBudgetsId = $CompanyBudgetsId;
$this->usersId = $usersId;
$this->dateStart = $dateStart;
$this->dateEnd = $dateEnd;
$this->and = '';
$this->and .= $this->CompanyBudgetsId > 0 ? ' and cb.company_id = :company_id ' : '';
$this->and .= $this->usersId > 0 ? ' and cm.user_id = :user_id ' : '';
/** Período de consulta */
if(!empty($this->dateStart) && !empty($this->dateEnd)){
$this->and .= ' and fm.movement_date_paid between :date_start and :date_end ';
}
/** Consulta SQL */
$this->sql = 'select cm.companies_budgets_commissions_id,
cm.companies_budgets_id,
cm.user_id,
cm.value,
cm.user_id_create,
cm.date_create,
cm.description,
cm.parcel,
cm.commission_value_paid,
cm.commission_date_paid,
cm.commission_date_confirm,
fm.reference as movement_reference,
fm.movement_value,
fm.movement_value_paid,
fm.movement_date_paid,
fm.movement_date_scheduled,
u.name_first,
u.name_last,
c.name_fantasy,
c.cns
from companies_budgets_commissions cm
left join users u on cm.user_id = u.user_id
left join companies_budgets cb on cm.companies_budgets_id = cb.companies_budgets_id
left join financial_movements fm on cm.financial_movements_id = fm.financial_movements_id
where cm.companies_budgets_commissions_id > 0 ';
/** Adiciona o filtro */
$this->sql .= $this->and;
/** Ordenação */
$this->sql .= ' order by cm.companies_budgets_commissions_id asc';
/** Verifico se há paginação */
if($this->max > 0){
$this->limit = ' limit '.$this->start.', '.$this->max;
}
/** Adiciona a limitação */
$this->sql .= $this->limit;
/** Preparo o SQL para execução */
$this->stmt = $this->connection->connect()->prepare($this->sql);
/** Verifica se o cliente foi informado */
if($this->CompanyBudgetsId > 0){
/** Preencho os parâmetros do SQL */
$this->stmt->bindParam('company_id', $this->CompanyBudgetsId);
}
/** Verifica se o usuário foi informado */
if($this->usersId > 0){
/** Preencho os parâmetros do SQL */
$this->stmt->bindParam('user_id', $this->usersId);
}
/** Período de consulta */
if(!empty($this->dateStart) && !empty($this->dateEnd)){
/** Preencho os parâmetros do SQL */
$this->stmt->bindParam('date_start', $this->dateStart);
$this->stmt->bindParam('date_end', $this->dateEnd);
}
/** 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 $CompanyBudgetsId, int $usersId, string $dateStart, string $dateEnd)
{
/** Parametros de entrada */
$this->CompanyBudgetsId = $CompanyBudgetsId;
$this->usersId = $usersId;
$this->dateStart = $dateStart;
$this->dateEnd = $dateEnd;
$this->and = '';
$this->and .= $this->CompanyBudgetsId > 0 ? ' and cb.company_id = :company_id ' : '';
$this->and .= $this->usersId > 0 ? ' and cm.user_id = :user_id ' : '';
/** Período de consulta */
if(!empty($this->dateStart) && !empty($this->dateEnd)){
$this->and .= ' and fm.movement_date_paid between :date_start and :date_end ';
}
/** Consulta SQL */
$this->sql = 'select count(cm.companies_budgets_commissions_id) as qtde
from companies_budgets_commissions cm
left join companies_budgets cb on cm.company_budgets_id = cb.company_id
left join financial_movements fm on cm.financial_movements_id = fm.financial_movements_id
where cm.companies_budgets_commissions_id > 0 ';
/** Adiciona o filtro */
$this->sql .= $this->and;
/** Preparo o SQL para execução */
$this->stmt = $this->connection->connect()->prepare($this->sql);
/** Verifica se o cliente foi informado */
if($this->CompanyBudgetsId > 0){
/** Preencho os parâmetros do SQL */
$this->stmt->bindParam('company_id', $this->CompanyBudgetsId);
}
/** Verifica se o usuário foi informado */
if($this->usersId > 0){
/** Preencho os parâmetros do SQL */
$this->stmt->bindParam('user_id', $this->usersId);
}
/** Período de consulta */
if(!empty($this->dateStart) && !empty($this->dateEnd)){
/** Preencho os parâmetros do SQL */
$this->stmt->bindParam('date_start', $this->dateStart);
$this->stmt->bindParam('date_end', $this->dateEnd);
}
/** Executo o SQL */
$this->stmt->execute();
/** Retorno o resultado */
return $this->stmt->fetchObject()->qtde;
}
/** Insere um novo registro no banco */
public function Save(? int $CompaniesBudgetsCommissionsId,
? int $financialMovementsId,
? int $CompaniesBudgetsId,
? int $usersId,
? float $value,
? int $usersIdCreate,
? string $description,
? int $parcel,
? float $commissionValuePaid,
? string $commissionDatePaid,
? int $usersIdConfirm)
{
/** Parametros */
$this->CompaniesBudgetsCommissionsId = $CompaniesBudgetsCommissionsId;
$this->financialMovementsId = $financialMovementsId;
$this->CompaniesBudgetsId = $CompaniesBudgetsId;
$this->usersId = $usersId;
$this->value = $value;
$this->usersIdCreate = $usersIdCreate;
$this->description = $description;
$this->parcel = $parcel;
$this->commissionValuePaid = $commissionValuePaid;
$this->commissionDatePaid = $commissionDatePaid;
$this->usersIdConfirm = $usersIdConfirm;
/** Verifica se o ID do registro foi informado */
if($this->CompaniesBudgetsCommissionsId > 0){
/** Consulta SQL */
$this->sql = 'update companies_budgets_commissions set commission_value_paid = :commission_value_paid,
commission_date_paid = :commission_date_paid,
user_id_confirm = :user_id_confirm
where companies_budgets_commissions_id = :companies_budgets_commissions_id
and commission_date_paid is null';
/** 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_confirm', $this->usersIdConfirm);
$this->stmt->bindParam('commission_date_paid', $this->commissionDatePaid);
$this->stmt->bindParam('commission_value_paid', $this->commissionValuePaid);
$this->stmt->bindParam('companies_budgets_commissions_id', $this->CompaniesBudgetsCommissionsId);
/** Executo o SQL */
return $this->stmt->execute();
}else{//Se o ID não foi informado, grava-se um novo registro
/** Consulta SQL */
$this->sql = 'insert into companies_budgets_commissions(companies_budgets_commissions_id,
financial_movements_id,
companies_budgets_id,
user_id,
value,
user_id_create,
description,
parcel
) values (:companies_budgets_commissions_id,
:financial_movements_id,
:companies_budgets_id,
:user_id,
:value,
:user_id_create,
:description,
:parcel)';
/** Preparo o sql para receber os valores */
$this->stmt = $this->connection->connect()->prepare($this->sql);
try{
/** Inicia a transação */
$this->connection->connect()->beginTransaction();
/** Preencho os parâmetros do SQL */
$this->stmt->bindParam('value', $this->value);
$this->stmt->bindParam('parcel', $this->parcel);
$this->stmt->bindParam('user_id', $this->usersId);
$this->stmt->bindParam('description', $this->description);
$this->stmt->bindParam('user_id_create', $this->usersIdCreate);
$this->stmt->bindParam('companies_budgets_id', $this->CompaniesBudgetsId);
$this->stmt->bindParam('financial_movements_id', $this->financialMovementsId);
$this->stmt->bindParam('companies_budgets_commissions_id', $this->CompaniesBudgetsCommissionsId);
/** Executo o SQL */
$this->stmt->execute();
/** Retorna o ID do novo registro */
$this->setId($this->connection->connect()->lastInsertId());
/** Confirma a transação */
$this->connection->connect()->commit();
return true;
}catch(\Exception $exception) {
/** Desfaz a transação */
$this->connection->connect()->rollback();
/** Captura o erro */
array_push($this->errors, $exception->getMessage());
return false;
}
}
}
/** Deleta um determinado registro no banco de dados */
function Delete(int $CompaniesBudgetsCommissionsId)
{
/** Parametros de entrada */
$this->CompaniesBudgetsCommissionsId = $CompaniesBudgetsCommissionsId;
/** Consulta SQL */
$this->sql = 'delete from companies_budgets
where companies_budgets_commissions_id = :companies_budgets_commissions_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('companies_budgets_commissions_id', $this->CompaniesBudgetsCommissionsId);
/** Executo o SQL */
return $this->stmt->execute();
}
/** Define o Último ID inserido */
public function setId($lastId) : void
{
$this->lastId = $lastId;
}
/** Recupera o Último ID inserido */
public function getId(): ? int
{
return (int)$this->lastId;
}
/** Verifica se há erros a serem visualizadas */
public function getErrors(): ? string
{
/** Verifico se deve informar os erros */
if (count($this->errors)) {
/** Verifica a quantidade de erros para informar a legenda */
$this->info = count($this->errors) > 1 ? 'Os seguintes erros foram encontrados' : 'O seguinte erro foi encontrado';
/** Lista os erros */
foreach ($this->errors as $keyError => $error) {
/** Monto a mensagem de erro */
$this->info .= '' . ($keyError + 1) . ' - ' . $error;
}
/** Retorno os erros encontrados */
return (string)$this->info;
} else {
return false;
}
}
/** Fecha uma conexão aberta anteriormente com o banco de dados */
function __destruct()
{
$this->connection = null;
}
}