5.5.任務(wù)到達(dá)提醒

IMessageVariableRegister接口源碼
package com.bstek.bdf2.core.business;
import java.util.Collection;
import com.bstek.bdf2.core.model.MessageVariable;
/**
 * @author Jacky.gao
 * @since 2013-3-24
 */
public interface IMessageVariableRegister {
 String getTypeId();
 String getTypeName();
 Collection<MessageVariable> getMessageVariables();
}

實(shí)現(xiàn)類示例
package com.bstek.bdf2.jbpm4.context;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.jbpm.api.TaskService;
import org.jbpm.api.task.Task;
import com.bstek.bdf2.core.model.MessageVariable;
import com.bstek.bdf2.jbpm4.service.IBpmService;
/**

 * @author Jacky.gao
 * @since 2013-3-25
 */
public class DefaultJbpm4MessageVariableRegister extends AbstractJbpm4MessageVariableRegister{
 private IBpmService bpmService;
 private String taskName="taskName";
 private String principal="principal"; 
 private String taskCreateDate="taskCreateDate"; 
 public Collection<MessageVariable> getMessageVariables() {
 List<MessageVariable> result=new ArrayList<MessageVariable>();
 MessageVariable var=new MessageVariable();
 var.setName(IBpmService.BUSINESS_ID);
 var.setDesc("業(yè)務(wù)數(shù)據(jù)ID");
 result.add(var);
 
 var=new MessageVariable();
 var.setName(taskCreateDate);
 var.setDesc("任務(wù)創(chuàng)建時(shí)間");
 result.add(var);
 var=new MessageVariable();
 var.setName(principal);
 var.setDesc("任務(wù)處理人");
 result.add(var);
 
 var=new MessageVariable();
 var.setName(taskName);
 var.setDesc("任務(wù)名稱");
 result.add(var);
 
 var=new MessageVariable();
 var.setName(IBpmService.PROCESS_INSTANCE_PROMOTER);
 var.setDesc("流程實(shí)例發(fā)起人");
 result.add(var);
 return result;
 }
 public Map<String, String> fetchMessages(Task task,String assignee) {
 SimpleDateFormat sd=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
 TaskService taskService=bpmService.getTaskService();
 Map<String, String> map=new HashMap<String,String>();
 map.put(principal, assignee);
 map.put(taskName, task.getName());
 map.put(taskCreateDate, sd.format(task.getCreateTime()));
 map.put(IBpmService.BUSINESS_ID,(String)taskService.getVariable(task.getId(),
IBpmService.BUSINESS_ID));
 map.put(IBpmService.PROCESS_INSTANCE_PROMOTER,(String)taskService.getVariable(task.getId(),
IBpmService.PROCESS_INSTANCE_PROMOTER));
 return map;
 }
 public IBpmService getBpmService() {
 return bpmService;
 }
 public void setBpmService(IBpmService bpmService) {

 this.bpmService = bpmService;
 }
}

AbstractJbpm4MessageVariableRegister類源碼
public abstract class AbstractJbpm4MessageVariableRegister implements
IJbpm4MessageVariableRegister {
 public String getTypeId() {
 return TYPE;
 }
 public String getTypeName() {
 return "jBPM4消息模版";
 }
}

IMessageSender接口源碼
package com.bstek.bdf2.core.message;
/**
 * @author Jacky.gao
 * @since 2013-3-28
 */
public interface IMessageSender {
 String getSenderId();
 String getSenderName();
 void send(MessagePacket message);
 boolean isDisabled();
}