fernando/luos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HOR-2795 El cron no procesa todos los mensajes para los message events cuando hay uno que no puede ser procesado

Browse Source 
- Add validation count get element message Applications.
This commit is contained in:
Marco A. Nina Mena
2017-03-11 09:18:11 -04:00
parent a4c57f329a
commit 9744193eb8
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
workflow/engine/src/ProcessMaker/BusinessModel/MessageApplication.php
View File

@@ -360,6 +360,7 @@ class MessageApplication
*
* @param bool $frontEnd Flag to represent progress bar
*
* @throws \Exception
* @return void
*/
public function catchMessageEvent($frontEnd = false)
@@ -382,6 +383,9 @@ class MessageApplication
$counterIntermediateCatchMessageEvent = 0;
$counter = 0;
$start = 0;
$limit = 1000;
$flagFirstTime = false;
$common->frontEndShow("START");
@@ -389,7 +393,7 @@ class MessageApplication
do {
$flagNextRecords = false;
$arrayMessageApplicationUnread = $this->getMessageApplications(array("messageApplicationStatus" => "UNREAD"), null, null, 0, 1000);
$arrayMessageApplicationUnread = $this->getMessageApplications(array("messageApplicationStatus" => "UNREAD"), null, null, $start, $limit);
if (!$flagFirstTime) {
$totalMessageEvent = $arrayMessageApplicationUnread["total"];
@@ -398,6 +402,7 @@ class MessageApplication
}
foreach ($arrayMessageApplicationUnread["data"] as $value) {
$start++;
if ($counter + 1 > $totalMessageEvent) {
$flagNextRecords = false;
break;
@@ -425,11 +430,11 @@ class MessageApplication
$result = $ws->newCase($processUid, $messageEventDefinitionUserUid, $taskUid, $arrayVariable);
$arrayResult = \G::json_decode(\G::json_encode($result), true);
$appNumber = !empty($arrayResult["caseNumber"]) ? $arrayResult["caseNumber"] : '';
if ($arrayResult["status_code"] == 0) {
$applicationUid = $arrayResult["caseId"];
$appUid = $arrayResult["caseId"];
$appNumber = $arrayResult["caseNumber"];
$aInfo = array(
'ip' => \G::getIpAddress()
,'action' => 'CREATED-NEW-CASE'
@@ -592,12 +597,14 @@ class MessageApplication
}
$flagCatched = true;
break;
}
}
//Counter
if ($flagCatched) {
$counterIntermediateCatchMessageEvent++;
$start--;
}
break;
}