package com.vci.test.qttest;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
|
import com.vci.common.qt.object.Condition;
|
import com.vci.common.qt.object.ConditionItem;
|
import com.vci.common.qt.object.LeafInfo;
|
import com.vci.common.qt.object.LeafValue;
|
import com.vci.common.qt.object.Operator;
|
import com.vci.common.qt.object.QTConstants;
|
import com.vci.common.qt.object.QueryTemplate;
|
import com.vci.corba.common.VCIError;
|
import com.vci.corba.omd.atm.AttribItem;
|
import com.vci.corba.omd.btm.BtmItem;
|
import com.vci.corba.omd.data.BusinessObject;
|
import com.vci.corba.omd.data.LinkObject;
|
import com.vci.omd.objects.OtherInfo;
|
import com.vci.server.base.utility.ServerServiceProvider;
|
import com.vci.server.query.service.QueryObjectService;
|
|
/**
|
* @Title :服务器端QT查询API使用示例
|
* @Description :
|
* @Copyright :宏博远达科技有限公司
|
* @Author :平台与规划部/ZhongGY/E-mail:zhonggy@vci-tech.com
|
* @Date :2015-7-6
|
* @Version :1
|
* @Other :产生注释:Alt+Shift+J
|
*/
|
public class TestQTAPI {
|
/**
|
* 业务对象QT嵌套查询
|
* @Title :testBOQt
|
* @Description :
|
* @return
|
*/
|
public static BusinessObject[] testBOQt() {
|
//主查询QT对象
|
QueryTemplate qt = new QueryTemplate();
|
//QT临时Id
|
qt.setId("qt1");
|
//业务类型查询
|
qt.setType(QTConstants.TYPE_BTM);
|
//查询的业务类型
|
qt.setBtmType("part");
|
qt.setQueryChildrenFlag(true);//true表示查询子孙业务类型
|
//qt.setVersion(？);//业务对象版本规则（最新版本版次、最新发布版本?）
|
//查询列
|
List<String> clauseList = new ArrayList<String>();
|
//默认查询返回所有列
|
clauseList.add("*");
|
qt.setClauseList(clauseList);
|
//查询条件（条件中可嵌套QT对象）
|
Condition con = new Condition();
|
qt.setCondition(con);//设置查询条件
|
HashMap<String, ConditionItem> ciMap = new HashMap<String, ConditionItem>();
|
//查询条件项
|
ConditionItem ci = new ConditionItem();
|
ci.setId("test1");
|
ci.setLeafFlag(true);
|
LeafInfo leafInfo = new LeafInfo();
|
leafInfo.setClause("ownproduct");//查询条件属性
|
leafInfo.setOperator(Operator.IN);//查询条件操作符（IN 中可嵌套QT对象）
|
//嵌套查询QT对象
|
QueryTemplate qtse = getRefQT("ownproduct", "code", "=", "test");
|
LeafValue lValue = new LeafValue();//查询条件值
|
lValue.setQueryTemplate(qtse);//查询条件值可嵌套QT对象
|
leafInfo.setValue(lValue);//设置查询条件值
|
ci.setLeafInfo(leafInfo);//查询条件项
|
ciMap.put(ci.getId(), ci);//设置查询条件项（通过集合可设置多查询条件项）
|
con.setCIMap(ciMap);//QT查询条件定义
|
con.setRootCIName(con.getRootCINameByCIMap(ciMap));
|
List<BusinessObject> result = null;
|
try {
|
//执行查询
|
try {
|
result = QueryObjectService.getInstance().findBtmObjects(qt);
|
} catch (Throwable e) {
|
}
|
if(qt.isQueryChildren()){
|
//查询子类型
|
BtmItem[] btms = null;
|
try {
|
btms = ServerServiceProvider.getOMDService().getBTMService().getChildrenBtms(qt.getBtmType());
|
} catch (Exception e) {
|
} catch (Throwable e) {
|
}
|
for(int i = 0; i < btms.length; i++){
|
qt.setBtmType(btms[i].name);
|
try {
|
result.addAll(QueryObjectService.getInstance().findBtmObjects(qt));
|
} catch (Throwable e) {
|
}
|
}
|
}
|
return result.toArray(new BusinessObject[0]);
|
} catch (Throwable e) {
|
}
|
return new BusinessObject[]{};
|
|
}
|
|
/**
|
* @Title :构建嵌套查询模板
|
* @Description :
|
* @param refAbName：参照属性名称
|
* @param clause：查询条件项属性
|
* @param operator：查询条件项操作
|
* @param ordinaryValue：查询条件项值
|
* @return
|
*/
|
private static QueryTemplate getRefQT(String refAbName, String clause,
|
String operator, String ordinaryValue) {
|
QueryTemplate qt = new QueryTemplate();
|
try {
|
List<String> clauseList = new ArrayList<String>();
|
clauseList.add("OID");
|
qt.setClauseList(clauseList);
|
// 根据refAbName获取业务类型
|
AttribItem refAb;
|
refAb = ServerServiceProvider.getOMDService().getAttributeService().getAttribItemByName(refAbName);
|
OtherInfo otherInfo = OtherInfo.getOtherInfoByText(refAb.other);
|
int refFlag = otherInfo.getRefFlag();
|
String type = otherInfo.getRefTypeName();
|
if (refFlag == 0) {
|
qt.setType(QTConstants.TYPE_BTM);
|
qt.setBtmType(type);
|
} else if (refFlag == 1) {
|
qt.setType(QTConstants.TYPE_LINK);
|
qt.setLinkType(type);
|
}
|
Condition condition = new Condition();
|
qt.setCondition(condition);
|
condition.setRootCIName("ci1");
|
HashMap<String, ConditionItem> ciMap = new HashMap<String, ConditionItem>();
|
condition.setCIMap(ciMap);
|
ConditionItem ci = new ConditionItem();
|
ci.setId("ci1");
|
ciMap.put(ci.getId(), ci);
|
ci.setLeafFlag(true);
|
LeafInfo leafInfo = new LeafInfo();
|
if (clause.contains(".")) {
|
int fpIndex = clause.indexOf(".");
|
String refAbName_ = clause.substring(0, fpIndex);
|
clause = clause.substring(fpIndex + 1);
|
leafInfo.setClause(refAbName_);
|
leafInfo.setOperator(Operator.IN);
|
QueryTemplate qt_ = getRefQT(refAbName_, clause, operator, ordinaryValue);
|
LeafValue lValue = new LeafValue();
|
lValue.setQueryTemplate(qt_);
|
leafInfo.setValue(lValue);
|
qt.setId("qt_" + refAbName + "_" + refAbName_);
|
} else {
|
leafInfo.setClause(clause);
|
leafInfo.setOperator(operator);
|
LeafValue lValue = new LeafValue();
|
lValue.setOrdinaryValue(ordinaryValue);
|
leafInfo.setValue(lValue);
|
qt.setId("qt_" + refAbName + "_" + clause);
|
}
|
ci.setLeafInfo(leafInfo);
|
condition.setCIMap(ciMap);
|
} catch (VCIError e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return qt;
|
}
|
|
public static void main(String[] args) {
|
// System.err.println(testBOQt().length);
|
System.err.println(testLinkQt().length);
|
}
|
|
/**
|
* @Title :多链接类型（嵌套）查询示例：获取某产品下所有子孙零部件对象 [产品to根零部件link关系 + ebom关系]
|
* @Description :
|
* @return
|
*/
|
private static LinkObject[] testLinkQt() {
|
// 主查询模板对象
|
QueryTemplate qt = new QueryTemplate(); //示例ebom关系
|
qt.setId("qt1");
|
qt.setType(QTConstants.TYPE_LINK);
|
qt.setLinkType("ebom");
|
//设置正反向查询
|
//qt.setDirection("positiva");
|
qt.setBtmType("part");
|
//qt.setBtmType("*");//也支持所有业务类型查询
|
//设置查询多少层
|
qt.setLevel(5);
|
List<String> clauseList = new ArrayList<String>();
|
//查询列
|
clauseList.add("*");
|
qt.setClauseList(clauseList);
|
Condition con = new Condition();
|
qt.setCondition(con);
|
HashMap<String, ConditionItem> ciMap = new HashMap<String, ConditionItem>();
|
//设置嵌套查询条件
|
ConditionItem ci = new ConditionItem();
|
ci.setId("test1");
|
ci.setLeafFlag(true);
|
LeafInfo leafInfo = new LeafInfo();
|
leafInfo.setClause("f_oid");
|
leafInfo.setOperator(Operator.IN);
|
LeafValue lValue = new LeafValue();
|
leafInfo.setValue(lValue);
|
try {
|
//获取嵌套条件的查询模板
|
/*QTWrapper qtm = QTClient.getService().getQT("productTreeQueryTemplate");
|
String qtText = qtm.qtText;
|
QueryTemplate qt_ = Tool.getQTByQTText(qtm.qtName, qtText);*/
|
QueryTemplate qt_ = new QueryTemplate(); //示例"产品to根零部件link关系"
|
//TODO:构件一个查询模板对象qt_
|
|
List<String> clauseListse = new ArrayList<String>();
|
clauseListse.add("t_oid");
|
qt_.setClauseList(clauseListse);
|
lValue.setQueryTemplate(qt_);//设置嵌套查询模板对象
|
} catch (Throwable e) {
|
}
|
ci.setLeafInfo(leafInfo);
|
ciMap.put(ci.getId(), ci);
|
con.setCIMap(ciMap);
|
con.setRootCIName(con.getRootCINameByCIMap(ciMap));
|
List<LinkObject> result = null;
|
try {
|
/*
|
* result = QTClient.getService().findLTObjects(qt.getId(),
|
* Tool.qtTOXMl(qt).asXML()); QueryResultDialog dialog = new
|
* QueryResultDialog(result, qt.getClauseList());
|
* dialog.setVisible(true);
|
*/
|
// 执行查询
|
// 查询一层, 分查询是否有有下一级和不查询是否有有下一级
|
if (qt.getLevel() == 1) {
|
try {
|
result = QueryObjectService.getInstance().findLinkObjectOneLevel(qt);
|
} catch (Throwable e) {
|
}
|
// 查询多层, 或者没有层数限制
|
} else {
|
try {
|
result = QueryObjectService.getInstance().findLinkObject(qt);
|
} catch (Throwable e) {
|
}
|
int recReturnMode = qt.getRecReturnMode();
|
// 对查询结果进行过滤
|
if (recReturnMode == QTConstants.RECRETURNMODE_FILTER) {
|
result = QueryObjectService.getInstance().filterLos(result);
|
}
|
}
|
return result.toArray(new LinkObject[0]);
|
} catch (Throwable e) {
|
}
|
return new LinkObject[]{};
|
}
|
}
|
