Programación Avanzada

Symfony

Crear archivos batch en symfony

por tryke en Dic.17, 2008, dentro Symfony

Crear archivos batch con symfony considero que es una de las tareas menos documentadas dentro del framework.

En este post veremos un ejemplo de como hacer un proceso batch para enviar un mailing a todos los usuarios con nuestro boletin.

En primer lugar ejecutaremos el comando init-batch de symfony para que cree el archivo batch.

  1. symfony init-batch default [yourBatchName] [yourApplicationName]

El comando crea automaticamente un archivo en el directorio batch de nuestro proyecto.

  1. <?php
  2.  
  3. /**
  4.  * yourBatchName batch script
  5.  *
  6.  * Here goes a brief description of the purpose of the batch script
  7.  *
  8.  * @package    yourProject
  9.  * @subpackage batch
  10.  * @version    $Id$
  11.  */
  12.  
  13. define('SF_ROOT_DIR',    realpath(dirname(__file__).'/..'));
  14. define('SF_APP',         'yourApplicationName');
  15. define('SF_ENVIRONMENT', 'dev');
  16. define('SF_DEBUG',       1);
  17.  
  18. require_once(SF_ROOT_DIR.DIRECTORY_SEPARATOR.'apps'.DIRECTORY_SEPARATOR.SF_APP.DIRECTORY_SEPARATOR.'config'.DIRECTORY_SEPARATOR.'config.php');
  19.  
  20. // initialize database manager
  21. //$databaseManager = new sfDatabaseManager();
  22. //$databaseManager->initialize();
  23.  
  24. // batch process here
  25. ?>

Como podemos observar por defecto te crea un comentario con las llamadas necesarias para inicializar nuestro acceso a la base de datos.

En primer lugar deberemos crearnos un modulo para el envio de emails, a este modulo nosotros lo hemos llamado “email” y la acción “boletin” es la encargada de realizar el envio. En la acción de este modulo leeremos el parametro “usuario_id” que será el que identifica el usuario receptor del mensaje.

actions.class.php

  1. <?php
  2. class emailActions extends sfActions
  3. {
  4.   public function executeBoletin()
  5.   {
  6.    $this->i18n = $this->getContext()->getI18N();
  7.    $this->usuario = UsuarioPeer::retrieveByPK($this->getRequestParameter('usuario_id'));
  8.    if (!$this->usuario) {
  9.       return sfView::NONE;
  10.    }
  11.    if (!$this->usuario->getMailavisos()) {
  12.       return sfView::NONE;
  13.    }
  14.    $this->i18n->setCulture($this->usuario->getCulture());
  15.  
  16.    $this->mail = new sfMail();
  17.    $this->setMailer('sendmail');
  18.    $this->setCharset('utf-8');
  19.    $this->setContentType('text/html');
  20.  
  21.    $this->mail->setSender('no-reply@miweb.com', 'miweb.com');
  22.    $this->mail->setFrom('no-reply@miweb.com', 'miweb.com');
  23.    $this->mail->addAddress($this->usuario->getEmail());
  24.    $this->mail->setSubject($this->i18n->__('Boletin semanal', null, 'email'));
  25.   }
  26. }
  27. ?>

Por otro lado montamos el template que será el que contiene el cuerpo del mensaje con el boletin a enviar.

boletinSuccess.php

  1. <?php echo sprintf('%s <b>%s</b>', __('Hola', null, 'email'), $usuario->getNombre() ); ?><br>
  2. <?php echo __('Este es tu boletin semanal', null, 'email') ?>

Para finalizar solo tenemos que retocar el fichero batch que hemos creado anteriormente para que lea de la base de datos todos los usuarios y vaya enviando el boletin.

