src/Repository/Idempiere/AdSequenceRepository.php line 31

Open in your IDE?
  1. <?php
  3. namespace App\Repository\Idempiere;
  5. use App\Entity\Idempiere\AdSequence;
  6. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  7. use Doctrine\Persistence\ManagerRegistry;
  9. /**
  10.  * @method AdSequence|null find($id, $lockMode = null, $lockVersion = null)
  11.  * @method AdSequence|null findOneBy(array $criteria, array $orderBy = null)
  12.  * @method AdSequence[]    findAll()
  13.  * @method AdSequence[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
  14.  */
  15. class AdSequenceRepository extends ServiceEntityRepository
  16. {
  17.     public function __construct(ManagerRegistry $registry)
  18.     {
  19.         parent::__construct($registry, AdSequence::class);
  20.     }
  21.     
  22.     /**
  23.      * Buscar el correlativo siguiente de una
  24.      * secuencia
  25.      * 
  26.      * @param AdSequence $sequence Secuencia
  27.      * @param object $entity Entidad base
  28.      * 
  29.      * @return string Correlativo 
  30.      */
  31.     public function findNextSequence(AdSequence $sequence, Object $entity = null): String
  32.     {
  33.         $connection = $this->getEntityManager()->getConnection();
  35.         if( $sequence->getIsorglevelsequence() )
  36.             return $this->findNextSequenceByOrg($sequence, $entity);
  38.         $stmt = $connection->prepare("SELECT nextid(:sequence_id, 'N')");
  39.         $resultSet = $stmt->executeQuery(['sequence_id' => $sequence->getId() ]);
  41.         return $resultSet->fetchOne();
  42.     }
  44.     /**
  45.      * Buscar el correlativo siguiente 
  46.      * de una secuencia correspondiente a 
  47.      * una organizacion 
  48.      * 
  49.      * @param AdSequence $sequence Secuencia
  50.      * @param object $entity Entidad base
  51.      * 
  52.      * @return string Correlativo
  53.      */
  54.     protected function findNextSequenceByOrg(AdSequence $sequence, Object $entity): String
  55.     {
  56.         $connection = $this->getEntityManager()->getConnection();
  58.         // Get Current Next
  59.         $stmt = $connection->prepare(
  60.             "SELECT currentnext FROM ad_sequence_no 
  61.             WHERE ad_sequence_id = :sequence_id AND ad_org_id = :org_id");
  62.         $resultSet = $stmt->executeQuery([
  63.             'sequence_id' => $sequence->getId(),
  64.             'org_id' => $entity->getAdOrg()->getAdOrgId()
  65.         ]);
  66.         $currentnext = $resultSet->fetchOne();
  68.         // Get Prefix
  69.         $prefix = $this->buildPrefex($sequence->getPrefix(), $entity);
  71.         // Update Sequence No
  72.         $stmt = $connection->prepare(
  73.             "UPDATE ad_sequence_no SET currentnext = :currentnext
  74.             WHERE ad_sequence_id = :sequence_id AND ad_org_id = :org_id"
  75.         );
  76.         $stmt->executeQuery([
  77.             'currentnext' => $currentnext + 1,
  78.             'sequence_id' => $sequence->getId(),
  79.             'org_id' => $entity->getAdOrg()->getAdOrgId()
  80.         ]);
  82.         return $prefix . $currentnext;
  83.     }
  85.     /**
  86.      * Genera un RowGUID
  87.      * 
  88.      * @return string RowGUID
  89.      */
  90.     public function findNextUU(): String
  91.     {
  92.         $connection = $this->getEntityManager()->getConnection();
  94.         $stmt = $connection->prepare("SELECT generate_uuid()");
  95.         $resultSet = $stmt->executeQuery();
  97.         return $resultSet->fetchOne();
  98.     }
  100.     /**
  101.      * Construir prefijos de secuencias
  102.      * 
  103.      * @param string $prefix Prefijo de la secuencia
  104.      * @param object $entity Entidad base
  105.      * 
  106.      * @return string Prefijo
  107.      */
  108.     protected function buildPrefex(String $prefix, Object $entity): String
  109.     {
  110.         if ( !empty($prefix) ) {
  111.             $prefix = preg_split('([<@.>\s])', $prefix);
  112.             $prefix = array_filter($prefix, 'trim');
  114.             $_prefix = $prefix[0];
  115.             if (count($prefix) === 4) {
  116.                 $connection = $this->getEntityManager()->getConnection();
  117.                 $getObject = 'get' . implode( array_map('ucfirst', explode('_', $prefix[2]) ) );
  119.                 $sql = "SELECT {$prefix[3]} FROM {$prefix[2]} WHERE {$prefix[1]} = :value";
  120.                 $stmt = $connection->prepare($sql);
  121.                 $resultSet = $stmt->executeQuery( ['value' => $entity->$getObject()->getId()] );
  123.                 $_prefix .= $resultSet->fetchOne();
  124.             }
  125.             return $_prefix;
  126.         }
  127.         return '';
  128.     }
  129. }