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

PM-767 "BPMN Designer Añr lista de messages"

Browse Source 
> ProcessMaker-MA "Message (endpoints)"
  - Se han implementado los siguientes Endpoints:
  GET    /api/1.0/{workspace}/project/{prj_uid}/message-types/{msgt_uid}
  GET    /api/1.0/{workspace}/project/{prj_uid}/message-type/{msgt_uid}
  POST   /api/1.0/{workspace}/project/{prj_uid}/message-type
  PUT    /api/1.0/{workspace}/project/{prj_uid}/message-type/{msgt_uid}
  DELETE /api/1.0/{workspace}/project/{prj_uid}/message-type/{msgt_uid}
- Se han implementado los metodos necesarios para el Export, Import y Delete (delete Process) de este nuevo "Objeto"
This commit is contained in:
Luis Fernando Saisa Lopez
2015-02-04 17:18:32 -04:00
parent 4f1d370708
commit 02d91e90a6
26 changed files with 2227 additions and 1035 deletions
Download Patch File Download Diff File Expand all files Collapse all files

244
workflow/engine/classes/class.processes.php
View File

@@ -663,6 +663,48 @@ class Processes
return $sNewUid;
}
/**
* Get an unused unique id for Message-Type
*
* @return string $uid
*/
public function getUnusedMessageTypeUid()
{
try {
$messageType = new \ProcessMaker\BusinessModel\MessageType();
do {
$newUid = \ProcessMaker\Util\Common::generateUID();
} while ($messageType->exists($newUid));
return $newUid;
} catch (Exception $e) {
throw $e;
}
}
/**
* Get an unused unique id for Message-Type-Variable
*
* @return string $uid
*/
public function getUnusedMessageTypeVariableUid()
{
try {
$variable = new \ProcessMaker\BusinessModel\MessageType\Variable();
do {
$newUid = \ProcessMaker\Util\Common::generateUID();
} while ($variable->exists($newUid));
return $newUid;
} catch (Exception $e) {
throw $e;
}
}
/**
* change the GUID for a serialized process
*
@@ -800,6 +842,12 @@ class Processes
}
}
if (isset($oData->messageType)) {
foreach ($oData->messageType as $key => $value) {
$oData->messageType[$key]["PRJ_UID"] = $sNewProUid;
}
}
return true;
}
@@ -2212,6 +2260,77 @@ class Processes
throw $e;
}
}
/**
* Renew all the unique id for Message-Type
*
* @param object $data Object with the data
*
* return void
*/
public function renewAllMessageTypeUid(&$data)
{
try {
$map = array();
foreach ($data->messageType as $key => $value) {
$record = $value;
if (isset($record["MSGT_UID"])) {
$newUid = $this->getUnusedMessageTypeUid();
$map[$record["MSGT_UID"]] = $newUid;
$data->messageType[$key]["MSGT_UID"] = $newUid;
}
}
$data->uid["MESSAGE_TYPE"] = $map;
if (isset($data->messageTypeVariable)) {
foreach ($data->messageTypeVariable as $key => $value) {
$record = $value;
if (isset($map[$record["MSGT_UID"]])) {
$newUid = $map[$record["MSGT_UID"]];
$data->messageTypeVariable[$key]["MSGT_UID"] = $newUid;
}
}
}
} catch (Exception $e) {
throw $e;
}
}
/**
* Renew all the unique id for Message-Type-Variable
*
* @param object $data Object with the data
*
* return void
*/
public function renewAllMessageTypeVariableUid(&$data)
{
try {
$map = array();
foreach ($data->messageTypeVariable as $key => $value) {
$record = $value;
if (isset($record["MSGTV_UID"])) {
$newUid = $this->getUnusedMessageTypeVariableUid();
$map[$record["MSGTV_UID"]] = $newUid;
$data->messageTypeVariable[$key]["MSGTV_UID"] = $newUid;
}
}
$data->uid["MESSAGE_TYPE_VARIABLE"] = $map;
} catch (Exception $e) {
throw $e;
}
}
/**
* Renew the GUID's for all the Uids for all the elements
*
@@ -2242,6 +2361,8 @@ class Processes
$this->renewAllCaseScheduler( $oData );
$this->renewAllProcessUserUid($oData);
$this->renewAllProcessVariableUid($oData);
$this->renewAllMessageTypeUid($oData);
$this->renewAllMessageTypeVariableUid($oData);
}
/**
@@ -2891,6 +3012,71 @@ class Processes
}
}
public function getMessageTypes($processUid)
{
try {
$arrayMessageType = array();
$messageType = new \ProcessMaker\BusinessModel\MessageType();
//Get data
$criteria = new Criteria("workflow");
$criteria->addSelectColumn(MessageTypePeer::MSGT_UID);
$criteria->add(MessageTypePeer::PRJ_UID, $processUid, Criteria::EQUAL);
$rsCriteria = MessageTypePeer::doSelectRS($criteria);
$rsCriteria->setFetchmode(ResultSet::FETCHMODE_ASSOC);
while ($rsCriteria->next()) {
$row = $rsCriteria->getRow();
$arrayAux = $messageType->getMessageType($row["MSGT_UID"], true);
unset($arrayAux["MSGT_VARIABLES"]);
$arrayMessageType[] = $arrayAux;
}
//Return
return $arrayMessageType;
} catch (Exception $e) {
throw $e;
}
}
public function getMessageTypeVariables($processUid)
{
try {
$arrayVariable = array();
$variable = new \ProcessMaker\BusinessModel\MessageType\Variable();
//Get data
$criteria = new Criteria("workflow");
$criteria->addSelectColumn(MessageTypeVariablePeer::MSGTV_UID);
$criteria->addJoin(MessageTypePeer::MSGT_UID, MessageTypeVariablePeer::MSGT_UID, Criteria::LEFT_JOIN);
$criteria->add(MessageTypePeer::PRJ_UID, $processUid, Criteria::EQUAL);
$rsCriteria = MessageTypeVariablePeer::doSelectRS($criteria);
$rsCriteria->setFetchmode(ResultSet::FETCHMODE_ASSOC);
while ($rsCriteria->next()) {
$row = $rsCriteria->getRow();
$arrayVariable[] = $variable->getMessageTypeVariable($row["MSGTV_UID"], true);
}
//Return
return $arrayVariable;
} catch (Exception $e) {
throw $e;
}
}
/**
* Get Task User Rows from an array of data
*
@@ -3079,6 +3265,59 @@ class Processes
}
}
/**
* Create Message-Type records
*
* @param array $arrayData Data
*
* return void
*/
public function createMessageType(array $arrayData)
{
try {
$messageType = new \ProcessMaker\BusinessModel\MessageType();
foreach ($arrayData as $value) {
$record = $value;
if ($messageType->exists($record["MSGT_UID"])) {
$messageType->delete($record["MSGT_UID"]);
}
$result = $messageType->singleCreate($record);
}
} catch (Exception $e) {
throw $e;
}
}
/**
* Create Message-Type-Variable records
*
* @param array $arrayData Data
*
* return void
*/
public function createMessageTypeVariable(array $arrayData)
{
try {
$variable = new \ProcessMaker\BusinessModel\MessageType\Variable();
foreach ($arrayData as $value) {
$record = $value;
if ($variable->exists($record["MSGTV_UID"])) {
$variable->delete($record["MSGTV_UID"]);
}
$result = $variable->singleCreate($record);
}
} catch (Exception $e) {
throw $e;
}
}
/**
* Cleanup Report Tables References from an array of data
*
@@ -3265,7 +3504,8 @@ class Processes
$oData->processVariables = $this->getProcessVariables($sProUid);
$oData->webEntry = $this->getWebEntries($sProUid);
$oData->webEntryEvent = $this->getWebEntryEvents($sProUid);
$oData->messageType = $this->getMessageTypes($sProUid);
$oData->messageTypeVariable = $this->getMessageTypeVariables($sProUid);
$oData->groupwfs = $this->groupwfsMerge($oData->groupwfs, $oData->processUser, "USR_UID");
$oData->process["PRO_TYPE_PROCESS"] = "PUBLIC";
@@ -4310,6 +4550,8 @@ class Processes
$this->createProcessVariables((isset($oData->processVariables))? $oData->processVariables : array());
$this->createWebEntry($arrayProcessData["PRO_UID"], $arrayProcessData["PRO_CREATE_USER"], (isset($oData->webEntry))? $oData->webEntry : array());
$this->createWebEntryEvent($arrayProcessData["PRO_UID"], $arrayProcessData["PRO_CREATE_USER"], (isset($oData->webEntryEvent))? $oData->webEntryEvent : array());
$this->createMessageType((isset($oData->messageType))? $oData->messageType : array());
$this->createMessageTypeVariable((isset($oData->messageTypeVariable))? $oData->messageTypeVariable : array());
}