package com.vci.client.uif.actions.client;
|
|
import java.util.Map;
|
import java.util.Map.Entry;
|
|
import javax.swing.JFrame;
|
|
import com.vci.client.common.objects.UserEntityObject;
|
import com.vci.client.logon.base.TabPanelManage;
|
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.task.TodoTaskByPlatformDialog;
|
import com.vci.corba.common.VCIError;
|
import com.vci.mw.ClientContextVariable;
|
|
/**
|
* 执行流程 Action
|
* <p>执行流程</p>
|
* @author liudi
|
*
|
*/
|
public class ExecuteWorkFlowAction extends AbstractBusionessOperationAction {
|
|
@Override
|
public String getKey() {
|
return "executetask";
|
}
|
|
private Object[] objs = new Object[0];
|
private String outcome = "";
|
private String[] taskOids = new String[objs.length];
|
private String[] executionIds = new String[objs.length];
|
private String[] taskNames = new String[objs.length];
|
private String[] taskStatuss = new String[objs.length];
|
private ProcessCustomClientDelegate getProcessCustomClientDelegate(){
|
UserEntityObject userEntityObject = new UserEntityObject();
|
String ip = ClientContextVariable.getInvocationInfo().clientIPInfo;
|
String loginUserName = ClientContextVariable.getInvocationInfo().userName;
|
userEntityObject.setIp(ip);
|
userEntityObject.setUserName(loginUserName);
|
userEntityObject.setModules("");
|
ProcessCustomClientDelegate delegate = new ProcessCustomClientDelegate(userEntityObject);
|
return delegate;
|
}
|
|
private void checkExecutable(){
|
taskOids = new String[objs.length];
|
executionIds = new String[objs.length];
|
taskNames = new String[objs.length];
|
taskStatuss = new String[objs.length];
|
for (int objectIndex = 0; objectIndex < objs.length; objectIndex++) {
|
IDataNode idn = (IDataNode) objs[objectIndex];
|
Map<String, String> valueMap = idn.getValueMap();
|
int i=0;
|
int j=0;
|
int k=0;
|
int s=0;
|
boolean subFlag = false;
|
int subint =0;
|
for(Entry<String, String> entrySet : valueMap.entrySet()){
|
String value = entrySet.getValue();
|
if(entrySet.getKey()!=null&&entrySet.getKey().equals("TaskOID".toLowerCase())){
|
taskOids[i] = value;
|
i++;
|
}
|
if(entrySet.getKey()!=null&&entrySet.getKey().equals("Executionid".toLowerCase())){
|
executionIds[j] = value;
|
String replace = value.replace(".", ",");
|
String[] split = replace.split(",");
|
if(split.length>2){
|
subFlag = true;
|
}else{
|
subFlag = false;
|
}
|
j++;
|
}
|
if(entrySet.getKey()!=null&&entrySet.getKey().equals("Name".toLowerCase())){
|
taskNames[k] = value;
|
k++;
|
}
|
if(entrySet.getKey()!=null&&entrySet.getKey().equals("lcstatus".toLowerCase())){
|
taskStatuss[s] = value;
|
s++;
|
}
|
}
|
taskNames[0] = taskNames[0].substring(taskNames[0].lastIndexOf("-")+1);
|
}
|
}
|
@Override
|
public boolean doPost() {
|
// 获取选择的数据
|
// 数据的实际类型一般为 IDataNode
|
objs = getDataModel().getSelectObjects();
|
ProcessCustomClientDelegate delegate = getProcessCustomClientDelegate();
|
checkExecutable();
|
// 用户名
|
String[] userName = new String[] {};
|
if("Completed".toLowerCase().equals(taskStatuss[0].toLowerCase())){
|
UIFUtils.showMessage(ClientContextVariable.getFrame(), "任务已经完成！");
|
return false;
|
}
|
TodoTaskByPlatformDialog dialog = new TodoTaskByPlatformDialog(executionIds[0],taskOids[0], taskNames[0],taskStatuss[0]);
|
dialog.setTitle("执行任务");
|
dialog.setVisible(true);
|
boolean b = false;
|
if(dialog.isSaveFlag()){
|
outcome = dialog.getOutCome() == null ? "" : dialog.getOutCome();
|
String approvalNote = dialog.getDesc() == null ? "" : dialog.getDesc();
|
userName = !"".equals(dialog.getNextUser()) ? new String[]{dialog.getNextUser()} : new String[0];
|
b = completeTask(delegate, taskOids, outcome, approvalNote, userName);
|
if(b){
|
UIFUtils.showMessage(ClientContextVariable.getFrame(), "执行成功！");
|
}
|
|
// 根据配置 close 决定，流程正常执行完毕，是否从顶级UI中关闭此窗口
|
// 默认行为：如果没有配置值，则执行关闭；如果配置了值，当且仅当值为true时，执行关闭；否则不关闭
|
// 即：默认关闭
|
String close = getParameterValue(ValueType.ButtonConfig, "close", -1);
|
Boolean closeValue = (close != null && "false".equalsIgnoreCase(close))? false : true;
|
if(closeValue){
|
TabPanelManage.getInstance().getTabPanel().remove(TabPanelManage.getInstance().getTabPanel().getSelectedIndex());
|
}
|
}
|
return b;
|
}
|
private boolean completeTask(
|
final ProcessCustomClientDelegate delegate,
|
final String[] taskOids, final String outcome, final String approvalNote, final String[] userName){
|
final boolean[] ress = {false};
|
final QANProcessBarFrame frame = new QANProcessBarFrame();
|
final QANProcessBar bar = new QANProcessBar(new Thread(new Runnable() {
|
@Override
|
public void run() {
|
try{
|
frame.setContent("正在提交流程，请稍等...");
|
String jbpmDeploymentId = delegate.getDeploymentIdByExecutionId(executionIds[0]);
|
String nextTaskName = delegate.getNextTaskNameByJbpmId(jbpmDeploymentId, taskNames[0], outcome);
|
// String[][] properties = new String[][]{new String[]{"Oid","RevisionOid","NameOid","BTMName"},
|
// new String[]{}};
|
ress[0] = delegate.completeTaskByPlatform(
|
taskOids[0], outcome, nextTaskName, approvalNote , userName);
|
}catch(VCIError e){
|
frame.setProcessBarCancel(true);
|
UIFUtils.showErrorMessage(ClientContextVariable.getFrame(), e);
|
} catch (VCIException e) {
|
e.printStackTrace();
|
UIFUtils.showErrorMessage(ClientContextVariable.getFrame(), e);
|
} finally{
|
frame.setProcessBarCancel(true);
|
}
|
}
|
}), (JFrame) ClientContextVariable.getFrame(), frame, "执行流程", false);
|
bar.setVisible(true);
|
return ress[0];
|
}
|
}
|
