Add function to returns conuts over a period

Author: stevenjbrookes

.gitignore

@@ -3,4 +3,4 @@
 /docs/_build
 /coverage
 .idea
-/nbproject/private/
+/nbproject

src/Provider/DoctrineProvider.php

@@ -30,6 +30,8 @@
 class DoctrineProvider extends AbstractProvider
 {
 
+    const DEFAULT_PERIOD = 300;
+
     protected $em;
     protected $repository;
     protected static $entityName = 'Uecode\Bundle\QPushBundle\Entity\DoctrineMessage';
@@ -113,7 +115,7 @@ public function getRepository()
         if (!$this->repository) {
             return;
         }
-        
+
         return $this->repository;
     }
 
@@ -127,7 +129,7 @@ public function create()
     {
         $sm = $this->em->getConnection()->getSchemaManager();
         $table = $this->em->getClassMetadata(self::$entityName)->getTableName();
-        
+
         return $sm->tablesExist(array($table));
     }
 
@@ -178,8 +180,7 @@ public function receive(array $options = [])
         }
 
         $doctrineMessages = $this->repository->findBy(
-                array('delivered' => false, 'queue' => $this->name),
-                array('id' => 'ASC')
+                array('delivered' => false, 'queue' => $this->name), array('id' => 'ASC')
         );
 
         $messages = [];
@@ -202,7 +203,7 @@ public function delete($id)
         $doctrineMessage = $this->repository->findById($id);
         $doctrineMessage->setDelivered(true);
         $this->em->flush();
-        
+
         return true;
     }
 
@@ -218,7 +219,7 @@ public function destroy()
         $qb->where('dm.queue = :queue');
         $qb->setParameter('queue', $this->name);
         $qb->getQuery()->execute();
-        
+
         return true;
     }
 
@@ -248,10 +249,10 @@ public function findBy($data)
         $qb->where('p.queue = :queue');
         $qb->setParameter('queue', $this->name);
 
-        $field = (isset($data['field']))?$data['field']:'message';
-        
+        $field = (isset($data['field'])) ? $data['field'] : 'message';
+
         if (isset($data['search']) && $data['search'] !== null) {
-            $qb->andWhere('p.'.$field.' LIKE :contains');
+            $qb->andWhere('p.' . $field . ' LIKE :contains');
             $qb->setParameter('contains', '%' . $data['search'] . '%');
         }
 
@@ -267,4 +268,43 @@ public function findBy($data)
 
         return $qb->getQuery();
     }
+
+    /*
+     * Returns an array of times and messgae counts
+     * @praram $data ['from' => date, 'to' => date, 'period' => seconds
+     * @return ['time', 'count']
+     */
+
+    public function counts($data)
+    {
+        if (isset($data['period']) && $data['period'] !== null) {
+            $period = $data['period'];
+        } else {
+            $period = self::DEFAULT_PERIOD;
+        }
+
+        $sql = 'SELECT from_unixtime(floor(unix_timestamp(created)/'
+                . $period . ') * ' . $period . ') as time, 
+            count(*) as count 
+            FROM uecode_qpush_message
+            where queue = "' . $this->name . '"';
+
+        if (isset($data['from']) && $data['from'] !== null) {
+            $sql = $sql . ' and created >= "' . $data['from'] . '"';
+        }
+
+        if (isset($data['to']) && $data['to'] !== null) {
+            $sql = $sql . ' and created <= "' . $data['to'] . '"';
+        }
+
+        $sql = $sql . ' group by floor(unix_timestamp(created)/' . $period . ')';
+        $sql = $sql . ' order by floor(unix_timestamp(created)/' . $period . ') ASC';
+
+        $statement = $this->em->getConnection() > prepare($sql);
+        $statement->execute();
+        $results = $statement->fetchAll();
+        
+        return $results;
+    }
+
 }