Activiti: пример создания workflow. Продолжение.

В прошлый раз был рассмотрен пример создания бизнес-процесса на Activiti. В этой статье будет рассмотрен тот же процесс, но с некоторой разницей: начальник будет выбирать не одного исполнителя, а нескольких, и число исполнителей не будет предопределено.

Сценарий практически остается тот же. Задача perform создается также одна, но  попадает в пул, появляясь на рабочих столах у всех выбранных начальником исполнителей. И пока один из юзеров-исполнителей не берет задачу на себя, владелец у задачи не определен. Только тогда, когда задача взята, у нее появляется owner, задача остается на столе, взявшего ее на себя, и исчезает со столов остальных исполнителей.

Для описания такого рода задачи (pooled task) в activiti вместо атрибута activiti:assignee используется атрибут activiti:candidateUsers или же конструкция potentialOwner. 

Вот так:

<userTask id="perform" name="Исполнение поручения." activiti:formKey="dir:perform" activiti:candidateUsers="ivanov, petrov" >

 Или же так:

<userTask id="perform" name="Исполнение поручения." activiti:formKey="dir:perform" >
  <potentialOwner>
    <resourceAssignmentExpression>
      <formalExpression>ivanov, petrov</formalExpression>
    </resourceAssignmentExpression>
  </potentialOwner>
</userTask>

 При этом мы должны помнить, что переменная, которую принимает конструкция <formalExpression> ,  обязательно должна быть типа Collеction. Т е мы не можем просто создать строку, а затем посадить ее в эту конструкцию.

К примеру, следующее описание даст ошибку "Variable performers' is not a Collection":

...
 
<userTask id="inspection" name="Ознакомиться с документом и передать на исполнение." activiti:formKey="dir:inspection" >
  <extensionElements>
    <activiti:taskListener event="complete" class="org.alfresco.repo.workflow.activiti.tasklistener.ScriptTaskListener">
      <activiti:field name="script">
	<activiti:string>
	  var performers = "ivanov, petrov";
	  execution.setVariable('performers', performers);
        </activiti:string>
      </activiti:field>
    </activiti:taskListener>
  </extensionElements>
</userTask>

...
 
<userTask id="perform" name="Исполнение поручения." activiti:formKey="dir:perform" activiti:candidateUsers="${performers}">
... 
</userTask>
 
...

Что же делать в этом случае? Можно решить эту проблему, создав свой JavaScript scoped object, который и будет конвертировать нашу строку в соответствующий тип. Для этого опишем класс StringConverter:

package ru.ossportal.util;
 
import java.util.*;
import org.alfresco.repo.processor.BaseProcessorExtension;
 
public class StringConverter extends BaseProcessorExtension {
 
	public List<String> convert(String s) {
		List<String> list = new ArrayList<String>(Arrays.asList(s.split(",")));
		return list;
	}	
}

 Как видите, все, что делает метод convert - это принимает строку "ivanov, petrov" и возвращает уже соответствующий тип. Скомпилированый, а затем собраный в jar код помещаем в ALFRESCO_HOME/tomcat/webapps/alfresco/lib

Пишем к нему контекст ossportal-util-context.xml:

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC '-//SPRING//DTD BEAN//EN' 'http://www.springframework.org/dtd/spring-beans.dtd'>
<beans>
 
    <bean id="converter" parent="baseJavaScriptExtension" class="ru.ossportal.util.StringConverter">
        <property name="extensionName">
            <value>converter</value>
        </property>
    </bean>
 
</beans>

и помещаем его в ALFRESCO_HOME/tomcat/shared/classes/alfresco/extension

После чего мы можем использовать наш конвертер в процессе:

...
 
<userTask id="inspection" name="Ознакомиться с документом и передать на исполнение." activiti:formKey="dir:inspection" >
  <extensionElements>
    <activiti:taskListener event="complete" class="org.alfresco.repo.workflow.activiti.tasklistener.ScriptTaskListener">
      <activiti:field name="script">
	<activiti:string>
	  var performersString = "ivanov, petrov";
          vat performers = converter.convert(performersString);
	  execution.setVariable('performers', performers);
        </activiti:string>
      </activiti:field>
    </activiti:taskListener>
  </extensionElements>
</userTask>
 
...
 
<userTask id="perform" name="Исполнение поручения." activiti:formKey="dir:perform" activiti:candidateUsers="${performers}">
 
</userTask>
 
...

 А теперь давайте рассмотрим все вышеперечисленное в коде нашего workflow․ Для того, чтобы переписать наш workflow так, чтобы исполнители назначались динамически, а задача шла в пул,  мы должны изменить не только процесс, но и модель следующим образом:

