package com.vci.client.portal.utility;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.Iterator;
|
import java.util.LinkedHashMap;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.dom4j.DocumentException;
|
import org.dom4j.DocumentHelper;
|
|
import com.vci.corba.query.data.RefPath;
|
import com.vci.omd.utils.ObjectTool;
|
import com.vci.client.common.oq.OQTool;
|
import com.vci.client.common.providers.ServiceProvider;
|
import com.vci.client.oq.QTClient;
|
import com.vci.client.oq.QTDClient;
|
import com.vci.client.portal.custom.ICustomDefine;
|
import com.vci.common.qt.object.Condition;
|
import com.vci.common.qt.object.Connector;
|
import com.vci.common.qt.object.OrderInfo;
|
import com.vci.common.qt.object.PageInfo;
|
import com.vci.common.qt.object.QueryTemplate;
|
import com.vci.corba.common.VCIError;
|
import com.vci.corba.omd.data.BusinessObject;
|
import com.vci.corba.omd.qtm.QTInfo;
|
|
public class TableDataUtilNew extends TableDataUtil {
|
|
/**
|
* 查询业务对象的详细信息
|
* @param qtName， 查询模版
|
* @param replaceMap， 替换map
|
* @param conditionMap， 附加条件
|
* @param pageInfo， 翻页信息
|
* @param orderInfos， 排序信息
|
* @param showType， 显示类型
|
* @param queryColumnsMap， 查询列, key为查询列名，value为显示名称
|
* @param customMap， 自定义列
|
* @return
|
* @throws VCIError
|
* @throws DocumentException
|
*/
|
public List<Map<String, String>> getNewObjectDataList(String qtName, Map<String, String> replaceMap,
|
Map<String, List<String>> conditionMap, PageInfo pageInfo, List<OrderInfo> orderInfos, String showType,
|
Map<String, String> queryColumnsMap, Map<String, PRMItem> customMap, Map<String, PRMItem> fileMap) throws VCIError {
|
DataModelProcessor processor = new DataModelProcessor();
|
BusinessObject[] objs = getNewBusinessObjectByQueryTemplate(qtName, replaceMap, conditionMap, pageInfo, orderInfos);
|
List<Map<String, String>> datas = getObjectDataSecondList(processor, objs, showType, queryColumnsMap);
|
if (customMap != null && customMap.size() > 0) {
|
getCustomValue(customMap, datas);
|
}
|
if (fileMap != null && fileMap.size() > 0) {
|
getFileColValue(fileMap, datas);
|
}
|
return datas;
|
}
|
|
public BusinessObject[] getNewBusinessObjectByQueryTemplate(String queryTemplate, Map<String, String> replaceMap, Map<String, List<String>> conditionMap, PageInfo pageInfo, List<OrderInfo> orderInfos) throws VCIError {
|
BusinessObject[] v = null;
|
try
|
{
|
QueryTemplate qt_ = getNewCustomQt(queryTemplate, replaceMap, conditionMap, pageInfo, orderInfos);
|
v = QTClient.getService().findBTMObjects(qt_.getId(), OQTool.qtTOXMl(qt_).asXML());
|
}
|
catch(VCIError vcie)
|
{
|
throw vcie;
|
}
|
catch(java.lang.Exception se)
|
{
|
VCIError vcierror = new VCIError("",new String[]{se.getMessage()});
|
throw vcierror;
|
}
|
return v;
|
}
|
|
private QueryTemplate getNewCustomQt(String queryTemplate, Map<String, String> replaceMap, Map<String, List<String>> conditionMap, PageInfo pageInfo, List<OrderInfo> orderInfos) throws VCIError, DocumentException {
|
QueryTemplate qt_ = null;
|
try
|
{
|
QTInfo wrapper = ServiceProvider.getOMDService().getQTDService().getQT(queryTemplate);
|
QueryTemplate qt = OQTool.getQTByDoc(DocumentHelper.parseText(wrapper.qtText), queryTemplate);
|
qt_ = OQTool.replaceQTValues(qt, replaceMap);
|
if (conditionMap != null && conditionMap.size() > 0) {
|
Iterator<String> itor = conditionMap.keySet().iterator();
|
while (itor.hasNext()) {
|
String key = itor.next();
|
List<String> list = conditionMap.get(key);
|
for (int i = 0; i < list.size(); i++) {
|
Map<String, String> cMap = new HashMap<String, String>();
|
cMap.put(key, list.get(i));
|
Condition condition = OQTool.getCondition(cMap);
|
Condition mergeCondition = OQTool.mergeCondition(qt_.getCondition(), condition, Connector.AND);
|
qt_.setCondition(mergeCondition);
|
}
|
}
|
}
|
if(pageInfo != null){
|
qt_.setPageInfo(pageInfo);
|
}
|
if(orderInfos != null){
|
qt_.setOrderInfoList(orderInfos);
|
}
|
}
|
catch(VCIError vcie)
|
{
|
throw vcie;
|
}
|
catch(java.lang.Exception se)
|
{
|
VCIError vcierror = new VCIError("",new String[]{se.getMessage()});
|
throw vcierror;
|
}
|
return qt_;
|
}
|
|
/**
|
* 获取业务对象二次查询的结果
|
* @param processor
|
* @param objs， 业务对象
|
* @param showType， 显示类型
|
* @param formColumnsMap,key为内部主键，value为显示名称（在此过程中暂不使用，可以传入空值）
|
*/
|
private List<Map<String, String>> getObjectDataSecondList(
|
DataModelProcessor processor,
|
BusinessObject[] objs, String showType,
|
Map<String, String> queryColumnsMap){
|
@SuppressWarnings("unchecked")
|
Map<String, String>[] res = new LinkedHashMap[0];
|
res = CBOHelper.getBOValueMap(objs);
|
Map<String, List<String>> referenceKeyMap = processor.getReferenceCol(queryColumnsMap);
|
if (referenceKeyMap != null && referenceKeyMap.size() > 0) {
|
Iterator<String> referenceKey = referenceKeyMap.keySet().iterator();
|
List<String> referenceList = new LinkedList<String>();
|
while (referenceKey.hasNext()) {
|
referenceList.add(referenceKey.next());
|
}
|
Map<String, Map<String, String>> rowRefMap = new LinkedHashMap<String, Map<String, String>>();
|
Map<String, Boolean> emptyCheckMap = new LinkedHashMap<String, Boolean>();
|
for (BusinessObject obj : objs) {
|
String boOid = obj.oid;
|
Map<String, String> refMap = new LinkedHashMap<String, String>();
|
for (int j = 0; j < referenceList.size(); j++) {
|
String refKey = referenceList.get(j);
|
String refVal = ObjectTool.getBOAttributeValue(obj, refKey);
|
if (refVal == null) {
|
refVal = "";
|
emptyCheckMap.put(refVal, true);
|
} else {
|
emptyCheckMap.put(refKey, false);
|
}
|
refMap.put(refKey, refVal);
|
}
|
rowRefMap.put(boOid, refMap);
|
}
|
|
Map<String, String> emptyMap = new HashMap<String, String>();
|
Iterator<String> emptyCheckItor = emptyCheckMap.keySet().iterator();
|
List<String> delKeyList = new ArrayList<String>();
|
while (emptyCheckItor.hasNext()) {
|
String emptyCheckKey = emptyCheckItor.next();
|
boolean emptyCheckVal = emptyCheckMap.get(emptyCheckKey);
|
if (!emptyCheckVal) {
|
continue;
|
}
|
List<String> list = referenceKeyMap.get(emptyCheckKey);
|
emptyMap.put(emptyCheckKey, "");
|
for (int j = 0; j < list.size(); j++) {
|
emptyMap.put(list.get(j), "");
|
}
|
referenceKeyMap.remove(emptyCheckKey);
|
delKeyList.add(emptyCheckKey);
|
}
|
if (delKeyList.size() > 0) {
|
Iterator<String> itor = rowRefMap.keySet().iterator();
|
while (itor.hasNext()) {
|
Map<String, String> crowMap = rowRefMap.get(itor.next());
|
for (int i = 0; i < delKeyList.size(); i++) {
|
crowMap.remove(delKeyList.get(i));
|
}
|
}
|
}
|
|
Map<String, String> secQueryMap = processor.getQueryBusinessObjectCondition(showType, rowRefMap, referenceKeyMap);
|
RefPath[] refPaths = processor.queryReference(secQueryMap, showType);
|
connectSecondQueryResult(res, refPaths, secQueryMap, referenceKeyMap);
|
}
|
|
List<Map<String, String>> listRes = new LinkedList<Map<String, String>>();
|
for (Map<String, String> resMap : res) {
|
listRes.add(resMap);
|
}
|
return listRes;
|
}
|
|
/**
|
* 将二次查询结果拼接到一次查询结果中
|
* @param res
|
* @param refPaths
|
* @param secQueryMap
|
* @param referenceKeyMap
|
*/
|
private void connectSecondQueryResult(Map<String, String>[] res, RefPath[] refPaths, Map<String, String> secQueryMap, Map<String, List<String>> referenceKeyMap) {
|
if (refPaths != null) {
|
int colNum = secQueryMap.size();
|
for (int i = 0; i < res.length; i++) {
|
Map<String, String> rowVal = res[i];
|
for (int j = 0; j < colNum; j++) {
|
String key = secQueryMap.keySet().toArray(new String[colNum])[j];
|
if (referenceKeyMap.containsKey(key)) {
|
continue;
|
}
|
if (refPaths[j].values.length <= i) {
|
continue;
|
}
|
String cVal = refPaths[j].values[i].value;
|
rowVal.put(secQueryMap.keySet().toArray(new String[colNum])[j], cVal);
|
}
|
}
|
}
|
}
|
|
/**
|
* 获取自定义列的值
|
* @param customMap, 自定义查询列
|
* @param datas, 查询结果
|
* @throws VCIError
|
*/
|
private void getCustomValue(Map<String, PRMItem> customMap, List<Map<String, String>> datas) throws VCIError {
|
Iterator<String> itor = customMap.keySet().iterator();
|
while (itor.hasNext()) {
|
String key = itor.next();
|
PRMItem prm = customMap.get(key);
|
String customCls = prm.getItemCustomClass();
|
if(customCls == null || "".equals(customCls)){
|
continue;
|
}
|
executeSetCustomValue(customCls, key, customMap, datas);
|
}
|
}
|
|
/**
|
* 执行自定义列类获取具体的值
|
* @param customCls， 自定义类
|
* @param key， 自定义列主键
|
* @param customMap， 自定义列对应的Map
|
* @param datas， 数据
|
*/
|
private void executeSetCustomValue(String customCls, String key, Map<String, PRMItem> customMap, List<Map<String, String>> datas){
|
try {
|
int paramIndex = customCls.indexOf("?");
|
String param = "";
|
if(paramIndex > 0){
|
param = customCls.substring(paramIndex + 1);
|
customCls = customCls.substring(0, paramIndex);
|
}
|
Class<?> cls = Class.forName(customCls);
|
ICustomDefine custom = (ICustomDefine)cls.getConstructor().newInstance();
|
if(param != null && !"".equals(param)){
|
key = key + "?" + param;
|
}
|
custom.getCustomValue(key, customMap, datas);
|
} catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
|
private void getFileColValue(Map<String, PRMItem> fileMap, List<Map<String, String>> datas) throws VCIError {
|
try {
|
Iterator<String> itor = fileMap.keySet().iterator();
|
while (itor.hasNext()) {
|
String key = itor.next();
|
PRMItem prm = fileMap.get(key);
|
String customCls = prm.getItemCustomClass();
|
if(customCls == null || "".equals(customCls)){
|
customCls = "plm.portal.custom.CustomFileInterceptor";
|
}
|
executeSetCustomValue(customCls, key, fileMap, datas);
|
}
|
} catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
}
|
