operationchargeassigment.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;

import com.chinacars.oss.data.appform.exception.ApplicationException;

public class OperationChargeAssigment 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 = getOperationCharge(user);
		if (actors==null || actors.length==0){
			throw new ApplicationException("运营管理部主管未定义！");
		}
		assignable.setPooledActors(actors);
	}

	/**
	 * 获取运营管理部的主管,部门ID==="0101"
	 * @param user 暂时没有用,可为null
	 * @return
	 */
	private String[] getOperationCharge(User user){
		UserService userService = (UserService) WAC.getBean("userService");
		//Organization o = user.getOrganization();
		Map<String, Object> map = new HashMap<String, Object>();
		map.put("isDeptPrincipal", "true");
		List<User> list = userService.findByOrgan("0101", map, Integer.valueOf("0"));
		if (list==null || list.size()==0){
			return new String[] {"yitao-sun"};
			//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;
	}
}