`

JBPM5.4发送email

 
阅读更多
 
JBPM5.4配置参考: http://panyongzheng.iteye.com/blog/1879279
本文参考: https://community.jboss.org/thread/201336
发送邮件的功能，只有三个控件，开始事件，邮件事件，结束时间。
dpmn文件:
Xml代码 复制代码 收藏代码
  1. <?xml version="1.0" encoding="UTF-8"?>    
  2. <definitions id="Definition"  
  3.              targetNamespace="http://www.jboss.org/drools"  
  4.              typeLanguage="http://www.java.com/javaTypes"  
  5.              expressionLanguage="http://www.mvel.org/2.0"  
  6.              xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"  
  7.              xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  8.              xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd"  
  9.              xmlns:g="http://www.jboss.org/drools/flow/gpd"  
  10.              xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI"  
  11.              xmlns:dc="http://www.omg.org/spec/DD/20100524/DC"  
  12.              xmlns:di="http://www.omg.org/spec/DD/20100524/DI"  
  13.              xmlns:tns="http://www.jboss.org/drools">  
  14.   
  15.   <process processType="Private" isExecutable="true" id="com.sample.email.bpmn" name="Sample Process" tns:packageName="defaultPackage" >  
  16.   
  17.     <!-- nodes -->  
  18.     <startEvent id="_1" name="StartProcess" />  
  19.     <endEvent id="_2" name="End" >  
  20.         <terminateEventDefinition/>  
  21.     </endEvent>  
  22.     <task id="_3" name="Email" tns:taskName="Email" >  
  23.       <ioSpecification>  
  24.         <dataInput id="_3_BodyInput" name="Body" />  
  25.         <dataInput id="_3_SubjectInput" name="Subject" />  
  26.         <dataInput id="_3_ToInput" name="To" />  
  27.         <dataInput id="_3_FromInput" name="From" />  
  28.         <inputSet>  
  29.           <dataInputRefs>_3_BodyInput</dataInputRefs>  
  30.           <dataInputRefs>_3_SubjectInput</dataInputRefs>  
  31.           <dataInputRefs>_3_ToInput</dataInputRefs>  
  32.           <dataInputRefs>_3_FromInput</dataInputRefs>  
  33.         </inputSet>  
  34.         <outputSet>  
  35.         </outputSet>  
  36.       </ioSpecification>  
  37.       <dataInputAssociation>  
  38.         <targetRef>_3_BodyInput</targetRef>  
  39.         <assignment>  
  40.           <from xsi:type="tFormalExpression">This is a test mail.</from>  
  41.           <to xsi:type="tFormalExpression">_3_BodyInput</to>  
  42.         </assignment>  
  43.       </dataInputAssociation>  
  44.       <dataInputAssociation>  
  45.         <targetRef>_3_SubjectInput</targetRef>  
  46.         <assignment>  
  47.           <from xsi:type="tFormalExpression">JBPM5.4 Email Event</from>  
  48.           <to xsi:type="tFormalExpression">_3_SubjectInput</to>  
  49.         </assignment>  
  50.       </dataInputAssociation>  
  51.       <dataInputAssociation>  
  52.         <targetRef>_3_ToInput</targetRef>  
  53.         <assignment>  
  54.           <from xsi:type="tFormalExpression">1453261799@qq.com</from>  
  55.           <to xsi:type="tFormalExpression">_3_ToInput</to>  
  56.         </assignment>  
  57.       </dataInputAssociation>  
  58.       <dataInputAssociation>  
  59.         <targetRef>_3_FromInput</targetRef>  
  60.         <assignment>  
  61.           <from xsi:type="tFormalExpression">pandy_test@163.com</from>  
  62.           <to xsi:type="tFormalExpression">_3_FromInput</to>  
  63.         </assignment>  
  64.       </dataInputAssociation>  
  65.     </task>  
  66.   
  67.     <!-- connections -->  
  68.     <sequenceFlow id="_3-_2" sourceRef="_3" targetRef="_2" />  
  69.     <sequenceFlow id="_1-_3" sourceRef="_1" targetRef="_3" />  
  70.   
  71.   </process>  
  72.   
  73.   <bpmndi:BPMNDiagram>  
  74.     <bpmndi:BPMNPlane bpmnElement="com.sample.email.bpmn" >  
  75.       <bpmndi:BPMNShape bpmnElement="_1" >  
  76.         <dc:Bounds x="47" y="157" width="48" height="48" />  
  77.       </bpmndi:BPMNShape>  
  78.       <bpmndi:BPMNShape bpmnElement="_2" >  
  79.         <dc:Bounds x="704" y="150" width="48" height="48" />  
  80.       </bpmndi:BPMNShape>  
  81.       <bpmndi:BPMNShape bpmnElement="_3" >  
  82.         <dc:Bounds x="349" y="156" width="100" height="48" />  
  83.       </bpmndi:BPMNShape>  
  84.       <bpmndi:BPMNEdge bpmnElement="_3-_2" >  
  85.         <di:waypoint x="399" y="180" />  
  86.         <di:waypoint x="728" y="174" />  
  87.       </bpmndi:BPMNEdge>  
  88.       <bpmndi:BPMNEdge bpmnElement="_1-_3" >  
  89.         <di:waypoint x="71" y="181" />  
  90.         <di:waypoint x="399" y="180" />  
  91.       </bpmndi:BPMNEdge>  
  92.     </bpmndi:BPMNPlane>  
  93.   </bpmndi:BPMNDiagram>  
  94.   
  95. </definitions>   
<?xml version="1.0" encoding="UTF-8"?> 
<definitions id="Definition"
             targetNamespace="http://www.jboss.org/drools"
             typeLanguage="http://www.java.com/javaTypes"
             expressionLanguage="http://www.mvel.org/2.0"
             xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd"
             xmlns:g="http://www.jboss.org/drools/flow/gpd"
             xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI"
             xmlns:dc="http://www.omg.org/spec/DD/20100524/DC"
             xmlns:di="http://www.omg.org/spec/DD/20100524/DI"
             xmlns:tns="http://www.jboss.org/drools">

  <process processType="Private" isExecutable="true" id="com.sample.email.bpmn" name="Sample Process" tns:packageName="defaultPackage" >

    <!-- nodes -->
    <startEvent id="_1" name="StartProcess" />
    <endEvent id="_2" name="End" >
        <terminateEventDefinition/>
    </endEvent>
    <task id="_3" name="Email" tns:taskName="Email" >
      <ioSpecification>
        <dataInput id="_3_BodyInput" name="Body" />
        <dataInput id="_3_SubjectInput" name="Subject" />
        <dataInput id="_3_ToInput" name="To" />
        <dataInput id="_3_FromInput" name="From" />
        <inputSet>
          <dataInputRefs>_3_BodyInput</dataInputRefs>
          <dataInputRefs>_3_SubjectInput</dataInputRefs>
          <dataInputRefs>_3_ToInput</dataInputRefs>
          <dataInputRefs>_3_FromInput</dataInputRefs>
        </inputSet>
        <outputSet>
        </outputSet>
      </ioSpecification>
      <dataInputAssociation>
        <targetRef>_3_BodyInput</targetRef>
        <assignment>
          <from xsi:type="tFormalExpression">This is a test mail.</from>
          <to xsi:type="tFormalExpression">_3_BodyInput</to>
        </assignment>
      </dataInputAssociation>
      <dataInputAssociation>
        <targetRef>_3_SubjectInput</targetRef>
        <assignment>
          <from xsi:type="tFormalExpression">JBPM5.4 Email Event</from>
          <to xsi:type="tFormalExpression">_3_SubjectInput</to>
        </assignment>
      </dataInputAssociation>
      <dataInputAssociation>
        <targetRef>_3_ToInput</targetRef>
        <assignment>
          <from xsi:type="tFormalExpression">1453261799@qq.com</from>
          <to xsi:type="tFormalExpression">_3_ToInput</to>
        </assignment>
      </dataInputAssociation>
      <dataInputAssociation>
        <targetRef>_3_FromInput</targetRef>
        <assignment>
          <from xsi:type="tFormalExpression">pandy_test@163.com</from>
          <to xsi:type="tFormalExpression">_3_FromInput</to>
        </assignment>
      </dataInputAssociation>
    </task>

    <!-- connections -->
    <sequenceFlow id="_3-_2" sourceRef="_3" targetRef="_2" />
    <sequenceFlow id="_1-_3" sourceRef="_1" targetRef="_3" />

  </process>

  <bpmndi:BPMNDiagram>
    <bpmndi:BPMNPlane bpmnElement="com.sample.email.bpmn" >
      <bpmndi:BPMNShape bpmnElement="_1" >
        <dc:Bounds x="47" y="157" width="48" height="48" />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="_2" >
        <dc:Bounds x="704" y="150" width="48" height="48" />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="_3" >
        <dc:Bounds x="349" y="156" width="100" height="48" />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNEdge bpmnElement="_3-_2" >
        <di:waypoint x="399" y="180" />
        <di:waypoint x="728" y="174" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="_1-_3" >
        <di:waypoint x="71" y="181" />
        <di:waypoint x="399" y="180" />
      </bpmndi:BPMNEdge>
    </bpmndi:BPMNPlane>
  </bpmndi:BPMNDiagram>

</definitions>



java代码:
Java代码 复制代码 收藏代码
  1. package com.gds.web;   
  2.   
  3. import static org.springframework.web.bind.annotation.RequestMethod.GET;   
  4. import static org.springframework.web.bind.annotation.RequestMethod.POST;   
  5. import static org.springframework.web.bind.annotation.RequestMethod.PUT;   
  6.   
  7. import java.io.ByteArrayOutputStream;   
  8. import java.io.IOException;   
  9. import java.io.ObjectOutputStream;   
  10. import java.util.HashMap;   
  11. import java.util.Iterator;   
  12. import java.util.List;   
  13. import java.util.Map;   
  14.   
  15. import javax.annotation.Resource;   
  16.   
  17. import org.apache.log4j.Logger;   
  18. import org.drools.command.Context;   
  19. import org.drools.command.impl.GenericCommand;   
  20. import org.drools.command.impl.KnowledgeCommandContext;   
  21. import org.drools.runtime.StatefulKnowledgeSession;   
  22. import org.drools.runtime.process.WorkflowProcessInstance;   
  23. import org.jbpm.process.core.context.variable.VariableScope;   
  24. import org.jbpm.process.instance.context.variable.VariableScopeInstance;   
  25. import org.jbpm.process.workitem.email.EmailWorkItemHandler;   
  26. import org.jbpm.process.workitem.wsht.LocalHTWorkItemHandler;   
  27. import org.jbpm.task.Task;   
  28. import org.jbpm.task.TaskData;   
  29. import org.jbpm.task.TaskService;   
  30. import org.jbpm.task.query.TaskSummary;   
  31. import org.jbpm.task.service.ContentData;   
  32. import org.jbpm.task.utils.ContentMarshallerHelper;   
  33. import org.springframework.beans.factory.annotation.Qualifier;   
  34. import org.springframework.stereotype.Controller;   
  35. import org.springframework.ui.Model;   
  36. import org.springframework.web.bind.annotation.ModelAttribute;   
  37. import org.springframework.web.bind.annotation.PathVariable;   
  38. import org.springframework.web.bind.annotation.RequestMapping;   
  39.   
  40. import com.gds.jbpm.MyLocalTaskService;   
  41. import com.gds.jbpm.Order;   
  42.   
  43. @Controller  
  44. public class EmailController {   
  45.   
  46.     private Logger log = Logger.getLogger(this.getClass());   
  47.   
  48.     @Resource  
  49.     @Qualifier("myLocalTaskService")   
  50.     private MyLocalTaskService myLocalTaskService;   
  51.     @Resource  
  52.     @Qualifier("ksession")   
  53.     private StatefulKnowledgeSession ksession;   
  54.   
  55.     public void registerWorkItemHandler() {   
  56.         LocalHTWorkItemHandler humanTaskHandler = new LocalHTWorkItemHandler(   
  57.                 myLocalTaskService.getLocalTaskService(), ksession);   
  58.         humanTaskHandler.setLocal(true);   
  59.         humanTaskHandler.connect();   
  60.         ksession.getWorkItemManager().registerWorkItemHandler("Human Task",   
  61.                 humanTaskHandler);   
  62.         System.out   
  63.                 .println("----------------------------------------------------->LocalHTWorkItemHandler");   
  64.         EmailWorkItemHandler emailHandler1 = new EmailWorkItemHandler();   
  65.         emailHandler1.setConnection("smtp.163.com", "25", "abc@163.com", "123");   
  66.         emailHandler1.getConnection().setStartTls(true);   
  67.         ksession.getWorkItemManager().registerWorkItemHandler("Email", emailHandler1);   
  68.         System.out   
  69.                 .println("----------------------------------------------------->EmailWorkItemHandler");   
  70.     }   
  71.   
  72.     @RequestMapping(value = "email.do", method = { GET, POST, PUT })   
  73.     public String doCreate(Model model) {   
  74.         System.out.println("JBPM5.4的邮件测试");   
  75.         ksession = myLocalTaskService.getKsession();   
  76.         registerWorkItemHandler();   
  77.         ksession.startProcess("com.sample.email.bpmn");   
  78.         ksession.fireAllRules();   
  79.         model.addAttribute("message", "process created!");   
  80.         return "create";   
  81.     }   
  82.   
  83. }  
package com.gds.web;

import static org.springframework.web.bind.annotation.RequestMethod.GET;
import static org.springframework.web.bind.annotation.RequestMethod.POST;
import static org.springframework.web.bind.annotation.RequestMethod.PUT;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import javax.annotation.Resource;

import org.apache.log4j.Logger;
import org.drools.command.Context;
import org.drools.command.impl.GenericCommand;
import org.drools.command.impl.KnowledgeCommandContext;
import org.drools.runtime.StatefulKnowledgeSession;
import org.drools.runtime.process.WorkflowProcessInstance;
import org.jbpm.process.core.context.variable.VariableScope;
import org.jbpm.process.instance.context.variable.VariableScopeInstance;
import org.jbpm.process.workitem.email.EmailWorkItemHandler;
import org.jbpm.process.workitem.wsht.LocalHTWorkItemHandler;
import org.jbpm.task.Task;
import org.jbpm.task.TaskData;
import org.jbpm.task.TaskService;
import org.jbpm.task.query.TaskSummary;
import org.jbpm.task.service.ContentData;
import org.jbpm.task.utils.ContentMarshallerHelper;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;

import com.gds.jbpm.MyLocalTaskService;
import com.gds.jbpm.Order;

@Controller
public class EmailController {

	private Logger log = Logger.getLogger(this.getClass());

	@Resource
	@Qualifier("myLocalTaskService")
	private MyLocalTaskService myLocalTaskService;
	@Resource
	@Qualifier("ksession")
	private StatefulKnowledgeSession ksession;

	public void registerWorkItemHandler() {
		LocalHTWorkItemHandler humanTaskHandler = new LocalHTWorkItemHandler(
				myLocalTaskService.getLocalTaskService(), ksession);
		humanTaskHandler.setLocal(true);
		humanTaskHandler.connect();
		ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
				humanTaskHandler);
		System.out
				.println("----------------------------------------------------->LocalHTWorkItemHandler");
		EmailWorkItemHandler emailHandler1 = new EmailWorkItemHandler();
		emailHandler1.setConnection("smtp.163.com", "25", "abc@163.com", "123");
		emailHandler1.getConnection().setStartTls(true);
		ksession.getWorkItemManager().registerWorkItemHandler("Email", emailHandler1);
		System.out
				.println("----------------------------------------------------->EmailWorkItemHandler");
	}

	@RequestMapping(value = "email.do", method = { GET, POST, PUT })
	public String doCreate(Model model) {
		System.out.println("JBPM5.4的邮件测试");
		ksession = myLocalTaskService.getKsession();
		registerWorkItemHandler();
		ksession.startProcess("com.sample.email.bpmn");
		ksession.fireAllRules();
		model.addAttribute("message", "process created!");
		return "create";
	}

}

EmailWorkItemHandler emailHandler1 = new EmailWorkItemHandler();
emailHandler1.setConnection("smtp.163.com", "25", "abc@163.com", "123");
emailHandler1.getConnection().setStartTls(true);
ksession.getWorkItemManager().registerWorkItemHandler("Email", emailHandler1);
分享到：
| JBPM5的一些概念
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

Magicbox
Global site tag (gtag.js) - Google Analytics