<?php

namespace ProcessMaker\Models;

use DOMElement;

use Exception;

use Illuminate\Database\Eloquent\Relations\HasMany;

use Illuminate\Database\Eloquent\SoftDeletes;

use Illuminate\Support\Arr;

use Illuminate\Support\Facades\Auth;

use Illuminate\Support\Facades\DB;

use Illuminate\Support\Facades\Storage;

use Illuminate\Support\Str;

use Illuminate\Validation\Rule;

use Mustache_Engine;

use ProcessMaker\AssignmentRules\PreviousTaskAssignee;

use ProcessMaker\AssignmentRules\ProcessManagerAssigned;

use ProcessMaker\BpmnEngine;

use ProcessMaker\Contracts\ProcessModelInterface;

use ProcessMaker\Exception\InvalidUserAssignmentException;

use ProcessMaker\Exception\TaskDoesNotHaveRequesterException;

use ProcessMaker\Exception\TaskDoesNotHaveUsersException;

use ProcessMaker\Exception\ThereIsNoProcessManagerAssignedException;

use ProcessMaker\Facades\WorkflowUserManager;

use ProcessMaker\Managers\DataManager;

use ProcessMaker\Nayra\Bpmn\Models\Activity;

use ProcessMaker\Nayra\Contracts\Bpmn\ActivityInterface;

use ProcessMaker\Nayra\Contracts\Bpmn\ScriptTaskInterface;

use ProcessMaker\Nayra\Contracts\Bpmn\ServiceTaskInterface;

use ProcessMaker\Nayra\Contracts\Bpmn\StartEventInterface;

use ProcessMaker\Nayra\Contracts\Storage\BpmnDocumentInterface;

use ProcessMaker\Nayra\Managers\WorkflowManagerDefault;

use ProcessMaker\Nayra\Storage\BpmnDocument;

use ProcessMaker\Package\WebEntry\Models\WebentryRoute;

use ProcessMaker\Rules\BPMNValidation;

use ProcessMaker\Traits\Exportable;

use ProcessMaker\Traits\ExtendedPMQL;

use ProcessMaker\Traits\HasCategories;

use ProcessMaker\Traits\HasSelfServiceTasks;

use ProcessMaker\Traits\HasVersioning;

use ProcessMaker\Traits\HideSystemResources;

use ProcessMaker\Traits\ProcessStartEventAssignmentsTrait;

use ProcessMaker\Traits\ProcessTaskAssignmentsTrait;

use ProcessMaker\Traits\ProcessTimerEventsTrait;

use ProcessMaker\Traits\ProcessTrait;

use ProcessMaker\Traits\ProjectAssetTrait;

use ProcessMaker\Traits\SerializeToIso8601;

use Spatie\MediaLibrary\HasMedia;

use Spatie\MediaLibrary\InteractsWithMedia;

use Throwable;

