src/Noahtech/Sistemas/InterjamaBundle/Repository/McCajaMonedaRepository.php line 50

Open in your IDE?
  1. <?php
  3. namespace Noahtech\Sistemas\InterjamaBundle\Repository;
  5. use Doctrine\ORM\EntityRepository;
  6. use Doctrine\ORM\Query;
  7. use Noahtech\Sistemas\InterjamaBundle\Entity\McCajaMoneda;
  9. class McCajaMonedaRepository extends EntityRepository {
  11.     public function save(McCajaMoneda $cajaMoneda) {
  12.         try {
  13.             $em = $this->getEntityManager();
  14.             $em->getConnection()->beginTransaction();
  15.             $em->persist($cajaMoneda);
  16.             $em->flush();
  17.             $em->getConnection()->commit();
  18.             return $cajaMoneda;
  19.         } catch (Exception $e) {
  20.             $em->getConnection()->rollback();
  21.             throw new \Symfony\Component\HttpKernel\Exception\HttpException(500, "Ocurrio un error con la transaccion.");
  22.         }
  23.     }
  24.     
  25.     public function getAllMonedasByCaja($cajaId) {
  26.         $qb = $this->createQueryBuilder('cm');
  27.         $qb->where('cm.caja = :caja')->setParameter('caja', $cajaId);
  28.         $results = $qb->select('cm')->getQuery()->getResult();
  29.         return $results;
  30.     }
  32.     public function delete(McCajaMoneda $cajaMoneda) {
  33.         try {
  34.             $em = $this->getEntityManager();
  35.             $em->getConnection()->beginTransaction();
  36.             $em->remove($cajaMoneda);
  37.             $em->flush();
  38.             $em->getConnection()->commit();
  39.             return "Moneda eliminada con éxito";            
  40.         } catch (Exception $e) {
  41.             $em->getConnection()->rollback();
  42.             throw new \Symfony\Component\HttpKernel\Exception\HttpException("Ocurrio un error con la transaccion.");
  43.         }
  44.     }
  46.     public function getByCajaAndMoneda($cajaId, $monedaId) {
  47.         $qb = $this->createQueryBuilder('cm');
  48.         $qb->where('cm.caja = :caja')->setParameter('caja', $cajaId);
  49.         $qb->andWhere('cm.moneda = :moneda')->setParameter('moneda', $monedaId);
  50.         $results = $qb->select('cm')->getQuery()->getOneOrNullResult();
  51.         return $results;
  52.     }
  53. }