fix cach & fix #398 move service fallback

This commit is contained in:
Nicolas Le Goff
2012-02-16 18:52:44 +01:00
parent 5743267b01
commit 371b21371d
7 changed files with 340 additions and 318 deletions

View File

@@ -479,10 +479,12 @@ class Basket implements ControllerProviderInterface
$basket = $em->getRepository('\Entities\Basket') $basket = $em->getRepository('\Entities\Basket')
->findUserBasket($basket_id, $app['Core']->getAuthenticatedUser()); ->findUserBasket($basket_id, $app['Core']->getAuthenticatedUser());
if ($basket->getIsRead() === false)
{
$basket = $em->merge($basket);
$basket->setIsRead(true); $basket->setIsRead(true);
$em->merge($basket);
$em->flush(); $em->flush();
}
/* @var $twig \Twig_Environment */ /* @var $twig \Twig_Environment */
$twig = $app['Core']->getTwig(); $twig = $app['Core']->getTwig();

View File

@@ -65,15 +65,14 @@ class MemcacheCache extends ServiceAbstract implements ServiceInterface
$stats = @$memcache->getExtendedStats(); $stats = @$memcache->getExtendedStats();
if ($stats[$key]) if (isset($stats[$key]) && @$memcache->connect($this->host, $this->port))
{ {
$memcache->connect($this->host, $this->port);
$service = new CacheService\MemcacheCache(); $service = new CacheService\MemcacheCache();
$service->setMemcache($memcache); $service->setMemcache($memcache);
} }
else else
{ {
$service = new CacheService\ArrayCache(); throw new \Exception(sprintf("Memcache instance with host '%s' and port '%s' is not reachable", $this->host, $this->port));
} }
$registry = $this->getRegistry(); $registry = $this->getRegistry();

View File

@@ -72,7 +72,7 @@ class RedisCache extends ServiceAbstract implements ServiceInterface
} }
else else
{ {
$service = new CacheService\ArrayCache(); throw new \Exception(sprintf("Redis instance with host '%s' and port '%s' is not reachable", $this->host, $this->port));
} }
$registry = $this->getRegistry(); $registry = $this->getRegistry();

View File

@@ -338,14 +338,17 @@ class Doctrine extends ServiceAbstract implements ServiceInterface
*/ */
private function getCache($cacheDoctrine, $serviceName = null) private function getCache($cacheDoctrine, $serviceName = null)
{ {
if (null === $serviceName) $defaultServiceName = 'default_cache';
{ $defaultConfiguration = new ParameterBag(array(
$serviceName = 'default_cache';
$configuration = new ParameterBag(array(
'type' => self::ARRAYCACHE 'type' => self::ARRAYCACHE
, 'options' => array() , 'options' => array()
) )
); );
if (null === $serviceName)
{
$serviceName = $defaultServiceName;
$configuration = $defaultConfiguration;
} }
else else
{ {
@@ -382,6 +385,8 @@ class Doctrine extends ServiceAbstract implements ServiceInterface
$registry = $this->getDependency("registry"); $registry = $this->getDependency("registry");
try
{
$serviceBuilder = new Core\ServiceBuilder\Cache( $serviceBuilder = new Core\ServiceBuilder\Cache(
$serviceName, $serviceName,
$configuration, $configuration,
@@ -390,9 +395,24 @@ class Doctrine extends ServiceAbstract implements ServiceInterface
$service = $serviceBuilder->buildService(); $service = $serviceBuilder->buildService();
$cacheService = $service->getService();
}
catch (\Exception $e)
{
$serviceBuilder = new Core\ServiceBuilder\Cache(
$defaultServiceName,
$defaultConfiguration,
array("registry" => $registry)
);
$service = $serviceBuilder->buildService();
$cacheService = $service->getService();
}
$this->cacheServices[$cacheDoctrine] = $service; $this->cacheServices[$cacheDoctrine] = $service;
return $service->getService(); return $cacheService;
} }
private function getLog($serviceName) private function getLog($serviceName)

View File

@@ -34,7 +34,7 @@ class Twig extends ServiceAbstract implements ServiceInterface
try try
{ {
if(!$this->options['debug']) if(!isset($this->options['debug']) || !$this->options['debug'])
{ {
$this->options['cache'] = realpath( __DIR__ . '/../../../../../../tmp/cache_twig/'); $this->options['cache'] = realpath( __DIR__ . '/../../../../../../tmp/cache_twig/');
} }

View File

@@ -155,8 +155,6 @@ class BasketElementRepository extends EntityRepository
throw new \Exception_Forbidden(_('You have not access to this basket element')); throw new \Exception_Forbidden(_('You have not access to this basket element'));
} }
$element = $this->_em->merge($element);
return $element; return $element;
} }

View File

@@ -56,7 +56,8 @@ class BasketRepository extends EntityRepository
$query = $this->_em->createQuery($dql); $query = $this->_em->createQuery($dql);
$query->setParameters(array('usr_id' => $user->get_id())); $query->setParameters(array('usr_id' => $user->get_id()));
$idCache = "_active_by_user_" . ($sort === null ? "nosort" : $sort) . "_" . $user->get_id(). Entities\Basket::CACHE_SUFFIX; $idCache = "_active_by_user_" . ($sort === null ? "" : $sort ) . "_" . $user->get_id(). Entities\Basket::CACHE_SUFFIX;
$query->useResultCache(true, 1800, $idCache); $query->useResultCache(true, 1800, $idCache);
return $query->getResult(); return $query->getResult();
@@ -80,7 +81,9 @@ class BasketRepository extends EntityRepository
$query = $this->_em->createQuery($dql); $query = $this->_em->createQuery($dql);
$query->setParameters(array('usr_id' => $user->get_id())); $query->setParameters(array('usr_id' => $user->get_id()));
$idCache = "_unread_active_by_user_" . $user->get_id() . Entities\Basket::CACHE_SUFFIX;
$idCache = "findUnreadActiveByUser" . $user->get_id() . Entities\Basket::CACHE_SUFFIX;
$query->useResultCache(true, 1800, $idCache); $query->useResultCache(true, 1800, $idCache);
return $query->getResult(); return $query->getResult();
@@ -100,8 +103,8 @@ class BasketRepository extends EntityRepository
JOIN b.elements e JOIN b.elements e
JOIN b.validation s JOIN b.validation s
JOIN s.participants p JOIN s.participants p
WHERE b.usr_id != ?1 AND p.usr_id = ?2'; WHERE b.usr_id != ?1 AND p.usr_id = ?2
//@todo implements expires session AND s.expires > CURRENT_TIMESTAMP()'; AND (s.expires IS NULL OR s.expires > CURRENT_TIMESTAMP()) ';
if ($sort == 'date') if ($sort == 'date')
{ {
@@ -156,8 +159,6 @@ class BasketRepository extends EntityRepository
throw new \Exception_Forbidden(_('You have not access to this basket')); throw new \Exception_Forbidden(_('You have not access to this basket'));
} }
$basket = $this->_em->merge($basket);
return $basket; return $basket;
} }
@@ -254,7 +255,9 @@ class BasketRepository extends EntityRepository
$count = Paginate::getTotalQueryResults($query); $count = Paginate::getTotalQueryResults($query);
$paginateQuery = Paginate::getPaginateQuery($query, $offset, $perPage); $paginateQuery = Paginate::getPaginateQuery($query, $offset, $perPage);
$idCache = "_" . $type . "_workzone_basket_" . $user->get_id() . Entities\Basket::CACHE_SUFFIX; $idCache = "_" . $type . "_workzone_basket_" . $user->get_id() . Entities\Basket::CACHE_SUFFIX;
$paginateQuery->useResultCache(true, 1800, $idCache); $paginateQuery->useResultCache(true, 1800, $idCache);
$result = $paginateQuery->getResult(); $result = $paginateQuery->getResult();