/**

* Represents a business process definition.

*

* @property string $id

* @property string $process_category_id

* @property string $user_id

* @property string $bpmn

* @property string $description

* @property string $name

* @property string $status

* @property array $start_events

* @property int $manager_id

* @property \Carbon\Carbon $updated_at

* @property \Carbon\Carbon $created_at

*

* @OA\Schema(

* schema="ProcessEditable",

* @OA\Property(property="process_category_id", type="integer", format="id"),

* @OA\Property(property="name", type="string"),

* @OA\Property(property="description", type="string"),

* @OA\Property(property="status", type="string", enum={"ACTIVE", "INACTIVE", "ARCHIVED"}),

* @OA\Property(property="pause_timer_start", type="integer"),

* @OA\Property(property="cancel_screen_id", type="integer"),

* @OA\Property(property="has_timer_start_events", type="boolean"),

* @OA\Property(property="request_detail_screen_id", type="integer", format="id"),

* @OA\Property(property="is_valid", type="integer"),

* @OA\Property(property="package_key", type="string"),

* @OA\Property(property="start_events", type="array", @OA\Items(ref="#/components/schemas/ProcessStartEvents")),

* @OA\Property(property="warnings", type="string"),

* @OA\Property(property="self_service_tasks", type="object"),

* @OA\Property(property="signal_events", type="array", @OA\Items(type="object")),

* @OA\Property(property="category", type="object", @OA\Schema(ref="#/components/schemas/ProcessCategory")),

* @OA\Property(property="manager_id", type="integer", format="id"),

* ),

* @OA\Schema(

* schema="Process",

* allOf={

* @OA\Schema(ref="#/components/schemas/ProcessEditable"),

* @OA\Schema(

* @OA\Property(property="user_id", type="integer", format="id"),

* @OA\Property(property="id", type="string", format="id"),

* @OA\Property(property="deleted_at", type="string", format="date-time"),

* @OA\Property(property="created_at", type="string", format="date-time"),

* @OA\Property(property="updated_at", type="string", format="date-time"),

* @OA\Property(property="notifications", type="object"),

* @OA\Property(property="task_notifications", type="object"),

* )

* }

* ),

* @OA\Schema(

* schema="ProcessStartEvents",

* @OA\Property(property="eventDefinitions", type="object"),

* @OA\Property(property="parallelMultiple", type="boolean"),

* @OA\Property(property="outgoing", type="object"),

* @OA\Property(property="incoming", type="object"),

* @OA\Property(property="id", type="string"),

* @OA\Property(property="name", type="string"),

* ),

* @OA\Schema(

* schema="ProcessWithStartEvents",

* allOf={

* @OA\Schema(ref="#/components/schemas/Process"),

* @OA\Schema(

* @OA\Property(

* property="events",

* type="array",

* @OA\Items(ref="#/components/schemas/ProcessStartEvents"),

* ))

* }

* ),

*

* @OA\Schema(

* schema="ProcessImport",

* allOf={

* @OA\Schema(ref="#/components/schemas/ProcessEditable"),

* @OA\Schema(

* @OA\Property(property="status", type="array", @OA\Items(type="object")),

* @OA\Property(property="assignable", type="array", @OA\Items(type="object")),

* @OA\Property(property="process", @OA\Schema(ref="#/components/schemas/Process"))

* )

* }

* ),

* @OA\Schema(

* schema="ProcessAssignments",

* @OA\Property(property="assignable", type="array", @OA\Items(type="object")),

* @OA\Property(property="cancel_request", type="object"),

* @OA\Property(property="edit_data", type="object"),

* )

*/

class Process extends ProcessMakerModel implements HasMedia, ProcessModelInterface

