luos/workflow/engine/classes/ReportTables.php

<?php

use App\Jobs\GenerateReportTable;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use ProcessMaker\Core\JobsManager;
use ProcessMaker\Core\System;
use ProcessMaker\Model\Application;

/**
 * Report Tables
 */
class ReportTables
{
    private $aDef = array(
        'mysql' => array(
            'number' => 'DOUBLE',
            'char' => 'VARCHAR(255)',
            'text' => 'TEXT',
            'date' => 'DATETIME'
        ),
        'pgsql' => array(
            'number' => 'DOUBLE',
            'char' => 'VARCHAR(255)',
            'text' => 'TEXT',
            'date' => 'DATETIME'
        ),
        'mssql' => array(
            'number' => 'FLOAT',
            'char' => 'NVARCHAR(255)',
            'text' => 'TEXT',
            'date' => 'CHAR(19)'
        ) /* Changed DATETIME CHAR(19) for compatibility issues. */
    );
    private $sPrefix = '';

    /**
     * Function deleteAllReportVars
     * This function delete all reports
     *
     * @access public
     *
     * @param string $sRepTabUid
     *
     * @return void
     */
    public function deleteAllReportVars($sRepTabUid = '')
    {
        try {
            $oCriteria = new Criteria('workflow');
            $oCriteria->add(ReportVarPeer::REP_TAB_UID, $sRepTabUid);
            ReportVarPeer::doDelete($oCriteria);
        } catch (Exception $oError) {
            throw ($oError);
        }
    }

