test

2cd96b34 · Cristian Mauricio Diaz Canales · 1631fbd7 · 2cd96b34
Commit 2cd96b34 authored Jun 14, 2019 by Cristian Mauricio Diaz Canales 💬
Hide whitespace changes
Inline Side-by-side

Showing with 108 additions and 108 deletions

src/BackendBundle/Command/McafeeNormalizacionUsuariosMigracionCommand.php ...e/Command/McafeeNormalizacionUsuariosMigracionCommand.php +108 -108

No files found.
--- a/src/BackendBundle/Command/McafeeNormalizacionUsuariosMigracionCommand.php
+++ b/src/BackendBundle/Command/McafeeNormalizacionUsuariosMigracionCommand.php
 <?php
 namespace BackendBundle\Command;
 use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
 use Symfony\Component\Console\Input\InputArgument;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Input\InputOption;
 use Symfony\Component\Console\Output\OutputInterface;
 use AppBundle\Model\UsuarioMcafee;
 use AppBundle\Model\UsuarioMcafeeQuery;
 use AppBundle\Model\UsuariosMcafeeMovistarMigrar;
 use AppBundle\Model\UsuariosMcafeeMovistarMigrarQuery;
 use AppBundle\Model\McafeeUltimoProcesoNormalizacion;
 use AppBundle\Model\McafeeUltimoProcesoNormalizacionQuery;
 use AppBundle\Lib\Utiles;
 class McafeeNormalizacionUsuariosMigracionCommand extends ContainerAwareCommand
 {
    const SKU_DESTINY = "419-92860-1usermds";
    protected function configure()
    {
        $this
            ->setName('mcafee:normalizacion-usuarios-migracion')
            ->setDescription('comando que sirve para normalizar errores generados en la migracion.')
        ;
    }
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $output->writeln("COMANDO INICIADO.");
        $log = Utiles::setLog('command::NormalizacionUsuariosMigracion', 'ws/wsNormalizarUsuariosMcAfee');
        $ultimoUsuarioProcesado = null;
        $cantidadProcesados = 0;
        $cantidadPendientes = 0;
        $usuariosMax = Utiles::getParametroConfiguracion("numero_usuarios_normalizar");
        $log->debug("obteniendo ultimo indice procesado normalizacion...");
        $ultimoIndiceUsuarioProcesado = McafeeUltimoProcesoNormalizacionQuery::create()//arreglar es ultimo indice procesado
                ->orderByMunId("DESC")
                ->findOne();
        if ($ultimoIndiceUsuarioProcesado == null){
            $condicion = "usuario_mcafee.umc_id > 0 and created_at >= '2019-05-19'";
        //else $condicion = "usuarios_mcafee_movistar_migrar.id > ".$ultimoIndiceUsuarioProcesado->getUltimoUmcId();
        }else $condicion = "usuario_mcafee.umc_id >= 0 and usuario_mcafee.umc_id > ".$ultimoIndiceUsuarioProcesado->getUltimoUmcId()." and created_at >= '2019-05-19'";
        $log->debug("condicion a analizar ".$condicion);
        $log->debug("obteniendo usuarios candidatos a migrar...");
        $usuariosANormalizar = UsuarioMcafeeQuery::create()
                ->where($condicion)
                ->limit($usuariosMax)
                ->find();
        $log->debug("usuarios a normalizar : ".count($usuariosANormalizar));
        foreach($usuariosANormalizar as $index=>$usuario):
            $strAencriptar = $usuario->getUmcMcafeeCcid()."|".$usuario->getUmcMcafeeEmail();
            $log->debug("buscando usuario en tabla usuario movistar migrar por correo mcafee : ".$usuario->getUmcMcafeeEmail());
            $usuarioTablaMigracion = UsuariosMcafeeMovistarMigrarQuery::create()
                                    ->filterByEmailAddress($usuario->getUmcMcafeeEmail())
                                    ->findOne();
            if($usuarioTablaMigracion == null) continue;
            $log->debug("usuario mcafee a normalizar : ".$usuario->getUmcId());
            if($usuarioTablaMigracion->getFonoContactoMovil1() != 0){
                $telMovil = $usuarioTablaMigracion->getFonoContactoMovil1();
            }else {
                $telMovil = $usuarioTablaMigracion->getFonoContactoMovil2();
            }
+            $log->debug("paso");
            /*
            if($usuarioTablaMigracion->getCreatedAt()->format('Y-m-d') >= '2019-05-22'){
                $usuario->setUmcMcafeeSku(self::SKU_DESTINY);
            }*/
            $usuario->setUmcMovil($telMovil);
            $usuario->setUmcFijo($usuarioTablaMigracion->getAreaTel());
            $usuario->setUmcParametroEncriptado(Utiles::base64url_encode($strAencriptar));
            $usuario->setUpdatedAt(new \DateTime());
            $usuario->save();
+            $log->debug("paso2");
            $log->debug("Ultimo usuario procesado : ".$usuario->getUmcId());
            $log->debug("descansando el proceso un segundo...");
            $cantidadProcesados++;
            $ultimoUsuarioProcesado = $usuario;
            sleep(1);
        endforeach;
         //GENERANDO REGISTRO DE PROCESO
        $registroProceso = new McafeeUltimoProcesoNormalizacion();
        $registroProceso->setUsuarioMcafee($ultimoUsuarioProcesado);
        $registroProceso->setMunCantidadProcesados($cantidadProcesados);
        $registroProceso->setMunCantidadPendientes($cantidadPendientes);
        $registroProceso->setCreatedAt(new \DateTime());
        $registroProceso->setUpdatedAt(new \DateTime());
        $registroProceso->save();
        $log->debug("Ultimo usuario procesado : ".$ultimoUsuarioProcesado->getUmcId()." | cantidad procesados : $cantidadProcesados | cantidad pendientes : $cantidadPendientes");
        $output->writeln('COMANDO FINALIZADO.');
    }
 }