processbatchcasethread.java

来自「公司自己开发的工作流引擎」· Java 代码 · 共 59 行

package cn.com.iaspec.workflow.helper;

import java.util.*;
import org.apache.log4j.*;
import cn.com.iaspec.workflow.engine.ejb.*;
import cn.com.iaspec.workflow.vo.workflow.*;

/**
 *
 * <p>Title: 批量分案处理线程</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: IASPEC Technologies</p>
 * @author xiesonglin
 * @version 1.0
 */
public class ProcessBatchCaseThread
    extends Thread{
  private static Logger logger=Logger.getLogger(CaseWorkflowHelper.class);
  private List list;
  private String nextActName;
  private UserInfo userInfo;
  public ProcessBatchCaseThread(List list,String nextActName,UserInfo userInfo){
    this.list=list;
    this.nextActName=nextActName;
    this.userInfo=userInfo;
  }

  public void run(){
    try{
      logger.info("begin start ProcessBatchCaseThread run...");
      processBatchCase();
    }
    catch(Exception ex){
      ex.printStackTrace();
    }
  }

  public void processBatchCase()
      throws Exception{
    //批量分案处理
    long startTime=System.currentTimeMillis();
    logger.info("begin start processBatchCase run...");
    WorkflowEJBHandle handle=new WorkflowEJBHandle();
    EngineEJB ejb=handle.getEngineEJB();
    if(list.size()>1){
      //从第二条记录开始循环
      for(int i=1;i<list.size();i++){
        List newList=new ArrayList();
        newList.add(list.get(i));
        ejb.processBatchCase(newList,nextActName,userInfo);
      }
    }
    logger.info("Execution processBatchCase time: "+(System.currentTimeMillis()-
        startTime)+" ms.");
  }

}