NEW garder le processus lie a la tache planifiee d'indexation

lib/BackgroundJob/IndexationProcess.php

@@ -270,9 +270,9 @@ class IndexationProcess extends TimedJob {
                 $this->_log('Indexation process : Begin');
 
                 // find process in indexation step
-                $processList = $this->_dematpayslipProcessMapper->findAll();
+                $processList = $this->_dematpayslipProcessMapper->findAllLast();
                 if (!empty($processList)) {
-                    $process = current($processList);
+                    $process = $processList[0];
                     if ($process->getPhase() == DematpayslipProcess::PHASE_ID_INDEXATION) {
                         $process->load($this->_appName, $this->_config, $this->_dbConnection, $this->_l10n, $this->_rootFolder, $this->_shareManager, $this->_userManager, $userId, $this->_dematpayslipProcessMapper, $this->_dematpayslipProcessSkipMapper, $this->_dematpayslipUserMapper, $this->_timeZone);
                         $result = $process->indexation($processMsgList);

lib/Controller/PageController.php

@@ -248,7 +248,7 @@ class PageController extends Controller {
         $this->_dematpayslipUserMapper = $dematpayslipUserMapper;
 
         // create process if not exists
-        $processList = $this->_dematpayslipProcessMapper->findAll();
+        $processList = $this->_dematpayslipProcessMapper->findAllLast();
         if (empty($processList)) {
             $process = new DematpayslipProcess();
             $process->setProcessing(0);
@@ -266,6 +266,7 @@ class PageController extends Controller {
             $this->_dematpayslipProcessMapper->insert($process);
             $this->_dematpaylsipProcess = $process;
         } else {
+            // get last process
             $this->_dematpaylsipProcess = $processList[0];
         }
 
@@ -323,7 +324,7 @@ class PageController extends Controller {
      * @throws  Exception
      */
     public function upload() {
-        // verifier l'utilisateur
+        // check user
         if ($this->_userId === $this->_dematpayslipConfigList['user_id']) {
             $this->_dematpaylsipProcess->upload();
 

lib/Db/DematpayslipProcessMapper.php

@@ -30,4 +30,14 @@ class DematpayslipProcessMapper extends QBMapper {
 
         return $this->findEntities($qb);
     }
+
+    public function findAllLast() {
+        $qb = $this->db->getQueryBuilder();
+
+        $qb->select('*')
+            ->from($this->getTableName())
+            ->orderBy('id', 'DESC');
+
+        return $this->findEntities($qb);
+    }
 }