firstchargeassigment.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.Organization;
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 FirstChargeAssigment 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");
		User user = (User)ci.getTransientVariable("LOGIN_USER");		
		
		//获取一级主管
		String[] actors = getFirstCharge(user);
		
		assignable.setPooledActors(actors);
	}
	
	/**
	 * 获取一级主管审批人
	 * @param user
	 * @return
	 */
	@SuppressWarnings("unchecked")
	private String[] getFirstCharge(User user) {
		UserService userService = (UserService) WAC.getBean("userService");
		Organization o = user.getOrganization();
		
		String[] result = null;
		Map<String, Object> map = new HashMap<String, Object>();
		map.put("isCManager", "true");
		while (o != null ) {
			List list = userService.findByOrgan(o.getId(), map, Integer.valueOf("0"));
			if (list==null || list.size()==0){
				o = o.getParent();
			}else {
				result = new String[list.size()];
				Iterator<User> it = list.iterator();
				int i = 0;
				while (it.hasNext()) {
					result[i] = it.next().getId();
					i++;
				}
				break;
			}
		}
		
		return result;
	}	
	
}