<?xml version="1.0" encoding="UTF-8"?>
<!-- Описание модели бизнес-процесса -->
<model name="dir:workflowmodel" xmlns="http://www.alfresco.org/model/dictionary/1.0">
 
	<!-- Импорт необходимых описаний -->
	<imports>
		<import uri="http://www.alfresco.org/model/dictionary/1.0" prefix="d" />
		<import uri="http://www.alfresco.org/model/bpm/1.0" prefix="bpm" />
		<import uri="http://www.alfresco.org/model/content/1.0" prefix="cm"/>
	</imports>
 
	<!-- Описываем пространство имен для нашего процесса -->
	<namespaces>
		<namespace uri="http://www.somecompany.ru/model/workflow/1.0" prefix="dir" />
	</namespaces>
 
	<types>
		<!-- Подача директивы -->
		<type name="dir:start">
			<!-- Наследуем от bpm:startTask -->
			<parent>bpm:startTask</parent>
			<!-- Указываем обязательные аспекты -->
			<mandatory-aspects>
				<!-- Начальник подразделения -->
				<aspect>bpm:assignee</aspect>
			</mandatory-aspects>
		</type>
 
		<!-- Ознакомление с директивой и передача на исполнение -->
		<type name="dir:inspection">
			<!-- Наследуем от bpm:workflowTask -->
			<parent>bpm:workflowTask</parent>
 
			<!-- Доступ к документам пакета -->
			<overrides>
				<!-- Документ может быть добавлен -->
				<property name="bpm:packageActionGroup">
					<default>add_package_item_actions</default>
				</property>
				<!-- Документ может быть отредактирован -->
				<property name="bpm:packageItemActionGroup">
					<default>edit_package_item_actions</default>
				</property>
			</overrides>
				<!-- Указываем обязательные аспекты -->
				<mandatory-aspects>
					<!-- Исполнители -->
					<aspect>dir:performers</aspect>
				</mandatory-aspects>
		</type>
 
		<!-- Исполнение поручения -->
		<type name="dir:perform">
			<parent>bpm:workflowTask</parent>
			<!-- Доступ к документам пакета -->
			<overrides>
				<!-- Документ может быть добавлен -->
				<property name="bpm:packageActionGroup">
					<default>add_package_item_actions</default>
				</property>
				<!-- Документ может быть отредактирован -->
				<property name="bpm:packageItemActionGroup">
					<default>edit_package_item_actions</default>
				</property>
			</overrides>
		</type>
 
		<!-- Проверка исполнения -->
		<type name="dir:approve">
			<!-- Наследуем от bpm:activitiOutcomeTask -->
			<!-- Новый объект, появился с введением activiti в альфреско -->
			<parent>bpm:activitiOutcomeTask</parent>
			<!-- Свойства -->
			<properties>
				<!-- Утвердить исполнение или же отправить на доработку -->
				<property name="dir:appOutcome">
					<type>d:text</type>
					<default>reject</default>
					<constraints>
						<constraint name="dir:propAppOutcome" type="LIST">
							<parameter name="allowedValues">
								<list>
									<!-- Утвердить -->
									<value>approve</value>
									<!-- Отправить на доработку -->
									<value>reject</value>
								</list>
							</parameter>
							<parameter name="caseSensitive">
								<value>true</value>
							</parameter>
						</constraint>
					</constraints>
				</property>
			</properties>
			<!-- Доступ к документам пакета -->
			<overrides>
				<!-- Документ может быть добавлен -->
				<property name="bpm:packageActionGroup">
					<default>add_package_item_actions</default>
				</property>
				<!-- Документ может быть отредактирован -->
				<property name="bpm:packageItemActionGroup">
					<default>edit_package_item_actions</default>
				</property>
			</overrides>
		</type>
	</types>
 
	<aspects>
		<aspect name="dir:performers">
			<associations>
				<association name="dir:performers">
					<source>
						<mandatory>true</mandatory>
						<many>false</many>
					</source>
					<target>
						<class>cm:person</class>
						<mandatory>true</mandatory>
						<!-- Исполнителей может быть много -->
						<many>true</many>
					</target>
				</association>
			</associations>
		</aspect>
	</aspects>
</model>

Как видите, от предыдущей темы модель отличается лишь тем, что аспект dir:performer переименовывается в dir:performers, а значение элемента many меняется на true.

Теперь опишем процесс:

<?xml version="1.0" encoding="UTF-8" ?>
 
