基于WPS的电信业务集成场景，第六部分: 人工任务

public class HumanTaskImpl {
	private HumanTaskHandler handler;

	public HumanTaskImpl() {
		super();
		handler = new HumanTaskHandler();
	}

	private Object getMyService() {
		return (Object) ServiceManager.INSTANCE.locateService("self");
	}

	public DataObject retrieveCustomerEvents() {
		return handler.obtainCustomerEvents(false);
	}

	public Boolean completeCustomerEvent(String taskID) {
		return new Boolean(handler.completeTask(taskID));
	}

	public DataObject retrieveEscalatedCustomerEvents() {
		return handler.obtainCustomerEvents(true);
	}
}

public class HumanTaskHandler {

	private HumanTaskManagerService taskManagerService;

	public HumanTaskHandler() {
		super();
		InitialContext ctx=null;
		try {
			ctx = new InitialContext();
		} catch (NamingException e) {
			e.printStackTrace();
		}

		//获得HumanTaskManager服务

		Object myObj=null;
		try {
			myObj = ctx.lookup("com/ibm/task/api/HumanTaskManagerHome");
		} catch (NamingException e1) {
			e1.printStackTrace();
		}

		HumanTaskManagerHome myHome =	
		(HumanTaskManagerHome)javax.rmi.PortableRemoteObject.narrow(myObj,
		com.ibm.task.api.HumanTaskManagerHome.class);
		if(myHome != null)
		{
			try {
				taskManagerService = myHome.create();
			} catch(Exception e2) {
				e2.printStackTrace();
			} 
		}
	}

	/** 
	 *读取WPS中名为CustomerNotificationHTM的人工任务
	 * onlyEscalated表示是否只读取调升的任务
	 */
	public DataObject obtainCustomerEvents(boolean onlyEscalated) {
		BOFactory factory = (BOFactory) new
		ServiceManager().locateService("com/ibm/websphere/bo/BOFactory");
		//创建返回业务对象
		DataObject events =
		factory.create("http://PeonyLibrary","CustomerEvents");
		
		List tList = new ArrayList();
		
		if (taskManagerService!=null)
		{
				QueryResultSet result = null;
				TKIID tkiid = null;
				ClientObjectWrapper input = null;
				ArrayList idList = new ArrayList();
				ArrayList timeList = new ArrayList();
				if(onlyEscalated) {
					result =
					queryTask("TASK.TKIID","(TASK.STATE=TASK.STATE.STATE_READY
					OR TASK.STATE=TASK.STATE.STATE_CLAIMED) AND
					TASK.KIND=TASK.KIND.KIND_PARTICIPATING AND
					WORK_ITEM.REASON=WORK_ITEM.REASON.REASON_ADMINISTRATOR AND
					TASK.IS_ESCALATED=1 AND
					TASK.NAME='CustomerNotificationHTM'");
				}
				else {
					result =
					queryTask("TASK.TKIID","(TASK.STATE=TASK.STATE.STATE_READY
					OR TASK.STATE=TASK.STATE.STATE_CLAIMED) AND
					TASK.KIND=TASK.KIND.KIND_PARTICIPATING AND
					WORK_ITEM.REASON=WORK_ITEM.REASON.REASON_POTENTIAL_OWNER AND
					TASK.NAME='CustomerNotificationHTM'");
				}
				
				for(int a = 0; a < result.size(); a++)
				{
					if (a==0)
						result.first();
					else
						result.next();
					tkiid = (TKIID)result.getOID(1);					
					try {
						//解析任务的输入业务对象
						try {
							input = taskManagerService.
							getInputMessage(tkiid);
						} catch (RemoteException e) {
							e.printStackTrace();
						}
						if (input != null)
						{						
							BusObjImpl y = (BusObjImpl)input.getObject();
							DataObject p = y.getDataObject(0);	
							if(p ！= null) {
								tList.add(p);	
								idList.add(tkiid.toString());
								Task task = 
								taskManagerService.getTask(tkiid);
								
                              timeList.add(task.getActivationTime().getTime());
								
						
								DataObject customer =
								p.getDataObject("customer");
								if(customer != null)
									System.out.println("CustomerID=" +
									customer.getString("custID"));	
									
							}
						}
						
					} catch (Exception e) {
						e.printStackTrace();
					} 
				}
				events.setList("events", tList);
				events.setList("taskIDList", idList);
				events.setList("taskActivationTimeList", timeList);
				return events;
		} 
		
		return null;
	}

	/**
	 * 根据条件查询人工任务
	 */
	private QueryResultSet queryTask(String what, String where)
	{
		if (taskManagerService!=null)
		{
			QueryResultSet result = null;
			try {
				result = taskManagerService.query(what,where,null,null,null);
				return result;
			} catch (Exception e) {
				e.printStackTrace();
			} 
		}
		return null;
	}
	
	/**
	 * 完成指定的人工任务
	 * taskID为任务的标识
	 */
	public boolean completeTask(String taskID)
	{
		try {
			Task task = taskManagerService.getTask(taskID);
			if(task != null) {
				int state = task.getState();
				switch(state) {
					case Task.STATE_READY: 
					{
				 		taskManagerService.claim(taskID);
				 		taskManagerService.complete(taskID);
				 		break;
					}
					case Task.STATE_CLAIMED:
					{
				 		taskManagerService.complete(taskID);
				 		break;
					}
					default: 
					{
						break;
					}
				}				
				taskManagerService.delete(taskID);		
			}
			return true;
		} catch (Exception e) {
			e.printStackTrace();
			return false;
		} 
	}
}