PMCORE-1420

workflow/engine/src/ProcessMaker/BusinessModel/Variable.php

@@ -26,6 +26,16 @@ class Variable
         'object'  => 10
     ];
 
+    /**
+     * Get the variables types accepted
+     * 
+     * @return array 
+     */
+    public function getVariableTypes()
+    {
+        return $this->variableTypes;
+    }
+
     /**
      * Create Variable for a Process
      *
@@ -355,6 +365,34 @@ class Variable
         return $arrayVariables;
     }
 
+     /**
+     * Get data of Variables related to the specific type
+     *
+     * @param string $processUid Unique id of Process
+     * @param int $typeVarId
+     * @param int $start
+     * @param int $limit
+     * @param string $search
+     * @param string $prefix
+     *
+     * @return array, return an array with data of a DynaForm
+     * @throws Exception
+     */
+    public function getVariablesByType($processUid, $typeVarId = 0, $start = null, $limit = null, $search = null, $prefix = null)
+    {
+        //Verify data
+        $proId = Validator::proUid($processUid, '$prj_uid');
+        $variables = ProcessVariables::getVariablesByType($proId, $typeVarId, $start, $limit, $search);
+        $arrayVariables = [];
+        foreach ($variables as $var) {
+            $arrayVariables[] = [
+                'value' => is_null($prefix) ? $var['VAR_NAME'] : $prefix . $var['VAR_NAME'],
+            ];
+        }
+
+        return $arrayVariables;
+    }
+
     /**
      * Verify field definition
      *

workflow/engine/src/ProcessMaker/Model/ProcessVariables.php

@@ -72,8 +72,21 @@ class ProcessVariables extends Model
      */
     public function scopeProcessId($query, int $proId)
     {
-        return $query->where('PRO_ID', $proId);
+        return $query->where('PROCESS_VARIABLES.PRO_ID', $proId);
     }
+
+    /**
+     * Scope a query to filter an specific type for variable
+     *
+     * @param  \Illuminate\Database\Eloquent\Builder $query
+     * @param  int $typeId
+     * @return \Illuminate\Database\Eloquent\Builder
+     */
+    public function scopeTypeId($query, int $typeId)
+    {
+        return $query->where('VAR_FIELD_TYPE_ID', $typeId);
+    }
+
     /**
      * Return the variables list
      *
@@ -96,4 +109,46 @@ class ProcessVariables extends Model
 
         return $variablesList;
     }
+
+    /**
+     * Return the variables list
+     *
+     * @param int $proId
+     * @param int $typeId
+     * @param int $start
+     * @param int $limit
+     * @param string $search
+     *
+     * @return array
+     */
+    public static function getVariablesByType(int $proId, int $typeId = 0, $start = null, $limit = null, $search = null)
+    {
+        $query = ProcessVariables::query()->select();
+        $query->leftJoin('DB_SOURCE', function ($join) {
+            $join->on('DB_SOURCE.PRO_ID', '=', 'PROCESS_VARIABLES.PRO_ID');
+        });
+        $query->processId($proId);
+        // Check if we need to filter the type of variables
+        if ($typeId > 0) {
+            $query->typeId($typeId);
+        }
+        // search a specific variable name
+        if (!empty($search)) {
+            $query->where('VAR_NAME', 'LIKE', "${search}%");
+        }
+        // orde by varNane
+        $query->orderBy('VAR_NAME', 'ASC');
+        // Check if we need to add a pagination
+        if(!is_null($start) && !is_null($limit)) {
+            $query->offset($start)->limit($limit);
+        }
+        // Get records
+        $results = $query->get();
+        $variablesList = [];
+        $results->each(function ($item, $key) use (&$variablesList) {
+            $variablesList[] = $item->toArray();
+        });
+
+        return $variablesList;
+    }
 }

workflow/engine/src/ProcessMaker/Services/Api/Project/Variable.php

@@ -1,8 +1,12 @@
 <?php
 namespace ProcessMaker\Services\Api\Project;
 
-use \ProcessMaker\Services\Api;
-use \Luracast\Restler\RestException;
+use Exception;
+use G;
+use ProcessMaker\BusinessModel\Variable as BmVariable;
+use ProcessMaker\Services\Api;
+use Luracast\Restler\RestException;
+
 /**
  * Project\Variable Api Controller
  *
@@ -28,6 +32,41 @@ class Variable extends Api
         }
     }
 
+    /**
+     * @url GET /:prj_uid/process-variables/:typeVariable/paged
+     *
+     * @param string $prj_uid {@min 32}{@max 32}
+     * @param string $typeVariable {@from path}
+     * @param int $start {@from path}
+     * @param int $limit {@from path}
+     * @param string $search {@from path}
+     */
+    public function doGetVariablesByType($prj_uid, $typeVariable, $start = null, $limit = null, $search = null)
+    {
+        try {
+            $variable = new BmVariable();
+            $typesAccepted = $variable::$varTypesValues;
+            if (!empty($typesAccepted[$typeVariable])) {
+                $typeVatId = $typesAccepted[$typeVariable];
+            } else {
+                throw new Exception(G::LoadTranslation("ID_INVALID_VALUE_ONLY_ACCEPTS_VALUES", ['$typeVariable', implode(',', $variable->getVariableTypes())]));
+            }
+            // Review if the word has the prefix
+            $count = preg_match_all('/\@(?:([\@\%\#\?\$\=\&Qq\!])|([a-zA-Z\_][\w\-\>\:]*)\(((?:[^\\\\\)]*(?:[\\\\][\w\W])?)*)\))((?:\s*\[[\'"]?\w+[\'"]?\])+|\-\>([a-zA-Z\_]\w*))?/', $search, $match, PREG_PATTERN_ORDER | PREG_OFFSET_CAPTURE);
+            // Check if the search has some prefix
+            $prefix = '';
+            if ($count) {
+                $prefix = substr($search,0,2);
+                $search = substr($search,2);
+            }
+            $response = $variable->getVariablesByType($prj_uid, $typeVatId, $start, $limit, $search, $prefix);
+
+            return $response;
+        } catch (Exception $e) {
+            throw (new RestException(Api::STAT_APP_EXCEPTION, $e->getMessage()));
+        }
+    }
+
     /**
      * @url GET /:prj_uid/process-variable/:var_uid
      *