少年阿賓

 <initial-actions>
  <action id="100" name="Start Ordinary Workflow">
   <results>
    <unconditional-result old-status="Finished"
     status="Queued" step="1" />
   </results>
  </action>
  <action id="200" name="Start Emergent Workflow">
   <results>
    <unconditional-result old-status="Finished"
     status="Queued" step="5" />
   </results>
  </action>
 </initial-actions>

 <steps>

  <step id="1" name="Initiate Doc">
   <actions>
    <action id="1" name="Initial Work">
     <restrict-to>
      <conditions>
       <condition type="class">
        <arg name="class.name">
         com.opensymphony.workflow.util.StatusCondition
        </arg>
        <arg name="status">Queued</arg>
       </condition>
      </conditions>
     </restrict-to>
     <validators>
      <validator type="class">
       <arg name="class.name">
        org.abin.lee.validator.TitleValidator
       </arg>
      </validator>
     </validators>
     <pre-functions>
      <function type="class">
       <arg name="class.name">
        com.opensymphony.workflow.util.Caller
       </arg>
       <arg name="stepId">1</arg>
      </function>
      <function type="beanshell">
       <arg name="script">
        transientVars.get("log").info("Initiate Work");
       </arg>
      </function>
     </pre-functions>
     <results>
      <unconditional-result old-status="Finished"
       status="Prepared" step="1" owner="${caller}" />
     </results>
     <post-functions>
      <function type="beanshell">
       <arg name="script">
        propertySet.setString("title",
        (String)transientVars.get("title"));
       </arg>
      </function>
     </post-functions>
    </action>
    <action id="2" name="Deliver Work">
     <restrict-to>
      <conditions type="AND">
       <condition type="class">
        <arg name="class.name">
         com.opensymphony.workflow.util.StatusCondition
        </arg>
        <arg name="status">Prepared</arg>
        <arg name="stepId">1</arg>
       </condition>
       <condition type="class">
        <arg name="class.name">
         com.opensymphony.workflow.util.AllowOwnerOnlyCondition
        </arg>
       </condition>
      </conditions>
     </restrict-to>
     <pre-functions>
      <function type="beanshell">
       <arg name="script">
        transientVars.get("log").info("Deliver Doc to Boss A and B");
       </arg>
      </function>
     </pre-functions>
     <results>
      <unconditional-result old-status="Finished"
       status="Prepared" split="1" />
     </results>
    </action>
   </actions>
  </step>

  <step id="2" name="Review Doc In Boss A">
   <external-permissions>
    <permission name="permA">
     <restrict-to>
      <conditions type="AND">
       <condition name="check.status" type="class">
        <arg name="class.name">com.opensymphony.workflow.util.StatusCondition</arg>
        <arg name="status">Prepared</arg>
       </condition>
       <condition name="allow.owner.only" type="class">
        <arg name="class.name">com.opensymphony.workflow.util.AllowOwnerOnlyCondition</arg>
       </condition>
      </conditions>
     </restrict-to>
    </permission>
   </external-permissions>
   <actions>
    <action id="3" name="Review Work By A">
     <pre-functions>
      <function type="beanshell">
       <arg name="script">
        transientVars.get("log").info("Doc Reviewed By Boss A")
       </arg>
      </function>
     </pre-functions>
     <results>
      <unconditional-result old-status="Finished"
       status="Underway" join="1" />
     </results>
    </action>
   </actions>
  </step>

  <step id="3" name="Review Doc In Boss B">
   <external-permissions>
    <permission name="permA">
     <restrict-to>
      <conditions type="AND">
       <condition name="check.status" type="class">
        <arg name="class.name">com.opensymphony.workflow.util.StatusCondition</arg>
        <arg name="status">Prepared</arg>
       </condition>
       <condition name="allow.owner.only" type="class">
        <arg name="class.name">com.opensymphony.workflow.util.AllowOwnerOnlyCondition</arg>
       </condition>
      </conditions>
     </restrict-to>
    </permission>
   </external-permissions>
   <actions>
    <action id="4" name="Review Work By B">
     <pre-functions>
      <function type="beanshell">
       <arg name="script">
        transientVars.get("log").info("Doc Reviewed By Boss B")
       </arg>
      </function>
     </pre-functions>
     <results>
      <unconditional-result old-status="Finished"
       status="Underway" join="1" />
     </results>
    </action>
   </actions>
  </step>

  <step id="4" name="Finish Ordinary Work">
   <pre-functions>
    <function type="beanshell">
     <arg name="script">
      System.out.println("Finish Doc Review. \nTitle:"+propertySet.getString("title")+".");
     </arg>
    </function>
   </pre-functions>
  </step>

  <step id="5" name="Finish Emergent Work">
   <pre-functions>
    <function type="beanshell">
     <arg name="script">
      System.out.println("Emergency Handler");
     </arg>
    </function>
   </pre-functions>
  </step>

 </steps>

 <splits>
  <split id="1">
   <unconditional-result old-status="Finished"
    status="Prepared" step="2" />
   <unconditional-result old-status="Finished"
    status="Prepared" step="3" />
  </split>
 </splits>

 <joins>
  <join id="1">
   <conditions type="AND">
    <condition type="beanshell">
     <arg name="script"><![CDATA[ "Finished".equals(jn.getStep(2).getStatus()) && "Finished".equals(jn.getStep(3).getStatus()) ]]></arg>
    </condition>
   </conditions>
   <unconditional-result old-status="Finished"
    status="Reviewed" step="4" />
  </join>
 </joins>

