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.List;
import java.util.Map;

import org.dom4j.DocumentException;
import org.dom4j.DocumentHelper;

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.constants.QueryConditionConstants;
import com.vci.client.refquery.PLMReferenceQueryFacade;
import com.vci.common.portal.constants.PRMConstants;
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.QTConstants;
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.data.LinkObject;
import com.vci.corba.omd.qtm.QTInfo;
import com.vci.corba.portal.data.PortalVI;
import com.vci.corba.query.data.BOAndLO;
import com.vci.corba.query.data.RefPath;

public class DataModelProcessor implements IDataModelProcessor{

	/**
	 * 根据输入参数自定义查询模板，根据自定义的查询模板获取符合条件的业务对象查询结果
	 * @param btmName，业务类型名称
	 * @param clauseList，返回的字段列表，暂时默认支持*
	 * @param queryChildrenFlag，是否查询子业务类型的数据
	 * @param rightFlag，是否根据数据授权过滤，true：进行数据授权过滤，false：不进行数据授权过滤
	 * @param queryCondition，查询条件map，即需要附加到业务类型的查询语句的查询条件
	 * @param version，1：当前版本当前版次；2代表当前版本最新版次；3：代表最新版本最新版次；4代表当前发布有效版
	 * @param pageInfo，分页信息，不需要分页时将其设为null即可，其包含两个属性：pageNO：页数和rowCount：当前页显示条数
	 * @param orderInfoList，排序信息，不需要是将其设置为null， 其包含三个属性：level:排序优先级，数越小越优先； orderField：排序字段名称;orderMode：属性ASC或DESC;
	 * @return
	 * @throws VCIError
	 * @throws DocumentException
	 */
	@Override
	public BusinessObject[] getBusinessObjectByCondition(String btmName, List<String> clauseList, boolean queryChildrenFlag, boolean rightFlag, 
			Map<String, String> queryCondition, int version, PageInfo pageInfo, List<OrderInfo> orderInfoList) throws VCIError {
			BusinessObject[] bos = null;
			try{
				QueryTemplate qt2 = new QueryTemplate();
				qt2.setId("btmQuery");
				qt2.setBtmType(btmName);
				qt2.setType("btm");
				clauseList = new ArrayList<String>();
				clauseList.add("*");
				qt2.setClauseList(clauseList);
				qt2.setQueryChildrenFlag(queryChildrenFlag);
				qt2.setRightFlag(rightFlag);
				qt2.setVersion(version);
				if (pageInfo != null && pageInfo.getPageNO() > 0 && pageInfo.getRowCount() > 0) {
					qt2.setPageInfo(pageInfo);
				}
				if (orderInfoList != null && orderInfoList.size() > 0) {
					qt2.setOrderInfoList(orderInfoList);
				}
				
				if (queryCondition != null && queryCondition.size() > 0) {
					Condition cond = OQTool.getCondition(queryCondition);
					qt2.setCondition(cond);
				}
				bos = QTClient.getService().findBTMObjects(qt2.getId(),  OQTool.qtTOXMl(qt2).asXML());
			}
			catch(VCIError vcie)
			{
				throw vcie;
			}
			catch(java.lang.Exception se)
			{
				se.printStackTrace();
				VCIError vcierror = new VCIError("",new String[]{se.getMessage()});
				throw vcierror;
			}
			return bos;
	}
	