batch_boletin.php

  1. <?php
  2. /**
  3.  * yourBatchName batch script
  4.  *
  5.  * Here goes a brief description of the purpose of the batch script
  6.  *
  7.  * @package    yourProject
  8.  * @subpackage batch
  9.  * @version    $Id$
  10.  */
  11. set_time_limit(0);
  12.  
  13. define('SF_ROOT_DIR',    realpath(dirname(__file__).'/..'));
  14. define('SF_APP',         'yourApplicationName');
  15. define('SF_ENVIRONMENT', 'dev');
  16. define('SF_DEBUG',       1);
  17. define('SF_LOG_DEBUG',   'crit');
  18.  
  19. require_once(SF_ROOT_DIR.DIRECTORY_SEPARATOR.'apps'.DIRECTORY_SEPARATOR.SF_APP.DIRECTORY_SEPARATOR.'config'.DIRECTORY_SEPARATOR.'config.php');
  20.  
  21. // initialize database manager
  22. $databaseManager = new sfDatabaseManager();
  23. $databaseManager->initialize();
  24.  
  25. // batch process here
  26. sfLogger::getInstance()->log('Inicio envio boletin (' . date('Y-m-d H:m:i') . ')…', SF_LOG_DEBUG);
  27.  
  28. $c = new Criteria();
  29. $usuarios = UsuarioPeer::doSelect($c);
  30.  
  31. foreach ($usuarios as $s) {
  32.  sfContext::getInstance()->getRequest()->setParameter('usuario_id', $s->getId()); //Pasa el usuario por parametro
  33.  sfContext::getInstance()->getController()->sendEmail('email', 'boletin'); //Envia el email al usuario
  34.  sfLogger::getInstance()->log('envio boletin: ' . $s->getId(), SF_LOG_DEBUG); //Añado una linea en el log
  35.  sleep(rand(0,4)); //Espera un máximo de 4s por envio para evitar ser catalogado como spam
  36. }
  37.  
  38. sfLogger::getInstance()->log('Fin envio boletin (' . date('Y-m-d H:m:i') . ')…', SF_LOG_DEBUG);
  39. ?>

Si quisieramos podriamos poner nuestro archivo batch_boletin en el cron del servidor para que se ejecutará semanalmente.

Hacer un Comentario :batch, Symfony más...

Symfony Cache por Base de Datos en MySQL

por admin en Dic.15, 2008, dentro Symfony

El Framework de Symfony dispone de diversos metodos de almacenar la cache. Entre los cuales podemos elegir diferentes opciones:

- Guardar la cache en disco mediante el uso de ficheros.
- Utilizar memcache.
- Almacenar la cache en base de datos mediante SQLite.
- etc..

Cuando trabajamos con proyectos muy grandes que requieren balanceo de carga, el sistema de cache puede resultar un problema.

Una posible solución es manipular la cache mediante Base de Datos.

Para poder almacenar la cache en MySQL he creado esta pequeña clase.

