se añaden cambios para kushki

parent a5f3cd9b
......@@ -48,6 +48,7 @@ class PluSuscripcionRepository extends ServiceEntityRepository {
public function getUltimaSuscripcionLista($msisdn, $idLista) {
return $this->createQueryBuilder('p')
->where('p.susVigente = 1')
->andWhere('p.susTipoSuscripcion = 1')
->andWhere('p.susUltimoTipoXml = 1')
->andWhere('p.susEliminado = 0')
->andWhere('p.susMsisdn = :msisdn')
......@@ -57,6 +58,20 @@ class PluSuscripcionRepository extends ServiceEntityRepository {
->getQuery()
->getOneOrNullResult();
}
public function getUltimaSuscripcionListaKushki($msisdn, $idLista) {
return $this->createQueryBuilder('p')
->where('p.susVigente = 1')
->andWhere('p.susTipoSuscripcion = 2')
->andWhere('p.susUltimoTipoKushki = 1')
->andWhere('p.susEliminado = 0')
->andWhere('p.susMsisdn = :msisdn')
->andWhere('p.lisId = :id')
->setParameters(array("id" => $idLista, "msisdn" => $msisdn))
->orderBy('p.susId', 'DESC')
->getQuery()
->getOneOrNullResult();
}
public function getUltimaSuscripcionListaByCode($msisdn, $code) {
$qb = $this->createQueryBuilder('sus');
......
......@@ -59,8 +59,34 @@ class Kushki {
}
}
public function callCancelarSuscripcionKushki($em) {
public function callCancelarSuscripcionKushki($em, $suscripcion) {
$log = Utiles::setLog("Kushki::callSuscripcionKushki", 'project/ws/kushki/pagos/suscripcion');
$url = Utiles::getParametroConfiguracion("urlBaseGatewayPagos", $em).Utiles::getParametroConfiguracion("cancelarSuscripcionPagos", $em).Utiles::getParametroConfiguracion("publicKeyKushki", $em)."/".Utiles::getParametroConfiguracion("clientIdKushki", $em)."/".$suscripcion->getSusSuscriptionIdKushki();
try {
$log->debug('suscribiendo kushki... url:' . $url);
$ch = curl_init($url);
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, "clientInternalId=".$suscripcion->getSusId()."&userIdentifier=".$suscripcion->getSusMsisdn()."&startDate=".$suscripcion->getSusStartDateKushki()."&periodicity=".Utiles::getParametroConfiguracion("periodoSuscripcion", $em));
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_TIMEOUT, 60);
$output = curl_exec($ch);
$status_code_suscribir = curl_getinfo($ch, CURLINFO_HTTP_CODE);
curl_close($ch);
$log->debug('Retorno status a suscribir externo:' . $status_code_suscribir . ' | desc:' . $output);
$data = json_decode($output, true);
return $data;
} catch (\Exception $e) {
$log->err(' Error al suscribir. url:' . $url . ' .Exception: ' . $e);
$status_code = null;
$desc = null;
$logError = Utiles::setLog("Kushki::callSuscripcionKushki", 'error/wsKushkiSuscripcion');
$logError->err(' Error al suscribir. url:' . $url . ' .Exception: ' . $e);
return ['code' => 500, 'message' => "", "subscriptionId" => "", "internalId" => ""];
}
}
public function getPostFields(){
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment