14.4. フォームまたはプロセスでのドキュメントの添付

手順

1. org.kie.api.marshalling.ObjectMarshallingStrategy インターフェイスの実装を含むカスタムマーシャリングストラテジー .java ファイルを作成します。このインターフェイスを使用すると、カスタムドキュメントマーシャリングストラテジーに必要な変数の永続性を実装できます。

   このインターフェイスの以下のメソッドは、戦略の作成に役立ちます。

   • boolean accept(Object object): 指定されたオブジェクトをストラテジーでマーシャリングできるかどうかを決定します。
   • byte[] marshal(Context context, ObjectOutputStream os, Object object): 指定されたオブジェクトをマーシャリングし、マーシャリングされたオブジェクトを byte[] として返します。
   • Object unmarshal(Context context, ObjectInputStream is, byte[] object, ClassLoader classloader): 受け取ったオブジェクトを byte[] として読み取り、マーシャリングされていないオブジェクトを返します。
   • void write(ObjectOutputStream os, Object object): 下位互換性のために提供されている marshal メソッドと同じです。
   • Object read(ObjectInputStream os): 下位互換性のために提供されている unmarshal メソッドと同じです。

   以下のコードサンプルは、コンテンツ管理相互運用サービス (CMIS) システムからデータを保存および取得するための ObjectMarshallingStrategy 実装例です。

   CMIS システムからデータを保存および取得するための実装例

   package org.jbpm.integration.cmis.impl;
   
   import java.io.ByteArrayInputStream;
   import java.io.ByteArrayOutputStream;
   import java.io.IOException;
   import java.io.ObjectInputStream;
   import java.io.ObjectOutputStream;
   import java.util.HashMap;
   
   import org.apache.chemistry.opencmis.client.api.Folder;
   import org.apache.chemistry.opencmis.client.api.Session;
   import org.apache.chemistry.opencmis.commons.data.ContentStream;
   import org.apache.commons.io.IOUtils;
   import org.drools.core.common.DroolsObjectInputStream;
   import org.jbpm.document.Document;
   import org.jbpm.integration.cmis.UpdateMode;
   
   import org.kie.api.marshalling.ObjectMarshallingStrategy;
   
   public class OpenCMISPlaceholderResolverStrategy extends OpenCMISSupport implements ObjectMarshallingStrategy {
   
   	private String user;
   	private String password;
   	private String url;
   	private String repository;
   	private String contentUrl;
   	private UpdateMode mode = UpdateMode.OVERRIDE;
   
   	public OpenCMISPlaceholderResolverStrategy(String user, String password, String url, String repository) {
   		this.user = user;
   		this.password = password;
   		this.url = url;
   		this.repository = repository;
   	}
   
   	public OpenCMISPlaceholderResolverStrategy(String user, String password, String url, String repository, UpdateMode mode) {
   		this.user = user;
   		this.password = password;
   		this.url = url;
   		this.repository = repository;
   		this.mode = mode;
   	}
   
   	   public OpenCMISPlaceholderResolverStrategy(String user, String password, String url, String repository, String contentUrl) {
   	        this.user = user;
   	        this.password = password;
   	        this.url = url;
   	        this.repository = repository;
   	        this.contentUrl = contentUrl;
   	    }
   
   	    public OpenCMISPlaceholderResolverStrategy(String user, String password, String url, String repository, String contentUrl, UpdateMode mode) {
   	        this.user = user;
   	        this.password = password;
   	        this.url = url;
   	        this.repository = repository;
   	        this.contentUrl = contentUrl;
   	        this.mode = mode;
   	    }
   
   	public boolean accept(Object object) {
   		if (object instanceof Document) {
   			return true;
   		}
   		return false;
   	}
   
   	public byte[] marshal(Context context, ObjectOutputStream os, Object object) throws IOException {
   		Document document = (Document) object;
   		Session session = getRepositorySession(user, password, url, repository);
   		try {
   			if (document.getContent() != null) {
   				String type = getType(document);
   				if (document.getIdentifier() == null || document.getIdentifier().isEmpty()) {
   					String location = getLocation(document);
   
   					Folder parent = findFolderForPath(session, location);
   					if (parent == null) {
   						parent = createFolder(session, null, location);
   					}
   					org.apache.chemistry.opencmis.client.api.Document doc = createDocument(session, parent, document.getName(), type, document.getContent());
   					document.setIdentifier(doc.getId());
   					document.addAttribute("updated", "true");
   				} else {
   					if (document.getContent() != null && "true".equals(document.getAttribute("updated"))) {
   						org.apache.chemistry.opencmis.client.api.Document doc = updateDocument(session, document.getIdentifier(), type, document.getContent(), mode);
   
   						document.setIdentifier(doc.getId());
   						document.addAttribute("updated", "false");
   					}
   				}
   			}
   			ByteArrayOutputStream buff = new ByteArrayOutputStream();
   	        ObjectOutputStream oos = new ObjectOutputStream( buff );
   	        oos.writeUTF(document.getIdentifier());
   	        oos.writeUTF(object.getClass().getCanonicalName());
   	        oos.close();
   	        return buff.toByteArray();
   		} finally {
   			session.clear();
   		}
   	}
   
   	public Object unmarshal(Context context, ObjectInputStream ois, byte[] object, ClassLoader classloader) throws IOException, ClassNotFoundException {
   		DroolsObjectInputStream is = new DroolsObjectInputStream( new ByteArrayInputStream( object ), classloader );
   		String objectId = is.readUTF();
   		String canonicalName = is.readUTF();
   		Session session = getRepositorySession(user, password, url, repository);
   		try {
   			org.apache.chemistry.opencmis.client.api.Document doc = (org.apache.chemistry.opencmis.client.api.Document) findObjectForId(session, objectId);
   			Document document = (Document) Class.forName(canonicalName).newInstance();
   			document.setAttributes(new HashMap<String, String>());
   
   			document.setIdentifier(objectId);
   			document.setName(doc.getName());
   			document.setLastModified(doc.getLastModificationDate().getTime());
   			document.setSize(doc.getContentStreamLength());
   			document.addAttribute("location", getFolderName(doc.getParents()) + getPathAsString(doc.getPaths()));
   			if (doc.getContentStream() != null && contentUrl == null) {
   				ContentStream stream = doc.getContentStream();
   				document.setContent(IOUtils.toByteArray(stream.getStream()));
   				document.addAttribute("updated", "false");
   				document.addAttribute("type", stream.getMimeType());
   			} else {
   			    document.setLink(contentUrl + document.getIdentifier());
   			}
   			return document;
   		} catch(Exception e) {
   			throw new RuntimeException("Cannot read document from CMIS", e);
   		} finally {
   			is.close();
   			session.clear();
   		}
   	}
   
   	public Context createContext() {
   		return null;
   	}
   
   	// For backward compatibility with previous serialization mechanism
   	public void write(ObjectOutputStream os, Object object) throws IOException {
   		Document document = (Document) object;
   		Session session = getRepositorySession(user, password, url, repository);
   		try {
   			if (document.getContent() != null) {
   				String type = document.getAttribute("type");
   				if (document.getIdentifier() == null) {
   					String location = document.getAttribute("location");
   
   					Folder parent = findFolderForPath(session, location);
   					if (parent == null) {
   						parent = createFolder(session, null, location);
   					}
   					org.apache.chemistry.opencmis.client.api.Document doc = createDocument(session, parent, document.getName(), type, document.getContent());
   					document.setIdentifier(doc.getId());
   					document.addAttribute("updated", "false");
   				} else {
   					if (document.getContent() != null && "true".equals(document.getAttribute("updated"))) {
   						org.apache.chemistry.opencmis.client.api.Document doc = updateDocument(session, document.getIdentifier(), type, document.getContent(), mode);
   
   						document.setIdentifier(doc.getId());
   						document.addAttribute("updated", "false");
   					}
   				}
   			}
   			ByteArrayOutputStream buff = new ByteArrayOutputStream();
   	        ObjectOutputStream oos = new ObjectOutputStream( buff );
   	        oos.writeUTF(document.getIdentifier());
   	        oos.writeUTF(object.getClass().getCanonicalName());
   	        oos.close();
   		} finally {
   			session.clear();
   		}
   	}
   
   	public Object read(ObjectInputStream os) throws IOException, ClassNotFoundException {
   		String objectId = os.readUTF();
   		String canonicalName = os.readUTF();
   		Session session = getRepositorySession(user, password, url, repository);
   		try {
   			org.apache.chemistry.opencmis.client.api.Document doc = (org.apache.chemistry.opencmis.client.api.Document) findObjectForId(session, objectId);
   			Document document = (Document) Class.forName(canonicalName).newInstance();
   
   			document.setIdentifier(objectId);
   			document.setName(doc.getName());
   			document.addAttribute("location", getFolderName(doc.getParents()) + getPathAsString(doc.getPaths()));
   			if (doc.getContentStream() != null) {
   				ContentStream stream = doc.getContentStream();
   				document.setContent(IOUtils.toByteArray(stream.getStream()));
   				document.addAttribute("updated", "false");
   				document.addAttribute("type", stream.getMimeType());
   			}
   			return document;
   		} catch(Exception e) {
   			throw new RuntimeException("Cannot read document from CMIS", e);
   		} finally {
   			session.clear();
   		}
   	}
   
   }

