bossassigment.java.svn-base

jbpm工作流 jbpm工作流

package com.chinacars.oss.data.appform.workflow.assignment;

import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import net.sf.jaype.ext.domain.sys.User;
import net.sf.jaype.ext.services.UserService;

import org.jbpm.context.exe.ContextInstance;
import org.jbpm.graph.exe.ExecutionContext;
import org.jbpm.taskmgmt.def.AssignmentHandler;
import org.jbpm.taskmgmt.exe.Assignable;
import org.springframework.web.context.WebApplicationContext;

public class BossAssigment implements AssignmentHandler {

	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;

	private WebApplicationContext WAC;
	
	@Override
	public void assign(Assignable assignable, ExecutionContext executionContext)
			throws Exception {
		//临时变量,用户数据交互的接口
		ContextInstance ci = executionContext.getContextInstance();
		WAC = (WebApplicationContext)ci.getTransientVariable("WEB_APPLICATION_CONTEXT");

		String[] actors = getBossCharge();

		assignable.setPooledActors(actors);
	}
	
	/**
	 * 获取审批人
	 * @param user
	 * @return
	 */
	@SuppressWarnings("unchecked")
	private String[] getBossCharge() {
		UserService userService = (UserService) WAC.getBean("userService");
		Map<String, Object> map = new HashMap<String, Object>();
		map.put("isCeoAssi", "true");
		List list = userService.findByOrgan("0", map, Integer.valueOf("0"));
		if (list==null || list.size()==0){
			return null;
		}
		String[] result = new String[list.size()];
		Iterator<User> it = list.iterator();
		int i = 0;
		while (it.hasNext()) {
			result[i] = it.next().getId();
			i++;
		}

		return result;
	}
}