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;
  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. }