luos/workflow/engine/classes/model/Process.php

<?php

class Process extends BaseProcess
{
    /**
     * This value goes in the content table
     *
     * @var string
     */
    protected $pro_title_content = '';
    public $dir = 'ASC';
    public $sort = 'PRO_TITLE';

    /**
     * Get the [Pro_title] column value.
     *
     * @return string
     */
    public function getProTitleContent()
    {
        if ($this->getProUid() == '') {
            throw (new Exception("Error in getProTitle, the PRO_UID can't be blank"));
        }
        $lang = defined('SYS_LANG') ? SYS_LANG : 'en';
        $this->pro_title_content = Content::load('PRO_TITLE', '', $this->getProUid(), $lang);
        return $this->pro_title_content;
    }

    /**
     * Set the [Pro_title] column value.
     *
     * @param string $v new value
     * @return void
     */
    public function setProTitleContent($v)
    {
        if ($this->getProUid() == '') {
            throw (new Exception("Error in setProTitle, the PRO_UID can't be blank" . print_r(debug_backtrace(), 1)));
        }
        // Since the native PHP type for this column is string,
        // we will cast the input to a string (if it is not).
        if ($v !== null && ! is_string($v)) {
            $v = (string) $v;
        }

        if (in_array(ProcessPeer::PRO_TITLE, $this->modifiedColumns) || $v === '') {
            $this->pro_title_content = $v;
            $lang = defined('SYS_LANG') ? SYS_LANG : 'en';

            $res = Content::addContent('PRO_TITLE', '', $this->getProUid(), $lang, $this->pro_title_content);
        }
    } // set()


    /**
     * This value goes in the content table
     *
     * @var string
     */
    protected $pro_description_content = '';

    /**
     * Get the [Pro_description] column value.
     *
     * @return string
     */
    public function getProDescriptionContent()
    {
        if ($this->getProUid() == '') {
            throw (new Exception("Error in getProDescription, the PRO_UID can't be blank"));
        }
        $lang = defined('SYS_LANG') ? SYS_LANG : 'en';
        $this->pro_description_content = Content::load('PRO_DESCRIPTION', '', $this->getProUid(), $lang);
        return $this->pro_description_content;
    }

    /**
     * Set the [Pro_description] column value.
     *
     * @param string $v new value
     * @return void
     */
    public function setProDescriptionContent($v)
    {
        if ($this->getProUid() == '') {
            throw (new Exception("Error in setProDescription, the PRO_UID can't be blank"));
        }
        // Since the native PHP type for this column is string,
        // we will cast the input to a string (if it is not).
        if ($v !== null && ! is_string($v)) {
            $v = (string) $v;
        }

        if (in_array(ProcessPeer::PRO_DESCRIPTION, $this->modifiedColumns) || $v === '') {
            $this->pro_description_content = $v;
            $lang = defined('SYS_LANG') ? SYS_LANG : 'en';

            $res = Content::addContent('PRO_DESCRIPTION', '', $this->getProUid(), $lang, $this->pro_description_content);
        }
    } // set()


    /**
     * Creates the Process
     *
     * @param array $aData Fields with :
     * $aData['PRO_UID'] the process id
     * $aData['USR_UID'] the userid
     * $aData['PRO_CATEGORY'] the id category
     * @return string
     */

    public function create($aData, $generateUid = true)
    {
        if (! isset($aData['USR_UID'])) {
            throw (new PropelException('The process cannot be created. The USR_UID is empty.'));
        }
        $con = Propel::getConnection(ProcessPeer::DATABASE_NAME);
        try {
            if ($generateUid) {
                do {
                    $sNewProUid = G::generateUniqueID();
                } while ($this->processExists($sNewProUid));
            } else {
                $sNewProUid = $aData['PRO_UID'];
                if (!empty($aData['PRO_ID'])) {
                    $this->setProId($aData['PRO_ID']);
                }
            }

            $this->setProUid($sNewProUid);
            $this->setProTitle((isset($aData['PRO_TITLE'])) ? $aData['PRO_TITLE'] : 'Default Process Title');
            $this->setProDescription((isset($aData['PRO_DESCRIPTION'])) ? $aData['PRO_DESCRIPTION'] : 'Default Process Description');
            $this->setProParent($sNewProUid);
            $this->setProTime(1);
            $this->setProTimeunit('DAYS');
            $this->setProStatus((isset($aData["PRO_STATUS"])) ? $aData["PRO_STATUS"] : 'ACTIVE');
            $this->setProTypeDay('');
            $this->setProType((isset($aData["PRO_TYPE"]))? $aData["PRO_TYPE"]: "NORMAL");
            $this->setProAssignment('FALSE');
            $this->setProShowMap('');
            $this->setProShowMessage('');
            $this->setProShowDelegate('');
            $this->setProShowDynaform('');
            $this->setProCategory((isset($aData["PRO_CATEGORY"]))? $aData["PRO_CATEGORY"]: "");
            $this->setCategoryId((isset($aData["CATEGORY_ID"])) ? $aData["CATEGORY_ID"]: 0);
            $this->setProSubCategory('');
            $this->setProIndustry('');
            $this->setProCreateDate(date("Y-m-d H:i:s"));
            $this->setProCreateUser($aData['USR_UID']);
            $this->setProHeight(5000);
            $this->setProWidth(10000);
            $this->setProTitleX(0);
            $this->setProTitleY(0);
            $this->setProItee(1);
            $this->setProDynaforms(isset($aData['PRO_DYNAFORMS']) ? (is_array($aData['PRO_DYNAFORMS']) ? serialize($aData['PRO_DYNAFORMS']) : $aData['PRO_DYNAFORMS']) : '');

            if ($this->validate()) {
                $con->begin();

                if (isset($aData['PRO_TITLE'])) {
                    $this->setProTitleContent($aData['PRO_TITLE']);
                } else {
                    $this->setProTitleContent('Default Process Title');
                }

                if (isset($aData['PRO_DESCRIPTION'])) {
                    $this->setProDescriptionContent($aData['PRO_DESCRIPTION']);
                } else {
                    $this->setProDescriptionContent('Default Process Description');
                }

                $res = $this->save();
                $con->commit();

                $this->memcachedDelete();

                return $this->getProUid();
            } else {
                $msg = '';
                foreach ($this->getValidationFailures() as $objValidationFailure) {
                    $msg .= $objValidationFailure->getMessage() . "<br/>";
                }
                throw (new PropelException('The row cannot be created!', new PropelException($msg)));
            }
        } catch (Exception $e) {
            $con->rollback();
            throw ($e);
        }
    }

