|
@@ -4,10 +4,7 @@ import com.flow.enums.NotifyTypeEnum;
|
|
|
import com.google.common.collect.Lists;
|
|
|
import lombok.Data;
|
|
|
import lombok.EqualsAndHashCode;
|
|
|
-import org.flowable.bpmn.model.FlowElement;
|
|
|
-import org.flowable.bpmn.model.ImplementationType;
|
|
|
-import org.flowable.bpmn.model.SequenceFlow;
|
|
|
-import org.flowable.bpmn.model.ServiceTask;
|
|
|
+import org.flowable.bpmn.model.*;
|
|
|
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.List;
|
|
@@ -31,6 +28,15 @@ public class NotifyNode extends AssigneeNode {
|
|
|
serviceTask.setAsynchronous(true);
|
|
|
serviceTask.setImplementationType(ImplementationType.IMPLEMENTATION_TYPE_DELEGATEEXPRESSION);
|
|
|
serviceTask.setImplementation("${notifyDelegate}");
|
|
|
+ // 扩展属性
|
|
|
+ FieldExtension subjectExtension = new FieldExtension();
|
|
|
+ subjectExtension.setFieldName("subject");
|
|
|
+ subjectExtension.setExpression(this.subject);
|
|
|
+ serviceTask.getFieldExtensions().add(subjectExtension);
|
|
|
+ FieldExtension contentExtension = new FieldExtension();
|
|
|
+ contentExtension.setFieldName("content");
|
|
|
+ contentExtension.setExpression(this.content);
|
|
|
+ serviceTask.getFieldExtensions().add(contentExtension);
|
|
|
elements.add(serviceTask);
|
|
|
// 下一个节点的连线
|
|
|
Node child = this.getChild();
|