AutorÃa | Ultima modificación | Ver Log |
<?php
declare(strict_types=1);
namespace LeadersLinked\Mapper;
use Laminas\Db\Adapter\AdapterInterface;
use LeadersLinked\Hydrator\ObjectPropertyHydrator;
use Laminas\Log\LoggerInterface;
use LeadersLinked\Model\EngagementUser;
use LeadersLinked\Mapper\Common\MapperCommon;
use Laminas\Db\Sql\Expression;
class EngagementUserMapper extends MapperCommon
{
const _TABLE = 'tbl_engagement_users';
/**
*
* @var EngagementUserMapper
*/
private static $_instance;
/**
*
* @param AdapterInterface $adapter
*/
private function __construct($adapter)
{
parent::__construct($adapter);
}
/**
*
* @param AdapterInterface $adapter
* @return EngagementUserMapper
*/
public static function getInstance($adapter)
{
if(self::$_instance == null) {
self::$_instance = new EngagementUserMapper($adapter);
}
return self::$_instance;
}
/**
*
* @param int $company_id
* @param int $user_id
* @return EngagementUser
*/
public function fetchOneByCompanyIdAndUserId($company_id, $user_id)
{
$select = $this->sql->select(self::_TABLE);
$select->where->equalTo('company_id', $company_id);
$select->where->equalTo('user_id', $user_id);
$select->limit(1);
$prototype = new EngagementUser();
return $this->executeFetchOneObject($select, $prototype);
}
/**
*
* @param EngagementUser $record
* @return boolean
*/
public function insert($record)
{
$hydrator = new ObjectPropertyHydrator();
$values = $hydrator->extract($record);
$values = $this->removeEmpty($values);
$values['date'] = new Expression('DATE(NOW())');
$insert = $this->sql->insert(self::_TABLE);
$insert->values($values);
return $this->executeInsert($insert);
}
/**
*
* @param EngagementUser $record
* @return boolean
*/
public function update($record)
{
$hydrator = new ObjectPropertyHydrator();
$values = $hydrator->extract($record);
$values = $this->removeEmpty($values);
$update = $this->sql->update(self::_TABLE);
$update->set($values);
$update->where->equalTo('company_id', $record->company_id);
$update->where->equalTo('user_id', $record->user_id);
return $this->executeUpdate($update);
}
}