一个用数据库实现的工作流

package com.highcom.workflow.dao.JDBC;

import org.springFramework.dao.*;

import org.springframework.jdbc.core.*;
import org.springframework.jdbc.core.support.*;

import Java.sql.*;

import java.util.*;
import com.highcom.workflow.domain.*;
import com.highcom.workflow.dao.*;
import com.highcom.seqgen.*;

public class WorkflowDaoJdbcImpl extends JdbcDaoSupport implements WorkflowDao {
private SequenceService sequenceService = null;
private String WORKFLOW_TEMPLATE_SEQ =
"com.highcom.workflow.template";
private String WORKFLOW_TEMPLATE_NODE_SEQ =
"com.highcom.workflow.template.node";
private String WORKFLOW_TEMPLATE_NODE_MAN_SEQ =
"com.highcom.workflow.template.node.man";
//
private String WORKFLOW_SEQ =
"com.highcom.workflow";
private String WORKFLOW_NODE_SEQ =
"com.highcom.workflow.node";
private String WORKFLOW_NODE_MAN_SEQ =
"com.highcom.workflow.node.man";
//
public WorkflowDaoJdbcImpl() {
}

/**
* 新建立一个工作流模板
* @param template WorkflowTemplate
*/
public void addNewTemplate(WorkflowTemplate template) {
String id = sequenceService.getValue(WORKFLOW_TEMPLATE_SEQ);
this.getJdbcTemplate().update("insert into workflow_template(id,name,description,createDate,createMan,status,defaultworkflow) values(?,?,?,?,?,?,?)",
new Object[] {
id, template.getName(),
template.getDescription(),
template.getCreateDate(),
template.getCreateMan(),
new Integer(template.getStatus()),
new Integer(template.getDefaultWorkflow())
},
new int[] {
Types.VARCHAR, Types.VARCHAR, Types.VARCHAR, Types.DATE,
Types.VARCHAR, Types.INTEGER, Types.INTEGER
});
}

public void addNewTemplateNode(WorkflowTemplateNode flowNode) {
String id = this.sequenceService.getValue(this.
WORKFLOW_TEMPLATE_NODE_SEQ);
int maxseq = getTemplateNodeMaxSequence(flowNode.getWorkId());
maxseq = 1;
this.getJdbcTemplate().update("insert into workflow_template_flow(id,template_id,sequence,name,description) values(?,?,?,?,?)",
new Object[] {
id, flowNode.getWorkId(),
new Integer(maxseq),
flowNode.getName(),
flowNode.getDescription()
},
new int[] {
Types.VARCHAR, Types.VARCHAR, Types.INTEGER, Types.VARCHAR,
Types.VARCHAR
});

//插入人员信息
if (flowNode.getMans() != null) {
List mans = flowNode.getMans();

for (int i = 0; i < mans.size(); i ) {
String man_id = this.sequenceService.getValue(this.
WORKFLOW_TEMPLATE_NODE_MAN_SEQ);
String account_id = (String) mans.get(i);
this.getJdbcTemplate().update("insert into workflow_template_man(id,template_flow_id,account_id) values(?,?,?)",
new Object[] {man_id, id,
account_id},
new int[] {Types.VARCHAR,
Types.VARCHAR,
Types.VARCHAR});
}
}
}

/**
* 生成新的工作流实例 调用程序需要本身设置这些信息 1)本身信息 2)结点信息
* 3)结点人员信息
* status:-1,待启动,-2:强制终止,-3：退回到原始状态(需要修改),0:正在运行,1:已经完成.
* flow_id:当前运行结点id.-9999:已经没有当前结点.
*
* @param workflow Workflow
* @return String
*/
public String addNewWorkflow(Workflow workflow) {
//
String id = sequenceService.getValue(WORKFLOW_SEQ);
this.getJdbcTemplate().update(
"insert into workflow_work(id,doc_id,status,"
"flow_id,start_date,end_date,v_comment) values(?,?,?,?,?,?,?)",
new Object[] {
id, workflow.getDocId(),
new Integer(workflow.getStatus()),
workflow.getFlowId(), workflow.getStartDate(),
workflow.getEndDate(),

文章整理：西部数码--专业提供域名注册、虚拟主机服务
http://www.west263.com
以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!