package com.vci.server.workflow.server.delegate;
|
|
import java.io.IOException;
|
import java.io.UnsupportedEncodingException;
|
import java.math.BigDecimal;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.jbpm.api.ProcessDefinition;
|
import org.jbpm.api.task.Task;
|
import org.omg.CORBA.LongHolder;
|
|
import com.vci.common.log.ServerWithLog4j;
|
import com.vci.common.objects.QueryParam;
|
import com.vci.common.objects.QueryResult;
|
import com.vci.common.utility.ObjectUtility;
|
import com.vci.corba.common.VCIError;
|
import com.vci.corba.workflow.data.QueryParamInfo;
|
import com.vci.corba.common.data.UserEntityInfo;
|
import com.vci.corba.workflow.data.FlowApproveHistoryInfo;
|
import com.vci.corba.workflow.data.FlowInstanceInfo;
|
import com.vci.corba.workflow.data.FlowObjectInfo;
|
import com.vci.corba.workflow.data.FlowTaskInfo;
|
import com.vci.corba.workflow.data.MapTransfersInfo;
|
import com.vci.corba.workflow.data.NodeHideInfo;
|
import com.vci.corba.workflow.data.ProcessCategoryInfo;
|
import com.vci.corba.workflow.data.ProcessDefinitionInfo;
|
import com.vci.corba.workflow.data.ProcessTaskInfo;
|
import com.vci.corba.workflow.data.SubprocessTemInfo;
|
import com.vci.corba.workflow.data.TaskDescInfo;
|
import com.vci.corba.workflow.data.TaskRevokeInfo;
|
import com.vci.corba.workflow.data.TasksAssignedInfo;
|
import com.vci.server.workflow.common.task.FlowApproveHistory;
|
import com.vci.server.workflow.objects.NodeHide;
|
import com.vci.server.workflow.objects.PLFlowObject;
|
import com.vci.server.workflow.objects.ProcessCategory;
|
import com.vci.server.workflow.objects.ProcessTask;
|
import com.vci.server.workflow.objects.TaskDescSObject;
|
import com.vci.server.workflow.objects.TaskRevokeSObject;
|
import com.vci.server.workflow.server.template.ProcessCustomService;
|
import com.vci.server.workflow.server.template.ProcessTemplateService;
|
import com.vci.server.workflow.server.template.TasksAssigned;
|
|
public class ProcessCustomDelegate extends BaseDelegate {
|
ProcessCustomService service = null;
|
public ProcessCustomDelegate(UserEntityInfo userEntityInfo) {
|
super(userEntityInfo);
|
service = new ProcessCustomService(this.getUserEntity());
|
}
|
|
public ProcessCustomDelegate() {
|
service = new ProcessCustomService();
|
}
|
|
public ProcessCategoryInfo[] getProcessCategories(String parentId) throws VCIError {
|
ProcessCategoryInfo[] infos = new ProcessCategoryInfo[0];
|
try {
|
List<ProcessCategory> list = service.getProcessCategories(parentId);
|
ProcessCategory[] objects = list.toArray(new ProcessCategory[] {});
|
infos = this.convertProcessCategorysToProcessCategoryInfos(objects);
|
} catch (Exception ex) {
|
throw new VCIError("410101", new String[] {});
|
}
|
return infos;
|
}
|
public ProcessCategoryInfo[] getProcessCategoriesByPage(String parentId,int pageSize,int pageIndex) throws VCIError {
|
ProcessCategoryInfo[] infos = new ProcessCategoryInfo[0];
|
try {
|
List<ProcessCategory> list = service.getProcessCategoriesByPage(parentId,pageSize,pageIndex);
|
ProcessCategory[] objects = list.toArray(new ProcessCategory[] {});
|
infos = this.convertProcessCategorysToProcessCategoryInfos(objects);
|
} catch (Exception ex) {
|
throw new VCIError("410101", new String[] {});
|
}
|
return infos;
|
}
|
public String saveProcessCategory(ProcessCategoryInfo info) throws VCIError {
|
String id = ObjectUtility.getNewObjectID36();
|
info.id = id;
|
try {
|
service.saveProcessCategory(this.convertProcessCategoryInfoToProcessCategory(info));
|
} catch (Exception ex) {
|
throw new VCIError("410102", new String[] {});
|
}
|
return id;
|
}
|
|
public boolean updateProcessCategory(ProcessCategoryInfo info) throws VCIError {
|
boolean res = false;
|
try {
|
res = service.updateProcessCategory(this.convertProcessCategoryInfoToProcessCategory(info));
|
} catch (Exception ex) {
|
throw new VCIError("410103", new String[] {});
|
}
|
return res;
|
}
|
|
public boolean existProcessCategory(String id, String name) throws VCIError {
|
boolean result = false;
|
try {
|
result = service.existProcessCategory(id, name);
|
} catch (Exception ex) {
|
throw new VCIError("410104", new String[] {});
|
}
|
return result;
|
}
|
|
public boolean deleteProcessCategory(String id) throws VCIError {
|
boolean res = false;
|
try {
|
res = service.deleteProcessCategory(id);
|
} catch (Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410105", new String[] {});
|
}
|
return res;
|
}
|
|
/**
|
* 移动流程模板
|
* @param deploymentId
|
* @param categoryId
|
* @return
|
* @throws VCIError
|
*/
|
public boolean moveDefinition( String deploymentId , String categoryId) throws VCIError{
|
return service.moveDefinition(deploymentId, categoryId);
|
}
|
|
|
public void loadWorkFlowTemplate(String jbpmDeploymentId){
|
new ProcessTemplateService().loadWorkFlowTemplate(jbpmDeploymentId);
|
}
|
|
public boolean deployProcess(byte[] jbpmImage, String jbmpXml, String graphXml, String processCategoryId, ProcessTaskInfo[] processTaskInfos) throws VCIError {
|
boolean res = false;
|
try {
|
res = new ProcessTemplateService(this.getUserEntity()).deployProcess(jbpmImage, jbmpXml, graphXml, processCategoryId, processTaskInfos);
|
} catch (Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410106", new String[] {});
|
}
|
return res;
|
}
|
|
public boolean updateProcess(byte[] jbpmImage, String jbmpXml, String graphXml, String processCategoryId, ProcessTaskInfo[] processTaskInfos,String deployId) throws VCIError {
|
boolean res = false;
|
try {
|
res = new ProcessTemplateService(this.getUserEntity()).updateProcess(jbpmImage, jbmpXml, graphXml, processCategoryId, processTaskInfos, deployId);
|
} catch (Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410106", new String[] {});
|
}
|
return res;
|
}
|
/**
|
* 通过任务节点获取阶段名称
|
* @param processDefinitionKey
|
* @param jbpmdeploymentid
|
* @return
|
* @throws VCIError
|
*/
|
public String getTaskPhaseName(String processDefinitionKey,
|
String jbpmdeploymentid,FlowInstanceInfo var) throws VCIError {
|
try{
|
return new ProcessTemplateService(this.getUserEntity()).getTaskPhaseName(processDefinitionKey, jbpmdeploymentid,var);
|
}catch(Error e){
|
throw e;
|
}
|
}
|
public boolean deleteProcessDefinition(String deployId, String pdId) throws VCIError {
|
boolean res = false;
|
try {
|
res = service.deleteProcessDefinition(deployId, pdId);
|
} catch (VCIError ex) {
|
ex.printStackTrace();
|
throw ex;
|
} catch (Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410112", new String[] {});
|
}
|
return res;
|
}
|
|
public ProcessDefinitionInfo[] getProcessDefinitions(String processCategoryId) throws VCIError {
|
ProcessDefinitionInfo[] infos = new ProcessDefinitionInfo[0];
|
try {
|
List<ProcessDefinitionInfo> processDefinitions = new ProcessTemplateService().getProcessDefinitions(processCategoryId);
|
infos = processDefinitions.toArray(new ProcessDefinitionInfo[] {});
|
} catch (Exception ex) {
|
throw new VCIError("410107", new String[] {});
|
}
|
return infos;
|
}
|
public ProcessDefinitionInfo[] getAllProcessDefinitions() throws VCIError {
|
ProcessDefinitionInfo[] infos = new ProcessDefinitionInfo[0];
|
try {
|
List<ProcessDefinitionInfo> processDefinitions = new ProcessTemplateService().getAllProcessDefinitions();
|
infos = processDefinitions.toArray(new ProcessDefinitionInfo[] {});
|
} catch (Exception ex) {
|
throw new VCIError("410107", new String[] {});
|
}
|
return infos;
|
}
|
/**
|
* 编码专用
|
* @param processCategoryId
|
* @return
|
* @throws VCIError
|
*/
|
public ProcessDefinitionInfo[] getProcessDefinitionsForRMCode(String processCategoryId) throws VCIError {
|
ProcessDefinitionInfo[] infos = new ProcessDefinitionInfo[0];
|
try {
|
List<ProcessDefinitionInfo> processDefinitions = new ProcessTemplateService().getProcessDefinitionsForRMCode(processCategoryId);
|
infos = processDefinitions.toArray(new ProcessDefinitionInfo[] {});
|
} catch (Exception ex) {
|
throw new VCIError("410107", new String[] {});
|
}
|
return infos;
|
}
|
public ProcessDefinitionInfo[] getProcessDefinitionsByPage(String processCategoryId,String name, int pageSize, int pageIndex) throws VCIError {
|
ProcessDefinitionInfo[] infos = new ProcessDefinitionInfo[0];
|
try {
|
List<ProcessDefinitionInfo> processDefinitions = new ProcessTemplateService().getProcessDefinitionsByPage(processCategoryId,name, pageSize, pageIndex);
|
infos = processDefinitions.toArray(new ProcessDefinitionInfo[] {});
|
} catch (Exception ex) {
|
throw new VCIError("410107", new String[] {});
|
}
|
return infos;
|
}
|
public ProcessDefinitionInfo[] getProcessDefinitionByProcessDefinitionName(String processCategoryName,String processCategoryId) throws VCIError {
|
ProcessDefinitionInfo[] infos = new ProcessDefinitionInfo[0];
|
try {
|
List<ProcessDefinitionInfo> processDefinitions = new ProcessTemplateService().getProcessDefinitionByProcessDefinitionName(processCategoryName,processCategoryId);
|
infos = processDefinitions.toArray(new ProcessDefinitionInfo[] {});
|
} catch (Exception ex) {
|
throw new VCIError("410107", new String[] {});
|
}
|
return infos;
|
}
|
public ProcessDefinitionInfo getProcessDefinitionByDeployId(String deployId) throws VCIError {
|
ProcessDefinitionInfo info = new ProcessDefinitionInfo();
|
try {
|
info = new ProcessTemplateService().getProcessDefinitionByDeployId(deployId);
|
} catch (Exception ex) {
|
throw new VCIError("410115", new String[] {ex.getCause().getMessage()});
|
}
|
return info;
|
}
|
public byte[] getProcessResource(String jbpmDeploymentId, String resourceType) throws VCIError {
|
byte[] infos = new byte[0];
|
try {
|
infos = new ProcessTemplateService().getProcessResource(jbpmDeploymentId, resourceType);
|
} catch (Exception ex) {
|
throw new VCIError("410108", new String[] {});
|
}
|
return infos;
|
}
|
|
public String[] getNextCandidates(String jbpmDeploymentId, String taskName,
|
String outcome) throws VCIError {
|
String[] infos = new String[0];
|
try {
|
infos = new ProcessTemplateService().getNextCandidates(jbpmDeploymentId, taskName, outcome);
|
} catch (Exception ex) {
|
throw new VCIError("410122", new String[] {});
|
}
|
return infos;
|
}
|
|
/**
|
* 获取下一步任务候选人
|
* @param excutionId
|
* @param taskName
|
* @return
|
*/
|
public String[] nextTaskCandidateUsers(String excutionId,String taskName){
|
String[] infos = new String[0];
|
infos = new ProcessTemplateService().nextTaskCandidateUsers(excutionId, taskName);
|
return infos;
|
}
|
public String[] getNextTaskNames(String jbpmDeploymentId, String taskName,
|
String outcome) throws VCIError {
|
String[] infos = new String[0];
|
try {
|
infos = new ProcessTemplateService().getNextTaskNames(jbpmDeploymentId, taskName, outcome);
|
} catch (Exception ex) {
|
throw new VCIError("410123", new String[] {});
|
}
|
return infos;
|
}
|
public String[] getCurCandidates(String jbpmDeploymentId, String taskName,
|
String outcome, String excutionId) throws VCIError {
|
String[] infos = new String[0];
|
try {
|
infos = new ProcessTemplateService().getCurCandidates(jbpmDeploymentId, taskName, outcome, excutionId);
|
} catch (Exception ex) {
|
throw new VCIError("410124", new String[] {});
|
}
|
return infos;
|
}
|
public String[] getAllCandidatesForTask(String jbpmDeploymentId, String taskName,
|
String outcome) throws VCIError {
|
String[] infos = new String[0];
|
try {
|
infos = new ProcessTemplateService().getAllCandidatesForTask(jbpmDeploymentId, taskName, outcome);
|
} catch (Exception ex) {
|
throw new VCIError("410124", new String[] {});
|
}
|
return infos;
|
}
|
public String[] getCurConstituents(String jbpmDeploymentId, String taskName,
|
String outcome) throws VCIError {
|
String[] infos = new String[0];
|
try {
|
infos = new ProcessTemplateService().getCurConstituents(jbpmDeploymentId, taskName, outcome);
|
} catch (Exception ex) {
|
throw new VCIError("410124", new String[] {});
|
}
|
return infos;
|
}
|
public String[] getTrainName(String jbpmDeploymentId, String taskName,
|
String outcome) throws VCIError {
|
String[] infos = new String[0];
|
try {
|
infos = new ProcessTemplateService().getTrainName(jbpmDeploymentId, taskName, outcome);
|
} catch (Exception ex) {
|
throw new VCIError("410125", new String[] {});
|
}
|
return infos;
|
}
|
|
public ProcessDefinitionInfo[] getProcessDefinition(String rmTemplateId, String processType) throws VCIError {
|
|
ProcessDefinitionInfo[] infos = new ProcessDefinitionInfo[0];
|
try {
|
List<ProcessDefinition> processDefinitions = new ProcessTemplateService().getProcessDefinition(rmTemplateId, processType);
|
ProcessDefinition[] objects = processDefinitions.toArray(new ProcessDefinition[] {});
|
infos = this.convertProcessDefinitionsToProcessDefinitionInfos(objects);
|
} catch (Exception ex) {
|
throw new VCIError("410109", new String[] {});
|
}
|
return infos;
|
}
|
/**
|
* 获取全部流程定义
|
* @return
|
* @throws VCIError
|
*/
|
public ProcessDefinitionInfo[] getProcessDefinitionAll() throws VCIError {
|
|
ProcessDefinitionInfo[] infos = new ProcessDefinitionInfo[0];
|
try {
|
List<ProcessDefinition> processDefinitions = new ProcessTemplateService().getProcessDefinitionAll();
|
ProcessDefinition[] objects = processDefinitions.toArray(new ProcessDefinition[] {});
|
infos = this.convertProcessDefinitionsToProcessDefinitionInfos(objects);
|
} catch (Exception ex) {
|
throw new VCIError("410109", new String[] {});
|
}
|
return infos;
|
}
|
|
public void saveRMTemplateProcess(String rmTemplateId, String[] processTypes, String[] jbpmDeploymentIds) throws VCIError {
|
try {
|
|
new ProcessTemplateService().saveRMTemplateProcess(rmTemplateId, processTypes, jbpmDeploymentIds);
|
} catch (Exception ex) {
|
throw new VCIError("410110", new String[] {});
|
}
|
}
|
|
public boolean deleteRMTemplateProcess(String rmTemplateId) throws VCIError {
|
boolean res = false;
|
try {
|
res = new ProcessTemplateService().deleteRMTemplateProcess(rmTemplateId);
|
} catch (Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410111", new String[] {});
|
}
|
return res;
|
}
|
|
public FlowInstanceInfo getFlowInstanceInfo(String taskId) throws VCIError {
|
FlowInstanceInfo info = new FlowInstanceInfo();
|
try {
|
info = service.getFlowInstanceInfo(taskId);
|
} catch (Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410115", new String[] {});
|
}
|
return info;
|
}
|
|
public TaskDescInfo[] getTaskDescList(String taskName, String deploymentId){
|
List<TaskDescSObject> list = new ProcessTemplateService().getTaskDescList(taskName, deploymentId);
|
TaskDescInfo[] taskDescinfo = new TaskDescInfo[list.size()];
|
for(int i=0;i<list.size();i++){
|
TaskDescSObject object = list.get(i);
|
taskDescinfo[i] = convertTaskDescObjToInfo(object);
|
}
|
return taskDescinfo;
|
}
|
|
/************************* CORBA & HIBERNATE CONVERT **************************/
|
/**
|
* 对象转换(批量)，从Corba对象转换到Hibernate对象
|
*
|
* @param objects
|
*/
|
private TaskDescInfo convertTaskDescObjToInfo(TaskDescSObject o){
|
TaskDescInfo info = new TaskDescInfo();
|
info.id = o.getId() == null ? "" : o.getId();
|
info.pljbpmdeploymentid = o.getPljbpmdeploymentid() == null?"":o.getPljbpmdeploymentid();
|
info.pltask = o.getPltask() ==null?"":o.getPltask();
|
info.pltaskdesc = o.getPltaskdesc() ==null?"":o.getPltaskdesc();
|
info.pltreatment = o.getPltreatment() ;
|
info.popUserDialog = o.getPopUserDialog()==null?"":o.getPopUserDialog();
|
info.customclassname = o.getPlcustomclassname()==null?"":o.getPlcustomclassname();
|
info.customparam = o.getPlcustomparam()==null?"":o.getPlcustomparam();
|
return info;
|
}
|
private ProcessCategoryInfo[] convertProcessCategorysToProcessCategoryInfos(ProcessCategory[] objects) {
|
ProcessCategoryInfo[] infos = new ProcessCategoryInfo[objects.length];
|
int i = 0;
|
for (ProcessCategory obj : objects) {
|
infos[i++] = this.convertProcessCategoryToProcessCategoryInfo(obj);
|
}
|
return infos;
|
}
|
|
private ProcessCategoryInfo convertProcessCategoryToProcessCategoryInfo(ProcessCategory object) {
|
ProcessCategoryInfo info = new ProcessCategoryInfo();
|
info.id = object.getId() == null ? "" : object.getId();
|
info.parentId = object.getId() == null ? "" : object.getParentId();
|
info.name = object.getName() == null ? "" : object.getName();
|
info.desc = object.getDesc() == null ? "" : object.getDesc();
|
info.icon = object.getIcon() == null ? "" : object.getIcon();
|
info.createTime = object.getCreateTime().getTime();
|
info.createUser = object.getCreateUser() == null ? "" : object.getCreateUser();
|
info.createRole = object.getCreateRole() == null ? "" : object.getCreateRole();
|
info.createOrg = object.getCreateOrg() == null ? "" : object.getCreateOrg();
|
info.modifyTime = object.getModifyTime().getTime();
|
info.modifyUser = object.getModifyUser() == null ? "" : object.getModifyUser();
|
info.modifyRole = object.getModifyRole() == null ? "" : object.getModifyRole();
|
info.modifyOrg = object.getModifyOrg() == null ? "" : object.getModifyOrg();
|
return info;
|
}
|
|
private ProcessCategory convertProcessCategoryInfoToProcessCategory(ProcessCategoryInfo info) {
|
ProcessCategory object = new ProcessCategory();
|
object.setId(info.id);
|
object.setParentId(info.parentId);
|
object.setName(info.name);
|
object.setDesc(info.desc);
|
object.setIcon(info.icon);
|
object.setCreateTime(new Date(info.createTime));
|
object.setCreateUser(info.createUser);
|
object.setCreateRole(info.createRole);
|
object.setCreateOrg(info.createOrg);
|
object.setModifyTime(new Date(info.modifyTime));
|
object.setModifyUser(info.modifyUser);
|
object.setModifyRole(info.modifyRole);
|
object.setModifyOrg(info.modifyOrg);
|
return object;
|
}
|
|
private ProcessDefinitionInfo[] convertProcessDefinitionsToProcessDefinitionInfos(ProcessDefinition[] objects) {
|
ProcessDefinitionInfo[] infos = new ProcessDefinitionInfo[objects.length];
|
int i = 0;
|
for (ProcessDefinition obj : objects) {
|
infos[i++] = this.convertProcessDefinitionToProcessDefinitionInfo(obj);
|
}
|
return infos;
|
}
|
|
private ProcessDefinitionInfo convertProcessDefinitionToProcessDefinitionInfo(ProcessDefinition object) {
|
ProcessDefinitionInfo info = new ProcessDefinitionInfo();
|
info.id = object.getId() == null ? "" : object.getId();
|
info.name = object.getName() == null ? "" : object.getName();
|
info.key = object.getKey() == null ? "" : object.getKey();
|
info.version = object.getVersion();
|
info.jbpmDeploymentId = object.getDeploymentId() == null ? "" : object.getDeploymentId();
|
return info;
|
}
|
|
public boolean startProcessInstanceByKey(String processDefinitionKey, FlowInstanceInfo var, String[] objId,String[] userName,String outcome) throws VCIError{
|
try{
|
return new ProcessTemplateService(this.getUserEntity()).startProcessInstanceByKey(processDefinitionKey, var, objId,userName,outcome);
|
}catch(VCIError e){
|
e.printStackTrace();
|
throw e;
|
}
|
}
|
// public boolean startProcessInstanceByKey(String processDefinitionKey, FlowInstanceInfo var, String[] objId,String[] userNames) throws VCIError{
|
// try{
|
// return new ProcessTemplateService(this.getUserEntity()).startProcessInstanceByKey(processDefinitionKey, var, objId,userNames);
|
// }catch(Error e){
|
// throw e;
|
// }
|
// }
|
|
public String startPocessSetUser(String processDefinitionKey,
|
FlowInstanceInfo flowInstanceInfo, String[] objId,
|
UserEntityInfo userEntityInfo, String[] userName, String outcome,
|
String[] tasknames, String[][] taskUserNames) throws VCIError{
|
Map<String,String[]> taskAndUserMap = new HashMap<String, String[]>();
|
for(int i=0;i<tasknames.length;i++){
|
taskAndUserMap.put(tasknames[i], taskUserNames[i]);
|
}
|
return new ProcessTemplateService(this.getUserEntity()).startPocessSetUser(processDefinitionKey, flowInstanceInfo, objId, userName, outcome, taskAndUserMap);
|
}
|
public String startPocessSetUser(String processDefinitionKey,
|
FlowInstanceInfo flowInstanceInfo, String[] objId,
|
UserEntityInfo userEntityInfo, String[] userName, String outcome,
|
String[] tasknames, String[][] taskUserNames,String[] keys,String[] values) throws VCIError{
|
Map<String,String[]> taskAndUserMap = new HashMap<String, String[]>();
|
for(int i=0;i<tasknames.length;i++){
|
taskAndUserMap.put(tasknames[i], taskUserNames[i]);
|
}
|
return new ProcessTemplateService(this.getUserEntity()).startPocessSetUser(processDefinitionKey, flowInstanceInfo, objId, userName, outcome, taskAndUserMap,keys,values);
|
}
|
public String startPocessByPLM(String processDefinitionKey,
|
FlowInstanceInfo flowInstanceInfo, String[] objId,
|
UserEntityInfo userEntityInfo, String[] userName, String outcome,
|
String[] tasknames, String[][] taskUserNames,MapTransfersInfo[] mapTransfersServerObject) throws VCIError{
|
Map<String,String[]> taskAndUserMap = new HashMap<String, String[]>();
|
for(int i=0;i<tasknames.length;i++){
|
taskAndUserMap.put(tasknames[i], taskUserNames[i]);
|
}
|
Map<String,Object> mapParams = new HashMap<String, Object>();
|
for(int i=0;i<mapTransfersServerObject.length;i++){
|
mapParams.put(mapTransfersServerObject[i].key, mapTransfersServerObject[i].value);
|
}
|
return new ProcessTemplateService(this.getUserEntity()).startPocessByPLM(processDefinitionKey, flowInstanceInfo, objId, userName, outcome, taskAndUserMap, mapParams);
|
}
|
|
public void setTaskAndUserForComplete(String executionId,String[] tasknames,String[][] taskUserNames){
|
Map<String,String[]> taskAndUserMap = new HashMap<String, String[]>();
|
for(int i=0;i<tasknames.length;i++){
|
taskAndUserMap.put(tasknames[i], taskUserNames[i]);
|
}
|
new ProcessTemplateService(this.getUserEntity()).setTaskAndUserForComplete(executionId,taskAndUserMap);
|
}
|
// public boolean startProcessInstanceByKeyForWuyuan(String processDefinitionKey, FlowInstanceInfo var, String[] objId,String[] userName,String outcome) throws VCIError{
|
// try{
|
// return new ProcessTemplateService(this.getUserEntity()).startProcessInstanceByKeyForWuyuan(processDefinitionKey, var, objId,userName,outcome);
|
// }catch(Error e){
|
// throw e;
|
// }
|
// }
|
|
// public FlowTaskInfo[] getTodoTaskByUserId(String pluseroid,int first,int pageSize, String expandSql) {
|
// return new ProcessTemplateService().getTodoTaskByUserId(pluseroid,first,pageSize, expandSql);
|
// }
|
|
/**
|
* 编码资源专用-待办任务
|
* @param pluseroid
|
* @param first
|
* @param pageSize
|
* @param taskType
|
* @param sql
|
* @return
|
*/
|
public FlowTaskInfo[] getTodoTaskByUserId(String pluseroid,int first,int pageSize,String taskType,String sql) {
|
return new ProcessTemplateService().getTodoTaskByUserId(pluseroid,first,pageSize,taskType,sql);
|
}
|
/**
|
* 待办任务-可排序
|
* @param pluseroid
|
* @param first
|
* @param pageSize
|
* @param taskType
|
* @param sql
|
* @param orderStr
|
* @return
|
*/
|
public FlowTaskInfo[] getTodoTaskCompositorByUserId(String pluseroid,int first,int pageSize,String taskType,String sql,String orderStr) {
|
return new ProcessTemplateService().getTodoTaskCompositorByUserId(pluseroid, first, pageSize, taskType, sql, orderStr);
|
}
|
// public int queryTodoTaskCount(String pluseroid, String expandSql) throws VCIError{
|
// int count = 1;
|
// try{
|
// count = new ProcessTemplateService().queryTodoTaskCount(pluseroid, expandSql);
|
// }catch(Exception ex) {
|
// ex.printStackTrace();
|
// throw new VCIError(410119, new String[] {});
|
// }
|
// return count;
|
// }
|
/**
|
* 编码专用
|
* @param pluseroid
|
* @param expandSql
|
* @return
|
* @throws VCIError
|
*/
|
public int queryTodoTaskCount(String pluseroid, String expandSql) throws VCIError{
|
int count = 1;
|
try{
|
count = new ProcessTemplateService().queryTodoTaskCount(pluseroid, expandSql);
|
}catch(Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410119", new String[] {});
|
}
|
return count;
|
}
|
|
/**
|
* 抄送消息列表
|
* @param pluseroid
|
* @param first
|
* @param pageSize
|
* @return
|
*/
|
public FlowTaskInfo[] getCCTaskByUserId(String pluseroid,int first,int pageSize) {
|
return new ProcessTemplateService().getCCTaskByUserId(pluseroid,first,pageSize);
|
}
|
|
/**
|
* 抄送消息总数
|
* @param pluseroid
|
* @return
|
* @throws VCIError
|
*/
|
public int queryCCTaskCount(String pluseroid) throws VCIError{
|
int count = 1;
|
try{
|
count = new ProcessTemplateService().queryCCTaskCount(pluseroid);
|
}catch(Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410119", new String[] {});
|
}
|
return count;
|
}
|
|
public FlowTaskInfo[] getDoneTaskByUserId(String pluseroid) {
|
// return new ProcessTemplateService().getDoneTaskByUserId(pluseroid);
|
return new FlowTaskInfo[]{};
|
}
|
|
// public FlowTaskInfo[] getTrackTaskByUserId(String pluseroid,int first,int pageSize, String expandSql) {
|
// return new ProcessTemplateService().getTrackTaskByUserId(pluseroid,first,pageSize, expandSql);
|
// }
|
|
/**
|
* 跟踪流程
|
* @param pluseroid
|
* @param first
|
* @param pageSize
|
* @param taskType
|
* @param querySQL
|
* @return
|
*/
|
public FlowTaskInfo[] getTrackTaskByUserId(String pluseroid,int first,int pageSize,String taskType,String querySQL) {
|
return new ProcessTemplateService().getTrackTaskByUserId(pluseroid, first, pageSize, taskType, querySQL);
|
}
|
|
/**
|
* 我发起的流程
|
* 2013-4-9
|
* @param pluseroid
|
* @param first
|
* @param pageSize
|
* @return
|
*/
|
public FlowTaskInfo[] getMyTrackProcessByUserId(String pluseroid,int first,int pageSize, String expandSql) {
|
return new ProcessTemplateService().getMyTrackProcessByUserId(pluseroid,first,pageSize, expandSql);
|
}
|
/**
|
* 我发起的流程-可排序
|
* @param pluseroid
|
* @param first
|
* @param pageSize
|
* @param expandSql
|
* @param orderStr
|
* @return
|
*/
|
public FlowTaskInfo[] getMyTrackProcessCompositorByUserId(String pluseroid,int first,int pageSize, String expandSql,String orderStr) {
|
return new ProcessTemplateService().getMyTrackProcessCompositorByUserId(pluseroid, first, pageSize, expandSql, orderStr);
|
}
|
|
/**
|
* 根据数据查询流程示例
|
* @param dataId
|
* @param tableName TODO
|
* @return
|
*/
|
public FlowTaskInfo[] getFlowTaskInfoByDataId(String dataId, String tableName) {
|
return new ProcessTemplateService().getFlowTaskInfoByDataId(dataId, tableName);
|
}
|
/** 根据数据id查询流程实例
|
* @param dataIds
|
* @param tableName
|
* @return
|
*/
|
public String[] getFlowTaskInfoByDataIds(String[] dataIds, String tableName) {
|
return new ProcessTemplateService().getFlowTaskInfoByDataIds(dataIds, tableName);
|
}
|
|
// public int queryTraceTaskCount(String pluseroid, String expandSql) throws VCIError{
|
// int count = 1;
|
// try{
|
// count = new ProcessTemplateService().queryTraceTaskCount(pluseroid, expandSql);
|
// }catch(Exception ex) {
|
// ex.printStackTrace();
|
// throw new VCIError(410118, new String[] {});
|
// }
|
// return count;
|
// }
|
/**
|
* 跟踪流程总数查询
|
* @param pluseroid
|
* @param expandSql
|
* @return
|
* @throws VCIError
|
*/
|
public int queryTraceTaskCount(String pluseroid, String expandSql) throws VCIError{
|
int count = 1;
|
try{
|
count = new ProcessTemplateService().queryTraceTaskCount(pluseroid, expandSql);
|
}catch(Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410118", new String[] {});
|
}
|
return count;
|
}
|
public int queryMyTraceProcessCount(String pluseroid, String expandSql) throws VCIError{
|
int count = 1;
|
try{
|
count = new ProcessTemplateService().queryMyTraceProcessCount(pluseroid, expandSql);
|
}catch(Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410118", new String[] {});
|
}
|
return count;
|
}
|
|
public boolean completeTask(String taskId, String outcome,String nextTask, String approvalNote,String[] userName) throws VCIError {
|
try{
|
return new ProcessTemplateService(this.getUserEntity()).completeTask(taskId, outcome, nextTask,approvalNote,userName);
|
}catch(VCIError e){
|
throw e;
|
}
|
}
|
public boolean completeTask(String taskId, String outcome,String nextTask, String approvalNote,String[] userName,String[] keys,String[] values) throws VCIError {
|
try{
|
return new ProcessTemplateService(this.getUserEntity()).completeTask(taskId, outcome, nextTask,approvalNote,userName,keys,values);
|
}catch(VCIError e){
|
throw e;
|
}
|
}
|
public boolean completeTaskByPlatform(String taskId, String outcome,String nextTask, String approvalNote,String[] userName) throws VCIError {
|
try{
|
return new ProcessTemplateService(this.getUserEntity()).completeTaskByPlatform(taskId, outcome, nextTask,approvalNote,userName);
|
}catch(VCIError e){
|
throw e;
|
}
|
}
|
|
/**
|
* 获取任务的子任务
|
* @param taskId
|
* @return
|
*/
|
public String[] getsubTasks( String taskId){
|
List<Task> getsubTasks = new ProcessTemplateService().getsubTasks(taskId);
|
String[] subTasks = new String[getsubTasks.size()];
|
for(int i=0;i<getsubTasks.size();i++){
|
subTasks[i] = getsubTasks.get(i).getName();
|
}
|
return subTasks;
|
}
|
/**
|
* 编码资源专用-任务提交
|
* @param taskId
|
* @param outcome
|
* @param approvalNote
|
* @param userNames
|
* @throws VCIError
|
*/
|
public void completeTask(String taskId, String outcome, String approvalNote,String[] userNames) throws VCIError {
|
try{
|
new ProcessTemplateService(this.getUserEntity()).completeTask(taskId, outcome, approvalNote, userNames);
|
}catch(Error e){
|
throw e;
|
}
|
}
|
|
public ProcessTaskInfo findTaskPropertyById(String jbpmDeploymentId, String name) {
|
return new ProcessTemplateService().findTaskPropertyById(jbpmDeploymentId, name);
|
}
|
|
public FlowApproveHistoryInfo[] getHistoryActivityByProInsId(String processInstanceId) {
|
List<FlowApproveHistory> list = new ProcessTemplateService().getHistoryActivityByProInsId(processInstanceId);
|
return convListToFlowApproveHistoryInfo(list);
|
|
}
|
|
private FlowApproveHistoryInfo[] convListToFlowApproveHistoryInfo(List<FlowApproveHistory> list) {
|
FlowApproveHistoryInfo[] f = new FlowApproveHistoryInfo[list.size()];
|
|
for (int i = 0; i < list.size(); i++) {
|
FlowApproveHistory flowApproveHistory = list.get(i);
|
f[i] = new FlowApproveHistoryInfo();
|
f[i].taskId = flowApproveHistory.getTaskId() == null?"":flowApproveHistory.getTaskId();
|
f[i].executionId = flowApproveHistory.getExecutionId() == null ? "" : flowApproveHistory.getExecutionId();
|
f[i].taskName = flowApproveHistory.getTaskName() == null ? "" : flowApproveHistory.getTaskName();
|
f[i].opinion = flowApproveHistory.getOpinion() == null ? "" : flowApproveHistory.getOpinion();
|
f[i].assignee = flowApproveHistory.getAssignee() == null ? "" : flowApproveHistory.getAssignee();
|
f[i].createTime = flowApproveHistory.getCreateTime() == null ? 0 : flowApproveHistory.getCreateTime().getTime();
|
f[i].endTime = flowApproveHistory.getEndTime() == null ? 0 : flowApproveHistory.getEndTime().getTime();
|
f[i].note = flowApproveHistory.getNote() == null ? "" : flowApproveHistory.getNote();
|
|
f[i].parentTaskId = flowApproveHistory.getParentTaskId() == null ? "" : flowApproveHistory.getParentTaskId();
|
}
|
return f;
|
}
|
|
public byte[] getExecutionImageByExecutionId(String executionId, String taskName) throws IOException {
|
return new ProcessTemplateService().getExecutionImageByExecutionId(executionId, taskName);
|
}
|
public byte[] getExecutionImage(String executionId) throws IOException {
|
return new ProcessTemplateService().getExecutionImage(executionId);
|
}
|
|
public FlowObjectInfo[] getFlowObjectByExecutionId(String executionId) {
|
List<PLFlowObject> list = new ProcessTemplateService().getFlowObjectByExecutionId(executionId);
|
return convListToInfo(list);
|
}
|
|
private FlowObjectInfo[] convListToInfo(List<? extends PLFlowObject> list) {
|
FlowObjectInfo[] flowObjectInfo = new FlowObjectInfo[list.size()];
|
for (int i = 0; i < list.size(); i++) {
|
PLFlowObject flowObject = list.get(i);
|
flowObjectInfo[i] = new FlowObjectInfo();
|
flowObjectInfo[i].ploid = flowObject.getPloid() == null ? "" : flowObject.getPloid();
|
flowObjectInfo[i].plexecutionid = flowObject.getPlexecutionid() == null ? "" : flowObject.getPlexecutionid();
|
flowObjectInfo[i].plprocesstype = flowObject.getPlprocesstype() == null ? "" : flowObject.getPlprocesstype();
|
flowObjectInfo[i].plobjectid = flowObject.getPlobjectid() == null ? "" : flowObject.getPlobjectid();
|
flowObjectInfo[i].initStatus = flowObject.getInitStatus() == null ? "" : flowObject.getInitStatus();
|
}
|
return flowObjectInfo;
|
}
|
|
public String getDeploymentIdByExecutionId(String executionId) {
|
return new ProcessTemplateService().getDeploymentIdByExecutionId(executionId);
|
}
|
|
public void endProcessInstance(String processInstanceId) throws VCIError {
|
new ProcessTemplateService(this.getUserEntity()).endProcessInstance(processInstanceId);
|
}
|
public void endProcessInstanceByplatform(String processInstanceId) throws VCIError {
|
new ProcessTemplateService(this.getUserEntity()).endProcessInstanceByplatform(processInstanceId);
|
}
|
|
public ProcessDefinitionInfo[] getProcessDefinitionByType(String processType) throws VCIError {
|
|
ProcessDefinitionInfo[] infos = new ProcessDefinitionInfo[0];
|
try {
|
List<ProcessDefinition> processDefinitions = new ProcessTemplateService().getProcessDefinitionByType(processType);
|
ProcessDefinition[] objects = processDefinitions.toArray(new ProcessDefinition[] {});
|
infos = this.convertProcessDefinitionsToProcessDefinitionInfos(objects);
|
} catch (Exception ex) {
|
throw new VCIError("410109", new String[] {});
|
}
|
return infos;
|
}
|
|
|
public String getDepolymentID(String executionId) throws VCIError {
|
String str = "";
|
try{
|
ProcessTemplateService srv = new ProcessTemplateService();
|
str = srv.getDepolymentID(executionId);
|
}catch(Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("-1", new String[] {});
|
}
|
return str;
|
}
|
public byte[] getFlowImageByDeployID(String deployID) throws VCIError,IOException {
|
return new ProcessTemplateService().getFlowImageByDeployID(deployID);
|
}
|
// public FlowTaskInfo[] getDoneTaskByUserId(String pluseroid,int first,int pageSize, String expandSql) {
|
// return new ProcessTemplateService().getDoneTaskByUserId(pluseroid,first,pageSize, expandSql);
|
// }
|
|
/**
|
* 已办任务
|
* @param pluseroid
|
* @param first
|
* @param pageSize
|
* @param taskType
|
* @param querySQL
|
* @return
|
*/
|
public FlowTaskInfo[] getDoneTaskByUserId(String pluseroid,int first,int pageSize,String taskType,String querySQL) {
|
return new ProcessTemplateService().getDoneTaskByUserId(pluseroid, first, pageSize, taskType, querySQL);
|
}
|
/**
|
* 已办任务-可排序
|
* @param pluseroid
|
* @param first
|
* @param pageSize
|
* @param taskType
|
* @param querySQL
|
* @param orderStr
|
* @return
|
*/
|
public FlowTaskInfo[] getDoneTaskCompositorByUserId(String pluseroid,int first,int pageSize,String taskType,String querySQL,String orderStr) {
|
return new ProcessTemplateService().getDoneTaskCompositorByUserId(pluseroid, first, pageSize, taskType, querySQL, orderStr);
|
}
|
|
// public int queryDoneTaskCount(String pluseroid, String expandSql) throws VCIError{
|
// int count = 1;
|
// try{
|
// count = new ProcessTemplateService().queryDoneTaskCount(pluseroid, expandSql);
|
// }catch(Exception ex) {
|
// ex.printStackTrace();
|
// throw new VCIError(410117, new String[] {});
|
// }
|
// return count;
|
// }
|
/**
|
* 已办任务总数
|
* @param pluseroid
|
* @param expandSql
|
* @return
|
* @throws VCIError
|
*/
|
public int queryDoneTaskCount(String pluseroid,String expandSql) throws VCIError{
|
int count = 1;
|
try{
|
count = new ProcessTemplateService().queryDoneTaskCount(pluseroid, expandSql);
|
}catch(Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410117", new String[] {});
|
}
|
return count;
|
}
|
public boolean checkKey(String name, String keyValue) throws VCIError{
|
return new ProcessTemplateService().checkKey(name, keyValue);
|
}
|
public String[] getDeployId(String taskId) throws VCIError {
|
return new ProcessTemplateService().getDeployId(taskId);
|
}
|
|
/**
|
* 判断下一任务节点是否是end节点
|
* @param jbpmDeploymentId
|
* @param taskName
|
* @return
|
* @throws VCIError
|
*/
|
public boolean getProcessTaskByTaskName(String taskId,String taskName,String outcome) throws VCIError{
|
try {
|
return new ProcessTemplateService().getProcessTaskByTaskName(taskId, taskName, outcome);
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new VCIError("410202", new String[]{e.getMessage()});
|
}
|
}
|
|
/**
|
* 五院专用
|
* @param pluseroid
|
* @param first
|
* @param pageSize
|
* @return
|
*/
|
public FlowTaskInfo[] getTodoTaskByUser(String pluseroid,int first,int pageSize) {
|
FlowTaskInfo[] taskInfo = new ProcessTemplateService().getTodoTaskByUserId(pluseroid,first,pageSize,"","");
|
// FlowTaskInfo[] todoTask = new FlowTaskInfo[taskInfo.length];
|
for(int i=0;i<taskInfo.length;i++){
|
taskInfo[i].executionId = convertGBKToISO_8859_1(taskInfo[i].executionId);
|
taskInfo[i].plclsfoid = convertGBKToISO_8859_1(taskInfo[i].plclsfoid);
|
taskInfo[i].createTime = taskInfo[i].createTime;
|
taskInfo[i].create = convertGBKToISO_8859_1(taskInfo[i].create);
|
taskInfo[i].desc = convertGBKToISO_8859_1(taskInfo[i].desc);
|
taskInfo[i].name = convertGBKToISO_8859_1(taskInfo[i].name);
|
taskInfo[i].templateName = convertGBKToISO_8859_1(taskInfo[i].templateName);
|
taskInfo[i].processName = convertGBKToISO_8859_1(taskInfo[i].processName);
|
}
|
return taskInfo;
|
}
|
|
static String convertGBKToISO_8859_1(String text){
|
return convertEncoding(text, "GBK", "ISO-8859-1");
|
}
|
static String convertISO_8859_1ToGBK(String text){
|
return convertEncoding(text, "ISO-8859-1", "GBK");
|
}
|
static String convertEncoding(String text, String fromEncoding, String toEncoding){
|
String res = text;
|
try {
|
res = new String(text.getBytes(fromEncoding), toEncoding);
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
return res;
|
}
|
|
public String[] getNextTask(String executionId, String taskName,
|
String outcome) throws VCIError {
|
executionId = convertISO_8859_1ToGBK(executionId);
|
taskName = convertISO_8859_1ToGBK(taskName);
|
outcome = convertISO_8859_1ToGBK(outcome);
|
String jbpmDeploymentId = getDeploymentIdByExecutionId(executionId);
|
String[] nextTaskNames = getNextTaskNames(jbpmDeploymentId, taskName, outcome);
|
for(int i=0;i<nextTaskNames.length;i++){
|
nextTaskNames[i] = convertGBKToISO_8859_1(nextTaskNames[i]);
|
}
|
return nextTaskNames;
|
}
|
public String[] getUserNames(String executionId, String taskName,
|
String outcome) throws VCIError {
|
executionId = convertISO_8859_1ToGBK(executionId);
|
// taskName = convertISO_8859_1ToGBK(taskName);
|
// outcome = convertISO_8859_1ToGBK(outcome);
|
String jbpmDeploymentId = getDeploymentIdByExecutionId(executionId);
|
String[] userName = getCurCandidates(jbpmDeploymentId, taskName, outcome, executionId);
|
for(int i=0;i<userName.length;i++){
|
userName[i] = convertGBKToISO_8859_1(userName[i]);
|
}
|
return userName;
|
}
|
|
//获取全部任务列表
|
public String[] getAllTaskNames(String jbpmDeploymentId) throws VCIError {
|
try {
|
return new ProcessTemplateService(this.getUserEntity()).getAllTaskNames(jbpmDeploymentId);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return new String[0];
|
}
|
//获取任务对用的自定义URl
|
public String getUrlPath(String jbpmDeploymentId,String taskName) throws VCIError {
|
try {
|
return new ProcessTemplateService(this.getUserEntity()).getUrlPath(jbpmDeploymentId, taskName);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return "";
|
}
|
//获取路由对应的自定义URl
|
public String[] getTrainsitionUrlPath(String jbpmDeploymentId,String taskName,String trainsitionName) throws VCIError {
|
try {
|
return new ProcessTemplateService(this.getUserEntity()).getTrainsitionUrlPath(jbpmDeploymentId, taskName, trainsitionName);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return new String[]{};
|
}
|
/**
|
* 转交任务
|
* @param fromUser
|
* @param username
|
* @return
|
* @throws VCIError
|
*/
|
public boolean assignTask(String fromUser,String username) throws VCIError {
|
boolean flag = false;
|
try {
|
flag = new ProcessTemplateService(this.getUserEntity()).assignTask(fromUser,username);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return flag;
|
}
|
public boolean assignTaskByPlatform(String taskId,String username) throws VCIError {
|
boolean flag = false;
|
try {
|
flag = new ProcessTemplateService(this.getUserEntity()).assignTaskByPlatform(taskId,username);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return flag;
|
}
|
|
/**
|
* 任务转发
|
* @param taskid
|
* @param toUserName
|
* @return
|
*/
|
public boolean transmitTask(String taskid,String toUserName,UserEntityInfo userEntityInfo){
|
boolean flag = false;
|
try {
|
flag = new ProcessTemplateService(this.getUserEntity()).transmitTask(taskid, toUserName);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return flag;
|
}
|
public boolean transmitTaskByPlatform(String[] taskids,String toUserName,UserEntityInfo userEntityInfo){
|
boolean flag = false;
|
try {
|
for(String taskid : taskids){
|
new ProcessTemplateService(this.getUserEntity()).transmitTaskByPlatform(taskid, toUserName);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return flag;
|
}
|
|
|
/**
|
* 获取当前任务路由
|
* @param taskID 任务ID
|
* @return
|
* @throws VCIError
|
*/
|
public String[] getAllOutComes(String taskID) throws VCIError{
|
try{
|
|
return new ProcessTemplateService().getAllOutComes(taskID);
|
}catch(Exception e){
|
e.getStackTrace();
|
throw new VCIError("410301",new String[0]);
|
}
|
|
}
|
|
public boolean saveOrUpdateTasksAssigned(TasksAssignedInfo tasksAssignedInfo) throws VCIError{
|
boolean res = false;
|
TasksAssigned tasksAssigned = new TasksAssigned();
|
tasksAssigned.setId(tasksAssignedInfo.id);
|
// tasksAssigned.setTasksId(tasksAssignedInfo.TasksId);
|
tasksAssigned.setTasksName(tasksAssignedInfo.TasksName);
|
tasksAssigned.setUserName(tasksAssignedInfo.userName);
|
// tasksAssigned.setTasksTrueName(tasksAssignedInfo.TasksTrueName);
|
tasksAssigned.setIsTrue(tasksAssignedInfo.isTrue);
|
tasksAssigned.setStartTime(new Date(tasksAssignedInfo.startTime));
|
tasksAssigned.setEndTime(new Date(tasksAssignedInfo.endTime));
|
tasksAssigned.setFromUser(tasksAssignedInfo.fromUser);
|
try{
|
res = new ProcessTemplateService().saveOrUpdateTasksAssigned(tasksAssigned);
|
}catch(Exception e){
|
e.getStackTrace();
|
}
|
return res;
|
}
|
|
public TasksAssignedInfo getTasksAssignedByUserName(String userName) throws VCIError{
|
TasksAssigned tasksAssigned;
|
tasksAssigned = new ProcessTemplateService(this.getUserEntity()).getTasksAssignedByUserName(userName);
|
TasksAssignedInfo info = new TasksAssignedInfo();
|
info.id = tasksAssigned.getId();
|
// info.TasksId = tasksAssigned.getTasksId();
|
info.TasksName = tasksAssigned.getTasksName();
|
// info.TasksTrueName = tasksAssigned.getTasksTrueName();
|
info.userName = tasksAssigned.getUserName();
|
info.isTrue = tasksAssigned.getIsTrue();
|
info.startTime = tasksAssigned.getStartTime().getTime();
|
info.endTime = tasksAssigned.getEndTime().getTime();
|
info.fromUser = tasksAssigned.getFromUser()==null?"":tasksAssigned.getFromUser();
|
return info;
|
}
|
|
public TasksAssignedInfo[] getAllTasksAssignedByUserName(String userName) throws VCIError{
|
TasksAssigned[] tasksAssigneds = new ProcessTemplateService(this.getUserEntity()).getAllTasksAssignedByUserName(userName);
|
|
List<TasksAssignedInfo> lstTaskAssign = new ArrayList<TasksAssignedInfo>();
|
|
for (TasksAssigned a : tasksAssigneds){
|
TasksAssignedInfo info = new TasksAssignedInfo();
|
info.id = a.getId();
|
// info.TasksId = tasksAssigned.getTasksId();
|
info.TasksName = a.getTasksName();
|
// info.TasksTrueName = tasksAssigned.getTasksTrueName();
|
info.userName = a.getUserName();
|
info.isTrue = a.getIsTrue();
|
info.startTime = a.getStartTime().getTime();
|
info.endTime = a.getEndTime().getTime();
|
info.fromUser = a.getFromUser()==null?"":a.getFromUser();
|
|
lstTaskAssign.add(info);
|
}
|
return lstTaskAssign.toArray(new TasksAssignedInfo[0]);
|
}
|
|
public void saveSubProcess(SubprocessTemInfo[] subprocessTemInfos){
|
new ProcessTemplateService().saveSubProcess(subprocessTemInfos);
|
}
|
public int checkSubprocessQuote(String subProcess){
|
return new ProcessTemplateService().checkSubprocessQuote(subProcess);
|
}
|
|
public void configTaskAndUser(String deploymentId,String[] dataIds,String[] taskName,String[][] userName){
|
Map<String,String[]> taskAndUserMap = new HashMap<String, String[]>();
|
for(int i=0;i<taskName.length;i++){
|
taskAndUserMap.put(taskName[i], userName[i]);
|
}
|
// new ProcessTemplateService().configTaskAndUser(deploymentId, dataIds, taskAndUserMap);
|
}
|
|
/**
|
* 通过流程定义ID获取部署ID
|
* @param processDifId
|
* @return
|
*/
|
public String getDeployIdByProcessDefintionId(String processDifId){
|
return new ProcessTemplateService().getDeployIdByProcessDefintionId(processDifId);
|
}
|
/**
|
* 判断节点是否是end节点
|
* @param jbpmDeploymentId
|
* @param endTaskName
|
* @return
|
* @throws Exception
|
*/
|
public boolean getEndNode(String jbpmDeploymentId,String endTaskName){
|
try {
|
return new ProcessTemplateService().getEndNode(jbpmDeploymentId, endTaskName);
|
} catch (Exception e) {
|
e.printStackTrace();
|
return false;
|
}
|
}
|
|
public boolean isEndNode(String executionId,String endTaskName){
|
try {
|
executionId = convertISO_8859_1ToGBK(executionId);
|
endTaskName = convertISO_8859_1ToGBK(endTaskName);
|
ServerWithLog4j.logger.debug("executionId=="+executionId + "; endTaskName=="+endTaskName);
|
String jbpmDeploymentId = getDeploymentIdByExecutionId(executionId);
|
ServerWithLog4j.logger.debug("isEndNode==jbpmDeploymentId=="+jbpmDeploymentId);
|
return getEndNode(jbpmDeploymentId, endTaskName);
|
} catch (Exception e) {
|
e.printStackTrace();
|
return false;
|
}
|
}
|
|
public String getNextTaskAssigner(String executionId, String taskName) {
|
return new ProcessTemplateService().getNextTaskAssigner(executionId, taskName);
|
}
|
public String getNextSubTaskAssigner(String executionId, String taskName, String outcome) throws Exception {
|
return new ProcessTemplateService().getNextSubTaskAssigner(executionId, taskName, outcome);
|
}
|
|
public ProcessTaskInfo findTaskPropertyByProcessId(String jbpmDeploymentId) {
|
return new ProcessTemplateService().findTaskPropertyByProcessId(jbpmDeploymentId);
|
}
|
/**
|
* 返回任节点上定义的候选人字符串内容
|
* <p>Description: </p>
|
*
|
* @author xchao
|
* @time 2012-11-10
|
* @param jbpmDeploymentId
|
* @param taskName
|
* @param outcome
|
* @return
|
* @throws Exception
|
*/
|
public String getNextCandidatesDefineString(String jbpmDeploymentId, String taskName,
|
String outcome) throws VCIError {
|
String res = "";
|
try {
|
res = new ProcessTemplateService().getNextCandidatesDefineString(jbpmDeploymentId, taskName, outcome);
|
} catch (Exception ex) {
|
throw new VCIError("410122", new String[] {});
|
}
|
return res;
|
}
|
|
/**
|
* 流程监控
|
* @param pluseroid
|
* @param first
|
* @param pageSize
|
* @param taskType
|
* @param querySQL
|
* @return
|
*/
|
public FlowTaskInfo[] getProcessControlByUserId(String pluseroid,int first,int pageSize,String taskType,String querySQL) {
|
return new ProcessTemplateService().getProcessControlByUserId(pluseroid,first,pageSize,taskType,querySQL);
|
}
|
public int queryProcessControlCount(String pluseroid,String taskType) throws VCIError{
|
int count = 1;
|
try{
|
count = new ProcessTemplateService().queryProcessControlCount(pluseroid,taskType);
|
}catch(Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410117", new String[] {});
|
}
|
return count;
|
}
|
|
public FlowTaskInfo[] getDoneProcessByUserId(String pluseroid,int first,int pageSize,String taskType,String querySQL) {
|
return new ProcessTemplateService().getDoneProcessByUserId(pluseroid,first,pageSize,taskType,querySQL);
|
}
|
public int queryDoneProcessCount(String pluseroid,String taskType) throws VCIError{
|
int count = 1;
|
try{
|
count = new ProcessTemplateService().queryDoneProcessCount(pluseroid,taskType);
|
}catch(Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410117", new String[] {});
|
}
|
return count;
|
}
|
|
/**
|
* 查询流程模板的第一个任务对象
|
* <p>Description: </p>
|
*
|
* @author xchao
|
* @time 2012-6-6
|
* @param jbpmDeploymentId 流程模板部署的ID
|
* @return
|
* @throws VCIError
|
*/
|
public ProcessTaskInfo getFirstProcessTask(String jbpmDeploymentId) throws VCIError{
|
try{
|
ProcessTask processTask = new ProcessTemplateService().getFirstProcessTask(jbpmDeploymentId);
|
return this.findTaskPropertyById(jbpmDeploymentId, processTask.getTaskName());
|
}catch(Exception ex){
|
ex.printStackTrace();
|
throw new VCIError("410117", new String[]{ex.getMessage()});
|
}
|
}
|
public ProcessTaskInfo getFirstProcessTaskByExecId(String execId) throws VCIError{
|
try{
|
String jbpmDeploymentId = getDeploymentIdByExecutionId(execId);
|
ProcessTask processTask = new ProcessTemplateService().getFirstProcessTask(jbpmDeploymentId);
|
return this.findTaskPropertyById(jbpmDeploymentId, processTask.getTaskName());
|
}catch(Exception ex){
|
ex.printStackTrace();
|
throw new VCIError("410117", new String[]{ex.getMessage()});
|
}
|
}
|
|
/**
|
*
|
* <p>查询当前节点同意的所有的下一任务节点数据:
|
* 返回格式：transitionName,TaskName;transitionName,TaskName;的字符串值
|
* </p>
|
*
|
* @time 2013-3-31
|
* @param taskId 任务ID
|
* @param taskName 任务名称
|
* @param outcome 同意或者不同意；
|
* @return
|
*/
|
public String getAllNoAgreeProcessTaskByTaskName(String taskId,String taskName,String outcome) throws VCIError{
|
try {
|
return new ProcessTemplateService().getAllNoAgreeProcessTaskByTaskName(taskId, taskName, outcome);
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new VCIError("410202", new String[]{e.getMessage()});
|
}
|
}
|
public boolean setNodeHide(String deploymentId) throws VCIError {
|
return new ProcessTemplateService().setNodeHide(deploymentId);
|
}
|
//隐藏流程节点方法
|
public NodeHideInfo[] getNodeHideDeploymentId() {
|
List<NodeHide> list = null;
|
ProcessTemplateService uservice = new ProcessTemplateService();
|
list = uservice.getNodeHideDeploymentId();
|
NodeHideInfo[] info = new NodeHideInfo[list.size()];
|
for(int i=0;i<list.size();i++) {
|
info[i] = changeNodeHideToNodeHideInfo(list.get(i));
|
}
|
return info;
|
}
|
public NodeHideInfo changeNodeHideToNodeHideInfo(NodeHide nodehide) {
|
NodeHideInfo info = new NodeHideInfo();
|
info.deploymentId = nodehide.getDeploymentId();
|
info.hide = nodehide.getHide();
|
info.id = nodehide.getId();
|
return info;
|
}
|
public boolean deleteHideFlow(String deployId) throws VCIError{
|
boolean res = false;
|
try{
|
res = new ProcessTemplateService().deleteHideFlow(deployId);
|
}catch(Exception e) {
|
throw new VCIError("410203",new String[0]);
|
}
|
return res;
|
}
|
public FlowTaskInfo[] getTaskByCondition(String[] values,int first,int pageSize,String objectId) throws VCIError{
|
FlowTaskInfo[] infos = null;
|
try{
|
infos = new ProcessTemplateService().getTaskByCondition(values,first,pageSize,objectId);
|
}catch(Exception e) {
|
throw new VCIError("410121", new String[] {});
|
}
|
return infos;
|
}
|
public int queryFlowTaskCount(String[] values,String objectId,boolean flag) throws VCIError{
|
int count = 1;
|
try{
|
count = new ProcessTemplateService().queryFlowTaskCount(values,objectId,flag);
|
}catch(Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410120", new String[] {});
|
}
|
return count;
|
}
|
public String getNextTaskNameByJbpmId(String jbpmDeploymentId, String taskName, String outcome) throws VCIError{
|
String res = "";
|
try{
|
res = new ProcessTemplateService().getNextTaskNameByJbpmId(jbpmDeploymentId,taskName,outcome);
|
}catch(Exception e) {
|
throw new VCIError("410204", new String[] {});
|
}
|
return res;
|
}
|
public String getNextTaskTypeByJbpmId(String jbpmDeploymentId, String taskName, String outcome) throws VCIError{
|
String res = "";
|
try{
|
res = new ProcessTemplateService().getNextTaskTypeByJbpmId(jbpmDeploymentId,taskName,outcome);
|
}catch(Exception e) {
|
throw new VCIError("410204", new String[] {});
|
}
|
return res;
|
}
|
public String getProcessStartUser(String execId)throws VCIError {
|
String res = "";
|
try {
|
res = new ProcessTemplateService().getProcessStartUser(execId);
|
}catch(Exception e) {
|
throw new VCIError("410205",new String[0]);
|
}
|
return res;
|
}
|
/**
|
* 通过执行标示查询任务ID
|
* <p>Description: </p>
|
*
|
* @time 2013-4-27
|
* @param execId
|
* @return
|
* @throws VCIError
|
*/
|
public String getProcessTaskId(String execId)throws VCIError {
|
String res = "";
|
try {
|
res = new ProcessTemplateService().getProcessTaskId(execId);
|
}catch(Exception e) {
|
throw new VCIError("410205",new String[0]);
|
}
|
return res;
|
}
|
public boolean setProcessHide(String jbpmdeplotmentId,int status) throws VCIError{
|
boolean res = false;
|
try{
|
res = new ProcessTemplateService().setProcessHide(jbpmdeplotmentId,status);
|
}catch(Exception e) {
|
if(status ==0){
|
throw new VCIError("410301",new String[0]);
|
}else throw new VCIError("410302",new String[0]);
|
}
|
return res;
|
}
|
/**
|
* 获取策略列表
|
* @param taskName
|
* @param deploymentId
|
* @return
|
*/
|
public TaskRevokeInfo[] getTaskRevokeList(String taskName, String deploymentId){
|
List<TaskRevokeSObject> list = new ProcessTemplateService().getTaskRevokeList(taskName, deploymentId);
|
TaskRevokeInfo[] taskRevokeInfo = new TaskRevokeInfo[list.size()];
|
for(int i=0;i<list.size();i++){
|
TaskRevokeSObject object = list.get(i);
|
taskRevokeInfo[i] = convertTaskRevokeObjToInfo(object);
|
}
|
return taskRevokeInfo;
|
}
|
private TaskRevokeInfo convertTaskRevokeObjToInfo(TaskRevokeSObject o){
|
TaskRevokeInfo info = new TaskRevokeInfo();
|
info.id = o.getId() == null ? "" : o.getId();
|
info.deploymentId = o.getPljbpmdeploymentid() == null?"":o.getPljbpmdeploymentid();
|
info.taskName = o.getPltask() ==null?"":o.getPltask();
|
info.className = o.getPlclassname()==null?"":o.getPlclassname();
|
info.revokeflag = o.getPlrevoke() ==null ? "" : o.getPlrevoke();
|
return info;
|
}
|
public boolean deleteTasksAssignedByUserName(String[] userName) throws VCIError {
|
boolean res = false;
|
try{
|
res = new ProcessTemplateService().deleteTasksAssignedByUserName(userName);
|
}catch(Exception e){
|
e.getStackTrace();
|
}
|
return res;
|
}
|
|
public boolean deleteTasksAssignedByIds(String[] ids) throws VCIError {
|
boolean res = false;
|
try{
|
//System.out.println("===============ProcessCustomDelegate.deleteTasksAssignedByIds===============");
|
res = new ProcessTemplateService().deleteTasksAssignedByIds(ids);
|
}catch(Exception e){
|
e.getStackTrace();
|
}
|
return res;
|
}
|
|
public void setParticipation(String nextTaskId,String[] userNames) throws VCIError{
|
try{
|
new ProcessTemplateService().setParticipation(nextTaskId, userNames);
|
}catch(Exception e){
|
e.getStackTrace();
|
throw new VCIError("410302",new String[0]);
|
}
|
}
|
/**
|
* 获取任务的所有候选人包含自定义用户
|
* @param taskName
|
* @param deploymentId
|
* @param outcome
|
* @return
|
*/
|
public String[] getAllUserListForTask(String taskName, String deploymentId,String outcome,String [] varKey, String[] varValue){
|
List<String> allUserListForTask = new ProcessTemplateService().getAllUserListForTask(taskName, deploymentId, outcome,varKey, varValue);
|
return allUserListForTask.toArray(new String[0]);
|
}
|
/**
|
* 撤销任务
|
* @param assignName
|
* @param destActivityName
|
* @param executionId
|
* @return
|
*/
|
public boolean revokeTask(String taskName,String destActivityName, String executionId){
|
return new ProcessTemplateService().revokeTask(taskName, destActivityName, executionId);
|
}
|
/**
|
* 任务指派
|
* @param destActivityName
|
* @param tagActivityName
|
* @param classNames
|
* @param userNames
|
* @return
|
*/
|
public boolean appointTask(String destActivityName,String tagActivityName,String[] classNames,String executionId, String[] userNames){
|
return new ProcessTemplateService().appointTask(destActivityName, tagActivityName, classNames,executionId, userNames);
|
}
|
/**
|
* 任务指派
|
* @param destActivityName
|
* @param tagActivityName
|
* @param classNames
|
* @param userNames
|
* @return
|
*/
|
public boolean appointTask2(String destActivityName,String tagActivityName,String[] classNames,String executionId, String[] userNames, UserEntityInfo userEntityInfo){
|
return new ProcessTemplateService(this.getUserEntity()).appointTask2(destActivityName, tagActivityName, classNames,executionId, userNames, userEntityInfo);
|
}
|
/**
|
* 返回流程执行时的参数值
|
* <p>Description: </p>
|
* @author xchao
|
* @time 2013-5-24
|
* @param executionId 流程执行ID
|
* @param varName 变量名称
|
* @return
|
*/
|
public String getProcessVariable(String executionId, String varName) throws VCIError{
|
String str = "";
|
try{
|
ProcessTemplateService srv = new ProcessTemplateService();
|
str = srv.getProcessVariable(executionId, varName);
|
}catch(Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("410401", new String[] {ex.getMessage()});
|
}
|
return str;
|
}
|
public String[] getTasksNameByProcessName(final String[] processNames) throws VCIError{
|
List<String> list = new LinkedList<String>();
|
try {
|
list = new ProcessTemplateService().getTasksNameByProcessName(processNames);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
throw new VCIError("410303",new String[0]);
|
}
|
return list.toArray(new String[0]);
|
}
|
/**
|
*
|
* <p>Description: 查看已办任务的详细信息</p>
|
*
|
* @time 2013-4-11
|
* @param executionId
|
* @return
|
* @throws VCIError
|
*/
|
public String searchComplateTask(String[] param) throws VCIError {
|
String str = "";
|
try{
|
ProcessTemplateService srv = new ProcessTemplateService();
|
str = srv.searchComplateTask(param);
|
}catch(Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError("-1", new String[] {});
|
}
|
return str;
|
}
|
public TasksAssignedInfo[] getTasksAssignedByPageing(LongHolder total,QueryParamInfo queryParamInfo) throws VCIError{
|
TasksAssignedInfo[] infos = new TasksAssignedInfo[0];
|
try{
|
QueryParam queryParam = this.convertQueryParam(queryParamInfo);
|
QueryResult<TasksAssigned> res = new ProcessTemplateService(this.getUserEntity()).getTasksAssignedByPageing(queryParam);
|
total.value = res.getTotal();
|
TasksAssigned[] objects = res.getDatas();
|
infos = this.coventObjectListToInfoList(objects);
|
}catch(Exception ex){
|
throw new VCIError("810005", new String[]{});
|
}
|
return infos;
|
}
|
private QueryParam convertQueryParam(QueryParamInfo info){
|
QueryParam obj = new QueryParam();
|
obj.setCustomQueryString(info.customQueryString);
|
obj.setPageIndex(info.pageIndex);
|
obj.setPageSize(info.pageSize);
|
return obj;
|
}
|
private TasksAssignedInfo[] coventObjectListToInfoList(TasksAssigned[] obj){
|
TasksAssignedInfo[] infos = new TasksAssignedInfo[obj.length];
|
for(int i = 0;i<obj.length;i++){
|
infos[i] = this.coventObjectToInfo(obj[i]);
|
}
|
return infos;
|
}
|
private TasksAssignedInfo coventObjectToInfo(TasksAssigned tasksAssigned){
|
TasksAssignedInfo info = new TasksAssignedInfo();
|
info.id = tasksAssigned.getId() == null ? "" : tasksAssigned.getId();
|
info.userName = tasksAssigned.getUserName() == null ? "" : tasksAssigned.getUserName();
|
// info.TasksId = tasksAssigned.getTasksId() == null ? "" : tasksAssigned.getTasksId();
|
info.TasksName = tasksAssigned.getTasksName() == null ? "" : tasksAssigned.getTasksName();
|
// info.TasksTrueName = tasksAssigned.getTasksTrueName() == null ? "" : tasksAssigned.getTasksTrueName();
|
info.isTrue = tasksAssigned.getIsTrue();
|
info.startTime = tasksAssigned.getStartTime() == null ? 0 : tasksAssigned.getStartTime().getTime();
|
info.endTime = tasksAssigned.getEndTime() == null ? 0 : tasksAssigned.getEndTime().getTime();
|
info.fromUser=tasksAssigned.getFromUser()==null?"":tasksAssigned.getFromUser();
|
return info;
|
}
|
public String getTaskId(String currActivityName,String executionId){
|
return new ProcessTemplateService().getTaskId(currActivityName, executionId);
|
}
|
public String[] getOutComesByTaskName(String jbpmDeploymentId,String taskName){
|
try {
|
return new ProcessTemplateService().getOutComesByTaskName(jbpmDeploymentId, taskName);
|
} catch (Exception e) {
|
return new String[0];
|
}
|
}
|
|
/**
|
* 通过流程模板key,获取流程部署id
|
* @param processDefinitionKey
|
* @return
|
*/
|
public String getDeploymentID(String processDefinitionKey) {
|
BigDecimal deploymentID = new ProcessTemplateService().getDeploymentID(processDefinitionKey);
|
return String.valueOf(deploymentID);
|
}
|
|
|
public String[] getFirstTasksAssigneeByCatid(String catid) throws VCIError
|
{
|
ArrayList list = new ArrayList();
|
ProcessDefinitionInfo[] pdis = this.getProcessDefinitions(catid);
|
for( int i=0;i<pdis.length;i++ )
|
{
|
ProcessDefinitionInfo pdi = pdis[i];
|
ProcessTaskInfo pti = this.getFirstProcessTask(pdi.jbpmDeploymentId);
|
String[] temps = this.getCurCandidates(pdi.jbpmDeploymentId, pti.taskName, "", null);
|
for(int j=0;j<temps.length;j++)
|
{
|
String temp = pdi.jbpmDeploymentId + "==" + temps[j];
|
list.add(temp);
|
}
|
|
}
|
return (String[]) list.toArray(new String[list.size()]);
|
// return (String[])list.toArray();
|
}
|
|
/**
|
* 获取流程名称
|
* @param executionid
|
* @return
|
*/
|
public String getProcessName(String executionid){
|
return new ProcessTemplateService().getProcessName(executionid);
|
}
|
|
public FlowTaskInfo getFlowTaskInfo(String exectionId, String taskid) throws VCIError{
|
try{
|
return new ProcessTemplateService().getFlowTaskInfo(exectionId, taskid);
|
}catch(Exception ex){
|
throw new VCIError("410115", new String[]{});
|
}
|
}
|
|
public FlowApproveHistoryInfo[] getHistoryActivityByProInsIdbyPLM(
|
String processInstanceId) {
|
List<FlowApproveHistory> list = new ProcessTemplateService().getHistoryActivityByProInsIdbyPLM(processInstanceId);
|
return convListToFlowApproveHistoryInfo(list);
|
}
|
|
public String startPocessByPLM_v1(String processDefinitionKey,
|
FlowInstanceInfo flowInstanceInfo, String[] objId,
|
UserEntityInfo userEntityInfo, String[] userName, String outcome,
|
String[] tasknames, String[][] taskUserNames,
|
MapTransfersInfo[] mapTransfersServerObject,
|
String[] objectProperty, String[][] objectPropertyValues)
|
throws VCIError {
|
Map<String, String[]> taskAndUserMap = new HashMap<String, String[]>();
|
for (int i = 0; i < tasknames.length; i++) {
|
taskAndUserMap.put(tasknames[i], taskUserNames[i]);
|
}
|
Map<String, Object> mapParams = new HashMap<String, Object>();
|
for (int i = 0; i < mapTransfersServerObject.length; i++) {
|
mapParams.put(mapTransfersServerObject[i].key,
|
mapTransfersServerObject[i].value);
|
}
|
return new ProcessTemplateService(this.getUserEntity())
|
.startPocessByPLM_v1(processDefinitionKey, flowInstanceInfo,
|
objId, userName, outcome, taskAndUserMap, mapParams,
|
objectProperty, objectPropertyValues, userEntityInfo);
|
}
|
|
public String startProcessAndExecuteFirstNode(String processDefinitionKey,
|
FlowInstanceInfo flowInstanceInfo, String[] objId,
|
UserEntityInfo userEntityInfo, String[] userName, String outcome,
|
String[] tasknames, String[][] taskUserNames,
|
MapTransfersInfo[] mapTransfersServerObject,
|
String[] objectProperty, String[][] objectPropertyValues)
|
throws VCIError {
|
Map<String, String[]> taskAndUserMap = new HashMap<String, String[]>();
|
for (int i = 0; i < tasknames.length; i++) {
|
taskAndUserMap.put(tasknames[i], taskUserNames[i]);
|
}
|
Map<String, Object> mapParams = new HashMap<String, Object>();
|
for (int i = 0; i < mapTransfersServerObject.length; i++) {
|
mapParams.put(mapTransfersServerObject[i].key,
|
mapTransfersServerObject[i].value);
|
}
|
return new ProcessTemplateService(this.getUserEntity())
|
.startProcessAndExecuteFirstNode(processDefinitionKey,
|
flowInstanceInfo, objId, userEntityInfo, userName,
|
outcome, taskAndUserMap, mapParams, objectProperty,
|
objectPropertyValues);
|
}
|
|
public boolean completeTaskByPlatform_v1(String taskId, String outcome,
|
String nextTask, String approvalNote,
|
UserEntityInfo userEntityInfo, String[] userName,
|
String[] objectProperty, String[][] objectPropertyValues)
|
throws VCIError {
|
try {
|
return new ProcessTemplateService(this.getUserEntity())
|
.completeTaskByPlatform_v1(taskId, outcome, nextTask,
|
approvalNote, userEntityInfo, userName,
|
objectProperty, objectPropertyValues);
|
} catch (VCIError e) {
|
throw e;
|
}
|
}
|
|
public boolean completeTasksByPlatform_v1(String[] taskIds, String outcome,
|
String nextTask, String approvalNote,
|
UserEntityInfo userEntityInfo, String[] userName,
|
String[] objectProperty, String[][] objectPropertyValues)
|
throws VCIError {
|
try {
|
return new ProcessTemplateService(this.getUserEntity())
|
.completeTasksByPlatform_v1(taskIds, outcome, nextTask,
|
approvalNote, userEntityInfo, userName,
|
objectProperty, objectPropertyValues);
|
} catch (VCIError e) {
|
throw e;
|
}
|
}
|
|
public boolean resetNodeUser(String executionId, String[] taskNames,
|
String[] userNames) throws VCIError {
|
return new ProcessTemplateService(this.getUserEntity()).resetNodeUser(executionId, taskNames, userNames);
|
}
|
}
|