	/**
	 * 自定义查询模板，根据查询条件查询符合条件的链接类型查询结果
	 * @param linkName，link名称
	 * @param clauseList，返回的字段列表，暂时默认支持*
	 * @param queryISLeaf，是否查询叶子节点，true代表查询，false代表不查询
	 * @param rightFlag，是否根据数据授权过滤，true：进行数据授权过滤，false：不进行数据授权过滤
	 * @param direction，查询方向，true代表正向查询，false代表反向查询
	 * @param queryCondition，是否查询子业务类型的数据
	 * @param version，1：当前版本当前版次；2代表当前版本最新版次；3：代表最新版本最新版次；4代表当前发布有效版
	 * @param pageInfo，分页信息，不需要分页时将其设为null即可，其包含两个属性：pageNO：页数和rowCount：当前页显示条数
	 * @param level，查询的层级，-1代表所有，其他数字代码查询的具体层数
	 * @param orderInfoList，排序信息，不需要是将其设置为null， 其包含三个属性：level:排序优先级，数越小越优先； orderField：排序字段名称;orderMode：属性ASC或DESC;
	 * @param recReturnMode，是否去重，true代表去重，false代表不去重
	 * @param objId，源对象ID
	 * @param btmType，查询目标对象的业务类型
	 * @return
	 * @throws VCIError
	 */
	@Override
	public LinkObject[] getLinkObjectByCondition(String linkName, List<String> clauseList, boolean queryISLeaf, boolean rightFlag, boolean direction,
			Map<String, String> queryCondition, int version, PageInfo pageInfo, int level, List<OrderInfo> orderInfoList, boolean recReturnMode, String btmType) throws VCIError {
		LinkObject[] linkObjects = null;
		try
		{
			QueryTemplate qt2 = new QueryTemplate();
			qt2.setId("ltQuery");
			qt2.setLinkType(linkName);
			qt2.setType("link");
			clauseList = new ArrayList<String>();
			clauseList.add("*");
			qt2.setClauseList(clauseList);
			qt2.setQueryISLeaf(queryISLeaf);
			qt2.setRightFlag(rightFlag);
			qt2.setBtmType(btmType);
			
			if(direction){
				qt2.setDirection(QTConstants.DIRECTION_POSITIVE);
			}else{
				qt2.setDirection(QTConstants.DIRECTION_OPPOSITE);
			}
			if (pageInfo != null && pageInfo.getPageNO() > 0 && pageInfo.getRowCount() > 0) {
				qt2.setPageInfo(pageInfo);
			}
			if (orderInfoList != null && orderInfoList.size() > 0) {
				qt2.setOrderInfoList(orderInfoList);
			}
			if (queryCondition != null && queryCondition.size() > 0) {
				Condition cond = OQTool.getCondition(queryCondition);
				qt2.setCondition(cond);
			}
			
			qt2.setVersion(version);
			qt2.setLevel(level);
			if (recReturnMode) {
				qt2.setRecReturnMode(1);
			} else {
				qt2.setRecReturnMode(2);
			}
			
			linkObjects = QTClient.getService().findLTObjects(qt2.getId(), OQTool.qtTOXMl(qt2).asXML());
		}
		catch(VCIError vcie)
		{
			throw vcie;
		}
		catch(java.lang.Exception se)
		{
			VCIError vcierror = new VCIError("",new String[]{se.getMessage()});
			throw vcierror;
		}
		return linkObjects;
	}
	
	/**
	 * 自定义查询模板，根据查询条件查询符合条件的业务对象和链接类型查询结果
	 * @param linkName，link名称
	 * @param clauseList，返回的字段列表，暂时默认支持*
	 * @param queryISLeaf，是否查询叶子节点，true代表查询，false代表不查询
	 * @param rightFlag，是否根据数据授权过滤，true：进行数据授权过滤，false：不进行数据授权过滤
	 * @param direction，查询方向，true代表正向查询，false代表反向查询
	 * @param queryCondition，是否查询子业务类型的数据
	 * @param version，1：当前版本当前版次；2代表当前版本最新版次；3：代表最新版本最新版次；4代表当前发布有效版
	 * @param pageInfo，分页信息，不需要分页时将其设为null即可，其包含两个属性：pageNO：页数和rowCount：当前页显示条数
	 * @param level，查询的层级，-1代表所有，其他数字代码查询的具体层数
	 * @param orderInfoList，排序信息，不需要是将其设置为null， 其包含三个属性：level:排序优先级，数越小越优先； orderField：排序字段名称;orderMode：属性ASC或DESC;
	 * @param recReturnMode，是否去重，true代表去重，false代表不去重
	 * @param btmType，查询目标对象的业务类型
	 * @return
	 * @throws VCIError
	 */
	@Override
	public BOAndLO[] getBOLOsByCondition(String linkName, List<String> clauseList, boolean queryISLeaf, boolean rightFlag, boolean direction,
			Map<String, String> queryCondition, int version, PageInfo pageInfo, int level, List<OrderInfo> orderInfoList, boolean recReturnMode, String btmType) throws VCIError {
		BOAndLO[]  bolos = null;
		try
		{
		QueryTemplate qt2 = new QueryTemplate();
		qt2.setId("ltQuery");
		qt2.setLinkType(linkName);
		qt2.setType("link");
		clauseList = new ArrayList<String>();
		clauseList.add("*");
		qt2.setClauseList(clauseList);
		qt2.setQueryISLeaf(queryISLeaf);
		qt2.setRightFlag(rightFlag);
		qt2.setBtmType(btmType);
		
		if(direction){
			qt2.setDirection(QTConstants.DIRECTION_POSITIVE);
		}else{
			qt2.setDirection(QTConstants.DIRECTION_OPPOSITE);
		}
		if (pageInfo != null && pageInfo.getPageNO() > 0 && pageInfo.getRowCount() > 0) {
			qt2.setPageInfo(pageInfo);
		}
		if (orderInfoList != null && orderInfoList.size() > 0) {
			qt2.setOrderInfoList(orderInfoList);
		}
		if (queryCondition != null && queryCondition.size() > 0) {
			Condition cond = OQTool.getCondition(queryCondition);
			qt2.setCondition(cond);
		}
		
		qt2.setVersion(version);
		qt2.setLevel(level);
		if (recReturnMode) {
			qt2.setRecReturnMode(1);
		} else {
			qt2.setRecReturnMode(2);
		}
		
		bolos = QTClient.getService().getBOAndLOS(qt2.getId(), OQTool.qtTOXMl(qt2).asXML(), "");
		}
		catch(VCIError vcie)
		{
			throw vcie;
		}
		catch(java.lang.Exception se)
		{
			VCIError vcierror = new VCIError("",new String[]{se.getMessage()});
			throw vcierror;
		}
		return bolos;
	}
	