    /**
     * verify if Process row specified in [pro_id] exists.
     *
     * @param string $sProUid the uid of the Prolication
     */
    public function processExists($ProUid)
    {
        $con = Propel::getConnection(ProcessPeer::DATABASE_NAME);
        try {
            $oPro = ProcessPeer::retrieveByPk($ProUid);
            if (is_object($oPro) && get_class($oPro) == 'Process') {
                return true;
            } else {
                return false;
            }
        } catch (Exception $oError) {
            throw ($oError);
        }
    }

    /**
     * Load the Process row specified in [pro_id] column value.
     *
     * @param string $ProUid the uid of the Prolication
     * @return array $Fields the fields
     */
    public function load($ProUid, $getAllLang = false)
    {
        $con = Propel::getConnection(ProcessPeer::DATABASE_NAME);
        try {
            $oPro = ProcessPeer::retrieveByPk($ProUid);
            if (is_object($oPro) && get_class($oPro) == 'Process') {
                $aFields = $oPro->toArray(BasePeer::TYPE_FIELDNAME);
                $this->fromArray($aFields, BasePeer::TYPE_FIELDNAME);
                //optimized to avoid double and multiple execution of the same query
                //        $aFields['PRO_TITLE']       = $oPro->getProTitle();
                //        $aFields['PRO_DESCRIPTION'] = $oPro->getProDescription();
                //        $this->pro_title = $aFields['PRO_TITLE'];
                //        $this->pro_description = $aFields['PRO_DESCRIPTION'];

                //the following code is to copy the parent in old process, when the parent was empty.
                if ($oPro->getProParent() == '') {
                    $oPro->setProParent($oPro->getProUid());
                    $oPro->save();
                }

                //Get category Name, by default No category
                $aFields['PRO_CATEGORY_LABEL'] = G::LoadTranslation("ID_PROCESS_NO_CATEGORY");
                if ($aFields['PRO_CATEGORY'] != "") {
                    $oProCat = ProcessCategoryPeer::retrieveByPk($aFields['PRO_CATEGORY']);
                    if (is_object($oProCat) && get_class($oProCat) == 'ProcessCategory') {
                        $aFields['PRO_CATEGORY_LABEL'] = $oProCat->getCategoryName();
                    }
                }

                $aFields['PRO_DYNAFORMS'] = @unserialize($aFields['PRO_DYNAFORMS']);
                //Check if is BPMN process
                $aFields['PRO_BPMN'] = $this->isBpmnProcess($ProUid);

                return $aFields;
            } else {
                throw (new Exception("The row '$ProUid' in table Process doesn't exist!"));
            }
        } catch (Exception $oError) {
            throw ($oError);
        }
    }