2. Business Central で、Menu → Design → Projects に移動します。

3. プロジェクトの名前をクリックしてから、Settings をクリックします。

   図14.4 Settings タブ

   
4. Deployments → Marshalling Strategies→ Add Marshalling Strategy をクリックします。
5. Name フィールドに、この例の org.jbpm.integration.cmis.impl.OpenCMISPlaceholderResolverStrategy のように、カスタムドキュメントマーシャリングストラテジーの識別子を入力します。
6. この例の Reflection のように、Resolver ドロップダウンメニューから関連オプションを選択します。
7. Test をクリックして、デプロイメント記述子ファイルを検証します。

8. Deploy をクリックして、更新されたプロジェクトをビルドおよびデプロイします。

   または、Business Central を使用していない場合は、PROJECT_HOME/src/main/resources/META_INF/kie-deployment-descriptor.xml (該当する場合) に移動し、必要な <marshalling-strategies> 要素を使用してデプロイメント記述子ファイルを編集します。

   カスタムドキュメントマーシャリング戦略を使用したデプロイメント記述子ファイルの例

   <deployment-descriptor
       xsi:schemaLocation="http://www.jboss.org/jbpm deployment-descriptor.xsd"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
     <persistence-unit>org.jbpm.domain</persistence-unit>
     <audit-persistence-unit>org.jbpm.domain</audit-persistence-unit>
     <audit-mode>JPA</audit-mode>
     <persistence-mode>JPA</persistence-mode>
     <runtime-strategy>SINGLETON</runtime-strategy>
     <marshalling-strategies>
       <marshalling-strategy>
         <resolver>reflection</resolver>
         <identifier>
           org.jbpm.integration.cmis.impl.OpenCMISPlaceholderResolverStrategy
         </identifier>
       </marshalling-strategy>
     </marshalling-strategies>

9. カスタムの場所に保存されたドキュメントをフォームおよびプロセスにアタッチできるようにするには、関連するプロセスでドキュメント変数を作成し、Business Central でそのドキュメント変数にタスクの入力と出力をマッピングします。