{

use InteractsWithMedia;

use SerializeToIso8601;

use SoftDeletes;

use ProcessTaskAssignmentsTrait;

use HasVersioning;

use ProcessTimerEventsTrait;

use ProcessStartEventAssignmentsTrait;

use HideSystemResources;

use ExtendedPMQL;

use HasCategories;

use HasSelfServiceTasks;

use ProcessTrait;

use Exportable;

use ProjectAssetTrait;

const categoryClass = ProcessCategory::class;

const ASSIGNMENT_PROCESS = 'Assignment process';

protected $connection = 'processmaker';

/**

* The attributes that aren't mass assignable.

*

* @var array

*/

protected $guarded = [

'id',

'user_id',

'created_at',

'updated_at',

'has_timer_start_events',

'warnings',

];

/**

* The attributes that are dates.

*

* @var array

*/

/**

* The attributes that should be hidden for serialization.

*

* BPMN data will be hidden. It will be able by its getter.

*

* @var array

*/

protected $hidden = [

'bpmn',

'svg',

];

public $requestNotifiableTypes = [

'requester',

'assignee',

'participants',

'manager',

];

public $requestNotificationTypes = [

'started',

'canceled',

'completed',

'error',

'comment',

];

public $taskNotifiableTypes = [

'requester',

'assignee',

'participants',

'manager',

];

public $taskNotificationTypes = [

'assigned',

'completed',

'due',

];

protected $appends = [

'has_timer_start_events',

'projects',

];

protected $casts = [

'start_events' => 'array',

'warnings' => 'array',

'self_service_tasks' => 'array',

'signal_events' => 'array',

'conditional_events' => 'array',

'properties' => 'array',

];

/**

* Category of the process.

*

* @return BelongsTo

*/

public function category()

{

return $this->belongsTo(ProcessCategory::class, 'process_category_id')->withDefault();

}

/**

* Get the associated projects

*/

public function projects()

{

if (!class_exists('ProcessMaker\Package\Projects\Models\Project')) {

// return an empty collection

return new HasMany($this->newQuery(), $this, '', '');

}

return $this->belongsToMany('ProcessMaker\Package\Projects\Models\Project',

'project_assets',

'asset_id',

'project_id',

'id',

'id'

)->wherePivot('asset_type', static::class);

}

// Define the relationship with the ProjectAsset model

public function projectAssets()

{

return $this->belongsToMany('ProcessMaker\Package\Projects\Models\ProjectAsset',

'project_assets', 'asset_id', 'project_id')

->withPivot('asset_type')

->wherePivot('asset_type', static::class)->withTimestamps();

}

public function projectAsset()

{

return $this->belongsToMany('ProcessMaker\Package\Projects\Models\ProjectAsset',

'project_assets',

'asset_id',

'project_id',

)->withTimeStamps();

}

/**

* Notification settings of the process.

*

* @return HasMany

*/

public function notification_settings()

{

return $this->hasMany(ProcessNotificationSetting::class);

}

/**

* Notification settings of the process.

*

* @return object

*/

public function getNotificationsAttribute()

{

$array = [];

foreach ($this->requestNotifiableTypes as $notifiable) {

foreach ($this->requestNotificationTypes as $notification) {

$setting = $this->notification_settings()

->whereNull('element_id')

->where('notifiable_type', $notifiable)

->where('notification_type', $notification)->get();

if ($setting->count()) {

$value = true;

} else {

$value = false;

}

$array[$notifiable][$notification] = $value;

}

}

return (object) $array;

}

/**

* Task notification settings of the process.

*

* @return object

*/

public function getTaskNotificationsAttribute()

{

$array = [];

$elements = $this->notification_settings()

->whereNotNull('element_id')

->get();

foreach ($elements->groupBy('element_id') as $group) {

$elementId = $group->first()->element_id;

foreach ($this->taskNotifiableTypes as $notifiable) {

foreach ($this->taskNotificationTypes as $notification) {

$setting = $group->where('notifiable_type', $notifiable)

->where('notification_type', $notification);

if ($setting->count()) {

$value = true;

} else {

$value = false;

}

$array[$elementId][$notifiable][$notification] = $value;

}

}

}

return (object) $array;

}

/**

* Cancel Screen of the process.

*

* @return BelongsTo

*/

public function cancelScreen()

{

return $this->belongsTo(Screen::class, 'cancel_screen_id');

}

/**

* Validation rules.

*

* @param null $existing

*

* @return array

*/

public static function rules($existing = null)

{

$unique = Rule::unique('processes')->ignore($existing);

return [

'name' => ['required', $unique, 'alpha_spaces'],

'description' => 'required',

'status' => 'in:ACTIVE,INACTIVE,ARCHIVED',

'process_category_id' => 'exists:process_categories,id',

'bpmn' => 'nullable',

];

}

/**

* Get the creator/author of this process.

*/

public function user()

{

return $this->belongsTo(User::class, 'user_id');

}

/**

* Get the users who can start this process

*

* @param string|null $node If null get START from any node

*/

public function usersCanStart($node = null)

{

$relationship = $this->morphedByMany('ProcessMaker\Models\User', 'processable')

->wherePivot('method', 'START');

return $node === null ? $relationship : $relationship->wherePivot('node', $node);

}

/**

* Get the groups who can start this process

*

* @param string|null $node If null get START from any node

*/

public function groupsCanStart($node = null)

{

$relationship = $this->morphedByMany('ProcessMaker\Models\Group', 'processable')

->wherePivot('method', 'START');

return $node === null ? $relationship : $relationship->wherePivot('node', $node);

}

/**

* Scope a query to include only active and inactive but not archived processes

*/

public function scopeNotArchived($query)

{

return $query->whereIn('processes.status', ['ACTIVE', 'INACTIVE']);

}

/**

* Scope a query to include only active processes

*/

public function scopeActive($query)

{

return $query->where('processes.status', 'ACTIVE');

}

/**

* Scope a query to include only inactive processes

*/

public function scopeInactive($query)

{

return $query->where('processes.status', 'INACTIVE');

}

/**

* Scope a query to include only archived processes

*/

public function scopeArchived($query)

{

return $query->where('processes.status', 'ARCHIVED');

}

public function getCollaborations()

{

$this->bpmnDefinitions = app(BpmnDocumentInterface::class, ['process' => $this]);

if ($this->bpmn) {

$this->bpmnDefinitions->loadXML($this->bpmn);

// Load the collaborations if exists

return $this->bpmnDefinitions->getElementsByTagNameNS(BpmnDocument::BPMN_MODEL, 'collaboration');

}

}

/**

* Get the path of the process templates.

*

* @return string

*/

public static function getProcessTemplatesPath()

{

return Storage::disk('process_templates')->path('');

}

/**

* Get a process template by name.

*

* @param string $name

*

* @return string

*/

public static function getProcessTemplate($name)

{

return Storage::disk('process_templates')->get($name);

}

/**

* Category of the process.

*

* @return BelongsTo

*/

public function requests()

{

return $this->hasMany(ProcessRequest::class);

}

/**

* Category of the process.

*

* @return BelongsTo

*/

public function collaborations()

{

return $this->hasMany(ProcessCollaboration::class);

}

/**

* Get the user to whom to assign a task.

*

* @param ActivityInterface $activity

* @param TokenInterface $token

*

* @return User

*/

public function getNextUser(ActivityInterface $activity, ProcessRequestToken $token)

{

$default = $activity instanceof ScriptTaskInterface

|| $activity instanceof ServiceTaskInterface ? 'script' : 'requester';

$assignmentType = $activity->getProperty('assignment', $default);

$config = json_decode($activity->getProperty('config', '{}'), true);

$escalateToManager = $config['escalateToManager'] ?? false;

$definitions = $token->getInstance()->getVersionDefinitions();

$properties = $definitions->findElementById($activity->getId())->getBpmnElementInstance()->getProperties();

$assignmentLock = array_key_exists('assignmentLock', $properties ?? []) ? $properties['assignmentLock'] : false;

$config = array_key_exists('config', $properties ?? []) ? json_decode($properties['config'], true) : [];

$isSelfService = array_key_exists('selfService', $config ?? []) ? $config['selfService'] : false;

if ($assignmentType === 'rule_expression') {

$userByRule = $isSelfService ? null : $this->getNextUserByRule($activity, $token);

if ($userByRule !== null) {

$user = $this->scalateToManagerIfEnabled($userByRule->id, $activity, $token, $assignmentType);

return $this->checkAssignment($token->processRequest, $activity, $assignmentType, $escalateToManager, $user ? User::where('id', $user)->first() : null);

}

}

if (filter_var($assignmentLock, FILTER_VALIDATE_BOOLEAN) === true) {

$user = $this->getLastUserAssignedToTask($activity->getId(), $token->getInstance()->getId());

if ($user) {

return $this->checkAssignment($token->processRequest, $activity, $assignmentType, $escalateToManager, User::where('id', $user)->first());

}

}

switch ($assignmentType) {

case 'user_group':

case 'group':

$user = $this->getNextUserFromGroupAssignment($activity->getId());

break;

case 'user':

$user = $this->getNextUserAssignment($activity->getId());

break;

case 'user_by_id':

$user = $this->getNextUserFromVariable($activity, $token);

break;

case 'process_variable':

$user = $this->getNextUserFromProcessVariable($activity, $token);

break;

case 'requester':

$user = $this->getRequester($activity, $token);

break;

case 'previous_task_assignee':

$rule = new PreviousTaskAssignee();

$user = $rule->getNextUser($activity, $token, $this, $token->getInstance());

break;

case 'process_manager':

$rule = new ProcessManagerAssigned();

$user = $rule->getNextUser($activity, $token, $this, $token->getInstance());

break;

case 'manual':

case 'self_service':

$user = null;

break;

case 'script':

default:

$user = null;

}

// If the self-service toggle is enabled the user must always be null

if ($isSelfService && in_array($assignmentType, ['user_group', 'process_variable', 'rule_expression'])) {

$user = null;

}

$user = $this->scalateToManagerIfEnabled($user, $activity, $token, $assignmentType);

return $this->checkAssignment($token->getInstance(), $activity, $assignmentType, $escalateToManager, $user ? User::where('id', $user)->first() : null);

}

/**

* If user assignment is not valid reassign to Process Manager

*

* @param ProcessRequest $request

* @param ActivityInterface $activity

* @param string $assignmentType

* @param bool $escalateToManager

* @param User|null $user

*

* @return User|null

*/

private function checkAssignment(ProcessRequest $request, ActivityInterface $activity, $assignmentType, $escalateToManager, User $user = null)

{

$config = $activity->getProperty('config') ? json_decode($activity->getProperty('config'), true) : [];

$selfServiceToggle = array_key_exists('selfService', $config ?? []) ? $config['selfService'] : false;

$isSelfService = $selfServiceToggle || $assignmentType === 'self_service';

if ($activity instanceof ScriptTaskInterface

|| $activity instanceof ServiceTaskInterface) {

return $user;

}

if ($user === null) {

if ($isSelfService && !$escalateToManager) {

return null;

}

$user = $request->processVersion->manager;

if (!$user) {

throw new ThereIsNoProcessManagerAssignedException($activity);

}

}

return $user;

}

private function scalateToManagerIfEnabled($user, $activity, $token, $assignmentType)

{

if ($user) {

$assignmentProcess = self::where('name', self::ASSIGNMENT_PROCESS)->first();

if (app()->bound('workflow.UserManager') && $assignmentProcess) {

$config = json_decode($activity->getProperty('config', '{}'), true);

$escalateToManager = $config['escalateToManager'] ?? false;

if ($escalateToManager) {

$user = WorkflowUserManager::escalateToManager($token, $user);

} else {

$res = (new WorkflowManagerDefault)->runProcess($assignmentProcess, 'assign', [

'user_id' => $user,

'process_id' => $this->id,

'request_id' => $token->getInstance()->getId(),

]);

$user = $res['assign_to'];

}

}

}

return $user;

}

/**

* If the assignment type is user_by_id, we need to parse

* mustache syntax with the current data to get the user

* that should be assigned

*

* @param ProcessRequestToken $token

* @return User $user

* @throws InvalidUserAssignmentException

*/

private function getNextUserFromVariable($activity, $token)

{

try {

$userExpression = $activity->getProperty('assignedUsers');

$dataManager = new DataManager();

$instanceData = $dataManager->getData($token);

$mustache = new Mustache_Engine();

$userId = $mustache->render($userExpression, $instanceData);

$user = User::find($userId);

if (!$user) {

throw new InvalidUserAssignmentException($userExpression, $userId);

}

return $user->id;

} catch (Exception $exception) {

return null;

}

}

/*

* Used to assign a user when the task is assigned by variables that have lists

* of users and groups

*/

private function getNextUserFromProcessVariable($activity, $token)

{

// self service tasks should not have a next user

if ($token->getSelfServiceAttribute()) {

return null;

}

$usersVariable = $activity->getProperty('assignedUsers');

$groupsVariable = $activity->getProperty('assignedGroups');

$dataManager = new DataManager();

$instanceData = $dataManager->getData($token);

$assignedUsers = $usersVariable ? Arr::get($instanceData, $usersVariable) : [];

$assignedGroups = $groupsVariable ? Arr::get($instanceData, $groupsVariable) : [];

if (!is_array($assignedUsers)) {

$assignedUsers = [$assignedUsers];

}

if (!is_array($assignedGroups)) {

$assignedGroups = [$assignedGroups];

}

// We need to remove inactive users.

$users = User::whereIn('id', array_unique($assignedUsers))->where('status', 'ACTIVE')->pluck('id')->toArray();

foreach ($assignedGroups as $groupId) {

// getConsolidatedUsers already removes inactive users

$this->getConsolidatedUsers($groupId, $users);

}

return $this->getNextUserFromGroupAssignment($activity->getId(), $users);

}

/**

* Get the next user in a cyclical assignment.

*

* @param string $processTaskUuid

*

* @return binary

* @throws TaskDoesNotHaveUsersException

*/

private function getNextUserFromGroupAssignment($processTaskUuid, $users = null)

{

$last = ProcessRequestToken::where('process_id', $this->id)

->where('element_id', $processTaskUuid)

->orderBy('created_at', 'desc')

->orderBy('id', 'desc')

->first();

if ($users === null) {

$users = $this->getAssignableUsers($processTaskUuid);

}

if (empty($users)) {

return null;

}

sort($users);

if ($last) {

foreach ($users as $user) {

if ($user > $last->user_id) {

return $user;

}

}

}

return $users[0];

}

/**

* Given a request, returns the last user assigned to a task. If it is the

* first time that the task is assigned, null is returned.

*

* @param string $processTaskUuid

*

* @return binary

* @throws TaskDoesNotHaveUsersException

*/

private function getLastUserAssignedToTask($processTaskUuid, $processRequestId)

{

$last = ProcessRequestToken::where('process_id', $this->id)

->where('element_id', $processTaskUuid)

->where('process_request_id', $processRequestId)

->orderBy('created_at', 'desc')

->first();

return $last ? $last->user_id : null;

}

/**

* Get the next user in a user assignment.

*

* @param string $processTaskUuid

*

* @return binary

* @throws TaskDoesNotHaveUsersException

*/

private function getNextUserAssignment($processTaskUuid, $users = null)

{

$last = ProcessRequestToken::where('process_id', $this->id)

->where('element_id', $processTaskUuid)

->orderBy('created_at', 'desc')

->first();

if ($users === null) {

$users = $this->getAssignableUsers($processTaskUuid);

}

if (empty($users)) {

return null;

}

sort($users);

if ($last) {

foreach ($users as $user) {

if ($user > $last->user_id) {

return $user;

}

}

}

return $users[0];

}

/**

* Get the next user if some special assignment is true

*

* @param string $processTaskUuid

*

* @return binary

* @throws TaskDoesNotHaveUsersException

*/

private function getNextUserByRule($activity, $token)

{

$assignmentRules = $activity->getProperty('assignmentRules', null);

$instanceData = $token->getInstance()->getDataStore()->getData();

if ($assignmentRules && $instanceData) {

$list = json_decode($assignmentRules);

$list = ($list === null) ? [] : $list;

foreach ($list as $item) {

$formalExp = new FormalExpression();

$formalExp->setLanguage('FEEL');

$formalExp->setBody($item->expression);

$eval = $formalExp($instanceData);

if ($eval) {

switch ($item->type) {

case 'user_group':

$users = [];

foreach ($item->assignee->users as $user) {

$users[$user] = $user;

}

foreach ($item->assignee->groups as $group) {

$this->getConsolidatedUsers($group, $users);

}

$user = $this->getNextUserFromGroupAssignment(

$activity->getId(),

$users

);

break;

case 'group':

$users = [];

$user = $this->getNextUserFromGroupAssignment(

$activity->getId(),

$this->getConsolidatedUsers($item->assignee, $users)

);

break;

case 'user':

$user = $item->assignee;

break;

case 'requester':

$user = $this->getRequester($activity, $token);

break;

case 'manual':

case 'self_service':

$user = null;

break;

case 'user_by_id':

$mustache = new Mustache_Engine();

$assigneeId = $mustache->render($item->assignee, $instanceData);

$user = $assigneeId;

break;

case 'script':

default:

$user = null;

}

return $user ? User::where('id', $user)->first() : null;

}

}

}

return null;

}

/**

* Evaluates each expression rule and returns the list of groups and users

* that can be assigned to

*

* @param $activity

* @param $token

* @return array

*/

public function getAssigneesFromExpressionRules($activity, $token)

{

$assignmentRules = $activity->getProperty('assignmentRules', null);

$instanceData = $token->getInstance()->getDataStore()->getData();

$groups = [];

$users = [];

$default = [];

if ($assignmentRules && $instanceData) {

$list = json_decode($assignmentRules);

$list = ($list === null) ? [] : $list;

foreach ($list as $item) {

if (is_null($item->expression)) {

$default[] = $item;

continue;

}

$formalExp = new FormalExpression();

$formalExp->setLanguage('FEEL');

$formalExp->setBody($item->expression);

$eval = $formalExp($instanceData);

if ($eval) {

if ($item->type === 'group') {

$groups[] = $item->assignee;

} elseif ($item->type === 'user') {

$users[] = $item->assignee;

}

}

}

// If no rule was applied, use the default configured user/group

if (empty($users) && empty($groups)) {

foreach ($default as $item) {

if ($item->type === 'group') {

$groups[] = $item->assignee;

} elseif ($item->type === 'user') {

$users[] = $item->assignee;

}

}

}

}

return compact('users', 'groups');

}

/**

* Get an array of all assignable users to a task.

*

* @param string $processTaskUuid

*

* @return array

*/

public function getAssignableUsers($processTaskUuid)

{

$assignments = ProcessTaskAssignment::select(['assignment_id', 'assignment_type'])

->where('process_id', $this->id)

->where('process_task_id', $processTaskUuid)

->get();

$users = [];

foreach ($assignments as $assignment) {

if ($assignment->assignment_type === User::class) {

$users[$assignment->assignment_id] = $assignment->assignment_id;

} else { // Group::class

$this->getConsolidatedUsers($assignment->assignment_id, $users);

}

}

return array_values($users);

}

/**

* Get a consolidated list of users within groups.

*

* @param binary $group_id

* @param array $users

*

* @return array

*/

public function getConsolidatedUsers($group_id, array &$users)

{

$users = array_unique(array_merge(

GroupMember::where([

['group_id', '=', $group_id],

['member_type', '=', User::class],

])

->leftjoin('users', 'users.id', '=', 'group_members.member_id')

->where('users.status', 'ACTIVE')->pluck('member_id')->toArray(),

$users

));

$groupMembers = GroupMember::where([

['group_id', '=', $group_id],

['member_type', '=', Group::class],

])

->leftjoin('groups', 'groups.id', '=', 'group_members.member_id')

->where('groups.status', 'ACTIVE')

->pluck('member_id');

foreach ($groupMembers as $groupMember) {

$this->getConsolidatedUsers($groupMember, $users);

}

return $users;

}

/**

* Check if the user belongs to the group

*/

private function doesUserBelongsGroup($userId, $groupId)

{

$isMember = GroupMember::where('group_id', $groupId)

->where('member_type', User::class)

->where('member_id', $userId)

->first();

if ($isMember) {

return true;

} else {

$groupMembers = GroupMember::where('group_id', $groupId)

->where('member_type', Group::class)

->get();

foreach ($groupMembers as $groupMember) {

$belongs = $this->doesUserBelongsGroup($userId, $groupMember->member_id);

if ($belongs) {