	/**
	 * 根据查询模板及附加条件查询业务对象
	 * @param queryTemplate，查询模板名称
	 * @param replaceMap，替换属性map
	 * @param conditionMap，查询条件map
	 * @param pageInfo，分页信息，其包含两个属性：pageNO：页数和rowCount：当前页显示条数
	 * @return
	 * @throws VCIError
	 * @throws DocumentException
	 */
	@Override
	public BusinessObject[] getBusinessObjectByQueryTemplate(String queryTemplate, Map<String, String> replaceMap, Map<String, String> conditionMap, PageInfo pageInfo) throws VCIError {
		BusinessObject[] v = null;
		try
		{
			QueryTemplate qt_ = getCustomQt(queryTemplate, replaceMap, conditionMap, pageInfo);
			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;
	}
	
	/**
	 * 根据查询模板及附加条件查询业务对象
	 * @param queryTemplate，查询模板名称
	 * @param replaceMap，替换属性map
	 * @param conditionMap，查询条件map
	 * @param pageInfo，分页信息，其包含两个属性：pageNO：页数和rowCount：当前页显示条数
	 * @param orderInfos: 排序信息
	 * @return
	 * @throws VCIError
	 * @throws DocumentException
	 */
	@Override
	public BusinessObject[] getBusinessObjectByQueryTemplate(String queryTemplate, Map<String, String> replaceMap, Map<String, String> conditionMap, PageInfo pageInfo, List<OrderInfo> orderInfos) throws VCIError {
		BusinessObject[] v = null;
		try
		{
		QueryTemplate qt_ = getCustomQt(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;
	}
	
	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;
	}
	
	/**
	 * ADD BY ZhongGY
	 * @Title		:getBusinessObjectByQueryTemplate
	 * @Description	:直接根据查询模板查询数据 
	 * @param qt_
	 * @return
	 * @throws VCIError
	 */
	public BusinessObject[] getBusinessObjectByQueryTemplate(QueryTemplate qt_) throws VCIError {
		BusinessObject[] v = null;
		try
		{
		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;
	}
	
	/**
	 * 根据查询模板查询符合要求的link对象
	 * @param queryTemplate，查询模板
	 * @param replaceMap，替换map，
	 * @param conditionMap，附件的查询条件
	 * @param pageInfo，分页信息，其包含两个属性：pageNO：页数和rowCount：当前页显示条数
	 * @return
	 * @throws VCIError
	 * @throws DocumentException
	 */
	@Override
	public LinkObject[] getLinkObjectByQueryTemplate(String queryTemplate, Map<String, String> replaceMap, Map<String, String> conditionMap, PageInfo pageInfo) throws VCIError {
		LinkObject[] linkObjects = null;
		try
		{
		QueryTemplate qt_ = getCustomQt(queryTemplate, replaceMap, conditionMap, pageInfo);
		linkObjects = QTClient.getService().findLTObjects(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 linkObjects;
	}
	
	/**
	 * 根据查询模板查询符合要求的业务对象和链接对象
	 * @param queryTemplate，查询模板
	 * @param replaceMap，替换map，
	 * @param conditionMap，附件的查询条件
	 * @param pageInfo，分页信息，其包含两个属性：pageNO：页数和rowCount：当前页显示条数
	 * @return
	 * @throws VCIError
	 * @throws DocumentException
	 */
	@Override
	public BOAndLO[] getBOLOsByQueryTemplate(String queryTemplate, Map<String, String> replaceMap, Map<String, String> conditionMap, PageInfo pageInfo) throws VCIError {
		BOAndLO[] bolos = null;
		try
		{
		QueryTemplate qt_ = getCustomQt(queryTemplate, replaceMap, conditionMap, pageInfo);
		bolos = QTClient.getService().getBOAndLOS(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 bolos;
	}
	
	/**
	 * 根据查询模板查询符合要求的业务对象和链接对象
	 * @param queryTemplate，查询模板
	 * @param replaceMap，替换map，
	 * @param conditionMap，附件的查询条件
	 * @param pageInfo，分页信息，其包含两个属性：pageNO：页数和rowCount：当前页显示条数
	 * @return
	 * @throws VCIError
	 * @throws DocumentException
	 */
	@Override
	public BOAndLO[] getBOLOsByQueryTemplate(String queryTemplate, Map<String, String> replaceMap, Map<String, String> conditionMap, PageInfo pageInfo, List<OrderInfo> orderInfos) throws VCIError {
		BOAndLO[] bolos = null;
		try
		{
		QueryTemplate qt_ = getCustomQt(queryTemplate, replaceMap, conditionMap, pageInfo, orderInfos);
		bolos = QTClient.getService().getBOAndLOS(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 bolos;
	}
	
	@Override
	public Map<String, String> getFormColumnMap(PortalVI formDef) {
		Map<String, String> colMap = new LinkedHashMap<String, String>();
		PRM sheetPrm = UITools.getPRM(formDef.prm);
		for (int i = 0; i < sheetPrm.getPrmItemList().size(); i++) {
			String key = sheetPrm.getPrmItemList().get(i).getItemField();
			colMap.put(key, sheetPrm.getPrmItemList().get(i).getItemName());
		}
		
		return colMap;
	}
	
	@Override
	public String getTableQueryTemplate(PRM prm) {
		return prm.getPrmItemList().get(0).getItemQtName();
	}

	@Override
	public Map<String, String> getSheetColumnMap(PortalVI formDef,
			String[] tableCol) {
		Map<String, String> colMap = new LinkedHashMap<String, String>();
		for (int i = 0; i < tableCol.length; i++) {
			String key = tableCol[i];
			String value = getSheetColumnName(key, formDef);
			colMap.put(tableCol[i], value);
		}
		
		return colMap;
	}
	
	/**
	 * 根据主键获取对应的名称
	 * 
	 * @param key
	 * @param formDef
	 * @return
	 */
	private String getSheetColumnName(String key, PortalVI formDef) {
		PRM sheetPrm = UITools.getPRM(formDef.prm);
		for (int i = 0; i < sheetPrm.getPrmItemList().size(); i++) {
			String ckey = sheetPrm.getPrmItemList().get(i).getItemField();
			if (ckey.equals(key)) {
				return sheetPrm.getPrmItemList().get(i).getItemName();
			}
		}
		return "";
	}

	@Override
	public String getSelectDisplayValue(String key, String value, List<String> selectValues) {
		for (int i = 0; i < selectValues.size(); i++) {
			String valueStr = selectValues.get(i);
			String ckey = valueStr.substring(0, valueStr.indexOf("{"));
			String cvalue = valueStr.substring(valueStr.indexOf("{") + 1, valueStr.indexOf("}"));
			if (value.equals(cvalue)) {
				return ckey;
			}
		}
		return value;
	}

	@Override
	public Map<String, PRMItem> getMultiFileCol(PortalVI formDef) {
		Map<String, PRMItem> multiFiles = new HashMap<String, PRMItem>();
		PRM sheetPrm = UITools.getPRM(formDef.prm);
		for (int i = 0; i < sheetPrm.getPrmItemList().size(); i++) {
			String key = sheetPrm.getPrmItemList().get(i).getItemField();
			if (sheetPrm.getPrmItemList().get(i).getItemType().equalsIgnoreCase(PRMConstants.MULTIFILE)) {
				multiFiles.put(key, sheetPrm.getPrmItemList().get(i));
			}
		}
		return multiFiles;
	}
	
	@Override
	public Map<String, PRMItem> getFileCol(PortalVI formDef) {
		Map<String, PRMItem> files = new HashMap<String, PRMItem>();
		PRM sheetPrm = UITools.getPRM(formDef.prm);
		for (int i = 0; i < sheetPrm.getPrmItemList().size(); i++) {
			String key = sheetPrm.getPrmItemList().get(i).getItemField();
			if (sheetPrm.getPrmItemList().get(i).getItemType().equalsIgnoreCase(PRMConstants.MULTIFILE)
					|| sheetPrm.getPrmItemList().get(i).getItemType().equalsIgnoreCase("file")) {
				files.put(key, sheetPrm.getPrmItemList().get(i));
			}
		}
		return files;
	}

	@Override
	public Map<String, PRMItem> getCustomCol(PortalVI formDef) {
		Map<String, PRMItem> customCols = new HashMap<String, PRMItem>();
		PRM sheetPrm = UITools.getPRM(formDef.prm);
		for (int i = 0; i < sheetPrm.getPrmItemList().size(); i++) {
			String key = sheetPrm.getPrmItemList().get(i).getItemField();
			if (sheetPrm.getPrmItemList().get(i).getItemType().equalsIgnoreCase(PRMConstants.CUSTOM)) {
				customCols.put(key, sheetPrm.getPrmItemList().get(i));
			}
		}
		
		return customCols;
	}

	@Override
	public Map<String, List<String>> getReferenceCol(Map<String, String> queryCol) {
		Map<String, List<String>> referenceKeyMap = new HashMap<String, List<String>>(); //引用首字段Map
		Iterator<String> itor =  queryCol.keySet().iterator();
		while (itor.hasNext()) {
			String key = itor.next();
			String[] keyArray = key.split("\\.");
			if (keyArray.length > 1) {
				List<String> refList = null;
				if (referenceKeyMap.get(keyArray[0]) == null) {
					refList = new ArrayList<String>();
				} else {
					refList = referenceKeyMap.get(keyArray[0]);
				}
				refList.add(key);
				referenceKeyMap.put(keyArray[0], refList);
			}
		}
		
		return referenceKeyMap;
	}


	@Override
	public String getFormQueryTemplate(PRM prm) {
		return prm.getFormQtName();
	}
	
	public static void main(String[] args) {
		DataModelProcessor p = new DataModelProcessor();
//		String queryTemplate = "ProductQueryPartsTemplate";
		Map<String, String> replaceMap = new HashMap<String, String>();
		replaceMap.put("name_oid", "A389B604-5483-ABA1-D8D8-FA29DFC373DD");
		replaceMap.put("_TRAINSITIONOID", "81FAB5BF-969F-C549-BF80-88BC27B044FB");
		replaceMap.put("ISLASTR", "1");
		replaceMap.put("f_oid", "81FAB5BF-969F-C549-BF80-88BC27B044FB");
		replaceMap.put("ISLASTV", "1");
		replaceMap.put("type", "Parts");
		
		Map<String, String> queryCondition = new HashMap<String, String>();
		queryCondition.put("T_OID", "37EDEC00-F3A6-A4D5-23E7-D06846FAB51D");
		try {
//			LinkObject[] los = p.getLinkObjectByQueryTemplate(queryTemplate, replaceMap);
//			BOAndLO[] bolos = p.getBOLOsByCondition("EBOM", null, false, false, false, true, queryCondition, 1, null, 1, null, true, "37EDEC00-F3A6-A4D5-23E7-D06846FAB51D", "*");
			BusinessObject[] bos = p.getBusinessObjectByCondition("part", null, true, false, queryCondition, 1, null, null);
//			LinkObject[] los = p.getLinkObjectByCondition("EBOM", null, false, false, false, queryCondition, 1, null, 1, null, true, "37EDEC00-F3A6-A4D5-23E7-D06846FAB51D", "part");
			//System.out.println(bos.length);
		} catch (VCIError e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	@Override
	public int getObjectCountByTemplate(String queryTemplate, Map<String, String> replaceMap, Map<String, String> conditionMap) throws VCIError {
		int count = 0;
		try
		{
			QueryTemplate qt_ = getCustomQt(queryTemplate, replaceMap, conditionMap);
			count = (int)QTClient.getService().findTotalCount(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 count;
	}
	
	@Override
	public LinkObject[] getLinkObjectByQueryTemplate(String queryTemplate, Map<String, String> replaceMap, Map<String, String> conditionMap) throws VCIError {
		LinkObject[] linkObjects = null;
		
		try
		{
		QueryTemplate qt_ = getCustomQt(queryTemplate, replaceMap, conditionMap);
		linkObjects = QTClient.getService().findLTObjects(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 linkObjects;
	}

	@Override
	public LinkObject[] getLinkObjectByQueryTemplate(String queryTemplate, Map<String, String> replaceMap) throws VCIError, DocumentException {
		LinkObject[] linkObjects = null;
		try{
		QTInfo wrapper = ServiceProvider.getOMDService().getQTDService().getQT(queryTemplate);
		QueryTemplate qt = OQTool.getQTByDoc(DocumentHelper.parseText(wrapper.qtText), queryTemplate);
		PageInfo pageInfo = null;
		if(replaceMap.containsKey(QueryConditionConstants.PAGESIZE) && replaceMap.containsKey(QueryConditionConstants.PAGENO)){
			int pageSize = Integer.valueOf(replaceMap.get(QueryConditionConstants.PAGESIZE));
			int pageNO = Integer.valueOf(replaceMap.get(QueryConditionConstants.PAGENO));
			replaceMap.remove(QueryConditionConstants.PAGESIZE);
			replaceMap.remove(QueryConditionConstants.PAGENO);
			pageInfo = new PageInfo();
			pageInfo.setPageNO(pageNO);
			pageInfo.setRowCount(pageSize);
		}
		QueryTemplate qt_ = OQTool.replaceQTValues(qt, replaceMap);
		if(pageInfo != null){
			qt_.setPageInfo(pageInfo);
		}
		linkObjects = QTClient.getService().findLTObjects(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 linkObjects;
	}
	
	@Override
	public LinkObject[] getLinkObjectByCondition(Map<String, String> conditions, boolean direction) throws VCIError {
		if (conditions == null || conditions.size() == 0) {
			return null;
		}
		LinkObject[] linkObjects = null;
		try
		{
		QueryTemplate qt2 = new QueryTemplate();
		qt2.setId("ltQuery");
		qt2.setLinkType(conditions.get(QueryConditionConstants.LO_TYPE));
		qt2.setType("link");
		List<String> clauseList = new ArrayList<String>();
		clauseList.add("*");
		qt2.setClauseList(clauseList);
		String queryType = conditions.get(QueryConditionConstants.BO_TYPE);
		String fromOrToOid = conditions.get(QueryConditionConstants.FROM_OR_TO_OID);
		conditions.remove(QueryConditionConstants.BO_TYPE);
		conditions.remove(QueryConditionConstants.LO_TYPE);
		conditions.remove(QueryConditionConstants.FROM_OR_TO_OID);
		if(direction){
			qt2.setDirection(QTConstants.DIRECTION_POSITIVE);
		}else{
			qt2.setDirection(QTConstants.DIRECTION_OPPOSITE);
		}
		if(conditions.containsKey(QueryConditionConstants.PAGESIZE) && conditions.containsKey(QueryConditionConstants.PAGENO)){
			int pageSize = Integer.valueOf(conditions.get(QueryConditionConstants.PAGESIZE));
			int pageNO = Integer.valueOf(conditions.get(QueryConditionConstants.PAGENO));
			conditions.remove(QueryConditionConstants.PAGESIZE);
			conditions.remove(QueryConditionConstants.PAGENO);
			PageInfo pageInfo = new PageInfo();
			pageInfo.setPageNO(pageNO);
			pageInfo.setRowCount(pageSize);
			qt2.setPageInfo(pageInfo);
		}
		Condition cond = OQTool.getConditionForLink(qt2.getDirection(), fromOrToOid, queryType, conditions);
		qt2.setCondition(cond);
		
		linkObjects = QTClient.getService().findLTObjects(qt2.getId(), OQTool.qtTOXMl(qt2).asXML());
		}
		catch(VCIError vcie)
		{
			throw vcie;
		}
		catch(java.lang.Exception se)
		{
			VCIError vcierror = new VCIError("",new String[]{se.getMessage()});
			throw vcierror;
		}
		return linkObjects;
	}
	
	@Override
	public BusinessObject[] getBusinessObjectByQueryTemplate(String queryTemplate, Map<String, String> replaceMap, Map<String, String> conditionMap) throws VCIError, DocumentException {
		BusinessObject[] v = null;
		try
		{
		QueryTemplate qt_ = getCustomQt(queryTemplate, replaceMap, conditionMap);
		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;
	}
	
	/**
	 * 根据传递的参数构建新的查询模版
	 * @param queryTemplate
	 * @param replaceMap
	 * @param conditionMap
	 * @return
	 * @throws VCIError
	 * @throws DocumentException
	 */
	private QueryTemplate getCustomQt(String queryTemplate, Map<String, String> replaceMap, Map<String, String> conditionMap) throws VCIError, DocumentException {
		QueryTemplate qt_ = null;
		try
		{
		QTInfo wrapper = ServiceProvider.getOMDService().getQTDService().getQT(queryTemplate);
		QueryTemplate qt = OQTool.getQTByDoc(DocumentHelper.parseText(wrapper.qtText), queryTemplate);
		PageInfo pageInfo = null;
		if(replaceMap != null && replaceMap.containsKey(QueryConditionConstants.PAGESIZE) && replaceMap.containsKey(QueryConditionConstants.PAGENO)){
			int pageSize = Integer.valueOf(replaceMap.get(QueryConditionConstants.PAGESIZE));
			int pageNO = Integer.valueOf(replaceMap.get(QueryConditionConstants.PAGENO));
			replaceMap.remove(QueryConditionConstants.PAGESIZE);
			replaceMap.remove(QueryConditionConstants.PAGENO);
			pageInfo = new PageInfo();
			pageInfo.setPageNO(pageNO);
			pageInfo.setRowCount(pageSize);
		}
		qt_ = OQTool.replaceQTValues(qt, replaceMap);
		if (conditionMap != null && conditionMap.size() > 0) {
			Condition condition = OQTool.getCondition(conditionMap);
			Condition mergeCondition = OQTool.mergeCondition(qt_.getCondition(), condition, Connector.AND);
			qt_.setCondition(mergeCondition);
		}
		if(pageInfo != null){
			qt_.setPageInfo(pageInfo);
		}
		}
		catch(VCIError vcie)
		{
			throw vcie;
		}
		catch(java.lang.Exception se)
		{
			VCIError vcierror = new VCIError("",new String[]{se.getMessage()});
			throw vcierror;
		}
		return qt_;
	}
	
	/**
	 *  根据传递的参数构建新的查询模版
	 * @param queryTemplate, 查询模板
	 * @param replaceMap，替换map
	 * @param conditionMap，查询条件
	 * @param pageInfo，分页信息，其包含两个属性：pageNO：页数和rowCount：当前页显示条数
	 * @return
	 * @throws VCIError
	 * @throws DocumentException
	 */
	 QueryTemplate getCustomQt(String queryTemplate, Map<String, String> replaceMap, Map<String, String> conditionMap, PageInfo pageInfo) 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) {
			Condition condition = OQTool.getCondition(conditionMap);
			Condition mergeCondition = OQTool.mergeCondition(qt_.getCondition(), condition, Connector.AND);
			qt_.setCondition(mergeCondition);
		}
		if(pageInfo != null){
			qt_.setPageInfo(pageInfo);
		}
		}
		catch(VCIError vcie)
		{
			throw vcie;
		}
		catch(java.lang.Exception se)
		{
			VCIError vcierror = new VCIError("",new String[]{se.getMessage()});
			throw vcierror;
		}
		return qt_;
	}
	 
	/**
	 * 根据传递的参数构建新的查询模版
	 * 
	 * @param queryTemplate, 查询模板
	 * @param replaceMap，替换map
	 * @param conditionMap，查询条件
	 * @param pageInfo，分页信息，其包含两个属性：pageNO：页数和rowCount：当前页显示条数
	 * @param orderInfos: 排序信息
	 * @return
	 * @throws VCIError
	 * @throws DocumentException
	 */ 
	public QueryTemplate getCustomQt(String queryTemplate, Map<String, String> replaceMap, Map<String, String> conditionMap, PageInfo pageInfo, List<OrderInfo> orderInfos) throws VCIError {
		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) {
			Condition condition = OQTool.getCondition(conditionMap);
			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_;	
	}
	
	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_;	
	}
	
	@Override
	public BusinessObject[] getBusinessObjectByQueryTemplate(String queryTemplate, Map<String, String> replaceMap) throws VCIError, DocumentException {
		BusinessObject[] v = null;
		try
		{
		QTInfo wrapper = ServiceProvider.getOMDService().getQTDService().getQT(queryTemplate);
		if (replaceMap != null && replaceMap.size() > 0){
			QueryTemplate qt = OQTool.getQTByDoc(DocumentHelper.parseText(wrapper.qtText), queryTemplate);
			PageInfo pageInfo = null;
			if(replaceMap.containsKey(QueryConditionConstants.PAGESIZE) && replaceMap.containsKey(QueryConditionConstants.PAGENO)){
				int pageSize = Integer.valueOf(replaceMap.get(QueryConditionConstants.PAGESIZE));
				int pageNO = Integer.valueOf(replaceMap.get(QueryConditionConstants.PAGENO));
				replaceMap.remove(QueryConditionConstants.PAGESIZE);
				replaceMap.remove(QueryConditionConstants.PAGENO);
				pageInfo = new PageInfo();
				pageInfo.setPageNO(pageNO);
				pageInfo.setRowCount(pageSize);
			}
			QueryTemplate qt_ = OQTool.replaceQTValues(qt, replaceMap);
			if(pageInfo != null){
				qt_.setPageInfo(pageInfo);
			}
			v = QTClient.getService().findBTMObjects(qt.getId(), OQTool.qtTOXMl(qt_).asXML());
		} else {
			v = QTClient.getService().findBTMObjects(wrapper.qtName, wrapper.qtText);
		}
		}
		catch(VCIError vcie)
		{
			throw vcie;
		}
		catch(java.lang.Exception se)
		{
			VCIError vcierror = new VCIError("",new String[]{se.getMessage()});
			throw vcierror;
		}
		return v;
	}
	
	@Override
	public BusinessObject[] getBusinessObjectByCondition(Map<String, String> conditions) throws VCIError {
		BusinessObject[] bos = null;
		try
		{
		QueryTemplate qt2 = new QueryTemplate();
		qt2.setId("btmQuery");
		qt2.setBtmType(conditions.get(QueryConditionConstants.BO_TYPE));
		qt2.setType("btm");
		List<String> clauseList = new ArrayList<String>();
		clauseList.add("*");
		qt2.setClauseList(clauseList);
		conditions.remove(QueryConditionConstants.BO_TYPE);
		if(conditions.containsKey(QueryConditionConstants.PAGESIZE) && conditions.containsKey(QueryConditionConstants.PAGENO)){
			int pageSize = Integer.valueOf(conditions.get(QueryConditionConstants.PAGESIZE));
			int pageNO = Integer.valueOf(conditions.get(QueryConditionConstants.PAGENO));
			conditions.remove(QueryConditionConstants.PAGESIZE);
			conditions.remove(QueryConditionConstants.PAGENO);
			PageInfo pageInfo = new PageInfo();
			pageInfo.setPageNO(pageNO);
			pageInfo.setRowCount(pageSize);
			qt2.setPageInfo(pageInfo);
		}
		Condition cond = OQTool.getCondition(conditions);
		qt2.setCondition(cond);
		bos = QTClient.getService().findBTMObjects(qt2.getId(),  OQTool.qtTOXMl(qt2).asXML());
		}
		catch(VCIError vcie)
		{
			throw vcie;
		}
		catch(java.lang.Exception se)
		{
			VCIError vcierror = new VCIError("",new String[]{se.getMessage()});
			throw vcierror;
		}
		return bos;
	}
	
	@Override
	public Map<String, String> getQueryBusinessObjectCondition(String type, Map<String, Map<String, String>> rowRefMap, Map<String, List<String>> referenceKeyMap) {
		Map<String, String> queryMap = new LinkedHashMap<String, String>();
		Iterator<String> itor = rowRefMap.keySet().iterator();
		boolean isFirstRow = true;
		
		while (itor.hasNext()) {
			String key = itor.next();
			Map<String, String> instanceMap = rowRefMap.get(key);
			Iterator<String> citor = instanceMap.keySet().iterator();
			while (citor.hasNext()) {
				String ckey = citor.next();
				String cVal = instanceMap.get(ckey);
				if (cVal == null) {
					cVal = "";
				}
				List<String> list = referenceKeyMap.get(ckey);
				if (list == null || list.size() == 0) {
					continue;
				}
				if (isFirstRow) {
					queryMap.put(ckey, type + "." + ckey + "=" + cVal);
				} else {
					queryMap.put(ckey, queryMap.get(ckey) + "," + cVal); 
				}
				for (int i = 0; i < list.size(); i++) {
					if (isFirstRow) {
						queryMap.put(list.get(i), type + "." + list.get(i) + "=" + cVal);
					} else {
						queryMap.put(list.get(i), queryMap.get(list.get(i)) + "," + cVal); 
					}
				}
			}
			isFirstRow = false;
		}
		itor = queryMap.keySet().iterator();
		ArrayList<String> emptyValKey = new ArrayList<String>();
		while (itor.hasNext()) {
			String key = itor.next();
			String value = queryMap.get(key);
			String[] values = value.split("=");
			if (values.length == 1) {
				emptyValKey.add(key);
			} else {
				int repeatTime = computerStrAppearTimes(values[1], ",");
				if (values[1].length() == repeatTime) {
					emptyValKey.add(key);
				} else if (values[1].lastIndexOf(",") + 1 == values[1].length()) {
					value = connectStr(values[1].split(","), ",");
					queryMap.put(key, new StringBuffer(values[0]).append("=").append(value).toString());
				}
			}
		}
		for (int i = 0; i < emptyValKey.size(); i++) {
			queryMap.remove(emptyValKey.get(i));
		}
		return queryMap;
	}
	
	private int computerStrAppearTimes(String source, String str) {
		if (source == null || source.length() == 0) {
			return 0;
		}
		int sLen = source.length();
		String des = source.replaceAll(str, "##");
		int dLen = des.length();
		return dLen - sLen;
	}
	
	private String connectStr(String[] values, String split) {
		StringBuffer buffer = new StringBuffer();
		for (int i = 0; i < values.length; i++) {
			if (i != 0) {
				buffer.append(split);
			}
			buffer.append(values[i]);
		}
		return buffer.toString();
	}
	
	@Override
	public Map<String, String> getQueryLinkObjectCondition(String linkType, Map<String, String> rowKeyMap, Map<String, String> rowRefMap, Map<String, List<String>> referenceKeyMap) {
		Map<String, String> queryMap = new LinkedHashMap<String, String>();
		Iterator<String> itor = rowKeyMap.keySet().iterator();
		boolean isFirstRow = true;
		
		while (itor.hasNext()) {
			String rowKey = itor.next();
			String id = rowKeyMap.get(rowKey);
			String key = rowRefMap.get(id);
			List<String> list = referenceKeyMap.get(key);
			if (list == null || list.size() == 0) {
				continue;
			}
			
			if (isFirstRow) {
				queryMap.put(key, linkType + "." + key + "=" + id);
			} else {
				queryMap.put(key, queryMap.get(key) + "," + id); 
			}
			
			for (int i = 0; i < list.size(); i++) {
				if (isFirstRow) {
					queryMap.put(list.get(i), linkType + "." + list.get(i) + "=" + id); 
				} else {
					queryMap.put(list.get(i), queryMap.get(list.get(i)) + "," + id); 
				}
			}
			isFirstRow = false;
		}
		return queryMap;
	}
	
	@Override
	public RefPath[] queryReference(Map<String, String> map, String typeName) {
		PLMReferenceQueryFacade facade = new PLMReferenceQueryFacade();
		try {
			List<String> queryList = new ArrayList<String>();
			Iterator<String> itor = map.keySet().iterator();
			while(itor.hasNext()) {
				queryList.add(map.get(itor.next()));
			}
			RefPath[] refPath = facade.query(queryList.toArray(new String[queryList.size()]), typeName);
			return refPath;
		} catch (Throwable e) {
			e.printStackTrace();
		}
		return null;
	}
	
	@Override
	public RefPath[] queryReference(Map<String, String> map, String[] typeNames) {
		PLMReferenceQueryFacade facade = new PLMReferenceQueryFacade();
		try {
			List<String> queryList = new ArrayList<String>();
			Iterator<String> itor = map.keySet().iterator();
			while(itor.hasNext()) {
				queryList.add(map.get(itor.next()));
			}
			RefPath[] refPath = facade.query(queryList.toArray(new String[queryList.size()]), typeNames);
			return refPath;
		} catch (Throwable e) {
			e.printStackTrace();
		}
		return null;
	}
}