Merge branch 'develop' of https://bitbucket.org/colosa/processmaker into feature/PMCORE-1444
This commit is contained in:
@@ -36,7 +36,6 @@ class PmBootstrap extends Bootstrap
|
||||
ini_set('error_reporting', $e_all);
|
||||
ini_set('short_open_tag', 'On');
|
||||
ini_set('default_charset', "UTF-8");
|
||||
ini_set('memory_limit', $this->pmConfig['memory_limit']);
|
||||
ini_set('soap.wsdl_cache_enabled', $this->pmConfig['wsdl_cache']);
|
||||
ini_set('date.timezone', (isset($_SESSION['__SYSTEM_UTC_TIME_ZONE__']) && $_SESSION['__SYSTEM_UTC_TIME_ZONE__'])? 'UTC' : $this->pmConfig['time_zone']); //Set Time Zone
|
||||
|
||||
|
||||
@@ -101,7 +101,6 @@ try {
|
||||
ini_set('error_reporting', $e_all);
|
||||
ini_set('short_open_tag', 'On');
|
||||
ini_set('default_charset', 'UTF-8');
|
||||
ini_set('memory_limit', $arraySystemConfiguration['memory_limit']);
|
||||
ini_set('soap.wsdl_cache_enabled', $arraySystemConfiguration['wsdl_cache']);
|
||||
ini_set('date.timezone', $systemUtcTimeZone ? 'UTC' : $arraySystemConfiguration['time_zone']);
|
||||
|
||||
|
||||
@@ -95,7 +95,6 @@ try {
|
||||
restore_error_handler();
|
||||
|
||||
// Do not change any of these settings directly, use env.ini instead
|
||||
ini_set('memory_limit', $arraySystemConfiguration['memory_limit']);
|
||||
ini_set('display_errors', $arraySystemConfiguration['debug']);
|
||||
ini_set('error_reporting', $e_all);
|
||||
ini_set('short_open_tag', 'On');
|
||||
|
||||
@@ -87,8 +87,6 @@ if(count ($argv) > 3) {
|
||||
$debug = 1;
|
||||
|
||||
ini_set ('display_errors', 1);
|
||||
//error_reporting (E_ALL);
|
||||
ini_set ('memory_limit', '256M'); // set enough memory for the script
|
||||
|
||||
$e_all = defined( 'E_DEPRECATED' ) ? E_ALL & ~ E_DEPRECATED : E_ALL;
|
||||
$e_all = defined( 'E_STRICT' ) ? $e_all & ~ E_STRICT : $e_all;
|
||||
|
||||
@@ -52,8 +52,6 @@ $debug = 1;//enable o disable notice, this mechanism is inherited from '/process
|
||||
|
||||
ini_set ('display_errors', 1);
|
||||
|
||||
ini_set ('memory_limit', '256M'); // set enough memory for the script
|
||||
|
||||
$e_all = defined( 'E_DEPRECATED' ) ? E_ALL & ~ E_DEPRECATED : E_ALL;
|
||||
$e_all = defined( 'E_STRICT' ) ? $e_all & ~ E_STRICT : $e_all;
|
||||
$e_all = $debug ? $e_all : $e_all & ~ E_NOTICE;
|
||||
|
||||
@@ -437,18 +437,6 @@ class ActionsByEmailCoreClass extends PMPlugin
|
||||
return $emailSetup;
|
||||
}
|
||||
|
||||
/**
|
||||
* Define the properties in the task related the action by email configuration
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
private function defineTaskAbeProperties()
|
||||
{
|
||||
$actionEmailTable = new AbeConfiguration();
|
||||
$properties = $actionEmailTable->getTaskConfiguration($this->getCasePropertiesKey('PRO_UID'), $this->getTask());
|
||||
$this->setTaskAbeProperties($properties);
|
||||
}
|
||||
|
||||
/**
|
||||
* Define the email from
|
||||
*
|
||||
@@ -623,79 +611,94 @@ class ActionsByEmailCoreClass extends PMPlugin
|
||||
self::validateAndSetValues($data);
|
||||
|
||||
$emailServerSetup = $this->getEmailServer($dataAbe['ABE_EMAIL_SERVER_UID']);
|
||||
if (!empty($emailServerSetup)) {
|
||||
$cases = new Cases();
|
||||
$caseFields = $cases->loadCase($this->getAppUid(), $this->getIndex());
|
||||
$this->setCaseProperties($caseFields);
|
||||
$this->defineTaskAbeProperties();
|
||||
$caseFields['APP_DATA']['PRO_ID'] = $this->getItemAbeProperties('PRO_ID');
|
||||
$caseFields['APP_DATA']['TAS_ID'] = $this->getItemAbeProperties('TAS_ID');
|
||||
if (!empty($this->getTaskAbeProperties())) {
|
||||
$this->defineEmailTo($this->getItemAbeProperties('ABE_EMAIL_FIELD'), $caseFields['APP_DATA']);
|
||||
|
||||
if (!empty($this->getEmailTo())) {
|
||||
$this->defineSubject($this->getItemAbeProperties('ABE_SUBJECT_FIELD'), $caseFields['APP_DATA']);
|
||||
|
||||
$request = [
|
||||
'ABE_REQ_UID' => '',
|
||||
'ABE_UID' => $this->getItemAbeProperties('ABE_UID'),
|
||||
'APP_UID' => $this->getAppUid(),
|
||||
'DEL_INDEX' => $this->getIndex(),
|
||||
'ABE_REQ_SENT_TO' => $this->getEmailTo(),
|
||||
'ABE_REQ_SUBJECT' => $this->getSubject(),
|
||||
'ABE_REQ_BODY' => '',
|
||||
'ABE_REQ_ANSWERED' => 0,
|
||||
'ABE_REQ_STATUS' => 'PENDING'
|
||||
];
|
||||
$this->setAbeRequest($request);
|
||||
$this->registerRequest();
|
||||
|
||||
if (!empty($this->getItemAbeProperties('ABE_TYPE'))) {
|
||||
// Email
|
||||
$_SESSION['CURRENT_DYN_UID'] = $this->getItemAbeProperties('DYN_UID');
|
||||
$__ABE__ = '';
|
||||
|
||||
switch ($this->getItemAbeProperties('ABE_TYPE')) {
|
||||
case 'CUSTOM':
|
||||
$__ABE__ .= $this->getCustomTemplate();
|
||||
break;
|
||||
case 'RESPONSE':
|
||||
$this->defineReplyTo($dataAbe['ABE_EMAIL_SERVER_RECEIVER_UID']);
|
||||
$__ABE__ .= $this->getResponseTemplate();
|
||||
break;
|
||||
case 'LINK':
|
||||
$__ABE__ .= $this->getServicePathTemplate();
|
||||
break;
|
||||
case 'FIELD':
|
||||
$__ABE__ .= $this->getFieldTemplate();
|
||||
break;
|
||||
}
|
||||
$__ABE__ = preg_replace('/\<img src=\"\/js\/maborak\/core\/images\/(.+?)\>/', '', $__ABE__);
|
||||
$__ABE__ = preg_replace('/\<input\b[^>]*\/>/', '', $__ABE__);
|
||||
$__ABE__ = preg_replace('/<select\b[^>]*>(.*?)<\/select>/is', "", $__ABE__);
|
||||
$__ABE__ = preg_replace('/align=\"center\"/', '', $__ABE__);
|
||||
$__ABE__ = preg_replace('/class="tableGrid_view" /', 'class="tableGrid_view" width="100%" ',
|
||||
$__ABE__);
|
||||
$caseFields['APP_DATA']['__ABE__'] = $__ABE__;
|
||||
|
||||
$this->defineEmailFrom($emailServerSetup);
|
||||
$result = $this->abeSendMessage(
|
||||
$this->getItemAbeProperties('ABE_TEMPLATE'),
|
||||
$caseFields['APP_DATA'],
|
||||
$emailServerSetup
|
||||
);
|
||||
$request = [];
|
||||
$request['ABE_REQ_STATUS'] = ($result->status_code == 0 ? 'SENT' : 'ERROR');
|
||||
|
||||
$request['ABE_REQ_BODY'] = empty($result->getAppMessUid()) ? '' : AppMessage::getAppMsgBodyByKey($result->getAppMessUid());
|
||||
$this->addItemAbeRequest($request);
|
||||
$this->registerRequest();
|
||||
}
|
||||
}
|
||||
} else {
|
||||
throw new Exception('Task does not have an action by email configuration.');
|
||||
}
|
||||
if (empty($emailServerSetup)) {
|
||||
return;
|
||||
}
|
||||
|
||||
$cases = new Cases();
|
||||
$caseFields = $cases->loadCase($this->getAppUid(), $this->getIndex());
|
||||
$this->setCaseProperties($caseFields);
|
||||
|
||||
$actionEmailTable = new AbeConfiguration();
|
||||
$properties = $actionEmailTable->getTaskConfiguration($this->getCasePropertiesKey('PRO_UID'), $this->getTask());
|
||||
if (empty($properties)) {
|
||||
throw new Exception('Task does not have an action by email configuration.');
|
||||
}
|
||||
$this->setTaskAbeProperties($properties);
|
||||
|
||||
$caseFields['APP_DATA']['PRO_ID'] = $this->getItemAbeProperties('PRO_ID');
|
||||
$caseFields['APP_DATA']['TAS_ID'] = $this->getItemAbeProperties('TAS_ID');
|
||||
|
||||
$this->defineEmailTo($this->getItemAbeProperties('ABE_EMAIL_FIELD'), $caseFields['APP_DATA']);
|
||||
if (empty($this->getEmailTo())) {
|
||||
return;
|
||||
}
|
||||
|
||||
$this->defineSubject($this->getItemAbeProperties('ABE_SUBJECT_FIELD'), $caseFields['APP_DATA']);
|
||||
|
||||
$request = [
|
||||
'ABE_REQ_UID' => '',
|
||||
'ABE_UID' => $this->getItemAbeProperties('ABE_UID'),
|
||||
'APP_UID' => $this->getAppUid(),
|
||||
'DEL_INDEX' => $this->getIndex(),
|
||||
'ABE_REQ_SENT_TO' => $this->getEmailTo(),
|
||||
'ABE_REQ_SUBJECT' => $this->getSubject(),
|
||||
'ABE_REQ_BODY' => '',
|
||||
'ABE_REQ_ANSWERED' => 0,
|
||||
'ABE_REQ_STATUS' => 'PENDING'
|
||||
];
|
||||
$this->setAbeRequest($request);
|
||||
$this->registerRequest();
|
||||
|
||||
if (empty($this->getItemAbeProperties('ABE_TYPE'))) {
|
||||
return;
|
||||
}
|
||||
// Email
|
||||
$_SESSION['CURRENT_DYN_UID'] = $this->getItemAbeProperties('DYN_UID');
|
||||
|
||||
$__ABE__ = '';
|
||||
switch ($this->getItemAbeProperties('ABE_TYPE')) {
|
||||
case 'CUSTOM':
|
||||
$__ABE__ .= $this->getCustomTemplate();
|
||||
break;
|
||||
case 'RESPONSE':
|
||||
$this->defineReplyTo($dataAbe['ABE_EMAIL_SERVER_RECEIVER_UID']);
|
||||
$__ABE__ .= $this->getResponseTemplate();
|
||||
break;
|
||||
case 'LINK':
|
||||
$__ABE__ .= $this->getServicePathTemplate();
|
||||
break;
|
||||
case 'FIELD':
|
||||
$__ABE__ .= $this->getFieldTemplate();
|
||||
break;
|
||||
}
|
||||
$__ABE__ = preg_replace('/\<img src=\"\/js\/maborak\/core\/images\/(.+?)\>/', '', $__ABE__);
|
||||
$__ABE__ = preg_replace('/\<input\b[^>]*\/>/', '', $__ABE__);
|
||||
$__ABE__ = preg_replace('/<select\b[^>]*>(.*?)<\/select>/is', "", $__ABE__);
|
||||
$__ABE__ = preg_replace('/align=\"center\"/', '', $__ABE__);
|
||||
$__ABE__ = preg_replace('/class="tableGrid_view" /', 'class="tableGrid_view" width="100%" ', $__ABE__);
|
||||
|
||||
$caseFields['APP_DATA']['__ABE__'] = $__ABE__;
|
||||
|
||||
$this->defineEmailFrom($emailServerSetup);
|
||||
|
||||
$params = [
|
||||
$this->getItemAbeProperties('ABE_TEMPLATE'),
|
||||
$caseFields['APP_DATA'],
|
||||
$emailServerSetup
|
||||
];
|
||||
$result = $this->abeSendMessage(...$params);
|
||||
|
||||
$request = [
|
||||
'ABE_REQ_STATUS' => $result->status_code == 0 ? 'SENT' : 'ERROR',
|
||||
'ABE_REQ_BODY' => '',
|
||||
];
|
||||
if (!empty($result->getExtraParam('AppMessUid'))) {
|
||||
$request['ABE_REQ_BODY'] = AppMessage::getAppMsgBodyByKey($result->getExtraParam('AppMessUid'));
|
||||
}
|
||||
|
||||
$this->addItemAbeRequest($request);
|
||||
$this->registerRequest();
|
||||
} catch (Exception $error) {
|
||||
throw $error;
|
||||
}
|
||||
|
||||
@@ -206,6 +206,7 @@ class DbConnections
|
||||
});
|
||||
foreach ($externalDbs as $externalDb) {
|
||||
$conf['datasources'][$externalDb->DBS_UID] = [];
|
||||
$laravelConfig = [];
|
||||
$flagTns = ($externalDb->DBS_TYPE == "oracle" && $externalDb->DBS_CONNECTION_TYPE == "TNS")? 1 : 0;
|
||||
// Build the appropriate items to add to our Propel configuration
|
||||
// Let's grab the decrypted password
|
||||
@@ -235,12 +236,26 @@ class DbConnections
|
||||
. $externalDb->DBS_USERNAME . ':' . $passw . '@' . $externalDb->DBS_SERVER . $dbsPort . '/'
|
||||
. $externalDb->DBS_DATABASE_NAME . $encoding;
|
||||
}
|
||||
$laravelConfig = [
|
||||
'driver' => $externalDb->DBS_TYPE === 'mssql' ? 'sqlsrv' : $externalDb->DBS_TYPE, // MSSQL driver is not supported anymore, only SQLSRV
|
||||
'host' => $externalDb->DBS_SERVER,
|
||||
'port' => $externalDb->DBS_PORT == '' ? null : $externalDb->DBS_PORT,
|
||||
'database' => $externalDb->DBS_DATABASE_NAME,
|
||||
'username' => $externalDb->DBS_USERNAME,
|
||||
'password' => $passw,
|
||||
'charset' => trim($externalDb->DBS_ENCODE) == '' ? null : trim($externalDb->DBS_ENCODE),
|
||||
'options' => [PDO::ATTR_STRINGIFY_FETCHES => true] // For keep the old behaviour, all values are transformed to strings
|
||||
];
|
||||
} else {
|
||||
// Is oracle and TNS, let's provide a TNS based DSN
|
||||
$conf["datasources"][$externalDb->DBS_UID]["connection"] = $externalDb->DBS_TYPE . "://"
|
||||
. $externalDb->DBS_USERNAME . ":" . $passw . "@" . $externalDb->DBS_TNS;
|
||||
}
|
||||
$conf['datasources'][$externalDb->DBS_UID]['adapter'] = $externalDb->DBS_TYPE;
|
||||
// Load the config for the external database into laravel
|
||||
config([
|
||||
'database.connections.' . $externalDb->DBS_UID => $laravelConfig
|
||||
]);
|
||||
}
|
||||
Propel::initConfiguration($conf);
|
||||
$lastProcessId = $_SESSION['PROCESS'];
|
||||
|
||||
@@ -8,7 +8,6 @@ use ProcessMaker\ChangeLog\ChangeLog;
|
||||
use ProcessMaker\Core\JobsManager;
|
||||
use ProcessMaker\Core\System;
|
||||
use ProcessMaker\Model\Delegation;
|
||||
use ProcessMaker\Util\WsMessageResponse;
|
||||
|
||||
class WsBase
|
||||
{
|
||||
@@ -910,6 +909,7 @@ class WsBase
|
||||
)
|
||||
{
|
||||
try {
|
||||
$setup = [];
|
||||
|
||||
/*----------------------------------********---------------------------------*/
|
||||
if (!empty($config)) {
|
||||
@@ -972,9 +972,7 @@ class WsBase
|
||||
|
||||
if (!file_exists($fileTemplate)) {
|
||||
$data['FILE_TEMPLATE'] = $fileTemplate;
|
||||
$result = new WsResponse(28, G::LoadTranslation('ID_TEMPLATE_FILE_NOT_EXIST', SYS_LANG, $data));
|
||||
|
||||
return $result;
|
||||
return new WsResponse(28, G::LoadTranslation('ID_TEMPLATE_FILE_NOT_EXIST', SYS_LANG, $data));
|
||||
}
|
||||
|
||||
if ($appFields == null) {
|
||||
@@ -1002,45 +1000,46 @@ class WsBase
|
||||
(preg_match("/^.+\.html?$/i", $fileTemplate)) ? true : false,
|
||||
isset($fieldsCase['APP_NUMBER']) ? $fieldsCase['APP_NUMBER'] : 0,
|
||||
isset($fieldsCase['PRO_ID']) ? $fieldsCase['PRO_ID'] : 0,
|
||||
$this->getTaskId() ?$this->getTaskId():(isset($oldFields['TAS_ID'])? $oldFields['TAS_ID'] : 0)
|
||||
$this->getTaskId() ? $this->getTaskId() : (isset($oldFields['TAS_ID']) ? $oldFields['TAS_ID'] : 0)
|
||||
);
|
||||
|
||||
$result = "";
|
||||
if ($gmail != 1) {
|
||||
// Create always the record in APP_MESSAGE table
|
||||
if ($gmail === 1) {
|
||||
return new WsResponse(0, G::loadTranslation('ID_PMGMAIL'));
|
||||
}
|
||||
|
||||
// Create always the record in APP_MESSAGE table
|
||||
$spool = new SpoolRun();
|
||||
$spool->setConfig($setup);
|
||||
$spool->create($messageArray);
|
||||
|
||||
// Get the data of the record created
|
||||
$fileData = $spool->getFileData();
|
||||
$fileData['spoolId'] = $spool->getSpoolId();
|
||||
|
||||
// Create the closure and send the required data
|
||||
$closure = function() use ($setup, $fileData, $gmail, $to) {
|
||||
$spool = new SpoolRun();
|
||||
$spool->setConfig($setup);
|
||||
$spool->create($messageArray);
|
||||
|
||||
// Get the data of the record created
|
||||
$fileData = $spool->getFileData();
|
||||
$fileData['spoolId'] = $spool->getSpoolId();
|
||||
|
||||
// Create the closure and send the required data
|
||||
$closure = function() use ($setup, $fileData, $gmail, $to) {
|
||||
$spool = new SpoolRun();
|
||||
$spool->setConfig($setup);
|
||||
$spool->setSpoolId($fileData['spoolId']);
|
||||
$spool->setFileData($fileData);
|
||||
$spool->sendMail();
|
||||
return $spool;
|
||||
};
|
||||
$result = new WsMessageResponse(0, G::loadTranslation('ID_MESSAGE_SENT') . ": " . $to);
|
||||
switch ($appMsgType) {
|
||||
case WsBase::MESSAGE_TYPE_EMAIL_EVENT:
|
||||
case WsBase::MESSAGE_TYPE_PM_FUNCTION:
|
||||
JobsManager::getSingleton()->dispatch('EmailEvent', $closure);
|
||||
break;
|
||||
default :
|
||||
$spool = $closure();
|
||||
if ($spool->status == 'sent') {
|
||||
$result = new WsMessageResponse(0, G::loadTranslation('ID_MESSAGE_SENT') . ": " . $to);
|
||||
$result->setAppMessUid($spool->getSpoolId());
|
||||
} else {
|
||||
$result = new WsResponse(29, $spool->status . ' ' . $spool->error . PHP_EOL . print_r($setup, 1));
|
||||
}
|
||||
break;
|
||||
}
|
||||
$spool->setSpoolId($fileData['spoolId']);
|
||||
$spool->setFileData($fileData);
|
||||
$spool->sendMail();
|
||||
return $spool;
|
||||
};
|
||||
switch ($appMsgType) {
|
||||
case WsBase::MESSAGE_TYPE_EMAIL_EVENT:
|
||||
case WsBase::MESSAGE_TYPE_PM_FUNCTION:
|
||||
JobsManager::getSingleton()->dispatch('EmailEvent', $closure);
|
||||
$result = new WsResponse(0, G::loadTranslation('ID_MESSAGE_SENT') . ": " . $to);
|
||||
break;
|
||||
default :
|
||||
$spool = $closure();
|
||||
if ($spool->status == 'sent') {
|
||||
$result = new WsResponse(0, G::loadTranslation('ID_MESSAGE_SENT') . ": " . $to);
|
||||
$result->addExtraParam('AppMessUid', $spool->getSpoolId());
|
||||
} else {
|
||||
$result = new WsResponse(29, $spool->status . ' ' . $spool->error . PHP_EOL . print_r($setup, 1));
|
||||
}
|
||||
break;
|
||||
}
|
||||
return $result;
|
||||
} catch (Exception $e) {
|
||||
|
||||
@@ -43,10 +43,11 @@ class WsResponse
|
||||
* 36 ID_CASE_COULD_NOT_REASSIGNED
|
||||
*
|
||||
* 100 Exception
|
||||
*/
|
||||
*/
|
||||
public $status_code = 0;
|
||||
public $message = '';
|
||||
public $timestamp = '';
|
||||
private $extraParams = [];
|
||||
|
||||
/**
|
||||
* Function __construct
|
||||
@@ -56,11 +57,31 @@ class WsResponse
|
||||
* @param string $message
|
||||
* @return void
|
||||
*/
|
||||
function __construct ($status, $message)
|
||||
public function __construct($status, $message)
|
||||
{
|
||||
$this->status_code = $status;
|
||||
$this->message = $message;
|
||||
$this->timestamp = date( 'Y-m-d H:i:s' );
|
||||
$this->timestamp = date('Y-m-d H:i:s');
|
||||
}
|
||||
|
||||
/**
|
||||
* Get extra parameters for message response.
|
||||
* @return mixed
|
||||
*/
|
||||
public function getExtraParam(string $name)
|
||||
{
|
||||
return isset($this->extraParams[$name]) ? $this->extraParams[$name] : '';
|
||||
}
|
||||
|
||||
/**
|
||||
* Add extra parameters for message response.
|
||||
* @param string $name
|
||||
* @param mixed $value
|
||||
* @return void
|
||||
*/
|
||||
public function addExtraParam(string $name, $value): void
|
||||
{
|
||||
$this->extraParams[$name] = $value;
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -69,13 +90,12 @@ class WsResponse
|
||||
* @param string $operation
|
||||
* @return string
|
||||
*/
|
||||
function getPayloadString ($operation)
|
||||
public function getPayloadString($operation)
|
||||
{
|
||||
$res = "<$operation>\n";
|
||||
$res .= "<status_code>" . $this->status_code . "</status_code>";
|
||||
$res .= "<message>" . $this->message . "</message>";
|
||||
$res .= "<timestamp>" . $this->timestamp . "</timestamp>";
|
||||
// $res .= "<array>" . $this->timestamp . "</array>";
|
||||
$res .= "<$operation>";
|
||||
return $res;
|
||||
}
|
||||
@@ -85,9 +105,8 @@ class WsResponse
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
function getPayloadArray ()
|
||||
public function getPayloadArray()
|
||||
{
|
||||
return array ("status_code" => $this->status_code,'message' => $this->message,'timestamp' => $this->timestamp
|
||||
);
|
||||
return ["status_code" => $this->status_code, 'message' => $this->message, 'timestamp' => $this->timestamp];
|
||||
}
|
||||
}
|
||||
|
||||
@@ -32,6 +32,7 @@ use ProcessMaker\BusinessModel\Cases as BusinessModelCases;
|
||||
use ProcessMaker\Core\System;
|
||||
use ProcessMaker\Plugins\PluginRegistry;
|
||||
use ProcessMaker\Util\ElementTranslation;
|
||||
use Illuminate\Support\Facades\DB;
|
||||
|
||||
/**
|
||||
* ProcessMaker has made a number of its PHP functions available be used in triggers and conditions.
|
||||
@@ -243,8 +244,22 @@ function executeQuery ($SqlStatement, $DBConnectionUID = 'workflow', $aParameter
|
||||
{
|
||||
$sysSys = (!empty(config("system.workspace")))? config("system.workspace") : "Undefined";
|
||||
$aContext = \Bootstrap::getDefaultContextLog();
|
||||
$con = Propel::getConnection( $DBConnectionUID );
|
||||
$con->begin();
|
||||
|
||||
// This means the DBConnectionUID is not loaded yet, so we'll force DbConnections::loadAdditionalConnections
|
||||
if (is_null(config('database.connections.' . $DBConnectionUID . '.driver'))) {
|
||||
// Force to load the external connections
|
||||
DbConnections::loadAdditionalConnections();
|
||||
if (config('database.connections.' . $DBConnectionUID . '.driver') !== 'oracle') {
|
||||
// If the connections drivers are "mysql", "pgsql" or "sqlsrv" we're using Laravel
|
||||
$con = DB::connection($DBConnectionUID);
|
||||
$con->beginTransaction();
|
||||
} else {
|
||||
// If the connection driver is "oracle" we're using the native oci8 functions
|
||||
$con = Propel::getConnection($DBConnectionUID);
|
||||
$con->begin();
|
||||
}
|
||||
}
|
||||
|
||||
$blackList = System::getQueryBlackList();
|
||||
$listQueries = explode('|', isset($blackList['queries']) ? $blackList['queries'] : '');
|
||||
$aListAllTables = explode(
|
||||
@@ -299,36 +314,34 @@ function executeQuery ($SqlStatement, $DBConnectionUID = 'workflow', $aParameter
|
||||
$statement = str_replace( '(', '', $statement );
|
||||
|
||||
$result = false;
|
||||
if (getEngineDataBaseName( $con ) != 'oracle') {
|
||||
|
||||
// Check to see if we're not running oracle, which is usually a safe default
|
||||
if (config('database.connections.' . $DBConnectionUID . '.driver') != 'oracle') {
|
||||
switch (true) {
|
||||
case preg_match( "/^(SELECT|EXECUTE|EXEC|SHOW|DESCRIBE|EXPLAIN|BEGIN)\s/i", $statement ):
|
||||
$rs = $con->executeQuery( $SqlStatement );
|
||||
$result = Array ();
|
||||
$i = 1;
|
||||
while ($rs->next()) {
|
||||
$result[$i ++] = $rs->getRow();
|
||||
}
|
||||
$rs->close();
|
||||
$result = $con->select( $SqlStatement );
|
||||
|
||||
// Convert to 1 index key array of array results
|
||||
$result = collect($result)->map(function($x) { return (array)$x; })->toArray();
|
||||
array_unshift($result, []);
|
||||
unset($result[0]);
|
||||
|
||||
$con->commit();
|
||||
break;
|
||||
case preg_match( "/^INSERT\s/i", $statement ):
|
||||
$rs = $con->executeUpdate( $SqlStatement );
|
||||
$result = $con->getUpdateCount();
|
||||
$result = $con->insert( $SqlStatement );
|
||||
$con->commit();
|
||||
break;
|
||||
case preg_match( "/^REPLACE\s/i", $statement ):
|
||||
$rs = $con->executeUpdate( $SqlStatement );
|
||||
$result = $con->getUpdateCount();
|
||||
$result = $con->update( $SqlStatement );
|
||||
$con->commit();
|
||||
break;
|
||||
case preg_match( "/^UPDATE\s/i", $statement ):
|
||||
$rs = $con->executeUpdate( $SqlStatement );
|
||||
$result = $con->getUpdateCount();
|
||||
$result = $con->update( $SqlStatement );
|
||||
$con->commit();
|
||||
break;
|
||||
case preg_match( "/^DELETE\s/i", $statement ):
|
||||
$rs = $con->executeUpdate( $SqlStatement );
|
||||
$result = $con->getUpdateCount();
|
||||
$result = $con->delete( $SqlStatement );
|
||||
$con->commit();
|
||||
break;
|
||||
}
|
||||
@@ -947,9 +960,8 @@ function PMFSendMessage(
|
||||
$delIndex = 0,
|
||||
$config = []
|
||||
) {
|
||||
ini_set ( "pcre.backtrack_limit", 1000000 );
|
||||
ini_set ( 'memory_limit', '-1' );
|
||||
@set_time_limit ( 100000 );
|
||||
ini_set("pcre.backtrack_limit", 1000000);
|
||||
@set_time_limit(100000);
|
||||
|
||||
global $oPMScript;
|
||||
|
||||
|
||||
@@ -1181,7 +1181,6 @@ class InstallerModule extends Controller
|
||||
{
|
||||
$filter = new InputFilter();
|
||||
ini_set('max_execution_time', '0');
|
||||
ini_set('memory_limit', '256M');
|
||||
|
||||
$serv = 'http://';
|
||||
if (isset($_SERVER['HTTPS']) && !empty(trim($_SERVER['HTTPS']))) {
|
||||
|
||||
@@ -65,11 +65,6 @@ class adminProxy extends HttpProxyController
|
||||
$updatedConf['expiration_year'] = $httpData->expiration_year;
|
||||
}
|
||||
|
||||
$httpData->memory_limit .= 'M';
|
||||
if ($sysConf['memory_limit'] != $httpData->memory_limit) {
|
||||
$updatedConf['memory_limit'] = $httpData->memory_limit;
|
||||
}
|
||||
|
||||
if ($sysConf['proxy_host'] != $httpData->proxy_host) {
|
||||
$updatedConf['proxy_host'] = $httpData->proxy_host;
|
||||
}
|
||||
@@ -126,7 +121,7 @@ class adminProxy extends HttpProxyController
|
||||
$msg = ", Host -> " . $httpData->proxy_host . ", Port -> " . $httpData->proxy_port . ", User -> " . $httpData->proxy_user;
|
||||
}
|
||||
|
||||
G::auditLog("UploadSystemSettings", "Time Zone -> " . $httpData->time_zone . ", Memory Limit -> " . $httpData->memory_limit . ", Cookie lifetime -> " . $httpData->max_life_time . ", Default Skin -> " . $httpData->default_skin . ", Default Language -> " . $httpData->default_lang . $msg);
|
||||
G::auditLog("UploadSystemSettings", "Time Zone -> " . $httpData->time_zone . ", Cookie lifetime -> " . $httpData->max_life_time . ", Default Skin -> " . $httpData->default_skin . ", Default Language -> " . $httpData->default_lang . $msg);
|
||||
}
|
||||
|
||||
public function uxUserUpdate($httpData)
|
||||
@@ -1584,12 +1579,6 @@ class adminProxy extends HttpProxyController
|
||||
*/
|
||||
public static function validateDataSystemConf($httpData, $envFile)
|
||||
{
|
||||
if (!((is_numeric($httpData->memory_limit)) && ((int)$httpData->memory_limit == $httpData->memory_limit) &&
|
||||
((int)$httpData->memory_limit >= -1))
|
||||
) {
|
||||
throw new Exception(G::LoadTranslation('ID_MEMORY_LIMIT_VALIDATE'));
|
||||
}
|
||||
|
||||
if (!((is_numeric($httpData->max_life_time)) && ((int)$httpData->max_life_time == $httpData->max_life_time) &&
|
||||
((int)$httpData->max_life_time > 0))
|
||||
) {
|
||||
|
||||
@@ -376,9 +376,7 @@ class Installer
|
||||
}
|
||||
|
||||
//ACTIVE ENTERPRISE
|
||||
|
||||
ini_set('max_execution_time', '0');
|
||||
ini_set('memory_limit', '256M');
|
||||
|
||||
$serv = 'http://';
|
||||
if (isset($_SERVER['HTTPS']) && trim($_SERVER['HTTPS']) != '') {
|
||||
|
||||
@@ -36,7 +36,6 @@ class System
|
||||
'debug_time' => 0,
|
||||
'debug_calendar' => 0,
|
||||
'wsdl_cache' => 1,
|
||||
'memory_limit' => "256M",
|
||||
'time_zone' => 'America/New_York',
|
||||
'expiration_year' => '1',
|
||||
'memcached' => 0,
|
||||
|
||||
@@ -1,32 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace ProcessMaker\Util;
|
||||
|
||||
use WsResponse;
|
||||
|
||||
class WsMessageResponse extends WsResponse
|
||||
{
|
||||
private $appMessUid = null;
|
||||
|
||||
/**
|
||||
* Get the appMessUid
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
public function getAppMessUid()
|
||||
{
|
||||
return $this->appMessUid;
|
||||
}
|
||||
|
||||
/**
|
||||
* Set the appMessUid
|
||||
*
|
||||
* @param string $v
|
||||
* @return void
|
||||
*/
|
||||
public function setAppMessUid($v)
|
||||
{
|
||||
$this->appMessUid = $v;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -96,21 +96,6 @@ Ext.onReady(function(){
|
||||
items: [
|
||||
cmbTimeZone,
|
||||
{
|
||||
xtype: 'numberfield',
|
||||
id: 'memory_limit',
|
||||
name: 'memory_limit',
|
||||
fieldLabel: _('ID_MEMORY_LIMIT'),
|
||||
allowBlank: false,
|
||||
allowDecimals: false,
|
||||
minValue: -1,
|
||||
autoCreate: {tag: "input", type: "text", autocomplete: "off", maxlength: 15},
|
||||
value: sysConf.memory_limit,
|
||||
listeners: {
|
||||
change: function () {
|
||||
changeSettings();
|
||||
}
|
||||
}
|
||||
}, {
|
||||
xtype: 'numberfield',
|
||||
id: 'max_life_time',
|
||||
name: 'max_life_time',
|
||||
|
||||
@@ -52,7 +52,6 @@ $config = PmSystem::getSystemConfiguration();
|
||||
$filter = new InputFilter();
|
||||
$config['display_errors'] = $filter->validateInput($config['display_errors']);
|
||||
$config['error_reporting'] = $filter->validateInput($config['error_reporting']);
|
||||
$config['memory_limit'] = $filter->validateInput($config['memory_limit']);
|
||||
$config['wsdl_cache'] = $filter->validateInput($config['wsdl_cache'], 'int');
|
||||
$config['time_zone'] = $filter->validateInput($config['time_zone']);
|
||||
// Do not change any of these settings directly, use env.ini instead
|
||||
@@ -60,7 +59,6 @@ ini_set('display_errors', $filter->validateInput($config['display_errors']));
|
||||
ini_set('error_reporting', $filter->validateInput($config['error_reporting']));
|
||||
ini_set('short_open_tag', 'On');
|
||||
ini_set('default_charset', "UTF-8");
|
||||
ini_set('memory_limit', $filter->validateInput($config['memory_limit']));
|
||||
ini_set('soap.wsdl_cache_enabled', $config['wsdl_cache']);
|
||||
ini_set('date.timezone',
|
||||
(isset($_SESSION['__SYSTEM_UTC_TIME_ZONE__']) && $_SESSION['__SYSTEM_UTC_TIME_ZONE__']) ? 'UTC' : $config['time_zone']); //Set Time Zone
|
||||
|
||||
@@ -315,7 +315,6 @@ ini_set('display_errors', $config['display_errors']);
|
||||
ini_set('error_reporting', $config['error_reporting']);
|
||||
ini_set('short_open_tag', 'On');
|
||||
ini_set('default_charset', "UTF-8");
|
||||
ini_set('memory_limit', $config['memory_limit']);
|
||||
ini_set('soap.wsdl_cache_enabled', $config['wsdl_cache']);
|
||||
ini_set('date.timezone',
|
||||
(isset($_SESSION['__SYSTEM_UTC_TIME_ZONE__']) && $_SESSION['__SYSTEM_UTC_TIME_ZONE__']) ? 'UTC' : $config['time_zone']); //Set Time Zone
|
||||
@@ -572,7 +571,6 @@ ini_set('display_errors', $config['display_errors']);
|
||||
ini_set('error_reporting', $config['error_reporting']);
|
||||
ini_set('short_open_tag', 'On');
|
||||
ini_set('default_charset', "UTF-8");
|
||||
ini_set('memory_limit', $config['memory_limit']);
|
||||
ini_set('soap.wsdl_cache_enabled', $config['wsdl_cache']);
|
||||
ini_set('date.timezone', TIME_ZONE); //Set Time Zone
|
||||
|
||||
|
||||
Reference in New Issue
Block a user