sfMySQLCache.class.php

  1. <?php
  2.  
  3. class sfMySQLCache extends sfCache
  4. {
  5.   const DEFAULT_HOST = 'localhost';
  6.   const DEFAULT_BD = 'database';
  7.   const DEFAULT_USR = 'usuario';
  8.   const DEFAULT_PSR = 'password';
  9.  
  10.   const DEFAULT_NAMESPACE = '';
  11.  
  12.   protected $automaticCleaningFactor = 500;
  13.   protected $conn = null;
  14.  
  15.   public function __construct($database = null)
  16.   {
  17.   }
  18.  
  19.   public function __destruct()
  20.   {
  21.   }
  22.  
  23.   public function initialize($options = array())
  24.   {
  25.   }
  26.  
  27.  
  28.   /*Terminada …*/
  29.   public function get($id, $namespace = self::DEFAULT_NAMESPACE, $doNotTestCacheValidity = false)
  30.   {
  31.    $this->conn = mysql_connect(self::DEFAULT_HOST, self::DEFAULT_USR, self::DEFAULT_PSR);
  32.    mysql_select_db(self::DEFAULT_BD, $this->conn);
  33.    mysql_query("SET NAMES 'utf8'", $this->conn);
  34.  
  35.    $statement = sprintf("SELECT data FROM _cache WHERE id = '%s' AND namespace = '%s'", mysql_escape_string($id), mysql_escape_string($namespace));
  36.     if (!$doNotTestCacheValidity) {
  37.       $statement .= sprintf(" AND created_at > '%s'", mysql_escape_string(date('Y-m-d H:i:s', $this->refreshTime)));
  38.     }
  39.     $statement .= ' LIMIT 1';
  40.  
  41.     $rs = mysql_query($statement, $this->conn);
  42.     $datos = mysql_fetch_array($rs);
  43.     $resultado = mysql_num_rows($rs) ? $datos['data'] : null;
  44.  
  45.     return $resultado;
  46.   }
  47.  
  48.   /*Terminada …*/
  49.   public function has($id, $namespace = self::DEFAULT_NAMESPACE, $doNotTestCacheValidity = false)
  50.   {
  51.    $this->conn = mysql_connect(self::DEFAULT_HOST, self::DEFAULT_USR, self::DEFAULT_PSR);
  52.    mysql_select_db(self::DEFAULT_BD, $this->conn);
  53.    mysql_query("SET NAMES 'utf8'", $this->conn);
  54.    
  55.    $statement = sprintf("SELECT id FROM _cache WHERE id = '%s' AND namespace = '%s'", mysql_escape_string($id), mysql_escape_string($namespace));
  56.     if (!$doNotTestCacheValidity) {
  57.       $statement .= sprintf(" AND created_at > '%s'", mysql_escape_string(date('Y-m-d H:i:s', $this->refreshTime)));
  58.     }
  59.     $statement .= ' LIMIT 1';
  60.  
  61.     $rs = mysql_query($statement, $this->conn);
  62.     $resultado = mysql_num_rows($rs) ? true : false;
  63.  
  64.     return $resultado;
  65.   }
  66.  
  67.   /*Terminada…*/
  68.   public function set($id, $namespace = self::DEFAULT_NAMESPACE, $data)
  69.   {
  70.    if ($this->automaticCleaningFactor > 0) {
  71.       $rand = rand(1, $this->automaticCleaningFactor);
  72.       if ($rand == 1) {
  73.          $this->clean(false, 'old');
  74.       }
  75.    }
  76.  
  77.    if (!$this->has($id, $namespace, true)) {
  78.       $this->conn = mysql_connect(self::DEFAULT_HOST, self::DEFAULT_USR, self::DEFAULT_PSR);
  79.       mysql_select_db(self::DEFAULT_BD, $this->conn);
  80.       mysql_query("SET NAMES 'utf8'", $this->conn);  
  81.       $statement = sprintf("INSERT INTO _cache (id, namespace, data, created_at) VALUES ('%s', '%s', '%s', '%s')", mysql_escape_string($id), mysql_escape_string($namespace), mysql_escape_string($data), date('Y-m-d H:i:s'));
  82.    } else {
  83.       $this->conn = mysql_connect(self::DEFAULT_HOST, self::DEFAULT_USR, self::DEFAULT_PSR);
  84.       mysql_select_db(self::DEFAULT_BD, $this->conn);
  85.       mysql_query("SET NAMES 'utf8'", $this->conn);  
  86.       $statement = sprintf("UPDATE _cache SET data = '%s', created_at = '%s' WHERE id = '%s' AND namespace = '%s' LIMIT 1", mysql_escape_string($data), date('Y-m-d H:i:s'), mysql_escape_string($id), mysql_escape_string($namespace));
  87.    }
  88.    
  89.    $resultado = mysql_query($statement, $this->conn) ? true : false;
  90.    return $resultado;
  91.   }
  92.  
  93.   /*Terminada…*/
  94.   public function remove($id, $namespace = self::DEFAULT_NAMESPACE)
  95.   {
  96.    $this->conn = mysql_connect(self::DEFAULT_HOST, self::DEFAULT_USR, self::DEFAULT_PSR);
  97.    mysql_select_db(self::DEFAULT_BD, $this->conn);
  98.    mysql_query("SET NAMES 'utf8'", $this->conn);
  99.    
  100.    $statement = sprintf("DELETE FROM _cache WHERE id = '%s' AND namespace = '%s' LIMIT 1", mysql_escape_string($id), mysql_escape_string($namespace));
  101.    $resultado = mysql_query($statement, $this->conn) ? true : false;
  102.    
  103.    return $resultado;
  104.   }
  105.  
  106.   /*Terminada… POR OBTIMIZAR*/
  107.   public function clean($namespace = null, $mode = 'all')
  108.   {
  109.    $this->conn = mysql_connect(self::DEFAULT_HOST, self::DEFAULT_USR, self::DEFAULT_PSR);
  110.    mysql_select_db(self::DEFAULT_BD, $this->conn);
  111.    mysql_query("SET NAMES 'utf8'", $this->conn);  
  112.  
  113.    if (!$namespace) {
  114.       $statement = "DELETE FROM _cache";
  115.    } else {
  116.       $statement = sprintf("DELETE FROM _cache WHERE namespace LIKE '%s%%'", $namespace);
  117.    }
  118.  
  119.    if ('old' == $mode) {
  120.       $statement .= sprintf(" %s created_at < '%s'", $namespace ? 'AND' : 'WHERE', mysql_escape_string(date('Y-m-d H:i:s', $this->refreshTime)));
  121.    }
  122.  
  123.    $resultado = mysql_num_rows(mysql_query($statement, $this->conn)) ? true : false;
  124.    
  125.    return $resultado;
  126.   }
  127.  
  128.   /*Terminada…*/
  129.   public function lastModified($id, $namespace = self::DEFAULT_NAMESPACE)
  130.   {
  131.    $this->conn = mysql_connect(self::DEFAULT_HOST, self::DEFAULT_USR, self::DEFAULT_PSR);
  132.    mysql_select_db(self::DEFAULT_BD, $this->conn);
  133.    mysql_query("SET NAMES 'utf8'", $this->conn);  
  134.  
  135.    $statement = sprintf("SELECT UNIX_TIMESTAMP(created_at) as created_at  FROM _cache WHERE id = '%s' AND namespace = '%s' LIMIT 1", mysql_escape_string($id), mysql_escape_string($namespace));
  136.    $rs = mysql_query($statement, $this->conn);
  137.    $data = mysql_fetch_array($rs);
  138.    $resultado = mysql_num_rows($rs) ? intval($data['created_at']) : 0;
  139.  
  140.    return $resultado;
  141.   }
  142.  
  143. }
  144. ?>
