554 lines
24 KiB
Java
554 lines
24 KiB
Java
package com.tenwa.flow.util;
|
||
|
||
import java.util.ArrayList;
|
||
import java.util.HashMap;
|
||
import java.util.Iterator;
|
||
import java.util.List;
|
||
import java.util.Map;
|
||
|
||
import jbo.sys.FLOW_CATALOG;
|
||
import jbo.sys.FLOW_MODEL;
|
||
import jbo.sys.FLOW_TASK;
|
||
|
||
import com.amarsoft.are.jbo.BizObject;
|
||
import com.amarsoft.are.jbo.BizObjectManager;
|
||
import com.amarsoft.are.jbo.BizObjectQuery;
|
||
import com.amarsoft.are.jbo.JBOFactory;
|
||
import com.amarsoft.are.jbo.JBOTransaction;
|
||
import com.amarsoft.are.util.json.JSONDecoder;
|
||
import com.amarsoft.are.util.json.JSONEncoder;
|
||
import com.amarsoft.are.util.json.JSONObject;
|
||
|
||
public class FlowViewGraph {
|
||
private String flowNo;
|
||
|
||
public String getFlowNo() {
|
||
return flowNo;
|
||
}
|
||
|
||
public void setFlowNo(String flowNo) {
|
||
this.flowNo = flowNo;
|
||
}
|
||
|
||
/**
|
||
* 获取ade工具开发的旧流程图
|
||
* @param tx
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
public String getModel(JBOTransaction tx,String flowNo) throws Exception{
|
||
List<BizObject> fms = JBOFactory.getBizObjectManager(FLOW_MODEL.CLASS_NAME).createQuery("flowno=:flowno ")
|
||
.setParameter("flowno", flowNo).getResultList(false);
|
||
BizObjectQuery beginEndPointQuery = JBOFactory.getBizObjectManager(FLOW_MODEL.CLASS_NAME).createQuery(
|
||
"select O.phaseno from O where flowno=:flowno and postscript is not null and postscript <> '' and "+
|
||
"(postscript like :phaseno1 or postScript like :phaseno2 or postScript like :phaseno3 or postscript like :phaseno4) ")
|
||
.setParameter("flowno", flowNo);
|
||
Map<String,Object> stateMap = new HashMap<String,Object>();
|
||
Map<String,String> rectPhaseno = new HashMap<String,String>();
|
||
Map<String,Object> pathMap = new HashMap<String,Object>();
|
||
Map<String,Object> propsMap = new HashMap<String,Object>();
|
||
Map<String,Object> modelMap = new HashMap<String,Object>();
|
||
if(fms.size()>0){
|
||
for(int i=0;i<fms.size();i++){
|
||
Map<String,Object> nodeName = new HashMap<String,Object>();
|
||
Map<String,Object> attrValue = new HashMap<String,Object>();
|
||
Map<String,Object> textValue = new HashMap<String,Object>();
|
||
Map<String,Object> keyValue = new HashMap<String,Object>();
|
||
Map<String,Object> positionValue = new HashMap<String,Object>();
|
||
Map<String,Object> props = new HashMap<String,Object>();
|
||
Map<String,Object> rect = new HashMap<String,Object>();
|
||
BizObject fm = fms.get(i);
|
||
if(fm.getAttribute("phaseno").getString().equals("8000")){
|
||
rect.put("type", "reject");
|
||
}else if(fm.getAttribute("phaseno").getString().equals("0010")){
|
||
rect.put("type", "task");
|
||
}else{
|
||
rect.put("type", fm.getAttribute("nodetype").getString().toLowerCase());
|
||
}
|
||
nodeName.put("text",fm.getAttribute("phasename").getString());
|
||
rect.put("text", nodeName);
|
||
attrValue.put("x", fm.getAttribute("xcoordinate").getInt());
|
||
attrValue.put("y", fm.getAttribute("ycoordinate").getInt());
|
||
if(fm.getAttribute("nodetype").getString().equalsIgnoreCase("task")||fm.getAttribute("nodetype").getString().equalsIgnoreCase("start")){
|
||
attrValue.put("width", 100);
|
||
attrValue.put("height",50);
|
||
}else{
|
||
attrValue.put("width", 50);
|
||
attrValue.put("height", 50);
|
||
}
|
||
rect.put("attr", attrValue);
|
||
textValue.put("value",fm.getAttribute("phasename").getString());
|
||
keyValue.put("value", String.valueOf(i));
|
||
positionValue.put("value", fm.getAttribute("phaseno").getString());
|
||
props.put("text", textValue);
|
||
props.put("key", keyValue);
|
||
props.put("position", positionValue);
|
||
rect.put("props", props);
|
||
stateMap.put("rect"+String.valueOf(i+1), rect);
|
||
rectPhaseno.put(fm.getAttribute("phaseno").getString(), "rect"+String.valueOf(i+1));
|
||
}
|
||
}
|
||
modelMap.put("states", stateMap);
|
||
|
||
if(fms.size()>0){
|
||
int num = fms.size()+1;
|
||
for(int i=0;i<fms.size();i++){
|
||
BizObject fm = fms.get(i);
|
||
String phaseNo = fm.getAttribute("phaseno").getString();
|
||
List<BizObject> phases = beginEndPointQuery.setParameter("phaseno1", "%'"+phaseNo+"'%").setParameter("phaseno2", "%\""+phaseNo+"\"%")
|
||
.setParameter("phaseno3", "%;"+phaseNo+"%").setParameter("phaseno4", "%"+phaseNo+";%").getResultList(false);
|
||
if(phases.size()>0){
|
||
for(BizObject phase : phases){
|
||
String prePhaseno = phase.getAttribute("phaseno").getString();
|
||
Map<String,Object> path = new HashMap<String,Object>();//
|
||
path.put("from", rectPhaseno.get(prePhaseno));
|
||
path.put("to", rectPhaseno.get(phaseNo));
|
||
path.put("dots", new ArrayList());
|
||
Map<String,Object> toPhasename = new HashMap<String,Object>();
|
||
toPhasename.put("text", "to"+fm.getAttribute("phasename").getString());
|
||
path.put("text", toPhasename);
|
||
Map<String,Object> textPos = new HashMap<String,Object>();//
|
||
textPos.put("x", 0);
|
||
textPos.put("y", -10);
|
||
path.put("textPos", textPos);
|
||
Map<String,Object> text =new HashMap<String,Object>();
|
||
text.put("value", "");
|
||
Map<String,Object> propstext =new HashMap<String,Object>();
|
||
propstext.put("text", text);
|
||
path.put("props",propstext);
|
||
pathMap.put("path"+String.valueOf(num), path);
|
||
num++;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
modelMap.put("paths", pathMap);
|
||
|
||
Map<String,Object> type = new HashMap<String,Object>();
|
||
Map<String,Object> displayName = new HashMap<String,Object>();
|
||
Map<String,Object> code = new HashMap<String,Object>();
|
||
Map<String,Object> name = new HashMap<String,Object>();
|
||
Map<String,Object> version = new HashMap<String,Object>();
|
||
Map<String,Object> jpdlVersion = new HashMap<String,Object>();
|
||
Map<String,Object> desc = new HashMap<String,Object>();
|
||
Map<String,Object> position = new HashMap<String,Object>();
|
||
Map<String,Object> props = new HashMap<String,Object>();
|
||
type.put("value", "null");
|
||
displayName.put("value", "null");
|
||
code.put("value", "null");
|
||
name.put("value", "null");
|
||
version.put("value", "null");
|
||
jpdlVersion.put("value", "4.4");
|
||
desc.put("value", "null");
|
||
position.put("value", "null");
|
||
props.put("type",type);
|
||
props.put("displayName",displayName);
|
||
props.put("code",code);
|
||
props.put("name",name);
|
||
props.put("type",version);
|
||
props.put("jpdlVersion",jpdlVersion);
|
||
props.put("desc",desc);
|
||
props.put("position",position);
|
||
propsMap.put("props", props);
|
||
modelMap.put("props", propsMap);
|
||
|
||
String graphJsonStr = JSONEncoder.encode(modelMap);
|
||
graphJsonStr = graphJsonStr.replaceAll("\"","\'");
|
||
return graphJsonStr;
|
||
}
|
||
/**
|
||
* 获取jbpm格式的json串
|
||
* @param tx,flowNo
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
public String getGraphJson(JBOTransaction tx,String flowNo) throws Exception{
|
||
BizObject fc = JBOFactory.getBizObjectManager(FLOW_CATALOG.CLASS_NAME).createQuery("flowno=:flowno ").setParameter("flowno",flowNo).getSingleResult(false);
|
||
String graphJsonData="";
|
||
if(fc != null){
|
||
graphJsonData = fc.getAttribute("graphjsondata").getString();
|
||
if(graphJsonData ==null || graphJsonData.equals("")){
|
||
List<BizObject> fms = JBOFactory.getBizObjectManager(FLOW_MODEL.CLASS_NAME).createQuery("flowno=:flowno ")
|
||
.setParameter("flowno", flowNo).getResultList(false);
|
||
if(fms.size()>0){
|
||
graphJsonData = getModel(tx,flowNo);
|
||
}
|
||
}
|
||
}
|
||
return graphJsonData;
|
||
}
|
||
/**
|
||
* 发布流程
|
||
* @param tx
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
public String publishFlow(JBOTransaction tx) throws Exception{
|
||
String result = "fail";
|
||
BizObjectManager fcManager = JBOFactory.getBizObjectManager(FLOW_CATALOG.CLASS_NAME);
|
||
tx.join(fcManager);
|
||
BizObject fc = fcManager.createQuery("flowno=:flowno ").setParameter("flowno",flowNo).getSingleResult(false);
|
||
BizObjectManager fmManager = JBOFactory.getBizObjectManager(FLOW_MODEL.CLASS_NAME);
|
||
tx.join(fmManager);
|
||
List<BizObject> fms = fmManager.createQuery("flowno=:flowno ").setParameter("flowno", flowNo).getResultList(false);
|
||
if(fms.size()==0){
|
||
String graphJson = fc.getAttribute("graphjsondata").getString();
|
||
JSONObject jsonObj = JSONDecoder.decode(graphJson);
|
||
JSONObject states = (JSONObject)jsonObj.getValue("states");
|
||
JSONObject paths = (JSONObject)jsonObj.getValue("paths");
|
||
Map<String,Map<String,String>> rect_phaseno_type = new HashMap<String,Map<String,String>>();
|
||
Map<String,Map<String,String>> rect_phaseno_specialtype = new HashMap<String,Map<String,String>>();
|
||
for(int i=0; i<states.size(); i++){
|
||
String key = states.get(i).getName();
|
||
JSONObject rect = (JSONObject)states.getValue(i);
|
||
newFlowModel(tx,rect,key,rect_phaseno_type,rect_phaseno_specialtype);
|
||
}
|
||
if(!rect_phaseno_specialtype.isEmpty()){
|
||
for(int i=0;i<paths.size(); i++){//在并行情况下，改变分支前一节点的nodetype和改变合并后一节点的nodetype
|
||
JSONObject path = (JSONObject)paths.getValue(i);
|
||
String from = (String)path.getValue("from");
|
||
String to = (String)path.getValue("to");
|
||
if(rect_phaseno_specialtype.containsKey(to) && rect_phaseno_specialtype.get(to).get("nodetype").equalsIgnoreCase("fork")){
|
||
String fromPhaseNo = rect_phaseno_type.get(from).get("phaseno");
|
||
String toNodeType = rect_phaseno_specialtype.get(to).get("nodetype");
|
||
BizObjectQuery bq = fmManager.createQuery("UPDATE O SET nodetype=:nodetype WHERE phaseno=:phaseno and flowno=:flowno ");
|
||
bq.setParameter("nodetype",toNodeType.toUpperCase());
|
||
bq.setParameter("phaseno",fromPhaseNo);
|
||
bq.setParameter("flowno",flowNo);
|
||
bq.executeUpdate();
|
||
}else if(rect_phaseno_specialtype.containsKey(from) && rect_phaseno_specialtype.get(from).get("nodetype").equalsIgnoreCase("join")){
|
||
String toPhaseNo = rect_phaseno_type.get(to).get("phaseno");
|
||
String fromNodeType = rect_phaseno_specialtype.get(from).get("nodetype");
|
||
BizObjectQuery bq = fmManager.createQuery("UPDATE O SET nodetype=:nodetype WHERE phaseno=:phaseno and flowno=:flowno ");
|
||
bq.setParameter("nodetype",fromNodeType.toUpperCase());
|
||
bq.setParameter("phaseno",toPhaseNo);
|
||
bq.setParameter("flowno",flowNo);
|
||
bq.executeUpdate();
|
||
}
|
||
}
|
||
}
|
||
BizObjectQuery bq = fcManager.createQuery("UPDATE O SET flowstate=:flowstate WHERE flowno=:flowno ");
|
||
bq.setParameter("flowno", flowNo);
|
||
bq.setParameter("flowstate","publish");
|
||
bq.executeUpdate();
|
||
result = "success";
|
||
}
|
||
return result;
|
||
}
|
||
|
||
/**
|
||
* 同步流程
|
||
* @param tx
|
||
* @param flowNo
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
public String syncFlow(JBOTransaction tx) throws Exception{
|
||
String result = "fail";
|
||
BizObjectManager fcManager = JBOFactory.getBizObjectManager(FLOW_CATALOG.CLASS_NAME);
|
||
tx.join(fcManager);
|
||
BizObject fc = fcManager.createQuery("flowno=:flowno ").setParameter("flowno",flowNo).getSingleResult(false);
|
||
BizObjectManager fmManager = JBOFactory.getBizObjectManager(FLOW_MODEL.CLASS_NAME);
|
||
tx.join(fmManager);
|
||
List<BizObject> oldFlowModels = fmManager.createQuery("flowno=:flowno ").setParameter("flowno",flowNo).getResultList(false);
|
||
Map<String,String> phasenos = new HashMap<String,String>();
|
||
for(BizObject oldFlowModel:oldFlowModels){
|
||
phasenos.put(oldFlowModel.getAttribute("phaseno").getString(), oldFlowModel.getAttribute("phaseno").getString());
|
||
}
|
||
String graphJson = fc.getAttribute("graphjsondata").getString();
|
||
JSONObject jsonObj = JSONDecoder.decode(graphJson);
|
||
JSONObject states = (JSONObject)jsonObj.getValue("states");
|
||
JSONObject paths = (JSONObject)jsonObj.getValue("paths");
|
||
Map<String,Map<String,String>> rect_phaseno_type = new HashMap<String,Map<String,String>>();
|
||
Map<String,Map<String,String>> rect_phaseno_specialtype = new HashMap<String,Map<String,String>>();
|
||
for(int i=0; i<states.size(); i++){
|
||
JSONObject rect = (JSONObject)states.getValue(i);
|
||
String key = states.get(i).getName();
|
||
JSONObject props = (JSONObject)rect.getValue("props");
|
||
JSONObject position = (JSONObject)props.getValue("position");
|
||
String phaseNo = (String)position.getValue("value");
|
||
BizObject fm = fmManager.createQuery("phaseno=:phaseno and flowno=:flowno ").setParameter("phaseno",phaseNo).setParameter("flowno", flowNo).getSingleResult(false);
|
||
if(fm !=null){
|
||
phasenos.remove(phaseNo);
|
||
updateFlowModel(tx,rect,key,rect_phaseno_type,rect_phaseno_specialtype,phaseNo);
|
||
}else{
|
||
newFlowModel(tx,rect,key,rect_phaseno_type,rect_phaseno_specialtype);
|
||
}
|
||
}
|
||
if(!phasenos.isEmpty()){
|
||
Iterator<String> it = phasenos.values().iterator();
|
||
while (it.hasNext()) {
|
||
String exphaseno = it.next();
|
||
fmManager.createQuery("delete from o where phaseno=:phaseno and flowno=:flowno ").setParameter("phaseno",exphaseno).setParameter("flowno", flowNo).executeUpdate();
|
||
}
|
||
}
|
||
if(!rect_phaseno_specialtype.isEmpty()){
|
||
for(int i=0;i<paths.size(); i++){//在并行情况下，改变分支前一节点的nodetype和改变合并后一节点的nodetype
|
||
JSONObject path = (JSONObject)paths.getValue(i);
|
||
String from = (String)path.getValue("from");
|
||
String to = (String)path.getValue("to");
|
||
if(rect_phaseno_specialtype.containsKey(to) && rect_phaseno_specialtype.get(to).get("nodetype").equalsIgnoreCase("fork")){
|
||
String fromPhaseNo = rect_phaseno_type.get(from).get("phaseno");
|
||
String toNodeType = rect_phaseno_specialtype.get(to).get("nodetype");
|
||
BizObjectQuery bq = fmManager.createQuery("UPDATE O SET nodetype=:nodetype WHERE phaseno=:phaseno and flowno=:flowno ");
|
||
bq.setParameter("nodetype",toNodeType.toUpperCase());
|
||
bq.setParameter("phaseno",fromPhaseNo);
|
||
bq.setParameter("flowno",flowNo);
|
||
bq.executeUpdate();
|
||
}else if(rect_phaseno_specialtype.containsKey(from) && rect_phaseno_specialtype.get(from).get("nodetype").equalsIgnoreCase("join")){
|
||
String toPhaseNo = rect_phaseno_type.get(to).get("phaseno");
|
||
String fromNodeType = rect_phaseno_specialtype.get(from).get("nodetype");
|
||
BizObjectQuery bq = fmManager.createQuery("UPDATE O SET nodetype=:nodetype WHERE phaseno=:phaseno and flowno=:flowno ");
|
||
bq.setParameter("nodetype",fromNodeType.toUpperCase());
|
||
bq.setParameter("phaseno",toPhaseNo);
|
||
bq.setParameter("flowno",flowNo);
|
||
bq.executeUpdate();
|
||
}
|
||
}
|
||
}
|
||
BizObjectQuery bq = fcManager.createQuery("UPDATE O SET flowstate=:flowstate WHERE flowno=:flowno ");
|
||
bq.setParameter("flowno", flowNo);
|
||
bq.setParameter("flowstate","synchronized");
|
||
bq.executeUpdate();
|
||
result = "success";
|
||
return result;
|
||
}
|
||
/**
|
||
* 更新flowModel
|
||
* @param tx
|
||
* @param rect
|
||
* @param phaseNo
|
||
* @throws Exception
|
||
*/
|
||
public void updateFlowModel(JBOTransaction tx,JSONObject rect,String key, Map<String,Map<String,String>> rect_phaseno_type,Map<String,Map<String,String>> rect_phaseno_specialtype, String phaseNo)throws Exception{
|
||
BizObjectManager fcManager = JBOFactory.getBizObjectManager(FLOW_CATALOG.CLASS_NAME);
|
||
tx.join(fcManager);
|
||
BizObjectManager fmManager = JBOFactory.getBizObjectManager(FLOW_MODEL.CLASS_NAME);
|
||
tx.join(fmManager);
|
||
JSONObject text = (JSONObject)rect.getValue("text");
|
||
String type = (String)rect.getValue("type");
|
||
String phaseName = (String)text.getValue("text");
|
||
String phaseType = "";
|
||
String initScript = "";
|
||
String nodeType ="";
|
||
if(phaseNo==null) phaseNo="";
|
||
if(!type.equalsIgnoreCase("start")){//开始符号不涉及逻辑，忽略
|
||
if(type.equalsIgnoreCase("exclusive")||type.equalsIgnoreCase("join")||type.equalsIgnoreCase("fork")){//分支，并行作为特殊符号，不需加在flow_model
|
||
Map<String,String> rect_type = new HashMap<String,String>();
|
||
rect_type.put("nodetype", type);
|
||
rect_type.put("phaseno", phaseNo);
|
||
rect_phaseno_specialtype.put(key,rect_type);
|
||
}else{
|
||
Map<String,String> rect_type = new HashMap<String,String>();
|
||
rect_type.put("nodetype", type);
|
||
rect_type.put("phaseno", phaseNo);
|
||
rect_phaseno_type.put(key,rect_type);
|
||
if(phaseNo.equals("0010")){
|
||
phaseType = "1010";
|
||
initScript = "{#UserID}";
|
||
nodeType = "TASK";
|
||
}else if(phaseNo.equals("1000")){
|
||
phaseType = "1040";
|
||
initScript = "{\"system\"}";
|
||
nodeType = "END";
|
||
}else if(phaseNo.equals("8000")){
|
||
phaseType = "1050";
|
||
initScript = "{\"system\"}";
|
||
nodeType = "END";
|
||
}else{
|
||
phaseType = "1020";
|
||
initScript = "toStringArray(\"#PhaseAction\",\",\",\" \",1)";
|
||
nodeType = "TASK";
|
||
}
|
||
JSONObject attr = (JSONObject)rect.getValue("attr");
|
||
Integer xcoordinate =(Integer)attr.getValue(0);
|
||
Integer ycoordinate = (Integer)attr.getValue(1);
|
||
Integer width = (Integer)attr.getValue(2);
|
||
Integer height = (Integer)attr.getValue(3);
|
||
BizObjectQuery bq = fmManager.createQuery("UPDATE O SET phaseno=:phaseno, phasetype=:phasetype, phasename=:phasename, initscript=:initscript, xcoordinate=:xcoordinate, ycoordinate=:ycoordinate, width=:width, height=:height, nodetype=:nodetype WHERE phaseno=:phaseno and flowno=:flowno");
|
||
bq.setParameter("phaseno", phaseNo).setParameter("phasetype", phaseType).setParameter("phasename", phaseName).setParameter("initscript", initScript)
|
||
.setParameter("xcoordinate", xcoordinate).setParameter("ycoordinate", ycoordinate).setParameter("width", width).setParameter("height", height).setParameter("nodetype", nodeType).setParameter("flowno",flowNo);
|
||
bq.executeUpdate();
|
||
}
|
||
}
|
||
}
|
||
/**
|
||
* 新建flow_model
|
||
* @param tx
|
||
* @param rect
|
||
* @param phaseNo
|
||
* @throws Exception
|
||
*/
|
||
public void newFlowModel(JBOTransaction tx,JSONObject rect,String key, Map<String,Map<String,String>> rect_phaseno_type,Map<String,Map<String,String>> rect_phaseno_specialtype)throws Exception{
|
||
BizObjectManager fcManager = JBOFactory.getBizObjectManager(FLOW_CATALOG.CLASS_NAME);
|
||
tx.join(fcManager);
|
||
BizObjectManager fmManager = JBOFactory.getBizObjectManager(FLOW_MODEL.CLASS_NAME);
|
||
tx.join(fmManager);
|
||
BizObject newFm = fmManager.newObject();
|
||
String type = (String)rect.getValue("type");
|
||
JSONObject text = (JSONObject)rect.getValue("text");
|
||
String phaseName = (String)text.getValue("text");
|
||
String phaseType = "";
|
||
String initScript = "";
|
||
String nodeType ="";
|
||
|
||
JSONObject props = (JSONObject)rect.getValue("props");
|
||
JSONObject position = (JSONObject)props.getValue("position");
|
||
String phaseNo = (String)position.getValue("value");
|
||
if(phaseNo==null) phaseNo="";
|
||
if(!type.equalsIgnoreCase("start")){//开始符号不涉及逻辑，忽略
|
||
if(type.equalsIgnoreCase("exclusive")||type.equalsIgnoreCase("join")||type.equalsIgnoreCase("fork")){//分支，并行作为特殊符号，不需加在flow_model
|
||
Map<String,String> rect_type = new HashMap<String,String>();
|
||
rect_type.put("nodetype", type);
|
||
rect_type.put("phaseno", phaseNo);
|
||
rect_phaseno_specialtype.put(key,rect_type);
|
||
}else{
|
||
Map<String,String> rect_type = new HashMap<String,String>();
|
||
rect_type.put("nodetype", type);
|
||
rect_type.put("phaseno", phaseNo);
|
||
rect_phaseno_type.put(key,rect_type);
|
||
if(phaseNo.equals("0010")){
|
||
phaseType = "1010";
|
||
initScript = "{#UserID}";
|
||
nodeType = "TASK";
|
||
}else if(phaseNo.equals("1000")){
|
||
phaseType = "1040";
|
||
initScript = "{\"system\"}";
|
||
nodeType = "END";
|
||
}else if(phaseNo.equals("8000")){
|
||
phaseType = "1050";
|
||
initScript = "{\"system\"}";
|
||
nodeType = "END";
|
||
}else{
|
||
phaseType = "1020";
|
||
initScript = "toStringArray(\"#PhaseAction\",\",\",\" \",1)";
|
||
nodeType = "TASK";
|
||
}
|
||
JSONObject attr = (JSONObject)rect.getValue("attr");
|
||
Integer xcoordinate =(Integer)attr.getValue(0);
|
||
Integer ycoordinate = (Integer)attr.getValue(1);
|
||
Integer width = (Integer)attr.getValue(2);
|
||
Integer height = (Integer)attr.getValue(3);
|
||
|
||
int standardtime1 = 0;
|
||
int standardtime2 = 0;
|
||
if(nodeType.equals("END")){
|
||
newFm.setAttributeValue("flowno", flowNo).setAttributeValue("phaseno", phaseNo).setAttributeValue("phasetype", phaseType).setAttributeValue("phasename", phaseName)
|
||
.setAttributeValue("initscript", initScript).setAttributeValue("standardtime1", standardtime1).setAttributeValue("standardtime2", standardtime2)
|
||
.setAttributeValue("xcoordinate", xcoordinate).setAttributeValue("ycoordinate", ycoordinate).setAttributeValue("width", width).setAttributeValue("height", height).setAttributeValue("nodetype", nodeType).setAttributeValue("version", "1");
|
||
}else{
|
||
newFm.setAttributeValue("flowno", flowNo).setAttributeValue("phaseno", phaseNo).setAttributeValue("phasetype", phaseType).setAttributeValue("phasename", phaseName)
|
||
.setAttributeValue("initscript", initScript).setAttributeValue("standardtime1", standardtime1).setAttributeValue("standardtime2", standardtime2).setAttributeValue("postscript", "#PhaseOpinion1")
|
||
.setAttributeValue("xcoordinate", xcoordinate).setAttributeValue("ycoordinate", ycoordinate).setAttributeValue("width", width).setAttributeValue("height", height).setAttributeValue("nodetype", nodeType).setAttributeValue("version", "1");
|
||
}
|
||
fmManager.saveObject(newFm);
|
||
}
|
||
}
|
||
}
|
||
/**
|
||
* 获取指定阶段号的坐标
|
||
* @param tx
|
||
* @param flowNo
|
||
* @param flowunid
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
public Map<String,String> getCoordinate(JBOTransaction tx, String flowNo, String flowunid) throws Exception{
|
||
BizObjectManager ftManager = JBOFactory.getBizObjectManager(FLOW_TASK.CLASS_NAME);
|
||
BizObjectManager fmManager = JBOFactory.getBizObjectManager(FLOW_MODEL.CLASS_NAME);
|
||
List<BizObject> fts = ftManager.createQuery("objectno=:objectno and (endtime='' or endtime is null) ").setParameter("objectno",flowunid).getResultList(false);
|
||
Map<String,String> results = new HashMap<String,String>();
|
||
if(fts.size()>0){
|
||
for(BizObject ft:fts){
|
||
String phaseNo = ft.getAttribute("phaseno").getString();
|
||
BizObject fm = fmManager.createQuery("flowno=:flowno and phaseno=:phaseno ").setParameter("flowno",flowNo).setParameter("phaseno",phaseNo).getSingleResult(false);
|
||
String xcoordinate = fm.getAttribute("xcoordinate").getString();
|
||
String ycoordinate = fm.getAttribute("ycoordinate").getString();
|
||
if(xcoordinate.endsWith(".0")){
|
||
xcoordinate=xcoordinate.split("\\.")[0];
|
||
}
|
||
if(ycoordinate.endsWith(".0")){
|
||
ycoordinate=ycoordinate.split("\\.")[0];
|
||
}
|
||
results.put(phaseNo,xcoordinate+'@'+ycoordinate);
|
||
}
|
||
}
|
||
return results;
|
||
}
|
||
/**
|
||
* 保存流程图校验开始下一步，结束，否决的排序号为固定值
|
||
* @param graphJson
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
public String checkFlowGraph(String graphJson) throws Exception{
|
||
String result = "";
|
||
JSONObject jsonObj = JSONDecoder.decode(graphJson);
|
||
JSONObject states = (JSONObject)jsonObj.getValue("states");
|
||
JSONObject paths = (JSONObject)jsonObj.getValue("paths");
|
||
Map<String,String> type_rect = new HashMap<String,String>();
|
||
Map<String,String> rect_phasno = new HashMap<String,String>();
|
||
for(int i=0; i<states.size(); i++){
|
||
JSONObject rect = (JSONObject)states.getValue(i);
|
||
String name = states.get(i).getName();
|
||
String type = (String)rect.getValue("type");
|
||
JSONObject props = (JSONObject)rect.getValue("props");
|
||
JSONObject position = (JSONObject)props.getValue("position");
|
||
String phaseNo = (String)position.getValue("value");
|
||
if(type.equalsIgnoreCase("end")){
|
||
if(!phaseNo.equals("1000")){
|
||
result+="结束步骤排序必须为1000;";
|
||
}
|
||
}else if(type.equalsIgnoreCase("reject")){
|
||
if(!phaseNo.equals("8000")){
|
||
result+="否决步骤排序必须为8000;";
|
||
}
|
||
}else if(type.equalsIgnoreCase("start")){
|
||
type_rect.put(type,name);
|
||
}
|
||
rect_phasno.put(name, phaseNo);
|
||
}
|
||
for(int i=0; i<paths.size(); i++){
|
||
JSONObject path = (JSONObject)paths.getValue(i);
|
||
String startRect = type_rect.get("start");
|
||
String from = (String)path.getValue("from");
|
||
if(from.equalsIgnoreCase(startRect)){
|
||
String to = (String)path.getValue("to");
|
||
String toPhaseNo = rect_phasno.get(to);
|
||
if(!toPhaseNo.equals("0010")){
|
||
result+="开始下一步骤排序必须为0010;";
|
||
return result;
|
||
}else{
|
||
return result;
|
||
}
|
||
}
|
||
}
|
||
return result;
|
||
}
|
||
/**
|
||
* 获取所有除了开始、结束、否决的坐标
|
||
* @param tx
|
||
* @param flowNo
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
public Map<String,String> getCoordinates(JBOTransaction tx, String flowNo) throws Exception{
|
||
BizObjectManager fmManager = JBOFactory.getBizObjectManager(FLOW_MODEL.CLASS_NAME);
|
||
List<BizObject> fms = fmManager.createQuery("flowno=:flowno and nodetype<>'END' ").setParameter("flowno",flowNo).getResultList(false);
|
||
Map<String,String> results = new HashMap<String,String>();
|
||
if(fms.size()>0){
|
||
for(BizObject fm:fms){
|
||
String xcoordinate = fm.getAttribute("xcoordinate").getString();
|
||
String ycoordinate = fm.getAttribute("ycoordinate").getString();
|
||
if(xcoordinate.endsWith(".0")){
|
||
xcoordinate=xcoordinate.split("\\.")[0];
|
||
}
|
||
if(ycoordinate.endsWith(".0")){
|
||
ycoordinate=ycoordinate.split("\\.")[0];
|
||
}
|
||
results.put(fm.getAttribute("phaseno").getString(),xcoordinate+'@'+ycoordinate);
|
||
}
|
||
}
|
||
return results;
|
||
}
|
||
} |