actualizacion command-contadores

src/BackendBundle/Command/McafeeMigrarUsuariosCommand.php

@@ -47,16 +47,17 @@ class McafeeMigrarUsuariosCommand extends ContainerAwareCommand {
         $ultimoIndiceUsuarioProcesado = McafeeTransaccionPendienteQuery::create()
                 ->orderByMtpId("DESC")
                 ->findOne();
-        if($ultimoIndiceUsuarioProcesado == null) $ultimoIndiceUsuarioProcesado = 0;
+        if ($ultimoIndiceUsuarioProcesado == null)
+            $ultimoIndiceUsuarioProcesado = 0;
         $log->debug("ultimo indice procesado $ultimoIndiceUsuarioProcesado");
         $log->debug("obteniendo usuarios candidatos a migrar...");
         $usuariosAMigrar = UsuariosMcafeeMovistarMigrarQuery::create()
                 ->where("usuarios_mcafee_movistar_migrar.id > $ultimoIndiceUsuarioProcesado")
                 ->limit($usuariosMax)
                 ->find();
-        
-        $log->debug("cantidad de usuarios a migrar...".count($usuariosAMigrar));
-        
+
+        $log->debug("cantidad de usuarios a migrar..." . count($usuariosAMigrar));
+
         $log->debug("obteniendo partner ID...");
         $mcAfeePartnerId = Utiles::getParametroConfiguracion('mcafee_partner_id');
 
@@ -65,7 +66,7 @@ class McafeeMigrarUsuariosCommand extends ContainerAwareCommand {
 
             $log->debug("generando item a procesar...");
             $customerContextId = 'GLN_' . $usuarioMigrar->getId() . '_' . $usuarioMigrar->getAreaTel();
-            
+
             $nuevoUsuario = new UsuarioMcafee();
             $nuevoUsuario->setUmcMcafeeTipoProducto(UsuarioMcafee::TIPO_MULTIDEVICE);
             $nuevoUsuario->setUmcMcafeeAffid(419);
@@ -76,7 +77,7 @@ class McafeeMigrarUsuariosCommand extends ContainerAwareCommand {
             $nuevoUsuario->setUmcMcafeeEmail($usuarioMigrar->getEmailAddress());
             $nuevoUsuario->setUmcMovistarEmail($usuarioMigrar->getCorreo());
             $nuevoUsuario->setUmcMovistarRut($usuarioMigrar->getRut());
-            $nuevoUsuario->setUmcMovistarAny(explode("@",$usuarioMigrar->getEmailAddress())[0]);
+            $nuevoUsuario->setUmcMovistarAny(explode("@", $usuarioMigrar->getEmailAddress())[0]);
             $nuevoUsuario->setUmcMovistarActivo(UsuarioMcafee::ACTIVO_MOVISTAR_TRUE);
             $nuevoUsuario->setUmcParametroEncriptado($nuevoUsuario->generarUsuarioEncriptadoParaMovistar());
             $nuevoUsuario->setUmcCustomerId($customerContextId);
@@ -86,7 +87,7 @@ class McafeeMigrarUsuariosCommand extends ContainerAwareCommand {
             $nuevoUsuario->setCreatedAt(new \DateTime());
             $nuevoUsuario->setUpdatedAt(new \DateTime());
             $nuevoUsuario->save();
-            
+
             $log->debug("comenzando a generar registro de la transaccion..");
             $mcAfeeTx = new McafeeTransaccion();
             $mcAfeeTx->setMtrTipo(McafeeTransaccion::TIPO_ALTA);
@@ -100,7 +101,7 @@ class McafeeMigrarUsuariosCommand extends ContainerAwareCommand {
                         <DATA>
                         <CUSTOMERCONTEXT ID="' . $customerContextId . '" REQUESTTYPE="UPDATE">
                          <ACCOUNT/>
-                         <ORDER PARTNERREF="' . $mcAfeeTx->getMtrReferencia().'" REF="">
+                         <ORDER PARTNERREF="' . $mcAfeeTx->getMtrReferencia() . '" REF="">
                          <ITEMS>
                          <ITEM SKU="' . self::SKU_DESTINY . '" QTY="1" ACTION="TU">
                          <SOURCESKU>' . $usuarioMigrar->getSku() . '</SOURCESKU></ITEM>
@@ -116,111 +117,114 @@ class McafeeMigrarUsuariosCommand extends ContainerAwareCommand {
 
             $peticion = array('requestXML' => $xmlPartnerContext);
             $log->debug('Peticion a McAfee->' . print_r($peticion, true));
-            
+
             ///INICIO PETICION MCAFEE
-            
+
             try {
-            //Llamada McAfee
-            $wsMcafeePostRequestUrl = Utiles::getParametroConfiguracion('ws_mcafee_post_request_url');
-            $SOAP = new \SoapClient($wsMcafeePostRequestUrl, array("connection_timeout" => self::TIMEOUT, 'cache_wsdl' => WSDL_CACHE_NONE));
+                //Llamada McAfee
+                $wsMcafeePostRequestUrl = Utiles::getParametroConfiguracion('ws_mcafee_post_request_url');
+                $SOAP = new \SoapClient($wsMcafeePostRequestUrl, array("connection_timeout" => self::TIMEOUT, 'cache_wsdl' => WSDL_CACHE_NONE));
 
-            $log->debug('Llamando metodo "ProcessRequestWS"  url WS->' . $wsMcafeePostRequestUrl);
+                $log->debug('Llamando metodo "ProcessRequestWS"  url WS->' . $wsMcafeePostRequestUrl);
 
-            $respuesta = $SOAP->ProcessRequestWS($peticion);
-            $log->debug('Respuesta McAfee->' . print_r($respuesta, true));
+                $respuesta = $SOAP->ProcessRequestWS($peticion);
+                $log->debug('Respuesta McAfee->' . print_r($respuesta, true));
 
-            if ($respuesta != null) {
-                $mcAfeeTx->setMtrXmlRespuesta(print_r($respuesta->ProcessRequestWSResult, TRUE));
-                $arrayRespuesta = $this->procesarXmlRespuesta($respuesta);
-                $log->debug("Xml procesado  en forma de array: ".print_r($arrayRespuesta, true));
-                if ($arrayRespuesta == NULL) {
+                if ($respuesta != null) {
+                    $mcAfeeTx->setMtrXmlRespuesta(print_r($respuesta->ProcessRequestWSResult, TRUE));
+                    $arrayRespuesta = $this->procesarXmlRespuesta($respuesta);
+                    $log->debug("Xml procesado  en forma de array: " . print_r($arrayRespuesta, true));
+                    if ($arrayRespuesta == NULL) {
 
-                    $mcAfeeTx->setMtrEstado(McafeeTransaccion::ESTADO_FRACASADA);
-                    $mcAfeeTx->save();
-                    McafeeTransaccionPendiente::generarTransaccionPendiente($nuevoUsuario, McafeeTransaccionPendiente::TIPO_ALTA);
-                    $log->err('$arrayRespuesta == NULL para mcAfeeTx id->' . $mcAfeeTx->getMtrId(). 'PETICION:'. print_r($peticion, TRUE));
-                    $logError = Utiles::setLog('command::migrarUsuariosSuscripcion', 'error/wsMigrarUsuariosMcAfee');
-                    $logError->err('$arrayRespuesta == NULL para mcAfeeTx id->' . $mcAfeeTx->getMtrId(). 'PETICION:'. print_r($peticion, TRUE));
-                    $cantidadPendientes++;
-                    $failedAlready  = true;
-                }
-                $log->debug('$arrayRespuesta McAfee->' . print_r($arrayRespuesta, true));
-
-                $mcAfeeTx->setMtrCodigoRetorno($arrayRespuesta['mcAfeeReturnCode']);
-                
-                $log->debug('Descripcion de la transaccion ->' . $arrayRespuesta['mcAfeeReturnDesc']);
-                if ($arrayRespuesta['mcAfeeReturnCode'] == '1000' || $arrayRespuesta['mcAfeeReturnCode'] == '5001'|| $arrayRespuesta['mcAfeeReturnCode'] == '5002') {
-                    //validacion datos Tx
-                    if ($arrayRespuesta['mcAfeeCostumerId'] == $nuevoUsuario->getUmcCustomerId() && $arrayRespuesta['mcAfeeOrderPartnerRef'] == $mcAfeeTx->getMtrReferencia()) {
-                        /**
-                         * @todo agregar urlProduct.
-                         */
-                        $mcAfeeTx->setMtrReferenciaMcafee($arrayRespuesta['mcAfeeOrderRef']);
-                        $mcAfeeTx->setMtrEstado(McafeeTransaccion::ESTADO_SUCCESS);
-                        $mcAfeeTx->setMtrProductdownloadurl($arrayRespuesta['mcAfeeProductDownloadUrl']);
-                        $mcAfeeTx->save();
-                        $log->debug('Transaccion finalizada con exito!.  id Transaccion->' . $mcAfeeTx->getMtrId());
-                        $cantidadProcesados++;
-                    } else {
                         $mcAfeeTx->setMtrEstado(McafeeTransaccion::ESTADO_FRACASADA);
                         $mcAfeeTx->save();
                         McafeeTransaccionPendiente::generarTransaccionPendiente($nuevoUsuario, McafeeTransaccionPendiente::TIPO_ALTA);
-                        
-                        $log->err('Respuesta Costumer Id->' . $arrayRespuesta['mcAfeeCostumerId'] . 'y Costumer id->' . $nuevoUsuario->getUmcCustomerId());
-                        $log->err('nro de referencia Respuesta->' . $arrayRespuesta['mcAfeeOrderPartnerRef'] . 'y nro referencia->' . $mcAfeeTx->getMtrReferencia());
-                        $log->err('la transaccion fracaso debido a inconsistencia en los datos.'.print_r($arrayRespuesta,true));
+                        $log->err('$arrayRespuesta == NULL para mcAfeeTx id->' . $mcAfeeTx->getMtrId() . 'PETICION:' . print_r($peticion, TRUE));
                         $logError = Utiles::setLog('command::migrarUsuariosSuscripcion', 'error/wsMigrarUsuariosMcAfee');
-                        $logError->err('Respuesta Costumer Id->' . $arrayRespuesta['mcAfeeCostumerId'] . 'y Costumer id->' . $nuevoUsuario->getUmcCustomerId());
-                        $logError->err('nro de referencia Respuesta->' . $arrayRespuesta['mcAfeeOrderPartnerRef'] . 'y nro referencia->' . $mcAfeeTx->getMtrReferencia());
-                        $logError->err('la transaccion fracaso debido a inconsistencia en los datos.'.print_r($arrayRespuesta,true));
+                        $logError->err('$arrayRespuesta == NULL para mcAfeeTx id->' . $mcAfeeTx->getMtrId() . 'PETICION:' . print_r($peticion, TRUE));
                         $cantidadPendientes++;
                         $failedAlready = true;
+                    } else {
+
+
+                        $log->debug('$arrayRespuesta McAfee->' . print_r($arrayRespuesta, true));
+
+                        $mcAfeeTx->setMtrCodigoRetorno($arrayRespuesta['mcAfeeReturnCode']);
+
+                        $log->debug('Descripcion de la transaccion ->' . $arrayRespuesta['mcAfeeReturnDesc']);
+                        if ($arrayRespuesta['mcAfeeReturnCode'] == '1000' || $arrayRespuesta['mcAfeeReturnCode'] == '5001' || $arrayRespuesta['mcAfeeReturnCode'] == '5002') {
+                            //validacion datos Tx
+                            if ($arrayRespuesta['mcAfeeCostumerId'] == $nuevoUsuario->getUmcCustomerId() && $arrayRespuesta['mcAfeeOrderPartnerRef'] == $mcAfeeTx->getMtrReferencia()) {
+                                /**
+                                 * @todo agregar urlProduct.
+                                 */
+                                $mcAfeeTx->setMtrReferenciaMcafee($arrayRespuesta['mcAfeeOrderRef']);
+                                $mcAfeeTx->setMtrEstado(McafeeTransaccion::ESTADO_SUCCESS);
+                                $mcAfeeTx->setMtrProductdownloadurl($arrayRespuesta['mcAfeeProductDownloadUrl']);
+                                $mcAfeeTx->save();
+                                $log->debug('Transaccion finalizada con exito!.  id Transaccion->' . $mcAfeeTx->getMtrId());
+                                $cantidadProcesados++;
+                            } else {
+                                $mcAfeeTx->setMtrEstado(McafeeTransaccion::ESTADO_FRACASADA);
+                                $mcAfeeTx->save();
+                                McafeeTransaccionPendiente::generarTransaccionPendiente($nuevoUsuario, McafeeTransaccionPendiente::TIPO_ALTA);
+
+                                $log->err('Respuesta Costumer Id->' . $arrayRespuesta['mcAfeeCostumerId'] . 'y Costumer id->' . $nuevoUsuario->getUmcCustomerId());
+                                $log->err('nro de referencia Respuesta->' . $arrayRespuesta['mcAfeeOrderPartnerRef'] . 'y nro referencia->' . $mcAfeeTx->getMtrReferencia());
+                                $log->err('la transaccion fracaso debido a inconsistencia en los datos.' . print_r($arrayRespuesta, true));
+                                $logError = Utiles::setLog('command::migrarUsuariosSuscripcion', 'error/wsMigrarUsuariosMcAfee');
+                                $logError->err('Respuesta Costumer Id->' . $arrayRespuesta['mcAfeeCostumerId'] . 'y Costumer id->' . $nuevoUsuario->getUmcCustomerId());
+                                $logError->err('nro de referencia Respuesta->' . $arrayRespuesta['mcAfeeOrderPartnerRef'] . 'y nro referencia->' . $mcAfeeTx->getMtrReferencia());
+                                $logError->err('la transaccion fracaso debido a inconsistencia en los datos.' . print_r($arrayRespuesta, true));
+                                $cantidadPendientes++;
+                                $failedAlready = true;
+                            }
+                        } else {//codigo de retorno distinto de 1000 y 5001
+                            $mcAfeeTx->setMtrEstado(McafeeTransaccion::ESTADO_FRACASADA);
+                            $mcAfeeTx->save();
+                            McafeeTransaccionPendiente::generarTransaccionPendiente($nuevoUsuario, McafeeTransaccionPendiente::TIPO_ALTA);
+
+                            $log->err('returnCode distinto de 1000 y 5001 que son los exitosos.' . print_r($arrayRespuesta, true));
+
+                            $logError = Utiles::setLog('command::migrarUsuariosSuscripcion', 'error/wsMigrarUsuariosMcAfee');
+                            $logError->err('returnCode distinto de 1000 y 5001 que son los exitosos.' . print_r($arrayRespuesta, true));
+                            $cantidadPendientes++;
+                            $failedAlready = true;
+                        }
                     }
-                } else {//codigo de retorno distinto de 1000 y 5001
+                } else {//$respuesta ==NULL                
                     $mcAfeeTx->setMtrEstado(McafeeTransaccion::ESTADO_FRACASADA);
                     $mcAfeeTx->save();
                     McafeeTransaccionPendiente::generarTransaccionPendiente($nuevoUsuario, McafeeTransaccionPendiente::TIPO_ALTA);
-                   
-                    $log->err('returnCode distinto de 1000 y 5001 que son los exitosos.'.print_r($arrayRespuesta,true));
-                    
+
+                    $log->err('respuesta NULL para peticion:' . print_r($peticion, true));
                     $logError = Utiles::setLog('command::migrarUsuariosSuscripcion', 'error/wsMigrarUsuariosMcAfee');
-                    $logError->err('returnCode distinto de 1000 y 5001 que son los exitosos.'.print_r($arrayRespuesta,true));
+                    $logError->err('respuesta NULL para peticion:' . print_r($peticion, true));
                     $cantidadPendientes++;
                     $failedAlready = true;
                 }
-            } else {//$respuesta ==NULL                
+            } catch (\Exception $exc) {
+
                 $mcAfeeTx->setMtrEstado(McafeeTransaccion::ESTADO_FRACASADA);
                 $mcAfeeTx->save();
-                McafeeTransaccionPendiente::generarTransaccionPendiente($nuevoUsuario, McafeeTransaccionPendiente::TIPO_ALTA);
-                
-                $log->err('respuesta NULL para peticion:' . print_r($peticion, true));
+                if (!$esTxPendiente) {
+                    McafeeTransaccionPendiente::generarTransaccionPendiente($nuevoUsuario, McafeeTransaccionPendiente::TIPO_ALTA);
+                }
+                $log->err('Error al llamar WS. Exception:' . $exc->getMessage() . ' | peticion:' . print_r($peticion, true));
                 $logError = Utiles::setLog('command::migrarUsuariosSuscripcion', 'error/wsMigrarUsuariosMcAfee');
-                $logError->err('respuesta NULL para peticion:' . print_r($peticion, true));
+                $logError->err('Error al llamar WS. Exception:' . $exc->getMessage() . ' | peticion:' . print_r($peticion, true));
+                //return FALSE;
                 $cantidadPendientes++;
                 $failedAlready = true;
             }
-        } catch (\Exception $exc) {
 
-            $mcAfeeTx->setMtrEstado(McafeeTransaccion::ESTADO_FRACASADA);
-            $mcAfeeTx->save();
-            if (!$esTxPendiente) {
-                McafeeTransaccionPendiente::generarTransaccionPendiente($nuevoUsuario, McafeeTransaccionPendiente::TIPO_ALTA);
-            }
-            $log->err('Error al llamar WS. Exception:' . $exc->getMessage() . ' | peticion:' . print_r($peticion, true));
-            $logError = Utiles::setLog('command::migrarUsuariosSuscripcion', 'error/wsMigrarUsuariosMcAfee');
-            $logError->err('Error al llamar WS. Exception:' . $exc->getMessage() . ' | peticion:' . print_r($peticion, true));
-            //return FALSE;
-            $cantidadPendientes++;
-            $failedAlready = true;
-        }
-        
-        $ultimoUsuarioProcesado = $nuevoUsuario;        
-        
+            $ultimoUsuarioProcesado = $nuevoUsuario;
+
         endforeach;
-        
-        
+
+
         //GENERANDO REGISTRO DE PROCESO
-        
+
         $registroProceso = new McafeeUltimoProcesoMigracion();
         $registroProceso->setUsuarioMcafee($ultimoUsuarioProcesado);
         $registroProceso->setMupCantidadProcesados($cantidadProcesados);
@@ -228,12 +232,12 @@ class McafeeMigrarUsuariosCommand extends ContainerAwareCommand {
         $registroProceso->setCreatedAt(new \DateTime());
         $registroProceso->setUpdatedAt(new \DateTime());
         $registroProceso->save();
-        
-        
-        
+
+
+
         $output->writeln('COMANDO FINALIZADO.');
     }
-    
+
     /**
      * Procesa respuesta mcafee, extrae valores y atributos y devuelve un array con estos valores.
      * 
@@ -282,7 +286,6 @@ class McafeeMigrarUsuariosCommand extends ContainerAwareCommand {
                     $arrayRespuesta['mcAfeeOrderPartnerRef'] = (string) $xObjRespuesta->DATA->RESPONSECONTEXT->ORDER->attributes()->PARTNERREF;
                     $arrayRespuesta['mcAfeeOrderRef'] = (string) $xObjRespuesta->DATA->RESPONSECONTEXT->ORDER->attributes()->REF;
                     $arrayRespuesta['mcAfeeProductKey'] = (string) $xObjRespuesta->DATA->RESPONSECONTEXT->ORDER->ITEMS->ITEM->PRODUCTKEY;
-                    
                 }
 
                 if (isset($xObjRespuesta->DATA->RESPONSECONTEXT->ACCOUNT)) {
@@ -292,11 +295,11 @@ class McafeeMigrarUsuariosCommand extends ContainerAwareCommand {
         } catch (\Exception $ex) {
             $log->crit("Error al leer detalles XML." . $xmlRespuesta->ProcessRequestWSResult);
             $log->crit("Detalle error " . print_r($ex, TRUE));
-            
+
             $logError = Utiles::setLog('WsBundle\Lib\controladorMcAfee::procesarXmlRespuesta', 'error/wsMcAfee');
             $logError->crit("Error al leer detalles XML." . $xmlRespuesta->ProcessRequestWSResult);
             $logError->crit("Detalle error " . print_r($ex, TRUE));
-            
+
             $arrayRespuesta = array();
         }