<!-- Объявление необходимых пространств имен -->
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:activiti="http://activiti.org/bpmn"
	xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC"
	xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema"
	expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
 
	<!-- Начало описания процесса -->
	<process id="PerformDirective" name="Исполнение внешних директив">
 
		<!-- Начальный узел процесса -->
		<startEvent id="start"	activiti:formKey="dir:start" />
 
		<!-- Переход от старта к задаче ознакомления с директивой -->
		<sequenceFlow id='flow1' sourceRef='start' targetRef='inspection' />
 
		<!-- Ознакомление с директивой и передача на исполнение -->
		<userTask id="inspection" name="Ознакомиться с документом и передать на исполнение."	
			activiti:formKey="dir:inspection" >
			<extensionElements>
				<!-- Скрипт при создании задачи -->
				<!-- Устанавливаем срок исполнения и приоритет, если те не указаны -->
				<!-- Запоминаем начальника -->
				<activiti:taskListener event="create" 
					class="org.alfresco.repo.workflow.activiti.tasklistener.ScriptTaskListener">
					<activiti:field name="script">
						<activiti:string>
							if (typeof bpm_workflowDueDate != 'undefined') task.dueDate = bpm_workflowDueDate
							if (typeof bpm_workflowPriority != 'undefined') task.priority = bpm_workflowPriority;
							execution.setVariable('manager', bpm_assignee.properties.userName);
						</activiti:string>
					</activiti:field>
				</activiti:taskListener>
				<!-- Скрипт при закрытии задачи -->
				<!-- Создаем строку, в которую запишем через запятую -->
				<!-- все userName исполнителей -->
				<!-- Затем конвертируем строку в переменную типа Collection и запоминаем ее -->
				<activiti:taskListener event="complete" 
					class="org.alfresco.repo.workflow.activiti.tasklistener.ScriptTaskListener">
					<activiti:field name="script">
						<activiti:string>
							var performers = task.getVariable('dir_performers');
							var performersString = "";
							<![CDATA[
								for (var i=0; i<performers.size(); i++ ) {
									if (i>0) performersString += ","; 
									performersString += performers.get(i).properties.userName;
								}
							]]>
							var userList = converter.convert(performersString);
							execution.setVariable('performers', userList);
						</activiti:string>
					</activiti:field>
				</activiti:taskListener>
			</extensionElements>
			<!-- Задача для начальника -->
			<humanPerformer>
				<resourceAssignmentExpression>
					<formalExpression>${bpm_assignee.properties.userName}</formalExpression>
				</resourceAssignmentExpression>
			</humanPerformer>
		</userTask>
 
		<!-- Переход от ознакомления с директивой к исполнениию -->
		<sequenceFlow id='flow2' sourceRef='inspection' targetRef='perform' />
 
		<!--Исполнение поручения -->
		<!-- Задача идет в пул, сформированный из списка исполнителей -->
		<userTask id="perform" name="Исполнение поручения."	activiti:formKey="dir:perform" 
			activiti:candidateUsers="${performers}" >
			<extensionElements>
				<!-- Скрипт при создании задачи -->
				<!-- Устанавливаем срок исполнения и приоритет, если те не указаны -->
				<activiti:taskListener event="create" 
					class="org.alfresco.repo.workflow.activiti.tasklistener.ScriptTaskListener">
					<activiti:field name="script">
						<activiti:string>
							if (typeof bpm_workflowDueDate != 'undefined') task.dueDate = bpm_workflowDueDate
							if (typeof bpm_workflowPriority != 'undefined') task.priority = bpm_workflowPriority;
						</activiti:string>
					</activiti:field>
				</activiti:taskListener>
			</extensionElements>
		</userTask>
 
		<!-- Переход от исполнениия к проверке исполнения -->
		<sequenceFlow id='flow3' sourceRef='perform' targetRef='approve' />
 
		<!-- Проверка исполнения -->
		<!-- Задача для начальника -->
		<userTask id="approve" name="Проверить исполнение поручения."	activiti:formKey="dir:approve"
			activiti:assignee="${manager}" >
			<extensionElements>
				<!-- Скрипт при создании задачи -->
				<!-- Устанавливаем срок исполнения и приоритет, если те не указаны -->
				<activiti:taskListener event="create" 
					class="org.alfresco.repo.workflow.activiti.tasklistener.ScriptTaskListener">
					<activiti:field name="script">
						<activiti:string>
							if (typeof bpm_workflowDueDate != 'undefined') task.dueDate = bpm_workflowDueDate
							if (typeof bpm_workflowPriority != 'undefined') task.priority = bpm_workflowPriority;
						</activiti:string>
					</activiti:field>
				</activiti:taskListener>
				<!-- Скрипт при закрытии задачи -->
				<!-- Устанавливаем результат -->
				<activiti:taskListener event="complete" 
					class="org.alfresco.repo.workflow.activiti.tasklistener.ScriptTaskListener">
					<activiti:field name="script">
						<activiti:string>
							execution.setVariable('dir_appOutcome', task.getVariable('dir_appOutcome'));
						</activiti:string>
					</activiti:field>
				</activiti:taskListener>
			</extensionElements>
		</userTask>
 
		<!-- Переход от проверки исполнения к развилке -->
		<sequenceFlow id='flow4' sourceRef='approve' targetRef='decision' />
 
		<!-- Развилка: вернуться ли к исполнению или же окончить процесс -->
		<exclusiveGateway id="decision" name="Decision" /> 
 
		<!-- Исполнение не утверждено: вернуться к задаче исполнения -->
		<sequenceFlow id='flow5' sourceRef='decision' targetRef='perform' >
			<conditionExpression xsi:type="tFormalExpression">${dir_appOutcome == 'reject'}</conditionExpression>
		</sequenceFlow>
 
		<!-- Исполнение утверждено: окончить процесс -->
		<sequenceFlow id='flow6' sourceRef='decision' targetRef='end' />
 
		<!-- Конец процесса -->
		<endEvent id="end" />
 
	</process>
</definitions>

Теперь начальник выбирает несколько исполнителей и задача идет в пул к этим исполнителям.