package com.vci.client.uif.actions.client;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Map.Entry;
|
|
import javax.swing.JFrame;
|
|
import org.apache.commons.lang3.StringUtils;
|
|
import com.vci.client.bof.ClientBusinessObject;
|
import com.vci.client.bof.ClientLinkObject;
|
import com.vci.client.common.objects.UserEntityObject;
|
import com.vci.client.common.oq.OQTool;
|
import com.vci.client.oq.QTClient;
|
import com.vci.client.ui.exception.VCIException;
|
import com.vci.client.ui.process.QANProcessBar;
|
import com.vci.client.ui.process.QANProcessBarFrame;
|
import com.vci.client.uif.engine.common.IDataNode;
|
import com.vci.client.workflow.delegate.ProcessCustomClientDelegate;
|
import com.vci.client.workflow.launch.LaunchDialog;
|
import com.vci.common.qt.object.Condition;
|
import com.vci.common.qt.object.QueryTemplate;
|
import com.vci.common.qt.object.Version;
|
import com.vci.corba.common.VCIError;
|
import com.vci.corba.omd.data.BusinessObject;
|
import com.vci.corba.workflow.data.FlowInstanceInfo;
|
import com.vci.corba.workflow.data.MapTransfersInfo;
|
import com.vci.corba.workflow.data.ProcessTaskInfo;
|
import com.vci.mw.ClientContextVariable;
|
|
|
/**
|
* 启动工作流程 Action
|
* <p>
|
* 1、基于选定数据进行的操作
|
* </p>
|
* <p>
|
* 2、可以选择多条数据进行此操作
|
* </p>
|
*
|
* @author xiongchao
|
*
|
*/
|
public class LaunchWorkFlowAction extends AbstractBatchBusionessOperationAction {
|
|
/**
|
* 按钮参数
|
*/
|
private Map<String, String> paramsMap = null;
|
|
/**
|
* 按钮配置的dialog列头。
|
*/
|
private String headers = "";
|
|
/**
|
* 按钮配置的dialog列头对应的mapvalue中的key。
|
*/
|
private String keys = "";
|
|
/**
|
* 登陆人员信息
|
*/
|
private String loginUserName = "";
|
|
private String processType = "";
|
|
private String boType = "";
|
|
private String[] objId = null;
|
|
/**
|
* dialog窗口数据。
|
*/
|
private Map<String, Map<String, String>> values = new HashMap<String, Map<String, String>>();
|
|
private String workflowStartState = "Working";
|
|
/**
|
* dialog窗口table列头。
|
*/
|
private String[] heads = null;
|
|
private boolean errorNameFlag = false;//用于标记当对象为已发布，但无法取其标示时为true;
|
|
// private String[] ids;
|
|
LaunchDialog dialog = null;
|
@Override
|
public String getKey() {
|
return "launchworkflow";
|
}
|
|
/*
|
* (non-Javadoc)
|
*
|
* @see plm.uif.actions.client.BusinessOperationAction#doPost()
|
*/
|
@SuppressWarnings("deprecation")
|
@Override
|
public boolean doPost() {
|
preLoadMessage();
|
try {
|
if(dialog == null){
|
return false;
|
}
|
if(!dialog.isSaveFlag()){
|
return false;
|
}
|
String processName = dialog.getProcessName();
|
String processDec = dialog.getProcessDec();
|
while(dialog.isSaveFlag() && checkProcessNameIsExist(dialog)){
|
dialog.setSaveFlag(false);
|
dialog.setVisible(true);
|
processName = dialog.getProcessName();
|
}
|
if(!dialog.isSaveFlag()){
|
return false;
|
}
|
Map<String, List<String>> taskAndUserMap = dialog
|
.getTaskAndUserMap();
|
// 流程名称：加版本号
|
String processDefinitionKey = dialog.getProcessTemplateName();
|
int taskIndex = 0;
|
// 任务名称数组
|
String[] tasknames = new String[taskAndUserMap.size()];
|
// 任务对应的用户数组
|
String[][] taskUserNames = new String[taskAndUserMap.size()][];
|
for (Entry<String, List<String>> entrySet : taskAndUserMap
|
.entrySet()) {
|
tasknames[taskIndex] = entrySet.getKey();
|
List<String> list = entrySet.getValue();
|
String[] array = list.toArray(new String[] {});
|
String[] userNames = new String[array.length];
|
for (int userIndex = 0; userIndex < array.length; userIndex++) {
|
userNames[userIndex] = array[userIndex];
|
}
|
taskUserNames[taskIndex] = userNames;
|
taskIndex++;
|
}
|
// 用户名
|
String[] userName = new String[] {};
|
ProcessCustomClientDelegate delegate = createProcessCustomClientDelegate();
|
String deploymentID = delegate
|
.getDeploymentID(processDefinitionKey);
|
ProcessTaskInfo firstProcessTask = delegate
|
.getFirstProcessTask(deploymentID);
|
for (int i = 0; i < tasknames.length; i++) {
|
if (firstProcessTask.taskName.equals(tasknames[i])) {
|
userName = new String[taskUserNames[i].length];
|
for (int j = 0; j < taskUserNames[i].length; j++) {
|
userName[j] = taskUserNames[i][j];
|
}
|
}
|
}
|
// 流程实例对象
|
FlowInstanceInfo flowInstanceInfo = new FlowInstanceInfo();
|
flowInstanceInfo.creator = loginUserName;
|
flowInstanceInfo.templatePuid = "";
|
flowInstanceInfo.clsfOid = "";
|
flowInstanceInfo.tableName = processType;
|
flowInstanceInfo.applicant = loginUserName;
|
flowInstanceInfo.desc = processDec == null ? "" : processDec;
|
flowInstanceInfo.processType = boType;
|
flowInstanceInfo.templateName = "";
|
flowInstanceInfo.partList = "";
|
flowInstanceInfo.processName = processName == null ? ""
|
: processName;
|
|
MapTransfersInfo[] mapTransfersInfos = new MapTransfersInfo[1];
|
MapTransfersInfo info = new MapTransfersInfo();
|
info.key = "boType";
|
info.value = boType;
|
mapTransfersInfos[0] = info;
|
String outcome = "";
|
return startPocess(delegate, processDefinitionKey, flowInstanceInfo, objId,
|
userName, outcome, tasknames, taskUserNames,
|
mapTransfersInfos);
|
|
} catch (VCIError e) {
|
e.printStackTrace();
|
UIFUtils.showErrorMessage(ClientContextVariable.getFrame(), e);
|
return false;
|
} catch (VCIException e) {
|
e.printStackTrace();
|
UIFUtils.showErrorMessage(ClientContextVariable.getFrame(), e);
|
return false;
|
}
|
}
|
|
private void preLoadMessage() {
|
final QANProcessBarFrame frame = new QANProcessBarFrame();
|
final QANProcessBar bar = new QANProcessBar(new Thread(new Runnable() {
|
@SuppressWarnings("deprecation")
|
@Override
|
public void run() {
|
try {
|
frame.setContent("正在校验数据......");
|
// 获取选择的数据
|
// 数据的实际类型一般为 IDataNode
|
Object[] objs = getDataModel().getSelectObjects();
|
paramsMap = getButtonParams();
|
String cWorkflowStartState = paramsMap.get("workflowStartState");
|
if (cWorkflowStartState != null && !cWorkflowStartState.equals("")) {
|
workflowStartState = cWorkflowStartState;
|
}
|
if(paramsMap.containsKey("header")){
|
headers = paramsMap.get("header");// 获取设置列头
|
}
|
if(paramsMap.containsKey("keys")){
|
keys = paramsMap.get("keys"); // 获取列头对应的属性值。
|
}
|
// 获取
|
if (headers.equals("")) {
|
headers = "编码##代号##名称";
|
}
|
if(keys.equals("")){
|
keys = "code##id##name";
|
}
|
setLaunchDialogMessage(objs);
|
dialog = new LaunchDialog(processType, heads, values);
|
} catch (VCIError e) {
|
e.printStackTrace();
|
frame.setProcessBarCancel(true);
|
UIFUtils.showErrorMessage(ClientContextVariable.getFrame(), e);
|
return;
|
}finally{
|
frame.setProcessBarCancel(true);
|
}
|
}
|
}), (JFrame) ClientContextVariable.getFrame(), frame, "启动流程", false);
|
bar.setVisible(true);
|
if(dialog != null){
|
dialog.setVisible(true);
|
}
|
}
|
|
private boolean startPocess(
|
final ProcessCustomClientDelegate delegate,
|
final String processDefinitionKey, final FlowInstanceInfo flowInstanceInfo,
|
final String[] objId, final String[] userName, final String outcome, final String[] tasknames,
|
final String[][] taskUserNames, final MapTransfersInfo[] mapTransfersInfos) {
|
final boolean[] ress = {false};
|
final QANProcessBarFrame frame = new QANProcessBarFrame();
|
final QANProcessBar bar = new QANProcessBar(new Thread(new Runnable() {
|
@SuppressWarnings("deprecation")
|
@Override
|
public void run() {
|
try{
|
frame.setContent("正在提交流程，请稍等...");
|
String processInstansId = delegate.startPocessByPLM(
|
processDefinitionKey, flowInstanceInfo, objId,
|
userName, outcome, tasknames, taskUserNames,
|
mapTransfersInfos);
|
ress[0] = true;
|
frame.setProcessBarCancel(true);
|
UIFUtils.showMessage(ClientContextVariable.getFrame(),
|
"流程启动成功!\n【流程执行ID:" + processInstansId + "】");
|
}catch(VCIError e){
|
frame.setProcessBarCancel(true);
|
UIFUtils.showErrorMessage(ClientContextVariable.getFrame(), e);
|
} finally{
|
frame.setProcessBarCancel(true);
|
}
|
}
|
}), (JFrame) ClientContextVariable.getFrame(), frame, "启动流程", false);
|
bar.setVisible(true);
|
return ress[0];
|
}
|
|
private void setLaunchDialogMessage(Object[] objs) throws VCIError {
|
heads = headers.split("##");
|
String[] key = keys.split("##");
|
if(heads.length != key.length){
|
throw new VCIError("plm.uif.actions.client.LaunchWorkFlowAction.headerNoEqualsKey", new String[]{});
|
}
|
int len = key.length;
|
ArrayList<String[]> vals = new ArrayList<String[]>();
|
objId = new String[objs.length];
|
String boOid = "";
|
String boLcstatus = "";
|
StringBuffer processDataSb = new StringBuffer();
|
for (int objectIndex = 0; objectIndex < objs.length; objectIndex++) {
|
IDataNode idn = (IDataNode) objs[objectIndex];
|
Map<String, String> valueMap = idn.getValueMap();
|
String[] val = new String[len];
|
String keyNotExist = "";
|
for (int i = 0; i < len; i++) {
|
if(valueMap.containsKey(key[i])){
|
val[i] = valueMap.get(key[i]);
|
}else{
|
keyNotExist +="["+ key[i]+"]";
|
}
|
}
|
if(!keyNotExist.equals("")){
|
//抛出异常，key值不存在
|
throw new VCIError("plm.uif.actions.client.LaunchWorkFlowAction.keyPropertyIsNull", new String[]{"{"+keyNotExist+"}"});
|
}
|
vals.add(val);
|
boType = getBoType(idn);
|
boOid = getBoOid(idn);
|
boLcstatus = getBoLcStatus(boLcstatus, idn);
|
if(StringUtils.isNotEmpty(workflowStartState)){
|
if (!boLcstatus.toLowerCase().equals(workflowStartState.toLowerCase())) {
|
processDataSb.append(idn.toString()).append(",");
|
}
|
}
|
objId[objectIndex] = boOid;
|
}
|
checkDataIfInProcess(processDataSb);
|
createDatasForDialog(objId, heads, vals);
|
// 分类名称
|
processType = boType;
|
}
|
|
/**
|
* 判断是否发起过流程
|
*
|
* @param processDataSb
|
* 发起国流程的对象名称字符串。
|
* @throws VCIError
|
*/
|
private void checkDataIfInProcess(StringBuffer processDataSb) throws VCIError {
|
if(errorNameFlag){
|
throw new VCIError("所选数据中存在处于不能发起流程状态的数据，请重新选择！", new String[]{});
|
}else if (processDataSb != null && processDataSb.length() > 0) {
|
String mes = processDataSb.substring(0, processDataSb.length()-1);
|
throw new VCIError("所选数据[ "+mes+" ]的状态不能启动流程，请重新选择！", new String[]{});
|
}
|
}
|
|
private ProcessCustomClientDelegate createProcessCustomClientDelegate() {
|
UserEntityObject userEntityObject = new UserEntityObject();
|
String ip = ClientContextVariable.getInvocationInfo().clientIPInfo;
|
loginUserName = ClientContextVariable.getInvocationInfo().userName;
|
userEntityObject.setIp(ip);
|
userEntityObject.setUserName(loginUserName);
|
userEntityObject.setModules("");
|
return new ProcessCustomClientDelegate(userEntityObject);
|
}
|
|
private void createDatasForDialog(
|
String[] objId, String[] headers, ArrayList<String[]> vals) {
|
for (int i = 0; i < objId.length; i++) {
|
Map<String, String> oneValues = new HashMap<String, String>();
|
for (int j = 0; j < headers.length; j++) {
|
oneValues.put(headers[j], vals.get(i)[j]);
|
}
|
values.put(objId[i], oneValues);
|
}
|
}
|
|
private String getBoType(IDataNode idn) {
|
String boType = "";
|
if (idn.getMaterObject() instanceof ClientBusinessObject) {
|
boType = ((ClientBusinessObject) idn.getMaterObject()).getBtmName();
|
} else if (idn.getMaterObject() instanceof ClientLinkObject) {
|
if (idn.isForward()) {
|
boType = ((ClientLinkObject) idn.getMaterObject())
|
.getToBTMName();
|
} else {
|
boType = ((ClientLinkObject) idn.getMaterObject())
|
.getFromBTMName();
|
}
|
}
|
return boType;
|
}
|
|
private String getBoOid(IDataNode idn) {
|
String boOid = "";
|
if (idn.getMaterObject() instanceof ClientBusinessObject) {
|
boOid = ((ClientBusinessObject) idn.getMaterObject()).getOid();
|
} else if (idn.getMaterObject() instanceof ClientLinkObject) {
|
if (idn.isForward()) {
|
boOid = ((ClientLinkObject) idn.getMaterObject()).getToOid();
|
} else {
|
boOid = ((ClientLinkObject) idn.getMaterObject()).getFromOid();
|
}
|
}
|
return boOid;
|
}
|
|
private String getBoLcStatus(String boLcstatus, IDataNode idn) {
|
if (idn.getMaterObject() instanceof ClientBusinessObject) {
|
boLcstatus = ((ClientBusinessObject) idn.getMaterObject())
|
.getLcStatus();
|
} else if (idn.getMaterObject() instanceof ClientLinkObject) {
|
if (idn.isForward()) {
|
boLcstatus = idn.getValueMap().get("t_oid.lcstatus");
|
} else {
|
boLcstatus = idn.getValueMap().get("f_oid.lcstatus");
|
}
|
}
|
return boLcstatus;
|
}
|
|
@SuppressWarnings("deprecation")
|
private boolean checkProcessNameIsExist(LaunchDialog dialog) throws VCIError{
|
if(!dialog.isSaveFlag()) return false;
|
String processName = dialog.getProcessName();
|
boolean res = false;
|
QueryTemplate qt9 = new QueryTemplate();
|
List<String> clauseList = new ArrayList<String>();
|
clauseList.add("*");
|
qt9.setClauseList(clauseList);
|
qt9.setVersion(Version.lastRevLastVer);
|
qt9.setBtmType("workitem");
|
qt9.setRightFlag(false);
|
qt9.setId("d");
|
qt9.setType("btm");
|
|
Map<String, String> conditions = new HashMap<String, String>();
|
conditions.put("name", "*" + processName + "-*");
|
conditions.put("workType", "2");
|
conditions.put("businesstype", "5");
|
Condition cond = OQTool.getCondition(conditions);
|
qt9.setCondition(cond);
|
BusinessObject[] d = QTClient.getService().findBTMObjects(qt9.getId(), OQTool.qtTOXMl(qt9).asXML());
|
res = d.length > 0;
|
if(res){
|
UIFUtils.showMessage(ClientContextVariable.getFrame(),
|
"流程名称：‘" + processName + "’已经存在，不允许出现重复的流程名称!");
|
}
|
return res;
|
}
|
}
|
