Update CustomQueriesExtension.php

src/CustomQueriesExtension.php

@@ -23,6 +23,8 @@ class CustomQueriesExtension extends SimpleExtension
     {
         return [
             'queriesResults' => ['getQueriesResults', ['is_safe' => ['html']]],
+            'queriesArrayResults' => ['queriesArrayResults'],
+            'countResults' => ['countResults'],
         ];
     }
 
@@ -105,7 +107,89 @@ class CustomQueriesExtension extends SimpleExtension
 
         return $this->getContainer()['twig']->render("custom_queries.twig", ['records' => $records]);
     }
+    
+       /**
+     * @return false|mixed
+     */
+    public function queriesArrayResults($input)
+    {
+        if($input == '') {
+           return '';
+        }
+
+        $json = json_decode($input, true);
+        if(!$json || empty($json)) {
+            return '';
+        }
+
+        $records = [];
+        $storage = $this->getContainer()['storage'];
+
+        foreach ($json as $contentType => $fields) {
+            $query = $this->_buildQuery($contentType, $fields);
+
+            if(!empty($query))
+            {
+                $rows = $this->getContainer()['db']->fetchAll($query);
+                $ids = array_map(function($rows) {
+                    return $rows['id'];
+                }, $rows);
+
+                $contents = $storage->getContent($contentType, ['id' => implode(' || ', $ids), 'paging' => true, 'limit' => 99999]);
+                if(is_array($contents)) {
+                    $records = array_merge($records, $contents);
+                } else {
+                    $records = array_merge($records, [$contents]);
+                }
+
+
+            }
+        }
+
+        return ['records' => $records];
+    }
 
+   /**
+     * @return false|mixed
+     */
+    public function countResults($input)
+    {
+        if($input == '') {
+           return '';
+        }
+
+        $json = json_decode($input, true);
+        if(!$json || empty($json)) {
+            return '';
+        }
+
+        $records = [];
+        $storage = $this->getContainer()['storage'];
+
+        foreach ($json as $contentType => $fields) {
+            $query = $this->_buildQuery($contentType, $fields);
+
+            if(!empty($query))
+            {
+                $rows = $this->getContainer()['db']->fetchAll($query);
+                $ids = array_map(function($rows) {
+                    return $rows['id'];
+                }, $rows);
+
+                $contents = $storage->getContent($contentType, ['id' => implode(' || ', $ids), 'paging' => true, 'limit' => 99999]);
+                if(is_array($contents)) {
+                    $records = array_merge($records, $contents);
+                } else {
+                    $records = array_merge($records, [$contents]);
+                }
+
+
+            }
+        }
+
+        return count($records);
+    }
+    
     /**
      * @param array $fields
      * @return string