// Decompiled by Jad v1.5.8g. Copyright 2001 Pavel Kouznetsov.
|
// Jad home page: http://www.kpdus.com/jad.html
|
// Decompiler options: packimports(3) radix(10) lradix(10)
|
// Source File Name: PLMWorkItem.java
|
|
package com.vci.server.workflow.plugins;
|
|
import com.vci.common.qt.object.*;
|
import com.vci.common.util.CollectionUtils;
|
import com.vci.common.utility.ObjectUtility;
|
import com.vci.corba.bofactory.BOFactoryServicePrx;
|
import com.vci.corba.common.VCIError;
|
import com.vci.corba.omd.data.*;
|
import com.vci.corba.query.ObjectQueryServicePrx;
|
import com.vci.corba.workflow.data.FlowInstanceInfo;
|
import com.vci.omd.constants.BusinessConstants;
|
import com.vci.omd.utils.ObjectTool;
|
import com.vci.server.base.persistence.dao.HibernateSessionFactory;
|
import com.vci.server.base.utility.OQueryHelper;
|
import com.vci.server.base.utility.ServerServiceProvider;
|
import com.vci.server.workflow.common.resouce.WorkflowProperties;
|
import com.vci.server.workflow.server.interfaces.PLMWorkItemInterface;
|
import com.vci.server.workflow.server.template.ProcessTemplateService;
|
import java.util.*;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.hibernate.SQLQuery;
|
import org.jbpm.api.task.Task;
|
|
|
public class PLMWorkItem implements PLMWorkItemInterface {
|
|
|
public PLMWorkItem() {
|
|
}
|
|
public void saveForStart(FlowInstanceInfo var, Task task, String userName, String taskId, String executionid, String objIds[], Map<String, Object> variables)
|
throws VCIError
|
{
|
BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
|
|
List<LinkObject> cloList = new ArrayList<LinkObject>();
|
List<BusinessObject> cboList = new ArrayList<BusinessObject>();
|
|
//����workitem����
|
BusinessObject fromBo = bofService.initBusinessObject(WI_NAME);
|
fromBo.id = ObjectUtility.getNewObjectID36();
|
fromBo.name = (new StringBuilder(String.valueOf(var.processName))).append("-").append(task.getName()).toString();
|
fromBo.description = var.desc;
|
fromBo.lcStatus = "Executing";
|
// fromBo.creator = "WorkFlowAdmin";
|
// fromBo.owner = userName;
|
ObjectTool.setBOAttributeValue(fromBo, "code", task.getName());
|
ObjectTool.setBOAttributeValue(fromBo, "assigner", var.creator);
|
ObjectTool.setBOAttributeValue(fromBo, "principal", userName);
|
ObjectTool.setBOAttributeValue(fromBo, "worktype", "2");
|
ObjectTool.setBOAttributeValue(fromBo, "businesstype", "5");
|
ObjectTool.setBOAttributeValue(fromBo, "taskoid", taskId);
|
ObjectTool.setBOAttributeValue(fromBo, "executionid", executionid);
|
cboList.add(fromBo);
|
|
//List<BusinessObject> toBos = new ArrayList<BusinessObject>();
|
BusinessObject[] toBOs = bofService.getBatchBusinessObject(objIds, var.tableName);
|
for(int j = 0; j < toBOs.length; j++)
|
{
|
BusinessObject toBO = toBOs[j];
|
|
//����workitem����˶���֮��Ĺ�ϵ
|
LinkObject clo = bofService.initLinkObject("input");
|
//BusinessObject toBO = boDelegate.getInfoBusinessObject(objId[j], var.tableName);
|
//toBos.add(toBO);
|
ObjectTool.setLOAttributeValue(clo, "linkdescription", var.desc);
|
ObjectTool.setLOFromBO(clo, fromBo);
|
ObjectTool.setLOToBO(clo, toBO);
|
cloList.add(clo);
|
}
|
//�����Ƿ����workflowinstance�洢�ж�
|
// if (isWorkFlowInstanceExist()) {
|
// this.cunstructWorkFlowInstanceObj(bofBoDelegate, loDelegate, cboList, cloList, var, executionid, toBOs);
|
// }
|
|
BusinessObject[] bos = cboList.toArray(new BusinessObject[0]);
|
// BusinessObjectListHolder bosh = new BusinessObjectListHolder();
|
// bosh.value = cboList.toArray(new BusinessObject[0]);
|
|
LinkObject[] los = cloList.toArray(new LinkObject[0]);
|
// LinkObjectListHolder losh = new LinkObjectListHolder();
|
// losh.value = cloList.toArray(new LinkObject[0]);
|
bofService.batchCreateBusinessObjectWithLink(bos, los);
|
//_bofService.batchCreateBusinessObjectWithLink((BusinessObject[])cboList.toArray(new BusinessObject[0]), (LinkObject[])cloList.toArray(new LinkObject[0]));
|
}
|
|
/**
|
* 判断流程实例是否存在
|
* @return
|
*/
|
private boolean isWorkFlowInstanceExist() {
|
String isWFInstanceExist = WorkflowProperties.getStringProperty("workflow.plmworkflowInstance.isExist");
|
if (isWFInstanceExist.equalsIgnoreCase("y")) {
|
return true;
|
} else {
|
return false;
|
}
|
}
|
|
/**
|
*
|
* @param bofBoDelegate
|
* @param loDelegate
|
* @param cboList
|
* @param cloList
|
* @param var
|
* @param executionid
|
* @param toBos
|
* @throws VCIError
|
*/
|
private void cunstructWorkFlowInstanceObj(List<BusinessObject> cboList, List<LinkObject> cloList, FlowInstanceInfo var, String executionid,
|
BusinessObject[] toBos) throws VCIError {
|
|
System.out.println("=======================PLMWorkItem:创建流程实例对象=========================");
|
BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
|
|
//����workflowinstance����
|
BusinessObject wfInstanceBo = bofService.initBusinessObject(WFI_NAME);
|
wfInstanceBo.id = ObjectUtility.getNewObjectID36();
|
wfInstanceBo.name = var.processName;
|
wfInstanceBo.description = var.desc;
|
wfInstanceBo.lcStatus = "Executing";
|
ObjectTool.setBOAttributeValue(wfInstanceBo, "executionid", executionid);
|
cboList.add(wfInstanceBo);
|
|
for(int j = 0; j < toBos.length; j++)
|
{
|
//����workflowinstance����˶���֮��Ĺ�ϵ
|
LinkObject clo = bofService.initLinkObject("input");
|
ObjectTool.setLOAttributeValue(clo, "linkdescription", var.desc);
|
ObjectTool.setLOFromBO(clo, wfInstanceBo);
|
ObjectTool.setLOToBO(clo, toBos[j]);
|
cloList.add(clo);
|
}
|
}
|
|
|
/**
|
* /修改流程处理人
|
*/
|
public void updateWorkItemPrincipal(String taskId, String curUserName) throws VCIError {
|
BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
|
ObjectQueryServicePrx oqService = ServerServiceProvider.getOQService();
|
|
QueryTemplate qt = new QueryTemplate();
|
List<String> list = new ArrayList<String>();
|
list.add("*");
|
qt.setBtmType(WI_NAME);
|
qt.setClauseList(list);
|
qt.setId("p");
|
qt.setType("btm");
|
qt.setRightFlag(false);
|
Map<String, String> map = new HashMap<String, String>();
|
map.put("businesstype", "5");
|
map.put("taskoid", taskId);
|
map.put("lcstatus", "Executing");
|
Condition condition = OQueryHelper.getCondition(map);
|
qt.setCondition(condition);
|
BusinessObject findBTMObjects[] = oqService.findBTMObjects(qt.getId(), OQueryHelper.getQTTextByQT(qt));
|
|
List<BusinessObject> oldBoUpdatelist = new ArrayList<BusinessObject>();
|
for (BusinessObject businessObject : findBTMObjects) {
|
//BusinessObject oldBO = boDelegate.getInfoBusinessObject(businessObject.oid, "WorkItem".toLowerCase());
|
ObjectTool.setBOAttributeValue(businessObject, "principal", curUserName);
|
oldBoUpdatelist.add(businessObject);
|
}
|
if(oldBoUpdatelist.size() > 0) {
|
// BusinessObjectListHolder bosh = new BusinessObjectListHolder();
|
// bosh.value = oldBoUpdatelist.toArray(new BusinessObject[0]);
|
bofService.batchUpdateBusinessObject(oldBoUpdatelist.toArray(new BusinessObject[0]));
|
}
|
}
|
|
/**
|
* 任务表的名称
|
*/
|
private static final String WI_TABLE_NAME = "PLATFORMBTM_WORKITEM";
|
private static final String WFI_TABLE_NAME = "PLATFORMBTM_WORKFLOWINSTANCE";
|
|
private static final String WFI_NAME = "workflowinstance";
|
private static final String WI_NAME = "workitem";
|
|
|
/**
|
* �Լ�ִ�е��������Ϊ���״̬�����˵�ֱ��ɾ��
|
*/
|
public String[] updataWorkItem(String taskId, String executId, String curUserName, String owner, Map<String, String> linkDataMap)
|
throws VCIError
|
{
|
ObjectQueryServicePrx oqService = ServerServiceProvider.getOQService();
|
|
//weidy@2020-7-19优化
|
//这个方法每次执行平均在200多ms以上，占流程任务执行时间的4分之一
|
|
//以前的逻辑
|
//1. 使用用户查询该用户的流程任务，并且是当前流程中的任务。获取其中的oid(而且如果有重复的时候，是最后一条的oid)
|
//2. 查询当前任务中对应的任务（？？是一个jbpm任务，在workitem里有多条吗?）。其中如果是当前用户处理的那条任务就修改；不是当前用户那一条就删除
|
//3. 使用input查询t_oid
|
|
//之前的代码存在的问题是，调用平台的接口会查询缓存，并且会查询很多无关的属性，耗时较慢
|
|
//使用当前用户查询
|
String queryWorkItemByUserSql = "select creator,oid from " + WI_TABLE_NAME + " where Principal = '"
|
+ curUserName.trim() + "' and BusinessType= '5' and executionid ='" + executId.trim() + "'";
|
String[][] workItemResult = oqService.queryBySqlWithoutKey(queryWorkItemByUserSql);
|
if(workItemResult == null || workItemResult.length == 0) {
|
throw new VCIError("查询任务对象出现了错误",new String[] {});
|
}
|
String workItemOid = "";
|
if(workItemResult[0] != null && workItemResult[0].length > 1) {
|
owner = workItemResult[0][0];
|
workItemOid = workItemResult[0][1];
|
}
|
|
//使用任务主键查询，看看除了当前用户，还有没有其他的用户处理的任务
|
|
String queryWorkItemByTaskSql = "select principal,oid from " + WI_TABLE_NAME + " where BusinessType= '5' and TaskOID = '" + taskId.trim() + "'";
|
String[][] allUserTaskResult = oqService.queryBySqlWithoutKey(queryWorkItemByTaskSql);
|
if(allUserTaskResult == null || allUserTaskResult.length == 0) {
|
throw new VCIError("查询任务对象出现了错误,taskId",new String[] {});
|
}
|
Set<String> needUpdateWorkItemOidList = new HashSet<String>();
|
Set<String> needDeleteWorkItemOidList = new HashSet<String>();
|
for(int i = 0 ; i < allUserTaskResult.length ; i ++) {
|
String[] record = allUserTaskResult[i];
|
if(record != null && record.length > 1) {
|
String principal = record[0];
|
String oid = record[1];
|
if(curUserName.equalsIgnoreCase(principal)) {
|
//说明是当前用户的那条任务
|
needUpdateWorkItemOidList.add(oid);
|
}else {
|
needDeleteWorkItemOidList.add(oid);
|
}
|
}
|
}
|
|
//执行修改和删除
|
if(!CollectionUtils.isEmpty(needUpdateWorkItemOidList)) {
|
String updateSql = "update " + WI_TABLE_NAME + " set " + BusinessConstants.SELECT_LCSTATUS.toLowerCase() + " = 'Completed' where oid ='";
|
for(String oid : needUpdateWorkItemOidList) {
|
String sql = updateSql + oid + "'";
|
HibernateSessionFactory.getSession().createSQLQuery(sql).executeUpdate();
|
}
|
}
|
if(!CollectionUtils.isEmpty(needDeleteWorkItemOidList)) {
|
String deleteSql = "delete from " + WI_TABLE_NAME + " where oid ='" ;
|
//因为oid本身就是查询出来的，所以不需要再去获取BO对象了
|
for(String oid : needDeleteWorkItemOidList) {
|
String sql = deleteSql + oid + "'";
|
HibernateSessionFactory.getSession().createSQLQuery(sql).executeUpdate();
|
}
|
}
|
|
//查询input中的t_oid
|
//平台中因为凡是使用流程的都会使用input这个链接类型，平台会自动为这个Input添加视图，查询的时候会查询这个视图，比较耗时
|
String queryInputToOidSql = "select t_oid from platformlt_input where f_oid = '" + workItemOid + "'";
|
String[][] inputResult = oqService.queryBySqlWithoutKey(queryInputToOidSql);
|
if(inputResult == null || inputResult.length == 0) {
|
return new String[0];
|
}
|
String ObjectOids[] = new String[inputResult.length];
|
for(int i = 0 ; i < inputResult.length ; i ++) {
|
if(inputResult[i] !=null && inputResult[i].length>0) {
|
ObjectOids[i] = inputResult[i][0];
|
}else {
|
ObjectOids[i] = "";
|
}
|
}
|
return ObjectOids;
|
|
}
|
|
public String getUser(String curUserName, String executId)
|
throws VCIError
|
{
|
ObjectQueryServicePrx oqService = ServerServiceProvider.getOQService();
|
|
//weidy@2020-7-19
|
//只是查询creator，以前这种方式需要查询相关的缓存等内容，所以调整一下
|
String queryWorkItemByUserSql = "select creator from " + WI_TABLE_NAME + " where Principal = '"
|
+ curUserName.trim() + "' and BusinessType= '5' and executionid ='" + executId.trim() + "'";
|
String[][] workItemResult = oqService.queryBySqlWithoutKey(queryWorkItemByUserSql);
|
if(workItemResult == null || workItemResult.length == 0) {
|
throw new VCIError("查询任务对象出现了错误",new String[] {});
|
}
|
String owner = "";
|
if(workItemResult[0] != null && workItemResult[0].length > 0) {
|
return workItemResult[0][0];
|
}
|
return owner ;
|
}
|
|
/**
|
* 删除分支任务
|
*/
|
public void deleteForkTask(String excutionid)
|
throws VCIError
|
{
|
BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
|
ObjectQueryServicePrx oqService = ServerServiceProvider.getOQService();
|
|
QueryTemplate qtl = new QueryTemplate();
|
List<String> queryList = new ArrayList<String>();
|
queryList.add("*");
|
qtl.setBtmType(WI_NAME);
|
qtl.setClauseList(queryList);
|
qtl.setId("p");
|
qtl.setType("btm");
|
qtl.setRightFlag(false);
|
Map<String, String> map = new HashMap<String, String>();
|
map.put("executionid", (new StringBuilder(String.valueOf(excutionid))).append("*").toString());
|
Condition condition = OQueryHelper.getCondition(map);
|
qtl.setCondition(condition);
|
BusinessObject findBTMObjects[] = oqService.findBTMObjects(qtl.getId(), OQueryHelper.getQTTextByQT(qtl));
|
bofService.batchDeleteBusinessObject(findBTMObjects, 1);
|
}
|
|
/**
|
* 完成任务
|
*/
|
public void saveForComplete(String userName, String ObjectOids[], Task task, String btmType,
|
String btmDesc, String processName, String nextTaskId, String owner)
|
throws VCIError
|
{
|
List<LinkObject> cloList = new ArrayList<LinkObject>();
|
List<BusinessObject> cboList = new ArrayList<BusinessObject>();
|
|
BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
|
|
// 查询任务所在流程实例的创建人
|
String idExec = task.getExecutionId();
|
|
String ownerWFI = getFlowInstanceOwner(idExec);
|
if (StringUtils.isEmpty(ownerWFI))
|
ownerWFI = owner;
|
|
BusinessObject fromBo = bofService.initBusinessObject(WI_NAME);
|
fromBo.id = ObjectUtility.getNewObjectID36();
|
fromBo.name = (new StringBuilder(String.valueOf(processName))).append("-").append(task.getName()).toString();
|
fromBo.description = btmDesc;
|
fromBo.lcStatus = "Executing";
|
// fromBo.owner = userName;
|
// fromBo.creator = "WorkFlowAdmin";
|
ObjectTool.setBOAttributeValue(fromBo, "code", task.getName());
|
ObjectTool.setBOAttributeValue(fromBo, "assigner", ownerWFI);
|
ObjectTool.setBOAttributeValue(fromBo, "principal", userName);
|
ObjectTool.setBOAttributeValue(fromBo, "workType", "2");
|
ObjectTool.setBOAttributeValue(fromBo, "businesstype", "5");
|
ObjectTool.setBOAttributeValue(fromBo, "taskoid", nextTaskId);
|
ObjectTool.setBOAttributeValue(fromBo, "executionid", idExec);
|
cboList.add(fromBo);
|
|
for(int k = 0; k < ObjectOids.length; k++)
|
{
|
String flowinstancesql = (new StringBuilder("select t.PLPROCESSTYPE from plflowobject t where t.plobjectid ='")).append(ObjectOids[k]).append("' and t.plexecutionid = '"+task.getExecutionId()+"'").toString();
|
SQLQuery flowinstancecreateSQLQuery = HibernateSessionFactory.getSession().createSQLQuery(flowinstancesql);
|
flowinstancecreateSQLQuery.executeUpdate();
|
List<?> flowinstancelist = flowinstancecreateSQLQuery.list();
|
for(int j = 0; j < flowinstancelist.size(); j++)
|
{
|
Object object = (Object)flowinstancelist.get(j);
|
btmType = String.valueOf(object);
|
}
|
LinkObject clo = bofService.initLinkObject("input");
|
BusinessObject toBO = bofService.readBusinessObject(ObjectOids[k], btmType);
|
ObjectTool.setLOAttributeValue(clo, "linkdescription", btmDesc);
|
ObjectTool.setLOFromBO(clo, fromBo);
|
ObjectTool.setLOToBO(clo, toBO);
|
cloList.add(clo);
|
}
|
|
// BusinessObjectListHolder bosh = new BusinessObjectListHolder();
|
// bosh.value = cboList.toArray(new BusinessObject[0]);
|
//
|
// LinkObjectListHolder losh = new LinkObjectListHolder();
|
// losh.value = cloList.toArray(new LinkObject[0]);
|
bofService.batchCreateBusinessObjectWithLink(cboList.toArray(new BusinessObject[0]), cloList.toArray(new LinkObject[0]));
|
// bofService.batchCreateBusinessObjectWithLink((BusinessObject[])cboList.toArray(new BusinessObject[0]), (LinkObject[])cloList.toArray(new LinkObject[0]));
|
}
|
|
/**
|
* 完成任务
|
*/
|
public void saveForComplete_v1(String userName, String ObjectOids[], Task task, String btmType,
|
String btmDesc, String processName, String nextTaskId, String owner,
|
String objectProperty[], String objectPropertyValues[][])
|
throws VCIError
|
{
|
BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
|
//ObjectQueryServicePrx oqService = ServerServiceProvider.getOQService();
|
|
List<LinkObject> cloList = new ArrayList<LinkObject>();
|
List<BusinessObject> cboList = new ArrayList<BusinessObject>();
|
|
String idExec = task.getExecutionId();
|
|
String ownerWFI = getFlowInstanceOwner(idExec);
|
if (StringUtils.isEmpty(ownerWFI))
|
ownerWFI = owner;
|
|
BusinessObject fromBo = bofService.initBusinessObject(WI_NAME);
|
fromBo.id = ObjectUtility.getNewObjectID36();
|
fromBo.name = (new StringBuilder(String.valueOf(processName))).append("-").append(task.getName()).toString();
|
fromBo.description = btmDesc;
|
fromBo.lcStatus = "Executing";
|
// fromBo.owner = userName;
|
// fromBo.creator = "WorkFlowAdmin";
|
ObjectTool.setBOAttributeValue(fromBo, "code", task.getName());
|
ObjectTool.setBOAttributeValue(fromBo, "assigner", ownerWFI);
|
ObjectTool.setBOAttributeValue(fromBo, "principal", userName);
|
ObjectTool.setBOAttributeValue(fromBo, "workType", "2");
|
ObjectTool.setBOAttributeValue(fromBo, "businesstype", "5");
|
ObjectTool.setBOAttributeValue(fromBo, "taskoid", nextTaskId);
|
ObjectTool.setBOAttributeValue(fromBo, "executionid", task.getExecutionId());
|
cboList.add(fromBo);
|
for(int j = 0; j < objectPropertyValues.length; j++)
|
{
|
LinkObject clo = bofService.initLinkObject("input");
|
for(int j1 = 0; j1 < objectPropertyValues[j].length; j1++)
|
{
|
String value = objectPropertyValues[j][j1];
|
String filed = objectProperty[j1].toLowerCase();
|
if("oid".equals(filed))
|
clo.toOid = value;
|
else
|
if("revisionoid".equals(filed))
|
clo.toRevOid = value;
|
else
|
if("nameoid".equals(filed))
|
clo.toNameOid = value;
|
else
|
if("btmname".equals(filed))
|
clo.toBTName = value;
|
}
|
|
ObjectTool.setLOFromBO(clo, fromBo);
|
cloList.add(clo);
|
}
|
|
// BusinessObjectListHolder bosh = new BusinessObjectListHolder();
|
// bosh.value = cboList.toArray(new BusinessObject[0]);
|
//
|
// LinkObjectListHolder losh = new LinkObjectListHolder();
|
// losh.value = cloList.toArray(new LinkObject[0]);
|
bofService.batchCreateBusinessObjectWithLink(cboList.toArray(new BusinessObject[0]), cloList.toArray(new LinkObject[0]));
|
// bofService.batchCreateBusinessObjectWithLink((BusinessObject[])cboList.toArray(new BusinessObject[0]), (LinkObject[])cloList.toArray(new LinkObject[0]));
|
}
|
|
/**
|
*保存workitem并在链接类型对象保存审批意见
|
*@author changmk
|
*/
|
public void saveForCompleteAndSaveOpinion_v1(String userName,
|
String[] objectOids, Task task, String btmType, String btmDesc,
|
String processName, String nextTaskId, String owner,
|
String[] objectProperty, String[][] allObjectPropertyValues,
|
String outcome, String approvalNote, Set<String> selecedOidSet)
|
throws VCIError {
|
// TODO Auto-generated method stub
|
List<LinkObject> cloList = new ArrayList<LinkObject>();
|
List<BusinessObject> cboList = new ArrayList<BusinessObject>();
|
|
BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
|
|
String idExec = task.getExecutionId();
|
|
String ownerWFI = getFlowInstanceOwner(idExec);
|
if (StringUtils.isEmpty(ownerWFI))
|
ownerWFI = owner;
|
|
BusinessObject fromBo = bofService.initBusinessObject(WI_NAME);
|
fromBo.id = ObjectUtility.getNewObjectID36();
|
fromBo.name = (new StringBuilder(String.valueOf(processName))).append("-").append(task.getName()).toString();
|
fromBo.description = btmDesc;
|
fromBo.lcStatus = "Executing";
|
// fromBo.owner = userName;
|
// fromBo.creator = "WorkFlowAdmin";
|
ObjectTool.setBOAttributeValue(fromBo, "code", task.getName());
|
ObjectTool.setBOAttributeValue(fromBo, "assigner", ownerWFI);
|
ObjectTool.setBOAttributeValue(fromBo, "principal", userName);
|
ObjectTool.setBOAttributeValue(fromBo, "worktype", "2");
|
ObjectTool.setBOAttributeValue(fromBo, "businesstype", "5");
|
ObjectTool.setBOAttributeValue(fromBo, "taskoid", nextTaskId);
|
ObjectTool.setBOAttributeValue(fromBo, "executionid", task.getExecutionId());
|
cboList.add(fromBo);
|
for(int j = 0; j < allObjectPropertyValues.length; j++)
|
{
|
LinkObject clo = bofService.initLinkObject("input");
|
for(int j1 = 0; j1 < allObjectPropertyValues[j].length; j1++)
|
{
|
String value = allObjectPropertyValues[j][j1];
|
String filed = objectProperty[j1].toLowerCase();
|
if("oid".equals(filed))
|
clo.toOid = value;
|
else
|
if("revisionoid".equals(filed))
|
clo.toRevOid = value;
|
else
|
if("nameoid".equals(filed))
|
clo.toNameOid = value;
|
else
|
if("btmname".equals(filed))
|
clo.toBTName = value;
|
}
|
String option = "";
|
if (selecedOidSet.contains(allObjectPropertyValues[j][0])) {
|
option += outcome;
|
if (!"".equals(approvalNote)) {
|
option += ":" + approvalNote;
|
}
|
}
|
ObjectTool.setLOAttributeValue(clo, "linkdescription", option);
|
ObjectTool.setLOFromBO(clo, fromBo);
|
cloList.add(clo);
|
}
|
|
// BusinessObjectListHolder bosh = new BusinessObjectListHolder();
|
// bosh.value = cboList.toArray(new BusinessObject[0]);
|
//
|
// LinkObjectListHolder losh = new LinkObjectListHolder();
|
// losh.value = cloList.toArray(new LinkObject[0]);
|
bofService.batchCreateBusinessObjectWithLink(cboList.toArray(new BusinessObject[0]), cloList.toArray(new LinkObject[0]));
|
|
}
|
|
/**
|
* 结束流程
|
*/
|
public void endProcess(String processInstanceId)
|
throws VCIError
|
{
|
BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
|
ObjectQueryServicePrx oqService = ServerServiceProvider.getOQService();
|
|
QueryTemplate qtl = new QueryTemplate();
|
List<String> queryList = new ArrayList<String>();
|
queryList.add("*");
|
qtl.setBtmType(WI_NAME);
|
qtl.setClauseList(queryList);
|
qtl.setId("p");
|
qtl.setType("btm");
|
qtl.setRightFlag(false);
|
Map<String, String> map = new HashMap<String, String>();
|
map.put("executionid", (new StringBuilder(String.valueOf(processInstanceId))).append("*").toString());
|
Condition condition = OQueryHelper.getCondition(map);
|
qtl.setCondition(condition);
|
BusinessObject findBTMObjects[] = oqService.findBTMObjects(qtl.getId(), OQueryHelper.getQTTextByQT(qtl));
|
bofService.batchDeleteBusinessObject(findBTMObjects, 1);
|
|
//��ֹ����ʱ��ͬʱ����workflowinstance״̬����Ҫ������ǰû�д˶���ļ������
|
if (isWorkFlowInstanceExist()) {
|
ObsoleteWorkflowInstance(processInstanceId);
|
}
|
}
|
|
/**
|
* 作废流程实例
|
* 设置流程实例状态为：Obsoleted
|
* @param processInstanceId
|
* @throws VCIError
|
*/
|
private void ObsoleteWorkflowInstance(String processInstanceId) throws VCIError {
|
BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
|
ObjectQueryServicePrx oqService = ServerServiceProvider.getOQService();
|
|
QueryTemplate qtl = new QueryTemplate();
|
List<String> queryList = new ArrayList<String>();
|
queryList.add("*");
|
qtl.setBtmType(WFI_NAME);
|
qtl.setClauseList(queryList);
|
qtl.setId("workflowinstanceQuery");
|
qtl.setType("btm");
|
qtl.setRightFlag(false);
|
Map<String, String> map = new HashMap<String, String>();
|
map.put("executionid", (new StringBuilder(String.valueOf(processInstanceId))).append("*").toString());
|
Condition condition = OQueryHelper.getCondition(map);
|
qtl.setCondition(condition);
|
BusinessObject bos[] = oqService.findBTMObjects(qtl.getId(),
|
OQueryHelper.getQTTextByQT(qtl));
|
for (BusinessObject bo : bos) {
|
ObjectTool.setBOAttributeValue(bo, BusinessConstants.SELECT_LCSTATUS.toLowerCase(), "Obsoleted");
|
}
|
|
// BusinessObjectListHolder bosh = new BusinessObjectListHolder();
|
// bosh.value = bos;
|
bofService.batchUpdateBusinessObject(bos);
|
}
|
|
/**
|
* 更新任务的责任人
|
*/
|
public void updataForAssign(String fromUser, String userName[], String taskId, int j)
|
throws VCIError
|
{
|
BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
|
|
BusinessObject bos[] = getTaskBusinessObject(fromUser, taskId);
|
ObjectTool.setBOAttributeValue(bos[0], "principal", userName[j]);
|
|
// BusinessObjectHolder boh = new BusinessObjectHolder();
|
// boh.value = bos[0];
|
bofService.updateBusinessObject(bos[0]);
|
}
|
|
/**
|
* 获取任务对象
|
* @param fromUser
|
* @param taskId
|
* @return
|
* @throws VCIError
|
*/
|
private BusinessObject[] getTaskBusinessObject(String fromUser, String taskId)
|
throws VCIError
|
{
|
QueryTemplate qtl = new QueryTemplate();
|
List<String> list = new ArrayList<String>();
|
list.add("*");
|
qtl.setBtmType(WI_NAME);
|
qtl.setClauseList(list);
|
qtl.setId("p");
|
qtl.setType("btm");
|
qtl.setRightFlag(false);
|
Map<String, String> map = new HashMap<String, String>();
|
map.put("principal", fromUser);
|
map.put("businesstype", "5");
|
map.put("taskoid", taskId);
|
Condition condition = OQueryHelper.getCondition(map);
|
qtl.setCondition(condition);
|
|
ObjectQueryServicePrx oqService = ServerServiceProvider.getOQService();
|
|
BusinessObject findBTMObjects[] = oqService.findBTMObjects(qtl.getId(), OQueryHelper.getQTTextByQT(qtl));
|
return findBTMObjects;
|
}
|
|
/**
|
* 更新任务完成状态
|
*/
|
public void updataWorkitemForComplete(String fromUser, String taskId)
|
throws VCIError
|
{
|
BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
|
|
List<LinkObject> cloList = new ArrayList<LinkObject>();
|
List<BusinessObject> cboList = new ArrayList<BusinessObject>();
|
//List<BusinessObject> boList = new ArrayList<BusinessObject>();
|
|
BusinessObject tasks[] = getTaskBusinessObject(fromUser, taskId);
|
if (tasks == null || tasks.length == 0)
|
throw new VCIError("查询任务对象出现了错误", new String[] {});
|
|
BusinessObject task = tasks[0];
|
String idExec = ObjectTool.getBOAttributeValue(task, "executionid");
|
|
String ownerWFI = getFlowInstanceOwner(idExec);
|
if (StringUtils.isEmpty(ownerWFI))
|
ownerWFI = task.owner;
|
|
BusinessObject fromBo = bofService.initBusinessObject(WI_NAME);
|
fromBo.id = ObjectUtility.getNewObjectID36();
|
fromBo.name = task.name;
|
fromBo.description = task.description;
|
fromBo.lcStatus = "Completed";
|
// fromBo.owner = fromUser;
|
// fromBo.creator = "WorkFlowAdmin";
|
|
ObjectTool.setBOAttributeValue(fromBo, "code", ObjectTool.getBOAttributeValue(task, "code"));
|
ObjectTool.setBOAttributeValue(fromBo, "assigner", ownerWFI);
|
ObjectTool.setBOAttributeValue(fromBo, "principal", fromUser);
|
ObjectTool.setBOAttributeValue(fromBo, "worktype", "2");
|
ObjectTool.setBOAttributeValue(fromBo, "businesstype", "5");
|
ObjectTool.setBOAttributeValue(fromBo, "taskoid", taskId);
|
ObjectTool.setBOAttributeValue(fromBo, "executionid", ObjectTool.getBOAttributeValue(task, "executionid"));
|
cboList.add(fromBo);
|
String ObjectOids[] = (new ProcessTemplateService()).getDataId(ObjectTool.getBOAttributeValue(task, "executionid"));
|
// String flowinstancesql = (new StringBuilder("select t.PLPROCESSTYPE from plflowobject t where t.plexecutionid ='")).append(ObjectTool.getBOAttributeValue(task, "executionid")).append("'").toString();
|
String flowinstancesql = "select t.pltablename,t.pldesc,t.processname from PLFLOWINSTANCE t where t.plexecutionid ='"
|
+ ObjectTool.getBOAttributeValue(task, "executionid") + "'";
|
|
SQLQuery flowinstancecreateSQLQuery = HibernateSessionFactory.getSession().createSQLQuery(flowinstancesql);
|
// flowinstancecreateSQLQuery.executeUpdate();
|
List<?> flowinstancelist = flowinstancecreateSQLQuery.list();
|
String btmType = "";
|
String btmDesc = "";
|
//String processName = "";
|
for(int j = 0; j < flowinstancelist.size(); j++)
|
{
|
Object object[] = (Object[])flowinstancelist.get(j);
|
btmType = String.valueOf(object[0]);
|
btmDesc = (String) object[1];
|
//processName = (String) object[2];
|
}
|
|
for(int k = 0; k < ObjectOids.length; k++)
|
{
|
String flowobjectsql = (new StringBuilder("select t.PLPROCESSTYPE from plflowobject t where t.plobjectid ='")).append(ObjectOids[k]).append("' and t.plexecutionid = '"+ObjectTool.getBOAttributeValue(task, "executionid")+"'").toString();
|
SQLQuery flowobjectSQLQuery = HibernateSessionFactory.getSession().createSQLQuery(flowobjectsql);
|
// flowobjectSQLQuery.executeUpdate();
|
List<?> flowobjectlist = flowobjectSQLQuery.list();
|
for(int j = 0; j < flowobjectlist.size(); j++)
|
{
|
Object object = (Object)flowobjectlist.get(j);
|
btmType = String.valueOf(object);
|
}
|
LinkObject clo = bofService.initLinkObject("input");
|
BusinessObject toBO = bofService.readBusinessObject(ObjectOids[k], btmType);
|
ObjectTool.setLOAttributeValue(clo, "linkdescription", btmDesc);
|
ObjectTool.setLOFromBO(clo, fromBo);
|
ObjectTool.setLOToBO(clo, toBO);
|
cloList.add(clo);
|
}
|
|
// BusinessObjectListHolder bosh = new BusinessObjectListHolder();
|
// bosh.value = cboList.toArray(new BusinessObject[0]);
|
//
|
// LinkObjectListHolder losh = new LinkObjectListHolder();
|
// losh.value = cloList.toArray(new LinkObject[0]);
|
bofService.batchCreateBusinessObjectWithLink(cboList.toArray(new BusinessObject[0]), cloList.toArray(new LinkObject[0]));
|
// bofService.batchCreateBusinessObjectWithLink((BusinessObject[])cboList.toArray(new BusinessObject[0]), (LinkObject[])cloList.toArray(new LinkObject[0]));
|
}
|
|
/**
|
* 任务传递
|
*/
|
public void transmitTaskByPlm(String taskid, String fromUser, String userName[])
|
throws VCIError
|
{
|
BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
|
|
List<LinkObject> cloList = new ArrayList<LinkObject>();
|
List<BusinessObject> cboList = new ArrayList<BusinessObject>();
|
|
BusinessObject tasks[] = getTaskBusinessObject(fromUser, taskid);
|
if (tasks == null || tasks.length == 0)
|
throw new VCIError("查询任务信息失败！", null);
|
|
BusinessObject task = tasks[0];
|
|
for(int j = 0; j < userName.length; j++)
|
{
|
ObjectTool.setBOAttributeValue(task, "principal", userName[j]);
|
if(j == 0) {
|
// BusinessObjectHolder boh = new BusinessObjectHolder();
|
// boh.value = task;
|
bofService.updateBusinessObject(task);
|
}
|
else {
|
// BusinessObjectListHolder bosh = new BusinessObjectListHolder();
|
// bosh.value = tasks;
|
bofService.batchCreateBusinessObject(tasks, false, false);
|
}
|
}
|
|
String idExec = ObjectTool.getBOAttributeValue(task, "executionid");
|
|
String ownerWFI = getFlowInstanceOwner(idExec);
|
if (StringUtils.isEmpty(ownerWFI))
|
ownerWFI = task.owner;
|
|
BusinessObject fromBo = bofService.initBusinessObject(WI_NAME);
|
fromBo.id = ObjectUtility.getNewObjectID36();
|
fromBo.name = task.name;
|
fromBo.description = task.description;
|
fromBo.lcStatus = "Completed";
|
// fromBo.owner = fromUser;
|
// fromBo.creator = "WorkFlowAdmin";
|
ObjectTool.setBOAttributeValue(fromBo, "assigner", ownerWFI);
|
ObjectTool.setBOAttributeValue(fromBo, "principal", fromUser);
|
ObjectTool.setBOAttributeValue(fromBo, "worktype", "2");
|
ObjectTool.setBOAttributeValue(fromBo, "businesstype", "5");
|
ObjectTool.setBOAttributeValue(fromBo, "taskoid", taskid);
|
ObjectTool.setBOAttributeValue(fromBo, "executionid", idExec);
|
cboList.add(fromBo);
|
String ObjectOids[] = (new ProcessTemplateService()).getDataId(ObjectTool.getBOAttributeValue(task, "executionid"));
|
|
String sqlFI = String.format("select t.pltablename,t.pldesc,t.processname from PLFLOWINSTANCE t where t.plexecutionid ='%s'", idExec);
|
SQLQuery flowinstancecreateSQLQuery = HibernateSessionFactory.getSession().createSQLQuery(sqlFI);
|
// flowinstancecreateSQLQuery.executeUpdate();
|
List<?> flowinstancelist = flowinstancecreateSQLQuery.list();
|
String btmType = "";
|
String btmDesc = "";
|
//String processName = "";
|
if (flowinstancelist.size() > 0)
|
{
|
Object object[] = (Object[])flowinstancelist.get(0);
|
btmType = String.valueOf(object[0]);
|
btmDesc = (String)object[1];
|
//processName = (String)object[2];
|
}
|
|
for(int k = 0; k < ObjectOids.length; k++)
|
{
|
LinkObject clo = bofService.initLinkObject("input");
|
BusinessObject toBO = bofService.readBusinessObject(ObjectOids[k], btmType);
|
ObjectTool.setLOAttributeValue(clo, "linkdescription", btmDesc);
|
ObjectTool.setLOFromBO(clo, fromBo);
|
ObjectTool.setLOToBO(clo, toBO);
|
cloList.add(clo);
|
}
|
|
// BusinessObjectListHolder bosh = new BusinessObjectListHolder();
|
// bosh.value = cboList.toArray(new BusinessObject[0]);
|
//
|
// LinkObjectListHolder losh = new LinkObjectListHolder();
|
// losh.value = cloList.toArray(new LinkObject[0]);
|
bofService.batchCreateBusinessObjectWithLink(cboList.toArray(new BusinessObject[0]), cloList.toArray(new LinkObject[0]));
|
//bofService.batchCreateBusinessObjectWithLink((BusinessObject[])cboList.toArray(new BusinessObject[0]), (LinkObject[])cloList.toArray(new LinkObject[0]));
|
}
|
|
/**
|
* 保存并开始
|
*/
|
public void saveForStart_v1(FlowInstanceInfo var, Task task, String userName, String taskId, String executionid,
|
String objId[], Map<String, Object> variables, String objectProperty[], String objectPropertyValues[][])
|
throws VCIError
|
{
|
BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
|
|
List<LinkObject> cloList = new ArrayList<LinkObject>();
|
List<BusinessObject> cboList = new ArrayList<BusinessObject>();
|
|
BusinessObject fromBo = bofService.initBusinessObject(WI_NAME);
|
fromBo.id = ObjectUtility.getNewObjectID36();
|
fromBo.name = (new StringBuilder(String.valueOf(var.processName))).append("-").append(task.getName()).toString();
|
fromBo.description = var.desc;
|
fromBo.lcStatus = "Executing";
|
// fromBo.creator = "WorkFlowAdmin";
|
// fromBo.owner = userName;
|
|
ObjectTool.setBOAttributeValue(fromBo, "code", task.getName());
|
ObjectTool.setBOAttributeValue(fromBo, "assigner", var.creator);
|
ObjectTool.setBOAttributeValue(fromBo, "principal", userName);
|
ObjectTool.setBOAttributeValue(fromBo, "worktype", "2");
|
ObjectTool.setBOAttributeValue(fromBo, "businesstype", "5");
|
ObjectTool.setBOAttributeValue(fromBo, "taskoid", taskId);
|
ObjectTool.setBOAttributeValue(fromBo, "executionid", executionid);
|
cboList.add(fromBo);
|
// added by cmk start
|
BusinessObject[] toBos = bofService.getBatchBusinessObject(objId, var.tableName);
|
// for(int i = 0; i < objId.length; i++)
|
// {
|
// //LinkObject clo = loDelegate.initLinkObject("input");
|
// BusinessObject toBO = boDelegate.getInfoBusinessObject(objId[i], var.tableName);
|
// toBos.add(toBO);
|
// }
|
// added by cmk end
|
for(int j = 0; j < objectPropertyValues.length; j++)
|
{
|
LinkObject clo = bofService.initLinkObject("input");
|
for(int j1 = 0; j1 < objectPropertyValues[j].length; j1++)
|
{
|
String value = objectPropertyValues[j][j1];
|
String filed = objectProperty[j1].toLowerCase();
|
if("oid".equals(filed))
|
clo.toOid = value;
|
else
|
if("revisionoid".equals(filed))
|
clo.toRevOid = value;
|
else
|
if("nameoid".equals(filed))
|
clo.toNameOid = value;
|
else
|
if("btmname".equals(filed))
|
clo.toBTName = value;
|
}
|
|
ObjectTool.setLOFromBO(clo, fromBo);
|
cloList.add(clo);
|
}
|
// added by cmk start
|
//�����Ƿ����workflowinstance�洢�ж�
|
// if (isWorkFlowInstanceExist()) {
|
// this.cunstructWorkFlowInstanceObj(bofBoDelegate, loDelegate, cboList, cloList, var, executionid, toBos);
|
// }
|
// added by cmk end
|
|
// BusinessObjectListHolder bosh = new BusinessObjectListHolder();
|
// bosh.value = cboList.toArray(new BusinessObject[0]);
|
|
// LinkObjectListHolder losh = new LinkObjectListHolder();
|
// losh.value = cloList.toArray(new LinkObject[0]);
|
bofService.batchCreateBusinessObjectWithLink(cboList.toArray(new BusinessObject[0]), cloList.toArray(new LinkObject[0]));
|
}
|
|
|
/**
|
* 更改执行中的工作流任务的负责人
|
* @param taskId 执行中的工作流任务ID
|
* @param fromUserName 原负责人
|
* @param newUserName 新负责人
|
* @author xchao
|
* @since 2018.01.18
|
* @throws VCIError
|
*/
|
public void updateExecutingWorkItemPrincipalToNewUserName(String taskId, String fromUserName, String newUserName) throws VCIError{
|
QueryTemplate qt = new QueryTemplate();
|
List<String> list = new ArrayList<String>();
|
list.add("*");
|
qt.setBtmType(WI_NAME);
|
qt.setClauseList(list);
|
qt.setId("p");
|
qt.setType("btm");
|
qt.setRightFlag(false);
|
Map<String, String> map = new HashMap<String, String>();
|
map.put("businesstype", "5");
|
map.put("taskoid", taskId);
|
map.put("lcstatus", "Executing");
|
map.put("principal", fromUserName);
|
Condition condition = OQueryHelper.getCondition(map);
|
qt.setCondition(condition);
|
|
BOFactoryServicePrx bofService = ServerServiceProvider.getBOFService();
|
ObjectQueryServicePrx oqService = ServerServiceProvider.getOQService();
|
|
|
BusinessObject findBTMObjects[] = oqService.findBTMObjects(qt.getId(), OQueryHelper.getQTTextByQT(qt));
|
|
List<BusinessObject> oldBoUpdatelist = new ArrayList<BusinessObject>();
|
for (BusinessObject businessObject : findBTMObjects) {
|
//BusinessObject oldBO = boDelegate.getInfoBusinessObject(businessObject.oid, "WorkItem".toLowerCase());
|
ObjectTool.setBOAttributeValue(businessObject, "principal", newUserName);
|
oldBoUpdatelist.add(businessObject);
|
}
|
if(oldBoUpdatelist != null && oldBoUpdatelist.size() > 0) {
|
// BusinessObjectListHolder bosh = new BusinessObjectListHolder();
|
// bosh.value = oldBoUpdatelist.toArray(new BusinessObject[0]);
|
bofService.batchUpdateBusinessObject(oldBoUpdatelist.toArray(new BusinessObject[0]));
|
}
|
}
|
|
private String getFlowInstanceOwner(String idExec) throws VCIError {
|
ObjectQueryServicePrx oqService = ServerServiceProvider.getOQService();
|
|
String sql = "select owner from " + WFI_TABLE_NAME + " where executionid ='" + idExec.trim() + "'";
|
String[][] result = oqService.queryBySqlWithoutKey(sql);
|
if(result == null || result.length == 0) {
|
return "";
|
}
|
|
if(result[0] != null && result[0].length > 0) {
|
return result[0][0];
|
}
|
|
return "";
|
}
|
}
|
