package com.vci.client.uif.engine.common;
|
|
import java.util.Arrays;
|
import java.util.HashMap;
|
import java.util.Iterator;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Map;
|
|
import com.vci.client.common.oq.OQTool;
|
import com.vci.common.qt.object.Condition;
|
import com.vci.common.qt.object.Connector;
|
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.query.ObjectQueryServicePrx;
|
|
/**
|
* UIFUtils 通用接口基类
|
* @author xiongchao
|
*
|
*/
|
public abstract class UIFUtilsCommon {
|
public UIFUtilsCommon(){
|
|
}
|
|
protected final int IN_MAX_COUNT = 900;
|
public abstract ObjectQueryServicePrx getQTService() throws VCIError;
|
|
/**
|
* 批量查询BO
|
* @param btmName BO业务类型
|
* @param conditionMap 过滤条件
|
* <p>key:要过滤的属性字段（内部名称）</p>
|
* <p>value:过滤值</p>
|
* @return
|
* @throws VCIError
|
*/
|
public BusinessObject[] getBusinessObject(
|
String btmName, Map<String, List<String>> conditionMap) throws VCIError{
|
QueryTemplate qt = getBtmQueryTemplate(btmName);
|
Iterator<String> its = conditionMap.keySet().iterator();
|
Condition condition = new Condition();
|
while(its.hasNext()){
|
String key = its.next();
|
List<String> values = conditionMap.get(key);
|
Condition cond = new Condition();
|
if(values.size() < IN_MAX_COUNT){
|
cond = getSingleCondition(key, values);
|
} else if(values.size() >= IN_MAX_COUNT){
|
cond = getMergedCondition(key, values);
|
}
|
condition = OQTool.mergeCondition(cond, condition, Connector.AND);
|
}
|
return getBusinessObject(qt, condition);
|
}
|
|
/**
|
* 返回单一in形式的过滤条件
|
* @param key 属性内部名称
|
* @param values 过滤条件值
|
* @return
|
*/
|
private Condition getSingleCondition(String key, List<String> values){
|
StringBuffer sb = new StringBuffer();
|
int size = values.size();
|
for (int i = 0; i < size;i++) {
|
sb.append("'").append(values.get(i)).append("'");
|
if(i != size - 1){
|
sb.append(",");
|
}
|
}
|
String value = sb.toString();
|
if(value.endsWith(",")){
|
value = value.substring(0, value.length() - 1);
|
}
|
if("".equals(value)){
|
value = "''";
|
}
|
Map<String, String> map = new HashMap<String, String>();
|
map.put(key, "\\IN(" + value + ")");
|
return OQTool.getCondition(map);
|
}
|
|
/**
|
* 返回合并后的过滤条件
|
* @param key 属性内部名称
|
* @param values 过滤条件值
|
* @return
|
*/
|
private Condition getMergedCondition(String key, List<String> values){
|
int size = values.size();
|
int sp = size / IN_MAX_COUNT;
|
int spx = size % IN_MAX_COUNT;
|
int loopCount = sp + (spx == 0 ? 0 : 1);
|
Condition condition = new Condition();
|
for (int i = 1; i <= loopCount; i++) {
|
Condition cond = getSingleCondition(key,
|
splitList(values,((i - 1) * IN_MAX_COUNT), (i * IN_MAX_COUNT - 1))
|
);
|
condition = OQTool.mergeCondition(cond, condition, Connector.OR);
|
}
|
return condition;
|
}
|
|
/**
|
* 截取list
|
* @param srcList 源列表
|
* @param start 开始索引
|
* @param end 结束索引
|
* @return 截取后的list
|
*/
|
private List<String> splitList(List<String> srcList, int start, int end){
|
List<String> list = new LinkedList<String>();
|
int size = srcList.size();
|
for (int i = start; i <= end && i <= size - 1; i++) {
|
list.add(srcList.get(i));
|
}
|
return list;
|
}
|
|
|
/**
|
* 返回查询指定业务类型的查询模板
|
* @param btmName 业务类型名称
|
* @param version
|
* @return 查询模板基础结构
|
*/
|
public QueryTemplate getBtmQueryTemplate(String btmName, int version){
|
QueryTemplate qt = new QueryTemplate();
|
qt.setId("qt");
|
qt.setType("btm");
|
qt.setBtmType(btmName);
|
qt.setVersion(version);
|
qt.setClauseList(Arrays.asList(new String[]{"*"}));
|
// 忽略对象的数据权限检查
|
qt.setRightFlag(false);
|
qt.setQueryChildrenFlag(true);
|
return qt;
|
}
|
|
/**
|
* 返回查询指定业务类型的查询模板
|
* @param btmName 业务类型名称
|
* @return 查询模板基础结构
|
*/
|
public QueryTemplate getBtmQueryTemplate(String btmName){
|
return getBtmQueryTemplate(btmName, Version.lastRevLastVer);
|
}
|
|
/**
|
* 单一查询BO
|
* @param qt 查询模板对象
|
* @param conditionMap 标准简单过滤条件
|
* @return 满足条件的BO
|
* @throws VCIError
|
*/
|
public BusinessObject[] getBusinessObject(QueryTemplate qt, Map<String, String> conditionMap) throws VCIError{
|
return getBusinessObject(qt, OQTool.getCondition(conditionMap));
|
}
|
|
/**
|
* 根据查询模板、查询条件返回数据
|
* @param qt 查询模板对象
|
* @param condition 查询条件对象
|
* @return 满足条件的BO
|
* @throws VCIError
|
*/
|
public BusinessObject[] getBusinessObject(QueryTemplate qt, Condition condition) throws VCIError{
|
qt.setCondition(condition);
|
return getQTService().findBTMObjects(qt.getId(), OQTool.qtTOXMl(qt).asXML());
|
}
|
}
|