</workflow>

package org.abin.lee.validator;

import java.util.Map;
import com.opensymphony.module.propertyset.PropertySet;
import com.opensymphony.workflow.InvalidInputException;
import com.opensymphony.workflow.Validator;
import com.opensymphony.workflow.WorkflowException;

public class TitleValidator implements Validator {
 public void validate(Map transientVars, Map args, PropertySet ps)
   throws InvalidInputException, WorkflowException {
  System.out.println("TitleValidator is running");
  String title = (String) transientVars.get("title");
  if (title == null)
   throw new InvalidInputException("Missing title");
  if (title.length() > 30)
   throw new InvalidInputException("Title too long");
 }
}

package org.abin.lee.workflow;

import java.util.HashMap;

import com.opensymphony.workflow.InvalidActionException;
import com.opensymphony.workflow.InvalidEntryStateException;
import com.opensymphony.workflow.InvalidInputException;
import com.opensymphony.workflow.InvalidRoleException;
import com.opensymphony.workflow.Workflow;
import com.opensymphony.workflow.WorkflowException;
import com.opensymphony.workflow.basic.BasicWorkflow;
import com.opensymphony.workflow.config.DefaultConfiguration;

public class SimpleSample {
 public static void main(String[] args) {
  try {
   Workflow workflow = new BasicWorkflow("abin");

   DefaultConfiguration config = new DefaultConfiguration();
   workflow.setConfiguration(config);

   long workflowId = workflow.initialize("docworkflow", 100, null);
   HashMap inputs = new HashMap();
   inputs.put("title", "openopen");

   workflow.doAction(workflowId, 1, inputs);

   workflow.doAction(workflowId, 2, null);

   workflow.doAction(workflowId, 3, null);

   workflow.doAction(workflowId, 4, null);
   
  } catch (InvalidActionException e) {
   System.out.println(e.getMessage());
  } catch (InvalidRoleException e) {
   System.out.println(e.getMessage());
  } catch (InvalidInputException e) {
   System.out.println(e.getMessage());
  } catch (InvalidEntryStateException e) {
   System.out.println(e.getMessage());
  } catch (WorkflowException e) {
   System.out.println(e.getMessage());
  }
 }
}

log4j.rootCategory=info,log,console

log4j.logger.org.apache.axis2.enterprise=FATAL
log4j.logger.de.hunsicker.jalopy.io=FATAL
log4j.logger.httpclient.wire.header=FATAL
log4j.logger.org.apache.commons.httpclient=FATAL

