Ir a la última revisión | Autoría | Comparar con el anterior | Ultima modificación | Ver Log |
<?php
declare(strict_types=1);
namespace LeadersLinked\Mapper;
use LeadersLinked\Mapper\Common\MapperCommon;
use Laminas\Db\Adapter\AdapterInterface;
use LeadersLinked\Model\DiscoveryContactInteraction;
use LeadersLinked\Hydrator\ObjectPropertyHydrator;
use Laminas\Db\ResultSet\HydratingResultSet;
use Laminas\Paginator\Adapter\DbSelect;
use Laminas\Paginator\Paginator;
class DiscoveryContactInteractionMapper extends MapperCommon
{
const _TABLE = 'tbl_discovery_contact_interactions';
/**
*
* @var DiscoveryContactInteractionMapper
*/
private static $_instance;
/**
*
* @param AdapterInterface $adapter
*/
private function __construct($adapter)
{
parent::__construct($adapter);
}
/**
*
* @param AdapterInterface $adapter
* @return DiscoveryContactInteractionMapper
*/
public static function getInstance($adapter)
{
if(self::$_instance == null) {
self::$_instance = new DiscoveryContactInteractionMapper($adapter);
}
return self::$_instance;
}
/**
*
* @param int $id
* @return DiscoveryContactInteraction
*/
public function fetchOne($id)
{
$select = $this->sql->select(self::_TABLE);
$select->where->equalTo('id', $id);
$prototype = new DiscoveryContactInteraction();
return $this->executeFetchOneObject($select, $prototype);
}
/**
*
* @param string $uuid
* @return DiscoveryContactInteraction
*/
public function fetchOneByUuid($uuid)
{
$select = $this->sql->select(self::_TABLE);
$select->where->equalTo('uuid', $uuid);
$prototype = new DiscoveryContactInteraction();
return $this->executeFetchOneObject($select, $prototype);
}
/**
*
* @param int $company_id
* @param int $contact_id
* @param int $page
* @param int $records_per_page
* @return Paginator
*/
public function fetchAllDataTableForCompanyIdAndContactId($company_id, $contact_id, $page = 1, $records_per_page = 10)
{
$prototype = new DiscoveryContactInteraction();
$select = $this->sql->select(self::_TABLE);
$select->where->equalTo('company_id', $company_id);
$select->where->equalTo('contact_id', $contact_id);
$select->order('added_on DESC');
$hydrator = new ObjectPropertyHydrator();
$resultset = new HydratingResultSet($hydrator, $prototype);
$adapter = new DbSelect($select, $this->sql, $resultset);
$paginator = new Paginator( $adapter);
$paginator->setItemCountPerPage($records_per_page);
$paginator->setCurrentPageNumber($page);
return $paginator;
}
/**
*
* @param DiscoveryContactInteraction $record
* @return boolean
*/
public function insert($record)
{
$hydrator = new ObjectPropertyHydrator();
$values = $hydrator->extract($record);
$values = $this->removeEmpty($values);
$insert = $this->sql->insert(self::_TABLE);
$insert->values($values);
$result = $this->executeInsert($insert);
if($result) {
$record->id = $this->lastInsertId;
}
return $result;
}
/**
*
* @param DiscoveryContactInteraction $record
* @return boolean
*/
public function delete($record)
{
$delete = $this->sql->delete(self::_TABLE);
$delete->where->equalTo('id', $record->id);
return $this->executeDelete($delete);
}
}