    /**
     * Function prepareQuery
     * This function removes the table
     *
     * @access public
     *
     * @param string $sTableName Table name
     * @param string $sConnection Conexion
     *
     * @return void
     */
    public function dropTable($sTableName, $sConnection = 'report')
    {
        $sTableName = $this->sPrefix . $sTableName;
        //we have to do the propel connection
        $PropelDatabase = $this->chooseDB($sConnection);
        $con = Propel::getConnection($PropelDatabase);
        $stmt = $con->createStatement();
        try {
            switch (DB_ADAPTER) {
                case 'mysql':
                    $rs = $stmt->executeQuery('DROP TABLE IF EXISTS `' . $sTableName . '`');
                    break;
                case 'mssql':
                    $rs = $stmt->executeQuery("IF OBJECT_ID (N'" . $sTableName . "', N'U') IS NOT NULL
                        DROP TABLE [" . $sTableName . "]");
                    break;
            }
        } catch (Exception $oError) {
            throw ($oError);
        }
    }

    /**
     * Function createTable
     * This Function creates the table
     *
     * @access public
     *
     * @param string $sTableName Table name
     * @param string $sConnection Connection name
     * @param string $sType
     * @param array $aFields
     * @param string $bDefaultFields
     *
     * @return void
     */
    public function createTable(
        $sTableName,
        $sConnection = 'report',
        $sType = 'NORMAL',
        $aFields = array(),
        $bDefaultFields = true
    )
    {
        $sTableName = $this->sPrefix . $sTableName;
        //we have to do the propel connection
        $PropelDatabase = $this->chooseDB($sConnection);
        $con = Propel::getConnection($PropelDatabase);
        $stmt = $con->createStatement();
        try {
            switch (DB_ADAPTER) {
                case 'mysql':
                    $sQuery = 'CREATE TABLE IF NOT EXISTS `' . $sTableName . '` (';
                    if ($bDefaultFields) {
                        $sQuery .= "`APP_UID` VARCHAR(32) NOT NULL DEFAULT '',`APP_NUMBER` INT NOT NULL,";
                        if ($sType == 'GRID') {
                            $sQuery .= "`ROW` INT NOT NULL,";
                        }
                    }
                    foreach ($aFields as $aField) {
                        switch ($aField['sType']) {
                            case 'number':
                                $sQuery .= '`' . $aField['sFieldName'] . '` ' . $this->aDef['mysql'][$aField['sType']] . " NOT NULL DEFAULT '0',";
                                break;
                            case 'char':
                                $sQuery .= '`' . $aField['sFieldName'] . '` ' . $this->aDef['mysql'][$aField['sType']] . " NOT NULL DEFAULT '',";
                                break;
                            case 'text':
                                $sQuery .= '`' . $aField['sFieldName'] . '` ' . $this->aDef['mysql'][$aField['sType']] . " ,";
                                break;
                            case 'date':
                                $sQuery .= '`' . $aField['sFieldName'] . '` ' . $this->aDef['mysql'][$aField['sType']] . " NULL,";
                                break;
                        }
                    }
                    if ($bDefaultFields) {
                        $sQuery .= 'PRIMARY KEY (APP_UID' . ($sType === 'GRID' ? ',ROW' : '') . ')) ';
                    }
                    $sQuery .= ' DEFAULT CHARSET=utf8;';
                    $rs = $stmt->executeQuery($sQuery);
                    break;
                case 'mssql':
                    $sQuery = 'CREATE TABLE [' . $sTableName . '] (';
                    if ($bDefaultFields) {
                        $sQuery .= "[APP_UID] VARCHAR(32) NOT NULL DEFAULT '', [APP_NUMBER] INT NOT NULL,";
                        if ($sType == 'GRID') {
                            $sQuery .= "[ROW] INT NOT NULL,";
                        }
                    }
                    foreach ($aFields as $aField) {
                        switch ($aField['sType']) {
                            case 'number':
                                $sQuery .= '[' . $aField['sFieldName'] . '] ' . $this->aDef['mssql'][$aField['sType']] . " NOT NULL DEFAULT '0',";
                                break;
                            case 'char':
                                $sQuery .= '[' . $aField['sFieldName'] . '] ' . $this->aDef['mssql'][$aField['sType']] . " NOT NULL DEFAULT '',";
                                break;
                            case 'text':
                                $sQuery .= '[' . $aField['sFieldName'] . '] ' . $this->aDef['mssql'][$aField['sType']] . " NOT NULL DEFAULT '',";
                                break;
                            case 'date':
                                $sQuery .= '[' . $aField['sFieldName'] . '] ' . $this->aDef['mssql'][$aField['sType']] . " NULL,";
                                break;
                        }
                    }
                    if ($bDefaultFields) {
                        $sQuery .= 'PRIMARY KEY (APP_UID' . ($sType == 'GRID' ? ',ROW' : '') . ')) ';
                    } else {
                        $sQuery .= ' ';
                    }

                    $rs = $stmt->executeQuery($sQuery);
                    break;

            }
        } catch (Exception $oError) {
            throw ($oError);
        }
    }

    /**
     * Function populateTable
     * This Function fills the table
     *
     * @access public
     * @param string $tableName Table name
     * @param string $connectionShortName Connection name
     * @param string $type
     * @param array $fields
     * @param string $proUid
     * @param string $grid
     * @see ConsolidatedCases->processConsolidated()
     * @see Processes->createReportTables()
     * @see workflow/engine/methods/cases/caseConsolidated.php
     * @see workflow/engine/methods/processes/consolidated.php ajax_con->con_save_properties()
     * @see workflow/engine/methods/reportTables/reportTables_Save.php
     * @link https://wiki.processmaker.com/3.0/Report_Tables
     * @return void
     */
    public function populateTable($tableName, $connectionShortName = 'report', $type = 'NORMAL', $fields = [], $proUid = '', $grid = '')
    {
        try {
            // Initializing variables
            $tableName = $this->sPrefix . $tableName;
            if ($type == 'GRID') {
                $aux = explode('-', $grid);
                $grid = $aux[0];
            }
            $n = Application::count();

            // Truncate report table
            DB::delete("TRUNCATE TABLE `{$tableName}` ");

            // Batch process
            $config = System::getSystemConfiguration();
            $reportTableBatchRegeneration = $config['report_table_batch_regeneration'];

            // Initializing more variables
            $size = $n;
            $start = 0;
            $limit = $reportTableBatchRegeneration;

            // Creating jobs
            for ($i = 1; $start < $size; $i++) {
                $closure = function () use ($tableName, $connectionShortName, $type, $fields, $proUid, $grid, $start, $limit) {
                    $this->generateOldReportTable($tableName, $connectionShortName, $type, $fields, $proUid, $grid, $start, $limit);
                };
                JobsManager::getSingleton()->dispatch(GenerateReportTable::class, $closure);
                $start = $i * $limit;
            }
        } catch (Exception $oError) {
            throw ($oError);
        }
    }

    /**
     * Generate old report table of application.
     * 
     * @param string $tableName
     * @param string $connectionShortName
     * @param string $type
     * @param array $fields
     * @param string $proUid
     * @param string $grid
     * @param int $start
     * @param int $limit
     */
    public function generateOldReportTable(string $tableName, string $connectionShortName = 'report', string $type = 'NORMAL', array $fields = [], string $proUid = '', string $grid = '', int $start = 0, int $limit = 0)
    {
        //we have to do the propel connection
        $database = $this->chooseDB($connectionShortName);
        $connection = Propel::getConnection($database);

        $case = new Cases();

        // Select cases of the related process, ordered by APP_NUMBER
        $applications = Application::query()
            ->where('PRO_UID', '=', $proUid)
            ->where('APP_NUMBER', '>', 0)
            ->orderBy('APP_NUMBER', 'asc')
            ->offset($start)
            ->limit($limit)
            ->get();

        foreach ($applications as $application) {
            $appData = $case->unserializeData($application->APP_DATA);
            if ($type == 'NORMAL') {
                $fieldsSection = "`APP_UID`, `APP_NUMBER`";
                $valuesSection = "'{$application->APP_UID}', {$application->APP_NUMBER}";
                $this->buildAndExecuteQuery($fieldsSection, $valuesSection, $fields, $appData, $connection, $tableName, $application);
            } else {
                if (isset($appData[$grid])) {
                    foreach ($appData[$grid] as $indexRow => $gridRow) {
                        $fieldsSection = "`APP_UID`, `APP_NUMBER`, `ROW`";
                        $valuesSection = "'{$application->APP_UID}', {$application->APP_NUMBER}, {$indexRow}";
                        $this->buildAndExecuteQuery($fieldsSection, $valuesSection, $fields, $gridRow, $connection, $tableName, $application);
                    }
                }
            }
        }
    }

    /**
     * Build and execute query.
     * 
     * @param string $fieldsSection
     * @param string $valuesSection
     * @param array $fields
     * @param array $appData
     * @param MySQLiConnection $connection
     * @param string $tableName
     * @param Application $application
     */
    private function buildAndExecuteQuery(string $fieldsSection, string $valuesSection, array $fields, array $appData, MySQLiConnection $connection, string $tableName, Application $application)
    {
        try {
            $fieldsSection = $this->buildFieldsSection($fieldsSection, $fields);
            $valuesSection = $this->buildValuesSection($valuesSection, $fields, $appData, $connection);
            $query = "INSERT INTO `{$tableName}` ({$fieldsSection}) VALUES ({$valuesSection});";
            DB::insert($query);
        } catch (Exception $e) {
            $message = "ReportTables::buildAndExecuteQuery";
            $context = [
                "message" => $e->getMessage(),
                "tableName" => $tableName,
                "appUid" => $application->APP_UID
            ];
            Log::channel(':sqlExecution')->critical($message, Bootstrap::context($context));
        }
    }

    /**
     * Build fields section for query string.
     * 
     * @param string $fieldsSection
     * @param array $fields
     * @return string
     */
    private function buildFieldsSection(string $fieldsSection = "", array $fields): string
    {
        foreach ($fields as $field) {
            $fieldsSection = $fieldsSection . ", `{$field['sFieldName']}`";
        }
        return $fieldsSection;
    }

    /**
     * Build values section for query string.
     * 
     * @param string $valuesSection
     * @param array $fields
     * @param array $appData
     * @param MySQLiConnection $connection
     * @return string
     */
    private function buildValuesSection(string $valuesSection = "", array $fields, array $appData, MySQLiConnection $connection): string
    {
        foreach ($fields as $field) {
            switch ($field['sType']) {
                case 'number':
                    $valuesSection .= ',' . (isset($appData[$field['sFieldName']]) ? (float) str_replace(',', '', $appData[$field['sFieldName']]) : '0');
                    break;
                case 'char':
                case 'text':
                    if (!isset($appData[$field['sFieldName']])) {
                        $appData[$field['sFieldName']] = '';
                    }
                    $string = $appData[$field['sFieldName']];
                    if (is_array($string)) {
                        $string = implode(",", $string);
                    }
                    $valuesSection .= ",'" . (isset($appData[$field['sFieldName']]) ? mysqli_real_escape_string($connection->getResource(), $string) : '') . "'";
                    break;
                case 'date':
                    $value = (isset($appData[$field['sFieldName']]) && trim($appData[$field['sFieldName']])) != '' ? "'" . $appData[$field['sFieldName']] . "'" : 'NULL';
                    $valuesSection .= "," . $value;
                    break;
            }
        }
        return $valuesSection;
    }

    /**
     * Function getTableVars
     *
     * @access public
     *
     * @param string $sRepTabUid
     * @param boolean $bWhitType
     *
     * @return void
     */
    public function getTableVars($sRepTabUid, $bWhitType = false)
    {
        try {
            $oCriteria = new Criteria('workflow');
            $oCriteria->add(ReportVarPeer::REP_TAB_UID, $sRepTabUid);
            $oDataset = ReportVarPeer::doSelectRS($oCriteria);
            $oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
            $oDataset->next();
            $aVars = array();
            $aImportedVars = array(); //This array will help to control if the variable already exist
            while ($aRow = $oDataset->getRow()) {
                if ($bWhitType) {
                    if (!in_array($aRow['REP_VAR_NAME'], $aImportedVars)) {
                        $aImportedVars[] = $aRow['REP_VAR_NAME'];
                        $aVars[] = array(
                            'sFieldName' => $aRow['REP_VAR_NAME'],
                            'sType' => $aRow['REP_VAR_TYPE']
                        );
                    }
                } else {
                    $aVars[] = $aRow['REP_VAR_NAME'];
                }
                $oDataset->next();
            }
            return $aVars;
        } catch (Exception $oError) {
            throw ($oError);
        }
    }

    /**
     * Function deleteReportTable
     * This Function deletes report table
     *
     * @access public
     *
     * @param string $sRepTabUid
     *
     * @return void
     */
    public function deleteReportTable($sRepTabUid)
    {
        try {
            $oReportTable = new ReportTable();
            $aFields = $oReportTable->load($sRepTabUid);
            if (!(empty($aFields))) {
                $this->dropTable($aFields['REP_TAB_NAME'], $aFields['REP_TAB_CONNECTION']);
                $oCriteria = new Criteria('workflow');
                $oCriteria->add(ReportVarPeer::REP_TAB_UID, $sRepTabUid);
                ReportVarPeer::doDelete($oCriteria);
                $oReportTable->remove($sRepTabUid);
            }
        } catch (Exception $oError) {
            throw ($oError);
        }
    }

    /**
     * Function getSplitDate
     * This function gets the split date
     *
     * @access public
     *
     * @param date $date
     * @param string $mask
     *
     * @return array
     */
    public function getSplitDate($date, $mask)
    {
        $sw1 = false;
        for ($i = 0; $i < 3; $i++) {
            $item = substr($mask, $i * 2, 1);
            switch ($item) {
                case 'Y':
                    switch ($i) {
                        case 0:
                            $d1 = substr($date, 0, 4);
                            break;
                        case 1:
                            $d1 = substr($date, 3, 4);
                            break;
                        case 2:
                            $d1 = substr($date, 6, 4);
                            break;
                    }
                    $sw1 = true;
                    break;
                case 'y':
                    switch ($i) {
                        case 0:
                            $d1 = substr($date, 0, 2);
                            break;
                        case 1:
                            $d1 = substr($date, 3, 2);
                            break;
                        case 2:
                            $d1 = substr($date, 6, 2);
                            break;
                    }
                    break;
                case 'm':
                    switch ($i) {
                        case 0:
                            $d2 = substr($date, 0, 2);
                            break;
                        case 1:
                            $d2 = ($sw1) ? substr($date, 5, 2) : substr($date, 3, 2);
                            break;
                        case 2:
                            $d2 = ($sw1) ? substr($date, 8, 2) : substr($date, 5, 2);
                            break;
                    }
                    break;
                case 'd':
                    switch ($i) {
                        case 0:
                            $d3 = substr($date, 0, 2);
                            break;
                        case 1:
                            $d3 = ($sw1) ? substr($date, 5, 2) : substr($date, 3, 2);
                            break;
                        case 2:
                            $d3 = ($sw1) ? substr($date, 8, 2) : substr($date, 5, 2);
                            break;
                    }
                    break;
            }
        }
        return array(
            isset($d1) ? $d1 : '',
            isset($d2) ? $d2 : '',
            isset($d3) ? $d3 : ''
        );
    }

    /**
     * Function getFormatDate
     * This function returns the date formated
     *
     * @access public
     *
     * @param date $sDate
     * @param date $sMask
     *
     * @return date
     */
    public function getFormatDate($sDate, $sMask)
    {
        $dateTime = explode(" ", $sDate); //To accept the Hour part
        $aDate = explode('-', str_replace("/", "-", $dateTime[0]));
        $bResult = true;
        foreach ($aDate as $sDate) {
            if (!is_numeric($sDate)) {
                $bResult = false;
                break;
            }
        }
        if ($sMask != '') {
            $aDate = $this->getSplitDate($dateTime[0], $sMask);
            $aDate[0] = ($aDate[0] == '') ? date('Y') : $aDate[0];
            $aDate[1] = ($aDate[1] == '') ? date('m') : $aDate[1];
            $aDate[2] = ($aDate[2] == '') ? date('d') : $aDate[2];
            if (checkdate($aDate[1], $aDate[2], $aDate[0])) {
            } else {
                return false;
            }
        }
        $sDateC = '';
        for ($i = 0; $i < count($aDate); $i++) {
            $sDateC .= (($i == 0) ? "" : "-") . $aDate[$i];
        }
        return ($sDateC);
    }

    /**
     * Function updateTables
     * This function updated the Report Tables
     *
     * @access public
     *
     * @param string $sProcessUid
     * @param string $sApplicationUid
     * @param string $iApplicationNumber
     * @param string $aFields
     *
     * @return void
     */
    public function updateTables($sProcessUid, $sApplicationUid, $iApplicationNumber, $aFields)
    {
        try {
            $c = new Criteria('workflow');
            $c->addSelectColumn(BpmnProjectPeer::PRJ_UID);
            $c->add(BpmnProjectPeer::PRJ_UID, $sProcessUid, Criteria::EQUAL);
            $ds = ProcessPeer::doSelectRS($c);
            $ds->setFetchmode(ResultSet::FETCHMODE_ASSOC);
            $ds->next();
            $row = $ds->getRow();
            $isBpmn = isset($row['PRJ_UID']);

            if (!class_exists('ReportTablePeer')) {
                require_once 'classes/model/ReportTablePeer.php';
            }
            //get all Active Report Tables
            $oCriteria = new Criteria('workflow');
            $oCriteria->add(ReportTablePeer::PRO_UID, $sProcessUid);
            $oCriteria->add(ReportTablePeer::REP_TAB_STATUS, 'ACTIVE');
            $oDataset = ReportTablePeer::doSelectRS($oCriteria);
            $oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
            $oDataset->next();
            while ($aRow = $oDataset->getRow()) {
                $aRow['REP_TAB_NAME'] = $this->sPrefix . $aRow['REP_TAB_NAME'];
                $PropelDatabase = $this->chooseDB($aRow['REP_TAB_CONNECTION']);
                $con = Propel::getConnection($PropelDatabase);
                $con->getResource();
                $stmt = $con->createStatement();
                $aTableFields = $this->getTableVars($aRow['REP_TAB_UID'], true);
                if ($aRow['REP_TAB_TYPE'] == 'NORMAL') {
                    $sqlExists = "SELECT * FROM `" . $aRow['REP_TAB_NAME'] . "` WHERE APP_UID = '" . $sApplicationUid . "'";
                    $rsExists = $stmt->executeQuery($sqlExists, ResultSet::FETCHMODE_ASSOC);
                    $rsExists->next();
                    $aRow2 = $rsExists->getRow();

                    if (is_array($aRow2)) {
                        $sQuery = 'UPDATE `' . $aRow['REP_TAB_NAME'] . '` SET ';
                        foreach ($aTableFields as $aField) {
                            $sQuery .= '`' . $aField['sFieldName'] . '` = ';

                            if (!$isBpmn && !isset($aFields[$aField['sFieldName']])) {
                                foreach ($aFields as $row) {
                                    if (is_array($row) && isset($row[count($row)])) {
                                        $aFields = $row[count($row)];
                                    }
                                }
                            }

                            switch ($aField['sType']) {
                                case 'number':
                                    $sQuery .= (isset($aFields[$aField['sFieldName']]) ? (float)str_replace(
                                            ',',
                                            '',
                                            $aFields[$aField['sFieldName']]
                                        ) : '0') . ',';
                                    break;
                                case 'char':
                                case 'text':
                                    if (!isset($aFields[$aField['sFieldName']])) {
                                        $aFields[$aField['sFieldName']] = '';
                                    }
                                    if (!isset($aFields[$aField['sFieldName'] . '_label'])) {
                                        $aFields[$aField['sFieldName'] . '_label'] = '';
                                    }
                                    if (is_array($aFields[$aField['sFieldName']])) {
                                        $sQuery .= "'" . (isset($aFields[$aField['sFieldName']]) ? $aFields[$aField['sFieldName']][0] : '') . "',";
                                    } else {
                                        $sQuery .= '\'' . ((isset($aFields[$aField['sFieldName']])) ? mysqli_real_escape_string(
                                                $con->getResource(),
                                                $aFields[$aField['sFieldName']]
                                            ) : '') . '\',';
                                    }
                                    break;
                                case 'date':
                                    $mysqlDate = (isset($aFields[$aField['sFieldName']]) ? $aFields[$aField['sFieldName']] : '');
                                    if ($mysqlDate != '') {
                                        $mysqlDate = str_replace('/', '-', $mysqlDate);
                                        $mysqlDate = date('Y-m-d', strtotime($mysqlDate));
                                    }
                                    $value = trim($mysqlDate) != '' ? "'" . $mysqlDate . "'" : 'NULL';
                                    $sQuery .= $value . ",";
                                    break;
                            }
                        }
                        $sQuery = substr($sQuery, 0, -1);
                        $sQuery .= " WHERE APP_UID = '" . $sApplicationUid . "'";

                        //Only we will to executeQuery if we have additional field
                        if (count($aTableFields) > 0) {
                            try {
                                $rs = $stmt->executeQuery($sQuery);
                            } catch (Exception $e) {
                                $message = 'Sql Execution';
                                $context = [
                                    'sql' => $sQuery, 
                                    'error' => $e->getMessage()
                                ];
                                Log::channel(':sqlExecution')->error($message, Bootstrap::context($context));
                            }
                        }
                    } else {
                        $sQuery = 'INSERT INTO `' . $aRow['REP_TAB_NAME'] . '` (';
                        $sQuery .= '`APP_UID`,`APP_NUMBER`';
                        foreach ($aTableFields as $aField) {
                            $sQuery .= ',`' . $aField['sFieldName'] . '`';
                        }
                        $sQuery .= ") VALUES ('" . $sApplicationUid . "'," . (int)$iApplicationNumber;
                        foreach ($aTableFields as $aField) {
                            switch ($aField['sType']) {
                                case 'number':
                                    $sQuery .= ',' . (isset($aFields[$aField['sFieldName']]) ? (float)str_replace(
                                            ',',
                                            '',
                                            $aFields[$aField['sFieldName']]
                                        ) : '0');
                                    break;
                                case 'char':
                                case 'text':
                                    if (!isset($aFields[$aField['sFieldName']])) {
                                        $aFields[$aField['sFieldName']] = '';
                                    }
                                    $sQuery .= ",'" . (isset($aFields[$aField['sFieldName']]) ? mysqli_real_escape_string(
                                            $con->getResource(),
                                            $aFields[$aField['sFieldName']]
                                        ) : '') . "'";
                                    break;
                                case 'date':
                                    $mysqlDate = (isset($aFields[$aField['sFieldName']]) ? $aFields[$aField['sFieldName']] : '');
                                    if ($mysqlDate != '') {
                                        $mysqlDate = str_replace('/', '-', $mysqlDate);
                                        $mysqlDate = date('Y-m-d', strtotime($mysqlDate));
                                    }
                                    $value = trim($mysqlDate) != '' ? "'" . $mysqlDate . "'" : 'NULL';
                                    $sQuery .= "," . $value;
                                    break;
                            }
                        }
                        $sQuery .= ')';

                        try {
                            $rs = $stmt->executeQuery($sQuery);
                        } catch (Exception $e) {
                            $message = 'Sql Execution';
                            $context = [
                                'sql' => $sQuery,
                                'error' => $e->getMessage()
                            ];
                            Log::channel(':sqlExecution')->error($message, Bootstrap::context($context));
                        }
                    }
                } else {
                    //remove old rows from database
                    $sqlDelete = 'DELETE FROM `' . $aRow['REP_TAB_NAME'] . "` WHERE APP_UID = '" . $sApplicationUid . "'";
                    $stmt->executeQuery($sqlDelete);

                    $aAux = explode('-', $aRow['REP_TAB_GRID']);
                    if (isset($aFields[$aAux[0]])) {
                        if (is_array($aFields[$aAux[0]])) {
                            foreach ($aFields[$aAux[0]] as $iRow => $aGridRow) {
                                $sQuery = 'INSERT INTO `' . $aRow['REP_TAB_NAME'] . '` (';
                                $sQuery .= '`APP_UID`,`APP_NUMBER`,`ROW`';
                                foreach ($aTableFields as $aField) {
                                    $sQuery .= ',`' . $aField['sFieldName'] . '`';
                                }
                                $sQuery .= ") VALUES ('" . $sApplicationUid . "'," . (int)$iApplicationNumber . ',' . $iRow;
                                foreach ($aTableFields as $aField) {
                                    switch ($aField['sType']) {
                                        case 'number':
                                            $sQuery .= ',' . (isset($aGridRow[$aField['sFieldName']]) ? (float)str_replace(
                                                    ',',
                                                    '',
                                                    $aGridRow[$aField['sFieldName']]
                                                ) : '0');
                                            break;
                                        case 'char':
                                        case 'text':
                                            if (!isset($aGridRow[$aField['sFieldName']])) {
                                                $aGridRow[$aField['sFieldName']] = '';
                                            }
                                            $sQuery .= ",'" . (isset($aGridRow[$aField['sFieldName']]) ? mysqli_real_escape_string(
                                                    $con->getResource(),
                                                    $aGridRow[$aField['sFieldName']]
                                                ) : '') . "'";
                                            break;
                                        case 'date':
                                            $sQuery .= ",'" . (isset($aGridRow[$aField['sFieldName']]) ? $aGridRow[$aField['sFieldName']] : '') . "'";
                                            break;
                                    }
                                }
                                $sQuery .= ')';
                                $rs = $stmt->executeQuery($sQuery);
                            }
                        }
                    }
                }
                $oDataset->next();
            }
        } catch (Exception $oError) {
            throw ($oError);
        }
    }

    /**
     * Function tableExist
     * Check if table exists
     *
     * @access public
     * @return boolean
     */
    public static function tableExist()
    {
        $bExists = true;

        $oDataBase = new database();
        $bExists = $oDataBase->reportTableExist();

        return $bExists;
    }

    /**
     * Function chooseDB
     * Choose the database to connect
     *
     * @access public
     *
     * @param string $TabConnectionk
     *
     * @return string
     */
    public function chooseDB($TabConnectionk)
    {
        $repTabConnection = trim(strtoupper($TabConnectionk));
        $PropelDatabase = 'rp';
        if ($repTabConnection == '' || $repTabConnection == 'REPORT') {
            $PropelDatabase = 'rp';
        }
        if ($repTabConnection == 'RBAC') {
            $PropelDatabase = 'rbac';
        }
        if ($repTabConnection == 'WF') {
            $PropelDatabase = 'workflow';
        }
        return ($PropelDatabase);
    }
}