    public function getAll()
    {
        $oCriteria = new Criteria('workflow');

        $oCriteria->addSelectColumn(ProcessPeer::PRO_UID);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_TITLE);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_DESCRIPTION);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_PARENT);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_STATUS);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_CATEGORY);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_CREATE_DATE);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_CREATE_USER);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_DEBUG);

        $oCriteria->add(ProcessPeer::PRO_UID, '', Criteria::NOT_EQUAL);
        $oCriteria->add(ProcessPeer::PRO_STATUS, 'DISABLED', Criteria::NOT_EQUAL);

        //execute the query
        $oDataset = ProcessPeer::doSelectRS($oCriteria, Propel::getDbConnection('workflow_ro'));
        $oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
        $processes = array();
        $uids = array();
        while ($oDataset->next()) {
            $row = $oDataset->getRow();

            $processes[] = $row;
            $uids[] = $processes[sizeof($processes) - 1]['PRO_UID'];
        }

        $oConf = new Configurations();
        $oConf->loadConfig($obj, 'ENVIRONMENT_SETTINGS', '');

        if ($this->dir=='ASC') {
            usort($processes, array($this, "ordProcessAsc"));
        } else {
            usort($processes, array($this, "ordProcessDesc"));
        }

        return $processes;
    }

    /**
     * Update the Prolication row
     *
     * @param array $aData
     * @return variant
     *
     */
    public function update($aData)
    {
        if (isset($aData['PRO_DYNAFORMS']) && is_array($aData['PRO_DYNAFORMS'])) {
            $aData['PRO_DYNAFORMS'] = @serialize($aData['PRO_DYNAFORMS']);
        }

        $con = Propel::getConnection(ProcessPeer::DATABASE_NAME);
        try {
            $con->begin();
            $oPro = ProcessPeer::retrieveByPK($aData['PRO_UID']);
            if (is_object($oPro) && get_class($oPro) == 'Process') {
                $oPro->fromArray($aData, BasePeer::TYPE_FIELDNAME);
                if ($oPro->validate()) {
                    if (isset($aData['PRO_TITLE'])) {
                        $oPro->setProTitleContent($aData['PRO_TITLE']);
                    }
                    if (isset($aData['PRO_DESCRIPTION'])) {
                        $oPro->setProDescriptionContent($aData['PRO_DESCRIPTION']);
                    }
                    if (isset($aData['PRO_PROCESS_OWNER'])) {
                        $oPro->setProCreateUser($aData['PRO_PROCESS_OWNER']);
                    }
                    $res = $oPro->save();
                    $con->commit();

                    $this->memcachedDelete();

                    return $res;
                } else {
                    $msg = '';
                    foreach ($oPro->getValidationFailures() as $objValidationFailure) {
                        $msg .= $objValidationFailure->getMessage() . "<br/>";
                    }

                    throw (new Exception('The row cannot be updated!' . $msg));
                }
            } else {
                $con->rollback();
                throw (new Exception("The row '" . $aData['PRO_UID'] . "' in table Process doesn't exist!"));
            }
        } catch (Exception $oError) {
            throw ($oError);
        }
    }

    /**
     * creates an Application row
     *
     * @param array $aData
     * @return variant
     *
     */
    public function createRow($aData)
    {
        $con = Propel::getConnection(ProcessPeer::DATABASE_NAME);
        //$con->begin(); //does not allow dual BEGIN
        $this->setProUid($aData['PRO_UID']);
        $this->setProTitle((isset($aData['PRO_TITLE'])) ? $aData['PRO_TITLE'] : 'Default Process Title');
        $this->setProDescription((isset($aData['PRO_DESCRIPTION'])) ? $aData['PRO_DESCRIPTION'] : 'Default Process Description');
        $this->setProParent($aData['PRO_PARENT']);
        $this->setProTime($aData['PRO_TIME']);
        $this->setProTimeunit($aData['PRO_TIMEUNIT']);
        $this->setProStatus($aData['PRO_STATUS']);
        $this->setProTypeDay($aData['PRO_TYPE_DAY']);
        $this->setProType($aData['PRO_TYPE']);
        $this->setProAssignment($aData['PRO_ASSIGNMENT']);
        $this->setProShowMap($aData['PRO_SHOW_MAP']);
        $this->setProShowMessage($aData['PRO_SHOW_MESSAGE']);
        $this->setProSubprocess(isset($aData['PRO_SUBPROCESS']) ? $aData['PRO_SUBPROCESS'] : '');
        $this->setProTriDeleted(isset($aData['PRO_TRI_DELETED']) ? $aData['PRO_TRI_DELETED'] : '');
        $this->setProTriCanceled(isset($aData['PRO_TRI_CANCELED']) ? $aData['PRO_TRI_CANCELED'] : '');
        $this->setProTriPaused(isset($aData['PRO_TRI_PAUSED']) ? $aData['PRO_TRI_PAUSED'] : '');
        $this->setProTriReassigned(isset($aData['PRO_TRI_REASSIGNED']) ? $aData['PRO_TRI_REASSIGNED'] : '');
        $this->setProTriUnpaused(isset($aData['PRO_TRI_UNPAUSED']) ? $aData['PRO_TRI_UNPAUSED'] : '');
        $this->setProShowDelegate($aData['PRO_SHOW_DELEGATE']);
        $this->setProShowDynaform($aData['PRO_SHOW_DYNAFORM']);
        $this->setProDerivationScreenTpl(isset($aData['PRO_DERIVATION_SCREEN_TPL']) ? $aData['PRO_DERIVATION_SCREEN_TPL'] : '');

        // validate if the category exists
        $criteria = new Criteria('workflow');
        $criteria->add(ProcessCategoryPeer::CATEGORY_UID, $aData['PRO_CATEGORY']);
        $ds = ProcessCategoryPeer::doSelectRS($criteria, Propel::getDbConnection('workflow_ro'));
        $ds->setFetchmode(ResultSet::FETCHMODE_ASSOC);
        $ds->next();
        // if it is not set, set value as empty "No Category"
        if (! $ds->getRow()) {
            $aData['PRO_CATEGORY'] = '';
        }

        $this->setProCategory($aData['PRO_CATEGORY']);
        $this->setProSubCategory($aData['PRO_SUB_CATEGORY']);
        $this->setProIndustry($aData['PRO_INDUSTRY']);
        $this->setProCreateDate($aData['PRO_CREATE_DATE']);
        $this->setProCreateUser($aData['PRO_CREATE_USER']);
        $this->setProHeight($aData['PRO_HEIGHT']);
        $this->setProWidth($aData['PRO_WIDTH']);
        $this->setProTitleX($aData['PRO_TITLE_X']);
        $this->setProTitleY($aData['PRO_TITLE_Y']);
        $this->setProDynaforms(isset($aData['PRO_DYNAFORMS']) ? (is_array($aData['PRO_DYNAFORMS']) ? serialize($aData['PRO_DYNAFORMS']) : $aData['PRO_DYNAFORMS']) : '');
        if ($this->validate()) {
            $con->begin();

            if (isset($aData['PRO_TITLE']) && trim($aData['PRO_TITLE']) != '') {
                $this->setProTitleContent($aData['PRO_TITLE']);
            } else {
                $this->setProTitleContent('Default Process Title');
            }
            if (isset($aData['PRO_DESCRIPTION'])) {
                $this->setProDescriptionContent($aData['PRO_DESCRIPTION']);
            } else {
                $this->setProDescriptionContent('Default Process Description');
            }

            $res = $this->save();
            $con->commit();

            $this->memcachedDelete();

            return $this->getProUid();
        } else {
            $msg = '';
            foreach ($this->getValidationFailures() as $objValidationFailure) {
                $msg .= $objValidationFailure->getMessage() . "<br/>";
            }

            throw (new PropelException('The row cannot be created!', new PropelException($msg)));
        }
    }

    /**
     * Remove the Prolication document registry
     *
     * @param array $aData or string $ProUid
     * @return string
     *
     */
    public function remove($ProUid)
    {
        if (is_array($ProUid)) {
            $ProUid = (isset($ProUid['PRO_UID']) ? $ProUid['PRO_UID'] : '');
        }
        try {
            $oPro = ProcessPeer::retrieveByPK($ProUid);
            if (! is_null($oPro)) {
                Content::removeContent('PRO_TITLE', '', $oPro->getProUid());
                Content::removeContent('PRO_DESCRIPTION', '', $oPro->getProUid());
                $this->memcachedDelete();
                return $oPro->delete();
            } else {
                throw (new Exception("The row '$ProUid' in table Process doesn't exist!"));
            }
        } catch (Exception $oError) {
            throw ($oError);
        }
    }

    public function exists($ProUid)
    {
        $oPro = ProcessPeer::retrieveByPk($ProUid);
        return (is_object($oPro) && get_class($oPro) == 'Process');
    }

    /**
     * @param $proTitle
     * @return bool
     * @throws PropelException
     */
    public static function existsByProTitle($proTitle)
    {
        $oCriteria = new Criteria("workflow");
        $oCriteria->addSelectColumn(ProcessPeer::PRO_TITLE);
        $oCriteria->add(ProcessPeer::PRO_TITLE, $proTitle);
        $oDataset = ProcessPeer::doSelectRS($oCriteria, Propel::getDbConnection('workflow_ro'));
        $oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
        $oDataset->next();
        $aRow = $oDataset->getRow();
        return ($aRow) ? true : false;
    }

    public static function getByProTitle($proTitle)
    {
        $oCriteria = new Criteria("workflow");
        $oCriteria->add(ProcessPeer::PRO_TITLE, $proTitle);
        $oDataset = ProcessPeer::doSelectRS($oCriteria, Propel::getDbConnection('workflow_ro'));
        $oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
        $oDataset->next();
        $aRow = $oDataset->getRow();
        return isset($aRow) ? $aRow : null;
    }

    public static function getNextTitle($proTitle)
    {
        $oCriteria = new Criteria('workflow');
        $oCriteria->addSelectColumn(ProcessPeer::PRO_TITLE);
        $oCriteria->add(ProcessPeer::PRO_TITLE, $proTitle . '-%', Criteria::LIKE);
        $oCriteria->addAscendingOrderByColumn(ProcessPeer::PRO_TITLE);
        $oDataset = ProcessPeer::doSelectRS($oCriteria, Propel::getDbConnection('workflow_ro'));
        $oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
        $data = array();
        $may = 0;
        while ($oDataset->next()) {
            $row = $oDataset->getRow();
            $number = explode("-", $row["PRO_TITLE"]);
            $number = $number[count($number) - 1] + 0;
            if ($number > $may) {
                $may = $number;
            }
            $row["PRO_TITLE"] = $number;
            $data[] = $row;
        }
        return $proTitle . "-" . ($may + 1);
    }

    public function getAllProcessesCount()
    {
        $c = $this->tmpCriteria;
        $c->clearSelectColumns();
        $c->addSelectColumn('COUNT(*)');
        $oDataset = ProcessPeer::doSelectRS($c, Propel::getDbConnection('workflow_ro'));
        $oDataset->next();
        $aRow = $oDataset->getRow();

        if (is_array($aRow)) {
            return $aRow[0];
        } else {
            return 0;
        }
    }

    public function getAllProcesses($start, $limit, $category = null, $processName = null, $counters = true, $reviewSubProcess = false, $userLogged = "")
    {
        require_once PATH_RBAC . "model/RbacUsers.php";
        require_once "classes/model/ProcessCategory.php";
        require_once "classes/model/Users.php";

        $user = new RbacUsers();
        $aProcesses = array();
        $categories = array();
        $oCriteria = new Criteria('workflow');

        $oCriteria->addSelectColumn(ProcessPeer::PRO_UID);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_TITLE);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_DESCRIPTION);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_PARENT);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_STATUS);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_TYPE);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_CATEGORY);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_UPDATE_DATE);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_CREATE_DATE);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_CREATE_USER);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_DEBUG);
        $oCriteria->addSelectColumn(ProcessPeer::PRO_TYPE_PROCESS);

        $oCriteria->addSelectColumn(UsersPeer::USR_UID);
        $oCriteria->addSelectColumn(UsersPeer::USR_USERNAME);
        $oCriteria->addSelectColumn(UsersPeer::USR_FIRSTNAME);
        $oCriteria->addSelectColumn(UsersPeer::USR_LASTNAME);

        $oCriteria->addSelectColumn(ProcessCategoryPeer::CATEGORY_UID);
        $oCriteria->addSelectColumn(ProcessCategoryPeer::CATEGORY_NAME);

        $oCriteria->add(ProcessPeer::PRO_UID, '', Criteria::NOT_EQUAL);
        $oCriteria->add(ProcessPeer::PRO_STATUS, 'DISABLED', Criteria::NOT_EQUAL);
        if ($reviewSubProcess) {
            $oCriteria->add(ProcessPeer::PRO_SUBPROCESS, '1', Criteria::NOT_EQUAL);
        }

        if (isset($category)) {
            $oCriteria->add(ProcessPeer::PRO_CATEGORY, $category, Criteria::EQUAL);
        }

        $oCriteria->addJoin(ProcessPeer::PRO_CREATE_USER, UsersPeer::USR_UID, Criteria::LEFT_JOIN);
        $oCriteria->addJoin(ProcessPeer::PRO_CATEGORY, ProcessCategoryPeer::CATEGORY_UID, Criteria::LEFT_JOIN);

        if ($this->sort == "PRO_CREATE_DATE") {
            if ($this->dir == "DESC") {
                $oCriteria->addDescendingOrderByColumn(ProcessPeer::PRO_CREATE_DATE);
            } else {
                $oCriteria->addAscendingOrderByColumn(ProcessPeer::PRO_CREATE_DATE);
            }
        }

        if ($userLogged != "") {
            $oCriteria->add(
                $oCriteria->getNewCriterion(ProcessPeer::PRO_TYPE_PROCESS, "PUBLIC", Criteria::EQUAL)->addOr(
                $oCriteria->getNewCriterion(ProcessPeer::PRO_CREATE_USER, $userLogged, Criteria::EQUAL)
                )
            );
        }

        $this->tmpCriteria = clone $oCriteria;

        //execute a query to obtain numbers, how many cases there are by process
        if ($counters) {
            $casesCnt = $this->getCasesCountInAllProcesses();
        }

        // getting bpmn projects
        $c = new Criteria('workflow');
        $c->addSelectColumn(BpmnProjectPeer::PRJ_UID);
        $ds = ProcessPeer::doSelectRS($c, Propel::getDbConnection('workflow_ro'));
        $ds->setFetchmode(ResultSet::FETCHMODE_ASSOC);
        $bpmnProjects = array();

        while ($ds->next()) {
            $row = $ds->getRow();
            $bpmnProjects[] = $row['PRJ_UID'];
        }

        //execute the query
        $oDataset = ProcessPeer::doSelectRS($oCriteria);
        $oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
        $processes = array();
        $uids = array();
        while ($oDataset->next()) {
            $row = $oDataset->getRow();

            $row["PROJECT_TYPE"] = ($row["PRO_TYPE"] == "NORMAL")? ((in_array($row["PRO_UID"], $bpmnProjects))? "bpmn" : "classic") : $row["PRO_TYPE"];

            $processes[] = $row;
            $uids[] = $processes[sizeof($processes) - 1]['PRO_UID'];
        }

        $oConf = new Configurations();
        $oConf->loadConfig($obj, 'ENVIRONMENT_SETTINGS', '');

        foreach ($processes as $process) {
            $proTitle = isset($process['PRO_TITLE'])? $process['PRO_TITLE'] : '';
            $proDescription = isset($process['PRO_DESCRIPTION']) ? htmlspecialchars($process['PRO_DESCRIPTION']) : '';
            $process["PRO_TYPE_PROCESS"] = ($process["PRO_TYPE_PROCESS"] == "PUBLIC") ? G::LoadTranslation("ID_PUBLIC") : G::LoadTranslation("ID_PRIVATE");
            // verify if the title is already set on the current language
            if (trim($proTitle) == '') {
                // if not, then load the record to generate content for current language
                $proData = $this->load($process['PRO_UID']);
                $proTitle = $proData['PRO_TITLE'];
                $proDescription = htmlspecialchars($proData['PRO_DESCRIPTION']);
            }

            //filtering by $processName
            if (isset($processName) && $processName != '' && stripos($proTitle, $processName) === false) {
                continue;
            }

            if ($counters) {
                $casesCountTotal = 0;
                if (isset($casesCnt[$process['PRO_UID']])) {
                    foreach ($casesCnt[$process['PRO_UID']] as $item) {
                        $casesCountTotal += $item;
                    }
                }
            }

            //get user format from configuration
            $userOwner = isset($oConf->aConfig['format']) ? $oConf->aConfig['format'] : '';
            $creationDateMask = isset($oConf->aConfig['dateFormat']) ? $oConf->aConfig['dateFormat'] : '';
            if ($userOwner != '') {
                $userOwner = str_replace('@userName', $process['USR_USERNAME'], $userOwner);
                $userOwner = str_replace('@firstName', $process['USR_FIRSTNAME'], $userOwner);
                $userOwner = str_replace('@lastName', $process['USR_LASTNAME'], $userOwner);
                if ($userOwner == " ( )") {
                    $userOwner = '-';
                }
            } else {
                $userOwner = $process['USR_FIRSTNAME'] . ' ' . $process['USR_LASTNAME'];
            }

            //get date format from configuration
            if ($creationDateMask != '') {
                list($date, $time) = explode(' ', $process['PRO_CREATE_DATE']);
                list($y, $m, $d) = explode('-', $date);
                list($h, $i, $s) = explode(':', $time);

                $process['PRO_CREATE_DATE'] = date($creationDateMask, mktime($h, $i, $s, $m, $d, $y));
            }

            $process['PRO_CATEGORY_LABEL'] = trim($process['PRO_CATEGORY']) != '' ? $process['CATEGORY_NAME'] : '- ' . G::LoadTranslation('ID_PROCESS_NO_CATEGORY') . ' -';
            $process['PRO_TITLE'] = $proTitle;
            $process['PRO_DESCRIPTION'] = $proDescription;
            $process['PRO_DEBUG'] = $process['PRO_DEBUG'];
            $process['PRO_DEBUG_LABEL'] = ($process['PRO_DEBUG'] == "1") ? G::LoadTranslation('ID_ON') : G::LoadTranslation('ID_OFF');
            $process['PRO_STATUS_LABEL'] = $process['PRO_STATUS'] == 'ACTIVE' ? G::LoadTranslation('ID_ACTIVE') : G::LoadTranslation('ID_INACTIVE');
            $process['PRO_CREATE_USER_LABEL'] = $userOwner;
            if ($counters) {
                $process['CASES_COUNT_TO_DO'] = (isset($casesCnt[$process['PRO_UID']]['TO_DO']) ? $casesCnt[$process['PRO_UID']]['TO_DO'] : 0);
                $process['CASES_COUNT_COMPLETED'] = (isset($casesCnt[$process['PRO_UID']]['COMPLETED']) ? $casesCnt[$process['PRO_UID']]['COMPLETED'] : 0);
                $process['CASES_COUNT_DRAFT'] = (isset($casesCnt[$process['PRO_UID']]['DRAFT']) ? $casesCnt[$process['PRO_UID']]['DRAFT'] : 0);
                $process['CASES_COUNT_CANCELLED'] = (isset($casesCnt[$process['PRO_UID']]['CANCELLED']) ? $casesCnt[$process['PRO_UID']]['CANCELLED'] : 0);
                $process['CASES_COUNT'] = $casesCountTotal;
            }

            unset($process['PRO_CREATE_USER']);

            $aProcesses[] = $process;
        }

        $memcache = PMmemcached::getSingleton(config("system.workspace"));
        if (isset($memcache) && $memcache->enabled == 1) {
            return $aProcesses;
        }

        if ($limit == '') {
            $limit = count($aProcesses);
        }

        if ($this->sort != "PRO_CREATE_DATE") {
            if ($this->dir == "ASC") {
                usort($aProcesses, array($this, "ordProcessAsc"));
            } else {
                usort($aProcesses, array($this, "ordProcessDesc"));
            }
        }

        return $aProcesses;
    }

    public function getCasesCountInAllProcesses()
    {
        /*SELECT PRO_UID, APP_STATUS, COUNT( * )
          FROM APPLICATION
          GROUP BY PRO_UID, APP_STATUS*/
        require_once 'classes/model/Application.php';

        $memcache = PMmemcached::getSingleton( config("system.workspace") );
        $memkey = 'getCasesCountInAllProcesses';
        if (($aProcesses = $memcache->get($memkey)) === false) {
            $oCriteria = new Criteria('workflow');
            $oCriteria->addSelectColumn(ApplicationPeer::PRO_UID);
            $oCriteria->addSelectColumn(ApplicationPeer::APP_STATUS);
            $oCriteria->addSelectColumn('COUNT(*) AS CNT');
            $oCriteria->addGroupByColumn(ApplicationPeer::PRO_UID);
            $oCriteria->addGroupByColumn(ApplicationPeer::APP_STATUS);

            $oDataset = ProcessPeer::doSelectRS($oCriteria, Propel::getDbConnection('workflow_ro'));
            $oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);

            $aProcesses = array();
            while ($oDataset->next()) {
                $row = $oDataset->getRow();
                $aProcesses[$row['PRO_UID']][$row['APP_STATUS']] = $row['CNT'];
            }
            $memcache->set($memkey, $aProcesses, PMmemcached::ONE_HOUR);
        }
        return $aProcesses;
    }

    /**
     * This returns the number of cases for the process.
     * @param string $pro_uid
     * @return integer
     * @see ProcessMaker\Project\Bpmn::canRemove()
     */
    public static function getCasesCountForProcess($pro_uid)
    {
        $oCriteria = new Criteria('workflow');
        $oCriteria->addSelectColumn('COUNT(*) AS TOTAL_CASES');
        $oCriteria->add(ApplicationPeer::PRO_UID, $pro_uid);
        $oDataset = ApplicationPeer::doSelectRS($oCriteria, Propel::getDbConnection('workflow_ro'));
        $oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);

        $oDataset->next();
        $cases = $oDataset->getRow();
        return (int)$cases['TOTAL_CASES'];
    }

    public function getAllProcessesByCategory()
    {
        $oCriteria = new Criteria('workflow');
        $oCriteria->addSelectColumn(ProcessPeer::PRO_CATEGORY);
        $oCriteria->addSelectColumn('COUNT(*) AS CNT');
        $oCriteria->addGroupByColumn(ProcessPeer::PRO_CATEGORY);
        $oDataSet = ProcessPeer::doSelectRS($oCriteria, Propel::getDbConnection('workflow_ro'));
        $oDataSet->setFetchmode(ResultSet::FETCHMODE_ASSOC);
        $aProc = array();
        while ($oDataSet->next()) {
            $row = $oDataSet->getRow();
            $aProc[$row['PRO_CATEGORY']] = $row['CNT'];
        }
        return $aProc;
    }

    /**
     * Get the trigger configured in committing an action in cases
     *
     * @param string $proUid
     * @param string $action
     *
     * @return mixed
     *
     * @see Cases::getExecuteTriggerProcess()
     * @link https://wiki.processmaker.com/3.2/Triggers#When_action_cases
    */
    public function getTriggerWebBotProcess($proUid, $action)
    {
        require_once("classes/model/Triggers.php");

        if (empty($proUid) || empty($action)){
            return false;
        }

        $action = G::toUpper($action);
        $arrayWebBotTrigger = [];

        switch ($action) {
            case 'CREATE':
                $columnName = ProcessPeer::PRO_TRI_CREATE;
                break;
            case 'OPEN':
                $columnName = ProcessPeer::PRO_TRI_OPEN;
                break;
            case 'DELETED':
                $columnName = ProcessPeer::PRO_TRI_DELETED;
                break;
            case 'CANCELED':
                $columnName = ProcessPeer::PRO_TRI_CANCELED;
                break;
            case 'PAUSED':
                $columnName = ProcessPeer::PRO_TRI_PAUSED;
                break;
            case 'REASSIGNED':
                $columnName = ProcessPeer::PRO_TRI_REASSIGNED;
                break;
            case "UNPAUSE":
                $columnName = ProcessPeer::PRO_TRI_UNPAUSED;
                break;
        }

        $criteria = new Criteria('workflow');
        $criteria->addSelectColumn($columnName);
        $criteria->addSelectColumn(TriggersPeer::TRI_UID);
        $criteria->addSelectColumn(TriggersPeer::TRI_WEBBOT);
        $criteria->addSelectColumn(TriggersPeer::TRI_TITLE);
        $criteria->addJoin($columnName, TriggersPeer::TRI_UID, Criteria::LEFT_JOIN);
        $criteria->add(ProcessPeer::PRO_UID, $proUid);
        $criteria->add($columnName, '', Criteria::NOT_EQUAL);
        $dataSet = ProcessPeer::doSelectRS($criteria, Propel::getDbConnection('workflow_ro'));
        $dataSet->setFetchmode(ResultSet::FETCHMODE_ASSOC);

        if ($dataSet->next()) {
            $arrayWebBotTrigger[] = $dataSet->getRow();
        }

        //Return
        return $arrayWebBotTrigger;
    }

    public function memcachedDelete()
    {
        //Limit defined in processmaker/workflow/engine/templates/processes/main.js
        $limit = 25;
        $start = 0;

        $memcache = PMmemcached::getSingleton( config("system.workspace") );

        for ($start = 0; $start <= 50 - 1; $start ++) {
            $memkey = "processList-allProcesses-" . ($start * $limit) . "-" . $limit;
            $memkeyTotal = $memkey . "-total";

            $r = $memcache->delete($memkey);
            $r = $memcache->delete($memkeyTotal);
        }
    }

    public function orderMemcache($dataMemcache, $start, $limit)
    {
        if ($this->dir=='ASC') {
            usort($dataMemcache, array($this, "ordProcessAsc"));
        } else {
            usort($dataMemcache, array($this, "ordProcessDesc"));
        }
        $response = new stdclass();
        $response->totalCount = count($dataMemcache);
        $dataMemcache = array_splice($dataMemcache, $start, $limit);
        $response->dataMemcache = $dataMemcache;
        return $response;
    }

    public function ordProcessAsc($a, $b)
    {
        if (($this->sort) == '') {
            $this->sort = 'PRO_TITLE';
        }
        if (strtolower($a[$this->sort]) > strtolower($b[$this->sort])) {
            return 1;
        } elseif (strtolower($a[$this->sort]) < strtolower($b[$this->sort])) {
            return - 1;
        } else {
            return 0;
        }
    }

    public function ordProcessDesc($a, $b)
    {
        if (($this->sort) == '') {
            $this->sort = 'PRO_TITLE';
        }
        if (strtolower($a[$this->sort]) > strtolower($b[$this->sort])) {
            return - 1;
        } elseif (strtolower($a[$this->sort]) < strtolower($b[$this->sort])) {
            return 1;
        } else {
            return 0;
        }
    }
    /**
     * Check is the Process is BPMN.
     *
     * @param string $ProUid the uid of the Prolication
     * @return int 1 if is BPMN process or 0 if a Normal process
    */
    public function isBpmnProcess($proUid)
    {
        $c = new Criteria("workflow");
        $c->add(BpmnProcessPeer::PRJ_UID, $proUid);
        $res = BpmnProcessPeer::doSelect($c);
        if (sizeof($res) == 0) {
            return 0;
        } else {
            return 1;
        }
    }

    public function getAllConfiguredCurrencies()
    {
        $oCriteria = new Criteria('workflow');
        $oCriteria->addSelectColumn(ProcessPeer::PRO_UNIT_COST);
        $oCriteria->setDistinct();
        $oDataSet = ProcessPeer::doSelectRS($oCriteria, Propel::getDbConnection('workflow_ro'));
        $oDataSet->setFetchmode(ResultSet::FETCHMODE_ASSOC);
        $aProc = array();
        while ($oDataSet->next()) {
            $row = $oDataSet->getRow();
            $aProc[$row['PRO_UNIT_COST']] = $row['PRO_UNIT_COST'];
        }
        return $aProc;
    }

    /**
     * Delete all cases from a process
     *
     * @param string $proUid
     * @throws Exception
     *
     * @see workflow/engine/methods/processes/processes_DeleteCases.php
     * @link https://wiki.processmaker.com/3.2/Processes#Deleting_all_Cases_of_a_Process
     */
    public function deleteProcessCases($proUid)
    {
        try {
            // Initialize variables
            $casesInstance = new Cases();

            // Get all cases from th process
            $criteria = new Criteria('workflow');
            $criteria->addSelectColumn(ApplicationPeer::APP_UID);
            $criteria->add(ApplicationPeer::PRO_UID, $proUid);
            $dataSet = ApplicationPeer::doSelectRS($criteria, Propel::getDbConnection('workflow_ro'));
            $dataSet->setFetchmode(ResultSet::FETCHMODE_ASSOC);
            while ($dataSet->next()) {
                $row = $dataSet->getRow();
                // Delete/Remove the case
                $casesInstance->removeCase($row['APP_UID']);
            }
        } catch (Exception $e) {
            throw ($e);
        }
    }

    /**
     * Load a process object by PRO_ID
     *
     * @param type $id
     * @return Process
     */
    public static function loadById($id)
    {
        $criteria = new Criteria(ProcessPeer::DATABASE_NAME);
        $criteria->add(ProcessPeer::PRO_ID, $id);
        return ProcessPeer::doSelect($criteria)[0];
    }
}