src/Repository/Idempiere/CPaymentRepository.php line 66

Open in your IDE?
  1. <?php
  3. namespace App\Repository\Idempiere;
  5. use App\Entity\Idempiere\CPayment;
  6. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  7. use Doctrine\ORM\OptimisticLockException;
  8. use Doctrine\ORM\ORMException;
  9. use Doctrine\Persistence\ManagerRegistry;
  11. /**
  12.  * @extends ServiceEntityRepository<CPayment>
  13.  *
  14.  * @method CPayment|null find($id, $lockMode = null, $lockVersion = null)
  15.  * @method CPayment|null findOneBy(array $criteria, array $orderBy = null)
  16.  * @method CPayment[]    findAll()
  17.  * @method CPayment[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
  18.  */
  19. class CPaymentRepository extends ServiceEntityRepository
  20. {
  21.     public $sequence;
  22.     
  23.     public function __construct(ManagerRegistry $registry)
  24.     {
  25.         parent::__construct($registry, CPayment::class);
  27.         /** Table Sequence */
  28.         $RSequence = new AdSequenceRepository($registry);
  29.         $this->sequence = $RSequence->findBy(['name' => $this->getClassMetadata()->getTableName()]);
  30.         $this->sequence = $this->sequence[0];
  31.     }
  33.     /**
  34.      * @throws ORMException
  35.      * @throws OptimisticLockException
  36.      */
  37.     public function add(CPayment $entity, bool $flush = true): void
  38.     {
  39.         $this->_em->persist($entity);
  40.         if ($flush) {
  41.             $this->_em->flush();
  42.         }
  43.     }
  45.     /**
  46.      * @throws ORMException
  47.      * @throws OptimisticLockException
  48.      */
  49.     public function remove(CPayment $entity, bool $flush = true): void
  50.     {
  51.         $this->_em->remove($entity);
  52.         if ($flush) {
  53.             $this->_em->flush();
  54.         }
  55.     }
  57.     /**
  58.      * Obtener pagos filtrando las 
  59.      * 
  60.      * @param array $BP_Items Rubros de Organizacion
  61.      * @param mixed $DocStatus Estatus de documento
  62.      * @param string $Date Fecha
  63.      * 
  64.      * @return CPayment[] Pagos
  65.      */
  66.     public function findPaymentsByBPItem(Array $BP_Items, $DocStatus = null, String $Date = null)
  67.     {
  68.         $qb = $this->createQueryBuilder('cp');
  70.         $qb
  71.             ->join('cp.sm_marca', 'sm')
  72.             ->where(
  73.                 $qb->expr()->andX(
  74.                     $qb->expr()->eq('cp.isreceipt', "'N'"),
  75.                     $qb->expr()->in('sm.sm_bp_item_id', ':bp_items')
  76.                 )
  77.             )
  78.             ->setParameter('bp_items', $BP_Items);
  80.         if ( is_array($DocStatus) && count($DocStatus) > 0) {
  81.             $qb->andWhere(
  82.                 $qb->expr()->in('cp.docstatus', ':status')
  83.             )->setParameter('status', $DocStatus);
  84.         } else if ( !is_null($DocStatus) && !empty($DocStatus) ) {
  85.             $qb->andWhere(
  86.                 $qb->expr()->eq('cp.docstatus', ':status')
  87.             )->setParameter('status', $DocStatus);
  88.         }
  90.         if ( !is_null($Date) && !empty($Date) ) {
  91.             $qb->andWhere(
  92.                 $qb->expr()->eq('cp.dateacct', ':date')
  93.             )->setParameter('date', $Date);
  94.         }
  96.         $query = $qb
  97.             ->orderBy(
  98.                 $qb->expr()->desc('cp.c_doctype_id'),
  99.                 $qb->expr()->desc('cp.ad_org_id')
  100.             )
  101.             ->getQuery();
  103.         return $query->getResult();
  104.     }
  106.     public function convertAmt(CPayment $Payamt)
  107.     {
  108.         $conn = $this->getEntityManager()->getConnection();
  110.         $sql    = 'SELECT CURRENCYCONVERT(:payamt, :currency_id, :currencytarget_id, :dateacct, :conversiontype_id, :client_id, :org_id)';
  111.         $stmt   = $conn->prepare($sql);
  112.         $rs     = $stmt->executeQuery([
  113.             'payamt' => $Payamt->getPayamt(),
  114.             'currency_id' => $Payamt->getCCurrencyId(),
  115.             'currencytarget_id' => 100,
  116.             'dateacct' => $Payamt->getDateacct(),
  117.             'conversiontype_id' => $Payamt->getCConversiontypeId(),
  118.             'client_id' => $Payamt->getAdClientId(),
  119.             'org_id' => $Payamt->getAdOrgId()
  120.         ]);
  122.         return $rs->fetchOne();
  123.     }
  124. }