Hacer un Comentario :cache, MySQL, PHP, sfMySQLCache, Symfony más...

Trabajar con UTF-8 en Symfony

por admin en Dic.15, 2008, dentro Symfony

Durante mis primeros días trabajando con symfony me encontré con un problema que me hizo perder varios días de trabajo.

Por lo visto symfony tiene un archivo de configuración “config/settings.yml” donde le puedes indicar el charset con el que vas a trabajar dentro del proyecto.

El problema me lo encontré al intentar conectar una base de datos MySQL utilizando el charset utf-8. Por lo visto synfony 1.0.17 no ejecuta la sentencia set names para trabajar en unicode.
Esta sentencia es la encargada de decirle a nuestra base de datos que se va a trabajar en utf-8.

Finalmente, despues de mucho pelearme, conseguí hacerlo funcionar mediante un filtro.

Para conseguirlo, solo es necesario crear la clase Utf8ConnectionFilter dentro del directorio lib de nuestra aplicación.

Utf8ConnectionFilter.class.php

  1. <?php
  2.  
  3. class Utf8ConnectionFilter extends sfFilter
  4. {
  5.  public function execute($filterChain) {
  6.   $con = Propel::getConnection();
  7.   if ($con) {
  8.    $con->executeQuery("set names utf8");
  9.   } else {
  10.    throw new Exception($e);
  11.   }
  12.   $filterChain->execute();
  13.  }
  14. }
  15.  
  16. ?>

El filtro, obtiene la conexión de propel y ejecuta la sentencia set names utf8 como primera sentencia sql.

Posteriormente hace una llamada al método execute para que continue con la ejecucción de los otros filtros.

Debemos añadir nuestra clase en el archivo config/filters.yml, que es el encargado de determinar que filtros se ejecutarán y cual será su orden de ejecucción.

filters.yml

  1. rendering: ~
  2. web_debug: ~
  3. security:  ~
  4.  
  5. connection:
  6.   class: Utf8ConnectionFilter
  7.  
  8. cache:     ~
  9. common:     ~
  10. flash:     ~
  11. execution: ~

Como último paso solo será necesario borrar la cache.

Hacer un Comentario :Filter, PHP, Symfony, Unicode, utf-8 más...

¿Buscas Algo?

Usa este formulario para buscar en el blog:

¿No encuentras lo que estas buscado? Si quieres borrar un comentario de un post contacta con nosotros, podemos ayudarte!

¡Visita nuestros amigos!

Listado de webs recomendadas...

Archivos

Todas las entradas, cronologicamente...