log4j.appender.console=org.apache.log4j.ConsoleAppender
log4j.appender.console.layout=org.apache.log4j.PatternLayout
log4j.appender.console.layout.ConversionPattern=%d [%t] %-5p %c %x - %m%n
 
log4j.appender.log=org.apache.log4j.DailyRollingFileAppender
log4j.appender.log.File=logs/osworkflow.log
log4j.appender.log.layout=org.apache.log4j.PatternLayout
log4j.appender.log.layout.ConversionPattern=%d [%t] %-5p %c %x - %m%n

  <insert id="insertTeacher" parameterMap="parameterTeacherMap">
    <selectKey    keyProperty="tid" resultType="int" order="AFTER">
      SELECT @@IDENTITY AS ID
    </selectKey>
    INSERT INTO teacher(tname)
    VALUES(#{tname})
  </insert>       
   
  <resultMap type="Teacher" id="resultTeacherMap">
    <result property="tid" column="tid"/>
    <result property="tname" column="tname"/>
    <collection property="student" column="sid" select="org.abin.lee.dao.StudentDao.getStudentById"/>
  </resultMap>
   
  <select id="getTeacher" resultMap="resultTeacherMap" parameterType="int">
    SELECT *
    FROM teacher
    WHERE tid=#{id}
  </select>         
  
</mapper>

package org.abin.lee.dao;

import java.util.List;

import org.abin.lee.bean.Student;

public interface StudentDao {
 void insertStudent(Student student);
 List<Student> getStudent(int id);
 List<Student> getStudentById(int teacherId);
}

package org.abin.lee.dao;

import org.abin.lee.bean.Teacher;

public interface TeacherDao {
 void insertTeacher(Teacher teacher);
 Teacher getTeacher(int id);
}

package org.abin.lee.dao.impl;

import java.util.List;

import org.abin.lee.bean.Student;
import org.abin.lee.dao.StudentDao;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

public class StudentDaoImpl extends HibernateDaoSupport implements StudentDao{

 public List<Student> getStudent(int id) {
  List<Student> list=null;
  String hql="select o from Student o where o.id="+id;
  try {
   list=(List<Student>)this.getHibernateTemplate().find(hql);
  } catch (Exception e) {
   e.printStackTrace();
  }
  return list;
 }

 public List<Student> getStudentById(int teacherId) {
  List<Student> list=null;
  String hql="select o from Student o where o.id="+teacherId;
  try {
   list=(List<Student>)this.getHibernateTemplate().find(hql);
  } catch (Exception e) {
   e.printStackTrace();
  }
  return list;
 }

 public void insertStudent(Student student) {
  try {
   this.getHibernateTemplate().save(student);
  } catch (Exception e) {
   e.printStackTrace();
  }
  
 }

}

package org.abin.lee.dao.impl;

import org.abin.lee.bean.Teacher;
import org.abin.lee.dao.TeacherDao;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

public class TeacherDaoImpl extends HibernateDaoSupport implements TeacherDao{

 public Teacher getTeacher(int id) {
  Teacher teacher=null;
  String hql="select o from Teacher o where o.id="+id;
  try {
   teacher=(Teacher)this.getHibernateTemplate().find(hql);
   this.getHibernateTemplate().flush();
  } catch (Exception e) {
   e.printStackTrace();
  }
  return teacher;
 }

 public void insertTeacher(Teacher teacher) {
  try {
   this.getHibernateTemplate().save(teacher);
   this.getHibernateTemplate().flush();
   
  } catch (Exception e) {
   e.printStackTrace();
  }
  
 }

}

package org.abin.lee.service;

import java.util.List;

import org.abin.lee.bean.Student;

public interface StudentService {
 
 void insertStudent(Student student);
 List<Student> getStudent(int id);
 List<Student> getStudentById(int teacherId);
 
}

package org.abin.lee.service;

import org.abin.lee.bean.Teacher;

public interface TeacherService {
 
 void insertTeacher(Teacher teacher);
 Teacher getTeacher(int id);
}

package org.abin.lee.service.impl;

import java.util.List;

import org.abin.lee.bean.Student;
import org.abin.lee.dao.StudentDao;
import org.abin.lee.service.StudentService;

public class StudentServiceImpl implements StudentService{
 private StudentDao studentDao;
 
 public List<Student> getStudent(int id) {
  return this.studentDao.getStudent(id);
 }

 public List<Student> getStudentById(int teacherId) {
  
  return this.studentDao.getStudentById(teacherId);
 }

 public void insertStudent(Student student) {
  this.studentDao.insertStudent(student);
  
 }

 public StudentDao getStudentDao() {
  return studentDao;
 }

 public void setStudentDao(StudentDao studentDao) {
  this.studentDao = studentDao;
 }

}

package org.abin.lee.service.impl;

import org.abin.lee.bean.Teacher;
import org.abin.lee.dao.TeacherDao;
import org.abin.lee.service.TeacherService;

public class TeacherServiceImpl implements TeacherService{
 private TeacherDao teacherDao;
 
 public Teacher getTeacher(int id) {
  
  return this.teacherDao.getTeacher(id);
 }

 public void insertTeacher(Teacher teacher) {
  this.teacherDao.insertTeacher(teacher);
  
 }

 public TeacherDao getTeacherDao() {
  return teacherDao;
 }

 public void setTeacherDao(TeacherDao teacherDao) {
  this.teacherDao = teacherDao;
 }
 
}

</beans>

    <!-- 創建SqlSessionFactory，同時指定數據源-->
 <bean id="sqlSessionFactory"
  class="org.mybatis.spring.SqlSessionFactoryBean">
  <property name="dataSource" ref="dataSource" />
  <property name="configLocation"
   value="classpath:mybatis-config.xml" />
 </bean>

 <bean id="transactionManager"
  class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  <property name="dataSource" ref="dataSource" />
 </bean>

</beans>

 <bean id="teacherService"
  class="org.abin.lee.service.impl.TeacherServiceImpl">
  <property name="teacherDao">
   <ref bean="teacherDao" />
  </property>
 </bean>

</beans>

 <settings>
  <!-- changes from the defaults for testing -->
  <setting name="cacheEnabled" value="false" />
  <setting name="useGeneratedKeys" value="true" />
  <setting name="defaultExecutorType" value="REUSE" />
 </settings>

 <typeAliases>
  <typeAlias type="org.abin.lee.bean.Student" alias="Student" />
  <typeAlias type="org.abin.lee.bean.Teacher" alias="Teacher" />
 </typeAliases>

 <mappers>
  <mapper resource="org/abin/lee/bean/StudentMapper.xml" />
  <mapper resource="org/abin/lee/bean/TeacherMapper.xml" />
 </mappers>

</configuration>





log4j.properties（直接放在src目錄下面）

log4j.rootLogger=INFO,stdout,logfile
//log4j.rootLogger=INFO,logfile

log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%-d{yyyy-MM-dd HH:mm:ss} [%c]-[%p] %m%n

log4j.appender.logfile=org.apache.log4j.RollingFileAppender
log4j.appender.logfile.File=../logs/contacts.log
log4j.appender.logfile.MaxFileSize=2048KB
log4j.appender.logfile.MaxBackupIndex=5
log4j.appender.logfile.layout=org.apache.log4j.PatternLayout
log4j.appender.logfile.layout.ConversionPattern=[%-5p] %d{yyyy-MM-dd HH:mm:ss} (%c) - %m%n

package org.abin.lee.test;

import junit.framework.TestCase;

import org.abin.lee.bean.Student;
import org.abin.lee.bean.Teacher;
import org.abin.lee.service.StudentService;
import org.abin.lee.service.TeacherService;
import org.junit.Before;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class TestStudent extends TestCase{
 
 private StudentService studentService;
 private TeacherService teacherService;
 private ApplicationContext context;
 @Before
 public void setUp(){
  String[] xml=new String[3];
  xml[0]="org/abin/lee/spring/applicationContext-resource.xml";
  xml[1]="org/abin/lee/spring/applicationContext-mapper.xml";
  xml[2]="org/abin/lee/spring/applicationContext-service.xml";
  context=new ClassPathXmlApplicationContext(xml);
 }
 
 public void testStudent(){
  Teacher tea=new Teacher();
  tea.setTname("steven");
  teacherService=(TeacherService)context.getBean("teacherService");
  this.teacherService.insertTeacher(tea);
  Student stu=new Student();
  stu.setSname("john");
  stu.setTeacherId(tea.getTid());
  studentService=(StudentService)context.getBean("studentService");
  this.studentService.insertStudent(stu);
 }
 public StudentService getStudentService() {
  return studentService;
 }
 public void setStudentService(StudentService studentService) {
  this.studentService = studentService;
 }
 public TeacherService getTeacherService() {
  return teacherService;
 }
 public void setTeacherService(TeacherService teacherService) {
  this.teacherService = teacherService;
 }
 
}

package org.abin.lee.test;

import java.util.List;

import junit.framework.TestCase;

import org.abin.lee.bean.Student;
import org.abin.lee.bean.Teacher;
import org.abin.lee.service.StudentService;
import org.abin.lee.service.TeacherService;
import org.junit.Before;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class TestFind extends TestCase{
 private StudentService studentService;
 private TeacherService teacherService;
 private ApplicationContext context;
 @Before
 public void setUp(){
  String[] xml=new String[3];
  xml[0]="org/abin/lee/spring/applicationContext-resource.xml";
  xml[1]="org/abin/lee/spring/applicationContext-mapper.xml";
  xml[2]="org/abin/lee/spring/applicationContext-service.xml";
  context=new ClassPathXmlApplicationContext(xml);
 }
 @Test
 public void testFind(){
  teacherService=(TeacherService)context.getBean("teacherService");
  studentService=(StudentService)context.getBean("studentService");
  List<Student> list=this.studentService.getStudentById(4);
  Student stu=new Student();
  Teacher tea=new Teacher();
  for(int i=0;i<list.size();i++){
   System.out.println("666");
   stu=list.get(i);
   System.out.println("sid="+stu.getSid()+",sname="+stu.getSname()+",teacherid="+stu.getTeacherId());
   tea=stu.getTeacher();
   System.out.println("tid="+tea.getTid()+",tname="+tea.getTname());
  }
 }
 public StudentService getStudentService() {
  return studentService;
 }
 public void setStudentService(StudentService studentService) {
  this.studentService = studentService;
 }
 public TeacherService getTeacherService() {
  return teacherService;
 }
 public void setTeacherService(TeacherService teacherService) {
  this.teacherService = teacherService;
 }
 
}

 public static String sendReq(String method, String jsonReq)
   throws ClientProtocolException, IOException {
  HttpPost post = new HttpPost(jsonServerUrl + method);
  List<NameValuePair> nvps = new ArrayList<NameValuePair>();
  nvps.add(new BasicNameValuePair("json", jsonReq));

  post.setEntity(new UrlEncodedFormEntity(nvps, HTTP.UTF_8));

  HttpResponse response = client.execute(post);
  HttpEntity entity = response.getEntity();
  String entityStr = EntityUtils.toString(entity);

  return entityStr;
 }

 /**
  * 查詢產品客戶經理接口
  */
 public void testQueryCustomerManager() throws ClientProtocolException,
   IOException {
  String jsonReq = "{" + "RequestID:'11111',"+ "ProductID:'SC9904348'," + "timestamp:'20120416121200',"
    + "Hashcode:'1324546asdfgfhr65432wsdfgt654eds'" + "}";

  String resStr = this.sendReq("query-customer-manager-json!queryCustomerManager.action", jsonReq);

  System.out.println(resStr);

  assertNotNull(resStr);
//  JSONObject json = JSONObject.fromObject(resStr);
//  assertNotNull(json.get("requestID"));
 }

}